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