Compare commits

..

3 Commits

Author SHA1 Message Date
wangxuanran 6141de68ac 合并 2023-07-27 12:47:08 +08:00
wangxuanran 5cf9c44c6c 合并 2023-07-27 12:46:05 +08:00
wangxuanran ee84e559e6 胸科医院代码上传 2023-07-27 12:44:37 +08:00
16 changed files with 1047 additions and 1 deletions

View File

@ -0,0 +1,48 @@
const detailTable = "detail_1";
// 多选字段
const detailMultiFieldId = ModeForm.convertFieldNameToId("model_field", detailTable);
// 单选字段
const detailRadioFieldId = ModeForm.convertFieldNameToId("model_field_ass", detailTable);
// 表单字段名字段
const detailFieldNameId = ModeForm.convertFieldNameToId("model_field_name", detailTable);
// 所属表
const detailFieldTableNameId = ModeForm.convertFieldNameToId("table_name", detailTable);
// 主表还是明细
const detailMainOrDetailId = ModeForm.convertFieldNameToId("main_or_detail", detailTable);
$(()=>{
let chose = {};
ModeForm.bindDetailFieldChangeEvent(detailMultiFieldId, (id, index, val)=>{
console.log('id : ', id);
console.log('index : ', index);
console.log('val : ', val);
if(!val){
return;
}
let fieldMameArr = [];
let tableNameArr = [];
let mainOrDetailArr = [];
val.split(',').forEach(id=>{
ModeForm.changeFieldValue(`${detailRadioFieldId}_${index}`, {
value: id,
specialobj:[
{id:id, name:"field"}
]
})
setTimeout(()=>{
let detailFieldNameIdValue = ModeForm.getFieldValue(`${detailFieldNameId}_${index}`)
let detailFieldTableNameValue = ModeForm.getFieldValue(`${detailFieldTableNameId}_${index}`)
let detailMainOrDetailValue = ModeForm.getFieldValue(`${detailMainOrDetailId}_${index}`);
fieldMameArr.push(detailFieldNameIdValue);
tableNameArr.push(detailFieldTableNameValue);
mainOrDetailArr.push(detailMainOrDetailValue);
},0);
})
console.log('fieldMameArr : ', fieldMameArr)
console.log('tableNameArr : ', tableNameArr)
console.log('mainOrDetailArr : ', mainOrDetailArr)
ModeForm.changeFieldValue(`${detailFieldNameId}_${index}`,{value:fieldMameArr.join(',')})
ModeForm.changeFieldValue(`${detailFieldTableNameId}_${index}`,{value:tableNameArr.join(',')})
ModeForm.changeFieldValue(`${detailMainOrDetailId}_${index}`,{value:mainOrDetailArr.join(',')})
})
})

View File

