app/Console/Commands/ReferralLinkPidDraw.php

@@ -64,7 +64,7 @@ class ReferralLinkPidDraw extends Command
                     continue;
                 }
 
-                $res = MassMsgService::drawPid($data, $pid, 'ReferralLinkPidDraw');
+                $res = $this->drawPid($data, $pid, 'ReferralLinkPidDraw');
             } catch (\Throwable $e) {
                 Log::logError('提取推广链接PID异常', [
                     'type'  => $type,
@@ -85,19 +85,19 @@ class ReferralLinkPidDraw extends Command
 
             if ($res) {
                 $upDb = ['is_draw' => 1];
-                if (!is_null($pid)) $upDb['pid'] = $pid;
+                if (!is_null($pid)) $upDb['pids'] = $pid;
 
                 $item->update($upDb);
             }
         }
     }
 
-    public function drawPid($data, &$pid)
+    public function drawPid($attachments, &$pid, $logName)
     {
-        Log::logInfo('提取开始', $data, 'ReferralLinkPidDraw');
+        Log::logInfo('提取开始', $attachments, $logName);
 
-        $drawPids     = [];
-        foreach ($data as $datum) {
+        $drawPids = [];
+        foreach ($attachments as $datum) {
             if (isset($datum['msgtype'])) {
                 $url = null;
                 // 小程序
@@ -133,71 +133,97 @@ class ReferralLinkPidDraw extends Command
                     $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], 'ReferralLinkPidDraw');
+                Log::logInfo('提取URL', [
+                    'url'       => $url
+                ], $logName);
 
                 // 处理url
-                $fildExistNum = 0;
-                $this->dealUrl($url, $fildExistNum, $drawPids);
+                $filedExistNum = 0;
+                $this->dealUrl($url, $filedExistNum, $drawPids, $logName);
 
-                if ($fildExistNum > 1) {
-                    Log::logError('提取推广链接PID存在多个字段', $datum, 'ReferralLinkPidDraw');
+                if ($filedExistNum > 1) {
+                    Log::logError('提取推广链接PID存在多个字段', $datum, $logName);
                     return false;
                 }
             }
 
-            if (count($drawPids) > 1) {
-                Log::logError('提取推广链接PID存在多个值', $datum, 'ReferralLinkPidDraw');
-                return false;
-            }
+//            if (count($drawPids) > 1) {
+//                Log::logError('提取推广链接PID存在多个值', $datum, $logName);
+//                return false;
+//            }
 
-            if (!empty($drawPids)) $pid = current($drawPids);
+            if (!empty($drawPids)) $pid = json_encode(array_filter($drawPids));
 
-            Log::logInfo('提取结束', $data, 'ReferralLinkPidDraw');
+            Log::logInfo('提取结束', $attachments, $logName);
         }
 
         return true;
     }
 
-    public function dealUrl($url, &$fildExistNum, &$drawPids)
+    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, 'fildExistNum' => $fildExistNum, 'drawPids' => $drawPids], 'ReferralLinkPidDraw');
+        Log::logInfo('提取url', [
+            'url'           => $url,
+            'filedExistNum' => $filedExistNum,
+            'drawPids'      => $drawPids
+        ], $logName);
 
         parse_str($urlArr['query'], $query);
 
         // 柚子 pathId
         if (isset($query['pathId']) && !empty($query['pathId'])) {
-            $fildExistNum ++;
+            $filedExistNum ++;
             $drawPids[] = $query['pathId'];
         }
 
         // 嘉书 article
         if (isset($query['article']) && !empty($query['article'])) {
-            $fildExistNum ++;
+            $filedExistNum ++;
             $drawPids[] = $query['article'];
         }
 
         // 迈步 pid
         if (isset($query['pid']) && !empty($query['pid'])) {
-            $fildExistNum ++;
+            $filedExistNum ++;
             $drawPids[] = $query['pid'];
         }
 
         // 点众阳光 referral_id
         if (isset($query['referral_id']) && !empty($query['referral_id'])) {
-            $fildExistNum ++;
+            $filedExistNum ++;
             $drawPids[] = $query['referral_id'];
         }
 
         foreach ($query as $urlVal) {
-            $this->dealUrl($urlVal, $fildExistNum, $drawPids);
+            $this->dealUrl($urlVal, $filedExistNum, $drawPids, $logName);
         }
 
-        Log::logInfo('提取url结果', ['url' => $url, 'fildExistNum' => $fildExistNum, 'drawPids' => $drawPids], 'ReferralLinkPidDraw');
+        Log::logInfo('提取url结果', [
+            'url'           => $url,
+            'filedExistNum' => $filedExistNum,
+            'drawPids'      => $drawPids
+        ], $logName);
     }
 }

