数字基建接口--以及配置文件数据库配置修改

ljq
1 parent d8f6e586
Showing 4 changed files with 147 additions and 1 deletions
src/main/java/com/bsth/CXFConfig.java
src/main/java/com/bsth/server_rs/dkl/StationPassengerService.java
src/main/resources/application-dev.properties
src/main/resources/application-prod.properties
@@ -14,6 +14,7 @@ import com.bsth.server_rs.bigdata.BigscreenService;
 import com.bsth.server_rs.departure.DepartureRestService;
 import com.bsth.server_rs.destroy.DestroyDetailRestService;
 import com.bsth.server_rs.directive.DirectiveRestService;
+import com.bsth.server_rs.dkl.StationPassengerService;
 import com.bsth.server_rs.dks.BxRestService;
 import com.bsth.server_rs.dks.DksRestService;
 import com.bsth.server_rs.dks.ExternalRestService;
@@ -146,6 +147,8 @@ public class CXFConfig {
     @Autowired
     private ExternalRestService externalRestService;
+    @Autowired
+    private StationPassengerService stationPassengerService;
     @Bean
     public Server rsServer() {
@@ -177,7 +180,8 @@ public class CXFConfig {
                 xxfbRestService,
                 manHoursRestService,
                 bxRestService,
-                externalRestService));
+                externalRestService,
+                stationPassengerService));
         endpoint.setProviders(Arrays.asList(new JacksonJsonProvider(), new AesExceptionMapper()));
         //endpoint.setFeatures(Arrays.asList(new Swagger2Feature()));
         endpoint.getInInterceptors().add(new AuthorizeInterceptor_IN());
+package com.bsth.server_rs.dkl;
+
+import com.bsth.common.ResponseCode;
+import com.bsth.util.ConfigUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.stereotype.Component;
+
+import javax.ws.rs.GET;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.*;
+
+@Component
+@Path("/station_passenger")
+@Produces({MediaType.APPLICATION_JSON})
+public class StationPassengerService {
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+    static String url;
+    static {
+        url = ConfigUtil.get("http.control.dkl_url");
+    }
+    @GET
+    @Path("/interactive")
+    public Map<String, Object> Interactive() {
+        Map<String, Object> map = new HashMap<>();
+        List<String> objList = new ArrayList<>();
+        String sql = "SELECT l.name,s.up_down,if(up_down = 0,start_station_name,end_station_name) as station,url FROM `station_video`  s LEFT JOIN bsth_c_line l on s.line_code = l.id ";
+        try {
+            List<Map<String, Object>> list = jdbcTemplate.query(sql, objList.toArray(),
+                    new RowMapper<Map<String, Object>>() {
+                        @Override
+                        public Map<String, Object> mapRow(ResultSet rs, int rowNum) throws SQLException {
+                            Map<String, Object> m = new HashMap<String, Object>();
+                            m.put("name", rs.getString("name"));
+                            m.put("upDown", rs.getString("up_down"));
+                            m.put("station", rs.getString("station"));
+                            m.put("url", rs.getString("url"));
+                            return m;
+                        }
+                    });
+            map.put("status", ResponseCode.SUCCESS);
+            map.put("list",list);
+        } catch (Exception e) {
+            map.put("status", ResponseCode.ERROR);
+            logger.error("站点客流调用失败---", e);
+        } finally {
+            return map;
+        }
+    }
+
+
+
+    @GET
+    @Path("/dkl/{date}")
+    public Map<String, Object> dkl(@PathParam("date") String date) {
+        Map<String, Object> map = new HashMap<>();
+        List<String> objList = new ArrayList<>();
+        String sql = "SELECT line_name,up_down,station_name,num,image from dkl_info where create_date like '%"+date+"%' ";
+        try {
+            List<Map<String, Object>> list = jdbcTemplate.query(sql, objList.toArray(),
+                    new RowMapper<Map<String, Object>>() {
+                        @Override
+                        public Map<String, Object> mapRow(ResultSet rs, int rowNum) throws SQLException {
+                            Map<String, Object> m = new HashMap<String, Object>();
+                            m.put("name", rs.getString("line_name"));
+                            m.put("upDown", rs.getString("up_down"));
+                            m.put("station", rs.getString("station_name"));
+                            m.put("num", rs.getString("num"));
+                            // 将图片路径转换为base64编码
+                            String imagePath = rs.getString("image");
+                            String base64Image = convertImageToBase64(url+ imagePath);
+                            m.put("image", base64Image);
+                            return m;
+                        }
+                    });
+            map.put("status", ResponseCode.SUCCESS);
+            map.put("list",list);
+        } catch (Exception e) {
+            map.put("status", ResponseCode.ERROR);
+            logger.error("站点客流调用失败---", e);
+        } finally {
+            return map;
+        }
+    }
+
+
+
+    /**
+     * 将图片文件转换为base64编码
+     * @param imagePath 图片路径
+     * @return base64编码字符串
+     */
+    private String convertImageToBase64(String imagePath) {
+        if (imagePath == null || imagePath.isEmpty()) {
+            return null;
+        }
+
+        try {
+            // 如果是相对路径，可能需要拼接完整路径
+            File imageFile = new File(imagePath);
+            // 判断是否为URL路径
+            // 判断是否为URL路径
+            if (imagePath.startsWith("http://") || imagePath.startsWith("https://")) {
+                // 处理网络图片
+                java.net.URL url = new java.net.URL(imagePath);
+                try (java.io.InputStream in = url.openStream()) {
+                    ByteArrayOutputStream buffer = new ByteArrayOutputStream();
+                    int nRead;
+                    byte[] data = new byte[1024];
+                    while ((nRead = in.read(data, 0, data.length)) != -1) {
+                        buffer.write(data, 0, nRead);
+                    }
+                    buffer.flush();
+                    byte[] imageBytes = buffer.toByteArray();
+                    return Base64.getEncoder().encodeToString(imageBytes);
+                }
+            }
+        } catch (Exception e) {
+            logger.error("图片转换为base64失败: " + imagePath, e);
+            return null;
+        }
+        return null;
+    }
+
+}
@@ -31,6 +31,7 @@ spring.redis.password=bsth_control_001
 spring.redis.port=28008
 http.control.service_data_url= http://127.0.0.1:9088/companyService
+http.control.dkl_url= http://127.0.0.1:9088
 http.control.secret.key= dVPHJkWUt5FhMT7jrM2dLV7QvlHAmZFd42rs1P0usBx8A7HZki
 http.gps.real.url= http://27.115.69.123:8800/transport_server/rtgps/
@@ -30,6 +30,7 @@ spring.redis.password=bsth_control_001
 spring.redis.port=28008
 http.control.service_data_url= http://10.10.150.103:9088/companyService
+http.control.dkl_url= http://10.10.150.103:9088
 http.control.secret.key= dVPHJkWUt5FhMT7jrM2dLV7QvlHAmZFd42rs1P0usBx8A7HZki
 http.gps.real.url= http://10.10.150.103:8080/transport_server/rtgps/
 \ No newline at end of file