三维校验

amos-boot-system-tdc/amos-boot-module-tdc-api/src/main/java/com/yeejoin/amos/boot/module/tdc/api/service/CheckModelService.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.yeejoin.amos.boot.module.tdc.api.dto.CheckModelDto;
 import com.yeejoin.amos.boot.module.tdc.api.entity.CheckModel;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
@@ -34,13 +35,13 @@ public interface CheckModelService extends IService<CheckModel> {
      * 校验机构下全部模型
      * @param amosOrgCode 机构code
      */
-    void checkAllMode(String amosOrgCode);
+    void checkAllMode(String amosOrgCode, AgencyUserModel userInfo);
 
     /**
      * 校验单个模型
      * @param modelId 模型id
      */
-    void checkSingleMode(String modelId);
+    void checkSingleMode(String modelId, AgencyUserModel userInfo);
 
     /**
      * 根据机构code和模型名称查询模型对象

amos-boot-system-tdc/amos-boot-module-tdc-api/src/main/java/com/yeejoin/amos/boot/module/tdc/api/service/CheckResultService.java

@@ -48,4 +48,11 @@ public interface CheckResultService extends IService<CheckResult> {
      */
     Integer selectItemCount(String batchNo);
 
+    /**
+     * 查询不合格项
+     * @param batchNo 批次号
+     * @return 属性个数
+     */
+    Integer selectItemNo(String batchNo,Long modelId);
+
 }

amos-boot-system-tdc/amos-boot-module-tdc-biz/src/main/java/com/yeejoin/amos/boot/module/tdc/biz/action/CheckModelAction.java

