定时任务完善

sapi/src/main/java/com/xhkjedu/sapi/interceptors/RequestInterceptor.java

@@ -2,6 +2,7 @@ package com.xhkjedu.sapi.interceptors;
 
 import com.alibaba.fastjson.JSON;
 import com.xhkjedu.config.MissingParametersException;
+import com.xhkjedu.sapi.utils.ApiUtil;
 import com.xhkjedu.sapi.utils.JedisUtil;
 import com.xhkjedu.utils.N_Utils;
 import com.xhkjedu.vo.ResultVo;
@@ -83,7 +84,7 @@ public class RequestInterceptor extends JedisUtil implements HandlerInterceptor
                 encoding = "UTF-8";
             }
             String params = new String(buffer, encoding);
-            Map<String, String> uriMap = new ConcurrentHashMap<>();;
+            Map<String, String> uriMap = ApiUtil.uriMap;
             String params2 = uriMap.get(requestURI);
             if (N_Utils.isNotEmpty(params2) && params2.equals(params)) {
                 log.error("地址：{}，参数：{}",requestURI,params);

sapi/src/main/java/com/xhkjedu/sapi/task/UriMapTask.java

@@ -0,0 +1,49 @@
+package com.xhkjedu.sapi.task;
+
+import com.xhkjedu.sapi.utils.ApiUtil;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * @author ywx
+ * @classname ReadTask
+ * @description 阅读定时任务
+ * CronTrigger配置完整格式为： [秒] [分] [小时] [日] [月] [周] [年]
+ * 说明    必填    值                  允许的通配符
+ * 秒        是    0-59                , - * /
+ * 分        是    0-59                , - * /
+ * 时        是    0-23                , - * /
+ * 日        是    1-31                , - * ? / L W
+ * 月        是    1-12或JAN-DEC       , - * /
+ * 周        是    1-7或SUN-SAT        , - * ? / L W
+ * 年        否    empty 或1970-2099   , - * /
+ * , 表示指定多个值，例如在周字段上设置 "MON,WED,FRI" 表示周一，周三和周五触发
+ * - 表示区间。例如 在小时上设置 "10-12",表示 10,11,12点都会触发。
+ * * 表示所有值. 例如:在分的字段上设置 "*",表示每一分钟都会触发
+ * ? 表示不指定值。使用的场景为不需要关心当前设置这个字段的值。每月的10号触发一个操作，但不关心是周几,具体设置为 0 0 0 10 * ?
+ * / 用于递增触发。如在秒上面设置"5/15" 表示从5秒开始，每增15秒触发(5,20,35,50)
+ * L 表示最后的意思。在日字段设置上，表示当月的最后一天(依据当前月份，如果是二月还会依据是否是润年[leap]),
+ * 在周字段上表示星期六，相当于"7"或"SAT(不区分大小写)"。
+ * 如果在"L"前加上数字，则表示该数据的最后一个。例如在周字段上设置"6L"这样的格式,则表示“本月最后一个星期五"
+ * W 表示离指定日期的最近那个工作日(周一至周五). 例如在日字段上设置"15W"，表示离每月15号最近的那个工作日触发。
+ * 如果15号正好是周六，则找最近的周五(14号)触发, 如果15号是周未，则找最近的下周一(16号)触发.
+ * 如果15号正好在工作日(周一至周五)，则就在该天触发。(注，"W"前只能设置具体的数字,不允许区间"-").
+ * @date 2020/9/1 9:36
+ **/
+@Component
+public class UriMapTask {
+
+    /**
+     * 每隔3s清除一下请求地址map
+     * @Param []
+     * @Author ywx
+     * @Date 2020/11/9 12:30
+     * @return void
+     **/
+    @Scheduled(cron = "${cron.deleteUriMap}")
+    public void deleteUriMap() {
+        ApiUtil.uriMap = new ConcurrentHashMap<>();
+    }
+}

sapi/src/main/java/com/xhkjedu/sapi/utils/ApiUtil.java

@@ -12,6 +12,8 @@ import org.springframework.web.client.RestTemplate;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
 import static com.xhkjedu.utils.N_Utils.getSecondTimestamp;
 
@@ -24,6 +26,7 @@ import static com.xhkjedu.utils.N_Utils.getSecondTimestamp;
 @Slf4j
 public class ApiUtil {
     public static Integer id = 0;
+    public static Map<String, String> uriMap = new ConcurrentHashMap<>();
 
     //获取id
     public static String getId(){

sapi/src/main/resources/application.properties

@@ -93,8 +93,8 @@ dbname=xhkjedu_school_test
 nummin=10000
 nummax=50000
 numadd=100000000
-#一次同步数量
-cron.syncnum=100
+
+#定时任务
 #默认为false，不开启定时任务
 enable.scheduled=false
 #周一的凌晨2:00触发生成班级周报
@@ -103,7 +103,8 @@ cron.classReportWeek=0 0 2 ? * MON
 cron.classReportMonth=0 0 3 1 * ?
 #周日的凌晨3:00同步基础信息
 cron.synctime=0 0 3 ? * SUN
-#一次同步数量
+#每隔3s清除一下请求地址map
+cron.deleteUriMap=0/3 * * * * ?
 
 #版本号
 versionname=Test_v3.2.0

sclass/src/main/resources/application.properties

@@ -53,10 +53,10 @@ redisdatatime=604800
 secretKey=nanhuakaizhangjianwangni
 
 #定时任务
-#每隔3s清除一下请求地址map
-cron.deleteUriMap=0/3 * * * * ?
 #默认为false，不开启定时任务
 enable.scheduled=false
+#每隔3s清除一下请求地址map
+cron.deleteUriMap=0/3 * * * * ?
 
 #版本号
 versionname=Test_v3.2.0

slive/src/main/resources/application.properties

@@ -87,14 +87,14 @@ agora.license.key=2cb21d4aadb44dbca60263df0ab9213d
 agora.license.secret=e2439c74719940649aa754ef8c79369d
 
 #定时任务
+#默认为false，不开启定时任务
+enable.scheduled=false
 #每隔1分钟修改课节状态
 cron.updateSectionState=0 0/1 * * * ?
 #每天凌晨处理未释放的授权
 cron.updateLicense=0 0 0 * * ?
 #每隔1小时修改license状态
 cron.updateLicenseState=0 0 0/1 * * ?
-#默认为false，不开启定时任务
-enable.scheduled=false
 
 #版本号
 versionname=Test_v3.2.0

sstudy/src/main/java/com/xhkjedu/sstudy/interceptors/RequestInterceptor.java

@@ -3,6 +3,7 @@ package com.xhkjedu.sstudy.interceptors;
 import com.alibaba.fastjson.JSON;
 import com.xhkjedu.config.MissingParametersException;
 import com.xhkjedu.sstudy.utils.JedisUtil;
+import com.xhkjedu.sstudy.utils.StudyUtil;
 import com.xhkjedu.utils.N_Utils;
 import com.xhkjedu.vo.ResultVo;
 import lombok.extern.slf4j.Slf4j;
@@ -83,7 +84,7 @@ public class RequestInterceptor extends JedisUtil implements HandlerInterceptor
                 encoding = "UTF-8";
             }
             String params = new String(buffer, encoding);
-            Map<String, String> uriMap =new ConcurrentHashMap<>();
+            Map<String, String> uriMap = StudyUtil.uriMap;
             String params2 = uriMap.get(requestURI);
             if (N_Utils.isNotEmpty(params2) && params2.equals(params)) {
                 log.error("地址：{}，参数：{}",requestURI,params);
@@ -92,9 +93,6 @@ public class RequestInterceptor extends JedisUtil implements HandlerInterceptor
                 uriMap.put(requestURI, params);
             }
         }
-       /* if("dev".equals(ConfigKey.env)){//开发环境接口不拦截
-            return true;
-        }*/
         return true;
     }
 

