'1'

twzd-admin/src/main/java/com/miaxis/app/controller/wx/WxNotifyController.java

@@ -285,7 +285,7 @@ public class WxNotifyController {
         WxMessageTemplate messageTemplate = new WxMessageTemplate();
         messageTemplate.setTouser(userInfo.getOpenid());
         messageTemplate.setTemplate_id("d1P87FFAAos_sHteTCA-slkFJesE8xkoDsRImVa58jc");
-        messageTemplate.setUrl("https://open.weixin.qq.com/connect/oauth2/authorize?appid=wx67ca1b8c9816ef28&redirect_uri=http://jpcj-h5.zzxcx.net&response_type=code&scope=snsapi_userinfo&state=LOGIN#wechat_redirect");
+        messageTemplate.setUrl("https://jpcj-h5.zzxcx.net");
         WxGzhMini wxGzhMini = new WxGzhMini();
         messageTemplate.setMiniprogram(wxGzhMini);
 

twzd-admin/src/test/java/com/miaxis/test/NormalTest.java

@@ -1,20 +1,26 @@
 package com.miaxis.test;
 
 import com.miaxis.TwzdApplication;
+import com.miaxis.wx.service.impl.WxGzhServiceImpl;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.ActiveProfiles;
 import org.springframework.test.context.junit4.SpringRunner;
 
-//@ActiveProfiles("prod")
+import javax.annotation.Resource;
+
+@ActiveProfiles("prod")
 @SpringBootTest(classes = TwzdApplication.class)
 @RunWith(SpringRunner.class)
 public class NormalTest {
 
 
+    @Resource
+    WxGzhServiceImpl wxGzhService;
     @Test
     public void test1() throws Exception {
-
+        wxGzhService.handlePublicMsg(null);
     }
 
 

twzd-service/src/main/java/com/miaxis/extension/domain/WxExtensionIncome.java

@@ -38,7 +38,7 @@ public class WxExtensionIncome extends BaseBusinessEntity {
     private String sourceOpenid;
 
     @TableField("hierarchy")
-    @ApiModelProperty(value = "层级，1:一级 ,2:二级（受益人 相对于收益来源人 层级关系）")
+    @ApiModelProperty(value = "层级，1:一级 ,2:二级（受益人 相对于收益来源人 层级关系） 3:销售")
     private String hierarchy;
 
     @TableField("percentage")

twzd-service/src/main/java/com/miaxis/extension/service/impl/WxExtensionIncomeServiceImpl.java

@@ -2,7 +2,6 @@ package com.miaxis.extension.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.miaxis.common.core.domain.Response;
 import com.miaxis.common.core.domain.entity.SysDictData;
 import com.miaxis.extension.domain.WxExtensionIncome;
 import com.miaxis.extension.mapper.WxExtensionIncomeMapper;
@@ -61,6 +60,9 @@ public class WxExtensionIncomeServiceImpl extends ServiceImpl<WxExtensionIncomeM
     @Override
     public void addExtensionIncomeBySourceId(String outTradeNo, String openid, Integer total) {
 
+
+
+
         //查找一二级绑定关系
         WxSpreadRelation oneRelation = wxSpreadRelationService.getOne(new QueryWrapper<WxSpreadRelation>().eq("openid", openid));
         if (oneRelation == null){
@@ -84,9 +86,8 @@ public class WxExtensionIncomeServiceImpl extends ServiceImpl<WxExtensionIncomeM
                 income.setProfitPrice((total*Integer.parseInt(d.getDictValue()))/100);
                 extensionIncomes.add(income);
             }
-
-            if (twoRelation != null){
-                if ("二级".equals(d.getDictLabel())){
+            if ("二级".equals(d.getDictLabel())){
+                if (twoRelation != null){
                     WxExtensionIncome income = new WxExtensionIncome();
                     income.setOutTradeNo(outTradeNo);
                     income.setBeneficiaryOpenid(twoRelation.getParentOpenid());
@@ -97,12 +98,35 @@ public class WxExtensionIncomeServiceImpl extends ServiceImpl<WxExtensionIncomeM
                     extensionIncomes.add(income);
                 }
             }
+
+            if ("销售".equals(d.getDictLabel())){
+                if (twoRelation != null){
+                    //销售提成
+                    List<WxSpreadRelation> wxSpreadRelationList = wxSpreadRelationService.getWxSpreadRelationList(twoRelation.getParentOpenid());
+                    if (!wxSpreadRelationList.isEmpty()){
+                        wxSpreadRelationList.stream().forEach(o->{
+                            if (o.getSaleType() > 0){
+                                WxExtensionIncome income = new WxExtensionIncome();
+                                income.setOutTradeNo(outTradeNo);
+                                income.setBeneficiaryOpenid(twoRelation.getParentOpenid());
+                                income.setSourceOpenid(openid);
+                                income.setHierarchy("3");
+                                income.setPercentage(Integer.parseInt(d.getDictValue()));
+                                income.setProfitPrice((total*Integer.parseInt(d.getDictValue()))/100);
+                                extensionIncomes.add(income);
+                            }
+                        });
+                    }
+                }
+            }
         });
 
         //保存分成收益信息
         this.saveBatch(extensionIncomes);
     }
 
+
+
     /**
      * 查询收益列表
      * @param openid openid

twzd-service/src/main/java/com/miaxis/spread/domain/WxSpreadRelation.java

@@ -36,4 +36,9 @@ public class WxSpreadRelation extends BaseBusinessEntity {
     @TableField("status")
     @ApiModelProperty(value = "状态  0：有效(默认)、1：失效 （伪删除）")
     private String status;
+
+    /** 销售类型 */
+    @TableField(exist = false)
+    @ApiModelProperty(value = "销售类型0- 非销售1- 个人销售2- 团队销售" )
+    private Integer saleType;
 }

twzd-service/src/main/java/com/miaxis/spread/mapper/WxSpreadRelationMapper.java

@@ -3,6 +3,8 @@ package com.miaxis.spread.mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.miaxis.spread.domain.WxSpreadRelation;
 
+import java.util.List;
+
 /**
  * wx推广关系Mapper接口
  * @author wwl
@@ -10,4 +12,5 @@ import com.miaxis.spread.domain.WxSpreadRelation;
  * @date 2021/10/29 9:41
  */
 public interface WxSpreadRelationMapper extends BaseMapper<WxSpreadRelation> {
+    List<WxSpreadRelation> getWxSpreadRelationList(String openid);
 }

twzd-service/src/main/java/com/miaxis/spread/service/IWxSpreadRelationService.java

@@ -1,11 +1,11 @@
 package com.miaxis.spread.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.miaxis.common.core.domain.Response;
 import com.miaxis.spread.domain.WxSpreadRelation;
 import com.miaxis.spread.vo.WxSpreadRelationVo;
 
 import java.util.ArrayList;
+import java.util.List;
 
 /**
  * wx推广关系Service接口
@@ -22,4 +22,5 @@ public interface IWxSpreadRelationService extends IService<WxSpreadRelation> {
      */
     ArrayList<WxSpreadRelationVo> spreadRelationList(String openid);
 
+    List<WxSpreadRelation> getWxSpreadRelationList(String openid);
 }

twzd-service/src/main/java/com/miaxis/spread/service/impl/WxSpreadRelationServiceImpl.java

@@ -1,7 +1,6 @@
 package com.miaxis.spread.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.miaxis.common.core.domain.Response;
 import com.miaxis.common.core.domain.entity.UserInfo;
 import com.miaxis.spread.domain.WxSpreadRelation;
 import com.miaxis.spread.mapper.WxSpreadRelationMapper;
@@ -57,4 +56,9 @@ public class WxSpreadRelationServiceImpl extends ServiceImpl<WxSpreadRelationMap
         return relationVos;
     }
 
