Push기능 추가

pom.xml

@@ -199,7 +199,21 @@
 			<version>3.8.0</version>
 		</dependency>
 
-  	</dependencies>
+		<dependency>
+			<groupId>com.google.firebase</groupId>
+			<artifactId>firebase-admin</artifactId>
+			<version>8.1.0</version>
+			<scope>runtime</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.json</groupId>
+			<artifactId>json</artifactId>
+			<version>20180813</version>
+		</dependency>
+
+
+
+	</dependencies>
 	<profiles>
 		<profile>
 			<id>local</id>

src/main/java/com/oqpo/api/constant/ApiConstants.java

@@ -20,4 +20,13 @@ public interface ApiConstants {
     String STR_OPTION_DELIMETER = "!";
     String STR_OPTION_END = "@";
     int STR_TICKET_START_LEN = STR_TICKET_START.length();
+
+    Boolean PUSH_CONTENT_AVAILABLE = true;
+    String PUSH_BAGE = "1";
+    String PUSH_PRIORITY = "high";
+    String PUSH_APNS_PUSH_TYPE = "alert";
+    String PUSH_APNS_PRIORITY = "10";
+    String PUSH_ACTION = ".view.MainActivity";
+    Integer PUSH_RETRY  = 3;
+    Integer URLCONN_TIME_OUT = 3000;
 }

src/main/java/com/oqpo/api/entity/PushData.java

@@ -0,0 +1,19 @@
+package com.oqpo.api.entity;
+
+import com.oqpo.api.entity.oper.MemberEntity;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+import java.io.Serializable;
+import java.util.List;
+
+@Getter
+@Setter
+@ToString
+public class PushData implements Serializable {
+    private static final long serialVersionUID = -3590936033715917450L;
+
+    private String bodyData;
+    private List<MemberEntity> targetList;
+}

src/main/java/com/oqpo/api/entity/PushEntity.java

@@ -0,0 +1,20 @@
+package com.oqpo.api.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+import java.io.Serializable;
+import java.util.List;
+
+@Getter
+@Setter
+@ToString
+public class PushEntity implements Serializable {
+    private static final long serialVersionUID = -3590936033715917450L;
+
+    private String jobType;
+    private String relUnqNo;
+    private String appReg;
+    private String userNm;
+}

src/main/java/com/oqpo/api/enums/PushMessage.java

@@ -0,0 +1,35 @@
+package com.oqpo.api.enums;
+
+import lombok.Getter;
+import lombok.Setter;
+
+public enum PushMessage {
+
+    PUSH_REQ("PO", "매장 발주 요청건이 들어왔습니다."), //
+    PUSH_RTN("RTN", "매장 반품 요청건이 들어왔습니다."), //
+    ;
+
+    PushMessage(String cd, String nm) {
+        this.cd = cd;
+        this.name = nm;
+    }
+
+    @Getter
+    @Setter
+    private String cd;
+
+    @Getter
+    @Setter
+    private String name;
+
+    public static String getName(String ccd) {
+        PushMessage[] values = PushMessage.values();
+        for (PushMessage icd : values) {
+            if (icd.cd.equals(ccd)) {
+                return icd.name;
+            }
+        }
+        return ccd;
+    }
+
+}

src/main/java/com/oqpo/api/mapper/oper/UserMngMapper.java

@@ -1,12 +1,14 @@
 package com.oqpo.api.mapper.oper;
 
 
+import com.oqpo.api.entity.oper.MemberEntity;
 import com.oqpo.api.entity.oper.UserAuthInfoEntity;
 import com.oqpo.api.entity.oper.UserMngEntity;
 import com.oqpo.api.web.dto.request.GridRequest;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.lang.reflect.Member;
 import java.util.List;
 
 @Mapper
@@ -67,4 +69,6 @@ public interface UserMngMapper {
     int deleteUserAuthWishList(@Param("brandId") String brandId) throws Exception;
 
     int selectWishListCnt(@Param("brandId") String brandId) throws Exception;
+
+    List<MemberEntity> selectPushTargetList(@Param("brandId") String brandId) ;
 }

src/main/java/com/oqpo/api/service/PushService.java

