入库同步修改

app/Console/Commands/WasSyncWmsAsnInformation.php

@@ -86,7 +86,6 @@ class WasSyncWmsAsnInformation extends Command
         $storeService  = app(StoreService::class);
         ini_set('memory_limit', '2048M');
         $storeService->storeCreateByWms();
-        $storeService->storeEditCreateWms();
         $storeService->storeUpdateByWms();
     }
 }

app/Http/Controllers/TestController.php

@@ -20,12 +20,18 @@ use App\Services\OracleDocAsnHerderService;
 use App\Services\OracleDOCOrderHeaderService;
 use App\Services\OrderCommodityService;
 use App\Services\OrderService;
+use App\Services\OwnerService;
+use App\Services\RejectedBillService;
+use App\Services\StoreItemService;
+use App\Services\StoreService;
 use App\Services\WaveService;
 use App\Services\WaybillService;
 use App\SortingStation;
 use App\Store;
 use App\User;
 use App\UserToken;
+use App\ValueStore;
+use App\Warehouse;
 use App\Waybill;
 use Carbon\Carbon;
 use Illuminate\Database\Eloquent\Collection;
@@ -90,8 +96,89 @@ class TestController extends Controller
     {
         /** @var OracleDocAsnHerderService $oracleDocAsnHerderService */
         $oracleDocAsnHerderService = app(OracleDocAsnHerderService::class);
-        $asnHerders = $oracleDocAsnHerderService->getWmsAsnOnStartDateEdit('2022-10-26 20:01:00');
-        dd($asnHerders);
+        $asnHerders = $oracleDocAsnHerderService->getWmsAsnOnStartDateEdit('2022-10-26 20:30:00');
+        if (count($asnHerders)<1) return;
+        $this->createStore($asnHerders,"update");
+    }
+
+    public function createStore($asnHerders,$isUpdate=null)
+    {
+        if (!$asnHerders) return null;
+        /** @var OwnerService $ownerService */
+        $ownerService = app(OwnerService::class);
+        $owner_codes = [];
+        $warehouse_codes = [];
+        foreach ($asnHerders as $asnHerder) {
+            if (!empty($asnHerder['customerid']))
+                $owner_codes[$asnHerder['customerid']] = $asnHerder['customerid'];
+            if (!empty($asnHerder['warehouseid']))
+                $warehouse_codes[$asnHerder['warehouseid']] = $asnHerder['warehouseid'];
+        }
+        $owners = $ownerService->getOwnerByCodes($owner_codes);
+        $warehouses = Warehouse::query()->get();
+        $owners_code_map=[];
+        foreach ($owners as $owner) {
+            $owners_code_map[$owner->code] = $owner;
+        }
+        $warehouses_code_map=[];
+        foreach ($warehouses as $warehouse) {
+            $warehouses_code_map[$warehouse->code] = $warehouse;
+        }
+        $params = $this->getParamsByAsnHeader($asnHerders, $owners_code_map, $warehouses_code_map);
+        dd($params);
+        if (count($params) > 0) $this->insertStore($params);
+        /** @var StoreItemService $storeItemService */
+        $storeItemService = app(StoreItemService::class);
+        $storeItemService->storeItemCreateByWms($asnHerders);
+        /** @var RejectedBillService $rejectedBillService */
+        $rejectedBillService = app(RejectedBillService::class);
+        $rejectedBillService->syncLoadedStatusByAsnHerder($asnHerders);
+    }
+    public function getParamsByAsnHeader($asnHerders, $owners_code_map, $warehouses_code_map)
+    {
+        $params = [];
+        $stores = Store::query()->whereIn('asn_code', data_get($asnHerders, '*.asnno'))->get();
+        $store_asn_code_map = [];
+        foreach ($stores as $store) {
+            $store_asn_code_map[$store->asn_code] = $store;
+        }
+        foreach ($asnHerders as $asnHerder) {
+            if ($store_asn_code_map[$asnHerder->asnno] ?? false) continue;
+            $owner = $owners_code_map[$asnHerder->customerid] ?? null;
+            $warehouse = $warehouses_code_map[$asnHerder->warehouseid] ?? null;
+            $status = null;
+            $fast = null;
+            if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '完全收货') $status = '已入库';
+            if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '订单创建') $status = '未入库';
+            if ($asnHerder->asnType && $asnHerder->asnType->codename_c == '调拨入库') $fast = '快速入库';
+            $params[] = [
+                'asn_code' => $asnHerder->asnno,
+                'warehouse_id' => $warehouse->id ?? null,
+                'owner_id' => $owner->id ?? null,
+                'stored_method' => $asnHerder->asnType ? $asnHerder->asnType->codename_c : '',
+                'status' => $status ? $status : $asnHerder->asnStatus->codename_c,
+                'remark' => $asnHerder->notes ?? null,
+                'created_at' => $asnHerder->addtime ?? null,
+                'updated_at' => $asnHerder->edittime ?? null,
+                'is_fast_stored' => $fast,
+            ];
+        }
+        return $params;
+    }
+    public function insertStore(array $params)
+    {
+        if (count($params) === 0) return;
+        foreach (array_chunk($params, 1000) as $item) {
+                $bool = $this->insert($item);
+                if ($bool) {
+                    app('LogService')->log(__METHOD__, __FUNCTION__, "批量创建 store success " . count($item) . ' || ' . json_encode($item));
+                } else app('LogService')->log(__METHOD__, __FUNCTION__, "批量添加 store FAILED " . ' || ' . json_encode($item));
+
+        }
+    }
+    public function insert($params)
+    {
+        return Store::query()->insert($params);
     }
 }
 

