Merge remote-tracking branch 'yudao/feature/mall_product' into feature/mall_product

# Conflicts:
#	yudao-module-mall/yudao-module-product-biz/src/main/java/cn/iocoder/yudao/module/product/controller/app/comment/AppCommentController.java
#	yudao-module-mall/yudao-module-product-biz/src/main/java/cn/iocoder/yudao/module/product/controller/app/comment/vo/AppProductCommentBaseVO.java
#	yudao-module-mall/yudao-module-product-biz/src/main/java/cn/iocoder/yudao/module/product/controller/app/comment/vo/AppProductCommentRespVO.java
#	yudao-module-mall/yudao-module-product-biz/src/main/java/cn/iocoder/yudao/module/product/controller/app/spu/AppProductSpuController.java
#	yudao-module-mall/yudao-module-product-biz/src/test/java/cn/iocoder/yudao/module/product/service/comment/ProductCommentServiceImplTest.java

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/controller/app/order/AppTradeOrderController.java

@@ -71,7 +71,7 @@ public class AppTradeOrderController {
     }
 
     @PostMapping("/update-paid")
-    @Operation(description = "更新订单为已支付") // 由 pay-module 支付服务，进行回调，可见 PayNotifyJob
+    @Operation(summary = "更新订单为已支付") // 由 pay-module 支付服务，进行回调，可见 PayNotifyJob
     public CommonResult<Boolean> updateOrderPaid(@RequestBody PayOrderNotifyReqDTO notifyReqDTO) {
         tradeOrderService.updateOrderPaid(Long.valueOf(notifyReqDTO.getMerchantOrderId()),
                 notifyReqDTO.getPayOrderId());

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/config/TradeExpressQueryProperties.java

@@ -0,0 +1,82 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.config;
+
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProviderEnum;
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+import org.springframework.validation.annotation.Validated;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotEmpty;
+
+// TODO @jason：TradeExpressProperties；更通用哈
+// TODO @芋艿：未来要不要放数据库中？考虑 saas 多租户时，不同租户使用不同的配置？
+/**
+ * 交易快递查询的配置项
+ *
+ * @author jason
+ */
+@Component
+@ConfigurationProperties(prefix = "yudao.trade.express.query")
+@Data
+@Validated
+public class TradeExpressQueryProperties {
+
+    /**
+     * 快递查询服务商
+     *
+     * 如果未配置，默认使用快递鸟
+     */
+    // TODO @jason：可以把 expressQueryProvider 改成 client 变量，更简洁一点；
+    private ExpressQueryProviderEnum expressQueryProvider; // TODO @jaosn：默认值可以通过属性直接赋值哈；
+    // TODO @jason：需要考虑下，用户只配置了其中一个；
+    /**
+     * 快递鸟配置
+     */
+    @Valid
+    private KdNiaoConfig kdNiao;
+    /**
+     * 快递 100 配置
+     */
+    @Valid
+    private Kd100Config kd100;
+
+    /**
+     * 快递鸟配置项目
+     */
+    @Data
+    public static class KdNiaoConfig {
+
+        /**
+         * 快递鸟用户 ID
+         */
+        @NotEmpty(message = "快递鸟用户 ID 配置项不能为空")
+        private String businessId;
+        /**
+         * 快递鸟 API Key
+         */
+        @NotEmpty(message = "快递鸟 Api Key 配置项不能为空")
+        private String apiKey;
+
+    }
+
+    /**
+     * 快递100 配置项
+     */
+    @Data
+    public static class Kd100Config {
+
+        /**
+         * 快递 100 授权码
+         */
+        @NotEmpty(message = "快递 100 授权码配置项不能为空")
+        private String customer;
+        /**
+         * 快递 100 授权 key
+         */
+        @NotEmpty(message = "快递 100 授权 Key 配置项不能为空")
+        private String key;
+
+    }
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/ExpressQueryClient.java

@@ -0,0 +1,24 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core;
+
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryRespDTO;
+
+import java.util.List;
+
+// TODO @jason：可以改成 ExpressClient，未来可能还对接别的接口噢
+/**
+ * 快递查询客户端
+ *
+ * @author jason
+ */
+public interface ExpressQueryClient {
+
+    /**
+     * 快递实时查询
+     *
+     * @param reqDTO 查询请求参数
+     */
+    // TODO @jason：可以改成 getExpressTrackList。返回字段可以参考 https://doc.youzanyun.com/detail/API/0/5 响应的 data
+    List<ExpressQueryRespDTO> realTimeQuery(ExpressQueryReqDTO reqDTO);
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/ExpressQueryProvider.java

@@ -0,0 +1,22 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core;
+
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryRespDTO;
+
+import java.util.List;
+
+/**
+ * 快递查询服务商
+ *
+ * @author jason
+ */
+public interface ExpressQueryProvider {
+
+    /**
+     * 快递实时查询
+     *
+     * @param reqDTO 查询请求参数
+     */
+    List<ExpressQueryRespDTO> realTimeQueryExpress(ExpressQueryReqDTO reqDTO);
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/ExpressQueryProviderEnum.java

@@ -0,0 +1,33 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core;
+
+import lombok.Getter;
+
+/**
+ * 快递查询服务商枚举
+ *
+ * @author jason
+ */
+@Getter
+
+public enum ExpressQueryProviderEnum {
+
+    KD_NIAO("kd-niao", "快递鸟"),
+    KD_100("kd-100", "快递100");
+
+    /**
+     * 快递服务商唯一编码
+     */
+    private final String code;
+
+    /**
+     * 快递服务商名称
+     */
+    private final String name;
+
+    // TODO @jaosn：@AllArgsConstructor 可以替代哈
+    ExpressQueryProviderEnum(String code, String name) {
+        this.code = code;
+        this.name = name;
+    }
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/ExpressQueryProviderFactory.java

@@ -0,0 +1,19 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core;
+
+/**
+ * 快递服务商工厂，用于创建和缓存快递服务商服务
+ *
+ * @author jason
+ */
+public interface ExpressQueryProviderFactory {
+
+    /**
+     * 通过枚举获取快递查询服务商
+     *
+     * 如果不存在，就创建一个对应的快递查询服务商
+     *
+     * @param queryProviderEnum 快递服务商枚举
+     */
+    ExpressQueryProvider getOrCreateExpressQueryProvider(ExpressQueryProviderEnum queryProviderEnum);
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/convert/ExpressQueryConvert.java

@@ -0,0 +1,27 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.convert;
+
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryRespDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kd100.Kd100ExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kd100.Kd100ExpressQueryRespDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kdniao.KdNiaoExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kdniao.KdNiaoExpressQueryRespDTO;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+import java.util.List;
+
+@Mapper
+public interface ExpressQueryConvert {
+
+    ExpressQueryConvert INSTANCE = Mappers.getMapper(ExpressQueryConvert.class);
+
+    List<ExpressQueryRespDTO> convertList(List<KdNiaoExpressQueryRespDTO.ExpressTrack> expressTrackList);
+
+    List<ExpressQueryRespDTO> convertList2(List<Kd100ExpressQueryRespDTO.ExpressTrack> expressTrackList);
+
+    KdNiaoExpressQueryReqDTO convert(ExpressQueryReqDTO dto);
+
+    Kd100ExpressQueryReqDTO convert2(ExpressQueryReqDTO dto);
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/dto/ExpressQueryReqDTO.java

@@ -0,0 +1,32 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.dto;
+
+import cn.iocoder.yudao.module.trade.dal.dataobject.delivery.DeliveryExpressDO;
+import lombok.Data;
+
+/**
+ * 快递查询 Req DTO
+ *
+ * @author jason
+ */
+@Data
+public class ExpressQueryReqDTO {
+
+    /**
+     * 快递公司编码
+     *
+     * 对应 {@link DeliveryExpressDO#getCode()}
+     */
+    // TODO @jaosn：要不改成 expressCode；项目里使用这个哈
+    private String expressCompanyCode;
+
+    /**
+     * 发货快递单号
+     */
+    private String logisticsNo;
+
+    /**
+     * 收、寄件人的电话号码
+     */
+    private String phone;
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/dto/ExpressQueryRespDTO.java

@@ -0,0 +1,24 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.dto;
+
+import lombok.Data;
+
+/**
+ * 快递查询 Resp DTO
+ *
+ * @author jason
+ */
+@Data
+public class ExpressQueryRespDTO {
+
+    // TODO @jason：LocalDateTime
+    /**
+     * 发生时间
+     */
+    private String time;
+    // TODO @jason：其它字段可能要补充下
+    /**
+     * 快递状态
+     */
+    private String state;
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/dto/provider/kd100/Kd100ExpressQueryReqDTO.java

@@ -0,0 +1,49 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kd100;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * 快递 100 快递查询 Req DTO
+ *
+ * @author jason
+ */
+@Data
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class Kd100ExpressQueryReqDTO {
+
+    // TODO @jaosn：要不改成 expressCode；项目里使用这个哈
+    /**
+     * 快递公司编码
+     */
+    @JsonProperty("com")
+    private String expressCompanyCode;
+
+    /**
+     * 快递单号
+     */
+    @JsonProperty("num")
+    private String logisticsNo;
+
+    /**
+     * 收、寄件人的电话号码
+     */
+    private String phone;
+    /**
+     * 出发地城市
+     */
+    private String from;
+    /**
+     * 目的地城市，到达目的地后会加大监控频率
+     */
+    private String to;
+
+    /**
+     * 返回结果排序
+     *
+     * desc 降序（默认）, asc 升序
+     */
+    private String order;
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/dto/provider/kd100/Kd100ExpressQueryRespDTO.java

@@ -0,0 +1,59 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kd100;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 快递 100 实时快递查询 Resp DTO 参见  <a href="https://api.kuaidi100.com/document/5f0ffb5ebc8da837cbd8aefc">快递 100 文档</a>
+ *
+ * @author jason
+ */
+@Data
+public class Kd100ExpressQueryRespDTO {
+
+    /**
+     * 快递公司编码
+     */
+    @JsonProperty("com")
+    private String expressCompanyCode;
+    /**
+     * 快递单号
+     */
+    @JsonProperty("nu")
+    private String logisticsNo;
+    /**
+     * 快递单当前状态
+     */
+    private String state;
+
+    /**
+     * 查询结果
+     *
+     * 失败返回 "false"
+     */
+    private String result;
+    /**
+     * 查询结果失败时的错误信息
+     */
+    private String message;
+
+    @JsonProperty("data")
+    private List<ExpressTrack> tracks;
+
+    @Data
+    public static class ExpressTrack {
+        /**
+         * 轨迹发生时间
+         */
+        @JsonProperty("time")
+        private String time;
+        /**
+         * 轨迹描述
+         */
+        @JsonProperty("context")
+        private String state;
+    }
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/dto/provider/kdniao/KdNiaoExpressQueryReqDTO.java

@@ -0,0 +1,33 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kdniao;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * 快递鸟快递查询 Req DTO
+ *
+ * @author jason
+ */
+@Data
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class KdNiaoExpressQueryReqDTO {
+
+    // TODO @jaosn：要不改成 expressCode；项目里使用这个哈
+    /**
+     * 快递公司编码
+     */
+    @JsonProperty("ShipperCode")
+    private String expressCompanyCode;
+    /**
+     * 快递单号
+     */
+    @JsonProperty("LogisticCode")
+    private String logisticsNo;
+    /**
+     * 订单编号
+     */
+    @JsonProperty("OrderCode")
+    private String orderNo;
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/dto/provider/kdniao/KdNiaoExpressQueryRespDTO.java

@@ -0,0 +1,75 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kdniao;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 快递鸟快递查询 Resp DTO 参见  <a href="https://www.yuque.com/kdnjishuzhichi/dfcrg1/wugo6k">快递鸟接口文档</a>
+ *
+ * @author jason
+ */
+@Data
+public class KdNiaoExpressQueryRespDTO {
+
+    /**
+     * 快递公司编码
+     */
+    @JsonProperty("ShipperCode")
+    private String expressCompanyCode;
+
+    /**
+     * 快递单号
+     */
+    @JsonProperty("LogisticCode")
+    private String logisticsNo;
+
+    /**
+     * 订单编号
+     */
+    @JsonProperty("OrderCode")
+    private String orderNo;
+
+    @JsonProperty("EBusinessID")
+    private String businessId;
+    @JsonProperty("State")
+    private String state;
+    /**
+     * 成功与否
+     */
+    @JsonProperty("Success")
+    private Boolean success;
+    /**
+     * 失败原因
+     */
+    @JsonProperty("Reason")
+    private String reason;
+
+    @JsonProperty("Traces")
+    private List<ExpressTrack> tracks;
+
+    @Data
+    public static class ExpressTrack {
+        /**
+         * 轨迹发生时间
+         */
+        @JsonProperty("AcceptTime")
+        private String time;
+        /**
+         * 轨迹描述
+         */
+        @JsonProperty("AcceptStation")
+        private String state;
+    }
+
+//    {
+//        "EBusinessID": "1237100",
+//            "Traces": [],
+//        "State": "0",
+//            "ShipperCode": "STO",
+//            "LogisticCode": "638650888018",
+//            "Success": true,
+//            "Reason": "暂无轨迹信息"
+//    }
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/impl/ExpressQueryClientImpl.java

@@ -0,0 +1,65 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.impl;
+
+import cn.hutool.core.lang.Assert;
+import cn.iocoder.yudao.module.trade.framework.delivery.config.TradeExpressQueryProperties;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryClient;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProvider;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProviderEnum;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProviderFactory;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryRespDTO;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.util.List;
+
+import static cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProviderEnum.KD_NIAO;
+
+// TODO @jason：可以把整体包结构调整下；参考 sms client 的方式；
+// + config
+// + core
+//      client
+//         + dto
+//         + impl：里面可以放 kdniaoclient、kd100client
+//         ExpressClient
+//         ExpressClientFactory: 通过它直接获取默认和创建默认的 Client
+//      enums
+/**
+ * 快递查询客户端实现
+ *
+ * @author jason
+ */
+@Component
+@Slf4j
+public class ExpressQueryClientImpl implements ExpressQueryClient  {
+
+    @Resource
+    private ExpressQueryProviderFactory expressQueryProviderFactory;
+    @Resource
+    private TradeExpressQueryProperties tradeExpressQueryProperties;
+
+    private ExpressQueryProvider expressQueryProvider;
+
+    @PostConstruct
+    private void init() {
+        // 如果未设置，默认使用快递鸟
+        ExpressQueryProviderEnum queryProvider = tradeExpressQueryProperties.getExpressQueryProvider();
+        if (queryProvider == null) {
+            queryProvider = KD_NIAO;
+        }
+        // 创建客户端
+        expressQueryProvider = expressQueryProviderFactory.getOrCreateExpressQueryProvider(queryProvider);
+        if (expressQueryProvider == null) {
+            log.error("获取创建快递查询服务商{}失败，请检查相关配置", queryProvider);
+        }
+        Assert.notNull(expressQueryProvider, "快递查询服务商不能为空");
+    }
+
+    @Override
+    public List<ExpressQueryRespDTO> realTimeQuery(ExpressQueryReqDTO reqDTO) {
+        return expressQueryProvider.realTimeQueryExpress(reqDTO);
+    }
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/impl/ExpressQueryProviderFactoryImpl.java

@@ -0,0 +1,48 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.impl;
+
+import cn.iocoder.yudao.module.trade.framework.delivery.config.TradeExpressQueryProperties;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProvider;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProviderEnum;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProviderFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+import javax.annotation.Resource;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * // TODO @jason：注释不全
+ * @author jason
+ */
+@Component
+public class ExpressQueryProviderFactoryImpl implements ExpressQueryProviderFactory {
+
+    private final Map<ExpressQueryProviderEnum, ExpressQueryProvider> providerMap = new ConcurrentHashMap<>(8);
+
+    @Resource
+    private TradeExpressQueryProperties tradeExpressQueryProperties;
+    @Resource
+    private RestTemplate restTemplate;
+
+    @Override
+    public ExpressQueryProvider getOrCreateExpressQueryProvider(ExpressQueryProviderEnum queryProviderEnum) {
+        return providerMap.computeIfAbsent(queryProviderEnum,
+                provider -> createExpressQueryProvider(provider, tradeExpressQueryProperties));
+    }
+
+    private ExpressQueryProvider createExpressQueryProvider(ExpressQueryProviderEnum queryProviderEnum,
+                                                            TradeExpressQueryProperties tradeExpressQueryProperties) {
+        // TODO @jason：是不是直接 return 就好啦，更简洁一点
+        ExpressQueryProvider result = null;
+        switch (queryProviderEnum) {
+            case KD_NIAO:
+                result = new KdNiaoExpressQueryProvider(restTemplate, tradeExpressQueryProperties.getKdNiao());
+                break;
+            case KD_100:
+                result = new Kd100ExpressQueryProvider(restTemplate, tradeExpressQueryProperties.getKd100());
+                break;
+        }
+        return result;
+    }
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/impl/Kd100ExpressQueryProvider.java

@@ -0,0 +1,115 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.impl;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.HexUtil;
+import cn.hutool.crypto.digest.DigestUtil;
+import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
+import cn.iocoder.yudao.module.trade.framework.delivery.config.TradeExpressQueryProperties;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProvider;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryRespDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kd100.Kd100ExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kd100.Kd100ExpressQueryRespDTO;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.*;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
+
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.module.trade.enums.ErrorCodeConstants.EXPRESS_API_QUERY_ERROR;
+import static cn.iocoder.yudao.module.trade.enums.ErrorCodeConstants.EXPRESS_API_QUERY_FAILED;
+import static cn.iocoder.yudao.module.trade.framework.delivery.core.convert.ExpressQueryConvert.INSTANCE;
+
+// TODO @jason：可以参考 KdNiaoExpressQueryProvider 建议改改哈
+/**
+ * 快递 100 服务商
+ *
+ * @author jason
+ */
+@Slf4j
+public class Kd100ExpressQueryProvider implements ExpressQueryProvider {
+
+    private static final String REAL_TIME_QUERY_URL = "https://poll.kuaidi100.com/poll/query.do";
+
+    private final RestTemplate restTemplate;
+    private final TradeExpressQueryProperties.Kd100Config config;
+
+    public Kd100ExpressQueryProvider(RestTemplate restTemplate, TradeExpressQueryProperties.Kd100Config config) {
+        this.restTemplate = restTemplate;
+        this.config = config;
+    }
+
+    @Override
+    public List<ExpressQueryRespDTO> realTimeQueryExpress(ExpressQueryReqDTO reqDTO) {
+        // 发起查询
+        Kd100ExpressQueryReqDTO kd100ReqParam = INSTANCE.convert2(reqDTO);
+        kd100ReqParam.setExpressCompanyCode(kd100ReqParam.getExpressCompanyCode().toLowerCase()); // 快递公司编码需要转成小写
+        Kd100ExpressQueryRespDTO respDTO = sendExpressQueryReq(REAL_TIME_QUERY_URL, kd100ReqParam,
+                Kd100ExpressQueryRespDTO.class);
+        log.debug("[realTimeQueryExpress][快递 100 接口 查询接口返回 {}]", respDTO);
+        // 处理结果
+        if (Objects.equals("false", respDTO.getResult())) {
+            log.error("[realTimeQueryExpress][快递 100 接口 返回失败 {}]", respDTO.getMessage());
+            throw exception(EXPRESS_API_QUERY_FAILED, respDTO.getMessage());
+        // TODO @json：else 可以不用写哈；
+        } else {
+            // TODO @jason：convertList2 如果空，应该返回 list 了；
+            if (CollUtil.isNotEmpty(respDTO.getTracks())) {
+                return INSTANCE.convertList2(respDTO.getTracks());
+            } else {
+                return Collections.emptyList();
+            }
+        }
+    }
+
+    /**
+     * 发送快递 100 实时快递查询请求，可以作为通用快递 100 通用请求接口。 目前没有其它场景需要使用。暂时放这里
+     *
+     * @param url 请求 url
+     * @param req 对应请求的请求参数
+     * @param respClass 对应请求的响应 class
+     * @param <Req> 每个请求的请求结构 Req DTO
+     * @param <Resp> 每个请求的响应结构 Resp DTO
+     */
+    // TODO @jason：可以改成 request，发起请求哈；
+    private <Req, Resp> Resp sendExpressQueryReq(String url, Req req, Class<Resp> respClass) {
+        // 请求头
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
+        // 生成签名
+        String param = JsonUtils.toJsonString(req);
+        String sign = generateReqSign(param, config.getKey(), config.getCustomer());
+        // 请求体
+        MultiValueMap<String, String> requestBody = new LinkedMultiValueMap<>();
+        requestBody.add("customer", config.getCustomer());
+        requestBody.add("sign", sign);
+        requestBody.add("param", param);
+        log.debug("[sendExpressQueryReq][快递 100 接口的请求参数: {}]", requestBody);
+        // 发送请求
+        HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(requestBody, headers);
+        // TODO @jason：可以使用 restTemplate 的 post 方法哇？
+        ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class);
+        log.debug("[sendExpressQueryReq][快递 100 接口响应结果 {}]", responseEntity);
+
+        // 处理响应
+        // TODO @jason：if return 原则；if (!responseEntity.getStatusCode().is2xxSuccessful()) 抛出异常；接着处理成功的
+        if (responseEntity.getStatusCode().is2xxSuccessful()) {
+            String response = responseEntity.getBody();
+            return JsonUtils.parseObject(response, respClass);
+        } else {
+            throw exception(EXPRESS_API_QUERY_ERROR);
+        }
+    }
+
+    private String generateReqSign(String param, String key, String customer) {
+        String plainText = String.format("%s%s%s", param, key, customer);
+        // TODO @jason：DigestUtil.md5Hex(plainText);
+        return HexUtil.encodeHexStr(DigestUtil.md5(plainText), false);
+    }
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/framework/delivery/core/impl/KdNiaoExpressQueryProvider.java

@@ -0,0 +1,125 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.impl;
+
+import cn.hutool.core.codec.Base64;
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.net.URLEncodeUtil;
+import cn.hutool.crypto.digest.DigestUtil;
+import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
+import cn.iocoder.yudao.module.trade.framework.delivery.config.TradeExpressQueryProperties;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.ExpressQueryProvider;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryRespDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kdniao.KdNiaoExpressQueryReqDTO;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.provider.kdniao.KdNiaoExpressQueryRespDTO;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.*;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Collections;
+import java.util.List;
+
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.module.trade.enums.ErrorCodeConstants.EXPRESS_API_QUERY_FAILED;
+import static cn.iocoder.yudao.module.trade.enums.ErrorCodeConstants.EXPRESS_API_QUERY_ERROR;
+import static cn.iocoder.yudao.module.trade.framework.delivery.core.convert.ExpressQueryConvert.INSTANCE;
+
+/**
+ * 快递鸟服务商
+ *
+ * @author jason
+ */
+@Slf4j
+public class KdNiaoExpressQueryProvider implements ExpressQueryProvider {
+
+    private static final String REAL_TIME_QUERY_URL = "https://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx";
+
+    /**
+     * 快递鸟即时查询免费版 RequestType
+     */
+    private static final String REAL_TIME_FREE_REQ_TYPE = "1002";
+
+    private final RestTemplate restTemplate;
+    private final TradeExpressQueryProperties.KdNiaoConfig config;
+
+    // TODO @jason：可以改成 lombok 哈
+    public KdNiaoExpressQueryProvider(RestTemplate restTemplate, TradeExpressQueryProperties.KdNiaoConfig config) {
+        this.restTemplate = restTemplate;
+        this.config = config;
+    }
+
+    /**
+     * 快递鸟即时查询免费版本
+     *
+     * @see <a href="https://www.yuque.com/kdnjishuzhichi/dfcrg1/wugo6k">快递鸟接口文档</a>
+     * @param reqDTO 查询请求参数
+     */
+    @Override
+    public List<ExpressQueryRespDTO> realTimeQueryExpress(ExpressQueryReqDTO reqDTO) {
+        KdNiaoExpressQueryReqDTO kdNiaoReqData = INSTANCE.convert(reqDTO);
+        // 快递公司编码需要转成大写
+        kdNiaoReqData.setExpressCompanyCode(reqDTO.getExpressCompanyCode().toUpperCase());
+        KdNiaoExpressQueryRespDTO respDTO = sendKdNiaoApiRequest(REAL_TIME_QUERY_URL, REAL_TIME_FREE_REQ_TYPE,
+                kdNiaoReqData, KdNiaoExpressQueryRespDTO.class);
+        log.debug("[realTimeQueryExpress][快递鸟即时查询接口返回 {}]", respDTO);
+        if(!respDTO.getSuccess()){
+            throw exception(EXPRESS_API_QUERY_FAILED, respDTO.getReason());
+        }else{
+            if (CollUtil.isNotEmpty(respDTO.getTracks())) {
+                return INSTANCE.convertList(respDTO.getTracks());
+            }else{
+                return Collections.emptyList();
+            }
+        }
+    }
+
+    /**
+     * 快递鸟 通用的 API 请求, 暂时没有其他应用场景， 暂时放这里
+     * @param url 请求 url
+     * @param requestType 对应的请求指令 (快递鸟的RequestType)
+     * @param req  对应请求的请求参数
+     * @param respClass 对应请求的响应 class
+     * @param <Req> 每个请求的请求结构 Req DTO
+     * @param <Resp> 每个请求的响应结构 Resp DTO
+     */
+    private  <Req, Resp> Resp sendKdNiaoApiRequest(String url, String requestType, Req req,
+                                                   Class<Resp> respClass){
+        // 请求头
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
+        // 请求体
+        String reqData = JsonUtils.toJsonString(req);
+        String dataSign = generateDataSign(reqData, config.getApiKey());
+        MultiValueMap<String, String> requestBody = new LinkedMultiValueMap<>();
+        requestBody.add("RequestData", reqData);
+        requestBody.add("DataType", "2");
+        requestBody.add("EBusinessID", config.getBusinessId());
+        requestBody.add("DataSign", dataSign);
+        requestBody.add("RequestType", requestType);
+        log.debug("[sendKdNiaoApiRequest][快递鸟接口 RequestType : {}, 的请求参数 {}]", requestType, requestBody);
+
+        // 发送请求
+        HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(requestBody, headers);
+        ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class);
+        log.debug("快递鸟接口 RequestType : {}, 的响应结果 {}", requestType,  responseEntity);
+        // 处理响应
+        if (responseEntity.getStatusCode().is2xxSuccessful()) {
+            String response = responseEntity.getBody();
+            return JsonUtils.parseObject(response, respClass);
+        } else {
+            throw exception(EXPRESS_API_QUERY_ERROR);
+        }
+    }
+
+    /**
+     * 快递鸟生成请求签名 参见 <a href="https://www.yuque.com/kdnjishuzhichi/dfcrg1/zes04h">签名说明</a>
+     * @param reqData 请求实体
+     * @param apiKey  api Key
+     */
+    private String generateDataSign(String reqData, String apiKey) {
+        String plainText = String.format("%s%s", reqData, apiKey);
+        return URLEncodeUtil.encode(Base64.encode(DigestUtil.md5Hex(plainText)));
+    }
+
+}

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/delivery/DeliveryExpressTemplateService.java

@@ -75,7 +75,7 @@ public interface DeliveryExpressTemplateService {
 
     /**
      * 校验快递运费模板
-     * <p>
+     *
      * 如果校验不通过，抛出 {@link cn.iocoder.yudao.framework.common.exception.ServiceException} 异常
      *
      * @param templateId 模板编号
@@ -83,6 +83,7 @@ public interface DeliveryExpressTemplateService {
      */
     DeliveryExpressTemplateDO validateDeliveryExpressTemplate(Long templateId);
 
+    // TODO @jason：可以把 spuIds 改成传递 ids 么？价格计算那，在 TradePriceCalculateRespBO 冗余好 templateId 字段。目的是，减少重复的查询
     /**
      * 基于指定的 SPU 编号数组和收件人地址区域编号. 获取匹配运费模板
      *

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/delivery/DeliveryExpressTemplateServiceImpl.java

@@ -242,10 +242,9 @@ public class DeliveryExpressTemplateServiceImpl implements DeliveryExpressTempla
             if (spu == null) {
                 return;
             }
+            // TODO @jason：避免循环查询；最好类似 expressTemplateMapper.selectBatchIds(spuMap.keySet()); 批量查询，内存组合；
             SpuDeliveryExpressTemplateRespBO bo = new SpuDeliveryExpressTemplateRespBO()
                     .setChargeMode(item.getChargeMode())
-                    // TODO @jason：是不是只要查询到一个，就不用查询下一个了；TemplateCharge 和 TemplateFree
-                    //  @芋艿 包邮的优先级> 费用的优先级 所以两个都要查询
                     .setTemplateCharge(findMatchExpressTemplateCharge(item.getId(), areaId))
                     .setTemplateFree(findMatchExpressTemplateFree(item.getId(), areaId));
             result.put(spu.getId(), bo);

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/delivery/bo/SpuDeliveryExpressTemplateRespBO.java

@@ -18,6 +18,8 @@ public class SpuDeliveryExpressTemplateRespBO {
      */
     private Integer chargeMode;
 
+    // TODO @jaosn：可以把 DeliveryExpressTemplateChargeBO 和 DeliveryExpressTemplateFreeBO 搞成内嵌的类。这样简洁一点
+
     /**
      * 运费模板快递运费设置
      */

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/price/bo/TradePriceCalculateRespBO.java

@@ -164,16 +164,7 @@ public class TradePriceCalculateRespBO {
          */
         private Integer payPrice;
 
-        /**
-         * 商品重量，单位：kg 千克
-         */
-        private Double weight;
-        /**
-         * 商品体积，单位：m^3 平米
-         */
-        private Double volume;
-
-        // ========== 商品信息 ==========
+        // ========== 商品 SPU 信息 ==========
         /**
          * 商品名
          */
@@ -189,6 +180,16 @@ public class TradePriceCalculateRespBO {
          */
         private Long categoryId;
 
+        // ========== 商品 SKU 信息 ==========
+        /**
+         * 商品重量，单位：kg 千克
+         */
+        private Double weight;
+        /**
+         * 商品体积，单位：m^3 平米
+         */
+        private Double volume;
+
         /**
          * 商品属性数组
          */

yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/price/calculator/TradeDeliveryPriceCalculator.java

@@ -62,7 +62,7 @@ public class TradeDeliveryPriceCalculator implements TradePriceCalculator {
                 deliveryExpressTemplateService.getExpressTemplateMapBySpuIdsAndArea(spuIds, address.getAreaId());
         // 3. 计算配送费用
         if (CollUtil.isEmpty(spuExpressTemplateMap)) {
-            log.error("找不到商品 SPU ID {}, area Id {} ,对应的运费模板", spuIds, address.getAreaId());
+            log.error("[calculate][找不到商品 spuId{} areaId{} 对应的运费模板]", spuIds, address.getAreaId());
             throw exception(PRODUCT_EXPRESS_TEMPLATE_NOT_FOUND);
         }
         calculateDeliveryPrice(selectedItem, spuExpressTemplateMap, result);
@@ -170,7 +170,8 @@ public class TradeDeliveryPriceCalculator implements TradePriceCalculator {
      */
     private void divideDeliveryPrice(int deliveryPrice, List<OrderItem> orderItems) {
         // TODO @jason：分摊的话，是不是要按照比例呀？重量、价格、数量等等,
-        //  按比例是不是有点复杂。后面看看是否需要
+        //  按比例是不是有点复杂。后面看看是否需要；
+        // TODO 可以看看别的项目怎么搞的哈。
         int dividePrice = deliveryPrice / orderItems.size();
         for (OrderItem item : orderItems) {
             // 更新快递运费
@@ -207,6 +208,7 @@ public class TradeDeliveryPriceCalculator implements TradePriceCalculator {
                 // freeCount 是不是应该是 double ??
                 // TODO @jason：要不配置的时候，把它的单位和商品对齐？到底是 kg、还是斤
                 // TODO @芋艿 目前 包邮 件数/重量/体积 都用的是这个字段
+                // TODO @jason：那要不快递模版也改成 kg？这样是不是就不用 double ？
                 if (totalWeight >= templateFree.getFreeCount()
                         && totalPrice >= templateFree.getFreePrice()) {
                     return true;

yudao-module-mall/yudao-module-trade-biz/src/test/java/cn/iocoder/yudao/module/trade/framework/delivery/core/impl/Kd100ExpressQueryProviderTest.java

@@ -0,0 +1,56 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.impl;
+
+import cn.iocoder.yudao.framework.common.exception.ServiceException;
+import cn.iocoder.yudao.module.trade.framework.delivery.config.TradeExpressQueryProperties;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryReqDTO;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.autoconfigure.web.client.RestTemplateAutoConfiguration;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.web.client.RestTemplateBuilder;
+import org.springframework.context.annotation.Import;
+import org.springframework.test.context.ActiveProfiles;
+
+import javax.annotation.Resource;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+/**
+ * @author jason
+ */
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE, classes = Kd100ExpressQueryProviderTest.Application.class)
+@ActiveProfiles("trade-delivery-query") // 设置使用 trade-delivery-query 配置文件
+public class Kd100ExpressQueryProviderTest {
+    @Resource
+    private RestTemplateBuilder builder;
+    @Resource
+    private TradeExpressQueryProperties expressQueryProperties;
+
+    private Kd100ExpressQueryProvider kd100ExpressQueryProvider;
+
+    @BeforeEach
+    public void init(){
+        kd100ExpressQueryProvider = new Kd100ExpressQueryProvider(builder.build(),expressQueryProperties.getKd100());
+    }
+    @Test
+    @Disabled("需要 授权 key. 暂时忽略")
+    void testRealTimeQueryExpressFailed() {
+        ServiceException t =  assertThrows(ServiceException.class, () -> {
+            ExpressQueryReqDTO reqDTO = new ExpressQueryReqDTO();
+            reqDTO.setExpressCompanyCode("yto");
+            reqDTO.setLogisticsNo("YT9383342193097");
+            kd100ExpressQueryProvider.realTimeQueryExpress(reqDTO);
+        });
+        assertEquals(1011003007, t.getCode());
+    }
+
+    @Import({
+            RestTemplateAutoConfiguration.class
+    })
+    @EnableConfigurationProperties(TradeExpressQueryProperties.class)
+    public static class Application {
+    }
+}

yudao-module-mall/yudao-module-trade-biz/src/test/java/cn/iocoder/yudao/module/trade/framework/delivery/core/impl/KdNiaoExpressQueryProviderTest.java

@@ -0,0 +1,55 @@
+package cn.iocoder.yudao.module.trade.framework.delivery.core.impl;
+
+import cn.iocoder.yudao.framework.common.exception.ServiceException;
+import cn.iocoder.yudao.module.trade.framework.delivery.config.TradeExpressQueryProperties;
+import cn.iocoder.yudao.module.trade.framework.delivery.core.dto.ExpressQueryReqDTO;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.autoconfigure.web.client.RestTemplateAutoConfiguration;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.web.client.RestTemplateBuilder;
+import org.springframework.context.annotation.Import;
+import org.springframework.test.context.ActiveProfiles;
+
+import javax.annotation.Resource;
+
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+// TODO @芋艿：单测最后 review
+/**
+ * @author jason
+ */
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE, classes = KdNiaoExpressQueryProviderTest.Application.class)
+@ActiveProfiles("trade-delivery-query") // 设置使用 trade-delivery-query 配置文件 TODO @jason：可以直接写到 application-unit-test.yaml 配置文件里
+public class KdNiaoExpressQueryProviderTest {
+    @Resource
+    private RestTemplateBuilder builder;
+    @Resource
+    private TradeExpressQueryProperties expressQueryProperties;
+
+    private KdNiaoExpressQueryProvider kdNiaoExpressQueryProvider;
+
+    @BeforeEach
+    public void init(){
+        kdNiaoExpressQueryProvider = new KdNiaoExpressQueryProvider(builder.build(),expressQueryProperties.getKdNiao());
+    }
+    @Test
+    @Disabled("需要 授权 key. 暂时忽略")
+    void testRealTimeQueryExpressFailed() {
+        assertThrows(ServiceException.class,() ->{
+            ExpressQueryReqDTO reqDTO = new ExpressQueryReqDTO();
+            reqDTO.setExpressCompanyCode("yy");
+            reqDTO.setLogisticsNo("YT9383342193097");
+            kdNiaoExpressQueryProvider.realTimeQueryExpress(reqDTO);
+        });
+    }
+
+    @Import({
+            RestTemplateAutoConfiguration.class
+    })
+    @EnableConfigurationProperties(TradeExpressQueryProperties.class)
+    public static class Application {
+    }
+}

yudao-module-mall/yudao-module-trade-biz/src/test/resources/application-trade-delivery-query.yaml

@@ -0,0 +1,18 @@
+spring:
+  main:
+    lazy-initialization: true # 开启懒加载，加快速度
+    banner-mode: off # 单元测试，禁用 Banner
+
+--- #################### 交易快递查询相关配置 ####################
+
+yudao:
+  trade:
+    express:
+      query:
+        express-query-provider: kd_niao
+        kd-niao:
+          api-key: xxx
+          business-id: xxxxxxxx
+        kd100:
+          customer: xxxx
+          key: xxxxx