DispatchService.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601
  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\Equipment;
  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. }
  57. public function makeData($equipment_id, $team_id,$employee_id,$message){
  58. $arr = [];
  59. if(! empty($equipment_id)){
  60. foreach ($equipment_id as $v_e){
  61. if(! empty($team_id)){
  62. foreach ($team_id as $t){
  63. if(! empty($employee_id)){
  64. foreach ($employee_id as $e){
  65. $arr[] = [
  66. 'equipment_id' => $v_e,
  67. 'team_id' => $t,
  68. 'employee_id' => $e,
  69. 'order_product_id' => $message['order_product_id'],
  70. 'dispatch_no' => $message['dispatch_no'],
  71. ];
  72. }
  73. }else{
  74. $arr[] = [
  75. 'equipment_id' => $v_e,
  76. 'team_id' => $t,
  77. 'order_product_id' => $message['order_product_id'],
  78. 'dispatch_no' => $message['dispatch_no'],
  79. ];
  80. }
  81. }
  82. }elseif(! empty($employee_id)){
  83. foreach ($employee_id as $e){
  84. $arr[] = [
  85. 'equipment_id' => $v_e,
  86. 'employee_id' => $e,
  87. 'order_product_id' => $message['order_product_id'],
  88. 'dispatch_no' => $message['dispatch_no'],
  89. ];
  90. }
  91. }else{
  92. $arr[] = [
  93. 'equipment_id' => $v_e,
  94. 'order_product_id' => $message['order_product_id'],
  95. 'dispatch_no' => $message['dispatch_no'],
  96. ];
  97. }
  98. }
  99. }elseif (! empty($team_id)){
  100. foreach ($team_id as $t){
  101. if(! empty($employee_id)){
  102. foreach ($employee_id as $e){
  103. $arr[] = [
  104. 'team_id' => $t,
  105. 'employee_id' => $e,
  106. 'order_product_id' => $message['order_product_id'],
  107. 'dispatch_no' => $message['dispatch_no'],
  108. ];
  109. }
  110. }else{
  111. $arr[] = [
  112. 'team_id' => $t,
  113. 'order_product_id' => $message['order_product_id'],
  114. 'dispatch_no' => $message['dispatch_no'],
  115. ];
  116. }
  117. }
  118. }elseif(! empty($employee_id)){
  119. foreach ($employee_id as $e){
  120. $arr[] = [
  121. 'employee_id' => $e,
  122. 'order_product_id' => $message['order_product_id'],
  123. 'dispatch_no' => $message['dispatch_no'],
  124. ];
  125. }
  126. }
  127. return $arr;
  128. }
  129. public function insertDispatch($msg, $data, $user){
  130. //生产数据的源数据
  131. $result = $msg;
  132. $time = time();
  133. $dispatch_no = $this->setOrderNO();
  134. //主表
  135. Dispatch::insert(['dispatch_no' => $dispatch_no,'crt_time' => $time]);
  136. date_default_timezone_set("PRC");
  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. }
  163. DispatchSub::insert($result);
  164. if(! empty($insert_emp_sub)) DispatchEmpSub::insert($insert_emp_sub);
  165. }
  166. public function del($data){
  167. if($this->isEmpty($data,'id')) return [false,'ID不能为空!'];
  168. return [true,'删除成功'];
  169. }
  170. public function orderDetail($data){
  171. return [200,''];
  172. }
  173. public function is_same_month($timestamp1,$timestamp2){
  174. date_default_timezone_set("PRC");
  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')
  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. $list = $this->limit($model,'',$data);
  212. $list = $this->fillData($list);
  213. return [true,$list];
  214. }
  215. public function orderListRule($data){
  216. if(empty($data['process_id'])) return [false, '工序必须选择!'];
  217. if(empty($data['out_order_no_time'][0]) || empty($data['out_order_no_time'][1])) return [false,'制单日期必须选择'];
  218. $bool = $this->is_same_month($data['out_order_no_time'][0],$data['out_order_no_time'][1]);
  219. if(! $bool) return [false,'制单日期必须同月!'];
  220. date_default_timezone_set("PRC");
  221. $time = date("Ymd",$data['out_order_no_time'][0]);
  222. $process_model = new OrdersProductProcess(['channel' => $time]);
  223. if(! $process_model->is_table_isset()) return [true, []];//不存在process子表 返回空数据
  224. $process_array = $process_model->where('del_time',0)
  225. ->where('process_id',$data['process_id'])
  226. ->distinct()
  227. ->select('order_product_id')
  228. ->get()->toArray();
  229. $order_product_id = array_column($process_array,'order_product_id');
  230. if(empty($order_product_id)) return [true,[]];//process子表无数据 返回空数据
  231. return [true, $order_product_id];
  232. }
  233. public function orderRule($data){
  234. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  235. if($this->isEmpty($data,'quantity')) return [false,'请填写数量!'];
  236. if(in_array(false, $data['quantity'], true) || in_array(0, $data['quantity'], true) || in_array('', $data['quantity'], true))return [false,'数量不能为空!'];
  237. if(empty($data['dispatch_time'][0]) || empty($data['dispatch_time'][1])) return [false,'计划生产时间不能为空!'];
  238. if(empty($data['out_order_no_time'][0]) || empty($data['out_order_no_time'][1])) return [false,'制单时间不能为空!'];
  239. if($this->isEmpty($data,'process_id')) return [false,'工序不能为空!'];
  240. if(! isset($data['is_split'])) return [false,'是否拆分标识不能为空!'];
  241. $result = OrdersProduct::whereIn('id',$data['id'])
  242. ->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')
  243. ->orderBy('id','desc')
  244. ->get()->toArray();
  245. $result_map = array_column($result,null,'order_product_id');
  246. //已派工数据
  247. $map = $this->getDispatchQuantity($data['id']);
  248. $total_map = $return = [];
  249. if($data['is_split']){
  250. foreach ($data['id'] as $key => $value){
  251. if(isset($total_map[$value])){
  252. $total_map[$value] += $data['quantity'][$key];
  253. }else{
  254. $total_map[$value] = $data['quantity'][$key];
  255. }
  256. $tmp = $result_map[$value];
  257. $tmp['quantity'] = $data['quantity'][$key];
  258. $return[] = $tmp;
  259. }
  260. }
  261. foreach ($result as $key => $value){
  262. //数据校验
  263. $quantity_tmp = $total_map[$value['order_product_id']] ?? $data['quantity'][$key];
  264. if(isset($map[$value['order_product_id']])){
  265. if($map[$value['order_product_id']] + $quantity_tmp > $value['production_quantity']) return [false,'派单数量不能大于生产订单数量'];
  266. }else{
  267. if($quantity_tmp > $value['production_quantity']) return [false,'派单数量不能大于生产订单数量'];
  268. }
  269. if(! empty($return)) $result[$key]['quantity'] = $data['quantity'][$key];
  270. }
  271. $array = ! empty($return) ? $return : $result;
  272. return [true, $array];
  273. }
  274. public function fillData($data){
  275. if(empty($data['data'])) return $data;
  276. $map = $this->getDispatchQuantity(array_column($data['data'],'id'));
  277. $emp_map = Employee::whereIn('id',array_column($data['data'],'crt_id'))
  278. ->pluck('emp_name','id')
  279. ->toArray();
  280. date_default_timezone_set("PRC");
  281. foreach ($data['data'] as $key => $value){
  282. $data['data'][$key]['out_order_no_time'] = $value['out_order_no_time'] ? date('Y-m-d',$value['out_order_no_time']) : '';
  283. $data['data'][$key]['out_checker_time'] = $value['out_checker_time'] ? date('Y-m-d',$value['out_checker_time']) : '';
  284. $data['data'][$key]['production_time'] = $value['production_time'] ? date('Y-m-d',$value['production_time']) : '';
  285. $data['data'][$key]['dispatch_quantity'] = $map[$value['id']] ?? 0;
  286. $data['data'][$key]['not_dispatch_quantity'] = $value['production_quantity'] - ($map[$value['id']] ?? 0);
  287. $data['data'][$key]['order_product_man'] = $emp_map[$value['crt_id']] ?? '';
  288. }
  289. $data['production_quantity'] = array_sum(array_column($data['data'], 'production_quantity'));
  290. $data['dispatch_quantity'] = array_sum(array_column($data['data'], 'dispatch_quantity'));
  291. $data['not_dispatch_quantity'] = array_sum(array_column($data['data'], 'not_dispatch_quantity'));
  292. return $data;
  293. }
  294. //返回已派工数量
  295. public function getDispatchQuantity($order_product_id = []){
  296. if(empty($order_product_id)) return [];
  297. $result = DispatchSub::where('del_time',0)
  298. ->whereIn("order_product_id",$order_product_id)
  299. ->select(DB::raw("sum(dispatch_quantity) as dispatch_quantity"),'order_product_id')
  300. ->groupby('order_product_id')
  301. ->pluck('dispatch_quantity','order_product_id')
  302. ->toArray();
  303. return $result;
  304. }
  305. public function dispatchOrderList($data){
  306. $model = DispatchSub::where('del_time',0)
  307. ->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')
  308. ->orderBy('id','desc');
  309. if(isset($data['finished_num'])) $model->where('finished_num', '>',0);
  310. if(! empty($data['order_no'])) $model->where('order_no', 'LIKE', '%'.$data['order_no'].'%');
  311. if(! empty($data['dispatch_no'])) $model->where('dispatch_no', 'LIKE', '%'.$data['dispatch_no'].'%');
  312. if(! empty($data['process_id'])) $model->where('process_id',$data['process_id']);
  313. if(! empty($data['technology_material'])) $model->where('technology_material', 'LIKE', '%'.$data['technology_material'].'%');
  314. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) $model->whereBetween('crt_time',[$data['crt_time'][0],$data['crt_time'][1]]);
  315. if(! empty($data['dispatch_time'][0]) && ! empty($data['dispatch_time'][1])){
  316. $model->where('dispatch_time_start','<=',$data['dispatch_time'][0]);
  317. $model->where('dispatch_time_end','>=',$data['dispatch_time'][1]);
  318. }
  319. if(! empty($data['team_id'])) {
  320. $res = DispatchEmpSub::where('del_time',0)
  321. ->where('team_id',$data['team_id'])
  322. ->distinct()
  323. ->select('dispatch_no')
  324. ->get()->toArray();
  325. $model->whereIn('dispatch_no',array_column($res,'dispatch_no'));
  326. }
  327. if(! empty($data['equipment_id'])) {
  328. $res = DispatchEmpSub::where('del_time',0)
  329. ->where('equipment_id',$data['equipment_id'])
  330. ->distinct()
  331. ->select('dispatch_no')
  332. ->get()->toArray();
  333. $model->whereIn('dispatch_no',array_column($res,'dispatch_no'));
  334. }
  335. if(! empty($data['employee_id'])) {
  336. $res = DispatchEmpSub::where('del_time',0)
  337. ->where('employee_id',$data['employee_id'])
  338. ->distinct()
  339. ->select('dispatch_no')
  340. ->get()->toArray();
  341. $model->whereIn('dispatch_no',array_column($res,'dispatch_no'));
  342. }
  343. $list = $this->limit($model,'',$data);
  344. $list = $this->fillDispatchOrderListData($list);
  345. return [true,$list];
  346. }
  347. public function fillDispatchOrderListData($data){
  348. if(empty($data['data'])) return $data;
  349. $emp_sub = DispatchEmpSub::where('del_time',0)
  350. ->whereIn('dispatch_no',array_column($data['data'],'dispatch_no'))
  351. ->select('dispatch_no','equipment_id','team_id','employee_id')
  352. ->get()->toArray();
  353. if(! empty($emp_sub)){
  354. $team_map = Team::whereIn('id',array_unique(array_column($emp_sub,'team_id')))
  355. ->pluck('title','id')
  356. ->toArray();
  357. $equipment_map = Equipment::whereIn('id',array_unique(array_column($emp_sub,'equipment_id')))
  358. ->pluck('title','id')
  359. ->toArray();
  360. $emp_map = Employee::whereIn('id',array_unique(array_column($emp_sub,'employee_id')))
  361. ->pluck('emp_name','id')
  362. ->toArray();
  363. $equipment_map1 = $team_map1 = $employee_map1 = $employee_map2 = $equipment_map2 = $team_map2 = [];
  364. foreach ($emp_sub as $value){
  365. $equipment_name = $equipment_map[$value['equipment_id']] ?? '';
  366. $team_name = $team_map[$value['team_id']] ?? '';
  367. $employee_name = $emp_map[$value['employee_id']] ?? '';
  368. $equipment_map1[$value['dispatch_no']][] = $equipment_name;
  369. $equipment_map2[$value['dispatch_no']][] = $value['equipment_id'];
  370. $team_map1[$value['dispatch_no']][] = $team_name;
  371. $team_map2[$value['dispatch_no']][] = $value['team_id'];
  372. $employee_map1[$value['dispatch_no']][] = $employee_name;
  373. $employee_map2[$value['dispatch_no']][] = $value['employee_id'];
  374. }
  375. }
  376. $process_map = Process::whereIn('id',array_column($data['data'],'process_id'))
  377. ->pluck('title','id')
  378. ->toArray();
  379. $order_map = Orders::where('del_time',0)
  380. ->whereIn('order_no',array_column($data['data'],'order_no'))
  381. ->pluck('out_order_no','order_no')
  382. ->toArray();
  383. date_default_timezone_set("PRC");
  384. foreach ($data['data'] as $key => $value){
  385. $data['data'][$key]['out_order_no'] = $order_map[$value['order_no']] ?? '';
  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. $data['data'][$key]['team_man'] = implode(',',array_unique($employee_map1[$value['dispatch_no']]));
  392. $data['data'][$key]['team_man_id'] = array_unique($employee_map2[$value['dispatch_no']]);
  393. $data['data'][$key]['team_name'] = implode(',',array_unique($team_map1[$value['dispatch_no']]));
  394. $data['data'][$key]['team_id'] = implode(',',array_unique($team_map2[$value['dispatch_no']]));
  395. $data['data'][$key]['equipment_name'] = implode(',',array_unique($equipment_map1[$value['dispatch_no']]));
  396. $data['data'][$key]['equipment_id'] = implode(',',array_unique($equipment_map2[$value['dispatch_no']]));
  397. $data['data'][$key]['un_finished_quantity'] = $value['dispatch_quantity'] - $value['finished_num'];
  398. }
  399. $data['dispatch_quantity'] = array_sum(array_column($data['data'], 'dispatch_quantity'));
  400. return $data;
  401. }
  402. //反写写派工数量(增加)
  403. public function writeDispatchQuantity($order_product_id){
  404. if(empty($order_product_id)) return;
  405. $result = DispatchSub::where('del_time',0)
  406. ->whereIn('order_product_id',$order_product_id)
  407. ->select(DB::raw("sum(dispatch_quantity) as dispatch_quantity"),'order_product_id')
  408. ->groupby('order_product_id')
  409. ->pluck('dispatch_quantity','order_product_id')
  410. ->toArray();
  411. if(empty($result)) return;
  412. foreach ($result as $key => $value){
  413. OrdersProduct::where('id',$key)->update([
  414. 'dispatch_complete_quantity' => $value
  415. ]);
  416. }
  417. }
  418. //反写写派工数量(删除)
  419. public function writeDispatchQuantityDEL($order_product_id){
  420. if(empty($order_product_id)) return;
  421. $result = DispatchSub::where('del_time',0)
  422. ->whereIn('order_product_id',$order_product_id)
  423. ->select(DB::raw("sum(dispatch_quantity) as dispatch_quantity"),'order_product_id')
  424. ->groupby('order_product_id')
  425. ->pluck('dispatch_quantity','order_product_id')
  426. ->toArray();
  427. foreach ($order_product_id as $value){
  428. $quantity = $result[$value] ?? 0;
  429. OrdersProduct::where('id',$value)->update([
  430. 'dispatch_complete_quantity' => $quantity
  431. ]);
  432. }
  433. }
  434. //设备上的去完工列表
  435. public function dispatchMobileOrderList($data){
  436. $model = DispatchSub::where('del_time',0)
  437. ->select('id','product_title','product_no','dispatch_quantity','finished_num','dispatch_no')
  438. ->whereRaw('dispatch_quantity > finished_num')
  439. ->orderBy('id','desc');
  440. if(! empty($data['process_id'])) $model->where('process_id',$data['process_id']);
  441. if(! empty($data['order_number'])) $model->where('dispatch_no',$data['dispatch_no']);
  442. $list = $model->get()->toArray();
  443. $list = $this->fillDispatchMobileOrderList($list);
  444. return [true,$list];
  445. }
  446. public function fillDispatchMobileOrderList($data){
  447. if(empty($data)) return $data;
  448. date_default_timezone_set("PRC");
  449. foreach ($data as $key => $value){
  450. $data[$key]['un_finished_quantity'] = $value['dispatch_quantity'] - $value['finished_num'];
  451. }
  452. $return['product_num'] = count($data);
  453. $return['finished_num'] = array_sum(array_column($data, 'finished_num'));
  454. $return['un_finished_quantity'] = array_sum(array_column($data, 'un_finished_quantity'));
  455. $return['data'] = $data;
  456. unset($data);
  457. return $return;
  458. }
  459. //设备上完工填写数据的页面
  460. public function dispatchMobileOrderDetailsList($data){
  461. if(empty($data['id'])) return [false,'派工单ID不能为空!'];
  462. $dispatch = DispatchSub::whereIn('id',$data['id'])
  463. ->where('del_time',0)
  464. ->select('id','product_title','product_no','dispatch_no',DB::raw('(dispatch_quantity - finished_num) as quantity'))
  465. ->get()->toArray();
  466. $sub = DispatchEmpSub::where('del_time',0)
  467. ->whereIn('dispatch_no',array_column($dispatch,'dispatch_no'))
  468. ->select('dispatch_no','equipment_id','team_id','employee_id')
  469. ->get()->toArray();
  470. $sub_map = [];
  471. foreach ($sub as $s){
  472. $array = [
  473. 'equipment_id' => $s['equipment_id'],
  474. 'team_id' => $s['team_id'],
  475. 'employee_id' => $s['employee_id'],
  476. ];
  477. if(empty($sub_map[$s['dispatch_no']])){
  478. $sub_map[$s['dispatch_no']][] = $array;
  479. }else{
  480. if(! in_array($array,$sub_map[$s['dispatch_no']])) {
  481. $sub_map[$s['dispatch_no']][] = $array;
  482. }
  483. }
  484. }
  485. $return_list = $return_details = [];
  486. foreach ($dispatch as $value){
  487. $dispatch_tmp = $sub_map[$value['dispatch_no']];
  488. $counts = count($dispatch_tmp) ?? 1;
  489. // 计算每个人应该得到的数量
  490. $per_person = floor($value['quantity'] / $counts);
  491. // 计算最后一个人拿到的数量
  492. $last_person = $value['quantity'] - ($per_person * ($counts - 1));
  493. foreach ($dispatch_tmp as $k => $t){
  494. $dispatch_tmp[$k]['id'] = $value['id'];
  495. $dispatch_tmp[$k]['product_title'] = $value['product_title'];
  496. $dispatch_tmp[$k]['product_no'] = $value['product_no'];
  497. $dispatch_tmp[$k]['dispatch_no'] = $value['dispatch_no'];
  498. if ($k == $counts - 1) {
  499. $dispatch_tmp[$k]['quantity'] = (int)$last_person;
  500. }else{
  501. $dispatch_tmp[$k]['quantity'] = (int)$per_person;
  502. }
  503. }
  504. //列数据
  505. $return_list = array_merge_recursive($return_list,$dispatch_tmp);
  506. //总数量
  507. $return_details[$value['id']] = $value['quantity'];
  508. }
  509. $return['list'] = $return_list;
  510. $return['list_details'] = $return_details;
  511. return [true, $return];
  512. }
  513. }