baoshi-was/app/Http/Controllers/TestController.php

<?php

namespace App\Http\Controllers;

use App\Components\AsyncResponse;
use App\Components\Database;
use App\Components\ErrorPush;
use App\MaterialBox;
use App\MaterialBoxModel;
use App\Order;
use App\OrderDetail;
use App\OrderIssue;
use App\OrderIssueRejectedBill;
use App\RejectedBill;
use App\Services\common\BatchUpdateService;
use App\Services\OracleDocAsnHerderService;
use App\Services\OrderRejectedBillRelationService;
use App\Services\OrderRejectingStatusService;
use App\Services\RejectedService;
use App\Services\WaybillService;
use App\User;
use App\Waybill;
use App\WorkOrder;
use Illuminate\Database\Capsule\Manager;
use Illuminate\Database\DatabaseManager;
use Illuminate\Foundation\Auth\AuthenticatesUsers;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Facades\Log;
use Oursdreams\Export\Export;
use Workerman\Worker;

class TestController extends Controller
{
    use AsyncResponse, ErrorPush, Database;

    const ASNREFERENCE_2 = 'ASNREFERENCE2';

    public function __construct()
    {
        $this->data["active_test"] = "active";
    }

    public function method(Request $request, $method)
    {
        try {
            return call_user_func([$this, $method], $request);
        }catch (\BadMethodCallException $e){
            dd("方法不存在");
        }
    }
    public function test(Request $request){
        dd(array_filter(array_unique(preg_split('/[,， ]+/u', "125,456，888, 6 ,  ,"))));
    }

    public function testOrder()
    {
        /** @var OrderRejectedBillRelationService $service */
        $service = app('OrderRejectedBillRelationService');
        $service->orderSyncRejectedBill(Order::query()->find(12));
    }

    public function testRejectedBill()
    {
        /** @var OrderRejectedBillRelationService $service */
        $service = app(OrderRejectedBillRelationService::class);
        /** @var RejectedBill $item */
        $item = RejectedBill::query()->find(2);
        $service->rejectedBillSyncOrder($item);
    }

    public function getOrder()
    {

        $query = Order::query()->select('id')->where('client_code','22011700000161');
        dd(OrderDetail::query()->whereIn('order_id',$query)->get());
    }

    public function sync_order_issue()
    {
        $items = OrderIssueRejectedBill::query()->with('orderIssue')->get();
        $item_array = $items->chunk(500);
        foreach ($item_array as $items){
            $insert_params = [];
            $update_params = [['logistic_number_return','order_id']];
            foreach ($items as $item){
                if (!$item->orderIssue) continue;
                $insert_params[$item->orderIssue->order_id] = [
                    'order_id' => $item->orderIssue->order_id,
                    'is_new_rejecting' => $item->orderIssue->is_new_rejecting,
                    'rejecting_status' => $item->orderIssue->rejecting_status
                ];
                $update_params[] = ['logistic_number_return' => $item->logistic_number_return,'order_id' => $item->orderIssue->order_id];
            }
            $this->batchOrderIssueRejectedBIll($update_params);
            $items = OrderDetail::query()->whereIn('order_id',array_keys($insert_params))->get()->map(function($item){
                return  $item->order_id;
            })->toArray();
            $insert_params = array_filter($insert_params,function($item)use($items){
                return !in_array($item['order_id'],$items) && !is_null($item['order_id']);
            });
            if (count($insert_params) == 0) continue;
            OrderDetail::query()->insert(array_values($insert_params));
        }
    }


    public function batchOrderIssueRejectedBIll($array)
    {
        /** @var BatchUpdateService $service */
        $service = app(BatchUpdateService::class);
        $service->batchUpdate('order_issue_rejected_bill',$array);
    }

    public function testQuery()
    {
        /** @var OracleDocAsnHerderService $oracleDocAsnHerderService */
        $oracleDocAsnHerderService = app(OracleDocAsnHerderService::class);
        $asnHerders = $oracleDocAsnHerderService->getWmsAsnOnStartDateCreate('2022-01-20 16:38:00');
        dd($asnHerders);
    }
}