<?php
defined('BASEPATH') or exit('No direct script access allowed');

class Notice extends CI_Controller
{
    private $log_dir = 'plan_notice';

    public function __construct()
    {
        parent::__construct();
        $this->load->model('receiver/receiver_clues_model', 'clues_model');
        $this->load->model('receiver/receiver_clues_notice_model', 'clues_notice_model');
        $this->load->model('sys/sys_notice_model');
        $this->load->model('sys/Sys_admin_model', 'sysAdmin');
    }

    /**
     * 线索通知
     * @return void
     */
    public function clues()
    {
        $logPath = "clues.txt";
        $cluseNoticeRow = $this->clues_notice_model->select([], 'clue_id desc', 1, 1);
        $where = [
            'app_id' => Receiver_clues_model::APP_ID_ACTIVITY
        ];
        if ($cluseNoticeRow[0]) {
            $where['id>'] = $cluseNoticeRow[0]['clue_id'];
        }
        $cluesRow = $this->clues_model->select($where, 'id asc', 1, 20);
        if ($cluesRow) {
            $noticeAdmins = $this->sysAdmin->select(['role_id' => 2, 'status' => 1], '', 0, 0, 'id,other_json');
            foreach ($cluesRow as $item) {
                debug_log("开始处理线: {$item['id']}", $logPath);
                $mobile = substr($item['mobile'], -4);
                $content = "超级车补新增了一条线索，尾号{$mobile}，请及时查看处理。";
                //推送消息给中台客服
                if ($noticeAdmins) {
                    foreach ($noticeAdmins as $noticeAdmin) {
                        $otherJson = json_decode($noticeAdmin['other_json'], true);
                        if ($item['belong_id'] && $item['belong_id'] != $otherJson['belong_id']) {
                            continue;
                        }
                        $params = [
                            'platform' => Sys_notice_model::PLAT_FORM_ADMIN,
                            'uid' => $noticeAdmin['id'],
                            'content' => $content,
                            'url' => '/receiver/clues/get?id=' . $item['id'],
                        ];
                        $sendPlatform = Sys_notice_model::PLAT_FORM_SYS_H5;
                        $this->sys_notice_model->addNotice($params, $sendPlatform);
                    }
                }
                if ($item['pingan_user_id']) {
                    $params = [
                        'platform' => Sys_notice_model::PLAT_FORM_PINGAN,
                        'uid' => $item['pingan_user_id'],
                        'content' => $content,
                        'url' => '/receiver/clues/detail?id=' . $item['id'],
                    ];
                    $sendPlatform = Sys_notice_model::PLAT_FORM_SYS_H5;
                    $this->sys_notice_model->addNotice($params, $sendPlatform);
                }
                $this->clues_notice_model->add([
                    'clue_id' => $item['id'],
                    'c_time' => time(),
                ]);
                debug_log("处理完成线: {$item['id']}", $logPath);
            }
        } else {
            echo '没有新线索';
        }
    }
}