xky/app/Service/DingService.php

<?php

namespace App\Service;

use App\Model\DDEmployee;
use App\Model\Record;
use Illuminate\Support\Facades\Redis;

class DingService extends Service
{
    public function getAccessToken($type)
    {
        $key = DDEmployee::type_redis[$type];
        if(empty($key)) return [false, 'token名称未设置'];
        $token = Redis::get($key);
        if(! empty($token)) return [true, ['access_token' => $token]];
        $config = config("dingtalk.{$type}");
        if(empty($config)) return [false, '钉钉配置信息不存在'];
        $appKey = $config['app_key'] ?? null;
        $appSecret = $config['app_secret'] ?? null;
        if (!$appKey) return [false, 'AppKey 配置不完整'];
        if (!$appSecret) return [false, 'AppSecret 配置不完整'];

        $url = "https://api.dingtalk.com/v1.0/oauth2/accessToken";
        $resp = $this->curlOpen1($url, [
            'request' => 'post',
            'header'  => ['Content-Type: application/json'],
            'json'    => [
                "appKey"    => $appKey,
                "appSecret" => $appSecret
            ]
        ]);
        $res = json_decode($resp, true);
        $accessToken = $res['accessToken'] ?? "";
        $expires_in = $res['expires_in'] ?? 0;
        if(empty($accessToken)) return [false, 'AccessToken获取失败'];
        Redis::setex($key, $expires_in, $accessToken);

        return [true, ['access_token' => $accessToken]];
    }

    /**
     * 根据前端传来的免登 code 获取用户信息
     * @param string $code 前端 dd.getAuthCode 获取的 code
     * @return array [bool, data]  bool 表示成功与否，data 成功返回用户信息，失败返回错误信息
     */
    public function getUserByCode($data, $LoginType)
    {
        if(empty($LoginType)) return [false, 'login_type类型不能为空'];
        if(! isset(DDEmployee::type[$LoginType])) return [false, 'login_type类型不存在或错误'];

        $code = $data['code'] ?? "";
        if (empty($code)) return [false, '钉钉授权code不能为空'];

        // 1. 获取 access_token
        [$success, $tokenData] = $this->getAccessToken($LoginType);
        if (! $success) return [false, $tokenData]; // tokenData 是错误信息
        $accessToken = $tokenData['access_token'];

        // 2. 用 code 换取用户信息（v2 接口）
        $url = "https://oapi.dingtalk.com/topapi/v2/user/getuserinfo?access_token={$accessToken}";

        $resp = $this->curlOpen1($url, [
            'request' => 'post',
            'header'  => [
                "Content-Type: application/json",
            ],
            'json'    => [
                "code" => $code
            ]
        ]);

        $res = json_decode($resp, true);

        if (!isset($res['errcode'])) {
            return [false, '接口返回异常: ' . $resp];
        }

        if ($res['errcode'] !== 0) {
            return [false, '获取用户信息失败: ' . $res['errmsg']];
        }

        if(! empty($res['result'])){
            $result = $res['result'];

            DDEmployee::updateOrCreate(
                ['userid' => $result['userid']],
                ['name' => $result['name'], 'userid' => $result['userid'], 'login_type' => $LoginType]
            );
        }

        return [true, $res];
    }

    private function getManDetail($user, $accessToken){
        // 3. 根据 userid 获取详细用户信息（包括部门）
        $urlDetail = "https://oapi.dingtalk.com/topapi/v2/user/get?access_token={$accessToken}";
        $respDetail = $this->curlOpen1($urlDetail, [
            'request' => 'post',
            'header'  => ["Content-Type: application/json"],
            'json'    => ["userid" => $user['userId']]
        ]);
        $detail = json_decode($respDetail, true);

        if (!isset($detail['errcode'])) return [false, '获取用户详情接口异常: ' . $respDetail];
        if ($detail['errcode'] !== 0) return [false, '获取用户详情失败: ' . $detail['errmsg']];
        if (empty($detail['result'])) return [false, '获取用户详情失败，结果为空'];

        // 返回完整用户信息
        return [true, $detail['result']];
    }

