推送公众号任务表日志表添加

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/dto/BizMpPublishLogDTO.java

@@ -0,0 +1,56 @@
+package cn.tr.module.smart.common.dto;
+
+import cn.tr.core.validation.Update;
+import cn.tr.plugin.mybatis.pojo.BaseDTO;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.ToString;
+
+import javax.validation.constraints.NotBlank;
+import java.util.Date;
+/**
+ * biz_mp_publish_log传输对象
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:28
+ **/
+@Data
+@ApiModel("biz_mp_publish_log传输对象")
+@EqualsAndHashCode(callSuper = true)
+@ToString
+public class BizMpPublishLogDTO extends BaseDTO  {
+    private static final long serialVersionUID = 1L;
+    @ApiModelProperty(value = "id", position = 1)
+     @NotBlank  (message = "主键不能为空",groups = {Update.class})
+    private String id;
+
+    @ApiModelProperty(value = "任务id", position = 2)
+    private String taskId;
+
+    @ApiModelProperty(value = "发送时间", position = 3)
+    private Date publishTime;
+
+    @ApiModelProperty(value = "发送用户", position = 4)
+    private String reviveUserId;
+
+    @ApiModelProperty(value = "发送结果", position = 5)
+    private Integer success;
+
+    @ApiModelProperty(value = "错误日志", position = 6)
+    private String errorMsg;
+
+    @ApiModelProperty(value = "发送人", position = 7)
+    private String sendUserId;
+
+    @ApiModelProperty(value = "发送类型 （手动、自动）", position = 8)
+    private String type;
+
+    @ApiModelProperty(value = "发送模板", position = 9)
+    private String templateCode;
+
+    @ApiModelProperty(value = "发送参数", position = 10)
+    private String params;
+
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/dto/BizMpPublishLogQueryDTO.java

@@ -0,0 +1,17 @@
+package cn.tr.module.smart.common.dto;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.ToString;
+/**
+ * biz_mp_publish_log查询参数
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:28
+ **/
+@Data
+@ApiModel("biz_mp_publish_log查询参数")
+@ToString
+public class BizMpPublishLogQueryDTO  {
+    private static final long serialVersionUID = 1L;
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/dto/BizMpPublishTaskDTO.java

@@ -0,0 +1,46 @@
+package cn.tr.module.smart.common.dto;
+
+import cn.tr.core.validation.Update;
+import cn.tr.plugin.mybatis.pojo.BaseDTO;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.ToString;
+
+import javax.validation.constraints.NotBlank;
+/**
+ * 公众号推送任务表传输对象
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:29
+ **/
+@Data
+@ApiModel("公众号推送任务表传输对象")
+@EqualsAndHashCode(callSuper = true)
+@ToString
+public class BizMpPublishTaskDTO extends BaseDTO  {
+    private static final long serialVersionUID = 1L;
+    @ApiModelProperty(value = "id", position = 1)
+     @NotBlank  (message = "主键不能为空",groups = {Update.class})
+    private String id;
+
+    @ApiModelProperty(value = "诊疗室ID", position = 2)
+    private String clinicRoomId;
+
+    @ApiModelProperty(value = "任务类型", position = 3)
+    private String type;
+
+    @ApiModelProperty(value = "总次数", position = 4)
+    private Integer totalCount;
+
+    @ApiModelProperty(value = "已推送次数", position = 5)
+    private Integer publishCount;
+
+    @ApiModelProperty(value = "cron表达式", position = 6)
+    private String cron;
+
+    @ApiModelProperty(value = "定时任务对象", position = 7)
+    private String cronJob;
+
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/dto/BizMpPublishTaskQueryDTO.java

@@ -0,0 +1,17 @@
+package cn.tr.module.smart.common.dto;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.ToString;
+/**
+ * 公众号推送任务表查询参数
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:29
+ **/
+@Data
+@ApiModel("公众号推送任务表查询参数")
+@ToString
+public class BizMpPublishTaskQueryDTO  {
+    private static final long serialVersionUID = 1L;
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/mapper/BizMpPublishLogMapper.java

@@ -0,0 +1,28 @@
+package cn.tr.module.smart.common.mapper;
+
+import cn.tr.module.smart.common.dto.BizMpPublishLogDTO;
+import cn.tr.module.smart.common.po.BizMpPublishLogPO;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+import java.util.List;
+
+/**
+* biz_mp_publish_log映射工具
+*
+* @author wangzl
+* @date  2025/07/25 08:28
+**/
+@Mapper
+public interface BizMpPublishLogMapper {
+    BizMpPublishLogMapper INSTANCE = Mappers.getMapper(BizMpPublishLogMapper.class);
+
+    BizMpPublishLogPO convertPO(BizMpPublishLogDTO source);
+
+    BizMpPublishLogDTO convertDto(BizMpPublishLogPO source);
+
+    List<BizMpPublishLogDTO> convertDtoList(List<BizMpPublishLogPO> source);
+
+    List<BizMpPublishLogPO> convertPOList(List<BizMpPublishLogDTO> source);
+
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/mapper/BizMpPublishTaskMapper.java

@@ -0,0 +1,29 @@
+package cn.tr.module.smart.common.mapper;
+
+import cn.tr.module.smart.common.dto.BizMpPublishTaskDTO;
+import cn.tr.module.smart.common.po.BizMpPublishTaskPO;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+import java.util.List;
+
+
+/**
+* 公众号推送任务表映射工具
+*
+* @author wangzl
+* @date  2025/07/25 08:29
+**/
+@Mapper
+public interface BizMpPublishTaskMapper {
+    BizMpPublishTaskMapper INSTANCE = Mappers.getMapper(BizMpPublishTaskMapper.class);
+
+    BizMpPublishTaskPO convertPO(BizMpPublishTaskDTO source);
+
+    BizMpPublishTaskDTO convertDto(BizMpPublishTaskPO source);
+
+    List<BizMpPublishTaskDTO> convertDtoList(List<BizMpPublishTaskPO> source);
+
+    List<BizMpPublishTaskPO> convertPOList(List<BizMpPublishTaskDTO> source);
+
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/po/BizMpPublishLogPO.java

@@ -0,0 +1,65 @@
+package cn.tr.module.smart.common.po;
+
+import cn.tr.plugin.mybatis.pojo.TenantPO;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.ToString;
+
+import java.util.Date;
+/**
+ * biz_mp_publish_log实体
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:28
+ **/
+@Data
+@TableName(value="biz_mp_publish_log",autoResultMap = true)
+@EqualsAndHashCode(callSuper = true)
+@ToString
+public class BizMpPublishLogPO extends TenantPO {
+
+    /** id */
+    @TableId
+    @ApiModelProperty(value = "id", position = 1)
+    private String id;
+
+    /** 任务id */
+    @ApiModelProperty(value = "任务id", position = 2)
+    private String taskId;
+
+    /** 发送时间 */
+    @ApiModelProperty(value = "发送时间", position = 3)
+    private Date publishTime;
+
+    /** 发送用户 */
+    @ApiModelProperty(value = "发送用户", position = 4)
+    private String reveiveUserId;
+
+    /** 发送结果 */
+    @ApiModelProperty(value = "发送结果", position = 5)
+    private Integer success;
+
+    /** 错误日志 */
+    @ApiModelProperty(value = "错误日志", position = 6)
+    private String errorMsg;
+
+    /** 发送人 */
+    @ApiModelProperty(value = "发送人", position = 7)
+    private String sendUserId;
+
+    /** 发送类型 （手动、自动） */
+    @ApiModelProperty(value = "发送类型 （手动、自动）", position = 8)
+    private String type;
+
+    /** 发送模板 */
+    @ApiModelProperty(value = "发送模板", position = 9)
+    private String templateCode;
+
+    /** 发送参数 */
+    @ApiModelProperty(value = "发送参数", position = 10)
+    private String params;
+
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/po/BizMpPublishTaskPO.java

@@ -0,0 +1,51 @@
+package cn.tr.module.smart.common.po;
+
+import cn.tr.plugin.mybatis.pojo.TenantPO;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.ToString;
+/**
+ * 公众号推送任务表实体
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:29
+ **/
+@Data
+@TableName(value="biz_mp_publish_task",autoResultMap = true)
+@EqualsAndHashCode(callSuper = true)
+@ToString
+public class BizMpPublishTaskPO extends TenantPO {
+
+    /** id */
+    @TableId
+    @ApiModelProperty(value = "id", position = 1)
+    private String id;
+
+    /** clinic_room_id */
+    @ApiModelProperty(value = "clinic_room_id", position = 2)
+    private String clinicRoomId;
+
+    /** 任务类型 */
+    @ApiModelProperty(value = "任务类型", position = 3)
+    private String type;
+
+    /** 总次数 */
+    @ApiModelProperty(value = "总次数", position = 4)
+    private Integer totalCount;
+
+    /** 已推送次数 */
+    @ApiModelProperty(value = "已推送次数", position = 5)
+    private Integer publishCount;
+
+    /** cron表达式 */
+    @ApiModelProperty(value = "cron表达式", position = 6)
+    private String cron;
+
+    /** cron_job */
+    @ApiModelProperty(value = "cron_job", position = 7)
+    private String cronJob;
+
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/repository/BizMpPublishLogRepository.java

@@ -0,0 +1,16 @@
+package cn.tr.module.smart.common.repository;
+
+import cn.tr.module.smart.common.po.BizMpPublishLogPO;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+/**
+ * biz_mp_publish_logMapper接口
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:28
+ **/
+@Repository
+@Mapper
+public interface BizMpPublishLogRepository extends BaseMapper<BizMpPublishLogPO> {
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/repository/BizMpPublishTaskRepository.java

@@ -0,0 +1,16 @@
+package cn.tr.module.smart.common.repository;
+
+import cn.tr.module.smart.common.po.BizMpPublishTaskPO;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+/**
+ * 公众号推送任务表Mapper接口
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:29
+ **/
+@Repository
+@Mapper
+public interface BizMpPublishTaskRepository extends BaseMapper<BizMpPublishTaskPO> {
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/service/IBizMpPublishLogService.java

@@ -0,0 +1,55 @@
+package cn.tr.module.smart.common.service;
+
+import cn.tr.module.smart.common.dto.BizMpPublishLogDTO;
+import cn.tr.module.smart.common.dto.BizMpPublishLogQueryDTO;
+
+import java.util.*;
+
+/**
+ * biz_mp_publish_logService接口
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:28
+ **/
+public interface IBizMpPublishLogService{
+
+    /**
+     * 根据条件查询biz_mp_publish_log
+     * @param    query 查询参数
+     * @author   wangzl
+     * @date      2025/07/25 08:28
+     */
+    List<BizMpPublishLogDTO> selectBizMpPublishLogList(BizMpPublishLogQueryDTO query);
+
+    /**
+     * 根据id查询biz_mp_publish_log
+     * @param    id 主键id
+     * @author   wangzl
+     * @date      2025/07/25 08:28
+     */
+    BizMpPublishLogDTO selectBizMpPublishLogById(String id);
+
+    /**
+     * 编辑biz_mp_publish_log
+     * @param   source 编辑实体类
+     * @author  wangzl
+     * @date     2025/07/25 08:28
+     */
+    boolean updateBizMpPublishLogById(BizMpPublishLogDTO source);
+
+    /**
+     * 新增biz_mp_publish_log
+     * @param   source 新增实体类
+     * @author wangzl
+     * @date  2025/07/25 08:28
+     */
+    boolean insertBizMpPublishLog(BizMpPublishLogDTO source);
+
+    /**
+     * 删除biz_mp_publish_log详情
+     * @param  ids 删除主键集合
+     * @author wangzl
+     * @date    2025/07/25 08:28
+     */
+    int removeBizMpPublishLogByIds(Collection<String> ids);
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/service/IBizMpPublishTaskService.java

@@ -0,0 +1,57 @@
+package cn.tr.module.smart.common.service;
+
+
+import cn.tr.module.smart.common.dto.BizMpPublishTaskDTO;
+import cn.tr.module.smart.common.dto.BizMpPublishTaskQueryDTO;
+
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * 公众号推送任务表Service接口
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:29
+ **/
+public interface IBizMpPublishTaskService{
+
+    /**
+     * 根据条件查询公众号推送任务表
+     * @param    query 查询参数
+     * @author   wangzl
+     * @date      2025/07/25 08:29
+     */
+    List<BizMpPublishTaskDTO> selectBizMpPublishTaskList(BizMpPublishTaskQueryDTO query);
+
+    /**
+     * 根据id查询公众号推送任务表
+     * @param    id 主键id
+     * @author   wangzl
+     * @date      2025/07/25 08:29
+     */
+    BizMpPublishTaskDTO selectBizMpPublishTaskById(String id);
+
+    /**
+     * 编辑公众号推送任务表
+     * @param   source 编辑实体类
+     * @author  wangzl
+     * @date     2025/07/25 08:29
+     */
+    boolean updateBizMpPublishTaskById(BizMpPublishTaskDTO source);
+
+    /**
+     * 新增公众号推送任务表
+     * @param   source 新增实体类
+     * @author wangzl
+     * @date  2025/07/25 08:29
+     */
+    boolean insertBizMpPublishTask(BizMpPublishTaskDTO source);
+
+    /**
+     * 删除公众号推送任务表详情
+     * @param  ids 删除主键集合
+     * @author wangzl
+     * @date    2025/07/25 08:29
+     */
+    int removeBizMpPublishTaskByIds(Collection<String> ids);
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/service/impl/BizMpPublishLogServiceImpl.java

@@ -0,0 +1,94 @@
+package cn.tr.module.smart.common.service.impl;
+
+import cn.hutool.core.collection.CollectionUtil;
+import cn.tr.core.exception.ServiceException;
+import cn.tr.core.exception.TRExcCode;
+import cn.tr.module.smart.common.dto.BizMpPublishLogDTO;
+import cn.tr.module.smart.common.dto.BizMpPublishLogQueryDTO;
+import cn.tr.module.smart.common.mapper.BizMpPublishLogMapper;
+import cn.tr.module.smart.common.po.BizMpPublishLogPO;
+import cn.tr.module.smart.common.repository.BizMpPublishLogRepository;
+import cn.tr.module.smart.common.service.IBizMpPublishLogService;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Collection;
+import java.util.List;
+/**
+ * biz_mp_publish_logService接口实现类
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:28
+ **/
+@Service
+public class BizMpPublishLogServiceImpl implements IBizMpPublishLogService {
+    @Autowired
+    private BizMpPublishLogRepository baseRepository;
+
+
+    /**
+    * 根据条件查询biz_mp_publish_log
+    * @param    query 查询参数
+    * @author   wangzl
+    * @date      2025/07/25 08:28
+    */
+    @Override
+    public List<BizMpPublishLogDTO> selectBizMpPublishLogList(BizMpPublishLogQueryDTO query){
+        return BizMpPublishLogMapper.INSTANCE.convertDtoList(
+                baseRepository.selectList(new LambdaQueryWrapper<BizMpPublishLogPO>()
+                )
+        );
+    };
+
+    /**
+    * 根据id查询biz_mp_publish_log
+    * @param    id 主键id
+    * @author   wangzl
+    * @date      2025/07/25 08:28
+    */
+    @Override
+    public BizMpPublishLogDTO selectBizMpPublishLogById(String id){
+        return BizMpPublishLogMapper.INSTANCE.convertDto(baseRepository.selectById(id));
+    };
+
+    /**
+    * 编辑biz_mp_publish_log
+    * @param   source 编辑实体类
+    * @author  wangzl
+    * @date     2025/07/25 08:28
+    */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public boolean updateBizMpPublishLogById(BizMpPublishLogDTO source){
+            return baseRepository.updateById(BizMpPublishLogMapper.INSTANCE.convertPO(source))!=0;
+    };
+
+    /**
+    * 新增biz_mp_publish_log
+    * @param   source 新增实体类
+    * @author wangzl
+    * @date  2025/07/25 08:28
+    */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public boolean insertBizMpPublishLog(BizMpPublishLogDTO source){
+        return baseRepository.insert(BizMpPublishLogMapper.INSTANCE.convertPO(source))!=0;
+    };
+
+    /**
+    * 删除biz_mp_publish_log详情
+    * @param  ids 删除主键集合
+    * @author wangzl
+    * @date    2025/07/25 08:28
+    */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public int removeBizMpPublishLogByIds(Collection<String> ids){
+        if(CollectionUtil.isEmpty(ids)){
+            throw new ServiceException(TRExcCode.SYSTEM_ERROR_B0001,"请选择要删除的数据");
+        }
+        return baseRepository.deleteBatchIds(ids);
+    };
+}

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/service/impl/BizMpPublishTaskServiceImpl.java

@@ -0,0 +1,94 @@
+package cn.tr.module.smart.common.service.impl;
+
+import cn.hutool.core.collection.CollectionUtil;
+import cn.tr.core.exception.ServiceException;
+import cn.tr.core.exception.TRExcCode;
+import cn.tr.module.smart.common.dto.BizMpPublishTaskDTO;
+import cn.tr.module.smart.common.dto.BizMpPublishTaskQueryDTO;
+import cn.tr.module.smart.common.mapper.BizMpPublishTaskMapper;
+import cn.tr.module.smart.common.po.BizMpPublishTaskPO;
+import cn.tr.module.smart.common.repository.BizMpPublishTaskRepository;
+import cn.tr.module.smart.common.service.IBizMpPublishTaskService;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Collection;
+import java.util.List;
+/**
+ * 公众号推送任务表Service接口实现类
+ *
+ * @author wangzl
+ * @date  2025/07/25 08:29
+ **/
+@Service
+public class BizMpPublishTaskServiceImpl implements IBizMpPublishTaskService {
+    @Autowired
+    private BizMpPublishTaskRepository baseRepository;
+
+
+    /**
+    * 根据条件查询公众号推送任务表
+    * @param    query 查询参数
+    * @author   wangzl
+    * @date      2025/07/25 08:29
+    */
+    @Override
+    public List<BizMpPublishTaskDTO> selectBizMpPublishTaskList(BizMpPublishTaskQueryDTO query){
+        return BizMpPublishTaskMapper.INSTANCE.convertDtoList(
+                baseRepository.selectList(new LambdaQueryWrapper<BizMpPublishTaskPO>()
+                )
+        );
+    };
+
+    /**
+    * 根据id查询公众号推送任务表
+    * @param    id 主键id
+    * @author   wangzl
+    * @date      2025/07/25 08:29
+    */
+    @Override
+    public BizMpPublishTaskDTO selectBizMpPublishTaskById(String id){
+        return BizMpPublishTaskMapper.INSTANCE.convertDto(baseRepository.selectById(id));
+    };
+
+    /**
+    * 编辑公众号推送任务表
+    * @param   source 编辑实体类
+    * @author  wangzl
+    * @date     2025/07/25 08:29
+    */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public boolean updateBizMpPublishTaskById(BizMpPublishTaskDTO source){
+            return baseRepository.updateById(BizMpPublishTaskMapper.INSTANCE.convertPO(source))!=0;
+    };
+
+    /**
+    * 新增公众号推送任务表
+    * @param   source 新增实体类
+    * @author wangzl
+    * @date  2025/07/25 08:29
+    */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public boolean insertBizMpPublishTask(BizMpPublishTaskDTO source){
+        return baseRepository.insert(BizMpPublishTaskMapper.INSTANCE.convertPO(source))!=0;
+    };
+
+    /**
+    * 删除公众号推送任务表详情
+    * @param  ids 删除主键集合
+    * @author wangzl
+    * @date    2025/07/25 08:29
+    */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public int removeBizMpPublishTaskByIds(Collection<String> ids){
+        if(CollectionUtil.isEmpty(ids)){
+            throw new ServiceException(TRExcCode.SYSTEM_ERROR_B0001,"请选择要删除的数据");
+        }
+        return baseRepository.deleteBatchIds(ids);
+    };
+}