Selaa lähdekoodia

Merge branch 'master' into v2.0.0

lixing 3 vuotta sitten
vanhempi
commit
754addd5e2

+ 3 - 0
dmp-alarm/src/main/java/com/persagy/dmp/alarm/entity/AlarmRecord.java

@@ -1,6 +1,7 @@
 package com.persagy.dmp.alarm.entity;
 
 import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.google.common.collect.Maps;
 import com.vladmihalcea.hibernate.type.json.JsonStringType;
 import lombok.Getter;
 import lombok.Setter;
@@ -12,6 +13,8 @@ import javax.persistence.GeneratedValue;
 import javax.persistence.*;
 import javax.persistence.Table;
 import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
 
 @Setter
 @Getter

+ 10 - 1
dmp-alarm/src/main/java/com/persagy/dmp/alarm/service/AlarmRecordService.java

@@ -103,6 +103,10 @@ public class AlarmRecordService extends AlarmBaseService {
         } else {
             entity.setCreateTime(new Date());
         }
+        // 默认处理状态为未处理
+        if (entity.getTreatState() == null) {
+            entity.setTreatState(1);
+        }
         entity.setValid(1);
         entity.setProjectId(alarmParam.projectId);
         entity.setGroupCode(alarmParam.groupCode);
@@ -273,7 +277,12 @@ public class AlarmRecordService extends AlarmBaseService {
             return response;
         }
 
-        alarmRecordModelList.forEach(this::update);
+        List<DmpMessage> msgList = new ArrayList<>();
+        alarmRecordModelList.forEach(alarmRecordModel -> {
+            MapResponse updateResponse = update(alarmRecordModel);
+            msgList.addAll(updateResponse.getMessageList());
+        });
+        response.add(msgList);
         return response;
     }
 

+ 4 - 7
dmp-alarm/src/main/resources/bootstrap.yml

@@ -5,13 +5,10 @@ spring:
     active: dev
   cloud:
     config:
-#      profile: dev2
-      profile: aliyun-dev
-#      uri: http://192.168.100.107:9932
-#      uri: http://192.168.64.18:9932
-      uri: http://39.102.43.179:9932
-      #      profile: dev2
-#      uri: http://192.168.64.18:9932
+#      profile: aliyun-dev
+#      uri: http://39.102.43.179:9932
+      profile: dev2
+      uri: http://192.168.64.18:9932
 persagy:
   log:
     path: ../logs/dmp-alarm/

+ 7 - 0
dmp-common/src/main/java/com/persagy/common/web/BaseResponse.java

@@ -61,4 +61,11 @@ public class BaseResponse<T> {
 		}
 		messageList.add(msg);
 	}
+
+	public void add(List<DmpMessage> msgs){
+		if (messageList == null) {
+			messageList = new LinkedList<>();
+		}
+		messageList.addAll(msgs);
+	}
 }