오더퀸 매장 단가정보 연동

src/main/java/com/oqpo/api/service/stinfo/ItemUnitService.java

@@ -2,6 +2,10 @@ package com.oqpo.api.service.stinfo;
 
 
 import com.oqpo.api.client.oqlink.OqlinkClient;
+import com.oqpo.api.client.oqlink.dto.OqScmMenuModel;
+import com.oqpo.api.client.oqlink.dto.OqScmStorePriceChangeReqModel;
+import com.oqpo.api.client.oqlink.dto.OqScmStorePriceChangeResModel;
+import com.oqpo.api.client.oqlink.util.HmacUtil;
 import com.oqpo.api.entity.CodeEntity;
 import com.oqpo.api.entity.oper.FileEntity;
 import com.oqpo.api.entity.oper.UserMngEntity;
@@ -12,8 +16,10 @@ import com.oqpo.api.mapper.FileMapper;
 import com.oqpo.api.mapper.oper.UserMngMapper;
 import com.oqpo.api.mapper.stinfo.ItemMapper;
 import com.oqpo.api.mapper.stinfo.ItemUnitMapper;
+import com.oqpo.api.mapper.stinfo.StoreBaseInfoMapper;
 import com.oqpo.api.mapper.stinfo.StoreItemUnitMapper;
 import com.oqpo.api.service.CommonService;
+import com.oqpo.api.util.StringUtil;
 import com.oqpo.api.web.dto.request.GridRequest;
 import com.oqpo.api.web.dto.request.stinfo.item.DelItemInfolRequest;
 import com.oqpo.api.web.dto.request.stinfo.item.SaveItemClassMngInfolRequest;
@@ -46,9 +52,15 @@ public class ItemUnitService extends CommonService {
     @Autowired
     private ItemUnitMapper itemUnitMapper;
 
+    @Autowired
+    private ItemMapper itemMapper;
+
     @Autowired
     private StoreItemUnitMapper storeItemUnitMapper;
 
+    @Autowired
+    private StoreBaseInfoMapper storeBaseInfoMapper;
+
     @Autowired
     private FileMapper fileMapper;
 
@@ -332,7 +344,6 @@ public class ItemUnitService extends CommonService {
             StoreItemUnitEntity entity = new StoreItemUnitEntity();
             entity.setBrandId(saveStoreItemUnitInfolRequest.getBrandId());
             entity.setStoreId(saveStoreItemUnitInfolRequest.getStoreId());
-
             entity.setContSttDt(saveStoreItemUnitInfolRequest.getContSttDt().replaceAll("\\.", ""));
             entity.setContEndDt(saveStoreItemUnitInfolRequest.getContEndDt().replaceAll("\\.", ""));
 
@@ -409,10 +420,38 @@ public class ItemUnitService extends CommonService {
                 storeItemUnitMapper.updateStoreItemUnitChgContEnd(entity.getBrandId(), entity.getStoreId(), entity.getContSttDt(), entity.getContEndDt());
             }
 
-            //selectStoreItemUnitEndDtInfo  , updateStoreItemUnitChgContEnd
-
             // TODO 오더퀸 연동
-
+            StoreBaseInfoEntity storeInfo = storeBaseInfoMapper.selectStoreInfo(saveStoreItemUnitInfolRequest.getBrandId(), saveStoreItemUnitInfolRequest.getStoreId());
+            if (!StringUtil.isEmpty(storeInfo.getOqBrandId()) && !StringUtil.isEmpty(storeInfo.getOqStoreId())) {
+
+                List<OqScmMenuModel> menuList = new ArrayList<>();
+                // 등록 리스트 처리
+                for (StoreItemUnitEntity item : gridInsertData) {
+                    OqScmMenuModel menu = toOqScmMenuModel(saveStoreItemUnitInfolRequest, item);
+                    menuList.add(menu);
+                }
+                // 수정 리스트 처리
+                for (StoreItemUnitEntity item : gridUpdateData) {
+                    OqScmMenuModel menu = toOqScmMenuModel(saveStoreItemUnitInfolRequest, item);
+                    menuList.add(menu);
+                }
+                OqScmStorePriceChangeReqModel req = new OqScmStorePriceChangeReqModel();
+                req.setBrandCd(storeInfo.getOqBrandId());
+                req.setStoreNo(storeInfo.getOqStoreId());
+                req.setMenuList(menuList);
+                OqScmStorePriceChangeResModel res = oqlinkClient.changeScmStorePrice(HmacUtil.makeHmacValue4OqLink(req), req);
+
+                if (SystemMessageCode.BO_IF_OK.getId() == Integer.parseInt(res.getCode())) {
+                    // 오더퀸 메뉴코드 업데이트
+                    ItemEntity itemEntity = null;
+                    for (OqScmMenuModel item : res.getMenuList()) {
+                        itemEntity = toItemEntity4OqLink(item);
+                        itemMapper.updateItemInfo4OqLinik(userId, itemEntity);
+                    }
+                } else {
+                    throw new GlobalException(SystemMessageCode.valueOf(Integer.valueOf(res.getCode())));
+                }
+            }
         } catch (GlobalException e) {
             e.getStackTrace();
             throw new GlobalException(e.getSystemMessageCode());
@@ -422,4 +461,20 @@ public class ItemUnitService extends CommonService {
         }
     }
 
+    private ItemEntity toItemEntity4OqLink(OqScmMenuModel item) {
+        ItemEntity itemEntity = new ItemEntity();
+        itemEntity.setItemId(item.getItemId());
+        itemEntity.setOqMenuCd(item.getMenuCd());
+        return itemEntity;
+    }
+
+    private OqScmMenuModel toOqScmMenuModel(SaveStoreItemUnitInfolRequest saveStoreItemUnitInfolRequest, StoreItemUnitEntity item) throws Exception {
+        ItemEntity itemInfo = itemMapper.selectItemInfo(saveStoreItemUnitInfolRequest.getBrandId(), item.getItemId());
+        OqScmMenuModel menu = new OqScmMenuModel();
+        menu.setItemId(item.getItemId()); // 품목아이디
+        menu.setSupplyPrice(item.getUnitAmt().intValue()); // 단가금액
+        menu.setMenuCd(itemInfo == null || StringUtil.isEmpty(itemInfo.getOqMenuCd()) ? null : itemInfo.getOqMenuCd());
+        return menu;
+    }
+
 }

src/main/java/com/oqpo/api/web/dto/request/stinfo/itemUnit/SaveStoreItemUnitInfolRequest.java

@@ -40,7 +40,7 @@ public class SaveStoreItemUnitInfolRequest {
     private List<SaveStoreItemUnitInfolRequest.SaveStoreItemUnit> gridInsertData;
 
 
-    public List<StoreItemUnitEntity> toCodeEntities(List< SaveStoreItemUnitInfolRequest.SaveStoreItemUnit > gridData) {
+    public List<StoreItemUnitEntity> toCodeEntities(List<SaveStoreItemUnitInfolRequest.SaveStoreItemUnit> gridData) {
         List<StoreItemUnitEntity> entities = new ArrayList<>();
         if (gridData == null || gridData.size() == 0)
             return entities;