feat: 实现微信小店带货助手相关接口

weixin-java-channel/src/main/java/me/chanjar/weixin/channel/api/WxChannelService.java

@@ -182,4 +182,11 @@ public interface WxChannelService extends BaseWxChannelService {
    */
   WxChannelLiveDashboardService getLiveDashboardService();
 
+  /**
+   * 微信小店-带货助手服务
+   *
+   * @return 带货助手服务
+   */
+  WxTalentService getTalentService();
+
 }

weixin-java-channel/src/main/java/me/chanjar/weixin/channel/api/WxTalentService.java

@@ -0,0 +1,56 @@
+package me.chanjar.weixin.channel.api;
+
+import me.chanjar.weixin.channel.bean.talent.TalentOrderDetailParam;
+import me.chanjar.weixin.channel.bean.talent.TalentOrderDetailResponse;
+import me.chanjar.weixin.channel.bean.talent.TalentOrderListParam;
+import me.chanjar.weixin.channel.bean.talent.TalentOrderListResponse;
+import me.chanjar.weixin.channel.bean.talent.TalentWindowProductDetailParam;
+import me.chanjar.weixin.channel.bean.talent.TalentWindowProductDetailResponse;
+import me.chanjar.weixin.channel.bean.talent.TalentWindowProductListParam;
+import me.chanjar.weixin.channel.bean.talent.TalentWindowProductListResponse;
+import me.chanjar.weixin.common.error.WxErrorException;
+
+/**
+ * 微信小店-带货助手服务接口
+ *
+ * @author <a href="https://github.com/features/copilot">GitHub Copilot</a>
+ */
+public interface WxTalentService {
+
+  /**
+   * <a href="https://developers.weixin.qq.com/doc/store/talent/openapi/order/api_get_order_list.html">获取佣金单列表</a>
+   *
+   * @param param 查询参数
+   * @return 佣金单列表
+   * @throws WxErrorException 接口调用异常
+   */
+  TalentOrderListResponse getOrderList(TalentOrderListParam param) throws WxErrorException;
+
+  /**
+   * <a href="https://developers.weixin.qq.com/doc/store/talent/openapi/order/api_get_order_detail.html">获取佣金单详情</a>
+   *
+   * @param param 查询参数
+   * @return 佣金单详情
+   * @throws WxErrorException 接口调用异常
+   */
+  TalentOrderDetailResponse getOrderDetail(TalentOrderDetailParam param) throws WxErrorException;
+
+  /**
+   * <a href="https://developers.weixin.qq.com/doc/store/talent/openapi/window/api_get_product_list.html">获取达人橱窗商品列表</a>
+   *
+   * @param param 查询参数
+   * @return 橱窗商品列表
+   * @throws WxErrorException 接口调用异常
+   */
+  TalentWindowProductListResponse getWindowProductList(TalentWindowProductListParam param) throws WxErrorException;
+
+  /**
+   * <a href="https://developers.weixin.qq.com/doc/store/talent/openapi/window/api_get_product_detail.html">获取达人橱窗商品详情</a>
+   *
+   * @param param 查询参数
+   * @return 橱窗商品详情
+   * @throws WxErrorException 接口调用异常
+   */
+  TalentWindowProductDetailResponse getWindowProductDetail(TalentWindowProductDetailParam param)
+    throws WxErrorException;
+}

weixin-java-channel/src/main/java/me/chanjar/weixin/channel/api/impl/BaseWxChannelServiceImpl.java

@@ -60,6 +60,7 @@ public abstract class BaseWxChannelServiceImpl<H, P> implements WxChannelService
   private WxChannelVipService vipService = null;
   private WxChannelCompassFinderService compassFinderService = null;
   private WxChannelLiveDashboardService liveDashboardService = null;
+  private WxTalentService talentService = null;
 
   protected WxChannelConfig config;
   private int retrySleepMillis = 1000;
@@ -473,4 +474,12 @@ public synchronized WxChannelLiveDashboardService getLiveDashboardService() {
     return liveDashboardService;
   }
 
+  @Override
+  public synchronized WxTalentService getTalentService() {
+    if (talentService == null) {
+      talentService = new WxTalentServiceImpl(this);
+    }
+    return talentService;
+  }
+
 }

weixin-java-channel/src/main/java/me/chanjar/weixin/channel/api/impl/WxTalentServiceImpl.java

