初始化

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

@@ -162,7 +162,7 @@ public class ChoiceBondServiceImpl implements ChoiceBondService {
                     }
                     StringBuffer tableName = new StringBuffer("data_rt_");
                     tableName.append(entry.getKey().replace(".", "_").toLowerCase());
-                    stockRestPojo.setCode(entry.getKey().toLowerCase());
+                    stockRestPojo.setCode(entry.getKey().toUpperCase());
                     stockRestPojo.setTableName(tableName.toString());
                     stockRestPojoList.add(stockRestPojo);
                     stockRestVO = new StockRestVO();

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

@@ -161,7 +161,7 @@ public class ChoiceStockServiceImpl implements ChoiceStockService {
                     }
                     StringBuffer tableName = new StringBuffer("data_rt_");
                     tableName.append(entry.getKey().replace(".", "_").toLowerCase());
-                    stockRestPojo.setCode(entry.getKey().toLowerCase());
+                    stockRestPojo.setCode(entry.getKey().toUpperCase());
                     stockRestPojo.setTableName(tableName.toString());
                     stockRestPojoList.add(stockRestPojo);
                     stockRestVO = new StockRestVO();
@@ -201,8 +201,7 @@ public class ChoiceStockServiceImpl implements ChoiceStockService {
             Thread thread=new Thread(new Runnable() {
                 @Override
                 public void run() {
-                    String returnStr = HttpRequest.httpPostWithjson(url, JSON.toJSONString(subList));
-                    log.info(returnStr);
+                   HttpRequest.httpPostWithjson(url, JSON.toJSONString(subList));
                 }
             });
             thread.start();

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

@@ -161,7 +161,7 @@ public class ChoiceTempIndexServiceImpl implements ChoiceTempIndexService {
                     }
                     StringBuffer tableName = new StringBuffer("data_rt_");
                     tableName.append(entry.getKey().replace(".", "_").toLowerCase());
-                    stockRestPojo.setCode(entry.getKey().toLowerCase());
+                    stockRestPojo.setCode(entry.getKey().toUpperCase());
                     stockRestPojo.setTableName(tableName.toString());
                     stockRestPojoList.add(stockRestPojo);
                     stockRestVO = new StockRestVO();

src/main/java/com/zx/dataservice/task/AnalysisBondRestDataTask.java

@@ -4,6 +4,8 @@ import com.zx.dataservice.service.ChoiceBondService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 /**
@@ -17,8 +19,8 @@ public class AnalysisBondRestDataTask {
     @Autowired
     private ChoiceBondService choiceBondService;
 
-//    @Async("executorBond")
-//    @Scheduled(fixedRate=10)
+    @Async("executorBond")
+    @Scheduled(fixedRate=10)
     public void toAnalysisRestData() {
         doTask();
     }

src/main/java/com/zx/dataservice/task/AnalysisTempIndexRestDataTask.java

@@ -4,6 +4,8 @@ import com.zx.dataservice.service.ChoiceTempIndexService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 /**
@@ -17,8 +19,8 @@ public class AnalysisTempIndexRestDataTask {
     @Autowired
     private ChoiceTempIndexService choiceTempIndexService;
 
-//    @Async("executorTempIndex")
-//    @Scheduled(fixedRate=100)
+    @Async("executorTempIndex")
+    @Scheduled(fixedRate=100)
     public void toAnalysisRestData() {
         doTask();
     }

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

@@ -16,7 +16,7 @@ public class PropertiesUtil {
     private static Properties props;
 
     static {
-        String fileName = "application-dev.properties";
+        String fileName = "application-real.properties";
         props = new Properties();
         try {
             props.load(new InputStreamReader(PropertiesUtil.class.getClassLoader().getResourceAsStream(fileName), "UTF-8"));