From 931ce2cb0e544a6ad2744284f15392032dba41f7 Mon Sep 17 00:00:00 2001
From: lccsw <805383944@qq.com>
Date: Mon, 19 Dec 2022 16:19:36 +0800
Subject: [PATCH] add-plan-up_view_log

---
 api/controllers/plan/Syt.php | 38 +++++++++++++++++++++++++++++++++++-
 1 file changed, 37 insertions(+), 1 deletion(-)

diff --git a/api/controllers/plan/Syt.php b/api/controllers/plan/Syt.php
index 92b9c63e..3fded2bc 100644
--- a/api/controllers/plan/Syt.php
+++ b/api/controllers/plan/Syt.php
@@ -340,7 +340,7 @@ class Syt extends CI_Controller
                 $user && $ac_user = $this->act_user_model->get(['activityId'=>$value['activityId'],'userId'=>$user['userId']]);
                 if($ac_user['channelId']){
                     $ac_user['channelId'] && $p_user = $this->act_user_model->get(['activityId'=>$value['activityId'],'userId'=>$ac_user['channelId']]);
-                    $p_user['cfUserId'] && $addData['cfUserId'] = $p_user['userId'];
+                    $p_user && $addData['cfUserId'] = $p_user['userId'];
                     $p_user['bizId'] && $addData['bizId'] = $p_user['bizId'];
                     $p_user['levelId1'] && $addData['levelId1'] = $p_user['levelId1'];
                     $p_user['levelId2'] && $addData['levelId2'] = $p_user['levelId2'];
@@ -497,4 +497,40 @@ class Syt extends CI_Controller
             echo '执行结束';
         }
     }
+
+    public function tmp(){
+        $this->load->model('market/market_sylive_activity_user_model', 'act_user_model');
+        $this->load->model('market/market_sylive_viewlog_model');
+        $page = $this->input->get('page');
+        $size = $this->input->get('size');
+        !$page && $page = 1;
+        !$size && $size = 20;
+        $activityId = 6;
+        $where = [
+            'activityId' => $activityId,
+        ];
+        $rows = $this->market_sylive_viewlog_model->select($where,'id desc',$page,$size,'id,userId,updateTime');
+        if($rows){
+            $user_ids = implode(',',array_column($rows,'userId'));
+            $user_rows = [];
+            if($user_ids){
+                $where = [
+                    "userId in ($user_ids)" => null
+                ];
+                $user_rows = $this->act_user_model->map('userId','channelId',$where,0,0,'userId,channelId');
+            }
+            foreach ($rows as $key => $val) {
+                if($user_rows['userId']){
+                    $update = [
+                        'cfUserId' => $user_rows['userId'],
+                        'updateTime' => $val['updateTime']
+                    ];
+                    $this->market_sylive_viewlog_model->update($update,['id'=>$val['id']]);
+                }
+                echo "执行成功:{$val['id']}\n";
+            }
+        }else{
+            echo '执行结束';
+        }
+    }
 }