ReturnExchangeOrderService.php 45 KB

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