정산완료 개선

src/main/java/com/oqpo/api/mapper/sttlmng/SttlReqMapper.java

@@ -57,6 +57,8 @@ public interface SttlReqMapper {
 
     int updateStlMgntBaseInfo4SttlConfirm(@Param("userId") String userId, StlMgntBaseInfoEntity entity) throws Exception;
 
+    int updateStlMgntBaseInfo4Rcpt(@Param("userId") String userId, StlMgntBaseInfoEntity entity) throws Exception;
+
     int updateStlMgntBaseInfo4SttlReject(@Param("userId") String userId, StlMgntBaseInfoEntity entity) throws Exception;
 
 }

src/main/java/com/oqpo/api/service/sttlmng/SttlStateService.java

@@ -1,8 +1,15 @@
 package com.oqpo.api.service.sttlmng;
 
 
+import com.oqpo.api.entity.loanmng.LoanMgntBaseInfoEntity;
+import com.oqpo.api.entity.loanmng.LoanMgntDtlHstEntity;
 import com.oqpo.api.entity.settmng.StlMgntBaseInfoEntity;
+import com.oqpo.api.enums.DpstPayDvsn;
+import com.oqpo.api.enums.MediaDvsn;
+import com.oqpo.api.enums.PayType;
 import com.oqpo.api.enums.SttlStCd;
+import com.oqpo.api.mapper.loanmng.DsptMngMapper;
+import com.oqpo.api.mapper.loanmng.UnpaidMngMapper;
 import com.oqpo.api.mapper.sttlmng.SttlReqMapper;
 import com.oqpo.api.mapper.sttlmng.SttlStateMapper;
 import com.oqpo.api.service.CommonService;
@@ -29,6 +36,12 @@ public class SttlStateService extends CommonService {
     @Autowired
     private SttlReqMapper sttlReqMapper;
 
+    @Autowired
+    private DsptMngMapper dsptMngMapper;
+
+    @Autowired
+    private UnpaidMngMapper unpaidMngMapper;
+
     /*
       정산요청 그리드 리스트 조회
      */
@@ -76,12 +89,54 @@ public class SttlStateService extends CommonService {
         StlMgntBaseInfoEntity entity = sttlReqMapper.selectStlMgntBaseInfo(sttlConfirmRequest.getSttlMgntUnqNo());
 
         // 정산관리기본정보 - 정산상태코드 변경
-        StlMgntBaseInfoEntity infoEntity = new StlMgntBaseInfoEntity();
-        infoEntity.setSttlMgntUnqNo(sttlConfirmRequest.getSttlMgntUnqNo());
-        infoEntity.setSttlStCd(SttlStCd.STTL_CONFIRM.getCd());
-        infoEntity.setSttlDt(DateUtil.getCurrentDate());
-        infoEntity.setSttlAmt(entity.getSttlReqAmt()); // 정산요청금액을 정산금액으로 지정한다.
-        sttlReqMapper.updateStlMgntBaseInfo4SttlConfirm(userId, infoEntity);
+        StlMgntBaseInfoEntity stlEntity = new StlMgntBaseInfoEntity();
+        stlEntity.setSttlMgntUnqNo(sttlConfirmRequest.getSttlMgntUnqNo());
+        stlEntity.setSttlStCd(SttlStCd.STTL_CONFIRM.getCd());
+        stlEntity.setSttlDt(DateUtil.getCurrentDate());
+        stlEntity.setSttlAmt(entity.getSttlReqAmt()); // 정산요청금액을 정산금액으로 지정한다.
+        sttlReqMapper.updateStlMgntBaseInfo4SttlConfirm(userId, stlEntity);
+
+        // 매장의 계좌잔액이 있은 경우 정산지급 처리를 한다.
+        // 매장 계좌잔액 조회
+        LoanMgntBaseInfoEntity loanEntity = dsptMngMapper.selectLoanMgntBaseInfo(entity.getBrandId(), entity.getStoreId());
+        if (loanEntity.getAcctBal() > 0) {
+            // 계좌잔액이 정산요청금액 이상인 경우 정산요청금액을 지급처리하고 정산 데이터는 수납처리한다.
+            // 계좌잔액이 정산요청금액 미만인 경우 계좌잔액을 지급처리하고 정산 데이터는 일부 수납처리한다. (미납금 발생)
+            String rcptYn; // 수납완료여부
+            long rcptAmt = 0; // 수납금액
+            if (loanEntity.getAcctBal() >= entity.getSttlReqAmt()) {
+                rcptAmt = entity.getSttlReqAmt();
+                rcptYn = "Y";
+            } else {
+                rcptAmt = loanEntity.getAcctBal();
+                rcptYn = "N";
+            }
+
+            // 1. 여신관리기본정보 처리
+            long trscBfBal = loanEntity.getAcctBal();
+            long trscAfBal = loanEntity.getAcctBal() - rcptAmt;
+            loanEntity.setAcctBal(trscAfBal); // 계좌잔액
+            loanEntity.setUseAmtTotal(loanEntity.getUseAmtTotal() - rcptAmt); // 사용금액합계 감소
+            sttlReqMapper.updateLoanMgntBaseInfo4SttlReqProc(userId, loanEntity);
+
+            // 2. 여신관리상세이력
+            LoanMgntDtlHstEntity hstEntity = new LoanMgntDtlHstEntity();
+            hstEntity.setLoanMgntUnqNo(loanEntity.getLoanMgntUnqNo());
+            hstEntity.setLoanRegDt(DateUtil.getCurrentDate());
+            hstEntity.setLoanRegTm(DateUtil.getCurrentTime());
+            hstEntity.setDpstPayDvsn(DpstPayDvsn.PAYMENT.getCd());
+            hstEntity.setMediaDvsn(MediaDvsn.SETTLMENT.getCd());
+            hstEntity.setPayType(PayType.STTL_PAY.getCd());
+            hstEntity.setTrscAmt(rcptAmt); // 거래금액
+            hstEntity.setTrscBfBal(trscAfBal);
+            hstEntity.setTrscAfBal(trscBfBal);
+            dsptMngMapper.insertLoanMgntDtlHst(userId, hstEntity);
+
+            // 3. 정산관리기본정보 수납처리
+            stlEntity.setRcptYn(rcptYn); // 수납여부
+            stlEntity.setRcptAmt(rcptAmt); // 수납금액
+            sttlReqMapper.updateStlMgntBaseInfo4Rcpt(userId, stlEntity);
+        }
     }
 
 }