app/Services/StoreService.php

@@ -27,17 +27,19 @@ use Illuminate\Support\Facades\Log;
 class StoreService
 {
     use ServiceAppAop;
-    protected $modelClass=Store::class;
+
+    protected $modelClass = Store::class;
+
     private function conditionQuery(array $params)
     {
         $stores = Store::query()->with(['storeItems.store', 'warehouse', 'owner'])->where('is_fast_stored', '无')->orderBy('id', 'DESC');
         $columnQueryRules = [
             'asn_code' => ['batch' => ''],
-            'remark' => ['batch' => '','timeLimit' => 15],
+            'remark' => ['batch' => '', 'timeLimit' => 15],
             'created_at_start' => ['alias' => 'created_at', 'startDate' => ' 00:00:00'],
             'created_at_end' => ['alias' => 'created_at', 'endDate' => ' 23:59:59'],
-            'owner' => ['alias' => 'owner_id','multi' => ','],
-            'warehouse' => ['alias' => 'warehouse_id','multi' => ','],
+            'owner' => ['alias' => 'owner_id', 'multi' => ','],
+            'warehouse' => ['alias' => 'warehouse_id', 'multi' => ','],
             'status' => ['multi' => ','],
             'stored_method' => ['multi' => ','],
             'id' => ['multi' => ',']
@@ -67,15 +69,15 @@ class StoreService
         $oracleDocAsnHerderService = app(OracleDocAsnHerderService::class);
         $last_time = $this->getAsnLastSyncAt($created_at, 'create');
         $asnHerders = $oracleDocAsnHerderService->getWmsAsnOnStartDateCreate($last_time);
-        if (count($asnHerders)<1) return;
+        if (count($asnHerders) < 1) return;
         try {
-            $arr=[];
-            foreach ($asnHerders as $asnHerder){
-                array_push($arr,$asnHerder->asnno);
+            $arr = [];
+            foreach ($asnHerders as $asnHerder) {
+                array_push($arr, $asnHerder->asnno);
             }
             RejectedPushJob::dispatch($arr);
         } catch (\Exception $e) {
-            Log::error("退货推送asn集合失败",[$e->getMessage()]);
+            Log::error("退货推送asn集合失败", [$e->getMessage()]);
         }
         $last_time = $asnHerders->first()['addtime'];
         $last_records = $asnHerders->where('addtime', $last_time);
@@ -85,15 +87,6 @@ class StoreService
         $this->setLastRecordsByRedis($create_key, $create_set, $create_keys, $last_records);
         $this->setAsnLastSyncAt($created_at, $last_time);
     }
-    public function storeEditCreateWms(){
-        $updated_at = config('sync.asn_sync.updated_at');
-        /** @var OracleDocAsnHerderService $oracleDocAsnHerderService */
-        $oracleDocAsnHerderService = app(OracleDocAsnHerderService::class);
-        $last_time = $this->getAsnLastSyncAt($updated_at, 'update');
-        $asnHerders = $oracleDocAsnHerderService->getWmsAsnOnStartDateEdit($last_time);
-        if (count($asnHerders)<1) return;
-        $this->createStore($asnHerders,"update");
-    }
 
     public function storeUpdateByWms()
     {
@@ -106,22 +99,22 @@ class StoreService
         $oracleDocAsnHerderService = app(OracleDocAsnHerderService::class);
         $last_time = $this->getAsnLastSyncAt($updated_at, 'update');
         app('LogService')
-            ->log(__METHOD__, __FUNCTION__, '11 获取上次更新时间：' . $last_time );
+            ->log(__METHOD__, __FUNCTION__, '11 获取上次更新时间：' . $last_time);
         $asnHerders = $oracleDocAsnHerderService->getWmsAsnOnStartDateEdit($last_time);
 
-        if (count($asnHerders)<1) return;
+        if (count($asnHerders) < 1) return;
         try {
-            $arr=[];
-            foreach ($asnHerders as $asnHerder){
-                array_push($arr,$asnHerder->asnno);
+            $arr = [];
+            foreach ($asnHerders as $asnHerder) {
+                array_push($arr, $asnHerder->asnno);
             }
             RejectedPushJob::dispatch($arr);
         } catch (\Exception $e) {
-            Log::error("退货推送asn集合失败",[$e->getMessage()]);
+            Log::error("退货推送asn集合失败", [$e->getMessage()]);
         }
         $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);
@@ -130,7 +123,7 @@ class StoreService
 
     }
 
-    public function createStore($asnHerders,$isUpdate=null)
+    public function createStore($asnHerders, $isUpdate = null)
     {
         if (!$asnHerders) return null;
         /** @var OwnerService $ownerService */
@@ -145,11 +138,11 @@ class StoreService
         }
         $owners = $ownerService->getOwnerByCodes($owner_codes);
         $warehouses = Warehouse::query()->get();
-        $owners_code_map=[];
+        $owners_code_map = [];
         foreach ($owners as $owner) {
             $owners_code_map[$owner->code] = $owner;
         }
-        $warehouses_code_map=[];
+        $warehouses_code_map = [];
         foreach ($warehouses as $warehouse) {
             $warehouses_code_map[$warehouse->code] = $warehouse;
         }
@@ -161,7 +154,7 @@ class StoreService
         /** @var RejectedBillService $rejectedBillService */
         $rejectedBillService = app(RejectedBillService::class);
         $rejectedBillService->syncLoadedStatusByAsnHerder($asnHerders);
-        if (!$isUpdate)$this->pushJob($asnHerders);
+        if (!$isUpdate) $this->pushJob($asnHerders);
         if (!$isUpdate) unset($asnHerders);
         unset($owners_code_map, $warehouses_code_map);
     }
@@ -179,7 +172,7 @@ class StoreService
             $owner = $owners_code_map[$asnHerder->customerid] ?? null;
             $warehouse = $warehouses_code_map[$asnHerder->warehouseid] ?? null;
             $status = null;
-            $fast = null;
+            $fast = '无';
             if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '完全收货') $status = '已入库';
             if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '订单创建') $status = '未入库';
             if ($asnHerder->asnType && $asnHerder->asnType->codename_c == '调拨入库') $fast = '快速入库';
