feats

src/main/java/com/yunzhi/shigongli/common/CommUtils.java

@@ -1,5 +1,6 @@
 package com.yunzhi.shigongli.common;
 
+import com.yunzhi.shigongli.service.ISysConfigService;
 import com.yunzhi.shigongli.service.ITaHotelAccountService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -12,8 +13,16 @@ public class CommUtils {
     @Autowired
     ITaHotelAccountService iTaHotelAccountService;
 
+    @Autowired
+    ISysConfigService iSysConfigService;
+
     @PostConstruct
     public void init() {
-        iTaHotelAccountService.initSystemAccount();
+        try {
+            iTaHotelAccountService.initSystemAccount();
+            iSysConfigService.initSysConfig();
+        } catch (Exception e) {
+//            e.printStackTrace();
+        }
     }
 }

src/main/java/com/yunzhi/shigongli/common/Constants.java

@@ -40,4 +40,8 @@ public class Constants {
     // 推荐人类型
     public final static String RECOMMEND_SHOP = "shop";     // 商铺
     public final static String RECOMMEND_HOTEL = "hotel";   // 民宿
+
+    // 系统参数
+    public final static String CONF_HOTEL_RECOMMEND_VALID_DAYS = "hotel_recommend_valid_days";      // 民宿推广客户有效时间
+    public final static String CONF_SHOP_RECOMMEND_VALID_DAYS = "shop_recommend_valid_days";        // 商铺推广客户有效时间
 }

src/main/java/com/yunzhi/shigongli/controller/WxMaController.java

@@ -1,21 +1,24 @@
 package com.yunzhi.shigongli.controller;
 
 import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
+import cn.binarywang.wx.miniapp.bean.WxMaPhoneNumberInfo;
+import cn.binarywang.wx.miniapp.bean.WxMaUserInfo;
 import com.yunzhi.shigongli.common.*;
 import com.yunzhi.shigongli.entity.TaMiniappQrcode;
 import com.yunzhi.shigongli.entity.TaPerson;
+import com.yunzhi.shigongli.entity.TaPersonRole;
 import com.yunzhi.shigongli.service.ITaMiniappQrcodeService;
+import com.yunzhi.shigongli.service.ITaPersonRecommenderService;
+import com.yunzhi.shigongli.service.ITaPersonRoleService;
 import com.yunzhi.shigongli.service.ITaPersonService;
+import com.yunzhi.shigongli.vo.WxMaAuthParam;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-import me.chanjar.weixin.common.error.WxErrorException;
+import io.swagger.annotations.ApiParam;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Optional;
+import java.util.*;
 
 
 @Api(tags = "微信小程序")
