683 lines
24 KiB
PHP
683 lines
24 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2016~2020 https://www.crmeb.com All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
|
||
// +----------------------------------------------------------------------
|
||
// | Author: CRMEB Team <admin@crmeb.com>
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace app\services\order;
|
||
|
||
|
||
use app\dao\order\StoreDeliveryOrderDao;
|
||
use app\jobs\order\OrderTakeJob;
|
||
use app\jobs\store\StoreFinanceJob;
|
||
use app\services\BaseServices;
|
||
use app\services\other\CityAreaServices;
|
||
use app\services\store\SystemStoreServices;
|
||
use app\services\supplier\SystemSupplierServices;
|
||
use crmeb\services\DeliverySevices;
|
||
use crmeb\services\FormBuilder as Form;
|
||
use crmeb\services\SystemConfigService;
|
||
use crmeb\traits\OptionTrait;
|
||
use think\exception\ValidateException;
|
||
use think\facade\Log;
|
||
use think\facade\Route as Url;
|
||
|
||
/**
|
||
* 发货单
|
||
* Class StoreDeliveryOrderServices
|
||
* @package app\services\order
|
||
* @mixin StoreDeliveryOrderDao
|
||
*/
|
||
class StoreDeliveryOrderServices extends BaseServices
|
||
{
|
||
use OptionTrait;
|
||
|
||
protected $statusData = [
|
||
2 => '待取货',
|
||
3 => '配送中',
|
||
4 => '已完成',
|
||
-1 => '已取消',
|
||
9 => '物品返回中',
|
||
10 => '物品返回完成',
|
||
100 => '骑士到店',
|
||
];
|
||
|
||
/**
|
||
* 平台达达门店
|
||
* @var string
|
||
*/
|
||
public $platCityShopId = 'plat_delivery_city_shop_001';
|
||
|
||
/**
|
||
* 构造方法
|
||
* StoreDeliveryOrderServices constructor.
|
||
* @param StoreDeliveryOrderDao $dao
|
||
*/
|
||
public function __construct(StoreDeliveryOrderDao $dao)
|
||
{
|
||
$this->dao = $dao;
|
||
}
|
||
|
||
/**
|
||
* 配送信息
|
||
* @return string[]
|
||
*/
|
||
public function getStatusMsg()
|
||
{
|
||
return $this->statusData;
|
||
}
|
||
|
||
/**
|
||
* @param array $where
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function systemPage(array $where)
|
||
{
|
||
[$page, $limit] = $this->getPageValue();
|
||
$list = $this->dao->getList($where, '*', $page, $limit, ['orderInfo', 'storeInfo']);
|
||
$count = $this->dao->count($where);
|
||
if ($list) {
|
||
foreach ($list as &$item) {
|
||
$item['add_time'] = $item['add_time'] ? date('Y-m-d H:i:s') : '';
|
||
$item['distance'] = $item['distance'] ? bcdiv($item['distance'], '1000', 3) : 0;
|
||
}
|
||
}
|
||
return compact('count', 'list');
|
||
}
|
||
|
||
/**
|
||
* 生成订单号
|
||
* @return string
|
||
* @throws \Exception
|
||
*/
|
||
public function getOrderSn(string $key = '')
|
||
{
|
||
[$msec, $sec] = explode(' ', microtime());
|
||
$msectime = number_format((floatval($msec) + floatval($sec)) * 1000, 0, '', '');
|
||
$orderId = $key . $msectime . random_int(10000, max(intval($msec * 10000) + 10000, 98369));
|
||
return $orderId;
|
||
}
|
||
|
||
/**
|
||
* 地址转经纬度
|
||
* @param $region
|
||
* @param $address
|
||
* @return mixed|null
|
||
*/
|
||
public function lbs_address($region, $address)
|
||
{
|
||
$key = sys_config('tengxun_map_key', '');
|
||
if (!$key) {
|
||
throw new ValidateException('请先配置地图KEY');
|
||
}
|
||
$locationOption = new \Joypack\Tencent\Map\Bundle\AddressOption($key);
|
||
$locationOption->setAddress($address);
|
||
// $locationOption->setRegion($region);
|
||
$location = new \Joypack\Tencent\Map\Bundle\Address($locationOption);
|
||
$res = $location->request();
|
||
if ($res->error) {
|
||
throw new ValidateException($res->error);
|
||
}
|
||
if ($res->status) {
|
||
throw new ValidateException($res->message);
|
||
}
|
||
if (!$res->result) {
|
||
throw new ValidateException('获取失败');
|
||
}
|
||
return $res->result;
|
||
}
|
||
|
||
|
||
/**
|
||
* 处理订单数据
|
||
* @param array $station
|
||
* @param array $order
|
||
* @param int $type
|
||
* @return array
|
||
*/
|
||
public function getPriceParams(array $station, array $order, int $type)
|
||
{
|
||
$data = [];
|
||
$type = (int)$type;
|
||
|
||
switch ($type) {
|
||
case 1:
|
||
$city = DeliverySevices::init(DeliverySevices::DELIVERY_TYPE_DADA)->getCity([]);
|
||
$res = [];
|
||
foreach ($city as $item) {
|
||
$res[$item['label']] = $item['key'];
|
||
}
|
||
//达达城市数据：西安
|
||
$city_name = str_replace(['市','自治州','地区','区划','县'], '',$station['city_name'] ?? '');
|
||
$data = [
|
||
'shop_no' => $station['origin_shop_id'],
|
||
'city_code' => $res[$city_name] ?? '西安',
|
||
'cargo_price' => $order['pay_price'],
|
||
'is_prepay' => 0,
|
||
'receiver_name' => $order['real_name'],
|
||
'receiver_address' => $order['user_address'],
|
||
'cargo_weight' => 0,
|
||
'receiver_phone' => $order['user_phone'],
|
||
'is_finish_code_needed' => 1,
|
||
];
|
||
break;
|
||
case 2://uu城市数据：西安市
|
||
$business = DeliverySevices::init(DeliverySevices::DELIVERY_TYPE_UU)->getBusiness();
|
||
$business = array_combine(array_column($business, 'key'), $business);
|
||
$data = [
|
||
'from_address' => $station['station_address'],
|
||
'to_address' => $order['user_address'],
|
||
'city_name' => $station['city_name'] ?? '西安',
|
||
'goods_type' => $business[$station['business'] ?? 1]['label'],
|
||
'send_type' =>'0',
|
||
'to_lat' => $order['latitude'],
|
||
'to_lng' => $order['longitude'],
|
||
'from_lat' => $station['lat'],
|
||
'from_lng' => $station['lng'],
|
||
];
|
||
break;
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 创建配送单
|
||
* @param int $id
|
||
* @param array $data
|
||
* @param int $type
|
||
* @param $order
|
||
* @return bool
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function create(int $id, array $data, int $type = 1, $order = [])
|
||
{
|
||
if (!$order) {
|
||
/** @var StoreOrderServices $orderServices */
|
||
$orderServices = app()->make(StoreOrderServices::class);
|
||
$order = $orderServices->get($id);
|
||
}
|
||
if (!$order) {
|
||
throw new ValidateException('订单信息获取失败');
|
||
}
|
||
if (isset($order['user_address']) && !$order['user_address']) {
|
||
throw new ValidateException('自提订单不支持同城配送');
|
||
}
|
||
$order = is_object($order) ? $order->toArray() : $order;
|
||
//处理地址定位
|
||
if (isset($order['user_location']) && $order['user_location']) {
|
||
[$longitude, $latitude] = explode(' ', $order['user_location']);
|
||
$order['longitude'] = $longitude;
|
||
$order['latitude'] = $latitude;
|
||
if (!$order['longitude'] || !$order['latitude']) {
|
||
$addressArr = $this->addressHandle($order['user_address']);
|
||
$city_name = $addressArr['city'] ?? '';
|
||
try {
|
||
$addres = $this->lbs_address($city_name, $order['user_address']);
|
||
$order['latitude'] = $addres['location']['lat'] ?? '';
|
||
$order['longitude'] = $addres['location']['lng'] ?? '';
|
||
} catch (\Exception $e) {
|
||
throw new ValidateException('获取经纬度失败');
|
||
}
|
||
}
|
||
}
|
||
if ($order['store_id']) {//门店
|
||
$resType = 1;
|
||
$relationId = (int)$order['store_id'];
|
||
} elseif ($order['supplier_id']) {//供应商
|
||
$resType = 2;
|
||
$relationId = (int)$order['supplier_id'];
|
||
} else {//平台信息
|
||
$resType = 0;
|
||
$relationId = 0;
|
||
}
|
||
//获取发货信息
|
||
$station = $this->syncCityShop($relationId, $resType, $type);
|
||
if (!$station || !isset($station['lat']) || !$station['lat'] || !isset($station['lng']) || !$station['lng']) {
|
||
throw new ValidateException('获取发货信息失败');
|
||
}
|
||
$getPriceParams = $this->getPriceParams($station, $order, $type);
|
||
$orderSn = $this->getOrderSn($type == 1 ? 'dd' : 'uu');
|
||
$getPriceParams['origin_id'] = $orderSn;
|
||
$getPriceParams['cargo_weight'] = $data['cargo_weight'] ?? '';
|
||
|
||
$service = DeliverySevices::init($type);
|
||
try {
|
||
//计算价格
|
||
$priceData = $service->getOrderPrice($getPriceParams);
|
||
if ($type == DeliverySevices::DELIVERY_TYPE_UU) { //uu
|
||
$priceData['receiver'] = $order['real_name'];
|
||
$priceData['receiver_phone'] = $order['user_phone'];
|
||
$priceData['note'] = $data['delivery_remark'] ?? '';
|
||
$priceData['push_type'] = 2;
|
||
$priceData['special_type'] = $data['special_type'] ?? 0;
|
||
}
|
||
|
||
$res = $service->addOrder($priceData);
|
||
$ret = [
|
||
'type' => $resType,
|
||
'relation_id' => $relationId,
|
||
'oid' => $id,
|
||
'order_id' => $orderSn,
|
||
'delivery_no' => $type == 2 ?($res['ordercode'] ?? '') : ($priceData['deliveryNo'] ?? ''),
|
||
'city_code' => $station['city_name'] ?? '西安',
|
||
'receiver_phone' => $order['user_phone'],
|
||
'user_name' => $order['real_name'],
|
||
'from_address' => $station['station_address'] ?? '',
|
||
'to_address' => $order['user_address'],
|
||
'info' => $data['delivery_remark'] ?? '',
|
||
'status' => 0,
|
||
'station_type' => $type,
|
||
'to_lat' => $order['latitude'],
|
||
'to_lng' => $order['longitude'],
|
||
'from_lat' => $station['lat'] ?? '',
|
||
'from_lng' => $station['lng'] ?? '',
|
||
'distance' => $priceData['distance'],
|
||
'fee' => $priceData['fee'] ?? $priceData['need_paymoney'] ?? 0,
|
||
'mark' => $data['delivery_remark'] ?? '',
|
||
'uid' => $order['uid'],
|
||
'add_time' => time()
|
||
];
|
||
//入库操作
|
||
$this->dao->save($ret);
|
||
//记录门店流水
|
||
if ($resType == 1) {
|
||
StoreFinanceJob::dispatch([$ret, 6, $ret['fee']]);
|
||
}
|
||
return true;
|
||
} catch (\Throwable $e) {
|
||
if (isset($res['status']) && $res['status'] == 'success'){
|
||
$error['origin_id'] = $orderSn;
|
||
$error['reason'] = $type == 1 ? 36 : '信息错误';
|
||
$error['delivery_no'] = $type == 2 ? $res['ordercode'] : $priceData['deliveryNo'];
|
||
$service->cancelOrder($error);
|
||
}
|
||
throw new ValidateException($e->getMessage());
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* 配送订单详情
|
||
* @param int $id
|
||
* @return array|\think\Model
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function detail(int $id)
|
||
{
|
||
$res = $this->dao->get($id, ['orderInfo']);
|
||
if (!$res) {
|
||
throw new ValidateException('配送订单不存在，或已取消');
|
||
}
|
||
$res = $res->toArray();
|
||
$order = DeliverySevices::init((int)$res['station_type'])->getOrderDetail($res);
|
||
if (!$res) throw new ValidateException('订单不存在');
|
||
$res['data'] = [
|
||
'order_id' => $order['order_code'],
|
||
'to_address' => $order['to_address'],
|
||
'from_address' => $order['from_address'],
|
||
'state' => $order['state'],
|
||
'note' => $order['note'],
|
||
'order_price' => $order['order_price'],
|
||
'distance' => round(($order['distance'] / 1000),2) . ' km',
|
||
];
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 删除
|
||
* @param int $id
|
||
* @return mixed
|
||
*/
|
||
public function delete(int $id)
|
||
{
|
||
$res = $this->dao->get($id);
|
||
if (!$res) throw new ValidateException('订单不存在');
|
||
return $this->dao->delete($id);
|
||
}
|
||
|
||
/**
|
||
* @param $id
|
||
* @return mixed
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function cancelForm($id)
|
||
{
|
||
$order = $this->dao->get($id);
|
||
if (!$order) throw new ValidateException('订单不存在');
|
||
if ($order['status'] == -1) throw new ValidateException('订单已取消，无法操作');
|
||
$field = [];
|
||
if ($order['station_type'] == 1) {
|
||
$options = DeliverySevices::init(1)->reasons();
|
||
$field[] = Form::select('reason', '取消原因')->setOptions(Form::setOptions($options))->filterable(1)->col(12);
|
||
$field[] = Form::input('cancel_reason', '其他原因说明')->required('请输入原因');
|
||
} else {
|
||
$field[] = Form::input('reason', '取消原因')->required('请输入原因');
|
||
}
|
||
return create_form('取消同城配送订单', $field, Url::buildUrl('/order/delivery_order/cancel/'. $id), 'POST');
|
||
}
|
||
|
||
/**
|
||
* 取消订单
|
||
* @param int $id
|
||
* @param array $reason
|
||
* @return mixed
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function cancel(int $id, array $reason)
|
||
{
|
||
$order = $this->dao->get($id);
|
||
if (!$order) throw new ValidateException('配送订单不存在');
|
||
if ($order['status'] == -1) throw new ValidateException('请勿重复操作');
|
||
$data = [
|
||
'origin_id' => $order['order_id'],
|
||
'order_code'=> $order['delivery_no'],
|
||
'reason' => $reason['reason'],
|
||
'cancel_reason' => $reason['cancel_reason'],
|
||
];
|
||
$this->transaction(function () use($id, $order, $data){
|
||
$mark = $data['reason'];
|
||
$delivery = DeliverySevices::init((int)$order['station_type']);
|
||
if ($order['station_type'] == DeliverySevices::DELIVERY_TYPE_DADA) {
|
||
$options = $delivery->reasons();
|
||
if ($options) $options = array_combine(array_column($options, 'value'), $options);
|
||
$mark = $options[$data['reason']]['label'] ?? '';
|
||
}
|
||
if ($data['cancel_reason']) $mark .= ','.$data['cancel_reason'];
|
||
$res = $delivery->cancelOrder($data);
|
||
$deduct_fee = $res['deduct_fee'] ?? 0;
|
||
$this->doCancel($id, $order, $deduct_fee, $mark);
|
||
|
||
});
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 执行取消订单
|
||
* @param int $id
|
||
* @param $deliveryOrder
|
||
* @param $deduct_fee
|
||
* @param $mark
|
||
* @return bool
|
||
*/
|
||
public function doCancel(int $id , $deliveryOrder, $deduct_fee, $mark)
|
||
{
|
||
//修改配送单
|
||
$this->dao->update($id, ['status' => 1, 'mark' => $mark, 'deduct_fee' => $deduct_fee]);
|
||
//修改愿订单
|
||
/** @var StoreOrderServices $storeOrderServices */
|
||
$storeOrderServices = app()->make(StoreOrderServices::class);
|
||
$storeOrderServices->update($deliveryOrder['oid'], ['status' => 0, 'delivery_type' => '', 'delivery_name' => '', 'delivery_id' => '', 'delivery_uid' => '']);
|
||
/** @var StoreOrderStatusServices $statusServices */
|
||
$statusServices = app()->make(StoreOrderStatusServices::class);
|
||
$statusServices->save([
|
||
'oid' => $deliveryOrder['oid'],
|
||
'change_type' => 'city_delivery_cancel',
|
||
'change_message' => '同城配送取消',
|
||
'change_time' => time()
|
||
]);
|
||
//记录门店流水
|
||
if ($deliveryOrder['type'] == 1) {
|
||
StoreFinanceJob::dispatch([$deliveryOrder, 7, $deliveryOrder['fee']]);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
|
||
/**
|
||
* TODO 回调
|
||
* @param $data
|
||
* @author Qinii
|
||
* @day 2/17/22
|
||
*/
|
||
public function notify($data)
|
||
{
|
||
//达达
|
||
/**
|
||
* 订单状态(待接单＝1,待取货＝2,配送中＝3,已完成＝4,已取消＝5, 指派单=8,妥投异常之物品返回中=9, 妥投异常之物品返回完成=10, 骑士到店=100,创建达达运单失败=1000 可参考文末的状态说明）
|
||
*/
|
||
Log::info('同城回调参数：'.var_export(['=======',$data,'======='],1));
|
||
if (isset($data['data'])) {
|
||
$data = json_decode($data['data'], 1);
|
||
}
|
||
|
||
$reason = '';
|
||
$deductFee = 0;
|
||
$delivery = [];
|
||
if (isset($data['order_status'])){
|
||
$order_id = $data['order_id'];
|
||
if ($data['order_status'] == 1) {
|
||
$orderData = $this->dao->getOne(['order_id' => $data['order_id']]);
|
||
if (!$orderData['finish_code']) {
|
||
$orderData->finish_code = $data['finish_code'];
|
||
$orderData->save();
|
||
}
|
||
return ;
|
||
} else if (in_array( $data['order_status'],[2,3,4,5,9,10,100])){
|
||
$status = $data['order_status'];
|
||
if ($data['order_status'] == 5){
|
||
$msg = [
|
||
'取消：',
|
||
'达达配送员取消：',
|
||
'商家主动取消：',
|
||
'系统或客服取消：',
|
||
];
|
||
//1:达达配送员取消；2:商家主动取消；3:系统或客服取消；0:默认值
|
||
$status = -1;
|
||
$reason = $msg[$data['cancel_from']].$data['cancel_reason'];
|
||
}
|
||
$deductFee = $data['deductFee'] ?? 0;
|
||
if (isset($data['dm_name']) && $data['dm_name']) {
|
||
$delivery = [
|
||
'delivery_name' => $data['dm_name'],
|
||
'delivery_id' => $data['dm_mobile'],
|
||
];
|
||
}
|
||
|
||
}
|
||
} else if (isset($data['state'])){ //uu
|
||
if (!$data['origin_id']) $deliveryOrder = $this->dao->getOne(['delivery_no' => $data['order_code']]);
|
||
$order_id = $data['origin_id'] ?: $deliveryOrder['order_id'] ;
|
||
//当前状态 1下单成功 3跑男抢单 4已到达 5已取件 6到达目的地 10收件人已收货 -1订单取消
|
||
switch ($data['state']) {
|
||
case 3:
|
||
$status = 2;
|
||
break;
|
||
case 4:
|
||
$status = 100;
|
||
break;
|
||
case 5:
|
||
$status = 3;
|
||
break;
|
||
case 10:
|
||
$status = 4;
|
||
break;
|
||
case -1:
|
||
$status = -1;
|
||
$reason = $data['state_text'];
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
if (isset($data['driver_name']) && $data['driver_name']) {
|
||
$delivery = [
|
||
'delivery_name' => $data['driver_name'],
|
||
'delivery_id' => $data['driver_mobile'],
|
||
];
|
||
}
|
||
}
|
||
|
||
if (isset($order_id) && isset($status)){
|
||
$deliveryOrder = $this->dao->getOne(['order_id' => $order_id]);
|
||
if ($deliveryOrder) {
|
||
$this->notifyAfter($status, $reason, $deliveryOrder, $delivery, $deductFee);
|
||
}else {
|
||
Log::info('同城配送回调，未查询到订单：'.$order_id);
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @param $status
|
||
* @param $reason
|
||
* @param $res
|
||
* @param $data
|
||
* @param $deductFee
|
||
* @return bool
|
||
*/
|
||
public function notifyAfter($status, $reason, $deliveryOrder, $data, $deductFee)
|
||
{
|
||
if (!isset($this->statusData[$status])) return true;
|
||
/** @var StoreOrderServices $orderServices */
|
||
$orderServices = app()->make(StoreOrderServices::class);
|
||
$orderData = $orderServices->get($deliveryOrder['oid']);
|
||
/** @var StoreOrderStatusServices $statusServices */
|
||
$statusServices = app()->make(StoreOrderStatusServices::class);
|
||
$change_type = 'city_delivery_' . $status;
|
||
$oid = (int)$deliveryOrder['oid'];
|
||
|
||
if ($orderData['status'] != $status && !$statusServices->count(['oid' => $oid, 'change_type' => $change_type])) {
|
||
$order = $orderServices->get($oid);
|
||
//修改配送单
|
||
$this->dao->update($deliveryOrder['id'], ['status' => $status, 'reason' => $reason]);
|
||
//增加
|
||
$message = '订单已配送【'. $this->statusData[$status].'】';
|
||
$statusServices->save([
|
||
'oid' => $oid,
|
||
'change_type' => $change_type,
|
||
'change_message' => $message,
|
||
'change_time' => time()
|
||
]);
|
||
switch ($status) {
|
||
case 2:
|
||
if (!empty($data)) $orderServices->update($oid, $data);
|
||
break;
|
||
case 4:
|
||
//订单收货
|
||
if ($order['status'] != 2) {
|
||
OrderTakeJob::dispatch([$order]);
|
||
}
|
||
break;
|
||
case -1:
|
||
$this->doCancel((int)$deliveryOrder['id'], $deliveryOrder, $deductFee , $reason);
|
||
break;
|
||
}
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 同步达达门店信息
|
||
* @param int $id
|
||
* @param bool $is_new
|
||
* @param int $type
|
||
* @param int $station_type
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function syncCityShop(int $id, int $type = 1, int $station_type = 1)
|
||
{
|
||
$data = [];
|
||
if ($station_type == 1) {
|
||
$status = sys_config('dada_delivery_status');
|
||
} else {
|
||
$status = sys_config('uu_delivery_status');
|
||
}
|
||
if (!$status) {//未开启
|
||
return $data;
|
||
}
|
||
if ($type == 1) {//门店
|
||
/** @var SystemStoreServices $storeServices */
|
||
$storeServices = app()->make(SystemStoreServices::class);
|
||
$station = $storeServices->getStoreInfo($id);
|
||
/** @var CityAreaServices $cityArea */
|
||
$cityArea = app()->make(CityAreaServices::class);
|
||
$station['city_name'] = $cityArea->value(['id' => $station['city']], 'name');
|
||
$station['address'] = $station['address'] . $station['detailed_address'];
|
||
if (!$station['city_shop_id']) {
|
||
$station['city_shop_id'] = 'deliver_store_' . $station['id'] . '_'. $this->getOrderSn();
|
||
$storeServices->update($id, ['city_shop_id' => $station['city_shop_id']]);
|
||
}
|
||
} elseif ($type == 2){//供应商
|
||
/** @var SystemSupplierServices $services */
|
||
$services = app()->make(SystemSupplierServices::class);
|
||
$station = $services->getSupplierInfo($id);
|
||
if ($station) {
|
||
$station['name'] = $station['supplier_name'] ?? '';
|
||
}
|
||
} else {//平台
|
||
$station = SystemConfigService::more(['refund_address', 'refund_name', 'refund_phone']);
|
||
$address = $station['refund_address'];
|
||
if ($address) {
|
||
$station['address'] = $station['refund_address'];
|
||
$station['name'] = $station['refund_name'];
|
||
$station['phone'] = $station['refund_phone'];
|
||
$station['city_shop_id'] = $this->platCityShopId;
|
||
}
|
||
}
|
||
if (!isset($station['latitude'])) {//地址转经纬度
|
||
$addressArr = $this->addressHandle($station['address']);
|
||
if (!$addressArr['province'] || !$addressArr['city']) {
|
||
throw new ValidateException($type == 0 ? '请检查（设置->商城设置->交易设置->退货收货人地址）完整性' : '请检查该订单关联供应商地址信息是否正确');
|
||
}
|
||
$station['city_name'] = $addressArr['city'] ?? '';
|
||
try {
|
||
$addres = $this->lbs_address($station['city_name'], $station['address']);
|
||
$station['latitude'] = $addres['location']['lat'] ?? '';
|
||
$station['longitude'] = $addres['location']['lng'] ?? '';
|
||
} catch (\Exception $e) {
|
||
throw new ValidateException('获取经纬度失败');
|
||
}
|
||
}
|
||
$data = [
|
||
'lng' => (float)($station['longitude'] ?? 0),
|
||
'lat' => (float)($station['latitude'] ?? 0),
|
||
'phone' => $station['phone'] ?? '',
|
||
'business' => (int)($station['business'] ?? 5),
|
||
'contact_name' => $station['name'] ?? '',
|
||
'station_name' => $station['name'],
|
||
'station_address' => $station['address'] ?? '',
|
||
'status' => 1,
|
||
'origin_shop_id' => $station['city_shop_id'],
|
||
];
|
||
if ($data) {
|
||
$serve = DeliverySevices::init($station_type);
|
||
try {
|
||
$shop = $serve->getShopDetail($data['origin_shop_id']);
|
||
} catch (\Throwable $e) {
|
||
$shop = [];
|
||
}
|
||
try {
|
||
if (!$shop) {
|
||
$serve->addShop($data);
|
||
} else {
|
||
$serve->updateShop($data);
|
||
}
|
||
} catch (\Throwable $e) {
|
||
throw new ValidateException('创建达达门店失败，原因：' . $e->getMessage());
|
||
}
|
||
}
|
||
$data['city_name'] = $station['city_name'];
|
||
return $data;
|
||
}
|
||
|
||
|
||
}
|