feats

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

@@ -1,8 +1,9 @@
 package com.yunzhi.shigongli.common;
 
 import java.io.UnsupportedEncodingException;
+import java.net.URLDecoder;
 import java.net.URLEncoder;
-import java.util.Random;
+import java.util.*;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
@@ -61,6 +62,17 @@ public class StringUtils {
         }
     }
 
+    public static String encodeURIComponent(String str) {
+        String result = urlEncode(str);
+
+        return result.replaceAll("\\+", "%20")
+                .replaceAll("\\%21", "!")
+                .replaceAll("\\%27", "'")
+                .replaceAll("\\%28", "(")
+                .replaceAll("\\%29", ")")
+                .replaceAll("\\%7E", "~");
+    }
+
     public static String humpToLine(String str) {
         if (null == str || "".equals(str)) return "";
 
@@ -117,4 +129,62 @@ public class StringUtils {
         prefix = prefix.substring(0, padLen);
         return prefix + src;
     }
+
+    /**
+     * 解析 QueryString
+     * @param queryStr
+     * @return
+     */
+    public static Map<String, String> parseQueryString(String queryStr) {
+        if (isEmpty(queryStr)) {
+            return null;
+        }
+        Map<String, String> result = new HashMap<String, String>();
+
+        String[] fields = queryStr.split("&");
+        for (String field : fields) {
+            String[] pairs = field.split("=");
+            if (2 != pairs.length) {
+                continue;
+            }
+
+            try {
+                String key = URLDecoder.decode(pairs[0].trim(), "UTF-8");
+                String val = URLDecoder.decode(pairs[1].trim(), "UTF-8");
+
+                result.put(key, val);
+            } catch (UnsupportedEncodingException e) {
+                e.printStackTrace();
+            }
+        }
+
+        return result;
+    }
+
+    /**
+     * Map 转 QueryString
+     * @param params
+     * @return
+     */
+    public static String buildQueryString(Map<String, Object> params) {
+        if (null == params) {
+            return null;
+        }
+
+        List<String> lst = new ArrayList<>();
+        for (Map.Entry<String, Object> entry : params.entrySet()) {
+            String key = StringUtils.urlEncode(entry.getKey());
+            Object o = entry.getValue();
+            if (null == o) {
+                continue;
+            }
+            String val = o.toString();
+            if (StringUtils.isEmpty(val)) {
+                continue;
+            }
+            String queryStr = key + "=" + StringUtils.urlEncode(val);
+            lst.add(queryStr);
+        }
+        return String.join("&", lst);
+    }
 }

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

@@ -2,12 +2,14 @@ package com.yunzhi.shigongli.common;
 
 import cn.binarywang.wx.miniapp.api.WxMaService;
 import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
+import cn.binarywang.wx.miniapp.bean.WxMaCodeLineColor;
 import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
 import com.github.binarywang.wxpay.config.WxPayConfig;
 import com.github.binarywang.wxpay.constant.WxPayConstants;
 import com.github.binarywang.wxpay.service.WxPayService;
 import com.github.binarywang.wxpay.service.impl.WxPayServiceImpl;
 import com.yunzhi.shigongli.config.WeixinConfig;
+import lombok.Data;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -57,4 +59,14 @@ public class WxUtils {
     public WxPayService getPayService() {
         return payService;
     }
+
+    @Data
+    public static class AQrCodeParam {
+        private String scene;
+        private String page;
+        private int width;
+        private boolean autoColor;
+        private WxMaCodeLineColor lineColor;
+        private boolean isHyaline;
+    }
 }

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

@@ -4,7 +4,9 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yunzhi.shigongli.common.BaseController;
+import com.yunzhi.shigongli.common.Constants;
 import com.yunzhi.shigongli.common.ResponseBean;