@@ -202,14 +195,10 @@ class StoreService
     {
         if (count($params) === 0) return;
         foreach (array_chunk($params, 1000) as $item) {
-            try {
-                $bool = $this->insert($item);
-                if ($bool) {
-                    app('LogService')->log(__METHOD__, __FUNCTION__, "批量创建 store success " . count($item) . ' || ' . json_encode($item));
-                } else app('LogService')->log(__METHOD__, __FUNCTION__, "批量添加 store FAILED " . ' || ' . json_encode($item));
-            } catch (\Exception $e) {
-                app('LogService')->log(__METHOD__, __FUNCTION__, "批量添加 store ERROR " . ' || ' . json_encode($params) . ' || ' . json_encode($e->getMessage()) . ' || ' . json_encode($e->getTraceAsString()));
-            }
+            $bool = $this->insert($item);
+            if ($bool) {
+                app('LogService')->log(__METHOD__, __FUNCTION__, "批量创建 store success " . count($item) . ' || ' . json_encode($item));
+            } else app('LogService')->log(__METHOD__, __FUNCTION__, "批量添加 store FAILED " . ' || ' . json_encode($item));
         }
     }
 
@@ -224,7 +213,7 @@ class StoreService
         $dataHandlerService = app(DataHandlerService::class);
         $stores = $this->getByWms($asnHerders);
         $store_asn_code_map = $dataHandlerService->dataHeader(['asn_code'], $stores);
