StoreOrderDeliveryServices.php 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
  8. // +----------------------------------------------------------------------
  9. // | Author: CRMEB Team <admin@crmeb.com>
  10. // +----------------------------------------------------------------------
  11. namespace app\services\order;
  12. use app\jobs\MiniOrderJob;
  13. use app\services\activity\coupon\StoreCouponIssueServices;
  14. use app\services\activity\integral\StoreIntegralOrderServices;
  15. use app\services\BaseServices;
  16. use app\dao\order\StoreOrderDao;
  17. use app\services\message\MessageSystemServices;
  18. use app\services\product\sku\StoreProductAttrValueServices;
  19. use app\services\product\sku\StoreProductVirtualServices;
  20. use app\services\serve\ServeServices;
  21. use app\services\wechat\WechatUserServices;
  22. use crmeb\exceptions\AdminException;
  23. use crmeb\exceptions\ApiException;
  24. use crmeb\services\FormBuilder as Form;
  25. use app\services\shipping\ExpressServices;
  26. use think\facade\Log;
  27. /**
  28. * 订单发货
  29. * Class StoreOrderDeliveryServices
  30. * @package app\services\order
  31. */
  32. class StoreOrderDeliveryServices extends BaseServices
  33. {
  34. /**
  35. * 构造方法
  36. * StoreOrderDeliveryServices constructor.
  37. * @param StoreOrderDao $dao
  38. */
  39. public function __construct(StoreOrderDao $dao)
  40. {
  41. $this->dao = $dao;
  42. }
  43. /**
  44. * 订单发货
  45. * @param int $id
  46. * @param array $data
  47. * @return array
  48. */
  49. public function delivery(int $id, array $data)
  50. {
  51. $orderInfo = $this->dao->get($id, ['*'], ['pink']);
  52. if (!$orderInfo) {
  53. throw new AdminException(400470);
  54. }
  55. if ($orderInfo->is_del) {
  56. throw new AdminException(400471);
  57. }
  58. if ($orderInfo->status) {
  59. throw new AdminException(400472);
  60. }
  61. if ($orderInfo->shipping_type == 2) {
  62. throw new AdminException(400473);
  63. }
  64. if (isset($orderInfo['pinkStatus']) && $orderInfo['pinkStatus'] != 2) {
  65. throw new AdminException(400474);
  66. }
  67. if ($data['type'] == 1) {
  68. // 检测快递公司编码
  69. /** @var ExpressServices $expressServices */
  70. $expressServices = app()->make(ExpressServices::class);
  71. if (!$expressServices->be(['code' => $data['delivery_code']])) {
  72. throw new AdminException(410324);
  73. }
  74. }
  75. /** @var StoreOrderRefundServices $storeOrderRefundServices */
  76. $storeOrderRefundServices = app()->make(StoreOrderRefundServices::class);
  77. if ($storeOrderRefundServices->count(['store_order_id' => $id, 'refund_type' => [1, 2, 4, 5], 'is_cancel' => 0, 'is_del' => 0])) {
  78. throw new AdminException(400475);
  79. }
  80. return $this->doDelivery($id, $orderInfo, $data);
  81. }
  82. /**
  83. * 订单快递发货
  84. * @param int $id
  85. * @param array $data
  86. */
  87. public function orderDeliveryGoods(int $id, array $data, $orderInfo, $storeTitle)
  88. {
  89. /** @var StoreOrderCartInfoServices $orderInfoServices */
  90. $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
  91. if (!$data['delivery_name']) {
  92. throw new AdminException(400007);
  93. }
  94. $data['delivery_type'] = 'express';
  95. if ($data['express_record_type'] == 2) {//电子面单
  96. if (!$data['delivery_code']) {
  97. throw new AdminException(400476);
  98. }
  99. if (!$data['express_temp_id']) {
  100. throw new AdminException(400527);
  101. }
  102. if (!$data['to_name']) {
  103. throw new AdminException(400008);
  104. }
  105. if (!$data['to_tel']) {
  106. throw new AdminException(400477);
  107. }
  108. if (!$data['to_addr']) {
  109. throw new AdminException(400478);
  110. }
  111. /** @var ServeServices $expressService */
  112. $expressService = app()->make(ServeServices::class);
  113. $expData['com'] = $data['delivery_code'];
  114. $expData['to_name'] = $orderInfo->real_name;
  115. $expData['to_tel'] = $orderInfo->user_phone;
  116. $expData['to_addr'] = $orderInfo->user_address;
  117. $expData['from_name'] = $data['to_name'];
  118. $expData['from_tel'] = $data['to_tel'];
  119. $expData['from_addr'] = $data['to_addr'];
  120. $expData['siid'] = sys_config('config_export_siid');
  121. $expData['temp_id'] = $data['express_temp_id'];
  122. $expData['count'] = $orderInfo->total_num;
  123. $expData['cargo'] = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo->id, true);
  124. $expData['order_id'] = $orderInfo->order_id;
  125. if (!sys_config('config_export_open', 0)) {
  126. throw new AdminException(400528);
  127. }
  128. $dump = $expressService->express()->dump($expData);
  129. $orderInfo->delivery_id = $dump['kuaidinum'];
  130. $data['express_dump'] = json_encode([
  131. 'com' => $expData['com'],
  132. 'from_name' => $expData['from_name'],
  133. 'from_tel' => $expData['from_tel'],
  134. 'from_addr' => $expData['from_addr'],
  135. 'temp_id' => $expData['temp_id'],
  136. 'cargo' => $expData['cargo'],
  137. ]);
  138. $data['delivery_id'] = $dump['kuaidinum'];
  139. } else {
  140. if (!$data['delivery_id']) {
  141. throw new AdminException(400531);
  142. }
  143. $orderInfo->delivery_id = $data['delivery_id'];
  144. }
  145. $data['status'] = 1;
  146. $orderInfo->delivery_type = $data['delivery_type'];
  147. $orderInfo->delivery_name = $data['delivery_name'];
  148. $orderInfo->status = $data['status'];
  149. /** @var StoreOrderStatusServices $services */
  150. $services = app()->make(StoreOrderStatusServices::class);
  151. $this->transaction(function () use ($id, $data, $services) {
  152. $res = $this->dao->update($id, $data);
  153. $res = $res && $services->save([
  154. 'oid' => $id,
  155. 'change_time' => time(),
  156. 'change_type' => 'delivery_goods',
  157. 'change_message' => '已发货 快递公司:' . $data['delivery_name'] . ' 快递单号:' . $data['delivery_id']
  158. ]);
  159. if (!$res) {
  160. throw new AdminException(400529);
  161. }
  162. });
  163. return true;
  164. }
  165. /**
  166. * 订单配送
  167. * @param int $id
  168. * @param array $data
  169. */
  170. public function orderDelivery(int $id, array $data, $orderInfo, string $storeTitle)
  171. {
  172. $data['delivery_type'] = 'send';
  173. $data['delivery_name'] = $data['sh_delivery_name'];
  174. $data['delivery_id'] = $data['sh_delivery_id'];
  175. $data['delivery_uid'] = $data['sh_delivery_uid'];
  176. $data['shipping_type'] = 1;
  177. //获取核销码
  178. /** @var StoreOrderCreateServices $storeOrderCreateService */
  179. $storeOrderCreateService = app()->make(StoreOrderCreateServices::class);
  180. $data['verify_code'] = $storeOrderCreateService->getStoreCode();
  181. unset($data['sh_delivery_name'], $data['sh_delivery_id'], $data['sh_delivery_uid']);
  182. if (!$data['delivery_name']) {
  183. throw new AdminException(400523);
  184. }
  185. if (!$data['delivery_id']) {
  186. throw new AdminException(400524);
  187. }
  188. if (!$data['delivery_uid']) {
  189. throw new AdminException(400525);
  190. }
  191. if (!preg_match("/^1[3456789]{1}\d{9}$/", $data['delivery_id'])) {
  192. throw new AdminException(400526);
  193. }
  194. $data['status'] = 1;
  195. $orderInfo->delivery_type = $data['delivery_type'];
  196. $orderInfo->delivery_name = $data['delivery_name'];
  197. $orderInfo->delivery_id = $data['delivery_id'];
  198. $orderInfo->status = $data['status'];
  199. /** @var StoreOrderStatusServices $services */
  200. $services = app()->make(StoreOrderStatusServices::class);
  201. $this->transaction(function () use ($id, $data, $services) {
  202. $this->dao->update($id, $data);
  203. //记录订单状态
  204. $services->save([
  205. 'oid' => $id,
  206. 'change_type' => 'delivery',
  207. 'change_time' => time(),
  208. 'change_message' => '已配送 发货人:' . $data['delivery_name'] . ' 发货人电话:' . $data['delivery_id']
  209. ]);
  210. });
  211. return true;
  212. }
  213. /**
  214. * 虚拟发货
  215. * @param int $id
  216. * @param array $data
  217. */
  218. public function orderVirtualDelivery(int $id, array $data)
  219. {
  220. $data['delivery_type'] = 'fictitious';
  221. $data['status'] = 1;
  222. unset($data['sh_delivery_name'], $data['sh_delivery_id'], $data['delivery_name'], $data['delivery_id']);
  223. //保存信息
  224. /** @var StoreOrderStatusServices $services */
  225. $services = app()->make(StoreOrderStatusServices::class);
  226. $this->transaction(function () use ($id, $data, $services) {
  227. $this->dao->update($id, $data);
  228. $services->save([
  229. 'oid' => $id,
  230. 'change_type' => 'delivery_fictitious',
  231. 'change_message' => '已虚拟发货',
  232. 'change_time' => time()
  233. ]);
  234. });
  235. }
  236. /**
  237. * 获取修改配送信息表单结构
  238. * @param int $id
  239. * @return array
  240. * @throws \FormBuilder\Exception\FormBuilderException
  241. */
  242. public function distributionForm(int $id)
  243. {
  244. if (!$orderInfo = $this->dao->get($id))
  245. throw new AdminException(400118);
  246. $f[] = Form::input('order_id', '订单号', $orderInfo->getData('order_id'))->disabled(1);
  247. switch ($orderInfo['delivery_type']) {
  248. case 'send':
  249. $f[] = Form::input('delivery_name', '送货人姓名', $orderInfo->getData('delivery_name'))->required('请输入送货人姓名');
  250. $f[] = Form::input('delivery_id', '送货人电话', $orderInfo->getData('delivery_id'))->required('请输入送货人电话');
  251. break;
  252. case 'express':
  253. /** @var ExpressServices $expressServices */
  254. $expressServices = app()->make(ExpressServices::class);
  255. $f[] = Form::select('delivery_code', '快递公司', (string)$orderInfo->getData('delivery_code'))->setOptions($expressServices->expressSelectForm(['is_show' => 1]))->required('请选择快递公司')->filterable(true);
  256. $f[] = Form::input('delivery_id', '快递单号', $orderInfo->getData('delivery_id'))->required('请填写快递单号');
  257. break;
  258. }
  259. return create_form('配送信息', $f, $this->url('/order/distribution/' . $id), 'PUT');
  260. }
  261. /**
  262. * 修改配送信息
  263. * @param int $id 订单id
  264. * @return mixed
  265. */
  266. public function updateDistribution(int $id, array $data)
  267. {
  268. $order = $this->dao->get($id);
  269. if (!$order) {
  270. throw new AdminException(100026);
  271. }
  272. switch ($order['delivery_type']) {
  273. case 'send':
  274. if (!$data['delivery_name']) {
  275. throw new AdminException(400523);
  276. }
  277. if (!$data['delivery_id']) {
  278. throw new AdminException(400524);
  279. }
  280. if (!preg_match("/^1[3456789]{1}\d{9}$/", $data['delivery_id'])) {
  281. throw new AdminException(400526);
  282. }
  283. break;
  284. case 'express':
  285. if (!$data['delivery_id']) {
  286. throw new AdminException(400531);
  287. }
  288. // 检测快递公司编码
  289. /** @var ExpressServices $expressServices */
  290. $expressServices = app()->make(ExpressServices::class);
  291. if ($name = $expressServices->value(['code' => $data['delivery_code']], 'name')) {
  292. $data['delivery_name'] = $name;
  293. } else {
  294. throw new AdminException(410324);
  295. }
  296. break;
  297. case 'fictitious':
  298. throw new AdminException(400479);
  299. break;
  300. default:
  301. throw new AdminException(400480);
  302. break;
  303. }
  304. /** @var StoreOrderStatusServices $statusService */
  305. $statusService = app()->make(StoreOrderStatusServices::class);
  306. $statusService->save([
  307. 'oid' => $id,
  308. 'change_type' => 'distribution',
  309. 'change_message' => '修改发货信息为' . $data['delivery_name'] . '号' . $data['delivery_id'],
  310. 'change_time' => time()
  311. ]);
  312. return $this->dao->update($id, $data);
  313. }
  314. /**订单发货后打印电子面单
  315. * @param $orderId
  316. * @return bool|mixed
  317. */
  318. public function orderDump($orderId, $type = 'order')
  319. {
  320. if (!$orderId) throw new AdminException(10100);
  321. // /** @var StoreOrderServices $orderService */
  322. // $orderService = app()->make(StoreOrderServices::class);
  323. // $orderInfo = $orderService->getOne(['id' => $orderId]);
  324. if ($type == 'order') {
  325. /** @var StoreOrderServices $orderService */
  326. $orderService = app()->make(StoreOrderServices::class);
  327. $orderInfo = $orderService->getOne(['id' => $orderId]);
  328. } else {
  329. /** @var StoreIntegralOrderServices $integralOrderService */
  330. $integralOrderService = app()->make(StoreIntegralOrderServices::class);
  331. $orderInfo = $integralOrderService->getOne(['id' => $orderId]);
  332. }
  333. if (!$orderInfo) throw new AdminException(400118);
  334. if ($orderInfo->shipping_type != 1) throw new AdminException(400481);
  335. if (!$orderInfo->express_dump) throw new AdminException(400482);
  336. if (!sys_config('config_export_open', 0)) {
  337. throw new AdminException(400483);
  338. }
  339. $dumpInfo = json_decode($orderInfo->express_dump, true);
  340. /** @var ServeServices $expressService */
  341. $expressService = app()->make(ServeServices::class);
  342. $expData['com'] = $dumpInfo['com'];
  343. $expData['to_name'] = $orderInfo->real_name;
  344. $expData['to_tel'] = $orderInfo->user_phone;
  345. $expData['to_addr'] = $orderInfo->user_address;
  346. $expData['from_name'] = $dumpInfo['from_name'];
  347. $expData['from_tel'] = $dumpInfo['from_tel'];
  348. $expData['from_addr'] = $dumpInfo['from_addr'];
  349. $expData['siid'] = sys_config('config_export_siid');
  350. $expData['temp_id'] = $dumpInfo['temp_id'];
  351. $expData['cargo'] = $dumpInfo['cargo'];
  352. $expData['count'] = $orderInfo->total_num;
  353. $expData['order_id'] = $orderInfo->order_id;
  354. $expData['weight'] = 1;
  355. return $expressService->express()->dump($expData);
  356. }
  357. /**
  358. * 订单拆单发货
  359. * @param int $id
  360. * @param array $data
  361. * @return bool
  362. * @throws \think\db\exception\DataNotFoundException
  363. * @throws \think\db\exception\DbException
  364. * @throws \think\db\exception\ModelNotFoundException
  365. * @author 吴汐
  366. * @email 442384644@qq.com
  367. * @date 2023/02/21
  368. */
  369. public function splitDelivery(int $id, array $data, $delivery_code = true)
  370. {
  371. $orderInfo = $this->dao->get($id, ['*'], ['pink']);
  372. if (!$orderInfo) {
  373. throw new AdminException(400470);
  374. }
  375. if ($orderInfo->is_del) {
  376. throw new AdminException(400471);
  377. }
  378. if ($orderInfo->shipping_type == 2) {
  379. throw new AdminException(400473);
  380. }
  381. if (isset($orderInfo['pinkStatus']) && $orderInfo['pinkStatus'] != 2) {
  382. throw new AdminException(400474);
  383. }
  384. /** @var StoreOrderRefundServices $storeOrderRefundServices */
  385. $storeOrderRefundServices = app()->make(StoreOrderRefundServices::class);
  386. if ($storeOrderRefundServices->count(['store_order_id' => $id, 'refund_type' => [1, 2, 4, 5], 'is_cancel' => 0, 'is_del' => 0])) {
  387. throw new AdminException(400475);
  388. }
  389. if ($data['type'] == 1 && $delivery_code) {
  390. // 检测快递公司编码
  391. /** @var ExpressServices $expressServices */
  392. $expressServices = app()->make(ExpressServices::class);
  393. if (!$expressServices->be(['code' => $data['delivery_code']])) {
  394. throw new AdminException(410324);
  395. }
  396. }
  397. $cart_ids = $data['cart_ids'];
  398. unset($data['cart_ids']);
  399. $this->transaction(function () use ($id, $cart_ids, $orderInfo, $data) {
  400. /** @var StoreOrderSplitServices $storeOrderSplitServices */
  401. $storeOrderSplitServices = app()->make(StoreOrderSplitServices::class);
  402. //订单拆单
  403. [$splitOrderInfo, $otherOrder] = $storeOrderSplitServices->equalSplit($id, $cart_ids, $orderInfo);
  404. if ($splitOrderInfo) {
  405. $splitOrderInfo['refund_status'] = 0;
  406. //拆分订单执行发货
  407. $this->doDelivery((int)$splitOrderInfo->id, $splitOrderInfo, $data);
  408. /** @var StoreOrderStatusServices $services */
  409. $services = app()->make(StoreOrderStatusServices::class);
  410. //记录原订单状态
  411. $status_data = ['oid' => $id, 'change_time' => time()];
  412. $status_data['change_type'] = 'delivery_split';
  413. $status_data['change_message'] = '已拆分发货';
  414. $services->save($status_data);
  415. } else {
  416. $this->doDelivery($id, $orderInfo, $data);
  417. }
  418. });
  419. return true;
  420. }
  421. /**
  422. * 具体执行发货
  423. * @param int $id
  424. * @param $orderInfo
  425. * @param array $data
  426. * @return array
  427. */
  428. public function doDelivery(int $id, $orderInfo, array $data)
  429. {
  430. $type = (int)$data['type'];
  431. unset($data['type']);
  432. //获取购物车内的商品标题
  433. /** @var StoreOrderCartInfoServices $orderInfoServices */
  434. $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
  435. $storeName = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo->id);
  436. if (isset($data['pickup_time']) && count($data['pickup_time']) == 2) {
  437. $data['pickup_start_time'] = $data['pickup_time'][0];
  438. $data['pickup_end_time'] = $data['pickup_time'][1];
  439. } else {
  440. $data['pickup_start_time'] = '';
  441. $data['pickup_end_time'] = '';
  442. }
  443. // 发货信息录入
  444. $res = [];
  445. switch ($type) {
  446. case 1://快递发货
  447. $res = $this->orderDeliverGoods($id, $data, $orderInfo, $storeName);
  448. event('NoticeListener', [['orderInfo' => $orderInfo, 'storeName' => $storeName, 'data' => $data], 'order_postage_success']);
  449. //自定义消息-快递发货
  450. $orderInfo['storeName'] = $storeName;
  451. $orderInfo['delivery_name'] = $data['delivery_name'];
  452. $orderInfo['delivery_id'] = $data['delivery_id'];
  453. $orderInfo['time'] = date('Y-m-d H:i:s');
  454. $orderInfo['phone'] = $orderInfo['user_phone'];
  455. event('CustomNoticeListener', [$orderInfo['uid'], $orderInfo, 'order_express_success']);
  456. break;
  457. case 2://配送
  458. $this->orderDelivery($id, $data, $orderInfo, $storeName);
  459. event('NoticeListener', [['orderInfo' => $orderInfo, 'storeName' => $storeName, 'data' => $data], 'order_deliver_success']);
  460. //自定义消息-配送员配送
  461. $orderInfo['storeName'] = $storeName;
  462. $orderInfo['delivery_name'] = $data['delivery_name'];
  463. $orderInfo['delivery_id'] = $data['delivery_id'];
  464. $orderInfo['time'] = date('Y-m-d H:i:s');
  465. $orderInfo['phone'] = $orderInfo['user_phone'];
  466. event('CustomNoticeListener', [$orderInfo['uid'], $orderInfo, 'order_send_success']);
  467. break;
  468. case 3://虚拟发货
  469. $this->orderVirtualDelivery($id, $data, $orderInfo, $storeName);
  470. break;
  471. default:
  472. throw new AdminException(400522);
  473. }
  474. if (!$data['delivery_id'] && !empty($res['kuaidinum'])) {
  475. $data['delivery_id'] = $res['kuaidinum'];
  476. }
  477. if (!$data['delivery_id']) {
  478. $data['delivery_id'] = uniqid();
  479. }
  480. // 小程序订单管理
  481. event('OrderShippingListener', ['product', $orderInfo, $type, $data['delivery_id'], $data['delivery_code']]);
  482. //到期自动收货
  483. event('OrderDeliveryListener', [$orderInfo, $storeName, $data, $type]);
  484. //自定义事件-订单发货
  485. event('CustomEventListener', ['admin_order_express', [
  486. 'uid' => $orderInfo['uid'],
  487. 'real_name' => $orderInfo['real_name'],
  488. 'user_phone' => $orderInfo['user_phone'],
  489. 'user_address' => $orderInfo['user_address'],
  490. 'order_id' => $orderInfo['order_id'],
  491. 'delivery_name' => $orderInfo['delivery_name'],
  492. 'delivery_id' => $orderInfo['delivery_id'],
  493. 'express_time' => date('Y-m-d H:i:s'),
  494. ]]);
  495. return $res;
  496. }
  497. /**
  498. * 订单快递发货
  499. * @param int $id
  500. * @param array $data
  501. */
  502. public function orderDeliverGoods(int $id, array $data, $orderInfo, $storeTitle)
  503. {
  504. /** @var StoreOrderCartInfoServices $orderInfoServices */
  505. $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
  506. if (!$data['delivery_name']) {
  507. throw new AdminException(400007);
  508. }
  509. $dump = [];
  510. $data['delivery_type'] = 'express';
  511. if ($data['express_record_type'] == 2) {//电子面单
  512. if (!$data['delivery_code']) {
  513. throw new AdminException(400476);
  514. }
  515. if (!$data['express_temp_id']) {
  516. throw new AdminException(400527);
  517. }
  518. if (!$data['to_name']) {
  519. throw new AdminException(400008);
  520. }
  521. if (!$data['to_tel']) {
  522. throw new AdminException(400477);
  523. }
  524. if (!$data['to_addr']) {
  525. throw new AdminException(400478);
  526. }
  527. /** @var ServeServices $expressService */
  528. $expressService = app()->make(ServeServices::class);
  529. $expData['com'] = $data['delivery_code'];
  530. $expData['to_name'] = $orderInfo->real_name;
  531. $expData['to_tel'] = $orderInfo->user_phone;
  532. $expData['to_addr'] = $orderInfo->user_address;
  533. $expData['from_name'] = $data['to_name'];
  534. $expData['from_tel'] = $data['to_tel'];
  535. $expData['from_addr'] = $data['to_addr'];
  536. $expData['siid'] = sys_config('config_export_siid');
  537. $expData['temp_id'] = $data['express_temp_id'];
  538. $expData['count'] = $orderInfo->total_num;
  539. $expData['weight'] = $this->getOrderSumWeight($id);
  540. $expData['cargo'] = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo->id, true);
  541. $expData['order_id'] = $orderInfo->order_id;
  542. if (!sys_config('config_export_open', 0)) {
  543. throw new AdminException(400528);
  544. }
  545. $dump = $expressService->express()->dump($expData);
  546. $orderInfo->delivery_id = $dump['kuaidinum'];
  547. $data['express_dump'] = json_encode([
  548. 'com' => $expData['com'],
  549. 'from_name' => $expData['from_name'],
  550. 'from_tel' => $expData['from_tel'],
  551. 'from_addr' => $expData['from_addr'],
  552. 'temp_id' => $expData['temp_id'],
  553. 'cargo' => $expData['cargo'],
  554. ]);
  555. $data['delivery_id'] = $dump['kuaidinum'];
  556. if (!empty($dump['label'])) {
  557. $data['kuaidi_label'] = $dump['label'];
  558. }
  559. } else if ($data['express_record_type'] == 3) {
  560. //商家寄件
  561. if (!$data['delivery_code']) {
  562. throw new AdminException(400476);
  563. }
  564. if (!$data['express_temp_id']) {
  565. throw new AdminException(400527);
  566. }
  567. if (!$data['to_name']) {
  568. throw new AdminException(400008);
  569. }
  570. if (!$data['to_tel']) {
  571. throw new AdminException(400477);
  572. }
  573. if (!$data['to_addr']) {
  574. throw new AdminException(400478);
  575. }
  576. /** @var ServeServices $expressService */
  577. $expressService = app()->make(ServeServices::class);
  578. $expData['kuaidicom'] = $data['delivery_code'];
  579. $expData['man_name'] = $orderInfo->real_name;
  580. $expData['phone'] = $orderInfo->user_phone;
  581. $expData['address'] = $orderInfo->user_address;
  582. $expData['send_real_name'] = $data['to_name'];
  583. $expData['send_phone'] = $data['to_tel'];
  584. $expData['send_address'] = $data['to_addr'];
  585. $expData['temp_id'] = $data['express_temp_id'];
  586. $expData['weight'] = $this->getOrderSumWeight($id);
  587. $expData['cargo'] = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo->id, true);
  588. $expData['day_type'] = $data['day_type'];
  589. $expData['pickup_start_time'] = $data['pickup_start_time'];
  590. $expData['pickup_end_time'] = $data['pickup_end_time'];
  591. // if (!sys_config('config_shippment_open', 0)) {
  592. // throw new AdminException('商家寄件未开启无法寄件');
  593. // }
  594. $dump = $expressService->express()->shippmentCreateOrder($expData);
  595. Log::error('商家寄件返回数据:' . json_encode($dump));
  596. $orderInfo->delivery_id = $dump['kuaidinum'] ?? '';
  597. $data['express_dump'] = json_encode([
  598. 'com' => $expData['kuaidicom'],
  599. 'from_name' => $expData['send_real_name'],
  600. 'from_tel' => $expData['send_phone'],
  601. 'from_addr' => $expData['send_address'],
  602. 'temp_id' => $expData['temp_id'],
  603. 'cargo' => $expData['cargo'],
  604. ]);
  605. $data['delivery_id'] = $dump['kuaidinum'] ?? '';
  606. $data['kuaidi_label'] = $dump['label'] ?? '';
  607. $data['kuaidi_task_id'] = $dump['task_id'] ?? '';
  608. $data['kuaidi_order_id'] = $dump['order_id'] ?? '';
  609. } else {
  610. if (!$data['delivery_id']) {
  611. throw new AdminException(400531);
  612. }
  613. $orderInfo->delivery_id = $data['delivery_id'];
  614. }
  615. if (true) {
  616. $data['status'] = 1;
  617. $orderInfo->delivery_type = $data['delivery_type'];
  618. $orderInfo->delivery_name = $data['delivery_name'];
  619. $orderInfo->status = $data['status'];
  620. /** @var StoreOrderStatusServices $services */
  621. $services = app()->make(StoreOrderStatusServices::class);
  622. $this->transaction(function () use ($id, $data, $services) {
  623. $res = $this->dao->update($id, $data);
  624. $res = $res && $services->save([
  625. 'oid' => $id,
  626. 'change_time' => time(),
  627. 'change_type' => 'delivery_goods',
  628. 'change_message' => '已发货 快递公司:' . $data['delivery_name'] . ' 快递单号:' . $data['delivery_id']
  629. ]);
  630. if (!$res) {
  631. throw new AdminException(400529);
  632. }
  633. });
  634. } else {
  635. $update = [
  636. 'is_stock_up' => 1,
  637. 'delivery_type' => $data['delivery_type'],
  638. 'delivery_name' => $data['delivery_name'],
  639. 'delivery_code' => $data['delivery_code'],
  640. 'delivery_id' => $data['delivery_id'],
  641. 'kuaidi_label' => $data['kuaidi_label'],
  642. 'kuaidi_task_id' => $data['kuaidi_task_id'],
  643. 'kuaidi_order_id' => $data['kuaidi_order_id'],
  644. 'express_dump' => $data['express_dump']
  645. ];
  646. /** @var StoreOrderStatusServices $services */
  647. $services = app()->make(StoreOrderStatusServices::class);
  648. $this->transaction(function () use ($id, $data, $services, $update) {
  649. $res = $this->dao->update($id, $update);
  650. $res = $res && $services->save([
  651. 'oid' => $id,
  652. 'change_time' => time(),
  653. 'change_type' => 'stock_up_goods',
  654. 'change_message' => '备货中 快递公司:' . $data['delivery_name'] . ' 快递单号:' . $data['delivery_id']
  655. ]);
  656. if (!$res) {
  657. throw new AdminException(400529);
  658. }
  659. });
  660. }
  661. return $dump;
  662. }
  663. /**
  664. * 返回订单商品总重量
  665. * @param int $id
  666. * @return int|string
  667. */
  668. public function getOrderSumWeight(int $id, $default = false)
  669. {
  670. /** @var StoreOrderCartInfoServices $services */
  671. $services = app()->make(StoreOrderCartInfoServices::class);
  672. $orderGoodInfo = $services->getOrderCartInfo((int)$id);
  673. $weight = 0;
  674. foreach ($orderGoodInfo as $cartInfo) {
  675. $cart = $cartInfo['cart_info'] ?? [];
  676. if ($cart) {
  677. $weight = bcadd((string)$weight, (string)bcmul((string)$cart['cart_num'] ?? '0', (string)$cart['productInfo']['attrInfo']['weight'] ?? '0', 4), 2);
  678. }
  679. }
  680. return $weight ?: ($default === false ? 0 : $default);
  681. }
  682. /**
  683. * 虚拟商品自动发货
  684. * @param $orderInfo
  685. * @throws \ReflectionException
  686. */
  687. public function virtualSend($orderInfo)
  688. {
  689. /** @var StoreOrderStatusServices $statusService */
  690. $statusService = app()->make(StoreOrderStatusServices::class);
  691. /** @var StoreOrderCartInfoServices $services */
  692. $services = app()->make(StoreOrderCartInfoServices::class);
  693. $orderInfo['cart_info'] = $services->getOrderCartInfo((int)$orderInfo['id']);
  694. $activityStatus = $orderInfo['combination_id'] || $orderInfo['seckill_id'] || $orderInfo['bargain_id'];
  695. if ($orderInfo['virtual_type'] == 1) {
  696. /** @var StoreOrderServices $orderService */
  697. $orderService = app()->make(StoreOrderServices::class);
  698. $sku = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['suk'];
  699. if ($activityStatus) {
  700. $product_id = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['product_id'];
  701. /** @var StoreProductAttrValueServices $attrValue */
  702. $attrValue = app()->make(StoreProductAttrValueServices::class);
  703. $disk_info = $attrValue->value(['product_id' => $product_id, 'suk' => $sku, 'type' => 0, 'is_virtual' => 1], 'disk_info');
  704. } else {
  705. $disk_info = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['disk_info'];
  706. }
  707. if ($disk_info != '') {
  708. $orderService->update(['id' => $orderInfo['id']], ['status' => 1, 'delivery_type' => 'fictitious', 'virtual_info' => $disk_info, 'remark' => '密钥自动发放:' . $disk_info]);
  709. $this->SystemSend($orderInfo['uid'], [
  710. 'mark' => 'virtual_info',
  711. 'title' => '虚拟密钥发放',
  712. 'content' => '您购买的密钥商品已支付成功,支付金额' . $orderInfo['pay_price'] . '元,订单号:' . $orderInfo['order_id'] . ',密钥:' . $disk_info . ',感谢您的光临!'
  713. ]);
  714. } else {
  715. if ($activityStatus) {
  716. $product_id = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['product_id'];
  717. /** @var StoreProductAttrValueServices $attrValue */
  718. $attrValue = app()->make(StoreProductAttrValueServices::class);
  719. $unique = $attrValue->value(['product_id' => $product_id, 'suk' => $sku, 'type' => 0, 'is_virtual' => 1], 'unique');
  720. } else {
  721. $unique = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['unique'];
  722. }
  723. /** @var StoreProductVirtualServices $virtualService */
  724. $virtualService = app()->make(StoreProductVirtualServices::class);
  725. $virtual = $virtualService->get(['attr_unique' => $unique, 'uid' => 0]);
  726. if (!$virtual) throw new ApiException(100026);
  727. $virtual->order_id = $orderInfo['order_id'];
  728. $virtual->uid = $orderInfo['uid'];
  729. $virtual->save();
  730. $orderService->update(['id' => $orderInfo['id']], ['status' => 1, 'delivery_type' => 'fictitious', 'virtual_info' => $virtual->card_unique, 'remark' => '卡密已自动发放,卡号:' . $virtual->card_no . ';密码:' . $virtual->card_pwd]);
  731. $this->SystemSend($orderInfo['uid'], [
  732. 'mark' => 'virtual_info',
  733. 'title' => '虚拟卡密发放',
  734. 'content' => '您购买的卡密商品已支付成功,支付金额' . $orderInfo['pay_price'] . '元,订单号:' . $orderInfo['order_id'] . ',卡号:' . $virtual->card_no . ';密码:' . $virtual->card_pwd . ',感谢您的光临!'
  735. ]);
  736. }
  737. $statusService->save([
  738. 'oid' => $orderInfo['id'],
  739. 'change_type' => 'delivery_fictitious',
  740. 'change_message' => '卡密自动发货',
  741. 'change_time' => time()
  742. ]);
  743. } elseif ($orderInfo['virtual_type'] == 2) {
  744. if ($activityStatus) {
  745. $sku = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['suk'];
  746. $product_id = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['product_id'];
  747. /** @var StoreProductAttrValueServices $attrValue */
  748. $attrValue = app()->make(StoreProductAttrValueServices::class);
  749. $coupon_id = $attrValue->value(['product_id' => $product_id, 'suk' => $sku, 'type' => 0, 'is_virtual' => 1], 'coupon_id');
  750. } else {
  751. $coupon_id = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['coupon_id'];
  752. }
  753. /** @var StoreCouponIssueServices $issueService */
  754. $issueService = app()->make(StoreCouponIssueServices::class);
  755. $coupon = $issueService->get($coupon_id);
  756. if ($issueService->setCoupon($coupon, [$orderInfo['uid']])) {
  757. /** @var StoreOrderServices $orderService */
  758. $orderService = app()->make(StoreOrderServices::class);
  759. $orderService->update(['id' => $orderInfo['id']], ['status' => 1, 'delivery_type' => 'fictitious', 'virtual_info' => $coupon_id, 'remark' => '优惠券已自动发放']);
  760. $this->SystemSend($orderInfo['uid'], [
  761. 'mark' => 'virtual_info',
  762. 'title' => '购买优惠券发放',
  763. 'content' => '您购买的优惠券已支付成功,支付金额' . $orderInfo['pay_price'] . '元,订单号' . $orderInfo['order_id'] . '请在个人中心优惠券中查看,感谢您的光临!'
  764. ]);
  765. } else {
  766. throw new ApiException(410323);
  767. }
  768. $statusService->save([
  769. 'oid' => $orderInfo['id'],
  770. 'change_type' => 'delivery_fictitious',
  771. 'change_message' => '优惠券自动发货',
  772. 'change_time' => time()
  773. ]);
  774. }
  775. if ($orderInfo['is_channel'] == 1 && $orderInfo['pay_type'] == 'weixin') {
  776. MiniOrderJob::dispatchSecs(10, 'doJob', [
  777. $orderInfo['order_id'],
  778. 3,
  779. [['item_desc' => $orderInfo['virtual_type'] == 1 ? '卡密自动发货' : '优惠券自动发货']],
  780. app()->make(WechatUserServices::class)->uidToOpenid($orderInfo['uid'], 'routine'),
  781. 'pages/goods/order_details/index?order_id=' . $orderInfo['order_id']
  782. ]);
  783. }
  784. }
  785. /**
  786. * 虚拟商品站内信
  787. * @param int $uid
  788. * @param array $noticeInfo
  789. */
  790. public function SystemSend(int $uid, array $noticeInfo)
  791. {
  792. /** @var MessageSystemServices $MessageSystemServices */
  793. $MessageSystemServices = app()->make(MessageSystemServices::class);
  794. $data = [];
  795. $data['mark'] = $noticeInfo['mark'];
  796. $data['uid'] = $uid;
  797. $data['title'] = $noticeInfo['title'];
  798. $data['content'] = $noticeInfo['content'];
  799. $data['type'] = 1;
  800. $data['add_time'] = time();
  801. $MessageSystemServices->save($data);
  802. }
  803. }