sstudy/src/main/java/com/xhkjedu/sstudy/task/UriMapTask.java

@@ -0,0 +1,49 @@
+package com.xhkjedu.sstudy.task;
+
+import com.xhkjedu.sstudy.utils.StudyUtil;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * @author ywx
+ * @classname ReadTask
+ * @description 阅读定时任务
+ * CronTrigger配置完整格式为： [秒] [分] [小时] [日] [月] [周] [年]
+ * 说明    必填    值                  允许的通配符
+ * 秒        是    0-59                , - * /
+ * 分        是    0-59                , - * /
+ * 时        是    0-23                , - * /
+ * 日        是    1-31                , - * ? / L W
+ * 月        是    1-12或JAN-DEC       , - * /
+ * 周        是    1-7或SUN-SAT        , - * ? / L W
+ * 年        否    empty 或1970-2099   , - * /
+ * , 表示指定多个值，例如在周字段上设置 "MON,WED,FRI" 表示周一，周三和周五触发
+ * - 表示区间。例如 在小时上设置 "10-12",表示 10,11,12点都会触发。
+ * * 表示所有值. 例如:在分的字段上设置 "*",表示每一分钟都会触发
+ * ? 表示不指定值。使用的场景为不需要关心当前设置这个字段的值。每月的10号触发一个操作，但不关心是周几,具体设置为 0 0 0 10 * ?
+ * / 用于递增触发。如在秒上面设置"5/15" 表示从5秒开始，每增15秒触发(5,20,35,50)
+ * L 表示最后的意思。在日字段设置上，表示当月的最后一天(依据当前月份，如果是二月还会依据是否是润年[leap]),
+ * 在周字段上表示星期六，相当于"7"或"SAT(不区分大小写)"。
+ * 如果在"L"前加上数字，则表示该数据的最后一个。例如在周字段上设置"6L"这样的格式,则表示“本月最后一个星期五"
+ * W 表示离指定日期的最近那个工作日(周一至周五). 例如在日字段上设置"15W"，表示离每月15号最近的那个工作日触发。
+ * 如果15号正好是周六，则找最近的周五(14号)触发, 如果15号是周未，则找最近的下周一(16号)触发.
+ * 如果15号正好在工作日(周一至周五)，则就在该天触发。(注，"W"前只能设置具体的数字,不允许区间"-").
+ * @date 2020/9/1 9:36
+ **/
+@Component
+public class UriMapTask {
+
+    /**
+     * 每隔3s清除一下请求地址map
+     * @Param []
+     * @Author ywx
+     * @Date 2020/11/9 12:30
+     * @return void
+     **/
+    @Scheduled(cron = "${cron.deleteUriMap}")
+    public void deleteUriMap() {
+        StudyUtil.uriMap = new ConcurrentHashMap<>();
+    }
+}

