kimi
2020-05-18 c8aee7b9bfd79cfd741d7e5692520f4f51a31a86
src/main/java/com/highdatas/mdm/controller/SysAssembleDbTableController.java
@@ -20,7 +20,6 @@
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import java.sql.Connection;
import java.text.MessageFormat;
import java.util.Date;
import java.util.List;
@@ -161,20 +160,24 @@
        } else if (type.equals(SysAssembleTableType.table)) {
            tableName = sysAssembleDbTable.getTableName();
        }
        Set<String> matcher = DbUtils.matcher(filter);
        for (String code : matcher) {
            SysAssembleParams sysAssembleParams = paramsService.selectOne(new EntityWrapper<SysAssembleParams>().eq(Constant.PARENT_ID, assembleId).eq(Constant.Code, code));
            if (sysAssembleParams == null){
                return Result.error(new CodeMsg(6009, assembleId + "有变量未匹配到:"+ code));
        if (StringUtils.isEmpty(filter)) {
            filter = Constant.WHERE_DEFAULT;
        } else {
            Set<String> matcher = DbUtils.matcher(filter);
            for (String code : matcher) {
                SysAssembleParams sysAssembleParams = paramsService.selectOne(new EntityWrapper<SysAssembleParams>().eq(Constant.PARENT_ID, assembleId).eq(Constant.Code, code));
                if (sysAssembleParams == null){
                    return Result.error(new CodeMsg(6009, assembleId + "有变量未匹配到:"+ code));
                }
                String val = sysAssembleParams.getVal();
                if (StringUtils.isEmpty(val)) {
                    return Result.error(new CodeMsg(6009, assembleId + "有变量未获取到值:"+ code));
                }
                val = DbUtils.quotedStr(val);
                filter = filter.replace(DbUtils.assemblParam(code), val);
            }
            String val = sysAssembleParams.getVal();
            if (StringUtils.isEmpty(val)) {
                return Result.error(new CodeMsg(6009, assembleId + "有变量未获取到值:"+ code));
            }
            val = DbUtils.quotedStr(val);
            filter = filter.replace(DbUtils.assemblParam(code), val);
        }
        String runSqlTemplate = null;
        if (type.equals(SysAssembleTableType.table)){
            runSqlTemplate = Constant.selectFieldTableTemplate;