SportsBagService.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353
  1. <?php
  2. namespace App\Service;
  3. use App\Model\BasicType;
  4. use App\Model\Construction;
  5. use App\Model\Employee;
  6. use App\Model\PurchaseOrder;
  7. use App\Model\SeeRange;
  8. use App\Model\SportsBag;
  9. use App\Model\SportsBagProductInfo;
  10. use Illuminate\Support\Facades\DB;
  11. class SportsBagService extends Service
  12. {
  13. public function edit($data,$user){
  14. list($status,$msg) = $this->orderRule($data,$user,false);
  15. if(!$status) return [$status,$msg];
  16. $params = $this->getDataFile($data);
  17. (new OperationLogService())->setOperationList($params,$user,2);
  18. try{
  19. DB::beginTransaction();
  20. $material_model = SportsBag::where('id',$data['id'])->first();
  21. $material_model->title = $data['title'];
  22. $material_model->purchase_attribute = $data['purchase_attribute'];
  23. $material_model->mark = $data['mark'] ?? "";
  24. $material_model->number = $data['number'];
  25. $material_model->start_time = $data['start_time'] ?? 0;
  26. $material_model->end_time = $data['end_time'] ?? 0;
  27. $material_model->total_amount = $data['total_amount'] ?? 0;
  28. $material_model->save();
  29. $time = time();
  30. SportsBagProductInfo::where('del_time',0)
  31. ->where('sports_bag_id',$data['id'])
  32. ->update(['del_time' => $time]);
  33. if(!empty($data['product'])){
  34. $map = (new ProductService())->getProductDetail(array_column($data['product'],'product_id'));
  35. $sub = [];
  36. foreach ($data['product'] as $value){
  37. $tmp = $map[$value['product_id']] ?? [];
  38. $sub[] = [
  39. 'sports_bag_id' => $material_model->id,
  40. 'product_id' => $value['product_id'],
  41. 'number' => $value['number'],
  42. 'mark' => $value['mark'] ?? '',
  43. 'cost' => $value['cost'] ?? 0,
  44. 'retail_price' => $tmp['retail_price'] ?? 0,
  45. 'crt_time' => $time,
  46. 'basic_type_id' => $value['basic_type_id'],
  47. 'price' => $value['price'],
  48. ];
  49. }
  50. SportsBagProductInfo::insert($sub);
  51. }
  52. DB::commit();
  53. }catch (\Throwable $e){
  54. DB::rollBack();
  55. return [false,$e->getMessage()];
  56. }
  57. if(! empty($data['check'])) {
  58. list($status,$msg) = (new CheckService())->checkAll([
  59. "id" => $material_model->id,
  60. "order_number" => $data['order_number'],
  61. "opt_case" => CheckService::twl,
  62. "menu_id" => $data['menu_id']
  63. ],$user);
  64. if(! $status) return [true, '保存成功,活动包确认失败,异常信息:' . $msg];
  65. }
  66. return [true,''];
  67. }
  68. public function add($data,$user){
  69. list($status,$msg) = $this->orderRule($data,$user);
  70. if(!$status) return [$status,$msg];
  71. try{
  72. DB::beginTransaction();
  73. $material_model = new SportsBag();
  74. $material_model->order_number = $data['order_number'];
  75. $material_model->purchase_attribute = $data['purchase_attribute'];
  76. $material_model->title = $data['title'];
  77. $material_model->mark = $data['mark'] ?? "";
  78. $material_model->number = $data['number'];
  79. $material_model->start_time = $data['start_time'] ?? 0;
  80. $material_model->end_time = $data['end_time'] ?? 0;
  81. $material_model->crt_id = $user['id'];
  82. $material_model->depart_id = $data['depart_id'] ?? 0;
  83. $material_model->top_depart_id = $data['top_depart_id'] ?? 0;
  84. $material_model->total_amount = $data['total_amount'] ?? 0;
  85. $material_model->save();
  86. $time = time();
  87. if(!empty($data['product'])){
  88. $map = (new ProductService())->getProductDetail(array_column($data['product'],'product_id'));
  89. $sub = [];
  90. foreach ($data['product'] as $value){
  91. $tmp = $map[$value['product_id']] ?? [];
  92. $sub[] = [
  93. 'sports_bag_id' => $material_model->id,
  94. 'product_id' => $value['product_id'],
  95. 'number' => $value['number'],
  96. 'mark' => $value['mark'] ?? '',
  97. 'cost' => $value['cost'] ?? 0,
  98. 'retail_price' => $tmp['retail_price'] ?? 0,
  99. 'crt_time' => $time,
  100. 'basic_type_id' => $value['basic_type_id'],
  101. 'price' => $value['price'],
  102. ];
  103. }
  104. SportsBagProductInfo::insert($sub);
  105. }
  106. DB::commit();
  107. }catch (\Throwable $e){
  108. DB::rollBack();
  109. if (str_contains($e->getMessage(), '1062') || str_contains($e->getMessage(), 'Duplicate entry')) {
  110. return [false, '网络环境波动,请重新操作'];
  111. }
  112. return [false,$e->getMessage()];
  113. }
  114. (new OperationLogService())->setOperationList($data,$user);
  115. if(! empty($data['check'])) {
  116. list($status,$msg) = (new CheckService())->checkAll([
  117. "id" => $material_model->id,
  118. "order_number" => $data['order_number'],
  119. "opt_case" => CheckService::twl,
  120. "menu_id" => $data['menu_id']
  121. ],$user);
  122. if(! $status) return [true, '保存成功,活动包确认失败,异常信息:' . $msg];
  123. }
  124. return [true,''];
  125. }
  126. public function detail($data){
  127. if($this->isEmpty($data,'id')) return [false,'请选择数据'];
  128. $order = SportsBag::where('id',$data['id'])
  129. ->where('del_time',0)
  130. ->first();
  131. if(empty($order)) return [false, '活动包不存在或已被删除'];
  132. $order = $order->toArray();
  133. $basic_type = BasicType::whereRaw("FIND_IN_SET(?, id)", [$order['purchase_attribute']])->pluck('title','id')->toArray();
  134. $str = "";
  135. if(! empty($basic_type)){
  136. $purchase_attribute = explode(',',$order['purchase_attribute']);
  137. foreach ($purchase_attribute as $value){
  138. $str .= $basic_type[$value] . ',';
  139. }
  140. }
  141. $order['purchase_attribute_title'] = $str;
  142. $start_time = $order['start_time'] ? date("Y-m-d H:i",$order['start_time']) : '';
  143. $end_time = $order['end_time'] ? date("Y-m-d H:i",$order['end_time']) : '';
  144. $order['sports_bag_time'] = $start_time . '——' . $end_time;
  145. $order['product'] = $order['depart'] = $order['employee'] = [];
  146. $info = SportsBagProductInfo::where('del_time',0)
  147. ->where('sports_bag_id',$data['id'])
  148. ->get()->toArray();
  149. $map = (new ProductService())->getProductDetail(array_column($info,'product_id'));
  150. foreach ($info as $value){
  151. $tmp = $map[$value['product_id']] ?? [];
  152. $value['title'] = $tmp['title'] ?? "";
  153. $value['code'] = $tmp['code'] ?? "";
  154. $value['size'] = $tmp['size'] ?? "";
  155. $value['unit'] = $tmp['unit'] ?? "";
  156. $value['bar_code'] = $tmp['bar_code'] ?? "";
  157. $order['product'][] = $value;
  158. }
  159. $order['crt_name'] = Employee::where('id',$order['crt_id'])->value('emp_name');
  160. $order['crt_time'] = $order['crt_time'] ? date("Y-m-d H:i:s",$order['crt_time']): '';
  161. $state_array = $this->getStateMake([$order]);
  162. $order['state_title'] = $this->makeState($order,$state_array);
  163. //可见范围
  164. $return = (new RangeService())->RangeDetail($order['id'],SeeRange::type_eight);
  165. $order['depart'] = $return[0] ?? [];
  166. $order['employee'] = $return[1] ?? [];
  167. return [true, $order];
  168. }
  169. public function del($data,$user){
  170. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  171. $order = SportsBag::where('del_time',0)->where('id',$data['id'])->first();
  172. if(empty($order)) return [false,'活动包不存在或已被删除'];
  173. if($order['state'] > SportsBag::STATE_ZERO) return [false, '请确认活动包状态,删除失败!'];
  174. try{
  175. DB::beginTransaction();
  176. SportsBag::where('id',$data['id'])->update([
  177. 'del_time'=>time()
  178. ]);
  179. SportsBagProductInfo::where('sports_bag_id',$data['id'])->update([
  180. 'del_time'=>time()
  181. ]);
  182. (new RangeService())->RangeDelete($data['id'],SeeRange::type_eight);
  183. DB::commit();
  184. }catch (\Throwable $e){
  185. DB::rollBack();
  186. return [false,$e->getMessage()];
  187. }
  188. return [true,''];
  189. }
  190. public function getList($data,$user){
  191. $model = SportsBag::Clear($user,$data);
  192. $model = $model->where('del_time',0)
  193. ->select('id','title','number','start_time','end_time','crt_time','crt_id','mark','total_amount','state','order_number','purchase_attribute')
  194. ->orderby('id', 'desc');
  195. if(! empty($data['purchase_attribute'])) $model->whereRaw("FIND_IN_SET(?, purchase_attribute)", [$data['purchase_attribute']]);
  196. if(isset($data['state'])) $model->where('state', $data['state']);
  197. if(isset($data['valid'])) {
  198. //获取有效时间内的活动包
  199. $time = time();
  200. $model->where('start_time','<=',$time);
  201. $model->where('end_time','>=',$time);
  202. }
  203. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  204. if(! empty($data['mark'])) $model->where('mark', 'LIKE', '%'.$data['mark'].'%');
  205. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  206. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  207. $model->where('crt_time','>=',$return[0]);
  208. $model->where('crt_time','<=',$return[1]);
  209. }
  210. if(! empty($data['sports_bag_time'][0]) && ! empty($data['sports_bag_time'][1])) {
  211. $start_time = $this->changeDateToDateMin($data['sports_bag_time'][0]);
  212. $end_time = $this->changeDateToDateMin($data['sports_bag_time'][1]);
  213. $model->where('start_time','>=',$start_time);
  214. $model->where('end_time','<=',$end_time);
  215. }
  216. $list = $this->limit($model,'',$data);
  217. $list = $this->fillListData($list,$data);
  218. return [true, $list];
  219. }
  220. public function fillListData($data,$ergs){
  221. if(empty($data['data'])) return $data;
  222. $emp_id = array_unique(array_merge_recursive(array_column($data['data'],'crt_id')));
  223. $emp_map = Employee::whereIn('id',$emp_id)
  224. ->pluck('emp_name','id')
  225. ->toArray();
  226. $product = [];
  227. if(! empty($ergs['product'])){
  228. $sales_p_info = SportsBagProductInfo::where('del_time',0)
  229. ->whereIn('sports_bag_id',array_column($data['data'],'id'))
  230. ->get()->toArray();
  231. $map = (new ProductService())->getProductDetail(array_column($sales_p_info,'product_id'));
  232. foreach ($sales_p_info as $value){
  233. $tmp = $map[$value['product_id']] ?? [];
  234. $value['title'] = $tmp['title'] ?? "";
  235. $value['code'] = $tmp['code'] ?? "";
  236. $value['size'] = $tmp['size'] ?? "";
  237. $value['unit'] = $tmp['unit'] ?? "";
  238. $value['bar_code'] = $tmp['bar_code'] ?? "";
  239. $product[$value['sports_bag_id']][] = $value;
  240. }
  241. }
  242. //订单状态数据组织
  243. $state_array = $this->getStateMake($data['data']);
  244. foreach ($data['data'] as $key => $value){
  245. $start_time = $value['start_time'] ? date("Y-m-d H:i",$value['start_time']) : '';
  246. $end_time = $value['end_time'] ? date("Y-m-d H:i",$value['end_time']) : '';
  247. $data['data'][$key]['sports_bag_time'] = $start_time . '——' . $end_time;
  248. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']) : '';
  249. $data['data'][$key]['crt_name'] = $emp_map[$value['crt_id']] ?? '';
  250. $data['data'][$key]['state_title'] = $this->makeState($data['data'][$key], $state_array);
  251. $data['data'][$key]['product'] = $product[$value['id']] ?? [];
  252. }
  253. return $data;
  254. }
  255. public function makeState($value, $state_array){
  256. if(! empty($state_array[$value['order_number']])){
  257. $return = $state_array[$value['order_number']];
  258. if($value['state'] == SportsBag::State_minus_one){
  259. $state = "驳回:" . $return;
  260. }else{
  261. $state = "待" . $return . "审核";
  262. }
  263. }elseif($value['state'] == SportsBag::STATE_ZERO){
  264. $state = "待" . $value['crt_name'] . "提交";
  265. }else{
  266. $state = SportsBag::$name[$value['state']] ?? '';
  267. }
  268. return $state;
  269. }
  270. public function getStateMake($data){
  271. if(empty($data)) return [];
  272. $order_no = [];
  273. foreach ($data as $value){
  274. if(! in_array($value['state'], [SportsBag::State_minus_one,SportsBag::STATE_ONE])) continue;
  275. $order_no[] = $value['order_number'];
  276. }
  277. return (new OaService())->getOaTeamDetailList($order_no);
  278. }
  279. public function orderRule(&$data, $user, $is_check = true){
  280. if(empty($data['title'])) return [false,'请填写活动名称'];
  281. if(empty($data['sports_bag_time'][0]) || empty($data['sports_bag_time'][1])) return [false,'请填写活动时间范围'];
  282. $data['start_time'] = $this->changeDateToDateMin($data['sports_bag_time'][0]);
  283. $data['end_time'] = $this->changeDateToDateMin($data['sports_bag_time'][1]);
  284. if(empty($data['number'])) return [false,'必选产品种数不能为空'];
  285. $res = $this->checkNumber($data['number']);
  286. if(! $res) return [false,'请输入正确的必选产品种数'];
  287. if(empty($data['total_amount'])) return [false,'活动包总金额不能为空'];
  288. $res = $this->checkNumber($data['total_amount']);
  289. if(! $res) return [false,'活动包总金额请输入不超过两位小数并且大于0的数值'];
  290. //所属部门 以及 顶级部门
  291. if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
  292. $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
  293. if($is_check){
  294. $order_number = (new OrderNoService())->createOrderNumber(SportsBag::prefix);
  295. if(empty($order_number)) return [false,'活动包唯一单号生成失败!'];
  296. $data['order_number'] = $order_number;
  297. }else{
  298. if($this->isEmpty($data,'id')) return [false,'活动包ID不能为空!'];
  299. $purchase = SportsBag::where('del_time',0)->where('id',$data['id'])->first();
  300. if(empty($purchase)) return [false, '活动包不存在或已被删除'];
  301. if($purchase->state > SportsBag::STATE_ZERO) return [false,'请确认活动包状态,修改失败'];
  302. }
  303. return [true, ''];
  304. }
  305. }