代码整理

pm-admin/src/main/java/com/pm/web/controller/device/IbmsDeviceController.java

@@ -1,4 +1,4 @@
-package com.pm.web.controller.basic;
+package com.pm.web.controller.device;
 
 import java.util.List;
 import javax.servlet.http.HttpServletResponse;

pm-admin/src/main/resources/banner.txt

@@ -1,3 +1,3 @@
 Application Version: ${pm.version}
 Spring Boot Version: ${spring-boot.version}
-////////////////////////////////////////////////////////////////////
+//////////////////////项目启动中//////////////////////////

pm-system/pom.xml

@@ -7,18 +7,6 @@
         <groupId>com.pm</groupId>
         <version>3.8.8</version>
     </parent>
-    <build>
-        <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <configuration>
-                    <source>11</source>
-                    <target>11</target>
-                </configuration>
-            </plugin>
-        </plugins>
-    </build>
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>pm-system</artifactId>

pm-system/src/main/java/com/pm/sms/ApiSmsSender.java

@@ -1,39 +1,71 @@
 package com.pm.sms;
 
-import ch.qos.logback.classic.Logger;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
-import java.net.URI;
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
 import java.net.URLEncoder;
-import java.net.http.HttpClient;
-import java.net.http.HttpRequest;
-import java.net.http.HttpResponse;
+import java.nio.charset.StandardCharsets;
 
 // 网线通道 - API方式
 public class ApiSmsSender implements SmsSender {
+    private static final Logger log = LoggerFactory.getLogger(ApiSmsSender.class);
     private static final String API_URL = "https://sms.provider.com/send";
-    
+    private static final String API_KEY = "YOUR_API_KEY";
+
     @Override
     public boolean sendAlert(String phone, String message) {
+        HttpURLConnection connection = null;
         try {
-            HttpClient client = HttpClient.newHttpClient();
+            // 创建URL连接
+            URL url = new URL(API_URL);
+            connection = (HttpURLConnection) url.openConnection();
+            connection.setRequestMethod("POST");
+            connection.setRequestProperty("Content-Type", "application/json");
+            connection.setDoOutput(true);
+
+            // 构建JSON请求体
             String jsonBody = String.format(
-                "{\"key\":\"YOUR_API_KEY\",\"phone\":\"%s\",\"msg\":\"%s\"}", 
-                phone, URLEncoder.encode(message, "UTF-8"));
-            
-            HttpRequest request = HttpRequest.newBuilder()
-                .uri(URI.create(API_URL))
-                .header("Content-Type", "application/json")
-                .POST(HttpRequest.BodyPublishers.ofString(jsonBody))
-                .build();
-            
-            HttpResponse<String> response = client.send(
-                request, HttpResponse.BodyHandlers.ofString());
-            
-            return response.statusCode() == 200;
+                    "{\"key\":\"%s\",\"phone\":\"%s\",\"msg\":\"%s\"}",
+                    API_KEY,
+                    phone,
+                    URLEncoder.encode(message, "UTF-8")
+            );
+
+            // 发送请求
+            try (OutputStream os = connection.getOutputStream()) {
+                byte[] input = jsonBody.getBytes(StandardCharsets.UTF_8);
+                os.write(input, 0, input.length);
+            }
+
+            // 处理响应
+            int statusCode = connection.getResponseCode();
+            if (statusCode == HttpURLConnection.HTTP_OK) {
+                try (BufferedReader br = new BufferedReader(
+                        new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8))) {
+                    StringBuilder response = new StringBuilder();
+                    String responseLine;
+                    while ((responseLine = br.readLine()) != null) {
+                        response.append(responseLine.trim());
+                    }
+                    log.info("短信发送成功: {}", phone);
+                    return true;
+                }
+            } else {
+                log.warn("短信发送失败，状态码: {}", statusCode);
+                return false;
+            }
         } catch (Exception e) {
-            Logger log = null;
             log.error("API短信发送失败", e);
             return false;
+        } finally {
+            if (connection != null) {
+                connection.disconnect();
+            }
         }
     }
-}
+}