消息优化

cloud-core/src/main/java/com/yizhi/core/application/publish/PublicSendMessageClient.java

+package com.yizhi.core.application.publish;
+
+import com.yizhi.core.application.event.EventWrapper;
+import com.yizhi.core.application.vo.MessageRemindVo;
+import io.swagger.annotations.Api;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+/**
+ * com.yizhi.core.application.publish
+ *
+ * @author yanglang
+ * @create 2025-02-19 15:19:33
+ */
+@Api(tags = "管理端用户消息接口")
+@FeignClient(name = "newMessage", contextId = "PublicSendMessageClient")
+public interface PublicSendMessageClient {
+
+    @PostMapping("/remote/manage/messageAccount/processBizEvent")
+    void processBizEvent(@RequestBody EventWrapper<MessageRemindVo> ew);
+}

cloud-core/src/main/java/com/yizhi/core/application/vo/EvenType.java

+package com.yizhi.core.application.vo;
+
+import java.util.Arrays;
+import java.util.List;
+
+/**
+ *
+ */
+
+public enum EvenType {
+
+    COURSE_UP(1L,Arrays.asList(1,2)),//"课程上架通知"
+    COURSE_FINISH(2L, Arrays.asList(1,2)),//课程完成通知
+    ENROLL_START(3L, Arrays.asList(1,3,4,5)),//报名开始
+    TRAINING_AUDIT_PASS(4L, Arrays.asList(1,3,4,5)),//项目审核通过通知
+    TRAINING_AUDIT_FAIL(5L, Arrays.asList(1,3,4,5)),//项目审核不通过通知
+    SIGN_SUCCESS(6L, Arrays.asList(1,3,4,5)),//签到成功通知
+    TRAINING_FINISH(7L, Arrays.asList(1,3,4,5)),//项目完成通知
+    ASSIGNMENT_AUDIT_FINISH(8L, Arrays.asList(1,6,7,8)),//作业已被批阅通知
+    EXAM_AUDIT_FINISH(9L, Arrays.asList(1,9,10,11)),//考试已被批阅通知
+    POINT_CHANGE(10L, Arrays.asList(1,12,13,14));//积分变动原因
+
+
+    //数据库message表的id
+    private Long key;
+
+    //数据库message_parameter表的field_type
+    private List<Integer> fieldType;
+
+    private EvenType(Long key, List<Integer> fieldType) {
+        this.key = key;
+        this.fieldType = fieldType;
+    }
+
+    public Long getKey() {
+        return key;
+    }
+
+    public List<Integer> getName() {
+        return fieldType;
+    }
+
+}

cloud-core/src/main/java/com/yizhi/core/application/vo/MessageRemindVo.java