+    @Override
+    public List<WxSpreadRelation> getWxSpreadRelationList(String openid) {
+        return wxSpreadRelationMapper.getWxSpreadRelationList(openid);
+    }
+
 }

twzd-service/src/main/java/com/miaxis/wx/service/impl/WxGzhServiceImpl.java

@@ -1,11 +1,9 @@
 package com.miaxis.wx.service.impl;
 
-import cn.hutool.json.XML;
 import com.alibaba.fastjson.JSONObject;
 import com.miaxis.common.constant.Constants;
 import com.miaxis.common.core.domain.entity.UserInfo;
 import com.miaxis.common.utils.StringUtils;
-import com.miaxis.common.utils.http.HttpUtils;
 import com.miaxis.common.utils.wx.MessageUtil;
 import com.miaxis.feign.service.IWxSendService;
 import com.miaxis.system.service.ISysUserService;
@@ -15,7 +13,6 @@ import com.miaxis.wx.service.IWxMessageEvenService;
 import com.qcloud.cos.COSClient;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.io.IOUtils;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
@@ -90,10 +87,15 @@ public class WxGzhServiceImpl implements IWxGzhService {
     public String handlePublicMsg(HttpServletRequest request) {
         try {
             log.info("1....");
-            cn.hutool.json.JSONObject decryptMap = XML.toJSONObject(IOUtils.toString(request.getInputStream()));
-            cn.hutool.json.JSONObject jsonObjectData = decryptMap.getJSONObject("xml");
+//            cn.hutool.json.JSONObject decryptMap = XML.toJSONObject(IOUtils.toString(request.getInputStream()));
+//            cn.hutool.json.JSONObject jsonObjectData = decryptMap.getJSONObject("xml");
+
+
+            cn.hutool.json.JSONObject jsonObjectData = new cn.hutool.json.JSONObject("{\"CreateTime\":1639474955,\"EventKey\":\"https://jpcj-h5.zzxcx.net\",\"ToUserName\":\"gh_628da25a95e5\",\"MsgType\":\"event\",\"MenuId\":442656773,\"Event\":\"VIEW\",\"FromUserName\":\"ovKTX50v7OAEPI_ERofpUvrNQCJU\"}");
             log.info("2-----jsonObjectData------"+jsonObjectData);
 
+
+
             //开发者微信号
             String toUserName = jsonObjectData.getStr("ToUserName");
             //发送方帐号（一个OpenID）
@@ -153,7 +155,7 @@ public class WxGzhServiceImpl implements IWxGzhService {
                 } else if (MessageUtil.MESSAGE_SCAN.equals(event)) { // 已关注扫描二维码事件
                     log.info("3.2...");
                     return MessageUtil.initText(fromUserName, toUserName, "已关注扫描二维码事件");
-                    
+
                 } else if (MessageUtil.MESSAGE_LOCATION.equals(event)) { // 上报地理位置事件
                     // todo 处理上报地理位置事件
 

twzd-service/src/main/java/com/miaxis/wx/service/impl/WxMessageEvenServiceImpl.java

@@ -1,13 +1,11 @@
 package com.miaxis.wx.service.impl;
 
-import cn.hutool.core.date.DateField;
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.img.ImgUtil;
 import cn.hutool.core.io.FileUtil;
 import cn.hutool.extra.qrcode.QrCodeUtil;
 import cn.hutool.extra.qrcode.QrConfig;
-import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.miaxis.common.constant.Constants;
@@ -259,7 +257,7 @@ public class WxMessageEvenServiceImpl implements IWxMessageEvenService {
         WxMessageTemplate messageTemplate = new WxMessageTemplate();
         messageTemplate.setTouser(openid);
         messageTemplate.setTemplate_id("P4nKRB6L3dmhBjEj1VeE0gr9yC11Z0uBTAuu-XKmIjs");
-        messageTemplate.setUrl("https://open.weixin.qq.com/connect/oauth2/authorize?appid=wx67ca1b8c9816ef28&redirect_uri=http://jpcj-h5.zzxcx.net/myBranch&response_type=code&scope=snsapi_userinfo&state=LOGIN#wechat_redirect");
+        messageTemplate.setUrl("https://jpcj-h5.zzxcx.net/myBranch");
         WxGzhMini wxGzhMini = new WxGzhMini();
         messageTemplate.setMiniprogram(wxGzhMini);
 

twzd-service/src/main/resources/mapper/spread/WxSpreadRelationMapper.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.miaxis.spread.mapper.WxSpreadRelationMapper">
+<select id="getWxSpreadRelationList" resultType="com.miaxis.spread.domain.WxSpreadRelation">
+select * from wx_spread_relation
+where
+FIND_IN_SET(openid,getParents(#{openid})) and openid != #{openid}
+</select>
+
+
+</mapper>