@@ -0,0 +1,166 @@
+package com.oqpo.api.service;
+
+import com.oqpo.api.constant.ApiConstants;
+import com.oqpo.api.entity.PushData;
+import com.oqpo.api.entity.oper.MemberEntity;
+import com.oqpo.api.enums.PushMessage;
+import com.oqpo.api.mapper.oper.UserMngMapper;
+import com.oqpo.api.web.interceptor.HeaderRequestInterceptor;
+import lombok.extern.slf4j.Slf4j;
+import org.codehaus.jackson.map.ObjectMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.json.JSONArray;
+import org.json.JSONException;
+import org.json.JSONObject;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.client.ClientHttpRequestInterceptor;
+import org.springframework.stereotype.Service;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+@Slf4j
+public class PushService  extends CommonService {
+
+    @Autowired
+    private UserMngMapper userMngMapper;
+
+
+    @Value("${push.firebase_server_key}")
+    private String firebase_server_key;
+
+    @Value("${push.firebase_api_url}")
+    private String firebase_api_url;
+
+    // jobType po 주문, rtn 반품  , reuUnqNo 관련번호
+    public PushData makePushData(String brandId, String jobType, String relUnqNo) throws JSONException, InterruptedException {
+
+        PushData  pushData = new PushData();
+
+        List<MemberEntity> targetList = userMngMapper.selectPushTargetList(brandId);
+
+        if (targetList.size() > 0) {
+
+            JSONObject bodySA = new JSONObject();
+            //List<JSONArray> arrayListSA = new ArrayList<JSONArray>();
+            JSONArray arraySA = new JSONArray();
+
+            for (int i = 0 ; i < targetList.size() ;i++) {
+                MemberEntity tempEntity = targetList.get(i);
+                arraySA.put(tempEntity.getAppReg());
+            }
+
+            bodySA.put("registration_ids", arraySA);
+            bodySA.put("content_available", ApiConstants.PUSH_CONTENT_AVAILABLE);
+            bodySA.put("priority", ApiConstants.PUSH_PRIORITY);
+            bodySA.put("apns-push-type", ApiConstants.PUSH_APNS_PUSH_TYPE);
+            bodySA.put("apns-priority", ApiConstants.PUSH_APNS_PRIORITY);
+
+            JSONObject dataSA = new JSONObject();
+
+            try {
+                if ("PO".equals(jobType)) {
+                    dataSA.put("title", "매장주문");
+                } else {
+                    dataSA.put("title", "매장반품");
+                }
+                if ("PO".equals(jobType)) {
+                    dataSA.put("body", PushMessage.PUSH_REQ.getName());
+                } else {
+                    dataSA.put("body", PushMessage.PUSH_RTN.getName());
+                }
+
+                dataSA.put("click_action", ApiConstants.PUSH_ACTION);
+                //dataSA.put("data", entity.getPushLandingCd());
+                //dataSA.put("relNo", entity.getLinkUrl());
+                bodySA.put("data", dataSA);
+            } catch (Exception e) {
+            }
+
+            pushData.setBodyData(bodySA.toString());
+            //pushData.setPushNo(entity.getPushNo());
+            //pushData.setPushSize(targetList.size());
+
+        }
+
+        return pushData;
+    }
+
+
+    public ArrayList<ClientHttpRequestInterceptor> pushSet(HttpEntity<String> entity) {
+
+        ArrayList<ClientHttpRequestInterceptor> interceptors = new ArrayList<>();
+
+        log.info("firebase_server_key ============>" + firebase_server_key);
+        interceptors.add(new HeaderRequestInterceptor("Authorization", "key=" + firebase_server_key));
+        interceptors.add(new HeaderRequestInterceptor("Content-Type", "application/json;charset=UTF-8"));
+
+        return interceptors;
+    }
+
+
+    public void pushSend(String brandId, String jobType, String relUnqNo) {
+        log.info("=========================push run");
+        try {
+            PushData  pushData = makePushData(brandId, jobType, relUnqNo);
+            String bodyData = pushData.getBodyData();
+            for (int i = 0; i < ApiConstants.PUSH_RETRY; i++) {
+                URL url = new URL(firebase_api_url);
+                HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+                conn.setDoOutput(true);
+                conn.setRequestMethod("POST");
+                conn.setRequestProperty("Content-Type", "application/json");
+                conn.setRequestProperty("Authorization", "key=" + firebase_server_key);
+                conn.setConnectTimeout(ApiConstants.URLCONN_TIME_OUT);
+                conn.setReadTimeout(ApiConstants.URLCONN_TIME_OUT);
+                conn.setDoOutput(true);
+
+                OutputStream os = conn.getOutputStream();
+                os.write(bodyData.getBytes("UTF-8"));
+                os.flush();
+                os.close();
+                int responseCode = conn.getResponseCode();
+                if (responseCode == HttpURLConnection.HTTP_OK) {
+                    BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
+                    String inputLine;
+                    StringBuffer response = new StringBuffer();
+
+                    while ((inputLine = in.readLine()) != null) {
+                        response.append(inputLine);
+                    }
+                    in.close();
+                    // 결과 처리
+                    Map<String,Object> responsMap = new ObjectMapper().readValue(response.toString(), HashMap.class);
+
+                    int retSuccess = (int) responsMap.get("success");
+                    log.info("========================connect retSuccess" + Integer.toString(retSuccess));
+                    int retError = (int) responsMap.get("failure");
+                    log.info("========================connect erroor" + Integer.toString(retError));
+                    break;
+                } else {
+                    Thread.sleep(1000);
+                    log.info("========================connect erroor" + Integer.toString(i));
+                }
+
+            }
+
+        } catch(Exception e) {
+            e.printStackTrace();
+        }
+
+
+    }
+
+
+
+
+}

