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();
$inventoryCompareService = new InventoryCompareService();
echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
echo ($inventoryCompareService)->getCreatingMissionCode('安桥主品');
}
function setCache(Request $request)
{
$today = now();
Cache::put('storedTest', $today);
return "cacheing:'$today'";
}
function getCache(Request $request)
{
$cache=Cache::get('storedTest');
return "cacheing get:'$cache'";
}
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()
{
$fields = [
'doc_order_header.userdefine1',
'doc_order_header.userdefine2',
'doc_order_header.SOReference5',
'doc_order_header.waveno',
'doc_order_header.orderno',
'doc_order_header.customerid',
'doc_order_header.Consigneename'
];
if(''){
$resultOracleObj=OracleDOCOrderHeader::select($fields)->where('orderno','SO200603004708');
}else{
$resultOracleObj=OracleActAllocationDetails::select($fields);
$resultOracleObj->where('picktotraceid','546152742096');
$resultOracleObj->leftJoin('DOC_Order_Header','act_allocation_details.orderno','doc_order_header.orderno');
}
$_temOracleInfo=$resultOracleObj->first();
dd($_temOracleInfo);
}
public function mergerPackageData(){
$number = 1000;
$sum = Package::query()->count();
$len = ceil($sum / $number);
$id = 0;
for ($i = 1;$i <= $len; $i++){
$packages = Package::query()->orderBy('id')->where('id','>',$id)->limit($number)->get();
$error = [];
foreach ($packages as $package){
/** @var OrderPackageService */
$orderPackage = app('orderPackageService')->firstOrCreate($package->logistic_number,
['batch_number'=>$package->batch_number,
'batch_rule'=>$package->batch_rule,
'bulk'=>$package->bulk,
'weight'=>$package->weight,
'length'=>$package->length,
'width'=>$package->width,
'height'=>$package->height,
'paper_box_id'=>$package->paper_box_id,
'measuring_machine_id'=>$package->measuring_machine_id,
'weighed_at'=>$package->weighed_at,
'status'=>$package->status]);
if (!$orderPackage)array_push($error,$package->id);
}
LogService::log(__METHOD__,"同步时WMS中未找到这些订单",json_encode($error));
$id = $packages[count($packages)-1]->id;
}
}
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()
{
User::query()->get()->toArray();
User::query()->get()->toJson();
}
public function deletePackageAuthority()
{
$authorities = Authority::where('name', 'like', '%包裹信息%')->get();
$authorities->each(function ($authority) {
$authority->delete();
});
}
function test(){
dd(Owner::query()->where('code','CHAIJING')->first());
$owner = app('ownerService')->first(['code' => "CHAIJING"]);
dd($owner);
dd(Waybill::query()->with('uploadFile')->find(695));
$actAllocationDetail = OracleActAllocationDetails::query();
$actAllocationDetail->with(['oracleDocOrderHeader'=>function(Builder $query){
$query->with('oracleBASCustomer','oracleBASCode');
}])->first();//报错
dd($actAllocationDetail);
}
/*1*/
function socket(Request $request)
{/**/
$a = microtime(true);
error_reporting(E_ALL);
set_time_limit(0);
echo "TCP/IP Connection
\n";
$port = 8091;
$ip = "127.0.0.1";
/*
+-------------------------------
* @socket连接整个过程
+-------------------------------
* @socket_create
* @socket_connect
* @socket_write
* @socket_read
* @socket_close
+--------------------------------
*/
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket < 0) {
echo "socket_create() failed: reason: " . socket_strerror($socket) . "\n";
}else {
echo "OK.\n";
}
echo "试图连接 '$ip' 端口 '$port'...\n";
$result = socket_connect($socket, $ip, $port);
if ($result < 0) {
echo "socket_connect() failed.\nReason: ($result) " . socket_strerror($result) . "\n";
}else {
echo "连接OK\n";
}
$b = microtime(true);
echo "连接耗时：".($b-$a)."\n";
$content = Commodity::query()->limit(200)->get();
$c= microtime(true);
echo "查询数据耗时：".($c-$b)."\n";
$content->toArray();
/*$chunks=$content->chunk(100);
foreach ($chunks as $chunk){
$chunk->toJson();
var_dump(mb_strlen($chunk->toJson()));
//socket_write($socket, $chunk->toJson(), mb_strlen($chunk->toJson()));
}*/
$d= microtime(true);
echo "发送数据耗时：".($d-$c)."\n";
socket_close($socket);
$e= microtime(true);
echo "共耗时：".($e-$a)."\n";
}
}