门店控件增加接口

gic-store-web/src/main/java/com/gic/store/web/controller/StoreDictController.java

@@ -16,6 +16,7 @@ import com.gic.enterprise.utils.UserDetailUtils;
 import com.gic.redis.data.util.RedisUtil;
 import com.gic.store.constant.StoreESFieldsEnum;
 import com.gic.store.dto.StoreDictDTO;
+import com.gic.store.service.StoreApiService;
 import com.gic.store.service.StoreDictApiService;
 import com.gic.store.web.vo.StoreDictVO;
 import org.apache.commons.lang.StringUtils;
@@ -39,6 +40,8 @@ public class StoreDictController {
     private EnterpriseInitApiService enterpriseInitApiService;
     @Autowired
     private AuditLogApiService auditLogApiService;
+    @Autowired
+    private StoreApiService storeApiService;
 
 
     @RequestMapping("list-all-businesscategory")
@@ -136,7 +139,7 @@ public class StoreDictController {
     @RequestMapping("save-status-type")
     @ResponseBody
     public RestResponse saveStoreStatusAndStoreType(String storeStatus, String storeType){
-        AuditLogDTO auditLogDTO = new AuditLogDTO();
+        /*AuditLogDTO auditLogDTO = new AuditLogDTO();
         // 商户id
         auditLogDTO.setEnterpriseId(UserDetailUtils.getUserDetail().getEnterpriseId());
         // 申请人id
@@ -151,16 +154,23 @@ public class StoreDictController {
         jsonObject.put("storeType", storeType);
         auditLogDTO.setExtraInfo(jsonObject.toJSONString());
         ServiceResponse<Void> serviceResponse = auditLogApiService.apply(auditLogDTO);
-        return ResultControllerUtils.commonResult(serviceResponse);
-//        Integer enterpriseId = UserDetailUtils.getUserDetail().getEnterpriseId();
-//        ServiceResponse serviceResponse = this.storeDictApiService.saveStoreStatusAndStoreType(enterpriseId, storeStatus.split(","), storeType.split(","));
-//        if(serviceResponse.isSuccess()){
-//            LogUtils.createLog("配置商户门店类型和门店状态", "门店状态和门店类型");
-//            this.enterpriseInitApiService.setStoreStatusAndType(enterpriseId);
-//            return RestResponse.success();
-//        }else {
-//            return RestResponse.failure(serviceResponse.getCode(), serviceResponse.getMessage());
-//        }
+        return ResultControllerUtils.commonResult(serviceResponse);*/
+        Integer enterpriseId = UserDetailUtils.getUserDetail().getEnterpriseId();
+        String key = "storeStatusAndType:"+enterpriseId;
+        Object cache = RedisUtil.getCache(key);
+        if(cache != null){
+            return RestResponse.failure(ErrorCode.SYSTEM_ERROR.getCode(), "请稍后重试");
+        }
+        RedisUtil.setCache(key, 1, 12l, TimeUnit.HOURS);
+        ServiceResponse serviceResponse = this.storeDictApiService.saveStoreStatusAndStoreType(enterpriseId, storeStatus.split(","), storeType.split(","));
+        if(serviceResponse.isSuccess()){
+            LogUtils.createLog("配置商户门店类型和门店状态", "门店状态和门店类型");
+            this.enterpriseInitApiService.setStoreStatusAndType(enterpriseId);
+            this.storeApiService.bulkAddStoreToIndex(enterpriseId);
+            return RestResponse.success();
+        }else {
+            return RestResponse.failure(serviceResponse.getCode(), serviceResponse.getMessage());
+        }
     }