diff --git a/src/main/java/com/lanhai/entity/SurvHisdataAir.java b/src/main/java/com/lanhai/entity/SurvHisdataAir.java index 6f0de42..513abd4 100644 --- a/src/main/java/com/lanhai/entity/SurvHisdataAir.java +++ b/src/main/java/com/lanhai/entity/SurvHisdataAir.java @@ -113,8 +113,8 @@ public class SurvHisdataAir extends Model { /** * 设备编号 */ - @TableField("DEVICE_CODE") - private String deviceCode; + @TableField("DEPLOY_CODE") + private String deployCode; /** * 机构ID diff --git a/src/main/java/com/lanhai/entity/SurvHisdataLivestockwater.java b/src/main/java/com/lanhai/entity/SurvHisdataLivestockwater.java index 68f22fd..eecf228 100644 --- a/src/main/java/com/lanhai/entity/SurvHisdataLivestockwater.java +++ b/src/main/java/com/lanhai/entity/SurvHisdataLivestockwater.java @@ -132,8 +132,8 @@ public class SurvHisdataLivestockwater extends Model /** * 设备编号 */ - @TableField("DEVICE_CODE") - private String deviceCode; + @TableField("DEPLOY_CODE") + private String deployCode; /** * 机构ID diff --git a/src/main/java/com/lanhai/entity/SurvHisdataLivestockwaterError.java b/src/main/java/com/lanhai/entity/SurvHisdataLivestockwaterError.java index a49c896..fb0440b 100644 --- a/src/main/java/com/lanhai/entity/SurvHisdataLivestockwaterError.java +++ b/src/main/java/com/lanhai/entity/SurvHisdataLivestockwaterError.java @@ -100,8 +100,8 @@ public class SurvHisdataLivestockwaterError extends Model { /** * 设备编号 */ - @TableField("DEVICE_CODE") - private String deviceCode; + @TableField("DEPLOY_CODE") + private String deployCode; /** * 机构ID diff --git a/src/main/java/com/lanhai/entity/SurvHisdataOrientwaterError.java b/src/main/java/com/lanhai/entity/SurvHisdataOrientwaterError.java index 5a9fb36..5906024 100644 --- a/src/main/java/com/lanhai/entity/SurvHisdataOrientwaterError.java +++ b/src/main/java/com/lanhai/entity/SurvHisdataOrientwaterError.java @@ -160,8 +160,8 @@ public class SurvHisdataOrientwaterError extends Model { /** * 设备编号 */ - @TableField("DEVICE_CODE") - private String deviceCode; + @TableField("DEPLOY_CODE") + private String deployCode; /** * 机构ID diff --git a/src/main/java/com/lanhai/entity/SurvHisdataSoil.java b/src/main/java/com/lanhai/entity/SurvHisdataSoil.java index 895249e..d9c5032 100644 --- a/src/main/java/com/lanhai/entity/SurvHisdataSoil.java +++ b/src/main/java/com/lanhai/entity/SurvHisdataSoil.java @@ -237,8 +237,8 @@ public class SurvHisdataSoil extends Model { /** * 设备编号 */ - @TableField("DEVICE_CODE") - private String deviceCode; + @TableField("DEPLOY_CODE") + private String deployCode; /** * 机构ID diff --git a/src/main/java/com/lanhai/entity/SurvTransdataAir.java b/src/main/java/com/lanhai/entity/SurvTransdataAir.java index 2cc2625..7e7afa3 100644 --- a/src/main/java/com/lanhai/entity/SurvTransdataAir.java +++ b/src/main/java/com/lanhai/entity/SurvTransdataAir.java @@ -112,8 +112,8 @@ public class SurvTransdataAir extends Model { /** * 设备编号 */ - @TableField("DEVICE_CODE") - private String deviceCode; + @TableField("DEPLOY_CODE") + private String deployCode; /** * 机构ID diff --git a/src/main/java/com/lanhai/entity/SurvTransdataLivestockwater.java b/src/main/java/com/lanhai/entity/SurvTransdataLivestockwater.java index 4cb8ca0..2804df3 100644 --- a/src/main/java/com/lanhai/entity/SurvTransdataLivestockwater.java +++ b/src/main/java/com/lanhai/entity/SurvTransdataLivestockwater.java @@ -134,8 +134,8 @@ public class SurvTransdataLivestockwater extends Model { /** * 设备编号 */ - @TableField("DEVICE_CODE") - private String deviceCode; + @TableField("DEPLOY_CODE") + private String deployCode; /** * 机构ID diff --git a/src/main/java/com/lanhai/entity/SurvTransdataPestlight.java b/src/main/java/com/lanhai/entity/SurvTransdataPestlight.java index 4bc6ef8..2648121 100644 --- a/src/main/java/com/lanhai/entity/SurvTransdataPestlight.java +++ b/src/main/java/com/lanhai/entity/SurvTransdataPestlight.java @@ -121,8 +121,8 @@ public class SurvTransdataPestlight extends Model { /** * 设备编号 */ - @TableField("DEVICE_CODE") - private String deviceCode; + @TableField("DEPLOY_CODE") + private String deployCode; /** * 机构ID diff --git a/src/main/java/com/lanhai/entity/SurvTransdataSoil.java b/src/main/java/com/lanhai/entity/SurvTransdataSoil.java index 51420d9..a0c6b98 100644 --- a/src/main/java/com/lanhai/entity/SurvTransdataSoil.java +++ b/src/main/java/com/lanhai/entity/SurvTransdataSoil.java @@ -239,8 +239,8 @@ public class SurvTransdataSoil extends Model { /** * 设备编号 */ - @TableField("DEVICE_CODE") - private String deviceCode; + @TableField("DEPLOY_CODE") + private String deployCode; /** * 机构ID diff --git a/src/main/java/com/lanhai/service/Impl/SurvHisdataLivestockwaterServiceImpl.java b/src/main/java/com/lanhai/service/Impl/SurvHisdataLivestockwaterServiceImpl.java index 915021c..c4ce093 100644 --- a/src/main/java/com/lanhai/service/Impl/SurvHisdataLivestockwaterServiceImpl.java +++ b/src/main/java/com/lanhai/service/Impl/SurvHisdataLivestockwaterServiceImpl.java @@ -107,7 +107,7 @@ public class SurvHisdataLivestockwaterServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper(); - queryWrapper.eq("DEVICE_CODE",deviceCode).last("limit 1"); + queryWrapper.eq("DEPLOY_CODE",deviceCode).last("limit 1"); return getOne(queryWrapper); } @@ -73,7 +73,7 @@ public class SurvTransdataAirServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper(); - queryWrapper.eq("DEVICE_CODE",deviceCode).last("limit 1"); + queryWrapper.eq("DEPLOY_CODE",deviceCode).last("limit 1"); return getOne(queryWrapper); } @@ -54,7 +54,7 @@ public class SurvTransdataLivestockwaterServiceImpl extends ServiceImpl baowenMap = new HashMap(); - baowenMap.put("mn", transdataLivestockwater.getDeviceCode()); + baowenMap.put("mn", transdataLivestockwater.getDeployCode()); baowenMap.put("DataTime", dataDateTimeStr); baowenMap.put("e1", transdataLivestockwater.getDataWaterTp()); baowenMap.put("e2", transdataLivestockwater.getDataWaterTpSy()); diff --git a/src/main/java/com/lanhai/service/Impl/SurvTransdataOrientwaterServiceImpl.java b/src/main/java/com/lanhai/service/Impl/SurvTransdataOrientwaterServiceImpl.java index 859902d..4b18fcb 100644 --- a/src/main/java/com/lanhai/service/Impl/SurvTransdataOrientwaterServiceImpl.java +++ b/src/main/java/com/lanhai/service/Impl/SurvTransdataOrientwaterServiceImpl.java @@ -45,7 +45,7 @@ public class SurvTransdataOrientwaterServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper(); - queryWrapper.eq("DEVICE_CODE",deviceCode).last("limit 1"); + queryWrapper.eq("DEPLOY_CODE",deviceCode).last("limit 1"); return getOne(queryWrapper); } @@ -56,7 +56,7 @@ public class SurvTransdataOrientwaterServiceImpl extends ServiceImpl baowenMap = new HashMap(); - baowenMap.put("mn", transdataOrientwater.getDeviceCode()); + baowenMap.put("mn", transdataOrientwater.getDeployCode()); baowenMap.put("DataTime", dataDateTimeStr); baowenMap.put("e1", transdataOrientwater.getDataWaterTp()); baowenMap.put("e2", transdataOrientwater.getDataWaterTpSy()); diff --git a/src/main/java/com/lanhai/service/Impl/SurvTransdataPestlightServiceImpl.java b/src/main/java/com/lanhai/service/Impl/SurvTransdataPestlightServiceImpl.java index f7a32e5..a3d7ef2 100644 --- a/src/main/java/com/lanhai/service/Impl/SurvTransdataPestlightServiceImpl.java +++ b/src/main/java/com/lanhai/service/Impl/SurvTransdataPestlightServiceImpl.java @@ -33,7 +33,7 @@ public class SurvTransdataPestlightServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper(); - queryWrapper.eq("DEVICE_CODE",deviceCode).last("limit 1"); + queryWrapper.eq("DEPLOY_CODE",deviceCode).last("limit 1"); return getOne(queryWrapper); } @@ -60,7 +60,7 @@ public class SurvTransdataPestlightServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper(); - queryWrapper.eq("DEVICE_CODE",deviceCode).last("limit 1"); + queryWrapper.eq("DEPLOY_CODE",deviceCode).last("limit 1"); return getOne(queryWrapper); } @@ -99,7 +99,7 @@ public class SurvTransdataSoilServiceImpl extends ServiceImpl 0){//只有数据有效时才入库 soil.setDataDateTime(DateUtil.parse(DataTime));//数据时间 soil.setDataGatherType("realTime");//数据类型-realTime=实时,dayTime=日数据,month=月数据,year=年数据 - soil.setDeviceCode(mn);//设备编号 + soil.setDeployCode(mn);//设备编号 soil.setTenantId(deploy.getTenantId()); SurvDeviceDeploy survDeviceDeploy = deviceDeployMap.get(deploy.getDeployCode()+"_"+ DeviceDeployEnum.SURV_SOIL.getType()); @@ -162,7 +162,7 @@ public class SurvTransdataSoilServiceImpl extends ServiceImpl 0) {//只有数据有效时才入库 air.setDataDateTime(DateUtil.parse(DataTime));//数据时间 air.setDataGatherType("realTime");//数据类型-realTime=实时,dayTime=日数据,month=月数据,year=年数据 - air.setDeviceCode(mn);//设备编号 + air.setDeployCode(mn);//设备编号 air.setTenantId(deploy.getTenantId()); SurvDeviceDeploy survDeviceDeploy = deviceDeployMap.get(deploy.getDeployCode()+"_"+ DeviceDeployEnum.SURV_AIR.getType()); @@ -237,7 +237,7 @@ public class SurvTransdataSoilServiceImpl extends ServiceImpl0 ){ soil.setDataDateTime(DateUtil.parse(DataTime));//数据时间 soil.setDataGatherType("realTime");//数据类型-realTime=实时,dayTime=日数据,month=月数据,year=年数据 - soil.setDeviceCode(mn);//设备编号 + soil.setDeployCode(mn);//设备编号 soil.setTenantId(deploy.getTenantId()); SurvDeviceDeploy survDeviceDeploy = deviceDeployMap.get(deploy.getDeployCode()+"_"+ DeviceDeployEnum.WATER_QULITY.getType()); @@ -301,7 +301,7 @@ public class SurvTransdataSoilServiceImpl extends ServiceImpl 0) { air.setDataDateTime(DateUtil.parse(DataTime));//数据时间 air.setDataGatherType("realTime");//数据类型-realTime=实时,dayTime=日数据,month=月数据,year=年数据 - air.setDeviceCode(mn);//设备编号 + air.setDeployCode(mn);//设备编号 air.setTenantId(deploy.getTenantId()); SurvDeviceDeploy survDeviceDeploy = deviceDeployMap.get(deploy.getDeployCode()+"_"+ DeviceDeployEnum.SURV_AIR.getType()); air.setDeployId(survDeviceDeploy!=null?survDeviceDeploy.getId():null); diff --git a/src/main/java/com/lanhai/util/DataUtil.java b/src/main/java/com/lanhai/util/DataUtil.java index 09c5e1d..d26aeb3 100644 --- a/src/main/java/com/lanhai/util/DataUtil.java +++ b/src/main/java/com/lanhai/util/DataUtil.java @@ -105,7 +105,7 @@ public class DataUtil{ SurvTransdataOrientwater orientwater = new SurvTransdataOrientwater(); orientwater.setDataDateTime(new Date()); orientwater.setDataGatherType("realTime"); - orientwater.setDeviceCode(CommonConstant.XZP_WATER +str.substring(2,4));// + orientwater.setDeployCode(CommonConstant.XZP_WATER +str.substring(2,4));// if(str.length() >= 80){ orientwater.setDataWaterTp(getVal(str.substring(8,16)));// @@ -137,7 +137,7 @@ public class DataUtil{ SurvTransdataLivestockwater livestockwater = new SurvTransdataLivestockwater(); livestockwater.setDataDateTime(new Date()); livestockwater.setDataGatherType("realTime"); - livestockwater.setDeviceCode(CommonConstant.XZP_WATER +str.substring(2,4));// + livestockwater.setDeployCode(CommonConstant.XZP_WATER +str.substring(2,4));// if(str.length() >= 120){ livestockwater.setDataWaterTp(getVal(str.substring(8,16)));//