@@ -32,7 +35,13 @@ public class WxMaController extends BaseController {
     @Autowired
     ITaMiniappQrcodeService miniappQrcodeService;
 
-    @GetMapping("prefetch")
+    @Autowired
+    ITaPersonRecommenderService recommenderService;
+
+    @Autowired
+    ITaPersonRoleService personRoleService;
+
+    @GetMapping("/prefetch")
     @ApiOperation(value="微信预拉取数据", notes = "微信预拉取数据", httpMethod = "GET", response = ResponseBean.class)
     public ResponseBean perfetch(String appid,
                                  String token,
@@ -44,19 +53,13 @@ public class WxMaController extends BaseController {
         WxMaJscode2SessionResult info = wxUtils.getService().getUserService().getSessionInfo(code);
         String openid = info.getOpenid();
 
-        TaPerson taPerson = iTaPersonService.getByOpenid(openid);
-        if (null == taPerson) {
-            taPerson = new TaPerson();
-            taPerson.setOpenid(openid);
-            iTaPersonService.save(taPerson);
-            // 插入过程会有默认字段写入
-            taPerson = iTaPersonService.getById(taPerson.getPersonId());
-        }
+        TaPerson taPerson = iTaPersonService.getByOpenidOrNot(openid);
 
         Map<String, Object> result = new HashMap<>();
-        result.put("person", taPerson);
+        result.put("personId", taPerson.getPersonId());
+        result.put("openid", taPerson.getOpenid());
+        result.put("sessionKey", info.getSessionKey());
 
-        // 如果是通过扫码打开
         if (!StringUtils.isEmpty(query)) {
             Map<String, String> params = StringUtils.parseQueryString(query);
 
@@ -83,116 +86,108 @@ public class WxMaController extends BaseController {
             }
 
             // 如果有推广ID, 比如民宿或者商铺
-            if (StringUtils.isEmpty(taPerson.getRecommender()) && !StringUtils.isEmpty(recommender)) {
-                taPerson.setFromType(fromType);
-                taPerson.setRecommender(recommender);
-                iTaPersonService.setRecommender(taPerson);
-            }
+            if (!StringUtils.isEmpty(recommender)) {
+                if (StringUtils.isEmpty(taPerson.getRecommender())) {
+                    taPerson.setFromType(fromType);
+                    taPerson.setRecommender(recommender);
+                    iTaPersonService.updateById(taPerson);
+                }
 
+                // 写入推荐表
+                try {
+                    recommenderService.addNewRecommender(taPerson.getPersonId(), fromType, recommender);
+                } catch (Exception e) {
+                    e.printStackTrace();;
+                }
+            }
         }
 
+        // 生成 token
+        Map<String, Object> tokenClaims = new HashMap<>();
+        tokenClaims.put("userId", taPerson.getPersonId());
+        tokenClaims.put("miniApp", true);
+        String authToken = JWTUtils.encode(tokenClaims);
+        result.put("token", authToken);
+
         return ResponseBean.success(result);
     }
 
-//    @PostMapping("/login")
-//    @ApiOperation(value="登录", notes = "登录", httpMethod = "POST", response = ResponseBean.class)
-//    public ResponseBean login(@ApiParam("登录参数") @RequestParam String code) throws Exception {
-//        WxMaJscode2SessionResult info = wxUtils.getService().getUserService().getSessionInfo(code);
-//
-//        String openid = info.getOpenid();
-//        TaPerson taPerson = iTaPersonService.getByOpenid(openid);
-//        if (null == taPerson) {
-//            taPerson = new TaPerson();
-//            taPerson.setOpenid(openid);
-//            iTaPersonService.save(taPerson);
-//
-//            TaPersonData taPersonData = new TaPersonData();
-//            taPersonData.setPersonId(taPerson.getPersonId());
-//            iTaPersonDataService.save(taPersonData);
-//        }
-//
-//        // 查询学生
-//        TaStudent taStudent = iTaStudentService.getByPersonId(taPerson.getPersonId());
-//        taPerson.setStudent(taStudent);
-//
-//        Map<String, Object> tokenClaims = new HashMap<>();
-//        tokenClaims.put("userId", taPerson.getPersonId());
-////        tokenClaims.put("sessionKey", info.getSessionKey());
-//        tokenClaims.put("miniApp", true);
-//        String token = JWTUtils.encode(tokenClaims);
-//
-//        Map<String, Object> rtn = new HashMap<>();
-//        rtn.put("person", taPerson);
-//        rtn.put("sessionKey", info.getSessionKey());
-//        rtn.put("token", token);
-//
-//        return ResponseBean.success(rtn);
-//    }
-//
-//    @PutMapping("/auth-user")
-//    @ApiOperation(value="授权头像", notes = "授权头像", httpMethod = "PUT", response = TaPerson.class)
-//    public ResponseBean updateUserInfo(@ApiParam("授权头像的参数") @RequestBody WxMaAuthParam params) throws Exception {
-//        checkAuthParams(params);
-//
-//        // 解密用户信息
-//        WxMaUserInfo userInfo = wxUtils.getService().getUserService().getUserInfo(params.getSessionKey(), params.getEncryptedData(), params.getIv());
-//
-//        TaPerson taPerson = getCurrentPerson();
-//        if (null == taPerson) {
-//            throw new Exception("校验当前人员失败, 请重试");
-//        }
-//
-//        taPerson.setAvatar(userInfo.getAvatarUrl());
-//        taPerson.setNickName(userInfo.getNickName());
-//        taPerson.setSex(Integer.parseInt(userInfo.getGender()));
-//
-//        iTaPersonService.updateById(taPerson);
-//
-//        return ResponseBean.success(taPerson);
-//    }
-//
-//    @ApiOperation(value="授权手机", notes = "授权手机", httpMethod = "PUT", response = TaPerson.class)
-//    @PutMapping("/auth-phone")
-//    public ResponseBean updateUserPhone(@ApiParam("授权手机的参数") @RequestBody WxMaAuthParam params) throws Exception {
-////        checkAuthParams(params);
-//
-//        // 解密
-//        WxMaPhoneNumberInfo phoneNoInfo = wxUtils.getService().getUserService().getPhoneNoInfo(params.getSessionKey(), params.getEncryptedData(), params.getIv());
-//
-//        TaPerson taPerson = getCurrentPerson();
-//        if (null == taPerson) {
-//            throw new Exception("校验当前人员失败, 请重试");
-//        }
-//
-//        taPerson.setPhone(phoneNoInfo.getPhoneNumber());
-//        iTaPersonService.updateById(taPerson);
-//
-//        // 查询学生
-//        TaStudent taStudent = iTaStudentService.getByPhone(taPerson.getPhone());
-//        if (null != taStudent) {
-//            taStudent.setPersonId(taPerson.getPersonId());
-//            iTaStudentService.updateById(taStudent);
-//        }
-//
-//        return ResponseBean.success(taPerson);
-//    }
-//
-//    private void checkAuthParams(WxMaAuthParam params) throws Exception {
-//        String signature = params.getSignature();
-//        String rawData = params.getRawData();
-//        String encryptedData = params.getEncryptedData();
-//        String iv = params.getIv();
-//        String sessionKey = params.getSessionKey();
-//
-//        if (StringUtils.isEmpty(signature) || StringUtils.isEmpty(rawData) || StringUtils.isEmpty(encryptedData) || StringUtils.isEmpty(iv) || StringUtils.isEmpty(sessionKey)) {
-//            throw new Exception("缺失授权参数");
-//        }
-//
-//        boolean isValid = wxUtils.getService().getUserService().checkUserInfo(sessionKey, rawData, signature);
-//        if (!isValid) {
-//            throw new Exception("校验授权参数失败, 请重试");
-//        }
-//
-//        return;
-//    }
+    @PostMapping("/login")
+    @ApiOperation(value="登录", notes = "登录", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean login(@ApiParam("登录参数") @RequestParam String code) throws Exception {
+        WxMaJscode2SessionResult info = wxUtils.getService().getUserService().getSessionInfo(code);
+
+        String openid = info.getOpenid();
+        TaPerson taPerson = iTaPersonService.getByOpenidOrNot(openid);
+
+        // 查询人员角色
+        List<TaPersonRole> roleList = personRoleService.getListByPerson(taPerson.getPersonId());
+
+        Map<String, Object> rtn = new HashMap<>();
+        rtn.put("person", taPerson);
+        rtn.put("personRoleList", roleList);
+        rtn.put("sessionKey", info.getSessionKey());
+
+        return ResponseBean.success(rtn);
+    }
+
+    @PutMapping("/auth-user")
+    @ApiOperation(value="授权头像", notes = "授权头像", httpMethod = "PUT", response = TaPerson.class)
+    public ResponseBean updateUserInfo(@ApiParam("授权头像的参数") @RequestBody WxMaAuthParam params) throws Exception {
+        checkAuthParams(params);
+
+        // 解密用户信息
+        WxMaUserInfo userInfo = wxUtils.getService().getUserService().getUserInfo(params.getSessionKey(), params.getEncryptedData(), params.getIv());
+
+        TaPerson taPerson = getCurrentPerson();
+        if (null == taPerson) {
+            throw new Exception("校验当前人员失败, 请重试");
+        }
+
+        taPerson.setAvatar(userInfo.getAvatarUrl());
+        taPerson.setNickName(userInfo.getNickName());
+        taPerson.setSex(Integer.parseInt(userInfo.getGender()));
+
+        iTaPersonService.updateById(taPerson);
+
+        return ResponseBean.success(taPerson);
+    }
+
+    @ApiOperation(value="授权手机", notes = "授权手机", httpMethod = "PUT", response = TaPerson.class)
+    @PutMapping("/auth-phone")
+    public ResponseBean updateUserPhone(@ApiParam("授权手机的参数") @RequestBody WxMaAuthParam params) throws Exception {
+        checkAuthParams(params);
+
+        // 解密
+        WxMaPhoneNumberInfo phoneNoInfo = wxUtils.getService().getUserService().getPhoneNoInfo(params.getSessionKey(), params.getEncryptedData(), params.getIv());
+
+        TaPerson taPerson = getCurrentPerson();
+        if (null == taPerson) {
+            throw new Exception("校验当前人员失败, 请重试");
+        }
+
+        taPerson.setPhone(phoneNoInfo.getPhoneNumber());
+        iTaPersonService.updateById(taPerson);
+
+        return ResponseBean.success(taPerson);
+    }
+
+    private void checkAuthParams(WxMaAuthParam params) throws Exception {
+        String signature = params.getSignature();
+        String rawData = params.getRawData();
+        String encryptedData = params.getEncryptedData();
+        String iv = params.getIv();
+        String sessionKey = params.getSessionKey();
+
+        if (StringUtils.isEmpty(signature) || StringUtils.isEmpty(rawData) || StringUtils.isEmpty(encryptedData) || StringUtils.isEmpty(iv) || StringUtils.isEmpty(sessionKey)) {
+            throw new Exception("缺失授权参数");
+        }
+
+        boolean isValid = wxUtils.getService().getUserService().checkUserInfo(sessionKey, rawData, signature);
+        if (!isValid) {
+            throw new Exception("校验授权参数失败, 请重试");
+        }
+
+        return;
+    }
 }

src/main/java/com/yunzhi/shigongli/entity/SysConfig.java

@@ -0,0 +1,52 @@
+package com.yunzhi.shigongli.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import io.swagger.models.auth.In;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 登录
+ * </p>
+ *
+ * @author yansen
+ * @since 2021-08-17
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="SysConfig对象", description="系统参数表")
+public class SysConfig implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "配置编码")
+    @TableId(value = "config_code", type = IdType.INPUT)
+    private String configCode;
+
+    @ApiModelProperty(value = "配置名称")
+    private String configName;
+
+    @ApiModelProperty(value = "配置描述")
+    @TableField("`description`")
+    private String description;
+
+    @ApiModelProperty(value = "配置值")
+    private String configValue;
+
+    @ApiModelProperty(value = "状态;1已启用,0未启用")
+    private Boolean status;
+
+    @ApiModelProperty(value = "排序")
+    private Integer sort;
+
+}

