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;
|
}
|
}
|
