wkcrm/application/crm/logic/MessageLogic.php

<?php

namespace app\crm\logic;

use app\admin\model\Common;
use app\crm\model\Customer;
use think\Db;
use function foo\func;

class MessageLogic extends Common
{
    /**
     *
     * 今日续联系线索列表
     * @param $param
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/24 0024 11:43
     */
    public function todayLeads($param)
    {
        $type = !empty($param['type']) ? $param['type'] : 1;
        $isSub = !empty($param['isSub']) ? $param['isSub'] : 0;
        $todayTime = getTimeByType('today');
        unset($param['type']);
        unset($param['isSub']);
        $request = $this->where($param, $type, $isSub, $todayTime);
        $leadsModel = new \app\crm\model\Leads();
        $data = $leadsModel->getDataList($request);
        return $data;
    }
    
    /**
     * 客户
     * @param $request
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/25 0025 09:17
     */
    public function remindCustomer($param)
    {
        
        $type = $param['type'] ?: 1;
        $isSub = $param['isSub'] ?: '';
        $todayTime = getTimeByType('today');
        unset($param['type']);
        unset($param['isSub']);
        $request = $this->where($param, $type, $isSub, $todayTime);
        $customerModel = model('Customer');
        $data = $customerModel->getDataList($request);
        return $data;
    }
    
    /**
     *
     * @param $param
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/26 0026 10:13
     */
    public function todayBusiness($param)
    {
        $type = !empty($param['type']) ? $param['type'] : 1;
        $isSub = !empty($param['isSub']) ? $param['isSub'] : 0;
        $todayTime = getTimeByType('today');
        unset($param['type']);
        unset($param['isSub']);
        $request = $this->where($param, $type, $isSub, $todayTime);
        $businessModel = new \app\crm\model\Business();
        $data = $businessModel->getDataList($request);
        return $data;
    }
    
    /**
     * 分配给我的线索
     * @param $param
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/26 0026 10:32
     */
    public function followLeads($param)
    {
        $type = $param['type'] ?: 1;
        unset($param['type']);
        $request = $this->where($param, $type, '', '');
        $leadsModel = model('Leads');
        $data = $leadsModel->getDataList($request);
        return $data;
    }
    
    /**
     * 分配给我的客户
     * @param $param
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/26 0026 10:36
     */
    public function followCustomer($param)
    {
        $type = $param['type'] ?: 1;
        $isSub = $param['isSub'] ?: '';
        unset($param['type']);
        unset($param['isSub']);
        $request = $this->where($param, $type, $isSub, '');
        unset($param['user_id']);
        $customerModel = model('Customer');
        $data = $customerModel->getDataList($request);
        return $data;
    }
    
    /**
     * @param $param
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/26 0026 11:42
     */
    public function checkContract($param)
    {
        $type = $param['type'] ?: 1;
        unset($param['type']);
        $contractModel = model('Contract');
        $request = $this->whereCheck($param, $type);
        $request['isMessage'] = true;
        $data = $contractModel->getDataList($request);
        return $data;
    }
    
    /**
     * 待审核回款
     * @param $param
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/26 0026 11:48
     */
    public function checkReceivables($param){
        $type = $param['type'] ? : 1;
        $isSub = 1;
        unset($param['type']);
        $receivablesModel = model('Receivables');
        $request = $this->whereCheck($param, $type,$isSub);
        $request['isMessage'] = true;
        $data = $receivablesModel->getDataList($request);
        return $data;
    }
    
    /**
     *待审核发票
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/26 0026 13:35
     */
    public function checkInvoice($param){
        $type   = !empty($param['type'])  ? $param['type']  : 1;
        $isSub  = 2;
        # 清除与模型无关的数据
        unset($param['type']);
        $request = $this->whereCheck($param, $type,$isSub);
        $request['isMessage'] = true;
        $data = (new InvoiceLogic())->index($request);
        return $data;
    }

    /**
     *待审核商机
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/26 0026 13:35
     */
    public function checkBusiness($param){
        $type   = !empty($param['type'])  ? $param['type']  : 1;
        $isSub = 3;
        unset($param['type']);
        $businessModel = model('Business');
        $request = $this->whereCheck($param, $type,$isSub);
        $request['isMessage'] = true;
        $data = $businessModel->getDataList($request);
        return $data;
    }

    /**
     *待审核客户捞取
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/26 0026 13:35
     */
    public function checkCustomerCheck($param){
        $type   = !empty($param['type'])  ? $param['type']  : 1;
        $isSub = 4;
        unset($param['type']);
        $customerCheckModel = model('CustomerCheck');
        $request = $this->whereCheck($param, $type,$isSub);
        $request['isMessage'] = true;
        $data = $customerCheckModel->getDataList($request);
        return $data;
    }

