å修改é—æ红包记录问题

app/command/PensionTasks.php

@@ -12,6 +12,7 @@ use app\common\repositories\merchant\order\OrderMerchantRepository;
 use app\common\repositories\store\order\StoreOrderStatusRepository;
 use app\common\repositories\store\product\ProductRepository;
 use app\common\repositories\user\UserBillRepository;
+use app\common\repositories\user\UserRepository;
 use app\traits\GzcApiRequest;
 use Carbon\Carbon;
 use think\console\Command;
@@ -524,6 +525,9 @@ class PensionTasks extends Command
                             'status'          => 1,
                             'settlement_time' => date('Y-m-d H:i:s')
                         ]);
+                    /** @var UserRepository $userRepository */
+                    $userRepository = app()->make(UserRepository::class);
+                    $userRepository->setUserIdentity($user_sign_gongxian['uid']);
                 }
 
             });
@@ -772,6 +776,33 @@ class PensionTasks extends Command
                             'status'          => 1,
                             'settlement_time' => date('Y-m-d H:i:s')
                         ]);
+                    /** @var UserRepository $userRepository */
+                    $userRepository = app()->make(UserRepository::class);
+                    $userRepository->setUserIdentity($user_sign_gongxian['uid']);
+                }
+
+                // 结算PV值
+                $user_pv_list = Db::name('user_pv_log')
+                    ->where('status', -1)
+                    ->where('order_id', $online['order_id'])
+                    ->whereIn('type', [1, 2])
+                    ->select()
+                    ->toArray();
+                if($user_pv_list) {
+                    foreach ($user_pv_list as $user_pv) {
+                        // 修改pv
+                        Db::name('user')
+                            ->where('uid', $user_pv['uid'])
+                            ->inc('pv', (float)$user_pv['pv'])
+                            ->update();
+                        Db::name('user_pv_log')
+                            ->where('status', -1)
+                            ->where('id', $user_pv['id'])
+                            ->update([
+                                'status'          => 1,
+                                'settlement_time' => date('Y-m-d H:i:s')
+                            ]);
+                    }
                 }
 
                 

app/common/repositories/user/UserThirdRepository.php

@@ -865,6 +865,18 @@ class UserThirdRepository extends BaseRepository
             Db::name("user_sign_gongxian")->insert($gongxian_data);//添加贡献记录
             log::info("===添加完积分和贡献值");
 
+            // 添加pv记录
+            $pv_data = [
+                "uid"           =>$user_id,
+                "pv"            =>$gongxian,
+                "addtime"       =>time(),
+                "status"        =>-1,
+                "order_type"    =>$type_shop,
+                "order_id"      =>$order_sn,
+                "mark"          =>"购买{$make}商品获得的PV",
+            ];
+            Db::name("user_pv_log")->insert($pv_data);//添加pv记录
+
             //判断是否是老用户  is_old=1是1.0的用户，1.0的用户要总pv*45%的红包
             if($user["is_old"]==1){
                 //添加红包

app/controller/api/user/User.php

@@ -219,10 +219,10 @@ class User extends BaseController
 
         if ($pm==0){
 
-            $data = DB::name('user_sign_hongbao')->where($where)->where('type', 1)->field('id,mark,number,type,addtime,order_id')->page($page, $limit)->order("id desc")->select();
+            $data = DB::name('user_sign_hongbao')->where($where)->where(['type' => 1,'status' => 1])->field('id,mark,number,type,addtime,order_id')->page($page, $limit)->order("id desc")->select();
         }
         if($pm==1){
-            $data = DB::name('user_sign_hongbao')->where($where)->where('type', 2)->field('id,mark,number,type,addtime,order_id')->page($page, $limit)->order("id desc")->select();
+            $data = DB::name('user_sign_hongbao')->where($where)->where(['type' => 2,'status' => 1])->field('id,mark,number,type,addtime,order_id')->page($page, $limit)->order("id desc")->select();
 
         }
         if($pm==2){