@ -1,5 +1,6 @@
package aiyh.utils;
import aiyh.utils.interfaces.script_util.CusScriptFunInterface;
import aiyh.utils.tool.org.apache.commons.jexl3.*;
import java.util.Map;
@ -13,9 +14,16 @@ import java.util.Map;
*/
public class ScriptUtil {
private static final JexlEngine JEXL = new JexlBuilder().create();
public static Object invokeScript(String script, Map<String, Object> params) {
return invokeScript(script, params, null);
}
public static Object invokeScript(String script, Map<String, Object> params, CusScriptFunInterface scriptFunInterface) {
JexlContext jc = new MapContext();
if(null != scriptFunInterface){
jc.set(scriptFunInterface.getClass().getSimpleName(), scriptFunInterface);
}
for (Map.Entry<String, Object> entry : params.entrySet()) {
jc.set(entry.getKey(), entry.getValue());
}

View File

@ -0,0 +1,10 @@
package aiyh.utils.interfaces.script_util;
/**
* <h1>script util </h1>
*
* @author xuanran.wang
* @date 2023/7/25 16:41
*/
public interface CusScriptFunInterface {
}

View File

@ -0,0 +1,25 @@
package weaver.xuanran.wang.xk_hospital.model_check.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* <h1></h1>
*
* @author xuanran.wang
* @date 2023/7/25 15:08
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class CheckErrorInfo {
private String tableName;
private String dataId;
private String errorFieldName;
private String errorMsg;
private Object currentValue;
private String mainId;
}

View File

@ -0,0 +1,16 @@
package weaver.xuanran.wang.xk_hospital.model_check.entity;
import lombok.Data;
/**
* <h1></h1>
*
* @author xuanran.wang
* @date 2023/7/26 14:37
*/
@Data
public class ModelFieldInfo {
private String fieldName;
private String tableName;
private int viewType;
}

View File

@ -0,0 +1,21 @@
package weaver.xuanran.wang.xk_hospital.model_check.entity;
import lombok.Data;
import java.util.List;
/**
* <h1> </h1>
*
* @author xuanran.wang
* @date 2023/7/24 15:00
*/
@Data
public class XkModelCusCheckConfig {
private int modelTable;
private String modelTableName;
private String onlyMark;
private String cusText;
private List<XkModelCusCheckFiledConfig> filedConfigList;
private List<XkModelCusCheckFiledGroupConfig> filedGroupConfigList;
}

View File

@ -0,0 +1,27 @@
package weaver.xuanran.wang.xk_hospital.model_check.entity;
import lombok.Data;
import java.util.List;
/**
* <h1> 1 </h1>
*
* @author xuanran.wang
* @date 2023/7/24 15:00
*/
@Data
public class XkModelCusCheckFiledConfig {
private String mainId;
private String modelField;
private int checkRule;
private String customerValue;
private String checkExpression;
private String errorMsg;
private int controlLevel;
private String fieldDbType;
private String modelTable;
private String modelTableName;
private List<ModelFieldInfo> modelFieldNameList;
private String cusWhere;
}

View File

@ -0,0 +1,16 @@
package weaver.xuanran.wang.xk_hospital.model_check.entity;
import lombok.Data;
/**
* <h1> 2 </h1>
*
* @author xuanran.wang
* @date 2023/7/24 15:00
*/
@Data
public class XkModelCusCheckFiledGroupConfig {
private int conditionName;
private int conditionRule;
private String customerValue;
}

View File

@ -0,0 +1,26 @@
package weaver.xuanran.wang.xk_hospital.model_check.job;
import aiyh.utils.action.CusBaseCronJob;
import aiyh.utils.annotation.PrintParamMark;
import aiyh.utils.annotation.RequiredMark;
import java.io.IOException;
/**
* <h1></h1>
*
* @author xuanran.wang
* @date 2023/7/24 16:02
*/
public class XkModelCusCheckJob extends CusBaseCronJob {
@RequiredMark
@PrintParamMark
private String onlyMark;
@Override
public void runCode() throws IOException {
}
}

View File

@ -0,0 +1,79 @@
package weaver.xuanran.wang.xk_hospital.model_check.mapper;
import aiyh.utils.annotation.recordset.*;
import weaver.xuanran.wang.xk_hospital.model_check.entity.ModelFieldInfo;
import weaver.xuanran.wang.xk_hospital.model_check.entity.XkModelCusCheckConfig;
import weaver.xuanran.wang.xk_hospital.model_check.entity.XkModelCusCheckFiledConfig;
import weaver.xuanran.wang.xk_hospital.model_check.entity.XkModelCusCheckFiledGroupConfig;
import java.util.List;
import java.util.Map;
/**
* <h1></h1>
*
* @author xuanran.wang
* @date 2023/7/24 15:18
*/
@SqlMapper
public interface XkModelCusCheckMapper {
/**
* <h2>1</h2>
*/
@Select("select a.*, a.mainid main_id, b.tablename model_table_name " +
"from $t{modelTableName}_dt2 a " +
"left join workflow_mode_table_view b " +
"on a.model_table = b.id " +
"where enable = 0")
@Associations( @Association(property = "modelFieldNameList", column = "model_field", id = @Id(value = String.class,methodId = 1)))
List<XkModelCusCheckFiledConfig> queryConditionList(@ParamMapper("modelTableName")String modelTableName);
/**
* <h2></h2>
* @param fieldIds
*/
@AssociationMethod(value = 1)
@Select("select a.fieldname field_name, a.tablename table_name, b.viewtype view_type " +
"from workflow_field_table_view a " +
"left join workflow_billfield b " +
"on a.id = b.id " +
"where a.id in ( $t{fieldIds} )")
List<ModelFieldInfo> queryFieldName(@ParamMapper("fieldIds") String fieldIds);
/**
* <h2>2</h2>
* @param mainId id
*/
@Select("select * from uf_xk_model_data_cus_check_dt2 where mainid = #{mainId} and enable = 0")
@CollectionMethod(2)
List<XkModelCusCheckFiledGroupConfig> queryAssignmentList(@ParamMapper("mainId")int mainId);
@Select("select * from $t{tableName} $t{where}")
List<Map<String, Object>> queryModelMain(@ParamMapper("tableName") String tableName,
@ParamMapper("where") String where);
@Select("select detail.* " +
"from $t{detailTableName} detail " +
"right join $t{mainTableName} main " +
"on detail.mainid = main.id " +
"$t{where} ")
List<Map<String, Object>> queryModelDetail(@ParamMapper("detailTableName") String detailTableName,
@ParamMapper("mainTableName") String mainTableName,
@ParamMapper("where") String where);
@Select(custom = true)
int queryCusSqlCount(@SqlString String sql,
@ParamMapper("mainMap") Map<String, Object> mainMap,
@ParamMapper("detailMap") Map<String, Object> detailMap);
@Select(custom = true)
Map<String, Object> queryCusSqlMap(@SqlString String sql,
@ParamMapper("mainMap") Map<String, Object> mainMap,
@ParamMapper("detailMap") Map<String, Object> detailMap);
@Select(custom = true)
String queryCusSqlDate(@SqlString String sql,
@ParamMapper("mainMap") Map<String, Object> mainMap,
@ParamMapper("detailMap") Map<String, Object> detailMap);
}

View File

@ -0,0 +1,136 @@
package weaver.xuanran.wang.xk_hospital.model_check.service;
import aiyh.utils.Util;
import aiyh.utils.function.Bi4Function;
import aiyh.utils.tool.Assert;
import aiyh.utils.tool.cn.hutool.core.util.StrUtil;
import aiyh.utils.zwl.common.ToolUtil;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import weaver.xuanran.wang.xk_hospital.model_check.entity.*;
import weaver.xuanran.wang.xk_hospital.model_check.mapper.XkModelCusCheckMapper;
import weaver.xuanran.wang.xk_hospital.model_check.util.CheckRuleMethodUtil;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* <h1> </h1>
*
* @author xuanran.wang
* @date 2023/7/24 16:07
*/
public class XkModelCusCheckService {
private final XkModelCusCheckMapper mapper = Util.getMapper(XkModelCusCheckMapper.class);
private final ToolUtil toolUtil = new ToolUtil();
public List<XkModelCusCheckFiledConfig> getFieldCheckRuleConfigList(){
String configTableName = Util.null2DefaultStr(toolUtil.getSystemParamValue("checkRuleConfigTableName"), "uf_yyhcfxgz");
return mapper.queryConditionList(configTableName);
}
public void checkModelData(List<XkModelCusCheckFiledConfig> configList){
// 根据建模表名进行分组 查找出每个表对应有哪些校验规则事项
Map<String, List<XkModelCusCheckFiledConfig>> map = configList.stream().collect(Collectors.groupingBy(XkModelCusCheckFiledConfig::getModelTableName));
List<CheckErrorInfo> result = new ArrayList<>();
for (Map.Entry<String, List<XkModelCusCheckFiledConfig>> entry : map.entrySet()) {
// 在对每个表的第一个字段做分组 找出主表和明细表
List<XkModelCusCheckFiledConfig> filedConfigs = entry.getValue();
Map<String, List<XkModelCusCheckFiledConfig>> configMap = filedConfigs.stream()
.collect(Collectors.groupingBy(item->item.getModelFieldNameList().get(0).getTableName()));
System.out.println("configMap : \n" + JSONObject.toJSONString(configMap));
// 主表表名
String mainTableName = entry.getKey();
// 主表数据
List<Map<String, Object>> modelList = mapper.queryModelMain(mainTableName,"");
// 主表校验规则配置
List<XkModelCusCheckFiledConfig> mainTableConfig = configMap.remove(mainTableName);
// 先处理主表数据
checkModel(mainTableName, new HashMap<>(), modelList, mainTableConfig, result);
// 明细数据
for (Map.Entry<String, List<XkModelCusCheckFiledConfig>> detailEntry : configMap.entrySet()) {
String detailTable = detailEntry.getKey();
List<Map<String, Object>> detailModel = mapper.queryModelDetail(detailTable, mainTableName, "");
if(CollectionUtils.isEmpty(detailModel)){
continue;
}
// 主表的mainId
String detailMainId = Util.null2DefaultStr(detailModel.get(0).get("mainid"), "");
if(StrUtil.isBlank(detailMainId)){
continue;
}
List<Map<String, Object>> mainList = modelList.stream().filter(item -> {
String id = Util.null2DefaultStr(item.get("id"), "");
return StrUtil.isNotBlank(id) && detailMainId.equals(id);
}).collect(Collectors.toList());
if(CollectionUtils.isEmpty(mainList)){
Util.getLogger()
.error(Util.logStr("当前明细表: {}, detailMainId: {} 在主表数据集合中没找到对应的主表数据! 当前主表数据集合: {}", detailTable, detailMainId, JSONObject.toJSONString(modelList)));
continue;
}
List<XkModelCusCheckFiledConfig> detailConfig = detailEntry.getValue();
checkModel(detailTable, mainList.get(0), detailModel, detailConfig, result);
}
}
System.out.println("result : \n" + JSONObject.toJSONString(result));
}
public String buildWhereSql(String modelWhereSql, boolean joinQuery){
StringBuilder sb = new StringBuilder();
modelWhereSql = Util.sbc2dbcCase(modelWhereSql);
if(StrUtil.isNotBlank(modelWhereSql)){
sb.append(modelWhereSql);
}
if(joinQuery && StrUtil.isNotBlank(modelWhereSql)){
sb.append(" detail.").append(modelWhereSql).append(" and ").append(" main.").append(modelWhereSql);
}
if(sb.length() > 0){
sb.insert(0, " where ");
}
return sb.toString();
}
public void checkModel(String tableName,
Map<String, Object> mainMap,
List<Map<String, Object>> modelList,
List<XkModelCusCheckFiledConfig> configs,
List<CheckErrorInfo> result){
if(CollectionUtils.isEmpty(configs) || CollectionUtils.isEmpty(modelList)){
return;
}
Map<String, Object> tempMainMap;
for (Map<String, Object> map : modelList) {
for (XkModelCusCheckFiledConfig config : configs) {
int viewType = config.getModelFieldNameList().get(0).getViewType();
boolean isMain = viewType == 0;
tempMainMap = isMain ? map : mainMap;
Bi4Function<XkModelCusCheckFiledConfig, XkModelCusCheckFiledGroupConfig, Map<String, Object>, Map<String, Object>, Boolean> function = CheckRuleMethodUtil.CHECK_RULE_MAP.get(config.getCheckRule());
if(function == null){
continue;
}
Boolean check = function.apply(config, null, tempMainMap, map);
if(!check){
String fieldName = config.getModelFieldNameList().get(0).getFieldName();
String mainId = Util.null2DefaultStr(tempMainMap.get("id"), "");
String itemId = Util.null2DefaultStr(map.get("id"), "");
CheckErrorInfo errorInfo = CheckErrorInfo.builder()
.errorMsg(config.getErrorMsg())
.errorFieldName(fieldName)
.tableName(tableName)
.dataId(isMain ? mainId : itemId)
.currentValue(map.get(fieldName))
.mainId(mainId)
.build();
result.add(errorInfo);
}
}
}
}
}

View File

@ -0,0 +1,301 @@
package weaver.xuanran.wang.xk_hospital.model_check.util;
import aiyh.utils.ScriptUtil;
import aiyh.utils.Util;
import aiyh.utils.annotation.MethodRuleNo;
import aiyh.utils.excention.CustomerException;
import aiyh.utils.function.Bi4Function;
import aiyh.utils.tool.cn.hutool.core.util.StrUtil;
import org.apache.commons.collections.CollectionUtils;
import org.apache.log4j.Logger;
import weaver.general.TimeUtil;
import weaver.xuanran.wang.xk_hospital.model_check.entity.ModelFieldInfo;
import weaver.xuanran.wang.xk_hospital.model_check.entity.XkModelCusCheckFiledConfig;
import weaver.xuanran.wang.xk_hospital.model_check.entity.XkModelCusCheckFiledGroupConfig;
import weaver.xuanran.wang.xk_hospital.model_check.mapper.XkModelCusCheckMapper;
import java.lang.reflect.Method;
import java.util.*;
/**
* <h1></h1>
*
* <p>create: 2023/6/14 18:30</p>
*
* @author youHong.ai
*/
public class CheckRuleMethodUtil {
private static final Logger log = Util.getLogger();
private static final XkModelCusCheckMapper mapper = Util.getMapper(XkModelCusCheckMapper.class);
public static final Map<Integer,
Bi4Function<XkModelCusCheckFiledConfig, XkModelCusCheckFiledGroupConfig, Map<String, Object>, Map<String, Object>, Boolean>
> CHECK_RULE_MAP = new HashMap<>(8);
private static final CusJexlFunctions CUS_SCRIPT_FUN = new CusJexlFunctions();
static {
try {
Class<CheckRuleMethodUtil> checkRuleMethodUtilClass = CheckRuleMethodUtil.class;
Method[] methods = checkRuleMethodUtilClass.getDeclaredMethods();
for (Method method : methods) {
if (method.isAnnotationPresent(MethodRuleNo.class)) {
MethodRuleNo annotation = method.getAnnotation(MethodRuleNo.class);
int value = annotation.value();
CHECK_RULE_MAP.put(value, (filedConfig, groupConfig, mainMap, detailMap) -> {
try {
return (Boolean) method.invoke(null, filedConfig, groupConfig, mainMap,detailMap);
} catch (Exception e) {
log.error("调用CheckRuleMethodUtil类中注解方法失败" + Util.getErrString(e));
throw new RuntimeException(e);
}
});
}
}
} catch (Exception e) {
log.error("初始化CheckRuleMethodUtil失败" + Util.getErrString(e));
}
}
@MethodRuleNo(value = 0, desc = "不为空")
private static boolean noNull(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
boolean check = true;
for (ModelFieldInfo fieldInfo : filedConfig.getModelFieldNameList()) {
int mainOrDetail = fieldInfo.getViewType();
if(mainOrDetail == 0){
check = StrUtil.isNotBlank(Util.null2DefaultStr(mainMap.get(fieldInfo.getFieldName()),""));
}else {
check = StrUtil.isNotBlank(Util.null2DefaultStr(detailMap.get(fieldInfo.getFieldName()),""));
}
}
return check;
}
// @MethodRuleNo(value = 0, desc = "整数类型")
private static boolean isNumber(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
try {
for (ModelFieldInfo fieldInfo : filedConfig.getModelFieldNameList()) {
int mainOrDetail = fieldInfo.getViewType();
if(mainOrDetail == 0) {
Integer.parseInt(Util.null2DefaultStr(mainMap.get(fieldInfo.getFieldName()), ""));
}else {
Integer.parseInt(Util.null2DefaultStr(detailMap.get(fieldInfo.getFieldName()), ""));
}
}
return true;
} catch (Exception e) {
return false;
}
}
// @MethodRuleNo(value = 2, desc = "小数类型")
private static boolean isDouble(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
try {
for (ModelFieldInfo fieldInfo : filedConfig.getModelFieldNameList()) {
int mainOrDetail = fieldInfo.getViewType();
if (mainOrDetail == 0) {
Double.parseDouble(Util.null2DefaultStr(mainMap.get(fieldInfo.getFieldName()), ""));
} else {
Double.parseDouble(Util.null2DefaultStr(detailMap.get(fieldInfo.getFieldName()), ""));
}
}
return true;
} catch (Exception e) {
return false;
}
}
@MethodRuleNo(value = 1, desc = "字段长度")
private static boolean isEnumerate(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
boolean check = true;
for (ModelFieldInfo fieldInfo : filedConfig.getModelFieldNameList()) {
if (fieldInfo.getViewType() == 0) {
check = (boolean) ScriptUtil.invokeScript(fieldInfo.getFieldName() + ".length() " + filedConfig.getCheckExpression(), mainMap);
}else {
check = (boolean) ScriptUtil.invokeScript(fieldInfo.getFieldName() + ".length() " + filedConfig.getCheckExpression(), detailMap);
}
}
return check;
}
@MethodRuleNo(value = 2, desc = "自定义sql存在值")
private static boolean customerSqlHasValue(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
String sql = sqlHandle(filedConfig.getCustomerValue());
if(StrUtil.isBlank(sql)){
return true;
}
return mapper.queryCusSqlCount(sql, mainMap, detailMap) > 0;
}
@MethodRuleNo(value = 3, desc = "自定义sql校验表达式")
private static boolean customerSqlCheck(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
String expression = filedConfig.getCheckExpression();
if(StrUtil.isBlank(expression)){
return true;
}
String sql = sqlHandle(filedConfig.getCustomerValue());
if(StrUtil.isBlank(sql)){
return true;
}
Map<String, Object> valueMap = mapper.queryCusSqlMap(sql, mainMap, detailMap);
try {
return (Boolean) ScriptUtil.invokeScript(expression, valueMap, CUS_SCRIPT_FUN);
}catch (Exception e){
log.error("自定义表达式执行失败! " + e.getMessage());
Util.logErrorStr(e);
return false;
}
}
// @MethodRuleNo(value = 6, desc = "自定义表达式")
private static boolean checkCustomerExpression(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
// String expression = Util.sbc2dbcCase(filedConfig.getCheckExpression());
// if(StrUtil.isBlank(expression)){
// return true;
// }
// try {
// if(filedConfig.getMainOrDetail() == 0){
// return (Boolean)ScriptUtil.invokeScript(expression, mainMap, CUS_SCRIPT_FUN);
// } else {
// return (Boolean)ScriptUtil.invokeScript(expression, detailMap, CUS_SCRIPT_FUN);
// }
// }catch (Exception e){
// log.error("自定义表达式执行失败! " + e.getMessage());
// Util.logErrorStr(e);
// return false;
// }
return true;
}
@MethodRuleNo(value = 4, desc = "两个日期相差月数")
private static boolean twoDateSubMonth(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
List<ModelFieldInfo> fieldNameList = filedConfig.getModelFieldNameList();
if(!checkFieldConf(fieldNameList)){
return false;
}
Map<String, Object> dateMap = parse2DateMap(filedConfig, fieldNameList, mainMap, detailMap);
String scriptStr = "CusJexlFunctions.twoDateSubNoFormat(beginDate,endDate, 1) " + filedConfig.getCheckExpression();
return (boolean) ScriptUtil.invokeScript(scriptStr, dateMap);
}
@MethodRuleNo(value = 5, desc = "自定义校验")
private static boolean checkCustomerInterface(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
String customerValue = filedConfig.getCustomerValue();
if (StrUtil.isBlank(customerValue)) {
return true;
}
Map<String, String> pathMap = Util.parseCusInterfacePathParam(customerValue);
String classPath = pathMap.remove("_ClassPath");
CusCheckRuleInterface instance = Util.getClassInstance(classPath, CusCheckRuleInterface.class);
try {
return instance.checkRule(filedConfig, groupConfig, mainMap, detailMap, pathMap);
} catch (Exception e){
log.error("自定义接口校验error! : " + e.getMessage());
Util.logErrorStr(e);
return false;
}
}
@MethodRuleNo(value = 6, desc = "第一个日期字段是否早于第二个日期字段")
private static boolean compare2Date(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap) {
List<ModelFieldInfo> fieldNameList = filedConfig.getModelFieldNameList();
if(!checkFieldConf(fieldNameList)){
return false;
}
Map<String, Object> dateMap = parse2DateMap(filedConfig, fieldNameList, mainMap, detailMap);
String scriptStr = "CusJexlFunctions.compare2Date(beginDate,endDate) " + filedConfig.getCheckExpression();
return (boolean) ScriptUtil.invokeScript(scriptStr, dateMap);
}
public static String sqlHandle(String cusSql){
String customerValue = Util.sbc2dbcCase(cusSql);
if(StrUtil.isBlank(customerValue)){
return "";
}
if(!customerValue.startsWith("select ")){
return "";
}
return customerValue;
}
public static boolean checkFieldConf(List<ModelFieldInfo> fieldNameList) {
if (CollectionUtils.isEmpty(fieldNameList) || fieldNameList.size() > 2) {
Util.getLogger().error("校验规则选择日期相差月数时, 表单字段不能超过2个!");
return false;
}
return true;
}
public static Map<String, Object> parse2DateMap(XkModelCusCheckFiledConfig filedConfig,
List<ModelFieldInfo> fieldNameList,
Map<String, Object> mainMap,
Map<String, Object> detailMap){
String beginDate = "";
String endDate = "";
Map<String, Object> dateMap = new HashMap<>();
// 如果只勾选了一个字段
if(fieldNameList.size() == 1){
String cusWhere = filedConfig.getCusWhere();
if(StrUtil.isNotBlank(cusWhere)){
String sql = sqlHandle(cusWhere);
endDate = mapper.queryCusSqlDate(sql, mainMap, detailMap);
if(StrUtil.isBlank(endDate)){
endDate = TimeUtil.getCurrentDateString();
}
}else {
endDate = TimeUtil.getCurrentDateString();
}
}else {
for (int i = 0; i < fieldNameList.size(); i++) {
ModelFieldInfo fieldInfo = fieldNameList.get(i);
String date;
if (fieldInfo.getViewType() == 0) {
date = Util.null2DefaultStr(mainMap.get(fieldInfo.getFieldName()),"");
}else {
date = Util.null2DefaultStr(detailMap.get(fieldInfo.getFieldName()),"");
}
if(i == 0){
beginDate = date;
}else {
endDate = date;
}
}
}
dateMap.put("endDate", endDate);
dateMap.put("beginDate", beginDate);
return dateMap;
}
}

View File

@ -0,0 +1,20 @@
package weaver.xuanran.wang.xk_hospital.model_check.util;
import weaver.xuanran.wang.xk_hospital.model_check.entity.XkModelCusCheckFiledConfig;
import weaver.xuanran.wang.xk_hospital.model_check.entity.XkModelCusCheckFiledGroupConfig;
import java.util.Map;
/**
* <h1></h1>
*
* @author xuanran.wang
* @date 2023/7/25 13:16
*/
public interface CusCheckRuleInterface {
boolean checkRule(XkModelCusCheckFiledConfig filedConfig,
XkModelCusCheckFiledGroupConfig groupConfig,
Map<String, Object> mainMap,
Map<String, Object> detailMap,
Map<String, String> pathMap);
}

View File

@ -0,0 +1,239 @@
package weaver.xuanran.wang.xk_hospital.model_check.util;
import aiyh.utils.Util;
import aiyh.utils.interfaces.script_util.CusScriptFunInterface;
import aiyh.utils.tool.cn.hutool.core.util.StrUtil;
import aiyh.utils.tool.org.apache.commons.jexl3.JexlException;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.time.temporal.ChronoUnit;
/**
* <h1></h1>
*
* @author xuanran.wang
* @date 2023/7/25 16:23
*/
public class CusJexlFunctions implements CusScriptFunInterface {
/**
* <h1></h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:15
* @param str
* @return
**/
public BigDecimal parseDecimal(String str) {
try {
if(StrUtil.isBlank(str)){
return new BigDecimal("0");
}
return new BigDecimal(str);
} catch (NumberFormatException e) {
throw new JexlException(null, "Invalid number format: " + str);
}
}
/**
* <h1></h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:15
* @param dateStr yyyy-MM-dd
* @return
**/
public int parsNormalDateMonth(String dateStr){
return parseDateMonth(dateStr, "yyyy-MM-dd");
}
/**
* <h1></h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:16
* @param dateStr
* @param format
* @return
**/
public int parseDateMonth(String dateStr, String format) {
try {
LocalDate currentDate = LocalDate.now();
if(StrUtil.isBlank(dateStr)){
return currentDate.getMonthValue();
}
currentDate = parseDateStr2LocalDate(dateStr, format);
return currentDate.getMonthValue();
} catch (Exception e) {
throw new JexlException(null, "Invalid date format error! dateStr : " + dateStr + " ,format : " + format);
}
}
/**
* <h1>yyyy-MM-dd</h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:17
* @param dateStr
* @return -
**/
public int normalDateStrSubCurrentMonth(String dateStr){
int dateMonth = parseDateMonth(dateStr, "yyyy-MM-dd");
return LocalDate.now().getMonthValue() - dateMonth;
}
/**
* <h1></h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:19
* @param dateStr
* @param format
* @return -
**/
public int dateStrSubCurrentMonth(String dateStr, String format){
int dateMonth = parseDateMonth(dateStr, format);
return LocalDate.now().getMonthValue() - dateMonth;
}
/**
* <h1>yyyy-MM-dd</h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:17
* @param dateStr
* @return -
**/
public int normalDateStrSubCurrentMonthAbs(String dateStr){
return Math.abs(normalDateStrSubCurrentMonth(dateStr));
}
/**
* <h1></h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:19
* @param dateStr
* @param format
* @return -
**/
public int dateStrSubCurrentMonthAbs(String dateStr, String format){
return Math.abs(dateStrSubCurrentMonth(dateStr, format));
}
/**
* <h1></h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:20
* @param dateStr
* @param format
* @return LocalDate
**/
public LocalDate parseDateStr2LocalDate(String dateStr, String format){
try {
if(StrUtil.isBlank(format)){
format = "yyyy-MM-dd";
}
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(format);
return LocalDate.parse(dateStr, formatter);
}catch (Exception e){
Util.getLogger().error("解析LocalDate error!" + e.getMessage());
return LocalDate.now();
}
}
/**
* <h1></h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:21
* @param firstDate
* @param secondDate
* @return
**/
public boolean compare2Date(String firstDate, String secondDate){
try {
LocalDate firstLocalDate = parseDateStr2LocalDate(firstDate, "");
LocalDate secondLocalDate = parseDateStr2LocalDate(secondDate, "");
return firstLocalDate.isBefore(secondLocalDate);
}catch (Exception e){
Util.getLogger().error("解析LocalDate error!" + e.getMessage());
return true;
}
}
/**
* <h1></h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:21
* @param firstDate
* @param firstDateFormat
* @param secondDate
* @param secondDateFormat
* @return
**/
public boolean compare2Date(String firstDate,
String firstDateFormat,
String secondDate,
String secondDateFormat){
try {
LocalDate firstLocalDate = parseDateStr2LocalDate(firstDate, firstDateFormat);
LocalDate secondLocalDate = parseDateStr2LocalDate(secondDate, secondDateFormat);
return firstLocalDate.isBefore(secondLocalDate);
}catch (Exception e){
Util.getLogger().error("解析LocalDate error!" + e.getMessage());
return true;
}
}
/**
* <h1>yyyy-MM-dd</h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:49
* @param firstDate
* @param secondDate
* @param type
* @return
**/
public long twoDateSubNoFormat(String firstDate, String secondDate, int type){
return twoDateSub(firstDate,"", secondDate, "", type);
}
/**
* <h1></h1>
* @author xuanran.wang
* @dateTime 2023/7/26 10:51
* @param firstDate
* @param firstDateFormat
* @param secondDate
* @param secondDateFormat
* @param type 0: , 1: , 2: , 3: , 4: , 5:
* @return
**/
public long twoDateSub(String firstDate,
String firstDateFormat,
String secondDate,
String secondDateFormat,
int type){
LocalDate firstLocalDate = parseDateStr2LocalDate(firstDate, firstDateFormat);
LocalDate secondLocalDate = parseDateStr2LocalDate(secondDate, secondDateFormat);
switch (type){
case 0:{
return ChronoUnit.YEARS.between(firstLocalDate, secondLocalDate);
}
case 1:{
return ChronoUnit.MONTHS.between(firstLocalDate, secondLocalDate);
}
case 2:{
return ChronoUnit.DAYS.between(firstLocalDate, secondLocalDate);
}
case 3:{
return ChronoUnit.HOURS.between(firstLocalDate, secondLocalDate);
}
case 4:{
return ChronoUnit.MINUTES.between(firstLocalDate, secondLocalDate);
}
case 5:{
return ChronoUnit.SECONDS.between(firstLocalDate, secondLocalDate);
}
default: {
return 0;
}
}
}
}

View File

@ -0,0 +1,66 @@
package xuanran.wang.xk_hospital.test;
import aiyh.utils.ScriptUtil;
import aiyh.utils.tool.org.apache.commons.jexl3.*;
import basetest.BaseTest;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.collections.CollectionUtils;
import org.junit.Test;
import weaver.general.TimeUtil;
import weaver.xuanran.wang.xk_hospital.model_check.entity.XkModelCusCheckConfig;
import weaver.xuanran.wang.xk_hospital.model_check.entity.XkModelCusCheckFiledConfig;
import weaver.xuanran.wang.xk_hospital.model_check.service.XkModelCusCheckService;
import weaver.xuanran.wang.xk_hospital.model_check.util.CusJexlFunctions;
import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* <h1></h1>
*
* @author xuanran.wang
* @date 2023/7/24 14:28
*/
public class XkHospitalCheckModelTest extends BaseTest {
private final XkModelCusCheckService service = new XkModelCusCheckService();
private static final CusJexlFunctions FUN = new CusJexlFunctions();
@Test
public void testA(){
HashMap<String, Object> map = new HashMap<>();
map.put("a","测试");
map.put("b", "112094.28");
System.out.println(map);
boolean res = (boolean) ScriptUtil.invokeScript("a.length() > 3", map, FUN);
System.out.println(res);
HashMap<String, Object> map2 = new HashMap<>();
map2.put("str", "数据卡健身卡净空法师大法师");
map2.put("currentDate", new Date());
map2.put("month", 3);
boolean res2 = (boolean)ScriptUtil.invokeScript("currentDate.getMonth() - month > 1", map2);
System.out.println(res2);
}
@Test
public void testB(){
List<XkModelCusCheckFiledConfig> configList = service.getFieldCheckRuleConfigList();
System.out.println(JSONObject.toJSONString(configList));
service.checkModelData(configList);
// service.checkModelData(config);
}
@Test
public void testC(){
System.out.println(FUN.compare2Date("2023-07-26", "2023-07-27"));
System.out.println(FUN.normalDateStrSubCurrentMonthAbs("2023-08-01"));
System.out.println(FUN.twoDateSubNoFormat("2023-08-01", "2023-09-01", 2));
}
}

View File

@ -117,4 +117,12 @@ public class XkHospitalTest extends BaseTest {
Util.null2DefaultStr(null,"");
service.async("4bce0693734d","common", map);
}
@Test
public void testD(){
String json = "{\"data\":[{\"ID\":\"2\",\"GroupID\":\"test_yl_01\",\"Wards\":[]},{\"ID\":\"1\",\"GroupID\":\"test_yl_01\",\"Wards\":[{\"ID\":\"1\",\"WardCode\":\"bq_01\",\"WardName\":\"病区名称01_1\"},{\"ID\":\"2\",\"WardCode\":\"bq_02\",\"WardName\":\"病区名称01_2\"},{\"ID\":\"3\",\"WardCode\":\"bq_03\",\"WardName\":\"病区名称0_2_3\"},{\"ID\":\"4\",\"WardCode\":\"bq_04\",\"WardName\":\"病区名称02_1_3\"}]}]}\n";
System.out.println(json);
Map map = JSONObject.parseObject(json, Map.class);
service.async("testarr","common", map);
}
}