qyWechat/app/Support/qyApi/QyCommon.php

<?php

namespace App\Support\qyApi;

use App\Service\AccessTokenService;
use App\Service\HttpService;
use App\Log;
use App\RedisModel;
use App\Support\EmailQueue;

class QyCommon{

    /**
     * path:朋友圈接口路径 如：get_moment_comments(互动数据接口)
     */
	public static function momentCommon($path, $corpid, $params = [])
	{
        try{
            //记录调用日志
            Log::logInfo('企微朋友圈接口调用-'. $path, [
                'params' => $params,
                'corpid' => $corpid
            ], 'QyCommon/momentCommon');

    		# 获取AccessToken
            $accessToken = AccessTokenService::getAccessToken($corpid, $path);

            if(empty($accessToken)) {
                return false;
            }

            $requestUri = config('qyWechat.moment_common');
            $url = $requestUri . $path . '?access_token=' . $accessToken;

            $response = HttpService::httpPost($url, json_encode($params));

            if(empty($response)){
                Log::logError('企微朋友圈接口调用失败-'.$path, [
                    'url' => $url,
                    'params' => $params,
                    'corpid' => $corpid,
                    'response' => $response
                ], 'QyCommon/momentCommon');

                return false;
            }

            $response = json_decode($response, true);

            if( !isset($response['errcode']) || $response['errcode'] !== 0 ){
                Log::logError('企微朋友圈接口调用失败-'.$path, [
                    'url' => $url,
                    'params' => $params,
                    'corpid' => $corpid,
                    'response' => $response
                ], 'QyCommon/momentCommon');

                return false;
            }

            return $response;
        } catch (\Exception $e){
            Log::logError('企微朋友圈接口调用异常-'.$path, [
                    'path' => $path,
                    'params' => $params,
                    'corpid' => $corpid,
                    'msg' => $e->getMessage(),
                    'line' => $e->getLine()
                ], 'QyCommon/momentCommon');

            return false;
        }

	}

