crm/app/api/controller/UserMsg.php

<?php

namespace app\api\controller;

use app\model\EmployeeMsg;
use app\model\ExamPaper;
use app\model\ExamPaperQuestion;
use app\model\ExamQuestion;
use app\model\ExamEmpResult;
use app\model\Customer;
use app\model\User;
class UserMsg extends Base
{
    /**
     * 列表获取
     */
    public function list($page, $limit)
    {
        $token = $this->request->token;
        $condition = [
            ['employee_id', '=', $token['employee_id']],
        ];
        $data = EmployeeMsg::where($condition)->page($page, $limit)->order('id desc')->select();
        $data->update(['saw' => 1]);

        //returnVisit 待回访消息提醒
        foreach ($data as $k => $v) {
            if ($v['type'] == 'returnVisit') {
                $v['user_type'] = !Customer::where([['id','=',$v['data']],['employee_id|designer_id','=',$token['employee_id']]])->findOrEmpty()->isEmpty();
            }elseif($v['type'] == 'building'){
                $customer_id=null;
                $jd=json_decode($v['data'],true);
                if(!empty($jd) && is_array($jd)){
                    $customer_id=Customer::where([['employee_id','=',$token['employee_id']],['uid','=',$jd['uid']]])->value('id');
                    if(empty($customer_id)){
                        $user=User::where(['id'=>$jd['uid'],'root_id'=>$token['root_org']])->field('phone,nickname')->find();
                        if(!empty($user['phone'])){
                            $customer_id= Customer::where(['employee_id'=>$token['employee_id'],'phone'=>cypherphone(trim($user['phone']))])->value('id');
                        }
                    }
                    
                }
                $v['user_type'] = $customer_id ? $customer_id : false;
            }else{
                $v['user_type'] = false;
            }
        }

        return json(['code' => self::success, 'data' => $data]);
    }

    /**
     * 未阅读消息数量获取
     */
    public function unreadCount()
    {
        $token = $this->request->token;
        // $token['root_org'] = 23;
        // $token['employee_id'] = 58;
        $condition = [
            ['employee_id', '=', $token['employee_id']],
            ['saw', '=', 0]
        ];
        $num = EmployeeMsg::where($condition)->count();

        //是否存在待批改的试卷
        $root_id = $token['root_org'];
        $w[] = ['exam_emp_result.root_id','=',$root_id];
        $w[] = ['paper.root_id','=',$root_id];
        $w[] = ['exam_emp_result.state','=',1];
        // $w[] = ['exam_emp_result.checked','=',0];
        $w[] = ['exam_emp_result.approve_status','<>',2];
        // $res['data'] = $num;

        $paper = ExamEmpResult::withJoin('paper')->where($w)->whereRaw("FIND_IN_SET(".$token['employee_id']." , approve_employee_ids)")->select()->toArray();
        
        $paper = $paper ? 1 : 0;
        return json(['code' => self::success, 'data' => $num,'paper'=>$paper]);
    }
}