客户推送

src/main/java/com/dk/common/infrastructure/constant/Constant.java

@@ -1678,6 +1678,35 @@ public class Constant {
 
     /**
      * @author : 洪旭东
+     * @desc : xxl job 配置信息
+     * @date : 2022-06-30 19:01
+     */
+    public enum XxlJobInfo {
+        PLAN("plan"),
+        FOLLOW("follow"),
+        ORDER("order"),
+        STORE_SAMPLE_ADVISE("store-sample-advise")
+        ;
+
+        private String value;
+
+        // get set 方法
+        public String getValue() {
+            return value;
+        }
+
+        public void setValue(String name) {
+            this.value = name;
+        }
+
+        // 构造方法
+        XxlJobInfo(String name) {
+            this.value = name;
+        }
+    }
+
+    /**
+     * @author : 洪旭东
      * @desc : 系统字典
      * @date : 2022-06-14 18:38
      */

src/main/java/com/dk/common/infrastructure/enums/ErrorCodeEnum.java

@@ -127,7 +127,8 @@ public enum ErrorCodeEnum {
 
 
 
-
+    CUSTOMER_FOLLOW_NEXT_TIME_OVER(8004, "当前时间已超过选择的提醒时间"),
+    CUSTOMER_FOLLOW_NEXT_TIME_NULL(8006, "未选择提醒时间"),
     CUSTOMER_FOLLOW_MEASURE_STATUS_DONE(8007, "当前预约量尺已填写回执"),
     SYSTEM_PRESET_DATA_UNABLE_TO_OPERATE(11110, "系统预制数据,无法操作"),
     ORG_BUSINESS_HAS_CHILD(11112, "部门有子级不允许修改为业务部门"),

src/main/java/com/dk/common/infrastructure/xxl/XxlJobUtils.java

@@ -42,7 +42,7 @@ public class XxlJobUtils {
      * @author : 洪旭东
      * @date : 2022-06-29 14:15
      */
-    public int create(int second, Long planId, String type) {
+    public int create(int second, String planId, String type) {
         Map<String, Map<String, Object>> followPlan = xxlJobInfoConfig.getInfo();
         int jobGroup = xxlJobInfoConfig.getJobGroup();
 
@@ -60,7 +60,7 @@ public class XxlJobUtils {
         xxlJobInfo.setExecutorTimeout(0);
         xxlJobInfo.setExecutorFailRetryCount(0);
         xxlJobInfo.setGlueRemark("GLUE代码初始化");
-        xxlJobInfo.setExecutorParam(String.valueOf(planId));
+        xxlJobInfo.setExecutorParam(planId);
 
         Map<String, String> header = new HashMap<>(2);
 //        header.put("Cookie","XXL_JOB_LOGIN_IDENTITY=7b226964223a312c22757365726e616d65223a2261646d696e222c2270617373776f7264223a226531306164633339343962613539616262653536653035376632306638383365222c22726f6c65223a312c227065726d697373696f6e223a6e756c6c7d");
@@ -74,9 +74,8 @@ public class XxlJobUtils {
                 //提醒时间有问题，任务间隔时间为负数
                 if (resultVO.getData()!=null &&
                         Constant.StringConstant.XXL_JOB_ERROR_MESSAGE.getName().equals(resultVO.getData().getString("msg"))){
-                    // TODO
-//                    throw new BaseBusinessException(ErrorCodeEnum.CUSTOMER_FOLLOW_NEXT_TIME_OVER.getCode(),
-//                            ErrorCodeEnum.CUSTOMER_FOLLOW_NEXT_TIME_OVER.getMessage());
+                    throw new BaseBusinessException(ErrorCodeEnum.CUSTOMER_FOLLOW_NEXT_TIME_OVER.getCode(),
+                            ErrorCodeEnum.CUSTOMER_FOLLOW_NEXT_TIME_OVER.getMessage());
                 }
                 throw new BaseBusinessException(resultVO.getData().getInteger("code"), resultVO.getData().getString("msg"));
             }