diff --git a/app/Console/Commands/CheckSkuQualityPeriod.php b/app/Console/Commands/CheckSkuQualityPeriod.php index 621874e..1730285 100644 --- a/app/Console/Commands/CheckSkuQualityPeriod.php +++ b/app/Console/Commands/CheckSkuQualityPeriod.php @@ -45,7 +45,7 @@ class CheckSkuQualityPeriod extends Command { //定时任务每天执行一次 $endTime = Carbon::now()->endOfDay()->toDateTimeString(); - $startTime = Carbon::now()->startOfDay()->toDateTimeString();//目前检查范围是1天 + $startTime = Carbon::now()->subDays(4)->startOfDay()->toDateTimeString();//目前检查范围是5天 //查询未处理过的快过期的异常订单 $purchaseRecords = DB::table('purchase_records as a') @@ -60,21 +60,25 @@ class CheckSkuQualityPeriod extends Command $updateIds = []; foreach ($purchaseRecords as $v) { // 单独采购单后续总和小于库存表示该sku没有卖完 - $totalPurchaseNum = PurchaseRecords::query()->where('date', '>=', $v->date) + $totalPurchaseNum = PurchaseRecords::query()->where('created_at', '>=', $v->created_at) ->where('external_sku_id', "=", $v->external_sku_id) ->where("status", 1)->sum('num'); if ($totalPurchaseNum < $v->stock) { $messageService->skuQualityPeriodNoticeMessage((array)$v); + }else{ + // + $updateIds[] = $v->id; } - $updateIds[] = $v->id; //更新下状态 } - PurchaseRecords::query()->whereIn('id', $updateIds)->update([ - "check_status" => 1 - ]); + if(!empty($updateIds)){ + PurchaseRecords::query()->whereIn('id', $updateIds)->update([ + "check_status" => 1 + ]); + } } - Log::info('任务完成:check-CheckSkuQualityPeriod'); + Log::info('任务完成:check-CheckSkuQualityPeriod',[$updateIds]); } } \ No newline at end of file