@@ -0,0 +1,59 @@
+package me.chanjar.weixin.channel.api.impl;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.channel.api.WxTalentService;
+import me.chanjar.weixin.channel.bean.talent.TalentOrderDetailParam;
+import me.chanjar.weixin.channel.bean.talent.TalentOrderDetailResponse;
+import me.chanjar.weixin.channel.bean.talent.TalentOrderListParam;
+import me.chanjar.weixin.channel.bean.talent.TalentOrderListResponse;
+import me.chanjar.weixin.channel.bean.talent.TalentWindowProductDetailParam;
+import me.chanjar.weixin.channel.bean.talent.TalentWindowProductDetailResponse;
+import me.chanjar.weixin.channel.bean.talent.TalentWindowProductListParam;
+import me.chanjar.weixin.channel.bean.talent.TalentWindowProductListResponse;
+import me.chanjar.weixin.channel.util.ResponseUtils;
+import me.chanjar.weixin.common.error.WxErrorException;
+
+import static me.chanjar.weixin.channel.constant.WxChannelApiUrlConstants.Talent.GET_ORDER_DETAIL_URL;
+import static me.chanjar.weixin.channel.constant.WxChannelApiUrlConstants.Talent.GET_ORDER_LIST_URL;
+import static me.chanjar.weixin.channel.constant.WxChannelApiUrlConstants.Talent.GET_WINDOW_PRODUCT_DETAIL_URL;
+import static me.chanjar.weixin.channel.constant.WxChannelApiUrlConstants.Talent.GET_WINDOW_PRODUCT_LIST_URL;
+
+/**
+ * 微信小店-带货助手服务实现
+ *
+ * @author <a href="https://github.com/features/copilot">GitHub Copilot</a>
+ */
+@RequiredArgsConstructor
+@Slf4j
+public class WxTalentServiceImpl implements WxTalentService {
+
+  /** 微信商店服务 */
+  private final BaseWxChannelServiceImpl<?, ?> shopService;
+
+  @Override
+  public TalentOrderListResponse getOrderList(TalentOrderListParam param) throws WxErrorException {
+    String resJson = shopService.post(GET_ORDER_LIST_URL, param);
+    return ResponseUtils.decode(resJson, TalentOrderListResponse.class);
+  }
+
+  @Override
+  public TalentOrderDetailResponse getOrderDetail(TalentOrderDetailParam param) throws WxErrorException {
+    String resJson = shopService.post(GET_ORDER_DETAIL_URL, param);
+    return ResponseUtils.decode(resJson, TalentOrderDetailResponse.class);
+  }
+
+  @Override
+  public TalentWindowProductListResponse getWindowProductList(TalentWindowProductListParam param)
+    throws WxErrorException {
+    String resJson = shopService.post(GET_WINDOW_PRODUCT_LIST_URL, param);
+    return ResponseUtils.decode(resJson, TalentWindowProductListResponse.class);
+  }
+
+  @Override
+  public TalentWindowProductDetailResponse getWindowProductDetail(TalentWindowProductDetailParam param)
+    throws WxErrorException {
+    String resJson = shopService.post(GET_WINDOW_PRODUCT_DETAIL_URL, param);
+    return ResponseUtils.decode(resJson, TalentWindowProductDetailResponse.class);
+  }
+}

weixin-java-channel/src/main/java/me/chanjar/weixin/channel/bean/talent/TalentOrderDetailParam.java

@@ -0,0 +1,32 @@
+package me.chanjar.weixin.channel.bean.talent;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * 带货助手-获取佣金单详情 请求参数
+ *
+ * @author <a href="https://github.com/features/copilot">GitHub Copilot</a>
+ */
+@Data
+@NoArgsConstructor
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class TalentOrderDetailParam implements Serializable {
+
+  private static final long serialVersionUID = 8741285036412736219L;
+
+  /** 订单号，可从获取佣金单列表接口获得 */
+  @JsonProperty("order_id")
+  private String orderId;
+
+  /** 商品skuid，可从获取佣金单列表接口获得 */
+  @JsonProperty("sku_id")
+  private String skuId;
+
+  /** 订单额外参数【在订单列表里面返回的参数回传】 */
+  @JsonProperty("special_id")
+  private String specialId;
+}

weixin-java-channel/src/main/java/me/chanjar/weixin/channel/bean/talent/TalentOrderDetailResponse.java

