新需求

pom.xml

@@ -56,7 +56,17 @@
 		<dependency>
 			<groupId>com.github.binarywang</groupId>
 			<artifactId>weixin-java-miniapp</artifactId>
-			<version>3.6.0</version>
+			<version>3.8.0</version>
+		</dependency>
+		<dependency>
+			<groupId>com.github.binarywang</groupId>
+			<artifactId>weixin-java-mp</artifactId>
+			<version>3.8.0</version>
+		</dependency>
+		<dependency>
+			<groupId>com.github.binarywang</groupId>
+			<artifactId>weixin-java-pay</artifactId>
+			<version>3.8.0</version>
 		</dependency>
 		<dependency>
 			<groupId>com.alibaba</groupId>

src/main/java/com/huiju/estateagents/common/WxMpUtils.java

@@ -0,0 +1,41 @@
+package com.huiju.estateagents.common;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.huiju.estateagents.third.entity.TaMpInfo;
+import com.huiju.estateagents.third.service.ITaMpInfoService;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
+import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Component
+public class WxMpUtils {
+
+    @Autowired
+    public ITaMpInfoService iTaMpInfoService;
+
+    @PostConstruct
+    public WxMpService wxMpService() {
+        //从数据库读取公众号信息
+        QueryWrapper<TaMpInfo> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("status", CommConstant.STATUS_NORMAL);
+        List<TaMpInfo> mplist = iTaMpInfoService.list(queryWrapper);
+
+        WxMpService service = new WxMpServiceImpl();
+        service.setMultiConfigStorages(mplist
+                .stream().map(a -> {
+                    WxMpDefaultConfigImpl configStorage = new WxMpDefaultConfigImpl();
+                    configStorage.setAppId(a.getAppid());
+                    configStorage.setSecret(a.getSecret());
+                    configStorage.setToken(a.getToken());
+                    configStorage.setAesKey(a.getAesKey());
+                    return configStorage;
+                }).collect(Collectors.toMap(WxMpDefaultConfigImpl::getAppId, a -> a, (o, n) -> o)));
+        return service;
+    }
+}

src/main/java/com/huiju/estateagents/interceptor/AccessInterceptor.java