    public function createProcessInstance($data, $user)
    {
        if(empty($data['type'])) return [false, '单据类型不能为空'];
        $type = $data['type'];
        if(empty($data['order_number'])) return [false,'订单号不能为空'];
        [$success, $msg] = $this->checkCreateProcessInstance($data, $user);
        if(! $success) return [false, $msg];

        //获取模板id
        $code = $this->getModelCode($type, $user);
        //获取模板数据
        [$success, $formData] = $this->getFormData($data, $user);
        if(! $success) return [false, $formData];

        // 1. 获取 access_token
        [$success, $tokenData] = $this->getAccessToken($user['login_type']);
        if (!$success) return [false, $tokenData];
        $accessToken = $tokenData['access_token'];

        $userId = $user['userId'];
        [$success, $userDetail] = $this->getManDetail($user, $accessToken);
        if(!$success) return [false, $userDetail];

        //创建审批
        [$success, $msg] = $this->createFlow($accessToken, $code, $userId, $userDetail, $formData);
        if(! $success) return [false, $msg];

        //记录信息
        $this->recordDatabase($data, $user, $msg);

        return [true, ''];
    }

    private function recordDatabase($data, $user, $process_instance_id){
        $type = $data['type'];

        Record::insert([
            'type' => $type,
            'login_type' => $user['login_type'],
            'database' => $user['zt_database'],
            'order_number'=> $data['order_number'],
            'crt_time' => time(),
            'process_instance_id' => $process_instance_id
        ]);

        return [true, ''];
    }

    private function checkCreateProcessInstance($data, $user){
        list($status,$msg) = $this->limitingSendRequestBackgExpire($data['order_number'].$data['type'].$user['zt_database']);
        if(! $status) return [false,$msg];

        $type = $data['type'];
        $login_type = $data['login_type'];

        $bool = Record::where('del_time',0)
            ->where('type', $type)
            ->where('login_type', $login_type)
            ->where('database', $user['zt_database'])
            ->where('order_number',$data['order_number'])
            ->exists();
        if($bool) return [false, '单号' . $data['order_number'] . '已创建审批流'];

        return [true, ''];
    }

    private function createFlow($accessToken, $code, $userId, $userDetail, $formData){
        // 2. 请求 URL
        $url = "https://oapi.dingtalk.com/topapi/processinstance/create?access_token={$accessToken}";

        // 3. 请求体
        $payload = [
            "process_code" => $code,            // 审批模板编码
            "originator_user_id" => $userId,    // 发起人 userId
            "dept_id" => $userDetail['dept_id_list'][0],               // 发起人部门 ID
            "form_component_values" => $formData, // 表单数据
        ];

        // 4. 发送请求
        $resp = $this->curlOpen1($url, [
            'request' => 'post',
            'header'  => [
                "Content-Type: application/json",
            ],
            'json'    => $payload
        ]);

        $res = json_decode($resp, true);

        if (!isset($res['errcode'])) {
            return [false, "接口返回异常: " . $resp];
        }

        if ($res['errcode'] !== 0) {
            return [false, "创建审批实例失败: " . $res['errmsg']];
        }

        return [true, $res['process_instance_id']];
    }

    /**
     * 获取当前用户待审批的实例 ID 列表
     * @param string $accessToken
     * @param string $userId 钉钉用户的 userId
     * @param int $cursor 分页游标，从0开始
     * @param int $size 分页大小，最大100
     */
    public function getTodoProcessList($data, $user)
    {
        [$success, $tokenData] = $this->getAccessToken($user['login_type']);
        if (!$success) return [false, $tokenData];
        $accessToken = $tokenData['access_token'];

        $cursor = $data['cursor'] ?? 0;
        $size = $data['size'] ?? 20;

        // 1. 请求 URL
        $url = "https://oapi.dingtalk.com/topapi/process/todo/list?access_token={$accessToken}";

        // 2. 请求体
        $payload = [
            "userid" => $user['userid'],
            "cursor" => $cursor,
            "size"   => $size,
        ];

        // 3. 发送请求
        $resp = $this->curlOpen1($url, [
            'request' => 'post',
            'header'  => ["Content-Type: application/json"],
            'json'    => $payload
        ]);

        $res = json_decode($resp, true);

        if (!isset($res['errcode']) || $res['errcode'] !== 0) return [false, "获取待办列表失败: " . ($res['errmsg'] ?? '未知错误')];


        // 4. 提取 process_instance_id
        // 返回的结果中包含数据列表，我们需要从中提取所有的实例ID
        $list = $res['result']['list'] ?? [];
        $instanceIds = array_column($list, 'process_instance_id');

        $result = Record::whereIn('process_instance_id', $instanceIds)
            ->select('type', 'order_number')
            ->get()->toArray();

        return [true, [
            'list' => $result, // 所有的待我审核
            'has_more'     => $res['result']['has_more'] ?? false, // 是否还有更多
            'next_cursor'  => $res['result']['next_cursor'] ?? null // 下一页游标
        ]];
    }

