Commit @d485f2d279055b02ac4eca13af34443d403d6358

김성원 2023-09-19

공단 수집 기능 추가

@d485f2d279055b02ac4eca13af34443d403d6358

c96ce73

d485f2d

server/main/java/kr/co/takensoft/crosswalk/common/service/ScedulerService.java

--- server/main/java/kr/co/takensoft/crosswalk/common/service/ScedulerService.java

+++ server/main/java/kr/co/takensoft/crosswalk/common/service/ScedulerService.java


 import java.net.MalformedURLException;
 import java.net.URL;
 import java.net.URLEncoder;
+import java.sql.SQLException;
 import java.text.SimpleDateFormat;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;

         // 등록된 횡단보도 리스트 확인
         List<HashMap<String, Object>> crosswalkList = dataCenterDAO.crosswalkList();
 
-
         //API URL Path
         String requestUrlPath = "/aiSafetyCrossing/requestLogInfo.json";
         String responseUrlPath = "/aiSafetyCrossing/responsLogInfo.json";

         parameter.put("ed_dt" , formatter.format(endCalendar.getTime()));
 
 
-
         String responseBody = httpGetConnection(apiRequestUrl,parameter);
         HashMap<String, Object> params = objectMapper.readValue(responseBody, new TypeReference<HashMap<String, Object>>(){});
         List<HashMap<String,Object>> resultData = (List<HashMap<String, Object>>) params.get("resultData");

         // 등록된 리스트
         for(HashMap<String, Object> crosswalk : crosswalkList){
            // 등롣 횡단보도 데이터 없을때 오류처리
-           if(resultData.stream().filter(c -> c.get("node_id") == crosswalk.get("node_id") && c.get("node_id") == crosswalk.get("node_id")).count() == 0){
+           if(resultData.stream().filter(c -> c.get("node_id").equals(crosswalk.get("node_id")) && c.get("crslk_az").equals(crosswalk.get("crslk_az"))).count() == 0){
                HashMap<String,Object> errorData = new HashMap<>();
                errorData.put("call_dt", formatter.format(endCalendar.getTime()));
                errorData.put("err_yn", "Y");

 
         // 데이터 저장
         for(HashMap<String,Object> temp :  resultData){
-        //    try {
+            try {
                 temp.put("user_id", temp.get("user_nm"));
                 requestDataList.add(temp);
-        //    }catch (NullPointerException e){
-        //        System.out.println(e.toString());
-         //   }
+            }catch (NullPointerException e){
+                System.out.println(e.toString());
+            }
         }
 
         // 내비게이션 수집 데이터 가져오기

 
         // 데이터 저장
         for(HashMap<String,Object> temp :  responseresultData){
-         //   try {
+           try {
                 temp.put("user_id", temp.get("user_nm"));
                 responseDataList.add(temp);
-       //     }catch (NullPointerException e){
-        //        System.out.println(e.toString());
-        //    }
+           }catch (NullPointerException e){
+                System.out.println(e.toString());
+           }
         }
 
-        System.out.println(requestDataList.size());
-        System.out.println(responseDataList.size());
         // DB 저장
-        System.out.println("result : " +dataCenterDAO.setApiRequestLog(requestDataList));
+        try {
+            dataCenterDAO.setApiRequestLog(requestDataList);
+        }catch (SQLException e){
+            System.out.println(e.toString());
+        }
+
+        try {
         dataCenterDAO.setApiResponseLog(responseDataList);
+        }catch (SQLException e){
+            System.out.println(e.toString());
+        }
 
     }
 

c96ce73

d485f2d

server/main/resources/log4j2.xml

--- server/main/resources/log4j2.xml

+++ server/main/resources/log4j2.xml


     </Appenders>
 
     <Loggers>
-        <Logger name="kr.co.takensoft" level="debug" additivity="false">
+        <Logger name="kr.co.takensoft" level="debug" additivity="true">
             <AppenderRef ref="Console"/>
         </Logger>
 
-        <Logger name="jdbc.sqltiming" level="info" additivity="false">
+        <Logger name="jdbc.sqltiming" level="info" additivity="true">
             <AppenderRef ref="Console"/>
         </Logger>
 
-        <Logger name="jdbc.resultsettable" level="info" additivity="false">
+        <Logger name="jdbc.resultsettable" level="info" additivity="true">
             <AppenderRef ref="Console"/>
         </Logger>
 

c96ce73

d485f2d

server/main/resources/mybatis/main/common-data-center-SQL.xml

--- server/main/resources/mybatis/main/common-data-center-SQL.xml

+++ server/main/resources/mybatis/main/common-data-center-SQL.xml


              VALUES
         <foreach collection="list" item="item" separator=",">
             (
-               to_timestamp(#{item.call_dt}, 'YYYY-MM-DD HH24:MI:SS')
+               to_timestamp(#{item.call_dt}, 'YYYY-MM-DD HH24:MI:SS.MS')
              , #{item.err_yn}
              , #{item.msg}
              , #{item.node_id}

         VALUES
         <foreach collection="list" item="item" separator=",">
             (
-            to_timestamp(#{item.call_dt}, 'YYYY-MM-DD HH24:MI:SS')
+            to_timestamp(#{item.call_dt}, 'YYYY-MM-DD HH24:MI:SS.MS')
             , #{item.err_yn}
             , #{item.msg}
             , #{item.node_id}

Add a comment

Open 0
Closed 0

List

...	...	@@ -19,6 +19,7 @@
19	19	import java.net.MalformedURLException;
20	20	import java.net.URL;
21	21	import java.net.URLEncoder;
	22	+import java.sql.SQLException;
22	23	import java.text.SimpleDateFormat;
23	24	import java.time.LocalDateTime;
24	25	import java.time.format.DateTimeFormatter;
...	...	@@ -333,7 +334,6 @@
333	334	// 등록된 횡단보도 리스트 확인
334	335	List<HashMap<String, Object>> crosswalkList = dataCenterDAO.crosswalkList();
335	336
336		-
337	337	//API URL Path
338	338	String requestUrlPath = "/aiSafetyCrossing/requestLogInfo.json";
339	339	String responseUrlPath = "/aiSafetyCrossing/responsLogInfo.json";
...	...	@@ -350,7 +350,6 @@
350	350	parameter.put("ed_dt" , formatter.format(endCalendar.getTime()));
351	351
352	352
353		-
354	353	String responseBody = httpGetConnection(apiRequestUrl,parameter);
355	354	HashMap<String, Object> params = objectMapper.readValue(responseBody, new TypeReference<HashMap<String, Object>>(){});
356	355	List<HashMap<String,Object>> resultData = (List<HashMap<String, Object>>) params.get("resultData");
...	...	@@ -359,7 +358,7 @@
359	358	// 등록된 리스트
360	359	for(HashMap<String, Object> crosswalk : crosswalkList){
361	360	// 등롣 횡단보도 데이터 없을때 오류처리
362		- if(resultData.stream().filter(c -> c.get("node_id") == crosswalk.get("node_id") && c.get("node_id") == crosswalk.get("node_id")).count() == 0){
	361	+ if(resultData.stream().filter(c -> c.get("node_id").equals(crosswalk.get("node_id")) && c.get("crslk_az").equals(crosswalk.get("crslk_az"))).count() == 0){
363	362	HashMap<String,Object> errorData = new HashMap<>();
364	363	errorData.put("call_dt", formatter.format(endCalendar.getTime()));
365	364	errorData.put("err_yn", "Y");
...	...	@@ -375,12 +374,12 @@
375	374
376	375	// 데이터 저장
377	376	for(HashMap<String,Object> temp : resultData){
378		- // try {
	377	+ try {
379	378	temp.put("user_id", temp.get("user_nm"));
380	379	requestDataList.add(temp);
381		- // }catch (NullPointerException e){
382		- // System.out.println(e.toString());
383		- // }
	380	+ }catch (NullPointerException e){
	381	+ System.out.println(e.toString());
	382	+ }
384	383	}
385	384
386	385	// 내비게이션 수집 데이터 가져오기
...	...	@@ -393,19 +392,26 @@
393	392
394	393	// 데이터 저장
395	394	for(HashMap<String,Object> temp : responseresultData){
396		- // try {
	395	+ try {
397	396	temp.put("user_id", temp.get("user_nm"));
398	397	responseDataList.add(temp);
399		- // }catch (NullPointerException e){
400		- // System.out.println(e.toString());
401		- // }
	398	+ }catch (NullPointerException e){
	399	+ System.out.println(e.toString());
	400	+ }
402	401	}
403	402
404		- System.out.println(requestDataList.size());
405		- System.out.println(responseDataList.size());
406	403	// DB 저장
407		- System.out.println("result : " +dataCenterDAO.setApiRequestLog(requestDataList));
	404	+ try {
	405	+ dataCenterDAO.setApiRequestLog(requestDataList);
	406	+ }catch (SQLException e){
	407	+ System.out.println(e.toString());
	408	+ }
	409	+
	410	+ try {
408	411	dataCenterDAO.setApiResponseLog(responseDataList);
	412	+ }catch (SQLException e){
	413	+ System.out.println(e.toString());
	414	+ }
409	415
410	416	}
411	417

...	...	@@ -1002,7 +1002,7 @@
1002	1002	VALUES
1003	1003	<foreach collection="list" item="item" separator=",">
1004	1004	(
1005		- to_timestamp(#{item.call_dt}, 'YYYY-MM-DD HH24:MI:SS')
	1005	+ to_timestamp(#{item.call_dt}, 'YYYY-MM-DD HH24:MI:SS.MS')
1006	1006	, #{item.err_yn}
1007	1007	, #{item.msg}
1008	1008	, #{item.node_id}
...	...	@@ -1035,7 +1035,7 @@
1035	1035	VALUES
1036	1036	<foreach collection="list" item="item" separator=",">
1037	1037	(
1038		- to_timestamp(#{item.call_dt}, 'YYYY-MM-DD HH24:MI:SS')
	1038	+ to_timestamp(#{item.call_dt}, 'YYYY-MM-DD HH24:MI:SS.MS')
1039	1039	, #{item.err_yn}
1040	1040	, #{item.msg}
1041	1041	, #{item.node_id}

...	...	@@ -20,15 +20,15 @@
20	20	</Appenders>
21	21
22	22	<Loggers>
23		- <Logger name="kr.co.takensoft" level="debug" additivity="false">
	23	+ <Logger name="kr.co.takensoft" level="debug" additivity="true">
24	24	<AppenderRef ref="Console"/>
25	25	</Logger>
26	26
27		- <Logger name="jdbc.sqltiming" level="info" additivity="false">
	27	+ <Logger name="jdbc.sqltiming" level="info" additivity="true">
28	28	<AppenderRef ref="Console"/>
29	29	</Logger>
30	30
31		- <Logger name="jdbc.resultsettable" level="info" additivity="false">
	31	+ <Logger name="jdbc.resultsettable" level="info" additivity="true">
32	32	<AppenderRef ref="Console"/>
33	33	</Logger>
34	34

Delete comment