    /**
     * 企业发表朋友圈获取任务创建结果
     * @param $corpid string 企微id
     * @param $jobid string 企微朋友圈发布任务id
     * @return bool|mixed
     */
    public static function get_moment_task_result($corpid, $jobid)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '企业发表朋友圈获取任务创建结果');
        if(empty($accessToken)) {
            Log::logError('企业发表朋友圈获取任务创建结果', [
                'params' => [
                    'corpid' => $corpid,
                    'jobid' => $jobid
                ],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $requestUri = config('qyWechat.get_moment_task_result');
        $requestUri .= $accessToken.'&jobid='.$jobid;

        $response = HttpService::httpGet($requestUri );
        $responseData = json_decode($response, true);

        Log::logInfo('企业发表朋友圈获取任务创建结果', [
            'params' => [
                'corpid' => $corpid,
                'jobid' => $jobid
            ],
            'response' => $responseData
        ], 'qyWechat');

        return $responseData;
    }

    /**
     * 获取客户朋友圈企业发表的列表
     * @param $corpid string 企微id
     * @param $moment_id string 朋友圈id
     * @param $retry integer 重试次数
     * @return array|bool
     */
    public static function get_moment_task($corpid, $moment_id, $responseDataArr = [], $cursor = '', $retry = 0)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '获取客户朋友圈企业发表的列表');
        if(empty($accessToken)) {
            Log::logError('获取客户朋友圈企业发表的列表', [
                'params' => [
                    'corpid' => $corpid,
                    'moment_id' => $moment_id
                ],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $postData = [
            'moment_id' => $moment_id,
            'cursor' => $cursor,
            'limit' => 1000,
        ];

        $requestUri = config('qyWechat.get_moment_task');
        $requestUri .= $accessToken;

        while(true) {
            $response = HttpService::httpPost($requestUri, json_encode($postData));
            $responseData = json_decode($response, true);

            Log::logInfo('获取客户朋友圈企业发表的列表', [
                'params' => [
                    'corpid'    => $corpid,
                    'moment_id' => $moment_id,
                    'cursor'    => $postData['cursor']
                ],
                'response' => $responseData,
            ], 'qyWechat');

            if(isset($responseData['errcode']) && $responseData['errcode'] == 0) {
                // 获取下一页游标
                $cursor = $responseData['next_cursor'];
                $postData['cursor'] = $cursor;
                $responseDataArr = array_merge($responseDataArr, $responseData['task_list']);

                if(empty($cursor)) {
                    // 没有下一页数据了，结束循环
                    return $responseDataArr;
                }
            } else {
                # 检测是否为预期外的错误码需要处理
                // 系统繁忙 手机号码已存在
                if(isset($responseData['errcode']) && !in_array($responseData['errcode'], [-1])) {
                    $content = '获取客户朋友圈企业发表的列表响应结果异常';
                    $params = [
                        'params' => [
                            'corpid'    => $corpid,
                            'moment_id' => $moment_id,
                            'cursor'    => $postData['cursor']
                        ],
                        'response' => $responseData
                    ];
                    self::getMomentTaskErrorMsgSend($content, $params);
                }

                if($retry < 3) {
                    sleep(1);
                    $retry++;
                    return self::get_moment_task($corpid, $moment_id, $responseDataArr, $cursor, $retry);
                } else {
                    // 返回数据异常了，退出循环并报警
                    $content = '获取客户朋友圈企业发表的列表重试3次后失败';
                    $params = [
                        'params' => [
                            'corpid'    => $corpid,
                            'moment_id' => $moment_id,
                            'cursor'    => $postData['cursor']
                        ],
                        'response' => $responseData
                    ];
                    self::getMomentTaskErrorMsgSend($content, $params);
                    return $responseDataArr;
                }
            }
        }
    }

    public static function getMomentTaskErrorMsgSend($content, $params) {
        Log::logError($content, $params, 'qyWechat');
        EmailQueue::rPush($content, json_encode($params, 256), ['song.shen@kuxuan-inc.com'], '猎羽');
    }

    /**
     * 修改客户备注信息
     * @param $corpid string 企微id
     * @param $userid string 企业成员userid
     * @param $external_userid string 外部联系人userid
     * @param $remark string string 此用户对外部联系人的备注，最多20个字符
     * @param $description string 此用户对外部联系人的描述，最多150个字符
     * @param $remark_company string 此用户对外部联系人备注的所属公司名称，最多20个字符
     * @param $remark_mobiles array 此用户对外部联系人备注的手机号
     * @param $remark_pic_mediaid string 备注图片的mediaid，
     * @return array|bool
     *
     * remark_company只在此外部联系人为微信用户时有效。
     * remark，description，remark_company，remark_mobiles和remark_pic_mediaid不可同时为空。
     * 如果填写了remark_mobiles，将会覆盖旧的备注手机号。
     * 如果要清除所有备注手机号,请在remark_mobiles填写一个空字符串("")。
     * remark_pic_mediaid可以通过素材管理接口获得。
     */
    public static function update_customer_remark($corpid, $userid, $external_userid, $remark = null, $description = null,
        $remark_company = null, array $remark_mobiles = null, $remark_pic_mediaid = null)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '修改客户备注信息');
        if(empty($accessToken)) {
            Log::logError('修改客户备注信息', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $postData = [
            'userid' => $userid,
            'external_userid' => $external_userid,
        ];

        if(!is_null($remark)) {
            $postData['remark'] = $remark;
        }

        if(!is_null($description)) {
            $postData['description'] = $description;
        }

        if(!is_null($remark_company)) {
            $postData['remark_company'] = $remark_company;
        }

        if(!is_null($remark_mobiles)) {
            $postData['remark_mobiles'] = $remark_mobiles;
        }

        if(!is_null($remark_pic_mediaid)) {
            $postData['remark_pic_mediaid'] = $remark_pic_mediaid;
        }

        $requestUri = config('qyWechat.update_customer_remark');
        $requestUri .= $accessToken;

        $response = HttpService::httpPost($requestUri ,json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('修改客户备注信息', [
            'params' => [
                'corpid' => $corpid,
                'userid' => $userid,
                'external_userid' => $external_userid,
                'remark' => $remark,
                'description' => $description,
                'remark_company' => $remark_company,
                'remark_mobiles' => $remark_mobiles,
                'remark_pic_mediaid' => $remark_pic_mediaid,
            ],
            'response' => $responseData
        ], 'qyWechat');

        return $responseData;
    }

    /**
     * 创建企业标签
     * @param $corpid string 企微id
     * @param $group_id string 标签组id
     * @param $group_name string 标签组名称
     * @param $order integer 标签组排序值
     * @param $tag array 标签列表
     * @return mixed
     */
    public static function add_corp_tag($corpid, $group_id, $group_name, $order, $tag, $retry = 0)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '创建企业标签');
        if(empty($accessToken)) {
            Log::logError('创建企业标签', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $requestUri = config('qyWechat.add_corp_tag');
        $requestUri .= $accessToken;

        $params['tag'] = $tag; // '[{"name": "TAG_NAME_1","order": 1},{"name": "TAG_NAME_2","order": 2}]';
        if (!empty($group_name)) {
            $params['group_name'] = $group_name;
        }

        if (!empty($group_id)) {
            $params['group_id'] = $group_id;
        }

        if (!empty($order)) {
            $params['order'] = $order;
        }

        $responseData = HttpService::httpPost($requestUri, json_encode($params), true);
        if($responseData === false && $retry < 5) {
            $retry++;
            return self::add_corp_tag($corpid, $group_id, $group_name, $order, $tag, $retry);
        }
        $responseData = json_decode($responseData, 1);

        Log::logInfo('创建企业标签', [
            'params' => [
                'corpid' => $corpid,
                'group_id' => $group_id,
                'group_name' => $group_name,
                'order' => $order,
                'tag' => $tag,
            ],
            'response' => $responseData
        ], 'qyWechat');

        return $responseData;
    }

    /**
     * 编辑客户企业标签
     * @param $corpid string 企微id
     * @param $userid string 企微成员userid
     * @param $external_userid string 外部联系人userid
     * @param $add_tag array 要标记的企业标签列表
     * @param $remove_tag array 要移除的企业标签列表
     * @return bool|mixed
     */
    public static function mark_tag($corpid, $userid, $external_userid, $add_tag, $remove_tag, $retry=0)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '编辑客户企业标签');
        if(empty($accessToken)) {
            Log::logError('编辑客户企业标签', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败',
            ], 'qyWechat');
            return false;
        }

        $requestUri = config('qyWechat.mark_tag');
        $requestUri .= $accessToken;

        $postData['userid'] = $userid;
        $postData['external_userid'] = $external_userid;

        if($add_tag) {
            $postData['add_tag'] = $add_tag;
        }

        if($remove_tag) {
            $postData['remove_tag'] = $remove_tag;
        }

        $responseData = HttpService::httpPost($requestUri, json_encode($postData), true);
        if($responseData === false && $retry < 5) {
            $retry++;
            return self::mark_tag($corpid, $userid, $external_userid, $add_tag, $remove_tag, $retry);
        }
        $responseData = json_decode($responseData, 1);

        Log::logInfo('编辑客户企业标签', [
            'params' => [
                'corpid' => $corpid,
                'userid' => $userid,
                'external_userid' => $external_userid,
                'add_tag' => $add_tag,
                'remove_tag' => $remove_tag,
            ],
            'response' => $responseData,
        ], 'qyWechat');

        return $responseData;
    }

    /**
     * 获取企微所有已授权部门列表
     * @param $corpid
     * @return bool|mixed
     */
    public static function simplelist($corpid)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '获取企微所有已授权部门列表');
        if(empty($accessToken)) {
            Log::logError('获取企微所有已授权部门列表', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $requestUri = config('qyWechat.simplelist');
        $requestUri .= $accessToken.'&id=';

        $response = HttpService::httpGet($requestUri );
        $responseData = json_decode($response, true);

        Log::logInfo('获取企微所有已授权部门列表', [
            'params' => ['corpid' => $corpid],
            'response' => $responseData,
        ], 'qyWechat');

        return $responseData;
    }

    /**
     * 获取企业配置了联系我功能的客服列表
     * @param $corpid
     * @return bool|mixed
     */
    public static function get_follow_user_list($corpid)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '获取企业配置了联系我功能的客服列表');
        if(empty($accessToken)) {
            Log::logError('获取企业配置了联系我功能的客服列表', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $requestUri = config('qyWechat.get_follow_user_list');
        $requestUri .= $accessToken.'&id=';

        $response = HttpService::httpGet($requestUri );
        $responseData = json_decode($response, true);

        Log::logInfo('获取企业配置了联系我功能的客服列表', [
            'params' => ['corpid' => $corpid],
            'response' => $responseData,
        ], 'qyWechat');

        return $responseData;
    }

    /**
     * 获取部门详细信息
     * @param $corpid
     * @param $department_id
     * @return bool|mixed
     */
    public static function get_department_info($corpid, $department_id)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '获取部门详细信息');
        if(empty($accessToken)) {
            Log::logError('获取部门详细信息', [
                'params' => [
                    'corpid' => $corpid,
                    'depatment_id' => $department_id,
                ],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $requestUri = config('qyWechat.get_department_info');
        $requestUri .= $accessToken.'&id='.$department_id;

        $response = HttpService::httpGet($requestUri );
        $responseData = json_decode($response, true);

        Log::logInfo('获取部门详细信息', [
            'params' => [
                'corpid' => $corpid,
                'depatment_id' => $department_id,
            ],
            'response' => $responseData,
        ], 'qyWechat');

        return $responseData;
    }

    /**
     * 根据Oauth2授权code获取用户信息
     * */
    public static function getCustomerInfoByCode($corpid, $code)
    {
        # 获取SuiteAccessToken
        $accessToken = AccessTokenService::getAccessToken($corpid, '根据Oauth2授权code获取用户信息');
        if(empty($accessToken)) {
            Log::logError('根据Oauth2授权code获取用户信息时令牌获取失败', [
                'corpid' => $corpid,
                'code' => $code
            ], 'GetCustomerInfoByCode');

            return false;
        }

        # 获取用户信息API
        $getExternalContactUri = config('qyWechat.get_user_info');
        $getExternalContactUri .= $accessToken . '&code=' . $code;

        $response = HttpService::httpGet($getExternalContactUri);
        $responseData = json_decode($response, true);

        return $responseData;
    }

    /**
     * 分配在职成员客户
     * @param $corpid string 企微id
     * @param $handoverUserId string 被接替员工id
     * @param $takeoverUserId string 接替员工id
     * @param $externalUserIdList array 需要迁移的外部联系人id
     * @param $transferSuccessMsg string 迁移成功后为客户发送的提醒消息
     * @return mixed
     */
    public static function transferCustomerOnJob($corpid, $handoverUserId, $takeoverUserId, $externalUserIdList,
                                                 $transferSuccessMsg)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '分配在职成员客户');
        if(empty($accessToken)) {
            Log::logError('分配在职成员客户', [
                'params' => ['corpid' => $corpid, 'handover_userid' => $handoverUserId, 'takeover_userid' => $takeoverUserId,
                    'external_userid_list' => $externalUserIdList, 'transfer_success_msg' => $transferSuccessMsg],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.transfer_customer_on_job').$accessToken;
        $params['handover_userid'] = $handoverUserId;
        $params['takeover_userid'] = $takeoverUserId;
        if(!empty($transferSuccessMsg)) {
            $params['transfer_success_msg'] = $transferSuccessMsg;
        }

        $params['external_userid'] = $externalUserIdList;

        $result = HttpService::httpPost($url, json_encode($params), true);
        $result = json_decode($result, 1);

        Log::logInfo('分配在职成员客户', [
            'params' => ['corpid' => $corpid, 'handover_userid' => $handoverUserId, 'takeover_userid' => $takeoverUserId,
                'external_userid_list' => $externalUserIdList, 'transfer_success_msg' => $transferSuccessMsg],
            'responseData' => $result,
        ], 'qyWechat');

        return $result;
    }

    /**
     * 查询待分配的客户列表
     * @param $corpid
     * @param $cursor
     * @return mixed
     */
    public static function getUnassignedList($corpid, $cursor, $retry = 0)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '查询待分配的离职成员列表');
        if(empty($accessToken)) {
            Log::logError('查询待分配的离职成员列表', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.get_unassigned_list').$accessToken;
        $params['cursor'] = $cursor;

        $data = HttpService::httpPost($url, json_encode($params), true);
        if($data === false && $retry < 3) {
            $retry++;
            return self::getUnassignedList($corpid, $cursor, $retry);
        }
        $data = json_decode($data, 1);

        Log::logInfo('查询待分配的离职成员列表', [
            'params' => ['corpid' => $corpid, 'cursor' => $cursor],
            'responseData' => $data,
        ], 'qyWechat');

        return $data;
    }

    /**
     * 分配离职成员的客户
     * @param $corpid string 企业id
     * @param $handoverUserId string 原跟进成员的userid
     * @param $takeoverUserId string 接替成员的userid
     * @param $externalUserIdList array 客户的external_userid列表，每次最多分配100个客户
     * @return mixed
     * 注意：
     *  1.external_userid必须是handover_userid的客户（即配置了客户联系功能的成员所添加的联系人）。
     *  2.handover_userid必须是已离职用户。
     */
    public static function transferCustomerQuit($corpid, $handoverUserId, $takeoverUserId, $externalUserIdList)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '分配离职成员的客户');
        if(empty($accessToken)) {
            Log::logError('分配离职成员的客户', [
                'params' => ['corpid' => $corpid, 'handover_userid' => $handoverUserId, 'takeover_userid' => $takeoverUserId,
                    'external_userid_list' => $externalUserIdList],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.transfer_customer_quit').$accessToken;
        $params['handover_userid'] = $handoverUserId;
        $params['takeover_userid'] = $takeoverUserId;
        $params['external_userid'] = $externalUserIdList;

        $result = HttpService::httpPost($url, json_encode($params), true);
        $result = json_decode($result, 1);

        Log::logInfo('分配离职成员的客户', [
            'params' => ['corpid' => $corpid, 'handover_userid' => $handoverUserId, 'takeover_userid' => $takeoverUserId,
                'external_userid_list' => $externalUserIdList],
            'responseData' => $result,
        ], 'qyWechat');

        return $result;
    }

    /**
     * 客户迁移结果查询
     * @param $type int 接替类型 1在职 2离职
     * @param $corpid
     * @param $handOverUserId string 原跟进员工user_id
     * @param $takeOverUserId string 接替成员的user_id
     * @param string $cursor string 分页查询的游标
     * @return mixed
     */
    public static function transferResult($type, $corpid, $handOverUserId, $takeOverUserId, $cursor)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '客户迁移结果查询');
        if(empty($accessToken)) {
            Log::logError('客户迁移结果查询', [
                'params' => [
                    'type' => $type,
                    'corpid' => $corpid,
                    'handover_userid' => $handOverUserId,
                    'takeover_userid' => $takeOverUserId,
                    'cursor' => $cursor,
                ],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        if(1 == $type) {
            $url = 'https://qyapi.weixin.qq.com/cgi-bin/externalcontact/transfer_result?access_token='.$accessToken;
        } else {
            $url = 'https://qyapi.weixin.qq.com/cgi-bin/externalcontact/resigned/transfer_result?access_token='.$accessToken;
        }

        $params['handover_userid'] = $handOverUserId;
        $params['takeover_userid'] = $takeOverUserId;
        $params['cursor'] = $cursor;

        $result = HttpService::httpPost($url, json_encode($params), true);
        $result = json_decode($result, 1);

        Log::logInfo('客户迁移结果查询', [
            'params' => [
                'type' => $type,
                'corpid' => $corpid,
                'handover_userid' => $handOverUserId,
                'takeover_userid' => $takeOverUserId,
                'cursor' => $cursor,
            ],
            'response' => $result,
        ], 'qyWechat');

        return $result;
    }

    /**
     * 客户群基本信息获取
     * */
    public static function getGroupChatList($corpid, $ownerFilter, $limit, $cursor, $statusFilter=0, $retry=0)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '客户群基本信息获取');
        if(empty($accessToken)) {
            Log::logError('客户群基本信息获取', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.group_chat_list') . $accessToken;
        $postData = [
            'status_filter' => $statusFilter,
            'owner_filter' => [
                'userid_list' => $ownerFilter
            ],
            'cursor' => $cursor,
            'limit' => $limit
        ];

        $response = HttpService::httpPost($url, json_encode($postData));
        if($response === false && $retry <=5) {   // 发起重试
            $retry++;
            return self::getGroupChatList($corpid, $ownerFilter, $limit, $cursor, $statusFilter, $retry);
        }

        $responseData = json_decode($response, true);
        Log::logInfo('getGroupChatList', (array)$responseData, 'qyWechat');

        return $responseData;
    }

    /**
     * 获取客户群详情
     * */
    public static function getGroupChatDetail($corpid, $chatId, $needName=1, $retry=0)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '客户群基本信息获取');
        if(empty($accessToken)) {
            Log::logError('客户群详情获取', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.group_chat_detail') . $accessToken;
        $postData = [
            'chat_id' => $chatId,
            'need_name' => $needName
        ];

        $response = HttpService::httpPost($url, json_encode($postData));
        if($response === false && $retry <=5) {   // 发起重试
            $retry++;
            return self::getGroupChatDetail($corpid, $chatId, $needName, $retry);
        }

        $responseData = json_decode($response, true);
        Log::logInfo('getGroupChatDetail', (array)$responseData, 'qyWechat');

        return $responseData;
    }

    /**
     * 企业成员user_id转换为open_userid
     * */
    public static function useridToOpenUserid($corpid, $userIdList)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '企业成员user_id转换为open_userid');
        if(empty($accessToken)) {
            Log::logError('企业成员user_id转换为open_userid', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.userid_to_open_userid') . $accessToken;
        $postData = [
            'userid_list' => $userIdList,
        ];

        $response = HttpService::httpPost($url, json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('useridToOpenUserid', ['data' => $responseData, 'param' => $userIdList, 'corpid' => $corpid], 'qyWechat');

        return $responseData;
    }

    /**
     * 配置客户群进群方式
     * @param $corpid string 企微id
     * @param $scene integer 场景 1：群的小程序插件 2：群的二维码插件
     * @param $remark string 联系方式的备注信息，用于助记，超过30个字符将被截断
     * @param $autoCreateRoom int 当群满了后，是否自动新建群。0-否；1-是。 默认为1
     * @param $roomBaseName string 自动建群的群名前缀
     * @param $roomBaseId int 自动建群的起始序号
     * @param $chatIdList array 使用该配置的客户群ID列表，支持5个
     * @param $state string 企业自定义的state参数，用于区分不同的入群渠道
     * */
    public static function addGroupJoinWay(
        $corpid, $scene, $chatIdList, $state, $autoCreateRoom=1, $roomBaseName='', $roomBaseId=1, $remark=null
    )
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '配置客户群进群方式');
        if(empty($accessToken)) {
            Log::logError('配置客户群进群方式', [
                'params' => [
                    'corpid' => $corpid, 'scene' => $scene, 'chat_id_list' => $chatIdList, 'state' => $state, 'auto_create_room' => $autoCreateRoom, 'room_base_name' => $roomBaseName, 'room_base_id' => $roomBaseId, 'remark' => $remark
                ],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.add_group_join_way') . $accessToken;
        $postData = [
            'scene' => $scene,
            'chat_id_list' => $chatIdList
        ];

        # 联系方式的备注信息
        if($remark)
            $postData['remark'] = $remark;

        # 当群满了后，是否自动新建群
        if(in_array($autoCreateRoom, [0, 1]))
            $postData['auto_create_room'] = $autoCreateRoom;

        # 自动建群规则
        if($roomBaseName)
            $postData['room_base_name'] = $roomBaseName;
        if(is_numeric($roomBaseId))
            $postData['room_base_id'] = $roomBaseId;

        # state
        if($state)
            $postData['state'] = $state;

        $response = HttpService::httpPost($url, json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('addGroupJoinWay', ['data' => $responseData, 'param' => $postData, 'corpid' => $corpid], 'qyWechat');

        return $responseData;
    }

    /**
     * 获取客户群进群方式配置
     * @param $corpid string 企微ID
     * @param $configId string 联系方式的配置id
     * */
    public static function getGroupJoinWay($corpid, $configId)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '获取客户群进群方式配置');
        if(empty($accessToken)) {
            Log::logError('获取客户群进群方式配置', [
                'params' => ['corpid' => $corpid, 'config_id' => $configId],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.get_group_join_way') . $accessToken;
        $postData = [
            'config_id' => $configId,
        ];

        $response = HttpService::httpPost($url, json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('getGroupJoinWay', ['data' => $responseData, 'param' => $postData, 'corpid' => $corpid], 'qyWechat');

        return $responseData;
    }

    /**
     * 更新客户群进群方式配置
     * @param $corpid string 企微id
     * @param $configId string 联系方式的配置id
     * @param $scene integer 场景 1：群的小程序插件 2：群的二维码插件
     * @param $remark string 联系方式的备注信息，用于助记，超过30个字符将被截断
     * @param $autoCreateRoom int 当群满了后，是否自动新建群。0-否；1-是。 默认为1
     * @param $roomBaseName string 自动建群的群名前缀
     * @param $roomBaseId int 自动建群的起始序号
     * @param $chatIdList array 使用该配置的客户群ID列表，支持5个
     * @param $state string 企业自定义的state参数，用于区分不同的入群渠道
     * */
    public static function updateGroupJoinWay(
        $corpid, $configId, $scene, $chatIdList, $state, $autoCreateRoom=1, $roomBaseName='', $roomBaseId=1, $remark=null
    )
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '配置客户群进群方式');
        if(empty($accessToken)) {
            Log::logError('配置客户群进群方式', [
                'params' => [
                    'corpid' => $corpid, 'scene' => $scene, 'chat_id_list' => $chatIdList, 'state' => $state, 'auto_create_room' => $autoCreateRoom, 'room_base_name' => $roomBaseName, 'room_base_id' => $roomBaseId, 'remark' => $remark
                ],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.update_group_join_way') . $accessToken;
        $postData = [
            'config_id' => $configId,
            'scene' => $scene,
            'chat_id_list' => $chatIdList
        ];

        # 联系方式的备注信息
        if($remark)
            $postData['remark'] = $remark;

        # 当群满了后，是否自动新建群
        if(in_array($autoCreateRoom, [0, 1]))
            $postData['auto_create_room'] = $autoCreateRoom;

        # 自动建群规则
        if($roomBaseName)
            $postData['room_base_name'] = $roomBaseName;
        if(is_numeric($roomBaseId))
            $postData['room_base_id'] = $roomBaseId;

        # state
        if($state)
            $postData['state'] = $state;

        $response = HttpService::httpPost($url, json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('updateGroupJoinWay', ['data' => $responseData, 'param' => $postData, 'corpid' => $corpid], 'qyWechat');

        return $responseData;
    }

    /**
     * 删除客户群进群方式配置
     * @param $corpid string 企微ID
     * @param $configId string 联系方式的配置id
     * */
    public static function delGroupJoinWay($corpid, $configId)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '删除客户群进群方式配置');
        if(empty($accessToken)) {
            Log::logError('删除客户群进群方式配置', [
                'params' => ['corpid' => $corpid, 'config_id' => $configId],
                'errmsg' => '令牌获取失败'
            ], 'qyWechat');
            return false;
        }

        $url = config('qyWechat.del_group_join_way') . $accessToken;
        $postData = [
            'config_id' => $configId,
        ];

        $response = HttpService::httpPost($url, json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('delGroupJoinWay', ['data' => $responseData, 'param' => $postData, 'corpid' => $corpid], 'qyWechat');

        return $responseData;
    }

    /**
     * 停止企业群发
     * */
    public static function cancelMsg($corpid, $msgId)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid);
        if(empty($accessToken)) {
            Log::logError('停止企业群发令牌获取失败', [
                'params' => ['corpid' => $corpid, 'msg_id' => $msgId],
            ], 'qyWechat');

            return false;
        }

        $url = config('qyWechat.cancel_mass_msg') . $accessToken;
        $postData = [
            'msgid' => $msgId,
        ];

        $response = HttpService::httpPost($url, json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('cancelMsg', ['data' => $responseData, 'param' => $postData, 'corpid' => $corpid], 'qyWechat');

        return $responseData;
    }

    // 根据内部员工获取外部联系客户具体方法
    public static function getExternalContactList($userId, $corpid, $retry = 0)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid, '根据员工获取外部客户');
        if(!$accessToken) {
            Log::logError('获取客户列表时accessToken异常', [
                'params' => ['corpid' => $corpid],
                'errmsg' => '令牌获取失败'
            ], 'getCustomerList');
            return '令牌获取失败';
        }

        $url = config('qyWechat.external_contact_list').$accessToken.'&userid='.$userId;

        $response =  HttpService::HttpGet($url);
        if(empty($response) && $retry<5) {
            $retry++;
            sleep(1);
            return self::getExternalContactList($userId, $corpid, $retry);
        }
        $responseData = json_decode($response, true);

        Log::logInfo('获取客户列表响应结果为：', ['data' => $responseData, 'param' => ['corpid' => $corpid, 'user_id' => $userId]
            , 'url' => $url], 'getExternalContactList');

        return $responseData;
    }

    /**
     * 客户群在职迁移
     * */
    public static function onJobTransfer($corpid, $chatIdList, $newOwner)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid);
        if(empty($accessToken)) {
            Log::logError('【onJobTransfer】客户群在职迁移令牌获取失败', [
                'params' => ['corpid' => $corpid, 'chat_id_list' => $chatIdList, 'new_owner' => $newOwner],
            ], 'qyWechat');

            return false;
        }

        $url = config('qyWechat.chat_group_on_job_transfer') . $accessToken;
        $postData = [
            'chat_id_list' => $chatIdList,
            'new_owner' => $newOwner
        ];

        $response = HttpService::httpPost($url, json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('onJobTransfer', ['data' => $responseData, 'param' => $postData, 'corpid' => $corpid], 'qyWechat');

        return $responseData;
    }

    /**
     * 离职迁移
     * */
    public static function transfer($corpid, $chatIdList, $newOwner)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid);
        if(empty($accessToken)) {
            Log::logError('【OffJobTransfer】客户群离职迁移令牌获取失败', [
                'params' => ['corpid' => $corpid, 'chat_id_list' => $chatIdList, 'new_owner' => $newOwner],
            ], 'qyWechat');

            return false;
        }

        $url = config('qyWechat.chat_group_transfer') . $accessToken;
        $postData = [
            'chat_id_list' => $chatIdList,
            'new_owner' => $newOwner
        ];

        $response = HttpService::httpPost($url, json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('OffJobTransfer', ['data' => $responseData, 'param' => $postData, 'corpid' => $corpid], 'qyWechat');

        return $responseData;
    }

    /**
     * 停止发表企业朋友圈
     * */
    public static function cancelMomentTask($corpid, $momentId)
    {
        $accessToken = AccessTokenService::getAccessToken($corpid);
        if(empty($accessToken)) {
            Log::logError('停止发表企业朋友圈令牌获取失败', [
                'params' => ['corpid' => $corpid, 'moment_id' => $momentId],
            ], 'qyWechat');

            return false;
        }

        $url = config('qyWechat.cancel_moment_task') . $accessToken;
        $postData = [
            'moment_id' => $momentId,
        ];

        $response = HttpService::httpPost($url, json_encode($postData));
        $responseData = json_decode($response, true);

        Log::logInfo('cancelMomentTask', ['data' => $responseData, 'param' => $postData, 'corpid' => $corpid], 'qyWechat');

        return $responseData;
    }

    // 根据内部员工获取外部联系客户具体方法
    public static function getCustomerListMethod($params, $accessToken, $retry = 0)
    {
        $url = 'https://qyapi.weixin.qq.com/cgi-bin/externalcontact/batch/get_by_user?access_token='.$accessToken;

        $result =  HttpService::httpPost($url, json_encode($params), true);
        if(empty($result) && $retry < 3) {
            $retry++;
            return self::getCustomerListMethod($params, $accessToken, $retry);
        }
        $result = json_decode($result, 1);

        if(isset($result['errcode']) && $result['errcode'] == 0) {
            return $result;
        } else {
            // 请求失败，将响应数据写入日志
            Log::logError('获取内部员工对应的外部联系人列表失败：URL'.$url.', 请求参数：'.json_encode($params),
                (array)$result, 'get_user_customer_list');

            return false;
        }
    }

    // 获取配置了客户联系功能的成员列表
    public static function followUserList($corpid, $accessToken = null, $retry = 0)
    {
        if(empty($corpid) && empty($accessToken)) {
            return [];
        }

        if(empty($accessToken)) {
            $accessToken = AccessTokenService::getAccessToken($corpid, '获取配置了客户联系功能的成员列表');
        }

        $url = 'https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_follow_user_list?access_token='.$accessToken;

        $result = HttpService::httpGet($url);
        if(empty($result) && $retry<3) {
            $retry++;
            return self::followUserList($corpid, $accessToken, $retry);
        }
        $result = json_decode($result, 1);

        if(isset($result['errcode']) && $result['errcode'] == 0) {
            return [$result['follow_user'], 0];
        } else {
            $errcode = $result['errcode'] ?? null;
            // 请求失败，将响应数据写入日志
            Log::logError('获取配置了客户联系功能的成员列表失败,url:'.$url,
                (array)$result,
                'follow_user_list');
            return [[], $errcode];
        }
    }
}