src/main/java/com/yunzhi/shigongli/mapper/SysConfigMapper.java

@@ -0,0 +1,18 @@
+package com.yunzhi.shigongli.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yunzhi.shigongli.entity.SysConfig;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 登录 Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2021-08-17
+ */
+@Mapper
+public interface SysConfigMapper extends BaseMapper<SysConfig> {
+
+}

src/main/java/com/yunzhi/shigongli/mapper/TaPersonRoleMapper.java

@@ -0,0 +1,18 @@
+package com.yunzhi.shigongli.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yunzhi.shigongli.entity.TaPersonRole;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 小程序人员表 Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2021-08-17
+ */
+@Mapper
+public interface TaPersonRoleMapper extends BaseMapper<TaPersonRole> {
+
+}

src/main/java/com/yunzhi/shigongli/service/ISysConfigService.java

@@ -0,0 +1,16 @@
+package com.yunzhi.shigongli.service;
+
+
+import com.yunzhi.shigongli.entity.SysConfig;
+
+/**
+ * <p>
+ * 用户登录 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2021-04-15
+ */
+public interface ISysConfigService extends IBaseService<SysConfig> {
+    void initSysConfig() throws Exception;
+}

src/main/java/com/yunzhi/shigongli/service/ITaPersonRecommenderService.java

