CheckService.php 59 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529
  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. $customer_short_name = Depart::where('id',$order['top_depart_id'])->value('title') ?? "";
  347. $prefix = SalesOrder::$prefix[SalesOrder::Model_type_two];
  348. $order_number = OrderNoService::createSalesOrderNumber($prefix);
  349. $product = PurchaseOrderInfo::where('del_time',0)
  350. ->where('purchase_order_id',$order['id'])
  351. ->get()->toArray();
  352. if(empty($product)) return [false, '采购订单产品数据不能为空'];
  353. $time = time();
  354. $model = new SalesOrder();
  355. $model->model_type = SalesOrder::Model_type_two;
  356. $model->sales_order_type = SalesOrder::Order_type_two;
  357. $model->customer_short_name = $customer_short_name;
  358. $model->order_number = $order_number;
  359. $model->crt_id = $order['crt_id'];
  360. $model->depart_id = $head;
  361. $model->top_depart_id = $head;
  362. $model->other_fee = $order['other_fee'];
  363. $model->discount_fee = $order['discount_fee'];
  364. $model->contract_fee = $order['purchase_total'];
  365. $model->contact_order_no = $order['order_number'];
  366. $model->sign_time = $time;
  367. $model->save();
  368. $sales_order_id = $model->id;
  369. //产品字典
  370. $product_map = (new ProductService())->getProductDetail(array_column($product,'product_id'));
  371. $insert = [];
  372. $product_total = 0;
  373. foreach ($product as $value){
  374. $tmp = $product_map[$value['product_id']] ?? [];
  375. $product_total += $value['price'] * $value['number'];
  376. $insert[] = [
  377. 'sales_order_id' => $sales_order_id,
  378. 'product_id' => $value['product_id'],
  379. 'number' => $value['number'],
  380. 'basic_type_id' => $value['basic_type_id'],
  381. 'price' => $value['price'],
  382. 'cost' => $tmp['cost'] ?? 0,
  383. 'retail_price' => $tmp['retail_price'] ?? 0,
  384. 'final_amount' => $value['price'] * $value['number'],
  385. ];
  386. }
  387. $bool = SalesOrderProductInfo::insert($insert);
  388. if(! $bool) return [false,'合同生成失败!'];
  389. //反写数据
  390. $tmp = $product_total + $order['other_fee'];
  391. $tmp = $tmp > 0 ? $tmp : 1;
  392. $rate = ($product_total + $order['other_fee'] - $order['discount_fee']) / $tmp;
  393. SalesOrder::where('id',$sales_order_id)->update([
  394. 'product_total' => $product_total,
  395. 'rate' => $rate
  396. ]);
  397. //生成付款单
  398. $model = new PaymentReceipt();
  399. $model->order_number = (new OrderNoService())->createOrderNumber(PaymentReceipt::prefix);
  400. $model->data_order_no = $order_number;
  401. $model->data_type = PaymentReceipt::data_type_one;
  402. $model->type = PaymentReceipt::type_one;
  403. $model->amount = $order['purchase_total'] ?? 0;
  404. $model->crt_id = $user['id'];
  405. $model->depart_id = $head;
  406. $model->top_depart_id = $head;
  407. $model->save();
  408. return [true,''];
  409. }
  410. //自动生成-----------------------------------
  411. //自动生成删除
  412. public function delCreatePurchaseOrderSales($data, $order){
  413. $sale_order = SalesOrder::where('del_time',0)
  414. ->where('contact_order_no',$order['order_number'])
  415. ->select('id','order_number')
  416. ->get()->toArray();
  417. if(empty($sale_order)) return [true,''];
  418. foreach ($sale_order as $value){
  419. list($status, $msg) = (new SalesOrderService())->salesOrderDel(['id' => $value['id']]);
  420. if(! $status) return [false,$msg];
  421. list($status, $msg) = (new PaymentReceiptService())->customerDel(['id' => $value['id']]);
  422. if(! $status) return [false,$msg];
  423. }
  424. return [true, ''];
  425. }
  426. //自动生成删除
  427. public function confirmPaymentReceipt($data){
  428. $model = PaymentReceipt::where('order_number',$data['order_number'])
  429. ->where('del_time',0)
  430. ->first();
  431. if(empty($model)) return [false, '收付款单不存在或已被删除'];
  432. if($model->state != PaymentReceipt::STATE_ONE) return [false, '请确认收付款单状态,操作失败'];
  433. if($data['type'] == self::TYPE_ONE){
  434. //通过
  435. $model->state = PaymentReceipt::STATE_TWO;
  436. $model->save();
  437. }else{
  438. //驳回
  439. $model->state = InvoiceOrder::STATE_ZERO;
  440. $model->save();
  441. }
  442. return [true, $model->toArray()];
  443. }
  444. public function confirmInvoiceOrder($data){
  445. $model = InvoiceOrder::where('order_number',$data['order_number'])
  446. ->where('del_time',0)
  447. ->first();
  448. if(empty($model)) return [false, '发货单不存在或已被删除'];
  449. if($model->state != InvoiceOrder::STATE_ONE) return [false, '请确认发货单状态,操作失败'];
  450. if($data['type'] == self::TYPE_ONE){
  451. //通过
  452. $model->state = InvoiceOrder::STATE_TWO;
  453. $model->save();
  454. $sale = SalesOrder::where('id',$model->sales_order_id)->first();
  455. if($sale['sales_order_type'] == SalesOrder::Order_type_one){
  456. //安装件更新发货状态
  457. SalesOrder::where('id',$model->sales_order_id)
  458. ->update(['invoice_state' => SalesOrder::invoice_one]);
  459. }else{
  460. //快递件更新 单据状态 发货状态
  461. SalesOrder::where('id',$model->sales_order_id)
  462. ->update([
  463. 'state' => SalesOrder::State2_one,
  464. 'invoice_state' => SalesOrder::invoice_one
  465. ]);
  466. }
  467. }else{
  468. //驳回
  469. $model->state = InvoiceOrder::STATE_ZERO;
  470. $model->save();
  471. }
  472. return [true, $model->toArray()];
  473. }
  474. public function recordInvoiceOrder($data, $order){
  475. $result = InvoiceOrderInfo::where('del_time',0)
  476. ->where('order_number',$order['order_number'])
  477. ->get()->toArray();
  478. if(empty($result)) return [false,'发货单产品信息不存在或已被删除'];
  479. $insert = [];
  480. $time = time();
  481. foreach ($result as $value){
  482. $key = $value['product_id'] . $value['storehouse_id'];
  483. if(isset($insert[$key])){
  484. $insert[$key]['number'] += -($value['number']);
  485. }else{
  486. $insert[$key] = [
  487. 'product_id' => $value['product_id'],
  488. 'number' => -($value['number']),
  489. 'order_type' => InvoiceOrder::prefix,
  490. 'order_number' => $order['order_number'],
  491. 'crt_time' => $time,
  492. 'storehouse_id' => $value['storehouse_id'],
  493. 'depart_id' => $order['depart_id'],
  494. 'top_depart_id' => $order['top_depart_id'],
  495. ];
  496. }
  497. }
  498. $insert = array_values($insert);
  499. $bool = InOutRecord::insert($insert);
  500. if(! $bool) return [false,'流水写入失败'];
  501. return [true,''];
  502. }
  503. public function confirmPurchaseOrderState($data){
  504. $model = PurchaseOrder::where('order_number',$data['order_number'])
  505. ->where('del_time',0)
  506. ->first();
  507. if(empty($model)) return [false,'采购单不存在或已被删除'];
  508. if($model->state != PurchaseOrder::STATE_ONE) return [false,'请确认采购单状态,操作失败'];
  509. if($data['type'] == self::TYPE_ONE){
  510. $model->state = PurchaseOrder::STATE_TWO;
  511. $model->save();
  512. }else{
  513. $model->state = PurchaseOrder::STATE_ZERO;
  514. $model->save();
  515. }
  516. return [true, $model->toArray()];
  517. }
  518. public function confirmPurchaseOrder($data,$user){
  519. $model = PurchaseOrder::where('order_number',$data['order_number'])
  520. ->where('del_time',0)
  521. ->first();
  522. if(empty($model)) return [false, '采购订单不存在或已被删除'];
  523. if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购订单状态,操作失败'];
  524. $model->state = PurchaseOrder::STATE_Four;
  525. $model->save();
  526. return [true, $model->toArray()];
  527. }
  528. public function recordPurchaseOrder($data, $order){
  529. $result = PurchaseOrderInfo::where('del_time',0)
  530. ->where('order_number',$order['order_number'])
  531. ->get()->toArray();
  532. if(empty($result)) return [false,'采购单产品信息不存在或已被删除'];
  533. $insert = [];
  534. $time = time();
  535. foreach ($result as $value){
  536. $key = $value['product_id'] . $value['storehouse_id'];
  537. if(isset($insert[$key])){
  538. $insert[$key]['number'] += $value['number'];
  539. }else{
  540. $insert[$key] = [
  541. 'product_id' => $value['product_id'],
  542. 'number' => $value['number'],
  543. 'order_type' => PurchaseOrder::prefix,
  544. 'order_number' => $order['order_number'],
  545. 'crt_time' => $time,
  546. 'storehouse_id' => $value['storehouse_id'],
  547. 'depart_id' => $order['depart_id'],
  548. 'top_depart_id' => $order['top_depart_id'],
  549. ];
  550. }
  551. }
  552. $insert = array_values($insert);
  553. $bool = InOutRecord::insert($insert);
  554. if(! $bool) return [false,'流水写入失败'];
  555. return [true,''];
  556. }
  557. public function confirmConstruction($data){
  558. $model = Construction::where('order_number',$data['order_number'])
  559. ->where('del_time',0)
  560. ->first();
  561. if(empty($model)) return [false, '施工单不存在或已被删除'];
  562. if($model->state != Construction::STATE_ONE) return [false, '请确认施工单状态,操作失败'];
  563. if($data['type'] == self::TYPE_ONE){
  564. $model->state = Construction::STATE_TWO;
  565. $model->save();
  566. //已下施工
  567. SalesOrder::where('id',$model->sales_order_id)->update(['state' => SalesOrder::State_five]);
  568. }else{
  569. $model->state = Construction::STATE_ZERO;
  570. $model->save();
  571. }
  572. return [true, $model->toArray()];
  573. }
  574. public function recordConstruction($data, $order){
  575. $result = ConstructionProductInfo::where('del_time',0)
  576. ->where('construction_id',$order['id'])
  577. ->get()->toArray();
  578. if(empty($result)) return [false,'施工单产品信息不存在或已被删除'];
  579. $insert = [];
  580. $time = time();
  581. foreach ($result as $value){
  582. $key = $value['product_id'] . $value['storehouse_id'];
  583. if(isset($insert[$key])){
  584. $insert[$key]['number'] += -($value['number']);
  585. }else{
  586. $insert[$key] = [
  587. 'product_id' => $value['product_id'],
  588. 'number' => -($value['number']),
  589. 'order_type' => Construction::$prefix[$order['model_type']] ?? '',
  590. 'order_number' => $order['order_number'],
  591. 'crt_time' => $time,
  592. 'storehouse_id' => $value['storehouse_id'],
  593. 'depart_id' => $order['depart_id'],
  594. 'top_depart_id' => $order['top_depart_id'],
  595. ];
  596. }
  597. }
  598. $insert = array_values($insert);
  599. $bool = InOutRecord::insert($insert);
  600. if(! $bool) return [false,'流水写入失败'];
  601. return [true,''];
  602. }
  603. public function confirmReturnExchangeOrder($data){
  604. $model = ReturnExchangeOrder::where('order_number',$data['order_number'])
  605. ->where('del_time',0)
  606. ->first();
  607. if(empty($model)) return [false, '退换货单不存在或已被删除'];
  608. if($model->state != ReturnExchangeOrder::State_one) return [false, '请确认退换货单状态,操作失败'];
  609. if($data['type'] == self::TYPE_ONE){
  610. $model->state = ReturnExchangeOrder::State_two;
  611. $model->save();
  612. // if($model->data_type == ReturnExchangeOrder::Order_type){
  613. // SalesOrder::where('id', $model->data_id)->update([
  614. // 'state' => SalesOrder::State_six
  615. // ]);
  616. // }
  617. }else{
  618. $model->state = ReturnExchangeOrder::State_zero;
  619. $model->save();
  620. }
  621. return [true, $model->toArray()];
  622. }
  623. public function recordReturnExchangeOrder($data, $order){
  624. $result = ReturnExchangeOrderProductInfo::where('del_time',0)
  625. ->where('return_exchange_id',$order['id'])
  626. ->get()->toArray();
  627. if(empty($result)) return [false,'退换货单产品信息不存在或已被删除'];
  628. $insert = $insert2 = [];
  629. $time = time();
  630. foreach ($result as $value){
  631. $key = $value['product_id'] . $value['storehouse_id'];
  632. $prefix = ReturnExchangeOrder::$prefix[$value['return_or_exchange']] ?? '';
  633. if($value['return_or_exchange'] == ReturnExchangeOrderProductInfo::type_one){
  634. //退货
  635. if(isset($insert[$key])){
  636. $insert[$key]['number'] += $value['number'];
  637. }else{
  638. $insert[$key] = [
  639. 'product_id' => $value['product_id'],
  640. 'number' => $value['number'],
  641. 'order_type' => $prefix,
  642. 'order_number' => $order['order_number'],
  643. 'crt_time' => $time,
  644. 'storehouse_id' => $value['storehouse_id'],
  645. 'depart_id' => $order['depart_id'],
  646. 'top_depart_id' => $order['top_depart_id'],
  647. ];
  648. }
  649. }else{
  650. //换货
  651. if(isset($insert2[$key])){
  652. $insert2[$key]['number'] += -($value['number']);
  653. }else{
  654. $insert2[$key] = [
  655. 'product_id' => $value['product_id'],
  656. 'number' => -($value['number']),
  657. 'order_type' => $prefix,
  658. 'order_number' => $order['order_number'],
  659. 'crt_time' => $time,
  660. 'storehouse_id' => $value['storehouse_id'],
  661. 'depart_id' => $order['depart_id'],
  662. 'top_depart_id' => $order['top_depart_id'],
  663. ];
  664. }
  665. }
  666. }
  667. $insert = array_values($insert);
  668. $bool = InOutRecord::insert($insert);
  669. if(! $bool) return [false,'流水写入失败'];
  670. if(! empty($insert2)) {
  671. $insert2 = array_values($insert2);
  672. $bool = InOutRecord::insert($insert2);
  673. if(! $bool) return [false,'流水写入失败'];
  674. }
  675. return [true,''];
  676. }
  677. public function settleSalesOrder($data,$user){
  678. $model = SalesOrder::where('order_number', $data['order_number'])
  679. ->where('del_time',0)
  680. ->first();
  681. if(empty($model)) return [false, '合同不存在或已被删除'];
  682. //安装件
  683. if($model->state <= SalesOrder::State_four || $model->state >= SalesOrder::State_seven) return [false, '请确认合同状态,操作失败'];
  684. SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])
  685. ->update(['state' => SalesOrder::State_seven]);
  686. return [true, $model->toArray()];
  687. }
  688. public function settleSalesOrderCustomer($data,$user){
  689. $model = SalesOrder::where('order_number', $data['order_number'])
  690. ->where('del_time',0)
  691. ->first();
  692. if(empty($model)) return [false, '合同不存在或已被删除'];
  693. if(empty($data['img'])) return [false,'图片不能为空'];
  694. //安装件
  695. if($model->state != SalesOrder::State_seven) return [false, '请确认合同状态,操作失败'];
  696. SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])
  697. ->update(['state' => SalesOrder::State_eight]);
  698. SalesOrderInfo::insert([
  699. 'sales_order_id' => $model->id,
  700. 'type' => SalesOrderInfo::type_six,
  701. 'file' => $data['img'],
  702. 'crt_time' => time(),
  703. ]);
  704. return [true, $model->toArray()];
  705. }
  706. public function settleSalesOrderConfirm($data,$user){
  707. $model = SalesOrder::where('order_number', $data['order_number'])
  708. ->where('del_time',0)
  709. ->first();
  710. if(empty($model)) return [false, '合同不存在或已被删除'];
  711. //安装件
  712. if($model->state != SalesOrder::State_four) return [false, '请确认合同状态,操作失败'];
  713. $model->is_confirm = 1;
  714. $model->save();
  715. $emp_name = Employee::where('id',$user['id'])->value('emp_name');
  716. $tmp_data = [
  717. $model->order_number,
  718. "派单合同",
  719. "接收派单成功",
  720. $emp_name,
  721. date('Y-m-d H:i:s'),
  722. ];
  723. if(! empty($model->dispatch_time_second_id)) (new OaService())->sendWxMsg($model->dispatch_time_second_id,2,0,37,$tmp_data);
  724. return [true, $model->toArray()];
  725. }
  726. public function confirmSales($data){
  727. $model = SalesOrder::where('order_number', $data['order_number'])
  728. ->where('del_time',0)
  729. ->first();
  730. if(empty($model)) return [false, '合同不存在或已被删除'];
  731. if($model->state != SalesOrder::State_one) return [false, '请确认合同状态,操作失败'];
  732. if($data['type'] == self::TYPE_ONE){
  733. $state = SalesOrder::State_three;
  734. if($model->model_type == SalesOrder::Model_type_four){
  735. //线上订单
  736. $state = SalesOrder::State_two;
  737. }
  738. $model->state = $state;
  739. $model->save();
  740. }else{
  741. $model->state = SalesOrder::State_zero;
  742. $model->save();
  743. }
  744. return [true, $model->toArray()];
  745. }
  746. public function reject_sales($data){
  747. $model = SalesOrder::where('order_number', $data['order_number'])
  748. ->where('del_time',0)
  749. ->first();
  750. if(empty($model)) return [false, '合同不存在或已被删除'];
  751. //安装件
  752. if($model->model_type == SalesOrder::Model_type_four){
  753. //线上订单
  754. if($model->state != SalesOrder::State_two) return [false, '请确认合同状态,操作失败'];
  755. }else{
  756. //除线上订单之外
  757. if($model->state != SalesOrder::State_three) return [false, '请确认合同状态,操作失败'];
  758. }
  759. //未确认
  760. $model->state = SalesOrder::State_zero;
  761. $model->save();
  762. return [true, $model->toArray()];
  763. }
  764. public function reject_purchase($data){
  765. $model = PurchaseOrder::where('order_number', $data['order_number'])
  766. ->where('del_time',0)
  767. ->first();
  768. if(empty($model)) return [false, '采购单不存在或已被删除'];
  769. //安装件
  770. if($model->state != PurchaseOrder::STATE_Four) return [false, '请确认采购单状态,操作失败'];
  771. $model->state = PurchaseOrder::STATE_TWO;
  772. $model->save();
  773. return [true, $model->toArray()];
  774. }
  775. public function reject_purchase_confirm($data){
  776. $model = PurchaseOrder::where('order_number', $data['order_number'])
  777. ->where('del_time',0)
  778. ->first();
  779. if(empty($model)) return [false, '采购单不存在或已被删除'];
  780. //安装件
  781. if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购单状态,操作失败'];
  782. $model->state = PurchaseOrder::STATE_ZERO;
  783. $model->save();
  784. return [true, $model->toArray()];
  785. }
  786. public function reject_construction($data){
  787. $model = Construction::where('order_number', $data['order_number'])
  788. ->where('del_time',0)
  789. ->first();
  790. if(empty($model)) return [false, '施工单不存在或已被删除'];
  791. //安装件
  792. if($model->state != Construction::STATE_TWO) return [false, '请确认施工单状态,操作失败'];
  793. $model->state = Construction::STATE_ZERO;
  794. $model->save();
  795. return [true, $model->toArray()];
  796. }
  797. public function reject_payment_receipt($data){
  798. $model = PaymentReceipt::where('order_number', $data['order_number'])
  799. ->where('del_time',0)
  800. ->first();
  801. if(empty($model)) return [false, '收付款单不存在或已被删除'];
  802. if($model->state != PaymentReceipt::STATE_TWO) return [false, '请确认收付款单状态,操作失败'];
  803. $model->state = PaymentReceipt::STATE_ZERO;
  804. $model->save();
  805. return [true, $model->toArray()];
  806. }
  807. public function reject_return_exchange($data){
  808. $model = ReturnExchangeOrder::where('order_number', $data['order_number'])
  809. ->where('del_time',0)
  810. ->first();
  811. if(empty($model)) return [false, '退换货单不存在或已被删除'];
  812. if($model->state != ReturnExchangeOrder::State_two) return [false, '请确认退换货单状态,操作失败'];
  813. $model->state = ReturnExchangeOrder::State_zero;
  814. $model->save();
  815. return [true, $model->toArray()];
  816. }
  817. public function reject_record_construction($data,$order){
  818. //获取单据最新数据时间 正常施工数据
  819. $latest = InOutRecord::where('del_time',0)
  820. ->where('order_number',$data['order_number'])
  821. ->where('number','<',0)
  822. ->select('crt_time')
  823. ->orderBy('crt_time', 'desc')
  824. ->first();
  825. $latest = $latest->toArray();
  826. $result = InOutRecord::where('del_time',0)
  827. ->where('crt_time',$latest['crt_time'])
  828. ->where('order_number',$data['order_number'])
  829. ->where('number','<',0)
  830. ->select('product_id','storehouse_id','number','depart_id','order_number','top_depart_id','order_type')
  831. ->get()->toArray();
  832. if(empty($result)) return [false,'施工出库流水数据未找到'];
  833. //生成对冲数据
  834. $time = time();
  835. foreach ($result as $key => $value){
  836. $result[$key]['number'] = abs($value['number']);
  837. $result[$key]['crt_time'] = $time;
  838. }
  839. $bool = InOutRecord::insert($result);
  840. if(! $bool) return [false,'流水写入失败'];
  841. //写入流水
  842. return [true, ''];
  843. }
  844. public function reject_record_purchase($data,$order){
  845. //获取单据最新数据时间 正常采购入库数据
  846. $latest = InOutRecord::where('del_time',0)
  847. ->where('order_number',$data['order_number'])
  848. ->where('number','>',0)
  849. ->select('crt_time')
  850. ->orderBy('crt_time', 'desc')
  851. ->first();
  852. $latest = $latest->toArray();
  853. $result = InOutRecord::where('del_time',0)
  854. ->where('crt_time',$latest['crt_time'])
  855. ->where('order_number',$data['order_number'])
  856. ->where('number','>',0)
  857. ->select('product_id','storehouse_id','number','depart_id','order_number','top_depart_id','order_type')
  858. ->get()->toArray();
  859. if(empty($result)) return [false,'采购入库流水数据未找到'];
  860. //生成对冲数据
  861. $time = time();
  862. foreach ($result as $key => $value){
  863. $result[$key]['number'] = - $value['number'];
  864. $result[$key]['crt_time'] = $time;
  865. }
  866. $bool = InOutRecord::insert($result);
  867. if(! $bool) return [false,'流水写入失败'];
  868. //写入流水
  869. return [true, ''];
  870. }
  871. public function reject_record_return_exchange($data,$order){
  872. $result = ReturnExchangeOrderProductInfo::where('del_time',0)
  873. ->where('return_exchange_id',$order['id'])
  874. ->get()->toArray();
  875. if(empty($result)) return [false,'退换货单产品信息不存在或已被删除'];
  876. $insert = $insert2 = [];
  877. $time = time();
  878. foreach ($result as $value){
  879. $key = $value['product_id'] . $value['storehouse_id'];
  880. $prefix = ReturnExchangeOrder::$prefix[$value['return_or_exchange']] ?? '';
  881. if($value['return_or_exchange'] == ReturnExchangeOrderProductInfo::type_one){
  882. //退货 扣出
  883. if(isset($insert[$key])){
  884. $insert[$key]['number'] += -($value['number']);
  885. }else{
  886. $insert[$key] = [
  887. 'product_id' => $value['product_id'],
  888. 'number' => -($value['number']),
  889. 'order_type' => $prefix,
  890. 'order_number' => $order['order_number'],
  891. 'crt_time' => $time,
  892. 'storehouse_id' => $value['storehouse_id'],
  893. 'depart_id' => $order['depart_id'],
  894. 'top_depart_id' => $order['top_depart_id'],
  895. ];
  896. }
  897. }else{
  898. //换货 加回
  899. if(isset($insert2[$key])){
  900. $insert2[$key]['number'] += $value['number'];
  901. }else{
  902. $insert2[$key] = [
  903. 'product_id' => $value['product_id'],
  904. 'number' => $value['number'],
  905. 'order_type' => $prefix,
  906. 'order_number' => $order['order_number'],
  907. 'crt_time' => $time,
  908. 'storehouse_id' => $value['storehouse_id'],
  909. 'depart_id' => $order['depart_id'],
  910. 'top_depart_id' => $order['top_depart_id'],
  911. ];
  912. }
  913. }
  914. }
  915. $insert = array_values($insert);
  916. $bool = InOutRecord::insert($insert);
  917. if(! $bool) return [false,'流水写入失败'];
  918. if(! empty($insert2)) {
  919. $insert2 = array_values($insert2);
  920. $bool = InOutRecord::insert($insert2);
  921. if(! $bool) return [false,'流水写入失败'];
  922. }
  923. return [true,''];
  924. }
  925. public function getOrderDetail($data,$user){
  926. if(empty($data['order_number'])) return [false,'必传参数不能为空'];
  927. $array = [];
  928. foreach (Construction::$prefix as $value){
  929. $array[$value] = "\App\Service\\ConstructionService";
  930. }
  931. foreach (ReturnExchangeOrder::$prefix as $value){
  932. $array[$value] = "\App\Service\\ReturnExchangeOrderService";
  933. }
  934. foreach (SalesOrder::$prefix as $value){
  935. $array[$value] = "\App\Service\\SalesOrderService";
  936. }
  937. $status = true;
  938. $msg = [];
  939. foreach ($array as $key => $value){
  940. if(strpos($data['order_number'],$key) !== false) {
  941. list($status, $msg) = (new $value)->detail($data);
  942. return [$status, $msg];
  943. }
  944. }
  945. if(strpos($data['order_number'],PurchaseOrder::prefix) !== false){
  946. $service = "\App\Service\\PurchaseOrderService";
  947. list($status, $msg) = (new $service)->detail($data,$user);
  948. return [$status, $msg];
  949. }
  950. return [$status, $msg];
  951. }
  952. public function checkAll($data,$user){
  953. if(empty($data['id']) || empty($data['order_number'])|| empty($data['opt_case'])) return [false,'必传参数不能为空或者参数值错误!'];
  954. list($status,$msg) = $this->limitingSendRequestBackgExpire($data['order_number'].$data['opt_case']);
  955. if(! $status) return [false,$msg];
  956. //走审批流 单据校验
  957. $function_check = self::$opt_1case_check[$data['opt_case']] ?? '';
  958. //走审批流 单据状态改为待审批方法
  959. $function = self::$opt_1case[$data['opt_case']] ?? '';
  960. //单据不走审批流
  961. $function2 = self::$finished[$data['opt_case']] ?? '';
  962. try{
  963. DB::beginTransaction();
  964. //不走审批流,更新完直接返回
  965. if($function2) {
  966. list($bool,$msg) = $this->$function2($data,$user);
  967. if($bool) {
  968. $order = $msg;
  969. list($bool,$err) = $this->createRecordAndInventoryMy($data,$user,$order);
  970. if($bool){
  971. DB::commit();
  972. return [true, ''];
  973. }else{
  974. DB::rollBack();
  975. return [false, $err];
  976. }
  977. }else{
  978. DB::rollBack();
  979. return [false, $msg];
  980. }
  981. }
  982. //需要审批流,校验
  983. if($function_check){
  984. list($bool,$msg) = $this->$function_check($data, $user);
  985. if(! $bool){
  986. DB::rollBack();
  987. return [false, $msg];
  988. }
  989. }
  990. //需要审批流,从未审核变成待审核
  991. if($function){
  992. list($bool,$msg) = $this->$function($data);
  993. if(! $bool){
  994. DB::rollBack();
  995. return [false, $msg];
  996. }
  997. //创建审批流
  998. $args = [
  999. 'order_no' => $data['order_number'],
  1000. 'menu_id' => $data['menu_id'] ?? 0,
  1001. 'opt_case' => $data['opt_case'],
  1002. 'order' => $msg,
  1003. ];
  1004. $oa = new OaService($user);
  1005. list($bool,$msg) = $oa->createOaOrder($args);
  1006. if(! $bool) {
  1007. DB::rollBack();
  1008. if($msg) return [false,$msg];
  1009. }
  1010. }
  1011. DB::commit();
  1012. return [true, ''];
  1013. }catch (\Throwable $exception){
  1014. DB::rollBack();
  1015. return [false, $exception->getMessage() . $exception->getFile(). $exception->getLine()];
  1016. }
  1017. }
  1018. //更新库存
  1019. public function changeInventory($data,$order,$user){
  1020. $number_symbol = "";
  1021. if(in_array($data['opt_case'],self::$in_opt)){
  1022. $number_symbol = ">";
  1023. }elseif (in_array($data['opt_case'],self::$out_opt)){
  1024. $number_symbol = "<";
  1025. }
  1026. //获取单据最新数据时间 正常审核的数据
  1027. $latest = InOutRecord::where('del_time',0)
  1028. ->where('order_number',$order['order_number'])
  1029. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1030. return $query->where('number', $number_symbol,0);
  1031. })
  1032. ->select('crt_time')
  1033. ->orderBy('crt_time', 'desc')
  1034. ->first();
  1035. $model = InOutRecord::where('del_time',0)
  1036. ->where('order_number',$order['order_number'])
  1037. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1038. return $query->where('number', $number_symbol,0);
  1039. })
  1040. ->select('number','crt_time','product_id','storehouse_id','top_depart_id');
  1041. if(! empty($latest)) {
  1042. $t = $latest->toArray();
  1043. $model->where('crt_time',$t['crt_time']);
  1044. }
  1045. $record = $model->get()->toArray();
  1046. if (empty($record)) return [false,'流水记录不存在'];
  1047. $top_depart_id = Storehouse::where('id', $order['storehouse_id'])->value('top_depart_id');
  1048. $result = $lock_number = [];
  1049. foreach ($record as $value){
  1050. $key = $value['product_id'] . $value['storehouse_id'];
  1051. if(isset($result[$key])){
  1052. $result[$key]['number'] += $value['number'];
  1053. }else{
  1054. $result[$key] = [
  1055. 'product_id' => $value['product_id'],
  1056. 'number' => $value['number'],
  1057. 'crt_time' => $value['crt_time'],
  1058. 'storehouse_id' => $value['storehouse_id'],
  1059. 'top_depart_id' => $top_depart_id,
  1060. ];
  1061. }
  1062. if($value['number'] < 0){
  1063. if(isset($lock_number[$key])){
  1064. $lock_number[$key] += $value['number'];
  1065. }else{
  1066. $lock_number[$key] = $value['number'];
  1067. }
  1068. }
  1069. }
  1070. //是否校验库存 是的话锁定数量要更新(根据当前操作人所在门店是否校验库存)
  1071. $lock = $user['is_check_stock'];
  1072. $result = array_values($result);
  1073. foreach ($result as $key => $value){
  1074. $keys = $value['product_id'] . $value['storehouse_id'];
  1075. $m = ProductInventory::where('product_id',$value['product_id'])
  1076. ->where('storehouse_id',$value['storehouse_id'])
  1077. ->select('product_id','number','storehouse_id')
  1078. ->first();
  1079. if(empty($m)){
  1080. ProductInventory::insert($result[$key]);
  1081. }else{
  1082. //锁定数量
  1083. $lock_number_tmp = 0;
  1084. if($lock && ! empty($lock_number[$keys])) $lock_number_tmp = $lock_number[$keys];
  1085. ProductInventory::where('product_id',$m->product_id)
  1086. ->where('storehouse_id',$m->storehouse_id)
  1087. ->lockForUpdate()
  1088. ->update([
  1089. 'number' => DB::raw('number + ('. $value['number'] . ')'),
  1090. 'lock_number' => DB::raw('lock_number + ('. $lock_number_tmp . ')')
  1091. ]);
  1092. }
  1093. }
  1094. return [true,''];
  1095. }
  1096. //业务单据审批通过后 驳回 更新库存
  1097. public function changeInventoryReject($data,$order,$user){
  1098. $number_symbol = "";
  1099. if(in_array($data['opt_case'],self::$in_opt)){
  1100. $number_symbol = "<";
  1101. }elseif (in_array($data['opt_case'],self::$out_opt)){
  1102. $number_symbol = ">";
  1103. }
  1104. //获取单据最新数据时间 正常审核的数据
  1105. $latest = InOutRecord::where('del_time',0)
  1106. ->where('order_number',$order['order_number'])
  1107. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1108. return $query->where('number', $number_symbol,0);
  1109. })
  1110. ->select('crt_time')
  1111. ->orderBy('crt_time', 'desc')
  1112. ->first();
  1113. $model = InOutRecord::where('del_time',0)
  1114. ->where('order_number',$order['order_number'])
  1115. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1116. return $query->where('number', $number_symbol,0);
  1117. })
  1118. ->select('number','crt_time','product_id','storehouse_id','top_depart_id');
  1119. if(! empty($latest)) {
  1120. $t = $latest->toArray();
  1121. $model->where('crt_time',$t['crt_time']);
  1122. }
  1123. $record = $model->get()->toArray();
  1124. if (empty($record)) return [false,'流水记录不存在'];
  1125. $top_depart_id = Storehouse::where('id', $order['storehouse_id'])->value('top_depart_id');
  1126. $result = $lock_number = [];
  1127. foreach ($record as $value){
  1128. $key = $value['product_id'] . $value['storehouse_id'];
  1129. if(isset($result[$key])){
  1130. $result[$key]['number'] += $value['number'];
  1131. }else{
  1132. $result[$key] = [
  1133. 'product_id' => $value['product_id'],
  1134. 'number' => $value['number'],
  1135. 'crt_time' => $value['crt_time'],
  1136. 'storehouse_id' => $value['storehouse_id'],
  1137. 'top_depart_id' => $top_depart_id,
  1138. ];
  1139. }
  1140. if($value['number'] > 0){
  1141. if(isset($lock_number[$key])){
  1142. $lock_number[$key] += $value['number'];
  1143. }else{
  1144. $lock_number[$key] = $value['number'];
  1145. }
  1146. }
  1147. }
  1148. //是否校验库存 是的话锁定数量要更新(根据当前操作人所在门店是否校验库存)
  1149. $lock = $user['is_check_stock'];
  1150. $result = array_values($result);
  1151. foreach ($result as $key => $value){
  1152. $keys = $value['product_id'] . $value['storehouse_id'];
  1153. $m = ProductInventory::where('product_id',$value['product_id'])
  1154. ->where('storehouse_id',$value['storehouse_id'])
  1155. ->select('product_id','number','storehouse_id')
  1156. ->first();
  1157. if(empty($m)){
  1158. ProductInventory::insert($result[$key]);
  1159. }else{
  1160. //锁定数量
  1161. $lock_number_tmp = 0;
  1162. if($lock && ! empty($lock_number[$keys])) $lock_number_tmp = $lock_number[$keys];
  1163. ProductInventory::where('product_id',$m->product_id)
  1164. ->where('storehouse_id',$m->storehouse_id)
  1165. ->lockForUpdate()
  1166. ->update([
  1167. 'number' => DB::raw('number + ('. $value['number'] . ')'),
  1168. 'lock_number' => DB::raw('lock_number + ('. $lock_number_tmp . ')')
  1169. ]);
  1170. }
  1171. }
  1172. return [true,''];
  1173. }
  1174. public function createRecordAndInventory($data = []){
  1175. if(empty($data['type']) || empty($data['opt_case']) || empty($data['order_number'])) return [false, '传递参数缺少'];
  1176. $user = $data['user_data'] ?? [];
  1177. if($data['type'] == self::TYPE_THREE){
  1178. //通过后弃审
  1179. if(! isset(self::$opt_case_reject[$data['opt_case']])) return [false, '该操作不存在'];
  1180. //具体方法
  1181. $function = self::$opt_case_reject[$data['opt_case']];
  1182. //流水
  1183. $function2 = self::$reject_record[$data['opt_case']] ?? '';
  1184. //自动生成删除
  1185. $function3 = self::$create_del[$data['opt_case']] ?? '';
  1186. try{
  1187. DB::beginTransaction();
  1188. //更新单据的状态
  1189. list($bool,$msg) = $this->$function($data);
  1190. if(! $bool){
  1191. DB::rollBack();
  1192. return [false, $msg];
  1193. }
  1194. $order = $msg;
  1195. if($function3){
  1196. list($boolean,$msg) = $this->$function3($data,$order);
  1197. if(! $boolean) {
  1198. DB::rollBack();
  1199. return [false, $msg];
  1200. }
  1201. }
  1202. if($function2) {
  1203. //流水
  1204. list($boolean,$msg) = $this->$function2($data,$order);
  1205. if(! $boolean) {
  1206. DB::rollBack();
  1207. return [false, $msg];
  1208. }
  1209. //库存
  1210. list($bool,$msg) = $this->changeInventoryReject($data,$order,$user);
  1211. if(! $bool){
  1212. DB::rollBack();
  1213. return [false, $msg];
  1214. }
  1215. }
  1216. if(! empty(self::$operation_order_reject[$data['opt_case']])){
  1217. $type = self::$operation_order_reject[$data['opt_case']];
  1218. (new OrderOperationService())->add([
  1219. 'order_number' => $order['order_number'],
  1220. 'msg' => OrderOperation::$type[$type],
  1221. 'type' => $type
  1222. ],$user);
  1223. }
  1224. DB::commit();
  1225. return [true, ''];
  1226. }catch (\Throwable $exception){
  1227. DB::rollBack();
  1228. return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];
  1229. }
  1230. }else{
  1231. //具体方法
  1232. $function = self::$opt_case[$data['opt_case']] ?? "";
  1233. $record = self::$record[$data['opt_case']] ?? "";
  1234. $create = self::$create[$data['opt_case']] ?? "";
  1235. try{
  1236. DB::beginTransaction();
  1237. list($bool,$msg) = $this->$function($data);
  1238. if(! $bool){
  1239. DB::rollBack();
  1240. return [false, $msg];
  1241. }
  1242. $order = $msg;
  1243. if($data['type'] == self::TYPE_ONE){
  1244. if($record) {
  1245. //流水
  1246. $bool = $this->$record($data, $order);
  1247. if(! $bool) {
  1248. DB::rollBack();
  1249. return [false, $msg];
  1250. }
  1251. //库存
  1252. list($bool,$msg) = $this->changeInventory($data, $order, $user);
  1253. if(! $bool) {
  1254. DB::rollBack();
  1255. return [false, $msg];
  1256. }
  1257. }
  1258. if($create) {
  1259. list($bool,$msg) = $this->$create($order,$user);
  1260. if(! $bool) {
  1261. DB::rollBack();
  1262. return [false, $msg];
  1263. }
  1264. }
  1265. }
  1266. if(! empty(self::$operation_order[$data['opt_case']])){
  1267. $user = $data['user_data'] ?? [];
  1268. $type = self::$operation_order[$data['opt_case']];
  1269. (new OrderOperationService())->add([
  1270. 'order_number' => $order['order_number'],
  1271. 'msg' => OrderOperation::$type[$type],
  1272. 'type' => $type
  1273. ],$user);
  1274. }
  1275. DB::commit();
  1276. return [true, ''];
  1277. }catch (\Throwable $exception){
  1278. DB::rollBack();
  1279. return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];
  1280. }
  1281. }
  1282. }
  1283. //不需要走审批流 直接调用
  1284. public function createRecordAndInventoryMy($data = [],$user = [],$order = []){
  1285. if(! empty($data['type']) && $data['type'] == self::TYPE_THREE){
  1286. }else{
  1287. //具体方法
  1288. $record = self::$record[$data['opt_case']] ?? "";
  1289. $create = self::$create[$data['opt_case']] ?? "";
  1290. try{
  1291. DB::beginTransaction();
  1292. if($record) {
  1293. //流水
  1294. list($bool,$msg) = $this->$record($data, $order);
  1295. if(! $bool) {
  1296. DB::rollBack();
  1297. return [false, $msg];
  1298. }
  1299. //库存
  1300. list($bool,$msg) = $this->changeInventory($data, $order, $user);
  1301. if(! $bool) {
  1302. DB::rollBack();
  1303. return [false, $msg];
  1304. }
  1305. }
  1306. if($create) {
  1307. list($bool,$msg) = $this->$create($order,$user);
  1308. if(! $bool) {
  1309. DB::rollBack();
  1310. return [false, $msg];
  1311. }
  1312. }
  1313. if(! empty(self::$operation_order[$data['opt_case']])){
  1314. $type = self::$operation_order[$data['opt_case']];
  1315. (new OrderOperationService())->add([
  1316. 'order_number' => $order['order_number'],
  1317. 'msg' => OrderOperation::$type[$type],
  1318. 'type' => $type
  1319. ],$user);
  1320. }
  1321. DB::commit();
  1322. return [true, ''];
  1323. }catch (\Throwable $exception){
  1324. DB::rollBack();
  1325. return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];
  1326. }
  1327. }
  1328. }
  1329. }