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

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")
@@ -111,125 +111,125 @@ class GzcAddByBillCommand extends Command
         // // 定时任务执行完成
 
         /** 将之前多跑出来的佣金和 */
-        $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;
-        $yongjinKouchu = [];
-        $yongjinKouchuDelBillIdList = [];
-        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'];
-                        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']]));
-            } else {
-                // 保留第一条记录，删除其他
-                $delIdList = array_slice($allIds, 1);
-            }
-            $delAllIdList = array_merge($delAllIdList, $delIdList);
-        }
-
-        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";
+        // $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;
+        // $yongjinKouchu = [];
+        // $yongjinKouchuDelBillIdList = [];
+        // 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'];
+        //                 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']]));
+        //     } else {
+        //         // 保留第一条记录，删除其他
+        //         $delIdList = array_slice($allIds, 1);
+        //     }
+        //     $delAllIdList = array_merge($delAllIdList, $delIdList);
+        // }
+        //
+        // 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('定时任务执行完成');
     }