jucai/app/Services/Company/ServiceService.php

<?php
/**
 * Created by PhpStorm.
 * User: wuzhenke
 * Date: 2018/11/28
 * Time: 16:43
 */

namespace App\Services\Company;

use App\Exceptions\ResponseException;
use App\Models\Company;
use App\Models\Jobs;
use App\Models\MembersSetmeal;
use App\Models\Tpl;
use App\Repositories\CompanyRepository;
use App\Repositories\JobsRepository;
use App\Repositories\MemberHandselRepository;
use App\Repositories\MemberLogRepository;
use App\Repositories\MemberPointRepository;
use App\Repositories\MembersChargeLogRepository;
use App\Repositories\MemberSetmealRepository;
use App\Repositories\MembersSetmealLogRepository;
use App\Repositories\OrderRepository;
use App\Repositories\PaymentRepository;
use App\Repositories\QueueAutoRefreshRepository;
use App\Repositories\SetmealIncrementsRepository;
use App\Repositories\SetmealRepository;
use App\Repositories\TaskLogRepository;
use App\Repositories\TaskRepository;
use App\Services\Common\MembersSetmealRecordService;
use App\Services\Common\PayService;
use Carbon\Carbon;
use Illuminate\Contracts\Encryption\EncryptException;
use Illuminate\Support\Facades\DB;
use App\Repositories\TplRepository;
use App\Repositories\MemberSetmealRecordRepository;
use Illuminate\Support\Facades\Log;

class ServiceService
{

    protected $taskRepository;
    protected $memberPointRepository;
    protected $taskLogRepository;
    protected $memberHandselRepository;
    protected $memberSetmealRepository;
    protected $jobsRepository;
    protected $setmealRepository;
    protected $paymentRepository;
    protected $orderRepository;
    protected $memberLogRepository;
    protected $membersChargeLogRepository;
    protected $companyRepository;
    protected $membersSetmealLogRepository;
    protected $setmealIncrementsRepository;
    protected $queueAutoRefreshRepository;
    protected $tplRepository;
    protected $memberSetmealRecordRepository;

    /**
     * ServiceService constructor.
     * @param $taskRepository
     * @param $memberPointRepository
     * @param $taskLogRepository
     * @param $memberHandselRepository
     * @param $memberSetmealRepository
     * @param $jobsRepository
     * @param $setmealRepository
     * @param $paymentRepository
     * @param $orderRepository
     * @param $memberLogRepository
     * @param $membersChargeLogRepository
     * @param $companyRepository
     * @param $membersSetmealLogRepository
     * @param $setmealIncrementsRepository
     * @param $queueAutoRefreshRepository
     * @param $tplRepository
     *
     */

    public function __construct(TaskRepository $taskRepository,TplRepository $tplRepository,  QueueAutoRefreshRepository $queueAutoRefreshRepository,  SetmealIncrementsRepository $setmealIncrementsRepository,  MembersSetmealLogRepository $membersSetmealLogRepository,  CompanyRepository $companyRepository,  MembersChargeLogRepository $membersChargeLogRepository,  MemberLogRepository $memberLogRepository,  OrderRepository $orderRepository,  PaymentRepository $paymentRepository,  SetmealRepository $setmealRepository,  JobsRepository $jobsRepository,  MemberSetmealRepository $memberSetmealRepository,  MemberPointRepository $memberPointRepository,  TaskLogRepository $taskLogRepository, MemberHandselRepository $memberHandselRepository,MemberSetmealRecordRepository $memberSetmealRecordRepository,MembersSetmealRecordService $membersSetmealRecordService){
        $this->taskRepository = $taskRepository;
        $this->memberPointRepository = $memberPointRepository;
        $this->taskLogRepository = $taskLogRepository;
        $this->memberHandselRepository = $memberHandselRepository;
        $this->memberSetmealRepository = $memberSetmealRepository;
        $this->jobsRepository = $jobsRepository;
        $this->setmealRepository = $setmealRepository;
        $this->paymentRepository = $paymentRepository;
        $this->orderRepository = $orderRepository;
        $this->memberLogRepository = $memberLogRepository;
        $this->membersChargeLogRepository = $membersChargeLogRepository;
        $this->companyRepository = $companyRepository;
        $this->membersSetmealLogRepository = $membersSetmealLogRepository;
        $this->setmealIncrementsRepository = $setmealIncrementsRepository;
        $this->queueAutoRefreshRepository = $queueAutoRefreshRepository;
        $this->tplRepository = $tplRepository;
        $this->memberSetmealRecordRepository=$memberSetmealRecordRepository;
        $this->membersSetmealRecordService=$membersSetmealRecordService;
    }

    public function index($user)
    {
        $mySetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);//套餐详细
        $condition['company_id'] = $user->id;
        $condition['display'] = 1;
        $condition['valid'] = 1;
        $condition[] = ['audit','<>',3];
        $jobsCount = $this->jobsRepository->jobsTotal($condition);

        $surplus_jobs = $mySetmeal->jobs_meanwhile-$jobsCount;
        $mySetmeal->jobs_meanwhile =$surplus_jobs>0?$surplus_jobs:0;
        if ($mySetmeal->endtime == 0) {
            $mySetmeal->leave_days = '永久';
        } else {
            $tmpday = ceil((strtotime($mySetmeal->endtime) - time())/86400);
            $minus = $tmpday<0?0:$tmpday;
            $mySetmeal->leave_days = intval($minus);
        }
        $setmeal = $this->setmealRepository->findWhere(['display' => 1]);//会员套餐
        foreach ($setmeal as $key => $val) {
            $setmeal[$key]->discount = $this->setmealRepository->getDiscountForSetmealOne($val);
            $setmeal[$key]->long = $val->days == 0 ? '永久' : $this->formatDays($val->days);
        }
        request()->offsetSet('id', $user->id);

