OrderController.php 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Database;
  4. use App\Http\Requests\OrderDelivering;
  5. use App\OracleDOCOrderHeader;
  6. use App\OracleDOCWaveDetails;
  7. use App\OrderIssue;
  8. use App\Services\LogisticService;
  9. use App\Services\LogService;
  10. use App\Services\OrderIssueTypeService;
  11. use App\Services\OrderPackageService;
  12. use App\Services\OrderService;
  13. use App\Services\OwnerService;
  14. use App\Services\RejectedBillItemService;
  15. use App\Services\RejectedBillService;
  16. use GuzzleHttp\Exception\GuzzleException;
  17. use Illuminate\Http\Request;
  18. use Illuminate\Support\Facades\Auth;
  19. use Illuminate\Support\Facades\DB;
  20. use Illuminate\Support\Facades\Gate;
  21. use Oursdreams\Export\Export;
  22. use function DeepCopy\deep_copy;
  23. class OrderController extends Controller
  24. {
  25. use Database;
  26. /**
  27. * @var OrderIssueTypeService $orderIssueTypeService
  28. */
  29. private $orderIssueTypeService;
  30. public function __construct()
  31. {
  32. $this->orderIssueTypeService = app(OrderIssueTypeService::class);
  33. }
  34. public function delivering(OrderDelivering $request)
  35. {
  36. /** @var OrderService $orderService */
  37. $orderService = app('OrderService');
  38. $request = $request->input();
  39. $service = app(LogisticService::class);
  40. $logistics = $service->getSelection(['id', 'name']);
  41. $result = $orderService->paginate($request);
  42. $picktotraceids = $result['picktotraceids'];
  43. $orders = $result['orders'];
  44. app('WorkOrderService')->tagWorkOrder($orders);
  45. $commodities = $result['commodities'];
  46. $customers = app(OwnerService::class)->getQuery()->select("code","name")->get();
  47. $page = $request["page"] ?? 1;
  48. $codes = DB::connection('oracle')->table('BAS_CODES')->select('code', 'codename_c')->where('codeid', 'SO_STS')->orderBy('code', 'asc')->get();
  49. $orderIssueType = $this->orderIssueTypeService->getOwnerOrderIssueType();
  50. return view('order/index/delivering', compact('orders', 'customers', 'request', 'codes', 'commodities', 'page', 'picktotraceids', 'orderIssueType', 'logistics'));
  51. }
  52. //导出
  53. /**
  54. * @throws \Exception|GuzzleException
  55. */
  56. public function export(Request $request)
  57. {
  58. $is_merge = $request->is_merge ?? false;
  59. /** @var OrderService $orderService */
  60. $orderService = app('OrderService');
  61. $req = ['type' => 'order'];
  62. if ($is_merge && $is_merge == 'true') $req["createFormat"] = "merge";
  63. if ($request->data) {
  64. $req["sql"] = $orderService->getSql(['data' => $request->data]);
  65. } else {
  66. new OrderDelivering();
  67. $req["sql"] = $orderService->getSql($request->input());
  68. }
  69. $e = new Export();
  70. $e->setOracleConnection(config('database.connections.oracle.host'),
  71. config('database.connections.oracle.port'), config('database.connections.oracle.database')
  72. , config('database.connections.oracle.username'), config('database.connections.oracle.password'));
  73. if ($is_merge && $is_merge == 'true') {
  74. $e->setMergeFormat([
  75. "A", "B", "C", "D", "E", "F", "G", "H", "I", "J", "K", "L", "M", "N", "O", "P",
  76. "Q", "R", "S", "Z", "AA", "AB", "AC", "AD"
  77. ]);
  78. $e->setDatum("ORDERNO");
  79. } else $e->setWarpTextFormat();
  80. $e->setFileName("订单记录-" . date('ymdHis'));
  81. return $e->sql($req["sql"], [
  82. "ORDERNO" => "编号", "ORDERCODENAME" => "订单状态",
  83. "NOTES" => "备注", "ADDTIME" => "接口下发时间",
  84. "ISSUEPARTYNAME" => "店铺名称", "CUSTOMER_DESCR_C" => "客户",
  85. "SOREFERENCE1" => "客户订单号", "CARRIERNAME" => "承运人",
  86. "SOREFERENCE5" => "快递单号", "C_CONTACT" => "收货人名称", "C_TEL2" => "收货人电话",
  87. "C_PROVINCE" => "省", "C_CITY" => "市", "C_DISTRICT" => "区", "C_ADDRESS1" => "收货人地址",
  88. "WAVENO" => "波次编号", "WAREHOUSEID" => "仓库", "EDISENDFLAG2" => "快递获取标记", "EDISENDTIME2" => "快递获取时间",
  89. "SKU" => "产品代码", "ALTERNATE_SKU1" => "产品条码", "ORDERDETAILCODENAME" => "明细状态", "DESCR_C" => "产品名称",
  90. "QTYORDERED" => "订单数量", "CHECKTIME" => "复核时间", "ERPCANCELFLAG" => "接口取消标记",
  91. "PICKING_PRINT_FLAG" => "拣货单打印标记", "EDISENDFLAG" => "接口回传标记", "EDIREMARKS2" => "接口回传异常备注",
  92. "RELEASESTATUS" => "订单冻结"], ["ADDTIME" => "date", "EDISENDTIME2" => "date"])->direct();
  93. }
  94. public function createRejectedBill(Request $request)
  95. {
  96. if (!Gate::allows('订单管理-订单-生成退货单')) {
  97. return ['success' => false, 'data' => '您无权操作!'];
  98. }
  99. /** @var OrderService $orderService */
  100. $orderService = app('OrderService');
  101. $result = $orderService->get(['data' => $request->data]);
  102. /** @var RejectedBillService $rejectedBillService */
  103. $rejectedBillService = app('RejectedBillService');
  104. /** @var RejectedBillItemService $rejectedBillItemService */
  105. $rejectedBillItemService = app('RejectedBillItemService');
  106. $commodities = $result['commodities'];
  107. $rejectedBillItems = [];
  108. //分箱号
  109. $picktotraceids = json_decode($result['picktotraceids'], true);
  110. $rejectedBill_collect = collect();// 保存生成的rejectedBill
  111. foreach ($result['orders'] as $order) {
  112. $blacklist = ["00", "10", "20", "30", "90"/*,"99"*/];
  113. if (array_search($order->sostatus, $blacklist) !== false) return ['success' => false, 'data' => '“' . $order->orderno . "”状态异常,无法操作"];
  114. }
  115. foreach ($result['orders'] as $order) {
  116. //不存在时将当前快递单号视为分箱号
  117. if (!($picktotraceids[$order->orderno] ?? false)) $picktotraceids[$order->orderno] = [$order->soreference5];
  118. //获取货主与快递方
  119. $owner = app('OwnerService')->firstOrCreate(['name' => $order->customer_descr_c],
  120. ['name' => $order->customer_descr_c, 'code' => $order->customer_descr_c]);
  121. $logistic = app('LogisticService')->firstOrCreate(['name' => $order->carriername],
  122. ['name' => $order->carriername, 'code' => $order->carriername]);
  123. foreach ($picktotraceids[$order->orderno] as $orderno) {
  124. $rejectedBill = $rejectedBillService->create([
  125. 'id_owner' => $owner->id,
  126. 'sender' => $order->c_contact,
  127. 'logistic_number_return' => $orderno,
  128. 'id_logistic_return' => $logistic->id,
  129. 'order_number' => $order->soreference1,
  130. 'mobile_sender' => empty($order->c_tel2) ? $order->c_tel1 : $order->c_tel2,
  131. 'logistic_number' => '原单退回',//$order->soreference1
  132. 'remark' => $order->notes,
  133. 'is_loaded' => 0,
  134. "id_operator" => Auth::id(),
  135. ]);
  136. $rejectedBill_collect->push($rejectedBill);// 保存生成的rejectedBill
  137. LogService::log(__METHOD__, "生成退货单", json_encode($order), Auth::user()['id']);
  138. $cms = $commodities[$order->orderno] ?? [];
  139. if (count($picktotraceids[$order->orderno]) > 0 && $cms) {
  140. $sql = <<<sql
  141. SELECT sum(QTY) qty,sku FROM ACT_ALLOCATION_DETAILS where ORDERNO = ? and PICKTOTRACEID = ? GROUP BY sku
  142. sql;
  143. $acts = DB::connection("oracle")->select(DB::raw($sql), [$order->orderno, $orderno]);
  144. $skus = array_column($acts, "sku");
  145. foreach ($cms as $orderCommodities) {
  146. $index = array_search($orderCommodities["sku"], $skus);
  147. if ($index === false) continue;
  148. array_push($rejectedBillItems, [
  149. 'id_rejected_bill' => $rejectedBill->id,
  150. 'barcode_goods' => $orderCommodities['alternate_sku1'],
  151. 'name_goods' => $orderCommodities['descr_c'],
  152. 'amount' => $acts[$index]->qty,//$orderCommodities['qtyordered'],
  153. 'id_quality_label' => 1,
  154. 'created_at' => date('Y-m-d H:i:s'),
  155. ]);
  156. }
  157. }
  158. }
  159. }
  160. $rejectedBillItemService->insert($rejectedBillItems);
  161. LogService::log(__METHOD__, "批量生成退货单详情", json_encode($rejectedBillItems), Auth::user()['id']);
  162. $rejectedBill_collect->each(function ($rejectedBill) use ($rejectedBillService) {
  163. $rejectedBillService->joinOrderIssue($rejectedBill);
  164. $rejectedBillService->syncOrderIssue($rejectedBill);
  165. });
  166. return ['success' => true];
  167. }
  168. public function isRejectedBillExist(Request $request)
  169. {
  170. if (!Gate::allows('订单管理-订单-生成退货单')) {
  171. return redirect(url('/'));
  172. }
  173. /** @var RejectedBillService $rejectedBillService */
  174. $rejectedBillService = app('RejectedBillService');
  175. $rejectedBills = $rejectedBillService->get(['order_number' => $request->data]);
  176. if (count($rejectedBills) == 0) return ['success' => true];
  177. return ['success' => false, 'data' => json_encode(array_column($rejectedBills->toArray(), 'order_number'))];
  178. }
  179. //批量备注追加
  180. public function batchComments(Request $request)
  181. {
  182. if (!Gate::allows('订单管理-批量备注')) {
  183. return redirect(url('/'));
  184. }
  185. $checkData = $request->input('checkData');
  186. $content = $request->input('content');
  187. $ordersNotNull = OracleDOCOrderHeader::query()->select('OrderNo', 'Notes')->whereIn('orderno', $checkData)
  188. ->whereNotNull('notes')->get();
  189. OracleDOCOrderHeader::query()->select('OrderNo', 'Notes')->whereIn('orderno', $checkData)
  190. ->whereNull('notes')->update(['notes' => $content]);
  191. $ordersNotNullArr = array_column($ordersNotNull->toArray(), 'orderno');
  192. $ordersNullArr = array_diff($checkData, $ordersNotNullArr);
  193. $data = [];
  194. foreach ($ordersNotNull as $order) {
  195. OracleDOCOrderHeader::query()->where('orderno', $order->orderno)->update(["notes" => ($order->notes) . "," . $content]);
  196. app('LogService')->log(__METHOD__, '批量备注追加修改' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  197. $order->notes = ($order->notes) . "," . $content;
  198. array_push($data, $order);
  199. }
  200. foreach ($ordersNullArr as $order) {
  201. array_push($data, ["orderno" => $order, 'notes' => $content]);
  202. }
  203. return $data;
  204. }
  205. //批量冻结
  206. public function freezeAll(Request $request)
  207. {
  208. if (!Gate::allows('订单管理-编辑')) {
  209. return redirect(url('/'));
  210. }
  211. $checkData = $request->input('checkData') ?? '';
  212. //冻结条件只局限于 分配完成sostatus=40 创建订单sostatus=00 拣货完成sostatus=60 播种完成sostatus=61
  213. $sostatus = ['40', '00', '60', '61'];
  214. $orders = OracleDOCOrderHeader::select('OrderNo', 'SoStatus')->whereIn('orderno', $checkData)->whereIn('SoStatus', $sostatus)->get();
  215. if (count($checkData) != count($orders)) return ['success' => false, 'fail_info' => "勾选订单有不可冻结订单"];
  216. foreach ($orders as $order) {
  217. $waveno = OracleDOCOrderHeader::where('orderno', $order->orderno)->value('waveno');
  218. if ($waveno && $waveno != '*') {
  219. OracleDOCWaveDetails::where('waveno', $waveno)->where('orderno', $order->orderno)->delete();
  220. app('LogService')->log(__METHOD__, '批量冻结删除波次号' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  221. }
  222. $is_freeze = OracleDOCOrderHeader::where('orderno', $order->orderno)->update(['releasestatus' => 'H', 'waveno' => '*']);
  223. app('LogService')->log(__METHOD__, '批量冻结修改' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  224. if (!$is_freeze) return ['success' => false, 'fail_info' => "数据 {$order['orderno']} 更新失败"];
  225. }
  226. return ['success' => true];
  227. }
  228. //批量取消分配
  229. public function deAllocationAll(Request $request)
  230. {
  231. if (!Gate::allows('订单管理-编辑')) {
  232. return redirect(url('/'));
  233. }
  234. $checkData = $request->input('checkData') ?? '';
  235. //取消分配条件只局限于 分配完成sostatus=40 和 部分分配sostatus=30
  236. $sostatus = ['30', '40'];
  237. $orders = OracleDOCOrderHeader::select('OrderNo', 'SoStatus')->whereIn('orderno', $checkData)->whereIn('SoStatus', $sostatus)->get();
  238. if (count($checkData) != count($orders)) return ['success' => false, 'fail_info' => "勾选订单有不可取消分配订单"];
  239. foreach ($orders as $order) {
  240. $is_deAllocation = $this->isDeAllocation($order->orderno);
  241. $waveno = OracleDOCOrderHeader::where('orderno', $order->orderno)->value('waveno');
  242. if ($waveno && $waveno != '*') {
  243. OracleDOCWaveDetails::where('waveno', $waveno)->where('orderno', $order->orderno)->delete();
  244. app('LogService')->log(__METHOD__, '批量取消分配删除波次号' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  245. }
  246. $deAllocation = OracleDOCOrderHeader::where('orderno', $order->orderno)->update(['sostatus' => '00', 'waveno' => '*']);
  247. app('LogService')->log(__METHOD__, '批量取消分配' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  248. if (!$is_deAllocation || !$deAllocation) return ['success' => false, 'fail_info' => "数据 {$order['orderno']} 更新失败"];
  249. }
  250. return ['success' => true];
  251. }
  252. //冻结
  253. public function freeze(Request $request)
  254. {
  255. if (!Gate::allows('订单管理-编辑')) {
  256. return redirect(url('/'));
  257. }
  258. $orderno = $request->input('orderno');
  259. $waveno = $request->input('waveno');
  260. if ($waveno && $waveno != '*') {
  261. OracleDOCWaveDetails::where('waveno', $waveno)->where('orderno', $orderno)->delete();
  262. app('LogService')->log(__METHOD__, '冻结删除波次号' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  263. }
  264. OracleDOCOrderHeader::where('orderno', $orderno)->update(['releasestatus' => 'H', 'waveno' => '*']);
  265. app('LogService')->log(__METHOD__, '冻结' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  266. return ['success' => true];
  267. }
  268. public function thaw(Request $request)
  269. {
  270. if (!Gate::allows('订单管理-编辑')) {
  271. return redirect(url('/'));
  272. }
  273. $orderno = $request->orderno;
  274. if (!is_array($orderno)) {
  275. $orderno = [$orderno];
  276. }
  277. OracleDOCOrderHeader::query()->whereIn('orderno', $orderno)->update(['releasestatus' => 'N']);
  278. app('LogService')->log(__METHOD__, '解冻' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  279. return ['success' => true];
  280. }
  281. //重置快递获取标记
  282. public function resetLogisticsGetMark(Request $request)
  283. {
  284. if (!Gate::allows('订单管理-编辑')) {
  285. return redirect(url('/'));
  286. }
  287. $orderno = $request->orderno;
  288. OracleDOCOrderHeader::query()->whereIn('orderno', $orderno)->where('edisendflag2', 'W')->update(['edisendflag2' => 'N']);
  289. app('LogService')->log(__METHOD__, '解冻' . __FUNCTION__, json_encode($orderno), Auth::user()['id']);
  290. return ['success' => true];
  291. }
  292. //取消分配
  293. public function deAllocation(Request $request)
  294. {
  295. if (!Gate::allows('订单管理-编辑')) {
  296. return redirect(url('/'));
  297. }
  298. $orderno = $request->input('orderno');
  299. $waveno = $request->input('waveno');
  300. if ($waveno && $waveno != '*') {
  301. OracleDOCWaveDetails::where('waveno', $waveno)->where('orderno', $orderno)->delete();
  302. app('LogService')->log(__METHOD__, '取消分配删除波次号' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  303. }
  304. OracleDOCOrderHeader::where('orderno', $orderno)->update(['sostatus' => '00', 'waveno' => '*']);
  305. app('LogService')->log(__METHOD__, '取消分配' . __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  306. $is_deAllocation = $this->isDeAllocation($orderno);
  307. if ($is_deAllocation) return ['success' => true];
  308. }
  309. //调用sp取消选中订单的分配
  310. public function isDeAllocation($orderno)
  311. {
  312. $username = config('database.connections.oracle.username');
  313. $password = config('database.connections.oracle.password');
  314. $host = config('database.connections.oracle.host');
  315. $service_name = config('database.connections.oracle.service_name');
  316. $conn = oci_connect($username, $password, $host . '/' . $service_name, 'utf8'); //连接oracle数据库
  317. $IN_Warehouse = '';
  318. $IN_Process_Action_C = '';
  319. $IN_Process_By_C = 'By OrderNO';
  320. $IN_WaveNO_C = '';
  321. $IN_OrderNO_C = $orderno;
  322. $IN_OrderLineNO_C = '';
  323. $IN_AllocationDetailsID = '';
  324. $IN_Language = '';
  325. $IN_UserID = '';
  326. $OUT_Return_Code = '';
  327. $sql_sp = "begin SPSO_DEALLOCATION_PROCESS(:IN_Warehouse,:IN_Process_Action_C,:IN_Process_By_C,
  328. :IN_WaveNO_C,:IN_OrderNO_C,:IN_OrderLineNO_C,:IN_AllocationDetailsID,:IN_Language,:IN_UserID,:OUT_Return_Code); end;";
  329. $stmt = oci_parse($conn, $sql_sp);
  330. oci_bind_by_name($stmt, ':IN_Warehouse', $IN_Process_Action_C);
  331. oci_bind_by_name($stmt, ':IN_Process_Action_C', $IN_Warehouse);
  332. oci_bind_by_name($stmt, ':IN_Process_By_C', $IN_Process_By_C);
  333. oci_bind_by_name($stmt, ':IN_WaveNO_C', $IN_WaveNO_C);
  334. oci_bind_by_name($stmt, ':IN_OrderNO_C', $IN_OrderNO_C);
  335. oci_bind_by_name($stmt, ':IN_OrderLineNO_C', $IN_OrderLineNO_C);
  336. oci_bind_by_name($stmt, ':IN_AllocationDetailsID', $IN_AllocationDetailsID);
  337. oci_bind_by_name($stmt, ':IN_Language', $IN_Language);
  338. oci_bind_by_name($stmt, ':IN_UserID', $IN_UserID);
  339. oci_bind_by_name($stmt, ':OUT_Return_Code', $OUT_Return_Code, 300);
  340. oci_execute($stmt);
  341. if (substr($OUT_Return_Code, 0, 3) != '000') {
  342. app('LogService')->log(__METHOD__, '调用sp根据订单取消分配失败' . __FUNCTION__, "ORDERNO:" . $orderno . "ERROR:" . $OUT_Return_Code);
  343. return false;
  344. }
  345. oci_close($conn);
  346. return true;
  347. }
  348. public function resetInterfaceReturnMark(Request $request)
  349. {
  350. if (!Gate::allows('订单管理-编辑')) {
  351. return redirect(url('/'));
  352. }
  353. $orderno = $request->orderno;
  354. $oldIds = OracleDOCOrderHeader::query()
  355. ->whereIn('orderno', $orderno)
  356. ->where('edisendflag', 'N')->pluck('orderno')->toArray();
  357. OracleDOCOrderHeader::query()
  358. ->whereIn('orderno', $orderno)
  359. ->where('sostatus', '99')
  360. ->whereIn('edisendflag', ['R', 'W'])
  361. ->where('addwho', 'EDI')
  362. ->update(['edisendflag' => 'N']);
  363. $failedOrdernos = OracleDOCOrderHeader::query()
  364. ->whereIn('orderno', $orderno)
  365. ->where('edisendflag', '!=', 'N')->pluck('orderno');
  366. $successedOrdernos = OracleDOCOrderHeader::query()
  367. ->whereIn('orderno', array_diff($orderno, $oldIds))
  368. ->where('edisendflag', 'N')->pluck('orderno');
  369. app('LogService')->log(__METHOD__, '重置接口回传标记' . __FUNCTION__, json_encode($orderno), Auth::user()['id']);
  370. if (count($failedOrdernos) == 0) {
  371. return ['success' => true];
  372. } else {
  373. return ['success' => false, 'fail_info' => "数据 {$failedOrdernos} 更新失败,数据{$successedOrdernos}更新成功"];
  374. }
  375. }
  376. /**
  377. * @param Request $request
  378. * @return array
  379. * 一键回传功能
  380. */
  381. public function manualBack(Request $request): array
  382. {
  383. if (!Gate::allows('订单管理-订单-一键回传')) return ["success" => false, "data" => "无权操作"];
  384. /** @var OrderService $orderService */
  385. $orderService = app(OrderService::class);
  386. $orderNos = $request->input('ordernos');
  387. $failNo = array();
  388. $successNo = array();
  389. $docOrders = OracleDOCOrderHeader::query()
  390. ->whereIn('orderno', $orderNos)
  391. ->get();
  392. /** @var OrderService $service */
  393. $service = app("OrderService");
  394. foreach ($docOrders as $order) {
  395. if ($order->sostatus == '00' || $order->sostatus == '10' || $order->sostatus == '20') {
  396. $res = $service->allocation($order->orderno, null, $order->warehouseid);
  397. if (mb_substr($res, 0, 3) != '000') {
  398. array_push($failNo, $order->orderno);
  399. app('LogService')->log(__METHOD__, '手动回传分配失败' . __FUNCTION__, json_encode($order->orderno), Auth::user()['id']);
  400. }
  401. }
  402. }
  403. foreach ($orderNos as $no) {
  404. $res = $orderService->manualBack($no);
  405. if (!$res) {
  406. array_push($failNo, $no);
  407. app('LogService')->log(__METHOD__, '人工回传失败' . __FUNCTION__, json_encode($no), Auth::user()['id']);
  408. } else {
  409. array_push($successNo, $no);
  410. }
  411. }
  412. if (count($orderNos) >= count($failNo)) return ["success" => true, "successNo" => $orderNos, "failNo" => $failNo];
  413. else return ["success" => false, "failNo" => $failNo];
  414. }
  415. public function allocation(Request $request): array
  416. {
  417. if (!Gate::allows('订单管理-编辑')) return ["status" => 'fail', "msg" => "无权操作"];
  418. $list = $request->input("list", []);
  419. $error = [];
  420. /** @var OrderService $service */
  421. $service = app("OrderService");
  422. $conn = null;
  423. foreach ($list as $item) {
  424. if (!$item["number"]) {
  425. $error[] = "'{$item["code"]}'尚未获取快递单号";
  426. continue;
  427. }
  428. if ((int)$item["status"] > 30) {
  429. $error[] = "'{$item["code"]}'已被分配";
  430. continue;
  431. }
  432. if (!$conn) $conn = $this->getFluxConnection();
  433. $res = $service->allocation($item["code"], null, $item["warehouse"], $conn);
  434. if (mb_substr($res, 0, 3) == '000') continue;
  435. $error[] = "'{$item["code"]}'{$res}";
  436. }
  437. if ($conn) $this->releaseFluxConnection($conn);
  438. if (!$error) return ["status" => 'success'];
  439. $txt = implode(",", $error);
  440. return ["status" => 'part', "msg" => $txt];
  441. }
  442. /**
  443. * 一键揽收分配
  444. * @param Request $request
  445. * @return array
  446. */
  447. public function collectUpload(Request $request): array
  448. {
  449. $inOrderno = $request->orderno;
  450. $strict = $request->strict;
  451. if (empty($inOrderno)) return ['success' => false, 'message' => '选择为空'];
  452. $orderno = deep_copy($inOrderno);
  453. /**
  454. * 是否是严格模式
  455. * 是
  456. * 根据筛选条件
  457. * 1. 状态 61 81
  458. * 2. 承运商是中通
  459. * 3. 有单号
  460. * 4. 有复核,
  461. * 5. 没揽收
  462. * 否
  463. * 筛选出快递单号
  464. * 将快递单号调用一键揽收
  465. * 如果返回异常,记录异常
  466. * 调用分配
  467. * 严格模式下:将入参与过滤结果取差集合,结果就是不复核的单号,作为错误提示返回
  468. */
  469. //严格模式,校验订单与包裹状态
  470. /** @var OrderService $orderService */
  471. $orderService = app('OrderService');
  472. foreach ($orderno as $no)$orderService->manualBack($no);
  473. $logisticNums = $orderService->getCollectUploadLogisticNumbers($strict, $orderno);
  474. if (!$logisticNums)return ["success"=>"揽收失败","message"=>"订单不允许发起揽收"];
  475. //调用一键揽收
  476. /** @var OrderPackageService $orderPackageService */
  477. $orderPackageService = app('OrderPackageService');
  478. $collectUpLoadResult = $orderPackageService->collectUpload($logisticNums->toArray());
  479. $error = [];
  480. //揽收有异常记录
  481. $collectFailed = (!$collectUpLoadResult['success']) ?? false;
  482. if ($collectFailed) {
  483. $error['collectUpload'] = $collectUpLoadResult['message'] ?? '';
  484. }
  485. $result = [];
  486. if (!empty($error)) {
  487. $result['success'] = false;
  488. $result['error_message'] = $error;
  489. } else if (!empty($errorOrderno)) {
  490. $result['success'] = false;
  491. $result['error_message'][] = $error;
  492. } else {
  493. $result['success'] = true;
  494. $result['message'] = '一键揽收完成';
  495. }
  496. return $result;
  497. }
  498. }