京东联盟转链

2025-09-02 11:24:23 +08:00
parent 09e78277b5
commit c146796987
4 changed files with 110 additions and 5 deletions
--- a/Server/application/cunkebao/config/route.php
+++ b/Server/application/cunkebao/config/route.php
@@ -100,6 +100,7 @@ Route::group('v1/', function () {

        Route::get('getJdSocialMedia', 'app\cunkebao\controller\WorkbenchController@getJdSocialMedia'); // 获取京东联盟导购媒体
        Route::get('getJdPromotionSite', 'app\cunkebao\controller\WorkbenchController@getJdPromotionSite'); // 获取京东联盟广告位
+        Route::get('changeLink', 'app\cunkebao\controller\WorkbenchController@changeLink'); // 获取京东联盟广告位
    });

    // 内容库相关
--- a/Server/application/cunkebao/controller/ContentLibraryController.php
+++ b/Server/application/cunkebao/controller/ContentLibraryController.php
@@ -61,6 +61,7 @@ class ContentLibraryController extends Controller
                'sourceFriends' => $sourceType == 1 && isset($param['friendsGroups']) ? json_encode($param['friendsGroups']) : json_encode([]), // 选择的微信好友
                'sourceGroups' => $sourceType == 2 && isset($param['wechatGroups']) ? json_encode($param['wechatGroups']) : json_encode([]), // 选择的微信群
                'groupMembers' => $sourceType == 2 && isset($param['groupMembers']) ? json_encode($param['groupMembers']) : json_encode([]), // 群组成员
+                'catchType' => isset($param['catchType']) ? json_encode($param['catchType']) : json_encode([]), // 采集类型
                // 关键词配置
                'keywordInclude' => $keywordInclude, // 包含的关键词
                'keywordExclude' => $keywordExclude, // 排除的关键词
@@ -225,6 +226,7 @@ class ContentLibraryController extends Controller
        $library['keywordInclude'] = json_decode($library['keywordInclude'] ?: '[]', true);
        $library['keywordExclude'] = json_decode($library['keywordExclude'] ?: '[]', true);
        $library['groupMembers'] = json_decode($library['groupMembers'] ?: '[]', true);
+        $library['catchType'] = json_decode($library['catchType'] ?: '[]', true);
        unset($library['sourceFriends'],$library['sourceGroups']);

        // 将时间戳转换为日期格式（精确到日）
@@ -320,13 +322,13 @@ class ContentLibraryController extends Controller
            $keywordInclude = isset($param['keywordInclude']) ? json_encode($param['keywordInclude'], 256) : json_encode([]);
            $keywordExclude = isset($param['keywordExclude']) ? json_encode($param['keywordExclude'], 256) : json_encode([]);

-
            // 更新内容库基本信息
            $library->name = $param['name'];
            $library->sourceType = isset($param['sourceType']) ? $param['sourceType'] : 1;
            $library->sourceFriends = $param['sourceType'] == 1 && isset($param['friendsGroups']) ? json_encode($param['friendsGroups']) : json_encode([]);
            $library->sourceGroups = $param['sourceType'] == 2 && isset($param['wechatGroups']) ? json_encode($param['wechatGroups']) : json_encode([]);
            $library->groupMembers = $param['sourceType'] == 2 && isset($param['groupMembers']) ? json_encode($param['groupMembers']) : json_encode([]);
+            $library->catchType = isset($param['catchType']) ? json_encode($param['catchType']) : json_encode([]);// 采集类型
            $library->keywordInclude = $keywordInclude;
            $library->keywordExclude = $keywordExclude;
            $library->aiEnabled = isset($param['aiEnabled']) ? $param['aiEnabled'] : 0;
--- a/Server/application/cunkebao/controller/WorkbenchController.php
+++ b/Server/application/cunkebao/controller/WorkbenchController.php
@@ -15,6 +15,7 @@ use think\Controller;
 use think\Db;
 use app\cunkebao\model\WorkbenchTrafficConfig;
 use app\cunkebao\model\ContentLibrary;
