水报错不影响下面数据

src/main/java/com/steerinfo/ems/emswaterrealtime/service/impl/EmsWaterRealtimeServiceImpl.java

@@ -1,5 +1,6 @@
 package com.steerinfo.ems.emswaterrealtime.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.steerinfo.auth.utils.JwtUtil;
 import com.steerinfo.ems.Utils.DateUtils;
 import com.steerinfo.ems.Utils.MosaicUtils;
@@ -94,13 +95,19 @@ public class EmsWaterRealtimeServiceImpl extends BaseServiceImpl<EmsWaterRealtim
             //List<EmsWaterRealtime> emsWaterRealtimeList = getWaterListByArmMeter();
             //updateSize = emsWaterRealtimeMapper.batchUpdate(emsWaterRealtimeList);
             for (EmsWaterRealtime emsWaterRealtime : emsWaterRealtimeList){
-                emsWaterRealtime.setReadtime(new Date());
-                //根据地址编码addresscode去进行更新（大用户出现先新增后修改的情况，导致我们出现同一个code出现两条数据）
-                if(emsWaterRealtimeMapper.updateByAddresscodeSelective(emsWaterRealtime) == 0){
-                    addSize+= emsWaterRealtimeMapper.insertSelective(emsWaterRealtime);
-                }else {
-                    updateSize+= 1;
+                try{
+                    emsWaterRealtime.setReadtime(new Date());
+                    //根据地址编码addresscode去进行更新（大用户出现先新增后修改的情况，导致我们出现同一个code出现两条数据）
+                    if(emsWaterRealtimeMapper.updateByAddresscodeSelective(emsWaterRealtime) == 0){
+                        addSize+= emsWaterRealtimeMapper.insertSelective(emsWaterRealtime);
+                    }else {
+                        updateSize+= 1;
+                    }
+                }catch (Exception e){
+                    e.printStackTrace();
+                    logger.info("出错数据：" + JSONObject.toJSONString(emsWaterRealtime));
                 }
+
             }
             String clock = DateUtils.dateStr(new Date(),"yyyy-MM-dd HH:mm:ss");
             HashMap<String,Object> hashMap = new HashMap<String,Object>();

src/main/java/com/steerinfo/ems/trmcalpoint/service/impl/TRmCalpointServiceImpl.java

@@ -949,7 +949,9 @@ public class TRmCalpointServiceImpl extends BaseServiceImpl<TRmCalpoint, String>
                         emsPAiHourSumTab1Mapper.insert(po);
                     }
                 }catch (Exception e){
-                    logger.info("小时数据出错：" + itemid);
+                    logger.info("列名：" + tag);
+                    logger.info("值为：" + hval.doubleValue());
+                    logger.info("小时数据出错：" + itemid+",列名：" + tag);
                     e.printStackTrace();
                 }