OrderService.php 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957
  1. <?php
  2. namespace App\Service;
  3. use App\Model\Employee;
  4. use App\Model\Order;
  5. use App\Model\OrderDetails;
  6. use App\Model\Reminder;
  7. use App\Model\ReminderDetails;
  8. use App\Model\ReminderRecord;
  9. use App\Model\ReminderRecordDetails;
  10. use App\Model\TodoList;
  11. use Illuminate\Support\Facades\DB;
  12. class OrderService extends Service
  13. {
  14. public function orderEdit($data,$user){
  15. list($status,$msg) = $this->orderRule($data, $user, false);
  16. if(!$status) return [$status,$msg];
  17. try {
  18. DB::beginTransaction();
  19. $model = Order::where('id',$data['id'])->first();
  20. $model->order_number = $data['order_number'] ?? '';
  21. $model->customer_id = $data['customer_id'] ?? 0;
  22. $model->supply_id = $data['supply_id'] ?? 0;
  23. $model->order_time = $data['order_time'] ?? 0;
  24. $model->quantity = $data['quantity'] ?? 0;
  25. $model->save();
  26. $time = time();
  27. OrderDetails::where('del_time',0)
  28. ->where('order_id', $model->id)
  29. ->update(['del_time' => $time]);
  30. $this->saveDetail($model->id, $time, $data);
  31. DB::commit();
  32. }catch (\Exception $exception){
  33. DB::rollBack();
  34. return [false,$exception->getMessage()];
  35. }
  36. return [true, ''];
  37. }
  38. public function orderAdd($data,$user){
  39. list($status,$msg) = $this->orderRule($data, $user);
  40. if(!$status) return [$status,$msg];
  41. try {
  42. DB::beginTransaction();
  43. $model = new Order();
  44. $model->order_number = $data['order_number'] ?? '';
  45. $model->customer_id = $data['customer_id'] ?? 0;
  46. $model->supply_id = $data['supply_id'] ?? 0;
  47. $model->order_time = $data['order_time'] ?? 0;
  48. $model->quantity = $data['quantity'] ?? 0;
  49. $model->crt_id = $user['id'];
  50. $model->save();
  51. $this->saveDetail($model->id, time(), $data);
  52. DB::commit();
  53. }catch (\Exception $exception){
  54. DB::rollBack();
  55. return [false,$exception->getMessage()];
  56. }
  57. return [true, ''];
  58. }
  59. private function saveDetail($id, $time, $data){
  60. if(! empty($data['details'])){
  61. $unit = [];
  62. foreach ($data['details'] as $value){
  63. $unit[] = [
  64. 'order_id' => $id,
  65. 'code' => $value['code'],
  66. 'title' => $value['title'],
  67. 'size' => $value['size'] ?? "",
  68. 'unit' => $value['unit'] ?? "",
  69. 'quantity' => $value['quantity'],
  70. 'crt_time' => $time,
  71. ];
  72. }
  73. if(! empty($unit)) OrderDetails::insert($unit);
  74. }
  75. }
  76. private function getDetail($id){
  77. $data = OrderDetails::where('del_time',0)
  78. ->where('order_id', $id)
  79. ->get()->toArray();
  80. $unit = [];
  81. foreach ($data as $value){
  82. $unit[] = [
  83. 'code' => $value['code'],
  84. 'title' => $value['title'],
  85. 'size' => $value['size'],
  86. 'unit' => $value['unit'],
  87. 'quantity' => $value['quantity'],
  88. ];
  89. }
  90. $detail = [
  91. 'details' => $unit,
  92. ];
  93. foreach ($detail as $key => $value) {
  94. if (empty($value)) {
  95. $detail[$key] = (object)[]; // 转成 stdClass 对象
  96. }
  97. }
  98. return $detail;
  99. }
  100. public function orderDel($data){
  101. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  102. try {
  103. DB::beginTransaction();
  104. $time = time();
  105. Order::where('del_time',0)
  106. ->whereIn('id',$data['id'])
  107. ->update(['del_time' => $time]);
  108. OrderDetails::where('del_time',0)
  109. ->where('order_id', $data['id'])
  110. ->update(['del_time' => $time]);
  111. DB::commit();
  112. }catch (\Exception $exception){
  113. DB::rollBack();
  114. return [false,$exception->getMessage()];
  115. }
  116. return [true, ''];
  117. }
  118. public function orderDetail($data, $user){
  119. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  120. $customer = Order::where('del_time',0)
  121. ->where('id',$data['id'])
  122. ->first();
  123. if(empty($customer)) return [false,'订单不存在或已被删除'];
  124. $customer = $customer->toArray();
  125. $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('emp_name');
  126. $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
  127. $details = $this->getDetail($data['id']);
  128. $customer = array_merge($customer, $details);
  129. return [true, $customer];
  130. }
  131. public function orderCommon($data,$user, $field = []){
  132. if(empty($field)) $field = Order::$field;
  133. $model = Order::Clear($user,$data);
  134. $model = $model->where('del_time',0)
  135. ->select($field)
  136. ->orderby('id', 'desc');
  137. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  138. if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
  139. if(! empty($data['id'])) $model->whereIn('id', $data['id']);
  140. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  141. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  142. $model->where('crt_time','>=',$return[0]);
  143. $model->where('crt_time','<=',$return[1]);
  144. }
  145. if(! empty($data['order_time'][0]) && ! empty($data['order_time'][1])) {
  146. $return = $this->changeDateToTimeStampAboutRange($data['order_time']);
  147. $model->where('order_time','>=',$return[0]);
  148. $model->where('order_time','<=',$return[1]);
  149. }
  150. return $model;
  151. }
  152. public function orderList($data,$user){
  153. $model = $this->orderCommon($data, $user);
  154. $list = $this->limit($model,'',$data);
  155. $list = $this->fillData($list,$user,$data);
  156. $list['count'] = $this->countTotal($list['data'], $user['header_default']);
  157. return [true, $list];
  158. }
  159. public function orderRule(&$data, $user, $is_add = true){
  160. if(empty($data['order_number'])) return [false, '订单号不能为空'];
  161. if(empty($data['order_time'])) return [false, '订单日期不能为空'];
  162. $data['order_time'] = $this->changeDateToDate($data['order_time']);
  163. if(empty($data['details'])) return [false, '物料不能为空'];
  164. $total = 0;
  165. foreach ($data['details'] as $value){
  166. if(empty($value['code'])) return [false, '物料编码不能为空'];
  167. if(empty($value['title'])) return [false, '物料名称不能为空'];
  168. $res = $this->checkNumber($data['quantity'],2,'positive');
  169. if(! $res['valid']) return [false,'物料数量:' . $res['error']];
  170. $total = bcadd($total, $value['quantity'],2);
  171. }
  172. $data['quantity'] = $total;
  173. list($status, $msg) = $this->checkArrayRepeat($data['details'],'code','物料编码');
  174. if(! $status) return [false, $msg];
  175. if($is_add){
  176. $bool = Order::where('order_number',$data['order_number'])
  177. ->where('crt_id', $user['id'])
  178. ->where('del_time',0)
  179. ->exists();
  180. }else{
  181. if(empty($data['id'])) return [false,'ID不能为空'];
  182. $bool = Order::where('order_number',$data['order_number'])
  183. ->where('crt_id', $user['id'])
  184. ->where('id','<>',$data['id'])
  185. ->where('del_time',0)
  186. ->exists();
  187. }
  188. if($bool) return [false, '订单号已存在'];
  189. return [true, $data];
  190. }
  191. public function fillData($data, $user, $search){
  192. if(empty($data['data'])) return $data;
  193. $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_column($data['data'],'id')));
  194. $emp_2 = (new CustomerSupplyService())->getEmployeeMap(array_unique(array_merge_recursive(array_column($data['data'],'customer_id'), array_column($data['data'],'supply_id'))));
  195. foreach ($data['data'] as $key => $value){
  196. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
  197. $data['data'][$key]['order_time'] = $value['order_time'] ? date('Y-m-d',$value['order_time']) : '';
  198. $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
  199. $data['data'][$key]['customer_title'] = $emp_2[$value['customer_id']] ?? '';
  200. $data['data'][$key]['supply_title'] = $emp_2[$value['supply_id']] ?? '';
  201. }
  202. return $data;
  203. }
  204. //催单管理---------------------------------------------
  205. public function reminderEdit($data,$user){
  206. list($status,$msg) = $this->reminderRule($data, $user, false);
  207. if(!$status) return [$status,$msg];
  208. try {
  209. DB::beginTransaction();
  210. $model = Reminder::where('id',$data['id'])->first();
  211. $model->order_id = $data['order_id'] ?? 0;
  212. $model->order_no = $data['order_no'] ?? '';
  213. $model->product_code = $data['product_code'] ?? '';
  214. $model->product_size = $data['product_size'] ?? '';
  215. $model->product_unit = $data['product_unit'] ?? '';
  216. $model->product_title = $data['product_title'] ?? '';
  217. $model->quantity = $data['quantity'] ?? 0;
  218. $model->order_time = $data['order_time'] ?? 0;
  219. $model->lt_arrived_time = $data['lt_arrived_time'] ?? 0;
  220. $model->tl_arrived_time = $data['tl_arrived_time'] ?? 0;
  221. $model->tl_quantity = $data['tl_quantity'] ?? 0;
  222. $model->df_type = $data['df_type'] ?? 0;
  223. $model->save();
  224. $time = time();
  225. ReminderDetails::where('del_time',0)
  226. ->where('reminder_id', $model->id)
  227. ->update(['del_time' => $time]);
  228. $this->saveDetail1($model->id, $time, $data);
  229. DB::commit();
  230. }catch (\Exception $exception){
  231. DB::rollBack();
  232. return [false,$exception->getMessage()];
  233. }
  234. return [true, ''];
  235. }
  236. public function reminderAdd($data,$user){
  237. list($status,$msg) = $this->reminderRule($data, $user);
  238. if(!$status) return [$status,$msg];
  239. try {
  240. DB::beginTransaction();
  241. $model = new Reminder();
  242. $model->order_number = $this->createOrderNumber();
  243. $model->order_id = $data['order_id'] ?? 0;
  244. $model->order_no = $data['order_no'] ?? '';
  245. $model->product_code = $data['product_code'] ?? '';
  246. $model->product_size = $data['product_size'] ?? '';
  247. $model->product_unit = $data['product_unit'] ?? '';
  248. $model->product_title = $data['product_title'] ?? '';
  249. $model->quantity = $data['quantity'] ?? 0;
  250. $model->order_time = $data['order_time'] ?? 0;
  251. $model->lt_arrived_time = $data['lt_arrived_time'] ?? 0;
  252. $model->tl_arrived_time = $data['tl_arrived_time'] ?? 0;
  253. $model->tl_quantity = $data['tl_quantity'] ?? 0;
  254. $model->df_type = $data['df_type'] ?? 0;
  255. $model->crt_id = $user['id'];
  256. $model->save();
  257. $this->saveDetail1($model->id, time(), $data);
  258. DB::commit();
  259. }catch (\Exception $exception){
  260. DB::rollBack();
  261. return [false,$exception->getMessage()];
  262. }
  263. return [true, ''];
  264. }
  265. private function saveDetail1($id, $time, $data){
  266. if(! empty($data['details'])){
  267. $unit = [];
  268. foreach ($data['details'] as $value){
  269. $unit[] = [
  270. 'reminder_id' => $id,
  271. 'customer_supply_id' => $value['customer_supply_id'],
  272. 'is_main' => $value['is_main'],
  273. 'quantity' => $value['quantity'],
  274. 'crt_time' => $time,
  275. ];
  276. }
  277. if(! empty($unit)) ReminderDetails::insert($unit);
  278. }
  279. }
  280. private function getDetail1($id, $user = []){
  281. $customer_supply_id = $user['id'] ?? 0;
  282. $data = ReminderDetails::from('reminder_details as a')
  283. ->leftJoin('customer_supply as b','b.id','a.customer_supply_id')
  284. ->where('a.del_time',0)
  285. ->where('a.reminder_id', $id)
  286. ->when(! empty($customer_supply_id), function ($query) use ($customer_supply_id) {
  287. return $query->where('a.customer_supply_id', $customer_supply_id);
  288. })
  289. ->select('a.customer_supply_id','a.is_main','b.title','a.status')
  290. ->get()->toArray();
  291. $unit = $unit2 = [];
  292. foreach ($data as $value){
  293. if(! empty($customer_supply_id)) {
  294. $unit2 = [
  295. 'status' => $value['status'],
  296. ];
  297. }else{
  298. $unit[] = [
  299. 'customer_supply_id' => $value['customer_supply_id'],
  300. 'customer_supply_title' => $value['title'],
  301. 'is_main' => $value['is_main'],
  302. ];
  303. }
  304. }
  305. if(! empty($unit2)) return $unit2;
  306. $detail = [
  307. 'details' => $unit,
  308. ];
  309. foreach ($detail as $key => $value) {
  310. if (empty($value)) {
  311. $detail[$key] = (object)[]; // 转成 stdClass 对象
  312. }
  313. }
  314. return $detail;
  315. }
  316. public function reminderDel($data){
  317. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  318. $bool = Reminder::where('del_time',0)
  319. ->whereIn('id',$data['id'])
  320. ->where('status','>',Reminder::status_zero)
  321. ->exists();
  322. if($bool) return [false, '催单状态已变更,删除失败'];
  323. try {
  324. DB::beginTransaction();
  325. $time = time();
  326. Reminder::where('del_time',0)
  327. ->whereIn('id',$data['id'])
  328. ->update(['del_time' => $time]);
  329. ReminderDetails::where('del_time',0)
  330. ->where('reminder_id', $data['id'])
  331. ->update(['del_time' => $time]);
  332. DB::commit();
  333. }catch (\Exception $exception){
  334. DB::rollBack();
  335. return [false,$exception->getMessage()];
  336. }
  337. return [true, ''];
  338. }
  339. public function reminderDetail($data, $user){
  340. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  341. $customer = Reminder::where('del_time',0)
  342. ->where('id',$data['id'])
  343. ->first();
  344. if(empty($customer)) return [false,'催单不存在或已被删除'];
  345. $customer = $customer->toArray();
  346. $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('emp_name');
  347. $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
  348. $customer['order_time'] = $customer['order_time'] ? date("Y-m-d",$customer['order_time']): '';
  349. $customer['lt_arrived_time'] = $customer['lt_arrived_time'] ? date("Y-m-d",$customer['lt_arrived_time']): '';
  350. $customer['tl_arrived_time'] = $customer['tl_arrived_time'] ? date("Y-m-d",$customer['tl_arrived_time']): '';
  351. $customer['df_type_title'] = Reminder::$df_type_name[$customer['df_type']] ?? "";
  352. $customer['rule_title'] = Reminder::$rule_name[$customer['rule']] ?? "";
  353. $customer['status_title'] = Reminder::$status_name[$customer['status']] ?? "";
  354. $details = $this->getDetail1($data['id']);
  355. $customer = array_merge($customer, $details);
  356. $details_s = $this->getDetailOut($data);
  357. $customer['cd_details'] = $details_s;
  358. return [true, $customer];
  359. }
  360. public function reminderCommon($data,$user, $field = []){
  361. if(empty($field)) $field = Order::$field;
  362. $model = Reminder::Clear($user,$data);
  363. $model = $model->where('del_time',0)
  364. ->select($field)
  365. ->orderby('id', 'desc');
  366. if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
  367. if(! empty($data['order_no'])) $model->where('order_no', 'LIKE', '%'.$data['order_no'].'%');
  368. if(! empty($data['product_title'])) $model->where('product_title', 'LIKE', '%'.$data['product_title'].'%');
  369. if(! empty($data['product_code'])) $model->where('product_code', 'LIKE', '%'.$data['product_code'].'%');
  370. if(! empty($data['id'])) $model->whereIn('id', $data['id']);
  371. if(isset($data['status'])) $model->where('status', $data['status']);
  372. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  373. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  374. $model->where('crt_time','>=',$return[0]);
  375. $model->where('crt_time','<=',$return[1]);
  376. }
  377. if(! empty($data['order_time'][0]) && ! empty($data['order_time'][1])) {
  378. $return = $this->changeDateToTimeStampAboutRange($data['order_time']);
  379. $model->where('order_time','>=',$return[0]);
  380. $model->where('order_time','<=',$return[1]);
  381. }
  382. return $model;
  383. }
  384. public function reminderList($data,$user){
  385. $model = $this->reminderCommon($data, $user);
  386. $list = $this->limit($model,'',$data);
  387. $list = $this->fillReminderData($list,$user,$data);
  388. $list['count'] = $this->countTotal($list['data'], $user['header_default']);
  389. return [true, $list];
  390. }
  391. public function reminderRule(&$data, $user, $is_add = true){
  392. if(empty($data['order_id'])) return [false, '订单ID不能为空'];
  393. if(empty($data['order_no'])) return [false, '订单号不能为空'];
  394. if(empty($data['order_time'])) return [false, '订单日期不能为空'];
  395. $data['order_time'] = strtotime($data['order_time']);
  396. if(empty($data['product_code'])) return [false, '物料编码不能为空'];
  397. if(empty($data['product_title'])) return [false, '物料名称不能为空'];
  398. if(empty($data['quantity'])) return [false, '物料数量不能为空'];
  399. if(empty($data['lt_arrived_time'])) return [false, 'LT要求到货日期不能为空'];
  400. $data['lt_arrived_time'] = $this->changeDateToDate($data['lt_arrived_time']);
  401. if(empty($data['tl_arrived_time'])) return [false, '提拉到货日期不能为空'];
  402. $data['tl_arrived_time'] = $this->changeDateToDate($data['tl_arrived_time']);
  403. $res = $this->checkNumber($data['tl_quantity'],2,'positive');
  404. if(! $res['valid']) return [false,'提拉到货数量:' . $res['error']];
  405. if(empty($data['df_type'])) return [false, '要求答复时间不能为空'];
  406. if(! isset(Reminder::$df_type_name[$data['df_type']])) return [false, '要求答复时间错误'];
  407. if(empty($data['rule'])) return [false, '主要人员关系规则不能为空'];
  408. if(! isset(Reminder::$rule_name[$data['rule']])) return [false, '主要人员关系规则不存在'];
  409. if(empty($data['details'])) return [false, '催单提醒人员不能为空'];
  410. $is_bool = false;
  411. $main_ids = [];
  412. $sub_ids = [];
  413. foreach ($data['details'] as $value) {
  414. if (empty($value['customer_supply_id'])) return [false, '人员id不能为空'];
  415. if (empty($value['is_main'])) return [false, 'is_main不能为空'];
  416. $customer_id = $value['customer_supply_id'];
  417. $is_main_val = $value['is_main'];
  418. if ($is_main_val == ReminderDetails::is_main_one) {
  419. // 检查主要人员重复
  420. if (in_array($customer_id, $main_ids)) {
  421. return [false, "主要成员不能重复"];
  422. }
  423. $main_ids[] = $customer_id;
  424. $is_bool = true;
  425. } elseif ($is_main_val == ReminderDetails::is_main_two) {
  426. // 检查次要人员重复
  427. if (in_array($customer_id, $sub_ids)) {
  428. return [false, "次要成员不能重复"];
  429. }
  430. $sub_ids[] = $customer_id;
  431. }
  432. }
  433. // 检查主要成员至少一个
  434. if (!$is_bool) return [false, '主要成员必须选择'];
  435. // 检查主要与次要是否有重复
  436. $intersect = array_intersect($main_ids, $sub_ids);
  437. if (!empty($intersect)) return [false, "主要成员与次要成员不能重复"];
  438. if($is_add){
  439. }else{
  440. if(empty($data['id'])) return [false,'ID不能为空'];
  441. $order = Order::where('id',$data['id'])
  442. ->where('del_time',0)
  443. ->fist();
  444. if(empty($order)) return [false, '催单不存在或已被删除'];
  445. $order = $order->toArray();
  446. if($order['status'] > Reminder::status_zero) return [false, '催单状态已变更,编辑失败'];
  447. }
  448. return [true, $data];
  449. }
  450. public function fillReminderData($data, $user, $search){
  451. if(empty($data['data'])) return $data;
  452. $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_column($data['data'],'id')));
  453. foreach ($data['data'] as $key => $value){
  454. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
  455. $data['data'][$key]['order_time'] = $value['order_time'] ? date('Y-m-d',$value['order_time']) : '';
  456. $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
  457. $data['data'][$key]['lt_arrived_time'] = $value['lt_arrived_time'] ? date("Y-m-d",$value['lt_arrived_time']): '';
  458. $data['data'][$key]['tl_arrived_time'] = $value['tl_arrived_time'] ? date("Y-m-d",$value['tl_arrived_time']): '';
  459. $data['data'][$key]['df_type_title'] = Reminder::$df_type_name[$value['df_type']] ?? "";
  460. $data['data'][$key]['rule_title'] = Reminder::$rule_name[$value['rule']] ?? "";
  461. $data['data'][$key]['status_title'] = Reminder::$status_name[$value['status']] ?? "";
  462. }
  463. return $data;
  464. }
  465. public function createOrderNumber(){
  466. return date('YmdHis',time()) . rand(1000,9999);
  467. }
  468. public function reminderSendWx($data, $user){
  469. if(empty($data['id'])) return [false, 'ID不能为空'];
  470. $customer = Reminder::where('del_time',0)
  471. ->whereIn('id',$data['id'])
  472. ->get()->toArray();
  473. if(empty($customer)) return [false,'催单数据不存在或已被删除'];
  474. return [true, ''];
  475. }
  476. //催单管理---------------------------------------------
  477. //待办管理---------------------------------------------
  478. public function toDoEdit($data,$user){
  479. list($status,$msg) = $this->toDoRule($data, $user, false);
  480. if(!$status) return [$status,$msg];
  481. try {
  482. DB::beginTransaction();
  483. $model = TodoList::where('id',$data['id'])->first();
  484. $model->title = $data['title'] ?? "";
  485. $model->type = $data['type'] ?? '';
  486. $model->remind_start = $data['remind_start'] ?? '';
  487. $model->remind_interval = $data['remind_interval'] ?? 0;
  488. $model->last_remind_time = $data['last_remind_time'] ?? 0;
  489. $model->man_type = $data['man_type'] ?? '';
  490. $model->organization_name = $data['organization_name'] ?? '';
  491. $model->contact = $data['contact'] ?? '';
  492. $model->address = $data['address'] ?? '';
  493. $model->content = $data['content'] ?? '';
  494. $model->save();
  495. DB::commit();
  496. }catch (\Exception $exception){
  497. DB::rollBack();
  498. return [false,$exception->getMessage()];
  499. }
  500. return [true, ''];
  501. }
  502. public function toDoAdd($data,$user){
  503. list($status,$msg) = $this->toDoRule($data, $user);
  504. if(!$status) return [$status,$msg];
  505. try {
  506. DB::beginTransaction();
  507. $model = new Reminder();
  508. $model->title = $data['title'] ?? "";
  509. $model->type = $data['type'] ?? '';
  510. $model->remind_start = $data['remind_start'] ?? '';
  511. $model->remind_interval = $data['remind_interval'] ?? 0;
  512. $model->last_remind_time = $data['last_remind_time'] ?? 0;
  513. $model->man_type = $data['man_type'] ?? '';
  514. $model->organization_name = $data['organization_name'] ?? '';
  515. $model->contact = $data['contact'] ?? '';
  516. $model->address = $data['address'] ?? '';
  517. $model->content = $data['content'] ?? '';
  518. $model->crt_id = $user['id'];
  519. $model->save();
  520. DB::commit();
  521. }catch (\Exception $exception){
  522. DB::rollBack();
  523. return [false,$exception->getMessage()];
  524. }
  525. return [true, ''];
  526. }
  527. public function toDoDel($data){
  528. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  529. // $bool = TodoList::where('del_time',0)
  530. // ->whereIn('id',$data['id'])
  531. // ->where('status','>',TodoList::status_zero)
  532. // ->exists();
  533. // if($bool) return [false, '待办状态已变更,删除失败'];
  534. try {
  535. DB::beginTransaction();
  536. $time = time();
  537. TodoList::where('del_time',0)
  538. ->whereIn('id',$data['id'])
  539. ->update(['del_time' => $time]);
  540. DB::commit();
  541. }catch (\Exception $exception){
  542. DB::rollBack();
  543. return [false,$exception->getMessage()];
  544. }
  545. return [true, ''];
  546. }
  547. public function toDoDetail($data, $user){
  548. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  549. $customer = TodoList::where('del_time',0)
  550. ->where('id',$data['id'])
  551. ->first();
  552. if(empty($customer)) return [false,'催单不存在或已被删除'];
  553. $customer = $customer->toArray();
  554. $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('emp_name');
  555. $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
  556. $customer['remind_start'] = $customer['remind_start'] ? date("Y-m-d H:i",$customer['remind_start']): '';
  557. $customer['type_title'] = TodoList::$type_name[$customer['df_type']] ?? "";
  558. $customer['status_title'] = TodoList::$status_name[$customer['status']] ?? "";
  559. return [true, $customer];
  560. }
  561. public function toDoCommon($data,$user, $field = []){
  562. if(empty($field)) $field = TodoList::$field;
  563. $model = TodoList::Clear($user,$data);
  564. $model = $model->where('del_time',0)
  565. ->select($field)
  566. ->orderby('id', 'desc');
  567. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  568. if(! empty($data['id'])) $model->whereIn('id', $data['id']);
  569. if(isset($data['status'])) $model->where('status', $data['status']);
  570. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  571. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  572. $model->where('crt_time','>=',$return[0]);
  573. $model->where('crt_time','<=',$return[1]);
  574. }
  575. if(! empty($data['remind_start'][0]) && ! empty($data['remind_start'][1])) {
  576. $return = $this->changeDateToTimeStampAboutRange($data['remind_start']);
  577. $model->where('remind_start','>=',$return[0]);
  578. $model->where('remind_start','<=',$return[1]);
  579. }
  580. return $model;
  581. }
  582. public function toDoList($data,$user){
  583. $model = $this->toDoCommon($data, $user);
  584. $list = $this->limit($model,'',$data);
  585. $list = $this->fillToDoData($list,$user,$data);
  586. return [true, $list];
  587. }
  588. public function toDoRule(&$data, $user, $is_add = true){
  589. if(empty($data['title'])) return [false, '待办标题不能为空'];
  590. if(empty($data['type'])) return [false, '间隔时长不能为空'];
  591. if(! isset(TodoList::$type_value[$data['type']])) return [false, '间隔时长错误'];
  592. $data['remind_interval'] = TodoList::$type_value[$data['type']];
  593. if(empty($data['remind_start'])) return [false, '提醒开始时间不能为空'];
  594. $data['remind_start'] = $this->changeDateToDateMin($data['remind_start']);
  595. $now = strtotime(date("Y-m-d H:i"));
  596. if ($data['remind_start'] - $now < 300) return [false, '提醒开始时间必须至少比当前时间晚5分钟'];
  597. // if(empty($data['man_type'])) return [false, '拜访人员类型不能为空'];
  598. // if(empty($data['organization_name'])) return [false, '组织名称不能为空'];
  599. // if(empty($data['contact'])) return [false, '联系人不能为空'];
  600. // if(empty($data['address'])) return [false, '地点不能为空'];
  601. if(empty($data['content'])) return [false, '内容不能为空'];
  602. if($is_add){
  603. }else{
  604. if(empty($data['id'])) return [false,'ID不能为空'];
  605. $order = TodoList::where('id',$data['id'])
  606. ->where('del_time',0)
  607. ->first();
  608. if(empty($order)) return [false, '待办事项不存在或已被删除'];
  609. $order = $order->toArray();
  610. if($order['status'] > TodoList::status_zero) return [false, '待办事项状态已变更,编辑失败'];
  611. if ($order->remind_start != $data['remind_start'] || $order->remind_interval != $data['remind_interval']) {
  612. $data['last_remind_time'] = 0;
  613. }
  614. }
  615. return [true, $data];
  616. }
  617. public function fillToDoData($data, $user, $search){
  618. if(empty($data['data'])) return $data;
  619. $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_column($data['data'],'id')));
  620. foreach ($data['data'] as $key => $value){
  621. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
  622. $data['data'][$key]['remind_start'] = $value['remind_start'] ? date('Y-m-d H:i',$value['remind_start']) : '';
  623. $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
  624. $data['data'][$key]['type_title'] = TodoList::$type_name[$value['df_type']] ?? "";
  625. $data['data'][$key]['status_title'] = TodoList::$status_name[$value['status']] ?? "";
  626. }
  627. return $data;
  628. }
  629. public function reminderDetail2($data, $user){
  630. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  631. $customer = Reminder::where('del_time',0)
  632. ->where('id',$data['id'])
  633. ->first();
  634. if(empty($customer)) return [false,'催单不存在或已被删除'];
  635. $customer = $customer->toArray();
  636. $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('emp_name');
  637. $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
  638. $customer['order_time'] = $customer['order_time'] ? date("Y-m-d",$customer['order_time']): '';
  639. $customer['lt_arrived_time'] = $customer['lt_arrived_time'] ? date("Y-m-d",$customer['lt_arrived_time']): '';
  640. $customer['tl_arrived_time'] = $customer['tl_arrived_time'] ? date("Y-m-d",$customer['tl_arrived_time']): '';
  641. $customer['df_type_title'] = Reminder::$df_type_name[$customer['df_type']] ?? "";
  642. $customer['rule_title'] = Reminder::$rule_name[$customer['rule']] ?? "";
  643. $customer['status_title'] = Reminder::$status_name[$customer['status']] ?? "";
  644. $details_status = $this->getDetail1($data['id'], $user);
  645. $customer['reminder_detail_status'] = $details_status['status'];
  646. $details_s = $this->getDetailOut($data, $user);
  647. $customer['cd_details'] = $details_s;
  648. return [true, $customer];
  649. }
  650. private function getDetailOut($data, $user = []){
  651. $user_id = $user['id'] ?? 0;
  652. $record = ReminderRecord::where('del_time',0)
  653. ->where('reminder_id',$data['id'])
  654. ->when(! empty($user_id), function ($query) use ($user_id) {
  655. return $query->where('crt_id', $user_id);
  656. })
  657. ->select('id','crt_id','tl_type','crt_time','tl_result','tl_ways')
  658. ->orderby('id','desc')
  659. ->get()->toArray();
  660. $record_detail = ReminderRecordDetails::where('del_time',0)
  661. ->whereIn('reminder_record_id',array_column($record,'id'))
  662. ->select('reminder_record_id','quantity','tl_time')
  663. ->get()->toArray();
  664. $record_detail_map = [];
  665. foreach ($record_detail as $value){
  666. $record_detail_map[$value['reminder_record_id']][] = [
  667. 'quantity' => $value['quantity'],
  668. 'tl_time' => date("Y-m-d", $value['tl_time']),
  669. ];
  670. }
  671. $emp_2 = (new CustomerSupplyService())->getEmployeeMap(array_unique(array_column($record,'crt_id')));
  672. foreach ($record as $key => $value){
  673. $record[$key]['crt_name'] = $emp_2[$value['crt_id']] ?? "";
  674. $record[$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  675. $record[$key]['tl_type_title'] = ReminderRecord::$tl_type_name[$value['tl_type']] ?? "";
  676. $record[$key]['tl_ways_title'] = ReminderRecord::$tl_way_name[$value['tl_ways']] ?? "";
  677. $record[$key]['tl_result_title'] = ReminderRecord::$tl_result_name[$value['tl_result']] ?? "";
  678. $record[$key]['details'] = $record_detail_map[$value['id']] ?? (object)[];
  679. }
  680. return $record ?? (object)[];
  681. }
  682. public function reminderSave($data, $user){
  683. list($status, $msg) = $this->reminderSaveRule($data, $user);
  684. if(! $status) return [false, $msg];
  685. list($reminder, $reminder_details) = $msg;
  686. try {
  687. DB::beginTransaction();
  688. $reminder_details->status = ReminderDetails::status_one;
  689. $reminder_details->save();
  690. $time = time();
  691. $model = new ReminderRecord();
  692. $model->reminder_id = $reminder->id;
  693. $model->tl_type = $data['tl_type'];
  694. $model->tl_result = $data['tl_result'];
  695. $model->tl_ways = $data['tl_ways'];
  696. $model->crt_id = $user['id'];
  697. $model->save();
  698. if(! empty($data['details'])){
  699. $insert = [];
  700. foreach ($data['details'] as $value){
  701. $insert[] = [
  702. 'reminder_record_id' => $model->id,
  703. 'quantity' => $value['quantity'],
  704. 'tl_time' => $value['tl_time'],
  705. 'crt_time' => $time,
  706. ];
  707. }
  708. if(! empty($insert)) ReminderRecordDetails::insert($insert);
  709. }
  710. $this->updateReminderStatus($reminder);
  711. DB::commit();
  712. }catch (\Exception $exception){
  713. DB::rollBack();
  714. return [false, $exception->getMessage()];
  715. }
  716. return [true, ''];
  717. }
  718. private function reminderSaveRule(&$data, $user){
  719. if(empty($data['id'])) return [false, '催单id不能为空'];
  720. $reminder = Reminder::where('del_time',0)
  721. ->where('id', $data['id'])
  722. ->first();
  723. if(empty($reminder)) return [false, '催单不存在或已被删除'];
  724. list($status,$msg) = $this->limitingSendRequestBackgExpire("reminderSave" . $reminder->id);
  725. if(! $status) return [false, $msg];
  726. if($reminder->status == Reminder::status_one) return [false, '催单已完成,提交失败'];
  727. if($reminder->status == Reminder::status_two) return [false, '催单已结束,提交失败'];
  728. if(empty($data['tl_type'])) return [false, '提拉类型不能为空'];
  729. if(! isset(ReminderRecord::$tl_type_name[$data['tl_type']])) return [false, '提拉类型错误'];
  730. if(empty($data['tl_result'])) return [false, '提拉结果不能为空'];
  731. if(isset(ReminderRecord::$tl_result_name[$data['tl_result']])) return [false, '提拉结果错误'];
  732. if($data['tl_result'] == ReminderRecord::tl_result_one){
  733. if(empty($data['tl_ways'])) return [false, '提拉方式不能为空'];
  734. if(isset(ReminderRecord::$tl_way_name[$data['tl_ways']])) return [false, '提拉方式错误'];
  735. if(empty($data['details'])) return [false, '结果明细不能为空'];
  736. foreach ($data['details'] as $key => $value){
  737. $res = $this->checkNumber($value['quantity'],2,'positive');
  738. if(! $res['valid']) return [false,'提拉应答数量:' . $res['error']];
  739. if(empty($value['tl_time'])) return [false, '提拉应答日期不能为空'];
  740. $data['details'][$key]['tl_time'] = $this->changeDateToDate($value['tl_time']);
  741. }
  742. }
  743. $order = ReminderDetails::where('del_time',0)
  744. ->where('reminder_id', $data['id'])
  745. ->where('customer_supply_id', $user['id'])
  746. ->first();
  747. if(! $order) return [false, '该人员不在本次催单供应商人员内容'];
  748. if($order->status) return [false, '催单信息已回复,请勿重复操作'];
  749. return [true, [$reminder, $order]];
  750. }
  751. public function updateReminderStatus($reminder)
  752. {
  753. if (empty($reminder)) return;
  754. $reminder_id = $reminder->id;
  755. // 查询主要人员
  756. $main_users = ReminderDetails::where('reminder_id', $reminder_id)
  757. ->where('is_main', ReminderDetails::is_main_one)
  758. ->pluck('customer_supply_id')
  759. ->toArray();
  760. // 查询主要人员的最新回复结果
  761. $records = ReminderRecord::where('reminder_id', $reminder_id)
  762. ->whereIn('crt_id', $main_users)
  763. ->orderBy('id', 'desc')
  764. ->get()
  765. ->groupBy('crt_id')
  766. ->map(function ($items) {
  767. return $items->first(); // 每人最新一次回复
  768. });
  769. // 如果主要人员都还没回复,不更新
  770. if ($records->isEmpty()) return;
  771. // 统计回复结果
  772. $agree_count = $records->where('tl_result', ReminderRecord::tl_result_one)->count();
  773. $reject_count = $records->where('tl_result', ReminderRecord::tl_result_two)->count();
  774. $total_main = count($main_users);
  775. // 当前规则判断
  776. $new_status = null;
  777. if ($reminder->rule == Reminder::rule_one) {
  778. // 与规则:全同意 -> 1;有一人不同意 -> 2
  779. if ($reject_count > 0) {
  780. $new_status = Reminder::status_two; // 结束
  781. } elseif ($agree_count == $total_main) {
  782. $new_status = Reminder::status_one; // 完成
  783. }
  784. } elseif ($reminder->rule == Reminder::rule_two) {
  785. // 或规则:任意同意 -> 1;全不同意 -> 2
  786. if ($agree_count > 0) {
  787. $new_status = Reminder::status_one; // 完成
  788. } elseif ($reject_count == $total_main) {
  789. $new_status = Reminder::status_two; // 结束
  790. }
  791. }
  792. // 更新状态
  793. if ($new_status !== null && $reminder->status != $new_status) {
  794. $reminder->status = $new_status;
  795. $reminder->save();
  796. }
  797. }
  798. }