@@ -73,6 +73,7 @@ public class CheckModelAction {
         String batchNo = String.valueOf(propertyValues.get("batch_no"));
         Integer checkType = Integer.valueOf(String.valueOf(propertyValues.get("checkType")));
         String orgCode = String.valueOf(propertyValues.get("org_code"));
+        String checkPeopleName = String.valueOf(propertyValues.get("checkPeopleName"));
         String itemName = idxProjectModel.getItemName();
 
         // 获取模型
@@ -105,12 +106,12 @@ public class CheckModelAction {
         if (ObjectUtils.isNotEmpty(checkType)) {
             if (checkType == 1) {
                 // 2.2 单独模型校验,根据批次号查询已经入库的属性
-                sendWebMessage(batchNo, checkModel.getCheckItemAmount());
+                sendWebMessage(batchNo, checkModel.getCheckItemAmount(), orgCode, checkPeopleName, checkType, itemName);
             } else if (checkType == 0) {
                 // 2.1 全站校验
                 List<CheckModel> checkModels = checkModelService.selectByOrgCode(orgCode);
                 int sum = checkModels.stream().mapToInt(CheckModel::getCheckItemAmount).sum();
-                sendWebMessage(batchNo, sum);
+                sendWebMessage(batchNo, sum, orgCode, checkPeopleName, checkType, itemName);
             }
         }
 //        else {
@@ -124,7 +125,7 @@ public class CheckModelAction {
 //        }
     }
 
-    private void sendWebMessage(String batchNo, Integer itemSize) {
+    private void sendWebMessage(String batchNo, Integer itemSize, String orgCode, String checkPeopleName, Integer checkType, String itemName) {
         Integer itemCount = checkResultService.selectItemCount(batchNo);
         if (itemCount.equals(itemSize)) {
             // 所有属性已全部入库，给前端发送消息
@@ -139,8 +140,29 @@ public class CheckModelAction {
                 e.printStackTrace();
             }
 
-            // 全站校验生成报告
+            if (checkType == 0) {
+                // 全站校验生成报告
+                checkResultService.saveSql(orgCode, checkPeopleName);
+                List<CheckModel> checkModels = checkModelService.selectByOrgCode(orgCode);
+                checkModels.forEach(checkModel -> {
+                    saveCheckModel(checkModel, batchNo);
+                });
+            } else {
+                // 更改校验结果
+                CheckModel checkModel = checkModelService.selectCheckModelByNameCode(itemName, orgCode);
+                saveCheckModel(checkModel, batchNo);
+            }
+        }
+    }
 
+    private void saveCheckModel (CheckModel checkModel, String batchNo) {
+        Integer integer = checkResultService.selectItemNo(batchNo, checkModel.getSequenceNbr());
+        if (0 == integer) {
+            checkModel.setCheckStatus(1);
+        } else {
+            checkModel.setCheckStatus(2);
         }
+        checkModel.setCheckDate(new Date());
+        checkModelService.updateById(checkModel);
     }
 }

amos-boot-system-tdc/amos-boot-module-tdc-biz/src/main/java/com/yeejoin/amos/boot/module/tdc/biz/controller/CheckModelController.java

 package com.yeejoin.amos.boot.module.tdc.biz.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.module.tdc.api.dto.CheckModelDto;
 import com.yeejoin.amos.boot.module.tdc.api.entity.CheckModel;
 import com.yeejoin.amos.boot.module.tdc.api.service.CheckModelService;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -21,7 +23,7 @@ import java.util.List;
 @RestController
 @Api(tags = "校验模型api")
 @RequestMapping(value = "/model")
-public class CheckModelController {
+public class CheckModelController extends BaseController {
 
     @Autowired
     CheckModelService checkModelService;
@@ -55,7 +57,8 @@ public class CheckModelController {
     @GetMapping(value = "/CheckAllModel/{amosOrgCode}")
     @ApiOperation(httpMethod = "GET",value = "点击全站校验",  notes = "根据机构code校验模型")
     public void CheckAllModel(@PathVariable(value = "amosOrgCode") String amosOrgCode) {
-        checkModelService.checkAllMode(amosOrgCode);
+        AgencyUserModel userInfo = getUserInfo();
+        checkModelService.checkAllMode(amosOrgCode, userInfo);
     }
 
     /**
@@ -65,6 +68,7 @@ public class CheckModelController {
     @GetMapping(value = "/checkSingleMode/{modelId}")
     @ApiOperation(httpMethod = "GET",value = "点击单独模型校验",  notes = "根据modelId校验模型")
     public void checkSingleMode(@PathVariable(value = "modelId") String modelId) {
-        checkModelService.checkSingleMode(modelId);
+        AgencyUserModel userInfo = getUserInfo();
+        checkModelService.checkSingleMode(modelId, userInfo);
     }
 }

amos-boot-system-tdc/amos-boot-module-tdc-biz/src/main/java/com/yeejoin/amos/boot/module/tdc/biz/service/impl/CheckModelImpl.java

@@ -20,6 +20,7 @@ import com.yeejoin.amos.boot.module.tdc.api.vo.SubjectTreeVo;
 import com.yeejoin.amos.boot.module.tdc.api.vo.TableColumnsVo;
 import com.yeejoin.amos.boot.module.tdc.biz.action.model.IdxProjectModel;
 import com.yeejoin.amos.component.rule.RuleTrigger;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -78,27 +79,29 @@ public class CheckModelImpl extends ServiceImpl<CheckModelMapper, CheckModel> im
     }
 
     @Override
-    public void checkAllMode(String amosOrgCode) {
+    public void checkAllMode(String amosOrgCode, AgencyUserModel userInfo) {
+        String userName = userInfo.getUserName();
         LambdaQueryWrapper<CheckModel> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(CheckModel::getAmosOrgCode, amosOrgCode);
         List<CheckModel> checkModels = this.baseMapper.selectList(wrapper);
         String batchNo = UUID.randomUUID().toString();
         if (!CollectionUtils.isEmpty(checkModels)) {
             checkModels.forEach(checkModel -> {
-                checkModelRule(checkModel, 0, batchNo, amosOrgCode);
+                checkModelRule(checkModel, 0, batchNo, amosOrgCode, userName);
             });
         }
     }
 
     @Override
-    public void checkSingleMode(String modelId) {
+    public void checkSingleMode(String modelId, AgencyUserModel userInfo) {
+        String userName = userInfo.getUserName();
         LambdaQueryWrapper<CheckModel> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(CheckModel::getSequenceNbr, modelId);
         CheckModel checkModel = this.baseMapper.selectOne(wrapper);
         if (!ObjectUtils.isEmpty(checkModel)) {
             // 调用规则校验模型
             String batchNo = UUID.randomUUID().toString();
-            checkModelRule(checkModel, 1, batchNo, checkModel.getAmosOrgCode());
+            checkModelRule(checkModel, 1, batchNo, checkModel.getAmosOrgCode(), userName);
         }
     }
 
@@ -110,7 +113,7 @@ public class CheckModelImpl extends ServiceImpl<CheckModelMapper, CheckModel> im
         return this.baseMapper.selectOne(wrapper);
     }
 
-    private void checkModelRule(CheckModel checkModel, int checkType, String batchNo, String amosOrgCode) {
+    private void checkModelRule(CheckModel checkModel, int checkType, String batchNo, String amosOrgCode, String userName) {
         IdxProjectModel idxProjectModel = new IdxProjectModel();
         // 查询表最新一条数据
         String idxTableName = checkModel.getIdxTableName();
@@ -121,6 +124,7 @@ public class CheckModelImpl extends ServiceImpl<CheckModelMapper, CheckModel> im
         }
         map.put("batch_no", batchNo);
         map.put("checkType", checkType);
+        map.put("checkPeopleName", userName);
 
         // 查询表所有字段
         ResponseModel<JSONObject> model = idxFeignService.queryByTableId(checkModel.getTableId());

amos-boot-system-tdc/amos-boot-module-tdc-biz/src/main/java/com/yeejoin/amos/boot/module/tdc/biz/service/impl/CheckReportImpl.java

@@ -28,7 +28,7 @@ public class CheckReportImpl extends ServiceImpl<CheckReportMapper, CheckReport>
             return this.page(page);
         }else{
             LambdaQueryWrapper<CheckReport> wrapper = new LambdaQueryWrapper<>();
-            wrapper.eq(CheckReport::getAmosOrgCode, amosOrgCode);
+            wrapper.likeRight(CheckReport::getAmosOrgCode, amosOrgCode);
             return this.page(page,wrapper);
         }
 

amos-boot-system-tdc/amos-boot-module-tdc-biz/src/main/java/com/yeejoin/amos/boot/module/tdc/biz/service/impl/CheckResultImpl.java

@@ -165,6 +165,15 @@ public class CheckResultImpl extends ServiceImpl<CheckResultMapper, CheckResult>
         return this.baseMapper.selectCount(wrapper);
     }
 
+    @Override
+    public Integer selectItemNo(String batchNo, Long modelId) {
+        LambdaQueryWrapper<CheckResult> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(CheckResult::getBatchNo, batchNo);
+        wrapper.eq(CheckResult::getModelId, modelId);
+        wrapper.eq(CheckResult::getCheckItemResult, 1);
+        return this.baseMapper.selectCount(wrapper);
+    }
+
 
     /**
      * 获取报告数据