OrderIssueController.php 34 KB

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