@@ -13,4 +13,5 @@ import com.yunzhi.shigongli.entity.TaPersonRecommender;
  */
 public interface ITaPersonRecommenderService extends IBaseService<TaPersonRecommender> {
 
+    void addNewRecommender(String personId, String fromType, String recommender) throws Exception;
 }

src/main/java/com/yunzhi/shigongli/service/ITaPersonRoleService.java

@@ -0,0 +1,19 @@
+package com.yunzhi.shigongli.service;
+
+import com.yunzhi.shigongli.entity.TaPersonRole;
+
+import java.util.List;
+
+
+/**
+ * <p>
+ * 小程序人员表 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2021-08-17
+ */
+public interface ITaPersonRoleService extends IBaseService<TaPersonRole> {
+
+    List<TaPersonRole> getListByPerson(String personId);
+}

src/main/java/com/yunzhi/shigongli/service/ITaPersonService.java

@@ -15,5 +15,5 @@ public interface ITaPersonService extends IBaseService<TaPerson> {
 
     TaPerson getByOpenid(String openid);
 
-    void setRecommender(TaPerson taPerson) throws Exception;
+    TaPerson getByOpenidOrNot(String openid);
 }

src/main/java/com/yunzhi/shigongli/service/impl/SysConfigServiceImpl.java

