Commit @50cccb9bdc08d7b42e1fe69f5aadad16703de382

dsjang 2024-07-29

MMS, 알림톡, 친구톡 기능 추가

@50cccb9bdc08d7b42e1fe69f5aadad16703de382

e38c24b

50cccb9

src/main/java/com/munjaon/client/config/DataSourceConfig.java

--- src/main/java/com/munjaon/client/config/DataSourceConfig.java

+++ src/main/java/com/munjaon/client/config/DataSourceConfig.java


 package com.munjaon.client.config;
 
+import com.zaxxer.hikari.HikariDataSource;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;

         System.out.println("MARIADB.URL : " + serverConfig.getString(dbms + ".URL"));
         System.out.println("MARIADB.USER : " + serverConfig.getString(dbms + ".USER"));
         System.out.println("MARIADB.PASSWORD : " + serverConfig.getString(dbms + ".PASSWORD"));
-        return DataSourceBuilder.create()
+        return DataSourceBuilder.create().type(HikariDataSource.class)
                 .driverClassName(serverConfig.getString(dbms + ".DRIVER"))
                 .url(serverConfig.getString(dbms + ".URL"))
                 .username(serverConfig.getString(dbms + ".USER"))

e38c24b

50cccb9

src/main/java/com/munjaon/client/config/RunnerConfiguration.java

--- src/main/java/com/munjaon/client/config/RunnerConfiguration.java

+++ src/main/java/com/munjaon/client/config/RunnerConfiguration.java

...	...	@@ -81,6 +81,34 @@
81	81
82	82	@Bean
83	83	@Order(2)
	84	+ public CommandLineRunner getRunnerBeanForKat() {
	85	+ try {
	86	+ String serviceName = "KAT";
	87	+ String serviceType = serverConfig.getString(serviceName + ".SERVICE_TYPE");
	88	+ CollectClientService collectClientService = new CollectClientService(serviceName, serviceType);
	89	+ collectClientService.start();
	90	+ } catch (Exception e) {
	91	+ throw new RuntimeException(e);
	92	+ }
	93	+ return args -> System.out.println("Runner Bean #2");
	94	+ }
	95	+
	96	+ @Bean
	97	+ @Order(2)
	98	+ public CommandLineRunner getRunnerBeanForKft() {
	99	+ try {
	100	+ String serviceName = "KFT";
	101	+ String serviceType = serverConfig.getString(serviceName + ".SERVICE_TYPE");
	102	+ CollectClientService collectClientService = new CollectClientService(serviceName, serviceType);
	103	+ collectClientService.start();
	104	+ } catch (Exception e) {
	105	+ throw new RuntimeException(e);
	106	+ }
	107	+ return args -> System.out.println("Runner Bean #2");
	108	+ }
	109	+
	110	+ @Bean
	111	+ @Order(2)
