huahuibao/console/controllers/CustomController.php

<?php

namespace console\controllers;

use biz\shop\classes\ShopClass;
use bizGhs\custom\models\Custom;
use bizGhs\order\classes\OrderClass;
use bizHd\custom\classes\CustomClass;
use bizHd\purchase\classes\PurchaseClass;
use common\components\noticeUtil;
use common\components\util;
use bizHd\user\classes\UserClass;
use Overtrue\ChineseCalendar\Calendar;
use yii\console\Controller;

class CustomController extends Controller
{

    //欠款信息不一致跟踪 ssh 20220307 ./yii custom/adjust-debt
    public function actionAdjustDebt()
    {
        //感觉好像没有用了，可以停了 ssh 20250724
        util::stop();

        ini_set('memory_limit', '2045M');
        set_time_limit(0);
        $shopList = ShopClass::getAllByCondition(['ptStyle' => 2], null, '*', null, true);
        if (empty($shopList)) {
            return false;
        }
        foreach ($shopList as $key => $shop) {

            $shopId = $shop->id ?? 0;

            $query = new \yii\db\Query();

            $query->from(Custom::tableName());

            $query->where(['ownShopId' => $shopId]);
            $query->orderBy('addTime ASC');

            foreach ($query->batch(50) as $customList) {
                if (!empty($customList)) {
                    foreach ($customList as $custom) {
                        //$customName = $custom['name'] ?? '';
                        $customId = $custom['id'] ?? 0;
                        $where = ['customId' => $customId, 'debt' => 1];
                        $orderList = OrderClass::getAllByCondition($where, 'addTime DESC', '*');
                        $ghsOrderDebtAmount = 0;
                        if (!empty($orderList)) {
                            foreach ($orderList as $order) {
                                $actPrice = $order['remainDebtPrice'] ?? 0;
                                $ghsOrderDebtAmount = bcadd($ghsOrderDebtAmount, $actPrice, 2);
                            }
                        }


                        $ghsId = $custom['ghsId'] ?? 0;

                        $ghs = \bizHd\ghs\classes\GhsClass::getById($ghsId);

                        $where = ['ghsId' => $ghsId, 'debt' => PurchaseClass::DEBT_YES];
                        $cgList = PurchaseClass::getAllByCondition($where, 'addTime DESC', '*');
                        $hdCgOrderDebtAmount = 0;
                        if (!empty($cgList)) {
                            foreach ($cgList as $cg) {
                                $actPrice = $cg['remainDebtPrice'] ?? 0;
                                $hdCgOrderDebtAmount = bcadd($hdCgOrderDebtAmount, $actPrice, 2);
                            }
                        }
                        if ($ghsOrderDebtAmount < 0 || $hdCgOrderDebtAmount < 0) {
                            noticeUtil::push("!!!!!!!供货商 {$ghsId}  客户id {$customId} 出现负数 $ghsOrderDebtAmount $hdCgOrderDebtAmount", '15280215347');
                            echo "@@@@@@@@@@@@@供货商 {$ghsId}  客户id {$customId} 出现负数 $ghsOrderDebtAmount $hdCgOrderDebtAmount \n";
                        }
                        $ghsOrderDebtAmount = floatval($ghsOrderDebtAmount);
                        $hdCgOrderDebtAmount = floatval($hdCgOrderDebtAmount);

                        if ($ghsOrderDebtAmount != $hdCgOrderDebtAmount) {
                            noticeUtil::push("!!!!!!!供货商 {$ghsId}  客户id {$customId} 二边欠款单总金额不一致", '15280215347');
                            echo "---------供货商 {$ghsId}  客户id {$customId} 二边 欠款单 总金额 不一致 {$ghsOrderDebtAmount} {$hdCgOrderDebtAmount} \n";
                            continue;
                        }

                        $customSaveDebtAmount = $custom['debtAmount'] ? floatval($custom['debtAmount']) : 0;
                        $ghsSaveDebtAmount = $ghs['debtAmount'] ? floatval($ghs['debtAmount']) : 0;

                        if ($customSaveDebtAmount != $ghsOrderDebtAmount) {
                            echo "*********客户 {$customId} 欠款 和 订单总额 不一致 $customSaveDebtAmount $ghsOrderDebtAmount \n";
                            noticeUtil::push("*********客户 {$customId} 欠款总金额 和 订单总合 不一致 $customSaveDebtAmount $ghsOrderDebtAmount ", '15280215347');
                            continue;
                        }

                        if ($ghsSaveDebtAmount != $hdCgOrderDebtAmount) {
                            echo "#########欠供货商 {$ghsId}  和 订单总额 不一致 $ghsSaveDebtAmount $hdCgOrderDebtAmount \n";
                            noticeUtil::push("#########欠供货商 {$ghsId} 金额 和 订单总合 不一致 $ghsSaveDebtAmount $hdCgOrderDebtAmount ", '15280215347');
                            continue;
                        }

                    }
                }
            }
        }

    }

    //每天凌晨2点执行，取出所有 lunar==1 的 且 birthdayTime 小于当前时间的客户，然后把他们的阴历转阳历，然后更新他们的 birthdayTime
    public function actionUpdateBirthday()
    {
        $calendar = new Calendar();
        $customList = CustomClass::getAllByCondition(['lunar' => 1, 'birthdayTime<' => time()], null, 'id, userId, birthday, birthdayTime, birthdayMonth, birthdayDate', null, true);
        foreach ($customList as $custom) {
            $birthdayMonth = $custom->birthdayMonth;
            $birthdayDate = $custom->birthdayDate;
            $year = date("Y");
            // 农历转公历
            $result = $calendar->lunar($year, $birthdayMonth, $birthdayDate);
            $month = $result['gregorian_month'];
            $day = $result['gregorian_day'];
            $birthday = $year . '-' . $month . '-' . $day;

            // 如果今年的生日已经过去，则计算明年的生日
            if (strtotime($birthday) < strtotime(date('Y-m-d'))) {
                $year++;
                $result = $calendar->lunar($year, $birthdayMonth, $birthdayDate);
                $month = $result['gregorian_month'];
                $day = $result['gregorian_day'];
                $birthday = $year . '-' . $month . '-' . $day;
            }
            $custom->birthday = $birthday;
            $custom->birthdayTime = strtotime($birthday);
            $custom->save();

            UserClass::updateById($custom->userId, [
                'birthday' => $birthday,
                'birthdayTime' => $custom->birthdayTime
            ]);
        }
    }

    //批量创建客户
    private function createCustomer()
    {
        //重新写这个方法，用rabbitMQ来实现
    }

    //批发端分店从首店同步客户
    private function copyCustomers()
    {
        //重新写这个方法，用rabbitMQ来实现
    }

    //从文件批量创建客户 ssh 20240426
    public function actionFileCreateCustom()
    {
        //重新写这个方法，用rabbitMQ来实现
    }

}