From bd885c7015446c6c0495d3299ef64068a4c9b30e Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 16 十月 2024 15:00:34 +0800 Subject: [PATCH] CMQ改造为rabbitmq --- facade-push/src/main/java/com/ks/push/pojo/DO/BPushTask.java | 56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 54 insertions(+), 2 deletions(-) diff --git a/facade-push/src/main/java/com/ks/push/pojo/DO/BPushTask.java b/facade-push/src/main/java/com/ks/push/pojo/DO/BPushTask.java index df626b3..33ed13f 100644 --- a/facade-push/src/main/java/com/ks/push/pojo/DO/BPushTask.java +++ b/facade-push/src/main/java/com/ks/push/pojo/DO/BPushTask.java @@ -1,16 +1,68 @@ package com.ks.push.pojo.DO; -import java.util.Date; +import org.springframework.data.annotation.Id; -public class BPushTask { +import javax.validation.constraints.NotEmpty; +import javax.validation.constraints.NotNull; +import java.io.Serializable; +import java.util.Date; +import java.util.UUID; + +public class BPushTask implements Serializable { + + //杩樻湭寮�濮嬫帹閫� + public final static int STATE_NOT_START = 0; + + //鎺ㄩ�佷腑 + public final static int STATE_PUSHING = 1; + + //鎺ㄩ�佽鍙栨秷 + public final static int STATE_CANCELED = 2; + + //鏆傚仠鎺ㄩ�� + public final static int STATE_PAUSED = 3; + + //鎺ㄩ�佺粨鏉� + public final static int STATE_FINSIH = 5; + + + @Id private String id; + @NotEmpty(message = "搴旂敤鏍囪瘑涓嶈兘涓虹┖") private String appCode; + /** + * 鎺ㄩ�佺殑鐘舵�� + */ + private Integer state; + private String stateDesc; + @NotNull(message = "鎺ㄩ�佹潯浠朵笉鑳戒负绌�") private BPushFilter filter; + @NotNull(message = "鎺ㄩ�佸唴瀹逛笉鑳戒负绌�") private BPushMessage message; private Date createTime; private Date updateTime; + public static String createId() { + return UUID.randomUUID().toString(); + } + + public String getStateDesc() { + return stateDesc; + } + + public void setStateDesc(String stateDesc) { + this.stateDesc = stateDesc; + } + + public Integer getState() { + return state; + } + + public void setState(Integer state) { + this.state = state; + } + public String getId() { return id; } -- Gitblit v1.8.0