123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784 |
- <?php
- // +----------------------------------------------------------------------
- // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
- // +----------------------------------------------------------------------
- // | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved.
- // +----------------------------------------------------------------------
- // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
- // +----------------------------------------------------------------------
- // | Author: CRMEB Team <admin@crmeb.com>
- // +----------------------------------------------------------------------
- namespace app\services\order;
- use app\services\activity\coupon\StoreCouponIssueServices;
- use app\services\BaseServices;
- use app\dao\order\StoreOrderDao;
- use app\services\message\MessageSystemServices;
- use app\services\product\sku\StoreProductAttrValueServices;
- use app\services\product\sku\StoreProductVirtualServices;
- use app\services\serve\ServeServices;
- use crmeb\exceptions\AdminException;
- use crmeb\exceptions\ApiException;
- use crmeb\services\FormBuilder as Form;
- use app\services\shipping\ExpressServices;
- use think\facade\Log;
- /**
- * 订单发货
- * Class StoreOrderDeliveryServices
- * @package app\services\order
- */
- class StoreOrderDeliveryServices extends BaseServices
- {
- /**
- * 构造方法
- * StoreOrderDeliveryServices constructor.
- * @param StoreOrderDao $dao
- */
- public function __construct(StoreOrderDao $dao)
- {
- $this->dao = $dao;
- }
- /**
- * 订单发货
- * @param int $id
- * @param array $data
- * @return array
- */
- public function delivery(int $id, array $data)
- {
- $orderInfo = $this->dao->get($id, ['*'], ['pink']);
- if (!$orderInfo) {
- throw new AdminException(400470);
- }
- if ($orderInfo->is_del) {
- throw new AdminException(400471);
- }
- if ($orderInfo->status) {
- throw new AdminException(400472);
- }
- if ($orderInfo->shipping_type == 2) {
- throw new AdminException(400473);
- }
- if (isset($orderInfo['pinkStatus']) && $orderInfo['pinkStatus'] != 2) {
- throw new AdminException(400474);
- }
- if ($data['type'] == 1) {
- // 检测快递公司编码
- /** @var ExpressServices $expressServices */
- $expressServices = app()->make(ExpressServices::class);
- if (!$expressServices->be(['code' => $data['delivery_code']])) {
- throw new AdminException(410324);
- }
- }
- /** @var StoreOrderRefundServices $storeOrderRefundServices */
- $storeOrderRefundServices = app()->make(StoreOrderRefundServices::class);
- if ($storeOrderRefundServices->count(['store_order_id' => $id, 'refund_type' => [1, 2, 4, 5], 'is_cancel' => 0, 'is_del' => 0])) {
- throw new AdminException(400475);
- }
- return $this->doDelivery($id, $orderInfo, $data);
- }
- /**
- * 订单快递发货
- * @param int $id
- * @param array $data
- */
- public function orderDeliveryGoods(int $id, array $data, $orderInfo, $storeTitle)
- {
- /** @var StoreOrderCartInfoServices $orderInfoServices */
- $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
- if (!$data['delivery_name']) {
- throw new AdminException(400007);
- }
- $data['delivery_type'] = 'express';
- if ($data['express_record_type'] == 2) {//电子面单
- if (!$data['delivery_code']) {
- throw new AdminException(400476);
- }
- if (!$data['express_temp_id']) {
- throw new AdminException(400527);
- }
- if (!$data['to_name']) {
- throw new AdminException(400008);
- }
- if (!$data['to_tel']) {
- throw new AdminException(400477);
- }
- if (!$data['to_addr']) {
- throw new AdminException(400478);
- }
- /** @var ServeServices $expressService */
- $expressService = app()->make(ServeServices::class);
- $expData['com'] = $data['delivery_code'];
- $expData['to_name'] = $orderInfo->real_name;
- $expData['to_tel'] = $orderInfo->user_phone;
- $expData['to_addr'] = $orderInfo->user_address;
- $expData['from_name'] = $data['to_name'];
- $expData['from_tel'] = $data['to_tel'];
- $expData['from_addr'] = $data['to_addr'];
- $expData['siid'] = sys_config('config_export_siid');
- $expData['temp_id'] = $data['express_temp_id'];
- $expData['count'] = $orderInfo->total_num;
- $expData['cargo'] = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo->id, true);
- $expData['order_id'] = $orderInfo->order_id;
- if (!sys_config('config_export_open', 0)) {
- throw new AdminException(400528);
- }
- $dump = $expressService->express()->dump($expData);
- $orderInfo->delivery_id = $dump['kuaidinum'];
- $data['express_dump'] = json_encode([
- 'com' => $expData['com'],
- 'from_name' => $expData['from_name'],
- 'from_tel' => $expData['from_tel'],
- 'from_addr' => $expData['from_addr'],
- 'temp_id' => $expData['temp_id'],
- 'cargo' => $expData['cargo'],
- ]);
- $data['delivery_id'] = $dump['kuaidinum'];
- } else {
- if (!$data['delivery_id']) {
- throw new AdminException(400531);
- }
- $orderInfo->delivery_id = $data['delivery_id'];
- }
- $data['status'] = 1;
- $orderInfo->delivery_type = $data['delivery_type'];
- $orderInfo->delivery_name = $data['delivery_name'];
- $orderInfo->status = $data['status'];
- /** @var StoreOrderStatusServices $services */
- $services = app()->make(StoreOrderStatusServices::class);
- $this->transaction(function () use ($id, $data, $services) {
- $res = $this->dao->update($id, $data);
- $res = $res && $services->save([
- 'oid' => $id,
- 'change_time' => time(),
- 'change_type' => 'delivery_goods',
- 'change_message' => '已发货 快递公司:' . $data['delivery_name'] . ' 快递单号:' . $data['delivery_id']
- ]);
- if (!$res) {
- throw new AdminException(400529);
- }
- });
- return true;
- }
- /**
- * 订单配送
- * @param int $id
- * @param array $data
- */
- public function orderDelivery(int $id, array $data, $orderInfo, string $storeTitle)
- {
- $data['delivery_type'] = 'send';
- $data['delivery_name'] = $data['sh_delivery_name'];
- $data['delivery_id'] = $data['sh_delivery_id'];
- $data['delivery_uid'] = $data['sh_delivery_uid'];
- $data['shipping_type'] = 1;
- //获取核销码
- /** @var StoreOrderCreateServices $storeOrderCreateService */
- $storeOrderCreateService = app()->make(StoreOrderCreateServices::class);
- $data['verify_code'] = $storeOrderCreateService->getStoreCode();
- unset($data['sh_delivery_name'], $data['sh_delivery_id'], $data['sh_delivery_uid']);
- if (!$data['delivery_name']) {
- throw new AdminException(400523);
- }
- if (!$data['delivery_id']) {
- throw new AdminException(400524);
- }
- if (!$data['delivery_uid']) {
- throw new AdminException(400525);
- }
- if (!preg_match("/^1[3456789]{1}\d{9}$/", $data['delivery_id'])) {
- throw new AdminException(400526);
- }
- $data['status'] = 1;
- $orderInfo->delivery_type = $data['delivery_type'];
- $orderInfo->delivery_name = $data['delivery_name'];
- $orderInfo->delivery_id = $data['delivery_id'];
- $orderInfo->status = $data['status'];
- /** @var StoreOrderStatusServices $services */
- $services = app()->make(StoreOrderStatusServices::class);
- $this->transaction(function () use ($id, $data, $services) {
- $this->dao->update($id, $data);
- //记录订单状态
- $services->save([
- 'oid' => $id,
- 'change_type' => 'delivery',
- 'change_time' => time(),
- 'change_message' => '已配送 发货人:' . $data['delivery_name'] . ' 发货人电话:' . $data['delivery_id']
- ]);
- });
- return true;
- }
- /**
- * 虚拟发货
- * @param int $id
- * @param array $data
- */
- public function orderVirtualDelivery(int $id, array $data)
- {
- $data['delivery_type'] = 'fictitious';
- $data['status'] = 1;
- unset($data['sh_delivery_name'], $data['sh_delivery_id'], $data['delivery_name'], $data['delivery_id']);
- //保存信息
- /** @var StoreOrderStatusServices $services */
- $services = app()->make(StoreOrderStatusServices::class);
- $this->transaction(function () use ($id, $data, $services) {
- $this->dao->update($id, $data);
- $services->save([
- 'oid' => $id,
- 'change_type' => 'delivery_fictitious',
- 'change_message' => '已虚拟发货',
- 'change_time' => time()
- ]);
- });
- }
- /**
- * 获取修改配送信息表单结构
- * @param int $id
- * @return array
- * @throws \FormBuilder\Exception\FormBuilderException
- */
- public function distributionForm(int $id)
- {
- if (!$orderInfo = $this->dao->get($id))
- throw new AdminException(400118);
- $f[] = Form::input('order_id', '订单号', $orderInfo->getData('order_id'))->disabled(1);
- switch ($orderInfo['delivery_type']) {
- case 'send':
- $f[] = Form::input('delivery_name', '送货人姓名', $orderInfo->getData('delivery_name'))->required('请输入送货人姓名');
- $f[] = Form::input('delivery_id', '送货人电话', $orderInfo->getData('delivery_id'))->required('请输入送货人电话');
- break;
- case 'express':
- /** @var ExpressServices $expressServices */
- $expressServices = app()->make(ExpressServices::class);
- $f[] = Form::select('delivery_code', '快递公司', (string)$orderInfo->getData('delivery_code'))->setOptions($expressServices->expressSelectForm(['is_show' => 1]))->required('请选择快递公司')->filterable(true);
- $f[] = Form::input('delivery_id', '快递单号', $orderInfo->getData('delivery_id'))->required('请填写快递单号');
- break;
- }
- return create_form('配送信息', $f, $this->url('/order/distribution/' . $id), 'PUT');
- }
- /**
- * 修改配送信息
- * @param int $id 订单id
- * @return mixed
- */
- public function updateDistribution(int $id, array $data)
- {
- $order = $this->dao->get($id);
- if (!$order) {
- throw new AdminException(100026);
- }
- switch ($order['delivery_type']) {
- case 'send':
- if (!$data['delivery_name']) {
- throw new AdminException(400523);
- }
- if (!$data['delivery_id']) {
- throw new AdminException(400524);
- }
- if (!preg_match("/^1[3456789]{1}\d{9}$/", $data['delivery_id'])) {
- throw new AdminException(400526);
- }
- break;
- case 'express':
- if (!$data['delivery_id']) {
- throw new AdminException(400531);
- }
- // 检测快递公司编码
- /** @var ExpressServices $expressServices */
- $expressServices = app()->make(ExpressServices::class);
- if ($name = $expressServices->value(['code' => $data['delivery_code']], 'name')) {
- $data['delivery_name'] = $name;
- } else {
- throw new AdminException(410324);
- }
- break;
- case 'fictitious':
- throw new AdminException(400479);
- break;
- default:
- throw new AdminException(400480);
- break;
- }
- /** @var StoreOrderStatusServices $statusService */
- $statusService = app()->make(StoreOrderStatusServices::class);
- $statusService->save([
- 'oid' => $id,
- 'change_type' => 'distribution',
- 'change_message' => '修改发货信息为' . $data['delivery_name'] . '号' . $data['delivery_id'],
- 'change_time' => time()
- ]);
- return $this->dao->update($id, $data);
- }
- /**订单发货后打印电子面单
- * @param $orderId
- * @return bool|mixed
- */
- public function orderDump($orderId)
- {
- if (!$orderId) throw new AdminException(10100);
- /** @var StoreOrderServices $orderService */
- $orderService = app()->make(StoreOrderServices::class);
- $orderInfo = $orderService->getOne(['id' => $orderId]);
- if (!$orderInfo) throw new AdminException(400118);
- if ($orderInfo->shipping_type != 1) throw new AdminException(400481);
- if (!$orderInfo->express_dump) throw new AdminException(400482);
- if (!sys_config('config_export_open', 0)) {
- throw new AdminException(400483);
- }
- $dumpInfo = json_decode($orderInfo->express_dump, true);
- /** @var ServeServices $expressService */
- $expressService = app()->make(ServeServices::class);
- $expData['com'] = $dumpInfo['com'];
- $expData['to_name'] = $orderInfo->real_name;
- $expData['to_tel'] = $orderInfo->user_phone;
- $expData['to_addr'] = $orderInfo->user_address;
- $expData['from_name'] = $dumpInfo['from_name'];
- $expData['from_tel'] = $dumpInfo['from_tel'];
- $expData['from_addr'] = $dumpInfo['from_addr'];
- $expData['siid'] = sys_config('config_export_siid');
- $expData['temp_id'] = $dumpInfo['temp_id'];
- $expData['cargo'] = $dumpInfo['cargo'];
- $expData['count'] = $orderInfo->total_num;
- $expData['order_id'] = $orderInfo->order_id;
- return $expressService->express()->dump($expData);
- }
- /**
- * 订单拆单发货
- * @param int $id
- * @param array $data
- * @return bool
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\DbException
- * @throws \think\db\exception\ModelNotFoundException
- * @author 吴汐
- * @email 442384644@qq.com
- * @date 2023/02/21
- */
- public function splitDelivery(int $id, array $data, $delivery_code = true)
- {
- $orderInfo = $this->dao->get($id, ['*'], ['pink']);
- if (!$orderInfo) {
- throw new AdminException(400470);
- }
- if ($orderInfo->is_del) {
- throw new AdminException(400471);
- }
- if ($orderInfo->shipping_type == 2) {
- throw new AdminException(400473);
- }
- if (isset($orderInfo['pinkStatus']) && $orderInfo['pinkStatus'] != 2) {
- throw new AdminException(400474);
- }
- /** @var StoreOrderRefundServices $storeOrderRefundServices */
- $storeOrderRefundServices = app()->make(StoreOrderRefundServices::class);
- if ($storeOrderRefundServices->count(['store_order_id' => $id, 'refund_type' => [1, 2, 4, 5], 'is_cancel' => 0, 'is_del' => 0])) {
- throw new AdminException(400475);
- }
- if ($data['type'] == 1 && $delivery_code) {
- // 检测快递公司编码
- /** @var ExpressServices $expressServices */
- $expressServices = app()->make(ExpressServices::class);
- if (!$expressServices->be(['code' => $data['delivery_code']])) {
- throw new AdminException(410324);
- }
- }
- $cart_ids = $data['cart_ids'];
- unset($data['cart_ids']);
- $this->transaction(function () use ($id, $cart_ids, $orderInfo, $data) {
- /** @var StoreOrderSplitServices $storeOrderSplitServices */
- $storeOrderSplitServices = app()->make(StoreOrderSplitServices::class);
- //订单拆单
- [$splitOrderInfo, $otherOrder] = $storeOrderSplitServices->equalSplit($id, $cart_ids, $orderInfo);
- if ($splitOrderInfo) {
- $splitOrderInfo['refund_status'] = 0;
- //拆分订单执行发货
- $this->doDelivery((int)$splitOrderInfo->id, $splitOrderInfo, $data);
- /** @var StoreOrderStatusServices $services */
- $services = app()->make(StoreOrderStatusServices::class);
- //记录原订单状态
- $status_data = ['oid' => $id, 'change_time' => time()];
- $status_data['change_type'] = 'delivery_split';
- $status_data['change_message'] = '已拆分发货';
- $services->save($status_data);
- } else {
- $this->doDelivery($id, $orderInfo, $data);
- }
- });
- return true;
- }
- /**
- * 具体执行发货
- * @param int $id
- * @param $orderInfo
- * @param array $data
- * @return array
- */
- public function doDelivery(int $id, $orderInfo, array $data)
- {
- $type = (int)$data['type'];
- unset($data['type']);
- //获取购物车内的商品标题
- /** @var StoreOrderCartInfoServices $orderInfoServices */
- $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
- $storeName = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo->id);
- if (isset($data['pickup_time']) && count($data['pickup_time']) == 2) {
- $data['pickup_start_time'] = $data['pickup_time'][0];
- $data['pickup_end_time'] = $data['pickup_time'][1];
- } else {
- $data['pickup_start_time'] = '';
- $data['pickup_end_time'] = '';
- }
- // 发货信息录入
- $res = [];
- switch ($type) {
- case 1://快递发货
- $res = $this->orderDeliverGoods($id, $data, $orderInfo, $storeName);
- event('NoticeListener', [['orderInfo' => $orderInfo, 'storeName' => $storeName, 'data' => $data], 'order_postage_success']);
- break;
- case 2://配送
- $this->orderDelivery($id, $data, $orderInfo, $storeName);
- event('NoticeListener', [['orderInfo' => $orderInfo, 'storeName' => $storeName, 'data' => $data], 'order_deliver_success']);
- break;
- case 3://虚拟发货
- $this->orderVirtualDelivery($id, $data, $orderInfo, $storeName);
- break;
- default:
- throw new AdminException(400522);
- }
- if (!$data['delivery_id'] && !empty($res['kuaidinum'])) {
- $data['delivery_id'] = $res['kuaidinum'];
- }
- if (!$data['delivery_id']) {
- $data['delivery_id'] = uniqid();
- }
- // 小程序订单管理
- event('OrderShipping', ['product', $orderInfo, $type, $data['delivery_id'], $data['delivery_name']]);
- //到期自动收货
- event('OrderDeliveryListener', [$orderInfo, $storeName, $data, $type]);
- return $res;
- }
- /**
- * 订单快递发货
- * @param int $id
- * @param array $data
- */
- public function orderDeliverGoods(int $id, array $data, $orderInfo, $storeTitle)
- {
- /** @var StoreOrderCartInfoServices $orderInfoServices */
- $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
- if (!$data['delivery_name']) {
- throw new AdminException(400007);
- }
- $dump = [];
- $data['delivery_type'] = 'express';
- if ($data['express_record_type'] == 2) {//电子面单
- if (!$data['delivery_code']) {
- throw new AdminException(400476);
- }
- if (!$data['express_temp_id']) {
- throw new AdminException(400527);
- }
- if (!$data['to_name']) {
- throw new AdminException(400008);
- }
- if (!$data['to_tel']) {
- throw new AdminException(400477);
- }
- if (!$data['to_addr']) {
- throw new AdminException(400478);
- }
- /** @var ServeServices $expressService */
- $expressService = app()->make(ServeServices::class);
- $expData['com'] = $data['delivery_code'];
- $expData['to_name'] = $orderInfo->real_name;
- $expData['to_tel'] = $orderInfo->user_phone;
- $expData['to_addr'] = $orderInfo->user_address;
- $expData['from_name'] = $data['to_name'];
- $expData['from_tel'] = $data['to_tel'];
- $expData['from_addr'] = $data['to_addr'];
- $expData['siid'] = sys_config('config_export_siid');
- $expData['temp_id'] = $data['express_temp_id'];
- $expData['count'] = $orderInfo->total_num;
- $expData['weight'] = $this->getOrderSumWeight($id);
- $expData['cargo'] = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo->id, true);
- $expData['order_id'] = $orderInfo->order_id;
- if (!sys_config('config_export_open', 0)) {
- throw new AdminException(400528);
- }
- $dump = $expressService->express()->dump($expData);
- $orderInfo->delivery_id = $dump['kuaidinum'];
- $data['express_dump'] = json_encode([
- 'com' => $expData['com'],
- 'from_name' => $expData['from_name'],
- 'from_tel' => $expData['from_tel'],
- 'from_addr' => $expData['from_addr'],
- 'temp_id' => $expData['temp_id'],
- 'cargo' => $expData['cargo'],
- ]);
- $data['delivery_id'] = $dump['kuaidinum'];
- if (!empty($dump['label'])) {
- $data['kuaidi_label'] = $dump['label'];
- }
- } else if ($data['express_record_type'] == 3) {
- //商家寄件
- if (!$data['delivery_code']) {
- throw new AdminException(400476);
- }
- if (!$data['express_temp_id']) {
- throw new AdminException(400527);
- }
- if (!$data['to_name']) {
- throw new AdminException(400008);
- }
- if (!$data['to_tel']) {
- throw new AdminException(400477);
- }
- if (!$data['to_addr']) {
- throw new AdminException(400478);
- }
- /** @var ServeServices $expressService */
- $expressService = app()->make(ServeServices::class);
- $expData['kuaidicom'] = $data['delivery_code'];
- $expData['man_name'] = $orderInfo->real_name;
- $expData['phone'] = $orderInfo->user_phone;
- $expData['address'] = $orderInfo->user_address;
- $expData['send_real_name'] = $data['to_name'];
- $expData['send_phone'] = $data['to_tel'];
- $expData['send_address'] = $data['to_addr'];
- $expData['temp_id'] = $data['express_temp_id'];
- $expData['weight'] = $this->getOrderSumWeight($id);
- $expData['cargo'] = $orderInfoServices->getCarIdByProductTitle((int)$orderInfo->id, true);
- $expData['day_type'] = $data['day_type'];
- $expData['pickup_start_time'] = $data['pickup_start_time'];
- $expData['pickup_end_time'] = $data['pickup_end_time'];
- // if (!sys_config('config_shippment_open', 0)) {
- // throw new AdminException('商家寄件未开启无法寄件');
- // }
- $dump = $expressService->express()->shippmentCreateOrder($expData);
- Log::error('商家寄件返回数据:' . json_encode($dump));
- $orderInfo->delivery_id = $dump['kuaidinum'] ?? '';
- $data['express_dump'] = json_encode([
- 'com' => $expData['kuaidicom'],
- 'from_name' => $expData['send_real_name'],
- 'from_tel' => $expData['send_phone'],
- 'from_addr' => $expData['send_address'],
- 'temp_id' => $expData['temp_id'],
- 'cargo' => $expData['cargo'],
- ]);
- $data['delivery_id'] = $dump['kuaidinum'] ?? '';
- $data['kuaidi_label'] = $dump['label'] ?? '';
- $data['kuaidi_task_id'] = $dump['task_id'] ?? '';
- $data['kuaidi_order_id'] = $dump['order_id'] ?? '';
- } else {
- if (!$data['delivery_id']) {
- throw new AdminException(400531);
- }
- $orderInfo->delivery_id = $data['delivery_id'];
- }
- if ($data['express_record_type'] != 3) {
- $data['status'] = 1;
- $orderInfo->delivery_type = $data['delivery_type'];
- $orderInfo->delivery_name = $data['delivery_name'];
- $orderInfo->status = $data['status'];
- /** @var StoreOrderStatusServices $services */
- $services = app()->make(StoreOrderStatusServices::class);
- $this->transaction(function () use ($id, $data, $services) {
- $res = $this->dao->update($id, $data);
- $res = $res && $services->save([
- 'oid' => $id,
- 'change_time' => time(),
- 'change_type' => 'delivery_goods',
- 'change_message' => '已发货 快递公司:' . $data['delivery_name'] . ' 快递单号:' . $data['delivery_id']
- ]);
- if (!$res) {
- throw new AdminException(400529);
- }
- });
- } else {
- $update = [
- 'is_stock_up' => 1,
- 'delivery_type' => $data['delivery_type'],
- 'delivery_name' => $data['delivery_name'],
- 'delivery_code' => $data['delivery_code'],
- 'delivery_id' => $data['delivery_id'],
- 'kuaidi_label' => $data['kuaidi_label'],
- 'kuaidi_task_id' => $data['kuaidi_task_id'],
- 'kuaidi_order_id' => $data['kuaidi_order_id'],
- 'express_dump' => $data['express_dump']
- ];
- /** @var StoreOrderStatusServices $services */
- $services = app()->make(StoreOrderStatusServices::class);
- $this->transaction(function () use ($id, $data, $services, $update) {
- $res = $this->dao->update($id, $update);
- $res = $res && $services->save([
- 'oid' => $id,
- 'change_time' => time(),
- 'change_type' => 'stock_up_goods',
- 'change_message' => '备货中 快递公司:' . $data['delivery_name'] . ' 快递单号:' . $data['delivery_id']
- ]);
- if (!$res) {
- throw new AdminException(400529);
- }
- });
- }
- return $dump;
- }
- /**
- * 返回订单商品总重量
- * @param int $id
- * @return int|string
- */
- public function getOrderSumWeight(int $id, $default = false)
- {
- /** @var StoreOrderCartInfoServices $services */
- $services = app()->make(StoreOrderCartInfoServices::class);
- $orderGoodInfo = $services->getOrderCartInfo((int)$id);
- $weight = 0;
- foreach ($orderGoodInfo as $cartInfo) {
- $cart = $cartInfo['cart_info'] ?? [];
- if ($cart) {
- $weight = bcadd((string)$weight, (string)bcmul((string)$cart['cart_num'] ?? '0', (string)$cart['productInfo']['attrInfo']['weight'] ?? '0', 4), 2);
- }
- }
- return $weight ?: ($default === false ? 0 : $default);
- }
- /**
- * 虚拟商品自动发货
- * @param $orderInfo
- * @throws \ReflectionException
- */
- public function virtualSend($orderInfo)
- {
- /** @var StoreOrderStatusServices $statusService */
- $statusService = app()->make(StoreOrderStatusServices::class);
- /** @var StoreOrderCartInfoServices $services */
- $services = app()->make(StoreOrderCartInfoServices::class);
- $orderInfo['cart_info'] = $services->getOrderCartInfo((int)$orderInfo['id']);
- $activityStatus = $orderInfo['combination_id'] || $orderInfo['seckill_id'] || $orderInfo['bargain_id'];
- if ($orderInfo['virtual_type'] == 1) {
- /** @var StoreOrderServices $orderService */
- $orderService = app()->make(StoreOrderServices::class);
- $sku = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['suk'];
- if ($activityStatus) {
- $product_id = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['product_id'];
- /** @var StoreProductAttrValueServices $attrValue */
- $attrValue = app()->make(StoreProductAttrValueServices::class);
- $disk_info = $attrValue->value(['product_id' => $product_id, 'suk' => $sku, 'type' => 0, 'is_virtual' => 1], 'disk_info');
- } else {
- $disk_info = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['disk_info'];
- }
- if ($disk_info != '') {
- $orderService->update(['id' => $orderInfo['id']], ['status' => 1, 'delivery_type' => 'fictitious', 'virtual_info' => $disk_info, 'remark' => '密钥自动发放:' . $disk_info]);
- $this->SystemSend($orderInfo['uid'], [
- 'mark' => 'virtual_info',
- 'title' => '虚拟密钥发放',
- 'content' => '您购买的密钥商品已支付成功,支付金额' . $orderInfo['pay_price'] . '元,订单号:' . $orderInfo['order_id'] . ',密钥:' . $disk_info . ',感谢您的光临!'
- ]);
- } else {
- if ($activityStatus) {
- $product_id = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['product_id'];
- /** @var StoreProductAttrValueServices $attrValue */
- $attrValue = app()->make(StoreProductAttrValueServices::class);
- $unique = $attrValue->value(['product_id' => $product_id, 'suk' => $sku, 'type' => 0, 'is_virtual' => 1], 'unique');
- } else {
- $unique = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['unique'];
- }
- /** @var StoreProductVirtualServices $virtualService */
- $virtualService = app()->make(StoreProductVirtualServices::class);
- $virtual = $virtualService->get(['attr_unique' => $unique, 'uid' => 0]);
- if (!$virtual) throw new ApiException(100026);
- $virtual->order_id = $orderInfo['order_id'];
- $virtual->uid = $orderInfo['uid'];
- $virtual->save();
- $orderService->update(['id' => $orderInfo['id']], ['status' => 1, 'delivery_type' => 'fictitious', 'virtual_info' => $virtual->card_unique, 'remark' => '卡密已自动发放,卡号:' . $virtual->card_no . ';密码:' . $virtual->card_pwd]);
- $this->SystemSend($orderInfo['uid'], [
- 'mark' => 'virtual_info',
- 'title' => '虚拟卡密发放',
- 'content' => '您购买的卡密商品已支付成功,支付金额' . $orderInfo['pay_price'] . '元,订单号:' . $orderInfo['order_id'] . ',卡号:' . $virtual->card_no . ';密码:' . $virtual->card_pwd . ',感谢您的光临!'
- ]);
- }
- $statusService->save([
- 'oid' => $orderInfo['id'],
- 'change_type' => 'delivery_fictitious',
- 'change_message' => '卡密自动发货',
- 'change_time' => time()
- ]);
- } elseif ($orderInfo['virtual_type'] == 2) {
- if ($activityStatus) {
- $sku = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['suk'];
- $product_id = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['product_id'];
- /** @var StoreProductAttrValueServices $attrValue */
- $attrValue = app()->make(StoreProductAttrValueServices::class);
- $coupon_id = $attrValue->value(['product_id' => $product_id, 'suk' => $sku, 'type' => 0, 'is_virtual' => 1], 'coupon_id');
- } else {
- $coupon_id = $orderInfo['cart_info'][$orderInfo['cart_id'][0]]['cart_info']['productInfo']['attrInfo']['coupon_id'];
- }
- /** @var StoreCouponIssueServices $issueService */
- $issueService = app()->make(StoreCouponIssueServices::class);
- $coupon = $issueService->get($coupon_id);
- if ($issueService->setCoupon($coupon, [$orderInfo['uid']])) {
- /** @var StoreOrderServices $orderService */
- $orderService = app()->make(StoreOrderServices::class);
- $orderService->update(['id' => $orderInfo['id']], ['status' => 1, 'delivery_type' => 'fictitious', 'virtual_info' => $coupon_id, 'remark' => '优惠券已自动发放']);
- $this->SystemSend($orderInfo['uid'], [
- 'mark' => 'virtual_info',
- 'title' => '购买优惠券发放',
- 'content' => '您购买的优惠券已支付成功,支付金额' . $orderInfo['pay_price'] . '元,订单号' . $orderInfo['order_id'] . '请在个人中心优惠券中查看,感谢您的光临!'
- ]);
- } else {
- throw new ApiException(410323);
- }
- $statusService->save([
- 'oid' => $orderInfo['id'],
- 'change_type' => 'delivery_fictitious',
- 'change_message' => '优惠券自动发货',
- 'change_time' => time()
- ]);
- }
- }
- /**
- * 虚拟商品站内信
- * @param int $uid
- * @param array $noticeInfo
- */
- public function SystemSend(int $uid, array $noticeInfo)
- {
- /** @var MessageSystemServices $MessageSystemServices */
- $MessageSystemServices = app()->make(MessageSystemServices::class);
- $data = [];
- $data['mark'] = $noticeInfo['mark'];
- $data['uid'] = $uid;
- $data['title'] = $noticeInfo['title'];
- $data['content'] = $noticeInfo['content'];
- $data['type'] = 1;
- $data['add_time'] = time();
- $MessageSystemServices->save($data);
- }
- }
|