PurchaseOrderService.php 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794
  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. // 填充产品
  243. list($product, $activity_product) = $this->purchaseFillDetailProduct($order);
  244. $order['product'] = $product;
  245. $order['activity_product'] = $activity_product;
  246. $file = PurchaseOrderFile::where('del_time',0)
  247. ->where('order_number',$data['order_number'])
  248. ->get()->toArray();
  249. $fileUploadService = new FileUploadService();
  250. foreach ($file as $value){
  251. if($value['type'] == PurchaseOrderFile::type_one){
  252. $tmp = [
  253. 'url' => $value['file'],
  254. 'name' => $value['name'],
  255. 'show_url' => $fileUploadService->getFileShow($value['file']),
  256. ];
  257. $order['file'][] = $tmp;
  258. }
  259. }
  260. $order['crt_name'] = $emp_map[$order['crt_id']] ?? '';
  261. $order['crt_time'] = $order['crt_time'] ? date("Y-m-d H:i:s",$order['crt_time']): '';
  262. $state_array = $this->getStateMake([$order]);
  263. $order['state_title'] = $this->makeState($order,$state_array);
  264. //可见范围
  265. $return = (new RangeService())->RangeDetail($order['id'],SeeRange::type_five);
  266. $order['depart'] = $return[0] ?? [];
  267. $order['employee'] = $return[1] ?? [];
  268. //对应的分社订货合同
  269. $order['sales_order_number2'] = SalesOrder::where('del_time',0)->where('contact_order_no',$data['order_number'])->value('order_number') ?? "";
  270. //回款信息
  271. $this->purchaseFillDetailPayment($order);
  272. return [true, $order];
  273. }
  274. public function purchaseFillDetailProduct($order){
  275. $product = $activity_product = [];
  276. $p_info = PurchaseOrderInfo::where('del_time',0)
  277. ->where('order_number',$order['order_number'])
  278. ->get()->toArray();
  279. $sports_bag_id = array_unique(array_column($p_info,'sports_bag_id'));
  280. $bag = SportsBag::whereIn('id',$sports_bag_id)->get()->toArray();
  281. $bag_pro = SportsBagProductInfo::where('del_time',0)->whereIn('sports_bag_id',$sports_bag_id)
  282. ->get()->toArray();
  283. $bag_map = array_column($bag,null,'id');
  284. $bag_pro_map = [];
  285. foreach ($bag_pro as $value){
  286. $bag_pro_map[$value['sports_bag_id']][] = $value;
  287. }
  288. $basic_price = BasicType::whereIn('id',array_unique(array_column($p_info,'basic_type_id')))->pluck('title','id')->toArray();
  289. $map = (new ProductService())->getProductDetail(array_column($p_info,'product_id'));
  290. $sports_bag_arr = [];
  291. $sports_bag_pro = [];
  292. foreach ($p_info as $value){
  293. $tmp = $map[$value['product_id']] ?? [];
  294. if(! empty($value['sports_bag_id'])){
  295. $bag_tmp = $bag_map[$value['sports_bag_id']] ?? [];
  296. if(! isset($sports_bag_arr[$value['sports_bag_id']])) $sports_bag_arr[$value['sports_bag_id']] = $bag_tmp;
  297. $bag_pro_tmp = $bag_pro_map[$value['sports_bag_id']] ?? [];
  298. foreach ($bag_pro_tmp as $k => $v){
  299. if($v['product_id'] != $value['product_id']) continue;
  300. $is_choose = false;
  301. $final_amount = 0;
  302. $number = $v['number'];
  303. $mark = "";
  304. if($v['id'] == $value['sports_bag_product_info_id']){
  305. $is_choose = true;
  306. $final_amount = $value['final_amount'];
  307. $number = $value['number'];
  308. $mark = $value['mark'];
  309. }
  310. $bag_pro_tmp[$k]['is_choose'] = $is_choose;
  311. $bag_pro_tmp[$k]['final_amount'] = $final_amount;
  312. $bag_pro_tmp[$k]['number'] = $number;
  313. $bag_pro_tmp[$k]['title'] = $tmp['title'] ?? "";
  314. $bag_pro_tmp[$k]['code'] = $tmp['code'] ?? "";
  315. $bag_pro_tmp[$k]['size'] = $tmp['size'] ?? "";
  316. $bag_pro_tmp[$k]['unit'] = $tmp['unit'] ?? "";
  317. $bag_pro_tmp[$k]['bar_code'] = $tmp['bar_code'] ?? "";
  318. $bag_pro_tmp[$k]['mark'] = $mark ?? "";
  319. $sports_bag_pro[$value['sports_bag_id']][] = $bag_pro_tmp[$k];
  320. }
  321. }else{
  322. $value['title'] = $tmp['title'] ?? "";
  323. $value['code'] = $tmp['code'] ?? "";
  324. $value['size'] = $tmp['size'] ?? "";
  325. $value['unit'] = $tmp['unit'] ?? "";
  326. $value['bar_code'] = $tmp['bar_code'] ?? "";
  327. $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
  328. $product[] = $value;
  329. }
  330. }
  331. foreach ($sports_bag_arr as $key => $value){
  332. $value['product'] = $sports_bag_pro[$key] ?? [];
  333. $activity_product[] = $value;
  334. }
  335. return [$product, $activity_product];
  336. }
  337. public function purchaseFillDetailPayment(&$order){
  338. //退换货信息
  339. $order['return_exchange'] = (new ReturnExchangeOrderService())->getDifferentAmount($order['id'],ReturnExchangeOrder::Order_type2);
  340. $order['return_exchange_amount'] = 0;
  341. foreach ($order['return_exchange'] as $value){
  342. if($value['state'] == ReturnExchangeOrder::State_two) $order['return_exchange_amount'] += $value['difference_amount'];
  343. }
  344. //回款单信息 审核过的
  345. $order['payment_receipt_list'] = (new PaymentReceiptService())->getPaymentReceiptDataList($order,PaymentReceipt::data_type_two);
  346. //坏账金额 = 已审核退货退款金额 - 红冲金额
  347. $order['payment_receipt_list']['bad_amount'] = bcsub($order['return_exchange_amount'], $order['payment_receipt_list']['red_amount'],2);
  348. //未回款金额 = 总金额 - 已回款金额 - 坏账金额 - 红冲
  349. $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);
  350. //回款单信息 审核过的
  351. $order['not_payment_receipt_amount'] = bcsub($order['purchase_total'],$order['payment_receipt_list']['not_confirm_receipt_amount'],2);
  352. }
  353. /**
  354. * 采购单删除
  355. * @param $data
  356. * @return array
  357. */
  358. public function del($data){
  359. if($this->isEmpty($data,'order_number')) return [false,'请选择数据!'];
  360. $order = PurchaseOrder::where('del_time',0)->where('order_number',$data['order_number'])->first();
  361. if(empty($order)) return [false,'采购单不存在或已被删除'];
  362. $order = $order->toArray();
  363. if($order['state'] > PurchaseOrder::STATE_ZERO) return [false,'请确认采购订单状态,删除失败!'];
  364. $bool = PaymentReceiptInfo::where('del_time',0)
  365. ->where('type',PaymentReceiptInfo::type_three)
  366. ->where('data_order_no', $order['order_number'])
  367. ->exists();
  368. if($bool) return [false, '采购已存在收付款单记录,请先删除收付款单据!'];
  369. try{
  370. DB::beginTransaction();
  371. PurchaseOrder::where('order_number',$data['order_number'])->where('del_time',0)->update([
  372. 'del_time'=>time()
  373. ]);
  374. PurchaseOrderInfo::where('order_number',$data['order_number'])->where('del_time',0)->update([
  375. 'del_time'=>time()
  376. ]);
  377. $old = PurchaseOrderFile::where('del_time',0)
  378. ->where('purchase_order_id',$order['id'])
  379. ->whereIn('type',[PurchaseOrderFile::type_one])
  380. ->select('file')
  381. ->get()->toArray();
  382. $old = array_column($old,'file');
  383. PurchaseOrderFile::where('order_number',$data['order_number'])
  384. ->where('del_time',0)
  385. ->update(['del_time' => time()]);
  386. (new RangeService())->RangeDelete($order['id'],SeeRange::type_five);
  387. DB::commit();
  388. }catch (\Throwable $e){
  389. DB::rollBack();
  390. return [false,$e->getMessage()];
  391. }
  392. return [true, ['file' => ['old' => $old]]];
  393. }
  394. public function purchaseCommon($data,$user){
  395. $model = PurchaseOrder::Clear($user,$data);
  396. $model = $model->where('del_time',0)
  397. ->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')
  398. ->orderby('id', 'desc');
  399. if(! empty($data['purchase_id'])) $model->where('id', $data['purchase_id']);
  400. if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
  401. if(! empty($data['depart_id'])) $model->where('depart_id', $data['depart_id']);
  402. if(! empty($data['company_id'])) $model->where('company_id', $data['company_id']);
  403. if(isset($data['state'])) $model->where('state',$data['state']);
  404. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  405. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  406. $model->whereBetween('crt_time',[$return[0],$return[1]]);
  407. }
  408. if(! empty($data['time_type'])) {
  409. if($data['time_type'] == 1) {
  410. $start = strtotime('today');
  411. $end = strtotime('tomorrow') - 1;
  412. }elseif ($data['time_type'] == 2){
  413. $start = strtotime('this week',strtotime('today'));
  414. $end = strtotime('this week +6 days 23:59:59', strtotime('today'));
  415. }
  416. if(! empty($start) && ! empty($end)) {
  417. $model->where('crt_time','>=',$start);
  418. $model->where('crt_time','<=',$end);
  419. }
  420. }
  421. if(! empty($data['order_type'])) {
  422. if($data['order_type'] == PurchaseOrder::Order_type_five){
  423. $model->whereIn('order_type',[PurchaseOrder::Order_type_two,PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four]);
  424. }else{
  425. $model->where('order_type',$data['order_type']);
  426. }
  427. }
  428. if(! empty($data['sale_order'])){
  429. $model2 = SalesOrder::Clear($user,$data);
  430. $sale = $model2->where('del_time',0)
  431. ->where('order_number', 'LIKE', '%'.$data['sale_order'].'%')
  432. ->select('id')
  433. ->get()->toArray();
  434. $model->whereIn('sales_order_id',array_unique(array_column($sale,'id')));
  435. }
  436. if(! empty($data['supplier_man'])){
  437. $emp = Supplier::where('del_time',0)
  438. ->where('title', 'LIKE', '%'.$data['supplier_man'].'%')
  439. ->select('id')
  440. ->get()->toArray();
  441. $model->whereIn('supplier',array_unique(array_column($emp,'id')));
  442. }
  443. if(! empty($data['purchase_man'])){
  444. $emp = Employee::where('del_time',0)
  445. ->where('emp_name', 'LIKE', '%'.$data['purchase_man'].'%')
  446. ->select('id')
  447. ->get()->toArray();
  448. $model->whereIn('purchase_id',array_unique(array_column($emp,'id')));
  449. }
  450. if(! empty($data['get_for_purchase'])){
  451. $model->whereIn('order_type',[PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four])
  452. ->where('state',">=",PurchaseOrder::STATE_TWO);
  453. }
  454. if(! empty($data['wx_crt_time'][0]) && ! empty($data['wx_crt_time'][1])) {
  455. $model->where('crt_time','>=',$data['wx_crt_time'][0]);
  456. $model->where('crt_time','<=',$data['wx_crt_time'][1]);
  457. }
  458. return $model;
  459. }
  460. /**
  461. * 获取采购单列表
  462. * @param $data
  463. * @param $user
  464. * @return array
  465. */
  466. public function getList($data,$user){
  467. $model = $this->purchaseCommon($data, $user);
  468. $list = $this->limit($model,'',$data);
  469. $list = $this->fillListData($list,$data,$user);
  470. $count = $this->countData("crt_time", $data, $user);
  471. $list['today'] = $count[0] ?? 0;
  472. $list['yesterday'] = $count[1] ?? 0;
  473. return [true, $list];
  474. }
  475. /**
  476. * 拼接数据
  477. * @param $data
  478. * @return array
  479. */
  480. public function fillListData($data,$ergs,$user){
  481. if(empty($data['data'])) return $data;
  482. $depart_id = array_unique(array_column($data['data'],'depart_id'));
  483. $depart_map = Depart::whereIn('id',$depart_id)
  484. ->pluck('title','id')
  485. ->toArray();
  486. $emp_id = array_unique(array_merge_recursive(array_column($data['data'],'crt_id'),array_column($data['data'],'purchase_id')));
  487. $emp_map = Employee::whereIn('id',$emp_id)
  488. ->pluck('emp_name','id')
  489. ->toArray();
  490. $sales = SalesOrder::whereIn('id',array_unique(array_column($data['data'],'sales_order_id')))->pluck('order_number','id')->toArray();
  491. $storehouse = Storehouse::whereIn('id',array_unique(array_column($data['data'],'storehouse_id')))
  492. ->pluck('title','id')
  493. ->toArray();
  494. $supplier = Supplier::whereIn('id',array_unique(array_column($data['data'],'supplier')))
  495. ->select('title','id','is_main')
  496. ->get()
  497. ->toArray();
  498. $supplier_map = array_column($supplier,null,'id');
  499. $product = [];
  500. if(! empty($ergs['product'])){
  501. $sales_p_info = PurchaseOrderInfo::where('del_time',0)
  502. ->whereIn('purchase_order_id',array_column($data['data'],'id'))
  503. ->get()->toArray();
  504. $basic_price = BasicType::whereIn('id',array_unique(array_column($sales_p_info,'basic_type_id')))->pluck('title','id')->toArray();
  505. $map = (new ProductService())->getProductDetail(array_column($sales_p_info,'product_id'));
  506. foreach ($sales_p_info as $value){
  507. $tmp = $map[$value['product_id']] ?? [];
  508. $value['title'] = $tmp['title'] ?? "";
  509. $value['code'] = $tmp['code'] ?? "";
  510. $value['size'] = $tmp['size'] ?? "";
  511. $value['unit'] = $tmp['unit'] ?? "";
  512. $value['bar_code'] = $tmp['bar_code'] ?? "";
  513. $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
  514. $product[$value['purchase_order_id']][] = $value;
  515. }
  516. }
  517. //分社订货合同
  518. $sales_array = [];
  519. if(! empty($ergs['get_for_purchase'])) $sales_array = $this->fsdhOrder($data);
  520. list($for_amount_list, $for_amount_list1) = (new PaymentReceiptService())->getPaymentReceiptDataCountList(array_column($data['data'],'order_number'));
  521. list($getDifferentAmountALL,$getDifferentAmountALL1) = (new ReturnExchangeOrderService())->getDifferentAmountALLNew(array_column($data['data'],'id'),1);
  522. //获取发货信息
  523. // $invoice_map = (new InvoiceOrderService())->getInvoiceData($data['data']);
  524. //订单状态数据组织
  525. $state_array = $this->getStateMake($data['data']);
  526. //特殊功能按钮
  527. $special_button = $user['special_button'] ?? [];
  528. foreach ($data['data'] as $key => $value){
  529. $supplier_tmp = $supplier_map[$value['supplier']] ?? [];
  530. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']) : '';
  531. $data['data'][$key]['depart_name'] = $depart_map[$value['depart_id']] ?? '';
  532. $data['data'][$key]['crt_name'] = $emp_map[$value['crt_id']] ?? '';
  533. $data['data'][$key]['state_title'] = $this->makeState($data['data'][$key], $state_array);
  534. $data['data'][$key]['purchase_name'] = $emp_map[$value['purchase_id']] ?? '';
  535. $data['data'][$key]['order_type_title'] = PurchaseOrder::$order_type[$value['order_type']] ?? '';
  536. $data['data'][$key]['sales_order_number'] = $sales[$value['sales_order_id']] ?? '';
  537. $data['data'][$key]['fsdh_id'] = $sales_array[$value['order_number']] ?? 0;
  538. $data['data'][$key]['storehouse_title'] = $storehouse[$value['storehouse_id']] ?? '';
  539. $data['data'][$key]['supplier_title'] = $supplier_tmp['title'] ?? '';
  540. $data['data'][$key]['product'] = $product[$value['id']] ?? [];
  541. //发货信息 分社向总社采购
  542. // $invoice_state = "未发货";
  543. // if(! empty($invoice_map[$value['order_number']])) $invoice_state = implode(',',$invoice_map[$value['order_number']]);
  544. if(in_array($value['order_type'], [PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four])){
  545. $invoice_state = PurchaseOrder::$invoice_name[$value['invoice_state']] ?? "";
  546. $data['data'][$key]['state_message'] = "订单状态:" . $data['data'][$key]['state_title'] . "\n"."是否发货:" . $invoice_state;
  547. }else{
  548. $data['data'][$key]['state_message'] = "订单状态:" . $data['data'][$key]['state_title'];
  549. }
  550. //用于计算--------
  551. //已收(审核后)
  552. $one1 = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
  553. $data['data'][$key]['checked_payment_receipt_amount'] = $one1;
  554. //已收
  555. $one = $for_amount_list[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
  556. $data['data'][$key]['payment_receipt_amount'] = $one;
  557. //已红冲
  558. $three = $for_amount_list[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
  559. $data['data'][$key]['red_amount'] = $three;
  560. //已退货退款
  561. $return_exchange_amount = $getDifferentAmountALL[$value['id']] ?? 0;
  562. $data['data'][$key]['return_exchange_amount'] = $return_exchange_amount;
  563. //用于计算--------
  564. //用于统计--------
  565. $red = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
  566. $return_exchange_amount1 = $getDifferentAmountALL1[$value['id']] ?? 0;
  567. $bad = bcsub($return_exchange_amount1 ,$red,2);
  568. //已收金额
  569. $fee1 = bcsub($one1 ,$red,2);
  570. $data['data'][$key]['fee1'] = $fee1;
  571. //未收金额
  572. $fee2 = bcsub(bcsub(bcsub($value['purchase_total'], $fee1,2), $bad, 2),$red,2);
  573. $data['data'][$key]['fee2'] = $fee2;
  574. //红冲金额
  575. $data['data'][$key]['fee3'] = $red;
  576. //坏账金额
  577. $data['data'][$key]['fee4'] = $bad;
  578. //用于统计--------
  579. }
  580. return $data;
  581. }
  582. public function countData($column = "", $data, $user){
  583. if(empty($column) || empty($data['from_wx'])) return [0, 0];
  584. // 获取今天的开始和结束时间戳
  585. $todayStart = Carbon::today()->startOfDay()->timestamp;
  586. $todayEnd = Carbon::today()->endOfDay()->timestamp;
  587. // 获取昨天的开始和结束时间戳
  588. $yesterdayStart = Carbon::yesterday()->startOfDay()->timestamp;
  589. $yesterdayEnd = Carbon::yesterday()->endOfDay()->timestamp;
  590. $data['wx_' . $column] = [$todayStart, $todayEnd];
  591. $model = $this->purchaseCommon($data, $user);
  592. // 查询今天的数据条数
  593. $todayCount = $model->count();
  594. $data['wx_' . $column] = [$yesterdayStart, $yesterdayEnd];
  595. $model = $this->purchaseCommon($data, $user);
  596. // 查询昨天的数据条数
  597. $yesterdayCount = $model->count();
  598. return [$todayCount, $yesterdayCount];
  599. }
  600. public function fsdhOrder($data){
  601. if(empty($data['data'])) return [];
  602. $order_no = [];
  603. foreach ($data['data'] as $value){
  604. if(in_array($value['order_type'] , [PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four])) $order_no[] = $value['order_number'];
  605. }
  606. if(empty($order_no)) return [];
  607. $sale_order = SalesOrder::where('del_time',0)
  608. ->whereIn('contact_order_no', $order_no)
  609. ->pluck('id','contact_order_no')
  610. ->toArray();
  611. return $sale_order;
  612. }
  613. public function getStateMake($data){
  614. if(empty($data)) return [];
  615. $order_no = [];
  616. foreach ($data as $value){
  617. if(! in_array($value['state'], [PurchaseOrder::State_minus_one,PurchaseOrder::STATE_ONE])) continue;
  618. $order_no[] = $value['order_number'];
  619. }
  620. return (new OaService())->getOaTeamDetailList($order_no);
  621. }
  622. public function makeState($value, $state_array){
  623. if(! empty($state_array[$value['order_number']])){
  624. $return = $state_array[$value['order_number']];
  625. if($value['state'] == PurchaseOrder::State_minus_one){
  626. $state = "驳回:" . $return;
  627. }else{
  628. $state = "待" . $return . "审核";
  629. }
  630. }elseif($value['state'] == PurchaseOrder::STATE_ZERO){
  631. $state = "待" . $value['crt_name'] . "提交";
  632. }else{
  633. $state = PurchaseOrder::$name[$value['state']] ?? '';
  634. }
  635. return $state;
  636. }
  637. /**
  638. * 采购单参数规则
  639. * @param $data
  640. * @param $is_check
  641. * @return array
  642. */
  643. public function orderRule(&$data, $user, $is_check = true){
  644. if(empty($data['order_type'])) return [false,'采购订单类型不能为空'];
  645. if($data['order_type'] == PurchaseOrder::Order_type_two && ! empty($data['supplier'])) {
  646. $supplier = Supplier::where('id',$data['supplier'])->first();
  647. if(! empty($supplier->is_main)) return [false,PurchaseOrder::$order_type[PurchaseOrder::Order_type_two] . '供应商请选择非总社供应商'];
  648. }
  649. if($data['order_type'] == PurchaseOrder::Order_type_three || $data['order_type'] == PurchaseOrder::Order_type_four) {
  650. if(empty($data['supplier'])){
  651. return [false,'请选择总部供应商'];
  652. }else{
  653. $supplier = Supplier::where('id',$data['supplier'])->first();
  654. if(empty($supplier->is_main)) return [false,'请选择总社供应商'];
  655. }
  656. }
  657. if($data['order_type'] == PurchaseOrder::Order_type_three && ! empty($data['sales_order_id'])) return [false,PurchaseOrder::$order_type[PurchaseOrder::Order_type_three] . '不需要选择合同'];
  658. if($data['order_type'] == PurchaseOrder::Order_type_four && empty($data['sales_order_id'])) return [false, PurchaseOrder::$order_type[PurchaseOrder::Order_type_four] . '必须选择合同'];
  659. if($this->isEmpty($data,'product')) return [false,'产品不能为空'];
  660. if(empty($data['storehouse_id'])) return [false,'请选择仓库'];
  661. if(empty($data['menu_id'])) return [false, '菜单信息不能为空'];
  662. if(! empty($data['other_fee'])){
  663. $res = $this->checkNumber($data['other_fee']);
  664. if(! $res) return [false, '其它费用请输入不超过两位小数并且大于0的数值'];
  665. }
  666. if(! empty($data['discount_fee'])){
  667. $res = $this->checkNumber($data['discount_fee']);
  668. if(! $res) return [false, '优惠金额请输入不超过两位小数并且大于0的数值'];
  669. }
  670. if(! empty($data['total'])){
  671. $res = $this->checkNumber($data['total']);
  672. if(! $res) return [false, '产品总价请输入不超过两位小数并且大于0的数值'];
  673. }
  674. if(! empty($data['purchase_total'])){
  675. $res = $this->checkNumber($data['purchase_total']);
  676. if(! $res) return [false, '采购总价请输入不超过两位小数并且大于0的数值'];
  677. }
  678. $sports_bag_id = [];
  679. foreach ($data['product'] as $value){
  680. if(empty($value['number'])) return [false,'产品数量不能为空'];
  681. $res = $this->checkNumber($value['number']);
  682. if(! $res) return [false,'请输入正确的产品数量'];
  683. if(! empty($value['sports_bag_id']) && ! in_array($value['sports_bag_id'], $sports_bag_id)) $sports_bag_id[] = $value['sports_bag_id'];
  684. }
  685. //所属部门 以及 顶级部门
  686. if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
  687. $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
  688. if($is_check){
  689. $order_number = (new OrderNoService())->createOrderNumber(PurchaseOrder::prefix);
  690. if(empty($order_number)) return [false,'采购单号生成失败!'];
  691. $data['order_number'] = $order_number;
  692. $check_id = $sports_bag_id;
  693. }else{
  694. if($this->isEmpty($data,'order_number')) return [false,'采购单号不能为空!'];
  695. $purchase = PurchaseOrder::where('del_time',0)->where('order_number',$data['order_number'])->first();
  696. if(empty($purchase)) return [false, '采购单不存在或已被删除'];
  697. if($purchase->state > PurchaseOrder::STATE_ZERO) return [false,'请确认采购单单据状态,修改失败'];
  698. $sports_bag_id_save = PurchaseOrderInfo::where('del_time',0)
  699. ->where('purchase_order_id',$data['id'])
  700. ->where('sports_bag_id','>',0)
  701. ->select('sports_bag_id')
  702. ->get()->toArray();
  703. $sports_bag_id_save = array_unique(array_column($sports_bag_id_save,'sports_bag_id'));
  704. $check_id = array_values(array_diff($sports_bag_id, $sports_bag_id_save));
  705. }
  706. //校验活动包有效性
  707. $service = new SportsBagService();
  708. list($status, $msg) = $service->checkSportsBag($check_id);
  709. if(! $status) return [false, $msg];
  710. return [true, ''];
  711. }
  712. }