src/main/java/com/oqpo/api/service/pomng/PchReqService.java

@@ -19,6 +19,7 @@ import com.oqpo.api.mapper.pomng.PchReqMapper;
 import com.oqpo.api.mapper.stinfo.BrandMapper;
 import com.oqpo.api.mapper.stockmng.WhsMngMapper;
 import com.oqpo.api.service.CommonService;
+import com.oqpo.api.service.PushService;
 import com.oqpo.api.util.DateUtil;
 import com.oqpo.api.web.dto.request.GridRequest;
 import com.oqpo.api.web.dto.request.pomng.pchReq.PchReqInitInfoRequest;
@@ -54,6 +55,9 @@ public class PchReqService extends CommonService {
     @Autowired
     private WhsMngMapper whsMngMapper;
 
+    @Autowired
+    private PushService pushService;
+
     /* 구매요청  초기 정보 */
     public PchReqInitInfoResponse selectPchReqInitInfo(String userId, PchReqInitInfoRequest pchReqInitInfoRequest) throws Exception {
         System.out.println("====================");
@@ -354,6 +358,12 @@ public class PchReqService extends CommonService {
                 }
             }
 
+            // push서비스 호출
+            log.info("====================================>" + savePchReqlRequest.getPchReqStCd());
+            if ("PR20".equals(savePchReqlRequest.getPchReqStCd())) {
+                log.info("=======================================pushSend");
+                pushService.pushSend(savePchReqlRequest.getBrandId(),"PO", savePchReqlRequest.getPchReqUnqNo() );
+            }
 
 
         } catch (GlobalException e) {

src/main/java/com/oqpo/api/service/rtnmng/RtnReqService.java

@@ -19,6 +19,7 @@ import com.oqpo.api.mapper.rtnmng.RtnReqMapper;
 import com.oqpo.api.mapper.stinfo.BrandMapper;
 import com.oqpo.api.mapper.stockmng.WhsMngMapper;
 import com.oqpo.api.service.CommonService;
+import com.oqpo.api.service.PushService;
 import com.oqpo.api.util.DateUtil;
 import com.oqpo.api.web.dto.request.GridRequest;
 import com.oqpo.api.web.dto.request.pomng.pchReq.PchReqInitInfoRequest;
@@ -51,6 +52,9 @@ public class RtnReqService extends CommonService {
     @Autowired
     private WhsMngMapper whsMngMapper;
 
+    @Autowired
+    private PushService pushService;
+
     /* 반품요청  초기 정보 */
 
     public RtnReqInitInfoResponse selectRtnReqInitInfo(String userId, PchReqInitInfoRequest pchReqInitInfoRequest) throws Exception {
@@ -200,6 +204,13 @@ public class RtnReqService extends CommonService {
                 rtnReqMapper.updateAllRtnReqDtlStCd(userId, entity.getRtnReqUnqNo(), "RRD00");
             }
 
+            // push서비스 호출
+            log.info("====================================>" + saveRtnReqlRequest.getRtnReqStCd());
+            if ("RR20".equals(saveRtnReqlRequest.getRtnReqStCd())) {
+                log.info("=======================================pushSend");
+                pushService.pushSend(saveRtnReqlRequest.getBrandId(),"RTN", entity.getRtnReqUnqNo());
+            }
+
         } catch (GlobalException e) {
             e.printStackTrace();
             throw new GlobalException(e.getSystemMessageCode());

src/main/resources-env/local/application.yml

@@ -90,3 +90,7 @@ kicc:
   cert_dir: C:/kicc/easypay/cert
   log_dir: C:/kicc/easypay/logs
   test_mall_tid: T0010761
+
+push:
+  firebase_server_key: AAAAIZ_eZOc:APA91bH38GR1FbgsRD-5tBLF__QehSHqd9kvGOr0lghneRyQFMdqme7uXv1-_U_3jXG4TgaVBc6sV6mSX3JT5my7-uhKrNPnkDBb_7Qms5dnymyWQp9t7z_qxmlzzYMG9VabiDHGGTWj
+  firebase_api_url: https://fcm.googleapis.com/fcm/send

src/main/resources/mybatis/sqlmaps/oper/UserMng.xml

@@ -393,4 +393,13 @@
         and   auth_no = 'SHOP_WISH'
     </insert>
 
+    <select id="selectPushTargetList" resultType="com.oqpo.api.entity.oper.MemberEntity">
+        select  user_nm, app_reg
+        from np_user_info
+        where brand_id = #{brandId}
+        and   auth_tp_cd = '40'
+        and   app_reg is not null
+        and   app_reg <![CDATA[ <> ]]> ''
+    </select>
+
 </mapper>