84	112	public CommandLineRunner getRunnerBeanForReport() {
85	113	try {
86	114	String serviceName = "REPORT";

e38c24b

50cccb9

src/main/java/com/munjaon/client/mariadb/service/MariaDBService.java

--- src/main/java/com/munjaon/client/mariadb/service/MariaDBService.java

+++ src/main/java/com/munjaon/client/mariadb/service/MariaDBService.java


         try {
             int msgCount = mariaDBMapper.checkTableForMessage();
             int logCount = mariaDBMapper.checkTableForLog();
-            if (msgCount == 1 && logCount == 1) {
+            if (msgCount > 0 && logCount > 0) {
                 isExist = true;
             }
         } catch (Exception e) {

e38c24b

50cccb9

src/main/java/com/munjaon/client/model/MunjaonMsg.java

--- src/main/java/com/munjaon/client/model/MunjaonMsg.java

+++ src/main/java/com/munjaon/client/model/MunjaonMsg.java


     private String filename02;
     private String filename03;
     private String deliverDate;
+    private String kakaoSenderKey;
+    private String kakaoTemplateCode;
+    private String kakaoJsonFile;
     private String sendDate;
     private String reportDate;
     private int fileCount = 0;

e38c24b

50cccb9

src/main/java/com/munjaon/client/server/config/ErrorCode.java

--- src/main/java/com/munjaon/client/server/config/ErrorCode.java

+++ src/main/java/com/munjaon/client/server/config/ErrorCode.java


 @Getter
 public enum ErrorCode {
     OK(200, "Success"),
-    ERROR_DATA_IS_NULL(300, "Msg is null"),
-    ERROR_SUBJECT_IS_NULL(310, "Subject is null"),
-    ERROR_MESSAGE_IS_NULL(320, "Message is null"),
+    ERROR_DATA_IS_NULL(300, "DATA is null"),
+    /* MSG_ID : 31X */
+    ERROR_MSGID_IS_NULL(310, "MSG_ID is null"),
+    ERROR_MSGID_IS_CAPACITY(311, "MSG_ID : SIZE is Zero Or Over"),
+    /* SENDER : 32X */
+    ERROR_SENDER_IS_NULL(320, "SENDER is null"),
+    ERROR_SENDER_IS_CAPACITY(321, "SENDER : SIZE is Zero Or Over"),
+    /* RECEIVER : 33X */
+    ERROR_RECEIVER_IS_NULL(330, "RECEIVER is null"),
+    ERROR_RECEIVER_IS_CAPACITY(331, "RECEIVER : SIZE is Zero Or Over"),
+    ERROR_RECEIVER_IS_INVALID(332, "RECEIVER is invalid number"),
+    /* SMS MESSAGE : 34X */
+    ERROR_SMS_MSG_IS_NULL(340, "SMS MESSAGE is null"),
+    ERROR_SMS_MSG_IS_CAPACITY(341, "SMS MESSAGE : SIZE is Zero Or Over"),
+    /* LMS, MMS SUBJECT : 35X */
+    ERROR_SUBJECT_IS_NULL(350, "Subject is null"),
+    ERROR_SUBJECT_OVER_CAPACITY(351, "Subject is over capacity"),
+    /* LMS, MMS MESSAGE : 36X */
+    ERROR_MULTI_MESSAGE_IS_NULL(360, "Multimedia Message is null"),
+    ERROR_MULTI_MESSAGE_OVER_CAPACITY(361, "Multimedia Message is over capacity"),
+    /* MMS IMAGE : 37X */
+    ERROR_MMS_IMAGE_IS_NULL(370, "MMS_IMAGE is not exist"),
+    ERROR_MMS_IMAGE_IS_EXT(371, "MMS_IMAGE is not support extension"),
+    ERROR_MMS_IMAGE_IS_NOT_PATH(372, "MMS_IMAGE is not exists"),
+    ERROR_MMS_IMAGE_IS_OVER_CAPACITY(373, "MMS_IMAGE is over capacity"),
+    /* KAKAO_SENDER_KEY : 38X */
+    ERROR_KAKAO_SENDER_KEY_IS_NULL(380, "KAKAO_SENDER_KEY is null"),
+    ERROR_KAKAO_SENDER_KEY_OVER_CAPACITY(381, "KAKAO_SENDER_KEY is over capacity"),
+    /* KAKAO_TEMPLATE_CODE : 39X */
+    ERROR_KAKAO_TEMPLATE_CODE_IS_NULL(390, "KAKAO_TEMPLATE_CODE is null"),
+    ERROR_KAKAO_TEMPLATE_CODE_OVER_CAPACITY(391, "KAKAO_TEMPLATE_CODE is over capacity"),
+    /* KAKAO_JSON_FILE : 40X */
+    ERROR_KAKAO_JSON_FILE_IS_NULL(400, "KAKAO_JSON_FILE is not exist"),
+    ERROR_KAKAO_JSON_FILE_IS_EXT(401, "KAKAO_JSON_FILE is not support extension"),
+    ERROR_KAKAO_JSON_FILE_IS_NOT_PATH(402, "KAKAO_JSON_FILE is not exists"),
+    ERROR_KAKAO_JSON_FILE_IS_OVER_CAPACITY(403, "KAKAO_JSON_FILE is over capacity"),
+
     ERROR_FILE_NOT_FOUND(390, "File Not Found"),
     ERROR_FILE_CAPACITY_EXCEED(391, "File capacity exceeded");
 

50cccb9

src/main/java/com/munjaon/client/server/packet/KakaoMessage.java (added)

+++ src/main/java/com/munjaon/client/server/packet/KakaoMessage.java

...	...	@@ -0,0 +1,157 @@
	1	+package com.munjaon.client.server.packet;
	2	+
	3	+import com.munjaon.client.model.MunjaonMsg;
	4	+import com.munjaon.client.util.CommonUtil;
	5	+
	6	+import java.io.File;
	7	+import java.io.IOException;
	8	+import java.nio.ByteBuffer;
	9	+import java.nio.file.Files;
	10	+
	11	+public final class KakaoMessage {
	12	+ public static final int LIMIT_FILE_CAPACITY = 1024 * 50;
	13	+
	14	+ public static final int DELIVER_JSON_FILENAME_LENGTH = 40;
	15	+ public static final int DELIVER_JSON_FILENAME_POSITION = 0;
	16	+
	17	+ public static final int DELIVER_JSON_FILESIZE_LENGTH = 8;
	18	+ public static final int DELIVER_JSON_FILESIZE_POSITION = DELIVER_JSON_FILENAME_POSITION + DELIVER_JSON_FILENAME_LENGTH;
	19	+
	20	+ public static final int DELIVER_KAKAO_BODY_LENGTH = 2233;
	21	+ public static final int DELIVER_KAKAO_ACK_BODY_LENGTH = 21;
	22	+
	23	+ /* DELIVER */
	24	+ /* SUBJECT */
	25	+ public static final int DELIVER_SUBJECT_LENGTH = 40;
	26	+ public static final int DELIVER_SUBJECT_POSITION = CommonMessage.DELIVER_MSG_TYPE_POSITION + CommonMessage.DELIVER_MSG_TYPE_LENGTH;
	27	+ /* MESSAGE */
	28	+ public static final int DELIVER_MESSAGE_LENGTH = 2000;
	29	+ public static final int DELIVER_MESSAGE_POSITION = DELIVER_SUBJECT_POSITION + DELIVER_SUBJECT_LENGTH;
	30	+ /* KAKAO_SENDER_KEY */
	31	+ public static final int DELIVER_KAKAO_SENDER_KEY_LENGTH = 40;
	32	+ public static final int DELIVER_KAKAO_SENDER_KEY_POSITION = DELIVER_MESSAGE_POSITION + DELIVER_MESSAGE_LENGTH;
	33	+ /* KAKAO_TEMPLATE_CODE */
	34	+ public static final int DELIVER_KAKAO_TEMPLATE_CODE_LENGTH = 64;
	35	+ public static final int DELIVER_KAKAO_TEMPLATE_CODE_POSITION = DELIVER_KAKAO_SENDER_KEY_POSITION + DELIVER_KAKAO_SENDER_KEY_LENGTH;
	36	+
	37	+ public static void putSubjectForDeliver(ByteBuffer buffer, String subject) {
	38	+ if (buffer == null \|\| subject == null) {
	39	+ return;
	40	+ }
	41	+ subject = CommonUtil.cutString(subject, DELIVER_SUBJECT_LENGTH);
	42	+ buffer.put(DELIVER_SUBJECT_POSITION, subject.getBytes());
	43	+ }
	44	+ public static String getSubjectForDeliver(ByteBuffer buffer) {
	45	+ if (buffer == null) {
	46	+ return null;
	47	+ }
	48	+
	49	+ buffer.position(DELIVER_SUBJECT_POSITION);
	50	+ byte[] destArray = new byte[DELIVER_SUBJECT_LENGTH];
	51	+ buffer.get(destArray);
	52	+
	53	+ return Packet.getString(destArray);
	54	+ }
	55	+
	56	+ public static void putMessageForDeliver(ByteBuffer buffer, String message) {
	57	+ if (buffer == null \|\| message == null) {
	58	+ return;
	59	+ }
	60	+ message = CommonUtil.cutString(message, DELIVER_MESSAGE_LENGTH);
	61	+ buffer.put(DELIVER_MESSAGE_POSITION, message.getBytes());
	62	+ }
	63	+ public static String getMessageForDeliver(ByteBuffer buffer) {
	64	+ if (buffer == null) {
	65	+ return null;
	66	+ }
	67	+
	68	+ buffer.position(DELIVER_MESSAGE_POSITION);
	69	+ byte[] destArray = new byte[DELIVER_MESSAGE_LENGTH];
	70	+ buffer.get(destArray);
	71	+
	72	+ return Packet.getString(destArray);
	73	+ }
	74	+ public static void putKakaoSenderKeyForDeliver(ByteBuffer buffer, String kakaoSenderKey) {
	75	+ if (buffer == null \|\| kakaoSenderKey == null) {
	76	+ return;
	77	+ }
	78	+ kakaoSenderKey = CommonUtil.cutString(kakaoSenderKey, DELIVER_KAKAO_SENDER_KEY_LENGTH);
	79	+ buffer.put(DELIVER_KAKAO_SENDER_KEY_POSITION, kakaoSenderKey.getBytes());
	80	+ }
	81	+ public static String getKakaoSenderKeyForDeliver(ByteBuffer buffer) {
	82	+ if (buffer == null) {
	83	+ return null;
	84	+ }
	85	+
	86	+ buffer.position(DELIVER_KAKAO_SENDER_KEY_POSITION);
	87	+ byte[] destArray = new byte[DELIVER_KAKAO_SENDER_KEY_LENGTH];
	88	+ buffer.get(destArray);
	89	+
	90	+ return Packet.getString(destArray);
	91	+ }
	92	+ public static void putKakaoTemplateCodeForDeliver(ByteBuffer buffer, String kakaoTemplateCode) {
	93	+ if (buffer == null \|\| kakaoTemplateCode == null) {
	94	+ return;
	95	+ }
	96	+ kakaoTemplateCode = CommonUtil.cutString(kakaoTemplateCode, DELIVER_KAKAO_TEMPLATE_CODE_LENGTH);
	97	+ buffer.put(DELIVER_KAKAO_TEMPLATE_CODE_POSITION, kakaoTemplateCode.getBytes());
	98	+ }
	99	+ public static String getKakaoTemplateCodeForDeliver(ByteBuffer buffer) {
	100	+ if (buffer == null) {
	101	+ return null;
	102	+ }
	103	+
	104	+ buffer.position(DELIVER_KAKAO_TEMPLATE_CODE_POSITION);
	105	+ byte[] destArray = new byte[DELIVER_KAKAO_TEMPLATE_CODE_LENGTH];
	106	+ buffer.get(destArray);
	107	+
	108	+ return Packet.getString(destArray);
	109	+ }
	110	+ public static void makeDataForDeliver(ByteBuffer buffer, MunjaonMsg data) {
	111	+ if (buffer == null \|\| data == null) {
	112	+ return;
	113	+ }
	114	+ /* MSG_ID */
	115	+ CommonMessage.putMessageIdForDeliver(buffer, data.getMsgId());
	116	+ /* SENDER */
	117	+ CommonMessage.putSenderForDeliver(buffer, data.getSendPhone());
	118	+ /* RECEIVER */
	119	+ CommonMessage.putReceiverForDeliver(buffer, data.getRecvPhone());
	120	+ /* RESERVE_TIME */
	121	+ CommonMessage.putReserveTimeForDeliver(buffer, data.getReserveDate());
	122	+ /* REQUEST_TIME */
	123	+ CommonMessage.putRequestTimeForDeliver(buffer, data.getRequestDate());
	124	+ /* MSG_TYPE */
	125	+ CommonMessage.putMsgTypeForDeliver(buffer, data.getMsgType());
	126	+ /* Subject */
	127	+ putSubjectForDeliver(buffer, data.getSubject());
	128	+ /* MSG */
	129	+ putMessageForDeliver(buffer, data.getMessage());
	130	+ /* KAKAO_SENDER_KEY */
	131	+ putKakaoSenderKeyForDeliver(buffer, data.getKakaoSenderKey());
	132	+ /* KAKAO_TEMPLATE_CODE */
	133	+ putKakaoTemplateCodeForDeliver(buffer, data.getKakaoTemplateCode());
	134	+ }
	135	+
	136	+ public static ByteBuffer makeJsonForDeliver(String path, String fileName) {
	137	+ if (path == null \|\| fileName == null) {
	138	+ return null;
	139	+ }
	140	+ File file = new File(path + fileName);
	141	+ if (file.exists() == false) {
	142	+ return null;
	143	+ }
	144	+ ByteBuffer fileHeadBuffer = ByteBuffer.allocate(MmsMessage.DELIVER_MMS_FILENAME_LENGTH + MmsMessage.DELIVER_MMS_FILESIZE_LENGTH);
	145	+ fileHeadBuffer.put(DELIVER_JSON_FILENAME_POSITION, fileName.getBytes());
	146	+ fileHeadBuffer.put(DELIVER_JSON_FILESIZE_POSITION, String.valueOf(file.length()).getBytes());
	147	+ ByteBuffer fileBodyBuffer = ByteBuffer.allocate((int) file.length());
	148	+ ByteBuffer fileBuffer = null;
	149	+ try {
	150	+ fileBodyBuffer.put(Files.readAllBytes(file.toPath()));
	151	+ fileBuffer = ByteBuffer.allocate(fileHeadBuffer.capacity() + fileBodyBuffer.capacity());
	152	+ Packet.mergeBuffers(fileBuffer, fileHeadBuffer, fileBodyBuffer);
	153	+ } catch (IOException e) {}
	154	+
	155	+ return fileBuffer;
	156	+ }
	157	+}

e38c24b

50cccb9

src/main/java/com/munjaon/client/server/packet/LmsMessage.java

--- src/main/java/com/munjaon/client/server/packet/LmsMessage.java

+++ src/main/java/com/munjaon/client/server/packet/LmsMessage.java


 import java.nio.ByteBuffer;
 
 public final class LmsMessage {
-    public static final int DELIVER_LMS_BODY_LENGTH = 2091;
+    public static final int DELIVER_LMS_BODY_LENGTH = 2129;
     public static final int DELIVER_LMS_ACK_BODY_LENGTH = 21;
 
     /* DELIVER */

e38c24b

50cccb9

src/main/java/com/munjaon/client/server/packet/MmsMessage.java

--- src/main/java/com/munjaon/client/server/packet/MmsMessage.java

+++ src/main/java/com/munjaon/client/server/packet/MmsMessage.java


 import com.munjaon.client.model.MunjaonMsg;
 import com.munjaon.client.util.CommonUtil;
 
+import java.io.File;
+import java.io.IOException;
 import java.nio.ByteBuffer;
+import java.nio.file.Files;
 
 public final class MmsMessage {
     public static final int LIMIT_FILE_CAPACITY = 1024 * 300;

     public static final int DELIVER_MMS_FILESIZE_LENGTH = 8;
     public static final int DELIVER_MMS_FILESIZE_POSITION = DELIVER_MMS_FILENAME_POSITION + DELIVER_MMS_FILENAME_LENGTH;
 
-    public static final int DELIVER_MMS_BODY_LENGTH = 2092;
+    public static final int DELIVER_MMS_BODY_LENGTH = 2130;
     public static final int DELIVER_MMS_ACK_BODY_LENGTH = 21;
 
     /* DELIVER */

         /* FileCount */
         putFileCountForDeliver(buffer, data.getFileCount());
     }
+
+    public static ByteBuffer makeImageForDeliver(String path, String fileName) {
+        if (path == null || fileName == null) {
+            return null;
+        }
+        File file = new File(path + fileName);
+        if (file.exists() == false) {
+            return null;
+        }
+        ByteBuffer fileHeadBuffer = ByteBuffer.allocate(MmsMessage.DELIVER_MMS_FILENAME_LENGTH + MmsMessage.DELIVER_MMS_FILESIZE_LENGTH);
+        fileHeadBuffer.put(DELIVER_MMS_FILENAME_POSITION, fileName.getBytes());
+        fileHeadBuffer.put(DELIVER_MMS_FILESIZE_POSITION, String.valueOf(file.length()).getBytes());
+        ByteBuffer fileBodyBuffer = ByteBuffer.allocate((int) file.length());
+        ByteBuffer fileBuffer = null;
+        try {
+            fileBodyBuffer.put(Files.readAllBytes(file.toPath()));
+            fileBuffer = ByteBuffer.allocate(fileHeadBuffer.capacity() + fileBodyBuffer.capacity());
+            Packet.mergeBuffers(fileBuffer, fileHeadBuffer, fileBodyBuffer);
+        } catch (IOException e) {}
+
+        return fileBuffer;
+    }
 }

e38c24b

50cccb9

src/main/java/com/munjaon/client/server/packet/SmsMessage.java

--- src/main/java/com/munjaon/client/server/packet/SmsMessage.java

+++ src/main/java/com/munjaon/client/server/packet/SmsMessage.java


 
     /* DELIVER */
     /* MESSAGE */
+    public static final int DELIVER_MESSAGE_TRANS_LENGTH = 90;
     public static final int DELIVER_MESSAGE_LENGTH = 160;
     public static final int DELIVER_MESSAGE_POSITION = CommonMessage.DELIVER_MSG_TYPE_POSITION + CommonMessage.DELIVER_MSG_TYPE_LENGTH;
 

e38c24b

50cccb9

src/main/java/com/munjaon/client/server/service/CollectClientService.java

--- src/main/java/com/munjaon/client/server/service/CollectClientService.java

+++ src/main/java/com/munjaon/client/server/service/CollectClientService.java


 import com.munjaon.client.server.config.ErrorCode;
 import com.munjaon.client.server.packet.*;
 import com.munjaon.client.service.DatabaseTypeWorker;
+import com.munjaon.client.util.MessageCheckUtil;
 import com.munjaon.client.util.MessageUtil;
 import org.json.simple.JSONObject;
 

     public void checkReady() {
         worker = DatabaseTypeWorker.find(System.getProperty("DBMS"));
         if (worker == null) {
+            saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is not ready]");
             return;
         }
+
+        saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
         this.IS_READY_YN = worker.checkTableExists();
     }
 
     @Override
     public void initResources() {
+        saveSystemLog("Resource is initializing ... ...");
         this.address = getProp("HOST");
         this.port = Integer.parseInt(getProp("DELIVER.PORT"));
         this.id = getProp("ID");
         this.pwd = getProp("PASSWORD");
-        saveSystemLog("Try Connect to " + this.address + ":" + this.port);
+        saveSystemLog("Try Connect to [ADDRESS : " + this.address + "] [PORT : " + this.port + "] [ID : " + this.id + "]");
         try {
             socketChannel = SocketChannel.open(new InetSocketAddress(this.address, this.port));
             socketChannel.configureBlocking(false);
         } catch (IOException e) {
-            saveSystemLog("Connect Fail " + this.address + ":" + this.port);
+            saveSystemLog("Connect Fail to [ADDRESS : " + this.address + "] [PORT : " + this.port + "] [ID : " + this.id + "]");
+            saveSystemLog("ERROR [" + e.getMessage() + "]");
             throw new RuntimeException(e);
         }
     }

             try {
                 socketChannel.close();
             } catch (IOException e) {
+                saveSystemLog("ERROR [" + e.getMessage() + "]");
                 throw new RuntimeException(e);
             }
         }

                 messageService();
                 linkCheckService();
             } catch (Exception e) {
+                saveSystemLog("ERROR [" + e.getMessage() + "]");
+                saveSystemLog("ERROR DETAIL");
+                saveSystemLog(e.toString());
                 throw new RuntimeException(e);
             }
         }

         ByteBuffer sendBuffer = Bind.makeBindBuffer(id, pwd);
         ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + Bind.BIND_ACK_BODY_LENGTH);
         try {
-            saveSystemLog("sendBuffer " + sendBuffer.position() + ":" + sendBuffer.limit());
-            saveSystemLog("Bind Try Connect to " + this.address + ":" + this.port);
+            saveSystemLog("[BIND REQUEST] [IP : " + this.address + "] [PORT : " + this.port + "] [ID : " + this.id + "]");
             socketChannel.write(sendBuffer);
-            saveSystemLog("Bind Read to " + this.address + ":" + this.port);
             while (true) {
                 int recvCount = socketChannel.read(recvBuffer);
                 if (recvCount == -1) {
+                    saveSystemLog("[BIND ERROR] [CONNECTION CLOSED]");
                     throw new RuntimeException("BIND ERROR");
                 } else if (recvCount > 0) {
                     String resultCode = Bind.getBindAckResultCode(recvBuffer);
                     saveSystemLog("resultCode " + resultCode);
                     if ("00".equals(resultCode)) {
                         lastPacketSendTime = System.currentTimeMillis();
-                        saveSystemLog("Bind OK");
+                        saveSystemLog("[BIND SUCCESS] [CONNECTION IS ESTABLISHED]");
                         break;
                     } else {
-                        saveSystemLog("Bind FAIL");
+                        saveSystemLog("[BIND FAIL] [RESULT CODE : " + resultCode + "]");
                         throw new RuntimeException("Bind FAIL");
                     }
                 }
             }
-
         } catch (Exception e) {
+            saveSystemLog("ERROR [" + e.getMessage() + "]");
+            saveSystemLog("ERROR DETAIL");
+            saveSystemLog(e.toString());
             throw new RuntimeException(e);
         }
     }

     private void messageService() {
         List<MunjaonMsg> list = selectToDeliver();
         if (list == null || list.isEmpty()) {
-            try {
-                Thread.sleep(1000);
-            } catch (InterruptedException e) {
-                throw new RuntimeException(e);
-            }
+            try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}
             return;
         }
