SalesOrderService.php 112 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612
  1. <?php
  2. namespace App\Service;
  3. use App\Model\BasicType;
  4. use App\Model\BookingList;
  5. use App\Model\Construction;
  6. use App\Model\Customer;
  7. use App\Model\CustomerInfo;
  8. use App\Model\Depart;
  9. use App\Model\Employee;
  10. use App\Model\FollowUpRecord;
  11. use App\Model\InvoiceOrder;
  12. use App\Model\OrderOperation;
  13. use App\Model\OutBoundOrderInfo;
  14. use App\Model\PaymentReceipt;
  15. use App\Model\PaymentReceiptInfo;
  16. use App\Model\Product;
  17. use App\Model\ProductCategory;
  18. use App\Model\ProductSnInfo;
  19. use App\Model\PurchaseOrder;
  20. use App\Model\ReturnExchangeOrder;
  21. use App\Model\ReturnExchangeOrderProductInfo;
  22. use App\Model\SalesOrder;
  23. use App\Model\SalesOrderInfo;
  24. use App\Model\SalesOrderOtherFee;
  25. use App\Model\SalesOrderProductInfo;
  26. use App\Model\SeeRange;
  27. use App\Model\SportsBag;
  28. use App\Model\SportsBagProductInfo;
  29. use App\Model\Storehouse;
  30. use App\Model\U8Job;
  31. use App\Model\WxEmployee;
  32. use App\Service\Weixin\WxSendMessageService;
  33. use Carbon\Carbon;
  34. use Illuminate\Database\Eloquent\Builder;
  35. use Illuminate\Support\Facades\DB;
  36. /**
  37. * 订单管理
  38. */
  39. class SalesOrderService extends Service
  40. {
  41. public function refundOption($data, $user){
  42. if(empty($data['sales_order_ids'])) return [false, 'sales_order_ids参数不能为空'];
  43. SalesOrder::whereIn('id',$data['sales_order_ids'])
  44. ->update(['is_refund' => 1]);
  45. return [true, ''];
  46. }
  47. /**
  48. * 订单编辑
  49. * @param $data
  50. * @param $user
  51. * @return array
  52. */
  53. public function salesOrderEdit($data,$user){
  54. list($status,$msg) = $this->salesOrderRule($data, $user, false);
  55. if(!$status) return [$status,$msg];
  56. $params = $this->getDataFile($data);
  57. (new OperationLogService())->setOperationList($params,$user,2);
  58. try {
  59. DB::beginTransaction();
  60. $model = SalesOrder::where('id', $data['id'])->first();
  61. $model->sales_order_type = $data['sales_order_type'];
  62. $model->model_type = $data['model_type'];
  63. $model->order_number = $data['order_number'];
  64. $model->selling_price = $data['selling_price'] ?? 0;
  65. $model->vin_no = $data['vin_no'] ?? '';
  66. $model->plat_type = $data['plat_type'] ?? 0;
  67. $model->plat_order = $data['plat_order'] ?? '';
  68. $model->order_type = $data['order_type'] ?? 0;
  69. $model->install_method = $data['install_method'] ?? 0;
  70. $model->install_position = $data['install_position'] ?? 0;
  71. $model->customer_id = $data['customer_id'] ?? 0;
  72. $model->customer_short_name = $data['customer_short_name'] ?? 0;
  73. $model->customer_contact = $data['customer_contact'] ?? "";
  74. $model->sign_time = $data['sign_time'] ?? 0;
  75. $model->product_total = $data['product_total'] ?? 0;
  76. $model->rate = $data['rate'] ?? 0;
  77. $model->mark = $data['mark'] ?? '';
  78. $model->construction_time = $data['construction_time'] ?? 0;
  79. $model->handover_time = $data['handover_time'] ?? 0;
  80. $model->other_fee = $data['other_fee'] ?? 0;
  81. $model->discount_fee = $data['discount_fee'] ?? 0;
  82. $model->contract_fee = $data['contract_fee'] ?? 0;
  83. $model->pay_way = $data['pay_way'] ?? 0;
  84. $model->car_type = $data['car_type'] ?? 0;
  85. $model->year = $data['year'] ?? '';
  86. $model->mileage = $data['mileage'] ?? '';
  87. $model->color = $data['color'] ?? '';
  88. $model->original_set = $data['original_set'] ?? '';
  89. $model->processing = $data['processing'] ?? '';
  90. $model->cdefine29 = $data['cdefine29'] ?? "";//分社施工
  91. $model->cdefine32 = $data['cdefine32'] ?? "";//达人昵称
  92. $model->cdefine30 = $data['cdefine30'] ?? "";//业务员
  93. $model->save();
  94. $time = time();
  95. SalesOrderInfo::where('del_time',0)
  96. ->where('sales_order_id',$data['id'])
  97. ->update(['del_time' => $time]);
  98. SalesOrderProductInfo::where('del_time',0)
  99. ->where('sales_order_id',$data['id'])
  100. ->update(['del_time' => $time]);
  101. if(! empty($data['employee_one'])){
  102. $insert = [];
  103. foreach ($data['employee_one'] as $value){
  104. $insert[] = [
  105. 'sales_order_id' => $model->id,
  106. 'data_id' => $value,
  107. 'type' => SalesOrderInfo::type_one,
  108. 'crt_time' => $time,
  109. ];
  110. }
  111. SalesOrderInfo::insert($insert);
  112. }
  113. if(! empty($data['employee_two'])){
  114. $insert = [];
  115. foreach ($data['employee_two'] as $value){
  116. $insert[] = [
  117. 'sales_order_id' => $model->id,
  118. 'data_id' => $value,
  119. 'type' => SalesOrderInfo::type_two,
  120. 'crt_time' => $time,
  121. ];
  122. }
  123. SalesOrderInfo::insert($insert);
  124. }
  125. if(! empty($data['employee_three'])){
  126. $insert = [];
  127. foreach ($data['employee_three'] as $value){
  128. $insert[] = [
  129. 'sales_order_id' => $model->id,
  130. 'data_id' => $value,
  131. 'type' => SalesOrderInfo::type_three,
  132. 'crt_time' => $time,
  133. ];
  134. }
  135. SalesOrderInfo::insert($insert);
  136. }
  137. if(! empty($data['product'])){
  138. $insert = [];
  139. foreach ($data['product'] as $value){
  140. $sports_bag_product_info_id = 0;
  141. if(! empty($value['sports_bag_id'])) $sports_bag_product_info_id = empty($value['id']) ? 0 : $value['id'];
  142. $insert[] = [
  143. 'sales_order_id' => $model->id,
  144. 'product_id' => $value['product_id'] ?? 0,
  145. 'number' => $value['number'] ?? 0,
  146. 'cost' => $value['cost'] ?? 0,
  147. 'retail_price' => $value['retail_price'] ?? 0,
  148. 'mark' => $value['mark'] ?? '',
  149. 'crt_time' => $time,
  150. 'basic_type_id' => $value['basic_type_id'],
  151. 'price' => $value['price'] ?? 0,
  152. 'final_amount' => $value['final_amount'] ?? 0,
  153. 'sports_bag_id' => $value['sports_bag_id'] ?? 0,
  154. 'sports_bag_product_info_id' => $sports_bag_product_info_id,
  155. 'rate' => $value['rate'] ?? 0,
  156. 'number_2' => $value['number_2'] ?? 0,
  157. ];
  158. }
  159. SalesOrderProductInfo::insert($insert);
  160. }
  161. // $new = [];
  162. // if(! empty($data['file'])){
  163. // $insert = [];
  164. // foreach ($data['file'] as $value){
  165. // $insert[] = [
  166. // 'sales_order_id' => $model->id,
  167. // 'file' => $value['url'],
  168. // 'name' => $value['name'],
  169. // 'type' => SalesOrderInfo::type_four,
  170. // 'crt_time' => $time,
  171. // ];
  172. // $new[] = $value['url'];
  173. // }
  174. // SalesOrderInfo::insert($insert);
  175. // }
  176. // $new = $old = [];
  177. // $order = PaymentReceipt::where('del_time',0)
  178. // ->where('crt_time',$model->crt_time)
  179. // ->where('data_order_no',$data['order_number'])
  180. // ->first();
  181. // if(! empty($order)){
  182. // $old = PaymentReceiptInfo::where('del_time',0)
  183. // ->where('payment_receipt_id',$order->id)
  184. // ->whereIn('type',[PaymentReceiptInfo::type_one])
  185. // ->select('file')
  186. // ->get()->toArray();
  187. // $old = array_column($old,'file');
  188. // }
  189. //
  190. // //收付款信息
  191. // if(! empty($data['payment_receipt'])){
  192. // if(empty($order)){
  193. // $this->savePaymentReceiptOrder($data,$user,$time);
  194. // }else{
  195. // PaymentReceiptInfo::where('del_time',0)
  196. // ->where('payment_receipt_id',$order->id)
  197. // ->update(['del_time' => $time]);
  198. // $this->savePaymentReceiptOrder($data,$user,$time,$order);
  199. // }
  200. // }
  201. DB::commit();
  202. }catch (\Exception $exception){
  203. DB::rollBack();
  204. return [false,$exception->getMessage()];
  205. }
  206. // $this->delStorageFile($old, $new);
  207. if(! empty($data['check'])) {
  208. list($status,$msg) = (new CheckService())->checkAll([
  209. "id" => $data['id'],
  210. "order_number" => $data['order_number'],
  211. "opt_case" => CheckService::eight,
  212. "menu_id" => $data['menu_id']
  213. ],$user);
  214. if(! $status) return [true, '保存成功,合同确认失败,异常信息:' . $msg];
  215. }
  216. return [true,''];
  217. }
  218. /**
  219. * 产品新增
  220. * @param $data
  221. * @param $user
  222. * @return array
  223. */
  224. public function salesOrderAdd($data,$user){
  225. list($status,$msg) = $this->salesOrderRule($data,$user);
  226. if(!$status) return [$status,$msg];
  227. try {
  228. DB::beginTransaction();
  229. $time = time();
  230. $model = new SalesOrder();
  231. $model->sales_order_type = $data['sales_order_type'];
  232. $model->model_type = $data['model_type'];
  233. $model->order_number = $data['order_number'];
  234. $model->selling_price = $data['selling_price'] ?? 0;
  235. $model->vin_no = $data['vin_no'] ?? '';
  236. $model->plat_type = $data['plat_type'] ?? 0;
  237. $model->plat_order = $data['plat_order'] ?? '';
  238. $model->order_type = $data['order_type'] ?? 0;
  239. $model->install_method = $data['install_method'] ?? 0;
  240. $model->install_position = $data['install_position'] ?? 0;
  241. $model->customer_id = $data['customer_id'] ?? 0;
  242. $model->customer_short_name = $data['customer_short_name'] ?? 0;
  243. $model->customer_contact = $data['customer_contact'] ?? "";
  244. $model->sign_time = $data['sign_time'] ?? 0;
  245. $model->product_total = $data['product_total'] ?? 0;
  246. $model->rate = $data['rate'] ?? 0;
  247. $model->mark = $data['mark'] ?? '';
  248. $model->construction_time = $data['construction_time'] ?? 0;
  249. $model->handover_time = $data['handover_time'] ?? 0;
  250. $model->other_fee = $data['other_fee'] ?? 0;
  251. $model->discount_fee = $data['discount_fee'] ?? 0;
  252. $model->contract_fee = $data['contract_fee'] ?? 0;
  253. $model->pay_way = $data['pay_way'] ?? 0;
  254. $model->car_type = $data['car_type'] ?? 0;
  255. $model->year = $data['year'] ?? '';
  256. $model->mileage = $data['mileage'] ?? '';
  257. $model->color = $data['color'] ?? '';
  258. $model->original_set = $data['original_set'] ?? '';
  259. $model->processing = $data['processing'] ?? '';
  260. $model->cdefine29 = $data['cdefine29'] ?? "";//分社施工
  261. $model->cdefine32 = $data['cdefine32'] ?? "";//达人昵称
  262. $model->cdefine30 = $data['cdefine30'] ?? "";//业务员
  263. $model->depart_id = $data['depart_id'] ?? 0;
  264. $model->top_depart_id = $data['top_depart_id'] ?? 0;
  265. $model->crt_id = $user['id'];
  266. $model->crt_time = $time;
  267. $model->save();
  268. if(! empty($data['employee_one'])){
  269. $insert = [];
  270. foreach ($data['employee_one'] as $value){
  271. $insert[] = [
  272. 'sales_order_id' => $model->id,
  273. 'data_id' => $value,
  274. 'type' => SalesOrderInfo::type_one,
  275. 'crt_time' => $time,
  276. ];
  277. }
  278. SalesOrderInfo::insert($insert);
  279. }
  280. if(! empty($data['employee_two'])){
  281. $insert = [];
  282. foreach ($data['employee_two'] as $value){
  283. $insert[] = [
  284. 'sales_order_id' => $model->id,
  285. 'data_id' => $value,
  286. 'type' => SalesOrderInfo::type_two,
  287. 'crt_time' => $time,
  288. ];
  289. }
  290. SalesOrderInfo::insert($insert);
  291. }
  292. if(! empty($data['employee_three'])){
  293. $insert = [];
  294. foreach ($data['employee_three'] as $value){
  295. $insert[] = [
  296. 'sales_order_id' => $model->id,
  297. 'data_id' => $value,
  298. 'type' => SalesOrderInfo::type_three,
  299. 'crt_time' => $time,
  300. ];
  301. }
  302. SalesOrderInfo::insert($insert);
  303. }
  304. // if(! empty($data['file'])){
  305. // $insert = [];
  306. // foreach ($data['file'] as $value){
  307. // $insert[] = [
  308. // 'sales_order_id' => $model->id,
  309. // 'file' => $value['url'],
  310. // 'name' => $value['name'],
  311. // 'type' => SalesOrderInfo::type_four,
  312. // 'crt_time' => $time,
  313. // ];
  314. // }
  315. // SalesOrderInfo::insert($insert);
  316. // }
  317. if(! empty($data['product'])){
  318. $insert = [];
  319. foreach ($data['product'] as $value){
  320. $sports_bag_product_info_id = 0;
  321. if(! empty($value['sports_bag_id'])) $sports_bag_product_info_id = empty($value['id']) ? 0 : $value['id'];;
  322. $insert[] = [
  323. 'sales_order_id' => $model->id,
  324. 'product_id' => $value['product_id'] ?? 0,
  325. 'number' => $value['number'] ?? 0,
  326. 'cost' => $value['cost'] ?? 0,
  327. 'retail_price' => $value['retail_price'] ?? 0,
  328. 'mark' => $value['mark'] ?? '',
  329. 'crt_time' => $time,
  330. 'basic_type_id' => $value['basic_type_id'] ?? 0,
  331. 'price' => $value['price'] ?? 0,
  332. 'final_amount' => $value['final_amount'] ?? 0,
  333. 'sports_bag_id' => $value['sports_bag_id'] ?? 0,
  334. 'sports_bag_product_info_id' => $sports_bag_product_info_id,
  335. 'rate' => $value['rate'] ?? 0,
  336. 'number_2' => $value['number_2'] ?? 0,
  337. ];
  338. }
  339. SalesOrderProductInfo::insert($insert);
  340. }
  341. //收付款信息
  342. if(! empty($data['payment_receipt']['order_number'])) $this->savePaymentReceiptOrder($data,$user,$time);
  343. DB::commit();
  344. }catch (\Exception $exception){
  345. DB::rollBack();
  346. if (str_contains($exception->getMessage(), '1062') || str_contains($exception->getMessage(), 'Duplicate entry')) {
  347. return [false, '合同编号或收付款单编号已存在,请重新获取!'];
  348. }
  349. return [false,$exception->getLine().':'.$exception->getMessage()];
  350. }
  351. (new OperationLogService())->setOperationList($data,$user);
  352. if(! empty($data['check'])) {
  353. list($status,$msg) = (new CheckService())->checkAll([
  354. "id" => $model->id,
  355. "order_number" => $data['order_number'],
  356. "opt_case" => CheckService::eight,
  357. "menu_id" => $data['menu_id']
  358. ],$user);
  359. if(! $status) return [true, '保存成功,合同确认失败,异常信息:' . $msg];
  360. }
  361. return [true,''];
  362. }
  363. public function savePaymentReceiptOrder($data,$user,$time,$orders = null){
  364. $order = $data['payment_receipt'];
  365. if(empty($orders)){
  366. $model = new PaymentReceipt();
  367. $model->order_number = $order['order_number'];
  368. // $model->data_order_no = $data['order_number'];
  369. $model->data_type = $order['data_type'];
  370. $model->type = $order['type'];
  371. $model->account = $order['account'] ?? 0;
  372. $model->pay_way = $order['pay_way'] ?? 0;
  373. // $model->amount = $order['amount'] ?? 0;
  374. $model->mark = $order['mark'] ?? '';
  375. $model->crt_id = $user['id'];
  376. $model->depart_id = $data['depart_id'];
  377. $model->top_depart_id = $data['top_depart_id'];
  378. $model->payment_receipt_date = $order['payment_receipt_date'] ?? 0;
  379. $model->crt_time = $time;
  380. $model->save();
  381. $new = [];
  382. if(! empty($order['file'])){
  383. $insert = [];
  384. foreach ($order['file'] as $value){
  385. $insert[] = [
  386. 'payment_receipt_id' => $model->id,
  387. 'file' => $value['url'],
  388. 'type' => PaymentReceiptInfo::type_one,
  389. 'name' => $value['name'],
  390. 'crt_time' => $time,
  391. ];
  392. if(! empty($value['url'])) $new[] = $value['url'];
  393. }
  394. PaymentReceiptInfo::insert($insert);
  395. }
  396. if(! empty($order['employee_one'])){
  397. $insert = [];
  398. foreach ($order['employee_one'] as $value){
  399. $insert[] = [
  400. 'payment_receipt_id' => $model->id,
  401. 'data_id' => $value,
  402. 'type' => PaymentReceiptInfo::type_two,
  403. 'crt_time' => $time,
  404. ];
  405. }
  406. PaymentReceiptInfo::insert($insert);
  407. }
  408. $insert = [];
  409. $insert[] = [
  410. 'payment_receipt_id' => $model->id,
  411. 'data_type' => $order['type'],
  412. 'data_order_no' => $data['order_number'],
  413. 'data_order_type' => $order['data_type'],
  414. 'amount' => $order['amount'],
  415. 'type' => PaymentReceiptInfo::type_three,
  416. 'crt_time' => $time,
  417. ];
  418. PaymentReceiptInfo::insert($insert);
  419. if(! empty($new)) (new FileUploadService())->createOssUpload($new);
  420. }else{
  421. $order = $data['payment_receipt'];
  422. $orders->type = $order['type'];
  423. $orders->account = $order['account'] ?? 0;
  424. $orders->pay_way = $order['pay_way'] ?? 0;
  425. $orders->amount = $order['amount'] ?? 0;
  426. $orders->mark = $order['mark'] ?? '';
  427. $orders->payment_receipt_date = $order['payment_receipt_date'] ?? 0;
  428. $orders->save();
  429. if(! empty($order['file'])){
  430. $insert = [];
  431. foreach ($order['file'] as $value){
  432. $insert[] = [
  433. 'payment_receipt_id' => $orders->id,
  434. 'file' => $value['url'],
  435. 'type' => PaymentReceiptInfo::type_one,
  436. 'name' => $value['name'],
  437. 'crt_time' => $time,
  438. ];
  439. $new[] = $value['url'];
  440. }
  441. PaymentReceiptInfo::insert($insert);
  442. }
  443. if(! empty($order['employee_one'])){
  444. $insert = [];
  445. foreach ($order['employee_one'] as $value){
  446. $insert[] = [
  447. 'payment_receipt_id' => $orders->id,
  448. 'data_id' => $value,
  449. 'type' => PaymentReceiptInfo::type_two,
  450. 'crt_time' => $time,
  451. ];
  452. }
  453. PaymentReceiptInfo::insert($insert);
  454. }
  455. }
  456. }
  457. /**
  458. * 订单删除
  459. * @param $data
  460. * @return array
  461. */
  462. public function salesOrderDel($data){
  463. if(empty($data['id']) && empty($data['order_number'])) return [false,'请选择数据!'];
  464. if(! empty($data['id'])){
  465. $sale_order = SalesOrder::where('del_time',0)
  466. ->where('id',$data['id'])
  467. ->first();
  468. }else{
  469. $sale_order = SalesOrder::where('del_time',0)
  470. ->where('order_number',$data['order_number'])
  471. ->first();
  472. $data['id'] = empty($sale_order->id) ? 0 : $sale_order->id;
  473. }
  474. if(empty($sale_order)) return [false,'合同不存在或已被删除'];
  475. $sale_order = $sale_order->toArray();
  476. if($sale_order['state'] > 0) return [false,'请确认合同状态,删除失败'];
  477. $bool = PaymentReceiptInfo::where('del_time',0)
  478. ->where('type',PaymentReceiptInfo::type_three)
  479. ->where('data_order_no', $sale_order['order_number'])
  480. ->exists();
  481. if($bool) return [false, '合同已存在收付款单记录,请先删除收付款单据!'];
  482. try {
  483. DB::beginTransaction();
  484. SalesOrder::where('del_time',0)
  485. ->where('id',$data['id'])->update(['del_time'=> time()]);
  486. // $old = SalesOrderInfo::where('del_time',0)
  487. // ->where('sales_order_id',$data['id'])
  488. // ->whereIn('type',[SalesOrderInfo::type_four])
  489. // ->select('file')
  490. // ->get()->toArray();
  491. // $old = array_column($old,'file');
  492. SalesOrderInfo::where('del_time',0)
  493. ->where('sales_order_id',$data['id'])
  494. ->update(['del_time' => time()]);
  495. SalesOrderProductInfo::where('del_time',0)
  496. ->where('sales_order_id',$data['id'])
  497. ->update(['del_time' => time()]);
  498. SalesOrderOtherFee::where('del_time',0)
  499. ->where('sales_order_id',$data['id'])
  500. ->update(['del_time' => time()]);
  501. (new RangeService())->RangeDelete($data['id'],SeeRange::type_seven);
  502. DB::commit();
  503. }catch (\Exception $exception){
  504. DB::rollBack();
  505. return [false,$exception->getMessage()];
  506. }
  507. // $this->delStorageFile($old);
  508. return [true,''];
  509. }
  510. /**
  511. * 订单详情
  512. * @param $data
  513. * @return array
  514. */
  515. public function detail($data,$user){
  516. if(empty($data['id']) && empty($data['order_number'])) return [false,'请选择数据!'];
  517. $is_flag = isset($data['invoice_state']) ? 1 : 0;
  518. if(! empty($data['id'])){
  519. $sales = SalesOrder::where('del_time',0)
  520. ->where('id',$data['id'])
  521. ->first();
  522. }else{
  523. $sales = SalesOrder::where('del_time',0)
  524. ->where('order_number',$data['order_number'])
  525. ->first();
  526. $data['id'] = empty($sales->id) ? 0 : $sales->id;
  527. }
  528. if(empty($sales)) return [false,'合同不存在或已被删除'];
  529. $sales = $sales->toArray();
  530. if($is_flag && $sales['invoice_state']) return [false, '合同已发货'];
  531. $take_address = $take_man = $take_phone = "";
  532. $purchase = PurchaseOrder::where('del_time',0)
  533. ->where('order_number',$sales['contact_order_no'])
  534. ->first();
  535. if(! empty($purchase)){
  536. $purchase = $purchase->toArray();
  537. $depart = Depart::where('id', $purchase['top_depart_id'])->first();
  538. if(! empty($depart)) {
  539. $depart = $depart->toArray();
  540. $take_address = $depart['title'];
  541. $employee = Employee::where('id', $depart['notify_id'])->first();
  542. if(! empty($employee)){
  543. $employee = $employee->toArray();
  544. $take_man = $employee['emp_name'];
  545. $take_phone = $employee['mobile'];
  546. }
  547. }
  548. }
  549. $sales['take_address'] = $take_address;
  550. $sales['take_man'] = $take_man;
  551. $sales['take_phone'] = $take_phone;
  552. if($sales['dispatch_time_second'] > 0){
  553. $see = SeeRange::where('del_time',0)
  554. ->where('data_id',$sales['id'])
  555. ->where('data_type',SeeRange::type_seven)
  556. ->where('type',SeeRange::data_three)
  557. ->select('param_id')
  558. ->first();
  559. $top_depart_id = $see->param_id ?? 0;
  560. $sales['storehouse_id'] = Storehouse::where('del_time', 0)->where('top_depart_id', $top_depart_id)->value('id') ?? 0;
  561. }else{
  562. $sales['storehouse_id'] = Storehouse::where('del_time', 0)->where('top_depart_id', $sales['top_depart_id'])->value('id') ?? 0;
  563. }
  564. $is_add_construction = 0;
  565. if($sales['top_depart_id'] == $user['head']['id']){
  566. if($sales['state'] >= SalesOrder::State_four && $sales['state'] < SalesOrder::State_seven) $is_add_construction = 1;
  567. }else{
  568. if($sales['state'] >= SalesOrder::State_two && $sales['state'] < SalesOrder::State_seven) $is_add_construction = 1;
  569. }
  570. $sales['add_construction'] = $is_add_construction;
  571. $customer = Customer::where('id',$sales['customer_id'])->value('title');
  572. $sales['customer_title'] = $customer ?? '';
  573. $customer_contact_id = $contact_type_id = 0;
  574. $customer_contact = CustomerInfo::where('del_time',0)
  575. ->where('customer_id',$sales['customer_id'])
  576. ->where('contact_info', $sales['customer_contact'])
  577. ->where('type',CustomerInfo::type_one)
  578. ->first();
  579. if(! empty($customer_contact)){
  580. $customer_contact = $customer_contact->toArray();
  581. $customer_contact_id = $customer_contact['id'];
  582. $contact_type_id = $customer_contact['contact_type'];
  583. }
  584. $sales['customer_contact_id'] = $customer_contact_id;
  585. $sales['contact_type_id'] = $contact_type_id;
  586. $sales['contact_type_title'] = BasicType::where('id',$contact_type_id)->value('title');
  587. $sales['sales_order_type_title'] = SalesOrder::$order_type[$sales['sales_order_type']] ?? '';
  588. $sales['type_title'] = SalesOrder::$build_state[$sales['type']] ?? '';
  589. $sales['is_dispatch'] = $sales['dispatch_time_second'] ? 1 : 0;
  590. $sales['activity_product'] = $sales['file'] = $sales['employee_one'] = $sales['employee_two'] = $sales['employee_three'] = $sales['product'] = $sales['dispatch_depart_one'] = $sales['dispatch_employee'] = $sales['dispatch_depart_two'] = [];
  591. $array = [
  592. $sales['plat_type'],
  593. $sales['order_type'],
  594. $sales['car_type'],
  595. $sales['pay_way'],
  596. $sales['install_method'],
  597. $sales['install_position'],
  598. $sales['customer_short_name'],
  599. ];
  600. $basic_map = BasicType::whereIn('id',$array)
  601. ->pluck('title','id')
  602. ->toArray();
  603. $sales['crt_name'] = Employee::where('id',$sales['crt_id'])->value('emp_name');
  604. $sales = [$sales];
  605. //订单状态数据组织
  606. $state_array = $this->getStateMake($sales);
  607. //分派的总社或分社
  608. $dispatch = $this->getDispatchData($sales);
  609. foreach ($sales as $key => $value){
  610. $sales[$key]['state_title'] = $this->makeState($value, $state_array);
  611. $sales[$key]['plat_type_title'] = $basic_map[$value['plat_type']] ?? '';
  612. $sales[$key]['order_type_title'] = $basic_map[$value['order_type']] ?? '';
  613. $sales[$key]['car_type_title'] = $basic_map[$value['car_type']] ?? '';
  614. $sales[$key]['pay_way_title'] = $basic_map[$value['pay_way']] ?? '';
  615. $sales[$key]['install_method_title'] = $basic_map[$value['install_method']] ?? '';
  616. $sales[$key]['install_position_title'] = $basic_map[$value['install_position']] ?? '';
  617. $sales[$key]['customer_short_name_title'] = $basic_map[$value['customer_short_name']] ?? '';
  618. }
  619. $sales = $sales[0];
  620. $show = "";
  621. $dispatch_company = $dispatch[$sales['id']] ?? '';
  622. if($dispatch_company){
  623. if($sales['is_confirm']){
  624. $show = $dispatch_company . '已接收';
  625. }else{
  626. $show = '待' . $dispatch_company . '接收';
  627. }
  628. }
  629. $sales['wx_show'] = $show;
  630. $sales_info = SalesOrderInfo::where('del_time',0)
  631. ->where('sales_order_id',$sales['id'])
  632. ->get()->toArray();
  633. $emp_id = [];
  634. foreach ($sales_info as $value){
  635. if(in_array($value['type'],SalesOrderInfo::$man)){
  636. $emp_id[] = $value['data_id'];
  637. }
  638. }
  639. $emp_map = Employee::whereIn('id',array_unique($emp_id))
  640. ->pluck('emp_name','id')
  641. ->toArray();
  642. foreach ($sales_info as $value){
  643. if(in_array($value['type'],SalesOrderInfo::$man)){
  644. $tt = $emp_map[$value['data_id']] ?? '';
  645. if(! empty($tt)){
  646. $tmp = [
  647. 'id' => $value['data_id'],
  648. 'name' => $emp_map[$value['data_id']] ?? '',
  649. ];
  650. if($value['type'] == SalesOrderInfo::type_one){
  651. $sales['employee_one'][] = $tmp;
  652. }elseif ($value['type'] == SalesOrderInfo::type_two){
  653. $sales['employee_two'][] = $tmp;
  654. }elseif ($value['type'] == SalesOrderInfo::type_three){
  655. $sales['employee_three'][] = $tmp;
  656. }
  657. }
  658. } elseif ($value['type'] == SalesOrderInfo::type_four){
  659. $sales['file'][] = [
  660. 'url' => $value['file'],
  661. 'name' => $value['name'],
  662. ];
  663. }
  664. }
  665. // 填充产品
  666. list($product, $activity_product) = $this->salesFillDetailProduct($sales);
  667. $sales['product'] = $product;
  668. $sales['activity_product'] = $activity_product;
  669. $sales['crt_time'] = $sales['crt_time'] ? date("Y-m-d H:i:s",$sales['crt_time']): '';
  670. $sales['dispatch_time_first'] = $sales['dispatch_time_first'] ? date("Y-m-d H:i:s",$sales['dispatch_time_first']): '';
  671. $sales['dispatch_time_second'] = $sales['dispatch_time_second'] ? date("Y-m-d H:i:s",$sales['dispatch_time_second']): '';
  672. //派单后数据 也就是可见范围
  673. $return = (new RangeService())->RangeDetail($sales['id'],SeeRange::type_seven);
  674. $sales['dispatch_depart_one'] = $return[0] ?? [];
  675. $sales['dispatch_employee'] = $return[1] ?? [];
  676. $sales['dispatch_depart_two'] = $return[2] ?? [];
  677. //回款单信息 审核过的
  678. $this->salesFillDetailPayment($sales);
  679. return [true, $sales];
  680. }
  681. public function salesFillDetailProduct($sales){
  682. $product = $activity_product = [];
  683. $sales_p_info = SalesOrderProductInfo::where('del_time',0)
  684. ->where('sales_order_id',$sales['id'])
  685. ->get()->toArray();
  686. $bag = SportsBag::whereIn('id',array_unique(array_column($sales_p_info,'sports_bag_id')))->get()->toArray();
  687. $bag_pro = SportsBagProductInfo::where('del_time',0)->whereIn('sports_bag_id',array_unique(array_column($sales_p_info,'sports_bag_id')))
  688. ->get()->toArray();
  689. $bag_map = array_column($bag,null,'id');
  690. $bag_pro_map = [];
  691. foreach ($bag_pro as $value){
  692. $bag_pro_map[$value['sports_bag_id']][] = $value;
  693. }
  694. $basic_price = BasicType::whereIn('id',array_unique(array_column($sales_p_info,'basic_type_id')))
  695. ->orWhere('type',BasicType::type_20)
  696. ->pluck('title','id')
  697. ->toArray();
  698. $map = (new ProductService())->getProductDetail(array_column($sales_p_info,'product_id'));
  699. $sports_bag_arr = [];
  700. $sports_bag_pro = [];
  701. foreach ($sales_p_info as $value){
  702. $tmp = $map[$value['product_id']] ?? [];
  703. if(! empty($value['sports_bag_id'])){
  704. $bag_tmp = $bag_map[$value['sports_bag_id']] ?? [];
  705. if(! isset($sports_bag_arr[$value['sports_bag_id']])) $sports_bag_arr[$value['sports_bag_id']] = $bag_tmp;
  706. $bag_pro_tmp = $bag_pro_map[$value['sports_bag_id']] ?? [];
  707. foreach ($bag_pro_tmp as $k => $v){
  708. if($v['product_id'] != $value['product_id']) continue;
  709. $is_choose = false;
  710. $final_amount = 0;
  711. $number = $v['number'];
  712. $mark = "";
  713. if($v['id'] == $value['sports_bag_product_info_id']){
  714. $is_choose = true;
  715. $final_amount = $value['final_amount'];
  716. $number = $value['number'];
  717. $mark = $value['mark'];
  718. }
  719. $bag_pro_tmp[$k]['is_choose'] = $is_choose;
  720. $bag_pro_tmp[$k]['final_amount'] = $final_amount;
  721. $bag_pro_tmp[$k]['number'] = $number;
  722. $bag_pro_tmp[$k]['title'] = $tmp['title'] ?? "";
  723. $bag_pro_tmp[$k]['code'] = $tmp['code'] ?? "";
  724. $bag_pro_tmp[$k]['size'] = $tmp['size'] ?? "";
  725. $bag_pro_tmp[$k]['unit'] = $tmp['unit'] ?? "";
  726. $bag_pro_tmp[$k]['unit_title'] = $basic_price[$value['unit']] ?? "";
  727. $bag_pro_tmp[$k]['unit_2'] = $tmp['unit_2'] ?? "";
  728. $bag_pro_tmp[$k]['unit_2_title'] = $basic_price[$value['unit_2']] ?? "";
  729. $bag_pro_tmp[$k]['main_number'] = $tmp['main_number'] ?? 0;
  730. $bag_pro_tmp[$k]['second_number'] = $tmp['second_number'] ?? 0;
  731. $bag_pro_tmp[$k]['bar_code'] = $tmp['bar_code'] ?? "";
  732. $bag_pro_tmp[$k]['mark'] = $mark ?? "";
  733. $sports_bag_pro[$value['sports_bag_id']][] = $bag_pro_tmp[$k];
  734. }
  735. }else{
  736. $value['title'] = $tmp['title'] ?? "";
  737. $value['code'] = $tmp['code'] ?? "";
  738. $value['size'] = $tmp['size'] ?? "";
  739. $value['unit'] = $tmp['unit'] ?? "";
  740. $value['unit_title'] = $basic_price[$value['unit']] ?? "";
  741. $value['unit_2'] = $tmp['unit_2'] ?? "";
  742. $value['unit_2_title'] = $basic_price[$value['unit_2']] ?? "";
  743. $value['main_number'] = $tmp['main_number'] ?? 0;
  744. $value['second_number'] = $tmp['second_number'] ?? 0;
  745. $value['bar_code'] = $tmp['bar_code'] ?? "";
  746. $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
  747. $product[] = $value;
  748. }
  749. }
  750. foreach ($sports_bag_arr as $key => $value){
  751. $value['product'] = $sports_bag_pro[$key] ?? [];
  752. $activity_product[] = $value;
  753. }
  754. return [$product, $activity_product];
  755. }
  756. public function salesFillDetailPayment(&$sales){
  757. //退换货信息
  758. $sales['return_exchange'] = (new ReturnExchangeOrderService())->getDifferentAmount($sales['id']);
  759. $sales['return_exchange_amount'] = 0;
  760. foreach ($sales['return_exchange'] as $value){
  761. if($value['state'] == ReturnExchangeOrder::State_two) $sales['return_exchange_amount'] += $value['difference_amount'];
  762. }
  763. //回款单信息 审核过的
  764. $sales['payment_receipt_list'] = (new PaymentReceiptService())->getPaymentReceiptDataList($sales, PaymentReceipt::data_type_one);
  765. //坏账金额 = 已审核退货退款金额 - 红冲金额
  766. $sales['payment_receipt_list']['bad_amount'] = bcsub($sales['return_exchange_amount'], $sales['payment_receipt_list']['red_amount'],2);
  767. //未回款金额 = 总金额 - 已回款金额 - 坏账金额 - 红冲
  768. $sales['payment_receipt_list']['not_receipt_amount'] = bcsub(bcsub(bcsub($sales['contract_fee'], $sales['payment_receipt_list']['receipt_amount'],2), $sales['payment_receipt_list']['bad_amount'], 2),$sales['payment_receipt_list']['red_amount'],2);
  769. //回款单信息 审核过的
  770. $sales['not_payment_receipt_amount'] = bcsub($sales['contract_fee'],$sales['payment_receipt_list']['not_confirm_receipt_amount'],2);
  771. }
  772. public function salesOrderCommon($data,$user, $field = []){
  773. if(empty($field)) $field = SalesOrder::$field;
  774. $model = SalesOrder::Clear($user,$data);
  775. $model = $model->where('del_time',0)
  776. ->select($field);
  777. if(! empty($data['order_list'])){
  778. if($data['order_list'] == 1){
  779. $model = $model->orderby('id','desc');
  780. //订单合同 安装件合同 状态未指派总社分社的 或者 快递件合同
  781. // $model->where('dispatch_time_second', 0);
  782. // $model->where('state', '<=', SalesOrder::State_three);
  783. }elseif($data['order_list'] == 2){
  784. $model = $model->orderby('dispatch_time_second','desc');
  785. //派单合同 安装件合同 状态已指派总社分社的
  786. $model = $model->where('dispatch_time_second', '>', 0);
  787. // $model->where('state', '>=', SalesOrder::State_four);
  788. }
  789. }else{
  790. $model = $model->orderby('id', 'desc');
  791. }
  792. if(isset($data['out_state'])) $model->where('out_state', $data['out_state']);
  793. $is_dispatch = -1;
  794. if(isset($data['is_dispatch'])) {
  795. if($data['is_dispatch'] == 0){
  796. //订单合同 安装件合同 状态未指派总社分社的 或者 快递件合同
  797. $model->where('dispatch_time_second', 0);
  798. $is_dispatch = 0;
  799. }else{
  800. //派单合同 安装件合同 状态已指派总社分社的
  801. $model->where('dispatch_time_second', '>', 0);
  802. $is_dispatch = 1;
  803. }
  804. }
  805. if(! empty($data['belong_top_depart_title'])){
  806. list($id, $depart_id) = $this->searchSalesDepart($data['belong_top_depart_title']);
  807. if($is_dispatch < 0){
  808. $model->whereIn('id', $id)
  809. ->orWhereIn('top_depart_id', $depart_id);
  810. }elseif ($is_dispatch > 0){
  811. $model->whereIn('id', $id);
  812. }else{
  813. $model->where('top_depart_id', $depart_id);
  814. }
  815. }
  816. if(! empty($data['customer_contact'])) $model->where('customer_contact','LIKE', '%'.$data['customer_contact'].'%');
  817. if(! empty($data['order_number'])) $model->where('order_number','LIKE', '%'.$data['order_number'].'%');
  818. if(! empty($data['order_numbers'])) {
  819. $order_numbers = explode(',',$data['order_numbers']);
  820. $model->whereIn('order_number',$order_numbers);
  821. }
  822. if(! empty($data['sales_order_type'])) $model->where('sales_order_type',$data['sales_order_type']);
  823. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  824. if(! empty($data['model_type'])) $model->where('model_type',$data['model_type']);
  825. if(! empty($data['time_type'])) {
  826. if($data['time_type'] == 1) {
  827. $start = strtotime('today');
  828. $end = strtotime('tomorrow') - 1;
  829. }elseif ($data['time_type'] == 2){
  830. $start = strtotime('this week',strtotime('today'));
  831. $end = strtotime('this week +6 days 23:59:59', strtotime('today'));
  832. }
  833. if(! empty($start) && ! empty($end)) {
  834. $model->where('crt_time','>=',$start);
  835. $model->where('crt_time','<=',$end);
  836. }
  837. }
  838. if(! empty($data['add_construction'])) {
  839. //能下施工单的合同状态
  840. $model->where('state','>=',SalesOrder::State_two);
  841. $model->where('state','<',SalesOrder::State_seven);
  842. }
  843. if(! empty($data['add_return'])) {
  844. //能下退换货单的合同状态
  845. $search = "(sales_order_type = " . SalesOrder::Order_type_one ." and state >= " . SalesOrder::State_two.") or sales_order_type = " . SalesOrder::Order_type_two;
  846. $model->whereRaw("($search)");
  847. // $model->where('state','<',SalesOrder::State_seven);
  848. }
  849. if(! empty($data['sales_order_id'])) $model->where('id',$data['sales_order_id']);
  850. if(isset($data['state'])) {
  851. if($data['state'] == SalesOrder::special_status){
  852. $model->whereRaw(SalesOrder::search1);
  853. }else{
  854. if($data['state'] == SalesOrder::State_three) $model->where('dispatch_time_first','>',0);
  855. $model->where('state', $data['state']);
  856. }
  857. }
  858. if(isset($data['invoice_state'])) $model->where('invoice_state',$data['invoice_state']);
  859. if(isset($data['is_confirm'])) $model->where('is_confirm',$data['is_confirm']);
  860. if(isset($data['is_refund'])) $model->where('is_refund',$data['is_refund']);
  861. if(! empty($data['order_type'])) $model->where('order_type',$data['order_type']);
  862. if(! empty($data['plat_type'])) $model->where('plat_type',$data['plat_type']);
  863. if(! empty($data['plat_type_title'])) {
  864. $id = (new BasicTypeService())->basicTypeSearch($data['plat_type_title']);
  865. $model->whereIn('plat_type',$id);
  866. }
  867. if(! empty($data['plat_order'])) $model->where('plat_order','LIKE', '%'.$data['plat_order'].'%');
  868. if(! empty($data['customer'])) {
  869. $customer_id = (new CustomerService())->titleSearch($user, $data, $data['customer']);
  870. $model->whereIn('customer_id',$customer_id);
  871. }
  872. if(! empty($data['customer_id'])) $model->where('customer_id',$data['customer_id']);
  873. if(! empty($data['sign_time'][0]) && ! empty($data['sign_time'][1])){
  874. $return = $this->changeDateToTimeStampAboutRange($data['sign_time']);
  875. $model->where('sign_time','>=',$return[0]);
  876. $model->where('sign_time','<=',$return[1]);
  877. }
  878. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  879. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  880. $model->where('crt_time','>=',$return[0]);
  881. $model->where('crt_time','<=',$return[1]);
  882. }
  883. if(! empty($data['qd']) || ! empty($data['fz'])){
  884. $sale_order_id = (new RangeService())->salesOrderSearch($data);
  885. $model->whereIn('id',$sale_order_id);
  886. }
  887. if(! empty($data['zp'])){
  888. $sale_order_id = (new RangeService())->salesOrderZpSearch($data);
  889. $model->whereIn('id',$sale_order_id);
  890. }
  891. if(! empty($data['purchase_order_number'])) $model->where('contact_order_no','LIKE', '%'.$data['purchase_order_number'].'%');
  892. if(! empty($data['contact_info'])){
  893. $customer_id = (new CustomerService())->contactSearch($data['contact_info']);
  894. $model->whereIn('customer_id',$customer_id);
  895. }
  896. if(! empty($data['customer_crt_name'])){
  897. $customer_id = (new RangeService())->salesOrderCustomerCrtSearch($user,$data);
  898. $model->whereIn('customer_id',$customer_id);
  899. }
  900. if(! empty($data['dispatch_time_second'][0]) && ! empty($data['dispatch_time_second'][1])) {
  901. $return = $this->changeDateToTimeStampAboutRange($data['dispatch_time_second']);
  902. $model->where('dispatch_time_second','>=',$return[0]);
  903. $model->where('dispatch_time_second','<=',$return[1]);
  904. }
  905. if(! empty($data['customer_from'])){
  906. $id = (new CustomerService())->searchBy($data,$user);
  907. $model->whereIn('customer_id', $id);
  908. }
  909. if(isset($data['construction_state'])){
  910. $for_search = [
  911. 'state' => $data['construction_state'],
  912. 'select_field' => true,
  913. ];
  914. $service = new ConstructionService();
  915. $return = $service->constructionList($for_search,$user);
  916. $model->whereIn('id', array_unique(array_column($return,'sales_order_id')));
  917. }
  918. if(! empty($data['smart_search'])){
  919. $service = new CustomerService();
  920. $customer_id = $service->contactSearch($data['smart_search']);
  921. $customer_id_2 = $service->titleSearch($user, $data, $data['smart_search']);
  922. $customer_id = array_unique(array_merge_recursive($customer_id,$customer_id_2));
  923. $model->where(function (Builder $query) use ($data, $customer_id) {
  924. $query->where('order_number', 'LIKE', '%' . $data['smart_search'] . '%')
  925. ->orWhereIn('customer_id', $customer_id);
  926. });
  927. }
  928. if(! empty($data['wx_crt_time'][0]) && ! empty($data['wx_crt_time'][1])) {
  929. $model->where('crt_time','>=',$data['wx_crt_time'][0]);
  930. $model->where('crt_time','<=',$data['wx_crt_time'][1]);
  931. }
  932. return $model;
  933. }
  934. public function orderNumberSearch($user, $data, $message){
  935. $model2 = SalesOrder::Clear($user,$data);
  936. $sale = $model2->where('del_time',0)
  937. ->where('order_number', 'LIKE', '%'.$message.'%')
  938. ->select('id')
  939. ->get()->toArray();
  940. return array_column($sale,'id');
  941. }
  942. //门店搜索
  943. public function searchSalesDepart($depart_title = ""){
  944. $sales_id = [];
  945. if(empty($depart_title)) return $sales_id;
  946. $depart_id = Depart::where('del_time', 0)
  947. ->where('parent_id', 0)
  948. ->where('title', 'LIKE', '%'. $depart_title .'%')
  949. ->select('id')->get()->toArray();
  950. $depart_id = array_column($depart_id, 'id');
  951. if(empty($depart_id)) return [$sales_id, $depart_id];
  952. $sales_id = SeeRange::where('del_time',0)
  953. ->whereIn('param_id', $depart_id)
  954. ->where('data_type',SeeRange::type_seven)
  955. ->where('type',SeeRange::data_three)
  956. ->select('data_id as sale_id')
  957. ->get()->toArray();
  958. $sales_id = array_column($sales_id, 'sale_id');
  959. return [$sales_id, $depart_id];
  960. }
  961. /**
  962. * 订单列表
  963. * @param $data
  964. * @param $user
  965. * @return array
  966. */
  967. public function salesOrderList($data,$user){
  968. $model = $this->salesOrderCommon($data, $user);
  969. $list = $this->limit($model,'',$data);
  970. $list = $this->fillData($list,$data);
  971. $count = $this->countData("crt_time", $data, $user);
  972. $list['today'] = $count[0] ?? 0;
  973. $list['yesterday'] = $count[1] ?? 0;
  974. return [true, $list];
  975. }
  976. function createTempTableIfNotExists($ids, &$model)
  977. {
  978. if (empty($ids)) {
  979. $model->whereIn('id', []);
  980. return;
  981. }
  982. // 使用事务
  983. DB::beginTransaction();
  984. try {
  985. // 先删除已有的临时表
  986. DB::unprepared('DROP TEMPORARY TABLE IF EXISTS temp_ids');
  987. // 创建临时表
  988. DB::unprepared('CREATE TEMPORARY TABLE temp_ids (id INT)');
  989. // 插入数据
  990. foreach (array_chunk($ids, 1000) as $chunk) {
  991. DB::table('temp_ids')->insert(array_map(function ($id) {
  992. return ['id' => $id];
  993. }, $chunk));
  994. }
  995. // 使用临时表
  996. $model->whereIn('id', function ($query) {
  997. $query->select('id')->from('temp_ids');
  998. });
  999. // 提交事务
  1000. DB::commit();
  1001. } catch (\Exception $e) {
  1002. // 回滚事务
  1003. DB::rollBack();
  1004. }
  1005. }
  1006. public function salesOrderClose($data,$user){
  1007. if(empty($data['id'])) return [false, '请选择合同'];
  1008. $sale_order = SalesOrder::where('id',$data['id'])
  1009. ->where('del_time',0)
  1010. ->first();
  1011. if(empty($sale_order)) return [false, '合同不存在或已被删除'];
  1012. $sale_order = $sale_order->toArray();
  1013. if($sale_order['model_type'] != SalesOrder::Model_type_four) return [false, '非线上订单'];
  1014. $bool = ReturnExchangeOrder::where('del_time',0)
  1015. ->where('data_id', $sale_order['id'])
  1016. ->where('type',ReturnExchangeOrder::Order_type)
  1017. ->exists();
  1018. if($bool) return [false, '合同已存在退换货单'];
  1019. $bool = PaymentReceipt::where('del_time',0)
  1020. ->where('data_order_no', $sale_order['order_number'])
  1021. ->where('data_type',PaymentReceipt::data_type_one)
  1022. ->exists();
  1023. if($bool) return [false, '合同已存在收付款单'];
  1024. $bool = PurchaseOrder::where('del_time',0)
  1025. ->where('sales_order_id', $sale_order['id'])
  1026. ->exists();
  1027. if($bool) return [false, '合同已存在采购订单'];
  1028. $bool = Construction::where('del_time',0)
  1029. ->where('sales_order_id', $sale_order['id'])
  1030. ->exists();
  1031. if($bool) return [false, '合同已存在施工单'];
  1032. try {
  1033. DB::beginTransaction();
  1034. $del_time = 1234;
  1035. SalesOrder::where('id', $data['id'])
  1036. ->update(['del_time' => $del_time]);
  1037. SalesOrderInfo::where('del_time',0)
  1038. ->where('sales_order_id',$data['id'])
  1039. ->update(['del_time' => $del_time]);
  1040. SalesOrderProductInfo::where('del_time',0)
  1041. ->where('sales_order_id',$data['id'])
  1042. ->update(['del_time' => $del_time]);
  1043. SalesOrderOtherFee::where('del_time',0)
  1044. ->where('sales_order_id',$data['id'])
  1045. ->update(['del_time' => $del_time]);
  1046. (new RangeService())->RangeDelete($data['id'],SeeRange::type_seven);
  1047. DB::commit();
  1048. }catch (\Throwable $exception){
  1049. DB::rollBack();
  1050. return [false, $exception->getMessage()];
  1051. }
  1052. return [true, ''];
  1053. }
  1054. /**
  1055. * 订单参数规则
  1056. * @param $data
  1057. * @param $user
  1058. * @param $is_add
  1059. * @return array
  1060. */
  1061. public function salesOrderRule(&$data, $user, $is_add = true){
  1062. if(empty($data['model_type'])) return [false,'销售类型不能为空'];
  1063. if(! in_array($data['model_type'],SalesOrder::$model_type)) return [false,'销售类型错误'];
  1064. if(empty($data['sales_order_type'])) return [false,'产品类型不能为空'];
  1065. if(empty($data['order_number'])) return [false,'合同编号不能为空'];
  1066. // if(empty($data['customer_id'])) return [false,'请选择客户'];
  1067. // if(empty($data['employee_one'])) return [false,'请选择签订人'];
  1068. if(! empty($data['sign_time'])) $data['sign_time'] = $this->changeDateToDateMin($data['sign_time']);
  1069. if(! empty($data['expire_time'])) $data['expire_time'] = $this->changeDateToDateMin($data['expire_time']);
  1070. // if(empty($data['employee_two'])) return [false,'请选择负责人'];
  1071. // if(empty($data['product'])) return [false,'请选择产品'];
  1072. if(empty($data['menu_id'])) return [false, '菜单信息不能为空'];
  1073. //限制频率
  1074. list($status,$msg) = $this->limitingSendRequestBackgExpire("saleOrder" . $data['order_number']);
  1075. if(! $status) return [false, $msg];
  1076. $sports_bag_id = [];
  1077. if(! empty($data['product'])){
  1078. foreach ($data['product'] as $value){
  1079. if(empty($value['number'])) return [false,'产品数量不能为空'];
  1080. if(! empty($value['number_2'])){
  1081. $res = $this->checkNumber($value['number_2'],1);
  1082. if(! $res) return [false,'副单位产品数量请输入不超过一位小数并且大于0的数值'];
  1083. }
  1084. $res = $this->checkNumber($value['number'],4);
  1085. if(! $res) return [false,'产品数量请输入不超过四位小数并且大于0的数值'];
  1086. if(! empty($value['sports_bag_id']) && ! in_array($value['sports_bag_id'], $sports_bag_id)) $sports_bag_id[] = $value['sports_bag_id'];
  1087. }
  1088. }
  1089. if(! empty($sports_bag_id)) return [false, '销售订单活动包暂未开放'];
  1090. if(! empty($data['contract_fee'])){
  1091. $res = $this->checkNumber($data['contract_fee']);
  1092. if(! $res) return [false, '合同金额请输入不超过两位小数并且大于0的数值'];
  1093. }
  1094. if(! empty($data['other_fee'])){
  1095. $res = $this->checkNumber($data['other_fee']);
  1096. if(! $res) return [false, '其它费用请输入不超过两位小数并且大于0的数值'];
  1097. }
  1098. if(! empty($data['discount_fee'])){
  1099. $res = $this->checkNumber($data['discount_fee']);
  1100. if(! $res) return [false, '优惠金额请输入不超过两位小数并且大于0的数值'];
  1101. }
  1102. //所属部门 以及 顶级部门
  1103. if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
  1104. $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
  1105. //是否总部
  1106. $is_head_now = 0;
  1107. if($data['top_depart_id'] == $user['head']['id']) $is_head_now = 1;
  1108. if($data['model_type'] == SalesOrder::Model_type_one){
  1109. if(! empty($data['construction_time'])) $data['construction_time'] = $this->changeDateToDateMin($data['construction_time']);
  1110. if(! empty($data['handover_time'])) $data['handover_time'] = $this->changeDateToDateMin($data['handover_time']);
  1111. if(empty($data['plat_type'])) return [false,'平台类型不能为空'];
  1112. if(empty($data['customer_short_name'])) return [false,'客户简称不能为空'];
  1113. }elseif($data['model_type'] == SalesOrder::Model_type_two){
  1114. }elseif($data['model_type'] == SalesOrder::Model_type_three){
  1115. }elseif($data['model_type'] == SalesOrder::Model_type_four){
  1116. if($is_head_now){
  1117. if(empty($data['plat_type'])) return [false,'平台类型不能为空'];
  1118. if(empty($data['customer_short_name'])) return [false,'客户简称不能为空'];
  1119. }
  1120. }elseif($data['model_type'] == SalesOrder::Model_type_five){
  1121. if($is_head_now){
  1122. if(empty($data['plat_type'])) return [false,'平台类型不能为空'];
  1123. if(empty($data['customer_short_name'])) return [false,'客户简称不能为空'];
  1124. }
  1125. }elseif($data['model_type'] == SalesOrder::Model_type_six){
  1126. }
  1127. //收付款信息
  1128. if(! empty($data['payment_receipt']['order_number'])){
  1129. if(! isset($data['contract_fee'])) return [false, '合同金额不能为空'];
  1130. if(empty($data['payment_receipt']['data_type'])) $data['payment_receipt']['data_type'] = PaymentReceipt::data_type_one;
  1131. if(empty($data['payment_receipt']['data_order_no'])) $data['payment_receipt']['data_order_no'] = $data['payment_receipt']['order_number'];
  1132. if(empty($data['payment_receipt']['type'])) return [false,'金额类型不能为空'];
  1133. if(empty($data['payment_receipt']['amount'])) return [false,'回款金额不能为空'];
  1134. $res = $this->checkNumber($data['payment_receipt']['amount']);
  1135. if(! $res) return [false, '回款金额请输入不超过两位小数并且大于0的数值'];
  1136. if($data['contract_fee'] < $data['payment_receipt']['amount']) return [false, '回款金额不能大于合同金额'];
  1137. if(! empty($data['payment_receipt']['payment_receipt_date'])) $data['payment_receipt']['payment_receipt_date'] = $this->changeDateToDate($data['payment_receipt']['payment_receipt_date']);
  1138. }
  1139. if($is_add){
  1140. $bool = SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])->exists();
  1141. if($bool) return [false,'合同编号已存在,请重新获取'];
  1142. $check_id = $sports_bag_id;
  1143. }else{
  1144. if(empty($data['id'])) return [false,'ID不能为空'];
  1145. $order = SalesOrder::where('del_time',0)->where('id',$data['id'])->first();
  1146. if(empty($order)) return [false,'合同不存在或已被删除'];
  1147. $order = $order->toArray();
  1148. if(! in_array($order['state'], [SalesOrder::State_minus_one,SalesOrder::State_zero])) return [false, '请确认合同状态,编辑失败'];
  1149. //订单编辑提交限制
  1150. $current_top_depart_id = $this->getMyTopDepart($user);
  1151. list($status, $msg) = $this->returnOrderEditErrorCommon($current_top_depart_id, $order['top_depart_id']);
  1152. if(! $status) return [false, $msg];
  1153. $sports_bag_id_save = SalesOrderProductInfo::where('del_time',0)
  1154. ->where('sales_order_id',$data['id'])
  1155. ->where('sports_bag_id','>',0)
  1156. ->select('sports_bag_id')
  1157. ->get()->toArray();
  1158. $sports_bag_id_save = array_unique(array_column($sports_bag_id_save,'sports_bag_id'));
  1159. $check_id = array_values(array_diff($sports_bag_id, $sports_bag_id_save));
  1160. }
  1161. //校验活动包有效性
  1162. $service = new SportsBagService();
  1163. list($status, $msg) = $service->checkSportsBag($check_id);
  1164. if(! $status) return [false, $msg];
  1165. return [true, $data];
  1166. }
  1167. /**
  1168. * 数据拼接
  1169. * @param $data
  1170. * @param $ergs
  1171. * @return array
  1172. */
  1173. public function fillData($data,$ergs){
  1174. if(empty($data['data'])) return $data;
  1175. $data_id = array_column($data['data'],'id');
  1176. $array = array_unique(array_merge_recursive(array_column($data['data'],'order_type'),array_column($data['data'],'car_type'),array_column($data['data'],'pay_way'),array_column($data['data'],'install_position'),array_column($data['data'],'install_method'),array_column($data['data'],'plat_type')));
  1177. $basic_map = BasicType::whereIn('id',$array)
  1178. ->pluck('title','id')
  1179. ->toArray();
  1180. $emp = Employee::whereIn('id',array_unique(array_column($data['data'],'crt_id')))
  1181. ->pluck('emp_name','id')
  1182. ->toArray();
  1183. $customer = Customer::whereIn('id',array_unique(array_column($data['data'],'customer_id')))
  1184. ->pluck('title','id')
  1185. ->toArray();
  1186. $product = $employee_two = $purchase = [];
  1187. //获取合同下的产品
  1188. if(! empty($ergs['product'])) $product = $this->getSalesOrderProduct($data_id);
  1189. if(! empty($ergs['employee_two'])){
  1190. //单据中选择的负责人
  1191. $sales_order = SalesOrderInfo::where('del_time',0)
  1192. ->where('type',SalesOrderInfo::type_two)
  1193. ->whereIn('sales_order_id',$data_id)
  1194. ->select('sales_order_id','data_id')
  1195. ->get()->toArray();
  1196. $empList = Employee::whereIn('id', array_unique(array_column($sales_order,'data_id')))
  1197. ->pluck('emp_name','id')
  1198. ->toArray();
  1199. foreach ($sales_order as $value){
  1200. $str = $empList[$value['data_id']] ?? "";
  1201. if(! $str) continue;
  1202. if(isset($employee_two[$value['sales_order_id']])){
  1203. $employee_two[$value['sales_order_id']] .= ',' . $str;
  1204. }else{
  1205. $employee_two[$value['sales_order_id']] = $str;
  1206. }
  1207. }
  1208. }
  1209. if(! empty($ergs['purchase'])){
  1210. $order = PurchaseOrder::where('del_time',0)
  1211. ->whereIn('sales_order_id',$data_id)
  1212. ->select('sales_order_id','order_number')
  1213. ->get()->toArray();
  1214. foreach ($order as $value){
  1215. if(isset($purchase[$value['sales_order_id']])){
  1216. $purchase[$value['sales_order_id']] .= ',' . $value['order_number'];
  1217. }else{
  1218. $purchase[$value['sales_order_id']] = $value['order_number'];
  1219. }
  1220. }
  1221. }
  1222. list($for_amount_list, $for_amount_list1) = (new PaymentReceiptService())->getPaymentReceiptDataCountList(array_column($data['data'],'order_number'));
  1223. list($getDifferentAmountALL,$getDifferentAmountALL1) = (new ReturnExchangeOrderService())->getDifferentAmountALLNew($data_id);
  1224. //获取分社订货合同关联的发货单
  1225. $invoiceData = $this->getInvoiceOrderData($data['data']);
  1226. //分派的总社或分社
  1227. $dispatch = $this->getDispatchData($data['data']);
  1228. //指派金额
  1229. $fee = $this->getOtherMoney($data['data']);
  1230. //订单状态数据组织
  1231. $state_array = $this->getStateMake($data['data']);
  1232. //同步用友信息
  1233. $u8 = $this->getMessage($data_id,U8Job::two);
  1234. //关联施工单号
  1235. $construction_array = $this->getConstruction($data_id);
  1236. //跟进记录
  1237. $record_array = (new FollowUpRecordService())->getVisitDataOfTime($data_id, FollowUpRecord::type_two);
  1238. //获取客户的信息
  1239. $customer_id = array_column($data['data'],'customer_id');
  1240. $customer_map = $this->getCustomer($customer_id);
  1241. $array2 = array_unique(array_column($data['data'],'top_depart_id'));
  1242. $depart = Depart::whereIn('id',$array2)->pluck('title','id')->toArray();
  1243. foreach ($data['data'] as $key => $value){
  1244. $data['data'][$key]['construction_model_type'] = SalesOrder::$build_for_con[$value['type']] ?? 1;
  1245. $data['data'][$key]['type_title'] = SalesOrder::$build_state[$value['type']] ?? '';
  1246. $data['data'][$key]['plat_type_title'] = $basic_map[$value['plat_type']] ?? '';
  1247. $data['data'][$key]['sales_order_type_title'] = SalesOrder::$order_type[$value['sales_order_type']] ?? '';
  1248. $data['data'][$key]['model_type_title'] = SalesOrder::$model_type_title[$value['model_type']] ?? '';
  1249. $data['data'][$key]['order_type_title'] = $basic_map[$value['order_type']] ?? '';
  1250. $data['data'][$key]['install_method_title'] = $basic_map[$value['install_method']] ?? '';
  1251. $data['data'][$key]['install_position_title'] = $basic_map[$value['install_position']] ?? '';
  1252. $data['data'][$key]['car_type_title'] = $basic_map[$value['car_type']] ?? '';
  1253. $data['data'][$key]['pay_way_title'] = $basic_map[$value['pay_way']] ?? '';
  1254. $data['data'][$key]['customer_title'] = $customer[$value['customer_id']] ?? '';
  1255. $c_tmp = $customer_map[$value['customer_id'] . $value['customer_contact']] ?? [];
  1256. $data['data'][$key]['customer_contact_id'] = $c_tmp['customer_contact_id'] ?? '';
  1257. $data['data'][$key]['contact_type_id'] = $c_tmp['contact_type_id'] ?? '';
  1258. $data['data'][$key]['contact_type_title'] = $c_tmp['contact_type_title'] ?? '';
  1259. $data['data'][$key]['sign_time'] = $value['sign_time'] ? date('Y-m-d',$value['sign_time']) : '';
  1260. $data['data'][$key]['construction_time'] = $value['construction_time'] ? date('Y-m-d H:i:s',$value['construction_time']) : '';
  1261. $data['data'][$key]['handover_time'] = $value['handover_time'] ? date('Y-m-d H:i:s',$value['handover_time']) : '';
  1262. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
  1263. $data['data'][$key]['is_dispatch'] = $value['dispatch_time_second'] ? 1 : 0;
  1264. $data['data'][$key]['is_dispatch_title'] = $value['dispatch_time_second'] ? "已派单" : "未派单";
  1265. $data['data'][$key]['is_refund_title'] = $value['is_refund'] ? "已返款" : "未返款";
  1266. $data['data'][$key]['dispatch_time_second_time'] = $value['dispatch_time_second'] ? date('Y-m-d H:i:s',$value['dispatch_time_second']) : '';
  1267. $crt_name = $emp[$value['crt_id']] ?? '';
  1268. $data['data'][$key]['crt_name'] = $crt_name;
  1269. $data['data'][$key]['product'] = $product[$value['id']] ?? [];
  1270. $data['data'][$key]['employee_two_title'] = $employee_two[$value['id']] ?? "";
  1271. $data['data'][$key]['purchase'] = $purchase[$value['id']] ?? "";
  1272. $data['data'][$key]['fee'] = $fee[$value['id']] ?? "";
  1273. $data['data'][$key]['state_title'] = $this->makeState($data['data'][$key], $state_array);
  1274. $data['data'][$key]['invoice_state_name'] = SalesOrder::$invoice_state[$value['invoice_state']] ?? '';
  1275. $data['data'][$key]['is_confirm_title'] = $value['is_confirm'] ? "已接收" : "未接收" ;
  1276. $tmp = $invoiceData[$value['id']] ?? [];
  1277. $data['data'][$key]['invoice_arr'] = implode(',', $tmp);
  1278. $dispatch_company = $dispatch[$value['id']] ?? '';
  1279. $data['data'][$key]['dispatch_company'] = $dispatch_company;
  1280. if($value['dispatch_time_second'] > 0) {
  1281. //分配过所属门店是分配门店
  1282. $data['data'][$key]['belong_top_depart_title'] = $dispatch_company;
  1283. }else{
  1284. //没分配过所属门店是创建门店
  1285. $data['data'][$key]['belong_top_depart_title'] = $depart[$value['top_depart_id']] ?? "";
  1286. }
  1287. $data['data'][$key]['u8_message'] = $u8[$value['id']] ?? '';
  1288. $data['data'][$key]['construction_no'] = $construction_array[$value['id']] ?? '';
  1289. if($value['is_confirm']){
  1290. $show = $dispatch_company . '已接收';
  1291. }else{
  1292. $show = '待' . $dispatch_company . '接收';
  1293. }
  1294. $data['data'][$key]['wx_show'] = $show;
  1295. //用于计算--------
  1296. //已收(审核后)
  1297. $one1 = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
  1298. $data['data'][$key]['checked_payment_receipt_amount'] = $one1;
  1299. //已收
  1300. $one = $for_amount_list[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
  1301. $data['data'][$key]['payment_receipt_amount'] = $one;
  1302. //已红冲
  1303. $three = $for_amount_list[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
  1304. $data['data'][$key]['red_amount'] = $three;
  1305. //已退货退款
  1306. $return_exchange_amount = $getDifferentAmountALL[$value['id']] ?? 0;
  1307. $data['data'][$key]['return_exchange_amount'] = $return_exchange_amount;
  1308. //用于计算--------
  1309. //用于统计--------
  1310. $red = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
  1311. $return_exchange_amount1 = $getDifferentAmountALL1[$value['id']] ?? 0;
  1312. $bad = bcsub($return_exchange_amount1 ,$red,2);
  1313. //已收金额
  1314. $fee1 = bcsub($one1 ,$red,2);
  1315. $data['data'][$key]['fee1'] = $fee1;
  1316. //未收金额
  1317. $fee2 = bcsub(bcsub(bcsub($value['contract_fee'], $fee1,2), $bad, 2),$red,2);
  1318. $data['data'][$key]['fee2'] = $fee2;
  1319. //红冲金额
  1320. $data['data'][$key]['fee3'] = $red;
  1321. //坏账金额
  1322. $data['data'][$key]['fee4'] = $bad;
  1323. //用于统计--------
  1324. $record_tmp = $record_array[$value['id']] ?? "";
  1325. $data['data'][$key]['has_record'] = $record_tmp ? "查看" : "无记录";
  1326. $data['data'][$key]['follow_record'] = $record_array[$value['id']] ?? "";
  1327. }
  1328. return $data;
  1329. }
  1330. public function getMessage($id,$type){
  1331. $result = U8Job::where('del_time',0)
  1332. ->whereIn('data',$id)
  1333. ->where('data_type',$type)
  1334. ->select('data','state','crt_time','msg')
  1335. ->get()->toArray();
  1336. $return = [];
  1337. foreach ($result as $value){
  1338. if($value['state'] == 1){
  1339. $return[$value['data']] = '同步成功';
  1340. }else{
  1341. $return[$value['data']] = '同步失败:' . $value['msg'];
  1342. }
  1343. }
  1344. return $return;
  1345. }
  1346. public function getCustomer($customer_id){
  1347. $customer_contact_map = [];
  1348. $contact_type_id = [];
  1349. $customer_contact = CustomerInfo::where('del_time',0)
  1350. ->whereIn('customer_id', $customer_id)
  1351. ->where('type',CustomerInfo::type_one)
  1352. ->select('customer_id','contact_info','contact_type','id')
  1353. ->get()->toArray();
  1354. if(! empty($customer_contact)){
  1355. foreach ($customer_contact as $value){
  1356. if(! empty($value['customer_id']) && ! empty($value['contact_info'])){
  1357. $customer_contact_map[$value['customer_id'] . $value['contact_info']] = [
  1358. 'customer_contact_id' => $value['id'],
  1359. 'contact_type_id' => $value['contact_type'],
  1360. ];
  1361. $contact_type_id[] = $value['contact_type'];
  1362. }
  1363. }
  1364. }
  1365. $contact_type_title = BasicType::whereIn('id', $contact_type_id)->pluck('title','id')->toArray();
  1366. foreach ($customer_contact_map as $key => $value){
  1367. $customer_contact_map[$key]['contact_type_title'] = $contact_type_title[$value['contact_type_id']] ?? "";
  1368. }
  1369. return $customer_contact_map;
  1370. }
  1371. public function countData($column = "", $data, $user){
  1372. if(empty($column) || empty($data['from_wx'])) return [0, 0];
  1373. // 获取今天的开始和结束时间戳
  1374. $todayStart = Carbon::today()->startOfDay()->timestamp;
  1375. $todayEnd = Carbon::today()->endOfDay()->timestamp;
  1376. // 获取昨天的开始和结束时间戳
  1377. $yesterdayStart = Carbon::yesterday()->startOfDay()->timestamp;
  1378. $yesterdayEnd = Carbon::yesterday()->endOfDay()->timestamp;
  1379. $data['wx_' . $column] = [$todayStart, $todayEnd];
  1380. $model = $this->salesOrderCommon($data, $user);
  1381. // 查询今天的数据条数
  1382. $todayCount = $model->count();
  1383. $data['wx_' . $column] = [$yesterdayStart, $yesterdayEnd];
  1384. $model = $this->salesOrderCommon($data, $user);
  1385. // 查询昨天的数据条数
  1386. $yesterdayCount = $model->count();
  1387. return [$todayCount, $yesterdayCount];
  1388. }
  1389. public function getSalesOrderProduct($data_id)
  1390. {
  1391. $product = [];
  1392. if(empty($data_id)) return $product;
  1393. $sales_p_info = SalesOrderProductInfo::where('del_time',0)
  1394. ->whereIn('sales_order_id',$data_id)
  1395. ->get()->toArray();
  1396. $basic_price = BasicType::whereIn('id',array_unique(array_column($sales_p_info,'basic_type_id')))
  1397. ->orWhere('type',BasicType::type_20)
  1398. ->pluck('title','id')
  1399. ->toArray();
  1400. $map = (new ProductService())->getProductDetail(array_column($sales_p_info,'product_id'));
  1401. foreach ($sales_p_info as $value){
  1402. $tmp = $map[$value['product_id']] ?? [];
  1403. $value['title'] = $tmp['title'] ?? "";
  1404. $value['is_edit_unit_price'] = $tmp['is_edit_unit_price'] ?? 0;
  1405. $value['code'] = $tmp['code'] ?? "";
  1406. $value['size'] = $tmp['size'] ?? "";
  1407. $value['unit'] = $tmp['unit'] ?? "";
  1408. $value['unit_title'] = $basic_price[$value['unit']] ?? "";
  1409. $value['unit_2'] = $tmp['unit_2'] ?? "";
  1410. $value['unit_2_title'] = $basic_price[$value['unit_2']] ?? "";
  1411. $value['main_number'] = $tmp['main_number'] ?? 0;
  1412. $value['second_number'] = $tmp['second_number'] ?? 0;
  1413. $value['bar_code'] = $tmp['bar_code'] ?? "";
  1414. $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
  1415. $value['install_time'] = $tmp['install_time'] ?? 0;
  1416. $product[$value['sales_order_id']][] = $value;
  1417. }
  1418. return $product;
  1419. }
  1420. public function salesOrderGet($data){
  1421. if(empty($data['model_type'])) return [false,'销售类型不能为空'];
  1422. if(! isset(SalesOrder::$prefix[$data['model_type']])) return [false,'销售类型错误'];
  1423. $prefix = SalesOrder::$prefix[$data['model_type']];
  1424. $order_number = OrderNoService::createSalesOrderNumber($prefix);
  1425. if(! $order_number) return [false,'合同编号生成失败!'];
  1426. return [true, ['order_number' => $order_number]];
  1427. }
  1428. /**
  1429. * 订单推送
  1430. * @param $data
  1431. * @return array
  1432. */
  1433. public function salesOrderDispatchSale($data, $user){
  1434. list($status,$msg) = $this->salesOrderDispatchSaleRule($data, $user);
  1435. if(! $status) return [false,$msg];
  1436. try {
  1437. DB::beginTransaction();
  1438. $time = time();
  1439. SalesOrder::where('del_time',0)->where('id',$msg['id'])->update([
  1440. 'state' => SalesOrder::State_three,
  1441. 'dispatch_time_first' => $time,
  1442. ]);
  1443. SeeRange::where('del_time',0)
  1444. ->where('data_id',$msg['id'])
  1445. ->where('data_type',SeeRange::type_seven)
  1446. ->whereIn('type',[SeeRange::data_one, SeeRange::data_two])
  1447. ->update(['del_time' => $time]);
  1448. if(! empty($data['dispatch_depart_one'])){
  1449. $insert = [];
  1450. foreach ($data['dispatch_depart_one'] as $value){
  1451. $insert[] = [
  1452. 'data_id' => $msg['id'],
  1453. 'data_type' => SeeRange::type_seven,
  1454. 'param_id' => $value,
  1455. 'type' => SeeRange::data_one,
  1456. 'crt_time' => $time,
  1457. ];
  1458. }
  1459. SeeRange::insert($insert);
  1460. }
  1461. if(! empty($data['dispatch_employee'])){
  1462. $insert = [];
  1463. foreach ($data['dispatch_employee'] as $value){
  1464. $insert[] = [
  1465. 'data_id' => $msg['id'],
  1466. 'data_type' => SeeRange::type_seven,
  1467. 'param_id' => $value,
  1468. 'type' => SeeRange::data_two,
  1469. 'crt_time' => $time,
  1470. ];
  1471. }
  1472. SeeRange::insert($insert);
  1473. }
  1474. (new OrderOperationService())->add([
  1475. 'order_number' => $msg['order_number'],
  1476. 'msg' => OrderOperation::$type[OrderOperation::one],
  1477. 'type' => OrderOperation::one
  1478. ],$user);
  1479. DB::commit();
  1480. }catch (\Exception $exception){
  1481. DB::rollBack();
  1482. return [false,$exception->getMessage()];
  1483. }
  1484. return [true,''];
  1485. }
  1486. /**
  1487. * 订单推送规则
  1488. * @param $data
  1489. * @return array
  1490. */
  1491. public function salesOrderDispatchSaleRule(&$data, $user){
  1492. if(empty($data['id'])) return [false,'请选择合同派单'];
  1493. $sale = SalesOrder::where('del_time',0)
  1494. ->where('id',$data['id'])
  1495. ->first();
  1496. if(empty($sale)) return [false,'合同不存在或已被删除'];
  1497. $sale = $sale->toArray();
  1498. if($sale['sales_order_type'] != SalesOrder::Order_type_one) return [false,'非安装件合同,操作失败'];
  1499. if(! in_array($sale['model_type'],[SalesOrder::Model_type_four,SalesOrder::Model_type_seven])) return [false,'非线上订单/补贴订单,线上派单操作失败'];
  1500. if($sale['state'] < SalesOrder::State_two) return [false,'合同还未确认,操作失败'];
  1501. if($sale['state'] > SalesOrder::State_three) return [false,'请确认合同状态,操作失败'];
  1502. $bool = SalesOrderProductInfo::where('del_time',0)
  1503. ->where('sales_order_id',$data['id'])
  1504. ->exists();
  1505. if(! $bool) return [false,'合同产品不能为空'];
  1506. if(empty($data['dispatch_depart_one']) && empty($data['dispatch_employee'])) return [false, '请指派部门或人员'];
  1507. return [true, $sale];
  1508. }
  1509. /**
  1510. * 订单推送公司
  1511. * @param $data
  1512. * @return array
  1513. */
  1514. public function salesOrderDispatchCompany($data,$user){
  1515. list($status,$msg) = $this->salesOrderDispatchCompanyRule($data,$user);
  1516. if(! $status) return [false,$msg];
  1517. try {
  1518. DB::beginTransaction();
  1519. $time = time();
  1520. SalesOrder::where('del_time',0)->where('id',$msg['id'])->update([
  1521. 'state' => SalesOrder::State_four,
  1522. 'dispatch_time_second' => $time,
  1523. 'dispatch_time_second_id' => $user['id'],
  1524. 'type' => $data['type']
  1525. ]);
  1526. SeeRange::where('del_time',0)
  1527. ->where('data_id',$msg['id'])
  1528. ->where('data_type',SeeRange::type_seven)
  1529. ->where('type',SeeRange::data_three)
  1530. ->update(['del_time' => $time]);
  1531. SalesOrderOtherFee::where('del_time',0)
  1532. ->where('sales_order_id',$msg['id'])
  1533. ->update(['del_time' => $time]);
  1534. if(! empty($data['dispatch_depart_two'])){
  1535. $insert = [];
  1536. foreach ($data['dispatch_depart_two'] as $value){
  1537. $insert[] = [
  1538. 'data_id' => $msg['id'],
  1539. 'data_type' => SeeRange::type_seven,
  1540. 'param_id' => $value,
  1541. 'type' => SeeRange::data_three,
  1542. 'crt_time' => $time,
  1543. ];
  1544. }
  1545. SeeRange::insert($insert);
  1546. }
  1547. if(! empty($data['other_fee_1'])){
  1548. $model = new SalesOrderOtherFee();
  1549. $model->sales_order_id = $msg['id'];
  1550. $model->other_fee_1 = $data['other_fee_1'] ?? 0;
  1551. $model->type = $data['type'] ?? 0;
  1552. $model->save();
  1553. }
  1554. if(isset($data['notify_id'])){
  1555. SalesOrder::where('del_time',0)->where('id',$msg['id'])->update([
  1556. 'dispatch_time_first' => $time, // 第一次派单时间也记录
  1557. ]);
  1558. if(! empty($data['notify_id'])){ //门店负责人不为空
  1559. $insert[] = [
  1560. 'data_id' => $msg['id'],
  1561. 'data_type' => SeeRange::type_seven,
  1562. 'param_id' => $data['notify_id'],
  1563. 'type' => SeeRange::data_two,
  1564. 'crt_time' => $time,
  1565. ];
  1566. SeeRange::insert($insert);
  1567. }
  1568. }
  1569. (new OrderOperationService())->add([
  1570. 'order_number' => $msg['order_number'],
  1571. 'msg' => OrderOperation::$type[OrderOperation::two],
  1572. 'type' => OrderOperation::two
  1573. ],$user);
  1574. DB::commit();
  1575. }catch (\Exception $exception){
  1576. DB::rollBack();
  1577. return [false,$exception->getMessage()];
  1578. }
  1579. $depart_id = $data['dispatch_depart_two'][0] ?? 0;
  1580. if(! empty($depart_id) && $depart_id != $msg['top_depart_id']){
  1581. //发送消息
  1582. $notify_id = Depart::where('id',$depart_id)->value('notify_id');
  1583. if(! empty($notify_id)){
  1584. $emp_name = Employee::whereIn('id',[$msg['crt_id'], $notify_id])->pluck('emp_name','id')->toArray();
  1585. $send_data[] = [
  1586. 'employee_id' => $notify_id,
  1587. 'type' => 1,
  1588. 'state' => 1,
  1589. 'menu_id' => 37,
  1590. 'order_number' => $msg['order_number'],
  1591. 'tmp_data' => [
  1592. $msg['order_number'],
  1593. $emp_name[$msg['crt_id']] ?? "",
  1594. $emp_name[$notify_id] ?? "" . "(派单通知)",
  1595. date('Y-m-d H:i:s'),
  1596. ],
  1597. ];
  1598. (new OaService())->sendWxOaCheckMessage($send_data);
  1599. }
  1600. }else{
  1601. //直接确认
  1602. SalesOrder::where('del_time',0)->where('id',$msg['id'])->update([
  1603. 'is_confirm' => 1,
  1604. ]);
  1605. }
  1606. return [true,''];
  1607. }
  1608. /**
  1609. * 订单推送公司规则
  1610. * @param $data
  1611. * @return array
  1612. */
  1613. public function salesOrderDispatchCompanyRule(&$data,$user){
  1614. if(empty($data['id'])) return [false,'请选择合同派单'];
  1615. if(empty($data['dispatch_depart_two'])) return [false, '请指派总社或分社'];
  1616. $depart_id = $data['dispatch_depart_two'][0];
  1617. if(! isset($data['other_fee_1'])) return [false,'分社安装金额不存在'];
  1618. $res = $this->checkNumber($data['other_fee_1']);
  1619. if(! isset($data['type']) || ! isset(SalesOrder::$build_state[$data['type']])) return [false, '合同安装类型不存在'];
  1620. if($data['type'] <= 0) $data['type'] = SalesOrder::build_zero;
  1621. if(! $res) return [false,'价格请输入不超过两位小数并且大于等于0的数值'];
  1622. $sale = SalesOrder::where('del_time',0)
  1623. ->where('id',$data['id'])
  1624. ->first();
  1625. if(empty($sale)) return [false,'合同不存在或已被删除'];
  1626. $sale = $sale->toArray();
  1627. if($sale['sales_order_type'] != SalesOrder::Order_type_one) return [false,'非安装件合同,操作失败'];
  1628. if($sale['state'] > SalesOrder::State_four) return [false,'请确认合同状态,操作失败'];
  1629. if($sale['state'] < SalesOrder::State_two) return [false, '合同未审核通过,操作失败'];
  1630. if($sale['state'] < SalesOrder::State_three) {
  1631. //如果没有派销售过 找到门店负责人
  1632. $data['notify_id'] = Depart::where('id', $depart_id)->value('notify_id');
  1633. }
  1634. $product = SalesOrderProductInfo::where('del_time',0)
  1635. ->where('sales_order_id',$data['id'])
  1636. ->select('product_id','number')
  1637. ->get()->toArray();
  1638. if(empty($product)) return [false,'合同产品不能为空'];
  1639. $bool = Construction::where('del_time',0)
  1640. ->where('sales_order_id',$data['id'])
  1641. ->exists();
  1642. if($bool) return [false,'合同已生成施工单,操作失败'];
  1643. $product_id = array_unique(array_column($product,'product_id'));
  1644. $return = RangeService::productNotSeeRange($product_id);
  1645. //产品信息
  1646. $product_array = Product::whereIn('id',$product_id)->select('title','id','build_fee')->get()->toArray();
  1647. $map = [];
  1648. foreach ($product_array as $value){
  1649. $map[$value['id']] = $value['title'];
  1650. }
  1651. if(! empty($return)){
  1652. foreach ($data['dispatch_depart_two'] as $value){
  1653. foreach ($return as $key => $values){
  1654. $tmp = $map[$key] ?? "";
  1655. if(in_array($value, $values)) return [false,'产品'. $tmp .'对于该总社或分社不可见'];
  1656. }
  1657. }
  1658. }
  1659. return [true, $sale];
  1660. }
  1661. public function salesOrderListsalesOrderWxList($data,$user){
  1662. $field = SalesOrder::$field;
  1663. $model = SalesOrder::where('del_time',0)
  1664. ->select($field)
  1665. ->orderby('id', 'desc')
  1666. ->orderby('dispatch_time_second','desc');
  1667. if(! empty($data['openid'])){
  1668. $mobile = WxEmployee::where('openid',$data['openid'])->select('mobile')->get()->toArray();
  1669. $mobile = array_column($mobile,'mobile');
  1670. $customer_id = CustomerInfo::where('del_time',0)
  1671. ->where('type',CustomerInfo::type_one)
  1672. ->whereIn('contact_info',$mobile)
  1673. ->select('customer_id')
  1674. ->get()->toArray();
  1675. $customer_id = array_column($customer_id,'customer_id');
  1676. $model->whereIn('customer_id',$customer_id);
  1677. }
  1678. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  1679. $list = $this->limit($model,'',$data);
  1680. $list = $this->fillData($list,$data);
  1681. return [true, $list];
  1682. }
  1683. public function getInvoiceOrderData($data){
  1684. //分社订货模板
  1685. $search_id = [];
  1686. foreach ($data as $value){
  1687. if(! empty($value['invoice_state'])) $search_id[] = $value['id'];
  1688. }
  1689. if(empty($search_id)) return [];
  1690. $invoice = InvoiceOrder::where('del_time',0)
  1691. ->whereIn('sales_order_id',$search_id)
  1692. ->select('sales_order_id','order_number','logistics_number')
  1693. ->get()->toArray();
  1694. $invoice_array = [];
  1695. foreach ($invoice as $value){
  1696. $invoice_array[$value['sales_order_id']][] = $value['logistics_number'];
  1697. }
  1698. return $invoice_array;
  1699. }
  1700. public function getDispatchData($data){
  1701. //分社订货模板
  1702. $search_id = [];
  1703. foreach ($data as $value){
  1704. if($value['state'] >= SalesOrder::State_four) $search_id[] = $value['id'];
  1705. }
  1706. if(empty($search_id)) return [];
  1707. $see = SeeRange::where('del_time',0)
  1708. ->whereIn('data_id',$search_id)
  1709. ->where('data_type',SeeRange::type_seven)
  1710. ->where('type',SeeRange::data_three)
  1711. ->select('data_id','param_id')
  1712. ->get()->toArray();
  1713. $map = Depart::whereIn('id',array_unique(array_column($see,'param_id')))
  1714. ->pluck('title','id')
  1715. ->toArray();
  1716. $see_array = [];
  1717. foreach ($see as $value){
  1718. $see_array[$value['data_id']] = $map[$value['param_id']] ?? "";
  1719. }
  1720. return $see_array;
  1721. }
  1722. public function getOtherMoney($data){
  1723. $fee = [];
  1724. $sales_o_info = SalesOrderOtherFee::where('del_time',0)
  1725. ->whereIn('sales_order_id',array_column($data,'id'))
  1726. ->get()->toArray();
  1727. foreach ($sales_o_info as $value){
  1728. $fee[$value['sales_order_id']] = $value['other_fee_1'];
  1729. }
  1730. return $fee;
  1731. }
  1732. public function getStateMake($data){
  1733. if(empty($data)) return [];
  1734. $order_no = [];
  1735. foreach ($data as $value){
  1736. if(! in_array($value['state'], [SalesOrder::State_minus_one,SalesOrder::State_one])) continue;
  1737. $order_no[] = $value['order_number'];
  1738. }
  1739. return (new OaService())->getOaTeamDetailList($order_no);
  1740. }
  1741. public function makeState($value, $state_array){
  1742. if($value['sales_order_type'] == SalesOrder::Order_type_one){
  1743. //安装件
  1744. if(! empty($state_array[$value['order_number']])){
  1745. $return = $state_array[$value['order_number']];
  1746. if($value['state'] == SalesOrder::State_minus_one){
  1747. $state = "驳回:" . $return;
  1748. }else{
  1749. $state = "待" . $return . "审核";
  1750. }
  1751. }elseif($value['state'] == SalesOrder::State_zero){
  1752. $state = "待" . $value['crt_name'] . "提交";
  1753. }elseif($value['state'] == SalesOrder::State_three && ! in_array($value['model_type'], [SalesOrder::Model_type_four,SalesOrder::Model_type_seven])){
  1754. // 除线上订单 补贴订单 外 3状态即使审核通过(本来3是指派销售 除了线上订单 补贴订单 其它不需要)
  1755. $state = SalesOrder::$state[SalesOrder::State_two] ?? '';
  1756. }else{
  1757. $state = SalesOrder::$state[$value['state']] ?? '';
  1758. }
  1759. }else{
  1760. //快递件
  1761. $state = SalesOrder::$state2[$value['state']] ?? '';
  1762. }
  1763. return $state;
  1764. }
  1765. public function getConstruction($sale_order_id){
  1766. if(empty($sale_order_id)) return [];
  1767. $result = Construction::where('del_time',0)
  1768. ->whereIn('sales_order_id',$sale_order_id)
  1769. ->select('order_number','sales_order_id','state','crt_id','start_time')
  1770. ->get()->toArray();
  1771. $emp = Employee::whereIn('crt_id',array_unique(array_column($result,'crt_id')))
  1772. ->pluck('emp_name','id')
  1773. ->toArray();
  1774. $service = new ConstructionService();
  1775. //订单状态数据组织
  1776. $state_array = $service->getStateMake($result);
  1777. $return = [];
  1778. foreach ($result as $value){
  1779. $value['crt_name'] = $emp[$value['crt_id']] ?? "";
  1780. $state_title = $service->makeState($value, $state_array);
  1781. $string = $value['order_number'] . " : " . $state_title;
  1782. if(isset($return[$value['sales_order_id']])){
  1783. $return[$value['sales_order_id']] .= ',' . $string;
  1784. }else{
  1785. $return[$value['sales_order_id']] = $string;
  1786. }
  1787. }
  1788. return $return;
  1789. }
  1790. public function batchConfirm($data,$user){
  1791. if(empty($data['order_number']) || ! is_array($data['order_number'])) return [false, '批量确认数据不正确'];
  1792. $result = SalesOrder::where('del_time',0)
  1793. ->whereIn('order_number',$data['order_number'])
  1794. ->select('state','order_number','model_type')
  1795. ->get()->toArray();
  1796. if(empty($result)) return [false, '未找到数据'];
  1797. $result = array_column($result,null,'order_number');
  1798. foreach ($data['order_number'] as $value){
  1799. if(! isset($result[$value])) return [false, $value . '不存在或已被删除'];
  1800. $tmp = $result[$value];
  1801. if(! in_array($tmp['model_type'], [SalesOrder::Model_type_four,SalesOrder::Model_type_seven])) return [false, '单据'. $value . '非线上订单/补贴订单,操作失败'];
  1802. if(! in_array($tmp['state'] , [SalesOrder::State_zero,SalesOrder::State_minus_one])) return [false, '请确认单据'. $value . '的状态,操作失败'];
  1803. }
  1804. SalesOrder::whereIn('order_number',$data['order_number'])->update(['state' => SalesOrder::State_two]);
  1805. (new OrderOperationService())->batchAdd([
  1806. 'order_number' => $data['order_number'],
  1807. 'msg' => OrderOperation::$type[OrderOperation::twenty_five],
  1808. 'type' => OrderOperation::twenty_five
  1809. ],$user);
  1810. return [true, ''];
  1811. }
  1812. /**
  1813. * 批量推送公司
  1814. * @param $data
  1815. * @return array
  1816. */
  1817. public function salesOrderBatchDispatchCompany($data,$user){
  1818. list($status,$msg) = $this->salesOrderBatchDispatchCompanyRule($data,$user);
  1819. if(! $status) return [false,$msg];
  1820. try {
  1821. $time = time();
  1822. DB::beginTransaction();
  1823. $sales = $msg;
  1824. $sales_id = array_column($sales, 'id');
  1825. SeeRange::where('del_time',0)
  1826. ->whereIn('data_id', $sales_id)
  1827. ->where('data_type',SeeRange::type_seven)
  1828. ->where('type',SeeRange::data_three)
  1829. ->update(['del_time' => $time]);
  1830. SalesOrderOtherFee::where('del_time',0)
  1831. ->whereIn('sales_order_id',$sales_id)
  1832. ->update(['del_time' => $time]);
  1833. if(! empty($data['dispatch_depart_two'])){
  1834. $insert = [];
  1835. foreach ($data['dispatch_depart_two'] as $value){
  1836. foreach ($sales_id as $v){
  1837. $insert[] = [
  1838. 'data_id' => $v,
  1839. 'data_type' => SeeRange::type_seven,
  1840. 'param_id' => $value,
  1841. 'type' => SeeRange::data_three,
  1842. 'crt_time' => $time,
  1843. ];
  1844. }
  1845. }
  1846. SeeRange::insert($insert);
  1847. }
  1848. $other_fee = $notify_id = [];
  1849. foreach ($sales as $value){
  1850. SalesOrder::where('del_time',0)->where('id', $value['id'])->update([
  1851. 'state' => SalesOrder::State_four,
  1852. 'dispatch_time_second' => $time,
  1853. 'dispatch_time_second_id' => $user['id'],
  1854. 'type' => $value['type']
  1855. ]);
  1856. $other_fee[] = [
  1857. 'sales_order_id' => $value['id'],
  1858. 'other_fee_1' => $value['other_fee_1'],
  1859. 'type' => $value['type'],
  1860. ];
  1861. if(! empty($value['notify_id'])){
  1862. //门店负责人不为空
  1863. $notify_id[] = [
  1864. 'data_id' => $value['id'],
  1865. 'data_type' => SeeRange::type_seven,
  1866. 'param_id' => $value['notify_id'],
  1867. 'type' => SeeRange::data_two,
  1868. 'crt_time' => $time,
  1869. ];
  1870. }
  1871. if(isset($value['notify_id']) && empty($value['dispatch_time_first'])){
  1872. SalesOrder::where('del_time',0)->where('id',$value['id'])->update([
  1873. 'dispatch_time_first' => $time, // 第一次派单时间记录
  1874. ]);
  1875. }
  1876. }
  1877. if(! empty($other_fee)) SalesOrderOtherFee::insert($other_fee);
  1878. if(! empty($notify_id)) SeeRange::insert($notify_id);
  1879. (new OrderOperationService())->batchAdd([
  1880. 'order_number' => array_column($sales, 'order_number'),
  1881. 'msg' => OrderOperation::$type[OrderOperation::thirty_one],
  1882. 'type' => OrderOperation::thirty_one
  1883. ],$user);
  1884. DB::commit();
  1885. }catch (\Exception $exception){
  1886. DB::rollBack();
  1887. return [false,$exception->getMessage()];
  1888. }
  1889. $depart_id = $data['dispatch_depart_two'][0] ?? 0;
  1890. $notify_id = Depart::where('id',$depart_id)->value('notify_id');
  1891. $crt_id = array_column($sales,'crt_id');
  1892. if($notify_id) $crt_id[] = $notify_id;
  1893. $emp_name = Employee::whereIn('id',$crt_id)->pluck('emp_name','id')->toArray();
  1894. foreach ($sales as $value){
  1895. if(! empty($depart_id) && $depart_id != $value['top_depart_id']){
  1896. //发送消息
  1897. if(! empty($notify_id)){
  1898. $send_data[] = [
  1899. 'employee_id' => $notify_id,
  1900. 'type' => 1,
  1901. 'state' => 1,
  1902. 'menu_id' => 37,
  1903. 'order_number' => $value['order_number'],
  1904. 'tmp_data' => [
  1905. $value['order_number'],
  1906. $emp_name[$value['crt_id']] ?? "",
  1907. $emp_name[$notify_id] ?? "" . "(派单通知)",
  1908. date('Y-m-d H:i:s'),
  1909. ],
  1910. ];
  1911. (new OaService())->sendWxOaCheckMessage($send_data);
  1912. }
  1913. }else{
  1914. //直接确认
  1915. SalesOrder::where('del_time',0)->where('id',$value['id'])->update([
  1916. 'is_confirm' => 1,
  1917. ]);
  1918. }
  1919. }
  1920. return [true,''];
  1921. }
  1922. /**
  1923. * 批量推送公司规则
  1924. * @param $data
  1925. * @return array
  1926. */
  1927. public function salesOrderBatchDispatchCompanyRule(&$data,$user){
  1928. //是总社还是分社
  1929. if(empty($data['dispatch_depart_two'])) return [false, '请指派总社或分社'];
  1930. $depart_id = $data['dispatch_depart_two'][0];
  1931. //前端传参
  1932. if(empty($data['data'])) return [false,'请选择合同派单'];
  1933. $other_fee_1_map = [];
  1934. foreach ($data['data'] as $value){
  1935. if(empty($value['id'])) return [false, '合同ID不能为空'];
  1936. if(! isset($value['type']) || ! isset(SalesOrder::$build_state[$value['type']])) return [false, '合同安装类型不存在'];
  1937. $type = $value['type'];
  1938. if($type <= 0) $type = SalesOrder::build_zero;
  1939. if(! isset($value['other_fee_1'])) return [false, '合同安装金额不存在'];
  1940. $res = $this->checkNumber($value['other_fee_1']);
  1941. if(! $res) return [false,'金额请输入不超过两位小数并且大于等于0的数值'];
  1942. $other_fee_1_map[$value['id']] = [
  1943. 'other_fee_1' => $value['other_fee_1'],
  1944. 'type' => $type,
  1945. ];
  1946. }
  1947. //合同信息
  1948. $sale_id = array_column($data['data'], 'id');
  1949. $sale = SalesOrder::where('del_time',0)
  1950. ->whereIn('id', $sale_id)
  1951. ->get()->toArray();
  1952. if(empty($sale)) return [false,'合同不存在或已被删除'];
  1953. $notify_id = Depart::where('id', $depart_id)->value('notify_id');
  1954. //组织合同数据
  1955. foreach ($sale as $key => $value){
  1956. if($value['del_time'] > 0) return [false,'合同:' . $value['order_number'] . '不存在或已被删除'];
  1957. if($value['sales_order_type'] != SalesOrder::Order_type_one) return [false,'非安装件合同,操作失败'];
  1958. if($value['state'] > SalesOrder::State_four) return [false,'请确认合同状态,操作失败'];
  1959. if($value['state'] < SalesOrder::State_three) {
  1960. //如果没有派销售过 找到门店负责人
  1961. $sale[$key]['notify_id'] = $notify_id;
  1962. }
  1963. //合同派单信息
  1964. $other_fee_1 = $other_fee_1_map[$value['id']] ?? [];
  1965. $sale[$key]['other_fee_1'] = $other_fee_1['other_fee_1'];
  1966. $sale[$key]['type'] = $other_fee_1['type'];
  1967. }
  1968. //校验产品
  1969. $p_id_map = array_column($sale, 'order_number', 'id');
  1970. $product = SalesOrderProductInfo::where('del_time',0)
  1971. ->whereIn('sales_order_id', $sale_id)
  1972. ->select('product_id','sales_order_id')
  1973. ->get()->toArray();
  1974. if(empty($product)) return [false,'合同产品不能为空'];
  1975. $p_map = array_column($product, null, 'sales_order_id');
  1976. foreach ($data['data'] as $value){
  1977. if(empty($p_map[$value['id']])){
  1978. $order_number = $p_id_map[$value['id']] ?? "";
  1979. return [false, '合同' . $order_number . '产品不能为空'];
  1980. }
  1981. }
  1982. //校验施工
  1983. $bool = Construction::where('del_time',0)
  1984. ->whereIn('sales_order_id', $sale_id)
  1985. ->exists();
  1986. if($bool) return [false,'合同已生成施工单,操作失败'];
  1987. //产品不可见
  1988. $product_id = array_unique(array_column($product,'product_id'));
  1989. $return = RangeService::productNotSeeRange($product_id);
  1990. //产品信息
  1991. $product_array = Product::whereIn('id',$product_id)->select('title','id','build_fee')->get()->toArray();
  1992. $map = [];
  1993. foreach ($product_array as $value){
  1994. $map[$value['id']] = $value['title'];
  1995. }
  1996. if(! empty($return)){
  1997. foreach ($data['dispatch_depart_two'] as $value){
  1998. foreach ($return as $key => $values){
  1999. $tmp = $map[$key] ?? "";
  2000. if(in_array($value, $values)) return [false,'产品'. $tmp .'对于该总社或分社不可见'];
  2001. }
  2002. }
  2003. }
  2004. return [true, $sale];
  2005. }
  2006. /**
  2007. * 获取安装价格
  2008. * @param $data
  2009. * @param $user
  2010. * @return array
  2011. */
  2012. public function salesOrderGetBuildFee($data,$user){
  2013. if(empty($data['id'])) return [false,'请选择合同派单'];
  2014. if(empty($data['top_depart_id'])) return [false,'请选择派单分社'];
  2015. $depart = Depart::where('del_time',0)->where('id', $data['top_depart_id'])->first();
  2016. if(empty($depart)) return [false, '分社不存在或已被删除'];
  2017. $depart = $depart->toArray();
  2018. $sale = SalesOrder::where('del_time',0)
  2019. ->whereIn('id', $data['id'])
  2020. ->get()->toArray();
  2021. if(empty($sale)) return [false,'合同不存在或已被删除'];
  2022. $product = SalesOrderProductInfo::where('del_time',0)
  2023. ->whereIn('sales_order_id',$data['id'])
  2024. ->select('product_id','number','sales_order_id')
  2025. ->get()->toArray();
  2026. if(empty($product)) return [false,'合同产品不能为空'];
  2027. $product_array = Product::whereIn('id',array_unique(array_column($product, 'product_id')))
  2028. ->select('title','id','build_fee')
  2029. ->get()->toArray();
  2030. $map2 = [];
  2031. foreach ($product_array as $value){
  2032. $map2[$value['id']] = $value['build_fee'];
  2033. }
  2034. // 实时 带货安装包安装
  2035. $count = [];
  2036. $other_fee_1 = 0;
  2037. foreach ($product as $value){
  2038. $build_fee = $map2[$value['product_id']] ?? 0;
  2039. $fee = bcmul($value['number'],$build_fee,2);
  2040. $other_fee_1 = bcadd($other_fee_1,$fee,2);
  2041. if(isset($count[$value['sales_order_id']])){
  2042. $tmp = bcadd($count[$value['sales_order_id']], $other_fee_1,2);
  2043. $count[$value['sales_order_id']] = $tmp;
  2044. }else{
  2045. $count[$value['sales_order_id']] = $other_fee_1;
  2046. }
  2047. }
  2048. $product_map = array_column($product,null,'sales_order_id');
  2049. $return_map = [];
  2050. foreach ($sale as $value){
  2051. if(! isset($product_map[$value['id']])) return [false, "合同:" . $value['order_number'] . '下没有产品信息'];
  2052. foreach (SalesOrder::$build_state as $key => $value_v){
  2053. if($key == SalesOrder::build_minus) continue;
  2054. if($key == SalesOrder::build_zero){
  2055. $rate = bcdiv($depart['rate'], 100,2);
  2056. $other_fee_1 = bcmul($value['contract_fee'], $rate,2);
  2057. }elseif($key == SalesOrder::build_one){
  2058. $other_fee_1 = $count[$value['id']] ?? "0.00";
  2059. }else{
  2060. $other_fee_1 = "0.00";
  2061. }
  2062. $return_map[$value['id']][$key] = [
  2063. 'id' => $value['id'],
  2064. 'order_number' => $value['order_number'],
  2065. 'type' => $key,
  2066. 'other_fee_1' => $other_fee_1,
  2067. 'is_choose' => 0,
  2068. ];
  2069. }
  2070. }
  2071. // 已保存的
  2072. $save = SalesOrderOtherFee::where('del_time',0)
  2073. ->whereIn('sales_order_id', $data['id'])
  2074. ->pluck('other_fee_1','sales_order_id')
  2075. ->toArray();
  2076. foreach ($sale as $value){// 填充已保存的
  2077. if(isset($save[$value['id']][$value['type']])){
  2078. $other_fee_1 = $save[$value['id']];
  2079. $return_map[$value['id']][$value['type']]['other_fee_1'] = $other_fee_1;
  2080. $return_map[$value['id']][$value['type']]['is_choose'] = 1;
  2081. }
  2082. }
  2083. $return = [];
  2084. foreach ($return_map as $value){
  2085. foreach ($value as $v){
  2086. $tmp = [
  2087. 'type' => $v['type'],
  2088. 'other_fee_1' => $v['other_fee_1'],
  2089. 'is_choose' => $v['is_choose'],
  2090. ];
  2091. if(isset($return[$v['id']])){
  2092. $return[$v['id']]['data'][] = $tmp;
  2093. }else{
  2094. $return[$v['id']] = [
  2095. 'id' => $v['id'],
  2096. 'order_number' => $v['order_number'],
  2097. 'data' => [$tmp]
  2098. ];
  2099. }
  2100. }
  2101. }
  2102. return [true, array_values($return)];
  2103. }
  2104. //申请出库
  2105. public function salesClickOut($data, $user){
  2106. if(empty($data['id'])) return [false, '合同ID不能为空'];
  2107. $sales = SalesOrder::where('del_time',0)
  2108. ->where('id',$data['id'])
  2109. ->first();
  2110. if(empty($sales)) return [false, '合同不存在或已被删除'];
  2111. $sales = $sales->toArray();
  2112. if($sales['state'] < SalesOrder::State_two) return [false, '合同未审核通过'];
  2113. if($sales['out_state'] > SalesOrder::out_zero) return [false, '合同已出库'];
  2114. try {
  2115. DB::beginTransaction();
  2116. SalesOrder::where('id',$sales['id'])->update(['out_state' => SalesOrder::out_one]);
  2117. (new OrderOperationService())->add([
  2118. 'order_number' => $sales['order_number'],
  2119. 'msg' => OrderOperation::$type[OrderOperation::thirty_two],
  2120. 'type' => OrderOperation::thirty_two
  2121. ],$user);
  2122. DB::commit();
  2123. }catch (\Throwable $exception){
  2124. DB::rollBack();
  2125. return [false, $exception->getMessage()];
  2126. }
  2127. return [true, ''];
  2128. }
  2129. public function salesOrderPdf($data, $user){
  2130. list($status, $msg) = $this->detail($data, $user);
  2131. if(! $status) return [false, $msg];
  2132. $order = $msg;
  2133. $num = $total = 0;
  2134. foreach (array_column($order['product'], 'number') as $value) {
  2135. $num = bcadd($num, $value, 2);
  2136. }
  2137. foreach (array_column($order['product'], 'final_amount') as $value) {
  2138. $total = bcadd($total, $value, 2);
  2139. }
  2140. $order['product_sum'] = [
  2141. 'num' => $num,
  2142. 'total' => $total,
  2143. ];
  2144. $num = $total = 0;
  2145. foreach (array_column($order['activity_product'], 'number') as $value) {
  2146. $num = bcadd($num, $value, 2);
  2147. }
  2148. foreach (array_column($order['activity_product'], 'final_amount') as $value) {
  2149. $total = bcadd($total, $value, 2);
  2150. }
  2151. $order['activity_product_sum'] = [
  2152. 'num' => $num,
  2153. 'total' => $total,
  2154. ];
  2155. $pdf = app('dompdf.wrapper')->loadView('pdf.salesOrder', ['order' => $order]);
  2156. $file_name = time().rand(1000,9999);
  2157. $filename = '合同_' . $file_name.'.' . 'pdf';
  2158. $pdf->save(storage_path('app/public/export/' . $filename));
  2159. return [true, ['file' => $filename]];
  2160. }
  2161. public function getSalesProductCK($sales_id = []){
  2162. if(empty($sales_id)) return [];
  2163. $sales_id = SalesOrder::whereIn('id',$sales_id)
  2164. ->where('out_state',SalesOrder::out_one)
  2165. ->select('id')
  2166. ->get()->toArray();
  2167. $sales_id = array_column($sales_id,'id');
  2168. //销售订单对应产品总数
  2169. $product = SalesOrderProductInfo::where('del_time',0)
  2170. ->where('sales_order_id', $sales_id)
  2171. ->select('number', 'sales_order_id')
  2172. ->get()->toArray();
  2173. $product_sale_map = [];
  2174. foreach ($product as $value){
  2175. $key = $value['sales_order_id'];
  2176. if(isset($product_sale_map[$key])){
  2177. $number = bcadd($value['number'], $product_sale_map[$key],2);
  2178. $product_sale_map[$key] = $number;
  2179. }else{
  2180. $product_sale_map[$key] = $value['number'];
  2181. }
  2182. }
  2183. //合同出库产品总数
  2184. $product_map = [];
  2185. $save = OutBoundOrderInfo::where('del_time',0)
  2186. ->where('type', OutBoundOrderInfo::type_one)
  2187. ->where('data_id', $sales_id)
  2188. ->select('number', 'data_id as sales_order_id','return_number')
  2189. ->get()->toArray();
  2190. foreach ($save as $value){
  2191. $key = $value['sales_order_id'];
  2192. if(isset($product_map[$key])){
  2193. $number = bcadd($value['number'], $product_map[$key]['number'],2);
  2194. $return_number = bcadd($value['return_number'], $product_map[$key]['return_number'],2);
  2195. $product_map[$key]['number'] = $number;
  2196. $product_map[$key]['return_number'] = $return_number;
  2197. }else{
  2198. $product_map[$key]['number'] = $value['number'];
  2199. $product_map[$key]['return_number'] = $value['return_number'];
  2200. }
  2201. }
  2202. //合同退货产品
  2203. $product_map2 = [];
  2204. $return_id = ReturnExchangeOrder::where('del_time',0)
  2205. ->where('type', ReturnExchangeOrder::Order_type)
  2206. ->where('model_type', ReturnExchangeOrder::Model_type_one)
  2207. ->whereIn('data_id', $sales_id)
  2208. ->select('id','data_id as sales_order_id')
  2209. ->get()->toArray();
  2210. $return_map = array_column($return_id,'sales_order_id','id');
  2211. $save2 = ReturnExchangeOrderProductInfo::where('del_time',0)
  2212. ->whereIn('return_exchange_id', array_column($return_id,'id'))
  2213. ->where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
  2214. ->select('number', 'return_exchange_id')
  2215. ->get()->toArray();
  2216. foreach ($save2 as $value){
  2217. $sales_order_tmp = $return_map[$value['return_exchange_id']] ?? 0;
  2218. if(! $sales_order_tmp) continue;
  2219. $key = $sales_order_tmp;
  2220. if(isset($product_map2[$key])){
  2221. $number = bcadd($value['number'], $product_map2[$key],2);
  2222. $product_map2[$key] = $number;
  2223. }else{
  2224. $product_map2[$key] = $value['number'];
  2225. }
  2226. }
  2227. $return = [];
  2228. //未出库 0 未完全出库 1 已完全出库 2
  2229. foreach ($product_sale_map as $key => $value){
  2230. //合同出库产品总数
  2231. $p1 = $product_map[$key] ?? [];
  2232. //合同出库产品数量
  2233. $p1_number = $p1['number'] ?? 0;
  2234. //合同出库后退货产品数量
  2235. $p1_return_number = $p1['return_number'] ?? 0;
  2236. //出库数量 - 退货数量 = 已出数量
  2237. $p_re = bcsub($p1_number,$p1_return_number,2);
  2238. //合同退货产品
  2239. $p2 = $product_map2[$key] ?? 0;
  2240. $p2_re = bcsub($p2,$p1_return_number,2);
  2241. //合同 - 已出 - 退货 = 剩余能出
  2242. $number = bcsub(bcsub($value['number'], $p_re,2), $p2_re,2);
  2243. if($p_re > 0) {
  2244. if($number <= 0){
  2245. $return_id[$value['sales_order_id']] = "已出库";
  2246. }else{
  2247. $return_id[$value['sales_order_id']] = "未完全出库";
  2248. }
  2249. }else{
  2250. if($number <= 0){
  2251. $return_id[$value['sales_order_id']] = "已退货";
  2252. }else{
  2253. $return_id[$value['sales_order_id']] = "未出库";
  2254. }
  2255. }
  2256. if(! $p1){
  2257. $return_id[$value['sales_order_id']] = "未出库";
  2258. }elseif($p1 == $value['number']){
  2259. $return_id[$value['sales_order_id']] = "已完全出库";
  2260. }elseif($p1 < $value['number']){
  2261. $number = bcsub(bcsub($value['number'], $p1,2), $p2,2);
  2262. if($number <= 0) {
  2263. $return_id[$value['sales_order_id']] = "已完全出库";
  2264. }else{
  2265. $return_id[$value['sales_order_id']] = "未完全出库";
  2266. }
  2267. }else{
  2268. $return_id[$value['sales_order_id']] = "已完全出库";
  2269. }
  2270. }
  2271. return $return;
  2272. }
  2273. public function getSalesProductForWarranty($sales_id = 0){
  2274. if(empty($sales_id)) return [];
  2275. //销售订单对应产品总数
  2276. $product = SalesOrderProductInfo::from('sales_order_product_info as a')
  2277. ->join('product as b','a.product_id','b.id')
  2278. ->where('a.del_time',0)
  2279. ->where('a.sales_order_id', $sales_id)
  2280. ->where('b.warranty_time', '>', 0)
  2281. ->select('a.number','a.product_id','b.code','b.product_category','b.title','b.warranty_time')
  2282. ->get()->toArray();
  2283. if(empty($product)) return [];
  2284. $product_id = array_column($product,'product_id');
  2285. //合同质保产品
  2286. $sn_product = ProductSnInfo::where("del_time",0)
  2287. ->where('data_id', $sales_id)
  2288. ->where('type',ProductSnInfo::type_two)
  2289. ->whereIn('product_id',$product_id)
  2290. ->select('product_id')
  2291. ->get()->toArray();
  2292. $product_map1 = [];
  2293. foreach ($sn_product as $value){
  2294. $key = $value['product_id'];
  2295. if(isset($product_map1[$key])){
  2296. $number = bcadd(1, $product_map1[$key],2);
  2297. $product_map1[$key] = $number;
  2298. }else{
  2299. $product_map1[$key] = 1;
  2300. }
  2301. }
  2302. //合同退货产品
  2303. $product_map2 = [];
  2304. $return_id = ReturnExchangeOrder::where('del_time',0)
  2305. ->where('type', ReturnExchangeOrder::Order_type)
  2306. ->where('model_type', ReturnExchangeOrder::Model_type_one)
  2307. ->where('data_id', $sales_id)
  2308. ->select('id')
  2309. ->get()->toArray();
  2310. $save2 = ReturnExchangeOrderProductInfo::where('del_time',0)
  2311. ->whereIn('return_exchange_id', array_column($return_id,'id'))
  2312. ->where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
  2313. ->select('number', 'return_exchange_id','product_id')
  2314. ->get()->toArray();
  2315. foreach ($save2 as $value){
  2316. $key = $value['product_id'];
  2317. if(isset($product_map2[$key])){
  2318. $number = bcadd($value['number'], $product_map2[$key],2);
  2319. $product_map2[$key] = $number;
  2320. }else{
  2321. $product_map2[$key] = $value['number'];
  2322. }
  2323. }
  2324. $return = [];
  2325. $service = new DataSyncToU8Service();
  2326. foreach ($product as $key => $value){
  2327. $bool = $service->forCheck($value['product_category']);
  2328. //车窗膜不管数量算一个
  2329. if($bool) $value['number'] = 1;
  2330. $sn_tmp = $product_map1[$value['product_id']] ?? 0;
  2331. $return_tmp = $product_map2[$value['product_id']] ?? 0;
  2332. $number = bcsub($value['number'], $sn_tmp,2);
  2333. $number = bcsub($number, $return_tmp,2);
  2334. if($number <= 0) unset($product[$key]);
  2335. $return[$value['product_id']] = $value;
  2336. $return[$value['product_id']]['number'] = $number;
  2337. }
  2338. return $return;
  2339. }
  2340. }