@@ -0,0 +1,57 @@
+package com.yunzhi.shigongli.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.yunzhi.shigongli.common.Constants;
+import com.yunzhi.shigongli.entity.SysConfig;
+import com.yunzhi.shigongli.mapper.SysConfigMapper;
+import com.yunzhi.shigongli.service.ISysConfigService;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * <p>
+ * 用户登录 服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2021-04-15
+ */
+@Service
+public class SysConfigServiceImpl extends BaseServiceImpl<SysConfigMapper, SysConfig> implements ISysConfigService {
+
+    @Async
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void initSysConfig() throws Exception {
+        if (count() > 0) {
+            return;
+        }
+
+        SysConfig config1 = new SysConfig();
+        config1.setConfigCode(Constants.CONF_HOTEL_RECOMMEND_VALID_DAYS);
+        config1.setConfigName("民宿推广客户有效时间");
+        config1.setDescription("单位 天");
+        config1.setConfigValue("365");
+        config1.setStatus(true);
+        config1.setSort(1);
+
+        SysConfig config2 = new SysConfig();
+        config2.setConfigCode(Constants.CONF_SHOP_RECOMMEND_VALID_DAYS);
+        config2.setConfigName("商铺推广客户有效时间");
+        config2.setDescription("单位 天");
+        config2.setConfigValue("12");
+        config2.setStatus(true);
+        config2.setSort(2);
+
+        List<SysConfig> configList = new ArrayList<SysConfig>(){{
+            add(config1);
+            add(config2);
+        }};
+
+        saveBatch(configList);
+    }
+}

src/main/java/com/yunzhi/shigongli/service/impl/TaPersonRecommenderServiceImpl.java

@@ -1,11 +1,19 @@
 package com.yunzhi.shigongli.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.yunzhi.shigongli.common.Constants;
+import com.yunzhi.shigongli.entity.SysConfig;
 import com.yunzhi.shigongli.entity.TaPersonRecommender;