+
         for (MunjaonMsg data : list) {
             switch (this.serviceType) {
                 case "SMS": smsMessageService(data); break;

                 case "KFT": kftMessageService(data); break;
                 default:break;
             }
-
         }
     }
 
-    private void lmsMessageService(MunjaonMsg data) {
-        if (data == null) {
-            return;
-        }
-        ByteBuffer sendBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + LmsMessage.DELIVER_LMS_BODY_LENGTH);
-        ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + LmsMessage.DELIVER_LMS_ACK_BODY_LENGTH);
+    private void smsMessageService(MunjaonMsg data) {
         try {
-            Header.putHeader(sendBuffer, Header.COMMAND_DELIVER, LmsMessage.DELIVER_LMS_BODY_LENGTH);
-            LmsMessage.makeDataForDeliver(sendBuffer, data);
-            saveSystemLog("Deliver Send");
+            /* 공통 메시지 유효성 체크 */
+            int checkCommonCode = MessageCheckUtil.validateMessageForCommon(data);
+            int checkMsgCode = MessageCheckUtil.validateMessageForSms(data);
+            if (checkCommonCode != ErrorCode.OK.getCode() || checkMsgCode != ErrorCode.OK.getCode()) {
+                saveSystemLog("[MESSAGE FILTER] [COMMON_CODE : " + checkCommonCode + "] [MSG_CODE : " + checkMsgCode + "]");
+                saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
+                /* 전송처리 */
+                worker.updateToDeliver(data.getMsgId());
+                /* 실패처리 */
+                MunjaonMsg errorMsg = null;
+                if (checkCommonCode != ErrorCode.OK.getCode()) {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkCommonCode), MessageUtil.getTime(), "ETC");;
+                } else {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkMsgCode), MessageUtil.getTime(), "ETC");;
+                }
+                worker.updateToReport(errorMsg);
+                /* 처리완료 */
+                return;
+            }
+
+            /* 정상인 경우 메시지 전송 */
+            ByteBuffer sendBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + SmsMessage.DELIVER_SMS_BODY_LENGTH);
+            ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + SmsMessage.DELIVER_SMS_ACK_BODY_LENGTH);
+            Header.putHeader(sendBuffer, Header.COMMAND_DELIVER, SmsMessage.DELIVER_SMS_BODY_LENGTH);
+            SmsMessage.makeDataForDeliver(sendBuffer, data);
+            saveSystemLog("[MESSAGE SEND] [... ...]");
+            saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
             socketChannel.write(sendBuffer);
             while (true) {
                 int recvCount = socketChannel.read(recvBuffer);
                 if (recvCount == -1) {
+                    saveSystemLog("[MESSAGE SEND] [FAIL] [SOCKET IS CLOSED]");
                     throw new RuntimeException("DELIVER ERROR");
                 } else if (recvCount > 0) {
                     worker.updateToDeliver(data.getMsgId());
-                    saveSystemLog("Deliver OK");
+                    saveSystemLog("[MESSAGE SEND] [SUCCESS]");
+                    lastPacketSendTime = System.currentTimeMillis();
+                    break;
+                }
+            }
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    private void lmsMessageService(MunjaonMsg data) {
+        try {
+            /* 공통 메시지 유효성 체크 */
+            int checkCommonCode = MessageCheckUtil.validateMessageForCommon(data);
+            int checkMsgCode = MessageCheckUtil.validateMessageForMedia(data);
+            if (checkCommonCode != ErrorCode.OK.getCode() || checkMsgCode != ErrorCode.OK.getCode()) {
+                saveSystemLog("[MESSAGE FILTER] [COMMON_CODE : " + checkCommonCode + "] [MSG_CODE : " + checkMsgCode + "]");
+                saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
+                /* 전송처리 */
+                worker.updateToDeliver(data.getMsgId());
+                /* 실패처리 */
+                MunjaonMsg errorMsg = null;
+                if (checkCommonCode != ErrorCode.OK.getCode()) {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkCommonCode), MessageUtil.getTime(), "ETC");;
+                } else {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkMsgCode), MessageUtil.getTime(), "ETC");;
+                }
+                worker.updateToReport(errorMsg);
+                /* 처리완료 */
+                return;
+            }
+
+            /* 정상인 경우 메시지 전송 */
+            ByteBuffer sendBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + LmsMessage.DELIVER_LMS_BODY_LENGTH);
+            ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + LmsMessage.DELIVER_LMS_ACK_BODY_LENGTH);
+            Header.putHeader(sendBuffer, Header.COMMAND_DELIVER, LmsMessage.DELIVER_LMS_BODY_LENGTH);
+            LmsMessage.makeDataForDeliver(sendBuffer, data);
+            saveSystemLog("[MESSAGE SEND] [... ...]");
+            saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
+            socketChannel.write(sendBuffer);
+            while (true) {
+                int recvCount = socketChannel.read(recvBuffer);
+                if (recvCount == -1) {
+                    saveSystemLog("[MESSAGE SEND] [FAIL] [SOCKET IS CLOSED]");
+                    throw new RuntimeException("DELIVER ERROR");
+                } else if (recvCount > 0) {
+                    worker.updateToDeliver(data.getMsgId());
+                    saveSystemLog("[MESSAGE SEND] [SUCCESS]");
                     lastPacketSendTime = System.currentTimeMillis();
                     break;
                 }

     }
 
     private void mmsMessageService(MunjaonMsg data) {
-        if (data == null) {
-            return;
-        }
-        ByteBuffer sendBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + MmsMessage.DELIVER_MMS_BODY_LENGTH);
-        ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + MmsMessage.DELIVER_MMS_ACK_BODY_LENGTH);
         try {
+            /* MMS Image 저장 경로 */
             String path = System.getProperty("ROOTPATH") + File.separator + "mmsfile" + File.separator;
-            int fileCount = 0;
-            int errorCode = validateErrorCodeForMms(data);
-            if (errorCode != ErrorCode.OK.getCode()) {
-                MunjaonMsg errorMsg = new MunjaonMsg();
-                errorMsg.setMsgId(data.getMsgId());
-                errorMsg.setAgentCode("00");
-                errorMsg.setSendStatus(String.valueOf(errorCode));
-                errorMsg.setSendDate(MessageUtil.getTime());
-                errorMsg.setTelecom("ETC");
+            /* 공통 메시지 유효성 체크 */
+            int checkCommonCode = MessageCheckUtil.validateMessageForCommon(data);
+            int checkMsgCode = MessageCheckUtil.validateMessageForMedia(data);
+            int checkImageCode = MessageCheckUtil.validateMessageForImage(data, path);
+            if (checkCommonCode != ErrorCode.OK.getCode() || checkMsgCode != ErrorCode.OK.getCode() || checkImageCode != ErrorCode.OK.getCode()) {
+                saveSystemLog("[MESSAGE FILTER] [COMMON_CODE : " + checkCommonCode + "] [MSG_CODE : " + checkMsgCode + "] [IMAGE_CODE : " + checkImageCode + "]");
+                saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
+                /* 전송처리 */
                 worker.updateToDeliver(data.getMsgId());
+                /* 실패처리 */
+                MunjaonMsg errorMsg = null;
+                if (checkCommonCode != ErrorCode.OK.getCode()) {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkCommonCode), MessageUtil.getTime(), "ETC");
+                }else if (checkMsgCode != ErrorCode.OK.getCode()) {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkMsgCode), MessageUtil.getTime(), "ETC");
+                } else {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkImageCode), MessageUtil.getTime(), "ETC");
+                }
                 worker.updateToReport(errorMsg);