@@ -0,0 +1,203 @@
+package me.chanjar.weixin.channel.bean.talent;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import me.chanjar.weixin.channel.bean.base.WxChannelBaseResponse;
+
+/**
+ * 带货助手-获取佣金单详情 响应
+ *
+ * @author <a href="https://github.com/features/copilot">GitHub Copilot</a>
+ */
+@Data
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+public class TalentOrderDetailResponse extends WxChannelBaseResponse {
+
+  private static final long serialVersionUID = 2174806923145876312L;
+
+  /** 订单基础信息 */
+  @JsonProperty("base_info")
+  private BaseInfo baseInfo;
+
+  /** 订单佣金信息 */
+  @JsonProperty("commission_info")
+  private CommissionInfo commissionInfo;
+
+  /** 下单通道信息 */
+  @JsonProperty("channel_info")
+  private ChannelInfo channelInfo;
+
+  /** 内容推广推客机构信息 */
+  @JsonProperty("promotion_head_supplier_info")
+  private PromotionHeadSupplierInfo promotionHeadSupplierInfo;
+
+  /** 商品信息 */
+  @JsonProperty("product_info")
+  private ProductInfo productInfo;
+
+  /** 订单基础信息 */
+  @Data
+  @NoArgsConstructor
+  public static class BaseInfo implements Serializable {
+
+    private static final long serialVersionUID = 6382947162830498251L;
+
+    /** 订单id */
+    @JsonProperty("order_id")
+    private String orderId;
+
+    /** 商品spuid */
+    @JsonProperty("spu_id")
+    private String spuId;
+
+    /** 商品skuid */
+    @JsonProperty("sku_id")
+    private String skuId;
+
+    /** 特殊id【针对本地生活】 */
+    @JsonProperty("special_id")
+    private String specialId;
+
+    /**
+     * 订单状态：1=待支付, 2=待发货, 3=已发货, 4=已收货, 5=售后中, 6=已完成, 7=已取消, 8=已退款, 9=部分退款, 10=待使用
+     */
+    @JsonProperty("order_status")
+    private Integer orderStatus;
+
+    /** 实际支付金额【单位：分】 */
+    @JsonProperty("actual_payment")
+    private String actualPayment;
+
+    /** 订单创建时间 */
+    @JsonProperty("order_create_time")
+    private Long orderCreateTime;
+
+    /** 订单更新时间 */
+    @JsonProperty("order_update_time")
+    private Long orderUpdateTime;
+
+    /** 下单用户 */
+    @JsonProperty("buyer_info")
+    private BuyerInfo buyerInfo;
+
+    /** 订单支付时间 */
+    @JsonProperty("order_pay_time")
+    private Long orderPayTime;
+
+    /** 订单的分佣基数【单位：分】 */
+    @JsonProperty("settle_payment")
+    private String settlePayment;
+  }
+
+  /** 下单用户信息 */
+  @Data
+  @NoArgsConstructor
+  public static class BuyerInfo implements Serializable {
+
+    private static final long serialVersionUID = 4729638451027364819L;
+
+    /** 下单用户的openid */
+    @JsonProperty("open_id")
+    private String openId;
+
+    /** 下单用户的unionid */
+    @JsonProperty("union_id")
+    private String unionId;
+  }
+
+  /** 订单佣金信息 */
+  @Data
+  @NoArgsConstructor
+  public static class CommissionInfo implements Serializable {
+
+    private static final long serialVersionUID = -3819264037182640581L;
+
+    /** 佣金单状态：1=待结算, 2=已结算, 3=取消结算, 4=结算异常 */
+    @JsonProperty("state")
+    private Integer state;
+
+    /** 佣金比例 */
+    @JsonProperty("ratio")
+    private String ratio;
+
+    /** 预期结算时间 */
+    @JsonProperty("expect_settle_time")
+    private Long expectSettleTime;
+
+    /** 预期结算金额 */
+    @JsonProperty("expect_settlement")
+    private String expectSettlement;
+
+    /** 实际结算时间 */
+    @JsonProperty("actual_settle_time")
+    private Long actualSettleTime;
+
+    /** 实际结算金额 */
+    @JsonProperty("actual_settlement")
+    private String actualSettlement;
+  }
+
+  /** 下单通道信息 */
+  @Data
+  @NoArgsConstructor
+  public static class ChannelInfo implements Serializable {
+
+    private static final long serialVersionUID = 7364918204736159023L;
+
+    /** 渠道类型：1=视频号, 2=公众号 */
+    @JsonProperty("channel_type")
+    private Integer channelType;
+
+    /** 渠道id */
+    @JsonProperty("channel_id")
+    private String channelId;
+
+    /** 渠道名称 */
+    @JsonProperty("channel_name")
+    private String channelName;
+  }
+
+  /** 内容推广推客机构信息 */
+  @Data
+  @NoArgsConstructor
+  public static class PromotionHeadSupplierInfo implements Serializable {
+
+    private static final long serialVersionUID = 1826374950183647291L;
+
+    /** 机构id */
+    @JsonProperty("id")
+    private String id;
+
+    /** 机构名称 */
+    @JsonProperty("name")
+    private String name;
+
+    /** 佣金单比例 */
+    @JsonProperty("ratio")
+    private String ratio;
+
+    /** 佣金 */
+    @JsonProperty("fee")
+    private String fee;
+  }
+
+  /** 商品信息 */
+  @Data
+  @NoArgsConstructor
+  public static class ProductInfo implements Serializable {
+
+    private static final long serialVersionUID = -4920183645872916370L;
+
+    /** 商品的标题 */
+    @JsonProperty("title")
+    private String title;
+
+    /** 商品的头图 */
+    @JsonProperty("thumb_img")
+    private String thumbImg;
+  }
+}