구발 간소화 발주 처리

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

@@ -73,6 +73,7 @@ public enum SystemMessageCode {
     ERR_BO_STORE (40039, "매장정보를 찿을 수 없습니다.", HttpStatus.BAD_REQUEST),
     ERR_PG_FAIL (40040, "PG 결제 처리중 에러가 발생하였습니다.", HttpStatus.BAD_REQUEST),
     ERR_PCH_JOB_FAIL (40041, "임시저장 상태가 아닙니다.", HttpStatus.BAD_REQUEST),
+    ERR_NON_BASE_WHS (40042, "창고관리에서 기본창고를 지정해주세요!", HttpStatus.BAD_REQUEST),
     ;
 
 

src/main/java/com/oqpo/api/mapper/inoutmng/ShmtOdrMapper.java

@@ -67,4 +67,8 @@ public interface ShmtOdrMapper {
     List<WhsProcInfoPtclEntity> selectWarehouseList(@Param("sBrandId") String sBrandId, @Param("sStoreId") String sStoreId, @Param("fromDt") String fromDt, @Param("toDt") String toDt, @Param("sPchPodrUnqNo") String sPchPodrUnqNo, @Param("sSpplyId") String sSpplyId, @Param("sWhsId") String sWhsId, @Param("sItemNm") String sItemNm, GridRequest gridRequest  )throws Exception;
     int selectWarehouseCnt(@Param("sBrandId") String sBrandId, @Param("sStoreId") String sStoreId,@Param("fromDt") String fromDt, @Param("toDt") String toDt, @Param("sPchPodrUnqNo") String sPchPodrUnqNo, @Param("sSpplyId") String sSpplyId, @Param("sWhsId") String sWhsId, @Param("sItemNm") String sItemNm  )throws Exception;
 
+
+    int insertStreamListShmtOdrBase(@Param("userId") String userId, List<ShmtOdrBaseEntity> gridInsertData)throws Exception;
+    int insertStreamListDeliInfoMngt(@Param("userId") String userId, List<DeliInfoMgntEntity> gridInsertData)throws Exception;
+
 }

src/main/java/com/oqpo/api/mapper/pomng/PchOrdMapper.java

@@ -44,7 +44,11 @@ public interface PchOrdMapper {
     PchOdrBaseInfoEntity selectSpplyPchOdrInfo(@Param("brandId") String brandId, @Param("pchPodrUnqNo") String pchPodrUnqNo, @Param("spplyId") String spplyId);
     List<PchOdrDtlPtclEntity> selectSpplyOdrDtlList(@Param("brandId") String brandId, @Param("pchPodrUnqNo") String pchPodrUnqNo, @Param("spplyId") String spplyId);
 
-    List<PchOdrBaseInfoEntity> selectPchPoStreamlineList(@Param("brandId") String brandId, List<PchReqBaseInfoEntity> gridUpdateData)throws Exception;
+    int selectPchPoStreamlineBrandDlvChk(@Param("brandId") String brandId, List<PchReqBaseInfoEntity> gridUpdateData)throws Exception;
 
+    List<PchOdrBaseInfoEntity> selectPchPoStreamlineList(@Param("brandId") String brandId, @Param("pchReqUnqNo") String pchReqUnqNo) throws Exception;
 
+
+    int insertStreamListPchOdrBaseInfo(@Param("userId") String userId, List<PchOdrBaseInfoEntity> gridInsertData)throws Exception;
+    int insertStreamListPchOdrDtlPtcl(@Param("userId") String userId, List<PchOdrDtlPtclEntity> gridInsertData)throws Exception;
 }

src/main/java/com/oqpo/api/mapper/pomng/PchReqMapper.java

@@ -84,4 +84,8 @@ public interface PchReqMapper {
 
     String selectPchReqStatProcYn(@Param("brandId") String brandId, @Param("pchReqUnqNo") String pchReqUnqNo )throws Exception;
 
+
+    int updateStreamListPchReqDtlStCd(@Param("userId") String userId, List<PchReqBaseInfoEntity> gridUpdateData) throws Exception;
+    int updateStreamListPchReqStCd(@Param("userId") String userId, List<PchReqBaseInfoEntity> gridUpdateData) throws Exception;
+
 }

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

@@ -1,6 +1,10 @@
 package com.oqpo.api.service.pomng;
 
 
+import com.oqpo.api.entity.inoutmng.DeliDtlMgntEntity;
+import com.oqpo.api.entity.inoutmng.DeliInfoMgntEntity;
+import com.oqpo.api.entity.inoutmng.ShmtOdrBaseEntity;
+import com.oqpo.api.entity.inoutmng.ShmtOdrDtlEntity;
 import com.oqpo.api.entity.loanmng.LoanMgntBaseInfoEntity;
 import com.oqpo.api.entity.oper.UserMngEntity;
 import com.oqpo.api.entity.pomng.PchOdrBaseInfoEntity;
@@ -9,14 +13,20 @@ import com.oqpo.api.entity.pomng.PchReqBaseInfoEntity;
 import com.oqpo.api.entity.pomng.PchReqDtlPtclEntity;
 import com.oqpo.api.entity.rtnmng.RtnReqBaseInfoEntity;
 import com.oqpo.api.entity.stockmng.StckMgntBaseInfoEntity;
+import com.oqpo.api.entity.stockmng.StckMgntDtlHistEntity;
+import com.oqpo.api.entity.stockmng.WhsMgntBaseInfoEntity;
+import com.oqpo.api.enums.ChgDvsn;
+import com.oqpo.api.enums.InOutCd;
 import com.oqpo.api.enums.SystemMessageCode;
 import com.oqpo.api.exception.GlobalException;
+import com.oqpo.api.mapper.inoutmng.ShmtOdrMapper;
 import com.oqpo.api.mapper.loanmng.LoanStateMapper;
 import com.oqpo.api.mapper.oper.UserMngMapper;
 import com.oqpo.api.mapper.pomng.PchOrdMapper;
 import com.oqpo.api.mapper.pomng.PchReqMapper;
 import com.oqpo.api.mapper.stinfo.StoreBaseInfoMapper;
 import com.oqpo.api.mapper.stockmng.StockMngMapper;
+import com.oqpo.api.mapper.stockmng.WhsMngMapper;
 import com.oqpo.api.service.CommonService;
 import com.oqpo.api.web.dto.request.GridRequest;
 import com.oqpo.api.web.dto.request.pomng.pchOrd.*;
@@ -29,6 +39,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.lang.reflect.Array;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -57,6 +68,12 @@ public class PchOrdService extends CommonService {
     @Autowired
     private PchReqService pchReqService;
 
+    @Autowired
+    private WhsMngMapper whsMngMapper;
+
+    @Autowired
+    private ShmtOdrMapper shmtOdrMapper;
+
 
 
     /* 구매요청건 발주 가능 여부 체크 */
@@ -248,7 +265,7 @@ public class PchOrdService extends CommonService {
             pchOrdEntity.setDlvReqDt(savePchOrdRequest.getDlvReqDt().replaceAll("\\.",""));
             pchOrdEntity.setPodrMgrNm(uEntity.getUserNm());
             pchOrdEntity.setPodrDvsn("OD01");
-            pchOrdEntity.setPchOdrStCd("PO001");
+            pchOrdEntity.setPchOdrStCd("PO20");
             pchOrdEntity.setSpplyId(savePchOrdRequest.getSpplyId());
             pchOrdEntity.setPodrMgrId(uEntity.getUserId());
             pchOrdEntity.setPodrMgrTelNo(uEntity.getTelNo());
@@ -629,16 +646,424 @@ public class PchOrdService extends CommonService {
                 throw new GlobalException(SystemMessageCode.ERR_NOTITEM);
             }
 
+            // 기본창고 여부 확인 (본사배송 건 존재시 기본창고 여부 확인 하여 없을 경우 오류 처리 있으면 그냥 진행
+            int brandDlvCnt = pchOrdMapper.selectPchPoStreamlineBrandDlvChk(savePchSteamlineOrdRequest.getBrandId(), gridInsertData);
+            WhsMgntBaseInfoEntity whsEntity = null ;
+
+            if (brandDlvCnt > 0 ) {
+                // 기본창고 및 로케이션 있는지 여부 확인
+                int baseWhsCnt = whsMngMapper.selectBaseWhsLocationCnt(savePchSteamlineOrdRequest.getBrandId()) ;
+
+                if (baseWhsCnt > 0 ) {
+                    whsEntity = whsMngMapper.selectBaseWhsLocationInfo(savePchSteamlineOrdRequest.getBrandId()) ;
+                } else {
+                    //오류 처리 (창고관리에서 기본창고를 지정해주세요!)
+                    throw new GlobalException(SystemMessageCode.ERR_NON_BASE_WHS);
+                }
+            }
+
+            //처리 내역 저장 구분
+            PchOdrBaseInfoEntity tempTargetBase =  null ; //new PchOdrBaseInfoEntity();
+            List<PchOdrBaseInfoEntity> tempTargetBaseList = new ArrayList<PchOdrBaseInfoEntity>();
+            PchOdrDtlPtclEntity tempTargetPtcl = null ; //new PchOdrDtlPtclEntity();
+            List<PchOdrDtlPtclEntity> tempTargetPtclList = new ArrayList<PchOdrDtlPtclEntity>();
+
+            ShmtOdrBaseEntity shmtBaseEntity = null ; //new ShmtOdrBaseEntity();
+            List<ShmtOdrBaseEntity> shmtBaseList = new ArrayList<ShmtOdrBaseEntity>();
+            ShmtOdrDtlEntity shmtOdrDtlEntity = null ; //new shmtOdrDtlEntity();
+            List<ShmtOdrDtlEntity> shmtDtlList = new ArrayList<ShmtOdrDtlEntity>();
+
+            DeliInfoMgntEntity deliBaseEntity = null; //new DeliInfoMgntEntity();
+            List<DeliInfoMgntEntity> deliBaseList = new ArrayList<DeliInfoMgntEntity>();
+            DeliDtlMgntEntity deliDtlEntity = null ; //new DeliDtlMgntEntity();
+            List<DeliDtlMgntEntity> deliDtlList = new ArrayList<DeliDtlMgntEntity>();
+
+            StckMgntBaseInfoEntity stckEntity = null;
+            List<StckMgntBaseInfoEntity> stockList = new ArrayList<StckMgntBaseInfoEntity>();
+
             for (int i = 0 ; i < gridInsertData.size() ; i++) {
+                PchReqBaseInfoEntity pchReqEntity = gridInsertData.get(i);
                 // 구매요청번호로 구매요청 내역 가져오기
-               // PchOdrBaseInfoEntity pchOrdEntity =
+                List<PchOdrBaseInfoEntity> pchOrdList = pchOrdMapper.selectPchPoStreamlineList(savePchSteamlineOrdRequest.getBrandId(),pchReqEntity.getPchReqUnqNo());
+
+                // 구매발주번호, 출하번호, 납품서번호
+                String preDlvDvsn = "";
+                String preSpplyId = "";
+                String pchPodrUnqNo = "";
+                String shmtReqUnqNo = ""; // 출하지시번호
+                String dlvSttmtUnqNo = ""; // 납품서번호
+                int dtlRow = 0 ;
+                long poTotAmt = 0 ;
+                int poItemCnt = 0 ;
+
+                for (int j = 0 ; j < pchOrdList.size() ; j++) {
+                    // 구매요청건에 대한 개별 처리 방안
+                    PchOdrBaseInfoEntity  podrEntity = pchOrdList.get(j);
+
+                    if (preDlvDvsn.equals(podrEntity.getDlvDvsn())) {
+                        if ("DL01".equals(podrEntity.getDlvDvsn())) {
+                            //본사배송 기존거와 동일
+                            tempTargetPtcl = new PchOdrDtlPtclEntity();
+                            tempTargetPtcl.setPchPodrUnqNo(pchPodrUnqNo);
+                            dtlRow = dtlRow + 10;
+                            tempTargetPtcl.setPchPodrDtlNo(Integer.toString(dtlRow));
+                            tempTargetPtcl.setPchReqUnqNo(podrEntity.getPchOdrDtlInfo().getPchReqUnqNo());
+                            tempTargetPtcl.setPchReqDtlNo(podrEntity.getPchOdrDtlInfo().getPchReqDtlNo());
+                            tempTargetPtcl.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                            tempTargetPtcl.setItemNm(podrEntity.getPchOdrDtlInfo().getItemNm());
+                            tempTargetPtcl.setPodrQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            tempTargetPtcl.setPodrAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                            tempTargetPtcl.setCurr(podrEntity.getPchOdrDtlInfo().getCurr());
+                            tempTargetPtcl.setUnit(podrEntity.getPchOdrDtlInfo().getUnit());
+                            tempTargetPtcl.setUnitAmt(podrEntity.getPchOdrDtlInfo().getUnitAmt());
+                            tempTargetPtcl.setDlvSchDt(podrEntity.getPchOdrDtlInfo().getDlvSchDt());
+                            tempTargetPtcl.setStoreUnitUnqNo(podrEntity.getPchOdrDtlInfo().getStoreUnitUnqNo());
+                            tempTargetPtcl.setBrandUnitUnqNo(podrEntity.getPchOdrDtlInfo().getBrandUnitUnqNo());
+                            tempTargetPtclList.add(tempTargetPtcl);
+
+                            poTotAmt = poTotAmt + podrEntity.getPchOdrDtlInfo().getPodrAmt();
+                            poItemCnt = poItemCnt + 1;
+
+                            shmtOdrDtlEntity.setShmtReqUnqNo(shmtReqUnqNo);
+                            shmtOdrDtlEntity.setShmtReqDtlNo(Integer.toString(dtlRow));
+                            shmtOdrDtlEntity.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                            shmtOdrDtlEntity.setItemNm(podrEntity.getPchOdrDtlInfo().getItemNm());
+                            shmtOdrDtlEntity.setUnitAmt(podrEntity.getPchOdrDtlInfo().getUnitAmt());
+                            shmtOdrDtlEntity.setUnit(podrEntity.getPchOdrDtlInfo().getUnit());
+                            shmtOdrDtlEntity.setPodrQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            shmtOdrDtlEntity.setPodrAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                            shmtOdrDtlEntity.setShmtQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            shmtOdrDtlEntity.setShmtAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                            shmtOdrDtlEntity.setExpryDate("");
+                            shmtOdrDtlEntity.setPchPodrUnqNo(pchPodrUnqNo);
+                            shmtOdrDtlEntity.setPchPodrDtlNo(Integer.toString(dtlRow));
+                            shmtOdrDtlEntity.setPchReqUnqNo(podrEntity.getPchOdrDtlInfo().getPchReqUnqNo());
+                            shmtOdrDtlEntity.setPchReqDtlNo(podrEntity.getPchOdrDtlInfo().getPchReqDtlNo());
+                            shmtDtlList.add(shmtOdrDtlEntity);
+
+                            stckEntity = new StckMgntBaseInfoEntity();
+                            stckEntity.setBrandId(savePchSteamlineOrdRequest.getBrandId());
+                            stckEntity.setWhsId(whsEntity.getWhsId());
+                            stckEntity.setLocation(whsEntity.getLocationInfo().getLocation());
+                            stckEntity.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                            stckEntity.setStckQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            stckEntity.setWaitQty(0);
+                            stckEntity.setRelationNo(shmtReqUnqNo);
+                            stockList.add(stckEntity);
+
+                            deliDtlEntity.setDlvSttmtUnqNo(dlvSttmtUnqNo);
+                            deliDtlEntity.setDlvSttmtDtlNo(Integer.toString(dtlRow));
+                            deliDtlEntity.setPchPodrUnqNo(pchPodrUnqNo);
+                            deliDtlEntity.setPchPodrDtlNo(Integer.toString(dtlRow));
+                            deliDtlEntity.setPchReqUnqNo(podrEntity.getPchOdrDtlInfo().getPchReqUnqNo());
+                            deliDtlEntity.setPchReqDtlNo(podrEntity.getPchOdrDtlInfo().getPchReqDtlNo());
+                            deliDtlEntity.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                            deliDtlEntity.setItemNm(podrEntity.getPchOdrDtlInfo().getItemNm());
+                            deliDtlEntity.setUnit(podrEntity.getPchOdrDtlInfo().getUnit());
+                            deliDtlEntity.setUnitAmt(podrEntity.getPchOdrDtlInfo().getUnitAmt());
+                            deliDtlEntity.setPodrQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            deliDtlEntity.setDlvQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            deliDtlEntity.setPodrAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                            deliDtlEntity.setDlvAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                            deliDtlEntity.setShmtReqUnqNo(shmtReqUnqNo);
+                            deliDtlEntity.setShmtReqDtlNo(Integer.toString(dtlRow));
+                            deliDtlEntity.setExpryDate(null);
+                            deliDtlList.add(deliDtlEntity);
+
+                        } else {
+                            if (preSpplyId.equals(podrEntity.getSpplyId())) {
+                                //기존거와 동일
+                                tempTargetPtcl = new PchOdrDtlPtclEntity();
+                                tempTargetPtcl.setPchPodrUnqNo(pchPodrUnqNo);
+                                dtlRow = dtlRow + 10;
+                                tempTargetPtcl.setPchPodrDtlNo(Integer.toString(dtlRow));
+                                tempTargetPtcl.setPchReqUnqNo(podrEntity.getPchOdrDtlInfo().getPchReqUnqNo());
+                                tempTargetPtcl.setPchReqDtlNo(podrEntity.getPchOdrDtlInfo().getPchReqDtlNo());
+                                tempTargetPtcl.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                                tempTargetPtcl.setItemNm(podrEntity.getPchOdrDtlInfo().getItemNm());
+                                tempTargetPtcl.setPodrQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                                tempTargetPtcl.setPodrAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                                tempTargetPtcl.setCurr(podrEntity.getPchOdrDtlInfo().getCurr());
+                                tempTargetPtcl.setUnit(podrEntity.getPchOdrDtlInfo().getUnit());
+                                tempTargetPtcl.setUnitAmt(podrEntity.getPchOdrDtlInfo().getUnitAmt());
+                                tempTargetPtcl.setDlvSchDt(podrEntity.getPchOdrDtlInfo().getDlvSchDt());
+                                tempTargetPtcl.setStoreUnitUnqNo(podrEntity.getPchOdrDtlInfo().getStoreUnitUnqNo());
+                                tempTargetPtcl.setBrandUnitUnqNo(podrEntity.getPchOdrDtlInfo().getBrandUnitUnqNo());
+                                tempTargetPtclList.add(tempTargetPtcl);
+
+                                poTotAmt = poTotAmt + podrEntity.getPchOdrDtlInfo().getPodrAmt();
+                                poItemCnt = poItemCnt + 1;
+                            } else {
+                                //기존거와 상이
+                                if (!"".toString().equals(preDlvDvsn)) {
+                                    tempTargetBase.setPodrTotalAmt(poTotAmt);
+                                    tempTargetBase.setPodrItemQty(poItemCnt);
+                                    tempTargetBaseList.add(tempTargetBase);
+
+                                    if ("DL01".equals(preDlvDvsn)) {
+                                        shmtBaseEntity.setShmtTotalAmt(poTotAmt);
+                                        shmtBaseEntity.setItemQty(poItemCnt);
+                                        shmtBaseList.add(shmtBaseEntity);
+                                        deliBaseList.add(deliBaseEntity);
+                                    }
+                                }
+
+                                poTotAmt = 0 ;
+                                poItemCnt = 0 ;
+                                tempTargetBase = new PchOdrBaseInfoEntity();
+                                tempTargetPtcl = new PchOdrDtlPtclEntity();
+
+                                pchPodrUnqNo = fnGetDealNo(14,"");
+                                tempTargetBase.setPchPodrUnqNo(pchPodrUnqNo);
+                                preDlvDvsn = podrEntity.getDlvDvsn();
+                                tempTargetBase.setBrandId(savePchSteamlineOrdRequest.getBrandId());
+                                tempTargetBase.setStoreId(podrEntity.getStoreId());
+                                tempTargetBase.setSpplyId(podrEntity.getSpplyId());
+                                tempTargetBase.setDlvDvsn(podrEntity.getDlvDvsn());
+                                tempTargetBase.setDlvReqDt(podrEntity.getDlvReqDt());
+                                tempTargetBase.setPodrMgrNm(uEntity.getUserNm());
+                                tempTargetBase.setPodrDvsn(podrEntity.getPodrDvsn());
+                                tempTargetBase.setPodrMgrId(uEntity.getUserId());
+                                tempTargetBase.setPodrMgrTelNo(uEntity.getTelNo());
+                                tempTargetBase.setWhsDvsn(podrEntity.getWhsDvsn());
+                                tempTargetBase.setWhsId(podrEntity.getWhsId());
+                                tempTargetBase.setLocation(podrEntity.getLocation());
+
+                                tempTargetPtcl.setPchPodrUnqNo(pchPodrUnqNo);
+                                dtlRow = 10;
+                                // String dtlNo = Integer.toString(dtlRow);
+                                tempTargetPtcl.setPchPodrDtlNo(Integer.toString(dtlRow));
+                                tempTargetPtcl.setPchReqUnqNo(podrEntity.getPchOdrDtlInfo().getPchReqUnqNo());
+                                tempTargetPtcl.setPchReqDtlNo(podrEntity.getPchOdrDtlInfo().getPchReqDtlNo());
+                                tempTargetPtcl.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                                tempTargetPtcl.setItemNm(podrEntity.getPchOdrDtlInfo().getItemNm());
+                                tempTargetPtcl.setPodrQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                                tempTargetPtcl.setPodrAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                                tempTargetPtcl.setCurr(podrEntity.getPchOdrDtlInfo().getCurr());
+                                tempTargetPtcl.setUnit(podrEntity.getPchOdrDtlInfo().getUnit());
+                                tempTargetPtcl.setUnitAmt(podrEntity.getPchOdrDtlInfo().getUnitAmt());
+                                tempTargetPtcl.setDlvSchDt(podrEntity.getPchOdrDtlInfo().getDlvSchDt());
+                                tempTargetPtcl.setStoreUnitUnqNo(podrEntity.getPchOdrDtlInfo().getStoreUnitUnqNo());
+                                tempTargetPtcl.setBrandUnitUnqNo(podrEntity.getPchOdrDtlInfo().getBrandUnitUnqNo());
+                                tempTargetPtclList.add(tempTargetPtcl);
+
+                                poTotAmt = poTotAmt + podrEntity.getPchOdrDtlInfo().getPodrAmt();
+                                poItemCnt = poItemCnt + 1;
+                            }
+                        }
+                    } else {
+                        // 서로 상이할경우
+                        if (!"".toString().equals(preDlvDvsn)) {
+                            tempTargetBase.setPodrTotalAmt(poTotAmt);
+                            tempTargetBase.setPodrItemQty(poItemCnt);
+                            tempTargetBaseList.add(tempTargetBase);
+
+                            if ("DL01".equals(preDlvDvsn)) {
+                                shmtBaseEntity.setShmtTotalAmt(poTotAmt);
+                                shmtBaseEntity.setItemQty(poItemCnt);
+                                shmtBaseList.add(shmtBaseEntity);
+                                deliBaseList.add(deliBaseEntity);
+                            }
+                        }
+
+                        poTotAmt = 0 ;
+                        poItemCnt = 0 ;
+                        tempTargetBase = new PchOdrBaseInfoEntity();
+                        tempTargetPtcl = new PchOdrDtlPtclEntity();
+
+
+                        // 이미등록건 업데이트 처리
+                        pchPodrUnqNo = fnGetDealNo(14,"");
+                        tempTargetBase.setPchPodrUnqNo(pchPodrUnqNo);
+                        preDlvDvsn = podrEntity.getDlvDvsn();
+                        tempTargetBase.setBrandId(savePchSteamlineOrdRequest.getBrandId());
+                        tempTargetBase.setStoreId(podrEntity.getStoreId());
+                        tempTargetBase.setSpplyId(podrEntity.getSpplyId());
+                        tempTargetBase.setDlvDvsn(podrEntity.getDlvDvsn());
+                        tempTargetBase.setDlvReqDt(podrEntity.getDlvReqDt());
+                        tempTargetBase.setPodrMgrNm(uEntity.getUserNm());
+                        tempTargetBase.setPodrDvsn(podrEntity.getPodrDvsn());
+                        tempTargetBase.setPodrMgrId(uEntity.getUserId());
+                        tempTargetBase.setPodrMgrTelNo(uEntity.getTelNo());
+                        tempTargetBase.setWhsDvsn(podrEntity.getWhsDvsn());
+                        tempTargetBase.setWhsId(podrEntity.getWhsId());
+                        tempTargetBase.setLocation(podrEntity.getLocation());
+
+                        tempTargetPtcl.setPchPodrUnqNo(pchPodrUnqNo);
+                        dtlRow = 10;
+                       // String dtlNo = Integer.toString(dtlRow);
+                        tempTargetPtcl.setPchPodrDtlNo(Integer.toString(dtlRow));
+                        tempTargetPtcl.setPchReqUnqNo(podrEntity.getPchOdrDtlInfo().getPchReqUnqNo());
+                        tempTargetPtcl.setPchReqDtlNo(podrEntity.getPchOdrDtlInfo().getPchReqDtlNo());
+                        tempTargetPtcl.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                        tempTargetPtcl.setItemNm(podrEntity.getPchOdrDtlInfo().getItemNm());
+                        tempTargetPtcl.setPodrQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                        tempTargetPtcl.setPodrAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                        tempTargetPtcl.setCurr(podrEntity.getPchOdrDtlInfo().getCurr());
+                        tempTargetPtcl.setUnit(podrEntity.getPchOdrDtlInfo().getUnit());
+                        tempTargetPtcl.setUnitAmt(podrEntity.getPchOdrDtlInfo().getUnitAmt());
+                        tempTargetPtcl.setDlvSchDt(podrEntity.getPchOdrDtlInfo().getDlvSchDt());
+                        tempTargetPtcl.setStoreUnitUnqNo(podrEntity.getPchOdrDtlInfo().getStoreUnitUnqNo());
+                        tempTargetPtcl.setBrandUnitUnqNo(podrEntity.getPchOdrDtlInfo().getBrandUnitUnqNo());
+                        tempTargetPtclList.add(tempTargetPtcl);
+
+                        poTotAmt = poTotAmt + podrEntity.getPchOdrDtlInfo().getPodrAmt();
+                        poItemCnt = poItemCnt + 1;
+
+                        //본사배송일경우 출하지시 , 납품서 생성 처리함
+                        if ("DL01".equals(podrEntity.getDlvDvsn())) {
+
+                            tempTargetBase.setPchOdrStCd("PO30");
+                            tempTargetPtcl.setPodrDtlStCd("POD3");
+
+                            shmtBaseEntity = new ShmtOdrBaseEntity();
+                            shmtOdrDtlEntity = new ShmtOdrDtlEntity();
+                            deliBaseEntity = new DeliInfoMgntEntity();
+                            deliDtlEntity = new DeliDtlMgntEntity();
+
+                            // 출하지시 처리
+                            shmtReqUnqNo = fnGetDealNo(16, "");  // 출하지시번호
+                            shmtBaseEntity.setShmtReqUnqNo(shmtReqUnqNo);
+                            shmtBaseEntity.setShmtReqStCd("SHM1");
+                            shmtBaseEntity.setShmtWhsId(whsEntity.getWhsId());
+                            shmtBaseEntity.setShmtLocation(whsEntity.getLocationInfo().getLocation());
+                            shmtBaseEntity.setWhsDvsn("W01");
+                            shmtBaseEntity.setBrandId(savePchSteamlineOrdRequest.getBrandId());
+                            shmtBaseEntity.setStoreId(podrEntity.getStoreId());
+                            shmtBaseEntity.setPodrDvsn("OD01");
+                            shmtBaseEntity.setPodrMgrNm(uEntity.getUserNm());
+                            shmtBaseEntity.setDlvReqDt(podrEntity.getDlvReqDt());
+                            shmtBaseEntity.setWhsId(podrEntity.getWhsId());
+                            shmtBaseEntity.setLocation(podrEntity.getLocation());
+
+                            shmtOdrDtlEntity.setShmtReqUnqNo(shmtReqUnqNo);
+                            shmtOdrDtlEntity.setShmtReqDtlNo(Integer.toString(dtlRow));
+                            shmtOdrDtlEntity.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                            shmtOdrDtlEntity.setItemNm(podrEntity.getPchOdrDtlInfo().getItemNm());
+                            shmtOdrDtlEntity.setUnitAmt(podrEntity.getPchOdrDtlInfo().getUnitAmt());
+                            shmtOdrDtlEntity.setUnit(podrEntity.getPchOdrDtlInfo().getUnit());
+                            shmtOdrDtlEntity.setPodrQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            shmtOdrDtlEntity.setPodrAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                            shmtOdrDtlEntity.setShmtQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            shmtOdrDtlEntity.setShmtAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                            shmtOdrDtlEntity.setExpryDate("");
+                            shmtOdrDtlEntity.setPchPodrUnqNo(pchPodrUnqNo);
+                            shmtOdrDtlEntity.setPchPodrDtlNo(Integer.toString(dtlRow));
+                            shmtOdrDtlEntity.setPchReqUnqNo(podrEntity.getPchOdrDtlInfo().getPchReqUnqNo());
+                            shmtOdrDtlEntity.setPchReqDtlNo(podrEntity.getPchOdrDtlInfo().getPchReqDtlNo());
+                            shmtDtlList.add(shmtOdrDtlEntity);
+
+                            stckEntity = new StckMgntBaseInfoEntity();
+                            stckEntity.setBrandId(savePchSteamlineOrdRequest.getBrandId());
+                            stckEntity.setWhsId(whsEntity.getWhsId());
+                            stckEntity.setLocation(whsEntity.getLocationInfo().getLocation());
+                            stckEntity.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                            stckEntity.setStckQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            stckEntity.setWaitQty(0);
+                            stckEntity.setRelationNo(shmtReqUnqNo);
+                            stockList.add(stckEntity);
+
+                            // 납품서 처리
+                            dlvSttmtUnqNo = fnGetDealNo(15, ""); // 납품서번호
+                            deliBaseEntity.setDlvSttmtUnqNo(dlvSttmtUnqNo);
+                            deliBaseEntity.setSpplyId(null);
+                            deliBaseEntity.setSpplyNm(null);
+                            deliBaseEntity.setStoreId(podrEntity.getStoreId());
+                            deliBaseEntity.setDlvMgrNm(uEntity.getUserNm());
+                            deliBaseEntity.setDlvMgrTelNo(uEntity.getTelNo());
+                            deliBaseEntity.setDlvMgrEmal(null);
+                            deliBaseEntity.setDlvMgrMblNo(uEntity.getTelNo());
+                            //deliBaseEntity.setVndrTelNo(entity.getDeliTelNo().replaceAll("-", ""));
+                            deliBaseEntity.setDlvStCd("DLV0");
+                            deliBaseEntity.setPodrRegDt(podrEntity.getPodrDt());
+                            deliBaseEntity.setDlvReqDt(podrEntity.getPodrDt());
+                            deliBaseEntity.setDlvSchDt(podrEntity.getPodrDt());
+                            deliBaseEntity.setDlvCmpltDt(null);
+                            deliBaseEntity.setWhsId(podrEntity.getWhsId());
+                            deliBaseEntity.setLocation(podrEntity.getLocation());
+                            deliBaseEntity.setWhsDvsn("W02");
+                            deliBaseEntity.setBrandId(savePchSteamlineOrdRequest.getBrandId());
+
+                            deliDtlEntity.setDlvSttmtUnqNo(dlvSttmtUnqNo);
+                            deliDtlEntity.setDlvSttmtDtlNo(Integer.toString(dtlRow));
+                            deliDtlEntity.setPchPodrUnqNo(pchPodrUnqNo);
+                            deliDtlEntity.setPchPodrDtlNo(Integer.toString(dtlRow));
+                            deliDtlEntity.setPchReqUnqNo(podrEntity.getPchOdrDtlInfo().getPchReqUnqNo());
+                            deliDtlEntity.setPchReqDtlNo(podrEntity.getPchOdrDtlInfo().getPchReqDtlNo());
+                            deliDtlEntity.setItemId(podrEntity.getPchOdrDtlInfo().getItemId());
+                            deliDtlEntity.setItemNm(podrEntity.getPchOdrDtlInfo().getItemNm());
+                            deliDtlEntity.setUnit(podrEntity.getPchOdrDtlInfo().getUnit());
+                            deliDtlEntity.setUnitAmt(podrEntity.getPchOdrDtlInfo().getUnitAmt());
+                            deliDtlEntity.setPodrQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            deliDtlEntity.setDlvQty(podrEntity.getPchOdrDtlInfo().getPodrQty());
+                            deliDtlEntity.setPodrAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                            deliDtlEntity.setDlvAmt(podrEntity.getPchOdrDtlInfo().getPodrAmt());
+                            deliDtlEntity.setShmtReqUnqNo(shmtReqUnqNo);
+                            deliDtlEntity.setShmtReqDtlNo(Integer.toString(dtlRow));
+                            deliDtlEntity.setExpryDate(null);
+                            deliDtlList.add(deliDtlEntity);
+
+                        } else {
+                            tempTargetBase.setPchOdrStCd("PO20");
+                            tempTargetPtcl.setPodrDtlStCd("POD1");
+                        }
+                    }
 
+                    //마지막 부분 추가 하기
+                    if (j == pchOrdList.size()-1) {
+                        tempTargetBase.setPodrTotalAmt(poTotAmt);
+                        tempTargetBase.setPodrItemQty(poItemCnt);
+                        tempTargetBaseList.add(tempTargetBase);
+                        if ("DL01".equals(preDlvDvsn)) {
+                            shmtBaseEntity.setShmtTotalAmt(poTotAmt);
+                            shmtBaseEntity.setItemQty(poItemCnt);
+                            shmtBaseList.add(shmtBaseEntity);
+                            deliBaseList.add(deliBaseEntity);
+                        }
+                    }
+
+                }  // 구매요청건 개별 종료
 
             } // for문 종료
 
+            // 발주 생성
+            pchOrdMapper.insertStreamListPchOdrBaseInfo(userId, tempTargetBaseList);
+            pchOrdMapper.insertStreamListPchOdrDtlPtcl(userId, tempTargetPtclList);
+            //구매요청 상태 업데이트
+            pchReqMapper.updateStreamListPchReqDtlStCd(userId,gridInsertData );
+            pchReqMapper.updateStreamListPchReqStCd(userId,gridInsertData );
+
+            // 출하지시생성
+            if (shmtBaseList.size() > 0 ) {
+                // 출하지시, 납품서 등록 및 재고 처리
+                shmtOdrMapper.insertStreamListShmtOdrBase(userId, shmtBaseList);
+                shmtOdrMapper.insertShmtOdrDtl(userId, shmtDtlList);
+                shmtOdrMapper.insertStreamListDeliInfoMngt(userId, deliBaseList);
+                shmtOdrMapper.insertDeliDtlPtcl(userId, deliDtlList);
+
+                stockMngMapper.updateMinStockQty(userId, stockList);
+                List<StckMgntDtlHistEntity> stockHistList = new ArrayList<StckMgntDtlHistEntity>();
+                for (int m = 0; m < stockList.size(); m++) {
+                    StckMgntBaseInfoEntity baseEntity = stockList.get(m);
+                    StckMgntDtlHistEntity sourceHist = new StckMgntDtlHistEntity();
+                    sourceHist.setStckMgntDtlNo(fnGetDealNo(32, "")); // 재고관리상세번호
+                    sourceHist.setBrandId(baseEntity.getBrandId());
+                    sourceHist.setWhsId(baseEntity.getWhsId());
+                    sourceHist.setLocation(baseEntity.getLocation());
+                    sourceHist.setItemId(baseEntity.getItemId());
+                    sourceHist.setItemNm(baseEntity.getItemNm());
+                    sourceHist.setInoutCd(InOutCd.OUT.getCd()); // 출고
+                    sourceHist.setInoutQty(baseEntity.getStckQty());
+                    sourceHist.setChgDvsn(ChgDvsn.PURCHASE_OUT.getCd()); // 구매출고
+                    sourceHist.setRelationNo(baseEntity.getRelationNo());
+                    stockHistList.add(sourceHist);
+                }
+                stockMngMapper.insertMultiStckMgntDtlHist(userId, stockHistList);
+            }
 
 
-        } catch (GlobalException e) {
+
+       } catch (GlobalException e) {
             //e.getStackTrace();
             e.printStackTrace();
             throw new GlobalException(e.getSystemMessageCode());

src/main/resources/mybatis/sqlmaps/inoutmng/ShmtOdr.xml

@@ -848,4 +848,37 @@
             and (whs.item_id like concat('%', #{sItemNm}, '%') or whs.item_nm like concat('%', #{sItemNm}, '%'))
         </if>
     </select>
+
+
+    <insert id="insertStreamListShmtOdrBase">
+        insert into shmt_odr_base_info
+            (shmt_req_unq_no, shmt_req_st_cd, shmt_reg_dt, shmt_whs_id, shmt_location
+            , whs_dvsn, brand_id, store_id, podr_dvsn, item_qty
+            , shmt_total_amt,  podr_mgr_nm, dlv_req_dt, whs_id, location
+            , sys_reg_dttm, sys_reg_id, sys_chg_dttm, sys_chg_id)
+        values
+        <foreach collection="gridInsertData" item="item" separator=",">
+            (#{item.shmtReqUnqNo}, #{item.shmtReqStCd}, date_format(now(),'%Y%m%d'), #{item.shmtWhsId}, #{item.shmtLocation}
+            , #{item.whsDvsn}, #{item.brandId}, #{item.storeId}, #{item.podrDvsn}, #{item.itemQty}
+            , #{item.shmtTotalAmt}, #{item.podrMgrNm}, #{item.dlvReqDt}, #{item.whsId}
+            , #{item.location}, NOW(), #{userId}, NOW(), #{userId})
+        </foreach>
+    </insert>
+
+    <insert id="insertStreamListDeliInfoMngt">
+        INSERT INTO deli_info_mgnt
+        (dlv_sttmt_unq_no, spply_id, spply_nm, dlv_reg_dt, dlv_amt
+        , dlv_mgr_nm, dlv_mgr_tel_no, dlv_mgr_emal, dlv_mgr_mbl_no, vndr_tel_no
+        , dlv_st_cd, podr_reg_dt, dlv_req_dt, dlv_sch_dt, dlv_cmplt_dt
+        , whs_id, location, whs_dvsn, brand_id,store_id
+        , sys_reg_dttm, sys_reg_id, sys_chg_dttm, sys_chg_id)
+        VALUES
+        <foreach collection="gridInsertData" item="item" separator=",">
+        (#{item.dlvSttmtUnqNo}, #{item.spplyId}, #{item.spplyNm}, date_format(now(),'%Y%m%d'), #{item.dlvAmt}
+        , #{item.dlvMgrNm}, #{item.dlvMgrTelNo}, #{item.dlvMgrEmal}, #{item.dlvMgrMblNo}, #{item.vndrTelNo}
+        , #{item.dlvStCd}, #{item.podrRegDt}, #{item.dlvReqDt}, #{item.dlvSchDt}, #{item.dlvCmpltDt}
+        , #{item.whsId}, #{item.location}, #{item.whsDvsn}, #{item.brandId}, #{item.storeId}
+        , NOW(), #{userId}, NOW(), #{userId})
+        </foreach>
+    </insert>
 </mapper>

src/main/resources/mybatis/sqlmaps/pomng/PchOrd.xml

@@ -415,13 +415,39 @@
         and base.spply_id = #{spplyId}
     </select>
 
+    <select id="selectPchPoStreamlineBrandDlvChk" resultType="int">
+        select count(*) as cnt
+        from (
+                 select  case when base.store_id is null or base.store_id = '' then 'DL02' else  case when item.store_deli_type = '10' then 'DL01' else 'DL02' end   end as dlv_dvsn
+                  from pch_req_base_info base
+                  join pch_req_dtl_ptcl ptcl on base.pch_req_unq_no = ptcl.pch_req_unq_no
+                  join brand_base_info brand on base.brand_id = brand.brand_id
+                  join item_base_info item on base.brand_id = item.brand_id and ptcl.item_id = item.item_id
+                  where 1 = 1
+                  and base.brand_id = #{brandId}
+                  and ptcl.pch_req_dtl_st_cd = 'PRD20'
+                  and brand.shmt_col_proc_type = '20'
+                  and base.pch_req_unq_no   in
+                    <foreach collection="gridUpdateData" item="item" separator="," open="(" close=")">
+                        concat(#{item.pchReqUnqNo})
+                    </foreach>
+              ) TCNT
+        where TCNT.dlv_dvsn = 'DL01'
+    </select>
+
+
+
     <select id="selectPchPoStreamlineList" resultType="com.oqpo.api.entity.pomng.PchOdrBaseInfoEntity">
-        select base.pch_req_unq_no, ptcl.pch_req_dtl_no as 'pchReqDtlInfo.pch_req_dtl_no'
-            , base.brand_id, base.store_id, base.whs_id, base.location
-            , ptcl.item_id as 'pchReqDtlInfo.item_id', ptcl.item_nm as 'pchReqDtlInfo.item_nm', ptcl.unit_amt as 'pchReqDtlInfo.unit_amt'
-            , bitem.unit_amt as 'itemUnitInfo.unit_amt' , ptcl.pch_req_qty as 'pchReqDtlInfo.pch_req_qty', base.dlv_req_dt
-            , ptcl.pch_req_amt as 'pchReqDtlInfo.pch_req_amt', bitem.unit_amt * ptcl.pch_req_qty as 'pchReqDtlInfo.pch_ord_amt'
-            , bitem.lead_time as 'itemUnitInfo.lead_time', bitem.spply_id as 'itemUnitInfo.spply_id'
+        select
+            base.brand_id, base.store_id,  bitem.spply_id,  base.dlv_req_dt, 'OD01' as podr_dvsn
+			,case when base.store_id is null or base.store_id = '' then 'W01' else 'W02' end as whs_dvsn
+			, base.whs_id, base.location
+            ,base.pch_req_unq_no as 'pchOdrDtlInfo.pch_req_unq_no', ptcl.pch_req_dtl_no as 'pchOdrDtlInfo.pch_req_dtl_no'
+            , ptcl.item_id as 'pchOdrDtlInfo.item_id', ptcl.item_nm as 'pchOdrDtlInfo.item_nm'
+			, ptcl.pch_req_qty as 'pchOdrDtlInfo.podr_qty', ptcl.pch_req_amt as 'pchOdrDtlInfo.podr_amt'
+			, bitem.curr as 'pchOdrDtlInfo.curr', bitem.unit  as 'pchOdrDtlInfo.unit'
+			, ptcl.unit_amt as 'pchOdrDtlInfo.unit_amt', base.dlv_req_dt as 'pchOdrDtlInfo.dlv_sch_dt'
+			, ptcl.brand_unit_unq_no  as 'pchOdrDtlInfo.brand_unit_unq_no', ptcl.store_unit_unq_no  as 'pchOdrDtlInfo.store_unit_unq_no'
             , case when base.store_id is null or base.store_id = '' then 'DL02' else  case when item.store_deli_type = '10' then 'DL01' else 'DL02' end   end as dlv_dvsn
             , fn_code_nm('DLV_DVSN',case when base.store_id is null or base.store_id = '' then 'DL02' else  case when item.store_deli_type = '10' then 'DL01' else 'DL02' end   end) as dlv_dvsn_nm
         from pch_req_base_info base
@@ -435,11 +461,43 @@
         and base.pch_req_st_cd = 'PR20'
         and ptcl.pch_req_dtl_st_cd = 'PRD20'
         and brand.shmt_col_proc_type = '20'
-        and base.pch_req_unq_no   in
-        <foreach collection="gridUpdateData" item="item" separator="," open="(" close=")">
-            concat(#{item.pchReqUnqNo})
-        </foreach>
+        and base.pch_req_unq_no   = #{pchReqUnqNo}
         order by base.pch_req_unq_no, dlv_dvsn, bitem.spply_id
     </select>
 
+    <insert id="insertStreamListPchOdrBaseInfo">
+        INSERT INTO pch_odr_base_info
+        (pch_podr_unq_no, brand_id, podr_total_amt
+        , dlv_dvsn, dlv_req_dt, podr_mgr_nm, podr_dvsn
+        , pch_odr_st_cd, note, spply_id, podr_mgr_id
+        , podr_dt, podr_mgr_tel_no, podr_item_qty, whs_dvsn, whs_id
+        , location, shmt_whs_id, shmt_location, store_id
+        , sys_reg_dttm, sys_reg_id, sys_chg_dttm, sys_chg_id)
+        VALUES
+        <foreach collection="gridInsertData" item="item" separator=",">
+            (#{item.pchPodrUnqNo}, #{item.brandId}, #{item.podrTotalAmt}
+           , #{item.dlvDvsn}, #{item.dlvReqDt}, #{item.podrMgrNm}, #{item.podrDvsn}
+            , #{item.pchOdrStCd}, #{item.note}, #{item.spplyId}, #{userId}
+            , date_format(now(),'%Y%m%d') , #{item.podrMgrTelNo}, #{item.podrItemQty}, #{item.whsDvsn}, #{item.whsId}
+            , #{item.location}, #{item.shmtWhsId}, #{item.shmtLocation}, #{item.storeId}
+            , NOW(), #{userId}, NOW(), #{userId})
+        </foreach>
+
+    </insert>
+
+    <insert id="insertStreamListPchOdrDtlPtcl">
+        INSERT INTO pch_odr_dtl_ptcl
+        (pch_podr_unq_no, pch_podr_dtl_no, pch_req_unq_no, pch_req_dtl_no, item_id
+        , item_nm, podr_qty, podr_amt, curr, unit, podr_dtl_st_cd
+        , unit_amt, dlv_sch_dt, store_unit_unq_no, brand_unit_unq_no
+        , sys_reg_dttm, sys_reg_id, sys_chg_dttm, sys_chg_id)
+        VALUES
+        <foreach collection="gridInsertData" item="item" separator=",">
+            (#{item.pchPodrUnqNo}, #{item.pchPodrDtlNo}, #{item.pchReqUnqNo}, #{item.pchReqDtlNo}, #{item.itemId}
+            , #{item.itemNm}, #{item.podrQty}, #{item.podrAmt}, #{item.curr}, #{item.unit}, #{item.podrDtlStCd}
+            , #{item.unitAmt}, #{item.dlvSchDt}, #{item.storeUnitUnqNo}, #{item.brandUnitUnqNo}
+            , NOW(), #{userId}, NOW(), #{userId})
+        </foreach>
+    </insert>
+
 </mapper>

src/main/resources/mybatis/sqlmaps/pomng/PchReq.xml

@@ -497,4 +497,29 @@
         where  brand_id = #{brandId}
         and    pch_req_unq_no = #{pchReqUnqNo}
     </select>
+
+    <update id="updateStreamListPchReqDtlStCd">
+        <foreach collection="gridUpdateData" item="item" separator=";">
+            UPDATE /* PchReq.updateStreamListPchReqDtlStCd */
+            pch_req_dtl_ptcl SET
+            pch_req_dtl_st_cd = 'PRD30',
+            sys_chg_dttm = NOW(),
+            sys_chg_id = #{userId}
+            WHERE pch_req_unq_no = #{item.pchReqUnqNo}
+        </foreach>
+    </update>
+
+    <update id="updateStreamListPchReqStCd">
+        <foreach collection="gridUpdateData" item="item" separator=";">
+            UPDATE /* PchReq.updateStreamListPchReqStCd */
+            pch_req_base_info SET
+            pch_req_st_cd ='PR30',
+            sys_chg_dttm = NOW(),
+            sys_chg_id = #{userId}
+            WHERE pch_req_unq_no = #{item.pchReqUnqNo}
+        </foreach>
+    </update>
+
+
+
 </mapper>