        $setmealRecords=$this->membersSetmealRecordService->SetmealRecord(true);

        $this->freeSetmealIsOver($user);

        $result = [
            'user' => $user,
            'mySetmeal' => $mySetmeal,
            'setmeal' => $setmeal,
            'setmealRecord'=>$setmealRecords,
        ];
        return $result;
    }

    /**
     * 免费的会员是否过期了
     */
    public function freeSetmealIsOver($user){
        $mySetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);//套餐详细
        session(["setmeal_message"=>""]);

        if (strtotime($mySetmeal->endtime)<time() && $mySetmeal->endtime!=0){  //现在就判断到期时间了
            if (request('look')!=true){ //通过url来判断是否已经看过
                session(["setmeal_message"=>"提醒：您的套餐已到期，请及时到我的套餐处升级套餐"]);
            }

        }

    }

    /**
     * @param $request
     * @return array
     */
    public function setmealDetail($request, $user)
    {
        $mySetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);//套餐详细
        $condition['company_id'] = $user->id;
        $condition['display'] = 1;
        $condition['valid'] = 1;
        $condition[] = ['audit','<>',3];
        $jobsCount = $this->jobsRepository->jobsTotal($condition);
        $surplus_jobs = $mySetmeal->jobs_meanwhile-$jobsCount;
        $mySetmeal->jobs_meanwhile =$surplus_jobs>0?$surplus_jobs:0;
        if ($mySetmeal->endtime == 0) {
            $mySetmeal->leave_days = '永久';
        } else {
            $tmpday = ceil((strtotime($mySetmeal->endtime) - time())/86400);
            $minus = $tmpday<0?0:$tmpday;
            $mySetmeal->leave_days = intval($minus);
        }
        $setmeal = $this->setmealRepository->findWhere(['display' => 1]);//会员套餐
        foreach ($setmeal as $key => $val) {
            $setmeal[$key]->discount = $this->setmealRepository->getDiscountForSetmealOne($val);
            $setmeal[$key]->long = $val->days == 0 ? '永久' : $this->formatDays($val->days);
        }
        $starttime = isset($request['starttime'])?$request['starttime']:date('Y-m-d', time()-30*86400);
        $endtime = isset($request['endtime'])?$request['endtime']:date('Y-m-d', time());
        $where= [
            ['created_at','>=',$starttime." 23:10:10"],
            ['created_at','<=',$endtime." 23:10:10"],
            ['log_uid','=',$user->id],
            ['log_utype','=',$user->utype],
        ];
        $setmealDetail = $this->membersSetmealLogRepository->membersSetmealLog($where);

        request()->offsetSet('id', $user->id);
        $setmealRecords=$this->membersSetmealRecordService->SetmealRecord(true);

        $result = [
            'user' => $user,
            'mySetmeal' => $mySetmeal,
            'setmeal' => $setmeal,
            'starttime'=>$starttime,
            'endtime'=>$endtime,
            'setmealDetail'=>$setmealDetail,
            'setmealRecord'=>$setmealRecords,
        ];

        return $result;
    }
    /**
     * 获取任务状态。
     */
    public function points($user, $type = 0)
    {
        $task = $this->memberPointRepository->getComTaskById($user->id);

        foreach ($task as $key => $val) {
            if ($key == 'task_logs') {
                $task_id = [];
                $task_id_w = [];
                foreach ($val as $k => $v) {
                    if ($v['once'] != 1) {
                        $task_id[] = $v['task_id'];
                    } else {
                        $task_id_w[] = $v['task_id'];
                    }
                }
            }
        }
        $count = [];
        $task_id = array_unique($task_id);
        foreach ($task_id as $k => $v) {
            $count[$v] = $this->taskLogRepository->getTaskLogCount($user->id, $v, $user->utype);
        }
        $task_info = $this->taskRepository->getTaskById(array_keys($count));
        $finshTask = [];  //已完成任务。
        foreach ($count as $k1 => $v1) {
            foreach ($task_info as $key1 => $val1) {
                if ($k1 == $val1->id) {
                    if ($val1->times != -1) {
                        if ($v1 == $val1->times) {
                            $finshTask[$k1]['id'] = $val1->id;
                            $finshTask[$k1]['title'] = $val1->title;
                            $finshTask[$k1]['points'] = $val1->points;
                            $finshTask[$k1]['type'] = '日常任务';
                            $finshTask[$k1]['status'] = '已完成';
                            $finshTask[$k1]['t_alias'] = $val1->t_alias;
                            $finshTask[$k1]['count'] = '(*' . $v1 . ')';
                        }
                    }
                }
            }
        }
        $task_info_w = $this->taskRepository->getTaskById(($task_id_w));
        foreach ($task_info_w as $ke => $va) {
            $finshTask[$va->id]['id'] = $va->id;
            $finshTask[$va->id]['title'] = $va->title;
            $finshTask[$va->id]['points'] = $va->points;
            $finshTask[$va->id]['type'] = '一次性任务';
            $finshTask[$va->id]['status'] = '已完成';
            $finshTask[$va->id]['t_alias'] = $va->t_alias;
            $finshTask[$va->id]['count'] = '';
        }
        $task_ZZ = $this->taskRepository->getTaskByUtype($user->utype);
        $task_info_z = [];

        $sub_site = '';
        if (get_subsite_id() > 0) {
            $sub_site = 'jkq.';
        }

        foreach ($task_ZZ as $key => $val) {
            if (!in_array($val->id, array_keys($finshTask))) {
                $task_info_z[$val->id]['id'] = $val->id;
                $task_info_z[$val->id]['title'] = $val->title;
                $task_info_z[$val->id]['points'] = $val->points;
                if ($val->once == 1) {
                    $task_info_z[$val->id]['count'] = '';
                    $task_info_z[$val->id]['type'] = '一次性任务';
                } else {
                    $task_info_z[$val->id]['type'] = '日常任务';
                    $hjk = $this->taskLogRepository->getTaskLogCount($user->id, $val->id, $user->utype);
                    if (!$hjk) {
                        $task_info_z[$val->id]['count'] = '';
                    } else {
                        $times = $val->times;
                        $lasT = $times - $hjk;
                        if ($times == -1) {
                            $task_info_z[$val->id]['count'] = '';
                        } else {
                            $task_info_z[$val->id]['count'] = '(*'.$lasT.')';
                        }
                    }
                }
                if ($type) {
                    if ($val->id == 17) {
                        $task_info_z[$val->id]['status'] = '<a href="" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 18) {
                        $task_info_z[$val->id]['status'] = '<a href="javascript:;" url="' . route($sub_site."mobile.firm.sing") . '" data-type="sign" class="ajax_do" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 19) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."mobile.firm.info") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 20) {
                        $task_info_z[$val->id]['status'] = '<a href="' . route($sub_site."mobile.firm.com.img") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 21) {
                        $task_info_z[$val->id]['status'] = '<a href="' . route($sub_site."mobile.resumes") . '" style="text-decoration: none;" target="_blank">去完成</a>';
                    } elseif ($val->id == 22) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."mobile.firm.com.security") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 23) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."mobile.firm.com.security") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 25) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."mobile.firm.com.binding") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 27) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."mobile.firm.info") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 28) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."mobile.firm.resume.apply") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 29) {
//                        $task_info_z[$val->id]['status'] = '<a href="" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 30) {
                        $task_info_z[$val->id]['status'] = '<a href="' . route($sub_site."mobile.firm.com.auth") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 31) {
//                        $task_info_z[$val->id]['status'] = '<a href="" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 32) {
                        $task_info_z[$val->id]['status'] = '<a href="' . route($sub_site."mobile.firm.com.psm.consult") . '" style="text-decoration: none;">去完成</a>';
                    } else {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."mobile.firm.com.binding") . '" style="text-decoration: none;">去完成</a>';
                    }
                } else {
                    if ($val->id == 17) {
                        $task_info_z[$val->id]['status'] = '<a href="" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 18) {
                        $task_info_z[$val->id]['status'] = '<a href="javascript:;" url="' . route($sub_site."com.sign") . '" data-type="sign" class="ajax_do" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 19) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."com.info") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 20) {
                        $task_info_z[$val->id]['status'] = '<a href="' . route($sub_site."com.img") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 21) {
                        $task_info_z[$val->id]['status'] = '<a href="' . route($sub_site."resumes") . '" style="text-decoration: none;" target="_blank">去完成</a>';
                    } elseif ($val->id == 22) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."com.security") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 23) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."com.security") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 25) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."com.security") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 27) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."com.info") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 28) {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."resume.apply") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 29) {
//                        $task_info_z[$val->id]['status'] = '<a href="" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 30) {
                        $task_info_z[$val->id]['status'] = '<a href="' . route($sub_site."com.auth") . '" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 31) {
//                        $task_info_z[$val->id]['status'] = '<a href="" style="text-decoration: none;">去完成</a>';
                    } elseif ($val->id == 32) {
                        $task_info_z[$val->id]['status'] = '<a href="' . route($sub_site."com.pms.consult") . '" style="text-decoration: none;">去完成</a>';
                    } else {
                        $task_info_z[$val->id]['status'] = '<a href=" ' . route($sub_site."com.security") . '" style="text-decoration: none;">去完成</a>';
                    }
                }

                $task_info_z[$val->id]['t_alias'] = $val->t_alias;
            }
        }
        $todayPoints = 0;
        $rs = $this->taskLogRepository->getTodayPoints($user->id, $user->utype);
        if ($rs) {
            $todayPoints = $rs;
        }
        $onPoints = $this->taskLogRepository->getSinglePoints($user->id, $user->utype);
        $dayPoints = $this->taskLogRepository->getDayPoints($user->id, $user->utype);
        $arrAll = $this->taskRepository->getAllPoints($user->utype);
        $allPoints = 0;
        foreach ($arrAll as $key => $val) {
            if ($val->once == 1) {
                $allPoints += $val->points;
            } else {
                $allPoints += (abs($val->times)) * ($val->points);
            }
        }
        $lastPoints = (int)$allPoints - $onPoints - $dayPoints > 0 ? (int)$allPoints - $onPoints - $dayPoints : 0;

        $mySetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);//套餐详细
        return [
            'w_finsh' => $task_info_z,
            'finsh' => $finshTask,
            'content' => $task,
            'todayPoints' => $todayPoints,
            'lastPoints' => $lastPoints,
            'content' => $this->memberPointRepository->getComPointsById($user->id, $user->utype),
            'mySetmeal' => $mySetmeal,
        ];
    }

    /**积分收支明细
     * @return array
     */
    public function pointsDetail($type, $user)
    {
        $getNum = $this->memberHandselRepository->getNum($user, 1);//累计获得
        $useNum = $this->memberHandselRepository->getNum($user, 2);//累计消耗
        $content = $this->memberHandselRepository->getMembersHandsel($user->id, $user->utype, $type);//积分操作记录
        $companyPoint = $this->memberPointRepository->getComPointsById($user->id, $user->utype);
        $points = $this->taskLogRepository->getTodayPoints($user->id, $user->utype);//今天获取积分
        $todayPoints = $points ? $points : 0;

        $onPoints = $this->taskLogRepository->getSinglePoints($user->id, $user->utype);//获取单次积分

        $dayPoints = $this->taskLogRepository->getDayPoints($user->id, $user->utype); //获取日常积分

        $arrAll = $this->taskRepository->getAllPoints($user->utype);
        $allPoints = 0;
        foreach ($arrAll as $key => $val) {
            if ($val->once == 1) {
                $allPoints += $val->points;
            } else {
                $allPoints += (abs($val->times)) * ($val->points);
            }
        }
        $lastPoints = (int)$allPoints - $onPoints - $dayPoints > 0 ? (int)$allPoints - $onPoints - $dayPoints : 0;
        $res = [
            'content' => $content,
            'points' => $todayPoints,
            'lastPoints' => $lastPoints,
            'companyPoint' => $companyPoint,
            'getNum' => $getNum[0]->getTotalPoints,
            'useNum' => $useNum[0]->getTotalPoints,
            'type'=>$type
        ];
        return $res;
    }

    /**套餐升级
     * @param $id
     * @return array
     * @throws ResponseException
     */
    public function setmealAdd($id, $user)
    {
        $setmeal = $this->setmealRepository->find($id);
        if (!$setmeal) {
            throw new ResponseException('请选择正确的套餐', '', 404);
        }
        //  购买套餐优惠
        $setmeal->long = $this->formatDays($setmeal->days);
        $setmeal->discount = $this->setmealRepository->getDiscountForSetmealOne($setmeal);
        $offline = $this->paymentRepository->findWhere(['alias'=>'offline']);
        $online = $this->paymentRepository->findWhere([['alias','<>','offline']]);
        foreach ($offline as $key => &$val) {
            if (!config("aix.system.pay.{$val->alias}.is_on")) {
                unset($offline[$key]);
            }
        }
        foreach ($online as $key => &$val) {
            if (!config("aix.system.pay.{$val->alias}.is_on")) {
                unset($online[$key]);
            }
        }
        $mypoints = $this->memberPointRepository->getPointsById($user->id, $user->utype);
        $result = [
            'user' => $user,
            'setmeal' => $setmeal,
            'offline' => $offline,
            'online' => $online,
            'mypoints' => $mypoints->points,
            'need_points' => $setmeal->expense * config('aix.companyset.points.points_set.payment_rate')
        ];
        return $result;
    }


    public function setmealAddMobile($user)
    {
        //我的套餐
        $mySetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, 1);
        //我的积分
        $myPoints = $this->memberPointRepository->getPointsById($user->id, 1);
        //套餐列表
        $setmeal = $this->setmealRepository->getSetmealList();

        foreach ($setmeal as $key => $val) {
            $setmeal[$key]->long = $val->days==0?'永久':$this->formatDays($val->days);
            $setmeal[$key]['discount'] = $this->setmealRepository->getDiscountForSetmealOne($val);
            if (config('aix.mobile.mobile_set.mobile_set.mobile_setmeal_discount_value')>0) {
                $setmeal[$key]->expense = config('aix.mobile.mobile_set.mobile_set.mobile_setmeal_discount_value_type')==1?$val->expense/100*config('aix.mobile.mobile_set.mobile_set.mobile_setmeal_discount_value'):$val->expense-config('aix.mobile.mobile_set.mobile_set.mobile_setmeal_discount_value');
            }
            $setmeal[$key]->service_points = round($setmeal[$key]->expense*config('aix.companyset.points.points_set.payment_rate'));
        }

        $result = [
            'user'=>$user,
            'mySetmeal'=>$mySetmeal,
            'myPoints'=>$myPoints,
            'setmeal'=>$setmeal,
        ];
        return $result;
    }

    /**设置套餐
     * @param $user
     * @param $setmeal_id
     * @return array
     * @params 用来传递参数,后台修改到期时间,希望设置开始时间维当日期 by 李艳
     * @throws \Prettus\Validator\Exceptions\ValidatorException
     * $params 参数使用地方 app/Admin/Controllers/Company/MembersSetmealController.php@update()
     */
    public function setMembersSetmeal($user, $setmeal_id,$params=null)
    {
        $setmeal = $this->setmealRepository->getOneSetmeal($setmeal_id);

        if (!$setmeal) {
            return ['status'=>0,'msg'=>'请选择正确的套餐'];
        }
        $mysetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);

        /**
         * 9月11日发现BUG
         * 当上个套餐,是免费会员的时候,并且结束时间是0,在此处转成时间戳的时候就会发生令人窒息的1970年
         */
        $before_end_time=$mysetmeal->endtime; //我现在的套餐的到期时间
        if ($before_end_time==0){
            $before_end_time=time();
        }else{ //有老的异常数据,1970年的
            if ($before_end_time<MembersSetmeal::ERROR_TIME){
                $before_end_time=time();//直接开始时间就是现在吧
            }
        }
        $sqlData['starttime']=$before_end_time;


        $sqlData['expire'] = 0;//如果$setmeal->is_free==1，说明是到期自动变为免费会员，标记过期 --- 其他会员降级 到期字段不变
        $sqlData['setmeal_id'] = $setmeal->id;
        $sqlData['setmeal_name'] = $setmeal->setmeal_name;
        $sqlData['days'] = $setmeal->days;


        if (!empty($params) && isset($params['starttime'])){ //传过来的是设置指定的开始时间
            $sqlData['starttime']=$params['starttime'];
        }
        if ($setmeal->days > 0) {
            //如果套餐未到期，判断是否叠加套餐服务时间
            //配置文件开启套餐时间叠被动模式
            if (config('aix.companyset.setmeal_com.setmeal_com_set.is_superposition_time') == 1) {

                $sqlData['endtime'] = strtotime("+{$setmeal->days} day",$sqlData['starttime']);
            } else {
                $sqlData['endtime'] = strtotime("".$setmeal->days." days");
            }
        } else {
            $sqlData['endtime'] = 0;
        }

        $sqlData['expense']=$setmeal['expense'];

        $sqlData['jobs_meanwhile'] = $setmeal->jobs_meanwhile;
        $sqlData['refresh_jobs_free'] = $setmeal->refresh_jobs_free;
        $sqlData['jobfair_num'] = $setmeal->jobfair_num;//招聘会场次
        $sqlData['download_resume'] = $setmeal->download_resume;
        //掠过免费会员
        if ($setmeal_id!=MembersSetmeal::FREE_SetMember){
            if (config('aix.companyset.setmeal_com.setmeal_com_set.is_superposition') == 1) { //如果开通服务时叠加项目，就减掉已发布的职位数
                $map['company_id'] = $user->id;
                $sqlData['download_resume']=$mysetmeal->download_resume+$setmeal->download_resume;
                $sqlData['jobfair_num'] = $mysetmeal->jobfair_num+$setmeal->jobfair_num;//招聘会场次
                $sqlData['jobs_meanwhile'] = $mysetmeal->jobs_meanwhile+$setmeal->jobs_meanwhile;
            }
        }

        $sqlData['download_resume_max'] = $setmeal->download_resume_max;
        $sqlData['added'] = $setmeal->added;
        $sqlData['setmeal_img'] = $setmeal->setmeal_img;
        $sqlData['show_apply_contact'] = $setmeal->show_apply_contact;
        $sqlData['is_free'] = $setmeal->is_free;
        $sqlData['discount_download_resume'] = $setmeal->discount_download_resume;
        $sqlData['discount_sms'] = $setmeal->discount_sms;
        $sqlData['discount_stick'] = $setmeal->discount_stick;
        $sqlData['discount_emergency'] = $setmeal->discount_emergency;
        $sqlData['discount_tpl'] = $setmeal->discount_tpl;
        $sqlData['discount_auto_refresh_jobs'] = $setmeal->discount_auto_refresh_jobs;
        $sqlData['discount_auto_refresh_jobs'] = $setmeal->discount_auto_refresh_jobs;
        $sqlData['discount_auto_refresh_jobs'] = $setmeal->discount_auto_refresh_jobs;
        $sqlData['discount_auto_refresh_jobs'] = $setmeal->discount_auto_refresh_jobs;

        $setmeal_jobs['setmeal_deadline']=$sqlData['endtime'];
        $setmeal_jobs['deadline']=$setmeal_jobs['setmeal_deadline'];
        $setmeal_jobs['setmeal_id']=$sqlData['setmeal_id'];
        $setmeal_jobs['setmeal_name']=$sqlData['setmeal_name'];
        DB::beginTransaction();//检查数据库事务(有错)
        try{
            //检查套餐的开始时间和结束时间是否正常
            if($sqlData["starttime"]<MembersSetmeal::ERROR_TIME ||
              ($sqlData["endtime"]<MembersSetmeal::ERROR_TIME && $sqlData["endtime"]!=0))
            {

                throw new \Exception('系统出现异常!,请联系管理员！');
            }



            if (!$this->memberSetmealRepository->updateSetmeal($sqlData, $mysetmeal->id)) {
                throw new \Exception('更新会员套餐失败！');
            }
            //删除 是否过期 以及套餐图标
            unset($sqlData['expire']);
            unset($sqlData['setmeal_img']);
            unset($sqlData['setmeal_deadline']);

            $sqlData['uid'] = $user->id;
            $sqlData['utype'] = $user->utype;
            //往套餐记录里头添加

            if($this->memberSetmealRecordRepository->create($sqlData)===false){
                throw new \Exception('添加记录失败！');
            }


            //如果套餐有赠送积分，则直接更新用户积分表
            if ($setmeal->set_points) {
                $this->memberPointRepository->reportDeal($user->id, $user->utype, 1, $setmeal->set_points);
                $handsel['uid'] = $user->id;
                $handsel['htype'] = 'setmeal_gifts';
                $handsel['htype_cn'] = '套餐内赠送';
                $handsel['operate'] = 1;
                $handsel['points'] = $setmeal->set_points;
                $this->memberHandselRepository->addNew($handsel);
            }
            //如果套餐有赠送短信，则直接更新用户表的短信条数字段
            //如果开启了服务叠被动模式
            if ($setmeal_id!=1 && config('aix.companyset.setmeal_com.setmeal_com_set.is_superposition') == 1){
                $this->companyRepository->updataSmsNum($user->id, 1, $setmeal->set_sms);
            }else{
                $this->companyRepository->SetSmsNum($user->id,$setmeal->set_sms);
            }

            $this->companyRepository->update(['setmeal_id'=>$setmeal->id, 'setmeal_name'=>$setmeal->setmeal_name], $user->id);
            event_search_update(Company::class, (string)$user->id, 'update');
            $this->jobsRepository->updateMap($user->id, $setmeal_jobs);
            $condition = [['where', 'company_id', $user->id]];
            event_search_update(Jobs::class, $condition, 'update');
            //检查在招职位数是否超出限额，并根据后台配置做关闭处理
            $this->checkJobsMeanwhile($user->id, $setmeal->jobs_meanwhile);

            DB::commit();
            return ['status'=>1];
        }catch (\Exception $exception){
            DB::rollBack();
            return ['status'=>0,'msg'=>$exception->getMessage()];
        }
    }


    /**设置免费会员套餐到期
     * @param $user
     * @param $setmeal_id
     * @return array
     * @throws \Prettus\Validator\Exceptions\ValidatorException
     */
    public function setFreeMembersSetmeal($user)
    {

        $mysetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);

        if (!$this->memberSetmealRepository->updateSetmeal(['expire'=>1], $mysetmeal->id)) {
            return ['status'=>0,'msg'=>'更新会员套餐失败！'];
        }else{
            return ['status'=>1];

        }

    }

    /**处理职位
     * @param $uid
     * @param $num
     */
    public function checkJobsMeanwhile($uid, $num)
    {
        if (config('aix.companyset.setmeal_com.setmeal_com_set.hold_beyond_jobs') == 0) {
            $yid = [];
            $com_ids = [];
            $jobs = $this->jobsRepository->jobsSelect($uid);
            if (count($jobs) >$num) {
                foreach ($jobs as $key => $val) {
                    if ($key >= $num) {
                        $yid[] = $val->id;
                        $com_ids[] = $val->company_id;
                    }
                }
            }
            if (!empty($yid)) {
                $this->jobsRepository->closeJobs($yid);
                $condition = [['whereIn','id', $yid]];
                event_search_update(Jobs::class, $condition, 'update');
                event_search_update(Company::class, [['whereIn','id', $com_ids]], 'update');
            }
        }
    }

    /**更新订单号
     * @param $order_insert_id
     * @param $oid
     * @return mixed
     * @throws \Prettus\Validator\Exceptions\ValidatorException
     */
    public function updateOid($order_insert_id, $oid)
    {
        $data['oid'] = $oid;
        return $this->orderRepository->update($data, $order_insert_id);
    }

    /**支付成功页面
     * @param $oid
     * @return array
     * @throws ResponseException
     */
    public function setmealFinish($oid)
    {
        if (!$oid) {
            throw new ResponseException('订单ID有误', '', 404);
        }
        $user = auth('web-company')->user();
        $order = $this->orderRepository->getOneOder($oid);

        if (!$order) {
            throw new ResponseException('参数错误', '', 404);
        }

        $mysetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);
        if (!$mysetmeal) {
            throw new ResponseException('您的套餐信息有误', '', 404);
        }


        switch ($order->order_type){
            case 1: //套餐升级
                $setmealIncr=$this->setmealRepository->find($order->setmeal);

                $setmealIncrDay=$setmealIncr->days;

                //理因到期时间
                $expireTimeBase=date("Y-m-d h:i:s",strtotime("+{$setmealIncrDay} day",$order->payment_time));

                $res['expireTime']=$expireTimeBase;

                break;

            case 16:case 7:case 14:case 2:case 10:case 5://充值积分 随着会员到期而到期
            $setmealIncrDay="无期限";

            break;

            case 15:

            $setmealIncrDay="无期限";
            break;

            case 8:
            case 9:
            case 12:
            case 13:
                $setmealIncr=$this->setmealIncrementsRepository->find($order->setmeal);
                $setmealIncrDay=$setmealIncr->value;


                //理因到期时间
                $expireTimeBase=date("Y-m-d H:i:s",strtotime("+{$setmealIncrDay} day",$order->payment_time));
                $expireTime=strtotime($expireTimeBase);
                //我会员的结束时间小于套餐的到期时间
                if (strtotime($expireTimeBase)>strtotime($mysetmeal->endtime)) {
                    $expireTime=strtotime($mysetmeal->endtime);
                }

                if($mysetmeal->endtime==0){//免费的
                    $expireTime=strtotime($expireTimeBase);
                }

                $res['expireTime']=date("Y-m-d H:i:s",$expireTime);

                break;
            default:
                $setmealIncrDay="--";
                break;
        }

        $endtime = strtotime($mysetmeal->endtime) == 0?"永久":date('Y-m-d', strtotime($mysetmeal->endtime));
        $res = [
            'mysetmeal'=>$mysetmeal,
            'order'=>$order,
            'endtime'=>$endtime,
            'open_time'=>date("Y-m-d H:i:s",$order->payment_time),
            'setmealIncrDay'=>$setmealIncrDay
        ];
        return $res;
    }



    /**各项增值服务
     * @return array
     */
    public function increment($user)
    {
        $cat = $this->setmealIncrementsRepository->getIncrementCategory();
        $result = [];
        $category = [];
        foreach ($cat as $key => $val) {
            $category[$val->cat] = $val->cat;
            if ($val->cat=='jobs' || $val->cat=='jobfair_num') {
                $result[$val->cat] = 0;
            } else {
                $result[$val->cat] =$this->setmealRepository->getMaxDiscount($val->cat);
            }
        }
        $member_setmeal = 0;
        $memberSetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);
        if($memberSetmeal){
            $member_setmeal = $memberSetmeal->discount_tpl;
        }
