ReturnExchangeOrderService.php 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891
  1. <?php
  2. namespace App\Service;
  3. use App\Model\BasicType;
  4. use App\Model\Employee;
  5. use App\Model\PurchaseOrder;
  6. use App\Model\PurchaseOrderInfo;
  7. use App\Model\ReturnExchangeOrder;
  8. use App\Model\ReturnExchangeOrderProductInfo;
  9. use App\Model\SalesOrder;
  10. use App\Model\SalesOrderProductInfo;
  11. use App\Model\SeeRange;
  12. use App\Model\Storehouse;
  13. use Carbon\Carbon;
  14. use Illuminate\Support\Facades\DB;
  15. class ReturnExchangeOrderService extends Service
  16. {
  17. public function edit($data,$user){
  18. list($status,$msg) = $this->orderRule($data,$user,false);
  19. if(!$status) return [$status,$msg];
  20. $params = $this->getDataFile($data);
  21. (new OperationLogService())->setOperationList($params,$user,2);
  22. try{
  23. DB::beginTransaction();
  24. $material_model = ReturnExchangeOrder::where('order_number',$data['order_number'])->first();
  25. $material_model->data_id = $data['data_id'];
  26. $material_model->type = $data['type'];
  27. $material_model->difference_amount = $data['difference_amount'];
  28. $material_model->mark = $data['mark'] ?? "";
  29. $material_model->storehouse_id = $data['storehouse_id'] ?? 0;
  30. $material_model->save();
  31. $time = time();
  32. if($data['model_type'] != ReturnExchangeOrder::Model_type_three){
  33. ReturnExchangeOrderProductInfo::where('del_time',0)
  34. ->where('return_exchange_id',$data['id'])
  35. ->update(['del_time' => $time]);
  36. if(! empty($data['product_one'])){
  37. $sub = [];
  38. foreach ($data['product_one'] as $value){
  39. $sub[] = [
  40. 'return_exchange_id' => $material_model->id,
  41. 'product_id' => $value['product_id'],
  42. 'number' => $value['number'],
  43. 'mark' => $value['mark'] ?? '',
  44. 'cost' => $value['cost'] ?? 0,
  45. 'retail_price' => $value['retail_price'] ?? 0,
  46. 'return_or_exchange' => ReturnExchangeOrderProductInfo::type_one,
  47. 'crt_time' => $time,
  48. 'storehouse_id' => $data['storehouse_id'] ?? 0,
  49. 'basic_type_id' => $value['basic_type_id'] ?? 0,
  50. 'price' => $value['price'],
  51. 'final_amount' => $value['final_amount'] ?? 0,
  52. 'return_exchange_price' => $value['return_exchange_price'],
  53. ];
  54. }
  55. ReturnExchangeOrderProductInfo::insert($sub);
  56. }
  57. if(! empty($data['product_two'])){
  58. $sub = [];
  59. foreach ($data['product_two'] as $value){
  60. if(empty($value['product_id'])) continue;
  61. $sub[] = [
  62. 'return_exchange_id' => $material_model->id,
  63. 'product_id' => $value['product_id'],
  64. 'number' => $value['number'],
  65. 'mark' => $value['mark'] ?? '',
  66. 'cost' => $value['cost'] ?? 0,
  67. 'retail_price' => $value['retail_price'] ?? 0,
  68. 'return_or_exchange' => ReturnExchangeOrderProductInfo::type_two,
  69. 'crt_time' => $time,
  70. 'storehouse_id' => $data['storehouse_id'] ?? 0,
  71. 'basic_type_id' => $value['basic_type_id'] ?? 0,
  72. 'price' => $value['price'],
  73. ];
  74. }
  75. if(! empty($sub)) ReturnExchangeOrderProductInfo::insert($sub);
  76. }
  77. //锁定库存
  78. // ProductInventoryService::changeLockNumber($user, $msg[0],$msg[1]);
  79. }
  80. DB::commit();
  81. }catch (\Throwable $e){
  82. DB::rollBack();
  83. return [false,$e->getMessage()];
  84. }
  85. if(! empty($data['check'])) {
  86. list($status,$msg) = (new CheckService())->checkAll([
  87. "id" => $material_model->id,
  88. "order_number" => $data['order_number'],
  89. "opt_case" => CheckService::six,
  90. "menu_id" => $data['menu_id']
  91. ],$user);
  92. if(! $status) return [true, '保存成功,退换货单提交失败,异常信息:' . $msg];
  93. }
  94. return [true,''];
  95. }
  96. public function add($data,$user){
  97. list($status,$msg) = $this->orderRule($data,$user);
  98. if(!$status) return [$status,$msg];
  99. try{
  100. DB::beginTransaction();
  101. $material_model = new ReturnExchangeOrder();
  102. $material_model->model_type = $data['model_type'];
  103. $material_model->order_number = $data['order_number'];
  104. $material_model->data_id = $data['data_id'];
  105. $material_model->type = $data['type'];
  106. $material_model->difference_amount = $data['difference_amount'];
  107. $material_model->mark = $data['mark'] ?? "";
  108. $material_model->depart_id = $data['depart_id'] ?? 0;
  109. $material_model->top_depart_id = $data['top_depart_id'] ?? 0;
  110. $material_model->crt_id = $user['id'];
  111. $material_model->storehouse_id = $data['storehouse_id'] ?? 0;
  112. $material_model->save();
  113. $time = time();
  114. if($data['model_type'] != ReturnExchangeOrder::Model_type_three){
  115. if(! empty($data['product_one'])){
  116. $sub = [];
  117. foreach ($data['product_one'] as $value){
  118. $sub[] = [
  119. 'return_exchange_id' => $material_model->id,
  120. 'product_id' => $value['product_id'],
  121. 'number' => $value['number'],
  122. 'mark' => $value['mark'] ?? '',
  123. 'cost' => $value['cost'] ?? 0,
  124. 'retail_price' => $value['retail_price'] ?? 0,
  125. 'return_or_exchange' => ReturnExchangeOrderProductInfo::type_one,
  126. 'crt_time' => $time,
  127. 'storehouse_id' => $data['storehouse_id'] ?? 0,
  128. 'basic_type_id' => $value['basic_type_id'] ?? 0,
  129. 'price' => $value['price'],
  130. 'final_amount' => $value['final_amount'] ?? 0,
  131. 'return_exchange_price' => $value['return_exchange_price'],
  132. ];
  133. }
  134. ReturnExchangeOrderProductInfo::insert($sub);
  135. }
  136. if(! empty($data['product_two'])){
  137. $sub = [];
  138. foreach ($data['product_two'] as $value){
  139. if(empty($value['product_id'])) continue;
  140. $sub[] = [
  141. 'return_exchange_id' => $material_model->id,
  142. 'product_id' => $value['product_id'],
  143. 'number' => $value['number'],
  144. 'mark' => $value['mark'] ?? '',
  145. 'cost' => $value['cost'] ?? 0,
  146. 'retail_price' => $value['retail_price'] ?? 0,
  147. 'return_or_exchange' => ReturnExchangeOrderProductInfo::type_two,
  148. 'crt_time' => $time,
  149. 'storehouse_id' => $data['storehouse_id'] ?? 0,
  150. 'basic_type_id' => $value['basic_type_id'] ?? 0,
  151. 'price' => $value['price'],
  152. ];
  153. }
  154. if(! empty($sub)) ReturnExchangeOrderProductInfo::insert($sub);
  155. }
  156. //锁定库存
  157. // ProductInventoryService::changeLockNumber($user, $msg[0],[]);
  158. }
  159. //单据创建时是否校验库存
  160. (new CheckService())->orderInventoryInsert(['order_number' => $data['order_number'], 'is_check_stock' => $data['is_check_stock']]);
  161. DB::commit();
  162. }catch (\Throwable $exception){
  163. DB::rollBack();
  164. if (str_contains($exception->getMessage(), '1062') || str_contains($exception->getMessage(), 'Duplicate entry')) {
  165. return [false, '网络波动,请重新操作!'];
  166. }
  167. return [false,$exception->getMessage()];
  168. }
  169. (new OperationLogService())->setOperationList($data,$user);
  170. if(! empty($data['check'])) {
  171. list($status,$msg) = (new CheckService())->checkAll([
  172. "id" => $material_model->id,
  173. "order_number" => $data['order_number'],
  174. "opt_case" => CheckService::six,
  175. "menu_id" => $data['menu_id']
  176. ],$user);
  177. // if(! $status) return [true, '保存成功,退换货单提交失败,异常信息:' . $msg];
  178. }
  179. return [true, ''];
  180. }
  181. public function detail($data,$user){
  182. if(empty($data['id']) && empty($data['order_number'])) return [false,'请选择数据!'];
  183. if(! empty($data['id'])){
  184. $order = ReturnExchangeOrder::where('del_time',0)
  185. ->where('id',$data['id'])
  186. ->first();
  187. }else{
  188. $order = ReturnExchangeOrder::where('del_time',0)
  189. ->where('order_number',$data['order_number'])
  190. ->first();
  191. $data['id'] = empty($order->id) ? 0 : $order->id;
  192. }
  193. if(empty($order)) return [false, '退换货订单不存在或已被删除'];
  194. $order = $order->toArray();
  195. $order['storehouse_title'] = "";
  196. if($order['storehouse_id'] > 0) $order['storehouse_title'] = Storehouse::where('id',$order['storehouse_id'])->value('title');
  197. $order['model_type_title'] = ReturnExchangeOrder::$model_type_name[$order['model_type']] ?? "";
  198. $order['product_one'] = $order['product_two'] = $order['depart'] = $order['employee'] = [];
  199. $info = ReturnExchangeOrderProductInfo::where('del_time',0)
  200. ->where('return_exchange_id',$data['id'])
  201. ->get()->toArray();
  202. $basic_price = BasicType::whereIn('id',array_unique(array_column($info,'basic_type_id')))->pluck('title','id')->toArray();
  203. $map = (new ProductService())->getProductDetail(array_column($info,'product_id'));
  204. foreach ($info as $value){
  205. $tmp = $map[$value['product_id']] ?? [];
  206. $value['title'] = $tmp['title'] ?? "";
  207. $value['code'] = $tmp['code'] ?? "";
  208. $value['size'] = $tmp['size'] ?? "";
  209. $value['unit'] = $tmp['unit'] ?? "";
  210. $value['bar_code'] = $tmp['bar_code'] ?? "";
  211. $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
  212. if($value['return_or_exchange'] == ReturnExchangeOrderProductInfo::type_one){
  213. $order['product_one'][] = $value;
  214. }else{
  215. $order['product_two'][] = $value;
  216. }
  217. }
  218. $order['crt_name'] = Employee::where('id',$order['crt_id'])->value('emp_name');
  219. $order['crt_time'] = $order['crt_time'] ? date("Y-m-d H:i:s",$order['crt_time']): '';
  220. //订单状态数据组织
  221. $state_array = $this->getStateMake([$order]);
  222. $order['state_title'] = $this->makeState($order,$state_array);
  223. //可见范围
  224. $return = (new RangeService())->RangeDetail($data['id'],SeeRange::type_six);
  225. $order['depart'] = $return[0] ?? [];
  226. $order['employee'] = $return[1] ?? [];
  227. $order['related_orders'] = [];
  228. //关联订单信息
  229. if($order['type'] == ReturnExchangeOrder::Order_type){
  230. $sales = SalesOrder::where('id',$order['data_id'])->value('order_number');
  231. $order['data_title'] = $sales;
  232. list($status, $msg) = (new SalesOrderService())->detail(['id' => $order['data_id']], $user);
  233. if($status){
  234. $order['related_orders'] = [
  235. 'product' => $msg['product'],
  236. 'activity_product' => $msg['activity_product'],
  237. 'payment_receipt_list' => $msg['payment_receipt_list'],
  238. ];
  239. }
  240. }elseif($order['type'] == ReturnExchangeOrder::Order_type2){
  241. $sales = PurchaseOrder::where('id',$order['data_id'])->value('order_number');
  242. $order['data_title'] = $sales;
  243. list($status, $msg) = (new PurchaseOrderService())->detail(['order_number' => $sales], $user);
  244. if($status){
  245. $order['related_orders'] = [
  246. 'product' => $msg['product'],
  247. 'activity_product' => $msg['activity_product'],
  248. 'payment_receipt_list' => $msg['payment_receipt_list'],
  249. ];
  250. }
  251. }
  252. return [true, $order];
  253. }
  254. public function del($data,$user){
  255. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  256. $order = ReturnExchangeOrder::where('del_time',0)->where('id',$data['id'])->first();
  257. if(empty($order)) return [false,'退换货单不存在或已被删除'];
  258. $order = $order->toArray();
  259. if($order['state'] > ReturnExchangeOrder::State_zero) return [false,'请确认退换货单状态,删除失败!'];
  260. $product_save_minus = $this->getSaveDetailMinus($data['id']);
  261. try{
  262. DB::beginTransaction();
  263. ReturnExchangeOrder::where('id',$data['id'])->update([
  264. 'del_time'=>time()
  265. ]);
  266. ReturnExchangeOrderProductInfo::where('return_exchange_id',$data['id'])->update([
  267. 'del_time'=>time()
  268. ]);
  269. //锁定库存
  270. // ProductInventoryService::changeLockNumber($user, [], $product_save_minus);
  271. (new RangeService())->RangeDelete($data['id'],SeeRange::type_six);
  272. DB::commit();
  273. }catch (\Throwable $e){
  274. DB::rollBack();
  275. return [false,$e->getMessage()];
  276. }
  277. return [true,''];
  278. }
  279. public function returnCommon($data,$user,$field = []){
  280. if(empty($field)){
  281. $field = ['id','order_number','data_id','difference_amount','state','crt_time','crt_id','mark','model_type','storehouse_id','type'];
  282. }
  283. $model = ReturnExchangeOrder::Clear($user,$data);
  284. $model = $model->where('del_time',0)
  285. ->select($field)
  286. ->orderby('id', 'desc');
  287. if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
  288. if(isset($data['state'])) $model->where('state',$data['state']);
  289. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  290. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  291. $model->whereBetween('crt_time',[$return[0],$return[1]]);
  292. }
  293. if(isset($data['type'])) $model->where('type',$data['type']);
  294. if(! empty($data['model_type'])) $model->where('model_type',$data['model_type']);
  295. if(! empty($data['order'])){
  296. $search = -1;
  297. if(isset($data['type'])) $search = $data['type'];
  298. $id = $this->getDataId($search,$user,$data);
  299. $model->whereIn('data_id',$id);
  300. }
  301. if(! empty($data['time_type'])) {
  302. if($data['time_type'] == 1) {
  303. $start = strtotime('today');
  304. $end = strtotime('tomorrow') - 1;
  305. }elseif ($data['time_type'] == 2){
  306. $start = strtotime('this week',strtotime('today'));
  307. $end = strtotime('this week +6 days 23:59:59', strtotime('today'));
  308. }
  309. if(! empty($start) && ! empty($end)) {
  310. $model->where('crt_time','>=',$start);
  311. $model->where('crt_time','<=',$end);
  312. }
  313. }
  314. if(! empty($data['wx_crt_time'][0]) && ! empty($data['wx_crt_time'][1])) {
  315. $model->where('crt_time','>=',$data['wx_crt_time'][0]);
  316. $model->where('crt_time','<=',$data['wx_crt_time'][1]);
  317. }
  318. return $model;
  319. }
  320. public function getList($data,$user){
  321. $model = $this->returnCommon($data, $user);
  322. $list = $this->limit($model,'',$data);
  323. $list = $this->fillListData($list);
  324. $count = $this->countData("crt_time", $data, $user);
  325. $list['today'] = $count[0] ?? 0;
  326. $list['yesterday'] = $count[1] ?? 0;
  327. return [true, $list];
  328. }
  329. public function countData($column = "", $data, $user){
  330. if(empty($column) || empty($data['from_wx'])) return [0, 0];
  331. // 获取今天的开始和结束时间戳
  332. $todayStart = Carbon::today()->startOfDay()->timestamp;
  333. $todayEnd = Carbon::today()->endOfDay()->timestamp;
  334. // 获取昨天的开始和结束时间戳
  335. $yesterdayStart = Carbon::yesterday()->startOfDay()->timestamp;
  336. $yesterdayEnd = Carbon::yesterday()->endOfDay()->timestamp;
  337. $data['wx_' . $column] = [$todayStart, $todayEnd];
  338. $model = $this->returnCommon($data, $user);
  339. // 查询今天的数据条数
  340. $todayCount = $model->count();
  341. $data['wx_' . $column] = [$yesterdayStart, $yesterdayEnd];
  342. $model = $this->returnCommon($data, $user);
  343. // 查询昨天的数据条数
  344. $yesterdayCount = $model->count();
  345. return [$todayCount, $yesterdayCount];
  346. }
  347. public function getDataId($search,$user,$data){
  348. if($search < 0){
  349. $model2 = SalesOrder::Clear($user,$data);
  350. $sale = $model2->where('del_time',0)
  351. ->where('order_number', 'LIKE', '%'.$data['order'].'%')
  352. ->select('id')
  353. ->get()->toArray();
  354. $model2 = PurchaseOrder::Clear($user,$data);
  355. $purchase = $model2->where('del_time',0)
  356. ->where('order_number', 'LIKE', '%'.$data['order'].'%')
  357. ->select('id')
  358. ->get()->toArray();
  359. return array_unique(array_merge_recursive(array_column($sale,'id'),array_column($purchase,'id')));
  360. }elseif ($search == 0){
  361. $model2 = SalesOrder::Clear($user,$data);
  362. $sale = $model2->where('del_time',0)
  363. ->where('order_number', 'LIKE', '%'.$data['order'].'%')
  364. ->select('id')
  365. ->get()->toArray();
  366. return array_column($sale,'id');
  367. }else{
  368. $model2 = PurchaseOrder::Clear($user,$data);
  369. $purchase = $model2->where('del_time',0)
  370. ->where('order_number', 'LIKE', '%'.$data['order'].'%')
  371. ->select('id')
  372. ->get()->toArray();
  373. return array_column($purchase,'id');
  374. }
  375. }
  376. public function fillListData($data){
  377. if(empty($data['data'])) return $data;
  378. $emp_id = array_unique(array_merge_recursive(array_column($data['data'],'crt_id')));
  379. $emp_map = Employee::whereIn('id',$emp_id)
  380. ->pluck('emp_name','id')
  381. ->toArray();
  382. $sales = $purchase = [];
  383. foreach ($data['data'] as $value){
  384. if($value['type'] == ReturnExchangeOrder::Order_type){
  385. $sales[] = $value['data_id'];
  386. }elseif($value['type'] == ReturnExchangeOrder::Order_type2){
  387. $purchase[] = $value['data_id'];
  388. }
  389. }
  390. $sales = SalesOrder::whereIn('id',$sales)->pluck('order_number','id')->toArray();
  391. $purchase = PurchaseOrder::whereIn('id',$purchase)->pluck('order_number','id')->toArray();
  392. $storehouse = Storehouse::whereIn('id',array_unique(array_column($data['data'],'storehouse_id')))
  393. ->pluck('title','id')
  394. ->toArray();
  395. //订单状态数据组织
  396. $state_array = $this->getStateMake($data['data']);
  397. foreach ($data['data'] as $key => $value){
  398. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']) : '';
  399. $crt_name = $emp_map[$value['crt_id']] ?? '';
  400. $data['data'][$key]['crt_name'] = $crt_name;
  401. $data['data'][$key]['state_title'] = $this->makeState($data['data'][$key],$state_array);
  402. // $data['data'][$key]['state_title'] = ReturnExchangeOrder::$state[$value['state']] ?? '';
  403. $title = "" ;
  404. if($value['type'] == ReturnExchangeOrder::Order_type){
  405. $title = $sales[$value['data_id']] ?? "";
  406. }elseif($value['type'] == ReturnExchangeOrder::Order_type2){
  407. $title = $purchase[$value['data_id']] ?? "";
  408. }
  409. $data['data'][$key]['data_title'] = $title;
  410. $data['data'][$key]['type_title'] = ReturnExchangeOrder::$order_type_name[$value['type']] ?? "";
  411. $data['data'][$key]['model_type_title'] = ReturnExchangeOrder::$model_type_name[$value['model_type']] ?? "";
  412. $data['data'][$key]['storehouse_title'] = $storehouse[$value['storehouse_id']] ?? '';
  413. }
  414. return $data;
  415. }
  416. public function getStateMake($data){
  417. if(empty($data)) return [];
  418. $order_no = [];
  419. foreach ($data as $value){
  420. if(! in_array($value['state'], [ReturnExchangeOrder::State_minus_one,ReturnExchangeOrder::State_one])) continue;
  421. $order_no[] = $value['order_number'];
  422. }
  423. return (new OaService())->getOaTeamDetailList($order_no);
  424. }
  425. public function makeState($value, $state_array){
  426. if(! empty($state_array[$value['order_number']])){
  427. $return = $state_array[$value['order_number']];
  428. if($value['state'] == ReturnExchangeOrder::State_minus_one){
  429. $state = "驳回:" . $return;
  430. }else{
  431. $state = "待" . $return . "审核";
  432. }
  433. }elseif($value['state'] == ReturnExchangeOrder::State_zero){
  434. $state = "待" . $value['crt_name'] . "提交";
  435. }else{
  436. $state = ReturnExchangeOrder::$state[$value['state']] ?? '';
  437. }
  438. return $state;
  439. }
  440. public function orderRule(&$data, $user, $is_check = true){
  441. if($this->isEmpty($data,'model_type')) return [false,'单据类型不能为空!'];
  442. if(! in_array($data['model_type'], ReturnExchangeOrder::$model_type)) return [false,'单据类型不存在'];
  443. //所属部门 以及 顶级部门
  444. if(empty($data['depart_id'])) {
  445. $data['depart_id'] = $this->getDepart($user);
  446. $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
  447. }
  448. if(! isset($data['type'])) return [false,'退换单据类型不能为空'];
  449. if(empty($data['data_id'])) return [false,'退换单据数据不能为空!'];
  450. $res = $this->checkNumber($data['difference_amount']);
  451. if(! $res) return [false, '金额请输入不超过两位小数并且大于等于0的数值'];
  452. $data['is_check_stock'] = $user['is_check_stock'];
  453. $total = 0;
  454. if($data['type'] == ReturnExchangeOrder::Order_type){
  455. $sale = SalesOrder::where('del_time',0)->where('id',$data['data_id'])->first();
  456. if(empty($sale)) return [false,'合同不存在或已被删除'];
  457. $sale = $sale->toArray();
  458. // if($sale['sales_order_type'] != SalesOrder::Order_type_one) return [false, '非安装件合同'];
  459. if($sale['sales_order_type'] == SalesOrder::Order_type_one && $sale['state'] < SalesOrder::State_two) return [false,'安装件合同未确认,不能进行退换货操作'];
  460. $order_number = $sale['order_number'];
  461. $total = $sale['contract_fee'];
  462. }elseif ($data['type'] == ReturnExchangeOrder::Order_type2){
  463. $purchase = PurchaseOrder::where('del_time',0)->where('id',$data['data_id'])->first();
  464. if(empty($purchase)) return [false,'采购单不存在或已被删除'];
  465. $purchase = $purchase->toArray();
  466. if($purchase['state'] < PurchaseOrder::STATE_Four) return [false,'采购单未入库,不能进行退换货操作'];
  467. $order_number = $purchase['order_number'];
  468. $total = $purchase['purchase_total'];
  469. }
  470. if(! empty($order_number)){
  471. list($status,$msg) = $this->limitingSendRequestBackgExpire("returnExchangeOrder" . $order_number);
  472. if(! $status) return [false, $msg];
  473. }
  474. //换货
  475. $product_submit_minus = $product_save_minus = [];
  476. if($data['model_type'] == ReturnExchangeOrder::Model_type_three){
  477. //仅退款
  478. //剩余能退金额计算
  479. $id = $data['id'] ?? 0;
  480. $save_money = $this->getSaveReturnALLCompareMessage($id, $data['data_id'], $data['type']);
  481. $save_money = $save_money[$data['data_id']] ?? 0;
  482. $money = bcsub($total,$save_money,2);
  483. if($data['difference_amount'] > $money) return [false,'剩余能退金额最大为'. $money];
  484. }else{
  485. if(empty($data['storehouse_id'])) return [false,'请选择仓库'];
  486. //退货
  487. $return_submit_add = [];
  488. if(empty($data['product_one'])) return [false,'退货产品不能为空'];
  489. foreach ($data['product_one'] as $value){
  490. if(empty($value['number'])) return [false,'退货产品数量不能为空'];
  491. $res = $this->checkNumber($value['number']);
  492. if(! $res) return [false,'请输入正确的退货产品数量'];
  493. if(isset($return_submit_add[$value['product_id']])){
  494. $return_submit_add[$value['product_id']] += $value['number'];
  495. }else{
  496. $return_submit_add[$value['product_id']] = $value['number'];
  497. }
  498. }
  499. if($data['type'] == ReturnExchangeOrder::Order_type){
  500. //剩余能退
  501. $id = $data['id'] ?? 0;
  502. list($s_product,$s_money) = $this->getSaveReturnCompareMessage($id, $data['data_id']);
  503. $save_money = $s_money[$data['data_id']] ?? 0;
  504. $money = bcsub($total,$save_money,2);
  505. if($data['difference_amount'] > $money) return [false,'剩余能退金额最大为'. $money];
  506. //比较
  507. foreach ($return_submit_add as $pro => $number){
  508. if(! isset($s_product[$pro])) return [false,'退货产品错误,合同中不存在该产品'];
  509. $s_number = $s_product[$pro];
  510. if($number > $s_number) return [false,'退货产品数量不能超过合同产品数据'];
  511. }
  512. }elseif ($data['type'] == ReturnExchangeOrder::Order_type2){
  513. //剩余能退
  514. $id = $data['id'] ?? 0;
  515. list($s_product,$s_money) = $this->getSaveReturnCompareMessage2($id, $data['data_id']);
  516. $save_money = $s_money[$data['data_id']] ?? 0;
  517. $money = bcsub($total,$save_money,2);
  518. if($data['difference_amount'] > $money) return [false,'剩余能退金额最大为'. $money];
  519. //比较
  520. foreach ($return_submit_add as $pro => $number){
  521. if(! isset($s_product[$pro])) return [false,'退货产品错误,采购单中不存在该产品'];
  522. $s_number = $s_product[$pro];
  523. if($number > $s_number) return [false,'退货产品数量不能超过合采购单产品数据'];
  524. }
  525. }
  526. //换货
  527. // $product_id = [];
  528. // if($data['model_type'] == ReturnExchangeOrder::Model_type_two){
  529. // if(empty($data['product_two'])) return [false,'换货产品不能为空'];
  530. // foreach ($data['product_two'] as $value){
  531. // if(empty($value['number'])) return [false,'换货产品数量不能为空'];
  532. // $res = $this->checkNumber($value['number']);
  533. // if(! $res) return [false,'请输入正确的换货产品数量'];
  534. //
  535. // $key = $value['product_id'] . ',' .$data['storehouse_id'];
  536. // if(isset($product_submit_minus[$key])){
  537. // $product_submit_minus[$key] += $value['number'];
  538. // }else{
  539. // $product_submit_minus[$key] = $value['number'];
  540. // }
  541. // $product_id[] = $value['product_id'];
  542. // }
  543. //
  544. // //是否校验库存
  545. // ProductInventoryService::is_check($user,$data);
  546. //
  547. // $product_save_minus = $this->getSaveDetailMinus($id);
  548. // list($status,$msg) = (new ProductInventoryService())->compareStock($user,$product_id, $product_submit_minus, $product_save_minus);
  549. // if(! $status) return [false, $msg];
  550. // }
  551. }
  552. if($is_check){
  553. $prefix = ReturnExchangeOrder::$prefix[$data['model_type']] ?? "";
  554. $order_number = (new OrderNoService())->createReturnExchangeOrderNumber($prefix);
  555. if(empty($order_number)) return [false,'退换货单号生成失败!'];
  556. $data['order_number'] = $order_number;
  557. }else{
  558. if($this->isEmpty($data,'id')) return [false,'退换货单ID不能为空!'];
  559. if($this->isEmpty($data,'order_number')) return [false,'退换货单号不能为空!'];
  560. $booking = ReturnExchangeOrder::where('del_time',0)->where('id',$data['id'])->first();
  561. if(empty($booking)) return [false,'退换货单不存在或已被删除'];
  562. $booking = $booking->toArray();
  563. if(! in_array($booking['state'],[ReturnExchangeOrder::State_zero,ReturnExchangeOrder::State_minus_one])) return [false,'请确认退换货单状态,编辑失败'];
  564. }
  565. return [true, [$product_submit_minus,$product_save_minus]];
  566. }
  567. /**
  568. * 获取保存详情
  569. * @param $order_number
  570. * @return array
  571. */
  572. public function getSaveDetailMinus($id = 0){
  573. $product_save = [];
  574. if(empty($id)) return $product_save;
  575. $sub = ReturnExchangeOrderProductInfo::where('return_exchange_id',$id)
  576. ->where('return_or_exchange',ReturnExchangeOrderProductInfo::type_two)
  577. ->where('del_time',0)
  578. ->get()->toArray();
  579. foreach ($sub as $value){
  580. $key = $value['product_id'] . ',' . $value['storehouse_id'];
  581. if(isset($product_save[$key])){
  582. $product_save[$key] += $value['number'];
  583. }else{
  584. $product_save[$key] = $value['number'];
  585. }
  586. }
  587. return $product_save;
  588. }
  589. //剩余能退
  590. public function getSaveReturnALLCompareMessage($id = 0, $order_id = 0, $type = 0){
  591. $return = ReturnExchangeOrder::where('del_time',0)
  592. ->where('type',$type)
  593. ->where('data_id',$order_id)
  594. ->when(! empty($id), function ($query) use ($id) {
  595. return $query->where('id', '<>',$id);
  596. })
  597. ->select('data_id','difference_amount')->get()->toArray();
  598. $total_save = [];
  599. foreach ($return as $value){
  600. if(isset($total_save[$value['data_id']])){
  601. $total_save[$value['data_id']] += $value['difference_amount'];
  602. }else{
  603. $total_save[$value['data_id']] = $value['difference_amount'];
  604. }
  605. }
  606. return $total_save;
  607. }
  608. //合同剩余能退
  609. public function getSaveReturnCompareMessage($id = 0, $sales_order_id = 0){
  610. $return = ReturnExchangeOrder::where('del_time',0)
  611. ->where('data_id',$sales_order_id)
  612. ->where('type',ReturnExchangeOrder::Order_type)
  613. ->select('id','data_id','difference_amount')->get()->toArray();
  614. $total_save = [];
  615. foreach ($return as $value){
  616. if($id > 0 && $value['id'] == $id) continue;
  617. if(isset($total_save[$value['data_id']])){
  618. $total_save[$value['data_id']] += $value['difference_amount'];
  619. }else{
  620. $total_save[$value['data_id']] = $value['difference_amount'];
  621. }
  622. }
  623. $return = array_column($return,'id');
  624. $product_save = [];
  625. $sub = ReturnExchangeOrderProductInfo::where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
  626. ->where('del_time',0)
  627. ->whereIn('return_exchange_id',$return)
  628. ->when(! empty($id), function ($query) use ($id) {
  629. return $query->where('return_exchange_id', '<>',$id);
  630. })
  631. ->get()->toArray();
  632. foreach ($sub as $value){
  633. if(isset($product_save[$value['product_id']])){
  634. $product_save[$value['product_id']] += $value['number'];
  635. }else{
  636. $product_save[$value['product_id']] = $value['number'];
  637. }
  638. }
  639. $sales_order_product = [];
  640. $sales_product = SalesOrderProductInfo::where('del_time',0)
  641. ->where('sales_order_id',$sales_order_id)
  642. ->get()->toArray();
  643. foreach ($sales_product as $value){
  644. $product_save_tmp = $product_save[$value['product_id']] ?? 0;
  645. if(isset($sales_order_product[$value['product_id']])){
  646. $sales_order_product[$value['product_id']] += $value['number'];
  647. }else{
  648. $sales_order_product[$value['product_id']] = $value['number'] - $product_save_tmp;
  649. }
  650. }
  651. return [$sales_order_product, $total_save];
  652. }
  653. //采购剩余能退
  654. public function getSaveReturnCompareMessage2($id = 0, $purchase_id = 0){
  655. $return = ReturnExchangeOrder::where('del_time',0)
  656. ->where('data_id',$purchase_id)
  657. ->where('type',ReturnExchangeOrder::Order_type2)
  658. ->select('id','data_id','difference_amount')->get()->toArray();
  659. $total_save = [];
  660. foreach ($return as $value){
  661. if($id > 0 && $value['id'] == $id) continue;
  662. if(isset($total_save[$value['data_id']])){
  663. $total_save[$value['data_id']] += $value['difference_amount'];
  664. }else{
  665. $total_save[$value['data_id']] = $value['difference_amount'];
  666. }
  667. }
  668. $return = array_column($return,'id');
  669. $product_save = [];
  670. $sub = ReturnExchangeOrderProductInfo::where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
  671. ->where('del_time',0)
  672. ->whereIn('return_exchange_id',$return)
  673. ->when(! empty($id), function ($query) use ($id) {
  674. return $query->where('return_exchange_id', '<>',$id);
  675. })
  676. ->get()->toArray();
  677. foreach ($sub as $value){
  678. if(isset($product_save[$value['product_id']])){
  679. $product_save[$value['product_id']] += $value['number'];
  680. }else{
  681. $product_save[$value['product_id']] = $value['number'];
  682. }
  683. }
  684. $sales_order_product = [];
  685. $sales_product = PurchaseOrderInfo::where('del_time',0)
  686. ->where('purchase_order_id',$purchase_id)
  687. ->get()->toArray();
  688. foreach ($sales_product as $value){
  689. $product_save_tmp = $product_save[$value['product_id']] ?? 0;
  690. if(isset($sales_order_product[$value['product_id']])){
  691. $sales_order_product[$value['product_id']] += $value['number'];
  692. }else{
  693. $sales_order_product[$value['product_id']] = $value['number'] - $product_save_tmp;
  694. }
  695. }
  696. return [$sales_order_product,$total_save];
  697. }
  698. //获取差异金额(合同和采购详情中统计的)
  699. public function getDifferentAmount($id = 0, $type = 0){
  700. if(empty($id)) return [];
  701. $result = ReturnExchangeOrder::where('del_time',0)
  702. ->where('data_id',$id)
  703. ->where('type',$type)
  704. ->select('id','model_type','order_number','difference_amount','state')
  705. ->get()->toArray();
  706. foreach ($result as $key => $value){
  707. $result[$key]['model_type_title'] = ReturnExchangeOrder::$model_type_name[$value['model_type']] ?? "";
  708. $result[$key]['state_title'] = ReturnExchangeOrder::$state[$value['state']] ?? "";
  709. }
  710. return $result;
  711. }
  712. //获取差异金额(合同和采购列表中统计的)
  713. public function getDifferentAmountALL($id = [], $type = 0){
  714. if(empty($id)) return [];
  715. $result = ReturnExchangeOrder::where('del_time',0)
  716. // ->where('state',ReturnExchangeOrder::State_two)
  717. ->whereIn('data_id',$id)
  718. ->where('type',$type)
  719. ->select('id','model_type','order_number','difference_amount','state','data_id')
  720. ->get()->toArray();
  721. $return = [];
  722. foreach ($result as $value){
  723. if(isset($return[$value['data_id']])){
  724. $return[$value['data_id']] += $value['difference_amount'];
  725. }else{
  726. $return[$value['data_id']] = $value['difference_amount'];
  727. }
  728. }
  729. return $return;
  730. }
  731. //获取差异金额(收付款单详情中统计的)
  732. public function getDifferentAmountALL2($order_no = [], $type = 0){
  733. if(empty($order_no)) return [];
  734. if(! $type){
  735. $order = SalesOrder::whereIn('order_number',$order_no)->select('id','order_number')->get()->toArray();
  736. }else{
  737. $order = PurchaseOrder::whereIn('order_number',$order_no)->select('id','order_number')->get()->toArray();
  738. }
  739. $id = array_column($order,'id');
  740. $order_map = array_column($order,'order_number','id');
  741. $result = ReturnExchangeOrder::where('del_time',0)
  742. // ->where('state',ReturnExchangeOrder::State_two)
  743. ->whereIn('data_id',$id)
  744. ->where('type',$type)
  745. ->select('id','model_type','order_number','difference_amount','state','data_id')
  746. ->get()->toArray();
  747. $return = [];
  748. foreach ($result as $value){
  749. $order_nos = $order_map[$value['data_id']] ?? "";
  750. if(isset($return[$order_nos])){
  751. $return[$order_nos] += $value['difference_amount'];
  752. }else{
  753. $return[$order_nos] = $value['difference_amount'];
  754. }
  755. }
  756. return $return;
  757. }
  758. //获取差异金额(合同和采购列表中统计的)新
  759. public function getDifferentAmountALLNew($id = [], $type = 0){
  760. if(empty($id)) return [];
  761. $result = ReturnExchangeOrder::where('del_time',0)
  762. ->whereIn('data_id',$id)
  763. ->where('type',$type)
  764. ->select('id','model_type','order_number','difference_amount','state','data_id')
  765. ->get()->toArray();
  766. $return = $return1 = [];
  767. foreach ($result as $value){
  768. if(isset($return[$value['data_id']])){
  769. $return[$value['data_id']] += $value['difference_amount'];
  770. }else{
  771. $return[$value['data_id']] = $value['difference_amount'];
  772. }
  773. if($value['state'] == ReturnExchangeOrder::State_two){
  774. if(isset($return1[$value['data_id']])){
  775. $return1[$value['data_id']] += $value['difference_amount'];
  776. }else{
  777. $return1[$value['data_id']] = $value['difference_amount'];
  778. }
  779. }
  780. }
  781. return [$return,$return1];
  782. }
  783. }