NN2026012201/app/Services/Api/MeetingService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services\Api;

use App\Models\CityModel;
use App\Models\MeetingModel;
use App\Models\MeetingRecordsModel;
use App\Models\SupervisorsModel;
use App\Models\UserModel;
use App\Services\BaseService;
use App\Services\MpService;
use App\Services\RedisService;

/**
 * 会议-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * @package App\Services\Api
 */
class MeetingService extends BaseService
{
    // 静态对象
    protected static $instance = null;

    /**
     * 构造函数
     * @author laravel开发员
     * @since 2020/11/11
     */
    public function __construct()
    {
        $this->model = new MeetingModel();
    }

    /**
     * 静态入口
     */
    public static function make()
    {
        if (!self::$instance) {
            self::$instance = new static();
        }
        return self::$instance;
    }

    /**
     * 信息
     * @param int $id
     * @param int $userId
     * @return array|mixed
     */
    public function getInfo($id,$userId=0,$type=1)
    {
        $cacheKey = "caches:meeting:info_{$id}_{$userId}_{$type}";
        $info = RedisService::get($cacheKey);
        if($info){
            return $info;
        }

        $info =  $this->model->with(['member','company'])
            ->where(['id'=>$id,'status'=>1,'mark'=>1])
            ->withCount(['records'])
            ->first();
        $info = $info? $info->toArray() : [];
        if($info){
            $info['fee'] = floatval($info['fee']);
            if($type == 2){
                $info['qrcode'] = MpService::make()->getMiniQrcode('pagesSub/pages/meeting/books',$id);
                $info['qrcode'] = $info['qrcode']? get_image_url($info['qrcode']):'';
            }else if($type == 3){
                $bookInfo = MeetingRecordsModel::where(['user_id'=>$userId,'meeting_id'=>$id,'mark'=>1])
                    ->select(['id','is_sign','status'])
                    ->first();
                $bookInfo = $bookInfo?$bookInfo->toArray() : [];
                $info['is_book'] = $bookInfo?1: 0;
                $info['is_sign'] = isset($bookInfo['is_sign'])?$bookInfo['is_sign']: 0;
                $info['is_fee'] = isset($bookInfo['status'])?$bookInfo['status']: 0;
            }else{
                $areaIds = [];
                if($info['city_id']){
                    $areaIds[] = $info['city_id'];
                }

                if($info['district_id']){
                    $areaIds[] = $info['district_id'];
                }

                $areas = CityModel::whereIn('citycode', $areaIds)->pluck('name');
                $areas = $areas?$areas->toArray() :[];
                $info['area'] = $areas? implode('/',$areas) : '';
                $stores = '';
                if($info['store_ids']){
                    $stores = UserModel::whereIn('id', $info['store_ids'])
                        ->select(['id','avatar','realname','nickname as company','mobile','department','position','status'])
                        ->where(['mark'=>1])
                        ->get();;
                }

                $info['stores'] = $stores?$stores->toArray() : [];
                $supervisors = '';
                if($info['supervisor_ids']){
                    $supervisors = SupervisorsModel::whereIn('id', $info['supervisor_ids'])
                        ->select(['id','name','avatar','mobile','company','occupation','department','position','status'])
                        ->where(['mark'=>1])
                        ->get();
                }
                $info['supervisors'] = $supervisors?$supervisors->toArray() :[];
                $info['store_count'] = count($info['stores']);
                $info['supervisor_count'] =count($info['supervisors']);

                $bookInfo = MeetingRecordsModel::where(['user_id'=>$userId,'meeting_id'=>$id,'mark'=>1])
                    ->select(['id','is_sign','status'])
                        ->first();
                $bookInfo = $bookInfo?$bookInfo->toArray() : [];
                $info['is_book'] = $bookInfo?1: 0;
                $info['is_sign'] = isset($bookInfo['is_sign'])?$bookInfo['is_sign']: 0;
                $info['is_fee'] = isset($bookInfo['status'])?$bookInfo['status']: 0;
            }

            RedisService::set($cacheKey, $info,   rand(5,10));
        }

        return $info;
    }

    /**
     * @param $params
     * @param int $pageSize
     * @return array
     */
    public function getDataList($params, $pageSize = 15)
    {
        $query = $this->getQuery($params);
        $list = $query->select(['meetings.*'])
            ->withCount(['records'])
            ->groupBy('meetings.id')
            ->orderBy('meetings.sort','desc')
            ->orderBy('meetings.id','desc')
            ->paginate($pageSize > 0 ? $pageSize : 9999999);
        $list = $list? $list->toArray() :[];
        return [
            'pageSize'=> $pageSize,
            'total'=>isset($list['total'])? $list['total'] : 0,
            'list'=> isset($list['data'])? $list['data'] : []
        ];
    }