//        $result['download_resume'] =$this->setmealRepository->getMaxDiscount('download_resume');
//        $result['sms'] =$this->setmealRepository->getMaxDiscount('sms');
//        $result['jobs_num'] =$this->setmealRepository->getMaxDiscount('jobs_num');
//        $result['jobfair_num'] =$this->setmealRepository->getMaxDiscount('jobfair_num');
//        $result['stick'] =$this->setmealRepository->getMaxDiscount('stick');
//        $result['emergency'] =$this->setmealRepository->getMaxDiscount('emergency');
//        $result['tpl'] =$this->setmealRepository->getMaxDiscount('tpl');
//        $result['auto_refresh_jobs'] =$this->setmealRepository->getMaxDiscount('auto_refresh_jobs');
//        return $result;
        return $res=['result'=>$result,'category'=>$category,'member_setmeal'=>$member_setmeal];
    }

    /**增值服务提示框
     * @return array
     */
    public function confirmPayIncrement($user)
    {
        $user = auth('web-company')->user();
        $mysetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);
        $setmeal_end_days = '永久';
        if (strtotime($mysetmeal->endtime) == 0) {
            $tip = '您当前【'.$mysetmeal->setmeal_name.'】有效期 '.date('Y-m-d', $mysetmeal->starttime).'至永久。增值包有效期与会员有效期一致（'.$setmeal_end_days.'），是否继续购买增值包？';
        } else {
            if (strtotime($mysetmeal->endtime) > time()) {
                $sub_day = sub_day(strtotime($mysetmeal->endtime), time());
                $sub_day = preg_replace('/(\d+)/', '<span class="font_yellow">\1</span>', $sub_day);
                $setmeal_end_days = $sub_day.'后到期';
            } else {
                $setmeal_end_days = '已经到期';
            }
            $tip = "您当前【".$mysetmeal->setmeal_name."】有效期".date('Y-m-d', $mysetmeal->starttime)."至".date('Y-m-d', strtotime($mysetmeal->endtime))."。增值包有效期与会员有效期一致(".$setmeal_end_days.")，是否继续购买增值包？";
        }
        return ['tip'=>$tip];
    }

    /**单个增值服务包内容
     * @param $cat
     * @param $request
     * @return array
     */
    public function incrementAdd($cat, $request)
    {
        $catData = $this->setmealIncrementsRepository->cate_arr;
        $service_unit = $this->setmealIncrementsRepository->service_unit;
        $user = auth('web-company')->user();
        $mysetmeal = $this->memberSetmealRepository->getSetmealByUid($user->id, $user->utype);
        $mypoints = $this->memberPointRepository->getComPointsById($user->id, $user->utype);
        $increment_rule = [
            'jobs'=>config('aix.companyset.business_set.points_set.jobs_num'),
            'jobfair_num'=>config('aix.companyset.business_set.points_set.jobfair_num'),
            'download_resume'=>config('aix.companyset.business_set.points_set.download_resume'),
            'sms'=>config('aix.companyset.business_set.points_set.sms'),
            'stick'=>config('aix.companyset.business_set.points_set.stick'),
            'emergency'=>config('aix.companyset.business_set.points_set.emergency'),
            'tpl'=>config('aix.companyset.business_set.points_set.tpl'),
            'auto_refresh_jobs'=>config('aix.companyset.business_set.points_set.auto_refresh_jobs')
        ];
        $offline = $this->paymentRepository->findWhere(['alias'=>'offline']);
        $online = $this->paymentRepository->findWhere([['alias','<>','offline']]);
        foreach ($offline as $key => &$val) {
            if (!config("aix.system.pay.{$val->alias}.is_on")) {
                unset($offline[$key]);
            }
        }
        foreach ($online as $key => &$val) {
            if (!config("aix.system.pay.{$val->alias}.is_on")) {
                unset($online[$key]);
            }
        }
        if ($cat == 'tpl') {
            $request_tpl = isset($request['tpl_id']) ? $request['tpl_id'] : 0;
            $cate_arr = $this->incrementAddTpl($mysetmeal, $request_tpl);
        } else {
            $cate_arr = $this->incrementAddNormal($cat, $mysetmeal);
        }
        $result = [
            'user'=>$user,
            'mysetmeal'=>$mysetmeal,
            'cate_arr'=>$cate_arr,
            'catData'=>$catData,
            'service_unit'=>$service_unit,
            'cat'=>$cat,
            'increment_rule'=>$increment_rule,
            'online'=>$online,
            'offline'=>$offline,
            'mypoints'=>$mypoints,
        ];
        return $result;
    }

    /**
     * 购买增值包 - 普通增值服务
     */
    protected function incrementAddNormal($cat, $mysetmeal)
    {
        $cate_arr = $this->setmealIncrementsRepository->findByField(['cat'=>$cat]);
        foreach ($cate_arr as $key => $val) {
            //如果是非免费套餐
            if ($mysetmeal->is_free == 0) {
                $discount = $this->setmealRepository->getIncrementDiscountByArray($cat, $mysetmeal);
                //当前基础套餐套餐需要付的价格,如果折扣为0,则价格与原始价格一致
                $cate_arr[$key]->my_price = $discount>0?round($val->price*$discount/10, 2):$val->price;
                //当前基础套餐的对应的折扣
                $cate_arr[$key]->my_discount = $discount;
                //单条价格
                $cate_arr[$key]->my_unit_price = round($cate_arr[$key]->my_price/$val->value, 2);
                //节省的数
                $cate_arr[$key]->my_saved_price = $val->price-$cate_arr[$key]->my_price;
            } else {
                $free_discount = $this->setmealRepository->getIncrementDiscountByArray($cat, $mysetmeal);
                //免费会员需要付的价格
                $cate_arr[$key]->my_price = $free_discount>0?round($val->price*$free_discount/10, 2):$val->price;
                //免费会员单条价格
                $cate_arr[$key]->my_unit_price = round($cate_arr[$key]->my_price/$val->value, 2);
                //VIP会员价格,取出折扣最大的套餐折扣
                $vip_discount = $this->setmealRepository->getMaxDiscount($cat);
                $cate_arr[$key]->vip_price = intval($vip_discount)>0?round($val->price*$vip_discount/10, 2):$val->price;
                //VIP会员单条价格
                $cate_arr[$key]->vip_unit_price = round($cate_arr[$key]->vip_price/$val->value, 2);
            }
            //换算积分
            $cate_arr[$key]->need_points = round($cate_arr[$key]->my_price*config('aix.companyset.points.points_set.payment_rate')); // 原为round()
        }
        $jobs_list = [];
        if ($cat=='stick' || $cat=='emergency' || $cat=='auto_refresh_jobs') {
            $jobs_where['company_id'] = auth('web-company')->user()->id;
            config('aix.companyset.comset.show_set.jobs_display') == 1 ? $jobs_where['audit'] = 1 : $jobs_where[] = ['audit','<>',3];
            $jobs_where['valid'] = 1;
            $jobs_list = $this->jobsRepository->findWhere($jobs_where);
            if ($cat == 'auto_refresh_jobs') {
                foreach ($jobs_list as $key => $val) {
                    $condition['pid'] = $val->id;
                    $condition['type'] = 1;
                    $condition['utype'] = auth('web-company')->user()->utype;
                    $has_auto = $this->queueAutoRefreshRepository->findData($condition);
                    $jobs_list[$key]->auto_refresh = $has_auto?1:0;
                }
            }
        }
        $buy_cn = '';
        switch ($cat) {
            case 'stick':
                $buy_cn = '置顶';
                break;
            case 'emergency':
                $buy_cn = '紧急';
                break;
            case 'jobs':
                $buy_cn = '职位增值包';
                break;
            case 'jobfair_num':
                $buy_cn = '招聘会场次';
                break;
        }
        return [
            'cate_arr'=>$cate_arr,
            'jobs_list'=>$jobs_list,
            'buy_cn'=>$buy_cn,
        ];
    }

    /**购买增值包 - 模版服务
     * @param int $request_tpl
     * @return bool
     */
    public function incrementAddTpl($mysetmeal, $request_tpl = 0)
    {
        if ($request_tpl >0) {
            $condition['id'] = $request_tpl;
        } else {
            $condition['tpl_type'] = 1;
        }
        $cate_arr =$this->tplRepository->findTpl($condition);
        foreach ($cate_arr as $key => $val) {
            $discount = $this->setmealRepository->getIncrementDiscountByArray('tpl', $mysetmeal);
            //当前基础套餐套餐需要付的价格,如果折扣为0,则价格与原始价格一致
            $cate_arr[$key]->my_price = $discount>0?round($val->price/config('aix.companyset.points.points_set.payment_rate')*$discount/10, 2):($val->price/config('aix.companyset.points.points_set.payment_rate'));
            //当前基础套餐的对应的折扣
            $cate_arr[$key]->my_discount = $discount;
            //换算积分
            $cate_arr[$key]->need_points = $discount>0?round($val->price*$discount/10):$val->price; //原为round()
            $cate_arr[$key]->id = $val->id;
//            $cate_arr[$key]->thumb_dir = $val->dir;//模版位置
        }
        return ['cate_arr'=>$cate_arr];
    }


    public function pointsAdd()
    {
        $payment = $this->paymentRepository->get();
        foreach ($payment as $key => $val) {
            if (!config("aix.system.pay.{$val->alias}.is_on")) {
                unset($payment[$key]);
            }
        }
        $result = [
            'payment'=>$payment,
            'payment_rate'=>config('aix.companyset.points.points_set.payment_rate'),
        ];
        return $result;
    }
    /**计算天数
     * @param $days
     * @return string
     */
    protected function formatDays($days)
    {
        if ($days < 30) {
            return $days . '天';
        } else {
            return intval($days / 30) . '个月';
        }
    }
    //添加会员操作日志
    public function writeMembersLog($user, $type, $log_value)
    {
        return $this->memberLogRepository->createLog($user, $type, $log_value);
    }
    //添加积分操作日志
    public function writeMemberHandselLog($data)
    {
        return $this->memberHandselRepository->create($data);
    }
    //清除积分
    public function clearPoint($uid){

        if (config("aix.companyset.points.points_set.clear_points")==1){
            $point=$this->memberPointRepository->getPointsOne($uid,1);
            if (empty($point->points)){ //如果积分就是空,就不清空了
                return null;
            }
            $this->memberPointRepository->updateNew($uid,1,['points'=>0]);

            try{
                //添加消除记录
                $this->memberHandselRepository->addNew(['uid'=>$uid,'utype'=>1,
                    "htype"=>"points_clear",
                    "htype_cn"=>"套餐到期,清空积分",
                    "operate"=>"2","points"=>$point->points]);
            }catch (\Exception $exception){

            }

        }

    }

    //检查套餐到期的问题
    public function checkMemberSetmeal(){
        $condition = [
            ['endtime','>', time()],//到期时间大于当前时间
            ['utype','=',1],
            ['expire','=',1]
        ];
        $or=[
            ['endtime',0],
            ['utype','=',1],
            ['expire','=',1]
        ];
        $list = $this->memberSetmealRepository->checkSetmeals($condition,$or);

        if (!empty($list)){
            foreach ($list as $item) {
                $log=[
                    'item'=>$item,
                    'action'=>"修改了套餐是否到期"
                ];
                $this->memberLogRepository->addDebugLog($log);
                $this->memberSetmealRepository->updateSetmeal(['expire'=>0],$item->id);

            }
        }
        return $list;
    }
}