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

<?php

namespace App\Http\Controllers;


use App\Authority;
use App\Batch;
use App\City;
use App\Events\CancelOrder;
use App\Events\WmsReceiveNewEvent;
use App\Http\Controllers\Api\thirdPart\flux\WaybillController;
use App\Logistic;
use App\OracleActAllocationDetails;
use App\OracleDOCOrderHeader;
use App\OracleDocOrderPackingSummary;
use App\OracleDOCWaveDetails;
use App\OracleDOCWaveHeader;
use App\OracleIdxAsrsReceive;
use App\Order;
use App\Package;
use App\ProcessStatistic;
use App\Rejected;
use App\RejectedBill;
use App\RejectedBillItem;
use App\Unit;
use App\UploadFile;
use App\User;
use App\UserToken;
use App\Waybill;
use App\OraccleBasCustomer;
use App\WMSReflectReceive;
use Carbon\Carbon;
use Endroid\QrCode\Response\QrCodeResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\DB;
use Ramsey\Uuid\Uuid;
use function PHPSTORM_META\map;
use Zttp\Zttp;

class TestController extends Controller
{
    private $data = [];

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

    public function method(Request $request, $method)
    {
        return call_user_func([$this, $method], $request);
    }

    function packageFromLog(Request $request)
    { //x        $packagesBatch=Package::where('batch_number',$batch_number)->first();

        ini_set('max_execution_time', 2500);
        ini_set('memory_limit', '1526M');
        $uploaded = 0;
        $count = DB::table('logs')->where('operation', 'like', "%PackageController::new_%")
            ->where('created_at', '>', "2020-06-08 15:46:00")
            ->where('created_at', '<', "2020-06-08 15:47:00")
            ->where('type', "request_new_")
            ->count();
        $requests = DB::table('logs')->where('operation', 'like', "%PackageController::new_%")
            ->where('created_at', '>', "2020-06-08 15:46:00")
            ->where('created_at', '<', "2020-06-08 15:47:00")
            ->where('type', "request_new_")
            ->get();
        $requests->each(function ($request) use (&$uploaded) {
            $requestJson = json_decode($request->description, true);
            $response = Zttp::withHeaders(['content-type' => 'application/json',
            ])->post('https://was.baoshi56.com/api/thirdPart/flux/package/new',
                $requestJson
            );
            if ($response->json() && $response->json()['response'] && $response->json()['response']['flag'] == 'Y')
                $uploaded += 1;
        });
        dd($uploaded . '/' . $count);


    }

    function t2(Request $request)
    { //x        $packagesBatch=Package::where('batch_number',$batch_number)->first();

        $uploaded = 0;
        $count = DB::table('logs')->where('operation', 'like', "%PackageController::new_%")
            ->where('created_at', '>', "2020-06-03 14:02:00")
            ->where('created_at', '<', "2020-06-03 15:05:00")
            ->where('type', "request_new_")
            ->where('description', 'like', "%W200603000117%")
            ->count();
        $requests = DB::table('logs')->where('operation', 'like', "%PackageController::new_%")
            ->where('created_at', '>', "2020-06-03 14:02:00")
            ->where('created_at', '<', "2020-06-03 15:05:00")
            ->where('description', 'like', "%W200603000117%")
            ->where('type', "request_new_")
            ->get();
        $requests->each(function ($request) use (&$uploaded) {
            $requestJson = json_decode($request->description, true);
            $response = Zttp::withHeaders(['content-type' => 'application/json',
            ])->post('https://was.baoshi56.com/api/thirdPart/flux/package/new',
                $requestJson
            );
            if ($response->json() && $response->json()['response'] && $response->json()['response']['flag'] == 'Y')
                $uploaded += 1;
        });
        dd($uploaded . '/' . $count);


    }

    function tFixWithoutWaveno(Request $request)
    {
//        $re=OracleDOCWaveDetails::select(['doc_wave_details.waveno','doc_wave_details.orderno'])->where('doc_order_header.WAVENO','*')
//            ->leftJoin('DOC_ORDER_HEADER','DOC_ORDER_HEADER.orderno','doc_wave_details.orderno')->get();
//        dd($re);
//        $re->each(function($waveDetail){
//            $o=OracleDOCOrderHeader::where('orderno',$waveDetail['orderno'])->update(['waveno'=>$waveDetail['waveno']]);
//        });
////        $orderHeader=OracleDOCOrderHeader::where('waveno',)
    }
    function t1(Request $request)
    {
        $package=Package::first();
        $package->length=31;
        $package->save();
        dd($package);

    }


