数据校验规则

xieb

2023-07-04 6e0943c5a3048c6d81a036618683c7757ea0d48a

数据校验规则

 skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/resDataCheck/feign/IRulesClient.java

@@ -20,6 +20,6 @@
    String CREATE_DATA_RULES = API_PREFIX + "/createDataRules";

    @GetMapping(CREATE_DATA_RULES)
    R createDataRules();
    R createDataRules(Long id);

}

 skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/resDataCheck/feign/RulesClientClientFallback.java

@@ -14,7 +14,7 @@
public class RulesClientClientFallback implements IRulesClient{

    @Override
    public R createDataRules() {
    public R createDataRules(Long id) {
        return R.fail("获取数据失败");
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/resDataCheck/feign/RulesClient.java

New file
@@ -0,0 +1,52 @@
package cn.gistack.sm.resDataCheck.feign;

import cn.gistack.sm.resDataCheck.entity.Rules;
import cn.gistack.sm.resDataCheck.entity.RulesCondition;
import cn.gistack.sm.resDataCheck.service.IRulesConditionService;
import cn.gistack.sm.resDataCheck.service.IRulesService;
import lombok.AllArgsConstructor;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.tenant.annotation.NonDS;
import org.springblade.core.tool.api.R;
import org.springframework.web.bind.annotation.RestController;
import springfox.documentation.annotations.ApiIgnore;

import java.util.List;

/**
 * @PROJECT_NAME: skjcmanager
 * @DESCRIPTION:
 * @USER: aix
 * @DATE: 2023/7/4 16:35
 */
@NonDS
@ApiIgnore
@RestController
@AllArgsConstructor
public class RulesClient implements IRulesClient {

    private IRulesService rulesService;

    private IRulesConditionService rulesConditionService;

    @Override
    public R createDataRules(Long id) {
        // 获取规则对象  返回值有关联水库，只匹配关联水库，为空表示匹配所有水库
        Rules rules = rulesService.getById(id);

        // 根据规则对象获取查询条件
        RulesCondition rulesCondition = new RulesCondition();
        rulesCondition.setRuleId(String.valueOf(rules.getId()));
        List<RulesCondition> rcList = rulesConditionService.list(Condition.getQueryWrapper(rulesCondition));

        // 开始拼接条件 where

        // 判断规则操作数据表
        if (rules.getType().equals("BASIC")) { // 水库基本类型

        }

        // 执行sql
        return null;
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/DataRulesXxlJob.java

@@ -24,7 +24,7 @@
    @XxlJob("dataRulesJobHandler")
    public ReturnT<String> execute(String param) {
        XxlJobLogger.log("开始数据校验规则任务...");
        R r = rulesClient.createDataRules();
        R r = rulesClient.createDataRules(1L);
        XxlJobLogger.log("结束数据校验规则任务...",r.getMsg());
        return ReturnT.SUCCESS;
    }