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

<?php

namespace App\Http\Controllers;

use App\Authority;
use App\Commodity;
use App\CommodityMaterialBoxModel;
use App\Components\AsyncResponse;
use App\Components\ErrorPush;
use App\ErrorTemp;
use App\Feature;
use App\Http\ApiControllers\LoginController;
use App\Http\Requests\OrderDelivering;
use App\Jobs\CacheShelfTaskJob;
use App\Jobs\OrderCreateInstantBill;
use App\Jobs\OrderCreateWaybill;
use App\Jobs\SettlementBillReportTask;
use App\Jobs\StoreCreateInstantBill;
use App\Jobs\WeightUpdateInstantBill;
use App\Log;
use App\MaterialBox;
use App\MaterialBoxModel;
use App\Order;
use App\OrderPackage;
use App\Owner;
use App\OwnerFeeDetail;
use App\OwnerFeeDetailLogistic;
use App\OwnerFeeExpress;
use App\OwnerFeeLogistic;
use App\OwnerFeeOperation;
use App\OwnerFeeOperationDetail;
use App\OwnerFeeStorage;
use App\OwnerPriceOperation;
use App\OrderPackageCountingRecord;
use App\ProcurementCheckSheet;
use App\RejectedBill;
use App\Services\CacheShelfService;
use App\Services\ForeignHaiRoboticsService;
use App\Services\OrderPackageReceivedSyncService;
use App\Services\OrderService;
use App\Services\OwnerFeeTotalService;
use App\Services\OwnerLogisticFeeReportService;
use App\Services\OwnerPriceOperationService;
use App\Services\OwnerStoreFeeReportService;
use App\Services\OwnerStoreOutFeeReportService;
use App\Services\StationService;
use App\Services\StorageService;
use App\Station;
use App\StationTask;
use App\StationTaskMaterialBox;
use App\Store;
use App\TaskTransaction;
use App\Unit;
use App\User;
use App\UserDetail;
use App\UserDutyCheck;
use App\ValueStore;
use App\Waybill;
use Carbon\Carbon;
use Carbon\CarbonPeriod;
use Decimal\Decimal;
use Doctrine\DBAL\Exception;
use Firebase\JWT\JWT;
use Illuminate\Database\Eloquent\Collection;
use Illuminate\Foundation\Http\FormRequest;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Cookie;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Facades\URL;
use Illuminate\Support\Facades\Validator;
use Laravel\Horizon\Events\JobFailed;
use Monolog\Handler\IFTTTHandler;
use PhpOffice\PhpSpreadsheet\Calculation\Web\Service;

class TestController extends Controller
{
    use AsyncResponse, ErrorPush;

    const ASNREFERENCE_2 = 'ASNREFERENCE2';

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

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

    public function test()
    {
        $a = 1;
        if ($a > 2) dd(1);
        else if ($a == 0) dd(2);
        dd(3);
    }

    public function update_order_packages_is_manual_update()
    {
        $descriptions = Log::query()
            ->select('description')
            ->whereBetween('created_at', ['2021-08-31 10:30:00', '2021-08-31 10:35:00'])
            ->where('class', 'like', 'https://was.baoshi56.com/package/logistic/batchUpdate%')->pluck('description');
        foreach ($descriptions as $description) {
            $description = substr($description, 9);
            $description = \Illuminate\Support\Str::before($description, "}");
            $obj = json_decode($description . '}', true);
            OrderPackage::query()
                ->whereIn('logistic_number', $obj['logistic_numbers'])
                ->update([
                    'status' => '无',
                    'is_manual_update' => false,
                ]);
        }
    }

    public function testUpdateInv()
    {
        ini_set('max_execution_time', 0);
        ini_set('memory_limit', '4096M');
        $sql = <<<sql
select FMLOTNUM,FMLOCATION,PLANTOLOCATION,CREATE_TRANSACTIONID,SKU,CUSTOMERID from TSK_TASKLISTS
where CUSTOMERID=?
  AND FMLOCATION= ?
  AND OPENWHO = ?
  AND TASKPROCESS = ?
  AND DOCTYPE = ?
  AND TASKTYPE = ?
  AND LOTATT05=?
  AND LOTATT08=?
  AND PLANTOID = ?
  and OPENTIME>=TO_DATE(?,'yyyy-mm-dd hh24:mi:ss')
  and OPENTIME<=TO_DATE(?,'yyyy-mm-dd hh24:mi:ss')
sql;
        $CUSTOMERID = 'JIANSHANG';
        $FMLOCATION = 'STAGEWH02';
        $OPENWHO = 'WCS';
        $TASKPROCESS = '00';
        $DOCTYPE = 'ASN';
        $TASKTYPE = 'PA';
        $LOTATT05 = 'MJ-CP';
        $LOTATT08 = 'ZP';
        $PLANTOID = '*';
        $traceid = 'JIANSHANG03';
        $start = '2021-09-02 23:59:59';
        $end = '2021-09-03 11:10:00';
        $res = DB::connection("oracle")->select(DB::raw($sql),
            [$CUSTOMERID, $FMLOCATION, $OPENWHO, $TASKPROCESS, $DOCTYPE, $TASKTYPE, $LOTATT05, $LOTATT08, $PLANTOID, $start, $end]);
        $resItems = array_chunk($res, 200);
        foreach ($resItems as $res) {
            DB::connection("oracle")->beginTransaction();
            try {
                foreach ($res as $re) {
                    DB::connection("oracle")->table('INV_LOT_LOC_ID')
                        ->where([
                            'LOTNUM' => $re->fmlotnum,
                            'LOCATIONID' => $re->fmlocation,
                            'CUSTOMERID' => $re->customerid,
                            'sku' => $re->sku,
                            'TRACEID' => '*',
                        ])
                        ->update([
                            'TRACEID' => $traceid,
                            'EDITWHO' => 'WCS_',
                        ]);
                    if ($re->fmlocation != $re->plantolocation) {
                        DB::connection("oracle")->table('INV_LOT_LOC_ID')
                            ->where([
                                'LOTNUM' => $re->fmlotnum,
                                'LOCATIONID' => $re->plantolocation,
                                'CUSTOMERID' => $re->customerid,
                                'sku' => $re->sku,
                                'TRACEID' => '*',
                            ])
                            ->update([
                                'TRACEID' => $traceid,
                                'EDITWHO' => 'WCS_',
                            ]);
                    }
                    DB::connection("oracle")->commit();
                }
                dd(true);
            } catch (\Exception $e) {
                DB::connection("oracle")->rollBack();
                dd($e->getMessage());
            }
        }
    }
}