数据校验规则准备

xieb

2023-07-03 c94885d4e04fffc973678ca068bc2e1fbc97823f

数据校验规则准备

 skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/resDataCheck/entity/Rules.java

 skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/resDataCheck/entity/RulesCondition.java

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

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

import org.springblade.core.tool.api.R;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;

/**
 * @PROJECT_NAME: skjcmanager
 * @DESCRIPTION:
 * @USER: aix
 * @DATE: 2023/7/3 19:03
 */
@FeignClient(
    value = "blade-sm",
    fallback = RulesClientClientFallback.class
)
public interface IRulesClient {

    String API_PREFIX = "/client";
    String CREATE_DATA_RULES = API_PREFIX + "/createDataRules";

    @GetMapping(CREATE_DATA_RULES)
    R createDataRules();

}

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

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

import org.springblade.core.tool.api.R;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;

/**
 * @PROJECT_NAME: skjcmanager
 * @DESCRIPTION:
 * @USER: aix
 * @DATE: 2023/7/3 19:04
 */
@Component
public class RulesClientClientFallback implements IRulesClient{

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

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/resDataCheck/controller/ConditionController.java

@@ -2,8 +2,6 @@

import cn.gistack.sm.resDataCheck.entity.RulesCondition;
import cn.gistack.sm.resDataCheck.service.IRulesConditionService;
import cn.gistack.sm.resDataCheck.service.IRulesService;
import cn.gistack.sm.resDataCheck.vo.RulesVO;
import com.baomidou.mybatisplus.core.metadata.IPage;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/resDataCheck/controller/RulesController.java

@@ -1,9 +1,6 @@
package cn.gistack.sm.resDataCheck.controller;

import cn.gistack.sm.patrol.entity.PatrolConfig;
import cn.gistack.sm.patrol.service.IPatrolConfigService;
import cn.gistack.sm.resDataCheck.entity.Rules;
import cn.gistack.sm.resDataCheck.entity.RulesCondition;
import cn.gistack.sm.resDataCheck.service.IRulesService;
import cn.gistack.sm.resDataCheck.vo.RulesVO;
import com.baomidou.mybatisplus.core.metadata.IPage;

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/resDataCheck/mapper/RulesConditionMapper.java

@@ -1,8 +1,6 @@
package cn.gistack.sm.resDataCheck.mapper;

import cn.gistack.sm.resDataCheck.entity.Rules;
import cn.gistack.sm.resDataCheck.entity.RulesCondition;
import cn.gistack.sm.resDataCheck.vo.RulesVO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;


 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/resDataCheck/mapper/RulesMapper.java

@@ -1,6 +1,5 @@
package cn.gistack.sm.resDataCheck.mapper;

import cn.gistack.sm.patrol.entity.PatrolConfig;
import cn.gistack.sm.resDataCheck.entity.Rules;
import cn.gistack.sm.resDataCheck.vo.RulesVO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;

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

@@ -1,8 +1,6 @@
package cn.gistack.sm.resDataCheck.service;

import cn.gistack.sm.resDataCheck.entity.Rules;
import cn.gistack.sm.resDataCheck.entity.RulesCondition;
import cn.gistack.sm.resDataCheck.vo.RulesVO;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springblade.core.mp.base.BaseService;


 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/resDataCheck/service/impl/RulesConditionServiceImpl.java

@@ -1,12 +1,8 @@
package cn.gistack.sm.resDataCheck.service.impl;

import cn.gistack.sm.resDataCheck.entity.Rules;
import cn.gistack.sm.resDataCheck.entity.RulesCondition;
import cn.gistack.sm.resDataCheck.mapper.RulesConditionMapper;
import cn.gistack.sm.resDataCheck.mapper.RulesMapper;
import cn.gistack.sm.resDataCheck.service.IRulesConditionService;
import cn.gistack.sm.resDataCheck.service.IRulesService;
import cn.gistack.sm.resDataCheck.vo.RulesVO;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springframework.stereotype.Service;

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

New file
@@ -0,0 +1,32 @@
package cn.gistack.job.executor.jobhandler;

import cn.gistack.sm.resDataCheck.feign.IRulesClient;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
import org.springblade.core.tool.api.R;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @PROJECT_NAME: skjcmanager
 * @DESCRIPTION: 数据校验规则相关
 * @USER: aix
 * @DATE: 2023/7/3 17:58
 */
@Component
public class DataRulesXxlJob {

    @Autowired
    private IRulesClient rulesClient;


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

}