上线与升级

biz/ghs/classes/GhsBackClass.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace biz\ghs\classes;
+
+use biz\base\classes\BaseClass;
+
+class GhsBackClass extends BaseClass
+{
+
+    public static $baseFile = '\biz\ghs\models\GhsBack';
+
+}

biz/ghs/models/GhsBack.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace biz\ghs\models;
+
+use biz\base\models\Base;
+
+class GhsBack extends Base
+{
+    public static function tableName()
+    {
+        return 'xhGhsBack';
+    }
+}

console/controllers/ClearController.php

@@ -2,8 +2,11 @@
 
 namespace console\controllers;
 
+use biz\ghs\classes\GhsBackClass;
 use bizGhs\clear\classes\OrderCgClearClass;
 use bizGhs\clear\models\Clear;
+use bizGhs\ghs\classes\GhsClass;
+use bizGhs\ghs\models\Ghs;
 use bizGhs\order\classes\OrderClass;
 use bizGhs\order\classes\PurchaseOrderClass;
 use bizHd\purchase\classes\PurchaseClass;
@@ -13,6 +16,7 @@ use Yii;
 class ClearController extends Controller
 {
 
+    //补回 xhOrderCgClear
     public function actionBc()
     {
 
@@ -52,8 +56,8 @@ class ClearController extends Controller
                                 $purchaseIdList = explode(',', $purchaseIds);
                                 $purchaseInfo = PurchaseOrderClass::getAllByCondition(['id' => ['in', $purchaseIdList]], null, 'id,orderSn', 'id');
                                 foreach ($purchaseInfo as $purchase) {
-                                    $purchaseId = $purchase['id']??0;
-                                    $purchaseOrderSn = $purchase['orderSn']??0;
+                                    $purchaseId = $purchase['id'] ?? 0;
+                                    $purchaseOrderSn = $purchase['orderSn'] ?? 0;
                                     $addData = ['orderId' => 0, 'orderSn' => '', 'cgId' => $purchaseId, 'cgSn' => $purchaseOrderSn,
                                         'clearId' => $clearId, 'clearSn' => $clearSn, 'amount' => $clearAmount, 'status' => $status];
                                     OrderCgClearClass::add($addData);
@@ -105,4 +109,75 @@ class ClearController extends Controller
 
     }
 
+    public function actionGhsBalance()
+    {
+        ini_set('memory_limit', '2045M');
+        set_time_limit(0);
+
+        $sql = "delete from xhGhsBack";
+        Yii::$app->db->createCommand($sql)->execute();
+
+        $query = new \yii\db\Query();
+        $query->from(Ghs::tableName());
+        $query->where(['ownPtStyle' => 1]);
+        $query->andWhere(['>', 'balance', 0]);
+        foreach ($query->batch(500) as $ghsList) {
+
+            $connection = Yii::$app->db;
+            $transaction = $connection->beginTransaction();
+            try {
+
+                foreach ($ghsList as $ghs) {
+                    GhsBackClass::add($ghs);
+                }
+
+                $transaction->commit();
+            } catch (\Exception $e) {
+                $transaction->rollBack();
+                $msg = $e->getMessage();
+                echo "报错了：" . $msg . "\n";
+            }
+        }
+    }
+
+    //将花店供货商的欠款迁到余额，同时保留欠款项为后面复查预留
+    public function actionGhs()
+    {
+        ini_set('memory_limit', '2045M');
+        set_time_limit(0);
+
+        $sql = "UPDATE xhGhs SET balance=-debtAmount WHERE ownPtStyle=1;";
+        Yii::$app->db->createCommand($sql)->execute();
+    }
+
+    public function actionGhsUp()
+    {
+        ini_set('memory_limit', '2045M');
+        set_time_limit(0);
+
+        $query = new \yii\db\Query();
+        $query->from(Ghs::tableName());
+        $query->where(['ownPtStyle' => 2]);
+        foreach ($query->batch(500) as $ghsList) {
+
+            $connection = Yii::$app->db;
+            $transaction = $connection->beginTransaction();
+            try {
+
+                foreach ($ghsList as $ghs) {
+                    $ghsId = $ghs['id'] ?? 0;
+                    $balance = PurchaseOrderClass::sum(['ghsId' => $ghsId, 'debt' => 1], 'actPrice');
+                    $debtNum = PurchaseOrderClass::getCount(['ghsId' => $ghsId, 'debt' => 1]);
+                    GhsClass::updateById($ghsId, ['balance' => -$balance, 'debtNum' => $debtNum]);
+                }
+
+                $transaction->commit();
+            } catch (\Exception $e) {
+                $transaction->rollBack();
+                $msg = $e->getMessage();
+                echo "报错了：" . $msg . "\n";
+            }
+        }
+    }
+
 }