lin.liu 3 недель назад
Родитель
Сommit
d7894ff8b0

+ 1 - 1
secure-producting-business/src/main/java/com/customs/cq/datacenter/business/mapper/impl/DangerCategoryMapperImpl.java

@@ -109,7 +109,7 @@ public class DangerCategoryMapperImpl extends BasicMapper<DangerCategoryPO> {
     public List<NameValueDto> listAllSelect() {
         List<String> listColumn = new ArrayList<>();
         listColumn.add("id");
-        listColumn.add("category_name");
+        listColumn.add("CATEGORY_NAME");
 
         LambdaQueryWrapper<DangerCategoryPO> queryWrapper = this.getQuery();
         queryWrapper.select(DangerCategoryPO.class, c -> listColumn.contains(c.getColumn()));

+ 8 - 0
secure-producting-business/src/main/java/com/customs/cq/datacenter/business/mapper/impl/DangerCheckFormMapperImpl.java

@@ -1,6 +1,7 @@
 package com.customs.cq.datacenter.business.mapper.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.customs.cq.datacenter.business.domain.DangerCheckFormPO;
@@ -107,4 +108,11 @@ public class DangerCheckFormMapperImpl extends BasicMapper<DangerCheckFormPO> {
         where.eq(DangerCheckFormPO::getDangerCategory, dangerCategory);
         return mapper.selectCount(where);
     }
+
+    public void updateCheckCycle(Long dangerCategory, Integer checkCycle) {
+        UpdateWrapper<DangerCheckFormPO> where = this.getUpdate();
+        where.set("CHECK_CYCLE", checkCycle);
+        where.eq("DANGER_CATEGORY", dangerCategory);
+        mapper.update(null, where);
+    }
 }

+ 7 - 0
secure-producting-business/src/main/java/com/customs/cq/datacenter/business/service/DangerCategoryService.java

@@ -29,6 +29,7 @@ import com.customs.cq.datacenter.business.entity.request.dangercategory.ReqCreat
 import com.customs.cq.datacenter.business.entity.request.dangercategory.ReqModifyDangerCategory;
 import com.customs.cq.datacenter.business.entity.search.SearchDangerCategory;
 import com.customs.cq.datacenter.business.mapper.impl.DangerCategoryMapperImpl;
+import com.customs.cq.datacenter.business.mapper.impl.DangerCheckFormMapperImpl;
 import com.customs.cq.datacenter.common.ExecutedResult;
 import com.customs.cq.datacenter.common.PagerResult;
 import com.customs.cq.datacenter.common.core.domain.model.LoginUser;
@@ -56,6 +57,8 @@ import java.util.Objects;
 public class DangerCategoryService extends BasicService {
     @Autowired
     private DangerCategoryMapperImpl dao;
+    @Autowired
+    private DangerCheckFormMapperImpl checkFormMapper;
 
     public ExecutedResult<Long> create(ReqCreateDangerCategory request) {
         // 转换po
@@ -101,6 +104,10 @@ public class DangerCategoryService extends BasicService {
         if (result != 1) {
             return ExecutedResult.failed("编辑[隐患类别]失败。");
         }
+        // 更新隐患检查表的检查频率
+        ThreadPoolUtil.getDefaultPool().execute(() -> {
+            checkFormMapper.updateCheckCycle(request.getId(), request.getCheckCycle());
+        });
         return ExecutedResult.success();
     }