瀏覽代碼

创建压测测试数据接口 存储数据为批量存储

miaolijing 3 年之前
父節點
當前提交
4e7fff687c

+ 2 - 0
src/main/java/com/persagy/apm/diagnose/indicatorrecord/service/IMonitorIndicatorRecordService.java

@@ -92,4 +92,6 @@ public interface IMonitorIndicatorRecordService {
     public void cleanAlarmConfigSendTime(CleanAlarmConfigDTO cleanAlarmConfigDTO);
 
     public void saveDeleterOrUpdateByPk(MonitorIndicatorRecord monitorIndicatorRecord) throws Exception;
+
+    void batchSaveMonitorIndicatorRecordList(List<MonitorIndicatorRecord> recordList)throws Exception;
 }

+ 7 - 0
src/main/java/com/persagy/apm/diagnose/indicatorrecord/service/impl/MonitorIndicatorRecordServiceImpl.java

@@ -336,6 +336,13 @@ public class MonitorIndicatorRecordServiceImpl implements IMonitorIndicatorRecor
     }
 
     @Override
+    public void batchSaveMonitorIndicatorRecordList(List<MonitorIndicatorRecord> recordList)throws Exception {
+        if (!CollectionUtils.isEmpty(recordList) && recordList.size() > 0){
+            coredao.save(recordList);
+        }
+    }
+
+    @Override
     public void saveDeleterOrUpdateByPk(MonitorIndicatorRecord monitorIndicatorRecord) throws Exception {
         MonitorIndicatorRecord query = new MonitorIndicatorRecord();
         query.setProject(monitorIndicatorRecord.getProject());

+ 3 - 1
src/main/java/com/persagy/apm/diagnose/maintenance/controller/MaintenanceController.java

@@ -73,6 +73,7 @@ public class MaintenanceController {
                         continue;
                     }
                     for (String infoCode : infoCodes) {
+                        List<MonitorIndicatorRecord> recordList = new ArrayList<>();
                         for (String objId : objIds) {
                             for (Date start = startDate; start.before(endDate);start = DateUtils.addMinutes(start,15)) {
                                 int num = (int) (Math.random()*100);
@@ -83,9 +84,10 @@ public class MaintenanceController {
                                 monitorIndicatorRecord.setMonitorIndicatorId(infoCode);
                                 monitorIndicatorRecord.setDataTime(start);
                                 monitorIndicatorRecord.setDataValue(Double.valueOf(num));
-                                monitorIndicatorRecordService.saveOrUpdateByPk(monitorIndicatorRecord);
+                                recordList.add(monitorIndicatorRecord);
                             }
                         }
+                        monitorIndicatorRecordService.batchSaveMonitorIndicatorRecordList(recordList);
                         Thread.sleep(5);
                     }
                 }