+                /* 처리완료 */
+                return;
             }
+
+            /* 정상인 경우 메시지 전송 */
+            ByteBuffer sendBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + MmsMessage.DELIVER_MMS_BODY_LENGTH);
+            ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + MmsMessage.DELIVER_MMS_ACK_BODY_LENGTH);
+            int fileCount = 0;
             /* File check */
-            ByteBuffer file01Buffer = null;
-            if (data.getFilename01() != null) {
-                File file = new File(path + data.getFilename01());
-                if (file.exists()) {
-                    fileCount++;
-                    ByteBuffer fileHeadBuffer = ByteBuffer.allocate(MmsMessage.DELIVER_MMS_FILENAME_LENGTH + MmsMessage.DELIVER_MMS_FILESIZE_LENGTH);
-                    ByteBuffer fileBodyBuffer = ByteBuffer.allocate((int) file.length());
-                    fileBodyBuffer.put(Files.readAllBytes(file.toPath()));
-                    file01Buffer = ByteBuffer.allocate(fileHeadBuffer.capacity() + fileBodyBuffer.capacity());
-                    Packet.mergeBuffers(file01Buffer, fileHeadBuffer, fileBodyBuffer);
-                }
+            ByteBuffer file01Buffer = MmsMessage.makeImageForDeliver(path, data.getFilename01());
+            if (file01Buffer != null) {
+                saveSystemLog("file01Buffer : " + file01Buffer.capacity());
             }
-            ByteBuffer file02Buffer = null;
-            if (data.getFilename02() != null) {
-                File file = new File(path + data.getFilename02());
-                if (file.exists()) {
-                    fileCount++;
-                    ByteBuffer fileHeadBuffer = ByteBuffer.allocate(MmsMessage.DELIVER_MMS_FILENAME_LENGTH + MmsMessage.DELIVER_MMS_FILESIZE_LENGTH);
-                    ByteBuffer fileBodyBuffer = ByteBuffer.allocate((int) file.length());
-                    fileBodyBuffer.put(Files.readAllBytes(file.toPath()));
-                    file02Buffer = ByteBuffer.allocate(fileHeadBuffer.capacity() + fileBodyBuffer.capacity());
-                    Packet.mergeBuffers(file02Buffer, fileHeadBuffer, fileBodyBuffer);
-                }
+            if (file01Buffer != null) {
+                fileCount++;
             }
-            ByteBuffer file03Buffer = null;
-            if (data.getFilename03() != null) {
-                File file = new File(path + data.getFilename03());
-                if (file.exists()) {
-                    fileCount++;
-                    ByteBuffer fileHeadBuffer = ByteBuffer.allocate(MmsMessage.DELIVER_MMS_FILENAME_LENGTH + MmsMessage.DELIVER_MMS_FILESIZE_LENGTH);
-                    ByteBuffer fileBodyBuffer = ByteBuffer.allocate((int) file.length());
-                    fileBodyBuffer.put(Files.readAllBytes(file.toPath()));
-                    file03Buffer = ByteBuffer.allocate(fileHeadBuffer.capacity() + fileBodyBuffer.capacity());
-                    Packet.mergeBuffers(file03Buffer, fileHeadBuffer, fileBodyBuffer);
-                }
+            ByteBuffer file02Buffer = MmsMessage.makeImageForDeliver(path, data.getFilename02());
+            if (file02Buffer != null) {
+                saveSystemLog("file02Buffer : " + file02Buffer.capacity());
+            }
+            if (file02Buffer != null) {
+                fileCount++;
+            }
+            ByteBuffer file03Buffer = MmsMessage.makeImageForDeliver(path, data.getFilename03());
+            if (file03Buffer != null) {
+                saveSystemLog("file03Buffer : " + file03Buffer.capacity());
+            }
+            if (file03Buffer != null) {
+                fileCount++;
             }
             /* fileCount 저장 */
             data.setFileCount(fileCount);
 
             Header.putHeader(sendBuffer, Header.COMMAND_DELIVER, MmsMessage.DELIVER_MMS_BODY_LENGTH);
             MmsMessage.makeDataForDeliver(sendBuffer, data);
-            saveSystemLog("Deliver Send");
+            saveSystemLog("[MESSAGE SEND] [... ...]");
+            saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
 
             ByteBuffer[] byteBuffers = new ByteBuffer[fileCount + 1];
             int index = 0;

             while (true) {
                 int recvCount = socketChannel.read(recvBuffer);
                 if (recvCount == -1) {
+                    saveSystemLog("[MESSAGE SEND] [FAIL] [SOCKET IS CLOSED]");
                     throw new RuntimeException("DELIVER ERROR");
                 } else if (recvCount > 0) {
                     worker.updateToDeliver(data.getMsgId());
-                    saveSystemLog("Deliver OK");
+                    saveSystemLog("[MESSAGE SEND] [SUCCESS]");
                     lastPacketSendTime = System.currentTimeMillis();
                     break;
                 }
             }
         } catch (IOException e) {
+            e.printStackTrace();
             throw new RuntimeException(e);
         }
     }
 
-    private int validateErrorCodeForMms(MunjaonMsg data) {
-        if (data == null) {
-            return ErrorCode.ERROR_DATA_IS_NULL.getCode();
-        }
-        if (data.getSubject() == null) {
-            return ErrorCode.ERROR_SUBJECT_IS_NULL.getCode();
-        }
-        if (data.getMessage() == null) {
-            return ErrorCode.ERROR_MESSAGE_IS_NULL.getCode();
-        }
-        /* 파일 체크 */
-        String path = System.getProperty("ROOTPATH") + File.separator + "mmsfile" + File.separator;
-        int fileCount = 0;
-        if (data.getFilename01() != null) {
-            File file = new File(path + data.getFilename01());
-            if (file.exists()) {
-                if (file.length() > MmsMessage.LIMIT_FILE_CAPACITY) {
-                    return ErrorCode.ERROR_FILE_CAPACITY_EXCEED.getCode();
-                } else {
-                    fileCount++;
-                }
-            }
-        }
-        if (data.getFilename02() != null) {
-            File file = new File(path + data.getFilename02());
-            if (file.exists()) {
-                if (file.length() > MmsMessage.LIMIT_FILE_CAPACITY) {
-                    return ErrorCode.ERROR_FILE_CAPACITY_EXCEED.getCode();
-                } else {
-                    fileCount++;
-                }
-            }
-        }
-        if (data.getFilename03() != null) {
-            File file = new File(path + data.getFilename03());
-            if (file.exists()) {
-                if (file.length() > MmsMessage.LIMIT_FILE_CAPACITY) {
-                    return ErrorCode.ERROR_FILE_CAPACITY_EXCEED.getCode();
-                } else {
-                    fileCount++;
-                }
-            }
-        }
-        if (fileCount == 0) {
-            return ErrorCode.ERROR_FILE_NOT_FOUND.getCode();
-        }
-        return ErrorCode.OK.getCode();
-    }
-
     private void katMessageService(MunjaonMsg data) {
-
-    }
-
-    private void kftMessageService(MunjaonMsg data) {
-
-    }
-
-    private void smsMessageService(MunjaonMsg data) {
-        ByteBuffer sendBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + SmsMessage.DELIVER_SMS_BODY_LENGTH);
-        ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + SmsMessage.DELIVER_SMS_ACK_BODY_LENGTH);
         try {
-            Header.putHeader(sendBuffer, Header.COMMAND_DELIVER, SmsMessage.DELIVER_SMS_BODY_LENGTH);
-            SmsMessage.makeDataForDeliver(sendBuffer, data);
-            saveSystemLog("Deliver Send");
-            socketChannel.write(sendBuffer);
+            /* Kakao Json 저장 경로 */
+            String path = System.getProperty("ROOTPATH") + File.separator + "kakaofile" + File.separator;
+            /* 공통 메시지 유효성 체크 */
+            int checkCommonCode = MessageCheckUtil.validateMessageForCommon(data);
+            int checkMsgCode = MessageCheckUtil.validateMessageForKakao(data);
+            int checkFileCode = MessageCheckUtil.validateJsonFile(path, data.getKakaoJsonFile());
+
+            if (checkCommonCode != ErrorCode.OK.getCode() || checkMsgCode != ErrorCode.OK.getCode() || checkFileCode != ErrorCode.OK.getCode()) {
+                saveSystemLog("[MESSAGE FILTER] [COMMON_CODE : " + checkCommonCode + "] [MSG_CODE : " + checkMsgCode + "] [JSON_FILE_CODE : " + checkFileCode + "]");
+                saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
+                /* 전송처리 */
+                worker.updateToDeliver(data.getMsgId());
+                /* 실패처리 */
+                MunjaonMsg errorMsg = null;
+                if (checkCommonCode != ErrorCode.OK.getCode()) {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkCommonCode), MessageUtil.getTime(), "ETC");
+                }else if (checkMsgCode != ErrorCode.OK.getCode()) {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkMsgCode), MessageUtil.getTime(), "ETC");
+                } else {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkFileCode), MessageUtil.getTime(), "ETC");
+                }
+                worker.updateToReport(errorMsg);
+                /* 처리완료 */
+                return;
+            }
+
+            /* 정상인 경우 메시지 전송 */
+            ByteBuffer sendBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + KakaoMessage.DELIVER_KAKAO_BODY_LENGTH);
+            ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + KakaoMessage.DELIVER_KAKAO_ACK_BODY_LENGTH);
+            /* File check */
+            ByteBuffer fileBuffer = KakaoMessage.makeJsonForDeliver(path, data.getKakaoJsonFile());
+
+            Header.putHeader(sendBuffer, Header.COMMAND_DELIVER, KakaoMessage.DELIVER_KAKAO_BODY_LENGTH);
+            KakaoMessage.makeDataForDeliver(sendBuffer, data);
+            saveSystemLog("[MESSAGE SEND] [... ...]");
+            saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
+
+            ByteBuffer[] byteBuffers = new ByteBuffer[2];
+            byteBuffers[0] = sendBuffer;
+            byteBuffers[1] = fileBuffer;
+
+            socketChannel.write(byteBuffers);
+
             while (true) {
                 int recvCount = socketChannel.read(recvBuffer);
                 if (recvCount == -1) {
+                    saveSystemLog("[MESSAGE SEND] [FAIL] [SOCKET IS CLOSED]");
                     throw new RuntimeException("DELIVER ERROR");
                 } else if (recvCount > 0) {
                     worker.updateToDeliver(data.getMsgId());
-                    saveSystemLog("Deliver OK");
+                    saveSystemLog("[MESSAGE SEND] [SUCCESS]");
                     lastPacketSendTime = System.currentTimeMillis();
                     break;
                 }
             }
         } catch (IOException e) {
+            e.printStackTrace();
+            throw new RuntimeException(e);
+        }
+    }
+
+    private void kftMessageService(MunjaonMsg data) {
+        try {
+            /* Kakao Json 저장 경로 */
+            String path = System.getProperty("ROOTPATH") + File.separator + "kakaofile" + File.separator;
+            /* 공통 메시지 유효성 체크 */
+            int checkCommonCode = MessageCheckUtil.validateMessageForCommon(data);
+            int checkMsgCode = MessageCheckUtil.validateMessageForKakao(data);
+            int checkFileCode = MessageCheckUtil.validateJsonFile(path, data.getKakaoJsonFile());
+            if (checkCommonCode != ErrorCode.OK.getCode() || checkMsgCode != ErrorCode.OK.getCode() || checkFileCode != ErrorCode.OK.getCode()) {
+                saveSystemLog("[MESSAGE FILTER] [COMMON_CODE : " + checkCommonCode + "] [MSG_CODE : " + checkMsgCode + "] [JSON_FILE_CODE : " + checkFileCode + "]");
+                saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
+                /* 전송처리 */
+                worker.updateToDeliver(data.getMsgId());
+                /* 실패처리 */
+                MunjaonMsg errorMsg = null;
+                if (checkCommonCode != ErrorCode.OK.getCode()) {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkCommonCode), MessageUtil.getTime(), "ETC");
+                }else if (checkMsgCode != ErrorCode.OK.getCode()) {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkMsgCode), MessageUtil.getTime(), "ETC");
+                } else {
+                    errorMsg = MessageCheckUtil.setReportMessage(data.getMsgId(), "00", String.valueOf(checkFileCode), MessageUtil.getTime(), "ETC");
+                }
+                worker.updateToReport(errorMsg);
+                /* 처리완료 */
+                return;
+            }
+
+            /* 정상인 경우 메시지 전송 */
+            ByteBuffer sendBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + KakaoMessage.DELIVER_KAKAO_BODY_LENGTH);
+            ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + KakaoMessage.DELIVER_KAKAO_ACK_BODY_LENGTH);
+            /* File check */
+            ByteBuffer fileBuffer = KakaoMessage.makeJsonForDeliver(path, data.getKakaoJsonFile());
+
+            Header.putHeader(sendBuffer, Header.COMMAND_DELIVER, KakaoMessage.DELIVER_KAKAO_BODY_LENGTH);
+            KakaoMessage.makeDataForDeliver(sendBuffer, data);
+            saveSystemLog("[MESSAGE SEND] [... ...]");
+            saveSystemLog("[MESSAGE DATA : " + data.toString() + "]");
+
+            ByteBuffer[] byteBuffers = new ByteBuffer[2];
+            byteBuffers[0] = sendBuffer;
+            byteBuffers[1] = fileBuffer;
+
+            socketChannel.write(byteBuffers);
+
+            while (true) {
+                int recvCount = socketChannel.read(recvBuffer);
+                if (recvCount == -1) {
+                    saveSystemLog("[MESSAGE SEND] [FAIL] [SOCKET IS CLOSED]");
+                    throw new RuntimeException("DELIVER ERROR");
+                } else if (recvCount > 0) {
+                    worker.updateToDeliver(data.getMsgId());
+                    saveSystemLog("[MESSAGE SEND] [SUCCESS]");
+                    lastPacketSendTime = System.currentTimeMillis();
+                    break;
+                }
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
             throw new RuntimeException(e);
         }
     }

 
         ByteBuffer recvBuffer = ByteBuffer.allocate(Header.HEADER_LENGTH + LinkCheck.LINK_CHECK_ACK_BODY_LENGTH);
         try {
-            saveSystemLog("LinkCheck Send");
+            saveSystemLog("[LINK_CHECK SEND] [... ...]");
             socketChannel.write(LinkCheck.makeLinkCheckBuffer());
             while (true) {
                 int recvCount = socketChannel.read(recvBuffer);
                 if (recvCount == -1) {
+                    saveSystemLog("[LINK_CHECK SEND] [FAIL] [SOCKET IS CLOSED]");
                     throw new RuntimeException("LINK_CHECK ERROR");
                 } else if (recvCount > 0) {
-                    saveSystemLog("LinkCheck OK");
+                    saveSystemLog("[LINK_CHECK SEND] [SUCCESS]");
                     lastPacketSendTime = System.currentTimeMillis();
                     break;
                 }

e38c24b

50cccb9

src/main/java/com/munjaon/client/server/service/ReportClientService.java

--- src/main/java/com/munjaon/client/server/service/ReportClientService.java

+++ src/main/java/com/munjaon/client/server/service/ReportClientService.java


     public void checkReady() {
         worker = DatabaseTypeWorker.find(System.getProperty("DBMS"));
         if (worker == null) {
+            saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is not ready]");
             return;
         }
+
+        saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
         this.IS_READY_YN = worker.checkTableExists();
     }
 

         this.port = Integer.parseInt(getProp("PORT"));
         this.id = getProp("ID");
         this.pwd = getProp("PASSWORD");
-        saveSystemLog("Try Connect to " + this.address + ":" + this.port);
+        saveSystemLog("Try Connect to [ADDRESS : " + this.address + "] [PORT : " + this.port + "] [ID : " + this.id + "]");
         try {
             socketChannel = SocketChannel.open(new InetSocketAddress(this.address, this.port));
             socketChannel.configureBlocking(false);
         } catch (IOException e) {
-            saveSystemLog("Connect Fail " + this.address + ":" + this.port);
+            saveSystemLog("Connect Fail to [ADDRESS : " + this.address + "] [PORT : " + this.port + "] [ID : " + this.id + "]");
+            saveSystemLog("ERROR [" + e.getMessage() + "]");
+            saveSystemLog("ERROR DETAIL");
+            saveSystemLog(e.toString());
             throw new RuntimeException(e);
         }
     }

             try {
                 socketChannel.close();
             } catch (IOException e) {
+                saveSystemLog("ERROR [" + e.getMessage() + "]");
+                saveSystemLog("ERROR DETAIL");
+                saveSystemLog(e.toString());
                 throw new RuntimeException(e);
             }
         }