+use think\facade\Env;

 /**
 * 工作台控制器
@@ -1576,6 +1577,58 @@ class WorkbenchController extends Controller
    }


+    //京东转链-京推推
+    public function changeLink($content = '',$positionid = '')
+    {
+        $unionId = Env::get('jd.unionId', '');
+        $jttAppId = Env::get('jd.jttAppId', '');
+        $appKey = Env::get('jd.appKey', '');
+        $apiUrl = Env::get('jd.apiUrl', '');
+
+        $content = !empty($content) ? $content : $this->request->param('content', '');
+        $positionid = !empty($positionid) ? $positionid : $this->request->param('positionid', '');
+
+
+
+        if (empty($content)){
+            return json_encode(['code' => 500, 'msg' => '转链的内容为空']) ;
+        }
+        
+        // 验证是否包含链接
+        if (!$this->containsLink($content)) {
+             return  json_encode(['code' => 500, 'msg' => '内容中未检测到有效链接']) ;
+        }
+
+        if(empty($unionId) || empty($jttAppId) || empty($appKey) || empty($apiUrl)){
+            return json_encode(['code' => 500, 'msg' => '参数缺失']) ;
+        }
+        $params = [
+            'unionid' => $unionId,
+            'content' => $content,
+            'appid' => $jttAppId,
+            'appkey' => $appKey,
+            'v' => 'v2'
+        ];
+
+        if (!empty($positionid)) {
+            $params['positionid'] = $positionid;
+        }
+
+        $res = requestCurl($apiUrl,$params,'GET',[],'json');
+        $res = json_decode($res,true);
+        if (empty($res)){
+              return json_encode(['code' => 500, 'msg' => '未知错误']) ;
+        }
+        $result = $res['result'];
+        if ($res['return'] == 0){
+              return json_encode(['code' => 200,'data' => $result['chain_content'],'msg' => $result['msg']]) ;
+        }else{
+              return json_encode(['code' => 500, 'msg' => $result['msg']]) ;
+        }
+    }
+
+
+
    public function getTrafficList()
    {
        $companyId = $this->request->userInfo['companyId'];
@@ -1607,8 +1660,6 @@ class WorkbenchController extends Controller
            $query->where('wf.wechatId|wf.alias|wf.nickname|wf.phone|u.account|u.username','like','%' . $keyword . '%');
        }

-
-
        $total = $query->count();
        $list = $query->page($page, $limit)->select();

@@ -1628,4 +1679,45 @@ class WorkbenchController extends Controller

    }

+    /**
+     * 验证内容是否包含链接
+     * @param string $content 要检测的内容
+     * @return bool
+     */
+    private function containsLink($content)
+    {
+        // 定义各种链接的正则表达式模式
+        $patterns = [
+            // HTTP/HTTPS链接
+            '/https?:\/\/[^\s]+/i',
+            // 京东商品链接
+            '/item\.jd\.com\/\d+/i',
+            // 京东短链接
+            '/u\.jd\.com\/[a-zA-Z0-9]+/i',
+            // 淘宝商品链接
+            '/item\.taobao\.com\/item\.htm\?id=\d+/i',
+            // 天猫商品链接
+            '/detail\.tmall\.com\/item\.htm\?id=\d+/i',
+            // 淘宝短链接
+            '/m\.tb\.cn\/[a-zA-Z0-9]+/i',
+            // 拼多多链接
+            '/mobile\.yangkeduo\.com\/goods\.html\?goods_id=\d+/i',
+            // 苏宁易购链接
+            '/product\.suning\.com\/\d+\/\d+\.html/i',
+            // 通用域名模式（包含常见电商域名）
+            '/(?:jd|taobao|tmall|yangkeduo|suning|amazon|dangdang)\.com[^\s]*/i',
+            // 通用短链接模式
+            '/[a-zA-Z0-9-]+\.[a-zA-Z]{2,}\/[a-zA-Z0-9\-._~:\/?#\[\]@!$&\'()*+,;=]+/i'
+        ];
+        
+        // 遍历所有模式进行匹配
+        foreach ($patterns as $pattern) {
+            if (preg_match($pattern, $content)) {
+                return true;
+            }
+        }
+        
+        return false;
+    }
+
 }
--- a/Server/application/job/WorkbenchGroupPushJob.php
+++ b/Server/application/job/WorkbenchGroupPushJob.php
@@ -15,6 +15,7 @@ use think\facade\Cache;
 use think\facade\Config;
 use app\api\controller\MomentsController as Moments;
 use Workerman\Lib\Timer;
+use app\cunkebao\controller\WorkbenchController;

 /**
 * 工作台消息群发任务
@@ -57,7 +58,7 @@ class WorkbenchGroupPushJob
    {
        try {
            // 获取所有工作台
-            $workbenches = Workbench::where(['status' => 1, 'type' => 3, 'isDel' => 0])->order('id desc')->select();
+            $workbenches = Workbench::where(['status' => 1, 'type' => 3, 'isDel' => 0,'id' => 178])->order('id desc')->select();
            foreach ($workbenches as $workbench) {
                // 获取工作台配置
                $config = WorkbenchGroupPush::where('workbenchId', $workbench->id)->find();
@@ -132,6 +133,15 @@ class WorkbenchGroupPushJob

                //内容
                if (!empty($content['content'])) {
+                    //京东转链
+                    if (!empty($config['promotionSiteId'])){
+                        $WorkbenchController = new WorkbenchController();
+                        $jdLink = $WorkbenchController->changeLink($content['content'],$config['promotionSiteId']);
+                        $jdLink = json_decode($jdLink, true);
+                        if($jdLink['code'] == 200){
+                            $content['content'] = $jdLink['data'];
+                        }
+                    }
                    $sendData[] = [
                        'content' => $content['content'],
                        'msgType' => 1,
@@ -301,7 +311,7 @@ class WorkbenchGroupPushJob
        $query = Db::name('content_library')->alias('cl')
            ->join('content_item ci', 'ci.libraryId = cl.id')
            ->join('workbench_group_push_item wgpi', 'wgpi.contentId = ci.id and wgpi.workbenchId = ' . $workbench->id, 'left')
-            ->where(['cl.isDel' => 0, 'ci.isDel' => 0])
+            ->where(['cl.isDel' => 0, 'ci.isDel' => 0,'wgpi.isLoop' => 0])
            ->where('ci.sendTime <= ' . (time() + 60))
            ->whereIn('cl.id', $contentids)
            ->field([