OrderIssueService.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597
  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. if($condition['logistic_indemnity_money']== '是'){
  173. $query->whereNotNull('logistic_indemnity_money');
  174. }elseif($condition['logistic_indemnity_money']== '否'){
  175. $query->whereNull('logistic_indemnity_money');
  176. }
  177. }
  178. if (isset($condition['baoshi_indemnity_money'])) {
  179. if($condition['baoshi_indemnity_money']== '是'){
  180. $query->whereNotNull('baoshi_indemnity_money');
  181. }elseif($condition['baoshi_indemnity_money']== '否'){
  182. $query->whereNull('baoshi_indemnity_money');
  183. }
  184. }
  185. if (isset($condition['order_issue_ids'])) {
  186. $orderIssuesId = $condition['order_issue_ids'];
  187. if (is_string($orderIssuesId)) {
  188. $orderIssuesId = explode(',', $orderIssuesId);
  189. }
  190. $query->whereIn('order_issues.id', $orderIssuesId);
  191. }
  192. if (isset($condition['settlement_at_start']) || isset($condition['settlement_at_end'])) {
  193. $query->whereHas('logs', function ($query) use ($condition) {
  194. if (isset($condition['settlement_at_start'])) {
  195. $query->where('created_at', '>=', $condition['settlement_at_start'] . ' 00:00:00')->where('type', '结束');
  196. }
  197. if (isset($condition['settlement_at_end'])) {
  198. $query->where('created_at', '<=', $condition['settlement_at_end'] . ' 23:59:59')->where('type', '结束');
  199. }
  200. });
  201. }
  202. return $query;
  203. }
  204. private function isSearchLike($str)
  205. {
  206. if (substr($str, 0, 1) == "%" || substr($str, strlen($str) - 1, 1) == "%") {
  207. return true;
  208. }
  209. return false;
  210. }
  211. private function searchWay($query, $param, $column)
  212. {
  213. if ($this->isSearchLike($param)) {
  214. $query->where($column, 'like', $param);
  215. } else {
  216. $query->whereIn($column, array_filter(preg_split('/[,, ]+/is', $param)));
  217. }
  218. return $query;
  219. }
  220. public function getSqlList(array $params)
  221. {
  222. $orderPackageSql = OrderPackage::query()->selectRaw('order_packages.logistic_number order_package_logistic_number')
  223. ->leftJoin('order_package_commodities','order_packages.id','order_package_commodities.order_package_id')
  224. ->selectRaw('order_package_commodities.amount commodity_amount')
  225. ->leftJoin('commodities','order_package_commodities.commodity_id','commodities.id')
  226. ->selectRaw('commodities.name commodity_name,commodities.sku commodity_sku')
  227. ->leftJoin('order_issues','order_packages.order_id','order_issues.order_id')
  228. ->selectRaw('order_issues.id order_issue_id')
  229. ->sql();
  230. $secondOrderPackageSql = Order::query()->from('order_packages','s_o_p')->selectRaw('s_o_p.logistic_number')
  231. ->leftJoin("orders as o_d","s_o_p.order_id","o_d.id")
  232. ->leftJoin('order_package_commodities as s_o_p_c','s_o_p_c.order_package_id','s_o_p.id')
  233. ->selectRaw('s_o_p_c.amount s_o_p_c_amount')
  234. ->leftJoin('commodities as s_c','s_o_p_c.commodity_id','s_c.id')
  235. ->selectRaw('s_c.sku s_c_sku,s_c.name s_c_name')
  236. ->leftJoin('order_issues','o_d.client_code','order_issues.second_client_no')
  237. ->selectRaw('order_issues.id order_issue_id')
  238. ->sql();
  239. $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')
  240. ->leftJoin('rejected_bills',"rejected_bill_items.id_rejected_bill","rejected_bills.id")
  241. ->leftJoin('order_issues','rejected_bills.logistic_number_return','order_issues.logistic_number_return')
  242. ->selectRaw('order_issues.id order_issue_id')
  243. ->sql();
  244. $logSql = OrderIssueProcessLog::query()->selectRaw('order_issue_process_logs.content log_content,order_issue_process_logs.type log_type')
  245. ->leftJoin('users','order_issue_process_logs.user_id','users.id')
  246. ->selectRaw('users.name user_name')
  247. ->leftJoin('order_issues','order_issue_process_logs.order_issue_id','order_issues.id')
  248. ->selectRaw('order_issues.id order_issue_id')
  249. ->sql();
  250. $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,";
  251. $column .= "order_issues.logistic_indemnity_money,order_issues.logistic_express_remission,order_issues.baoshi_indemnity_money,order_issues.baoshi_express_remission";
  252. $orderIssueSql = $this->getConditionQuery($params)->selectRaw($column)
  253. ->leftJoin('order_issue_types','order_issues.order_issue_type_id','order_issue_types.id')
  254. ->selectRaw('order_issue_types.`name` order_issue_type_name')
  255. ->leftJoin('orders','order_issues.order_id','orders.id')
  256. ->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')
  257. ->leftJoin('logistics','logistics.id','orders.logistic_id')
  258. ->selectRaw('logistics.name logistic_name')
  259. ->leftJoin('owners','owners.id','orders.owner_id')
  260. ->selectRaw('owners.name owner_name')
  261. ->leftJoin('shops','orders.shop_id','shops.id')
  262. ->selectRaw('shops.name shop_name')
  263. ->leftJoin('orders as s_o','s_o.client_code','order_issues.second_client_no')
  264. ->selectRaw('s_o.id s_o_id,s_o.client_code s_o_client_code')
  265. ->leftJoin('logistics as s_logistics','s_o.logistic_id','s_logistics.id')
  266. ->selectRaw('s_logistics.name s_logistics_name')
  267. ->leftJoin('user_workgroups','user_workgroups.id','order_issues.user_workgroup_id')
  268. ->selectRaw('user_workgroups.name user_workgroup_name')
  269. ->sql();
  270. return compact('orderPackageSql','secondOrderPackageSql','orderIssueSql','rejectedBillItemSql','logSql');
  271. }
  272. public function paginate(array $params)
  273. {
  274. return $query = $this->getConditionQuery($params)->paginate($params['paginate'] ?? 50);
  275. }
  276. public function orderIssueTag(array $params)
  277. {
  278. $orderNos = $params['orderNos'];
  279. $orderHeaders = OracleDOCOrderHeader::query()->with(['oracleDOCOrderDetails', 'actAllocationDetails', 'oracleBASCode'])->whereIn('orderNo', $orderNos)->get();
  280. $bool = $this->createOrderIssueByWmsOrder($orderHeaders, $params['typeId'], $params['result_explain']);
  281. if ($bool) {
  282. return ['success' => $bool];
  283. } else {
  284. return ['success' => $bool, 'fail_info' => '问题件创建失败'];
  285. }
  286. }
  287. public function createOrderIssueByWmsOrder($orderHeaders, $order_issue_type_id, $result_explain, $imported_status = '正常', $custom_code = null)
  288. {
  289. /** @var OrderService $orderService */
  290. $orderService = app('OrderService');
  291. // $orderService->updateByWmsOrders($orderHeaders);
  292. // $orders = $orderService->getByWmsOrders($orderHeaders);
  293. $orderService->createByWmsOrder($orderHeaders);
  294. $orders = Order::query()->whereIn('code',data_get($orderHeaders,'*.orderno'))->whereHas('packages')->get();
  295. $innerParams = [];
  296. if($orders->count()>0){
  297. foreach ($orderHeaders as $orderHeader) {
  298. $order = $orders->where('code',$orderHeader->orderno)->first();
  299. if($order==null){
  300. $order = Order::query()->where('code',$orderHeader->orderno)->first();
  301. }
  302. $innerParams[] = [
  303. 'order_id' => $order->id,
  304. 'order_issue_type_id' => $order_issue_type_id,
  305. 'result_explain' => $result_explain,
  306. 'imported_status' => $imported_status,
  307. 'custom_code' => $custom_code
  308. ];
  309. }
  310. }
  311. try {
  312. $this->insert($innerParams);
  313. $ordersIssues = OrderIssue::query()->whereIn('order_id', data_get($innerParams, '*.order_id'))->get();
  314. $this->同步退单状态($ordersIssues);
  315. $param = [
  316. 'ids' => data_get($ordersIssues, '*.id'),
  317. 'content' => '',
  318. 'user_id' => Auth::user()['id'],
  319. 'type' => '创建'
  320. ];
  321. app(OrderIssueProcessLogService::class)->create($param);
  322. app('LogService')->log(__METHOD__, __FUNCTION__, '创建问题件' . count($innerParams) . json_encode($innerParams));
  323. return true;
  324. } catch (\Exception $e) {
  325. app('LogService')->log(__METHOD__, __FUNCTION__, '创建问题件 error' . count($innerParams) . json_encode($innerParams) . $e->getMessage() . $e->getTraceAsString());
  326. return false;
  327. }
  328. }
  329. public function 同步退单状态($orderIssues)
  330. {
  331. if(!$orderIssues)return;
  332. foreach ($orderIssues as $orderIssue) {
  333. $orderIssue->syncRejectedBill();
  334. $orderIssue->同步退单状态();
  335. }
  336. }
  337. public function createOrFindByOrderNo($orderNo)
  338. {
  339. $orderHeader = OracleDOCOrderHeader::query()->where('orderNo', $orderNo)->first();
  340. if (!$orderHeader) {
  341. return null;
  342. }
  343. return $this->createOrFind($orderHeader['soreference1']);
  344. }
  345. public function createOrFind($clientCode)
  346. {
  347. /** @var OrderService $orderService */
  348. $orderService = app('OrderService');
  349. $orderHeader = OracleDOCOrderHeader::query()->where('SOReference1', $clientCode)->first();
  350. if ($orderHeader === null) {
  351. return null;
  352. }
  353. $order = $orderService->findOrCreateByClientCode($clientCode);
  354. $rejectedBill = RejectedBill::query()->where('order_number', $orderHeader['soreference1'])->first();
  355. if ($rejectedBill === null) {
  356. $asnHeader = OracleDOCASNHeader::query()->where('ASNReference2', $orderHeader['soreference1'])->first();
  357. if ($asnHeader['asnreference3'] ?? false) {
  358. $rejectedBill = RejectedBill::query()->where('logistic_number_return', $asnHeader['asnreference3'])->first();
  359. }
  360. }
  361. $arr = [
  362. 'order_id' => $order['id'],
  363. 'logistic_number_return' => $rejectedBill['logistic_number_return'] ?? '',
  364. ];
  365. $orderIssue = null;
  366. try {
  367. $orderIssue = OrderIssue::query()->create($arr);
  368. $orderIssue->同步退单状态();
  369. $orderIssue->order = $order;
  370. app('LogService')->log(__METHOD__, __FUNCTION__, '创建问题件' . json_encode($orderIssue));
  371. } catch (\Exception $e) {
  372. app('LogService')->log(__METHOD__, __FUNCTION__, '创建问题件error' . json_encode($arr) . $e->getMessage() . $e->getTraceAsString());
  373. } finally {
  374. unset($orderHeader, $rejectedBill, $order);
  375. return $orderIssue;
  376. }
  377. }
  378. public function validatorCreate(Request $request)
  379. {
  380. return Validator::make($request->input(), [
  381. 'rejected_bill_id' => ['nullable'],
  382. 'order_id' => ['nullable'],
  383. 'owner_id' => ['required'],
  384. 'second_order_id' => ['nullable'],
  385. 'logistic_id' => ['nullable'],
  386. 'order_issue_type_id' => ['required'],
  387. 'baoshi_indemnity_money' => ['numeric', 'nullable'],
  388. 'logistic_indemnity_money' => ['numeric', 'nullable'],
  389. 'final_status' => ['nullable'],
  390. 'result_explain' => ['nullable']
  391. ], [
  392. 'required' => ':attribute 为必填项',
  393. 'unique' => ':attribute 已存在',
  394. 'numeric' => ':attribute 为数组',
  395. ], [
  396. 'owner_id' => '货主',
  397. 'rejected_bill_id' => '退回单号',
  398. 'order_id' => '订单ID',
  399. 'second_order_id' => '退回订单id',
  400. 'logistic_id' => '承运人',
  401. 'order_issue_type_id' => '问题类别',
  402. 'baoshi_indemnity_money' => '宝时赔偿金额',
  403. 'logistic_indemnity_money' => '承运商赔偿金额',
  404. 'final_status' => '最终状态',
  405. 'result_explain' => '处理结果说明',
  406. ]);
  407. }
  408. public function create(array $arr)
  409. {
  410. $orderIssue = OrderIssue::query()->create($arr);
  411. if (!$arr['order_id']) {
  412. $order = Order::query()->create($arr);
  413. $orderIssue->order_id = $order['id'];
  414. $orderIssue->save();
  415. app('LogService')->log(__METHOD__,__FUNCTION__,'创建 Order'.json_encode($order));
  416. }
  417. $orderIssue->同步退单状态();
  418. return $orderIssue;
  419. }
  420. public function createByLogisticNumber(array $arr)
  421. {
  422. $order = new Order($arr);
  423. $order['code']='null_'.Uuid::uuid4();
  424. $order->save();
  425. app('LogService')->log(__METHOD__,__FUNCTION__,'创建 Order'.json_encode($order));
  426. $orderIssue = OrderIssue::query()->create($arr);
  427. $orderIssue['order_id'] = $order['id'];
  428. OrderPackage::query()->create(['order_id' => $order['id'], 'logistic_number' => $arr['logistic_number_return']]);
  429. $orderIssue->同步退单状态();
  430. $orderIssue->update(['order_id' => $order['id']]);
  431. return $orderIssue;
  432. }
  433. public function batchDestroy($ids)
  434. {
  435. try {
  436. $bool = OrderIssue::query()->whereIn('id', $ids)->delete();
  437. app('LogService')->log(__METHOD__, __FUNCTION__, json_encode($ids));
  438. return ['success' => $bool];
  439. } catch (\Exception $e) {
  440. app('LogService')->log(__METHOD__, __FUNCTION__, 'error' . json_decode($ids) . '||' . $e->getMessage() . '||' . $e->getTraceAsString());
  441. return ['success' => false];
  442. }
  443. }
  444. public function endOrderIssues(array $ids)
  445. {
  446. return OrderIssue::query()->whereIn('id', $ids)->update(['final_status' => '已解决']);
  447. }
  448. public function isExistOrderIssueTypeIsEnd($ids)
  449. {
  450. return OrderIssue::query()->whereIn('id', $ids)->where('final_status', '已解决')->count() > 0;
  451. }
  452. public function editOrderIssueSecondClientNo($id, $secondClientNo, &$order = null)
  453. {
  454. $order = Order::query()->where('client_code', $secondClientNo)->first();
  455. if (!$order) {
  456. /** @var OrderService $orderService */
  457. $orderService = app(OrderService::class);
  458. $orderHeaders = OracleDOCOrderHeader::query()->where('SoReference1', $secondClientNo)->get();
  459. $orders = $orderService->createByWmsOrder($orderHeaders);
  460. if ($orders->count() > 0) $order = $orders->first();
  461. }
  462. return OrderIssue::query()->where('id', $id)->update(['second_client_no' => $secondClientNo]) > 0;
  463. }
  464. public function updateSecondLogisticNumber($id, $logisticNumber)
  465. {
  466. $orderIssue = OrderIssue::query()->where('id', $id)->first();
  467. $order = app(OrderService::class)->getOrderByLogisticNumber($logisticNumber);
  468. if (!$order) {
  469. $orderIssue->update(['second_logistic_number' => $logisticNumber]);
  470. return ['success' => true, 'second_logistic_number' => $logisticNumber];
  471. }
  472. $orderIssue->update(['second_client_no' => $order->client_code]);
  473. $order = Order::query()->with(['packages.commodities.commodity', 'logistic'])
  474. ->where('id', $order->id)->first();
  475. return ['success' => true, 'order' => $order];
  476. }
  477. public function createOrderIssue($logisticNumber, $type, $result_explain, $importedStatus = '正常', $custom_code = null)
  478. {
  479. $orderHeaders = OracleDOCOrderHeader::query()->with(['oracleDOCOrderDetails', 'actAllocationDetails', 'oracleBASCode'])
  480. ->whereHas('actAllocationDetails', function ($query) use ($logisticNumber) {
  481. $query->where('picktotraceid', $logisticNumber);
  482. })->get();
  483. $orderIssueType = OrderIssueType::query()->where('name', $type)->first();
  484. return $this->createOrderIssueByWmsOrder($orderHeaders, $orderIssueType->id, $result_explain, $importedStatus, $custom_code);
  485. }
  486. /**
  487. * @param array $logisticNumbers
  488. * @return array
  489. */
  490. public function 校验问题件是否存在_快递单号_返回存在的快递单号($logisticNumbers)
  491. {
  492. $orderIssues = OrderIssue::query()->with('order.packages')->whereHas('order.packages', function ($query) use ($logisticNumbers) {
  493. $query->whereIn('logistic_number', $logisticNumbers);
  494. })->get();
  495. $exits_logistic_number = array_diff(array_unique(data_get($orderIssues, '*.order.packages.*.logistic_number')), ['', null]);
  496. return array_intersect($exits_logistic_number, $logisticNumbers);
  497. }
  498. /**
  499. * @param array $orderNos
  500. * @return array
  501. */
  502. public function 校验问题件是否存在_WMS订单号_返回存在的订单号($orderNos)
  503. {
  504. $orderIssues = OrderIssue::query()->with('order')->whereHas('order', function ($query) use ($orderNos) {
  505. $query->whereIn('code', $orderNos);
  506. })->get();
  507. $exits_logistic_number = array_diff(array_unique(data_get($orderIssues, '*.order.code')), ['', null]);
  508. return array_intersect($exits_logistic_number, $orderNos);
  509. }
  510. /**
  511. * 导入处理字段
  512. * @param array $ids
  513. * @return array|bool[]
  514. */
  515. public function disposeImport(array $ids)
  516. {
  517. $orderIssues = OrderIssue::query()->with('order')->whereIn('id', $ids)->get();
  518. if ($orderIssues->count()<count($ids)) {
  519. $is_exits_ids = array_diff($ids, data_get($orderIssues, '*.code'));
  520. return ['success' => false, 'fail_info' => json_encode($is_exits_ids) . '没有存在对应的问题件'];
  521. }
  522. if ($orderIssues->where('imported_status', '导入已梳理')->count() > 0) {
  523. $is_dispose_orderNos = data_get($orderIssues->where('imported_status', '导入已梳理'), '*.order.code');
  524. return ['success' => false, 'fail_info' => json_encode($is_dispose_orderNos) . '导入已处理'];
  525. }
  526. try {
  527. OrderIssue::query()->whereIn('id', $ids)->update(['imported_status' => '导入已梳理']);
  528. app('LogService')->log(__METHOD__,__FUNCTION__,'导入处理 '.json_encode($ids).'导入处理');
  529. return ['success' => true];
  530. } catch (\Exception $e) {
  531. app('LogService')->log(__METHOD__,__FUNCTION__,'导入处理 error'.json_encode($e->getMessage()).$e->getTraceAsString());
  532. return ['success' => false,'fail_info'=>$e->getMessage()];
  533. }
  534. }
  535. public function getJsonObj(array $params)
  536. {
  537. return $this->getConditionQuery($params)->get();
  538. }
  539. public function getRecycleBinPaginate($params){
  540. return OrderIssue::query()
  541. ->with(['order'=>function($query){
  542. $query->with(['logistic','shop','owner','packages'=>function($query){
  543. $query->with('commodities');
  544. }]);
  545. },'rejectedBill.items','issueType','secondOrder.packages.commodities'])->onlyTrashed()->paginate($params['paginate'] ?? 50);
  546. }
  547. public function recoverOrderIssue($ids)
  548. {
  549. try {
  550. $bool = OrderIssue::query()->withTrashed()->whereIn('id', $ids)->restore();
  551. app('LogService')->log(__METHOD__, __FUNCTION__, '恢复问题件 ids = ' . json_encode($ids));
  552. return ['success'=>$bool];
  553. } catch (\Exception $e) {
  554. app('LogService')->log(__METHOD__, 'ERROR '.__FUNCTION__, '恢复问题件 Error' . json_encode($ids).' || '.json_encode($e->getMessage()).' || '.json_encode($e->getTraceAsString()));
  555. return ['success'=>false,'error'=>$e->getMessage()];
  556. }
  557. }
  558. }