+package com.yizhi.core.application.vo;
+
+import com.yizhi.core.application.context.RequestContext;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author hutao123
+ * @since 2019-09-09
+ */
+@Data
+@Api(tags = "MessageRemindVo", description = "各个业务设置提醒时的数据")
+public class MessageRemindVo implements Serializable {
+    private static final long serialVersionUID  = 1l;
+
+    @ApiModelProperty(value = "提醒id  ")
+    private Long id;
+
+    @ApiModelProperty(value = "消息id")
+    private Long messageId;
+
+    @ApiModelProperty(value = "消息类型：1、自定义消息；2、系统消息；3、事件触发消息")
+    private Integer messageType;
+
+    @ApiModelProperty(value = "用户id  主要用于触发消息 个人完成发消息类型")
+    private Long accountId;
+
+    @ApiModelProperty(value = "消息内容（完整版）")
+    private String messageContext;
+
+    @ApiModelProperty(value = "关联模块类型(1：学习计划、2：考试、3：调研、4、投票5：报名、6：作业、7：签到、8：项目、9：直播、10：积分)")
+    private Integer relationType;
+
+    @ApiModelProperty(value = "关联的业务id: 比如调研id")
+    private Long relationId;
+
+    @ApiModelProperty(value = "发送方式：1、站内信；2、短信；3、邮件")
+    private Integer sendType;
+
+    @ApiModelProperty(value = "该业务提醒是被关闭，关闭则为true，默认false")
+    private Boolean hasDeleted = false;
+
+    @ApiModelProperty(value = "该业务提醒是否有变化，有则为true，默认false")
+    private Boolean isChangge = false;
+
+    @ApiModelProperty(value = "专门存放提醒时间设置")
+    private List<MessageTaskRemindVo> messageTaskRemindVos = new ArrayList<>();
+
+    @ApiModelProperty(value = "目前只有培训项目需要，计划同步项目可见范围")
+    private Boolean visibleRangeUpdate = false;
+
+    @ApiModelProperty(value = "指定范围(0:全平台,1:指定用户)")
+    private Integer visibleRange;
+
+    @ApiModelProperty(value = "业务参数对象")
+    private TaskVo taskVo;
+
+    @ApiModelProperty(value = "触发消息专用 发送时间")
+    private Date sendTime;
+
+    @ApiModelProperty(value = "是否设置为上架状态")
+    private Boolean hasUp = false;
+
+    @ApiModelProperty(value = "是否是 修改业务状态 ")
+    private Boolean taskStatusUpdate = false;
+
+    @ApiModelProperty(value = "业务状态  1：才允上架许发送（业务上架）0：不允许发送（业务非上架）  仅针对于系统消息")
+    private Integer taskStatus;
+
+    @ApiModelProperty(value = "上下文 必传，主要需要 siteId companyId accountId  accountName 都不能是空")
+    private RequestContext requestContext;
+
+    @ApiModelProperty(value = "调研是否为复制类型")
+    private Boolean isCopy = false;
+
+    @ApiModelProperty(value = "复制调研时，旧的调研id")
+    private Long oldRelationId;
+
+}

cloud-core/src/main/java/com/yizhi/core/application/vo/MessageTaskRemindVo.java

+package com.yizhi.core.application.vo;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author hutao123
+ * @since 2019-09-09
+ */
+@Data
+@Api(tags = "MessageTaskRemindVo", description = "各个业务设置提醒时的数据")
+public class MessageTaskRemindVo implements Serializable {
+
+    @ApiModelProperty(value = "待发消息id")
+    private Long messageRemindId;
+
+    @ApiModelProperty(value = "提醒时间事件类型 1：业务开始时间、 2：业务结束时间、3：自定义时间")
+    private Integer timeEventType;
+
+    @ApiModelProperty(value = "发生时间枚举：1：五分钟前、2：十分钟前、3：三十分钟前、4：一个小时前、5：两个小时前、6：一天前、7：两天前")
+    private Integer timeType;
+
+    @ApiModelProperty(value = "最终发送时间")
+    private Date sendTime;
+
+}

cloud-core/src/main/java/com/yizhi/core/application/vo/TaskVo.java

+package com.yizhi.core.application.vo;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * <p>
+ * 消息
+ * </p>
+ *
+ * @author hutao123
+ * @since 2019-09-09
+ */
+@Data
+@Api(tags = "TaskVo", description = "业务参数对象")
+public class TaskVo implements Serializable {
+
+
+    @ApiModelProperty(value = "业务名称")
+    private String taskName;
+
+    @ApiModelProperty(value = "业务开始时间")
+    private Date taskStratTime;
+
+    @ApiModelProperty(value = "业务结束时间")
+    private Date taskEndTime;
+
+    @ApiModelProperty(value = "业务得分")
+    private Double taskScore;
+
+    @ApiModelProperty(value = "业务发生原因（主要用于积分）")
+    private String reason;
+
+    @ApiModelProperty(value = "业务时间（主要用于积分）")
+    private Date taskTime;
+
+    @ApiModelProperty(value = "事件类型")
+    private EvenType evenType;
+
+
+
+}