@@ -75,6 +75,7 @@ public class AccessInterceptor implements HandlerInterceptor {
             "/api/notify",//微信支付所有回调放过
             "/api/refund/",//微信退款所有回调放过
             "/api/fadd/",//所有的法大大回调放过
+            "/api/third"
     };
 
     /*

src/main/java/com/huiju/estateagents/redpack/controller/TaMpMiniappController.java

@@ -0,0 +1,143 @@
+package com.huiju.estateagents.redpack.controller;
+
+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.huiju.estateagents.base.BaseController;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.redpack.entity.TaMpMiniapp;
+import com.huiju.estateagents.redpack.service.ITaMpMiniappService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * <p>
+    * 公众号小程序账户映射  前端控制器
+    * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@RestController
+@RequestMapping("/")
+public class TaMpMiniappController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(TaMpMiniappController.class);
+
+    @Autowired
+    public ITaMpMiniappService iTaMpMiniappService;
+
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/taMpMiniapp",method= RequestMethod.GET)
+    public ResponseBean taMpMiniappList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                        @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            //使用分页插件
+		    IPage<TaMpMiniapp> pg = new Page<>(pageNum, pageSize);
+            QueryWrapper<TaMpMiniapp> queryWrapper = new QueryWrapper<>();
+            queryWrapper.orderByDesc("create_date");
+
+            IPage<TaMpMiniapp> result = iTaMpMiniappService.page(pg, queryWrapper);
+            responseBean.addSuccess(result);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpMiniappList -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 保存对象
+     * @param taMpMiniapp 实体对象
+     * @return
+     */
+    @RequestMapping(value="/taMpMiniapp",method= RequestMethod.POST)
+    public ResponseBean taMpMiniappAdd(@RequestBody TaMpMiniapp taMpMiniapp){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if (iTaMpMiniappService.save(taMpMiniapp)){
+                responseBean.addSuccess(taMpMiniapp);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpMiniappAdd -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 根据id删除对象
+     * @param id  实体ID
+     */
+    @ResponseBody
+    @RequestMapping(value="/taMpMiniapp/{id}", method= RequestMethod.DELETE)
+    public ResponseBean taMpMiniappDelete(@PathVariable Integer id){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if(iTaMpMiniappService.removeById(id)){
+                responseBean.addSuccess("success");
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpMiniappDelete -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 修改对象
+     * @param id  实体ID
+     * @param taMpMiniapp 实体对象
+     * @return
+     */
+    @RequestMapping(value="/taMpMiniapp/{id}",method= RequestMethod.PUT)
+    public ResponseBean taMpMiniappUpdate(@PathVariable Integer id,
+                                        @RequestBody TaMpMiniapp taMpMiniapp){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if (iTaMpMiniappService.updateById(taMpMiniapp)){
+                responseBean.addSuccess(taMpMiniapp);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpMiniappUpdate -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 根据id查询对象
+     * @param id  实体ID
+     */
+    @RequestMapping(value="/taMpMiniapp/{id}",method= RequestMethod.GET)
+    public ResponseBean taMpMiniappGet(@PathVariable Integer id){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            responseBean.addSuccess(iTaMpMiniappService.getById(id));
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpMiniappDelete -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+}

src/main/java/com/huiju/estateagents/redpack/controller/TaMpPersonController.java

@@ -0,0 +1,143 @@
+package com.huiju.estateagents.redpack.controller;
+
+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.huiju.estateagents.base.BaseController;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.redpack.entity.TaMpPerson;
+import com.huiju.estateagents.redpack.service.ITaMpPersonService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * <p>
+    * 公众号用户表  前端控制器
+    * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@RestController
+@RequestMapping("/")
+public class TaMpPersonController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(TaMpPersonController.class);
+
+    @Autowired
+    public ITaMpPersonService iTaMpPersonService;
+
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/taMpPerson",method= RequestMethod.GET)
+    public ResponseBean taMpPersonList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                       @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            //使用分页插件
+		    IPage<TaMpPerson> pg = new Page<>(pageNum, pageSize);
+            QueryWrapper<TaMpPerson> queryWrapper = new QueryWrapper<>();
+            queryWrapper.orderByDesc("create_date");
+
+            IPage<TaMpPerson> result = iTaMpPersonService.page(pg, queryWrapper);
+            responseBean.addSuccess(result);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpPersonList -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 保存对象
+     * @param taMpPerson 实体对象
+     * @return
+     */
+    @RequestMapping(value="/taMpPerson",method= RequestMethod.POST)
+    public ResponseBean taMpPersonAdd(@RequestBody TaMpPerson taMpPerson){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if (iTaMpPersonService.save(taMpPerson)){
+                responseBean.addSuccess(taMpPerson);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpPersonAdd -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 根据id删除对象
+     * @param id  实体ID
+     */
+    @ResponseBody
+    @RequestMapping(value="/taMpPerson/{id}", method= RequestMethod.DELETE)
+    public ResponseBean taMpPersonDelete(@PathVariable Integer id){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if(iTaMpPersonService.removeById(id)){
+                responseBean.addSuccess("success");
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpPersonDelete -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 修改对象
+     * @param id  实体ID
+     * @param taMpPerson 实体对象
+     * @return
+     */
+    @RequestMapping(value="/taMpPerson/{id}",method= RequestMethod.PUT)
+    public ResponseBean taMpPersonUpdate(@PathVariable Integer id,
+                                        @RequestBody TaMpPerson taMpPerson){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if (iTaMpPersonService.updateById(taMpPerson)){
+                responseBean.addSuccess(taMpPerson);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpPersonUpdate -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 根据id查询对象
+     * @param id  实体ID
+     */
+    @RequestMapping(value="/taMpPerson/{id}",method= RequestMethod.GET)
+    public ResponseBean taMpPersonGet(@PathVariable Integer id){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            responseBean.addSuccess(iTaMpPersonService.getById(id));
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpPersonDelete -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+}

src/main/java/com/huiju/estateagents/redpack/entity/TaMpMiniapp.java

@@ -0,0 +1,35 @@
+package com.huiju.estateagents.redpack.entity;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ * <p>
+ * 公众号小程序账户映射 
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class TaMpMiniapp implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 公众号人员ID
+     */
+    private String mpPersonId;
+
+    /**
+     * 小程序人员ID
+     */
+    private String miniappPersonId;
+
+
+}

src/main/java/com/huiju/estateagents/redpack/entity/TaMpPerson.java

@@ -0,0 +1,86 @@
+package com.huiju.estateagents.redpack.entity;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 公众号用户表 
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class TaMpPerson implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 人员ID
+     */
+    private String mpPersonId;
+
+    /**
+     * openid
+     */
+    private String mpOpenid;
+
+    /**
+     * 昵称
+     */
+    private String nickname;
+
+    /**
+     * 头像
+     */
+    private String headimgurl;
+
+    /**
+     * 性别
+     */
+    private Boolean sex;
+
+    /**
+     * 省份
+     */
+    private String province;
+
+    /**
+     * 城市
+     */
+    private String city;
+
+    /**
+     * 国家
+     */
+    private String country;
+
+    /**
+     * unionid
+     */
+    private String unionid;
+
+    /**
+     * 公众号ID
+     */
+    private String appid;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createDate;
+
+    /**
+     * 状态
+     */
+    private Integer status;
+
+
+}

src/main/java/com/huiju/estateagents/redpack/mapper/TaMpMiniappMapper.java

@@ -0,0 +1,16 @@
+package com.huiju.estateagents.redpack.mapper;
+
+import com.huiju.estateagents.redpack.entity.TaMpMiniapp;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 公众号小程序账户映射  Mapper 接口
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+public interface TaMpMiniappMapper extends BaseMapper<TaMpMiniapp> {
+
+}

src/main/java/com/huiju/estateagents/redpack/mapper/TaMpPersonMapper.java

@@ -0,0 +1,16 @@
+package com.huiju.estateagents.redpack.mapper;
+
+import com.huiju.estateagents.redpack.entity.TaMpPerson;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 公众号用户表  Mapper 接口
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+public interface TaMpPersonMapper extends BaseMapper<TaMpPerson> {
+
+}

src/main/java/com/huiju/estateagents/redpack/service/ITaMpMiniappService.java

@@ -0,0 +1,16 @@
+package com.huiju.estateagents.redpack.service;
+
+import com.huiju.estateagents.redpack.entity.TaMpMiniapp;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 公众号小程序账户映射  服务类
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+public interface ITaMpMiniappService extends IService<TaMpMiniapp> {
+
+}

src/main/java/com/huiju/estateagents/redpack/service/ITaMpPersonService.java

@@ -0,0 +1,16 @@
+package com.huiju.estateagents.redpack.service;
+
+import com.huiju.estateagents.redpack.entity.TaMpPerson;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 公众号用户表  服务类
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+public interface ITaMpPersonService extends IService<TaMpPerson> {
+
+}

src/main/java/com/huiju/estateagents/redpack/service/impl/TaMpMiniappServiceImpl.java

@@ -0,0 +1,20 @@
+package com.huiju.estateagents.redpack.service.impl;
+
+import com.huiju.estateagents.redpack.entity.TaMpMiniapp;
+import com.huiju.estateagents.redpack.mapper.TaMpMiniappMapper;
+import com.huiju.estateagents.redpack.service.ITaMpMiniappService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 公众号小程序账户映射  服务实现类
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@Service
+public class TaMpMiniappServiceImpl extends ServiceImpl<TaMpMiniappMapper, TaMpMiniapp> implements ITaMpMiniappService {
+
+}

src/main/java/com/huiju/estateagents/redpack/service/impl/TaMpPersonServiceImpl.java

@@ -0,0 +1,20 @@
+package com.huiju.estateagents.redpack.service.impl;
+
+import com.huiju.estateagents.redpack.entity.TaMpPerson;
+import com.huiju.estateagents.redpack.mapper.TaMpPersonMapper;
+import com.huiju.estateagents.redpack.service.ITaMpPersonService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 公众号用户表  服务实现类
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@Service
+public class TaMpPersonServiceImpl extends ServiceImpl<TaMpPersonMapper, TaMpPerson> implements ITaMpPersonService {
+
+}

src/main/java/com/huiju/estateagents/service/impl/MiniAppServiceImpl.java

@@ -459,7 +459,7 @@ public class MiniAppServiceImpl implements IMiniAppService {
             return ResponseBean.error("小程序消息模板未设置字段内容", ResponseBean.ERROR_ILLEGAL_PARAMS);
         }
 
-        List<WxMaSubscribeData> sendData = createMessageData(data, tpl.getTplFields());
+        List<WxMaSubscribeMessage.Data> sendData = createMessageData(data, tpl.getTplFields());
 
         WxMaSubscribeMessage message = WxMaSubscribeMessage.builder()
                 .templateId(tpl.getTplId())
@@ -509,15 +509,15 @@ public class MiniAppServiceImpl implements IMiniAppService {
         return success ? null : "短信发送失败";
     }
 
-    private List<WxMaSubscribeData> createMessageData(String[] list, String fieldsStr) {
-        List<WxMaSubscribeData> data = new ArrayList<>();
+    private List<WxMaSubscribeMessage.Data> createMessageData(String[] list, String fieldsStr) {
+        List<WxMaSubscribeMessage.Data> data = new ArrayList<>();
         if (list == null || list.length == 0 || StringUtils.isEmpty(fieldsStr)) return data;
 
         String[] fileds = fieldsStr.split("\\|");
 
         int length = Math.min(fileds.length, list.length);
         for (int i = 0; i < length; i++) {
-            data.add(new WxMaSubscribeData(fileds[i], list[i], "#fffff"));
+            data.add(new WxMaSubscribeMessage.Data(fileds[i], list[i]));
         }
         return data;
     }

src/main/java/com/huiju/estateagents/third/controller/TaMpInfoController.java

@@ -0,0 +1,143 @@
+package com.huiju.estateagents.third.controller;
+
+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.huiju.estateagents.base.BaseController;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.third.entity.TaMpInfo;
+import com.huiju.estateagents.third.service.ITaMpInfoService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * <p>
+    *   前端控制器
+    * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@RestController
+@RequestMapping("/")
+public class TaMpInfoController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(TaMpInfoController.class);
+
+    @Autowired
+    public ITaMpInfoService iTaMpInfoService;
+
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/taMpInfo",method= RequestMethod.GET)
+    public ResponseBean taMpInfoList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                     @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            //使用分页插件
+		    IPage<TaMpInfo> pg = new Page<>(pageNum, pageSize);
+            QueryWrapper<TaMpInfo> queryWrapper = new QueryWrapper<>();
+            queryWrapper.orderByDesc("create_date");
+
+            IPage<TaMpInfo> result = iTaMpInfoService.page(pg, queryWrapper);
+            responseBean.addSuccess(result);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpInfoList -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 保存对象
+     * @param taMpInfo 实体对象
+     * @return
+     */
+    @RequestMapping(value="/taMpInfo",method= RequestMethod.POST)
+    public ResponseBean taMpInfoAdd(@RequestBody TaMpInfo taMpInfo){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if (iTaMpInfoService.save(taMpInfo)){
+                responseBean.addSuccess(taMpInfo);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpInfoAdd -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 根据id删除对象
+     * @param id  实体ID
+     */
+    @ResponseBody
+    @RequestMapping(value="/taMpInfo/{id}", method= RequestMethod.DELETE)
+    public ResponseBean taMpInfoDelete(@PathVariable Integer id){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if(iTaMpInfoService.removeById(id)){
+                responseBean.addSuccess("success");
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpInfoDelete -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 修改对象
+     * @param id  实体ID
+     * @param taMpInfo 实体对象
+     * @return
+     */
+    @RequestMapping(value="/taMpInfo/{id}",method= RequestMethod.PUT)
+    public ResponseBean taMpInfoUpdate(@PathVariable Integer id,
+                                        @RequestBody TaMpInfo taMpInfo){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if (iTaMpInfoService.updateById(taMpInfo)){
+                responseBean.addSuccess(taMpInfo);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpInfoUpdate -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 根据id查询对象
+     * @param id  实体ID
+     */
+    @RequestMapping(value="/taMpInfo/{id}",method= RequestMethod.GET)
+    public ResponseBean taMpInfoGet(@PathVariable Integer id){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            responseBean.addSuccess(iTaMpInfoService.getById(id));
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taMpInfoDelete -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+}

src/main/java/com/huiju/estateagents/third/controller/WxRedpackController.java

@@ -0,0 +1,54 @@
+package com.huiju.estateagents.third.controller;
+
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.WxMpUtils;
+import lombok.AllArgsConstructor;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.result.WxMpOAuth2AccessToken;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * @author Edward
+ */
+@AllArgsConstructor
+@Controller
+@RequestMapping("/api")
+public class WxRedpackController {
+    public WxMpUtils wxMpUtils;
+
+    /**
+     * 换取openid接口并插入公众号人员表
+     * @param appid
+     * @param code
+     * @param request
+     * @return
+     */
+    @GetMapping("/third/redirect/{appid}/greet")
+    public ResponseBean greetUser(@PathVariable String appid, @RequestParam String code, HttpServletRequest request) {
+        WxMpService wxService = wxMpUtils.wxMpService();
+        if (!wxService.switchover(appid)) {
+            throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", appid));
+        }
+        String openId = null;
+        try {
+            //换取openid
+            WxMpOAuth2AccessToken accessToken = wxService.oauth2getAccessToken(code);
+            WxMpUser user = wxService.oauth2getUserInfo(accessToken, null);
+            openId = user.getOpenId();
+            //插入公众号人员信息并插入表
+
+        } catch (WxErrorException e) {
+            e.printStackTrace();
+        }
+
+        return ResponseBean.success(openId);
+    }
+}

src/main/java/com/huiju/estateagents/third/entity/TaMpInfo.java

@@ -0,0 +1,70 @@
+package com.huiju.estateagents.third.entity;
+
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ *  
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class TaMpInfo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 公众号ID
+     */
+    private String appid;
+
+    /**
+     * Secret
+     */
+    private String secret;
+
+    /**
+     * 名称
+     */
+    private String name;
+
+    /**
+     * Token
+     */
+    private String token;
+
+    /**
+     * AccessToken
+     */
+    private String accessToken;
+
+    /**
+     * AES_KEY
+     */
+    private String aesKey;
+
+    /**
+     * 公司id 系统内置则为0
+     */
+    private Integer orgId;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createDate;
+
+    /**
+     * 状态
+     */
+    private Integer status;
+
+
+}

src/main/java/com/huiju/estateagents/third/mapper/TaMpInfoMapper.java

@@ -0,0 +1,18 @@
+package com.huiju.estateagents.third.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huiju.estateagents.third.entity.TaMpInfo;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ *   Mapper 接口
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@Mapper
+public interface TaMpInfoMapper extends BaseMapper<TaMpInfo> {
+
+}

src/main/java/com/huiju/estateagents/third/service/ITaMpInfoService.java

@@ -0,0 +1,16 @@
+package com.huiju.estateagents.third.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.huiju.estateagents.third.entity.TaMpInfo;
+
+/**
+ * <p>
+ *   服务类
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+public interface ITaMpInfoService extends IService<TaMpInfo> {
+
+}

src/main/java/com/huiju/estateagents/third/service/impl/TaMpInfoServiceImpl.java

@@ -0,0 +1,20 @@
+package com.huiju.estateagents.third.service.impl;
+
+import com.huiju.estateagents.third.entity.TaMpInfo;
+import com.huiju.estateagents.third.mapper.TaMpInfoMapper;
+import com.huiju.estateagents.third.service.ITaMpInfoService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *   服务实现类
+ * </p>
+ *
+ * @author fxf
+ * @since 2020-06-02
+ */
+@Service
+public class TaMpInfoServiceImpl extends ServiceImpl<TaMpInfoMapper, TaMpInfo> implements ITaMpInfoService {
+
+}

src/main/resources/mapper/TaMpInfoMapper.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.huiju.estateagents.third.mapper.TaMpInfoMapper">
+
+</mapper>

src/main/resources/mapper/redpack/TaMpMiniappMapper.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.huiju.estateagents.redpack.mapper.TaMpMiniappMapper">
+
+</mapper>

src/main/resources/mapper/redpack/TaMpPersonMapper.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.huiju.estateagents.redpack.mapper.TaMpPersonMapper">
+
+</mapper>