    /**
     * 执行审批操作（同意/拒绝）
     * @param string $accessToken
     * @param string $processInstanceId 审批实例ID
     * @param string $action 'agree' 为同意，'refuse' 为拒绝
     * @param string $remark 审批意见
     * @param string $userId 执行审批操作的人员ID
     */
    public function executeApproval($data, $user)
    {
        [$success, $tokenData] = $this->getAccessToken($user['login_type']);
        if (!$success) return [false, $tokenData];
        $accessToken = $tokenData['access_token'];

        $processInstanceId = $data['process_instance_id'] ?? 0;
        $action = $data['action'] ?? 'agree';
        $remark = $data['remark'] ?? '同意';

        // 1. 请求 URL
        $url = "https://oapi.dingtalk.com/topapi/process/instance/execute?access_token={$accessToken}";

        // 2. 构造请求体
        $payload = [
            "process_instance_id" => $processInstanceId,
            "remark" => $remark,
            "result" => $action, // 'agree' 或 'refuse'
            "task_id" => $this->getTaskIdByInstanceId($accessToken, $processInstanceId, $user['userid']), // 获取当前人的任务ID
        ];

        // 3. 发送请求
        $resp = $this->curlOpen1($url, [
            'request' => 'post',
            'header'  => ["Content-Type: application/json"],
            'json'    => $payload
        ]);

        $res = json_decode($resp, true);

        if (!isset($res['errcode']) || $res['errcode'] !== 0) {
            return [false, "审批操作失败: " . ($res['errmsg'] ?? '未知错误')];
        }

        return [true, "操作成功"];
    }

    /**
     * 获取指定实例中属于某个用户的待办任务 ID
     */
    private function getTaskIdByInstanceId($accessToken, $instanceId, $userId)
    {
        $url = "https://oapi.dingtalk.com/topapi/processinstance/get?access_token={$accessToken}";

        $resp = $this->curlOpen1($url, [
            'request' => 'post',
            'header'  => ["Content-Type: application/json"],
            'json'    => ["process_instance_id" => $instanceId]
        ]);

        $res = json_decode($resp, true);
        $tasks = $res['process_instance']['tasks'] ?? [];

        foreach ($tasks as $task) {
            // 状态为 RUNNING (进行中) 且 处理人是当前用户
            if ($task['task_status'] === 'RUNNING' && $task['userid'] === $userId) {
                return $task['task_id'];
            }
        }

        return null;
    }

    private function getModelCode($type, $user){
        $login_type = $user['login_type'];
        if($login_type == DDEmployee::type_one){
            //浙江
            if($type == 1){
                // 采购单
                $code = "";
            }elseif ($type == 2){
                // 请购单
                $code = "";
            }elseif ($type == 3){
                // 采购入库单
                $code = "";
            }elseif ($type == 4){
                // 存货
                $code = "";
            }elseif ($type == 5){
                // 供应商
                $code = "";
            }
        }elseif ($login_type == DDEmployee::type_two){
            //杭州
            if($type == 1){
                // 采购单
                $code = "";
            }elseif ($type == 2){
                // 请购单
                $code = "";
            }elseif ($type == 3){
                // 采购入库单
                $code = "";
            }elseif ($type == 4){
                // 存货
                $code = "";
            }elseif ($type == 5){
                // 供应商
                $code = "";
            }
        }

        return $code ?? "";
    }

