test-update

app/Console/Commands/Test.php

@@ -697,7 +697,7 @@ class Test extends Command
                 }
 
                 $pid = null;
-                $res = MassMsgService::drawPid($data, $pid, 'test');
+                $res = $this->drawPid($data, $pid, 'test');
                 if ($res) {
                     if (!is_null($pid)) {
                         $upDb['pids'] = $pid;
@@ -757,4 +757,139 @@ class Test extends Command
             $idMin = $list->max('id');
         }
     }
+
+    public function drawPid($attachments, &$pid, $logName)
+    {
+        Log::logInfo('提取开始', $attachments, $logName);
+
+        $drawPids = [];
+        foreach ($attachments as $datum) {
+            if (isset($datum['msgtype'])) {
+                $url = null;
+                // 小程序
+                if (
+                    ($datum['msgtype'] == 'miniprogram')
+                    &&
+                    isset($datum['miniprogram']['page'])
+                    &&
+                    !empty($datum['miniprogram']['page'])
+                ) {
+                    $url = $datum['miniprogram']['page'];
+                }
+
+                // 链接
+                if (
+                    ($datum['msgtype'] == 'link')
+                    &&
+                    isset($datum['link']['url'])
+                    &&
+                    !empty($datum['link']['url'])
+                ) {
+                    $url = $datum['link']['url'];
+                }
+
+                // H5推广
+                if (
+                    ($datum['msgtype'] == 'promote')
+                    &&
+                    isset($datum['promote']['jump_url'])
+                    &&
+                    !empty($datum['promote']['jump_url'])
+                ) {
+                    $url = $datum['promote']['jump_url'];
+                }
+
+                // 欢迎语中的H5推广会被转换成普通链接方式
+                if (
+                    ($datum['msgtype'] == 'link')
+                    &&
+                    isset($datum['link']['jump_url'])
+                    &&
+                    !empty($datum['link']['jump_url'])
+                ) {
+                    $url = $datum['link']['jump_url'];
+                }
+
+                // 属于其他类型
+                if (is_null($url)) continue;
+
+                Log::logInfo('提取URL', [
+                    'url'       => $url
+                ], $logName);
+
+                // 处理url
+                $filedExistNum = 0;
+                $this->dealUrl($url, $filedExistNum, $drawPids, $logName);
+
+                if ($filedExistNum > 1) {
+                    Log::logError('提取推广链接PID存在多个字段', $datum, $logName);
+                    return false;
+                }
+            }
+
+            if (count($drawPids) > 1) {
+                Log::logError('提取推广链接PID存在多个值', $datum, $logName);
+                return false;
+            }
+
+            if (!empty($drawPids)) $pid = current($drawPids);
+
+            Log::logInfo('提取结束', $attachments, $logName);
+        }
+
+        return true;
+    }
+
+    public function dealUrl($url, &$filedExistNum, &$drawPids, $logName)
+    {
+        $url = str_replace("%25", "%", $url);
+        $url = str_replace("&", "&", $url);
+
+        $url = urldecode($url);
+        $urlArr = parse_url($url);
+
+        if (!isset($urlArr['query']) && empty($urlArr['query'])) return false;
+
+        Log::logInfo('提取url', [
+            'url'           => $url,
+            'filedExistNum' => $filedExistNum,
+            'drawPids'      => $drawPids
+        ], $logName);
+
+        parse_str($urlArr['query'], $query);
+
+        // 柚子 pathId
+        if (isset($query['pathId']) && !empty($query['pathId'])) {
+            $filedExistNum ++;
+            $drawPids[] = $query['pathId'];
+        }
+
+        // 嘉书 article
+        if (isset($query['article']) && !empty($query['article'])) {
+            $filedExistNum ++;
+            $drawPids[] = $query['article'];
+        }
+
+        // 迈步 pid
+        if (isset($query['pid']) && !empty($query['pid'])) {
+            $filedExistNum ++;
+            $drawPids[] = $query['pid'];
+        }
+
+        // 点众阳光 referral_id
+        if (isset($query['referral_id']) && !empty($query['referral_id'])) {
+            $filedExistNum ++;
+            $drawPids[] = $query['referral_id'];
+        }
+
+        foreach ($query as $urlVal) {
+            self::dealUrl($urlVal, $filedExistNum, $drawPids, $logName);
+        }
+
+        Log::logInfo('提取url结果', [
+            'url'           => $url,
+            'filedExistNum' => $filedExistNum,
+            'drawPids'      => $drawPids
+        ], $logName);
+    }
 }