OutBoundOrderService.php 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760
  1. <?php
  2. namespace App\Service;
  3. use App\Model\Employee;
  4. use App\Model\OrderInventoryStock;
  5. use App\Model\OutBoundOrder;
  6. use App\Model\OutBoundOrderInfo;
  7. use App\Model\Product;
  8. use App\Model\ProductInventorySet;
  9. use App\Model\PurchaseOrderInfoForOutBound;
  10. use App\Model\ReturnExchangeOrder;
  11. use App\Model\ReturnExchangeOrderProductInfo;
  12. use App\Model\SalesOrder;
  13. use App\Model\SalesOrderProductInfo;
  14. use App\Model\Setting;
  15. use App\Model\Storehouse;
  16. use Illuminate\Support\Facades\DB;
  17. class OutBoundOrderService extends Service
  18. {
  19. public function edit($data,$user){
  20. list($status,$msg) = $this->orderRule($data,$user,false);
  21. if(! $status) return [$status,$msg];
  22. try{
  23. $time = time();
  24. DB::beginTransaction();
  25. $material_model = OutBoundOrder::where('order_number',$data['order_number'])->first();
  26. $material_model->data_id = $data['data_id'];
  27. $material_model->type = $data['type'];
  28. $material_model->out_id = $data['out_id'];
  29. $material_model->mark = $data['mark'] ?? "";
  30. $material_model->storehouse_id = $data['storehouse_id'];
  31. $material_model->save();
  32. OutBoundOrderInfo::where('order_number',$data['order_number'])
  33. ->where('del_time',0)
  34. ->update(['del_time' => time()]);
  35. if(! empty($data['product'])){
  36. $sub = [];
  37. foreach ($data['product'] as $value){
  38. $sub[] = [
  39. 'out_bound_id' => $material_model->id,
  40. 'order_number' => $data['order_number'],
  41. 'storehouse_id' => $data['storehouse_id'] ?? 0,
  42. 'product_id' => $value['product_id'],
  43. 'number' => $value['number'],
  44. 'price' => $value['price'] ?? 0,
  45. 'final_amount' => $value['final_amount'] ?? 0,
  46. 'data_id' => $data['data_id'],
  47. 'type' => $data['type'],
  48. ];
  49. }
  50. OutBoundOrderInfo::insert($sub);
  51. $is_check_stock = OrderInventoryStock::where('order_number', $data['order_number'])
  52. ->where('del_time',0)
  53. ->value('is_check_stock') ?? 0;
  54. //锁定库存
  55. ProductInventoryService::changeLockNumber($user, $msg[0],$msg[1],$is_check_stock);
  56. }
  57. PurchaseOrderInfoForOutBound::where('del_time',0)
  58. ->where('data_id', $material_model->id)
  59. ->where('type', PurchaseOrderInfoForOutBound::type_one)
  60. ->update(['del_time' => $time]);
  61. //增加采购占用
  62. $purchase_return = $msg[2] ?? [];
  63. if(! empty($purchase_return)){
  64. foreach ($purchase_return as $key => $value){
  65. $purchase_return[$key]['data_id'] = $material_model->id;
  66. }
  67. PurchaseOrderInfoForOutBound::insert($purchase_return);
  68. }
  69. DB::commit();
  70. }catch (\Throwable $e){
  71. DB::rollBack();
  72. return [false,$e->getMessage()];
  73. }
  74. if(! empty($data['check'])) {
  75. list($status,$msg) = (new CheckService())->checkAll([
  76. "id" => $material_model->id,
  77. "order_number" => $data['order_number'],
  78. "opt_case" => CheckService::sixteen,
  79. "menu_id" => $data['menu_id']
  80. ],$user);
  81. // if(! $status) return [true, '保存成功,出库单确认失败,异常信息:' . $msg];
  82. }
  83. return [true,''];
  84. }
  85. public function add($data,$user){
  86. list($status,$msg) = $this->orderRule($data, $user);
  87. if(! $status) return [$status,$msg];
  88. try{
  89. DB::beginTransaction();
  90. $material_model = new OutBoundOrder();
  91. $material_model->order_number = $data['order_number'];
  92. $material_model->data_id = $data['data_id'];
  93. $material_model->type = $data['type'];
  94. $material_model->out_id = $data['out_id'];
  95. $material_model->depart_id = $data['depart_id'] ?? 0;
  96. $material_model->top_depart_id = $data['top_depart_id'] ?? 0;
  97. $material_model->mark = $data['mark'] ?? "";
  98. $material_model->crt_id = $user['id'];
  99. $material_model->storehouse_id = $data['storehouse_id'];
  100. $material_model->save();
  101. if(!empty($data['product'])){
  102. $sub = [];
  103. foreach ($data['product'] as $value){
  104. $sub[] = [
  105. 'out_bound_id' => $material_model->id,
  106. 'order_number' => $data['order_number'],
  107. 'storehouse_id' => $data['storehouse_id'] ?? 0,
  108. 'product_id' => $value['product_id'],
  109. 'number' => $value['number'],
  110. 'price' => $value['price'] ?? 0,
  111. 'final_amount' => $value['final_amount'] ?? 0,
  112. 'data_id' => $data['data_id'],
  113. 'type' => $data['type'],
  114. ];
  115. }
  116. OutBoundOrderInfo::insert($sub);
  117. //锁定库存
  118. ProductInventoryService::changeLockNumber($user,$msg[0],[]);
  119. }
  120. //增加采购占用
  121. $purchase_return = $msg[2] ?? [];
  122. if(! empty($purchase_return)){
  123. foreach ($purchase_return as $key => $value){
  124. $purchase_return[$key]['data_id'] = $material_model->id;
  125. }
  126. PurchaseOrderInfoForOutBound::insert($purchase_return);
  127. }
  128. //单据创建时是否校验库存
  129. (new CheckService())->orderInventoryInsert(['order_number' => $data['order_number'], 'is_check_stock' => $data['is_check_stock']]);
  130. DB::commit();
  131. }catch (\Throwable $exception){
  132. DB::rollBack();
  133. if (str_contains($exception->getMessage(), '1062') || str_contains($exception->getMessage(), 'Duplicate entry')) {
  134. return [false, '网络波动,请重新操作!'];
  135. }
  136. return [false,$exception->getMessage()];
  137. }
  138. if(! empty($data['check'])) {
  139. list($status,$msg) = (new CheckService())->checkAll([
  140. "id" => $material_model->id,
  141. "order_number" => $data['order_number'],
  142. "opt_case" => CheckService::sixteen,
  143. "menu_id" => $data['menu_id']
  144. ],$user);
  145. if(! $status) return [true, '保存成功,出库单确认失败,异常信息:' . $msg];
  146. }
  147. return [true, ''];
  148. }
  149. public function detail($data,$user){
  150. if($this->isEmpty($data,'order_number')) return [false,'请选择数据'];
  151. $order = OutBoundOrder::where('order_number',$data['order_number'])->where('del_time',0)->first();
  152. if(empty($order)) return [false, '出库单不存在或已被删除'];
  153. $order = $order->toArray();
  154. $order['storehouse_title'] = Storehouse::where('id',$order['storehouse_id'])->value('title');
  155. $order['state_title'] = OutBoundOrder::$name[$order['state']] ?? '';
  156. $emp_map = Employee::whereIn('id',array_unique(array_merge_recursive([$order['crt_id']],[$order['out_id']])))
  157. ->pluck('emp_name','id')
  158. ->toArray();
  159. $info = OutBoundOrderInfo::where('del_time',0)
  160. ->where('order_number',$data['order_number'])
  161. ->get()->toArray();
  162. $map = (new ProductService())->getProductDetail(array_column($info,'product_id'));
  163. foreach ($info as $value){
  164. $tmp = $map[$value['product_id']] ?? [];
  165. $value['title'] = $tmp['title'] ?? "";
  166. $value['code'] = $tmp['code'] ?? "";
  167. $value['size'] = $tmp['size'] ?? "";
  168. $value['unit'] = $tmp['unit'] ?? "";
  169. $value['bar_code'] = $tmp['bar_code'] ?? "";
  170. $order['product'][] = $value;
  171. }
  172. $order['out_name'] = $emp_map[$order['out_id']] ?? '';
  173. $order['crt_name'] = $emp_map[$order['crt_id']] ?? '';
  174. $order['crt_time'] = $order['crt_time'] ? date("Y-m-d H:i:s",$order['crt_time']): '';
  175. if($order['type'] == OutBoundOrder::out_type_one){
  176. $sales = (object)[];
  177. list($status, $msg) = (new SalesOrderService())->detail(['id' => $order['data_id']], $user);
  178. if($status) $sales = $msg;
  179. $order['contact_order'] = $sales;
  180. }
  181. //可见范围
  182. // $return = (new RangeService())->RangeDetail($order['id'],SeeRange::type_three);
  183. // $order['depart'] = $return[0] ?? [];
  184. // $order['employee'] = $return[1] ?? [];
  185. return [true, $order];
  186. }
  187. public function del($data, $user){
  188. if($this->isEmpty($data,'order_number')) return [false,'请选择数据'];
  189. $order = OutBoundOrder::where('order_number',$data['order_number'])->where('del_time',0)->first();
  190. if(empty($order)) return [false,'出库单不存在或已被删除'];
  191. $order = $order->toArray();
  192. if($order['state'] > OutBoundOrder::STATE_ZERO) return [false,'请确认出库单状态,删除失败'];
  193. $product_save = $this->getSaveDetail($data['id']);
  194. $time = time();
  195. try{
  196. DB::beginTransaction();
  197. OutBoundOrder::where('order_number',$data['order_number'])->update([
  198. 'del_time'=>$time
  199. ]);
  200. OutBoundOrderInfo::where('order_number',$data['order_number'])->update([
  201. 'del_time'=>$time
  202. ]);
  203. PurchaseOrderInfoForOutBound::where('del_time',0)
  204. ->where('data_id', $order['id'])
  205. ->where('type', 1)
  206. ->update(['del_time' => $time]);
  207. // (new RangeService())->RangeDelete($order['id'],SeeRange::type_three);
  208. $is_check_stock = OrderInventoryStock::where('order_number', $data['order_number'])
  209. ->where('del_time',0)
  210. ->value('is_check_stock') ?? 0;
  211. //锁定库存释放
  212. ProductInventoryService::changeLockNumber($user,[],$product_save,$is_check_stock);
  213. DB::commit();
  214. }catch (\Throwable $e){
  215. DB::rollBack();
  216. return [false,$e->getMessage()];
  217. }
  218. return [true,''];
  219. }
  220. public function getList($data,$user){
  221. $model = OutBoundOrder::Clear($user,$data);
  222. $model = $model->where('del_time',0)
  223. ->select('id','order_number','data_id','type','crt_id','mark','state','crt_time','storehouse_id','top_depart_id','storehouse_id','out_id')
  224. ->orderby('id', 'desc');
  225. if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
  226. if(isset($data['state'])) $model->where('state',$data['state']);
  227. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  228. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  229. $model->whereBetween('crt_time',[$return[0],$return[1]]);
  230. }
  231. if(! empty($data['sale_order'])){
  232. $sale_order_number = $data['sale_order'];
  233. $sale = SalesOrder::where('del_time',0)
  234. ->where('order_number', 'LIKE', '%'.$sale_order_number.'%')
  235. ->select('id')
  236. ->get()->toArray();
  237. $model->whereIn('data_id',array_unique(array_column($sale,'id')))
  238. ->where('type', OutBoundOrder::out_type_one);
  239. }
  240. $list = $this->limit($model,'',$data);
  241. $list = $this->fillListData($list);
  242. return [true, $list];
  243. }
  244. public function fillListData($data){
  245. if(empty($data['data'])) return $data;
  246. $emp_id = array_unique(array_merge_recursive(array_column($data['data'],'crt_id'),array_column($data['data'],'out_id')));
  247. $emp_map = Employee::whereIn('id',$emp_id)
  248. ->pluck('emp_name','id')
  249. ->toArray();
  250. $sales_id = [];
  251. foreach ($data['data'] as $value){
  252. if($value['type'] == OutBoundOrder::out_type_one) $sales_id[] = $value['data_id'];
  253. }
  254. $sales = SalesOrder::whereIn('id', $sales_id)
  255. ->pluck('order_number','id')
  256. ->toArray();
  257. $storehouse = Storehouse::whereIn('id',array_unique(array_column($data['data'],'storehouse_id')))
  258. ->pluck('title','id')
  259. ->toArray();
  260. foreach ($data['data'] as $key => $value){
  261. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']) : '';
  262. $data['data'][$key]['crt_name'] = $emp_map[$value['crt_id']] ?? '';
  263. $data['data'][$key]['out_name'] = $emp_map[$value['out_id']] ?? '';
  264. $data['data'][$key]['state_title'] = OutBoundOrder::$name[$value['state']] ?? '';
  265. $data['data'][$key]['data_order_number'] = $sales[$value['data_id']] ?? "";
  266. $data['data'][$key]['storehouse_title'] = $storehouse[$value['storehouse_id']] ?? '';
  267. }
  268. return $data;
  269. }
  270. public function orderRule(&$data, $user, $is_check = true){
  271. if(empty($data['storehouse_id'])) return [false, '仓库不能为空'];
  272. if(empty($data['product'])) return [false, '出库数据不能为空'];
  273. if(empty($data['data_id'])) return [false, '出库数据源id不能为空'];
  274. if(empty($data['type'])) return [false, '出库类型不能为空'];
  275. if(empty($data['out_id'])) $data['out_id'] = $user['id'];
  276. $product_submit = $product_id = [];
  277. foreach ($data['product'] as $value){
  278. if(empty($value['product_id'])) return [false, '出库产品不能为空'];
  279. if(empty($value['number'])) return [false, '出库产品数量不能为空'];
  280. $res = $this->checkNumber($value['number']);
  281. if(! $res) return [false,'请输入正确的产品数量'];
  282. if(! isset($value['price'])) return [false, '出库产品单价不能为空'];
  283. if(! isset($value['final_amount'])) return [false, '出库产品总价值不能为空'];
  284. $key = $value['product_id'] . ',' .$data['storehouse_id'];
  285. if(isset($product_submit[$key])){
  286. $product_submit[$key] += $value['number'];
  287. }else{
  288. $product_submit[$key] = $value['number'];
  289. }
  290. $product_id[] = $value['product_id'];
  291. }
  292. //剩余能发
  293. $id = $data['id'] ?? 0;
  294. $purchase_return = [];
  295. if($data['type'] == OutBoundOrder::out_type_one) {
  296. list($status,$return) = $this->getSalesProduct(['out_bound_id' => $id, 'data_id' => $data['data_id'], 'type' => $data['type']], $user, $data['storehouse_id']);
  297. if(! $status) return [false, $return];
  298. $s_product = array_column($return,'number','product_id');
  299. //比较
  300. foreach ($product_submit as $pro => $number){
  301. $tmp = explode(',',$pro);
  302. $p = $tmp[0];
  303. if(! isset($s_product[$p])) return [false,'产品错误,合同中不存在该产品或产品出库已完成'];
  304. $s_number = $s_product[$p];
  305. if($number > $s_number) return [false,'出库产品数量不能超过合同产品数量'];
  306. }
  307. //校验采购单
  308. list($status, $msg) = $this->checkPurchase($id,$data,$user);
  309. if(! $status) return [false, $msg];
  310. $purchase_return = $msg;
  311. }
  312. //已保存
  313. $product_save = $this->getSaveDetail($id);
  314. //校验库存
  315. list($status,$msg) = (new ProductInventoryService())->compareStock($user,$product_id, $product_submit, $product_save);
  316. if(! $status) return [false, $msg];
  317. //所属部门 以及 顶级部门
  318. if(empty($data['depart_id'])) {
  319. $data['depart_id'] = $this->getDepart($user);
  320. $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
  321. }
  322. $data['is_check_stock'] = $user['is_check_stock'];
  323. if($is_check){
  324. $order_number = (new OrderNoService())->createOrderNumber(OutBoundOrder::prefix);
  325. if(empty($order_number)) return [false,'出库单号生成失败'];
  326. $data['order_number'] = $order_number;
  327. }else{
  328. if($this->isEmpty($data,'id')) return [false,'出库单ID不能为空'];
  329. if($this->isEmpty($data,'order_number')) return [false,'出库单号不能为空'];
  330. $order = OutBoundOrder::where('order_number', $data['order_number'])->where('del_time',0)->first();
  331. if(empty($order)) return [false, '出库单不存在或已被删除'];
  332. $order = $order->toArray();
  333. if($order['state'] > OutBoundOrder::STATE_ZERO) return [false, '请确认出库单状态,编辑失败'];
  334. }
  335. return [true, [$product_submit, $product_save, $purchase_return]];
  336. }
  337. public function outBoundGetProduct($data, $user){
  338. if(empty($data['data_id'])) return [false, '合同ID不能为空'];
  339. $data_id = $data['data_id'];
  340. $out_bound_id = $data['out_bound_id'] ?? 0;
  341. if(empty($data['type'])) return [false, '出库类型不能为空'];
  342. if(! in_array($data['type'], OutBoundOrder::$out_type)) return [false, '出库类型不存在'];
  343. // 合同 出库
  344. $return = [];
  345. if($data['type'] == OutBoundOrder::out_type_one) $return = $this->getSalesProductForList($data, $user);
  346. return [true, $return];
  347. }
  348. public function getSalesProductForList($data, $user){
  349. $return = [];
  350. $data_id = $data['data_id'];
  351. $out_bound_id = $data['out_bound_id'] ?? 0;
  352. $sale = SalesOrder::where('del_time',0)
  353. ->where('id', $data_id)
  354. ->first();
  355. if(empty($sale)) return [false, '合同不存在或已被删除'];
  356. $sale = $sale->toArray();
  357. //仓库ID
  358. $storehouse = Storehouse::where('top_depart_id', $sale['top_depart_id'])->where('del_time',0)->value('id');
  359. $product = SalesOrderProductInfo::where('del_time',0)
  360. ->where('sales_order_id', $data_id)
  361. ->select('product_id', 'number', 'final_amount','price')
  362. ->get()->toArray();
  363. $product_id = array_column($product,'product_id');
  364. $map = (new ProductService())->getProductDetail($product_id);
  365. //采购单产品
  366. $service = new PurchaseOrderService();
  367. $purchase = $service->getPurchaseProduct($product_id, $storehouse);
  368. //合同出库产品
  369. $product_map = [];
  370. $save = OutBoundOrderInfo::where('del_time',0)
  371. ->where('type', $data['type'])
  372. ->where('data_id', $data_id)
  373. ->when(! empty($out_bound_id), function ($query) use ($out_bound_id) {
  374. return $query->where('out_bound_id', '<>', $out_bound_id);
  375. })
  376. ->select('product_id', 'number', 'final_amount')
  377. ->get()->toArray();
  378. foreach ($save as $value){
  379. if(isset($product_map[$value['product_id']])){
  380. $number = bcadd($value['number'], $product_map[$value['product_id']]);
  381. $product_map[$value['product_id']] = $number;
  382. }else{
  383. $product_map[$value['product_id']] = $value['number'];
  384. }
  385. }
  386. //合同退货产品
  387. $product_map2 = [];
  388. $return_id = ReturnExchangeOrder::where('del_time',0)
  389. ->where('type', ReturnExchangeOrder::Order_type)
  390. ->where('model_type', ReturnExchangeOrder::Model_type_one)
  391. ->where('data_id', $data_id)
  392. ->select('id')
  393. ->get()->toArray();
  394. $save2 = ReturnExchangeOrderProductInfo::where('del_time',0)
  395. ->whereIn('return_exchange_id', array_column($return_id,'id'))
  396. ->where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
  397. ->select('product_id', 'number', 'final_amount')
  398. ->get()->toArray();
  399. foreach ($save2 as $value){
  400. if(isset($product_map2[$value['product_id']])){
  401. $number = bcadd($value['number'], $product_map2[$value['product_id']]);
  402. $product_map2[$value['product_id']] = $number;
  403. }else{
  404. $product_map2[$value['product_id']] = $value['number'];
  405. }
  406. }
  407. foreach ($product as $value){
  408. //合同出库产品
  409. $p1 = $product_map[$value['product_id']] ?? 0;
  410. //合同退货产品
  411. $p2 = $product_map2[$value['product_id']] ?? 0;
  412. $number = bcsub(bcsub($value['number'], $p1,2), $p2,2);
  413. if($p1 > 0) {
  414. $state = 2;
  415. $state_title = "已出库";
  416. }else{
  417. if($p2 > 0){
  418. $state_title = "已退货";
  419. $state = 1;
  420. }else{
  421. $state_title = "未出库";
  422. $state = 0;
  423. }
  424. }
  425. $tmp = $map[$value['product_id']] ?? [];
  426. $return[] = [
  427. 'number' => $number, //可出数量
  428. 'out_number' => $p1, //已出库数量
  429. 'return_number' => $p2, //已退货数量
  430. 'state' => $state,
  431. 'state_title' => $state_title,
  432. 'price' => $value['price'],
  433. 'final_amount' => bcmul($value['price'], $number,2),
  434. 'product_id' => $value['product_id'],
  435. 'title' => $tmp['title'] ?? "",
  436. 'code' => $tmp['code'] ?? "",
  437. 'size' => $tmp['size'] ?? "",
  438. 'unit' => $tmp['unit'] ?? "",
  439. 'purchase_product' => $purchase[$value['product_id']] ?? [],
  440. ];
  441. }
  442. return $return;
  443. }
  444. public function getSalesProduct($data, $user, $storehouse_id = 0){
  445. $return = [];
  446. $data_id = $data['data_id'];
  447. $out_bound_id = $data['out_bound_id'] ?? 0;
  448. $sale = SalesOrder::where('del_time',0)
  449. ->where('id', $data_id)
  450. ->first();
  451. if(empty($sale)) return [false, '合同不存在或已被删除'];
  452. $sale = $sale->toArray();
  453. $top_depart_id = $user['depart_top'][0] ?? [];
  454. $top_depart_id = $top_depart_id['depart_id'] ?? 0;
  455. list($status, $msg) = $this->returnOrderEditErrorCommon($top_depart_id,$sale['top_depart_id']);
  456. if(! $status) return [false, $msg];
  457. $storehouse = Storehouse::where('top_depart_id', $sale['top_depart_id'])->where('del_time',0)->value('id');
  458. if($storehouse_id && $storehouse_id != $storehouse) return [false, '出库仓库错误'];
  459. $product = SalesOrderProductInfo::where('del_time',0)
  460. ->where('sales_order_id', $data_id)
  461. ->select('product_id', 'number', 'final_amount','price')
  462. ->get()->toArray();
  463. $map = (new ProductService())->getProductDetail(array_column($product,'product_id'));
  464. //合同出库产品
  465. $product_map = [];
  466. $save = OutBoundOrderInfo::where('del_time',0)
  467. ->where('type', $data['type'])
  468. ->where('data_id', $data_id)
  469. ->when(! empty($out_bound_id), function ($query) use ($out_bound_id) {
  470. return $query->where('out_bound_id', '<>', $out_bound_id);
  471. })
  472. ->select('product_id', 'number', 'final_amount')
  473. ->get()->toArray();
  474. foreach ($save as $value){
  475. if(isset($product_map[$value['product_id']])){
  476. $number = bcadd($value['number'], $product_map[$value['product_id']]);
  477. $product_map[$value['product_id']] = $number;
  478. }else{
  479. $product_map[$value['product_id']] = $value['number'];
  480. }
  481. }
  482. //合同退货产品
  483. $product_map2 = [];
  484. $return_id = ReturnExchangeOrder::where('del_time',0)
  485. ->where('type', ReturnExchangeOrder::Order_type)
  486. ->where('model_type', ReturnExchangeOrder::Model_type_one)
  487. ->where('data_id', $data_id)
  488. ->select('id')
  489. ->get()->toArray();
  490. $save2 = ReturnExchangeOrderProductInfo::where('del_time',0)
  491. ->whereIn('return_exchange_id', array_column($return_id,'id'))
  492. ->where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
  493. ->select('product_id', 'number', 'final_amount')
  494. ->get()->toArray();
  495. foreach ($save2 as $value){
  496. if(isset($product_map2[$value['product_id']])){
  497. $number = bcadd($value['number'], $product_map2[$value['product_id']]);
  498. $product_map2[$value['product_id']] = $number;
  499. }else{
  500. $product_map2[$value['product_id']] = $value['number'];
  501. }
  502. }
  503. foreach ($product as $value){
  504. $p1 = $product_map[$value['product_id']] ?? 0;
  505. $p2 = $product_map2[$value['product_id']] ?? 0;
  506. $number = bcsub(bcsub($value['number'], $p1), $p2);
  507. if($number <= 0) continue;
  508. $tmp = $map[$value['product_id']] ?? [];
  509. $return[] = [
  510. 'number' => $number,
  511. 'price' => $value['price'],
  512. 'final_amount' => bcmul($value['price'], $number,2),
  513. 'product_id' => $value['product_id'],
  514. 'title' => $tmp['title'] ?? "",
  515. 'code' => $tmp['code'] ?? "",
  516. 'size' => $tmp['size'] ?? "",
  517. 'unit' => $tmp['unit'] ?? "",
  518. ];
  519. }
  520. return [true, $return];
  521. }
  522. public function getSaveDetail($id){
  523. $product_save = [];
  524. if(empty($id)) return $product_save;
  525. $sub = OutBoundOrderInfo::where('out_bound_id',$id)
  526. ->where('del_time',0)
  527. ->get()->toArray();
  528. foreach ($sub as $value){
  529. $key = $value['product_id'] . ',' . $value['storehouse_id'];
  530. if(isset($product_save[$key])){
  531. $product_save[$key] += $value['number'];
  532. }else{
  533. $product_save[$key] = $value['number'];
  534. }
  535. }
  536. return $product_save;
  537. }
  538. public function checkPurchase($id, $data, $user){
  539. //是否校验库存
  540. if($id > 0){
  541. $is_check_stock = OrderInventoryStock::where('order_number', $data['order_number'])
  542. ->where('del_time',0)
  543. ->value('is_check_stock') ?? 0;
  544. }else{
  545. $is_check_stock = $user['is_check_stock'];
  546. }
  547. $purchase_product = [];
  548. foreach ($data['product'] as $value){
  549. $purchase = $value['purchase_product'] ?? [];
  550. if(empty($purchase)) return [false, '出库操作时,请选择出库的产品来源采购单'];
  551. foreach ($purchase as $p_v){
  552. //必须校验的内容
  553. if(empty($p_v['number'])) return [false, '采购单产品数量不能为空'];
  554. $res = $this->checkNumber($p_v['number']);
  555. if(! $res) return [false,'请输入正确的采购单产品数量'];
  556. if(empty($p_v['product_id'])) return [false, '采购单产品ID不能为空'];
  557. if($is_check_stock != ProductInventorySet::type_two){
  558. //库存校验开启时 校验 需要采购单明细子表id
  559. if(! isset($p_v['id'])) return [false, 'ID不能为空'];
  560. if(! empty($p_v['id'])) {
  561. list($status, $msg) = $this->limitingSendRequestBackgExpire("purchaseOrderInfo" . $p_v['id']);
  562. if(! $status) return [false, '采购单产品处于出库操作中,请稍后'];
  563. }
  564. if(! isset($p_v['purchase_order_id'])) return [false, 'purchaseOrderId不能为空'];
  565. if(! isset($p_v['price'])) return [false, '采购单产品单价不能为空'];
  566. if(! isset($p_v['order_number'])) return [false, '采购单单号不能为空'];
  567. }
  568. $purchase_product[$value['product_id']] = [
  569. "product_id" => $value['product_id'],
  570. "total" => $value['number'],
  571. "from" => $purchase,
  572. ];
  573. }
  574. }
  575. if($is_check_stock != ProductInventorySet::type_two){
  576. //库存校验开启时 校验 需要采购单产品数量
  577. list($status, $msg) = (new PurchaseOrderService())->checkPurchaseProductByPurchaseInfoID($id, $purchase_product);
  578. if(! $status) return [false, $msg];
  579. }
  580. //返回产品对应数据
  581. $return = $this->returnProductData($data['product'], $user, $data['storehouse_id']);
  582. return [true, $return];
  583. }
  584. public function returnProductData($product, $user, $storehouse_id){
  585. $top_depart_id = $user['depart_top'][0] ?? [];
  586. $my_top_depart_id = $top_depart_id['id'] ?? 0;
  587. $basic_type_id = $top_depart_id['basic_type_id'] ?? 0;
  588. //产品id
  589. $product_id = array_column($product,'product_id');
  590. //获取产品的采购成本 如果设置了分社价格
  591. $service = new ProductService();
  592. $detail_map = [];
  593. if($basic_type_id) $detail_map = $service->getProductPrice($product_id,1, $basic_type_id);
  594. //产品的成本 如果是 总社或者杭州旗舰店用cost 其它分社用retail_price
  595. $product_array = Product::whereIn('id',$product_id)
  596. ->where('del_time',0)
  597. ->select('id','retail_price','cost')
  598. ->get()->toArray();
  599. $product_map = array_column($product_array,'retail_price','id');
  600. $product_map_2 = array_column($product_array,'cost','id');
  601. //需要所有数据的门店
  602. $setting = Setting::where('setting_name','bt_top_depart_id')->first();
  603. $bt_top_depart_id = $setting['setting_value'] ?? [];
  604. $bt_top_depart_id = json_decode($bt_top_depart_id,true);
  605. //产品使用价格
  606. $product_use = [];
  607. if(! empty($basic_type_id)){
  608. foreach ($detail_map as $key => $value){
  609. if(isset($value[$basic_type_id]) && ! empty($value[$basic_type_id]['price'])) {
  610. $product_use[$key] = $value[$basic_type_id]['price'];
  611. }else{
  612. if(in_array($my_top_depart_id, $bt_top_depart_id)){
  613. $product_use[$key] = $product_map_2[$key];
  614. }else{
  615. $product_use[$key] = $product_map[$key];
  616. }
  617. }
  618. }
  619. }else{
  620. if(in_array($my_top_depart_id, $bt_top_depart_id)){
  621. $product_use = $product_map_2;
  622. }else{
  623. $product_use = $product_map;
  624. }
  625. }
  626. $return = [];
  627. foreach ($product as $value){
  628. $product_id = $value['product_id'];
  629. // $total = $value['number'];
  630. $purchase = $value['purchase_product'] ?? [];
  631. $use_price = $product_use[$product_id] ?? 0;
  632. foreach ($purchase as $p_v){
  633. if(empty($p_v['id']) || empty($p_v['purchase_order_id'])){
  634. $return[] = [
  635. 'purchase_order_id' => 0,
  636. 'purchase_order_info_id' => 0,
  637. 'order_number' => "",
  638. 'product_id' => $p_v['product_id'],
  639. 'number' => $p_v['number'],
  640. 'price' => $use_price,
  641. 'storehouse_id' => $storehouse_id,
  642. 'type' => PurchaseOrderInfoForOutBound::type_one,
  643. 'is_use' => PurchaseOrderInfoForOutBound::is_not_use,
  644. ];
  645. }else{
  646. $return[] = [
  647. 'purchase_order_id' => $p_v['purchase_order_id'],
  648. 'purchase_order_info_id' => $p_v['id'],
  649. 'order_number' => $p_v['order_number'],
  650. 'product_id' => $p_v['product_id'],
  651. 'number' => $p_v['number'],
  652. 'price' => $p_v['price'],
  653. 'storehouse_id' => $storehouse_id,
  654. 'type' => PurchaseOrderInfoForOutBound::type_one,
  655. 'is_use' => PurchaseOrderInfoForOutBound::is_not_use,
  656. ];
  657. }
  658. }
  659. }
  660. return $return;
  661. }
  662. }