e38c24b

50cccb9

src/main/java/com/munjaon/client/server/service/Service.java

--- src/main/java/com/munjaon/client/server/service/Service.java

+++ src/main/java/com/munjaon/client/server/service/Service.java


                 initLogFile();
                 /* 3. Runflag reload */
                 reloadCheckRun();
-
+                saveSystemLog("[SERVICE_READY : " + IS_READY_YN + " || SERVICE_RUN : " + IS_RUN_YN);
                 if (isRun() && isReady()) {
                     /* 3. 서비스 초기화 */
                     initResources();

                     doService();
                     /* 5. 서비스 자원 해제 */
                     releaseResources();
-                    saveSystemLog("Service Stopped.");
+                    saveSystemLog("[SERVICE IS STOPPED] [... ...]");
                 } else {
-                    saveSystemLog("Service is Not Running.");
+                    saveSystemLog("[SERVICE IS NOT RUNNING] [... ...]");
                 }
                 /* 6. 3초간 sleep */
                 Thread.sleep(3000);

50cccb9

src/main/java/com/munjaon/client/util/MessageCheckUtil.java (added)

+++ src/main/java/com/munjaon/client/util/MessageCheckUtil.java

...	...	@@ -0,0 +1,277 @@
	1	+package com.munjaon.client.util;
	2	+
	3	+import com.munjaon.client.model.MunjaonMsg;
	4	+import com.munjaon.client.server.config.ErrorCode;
	5	+import com.munjaon.client.server.packet.*;
	6	+
	7	+import java.io.File;
	8	+
	9	+public class MessageCheckUtil {
	10	+ public static int validateMessageForCommon(MunjaonMsg data) {
	11	+ int code = isNullMessageForCommon(data);
	12	+ if (code != ErrorCode.OK.getCode()) {
	13	+ return code;
	14	+ }
	15	+
	16	+ return isLengthMessageForCommon(data);
	17	+ }
	18	+ public static int isLengthMessageForCommon(MunjaonMsg data) {
	19	+ /* MSG_ID */
	20	+ String value = data.getMsgId().trim();
	21	+ if (value.length() == 0 \|\| value.getBytes().length > CommonMessage.DELIVER_MESSAGE_ID_LENGTH) {
	22	+ return ErrorCode.ERROR_MSGID_IS_CAPACITY.getCode();
	23	+ }
	24	+ /* SENDER */
	25	+ value = MessageUtil.doNumber(data.getSendPhone());
	26	+ if (value.getBytes().length < 8 \|\| value.getBytes().length > CommonMessage.DELIVER_SENDER_LENGTH) {
	27	+ return ErrorCode.ERROR_SENDER_IS_CAPACITY.getCode();
	28	+ }
	29	+ /* RECEIVER */
	30	+ value = MessageUtil.doNumber(data.getRecvPhone());
	31	+ if (value.getBytes().length < 10 \|\| value.getBytes().length > CommonMessage.DELIVER_RECEIVER_LENGTH) {
	32	+ return ErrorCode.ERROR_RECEIVER_IS_CAPACITY.getCode();
	33	+ }
	34	+ if ("01".equals(value.substring(0, 2)) == false) {
	35	+ return ErrorCode.ERROR_RECEIVER_IS_INVALID.getCode();
	36	+ }
	37	+
	38	+ return ErrorCode.OK.getCode();
	39	+ }
	40	+
	41	+ public static int isNullMessageForCommon(MunjaonMsg data) {
	42	+ if (data == null) {
	43	+ return ErrorCode.ERROR_DATA_IS_NULL.getCode();
	44	+ }
	45	+ if (data.getMsgId() == null \|\| data.getMsgId().isEmpty()) {
	46	+ return ErrorCode.ERROR_MSGID_IS_NULL.getCode();
	47	+ }
	48	+ if (data.getSendPhone() == null \|\| data.getSendPhone().isEmpty()) {
	49	+ return ErrorCode.ERROR_SENDER_IS_NULL.getCode();
	50	+ }
	51	+ if (data.getRecvPhone() == null \|\| data.getRecvPhone().isEmpty()) {
	52	+ return ErrorCode.ERROR_RECEIVER_IS_NULL.getCode();
	53	+ }
	54	+
	55	+ return ErrorCode.OK.getCode();
	56	+ }
	57	+
	58	+ public static int validateMessageForSms(MunjaonMsg data) {
	59	+ if (data.getMessage() == null \|\| data.getMessage().isEmpty()) {
	60	+ return ErrorCode.ERROR_SMS_MSG_IS_NULL.getCode();
	61	+ }
	62	+ if (data.getMessage().getBytes().length > SmsMessage.DELIVER_MESSAGE_TRANS_LENGTH) {
	63	+ return ErrorCode.ERROR_SMS_MSG_IS_CAPACITY.getCode();
	64	+ }
	65	+
	66	+ return ErrorCode.OK.getCode();
	67	+ }
	68	+
	69	+ public static int validateMessageForMedia(MunjaonMsg data) {
	70	+ if (data == null) {
	71	+ return ErrorCode.ERROR_DATA_IS_NULL.getCode();
	72	+ }
	73	+ if (data.getSubject() == null) {
	74	+ return ErrorCode.ERROR_SUBJECT_IS_NULL.getCode();
	75	+ }
	76	+ if (data.getMessage() == null) {
	77	+ return ErrorCode.ERROR_MULTI_MESSAGE_IS_NULL.getCode();
	78	+ }
	79	+ if (data.getSubject().getBytes().length > LmsMessage.DELIVER_SUBJECT_LENGTH) {
	80	+ return ErrorCode.ERROR_SUBJECT_OVER_CAPACITY.getCode();
	81	+ }
	82	+ if (data.getMessage().getBytes().length > LmsMessage.DELIVER_MESSAGE_LENGTH) {
	83	+ return ErrorCode.ERROR_MULTI_MESSAGE_OVER_CAPACITY.getCode();
	84	+ }
	85	+
	86	+ return ErrorCode.OK.getCode();
	87	+ }
	88	+
	89	+ public static int validateMessageForImage(MunjaonMsg data, String path) {
	90	+ if (imageFileCount(data) == 0) {
	91	+ return ErrorCode.ERROR_MMS_IMAGE_IS_NULL.getCode();
	92	+ }
	93	+ if (imageExtErrorCount(data) > 0) {
	94	+ return ErrorCode.ERROR_MMS_IMAGE_IS_EXT.getCode();
	95	+ }
	96	+ if (imagePathErrorCount(data, path) > 0) {
	97	+ return ErrorCode.ERROR_MMS_IMAGE_IS_NOT_PATH.getCode();
	98	+ }
	99	+ if (imageSizeErrorCount(data, path) > 0) {
	100	+ return ErrorCode.ERROR_MMS_IMAGE_IS_OVER_CAPACITY.getCode();
	101	+ }
	102	+ return ErrorCode.OK.getCode();
	103	+ }
	104	+
	105	+ public static int imageSizeErrorCount(MunjaonMsg data, String path) {
	106	+ int errorCount = 0;
	107	+ if (data.getFilename01() != null) {
	108	+ File file = new File(path + data.getFilename01());
	109	+ if (file.length() > MmsMessage.LIMIT_FILE_CAPACITY) {
	110	+ errorCount++;
	111	+ }
	112	+ }
	113	+ if (data.getFilename02() != null) {
	114	+ File file = new File(path + data.getFilename02());
	115	+ if (file.length() > MmsMessage.LIMIT_FILE_CAPACITY) {
	116	+ errorCount++;
	117	+ }
	118	+ }
	119	+ if (data.getFilename03() != null) {
	120	+ File file = new File(path + data.getFilename03());
	121	+ if (file.length() > MmsMessage.LIMIT_FILE_CAPACITY) {
	122	+ errorCount++;
	123	+ }
	124	+ }
	125	+ return errorCount;
	126	+ }
	127	+
	128	+ public static int imagePathErrorCount(MunjaonMsg data, String path) {
	129	+ int errorCount = 0;
	130	+ if (data.getFilename01() != null) {
	131	+ File file = new File(path + data.getFilename01());
	132	+ if (file.exists() == false) {
	133	+ errorCount++;
	134	+ }
	135	+ }
	136	+ if (data.getFilename02() != null) {
	137	+ File file = new File(path + data.getFilename02());
	138	+ if (file.exists() == false) {
	139	+ errorCount++;
	140	+ }
	141	+ }
	142	+ if (data.getFilename03() != null) {
	143	+ File file = new File(path + data.getFilename03());
	144	+ if (file.exists() == false) {
	145	+ errorCount++;
	146	+ }
	147	+ }
	148	+ return errorCount;
	149	+ }
	150	+
	151	+ public static int imageExtErrorCount(MunjaonMsg data) {
	152	+ int errorCount = 0;
	153	+ if (data.getFilename01() != null && checkImageFileForExtension(data.getFilename01()) == false) {
	154	+ errorCount++;
	155	+ }
	156	+ if (data.getFilename02() != null && checkImageFileForExtension(data.getFilename02()) == false) {
	157	+ errorCount++;
	158	+ }
	159	+ if (data.getFilename03() != null && checkImageFileForExtension(data.getFilename03()) == false) {
	160	+ errorCount++;
	161	+ }
	162	+ return errorCount;
	163	+ }
	164	+
	165	+ public static int imageFileCount(MunjaonMsg data) {
	166	+ if (data == null) {
	167	+ return 0;
	168	+ }
	169	+ int count = 0;
	170	+ if (data.getFilename01() != null) {
	171	+ count++;
	172	+ }
	173	+ if (data.getFilename02() != null) {
	174	+ count++;
	175	+ }
	176	+ if (data.getFilename03() != null) {
	177	+ count++;
	178	+ }
	179	+
	180	+ return count;
	181	+ }
	182	+
	183	+ public static boolean checkImageFileForExtension(String fileName) {
	184	+ int lastIndex = fileName.lastIndexOf(".");
	185	+ if (lastIndex == -1) {
	186	+ return false;
	187	+ }
	188	+ String extension = fileName.substring(lastIndex + 1).toUpperCase();
	189	+ if ("JPG".equals(extension) \|\| "PNG".equals(extension) \|\| "GIF".equals(extension) \|\| "JPEG".equals(extension)) {
	190	+ return true;
	191	+ }
	192	+
	193	+ return false;
	194	+ }
	195	+
	196	+ public static int validateMessageForKakao(MunjaonMsg data) {
	197	+ if (data == null) {
	198	+ return ErrorCode.ERROR_DATA_IS_NULL.getCode();
	199	+ }
	200	+ if (data.getSubject() == null) {
	201	+ return ErrorCode.ERROR_SUBJECT_IS_NULL.getCode();
	202	+ }
	203	+ if (data.getMessage() == null) {
	204	+ return ErrorCode.ERROR_MULTI_MESSAGE_IS_NULL.getCode();
	205	+ }
	206	+ if (data.getKakaoSenderKey() == null) {
	207	+ return ErrorCode.ERROR_KAKAO_SENDER_KEY_IS_NULL.getCode();
	208	+ }
	209	+ if (data.getKakaoTemplateCode() == null) {
	210	+ return ErrorCode.ERROR_KAKAO_TEMPLATE_CODE_IS_NULL.getCode();
	211	+ }
	212	+ if (data.getKakaoJsonFile() == null) {
	213	+ return ErrorCode.ERROR_KAKAO_JSON_FILE_IS_NULL.getCode();
	214	+ }
	215	+ if (data.getSubject().getBytes().length > LmsMessage.DELIVER_SUBJECT_LENGTH) {
	216	+ return ErrorCode.ERROR_SUBJECT_OVER_CAPACITY.getCode();
	217	+ }
	218	+ if (data.getMessage().getBytes().length > LmsMessage.DELIVER_MESSAGE_LENGTH) {
	219	+ return ErrorCode.ERROR_MULTI_MESSAGE_OVER_CAPACITY.getCode();
	220	+ }
	221	+ if (data.getKakaoSenderKey().getBytes().length > KakaoMessage.DELIVER_KAKAO_SENDER_KEY_LENGTH) {
	222	+ return ErrorCode.ERROR_KAKAO_SENDER_KEY_OVER_CAPACITY.getCode();
	223	+ }
	224	+ if (data.getKakaoTemplateCode().getBytes().length > KakaoMessage.DELIVER_KAKAO_TEMPLATE_CODE_LENGTH) {
	225	+ return ErrorCode.ERROR_KAKAO_TEMPLATE_CODE_OVER_CAPACITY.getCode();
	226	+ }
	227	+
	228	+ return ErrorCode.OK.getCode();
	229	+ }
	230	+
	231	+ public static int validateJsonFile(String path, String fileName) {
	232	+ int lastIndex = fileName.lastIndexOf(".");
	233	+ if (lastIndex == -1) {
	234	+ return ErrorCode.ERROR_KAKAO_JSON_FILE_IS_EXT.getCode();
	235	+ }
	236	+ String extension = fileName.substring(lastIndex + 1).toUpperCase();
	237	+ if ("JSON".equals(extension) == false) {
	238	+ return ErrorCode.ERROR_KAKAO_JSON_FILE_IS_EXT.getCode();
	239	+ }
	240	+ File file = new File(path + fileName);
	241	+ if (file.exists() == false) {
	242	+ return ErrorCode.ERROR_KAKAO_JSON_FILE_IS_NOT_PATH.getCode();
	243	+ }
	244	+ if (file.length() > KakaoMessage.LIMIT_FILE_CAPACITY) {
	245	+ return ErrorCode.ERROR_KAKAO_JSON_FILE_IS_OVER_CAPACITY.getCode();
	246	+ }
	247	+
	248	+ return ErrorCode.OK.getCode();
	249	+ }
	250	+
	251	+ public static int validateMessageForJson(MunjaonMsg data) {
	252	+ return ErrorCode.OK.getCode();
	253	+ }
	254	+
	255	+ public static MunjaonMsg setReportMessage(String msgId, String agentCode, String sendStatus, String sendDate, String telecom) {
	256	+ MunjaonMsg msg = new MunjaonMsg();
	257	+ msg.setMsgId(msgId);
	258	+ msg.setAgentCode(agentCode);
	259	+ msg.setSendStatus(sendStatus);
	260	+ msg.setSendDate(sendDate);
	261	+ msg.setTelecom(telecom);
	262	+
	263	+ return msg;
	264	+ }
	265	+
	266	+
	267	+ public static void main(String[] args) {
	268	+ String fileName = " .dat";
	269	+ int lastIndex = fileName.lastIndexOf(".");
	270	+ if (lastIndex < 0) {
	271	+ System.out.println("EXT is not ");
	272	+ } else {
	273	+ System.out.println("EXT : " + fileName.substring(fileName.lastIndexOf(".") + 1, fileName.length()));
	274	+ }
	275	+ System.out.println("NM :" + fileName.substring(0, lastIndex) + "<<");
	276	+ }
	277	+}

