package cn.lili.modules.wechat.serviceimpl;
|
|
import cn.hutool.json.JSONObject;
|
import cn.hutool.json.JSONUtil;
|
import cn.lili.common.enums.ClientTypeEnum;
|
import cn.lili.common.exception.ServiceException;
|
import cn.lili.common.security.context.UserContext;
|
import cn.lili.common.utils.HttpUtils;
|
import cn.lili.modules.connect.entity.Connect;
|
import cn.lili.modules.connect.entity.enums.SourceEnum;
|
import cn.lili.modules.connect.service.ConnectService;
|
import cn.lili.modules.member.entity.dto.ConnectQueryDTO;
|
import cn.lili.modules.order.order.entity.dos.Order;
|
import cn.lili.modules.order.order.entity.dos.OrderItem;
|
import cn.lili.modules.order.order.entity.enums.OrderStatusEnum;
|
import cn.lili.modules.order.order.service.OrderItemService;
|
import cn.lili.modules.order.order.service.OrderService;
|
import cn.lili.modules.system.entity.dos.Setting;
|
import cn.lili.modules.system.entity.dto.payment.WechatPaymentSetting;
|
import cn.lili.modules.system.entity.enums.SettingEnum;
|
import cn.lili.modules.system.service.SettingService;
|
import cn.lili.modules.wechat.service.WechatMPService;
|
import cn.lili.modules.wechat.util.WechatAccessTokenUtil;
|
import lombok.AllArgsConstructor;
|
import lombok.Data;
|
import lombok.NoArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.time.ZonedDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 微信小程序 业务实现
|
*
|
* @author Bulbasaur
|
*/
|
@Service
|
@Slf4j
|
public class WechatMPServiceImpl implements WechatMPService {
|
|
@Autowired
|
private OrderService orderService;
|
@Autowired
|
private OrderItemService orderItemService;
|
@Autowired
|
private ConnectService connectService;
|
@Autowired
|
private WechatAccessTokenUtil wechatAccessTokenUtil;
|
@Autowired
|
private SettingService settingService;
|
|
/**
|
* 发货信息接口
|
*/
|
String url = "https://api.weixin.qq.com/wxa/sec/order/upload_shipping_info?access_token=";
|
/**
|
* 物流公司列表
|
*/
|
String DeliveryUrl = "https://api.weixin.qq.com/cgi-bin/express/delivery/open_msg/get_delivery_list?access_token=";
|
/**
|
* 是否开通发货信息管理
|
*/
|
String isTradeManagedUrl = "https://api.weixin.qq.com/wxa/sec/order/is_trade_managed?access_token=";
|
|
/**
|
* 发货信息录入
|
*
|
* @param orderSn 订单号
|
*/
|
@Override
|
public void uploadShippingInfo(String orderSn) {
|
|
Order order = orderService.getBySn(orderSn);
|
//是否是微信小程序订单 && 微信支付
|
if (!order.getClientType().equals(ClientTypeEnum.WECHAT_MP.name())
|
|| !order.getPaymentMethod().equals(ClientTypeEnum.WECHAT_MP.name())) {
|
return;
|
}
|
//是否开通发货信息管理
|
if (!isTradeManaged()) {
|
return;
|
}
|
|
Map<String, Object> map = new HashMap<>(2);
|
|
//发货信息录入
|
//订单，需要上传物流信息的订单
|
map.put("order_key", new OrderKey(order));
|
|
|
if (order.getOrderStatus().equals(OrderStatusEnum.TAKE.name())) {
|
|
//物流模式，发货方式枚举值：1、实体物流配送采用快递公司进行实体物流配送形式 2、同城配送 3、虚拟商品，虚拟商品，例如话费充值，点卡等，无实体配送形式 4、用户自提
|
map.put("logistics_type", 3);
|
//发货模式，发货模式枚举值：1、UNIFIED_DELIVERY（统一发货）2、SPLIT_DELIVERY（分拆发货） 示例值: UNIFIED_DELIVERY
|
map.put("delivery_mode", 1);
|
|
|
} else if (order.getOrderStatus().equals(OrderStatusEnum.DELIVERED.name())) {
|
|
//物流模式，发货方式枚举值：1、实体物流配送采用快递公司进行实体物流配送形式 2、同城配送 3、虚拟商品，虚拟商品，例如话费充值，点卡等，无实体配送形式 4、用户自提
|
map.put("logistics_type", 1);
|
//发货模式，发货模式枚举值：1、UNIFIED_DELIVERY（统一发货）2、SPLIT_DELIVERY（分拆发货） 示例值: UNIFIED_DELIVERY
|
map.put("delivery_mode", 1);
|
|
//物流信息列表，发货物流单列表，支持统一发货（单个物流单）和分拆发货（多个物流单）两种模式，多重性: [1, 10]
|
List<Shipping> shippingList = new ArrayList<>();
|
Shipping shipping = new Shipping();
|
shipping.setTracking_no(order.getLogisticsNo());
|
shipping.setExpress_company(getDeliveryList(order));
|
//商品信息，例如：微信红包抱枕*1个，限120个字以内
|
List<OrderItem> orderItemList = orderItemService.getByOrderSn(order.getSn());
|
shipping.setItem_desc(orderItemList.get(0).getGoodsName());
|
//联系方式，当发货的物流公司为顺丰时，联系方式为必填，收件人或寄件人联系方式二选一
|
Contact contact = new Contact();
|
contact.setReceiver_contact(order.getConsigneeMobile());
|
shipping.setContact(contact);
|
shippingList.add(shipping);
|
map.put("shipping_list", shippingList);
|
|
|
} else if (order.getOrderStatus().equals(OrderStatusEnum.STAY_PICKED_UP.name())) {
|
|
//物流模式，发货方式枚举值：1、实体物流配送采用快递公司进行实体物流配送形式 2、同城配送 3、虚拟商品，虚拟商品，例如话费充值，点卡等，无实体配送形式 4、用户自提
|
map.put("logistics_type", 4);
|
//发货模式，发货模式枚举值：1、UNIFIED_DELIVERY（统一发货）2、SPLIT_DELIVERY（分拆发货） 示例值: UNIFIED_DELIVERY
|
map.put("delivery_mode", 1);
|
|
}
|
//上传时间，用于标识请求的先后顺序 示例值: `2022-12-15T13:29:35.120+08:00`
|
map.put("upload_time", DateTimeFormatter.ISO_OFFSET_DATE_TIME.format(ZonedDateTime.now()));
|
|
//支付者，支付者信息
|
Connect connect = connectService.queryConnect(ConnectQueryDTO.builder().userId(UserContext.getCurrentUser().getId()).unionType(SourceEnum.WECHAT_MP_OPEN_ID.name()).build());
|
if (connect == null) {
|
return;
|
}
|
map.put("payer", new Payer(connect.getUnionId()));
|
this.doPostWithJson(url, map);
|
|
|
}
|
|
/**
|
* 是否已开通发货信息管理服务
|
* https://developers.weixin.qq.com/miniprogram/dev/platform-capabilities/business-capabilities/order-shipping/order-shipping.html#%E4%B8%83%E3%80%81%E6%9F%A5%E8%AF%A2%E5%B0%8F%E7%A8%8B%E5%BA%8F%E6%98%AF%E5%90%A6%E5%B7%B2%E5%BC%80%E9%80%9A%E5%8F%91%E8%B4%A7%E4%BF%A1%E6%81%AF%E7%AE%A1%E7%90%86%E6%9C%8D%E5%8A%A1
|
*/
|
private Boolean isTradeManaged() {
|
|
Setting systemSetting = settingService.get(SettingEnum.WECHAT_PAYMENT.name());
|
WechatPaymentSetting wechatPaymentSetting = JSONUtil.toBean(systemSetting.getSettingValue(), WechatPaymentSetting.class);
|
//发送url
|
Map<String, Object> map = new HashMap<>(2);
|
map.put("appid", wechatPaymentSetting.getMpAppId());
|
JSONObject jsonObject = this.doPostWithJson(isTradeManagedUrl, map);
|
|
return jsonObject.getBool("is_trade_managed");
|
}
|
|
/**
|
* 查询物流公司编码列表
|
* https://developers.weixin.qq.com/miniprogram/dev/platform-capabilities/industry/express/business/express_search.html#%E8%8E%B7%E5%8F%96%E8%BF%90%E5%8A%9Bid%E5%88%97%E8%A1%A8get-delivery-list
|
*/
|
private String getDeliveryList(Order order) {
|
//发送url
|
|
Map<String, Object> map = new HashMap<>(2);
|
JSONObject jsonObject = this.doPostWithJson(DeliveryUrl, map);
|
Map<String, String> roomMap = new HashMap<>(2);
|
List<Delivery> deliveryList = JSONUtil.toList(jsonObject.getStr("delivery_list"), Delivery.class);
|
for (Delivery delivery : deliveryList) {
|
if (order.getLogisticsName().equals(delivery.getDelivery_name())) {
|
return delivery.getDelivery_id();
|
}
|
}
|
throw new RuntimeException("未找到快递公司");
|
}
|
|
|
/**
|
* 请求微信接口
|
*
|
* @param url 链接
|
* @param map 参数
|
* @return 返回内容
|
*/
|
private JSONObject doPostWithJson(String url, Map map) {
|
//获取token
|
String token = wechatAccessTokenUtil.cgiAccessToken(ClientTypeEnum.WECHAT_MP);
|
//请求链接添加token
|
url += token;
|
//发起请求
|
String content = HttpUtils.doPostWithJson(url, map);
|
//记录请求结果
|
log.info("微信小程序请求结果：" + content);
|
//获取请求内容，如果token过期则重新获取，如果出错则抛出错误
|
JSONObject jsonObject = new JSONObject(content);
|
if (("0").equals(jsonObject.get("errcode").toString())) {
|
return jsonObject;
|
} else if (("40001").equals(jsonObject.get("errcode"))) {
|
wechatAccessTokenUtil.removeAccessToken(ClientTypeEnum.WECHAT_MP);
|
return this.doPostWithJson(url, map);
|
} else {
|
throw new ServiceException(jsonObject.get("errmsg").toString());
|
}
|
}
|
|
|
@Data
|
@AllArgsConstructor
|
@NoArgsConstructor
|
class Contact {
|
|
/**
|
* 寄件人联系方式，寄件人联系方式，采用掩码传输，最后4位数字不能打掩码 示例值: `189****1234, 021-****1234, ****1234, 0**2-***1234, 0**2-******23-10, ****123-8008` 值限制: 0 ≤ value ≤ 1024
|
*/
|
String consignor_contact;
|
|
/**
|
* 收件人联系方式，收件人联系方式为，采用掩码传输，最后4位数字不能打掩码 示例值: `189****1234, 021-****1234, ****1234, 0**2-***1234, 0**2-******23-10, ****123-8008` 值限制: 0 ≤ value ≤ 1024
|
*/
|
String receiver_contact;
|
}
|
|
@Data
|
@AllArgsConstructor
|
@NoArgsConstructor
|
class Delivery {
|
|
private String delivery_id;
|
private String delivery_name;
|
}
|
|
@Data
|
@AllArgsConstructor
|
@NoArgsConstructor
|
class OrderKey {
|
|
/**
|
* 订单单号类型，用于确认需要上传详情的订单。枚举值1，使用下单商户号和商户侧单号；枚举值2，使用微信支付单号。
|
*/
|
private Integer order_number_type;
|
|
/**
|
* 原支付交易对应的微信订单号
|
*/
|
private String transaction_id;
|
|
/**
|
* 支付下单商户的商户号，由微信支付生成并下发
|
*/
|
private String mchid;
|
|
/**
|
* 商户系统内部订单号，只能是数字、大小写字母`_-*`且在同一个商户号下唯一
|
*/
|
private String out_trade_no;
|
|
public OrderKey(Order order) {
|
this.order_number_type = 2;
|
this.out_trade_no = order.getPayOrderNo();
|
this.transaction_id = order.getReceivableNo();
|
}
|
}
|
|
@Data
|
@NoArgsConstructor
|
class Payer {
|
|
/**
|
* 用户标识，用户在小程序appid下的唯一标识。 下单前需获取到用户的Openid 示例值: oUpF8uMuAJO_M2pxb1Q9zNjWeS6o 字符字节限制: [1, 128]
|
*/
|
String openid;
|
|
public Payer(String openid) {
|
this.openid = openid;
|
}
|
}
|
|
@Data
|
@AllArgsConstructor
|
@NoArgsConstructor
|
class Shipping {
|
|
/**
|
* 物流单号，物流快递发货时必填，示例值: 323244567777 字符字节限制: [1, 128]
|
*/
|
private String tracking_no;
|
|
/**
|
* 物流公司编码，快递公司ID，参见「查询物流公司编码列表」，物流快递发货时必填， 示例值: DHL 字符字节限制: [1, 128]
|
*/
|
private String express_company;
|
|
/**
|
* 商品信息，例如：微信红包抱枕*1个，限120个字以内
|
*/
|
private String item_desc;
|
|
/**
|
* 联系方式，当发货的物流公司为顺丰时，联系方式为必填，收件人或寄件人联系方式二选一
|
*/
|
private Contact contact;
|
|
}
|
|
}
|
