OrderIssueService.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589
  1. <?php
  2. namespace App\Services;
  3. use App\OracleDOCASNHeader;
  4. use App\OracleDOCOrderHeader;
  5. use App\OrderIssue;
  6. use App\OrderIssueProcessLog;
  7. use App\OrderIssueType;
  8. use App\OrderPackage;
  9. use App\Order;
  10. use App\RejectedBill;
  11. use App\RejectedBillItem;
  12. use Carbon\Carbon;
  13. use Illuminate\Http\Request;
  14. use Illuminate\Support\Facades\Auth;
  15. use Illuminate\Support\Facades\Validator;
  16. use Ramsey\Uuid\Uuid;
  17. class OrderIssueService
  18. {
  19. public function __construct()
  20. {
  21. app()->bind("orderService", OrderService::class);
  22. app()->bind("rejectedService", RejectedService::class);
  23. app()->bind("orderPackageCommoditiesService", OrderPackageCommoditiesService::class);
  24. }
  25. public function insert($params)
  26. {
  27. OrderIssue::query()->insert($params);
  28. }
  29. public function getQuery(array $arr, array $condition = null)
  30. {
  31. if (!isset($condition)) {
  32. $condition = $arr;
  33. }
  34. $user = Auth::user();
  35. $owner_ids = $user ? app('UserService')->getPermittingOwnerIds($user) : [];
  36. if ($condition['owner_id'] ?? false) {
  37. $owner_ids = explode(',', $condition['owner_id']);
  38. }
  39. $query = OrderIssue::with(['top', 'userWorkGroup', 'issueType', 'logs' => function ($query) use ($arr) {
  40. $query->with('user')->orderByDesc('created_at');
  41. }, 'order' => function ($query) {
  42. $query->with(['shop', 'logistic', 'owner', 'packages.commodities.commodity' => function ($query) {
  43. $query->with('barcodes');
  44. }]);
  45. }, 'rejectedBill' => function ($query) {
  46. $query->with(['items']);
  47. }, 'secondOrder' => function ($query) {
  48. $query->with(['shop', 'logistic', 'owner', 'packages.commodities.commodity' => function ($query) {
  49. $query->with('barcodes');
  50. }]);
  51. }])->whereHas('order.owner', function ($query) use ($owner_ids) {
  52. $query->whereIn('id', $owner_ids);
  53. });
  54. if ($arr['log_content'] ?? false) {
  55. $query->whereHas('logs', function ($query) use ($arr) {
  56. $query->where('content', 'like', $arr['log_content']);
  57. if ($arr['addtime'] ?? false) {
  58. $query->where('created_at', '>=', Carbon::now()->subDays($arr['addtime']));
  59. } else {
  60. $query->where('created_at', '>=', Carbon::now()->subDays(31));
  61. }
  62. });
  63. }
  64. if (isset($arr['is_imported'])) {
  65. $query->where('imported_status', $arr['is_imported']);
  66. }
  67. if (isset($arr['is_new_rejecting'])) {
  68. $query->where('is_new_rejecting', '=', $arr['is_new_rejecting']);
  69. }
  70. if (isset($arr['logistic_id'])) {
  71. $query->whereHas('order', function ($query) use ($arr) {
  72. $query->where('logistic_id', $arr['logistic_id']);
  73. });
  74. }
  75. if (isset($arr['custom_code'])) {
  76. $query->where('custom_code', $arr['custom_code']);
  77. }
  78. $query->selectRaw('order_issues.* ,order_issue_on_tops.id top_id ,order_issue_on_tops.remark,order_issue_on_tops.updated_at top_update')
  79. ->leftJoin('order_issue_on_tops', 'order_issue_on_tops.order_issue_id', '=', 'order_issues.id')
  80. ->whereNull('order_issue_on_tops.deleted_at')
  81. ->orderBy('order_issue_on_tops.updated_at', 'desc');
  82. $query->orderBy('order_issues.id', 'desc');
  83. return $query;
  84. }
  85. private function getOrderQuery(array $arr, $query)
  86. {
  87. $query->whereHas('order', function ($query) use ($arr) {
  88. if ($arr['client_code'] ?? false) {
  89. return $this->searchWay($query, $arr['client_code'], 'client_code');
  90. }
  91. if ($arr['consignee_name'] ?? false) {
  92. return $this->searchWay($query, $arr['consignee_name'], 'consignee_name');
  93. }
  94. if ($arr['consignee_phone'] ?? false) {
  95. return $this->searchWay($query, $arr['consignee_phone'], 'consignee_phone');
  96. }
  97. if ($arr['logistic_number'] ?? false) {
  98. $logistic_number = $arr['logistic_number'];
  99. $query->whereHas('packages', function ($query) use ($logistic_number) {
  100. return $this->searchWay($query, $logistic_number, 'logistic_number');
  101. });
  102. }
  103. if (($arr['good_barcode'] ?? false) || ($arr['good_name'] ?? false)) {
  104. $query->whereHas('packages.commodities.commodity', function ($query) use ($arr) {
  105. if ($arr['good_barcode'] ?? false) {
  106. return $this->searchWay($query, $arr['good_barcode'], 'sku');
  107. }
  108. if ($arr['good_name'] ?? false) {
  109. $query->where('name', 'like', '%' . $arr['good_name'] . '%');
  110. }
  111. });
  112. }
  113. });
  114. if ($arr['send_client_code'] ?? false) {
  115. $query->whereHas('secondOrder', function ($query) use ($arr) {
  116. return $this->searchWay($query, $arr['send_client_code'], 'client_code');
  117. });
  118. }
  119. return $query;
  120. }
  121. public function getRejectedBillQuery(array $arr, $query)
  122. {
  123. if (($arr['logistic_number_return'] ?? false) || ($arr['id_quality_label'] ?? false)) {
  124. $query->whereHas('rejectedBill', function ($query) use (&$arr) {
  125. if ($arr['logistic_number_return'] ?? false) {
  126. return $this->searchWay($query, $arr['logistic_number_return'], 'logistic_number_return');
  127. }
  128. if ($arr['id_quality_label'] ?? false) {
  129. $query->whereHas('items', function ($query) use ($arr) {
  130. $query->where('id_quality_label', $arr['id_quality_label']);
  131. });
  132. }
  133. });
  134. }
  135. return $query;
  136. }
  137. public function getConditionQuery(array $arr, array $condition = null)
  138. {
  139. $query = $this->getQuery($arr, $condition);
  140. $query = $this->getOrderQuery($condition ?? $arr, $query);
  141. $query = $this->getRejectedBillQuery($condition ?? $arr, $query);
  142. if (!isset($condition)) {
  143. $condition = $arr;
  144. }
  145. if ($condition['id'] ?? false) {
  146. $query->whereIn('order_issues.id', explode(',', $condition['id']));
  147. }
  148. if (isset($condition['created_at_start'])) {
  149. $query->where('order_issues.created_at', '>=', $condition['created_at_start'] . " 00:00:00");
  150. }
  151. if (isset($condition['created_at_end'])) {
  152. $query->where('order_issues.created_at', '<=', $condition['created_at_end'] . " 23:59:59");
  153. }
  154. if (isset($condition['final_status'])) {
  155. if ($condition['final_status'] == 'null') {
  156. $query->whereNull('final_status');
  157. } else {
  158. $query->where('final_status', $condition['final_status']);
  159. }
  160. }
  161. if (isset($condition['order_issue_type_id'])) {
  162. $query->where('order_issue_type_id', $condition['order_issue_type_id']);
  163. }
  164. if (!($condition['is_handle'] ?? false) && !($condition['final_status'] ?? false)) {
  165. if (!(isset($condition['settlement_at_start']) || isset($condition['settlement_at_end']))) {
  166. $query->where(function ($query) {
  167. $query->where('final_status', '<>', '已解决')->orWhereNull('final_status');
  168. });
  169. }
  170. }
  171. if (isset($condition['logistic_indemnity_money'])) {
  172. $query->where('logistic_indemnity_money', $condition['logistic_indemnity_money']);
  173. }
  174. if (isset($condition['baoshi_indemnity_money'])) {
  175. $query->where('baoshi_indemnity_money', $condition['baoshi_indemnity_money']);
  176. }
  177. if (isset($condition['order_issue_ids'])) {
  178. $orderIssuesId = $condition['order_issue_ids'];
  179. if (is_string($orderIssuesId)) {
  180. $orderIssuesId = explode(',', $orderIssuesId);
  181. }
  182. $query->whereIn('order_issues.id', $orderIssuesId);
  183. }
  184. if (isset($condition['settlement_at_start']) || isset($condition['settlement_at_end'])) {
  185. $query->whereHas('logs', function ($query) use ($condition) {
  186. if (isset($condition['settlement_at_start'])) {
  187. $query->where('created_at', '>=', $condition['settlement_at_start'] . ' 00:00:00')->where('type', '结束');
  188. }
  189. if (isset($condition['settlement_at_end'])) {
  190. $query->where('created_at', '<=', $condition['settlement_at_end'] . ' 23:59:59')->where('type', '结束');
  191. }
  192. });
  193. }
  194. return $query;
  195. }
  196. private function isSearchLike($str)
  197. {
  198. if (substr($str, 0, 1) == "%" || substr($str, strlen($str) - 1, 1) == "%") {
  199. return true;
  200. }
  201. return false;
  202. }
  203. private function searchWay($query, $param, $column)
  204. {
  205. if ($this->isSearchLike($param)) {
  206. $query->where($column, 'like', $param);
  207. } else {
  208. $query->whereIn($column, array_filter(preg_split('/[,, ]+/is', $param)));
  209. }
  210. return $query;
  211. }
  212. public function getSqlList(array $params)
  213. {
  214. $orderPackageSql = OrderPackage::query()->selectRaw('order_packages.logistic_number order_package_logistic_number')
  215. ->leftJoin('order_package_commodities','order_packages.id','order_package_commodities.order_package_id')
  216. ->selectRaw('order_package_commodities.amount commodity_amount')
  217. ->leftJoin('commodities','order_package_commodities.commodity_id','commodities.id')
  218. ->selectRaw('commodities.name commodity_name,commodities.sku commodity_sku')
  219. ->leftJoin('order_issues','order_packages.order_id','order_issues.order_id')
  220. ->selectRaw('order_issues.id order_issue_id')
  221. ->sql();
  222. $secondOrderPackageSql = Order::query()->from('order_packages','s_o_p')->selectRaw('s_o_p.logistic_number')
  223. ->leftJoin("orders as o_d","s_o_p.order_id","o_d.id")
  224. ->leftJoin('order_package_commodities as s_o_p_c','s_o_p_c.order_package_id','s_o_p.id')
  225. ->selectRaw('s_o_p_c.amount s_o_p_c_amount')
  226. ->leftJoin('commodities as s_c','s_o_p_c.commodity_id','s_c.id')
  227. ->selectRaw('s_c.sku s_c_sku,s_c.name s_c_name')
  228. ->leftJoin('order_issues','o_d.client_code','order_issues.second_client_no')
  229. ->selectRaw('order_issues.id order_issue_id')
  230. ->sql();
  231. $rejectedBillItemSql = RejectedBillItem::query()->selectRaw('rejected_bill_items.remark,rejected_bill_items.amount rejected_bill_amount,rejected_bill_items.name_goods,rejected_bill_items.barcode_goods')
  232. ->leftJoin('rejected_bills',"rejected_bill_items.id_rejected_bill","rejected_bills.id")
  233. ->leftJoin('order_issues','rejected_bills.logistic_number_return','order_issues.logistic_number_return')
  234. ->selectRaw('order_issues.id order_issue_id')
  235. ->sql();
  236. $logSql = OrderIssueProcessLog::query()->selectRaw('order_issue_process_logs.content log_content,order_issue_process_logs.type log_type')
  237. ->leftJoin('users','order_issue_process_logs.user_id','users.id')
  238. ->selectRaw('users.name user_name')
  239. ->leftJoin('order_issues','order_issue_process_logs.order_issue_id','order_issues.id')
  240. ->selectRaw('order_issues.id order_issue_id')
  241. ->sql();
  242. $column = "order_issues.id,order_issues.rejected_bill_id,order_issues.rejecting_status,order_issues.created_at order_issues_created_at,order_issues.result_explain,order_issues.final_status,";
  243. $column .= "order_issues.logistic_indemnity_money,order_issues.logistic_express_remission,order_issues.baoshi_indemnity_money,order_issues.baoshi_express_remission";
  244. $orderIssueSql = $this->getConditionQuery($params)->selectRaw($column)
  245. ->leftJoin('order_issue_types','order_issues.order_issue_type_id','order_issue_types.id')
  246. ->selectRaw('order_issue_types.`name` order_issue_type_name')
  247. ->leftJoin('orders','order_issues.order_id','orders.id')
  248. ->selectRaw('orders.id order_id,orders.address,orders.district,orders.city,orders.province,orders.consignee_phone,orders.consignee_name,orders.client_code,orders.created_at order_created_at')
  249. ->leftJoin('logistics','logistics.id','orders.logistic_id')
  250. ->selectRaw('logistics.name logistic_name')
  251. ->leftJoin('owners','owners.id','orders.owner_id')
  252. ->selectRaw('owners.name owner_name')
  253. ->leftJoin('shops','orders.shop_id','shops.id')
  254. ->selectRaw('shops.name shop_name')
  255. ->leftJoin('orders as s_o','s_o.client_code','order_issues.second_client_no')
  256. ->selectRaw('s_o.id s_o_id,s_o.client_code s_o_client_code')
  257. ->leftJoin('logistics as s_logistics','s_o.logistic_id','s_logistics.id')
  258. ->selectRaw('s_logistics.name s_logistics_name')
  259. ->leftJoin('user_workgroups','user_workgroups.id','order_issues.user_workgroup_id')
  260. ->selectRaw('user_workgroups.name user_workgroup_name')
  261. ->sql();
  262. return compact('orderPackageSql','secondOrderPackageSql','orderIssueSql','rejectedBillItemSql','logSql');
  263. }
  264. public function paginate(array $params)
  265. {
  266. return $query = $this->getConditionQuery($params)->paginate($params['paginate'] ?? 50);
  267. }
  268. public function orderIssueTag(array $params)
  269. {
  270. $orderNos = $params['orderNos'];
  271. $orderHeaders = OracleDOCOrderHeader::query()->with(['oracleDOCOrderDetails', 'actAllocationDetails', 'oracleBASCode'])->whereIn('orderNo', $orderNos)->get();
  272. $bool = $this->createOrderIssueByWmsOrder($orderHeaders, $params['typeId'], $params['result_explain']);
  273. if ($bool) {
  274. return ['success' => $bool];
  275. } else {
  276. return ['success' => $bool, 'fail_info' => '问题件创建失败'];
  277. }
  278. }
  279. public function createOrderIssueByWmsOrder($orderHeaders, $order_issue_type_id, $result_explain, $imported_status = '正常', $custom_code = null)
  280. {
  281. /** @var OrderService $orderService */
  282. $orderService = app('OrderService');
  283. // $orderService->updateByWmsOrders($orderHeaders);
  284. // $orders = $orderService->getByWmsOrders($orderHeaders);
  285. $orderService->createByWmsOrder($orderHeaders);
  286. $orders = Order::query()->whereIn('code',data_get($orderHeaders,'*.orderno'))->whereHas('packages')->get();
  287. $innerParams = [];
  288. if($orders->count()>0){
  289. foreach ($orderHeaders as $orderHeader) {
  290. $order = $orders->where('code',$orderHeader->orderno)->first();
  291. if($order==null){
  292. $order = Order::query()->where('code',$orderHeader->orderno)->first();
  293. }
  294. $innerParams[] = [
  295. 'order_id' => $order->id,
  296. 'order_issue_type_id' => $order_issue_type_id,
  297. 'result_explain' => $result_explain,
  298. 'imported_status' => $imported_status,
  299. 'custom_code' => $custom_code
  300. ];
  301. }
  302. }
  303. try {
  304. $this->insert($innerParams);
  305. $ordersIssues = OrderIssue::query()->whereIn('order_id', data_get($innerParams, '*.order_id'))->get();
  306. $this->同步退单状态($ordersIssues);
  307. $param = [
  308. 'ids' => data_get($ordersIssues, '*.id'),
  309. 'content' => '',
  310. 'user_id' => Auth::user()['id'],
  311. 'type' => '创建'
  312. ];
  313. app(OrderIssueProcessLogService::class)->create($param);
  314. app('LogService')->log(__METHOD__, __FUNCTION__, '创建问题件' . count($innerParams) . json_encode($innerParams));
  315. return true;
  316. } catch (\Exception $e) {
  317. app('LogService')->log(__METHOD__, __FUNCTION__, '创建问题件 error' . count($innerParams) . json_encode($innerParams) . $e->getMessage() . $e->getTraceAsString());
  318. return false;
  319. }
  320. }
  321. public function 同步退单状态($orderIssues)
  322. {
  323. if(!$orderIssues)return;
  324. foreach ($orderIssues as $orderIssue) {
  325. $orderIssue->syncRejectedBill();
  326. $orderIssue->同步退单状态();
  327. }
  328. }
  329. public function createOrFindByOrderNo($orderNo)
  330. {
  331. $orderHeader = OracleDOCOrderHeader::query()->where('orderNo', $orderNo)->first();
  332. if (!$orderHeader) {
  333. return null;
  334. }
  335. return $this->createOrFind($orderHeader['soreference1']);
  336. }
  337. public function createOrFind($clientCode)
  338. {
  339. /** @var OrderService $orderService */
  340. $orderService = app('OrderService');
  341. $orderHeader = OracleDOCOrderHeader::query()->where('SOReference1', $clientCode)->first();
  342. if ($orderHeader === null) {
  343. return null;
  344. }
  345. $order = $orderService->findOrCreateByClientCode($clientCode);
  346. $rejectedBill = RejectedBill::query()->where('order_number', $orderHeader['soreference1'])->first();
  347. if ($rejectedBill === null) {
  348. $asnHeader = OracleDOCASNHeader::query()->where('ASNReference2', $orderHeader['soreference1'])->first();
  349. if ($asnHeader['asnreference3'] ?? false) {
  350. $rejectedBill = RejectedBill::query()->where('logistic_number_return', $asnHeader['asnreference3'])->first();
  351. }
  352. }
  353. $arr = [
  354. 'order_id' => $order['id'],
  355. 'logistic_number_return' => $rejectedBill['logistic_number_return'] ?? '',
  356. ];
  357. $orderIssue = null;
  358. try {
  359. $orderIssue = OrderIssue::query()->create($arr);
  360. $orderIssue->同步退单状态();
  361. $orderIssue->order = $order;
  362. app('LogService')->log(__METHOD__, __FUNCTION__, '创建问题件' . json_encode($orderIssue));
  363. } catch (\Exception $e) {
  364. app('LogService')->log(__METHOD__, __FUNCTION__, '创建问题件error' . json_encode($arr) . $e->getMessage() . $e->getTraceAsString());
  365. } finally {
  366. unset($orderHeader, $rejectedBill, $order);
  367. return $orderIssue;
  368. }
  369. }
  370. public function validatorCreate(Request $request)
  371. {
  372. return Validator::make($request->input(), [
  373. 'rejected_bill_id' => ['nullable'],
  374. 'order_id' => ['nullable'],
  375. 'owner_id' => ['required'],
  376. 'second_order_id' => ['nullable'],
  377. 'logistic_id' => ['nullable'],
  378. 'order_issue_type_id' => ['required'],
  379. 'baoshi_indemnity_money' => ['numeric', 'nullable'],
  380. 'logistic_indemnity_money' => ['numeric', 'nullable'],
  381. 'final_status' => ['nullable'],
  382. 'result_explain' => ['nullable']
  383. ], [
  384. 'required' => ':attribute 为必填项',
  385. 'unique' => ':attribute 已存在',
  386. 'numeric' => ':attribute 为数组',
  387. ], [
  388. 'owner_id' => '货主',
  389. 'rejected_bill_id' => '退回单号',
  390. 'order_id' => '订单ID',
  391. 'second_order_id' => '退回订单id',
  392. 'logistic_id' => '承运人',
  393. 'order_issue_type_id' => '问题类别',
  394. 'baoshi_indemnity_money' => '宝时赔偿金额',
  395. 'logistic_indemnity_money' => '承运商赔偿金额',
  396. 'final_status' => '最终状态',
  397. 'result_explain' => '处理结果说明',
  398. ]);
  399. }
  400. public function create(array $arr)
  401. {
  402. $orderIssue = OrderIssue::query()->create($arr);
  403. if (!$arr['order_id']) {
  404. $order = Order::query()->create($arr);
  405. $orderIssue->order_id = $order['id'];
  406. $orderIssue->save();
  407. app('LogService')->log(__METHOD__,__FUNCTION__,'创建 Order'.json_encode($order));
  408. }
  409. $orderIssue->同步退单状态();
  410. return $orderIssue;
  411. }
  412. public function createByLogisticNumber(array $arr)
  413. {
  414. $order = new Order($arr);
  415. $order['code']='null_'.Uuid::uuid4();
  416. $order->save();
  417. app('LogService')->log(__METHOD__,__FUNCTION__,'创建 Order'.json_encode($order));
  418. $orderIssue = OrderIssue::query()->create($arr);
  419. $orderIssue['order_id'] = $order['id'];
  420. OrderPackage::query()->create(['order_id' => $order['id'], 'logistic_number' => $arr['logistic_number_return']]);
  421. $orderIssue->同步退单状态();
  422. $orderIssue->update(['order_id' => $order['id']]);
  423. return $orderIssue;
  424. }
  425. public function batchDestroy($ids)
  426. {
  427. try {
  428. $bool = OrderIssue::query()->whereIn('id', $ids)->delete();
  429. app('LogService')->log(__METHOD__, __FUNCTION__, json_encode($ids));
  430. return ['success' => $bool];
  431. } catch (\Exception $e) {
  432. app('LogService')->log(__METHOD__, __FUNCTION__, 'error' . json_decode($ids) . '||' . $e->getMessage() . '||' . $e->getTraceAsString());
  433. return ['success' => false];
  434. }
  435. }
  436. public function endOrderIssues(array $ids)
  437. {
  438. return OrderIssue::query()->whereIn('id', $ids)->update(['final_status' => '已解决']);
  439. }
  440. public function isExistOrderIssueTypeIsEnd($ids)
  441. {
  442. return OrderIssue::query()->whereIn('id', $ids)->where('final_status', '已解决')->count() > 0;
  443. }
  444. public function editOrderIssueSecondClientNo($id, $secondClientNo, &$order = null)
  445. {
  446. $order = Order::query()->where('client_code', $secondClientNo)->first();
  447. if (!$order) {
  448. /** @var OrderService $orderService */
  449. $orderService = app(OrderService::class);
  450. $orderHeaders = OracleDOCOrderHeader::query()->where('SoReference1', $secondClientNo)->get();
  451. $orders = $orderService->createByWmsOrder($orderHeaders);
  452. if ($orders->count() > 0) $order = $orders->first();
  453. }
  454. return OrderIssue::query()->where('id', $id)->update(['second_client_no' => $secondClientNo]) > 0;
  455. }
  456. public function updateSecondLogisticNumber($id, $logisticNumber)
  457. {
  458. $orderIssue = OrderIssue::query()->where('id', $id)->first();
  459. $order = app(OrderService::class)->getOrderByLogisticNumber($logisticNumber);
  460. if (!$order) {
  461. $orderIssue->update(['second_logistic_number' => $logisticNumber]);
  462. return ['success' => true, 'second_logistic_number' => $logisticNumber];
  463. }
  464. $orderIssue->update(['second_client_no' => $order->client_code]);
  465. $order = Order::query()->with(['packages.commodities.commodity', 'logistic'])
  466. ->where('id', $order->id)->first();
  467. return ['success' => true, 'order' => $order];
  468. }
  469. public function createOrderIssue($logisticNumber, $type, $result_explain, $importedStatus = '正常', $custom_code = null)
  470. {
  471. $orderHeaders = OracleDOCOrderHeader::query()->with(['oracleDOCOrderDetails', 'actAllocationDetails', 'oracleBASCode'])
  472. ->whereHas('actAllocationDetails', function ($query) use ($logisticNumber) {
  473. $query->where('picktotraceid', $logisticNumber);
  474. })->get();
  475. $orderIssueType = OrderIssueType::query()->where('name', $type)->first();
  476. return $this->createOrderIssueByWmsOrder($orderHeaders, $orderIssueType->id, $result_explain, $importedStatus, $custom_code);
  477. }
  478. /**
  479. * @param array $logisticNumbers
  480. * @return array
  481. */
  482. public function 校验问题件是否存在_快递单号_返回存在的快递单号($logisticNumbers)
  483. {
  484. $orderIssues = OrderIssue::query()->with('order.packages')->whereHas('order.packages', function ($query) use ($logisticNumbers) {
  485. $query->whereIn('logistic_number', $logisticNumbers);
  486. })->get();
  487. $exits_logistic_number = array_diff(array_unique(data_get($orderIssues, '*.order.packages.*.logistic_number')), ['', null]);
  488. return array_intersect($exits_logistic_number, $logisticNumbers);
  489. }
  490. /**
  491. * @param array $orderNos
  492. * @return array
  493. */
  494. public function 校验问题件是否存在_WMS订单号_返回存在的订单号($orderNos)
  495. {
  496. $orderIssues = OrderIssue::query()->with('order')->whereHas('order', function ($query) use ($orderNos) {
  497. $query->whereIn('code', $orderNos);
  498. })->get();
  499. $exits_logistic_number = array_diff(array_unique(data_get($orderIssues, '*.order.code')), ['', null]);
  500. return array_intersect($exits_logistic_number, $orderNos);
  501. }
  502. /**
  503. * 导入处理字段
  504. * @param array $ids
  505. * @return array|bool[]
  506. */
  507. public function disposeImport(array $ids)
  508. {
  509. $orderIssues = OrderIssue::query()->with('order')->whereIn('id', $ids)->get();
  510. if ($orderIssues->count()<count($ids)) {
  511. $is_exits_ids = array_diff($ids, data_get($orderIssues, '*.code'));
  512. return ['success' => false, 'fail_info' => json_encode($is_exits_ids) . '没有存在对应的问题件'];
  513. }
  514. if ($orderIssues->where('imported_status', '导入已梳理')->count() > 0) {
  515. $is_dispose_orderNos = data_get($orderIssues->where('imported_status', '导入已梳理'), '*.order.code');
  516. return ['success' => false, 'fail_info' => json_encode($is_dispose_orderNos) . '导入已处理'];
  517. }
  518. try {
  519. OrderIssue::query()->whereIn('id', $ids)->update(['imported_status' => '导入已梳理']);
  520. app('LogService')->log(__METHOD__,__FUNCTION__,'导入处理 '.json_encode($ids).'导入处理');
  521. return ['success' => true];
  522. } catch (\Exception $e) {
  523. app('LogService')->log(__METHOD__,__FUNCTION__,'导入处理 error'.json_encode($e->getMessage()).$e->getTraceAsString());
  524. return ['success' => false,'fail_info'=>$e->getMessage()];
  525. }
  526. }
  527. public function getJsonObj(array $params)
  528. {
  529. return $this->getConditionQuery($params)->get();
  530. }
  531. public function getRecycleBinPaginate($params){
  532. return OrderIssue::query()
  533. ->with(['order'=>function($query){
  534. $query->with(['logistic','shop','owner','packages'=>function($query){
  535. $query->with('commodities');
  536. }]);
  537. },'rejectedBill.items','issueType','secondOrder.packages.commodities'])->onlyTrashed()->paginate($params['paginate'] ?? 50);
  538. }
  539. public function recoverOrderIssue($ids)
  540. {
  541. try {
  542. $bool = OrderIssue::query()->withTrashed()->whereIn('id', $ids)->restore();
  543. app('LogService')->log(__METHOD__, __FUNCTION__, '恢复问题件 ids = ' . json_encode($ids));
  544. return ['success'=>$bool];
  545. } catch (\Exception $e) {
  546. app('LogService')->log(__METHOD__, 'ERROR '.__FUNCTION__, '恢复问题件 Error' . json_encode($ids).' || '.json_encode($e->getMessage()).' || '.json_encode($e->getTraceAsString()));
  547. return ['success'=>false,'error'=>$e->getMessage()];
  548. }
  549. }
  550. }