OrderIssueController.php 38 KB

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