CheckService.php 89 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268
  1. <?php
  2. namespace App\Service;
  3. use App\Model\Construction;
  4. use App\Model\ConstructionProductInfo;
  5. use App\Model\Customer;
  6. use App\Model\Depart;
  7. use App\Model\Employee;
  8. use App\Model\InOutRecord;
  9. use App\Model\Inventory;
  10. use App\Model\InventorySub;
  11. use App\Model\InvoiceOrder;
  12. use App\Model\InvoiceOrderInfo;
  13. use App\Model\OrderInventoryStock;
  14. use App\Model\OrderOperation;
  15. use App\Model\OutBoundOrder;
  16. use App\Model\OutBoundOrderInfo;
  17. use App\Model\PaymentReceipt;
  18. use App\Model\PaymentReceiptInfo;
  19. use App\Model\ProductAdjustment;
  20. use App\Model\ProductAdjustmentSub;
  21. use App\Model\ProductInventory;
  22. use App\Model\ProductInventorySet;
  23. use App\Model\PurchaseOrder;
  24. use App\Model\PurchaseOrderInfo;
  25. use App\Model\PurchaseOrderInfoForOutBound;
  26. use App\Model\PurchaseOrderInfoForOutboundInfo;
  27. use App\Model\PurchaseOrderSpecial;
  28. use App\Model\PurchaseOrderSpecialInfo;
  29. use App\Model\ReturnExchangeOrder;
  30. use App\Model\ReturnExchangeOrderForOutboundInfo;
  31. use App\Model\ReturnExchangeOrderProductInfo;
  32. use App\Model\SalesOrder;
  33. use App\Model\SalesOrderInfo;
  34. use App\Model\SalesOrderOtherFee;
  35. use App\Model\SalesOrderProductInfo;
  36. use App\Model\SeeRange;
  37. use App\Model\SportsBag;
  38. use App\Model\Storehouse;
  39. use App\Model\Supplier;
  40. use Illuminate\Support\Facades\DB;
  41. class CheckService extends Service
  42. {
  43. //特殊操作数
  44. const minus_one = -1;//跳出库存流水
  45. //审批操作对应的数值
  46. const one = 1; //收货
  47. const two = 2; //发货
  48. const three = 3; //采购单入库
  49. const four = 4; //合同公司完结
  50. const five = 5; //施工单
  51. const six = 6; //退换货单
  52. const seven = 7; //采购单确认
  53. const eight = 8; //合同确认
  54. const nine = 9; //合同客户完结
  55. const ten = 10; //收付款确认
  56. const eve = 11; //接受派单
  57. const twl = 12; //活动包
  58. const thi = 13; //虚拟采购单
  59. const fourteen = 14; //盘点
  60. const fifteen = 15; //放弃门店派单
  61. const sixteen = 16; //出库单审核
  62. const seventeen = 17; //产品金额调整单审核
  63. //中文对照
  64. public $map = [
  65. self::one => '收货单',
  66. self::two => '发货单',//确认后出库
  67. self::three => '采购单入库',//确认后入库
  68. self::four => '公司完结', // 安装件 合同完结
  69. self::five => '施工单',//确认后出库
  70. self::six => '退换货单',//确认后出库或出库入库
  71. self::seven => '采购单确认',
  72. self::eight => '合同确认',
  73. self::nine => '合同客户完结',
  74. self::ten => '收付款确认',
  75. self::eve => '接受门店派单',
  76. self::twl => '活动包',
  77. self::thi => '虚拟采购单',
  78. self::fourteen => '盘点单',
  79. self::fifteen => '放弃门店派单',
  80. self::sixteen => '出库单审核',
  81. self::seventeen => '产品金额调整单审核',
  82. ];
  83. //入库操作
  84. public static $in_opt = [
  85. self::three,
  86. ];
  87. //出库操作
  88. public static $out_opt = [
  89. self::two,
  90. self::five,
  91. self::sixteen,
  92. ];
  93. const TYPE_ONE = 1;//通过
  94. const TYPE_TWO = 2;//不通过
  95. const TYPE_THREE = 3;//通过后驳回
  96. //改为待审核状态 校验
  97. public static $opt_1case_check = [
  98. // self::five => 'checkConstruction',//施工单
  99. ];
  100. //改为待审核状态
  101. public static $opt_1case = [
  102. self::two => 'waitInvoice',//发货单
  103. // self::three => 'waitPurchase',//采购单 入库
  104. self::five => 'waitConstruction',//施工单
  105. self::six => 'waitReturnExchange',//退换货单
  106. self::seven => 'waitPurchaseConfirm', //采购单确认
  107. self::eight => 'waitSales', // 合同安装件 合同确认
  108. self::ten => 'waitPaymentReceipt', //收付款确认
  109. self::twl => 'waitSportsBag', //活动包确认
  110. self::thi => 'waitPurchaseSpecial', //虚拟采购单
  111. self::fourteen => 'waitInventory', //盘点单
  112. self::sixteen => 'waitOut', //出库单
  113. self::seventeen => 'waitProductAdjustment', //产品金额调整单
  114. ];
  115. public static $finished = [
  116. self::three => 'confirmPurchaseOrder',//采购单 入库
  117. self::four => 'settleSalesOrder', // 合同 安装件 合同公司完结
  118. self::nine => 'settleSalesOrderCustomer', // 合同 安装件 合同客户完结
  119. self::eve => 'settleSalesOrderConfirm', // 合同 安装件 合同接收
  120. self::fifteen => 'settleSalesOrderConfirmBack', // 合同 安装件 合同接收后放弃
  121. ];
  122. //单据操作
  123. public static $opt_case = [
  124. self::two => 'confirmInvoiceOrder',
  125. // self::three => 'confirmPurchaseOrder',
  126. self::five => 'confirmConstruction',
  127. self::six => 'confirmReturnExchangeOrder',
  128. self::seven => 'confirmPurchaseOrderState',
  129. self::eight => 'confirmSales', // 合同 安装件 合同确认
  130. self::ten => 'confirmPaymentReceipt', // 确认收付款单
  131. self::twl => 'confirmSportsBag', // 确认活动包
  132. self::thi => 'confirmPurchaseSpecial', //虚拟采购单
  133. self::fourteen => 'confirmInventory', //盘点单
  134. self::sixteen => 'confirmOut', //出库单
  135. self::seventeen => 'confirmProductAdjustment', //产品金额调整单
  136. ];
  137. //单据库存流水
  138. public static $record = [
  139. // self::two => 'recordInvoiceOrder',
  140. self::three => 'recordPurchaseOrder',
  141. // self::five => 'recordConstruction',
  142. self::six => 'recordReturnExchangeOrder',
  143. self::fourteen => 'recordInventory',
  144. self::sixteen => 'recordOut',
  145. self::seventeen => 'recordProductAdjustment',
  146. ];
  147. //自动生成
  148. public static $create = [
  149. self::seven => 'createPurchaseOrderSales', //分社合同生成
  150. self::four => 'createPurchaseOrder', // 派给分社的合同 公司完结以后生成虚拟采购单
  151. ];
  152. //自动生成的删除
  153. public static $create_del = [
  154. self::seven => 'delCreatePurchaseOrderSales', //分社合同生成(删除)
  155. // self::four => 'delCreatePurchaseOrder', // 派给分社的合同确认以后生成虚拟采购单
  156. ];
  157. //审核通过后 弃审
  158. public static $opt_case_reject = [
  159. self::four => 'reject_sales', // 合同
  160. // self::three => 'reject_purchase', //采购入库
  161. self::seven => 'reject_purchase_confirm', //采购确认驳回
  162. self::five => 'reject_construction',//施工单
  163. self::six => 'reject_return_exchange',//退换货
  164. self::ten => 'reject_payment_receipt',//收付款单
  165. self::twl => 'reject_sports_bag',//活动包
  166. self::thi => 'reject_purchase_special',//虚拟采购单
  167. ];
  168. //审核通过后 驳回 产生流水
  169. public static $reject_record = [
  170. // self::five => 'reject_record_construction', //施工单驳回
  171. self::three => 'reject_record_purchase', //采购
  172. self::six => 'reject_record_return_exchange',//退换货
  173. ];
  174. //旅程日志 同意
  175. public static $operation_order = [
  176. self::eight => OrderOperation::three, //合同确认
  177. self::two => OrderOperation::eight, //发货单确认
  178. self::six => OrderOperation::nine, //退换货审核
  179. self::five => OrderOperation::eve, //施工单
  180. self::seven => OrderOperation::thi,//采购单确认
  181. self::three => OrderOperation::fourteen,//采购单入库
  182. self::ten => OrderOperation::twenty_one,//收付款单
  183. self::twl => OrderOperation::twenty_seven,//活动包确认
  184. self::thi => OrderOperation::twenty_nine,//虚拟采购单
  185. self::sixteen => OrderOperation::thirty_three,//出库单
  186. ];
  187. //旅程日志 驳回
  188. public static $operation_order_reject = [
  189. self::four => OrderOperation::four, //合同弃审
  190. self::six => OrderOperation::ten, //退换货弃审
  191. self::five => OrderOperation::twl, //施工单弃审
  192. self::three => OrderOperation::fif,//采购单入库弃审
  193. self::seven => OrderOperation::twenty,//采购单确认弃审
  194. self::ten => OrderOperation::twenty_two,//收付款单
  195. self::twl => OrderOperation::twenty_eight,//活动包
  196. self::thi => OrderOperation::thirty,//虚拟采购单
  197. ];
  198. //校验 不需要了
  199. public function checkConstruction($data, $user){
  200. $order = Construction::where('del_time',0)
  201. ->where('order_number',$data['order_number'])
  202. ->first();
  203. if(empty($order)) return [false,'施工单不存在或已被删除'];
  204. $order = $order->toArray();
  205. //总社id
  206. $head = $user['head'] ?? [];
  207. $head = $head['id'] ?? 0;
  208. //分社自己的施工单 直接返回
  209. if($order['top_depart_id'] != $head) return [true, ''];
  210. //不校验库存
  211. if($user['is_check_stock'] == ProductInventorySet::type_two) return [true,''];
  212. //施工单产品
  213. $sub = ConstructionProductInfo::where('construction_id',$order['id'])
  214. ->where('del_time',0)
  215. ->get()->toArray();
  216. if(empty($sub)) return [false,'施工单产品不存在或已被删除'];
  217. $product_submit = $product_id = [];
  218. foreach ($sub as $value){
  219. $product_id[] = $value['product_id'];
  220. $key = $value['product_id'] . ',' . $value['storehouse_id'];
  221. if(isset($product_save[$key])){
  222. $product_submit[$key] += $value['number'];
  223. }else{
  224. $product_submit[$key] = $value['number'];
  225. }
  226. }
  227. //比较库存
  228. list($status,$msg) = (new ProductInventoryService())->compareStock($user,$product_id, $product_submit, []);
  229. if(! $status) return [false, $msg];
  230. //锁定库存
  231. // ProductInventoryService::changeLockNumber($user,$product_submit);
  232. return [true, ''];
  233. }
  234. //改为待审核---------------------------------
  235. public function waitInvoice($data){
  236. $model = InvoiceOrder::where('id',$data['id'])
  237. ->where('del_time',0)
  238. ->first();
  239. if(empty($model)) return [false, '发货单不存在或已被删除'];
  240. if($model->state != InvoiceOrder::STATE_ZERO) return [false, '请确认发货单状态,操作失败'];
  241. InvoiceOrder::where('del_time',0)->where('id',$data['id'])
  242. ->update(['state' => InvoiceOrder::STATE_ONE]);
  243. return [true, $model->toArray()];
  244. }
  245. public function waitPurchaseConfirm($data){
  246. $model = PurchaseOrder::where('id',$data['id'])
  247. ->where('del_time',0)
  248. ->first();
  249. if(empty($model)) return [false,'采购单不存在或已被删除'];
  250. if(! in_array($model->state, [PurchaseOrder::State_minus_one,PurchaseOrder::STATE_ZERO])) return [false, '请确认采购单状态,操作失败'];
  251. //待确认
  252. PurchaseOrder::where('id',$data['id'])->update(['state' => PurchaseOrder::STATE_ONE]);
  253. return [true, $model->toArray()];
  254. }
  255. public function waitPurchase($data){
  256. $model = PurchaseOrder::where('id',$data['id'])
  257. ->where('del_time',0)
  258. ->first();
  259. if(empty($model)) return [false, '采购订单不存在或已被删除'];
  260. if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购订单状态,操作失败'];
  261. //待入库
  262. PurchaseOrder::where('del_time',0)->where('id',$data['id'])
  263. ->update(['state' => PurchaseOrder::STATE_Three]);
  264. return [true, $model->toArray()];
  265. }
  266. public function waitPurchaseSpecial($data){
  267. $model = PurchaseOrderSpecial::where('id',$data['id'])
  268. ->where('del_time',0)
  269. ->first();
  270. if(empty($model)) return [false, '虚拟采购订单不存在或已被删除'];
  271. if($model->state > PurchaseOrderSpecial::STATE_ZERO) return [false, '请确认虚拟采购订单状态,操作失败'];
  272. //待入库
  273. PurchaseOrderSpecial::where('del_time',0)->where('id',$data['id'])
  274. ->update(['state' => PurchaseOrder::STATE_ONE]);
  275. return [true, $model->toArray()];
  276. }
  277. public function waitInventory($data){
  278. $model = Inventory::where('id',$data['id'])
  279. ->where('del_time',0)
  280. ->first();
  281. if(empty($model)) return [false, '盘点单不存在或已被删除'];
  282. if($model->state > Inventory::STATE_ZERO) return [false, '请确认盘点单状态,操作失败'];
  283. //待入库
  284. Inventory::where('del_time',0)->where('id',$data['id'])
  285. ->update(['state' => Inventory::STATE_ONE]);
  286. return [true, $model->toArray()];
  287. }
  288. public function waitOut($data){
  289. $model = OutBoundOrder::where('id',$data['id'])
  290. ->where('del_time',0)
  291. ->first();
  292. if(empty($model)) return [false, '出库单不存在或已被删除'];
  293. if($model->state > OutBoundOrder::STATE_ZERO) return [false, '请确认出库单状态,操作失败'];
  294. //待入库
  295. OutBoundOrder::where('del_time',0)->where('id',$data['id'])
  296. ->update(['state' => OutBoundOrder::STATE_ONE]);
  297. return [true, $model->toArray()];
  298. }
  299. public function waitProductAdjustment($data){
  300. $model = ProductAdjustment::where('id',$data['id'])
  301. ->where('del_time',0)
  302. ->first();
  303. if(empty($model)) return [false, '产品金额调整单不存在或已被删除'];
  304. if($model->state > ProductAdjustment::STATE_ZERO) return [false, '请确认产品金额调整单状态,操作失败'];
  305. //待审核
  306. ProductAdjustment::where('del_time',0)->where('id',$data['id'])
  307. ->update(['state' => ProductAdjustment::STATE_ONE]);
  308. return [true, $model->toArray()];
  309. }
  310. public function waitConstruction($data){
  311. $model = Construction::where('id',$data['id'])
  312. ->where('del_time',0)
  313. ->first();
  314. if(empty($model)) return [false, '施工单不存在或已被删除'];
  315. if(! in_array($model->state, [Construction::State_minus_one,Construction::STATE_ZERO])) return [false, '请确认施工单状态,操作失败'];
  316. //待确认
  317. Construction::where('del_time',0)->where('id',$data['id'])
  318. ->update(['state' => Construction::STATE_ONE]);
  319. return [true, $model->toArray()];
  320. }
  321. public function waitReturnExchange($data){
  322. $model = ReturnExchangeOrder::where('id',$data['id'])
  323. ->where('del_time',0)
  324. ->first();
  325. if(empty($model)) return [false, '退换货单不存在或已被删除'];
  326. if(! in_array($model->state, [ReturnExchangeOrder::State_minus_one,ReturnExchangeOrder::State_zero])) return [false, '请确认退换货单状态,操作失败'];
  327. //待确认
  328. ReturnExchangeOrder::where('del_time',0)->where('id',$data['id'])
  329. ->update(['state' => ReturnExchangeOrder::State_one]);
  330. return [true, $model->toArray()];
  331. }
  332. public function waitSales($data){
  333. $model = SalesOrder::where('id', $data['id'])
  334. ->where('del_time',0)
  335. ->first();
  336. if(empty($model)) return [false, '合同不存在或已被删除'];
  337. //安装件
  338. if(! in_array($model->state, [SalesOrder::State_minus_one,SalesOrder::State_zero])) return [false, '请确认合同状态,操作失败'];
  339. SalesOrder::where('del_time',0)->where('id',$data['id'])
  340. ->update(['state' => SalesOrder::State_one]);
  341. return [true, $model->toArray()];
  342. }
  343. public function waitPaymentReceipt($data){
  344. $model = PaymentReceipt::where('id', $data['id'])
  345. ->where('del_time',0)
  346. ->first();
  347. if(empty($model)) return [false, '收付款单不存在或已被删除'];
  348. if(! in_array($model->state, [PaymentReceipt::State_minus_one,PaymentReceipt::STATE_ZERO])) return [false, '请确认收付款单状态,操作失败'];
  349. PaymentReceipt::where('del_time',0)->where('id',$data['id'])
  350. ->update(['state' => PaymentReceipt::STATE_ONE]);
  351. return [true, $model->toArray()];
  352. }
  353. public function waitSportsBag($data){
  354. $model = SportsBag::where('id', $data['id'])
  355. ->where('del_time',0)
  356. ->first();
  357. if(empty($model)) return [false, '活动包不存在或已被删除'];
  358. if(! in_array($model->state, [SportsBag::State_minus_one,SportsBag::STATE_ZERO])) return [false, '请确认活动包状态,操作失败'];
  359. SportsBag::where('del_time',0)->where('id',$data['id'])
  360. ->update(['state' => SportsBag::STATE_ONE]);
  361. return [true, $model->toArray()];
  362. }
  363. //改为待审核---------------------------------
  364. //自动生成-----------------------------------
  365. //总社派给分社的合同 完成生成虚拟采购单
  366. public function createPurchaseOrder($order,$user){
  367. //快递件
  368. if($order['sales_order_type'] == SalesOrder::Order_type_two) return [true,''];
  369. //不是总公司的合同
  370. $head = $user['head'] ?? [];
  371. $head = $head['id'] ?? 0; //总社id
  372. if($head != $order['top_depart_id']) return [true, ''];
  373. $see = SeeRange::where('del_time',0)
  374. ->where('data_id',$order['id'])
  375. ->where('data_type',SeeRange::type_seven)
  376. ->where('type',SeeRange::data_three)
  377. ->first();
  378. if(empty($see)) return [false, '未找到指派分社信息'];
  379. $depart_id = $see->param_id;//指派的分社
  380. //总社指派给自己
  381. if($depart_id == $head) return [true, ''];
  382. //获取指派分社时候的金额
  383. $fee = SalesOrderOtherFee::where('del_time',0)
  384. ->where('sales_order_id',$order['id'])
  385. ->first();
  386. if(empty($fee)) return [false, '未找到指派分社时填写的金额'];
  387. $fee = $fee->toArray();
  388. $order_number = (new OrderNoService())->createOrderNumber(PurchaseOrderSpecial::prefix);
  389. $storehouse = Storehouse::where('depart_id',$head)->value('id');
  390. $product = SalesOrderProductInfo::where('del_time',0)
  391. ->where('sales_order_id',$order['id'])
  392. ->select('product_id','number','retail_price')
  393. ->get()->toArray();
  394. //退货的差异
  395. $returnExchange_map = [];
  396. $returnExchange = ReturnExchangeOrder::where('del_time',0)
  397. ->where('type',ReturnExchangeOrder::Order_type)
  398. ->where('data_id',$order['id'])
  399. ->select('id')
  400. ->get()->toArray();
  401. $return_product = ReturnExchangeOrderProductInfo::where('del_time',0)
  402. ->where('return_exchange_id',array_column($returnExchange,'id'))
  403. ->select('product_id','number')
  404. ->get()->toArray();
  405. foreach ($return_product as $value){
  406. if(isset($returnExchange_map[$value['product_id']])){
  407. $returnExchange_map[$value['product_id']] += $value['number'];
  408. }else{
  409. $returnExchange_map[$value['product_id']] = $value['number'];
  410. }
  411. }
  412. $product_map = $rate = [];
  413. $total = 0;
  414. foreach ($product as $key => $value){
  415. $return_number = 0;
  416. if(isset($returnExchange_map[$value['product_id']])) $return_number = $returnExchange_map[$value['product_id']];
  417. $number = $value['number'];
  418. if($return_number >= $value['number']) {
  419. unset($product[$key]);
  420. continue;
  421. }else{
  422. $number = bcsub($number,$return_number,2);
  423. $product[$key]['number'] = $number;
  424. }
  425. $total += $number * $value['retail_price'];
  426. if(isset($product_map[$value['product_id']])){
  427. $product_map[$value['product_id']] += $value['retail_price'] * $number;
  428. }else{
  429. $product_map[$value['product_id']] = $value['retail_price'] * $number;
  430. }
  431. }
  432. foreach ($product_map as $key => $value){
  433. $rate[$key] = bcdiv($value, $total, 2);
  434. }
  435. try {
  436. DB::beginTransaction();
  437. $model = new PurchaseOrderSpecial();
  438. $model->order_number = $order_number;
  439. $model->sales_order_id = $order['id'];
  440. $model->supplier = $depart_id;
  441. $model->type = $order['type'];
  442. $model->depart_id = $head;
  443. $model->top_depart_id = $head;
  444. $model->crt_id = Employee::SPECIAL_ADMIN;
  445. $model->purchase_id = Employee::SPECIAL_ADMIN;
  446. $model->purchase_total = $fee['other_fee_1'] ?? 0;
  447. $model->storehouse_id = $storehouse ?? 0;
  448. $model->save();
  449. if(empty($model->id)) return [false,'采购单主信息生成失败'];
  450. $purchase_order_id = $model->id;
  451. $insert = [];$product_total = 0;
  452. foreach ($product as $value){
  453. $rate_tmp = $rate[$value['product_id']] ?? 0;
  454. $price = bcdiv(bcmul($rate_tmp, $fee['other_fee_1'],2), $value['number'],2);
  455. $product_total += $price * $value['number'];
  456. $insert[] = [
  457. 'purchase_order_special_id' => $purchase_order_id,
  458. 'product_id' => $value['product_id'],
  459. 'order_number' => $order_number,
  460. 'number' => $value['number'],
  461. 'price' => $price,
  462. 'storehouse_id' => $storehouse,
  463. ];
  464. }
  465. PurchaseOrderSpecialInfo::insert($insert);
  466. PurchaseOrderSpecial::where('id',$purchase_order_id)->update(['total' => $product_total]);
  467. $insert_see[] = [
  468. 'data_id' => $purchase_order_id, // 虚拟采购单
  469. 'data_type' => SeeRange::type_ten,
  470. 'param_id' => $depart_id, //门店id
  471. 'type' => SeeRange::data_three,
  472. 'crt_time' => time(),
  473. ];
  474. if(! empty($insert_see)) SeeRange::insert($insert_see);
  475. DB::commit();
  476. }catch (\Throwable $exception){
  477. DB::rollBack();
  478. if (str_contains($exception->getMessage(), '1062') || str_contains($exception->getMessage(), 'Duplicate entry')) {
  479. return [false, '网络波动,请重新操作!'];
  480. }
  481. return [false, $exception->getMessage()];
  482. }
  483. return [true, ''];
  484. }
  485. //分社向总社采购 生成 分社订货合同
  486. public function createPurchaseOrderSales($order,$user){
  487. //没有供应商 不创建合同
  488. if(empty($order['supplier'])) return [true, ''];
  489. //总公司的采购单 不创建合同
  490. $head = $user['head'] ?? [];
  491. $head = $head['id'] ?? 0; //总社id
  492. if($head == $order['top_depart_id']) return [true, ''];
  493. //分社公司的采购单 不向总供应商采购 不创建合同
  494. $is_create = Supplier::where('id',$order['supplier'])->value('is_main');
  495. if(empty($is_create)) return [true, ''];
  496. // $customer_short_name = Depart::where('id',$order['top_depart_id'])->value('id') ?? "";
  497. $prefix = SalesOrder::$prefix[SalesOrder::Model_type_two];
  498. $order_number = OrderNoService::createSalesOrderNumber($prefix);
  499. $product = PurchaseOrderInfo::where('del_time',0)
  500. ->where('purchase_order_id',$order['id'])
  501. ->get()->toArray();
  502. if(empty($product)) return [false, '采购订单产品数据不能为空'];
  503. try{
  504. DB::beginTransaction();
  505. $time = time();
  506. $model = new SalesOrder();
  507. $model->model_type = SalesOrder::Model_type_two;
  508. $model->sales_order_type = SalesOrder::Order_type_two;
  509. $model->customer_id = Customer::special_id;
  510. $model->order_number = $order_number;
  511. $model->crt_id = $order['crt_id'];
  512. $model->depart_id = $head;
  513. $model->top_depart_id = $head;
  514. $model->other_fee = $order['other_fee'];
  515. $model->discount_fee = $order['discount_fee'];
  516. $model->contract_fee = $order['purchase_total'];
  517. $model->contact_order_no = $order['order_number'];
  518. $model->sign_time = $time;
  519. $model->save();
  520. $sales_order_id = $model->id;
  521. //产品字典
  522. $product_map = (new ProductService())->getProductDetail(array_column($product,'product_id'));
  523. $insert = [];
  524. $product_total = 0;
  525. foreach ($product as $value){
  526. $tmp = $product_map[$value['product_id']] ?? [];
  527. $product_total += $value['price'] * $value['number'];
  528. $insert[] = [
  529. 'sales_order_id' => $sales_order_id,
  530. 'product_id' => $value['product_id'],
  531. 'number' => $value['number'],
  532. 'basic_type_id' => $value['basic_type_id'],
  533. 'price' => $value['price'],
  534. 'cost' => $tmp['cost'] ?? 0,
  535. 'retail_price' => $tmp['retail_price'] ?? 0,
  536. 'final_amount' => $value['price'] * $value['number'],
  537. ];
  538. }
  539. $bool = SalesOrderProductInfo::insert($insert);
  540. if(! $bool) return [false,'合同生成失败!'];
  541. //反写数据
  542. $tmp = $product_total + $order['other_fee'];
  543. $tmp = $tmp > 0 ? $tmp : 1;
  544. $rate = ($product_total + $order['other_fee'] - $order['discount_fee']) / $tmp;
  545. SalesOrder::where('id',$sales_order_id)->update([
  546. 'product_total' => $product_total,
  547. 'rate' => $rate
  548. ]);
  549. //生成付款单
  550. $model = new PaymentReceipt();
  551. $model->order_number = (new OrderNoService())->createOrderNumber(PaymentReceipt::prefix);
  552. $model->data_type = PaymentReceipt::data_type_one;
  553. $model->type = PaymentReceipt::type_one;
  554. $model->crt_id = $user['id'];
  555. $model->depart_id = $head;
  556. $model->top_depart_id = $head;
  557. $model->save();
  558. $insert = [];
  559. $insert[] = [
  560. 'payment_receipt_id' => $model->id,
  561. 'data_type' => PaymentReceipt::type_one,
  562. 'data_order_no' => $order_number,
  563. 'data_order_type' => PaymentReceipt::data_type_one,
  564. 'amount' => $order['purchase_total'],
  565. 'type' => PaymentReceiptInfo::type_three,
  566. 'crt_time' => $time,
  567. ];
  568. PaymentReceiptInfo::insert($insert);
  569. DB::commit();
  570. }catch (\Throwable $exception){
  571. DB::rollBack();
  572. if (str_contains($exception->getMessage(), '1062') || str_contains($exception->getMessage(), 'Duplicate entry')) {
  573. return [false, '网络波动,请重新操作!'];
  574. }
  575. return [false ,$exception->getMessage()];
  576. }
  577. return [true,''];
  578. }
  579. //自动生成-----------------------------------
  580. //自动生成删除
  581. //分社订货合同删除
  582. public function delCreatePurchaseOrderSales($data, $order){
  583. $sale_order = SalesOrder::where('del_time',0)
  584. ->where('contact_order_no',$order['order_number'])
  585. ->select('id','order_number')
  586. ->get()->toArray();
  587. if(empty($sale_order)) return [true,''];
  588. foreach ($sale_order as $value){
  589. list($status, $msg) = (new SalesOrderService())->salesOrderDel(['id' => $value['id']]);
  590. if(! $status) return [false,$msg];
  591. $info = PaymentReceiptInfo::where('del_time',0)
  592. ->where('type',PaymentReceiptInfo::type_three)
  593. ->where('data_order_no', $value['order_number'])
  594. ->select('payment_receipt_id')
  595. ->first();
  596. if(! empty($info)){
  597. $payment_id = $info->payment_receipt_id;
  598. list($status, $msg) = (new PaymentReceiptService())->customerDel(['id' => $payment_id]);
  599. if(! $status) return [false,$msg];
  600. }
  601. }
  602. return [true, ''];
  603. }
  604. //自动生成删除
  605. public function confirmSportsBag($data){
  606. $model = SportsBag::where('order_number',$data['order_number'])
  607. ->where('del_time',0)
  608. ->first();
  609. if(empty($model)) return [false, '活动包不存在或已被删除'];
  610. if($model->state != SportsBag::STATE_ONE) return [false, '请确认活动包状态,操作失败'];
  611. if($data['type'] == self::TYPE_ONE){
  612. //通过
  613. $model->state = SportsBag::STATE_TWO;
  614. $model->save();
  615. }else{
  616. //驳回
  617. $model->state = SportsBag::State_minus_one;
  618. $model->save();
  619. }
  620. return [true, $model->toArray()];
  621. }
  622. public function confirmPaymentReceipt($data){
  623. $model = PaymentReceipt::where('order_number',$data['order_number'])
  624. ->where('del_time',0)
  625. ->first();
  626. if(empty($model)) return [false, '收付款单不存在或已被删除'];
  627. if($model->state != PaymentReceipt::STATE_ONE) return [false, '请确认收付款单状态,操作失败'];
  628. if($data['type'] == self::TYPE_ONE){
  629. //通过
  630. $model->state = PaymentReceipt::STATE_TWO;
  631. $model->save();
  632. }else{
  633. //驳回
  634. $model->state = PaymentReceipt::State_minus_one;
  635. $model->save();
  636. }
  637. return [true, $model->toArray()];
  638. }
  639. public function confirmInvoiceOrder($data){
  640. $model = InvoiceOrder::where('order_number',$data['order_number'])
  641. ->where('del_time',0)
  642. ->first();
  643. if(empty($model)) return [false, '发货单不存在或已被删除'];
  644. if($model->state != InvoiceOrder::STATE_ONE) return [false, '请确认发货单状态,操作失败'];
  645. $send_data = [];
  646. if($data['type'] == self::TYPE_ONE){
  647. //通过
  648. $model->state = InvoiceOrder::STATE_TWO;
  649. $model->save();
  650. $sale = SalesOrder::where('id',$model->sales_order_id)->first();
  651. if($sale['sales_order_type'] == SalesOrder::Order_type_one){
  652. //安装件更新发货状态
  653. SalesOrder::where('id',$model->sales_order_id)
  654. ->update(['invoice_state' => SalesOrder::invoice_one]);
  655. }else{
  656. //快递件更新 单据状态 发货状态
  657. SalesOrder::where('id',$model->sales_order_id)
  658. ->update([
  659. 'state' => SalesOrder::State2_one,
  660. 'invoice_state' => SalesOrder::invoice_one
  661. ]);
  662. }
  663. //分社采购单更新发货状态
  664. if(! empty($sale->contact_order_no)) {
  665. $purchase = PurchaseOrder::where('order_number',$sale->contact_order_no)->where('del_time', 0)->first();
  666. if(! empty($purchase)){
  667. $purchase = $purchase->toArray();
  668. if(in_array($purchase['order_type'], [PurchaseOrder::Order_type_three, PurchaseOrder::Order_type_four])) {
  669. //提醒创建人
  670. $emp_tmp = Employee::where('id', $purchase['crt_id'])->value('emp_name');
  671. $send_data[] = [
  672. 'employee_id' => $purchase['crt_id'],
  673. 'type' => 2,
  674. 'state' => 0,
  675. 'menu_id' => 45,
  676. 'order_number' => $purchase['order_number'],
  677. 'tmp_data' => [
  678. $purchase['order_number'],
  679. "分社采购单",
  680. '已发货',
  681. $emp_tmp,
  682. date('Y-m-d H:i:s'),
  683. ],
  684. ];
  685. }
  686. }
  687. PurchaseOrder::where('order_number',$sale->contact_order_no)->update(['invoice_state' => PurchaseOrder::invoice_state_one]);
  688. }
  689. }else{
  690. //驳回
  691. $model->state = InvoiceOrder::STATE_ZERO;
  692. $model->save();
  693. }
  694. (new OaService())->sendWxOaCheckMessage($send_data);
  695. return [true, $model->toArray()];
  696. }
  697. public function recordInvoiceOrder($data, $order){
  698. $result = InvoiceOrderInfo::where('del_time',0)
  699. ->where('order_number',$order['order_number'])
  700. ->get()->toArray();
  701. if(empty($result)) return [false,'发货单产品信息不存在或已被删除'];
  702. $insert = [];
  703. $time = time();
  704. foreach ($result as $value){
  705. $key = $value['product_id'] . $value['storehouse_id'];
  706. if(isset($insert[$key])){
  707. $insert[$key]['number'] += -($value['number']);
  708. }else{
  709. $insert[$key] = [
  710. 'product_id' => $value['product_id'],
  711. 'number' => -($value['number']),
  712. 'order_type' => InvoiceOrder::prefix,
  713. 'order_number' => $order['order_number'],
  714. 'crt_time' => $time,
  715. 'storehouse_id' => $value['storehouse_id'],
  716. 'depart_id' => $order['depart_id'],
  717. 'top_depart_id' => $order['top_depart_id'],
  718. 'price' => $value['price'],
  719. ];
  720. }
  721. }
  722. $insert = array_values($insert);
  723. $bool = InOutRecord::insert($insert);
  724. if(! $bool) return [false,'流水写入失败'];
  725. return [true,''];
  726. }
  727. public function confirmPurchaseOrderState($data){
  728. $model = PurchaseOrder::where('order_number',$data['order_number'])
  729. ->where('del_time',0)
  730. ->first();
  731. if(empty($model)) return [false,'采购单不存在或已被删除'];
  732. if($model->state != PurchaseOrder::STATE_ONE) return [false,'请确认采购单状态,操作失败'];
  733. if($data['type'] == self::TYPE_ONE){
  734. $model->state = PurchaseOrder::STATE_TWO;
  735. $model->save();
  736. }else{
  737. //驳回
  738. $model->state = PurchaseOrder::State_minus_one;
  739. $model->save();
  740. }
  741. return [true, $model->toArray()];
  742. }
  743. public function confirmPurchaseOrder($data,$user){
  744. $model = PurchaseOrder::where('order_number',$data['order_number'])
  745. ->where('del_time',0)
  746. ->first();
  747. if(empty($model)) return [false, '采购订单不存在或已被删除'];
  748. if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购订单状态,操作失败'];
  749. $model->state = PurchaseOrder::STATE_Four;
  750. $model->save();
  751. return [true, $model->toArray()];
  752. }
  753. public function recordPurchaseOrder($data, $order){
  754. $result = PurchaseOrderInfo::where('del_time',0)
  755. ->where('order_number',$order['order_number'])
  756. ->get()->toArray();
  757. if(empty($result)) return [false,'采购单产品信息不存在或已被删除'];
  758. $insert = [];
  759. $time = time();
  760. foreach ($result as $value){
  761. $key = $value['product_id'] . $value['storehouse_id'];
  762. if(isset($insert[$key])){
  763. $insert[$key]['number'] += $value['number'];
  764. }else{
  765. $insert[$key] = [
  766. 'product_id' => $value['product_id'],
  767. 'number' => $value['number'],
  768. 'order_type' => PurchaseOrder::prefix,
  769. 'order_number' => $order['order_number'],
  770. 'crt_time' => $time,
  771. 'storehouse_id' => $value['storehouse_id'],
  772. 'depart_id' => $order['depart_id'],
  773. 'top_depart_id' => $order['top_depart_id'],
  774. 'price' => $value['price'],
  775. ];
  776. }
  777. }
  778. $insert = array_values($insert);
  779. $bool = InOutRecord::insert($insert);
  780. if(! $bool) return [false,'流水写入失败'];
  781. return [true,''];
  782. }
  783. public function confirmPurchaseSpecial($data){
  784. $model = PurchaseOrderSpecial::where('order_number',$data['order_number'])
  785. ->where('del_time',0)
  786. ->first();
  787. if(empty($model)) return [false,'虚拟采购订单不存在或已被删除'];
  788. if($model->state != PurchaseOrderSpecial::STATE_ONE) return [false,'请确认虚拟采购订单状态,操作失败'];
  789. if($data['type'] == self::TYPE_ONE){
  790. $model->state = PurchaseOrderSpecial::STATE_TWO;
  791. $model->save();
  792. }else{
  793. //驳回
  794. $model->state = PurchaseOrderSpecial::State_minus_one;
  795. $model->save();
  796. }
  797. return [true, $model->toArray()];
  798. }
  799. public function confirmConstruction($data){
  800. $model = Construction::where('order_number',$data['order_number'])
  801. ->where('del_time',0)
  802. ->first();
  803. if(empty($model)) return [false, '施工单不存在或已被删除'];
  804. if($model->state != Construction::STATE_ONE) return [false, '请确认施工单状态,操作失败'];
  805. if($data['type'] == self::TYPE_ONE){
  806. $model->state = Construction::STATE_TWO;
  807. $model->save();
  808. //已下施工
  809. SalesOrder::where('id',$model->sales_order_id)->update(['state' => SalesOrder::State_five]);
  810. }else{
  811. //驳回
  812. $model->state = Construction::State_minus_one;
  813. $model->save();
  814. }
  815. return [true, $model->toArray()];
  816. }
  817. public function recordConstruction($data, $order){
  818. //仅施工不需要库存流水
  819. if($order['model_type'] == Construction::Model_type_two) return [true, self::minus_one];
  820. $result = ConstructionProductInfo::where('del_time',0)
  821. ->where('construction_id',$order['id'])
  822. ->get()->toArray();
  823. if(empty($result)) return [false,'施工单产品信息不存在或已被删除'];
  824. $insert = [];
  825. $time = time();
  826. foreach ($result as $value){
  827. $key = $value['product_id'] . $value['storehouse_id'];
  828. if(isset($insert[$key])){
  829. $insert[$key]['number'] += -($value['number']);
  830. }else{
  831. $insert[$key] = [
  832. 'product_id' => $value['product_id'],
  833. 'number' => -($value['number']),
  834. 'order_type' => Construction::$prefix[$order['model_type']] ?? '',
  835. 'order_number' => $order['order_number'],
  836. 'crt_time' => $time,
  837. 'storehouse_id' => $value['storehouse_id'],
  838. 'depart_id' => $order['depart_id'],
  839. 'top_depart_id' => $order['top_depart_id'],
  840. 'price' => $value['price'],
  841. ];
  842. }
  843. }
  844. $insert = array_values($insert);
  845. $bool = InOutRecord::insert($insert);
  846. if(! $bool) return [false,'流水写入失败'];
  847. return [true,''];
  848. }
  849. public function confirmReturnExchangeOrder($data){
  850. $model = ReturnExchangeOrder::where('order_number',$data['order_number'])
  851. ->where('del_time',0)
  852. ->first();
  853. if(empty($model)) return [false, '退换货单不存在或已被删除'];
  854. if($model->state != ReturnExchangeOrder::State_one) return [false, '请确认退换货单状态,操作失败'];
  855. if($data['type'] == self::TYPE_ONE){
  856. $model->state = ReturnExchangeOrder::State_two;
  857. $model->save();
  858. // if($model->data_type == ReturnExchangeOrder::Order_type){
  859. // SalesOrder::where('id', $model->data_id)->update([
  860. // 'state' => SalesOrder::State_six
  861. // ]);
  862. // }
  863. }else{
  864. //驳回
  865. $model->state = ReturnExchangeOrder::State_minus_one;
  866. $model->save();
  867. }
  868. return [true, $model->toArray()];
  869. }
  870. public function recordReturnExchangeOrder($data, $order){
  871. if($order['model_type'] == ReturnExchangeOrder::Model_type_three) return [true, self::minus_one];
  872. // if($order['type'] == ReturnExchangeOrder::Order_type){
  873. // //快递件不记录流水
  874. // $sales_order_type = SalesOrder::where('id',$order['data_id'])->value('sales_order_type');
  875. // if($sales_order_type == SalesOrder::Order_type_two) return [true, self::minus_one];
  876. // }
  877. //合同 退货
  878. $map = $outbound = [];
  879. if($order['type'] == ReturnExchangeOrder::Order_type){
  880. //查找 出库数据的产品
  881. $product = OutBoundOrderInfo::where('del_time',0)
  882. ->where('data_id', $order['data_id'])
  883. ->where('type', OutBoundOrder::out_type_one)
  884. ->whereColumn('number','>','return_number')
  885. ->select('id','product_id','number','return_number','out_bound_id')
  886. ->get()->toArray();
  887. foreach($product as $value){
  888. $map[$value['product_id']][] = $value;
  889. }
  890. //采购占用数量
  891. $purchase = PurchaseOrderInfoForOutBound::where('del_time',0)
  892. ->whereIn('data_id', array_unique(array_column($product,'out_bound_id')))
  893. ->where('type',PurchaseOrderInfoForOutBound::type_one)
  894. ->where('from_order_type',PurchaseOrderInfoForOutBound::from_type_zero)
  895. ->where('is_use',PurchaseOrderInfoForOutBound::is_use)
  896. ->whereColumn('number','>','return_number')
  897. ->get()->toArray();
  898. foreach ($purchase as $value){
  899. $key = $value['data_id'] . $value['product_id'];
  900. $num = bcsub($value['number'],$value['return_number'],2);
  901. if(isset($outbound[$key])){
  902. $tmp = bcadd($num, $outbound[$key]['number'],2);
  903. $outbound[$key]['number'] = $tmp;
  904. }else{
  905. $outbound[$key] = [
  906. 'id' => $value['id'],
  907. 'number' => $num,
  908. ];
  909. }
  910. }
  911. }
  912. $result = ReturnExchangeOrderProductInfo::where('del_time',0)
  913. ->where('return_exchange_id',$order['id'])
  914. ->get()->toArray();
  915. if(empty($result)) return [false,'退换货单产品信息不存在或已被删除'];
  916. $insert = $update = $insert2 = $update2 = [];
  917. $time = time();
  918. foreach ($result as $value){
  919. $key = $value['product_id'] . $value['storehouse_id'];
  920. $prefix = ReturnExchangeOrder::$prefix[$value['return_or_exchange']] ?? '';
  921. if($value['return_or_exchange'] == ReturnExchangeOrderProductInfo::type_one){
  922. //退货
  923. if($order['type'] == ReturnExchangeOrder::Order_type){
  924. $number = 0;
  925. //合同出库数量
  926. $out_array = $map[$value['product_id']] ?? [];
  927. if(empty($out_array)){
  928. //未出库 这个退货不需要加回来 不需要流水
  929. continue;
  930. } else{
  931. foreach ($out_array as $out){
  932. if($value['number'] <= 0) continue;
  933. //剩余能退数量
  934. $out_number = bcsub($out['number'], $out['return_number'],2);
  935. if($out_number >= $value['number']) {
  936. $number = bcadd($value['number'], $number,2);
  937. $t = $value['number'];
  938. $value['number'] = 0;
  939. }else{
  940. $number = bcadd($out_number, $number,2);
  941. $value['number'] = bcsub($value['number'], $out_number,2);
  942. $t = $out_number;
  943. }
  944. //更新数据
  945. $update[] = [
  946. 'id' => $out['id'],
  947. 'return_number' => bcadd($out['return_number'], $t,2),
  948. ];
  949. $insert2[] = [
  950. 'order_number' => $order['order_number'],
  951. 'out_bound_order_info_id' => $out['id'],
  952. 'number' => $t,
  953. 'crt_time' => $time
  954. ];
  955. $out_key = $out['out_bound_id'] . $value['product_id'];
  956. if(isset($outbound[$out_key])){
  957. $num = $outbound[$out_key]['number'];
  958. $id = $outbound[$out_key]['id'];
  959. if($t > $num){
  960. $update2_num = $num;
  961. }else{
  962. $update2_num = $t;
  963. }
  964. if(isset($update2[$id])){
  965. $update2[$id] = bcadd($update2_num, $update2[$id],2);
  966. }else{
  967. $update2[$id] = $update2_num;
  968. }
  969. }
  970. }
  971. }
  972. }else{
  973. // 采购
  974. $number = -($value['number']);
  975. }
  976. if(isset($insert[$key])){
  977. $insert[$key]['number'] += $number;
  978. }else{
  979. $insert[$key] = [
  980. 'product_id' => $value['product_id'],
  981. 'number' => $number,
  982. 'order_type' => $prefix,
  983. 'order_number' => $order['order_number'],
  984. 'crt_time' => $time,
  985. 'storehouse_id' => $value['storehouse_id'],
  986. 'depart_id' => $order['depart_id'],
  987. 'top_depart_id' => $order['top_depart_id'],
  988. 'price' => $value['return_exchange_price'],
  989. ];
  990. }
  991. }
  992. }
  993. $insert = array_values($insert);
  994. if(empty($insert)) return [true, self::minus_one];
  995. $bool = InOutRecord::insert($insert);
  996. if(! $bool) return [false,'流水写入失败'];
  997. if(! empty($insert2)) ReturnExchangeOrderForOutboundInfo::insert($insert2);
  998. if(! empty($update)){
  999. foreach ($update as $value){
  1000. OutBoundOrderInfo::where('id', $value['id'])
  1001. ->update(['return_number' => $value['return_number']]);
  1002. }
  1003. }
  1004. if(! empty($update2)){
  1005. foreach ($update2 as $key => $value){
  1006. $insert3[] = [
  1007. 'order_number' => $order['order_number'],
  1008. 'purchase_order_info_id' => $key,
  1009. 'number' => $value,
  1010. 'crt_time' => $time
  1011. ];
  1012. PurchaseOrderInfoForOutBound::where('id', $key)
  1013. ->lockForUpdate()
  1014. ->update([
  1015. 'return_number' => DB::raw('return_number + ('. $value . ')'),
  1016. ]);
  1017. }
  1018. if(! empty($insert3)) PurchaseOrderInfoForOutboundInfo::insert($insert3);
  1019. }
  1020. return [true,''];
  1021. }
  1022. public function confirmInventory($data){
  1023. $model = Inventory::where('order_number',$data['order_number'])
  1024. ->where('del_time',0)
  1025. ->first();
  1026. if(empty($model)) return [false,'盘点单不存在或已被删除'];
  1027. if($model->state != Inventory::STATE_ONE) return [false,'请确认盘点单状态,操作失败'];
  1028. if($data['type'] == self::TYPE_ONE){
  1029. $model->state = Inventory::STATE_TWO;
  1030. $model->save();
  1031. }else{
  1032. //驳回
  1033. $model->state = Inventory::State_minus_one;
  1034. $model->save();
  1035. }
  1036. return [true, $model->toArray()];
  1037. }
  1038. public function confirmOut($data){
  1039. $model = OutBoundOrder::where('order_number',$data['order_number'])
  1040. ->where('del_time',0)
  1041. ->first();
  1042. if(empty($model)) return [false,'出库单不存在或已被删除'];
  1043. if($model->state != OutBoundOrder::STATE_ONE) return [false,'请确认出库单状态,操作失败'];
  1044. if($data['type'] == self::TYPE_ONE){
  1045. $model->state = OutBoundOrder::STATE_TWO;
  1046. $model->save();
  1047. }else{
  1048. //驳回
  1049. $model->state = OutBoundOrder::State_minus_one;
  1050. $model->save();
  1051. }
  1052. return [true, $model->toArray()];
  1053. }
  1054. public function confirmProductAdjustment($data){
  1055. $model = ProductAdjustment::where('order_number',$data['order_number'])
  1056. ->where('del_time',0)
  1057. ->first();
  1058. if(empty($model)) return [false,'产品金额调整单不存在或已被删除'];
  1059. if($model->state != ProductAdjustment::STATE_ONE) return [false,'请确认产品金额调整单状态,操作失败'];
  1060. if($data['type'] == self::TYPE_ONE){
  1061. $model->state = ProductAdjustment::STATE_TWO;
  1062. $model->save();
  1063. }else{
  1064. //驳回
  1065. $model->state = ProductAdjustment::State_minus_one;
  1066. $model->save();
  1067. }
  1068. return [true, $model->toArray()];
  1069. }
  1070. public function recordInventory($data, $order){
  1071. $result = InventorySub::where('del_time',0)
  1072. ->where('inventory_id',$order['id'])
  1073. ->get()->toArray();
  1074. if(empty($result)) return [false,'盘点单明细信息不存在或已被删除'];
  1075. $prefix = Inventory::prefix;
  1076. $insert = [];
  1077. $time = time();
  1078. foreach ($result as $value){
  1079. $key = $value['product_id'] . $value['storehouse_id'];
  1080. $number = $value['final_num'];
  1081. if(isset($insert[$key])){
  1082. $insert[$key]['number'] += $number;
  1083. }else{
  1084. $insert[$key] = [
  1085. 'product_id' => $value['product_id'],
  1086. 'number' => $number,
  1087. 'order_type' => $prefix,
  1088. 'order_number' => $order['order_number'],
  1089. 'crt_time' => $time,
  1090. 'storehouse_id' => $value['storehouse_id'],
  1091. 'depart_id' => $order['depart_id'],
  1092. 'top_depart_id' => $order['top_depart_id'],
  1093. 'price' => $value['price'],
  1094. ];
  1095. }
  1096. }
  1097. $bool = InOutRecord::insert($insert);
  1098. if(! $bool) return [false,'流水写入失败'];
  1099. return [true,''];
  1100. }
  1101. public function recordOut($data, $order){
  1102. $result = PurchaseOrderInfoForOutBound::where('del_time',0)
  1103. ->where('data_id',$order['id'])
  1104. ->where('type',PurchaseOrderInfoForOutBound::type_one)
  1105. ->where('is_use',PurchaseOrderInfoForOutBound::is_not_use)
  1106. ->get()->toArray();
  1107. if(empty($result)) return [false,'出库单明细信息不存在或已被删除'];
  1108. $prefix = OutBoundOrder::prefix;
  1109. $insert = $tmp = [];
  1110. $time = time();
  1111. foreach ($result as $value){
  1112. $key = $value['product_id'] . $value['storehouse_id'];
  1113. $number = -($value['number']);
  1114. if(isset($insert[$key])){
  1115. $insert[$key]['number'] += $number;
  1116. }else{
  1117. $insert[$key] = [
  1118. 'product_id' => $value['product_id'],
  1119. 'number' => $number,
  1120. 'order_type' => $prefix,
  1121. 'order_number' => $order['order_number'],
  1122. 'crt_time' => $time,
  1123. 'storehouse_id' => $value['storehouse_id'],
  1124. 'depart_id' => $order['depart_id'],
  1125. 'top_depart_id' => $order['top_depart_id'],
  1126. 'price' => $value['price'],
  1127. ];
  1128. }
  1129. if(empty($value['purchase_order_id'])){
  1130. //没采购或盘点入库信息 则加入一条记录平流水
  1131. $tmp[] = [
  1132. 'product_id' => $value['product_id'],
  1133. 'number' => $value['number'],
  1134. 'order_type' => PurchaseOrderInfoForOutBound::prefix,
  1135. 'order_number' => $order['order_number'],
  1136. 'crt_time' => $time,
  1137. 'storehouse_id' => $value['storehouse_id'],
  1138. 'depart_id' => $order['depart_id'],
  1139. 'top_depart_id' => $order['top_depart_id'],
  1140. 'price' => $value['price'],
  1141. ];
  1142. }
  1143. }
  1144. $insert_final = array_merge_recursive(array_values($insert),$tmp);
  1145. $bool = InOutRecord::insert($insert_final);
  1146. if(! $bool) return [false, '流水写入失败'];
  1147. //更新采购出库占用
  1148. PurchaseOrderInfoForOutBound::where('del_time',0)
  1149. ->where('data_id',$order['id'])
  1150. ->where('type',PurchaseOrderInfoForOutBound::type_one)
  1151. ->where('is_use',PurchaseOrderInfoForOutBound::is_not_use)
  1152. ->update(['is_use' => PurchaseOrderInfoForOutBound::is_use]);
  1153. return [true, ''];
  1154. }
  1155. public function recordProductAdjustment($data, $order){
  1156. $result = ProductAdjustmentSub::where('del_time',0)
  1157. ->where('product_adjustment_id', $order['id'])
  1158. ->select('product_id','storehouse_id','final_amount')
  1159. ->get()->toArray();
  1160. if(empty($result)) return [false, "产品调整单明细数据不能为空"];
  1161. $time = time();
  1162. $prefix = ProductAdjustment::prefix;
  1163. $insert = [];
  1164. foreach ($result as $value){
  1165. $key = $value['product_id'] . $value['storehouse_id'];
  1166. if(isset($insert[$key])){
  1167. $price = bcadd($insert[$key]['price'], $value['final_amount'],2);
  1168. $insert[$key]['price'] = $price;
  1169. }else{
  1170. $insert[$key] = [
  1171. 'product_id' => $value['product_id'],
  1172. 'number' => 0,
  1173. 'order_type' => $prefix,
  1174. 'order_number' => $order['order_number'],
  1175. 'crt_time' => $time,
  1176. 'storehouse_id' => $value['storehouse_id'],
  1177. 'depart_id' => $order['depart_id'],
  1178. 'top_depart_id' => $order['top_depart_id'],
  1179. 'price' => $value['final_amount'],
  1180. ];
  1181. }
  1182. }
  1183. $bool = InOutRecord::insert($insert);
  1184. if(! $bool) return [false, '流水写入失败'];
  1185. return [true, self::minus_one];
  1186. }
  1187. public function settleSalesOrder($data,$user){
  1188. $model = SalesOrder::where('order_number', $data['order_number'])
  1189. ->where('del_time',0)
  1190. ->first();
  1191. if(empty($model)) return [false, '合同不存在或已被删除'];
  1192. //安装件
  1193. if($model->state < SalesOrder::State_four || $model->state >= SalesOrder::State_seven) return [false, '请确认合同状态,操作失败'];
  1194. SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])
  1195. ->update(['state' => SalesOrder::State_seven]);
  1196. $time = time();
  1197. $insert = [];
  1198. $new = [];
  1199. if(! empty($data['img'])){
  1200. foreach ($data['img'] as $value){
  1201. $insert[] = [
  1202. 'sales_order_id' => $model->id,
  1203. 'data_id' => 0,
  1204. 'type' => SalesOrderInfo::type_seven,
  1205. 'file' => $value,
  1206. 'crt_time' => $time,
  1207. ];
  1208. $new[] = $value;
  1209. }
  1210. }
  1211. if(! empty($data['mark'])){
  1212. $insert[] = [
  1213. 'sales_order_id' => $model->id,
  1214. 'data_id' => $user['id'],
  1215. 'type' => SalesOrderInfo::type_eight,
  1216. 'file' => $data['mark'],
  1217. 'crt_time' => $time,
  1218. ];
  1219. }
  1220. if(! empty($insert)) SalesOrderInfo::insert($insert);
  1221. return [true, ['file' => $new, 'order' => $model->toArray()]];
  1222. }
  1223. public function settleSalesOrderCustomer($data,$user){
  1224. $model = SalesOrder::where('order_number', $data['order_number'])
  1225. ->where('del_time',0)
  1226. ->first();
  1227. if(empty($model)) return [false, '合同不存在或已被删除'];
  1228. if(empty($data['img'])) return [false,'图片不能为空'];
  1229. //安装件
  1230. if($model->state != SalesOrder::State_seven) return [false, '请确认合同状态,操作失败'];
  1231. SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])
  1232. ->update(['state' => SalesOrder::State_eight]);
  1233. SalesOrderInfo::insert([
  1234. 'sales_order_id' => $model->id,
  1235. 'type' => SalesOrderInfo::type_six,
  1236. 'file' => $data['img'],
  1237. 'crt_time' => time(),
  1238. ]);
  1239. return [true, $model->toArray()];
  1240. }
  1241. public function settleSalesOrderConfirm($data,$user){
  1242. $model = SalesOrder::where('order_number', $data['order_number'])
  1243. ->where('del_time',0)
  1244. ->first();
  1245. if(empty($model)) return [false, '合同不存在或已被删除'];
  1246. //安装件
  1247. if($model->state != SalesOrder::State_four) return [false, '请确认合同状态,操作失败'];
  1248. $model->is_confirm = 1;
  1249. $model->save();
  1250. $depart = SeeRange::where('del_time',0)
  1251. ->where('data_id', $model->id)
  1252. ->where('data_type',SeeRange::type_seven)
  1253. ->where('type',SeeRange::data_three)
  1254. ->first();
  1255. if(! empty($depart)){
  1256. $depart = $depart->toArray();
  1257. $channel_id = Depart::where('id',$depart['param_id'])->value('channel_id');
  1258. if(! empty($channel_id)){
  1259. $emp_name = Employee::where('id',$channel_id)->value('emp_name');
  1260. $send_data[] = [
  1261. 'employee_id' => $channel_id,
  1262. 'type' => 2,
  1263. 'state' => 0,
  1264. 'menu_id' => 37,
  1265. 'order_number' => $model->order_number,
  1266. 'tmp_data' => [
  1267. $model->order_number,
  1268. "派单合同",
  1269. "门店接收派单",
  1270. $emp_name,
  1271. date('Y-m-d H:i:s'),
  1272. ],
  1273. ];
  1274. (new OaService())->sendWxOaCheckMessage($send_data);
  1275. }
  1276. }
  1277. return [true, $model->toArray()];
  1278. }
  1279. public function settleSalesOrderConfirmBack($data,$user){
  1280. $model = SalesOrder::where('order_number', $data['order_number'])
  1281. ->where('del_time',0)
  1282. ->first();
  1283. if(empty($model)) return [false, '合同不存在或已被删除'];
  1284. //安装件
  1285. if($model->state != SalesOrder::State_four) return [false, '请确认合同状态,操作失败'];
  1286. //校验施工
  1287. $bool = Construction::where('del_time',0)
  1288. ->where('sales_order_id', $model->id)
  1289. ->exists();
  1290. if($bool) return [false,'合同已生成施工单,操作失败'];
  1291. if($model->is_confirm != 1) return [false, '合同未接受派单,操作失败'];
  1292. $model->is_confirm = 0;
  1293. $model->save();
  1294. //单据状态还原
  1295. SalesOrder::where('del_time',0)->where('id', $model->id)->update([
  1296. 'state' => SalesOrder::State_three,
  1297. 'dispatch_time_second' => 0,
  1298. 'dispatch_time_second_id' => 0,
  1299. ]);
  1300. SeeRange::where('del_time',0)
  1301. ->where('data_id', $model->id)
  1302. ->where('data_type',SeeRange::type_seven)
  1303. ->where('type',SeeRange::data_three)
  1304. ->update(['del_time' => time()]);
  1305. return [true, $model->toArray()];
  1306. }
  1307. public function confirmSales($data){
  1308. $model = SalesOrder::where('order_number', $data['order_number'])
  1309. ->where('del_time',0)
  1310. ->first();
  1311. if(empty($model)) return [false, '合同不存在或已被删除'];
  1312. if($model->state != SalesOrder::State_one) return [false, '请确认合同状态,操作失败'];
  1313. if($data['type'] == self::TYPE_ONE){
  1314. $state = SalesOrder::State_three;
  1315. if(in_array($model->model_type,[SalesOrder::Model_type_four,SalesOrder::Model_type_seven])){
  1316. //线上订单 补贴订单
  1317. $state = SalesOrder::State_two;
  1318. }
  1319. $model->state = $state;
  1320. $model->save();
  1321. }else{
  1322. $model->state = SalesOrder::State_minus_one;
  1323. $model->save();
  1324. }
  1325. return [true, $model->toArray()];
  1326. }
  1327. public function reject_sales($data){
  1328. $model = SalesOrder::where('order_number', $data['order_number'])
  1329. ->where('del_time',0)
  1330. ->first();
  1331. if(empty($model)) return [false, '合同不存在或已被删除'];
  1332. if($model->out_state > SalesOrder::out_zero) return [false, '合同已提交出库,操作失败'];
  1333. //安装件
  1334. if(in_array($model->model_type,[SalesOrder::Model_type_four,SalesOrder::Model_type_seven])){
  1335. //线上订单 补贴订单
  1336. if($model->state != SalesOrder::State_two) return [false, '请确认合同状态,操作失败'];
  1337. }else{
  1338. //除线上订单 补贴订单 之外
  1339. if($model->state != SalesOrder::State_three) return [false, '请确认合同状态,操作失败'];
  1340. }
  1341. //未确认
  1342. $model->state = SalesOrder::State_zero;
  1343. $model->save();
  1344. return [true, $model->toArray()];
  1345. }
  1346. public function reject_purchase($data){
  1347. $model = PurchaseOrder::where('order_number', $data['order_number'])
  1348. ->where('del_time',0)
  1349. ->first();
  1350. if(empty($model)) return [false, '采购单不存在或已被删除'];
  1351. //安装件
  1352. if($model->state != PurchaseOrder::STATE_Four) return [false, '请确认采购单状态,操作失败'];
  1353. $model->state = PurchaseOrder::STATE_TWO;
  1354. $model->save();
  1355. return [true, $model->toArray()];
  1356. }
  1357. public function reject_purchase_special($data){
  1358. $model = PurchaseOrderSpecial::where('order_number', $data['order_number'])
  1359. ->where('del_time',0)
  1360. ->first();
  1361. if(empty($model)) return [false, '虚拟采购订单不存在或已被删除'];
  1362. //安装件
  1363. if($model->state != PurchaseOrderSpecial::STATE_TWO) return [false, '请确认虚拟采购订单状态,操作失败'];
  1364. $model->state = PurchaseOrder::STATE_ZERO;
  1365. $model->save();
  1366. return [true, $model->toArray()];
  1367. }
  1368. public function reject_purchase_confirm($data){
  1369. $model = PurchaseOrder::where('order_number', $data['order_number'])
  1370. ->where('del_time',0)
  1371. ->first();
  1372. if(empty($model)) return [false, '采购单不存在或已被删除'];
  1373. //安装件
  1374. if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购单状态,操作失败'];
  1375. $model->state = PurchaseOrder::STATE_ZERO;
  1376. $model->save();
  1377. return [true, $model->toArray()];
  1378. }
  1379. public function reject_construction($data){
  1380. $model = Construction::where('order_number', $data['order_number'])
  1381. ->where('del_time',0)
  1382. ->first();
  1383. if(empty($model)) return [false, '施工单不存在或已被删除'];
  1384. //安装件
  1385. if($model->state != Construction::STATE_TWO) return [false, '请确认施工单状态,操作失败'];
  1386. $model->state = Construction::STATE_ZERO;
  1387. $model->save();
  1388. return [true, $model->toArray()];
  1389. }
  1390. public function reject_payment_receipt($data){
  1391. $model = PaymentReceipt::where('order_number', $data['order_number'])
  1392. ->where('del_time',0)
  1393. ->first();
  1394. if(empty($model)) return [false, '收付款单不存在或已被删除'];
  1395. if($model->state != PaymentReceipt::STATE_TWO) return [false, '请确认收付款单状态,操作失败'];
  1396. $model->state = PaymentReceipt::STATE_ZERO;
  1397. $model->save();
  1398. return [true, $model->toArray()];
  1399. }
  1400. public function reject_sports_bag($data){
  1401. $model = SportsBag::where('order_number', $data['order_number'])
  1402. ->where('del_time',0)
  1403. ->first();
  1404. if(empty($model)) return [false, '活动包不存在或已被删除'];
  1405. if($model->state != SportsBag::STATE_TWO) return [false, '请确认活动包状态,操作失败'];
  1406. $model->state = SportsBag::STATE_ZERO;
  1407. $model->save();
  1408. return [true, $model->toArray()];
  1409. }
  1410. public function reject_return_exchange($data){
  1411. $model = ReturnExchangeOrder::where('order_number', $data['order_number'])
  1412. ->where('del_time',0)
  1413. ->first();
  1414. if(empty($model)) return [false, '退换货单不存在或已被删除'];
  1415. if($model->state != ReturnExchangeOrder::State_two) return [false, '请确认退换货单状态,操作失败'];
  1416. $model->state = ReturnExchangeOrder::State_zero;
  1417. $model->save();
  1418. return [true, $model->toArray()];
  1419. }
  1420. public function reject_record_construction($data,$order){
  1421. //仅施工不需要库存流水
  1422. if($order['model_type'] == Construction::Model_type_two) return [true, self::minus_one];
  1423. //获取单据最新数据时间 正常施工数据
  1424. $crt_time = 0;
  1425. $latest = InOutRecord::where('del_time',0)
  1426. ->where('order_number',$data['order_number'])
  1427. ->where('number','<',0)
  1428. ->select('crt_time')
  1429. ->orderBy('crt_time', 'desc')
  1430. ->first();
  1431. if(! empty($latest)) $crt_time = $latest->crt_time;
  1432. $result = InOutRecord::where('del_time',0)
  1433. ->where('crt_time',$crt_time)
  1434. ->where('order_number',$data['order_number'])
  1435. ->where('number','<',0)
  1436. ->select('product_id','storehouse_id','number','depart_id','order_number','top_depart_id','order_type','price')
  1437. ->get()->toArray();
  1438. if(empty($result)) return [false,'施工出库流水数据未找到'];
  1439. //生成对冲数据
  1440. $time = time();
  1441. foreach ($result as $key => $value){
  1442. $result[$key]['number'] = abs($value['number']);
  1443. $result[$key]['crt_time'] = $time;
  1444. }
  1445. $bool = InOutRecord::insert($result);
  1446. if(! $bool) return [false,'流水写入失败'];
  1447. //写入流水
  1448. return [true, ''];
  1449. }
  1450. public function reject_record_purchase($data,$order){
  1451. //获取单据最新数据时间 正常采购入库数据
  1452. $crt_time = 0;
  1453. $latest = InOutRecord::where('del_time',0)
  1454. ->where('order_number',$data['order_number'])
  1455. ->where('number','>',0)
  1456. ->select('crt_time')
  1457. ->orderBy('crt_time', 'desc')
  1458. ->first();
  1459. if(! empty($latest)) $crt_time = $latest->crt_time;
  1460. $result = InOutRecord::where('del_time',0)
  1461. ->where('crt_time',$crt_time)
  1462. ->where('order_number',$data['order_number'])
  1463. ->where('number','>',0)
  1464. ->select('product_id','storehouse_id','number','depart_id','order_number','top_depart_id','order_type','price')
  1465. ->get()->toArray();
  1466. if(empty($result)) return [false,'采购入库流水数据未找到'];
  1467. //生成对冲数据
  1468. $time = time();
  1469. foreach ($result as $key => $value){
  1470. $result[$key]['number'] = - $value['number'];
  1471. $result[$key]['crt_time'] = $time;
  1472. }
  1473. $bool = InOutRecord::insert($result);
  1474. if(! $bool) return [false,'流水写入失败'];
  1475. //写入流水
  1476. return [true, ''];
  1477. }
  1478. public function reject_record_return_exchange($data,$order){
  1479. if($order['model_type'] == ReturnExchangeOrder::Model_type_three) return [true, self::minus_one];
  1480. //获取单据最新数据时间 正常退换货流水数据
  1481. $crt_time = 0;
  1482. $latest = InOutRecord::where('del_time',0)
  1483. ->where('order_number',$data['order_number'])
  1484. ->select('crt_time')
  1485. ->orderBy('crt_time', 'desc')
  1486. ->first();
  1487. if(! empty($latest)) $crt_time = $latest->crt_time;
  1488. $result = InOutRecord::where('del_time',0)
  1489. ->where('crt_time',$crt_time)
  1490. ->where('order_number',$data['order_number'])
  1491. ->select('product_id','storehouse_id','number','depart_id','order_number','top_depart_id','order_type','price')
  1492. ->get()->toArray();
  1493. if(empty($result)) return [true, self::minus_one];
  1494. //生成对冲数据
  1495. $time = time();
  1496. foreach ($result as $key => $value){
  1497. $result[$key]['number'] = - $value['number'];
  1498. $result[$key]['crt_time'] = $time;
  1499. }
  1500. $bool = InOutRecord::insert($result);
  1501. if(! $bool) return [false, '流水写入失败'];
  1502. $info = ReturnExchangeOrderForOutboundInfo::where('del_time',0)
  1503. ->where('order_number',$data['order_number'])
  1504. ->get()->toArray();
  1505. if(! empty($info)){
  1506. foreach ($info as $value){
  1507. //出库单占用出库数量解放
  1508. OutBoundOrderInfo::where('id',$value['out_bound_order_info_id'])
  1509. ->lockForUpdate()
  1510. ->update([
  1511. 'return_number' => DB::raw('return_number - ('. $value['number'] . ')'),
  1512. ]);
  1513. }
  1514. //记录信息标记删除
  1515. ReturnExchangeOrderForOutboundInfo::where('del_time',0)
  1516. ->where('order_number',$data['order_number'])
  1517. ->update(['del_time' => $time]);
  1518. }
  1519. $info = PurchaseOrderInfoForOutboundInfo::where('del_time',0)
  1520. ->where('order_number',$data['order_number'])
  1521. ->get()->toArray();
  1522. if(! empty($info)){
  1523. foreach ($info as $value){
  1524. //退换货退合同 合同占用的采购或盘点占用出库数量解放
  1525. PurchaseOrderInfoForOutBound::where('id',$value['purchase_order_info_id'])
  1526. ->lockForUpdate()
  1527. ->update([
  1528. 'return_number' => DB::raw('return_number - ('. $value['number'] . ')'),
  1529. ]);
  1530. }
  1531. //记录信息标记删除
  1532. PurchaseOrderInfoForOutboundInfo::where('del_time',0)
  1533. ->where('order_number',$data['order_number'])
  1534. ->update(['del_time' => $time]);
  1535. }
  1536. //写入流水
  1537. return [true, ''];
  1538. }
  1539. public function getOrderDetail($data,$user){
  1540. if(empty($data['order_number'])) return [false,'必传参数不能为空'];
  1541. $array = [];
  1542. foreach (Construction::$prefix as $value){
  1543. $array[$value] = "\App\Service\\ConstructionService";
  1544. }
  1545. foreach (ReturnExchangeOrder::$prefix as $value){
  1546. $array[$value] = "\App\Service\\ReturnExchangeOrderService";
  1547. }
  1548. foreach (SalesOrder::$prefix as $value){
  1549. $array[$value] = "\App\Service\\SalesOrderService";
  1550. }
  1551. $status = true;
  1552. $msg = [];
  1553. foreach ($array as $key => $value){
  1554. if(strpos($data['order_number'],$key) !== false) {
  1555. list($status, $msg) = (new $value)->detail($data,$user);
  1556. return [$status, $msg];
  1557. }
  1558. }
  1559. if(strpos($data['order_number'],PurchaseOrder::prefix) !== false){
  1560. $service = "\App\Service\\PurchaseOrderService";
  1561. list($status, $msg) = (new $service)->detail($data,$user);
  1562. return [$status, $msg];
  1563. }
  1564. return [$status, $msg];
  1565. }
  1566. public function checkAll($data,$user){
  1567. if(empty($data['id']) || empty($data['order_number'])|| empty($data['opt_case'])) return [false,'必传参数不能为空或者参数值错误!'];
  1568. list($status,$msg) = $this->limitingSendRequestBackgExpire($data['order_number'].$data['opt_case']);
  1569. if(! $status) return [false,$msg];
  1570. //走审批流 单据校验
  1571. $function_check = self::$opt_1case_check[$data['opt_case']] ?? '';
  1572. //走审批流 单据状态改为待审批方法
  1573. $function = self::$opt_1case[$data['opt_case']] ?? '';
  1574. //单据不走审批流
  1575. $function2 = self::$finished[$data['opt_case']] ?? '';
  1576. try{
  1577. DB::beginTransaction();
  1578. //不走审批流,更新完直接返回
  1579. if($function2) {
  1580. list($bool,$msg) = $this->$function2($data,$user);
  1581. if($bool) {
  1582. $file = [];
  1583. if(isset($msg['order'])){
  1584. $order = $msg['order'];
  1585. $file = $msg['file'];
  1586. } else{
  1587. $order = $msg;
  1588. }
  1589. list($bool,$err) = $this->createRecordAndInventoryMy($data,$user,$order);
  1590. if($bool){
  1591. DB::commit();
  1592. if(! empty($file)) return [true, ['file' => ['new' => $file]]];
  1593. return [true, ''];
  1594. }else{
  1595. DB::rollBack();
  1596. return [false, $err];
  1597. }
  1598. }else{
  1599. DB::rollBack();
  1600. return [false, $msg];
  1601. }
  1602. }
  1603. //需要审批流,校验
  1604. if($function_check){
  1605. list($bool,$msg) = $this->$function_check($data, $user);
  1606. if(! $bool){
  1607. DB::rollBack();
  1608. return [false, $msg];
  1609. }
  1610. }
  1611. //需要审批流,从未审核变成待审核
  1612. if($function){
  1613. list($bool,$msg) = $this->$function($data);
  1614. if(! $bool){
  1615. DB::rollBack();
  1616. return [false, $msg];
  1617. }
  1618. //创建审批流
  1619. $args = [
  1620. 'order_no' => $data['order_number'],
  1621. 'menu_id' => $data['menu_id'] ?? 0,
  1622. 'opt_case' => $data['opt_case'],
  1623. 'order' => $msg,
  1624. ];
  1625. $oa = new OaService($user);
  1626. list($bool,$msg) = $oa->createOaOrder($args);
  1627. if(! $bool) {
  1628. DB::rollBack();
  1629. if($msg) return [false,$msg];
  1630. }
  1631. }
  1632. DB::commit();
  1633. return [true, ''];
  1634. }catch (\Throwable $exception){
  1635. DB::rollBack();
  1636. return [false, $exception->getMessage() . $exception->getFile(). $exception->getLine()];
  1637. }
  1638. }
  1639. //更新库存
  1640. public function changeInventory($data,$order,$user){
  1641. $number_symbol = "";
  1642. if(in_array($data['opt_case'],self::$in_opt)){
  1643. $number_symbol = ">";
  1644. }elseif (in_array($data['opt_case'],self::$out_opt)){
  1645. $number_symbol = "<";
  1646. }
  1647. //获取单据最新数据时间 正常审核的数据
  1648. $latest = InOutRecord::where('del_time',0)
  1649. ->where('order_number',$order['order_number'])
  1650. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1651. return $query->where('number', $number_symbol,0);
  1652. })
  1653. ->select('crt_time')
  1654. ->orderBy('crt_time', 'desc')
  1655. ->first();
  1656. $model = InOutRecord::where('del_time',0)
  1657. ->where('order_number',$order['order_number'])
  1658. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1659. return $query->where('number', $number_symbol,0);
  1660. })
  1661. ->select('number','crt_time','product_id','storehouse_id','top_depart_id');
  1662. if(! empty($latest)) {
  1663. $t = $latest->toArray();
  1664. $model->where('crt_time',$t['crt_time']);
  1665. }
  1666. $record = $model->get()->toArray();
  1667. if (empty($record)) return [false,'流水记录不存在'];
  1668. $top_depart_id = Storehouse::where('id', $order['storehouse_id'])->value('top_depart_id');
  1669. $result = $lock_number = [];
  1670. foreach ($record as $value){
  1671. $key = $value['product_id'] . $value['storehouse_id'];
  1672. if(isset($result[$key])){
  1673. $result[$key]['number'] += $value['number'];
  1674. }else{
  1675. $result[$key] = [
  1676. 'product_id' => $value['product_id'],
  1677. 'number' => $value['number'],
  1678. 'crt_time' => $value['crt_time'],
  1679. 'storehouse_id' => $value['storehouse_id'],
  1680. 'top_depart_id' => $top_depart_id,
  1681. ];
  1682. }
  1683. if($value['number'] < 0){
  1684. if(isset($lock_number[$key])){
  1685. $lock_number[$key] += $value['number'];
  1686. }else{
  1687. $lock_number[$key] = $value['number'];
  1688. }
  1689. }
  1690. }
  1691. //是否校验库存 是的话锁定数量要更新(根据当前操作人所在门店是否校验库存)
  1692. // $lock = $user['is_check_stock'];
  1693. $lock = ProductInventorySet::type_one;
  1694. $for_lock = OrderInventoryStock::where('order_number',$order['order_number'])
  1695. ->where('del_time',0)
  1696. ->orderBy('id','desc')
  1697. ->first();
  1698. if(! empty($for_lock)) {
  1699. $for_lock = $for_lock->toArray();
  1700. $lock = $for_lock['is_check_stock'];
  1701. }
  1702. $result = array_values($result);
  1703. foreach ($result as $key => $value){
  1704. $keys = $value['product_id'] . $value['storehouse_id'];
  1705. $m = ProductInventory::where('product_id',$value['product_id'])
  1706. ->where('storehouse_id',$value['storehouse_id'])
  1707. ->select('product_id','number','storehouse_id')
  1708. ->first();
  1709. if(empty($m)){
  1710. ProductInventory::insert($result[$key]);
  1711. }else{
  1712. //锁定数量
  1713. $lock_number_tmp = 0;
  1714. if($lock == ProductInventorySet::type_one && ! empty($lock_number[$keys])) $lock_number_tmp = $lock_number[$keys];
  1715. ProductInventory::where('product_id',$m->product_id)
  1716. ->where('storehouse_id',$m->storehouse_id)
  1717. ->lockForUpdate()
  1718. ->update([
  1719. 'number' => DB::raw('number + ('. $value['number'] . ')'),
  1720. 'lock_number' => DB::raw('lock_number + ('. $lock_number_tmp . ')')
  1721. ]);
  1722. }
  1723. }
  1724. return [true,''];
  1725. }
  1726. //业务单据审批通过后 驳回 更新库存
  1727. public function changeInventoryReject($data,$order,$user){
  1728. $number_symbol = "";
  1729. if(in_array($data['opt_case'],self::$in_opt)){
  1730. $number_symbol = "<";
  1731. }elseif (in_array($data['opt_case'],self::$out_opt)){
  1732. $number_symbol = ">";
  1733. }
  1734. //获取单据最新数据时间 正常审核的数据
  1735. $latest = InOutRecord::where('del_time',0)
  1736. ->where('order_number',$order['order_number'])
  1737. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1738. return $query->where('number', $number_symbol,0);
  1739. })
  1740. ->select('crt_time')
  1741. ->orderBy('crt_time', 'desc')
  1742. ->first();
  1743. $model = InOutRecord::where('del_time',0)
  1744. ->where('order_number',$order['order_number'])
  1745. ->when(! empty($number_symbol), function ($query) use ($number_symbol) {
  1746. return $query->where('number', $number_symbol,0);
  1747. })
  1748. ->select('number','crt_time','product_id','storehouse_id','top_depart_id');
  1749. if(! empty($latest)) {
  1750. $t = $latest->toArray();
  1751. $model->where('crt_time',$t['crt_time']);
  1752. }
  1753. $record = $model->get()->toArray();
  1754. if (empty($record)) return [false,'流水记录不存在'];
  1755. $top_depart_id = Storehouse::where('id', $order['storehouse_id'])->value('top_depart_id');
  1756. $result = $lock_number = [];
  1757. foreach ($record as $value){
  1758. $key = $value['product_id'] . $value['storehouse_id'];
  1759. if(isset($result[$key])){
  1760. $result[$key]['number'] += $value['number'];
  1761. }else{
  1762. $result[$key] = [
  1763. 'product_id' => $value['product_id'],
  1764. 'number' => $value['number'],
  1765. 'crt_time' => $value['crt_time'],
  1766. 'storehouse_id' => $value['storehouse_id'],
  1767. 'top_depart_id' => $top_depart_id,
  1768. ];
  1769. }
  1770. if($value['number'] > 0){
  1771. if(isset($lock_number[$key])){
  1772. $lock_number[$key] += $value['number'];
  1773. }else{
  1774. $lock_number[$key] = $value['number'];
  1775. }
  1776. }
  1777. }
  1778. //是否校验库存 是的话锁定数量要更新(根据当前操作人所在门店是否校验库存)
  1779. $lock = $user['is_check_stock'];
  1780. $result = array_values($result);
  1781. foreach ($result as $key => $value){
  1782. $keys = $value['product_id'] . $value['storehouse_id'];
  1783. $m = ProductInventory::where('product_id',$value['product_id'])
  1784. ->where('storehouse_id',$value['storehouse_id'])
  1785. ->select('product_id','number','storehouse_id')
  1786. ->first();
  1787. if(empty($m)){
  1788. ProductInventory::insert($result[$key]);
  1789. }else{
  1790. //锁定数量
  1791. $lock_number_tmp = 0;
  1792. if($lock == ProductInventorySet::type_one && ! empty($lock_number[$keys])) $lock_number_tmp = $lock_number[$keys];
  1793. ProductInventory::where('product_id',$m->product_id)
  1794. ->where('storehouse_id',$m->storehouse_id)
  1795. ->lockForUpdate()
  1796. ->update([
  1797. 'number' => DB::raw('number + ('. $value['number'] . ')'),
  1798. 'lock_number' => DB::raw('lock_number + ('. $lock_number_tmp . ')')
  1799. ]);
  1800. }
  1801. }
  1802. return [true,''];
  1803. }
  1804. public function createRecordAndInventory($data = []){
  1805. if(empty($data['type']) || empty($data['opt_case']) || empty($data['order_number'])) return [false, '传递参数缺少'];
  1806. $user = $data['user_data'] ?? [];
  1807. if($data['type'] == self::TYPE_THREE){
  1808. //通过后弃审
  1809. if(! isset(self::$opt_case_reject[$data['opt_case']])) return [false, '该操作不存在'];
  1810. //具体方法
  1811. $function = self::$opt_case_reject[$data['opt_case']];
  1812. //流水
  1813. $function2 = self::$reject_record[$data['opt_case']] ?? '';
  1814. //自动生成删除
  1815. $function3 = self::$create_del[$data['opt_case']] ?? '';
  1816. try{
  1817. DB::beginTransaction();
  1818. //更新单据的状态
  1819. list($bool,$msg) = $this->$function($data);
  1820. if(! $bool){
  1821. DB::rollBack();
  1822. return [false, $msg];
  1823. }
  1824. $order = $msg;
  1825. if($function3){
  1826. list($boolean,$msg) = $this->$function3($data,$order);
  1827. if(! $boolean) {
  1828. DB::rollBack();
  1829. return [false, $msg];
  1830. }
  1831. }
  1832. if($function2) {
  1833. //流水
  1834. list($boolean,$msg) = $this->$function2($data,$order);
  1835. if(! $boolean) {
  1836. DB::rollBack();
  1837. return [false, $msg];
  1838. }
  1839. if($msg != self::minus_one){
  1840. //库存
  1841. list($bool,$msg) = $this->changeInventoryReject($data,$order,$user);
  1842. if(! $bool){
  1843. DB::rollBack();
  1844. return [false, $msg];
  1845. }
  1846. }
  1847. }
  1848. if(! empty(self::$operation_order_reject[$data['opt_case']])){
  1849. $type = self::$operation_order_reject[$data['opt_case']];
  1850. (new OrderOperationService())->add([
  1851. 'order_number' => $order['order_number'],
  1852. 'msg' => OrderOperation::$type[$type],
  1853. 'type' => $type
  1854. ],$user);
  1855. }
  1856. DB::commit();
  1857. return [true, ''];
  1858. }catch (\Throwable $exception){
  1859. DB::rollBack();
  1860. return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];
  1861. }
  1862. }else{
  1863. //具体方法
  1864. $function = self::$opt_case[$data['opt_case']] ?? "";
  1865. $record = self::$record[$data['opt_case']] ?? "";
  1866. $create = self::$create[$data['opt_case']] ?? "";
  1867. try{
  1868. DB::beginTransaction();
  1869. list($bool,$msg) = $this->$function($data);
  1870. if(! $bool){
  1871. DB::rollBack();
  1872. return [false, $msg];
  1873. }
  1874. $order = $msg;
  1875. if($data['type'] == self::TYPE_ONE){
  1876. if($record) {
  1877. //流水
  1878. list($bool,$msg) = $this->$record($data, $order);
  1879. if(! $bool) {
  1880. DB::rollBack();
  1881. return [false, $msg];
  1882. }
  1883. if($msg != self::minus_one){
  1884. //库存
  1885. list($bool,$msg) = $this->changeInventory($data, $order, $user);
  1886. if(! $bool) {
  1887. DB::rollBack();
  1888. return [false, $msg];
  1889. }
  1890. }
  1891. }
  1892. if($create) {
  1893. list($bool,$msg) = $this->$create($order,$user);
  1894. if(! $bool) {
  1895. DB::rollBack();
  1896. return [false, $msg];
  1897. }
  1898. }
  1899. }
  1900. if(! empty(self::$operation_order[$data['opt_case']])){
  1901. $user = $data['user_data'] ?? [];
  1902. $type = self::$operation_order[$data['opt_case']];
  1903. (new OrderOperationService())->add([
  1904. 'order_number' => $order['order_number'],
  1905. 'msg' => OrderOperation::$type[$type],
  1906. 'type' => $type
  1907. ],$user);
  1908. }
  1909. DB::commit();
  1910. return [true, ''];
  1911. }catch (\Throwable $exception){
  1912. DB::rollBack();
  1913. return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];
  1914. }
  1915. }
  1916. }
  1917. //不需要走审批流 直接调用
  1918. public function createRecordAndInventoryMy($data = [],$user = [],$order = []){
  1919. if(! empty($data['type']) && $data['type'] == self::TYPE_THREE){
  1920. }else{
  1921. //具体方法
  1922. $record = self::$record[$data['opt_case']] ?? "";
  1923. $create = self::$create[$data['opt_case']] ?? "";
  1924. try{
  1925. DB::beginTransaction();
  1926. if($record) {
  1927. //流水
  1928. list($bool,$msg) = $this->$record($data, $order);
  1929. if(! $bool) {
  1930. DB::rollBack();
  1931. return [false, $msg];
  1932. }
  1933. if($msg != self::minus_one){
  1934. //库存
  1935. list($bool,$msg) = $this->changeInventory($data, $order, $user);
  1936. if(! $bool) {
  1937. DB::rollBack();
  1938. return [false, $msg];
  1939. }
  1940. }
  1941. }
  1942. if($create) {
  1943. list($bool,$msg) = $this->$create($order,$user);
  1944. if(! $bool) {
  1945. DB::rollBack();
  1946. return [false, $msg];
  1947. }
  1948. }
  1949. if(! empty(self::$operation_order[$data['opt_case']])){
  1950. $type = self::$operation_order[$data['opt_case']];
  1951. (new OrderOperationService())->add([
  1952. 'order_number' => $order['order_number'],
  1953. 'msg' => OrderOperation::$type[$type],
  1954. 'type' => $type
  1955. ],$user);
  1956. }
  1957. DB::commit();
  1958. return [true, ''];
  1959. }catch (\Throwable $exception){
  1960. DB::rollBack();
  1961. return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];
  1962. }
  1963. }
  1964. }
  1965. public function orderInventoryInsert($insert){
  1966. if(empty($insert['order_number'])) return;
  1967. $model = new OrderInventoryStock();
  1968. $model->order_number = $insert['order_number'];
  1969. $model->is_check_stock = $insert['is_check_stock'];
  1970. $model->save();
  1971. }
  1972. }