+import com.yunzhi.shigongli.mapper.SysConfigMapper;
 import com.yunzhi.shigongli.mapper.TaPersonRecommenderMapper;
 import com.yunzhi.shigongli.service.ITaPersonRecommenderService;
 
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
+
 /**
  * <p>
  * 用户推广人 服务实现类
@@ -17,4 +25,59 @@ import org.springframework.stereotype.Service;
 @Service
 public class TaPersonRecommenderServiceImpl extends BaseServiceImpl<TaPersonRecommenderMapper, TaPersonRecommender> implements ITaPersonRecommenderService {
 
+    @Autowired
+    SysConfigMapper sysConfigMapper;
+
+    @Autowired
+    TaPersonRecommenderMapper personRecommenderMapper;
+
+    @Async
+    @Override
+    public void addNewRecommender(String personId, String fromType, String recommender) throws Exception {
+        if (isExists(personId, fromType, recommender)) {
+            throw new Exception("当前客户还有未到期的推荐人");
+        }
+
+        // 读取系统配置
+        String configCode = null;
+        if (Constants.RECOMMEND_SHOP.equals(fromType)) {
+            configCode = Constants.CONF_SHOP_RECOMMEND_VALID_DAYS;
+        }
+        if (Constants.RECOMMEND_SHOP.equals(fromType)) {
+            configCode = Constants.CONF_HOTEL_RECOMMEND_VALID_DAYS;
+        }
+
+        SysConfig config = null == configCode ? null : sysConfigMapper.selectById(configCode);
+        Integer validDays = 0;
+        if (null != config && config.getStatus()) {
+            validDays = Integer.valueOf(config.getConfigValue().trim());
+        }
+
+        LocalDateTime now = LocalDateTime.now();
+        LocalDateTime expireDate = now.plusDays(validDays);
+
+        // 生成推广记录
+        TaPersonRecommender personRecommender = new TaPersonRecommender();
+        personRecommender.setPersonId(personId);
+        personRecommender.setFromType(fromType);
+        personRecommender.setRecommender(recommender);
+        personRecommender.setCreateDate(now);
+        personRecommender.setExpireDate(expireDate);
+        personRecommender.setStatus(Constants.STATUS_NORMAL);
+
+        save(personRecommender);
+    }
+
+    private boolean isExists(String personId, String fromType, String recommender) {
+        LocalDateTime now = LocalDateTime.now();
+        LambdaQueryWrapper<TaPersonRecommender> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaPersonRecommender::getPersonId, personId)
+                .eq(TaPersonRecommender::getFromType, fromType)
+                .eq(TaPersonRecommender::getRecommender, recommender)
+                .eq(TaPersonRecommender::getStatus, Constants.STATUS_NORMAL)
+                .gt(TaPersonRecommender::getCreateDate, LocalDateTime.now())
+                .lt(TaPersonRecommender::getExpireDate, now);
+
+        return count(queryWrapper) > 0;
+    }
 }

src/main/java/com/yunzhi/shigongli/service/impl/TaPersonRoleServiceImpl.java

@@ -0,0 +1,29 @@
+package com.yunzhi.shigongli.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.yunzhi.shigongli.entity.TaPersonRole;
+import com.yunzhi.shigongli.mapper.TaPersonRoleMapper;
+import com.yunzhi.shigongli.service.ITaPersonRoleService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 小程序人员表 服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2021-08-17
+ */
+@Service
+public class TaPersonRoleServiceImpl extends BaseServiceImpl<TaPersonRoleMapper, TaPersonRole> implements ITaPersonRoleService {
+
+    @Override
+    public List<TaPersonRole> getListByPerson(String personId) {
+        LambdaQueryWrapper<TaPersonRole> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaPersonRole::getPersonId, personId);
+
+        return list(queryWrapper);
+    }
+}

src/main/java/com/yunzhi/shigongli/service/impl/TaPersonServiceImpl.java

@@ -8,7 +8,6 @@ import com.yunzhi.shigongli.mapper.TaPersonMapper;
 import com.yunzhi.shigongli.service.ITaPersonService;
 
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
 
 /**
  * <p>
@@ -35,12 +34,17 @@ public class TaPersonServiceImpl extends BaseServiceImpl<TaPersonMapper, TaPerso
         return getOne(queryWrapper);
     }
 
-    @Transactional(rollbackFor = Exception.class)
     @Override
-    public void setRecommender(TaPerson taPerson) throws Exception {
-        updateById(taPerson);
-
-        // 生成推广记录
+    public TaPerson getByOpenidOrNot(String openid) {
+        TaPerson taPerson = getByOpenid(openid);
+        if (null == taPerson) {
+            taPerson = new TaPerson();
+            taPerson.setOpenid(openid);
+            save(taPerson);
+            // 插入过程会有默认字段写入
+            taPerson = getById(taPerson.getPersonId());
+        }
 
+        return taPerson;
     }
 }

src/main/resources/application.yml

@@ -12,7 +12,8 @@ interceptor:
     exclude-paths:
       - /admin/login
       - /admin/logout
-      - /ma/login
+      - /wx/prefetch
+      - /wx/login
       - /wxpay/notify/order
       - /swagger-ui/**
       - /swagger-resources/**

src/main/resources/mapper/SysConfigMapper.xml

@@ -0,0 +1,5 @@
+<?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.yunzhi.shigongli.mapper.SysConfigMapper">
+
+</mapper>