🆕 #3279【小程序】新增小程序推广员相关接口

weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/api/WxMaPromotionService.java

@@ -0,0 +1,125 @@
+package cn.binarywang.wx.miniapp.api;
+
+import cn.binarywang.wx.miniapp.bean.promoter.request.*;
+import cn.binarywang.wx.miniapp.bean.promoter.response.*;
+import me.chanjar.weixin.common.error.WxErrorException;
+
+/**
+ * 小程序推广员
+ *
+ * @author zhuangzibin
+ */
+public interface WxMaPromotionService {
+
+ /**
+ * 管理角色接口-新增角色
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionAddRoleResponse
+ */
+ WxMaPromotionAddRoleResponse addRole(WxMaPromotionAddRoleRequest request) throws WxErrorException;
+
+ /**
+ * 管理角色接口-查询角色
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionGetRoleResponse
+ */
+ WxMaPromotionGetRoleResponse getRole(WxMaPromotionGetRoleRequest request) throws WxErrorException;
+
+ /**
+ * 管理角色接口-修改角色
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionUpdateRoleResponse
+ */
+ WxMaPromotionUpdateRoleResponse updateRole(WxMaPromoterUpdateRoleRequest request) throws WxErrorException;
+
+ /**
+ * 管理推广员接口-声明推广员身份
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionAddPromoterResponse
+ */
+ WxMaPromotionAddPromoterResponse addPromoter(WxMaPromotionAddPromoterRequest request) throws WxErrorException;
+
+ /**
+ * 管理推广员接口-查询推广员身份
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionGetPromoterResponse
+ */
+ WxMaPromotionGetPromoterResponse getPromoter(WxMaPromotionGetPromoterRequest request) throws WxErrorException;
+
+ /**
+ * 管理推广员接口-修改推广员身份
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionUpdatePromoterResponse
+ */
+ WxMaPromotionUpdatePromoterResponse updatePromoter(WxMaPromotionUpdatePromoterRequest request) throws WxErrorException;
+
+ /**
+ * 邀请推广员-获取推广员邀请素材
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionGetInvitationMaterialResponse
+ */
+ WxMaPromotionGetInvitationMaterialResponse getInvitationMaterial(WxMaPromotionGetInvitationMaterialRequest request) throws WxErrorException;
+
+ /**
+ * 推广员消息管理接口-群发消息
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionSendMsgResponse
+ */
+ WxMaPromotionSendMsgResponse sendMsg(WxMaPromotionSendMsgRequest request) throws WxErrorException;
+
+ /**
+ * 推广员消息管理接口-单发消息
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionSingleSendMsgResponse
+ */
+ WxMaPromotionSingleSendMsgResponse singleSendMsg(WxMaPromotionSingleSendMsgRequest request) throws WxErrorException;
+
+ /**
+ * 推广员消息管理接口-查询送达结果
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionGetMsgResponse
+ */
+ WxMaPromotionGetMsgResponse getMsg(WxMaPromotionGetMsgRequest request) throws WxErrorException;
+
+ /**
+ * 推广员消息管理接口-分析点击效果
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionGetMsgClickDataResponse
+ */
+ WxMaPromotionGetMsgClickDataResponse getMsgClickData(WxMaPromotionGetMsgClickDataRequest request) throws WxErrorException;
+
+ /**
+ * 推广数据接口-生成推广素材
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionGetShareMaterialResponse
+ */
+ WxMaPromotionGetShareMaterialResponse getShareMaterial(WxMaPromotionGetShareMaterialRequest request) throws WxErrorException;
+
+ /**
+ * 推广数据接口-分析触达效果
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionGetRelationResponse
+ */
+ WxMaPromotionGetRelationResponse getRelation(WxMaPromotionGetRelationRequest request) throws WxErrorException;
+
+ /**
+ * 推广数据接口-查询推广订单
+ *
+ * @param request 请求参数
+ * @return WxMaPromotionGetOrderResponse
+ */
+ WxMaPromotionGetOrderResponse getOrder(WxMaPromotionGetOrderRequest request) throws WxErrorException;
+}

weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/api/WxMaService.java

@@ -547,4 +547,11 @@ public interface WxMaService extends WxService {
  */
  WxMaXPayService getWxMaXPayService();
  WxMaExpressDeliveryReturnService getWxMaExpressDeliveryReturnService();
+
+ /**
+ * 小程序推广员
+ *
+ * @return WxMaPromotionService
+ */
+ WxMaPromotionService getWxMaPromotionService();
 }

weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/api/impl/BaseWxMaServiceImpl.java

@@ -93,6 +93,7 @@ public abstract class BaseWxMaServiceImpl<H, P> implements WxMaService, RequestH
  private final WxMaVodService wxMaVodService = new WxMaVodServiceImpl(this);
  private final WxMaXPayService wxMaXPayService = new WxMaXPayServiceImpl(this);
  private final WxMaExpressDeliveryReturnService wxMaExpressDeliveryReturnService = new WxMaExpressDeliveryReturnServiceImpl(this);
