修改插件

plugins/addon/example/logic/IdcsmartTicketLogic.php

@@ -0,0 +1,399 @@
+<?php
+namespace addon\idcsmart_ticket\logic;
+
+use addon\idcsmart_ticket\model\IdcsmartTicketInternalModel;
+use addon\idcsmart_ticket\model\IdcsmartTicketModel;
+use addon\idcsmart_ticket\IdcsmartTicket;
+use addon\idcsmart_ticket\model\IdcsmartTicketReplyModel;
+use addon\idcsmart_ticket\model\IdcsmartTicketStatusModel;
+use addon\idcsmart_ticket\model\IdcsmartTicketTypeModel;
+use addon\idcsmart_ticket\model\IdcsmartTicketUpstreamModel;
+use app\admin\model\PluginModel;
+
+class IdcsmartTicketLogic
+{
+    # 默认配置
+    public static function getDefaultConfig($name = '')
+    {
+        $fileConfig = include dirname(__DIR__) . '/config/config.php';
+
+        $dbConfig = (new IdcsmartTicket())->getConfig();
+        
+        $config = array_merge($fileConfig?:[],$dbConfig?:[]);
+
+        return isset($config[$name])?$config[$name]:$config;
+    }
+
+    # 工单号生成
+    public function ticketNum($prefix='YHGD')
+    {
+        $IdcsmartTicketModel = new IdcsmartTicketModel();
+
+        $ticketNum = rand_str(7,'NUMBER');
+
+        for ($i=0;$i<10;$i++){ # 至多10次比较
+            $exist = $IdcsmartTicketModel->where('ticket_num',$ticketNum)->find();
+            if (empty($exist)){
+                break;
+            }
+            $ticketNum = rand_str(7,'NUMBER');
+        }
+
+        return [$ticketNum,$ticketNum];
+    }
+
+    public function setConfig($param)
+    {
+        $PluginModel = new PluginModel();
+
+        $plugin = $PluginModel->where('name','IdcsmartTicket')->find();
+
+        $config =  json_decode($plugin['config'],true);
+
+        $config['refresh_time'] = $param['refresh_time']??($config['refresh_time']??3);
+        $config['ticket_notice_open'] = $param['ticket_notice_open']??($config['ticket_notice_open']??1);
+        if (isset($param['ticket_notice_description']) && !empty($param['ticket_notice_description'])){
+            $config['ticket_notice_description'] = htmlspecialchars($param['ticket_notice_description']);
+        }else{
+            $config['ticket_notice_description'] = $config['ticket_notice_description']??"";
+        }
+
+        if (isset($param['ticket_type_id']) && !empty($param['ticket_type_id'])){
+            $IdcsmartTicketTypeModel = new IdcsmartTicketTypeModel();
+            $ticketType = $IdcsmartTicketTypeModel->where('id',$param['ticket_type_id'])->find();
+            if (empty($ticketType)){
+                return ['status'=>400,'msg'=>lang_plugins('ticket_type_is_not_exist')];
+            }
+            $config['ticket_type_id'] = $param['ticket_type_id'];
+        }
+        $config['downstream_delivery'] = intval($param['downstream_delivery']??0);
+
+        $config['ticket_close_switch'] = $param['ticket_close_switch']??($config['ticket_close_switch']??0);
+        $config['ticket_close_hour'] = $param['ticket_close_hour']??($config['ticket_close_hour']??0);
+
+        $plugin->save([
+            'config' => json_encode($config)
+        ]);
+
+        return [
+            'status' => 200,
+            'msg' => lang_plugins('success_message')
+        ];
+    }
+
+    /**
+     * 时间 2022-5-25
+     * @title curl下载解压包到指定路径
+     * @desc curl下载解压包到指定路径
+     * @author theworld
+     * @version v1
+     * @param string url - 下载链接地址
+     * @param string file_name - 目标路径
+     * @return mixed
+     */
+    public static function curl_download($url, $file_name)
+    {
+        $ch = curl_init($url);
+        //设置抓取的url
+        $dir = $file_name;
+        $fp = fopen($dir, "wb");
+        curl_setopt($ch, CURLOPT_FILE, $fp);
+        curl_setopt($ch, CURLOPT_HEADER, 0);
+
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
+        $res=curl_exec($ch);
+        curl_close($ch);
+        fclose($fp);
+
+        return $res;
+    }
+
+    public static function idcsmartApiCurlUploadFile($api_id,$file_path,$file_name)
+    {
+        $login = idcsmart_api_login($api_id);
+        if ($login['status']!=200){
+            return $login;
+        }
+
+        if($login['data']['supplier']['type']!='default'){
+            return ['status'=>400,'msg'=>lang_plugins('ticket_supplier_not_support_delivery')];
+        }
+
+        // 下载对象存储的文件
+        $fileUrl = getOssUrl([
+            'file_path' => $file_path,
+            'file_name' => $file_name
+        ])['url'];
+
+        if (strpos($file_name,'^')!==false){
+            $file_name = explode('^',$file_name)[1];
+        }
+
+        $file = UPLOAD_DEFAULT.$file_name;
+
+        self::curl_download($fileUrl, $file);
+
+        if (!file_exists($file)){
+            return ['status'=>400,'msg'=>lang_plugins('source_file_not_exist')];
+        }
+
+        $url = $login['data']['url'] . '/console/v1/upload';
+
+        $header = [
+            'Authorization: Bearer '.$login['data']['jwt']
+        ];
+
+        $file = realpath($file);
+
+        $data = ['file' => new \CURLFile($file)];
+
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL, $url);
+        $ssl = substr($url, 0, 8) == 'https://' ? true : false;
+        //if ($ssl) {
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // 对认证证书来源的检查
+        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
+        //}
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
+        curl_setopt($ch, CURLOPT_POST, true);
+        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
+        if(!empty($header)){
+            curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
+        }
+        $response = curl_exec($ch);
+        $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+        curl_close($ch);
+
+        if ($file==UPLOAD_DEFAULT.$file_name){
+            unlink($file);
+        }
+
+        if ($http_code!=200){
+            return ['status'=>400, 'msg'=>lang_plugins('ticket_network_desertion')];
+        }
+
+        $response = json_decode($response,true);
+
+        return $response;
+    }
+
+    /**
+     * 时间 2024-06-18
+     * @title 判断后台当前工单是否可操作
+     * @desc 判断后台当前工单是否可操作，涉及：
+     * @author wyh
+     * @version v1
+     * @param int ticketId - 工单ID required
+     * @return boolean
+     */
+    public static function checkUpstreamTicket($ticketId)
+    {
+        // 考虑到目前逻辑是一个工单最多对应一个产品，所以这里直接拉取
+        $IdcsmartTicketUpstreamModel = new IdcsmartTicketUpstreamModel();
+        $ticketUpstream = $IdcsmartTicketUpstreamModel->where('ticket_id',$ticketId)->find();
+        // 1、没有对应的上游工单，可操作
+        if (empty($ticketUpstream)){
+            return true;
+        }
+        // 2、对于多级传递来说，中间层不可操作(有上游，也有下游)
+        $IdcsmartTicketModel = new IdcsmartTicketModel();
+        $ticket = $IdcsmartTicketModel->find($ticketId);
+        if ($ticket['downstream_ticket_id']>0){
+            // 若本地已关闭传递，且下游已开启传递或者已关闭；则可操作
+            if ($ticketUpstream['delivery_status']==0/* && $ticket['downstream_delivery_status']==1*/){
+                return true;
+            }
+            return false;
+        }
+
+        // 3、已关闭传递，可操作
+        if ($ticketUpstream['delivery_status']==0){
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * 时间 2024-06-18
+     * @title 判断前台当前工单是否可操作
+     * @desc 判断前台当前工单是否可操作，涉及：
+     * @author wyh
+     * @version v1
+     * @param int ticketId - 工单ID required
+     * @return boolean
+     */
+    public static function checkDownstreamTicket($ticketId)
+    {
+        $IdcsmartTicketModel = new IdcsmartTicketModel();
+
+        $ticket = $IdcsmartTicketModel->find($ticketId);
+
+        if ($ticket['is_downstream']==1 && $ticket['downstream_delivery_status']==1){
+            return false;
+        }
+
+        return true;
+    }
+
+    // 后台判断是否可以向下游推送
+    public static function checkPushTicketToDownstream(IdcsmartTicketModel $ticket)
+    {
+        if ($ticket['is_downstream'] && $ticket['downstream_delivery_status']==1){
+            return true;
+        }
+
+        return false;
+    }
+
+    // 下游验证签名
+    public static function validateSign($params){
+        $sign = $params['signature'];
+        // 用这几个参数生成签名
+        $data = [
+            'id'=>(int)$params['id'], // 数据类型必须和生成签名时的类型一致
+            'token'=>$params['token'],
+            'rand_str'=>$params['rand_str'],
+        ];
+        ksort($data, SORT_STRING);
+        $str = json_encode($data);
+        $signature = md5($str);
+        return strtoupper($signature) === $sign;
+    }
+
+    // 推送通用curl请求
+    public static function commonCurl($url, $data = [], $timeout = 30, $request = 'POST', $header = [])
+    {
+        $result = curl($url,$data,$timeout,$request,$header);
+
+        if($result['http_code'] != 200){
+            return ['status'=>400, 'msg'=>lang('network_desertion'), 'content'=>$result['content']];
+        }
+
+        $result = json_decode($result['content'], true);
+
+        if ($result['status']==401){
+            $result['status']=400;
+            $result['msg'] = lang('network_desertion');
+        }
+
+        return $result;
+    }
+
+    // 推送工单状态至下游
+    public static function pushTicketStatus(IdcsmartTicketModel $ticket,IdcsmartTicketStatusModel $ticketStatus,$param)
+    {
+        if (self::checkPushTicketToDownstream($ticket)){
+            // 非默认状态
+            if (!in_array($param['status'],[1,2,3,4,5])){
+                // 完结状态推送至下游，下游为已回复
+                if ($ticketStatus['status']==1){
+                    $param['status'] = 3;
+                }else{
+                    // 未完结状态推送至下游，下游为处理中
+                    $param['status'] = 5;
+                }
+            }
+            $data = [
+                'status' => $param['status']
+            ];
+            $sign = create_sign(['id'=>$ticket['downstream_ticket_id']],$ticket['downstream_token']);
+            $data = array_merge($data,$sign);
+            $res = IdcsmartTicketLogic::commonCurl(rtrim($ticket['downstream_url'],'/')."/console/v1/api/ticket/{$ticket['downstream_ticket_id']}/status", $data, 30, 'PUT');
+            if ($res['status']==200){
+                active_log(lang_plugins('ticket_log_admin_update_downstream_ticket_status_success',
+                    ['{admin}'=>'admin#'.request()->admin_id.'#' .request()->admin_name.'#','{ticket}'=>'ticket#'.$ticket['ticket_num'],'{status}'=>$ticketStatus['name'],'{url}'=>$ticket['downstream_url']]),
+                    'addon_idcsmart_ticket', $ticket['id']);
+            }else{
+                active_log(lang_plugins('ticket_log_admin_update_downstream_ticket_status_fail',
+                    ['{admin}'=>'admin#'.request()->admin_id.'#' .request()->admin_name.'#','{ticket}'=>'ticket#'.$ticket['ticket_num'],'{status}'=>$ticketStatus['name'],'{url}'=>$ticket['downstream_url'],'{reason}'=>$res['msg']]),
+                    'addon_idcsmart_ticket', $ticket['id']);
+            }
+        }
+
+        return true;
+    }
+
+    // 推送工单回复内容更改至下游
+    public static function pushTicketReply(IdcsmartTicketModel $ticket,IdcsmartTicketReplyModel $ticketReply,$param)
+    {
+        if (self::checkPushTicketToDownstream($ticket)){
+            $data = [
+                'ticket_reply_id' => $ticketReply['downstream_ticket_reply_id'],
+                'content' => $param['content']??""
+            ];
+            $sign = create_sign(['id'=>$ticket['downstream_ticket_id']],$ticket['downstream_token']);
+            $data = array_merge($data,$sign);
+            $res = IdcsmartTicketLogic::commonCurl(rtrim($ticket['downstream_url'],'/')."/console/v1/api/ticket/{$ticket['downstream_ticket_id']}/reply", $data, 30, 'PUT');
+            if ($res['status']==200){
+                active_log(lang_plugins('ticket_log_admin_update_downstream_ticket_reply_success',
+                    ['{admin}'=>'admin#'.request()->admin_id.'#' .request()->admin_name.'#','{ticket}'=>'ticket#'.$ticket['ticket_num'],'{ticket_reply_id}'=>$ticketReply['id'],'{url}'=>$ticket['downstream_url']]),
+                    'addon_idcsmart_ticket', $ticket['id']);
+            }else{
+                active_log(lang_plugins('ticket_log_admin_update_downstream_ticket_reply_fail',
+                    ['{admin}'=>'admin#'.request()->admin_id.'#' .request()->admin_name.'#','{ticket}'=>'ticket#'.$ticket['ticket_num'],'{ticket_reply_id}'=>$ticketReply['id'],'{url}'=>$ticket['downstream_url'],'{reason}'=>$res['msg']]),
+                    'addon_idcsmart_ticket', $ticket['id']);
+            }
+        }
+
+        return true;
+    }
+
+    // 推送工单回复删除至下游
+    public static function pushTicketReplyDelete(IdcsmartTicketModel $ticket,IdcsmartTicketReplyModel $ticketReply,$param)
+    {
+        if (self::checkPushTicketToDownstream($ticket)){
+            $data = [
+                'ticket_reply_id' => $ticketReply['downstream_ticket_reply_id'],
+            ];
+            $sign = create_sign(['id'=>$ticket['downstream_ticket_id']],$ticket['downstream_token']);
+            $data = array_merge($data,$sign);
+            $res = IdcsmartTicketLogic::commonCurl(rtrim($ticket['downstream_url'],'/')."/console/v1/api/ticket/{$ticket['downstream_ticket_id']}/reply", $data, 30, 'DELETE');
+            if ($res['status']==200){
+                active_log(lang_plugins('ticket_log_admin_update_downstream_ticket_reply_delete_success',
+                    ['{admin}'=>'admin#'.request()->admin_id.'#' .request()->admin_name.'#','{ticket}'=>'ticket#'.$ticket['ticket_num'],'{ticket_reply_id}'=>$ticketReply['id'],'{url}'=>$ticket['downstream_url']]),
+                    'addon_idcsmart_ticket', $ticket['id']);
+            }else{
+                active_log(lang_plugins('ticket_log_admin_update_downstream_ticket_reply_delete_fail',
+                    ['{admin}'=>'admin#'.request()->admin_id.'#' .request()->admin_name.'#','{ticket}'=>'ticket#'.$ticket['ticket_num'],'{ticket_reply_id}'=>$ticketReply['id'],'{url}'=>$ticket['downstream_url'],'{reason}'=>$res['msg']]),
+                    'addon_idcsmart_ticket', $ticket['id']);
+            }
+        }
+
+        return true;
+    }
+
+    // 推送工单回复至下游
+    public static function pushTicketReplyCreate(IdcsmartTicketModel $ticket,IdcsmartTicketReplyModel $ticketReply,$param)
+    {
+        if (self::checkPushTicketToDownstream($ticket)){
+            $data = [
+                'content' => htmlspecialchars_decode($ticketReply['content']),
+                'upstream_ticket_reply_id' => $ticketReply['id'],
+                'attachment' => [],
+            ];
+            $sign = create_sign(['id'=>$ticket['downstream_ticket_id']],$ticket['downstream_token']);
+            $data = array_merge($data,$sign);
+            $res = IdcsmartTicketLogic::commonCurl(rtrim($ticket['downstream_url'],'/')."/console/v1/api/ticket/{$ticket['downstream_ticket_id']}/reply", $data, 30, 'POST');
+            if ($res['status']==200){
+                $ticketReply->save([
+                    'is_downstream' => 1,
+                    'downstream_ticket_reply_id' => $res['data']['ticket_reply_id'],
+                    'update_time' => time()
+                ]);
+                active_log(lang_plugins('ticket_log_admin_update_downstream_ticket_reply_create_success',
+                    ['{admin}'=>'admin#'.request()->admin_id.'#' .request()->admin_name.'#','{ticket}'=>'ticket#'.$ticket['ticket_num'],'{ticket_reply_id}'=>$ticketReply['id'],'{url}'=>$ticket['downstream_url']]),
+                    'addon_idcsmart_ticket', $ticket['id']);
+            }else{
+                active_log(lang_plugins('ticket_log_admin_update_downstream_ticket_reply_create_fail',
+                    ['{admin}'=>'admin#'.request()->admin_id.'#' .request()->admin_name.'#','{ticket}'=>'ticket#'.$ticket['ticket_num'],'{ticket_reply_id}'=>$ticketReply['id'],'{url}'=>$ticket['downstream_url'],'{reason}'=>$res['msg']]),
+                    'addon_idcsmart_ticket', $ticket['id']);
+            }
+        }
+
+        return true;
+    }
+
+}