计划任务-修复养老金进入公证处记录

app/command/GzcAddByBillCommand.php

@@ -140,6 +140,8 @@ class GzcAddByBillCommand extends Command
         $delAllIdList = [];
         $delYongJin = [];
         $yjNum = 0.00;
+        $yongjinKouchu = [];
+        $yongjinKouchuDelBillIdList = [];
         foreach ($userBillMap as $userBillArr) {
             $allIds = [];
             $baoLiuIds = [];
@@ -173,6 +175,11 @@ class GzcAddByBillCommand extends Command
                     foreach ($yjDataList as $billData) {
                         $delYongJin[] = $billData['bill_id'];
                         $yjNum += $billData['number'];
+                        if (!isset($yongjinKouchu[$billData['uid']])) {
+                            $yongjinKouchu[$billData['uid']] = 0.00;
+                        }
+                        $yongjinKouchu[$billData['uid']] += $billData['number'];
+                        $yongjinKouchuDelBillIdList[$billData['uid']][] = $billData['bill_id'];
                     }
                 }
                 $delIdList = array_values(array_diff($allIds, [$yjDataOne['bill_id']]));
@@ -183,9 +190,46 @@ class GzcAddByBillCommand extends Command
             $delAllIdList = array_merge($delAllIdList, $delIdList);
         }
 
-        echo '删除的Bill记录' . implode(',', $delAllIdList) . "\n";
-        echo '删除的佣金记录' . implode(',', $delYongJin) . "\n";
-        echo '删除的佣金金额' . $yjNum . "\n";
+        echo '应删除的Bill记录' . implode(',', $delAllIdList) . "\n";
+        echo '应删除的佣金记录' . implode(',', $delYongJin) . "\n";
+        echo '应删除的佣金金额' . $yjNum . "\n";
+
+        $successDecYongjin = 0.00;
+        $fallDelBillIdList = [];
+        if (!empty($yongjinKouchu)) {
+            foreach ($yongjinKouchu as $uid => $number) {
+                $user = Db::name('user')->where('uid', '=', $uid)->find();
+                if ($user) {
+                    if ($user['brokerage_price'] >= $number) {
+                        $updateNum = Db::name('user')->where('uid', '=', $uid)->dec('brokerage_price', $number)->update();
+                        if ($updateNum) {
+                            $successDecYongjin += $number;
+                            echo "用户佣金扣除成功（uid：$uid ，账号：{$user['account']} ，用户佣金余额：{$user['brokerage_price']}，应扣除佣金：$number )\n";
+                            continue;
+                        } else {
+                            echo "用户佣金余额不足（uid：$uid ，账号：{$user['account']} ，用户佣金余额：{$user['brokerage_price']}，应扣除佣金：$number )\n";
+                        }
+                    } else {
+                        echo "用户佣金余额不足（uid：$uid ，账号：{$user['account']} ，用户佣金余额：{$user['brokerage_price']}，应扣除佣金：$number )\n";
+                    }
+                } else {
+                    echo "未查询到用户信息（uid：$uid ，应扣除佣金：$number )\n";
+                }
+                $fallDelBillIdList = array_values(array_merge($fallDelBillIdList, $yongjinKouchuDelBillIdList[$uid]));
+            }
+        }
+        echo '因佣金扣减失败而不能删除的佣金记录：' . implode(',', $fallDelBillIdList) . "\n";
+        echo '成功扣减佣金总额：' . $successDecYongjin . "\n";
+        $delAllIdList = array_values(array_diff($delAllIdList, $fallDelBillIdList));
+        echo '实际删除的Bill记录' . implode(',', $delAllIdList) . "\n";
+        Db::name("user_bill")
+            ->whereIn('bill_id', $delAllIdList)
+            ->delete();
+        Db::name("gzc_logs")
+            ->whereIn('link_id', $delAllIdList)
+            ->delete();
+        $delYongJin = array_values(array_diff($delYongJin, $fallDelBillIdList));
+        echo '实际应删除的佣金记录' . implode(',', $delYongJin) . "\n";
 
         $output->writeln('定时任务执行完成');
     }