|
|
@@ -26,6 +26,7 @@ use App\Events\CancelOrder;
|
|
|
use App\Events\SendEmailEvent;
|
|
|
use App\Exceptions\Exception;
|
|
|
use App\Http\Controllers\api\thirdPart\haiq\PickStationController;
|
|
|
+use App\Http\Controllers\api\thirdPart\hengli\PackageController;
|
|
|
use App\Http\Requests\ForeignHaiRobotic_taskUpdateRequest;
|
|
|
use App\Http\Requests\TestAaRequest;
|
|
|
use App\Imports\OrderTrackingImport;
|
|
|
@@ -61,7 +62,6 @@ use App\Owner;
|
|
|
use App\OwnerFeeDetail;
|
|
|
use App\OwnerFeeDetailLogistic;
|
|
|
use App\OwnerPriceExpress;
|
|
|
-use App\OwnerPriceExpressProvince;
|
|
|
use App\OwnerPriceOperation;
|
|
|
use App\OwnerPriceOperationItem;
|
|
|
use App\OwnerReport;
|
|
|
@@ -102,13 +102,11 @@ use App\Services\OrderTrackingOwnerService;
|
|
|
use App\Services\OrderTrackingService;
|
|
|
use App\Services\OwnerPriceOperationService;
|
|
|
use App\Services\OwnerService;
|
|
|
-use App\Services\ProcurementWeiXinSendMessageService;
|
|
|
use App\Services\RegionService;
|
|
|
use App\Services\RejectedBillService;
|
|
|
use App\Services\ShopService;
|
|
|
use App\Services\StoreService;
|
|
|
use App\Services\WarehouseService;
|
|
|
-use App\Station;
|
|
|
use App\StationRuleBatch;
|
|
|
use App\StationTask;
|
|
|
use App\StationTaskMaterialBox;
|
|
|
@@ -564,7 +562,6 @@ class TestController extends Controller
|
|
|
});
|
|
|
dd($authorities);
|
|
|
}
|
|
|
-
|
|
|
public function output2()
|
|
|
{
|
|
|
StationTaskBatch::query()->insert([[
|
|
|
@@ -782,40 +779,6 @@ class TestController extends Controller
|
|
|
}
|
|
|
|
|
|
|
|
|
- public function testSyncOrderTask()
|
|
|
- {
|
|
|
- Cache::flush();
|
|
|
- dump('hendle...');
|
|
|
- dump((string)Carbon::now());
|
|
|
- dump(memory_get_usage() / 1024 / 1024);
|
|
|
- $task = new SyncWMSOrderTask();
|
|
|
- $task->handle();
|
|
|
- dump((string)Carbon::now());
|
|
|
- dump('hendle...end');
|
|
|
- dump(memory_get_usage() / 1024 / 1024);
|
|
|
- dump(memory_get_peak_usage() / 1024 / 1024);
|
|
|
- return view('test');
|
|
|
- }
|
|
|
-
|
|
|
- public function testSyncWaveNo()
|
|
|
- {
|
|
|
- $waveHeader = OracleDOCWaveHeader::query()->where('waveno', 'W201209000024')->first();
|
|
|
-// Batch::query()->create([
|
|
|
-// 'code' => $waveHeader->waveno,
|
|
|
-// 'wms_created_at' => $waveHeader->addtime,
|
|
|
-// 'remark' => $waveHeader->descr,
|
|
|
-// 'wms_status' => '99',
|
|
|
-// ]);
|
|
|
- $waveHeaderDetails = OracleDOCWaveDetails::query()->where('waveno', $waveHeader->waveno)->get();
|
|
|
- $orderNos = $waveHeaderDetails->map(function ($item) {
|
|
|
- return $item->orderno;
|
|
|
- });
|
|
|
- $orderHeaderService = new OracleDOCOrderHeaderService();
|
|
|
- $orderHeaders = $orderHeaderService->getOrderInfoByOrderNos($orderNos);
|
|
|
- $orderService = new OrderService();
|
|
|
- $orderService->syncOrderByWMSOrderHeaders($orderHeaders);
|
|
|
- }
|
|
|
-
|
|
|
|
|
|
public function testUpdateSkuNameBarcodeToCommodity_id()
|
|
|
{
|
|
|
@@ -861,145 +824,42 @@ class TestController extends Controller
|
|
|
if (count($updateParams) > 0) app(BatchUpdateService::class)->batchUpdate('store_items', $updateParams);
|
|
|
}
|
|
|
|
|
|
- public function syncOrderTrackingTask()
|
|
|
+ function testUpdateStores()
|
|
|
{
|
|
|
- $service = new OrderTrackingService();
|
|
|
- $start_data = Carbon::parse('2020-12-21 10:00:00');
|
|
|
- $end_data = Carbon::parse('2020-12-21 10:05:00');
|
|
|
- $orderNos = OracleDOCOrderHeader::query()->selectRaw('orderno')
|
|
|
- ->where('addTime', '>=', $start_data)
|
|
|
- ->where('addTime', '<=', $end_data)
|
|
|
- ->get()->map(function ($orderHeader) {
|
|
|
- return $orderHeader->orderno;
|
|
|
- });
|
|
|
- $order_no_list = $orderNos->chunk(3000);
|
|
|
- foreach ($order_no_list as $order_nos) {
|
|
|
- $orderHeaders = OracleDOCOrderHeader::query()->selectRaw(implode(',', OracleDOCOrderHeaderService::$columns))
|
|
|
- ->with(['oracleBASCustomer' => function ($query) {
|
|
|
- $query->selectRaw('BAS_CUSTOMER.CustomerID,BAS_CUSTOMER.Customer_Type,BAS_CUSTOMER.Descr_C,BAS_CUSTOMER.Active_Flag');
|
|
|
- }, 'oracleDOCOrderDetails' => function ($query) {
|
|
|
- $query->selectRaw('doc_order_details.orderNo,doc_order_details.customerid,doc_order_details.sku,doc_order_details.QtyOrdered,doc_order_details.Location');
|
|
|
- }, 'actAllocationDetails' => function ($query) {
|
|
|
- $query->selectRaw('ACT_Allocation_Details.AllocationDetailsID,ACT_Allocation_Details.OrderNo,ACT_Allocation_Details.Qty_Each,ACT_Allocation_Details.PickToTraceID,ACT_Allocation_Details.CustomerID,ACT_Allocation_Details.Sku,ACT_Allocation_Details.Location');
|
|
|
- }, 'oracleBASCode' => function ($query) {
|
|
|
- $query->selectRaw('BAS_Codes.CodeID,BAS_Codes.CodeName_C,BAS_Codes.Code');
|
|
|
- }, 'orderType' => function ($query) {
|
|
|
- $query->selectRaw('BAS_Codes.CodeID,BAS_Codes.CodeName_C,BAS_Codes.Code');
|
|
|
- }])
|
|
|
- ->whereIn('DOC_Order_Header.OrderNo', $order_nos)
|
|
|
- ->get();
|
|
|
- app(OrderService::class)->syncOrderByWMSOrderHeaders($orderHeaders);
|
|
|
- app("OrderCommodityService")->syncOrderCommodity($orderHeaders);
|
|
|
- app('OrderPackageService')->syncOrderPackage($orderHeaders);
|
|
|
- app("OrderPackageCommoditiesService")->syncOrderPackageCommodities($orderHeaders);
|
|
|
- $service->createByWmsOrderHeader($orderHeaders);
|
|
|
- unset($orderHeaders);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public function syncOrderTask()
|
|
|
- {
|
|
|
- $service = new OrderService();
|
|
|
- $start_data = Carbon::parse('2020-12-21 10:00:00');
|
|
|
- $end_data = Carbon::parse('2020-12-21 11:00:00');
|
|
|
- $orderNos = OracleDOCOrderHeader::query()->selectRaw('orderno')
|
|
|
- ->where('addTime', '>=', $start_data)
|
|
|
- ->where('addTime', '<=', $end_data)
|
|
|
- ->get()->map(function ($orderHeader) {
|
|
|
- return $orderHeader->orderno;
|
|
|
- });
|
|
|
- $order_no_list = $orderNos->chunk(3000);
|
|
|
- foreach ($order_no_list as $order_nos) {
|
|
|
- $orderHeaders = OracleDOCOrderHeader::query()->selectRaw(implode(',', OracleDOCOrderHeaderService::$columns))
|
|
|
- ->with(['oracleBASCustomer' => function ($query) {
|
|
|
- $query->selectRaw('BAS_CUSTOMER.CustomerID,BAS_CUSTOMER.Customer_Type,BAS_CUSTOMER.Descr_C,BAS_CUSTOMER.Active_Flag');
|
|
|
- }, 'oracleDOCOrderDetails' => function ($query) {
|
|
|
- $query->selectRaw('doc_order_details.orderNo,doc_order_details.customerid,doc_order_details.sku,doc_order_details.QtyOrdered,doc_order_details.Location');
|
|
|
- }, 'actAllocationDetails' => function ($query) {
|
|
|
- $query->selectRaw('ACT_Allocation_Details.AllocationDetailsID,ACT_Allocation_Details.OrderNo,ACT_Allocation_Details.Qty_Each,ACT_Allocation_Details.PickToTraceID,ACT_Allocation_Details.CustomerID,ACT_Allocation_Details.Sku,ACT_Allocation_Details.Location');
|
|
|
- }, 'oracleBASCode' => function ($query) {
|
|
|
- $query->selectRaw('BAS_Codes.CodeID,BAS_Codes.CodeName_C,BAS_Codes.Code');
|
|
|
- }, 'orderType' => function ($query) {
|
|
|
- $query->selectRaw('BAS_Codes.CodeID,BAS_Codes.CodeName_C,BAS_Codes.Code');
|
|
|
- }])
|
|
|
- ->whereIn('DOC_Order_Header.OrderNo', $order_nos)
|
|
|
- ->get();
|
|
|
- $service->syncOrder($orderHeaders);
|
|
|
- unset($orderHeaders);
|
|
|
+ $stores = Store::query()->where('stored_method', '快速入库')->get();
|
|
|
+ $updated_at = Carbon::now()->toDateTimeString();
|
|
|
+ $updateParams = [[
|
|
|
+ 'id', 'is_fast_stored', 'updated_at'
|
|
|
+ ]];
|
|
|
+ foreach ($stores as $store) {
|
|
|
+ if ($store->stored_method != '快速入库') continue;
|
|
|
+ $updateParams[] = [
|
|
|
+ 'id' => $store->id,
|
|
|
+ 'is_fast_stored' => '快速入库',
|
|
|
+ 'updated_at' => $updated_at,
|
|
|
+ ];
|
|
|
}
|
|
|
+ if (count($updateParams) > 1) app(BatchUpdateService::class)->batchUpdate('stores', $updateParams);
|
|
|
}
|
|
|
|
|
|
- public function testOrderissue()
|
|
|
+ public function testSyncAsn()
|
|
|
{
|
|
|
- $orderIssue_unique = \App\OrderIssue::withTrashed()
|
|
|
- ->selectRaw('count(1) as count,id,order_id')
|
|
|
- ->whereNotNull('order_id')
|
|
|
- ->orderByDesc('created_at')
|
|
|
- ->groupBy('order_id')
|
|
|
- ->having('count', '>', 1)
|
|
|
- ->limit(100)
|
|
|
- ->get();
|
|
|
- if ($orderIssue_unique->count() == 0) return;
|
|
|
- foreach ($orderIssue_unique as $item) {
|
|
|
- $orderIssue_delete = OrderIssue::withTrashed()->where('order_id', $item->order_id)->get();
|
|
|
- /** @var OrderIssue $order_issue_unique */
|
|
|
- $order_issue_unique = $orderIssue_delete->whereNull('deleted_at')->first();
|
|
|
- if (!$order_issue_unique) $order_issue_unique = $orderIssue_delete->first();
|
|
|
- $ids = [];
|
|
|
- foreach ($orderIssue_delete as $key => $order_issue) {
|
|
|
- if ($order_issue->id == $order_issue_unique->id) continue;
|
|
|
- $ids[] = $order_issue->id;
|
|
|
- if ($order_issue['logistic_number_return']) $order_issue_unique['logistic_number_return'] = $order_issue['logistic_number_return'];
|
|
|
- if ($order_issue['rejecting_status'] != '未退回') $order_issue_unique['rejecting_status'] = $order_issue['rejecting_status'];
|
|
|
- if ($order_issue['is_new_rejecting'] != '无') $order_issue_unique['is_new_rejecting'] = $order_issue['is_new_rejecting'];
|
|
|
- if ($order_issue['user_workgroup_id']) $order_issue_unique['user_workgroup_id'] = $order_issue['user_workgroup_id'];
|
|
|
- if ($order_issue['imported_status'] != '正常') $order_issue_unique['imported_status'] = $order_issue['imported_status'];
|
|
|
- if ($order_issue['custom_code']) $order_issue_unique['custom_code'] = $order_issue['custom_code'];
|
|
|
- }
|
|
|
- $order_issue_unique->save();
|
|
|
- app('LogService')->log(__METHOD__, __FUNCTION__, '修改OrderIssue:' . json_encode($order_issue_unique));
|
|
|
- $orderIssues = OrderIssue::query()->whereIn('id', $ids)->get();
|
|
|
- $bool = OrderIssue::query()->whereIn('id', $ids)->forceDelete();
|
|
|
- if ($bool) app('LogService')->log(__METHOD__, __FUNCTION__, '删除OrderIssue:' . json_encode($orderIssues));
|
|
|
- }
|
|
|
+// dump('hendle...');
|
|
|
+ dump((string)Carbon::now());
|
|
|
+// dump(memory_get_usage() / 1024 / 1024);
|
|
|
+ $task = new WasSyncWmsAsnInformation();
|
|
|
+ $task->handle();
|
|
|
+ dump((string)Carbon::now());
|
|
|
+// dump('hendle...end');
|
|
|
+// dump(memory_get_usage() / 1024 / 1024);
|
|
|
+// dump(memory_get_peak_usage() / 1024 / 1024);
|
|
|
+// return view('test');
|
|
|
}
|
|
|
|
|
|
- public function testChangeOrderTracking()
|
|
|
+ public function editOrderSyncAt()
|
|
|
{
|
|
|
- /** @var OrderTrackingService $service */
|
|
|
- $service = app(OrderTrackingService::class);
|
|
|
- $maxId = \App\OrderTracking::query()->orderByDesc('id')->first();
|
|
|
- $orderTracking_min = \App\OrderTracking::query()->where('logistic_id', 0)->orderBy('id')->first();
|
|
|
- if (!$maxId) return;
|
|
|
- $maxId = $maxId->id;
|
|
|
- $minId = $orderTracking_min->id;
|
|
|
- $logistic = \App\Logistic::query()->where('name', '新杰物流')->first();
|
|
|
- $logistic_zt = \App\Logistic::query()->where('name', '自提')->first();
|
|
|
- for ($i = $minId; $i <= $maxId; $i += 100) {
|
|
|
- $orderTrackings = \App\OrderTracking::query()
|
|
|
- ->where('id', '>=', $i)
|
|
|
- ->where('id', '<=', $i + 100)
|
|
|
- ->where('logistic_id', '=', 0)
|
|
|
- ->where('created_at', '!=', '0000-00-00 00:00:00')
|
|
|
- ->get();
|
|
|
- if ($orderTrackings->count() == 0) continue;
|
|
|
- $update_params = [['id', 'logistic_id']];
|
|
|
- $orderTrackings->each(function ($orderTracking) use ($logistic_zt, $logistic, &$update_params) {
|
|
|
- $order = $orderTracking->commodities->package->order;
|
|
|
- $logistic_id = $order->logistic_id;
|
|
|
- if ($logistic_id != null) {
|
|
|
- if ($order->logistic_id == $logistic_zt->id) $logistic_id = $logistic->id;
|
|
|
- if ($logistic_id == 0) dd($order, $logistic_id);
|
|
|
- $update_params[] = [
|
|
|
- 'id' => $orderTracking->id,
|
|
|
- 'logistic_id' => $logistic_id,
|
|
|
- ];
|
|
|
- }
|
|
|
- });
|
|
|
- if (count($update_params) > 1) {
|
|
|
- $service->batchUpdate($update_params);
|
|
|
- }
|
|
|
- }
|
|
|
+ ValueStore::query()->where('name', 'order_last_created_sync_at')->update(['value' => '2020-12-22 09:00:00']);
|
|
|
+ ValueStore::query()->where('name', 'order_last_updated_sync_at')->update(['value' => '2020-12-22 09:00:00']);
|
|
|
}
|
|
|
|
|
|
public function testHz()
|
|
|
@@ -1058,100 +918,6 @@ class TestController extends Controller
|
|
|
$controller->index();
|
|
|
}
|
|
|
|
|
|
- public function processOrderIssueRejectedBill()
|
|
|
- {
|
|
|
- OrderIssue::query()->withTrashed()->whereNotNull('logistic_number_return')->chunkById(200, function ($orderIssues) {
|
|
|
- $orderIssues->each(function ($orderIssue) {
|
|
|
- if ($orderIssue->logistic_number_return)
|
|
|
- $orderIssue->rejectedBills()->syncWithoutDetaching([trim($orderIssue->logistic_number_return)]);
|
|
|
- });
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- public function SyncOrderTracking()
|
|
|
- {
|
|
|
- $start_data = Carbon::parse('2021-01-01 00:00:00');
|
|
|
- $service = new OrderTrackingService();
|
|
|
- $service->trackingWmsOrderOnCreate($start_data);
|
|
|
- }
|
|
|
-
|
|
|
- public function SyncUpdateOrderTracking()
|
|
|
- {
|
|
|
- $start_data = Carbon::parse('2021-01-14 00:00:00');
|
|
|
- $service = new OrderTrackingService();
|
|
|
- $service->trackingWmsOrderOnEdit($start_data);
|
|
|
- }
|
|
|
-
|
|
|
- public function orderTrackingUpdate()
|
|
|
- {
|
|
|
- $start_at = '2021-01-08 00:00:00';
|
|
|
- $end_at = '2021-01-12 00:00:00';
|
|
|
- // 修改【安桥,锐活】 订单号
|
|
|
- $orderHeaderService = new OracleDOCOrderHeaderService();
|
|
|
- $orderTrackingService = new OrderTrackingService();
|
|
|
- $query = $orderHeaderService->getQuery();
|
|
|
- $orderHeaders = $query->whereIn('Doc_Order_Header.customerid', ['ONKYO', 'RUIHUO'])
|
|
|
- ->where('Doc_Order_Header.AddTime', '>=', $start_at)
|
|
|
- ->where('Doc_Order_Header.AddTime', '<=', $end_at)
|
|
|
- ->get();
|
|
|
- $orderTrackingService->updateByWmsOrderHeaders($orderHeaders);
|
|
|
- }
|
|
|
-
|
|
|
- public function updateOrderTracking()
|
|
|
- {
|
|
|
- OrderTracking::query()->with(['commodities' => function ($query) {
|
|
|
- $query->with(['commodity', 'package.order']);
|
|
|
- }])->whereNotNull('client')
|
|
|
- ->where('created_at', '>=', '2021-01-01')
|
|
|
- ->where('created_at', '<=', '2021-01-07')
|
|
|
- ->where('created_at', '!=', '0000-00-00 00:00:00')
|
|
|
- ->chunkById('200', function ($orderTrackings) {
|
|
|
- /**
|
|
|
- * @var DataHandlerService $dataService
|
|
|
- */
|
|
|
- $service = new OrderTrackingService();
|
|
|
- $update = [];
|
|
|
- $update[] = ['id', 'order_client_code_wms'];
|
|
|
- foreach ($orderTrackings as $orderTracking) {
|
|
|
- if ($orderTracking->commodities->order ?? false) {
|
|
|
- $update = [
|
|
|
- 'id' => $orderTracking->id,
|
|
|
- 'order_client_code_wms' => $orderTracking->commodities->order->client_code
|
|
|
- ];
|
|
|
- }
|
|
|
- }
|
|
|
- if (count($update) > 1) {
|
|
|
- $service->batchUpdate($update);
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- public function deleteOrderTracking()
|
|
|
- {
|
|
|
- $deleteId_arr = [];
|
|
|
- $deleteCommoditiesId_arr = [];
|
|
|
- OrderTracking::query()->with(['commodities.package'])
|
|
|
- ->where('created_at', '!=', '0000-00-00 00:00:00')
|
|
|
- ->chunkById('200', function ($orderTrackings) use (&$deleteId_arr, &$deleteCommoditiesId_arr) {
|
|
|
- $deleteIds = [];
|
|
|
- $deleteCommoditiesId = [];
|
|
|
- foreach ($orderTrackings as $orderTracking) {
|
|
|
- if (!($orderTracking->commodities->package ?? false)) {
|
|
|
- $deleteIds[] = $orderTracking->id;
|
|
|
- if ($orderTracking->commodities) {
|
|
|
- $deleteCommoditiesId[] = $orderTracking->commodities->id;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- if ($deleteIds) {
|
|
|
- $deleteId_arr[] = $deleteIds;
|
|
|
- $deleteCommoditiesId_arr[] = $deleteCommoditiesId;
|
|
|
- OrderTracking::query()->whereIn('id', $deleteIds)->delete();
|
|
|
- OrderPackageCommodities::query()->whereIn('id', $deleteCommoditiesId)->delete();
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
public function updateRejectBillCheckedStatus()
|
|
|
{
|
|
|
$time = Carbon::parse("2021-01-22 00:00:00")->subDays(15)->toDateTimeString();
|
|
|
@@ -1168,60 +934,7 @@ class TestController extends Controller
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public function clearCancelledOrder()
|
|
|
- {
|
|
|
- $wave_nos = ['W210129000248', 'W210202000216', 'W210202000251', 'W210202000216', 'W210202000282'];
|
|
|
- $order_nos = ['SO210129004112', 'SO210202003333', 'SO210202003333', 'SO210202003236', 'SO210202003247', 'SO210202003719'];
|
|
|
- try {
|
|
|
- OracleDOCWaveDetails::query()->whereIn('WaveNo', $wave_nos)->whereIn('OrderNo', $order_nos)->delete();
|
|
|
- app('LogService')->log(__CLASS__, __METHOD__, 'Delete OracleDOCWaveDetails' . ' ' . json_encode($order_nos) . json_encode($wave_nos));
|
|
|
- } catch (Exception $e) {
|
|
|
- app('LogService')->log(__CLASS__, __METHOD__, 'Error clearCancelledOrder' . json_encode($order_nos) . json_encode($wave_nos));
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public function syncOrderByWaveNo(Request $request)
|
|
|
- {
|
|
|
- $input = $request->input('wave');
|
|
|
- if (!$input) {
|
|
|
- echo 'no wave code!';
|
|
|
- } else {
|
|
|
- echo 'syncing ' . $input;
|
|
|
- return;
|
|
|
- }
|
|
|
- $oracleDOCOrderHeaderService = new OracleDOCOrderHeaderService();
|
|
|
- $orderService = new OrderService();
|
|
|
- $waveNos = [$input];
|
|
|
- $orderHeaders = OracleDOCOrderHeader::query()
|
|
|
- ->selectRaw(implode(',', OracleDOCOrderHeaderService::$columns))
|
|
|
- ->whereIn('WaveNo', $waveNos)
|
|
|
- ->get();
|
|
|
- $orderHeaderList = $orderHeaders->chunk(2000);
|
|
|
- foreach ($orderHeaderList as $item) {
|
|
|
- $item = $oracleDOCOrderHeaderService->loadMissing($item);
|
|
|
-// $last_order = $item->first(); // 时间点靠后的
|
|
|
-// $newest_orders = $item->where('addtime',$last_order->addtime);
|
|
|
- if (count($orderHeaders) > 0) {
|
|
|
- $orderService->syncOrder($item); // 同步订单
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
|
|
|
- public function syncOrderByWaveNo2(Request $request)
|
|
|
- {
|
|
|
- $oracleDOCOrderHeaderService = new OracleDOCOrderHeaderService();
|
|
|
- $orderService = new OrderService();
|
|
|
- $waveNos = ['W210220000010', 'W210220000009'];
|
|
|
- $orderHeaders = OracleDOCOrderHeader::query()
|
|
|
- ->selectRaw(implode(',', OracleDOCOrderHeaderService::$columns))
|
|
|
- ->whereIn('WaveNo', $waveNos)
|
|
|
- ->get();
|
|
|
- $orderHeaderList = $orderHeaders->chunk(2000);
|
|
|
- foreach ($orderHeaderList as $item) {
|
|
|
- $item = $oracleDOCOrderHeaderService->loadMissing($item);
|
|
|
- $orderService->syncOrder($item);
|
|
|
- }
|
|
|
- }
|
|
|
|
|
|
public function updateLaborReport()
|
|
|
{
|
|
|
@@ -1252,13 +965,4 @@ class TestController extends Controller
|
|
|
->get();
|
|
|
dd($procurementQuotations->toJson());
|
|
|
}
|
|
|
-
|
|
|
- public function syncOrdersHeader()
|
|
|
- {
|
|
|
- $service =new OracleDOCOrderHeaderService();
|
|
|
- $orderService = new OrderService();
|
|
|
- $edit_date = "2021-03-14 22:04:30";
|
|
|
- $syncOrderHeader = $service->getQuery()->where('editTime',">=",$edit_date)->whereNotIn("SOStatus",["90","99"])->get();
|
|
|
- $orderService->syncOrder($syncOrderHeader);
|
|
|
- }
|
|
|
}
|