src/main/java/com/oqpo/api/web/controller/sttlmng/SttlReqController.java

@@ -97,7 +97,7 @@ public class SttlReqController {
     })
     @ApiOperation(value = "정산 상세정보")
     @GetMapping("/info-sttl")
-    public ResponseEntity<SttlMngInfoResponse> infoUnpaid(@RequestParam(value = "sttlMgntUnqNo") String sttlMgntUnqNo) throws Exception {
+    public ResponseEntity<SttlMngInfoResponse> infoSttl(@RequestParam(value = "sttlMgntUnqNo") String sttlMgntUnqNo) throws Exception {
         return ResponseEntity.ok(sttlReqService.selectSttlReqInfo(sttlMgntUnqNo));
     }
 

src/main/resources/mybatis/sqlmaps/sttlmng/SttlReq.xml

@@ -162,7 +162,7 @@
             DATE_FORMAT(A.sys_reg_dttm,'%Y.%m.%d %H:%i:%s') AS sys_reg_dttm, A.sys_reg_id, FN_USER_NM(A.sys_reg_id) AS sys_reg_nm,
             DATE_FORMAT(A.sys_chg_dttm,'%Y.%m.%d %H:%i:%s') AS sys_chg_dttm, A.sys_chg_id,
             B.loan_dvsn, FN_CODE_NM('LOAN_DVSN', B.loan_dvsn) AS loan_dvsn_nm,      /* 매장 정상구분 */
-            C.acct_bal                                                              /* 매장 계좌잔액 */
+            IFNULL(C.acct_bal, 0) AS acct_bal                                       /* 매장 계좌잔액 */
         FROM stl_mgnt_base_info A
         INNER JOIN store_base_info B ON A.brand_id = B.brand_id AND A.store_id = B.store_id
         LEFT JOIN loan_mgnt_base_info C ON B.loan_mgnt_unq_no = C.loan_mgnt_unq_no
@@ -417,4 +417,17 @@
         WHERE sttl_mgnt_unq_no = #{entity.sttlMgntUnqNo}
     </update>
 
+    <update id="updateStlMgntBaseInfo4Rcpt" >
+        /* SttlReqMapper.updateStlMgntBaseInfo4Rcpt */
+        UPDATE stl_mgnt_base_info SET
+            rcpt_yn = #{entity.rcptYn},
+            <if test='"Y".equals(entity.rcptYn)'>
+            rcpt_dt = DATE_FORMAT(NOW(),'%Y%m%d'),
+            </if>
+            rcpt_amt = #{entity.rcptAmt},
+            sys_chg_dttm = NOW(),
+            sys_chg_id = #{userId}
+        WHERE sttl_mgnt_unq_no = #{entity.sttlMgntUnqNo}
+    </update>
+
 </mapper>