TestController.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Authority;
  4. use App\Batch;
  5. use App\City;
  6. use App\Events\CancelOrder;
  7. use App\Logistic;
  8. use App\OracleActAllocationDetails;
  9. use App\OracleBasSKU;
  10. use App\OracleDOCOrderHeader;
  11. use App\OracleDocOrderPackingSummary;
  12. use App\OracleDOCWaveDetails;
  13. use App\OracleDOCWaveHeader;
  14. use App\OracleIdxAsrsReceive;
  15. use App\Order;
  16. use App\Package;
  17. use App\Process;
  18. use App\ProcessesContent;
  19. use App\ProcessStatistic;
  20. use App\Rejected;
  21. use App\RejectedBill;
  22. use App\RejectedBillItem;
  23. use App\Unit;
  24. use App\UploadFile;
  25. use App\User;
  26. use App\UserToken;
  27. use App\Waybill;
  28. use App\OraccleBasCustomer;
  29. use App\WMSReflectReceive;
  30. use Carbon\Carbon;
  31. use Faker\Factory;
  32. use Illuminate\Support\Facades\Cache;
  33. use function Couchbase\zlibCompress;
  34. use function Couchbase\zlibDecompress;
  35. use Endroid\QrCode\Response\QrCodeResponse;
  36. use Illuminate\Database\Eloquent\Builder;
  37. use Illuminate\Http\Request;
  38. use Illuminate\Support\Facades\DB;
  39. use function PHPSTORM_META\map;
  40. use Zttp\Zttp;
  41. class TestController extends Controller
  42. {
  43. private $data = [];
  44. public function __construct()
  45. {
  46. $this->data["active_test"] = "active";
  47. }
  48. public function method(Request $request, $method)
  49. {
  50. return call_user_func([$this, $method], $request);
  51. }
  52. function packageFromLog(Request $request)
  53. { //x $packagesBatch=Package::where('batch_number',$batch_number)->first();
  54. ini_set('max_execution_time', 2500);
  55. ini_set('memory_limit', '1526M');
  56. $uploaded = 0;
  57. $count = DB::table('logs')->where('operation', 'like', "%PackageController::new_%")
  58. ->where('created_at', '>', "2020-06-08 15:46:00")
  59. ->where('created_at', '<', "2020-06-08 15:47:00")
  60. ->where('type', "request_new_")
  61. ->count();
  62. $requests = DB::table('logs')->where('operation', 'like', "%PackageController::new_%")
  63. ->where('created_at', '>', "2020-06-08 15:46:00")
  64. ->where('created_at', '<', "2020-06-08 15:47:00")
  65. ->where('type', "request_new_")
  66. ->get();
  67. $requests->each(function ($request) use (&$uploaded) {
  68. $requestJson = json_decode($request->description, true);
  69. $response = Zttp::withHeaders(['content-type' => 'application/json',
  70. ])->post('https://was.baoshi56.com/api/thirdPart/flux/package/new',
  71. $requestJson
  72. );
  73. if ($response->json() && $response->json()['response'] && $response->json()['response']['flag'] == 'Y')
  74. $uploaded += 1;
  75. });
  76. dd($uploaded . '/' . $count);
  77. }
  78. function t2(Request $request)
  79. { //x $packagesBatch=Package::where('batch_number',$batch_number)->first();
  80. $hasSku = OracleBasSKU::query()->where('sku', "2140100024")->where('customerid', "ONKYO")->first();
  81. dd($hasSku);
  82. }
  83. function setCache(Request $request)
  84. {
  85. $today = now();
  86. Cache::put('storedTest', $today);
  87. return "cacheing:'$today'<script>localStorage.setItem('storedTest','{$today}')</script>";
  88. }
  89. function getCache(Request $request)
  90. {
  91. $cache=Cache::get('storedTest');
  92. return "cacheing get:'$cache'<script>document.write('<br>localStorage:'+localStorage.getItem('storedTest'))</script>";
  93. }
  94. function t1(Request $request)
  95. {
  96. {
  97. $username=config('database.connections.oracle.username');
  98. $password=config('database.connections.oracle.password');
  99. $host=config('database.connections.oracle.host');
  100. $service_name=config('database.connections.oracle.service_name');
  101. $conn=oci_connect($username,$password,$host.'/'.$service_name); //连接oracle数据库
  102. $IN_WarehouseID='';
  103. $IN_TraceID='' ;
  104. $IN_WavenNo='';
  105. $IN_UserID='';
  106. $IN_Language='';
  107. $OUT_Return_Code='';
  108. $sql_sp="begin SPCUS_EDI_WCS001(:IN_WarehouseID,:IN_Process_Action_C,:IN_Process_By_C,
  109. :IN_WaveNO_C,:IN_OrderNO_C,:IN_OrderLineNO_C,:IN_AllocationDetailsID,:IN_Language,:IN_UserID,:OUT_Return_Code); end;";
  110. $stmt = oci_parse($conn, $sql_sp);
  111. oci_bind_by_name($stmt,':IN_Warehouse',$IN_WarehouseID);
  112. oci_bind_by_name($stmt,':IN_TraceID',$IN_TraceID);
  113. oci_bind_by_name($stmt,':IN_WavenNo',$IN_WavenNo);
  114. oci_bind_by_name($stmt,':IN_Language',$IN_Language);
  115. oci_bind_by_name($stmt,':IN_UserID',$IN_UserID);
  116. oci_bind_by_name($stmt,':OUT_Return_Code',$OUT_Return_Code);
  117. return oci_execute($stmt);
  118. }
  119. }
  120. function packageT(Request $request)
  121. {
  122. $package=Package::where('created_at','<','2020-07-08')->whereNotNull('logistic_number')->first();
  123. $package->fetchLogistic();
  124. }
  125. function injectJS(Request $request)
  126. {
  127. $items = RejectedBillItem::whereHas('rejectedBill', function ($query) {
  128. return $query->where('id_owner', 2);
  129. })->where('created_at', '>', '2019-12-23 18:11:00')->where('created_at', '<', '2019-12-24 11:25:00')->get();
  130. (new RejectedBillItemController())->collectionsToPackConfirm($items);
  131. }
  132. public function tj2(Request $request)
  133. {
  134. $numbersesOfBatch=OracleDOCWaveDetails::select('picktotraceid as logistic_number','act_allocation_details.orderno')->where('doc_wave_details.waveno','W190630000042')
  135. ->leftJoin('act_allocation_details','doc_wave_details.orderno','act_allocation_details.orderno')->get();
  136. $oneIdxAsrsReceive=OracleDocOrderPackingSummary::where('traceid',$numbersesOfBatch[0]['logistic_number'])->first();
  137. if(!$oneIdxAsrsReceive){
  138. $inserts='';
  139. $values=[];
  140. foreach($numbersesOfBatch as $numbers){
  141. $inserts .= " into doc_order_packing_summary (traceid,orderno,grossweight,addwho,addtime,editwho,edittime)values(?,?,?,?,?,?,?) ";
  142. $values[] = $numbers['logistic_number']??'';
  143. $values[] = $numbers['orderno']??'';
  144. $values[] = 12;
  145. $values[] = 'WAS';
  146. $values[] = Carbon::now();
  147. $values[] = 'WAS';
  148. $values[] = Carbon::now();
  149. }
  150. DB::connection('oracle')->insert("insert all {$inserts} select * from dual",$values);
  151. }else{
  152. $logisticNumbers=$numbersesOfBatch->map(function($numbers){return $numbers['logistic_number'];});
  153. OracleDocOrderPackingSummary::whereIn('traceid',$logisticNumbers)->update(['grossweight'=>32]);
  154. }
  155. }
  156. public function delme()
  157. {
  158. $fields = [
  159. 'doc_order_header.userdefine1',
  160. 'doc_order_header.userdefine2',
  161. 'doc_order_header.SOReference5',
  162. 'doc_order_header.waveno',
  163. 'doc_order_header.orderno',
  164. 'doc_order_header.customerid',
  165. 'doc_order_header.Consigneename'
  166. ];
  167. if(''){
  168. $resultOracleObj=OracleDOCOrderHeader::select($fields)->where('orderno','SO200603004708');
  169. }else{
  170. $resultOracleObj=OracleActAllocationDetails::select($fields);
  171. $resultOracleObj->where('picktotraceid','546152742096');
  172. $resultOracleObj->leftJoin('DOC_Order_Header','act_allocation_details.orderno','doc_order_header.orderno');
  173. }
  174. $_temOracleInfo=$resultOracleObj->first();
  175. dd($_temOracleInfo);
  176. }
  177. public function excelIt()
  178. {
  179. $excel = new ExcelController();
  180. return $excel->makeExcel();
  181. }
  182. public function featureIt()
  183. {
  184. LogisticNumberFeatureController::loadRecentRejectedsToFeatures(5, 2500);
  185. }
  186. public function newSku()
  187. {
  188. $url = 'http://bswcs/api/sorting/flux/newSku';
  189. $response = Zttp::post($url, [
  190. 'request' => [
  191. [
  192. "SKU" => "1234567890",
  193. "NAME" => "瑞士莲**巧克力",
  194. "Alternate_SKU1" => "1122334455",
  195. "GrossWeight" => "1.2",
  196. "Cube" => "0.75",
  197. "SKULength" => "0.25",
  198. "SKUWidth" => "0.15",
  199. "SKUHigh" => "0.05"
  200. ],
  201. [
  202. "SKU" => "1234567892",
  203. "NAME" => "跳跳饼",
  204. "Alternate_SKU1" => "",
  205. "GrossWeight" => "1.3",
  206. "Cube" => "0.75",
  207. "SKULength" => "0.25",
  208. "SKUWidth" => "0.15",
  209. "SKUHigh" => "0.25"
  210. ],
  211. ]
  212. ]);
  213. return $response->json();
  214. }
  215. public function changePackage()
  216. {
  217. $packages = Package::where('delivery_number', '<>', null)->where('logistic_id', null)->get();
  218. dd($packages);
  219. $packages = Package::whereRaw('delivery_number IS NOT NULL AND logistic_id IS NULL')->get();
  220. $logistics = Logistic::get();
  221. $packages->each(function ($package) use ($logistics) {
  222. $logistics->each(function ($logistic) use ($package) {
  223. if ($package->WMSReflectPackage->CarrierID == $logistic->code) {
  224. $package->logistic_id = $logistic->id;
  225. return;
  226. }
  227. });
  228. });
  229. return "OK";
  230. }
  231. public function tNull()
  232. {
  233. }
  234. public function deletePackageAuthority()
  235. {
  236. $authorities = Authority::where('name', 'like', '%包裹信息%')->get();
  237. $authorities->each(function ($authority) {
  238. $authority->delete();
  239. });
  240. }
  241. /*1*/
  242. function test(Request $request)
  243. {/**/
  244. $a = new OrderController();
  245. $alternate_sku1 = '8003340090276';
  246. dd($a -> getOrdersNo($alternate_sku1));
  247. $units=ProcessesContent::with('signCommodity')->get();
  248. foreach ($units as $unit){
  249. if ($unit->sign_commodity_name_mark)dd($unit->sign_commodity_name_mark);
  250. }
  251. header("Content-type:text/html;charset=utf-8");
  252. $stuid = "201301013";
  253. $pwd = "136";
  254. $uri = "127.0.0.1/login.php";//这里换成你服务器的地址
  255. // 参数数组
  256. $data = array (
  257. 'stuid' => $stuid,
  258. 'pwd' => $pwd
  259. );
  260. $ch = curl_init(); //初始化curl
  261. curl_setopt ( $ch, CURLOPT_URL, $uri );
  262. curl_setopt ( $ch, CURLOPT_POST, 1 ); //使用post请求
  263. curl_setopt ( $ch, CURLOPT_HEADER, 0 );
  264. curl_setopt ( $ch, CURLOPT_RETURNTRANSFER, 1 );
  265. curl_setopt ( $ch, CURLOPT_POSTFIELDS, $data); //提交数据
  266. curl_setopt ( $ch, CURLOPT_FOLLOWLOCATION, true); //重定向地址也输出
  267. $return = curl_exec ( $ch ); //得到返回值
  268. curl_close ( $ch ); //关闭
  269. print_r($return); //输出返回值
  270. }
  271. }