OrderLogic.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | likeshop100%开源免费商用商城系统
  4. // +----------------------------------------------------------------------
  5. // | 欢迎阅读学习系统程序代码,建议反馈是我们前进的动力
  6. // | 开源版本可自由商用,可去除界面版权logo
  7. // | 商业版本务必购买商业授权,以免引起法律纠纷
  8. // | 禁止对系统程序代码以任何目的,任何形式的再发布
  9. // | gitee下载:https://gitee.com/likeshop_gitee
  10. // | github下载:https://github.com/likeshop-github
  11. // | 访问官网:https://www.likeshop.cn
  12. // | 访问社区:https://home.likeshop.cn
  13. // | 访问手册:http://doc.likeshop.cn
  14. // | 微信公众号:likeshop技术社区
  15. // | likeshop团队 版权所有 拥有最终解释权
  16. // +----------------------------------------------------------------------
  17. // | author: likeshopTeam
  18. // +----------------------------------------------------------------------
  19. namespace app\businessapi\logic;
  20. use app\common\enum\AfterSaleEnum;
  21. use app\common\enum\AfterSaleLogEnum;
  22. use app\common\enum\DeliveryEnum;
  23. use app\common\enum\GoodsEnum;
  24. use app\common\enum\NoticeEnum;
  25. use app\common\enum\OrderEnum;
  26. use app\common\enum\OrderLogEnum;
  27. use app\common\enum\PayEnum;
  28. use app\common\enum\TeamEnum;
  29. use app\common\enum\VerificationEnum;
  30. use app\common\enum\YesNoEnum;
  31. use app\common\logic\BaseLogic;
  32. use app\common\logic\PayNotifyLogic;
  33. use app\common\model\AddressLibrary;
  34. use app\common\model\AfterSale;
  35. use app\common\model\AfterSaleGoods;
  36. use app\common\model\Delivery;
  37. use app\common\model\DeliveryTime;
  38. use app\common\model\Express;
  39. use app\common\model\Order;
  40. use app\common\model\OrderGoods;
  41. use app\common\model\OrderLog;
  42. use app\common\model\Region;
  43. use app\common\model\SelffetchShop;
  44. use app\common\model\Verification;
  45. use app\common\service\after_sale\AfterSaleService;
  46. use app\common\service\ConfigService;
  47. use app\common\service\FileService;
  48. use app\common\service\RegionService;
  49. use app\shopapi\logic\TeamLogic;
  50. use expressage\Kd100;
  51. use expressage\Kdniao;
  52. use think\facade\Db;
  53. /**
  54. * 订单逻辑类
  55. * Class OrderLogic
  56. * @package app\businessapi\logic
  57. */
  58. class OrderLogic extends BaseLogic
  59. {
  60. /**
  61. * @notes 订单详情
  62. * @param $params
  63. * @return array
  64. * @author 段誉
  65. * @date 2021/8/2 20:59
  66. */
  67. public function detail($params)
  68. {
  69. $result = (new Order())->with(['order_goods' => function ($query) {
  70. $query->field([
  71. 'id', 'order_id', 'goods_id', 'item_id', 'goods_snap',
  72. 'goods_name', 'goods_price', 'goods_num', 'total_price', 'total_pay_price'
  73. ])->append(['goods_image', 'spec_value_str','original_price'])->hidden(['goods_snap']);
  74. },'user'])
  75. ->where(['id' => $params['id']])
  76. ->append(['businesse_btn', 'delivery_address', 'cancel_unpaid_orders_time', 'show_pickup_code','order_terminal_desc','pay_way_desc','delivery_type_desc'])
  77. ->hidden(['user_id', 'order_terminal', 'transaction_id', 'delete_time', 'update_time'])
  78. ->findOrEmpty()->toArray();
  79. //订单类型
  80. $result['order_type_desc'] = ($result['delivery_type'] == DeliveryEnum::SELF_DELIVERY) ? '自提订单' : OrderEnum::getOrderTypeDesc($result['order_type']);
  81. //订单状态描述
  82. $result['order_status_desc'] = ($result['order_status'] == OrderEnum::STATUS_WAIT_DELIVERY && $result['delivery_type'] == DeliveryEnum::SELF_DELIVERY) ? '待取货' : OrderEnum::getOrderStatusDesc($result['order_status']);
  83. if ($result['order_type'] == OrderEnum::TEAM_ORDER && $result['is_team_success'] != TeamEnum::TEAM_FOUND_SUCCESS) {
  84. $result['order_status_desc'] = ($result['order_status'] == OrderEnum::STATUS_WAIT_DELIVERY) ? TeamEnum::getStatusDesc($result['is_team_success']) : OrderEnum::getOrderStatusDesc($result['order_status']);
  85. }
  86. //自提门店
  87. $result['selffetch_shop'] = SelffetchShop::where('id', $result['selffetch_shop_id'])
  88. ->field('id,name,province,city,district,address,business_start_time,business_end_time')
  89. ->append(['detailed_address'])
  90. ->hidden(['province', 'city', 'district', 'address'])
  91. ->find();
  92. //地址 省市区分隔开
  93. $result['address']->province = Region::where('id', $result['address']->province)->value('name');
  94. $result['address']->city = Region::where('id', $result['address']->city)->value('name');
  95. $result['address']->district = Region::where('id', $result['address']->district)->value('name');
  96. //订单商品原价总价
  97. $result['total_original_price'] = 0;
  98. $result['verification_time'] = '';
  99. if(DeliveryEnum::SELF_DELIVERY == $result['delivery_type']){
  100. $time = Verification::where(['order_id' => $result['id']])->value('create_time');
  101. $time && $result['verification_time'] = date('Y-m-d H:i:s',);
  102. }
  103. //订单商品售后按钮处理
  104. foreach ($result['order_goods'] as &$goods) {
  105. $goods['after_sale_btn'] = 0;//售后按钮关闭
  106. $after_sale = AfterSale::where(['order_goods_id' => $goods['id'], 'order_id' => $params['id']])->findOrEmpty();
  107. $after_sale_goods = AfterSaleGoods::where(['order_goods_id' => $goods['id'], 'after_sale_id' => $after_sale['id']])->findOrEmpty();
  108. $goods['after_sale_id'] = $after_sale_goods['id'] ?? 0;
  109. if ($result['order_status'] == OrderEnum::STATUS_FINISH && $result['after_sale_deadline'] > time() && $after_sale->isEmpty()) {
  110. $goods['after_sale_btn'] = 1;//售后按钮开启
  111. }
  112. if ($result['order_status'] == OrderEnum::STATUS_FINISH && $result['after_sale_deadline'] > time() && $after_sale['status'] == AfterSaleEnum::STATUS_ING) {
  113. $goods['after_sale_btn'] = 2;//售后中
  114. }
  115. if ($result['order_status'] == OrderEnum::STATUS_FINISH && $result['after_sale_deadline'] > time() && $after_sale['status'] == AfterSaleEnum::STATUS_SUCCESS) {
  116. $goods['after_sale_btn'] = 3;//售后成功
  117. }
  118. if ($result['order_status'] == OrderEnum::STATUS_FINISH && $result['after_sale_deadline'] > time() && $after_sale['status'] == AfterSaleEnum::STATUS_FAIL) {
  119. $goods['after_sale_btn'] = 4;//售后失败
  120. }
  121. $goods['total_original_price'] = $goods['original_price'] * $goods['goods_num'];
  122. $result['total_original_price'] += $goods['original_price'] * $goods['goods_num'];
  123. }
  124. $result['total_original_price'] = round($result['total_original_price'],2);
  125. //快递包裹信息
  126. $result['express_parcel'] = Delivery::field('id,order_id,order_goods_info,express_name,invoice_no,send_type,remark,create_time')
  127. ->where(['order_id'=>$result['id']])
  128. ->append(['send_type_desc'])
  129. ->select()->toArray();
  130. return $result;
  131. }
  132. /**
  133. * @notes 修改发货地址
  134. * @param $params
  135. * @throws \think\db\exception\DataNotFoundException
  136. * @throws \think\db\exception\DbException
  137. * @throws \think\db\exception\ModelNotFoundException
  138. * @author cjhao
  139. * @date 2023/2/17 10:20
  140. */
  141. public static function addressEdit($params)
  142. {
  143. Db::startTrans();
  144. try {
  145. $order = Order::find($params['id']);
  146. $address = [
  147. 'contact' => $params['contact'] ?? $order['address']->contact,
  148. 'province' => $params['province'],
  149. 'city' => $params['city'],
  150. 'district' => $params['district'],
  151. 'address' => $params['address'],
  152. 'mobile' => $params['mobile'] ?? $order['address']->mobile,
  153. ];
  154. $order->address = $address;
  155. $order->save();
  156. $change_address= RegionService::getAddress(
  157. [
  158. $params['province_id'] ?? '',
  159. $params['city_id'] ?? '',
  160. $params['district_id'] ?? ''
  161. ],
  162. $params['address'] ?? '',
  163. );
  164. //订单日志
  165. (new OrderLog())->record([
  166. 'type' => OrderLogEnum::TYPE_SHOP,
  167. 'channel' => OrderLogEnum::SHOP_ADDRESS_EDIT,
  168. 'order_id' => $params['id'],
  169. 'operator_id' => $params['admin_id'],
  170. 'content' => '商家修改收货地址为:'.$change_address,
  171. ]);
  172. Db::commit();
  173. return true;
  174. } catch (\Exception $e) {
  175. Db::rollback();
  176. self::$error = $e->getMessage();
  177. return false;
  178. }
  179. }
  180. /**
  181. * @notes 取消订单
  182. * @param $params
  183. * @return bool
  184. * @author cjhao
  185. * @date 2023/2/17 9:48
  186. */
  187. public function cancel($params)
  188. {
  189. Db::startTrans();
  190. try {
  191. $order = Order::find($params['id']);
  192. if ($order['order_type'] == OrderEnum::TEAM_ORDER) {
  193. TeamLogic::signFailTeam($order['id']);
  194. } else {
  195. //更新订单表
  196. $order->order_status = OrderEnum::STATUS_CLOSE;
  197. $order->cancel_time = time();
  198. //TODO 处于已支付状态的发起整单售后
  199. if ($order->pay_status == PayEnum::ISPAID) {
  200. AfterSaleService::orderRefund([
  201. 'order_id' => $params['id'],
  202. 'scene' => AfterSaleLogEnum::SELLER_CANCEL_ORDER
  203. ]);
  204. }
  205. $order->save();
  206. $returnInventory = ConfigService::get('transaction', 'return_inventory');
  207. if ($returnInventory) {
  208. // 需退还库存
  209. AfterSaleService::returnInventory(['order_id' => $order['id']]);
  210. }
  211. $returnCoupon = ConfigService::get('transaction', 'return_coupon');
  212. if ($returnCoupon) {
  213. // 需退还优惠券
  214. AfterSaleService::returnCoupon($order);
  215. }
  216. //订单日志
  217. (new OrderLog())->record([
  218. 'type' => OrderLogEnum::TYPE_SHOP,
  219. 'channel' => OrderLogEnum::SHOP_CANCEL_ORDER,
  220. 'order_id' => $params['id'],
  221. 'operator_id' => $params['admin_id'],
  222. ]);
  223. }
  224. Db::commit();
  225. return true;
  226. } catch (\Exception $e) {
  227. Db::rollback();
  228. self::$error = $e->getMessage();
  229. return false;
  230. }
  231. }
  232. function confirmOfflinePay($params): bool|string
  233. {
  234. try {
  235. $order = Order::where('id', $params['id'])->append([ 'admin_order_btn', 'businesse_btn' ])->findOrEmpty()->toArray();
  236. if (empty($order)) {
  237. throw new \Exception('订单不存在');
  238. }
  239. if (! $order['businesse_btn']['confirm_pay_btn']) {
  240. throw new \Exception('订单已不能确认线下付款');
  241. }
  242. PayNotifyLogic::handle('order', $order['sn']);
  243. return true;
  244. } catch(\Throwable $e) {
  245. self::$error = $e->getMessage();
  246. return false;
  247. }
  248. }
  249. /**
  250. * @notes 查看物流
  251. * @param $params
  252. * @return array[]
  253. * @author ljj
  254. * @date 2021/8/13 6:07 下午
  255. */
  256. public static function orderTraces($params)
  257. {
  258. //订单信息
  259. $order = Order::field('id,sn,pay_time,address,order_type,express_status,order_status')
  260. ->append(['delivery_address'])
  261. ->where('id',$params['id'])
  262. ->find()
  263. ->toArray();
  264. //物流配置
  265. $express_type = ConfigService::get('logistics_config', 'express_type', '');
  266. $express_bird = unserialize(ConfigService::get('logistics_config', 'express_bird', ''));
  267. $express_hundred = unserialize(ConfigService::get('logistics_config', 'express_hundred', ''));
  268. $parcelInfo = Delivery::field('id,order_id,order_goods_info,express_name,express_id,invoice_no,send_type,remark,create_time,delivery_address_info,return_address_info')
  269. ->where(['order_id'=>$order['id']])
  270. ->append(['send_type_desc'])
  271. ->select()->toArray();
  272. foreach ($parcelInfo as $key=>$parcel) {
  273. //查询物流信息
  274. $logisticsInfo = [];
  275. if ($parcel['send_type'] == DeliveryEnum::NO_EXPRESS) {
  276. $logisticsInfo['traces'] = ['无需物流'];
  277. } else {
  278. if (empty($express_type)) {
  279. $logisticsInfo['traces'] = ['暂无物流信息'];
  280. }
  281. //快递配置设置为快递鸟时
  282. if($express_type === 'express_bird') {
  283. $expressage = (new Kdniao($express_bird['ebussiness_id'], $express_bird['app_key']));
  284. $express_field = 'codebird';
  285. } elseif($express_type === 'express_hundred') {
  286. $expressage = (new Kd100($express_hundred['customer'], $express_hundred['app_key']));
  287. $express_field = 'code100';
  288. }
  289. //快递编码
  290. $express_code = Express::where('id',$parcel['express_id'])->value($express_field);
  291. //获取物流轨迹
  292. if (in_array(strtolower($express_code), [ 'sf', 'shunfeng' ])) {
  293. if ($express_type === 'express_bird') {
  294. $expressage->logistics($express_code, $parcel['invoice_no'], substr($order['address']->mobile, -4));
  295. } else {
  296. $expressage->logistics($express_code, $parcel['invoice_no'], $order['address']->mobile);
  297. }
  298. }else {
  299. $expressage->logistics($express_code, $parcel['invoice_no']);
  300. }
  301. $logisticsInfo['traces'] = $expressage->logisticsFormat();
  302. if ($logisticsInfo['traces'] == false) {
  303. $logisticsInfo['traces'] = ['暂无物流信息'];
  304. } else {
  305. foreach ($logisticsInfo['traces'] as &$item) {
  306. $item = array_values(array_unique($item));
  307. }
  308. }
  309. }
  310. $parcelInfo[$key]['logistics_info'] = $logisticsInfo;
  311. $parcelInfo[$key]['express_icon'] = Express::where('id',$parcel['express_id'])->value('icon');
  312. }
  313. $deliveryAddressInfo = !empty($parcelInfo[0]['delivery_address_info']) ? json_decode($parcelInfo[0]['delivery_address_info'],true) : '';
  314. $returnAddressInfo = !empty($parcelInfo[0]['return_address_info']) ? json_decode($parcelInfo[0]['return_address_info'],true) : '';
  315. //待发货商品
  316. $waitDeliveryGoods = OrderGoods::where(['order_id'=>$order['id'],'express_status'=>[DeliveryEnum::NOT_SHIPPED,DeliveryEnum::PART_SHIPPED]])
  317. ->field('id,goods_name,goods_num,goods_price,delivery_num,goods_snap')
  318. ->append(['spec_value_str','goods_image'])
  319. ->hidden(['goods_snap'])->select()->toArray();
  320. return [
  321. 'order_id' => $order['id'],
  322. 'order_sn' => $order['sn'],
  323. 'order_type' => $order['order_type'],
  324. 'order_status' => $order['order_status'],
  325. 'express_status' => $order['express_status'],
  326. 'pay_time' => $order['pay_time'],
  327. 'receipt_address_info' => [
  328. 'addresss' => $order['delivery_address'],
  329. 'contact' => $order['address']->contact,
  330. 'mobile' => $order['address']->mobile,
  331. ],
  332. 'delivery_address_info' => [
  333. 'addresss' => $deliveryAddressInfo['complete_address'] ?? '',
  334. 'contact' => $deliveryAddressInfo['contact'] ?? '',
  335. 'mobile' => $deliveryAddressInfo['mobile'] ?? '',
  336. ],
  337. 'return_address_info' => [
  338. 'addresss' => $returnAddressInfo['complete_address'] ?? '',
  339. 'contact' => $returnAddressInfo['contact'] ?? '',
  340. 'mobile' => $returnAddressInfo['mobile'] ?? '',
  341. ],
  342. 'remark' => $parcelInfo[0]['remark'],
  343. 'parcel_info' => $parcelInfo,
  344. 'wait_delivery_goods' => $waitDeliveryGoods
  345. ];
  346. }
  347. /**
  348. * @notes 确认收货
  349. * @param $params
  350. * @return bool
  351. * @author ljj
  352. * @date 2021/8/11 10:37 上午
  353. */
  354. public function confirm($params)
  355. {
  356. // 启动事务
  357. Db::startTrans();
  358. try {
  359. //更新订单状态
  360. $order = Order::find($params['id']);
  361. $order->order_status = OrderEnum::STATUS_FINISH;
  362. $order->confirm_take_time = time();
  363. $order->after_sale_deadline = self::getAfterSaleDeadline();
  364. $order->save();
  365. //订单日志
  366. (new OrderLog())->record([
  367. 'type' => OrderLogEnum::TYPE_SHOP,
  368. 'channel' => OrderLogEnum::SHOP_CONFIRM_ORDER,
  369. 'order_id' => $params['id'],
  370. 'operator_id' => $params['admin_id'],
  371. ]);
  372. // 提交事务
  373. Db::commit();
  374. return true;
  375. } catch (\Exception $e) {
  376. // 回滚事务
  377. Db::rollback();
  378. self::$error = $e->getMessage();
  379. return false;
  380. }
  381. }
  382. /**
  383. * @notes 获取当前售后
  384. * @return float|int
  385. * @author ljj
  386. * @date 2021/9/1 3:09 下午
  387. */
  388. public static function getAfterSaleDeadline()
  389. {
  390. //是否关闭维权
  391. $afterSale = ConfigService::get('transaction', 'after_sales');
  392. //可维权时间
  393. $afterSaleDays = ConfigService::get('transaction', 'after_sales_days');
  394. if ($afterSale == YesNoEnum::NO) {
  395. $afterSaleDeadline = time();
  396. } else {
  397. $afterSaleDeadline = ($afterSaleDays * 24 * 60 * 60) + time();
  398. }
  399. return $afterSaleDeadline;
  400. }
  401. /**
  402. * @notes 核销订单列表
  403. * @param $params
  404. * @return Order|array|string|\think\Model
  405. * @author cjhao
  406. * @date 2023/2/17 11:42
  407. */
  408. public function getVerificationOrder($params)
  409. {
  410. $order = (new Order())
  411. ->where(['pickup_code' => $params['code']])
  412. ->with(['order_goods' => function ($query) {
  413. $query->field('goods_id,order_id,goods_snap,goods_name,goods_price,goods_num,is_comment,original_price')
  414. ->append(['goods_image', 'spec_value_str'])
  415. ->hidden(['goods_snap']);
  416. }])
  417. ->append(['consignee'])
  418. ->hidden(['address'])
  419. ->field(['id', 'sn', 'user_id', 'order_type', 'order_status', 'total_num', 'order_amount', 'delivery_type', 'pay_status', 'address', 'create_time','verification_status'])
  420. ->order(['id' => 'desc'])
  421. ->findOrEmpty();
  422. if($order->isEmpty()) {
  423. return '订单不存在';
  424. }
  425. return $order->toArray();
  426. }
  427. /**
  428. * @notes 订单核销
  429. * @param $params
  430. * @return bool|string[]
  431. * @author cjhao
  432. * @date 2023/2/17 11:58
  433. */
  434. public function verification($params)
  435. {
  436. try {
  437. //校验是否有售后
  438. if ($params['confirm'] != 1) {
  439. $order_goods = OrderGoods::where(['order_id'=>$params['id']])->select()->toArray();
  440. foreach ($order_goods as $goods) {
  441. $after_sale = AfterSale::where(['order_goods_id' => $goods['id'], 'order_id' => $goods['order_id'],'status'=>[AfterSaleEnum::STATUS_ING,AfterSaleEnum::STATUS_SUCCESS]])->findOrEmpty();
  442. if (!$after_sale->isEmpty()) {
  443. return ['msg'=>'有商品处于售后中或已售后成功,请谨慎操作'];
  444. }
  445. }
  446. }
  447. $order = Order::find($params['id']);
  448. //添加核销记录
  449. $snapshot = [
  450. 'sn' => $params['admin_info']['account'],
  451. 'name' => $params['admin_info']['name']
  452. ];
  453. $verification = new Verification;
  454. $verification->order_id = $params['id'];
  455. $verification->selffetch_shop_id = $order['selffetch_shop_id'];
  456. $verification->handle_id = $params['admin_info']['admin_id'];
  457. $verification->verification_scene = VerificationEnum::TYPE_ADMIN;
  458. $verification->snapshot = json_encode($snapshot);
  459. $verification->save();
  460. //更新订单状态
  461. $order->order_status = OrderEnum::STATUS_FINISH;
  462. $order->verification_status = OrderEnum::WRITTEN_OFF;
  463. $order->confirm_take_time = time();
  464. $order->after_sale_deadline = self::getAfterSaleDeadline();
  465. $order->save();
  466. //订单日志
  467. (new OrderLog())->record([
  468. 'type' => OrderLogEnum::TYPE_SHOP,
  469. 'channel' => OrderLogEnum::SHOP_VERIFICATION,
  470. 'order_id' => $params['id'],
  471. 'operator_id' => $params['admin_info']['admin_id'],
  472. ]);
  473. return true;
  474. } catch (\Exception $e) {
  475. //错误
  476. self::$error = $e->getMessage();
  477. return false;
  478. }
  479. }
  480. /**
  481. * @notes 获取地址
  482. * @param $params
  483. * @author cjhao
  484. * @date 2023/2/17 17:36
  485. */
  486. public function getAddress($params)
  487. {
  488. $orderAddress = Order::where(['id'=>$params['id']])->value('address');
  489. $orderAddress = json_decode($orderAddress,true);
  490. $orderAddress['province_name'] = Region::where('id', $orderAddress['province'])->value('name');
  491. $orderAddress['city_name'] = Region::where('id', $orderAddress['city'])->value('name');
  492. $orderAddress['district_name'] = Region::where('id', $orderAddress['district'])->value('name');
  493. return $orderAddress;
  494. }
  495. /**
  496. * @notes 发货
  497. * @param $params
  498. * @return bool
  499. * @author ljj
  500. * @date 2021/8/10 6:25 下午
  501. */
  502. public function delivery($params)
  503. {
  504. Db::startTrans();
  505. try {
  506. $order = Order::find($params['id']);
  507. //消息通知
  508. $notice[] = [
  509. 'express_name' => '无需快递',
  510. 'invoice_no' => '',
  511. ];
  512. //虚拟发货和实物发货
  513. if(OrderEnum::VIRTUAL_ORDER != $order['order_type']){
  514. $delivery = new Delivery;
  515. $deliveryData = [];
  516. $orderGoodsInfo = [];
  517. $orderGoodsData = [];
  518. //新建批次发货时间记录
  519. $deliveryTime = DeliveryTime::create(['order_id' => $params['id']]);
  520. //快递发货
  521. $deliveryAddressInfo = AddressLibrary::where(['id'=>$params['delivery_address_id']])->append(['province','city','district','complete_address'])->findOrEmpty()->toArray();
  522. $returnAddressInfo = AddressLibrary::where(['id'=>$params['return_address_id']])->append(['province','city','district','complete_address'])->findOrEmpty()->toArray();
  523. if ($params['send_type'] == DeliveryEnum::EXPRESS) {
  524. $parcelOrderGoodsData = [];
  525. $notice = [];
  526. foreach ($params['parcel'] as $parcel) {
  527. //处理包裹数据
  528. foreach ($parcel['order_goods_info'] as $value) {
  529. $orderGoodsInfo[] = [
  530. 'order_goods_id' => $value['order_goods_id'],
  531. 'delivery_num' => $value['delivery_num']
  532. ];
  533. $parcelOrderGoodsData[$value['order_goods_id']] = ($parcelOrderGoodsData[$value['order_goods_id']] ?? 0) + $value['delivery_num'];
  534. }
  535. //添加发货单记录
  536. $express_id = $parcel['express_id'];
  537. $invoice_no = $parcel['invoice_no'];
  538. $express_name = Express::where('id',$express_id)->value('name');
  539. $deliveryData[] = [
  540. 'delivery_time_id' => $deliveryTime->id,
  541. 'order_id' => $params['id'],
  542. 'order_sn' => $order['sn'],
  543. 'order_goods_info' => json_encode($orderGoodsInfo),
  544. 'user_id' => $order['user_id'],
  545. 'admin_id' => $params['admin_id'],
  546. 'delivery_address_info' => json_encode($deliveryAddressInfo),
  547. 'return_address_info' => json_encode($returnAddressInfo),
  548. 'contact' => $order['address']->contact,
  549. 'mobile' => $order['address']->mobile,
  550. 'province' => $order['address']->province,
  551. 'city' => $order['address']->city,
  552. 'district' => $order['address']->district,
  553. 'address' => $order['address']->address,
  554. 'express_status' => DeliveryEnum::SHIPPED,
  555. 'express_id' => $express_id,
  556. 'express_name' => $express_name,
  557. 'invoice_no' => $invoice_no,
  558. 'send_type' => $params['send_type'],
  559. 'remark' => $params['remark'] ?? '',
  560. ];
  561. $notice[] = [
  562. 'express_name' => $express_name,
  563. 'invoice_no' => $invoice_no,
  564. ];
  565. }
  566. foreach ($parcelOrderGoodsData as $key=>$val) {
  567. $orderGoods = OrderGoods::where(['id'=>$key])->field('goods_num,delivery_num')->findOrEmpty()->toArray();
  568. $delivery_num = $val + $orderGoods['delivery_num'];
  569. $is_shipped = $delivery_num >= $orderGoods['goods_num'] ? true : false;
  570. $orderGoodsData[] = [
  571. 'id' => $key,
  572. 'delivery_num' => $is_shipped ? $orderGoods['goods_num'] : $delivery_num,
  573. 'express_status' => $is_shipped ? DeliveryEnum::SHIPPED : DeliveryEnum::PART_SHIPPED,
  574. ];
  575. }
  576. } else {
  577. //无需快递
  578. //添加发货单记录
  579. $orderGoods = OrderGoods::where(['id'=>$params['order_goods_ids']])->field('id,goods_num,delivery_num')->select()->toArray();
  580. foreach ($orderGoods as $goods) {
  581. $delivery_num = $goods['goods_num'] - $goods['delivery_num'];
  582. $delivery_num = $delivery_num > 0 ? $delivery_num : 0;
  583. $already_delivery_num = $goods['delivery_num'] + $delivery_num;
  584. $orderGoodsInfo[] = [
  585. 'order_goods_id' => $goods['id'],
  586. 'delivery_num' => $delivery_num
  587. ];
  588. $orderGoodsData[] = [
  589. 'id' => $goods['id'],
  590. 'delivery_num' => $already_delivery_num,
  591. 'express_status' => $already_delivery_num >= $goods['goods_num'] ? DeliveryEnum::SHIPPED : DeliveryEnum::PART_SHIPPED,
  592. ];
  593. }
  594. $deliveryData[] = [
  595. 'delivery_time_id' => $deliveryTime->id,
  596. 'order_id' => $params['id'],
  597. 'order_sn' => $order['sn'],
  598. 'order_goods_info' => json_encode($orderGoodsInfo),
  599. 'user_id' => $order['user_id'],
  600. 'admin_id' => $params['admin_id'],
  601. 'delivery_address_info' => json_encode($deliveryAddressInfo),
  602. 'return_address_info' => json_encode($returnAddressInfo),
  603. 'contact' => $order['address']->contact,
  604. 'mobile' => $order['address']->mobile,
  605. 'province' => $order['address']->province,
  606. 'city' => $order['address']->city,
  607. 'district' => $order['address']->district,
  608. 'address' => $order['address']->address,
  609. 'express_status' => DeliveryEnum::NOT_SHIPPED,
  610. 'send_type' => $params['send_type'],
  611. 'remark' => $params['remark'] ?? '',
  612. ];
  613. }
  614. //保存发货单记录
  615. $delivery->saveAll($deliveryData);
  616. //更新订单商品信息
  617. (new OrderGoods())->saveAll($orderGoodsData);
  618. //获取最新订单商品信息
  619. $orderGoodsIds = OrderGoods::where(['order_id'=>$params['id'],'express_status'=>[DeliveryEnum::NOT_SHIPPED,DeliveryEnum::PART_SHIPPED]])->column('id');
  620. if (!empty($orderGoodsIds)) {
  621. foreach ($orderGoodsIds as $key=>$orderGoodsId) {
  622. $afterSale = AfterSale::where(['order_goods_id'=>$orderGoodsId,'status'=>AfterSaleEnum::STATUS_SUCCESS])->findOrEmpty();
  623. if (!$afterSale->isEmpty()) {
  624. unset($orderGoodsIds[$key]);
  625. }
  626. }
  627. }
  628. $order_status = OrderEnum::STATUS_WAIT_DELIVERY;
  629. $express_status = DeliveryEnum::PART_SHIPPED;
  630. if (empty($orderGoodsIds)) {
  631. $order_status = OrderEnum::STATUS_WAIT_RECEIVE;
  632. $express_status = DeliveryEnum::SHIPPED;
  633. }
  634. //更新订单表
  635. $order->order_status = $order_status;
  636. $order->express_status = $express_status;
  637. $order->express_time = time();
  638. $order->delivery_id = 0;
  639. $order->save();
  640. }else{
  641. $orderGoods = OrderGoods::where(['order_id'=>$order['id']])->find();
  642. //自动完成订单
  643. $order->order_status = OrderEnum::STATUS_FINISH;
  644. if(GoodsEnum::AFTER_DELIVERY_HANDOPERSTION == $orderGoods->goods_snap->after_delivery){
  645. $order->order_status = OrderEnum::STATUS_WAIT_RECEIVE;
  646. }
  647. //更新订单表
  648. $order->express_status = DeliveryEnum::NOT_SHIPPED;
  649. $order->delivery_content = $params['delivery_content'] ?? '';
  650. $order->delivery_content1 = $params['delivery_content1'] ?? [];
  651. $order->delivery_content_type = $params['delivery_content_type'] ?? 0;
  652. $order->express_time = time();
  653. $order->delivery_id = 0;
  654. if(GoodsEnum::AFTER_DELIVERY_AUTO == $orderGoods->goods_snap->after_delivery){
  655. $order->confirm_take_time = time();
  656. }
  657. $order->save();
  658. }
  659. //订单日志
  660. (new OrderLog())->record([
  661. 'type' => OrderLogEnum::TYPE_SHOP,
  662. 'channel' => OrderLogEnum::SHOP_DELIVERY_ORDER,
  663. 'order_id' => $params['id'],
  664. 'operator_id' => $params['admin_id'],
  665. ]);
  666. // 消息通知
  667. foreach ($notice as $value) {
  668. event('Notice', [
  669. 'scene_id' => NoticeEnum::ORDER_SHIP_NOTICE,
  670. 'params' => [
  671. 'user_id' => $order->user_id,
  672. 'order_id' => $order->id,
  673. 'express_name' => $value['express_name'],
  674. 'invoice_no' => $value['invoice_no'],
  675. 'ship_time' => date('Y-m-d H:i:s')
  676. ]
  677. ]);
  678. }
  679. Db::commit();
  680. return true;
  681. } catch (\Exception $e) {
  682. Db::rollback();
  683. self::$error = $e->getMessage();
  684. return false;
  685. }
  686. }
  687. /**
  688. * @notes 发货信息
  689. * @return array
  690. * @throws \think\db\exception\DataNotFoundException
  691. * @throws \think\db\exception\DbException
  692. * @throws \think\db\exception\ModelNotFoundException
  693. * @author cjhao
  694. * @date 2023/2/20 11:33
  695. */
  696. public function getDeliverInfo($params)
  697. {
  698. $info = Order::field('id,order_type,address,delivery_content,pay_way,sn,pay_time')
  699. ->with(['order_goods'=> function($query){
  700. $query->field('id,order_id,goods_snap,goods_name,goods_price,discount_price,goods_num,total_pay_price,delivery_num')
  701. ->append(['goods_image','spec_value_str','surplus_delivery_num'])
  702. ->where(['express_status'=>[DeliveryEnum::NOT_SHIPPED,DeliveryEnum::PART_SHIPPED]]);
  703. }])
  704. ->where('id',$params['id'])
  705. ->append(['delivery_address'])
  706. ->find()
  707. ->toArray();
  708. //计算单个商品实付价格
  709. foreach ($info['order_goods'] as $key=>&$val) {
  710. $val['pay_price'] = $val['total_pay_price'] / $val['goods_num'];
  711. //售后状态
  712. $val['after_sale_status_desc'] = '无售后';
  713. $val['after_sale_status'] = 0;
  714. $val['after_sale_id'] = 0;
  715. $after_sale = AfterSale::where(['order_goods_id' => $val['id'], 'order_id' => $val['order_id']])->findOrEmpty();
  716. if ($after_sale->status == AfterSaleEnum::STATUS_SUCCESS) {
  717. unset($info['order_goods'][$key]);
  718. continue;
  719. }
  720. if (!$after_sale->isEmpty()) {
  721. $val['after_sale_status_desc'] = AfterSaleEnum::getStatusDesc($after_sale->status);
  722. $val['after_sale_status'] = $after_sale->status;
  723. $val['after_sale_id'] = $after_sale->id;
  724. }
  725. }
  726. $info['order_goods'] = array_values($info['order_goods']);
  727. if(OrderEnum::VIRTUAL_ORDER == $info['order_type']){
  728. $info['delivery_content'] = $val['goods_snap']->delivery_content;
  729. }
  730. //处理收货信息
  731. $info['contact'] = $info['address']->contact;
  732. $info['mobile'] = $info['address']->mobile;
  733. unset($info['address']);
  734. //获取物流公司
  735. $info['express'] = Express::field('id,name,code')->select()->toArray();
  736. //发货地址、退货地址信息
  737. $lastDelivery = Delivery::where(['order_id'=>$info['id']])->field('delivery_address_info,return_address_info')->order(['id'=>'desc'])->findOrEmpty()->toArray();
  738. $deliveryAddress = !empty($lastDelivery['delivery_address_info']) ? json_decode($lastDelivery['delivery_address_info'],true) : '';
  739. if(empty($deliveryAddress)) {
  740. $deliveryAddress = AddressLibrary::order(['is_deliver_default'=>'desc','id'=>'asc'])->append(['province','city','district'])->findOrEmpty()->toArray();
  741. }
  742. $returnAddress = !empty($lastDelivery['return_address_info']) ? json_decode($lastDelivery['return_address_info'],true) : '';
  743. if(empty($returnAddress)) {
  744. $returnAddress = AddressLibrary::order(['is_return_default'=>'desc','id'=>'asc'])->append(['province','city','district'])->findOrEmpty()->toArray();
  745. }
  746. $info['company_address'] = [
  747. 'delivery_address' => $deliveryAddress,
  748. 'return_address' => $returnAddress,
  749. ];
  750. return $info;
  751. }
  752. }