-        $owners = $ownerService->getOwnerByCodes(array_unique(data_get($asnHerders,'*.customerid')));
+        $owners = $ownerService->getOwnerByCodes(array_unique(data_get($asnHerders, '*.customerid')));
         $warehouses = Warehouse::query()->get();
         $owner_code_map = $dataHandlerService->dataHeader(['code'], $owners);
         $warehouses_map = $dataHandlerService->dataHeader(['code'], $warehouses);
@@ -239,15 +228,15 @@ class StoreService
             $owner_id = $owner->id ?? null;
             $warehouse_id = $warehouse->id ?? null;
             $status = null;
-            $fast = null;
+            $fast = '无';
             if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '完全收货') $status = '已入库';
             if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '订单创建') $status = '未入库';
             if ($asnHerder->asnType && $asnHerder->asnType->codename_c == '调拨入库') $fast = '快速入库';
             if ($store->asn_code != $asnHerder->asnno ||
                 $store->warehouse_id != $warehouse_id ||
                 $store->owner_id != $owner_id ||
-                $store->stored_method != ($asnHerder->asnType->codename_c ??'')||
-                $store->status != ($asnHerder->asnStatus->codename_c ?? '')||
+                $store->stored_method != ($asnHerder->asnType->codename_c ?? '') ||
+                $store->status != ($asnHerder->asnStatus->codename_c ?? '') ||
                 $store->remark != $asnHerder->notes ||
                 $store->updated_at != $asnHerder->edittime) {
                 $updateParams[] = [
@@ -263,7 +252,9 @@ class StoreService
                 ];
             }
         }
-        if (count($updateParams) > 1) {$this->batchUpdate($updateParams);}
+        if (count($updateParams) > 1) {
+            $this->batchUpdate($updateParams);
+        }
         /** @var StoreItemService $storeItemService */
         $storeItemService = app(StoreItemService::class);
         $storeItemService->storeItemUpdateByWms($asnHerders);
@@ -274,8 +265,9 @@ class StoreService
         unset($updateParams, $asnHerders);
     }
 
