소스 검색

后处理消息

huangxingxing 2 년 전
부모
커밋
a2d9e5f8df
1개의 변경된 파일10개의 추가작업 그리고 4개의 파일을 삭제
  1. 10 4
      src/main/java/com/miniframe/bisiness/system/AFT001Service.java

+ 10 - 4
src/main/java/com/miniframe/bisiness/system/AFT001Service.java

@@ -136,10 +136,16 @@ public class AFT001Service extends AFT001BaseModel implements ExecProcessFlow {
 			){
 				throw new BusinessException("EB4000013");
 			}
-			msg.setScaleFactor(this.getA_aft001().getScaleFactor());
-			msg.setDataU(this.getA_aft001().getDataU());
-			msg.setDataV(this.getA_aft001().getDataV());
-			msg.setDataW(this.getA_aft001().getDataW());
+			JSONObject obj  = new JSONObject();
+			obj.put("scaleFactor",this.getA_aft001().getScaleFactor());
+			obj.put("dataU",this.getA_aft001().getDataU());
+			obj.put("dataV",this.getA_aft001().getDataV());
+			obj.put("dataW",this.getA_aft001().getDataW());
+			msg.setParamJson(obj.toString());
+//			msg.setScaleFactor(this.getA_aft001().getScaleFactor());
+//			msg.setDataU(this.getA_aft001().getDataU());
+//			msg.setDataV(this.getA_aft001().getDataV());
+//			msg.setDataW(this.getA_aft001().getDataW());
 		}
 		System.out.println(XiJsonUtil.objectToJson(msg));
 		MFMqUtils.get(CaeMQ.class).sendCaein(XiJsonUtil.objectToJson(msg));