+ private final WxMaPromotionService wxMaPromotionService = new WxMaPromotionServiceImpl(this);
 
  private Map<String, WxMaConfig> configMap = new HashMap<>();
  private int retrySleepMillis = 1000;
@@ -694,4 +695,9 @@ public WxMaXPayService getWxMaXPayService() {
  public WxMaExpressDeliveryReturnService getWxMaExpressDeliveryReturnService() {
  return this.wxMaExpressDeliveryReturnService;
  }
+
+ @Override
+ public WxMaPromotionService getWxMaPromotionService() {
+ return this.wxMaPromotionService;
+ }
 }

weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/api/impl/WxMaPromotionServiceImpl.java

@@ -0,0 +1,196 @@
+package cn.binarywang.wx.miniapp.api.impl;
+
+import cn.binarywang.wx.miniapp.api.WxMaPromotionService;
+import cn.binarywang.wx.miniapp.api.WxMaService;
+import cn.binarywang.wx.miniapp.bean.promoter.request.*;
+import cn.binarywang.wx.miniapp.bean.promoter.response.*;
+import cn.binarywang.wx.miniapp.json.WxMaGsonBuilder;
+import com.google.gson.JsonObject;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.enums.WxType;
+import me.chanjar.weixin.common.error.WxError;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.common.util.json.GsonParser;
+
+import static cn.binarywang.wx.miniapp.constant.WxMaApiUrlConstants.Promotion.*;
+import static me.chanjar.weixin.common.api.WxConsts.ERR_CODE;
+
+/**
+ * @author zhuangzibin
+ */
+@RequiredArgsConstructor
+@Slf4j
+public class WxMaPromotionServiceImpl implements WxMaPromotionService {
+
+ private final WxMaService wxMaService;
+
+ private final static Integer ERR_CODE_OF_EMPTY_LIST = 103006;
+
+ @Override
+ public WxMaPromotionAddRoleResponse addRole(WxMaPromotionAddRoleRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_ADD_ROLE, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionAddRoleResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionGetRoleResponse getRole(WxMaPromotionGetRoleRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_GET_ROLE, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionGetRoleResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionUpdateRoleResponse updateRole(WxMaPromoterUpdateRoleRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_UPDATE_ROLE, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionUpdateRoleResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionAddPromoterResponse addPromoter(WxMaPromotionAddPromoterRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_ADD_PROMOTER, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionAddPromoterResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionGetPromoterResponse getPromoter(WxMaPromotionGetPromoterRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_GET_PROMOTER, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0 || jsonObject.get(ERR_CODE).getAsInt() != ERR_CODE_OF_EMPTY_LIST) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionGetPromoterResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionUpdatePromoterResponse updatePromoter(WxMaPromotionUpdatePromoterRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_UPDATE_PROMOTER, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionUpdatePromoterResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionGetInvitationMaterialResponse getInvitationMaterial(WxMaPromotionGetInvitationMaterialRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_GET_INVITATION_MATERIAL, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionGetInvitationMaterialResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionSendMsgResponse sendMsg(WxMaPromotionSendMsgRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_SEND_MSG, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionSendMsgResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionSingleSendMsgResponse singleSendMsg(WxMaPromotionSingleSendMsgRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_SINGLE_SEND_MSG, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionSingleSendMsgResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionGetMsgResponse getMsg(WxMaPromotionGetMsgRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_GET_MSG, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionGetMsgResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionGetMsgClickDataResponse getMsgClickData(WxMaPromotionGetMsgClickDataRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_GET_MSG_CLICK_DATA, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionGetMsgClickDataResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionGetShareMaterialResponse getShareMaterial(WxMaPromotionGetShareMaterialRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_GET_SHARE_MATERIAL, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionGetShareMaterialResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionGetRelationResponse getRelation(WxMaPromotionGetRelationRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_GET_RELATION, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0 || jsonObject.get(ERR_CODE).getAsInt() != ERR_CODE_OF_EMPTY_LIST) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionGetRelationResponse.class);
+ }
+
+ @Override
+ public WxMaPromotionGetOrderResponse getOrder(WxMaPromotionGetOrderRequest request) throws WxErrorException {
+ String responseContent = this.wxMaService.post(PROMOTION_GET_ORDER, request);
+ JsonObject jsonObject = GsonParser.parse(responseContent);
+
+ if (jsonObject.get(ERR_CODE).getAsInt() != 0 || jsonObject.get(ERR_CODE).getAsInt() != ERR_CODE_OF_EMPTY_LIST) {
+ throw new WxErrorException(WxError.fromJson(responseContent, WxType.MiniApp));
+ }
+
+ return WxMaGsonBuilder.create().fromJson(responseContent, WxMaPromotionGetOrderResponse.class);
+ }
+}