Merge branch 'zhaojianwei' into 'master'

add rule analysis、insert、struct codes

See merge request zhaojianwei/DQMP!1

pom.xml

@@ -40,6 +40,10 @@
 			<artifactId>spring-boot-starter-test</artifactId>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-validation</artifactId>
+		</dependency>
 		<!-- 集成mysql驱动 -->
 		<dependency>
 			<groupId>mysql</groupId>
@@ -216,7 +220,7 @@
 				</executions>
 			</plugin>
 			<!--集成mybatis自动生成工具 -->
-			<!-- <plugin>
+			<plugin>
 				<groupId>org.mybatis.generator</groupId>
 				<artifactId>mybatis-generator-maven-plugin</artifactId>
 				<version>1.3.2</version>
@@ -240,7 +244,7 @@
 						<version>1.3.2</version>
 					</dependency>
 				</dependencies>
-			</plugin> -->
+			</plugin>
 		</plugins>
 	</build>
 </project>
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/common/Constants.java

@@ -9,6 +9,10 @@ public class Constants {
 	public static final String CHECK_UNBLANK = "unblank_check";
 	// 参照性校验
 	public static final String CHECK_REFER = "refer_check";
+	// 波动性校验
+	public static final String CHECK_VOLATILITY = "volatility_check";
+	// 特殊性校验
+	public static final String CHECK_SPECIAL = "special_check";
 
 	// ***************监控指标类型******************
 	// 波动性监控-PV
@@ -22,4 +26,19 @@ public class Constants {
 	// 无效
 	public static final Integer IS_VALID_OFF = 0;
 
+	// ***************校验规则映射******************
+	// 校验规则映射
+	public static final String CHECK_RULE_MAPPING = "check_rule_mapping";
+
+	// ***************规则类型映射******************
+	// 单表规则类型
+	public static final String TABLE_SIMPLE = "simple";
+	// 双表规则类型
+	public static final String TABLE_DUPLEX = "duplex";
+
+//	public static final String CHECK_SIMPLE = "check_single";
+//	public static final String CHECK_MULTIPLE = "check_multiple";
+//	public static final String MONITOR_VOLATILITY = "monitor_volatility";
+//	public static final String MONITOR_SPECIAL = "monitor_special";
+
 }

src/main/java/com/gmei/data/dqmp/controller/DqRuleController.java

+package com.gmei.data.dqmp.controller;
+
+import javax.validation.Valid;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.gmei.data.dqmp.service.DqRuleService;
+import com.gmei.data.dqmp.vo.DqRuleVo;
+
+@RestController
+@RequestMapping(value = "/dqrule")
+public class DqRuleController {
+
+	@Autowired
+	private DqRuleService dqRuleService;
+	
+	/**
+	 * 校验规则新增
+	 * @param dqRuleVo
+	 * @param bindingResult
+	 * @return
+	 */
+	@ResponseBody
+    @RequestMapping(value = "/add", method = RequestMethod.POST)
+    public DqRuleVo addDqRule(@RequestBody @Valid DqRuleVo dqRuleVo,BindingResult bindingResult) {
+		if (bindingResult.hasErrors()) {
+            return new DqRuleVo(-1,bindingResult.getFieldError().getDefaultMessage());
+        }
+		Boolean isAddSuc = dqRuleService.addDqRule(dqRuleVo);
+		if(isAddSuc) {
+			return new DqRuleVo();
+		}else {
+			return new DqRuleVo(-1,"Rule add error!");
+		}
+    }
+}

src/main/java/com/gmei/data/dqmp/controller/RuleTemplateController.java

@@ -23,7 +23,7 @@ public class RuleTemplateController {
 	@ResponseBody
     @RequestMapping(value = "/find", method = RequestMethod.POST)
     public RuleTemplateVo findRuleTmpls(@RequestBody RuleTemplateVo ruleTemplateVo) {
-    	List<RuleTemplateDto> findRuleTmpls = ruleTemplateService.findRuleTmpls(ruleTemplateVo.getType());
+    	List<RuleTemplateDto> findRuleTmpls = ruleTemplateService.findRuleTmpls(ruleTemplateVo.getCheckType());
         return new RuleTemplateVo(findRuleTmpls);
     }
 	

src/main/java/com/gmei/data/dqmp/domain/TblIndicatorOperatorInfo.java

+package com.gmei.data.dqmp.domain;
+
+public class TblIndicatorOperatorInfo {
+    private Integer id;
+
+    private String indicatorName;
+
+    private String operatorExpr;
+
+    private String comment;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getIndicatorName() {
+        return indicatorName;
+    }
+
+    public void setIndicatorName(String indicatorName) {
+        this.indicatorName = indicatorName == null ? null : indicatorName.trim();
+    }
+
+    public String getOperatorExpr() {
+        return operatorExpr;
+    }
+
+    public void setOperatorExpr(String operatorExpr) {
+        this.operatorExpr = operatorExpr == null ? null : operatorExpr.trim();
+    }
+
+    public String getComment() {
+        return comment;
+    }
+
+    public void setComment(String comment) {
+        this.comment = comment == null ? null : comment.trim();
+    }
+}
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/domain/TblRuleDuplexInfo.java

+package com.gmei.data.dqmp.domain;
+
+public class TblRuleDuplexInfo {
+    private Integer id;
+
+    private String checkType;
+
+    private String checkDbName;
+
+    private String checkTbName;
+
+    private String checkColName;
+
+    private String referDbName;
+
+    private String referTbName;
+
+    private String referColName;
+
+    private Integer isPartitioned;
+
+    private Integer isValid;
+
+    private String checkTime;
+
+    private String createTime;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getCheckType() {
+        return checkType;
+    }
+
+    public void setCheckType(String checkType) {
+        this.checkType = checkType == null ? null : checkType.trim();
+    }
+
+    public String getCheckDbName() {
+        return checkDbName;
+    }
+
+    public void setCheckDbName(String checkDbName) {
+        this.checkDbName = checkDbName == null ? null : checkDbName.trim();
+    }
+
+    public String getCheckTbName() {
+        return checkTbName;
+    }
+
+    public void setCheckTbName(String checkTbName) {
+        this.checkTbName = checkTbName == null ? null : checkTbName.trim();
+    }
+
+    public String getCheckColName() {
+        return checkColName;
+    }
+
+    public void setCheckColName(String checkColName) {
+        this.checkColName = checkColName == null ? null : checkColName.trim();
+    }
+
+    public String getReferDbName() {
+        return referDbName;
+    }
+
+    public void setReferDbName(String referDbName) {
+        this.referDbName = referDbName == null ? null : referDbName.trim();
+    }
+
+    public String getReferTbName() {
+        return referTbName;
+    }
+
+    public void setReferTbName(String referTbName) {
+        this.referTbName = referTbName == null ? null : referTbName.trim();
+    }
+
+    public String getReferColName() {
+        return referColName;
+    }
+
+    public void setReferColName(String referColName) {
+        this.referColName = referColName == null ? null : referColName.trim();
+    }
+
+    public Integer getIsPartitioned() {
+        return isPartitioned;
+    }
+
+    public void setIsPartitioned(Integer isPartitioned) {
+        this.isPartitioned = isPartitioned;
+    }
+
+    public Integer getIsValid() {
+        return isValid;
+    }
+
+    public void setIsValid(Integer isValid) {
+        this.isValid = isValid;
+    }
+
+    public String getCheckTime() {
+        return checkTime;
+    }
+
+    public void setCheckTime(String checkTime) {
+        this.checkTime = checkTime == null ? null : checkTime.trim();
+    }
+
+    public String getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(String createTime) {
+        this.createTime = createTime == null ? null : createTime.trim();
+    }
+}
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/domain/TblRuleDuplexInfoWithBLOBs.java

+package com.gmei.data.dqmp.domain;
+
+public class TblRuleDuplexInfoWithBLOBs extends TblRuleDuplexInfo {
+    private String checkFilters;
+
+    private String referFilters;
+
+    public String getCheckFilters() {
+        return checkFilters;
+    }
+
+    public void setCheckFilters(String checkFilters) {
+        this.checkFilters = checkFilters == null ? null : checkFilters.trim();
+    }
+
+    public String getReferFilters() {
+        return referFilters;
+    }
+
+    public void setReferFilters(String referFilters) {
+        this.referFilters = referFilters == null ? null : referFilters.trim();
+    }
+}
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/domain/TblRuleSimpleInfo.java

+package com.gmei.data.dqmp.domain;
+
+public class TblRuleSimpleInfo {
+    private Integer id;
+
+    private String checkType;
+
+    private String dbName;
+
+    private String tbName;
+
+    private String colName;
+
+    private String indicatorType;
+
+    private String startTime;
+
+    private String endTime;
+
+    private Integer isPartitioned;
+
+    private Integer isValid;
+
+    private String checkTime;
+
+    private String createTime;
+
+    private String filters;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getCheckType() {
+        return checkType;
+    }
+
+    public void setCheckType(String checkType) {
+        this.checkType = checkType == null ? null : checkType.trim();
+    }
+
+    public String getDbName() {
+        return dbName;
+    }
+
+    public void setDbName(String dbName) {
+        this.dbName = dbName == null ? null : dbName.trim();
+    }
+
+    public String getTbName() {
+        return tbName;
+    }
+
+    public void setTbName(String tbName) {
+        this.tbName = tbName == null ? null : tbName.trim();
+    }
+
+    public String getColName() {
+        return colName;
+    }
+
+    public void setColName(String colName) {
+        this.colName = colName == null ? null : colName.trim();
+    }
+
+    public String getIndicatorType() {
+        return indicatorType;
+    }
+
+    public void setIndicatorType(String indicatorType) {
+        this.indicatorType = indicatorType == null ? null : indicatorType.trim();
+    }
+
+    public String getStartTime() {
+        return startTime;
+    }
+
+    public void setStartTime(String startTime) {
+        this.startTime = startTime == null ? null : startTime.trim();
+    }
+
+    public String getEndTime() {
+        return endTime;
+    }
+
+    public void setEndTime(String endTime) {
+        this.endTime = endTime == null ? null : endTime.trim();
+    }
+
+    public Integer getIsPartitioned() {
+        return isPartitioned;
+    }
+
+    public void setIsPartitioned(Integer isPartitioned) {
+        this.isPartitioned = isPartitioned;
+    }
+
+    public Integer getIsValid() {
+        return isValid;
+    }
+
+    public void setIsValid(Integer isValid) {
+        this.isValid = isValid;
+    }
+
+    public String getCheckTime() {
+        return checkTime;
+    }
+
+    public void setCheckTime(String checkTime) {
+        this.checkTime = checkTime == null ? null : checkTime.trim();
+    }
+
+    public String getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(String createTime) {
+        this.createTime = createTime == null ? null : createTime.trim();
+    }
+
+    public String getFilters() {
+        return filters;
+    }
+
+    public void setFilters(String filters) {
+        this.filters = filters == null ? null : filters.trim();
+    }
+}
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/domain/TblRuleTemplate.java

@@ -3,12 +3,12 @@ package com.gmei.data.dqmp.domain;
 public class TblRuleTemplate {
     private Integer id;
 
-    private String type;
-
-    private String content;
+    private String checkType;
 
     private String comment;
 
+    private String tpltContent;
+
     public Integer getId() {
         return id;
     }
@@ -17,20 +17,12 @@ public class TblRuleTemplate {
         this.id = id;
     }
 
-    public String getType() {
-        return type;
-    }
-
-    public void setType(String type) {
-        this.type = type == null ? null : type.trim();
-    }
-
-    public String getContent() {
-        return content;
+    public String getCheckType() {
+        return checkType;
     }
 
-    public void setContent(String content) {
-        this.content = content == null ? null : content.trim();
+    public void setCheckType(String checkType) {
+        this.checkType = checkType == null ? null : checkType.trim();
     }
 
     public String getComment() {
@@ -40,4 +32,12 @@ public class TblRuleTemplate {
     public void setComment(String comment) {
         this.comment = comment == null ? null : comment.trim();
     }
+
+    public String getTpltContent() {
+        return tpltContent;
+    }
+
+    public void setTpltContent(String tpltContent) {
+        this.tpltContent = tpltContent == null ? null : tpltContent.trim();
+    }
 }
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/domain/TblRuleTemplateCriteria.java

@@ -164,143 +164,73 @@ public class TblRuleTemplateCriteria {
             return (Criteria) this;
         }
 
-        public Criteria andTypeIsNull() {
-            addCriterion("type is null");
+        public Criteria andCheckTypeIsNull() {
+            addCriterion("check_type is null");
             return (Criteria) this;
         }
 
-        public Criteria andTypeIsNotNull() {
-            addCriterion("type is not null");
+        public Criteria andCheckTypeIsNotNull() {
+            addCriterion("check_type is not null");
             return (Criteria) this;
         }
 
-        public Criteria andTypeEqualTo(String value) {
-            addCriterion("type =", value, "type");
+        public Criteria andCheckTypeEqualTo(String value) {
+            addCriterion("check_type =", value, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeNotEqualTo(String value) {
-            addCriterion("type <>", value, "type");
+        public Criteria andCheckTypeNotEqualTo(String value) {
+            addCriterion("check_type <>", value, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeGreaterThan(String value) {
-            addCriterion("type >", value, "type");
+        public Criteria andCheckTypeGreaterThan(String value) {
+            addCriterion("check_type >", value, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeGreaterThanOrEqualTo(String value) {
-            addCriterion("type >=", value, "type");
+        public Criteria andCheckTypeGreaterThanOrEqualTo(String value) {
+            addCriterion("check_type >=", value, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeLessThan(String value) {
-            addCriterion("type <", value, "type");
+        public Criteria andCheckTypeLessThan(String value) {
+            addCriterion("check_type <", value, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeLessThanOrEqualTo(String value) {
-            addCriterion("type <=", value, "type");
+        public Criteria andCheckTypeLessThanOrEqualTo(String value) {
+            addCriterion("check_type <=", value, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeLike(String value) {
-            addCriterion("type like", value, "type");
+        public Criteria andCheckTypeLike(String value) {
+            addCriterion("check_type like", value, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeNotLike(String value) {
-            addCriterion("type not like", value, "type");
+        public Criteria andCheckTypeNotLike(String value) {
+            addCriterion("check_type not like", value, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeIn(List<String> values) {
-            addCriterion("type in", values, "type");
+        public Criteria andCheckTypeIn(List<String> values) {
+            addCriterion("check_type in", values, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeNotIn(List<String> values) {
-            addCriterion("type not in", values, "type");
+        public Criteria andCheckTypeNotIn(List<String> values) {
+            addCriterion("check_type not in", values, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeBetween(String value1, String value2) {
-            addCriterion("type between", value1, value2, "type");
+        public Criteria andCheckTypeBetween(String value1, String value2) {
+            addCriterion("check_type between", value1, value2, "checkType");
             return (Criteria) this;
         }
 
-        public Criteria andTypeNotBetween(String value1, String value2) {
-            addCriterion("type not between", value1, value2, "type");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentIsNull() {
-            addCriterion("content is null");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentIsNotNull() {
-            addCriterion("content is not null");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentEqualTo(String value) {
-            addCriterion("content =", value, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentNotEqualTo(String value) {
-            addCriterion("content <>", value, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentGreaterThan(String value) {
-            addCriterion("content >", value, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentGreaterThanOrEqualTo(String value) {
-            addCriterion("content >=", value, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentLessThan(String value) {
-            addCriterion("content <", value, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentLessThanOrEqualTo(String value) {
-            addCriterion("content <=", value, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentLike(String value) {
-            addCriterion("content like", value, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentNotLike(String value) {
-            addCriterion("content not like", value, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentIn(List<String> values) {
-            addCriterion("content in", values, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentNotIn(List<String> values) {
-            addCriterion("content not in", values, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentBetween(String value1, String value2) {
-            addCriterion("content between", value1, value2, "content");
-            return (Criteria) this;
-        }
-
-        public Criteria andContentNotBetween(String value1, String value2) {
-            addCriterion("content not between", value1, value2, "content");
+        public Criteria andCheckTypeNotBetween(String value1, String value2) {
+            addCriterion("check_type not between", value1, value2, "checkType");
             return (Criteria) this;
         }
 

src/main/java/com/gmei/data/dqmp/domain/TblSysParamInfo.java

+package com.gmei.data.dqmp.domain;
+
+public class TblSysParamInfo {
+    private Integer id;
+
+    private String paramType;
+
+    private String paramKey;
+
+    private String paramValue;
+
+    private String comment;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getParamType() {
+        return paramType;
+    }
+
+    public void setParamType(String paramType) {
+        this.paramType = paramType == null ? null : paramType.trim();
+    }
+
+    public String getParamKey() {
+        return paramKey;
+    }
+
+    public void setParamKey(String paramKey) {
+        this.paramKey = paramKey == null ? null : paramKey.trim();
+    }
+
+    public String getParamValue() {
+        return paramValue;
+    }
+
+    public void setParamValue(String paramValue) {
+        this.paramValue = paramValue == null ? null : paramValue.trim();
+    }
+
+    public String getComment() {
+        return comment;
+    }
+
+    public void setComment(String comment) {
+        this.comment = comment == null ? null : comment.trim();
+    }
+}
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/dto/RuleTemplateDto.java

@@ -4,9 +4,9 @@ public class RuleTemplateDto {
 	
 	private Integer id;
 
-    private String type;
+    private String checkType;
 
-    private String content;
+    private String tpltContent;
 
     private String comment;
 
@@ -18,27 +18,28 @@ public class RuleTemplateDto {
         this.id = id;
     }
 
-    public String getType() {
-        return type;
-    }
+	public String getCheckType() {
+		return checkType;
+	}
 
-    public void setType(String type) {
-        this.type = type == null ? null : type.trim();
-    }
+	public void setCheckType(String checkType) {
+		this.checkType = checkType;
+	}
 
-    public String getContent() {
-        return content;
-    }
+	public String getTpltContent() {
+		return tpltContent;
+	}
 
-    public void setContent(String content) {
-        this.content = content == null ? null : content.trim();
-    }
+	public void setTpltContent(String tpltContent) {
+		this.tpltContent = tpltContent;
+	}
 
-    public String getComment() {
-        return comment;
-    }
+	public String getComment() {
+		return comment;
+	}
+
+	public void setComment(String comment) {
+		this.comment = comment;
+	}
 
-    public void setComment(String comment) {
-        this.comment = comment == null ? null : comment.trim();
-    }
 }

src/main/java/com/gmei/data/dqmp/mapper/TblIndicatorOperatorInfoMapper.java

+package com.gmei.data.dqmp.mapper;
+
+import com.gmei.data.dqmp.domain.TblIndicatorOperatorInfo;
+import com.gmei.data.dqmp.domain.TblIndicatorOperatorInfoCriteria;
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+
+public interface TblIndicatorOperatorInfoMapper {
+    int countByExample(TblIndicatorOperatorInfoCriteria example);
+
+    int deleteByExample(TblIndicatorOperatorInfoCriteria example);
+
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(TblIndicatorOperatorInfo record);
+
+    int insertSelective(TblIndicatorOperatorInfo record);
+
+    List<TblIndicatorOperatorInfo> selectByExample(TblIndicatorOperatorInfoCriteria example);
+
+    TblIndicatorOperatorInfo selectByPrimaryKey(Integer id);
+
+    int updateByExampleSelective(@Param("record") TblIndicatorOperatorInfo record, @Param("example") TblIndicatorOperatorInfoCriteria example);
+
+    int updateByExample(@Param("record") TblIndicatorOperatorInfo record, @Param("example") TblIndicatorOperatorInfoCriteria example);
+
+    int updateByPrimaryKeySelective(TblIndicatorOperatorInfo record);
+
+    int updateByPrimaryKey(TblIndicatorOperatorInfo record);
+}
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/mapper/TblRuleDuplexInfoMapper.java

+package com.gmei.data.dqmp.mapper;
+
+import com.gmei.data.dqmp.domain.TblRuleDuplexInfo;
+import com.gmei.data.dqmp.domain.TblRuleDuplexInfoCriteria;
+import com.gmei.data.dqmp.domain.TblRuleDuplexInfoWithBLOBs;
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+
+public interface TblRuleDuplexInfoMapper {
+    int countByExample(TblRuleDuplexInfoCriteria example);
+
+    int deleteByExample(TblRuleDuplexInfoCriteria example);
+
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(TblRuleDuplexInfoWithBLOBs record);
+
+    int insertSelective(TblRuleDuplexInfoWithBLOBs record);
+
+    List<TblRuleDuplexInfoWithBLOBs> selectByExampleWithBLOBs(TblRuleDuplexInfoCriteria example);
+
+    List<TblRuleDuplexInfo> selectByExample(TblRuleDuplexInfoCriteria example);
+
+    TblRuleDuplexInfoWithBLOBs selectByPrimaryKey(Integer id);
+
+    int updateByExampleSelective(@Param("record") TblRuleDuplexInfoWithBLOBs record, @Param("example") TblRuleDuplexInfoCriteria example);
+
+    int updateByExampleWithBLOBs(@Param("record") TblRuleDuplexInfoWithBLOBs record, @Param("example") TblRuleDuplexInfoCriteria example);
+
+    int updateByExample(@Param("record") TblRuleDuplexInfo record, @Param("example") TblRuleDuplexInfoCriteria example);
+
+    int updateByPrimaryKeySelective(TblRuleDuplexInfoWithBLOBs record);
+
+    int updateByPrimaryKeyWithBLOBs(TblRuleDuplexInfoWithBLOBs record);
+
+    int updateByPrimaryKey(TblRuleDuplexInfo record);
+}
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/mapper/TblRuleSimpleInfoMapper.java

+package com.gmei.data.dqmp.mapper;
+
+import com.gmei.data.dqmp.domain.TblRuleSimpleInfo;
+import com.gmei.data.dqmp.domain.TblRuleSimpleInfoCriteria;
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+
+public interface TblRuleSimpleInfoMapper {
+    int countByExample(TblRuleSimpleInfoCriteria example);
+
+    int deleteByExample(TblRuleSimpleInfoCriteria example);
+
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(TblRuleSimpleInfo record);
+
+    int insertSelective(TblRuleSimpleInfo record);
+
+    List<TblRuleSimpleInfo> selectByExampleWithBLOBs(TblRuleSimpleInfoCriteria example);
+
+    List<TblRuleSimpleInfo> selectByExample(TblRuleSimpleInfoCriteria example);
+
+    TblRuleSimpleInfo selectByPrimaryKey(Integer id);
+
+    int updateByExampleSelective(@Param("record") TblRuleSimpleInfo record, @Param("example") TblRuleSimpleInfoCriteria example);
+
+    int updateByExampleWithBLOBs(@Param("record") TblRuleSimpleInfo record, @Param("example") TblRuleSimpleInfoCriteria example);
+
+    int updateByExample(@Param("record") TblRuleSimpleInfo record, @Param("example") TblRuleSimpleInfoCriteria example);
+
+    int updateByPrimaryKeySelective(TblRuleSimpleInfo record);
+
+    int updateByPrimaryKeyWithBLOBs(TblRuleSimpleInfo record);
+
+    int updateByPrimaryKey(TblRuleSimpleInfo record);
+}
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/mapper/TblRuleTemplateMapper.java

@@ -16,15 +16,21 @@ public interface TblRuleTemplateMapper {
 
     int insertSelective(TblRuleTemplate record);
 
+    List<TblRuleTemplate> selectByExampleWithBLOBs(TblRuleTemplateCriteria example);
+
     List<TblRuleTemplate> selectByExample(TblRuleTemplateCriteria example);
 
     TblRuleTemplate selectByPrimaryKey(Integer id);
 
     int updateByExampleSelective(@Param("record") TblRuleTemplate record, @Param("example") TblRuleTemplateCriteria example);
 
+    int updateByExampleWithBLOBs(@Param("record") TblRuleTemplate record, @Param("example") TblRuleTemplateCriteria example);
+
     int updateByExample(@Param("record") TblRuleTemplate record, @Param("example") TblRuleTemplateCriteria example);
 
     int updateByPrimaryKeySelective(TblRuleTemplate record);
 
+    int updateByPrimaryKeyWithBLOBs(TblRuleTemplate record);
+
     int updateByPrimaryKey(TblRuleTemplate record);
 }
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/mapper/TblSysParamInfoMapper.java

+package com.gmei.data.dqmp.mapper;
+
+import com.gmei.data.dqmp.domain.TblSysParamInfo;
+import com.gmei.data.dqmp.domain.TblSysParamInfoCriteria;
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+
+public interface TblSysParamInfoMapper {
+    int countByExample(TblSysParamInfoCriteria example);
+
+    int deleteByExample(TblSysParamInfoCriteria example);
+
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(TblSysParamInfo record);
+
+    int insertSelective(TblSysParamInfo record);
+
+    List<TblSysParamInfo> selectByExample(TblSysParamInfoCriteria example);
+
+    TblSysParamInfo selectByPrimaryKey(Integer id);
+
+    int updateByExampleSelective(@Param("record") TblSysParamInfo record, @Param("example") TblSysParamInfoCriteria example);
+
+    int updateByExample(@Param("record") TblSysParamInfo record, @Param("example") TblSysParamInfoCriteria example);
+
+    int updateByPrimaryKeySelective(TblSysParamInfo record);
+
+    int updateByPrimaryKey(TblSysParamInfo record);
+}
\ No newline at end of file

src/main/java/com/gmei/data/dqmp/scheduler/DqScheduler.java

@@ -16,28 +16,28 @@ public class DqScheduler {
 	@Autowired
 	private MonitorService monitorService;
 	
-    @Scheduled(cron="0 */100 * * * ?")
-    private void uniqueCheckProcess(){
-    	executeService.checkAndPersistSimpleResult(Constants.CHECK_UNIQUE);
-    }
-    
-    @Scheduled(cron="10 */100 * * * ?")
-    private void unblankCheckProcess(){
-    	executeService.checkAndPersistSimpleResult(Constants.CHECK_UNBLANK);
-    }
-    
-    @Scheduled(cron="0 */100 * * * ?")
-    private void referCheckProcess(){
-    	executeService.checkAndPersistMultipleResult(Constants.CHECK_REFER);
-    }
-    
-    @Scheduled(cron="0 */100 * * * ?")
-    private void volatilityMonitorProcess(){
-    	monitorService.monitorAndPersistVolatilityResult(Constants.MONITOR_PV);
-    }
-    
-    @Scheduled(cron="0 */1 * * * ?")
-    private void specialMonitorProcess(){
-    	monitorService.monitorAndPersistSpecialResult();
-    }
+//    @Scheduled(cron="0 */100 * * * ?")
+//    private void uniqueCheckProcess(){
+//    	executeService.checkAndPersistSimpleResult(Constants.CHECK_UNIQUE);
+//    }
+//    
+//    @Scheduled(cron="10 */100 * * * ?")
+//    private void unblankCheckProcess(){
+//    	executeService.checkAndPersistSimpleResult(Constants.CHECK_UNBLANK);
+//    }
+//    
+//    @Scheduled(cron="0 */100 * * * ?")
+//    private void referCheckProcess(){
+//    	executeService.checkAndPersistMultipleResult(Constants.CHECK_REFER);
+//    }
+//    
+//    @Scheduled(cron="0 */100 * * * ?")
+//    private void volatilityMonitorProcess(){
+//    	monitorService.monitorAndPersistVolatilityResult(Constants.MONITOR_PV);
+//    }
+//    
+//    @Scheduled(cron="0 */100 * * * ?")
+//    private void specialMonitorProcess(){
+//    	monitorService.monitorAndPersistSpecialResult();
+//    }
 }

src/main/java/com/gmei/data/dqmp/service/DqRuleService.java

+package com.gmei.data.dqmp.service;
+
+import com.gmei.data.dqmp.vo.DqRuleVo;
+
+public interface DqRuleService {
+
+	Boolean addDqRule(DqRuleVo dqRuleVo);
+
+}

src/main/java/com/gmei/data/dqmp/service/RuleTemplateService.java

@@ -7,7 +7,7 @@ import com.gmei.data.dqmp.vo.RuleTemplateVo;
 
 public interface RuleTemplateService {
 
-	List<RuleTemplateDto> findRuleTmpls(String tmplType);
+	List<RuleTemplateDto> findRuleTmpls(String checkType);
 
 	Integer addRuleTmpl(RuleTemplateVo ruleTemplateVo);
 

src/main/java/com/gmei/data/dqmp/service/TblSysParamInfoService.java

+package com.gmei.data.dqmp.service;
+
+import java.util.Map;
+
+public interface TblSysParamInfoService {
+
+	Map<String,String> getSysParamMap(String paramType);
+
+}

src/main/java/com/gmei/data/dqmp/service/impl/CheckServiceImpl.java

@@ -26,6 +26,7 @@ import com.gmei.data.dqmp.mapper.TblResultCheckUnblankMapper;
 import com.gmei.data.dqmp.mapper.TblResultCheckUniqueMapper;
 import com.gmei.data.dqmp.pool.JdbcConnectPool;
 import com.gmei.data.dqmp.service.CheckService;
+import com.gmei.data.dqmp.utils.DateUtils;
 
 @Service
 public class CheckServiceImpl implements CheckService {
@@ -116,6 +117,7 @@ public class CheckServiceImpl implements CheckService {
 	 * @return
 	 */
 	private TblResultCheckUnique getUniqueCheckResult(String sql) {
+		sql = sql.replaceAll("#partation_date", String.format("'%s'", DateUtils.getYesterdayDateStr()));
 		logger.info("Sql content : {}", sql);
 		TblResultCheckUnique tblResultCheckUnique = null;
 		if (StringUtils.isBlank(sql)) {
@@ -151,6 +153,7 @@ public class CheckServiceImpl implements CheckService {
 	 * @return
 	 */
 	private TblResultCheckUnblank getUnblankCheckResult(String sql) {
+		sql = sql.replaceAll("#partation_date", String.format("'%s'", DateUtils.getYesterdayDateStr()));
 		logger.info("Sql content : {}", sql);
 		TblResultCheckUnblank tblResultCheckUnblank = null;
 		if (StringUtils.isBlank(sql)) {
@@ -186,6 +189,7 @@ public class CheckServiceImpl implements CheckService {
 	 * @return
 	 */
 	private TblResultCheckRefer getReferCheckResult(String sql) {
+		sql = sql.replaceAll("#partation_date", String.format("'%s'", DateUtils.getYesterdayDateStr()));
 		logger.info("Sql content : {}", sql);
 		TblResultCheckRefer tblResultCheckRefer = null;
 		if (StringUtils.isBlank(sql)) {
@@ -217,4 +221,7 @@ public class CheckServiceImpl implements CheckService {
 		}
 		return tblResultCheckRefer;
 	}
+	
+	public static void main(String[] args) {
+	}
 }

src/main/java/com/gmei/data/dqmp/service/impl/DqRuleServiceImpl.java

+package com.gmei.data.dqmp.service.impl;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.gmei.data.dqmp.common.Constants;
+import com.gmei.data.dqmp.domain.TblCheckMultipleSql;
+import com.gmei.data.dqmp.domain.TblCheckSingleSql;
+import com.gmei.data.dqmp.domain.TblIndicatorOperatorInfo;
+import com.gmei.data.dqmp.domain.TblIndicatorOperatorInfoCriteria;
+import com.gmei.data.dqmp.domain.TblMonitorSpecialSql;
+import com.gmei.data.dqmp.domain.TblMonitorVolatilitySql;
+import com.gmei.data.dqmp.domain.TblRuleDuplexInfoWithBLOBs;
+import com.gmei.data.dqmp.domain.TblRuleSimpleInfo;
+import com.gmei.data.dqmp.domain.TblRuleTemplate;
+import com.gmei.data.dqmp.domain.TblRuleTemplateCriteria;
+import com.gmei.data.dqmp.mapper.TblCheckMultipleSqlMapper;
+import com.gmei.data.dqmp.mapper.TblCheckSingleSqlMapper;
+import com.gmei.data.dqmp.mapper.TblIndicatorOperatorInfoMapper;
+import com.gmei.data.dqmp.mapper.TblMonitorSpecialSqlMapper;
+import com.gmei.data.dqmp.mapper.TblMonitorVolatilitySqlMapper;
+import com.gmei.data.dqmp.mapper.TblRuleDuplexInfoMapper;
+import com.gmei.data.dqmp.mapper.TblRuleSimpleInfoMapper;
+import com.gmei.data.dqmp.mapper.TblRuleTemplateMapper;
+import com.gmei.data.dqmp.service.DqRuleService;
+import com.gmei.data.dqmp.utils.BeanUtils;
+import com.gmei.data.dqmp.utils.DateUtils;
+import com.gmei.data.dqmp.vo.DqRuleVo;
+
+@Service
+public class DqRuleServiceImpl implements DqRuleService {
+
+	@Autowired
+	private TblRuleSimpleInfoMapper tblRuleSimpleInfoMapper;
+	@Autowired
+	private TblRuleDuplexInfoMapper tblRuleDuplexInfoMapper;
+	@Autowired
+	private TblCheckSingleSqlMapper tblCheckSingleSqlMapper;
+	@Autowired
+	private TblCheckMultipleSqlMapper tblCheckMultipleSqlMapper;
+	@Autowired
+	private TblMonitorVolatilitySqlMapper tblMonitorVolatilitySqlMapper;
+	@Autowired
+	private TblMonitorSpecialSqlMapper tblMonitorSpecialSqlMapper;
+	@Autowired
+	private TblRuleTemplateMapper tblRuleTemplateMapper;
+	@Autowired
+	private TblIndicatorOperatorInfoMapper tblIndicatorOperatorInfoMapper;
+
+	private static final Logger logger = LoggerFactory.getLogger(DqRuleServiceImpl.class);
+
+	@Override
+	@Transactional
+	public Boolean addDqRule(DqRuleVo dqRuleVo) {
+		Boolean rs = false;
+		String checkType = dqRuleVo.getCheckType();
+		if (Constants.CHECK_UNIQUE.equals(checkType) || Constants.CHECK_UNBLANK.equals(checkType)
+				|| Constants.CHECK_VOLATILITY.equals(checkType) || Constants.CHECK_SPECIAL.equals(checkType)) {
+			rs = simpleRuleInfoInsert(dqRuleVo);
+		} else if (Constants.CHECK_REFER.equals(checkType)) {
+			rs = duplexRuleInfoInsert(dqRuleVo);
+		} else {
+			logger.error("checkType is illegal! {}", checkType);
+			return rs;
+		}
+		return rs;
+	}
+
+	/**
+	 * 简单校验规则新增
+	 * @param dqRuleVo
+	 * @return
+	 */
+	private Boolean simpleRuleInfoInsert(DqRuleVo dqRuleVo) {
+		if(!simpleRuleInfoCheck(dqRuleVo)) {
+			logger.error("Param is illegal! {}",dqRuleVo);
+			return false;
+		}
+		TblRuleSimpleInfo record = BeanUtils.map(dqRuleVo, TblRuleSimpleInfo.class);
+		int rs = tblRuleSimpleInfoMapper.insertSelective(record);
+		if (rs == 1) {
+			String checkType = dqRuleVo.getCheckType();
+			switch (checkType) {
+			case Constants.CHECK_UNIQUE:
+				TblCheckSingleSql tblCheckSingleSql = BeanUtils.map(dqRuleVo, TblCheckSingleSql.class);
+				tblCheckSingleSql.setSqlContent(genSqlByTemplate(dqRuleVo));
+				tblCheckSingleSqlMapper.insertSelective(tblCheckSingleSql);
+				break;
+			case Constants.CHECK_UNBLANK:
+				TblCheckSingleSql tcss = BeanUtils.map(dqRuleVo, TblCheckSingleSql.class);
+				tcss.setSqlContent(genSqlByTemplate(dqRuleVo));
+				tblCheckSingleSqlMapper.insertSelective(tcss);
+				break;
+			case Constants.CHECK_VOLATILITY:
+				if(!volatilityRuleParamsCheck(dqRuleVo)) {
+					logger.error("Param is illegal! {}",dqRuleVo);
+					return false;
+				}
+				TblMonitorVolatilitySql tblMonitorVolatilitySql = BeanUtils.map(dqRuleVo,
+						TblMonitorVolatilitySql.class);
+				tblMonitorVolatilitySql.setSqlContent(genSqlByTemplate(dqRuleVo));
+				tblMonitorVolatilitySqlMapper.insertSelective(tblMonitorVolatilitySql);
+				break;
+			case Constants.CHECK_SPECIAL:
+				if(!specialRuleParamsCheck(dqRuleVo)) {
+					logger.error("Param is illegal! {}",dqRuleVo);
+					return false;
+				}
+				TblMonitorSpecialSql tblMonitorSpecialSql = BeanUtils.map(dqRuleVo, TblMonitorSpecialSql.class);
+				tblMonitorSpecialSql.setSqlContent(genSqlByTemplate(dqRuleVo));
+				tblMonitorSpecialSqlMapper.insertSelective(tblMonitorSpecialSql);
+				break;
+			default:
+				logger.error("checkType value is error! {}", checkType);
+				return false;
+			}
+		}
+		return true;
+	}
+	
+	/**
+	 * 双表校验规则录入
+	 * @param dqRuleVo
+	 * @return
+	 */
+	private Boolean duplexRuleInfoInsert(DqRuleVo dqRuleVo) {
+		if(!duplexRuleInfoCheck(dqRuleVo)) {
+			logger.error("Param is illegal! {}",dqRuleVo);
+			return false;
+		}
+		TblRuleDuplexInfoWithBLOBs record = BeanUtils.map(dqRuleVo, TblRuleDuplexInfoWithBLOBs.class);
+		int rs = tblRuleDuplexInfoMapper.insertSelective(record);
+		if (rs == 1) {
+			String checkType = dqRuleVo.getCheckType();
+			if (Constants.CHECK_REFER.equals(checkType)) {
+				TblCheckMultipleSql tblCheckMultipleSql = BeanUtils.map(dqRuleVo, TblCheckMultipleSql.class);
+				String sqlContent = genSqlByTemplate(dqRuleVo);
+				tblCheckMultipleSql.setSqlContent(sqlContent);
+				tblCheckMultipleSqlMapper.insertSelective(tblCheckMultipleSql);
+			} else {
+				logger.error("checkType value is error! {}", checkType);
+				return false;
+			}
+		}
+		return true;
+	}
+
+	private boolean simpleRuleInfoCheck(DqRuleVo dqRuleVo) {
+		if(StringUtils.isBlank(dqRuleVo.getDbName()) || StringUtils.isBlank(dqRuleVo.getTbName()) 
+			 //|| StringUtils.isBlank(dqRuleVo.getFilters())
+			 ) {
+			return false;
+		}
+		if(Constants.CHECK_SPECIAL.equals(dqRuleVo.getCheckType())){
+			if(StringUtils.isBlank(dqRuleVo.getTimeColName())) {
+				return false;
+			}
+		}else {
+			if(StringUtils.isBlank(dqRuleVo.getColName())) {
+				return false;
+			}
+		}
+		return true;
+	}
+
+	private boolean volatilityRuleParamsCheck(DqRuleVo dqRuleVo) {
+		if(StringUtils.isBlank(dqRuleVo.getIndicatorType())) {
+			return false;
+		}
+		return true;
+	}
+	
+	private boolean specialRuleParamsCheck(DqRuleVo dqRuleVo) {
+		if(StringUtils.isBlank(dqRuleVo.getTimeColName()) || StringUtils.isBlank(dqRuleVo.getStartTime()) 
+				//|| StringUtils.isBlank(dqRuleVo.getEndTime())
+				) {
+			return false;
+		}
+		return true;
+	}
+	
+	private boolean duplexRuleInfoCheck(DqRuleVo dqRuleVo) {
+		if(StringUtils.isBlank(dqRuleVo.getCheckDbName()) || StringUtils.isBlank(dqRuleVo.getCheckTbName()) 
+				|| StringUtils.isBlank(dqRuleVo.getCheckColName()) || StringUtils.isBlank(dqRuleVo.getReferColName())
+				|| StringUtils.isBlank(dqRuleVo.getReferDbName()) || StringUtils.isBlank(dqRuleVo.getReferTbName()) 
+				//|| StringUtils.isBlank(dqRuleVo.getCheckFilters()) || StringUtils.isBlank(dqRuleVo.getReferfilters())
+				) {
+			return false;
+		}
+		return true;
+	}
+	
+	private String genSqlByTemplate(DqRuleVo dqRuleVo) {
+		TblRuleTemplateCriteria example = new TblRuleTemplateCriteria();
+		example.createCriteria().andCheckTypeEqualTo(dqRuleVo.getCheckType());
+		TblRuleTemplate tblRuleTemplate = tblRuleTemplateMapper.selectByExampleWithBLOBs(example).get(0);
+		String tpltContent = tblRuleTemplate.getTpltContent();
+		Map<String,String> indicatorMap = new HashMap<String, String>();
+		TblIndicatorOperatorInfoCriteria tblIndicatorOperatorInfoCriteria = new TblIndicatorOperatorInfoCriteria();
+		List<TblIndicatorOperatorInfo> tblIndicatorOperatorInfos = tblIndicatorOperatorInfoMapper.selectByExample(tblIndicatorOperatorInfoCriteria);
+		for(TblIndicatorOperatorInfo tblIndicatorOperatorInfo : tblIndicatorOperatorInfos) {
+			indicatorMap.put(tblIndicatorOperatorInfo.getIndicatorName(), tblIndicatorOperatorInfo.getOperatorExpr());
+		}
+		String indicatorType = dqRuleVo.getIndicatorType();
+		String rs = tpltContent
+				   .replaceAll("#db_name", dqRuleVo.getDbName())
+				   .replaceAll("#tb_name", dqRuleVo.getTbName())
+				   .replaceAll("#indicator_type", indicatorType)
+				   .replaceAll("#indicator_expre", indicatorMap.get(indicatorType))
+				   .replaceAll("#col_name", dqRuleVo.getColName())
+				   .replaceAll("#start_time", "'"+dqRuleVo.getStartTime()+"'")
+				   .replaceAll("#end_time", "'"+DateUtils.getTodayZeroTimeStr()+"'")
+				   .replaceAll("#check_db_name", dqRuleVo.getCheckDbName())
+				   .replaceAll("#check_tb_name", dqRuleVo.getCheckTbName())
+				   .replaceAll("#check_col_name", dqRuleVo.getCheckColName())
+				   .replaceAll("#refer_db_name", dqRuleVo.getReferDbName())
+				   .replaceAll("#refer_tb_name", dqRuleVo.getReferTbName())
+				   .replaceAll("#refer_col_name", dqRuleVo.getReferColName())
+				   .replaceAll("#time_col_name", dqRuleVo.getTimeColName());
+		if(null != dqRuleVo.getFilters()) {
+			rs = rs.replaceAll("#filters", dqRuleVo.getFilters());
+		}
+		if(null != dqRuleVo.getCheckFilters()) {
+			rs = rs.replaceAll("#check_filters", dqRuleVo.getCheckFilters());
+		}
+		if(null != dqRuleVo.getReferFilters()) {
+			rs = rs.replaceAll("#refer_filters", dqRuleVo.getReferFilters());
+		}
+		return rs;
+	}
+}

src/main/java/com/gmei/data/dqmp/service/impl/FormatServiceImpl.java

@@ -25,23 +25,18 @@ public class FormatServiceImpl implements FormatService {
 	}
 	
 	public static void main(String[] args) {
-		String removeNewlineSymbol = new FormatServiceImpl().removeNewlineSymbol("SELECT 'online' AS db_name,\n" + 
-				"\n" + 
-				"              'test' AS tb_name,\n" + 
-				"\n" + 
-				"              'age' AS time_col_name,\n" + 
-				"\n" + 
-				"              '23' AS start_time,\n" + 
-				"\n" + 
-				"              '66' AS end_time,\n" + 
-				"\n" + 
-				"              COUNT(*) as count_num,date_add(from_unixtime(unix_timestamp(),'yyyy-MM-dd'),-1) as partition_date,from_unixtime(unix_timestamp(),'yyyy-MM-dd HH:mm:ss') as create_time\n" + 
-				"\n" + 
-				"  FROM  online.test\n" + 
-				"\n" + 
-				"WHERE name >=11\n" + 
-				"\n" + 
-				"     AND name <=12");
+		String removeNewlineSymbol = new FormatServiceImpl().removeNewlineSymbol("SELECT '$db_name' AS DB_NAME,\n" + 
+				"	       '$tb_name' AS TB_NAME,\n" + 
+				"	       '$time_col_name' AS TIME_COL_NAME,\n" + 
+				"	       '$start_time' AS START_TIME,\n" + 
+				"	       '$end_time' AS END_TIME,\n" + 
+				"	       COUNT(*) AS COUNT_NUM,\n" + 
+				"       	   DATE_ADD(from_unixtime(unix_timestamp(), 'yyyy-MM-dd'), -1) AS PARTITION_DATE,\n" + 
+				"           FROM_UNIXTIME(unix_timestamp(), 'yyyy-MM-dd HH:mm:ss') AS CREATE_TIME\n" + 
+				"	  FROM $db_name.$tb_name\n" + 
+				"	 WHERE $time_col_name >= $start_time\n" + 
+				"	   AND $time_col_name < $end_time\n" + 
+				"	 $filters");
 		System.out.println(removeNewlineSymbol);
 	}
 }

src/main/java/com/gmei/data/dqmp/service/impl/MonitorServiceImpl.java

@@ -24,6 +24,7 @@ import com.gmei.data.dqmp.mapper.TblResultMonitorSpecialMapper;
 import com.gmei.data.dqmp.mapper.TblResultMonitorVolatilityMapper;
 import com.gmei.data.dqmp.pool.JdbcConnectPool;
 import com.gmei.data.dqmp.service.MonitorService;
+import com.gmei.data.dqmp.utils.DateUtils;
 
 @Service
 public class MonitorServiceImpl implements MonitorService {
@@ -101,6 +102,7 @@ public class MonitorServiceImpl implements MonitorService {
 	 * @return
 	 */
 	private TblResultMonitorVolatility getMonitorVolatilityResult(String sql, String indicatorType) {
+		sql = sql.replaceAll("#partation_date", String.format("'%s'", DateUtils.getYesterdayDateStr()));
 		logger.info("Sql content : {},indicatorType: {}", sql, indicatorType);
 		TblResultMonitorVolatility tblResultMonitorVolatility = null;
 		if (StringUtils.isBlank(sql) || StringUtils.isBlank(indicatorType)) {
@@ -136,6 +138,7 @@ public class MonitorServiceImpl implements MonitorService {
 	 * @return
 	 */
 	private TblResultMonitorSpecial getMonitorSpecialResult(String sql) {
+		sql = sql.replaceAll("#partation_date", String.format("'%s'", DateUtils.getYesterdayDateStr()));
 		logger.info("Sql content : {}", sql);
 		TblResultMonitorSpecial tblResultMonitorSpecial = null;
 		if (StringUtils.isBlank(sql)) {

src/main/java/com/gmei/data/dqmp/service/impl/RuleTemplateServiceImpl.java

@@ -22,10 +22,10 @@ public class RuleTemplateServiceImpl implements RuleTemplateService {
     private TblRuleTemplateMapper tblRuleTemplateMapper;
 
 	@Override
-	public List<RuleTemplateDto> findRuleTmpls(String tmplType) {
+	public List<RuleTemplateDto> findRuleTmpls(String checkType) {
 		List<RuleTemplateDto> rsList = new ArrayList<>();
 		TblRuleTemplateCriteria tblDqRuleTemplateCriteria = new TblRuleTemplateCriteria();
-		tblDqRuleTemplateCriteria.createCriteria().andTypeEqualTo(tmplType);
+		tblDqRuleTemplateCriteria.createCriteria().andCheckTypeEqualTo(checkType);
 		List<TblRuleTemplate> list = tblRuleTemplateMapper.selectByExample(tblDqRuleTemplateCriteria);
 		for(TblRuleTemplate tblDqRuleTemplate : list) {
 			rsList.add(BeanUtils.map(tblDqRuleTemplate, RuleTemplateDto.class));

src/main/java/com/gmei/data/dqmp/service/impl/TblSysParamInfoServiceImpl.java

+package com.gmei.data.dqmp.service.impl;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.beans.factory.annotation.Autowired;
+
+import com.gmei.data.dqmp.domain.TblSysParamInfo;
+import com.gmei.data.dqmp.domain.TblSysParamInfoCriteria;
+import com.gmei.data.dqmp.mapper.TblSysParamInfoMapper;
+import com.gmei.data.dqmp.service.TblSysParamInfoService;
+
+public class TblSysParamInfoServiceImpl implements TblSysParamInfoService {
+
+	@Autowired
+	private TblSysParamInfoMapper tblSysParamInfoMapper;
+	
+	@Override
+	public Map<String,String> getSysParamMap(String paramType){
+		Map<String,String> rsMap = new HashMap<String, String>();
+		TblSysParamInfoCriteria example = new TblSysParamInfoCriteria();
+		example.createCriteria().andParamTypeEqualTo(paramType);
+		List<TblSysParamInfo> rsList = tblSysParamInfoMapper.selectByExample(example);
+		for(TblSysParamInfo tblSysParamInfo : rsList) {
+			rsMap.put(tblSysParamInfo.getParamKey(), tblSysParamInfo.getParamValue());
+		}
+		return rsMap;
+	}
+}

src/main/java/com/gmei/data/dqmp/utils/DateUtils.java

 package com.gmei.data.dqmp.utils;
 
 import java.text.SimpleDateFormat;
+import java.util.Calendar;
 import java.util.Date;
 
 public class DateUtils {
 	
 	private static final String DATE_FORMATE_YMD = "yyyy-MM-dd";
+	private static final String PARTITION_DATE_FORMAT = "yyyyMMdd";
 	private static final String DATE_FORMATE_YMDHMS = "yyyy-MM-dd HH:mm:ss";
+	private static final String DATE_FORMATE_YMDHMSS = "yyyy-MM-dd HH:mm:ss.S";
 	
 	/**
 	 * 获取当前时间字符串
@@ -23,4 +26,33 @@ public class DateUtils {
 	public static String getCurrentTimeStr() {
 		return new SimpleDateFormat(DATE_FORMATE_YMDHMS).format(new Date());
 	}
+	
+	/**
+	 * 获取昨天时间字符串
+	 * @return
+	 */
+	public static String getYesterdayDateStr() {
+		Calendar cld = Calendar.getInstance();
+		cld.setTime(new Date());
+		cld.add(Calendar.DAY_OF_MONTH, -1);
+		return new SimpleDateFormat(PARTITION_DATE_FORMAT).format(cld.getTime());
+	}
+	
+	/**
+	 * 获取今天0时0分0秒0毫秒时间字符串
+	 * @return
+	 */
+	public static String getTodayZeroTimeStr() {
+		Calendar cld = Calendar.getInstance();
+		cld.setTime(new Date());
+		cld.set(Calendar.HOUR_OF_DAY, 0);
+		cld.set(Calendar.MINUTE, 0);
+		cld.set(Calendar.SECOND, 0);
+		cld.set(Calendar.MILLISECOND, 0);
+		return new SimpleDateFormat(DATE_FORMATE_YMDHMSS).format(cld.getTime());
+	}
+	
+	public static void main(String[] args) {
+		System.out.println(getTodayZeroTimeStr());
+	}
 }

src/main/java/com/gmei/data/dqmp/vo/DqRuleVo.java

+package com.gmei.data.dqmp.vo;
+
+import javax.validation.constraints.NotNull;
+import org.hibernate.validator.constraints.NotBlank;
+
+public class DqRuleVo extends BaseVo{
+	//common
+	@NotBlank(message = "校验类型字段不能为空")
+	private String checkType;
+	@NotNull(message = "状态字段不能为NULL")
+	private Integer isValid;
+	@NotBlank(message = "校验时间字段不能为空")
+	private String checkTime;
+	
+	//simple
+	private String dbName;
+	private String tbName;
+	private String colName;
+	private String timeColName;
+	private String filters;
+	private String indicatorType;
+	private String startTime;
+	//private String endTime;
+	
+	//duplex
+	private String checkDbName;
+	private String checkTbName;
+	private String checkColName;
+	private String referDbName;
+	private String referTbName;
+	private String referColName;
+	private String checkFilters;
+	private String referFilters;
+	
+	public DqRuleVo() {
+		super();
+	}
+	
+	public DqRuleVo(Integer status,String msg) {
+		super(status,msg);
+	}
+
+	public Integer getIsValid() {
+		return isValid;
+	}
+
+	public void setIsValid(Integer isValid) {
+		this.isValid = isValid;
+	}
+
+	public String getCheckTime() {
+		return checkTime;
+	}
+
+	public void setCheckTime(String checkTime) {
+		this.checkTime = checkTime;
+	}
+
+	public String getCheckType() {
+		return checkType;
+	}
+	public void setCheckType(String checkType) {
+		this.checkType = checkType;
+	}
+	public String getDbName() {
+		return dbName;
+	}
+	public void setDbName(String dbName) {
+		this.dbName = dbName;
+	}
+	public String getTbName() {
+		return tbName;
+	}
+	public void setTbName(String tbName) {
+		this.tbName = tbName;
+	}
+	public String getColName() {
+		return colName;
+	}
+	public void setColName(String colName) {
+		this.colName = colName;
+	}
+	public String getTimeColName() {
+		return timeColName;
+	}
+
+	public void setTimeColName(String timeColName) {
+		this.timeColName = timeColName;
+	}
+
+	public String getFilters() {
+		return filters;
+	}
+	public void setFilters(String filters) {
+		this.filters = filters;
+	}
+	public String getIndicatorType() {
+		return indicatorType;
+	}
+	public void setIndicatorType(String indicatorType) {
+		this.indicatorType = indicatorType;
+	}
+	public String getStartTime() {
+		return startTime;
+	}
+	public void setStartTime(String startTime) {
+		this.startTime = startTime;
+	}
+//	public String getEndTime() {
+//		return endTime;
+//	}
+//	public void setEndTime(String endTime) {
+//		this.endTime = endTime;
+//	}
+	public String getCheckDbName() {
+		return checkDbName;
+	}
+	public void setCheckDbName(String checkDbName) {
+		this.checkDbName = checkDbName;
+	}
+	public String getCheckTbName() {
+		return checkTbName;
+	}
+	public void setCheckTbName(String checkTbName) {
+		this.checkTbName = checkTbName;
+	}
+	public String getCheckColName() {
+		return checkColName;
+	}
+	public void setCheckColName(String checkColName) {
+		this.checkColName = checkColName;
+	}
+	public String getReferDbName() {
+		return referDbName;
+	}
+	public void setReferDbName(String referDbName) {
+		this.referDbName = referDbName;
+	}
+	public String getReferTbName() {
+		return referTbName;
+	}
+	public void setReferTbName(String referTbName) {
+		this.referTbName = referTbName;
+	}
+	public String getReferColName() {
+		return referColName;
+	}
+	public void setReferColName(String referColName) {
+		this.referColName = referColName;
+	}
+	public String getCheckFilters() {
+		return checkFilters;
+	}
+	public void setCheckFilters(String checkFilters) {
+		this.checkFilters = checkFilters;
+	}
+	public String getReferFilters() {
+		return referFilters;
+	}
+	public void setReferFilters(String referFilters) {
+		this.referFilters = referFilters;
+	}
+
+	@Override
+	public String toString() {
+		return "DqRuleVo [checkType=" + checkType + ", isValid=" + isValid + ", checkTime=" + checkTime + ", dbName="
+				+ dbName + ", tbName=" + tbName + ", colName=" + colName + ", timeColName=" + timeColName + ", filters="
+				+ filters + ", indicatorType=" + indicatorType + ", startTime=" + startTime + ", checkDbName="
+				+ checkDbName + ", checkTbName=" + checkTbName + ", checkColName=" + checkColName + ", referDbName="
+				+ referDbName + ", referTbName=" + referTbName + ", referColName=" + referColName + ", checkFilters="
+				+ checkFilters + ", referfilters=" + referFilters + "]";
+	}
+
+}

src/main/java/com/gmei/data/dqmp/vo/RuleTemplateVo.java

@@ -6,59 +6,47 @@ import com.gmei.data.dqmp.dto.RuleTemplateDto;
 
 public class RuleTemplateVo extends BaseVo{
 
-	private String type;
-	private String content;
-	private String comment;
-	private List<RuleTemplateDto> ruleTemplates;
-
+	private String checkType;
+    private String tpltContent;
+    private String comment;
+    private List<RuleTemplateDto> ruleTemplates;
+	
 	public RuleTemplateVo() {
 		super();
 	}
 
-	public RuleTemplateVo(Integer status, String msg) {
+	public RuleTemplateVo(Integer status,String msg) {
 		super(status,msg);
 	}
-
-	public RuleTemplateVo(String type) {
-		super();
-		this.type = type;
-	}
 	
-	public RuleTemplateVo(String type, String content, String comment) {
+	public RuleTemplateVo(List<RuleTemplateDto> ruleTemplates) {
 		super();
-		this.type = type;
-		this.content = content;
-		this.comment = comment;
+		this.ruleTemplates = ruleTemplates;
 	}
 
-	public String getType() {
-		return type;
-	}
+    public String getCheckType() {
+        return checkType;
+    }
 
-	public void setType(String type) {
-		this.type = type;
-	}
-	
-	public String getContent() {
-		return content;
-	}
+    public void setCheckType(String checkType) {
+        this.checkType = checkType == null ? null : checkType.trim();
+    }
 
-	public void setContent(String content) {
-		this.content = content;
-	}
+    public String getTpltContent() {
+        return tpltContent;
+    }
 
-	public String getComment() {
-		return comment;
-	}
+    public void setTpltContent(String tpltContent) {
+        this.tpltContent = tpltContent == null ? null : tpltContent.trim();
+    }
 
-	public void setComment(String comment) {
-		this.comment = comment;
-	}
+    public String getComment() {
+        return comment;
+    }
 
-	public RuleTemplateVo(List<RuleTemplateDto> ruleTemplates) {
-		super();
-		this.ruleTemplates = ruleTemplates;
-	}
+    public void setComment(String comment) {
+        this.comment = comment == null ? null : comment.trim();
+    }
 
 	public List<RuleTemplateDto> getRuleTemplates() {
 		return ruleTemplates;
@@ -67,5 +55,5 @@ public class RuleTemplateVo extends BaseVo{
 	public void setRuleTemplates(List<RuleTemplateDto> ruleTemplates) {
 		this.ruleTemplates = ruleTemplates;
 	}
-	
+    
 }

src/main/resources/generator.xml

@@ -34,16 +34,20 @@
         </javaClientGenerator>
 
         <!-- 需要生成的数据库表 -->
-        <!-- <table tableName="tbl_rule_template" domainObjectName="TblRuleTemplate"/> -->
+        <!-- <table tableName="tbl_client_version_info" domainObjectName="TblClientVersionInfo"/> -->
         <!-- <table tableName="tbl_check_single_sql" domainObjectName="TblCheckSingleSql"/> -->
+        <!-- <table tableName="tbl_check_multiple_sql" domainObjectName="TblCheckMultipleSql"/> -->
+        <!-- <table tableName="tbl_monitor_volatility_sql" domainObjectName="TblMonitorVolatilitySql"/> -->
+        <!-- <table tableName="tbl_monitor_special_sql" domainObjectName="TblMonitorSpecialSql"/> -->
         <!-- <table tableName="tbl_result_check_unique" domainObjectName="TblResultCheckUnique"/> -->
         <!-- <table tableName="tbl_result_check_unblank" domainObjectName="TblResultCheckUnblank"/> -->
-        <!-- <table tableName="tbl_client_version_info" domainObjectName="TblClientVersionInfo"/> -->
         <!-- <table tableName="tbl_result_check_refer" domainObjectName="TblResultCheckRefer"/> -->
-        <!-- <table tableName="tbl_check_multiple_sql" domainObjectName="TblCheckMultipleSql"/> -->
-        <!-- <table tableName="tbl_monitor_volatility_sql" domainObjectName="TblMonitorVolatilitySql"/> -->
         <!-- <table tableName="tbl_result_monitor_volatility" domainObjectName="TblResultMonitorVolatility"/> -->
-        <table tableName="tbl_monitor_special_sql" domainObjectName="TblMonitorSpecialSql"/>
-        <table tableName="tbl_result_monitor_special" domainObjectName="TblResultMonitorSpecial"/>
+        <!-- <table tableName="tbl_result_monitor_special" domainObjectName="TblResultMonitorSpecial"/> -->
+        <!-- <table tableName="tbl_indicator_operator_info" domainObjectName="TblIndicatorOperatorInfo"/> -->
+        <!-- <table tableName="tbl_rule_template" domainObjectName="TblRuleTemplate"/> -->
+        <!-- <table tableName="tbl_rule_simple_info" domainObjectName="TblRuleSimpleInfo"/> -->
+        <!-- <table tableName="tbl_rule_duplex_info" domainObjectName="TblRuleDuplexInfo"/> -->
+        <table tableName="tbl_sys_param_info" domainObjectName="TblSysParamInfo"/>
     </context>
 </generatorConfiguration>

src/main/resources/mybatis/mapper/TblIndicatorOperatorInfoMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.gmei.data.dqmp.mapper.TblIndicatorOperatorInfoMapper" >
+  <resultMap id="BaseResultMap" type="com.gmei.data.dqmp.domain.TblIndicatorOperatorInfo" >
+    <id column="id" property="id" jdbcType="INTEGER" />
+    <result column="indicator_name" property="indicatorName" jdbcType="VARCHAR" />
+    <result column="operator_expr" property="operatorExpr" jdbcType="VARCHAR" />
+    <result column="comment" property="comment" jdbcType="VARCHAR" />
+  </resultMap>
+  <sql id="Example_Where_Clause" >
+    <where >
+      <foreach collection="oredCriteria" item="criteria" separator="or" >
+        <if test="criteria.valid" >
+          <trim prefix="(" suffix=")" prefixOverrides="and" >
+            <foreach collection="criteria.criteria" item="criterion" >
+              <choose >
+                <when test="criterion.noValue" >
+                  and ${criterion.condition}
+                </when>
+                <when test="criterion.singleValue" >
+                  and ${criterion.condition} #{criterion.value}
+                </when>
+                <when test="criterion.betweenValue" >
+                  and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
+                </when>
+                <when test="criterion.listValue" >
+                  and ${criterion.condition}
+                  <foreach collection="criterion.value" item="listItem" open="(" close=")" separator="," >
+                    #{listItem}
+                  </foreach>
+                </when>
+              </choose>
+            </foreach>
+          </trim>
+        </if>
+      </foreach>
+    </where>
+  </sql>
+  <sql id="Update_By_Example_Where_Clause" >
+    <where >
+      <foreach collection="example.oredCriteria" item="criteria" separator="or" >
+        <if test="criteria.valid" >
+          <trim prefix="(" suffix=")" prefixOverrides="and" >
+            <foreach collection="criteria.criteria" item="criterion" >
+              <choose >
+                <when test="criterion.noValue" >
+                  and ${criterion.condition}
+                </when>
+                <when test="criterion.singleValue" >
+                  and ${criterion.condition} #{criterion.value}
+                </when>
+                <when test="criterion.betweenValue" >
+                  and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
+                </when>
+                <when test="criterion.listValue" >
+                  and ${criterion.condition}
+                  <foreach collection="criterion.value" item="listItem" open="(" close=")" separator="," >
+                    #{listItem}
+                  </foreach>
+                </when>
+              </choose>
+            </foreach>
+          </trim>
+        </if>
+      </foreach>
+    </where>
+  </sql>
+  <sql id="Base_Column_List" >
+    id, indicator_name, operator_expr, comment
+  </sql>
+  <select id="selectByExample" resultMap="BaseResultMap" parameterType="com.gmei.data.dqmp.domain.TblIndicatorOperatorInfoCriteria" >
+    select
+    <if test="distinct" >
+      distinct
+    </if>
+    <include refid="Base_Column_List" />
+    from tbl_indicator_operator_info
+    <if test="_parameter != null" >
+      <include refid="Example_Where_Clause" />
+    </if>
+    <if test="orderByClause != null" >
+      order by ${orderByClause}
+    </if>
+  </select>
+  <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
+    select 
+    <include refid="Base_Column_List" />
+    from tbl_indicator_operator_info
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >
+    delete from tbl_indicator_operator_info
+    where id = #{id,jdbcType=INTEGER}
+  </delete>
+  <delete id="deleteByExample" parameterType="com.gmei.data.dqmp.domain.TblIndicatorOperatorInfoCriteria" >
+    delete from tbl_indicator_operator_info
+    <if test="_parameter != null" >
+      <include refid="Example_Where_Clause" />
+    </if>
+  </delete>
+  <insert id="insert" parameterType="com.gmei.data.dqmp.domain.TblIndicatorOperatorInfo" >
+    insert into tbl_indicator_operator_info (id, indicator_name, operator_expr, 
+      comment)
+    values (#{id,jdbcType=INTEGER}, #{indicatorName,jdbcType=VARCHAR}, #{operatorExpr,jdbcType=VARCHAR}, 
+      #{comment,jdbcType=VARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.gmei.data.dqmp.domain.TblIndicatorOperatorInfo" >
+    insert into tbl_indicator_operator_info
+    <trim prefix="(" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        id,
+      </if>
+      <if test="indicatorName != null" >
+        indicator_name,
+      </if>
+      <if test="operatorExpr != null" >
+        operator_expr,
+      </if>
+      <if test="comment != null" >
+        comment,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        #{id,jdbcType=INTEGER},
+      </if>
+      <if test="indicatorName != null" >
+        #{indicatorName,jdbcType=VARCHAR},
+      </if>
+      <if test="operatorExpr != null" >
+        #{operatorExpr,jdbcType=VARCHAR},
+      </if>
+      <if test="comment != null" >
+        #{comment,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <select id="countByExample" parameterType="com.gmei.data.dqmp.domain.TblIndicatorOperatorInfoCriteria" resultType="java.lang.Integer" >
+    select count(*) from tbl_indicator_operator_info
+    <if test="_parameter != null" >
+      <include refid="Example_Where_Clause" />
+    </if>
+  </select>
+  <update id="updateByExampleSelective" parameterType="map" >
+    update tbl_indicator_operator_info
+    <set >
+      <if test="record.id != null" >
+        id = #{record.id,jdbcType=INTEGER},
+      </if>
+      <if test="record.indicatorName != null" >
+        indicator_name = #{record.indicatorName,jdbcType=VARCHAR},
+      </if>
+      <if test="record.operatorExpr != null" >
+        operator_expr = #{record.operatorExpr,jdbcType=VARCHAR},
+      </if>
+      <if test="record.comment != null" >
+        comment = #{record.comment,jdbcType=VARCHAR},
+      </if>
+    </set>
+    <if test="_parameter != null" >
+      <include refid="Update_By_Example_Where_Clause" />
+    </if>
+  </update>
+  <update id="updateByExample" parameterType="map" >
+    update tbl_indicator_operator_info
+    set id = #{record.id,jdbcType=INTEGER},
+      indicator_name = #{record.indicatorName,jdbcType=VARCHAR},
+      operator_expr = #{record.operatorExpr,jdbcType=VARCHAR},
+      comment = #{record.comment,jdbcType=VARCHAR}
+    <if test="_parameter != null" >
+      <include refid="Update_By_Example_Where_Clause" />
+    </if>
+  </update>
+  <update id="updateByPrimaryKeySelective" parameterType="com.gmei.data.dqmp.domain.TblIndicatorOperatorInfo" >
+    update tbl_indicator_operator_info
+    <set >
+      <if test="indicatorName != null" >
+        indicator_name = #{indicatorName,jdbcType=VARCHAR},
+      </if>
+      <if test="operatorExpr != null" >
+        operator_expr = #{operatorExpr,jdbcType=VARCHAR},
+      </if>
+      <if test="comment != null" >
+        comment = #{comment,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.gmei.data.dqmp.domain.TblIndicatorOperatorInfo" >
+    update tbl_indicator_operator_info
+    set indicator_name = #{indicatorName,jdbcType=VARCHAR},
+      operator_expr = #{operatorExpr,jdbcType=VARCHAR},
+      comment = #{comment,jdbcType=VARCHAR}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+</mapper>
\ No newline at end of file