sstudy/src/main/java/com/xhkjedu/sstudy/utils/StudyUtil.java

@@ -12,6 +12,8 @@ import org.springframework.web.client.RestTemplate;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
 import static com.xhkjedu.utils.N_Utils.getSecondTimestamp;
 
@@ -24,6 +26,7 @@ import static com.xhkjedu.utils.N_Utils.getSecondTimestamp;
 @Slf4j
 public class StudyUtil {
     public static Integer id = 0;
+    public static Map<String, String> uriMap = new ConcurrentHashMap<>();
 
     //获取id
     public static String getId(){

sstudy/src/main/resources/application.properties

@@ -78,12 +78,14 @@ spring.rabbitmq.listener.simple.default-requeue-rejected=false
 nummin=10000
 nummax=50000
 numadd=100000000
-#一次同步数量
-cron.syncnum=100
+
+#定时任务
 #默认为false，不开启定时任务
 enable.scheduled=false
 #每隔1分钟修改学生作业是否显示答案
-cron.updatePaperStuShowanswer=* */1 * * * ?
+cron.updatePaperStuShowanswer=0 0/1 * * * ?
+#每隔3s清除一下请求地址map
+cron.deleteUriMap=0/3 * * * * ?
 
 #云平台接口地址
 cloudapi=http://scapitest.xhkjedu.com/