    /**
     * 查询
     * @param $params
     * @return mixed
     */
    public function getQuery($params)
    {
        $where = ['meetings.status'=>0,'meetings.mark' => 1];
        $status = isset($params['status']) && $params['status']? intval($params['status']) : 1;
        if($status>0){
            $where['meetings.status'] = $status;
        }else{
            unset($where['meetings.status']);
        }

        return $this->model->with(['member','company'])
            ->from('meetings')
            ->leftJoin('meetings_records','meetings_records.meeting_id','meetings.id')
            ->where($where)
            ->where(function ($query) use($params){
                $keyword = isset($params['keyword'])? $params['keyword'] : '';
                if($keyword){
                    $query->where('meetings.title','like',"%{$keyword}%");
                }

                $type = isset($params['type'])? $params['type'] : 0;
                $userId = isset($params['user_id'])?$params['user_id'] : 0;
                // 我组织的
                if($type==1){
                    $query->where('meetings.user_id', $userId);
                }else if($type == 2){
                    $query->where('meetings_records.user_id', $userId)->where('meetings_records.mark',1);
                }

            });
    }

    /**
     * 报名
     * @param $userId
     * @param $params
     * @return array|false
     */
    public function books($userId, $params)
    {
        $meetingId = isset($params['id']) ? intval($params['id']) : 0;
        if ($meetingId<=0) {
            $this->error = '会议参数错误，请返回重试～';
            return false;
        }

        $cacheKey = "caches:meetingBooks:{$userId}_{$meetingId}";
        if (RedisService::get($cacheKey)) {
            $this->error = '请不要重复报名';
            return false;
        }

        $nowDate = date('Y-m-d H:i:s');
        $info = $this->model->where(['id'=>$meetingId])->first();
        $startAt = isset($info['start_at'])?$info['start_at'] : '';
        $endAt = isset($info['end_at'])?$info['end_at'] : '';
        $fee = isset($info['fee'])?$info['fee'] : 0;
        $orderDay = isset($info['order_day']) && $info['order_day']>1?intval($info['order_day']) : 1; // 订单关联天数
        if($startAt && $nowDate < $startAt){
            RedisService::clear($cacheKey);
            $this->error = '会议尚未开始，无法报名';
            return false;
        }

        if($endAt && $nowDate > $endAt){
            RedisService::clear($cacheKey);
            $this->error = '会议已结束，无法报名';
            return false;
        }

        $record = MeetingRecordsModel::where(['meeting_id'=> $meetingId,'user_id'=>$userId,'mark'=>1])->first();
        $status = isset($record['status'])?$record['status']:0;
        if($record){
            RedisService::clear($cacheKey);
            $this->error = $status==1? '您已经完成报名': '您已经完成报名，请等候付费确认';
            return false;
        }

        $otherRecord = MeetingRecordsModel::with(['meeting'])->where(['user_id'=>$userId,'mark'=>1])->first();
        $meeting = isset($otherRecord['meeting'])?$otherRecord['meeting']:[];
        $meetingStartAt = isset($meeting['start_at'])?$meeting['start_at'] : '';
        $meetingEndAt = isset($meeting['end_at'])?$meeting['end_at'] : '';
        if($otherRecord && $meetingStartAt <= $nowDate && $nowDate <= $meetingEndAt){
            RedisService::clear($cacheKey);
            $this->error = '您有未完成的会议，请完成后再报名';
            return false;
        }

        $data = [
            'user_id' => $userId,
            'meeting_id' => $meetingId,
            'order_count' => 0,
            'order_total' => 0,
            'is_sign' => 2,
            'status' => $fee<=0?1:2,
            'create_time' => time(),
            'update_time' => time(),
            'mark' => 1,
        ];

        if(!$id = MeetingRecordsModel::insertGetId($data)){
            RedisService::clear($cacheKey);
            $this->error = '报名失败';
            return false;
        }

        $this->error = $fee>0?'报名成功，请等候付费确认':'报名成功';
        RedisService::set($cacheKey, $data, 30);
        RedisService::keyDel("caches:meeting:info_{$meetingId}_{$userId}*");
        return ['id' => $id];
    }

