OrderIssueController.php 36 KB

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