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

app/command/GzcAddByBillCommand.php

@@ -18,7 +18,7 @@ class GzcAddByBillCommand extends Command
     protected function execute(Input $input, Output $output)
     {
         $output->writeln('定时任务执行中...');
-        $this->billGzcAdd();
+        // $this->billGzcAdd();
 
         /** 修复 历史数据脚本 */
         // $gzcLogList = Db::name("gzc_logs")
@@ -62,7 +62,7 @@ class GzcAddByBillCommand extends Command
         // // 定时任务执行完成
 
 
-        // /** 删除重复数据脚本 */
+        /** 删除重复数据脚本 */
         // $gzcLogList = Db::query('SELECT link_id FROM rrx_gzc_logs WHERE link_id != 0 GROUP BY link_id HAVING COUNT(*) > 1');
         // $linkIdList = array_column($gzcLogList, 'link_id');
         // $gzcLogList = Db::name("gzc_logs")
@@ -110,6 +110,82 @@ class GzcAddByBillCommand extends Command
         // // deleteNum78
         // // 定时任务执行完成
 
+        /** 将之前多跑出来的佣金和 */
+        $userBillLinkIdMap = Db::query('SELECT link_id FROM `rrx_user_bill` WHERE link_id != 0 GROUP BY link_id, type_shop, uid, number, commission_type HAVING COUNT(*) > 1');
+        $linkIdList = array_column($userBillLinkIdMap, 'link_id');
+
+        $userBillList = Db::name("user_bill")
+            ->whereIn('link_id', $linkIdList)
+            ->field('bill_id, gzc, link_id, type_shop, uid, number, commission_type, order_sn, status')
+            ->order('bill_id ASC')
+            ->select()
+            ->toArray();
+
+        $userBillMap = [];
+        $userBillIdList = [];
+        foreach ($userBillList as $item) {
+            $userBillIdList[] = $item['bill_id'];
+            $userBillMap[$item['link_id'] . '_' . $item['type_shop'] . '_' . $item['uid'] . '_' . $item['commission_type'] . '_' . $item['number']][] = $item;
+        }
+
+        $gzcLogList = Db::name("gzc_logs")
+            ->whereIn('link_id', $userBillIdList)
+            ->field('id, gzc, success, link_id')
+            ->order('id ASC')
+            ->select()
+            ->toArray();
+        // 提前查询过了，按正常来说 就是一对一，上边数据修复过后，没有重复数据
+        $gzcLogMap = array_column($gzcLogList, null, 'link_id');
+
+        $delAllIdList = [];
+        $delYongJin = [];
+        $yjNum = 0.00;
+        foreach ($userBillMap as $userBillArr) {
+            $allIds = [];
+            $baoLiuIds = [];
+            $yjDataList = [];
+            // 单次遍历同时收集所有ID和需要保留的ID
+            foreach ($userBillArr as $userBill) {
+                $allIds[] = $userBill['bill_id'];
+                // 如果该条记录是养老金记录 则根据 养老金公证处记录表 内的条件 来决定是否删除该条记录
+                if ($userBill['commission_type'] == 5) {
+                    if (!empty($gzcLogMap[$userBill['bill_id']] ?? []) && $gzcLogMap[$userBill['bill_id']]['success'] == 1) {
+                        // 如果该条 养老金记录 推送到了公证处明细记录表
+                        $baoLiuIds[] = $userBill['bill_id'];
+                    }
+                }
+
+                if ($userBill['commission_type'] == 3) {
+                    if ($userBill['status'] == 1) {
+                        $yjDataList[] = $userBill;
+                    }
+                }
+            }
+            // 确定需要删除的ID列表
+            if (!empty($billIdList)) {
+                // 保留有gzc标志的记录，删除其他
+                $delIdList = array_diff($allIds, $billIdList);
+            } else if (!empty($yjDataList)) {
+                // 保留第一条 已生效 的佣金，其余的，需要从用户身上扣减 并删除
+                $yjDataOne = array_shift($yjDataList);
+                if (!empty($yjDataList)) {
+                    // 如果移除掉第一个 还有已经发放的 佣金 需要从用户身上扣除
+                    foreach ($yjDataList as $billData) {
+                        $delYongJin[] = $billData['bill_id'];
+                        $yjNum += $billData['number'];
+                    }
+                }
+                $delIdList = array_values(array_diff($allIds, [$yjDataOne['bill_id']]));
+            } else {
+                // 保留第一条记录，删除其他
+                $delIdList = array_slice($allIds, 1);
+            }
+            $delAllIdList = array_merge($delAllIdList, $delIdList);
+        }
+
+        echo '删除的Bill记录' . implode(',', $delAllIdList) . "\n";
+        echo '删除的佣金记录' . implode(',', $delYongJin) . "\n";
+        echo '删除的佣金金额' . $yjNum . "\n";
 
         $output->writeln('定时任务执行完成');
     }