    /**
     * 签到
     * @param $userId
     * @param $params
     * @return array|false
     */
    public function sign($userId, $params)
    {
        $meetingId = isset($params['id']) ? intval($params['id']) : 0;
        if ($meetingId<=0) {
            $this->error = '会议参数错误，请返回重试～';
            return false;
        }

        $cacheKey = "caches:meetingSign:{$userId}_{$meetingId}";
        if (RedisService::get($cacheKey)) {
            $this->error = '请不要重复签到';
            return false;
        }



        $nowDate = date('Y-m-d H:i:s');
        $info = $this->model->where(['id'=>$meetingId])->first();
        $startAt = isset($info['start_at'])?$info['start_at'] : '';
        $endAt = isset($info['end_at'])?$info['end_at'] : '';
        $orderDay = isset($info['order_day']) && $info['order_day']>1?intval($info['order_day']) : 1; // 订单关联天数
        if($startAt && $nowDate < $startAt){
            RedisService::clear($cacheKey);
            $this->error = '会议尚未开始，无法签到';
            return false;
        }

        if($endAt && $nowDate > $endAt){
            RedisService::clear($cacheKey);
            $this->error = '会议已结束，无法签到';
            return false;
        }

        $record = MeetingRecordsModel::where(['meeting_id'=> $meetingId,'user_id'=>$userId,'mark'=>1])->first();
        $recordId = isset($record['id'])?$record['id'] : 0;
        $isSign = isset($record['is_sign'])?$record['is_sign'] : 0;
        $bookStatus = isset($record['status'])?$record['status'] : 0;
        if(empty($record) || $recordId<=0){
            RedisService::clear($cacheKey);
            $this->error = '抱歉，请先完成报名';
            return false;
        }

        if($bookStatus!=1){
            RedisService::clear($cacheKey);
            $this->error = '抱歉，请先完成报名付费确认';
            return false;
        }

        if($isSign==1){
            RedisService::clear($cacheKey);
            $this->error = '您已经完成签到';
            return false;
        }

        $otherRecord = MeetingRecordsModel::with(['meeting'])->where(['user_id'=>$userId,'mark'=>1])->first();
        $meeting = isset($otherRecord['meeting'])?$otherRecord['meeting']:[];
        $meetingStartAt = isset($meeting['start_at'])?$meeting['start_at'] : '';
        $meetingEndAt = isset($meeting['end_at'])?$meeting['end_at'] : '';
        if($otherRecord && $meetingStartAt <= $nowDate && $nowDate <= $meetingEndAt){
            RedisService::clear($cacheKey);
            $this->error = '您有未完成的会议，请完成后再签到';
            return false;
        }

        $data = [
            'is_sign' => 1,
            'sign_at' => date('Y-m-d H:i:s'),
            'expired_at' => date('Y-m-d H:i:s', time() + $orderDay * 86400),
            'create_time' => time(),
            'update_time' => time(),
            'mark' => 1,
        ];


        MeetingRecordsModel::where(['id'=>$recordId])->update($data);

        $this->error = '签到成功';
        RedisService::set($cacheKey, $data, 30);
        RedisService::keyDel("caches:meeting:info_{$meetingId}_{$userId}*");
        return ['id' => $recordId];
    }


    /**
     * 会议报名签到记录
     * @param $params
     * @param int $pageSize
     * @return array
     */
    public function records($params,$pageSize=20)
    {
        $meetingId = isset($params['meeting_id'])?$params['meeting_id']: 0;
        $list = MeetingRecordsModel::with(['member'])
            ->from('meetings_records as a')
            ->leftJoin('member as b','b.id','=','a.user_id')
            ->where(function($query) use($params){
                $keyword = isset($params['keyword'])? trim($params['keyword']) : '';
                if($keyword){
                    $query->where('b.mobile','like',"%{$keyword}%")
                        ->orWhere('b.nickname','like',"%{$keyword}%")
                        ->orWhere('b.realname','like',"%{$keyword}%");
                }
            })
            ->where('b.id','>',0)
            ->where(['a.meeting_id'=>$meetingId,'a.is_sign'=>1,'a.mark'=>1])
            ->select(['a.*'])
            ->orderBy('a.id','desc')
            ->paginate($pageSize > 0 ? $pageSize : 9999999);
        $list = $list? $list->toArray() :[];

        return [
            'pageSize'=> $pageSize,
            'total'=>isset($list['total'])? $list['total'] : 0,
            'list'=> isset($list['data'])? $list['data'] : []
        ];
    }
}