+import com.yunzhi.shigongli.common.StringUtils;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
@@ -49,14 +51,17 @@ public class TaHotelWorkerController extends BaseController {
     @RequestMapping(value="/admin/taHotelWorker",method= RequestMethod.GET)
     @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
     public ResponseBean taHotelWorkerList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
-									 @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception{
+                                          @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                          @ApiParam("民宿ID") @RequestParam(value ="hotelId", required = false) String hotelId) throws Exception{
 
-		    IPage<TaHotelWorker> pg = new Page<>(pageNum, pageSize);
-            QueryWrapper<TaHotelWorker> queryWrapper = new QueryWrapper<>();
-            queryWrapper.orderByDesc("create_date");
+        IPage<TaHotelWorker> pg = new Page<>(pageNum, pageSize);
+        QueryWrapper<TaHotelWorker> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq(!StringUtils.isEmpty(hotelId), "hotel_id", hotelId);
+        queryWrapper.gt("status", Constants.STATUS_DELETED);
+        queryWrapper.orderByDesc("create_date");
 
-            IPage<TaHotelWorker> result = iTaHotelWorkerService.page(pg, queryWrapper);
-            return ResponseBean.success(result);
+        IPage<TaHotelWorker> result = iTaHotelWorkerService.page(pg, queryWrapper);
+        return ResponseBean.success(result);
     }
 
     /**
@@ -81,7 +86,7 @@ public class TaHotelWorkerController extends BaseController {
      */
     @RequestMapping(value="/admin/taHotelWorker/{id}", method= RequestMethod.DELETE)
     @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
-    public ResponseBean taHotelWorkerDelete(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
+    public ResponseBean taHotelWorkerDelete(@ApiParam("对象ID") @PathVariable String id) throws Exception{
         if(iTaHotelWorkerService.removeLogicById(id)){
             return ResponseBean.success("success");
         }else {
@@ -97,7 +102,7 @@ public class TaHotelWorkerController extends BaseController {
      */
     @RequestMapping(value="/admin/taHotelWorker/{id}",method= RequestMethod.PUT)
     @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
-    public ResponseBean taHotelWorkerUpdate(@ApiParam("对象ID") @PathVariable Integer id,
+    public ResponseBean taHotelWorkerUpdate(@ApiParam("对象ID") @PathVariable String id,
                                         @ApiParam("更新内容") @RequestBody TaHotelWorker taHotelWorker) throws Exception{
 
         if (iTaHotelWorkerService.updateById(taHotelWorker)){
@@ -113,7 +118,7 @@ public class TaHotelWorkerController extends BaseController {
      */
     @RequestMapping(value="/admin/taHotelWorker/{id}",method= RequestMethod.GET)
     @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
-    public ResponseBean taHotelWorkerGet(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
+    public ResponseBean taHotelWorkerGet(@ApiParam("对象ID") @PathVariable String id) throws Exception{
         return ResponseBean.success(iTaHotelWorkerService.getById(id));
     }
 }

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

@@ -66,13 +66,16 @@ public class TaShopController extends BaseController {
      */
     @RequestMapping(value="/admin/taShop",method= RequestMethod.POST)
     @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
-    public ResponseBean taShopAdd(@ApiParam("保存内容") @RequestBody TaShop taShop) throws Exception{
+    public ResponseBean taShopAdd(@ApiParam("保存内容") @RequestBody TaShop taShop) throws Exception {
 
-        if (iTaShopService.save(taShop)){
-            return ResponseBean.success(taShop);
-        }else {
-            return ResponseBean.error("保存失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
+        try {
+            iTaShopService.createNew(taShop);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);
         }
+
+        return ResponseBean.success(taShop);
     }
 
     /**

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

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yunzhi.shigongli.common.BaseController;
+import com.yunzhi.shigongli.common.Constants;
 import com.yunzhi.shigongli.common.ResponseBean;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -52,13 +53,14 @@ public class TaShopPackageController extends BaseController {
                                           @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
                                           @ApiParam("商铺") @RequestParam(value ="shopId") String shopId) throws Exception{
 
-		    IPage<TaShopPackage> pg = new Page<>(pageNum, pageSize);
-            QueryWrapper<TaShopPackage> queryWrapper = new QueryWrapper<>();
+        IPage<TaShopPackage> pg = new Page<>(pageNum, pageSize);
+        QueryWrapper<TaShopPackage> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("shop_id", shopId);
-            queryWrapper.orderByDesc("create_date");
+        queryWrapper.gt("status", Constants.STATUS_DELETED);
+        queryWrapper.orderByDesc("create_date");
 
-            IPage<TaShopPackage> result = iTaShopPackageService.page(pg, queryWrapper);
-            return ResponseBean.success(result);
+        IPage<TaShopPackage> result = iTaShopPackageService.page(pg, queryWrapper);
+        return ResponseBean.success(result);
     }
 
     /**

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

@@ -76,7 +76,7 @@ public class TaShopWorkerController extends BaseController {
      */
     @RequestMapping(value="/admin/taShopWorker/{id}", method= RequestMethod.DELETE)
     @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
-    public ResponseBean taShopWorkerDelete(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
+    public ResponseBean taShopWorkerDelete(@ApiParam("对象ID") @PathVariable String id) throws Exception{
         if(iTaShopWorkerService.removeLogicById(id)){
             return ResponseBean.success("success");
         }else {
@@ -92,7 +92,7 @@ public class TaShopWorkerController extends BaseController {
      */
     @RequestMapping(value="/admin/taShopWorker/{id}",method= RequestMethod.PUT)
     @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
-    public ResponseBean taShopWorkerUpdate(@ApiParam("对象ID") @PathVariable Integer id,
+    public ResponseBean taShopWorkerUpdate(@ApiParam("对象ID") @PathVariable String id,
                                         @ApiParam("更新内容") @RequestBody TaShopWorker taShopWorker) throws Exception{
 
         if (iTaShopWorkerService.updateById(taShopWorker)){
@@ -108,7 +108,7 @@ public class TaShopWorkerController extends BaseController {
      */
     @RequestMapping(value="/admin/taShopWorker/{id}",method= RequestMethod.GET)
     @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
-    public ResponseBean taShopWorkerGet(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
+    public ResponseBean taShopWorkerGet(@ApiParam("对象ID") @PathVariable String id) throws Exception{
         return ResponseBean.success(iTaShopWorkerService.getById(id));
     }
 }

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

@@ -1,15 +1,26 @@
 package com.yunzhi.shigongli.controller;
 
+import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
 import com.yunzhi.shigongli.common.*;
+import com.yunzhi.shigongli.entity.TaMiniappQrcode;
+import com.yunzhi.shigongli.entity.TaPerson;
+import com.yunzhi.shigongli.service.ITaMiniappQrcodeService;
 import com.yunzhi.shigongli.service.ITaPersonService;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import me.chanjar.weixin.common.error.WxErrorException;
 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;
+
 
 @Api(tags = "微信小程序")
 @RestController
-@RequestMapping("/ma")
+@RequestMapping("/wx")
 public class WxMaController extends BaseController {
 
     @Autowired
@@ -18,6 +29,71 @@ public class WxMaController extends BaseController {
     @Autowired
     ITaPersonService iTaPersonService;
 
+    @Autowired
+    ITaMiniappQrcodeService miniappQrcodeService;
+
+    @GetMapping("prefetch")
+    @ApiOperation(value="微信预拉取数据", notes = "微信预拉取数据", httpMethod = "GET", response = ResponseBean.class)
+    public ResponseBean perfetch(String appid,
+                                 String token,
+                                 String code,
+                                 Integer timestamp,
+                                 String path,
+                                 String query,
+                                 String scene) 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);
+            // 插入过程会有默认字段写入
+            taPerson = iTaPersonService.getById(taPerson.getPersonId());
+        }
+
+        Map<String, Object> result = new HashMap<>();
+        result.put("person", taPerson);
+
+        // 如果是通过扫码打开
+        if (!StringUtils.isEmpty(query)) {
+            Map<String, String> params = StringUtils.parseQueryString(query);
+
+            String fromType = params.get("fromType");
+            String recommender = params.get("recommender");
+            String qrCodeId = params.get("scene");
+
+            // 如果是扫码进入
+            if (!StringUtils.isEmpty(qrCodeId)) {
+                TaMiniappQrcode miniappQrcode = miniappQrcodeService.getById(Integer.valueOf(qrCodeId));
+                if (null != miniappQrcode) {
+                    String qrcodeParamStr = miniappQrcode.getScene();
+                    if (!StringUtils.isEmpty(qrcodeParamStr)) {
+                        // 把真正的参数返回
+                        result.put("qrcode", qrcodeParamStr);
+                        // 如果小程序码中有
+                        Map<String, String> qrcodeParams = StringUtils.parseQueryString(qrcodeParamStr);
+                        if (!StringUtils.isEmpty(qrcodeParams.get("id"))) {
+                            fromType = qrcodeParams.get("type");
+                            recommender = qrcodeParams.get("id");
+                        }
+                    }
+                }
+            }
+
+            // 如果有推广ID, 比如民宿或者商铺
+            if (StringUtils.isEmpty(taPerson.getRecommender()) && !StringUtils.isEmpty(recommender)) {
+                taPerson.setFromType(fromType);
+                taPerson.setRecommender(recommender);
+                iTaPersonService.setRecommender(taPerson);
+            }
+
+        }
+
+        return ResponseBean.success(result);
+    }
+
 //    @PostMapping("/login")
 //    @ApiOperation(value="登录", notes = "登录", httpMethod = "POST", response = ResponseBean.class)
 //    public ResponseBean login(@ApiParam("登录参数") @RequestParam String code) throws Exception {

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

@@ -0,0 +1,50 @@
+package com.yunzhi.shigongli.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+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="TaMiniappQrcode 对象", description="小程序码")
+public class TaMiniappQrcode implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "qrID")
+    @TableId(value = "qr_id", type = IdType.AUTO)
+    private Integer qrId;
+
+    @ApiModelProperty(value = "小程序APPID")
+    private String miniappId;
+
+    @ApiModelProperty(value = "图片地址")
+    private String qrImage;
+
+    @ApiModelProperty(value = "页面地址")
+    private String page;
+
+    @ApiModelProperty(value = "页面参数")
+    private String scene;
+
+    @ApiModelProperty(value = "访问时间")
+    private LocalDateTime createDate;
+
+
+}

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

@@ -30,9 +30,6 @@ public class TaPerson implements Serializable {
     @TableId(value = "person_id", type = IdType.UUID)
     private String personId;
 
-    @ApiModelProperty(value = "类型")
-    private String personType;
-
     @ApiModelProperty(value = "openid")
     private String openid;
 

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

@@ -0,0 +1,52 @@
+package com.yunzhi.shigongli.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+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="TaPersonRole对象", description="小程序人员角色表")
+public class TaPersonRole implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "角色序号")
+    @TableId(value = "role_no", type = IdType.AUTO)
+    private Integer roleNo;
+
+    @ApiModelProperty(value = "人员ID")
+    private String personId;
+
+    @ApiModelProperty(value = "用户ID")
+    private String userId;
+
+    @ApiModelProperty(value = "是否管理员")
+    private Integer isManager;
+
+    @ApiModelProperty(value = "映射类型")
+    private String targetType;
+
+    @ApiModelProperty(value = "类型对象ID")
+    private String targetId;
+
+    @ApiModelProperty(value = "创建时间")
+    private LocalDateTime createDate;
+
+}

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

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

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

@@ -0,0 +1,23 @@
+package com.yunzhi.shigongli.service;
+
+
+import com.yunzhi.shigongli.entity.TaMiniappQrcode;
+import com.yunzhi.shigongli.vo.QrCodeParamsVO;
+
+/**
+ * <p>
+ * 访问人次 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2021-08-17
+ */
+public interface ITaMiniappQrcodeService extends IBaseService<TaMiniappQrcode> {
+    /**
+     * 生成小程序码
+     * @param qrCodeParamsVO
+     * @return
+     * @throws Exception
+     */
+    String createQrCode(QrCodeParamsVO qrCodeParamsVO) throws Exception;
+}

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

@@ -13,4 +13,7 @@ import com.yunzhi.shigongli.entity.TaPerson;
  */
 public interface ITaPersonService extends IBaseService<TaPerson> {
 
+    TaPerson getByOpenid(String openid);
+
+    void setRecommender(TaPerson taPerson) throws Exception;
 }

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

@@ -16,4 +16,6 @@ import com.yunzhi.shigongli.vo.ShopListVO;
 public interface ITaShopService extends IBaseService<TaShop> {
 
     IPage<ShopListVO> getPageListBy(IPage<ShopListVO> pg, String shopName, String phone);
+
+    void createNew(TaShop taShop) throws Exception;
 }

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

@@ -0,0 +1,124 @@
+package com.yunzhi.shigongli.service.impl;
+
+import cn.binarywang.wx.miniapp.api.WxMaQrcodeService;
+import cn.binarywang.wx.miniapp.bean.WxMaCodeLineColor;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.yunzhi.shigongli.common.OSSUtils;
+import com.yunzhi.shigongli.common.StringUtils;
+import com.yunzhi.shigongli.common.WxUtils;
+import com.yunzhi.shigongli.entity.TaMiniappQrcode;
+import com.yunzhi.shigongli.mapper.TaMiniappQrcodeMapper;
+import com.yunzhi.shigongli.service.ITaMiniappQrcodeService;
+import com.yunzhi.shigongli.vo.QrCodeParamsVO;
+import me.chanjar.weixin.common.error.WxErrorException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import sun.security.krb5.internal.PAData;
+
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 访问人次 服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2021-08-17
+ */
+@Service
+public class TaMiniappQrcodeImpl extends BaseServiceImpl<TaMiniappQrcodeMapper, TaMiniappQrcode> implements ITaMiniappQrcodeService {
+
+    @Autowired
+    WxUtils wxUtils;
+
+    @Autowired
+    OSSUtils ossUtils;
+
+    @Autowired
+    TaMiniappQrcodeMapper miniappQrcodeMapper;
+
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public String createQrCode(QrCodeParamsVO qrCodeParamsVO) throws Exception {
+        if (null == qrCodeParamsVO || StringUtils.isEmpty(qrCodeParamsVO.getPage())) {
+            throw new Exception("小程序码生成参数为空");
+        }
+
+        if (StringUtils.isEmpty(qrCodeParamsVO.getType())) {
+            throw new Exception("小程序码页面参数非法");
+        }
+
+        // 页面地址, 不能以 / 开头
+        String page = qrCodeParamsVO.getPage();
+        if (page.startsWith("/")) {
+            page = page.substring(1);
+        }
+
+        // 页面参数
+        String secen = qrCodeParamsVO.getSceneQueryString();
+
+        // 小程序ID
+        String miniappId = wxUtils.getService().getWxMaConfig().getAppid();
+
+        // 先去查询数据库中是否已经存在相同参数的小程序码
+        LambdaQueryWrapper<TaMiniappQrcode> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaMiniappQrcode::getMiniappId, miniappId)
+                .eq(TaMiniappQrcode::getPage, page)
+                .eq(!StringUtils.isEmpty(secen), TaMiniappQrcode::getScene, secen)
+                .orderByDesc(TaMiniappQrcode::getCreateDate)
+                .last("limit 1");
+
+        // 如果存在, 则直接返回
+        TaMiniappQrcode origin = getOne(queryWrapper);
+        if (null != origin) {
+            return origin.getQrImage();
+        }
+
+        // 否则, 则新生成一个
+        // 先入库
+        TaMiniappQrcode taMiniappQrcode = new TaMiniappQrcode();
+        taMiniappQrcode.setMiniappId(miniappId);
+        taMiniappQrcode.setPage(page);
+        taMiniappQrcode.setScene(secen);
+        taMiniappQrcode.setCreateDate(LocalDateTime.now());
+        save(taMiniappQrcode);
+
+        // 使用SDK生成
+        WxUtils.AQrCodeParam param = new WxUtils.AQrCodeParam();
+        param.setPage(page);
+        param.setScene(taMiniappQrcode.getQrId().toString()); // 使用 qrId 作为 scene
+        param.setWidth(860);
+        param.setAutoColor(false);
+        param.setLineColor(new WxMaCodeLineColor("0", "0", "0"));
+        param.setHyaline(true);
+
+        String qrImage = buildMAQrCode(param);
+
+        // 再反向更新库
+        taMiniappQrcode.setQrImage(qrImage);
+        updateById(taMiniappQrcode);
+
+        return qrImage;
+    }
+
+    /**
+     * 生成小程序码, 并上传阿里云
+     * @param param
+     * @return
+     * @throws WxErrorException
+     */
+    private String buildMAQrCode(WxUtils.AQrCodeParam param) throws WxErrorException, FileNotFoundException {
+        WxMaQrcodeService qrcodeService = wxUtils.getService().getQrcodeService();
+        File qrFile = qrcodeService.createWxaCodeUnlimit(param.getScene(),
+                param.getPage(),
+                param.getWidth(),
+                param.isAutoColor(),
+                param.getLineColor(),
+                param.isHyaline());
+
+        return ossUtils.putObject(qrFile);
+    }
+}

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

@@ -1,10 +1,14 @@
 package com.yunzhi.shigongli.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.yunzhi.shigongli.common.Constants;
+import com.yunzhi.shigongli.common.StringUtils;
 import com.yunzhi.shigongli.entity.TaPerson;
 import com.yunzhi.shigongli.mapper.TaPersonMapper;
 import com.yunzhi.shigongli.service.ITaPersonService;
 
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 /**
  * <p>
@@ -17,4 +21,26 @@ import org.springframework.stereotype.Service;
 @Service
 public class TaPersonServiceImpl extends BaseServiceImpl<TaPersonMapper, TaPerson> implements ITaPersonService {
 
+    @Override
+    public TaPerson getByOpenid(String openid) {
+        if (StringUtils.isEmpty(openid)) {
+            return null;
+        }
+
+        LambdaQueryWrapper<TaPerson> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TaPerson::getOpenid, "openid");
+        queryWrapper.gt(TaPerson::getStatus, Constants.STATUS_DELETED);
+        queryWrapper.last("limit 1");
+
+        return getOne(queryWrapper);
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void setRecommender(TaPerson taPerson) throws Exception {
+        updateById(taPerson);
+
+        // 生成推广记录
+
+    }
 }

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

@@ -2,12 +2,15 @@ package com.yunzhi.shigongli.service.impl;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.yunzhi.shigongli.entity.TaShop;
+import com.yunzhi.shigongli.entity.TaShopAccount;
+import com.yunzhi.shigongli.mapper.TaShopAccountMapper;
 import com.yunzhi.shigongli.mapper.TaShopMapper;
 import com.yunzhi.shigongli.service.ITaShopService;
 
 import com.yunzhi.shigongli.vo.ShopListVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 /**
  * <p>
@@ -23,8 +26,22 @@ public class TaShopServiceImpl extends BaseServiceImpl<TaShopMapper, TaShop> imp
     @Autowired
     TaShopMapper taShopMapper;
 
+    @Autowired
+    TaShopAccountMapper taShopAccountMapper;
+
     @Override
     public IPage<ShopListVO> getPageListBy(IPage<ShopListVO> pg, String shopName, String phone) {
         return taShopMapper.getPageListBy(pg, shopName, phone);
     }
+
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void createNew(TaShop taShop) throws Exception {
+        save(taShop);
+
+        TaShopAccount account = new TaShopAccount();
+        account.setShopId(taShop.getShopId());
+
+        taShopAccountMapper.insert(account);
+    }
 }

src/main/java/com/yunzhi/shigongli/vo/QrCodeParamsVO.java

@@ -0,0 +1,39 @@
+package com.yunzhi.shigongli.vo;
+
+import com.yunzhi.shigongli.common.StringUtils;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Map;
+
+
+@ApiModel(description = "修改密码参数")
+@Data
+public class QrCodeParamsVO {
+
+    @ApiModelProperty("页面地址")
+    String page;
+
+    @ApiModelProperty("页面类型")
+    String type;
+
+    @ApiModelProperty("页面参数")
+    Map<String, Object> scene;
+
+    /**
+     * 获取 scene 字符串
+     * @return
+     */
+    public String getSceneQueryString() {
+        if (null == scene) {
+            return null;
+        }
+
+        if (!StringUtils.isEmpty(type)) {
+            scene.put("type", type);
+        }
+
+        return StringUtils.buildQueryString(scene);
+    }
+}

src/main/resources/mapper/TaMiniappQrcodeMapper.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.TaMiniappQrcodeMapper">
+
+</mapper>