方法修改

src/main/java/com/gic/message/service/impl/StoreInfoMessageHandler.java

@@ -57,7 +57,7 @@ public class StoreInfoMessageHandler implements MessageHandler {
             for(StoreDTO storeDTO : listStore){
                 if(storeDTO.getOwnType() == StoreOwnTypeEnum.OWNER.getCode()){
                     if(Integer.valueOf(fieldMap.get("old_status").getValue()) == 1 && Integer.valueOf(fieldMap.get("new_status").getValue()) == 0){
-                        this.storeApiService.deleteStoreFromES(storeDTO.getEnterpriseId(), storeDTO.getStoreId());
+                        this.storeApiService.deleteStoreFromEs(storeDTO.getEnterpriseId(), storeDTO.getStoreId());
                     }else {
                         this.storeIndexRefreshHandler.refreshStoreIndex(storeDTO.getEnterpriseId(), storeDTO.getStoreId());
                     }
@@ -76,7 +76,7 @@ public class StoreInfoMessageHandler implements MessageHandler {
             ServiceResponse<List<StoreDTO>> listStoreResponse = this.storeApiService.listStoreByStoreInfoId(storeInfoId);
             List<StoreDTO> listStore = listStoreResponse.getResult();
             for(StoreDTO storeDTO : listStore){
-               this.storeApiService.deleteStoreFromES(storeDTO.getEnterpriseId(), storeDTO.getStoreId());
+               this.storeApiService.deleteStoreFromEs(storeDTO.getEnterpriseId(), storeDTO.getStoreId());
             }
         }
     }

src/main/java/com/gic/message/service/impl/StoreMessageHandler.java

@@ -3,7 +3,6 @@ package com.gic.message.service.impl;
 import com.gic.api.base.commons.Page;
 import com.gic.api.base.commons.ServiceResponse;
 import com.gic.auth.constant.AuthModeEnum;
-import com.gic.auth.dto.UnionEnterpriseDTO;
 import com.gic.auth.dto.UnionEnterpriseResourceDTO;
 import com.gic.auth.service.UnionEnterpriseApiService;
 import com.gic.binlog.base.entity.GicField;
@@ -59,7 +58,7 @@ public class StoreMessageHandler implements MessageHandler {
             storeId = Integer.valueOf(fieldMap.get("new_store_id").getValue());
             storeInfoId = Integer.valueOf(fieldMap.get("new_store_info_id").getValue());
             if (Integer.valueOf(fieldMap.get("old_status").getValue()) == 1 && Integer.valueOf(fieldMap.get("new_status").getValue()) == 0) {  //删除
-                this.storeApiService.deleteStoreFromES(enterpriseId, storeId);
+                this.storeApiService.deleteStoreFromEs(enterpriseId, storeId);
             } else if (Integer.valueOf(fieldMap.get("old_status").getValue()) == 1 && Integer.valueOf(fieldMap.get("new_status").getValue()) == 2){  //下线
                 //todo 通知会员组（积分成本转移）
             }else {
@@ -73,7 +72,7 @@ public class StoreMessageHandler implements MessageHandler {
             enterpriseId = Integer.valueOf(fieldMap.get("enterprise_id").getValue());
             storeId = Integer.valueOf(fieldMap.get("store_id").getValue());
             storeInfoId = Integer.valueOf(fieldMap.get("store_info_id").getValue());
-            this.storeApiService.deleteStoreFromES(enterpriseId, storeId);
+            this.storeApiService.deleteStoreFromEs(enterpriseId, storeId);
             Integer ownType = Integer.valueOf(fieldMap.get("own_type").getValue());
             if(ownType == StoreOwnTypeEnum.OWNER.getCode()){
                 this.dealStoreChange(enterpriseId, storeId, storeInfoId, GicRecordType.DELETE.value());