    function packageT(Request $request)
    {
        $package=Package::where('created_at','<','2020-07-08')->whereNotNull('logistic_number')->first();
        $package->fetchLogistic();
    }

    function injectJS(Request $request)
    {
        $items = RejectedBillItem::whereHas('rejectedBill', function ($query) {
            return $query->where('id_owner', 2);
        })->where('created_at', '>', '2019-12-23 18:11:00')->where('created_at', '<', '2019-12-24 11:25:00')->get();
        (new RejectedBillItemController())->collectionsToPackConfirm($items);
    }

    public function tj2(Request $request)
    {
        $numbersesOfBatch=OracleDOCWaveDetails::select('picktotraceid as logistic_number','act_allocation_details.orderno')->where('doc_wave_details.waveno','W190630000042')
            ->leftJoin('act_allocation_details','doc_wave_details.orderno','act_allocation_details.orderno')->get();

        $oneIdxAsrsReceive=OracleDocOrderPackingSummary::where('traceid',$numbersesOfBatch[0]['logistic_number'])->first();
        if(!$oneIdxAsrsReceive){
            $inserts='';
            $values=[];
            foreach($numbersesOfBatch as $numbers){
                $inserts .= " into doc_order_packing_summary (traceid,orderno,grossweight,addwho,addtime,editwho,edittime)values(?,?,?,?,?,?,?) ";
                $values[] = $numbers['logistic_number']??'';
                $values[] = $numbers['orderno']??'';
                $values[] = 12;
                $values[] = 'WAS';
                $values[] = Carbon::now();
                $values[] = 'WAS';
                $values[] = Carbon::now();
            }
            DB::connection('oracle')->insert("insert all {$inserts} select * from dual",$values);
        }else{
            $logisticNumbers=$numbersesOfBatch->map(function($numbers){return $numbers['logistic_number'];});
            OracleDocOrderPackingSummary::whereIn('traceid',$logisticNumbers)->update(['grossweight'=>32]);
        }
    }

    public function delme()
    {
        $package=new Package([
            'logistic_number'=>'546683955954',
            'delivery_number'=>'546683955954',
            'measuring_machine_id'=>'mm',
            'weight'=>12,
            'length'=>33,
            'width'=>22,
            'height'=>11,
            'weighed_at'=>now(),
            'status'=>"无",
        ]);
        $package->fetchAllFromOracle();
        dd($package->toJson());
        $package->fetchPaperBox();
    }
    public function excelIt()
    {
        $excel = new ExcelController();
        return $excel->makeExcel();
    }

    public function featureIt()
    {
        LogisticNumberFeatureController::loadRecentRejectedsToFeatures(5, 2500);
    }

    public function newSku()
    {
        $url = 'http://bswcs/api/sorting/flux/newSku';
        $response = Zttp::post($url, [
            'request' => [
                [
                    "SKU" => "1234567890",
                    "NAME" => "瑞士莲**巧克力",
                    "Alternate_SKU1" => "1122334455",
                    "GrossWeight" => "1.2",
                    "Cube" => "0.75",
                    "SKULength" => "0.25",
                    "SKUWidth" => "0.15",
                    "SKUHigh" => "0.05"
                ],
                [
                    "SKU" => "1234567892",
                    "NAME" => "跳跳饼",
                    "Alternate_SKU1" => "",
                    "GrossWeight" => "1.3",
                    "Cube" => "0.75",
                    "SKULength" => "0.25",
                    "SKUWidth" => "0.15",
                    "SKUHigh" => "0.25"
                ],
            ]
        ]);
        return $response->json();
    }

    public function changePackage()
    {
        $packages = Package::where('delivery_number', '<>', null)->where('logistic_id', null)->get();
        dd($packages);
        $packages = Package::whereRaw('delivery_number IS NOT NULL AND logistic_id IS NULL')->get();
        $logistics = Logistic::get();
        $packages->each(function ($package) use ($logistics) {
            $logistics->each(function ($logistic) use ($package) {
                if ($package->WMSReflectPackage->CarrierID == $logistic->code) {
                    $package->logistic_id = $logistic->id;
                    return;
                }
            });
        });
        return "OK";
    }

    public function tNull()
    {
    }

    public function deletePackageAuthority()
    {
        $authorities = Authority::where('name', 'like', '%包裹信息%')->get();
        $authorities->each(function ($authority) {
            $authority->delete();
        });
    }

    /*1*/
    function test()
    {/**/
    }

}