app/Models/MassMsg.php

@@ -148,8 +148,15 @@ class MassMsg extends Model
         }
 
         $popu_data = array();
-        $pids = $data->pluck('pid')->all();
-        $pids = array_filter($pids);
+        $pidVals = $data->pluck('pids')->all();
+        $pids = [];
+        foreach ($pidVals as $pidVal) {
+            if (empty($pidVal)) continue;
+
+            $itemPids = json_decode($pidVal, true);
+            $pids = array_merge($pids, $itemPids);
+        }
+
         if( !empty($pids) ){
             $popu_data = MassPopularizData::selectRaw('sum(viewUv) as viewUv, sum(payPv) as payPv, sum(payUv) as payUv, sum(payMoney) as payMoney')->whereIn('pid', $pids)->first();
 

app/Models/MomentTask.php

@@ -131,7 +131,15 @@ class MomentTask extends Model
 //        }
 
         $popu_data = null;
-        $pids = $data->pluck('pid')->all();
+        $pids = [];
+        $pidVals = $data->pluck('pids')->all();
+        foreach ($pidVals as $pidVal) {
+            if (empty($pidVal)) continue;
+
+            $itemPids = json_decode($pidVal, true);
+            $pids = array_merge($pids, $itemPids);
+        }
+
         $pids = array_filter($pids);
         if( !empty($pids) ){
             $popu_data = MassPopularizData::selectRaw('sum(viewUv) as viewUv, sum(payPv) as payPv, sum(payUv) as payUv, sum(payMoney) as payMoney')->whereIn('pid', $pids)->first();

app/Service/PopularizService.php

@@ -44,8 +44,15 @@ class PopularizService
                 ->whereIn('rule_id', $ruleIds)->groupBy(['rule_id'])->get();
 
             #统计回收信息
-            $pids = $list->pluck('pid')->all();
-            $pids = array_filter($pids);
+            $pids = [];
+            $pidVals = $list->pluck('pids')->all();
+            foreach ($pidVals as $pidVal) {
+                if (empty($pidVal)) continue;
+
+                $itemPids = json_decode($pidVal, true);
+                $pids = array_merge($pids, $itemPids);
+            }
+
             if( !empty($pids) ){
                 $popu_data = MassPopularizData::select('viewPv', 'viewUv', 'payPv', 'payUv', 'payMoney', 'pid', 'playletActivityId')
                     ->whereIn('pid', $pids)
@@ -102,35 +109,57 @@ class PopularizService
                 $datum->send_total = isset($sendStatInfo->send_total) ? $sendStatInfo->send_total : 0;
                 unset($datum->admin_id);
 
-                $pid = $datum->pid;
+                $datumPids = json_decode($datum->pids, true);
                 #统计 总播放人数（：总uv）  充值人数 充值次数（今日） 充值金额（今日）   付费率 点击率
-                if($pid){
-                    $popu_info = $popu_data->where('pid', $pid)->first();
-
-                    $datum->viewUv = $popu_info->viewUv ?? null;
-                    $datum->payUv = $popu_info->payUv ?? null;
-                    $datum->payPv = $popu_info->payPv ?? null;
-                    $datum->payMoney = $popu_info->payMoney ?? null;
+                if($datumPids){
                     $datum->payAvg = $datum->payUv>0 ? round($datum->payPv/$datum->payUv, 2) : null;
                     $datum->payRate = $datum->viewUv>0 ? round($datum->payUv/$datum->viewUv*100, 2) .'%' : null;
                     $datum->clickRate = $datum->send_success>0 ? round($datum->viewUv/$datum->send_success*100, 2) .'%' : null;
 
-                    if(isset($popu_info->playletActivityId)) {
-                        $datum->newPayUv = $orderData[$popu_info->playletActivityId]['newPayUv'] ?? null;
-                        $datum->newPayPv = $orderData[$popu_info->playletActivityId]['newPayPv'] ?? null;
-                        $datum->newPayAmount = isset($orderData[$popu_info->playletActivityId]['newPayAmount']) ? round($orderData[$popu_info->playletActivityId]['newPayAmount']/10000, 2) : null;
-                        $datum->oldPayAmount = isset($orderData[$popu_info->playletActivityId]['oldPayAmount']) ? round($orderData[$popu_info->playletActivityId]['oldPayAmount']/10000, 2) : null;
-                        $datum->otherPayAmount = isset($otherOrderData[$popu_info->playletActivityId]['otherPayAmount']) ? round($otherOrderData[$popu_info->playletActivityId]['otherPayAmount']/10000, 2) : null;
+                    $popu_list = MassPopularizData::select('viewPv', 'viewUv', 'payPv', 'payUv', 'payMoney', 'pid', 'playletActivityId')
+                        ->whereIn('pid', $datumPids)
+                        ->get();
+                    if ($popu_list->isNotEmpty()) {
+                        $datum->viewUv         = 0;
+                        $datum->payUv          = 0;
+                        $datum->payPv          = 0;
+                        $datum->payMoney       = 0;
+                        $datum->newPayUv       = 0;
+                        $datum->newPayPv       = 0;
+                        $datum->newPayAmount   = 0;
+                        $datum->oldPayAmount   = 0;
+                        $datum->otherPayAmount = 0;
+                        foreach ($popu_list as $popu_info) {
+                            $datum->viewUv   += ($popu_info->viewUv ?? 0);
+                            $datum->payUv    += ($popu_info->payUv ?? 0);
+                            $datum->payPv    += ($popu_info->payPv ?? 0);
+                            $datum->payMoney += ($popu_info->payMoney ?? 0);
+
+                            if(isset($popu_info->playletActivityId)) {
+                                $datum->newPayUv       += ($orderData[$popu_info->playletActivityId]['newPayUv'] ?? 0);
+                                $datum->newPayPv       += ($orderData[$popu_info->playletActivityId]['newPayPv'] ?? 0);
+                                $datum->newPayAmount   += ($orderData[$popu_info->playletActivityId]['newPayAmount'] ?? 0);
+                                $datum->oldPayAmount   += ($orderData[$popu_info->playletActivityId]['oldPayAmount'] ?? 0);
+                                $datum->otherPayAmount += ($otherOrderData[$popu_info->playletActivityId]['otherPayAmount'] ?? 0);
+                            }
+                        }
+
+                        $datum->newPayAmount   = round($orderData[$popu_info->playletActivityId]['newPayAmount']/10000, 2);
+                        $datum->oldPayAmount   = round($orderData[$popu_info->playletActivityId]['oldPayAmount']/10000, 2);
+                        $datum->otherPayAmount = round($otherOrderData[$popu_info->playletActivityId]['otherPayAmount']/10000, 2);
+                        $datum->newPayAvg      = $datum->newPayUv>0 ? round($datum->newPayPv/$datum->newPayUv, 2) : null;
                     } else {
-                        $datum->newPayUv = null;
-                        $datum->newPayPv = null;
-                        $datum->newPayAmount = null;
-                        $datum->oldPayAmount = null;
+                        $datum->viewUv         = null;
+                        $datum->payUv          = null;
+                        $datum->payPv          = null;
+                        $datum->payMoney       = null;
+                        $datum->newPayUv       = null;
+                        $datum->newPayPv       = null;
+                        $datum->newPayAmount   = null;
+                        $datum->oldPayAmount   = null;
                         $datum->otherPayAmount = null;
+                        $datum->newPayAvg      = null;
                     }
-
-                    $datum->newPayAvg = $datum->newPayUv>0 ? round($datum->newPayPv/$datum->newPayUv, 2) : null;
-
                 } else {
                     $datum->viewUv = null;
                     $datum->payUv = null;
@@ -205,8 +234,15 @@ class PopularizService
                 ->whereIn('rule_id', $ruleIds)->groupBy(['rule_id'])->get();
 
             #统计回收信息
-            $pids = $list->pluck('pid')->all();
-            $pids = array_filter($pids);
+            $pids = [];
+            $pidVals = $list->pluck('pids')->all();
+            foreach ($pidVals as $pidVal) {
+                if (empty($pidVal)) continue;
+
+                $itemPids = json_decode($pidVal, true);
+                $pids = array_merge($pids, $itemPids);
+            }
+
             if( !empty($pids) ){
                 $popu_data = MassPopularizData::select('viewPv', 'viewUv', 'payPv', 'payUv', 'payMoney', 'pid', 'playletActivityId')
                     ->whereIn('pid', $pids)
@@ -259,35 +295,55 @@ class PopularizService
 
                 unset($datum->admin_id);
 
-                $pid = $datum->pid;
+                $datumPids = json_decode($datum->pids, true);
                 #统计 总播放人数（：总uv）  充值人数 充值次数（今日） 充值金额（今日）   付费率 点击率
-                if($pid){
-                    $popu_info = $popu_data->where('pid', $pid)->first();
-
-                    $datum->viewUv = $popu_info->viewUv ?? null;
-                    $datum->payUv = $popu_info->payUv ?? null;
-                    $datum->payPv = $popu_info->payPv ?? null;
-                    $datum->payMoney = $popu_info->payMoney ?? null;
+                if($datumPids){
                     $datum->payAvg = $datum->payUv>0 ? round($datum->payPv/$datum->payUv, 2) : null;
                     $datum->payRate = $datum->viewUv>0 ? round($datum->payUv/$datum->viewUv*100, 2) .'%' : null;
                     $datum->clickRate = $datum->published_count>0 ? round($datum->viewUv/$datum->published_count*100, 2) .'%' : null;
 
-                    if(isset($popu_info->playletActivityId)) {
-                        $datum->newPayUv = $orderData[$popu_info->playletActivityId]['newPayUv'] ?? null;
-                        $datum->newPayPv = $orderData[$popu_info->playletActivityId]['newPayPv'] ?? null;
-                        $datum->newPayAmount = isset($orderData[$popu_info->playletActivityId]['newPayAmount']) ? round($orderData[$popu_info->playletActivityId]['newPayAmount']/10000, 2) : null;
-                        $datum->oldPayAmount = isset($orderData[$popu_info->playletActivityId]['oldPayAmount']) ? round($orderData[$popu_info->playletActivityId]['oldPayAmount']/10000, 2) : null;
-                        $datum->otherPayAmount = isset($otherOrderData[$popu_info->playletActivityId]['otherPayAmount']) ? round($otherOrderData[$popu_info->playletActivityId]['otherPayAmount']/10000, 2) : null;
+                    $popu_list = MassPopularizData::select('viewPv', 'viewUv', 'payPv', 'payUv', 'payMoney', 'pid', 'playletActivityId')
+                        ->whereIn('pid', $datumPids)
+                        ->get();
+                    if ($popu_list->isNotEmpty()) {
+                        $datum->viewUv         = 0;
+                        $datum->payUv          = 0;
+                        $datum->payPv          = 0;
+                        $datum->payMoney       = 0;
+                        $datum->newPayUv       = 0;
+                        $datum->newPayPv       = 0;
+                        $datum->newPayAmount   = 0;
+                        $datum->oldPayAmount   = 0;
+                        $datum->otherPayAmount = 0;
+                        foreach ($popu_list as $popu_info) {
+                            $datum->viewUv   += ($popu_info->viewUv ?? 0);
+                            $datum->payUv    += ($popu_info->payUv ?? 0);
+                            $datum->payPv    += ($popu_info->payPv ?? 0);
+                            $datum->payMoney += ($popu_info->payMoney ?? 0);
+                            if(isset($popu_info->playletActivityId)) {
+                                $datum->newPayUv       += ($orderData[$popu_info->playletActivityId]['newPayUv'] ?? 0);
+                                $datum->newPayPv       += ($orderData[$popu_info->playletActivityId]['newPayPv'] ?? 0);
+                                $datum->newPayAmount   += ($orderData[$popu_info->playletActivityId]['newPayAmount'] ?? 0);
+                                $datum->oldPayAmount   += ($orderData[$popu_info->playletActivityId]['oldPayAmount'] ?? 0);
+                                $datum->otherPayAmount += ($otherOrderData[$popu_info->playletActivityId]['otherPayAmount'] ?? 0);
+                            }
+                        }
+                        $datum->newPayAmount   = round($orderData[$popu_info->playletActivityId]['newPayAmount']/10000, 2);
+                        $datum->oldPayAmount   = round($orderData[$popu_info->playletActivityId]['oldPayAmount']/10000, 2);
+                        $datum->otherPayAmount = round($otherOrderData[$popu_info->playletActivityId]['otherPayAmount']/10000, 2);
+                        $datum->newPayAvg      = $datum->newPayUv>0 ? round($datum->newPayPv/$datum->newPayUv, 2) : null;
                     } else {
-                        $datum->newPayUv = null;
-                        $datum->newPayPv = null;
-                        $datum->newPayAmount = null;
-                        $datum->oldPayAmount = null;
-                        $datum->otherPayAmount = null;
+                        $datum->viewUv         = 0;
+                        $datum->payUv          = 0;
+                        $datum->payPv          = 0;
+                        $datum->payMoney       = 0;
+                        $datum->newPayUv       = 0;
+                        $datum->newPayPv       = 0;
+                        $datum->newPayAmount   = 0;
+                        $datum->oldPayAmount   = 0;
+                        $datum->otherPayAmount = 0;
+                        $datum->newPayAvg      = 0;
                     }
-
-                    $datum->newPayAvg = $datum->newPayUv>0 ? round($datum->newPayPv/$datum->newPayUv, 2) : null;
-
                 } else {
                     $datum->viewUv = null;
                     $datum->payUv = null;