PurchaseOrderService.php 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778
  1. <?php
  2. namespace App\Service;
  3. use App\Model\BasicType;
  4. use App\Model\BookingList;
  5. use App\Model\Depart;
  6. use App\Model\Employee;
  7. use App\Model\PaymentReceipt;
  8. use App\Model\PaymentReceiptInfo;
  9. use App\Model\PurchaseOrder;
  10. use App\Model\PurchaseOrderFile;
  11. use App\Model\PurchaseOrderInfo;
  12. use App\Model\ReturnExchangeOrder;
  13. use App\Model\RoleMenuButton;
  14. use App\Model\SalesOrder;
  15. use App\Model\SeeRange;
  16. use App\Model\SportsBag;
  17. use App\Model\SportsBagProductInfo;
  18. use App\Model\Storehouse;
  19. use App\Model\Supplier;
  20. use Carbon\Carbon;
  21. use Illuminate\Http\Request;
  22. use Illuminate\Support\Facades\DB;
  23. /**
  24. * 采购单
  25. */
  26. class PurchaseOrderService extends Service
  27. {
  28. /**
  29. * 采购单编辑
  30. * @param $data
  31. * @param $user
  32. * @return array
  33. */
  34. public function edit($data,$user){
  35. list($status,$msg) = $this->orderRule($data,$user, false);
  36. if(!$status) return [$status,$msg];
  37. $params = $this->getDataFile($data);
  38. (new OperationLogService())->setOperationList($params,$user,2);
  39. try{
  40. DB::beginTransaction();
  41. $material_model = PurchaseOrder::where('order_number',$data['order_number'])->first();
  42. $material_model->purchase_type = $data['purchase_type'] ?? 0;
  43. $material_model->order_number = $data['order_number'];
  44. // $material_model->depart_id = $data['depart_id'] ?? 0;
  45. // $material_model->top_depart_id = $data['top_depart_id'] ?? 0;
  46. $material_model->total = $data['total'] ?? 0;
  47. $material_model->other_fee = $data['other_fee'] ?? 0;
  48. $material_model->discount_fee = $data['discount_fee'] ?? 0;
  49. $material_model->purchase_total = $data['purchase_total'] ?? 0;
  50. $material_model->supplier = $data['supplier'] ?? 0;
  51. $material_model->purchase_id = $data['purchase_id'] ?? 0;
  52. $material_model->order_type = $data['order_type'];
  53. $material_model->sales_order_id = $data['sales_order_id'] ?? 0;
  54. $material_model->mark = $data['mark'] ?? '';
  55. $material_model->storehouse_id = $data['storehouse_id'];
  56. $material_model->save();
  57. $time = time();
  58. PurchaseOrderInfo::where('order_number',$data['order_number'])
  59. ->where('del_time',0)
  60. ->update(['del_time' => time()]);
  61. if(!empty($data['product'])){
  62. $sub = [];
  63. foreach ($data['product'] as $value){
  64. $sports_bag_product_info_id = 0;
  65. if(! empty($value['sports_bag_id'])) $sports_bag_product_info_id = empty($value['id']) ? 0 : $value['id'];
  66. $sub[] = [
  67. 'purchase_order_id' => $material_model->id,
  68. 'order_number' => $data['order_number'],
  69. 'storehouse_id' => $data['storehouse_id'] ?? 0,
  70. 'product_id' => $value['product_id'],
  71. 'number' => $value['number'],
  72. 'basic_type_id' => $value['basic_type_id'],
  73. 'price' => $value['price'],
  74. 'mark' => $value['mark'] ?? '',
  75. 'final_amount' => $value['final_amount'] ?? 0,
  76. 'sports_bag_id' => $value['sports_bag_id'] ?? 0,
  77. 'sports_bag_product_info_id' => $sports_bag_product_info_id,
  78. 'rate' => $value['rate'] ?? 0,
  79. ];
  80. }
  81. PurchaseOrderInfo::insert($sub);
  82. }
  83. $old = PurchaseOrderFile::where('del_time',0)
  84. ->where('purchase_order_id',$data['id'])
  85. ->whereIn('type',[PurchaseOrderFile::type_one])
  86. ->select('file')
  87. ->get()->toArray();
  88. $old = array_column($old,'file');
  89. PurchaseOrderFile::where('order_number',$data['order_number'])
  90. ->where('del_time',0)
  91. ->update(['del_time' => time()]);
  92. $new = [];
  93. if(! empty($data['file'])){
  94. $insert = [];
  95. foreach ($data['file'] as $value){
  96. $insert[] = [
  97. 'purchase_order_id' => $material_model->id,
  98. 'order_number' => $data['order_number'],
  99. 'file' => $value['url'],
  100. 'type' => PurchaseOrderFile::type_one,
  101. 'name' => $value['name'],
  102. 'crt_time' => $time,
  103. ];
  104. if(in_array($value['url'], $old)) {
  105. foreach ($old as $o_k => $o_v){
  106. if($o_v == $value['url']) unset($old[$o_k]);
  107. }
  108. }else{
  109. $new[] = $value['url'];
  110. }
  111. }
  112. PurchaseOrderFile::insert($insert);
  113. }
  114. DB::commit();
  115. }catch (\Throwable $e){
  116. DB::rollBack();
  117. return [false,$e->getMessage()];
  118. }
  119. if(! empty($data['check'])) {
  120. list($status,$msg) = (new CheckService())->checkAll([
  121. "id" => $material_model->id,
  122. "order_number" => $data['order_number'],
  123. "opt_case" => CheckService::seven,
  124. "menu_id" => $data['menu_id']
  125. ],$user);
  126. // if(! $status) return [true, '保存成功,采购单确认失败,异常信息:' . $msg];
  127. }
  128. return [true, ['file' => ['new' => $new, 'old' => $old]]];
  129. }
  130. /**
  131. * 采购单新增
  132. * @param $data
  133. * @param $user
  134. * @return array
  135. */
  136. public function add($data,$user){
  137. list($status,$msg) = $this->orderRule($data, $user);
  138. if(!$status) return [$status,$msg];
  139. try{
  140. DB::beginTransaction();
  141. $material_model = new PurchaseOrder();
  142. $material_model->order_number = $data['order_number'];
  143. $material_model->purchase_type = $data['purchase_type'] ?? 0;
  144. $material_model->depart_id = $data['depart_id'] ?? 0;
  145. $material_model->top_depart_id = $data['top_depart_id'] ?? 0;
  146. $material_model->total = $data['total'] ?? 0;
  147. $material_model->other_fee = $data['other_fee'] ?? 0;
  148. $material_model->discount_fee = $data['discount_fee'] ?? 0;
  149. $material_model->purchase_total = $data['purchase_total'] ?? 0;
  150. $material_model->supplier = $data['supplier'] ?? 0;
  151. $material_model->purchase_id = $data['purchase_id'] ?? 0;
  152. $material_model->order_type = $data['order_type'];
  153. $material_model->sales_order_id = $data['sales_order_id'] ?? 0;
  154. $material_model->mark = $data['mark'] ?? '';
  155. $material_model->crt_id = $user['id'];
  156. $material_model->storehouse_id = $data['storehouse_id'];
  157. $material_model->save();
  158. $time = time();
  159. if(!empty($data['product'])){
  160. $sub = [];
  161. foreach ($data['product'] as $value){
  162. $sports_bag_product_info_id = 0;
  163. if(! empty($value['sports_bag_id'])) $sports_bag_product_info_id = empty($value['id']) ? 0 : $value['id'];
  164. $sub[] = [
  165. 'purchase_order_id' => $material_model->id,
  166. 'order_number' => $data['order_number'],
  167. 'storehouse_id' => $data['storehouse_id'] ?? 0,
  168. 'product_id' => $value['product_id'],
  169. 'number' => $value['number'],
  170. 'basic_type_id' => $value['basic_type_id'],
  171. 'price' => $value['price'],
  172. 'mark' => $value['mark'] ?? '',
  173. 'final_amount' => $value['final_amount'] ?? 0,
  174. 'sports_bag_id' => $value['sports_bag_id'] ?? 0,
  175. 'sports_bag_product_info_id' => $sports_bag_product_info_id,
  176. 'rate' => $value['rate'] ?? 0,
  177. ];
  178. }
  179. PurchaseOrderInfo::insert($sub);
  180. }
  181. $new = [];
  182. if(! empty($data['file'])){
  183. $insert = [];
  184. foreach ($data['file'] as $value){
  185. $insert[] = [
  186. 'purchase_order_id' => $material_model->id,
  187. 'order_number' => $data['order_number'],
  188. 'file' => $value['url'],
  189. 'type' => PurchaseOrderFile::type_one,
  190. 'name' => $value['name'],
  191. 'crt_time' => $time,
  192. ];
  193. if(! empty($value['url'])) $new[] = $value['url'];
  194. }
  195. PurchaseOrderFile::insert($insert);
  196. }
  197. DB::commit();
  198. }catch (\Throwable $exception){
  199. DB::rollBack();
  200. if (str_contains($exception->getMessage(), '1062') || str_contains($exception->getMessage(), 'Duplicate entry')) {
  201. return [false, '网络波动,请重新操作!'];
  202. }
  203. return [false,$exception->getMessage()];
  204. }
  205. (new OperationLogService())->setOperationList($data,$user);
  206. if(! empty($data['check'])) {
  207. list($status,$msg) = (new CheckService())->checkAll([
  208. "id" => $material_model->id,
  209. "order_number" => $data['order_number'],
  210. "opt_case" => CheckService::seven,
  211. "menu_id" => $data['menu_id']
  212. ],$user);
  213. // if(! $status) return [true, '保存成功,采购单确认失败,异常信息:' . $msg];
  214. }
  215. return [true, ['file' => ['new' => $new]]];
  216. }
  217. /**
  218. * 采购单详情
  219. * @param $data
  220. * @return array
  221. */
  222. public function detail($data,$user){
  223. if($this->isEmpty($data,'order_number')) return [false,'请选择数据'];
  224. $order = PurchaseOrder::where('order_number',$data['order_number'])
  225. ->where('del_time',0)
  226. ->select('id','order_number','depart_id','mark','state','crt_id','order_type','sales_order_id','supplier','purchase_id','total','other_fee','discount_fee','purchase_total','crt_time','storehouse_id','top_depart_id','purchase_type')
  227. ->first();
  228. if(empty($order)) return [false, '采购订单不存在或已被删除'];
  229. $order = $order->toArray();
  230. $order['activity_product'] = $order['file'] = [];
  231. $order['purchase_type_title'] = BasicType::where('id',$order['purchase_type'])->value('title') ?? '';
  232. $order['storehouse_title'] = Storehouse::where('id',$order['storehouse_id'])->value('title');
  233. $supplier = Supplier::where('id',$order['supplier'])->first();
  234. $order['supplier_title'] = $supplier->title ?? '';
  235. $order['order_type_title'] = PurchaseOrder::$order_type[$order['order_type']] ?? '';
  236. $sales = SalesOrder::where('id',$order['sales_order_id'])->value('order_number');
  237. $order['sales_order_number'] = $sales;
  238. $emp_map = Employee::whereIn('id',array_unique(array_merge_recursive([$order['purchase_id']],[$order['crt_id']])))
  239. ->pluck('emp_name','id')
  240. ->toArray();
  241. $order['purchase_title'] = $emp_map[$order['purchase_id']] ?? '';
  242. $p_info = PurchaseOrderInfo::where('del_time',0)
  243. ->where('order_number',$data['order_number'])
  244. ->get()->toArray();
  245. $sports_bag_id = array_unique(array_column($p_info,'sports_bag_id'));
  246. $bag = SportsBag::whereIn('id',$sports_bag_id)->get()->toArray();
  247. $bag_pro = SportsBagProductInfo::where('del_time',0)->whereIn('sports_bag_id',$sports_bag_id)
  248. ->get()->toArray();
  249. $bag_map = array_column($bag,null,'id');
  250. $bag_pro_map = [];
  251. foreach ($bag_pro as $value){
  252. $bag_pro_map[$value['sports_bag_id']][] = $value;
  253. }
  254. $basic_price = BasicType::whereIn('id',array_unique(array_column($p_info,'basic_type_id')))->pluck('title','id')->toArray();
  255. $map = (new ProductService())->getProductDetail(array_column($p_info,'product_id'));
  256. $sports_bag_arr = [];
  257. $sports_bag_pro = [];
  258. foreach ($p_info as $value){
  259. $tmp = $map[$value['product_id']] ?? [];
  260. if(! empty($value['sports_bag_id'])){
  261. $bag_tmp = $bag_map[$value['sports_bag_id']] ?? [];
  262. if(! isset($sports_bag_arr[$value['sports_bag_id']])) $sports_bag_arr[$value['sports_bag_id']] = $bag_tmp;
  263. $bag_pro_tmp = $bag_pro_map[$value['sports_bag_id']] ?? [];
  264. foreach ($bag_pro_tmp as $k => $v){
  265. if($v['product_id'] != $value['product_id']) continue;
  266. $is_choose = false;
  267. $final_amount = 0;
  268. $number = $v['number'];
  269. $mark = "";
  270. if($v['id'] == $value['sports_bag_product_info_id']){
  271. $is_choose = true;
  272. $final_amount = $value['final_amount'];
  273. $number = $value['number'];
  274. $mark = $value['mark'];
  275. }
  276. $bag_pro_tmp[$k]['is_choose'] = $is_choose;
  277. $bag_pro_tmp[$k]['final_amount'] = $final_amount;
  278. $bag_pro_tmp[$k]['number'] = $number;
  279. $bag_pro_tmp[$k]['title'] = $tmp['title'] ?? "";
  280. $bag_pro_tmp[$k]['code'] = $tmp['code'] ?? "";
  281. $bag_pro_tmp[$k]['size'] = $tmp['size'] ?? "";
  282. $bag_pro_tmp[$k]['unit'] = $tmp['unit'] ?? "";
  283. $bag_pro_tmp[$k]['bar_code'] = $tmp['bar_code'] ?? "";
  284. $bag_pro_tmp[$k]['mark'] = $mark ?? "";
  285. $sports_bag_pro[$value['sports_bag_id']][] = $bag_pro_tmp[$k];
  286. }
  287. }else{
  288. $value['title'] = $tmp['title'] ?? "";
  289. $value['code'] = $tmp['code'] ?? "";
  290. $value['size'] = $tmp['size'] ?? "";
  291. $value['unit'] = $tmp['unit'] ?? "";
  292. $value['bar_code'] = $tmp['bar_code'] ?? "";
  293. $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
  294. $order['product'][] = $value;
  295. }
  296. }
  297. foreach ($sports_bag_arr as $key => $value){
  298. $value['product'] = $sports_bag_pro[$key] ?? [];
  299. $order['activity_product'][] = $value;
  300. }
  301. $file = PurchaseOrderFile::where('del_time',0)
  302. ->where('order_number',$data['order_number'])
  303. ->get()->toArray();
  304. $fileUploadService = new FileUploadService();
  305. foreach ($file as $value){
  306. if($value['type'] == PurchaseOrderFile::type_one){
  307. $tmp = [
  308. 'url' => $value['file'],
  309. 'name' => $value['name'],
  310. 'show_url' => $fileUploadService->getFileShow($value['file']),
  311. ];
  312. $order['file'][] = $tmp;
  313. }
  314. }
  315. $order['crt_name'] = $emp_map[$order['crt_id']] ?? '';
  316. $order['crt_time'] = $order['crt_time'] ? date("Y-m-d H:i:s",$order['crt_time']): '';
  317. $state_array = $this->getStateMake([$order]);
  318. $order['state_title'] = $this->makeState($order,$state_array);
  319. //可见范围
  320. $return = (new RangeService())->RangeDetail($order['id'],SeeRange::type_five);
  321. $order['depart'] = $return[0] ?? [];
  322. $order['employee'] = $return[1] ?? [];
  323. //对应的分社订货合同
  324. $order['sales_order_number2'] = SalesOrder::where('del_time',0)->where('contact_order_no',$data['order_number'])->value('order_number') ?? "";
  325. //退换货信息
  326. $order['return_exchange'] = (new ReturnExchangeOrderService())->getDifferentAmount($order['id'],ReturnExchangeOrder::Order_type2);
  327. $order['return_exchange_amount'] = 0;
  328. foreach ($order['return_exchange'] as $value){
  329. if($value['state'] == ReturnExchangeOrder::State_two) $order['return_exchange_amount'] += $value['difference_amount'];
  330. }
  331. //回款单信息 审核过的
  332. $order['payment_receipt_list'] = (new PaymentReceiptService())->getPaymentReceiptDataList($order,PaymentReceipt::data_type_two);
  333. //坏账金额 = 已审核退货退款金额 - 红冲金额
  334. $order['payment_receipt_list']['bad_amount'] = bcsub($order['return_exchange_amount'], $order['payment_receipt_list']['red_amount'],2);
  335. //未回款金额 = 总金额 - 已回款金额 - 坏账金额 - 红冲
  336. $order['payment_receipt_list']['not_receipt_amount'] = bcsub(bcsub(bcsub($order['purchase_total'], $order['payment_receipt_list']['receipt_amount'],2), $order['payment_receipt_list']['bad_amount'], 2),$order['payment_receipt_list']['red_amount'],2);
  337. //回款单信息 审核过的
  338. $order['not_payment_receipt_amount'] = bcsub($order['purchase_total'],$order['payment_receipt_list']['not_confirm_receipt_amount'],2);
  339. return [true, $order];
  340. }
  341. /**
  342. * 采购单删除
  343. * @param $data
  344. * @return array
  345. */
  346. public function del($data){
  347. if($this->isEmpty($data,'order_number')) return [false,'请选择数据!'];
  348. $order = PurchaseOrder::where('del_time',0)->where('order_number',$data['order_number'])->first();
  349. if(empty($order)) return [false,'采购单不存在或已被删除'];
  350. $order = $order->toArray();
  351. if($order['state'] > PurchaseOrder::STATE_ZERO) return [false,'请确认采购订单状态,删除失败!'];
  352. $bool = PaymentReceiptInfo::where('del_time',0)
  353. ->where('type',PaymentReceiptInfo::type_three)
  354. ->where('data_order_no', $order['order_number'])
  355. ->exists();
  356. if($bool) return [false, '采购已存在收付款单记录,请先删除收付款单据!'];
  357. try{
  358. DB::beginTransaction();
  359. PurchaseOrder::where('order_number',$data['order_number'])->where('del_time',0)->update([
  360. 'del_time'=>time()
  361. ]);
  362. PurchaseOrderInfo::where('order_number',$data['order_number'])->where('del_time',0)->update([
  363. 'del_time'=>time()
  364. ]);
  365. $old = PurchaseOrderFile::where('del_time',0)
  366. ->where('purchase_order_id',$order['id'])
  367. ->whereIn('type',[PurchaseOrderFile::type_one])
  368. ->select('file')
  369. ->get()->toArray();
  370. $old = array_column($old,'file');
  371. PurchaseOrderFile::where('order_number',$data['order_number'])
  372. ->where('del_time',0)
  373. ->update(['del_time' => time()]);
  374. (new RangeService())->RangeDelete($order['id'],SeeRange::type_five);
  375. DB::commit();
  376. }catch (\Throwable $e){
  377. DB::rollBack();
  378. return [false,$e->getMessage()];
  379. }
  380. return [true, ['file' => ['old' => $old]]];
  381. }
  382. public function purchaseCommon($data,$user){
  383. $model = PurchaseOrder::Clear($user,$data);
  384. $model = $model->where('del_time',0)
  385. ->select('order_number','id','depart_id','top_depart_id','mark','crt_time','state','crt_id','order_type','sales_order_id','supplier','purchase_id','purchase_total','discount_fee','other_fee','total','storehouse_id','invoice_state')
  386. ->orderby('id', 'desc');
  387. if(! empty($data['purchase_id'])) $model->where('id', $data['purchase_id']);
  388. if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
  389. if(! empty($data['depart_id'])) $model->where('depart_id', $data['depart_id']);
  390. if(! empty($data['company_id'])) $model->where('company_id', $data['company_id']);
  391. if(isset($data['state'])) $model->where('state',$data['state']);
  392. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  393. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  394. $model->whereBetween('crt_time',[$return[0],$return[1]]);
  395. }
  396. if(! empty($data['time_type'])) {
  397. if($data['time_type'] == 1) {
  398. $start = strtotime('today');
  399. $end = strtotime('tomorrow') - 1;
  400. }elseif ($data['time_type'] == 2){
  401. $start = strtotime('this week',strtotime('today'));
  402. $end = strtotime('this week +6 days 23:59:59', strtotime('today'));
  403. }
  404. if(! empty($start) && ! empty($end)) {
  405. $model->where('crt_time','>=',$start);
  406. $model->where('crt_time','<=',$end);
  407. }
  408. }
  409. if(! empty($data['order_type'])) {
  410. if($data['order_type'] == PurchaseOrder::Order_type_five){
  411. $model->whereIn('order_type',[PurchaseOrder::Order_type_two,PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four]);
  412. }else{
  413. $model->where('order_type',$data['order_type']);
  414. }
  415. }
  416. if(! empty($data['sale_order'])){
  417. $model2 = SalesOrder::Clear($user,$data);
  418. $sale = $model2->where('del_time',0)
  419. ->where('order_number', 'LIKE', '%'.$data['sale_order'].'%')
  420. ->select('id')
  421. ->get()->toArray();
  422. $model->whereIn('sales_order_id',array_unique(array_column($sale,'id')));
  423. }
  424. if(! empty($data['supplier_man'])){
  425. $emp = Supplier::where('del_time',0)
  426. ->where('title', 'LIKE', '%'.$data['supplier_man'].'%')
  427. ->select('id')
  428. ->get()->toArray();
  429. $model->whereIn('supplier',array_unique(array_column($emp,'id')));
  430. }
  431. if(! empty($data['purchase_man'])){
  432. $emp = Employee::where('del_time',0)
  433. ->where('emp_name', 'LIKE', '%'.$data['purchase_man'].'%')
  434. ->select('id')
  435. ->get()->toArray();
  436. $model->whereIn('purchase_id',array_unique(array_column($emp,'id')));
  437. }
  438. if(! empty($data['get_for_purchase'])){
  439. $model->whereIn('order_type',[PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four])
  440. ->where('state',">=",PurchaseOrder::STATE_TWO);
  441. }
  442. if(! empty($data['wx_crt_time'][0]) && ! empty($data['wx_crt_time'][1])) {
  443. $model->where('crt_time','>=',$data['wx_crt_time'][0]);
  444. $model->where('crt_time','<=',$data['wx_crt_time'][1]);
  445. }
  446. return $model;
  447. }
  448. /**
  449. * 获取采购单列表
  450. * @param $data
  451. * @param $user
  452. * @return array
  453. */
  454. public function getList($data,$user){
  455. $model = $this->purchaseCommon($data, $user);
  456. $list = $this->limit($model,'',$data);
  457. $list = $this->fillListData($list,$data,$user);
  458. $count = $this->countData("crt_time", $data, $user);
  459. $list['today'] = $count[0] ?? 0;
  460. $list['yesterday'] = $count[1] ?? 0;
  461. return [true, $list];
  462. }
  463. /**
  464. * 拼接数据
  465. * @param $data
  466. * @return array
  467. */
  468. public function fillListData($data,$ergs,$user){
  469. if(empty($data['data'])) return $data;
  470. $depart_id = array_unique(array_column($data['data'],'depart_id'));
  471. $depart_map = Depart::whereIn('id',$depart_id)
  472. ->pluck('title','id')
  473. ->toArray();
  474. $emp_id = array_unique(array_merge_recursive(array_column($data['data'],'crt_id'),array_column($data['data'],'purchase_id')));
  475. $emp_map = Employee::whereIn('id',$emp_id)
  476. ->pluck('emp_name','id')
  477. ->toArray();
  478. $sales = SalesOrder::whereIn('id',array_unique(array_column($data['data'],'sales_order_id')))->pluck('order_number','id')->toArray();
  479. $storehouse = Storehouse::whereIn('id',array_unique(array_column($data['data'],'storehouse_id')))
  480. ->pluck('title','id')
  481. ->toArray();
  482. $supplier = Supplier::whereIn('id',array_unique(array_column($data['data'],'supplier')))
  483. ->select('title','id','is_main')
  484. ->get()
  485. ->toArray();
  486. $supplier_map = array_column($supplier,null,'id');
  487. $product = [];
  488. if(! empty($ergs['product'])){
  489. $sales_p_info = PurchaseOrderInfo::where('del_time',0)
  490. ->whereIn('purchase_order_id',array_column($data['data'],'id'))
  491. ->get()->toArray();
  492. $basic_price = BasicType::whereIn('id',array_unique(array_column($sales_p_info,'basic_type_id')))->pluck('title','id')->toArray();
  493. $map = (new ProductService())->getProductDetail(array_column($sales_p_info,'product_id'));
  494. foreach ($sales_p_info as $value){
  495. $tmp = $map[$value['product_id']] ?? [];
  496. $value['title'] = $tmp['title'] ?? "";
  497. $value['code'] = $tmp['code'] ?? "";
  498. $value['size'] = $tmp['size'] ?? "";
  499. $value['unit'] = $tmp['unit'] ?? "";
  500. $value['bar_code'] = $tmp['bar_code'] ?? "";
  501. $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
  502. $product[$value['purchase_order_id']][] = $value;
  503. }
  504. }
  505. //分社订货合同
  506. $sales_array = [];
  507. if(! empty($ergs['get_for_purchase'])) $sales_array = $this->fsdhOrder($data);
  508. list($for_amount_list, $for_amount_list1) = (new PaymentReceiptService())->getPaymentReceiptDataCountList(array_column($data['data'],'order_number'));
  509. list($getDifferentAmountALL,$getDifferentAmountALL1) = (new ReturnExchangeOrderService())->getDifferentAmountALLNew(array_column($data['data'],'id'),1);
  510. //获取发货信息
  511. // $invoice_map = (new InvoiceOrderService())->getInvoiceData($data['data']);
  512. //订单状态数据组织
  513. $state_array = $this->getStateMake($data['data']);
  514. //特殊功能按钮
  515. $special_button = $user['special_button'] ?? [];
  516. foreach ($data['data'] as $key => $value){
  517. $supplier_tmp = $supplier_map[$value['supplier']] ?? [];
  518. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']) : '';
  519. $data['data'][$key]['depart_name'] = $depart_map[$value['depart_id']] ?? '';
  520. $data['data'][$key]['crt_name'] = $emp_map[$value['crt_id']] ?? '';
  521. $data['data'][$key]['state_title'] = $this->makeState($data['data'][$key], $state_array);
  522. $data['data'][$key]['purchase_name'] = $emp_map[$value['purchase_id']] ?? '';
  523. $data['data'][$key]['order_type_title'] = PurchaseOrder::$order_type[$value['order_type']] ?? '';
  524. $data['data'][$key]['sales_order_number'] = $sales[$value['sales_order_id']] ?? '';
  525. $data['data'][$key]['fsdh_id'] = $sales_array[$value['order_number']] ?? 0;
  526. $data['data'][$key]['storehouse_title'] = $storehouse[$value['storehouse_id']] ?? '';
  527. $data['data'][$key]['supplier_title'] = $supplier_tmp['title'] ?? '';
  528. $data['data'][$key]['product'] = $product[$value['id']] ?? [];
  529. //发货信息 分社向总社采购
  530. // $invoice_state = "未发货";
  531. // if(! empty($invoice_map[$value['order_number']])) $invoice_state = implode(',',$invoice_map[$value['order_number']]);
  532. if(in_array($value['order_type'], [PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four])){
  533. $invoice_state = PurchaseOrder::$invoice_name[$value['invoice_state']] ?? "";
  534. $data['data'][$key]['state_message'] = "订单状态:" . $data['data'][$key]['state_title'] . "\n"."是否发货:" . $invoice_state;
  535. }else{
  536. $data['data'][$key]['state_message'] = "订单状态:" . $data['data'][$key]['state_title'];
  537. }
  538. //用于计算--------
  539. //已收(审核后)
  540. $one1 = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
  541. $data['data'][$key]['checked_payment_receipt_amount'] = $one1;
  542. //已收
  543. $one = $for_amount_list[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
  544. $data['data'][$key]['payment_receipt_amount'] = $one;
  545. //已红冲
  546. $three = $for_amount_list[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
  547. $data['data'][$key]['red_amount'] = $three;
  548. //已退货退款
  549. $return_exchange_amount = $getDifferentAmountALL[$value['id']] ?? 0;
  550. $data['data'][$key]['return_exchange_amount'] = $return_exchange_amount;
  551. //用于计算--------
  552. //用于统计--------
  553. $red = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
  554. $return_exchange_amount1 = $getDifferentAmountALL1[$value['id']] ?? 0;
  555. $bad = bcsub($return_exchange_amount1 ,$red,2);
  556. //已收金额
  557. $fee1 = bcsub($one1 ,$red,2);
  558. $data['data'][$key]['fee1'] = $fee1;
  559. //未收金额
  560. $fee2 = bcsub(bcsub(bcsub($value['purchase_total'], $fee1,2), $bad, 2),$red,2);
  561. $data['data'][$key]['fee2'] = $fee2;
  562. //红冲金额
  563. $data['data'][$key]['fee3'] = $red;
  564. //坏账金额
  565. $data['data'][$key]['fee4'] = $bad;
  566. //用于统计--------
  567. }
  568. return $data;
  569. }
  570. public function countData($column = "", $data, $user){
  571. if(empty($column) || empty($data['from_wx'])) return [0, 0];
  572. // 获取今天的开始和结束时间戳
  573. $todayStart = Carbon::today()->startOfDay()->timestamp;
  574. $todayEnd = Carbon::today()->endOfDay()->timestamp;
  575. // 获取昨天的开始和结束时间戳
  576. $yesterdayStart = Carbon::yesterday()->startOfDay()->timestamp;
  577. $yesterdayEnd = Carbon::yesterday()->endOfDay()->timestamp;
  578. $data['wx_' . $column] = [$todayStart, $todayEnd];
  579. $model = $this->purchaseCommon($data, $user);
  580. // 查询今天的数据条数
  581. $todayCount = $model->count();
  582. $data['wx_' . $column] = [$yesterdayStart, $yesterdayEnd];
  583. $model = $this->purchaseCommon($data, $user);
  584. // 查询昨天的数据条数
  585. $yesterdayCount = $model->count();
  586. return [$todayCount, $yesterdayCount];
  587. }
  588. public function fsdhOrder($data){
  589. if(empty($data['data'])) return [];
  590. $order_no = [];
  591. foreach ($data['data'] as $value){
  592. if(in_array($value['order_type'] , [PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four])) $order_no[] = $value['order_number'];
  593. }
  594. if(empty($order_no)) return [];
  595. $sale_order = SalesOrder::where('del_time',0)
  596. ->whereIn('contact_order_no', $order_no)
  597. ->pluck('id','contact_order_no')
  598. ->toArray();
  599. return $sale_order;
  600. }
  601. public function getStateMake($data){
  602. if(empty($data)) return [];
  603. $order_no = [];
  604. foreach ($data as $value){
  605. if(! in_array($value['state'], [PurchaseOrder::State_minus_one,PurchaseOrder::STATE_ONE])) continue;
  606. $order_no[] = $value['order_number'];
  607. }
  608. return (new OaService())->getOaTeamDetailList($order_no);
  609. }
  610. public function makeState($value, $state_array){
  611. if(! empty($state_array[$value['order_number']])){
  612. $return = $state_array[$value['order_number']];
  613. if($value['state'] == PurchaseOrder::State_minus_one){
  614. $state = "驳回:" . $return;
  615. }else{
  616. $state = "待" . $return . "审核";
  617. }
  618. }elseif($value['state'] == PurchaseOrder::STATE_ZERO){
  619. $state = "待" . $value['crt_name'] . "提交";
  620. }else{
  621. $state = PurchaseOrder::$name[$value['state']] ?? '';
  622. }
  623. return $state;
  624. }
  625. /**
  626. * 采购单参数规则
  627. * @param $data
  628. * @param $is_check
  629. * @return array
  630. */
  631. public function orderRule(&$data, $user, $is_check = true){
  632. if(empty($data['order_type'])) return [false,'采购订单类型不能为空'];
  633. if($data['order_type'] == PurchaseOrder::Order_type_two && ! empty($data['supplier'])) {
  634. $supplier = Supplier::where('id',$data['supplier'])->first();
  635. if(! empty($supplier->is_main)) return [false,PurchaseOrder::$order_type[PurchaseOrder::Order_type_two] . '供应商请选择非总社供应商'];
  636. }
  637. if($data['order_type'] == PurchaseOrder::Order_type_three || $data['order_type'] == PurchaseOrder::Order_type_four) {
  638. if(empty($data['supplier'])){
  639. return [false,'请选择总部供应商'];
  640. }else{
  641. $supplier = Supplier::where('id',$data['supplier'])->first();
  642. if(empty($supplier->is_main)) return [false,'请选择总社供应商'];
  643. }
  644. }
  645. if($data['order_type'] == PurchaseOrder::Order_type_three && ! empty($data['sales_order_id'])) return [false,PurchaseOrder::$order_type[PurchaseOrder::Order_type_three] . '不需要选择合同'];
  646. if($data['order_type'] == PurchaseOrder::Order_type_four && empty($data['sales_order_id'])) return [false, PurchaseOrder::$order_type[PurchaseOrder::Order_type_four] . '必须选择合同'];
  647. if($this->isEmpty($data,'product')) return [false,'产品不能为空'];
  648. if(empty($data['storehouse_id'])) return [false,'请选择仓库'];
  649. if(empty($data['menu_id'])) return [false, '菜单信息不能为空'];
  650. if(! empty($data['other_fee'])){
  651. $res = $this->checkNumber($data['other_fee']);
  652. if(! $res) return [false, '其它费用请输入不超过两位小数并且大于0的数值'];
  653. }
  654. if(! empty($data['discount_fee'])){
  655. $res = $this->checkNumber($data['discount_fee']);
  656. if(! $res) return [false, '优惠金额请输入不超过两位小数并且大于0的数值'];
  657. }
  658. if(! empty($data['total'])){
  659. $res = $this->checkNumber($data['total']);
  660. if(! $res) return [false, '产品总价请输入不超过两位小数并且大于0的数值'];
  661. }
  662. if(! empty($data['purchase_total'])){
  663. $res = $this->checkNumber($data['purchase_total']);
  664. if(! $res) return [false, '采购总价请输入不超过两位小数并且大于0的数值'];
  665. }
  666. $sports_bag_id = [];
  667. foreach ($data['product'] as $value){
  668. if(empty($value['number'])) return [false,'产品数量不能为空'];
  669. $res = $this->checkNumber($value['number']);
  670. if(! $res) return [false,'请输入正确的产品数量'];
  671. if(! empty($value['sports_bag_id']) && ! in_array($value['sports_bag_id'], $sports_bag_id)) $sports_bag_id[] = $value['sports_bag_id'];
  672. }
  673. //所属部门 以及 顶级部门
  674. if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
  675. $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
  676. if($is_check){
  677. $order_number = (new OrderNoService())->createOrderNumber(PurchaseOrder::prefix);
  678. if(empty($order_number)) return [false,'采购单号生成失败!'];
  679. $data['order_number'] = $order_number;
  680. $check_id = $sports_bag_id;
  681. }else{
  682. if($this->isEmpty($data,'order_number')) return [false,'采购单号不能为空!'];
  683. $purchase = PurchaseOrder::where('del_time',0)->where('order_number',$data['order_number'])->first();
  684. if(empty($purchase)) return [false, '采购单不存在或已被删除'];
  685. if($purchase->state > PurchaseOrder::STATE_ZERO) return [false,'请确认采购单单据状态,修改失败'];
  686. $sports_bag_id_save = PurchaseOrderInfo::where('del_time',0)
  687. ->where('purchase_order_id',$data['id'])
  688. ->where('sports_bag_id','>',0)
  689. ->select('sports_bag_id')
  690. ->get()->toArray();
  691. $sports_bag_id_save = array_unique(array_column($sports_bag_id_save,'sports_bag_id'));
  692. $check_id = array_values(array_diff($sports_bag_id, $sports_bag_id_save));
  693. }
  694. //校验活动包有效性
  695. $service = new SportsBagService();
  696. list($status, $msg) = $service->checkSportsBag($check_id);
  697. if(! $status) return [false, $msg];
  698. return [true, ''];
  699. }
  700. }