瀏覽代碼

add rabbitmq

18339543638 3 年之前
父節點
當前提交
4ff2bf815b

+ 1 - 1
nb-service/iot-service/src/main/java/com/nb/mq/entity/PcAnalgesicScoreEntity.java

@@ -55,7 +55,7 @@ public class PcAnalgesicScoreEntity implements Serializable {
     private Integer leftLeg;
 
     @ApiModelProperty(value = "右上肢")
-    private Integer rightArm;
+    private Integer RightArm;
 
     @ApiModelProperty(value = "右下肢")
     private Integer rightLeg;

+ 4 - 0
nb-service/iot-service/src/main/java/com/nb/mq/listener/RabbitMqListener.java

@@ -3,6 +3,7 @@ package com.nb.mq.listener;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.nb.core.utils.ExceptionUtil;
@@ -197,7 +198,10 @@ public class RabbitMqListener {
         hospitalLog.setInput(body);
         long startTime = System.currentTimeMillis();
         try {
+            JSONObject jsonObject = JSONUtil.parseObj(body);
+            Long followDate = jsonObject.getLong("followDate");
             PcAnalgesicScoreEntity source = JSONUtil.toBean(body, PcAnalgesicScoreEntity.class);
+            source.setFollowDate(new Date(followDate*1000));
             HospitalResult hospitalResult = hospitalClient.getByIdOrCode(source.getHospitalCode());
             if(hospitalResult==null){
                 log.warn("id或编码为{}的医院不存在,丢弃该信息",source.getHospitalCode());