DispatchService.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609
  1. <?php
  2. namespace App\Service;
  3. use App\Model\Dispatch;
  4. use App\Model\DispatchEmpSub;
  5. use App\Model\DispatchSub;
  6. use App\Model\Employee;
  7. use App\Model\EmployeeTeamPermission;
  8. use App\Model\Gateway;
  9. use App\Model\FinishedOrderSub;
  10. use App\Model\Orders;
  11. use App\Model\OrdersProduct;
  12. use App\Model\OrdersProductProcess;
  13. use App\Model\Process;
  14. use App\Model\Team;
  15. use Illuminate\Support\Facades\DB;
  16. class DispatchService extends Service
  17. {
  18. public function edit($data){}
  19. public function setOrderNO(){
  20. $str = date('Ymd',time());
  21. $order_number = Dispatch::where('dispatch_no','Like','%'. $str . '%')
  22. ->max('dispatch_no');
  23. if(empty($order_number)){
  24. $number = str_pad(1,3,'0',STR_PAD_LEFT);
  25. $number = $str . $number;
  26. }else{
  27. $tmp = substr($order_number, -3);
  28. $tmp = $tmp + 1;
  29. //超过99999
  30. if(strlen($tmp) > 3) return '';
  31. $number = str_pad($tmp,3,'0',STR_PAD_LEFT);
  32. $number = $str . $number;
  33. }
  34. return $number;
  35. }
  36. public function add($data,$user){
  37. //数据校验以及填充
  38. list($status,$msg) = $this->orderRule($data);
  39. if(!$status) return [$status,$msg];
  40. try{
  41. DB::beginTransaction();
  42. if($data['is_split']){
  43. foreach ($msg as $value){
  44. $this->insertDispatch([$value],$data,$user);
  45. }
  46. }else{
  47. $this->insertDispatch($msg,$data,$user);
  48. }
  49. //反写已派工数量
  50. $this->writeDispatchQuantity(array_column($msg,'order_product_id'));
  51. DB::commit();
  52. }catch (\Exception $e){
  53. DB::rollBack();
  54. return [false,$e->getLine().':'.$e->getMessage()];
  55. }
  56. return [true,''];
  57. }
  58. public function makeData($equipment_id, $team_id,$employee_id,$message){
  59. $arr = [];
  60. if(! empty($equipment_id)){
  61. foreach ($equipment_id as $v_e){
  62. if(! empty($team_id)){
  63. foreach ($team_id as $t){
  64. if(! empty($employee_id)){
  65. foreach ($employee_id as $e){
  66. $arr[] = [
  67. 'equipment_id' => $v_e,
  68. 'team_id' => $t,
  69. 'employee_id' => $e,
  70. 'order_product_id' => $message['order_product_id'],
  71. 'dispatch_no' => $message['dispatch_no'],
  72. ];
  73. }
  74. }else{
  75. $arr[] = [
  76. 'equipment_id' => $v_e,
  77. 'team_id' => $t,
  78. 'order_product_id' => $message['order_product_id'],
  79. 'dispatch_no' => $message['dispatch_no'],
  80. ];
  81. }
  82. }
  83. }elseif(! empty($employee_id)){
  84. foreach ($employee_id as $e){
  85. $arr[] = [
  86. 'equipment_id' => $v_e,
  87. 'employee_id' => $e,
  88. 'order_product_id' => $message['order_product_id'],
  89. 'dispatch_no' => $message['dispatch_no'],
  90. ];
  91. }
  92. }else{
  93. $arr[] = [
  94. 'equipment_id' => $v_e,
  95. 'order_product_id' => $message['order_product_id'],
  96. 'dispatch_no' => $message['dispatch_no'],
  97. ];
  98. }
  99. }
  100. }elseif (! empty($team_id)){
  101. foreach ($team_id as $t){
  102. if(! empty($employee_id)){
  103. foreach ($employee_id as $e){
  104. $arr[] = [
  105. 'team_id' => $t,
  106. 'employee_id' => $e,
  107. 'order_product_id' => $message['order_product_id'],
  108. 'dispatch_no' => $message['dispatch_no'],
  109. ];
  110. }
  111. }else{
  112. $arr[] = [
  113. 'team_id' => $t,
  114. 'order_product_id' => $message['order_product_id'],
  115. 'dispatch_no' => $message['dispatch_no'],
  116. ];
  117. }
  118. }
  119. }elseif(! empty($employee_id)){
  120. foreach ($employee_id as $e){
  121. $arr[] = [
  122. 'employee_id' => $e,
  123. 'order_product_id' => $message['order_product_id'],
  124. 'dispatch_no' => $message['dispatch_no'],
  125. ];
  126. }
  127. }
  128. return $arr;
  129. }
  130. public function insertDispatch($msg, $data, $user){
  131. //生产数据的源数据
  132. $result = $msg;
  133. $time = time();
  134. $dispatch_no = $this->setOrderNO();
  135. //主表
  136. Dispatch::insert(['dispatch_no' => $dispatch_no,'crt_time' => $time]);
  137. $time_tmp = date("Ymd", $data['out_order_no_time'][0]);
  138. $process_model = new OrdersProductProcess(['channel' => $time_tmp]);
  139. $equipment_id = is_array($data['equipment_id']) ? $data['equipment_id'] : [$data['equipment_id']];
  140. $equipment_id = array_filter($equipment_id);
  141. $team_id = is_array($data['team_id']) ? $data['team_id'] : [$data['team_id']];
  142. $team_id = array_filter($team_id);
  143. $insert_emp_sub = [];
  144. foreach ($result as $key => $value){
  145. $result[$key]['dispatch_no'] = $dispatch_no;
  146. $result[$key]['process_id'] = $data['process_id'];
  147. $result[$key]['dispatch_time_start'] = $data['dispatch_time'][0];
  148. $result[$key]['dispatch_time_end'] = $data['dispatch_time'][1];
  149. $result[$key]['dispatch_quantity'] = $value['quantity'];
  150. $result[$key]['crt_time'] = $time;
  151. $result[$key]['crt_id'] = $user['id'];
  152. $tmp = $this->makeData($equipment_id,$team_id,$data['employee_id'],$result[$key]);
  153. $insert_emp_sub = array_merge_recursive($insert_emp_sub,$tmp);
  154. $process_model->where('order_product_id',$value['order_product_id'])
  155. ->where('process_id',$data['process_id'])
  156. ->where('dispatch_no','')
  157. ->take($value['quantity'])
  158. ->update([
  159. 'dispatch_no' => $dispatch_no,
  160. 'status' => 1
  161. ]);
  162. unset($result[$key]['quantity']);
  163. }
  164. DispatchSub::insert($result);
  165. if(! empty($insert_emp_sub)) DispatchEmpSub::insert($insert_emp_sub);
  166. }
  167. public function del($data){
  168. if($this->isEmpty($data,'id')) return [false,'ID不能为空!'];
  169. return [true,'删除成功'];
  170. }
  171. public function orderDetail($data){
  172. return [200,''];
  173. }
  174. public function is_same_month($timestamp1,$timestamp2){
  175. // 格式化时间戳为年份和月份
  176. $year1 = date('Y', $timestamp1);
  177. $month1 = date('m', $timestamp1);
  178. $year2 = date('Y', $timestamp2);
  179. $month2 = date('m', $timestamp2);
  180. if ($year1 === $year2 && $month1 === $month2) {
  181. return true;
  182. } else {
  183. return false;
  184. }
  185. }
  186. public function orderList($data){
  187. list($status,$msg) = $this->orderListRule($data);
  188. if(! $status) return [false, $msg];
  189. $model = OrdersProduct::where('del_time',0)
  190. ->select('id','order_no','out_order_no','out_order_no_time','customer_no','customer_name','table_header_mark','product_no','product_title','product_size','product_unit','order_quantity','technology_material','technology_name','wood_name','process_mark','table_body_mark','out_crt_man','out_checker_man','out_checker_time','production_quantity','production_time','production_no','status','crt_id','dispatch_complete_quantity')
  191. ->whereBetween('out_order_no_time',[$data['out_order_no_time'][0],$data['out_order_no_time'][1]])
  192. ->whereIn('id',$msg)
  193. ->orderBy('id','desc');
  194. if(! empty($data['order_no'])) $model->where('order_no', 'LIKE', '%'.$data['order_no'].'%');
  195. if(! empty($data['out_order_no'])) $model->where('out_order_no', 'LIKE', '%'.$data['out_order_no'].'%');
  196. if(! empty($data['production_no'])) $model->where('production_no', 'LIKE', '%'.$data['production_no'].'%');
  197. if(! empty($data['customer_name'])) $model->where('customer_name', 'LIKE', '%'.$data['customer_name'].'%');
  198. if(! empty($data['product_title'])) $model->where('product_title', 'LIKE', '%'.$data['product_title'].'%');
  199. if(! empty($data['product_size'])) $model->where('product_size', 'LIKE', '%'.$data['product_size'].'%');
  200. if(! empty($data['technology_material'])) $model->where('technology_material', 'LIKE', '%'.$data['technology_material'].'%');
  201. if(! empty($data['technology_name'])) $model->where('technology_name', 'LIKE', '%'.$data['technology_name'].'%');
  202. if(! empty($data['wood_name'])) $model->where('wood_name', 'LIKE', '%'.$data['wood_name'].'%');
  203. if(! empty($data['process_mark'])) $model->where('process_mark', 'LIKE', '%'.$data['process_mark'].'%');
  204. if(! empty($data['table_header_mark'])) $model->where('table_header_mark', 'LIKE', '%'.$data['table_header_mark'].'%');
  205. if(! empty($data['table_body_mark'])) $model->where('table_body_mark', 'LIKE', '%'.$data['table_body_mark'].'%');
  206. if(! empty($data['out_checker_man'])) $model->where('out_checker_man', 'LIKE', '%'.$data['out_checker_man'].'%');
  207. if(! empty($data['out_crt_man'])) $model->where('out_crt_man', 'LIKE', '%'.$data['out_crt_man'].'%');
  208. if(! empty($data['out_checker_time'][0]) && ! empty($data['out_checker_time'][1])) $model->whereBetween('out_checker_time',[$data['out_checker_time'][0],$data['out_checker_time'][1]]);
  209. if(! empty($data['production_time'][0]) && ! empty($data['production_time'][1])) $model->whereBetween('production_time',[$data['production_time'][0],$data['production_time'][1]]);
  210. if(isset($data['status'])) $model->where('status',$data['status']);
  211. if(isset($data['is_create'])) {
  212. if($data['is_create']){
  213. $model->whereColumn('dispatch_complete_quantity', '>=', 'production_quantity');
  214. }else{
  215. $model->whereColumn('production_quantity', '>', 'dispatch_complete_quantity');
  216. }
  217. }
  218. $list = $this->limit($model,'',$data);
  219. $list = $this->fillData($list);
  220. return [true,$list];
  221. }
  222. public function orderListRule($data){
  223. if(empty($data['process_id'])) return [false, '工序必须选择!'];
  224. if(empty($data['out_order_no_time'][0]) || empty($data['out_order_no_time'][1])) return [false,'制单日期必须选择'];
  225. $bool = $this->is_same_month($data['out_order_no_time'][0],$data['out_order_no_time'][1]);
  226. if(! $bool) return [false,'制单日期必须同月!'];
  227. $time = date("Ymd",$data['out_order_no_time'][0]);
  228. $process_model = new OrdersProductProcess(['channel' => $time]);
  229. if(! $process_model->is_table_isset()) return [true, []];//不存在process子表 返回空数据
  230. $process_array = $process_model->where('del_time',0)
  231. ->where('process_id',$data['process_id'])
  232. ->distinct()
  233. ->select('order_product_id')
  234. ->get()->toArray();
  235. $order_product_id = array_column($process_array,'order_product_id');
  236. if(empty($order_product_id)) return [true,[]];//process子表无数据 返回空数据
  237. return [true, $order_product_id];
  238. }
  239. public function orderRule($data){
  240. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  241. if($this->isEmpty($data,'quantity')) return [false,'请填写数量!'];
  242. if(in_array(false, $data['quantity'], true) || in_array(0, $data['quantity'], true) || in_array('', $data['quantity'], true))return [false,'数量不能为空!'];
  243. if(empty($data['dispatch_time'][0]) || empty($data['dispatch_time'][1])) return [false,'计划生产时间不能为空!'];
  244. if(empty($data['out_order_no_time'][0]) || empty($data['out_order_no_time'][1])) return [false,'制单时间不能为空!'];
  245. if($this->isEmpty($data,'process_id')) return [false,'工序不能为空!'];
  246. if(! isset($data['is_split'])) return [false,'是否拆分标识不能为空!'];
  247. $result = OrdersProduct::whereIn('id',$data['id'])
  248. ->select('id as order_product_id','sale_orders_product_id','order_no','table_header_mark','product_no','product_title','product_size','product_unit','production_quantity','technology_material','technology_name','wood_name','process_mark','table_body_mark','sale_orders_product_id','out_order_no_time','price','customer_name','out_order_no','customer_no')
  249. ->orderBy('id','desc')
  250. ->get()->toArray();
  251. $result_map = array_column($result,null,'order_product_id');
  252. //已派工数据
  253. $map = $this->getDispatchQuantity($data['id']);
  254. $total_map = $return = [];
  255. foreach ($data['id'] as $key => $value){
  256. if(isset($total_map[$value])){
  257. $total_map[$value] += $data['quantity'][$key];
  258. }else{
  259. $total_map[$value] = $data['quantity'][$key];
  260. }
  261. $tmp = $result_map[$value];
  262. $tmp['quantity'] = $data['quantity'][$key];
  263. $return[] = $tmp;
  264. }
  265. foreach ($result as $key => $value){
  266. //数据校验
  267. $quantity_tmp = $total_map[$value['order_product_id']];
  268. if(isset($map[$value['order_product_id']])){
  269. if($map[$value['order_product_id']] + $quantity_tmp > $value['production_quantity']) return [false,'派单数量不能大于生产订单数量'];
  270. }else{
  271. if($quantity_tmp > $value['production_quantity']) return [false,'派单数量不能大于生产订单数量'];
  272. }
  273. }
  274. return [true, $return];
  275. }
  276. public function fillData($data){
  277. if(empty($data['data'])) return $data;
  278. $map = $this->getDispatchQuantity(array_column($data['data'],'id'));
  279. $emp_map = Employee::whereIn('id',array_column($data['data'],'crt_id'))
  280. ->pluck('emp_name','id')
  281. ->toArray();
  282. foreach ($data['data'] as $key => $value){
  283. $data['data'][$key]['out_order_no_time'] = $value['out_order_no_time'] ? date('Y-m-d',$value['out_order_no_time']) : '';
  284. $data['data'][$key]['out_checker_time'] = $value['out_checker_time'] ? date('Y-m-d',$value['out_checker_time']) : '';
  285. $data['data'][$key]['production_time'] = $value['production_time'] ? date('Y-m-d',$value['production_time']) : '';
  286. $data['data'][$key]['dispatch_quantity'] = $map[$value['id']] ?? 0;
  287. $data['data'][$key]['not_dispatch_quantity'] = $value['production_quantity'] - ($map[$value['id']] ?? 0);
  288. $data['data'][$key]['order_product_man'] = $emp_map[$value['crt_id']] ?? '';
  289. if($value['dispatch_complete_quantity'] >= $value['production_quantity']){
  290. $data['data'][$key]['is_create'] = 1;
  291. }else{
  292. $data['data'][$key]['is_create'] = 0;
  293. }
  294. }
  295. $data['production_quantity'] = array_sum(array_column($data['data'], 'production_quantity'));
  296. $data['dispatch_quantity'] = array_sum(array_column($data['data'], 'dispatch_quantity'));
  297. $data['not_dispatch_quantity'] = array_sum(array_column($data['data'], 'not_dispatch_quantity'));
  298. return $data;
  299. }
  300. //返回已派工数量
  301. public function getDispatchQuantity($order_product_id = []){
  302. if(empty($order_product_id)) return [];
  303. $result = DispatchSub::where('del_time',0)
  304. ->whereIn("order_product_id",$order_product_id)
  305. ->select(DB::raw("sum(dispatch_quantity) as dispatch_quantity"),'order_product_id')
  306. ->groupby('order_product_id')
  307. ->pluck('dispatch_quantity','order_product_id')
  308. ->toArray();
  309. return $result;
  310. }
  311. public function dispatchOrderList($data){
  312. $model = DispatchSub::where('del_time',0)
  313. ->select('id','order_no','table_header_mark','product_no','product_title','product_size','product_unit','dispatch_quantity','technology_material','technology_name','wood_name','process_mark','table_body_mark','production_quantity','dispatch_no','status','crt_id','process_id','dispatch_time_start','dispatch_time_end','crt_time','finished_num','waste_num','customer_name','order_product_id','out_order_no')
  314. ->orderBy('id','desc');
  315. if(isset($data['finished_num'])) $model->where('finished_num', '>',0);
  316. if(! empty($data['order_no'])) $model->where('order_no', 'LIKE', '%'.$data['order_no'].'%');
  317. if(! empty($data['dispatch_no'])) $model->where('dispatch_no', 'LIKE', '%'.$data['dispatch_no'].'%');
  318. if(! empty($data['process_id'])) $model->where('process_id',$data['process_id']);
  319. if(! empty($data['technology_material'])) $model->where('technology_material', 'LIKE', '%'.$data['technology_material'].'%');
  320. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) $model->whereBetween('crt_time',[$data['crt_time'][0],$data['crt_time'][1]]);
  321. if(! empty($data['dispatch_time'][0]) && ! empty($data['dispatch_time'][1])){
  322. $model->where('dispatch_time_start','<=',$data['dispatch_time'][0]);
  323. $model->where('dispatch_time_end','>=',$data['dispatch_time'][1]);
  324. }
  325. if(! empty($data['team_id'])) {
  326. $res = DispatchEmpSub::where('del_time',0)
  327. ->where('team_id',$data['team_id'])
  328. ->distinct()
  329. ->select('dispatch_no')
  330. ->get()->toArray();
  331. $model->whereIn('dispatch_no',array_column($res,'dispatch_no'));
  332. }
  333. if(! empty($data['equipment_id'])) {
  334. $res = DispatchEmpSub::where('del_time',0)
  335. ->where('equipment_id',$data['equipment_id'])
  336. ->distinct()
  337. ->select('dispatch_no')
  338. ->get()->toArray();
  339. $model->whereIn('dispatch_no',array_column($res,'dispatch_no'));
  340. }
  341. if(! empty($data['employee_id'])) {
  342. $res = DispatchEmpSub::where('del_time',0)
  343. ->where('employee_id',$data['employee_id'])
  344. ->distinct()
  345. ->select('dispatch_no')
  346. ->get()->toArray();
  347. $model->whereIn('dispatch_no',array_column($res,'dispatch_no'));
  348. }
  349. $list = $this->limit($model,'',$data);
  350. $list = $this->fillDispatchOrderListData($list);
  351. return [true,$list];
  352. }
  353. public function fillDispatchOrderListData($data){
  354. if(empty($data['data'])) return $data;
  355. $emp_sub = DispatchEmpSub::where('del_time',0)
  356. ->whereIn('dispatch_no',array_column($data['data'],'dispatch_no'))
  357. ->select('dispatch_no','equipment_id','team_id','employee_id')
  358. ->get()->toArray();
  359. if(! empty($emp_sub)){
  360. $team_map = Team::whereIn('id',array_unique(array_column($emp_sub,'team_id')))
  361. ->pluck('title','id')
  362. ->toArray();
  363. $equipment_map = Gateway::whereIn('id',array_unique(array_column($emp_sub,'equipment_id')))
  364. ->pluck('title','id')
  365. ->toArray();
  366. $emp_map = Employee::whereIn('id',array_unique(array_column($emp_sub,'employee_id')))
  367. ->pluck('emp_name','id')
  368. ->toArray();
  369. $equipment_map1 = $team_map1 = $employee_map1 = $employee_map2 = $equipment_map2 = $team_map2 = [];
  370. foreach ($emp_sub as $value){
  371. $equipment_name = $equipment_map[$value['equipment_id']] ?? '';
  372. $team_name = $team_map[$value['team_id']] ?? '';
  373. $employee_name = $emp_map[$value['employee_id']] ?? '';
  374. $equipment_map1[$value['dispatch_no']][] = $equipment_name;
  375. $equipment_map2[$value['dispatch_no']][] = $value['equipment_id'];
  376. $team_map1[$value['dispatch_no']][] = $team_name;
  377. $team_map2[$value['dispatch_no']][] = $value['team_id'];
  378. $employee_map1[$value['dispatch_no']][] = $employee_name;
  379. $employee_map2[$value['dispatch_no']][] = $value['employee_id'];
  380. }
  381. }
  382. $process_map = Process::whereIn('id',array_column($data['data'],'process_id'))
  383. ->pluck('title','id')
  384. ->toArray();
  385. foreach ($data['data'] as $key => $value){
  386. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d',$value['crt_time']) : '';
  387. $time1 = $value['dispatch_time_start'] ? date('Y-m-d',$value['dispatch_time_start']) : '';
  388. $time2 = $value['dispatch_time_end'] ? date('Y-m-d',$value['dispatch_time_end']) : '';
  389. $data['data'][$key]['dispatch_time'] = $time1 . ' ' . $time2;
  390. $data['data'][$key]['process_name'] = $process_map[$value['process_id']] ?? '';
  391. $tmp = $employee_map1[$value['dispatch_no']] ?? [];
  392. $data['data'][$key]['team_man'] = implode(',',array_unique($tmp));
  393. $tmp = $employee_map2[$value['dispatch_no']] ?? [];
  394. $data['data'][$key]['team_man_id'] = array_unique($tmp);
  395. $tmp = $team_map1[$value['dispatch_no']] ?? [];
  396. $data['data'][$key]['team_name'] = implode(',',array_unique($tmp));
  397. $tmp = $team_map2[$value['dispatch_no']] ?? [];
  398. $data['data'][$key]['team_id'] = implode(',',array_unique($tmp));
  399. $tmp = $equipment_map1[$value['dispatch_no']] ?? [];
  400. $data['data'][$key]['equipment_name'] = implode(',',array_unique($tmp));
  401. $tmp = $equipment_map2[$value['dispatch_no']] ?? [];
  402. $data['data'][$key]['equipment_id'] = implode(',',array_unique($tmp));
  403. $data['data'][$key]['un_finished_quantity'] = $value['dispatch_quantity'] - $value['finished_num'] - $value['waste_num'];
  404. }
  405. $data['dispatch_quantity'] = array_sum(array_column($data['data'], 'dispatch_quantity'));
  406. return $data;
  407. }
  408. //反写写派工数量(增加)
  409. public function writeDispatchQuantity($order_product_id){
  410. if(empty($order_product_id)) return;
  411. $result = DispatchSub::where('del_time',0)
  412. ->whereIn('order_product_id',$order_product_id)
  413. ->select(DB::raw("sum(dispatch_quantity) as dispatch_quantity"),'order_product_id')
  414. ->groupby('order_product_id')
  415. ->pluck('dispatch_quantity','order_product_id')
  416. ->toArray();
  417. if(empty($result)) return;
  418. foreach ($result as $key => $value){
  419. OrdersProduct::where('id',$key)->update([
  420. 'dispatch_complete_quantity' => $value
  421. ]);
  422. }
  423. }
  424. //反写写派工数量(删除)
  425. public function writeDispatchQuantityDEL($order_product_id){
  426. if(empty($order_product_id)) return;
  427. $result = DispatchSub::where('del_time',0)
  428. ->whereIn('order_product_id',$order_product_id)
  429. ->select(DB::raw("sum(dispatch_quantity) as dispatch_quantity"),'order_product_id')
  430. ->groupby('order_product_id')
  431. ->pluck('dispatch_quantity','order_product_id')
  432. ->toArray();
  433. foreach ($order_product_id as $value){
  434. $quantity = $result[$value] ?? 0;
  435. OrdersProduct::where('id',$value)->update([
  436. 'dispatch_complete_quantity' => $quantity
  437. ]);
  438. }
  439. }
  440. //设备上的去完工列表
  441. public function dispatchMobileOrderList($data){
  442. $model = DispatchSub::where('del_time',0)
  443. ->select('id','product_title','product_no','dispatch_quantity','finished_num','dispatch_no','waste_num')
  444. ->whereRaw('dispatch_quantity > finished_num')
  445. ->orderBy('id','desc');
  446. if(! empty($data['process_id'])) $model->where('process_id',$data['process_id']);
  447. if(! empty($data['order_number'])) $model->where('dispatch_no',$data['dispatch_no']);
  448. $list = $model->get()->toArray();
  449. $list = $this->fillDispatchMobileOrderList($list);
  450. return [true,$list];
  451. }
  452. public function fillDispatchMobileOrderList($data){
  453. if(empty($data)) return $data;
  454. foreach ($data as $key => $value){
  455. $data[$key]['un_finished_quantity'] = $value['dispatch_quantity'] - $value['finished_num'] - $value['waste_num'];
  456. }
  457. $return['product_num'] = count($data);
  458. $return['finished_num'] = array_sum(array_column($data, 'finished_num'));
  459. $return['un_finished_quantity'] = array_sum(array_column($data, 'un_finished_quantity'));
  460. $return['data'] = $data;
  461. unset($data);
  462. return $return;
  463. }
  464. //设备上完工填写数据的页面
  465. public function dispatchMobileOrderDetailsList($data){
  466. if(empty($data['id'])) return [false,'派工单ID不能为空!'];
  467. $dispatch = DispatchSub::whereIn('id',$data['id'])
  468. ->where('del_time',0)
  469. ->select('id','product_title','product_no','dispatch_no',DB::raw('(dispatch_quantity - finished_num) as quantity'))
  470. ->get()->toArray();
  471. $sub = DispatchEmpSub::where('del_time',0)
  472. ->whereIn('dispatch_no',array_column($dispatch,'dispatch_no'))
  473. ->select('dispatch_no','equipment_id','team_id','employee_id')
  474. ->get()->toArray();
  475. $sub_map = [];
  476. foreach ($sub as $s){
  477. $array = [
  478. 'equipment_id' => $s['equipment_id'],
  479. 'team_id' => $s['team_id'],
  480. 'employee_id' => $s['employee_id'],
  481. ];
  482. if(empty($sub_map[$s['dispatch_no']])){
  483. $sub_map[$s['dispatch_no']][] = $array;
  484. }else{
  485. if(! in_array($array,$sub_map[$s['dispatch_no']])) {
  486. $sub_map[$s['dispatch_no']][] = $array;
  487. }
  488. }
  489. }
  490. $return_list = $return_details = [];
  491. foreach ($dispatch as $value){
  492. $dispatch_tmp = $sub_map[$value['dispatch_no']];
  493. $counts = count($dispatch_tmp) ?? 1;
  494. // 计算每个人应该得到的数量
  495. $per_person = floor($value['quantity'] / $counts);
  496. // 计算最后一个人拿到的数量
  497. $last_person = $value['quantity'] - ($per_person * ($counts - 1));
  498. foreach ($dispatch_tmp as $k => $t){
  499. $dispatch_tmp[$k]['id'] = $value['id'];
  500. $dispatch_tmp[$k]['product_title'] = $value['product_title'];
  501. $dispatch_tmp[$k]['product_no'] = $value['product_no'];
  502. $dispatch_tmp[$k]['dispatch_no'] = $value['dispatch_no'];
  503. if ($k == $counts - 1) {
  504. $dispatch_tmp[$k]['quantity'] = (int)$last_person;
  505. }else{
  506. $dispatch_tmp[$k]['quantity'] = (int)$per_person;
  507. }
  508. }
  509. //列数据
  510. $return_list = array_merge_recursive($return_list,$dispatch_tmp);
  511. //总数量
  512. $return_details[$value['id']] = $value['quantity'];
  513. }
  514. $return['list'] = $return_list;
  515. $return['list_details'] = $return_details;
  516. return [true, $return];
  517. }
  518. }