|
|
@@ -19,7 +19,6 @@ use App\OracleActAllocationDetails;
|
|
|
use App\OracleDOCOrderHeader;
|
|
|
use App\OracleDocOrderPackingSummary;
|
|
|
use App\OracleDOCWaveDetails;
|
|
|
-use App\OracleDOCWaveHeader;
|
|
|
use App\Order;
|
|
|
use App\OrderBin;
|
|
|
use App\OrderCommodity;
|
|
|
@@ -35,6 +34,7 @@ use App\ProcessStatistic;
|
|
|
use App\RejectedBill;
|
|
|
use App\RejectedBillItem;
|
|
|
use App\Services\CacheService;
|
|
|
+use App\Services\CommodityService;
|
|
|
use App\Services\common\BatchUpdateService;
|
|
|
use App\Services\common\DataHandlerService;
|
|
|
use App\Services\DocWaveHeaderService;
|
|
|
@@ -52,6 +52,7 @@ use App\Services\OwnerService;
|
|
|
use App\Services\ShopService;
|
|
|
use App\Services\StoreService;
|
|
|
use App\Services\WarehouseService;
|
|
|
+use App\Store;
|
|
|
use App\StoreCheckingReceiveItem;
|
|
|
use App\User;
|
|
|
use App\Warehouse;
|
|
|
@@ -82,49 +83,39 @@ class TestController extends Controller
|
|
|
{
|
|
|
return call_user_func([$this, $method], $request);
|
|
|
}
|
|
|
- public function updateInventory(){
|
|
|
- $inventoryAccounts=InventoryAccount::query()->get();
|
|
|
+
|
|
|
+ public function updateInventory()
|
|
|
+ {
|
|
|
+ $inventoryAccounts = InventoryAccount::query()->get();
|
|
|
$updateParams = [[
|
|
|
- 'id','processed','ignored','updated_at'
|
|
|
+ 'id', 'processed', 'ignored', 'updated_at'
|
|
|
]];
|
|
|
- $updated_at=Carbon::now()->toDateTimeString();
|
|
|
- foreach ($inventoryAccounts as $inventoryAccount){
|
|
|
- if ($inventoryAccount->getIgnoredAmount()>0){
|
|
|
+ $updated_at = Carbon::now()->toDateTimeString();
|
|
|
+ foreach ($inventoryAccounts as $inventoryAccount) {
|
|
|
+ if ($inventoryAccount->getIgnoredAmount() > 0) {
|
|
|
$updateParams[] = [
|
|
|
- 'id'=>$inventoryAccount->id,
|
|
|
- 'processed'=>$inventoryAccount->getProcessedAmount(),
|
|
|
+ 'id' => $inventoryAccount->id,
|
|
|
+ 'processed' => $inventoryAccount->getProcessedAmount(),
|
|
|
'ignored' => $inventoryAccount->getIgnoredAmount(),
|
|
|
- 'updated_at'=>$updated_at,
|
|
|
+ 'updated_at' => $updated_at,
|
|
|
];
|
|
|
}
|
|
|
}
|
|
|
- if(count($updateParams) > 1){
|
|
|
- app(BatchUpdateService::class)->batchUpdate('inventory_accounts',$updateParams);
|
|
|
+ if (count($updateParams) > 1) {
|
|
|
+ app(BatchUpdateService::class)->batchUpdate('inventory_accounts', $updateParams);
|
|
|
}
|
|
|
}
|
|
|
- public function zzd()
|
|
|
- {
|
|
|
- $a = DB::connection("oracle")->select(DB::raw("select * from DOC_WAVE_DETAILS where WAVENO = 'W201210000112'"));
|
|
|
- $str="";
|
|
|
- $a = array_column($a,"orderno");
|
|
|
- foreach ($a as $t){
|
|
|
- $str.="'".$t."',";
|
|
|
- }
|
|
|
- dd($str);
|
|
|
- $str = rtrim($str,",");
|
|
|
- $c = DB::connection("oracle")->select(DB::raw("select SUM(qtyordered) s from DOC_ORDER_DETAILS where ORDERNO IN (".$str.")"));
|
|
|
- dd($c);
|
|
|
- }
|
|
|
|
|
|
- public function mergeCarrier(){
|
|
|
+ public function mergeCarrier()
|
|
|
+ {
|
|
|
$carriers = Carrier::query()->get();
|
|
|
$logistics = [];
|
|
|
$map = [];
|
|
|
- foreach ($carriers as $carrier){
|
|
|
+ foreach ($carriers as $carrier) {
|
|
|
$map[$carrier->name] = $carrier->id;
|
|
|
- $lo = Logistic::query()->where("name",$carrier->name)->first();
|
|
|
- if ($lo){
|
|
|
- if ($lo->type == '快递'){
|
|
|
+ $lo = Logistic::query()->where("name", $carrier->name)->first();
|
|
|
+ if ($lo) {
|
|
|
+ if ($lo->type == '快递') {
|
|
|
// $lo->update(["type"=>"全部"]);$lo->save();
|
|
|
}
|
|
|
continue;
|
|
|
@@ -132,64 +123,68 @@ class TestController extends Controller
|
|
|
$logistics[] = [
|
|
|
"name" => $carrier->name,
|
|
|
'mobile' => $carrier->mobile,
|
|
|
- 'delivery_fee'=> $carrier->delivery_fee,
|
|
|
- 'remark'=> $carrier->remark,
|
|
|
+ 'delivery_fee' => $carrier->delivery_fee,
|
|
|
+ 'remark' => $carrier->remark,
|
|
|
"type" => "物流"
|
|
|
];
|
|
|
}
|
|
|
Logistic::query()->insert($logistics);
|
|
|
- $ls = Logistic::query()->where("type","物流")->get();
|
|
|
+ $ls = Logistic::query()->where("type", "物流")->get();
|
|
|
$result = [];
|
|
|
- foreach ($ls as $l)
|
|
|
- {
|
|
|
- if (isset($map[$l->name]))$result[$map[$l->name]] = $l->id;
|
|
|
+ foreach ($ls as $l) {
|
|
|
+ if (isset($map[$l->name])) $result[$map[$l->name]] = $l->id;
|
|
|
}
|
|
|
- LogService::log(__METHOD__,"同步承运商",json_encode($result));
|
|
|
- foreach ($result as $tag => $val){
|
|
|
- Waybill::query()->where("logistic_id",$tag)->update([
|
|
|
+ LogService::log(__METHOD__, "同步承运商", json_encode($result));
|
|
|
+ foreach ($result as $tag => $val) {
|
|
|
+ Waybill::query()->where("logistic_id", $tag)->update([
|
|
|
"logistic_id" => $val
|
|
|
]);
|
|
|
- WaybillPriceModel::query()->where("logistic_id",$tag)->update([
|
|
|
+ WaybillPriceModel::query()->where("logistic_id", $tag)->update([
|
|
|
"logistic_id" => $val
|
|
|
]);
|
|
|
- DB::table("logistic_user")->where("logistic_id",$tag)->update([
|
|
|
+ DB::table("logistic_user")->where("logistic_id", $tag)->update([
|
|
|
"logistic_id" => $val
|
|
|
]);
|
|
|
}
|
|
|
}
|
|
|
- public function updateLaborRemark(){
|
|
|
- $laborReports=LaborReport::query()->with(['remarks'=>function($query){
|
|
|
+
|
|
|
+ public function test4()
|
|
|
+ {
|
|
|
+ $arr = [['id' => 3], ['id' => 33],];
|
|
|
+ dd(data_get($arr, '*.id'));
|
|
|
+ }
|
|
|
+
|
|
|
+ public function t($a)
|
|
|
+ {
|
|
|
+ $r = new \ReflectionClass('App\Http\Controllers\UnitsController');
|
|
|
+ dd($r->getMethods(), $r->getConstants());
|
|
|
+ }
|
|
|
+
|
|
|
+ public function updateLaborRemark()
|
|
|
+ {
|
|
|
+ $laborReports = LaborReport::query()->with(['remarks' => function ($query) {
|
|
|
return $query->whereNotNull('mark');
|
|
|
}])->get();
|
|
|
$updateParams = [[
|
|
|
- 'id','remark','updated_at'
|
|
|
+ 'id', 'remark', 'updated_at'
|
|
|
]];
|
|
|
- $updated_at=Carbon::now()->toDateTimeString();
|
|
|
- foreach ($laborReports as $laborReport){
|
|
|
- if ($laborReport->remarks){
|
|
|
+ $updated_at = Carbon::now()->toDateTimeString();
|
|
|
+ foreach ($laborReports as $laborReport) {
|
|
|
+ if ($laborReport->remarks) {
|
|
|
$updateParams[] = [
|
|
|
- 'id'=>$laborReport->id,
|
|
|
- 'remark'=>$laborReport->remarks->mark,
|
|
|
- 'updated_at'=>$updated_at,
|
|
|
+ 'id' => $laborReport->id,
|
|
|
+ 'remark' => $laborReport->remarks->mark,
|
|
|
+ 'updated_at' => $updated_at,
|
|
|
];
|
|
|
}
|
|
|
}
|
|
|
- if(count($updateParams) > 1){
|
|
|
- app(BatchUpdateService::class)->batchUpdate('labor_reports',$updateParams);
|
|
|
+ if (count($updateParams) > 1) {
|
|
|
+ app(BatchUpdateService::class)->batchUpdate('labor_reports', $updateParams);
|
|
|
}
|
|
|
}
|
|
|
- public function test2(){
|
|
|
- $b = Logistic::query()->first();
|
|
|
- $a = OrderPackage::query()->with("order")->first();
|
|
|
- $a->bulk = 521;
|
|
|
- $a->save();
|
|
|
- if (!$a->order) $a->order = new Order();
|
|
|
- dd($a);
|
|
|
- if (!$a->order->logistic)$a->order->logistic = $b;
|
|
|
- dd($a->order->logistic);
|
|
|
- dd($a);
|
|
|
- $a->save();
|
|
|
- dd($a);
|
|
|
+
|
|
|
+ public function test2()
|
|
|
+ {
|
|
|
}
|
|
|
|
|
|
function packageFromLog(Request $request)
|
|
|
@@ -218,6 +213,15 @@ class TestController extends Controller
|
|
|
});
|
|
|
dd($uploaded . '/' . $count);
|
|
|
}
|
|
|
+
|
|
|
+ function wmsSql()
|
|
|
+ {
|
|
|
+ $owner = Owner::first();
|
|
|
+// $owner['phone_number'] ?? $owner['phone_number'] = '31115';
|
|
|
+// $owner->update();
|
|
|
+ dd($owner);
|
|
|
+ }
|
|
|
+
|
|
|
function issues()
|
|
|
{
|
|
|
/** @var OrderPackageService $orderPackageService */
|
|
|
@@ -230,16 +234,30 @@ class TestController extends Controller
|
|
|
$orderPackageService->createdByOrder($item);
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ function t2(Request $request)
|
|
|
+ { //x $packagesBatch=Package::where('batch_number',$batch_number)->first();
|
|
|
+
|
|
|
+
|
|
|
+ $inventoryCompareService = new InventoryCompareService();
|
|
|
+ echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
|
|
|
+ echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
|
|
|
+ echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
|
|
|
+ echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
|
|
|
+ }
|
|
|
+
|
|
|
function tlog(Request $request)
|
|
|
{
|
|
|
- app('LogService')->log(__METHOD__,'cczdelme'.__FUNCTION__,json_encode($request->all()),null);
|
|
|
+ app('LogService')->log(__METHOD__, 'cczdelme' . __FUNCTION__, json_encode($request->all()), null);
|
|
|
}
|
|
|
+
|
|
|
function setCache(Request $request)
|
|
|
{
|
|
|
$today = now();
|
|
|
Cache::put('storedTest', $today);
|
|
|
return "cacheing:'$today'<script>localStorage.setItem('storedTest','{$today}')</script>";
|
|
|
}
|
|
|
+
|
|
|
function getCache(Request $request)
|
|
|
{
|
|
|
$cache = Cache::get('storedTest');
|
|
|
@@ -270,8 +288,13 @@ class TestController extends Controller
|
|
|
oci_bind_by_name($stmt, ':IN_UserID', $IN_UserID);
|
|
|
oci_bind_by_name($stmt, ':OUT_Return_Code', $OUT_Return_Code);
|
|
|
return oci_execute($stmt);
|
|
|
+
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
function packageT(Request $request)
|
|
|
{
|
|
|
$package = Package::where('created_at', '<', '2020-07-08')->whereNotNull('logistic_number')->first();
|
|
|
@@ -567,56 +590,57 @@ class TestController extends Controller
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public function test5(){
|
|
|
- ini_set('max_execution_time',2500);
|
|
|
- ini_set('memory_limit','1526M');
|
|
|
+ public function test5()
|
|
|
+ {
|
|
|
+ ini_set('max_execution_time', 2500);
|
|
|
+ ini_set('memory_limit', '1526M');
|
|
|
//清理冗余条码
|
|
|
// $this->cleanBarcode();
|
|
|
|
|
|
- while(true){
|
|
|
+ while (true) {
|
|
|
$toDay = Carbon::now();
|
|
|
$skus = DB::select(DB::raw('select sku from commodities group by sku,owner_id having count(*)>1 limit 500 '));
|
|
|
$skus = array_column($skus,'sku');
|
|
|
|
|
|
- $commodities = Commodity::query()->with('barcodes')->whereNotNull('owner_id')->whereIn('sku',$skus)->get();
|
|
|
+ $commodities = Commodity::query()->with('barcodes')->whereNotNull('owner_id')->whereIn('sku', $skus)->get();
|
|
|
|
|
|
|
|
|
- if (count($commodities) < 1)return "SUCCESS";
|
|
|
+ if (count($commodities) < 1) return "SUCCESS";
|
|
|
$commodityMap = [];
|
|
|
$commodityDel = [];
|
|
|
$commodityTag = [];
|
|
|
$commodityBar = [];
|
|
|
$createBarcodes = [];
|
|
|
$logs = [];
|
|
|
- foreach ($commodities as $commodity){
|
|
|
- if ($commodityMap[$commodity->sku.'_'.$commodity->owner_id] ?? false){
|
|
|
- $codes = $commodity->barcodes ? array_column($commodity->barcodes->toArray(),'code') : [];
|
|
|
+ foreach ($commodities as $commodity) {
|
|
|
+ if ($commodityMap[$commodity->sku . '_' . $commodity->owner_id] ?? false) {
|
|
|
+ $codes = $commodity->barcodes ? array_column($commodity->barcodes->toArray(), 'code') : [];
|
|
|
$logs[] = [
|
|
|
'id' => $commodity->id,
|
|
|
'sku' => $commodity->sku,
|
|
|
- 'owner_id'=>$commodity->owner_id,
|
|
|
- 'code'=>$codes,
|
|
|
+ 'owner_id' => $commodity->owner_id,
|
|
|
+ 'code' => $codes,
|
|
|
];
|
|
|
$commodityDel[] = $commodity->id;
|
|
|
- $commodityTag[$commodity->id] = $commodityMap[$commodity->sku.'_'.$commodity->owner_id];
|
|
|
+ $commodityTag[$commodity->id] = $commodityMap[$commodity->sku . '_' . $commodity->owner_id];
|
|
|
|
|
|
- $arr = array_diff($codes,$commodityBar[$commodity->sku.'_'.$commodity->owner_id]);
|
|
|
- foreach ($arr as $code){
|
|
|
- if (!$code)continue;
|
|
|
+ $arr = array_diff($codes, $commodityBar[$commodity->sku . '_' . $commodity->owner_id]);
|
|
|
+ foreach ($arr as $code) {
|
|
|
+ if (!$code) continue;
|
|
|
$createBarcodes[] = [
|
|
|
'code' => $code,
|
|
|
- 'commodity_id' => $commodityMap[$commodity->sku.'_'.$commodity->owner_id],
|
|
|
+ 'commodity_id' => $commodityMap[$commodity->sku . '_' . $commodity->owner_id],
|
|
|
'created_at' => $toDay,
|
|
|
];
|
|
|
}
|
|
|
- }else{
|
|
|
- $commodityMap[$commodity->sku.'_'.$commodity->owner_id] = $commodity->id;
|
|
|
- $commodityBar[$commodity->sku.'_'.$commodity->owner_id] = $commodity->barcodes ? array_column($commodity->barcodes->toArray(),'code') : [];
|
|
|
+ } else {
|
|
|
+ $commodityMap[$commodity->sku . '_' . $commodity->owner_id] = $commodity->id;
|
|
|
+ $commodityBar[$commodity->sku . '_' . $commodity->owner_id] = $commodity->barcodes ? array_column($commodity->barcodes->toArray(), 'code') : [];
|
|
|
}
|
|
|
}
|
|
|
- dd($commodityMap,$commodityDel,$commodityTag);
|
|
|
- app('LogService')->log(__METHOD__,'清理商品',json_encode($logs,JSON_UNESCAPED_UNICODE));
|
|
|
- app('LogService')->log(__METHOD__,'重新分配商品',json_encode($commodityTag,JSON_UNESCAPED_UNICODE));
|
|
|
+ dd($commodityMap, $commodityDel, $commodityTag);
|
|
|
+ app('LogService')->log(__METHOD__, '清理商品', json_encode($logs, JSON_UNESCAPED_UNICODE));
|
|
|
+ app('LogService')->log(__METHOD__, '重新分配商品', json_encode($commodityTag, JSON_UNESCAPED_UNICODE));
|
|
|
|
|
|
app('InventoryAccountMissionService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新库存盘点任务
|
|
|
app('InventoryCompareService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新库存对比
|
|
|
@@ -625,13 +649,14 @@ class TestController extends Controller
|
|
|
app('StoreCheckingReceiveItemService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新入库盘收一体
|
|
|
app('OrderPackageCommoditiesService')->batchUpdateItself('commodity_id', $commodityTag);//批量更新订单商品
|
|
|
|
|
|
- app('LogService')->log(__METHOD__,'删除商品与对应条码',json_encode($commodityDel,JSON_UNESCAPED_UNICODE));
|
|
|
- CommodityBarcode::query()->whereIn('commodity_id',$commodityDel)->delete();
|
|
|
+ app('LogService')->log(__METHOD__, '删除商品与对应条码', json_encode($commodityDel, JSON_UNESCAPED_UNICODE));
|
|
|
+ CommodityBarcode::query()->whereIn('commodity_id', $commodityDel)->delete();
|
|
|
Commodity::destroy($commodityDel);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private function cleanBarcode(){
|
|
|
+ private function cleanBarcode()
|
|
|
+ {
|
|
|
|
|
|
$logCommodityBarcodes = CommodityBarcode::query()->where('code', "")->get();
|
|
|
if (count($logCommodityBarcodes) > 0) app('LogService')->log(__METHOD__, "纠正商品-删除空条码", json_encode($logCommodityBarcodes, JSON_UNESCAPED_UNICODE));
|
|
|
@@ -652,30 +677,31 @@ where (c.code,c.commodity_id) in (select code,commodity_id from commodity_barcod
|
|
|
CommodityBarcode::destroy($barcodeDelete);
|
|
|
}
|
|
|
|
|
|
- private function multiCodes(){
|
|
|
+ private function multiCodes()
|
|
|
+ {
|
|
|
|
|
|
- $barcode='BG10B1014C002100';
|
|
|
- $commodity=Commodity::whereHas('barcodes', function (Builder $query)use($barcode){
|
|
|
- $query->where('code',$barcode);
|
|
|
- })->where('owner_id',4)->first();
|
|
|
+ $barcode = 'BG10B1014C002100';
|
|
|
+ $commodity = Commodity::whereHas('barcodes', function (Builder $query) use ($barcode) {
|
|
|
+ $query->where('code', $barcode);
|
|
|
+ })->where('owner_id', 4)->first();
|
|
|
$codes = $commodity->barcodes->map(function ($barcode) {
|
|
|
- return $barcode->code??'';
|
|
|
+ return $barcode->code ?? '';
|
|
|
});
|
|
|
- foreach($codes as $code){
|
|
|
- $commodity=Commodity::whereHas('barcodes', function (Builder $query)use($barcode){
|
|
|
- $query->where('code',$barcode);
|
|
|
- })->where('owner_id',4)->get();
|
|
|
+ foreach ($codes as $code) {
|
|
|
+ $commodity = Commodity::whereHas('barcodes', function (Builder $query) use ($barcode) {
|
|
|
+ $query->where('code', $barcode);
|
|
|
+ })->where('owner_id', 4)->get();
|
|
|
dump($commodity);
|
|
|
}
|
|
|
die();
|
|
|
- $commodityBuilder=Commodity::query();
|
|
|
- $commodityBuilder->where('owner_id',4)->first();
|
|
|
- $commodityBuilder->whereHas('barcodes', function (Builder $query)use($barcode,$codes){
|
|
|
- foreach($codes as $code){
|
|
|
- $query->orWhere('code',$code);
|
|
|
- }
|
|
|
- });
|
|
|
- dd($commodity, $codes,$commodityBuilder->get());
|
|
|
+ $commodityBuilder = Commodity::query();
|
|
|
+ $commodityBuilder->where('owner_id', 4)->first();
|
|
|
+ $commodityBuilder->whereHas('barcodes', function (Builder $query) use ($barcode, $codes) {
|
|
|
+ foreach ($codes as $code) {
|
|
|
+ $query->orWhere('code', $code);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ dd($commodity, $codes, $commodityBuilder->get());
|
|
|
}
|
|
|
|
|
|
public function correctCommodity()
|
|
|
@@ -742,7 +768,7 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
}
|
|
|
$updateCommodities[$del->commodity_id] = $target->commodity_id;
|
|
|
}
|
|
|
- if (count($updateCommodities) > 0){
|
|
|
+ if (count($updateCommodities) > 0) {
|
|
|
app('InventoryAccountMissionService')->batchUpdateItself('commodity_id', $updateCommodities);//批量更新库存盘点任务
|
|
|
app('InventoryCompareService')->batchUpdateItself('commodity_id', $updateCommodities);//批量更新库存对比
|
|
|
app('InventoryDailyLogService')->batchUpdateItself('commodity_id', $updateCommodities);//批量更新库存每日记录
|
|
|
@@ -764,6 +790,7 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
|
|
|
Commodity::destroy($deleteCommodities);
|
|
|
}
|
|
|
+
|
|
|
/*1*/
|
|
|
function socket(Request $request)
|
|
|
{/**/
|
|
|
@@ -821,27 +848,50 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
}
|
|
|
|
|
|
|
|
|
+ public function test11()
|
|
|
+ {
|
|
|
+ $rejectedBills = RejectedBill::query()
|
|
|
+ ->where('created_at', '>=', '2020-11-10 18:00:22')
|
|
|
+ ->where('created_at', '<=', '2020-11-11 00:00:00')
|
|
|
+ ->get();
|
|
|
+ $update = [['id', 'logistic_number']];
|
|
|
+ $rejectedBills->each(function ($rejectedBill) use (&$update) {
|
|
|
+ if ($rejectedBill->logistic_number == '原单退回') {
|
|
|
+ $details = OracleActAllocationDetails::query()->with('oracleDocOrderHeader')->whereHas('oracleDocOrderHeader', function ($query) use ($rejectedBill) {
|
|
|
+ $query->where('SOReference1', $rejectedBill->order_number);
|
|
|
+ })->get()->groupBy('picktotraceid');
|
|
|
+ if ($details->count() == 1) {
|
|
|
+ $update[] = ['id' => $rejectedBill->id, 'logistic_number' => $rejectedBill->logistic_number_return];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+ app('RejectedBillService')->batchUpdate($update);
|
|
|
+ }
|
|
|
+
|
|
|
public function output()
|
|
|
{
|
|
|
/** @var CacheService $cacheService */
|
|
|
$cacheService = app('CacheService');
|
|
|
- $authorities=$cacheService->getOrExecute('userxx',function (){
|
|
|
+ $authorities = $cacheService->getOrExecute('userxx', function () {
|
|
|
return Authority::with('roles')->get();
|
|
|
});
|
|
|
dd($authorities);
|
|
|
}
|
|
|
+
|
|
|
public function output2()
|
|
|
{
|
|
|
dump(Cache::get('aa'));
|
|
|
Cache::put('aa', '2223', 5);
|
|
|
}
|
|
|
+
|
|
|
public function usage()
|
|
|
{
|
|
|
dd(Request::all());
|
|
|
}
|
|
|
+
|
|
|
public function relating()
|
|
|
{
|
|
|
- dd(OrderIssue::query()->where('id',182)->paginate()->total());
|
|
|
+ dd(OrderIssue::query()->where('id', 182)->paginate()->total());
|
|
|
}
|
|
|
|
|
|
public function updateOrdersWarehouse()
|
|
|
@@ -857,10 +907,11 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
$warehouse = Warehouse::query()->get();
|
|
|
$warehouse_map = $dataHandlerService->dataHeader(['code'], $warehouse);
|
|
|
for ($i = 0; $i < $count; $i += $page) {
|
|
|
- $min = $i;$max = $i + $page;
|
|
|
+ $min = $i;
|
|
|
+ $max = $i + $page;
|
|
|
$orders = Order::query()->where('id', '>=', $min)->where('id', '<=', $max)->get();
|
|
|
$orderNos = array_diff(array_unique(data_get($orders, '*.code')), ['', ' ', '*', null]);
|
|
|
- if (count($orderNos)==0) continue;
|
|
|
+ if (count($orderNos) == 0) continue;
|
|
|
/** @var Collection $orderHeaders */
|
|
|
$orderHeaders = OracleDOCOrderHeader::query()->whereIn('orderno', $orderNos)->get();
|
|
|
if ($orderHeaders->count() == 0) continue;
|
|
|
@@ -886,54 +937,57 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
public function syncSendOrder()
|
|
|
{
|
|
|
$order_issues = OrderIssue::query()->whereNotNull('second_client_no')->get();
|
|
|
- $client_nos = data_get($order_issues,'*.second_client_no');
|
|
|
- $orderHeaders = OracleDOCOrderHeader::query()->selectRaw(implode(',',OracleDOCOrderHeaderService::$columns))
|
|
|
- ->whereIn('SOReference1',$client_nos)
|
|
|
- ->with(['oracleBASCustomer'=>function($query){
|
|
|
+ $client_nos = data_get($order_issues, '*.second_client_no');
|
|
|
+ $orderHeaders = OracleDOCOrderHeader::query()->selectRaw(implode(',', OracleDOCOrderHeaderService::$columns))
|
|
|
+ ->whereIn('SOReference1', $client_nos)
|
|
|
+ ->with(['oracleBASCustomer' => function ($query) {
|
|
|
$query->selectRaw('BAS_CUSTOMER.CustomerID,BAS_CUSTOMER.Customer_Type,BAS_CUSTOMER.Descr_C,BAS_CUSTOMER.Active_Flag');
|
|
|
- },'oracleDOCOrderDetails'=>function($query){
|
|
|
+ }, 'oracleDOCOrderDetails' => function ($query) {
|
|
|
$query->selectRaw('doc_order_details.orderNo,doc_order_details.customerid,doc_order_details.sku,doc_order_details.QtyOrdered');
|
|
|
- }, 'actAllocationDetails'=>function($query){
|
|
|
+ }, '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');
|
|
|
- },'oracleBASCode'=>function($query){
|
|
|
+ }, 'oracleBASCode' => function ($query) {
|
|
|
$query->selectRaw('BAS_Codes.CodeID,BAS_Codes.CodeName_C,BAS_Codes.Code');
|
|
|
}])
|
|
|
->get();
|
|
|
$service = app('OrderIssueService');
|
|
|
$service->updateByWmsOrders($orderHeaders);
|
|
|
}
|
|
|
+
|
|
|
public function testCollectMethod()
|
|
|
{
|
|
|
- $startDate=Carbon::parse('2020-11-11 23:59:59')->subSeconds(65)->format('Y-m-d H:i:s');
|
|
|
- $asnHerders=app(OracleDocAsnHerderService::class)->getWmsAsnOnStartDateCreate($startDate);
|
|
|
- if ($asnHerders->isEmpty())return null;
|
|
|
+ $startDate = Carbon::parse('2020-11-11 23:59:59')->subSeconds(65)->format('Y-m-d H:i:s');
|
|
|
+ $asnHerders = app(OracleDocAsnHerderService::class)->getWmsAsnOnStartDateCreate($startDate);
|
|
|
+ if ($asnHerders->isEmpty()) return null;
|
|
|
/**
|
|
|
* @var OwnerService $ownerService
|
|
|
* @var WarehouseService $wareHouseService
|
|
|
*/
|
|
|
$ownerService = app(OwnerService::class);
|
|
|
- $owners=$ownerService->getByWmsOrders($asnHerders);
|
|
|
- $wareHouseService=app(WarehouseService::class);
|
|
|
- $warehouses=$wareHouseService->getByWms($asnHerders);
|
|
|
+ $owners = $ownerService->getByWmsOrders($asnHerders);
|
|
|
+ $wareHouseService = app(WarehouseService::class);
|
|
|
+ $warehouses = $wareHouseService->getByWms($asnHerders);
|
|
|
foreach ($owners as $owner) {
|
|
|
$owners_code_map[$owner->code] = $owner;
|
|
|
}
|
|
|
foreach ($warehouses as $warehouse) {
|
|
|
$warehouses_code_map[$warehouse->code] = $warehouse;
|
|
|
}
|
|
|
- var_dump('createStoreParam_start',Carbon::now());
|
|
|
- $params=app(StoreService::class)->getParamsByAsnHeader($asnHerders,$owners_code_map,$warehouses_code_map);
|
|
|
- var_dump('createStoreParam_end',Carbon::now());
|
|
|
+ var_dump('createStoreParam_start', Carbon::now());
|
|
|
+ $params = app(StoreService::class)->getParamsByAsnHeader($asnHerders, $owners_code_map, $warehouses_code_map);
|
|
|
+ var_dump('createStoreParam_end', Carbon::now());
|
|
|
|
|
|
- var_dump('insertStore_start',Carbon::now());
|
|
|
- if(count($params)> 0){
|
|
|
+ var_dump('insertStore_start', Carbon::now());
|
|
|
+ if (count($params) > 0) {
|
|
|
//app(StoreService::class)->insertStore($params);
|
|
|
DB::table('stores')->insert($params);
|
|
|
}
|
|
|
- var_dump('insertStore_end',Carbon::now());
|
|
|
+ var_dump('insertStore_end', Carbon::now());
|
|
|
}
|
|
|
- public function testMethodSecond(){
|
|
|
- $param=[
|
|
|
+
|
|
|
+ public function testMethodSecond()
|
|
|
+ {
|
|
|
+ $param = [
|
|
|
"asn_code" => "ASN2011120516",
|
|
|
"warehouse_id" => 2,
|
|
|
"owner_id" => 35,
|
|
|
@@ -942,11 +996,19 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
"remark" => null,
|
|
|
"created_at" => "2020-11-12 14:12:42",
|
|
|
"updated_at" => "2020-11-12 14:12:42",
|
|
|
- ];
|
|
|
- var_dump('start',Carbon::now());
|
|
|
+ ];
|
|
|
+ var_dump('start', Carbon::now());
|
|
|
//Store::query()->insert($param);
|
|
|
app(StoreService::class)->insertStore($param);
|
|
|
- var_dump('end',Carbon::now());
|
|
|
+ var_dump('end', Carbon::now());
|
|
|
+ }
|
|
|
+
|
|
|
+ public function testSyncAsn()
|
|
|
+ {
|
|
|
+ dump('start'.(string)Carbon::now());
|
|
|
+ app(StoreService::class)->storeCreateByWms();
|
|
|
+ app(StoreService::class)->storeUpdateByWms();
|
|
|
+ dump('end'.(string)Carbon::now());
|
|
|
}
|
|
|
|
|
|
public function changeOrder()
|
|
|
@@ -954,19 +1016,19 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
/**
|
|
|
* @var OrderService $orderService
|
|
|
*/
|
|
|
- $carbon =Carbon::now()->subMinutes(30);
|
|
|
- var_dump('$orderHeader',new Carbon());
|
|
|
- $orderHeader_start = OracleDOCOrderHeader::query()->selectRaw(implode(',',OracleDOCOrderHeaderService::$columns))
|
|
|
- ->with(['oracleBASCustomer'=>function($query){
|
|
|
+ $carbon = Carbon::now()->subMinutes(30);
|
|
|
+ var_dump('$orderHeader', new Carbon());
|
|
|
+ $orderHeader_start = 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){
|
|
|
+ }, 'oracleDOCOrderDetails' => function ($query) {
|
|
|
$query->selectRaw('doc_order_details.orderNo,doc_order_details.customerid,doc_order_details.sku,doc_order_details.QtyOrdered');
|
|
|
- }, 'actAllocationDetails'=>function($query){
|
|
|
+ }, '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');
|
|
|
- },'oracleBASCode'=>function($query){
|
|
|
+ }, 'oracleBASCode' => function ($query) {
|
|
|
$query->selectRaw('BAS_Codes.CodeID,BAS_Codes.CodeName_C,BAS_Codes.Code');
|
|
|
}])
|
|
|
- ->where('DOC_Order_Header.addTime','>=',$carbon)
|
|
|
+ ->where('DOC_Order_Header.addTime', '>=', $carbon)
|
|
|
// ->where('DOC_Order_Header.editTime','>=',$carbon)
|
|
|
->get();
|
|
|
var_dump((string)Carbon::now());
|
|
|
@@ -978,88 +1040,109 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
// orderService getCreateOrderModelsByWMSOrderHeaders
|
|
|
}
|
|
|
|
|
|
- public function testOrderPackages(){
|
|
|
+ public function testOrderPackages()
|
|
|
+ {
|
|
|
$batch_number = 'W201114000104';
|
|
|
$weight = 0.3;
|
|
|
- OrderPackage::createPackagesFromBatchCode($batch_number,$weight);
|
|
|
+ OrderPackage::createPackagesFromBatchCode($batch_number, $weight);
|
|
|
}
|
|
|
|
|
|
- public function view(){
|
|
|
+ public function view()
|
|
|
+ {
|
|
|
return view('test');
|
|
|
}
|
|
|
|
|
|
- public function cleanOrderRepeat(){
|
|
|
+ public function tdel()
|
|
|
+ {
|
|
|
+ echo '223232323';
|
|
|
+ return 'asdfsadfsdf';
|
|
|
+ }
|
|
|
+
|
|
|
+ public function cleanOrderRepeat()
|
|
|
+ {
|
|
|
|
|
|
- ini_set('max_execution_time',6500);
|
|
|
- ini_set('memory_limit','1526M');
|
|
|
- for($i=0;true;$i++){
|
|
|
- $orders_repeating=Order::query()
|
|
|
+ ini_set('max_execution_time', 6500);
|
|
|
+ ini_set('memory_limit', '1526M');
|
|
|
+ for ($i = 0; true; $i++) {
|
|
|
+ $orders_repeating = Order::query()
|
|
|
->selectRaw('count(*) as count, code, id')
|
|
|
->whereNotNull('code')
|
|
|
->groupBy('code')
|
|
|
->having('count', '>', 1)
|
|
|
->limit(100)
|
|
|
->get();
|
|
|
- if($orders_repeating->count()==0)break;
|
|
|
- $orders_repeating->each(function ($order){
|
|
|
- $code_repeating=$order['code'];
|
|
|
- $orders_toCombine=Order::query()
|
|
|
- ->where('code',$code_repeating)
|
|
|
+ if ($orders_repeating->count() == 0) break;
|
|
|
+ $orders_repeating->each(function ($order) {
|
|
|
+ $code_repeating = $order['code'];
|
|
|
+ $orders_toCombine = Order::query()
|
|
|
+ ->where('code', $code_repeating)
|
|
|
->orderByDesc('updated_at')
|
|
|
->get();
|
|
|
- $orderId_unique=(function()use($orders_toCombine){
|
|
|
- $order_toLive=$orders_toCombine->first();
|
|
|
- foreach($orders_toCombine as $key=>$order_toEliminate){
|
|
|
- if($key==0)continue;
|
|
|
- if(!$order_toLive['batch_id'])$order_toLive['batch_id']=$order_toEliminate['batch_id'];
|
|
|
- if(!$order_toLive['owner_id'])$order_toLive['owner_id']=$order_toEliminate['owner_id'];
|
|
|
- if(!$order_toLive['status'])$order_toLive['status']=$order_toEliminate['status'];
|
|
|
- if(!$order_toLive['created_at'])$order_toLive['created_at']=$order_toEliminate['created_at'];
|
|
|
- if(!$order_toLive['code'])$order_toLive['code']=$order_toEliminate['code'];
|
|
|
- if(!$order_toLive['shop_id'])$order_toLive['shop_id']=$order_toEliminate['shop_id'];
|
|
|
- if(!$order_toLive['owner_id'])$order_toLive['owner_id']=$order_toEliminate['owner_id'];
|
|
|
- if(!$order_toLive['client_code'])$order_toLive['client_code']=$order_toEliminate['client_code'];
|
|
|
- if(!$order_toLive['logistic_id'])$order_toLive['logistic_id']=$order_toEliminate['logistic_id'];
|
|
|
- if(!$order_toLive['consignee_name'])$order_toLive['consignee_name']=$order_toEliminate['consignee_name'];
|
|
|
- if(!$order_toLive['consignee_phone'])$order_toLive['consignee_phone']=$order_toEliminate['consignee_phone'];
|
|
|
- if(!$order_toLive['province'])$order_toLive['province']=$order_toEliminate['province'];
|
|
|
- if(!$order_toLive['city'])$order_toLive['city']=$order_toEliminate['city'];
|
|
|
- if(!$order_toLive['district'])$order_toLive['district']=$order_toEliminate['district'];
|
|
|
- if(!$order_toLive['address'])$order_toLive['address']=$order_toEliminate['address'];
|
|
|
- if(!$order_toLive['wms_status'])$order_toLive['wms_status']=$order_toEliminate['wms_status'];
|
|
|
- if(!$order_toLive['status'])$order_toLive['status']=$order_toEliminate['status'];
|
|
|
- if(!$order_toLive['warehouse_id'])$order_toLive['warehouse_id']=$order_toEliminate['warehouse_id'];
|
|
|
- if(!$order_toLive['wms_edittime'])$order_toLive['wms_edittime']=$order_toEliminate['wms_edittime'];
|
|
|
+ $orderId_unique = (function () use ($orders_toCombine) {
|
|
|
+ $order_toLive = $orders_toCombine->first();
|
|
|
+ foreach ($orders_toCombine as $key => $order_toEliminate) {
|
|
|
+ if ($key == 0) continue;
|
|
|
+ if (!$order_toLive['batch_id']) $order_toLive['batch_id'] = $order_toEliminate['batch_id'];
|
|
|
+ if (!$order_toLive['owner_id']) $order_toLive['owner_id'] = $order_toEliminate['owner_id'];
|
|
|
+ if (!$order_toLive['status']) $order_toLive['status'] = $order_toEliminate['status'];
|
|
|
+ if (!$order_toLive['created_at']) $order_toLive['created_at'] = $order_toEliminate['created_at'];
|
|
|
+ if (!$order_toLive['code']) $order_toLive['code'] = $order_toEliminate['code'];
|
|
|
+ if (!$order_toLive['shop_id']) $order_toLive['shop_id'] = $order_toEliminate['shop_id'];
|
|
|
+ if (!$order_toLive['owner_id']) $order_toLive['owner_id'] = $order_toEliminate['owner_id'];
|
|
|
+ if (!$order_toLive['client_code']) $order_toLive['client_code'] = $order_toEliminate['client_code'];
|
|
|
+ if (!$order_toLive['logistic_id']) $order_toLive['logistic_id'] = $order_toEliminate['logistic_id'];
|
|
|
+ if (!$order_toLive['consignee_name']) $order_toLive['consignee_name'] = $order_toEliminate['consignee_name'];
|
|
|
+ if (!$order_toLive['consignee_phone']) $order_toLive['consignee_phone'] = $order_toEliminate['consignee_phone'];
|
|
|
+ if (!$order_toLive['province']) $order_toLive['province'] = $order_toEliminate['province'];
|
|
|
+ if (!$order_toLive['city']) $order_toLive['city'] = $order_toEliminate['city'];
|
|
|
+ if (!$order_toLive['district']) $order_toLive['district'] = $order_toEliminate['district'];
|
|
|
+ if (!$order_toLive['address']) $order_toLive['address'] = $order_toEliminate['address'];
|
|
|
+ if (!$order_toLive['wms_status']) $order_toLive['wms_status'] = $order_toEliminate['wms_status'];
|
|
|
+ if (!$order_toLive['status']) $order_toLive['status'] = $order_toEliminate['status'];
|
|
|
+ if (!$order_toLive['warehouse_id']) $order_toLive['warehouse_id'] = $order_toEliminate['warehouse_id'];
|
|
|
+ if (!$order_toLive['wms_edittime']) $order_toLive['wms_edittime'] = $order_toEliminate['wms_edittime'];
|
|
|
}
|
|
|
$order_toLive->save();
|
|
|
return $order_toLive['id'];
|
|
|
})();
|
|
|
- $orderIds_toRemove=(function()use($orders_toCombine){
|
|
|
+ $orderIds_toRemove = (function () use ($orders_toCombine) {
|
|
|
$orders_toCombine->shift();
|
|
|
- return $orders_toCombine->map(function($order){return $order['id'];});
|
|
|
+ return $orders_toCombine->map(function ($order) {
|
|
|
+ return $order['id'];
|
|
|
+ });
|
|
|
})();
|
|
|
- OrderPackage::query()->whereIn('order_id',$orderIds_toRemove)->update(['order_id'=>$orderId_unique]);
|
|
|
- OrderIssue::query()->whereIn('order_id',$orderIds_toRemove)->update(['order_id'=>$orderId_unique]);
|
|
|
- OrderCommodity::query()->whereIn('order_id',$orderIds_toRemove)->update(['order_id'=>$orderId_unique]);
|
|
|
- OrderBin::query()->whereIn('order_id',$orderIds_toRemove)->update(['order_id'=>$orderId_unique]);
|
|
|
+ OrderPackage::query()->whereIn('order_id', $orderIds_toRemove)->update(['order_id' => $orderId_unique]);
|
|
|
+ OrderIssue::query()->whereIn('order_id', $orderIds_toRemove)->update(['order_id' => $orderId_unique]);
|
|
|
+ OrderCommodity::query()->whereIn('order_id', $orderIds_toRemove)->update(['order_id' => $orderId_unique]);
|
|
|
+ OrderBin::query()->whereIn('order_id', $orderIds_toRemove)->update(['order_id' => $orderId_unique]);
|
|
|
Order::destroy($orderIds_toRemove);
|
|
|
- app('LogService')->log(__METHOD__,__FUNCTION__,'orders_toCombine:'.json_encode($orderIds_toRemove).'|toBe OrderId: '.json_encode($orderId_unique));
|
|
|
+ app('LogService')->log(__METHOD__, __FUNCTION__, 'orders_toCombine:' . json_encode($orderIds_toRemove) . '|toBe OrderId: ' . json_encode($orderId_unique));
|
|
|
});
|
|
|
- app('LogService')->log(__METHOD__,__FUNCTION__,'orders_repeating:'.$orders_repeating->toJson());
|
|
|
+ app('LogService')->log(__METHOD__, __FUNCTION__, 'orders_repeating:' . $orders_repeating->toJson());
|
|
|
}
|
|
|
echo $i;
|
|
|
}
|
|
|
|
|
|
+ public function orderTrackingImportTest(Request $request)
|
|
|
+ {
|
|
|
+ $file = $request->file('file');
|
|
|
+ ini_set('max_execution_time', 4000);
|
|
|
+ ini_set('memory_limit', '1024M');
|
|
|
+ $extension = $request->file()['file']->getClientOriginalExtension();
|
|
|
+ $extension[0] = strtoupper($extension[0]);
|
|
|
+ Excel::import(new OrderTrackingImport(), $request->file('file')->path(), null, $extension);
|
|
|
+ }
|
|
|
+
|
|
|
public function testImp()
|
|
|
{
|
|
|
$client_no = null;
|
|
|
$items = null;
|
|
|
- $order=(new OrderTrackingImport())->getOrder($client_no,$items);
|
|
|
- if($order['id']) echo 'yes1';
|
|
|
+ $order = (new OrderTrackingImport())->getOrder($client_no, $items);
|
|
|
+ if ($order['id']) echo 'yes1';
|
|
|
|
|
|
|
|
|
$order = Order::query()->create([
|
|
|
- 'code'=>'null'.Str::uuid(),'client_code' => 'asdfdfdg','web_order_number' => 'sadfdsf'
|
|
|
+ 'code' => 'null' . Str::uuid(), 'client_code' => 'asdfdfdg', 'web_order_number' => 'sadfdsf'
|
|
|
]);
|
|
|
dd($order);
|
|
|
// $order=(new OrderTrackingImport())->getOrder('92024765871-SDO130000986796QX',$items);
|
|
|
@@ -1108,21 +1191,19 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
// }
|
|
|
|
|
|
public function testSyncOrder()
|
|
|
- {
|
|
|
- $carbon =Carbon::now()->subHours(1);
|
|
|
+ {
|
|
|
+ $carbon = Carbon::now()->subHours(1);
|
|
|
$date = '2020-05-18 18:13:50';
|
|
|
- $orderHeader = OracleDOCOrderHeader::query()->selectRaw(implode(',',OracleDOCOrderHeaderService::$columns))
|
|
|
- ->with(['oracleBASCustomer'=>function($query){
|
|
|
+ $orderHeader = 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){
|
|
|
+ }, 'oracleDOCOrderDetails' => function ($query) {
|
|
|
$query->selectRaw('doc_order_details.orderNo,doc_order_details.customerid,doc_order_details.sku,doc_order_details.QtyOrdered');
|
|
|
- }, 'actAllocationDetails'=>function($query){
|
|
|
+ }, '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');
|
|
|
- },'oracleBASCode'=>function($query){
|
|
|
+ }, 'oracleBASCode' => function ($query) {
|
|
|
$query->selectRaw('BAS_Codes.CodeID,BAS_Codes.CodeName_C,BAS_Codes.Code');
|
|
|
}])
|
|
|
-// ->where('DOC_Order_Header.addTime','>=',$startDate)
|
|
|
-// ->where('orderno','SO201112029795')
|
|
|
->where('DOC_Order_Header.addTime','>=',$carbon)
|
|
|
->get();
|
|
|
/** @var OrderService $service */
|
|
|
@@ -1130,35 +1211,64 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
$service->syncOrder($orderHeader);
|
|
|
}
|
|
|
|
|
|
- public function OrderSync(){
|
|
|
+ public function OrderSync()
|
|
|
+ {
|
|
|
+ dump(Carbon::now());
|
|
|
$tack = new SyncWMSOrderTask();
|
|
|
$tack->handle();
|
|
|
- dump(11);
|
|
|
+ dump(Carbon::now());
|
|
|
}
|
|
|
- //按日志恢复富勒发过的波次下发,不要删
|
|
|
+
|
|
|
+ public function testSyncCommodity()
|
|
|
+ {
|
|
|
+ /**
|
|
|
+ * @var CommodityService $commodityService
|
|
|
+ */
|
|
|
+ $commodityService = app(CommodityService::class);
|
|
|
+ dump('start'.(string)Carbon::now());
|
|
|
+ $commodityService->syncCommodityCreated();
|
|
|
+ $commodityService->syncCommodityUpdated();
|
|
|
+ dump('end'.(string)Carbon::now());
|
|
|
+ }
|
|
|
+
|
|
|
public function reNewBatches3()
|
|
|
{
|
|
|
- $batches=Batch::query()->where('id','>',5338)->get('code');
|
|
|
- $batchCodes = $batches->map(function($batch){
|
|
|
- return $batch['code'];
|
|
|
- })->toArray();
|
|
|
- $requests=[];
|
|
|
+ $batches = Batch::query()->where('id', '>', 324)->get('code');
|
|
|
+// $batchCodes = $batches->map(function($batch){
|
|
|
+// return $batch['code'];
|
|
|
+// })->toArray();
|
|
|
+ $batchCodes = ['W201201000037',
|
|
|
+ 'W201201000038',
|
|
|
+ 'W201201000039',
|
|
|
+ 'W201201000040',
|
|
|
+ 'W201201000041',
|
|
|
+ 'W201201000052',
|
|
|
+ 'W201201000053',
|
|
|
+ 'W201201000054',
|
|
|
+ 'W201201000055',
|
|
|
+ 'W201201000056',
|
|
|
+ 'W201201000057',
|
|
|
+ 'W201201000071',
|
|
|
+ 'W201201000074',
|
|
|
+ 'W201201000075',
|
|
|
+ 'W201201000076',];
|
|
|
+ $requests = [];
|
|
|
// $logs=Log::query()->select('description')->where('CREATED_AT','>','2020-11-11')
|
|
|
// ->where('type',"issued_newBatch")
|
|
|
// ->get();
|
|
|
// dd($logs);
|
|
|
- foreach($batchCodes as $code){
|
|
|
+ foreach ($batchCodes as $code) {
|
|
|
// $request=Cache::get('temp'.$code)['description'];
|
|
|
- $request=Log::query()->select('description')->where('CREATED_AT','>','2020-12-01')
|
|
|
- ->where('type',"issued_newBatch")
|
|
|
- ->where('description','like',"%{$code}%")
|
|
|
+ $request = Log::query()->select('description')->where('CREATED_AT', '>', '2020-12-01')
|
|
|
+ ->where('type', "issued_newBatch")
|
|
|
+ ->where('description', 'like', "%{$code}%")
|
|
|
->first();
|
|
|
- if($request){
|
|
|
- $response=Zttp::post('https://wcs.baoshi56.com/api/thirdPart/flux/sorting/newBatch',
|
|
|
+ if ($request) {
|
|
|
+ $response = Zttp::post('https://wcs.baoshi56.com/api/thirdPart/flux/sorting/newBatch',
|
|
|
json_decode($request['description'])
|
|
|
);
|
|
|
- app('LogService')->log(__METHOD__,__FUNCTION__,$response->body());
|
|
|
- $requests[]=$response->body();
|
|
|
+ app('LogService')->log(__METHOD__, __FUNCTION__, $response->body());
|
|
|
+ $requests[] = $response->body();
|
|
|
}
|
|
|
// Cache::put('temp'.$code,$request);
|
|
|
// $requests[]=$request;
|
|
|
@@ -1166,6 +1276,23 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
dd($requests);
|
|
|
}
|
|
|
|
|
|
+ public function testGetCommodity()
|
|
|
+ {
|
|
|
+ /**
|
|
|
+ * @var CommodityService $commodityService
|
|
|
+ */
|
|
|
+ $ownerIds=['13'];
|
|
|
+ $barcodes = 'BH08B4029E027110';
|
|
|
+ $skus = ['BH08B4029E027110'];
|
|
|
+ $commodityService = app(CommodityService::class);
|
|
|
+ //$commodities=$commodityService->get_($ownerIds,$skus,[],true);
|
|
|
+// dd($commodities->first());
|
|
|
+ $ownerId=13;
|
|
|
+ $sku='BH08B4029E027110';
|
|
|
+ $commodity=$commodityService->syncBarcodes($barcodes,$ownerId,$sku);
|
|
|
+ dd($commodity);
|
|
|
+ }
|
|
|
+
|
|
|
public function syncOrderTracking()
|
|
|
{
|
|
|
/** @var OrderTrackingService $orderTrackingService */
|
|
|
@@ -1174,9 +1301,9 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
$orderService = app(OrderService::class);
|
|
|
/*$owners = app(OrderTrackingOwnerService::class)->getTrackingOrderOwner();*/
|
|
|
/*$startDate = \Illuminate\Support\Carbon::parse('2020-10-28 00:00:00')->toDateTimeString();*/
|
|
|
- $orderNos = ['SO201205001735','SO201204003891','SO201204003706','SO201204002877','SO201203003771'];
|
|
|
+ $orderNos = ['SO201205001735', 'SO201204003891', 'SO201204003706', 'SO201204002877', 'SO201203003771'];
|
|
|
$orderHeaders = OracleDOCOrderHeader::query()->with(['oracleDOCOrderDetails', 'actAllocationDetails', 'oracleBASCode'])
|
|
|
- ->whereIn('orderno',$orderNos)
|
|
|
+ ->whereIn('orderno', $orderNos)
|
|
|
->get();
|
|
|
$orderService->updateByWmsOrders($orderHeaders);
|
|
|
$orderTrackingService->createByWmsOrderHeader($orderHeaders);
|
|
|
@@ -1190,49 +1317,20 @@ where (commodities.owner_id,commodity_barcodes.code) in (select commodities.owne
|
|
|
dump((string)Carbon::now());
|
|
|
dd('hendle...end');
|
|
|
}
|
|
|
-
|
|
|
- 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 testSyncOrderTracking(){
|
|
|
- $orderTrackingService = new OrderTrackingService();
|
|
|
- $items = OrderTracking::query()->with('commodities.package.order')->where('created_at','>=','2020-12-01 00:00:00')->get();
|
|
|
- $orderNos = $items->map(function ($orderTracking){
|
|
|
- return $orderTracking->commodities->package->order->code;
|
|
|
- });
|
|
|
- $update_params =[['id','client','order_remark']];
|
|
|
- $orderHeaders = OracleDOCOrderHeader::query()->whereIn('OrderNo',$orderNos)->get();
|
|
|
- foreach ($items as $orderTracking) {
|
|
|
- $order = $orderTracking->commodities->package->order;
|
|
|
- $orderHeader = $orderHeaders->where('orderno',$order->code)->first();
|
|
|
- if(!$orderHeader)continue;
|
|
|
- if(empty($order))continue;
|
|
|
- $params = $orderTrackingService->getParamsByOrderHeaderAndOrder($orderHeader,$order);
|
|
|
- if($params['client'] != $orderTracking->client || $params['order_remark'] != $orderTracking->order_remark ){
|
|
|
- $update_params[] = [
|
|
|
- 'id' => $orderTracking->id,
|
|
|
- 'client' => $params['client'] ,
|
|
|
- 'order_remark' =>$params['order_remark']
|
|
|
- ];
|
|
|
- }
|
|
|
+ function testUpdateStores(){
|
|
|
+ $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($update_params) == 0)return ;
|
|
|
- $orderTrackingService->batchUpdate($update_params);
|
|
|
+ if (count($updateParams) > 1) app(BatchUpdateService::class)->batchUpdate('stores', $updateParams);
|
|
|
}
|
|
|
}
|