e38c24b

50cccb9

src/main/resources/sqlmap/mariadb/mariadb_sql.xml

--- src/main/resources/sqlmap/mariadb/mariadb_sql.xml

+++ src/main/resources/sqlmap/mariadb/mariadb_sql.xml


             , FILENAME01
             , FILENAME02
             , FILENAME03
+            , KAKAO_SENDER_KEY
+            , KAKAO_TEMPLATE_CODE
+            , KAKAO_JSON_FILE
         FROM MUNJAON_MSG
         WHERE SEND_STATUS = '0'
             AND MSG_TYPE = #{msgType}

Add a comment

Open 0
Closed 0

List

...	...	@@ -1,5 +1,6 @@
1	1	package com.munjaon.client.config;
2	2
	3	+import com.zaxxer.hikari.HikariDataSource;
3	4	import lombok.Getter;
4	5	import lombok.RequiredArgsConstructor;
5	6	import lombok.extern.slf4j.Slf4j;
...	...	@@ -39,7 +40,7 @@
39	40	System.out.println("MARIADB.URL : " + serverConfig.getString(dbms + ".URL"));
40	41	System.out.println("MARIADB.USER : " + serverConfig.getString(dbms + ".USER"));
41	42	System.out.println("MARIADB.PASSWORD : " + serverConfig.getString(dbms + ".PASSWORD"));
42		- return DataSourceBuilder.create()
	43	+ return DataSourceBuilder.create().type(HikariDataSource.class)
