cunkebao_v3/Server/application/api/controller/FriendTaskController.php

<?php

namespace app\api\controller;

use app\api\model\FriendTaskModel;
use app\common\model\WechatRestricts;
use think\facade\Request;

class FriendTaskController extends BaseController
{
    /************************ 好友任务管理相关接口 ************************/
    
    /**
     * 获取添加好友记录列表
     * @param int $pageIndex 页码
     * @param int $pageSize 每页数量
     * @param bool $isInner 是否为定时任务调用
     * @return \think\response\Json
     */
    public function getlist($pageIndex, $pageSize, $isInner = false)
    {
        // 获取授权token
        $authorization = $this->authorization;
        if (empty($authorization)) {
            if($isInner){
                return json_encode(['code'=>500,'msg'=>'缺少授权信息']);
            }else{
                return errorJson('缺少授权信息');
            }
        }

        try {
            // 构建请求参数
            $params = [
                'keyword' => $this->request->param('keyword', ''),
                'status' => $this->request->param('status', ''),
                'pageIndex' => !empty($pageIndex) ? $pageIndex :  $this->request->param('pageIndex', 0),
                'pageSize' => !empty($pageSize) ? $pageSize :  $this->request->param('pageSize', 20),
            ];

            // 设置请求头
            $headerData = ['client:system'];
            $header = setHeader($headerData, $authorization, 'json');

            // 发送请求获取添加好友记录列表
            $result = requestCurl($this->baseUrl . 'api/AddFriendByPhoneTask/list', $params, 'GET', $header,'json');
            $response = handleApiResponse($result);
            

            // 保存数据到数据库
            if (!empty($response['results'])) {
                foreach ($response['results'] as $item) {
                    $this->saveFriendTask($item);
                }
            }
            if($isInner){
                return json_encode(['code'=>200,'msg'=>'获取添加好友记录列表成功','data'=>$response]);
            }else{
                return successJson($response);
            }
        } catch (\Exception $e) {
            if($isInner){
                return json_encode(['code'=>500,'msg'=>'获取添加好友记录列表失败：' . $e->getMessage()]);
            }else{
                return errorJson('获取添加好友记录列表失败：' . $e->getMessage());
            }
        }
    }

    /**
     * 添加好友任务
     * @return \think\response\Json
     */
    public function addFriendTask($data = [])
    {
        // 获取授权token
        $authorization =$this->authorization;
        if (empty($authorization)) {
            return json_encode(['code'=>500,'msg'=>'缺少授权信息']);
        }

        try {
            // 获取请求参数
            $phone = !empty($data['phone']) ? $data['phone'] : '';
            $message = !empty($data['message']) ? $data['message'] : '';
            $remark = !empty($data['remark']) ? $data['remark'] : '';
            $labels = !empty($data['labels']) ? $data['labels'] : '';
            $wechatAccountId = !empty($data['wechatAccountId']) ? $data['wechatAccountId'] : '';

            // 参数验证
            if (empty($phone)) {
                return json_encode(['code'=>500,'msg'=>'手机号不能为空']);
            }
            
            if (empty($wechatAccountId)) {
                return json_encode(['code'=>500,'msg'=>'微信号不能为空']);
            }

            // 构建请求参数
            $params = [
                'phone' => $phone,
                'message' => $message,
                'remark' => $remark,
                'labels' => is_array($labels) ? $labels : [$labels],
                'wechatAccountId' => (int)$wechatAccountId
            ];

            // 设置请求头
            $headerData = ['client:system'];
            $header = setHeader($headerData, $authorization, 'json');

            // 发送请求添加好友任务
            $result = requestCurl($this->baseUrl . 'api/AddFriendByPhoneTask/add', $params, 'POST', $header, 'json');

            // 处理响应
            return json_encode(['code'=>200,'msg'=>'添加好友任务创建成功']);
        } catch (\Exception $e) {
            return json_encode(['code'=>500,'msg'=> '添加好友任务失败：' . $e->getMessage()]);
        }
    }

    /************************ 私有辅助方法 ************************/

    /**
     * 保存添加好友记录到数据库
     * @param array $item 添加好友记录数据
     */
    private function saveFriendTask($item)
    {
        // 将日期时间字符串转换为时间戳
        $createTime = isset($item['createTime']) ? strtotime($item['createTime']) : null;

        $data = [
            'id' => $item['id'],
            'tenantId' => $item['tenantId'],
            'operatorAccountId' => $item['operatorAccountId'],
            'status' => $item['status'],
            'phone' => $item['phone'],
            'msgContent' => $item['msgContent'],
            'wechatAccountId' => $item['wechatAccountId'],
            'createTime' => $createTime,
            'remark' => $item['remark'],
            'extra' => $item['extra'],
            'labels' => $item['labels'],
            'from' => $item['from'],
            'alias' => $item['alias'],
            'wechatId' => $item['wechatId'],
            'wechatAvatar' => $item['wechatAvatar'],
            'wechatNickname' => $item['wechatNickname'],
            'accountNickname' => $item['accountNickname'],
            'accountRealName' => $item['accountRealName'],
            'accountUsername' => $item['accountUsername']
        ];

        // 使用taskId作为唯一性判断
        $task = FriendTaskModel::where('id', $item['id'])->find();
        if ($task) {
            $task->save($data);
        } else {
            FriendTaskModel::create($data);
        }

        //创建非法记录
        if ($item['status'] == 2){
            $data = [
                'level' => 2,
                'taskId' => $item['id'],
                'reason' => '',
                'memo' => '',
                'wechatId' => $item['wechatId'],
                'companyId' => '',
                'restrictTime' => time(),
                'recoveryTime' => time() + 3600 * 72,
            ];
            if (strpos('操作过于频繁', $item['extra']) !== false){
                $data['reason'] = '频繁添加好友';
                $data['memo'] = '操作过于频繁，请稍后再试';
            }

            if (strpos('当前账号存在安全风险', $item['extra']) !== false){
                $data['reason'] = '账号风险';
                $data['memo'] = '当前账号存在安全风险，需先到「微信团队」进行安全验证后才能继续使用当前功能';
            }
            $res = WechatRestricts::where('taskId', $item['id'])->find();
            if (empty($res)) {
                WechatRestricts::create($data);
            }
        }


    }
}