李晓鹤 / iot-scheduler · Commits

Commit 7efc23df24a4c769ce7102b1d85d4b68bd0184a8

Authored by 杨鸣坤
1 parent 994f0d24

池州经开区数据上报

Inline Side-by-side
Showing 1 changed file with 175 additions and 107 deletions
... ... @@ -2,12 +2,17 @@ package com.iot.scheduler.service.chizhou;
2 2
3 3 import com.alibaba.fastjson.JSON;
4 4 import com.iot.scheduler.utils.MqttUtils;
  5 +import com.iot.scheduler.utils.SqlTypedValueUtils;
  6 +import com.zaxxer.hikari.HikariConfig;
  7 +import com.zaxxer.hikari.HikariDataSource;
5 8 import lombok.extern.slf4j.Slf4j;
6 9 import org.springframework.stereotype.Service;
7 10
  11 +import java.sql.*;
8 12 import java.text.MessageFormat;
9 13 import java.text.SimpleDateFormat;
10 14 import java.util.*;
  15 +import java.util.Date;
11 16
12 17 /**
13 18 * 池州经开区数据上传
... ... @@ -20,80 +25,101 @@ public class CzDeviceReportService {
20 25 String username = "admin";
21 26 String password = "ly@666yc";
22 27
  28 + String jdbcUrl = "postgresql://106.15.73.210:5433/thingskit";
  29 + String jdbcUserName = "postgres";
  30 + String jdbcPassword = "postgres";
  31 + String selectSql = "SELECT\n" +
  32 + "dc.credentials_id AS sn,\n" +
  33 + "CASE\n" +
  34 + " WHEN ak2.long_v IS NULL OR (ak.bool_v = FALSE AND ak2.long_v IS NOT NULL) THEN 'OFF'\n" +
  35 + " WHEN tkl.long_v = 1 THEN 'ERROR'\n" +
  36 + " WHEN tkl2.long_v = 1 THEN 'STAND'\n" +
  37 + " WHEN tkl3.long_v = 1 THEN 'RUN'\n" +
  38 + " ELSE 'OFF'\n" +
  39 + " END AS status,\n" +
  40 + " de.organization_id\n" +
  41 + " FROM device de \n" +
  42 + "LEFT JOIN ts_kv_latest tkl on de.id = tkl.entity_id AND tkl.key = '64'\n" +
  43 + "LEFT JOIN ts_kv_latest tkl2 on de.id = tkl2.entity_id AND tkl2.key = '535'\n" +
  44 + "LEFT JOIN ts_kv_latest tkl3 on de.id = tkl3.entity_id AND tkl3.key = '534'\n" +
  45 + "LEFT JOIN attribute_kv ak ON de.id = ak.entity_id AND ak.entity_type = 'DEVICE' AND ak.attribute_key = 'active'\n" +
  46 + "LEFT JOIN attribute_kv ak2 ON de.id = ak2.entity_id AND ak2.entity_type = 'DEVICE' AND ak2.attribute_key = 'lastActivityTime'\n" +
  47 + "LEFT JOIN device_credentials dc ON de.id = dc.device_id\n" +
  48 + "WHERE (de.organization_id = '63934b6f-1e02-4d29-ac14-1a64649e2231' or de.organization_id = '35bcdb94-31ec-4750-9ee9-cc855aa66e17')\n" +
  49 + "AND de.device_profile_id = 'b2071bd0-df0b-11f0-9cb8-e3376d1e7978'\n" +
  50 + "union ALL\n" +
  51 + "SELECT \n" +
  52 + "dc.credentials_id AS sn,\n" +
  53 + "CASE\n" +
  54 + " WHEN ak2.long_v IS NULL OR (ak.bool_v = FALSE AND ak2.long_v IS NOT NULL) THEN 'OFF'\n" +
  55 + " ELSE 'RUN'\n" +
  56 + " END AS status,\n" +
  57 + " de.organization_id\n" +
  58 + "FROM device de \n" +
  59 + "LEFT JOIN attribute_kv ak ON de.id = ak.entity_id AND ak.entity_type = 'DEVICE' AND ak.attribute_key = 'active'\n" +
  60 + "LEFT JOIN attribute_kv ak2 ON de.id = ak2.entity_id AND ak2.entity_type = 'DEVICE' AND ak2.attribute_key = 'lastActivityTime'\n" +
  61 + "LEFT JOIN device_credentials dc ON de.id = dc.device_id\n" +
  62 + "WHERE (de.organization_id = '63934b6f-1e02-4d29-ac14-1a64649e2231' or de.organization_id = '35bcdb94-31ec-4750-9ee9-cc855aa66e17')\n" +
  63 + "AND (de.device_profile_id = 'fdf70e30-0272-11f1-9cb8-e3376d1e7978' OR de.device_profile_id = '6c1f9650-0298-11f1-9cb8-e3376d1e7978')\n";
  64 +
23 65 public void deviceReport() {
24   - List<String> deviceIdList = Arrays.asList("TCKJ-001", "TCKJ-002", "TCKJ-003", "TCKJ-004", "TCKJ-005", "TCKJ-006",
25   - "TCKJ-007", "TCKJ-008", "TCKJ-009", "TCKJ-010", "TCKJ-011", "TCKJ-012", "TCKJ-013", "TCKJ-014", "TCKJ-015",
26   - "TCKJ-016", "TCKJ-017", "TCKJ-018", "TCKJ-019", "TCKJ-020", "TCKJ-021", "TCKJ-022", "TCKJ-023", "TCKJ-024",
27   - "TCKJ-025", "TCKJ-026", "TCKJ-027", "TCKJ-028", "TCKJ-029", "TCKJ-030", "TCKJ-031", "TCKJ-032", "TCKJ-033",
28   - "TCKJ-034", "TCKJ-035", "TCKJ-036", "TCKJ-037", "TCKJ-038", "TCKJ-039", "TCKJ-040", "TCKJ-041",
29   - "vJAzZWk1Q2I8cdq7kx3z", "LmiW3ljI4KP487CeMmol", "ceK7YSNLrTjVSSPaFmn3", "6KePBYyCiEgo10iJXIrF",
30   - "9vrxIQhbaZ542DvCVne0", "XMLN-001", "XMLN-002", "XMLN-003", "XMLN-004", "XMLN-005", "XMLN-006", "XMLN-007",
31   - "XMLN-008", "XMLN-009", "XMLN-010", "XMLN-011", "XMLN-012", "XMLN-013", "XMLN-014", "XMLN-015", "XMLN-016",
32   - "XMLN-017", "XMLN-018", "XMLN-019", "XMLN-020", "XMLN-021", "XMLN-022", "XMLN-023", "XMLN-024", "XMLN-025",
33   - "XMLN-026", "XMLN-027", "XMLN-028", "XMLN-029", "XMLN-030", "XMLN-031", "XMLN-032", "XMLN-033", "XMLN-034",
34   - "XMLN-035", "XMLN-036", "XMLN-037", "XMLN-038", "XMLN-039", "XMLN-040", "XMLN-041", "XMLN-042", "XMLN-043",
35   - "XMLN-044", "XMLN-045", "XMLN-046", "XMLN-047", "XMLN-048", "XMLN-049", "XMLN-050", "XMLN-051", "XMLN-052",
36   - "GYDPF-014", "GYDPF-006", "KBS-1-1", "KBS-1-2", "KBS-3-1", "KBS-3-5", "KBS-3-3", "CS-001", "uzGf4mjzkOPwGO4aCOf3",
37   - "GYDPF-001", "GYDPF-010", "KBS-1-5", "KBS-2-2", "KBS-3-7", "CS-003", "LBKXrYxLQN9W7qmmqzp5", "rba7VggnqGdNyPvVNs1n",
38   - "GYDPF-002", "GYDPF-016", "GYDPF-017", "KBS-1-6", "EqFMlJarb2aDwpwvUi6J", "x2173A2HKOiPqeRsKtWY", "GYDPF-005",
39   - "KBS-1-3", "KBS-2-1", "KBS-3-4", "1fzR6X57k2aafbbkH4po", "lbqMr5pmkNJLWEPSa0yp", "mYz1kUajPOROg0Ewcfhr",
40   - "6TLlfKBbTMaUZGgHtvuH", "XTE8PKwLSYp29gE1umfW", "MqYu4y0OycHQkzZhothe", "IFeN0lAXlAVQ1fD7gwk1", "hZb9NsRCqtVBSagFqnPS",
41   - "r22r53PNgY7TeqCK5y14", "KCGSwfTvGCtBfd0qsH63", "4KzFQCncmwFh7UT4vbHp", "GYDPF-007", "KBS-3-2", "t2kkUTZYqxmKLN4X4VPB",
42   - "9vWKALGoat3XalEtQaRB", "vYtwLMkppPbM3CtB3U9U", "4vwTfMqi8oEtWxdEUrE8", "vVvK2cTLvjYtZX1dksyd", "GYDPF-003",
43   - "KBS-3-8", "2E6eUu66qxl5Llr6ib5v", "iWbeBfwg36lIpBRMDnvO", "GYDPF-015", "KBS-2-4", "OSbA7X7FGETF0TXub4OS",
44   - "GYDPF-008", "KBS-2-3", "KBS-2-7", "pRhGGECbXu6FBshyg2yg", "zrVVNRo8QIbjeYjdoCUq", "fjPj3oHW7cL5m0AE1t3y",
45   - "8dJsgqjmxIIduP4Sr2rL", "GYDPF-012", "KBS-1-4", "JZ8Tbzye8rKotYTbHUJw", "dwToSYEWr04sPtBUxaOH", "GYDPF-009",
46   - "oe3OmagW5Wi9yw9LfUr3", "2mDiH94D7uSh4CtD2bi0", "ceGyDxlK7xzMoUacIwCv", "gxECiKjMEsVkYyowKIMd", "irAqF3fmzaM5GIo8ZLAx",
47   - "GYDPF-013", "KBS-2-5", "KBS-3-6", "dxPdbg2UqqYADPMy9TVe", "cjFUpeVPTOh4Uf6wnVH1", "VR5XgpqhFWGMcwdy8yPQ",
48   - "GYDPF-004", "KBS-1-7", "KBS-2-8", "HEXmiSz0sXsahRHV2bQm", "0lIIGWP49Xuo91TnTvVx", "C99WsNGFSGQSV4n3YmrW",
49   - "3paJSiHK32wvVM6f1tO8", "GYDPF-011", "KBS-1-8", "KBS-2-6", "yrk5Cxa6EJncWX2kTywa", "xOxHHscmrEBhLTlmyRrF",
50   - "e3HzLoIl0p3iEM860EdK");
51   -
52   - log.info("总设备数量: {}台", deviceIdList.size());
  66 +// List<String> deviceIdList = Arrays.asList("TCKJ-001", "TCKJ-002", "TCKJ-003", "TCKJ-004", "TCKJ-005", "TCKJ-006",
  67 +// "TCKJ-007", "TCKJ-008", "TCKJ-009", "TCKJ-010", "TCKJ-011", "TCKJ-012", "TCKJ-013", "TCKJ-014", "TCKJ-015",
  68 +// "TCKJ-016", "TCKJ-017", "TCKJ-018", "TCKJ-019", "TCKJ-020", "TCKJ-021", "TCKJ-022", "TCKJ-023", "TCKJ-024",
  69 +// "TCKJ-025", "TCKJ-026", "TCKJ-027", "TCKJ-028", "TCKJ-029", "TCKJ-030", "TCKJ-031", "TCKJ-032", "TCKJ-033",
  70 +// "TCKJ-034", "TCKJ-035", "TCKJ-036", "TCKJ-037", "TCKJ-038", "TCKJ-039", "TCKJ-040", "TCKJ-041",
  71 +// "vJAzZWk1Q2I8cdq7kx3z", "LmiW3ljI4KP487CeMmol", "ceK7YSNLrTjVSSPaFmn3", "6KePBYyCiEgo10iJXIrF",
  72 +// "9vrxIQhbaZ542DvCVne0", "XMLN-001", "XMLN-002", "XMLN-003", "XMLN-004", "XMLN-005", "XMLN-006", "XMLN-007",
  73 +// "XMLN-008", "XMLN-009", "XMLN-010", "XMLN-011", "XMLN-012", "XMLN-013", "XMLN-014", "XMLN-015", "XMLN-016",
  74 +// "XMLN-017", "XMLN-018", "XMLN-019", "XMLN-020", "XMLN-021", "XMLN-022", "XMLN-023", "XMLN-024", "XMLN-025",
  75 +// "XMLN-026", "XMLN-027", "XMLN-028", "XMLN-029", "XMLN-030", "XMLN-031", "XMLN-032", "XMLN-033", "XMLN-034",
  76 +// "XMLN-035", "XMLN-036", "XMLN-037", "XMLN-038", "XMLN-039", "XMLN-040", "XMLN-041", "XMLN-042", "XMLN-043",
  77 +// "XMLN-044", "XMLN-045", "XMLN-046", "XMLN-047", "XMLN-048", "XMLN-049", "XMLN-050", "XMLN-051", "XMLN-052",
  78 +// "GYDPF-014", "GYDPF-006", "KBS-1-1", "KBS-1-2", "KBS-3-1", "KBS-3-5", "KBS-3-3", "CS-001", "uzGf4mjzkOPwGO4aCOf3",
  79 +// "GYDPF-001", "GYDPF-010", "KBS-1-5", "KBS-2-2", "KBS-3-7", "CS-003", "LBKXrYxLQN9W7qmmqzp5", "rba7VggnqGdNyPvVNs1n",
  80 +// "GYDPF-002", "GYDPF-016", "GYDPF-017", "KBS-1-6", "EqFMlJarb2aDwpwvUi6J", "x2173A2HKOiPqeRsKtWY", "GYDPF-005",
  81 +// "KBS-1-3", "KBS-2-1", "KBS-3-4", "1fzR6X57k2aafbbkH4po", "lbqMr5pmkNJLWEPSa0yp", "mYz1kUajPOROg0Ewcfhr",
  82 +// "6TLlfKBbTMaUZGgHtvuH", "XTE8PKwLSYp29gE1umfW", "MqYu4y0OycHQkzZhothe", "IFeN0lAXlAVQ1fD7gwk1", "hZb9NsRCqtVBSagFqnPS",
  83 +// "r22r53PNgY7TeqCK5y14", "KCGSwfTvGCtBfd0qsH63", "4KzFQCncmwFh7UT4vbHp", "GYDPF-007", "KBS-3-2", "t2kkUTZYqxmKLN4X4VPB",
  84 +// "9vWKALGoat3XalEtQaRB", "vYtwLMkppPbM3CtB3U9U", "4vwTfMqi8oEtWxdEUrE8", "vVvK2cTLvjYtZX1dksyd", "GYDPF-003",
  85 +// "KBS-3-8", "2E6eUu66qxl5Llr6ib5v", "iWbeBfwg36lIpBRMDnvO", "GYDPF-015", "KBS-2-4", "OSbA7X7FGETF0TXub4OS",
  86 +// "GYDPF-008", "KBS-2-3", "KBS-2-7", "pRhGGECbXu6FBshyg2yg", "zrVVNRo8QIbjeYjdoCUq", "fjPj3oHW7cL5m0AE1t3y",
  87 +// "8dJsgqjmxIIduP4Sr2rL", "GYDPF-012", "KBS-1-4", "JZ8Tbzye8rKotYTbHUJw", "dwToSYEWr04sPtBUxaOH", "GYDPF-009",
  88 +// "oe3OmagW5Wi9yw9LfUr3", "2mDiH94D7uSh4CtD2bi0", "ceGyDxlK7xzMoUacIwCv", "gxECiKjMEsVkYyowKIMd", "irAqF3fmzaM5GIo8ZLAx",
  89 +// "GYDPF-013", "KBS-2-5", "KBS-3-6", "dxPdbg2UqqYADPMy9TVe", "cjFUpeVPTOh4Uf6wnVH1", "VR5XgpqhFWGMcwdy8yPQ",
  90 +// "GYDPF-004", "KBS-1-7", "KBS-2-8", "HEXmiSz0sXsahRHV2bQm", "0lIIGWP49Xuo91TnTvVx", "C99WsNGFSGQSV4n3YmrW",
  91 +// "3paJSiHK32wvVM6f1tO8", "GYDPF-011", "KBS-1-8", "KBS-2-6", "yrk5Cxa6EJncWX2kTywa", "xOxHHscmrEBhLTlmyRrF",
  92 +// "e3HzLoIl0p3iEM860EdK");
  93 +
  94 + List<Object> needSyncDataList = initConnectAndSelectData();
  95 + log.info("总设备数量: {}台", needSyncDataList.size());
  96 +
  97 + Map<String, String> organizeIdAndClientIdMap = new HashMap<>(3);
  98 + organizeIdAndClientIdMap.put("63934b6f-1e02-4d29-ac14-1a64649e2231", "2020672119054331904"); // 安徽鑫米兰电子科技有限公司
  99 + organizeIdAndClientIdMap.put("35bcdb94-31ec-4750-9ee9-cc855aa66e17", "2020672015207559169"); // 安徽同池科技有限公司
  100 + organizeIdAndClientIdMap.put("365c477a-3e7b-4c4d-b80d-3c05379d5fda", "2020672228886376448"); // 凯盛信息显示材料（池州）有限公司
53 101
54 102 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
55 103 String formattedDate = sdf.format(new Date());
56 104 log.info("上报时间统一为: {}", formattedDate);
57 105
58   - // 用于统计状态分布
59   - Map<Integer, Integer> statusCountMap = new HashMap<>();
60   - statusCountMap.put(1, 0);
61   - statusCountMap.put(2, 0);
62   - statusCountMap.put(3, 0);
63   - statusCountMap.put(4, 0);
64   -
65 106 // 用于统计上报结果
66 107 int successCount = 0;
67 108 int failCount = 0;
68 109 List<String> failedDevices = new ArrayList<>();
69   -
70   - // 用于记录不同clientId的设备数量
71   - int clientId1Count = 0;
72   - int clientId2Count = 0;
73   - int clientId3Count = 0;
74   -
75   - for (int index = 0; index < deviceIdList.size(); index++) {
76   - String deviceId = deviceIdList.get(index);
  110 + for (int index = 0; index < needSyncDataList.size(); index++) {
  111 + Object needSyncData = needSyncDataList.get(index);
  112 + List<Object> dataList = (ArrayList) needSyncData;
  113 + String deviceId = dataList.get(0).toString();
  114 + String status = dataList.get(1).toString();
  115 + String organizeId = dataList.get(2).toString();
77 116
78 117 // 根据index确定clientId
79   - String clientId = "2020672015207559169";
80   - if (index > 45 && index <= 97) {
81   - clientId = "2020672119054331904";
82   - clientId2Count++;
83   - } else if (index > 97) {
84   - clientId = "2020672228886376448";
85   - clientId3Count++;
86   - } else {
87   - clientId1Count++;
88   - }
89   -
  118 + String clientId = organizeIdAndClientIdMap.get(organizeId);
90 119 String topic = MessageFormat.format("/{0}/{1}/properties/report", clientId, deviceId);
91 120
92 121 // 获取设备状态
93   - int deviceState = getDeviceState();
94   -
95   - // 统计状态分布
96   - statusCountMap.put(deviceState, statusCountMap.get(deviceState) + 1);
  122 + int deviceState = getDeviceState(status);
97 123
98 124 Map<String, Object> properties = new HashMap<>(5);
99 125 properties.put("type", 1);
... ... @@ -141,8 +167,6 @@ public class CzDeviceReportService {
141 167
142 168 // 任务完成，输出统计信息
143 169 log.info("========== 设备状态上报任务完成 ==========");
144   - log.info("任务完成时间: {}", new Date());
145   - log.info("设备总数: {}台", deviceIdList.size());
146 170 log.info("成功上报: {}台", successCount);
147 171 log.info("失败上报: {}台", failCount);
148 172
... ... @@ -150,60 +174,104 @@ public class CzDeviceReportService {
150 174 log.warn("失败设备列表: {}", failedDevices);
151 175 }
152 176
153   - // 输出clientId分布
154   - log.info("clientId分布统计:");
155   - log.info(" clientId-2020672015207559169: {}台", clientId1Count);
156   - log.info(" clientId-2020672119054331904: {}台", clientId2Count);
157   - log.info(" clientId-2020672228886376448: {}台", clientId3Count);
158   -
159   - // 输出状态分布统计
160   - log.info("设备状态分布统计 (按8:1:0.5:0.5比例):");
161   - log.info(" 状态1(80%): {}台 (占比: {}%)",
162   - statusCountMap.get(1),
163   - String.format("%.1f", statusCountMap.get(1) * 100.0 / deviceIdList.size()));
164   - log.info(" 状态2(10%): {}台 (占比: {}%)",
165   - statusCountMap.get(2),
166   - String.format("%.1f", statusCountMap.get(2) * 100.0 / deviceIdList.size()));
167   - log.info(" 状态3(5%): {}台 (占比: {}%)",
168   - statusCountMap.get(3),
169   - String.format("%.1f", statusCountMap.get(3) * 100.0 / deviceIdList.size()));
170   - log.info(" 状态4(5%): {}台 (占比: {}%)",
171   - statusCountMap.get(4),
172   - String.format("%.1f", statusCountMap.get(4) * 100.0 / deviceIdList.size()));
173   -
174   - // 计算实际比例
175   - double ratio1 = statusCountMap.get(1) / (double) statusCountMap.get(2);
176   - double ratio3 = statusCountMap.get(3) / (double) statusCountMap.get(2);
177   - double ratio4 = statusCountMap.get(4) / (double) statusCountMap.get(2);
178   - log.info("实际比例: {} : 1 : {} : {}",
179   - String.format("%.1f", ratio1),
180   - String.format("%.1f", ratio3),
181   - String.format("%.1f", ratio4));
182   -
183 177 // 任务执行耗时
184 178 log.info("========== 任务执行结束 ==========");
185 179 }
186 180
187   - private int getDeviceState() {
188   - Random random = new Random();
189   - double rand = random.nextDouble();
190   - int status;
191   -
192   - if (rand < 0.8) {
193   - status = 1; // 80%概率
194   - } else if (rand < 0.9) {
195   - status = 2; // 10%概率
196   - } else if (rand < 0.95) {
197   - status = 3; // 5%概率
  181 + private int getDeviceState(String status) {
  182 + int deviceState;
  183 + if ("RUN".equals(status)) {
  184 + deviceState = 1;
  185 + } else if ("STAND".equals(status)) {
  186 + deviceState = 2;
  187 + } else if ("OFF".equals(status)) {
  188 + deviceState = 3;
198 189 } else {
199   - status = 4; // 5%概率
  190 + deviceState = 4;
200 191 }
201 192
202   - // 调试日志
203   - if (log.isTraceEnabled()) {
204   - log.trace("生成设备状态: random={}, status={}", rand, status);
  193 + return deviceState;
  194 + }
  195 +
  196 + private List<Object> initConnectAndSelectData() {
  197 + Connection connection = null;
  198 + PreparedStatement statement = null;
  199 + ResultSet resultSet = null;
  200 + HikariDataSource dataSource = null;
  201 + List<Object> resultList = new ArrayList<>();
  202 +
  203 + log.info("开始连接数据库，URL: {}", jdbcUrl);
  204 +
  205 + try {
  206 + HikariConfig config = new HikariConfig();
  207 + config.setJdbcUrl(jdbcUrl);
  208 + config.setUsername(jdbcUserName);
  209 + config.setPassword(jdbcPassword);
  210 + config.setDriverClassName("org.postgresql.Driver");
  211 + config.setMaximumPoolSize(5);
  212 + config.setMinimumIdle(5);
  213 + config.setConnectionTimeout(60000);
  214 + config.setConnectionTestQuery("SELECT 1");
  215 +
  216 + dataSource = new HikariDataSource(config);
  217 + log.info("Hikari连接池配置完成");
  218 +
  219 + connection = dataSource.getConnection();
  220 + log.info("数据库连接成功");
  221 +
  222 + statement = connection.prepareStatement(selectSql);
  223 + log.info("执行SQL查询: {}", selectSql);
  224 +
  225 + resultSet = statement.executeQuery();
  226 + ResultSetMetaData metaData = resultSet.getMetaData();
  227 + int columnCount = metaData.getColumnCount();
  228 + log.info("查询结果集元数据获取成功，共{}列", columnCount);
  229 +
  230 + int rowCount = 0;
  231 + while (resultSet.next()) {
  232 + List<Object> result = new ArrayList<>(columnCount);
  233 + for (int index = 1; index <= columnCount; index++) {
  234 + int columnType = metaData.getColumnType(index);
  235 + Object value = SqlTypedValueUtils.getTypedValue(resultSet, index, columnType);
  236 + result.add(value);
  237 + }
  238 + resultList.add(result);
  239 + rowCount++;
  240 +
  241 + // 每处理1000行记录一次日志
  242 + if (rowCount % 1000 == 0) {
  243 + log.info("已处理{}行数据", rowCount);
  244 + }
  245 + }
  246 +
  247 + log.info("数据查询完成，共获取{}行数据", rowCount);
  248 +
  249 + } catch (SQLException e) {
  250 + log.error("数据库操作异常，URL: {}, 用户名: {}", jdbcUrl, jdbcUserName, e);
  251 + } catch (Exception e) {
  252 + log.error("初始化数据库连接或查询数据时发生异常", e);
  253 + } finally {
  254 + // 释放资源
  255 + try {
  256 + if (resultSet != null) resultSet.close();
  257 + if (statement != null) statement.close();
  258 + if (connection != null) connection.close();
  259 + log.info("数据库连接资源已释放");
  260 + } catch (SQLException e) {
  261 + log.error("关闭数据库资源时发生异常", e);
  262 + }
  263 +
  264 + if (dataSource != null) {
  265 + try {
  266 + dataSource.close();
  267 + log.info("HikariDataSource连接池已关闭");
  268 + } catch (Exception e) {
  269 + log.error("关闭HikariDataSource连接池时发生异常", e);
  270 + }
  271 + }
205 272 }
206 273
207   - return status;
  274 + log.info("数据库操作完成，返回{}条记录", resultList.size());
  275 + return resultList;
208 276 }
209 277 }
\ No newline at end of file
... ...