Pārlūkot izejas kodu

asn同步修改

haozi 4 gadi atpakaļ
vecāks
revīzija
9698d4890b

+ 12 - 9
app/Http/Controllers/TestController.php

@@ -520,20 +520,21 @@ sql;
     {
         ini_set('max_execution_time', 0);
         ini_set('memory_limit', '1024M');
-        $now = Carbon::now();
+//        $now = Carbon::now();
 //        $startDate = $this->getDate();
-        $startDate = '2021-09-19 14:15:58';
-        $diffDay = 2; // 天数
+        $startDate = '2021-09-25 13:23:14';
+        $diffDay = 1; // 天数
         for($i = 0;$i<=$diffDay;$i++){
             $endDate = Carbon::parse($startDate)->addDays(1)->toDateTimeString();
             $doc_asn_headers = $this->getDocAsnHeader($startDate,$endDate);
-            if (count($doc_asn_headers)>0){
-                $this->syncStores($doc_asn_headers);
-                $this->syncDate($endDate);
-            }
-            dump($endDate);
+//            if (count($doc_asn_headers)>0){
+//                $this->syncStores($doc_asn_headers);
+//                $this->syncDate($endDate);
+//            }
+            dump($startDate,$endDate);
             $startDate = $endDate;
         }
+        $this->clearCache();
 //        ValueStore::query()->updateOrCreate([
 //            'name' => 'last_asn_sync_task_end_at',
 //        ], [
@@ -590,8 +591,10 @@ sql;
     }
     public function updateStoreItem()
     {
+        ini_set('max_execution_time', 0);
+        ini_set('memory_limit', '1024M');
         $storeIds = Store::query()
-            ->where('updated_at', '>=', '2021-09-22 10:00:0')
+            ->where('updated_at', '>=', '2021-09-25 13:21:26')
             ->whereColumn('updated_at', '<>', 'created_at')
             ->pluck('id');
 

+ 1 - 1
app/Services/StoreService.php

@@ -92,7 +92,7 @@ class StoreService
         if (count($asnHerders)<1) return;
         $last_time = $asnHerders->first()['edittime'];
         $last_records = $asnHerders->where('edittime', $last_time);
-        $this->createStore($asnHerders,"update");
+//        $this->createStore($asnHerders,"update");
         $this->updateStore($asnHerders);
         $this->createStoreRejected($asnHerders);
         $this->deleteCacheKey($update_set, $update_keys);