From e0ba02eb14e31451293a93dafd285b279d9a7775 Mon Sep 17 00:00:00 2001
From: yaowanxin <3588231647@qq.com>
Date: 星期四, 24 七月 2025 09:28:59 +0800
Subject: [PATCH] 文件后缀.mysql增添字段数据表名
---
cnas-device/src/main/java/com/ruoyi/device/service/impl/DeviceServiceImpl.java | 3 ++-
cnas-device/src/main/java/com/ruoyi/device/dto/DataConfigDto.java | 8 ++++++++
cnas-device/src/main/java/com/ruoyi/device/pojo/Device.java | 2 ++
cnas-device/src/main/java/com/ruoyi/device/utils/DataAcquisition.java | 28 ++++++++++++++++------------
cnas-device/src/main/java/com/ruoyi/device/dto/DeviceCollectionDto.java | 2 ++
5 files changed, 30 insertions(+), 13 deletions(-)
diff --git a/cnas-device/src/main/java/com/ruoyi/device/dto/DataConfigDto.java b/cnas-device/src/main/java/com/ruoyi/device/dto/DataConfigDto.java
index c8a3721..6f6fa82 100644
--- a/cnas-device/src/main/java/com/ruoyi/device/dto/DataConfigDto.java
+++ b/cnas-device/src/main/java/com/ruoyi/device/dto/DataConfigDto.java
@@ -36,4 +36,12 @@
@ApiModelProperty("璁惧ID")
private Integer deviceId;
+ //鏁版嵁搴撶敤鎴峰悕
+ @ApiModelProperty("鏁版嵁搴撶敤鎴峰悕")
+ private String dbUserName;
+ //鏁版嵁搴撳瘑鐮�
+ @ApiModelProperty("鏁版嵁搴撳瘑鐮�")
+ private String dbPassword;
+ @ApiModelProperty("鏁版嵁搴撹〃")
+ private String dbTable;
}
diff --git a/cnas-device/src/main/java/com/ruoyi/device/dto/DeviceCollectionDto.java b/cnas-device/src/main/java/com/ruoyi/device/dto/DeviceCollectionDto.java
index 6d84b56..aad7fe3 100644
--- a/cnas-device/src/main/java/com/ruoyi/device/dto/DeviceCollectionDto.java
+++ b/cnas-device/src/main/java/com/ruoyi/device/dto/DeviceCollectionDto.java
@@ -31,4 +31,6 @@
//鏁版嵁搴撳瘑鐮�
@ApiModelProperty(value = "鏁版嵁搴撳瘑鐮�")
private String dbPassword;
+ @ApiModelProperty(value = "鏁版嵁搴撹〃")
+ private String dbTable;
}
diff --git a/cnas-device/src/main/java/com/ruoyi/device/pojo/Device.java b/cnas-device/src/main/java/com/ruoyi/device/pojo/Device.java
index a3dbdc8..b1826dd 100644
--- a/cnas-device/src/main/java/com/ruoyi/device/pojo/Device.java
+++ b/cnas-device/src/main/java/com/ruoyi/device/pojo/Device.java
@@ -140,4 +140,6 @@
//鏁版嵁搴撳瘑鐮�
@ApiModelProperty("鏁版嵁搴撳瘑鐮�")
private String dbPassword;
+ @ApiModelProperty("鏁版嵁搴撹〃")
+ private String dbTable;
}
diff --git a/cnas-device/src/main/java/com/ruoyi/device/service/impl/DeviceServiceImpl.java b/cnas-device/src/main/java/com/ruoyi/device/service/impl/DeviceServiceImpl.java
index a9ac09f..ba01fa4 100644
--- a/cnas-device/src/main/java/com/ruoyi/device/service/impl/DeviceServiceImpl.java
+++ b/cnas-device/src/main/java/com/ruoyi/device/service/impl/DeviceServiceImpl.java
@@ -241,6 +241,7 @@
Device device1 = deviceMapper.selectById(device.getId());
dto.setDbUserName(device1.getDbUserName());
dto.setDbPassword(device1.getDbPassword());
+ dto.setDbTable(device1.getDbTable());
String ip = device.getIp();
// 鏍规嵁妫�楠岄」鑾峰彇config
@@ -254,7 +255,7 @@
map.putAll(dataCollectBridge(list, device, dto.getEntrustCode()));
} else {
- map.putAll(DataAcquisition.dataAcquisitionEntrance(list, device, dto.getEntrustCode(), dto.getEntrustCode(), ip, insProducts.get(0).getCableTag(),dto.getDbUserName(),dto.getDbPassword()));
+ map.putAll(DataAcquisition.dataAcquisitionEntrance(list, device, dto.getEntrustCode(), dto.getEntrustCode(), ip, insProducts.get(0).getCableTag(),dto.getDbUserName(),dto.getDbPassword(),dto.getDbTable()));
}
}
diff --git a/cnas-device/src/main/java/com/ruoyi/device/utils/DataAcquisition.java b/cnas-device/src/main/java/com/ruoyi/device/utils/DataAcquisition.java
index 9d740d3..360eae6 100644
--- a/cnas-device/src/main/java/com/ruoyi/device/utils/DataAcquisition.java
+++ b/cnas-device/src/main/java/com/ruoyi/device/utils/DataAcquisition.java
@@ -43,7 +43,7 @@
* @param device
* @return
*/
- public static Map<String, Object> dataAcquisitionEntrance(List<DataConfig> dataConfig, Device device, String entrustCode, String sampleCode, String ip, String cableTag, String dbUserName, String dbPassword) {
+ public static Map<String, Object> dataAcquisitionEntrance(List<DataConfig> dataConfig, Device device, String entrustCode, String sampleCode, String ip, String cableTag, String dbUserName, String dbPassword,String dbTable) {
// 鍒ゆ柇鏄惁鏄奖鍍忔祴閲忎华
if (device.getManagementNumber().equals("JCZX-ZB-OP07001")) {
if (device.getFileType().equals(".xlsx")) {
@@ -78,7 +78,8 @@
"&mdbSampleCode=" + device.getSampleCode() +
"&dbFileName=" + device.getDbFileName()+
"&dbUserName=" + dbUserName +
- "&dbPassword=" + dbPassword;
+ "&dbPassword=" + dbPassword +
+ "&dbTable=" + dbTable;
System.out.println("璇锋眰鐨� URL: " + http);
String result = null;
try {
@@ -136,8 +137,12 @@
}
break;
case ".db":
- map = analysisDb1(data, userMap, device);
-// map = analysisDb(data, userMap, device);
+// map = analysisDb1(data, userMap, device);
+ map = analysisDb(data, userMap, device);
+ break;
+ case ".mysql":
+// map = analysisDb1(data, userMap, device);
+ map = analysisDb(data, userMap, device);
break;
case ".png":
map = readPngString(data, userMap, device);
@@ -205,15 +210,15 @@
String refery = getRefer(v.get(config).getRefery());
for (int i = 0; i < dataList.size(); i++) {
JSONObject jsonObject1 = JSON.parseObject(dataList.get(i).toString());
- if (ObjectUtils.isNotEmpty(jsonObject1.get(refery))) {
- numberOfDataEntries.addAndGet(1);
- list.add(jsonObject1.get(refery));
- }
-// Object o = jsonObject1.get(refery);
-// if (ObjectUtils.isNotEmpty(o)) {
+// if (ObjectUtils.isNotEmpty(jsonObject1.get(refery))) {
// numberOfDataEntries.addAndGet(1);
-// list.add(o);
+// list.add(jsonObject1.get(refery));
// }
+ Object o = jsonObject1.get(refery);
+ if (ObjectUtils.isNotEmpty(o)) {
+ numberOfDataEntries.addAndGet(1);
+ list.add(o);
+ }
}
}
// 鎷兼帴鏁伴噰閰嶇疆
@@ -261,7 +266,6 @@
AtomicInteger numberOfDataEntries = new AtomicInteger();
List<Object> list = new ArrayList<>();
for (int config = 0; config < v.size(); config++) {
-// String refery = v.get(config).getRefery();
String refery = getRefer(v.get(config).getRefery());
for (int i = 0; i < dataList.size(); i++) {
JSONObject jsonObject1 = JSON.parseObject(dataList.get(i).toString());
--
Gitblit v1.9.3