分佣配置结构调整

yanxuan-wx-store-sharer-biz/src/main/java/com/netease/yanxuan/wx/store/sharer/biz/config/DrmSharerConfig.java

@@ -359,8 +359,8 @@ public class DrmSharerConfig {
                         commissionRatio.longValue());
             }
             // 保存推客商品记录
-            saveSharerProductCommissionInfo(sharerInfo.getOpenId(), newBo.getProductId(),
-                    commissionRatio, SharerProductCommission.UnsetEnum.SET);
+            saveSharerProductCommissionInfo(sharerInfo.getOpenId(), sharerInfo.getSharerAppid(),
+                    newBo.getProductId(), commissionRatio, SharerProductCommission.UnsetEnum.SET);
             isSuccess = true;
         } catch (Exception e) {
             log.error("设置推客的的分佣类型和比例信息失败", e);
@@ -400,7 +400,7 @@ public class DrmSharerConfig {
                         Long.valueOf(oldBo.getProductId()), sharerCommissionRatio.longValue());
             }
             // 保存推客商品记录
-            saveSharerProductCommissionInfo(sharerInfo.getOpenId(), oldBo.getProductId(),
+            saveSharerProductCommissionInfo(sharerInfo.getOpenId(), sharerInfo.getSharerAppid(), oldBo.getProductId(),
                     sharerCommissionRatio, SharerProductCommission.UnsetEnum.UNSET);
             isSuccess = true;
         } catch (Exception e) {
@@ -441,14 +441,10 @@ public class DrmSharerConfig {
      * 保存推客商品分佣金表
      */
     private void saveSharerProductCommissionInfo(String openId,
+                                                 String sharerAppid,
                                                  String productId,
                                                  BigDecimal commissionRatio,
                                                  SharerProductCommission.UnsetEnum unsetEnum) {
-        String sharerAppid = getSharerAppidByOpenId(openId);
-        if (StringUtils.isBlank(sharerAppid)) {
-            log.error("微信用户暂未绑定微信小店，openId={}", openId);
-            return;
-        }
         LambdaQueryWrapper<SharerProductCommission> lqw = Wrappers.lambdaQuery();
         lqw.eq(SharerProductCommission::getOpenId, openId);
         lqw.eq(SharerProductCommission::getProductId, productId);
@@ -458,17 +454,17 @@ public class DrmSharerConfig {
         if (null == sharerProductCommission) {
             sharerProductCommission = new SharerProductCommission();
             sharerProductCommission.setOpenId(openId);
+            sharerProductCommission.setSharerAppid(sharerAppid);
             sharerProductCommission.setProductId(productId);
+            // 微信分佣比例倍数
+            BigDecimal wechatMultiplier = new BigDecimal(WeChatApi.WECHAT_COMMISSION_RATIO_MULTIPLIER);
+            commissionRatio = commissionRatio
+                    .divide(wechatMultiplier)
+                    .setScale(2, RoundingMode.HALF_UP);
+            sharerProductCommission.setCommissionRatio(commissionRatio.toPlainString());
+            sharerProductCommission.setCommissionType(CommissionTypeEnum.PLATFORM.getCode().toString());
             sharerProductCommission.setCreateTime(now);
         }
-        sharerProductCommission.setSharerAppid(sharerAppid);
-        // 微信分佣比例倍数
-        BigDecimal wechatMultiplier = new BigDecimal(WeChatApi.WECHAT_COMMISSION_RATIO_MULTIPLIER);
-        commissionRatio = commissionRatio
-                .divide(wechatMultiplier)
-                .setScale(2, RoundingMode.HALF_UP);
-        sharerProductCommission.setCommissionRatio(commissionRatio.toPlainString());
-        sharerProductCommission.setCommissionType(CommissionTypeEnum.PLATFORM.getCode().toString());
         sharerProductCommission.setUnset(unsetEnum.getCode());
         sharerProductCommission.setUpdateTime(now);
         if (null == sharerProductCommission.getId()) {