OrderIssueController.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Imports\OrderIssueImport;
  4. use App\Logistic;
  5. use App\OracleDOCOrderHeader;
  6. use App\Order;
  7. use App\OrderIssue;
  8. use App\OrderIssueProcessLog;
  9. use App\OrderIssueType;
  10. use App\OrderPackage;
  11. use App\Owner;
  12. use App\QualityLabel;
  13. use App\RejectedBill;
  14. use App\Services\LogService;
  15. use App\Services\OrderIssueProcessLogService;
  16. use App\Services\OrderIssueService;
  17. use App\Services\OrderPackageService;
  18. use App\Services\OrderService;
  19. use App\Services\OwnerService;
  20. use App\Shop;
  21. use App\UserWorkgroup;
  22. use Exception;
  23. use Illuminate\Http\Request;
  24. use Illuminate\Support\Arr;
  25. use Illuminate\Support\Facades\Auth;
  26. use Illuminate\Support\Facades\Cache;
  27. use Illuminate\Support\Facades\Gate;
  28. use Illuminate\Support\Facades\Http;
  29. use Illuminate\Support\Facades\Validator;
  30. use Maatwebsite\Excel\Facades\Excel;
  31. class OrderIssueController extends Controller
  32. {
  33. public function index(Request $request)
  34. {
  35. if (!Gate::allows('订单管理-问题件-查询')) {
  36. return redirect(url('/'));
  37. }
  38. /** @var OrderIssueService $orderIssueService */
  39. $orderIssueService = app('OrderIssueService');
  40. $owners = app(OwnerService::class)->getAuthorizedOwners();
  41. $orderIssues = $orderIssueService->paginate($request->all());
  42. $orderIssueType = OrderIssueType::all();
  43. $qualityLabel = QualityLabel::all();
  44. $logistics = Logistic::all();
  45. $userWorkgroup = UserWorkgroup::all();
  46. return view('order/issue/index', compact('owners', 'orderIssues', 'orderIssueType', 'qualityLabel','userWorkgroup','logistics'));
  47. }
  48. public function create()
  49. {
  50. if (!Gate::allows('订单管理-订单问题件生成')) {
  51. return redirect(url('/'));
  52. }
  53. $types = OrderIssueType::all();
  54. $meg = ['success' => true];
  55. $userWorkGroup = UserWorkgroup::all();
  56. $logistic = Logistic::all();
  57. $owners = Owner::all();
  58. return view('order.issue.create', compact('types', 'meg', 'userWorkGroup', 'logistic', 'owners'));
  59. }
  60. public function store(Request $request)
  61. {
  62. if (!Gate::allows('订单管理-订单问题件生成')) {
  63. return redirect(url('/'));
  64. }
  65. $orderIssueService = app('OrderIssueService');
  66. $orderIssueService->validatorCreate($request)->validate();
  67. $orderIssue = null;
  68. if ($request->filled('logistic_number_return')) {
  69. $orderIssue = $orderIssueService->createByLogisticNumber($request->all());
  70. } else {
  71. $orderIssue = $orderIssueService->create($request->all());
  72. }
  73. OrderIssueProcessLog::query()->create(['order_issue_id' => $orderIssue['id'], 'user_id' => Auth::user()['id'], 'content' => '创建订单问题件', 'type' => '创建']);
  74. return redirect('order/issue/index');
  75. }
  76. public function edit($id)
  77. {
  78. if (!Gate::allows('订单管理-问题件-编辑')) {
  79. return redirect(url('/'));
  80. }
  81. $orderIssue = OrderIssue::query()->with(['order','secondOrder.packages.commodities.commodity'])->where('id', $id)->first();
  82. $order = $orderIssue->order;
  83. $secondOrder = $orderIssue->secondOrder;
  84. $rejectedBill = RejectedBill::query()->where('id', $orderIssue->rejected_bill_id)->first();
  85. $userWorkgroup = UserWorkgroup::all();
  86. $orderIssueType = OrderIssueType::all();
  87. $owners = Owner::all();
  88. $shops = Shop::all();
  89. $logistics = Logistic::all();
  90. return view('order/issue/edit', compact('orderIssue', 'owners', 'userWorkgroup', 'shops', 'logistics', 'orderIssueType', 'order', 'secondOrder', 'rejectedBill'));
  91. }
  92. public function batchImport(Request $request)
  93. {
  94. if (!Gate::allows('订单管理-订单问题件生成')) {
  95. return redirect(url('/'));
  96. }
  97. $file = $request->file('file');
  98. $fileSuffix = $file->getClientOriginalExtension();
  99. if (in_array($fileSuffix, ['xlsx', 'xlsm', 'xltx', 'xltm', 'xls', 'xlt', 'ods', 'ots', 'slk', 'xml', 'gnumeric', 'htm', 'html', 'csv', 'tsv'])) {
  100. ini_set('max_execution_time', 2100);
  101. ini_set('memory_limit', '512M');
  102. $extension = $request->file()['file']->getClientOriginalExtension();
  103. $extension[0] = strtoupper($extension[0]);
  104. Excel::import(new OrderIssueImport(), $request->file('file')->path(), null, $extension);
  105. if (Cache::has('error')) {
  106. return '<h1 class="text-danger">导入Excel失败<br><p style="color: red">' . Cache::pull('error') . '</p></h1>';
  107. } else {
  108. $exception = Cache::get('exception');
  109. $a = '';
  110. for ($i = 0; $i < count($exception); $i++) {
  111. $a .= implode(',', $exception[$i]) . '&#10';
  112. };
  113. $this->log(__METHOD__, __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  114. return '<h1 class="text-danger">导入Excel成功<br><textarea style="width: 50%;height: 50%">' . $a . '</textarea></h1>';
  115. }
  116. } else {
  117. return '<h1 class="text-danger">失败<br><p style="color: red">不支持该文件类型</p></h1>';
  118. }
  119. }
  120. public function exportOrderIssue(Request $request)
  121. {
  122. if (!Gate::allows('订单管理-问题件-查询')) {
  123. return redirect(url('/'));
  124. }
  125. if ($request->checkAllSign){
  126. $params = $request->input();
  127. unset($params['checkAllSign']);
  128. $sqlList = app('OrderIssueService')->getSqlList($params);
  129. }else{
  130. $sqlList = app('OrderIssueService')->getSqlList(['id'=>$request->data,"is_handle"=>true]);
  131. }
  132. $post = Http::post(config('go.export.url'),['type'=>'orderIssue','sqlList'=>json_encode($sqlList),'createFormat'=>'merge']);
  133. if ($post->status() == 500){
  134. throw new Exception($post->header("Msg"));
  135. }
  136. return response($post,200, [
  137. "Content-type"=>"application/octet-stream",
  138. "Content-Disposition"=>"attachment; filename=订单问题件-".date('ymdHis').'.xlsx',
  139. ]);
  140. }
  141. public function excelImport()
  142. {
  143. if (!Gate::allows('订单管理-订单问题件生成')) {
  144. return redirect(url('/'));
  145. }
  146. return view('order.issue.import');
  147. }
  148. public function apiOrderIssueTag(Request $request)
  149. {
  150. if (!Gate::allows('订单管理-订单问题件生成')) {
  151. return ['success' => false, 'fail_info' => '没有对应权限'];
  152. }
  153. if (!$request->input('orderNos')) {
  154. return ['success' => false, 'fail_info' => '没有传入的订单编号'];
  155. }
  156. /** @var OrderIssueService $orderIssueService */
  157. $orderIssueService = app(OrderIssueService::class);
  158. $exits_orderNos = $orderIssueService->校验问题件是否存在_WMS订单号_返回存在的订单号($request->input('orderNos'));
  159. if(count($exits_orderNos)>0){
  160. return ['success'=>false,'fail_info'=>'标记问题件存在已有订单号','exitsOrderNos' =>$exits_orderNos];
  161. }
  162. return $orderIssueService->orderIssueTag($request->all());
  163. }
  164. public function apiDestroy(Request $request)
  165. {
  166. if (!Gate::allows('订单管理-问题件-删除')) {
  167. return ['success' => false, 'fail_info' => '没有对应权限'];
  168. }
  169. if (!($request->has('id'))) {
  170. return ['success' => 'false', 'fail_info' => '没有问题题件相关的参数'];
  171. }
  172. $orderIssue = OrderIssue::query()->where('id', $request->input('id'))->first();
  173. $bool = $orderIssue->delete();
  174. if ($bool) {
  175. $this->log(__METHOD__, __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  176. return ['success' => 'true'];
  177. } else {
  178. return ['success' => 'false', 'fail_info' => '删除问题单出现异常,请联系管理员'];
  179. }
  180. }
  181. public function updateApi(Request $request)
  182. {
  183. if (!Gate::allows('订单管理-问题件-编辑')) {
  184. return ['success' => false, 'fail_info' => '没有对应权限'];
  185. }
  186. try {
  187. $data = $request->only([
  188. 'order_issue_type_id','owner_id','logistic_id', 'logistic_number_return','result_explain','final_status','second_order_id','second_client_no',
  189. 'logistic_indemnity_money','logistic_express_remission','baoshi_indemnity_money','baoshi_express_remission','user_workgroup_id'
  190. ]);
  191. $orderIssue = OrderIssue::query()->find($request->id);
  192. $orderIssue->update($data);
  193. $orderIssue->同步退单状态();
  194. LogService::log(__METHOD__,__FUNCTION__,json_encode($request));
  195. return ['success' => true];
  196. } catch (Exception $e) {
  197. LogService::log(__METHOD__,__FUNCTION__,json_encode($request)."||".$e->getMessage().'||'.$e->getTraceAsString());
  198. return ['success' => false ,'fail_info' => $e->getMessage()];
  199. }
  200. }
  201. public function apiEndOrderIssue(Request $request)
  202. {
  203. if (!Gate::allows('订单管理-问题件-编辑')) {
  204. return ['success' => false, 'fail_info' => '没有对应的权限'];
  205. }
  206. if (!$request->has('ids')) {
  207. return ['success' => false, 'fail_info' => '没有传入对应的参数'];
  208. }
  209. $count = OrderIssue::query()->whereIn('id', $request->input('ids'))->where('final_status', '已解决')->count();
  210. if ($count > 0) {
  211. return ['success' => false, 'fail_info' => '勾选的内容中已有完结的订单问题件,取消勾选后重试'];
  212. } else {
  213. OrderIssue::query()->whereIn('id', $request->input('ids'))->update(['final_status' => '已解决']);
  214. foreach ($request->input('ids') as $id) {
  215. OrderIssueProcessLog::query()->create(['order_issue_id' => $id, 'user_id' => Auth::user()['id'], 'type' => '结束', 'content' => '完结订单']);
  216. }
  217. $this->log(__METHOD__, __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
  218. return ['success' => true];
  219. }
  220. }
  221. public function apiDisposeOrderIssue(Request $request)
  222. {
  223. if (!Gate::allows('订单管理-问题件-编辑')) {
  224. return ['success' => false, 'fail_info' => '没有对应权限'];
  225. }
  226. if (!$request->has('id')) {
  227. return ['success' => false, 'fail_info' => '没有传入对应参数'];
  228. }
  229. try {
  230. OrderIssue::query()
  231. ->where('id', $request->input('id'))
  232. ->update(['is_new_rejecting' => '已处理']);
  233. LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent()));
  234. return ['success'=>true];
  235. } catch (Exception $e) {
  236. LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent())."||".$e->getMessage()."||".$e->getTraceAsString());
  237. return ['success' => false,'fail_info' => $e->getMessage()];
  238. }
  239. }
  240. public function apiGetOrderInfoByClientNo(Request $request)
  241. {
  242. if (!$request->filled('clientNo')) {
  243. return ['success' => false, 'fail_info' => '缺失WMS订单参数无法查询'];
  244. }
  245. $orderInfo = app(OrderService::class)->findOrCreateByClientCode($request->input('clientNo'));
  246. if (!$orderInfo) {
  247. return ['success' => true, 'message' => '没有对应的订单信息'];
  248. }else{
  249. return ['success' => true, 'data' => $orderInfo];
  250. }
  251. }
  252. public function apiOrderIssueHasClientCode(Request $request)
  253. {
  254. if (!$request->filled('clientCode')) {
  255. return ['success' => false, 'fail_info' => '缺少对应的参数或条件'];
  256. }
  257. $orderService = app('OrderService');
  258. $clientCode = $request->input('clientCode');
  259. $order = Order::query()->where('client_code', $clientCode)->first();
  260. if ($order) {
  261. if (OrderIssue::query()->where('order_id', $order['id'])->count()) {
  262. return ['success' => false, 'fail_info' => '该客户订单号已有对应的订单问题件'];
  263. }
  264. $order = $orderService->findOrCreateByClientCode($clientCode);
  265. return ['success' => true, 'order' => $order];
  266. } else {
  267. $orderHeader = OracleDOCOrderHeader::query()->where('SOReference1', $clientCode)->first();
  268. if (!$orderHeader) {
  269. return ['success' => false, 'fail_info' => '该客户订单号没有对应的订单信息'];
  270. } else {
  271. $order = $orderService->findOrCreateByClientCode($clientCode);
  272. $rejectedBill = $orderService->getRejectedBillOfClientCode($clientCode);
  273. return ['success' => true, 'order' => $order, 'rejectedBill' => $rejectedBill];
  274. }
  275. }
  276. }
  277. public function apiOrderIssueHasLogisticNumberReturn(Request $request)
  278. {
  279. if (!$request->filled('logisticNumberReturn')) {
  280. return ['success' => false, 'fail_info' => '缺少对应的参数或条件'];
  281. }
  282. $logisticNumberReturn = $request->input('logisticNumberReturn');
  283. $rejectedBill = RejectedBill::with('items')->where('logistic_number_return', $logisticNumberReturn)->first();
  284. if ($rejectedBill) {
  285. $orderIssue = OrderIssue::query()->where('rejected_bill_id', $rejectedBill->id)->first();
  286. if ($orderIssue) {
  287. return ['success' => false, 'fail_info' => '该退回单号已有对应的问题件'];
  288. } else {
  289. $orderService = app('OrderService');
  290. $order = $orderService->findOrCreteByLogisticNumberReturn($logisticNumberReturn);
  291. return ['success' => true, 'order' => $order, 'rejectedBill' => $rejectedBill];
  292. }
  293. } else {
  294. return ['success' => true, 'meg' => '没有对应的退回单号,不与WMS同步'];
  295. }
  296. }
  297. public function isExistByOrderNoApi(Request $request){
  298. if (!Gate::allows('订单管理-订单问题件生成')) {
  299. return ['success'=>false,'fail_info' => '没有对应权限'];
  300. }
  301. $orderNos = $request->input('orderNos');
  302. $orderIssues =OrderIssue::query()->with('order')
  303. ->whereHas('order',function($query) use ($orderNos){
  304. $query->whereIn('code',$orderNos);
  305. })->get();
  306. if($orderIssues->count() == 0){
  307. return ['success'=>true ];
  308. }else{
  309. $is_exist_orderNos = '';
  310. foreach ($orderIssues as $orderIssue) {
  311. $is_exist_orderNos.= $orderIssue->order->code.',';
  312. }
  313. $is_exist_orderNos = rtrim($is_exist_orderNos,',');
  314. $is_exist_orderNos .= ';';
  315. return ['success'=>false,'fail_info'=>'选中的订单已有存在的问题件:'.$is_exist_orderNos];
  316. }
  317. }
  318. public function updateColumnApi(Request $request)
  319. {
  320. if (!Gate::allows('订单管理-问题件-编辑')) {
  321. return ['success'=>false,'fail_info' => '没有对应权限'];
  322. }
  323. try {
  324. OrderIssue::query()
  325. ->where('id', $request->input('id'))
  326. ->update([$request->input('column') => $request->input('value')]);
  327. LogService::log(__METHOD__,'更新问题件',json_encode($request->getContent()));
  328. return ['success' => true];
  329. } catch (Exception $e) {
  330. LogService::log(__METHOD__,'更新问题件error',json_encode($request->getContent()).'||'.$e->getMessage().'||'.$e->getTraceAsString());
  331. return ['success' => false, $e->getMessage()];
  332. }
  333. }
  334. public function batchDestroyApi(Request $request)
  335. {
  336. if (!Gate::allows('订单管理-问题件-删除')) {
  337. return ['success'=>false,'fail_info' => '没有对应权限'];
  338. }
  339. try {
  340. OrderIssue::query()->whereIn('id', $request->input('ids'))->delete();
  341. LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent()));
  342. return ['success' => true];
  343. } catch (Exception $e) {
  344. LogService::log(__METHOD__,__FUNCTION__,json_encode($request)."||".$e->getMessage()."||".$e->getTraceAsString());
  345. return ['success' => false,'fail_info' => $e->getMessage()];
  346. }
  347. }
  348. public function updateLogisticNumberReturnApi(Request $request){
  349. if (!Gate::allows('订单管理-问题件-编辑')) {
  350. return ['success'=>false,'fail_info' => '没有对应权限'];
  351. }
  352. try {
  353. /** @var OrderIssue $orderIssue */
  354. $orderIssue = OrderIssue::query()->where('id',$request->input('id'))->first();
  355. $rejectedBill = RejectedBill::query()
  356. ->with('items')
  357. ->where('logistic_number_return',$request->input('logisticNumberReturn'))
  358. ->first();
  359. LogService::log(__METHOD__, __FUNCTION__, json_encode($request->getContent()));
  360. if(!$rejectedBill){
  361. $orderIssue->update(['logistic_number_return' => $request->input('logisticNumberReturn')]);
  362. return ['success' => false, 'message' => '退回单号已修改,退回单号没有相应退件信息'];
  363. }else{
  364. $orderIssue->update(['logistic_number_return' => $request->input('logisticNumberReturn'),'is_new_rejecting' => '有']);
  365. $orderIssue->同步退单状态();
  366. return ['success' => true, 'rejectedBill' => $rejectedBill,'rejectingStatus' =>$orderIssue->rejecting_status];
  367. }
  368. } catch (Exception $e) {
  369. LogService::log(__METHOD__, __FUNCTION__,'error'. json_encode($request->getContent()).'||'.$e->getMessage().'||'.$e->getTraceAsString());
  370. return ['success' => false ,'fail_info' => $e->getMessage()];
  371. }
  372. }
  373. public function apiUpdateValidator(array $arr)
  374. {
  375. return Validator::make($arr, [
  376. 'order_issue_type_id' => ['required'],
  377. 'handle_status' => ['nullable'],
  378. 'result_explain' => ['nullable'],
  379. 'logistic_indemnity_money' => ['nullable', 'numeric'],
  380. 'logistic_express_remission' => ['nullable'],
  381. 'baoshi_indemnity_money' => ['nullable', 'numeric'],
  382. 'baoshi_express_remission' => ['nullable'],
  383. ], [
  384. 'required' => [':attribute 为必填项', ':attribute'],
  385. 'numeric' => [':attribute 为可确认的数值', ':attribute']
  386. ], [
  387. 'order_issue_type_id' => '问题类别',
  388. 'handle_status' => '处理状态',
  389. 'result_explain' => '处理结果说明',
  390. 'logistic_indemnity_money' => '承运商赔偿金额',
  391. 'logistic_express_remission' => '承运商快递减免',
  392. 'baoshi_indemnity_money' => '宝时赔偿金额',
  393. 'baoshi_express_remission' => '宝时快递减免',
  394. ]);
  395. }
  396. public function apiUpdateValidatorRejectedBill(array $arr){
  397. return Validator::make($arr, [
  398. 'logistic_number_return'=>['required'],
  399. 'id_logistic_return'=>['required'],
  400. ], [
  401. 'required' => [':attribute 为必填项', ':attribute'],
  402. ], [
  403. 'logistic_number_return'=> '退回单号',
  404. 'id_logistic_return'=> '退回单号承运商',
  405. ]);
  406. }
  407. public function endOrderIssuesApi(Request $request)
  408. {
  409. if (!Gate::allows('订单管理-问题件-编辑')) {
  410. return ['success'=>false,'fail_info' => '没有对应权限'];
  411. }
  412. $orderIssue_ids = $request->input('ids');
  413. $bool = app(OrderIssueService::class)->isExistOrderIssueTypeIsEnd($orderIssue_ids);
  414. if($bool)return ['success'=>false,'fail_info'=> '需要完结的订单问题件中已有完结的订单问题件'];
  415. $bool = app(OrderIssueService::class)->endOrderIssues($orderIssue_ids);
  416. if($bool == 0) return ['success'=>false,'fail_info' => '操作失败'];
  417. $params = ['ids'=>$orderIssue_ids,'content'=>'完结订单','type'=>'结束'];
  418. $logs = app(OrderIssueProcessLogService::class)->create($params);
  419. return ['success'=>true,'logs'=>$logs];
  420. }
  421. public function editSecondClientNoApi(Request $request)
  422. {
  423. if(!Gate::allows('订单管理-问题件-编辑')){
  424. return ['success'=>false,'fail_info'=>'没有对应权限'];
  425. }
  426. $secondClientNo = $request->input('secondClientNo');
  427. try {
  428. app(OrderIssueService::class)->editOrderIssueSecondClientNo($request->id,$secondClientNo);
  429. $order = Order::query()->with('packages.commodities.commodity')->where('client_code',$secondClientNo)->first();
  430. if (!$order) {
  431. return ['success' => true, 'message' => '二次客户单号已修改,没有对应的订单信息'];
  432. } else {
  433. return ['success' => true, 'order' => $secondClientNo =='' ? null : $order];
  434. }
  435. } catch (Exception $e) {
  436. LogService::log(__METHOD__, __FUNCTION__, json_encode($request->getContent()).$e->getMessage().$e->getTraceAsString());
  437. return ['success' =>false ,'fail_info' => $e->getMessage()];
  438. }
  439. }
  440. public function editSecondLogisticNumberApi(Request $request)
  441. {
  442. if(!Gate::allows('订单管理-问题件-编辑'))
  443. return ['success'=>false,'fail_info'=>'没有对应权限'];
  444. /** @var OrderIssueService $service */
  445. $service = app(OrderIssueService::class);
  446. try {
  447. $message = $service->updateSecondLogisticNumber($request->input('id'), $request->logistic_number);
  448. LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent()));
  449. return $message;
  450. } catch (Exception $e) {
  451. LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent()).$e->getMessage().$e->getTraceAsString());
  452. return ['success'=>false,$e->getMessage()];
  453. }
  454. }
  455. public function disposeImportApi(Request $request)
  456. {
  457. if(!Gate::allows('订单管理-问题件-编辑'))
  458. return ['success'=>false,'fail_info'=>'没有对应权限'];
  459. return app(OrderIssueService::class)->disposeImport($request->input('ids'));
  460. }
  461. public function importPasteDataApi(Request $request)
  462. {
  463. if (!Gate::allows('订单管理-订单问题件生成'))
  464. return ['success'=>false,'fail_info'=>'没有对应权限'];
  465. $rows = $request->input('rows');
  466. $logistic_numbers = [];
  467. $types = [];
  468. $maps = [];
  469. $errors = [];
  470. $orderIssueTypes = OrderIssueType::all();
  471. $orderIssueType_map = [];
  472. foreach ($orderIssueTypes as $orderIssueType) {
  473. $orderIssueType_map[$orderIssueType->name] = $orderIssueType;
  474. }
  475. $array = explode("\n",$request->input('pasteDataText')); //拆分行
  476. /** @var OrderIssueService $service */
  477. $service = app(OrderIssueService::class);
  478. foreach ($array as $i => $str) {
  479. // $string= preg_replace('/[\s,\,\,]+/','*++*',$str);
  480. // $items = explode('*++*',$string);
  481. // dd($items,$str);
  482. $items=[];
  483. preg_match('/^(\w*?)[\s,,;;]([\x{4e00}-\x{9fa5}]*?)[\s,,;;](.*?)[\s,,;;](\w*?)$/u', $str, $items);
  484. array_shift($items);
  485. $head = '第'.($i+1).'行';
  486. if(count($items)<count($rows)-1){
  487. $errors[$head] = ['数据不完整'];
  488. unset($items);
  489. continue;
  490. }
  491. $map = [];
  492. foreach ($rows as $index=>$row) {
  493. if($row === '原始运单号'){
  494. if(!$items[$index]){
  495. $errors[$head][]='快递单号为空';
  496. $map =[];
  497. }
  498. $logistic_numbers = [$items[$index]];
  499. $exist_logistic = $service->校验问题件是否存在_快递单号_返回存在的快递单号($logistic_numbers);
  500. $orderHeaders=OracleDOCOrderHeader::query()->with('actAllocationDetails')->whereHas('actAllocationDetails',function($query)use($logistic_numbers){
  501. $query->whereIn('picktotraceid',$logistic_numbers);
  502. })->get();
  503. if(count($exist_logistic) > 0){
  504. $errors[$head][]='快递单号存在对应的问题件';
  505. $map =[];
  506. }else if($orderHeaders->count()==0){
  507. $errors[$head][]='快递单号不存在对应的发运订单';
  508. $map =[];
  509. }
  510. $logistic_numbers[] = $items[$index];
  511. $map['logistic_number'] = $items[$index];
  512. }
  513. if($row==='情况说明'){
  514. if(!$items[$index]){
  515. $errors[$head][]='情况说明为空';
  516. $map =[];
  517. }
  518. $map['result_explain'] = $items[$index];
  519. }
  520. if($row==='自定义订单号'){
  521. if($items[$index]??false){
  522. $map['custom_code'] = $items[$index];
  523. }
  524. }
  525. if($row==='问题类别'){
  526. if(!$items[$index]){
  527. $errors[$head][]='问题类别为空';
  528. $map = [];
  529. }else{
  530. $type = $orderIssueType_map[$items[$index]] ?? null;
  531. if(!$type){
  532. $errors[$head][]='问题类型不存在';
  533. $map = [];
  534. }
  535. }
  536. $types[] =$items[$index];
  537. $map['type'] = $items[$index];
  538. }
  539. }
  540. if(count($map)!==0)$maps[] = $map;
  541. }
  542. // if(count($errors)>0)dd($errors);
  543. if(count($errors)>0) return ['success'=>false,'fail_info'=>$errors];
  544. try {
  545. foreach ($maps as $map) {
  546. $logistic_number = $map['logistic_number'];
  547. $result_explain = $map['result_explain'];
  548. $type = $map['type'];
  549. $custom_code = $map['custom_code'] ?? null;
  550. $service->createOrderIssue($logistic_number, $type, $result_explain,'导入未处理',$custom_code);
  551. }
  552. return ['success'=>true];
  553. } catch (Exception $e) {
  554. LogService::log(__METHOD__,__FUNCTION__,'文本导入问题件失败'.json_encode($request->getContent().$e->getMessage().$e->getTraceAsString()));
  555. return ['success'=>false,'fail_info'=>$e->getMessage()];
  556. }
  557. }
  558. public function exportJsonExcel(Request $request)
  559. {
  560. if (!Gate::allows('订单管理-问题件-查询')) {
  561. return redirect(url('/'));
  562. }
  563. $params = $request->input();
  564. if ($request->checkAllSign){
  565. $params = $request->input();
  566. unset($params['checkAllSign']);
  567. }else{
  568. $params['id'] = $request['data'];
  569. $params['is_handle'] = true;
  570. }
  571. /** @var OrderIssueService $service */
  572. $service = app('OrderIssueService');
  573. $order_Issues = $service->getJsonObj($params);
  574. $json = [];
  575. $row = [
  576. '登记日期','创建日期','客户','客户订单号','原始承运商','收货人','收货电话','省','市','区','收货人地址',
  577. '原始运单号','原始商品','原始商品名称','原始商品数量',
  578. '退单备注','退单商品名','退单商品条码','退单商品数量','退单状态',
  579. '操作类型','说明','操作者','情况说明','问题类别',
  580. '二次订单号','二次承运商','二次运单号','二次商品条码','二次商品名','二次商品数量',
  581. '最终状态', '承运商赔偿金额', '承运商快递减免', '宝时赔偿金额', '宝时快递减免','事故责任方'
  582. ];
  583. $count = null;
  584. $row_count = 0;
  585. $start_row= 0;
  586. $mergeRow = []; //合并规则
  587. $row_number = 2;
  588. $order_Issues->each(function ($order_issue)use(&$json,&$row_number,&$mergeRow){
  589. $order = $order_issue->order;
  590. $send_order = $order_issue->secondOrder ?? new Order();
  591. $logs = $order_issue->logs ?? collect();
  592. $issueType = $order_issue->issueType->name;
  593. $rejectedBill = $order_issue->rejectedBill ?? new RejectedBill();
  594. // 订单信息
  595. $order_logistic_number = [];
  596. $order_info = [];
  597. $order->packages->each(function($package)use(&$order_logistic_number,&$order_info){
  598. $order_logistic_number [] = $package->logistic_number;
  599. $package->commodities->each(function($commodities)use(&$order_info){
  600. $sku = $commodities->commodity;
  601. if($sku?? false)
  602. $order_info[]=['sku'=>$sku->sku,'sku_name'=>$sku->name,'amount'=>$commodities->amount];
  603. });
  604. });
  605. // 二次订单信息
  606. $send_order_logistic_number = [];
  607. $send_order_info = [];
  608. $send_order->packages->each(function($package)use(&$send_order_logistic_number,&$send_order_info){
  609. $send_order_logistic_number [] = $package->logistic_number;
  610. $package->commodities->each(function($commodities)use(&$send_order_info){
  611. $sku = $commodities->commodity;
  612. if($sku?? false)
  613. $send_order_info[] = ['send_sku'=>$sku->sku ?? '','send_sku_name'=>$sku->name ?? '','send_amount'=>$commodities->amount ?? ''];
  614. });
  615. });
  616. // 退回单信息
  617. $rejected_Bill_info = [];
  618. $rejected_Bill_remark =$rejectedBill->remark ?? '';
  619. $rejectedBill->items->each(function($item)use(&$rejected_Bill_info){
  620. $rejected_Bill_info[] = ['rejected_item_name'=>$item->name_goods,'rejected_item_barcode'=>$item->barcode_goods,'rejected_item_amount'=>$item->amount];
  621. });
  622. $logs_info = [];
  623. $logs->each(function($log)use(&$logs_info){
  624. $logs_info[] = ['log_type'=>$log->type,'log_content'=>$log->content,'log_user'=>$log->user->name];
  625. });
  626. $rows = [count($rejected_Bill_info),count($logs_info),count($send_order_info),count($order_info)];
  627. $max_rows = max($rows);
  628. $start_row = $row_number;
  629. for ($index =0 ;$index<$max_rows ;$index++){
  630. $json[] = [
  631. $order_issue->created_at, // 登记日期
  632. $order->created_at, // 创建日期
  633. $order->owner->name ?? '', // 客户
  634. $order->client_code, // 客户订单号
  635. $order->logistic->name ?? '', // 原始承运商
  636. $order->consignee_name, // 收货人
  637. $order->consignee_phone, // 收货电话
  638. $order->province, // 省
  639. $order->city, // 市
  640. $order->district, // 区
  641. $order->address, // 收货人地址
  642. $order_logistic_number[$index]??'', //原始运单号
  643. $order_info[$index]['sku']??'', //原始商品
  644. $order_info[$index]['sku_name']??'', //原始商品名称
  645. $order_info[$index]['amount']??'', //原始商品数量
  646. //'退单备注','退单商品名','退单商品条码','退单商品数量','退单状态',
  647. $rejected_Bill_remark, // 退单备注
  648. $rejected_Bill_info[$index]['rejected_item_name'] ?? '', // 退单商品名
  649. $rejected_Bill_info[$index]['rejected_item_barcode'] ?? '' , // 退单商品条码
  650. $rejected_Bill_info[$index]['rejected_item_amount'] ?? '', // 退单商品数量
  651. $order_issue->rejecting_status , // 退单状态
  652. // '操作类型','情况说明','问题类别',
  653. $logs_info[$index]['log_type'] ?? '', //操作类型
  654. $logs_info[$index]['log_content'] ?? '', //情况说明
  655. $logs_info[$index]['log_user'] ?? '', //操作者
  656. // '情况说明','问题类别',
  657. $order_issue->result_explain, // 情况说明
  658. $order_issue->issueType->name ?? '', // 问题类别
  659. // '二次订单号','二次承运商','二次运单号','二次商品条码','二次商品名','二次商品数量',
  660. $order_issue->secondOrder->client_code ?? '', //二次订单号
  661. $order_issue->secondOrder->logistic->name ?? '', //二次承运商
  662. $send_order_logistic_number[$index] ?? '' , //二次运单号
  663. $send_order_info[$index]['send_sku'] ?? '', // 二次商品条码
  664. $send_order_info[$index]['send_sku_name'] ?? '', // 二次商品名
  665. $send_order_info[$index]['send_amount'] ?? '', // 二次商品数量
  666. //'最终状态', '承运商赔偿金额', '承运商快递减免', '宝时赔偿金额', '宝时快递减免','事故责任方'
  667. $order_issue->final_status??'',
  668. $order_issue->logistic_indemnity_money ,
  669. $order_issue->logistic_express_remission,
  670. $order_issue->baoshi_indemnity_money,
  671. $order_issue->baoshi_express_remission,
  672. $order_issue->userWorkGroup->name ?? '',
  673. ];
  674. $row_number++;
  675. }
  676. if($max_rows>1){
  677. $mergeRow[(string)($start_row)] =(string)($row_number-1);
  678. }
  679. });
  680. $mergeColumn = ['A','B','C','D','E','F','G','H','I','J','K','L','P','T','X','Y','Z','AA','AF','AG','AH','AI','AJ','AK']; // 合并行
  681. $post=Http::post(config('go.export.url'),['type'=>'base','data'=>json_encode(['row'=>$row,'list'=>$json,'mergeColumn'=>$mergeColumn,'mergeRow'=>$mergeRow],JSON_UNESCAPED_UNICODE),'createFormat'=>'merge']);
  682. // $post=Http::post(config('go.export.url'),['type'=>'base','data'=>json_encode(['row'=>$row,'list'=>$json],JSON_UNESCAPED_UNICODE)]);
  683. if ($post->status() == 500){
  684. throw new Exception($post->header("Msg"));
  685. }
  686. return response($post,200, [
  687. "Content-type"=>"application/octet-stream",
  688. "Content-Disposition"=>"attachment; filename=订单问题件-".date('ymdHis').'.xlsx',
  689. ]);
  690. }
  691. }