diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
index ea5cd2c..86fbeb9 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
@@ -59,7 +59,7 @@
- and s.ID =to_number(#{deptid}, '999999999999999999999')
+ and s.ID =#{deptid}
ORDER by writetime DESC
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
index ea5cd2c..86fbeb9 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
@@ -59,7 +59,7 @@
- and s.ID =to_number(#{deptid}, '999999999999999999999')
+ and s.ID =#{deptid}
ORDER by writetime DESC
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
index 5d6ff85..97ee3e7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
@@ -27,8 +27,9 @@
FROM bus_imei_iccid
WHERE 1=1
- AND DEVCODE = #{devcode}
+ AND DEVCODE like CONCAT('%',#{devcode},'%')
+ order by logtime desc
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
index ea5cd2c..86fbeb9 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
@@ -59,7 +59,7 @@
- and s.ID =to_number(#{deptid}, '999999999999999999999')
+ and s.ID =#{deptid}
ORDER by writetime DESC
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
index 5d6ff85..97ee3e7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
@@ -27,8 +27,9 @@
FROM bus_imei_iccid
WHERE 1=1
- AND DEVCODE = #{devcode}
+ AND DEVCODE like CONCAT('%',#{devcode},'%')
+ order by logtime desc
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
index 4d3478b..a01053a 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
@@ -15,7 +15,7 @@
- ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,ONLINESTATE,VALID,TS,BFZT,wellId,
+ ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,lineLength,ONLINESTATE,VALID,TS,BFZT,wellId,
@@ -269,7 +269,7 @@
- timestampdiff(DAY,NOW(),install_date)
+ timestampdiff(DAY,install_date,NOW())
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
index ea5cd2c..86fbeb9 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
@@ -59,7 +59,7 @@
- and s.ID =to_number(#{deptid}, '999999999999999999999')
+ and s.ID =#{deptid}
ORDER by writetime DESC
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
index 5d6ff85..97ee3e7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
@@ -27,8 +27,9 @@
FROM bus_imei_iccid
WHERE 1=1
- AND DEVCODE = #{devcode}
+ AND DEVCODE like CONCAT('%',#{devcode},'%')
+ order by logtime desc
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
index 4d3478b..a01053a 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
@@ -15,7 +15,7 @@
- ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,ONLINESTATE,VALID,TS,BFZT,wellId,
+ ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,lineLength,ONLINESTATE,VALID,TS,BFZT,wellId,
@@ -269,7 +269,7 @@
- timestampdiff(DAY,NOW(),install_date)
+ timestampdiff(DAY,install_date,NOW())
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
index 34ed9a7..617ed38 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
@@ -18,14 +18,21 @@
RedisCommon redisCommon =SpringContextHolder.getBean("redisCommon");
CommConfigDTO commConfigDTO = new CommConfigDTO();
- commConfigDTO.setThresh(StringUtils.isNotBlank(content.split(",")[0])?
- Float.valueOf(content.split(",")[0]):null);
- commConfigDTO.setHeight(Float.valueOf(content.split(",")[1]));
- commConfigDTO.setRepeat(Long.valueOf(content.split(",")[2]));
- if(StringUtils.isNotBlank(content.split(",", 6)[4]))
- commConfigDTO.setIp(content.split(",", 6)[4]);
- if(StringUtils.isNotBlank(content.split(",",6)[5]))
- commConfigDTO.setPort(Long.valueOf(content.split(",", 6)[5]));
+ String[] configArr= content.split(",");
+ commConfigDTO.setThresh(StringUtils.isNotBlank(configArr[0])?
+ Float.valueOf(configArr[0]):null);
+ commConfigDTO.setHeight(Float.valueOf(configArr[1]));
+ commConfigDTO.setRepeat(Long.valueOf(configArr[2]));
+ if(StringUtils.isNotBlank(configArr[4])){
+ commConfigDTO.setInterval(Long.valueOf(configArr[4]));
+ }
+ if(StringUtils.isNotBlank(configArr[5])){
+ commConfigDTO.setTimes(Long.valueOf(configArr[5]));
+ }
+ if(StringUtils.isNotBlank(content.split(",", 8)[6]))
+ commConfigDTO.setIp(content.split(",", 8)[6]);
+ if(StringUtils.isNotBlank(content.split(",",8)[7]))
+ commConfigDTO.setPort(Long.valueOf(content.split(",", 8)[7]));
redisCommon.setRedisConfig(devCode, commConfigDTO);
if (/*"1".equals(this.getNetType()) &&*/ StringUtils.isNotBlank(getConcentratorCode()))
redisCommon.setRedisConcentrator(getConcentratorCode(), devCode, attemptsMax);
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
index ea5cd2c..86fbeb9 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
@@ -59,7 +59,7 @@
- and s.ID =to_number(#{deptid}, '999999999999999999999')
+ and s.ID =#{deptid}
ORDER by writetime DESC
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
index 5d6ff85..97ee3e7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
@@ -27,8 +27,9 @@
FROM bus_imei_iccid
WHERE 1=1
- AND DEVCODE = #{devcode}
+ AND DEVCODE like CONCAT('%',#{devcode},'%')
+ order by logtime desc
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
index 4d3478b..a01053a 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
@@ -15,7 +15,7 @@
- ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,ONLINESTATE,VALID,TS,BFZT,wellId,
+ ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,lineLength,ONLINESTATE,VALID,TS,BFZT,wellId,
@@ -269,7 +269,7 @@
- timestampdiff(DAY,NOW(),install_date)
+ timestampdiff(DAY,install_date,NOW())
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
index 34ed9a7..617ed38 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
@@ -18,14 +18,21 @@
RedisCommon redisCommon =SpringContextHolder.getBean("redisCommon");
CommConfigDTO commConfigDTO = new CommConfigDTO();
- commConfigDTO.setThresh(StringUtils.isNotBlank(content.split(",")[0])?
- Float.valueOf(content.split(",")[0]):null);
- commConfigDTO.setHeight(Float.valueOf(content.split(",")[1]));
- commConfigDTO.setRepeat(Long.valueOf(content.split(",")[2]));
- if(StringUtils.isNotBlank(content.split(",", 6)[4]))
- commConfigDTO.setIp(content.split(",", 6)[4]);
- if(StringUtils.isNotBlank(content.split(",",6)[5]))
- commConfigDTO.setPort(Long.valueOf(content.split(",", 6)[5]));
+ String[] configArr= content.split(",");
+ commConfigDTO.setThresh(StringUtils.isNotBlank(configArr[0])?
+ Float.valueOf(configArr[0]):null);
+ commConfigDTO.setHeight(Float.valueOf(configArr[1]));
+ commConfigDTO.setRepeat(Long.valueOf(configArr[2]));
+ if(StringUtils.isNotBlank(configArr[4])){
+ commConfigDTO.setInterval(Long.valueOf(configArr[4]));
+ }
+ if(StringUtils.isNotBlank(configArr[5])){
+ commConfigDTO.setTimes(Long.valueOf(configArr[5]));
+ }
+ if(StringUtils.isNotBlank(content.split(",", 8)[6]))
+ commConfigDTO.setIp(content.split(",", 8)[6]);
+ if(StringUtils.isNotBlank(content.split(",",8)[7]))
+ commConfigDTO.setPort(Long.valueOf(content.split(",", 8)[7]));
redisCommon.setRedisConfig(devCode, commConfigDTO);
if (/*"1".equals(this.getNetType()) &&*/ StringUtils.isNotBlank(getConcentratorCode()))
redisCommon.setRedisConcentrator(getConcentratorCode(), devCode, attemptsMax);
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
index a0a177d..525d9df 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
@@ -105,9 +105,11 @@
dto.setRetryTimes(configItems[2]);
dto.setPercent(null != configItems[3] ?
Float.valueOf(configItems[3]) : null);
- if (configItems.length == 6) {
- dto.setIp(configItems[4]);
- dto.setPort(configItems[5]);
+ dto.setCollectInterval(configItems[4]);
+ dto.setCollectCount(configItems[5]);
+ if (configItems.length == 8) {
+ dto.setIp(configItems[6]);
+ dto.setPort(configItems[7]);
}
dto.setPercentExp(dto.getPercent());
}
@@ -159,9 +161,11 @@
}
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig.setFramecontent(framecontent);
save(busConfig);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -195,9 +199,11 @@
busConfigDTO.setThreshold(Float.valueOf(getThresholdByDevId(busConfigDTO)));
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig1 = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig1.setFramecontent(framecontent);
save(busConfig1);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -264,7 +270,7 @@
if (0 == busConfigDTOList.get(i).getPercent()) {
stringMap.put("success", false);
- stringMap.put("msg", "第" + (i + 2) + "行,报警阈值必填且小数位最多保留2位");
+ stringMap.put("msg", "第" + (i + 2) + "行,报警阈值%必填且小数位最多保留2位");
return stringMap;
} else if (!RegUtil.isDecimal2(String.valueOf(busConfigDTOList.get(i).getPercent()))) {
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
index ea5cd2c..86fbeb9 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
@@ -59,7 +59,7 @@
- and s.ID =to_number(#{deptid}, '999999999999999999999')
+ and s.ID =#{deptid}
ORDER by writetime DESC
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
index 5d6ff85..97ee3e7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
@@ -27,8 +27,9 @@
FROM bus_imei_iccid
WHERE 1=1
- AND DEVCODE = #{devcode}
+ AND DEVCODE like CONCAT('%',#{devcode},'%')
+ order by logtime desc
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
index 4d3478b..a01053a 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
@@ -15,7 +15,7 @@
- ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,ONLINESTATE,VALID,TS,BFZT,wellId,
+ ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,lineLength,ONLINESTATE,VALID,TS,BFZT,wellId,
@@ -269,7 +269,7 @@
- timestampdiff(DAY,NOW(),install_date)
+ timestampdiff(DAY,install_date,NOW())
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
index 34ed9a7..617ed38 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
@@ -18,14 +18,21 @@
RedisCommon redisCommon =SpringContextHolder.getBean("redisCommon");
CommConfigDTO commConfigDTO = new CommConfigDTO();
- commConfigDTO.setThresh(StringUtils.isNotBlank(content.split(",")[0])?
- Float.valueOf(content.split(",")[0]):null);
- commConfigDTO.setHeight(Float.valueOf(content.split(",")[1]));
- commConfigDTO.setRepeat(Long.valueOf(content.split(",")[2]));
- if(StringUtils.isNotBlank(content.split(",", 6)[4]))
- commConfigDTO.setIp(content.split(",", 6)[4]);
- if(StringUtils.isNotBlank(content.split(",",6)[5]))
- commConfigDTO.setPort(Long.valueOf(content.split(",", 6)[5]));
+ String[] configArr= content.split(",");
+ commConfigDTO.setThresh(StringUtils.isNotBlank(configArr[0])?
+ Float.valueOf(configArr[0]):null);
+ commConfigDTO.setHeight(Float.valueOf(configArr[1]));
+ commConfigDTO.setRepeat(Long.valueOf(configArr[2]));
+ if(StringUtils.isNotBlank(configArr[4])){
+ commConfigDTO.setInterval(Long.valueOf(configArr[4]));
+ }
+ if(StringUtils.isNotBlank(configArr[5])){
+ commConfigDTO.setTimes(Long.valueOf(configArr[5]));
+ }
+ if(StringUtils.isNotBlank(content.split(",", 8)[6]))
+ commConfigDTO.setIp(content.split(",", 8)[6]);
+ if(StringUtils.isNotBlank(content.split(",",8)[7]))
+ commConfigDTO.setPort(Long.valueOf(content.split(",", 8)[7]));
redisCommon.setRedisConfig(devCode, commConfigDTO);
if (/*"1".equals(this.getNetType()) &&*/ StringUtils.isNotBlank(getConcentratorCode()))
redisCommon.setRedisConcentrator(getConcentratorCode(), devCode, attemptsMax);
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
index a0a177d..525d9df 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
@@ -105,9 +105,11 @@
dto.setRetryTimes(configItems[2]);
dto.setPercent(null != configItems[3] ?
Float.valueOf(configItems[3]) : null);
- if (configItems.length == 6) {
- dto.setIp(configItems[4]);
- dto.setPort(configItems[5]);
+ dto.setCollectInterval(configItems[4]);
+ dto.setCollectCount(configItems[5]);
+ if (configItems.length == 8) {
+ dto.setIp(configItems[6]);
+ dto.setPort(configItems[7]);
}
dto.setPercentExp(dto.getPercent());
}
@@ -159,9 +161,11 @@
}
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig.setFramecontent(framecontent);
save(busConfig);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -195,9 +199,11 @@
busConfigDTO.setThreshold(Float.valueOf(getThresholdByDevId(busConfigDTO)));
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig1 = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig1.setFramecontent(framecontent);
save(busConfig1);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -264,7 +270,7 @@
if (0 == busConfigDTOList.get(i).getPercent()) {
stringMap.put("success", false);
- stringMap.put("msg", "第" + (i + 2) + "行,报警阈值必填且小数位最多保留2位");
+ stringMap.put("msg", "第" + (i + 2) + "行,报警阈值%必填且小数位最多保留2位");
return stringMap;
} else if (!RegUtil.isDecimal2(String.valueOf(busConfigDTOList.get(i).getPercent()))) {
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
index f626ab7..97a8131 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
@@ -151,7 +151,7 @@
+ busConfigDTO.getCollectCount() + "," + busConfigDTO.getRetryTimes() + ","
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getSleepStartTime() + ","
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();//按照采集时间、采集间隔、采集次数、重传次数、阈值、睡眠开始时间
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
if (device != null) {
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
index ea5cd2c..86fbeb9 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
@@ -59,7 +59,7 @@
- and s.ID =to_number(#{deptid}, '999999999999999999999')
+ and s.ID =#{deptid}
ORDER by writetime DESC
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
index 5d6ff85..97ee3e7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
@@ -27,8 +27,9 @@
FROM bus_imei_iccid
WHERE 1=1
- AND DEVCODE = #{devcode}
+ AND DEVCODE like CONCAT('%',#{devcode},'%')
+ order by logtime desc
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
index 4d3478b..a01053a 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
@@ -15,7 +15,7 @@
- ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,ONLINESTATE,VALID,TS,BFZT,wellId,
+ ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,lineLength,ONLINESTATE,VALID,TS,BFZT,wellId,
@@ -269,7 +269,7 @@
- timestampdiff(DAY,NOW(),install_date)
+ timestampdiff(DAY,install_date,NOW())
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
index 34ed9a7..617ed38 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
@@ -18,14 +18,21 @@
RedisCommon redisCommon =SpringContextHolder.getBean("redisCommon");
CommConfigDTO commConfigDTO = new CommConfigDTO();
- commConfigDTO.setThresh(StringUtils.isNotBlank(content.split(",")[0])?
- Float.valueOf(content.split(",")[0]):null);
- commConfigDTO.setHeight(Float.valueOf(content.split(",")[1]));
- commConfigDTO.setRepeat(Long.valueOf(content.split(",")[2]));
- if(StringUtils.isNotBlank(content.split(",", 6)[4]))
- commConfigDTO.setIp(content.split(",", 6)[4]);
- if(StringUtils.isNotBlank(content.split(",",6)[5]))
- commConfigDTO.setPort(Long.valueOf(content.split(",", 6)[5]));
+ String[] configArr= content.split(",");
+ commConfigDTO.setThresh(StringUtils.isNotBlank(configArr[0])?
+ Float.valueOf(configArr[0]):null);
+ commConfigDTO.setHeight(Float.valueOf(configArr[1]));
+ commConfigDTO.setRepeat(Long.valueOf(configArr[2]));
+ if(StringUtils.isNotBlank(configArr[4])){
+ commConfigDTO.setInterval(Long.valueOf(configArr[4]));
+ }
+ if(StringUtils.isNotBlank(configArr[5])){
+ commConfigDTO.setTimes(Long.valueOf(configArr[5]));
+ }
+ if(StringUtils.isNotBlank(content.split(",", 8)[6]))
+ commConfigDTO.setIp(content.split(",", 8)[6]);
+ if(StringUtils.isNotBlank(content.split(",",8)[7]))
+ commConfigDTO.setPort(Long.valueOf(content.split(",", 8)[7]));
redisCommon.setRedisConfig(devCode, commConfigDTO);
if (/*"1".equals(this.getNetType()) &&*/ StringUtils.isNotBlank(getConcentratorCode()))
redisCommon.setRedisConcentrator(getConcentratorCode(), devCode, attemptsMax);
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
index a0a177d..525d9df 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
@@ -105,9 +105,11 @@
dto.setRetryTimes(configItems[2]);
dto.setPercent(null != configItems[3] ?
Float.valueOf(configItems[3]) : null);
- if (configItems.length == 6) {
- dto.setIp(configItems[4]);
- dto.setPort(configItems[5]);
+ dto.setCollectInterval(configItems[4]);
+ dto.setCollectCount(configItems[5]);
+ if (configItems.length == 8) {
+ dto.setIp(configItems[6]);
+ dto.setPort(configItems[7]);
}
dto.setPercentExp(dto.getPercent());
}
@@ -159,9 +161,11 @@
}
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig.setFramecontent(framecontent);
save(busConfig);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -195,9 +199,11 @@
busConfigDTO.setThreshold(Float.valueOf(getThresholdByDevId(busConfigDTO)));
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig1 = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig1.setFramecontent(framecontent);
save(busConfig1);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -264,7 +270,7 @@
if (0 == busConfigDTOList.get(i).getPercent()) {
stringMap.put("success", false);
- stringMap.put("msg", "第" + (i + 2) + "行,报警阈值必填且小数位最多保留2位");
+ stringMap.put("msg", "第" + (i + 2) + "行,报警阈值%必填且小数位最多保留2位");
return stringMap;
} else if (!RegUtil.isDecimal2(String.valueOf(busConfigDTOList.get(i).getPercent()))) {
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
index f626ab7..97a8131 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
@@ -151,7 +151,7 @@
+ busConfigDTO.getCollectCount() + "," + busConfigDTO.getRetryTimes() + ","
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getSleepStartTime() + ","
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();//按照采集时间、采集间隔、采集次数、重传次数、阈值、睡眠开始时间
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
if (device != null) {
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java
index 9e6929e..2f8dc74 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java
@@ -145,7 +145,7 @@
String str = busConfigDTO.getRetryTimes() + "," + busConfigDTO.getCollectInterval() + ","
+ busConfigDTO.getUploadPeriod() + ","
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();//按照重传次数、采集间隔、上传周期
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
String concentratorCode = redisCommon.sendMsg(DeviceTypeEnum.LG.toString(),
busConfig1.getDeviceId(), busConfig1.getFramecontent(), busConfigDTO.getAttemptsMax());
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
index ea5cd2c..86fbeb9 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
@@ -59,7 +59,7 @@
- and s.ID =to_number(#{deptid}, '999999999999999999999')
+ and s.ID =#{deptid}
ORDER by writetime DESC
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
index 5d6ff85..97ee3e7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
@@ -27,8 +27,9 @@
FROM bus_imei_iccid
WHERE 1=1
- AND DEVCODE = #{devcode}
+ AND DEVCODE like CONCAT('%',#{devcode},'%')
+ order by logtime desc
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
index 4d3478b..a01053a 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
@@ -15,7 +15,7 @@
- ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,ONLINESTATE,VALID,TS,BFZT,wellId,
+ ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,lineLength,ONLINESTATE,VALID,TS,BFZT,wellId,
@@ -269,7 +269,7 @@
- timestampdiff(DAY,NOW(),install_date)
+ timestampdiff(DAY,install_date,NOW())
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
index 34ed9a7..617ed38 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
@@ -18,14 +18,21 @@
RedisCommon redisCommon =SpringContextHolder.getBean("redisCommon");
CommConfigDTO commConfigDTO = new CommConfigDTO();
- commConfigDTO.setThresh(StringUtils.isNotBlank(content.split(",")[0])?
- Float.valueOf(content.split(",")[0]):null);
- commConfigDTO.setHeight(Float.valueOf(content.split(",")[1]));
- commConfigDTO.setRepeat(Long.valueOf(content.split(",")[2]));
- if(StringUtils.isNotBlank(content.split(",", 6)[4]))
- commConfigDTO.setIp(content.split(",", 6)[4]);
- if(StringUtils.isNotBlank(content.split(",",6)[5]))
- commConfigDTO.setPort(Long.valueOf(content.split(",", 6)[5]));
+ String[] configArr= content.split(",");
+ commConfigDTO.setThresh(StringUtils.isNotBlank(configArr[0])?
+ Float.valueOf(configArr[0]):null);
+ commConfigDTO.setHeight(Float.valueOf(configArr[1]));
+ commConfigDTO.setRepeat(Long.valueOf(configArr[2]));
+ if(StringUtils.isNotBlank(configArr[4])){
+ commConfigDTO.setInterval(Long.valueOf(configArr[4]));
+ }
+ if(StringUtils.isNotBlank(configArr[5])){
+ commConfigDTO.setTimes(Long.valueOf(configArr[5]));
+ }
+ if(StringUtils.isNotBlank(content.split(",", 8)[6]))
+ commConfigDTO.setIp(content.split(",", 8)[6]);
+ if(StringUtils.isNotBlank(content.split(",",8)[7]))
+ commConfigDTO.setPort(Long.valueOf(content.split(",", 8)[7]));
redisCommon.setRedisConfig(devCode, commConfigDTO);
if (/*"1".equals(this.getNetType()) &&*/ StringUtils.isNotBlank(getConcentratorCode()))
redisCommon.setRedisConcentrator(getConcentratorCode(), devCode, attemptsMax);
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
index a0a177d..525d9df 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
@@ -105,9 +105,11 @@
dto.setRetryTimes(configItems[2]);
dto.setPercent(null != configItems[3] ?
Float.valueOf(configItems[3]) : null);
- if (configItems.length == 6) {
- dto.setIp(configItems[4]);
- dto.setPort(configItems[5]);
+ dto.setCollectInterval(configItems[4]);
+ dto.setCollectCount(configItems[5]);
+ if (configItems.length == 8) {
+ dto.setIp(configItems[6]);
+ dto.setPort(configItems[7]);
}
dto.setPercentExp(dto.getPercent());
}
@@ -159,9 +161,11 @@
}
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig.setFramecontent(framecontent);
save(busConfig);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -195,9 +199,11 @@
busConfigDTO.setThreshold(Float.valueOf(getThresholdByDevId(busConfigDTO)));
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig1 = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig1.setFramecontent(framecontent);
save(busConfig1);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -264,7 +270,7 @@
if (0 == busConfigDTOList.get(i).getPercent()) {
stringMap.put("success", false);
- stringMap.put("msg", "第" + (i + 2) + "行,报警阈值必填且小数位最多保留2位");
+ stringMap.put("msg", "第" + (i + 2) + "行,报警阈值%必填且小数位最多保留2位");
return stringMap;
} else if (!RegUtil.isDecimal2(String.valueOf(busConfigDTOList.get(i).getPercent()))) {
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
index f626ab7..97a8131 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
@@ -151,7 +151,7 @@
+ busConfigDTO.getCollectCount() + "," + busConfigDTO.getRetryTimes() + ","
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getSleepStartTime() + ","
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();//按照采集时间、采集间隔、采集次数、重传次数、阈值、睡眠开始时间
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
if (device != null) {
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java
index 9e6929e..2f8dc74 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java
@@ -145,7 +145,7 @@
String str = busConfigDTO.getRetryTimes() + "," + busConfigDTO.getCollectInterval() + ","
+ busConfigDTO.getUploadPeriod() + ","
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();//按照重传次数、采集间隔、上传周期
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
String concentratorCode = redisCommon.sendMsg(DeviceTypeEnum.LG.toString(),
busConfig1.getDeviceId(), busConfig1.getFramecontent(), busConfigDTO.getAttemptsMax());
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusH2sConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusH2sConfigServiceImpl.java
index 860a67b..52ff667 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusH2sConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusH2sConfigServiceImpl.java
@@ -136,7 +136,7 @@
String str = busConfigDTO.getRetryTimes() + "," + busConfigDTO.getCollectInterval() + ","
+ busConfigDTO.getUploadPeriod() + ","
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();//按照重传次数、采集间隔、上传周期
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
String concentratorCode = redisCommon.sendMsg(DeviceTypeEnum.H2s.toString(),
busConfig1.getDeviceId(), busConfig1.getFramecontent(), busConfigDTO.getAttemptsMax());
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
index ea5cd2c..86fbeb9 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/BusConfigMapper.xml
@@ -59,7 +59,7 @@
- and s.ID =to_number(#{deptid}, '999999999999999999999')
+ and s.ID =#{deptid}
ORDER by writetime DESC
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
index 5d6ff85..97ee3e7 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceImeiMapper.xml
@@ -27,8 +27,9 @@
FROM bus_imei_iccid
WHERE 1=1
- AND DEVCODE = #{devcode}
+ AND DEVCODE like CONCAT('%',#{devcode},'%')
+ order by logtime desc
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
index 4d3478b..a01053a 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceMapper.xml
@@ -15,7 +15,7 @@
- ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,ONLINESTATE,VALID,TS,BFZT,wellId,
+ ID,DEVCODE,DEVICENAME,DEVICETYPE,DEVICETYPENAME,WATCHTYPE,COMMUNICATION,MODELID,MODELNAME,DEPTID,DEPTNAME,WELLCODE,POSITION,CONCENID,CONCENCODE,lineLength,ONLINESTATE,VALID,TS,BFZT,wellId,
@@ -269,7 +269,7 @@
- timestampdiff(DAY,NOW(),install_date)
+ timestampdiff(DAY,install_date,NOW())
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
index 34ed9a7..617ed38 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/rs/LiquidRequest.java
@@ -18,14 +18,21 @@
RedisCommon redisCommon =SpringContextHolder.getBean("redisCommon");
CommConfigDTO commConfigDTO = new CommConfigDTO();
- commConfigDTO.setThresh(StringUtils.isNotBlank(content.split(",")[0])?
- Float.valueOf(content.split(",")[0]):null);
- commConfigDTO.setHeight(Float.valueOf(content.split(",")[1]));
- commConfigDTO.setRepeat(Long.valueOf(content.split(",")[2]));
- if(StringUtils.isNotBlank(content.split(",", 6)[4]))
- commConfigDTO.setIp(content.split(",", 6)[4]);
- if(StringUtils.isNotBlank(content.split(",",6)[5]))
- commConfigDTO.setPort(Long.valueOf(content.split(",", 6)[5]));
+ String[] configArr= content.split(",");
+ commConfigDTO.setThresh(StringUtils.isNotBlank(configArr[0])?
+ Float.valueOf(configArr[0]):null);
+ commConfigDTO.setHeight(Float.valueOf(configArr[1]));
+ commConfigDTO.setRepeat(Long.valueOf(configArr[2]));
+ if(StringUtils.isNotBlank(configArr[4])){
+ commConfigDTO.setInterval(Long.valueOf(configArr[4]));
+ }
+ if(StringUtils.isNotBlank(configArr[5])){
+ commConfigDTO.setTimes(Long.valueOf(configArr[5]));
+ }
+ if(StringUtils.isNotBlank(content.split(",", 8)[6]))
+ commConfigDTO.setIp(content.split(",", 8)[6]);
+ if(StringUtils.isNotBlank(content.split(",",8)[7]))
+ commConfigDTO.setPort(Long.valueOf(content.split(",", 8)[7]));
redisCommon.setRedisConfig(devCode, commConfigDTO);
if (/*"1".equals(this.getNetType()) &&*/ StringUtils.isNotBlank(getConcentratorCode()))
redisCommon.setRedisConcentrator(getConcentratorCode(), devCode, attemptsMax);
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
index a0a177d..525d9df 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusConfigServiceImpl.java
@@ -105,9 +105,11 @@
dto.setRetryTimes(configItems[2]);
dto.setPercent(null != configItems[3] ?
Float.valueOf(configItems[3]) : null);
- if (configItems.length == 6) {
- dto.setIp(configItems[4]);
- dto.setPort(configItems[5]);
+ dto.setCollectInterval(configItems[4]);
+ dto.setCollectCount(configItems[5]);
+ if (configItems.length == 8) {
+ dto.setIp(configItems[6]);
+ dto.setPort(configItems[7]);
}
dto.setPercentExp(dto.getPercent());
}
@@ -159,9 +161,11 @@
}
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig.setFramecontent(framecontent);
save(busConfig);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -195,9 +199,11 @@
busConfigDTO.setThreshold(Float.valueOf(getThresholdByDevId(busConfigDTO)));
busConfigDTO.setDeviceType(Long.valueOf(DeviceTypeEnum.Liquid.getIndex()));
BusConfig busConfig1 = new BusConfig(busConfigDTO);
- String framecontent = busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + ","
- + busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," + busConfigDTO.getIp() + ","
- + busConfigDTO.getPort();
+ String framecontent =
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getInstallHeight() + "," +
+ busConfigDTO.getRetryTimes() + "," + busConfigDTO.getPercent() + "," +
+ busConfigDTO.getCollectInterval() + "," + busConfigDTO.getCollectCount() + "," +
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();
busConfig1.setFramecontent(framecontent);
save(busConfig1);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
@@ -264,7 +270,7 @@
if (0 == busConfigDTOList.get(i).getPercent()) {
stringMap.put("success", false);
- stringMap.put("msg", "第" + (i + 2) + "行,报警阈值必填且小数位最多保留2位");
+ stringMap.put("msg", "第" + (i + 2) + "行,报警阈值%必填且小数位最多保留2位");
return stringMap;
} else if (!RegUtil.isDecimal2(String.valueOf(busConfigDTOList.get(i).getPercent()))) {
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
index f626ab7..97a8131 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusDigConfigServiceImpl.java
@@ -151,7 +151,7 @@
+ busConfigDTO.getCollectCount() + "," + busConfigDTO.getRetryTimes() + ","
+ busConfigDTO.getThreshold() + "," + busConfigDTO.getSleepStartTime() + ","
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();//按照采集时间、采集间隔、采集次数、重传次数、阈值、睡眠开始时间
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
Device device = iDeviceService.getById(busConfigDTO.getDeviceId());
if (device != null) {
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java
index 9e6929e..2f8dc74 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusGasLiquidConfigServiceImpl.java
@@ -145,7 +145,7 @@
String str = busConfigDTO.getRetryTimes() + "," + busConfigDTO.getCollectInterval() + ","
+ busConfigDTO.getUploadPeriod() + ","
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();//按照重传次数、采集间隔、上传周期
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
String concentratorCode = redisCommon.sendMsg(DeviceTypeEnum.LG.toString(),
busConfig1.getDeviceId(), busConfig1.getFramecontent(), busConfigDTO.getAttemptsMax());
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusH2sConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusH2sConfigServiceImpl.java
index 860a67b..52ff667 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusH2sConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusH2sConfigServiceImpl.java
@@ -136,7 +136,7 @@
String str = busConfigDTO.getRetryTimes() + "," + busConfigDTO.getCollectInterval() + ","
+ busConfigDTO.getUploadPeriod() + ","
+ busConfigDTO.getIp() + "," + busConfigDTO.getPort();//按照重传次数、采集间隔、上传周期
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
String concentratorCode = redisCommon.sendMsg(DeviceTypeEnum.H2s.toString(),
busConfig1.getDeviceId(), busConfig1.getFramecontent(), busConfigDTO.getAttemptsMax());
diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusKadConfigServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusKadConfigServiceImpl.java
index 1a9bb6e..4aa661a 100644
--- a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusKadConfigServiceImpl.java
+++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/BusKadConfigServiceImpl.java
@@ -14,6 +14,7 @@
import com.casic.missiles.modular.system.dao.BusConfigMapper;
import com.casic.missiles.modular.system.dto.BusConfigDTO;
import com.casic.missiles.modular.system.dto.DeviceTypeEnum;
+import com.casic.missiles.modular.system.dto.ExcelModel.KadConfigExportDTO;
import com.casic.missiles.modular.system.model.BusConfig;
import com.casic.missiles.modular.system.model.Device;
import com.casic.missiles.modular.system.redis.RedisPublisherUtil;
@@ -152,7 +153,7 @@
+ (ObjectUtil.isNotEmpty(busConfigDTO.getIp())?busConfigDTO.getIp():"") + ","
+ (ObjectUtil.isNotEmpty(busConfigDTO.getPort())?busConfigDTO.getPort():"") + ","
+ busConfigDTO.getLowerThreshold() + "," + busConfigDTO.getUpperThreshold();//按照重传次数、采集间隔、上传周期
- busConfig1.setFramecontent(str);
+ busConfig1.setFramecontent(str.replaceAll("null",""));
save(busConfig1);
String concentratorCode = redisCommon.sendMsg(DeviceTypeEnum.KAD.toString(),
busConfig1.getDeviceId(), busConfig1.getFramecontent(), busConfigDTO.getAttemptsMax());
@@ -305,6 +306,8 @@
@Override
public void exp(List busConfigDTOList, HttpServletResponse response) {
+ List configExportDTOList = new ArrayList<>();
+
FileInputStream fis = null;
try {
response.setContentType("application/octet-stream");
@@ -318,22 +321,22 @@
var.put("list", new ArrayList