    private function getFormData($data, $user){
        //cs
//        $formData = [ [ "name" => "订单日期", "value" => "2025-09-23" ], [ "name" => "订单编号", "value" => "PO20250923001" ], [ "name" => "业务类型", "value" => "标准采购" ], [ "name" => "供应商", "value" => "XX供应商有限公司" ], [ "name" => "制单人", "value" => "陈庆鹏" ], [ "name" => "表体", "value" => json_encode([ [ [ "name" => "存货名称", "value" => "打印机" ], [ "name" => "数量", "value" => "2" ], [ "name" => "主计量单位", "value" => "台" ], [ "name" => "原币价税合计", "value" => "3000" ] ], [ [ "name" => "存货名称", "value" => "显示器" ], [ "name" => "数量", "value" => "5" ], [ "name" => "主计量单位", "value" => "个" ], [ "name" => "原币价税合计", "value" => "5000" ] ] ], JSON_UNESCAPED_UNICODE) ] ];
//        return [true, $formData];
        //cs
        $service = new U8ServerService($user);
        $error = $service->getError();
        if(! empty($error)) return [false, $error];
        [$success, $order] = $service->getOrderDetails($data, $user);
        if(! $success) return [false, $order];

        $type = $data['type'];
        if($type == 1){
            // 采购单
            $formData = $this->typeOne($order);
        }elseif ($type == 2){
            // 采购请购单
            $formData = $this->typeTwo($order);
        }elseif($type == 3){
            // 采购入库单
            $formData = $this->typeThree($order);
        }elseif($type == 4){
            // 存货
            $formData = $this->typeThree($order);
        }elseif($type == 5){
            // 供应商
            $formData = $this->typeThree($order);
        }
        if(empty($formData)) return [false, '审批参数不能为空'];

        return [true, $formData];
    }

    private function typeOne($userOrder){
        if (empty($userOrder)) return [];
        $formData = [
            [
                "name"  => "订单日期",
                "value" => date('Y-m-d', strtotime($userOrder['order_date'] ?? ''))
            ],
            [
                "name"  => "订单编号",
                "value" => $userOrder['order_number'] ?? ''
            ],
            [
                "name"  => "业务类型",
                "value" => $userOrder['business_type'] ?? ''
            ],
            [
                "name"  => "供应商",
                "value" => $userOrder['supplier_title'] ?? ''
            ],
            [
                "name"  => "制单人",
                "value" => $userOrder['crt_name'] ?? ''
            ],
            [
                "name"  => "表体", // 对应 TableField 的 label
                "value" => json_encode(
                    array_map(function($item){
                        return [
                            [
                                "name"  => "存货名称",
                                "value" => $item['product_title'] ?? ''
                            ],
                            [
                                "name"  => "数量",
                                "value" => $item['quantity'] ?? 0
                            ],
                            [
                                "name"  => "主计量", // 修改这里，对应模板字段
                                "value" => $item['unit_title'] ?? ''
                            ],
                            [
                                "name"  => "原币价税合计",
                                "value" => $item['amount'] ?? 0
                            ]
                        ];
                    }, $userOrder['detail'] ?? []),
                    JSON_UNESCAPED_UNICODE
                )
            ]
        ];

        return $formData;
    }

    private function typeTwo($userOrder){
        if (empty($userOrder)) return [];
        $formData = [
            [
                "name"  => "单据号",
                "value" => $userOrder['order_number'] ?? ''
            ],
            [
                "name"  => "日期",
                "value" => date('Y-m-d', strtotime($userOrder['order_date'] ?? ''))
            ],
            [
                "name"  => "业务类型",
                "value" => $userOrder['business_type'] ?? ''
            ],
            [
                "name"  => "请购人",
                "value" => $userOrder['purchase_name'] ?? ''
            ],
            [
                "name"  => "制单人",
                "value" => $userOrder['crt_name'] ?? ''
            ],
            [
                "name"  => "表体", // 对应 TableField 的 label
                "value" => json_encode(
                    array_map(function($item){
                        return [
                            [
                                "name"  => "存货名称",
                                "value" => $item['product_title'] ?? ''
                            ],
                            [
                                "name"  => "数量",
                                "value" => $item['quantity'] ?? 0
                            ],
                            [
                                "name"  => "主计量", // 修改这里，对应模板字段
                                "value" => $item['unit_title'] ?? ''
                            ],
                            [
                                "name"  => "要求到货日期",
                                "value" => $item['need_arrived_date'] ?? ''
                            ]
                        ];
                    }, $userOrder['detail'] ?? []),
                    JSON_UNESCAPED_UNICODE
                )
            ]
        ];

        return $formData;
    }

