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\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\Facades\DB;
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)
    {
        {
            $username=config('database.connections.oracle.username');
            $password=config('database.connections.oracle.password');
            $host=config('database.connections.oracle.host');
            $service_name=config('database.connections.oracle.service_name');
            $conn=oci_connect($username,$password,$host.'/'.$service_name); //连接oracle数据库
            $IN_WarehouseID='';
            $IN_TraceID='' ;
            $IN_WavenNo='';
            $IN_UserID='';
            $IN_Language='';
            $OUT_Return_Code='';
            $sql_sp="begin SPCUS_EDI_WCS001(:IN_WarehouseID,:IN_Process_Action_C,:IN_Process_By_C,
        :IN_WaveNO_C,:IN_OrderNO_C,:IN_OrderLineNO_C,:IN_AllocationDetailsID,:IN_Language,:IN_UserID,:OUT_Return_Code); end;";
            $stmt = oci_parse($conn, $sql_sp);
            oci_bind_by_name($stmt,':IN_Warehouse',$IN_WarehouseID);
            oci_bind_by_name($stmt,':IN_TraceID',$IN_TraceID);
            oci_bind_by_name($stmt,':IN_WavenNo',$IN_WavenNo);
            oci_bind_by_name($stmt,':IN_Language',$IN_Language);
            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();
        $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()
    {
        dd(DB::connection('oracle')->insert("insert into delme_log (id,name)values(?,?)",[32,'xx']));
    }
    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()
    {/**/
    }

}