cqp 1 hari lalu
induk
melakukan
cef6cf7174

+ 18 - 5
app/Console/Commands/U8Settle.php

@@ -45,13 +45,26 @@ class U8Settle extends Command
         }
     }
 
+    //array:3 [
+    //  "pu_date" => "2026-02-01"
+    //  "st_date" => "2026-02-01"
+    //  "sa_date" => "2026-02-01"
+    //]
     public function settle(){
         $service = new U8ThirtyPartyDatabaseServerService();
-        $minPeriods = $this->getYjData();
-        if(empty($minPeriods['pu_date']) || empty($minPeriods['st_date']) || empty($minPeriods['sa_date'])) {
-            Log::channel('u8_daily')->info('月结数据为空', ['msg' => $minPeriods]);
-            return;
-        }
+//        $minPeriods = $this->getYjData();
+//        if(empty($minPeriods['pu_date']) || empty($minPeriods['st_date']) || empty($minPeriods['sa_date'])) {
+//            Log::channel('u8_daily')->info('月结数据为空', ['msg' => $minPeriods]);
+//            return;
+//        }
+
+        $date = date("Y-m-d");
+        if($date <= "2026-03-23") $date = date("Y-m-d", strtotime("+1 day"));
+        $minPeriods = [
+            'pu_date' => $date,
+            'st_date' => $date,
+            'sa_date' => $date,
+        ];
 
         //单据-----------------
         $this->orderInsert($service, $minPeriods);

+ 2 - 2
app/Console/Commands/U8SettleInventory.php

@@ -57,7 +57,7 @@ class U8SettleInventory extends Command
         $tasks = [
             'product' => [
                 'whereRaw' => "",
-                'limit' => 100,
+                'limit' => 500,
             ]
         ];
 
@@ -126,7 +126,7 @@ class U8SettleInventory extends Command
             ->where('crt_time', $time)
             ->where('status', SyncTempRecordProduct::status_zero) // 只处理待处理的数据
             ->orderBy('id')
-            ->chunkById(100, function ($records) {
+            ->chunkById(500, function ($records) {
                 $batchData = [];
                 $record_ids = [];
                 $processedItems = []; // 用于批量维护快照

+ 2 - 2
app/Service/U8ThirdPartyService.php

@@ -32,7 +32,7 @@ class U8ThirdPartyService extends Service
        $type = $data['type'];
 
        list($status, $msg) = $this->getToken();
-//       if(! $status) return [false, $msg];
+       if(! $status) return [false, $msg];
        $data['u8_data'] = $msg;
 
        if($type == self::one){
@@ -57,7 +57,7 @@ class U8ThirdPartyService extends Service
    }
 
    public function getToken(){
-        $key = "drb_u8_api";
+        $key = "drb_u8_api" . env('SQLSRV_DATABASE');
         $config = config('wms.drb');
 
         // 1. 自检网络通畅