43	44	.driverClassName(serverConfig.getString(dbms + ".DRIVER"))
44	45	.url(serverConfig.getString(dbms + ".URL"))
45	46	.username(serverConfig.getString(dbms + ".USER"))

...	...	@@ -19,7 +19,7 @@
19	19	try {
20	20	int msgCount = mariaDBMapper.checkTableForMessage();
21	21	int logCount = mariaDBMapper.checkTableForLog();
22		- if (msgCount == 1 && logCount == 1) {
	22	+ if (msgCount > 0 && logCount > 0) {
23	23	isExist = true;
24	24	}
25	25	} catch (Exception e) {

...	...	@@ -23,6 +23,9 @@
23	23	private String filename02;
24	24	private String filename03;
25	25	private String deliverDate;
	26	+ private String kakaoSenderKey;
	27	+ private String kakaoTemplateCode;
	28	+ private String kakaoJsonFile;
26	29	private String sendDate;
27	30	private String reportDate;
28	31	private int fileCount = 0;

...	...	@@ -5,9 +5,43 @@
5	5	@Getter
6	6	public enum ErrorCode {
7	7	OK(200, "Success"),
8		- ERROR_DATA_IS_NULL(300, "Msg is null"),
9		- ERROR_SUBJECT_IS_NULL(310, "Subject is null"),
10		- ERROR_MESSAGE_IS_NULL(320, "Message is null"),
	8	+ ERROR_DATA_IS_NULL(300, "DATA is null"),
	9	+ /* MSG_ID : 31X */
	10	+ ERROR_MSGID_IS_NULL(310, "MSG_ID is null"),
	11	+ ERROR_MSGID_IS_CAPACITY(311, "MSG_ID : SIZE is Zero Or Over"),
	12	+ /* SENDER : 32X */
	13	+ ERROR_SENDER_IS_NULL(320, "SENDER is null"),
	14	+ ERROR_SENDER_IS_CAPACITY(321, "SENDER : SIZE is Zero Or Over"),
	15	+ /* RECEIVER : 33X */
	16	+ ERROR_RECEIVER_IS_NULL(330, "RECEIVER is null"),
	17	+ ERROR_RECEIVER_IS_CAPACITY(331, "RECEIVER : SIZE is Zero Or Over"),
	18	+ ERROR_RECEIVER_IS_INVALID(332, "RECEIVER is invalid number"),
	19	+ /* SMS MESSAGE : 34X */
	20	+ ERROR_SMS_MSG_IS_NULL(340, "SMS MESSAGE is null"),
	21	+ ERROR_SMS_MSG_IS_CAPACITY(341, "SMS MESSAGE : SIZE is Zero Or Over"),
	22	+ /* LMS, MMS SUBJECT : 35X */
	23	+ ERROR_SUBJECT_IS_NULL(350, "Subject is null"),
	24	+ ERROR_SUBJECT_OVER_CAPACITY(351, "Subject is over capacity"),
	25	+ /* LMS, MMS MESSAGE : 36X */
	26	+ ERROR_MULTI_MESSAGE_IS_NULL(360, "Multimedia Message is null"),
	27	+ ERROR_MULTI_MESSAGE_OVER_CAPACITY(361, "Multimedia Message is over capacity"),
	28	+ /* MMS IMAGE : 37X */
	29	+ ERROR_MMS_IMAGE_IS_NULL(370, "MMS_IMAGE is not exist"),
	30	+ ERROR_MMS_IMAGE_IS_EXT(371, "MMS_IMAGE is not support extension"),
	31	+ ERROR_MMS_IMAGE_IS_NOT_PATH(372, "MMS_IMAGE is not exists"),
	32	+ ERROR_MMS_IMAGE_IS_OVER_CAPACITY(373, "MMS_IMAGE is over capacity"),
	33	+ /* KAKAO_SENDER_KEY : 38X */
	34	+ ERROR_KAKAO_SENDER_KEY_IS_NULL(380, "KAKAO_SENDER_KEY is null"),
	35	+ ERROR_KAKAO_SENDER_KEY_OVER_CAPACITY(381, "KAKAO_SENDER_KEY is over capacity"),
	36	+ /* KAKAO_TEMPLATE_CODE : 39X */
	37	+ ERROR_KAKAO_TEMPLATE_CODE_IS_NULL(390, "KAKAO_TEMPLATE_CODE is null"),
	38	+ ERROR_KAKAO_TEMPLATE_CODE_OVER_CAPACITY(391, "KAKAO_TEMPLATE_CODE is over capacity"),
	39	+ /* KAKAO_JSON_FILE : 40X */
	40	+ ERROR_KAKAO_JSON_FILE_IS_NULL(400, "KAKAO_JSON_FILE is not exist"),
	41	+ ERROR_KAKAO_JSON_FILE_IS_EXT(401, "KAKAO_JSON_FILE is not support extension"),
	42	+ ERROR_KAKAO_JSON_FILE_IS_NOT_PATH(402, "KAKAO_JSON_FILE is not exists"),
	43	+ ERROR_KAKAO_JSON_FILE_IS_OVER_CAPACITY(403, "KAKAO_JSON_FILE is over capacity"),
	44	+
11	45	ERROR_FILE_NOT_FOUND(390, "File Not Found"),
12	46	ERROR_FILE_CAPACITY_EXCEED(391, "File capacity exceeded");
13	47

...	...	@@ -6,7 +6,7 @@
6	6	import java.nio.ByteBuffer;
7	7
8	8	public final class LmsMessage {
9		- public static final int DELIVER_LMS_BODY_LENGTH = 2091;
	9	+ public static final int DELIVER_LMS_BODY_LENGTH = 2129;
10	10	public static final int DELIVER_LMS_ACK_BODY_LENGTH = 21;
11	11
12	12	/* DELIVER */

...	...	@@ -3,7 +3,10 @@
3	3	import com.munjaon.client.model.MunjaonMsg;
4	4	import com.munjaon.client.util.CommonUtil;
5	5
	6	+import java.io.File;
	7	+import java.io.IOException;
6	8	import java.nio.ByteBuffer;
	9	+import java.nio.file.Files;
7	10
8	11	public final class MmsMessage {
9	12	public static final int LIMIT_FILE_CAPACITY = 1024 * 300;
...	...	@@ -14,7 +17,7 @@
14	17	public static final int DELIVER_MMS_FILESIZE_LENGTH = 8;
15	18	public static final int DELIVER_MMS_FILESIZE_POSITION = DELIVER_MMS_FILENAME_POSITION + DELIVER_MMS_FILENAME_LENGTH;
16	19
17		- public static final int DELIVER_MMS_BODY_LENGTH = 2092;
	20	+ public static final int DELIVER_MMS_BODY_LENGTH = 2130;
18	21	public static final int DELIVER_MMS_ACK_BODY_LENGTH = 21;
19	22
20	23	/* DELIVER */
...	...	@@ -110,4 +113,26 @@
110	113	/* FileCount */
111	114	putFileCountForDeliver(buffer, data.getFileCount());
112	115	}
	116	+
	117	+ public static ByteBuffer makeImageForDeliver(String path, String fileName) {
	118	+ if (path == null \|\| fileName == null) {
	119	+ return null;
	120	+ }
	121	+ File file = new File(path + fileName);
	122	+ if (file.exists() == false) {
	123	+ return null;
	124	+ }
	125	+ ByteBuffer fileHeadBuffer = ByteBuffer.allocate(MmsMessage.DELIVER_MMS_FILENAME_LENGTH + MmsMessage.DELIVER_MMS_FILESIZE_LENGTH);
	126	+ fileHeadBuffer.put(DELIVER_MMS_FILENAME_POSITION, fileName.getBytes());
	127	+ fileHeadBuffer.put(DELIVER_MMS_FILESIZE_POSITION, String.valueOf(file.length()).getBytes());
	128	+ ByteBuffer fileBodyBuffer = ByteBuffer.allocate((int) file.length());
	129	+ ByteBuffer fileBuffer = null;
	130	+ try {
	131	+ fileBodyBuffer.put(Files.readAllBytes(file.toPath()));
	132	+ fileBuffer = ByteBuffer.allocate(fileHeadBuffer.capacity() + fileBodyBuffer.capacity());
	133	+ Packet.mergeBuffers(fileBuffer, fileHeadBuffer, fileBodyBuffer);
	134	+ } catch (IOException e) {}
	135	+
	136	+ return fileBuffer;
	137	+ }
113	138	}

...	...	@@ -12,6 +12,7 @@
12	12
13	13	/* DELIVER */
14	14	/* MESSAGE */
	15	+ public static final int DELIVER_MESSAGE_TRANS_LENGTH = 90;
15	16	public static final int DELIVER_MESSAGE_LENGTH = 160;
16	17	public static final int DELIVER_MESSAGE_POSITION = CommonMessage.DELIVER_MSG_TYPE_POSITION + CommonMessage.DELIVER_MSG_TYPE_LENGTH;
17	18

...	...	@@ -33,8 +33,11 @@
33	33	public void checkReady() {
34	34	worker = DatabaseTypeWorker.find(System.getProperty("DBMS"));
35	35	if (worker == null) {
	36	+ saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is not ready]");
36	37	return;
37	38	}
	39	+
	40	+ saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
38	41	this.IS_READY_YN = worker.checkTableExists();
39	42	}
40	43
...	...	@@ -44,12 +47,15 @@
44	47	this.port = Integer.parseInt(getProp("PORT"));
45	48	this.id = getProp("ID");
46	49	this.pwd = getProp("PASSWORD");
47		- saveSystemLog("Try Connect to " + this.address + ":" + this.port);
	50	+ saveSystemLog("Try Connect to [ADDRESS : " + this.address + "] [PORT : " + this.port + "] [ID : " + this.id + "]");
48	51	try {
49	52	socketChannel = SocketChannel.open(new InetSocketAddress(this.address, this.port));
50	53	socketChannel.configureBlocking(false);
51	54	} catch (IOException e) {
52		- saveSystemLog("Connect Fail " + this.address + ":" + this.port);
	55	+ saveSystemLog("Connect Fail to [ADDRESS : " + this.address + "] [PORT : " + this.port + "] [ID : " + this.id + "]");
	56	+ saveSystemLog("ERROR [" + e.getMessage() + "]");
	57	+ saveSystemLog("ERROR DETAIL");
	58	+ saveSystemLog(e.toString());
53	59	throw new RuntimeException(e);
54	60	}
55	61	}
...	...	@@ -60,6 +66,9 @@
60	66	try {
61	67	socketChannel.close();
62	68	} catch (IOException e) {
	69	+ saveSystemLog("ERROR [" + e.getMessage() + "]");
	70	+ saveSystemLog("ERROR DETAIL");
	71	+ saveSystemLog(e.toString());
63	72	throw new RuntimeException(e);
64	73	}
65	74	}

