PurchaseOrderService.php 37 KB

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