    private function typeThree($userOrder){
        if (empty($userOrder)) return [];
        $formData = [
            [
                "name"  => "单据编号",
                "value" => $userOrder['order_number'] ?? ''
            ],
            [
                "name"  => "日期",
                "value" => date('Y-m-d', strtotime($userOrder['order_date'] ?? ''))
            ],
            [
                "name"  => "供应商",
                "value" => $userOrder['supplier_title'] ?? ''
            ],
            [
                "name"  => "制单人",
                "value" => $userOrder['crt_name'] ?? ''
            ],
            [
                "name"  => "总金额",
                "value" => $userOrder['total_amount'] ?? 0
            ],
            [
                "name"  => "表体", // 对应 TableField 的 label
                "value" => json_encode(
                    array_map(function($item){
                        return [
                            [
                                "name"  => "来源",
                                "value" => $item['source'] ?? ''
                            ],
                            [
                                "name"  => "来源单据号",
                                "value" => $item['source_order_number'] ?? ''
                            ],
                            [
                                "name"  => "存货名称",
                                "value" => $item['product_title'] ?? ''
                            ],
                            [
                                "name"  => "数量",
                                "value" => $item['number'] ?? 0,
                            ],
                            [
                                "name"  => "主计量", // 修改这里，对应模板字段
                                "value" => $item['unit_title'] ?? ''
                            ],
                            [
                                "name"  => "申请金额",
                                "value" => $item['amount'] ?? 0
                            ]
                        ];
                    }, $userOrder['detail'] ?? []),
                    JSON_UNESCAPED_UNICODE
                )
            ]
        ];

        return $formData;
    }

    public function getTemplateFields($data)
    {
        $processCode = $data['code'] ?? "";
        if (empty($processCode)) {
            return [false, '模板编号 process_code 不能为空'];
        }

        [$ok, $tokenData] = $this->getAccessToken();
        if (! $ok) return [false, $tokenData];
        $accessToken = $tokenData['access_token'];

        // 注意这里是 GET，并且 processCode 是 query 参数
        $url = "https://api.dingtalk.com/v1.0/workflow/forms/schemas/processCodes?processCode={$processCode}";

        $resp = $this->curlOpen1($url, [
            'request' => 'get',
            'header'  => [
                "Content-Type: application/json",
                "x-acs-dingtalk-access-token: {$accessToken}"
            ],
        ]);

        $res = json_decode($resp, true);

        if (isset($res['schemas'])) {
            return [true, $res['schemas']];
        } else {
            return [false, $res];
        }
    }

    protected function curlOpen1($url, $config = [])
    {
        $default = [
            'post' => false,
            'request' => 'get',
            'header' => [],
            'json' => null,
            'timeout' => 30
        ];

        $arr = array_merge($default, $config);

        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_TIMEOUT, $arr['timeout']);
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);

        if (!empty($arr['header'])) {
            curl_setopt($ch, CURLOPT_HTTPHEADER, $arr['header']);
        }

        if ($arr['post'] || $arr['request'] !== 'get') {
            curl_setopt($ch, CURLOPT_CUSTOMREQUEST, strtoupper($arr['request']));
            if ($arr['json'] !== null) {
                curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($arr['json'], JSON_UNESCAPED_UNICODE));
            }
        }

        $result = curl_exec($ch);
        if ($result === false) {
            $err = curl_error($ch);
            curl_close($ch);
            return json_encode(['error' => $err]);
        }

        curl_close($ch);
        return $result;
    }
}