    /**
     * 审批查询条件
     * @param $param
     * @param $type
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/26 0026 11:43
     */
    public function whereCheck($param, $type,$isSub='')
    {
        if(empty($isSub)){
            switch ($type) {
                case '1' :
                    $param['check_status'] = ['lt', '2'];
                    $param['check_user_id'] = ['like', '%,' . $param['user_id'] . ',%'];
                    # 要提醒的合同ID
                    $contractIdArray = db('crm_dealt_relation')->where(['types' => ['eq', 'crm_contract'], 'user_id' => ['eq', $param['user_id']]])->column('types_id');
                    $param['contractIdArray'] = !empty($contractIdArray) ? $contractIdArray : -1;
                    break;
                case '2' :
                    $param['flow_user_id'] = ['like', '%,' . $param['user_id'] . ',%'];
                    break;
            }
        }else if($isSub==1){
            switch ($type) {
                case '1' :
                    # 待审核、审核中
                    $param['check_status'] = ['lt','2'];
                    $param['check_user_id'] = ['like','%,'.$param['user_id'].',%'];
                    # 要提醒的回款ID
                    $receivablesIdArray = db('crm_dealt_relation')->where(['types' => ['eq', 'crm_receivables'], 'user_id' => ['eq', $param['user_id']]])->column('types_id');
                    $param['receivablesIdArray'] = !empty($receivablesIdArray) ? $receivablesIdArray : -1;
                    break;
                case '2' :
                    # 全部
                    $param['flow_user_id'] = ['like','%,'.$param['user_id'].',%'];
                    break;
            }
        }elseif($isSub==2){
            switch ($type) {
                case '1' :
                    # 待审核、审核中
                    $param['check_status']  = ['lt', 2];
                    $param['check_user_id'] = ['like', '%,'. $param['user_id'] .',%'];
                    # 要提醒的发票ID
                    $invoiceIdArray = db('crm_dealt_relation')->where(['types' => ['eq', 'crm_invoice'], 'user_id' => ['eq', $param['user_id']]])->column('types_id');
                    $param['invoiceIdArray'] = !empty($invoiceIdArray) ? $invoiceIdArray : -1;
                    $param['dealt'] = 1;
                    break;
                case '2' :
                    # 全部
                    $param['flow_user_id'] = ['like', '%,'. $param['user_id'] .',%'];
                    $param['dealt'] = 1;
                    break;
            }
        }elseif($isSub==3){
            switch ($type) {
                case '1' :
                    # 待审核、审核中
                    $param['check_status']  = ['lt', 2];
                    $param['check_user_id'] = ['like', '%,'. $param['user_id'] .',%'];
                    # 要提醒的商机ID
                    $businessIdArray = db('crm_dealt_relation')->where(['types' => ['eq', 'crm_business'], 'user_id' => ['eq', $param['user_id']]])->column('types_id');
                    $param['businessIdArray'] = !empty($businessIdArray) ? $businessIdArray : -1;
                    break;
                case '2' :
                    # 全部
                    $param['flow_user_id'] = ['like', '%,'. $param['user_id'] .',%'];
                    break;
            }
        }elseif($isSub==4){
            switch ($type) {
                case '1' :
                    # 待审核、审核中
                    $param['check_status']  = ['lt', 2];
                    $param['check_user_id'] = ['like', '%,'. $param['user_id'] .',%'];
                    # 要提醒的商机ID
                    $customerCheckIdArray = db('crm_dealt_relation')->where(['types' => ['eq', 'crm_customer_check'], 'user_id' => ['eq', $param['user_id']]])->column('types_id');
                    $param['customerCheckIdArray'] = !empty($customerCheckIdArray) ? $customerCheckIdArray : -1;
                    break;
                case '2' :
                    # 全部
                    $param['flow_user_id'] = ['like', '%,'. $param['user_id'] .',%'];
                    break;
            }
        }
        return $param;
    }
    
    /**
     * 负责人查询条件
     * @param $param
     *
     * @author      alvin guogaobo
     * @version     1.0 版本号
     * @since       2021/5/24 0024 09:46
     */
    public function where($param, $type, $isSub, $todayTime)
    {
        # 负责人
        $param['owner_user_id'] = !empty($isSub) ? ['in', getSubUserId(false, 0, $param['user_id'])] : ['eq', $param['user_id']];
        # 类型：1今日需联系；2已逾期；3已联系
        if (empty($isSub) && empty($todayTime)) {
            switch ($type) {
                case '1' :
                    $param['follow'] = [['neq', '已跟进'], null, 'or'];
                    $param['is_allocation'] = 1;
                    break;
                case '2' :
                    $param['follow'] = ['eq', '已跟进'];
                    $param['is_allocation'] = 1;
                    break;
            }
        } else {
            switch ($type) {
                case '1' :
                    $param['next_time'] = ['between', [$todayTime[0], $todayTime[1]]];
                    $param['is_dealt'] = ['neq', 1];
                    break;
                case '2' :
                    $param['next_time'] = ['between', [1, time()]];
                    $param['overdue'] = true;
                    $param['is_dealt'] = ['neq', 1];
                    break;
                case '3' :
                    $param['last_time'] = ['between', [$todayTime[0], $todayTime[1]]];
                    break;
            }
        }
        return $param;
    }
}