...	...	@@ -108,7 +108,7 @@
108	108	initLogFile();
109	109	/* 3. Runflag reload */
110	110	reloadCheckRun();
111		-
	111	+ saveSystemLog("[SERVICE_READY : " + IS_READY_YN + " \|\| SERVICE_RUN : " + IS_RUN_YN);
112	112	if (isRun() && isReady()) {
113	113	/* 3. 서비스 초기화 */
114	114	initResources();
...	...	@@ -116,9 +116,9 @@
116	116	doService();
117	117	/* 5. 서비스 자원 해제 */
118	118	releaseResources();
119		- saveSystemLog("Service Stopped.");
	119	+ saveSystemLog("[SERVICE IS STOPPED] [... ...]");
120	120	} else {
121		- saveSystemLog("Service is Not Running.");
	121	+ saveSystemLog("[SERVICE IS NOT RUNNING] [... ...]");
122	122	}
123	123	/* 6. 3초간 sleep */
124	124	Thread.sleep(3000);

...	...	@@ -33,6 +33,9 @@
33	33	, FILENAME01
34	34	, FILENAME02
35	35	, FILENAME03
	36	+ , KAKAO_SENDER_KEY
	37	+ , KAKAO_TEMPLATE_CODE
	38	+ , KAKAO_JSON_FILE
36	39	FROM MUNJAON_MSG
37	40	WHERE SEND_STATUS = '0'
38	41	AND MSG_TYPE = #{msgType}

Delete comment