CheckService.php 58 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518
  1. <?php
  2. namespace App\Service;
  3. use App\Model\Construction;
  4. use App\Model\ConstructionProductInfo;
  5. use App\Model\Depart;
  6. use App\Model\Employee;
  7. use App\Model\InOutRecord;
  8. use App\Model\InvoiceOrder;
  9. use App\Model\InvoiceOrderInfo;
  10. use App\Model\OrderOperation;
  11. use App\Model\PaymentReceipt;
  12. use App\Model\ProductInventory;
  13. use App\Model\ProductInventorySet;
  14. use App\Model\PurchaseOrder;
  15. use App\Model\PurchaseOrderInfo;
  16. use App\Model\PurchaseOrderSpecial;
  17. use App\Model\PurchaseOrderSpecialInfo;
  18. use App\Model\ReturnExchangeOrder;
  19. use App\Model\ReturnExchangeOrderProductInfo;
  20. use App\Model\SalesOrder;
  21. use App\Model\SalesOrderInfo;
  22. use App\Model\SalesOrderOtherFee;
  23. use App\Model\SalesOrderProductInfo;
  24. use App\Model\SeeRange;
  25. use App\Model\Storehouse;
  26. use App\Model\Supplier;
  27. use App\Service\OaService;
  28. use Illuminate\Support\Facades\DB;
  29. class CheckService extends Service
  30. {
  31. //审批操作对应的数值
  32. const one = 1; //收货
  33. const two = 2; //发货
  34. const three = 3; //采购单入库
  35. const four = 4; //合同公司完结
  36. const five = 5; //施工单
  37. const six = 6; //退换货单
  38. const seven = 7; //采购单确认
  39. const eight = 8; //合同确认
  40. const nine = 9; //合同客户完结
  41. const ten = 10; //收付款确认
  42. const eve = 11; //接受派单
  43. //中文对照
  44. public $map = [
  45. self::one => '收货单',
  46. self::two => '发货单',//确认后出库
  47. self::three => '采购单入库',//确认后入库
  48. self::four => '公司完结', // 安装件 合同完结
  49. self::five => '施工单',//确认后出库
  50. self::six => '退换货单',//确认后出库或出库入库
  51. self::seven => '采购单确认',
  52. self::eight => '合同确认',
  53. self::nine => '合同客户完结',
  54. self::ten => '收付款确认',
  55. self::eve => '接受门店派单',
  56. ];
  57. //入库操作
  58. public static $in_opt = [
  59. self::three,
  60. ];
  61. //出库操作
  62. public static $out_opt = [
  63. self::two,
  64. self::five,
  65. ];
  66. const TYPE_ONE = 1;//通过
  67. const TYPE_TWO = 2;//不通过
  68. const TYPE_THREE = 3;//通过后驳回
  69. //改为待审核状态 校验
  70. public static $opt_1case_check = [
  71. self::five => 'checkConstruction',//施工单
  72. ];
  73. //改为待审核状态
  74. public static $opt_1case = [
  75. self::two => 'waitInvoice',//发货单
  76. // self::three => 'waitPurchase',//采购单 入库
  77. self::five => 'waitConstruction',//施工单
  78. self::six => 'waitReturnExchange',//退换货单
  79. self::seven => 'waitPurchaseConfirm', //采购单确认
  80. self::eight => 'waitSales', // 合同安装件 合同确认
  81. self::ten => 'waitPaymentReceipt', //收付款确认
  82. ];
  83. public static $finished = [
  84. self::three => 'confirmPurchaseOrder',//采购单 入库
  85. self::four => 'settleSalesOrder', // 合同 安装件 合同公司完结
  86. self::nine => 'settleSalesOrderCustomer', // 合同 安装件 合同客户完结
  87. self::eve => 'settleSalesOrderConfirm', // 合同 安装件 合同接收
  88. ];
  89. //单据操作
  90. public static $opt_case = [
  91. self::two => 'confirmInvoiceOrder',
  92. // self::three => 'confirmPurchaseOrder',
  93. self::five => 'confirmConstruction',
  94. self::six => 'confirmReturnExchangeOrder',
  95. self::seven => 'confirmPurchaseOrderState',
  96. self::eight => 'confirmSales', // 合同 安装件 合同确认
  97. self::ten => 'confirmPaymentReceipt', // 确认收付款单
  98. ];
  99. //单据库存流水
  100. public static $record = [
  101. self::two => 'recordInvoiceOrder',
  102. self::three => 'recordPurchaseOrder',
  103. self::five => 'recordConstruction',
  104. self::six => 'recordReturnExchangeOrder'
  105. ];
  106. //自动生成
  107. public static $create = [
  108. self::seven => 'createPurchaseOrderSales', //分社合同生成
  109. self::four => 'createPurchaseOrder', // 派给分社的合同确认以后生成虚拟采购单
  110. ];
  111. //自动生成的删除
  112. public static $create_del = [
  113. self::seven => 'delCreatePurchaseOrderSales', //分社合同生成(删除)
  114. // self::four => 'createPurchaseOrder', // 派给分社的合同确认以后生成虚拟采购单
  115. ];
  116. //审核通过后 驳回
  117. public static $opt_case_reject = [
  118. self::four => 'reject_sales', // 合同
  119. // self::three => 'reject_purchase', //采购入库
  120. self::seven => 'reject_purchase_confirm', //采购确认驳回
  121. self::five => 'reject_construction',//施工单
  122. self::six => 'reject_return_exchange',//退换货
  123. self::ten => 'reject_payment_receipt',//收付款单
  124. ];
  125. //审核通过后 驳回 产生流水
  126. public static $reject_record = [
  127. self::five => 'reject_record_construction', //施工单驳回
  128. self::three => 'reject_record_purchase', //采购
  129. self::six => 'reject_record_return_exchange',//退换货
  130. ];
  131. //旅程日志 同意
  132. public static $operation_order = [
  133. self::eight => OrderOperation::three, //合同确认
  134. self::two => OrderOperation::eight, //发货单确认
  135. self::six => OrderOperation::nine, //退换货审核
  136. self::five => OrderOperation::eve, //施工单
  137. self::seven => OrderOperation::thi,//采购单确认
  138. self::three => OrderOperation::fourteen,//采购单入库
  139. self::ten => OrderOperation::twenty_one,//收付款单
  140. ];
  141. //旅程日志 驳回
  142. public static $operation_order_reject = [
  143. self::four => OrderOperation::four, //合同弃审
  144. self::six => OrderOperation::ten, //退换货弃审
  145. self::five => OrderOperation::twl, //施工单弃审
  146. self::three => OrderOperation::fif,//采购单入库弃审
  147. self::seven => OrderOperation::twenty,//采购单确认弃审
  148. self::ten => OrderOperation::twenty_two,//收付款单
  149. ];
  150. //校验
  151. public function checkConstruction($data, $user){
  152. $order = Construction::where('del_time',0)
  153. ->where('order_number',$data['order_number'])
  154. ->first();
  155. if(empty($order)) return [false,'施工单不存在或已被删除'];
  156. $order = $order->toArray();
  157. //总社id
  158. $head = $user['head'] ?? [];
  159. $head = $head['id'] ?? 0;
  160. //分社自己的施工单 直接返回
  161. if($order['top_depart_id'] != $head) return [true, ''];
  162. //不校验库存
  163. if($user['is_check_stock'] == ProductInventorySet::type_two) return [true,''];
  164. //施工单产品
  165. $sub = ConstructionProductInfo::where('construction_id',$order['id'])
  166. ->where('del_time',0)
  167. ->get()->toArray();
  168. if(empty($sub)) return [false,'施工单产品不存在或已被删除'];
  169. $product_submit = $product_id = [];
  170. foreach ($sub as $value){
  171. $product_id[] = $value['product_id'];
  172. $key = $value['product_id'] . ',' . $value['storehouse_id'];
  173. if(isset($product_save[$key])){
  174. $product_submit[$key] += $value['number'];
  175. }else{
  176. $product_submit[$key] = $value['number'];
  177. }
  178. }
  179. //比较库存
  180. list($status,$msg) = (new ProductInventoryService())->compareStock($user,$product_id, $product_submit, []);
  181. if(! $status) return [false, $msg];
  182. //锁定库存
  183. ProductInventoryService::changeLockNumber($user,$product_submit);
  184. return [true, ''];
  185. }
  186. //改为待审核---------------------------------
  187. public function waitInvoice($data){
  188. $model = InvoiceOrder::where('id',$data['id'])
  189. ->where('del_time',0)
  190. ->first();
  191. if(empty($model)) return [false, '发货单不存在或已被删除'];
  192. if($model->state != InvoiceOrder::STATE_ZERO) return [false, '请确认发货单状态,操作失败'];
  193. InvoiceOrder::where('del_time',0)->where('id',$data['id'])
  194. ->update(['state' => InvoiceOrder::STATE_ONE]);
  195. return [true, $model->toArray()];
  196. }
  197. public function waitPurchaseConfirm($data){
  198. $model = PurchaseOrder::where('id',$data['id'])
  199. ->where('del_time',0)
  200. ->first();
  201. if(empty($model)) return [false,'采购单不存在或已被删除'];
  202. if($model->state != PurchaseOrder::STATE_ZERO) return [false,'请确认采购单状态,操作失败'];
  203. //待确认
  204. PurchaseOrder::where('id',$data['id'])->update(['state' => PurchaseOrder::STATE_ONE]);
  205. return [true, $model->toArray()];
  206. }
  207. public function waitPurchase($data){
  208. $model = PurchaseOrder::where('id',$data['id'])
  209. ->where('del_time',0)
  210. ->first();
  211. if(empty($model)) return [false, '采购订单不存在或已被删除'];
  212. if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购订单状态,操作失败'];
  213. //待入库
  214. PurchaseOrder::where('del_time',0)->where('id',$data['id'])
  215. ->update(['state' => PurchaseOrder::STATE_Three]);
  216. return [true, $model->toArray()];
  217. }
  218. public function waitConstruction($data){
  219. $model = Construction::where('id',$data['id'])
  220. ->where('del_time',0)
  221. ->first();
  222. if(empty($model)) return [false, '施工单不存在或已被删除'];
  223. if($model->state != Construction::STATE_ZERO) return [false, '请确认施工单状态,操作失败'];
  224. //待确认
  225. Construction::where('del_time',0)->where('id',$data['id'])
  226. ->update(['state' => Construction::STATE_ONE]);
  227. return [true, $model->toArray()];
  228. }
  229. public function waitReturnExchange($data){
  230. $model = ReturnExchangeOrder::where('id',$data['id'])
  231. ->where('del_time',0)
  232. ->first();
  233. if(empty($model)) return [false, '退换货单不存在或已被删除'];
  234. if($model->state != ReturnExchangeOrder::State_zero) return [false, '请确认退换货单状态,操作失败'];
  235. //待确认
  236. ReturnExchangeOrder::where('del_time',0)->where('id',$data['id'])
  237. ->update(['state' => ReturnExchangeOrder::State_one]);
  238. return [true, $model->toArray()];
  239. }
  240. public function waitSales($data){
  241. $model = SalesOrder::where('id', $data['id'])
  242. ->where('del_time',0)
  243. ->first();
  244. if(empty($model)) return [false, '合同不存在或已被删除'];
  245. //安装件
  246. if($model->state != SalesOrder::State_zero) return [false, '请确认合同状态,操作失败'];
  247. SalesOrder::where('del_time',0)->where('id',$data['id'])
  248. ->update(['state' => SalesOrder::State_one]);
  249. return [true, $model->toArray()];
  250. }
  251. public function waitPaymentReceipt($data){
  252. $model = PaymentReceipt::where('id', $data['id'])
  253. ->where('del_time',0)
  254. ->first();
  255. if(empty($model)) return [false, '收付款单不存在或已被删除'];
  256. if($model->state != PaymentReceipt::STATE_ZERO) return [false, '请确认收付款单状态,操作失败'];
  257. PaymentReceipt::where('del_time',0)->where('id',$data['id'])
  258. ->update(['state' => PaymentReceipt::STATE_ONE]);
  259. return [true, $model->toArray()];
  260. }
  261. //改为待审核---------------------------------
  262. //自动生成-----------------------------------
  263. //总社派给分社的合同 完成生成虚拟采购单
  264. public function createPurchaseOrder($order,$user){
  265. //快递件
  266. if($order['sales_order_type'] == SalesOrder::Order_type_two) return [true,''];
  267. //不是总公司的合同
  268. $head = $user['head'] ?? [];
  269. $head = $head['id'] ?? 0; //总社id
  270. if($head != $order['top_depart_id']) return [true, ''];
  271. $see = SeeRange::where('del_time',0)
  272. ->where('data_id',$order['id'])
  273. ->where('data_type',SeeRange::type_seven)
  274. ->where('type',SeeRange::data_three)
  275. ->first();
  276. if(empty($see)) return [false, '未找到指派分社信息'];
  277. $depart_id = $see->param_id;//指派的分社
  278. //总社指派给自己
  279. if($depart_id == $head) return [true, ''];
  280. //获取指派分社时候的金额
  281. $fee = SalesOrderOtherFee::where('del_time',0)
  282. ->where('sales_order_id',$order['id'])
  283. ->first();
  284. if(empty($fee)) return [false, '未找到指派分社时填写的金额'];
  285. $fee = $fee->toArray();
  286. $order_number = (new OrderNoService())->createOrderNumber(PurchaseOrderSpecial::prefix);
  287. $storehouse = Storehouse::where('depart_id',$head)->value('id');
  288. $product = SalesOrderProductInfo::where('del_time',0)
  289. ->where('sales_order_id',$order['id'])
  290. ->select('product_id','number','retail_price')
  291. ->get()->toArray();
  292. $product_map = $rate = [];
  293. $total = 0;
  294. foreach ($product as $value){
  295. $total += $value['number'] * $value['retail_price'];
  296. if(isset($product_map[$value['product_id']])){
  297. $product_map[$value['product_id']] += $value['retail_price'] * $value['number'];
  298. }else{
  299. $product_map[$value['product_id']] = $value['retail_price'] * $value['number'];
  300. }
  301. }
  302. foreach ($product_map as $key => $value){
  303. $rate[$key] = sprintf("%.2f", round($value / $total, 2));
  304. }
  305. $model = new PurchaseOrderSpecial();
  306. $model->order_number = $order_number;
  307. $model->sales_order_id = $order['id'];
  308. $model->depart_id = $head;
  309. $model->top_depart_id = $head;
  310. $model->crt_id = Employee::SPECIAL_ADMIN;
  311. $model->purchase_id = Employee::SPECIAL_ADMIN;
  312. $model->purchase_total = $fee['other_fee_1'] ?? 0;
  313. $model->storehouse_id = $storehouse ?? 0;
  314. $model->save();
  315. if(empty($model->id)) return [false,'采购单主信息生成失败'];
  316. $purchase_order_id = $model->id;
  317. $insert = [];$product_total = 0;
  318. foreach ($product as $value){
  319. $rate_tmp = $rate[$value['product_id']] ?? 0;
  320. $price = sprintf("%.2f", round($rate_tmp * $fee['other_fee_1'] / $value['number'], 2));
  321. $product_total += $price * $value['number'];
  322. $insert[] = [
  323. 'purchase_order_special_id' => $purchase_order_id,
  324. 'product_id' => $value['product_id'],
  325. 'order_number' => $order_number,
  326. 'number' => $value['number'],
  327. 'price' => $price,
  328. 'storehouse_id' => $storehouse,
  329. ];
  330. }
  331. PurchaseOrderSpecialInfo::insert($insert);
  332. PurchaseOrderSpecial::where('id',$purchase_order_id)->update(['total' => $product_total]);
  333. return [true, ''];
  334. }
  335. //分社订货合同
  336. public function createPurchaseOrderSales($order,$user){
  337. //没有供应商 不创建合同
  338. if(empty($order['supplier'])) return [true, ''];
  339. //总公司的采购单 不创建合同
  340. $head = $user['head'] ?? [];
  341. $head = $head['id'] ?? 0; //总社id
  342. if($head == $order['top_depart_id']) return [true, ''];
  343. //分社公司的采购单 不向总供应商采购 不创建合同
  344. $is_create = Supplier::where('id',$order['supplier'])->value('is_main');
  345. if(empty($is_create)) return [true, ''];
  346. $prefix = SalesOrder::$prefix[SalesOrder::Model_type_two];
  347. $order_number = OrderNoService::createSalesOrderNumber($prefix);
  348. $product = PurchaseOrderInfo::where('del_time',0)
  349. ->where('purchase_order_id',$order['id'])
  350. ->get()->toArray();
  351. if(empty($product)) return [false, '采购订单产品数据不能为空'];
  352. $time = time();
  353. $model = new SalesOrder();
  354. $model->model_type = SalesOrder::Model_type_two;
  355. $model->sales_order_type = SalesOrder::Order_type_two;
  356. $model->order_number = $order_number;
  357. $model->crt_id = $order['crt_id'];
  358. $model->depart_id = $head;
  359. $model->top_depart_id = $head;
  360. $model->other_fee = $order['other_fee'];
  361. $model->discount_fee = $order['discount_fee'];
  362. $model->contract_fee = $order['purchase_total'];
  363. $model->contact_order_no = $order['order_number'];
  364. $model->sign_time = $time;
  365. $model->save();
  366. $sales_order_id = $model->id;
  367. //产品字典
  368. $product_map = (new ProductService())->getProductDetail(array_column($product,'product_id'));
  369. $insert = [];
  370. $product_total = 0;
  371. foreach ($product as $value){
  372. $tmp = $product_map[$value['product_id']] ?? [];
  373. $product_total += $value['price'] * $value['number'];
  374. $insert[] = [
  375. 'sales_order_id' => $sales_order_id,
  376. 'product_id' => $value['product_id'],
  377. 'number' => $value['number'],
  378. 'basic_type_id' => $value['basic_type_id'],
  379. 'price' => $value['price'],
  380. 'cost' => $tmp['cost'] ?? 0,
  381. 'retail_price' => $tmp['retail_price'] ?? 0,
  382. 'final_amount' => $value['price'] * $value['number'],
  383. ];
  384. }
  385. $bool = SalesOrderProductInfo::insert($insert);
  386. if(! $bool) return [false,'合同生成失败!'];
  387. //反写数据
  388. $tmp = $product_total + $order['other_fee'];
  389. $tmp = $tmp > 0 ? $tmp : 1;
  390. $rate = ($product_total + $order['other_fee'] - $order['discount_fee']) / $tmp;
  391. SalesOrder::where('id',$sales_order_id)->update([
  392. 'product_total' => $product_total,
  393. 'rate' => $rate
  394. ]);
  395. //生成付款单
  396. $model = new PaymentReceipt();
  397. $model->order_number = (new OrderNoService())->createOrderNumber(PaymentReceipt::prefix);
  398. $model->data_order_no = $order_number;
  399. $model->data_type = PaymentReceipt::data_type_one;
  400. $model->type = PaymentReceipt::type_one;
  401. $model->amount = $order['purchase_total'] ?? 0;
  402. $model->crt_id = $user['id'];
  403. $model->depart_id = $head;
  404. $model->top_depart_id = $head;
  405. $model->save();
  406. return [true,''];
  407. }
  408. //自动生成-----------------------------------
  409. //自动生成删除
  410. public function delCreatePurchaseOrderSales($data, $order){
  411. $sale_order = SalesOrder::where('del_time',0)
  412. ->where('contact_order_no',$order['order_number'])
  413. ->select('id','order_number')
  414. ->get()->toArray();
  415. if(empty($sale_order)) return [true,''];
  416. foreach ($sale_order as $value){
  417. list($status, $msg) = (new SalesOrderService())->salesOrderDel(['id' => $value['id']]);
  418. if(! $status) return [false,$msg];
  419. list($status, $msg) = (new PaymentReceiptService())->customerDel(['id' => $value['id']]);
  420. if(! $status) return [false,$msg];
  421. }
  422. return [true, ''];
  423. }
  424. //自动生成删除
  425. public function confirmPaymentReceipt($data){
  426. $model = PaymentReceipt::where('order_number',$data['order_number'])
  427. ->where('del_time',0)
  428. ->first();
  429. if(empty($model)) return [false, '收付款单不存在或已被删除'];
  430. if($model->state != PaymentReceipt::STATE_ONE) return [false, '请确认收付款单状态,操作失败'];
  431. if($data['type'] == self::TYPE_ONE){
  432. //通过
  433. $model->state = PaymentReceipt::STATE_TWO;
  434. $model->save();
  435. }else{
  436. //驳回
  437. $model->state = InvoiceOrder::STATE_ZERO;
  438. $model->save();
  439. }
  440. return [true, $model->toArray()];
  441. }
  442. public function confirmInvoiceOrder($data){
  443. $model = InvoiceOrder::where('order_number',$data['order_number'])
  444. ->where('del_time',0)
  445. ->first();
  446. if(empty($model)) return [false, '发货单不存在或已被删除'];
  447. if($model->state != InvoiceOrder::STATE_ONE) return [false, '请确认发货单状态,操作失败'];
  448. if($data['type'] == self::TYPE_ONE){
  449. //通过
  450. $model->state = InvoiceOrder::STATE_TWO;
  451. $model->save();
  452. $sale = SalesOrder::where('id',$model->sales_order_id)->first();
  453. if($sale['sales_order_type'] == SalesOrder::Order_type_one){
  454. //安装件更新发货状态
  455. SalesOrder::where('id',$model->sales_order_id)
  456. ->update(['invoice_state' => SalesOrder::invoice_one]);
  457. }else{
  458. //快递件更新 单据状态 发货状态
  459. SalesOrder::where('id',$model->sales_order_id)
  460. ->update([
  461. 'state' => SalesOrder::State2_one,
  462. 'invoice_state' => SalesOrder::invoice_one
  463. ]);
  464. }
  465. }else{
  466. //驳回
  467. $model->state = InvoiceOrder::STATE_ZERO;
  468. $model->save();
  469. }
  470. return [true, $model->toArray()];
  471. }
  472. public function recordInvoiceOrder($data, $order){
  473. $result = InvoiceOrderInfo::where('del_time',0)
  474. ->where('order_number',$order['order_number'])
  475. ->get()->toArray();
  476. if(empty($result)) return [false,'发货单产品信息不存在或已被删除'];
  477. $insert = [];
  478. $time = time();
  479. foreach ($result as $value){
  480. $key = $value['product_id'] . $value['storehouse_id'];
  481. if(isset($insert[$key])){
  482. $insert[$key]['number'] += -($value['number']);
  483. }else{
  484. $insert[$key] = [
  485. 'product_id' => $value['product_id'],
  486. 'number' => -($value['number']),
  487. 'order_type' => InvoiceOrder::prefix,
  488. 'order_number' => $order['order_number'],
  489. 'crt_time' => $time,
  490. 'storehouse_id' => $value['storehouse_id'],
  491. 'depart_id' => $order['depart_id'],
  492. 'top_depart_id' => $order['top_depart_id'],
  493. ];
  494. }
  495. }
  496. $insert = array_values($insert);
  497. $bool = InOutRecord::insert($insert);
  498. if(! $bool) return [false,'流水写入失败'];
  499. return [true,''];
  500. }
  501. public function confirmPurchaseOrderState($data){
  502. $model = PurchaseOrder::where('order_number',$data['order_number'])
  503. ->where('del_time',0)
  504. ->first();
  505. if(empty($model)) return [false,'采购单不存在或已被删除'];
  506. if($model->state != PurchaseOrder::STATE_ONE) return [false,'请确认采购单状态,操作失败'];
  507. if($data['type'] == self::TYPE_ONE){
  508. $model->state = PurchaseOrder::STATE_TWO;
  509. $model->save();
  510. }else{
  511. $model->state = PurchaseOrder::STATE_ZERO;
  512. $model->save();
  513. }
  514. return [true, $model->toArray()];
  515. }
  516. public function confirmPurchaseOrder($data,$user){
  517. $model = PurchaseOrder::where('order_number',$data['order_number'])
  518. ->where('del_time',0)
  519. ->first();
  520. if(empty($model)) return [false, '采购订单不存在或已被删除'];
  521. if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购订单状态,操作失败'];
  522. $model->state = PurchaseOrder::STATE_Four;
  523. $model->save();
  524. return [true, $model->toArray()];
  525. }
  526. public function recordPurchaseOrder($data, $order){
  527. $result = PurchaseOrderInfo::where('del_time',0)
  528. ->where('order_number',$order['order_number'])
  529. ->get()->toArray();
  530. if(empty($result)) return [false,'采购单产品信息不存在或已被删除'];
  531. $insert = [];
  532. $time = time();
  533. foreach ($result as $value){
  534. $key = $value['product_id'] . $value['storehouse_id'];
  535. if(isset($insert[$key])){
  536. $insert[$key]['number'] += $value['number'];
  537. }else{
  538. $insert[$key] = [
  539. 'product_id' => $value['product_id'],
  540. 'number' => $value['number'],
  541. 'order_type' => PurchaseOrder::prefix,
  542. 'order_number' => $order['order_number'],
  543. 'crt_time' => $time,
  544. 'storehouse_id' => $value['storehouse_id'],
  545. 'depart_id' => $order['depart_id'],
  546. 'top_depart_id' => $order['top_depart_id'],
  547. ];
  548. }
  549. }
  550. $insert = array_values($insert);
  551. $bool = InOutRecord::insert($insert);
  552. if(! $bool) return [false,'流水写入失败'];
  553. return [true,''];
  554. }
  555. public function confirmConstruction($data){
  556. $model = Construction::where('order_number',$data['order_number'])
  557. ->where('del_time',0)
  558. ->first();
  559. if(empty($model)) return [false, '施工单不存在或已被删除'];
  560. if($model->state != Construction::STATE_ONE) return [false, '请确认施工单状态,操作失败'];
  561. if($data['type'] == self::TYPE_ONE){
  562. $model->state = Construction::STATE_TWO;
  563. $model->save();
  564. //已下施工
  565. SalesOrder::where('id',$model->sales_order_id)->update(['state' => SalesOrder::State_five]);
  566. }else{
  567. $model->state = Construction::STATE_ZERO;
  568. $model->save();
  569. }
  570. return [true, $model->toArray()];
  571. }
  572. public function recordConstruction($data, $order){
  573. $result = ConstructionProductInfo::where('del_time',0)
  574. ->where('construction_id',$order['id'])
  575. ->get()->toArray();
  576. if(empty($result)) return [false,'施工单产品信息不存在或已被删除'];
  577. $insert = [];
  578. $time = time();
  579. foreach ($result as $value){
  580. $key = $value['product_id'] . $value['storehouse_id'];
  581. if(isset($insert[$key])){
  582. $insert[$key]['number'] += -($value['number']);
  583. }else{
  584. $insert[$key] = [
  585. 'product_id' => $value['product_id'],
  586. 'number' => -($value['number']),
  587. 'order_type' => Construction::$prefix[$order['model_type']] ?? '',
  588. 'order_number' => $order['order_number'],
  589. 'crt_time' => $time,
  590. 'storehouse_id' => $value['storehouse_id'],
  591. 'depart_id' => $order['depart_id'],
  592. 'top_depart_id' => $order['top_depart_id'],
  593. ];
  594. }
  595. }
  596. $insert = array_values($insert);
  597. $bool = InOutRecord::insert($insert);
  598. if(! $bool) return [false,'流水写入失败'];
  599. return [true,''];
  600. }
  601. public function confirmReturnExchangeOrder($data){
  602. $model = ReturnExchangeOrder::where('order_number',$data['order_number'])
  603. ->where('del_time',0)
  604. ->first();
  605. if(empty($model)) return [false, '退换货单不存在或已被删除'];
  606. if($model->state != ReturnExchangeOrder::State_one) return [false, '请确认退换货单状态,操作失败'];
  607. if($data['type'] == self::TYPE_ONE){
  608. $model->state = ReturnExchangeOrder::State_two;
  609. $model->save();
  610. // if($model->data_type == ReturnExchangeOrder::Order_type){
  611. // SalesOrder::where('id', $model->data_id)->update([
  612. // 'state' => SalesOrder::State_six
  613. // ]);
  614. // }
  615. }else{
  616. $model->state = ReturnExchangeOrder::State_zero;
  617. $model->save();
  618. }
  619. return [true, $model->toArray()];
  620. }
  621. public function recordReturnExchangeOrder($data, $order){
  622. $result = ReturnExchangeOrderProductInfo::where('del_time',0)
  623. ->where('return_exchange_id',$order['id'])
  624. ->get()->toArray();
  625. if(empty($result)) return [false,'退换货单产品信息不存在或已被删除'];
  626. $insert = $insert2 = [];
  627. $time = time();
  628. foreach ($result as $value){
  629. $key = $value['product_id'] . $value['storehouse_id'];
  630. $prefix = ReturnExchangeOrder::$prefix[$value['return_or_exchange']] ?? '';
  631. if($value['return_or_exchange'] == ReturnExchangeOrderProductInfo::type_one){
  632. //退货
  633. if(isset($insert[$key])){
  634. $insert[$key]['number'] += $value['number'];
  635. }else{
  636. $insert[$key] = [
  637. 'product_id' => $value['product_id'],
  638. 'number' => $value['number'],
  639. 'order_type' => $prefix,
  640. 'order_number' => $order['order_number'],
  641. 'crt_time' => $time,
  642. 'storehouse_id' => $value['storehouse_id'],
  643. 'depart_id' => $order['depart_id'],
  644. 'top_depart_id' => $order['top_depart_id'],
  645. ];
  646. }
  647. }else{
  648. //换货
  649. if(isset($insert2[$key])){
  650. $insert2[$key]['number'] += -($value['number']);
  651. }else{
  652. $insert2[$key] = [
  653. 'product_id' => $value['product_id'],
  654. 'number' => -($value['number']),
  655. 'order_type' => $prefix,
  656. 'order_number' => $order['order_number'],
  657. 'crt_time' => $time,
  658. 'storehouse_id' => $value['storehouse_id'],
  659. 'depart_id' => $order['depart_id'],
  660. 'top_depart_id' => $order['top_depart_id'],
  661. ];
  662. }
  663. }
  664. }
  665. $insert = array_values($insert);
  666. $bool = InOutRecord::insert($insert);
  667. if(! $bool) return [false,'流水写入失败'];
  668. if(! empty($insert2)) {
  669. $insert2 = array_values($insert2);
  670. $bool = InOutRecord::insert($insert2);
  671. if(! $bool) return [false,'流水写入失败'];
  672. }
  673. return [true,''];
  674. }
  675. public function settleSalesOrder($data,$user){
  676. $model = SalesOrder::where('order_number', $data['order_number'])
  677. ->where('del_time',0)
  678. ->first();
  679. if(empty($model)) return [false, '合同不存在或已被删除'];
  680. //安装件
  681. if($model->state <= SalesOrder::State_four || $model->state >= SalesOrder::State_seven) return [false, '请确认合同状态,操作失败'];
  682. SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])
  683. ->update(['state' => SalesOrder::State_seven]);
  684. return [true, $model->toArray()];
  685. }
  686. public function settleSalesOrderCustomer($data,$user){
  687. $model = SalesOrder::where('order_number', $data['order_number'])
  688. ->where('del_time',0)
  689. ->first();
  690. if(empty($model)) return [false, '合同不存在或已被删除'];
  691. if(empty($data['img'])) return [false,'图片不能为空'];
  692. //安装件
  693. if($model->state != SalesOrder::State_seven) return [false, '请确认合同状态,操作失败'];
  694. SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])
  695. ->update(['state' => SalesOrder::State_eight]);
  696. SalesOrderInfo::insert([
  697. 'sales_order_id' => $model->id,
  698. 'type' => SalesOrderInfo::type_six,
  699. 'file' => $data['img'],
  700. 'crt_time' => time(),
  701. ]);
  702. return [true, $model->toArray()];
  703. }
  704. public function settleSalesOrderConfirm($data,$user){
  705. $model = SalesOrder::where('order_number', $data['order_number'])
  706. ->where('del_time',0)
  707. ->first();
  708. if(empty($model)) return [false, '合同不存在或已被删除'];
  709. //安装件
  710. if($model->state != SalesOrder::State_four) return [false, '请确认合同状态,操作失败'];
  711. $model->is_confirm = 1;
  712. $model->save();
  713. $emp_name = Employee::where('id',$user['id'])->value('emp_name');
  714. $tmp_data = [
  715. $model->order_number,
  716. "合同",
  717. "接收派单",
  718. $emp_name,
  719. date('Y-m-d H:i:s'),
  720. ];
  721. if(! empty($model->dispatch_time_second_id)) (new OaService())->sendWxMsg($model->dispatch_time_second_id,2,0,37,$tmp_data);
  722. return [true, $model->toArray()];
  723. }
  724. public function confirmSales($data){
  725. $model = SalesOrder::where('order_number', $data['order_number'])
  726. ->where('del_time',0)
  727. ->first();
  728. if(empty($model)) return [false, '合同不存在或已被删除'];
  729. if($model->state != SalesOrder::State_one) return [false, '请确认合同状态,操作失败'];
  730. if($data['type'] == self::TYPE_ONE){
  731. $state = SalesOrder::State_three;
  732. if($model->model_type == SalesOrder::Model_type_four){
  733. //线上订单
  734. $state = SalesOrder::State_two;
  735. }
  736. $model->state = $state;
  737. $model->save();
  738. }else{
  739. $model->state = SalesOrder::State_zero;
  740. $model->save();
  741. }
  742. return [true, $model->toArray()];
  743. }
  744. public function reject_sales($data){
  745. $model = SalesOrder::where('order_number', $data['order_number'])
  746. ->where('del_time',0)
  747. ->first();
  748. if(empty($model)) return [false, '合同不存在或已被删除'];
  749. //安装件
  750. if($model->model_type == SalesOrder::Model_type_four){
  751. //线上订单
  752. if($model->state != SalesOrder::State_two) return [false, '请确认合同状态,操作失败'];
  753. }else{
  754. //除线上订单之外
  755. if($model->state != SalesOrder::State_three) return [false, '请确认合同状态,操作失败'];
  756. }
  757. //未确认
  758. $model->state = SalesOrder::State_zero;
  759. $model->save();
  760. return [true, $model->toArray()];
  761. }
  762. public function reject_purchase($data){
  763. $model = PurchaseOrder::where('order_number', $data['order_number'])
  764. ->where('del_time',0)
  765. ->first();
  766. if(empty($model)) return [false, '采购单不存在或已被删除'];
  767. //安装件
  768. if($model->state != PurchaseOrder::STATE_Four) return [false, '请确认采购单状态,操作失败'];
  769. $model->state = PurchaseOrder::STATE_TWO;
  770. $model->save();
  771. return [true, $model->toArray()];
  772. }
  773. public function reject_purchase_confirm($data){
  774. $model = PurchaseOrder::where('order_number', $data['order_number'])
  775. ->where('del_time',0)
  776. ->first();
  777. if(empty($model)) return [false, '采购单不存在或已被删除'];
  778. //安装件
  779. if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购单状态,操作失败'];
  780. $model->state = PurchaseOrder::STATE_ZERO;
  781. $model->save();
  782. return [true, $model->toArray()];
  783. }
  784. public function reject_construction($data){
  785. $model = Construction::where('order_number', $data['order_number'])
  786. ->where('del_time',0)
  787. ->first();
  788. if(empty($model)) return [false, '施工单不存在或已被删除'];
  789. //安装件
  790. if($model->state != Construction::STATE_TWO) return [false, '请确认施工单状态,操作失败'];
  791. $model->state = Construction::STATE_ZERO;
  792. $model->save();
  793. return [true, $model->toArray()];
  794. }
  795. public function reject_payment_receipt($data){
  796. $model = PaymentReceipt::where('order_number', $data['order_number'])
  797. ->where('del_time',0)
  798. ->first();
  799. if(empty($model)) return [false, '收付款单不存在或已被删除'];
  800. if($model->state != PaymentReceipt::STATE_TWO) return [false, '请确认收付款单状态,操作失败'];
  801. $model->state = PaymentReceipt::STATE_ZERO;
  802. $model->save();
  803. return [true, $model->toArray()];
  804. }
  805. public function reject_return_exchange($data){
  806. $model = ReturnExchangeOrder::where('order_number', $data['order_number'])
  807. ->where('del_time',0)
  808. ->first();
  809. if(empty($model)) return [false, '退换货单不存在或已被删除'];
  810. if($model->state != ReturnExchangeOrder::State_two) return [false, '请确认退换货单状态,操作失败'];
  811. $model->state = ReturnExchangeOrder::State_zero;
  812. $model->save();
  813. return [true, $model->toArray()];
  814. }
  815. public function reject_record_construction($data,$order){
  816. //获取单据最新数据时间 正常施工数据
  817. $latest = InOutRecord::where('del_time',0)
  818. ->where('order_number',$data['order_number'])
  819. ->where('number','<',0)
  820. ->select('crt_time')
  821. ->orderBy('crt_time', 'desc')
  822. ->first();
  823. $latest = $latest->toArray();
  824. $result = InOutRecord::where('del_time',0)
  825. ->where('crt_time',$latest['crt_time'])
  826. ->where('order_number',$data['order_number'])
  827. ->where('number','<',0)
  828. ->select('product_id','storehouse_id','number','depart_id','order_number','top_depart_id','order_type')
  829. ->get()->toArray();
  830. if(empty($result)) return [false,'施工出库流水数据未找到'];
  831. //生成对冲数据
  832. $time = time();
  833. foreach ($result as $key => $value){
  834. $result[$key]['number'] = abs($value['number']);
  835. $result[$key]['crt_time'] = $time;
  836. }
  837. $bool = InOutRecord::insert($result);
  838. if(! $bool) return [false,'流水写入失败'];
  839. //写入流水
  840. return [true, ''];
  841. }
  842. public function reject_record_purchase($data,$order){
  843. //获取单据最新数据时间 正常采购入库数据
  844. $latest = InOutRecord::where('del_time',0)
  845. ->where('order_number',$data['order_number'])
  846. ->where('number','>',0)
  847. ->select('crt_time')
  848. ->orderBy('crt_time', 'desc')
  849. ->first();
  850. $latest = $latest->toArray();
  851. $result = InOutRecord::where('del_time',0)
  852. ->where('crt_time',$latest['crt_time'])
  853. ->where('order_number',$data['order_number'])
  854. ->where('number','>',0)
  855. ->select('product_id','storehouse_id','number','depart_id','order_number','top_depart_id','order_type')
  856. ->get()->toArray();
  857. if(empty($result)) return [false,'采购入库流水数据未找到'];
  858. //生成对冲数据
  859. $time = time();
  860. foreach ($result as $key => $value){
  861. $result[$key]['number'] = - $value['number'];
  862. $result[$key]['crt_time'] = $time;
  863. }
  864. $bool = InOutRecord::insert($result);
  865. if(! $bool) return [false,'流水写入失败'];
  866. //写入流水
  867. return [true, ''];
  868. }
  869. public function reject_record_return_exchange($data,$order){
  870. $result = ReturnExchangeOrderProductInfo::where('del_time',0)
  871. ->where('return_exchange_id',$order['id'])
  872. ->get()->toArray();
  873. if(empty($result)) return [false,'退换货单产品信息不存在或已被删除'];
  874. $insert = $insert2 = [];
  875. $time = time();
  876. foreach ($result as $value){
  877. $key = $value['product_id'] . $value['storehouse_id'];
  878. $prefix = ReturnExchangeOrder::$prefix[$value['return_or_exchange']] ?? '';
  879. if($value['return_or_exchange'] == ReturnExchangeOrderProductInfo::type_one){
  880. //退货 扣出
  881. if(isset($insert[$key])){
  882. $insert[$key]['number'] += -($value['number']);
  883. }else{
  884. $insert[$key] = [
  885. 'product_id' => $value['product_id'],
  886. 'number' => -($value['number']),
  887. 'order_type' => $prefix,
  888. 'order_number' => $order['order_number'],
  889. 'crt_time' => $time,
  890. 'storehouse_id' => $value['storehouse_id'],
  891. 'depart_id' => $order['depart_id'],
  892. 'top_depart_id' => $order['top_depart_id'],
  893. ];
  894. }
  895. }else{
  896. //换货 加回
  897. if(isset($insert2[$key])){
  898. $insert2[$key]['number'] += $value['number'];
  899. }else{
  900. $insert2[$key] = [
  901. 'product_id' => $value['product_id'],
  902. 'number' => $value['number'],
  903. 'order_type' => $prefix,
  904. 'order_number' => $order['order_number'],
  905. 'crt_time' => $time,
  906. 'storehouse_id' => $value['storehouse_id'],
  907. 'depart_id' => $order['depart_id'],
  908. 'top_depart_id' => $order['top_depart_id'],
  909. ];
  910. }
  911. }
  912. }
  913. $insert = array_values($insert);
  914. $bool = InOutRecord::insert($insert);
  915. if(! $bool) return [false,'流水写入失败'];
  916. if(! empty($insert2)) {
  917. $insert2 = array_values($insert2);
  918. $bool = InOutRecord::insert($insert2);
  919. if(! $bool) return [false,'流水写入失败'];
  920. }
  921. return [true,''];
  922. }
  923. public function getOrderDetail($data,$user){
  924. if(empty($data['order_number'])) return [false,'必传参数不能为空'];
  925. $array = [];
  926. foreach (Construction::$prefix as $value){
  927. $array[$value] = "\App\Service\\ConstructionService";
  928. }
  929. foreach (ReturnExchangeOrder::$prefix as $value){
  930. $array[$value] = "\App\Service\\ReturnExchangeOrderService";
  931. }
  932. foreach (SalesOrder::$prefix as $value){
  933. $array[$value] = "\App\Service\\SalesOrderService";
  934. }
  935. $status = true;
  936. $msg = [];
  937. foreach ($array as $key => $value){
  938. if(strpos($data['order_number'],$key) !== false) {
  939. list($status, $msg) = (new $value)->detail($data);
  940. return [$status, $msg];
  941. }
  942. }
  943. if(strpos($data['order_number'],PurchaseOrder::prefix) !== false){
  944. $service = "\App\Service\\PurchaseOrderService";
  945. list($status, $msg) = (new $service)->detail($data,$user);
  946. return [$status, $msg];
  947. }
  948. return [$status, $msg];
  949. }
  950. public function checkAll($data,$user){
  951. if(empty($data['id']) || empty($data['order_number'])|| empty($data['opt_case'])) return [false,'必传参数不能为空或者参数值错误!'];
  952. list($status,$msg) = $this->limitingSendRequestBackgExpire($data['order_number'].$data['opt_case']);
  953. if(! $status) return [false,$msg];
  954. //走审批流 单据校验
  955. $function_check = self::$opt_1case_check[$data['opt_case']] ?? '';
  956. //走审批流 单据状态改为待审批方法
  957. $function = self::$opt_1case[$data['opt_case']] ?? '';
  958. //单据不走审批流
  959. $function2 = self::$finished[$data['opt_case']] ?? '';
  960. try{
  961. DB::beginTransaction();
  962. //不走审批流,更新完直接返回
  963. if($function2) {
  964. list($bool,$msg) = $this->$function2($data,$user);
  965. if($bool) {
  966. $order = $msg;
  967. list($bool,$err) = $this->createRecordAndInventoryMy($data,$user,$order);
  968. if($bool){
  969. DB::commit();
  970. return [true, ''];
  971. }else{
  972. DB::rollBack();
  973. return [false, $err];
  974. }
  975. }else{
  976. DB::rollBack();
  977. return [false, $msg];
  978. }
  979. }
  980. //需要审批流,校验
  981. if($function_check){
  982. list($bool,$msg) = $this->$function_check($data, $user);
  983. if(! $bool){
  984. DB::rollBack();
  985. return [false, $msg];
  986. }
  987. }
  988. //需要审批流,从未审核变成待审核
  989. if($function){
  990. list($bool,$msg) = $this->$function($data);
  991. if(! $bool){
  992. DB::rollBack();
  993. return [false, $msg];
  994. }
  995. //创建审批流
  996. $args = [
  997. 'order_no' => $data['order_number'],
  998. 'menu_id' => $data['menu_id'] ?? 0,
  999. 'opt_case' => $data['opt_case'],
  1000. 'order' => $msg,
  1001. ];
  1002. $oa = new OaService($user);
  1003. list($bool,$msg) = $oa->createOaOrder($args);
  1004. if(! $bool) {
  1005. DB::rollBack();
  1006. if($msg) return [false,$msg];
  1007. }
  1008. }
  1009. DB::commit();
  1010. return [true, ''];
  1011. }catch (\Throwable $exception){
  1012. DB::rollBack();
  1013. return [false, $exception->getMessage() . $exception->getFile(). $exception->getLine()];
  1014. }
  1015. }
  1016. //更新库存
  1017. public function changeInventory($data,$order,$user){
  1018. $number_symbol = "";
  1019. if(in_array($data['opt_case'],self::$in_opt)){
  1020. $number_symbol = ">";
  1021. }elseif (in_array($data['opt_case'],self::$out_opt)){
  1022. $number_symbol = "<";
  1023. }
  1024. //获取单据最新数据时间 正常审核的数据
  1025. $latest = InOutRecord::where('del_time',0)
  1026. ->where('order_number',$order['order_number'])
  1027. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1028. return $query->where('number', $number_symbol,0);
  1029. })
  1030. ->select('crt_time')
  1031. ->orderBy('crt_time', 'desc')
  1032. ->first();
  1033. $model = InOutRecord::where('del_time',0)
  1034. ->where('order_number',$order['order_number'])
  1035. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1036. return $query->where('number', $number_symbol,0);
  1037. })
  1038. ->select('number','crt_time','product_id','storehouse_id','top_depart_id');
  1039. if(! empty($latest)) {
  1040. $t = $latest->toArray();
  1041. $model->where('crt_time',$t['crt_time']);
  1042. }
  1043. $record = $model->get()->toArray();
  1044. if (empty($record)) return [false,'流水记录不存在'];
  1045. $top_depart_id = Storehouse::where('id', $order['storehouse_id'])->value('top_depart_id');
  1046. $result = $lock_number = [];
  1047. foreach ($record as $value){
  1048. $key = $value['product_id'] . $value['storehouse_id'];
  1049. if(isset($result[$key])){
  1050. $result[$key]['number'] += $value['number'];
  1051. }else{
  1052. $result[$key] = [
  1053. 'product_id' => $value['product_id'],
  1054. 'number' => $value['number'],
  1055. 'crt_time' => $value['crt_time'],
  1056. 'storehouse_id' => $value['storehouse_id'],
  1057. 'top_depart_id' => $top_depart_id,
  1058. ];
  1059. }
  1060. if($value['number'] < 0){
  1061. if(isset($lock_number[$key])){
  1062. $lock_number[$key] += $value['number'];
  1063. }else{
  1064. $lock_number[$key] = $value['number'];
  1065. }
  1066. }
  1067. }
  1068. //是否校验库存 是的话锁定数量要更新(根据当前操作人所在门店是否校验库存)
  1069. $lock = $user['is_check_stock'];
  1070. $result = array_values($result);
  1071. foreach ($result as $key => $value){
  1072. $keys = $value['product_id'] . $value['storehouse_id'];
  1073. $m = ProductInventory::where('product_id',$value['product_id'])
  1074. ->where('storehouse_id',$value['storehouse_id'])
  1075. ->select('product_id','number','storehouse_id')
  1076. ->first();
  1077. if(empty($m)){
  1078. ProductInventory::insert($result[$key]);
  1079. }else{
  1080. //锁定数量
  1081. $lock_number_tmp = 0;
  1082. if($lock && ! empty($lock_number[$keys])) $lock_number_tmp = $lock_number[$keys];
  1083. ProductInventory::where('product_id',$m->product_id)
  1084. ->where('storehouse_id',$m->storehouse_id)
  1085. ->lockForUpdate()
  1086. ->update([
  1087. 'number' => DB::raw('number + ('. $value['number'] . ')'),
  1088. 'lock_number' => DB::raw('lock_number + ('. $lock_number_tmp . ')')
  1089. ]);
  1090. }
  1091. }
  1092. return [true,''];
  1093. }
  1094. //业务单据审批通过后 驳回 更新库存
  1095. public function changeInventoryReject($data,$order,$user){
  1096. $number_symbol = "";
  1097. if(in_array($data['opt_case'],self::$in_opt)){
  1098. $number_symbol = "<";
  1099. }elseif (in_array($data['opt_case'],self::$out_opt)){
  1100. $number_symbol = ">";
  1101. }
  1102. //获取单据最新数据时间 正常审核的数据
  1103. $latest = InOutRecord::where('del_time',0)
  1104. ->where('order_number',$order['order_number'])
  1105. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1106. return $query->where('number', $number_symbol,0);
  1107. })
  1108. ->select('crt_time')
  1109. ->orderBy('crt_time', 'desc')
  1110. ->first();
  1111. $model = InOutRecord::where('del_time',0)
  1112. ->where('order_number',$order['order_number'])
  1113. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1114. return $query->where('number', $number_symbol,0);
  1115. })
  1116. ->select('number','crt_time','product_id','storehouse_id','top_depart_id');
  1117. if(! empty($latest)) {
  1118. $t = $latest->toArray();
  1119. $model->where('crt_time',$t['crt_time']);
  1120. }
  1121. $record = $model->get()->toArray();
  1122. if (empty($record)) return [false,'流水记录不存在'];
  1123. $top_depart_id = Storehouse::where('id', $order['storehouse_id'])->value('top_depart_id');
  1124. $result = $lock_number = [];
  1125. foreach ($record as $value){
  1126. $key = $value['product_id'] . $value['storehouse_id'];
  1127. if(isset($result[$key])){
  1128. $result[$key]['number'] += $value['number'];
  1129. }else{
  1130. $result[$key] = [
  1131. 'product_id' => $value['product_id'],
  1132. 'number' => $value['number'],
  1133. 'crt_time' => $value['crt_time'],
  1134. 'storehouse_id' => $value['storehouse_id'],
  1135. 'top_depart_id' => $top_depart_id,
  1136. ];
  1137. }
  1138. if($value['number'] > 0){
  1139. if(isset($lock_number[$key])){
  1140. $lock_number[$key] += $value['number'];
  1141. }else{
  1142. $lock_number[$key] = $value['number'];
  1143. }
  1144. }
  1145. }
  1146. //是否校验库存 是的话锁定数量要更新(根据当前操作人所在门店是否校验库存)
  1147. $lock = $user['is_check_stock'];
  1148. $result = array_values($result);
  1149. foreach ($result as $key => $value){
  1150. $keys = $value['product_id'] . $value['storehouse_id'];
  1151. $m = ProductInventory::where('product_id',$value['product_id'])
  1152. ->where('storehouse_id',$value['storehouse_id'])
  1153. ->select('product_id','number','storehouse_id')
  1154. ->first();
  1155. if(empty($m)){
  1156. ProductInventory::insert($result[$key]);
  1157. }else{
  1158. //锁定数量
  1159. $lock_number_tmp = 0;
  1160. if($lock && ! empty($lock_number[$keys])) $lock_number_tmp = $lock_number[$keys];
  1161. ProductInventory::where('product_id',$m->product_id)
  1162. ->where('storehouse_id',$m->storehouse_id)
  1163. ->lockForUpdate()
  1164. ->update([
  1165. 'number' => DB::raw('number + ('. $value['number'] . ')'),
  1166. 'lock_number' => DB::raw('lock_number + ('. $lock_number_tmp . ')')
  1167. ]);
  1168. }
  1169. }
  1170. return [true,''];
  1171. }
  1172. public function createRecordAndInventory($data = []){
  1173. if(empty($data['type']) || empty($data['opt_case']) || empty($data['order_number'])) return [false, '传递参数缺少'];
  1174. $user = $data['user_data'] ?? [];
  1175. if($data['type'] == self::TYPE_THREE){
  1176. //通过后弃审
  1177. if(! isset(self::$opt_case_reject[$data['opt_case']])) return [false, '该操作不存在'];
  1178. //具体方法
  1179. $function = self::$opt_case_reject[$data['opt_case']];
  1180. //流水
  1181. $function2 = self::$reject_record[$data['opt_case']] ?? '';
  1182. //自动生成删除
  1183. $function3 = self::$create_del[$data['opt_case']] ?? '';
  1184. try{
  1185. DB::beginTransaction();
  1186. //更新单据的状态
  1187. list($bool,$msg) = $this->$function($data);
  1188. if(! $bool){
  1189. DB::rollBack();
  1190. return [false, $msg];
  1191. }
  1192. $order = $msg;
  1193. if($function3){
  1194. list($boolean,$msg) = $this->$function3($data,$order);
  1195. if(! $boolean) {
  1196. DB::rollBack();
  1197. return [false, $msg];
  1198. }
  1199. }
  1200. if($function2) {
  1201. //流水
  1202. list($boolean,$msg) = $this->$function2($data,$order);
  1203. if(! $boolean) {
  1204. DB::rollBack();
  1205. return [false, $msg];
  1206. }
  1207. //库存
  1208. list($bool,$msg) = $this->changeInventoryReject($data,$order,$user);
  1209. if(! $bool){
  1210. DB::rollBack();
  1211. return [false, $msg];
  1212. }
  1213. }
  1214. if(! empty(self::$operation_order_reject[$data['opt_case']])){
  1215. $type = self::$operation_order_reject[$data['opt_case']];
  1216. (new OrderOperationService())->add([
  1217. 'order_number' => $order['order_number'],
  1218. 'msg' => OrderOperation::$type[$type],
  1219. 'type' => $type
  1220. ],$user);
  1221. }
  1222. DB::commit();
  1223. return [true, ''];
  1224. }catch (\Throwable $exception){
  1225. DB::rollBack();
  1226. return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];
  1227. }
  1228. }else{
  1229. //具体方法
  1230. $function = self::$opt_case[$data['opt_case']] ?? "";
  1231. $record = self::$record[$data['opt_case']] ?? "";
  1232. $create = self::$create[$data['opt_case']] ?? "";
  1233. try{
  1234. DB::beginTransaction();
  1235. list($bool,$msg) = $this->$function($data);
  1236. if(! $bool){
  1237. DB::rollBack();
  1238. return [false, $msg];
  1239. }
  1240. $order = $msg;
  1241. if($data['type'] == self::TYPE_ONE){
  1242. if($record) {
  1243. //流水
  1244. $bool = $this->$record($data, $order);
  1245. if(! $bool) {
  1246. DB::rollBack();
  1247. return [false, $msg];
  1248. }
  1249. //库存
  1250. $bool = $this->changeInventory($data, $order, $user);
  1251. if(! $bool) {
  1252. DB::rollBack();
  1253. return [false, $msg];
  1254. }
  1255. }
  1256. if($create) {
  1257. $bool = $this->$create($order,$user);
  1258. if(! $bool) {
  1259. DB::rollBack();
  1260. return [false, $msg];
  1261. }
  1262. }
  1263. }
  1264. if(! empty(self::$operation_order[$data['opt_case']])){
  1265. $user = $data['user_data'] ?? [];
  1266. $type = self::$operation_order[$data['opt_case']];
  1267. (new OrderOperationService())->add([
  1268. 'order_number' => $order['order_number'],
  1269. 'msg' => OrderOperation::$type[$type],
  1270. 'type' => $type
  1271. ],$user);
  1272. }
  1273. DB::commit();
  1274. return [true, ''];
  1275. }catch (\Throwable $exception){
  1276. DB::rollBack();
  1277. return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];
  1278. }
  1279. }
  1280. }
  1281. //不需要走审批流 直接调用
  1282. public function createRecordAndInventoryMy($data = [],$user = [],$order = []){
  1283. if(! empty($data['type']) && $data['type'] == self::TYPE_THREE){
  1284. }else{
  1285. //具体方法
  1286. $record = self::$record[$data['opt_case']] ?? "";
  1287. try{
  1288. DB::beginTransaction();
  1289. if($record) {
  1290. //流水
  1291. list($bool,$msg) = $this->$record($data, $order);
  1292. if(! $bool) {
  1293. DB::rollBack();
  1294. return [false, $msg];
  1295. }
  1296. //库存
  1297. list($bool,$msg) = $this->changeInventory($data, $order, $user);
  1298. if(! $bool) {
  1299. DB::rollBack();
  1300. return [false, $msg];
  1301. }
  1302. }
  1303. if(! empty(self::$operation_order[$data['opt_case']])){
  1304. $type = self::$operation_order[$data['opt_case']];
  1305. (new OrderOperationService())->add([
  1306. 'order_number' => $order['order_number'],
  1307. 'msg' => OrderOperation::$type[$type],
  1308. 'type' => $type
  1309. ],$user);
  1310. }
  1311. DB::commit();
  1312. return [true, ''];
  1313. }catch (\Throwable $exception){
  1314. DB::rollBack();
  1315. return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];
  1316. }
  1317. }
  1318. }
  1319. }