-    public function pushJob($asnHerders){
-        dispatch(new StoreCreateInstantBill(Store::query()->with(["storeItems"])->where('status','已入库')->whereIn('asn_code', data_get($asnHerders,'*.asnno'))->get()));
+    public function pushJob($asnHerders)
+    {
+        dispatch(new StoreCreateInstantBill(Store::query()->with(["storeItems"])->where('status', '已入库')->whereIn('asn_code', data_get($asnHerders, '*.asnno'))->get()));
     }
 
     public function insert($params)
@@ -349,19 +341,19 @@ class StoreService
     {
         /** @var \stdClass $store */
         if (!$store || $store->status != "已入库") return false;
-        if (Cache::has("owner_fee_details:stores_".$store->id))return true;
-        $store->loadMissing(["storeItems.commodity","warehouse"]);
+        if (Cache::has("owner_fee_details:stores_" . $store->id)) return true;
+        $store->loadMissing(["storeItems.commodity", "warehouse"]);
         /** @var OwnerPriceOperationService $service */
         $service = app("OwnerPriceOperationService");
 
         $workedAt = $store->updated_at;
-        $month = substr($workedAt,0,7);
+        $month = substr($workedAt, 0, 7);
 
         $GLOBALS["FEE_INFO"] = [];
-        list($id,$money,$taxFee) = $service->matching($month, $store, Feature::MAPPING["store"], $store->owner_id, "入库");
+        list($id, $money, $taxFee) = $service->matching($month, $store, Feature::MAPPING["store"], $store->owner_id, "入库");
 
         $amount = 0;
-        if ($store->storeItems)foreach ($store->storeItems as $item)$amount += $item->amount;
+        if ($store->storeItems) foreach ($store->storeItems as $item) $amount += $item->amount;
         if (!app("OwnerFeeDetailService")->create([
             "owner_id" => $store->owner_id,
             "worked_at" => $workedAt,
@@ -375,19 +367,19 @@ class StoreService
             "outer_table_name" => "stores",
             "work_tax_fee" => $taxFee,
         ])) return false;
-        $this->setStoreAmount($store->owner_id,$amount,$month);
-        if ($money>0)$this->constructFeeInfo([
+        $this->setStoreAmount($store->owner_id, $amount, $month);
+        if ($money > 0) $this->constructFeeInfo([
             "worked_at" => $workedAt,
             "owner_id" => $store->owner_id,
-            "model_id"  => $id,
-            "source_number"=> null,
-            "doc_number"   => $store->asn_code,
+            "model_id" => $id,
+            "source_number" => null,
+            "doc_number" => $store->asn_code,
             "commodity_id" => 0,
-            "total_fee"    =>0,
-            "tax_rate"     =>0,
-            "fee_description"=>'',
+            "total_fee" => 0,
+            "tax_rate" => 0,
+            "fee_description" => '',
         ]);
-        Cache::put("owner_fee_details:stores_".$store->id,1,86400);
+        Cache::put("owner_fee_details:stores_" . $store->id, 1, 86400);
         return true;
     }
 
@@ -400,14 +392,15 @@ class StoreService
      */
     public function constructFeeInfo(array $defaultInfo)
     {
-        foreach ($GLOBALS["FEE_INFO"] as $info){
+        foreach ($GLOBALS["FEE_INFO"] as $info) {
             $operation = $defaultInfo;
-            foreach ($operation as $key=>$val)if (isset($info[$key]))$operation[$key] = $info[$key];
+            foreach ($operation as $key => $val) if (isset($info[$key])) $operation[$key] = $info[$key];
             $model = OwnerFeeOperation::query()->create($operation);
-            if($info['details'])foreach ($info['details'] as &$detail)$detail["owner_fee_operation_id"] = $model->id;
+            if ($info['details']) foreach ($info['details'] as &$detail) $detail["owner_fee_operation_id"] = $model->id;
             OwnerFeeOperationDetail::query()->insert($info['details']);
         }
     }
+
     /**
      * 清除费用信息
      *
@@ -416,12 +409,12 @@ class StoreService
     public function clearFeeInfo(string $docNumber)
     {
         try {
-            $models = OwnerFeeOperation::query()->where("doc_number",$docNumber)->get();
-            if ($models->count()==0)return;
-            OwnerFeeOperationDetail::query()->whereIn("owner_fee_operation_id",array_column($models->toArray(),"id"))->delete();
-            OwnerFeeOperation::query()->where("doc_number",$docNumber)->delete();
-        }catch (\Exception $e){
-            Log::warning("清除费用信息发送错误",["ASN号：{$docNumber}",isset($models) ? $models->toJson() : "查费用信息时被锁定",$e->getMessage()]);
+            $models = OwnerFeeOperation::query()->where("doc_number", $docNumber)->get();
+            if ($models->count() == 0) return;
+            OwnerFeeOperationDetail::query()->whereIn("owner_fee_operation_id", array_column($models->toArray(), "id"))->delete();
+            OwnerFeeOperation::query()->where("doc_number", $docNumber)->delete();
+        } catch (\Exception $e) {
+            Log::warning("清除费用信息发送错误", ["ASN号：{$docNumber}", isset($models) ? $models->toJson() : "查费用信息时被锁定", $e->getMessage()]);
         }
     }
 
@@ -429,34 +422,35 @@ class StoreService
      * @param $asnHerders
      * @return null
      */
-    public function createStoreRejected($asnHerders){
+    public function createStoreRejected($asnHerders)
+    {
         if (!$asnHerders) return null;
         $stores = $this->getByWms($asnHerders);
         $orders = Order::query()->whereIn('client_code', data_get($asnHerders, '*.asnreference2'))->get();
-        $store_rejecteds=StoreRejected::query()->whereIn('order_id',data_get($orders,'*.id'))->whereIn('store_id',data_get($stores,'*.id'))->get();
+        $store_rejecteds = StoreRejected::query()->whereIn('order_id', data_get($orders, '*.id'))->whereIn('store_id', data_get($stores, '*.id'))->get();
         /** @var DataHandlerService $dataHandlerService */
         $dataHandlerService = app(DataHandlerService::class);
         $order_map = $dataHandlerService->dataHeader(['client_code'], $orders);
         $store_map = $dataHandlerService->dataHeader(['asn_code'], $stores);
-        $store_rejected_map=$dataHandlerService->dataHeader(['store_id','order_id','logistic_number_return'],$store_rejecteds);
-        $insert_param=[];
-        foreach ($asnHerders as $asnHerder){
+        $store_rejected_map = $dataHandlerService->dataHeader(['store_id', 'order_id', 'logistic_number_return'], $store_rejecteds);
+        $insert_param = [];
+        foreach ($asnHerders as $asnHerder) {
             if (!$asnHerder->asnreference2) continue;
-            $order=$dataHandlerService->getKeyValue(['client_code'=>$asnHerder->asnreference2],$order_map);
-            $store=$dataHandlerService->getKeyValue(['asn_code'=>$asnHerder->asnno],$store_map);
-            if (!$order || !$store)continue;
-            $store_rejected=$dataHandlerService->getKeyValue(['store_id'=>$store->id,'order_id'=>$order->id,'logistic_number_return'=>$asnHerder->asnreference3],$store_rejected_map);
+            $order = $dataHandlerService->getKeyValue(['client_code' => $asnHerder->asnreference2], $order_map);
+            $store = $dataHandlerService->getKeyValue(['asn_code' => $asnHerder->asnno], $store_map);
+            if (!$order || !$store) continue;
+            $store_rejected = $dataHandlerService->getKeyValue(['store_id' => $store->id, 'order_id' => $order->id, 'logistic_number_return' => $asnHerder->asnreference3], $store_rejected_map);
             if ($store_rejected) continue;
-            $insert_param[]=[
-                'store_id'=>$store->id,
-                'order_id'=>$order->id,
-                'logistic_number_return'=>$asnHerder->asnreference3 ?? '',
-                'created_at'=>Carbon::now()->toDateTimeString(),
+            $insert_param[] = [
+                'store_id' => $store->id,
+                'order_id' => $order->id,
+                'logistic_number_return' => $asnHerder->asnreference3 ?? '',
+                'created_at' => Carbon::now()->toDateTimeString(),
             ];
         }
-        if (count($insert_param)>0) StoreRejected::query()->insert($insert_param);
+        if (count($insert_param) > 0) StoreRejected::query()->insert($insert_param);
         app('LogService')
-            ->log(__METHOD__, __FUNCTION__, '11 createStoreRejected：'.json_encode($insert_param));
+            ->log(__METHOD__, __FUNCTION__, '11 createStoreRejected：' . json_encode($insert_param));
     }
 
     /**
@@ -471,8 +465,8 @@ class StoreService
 SELECT sum(amount) total FROM `store_items` LEFT JOIN stores ON store_items.store_id=stores.id WHERE stores.owner_id = ? AND (stores.status='已入库' OR stores.status='ASN关闭') AND store_items.updated_at LIKE ?
 sql
         );
-        $statistics = DB::selectOne($query,[$owner,date("Y-m")."%"]);
-        Cache::put($month."|A|".$owner,$statistics->total ?: 0,2764800);
+        $statistics = DB::selectOne($query, [$owner, date("Y-m") . "%"]);
+        Cache::put($month . "|A|" . $owner, $statistics->total ?: 0, 2764800);
     }
 
     /**
@@ -485,8 +479,8 @@ sql
     public function setStoreAmount(int $owner, int $amount, string $month)
     {
         $date = date("Y-m");
-        if (!Cache::has($date."|A|".$owner))$this->storeAmountCompensationLogic($owner,$month);//补偿逻辑
-        Cache::increment($date."|A|".$owner,$amount);
+        if (!Cache::has($date . "|A|" . $owner)) $this->storeAmountCompensationLogic($owner, $month);//补偿逻辑
+        Cache::increment($date . "|A|" . $owner, $amount);
     }
 
     /**
@@ -497,9 +491,9 @@ sql
      *
      * @return int
      */
-    public function getStoreAmount(int $owner, string $date):int
+    public function getStoreAmount(int $owner, string $date): int
     {
-        if (!Cache::has($date."|A|".$owner))$this->storeAmountCompensationLogic($owner,$date);
-        return Cache::get($date."|A|".$owner);
+        if (!Cache::has($date . "|A|" . $owner)) $this->storeAmountCompensationLogic($owner, $date);
+        return Cache::get($date . "|A|" . $owner);
     }
 }