1.涨停涨跌默认 0—— qlm

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

@@ -91,8 +91,8 @@ public class ChoiceBondServiceImpl implements ChoiceBondService {
                     stockRestPojo.setTradestatus("");
                     stockRestPojo.setOutvolume("");
                     stockRestPojo.setInvolume("");
-                    stockRestPojo.setHighlimit("");
-                    stockRestPojo.setLowlimit("");
+                    stockRestPojo.setHighlimit("0");
+                    stockRestPojo.setLowlimit("0");
                     stockRestPojo.setSpeed("");
                     stockRestPojo.setAverageprice("");
 
@@ -123,12 +123,13 @@ public class ChoiceBondServiceImpl implements ChoiceBondService {
                     if (StringUtils.isEmpty(stockRestPojo.getTime())) {
                         dateStr = dateStr.append(000000);
                     } else {
-                        if (5 == stockRestPojo.getTime().length()) {
-                            // 长度为5表示 小时前面需要补0
-                            dateStr = dateStr.append(0).append(stockRestPojo.getTime());
-                        } else {
-                            dateStr = dateStr.append(stockRestPojo.getTime());
-                        }
+                        dateStr.append( String.format("%06d", Integer.parseInt(stockRestPojo.getTime())));
+//                        if (5 == stockRestPojo.getTime().length()) {
+//                            // 长度为5表示 小时前面需要补0
+//                            dateStr = dateStr.append(0).append(stockRestPojo.getTime());
+//                        } else {
+//                            dateStr = dateStr.append(stockRestPojo.getTime());
+//                        }
                     }
                     Date date = TimeUtil.strToDate(dateStr.toString());
                     // 毫秒转成秒

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

@@ -126,12 +126,13 @@ public class ChoiceStockServiceImpl implements ChoiceStockService {
                     if (StringUtils.isEmpty(stockRestPojo.getTime())) {
                         dateStr = dateStr.append(000000);
                     } else {
-                        if (5 == stockRestPojo.getTime().length()) {
-                            // 长度为5表示 小时前面需要补0
-                            dateStr = dateStr.append(0).append(stockRestPojo.getTime());
-                        } else {
-                            dateStr = dateStr.append(stockRestPojo.getTime());
-                        }
+                        dateStr.append( String.format("%06d", Integer.parseInt(stockRestPojo.getTime())));
+//                        if (5 == stockRestPojo.getTime().length()) {
+//                            // 长度为5表示 小时前面需要补0
+//                            dateStr = dateStr.append(0).append(stockRestPojo.getTime());
+//                        } else {
+//                            dateStr = dateStr.append(stockRestPojo.getTime());
+//                        }
                     }
                     Date date = TimeUtil.strToDate(dateStr.toString());
                     // 毫秒转成秒

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

@@ -103,8 +103,8 @@ public class ChoiceTempIndexServiceImpl implements ChoiceTempIndexService {
                     stockRestPojo.setTradestatus("");
                     stockRestPojo.setOutvolume("");
                     stockRestPojo.setInvolume("");
-                    stockRestPojo.setHighlimit("");
-                    stockRestPojo.setLowlimit("");
+                    stockRestPojo.setHighlimit("0");
+                    stockRestPojo.setLowlimit("0");
                     stockRestPojo.setAverageprice("");
                     stockRestPojo.setBuyprice1("");
                     stockRestPojo.setBuyprice2("");
@@ -133,12 +133,13 @@ public class ChoiceTempIndexServiceImpl implements ChoiceTempIndexService {
                     if (StringUtils.isEmpty(stockRestPojo.getTime())) {
                         dateStr = dateStr.append(000000);
                     } else {
-                        if (5 == stockRestPojo.getTime().length()) {
-                            // 长度为5表示 小时前面需要补0
-                            dateStr = dateStr.append(0).append(stockRestPojo.getTime());
-                        } else {
-                            dateStr = dateStr.append(stockRestPojo.getTime());
-                        }
+                        dateStr.append( String.format("%06d", Integer.parseInt(stockRestPojo.getTime())));
+//                        if (5 == stockRestPojo.getTime().length()) {
+//                            // 长度为5表示 小时前面需要补0
+//                            dateStr = dateStr.append(0).append(stockRestPojo.getTime());
+//                        } else {
+//                            dateStr = dateStr.append(stockRestPojo.getTime());
+//                        }
                     }
                     Date date = TimeUtil.strToDate(dateStr.toString());
                     // 毫秒转成秒
@@ -501,8 +502,9 @@ public class ChoiceTempIndexServiceImpl implements ChoiceTempIndexService {
         tableName.append(valueArr[0].replace(".", "_").toLowerCase());
         tableName.append("_"+keyArr[0]);
         if("1".equals(valueArr[4])){ // 如果此时没有开启风控 那么不变化
-            stockRestPojo.setTableName(tableName.toString());
-            return stockRestPojo;
+            StockRestPojo stockRestPojoNew = new StockRestPojo();
+            stockRestPojoNew.setTableName(tableName.toString());
+            return stockRestPojoNew;
         }else {
             String tocode = valueArr[0];  // 新币
             String mini = valueArr[1];// 最小波动

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

@@ -26,7 +26,7 @@ public class AnalysisHisDataTask {
     }
 
     /**
-     * 凌晨6点处理指数风控
+     * 凌晨6点处理指数风控历史数据
      */
     @Scheduled(cron = "0 30 6 * * ? ")
     public void toAnalysisHistData() {