OrderIssueController.php 39 KB

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