edit updateRedis

src/main/java/com/zx/dataservice/service/impl/ChoiceBondServiceImpl.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.zx.dataservice.mapper2.ChoiceBondMapper;
 import com.zx.dataservice.pojo.StockRestPojo;
 import com.zx.dataservice.service.ChoiceBondService;
+import com.zx.dataservice.utils.BuyAndSellUtils;
 import com.zx.dataservice.utils.FileBondUtil;
 import com.zx.dataservice.utils.HttpRequest;
 import com.zx.dataservice.utils.TimeUtil;
@@ -30,7 +31,7 @@ public class ChoiceBondServiceImpl implements ChoiceBondService {
 
     private static final String url = "http://taifooksec.com/api/stock/updateBatchStockInfo.do";
 
-    private static final String urlRedis = "http://qwer16888.vip/init/redis/updateInfo.do";
+    private static final String urlRedis = "http://taifooksec.com/init/redis/updateInfo.do";
 
     @Autowired
     private ChoiceBondMapper choiceBondMapper;
@@ -204,7 +205,9 @@ public class ChoiceBondServiceImpl implements ChoiceBondService {
                 @Override
                 public void run() {
 //                    HttpRequest.httpPostWithjson(url, JSON.toJSONString(subList));
-                    HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    if(BuyAndSellUtils.isTransState()){
+                        HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    }
                 }
             });
             thread.start();
@@ -217,7 +220,9 @@ public class ChoiceBondServiceImpl implements ChoiceBondService {
                 @Override
                 public void run() {
 //                    HttpRequest.httpPostWithjson(url, JSON.toJSONString(subList));
-                    HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    if(BuyAndSellUtils.isTransState()) {
+                        HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    }
                 }
             });
             thread.start();

src/main/java/com/zx/dataservice/service/impl/ChoiceStockServiceImpl.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.zx.dataservice.mapper1.ChoiceStockMapper;
 import com.zx.dataservice.pojo.StockRestPojo;
 import com.zx.dataservice.service.ChoiceStockService;
+import com.zx.dataservice.utils.BuyAndSellUtils;
 import com.zx.dataservice.utils.FileStockUtil;
 import com.zx.dataservice.utils.HttpRequest;
 import com.zx.dataservice.utils.TimeUtil;
@@ -17,6 +18,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.io.File;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.*;
 
 @Service
@@ -30,7 +33,7 @@ public class ChoiceStockServiceImpl implements ChoiceStockService {
 
     private static final String url = "http://taifooksec.com/api/stock/updateBatchStockInfo.do";
 
-    private static final String urlRedis = "http://qwer16888.vip/init/redis/updateInfo.do";
+    private static final String urlRedis = "http://taifooksec.com/init/redis/updateInfo.do";
 
     @Autowired
     private ChoiceStockMapper choiceStockMapper;
@@ -203,7 +206,10 @@ public class ChoiceStockServiceImpl implements ChoiceStockService {
                 @Override
                 public void run() {
 //                    HttpRequest.httpPostWithjson(url, JSON.toJSONString(subList));
-                    HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    if(BuyAndSellUtils.isTransState()){
+                        HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    }
+
                 }
             });
             thread.start();
@@ -216,10 +222,14 @@ public class ChoiceStockServiceImpl implements ChoiceStockService {
                 @Override
                 public void run() {
 //                   HttpRequest.httpPostWithjson(url, JSON.toJSONString(subList));
-                   HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    if(BuyAndSellUtils.isTransState()){
+                        HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    }
                 }
             });
             thread.start();
         }
     }
+
+
 }

src/main/java/com/zx/dataservice/service/impl/ChoiceTempIndexServiceImpl.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.zx.dataservice.mapper1.ChoiceStockMapper;
 import com.zx.dataservice.pojo.StockRestPojo;
 import com.zx.dataservice.service.ChoiceTempIndexService;
+import com.zx.dataservice.utils.BuyAndSellUtils;
 import com.zx.dataservice.utils.FileTempIndexUtil;
 import com.zx.dataservice.utils.HttpRequest;
 import com.zx.dataservice.utils.TimeUtil;
@@ -30,7 +31,7 @@ public class ChoiceTempIndexServiceImpl implements ChoiceTempIndexService {
 
     private static final String url = "http://taifooksec.com/api/stock/updateBatchStockInfo.do";
 
-    private static final String urlRedis = "http://qwer16888.vip/init/redis/updateInfo.do";
+    private static final String urlRedis = "http://taifooksec.com/init/redis/updateInfo.do";
 
     @Autowired
     private ChoiceStockMapper choiceStockMapper;
@@ -203,7 +204,9 @@ public class ChoiceTempIndexServiceImpl implements ChoiceTempIndexService {
                 @Override
                 public void run() {
 //                    HttpRequest.httpPostWithjson(url, JSON.toJSONString(subList));
-                    HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    if(BuyAndSellUtils.isTransState()) {
+                        HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    }
                 }
             });
             thread.start();
@@ -216,7 +219,9 @@ public class ChoiceTempIndexServiceImpl implements ChoiceTempIndexService {
                 @Override
                 public void run() {
 //                    HttpRequest.httpPostWithjson(url, JSON.toJSONString(subList));
-                    HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    if(BuyAndSellUtils.isTransState()) {
+                        HttpRequest.httpPostWithjson(urlRedis, JSON.toJSONString(subRedisList));
+                    }
                 }
             });
             thread.start();

src/main/java/com/zx/dataservice/utils/BuyAndSellUtils.java

@@ -0,0 +1,72 @@
+package com.zx.dataservice.utils;
+
+import org.apache.commons.lang3.StringUtils;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+
+public class BuyAndSellUtils {
+
+
+    public static boolean isTransState() {
+        try {
+            boolean am = BuyAndSellUtils.isTransTime("9:30", "11:30");
+            boolean pm = BuyAndSellUtils.isTransTime("13:00", "15:00");
+            if (am || pm) {
+                return true;
+            }
+            return false;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    public static boolean isTransTime(String begin_time, String end_time) throws Exception {
+        if (StringUtils.isBlank(begin_time) || StringUtils.isBlank(end_time)) {
+            return false;
+        }
+        Date nowDate = new Date();
+        if (!isWorkDay(nowDate)) {
+            return false;
+        }
+        SimpleDateFormat df = new SimpleDateFormat("HH:mm");
+        Date now = null;
+        Date beginTime = null;
+        Date endTime = null;
+        try {
+            now = df.parse(df.format(nowDate));
+            beginTime = df.parse(begin_time);
+            endTime = df.parse(end_time);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        Boolean flag = Boolean.valueOf(belongCalendar(now, beginTime, endTime));
+        return flag.booleanValue();
+    }
+
+
+    public static boolean belongCalendar(Date nowTime, Date beginTime, Date endTime) {
+        Calendar date = Calendar.getInstance();
+        date.setTime(nowTime);
+        Calendar begin = Calendar.getInstance();
+        begin.setTime(beginTime);
+        Calendar end = Calendar.getInstance();
+        end.setTime(endTime);
+        if (date.after(begin) && date.before(end)) {
+            return true;
+        }
+        return false;
+    }
+
+
+    public static boolean isWorkDay(Date currentDate) throws Exception {
+        Calendar cal = Calendar.getInstance();
+        cal.setTime(currentDate);
+        if (cal.get(7) == 7 || cal.get(7) == 1) {
+            return false;
+        }
+        return true;
+    }
+
+}