feats

pom.xml

@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>com.huiju</groupId>
 	<artifactId>xiangsong</artifactId>
-	<version>1.0.25</version>
+	<version>1.0.27</version>
 	<name>xiangsong</name>
 	<description>香颂</description>
 

src/main/java/com/huiju/estateagents/controller/TpMessageEventController.java

@@ -0,0 +1,162 @@
+package com.huiju.estateagents.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.common.CommConstant;
+import com.huiju.estateagents.common.StringUtils;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import com.huiju.estateagents.service.ITpMessageEventService;
+import com.huiju.estateagents.entity.TpMessageEvent;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * <p>
+    *  前端控制器
+    * </p>
+ *
+ * @author yansen
+ * @since 2020-12-22
+ */
+
+@Api(tags = "")
+@RestController
+@RequestMapping("/api")
+public class TpMessageEventController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(TpMessageEventController.class);
+
+    @Autowired
+    public ITpMessageEventService iTpMessageEventService;
+
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/admin/tpMessageEvent",method= RequestMethod.GET)
+    @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
+    public ResponseBean tpMessageEventList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                           @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                           @ApiParam("事件名称") @RequestParam(value ="name", required = false) String name,
+                                           @ApiParam("事件类型") @RequestParam(value ="evtType", required = false) String evtType,
+                                           HttpServletRequest request) throws Exception {
+
+		    IPage<TpMessageEvent> pg = new Page<>(pageNum, pageSize);
+            QueryWrapper<TpMessageEvent> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("org_id", getOrgId(request));
+            queryWrapper.like(!StringUtils.isEmpty(name), "name", "%"+name+"%");
+            queryWrapper.like(!StringUtils.isEmpty(evtType), "evtType", "%"+evtType+"%");
+            queryWrapper.orderByAsc("evt_type");
+            queryWrapper.orderByAsc("evt_date");
+
+            IPage<TpMessageEvent> result = iTpMessageEventService.page(pg, queryWrapper);
+            return ResponseBean.success(result);
+    }
+
+    /**
+     * 保存对象
+     * @param tpMessageEvent 实体对象
+     * @return
+     */
+    @RequestMapping(value="/admin/tpMessageEvent",method= RequestMethod.POST)
+    @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean tpMessageEventAdd(@ApiParam("保存内容") @RequestBody TpMessageEvent tpMessageEvent,
+                                          HttpServletRequest request) throws Exception{
+
+        tpMessageEvent.setOrgId(getOrgId(request));
+
+        if (iTpMessageEventService.save(tpMessageEvent)){
+            return ResponseBean.success(tpMessageEvent);
+        }else {
+            return ResponseBean.error("保存失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+
+    /**
+     * 根据id删除对象
+     * @param id  实体ID
+     */
+    @RequestMapping(value="/admin/tpMessageEvent/{id}", method= RequestMethod.DELETE)
+    @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
+    public ResponseBean tpMessageEventDelete(@ApiParam("对象ID") @PathVariable Integer id,
+                                             HttpServletRequest request) throws Exception{
+        TpMessageEvent tpMessageEvent = iTpMessageEventService.getById(id);
+
+        if (null == tpMessageEvent || tpMessageEvent.getStatus().equals(CommConstant.STATUS_DELETE)) {
+            return ResponseBean.success("success");
+        }
+
+        if (!tpMessageEvent.getOrgId().equals(getOrgId(request))) {
+            return ResponseBean.error("您无权限操作当前数据", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        tpMessageEvent.setStatus(CommConstant.STATUS_DELETE);
+
+        return tpMessageEventUpdate(id, tpMessageEvent, request);
+    }
+
+    /**
+     * 修改对象
+     * @param id  实体ID
+     * @param tpMessageEvent 实体对象
+     * @return
+     */
+    @RequestMapping(value="/admin/tpMessageEvent/{id}",method= RequestMethod.PUT)
+    @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
+    public ResponseBean tpMessageEventUpdate(@ApiParam("对象ID") @PathVariable Integer id,
+                                             @ApiParam("更新内容") @RequestBody TpMessageEvent tpMessageEvent,
+                                             HttpServletRequest request) throws Exception{
+
+        if (null == tpMessageEvent || tpMessageEvent.getStatus().equals(CommConstant.STATUS_DELETE)) {
+            return ResponseBean.error("数据不存在", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        if (!tpMessageEvent.getOrgId().equals(getOrgId(request))) {
+            return ResponseBean.error("您无权限操作当前数据", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        if (iTpMessageEventService.updateById(tpMessageEvent)){
+            return ResponseBean.success(iTpMessageEventService.getById(id));
+        }else {
+            return ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+
+    /**
+     * 根据id查询对象
+     * @param id  实体ID
+     */
+    @RequestMapping(value="/tpMessageEvent/{id}",method= RequestMethod.GET)
+    @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
+    public ResponseBean tpMessageEventGet(@ApiParam("对象ID") @PathVariable Integer id,
+                                          HttpServletRequest request) throws Exception{
+        TpMessageEvent tpMessageEvent = iTpMessageEventService.getById(id);
+
+        if (null == tpMessageEvent || tpMessageEvent.getStatus().equals(CommConstant.STATUS_DELETE)) {
+            return ResponseBean.error("数据不存在", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        if (!tpMessageEvent.getOrgId().equals(getOrgId(request))) {
+            return ResponseBean.error("您无权限操作当前数据", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        return ResponseBean.success(tpMessageEvent);
+    }
+}

src/main/java/com/huiju/estateagents/controller/WxPortalController.java

@@ -124,7 +124,7 @@ public class WxPortalController extends BaseController {
         WxMpKefuMessage kefuMessage = WxMpKefuMessage.MINIPROGRAMPAGE().appId(taMiniapp.getMiniappId())
                 .title(taMiniapp.getName() + "欢迎您!")
                 .pagePath(miniAppIndex + "?mpOpenId=" + message.getOpenId())
-                .thumbMediaId(mpInfo.getMiniappThumb())
+                .thumbMediaId(mpInfo.getMiniappMedia())
                 .build();
 
         try {

src/main/java/com/huiju/estateagents/entity/TpMessageEvent.java

@@ -0,0 +1,55 @@
+package com.huiju.estateagents.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-12-22
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="TpMessageEvent对象", description="")
+public class TpMessageEvent implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "事件ID")
+    @TableId(value = "evt_id", type = IdType.AUTO)
+    private Integer evtId;
+
+    @ApiModelProperty(value = "名称")
+    private String name;
+
+    @ApiModelProperty(value = "事件类型,birthday生日,festival节日")
+    private String evtType;
+
+    @ApiModelProperty(value = "发生日mm-dd格式")
+    private String evtDate;
+
+    @ApiModelProperty(value = "是否阳历")
+    private Boolean isSolar;
+
+    @ApiModelProperty(value = "简要祝福语")
+    private String wishes;
+
+    @ApiModelProperty(value = "1开启,0未开启")
+    private Integer status;
+
+    @ApiModelProperty(value = "创建时间")
+    private LocalDateTime createDate;
+
+    private Integer orgId;
+}

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

@@ -84,7 +84,8 @@ public class AccessInterceptor implements HandlerInterceptor {
             "/api/fadd/",//所有的法大大回调放过
             "/api/third",
             "/api/third/redirect/",
-            "/api/official/" // 官网接口
+            "/api/official/", // 官网接口
+            "/api/mp/portal/"   // 公众号接入
     };
 
     /*

src/main/java/com/huiju/estateagents/mapper/TpMessageEventMapper.java

@@ -0,0 +1,18 @@
+package com.huiju.estateagents.mapper;
+
+import com.huiju.estateagents.entity.TpMessageEvent;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-12-22
+ */
+@Mapper
+public interface TpMessageEventMapper extends BaseMapper<TpMessageEvent> {
+
+}

src/main/java/com/huiju/estateagents/service/ITpMessageEventService.java

@@ -0,0 +1,16 @@
+package com.huiju.estateagents.service;
+
+import com.huiju.estateagents.entity.TpMessageEvent;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-12-22
+ */
+public interface ITpMessageEventService extends IService<TpMessageEvent> {
+
+}

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

@@ -0,0 +1,20 @@
+package com.huiju.estateagents.service.impl;
+
+import com.huiju.estateagents.entity.TpMessageEvent;
+import com.huiju.estateagents.mapper.TpMessageEventMapper;
+import com.huiju.estateagents.service.ITpMessageEventService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-12-22
+ */
+@Service
+public class TpMessageEventServiceImpl extends ServiceImpl<TpMessageEventMapper, TpMessageEvent> implements ITpMessageEventService {
+
+}

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

@@ -5,12 +5,27 @@ 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.common.StringUtils;
+import com.huiju.estateagents.common.WxUtils;
 import com.huiju.estateagents.third.entity.TaMpInfo;
 import com.huiju.estateagents.third.service.ITaMpInfoService;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.api.WxConsts;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.mp.bean.material.WxMpMaterial;
+import me.chanjar.weixin.mp.bean.material.WxMpMaterialUploadResult;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.servlet.http.HttpServletRequest;
+import java.io.File;
+import java.io.IOException;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Map;
 
 /**
  * <p>
@@ -20,124 +35,182 @@ import org.springframework.web.bind.annotation.*;
  * @author fxf
  * @since 2020-06-02
  */
+@Slf4j
 @RestController
-@RequestMapping("/")
+@RequestMapping("/api")
 public class TaMpInfoController extends BaseController {
 
-    private final Logger logger = LoggerFactory.getLogger(TaMpInfoController.class);
-
     @Autowired
     public ITaMpInfoService iTaMpInfoService;
 
+    @Autowired
+    private WxUtils wxUtils;
 
+//
+//    /**
+//     * 分页查询列表
+//     * @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;
+//    }
+//
     /**
-     * 分页查询列表
-     * @param pageNum
-     * @param pageSize
-     * @return
+     * 根据id查询对象
+     * @param id  实体ID
      */
-    @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;
+    @RequestMapping(value="/admin/mp/taMpInfo",method= RequestMethod.GET)
+    public ResponseBean taMpInfoGet(HttpServletRequest request){
+        Integer orgId = getOrgId(request);
+        TaMpInfo taMpInfo = iTaMpInfoService.getByOrgId(orgId);
+        return ResponseBean.success(taMpInfo);
     }
 
     /**
-     * 保存对象
-     * @param taMpInfo 实体对象
+     * 暂时仅支持 jpg
+     * @param file
+     * @param request
      * @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());
+    @PostMapping("/admin/mp/material/miniapp")
+    public ResponseBean postMpMiniappMedia(@RequestParam("file") MultipartFile file,
+                                           HttpServletRequest request) {
+        if (file.isEmpty()) {
+            return ResponseBean.error("请选择文件上传", ResponseBean.ERROR_MISSING_PARAMS);
         }
-        return responseBean;
-    }
 
-    /**
-     * 根据id删除对象
-     * @param id  实体ID
-     */
-    @ResponseBody
-    @RequestMapping(value="/taMpInfo/{id}", method= RequestMethod.DELETE)
-    public ResponseBean taMpInfoDelete(@PathVariable Integer id){
-        ResponseBean responseBean = new ResponseBean();
+        Integer orgId = getOrgId(request);
+        TaMpInfo taMpInfo = iTaMpInfoService.getByOrgId(orgId);
+
         try {
-            if(iTaMpInfoService.removeById(id)){
-                responseBean.addSuccess("success");
-            }else {
-                responseBean.addError("fail");
+            String nwName = "yz-"+LocalDateTime.now().getNano();
+            String path = System.getProperty("java.io.tmpdir") + System.getProperty("file.separator") + nwName;
+            File tmpFile = File.createTempFile(path, ".jpg");
+            file.transferTo(tmpFile);
+
+            String fname = null == file.getOriginalFilename() ? nwName : file.getOriginalFilename();
+            if (!fname.contains(".jpg")) {
+                fname += ".jpg";
             }
-        }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");
+            WxMpMaterial wxMaterial = new WxMpMaterial();
+            wxMaterial.setFile(tmpFile);
+            wxMaterial.setName(fname);
+
+            WxMpMaterialUploadResult res = wxUtils.getMpService(orgId).getMaterialService().materialFileUpload(WxConsts.MaterialType.IMAGE, wxMaterial);
+
+            if (StringUtils.isEmpty(res.getMediaId())) {
+                log.error("上传图片到微信失败 [{}]: {}", res.getErrCode(), res.getErrMsg());
+                return ResponseBean.error("上传图片到微信失败: " + res.getErrMsg(), ResponseBean.ERROR_UNAVAILABLE);
             }
-        }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){
+            taMpInfo.setMiniappMedia(res.getMediaId());
+            taMpInfo.setMiniappUrl(res.getUrl());
+            if (!iTaMpInfoService.updateById(taMpInfo)) {
+                return ResponseBean.error("保存图片媒体ID失败", ResponseBean.ERROR_UNAVAILABLE);
+            }
+
+            if (tmpFile.exists()) {
+                tmpFile.delete();
+            }
+
+            return ResponseBean.success(new HashMap<String, String>(){{
+                put("mediaId", res.getMediaId());
+                put("url", res.getUrl());
+            }});
+
+        } catch (IOException e) {
+            e.printStackTrace();
+            return ResponseBean.error("接收图片失败: " + e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);
+        } catch (WxErrorException e) {
             e.printStackTrace();
-            logger.error("taMpInfoDelete -=- {}",e.toString());
-            responseBean.addError(e.getMessage());
+            return ResponseBean.error("上传图片到微信失败: " + e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);
         }
-        return responseBean;
     }
 }

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

@@ -2,6 +2,9 @@ package com.huiju.estateagents.third.entity;
 
 import java.time.LocalDateTime;
 import java.io.Serializable;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
@@ -24,6 +27,7 @@ public class TaMpInfo implements Serializable {
     /**
      * 公众号ID
      */
+    @TableId(value = "appid", type = IdType.INPUT)
     private String appid;
 
     /**
@@ -69,5 +73,6 @@ public class TaMpInfo implements Serializable {
     /**
      * 对应小程序的封面 mediaId
      */
-    private String miniappThumb;
+    private String miniappMedia;
+    private String miniappUrl;
 }

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