diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java index 7f389ec..59fc808 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java @@ -2,7 +2,7 @@ /** * @ClassName ResTypeEnums - * @Description TODO + * @Description TODO * @Author lenovo * @Date 2020/9/18 18:08 * @Version 1.0 diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java index 7f389ec..59fc808 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java @@ -2,7 +2,7 @@ /** * @ClassName ResTypeEnums - * @Description TODO + * @Description TODO * @Author lenovo * @Date 2020/9/18 18:08 * @Version 1.0 diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java index 7d5c105..efa941b 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java @@ -24,10 +24,10 @@ /** *

* 共享交换数据集配置表 - * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 + * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 *

* - * @author stylefeng123 + * @author stylefeng123 * @since 2020-10-19 */ @Service diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java index 7f389ec..59fc808 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java @@ -2,7 +2,7 @@ /** * @ClassName ResTypeEnums - * @Description TODO + * @Description TODO * @Author lenovo * @Date 2020/9/18 18:08 * @Version 1.0 diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java index 7d5c105..efa941b 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java @@ -24,10 +24,10 @@ /** *

* 共享交换数据集配置表 - * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 + * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 *

* - * @author stylefeng123 + * @author stylefeng123 * @since 2020-10-19 */ @Service diff --git a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr index f9ba53e..02363d6 100644 --- a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr +++ b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr @@ -435,1224 +435,8 @@ - - 163_casic_optmonitoring - 11.100.6.163 - MYSQL - Native - casic_optmonitoring - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 163_casic_industrial_economy - 11.100.6.163 - MYSQL - Native - casic_industrial_economy - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 企业信息服务接口 - 解析code信息 - Y - - - 生成随机数 - 读取项目任务增量时间 - Y - - - 解析code信息 - 企业数据同步更新 - Y - - - 参数转换 - 企业信息服务接口 - Y - - - 读取项目任务增量时间 - 参数转换 - Y - - - 企业信息服务接口 - Rest - - Y - - 1 - - none - - - JSON - GET - http://11.100.5.8:8080/platformbigdata/modelservlet?appkey=53a21bdd-626a-4b3b-9170-0c79498193e6&id=155&param_dsid=1138&flag=97&format=json&&param_PAGESIZE=100000 - Y - N - - HOST - - - Encrypted - - - N - - Encrypted - - - - - - - - result - - - - - - - - - - - - - - 544 - 160 - Y - - - - 企业数据同步更新 - InsertUpdate - - Y - - 1 - - none - - - 163_casic_industrial_economy - 500 - N - - casic_industrial_economy - enterprise_info
- - zch - zch - = - - - - zch - zch - N - - - qylx - qylx - Y - - - tzze - tzze - Y - - - zczb - zczb - Y - - - yzbm - yzbm - Y - - - qymc - qymc - Y - - - fddbr - fddbr - Y - - - sszb - sszb - Y - - - bz - bz - Y - - - gq - gq - Y - - - djjg - djjg - Y - - - djjgbm - djjgbm - Y - - - qyzt - qyzt - Y - - - hyml - hyml - Y - - - hydm - hydm - Y - - - czfs - czfs - Y - - - clrq - clrq - Y - - - dzyj - dzyj - Y - - - ybjyxm - ybjyxm - Y - - - xkjyxm - xkjyxm - Y - - - sdjggss - sdjggss - Y - - - gxjg - gxjg - Y - - - jyqxq - jyqxq - Y - - - jyqxz - jyqxz - Y - - - zs - zs - Y - - - sfzrd - sfzrd - Y - - - sfgsq - sfgsq - Y - - - hzrq - hzrq - Y - - - gpz - gpz - Y - - - sjly - sjly - Y - - - sfcqyx - sfcqyx - Y - - - dabh - dabh - Y - - - tyshxydm - tyshxydm - Y - - - updatetime - updatetime - Y - - - - - - - - - - - - 816 - 160 - Y - - - - 参数转换 - UserDefinedJavaClass - - Y - - 1 - - none - - - - - TRANSFORM_CLASS - Processor - // 生成的代码片段 -public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws Exception { - if (first) { - first = false; - } - - Object[] r = getRow(); - - - if (r == null) { - setOutputDone(); - return false; - } - - r = createOutputRow(r, data.outputRowMeta.size()); - String condition= get(Fields.In, "REST_RULE").getString(r); - String host= get(Fields.In, "HOST").getString(r); - String value= get(Fields.In, "REST_PARAMS").getString(r); - Object[] params = value.split(","); - String outcondition =host+"&param_condition="+java.net.URLEncoder.encode(String.format(condition,params),"UTF-8"); - get(Fields.Out,"HOST").setValue(r,outcondition); - putRow(data.outputRowMeta, r); - - return true; -} - - - - - - N - - - - - - - - - - - - - 384 - 160 - Y - - - - 生成随机数 - RandomValue - - Y - - 1 - - none - - - - - - - - - - - - - - 80 - 160 - Y - - - - 解析code信息 - JsonInput - - Y - - 1 - - none - - - N - - N - N - N - N - N - Y - Y - Y - - - - - - N - N - - - - zch - $..ZCH - None - - - - - -1 - -1 - none - N - - - qylx - $..QYLX - None - - - - - -1 - -1 - none - N - - - tzze - $..TZZE - None - - - - - -1 - -1 - none - N - - - zczb - $..ZCZB - None - - - - - -1 - -1 - none - N - - - yzbm - $..YZBM - None - - - - - -1 - -1 - none - N - - - qymc - $..QYMC - None - - - - - -1 - -1 - none - N - - - fddbr - $..FDDBR - None - - - - - -1 - -1 - none - N - - - sszb - $..SSZB - None - - - - - -1 - -1 - none - N - - - bz - $..BZ - None - - - - - -1 - -1 - none - N - - - gq - $..GQ - None - - - - - -1 - -1 - none - N - - - djjg - $..DJJG - None - - - - - -1 - -1 - none - N - - - djjgbm - $..DJJGBM - None - - - - - -1 - -1 - none - N - - - qyzt - $..QYZT - None - - - - - -1 - -1 - none - N - - - hyml - $..HYML - None - - - - - -1 - -1 - none - N - - - hydm - $..HYDM - None - - - - - -1 - -1 - none - N - - - czfs - $..CZFS - None - - - - - -1 - -1 - none - N - - - clrq - $..CLRQ - None - - - - - -1 - -1 - none - N - - - dzyj - $..DZYJ - None - - - - - -1 - -1 - none - N - - - ybjyxm - $..YBJYXM - None - - - - - -1 - -1 - none - N - - - xkjyxm - $..XKJYXM - None - - - - - -1 - -1 - none - N - - - sdjggss - $..SDJGGSS - None - - - - - -1 - -1 - none - N - - - gxjg - $..GXJG - None - - - - - -1 - -1 - none - N - - - jyqxq - $..JYQXQ - None - - - - - -1 - -1 - none - N - - - jyqxz - $..JYQXZ - None - - - - - -1 - -1 - none - N - - - zs - $..ZS - None - - - - - -1 - -1 - none - N - - - sfzrd - $..SFZRD - None - - - - - -1 - -1 - none - N - - - sfgsq - $..SFGSQ - None - - - - - -1 - -1 - none - N - - - hzrq - $..HZRQ - None - - - - - -1 - -1 - none - N - - - gpz - $..GPZ - None - - - - - -1 - -1 - none - N - - - sjly - $..SJLY - None - - - - - -1 - -1 - none - N - - - sfcqyx - $..SFCQYX - None - - - - - -1 - -1 - none - N - - - dabh - $..DABH - None - - - - - -1 - -1 - none - N - - - tyshxydm - $..TYSHXYDM - None - - - - - -1 - -1 - none - N - - - updatetime - $..UPDATETIME - None - - - - - -1 - -1 - none - N - - - 0 - Y - N - result - - - - - - - - - - - - - - - - - - 704 - 160 - Y - - - - 读取项目任务增量时间 - TableInput - - Y - - 1 - - none - - - 163_casic_optmonitoring - SELECT - ID -, CODE,REST_RULE,REST_PARAMS -, TITLE,concat(HOST,DEFAULT_PARAMS) as HOST -, REST_PARAMS,DATE_FORMAT(NOW(),'%Y-%m-%d %H:%i:%s') as CURR_INCREMENT_DATE -FROM casic_optmonitoring.kettle_increment_config where code='entprise' - 0 - - N - N - N - N - - - Integer - normal - ID - 15 - 0 - 读取项目任务增量时间 - ID - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CODE - 32 - -1 - 读取项目任务增量时间 - CODE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_RULE - 255 - -1 - 读取项目任务增量时间 - REST_RULE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_PARAMS - 255 - -1 - 读取项目任务增量时间 - REST_PARAMS - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - TITLE - 64 - -1 - 读取项目任务增量时间 - TITLE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - HOST - 319 - -1 - 读取项目任务增量时间 - HOST - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - INCREMENT_DATE - 64 - -1 - 读取项目任务增量时间 - INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CURR_INCREMENT_DATE - 24 - -1 - 读取项目任务增量时间 - CURR_INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - - - - - - - - - - 224 - 160 - Y - - diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java index 7f389ec..59fc808 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java @@ -2,7 +2,7 @@ /** * @ClassName ResTypeEnums - * @Description TODO + * @Description TODO * @Author lenovo * @Date 2020/9/18 18:08 * @Version 1.0 diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java index 7d5c105..efa941b 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java @@ -24,10 +24,10 @@ /** *

* 共享交换数据集配置表 - * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 + * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 *

* - * @author stylefeng123 + * @author stylefeng123 * @since 2020-10-19 */ @Service diff --git a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr index f9ba53e..02363d6 100644 --- a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr +++ b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr @@ -435,1224 +435,8 @@ - - 163_casic_optmonitoring - 11.100.6.163 - MYSQL - Native - casic_optmonitoring - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 163_casic_industrial_economy - 11.100.6.163 - MYSQL - Native - casic_industrial_economy - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 企业信息服务接口 - 解析code信息 - Y - - - 生成随机数 - 读取项目任务增量时间 - Y - - - 解析code信息 - 企业数据同步更新 - Y - - - 参数转换 - 企业信息服务接口 - Y - - - 读取项目任务增量时间 - 参数转换 - Y - - - 企业信息服务接口 - Rest - - Y - - 1 - - none - - - JSON - GET - http://11.100.5.8:8080/platformbigdata/modelservlet?appkey=53a21bdd-626a-4b3b-9170-0c79498193e6&id=155&param_dsid=1138&flag=97&format=json&&param_PAGESIZE=100000 - Y - N - - HOST - - - Encrypted - - - N - - Encrypted - - - - - - - - result - - - - - - - - - - - - - - 544 - 160 - Y - - - - 企业数据同步更新 - InsertUpdate - - Y - - 1 - - none - - - 163_casic_industrial_economy - 500 - N - - casic_industrial_economy - enterprise_info
- - zch - zch - = - - - - zch - zch - N - - - qylx - qylx - Y - - - tzze - tzze - Y - - - zczb - zczb - Y - - - yzbm - yzbm - Y - - - qymc - qymc - Y - - - fddbr - fddbr - Y - - - sszb - sszb - Y - - - bz - bz - Y - - - gq - gq - Y - - - djjg - djjg - Y - - - djjgbm - djjgbm - Y - - - qyzt - qyzt - Y - - - hyml - hyml - Y - - - hydm - hydm - Y - - - czfs - czfs - Y - - - clrq - clrq - Y - - - dzyj - dzyj - Y - - - ybjyxm - ybjyxm - Y - - - xkjyxm - xkjyxm - Y - - - sdjggss - sdjggss - Y - - - gxjg - gxjg - Y - - - jyqxq - jyqxq - Y - - - jyqxz - jyqxz - Y - - - zs - zs - Y - - - sfzrd - sfzrd - Y - - - sfgsq - sfgsq - Y - - - hzrq - hzrq - Y - - - gpz - gpz - Y - - - sjly - sjly - Y - - - sfcqyx - sfcqyx - Y - - - dabh - dabh - Y - - - tyshxydm - tyshxydm - Y - - - updatetime - updatetime - Y - - - - - - - - - - - - 816 - 160 - Y - - - - 参数转换 - UserDefinedJavaClass - - Y - - 1 - - none - - - - - TRANSFORM_CLASS - Processor - // 生成的代码片段 -public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws Exception { - if (first) { - first = false; - } - - Object[] r = getRow(); - - - if (r == null) { - setOutputDone(); - return false; - } - - r = createOutputRow(r, data.outputRowMeta.size()); - String condition= get(Fields.In, "REST_RULE").getString(r); - String host= get(Fields.In, "HOST").getString(r); - String value= get(Fields.In, "REST_PARAMS").getString(r); - Object[] params = value.split(","); - String outcondition =host+"&param_condition="+java.net.URLEncoder.encode(String.format(condition,params),"UTF-8"); - get(Fields.Out,"HOST").setValue(r,outcondition); - putRow(data.outputRowMeta, r); - - return true; -} - - - - - - N - - - - - - - - - - - - - 384 - 160 - Y - - - - 生成随机数 - RandomValue - - Y - - 1 - - none - - - - - - - - - - - - - - 80 - 160 - Y - - - - 解析code信息 - JsonInput - - Y - - 1 - - none - - - N - - N - N - N - N - N - Y - Y - Y - - - - - - N - N - - - - zch - $..ZCH - None - - - - - -1 - -1 - none - N - - - qylx - $..QYLX - None - - - - - -1 - -1 - none - N - - - tzze - $..TZZE - None - - - - - -1 - -1 - none - N - - - zczb - $..ZCZB - None - - - - - -1 - -1 - none - N - - - yzbm - $..YZBM - None - - - - - -1 - -1 - none - N - - - qymc - $..QYMC - None - - - - - -1 - -1 - none - N - - - fddbr - $..FDDBR - None - - - - - -1 - -1 - none - N - - - sszb - $..SSZB - None - - - - - -1 - -1 - none - N - - - bz - $..BZ - None - - - - - -1 - -1 - none - N - - - gq - $..GQ - None - - - - - -1 - -1 - none - N - - - djjg - $..DJJG - None - - - - - -1 - -1 - none - N - - - djjgbm - $..DJJGBM - None - - - - - -1 - -1 - none - N - - - qyzt - $..QYZT - None - - - - - -1 - -1 - none - N - - - hyml - $..HYML - None - - - - - -1 - -1 - none - N - - - hydm - $..HYDM - None - - - - - -1 - -1 - none - N - - - czfs - $..CZFS - None - - - - - -1 - -1 - none - N - - - clrq - $..CLRQ - None - - - - - -1 - -1 - none - N - - - dzyj - $..DZYJ - None - - - - - -1 - -1 - none - N - - - ybjyxm - $..YBJYXM - None - - - - - -1 - -1 - none - N - - - xkjyxm - $..XKJYXM - None - - - - - -1 - -1 - none - N - - - sdjggss - $..SDJGGSS - None - - - - - -1 - -1 - none - N - - - gxjg - $..GXJG - None - - - - - -1 - -1 - none - N - - - jyqxq - $..JYQXQ - None - - - - - -1 - -1 - none - N - - - jyqxz - $..JYQXZ - None - - - - - -1 - -1 - none - N - - - zs - $..ZS - None - - - - - -1 - -1 - none - N - - - sfzrd - $..SFZRD - None - - - - - -1 - -1 - none - N - - - sfgsq - $..SFGSQ - None - - - - - -1 - -1 - none - N - - - hzrq - $..HZRQ - None - - - - - -1 - -1 - none - N - - - gpz - $..GPZ - None - - - - - -1 - -1 - none - N - - - sjly - $..SJLY - None - - - - - -1 - -1 - none - N - - - sfcqyx - $..SFCQYX - None - - - - - -1 - -1 - none - N - - - dabh - $..DABH - None - - - - - -1 - -1 - none - N - - - tyshxydm - $..TYSHXYDM - None - - - - - -1 - -1 - none - N - - - updatetime - $..UPDATETIME - None - - - - - -1 - -1 - none - N - - - 0 - Y - N - result - - - - - - - - - - - - - - - - - - 704 - 160 - Y - - - - 读取项目任务增量时间 - TableInput - - Y - - 1 - - none - - - 163_casic_optmonitoring - SELECT - ID -, CODE,REST_RULE,REST_PARAMS -, TITLE,concat(HOST,DEFAULT_PARAMS) as HOST -, REST_PARAMS,DATE_FORMAT(NOW(),'%Y-%m-%d %H:%i:%s') as CURR_INCREMENT_DATE -FROM casic_optmonitoring.kettle_increment_config where code='entprise' - 0 - - N - N - N - N - - - Integer - normal - ID - 15 - 0 - 读取项目任务增量时间 - ID - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CODE - 32 - -1 - 读取项目任务增量时间 - CODE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_RULE - 255 - -1 - 读取项目任务增量时间 - REST_RULE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_PARAMS - 255 - -1 - 读取项目任务增量时间 - REST_PARAMS - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - TITLE - 64 - -1 - 读取项目任务增量时间 - TITLE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - HOST - 319 - -1 - 读取项目任务增量时间 - HOST - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - INCREMENT_DATE - 64 - -1 - 读取项目任务增量时间 - INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CURR_INCREMENT_DATE - 24 - -1 - 读取项目任务增量时间 - CURR_INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - - - - - - - - - - 224 - 160 - Y - - diff --git a/casic-web/etl/demo/front_db_demo.ktr b/casic-web/etl/demo/front_db_demo.ktr index e606d8c..d170fef 100644 --- a/casic-web/etl/demo/front_db_demo.ktr +++ b/casic-web/etl/demo/front_db_demo.ktr @@ -436,73 +436,14 @@ - 10.225.240.21-ent - 10.225.240.21 - POSTGRESQL - Native - front_db - 5432 - resmg - Encrypted 2be98afc86aa7f2e4cb79bc75cd9fa88b - - - - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - INITIAL_POOL_SIZE - 10 - - - IS_CLUSTERED - N - - - MAXIMUM_POOL_SIZE - 5 - - - PORT_NUMBER - 5432 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - Y - - - - - scyy_local - ${source_local.server} + 163_casic_people_livelihood + 11.100.6.163 MYSQL Native - ${source_local.database} + casic_people_livelihood 3306 - ${source_local.username} - ${source_local.password} + root + Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 @@ -553,14 +494,2467 @@ + + 交通前置_10.225.240.12 + 10.225.240.12 + POSTGRESQL + Native + front_db + 5432 + resmg + Encrypted 2be98afc86aa7f2e4cb79bc75cd9fa88b + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + 表输入 - 表输出 + 添加字段信息 Y + 家庭关系映射 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + vehicle_no + $..VEHICLE_NO + None + + + + + -1 + -1 + none + N + + + source_type + $..SOURCE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_type + $..PLATE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_no + $..PLATE_NO + None + + + + + -1 + -1 + none + N + + + region + $..REGION + None + + + + + -1 + -1 + none + N + + + certification_official + $..CERTIFICATION_OFFICIAL + None + + + + + -1 + -1 + none + N + + + vehicle_brand + $..VEHICLE_BRAND + None + + + + + -1 + -1 + none + N + + + vehicle_model + $..VEHICLE_MODEL + None + + + + + -1 + -1 + none + N + + + vehicle_identification_code + $..VEHICLE_IDENTIFICATION_CODE + None + + + + + -1 + -1 + none + N + + + engine_no + $..ENGINE_NO + None + + + + + -1 + -1 + none + N + + + vehicle_type + $..VEHICLE_TYPE + None + + + + + -1 + -1 + none + N + + + vehicle_color + $..VEHICLE_COLOR + None + + + + + -1 + -1 + none + N + + + use_nature + $..USE_NATURE + None + + + + + -1 + -1 + none + N + + + first_regist_date + $..FIRST_REGIST_DATE + None + + + + + -1 + -1 + none + N + + + vehicle_status + $..VEHICLE_STATUS + None + + + + + -1 + -1 + none + N + + + engine_model + $..ENGINE_MODEL + None + + + + + -1 + -1 + none + N + + + fuel_type + $..FUEL_TYPE + None + + + + + -1 + -1 + none + N + + + displacement + $..DISPLACEMENT + None + + + + + -1 + -1 + none + N + + + power + $..POWER + None + + + + + -1 + -1 + none + N + + + total_mass + $..TOTAL_MASS + None + + + + + -1 + -1 + none + N + + + approved_passenger_capatity + $..APPROVED_PASSENGER_CAPATITY + None + + + + + -1 + -1 + none + N + + + production_date + $..PRODUCTION_DATE + None + + + + + -1 + -1 + none + N + + + update_date + $..UPDATE_DATE + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + vehicle_category + $..VEHICLE_CATEGORY + None + + + + + -1 + -1 + none + N + + + credential_type + $..CREDENTIAL_TYPE + None + + + + + -1 + -1 + none + N + + + credential_no + $..CREDENTIAL_NO + None + + + + + -1 + -1 + none + N + + + owner_name + $..OWNER_NAME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 880 + 176 + Y + + + + 订单支付数据转换 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + order_no + $..ORDER_NO + None + + + + + -1 + -1 + none + N + + + park_id + $..PARK_ID + None + + + + + -1 + -1 + none + N + + + car_no + $..CAR_NO + None + + + + + -1 + -1 + none + N + + + car_user_id + $..CAR_USER_ID + None + + + + + -1 + -1 + none + N + + + biz_code + $..BIZ_CODE + None + + + + + -1 + -1 + none + N + + + order_type + $..ORDER_TYPE + None + + + + + -1 + -1 + none + N + + + coupon_detail_id + $..COUPON_DETAIL_ID + None + + + + + -1 + -1 + none + N + + + pay_type + $..PAY_TYPE + None + + + + + -1 + -1 + none + N + + + pay_code + $..PAY_CODE + None + + + + + -1 + -1 + none + N + + + trade_no + $..TRADE_NO + None + + + + + -1 + -1 + none + N + + + receivable_amount + $..RECEIVABLE_AMOUNT + None + + + + + -1 + -1 + none + N + + + receive_amount + $..RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + local_receive_amount + $..LOCAL_RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + online_receive_amount + $..ONLINE_RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + update_time + $..UPDATE_TIME + None + + + + + -1 + -1 + none + N + + + version + $..VERSION + None + + + + + -1 + -1 + none + N + + + status + $..STATUS + None + + + + + -1 + -1 + none + N + + + sync_status + $..SYNC_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + 0 + Y + N + result + + + + + + + + + + + + + + + + + + 313 + 421 + Y + + + + 房屋数据映射 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + house_purpose_type + $..HOUSE_PURPOSE_TYPE + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + tenant_id + $..TENANT_ID + None + + + + + -1 + -1 + none + N + + + house_number + $..HOUSE_NUMBER + None + + + + + -1 + -1 + none + N + + + province_name + $..PROVINCE_NAME + None + + + + + -1 + -1 + none + N + + + province_type + $..PROVINCE_TYPE + None + + + + + -1 + -1 + none + N + + + city_name + $..CITY_NAME + None + + + + + -1 + -1 + none + N + + + city_type + $..CITY_TYPE + None + + + + + -1 + -1 + none + N + + + district_name + $..DISTRICT_NAME + None + + + + + -1 + -1 + none + N + + + district_type + $..DISTRICT_TYPE + None + + + + + -1 + -1 + none + N + + + street_name + $..STREET_NAME + None + + + + + -1 + -1 + none + N + + + road_name + $..ROAD_NAME + None + + + + + -1 + -1 + none + N + + + card_name + $..CARD_NAME + None + + + + + -1 + -1 + none + N + + + community_name + $..COMMUNITY_NAME + None + + + + + -1 + -1 + none + N + + + community_id + $..COMMUNITY_ID + None + + + + + -1 + -1 + none + N + + + village_tenant_no + $..VILLAGE_TENANT_NO + None + + + + + -1 + -1 + none + N + + + village_name + $..VILLAGE_NAME + None + + + + + -1 + -1 + none + N + + + village_id + $..VILLAGE_ID + None + + + + + -1 + -1 + none + N + + + zone_name + $..ZONE_NAME + None + + + + + -1 + -1 + none + N + + + zone_id + $..ZONE_ID + None + + + + + -1 + -1 + none + N + + + building_name + $..BUILDING_NAME + None + + + + + -1 + -1 + none + N + + + building_id + $..BUILDING_ID + None + + + + + -1 + -1 + none + N + + + unit_name + $..UNIT_NAME + None + + + + + -1 + -1 + none + N + + + unit_id + $..UNIT_ID + None + + + + + -1 + -1 + none + N + + + house_name + $..HOUSE_NAME + None + + + + + -1 + -1 + none + N + + + address + $..ADDRESS + None + + + + + -1 + -1 + none + N + + + built_area + $..BUILT_AREA + None + + + + + -1 + -1 + none + N + + + actual_area + $..ACTUAL_AREA + None + + + + + -1 + -1 + none + N + + + floor + $..FLOOR + None + + + + + -1 + -1 + none + N + + + room_count + $..ROOM_COUNT + None + + + + + -1 + -1 + none + N + + + office_count + $..OFFICE_COUNT + None + + + + + -1 + -1 + none + N + + + wc_count + $..WC_COUNT + None + + + + + -1 + -1 + none + N + + + max_people_number + $..MAX_PEOPLE_NUMBER + None + + + + + -1 + -1 + none + N + + + lon + $..LON + None + + + + + -1 + -1 + none + N + + + lat + $..LAT + None + + + + + -1 + -1 + none + N + + + alt + $..ALT + None + + + + + -1 + -1 + none + N + + + gis_area + $..GIS_AREA + None + + + + + -1 + -1 + none + N + + + gis_type + $..GIS_TYPE + None + + + + + -1 + -1 + none + N + + + house_details + $..HOUSE_DETAILS + None + + + + + -1 + -1 + none + N + + + house_pic_urls + $..HOUSE_PIC_URLS + None + + + + + -1 + -1 + none + N + + + source + $..SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + house_type + $..HOUSE_TYPE + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 976 + 176 + Y + + + + 投诉建议表 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + report_by_user_phone + $..REPORT_BY_USER_PHONE + None + + + + + -1 + -1 + none + N + + + report_by_village_id + $..REPORT_BY_VILLAGE_ID + None + + + + + -1 + -1 + none + N + + + report_by_village_name + $..REPORT_BY_VILLAGE_NAME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + tenant_id + $..TENANT_ID + None + + + + + -1 + -1 + none + N + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + complaint_tag + $..COMPLAINT_TAG + None + + + + + -1 + -1 + none + N + + + detail + $..DETAIL + None + + + + + -1 + -1 + none + N + + + report_by_user_id + $..REPORT_BY_USER_ID + None + + + + + -1 + -1 + none + N + + + report_time + $..REPORT_TIME + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + complaint_type + $..COMPLAINT_TYPE + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 1056 + 176 + Y + + + + 机动车数据 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + vehicle_no + $..VEHICLE_NO + None + + + + + -1 + -1 + none + N + + + source_type + $..SOURCE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_type + $..PLATE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_no + $..PLATE_NO + None + + + + + -1 + -1 + none + N + + + region + $..REGION + None + + + + + -1 + -1 + none + N + + + certification_official + $..CERTIFICATION_OFFICIAL + None + + + + + -1 + -1 + none + N + + + vehicle_brand + $..VEHICLE_BRAND + None + + + + + -1 + -1 + none + N + + + vehicle_model + $..VEHICLE_MODEL + None + + + + + -1 + -1 + none + N + + + vehicle_identification_code + $..VEHICLE_IDENTIFICATION_CODE + None + + + + + -1 + -1 + none + N + + + engine_no + $..ENGINE_NO + None + + + + + -1 + -1 + none + N + + + vehicle_type + $..VEHICLE_TYPE + None + + + + + -1 + -1 + none + N + + + vehicle_color + $..VEHICLE_COLOR + None + + + + + -1 + -1 + none + N + + + use_nature + $..USE_NATURE + None + + + + + -1 + -1 + none + N + + + first_regist_date + $..FIRST_REGIST_DATE + None + + + + + -1 + -1 + none + N + + + vehicle_status + $..VEHICLE_STATUS + None + + + + + -1 + -1 + none + N + + + engine_model + $..ENGINE_MODEL + None + + + + + -1 + -1 + none + N + + + fuel_type + $..FUEL_TYPE + None + + + + + -1 + -1 + none + N + + + displacement + $..DISPLACEMENT + None + + + + + -1 + -1 + none + N + + + power + $..POWER + None + + + + + -1 + -1 + none + N + + + total_mass + $..TOTAL_MASS + None + + + + + -1 + -1 + none + N + + + approved_passenger_capatity + $..APPROVED_PASSENGER_CAPATITY + None + + + + + -1 + -1 + none + N + + + production_date + $..PRODUCTION_DATE + None + + + + + -1 + -1 + none + N + + + update_date + $..UPDATE_DATE + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + vehicle_category + $..VEHICLE_CATEGORY + None + + + + + -1 + -1 + none + N + + + credential_type + $..CREDENTIAL_TYPE + None + + + + + -1 + -1 + none + N + + + credential_no + $..CREDENTIAL_NO + None + + + + + -1 + -1 + none + N + + + owner_name + $..OWNER_NAME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 784 + 176 + Y + + + + 添加字段信息 + ExecSQL + + Y + + 1 + + none + + + 163_casic_people_livelihood + Y + N + Y + N + alter table ? add ? ? COMMENT '?'; + N + + + + + + + tablename + + + name + + + type + + + comment + + + + + + + + + + + + 352 + 64 + Y + + + 表输入 TableInput @@ -571,48 +2965,21 @@ none - 10.225.240.21-ent - SELECT - qylx -, tzze -, zczb -, yzbm -, qymc -, fddbr -, sszb -, bz -, gq -, djjg -, djjgbm -, qyzt -, hyml -, hydm -, czfs -, clrq -, dzyj -, ybjyxm -, xkjyxm -, sdjggss -, gxjg -, jyqxq -, jyqxz -, zs -, sfzrd -, sfgsq -, hzrq -, gpz -, sjly -, sfcqyx -, dabh -, wxl -, tyshxydm -, zch -, ins -, seq -, updatestatus -, updatetime -FROM resmg.qyjbxxmd127142 - + 交通前置_10.225.240.12 + SELECT + col_description ( A.attrelid, A.attnum ) AS COMMENT, + format_type ( A.atttypid, A.atttypmod ) AS type, + A.attname AS NAME, + 'parking_zh_order_record' as TABLENAME +FROM + pg_class AS C, + pg_attribute AS A +WHERE + C.relname = 'tcjlzfjlb103634' + AND A.attrelid = C.oid + AND A.attnum > 0 + and a.attname not in('ins','seq') + 0 N @@ -623,11 +2990,11 @@ String normal - qylx - 800 + comment + 2147483647 -1 表输入 - qylx + comment . , @@ -646,11 +3013,11 @@ String normal - tzze - 800 + type + 2147483647 -1 表输入 - tzze + type . , @@ -669,11 +3036,11 @@ String normal - zczb - 800 + name + 2147483647 -1 表输入 - zczb + name . , @@ -692,793 +3059,11 @@ String normal - yzbm - 800 - -1 - 表输入 - yzbm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - qymc - 800 - -1 - 表输入 - qymc - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - fddbr - 800 - -1 - 表输入 - fddbr - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sszb - 800 - -1 - 表输入 - sszb - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - bz - 800 - -1 - 表输入 - bz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gq - 800 - -1 - 表输入 - gq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - djjg - 800 - -1 - 表输入 - djjg - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - djjgbm - 800 - -1 - 表输入 - djjgbm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - qyzt - 800 - -1 - 表输入 - qyzt - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hyml - 800 - -1 - 表输入 - hyml - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hydm - 800 - -1 - 表输入 - hydm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - czfs - 800 - -1 - 表输入 - czfs - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - clrq - 50 - -1 - 表输入 - clrq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - dzyj - 800 - -1 - 表输入 - dzyj - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - ybjyxm - 1600 - -1 - 表输入 - ybjyxm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - xkjyxm - 1600 - -1 - 表输入 - xkjyxm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sdjggss - 800 - -1 - 表输入 - sdjggss - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gxjg - 800 - -1 - 表输入 - gxjg - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - jyqxq - 50 - -1 - 表输入 - jyqxq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - jyqxz - 50 - -1 - 表输入 - jyqxz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - zs - 800 - -1 - 表输入 - zs - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfzrd - 800 - -1 - 表输入 - sfzrd - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfgsq - 800 - -1 - 表输入 - sfgsq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hzrq - 50 - -1 - 表输入 - hzrq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gpz - 800 - -1 - 表输入 - gpz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sjly - 800 - -1 - 表输入 - sjly - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfcqyx - 800 - -1 - 表输入 - sfcqyx - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - dabh - 800 - -1 - 表输入 - dabh - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - wxl - 800 - -1 - 表输入 - wxl - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - tyshxydm - 400 - -1 - 表输入 - tyshxydm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - zch - 250 - -1 - 表输入 - zch - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - ins - 9 + tablename + -1 0 表输入 - ins - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - seq - 15 - 0 - 表输入 - seq - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - updatestatus - 15 - 0 - 表输入 - updatestatus - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - updatetime - 50 - -1 - 表输入 - updatetime + tablename . , @@ -1504,52 +3089,8 @@ - 768 - 176 - Y - - - - 表输出 - TableOutput - - Y - - 1 - - none - - - scyy_local - scyy - enterprise_info
- 1000 - N - N - Y - N - N - - N - Y - N - - Y - N - - - - - - - - - - - - - 928 - 176 + 176 + 64 Y diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java index 7f389ec..59fc808 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java @@ -2,7 +2,7 @@ /** * @ClassName ResTypeEnums - * @Description TODO + * @Description TODO * @Author lenovo * @Date 2020/9/18 18:08 * @Version 1.0 diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java index 7d5c105..efa941b 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java @@ -24,10 +24,10 @@ /** *

* 共享交换数据集配置表 - * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 + * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 *

* - * @author stylefeng123 + * @author stylefeng123 * @since 2020-10-19 */ @Service diff --git a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr index f9ba53e..02363d6 100644 --- a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr +++ b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr @@ -435,1224 +435,8 @@ - - 163_casic_optmonitoring - 11.100.6.163 - MYSQL - Native - casic_optmonitoring - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 163_casic_industrial_economy - 11.100.6.163 - MYSQL - Native - casic_industrial_economy - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 企业信息服务接口 - 解析code信息 - Y - - - 生成随机数 - 读取项目任务增量时间 - Y - - - 解析code信息 - 企业数据同步更新 - Y - - - 参数转换 - 企业信息服务接口 - Y - - - 读取项目任务增量时间 - 参数转换 - Y - - - 企业信息服务接口 - Rest - - Y - - 1 - - none - - - JSON - GET - http://11.100.5.8:8080/platformbigdata/modelservlet?appkey=53a21bdd-626a-4b3b-9170-0c79498193e6&id=155&param_dsid=1138&flag=97&format=json&&param_PAGESIZE=100000 - Y - N - - HOST - - - Encrypted - - - N - - Encrypted - - - - - - - - result - - - - - - - - - - - - - - 544 - 160 - Y - - - - 企业数据同步更新 - InsertUpdate - - Y - - 1 - - none - - - 163_casic_industrial_economy - 500 - N - - casic_industrial_economy - enterprise_info
- - zch - zch - = - - - - zch - zch - N - - - qylx - qylx - Y - - - tzze - tzze - Y - - - zczb - zczb - Y - - - yzbm - yzbm - Y - - - qymc - qymc - Y - - - fddbr - fddbr - Y - - - sszb - sszb - Y - - - bz - bz - Y - - - gq - gq - Y - - - djjg - djjg - Y - - - djjgbm - djjgbm - Y - - - qyzt - qyzt - Y - - - hyml - hyml - Y - - - hydm - hydm - Y - - - czfs - czfs - Y - - - clrq - clrq - Y - - - dzyj - dzyj - Y - - - ybjyxm - ybjyxm - Y - - - xkjyxm - xkjyxm - Y - - - sdjggss - sdjggss - Y - - - gxjg - gxjg - Y - - - jyqxq - jyqxq - Y - - - jyqxz - jyqxz - Y - - - zs - zs - Y - - - sfzrd - sfzrd - Y - - - sfgsq - sfgsq - Y - - - hzrq - hzrq - Y - - - gpz - gpz - Y - - - sjly - sjly - Y - - - sfcqyx - sfcqyx - Y - - - dabh - dabh - Y - - - tyshxydm - tyshxydm - Y - - - updatetime - updatetime - Y - - - - - - - - - - - - 816 - 160 - Y - - - - 参数转换 - UserDefinedJavaClass - - Y - - 1 - - none - - - - - TRANSFORM_CLASS - Processor - // 生成的代码片段 -public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws Exception { - if (first) { - first = false; - } - - Object[] r = getRow(); - - - if (r == null) { - setOutputDone(); - return false; - } - - r = createOutputRow(r, data.outputRowMeta.size()); - String condition= get(Fields.In, "REST_RULE").getString(r); - String host= get(Fields.In, "HOST").getString(r); - String value= get(Fields.In, "REST_PARAMS").getString(r); - Object[] params = value.split(","); - String outcondition =host+"&param_condition="+java.net.URLEncoder.encode(String.format(condition,params),"UTF-8"); - get(Fields.Out,"HOST").setValue(r,outcondition); - putRow(data.outputRowMeta, r); - - return true; -} - - - - - - N - - - - - - - - - - - - - 384 - 160 - Y - - - - 生成随机数 - RandomValue - - Y - - 1 - - none - - - - - - - - - - - - - - 80 - 160 - Y - - - - 解析code信息 - JsonInput - - Y - - 1 - - none - - - N - - N - N - N - N - N - Y - Y - Y - - - - - - N - N - - - - zch - $..ZCH - None - - - - - -1 - -1 - none - N - - - qylx - $..QYLX - None - - - - - -1 - -1 - none - N - - - tzze - $..TZZE - None - - - - - -1 - -1 - none - N - - - zczb - $..ZCZB - None - - - - - -1 - -1 - none - N - - - yzbm - $..YZBM - None - - - - - -1 - -1 - none - N - - - qymc - $..QYMC - None - - - - - -1 - -1 - none - N - - - fddbr - $..FDDBR - None - - - - - -1 - -1 - none - N - - - sszb - $..SSZB - None - - - - - -1 - -1 - none - N - - - bz - $..BZ - None - - - - - -1 - -1 - none - N - - - gq - $..GQ - None - - - - - -1 - -1 - none - N - - - djjg - $..DJJG - None - - - - - -1 - -1 - none - N - - - djjgbm - $..DJJGBM - None - - - - - -1 - -1 - none - N - - - qyzt - $..QYZT - None - - - - - -1 - -1 - none - N - - - hyml - $..HYML - None - - - - - -1 - -1 - none - N - - - hydm - $..HYDM - None - - - - - -1 - -1 - none - N - - - czfs - $..CZFS - None - - - - - -1 - -1 - none - N - - - clrq - $..CLRQ - None - - - - - -1 - -1 - none - N - - - dzyj - $..DZYJ - None - - - - - -1 - -1 - none - N - - - ybjyxm - $..YBJYXM - None - - - - - -1 - -1 - none - N - - - xkjyxm - $..XKJYXM - None - - - - - -1 - -1 - none - N - - - sdjggss - $..SDJGGSS - None - - - - - -1 - -1 - none - N - - - gxjg - $..GXJG - None - - - - - -1 - -1 - none - N - - - jyqxq - $..JYQXQ - None - - - - - -1 - -1 - none - N - - - jyqxz - $..JYQXZ - None - - - - - -1 - -1 - none - N - - - zs - $..ZS - None - - - - - -1 - -1 - none - N - - - sfzrd - $..SFZRD - None - - - - - -1 - -1 - none - N - - - sfgsq - $..SFGSQ - None - - - - - -1 - -1 - none - N - - - hzrq - $..HZRQ - None - - - - - -1 - -1 - none - N - - - gpz - $..GPZ - None - - - - - -1 - -1 - none - N - - - sjly - $..SJLY - None - - - - - -1 - -1 - none - N - - - sfcqyx - $..SFCQYX - None - - - - - -1 - -1 - none - N - - - dabh - $..DABH - None - - - - - -1 - -1 - none - N - - - tyshxydm - $..TYSHXYDM - None - - - - - -1 - -1 - none - N - - - updatetime - $..UPDATETIME - None - - - - - -1 - -1 - none - N - - - 0 - Y - N - result - - - - - - - - - - - - - - - - - - 704 - 160 - Y - - - - 读取项目任务增量时间 - TableInput - - Y - - 1 - - none - - - 163_casic_optmonitoring - SELECT - ID -, CODE,REST_RULE,REST_PARAMS -, TITLE,concat(HOST,DEFAULT_PARAMS) as HOST -, REST_PARAMS,DATE_FORMAT(NOW(),'%Y-%m-%d %H:%i:%s') as CURR_INCREMENT_DATE -FROM casic_optmonitoring.kettle_increment_config where code='entprise' - 0 - - N - N - N - N - - - Integer - normal - ID - 15 - 0 - 读取项目任务增量时间 - ID - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CODE - 32 - -1 - 读取项目任务增量时间 - CODE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_RULE - 255 - -1 - 读取项目任务增量时间 - REST_RULE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_PARAMS - 255 - -1 - 读取项目任务增量时间 - REST_PARAMS - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - TITLE - 64 - -1 - 读取项目任务增量时间 - TITLE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - HOST - 319 - -1 - 读取项目任务增量时间 - HOST - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - INCREMENT_DATE - 64 - -1 - 读取项目任务增量时间 - INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CURR_INCREMENT_DATE - 24 - -1 - 读取项目任务增量时间 - CURR_INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - - - - - - - - - - 224 - 160 - Y - - diff --git a/casic-web/etl/demo/front_db_demo.ktr b/casic-web/etl/demo/front_db_demo.ktr index e606d8c..d170fef 100644 --- a/casic-web/etl/demo/front_db_demo.ktr +++ b/casic-web/etl/demo/front_db_demo.ktr @@ -436,73 +436,14 @@ - 10.225.240.21-ent - 10.225.240.21 - POSTGRESQL - Native - front_db - 5432 - resmg - Encrypted 2be98afc86aa7f2e4cb79bc75cd9fa88b - - - - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - INITIAL_POOL_SIZE - 10 - - - IS_CLUSTERED - N - - - MAXIMUM_POOL_SIZE - 5 - - - PORT_NUMBER - 5432 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - Y - - - - - scyy_local - ${source_local.server} + 163_casic_people_livelihood + 11.100.6.163 MYSQL Native - ${source_local.database} + casic_people_livelihood 3306 - ${source_local.username} - ${source_local.password} + root + Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 @@ -553,14 +494,2467 @@ + + 交通前置_10.225.240.12 + 10.225.240.12 + POSTGRESQL + Native + front_db + 5432 + resmg + Encrypted 2be98afc86aa7f2e4cb79bc75cd9fa88b + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + 表输入 - 表输出 + 添加字段信息 Y + 家庭关系映射 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + vehicle_no + $..VEHICLE_NO + None + + + + + -1 + -1 + none + N + + + source_type + $..SOURCE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_type + $..PLATE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_no + $..PLATE_NO + None + + + + + -1 + -1 + none + N + + + region + $..REGION + None + + + + + -1 + -1 + none + N + + + certification_official + $..CERTIFICATION_OFFICIAL + None + + + + + -1 + -1 + none + N + + + vehicle_brand + $..VEHICLE_BRAND + None + + + + + -1 + -1 + none + N + + + vehicle_model + $..VEHICLE_MODEL + None + + + + + -1 + -1 + none + N + + + vehicle_identification_code + $..VEHICLE_IDENTIFICATION_CODE + None + + + + + -1 + -1 + none + N + + + engine_no + $..ENGINE_NO + None + + + + + -1 + -1 + none + N + + + vehicle_type + $..VEHICLE_TYPE + None + + + + + -1 + -1 + none + N + + + vehicle_color + $..VEHICLE_COLOR + None + + + + + -1 + -1 + none + N + + + use_nature + $..USE_NATURE + None + + + + + -1 + -1 + none + N + + + first_regist_date + $..FIRST_REGIST_DATE + None + + + + + -1 + -1 + none + N + + + vehicle_status + $..VEHICLE_STATUS + None + + + + + -1 + -1 + none + N + + + engine_model + $..ENGINE_MODEL + None + + + + + -1 + -1 + none + N + + + fuel_type + $..FUEL_TYPE + None + + + + + -1 + -1 + none + N + + + displacement + $..DISPLACEMENT + None + + + + + -1 + -1 + none + N + + + power + $..POWER + None + + + + + -1 + -1 + none + N + + + total_mass + $..TOTAL_MASS + None + + + + + -1 + -1 + none + N + + + approved_passenger_capatity + $..APPROVED_PASSENGER_CAPATITY + None + + + + + -1 + -1 + none + N + + + production_date + $..PRODUCTION_DATE + None + + + + + -1 + -1 + none + N + + + update_date + $..UPDATE_DATE + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + vehicle_category + $..VEHICLE_CATEGORY + None + + + + + -1 + -1 + none + N + + + credential_type + $..CREDENTIAL_TYPE + None + + + + + -1 + -1 + none + N + + + credential_no + $..CREDENTIAL_NO + None + + + + + -1 + -1 + none + N + + + owner_name + $..OWNER_NAME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 880 + 176 + Y + + + + 订单支付数据转换 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + order_no + $..ORDER_NO + None + + + + + -1 + -1 + none + N + + + park_id + $..PARK_ID + None + + + + + -1 + -1 + none + N + + + car_no + $..CAR_NO + None + + + + + -1 + -1 + none + N + + + car_user_id + $..CAR_USER_ID + None + + + + + -1 + -1 + none + N + + + biz_code + $..BIZ_CODE + None + + + + + -1 + -1 + none + N + + + order_type + $..ORDER_TYPE + None + + + + + -1 + -1 + none + N + + + coupon_detail_id + $..COUPON_DETAIL_ID + None + + + + + -1 + -1 + none + N + + + pay_type + $..PAY_TYPE + None + + + + + -1 + -1 + none + N + + + pay_code + $..PAY_CODE + None + + + + + -1 + -1 + none + N + + + trade_no + $..TRADE_NO + None + + + + + -1 + -1 + none + N + + + receivable_amount + $..RECEIVABLE_AMOUNT + None + + + + + -1 + -1 + none + N + + + receive_amount + $..RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + local_receive_amount + $..LOCAL_RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + online_receive_amount + $..ONLINE_RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + update_time + $..UPDATE_TIME + None + + + + + -1 + -1 + none + N + + + version + $..VERSION + None + + + + + -1 + -1 + none + N + + + status + $..STATUS + None + + + + + -1 + -1 + none + N + + + sync_status + $..SYNC_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + 0 + Y + N + result + + + + + + + + + + + + + + + + + + 313 + 421 + Y + + + + 房屋数据映射 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + house_purpose_type + $..HOUSE_PURPOSE_TYPE + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + tenant_id + $..TENANT_ID + None + + + + + -1 + -1 + none + N + + + house_number + $..HOUSE_NUMBER + None + + + + + -1 + -1 + none + N + + + province_name + $..PROVINCE_NAME + None + + + + + -1 + -1 + none + N + + + province_type + $..PROVINCE_TYPE + None + + + + + -1 + -1 + none + N + + + city_name + $..CITY_NAME + None + + + + + -1 + -1 + none + N + + + city_type + $..CITY_TYPE + None + + + + + -1 + -1 + none + N + + + district_name + $..DISTRICT_NAME + None + + + + + -1 + -1 + none + N + + + district_type + $..DISTRICT_TYPE + None + + + + + -1 + -1 + none + N + + + street_name + $..STREET_NAME + None + + + + + -1 + -1 + none + N + + + road_name + $..ROAD_NAME + None + + + + + -1 + -1 + none + N + + + card_name + $..CARD_NAME + None + + + + + -1 + -1 + none + N + + + community_name + $..COMMUNITY_NAME + None + + + + + -1 + -1 + none + N + + + community_id + $..COMMUNITY_ID + None + + + + + -1 + -1 + none + N + + + village_tenant_no + $..VILLAGE_TENANT_NO + None + + + + + -1 + -1 + none + N + + + village_name + $..VILLAGE_NAME + None + + + + + -1 + -1 + none + N + + + village_id + $..VILLAGE_ID + None + + + + + -1 + -1 + none + N + + + zone_name + $..ZONE_NAME + None + + + + + -1 + -1 + none + N + + + zone_id + $..ZONE_ID + None + + + + + -1 + -1 + none + N + + + building_name + $..BUILDING_NAME + None + + + + + -1 + -1 + none + N + + + building_id + $..BUILDING_ID + None + + + + + -1 + -1 + none + N + + + unit_name + $..UNIT_NAME + None + + + + + -1 + -1 + none + N + + + unit_id + $..UNIT_ID + None + + + + + -1 + -1 + none + N + + + house_name + $..HOUSE_NAME + None + + + + + -1 + -1 + none + N + + + address + $..ADDRESS + None + + + + + -1 + -1 + none + N + + + built_area + $..BUILT_AREA + None + + + + + -1 + -1 + none + N + + + actual_area + $..ACTUAL_AREA + None + + + + + -1 + -1 + none + N + + + floor + $..FLOOR + None + + + + + -1 + -1 + none + N + + + room_count + $..ROOM_COUNT + None + + + + + -1 + -1 + none + N + + + office_count + $..OFFICE_COUNT + None + + + + + -1 + -1 + none + N + + + wc_count + $..WC_COUNT + None + + + + + -1 + -1 + none + N + + + max_people_number + $..MAX_PEOPLE_NUMBER + None + + + + + -1 + -1 + none + N + + + lon + $..LON + None + + + + + -1 + -1 + none + N + + + lat + $..LAT + None + + + + + -1 + -1 + none + N + + + alt + $..ALT + None + + + + + -1 + -1 + none + N + + + gis_area + $..GIS_AREA + None + + + + + -1 + -1 + none + N + + + gis_type + $..GIS_TYPE + None + + + + + -1 + -1 + none + N + + + house_details + $..HOUSE_DETAILS + None + + + + + -1 + -1 + none + N + + + house_pic_urls + $..HOUSE_PIC_URLS + None + + + + + -1 + -1 + none + N + + + source + $..SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + house_type + $..HOUSE_TYPE + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 976 + 176 + Y + + + + 投诉建议表 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + report_by_user_phone + $..REPORT_BY_USER_PHONE + None + + + + + -1 + -1 + none + N + + + report_by_village_id + $..REPORT_BY_VILLAGE_ID + None + + + + + -1 + -1 + none + N + + + report_by_village_name + $..REPORT_BY_VILLAGE_NAME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + tenant_id + $..TENANT_ID + None + + + + + -1 + -1 + none + N + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + complaint_tag + $..COMPLAINT_TAG + None + + + + + -1 + -1 + none + N + + + detail + $..DETAIL + None + + + + + -1 + -1 + none + N + + + report_by_user_id + $..REPORT_BY_USER_ID + None + + + + + -1 + -1 + none + N + + + report_time + $..REPORT_TIME + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + complaint_type + $..COMPLAINT_TYPE + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 1056 + 176 + Y + + + + 机动车数据 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + vehicle_no + $..VEHICLE_NO + None + + + + + -1 + -1 + none + N + + + source_type + $..SOURCE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_type + $..PLATE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_no + $..PLATE_NO + None + + + + + -1 + -1 + none + N + + + region + $..REGION + None + + + + + -1 + -1 + none + N + + + certification_official + $..CERTIFICATION_OFFICIAL + None + + + + + -1 + -1 + none + N + + + vehicle_brand + $..VEHICLE_BRAND + None + + + + + -1 + -1 + none + N + + + vehicle_model + $..VEHICLE_MODEL + None + + + + + -1 + -1 + none + N + + + vehicle_identification_code + $..VEHICLE_IDENTIFICATION_CODE + None + + + + + -1 + -1 + none + N + + + engine_no + $..ENGINE_NO + None + + + + + -1 + -1 + none + N + + + vehicle_type + $..VEHICLE_TYPE + None + + + + + -1 + -1 + none + N + + + vehicle_color + $..VEHICLE_COLOR + None + + + + + -1 + -1 + none + N + + + use_nature + $..USE_NATURE + None + + + + + -1 + -1 + none + N + + + first_regist_date + $..FIRST_REGIST_DATE + None + + + + + -1 + -1 + none + N + + + vehicle_status + $..VEHICLE_STATUS + None + + + + + -1 + -1 + none + N + + + engine_model + $..ENGINE_MODEL + None + + + + + -1 + -1 + none + N + + + fuel_type + $..FUEL_TYPE + None + + + + + -1 + -1 + none + N + + + displacement + $..DISPLACEMENT + None + + + + + -1 + -1 + none + N + + + power + $..POWER + None + + + + + -1 + -1 + none + N + + + total_mass + $..TOTAL_MASS + None + + + + + -1 + -1 + none + N + + + approved_passenger_capatity + $..APPROVED_PASSENGER_CAPATITY + None + + + + + -1 + -1 + none + N + + + production_date + $..PRODUCTION_DATE + None + + + + + -1 + -1 + none + N + + + update_date + $..UPDATE_DATE + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + vehicle_category + $..VEHICLE_CATEGORY + None + + + + + -1 + -1 + none + N + + + credential_type + $..CREDENTIAL_TYPE + None + + + + + -1 + -1 + none + N + + + credential_no + $..CREDENTIAL_NO + None + + + + + -1 + -1 + none + N + + + owner_name + $..OWNER_NAME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 784 + 176 + Y + + + + 添加字段信息 + ExecSQL + + Y + + 1 + + none + + + 163_casic_people_livelihood + Y + N + Y + N + alter table ? add ? ? COMMENT '?'; + N + + + + + + + tablename + + + name + + + type + + + comment + + + + + + + + + + + + 352 + 64 + Y + + + 表输入 TableInput @@ -571,48 +2965,21 @@ none - 10.225.240.21-ent - SELECT - qylx -, tzze -, zczb -, yzbm -, qymc -, fddbr -, sszb -, bz -, gq -, djjg -, djjgbm -, qyzt -, hyml -, hydm -, czfs -, clrq -, dzyj -, ybjyxm -, xkjyxm -, sdjggss -, gxjg -, jyqxq -, jyqxz -, zs -, sfzrd -, sfgsq -, hzrq -, gpz -, sjly -, sfcqyx -, dabh -, wxl -, tyshxydm -, zch -, ins -, seq -, updatestatus -, updatetime -FROM resmg.qyjbxxmd127142 - + 交通前置_10.225.240.12 + SELECT + col_description ( A.attrelid, A.attnum ) AS COMMENT, + format_type ( A.atttypid, A.atttypmod ) AS type, + A.attname AS NAME, + 'parking_zh_order_record' as TABLENAME +FROM + pg_class AS C, + pg_attribute AS A +WHERE + C.relname = 'tcjlzfjlb103634' + AND A.attrelid = C.oid + AND A.attnum > 0 + and a.attname not in('ins','seq') + 0 N @@ -623,11 +2990,11 @@ String normal - qylx - 800 + comment + 2147483647 -1 表输入 - qylx + comment . , @@ -646,11 +3013,11 @@ String normal - tzze - 800 + type + 2147483647 -1 表输入 - tzze + type . , @@ -669,11 +3036,11 @@ String normal - zczb - 800 + name + 2147483647 -1 表输入 - zczb + name . , @@ -692,793 +3059,11 @@ String normal - yzbm - 800 - -1 - 表输入 - yzbm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - qymc - 800 - -1 - 表输入 - qymc - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - fddbr - 800 - -1 - 表输入 - fddbr - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sszb - 800 - -1 - 表输入 - sszb - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - bz - 800 - -1 - 表输入 - bz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gq - 800 - -1 - 表输入 - gq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - djjg - 800 - -1 - 表输入 - djjg - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - djjgbm - 800 - -1 - 表输入 - djjgbm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - qyzt - 800 - -1 - 表输入 - qyzt - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hyml - 800 - -1 - 表输入 - hyml - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hydm - 800 - -1 - 表输入 - hydm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - czfs - 800 - -1 - 表输入 - czfs - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - clrq - 50 - -1 - 表输入 - clrq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - dzyj - 800 - -1 - 表输入 - dzyj - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - ybjyxm - 1600 - -1 - 表输入 - ybjyxm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - xkjyxm - 1600 - -1 - 表输入 - xkjyxm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sdjggss - 800 - -1 - 表输入 - sdjggss - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gxjg - 800 - -1 - 表输入 - gxjg - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - jyqxq - 50 - -1 - 表输入 - jyqxq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - jyqxz - 50 - -1 - 表输入 - jyqxz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - zs - 800 - -1 - 表输入 - zs - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfzrd - 800 - -1 - 表输入 - sfzrd - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfgsq - 800 - -1 - 表输入 - sfgsq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hzrq - 50 - -1 - 表输入 - hzrq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gpz - 800 - -1 - 表输入 - gpz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sjly - 800 - -1 - 表输入 - sjly - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfcqyx - 800 - -1 - 表输入 - sfcqyx - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - dabh - 800 - -1 - 表输入 - dabh - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - wxl - 800 - -1 - 表输入 - wxl - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - tyshxydm - 400 - -1 - 表输入 - tyshxydm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - zch - 250 - -1 - 表输入 - zch - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - ins - 9 + tablename + -1 0 表输入 - ins - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - seq - 15 - 0 - 表输入 - seq - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - updatestatus - 15 - 0 - 表输入 - updatestatus - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - updatetime - 50 - -1 - 表输入 - updatetime + tablename . , @@ -1504,52 +3089,8 @@ - 768 - 176 - Y - - - - 表输出 - TableOutput - - Y - - 1 - - none - - - scyy_local - scyy - enterprise_info
- 1000 - N - N - Y - N - N - - N - Y - N - - Y - N - - - - - - - - - - - - - 928 - 176 + 176 + 64 Y diff --git a/casic-web/etl/demo/rest-demo.ktr b/casic-web/etl/demo/rest-demo.ktr index 2ebb670..561eaf8 100644 --- a/casic-web/etl/demo/rest-demo.ktr +++ b/casic-web/etl/demo/rest-demo.ktr @@ -527,6 +527,198 @@ + REST client + Rest + + Y + + 1 + + none + + + TEXT PLAIN + GET + + Y + N + + host + + + Encrypted + + + N + + Encrypted + + + + + + + + result + + + + + + + + + + + + + + 544 + 32 + Y + + + + json转换 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + simcardnum + $..simcardnum + String + + + + + -1 + -1 + none + N + + + recordTime + $..recordTime + None + + + + + -1 + -1 + none + N + + + 0 + Y + N + result + + + + + + + + + + + + + + + + + + 688 + 96 + Y + + + + 文本文件输出 + TextFileOutput + + Y + + 1 + + none + + + ; + " + N + N +
Y
+
N
+ DOS + None + + + N + + Y + + E:\\test.txt + N + N + txt + N + N + N + N + N + N + + Y + N + N + + + + + + + + + + + + + + 480 + 208 + Y + + + 日期参数encode UserDefinedJavaClass @@ -592,6 +784,50 @@ + 更新上报时间 + ExecSQL + + Y + + 1 + + none + + + 163_casic_urban_governance + Y + N + Y + N + update dcms_car_info set recordTime = from_unixtime(?/1000) where simcardnum='?' + N + + + + + + + recordTime + + + simcardnum + + + + + + + + + + + + 688 + 208 + Y + + + 生成随机数 RandomValue @@ -751,242 +987,6 @@ Y - - json转换 - JsonInput - - Y - - 1 - - none - - - N - - N - N - N - N - N - Y - Y - Y - - - - - - N - N - - - - simcardnum - $..simcardnum - String - - - - - -1 - -1 - none - N - - - recordTime - $..recordTime - None - - - - - -1 - -1 - none - N - - - 0 - Y - N - result - - - - - - - - - - - - - - - - - - 688 - 96 - Y - - - - 更新上报时间 - ExecSQL - - Y - - 1 - - none - - - 163_casic_urban_governance - Y - N - Y - N - update dcms_car_info set recordTime = from_unixtime(?/1000) where simcardnum='?' - N - - - - - - - recordTime - - - simcardnum - - - - - - - - - - - - 688 - 208 - Y - - - - 文本文件输出 - TextFileOutput - - Y - - 1 - - none - - - ; - " - N - N -
Y
-
N
- DOS - None - - - N - - Y - - E:\\test.txt - N - N - txt - N - N - N - N - N - N - - Y - N - N - - - - - - - - - - - - - - 480 - 208 - Y - - - - REST client - Rest - - Y - - 1 - - none - - - TEXT PLAIN - GET - - Y - N - - host - - - Encrypted - - - N - - Encrypted - - - - - - - - result - - - - - - - - - - - - - - 544 - 32 - Y - - diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java index 7f389ec..59fc808 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java @@ -2,7 +2,7 @@ /** * @ClassName ResTypeEnums - * @Description TODO + * @Description TODO * @Author lenovo * @Date 2020/9/18 18:08 * @Version 1.0 diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java index 7d5c105..efa941b 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java @@ -24,10 +24,10 @@ /** *

* 共享交换数据集配置表 - * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 + * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 *

* - * @author stylefeng123 + * @author stylefeng123 * @since 2020-10-19 */ @Service diff --git a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr index f9ba53e..02363d6 100644 --- a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr +++ b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr @@ -435,1224 +435,8 @@ - - 163_casic_optmonitoring - 11.100.6.163 - MYSQL - Native - casic_optmonitoring - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 163_casic_industrial_economy - 11.100.6.163 - MYSQL - Native - casic_industrial_economy - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 企业信息服务接口 - 解析code信息 - Y - - - 生成随机数 - 读取项目任务增量时间 - Y - - - 解析code信息 - 企业数据同步更新 - Y - - - 参数转换 - 企业信息服务接口 - Y - - - 读取项目任务增量时间 - 参数转换 - Y - - - 企业信息服务接口 - Rest - - Y - - 1 - - none - - - JSON - GET - http://11.100.5.8:8080/platformbigdata/modelservlet?appkey=53a21bdd-626a-4b3b-9170-0c79498193e6&id=155&param_dsid=1138&flag=97&format=json&&param_PAGESIZE=100000 - Y - N - - HOST - - - Encrypted - - - N - - Encrypted - - - - - - - - result - - - - - - - - - - - - - - 544 - 160 - Y - - - - 企业数据同步更新 - InsertUpdate - - Y - - 1 - - none - - - 163_casic_industrial_economy - 500 - N - - casic_industrial_economy - enterprise_info
- - zch - zch - = - - - - zch - zch - N - - - qylx - qylx - Y - - - tzze - tzze - Y - - - zczb - zczb - Y - - - yzbm - yzbm - Y - - - qymc - qymc - Y - - - fddbr - fddbr - Y - - - sszb - sszb - Y - - - bz - bz - Y - - - gq - gq - Y - - - djjg - djjg - Y - - - djjgbm - djjgbm - Y - - - qyzt - qyzt - Y - - - hyml - hyml - Y - - - hydm - hydm - Y - - - czfs - czfs - Y - - - clrq - clrq - Y - - - dzyj - dzyj - Y - - - ybjyxm - ybjyxm - Y - - - xkjyxm - xkjyxm - Y - - - sdjggss - sdjggss - Y - - - gxjg - gxjg - Y - - - jyqxq - jyqxq - Y - - - jyqxz - jyqxz - Y - - - zs - zs - Y - - - sfzrd - sfzrd - Y - - - sfgsq - sfgsq - Y - - - hzrq - hzrq - Y - - - gpz - gpz - Y - - - sjly - sjly - Y - - - sfcqyx - sfcqyx - Y - - - dabh - dabh - Y - - - tyshxydm - tyshxydm - Y - - - updatetime - updatetime - Y - - - - - - - - - - - - 816 - 160 - Y - - - - 参数转换 - UserDefinedJavaClass - - Y - - 1 - - none - - - - - TRANSFORM_CLASS - Processor - // 生成的代码片段 -public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws Exception { - if (first) { - first = false; - } - - Object[] r = getRow(); - - - if (r == null) { - setOutputDone(); - return false; - } - - r = createOutputRow(r, data.outputRowMeta.size()); - String condition= get(Fields.In, "REST_RULE").getString(r); - String host= get(Fields.In, "HOST").getString(r); - String value= get(Fields.In, "REST_PARAMS").getString(r); - Object[] params = value.split(","); - String outcondition =host+"&param_condition="+java.net.URLEncoder.encode(String.format(condition,params),"UTF-8"); - get(Fields.Out,"HOST").setValue(r,outcondition); - putRow(data.outputRowMeta, r); - - return true; -} - - - - - - N - - - - - - - - - - - - - 384 - 160 - Y - - - - 生成随机数 - RandomValue - - Y - - 1 - - none - - - - - - - - - - - - - - 80 - 160 - Y - - - - 解析code信息 - JsonInput - - Y - - 1 - - none - - - N - - N - N - N - N - N - Y - Y - Y - - - - - - N - N - - - - zch - $..ZCH - None - - - - - -1 - -1 - none - N - - - qylx - $..QYLX - None - - - - - -1 - -1 - none - N - - - tzze - $..TZZE - None - - - - - -1 - -1 - none - N - - - zczb - $..ZCZB - None - - - - - -1 - -1 - none - N - - - yzbm - $..YZBM - None - - - - - -1 - -1 - none - N - - - qymc - $..QYMC - None - - - - - -1 - -1 - none - N - - - fddbr - $..FDDBR - None - - - - - -1 - -1 - none - N - - - sszb - $..SSZB - None - - - - - -1 - -1 - none - N - - - bz - $..BZ - None - - - - - -1 - -1 - none - N - - - gq - $..GQ - None - - - - - -1 - -1 - none - N - - - djjg - $..DJJG - None - - - - - -1 - -1 - none - N - - - djjgbm - $..DJJGBM - None - - - - - -1 - -1 - none - N - - - qyzt - $..QYZT - None - - - - - -1 - -1 - none - N - - - hyml - $..HYML - None - - - - - -1 - -1 - none - N - - - hydm - $..HYDM - None - - - - - -1 - -1 - none - N - - - czfs - $..CZFS - None - - - - - -1 - -1 - none - N - - - clrq - $..CLRQ - None - - - - - -1 - -1 - none - N - - - dzyj - $..DZYJ - None - - - - - -1 - -1 - none - N - - - ybjyxm - $..YBJYXM - None - - - - - -1 - -1 - none - N - - - xkjyxm - $..XKJYXM - None - - - - - -1 - -1 - none - N - - - sdjggss - $..SDJGGSS - None - - - - - -1 - -1 - none - N - - - gxjg - $..GXJG - None - - - - - -1 - -1 - none - N - - - jyqxq - $..JYQXQ - None - - - - - -1 - -1 - none - N - - - jyqxz - $..JYQXZ - None - - - - - -1 - -1 - none - N - - - zs - $..ZS - None - - - - - -1 - -1 - none - N - - - sfzrd - $..SFZRD - None - - - - - -1 - -1 - none - N - - - sfgsq - $..SFGSQ - None - - - - - -1 - -1 - none - N - - - hzrq - $..HZRQ - None - - - - - -1 - -1 - none - N - - - gpz - $..GPZ - None - - - - - -1 - -1 - none - N - - - sjly - $..SJLY - None - - - - - -1 - -1 - none - N - - - sfcqyx - $..SFCQYX - None - - - - - -1 - -1 - none - N - - - dabh - $..DABH - None - - - - - -1 - -1 - none - N - - - tyshxydm - $..TYSHXYDM - None - - - - - -1 - -1 - none - N - - - updatetime - $..UPDATETIME - None - - - - - -1 - -1 - none - N - - - 0 - Y - N - result - - - - - - - - - - - - - - - - - - 704 - 160 - Y - - - - 读取项目任务增量时间 - TableInput - - Y - - 1 - - none - - - 163_casic_optmonitoring - SELECT - ID -, CODE,REST_RULE,REST_PARAMS -, TITLE,concat(HOST,DEFAULT_PARAMS) as HOST -, REST_PARAMS,DATE_FORMAT(NOW(),'%Y-%m-%d %H:%i:%s') as CURR_INCREMENT_DATE -FROM casic_optmonitoring.kettle_increment_config where code='entprise' - 0 - - N - N - N - N - - - Integer - normal - ID - 15 - 0 - 读取项目任务增量时间 - ID - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CODE - 32 - -1 - 读取项目任务增量时间 - CODE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_RULE - 255 - -1 - 读取项目任务增量时间 - REST_RULE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_PARAMS - 255 - -1 - 读取项目任务增量时间 - REST_PARAMS - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - TITLE - 64 - -1 - 读取项目任务增量时间 - TITLE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - HOST - 319 - -1 - 读取项目任务增量时间 - HOST - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - INCREMENT_DATE - 64 - -1 - 读取项目任务增量时间 - INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CURR_INCREMENT_DATE - 24 - -1 - 读取项目任务增量时间 - CURR_INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - - - - - - - - - - 224 - 160 - Y - - diff --git a/casic-web/etl/demo/front_db_demo.ktr b/casic-web/etl/demo/front_db_demo.ktr index e606d8c..d170fef 100644 --- a/casic-web/etl/demo/front_db_demo.ktr +++ b/casic-web/etl/demo/front_db_demo.ktr @@ -436,73 +436,14 @@ - 10.225.240.21-ent - 10.225.240.21 - POSTGRESQL - Native - front_db - 5432 - resmg - Encrypted 2be98afc86aa7f2e4cb79bc75cd9fa88b - - - - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - INITIAL_POOL_SIZE - 10 - - - IS_CLUSTERED - N - - - MAXIMUM_POOL_SIZE - 5 - - - PORT_NUMBER - 5432 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - Y - - - - - scyy_local - ${source_local.server} + 163_casic_people_livelihood + 11.100.6.163 MYSQL Native - ${source_local.database} + casic_people_livelihood 3306 - ${source_local.username} - ${source_local.password} + root + Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 @@ -553,14 +494,2467 @@ + + 交通前置_10.225.240.12 + 10.225.240.12 + POSTGRESQL + Native + front_db + 5432 + resmg + Encrypted 2be98afc86aa7f2e4cb79bc75cd9fa88b + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + 表输入 - 表输出 + 添加字段信息 Y + 家庭关系映射 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + vehicle_no + $..VEHICLE_NO + None + + + + + -1 + -1 + none + N + + + source_type + $..SOURCE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_type + $..PLATE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_no + $..PLATE_NO + None + + + + + -1 + -1 + none + N + + + region + $..REGION + None + + + + + -1 + -1 + none + N + + + certification_official + $..CERTIFICATION_OFFICIAL + None + + + + + -1 + -1 + none + N + + + vehicle_brand + $..VEHICLE_BRAND + None + + + + + -1 + -1 + none + N + + + vehicle_model + $..VEHICLE_MODEL + None + + + + + -1 + -1 + none + N + + + vehicle_identification_code + $..VEHICLE_IDENTIFICATION_CODE + None + + + + + -1 + -1 + none + N + + + engine_no + $..ENGINE_NO + None + + + + + -1 + -1 + none + N + + + vehicle_type + $..VEHICLE_TYPE + None + + + + + -1 + -1 + none + N + + + vehicle_color + $..VEHICLE_COLOR + None + + + + + -1 + -1 + none + N + + + use_nature + $..USE_NATURE + None + + + + + -1 + -1 + none + N + + + first_regist_date + $..FIRST_REGIST_DATE + None + + + + + -1 + -1 + none + N + + + vehicle_status + $..VEHICLE_STATUS + None + + + + + -1 + -1 + none + N + + + engine_model + $..ENGINE_MODEL + None + + + + + -1 + -1 + none + N + + + fuel_type + $..FUEL_TYPE + None + + + + + -1 + -1 + none + N + + + displacement + $..DISPLACEMENT + None + + + + + -1 + -1 + none + N + + + power + $..POWER + None + + + + + -1 + -1 + none + N + + + total_mass + $..TOTAL_MASS + None + + + + + -1 + -1 + none + N + + + approved_passenger_capatity + $..APPROVED_PASSENGER_CAPATITY + None + + + + + -1 + -1 + none + N + + + production_date + $..PRODUCTION_DATE + None + + + + + -1 + -1 + none + N + + + update_date + $..UPDATE_DATE + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + vehicle_category + $..VEHICLE_CATEGORY + None + + + + + -1 + -1 + none + N + + + credential_type + $..CREDENTIAL_TYPE + None + + + + + -1 + -1 + none + N + + + credential_no + $..CREDENTIAL_NO + None + + + + + -1 + -1 + none + N + + + owner_name + $..OWNER_NAME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 880 + 176 + Y + + + + 订单支付数据转换 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + order_no + $..ORDER_NO + None + + + + + -1 + -1 + none + N + + + park_id + $..PARK_ID + None + + + + + -1 + -1 + none + N + + + car_no + $..CAR_NO + None + + + + + -1 + -1 + none + N + + + car_user_id + $..CAR_USER_ID + None + + + + + -1 + -1 + none + N + + + biz_code + $..BIZ_CODE + None + + + + + -1 + -1 + none + N + + + order_type + $..ORDER_TYPE + None + + + + + -1 + -1 + none + N + + + coupon_detail_id + $..COUPON_DETAIL_ID + None + + + + + -1 + -1 + none + N + + + pay_type + $..PAY_TYPE + None + + + + + -1 + -1 + none + N + + + pay_code + $..PAY_CODE + None + + + + + -1 + -1 + none + N + + + trade_no + $..TRADE_NO + None + + + + + -1 + -1 + none + N + + + receivable_amount + $..RECEIVABLE_AMOUNT + None + + + + + -1 + -1 + none + N + + + receive_amount + $..RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + local_receive_amount + $..LOCAL_RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + online_receive_amount + $..ONLINE_RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + update_time + $..UPDATE_TIME + None + + + + + -1 + -1 + none + N + + + version + $..VERSION + None + + + + + -1 + -1 + none + N + + + status + $..STATUS + None + + + + + -1 + -1 + none + N + + + sync_status + $..SYNC_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + 0 + Y + N + result + + + + + + + + + + + + + + + + + + 313 + 421 + Y + + + + 房屋数据映射 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + house_purpose_type + $..HOUSE_PURPOSE_TYPE + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + tenant_id + $..TENANT_ID + None + + + + + -1 + -1 + none + N + + + house_number + $..HOUSE_NUMBER + None + + + + + -1 + -1 + none + N + + + province_name + $..PROVINCE_NAME + None + + + + + -1 + -1 + none + N + + + province_type + $..PROVINCE_TYPE + None + + + + + -1 + -1 + none + N + + + city_name + $..CITY_NAME + None + + + + + -1 + -1 + none + N + + + city_type + $..CITY_TYPE + None + + + + + -1 + -1 + none + N + + + district_name + $..DISTRICT_NAME + None + + + + + -1 + -1 + none + N + + + district_type + $..DISTRICT_TYPE + None + + + + + -1 + -1 + none + N + + + street_name + $..STREET_NAME + None + + + + + -1 + -1 + none + N + + + road_name + $..ROAD_NAME + None + + + + + -1 + -1 + none + N + + + card_name + $..CARD_NAME + None + + + + + -1 + -1 + none + N + + + community_name + $..COMMUNITY_NAME + None + + + + + -1 + -1 + none + N + + + community_id + $..COMMUNITY_ID + None + + + + + -1 + -1 + none + N + + + village_tenant_no + $..VILLAGE_TENANT_NO + None + + + + + -1 + -1 + none + N + + + village_name + $..VILLAGE_NAME + None + + + + + -1 + -1 + none + N + + + village_id + $..VILLAGE_ID + None + + + + + -1 + -1 + none + N + + + zone_name + $..ZONE_NAME + None + + + + + -1 + -1 + none + N + + + zone_id + $..ZONE_ID + None + + + + + -1 + -1 + none + N + + + building_name + $..BUILDING_NAME + None + + + + + -1 + -1 + none + N + + + building_id + $..BUILDING_ID + None + + + + + -1 + -1 + none + N + + + unit_name + $..UNIT_NAME + None + + + + + -1 + -1 + none + N + + + unit_id + $..UNIT_ID + None + + + + + -1 + -1 + none + N + + + house_name + $..HOUSE_NAME + None + + + + + -1 + -1 + none + N + + + address + $..ADDRESS + None + + + + + -1 + -1 + none + N + + + built_area + $..BUILT_AREA + None + + + + + -1 + -1 + none + N + + + actual_area + $..ACTUAL_AREA + None + + + + + -1 + -1 + none + N + + + floor + $..FLOOR + None + + + + + -1 + -1 + none + N + + + room_count + $..ROOM_COUNT + None + + + + + -1 + -1 + none + N + + + office_count + $..OFFICE_COUNT + None + + + + + -1 + -1 + none + N + + + wc_count + $..WC_COUNT + None + + + + + -1 + -1 + none + N + + + max_people_number + $..MAX_PEOPLE_NUMBER + None + + + + + -1 + -1 + none + N + + + lon + $..LON + None + + + + + -1 + -1 + none + N + + + lat + $..LAT + None + + + + + -1 + -1 + none + N + + + alt + $..ALT + None + + + + + -1 + -1 + none + N + + + gis_area + $..GIS_AREA + None + + + + + -1 + -1 + none + N + + + gis_type + $..GIS_TYPE + None + + + + + -1 + -1 + none + N + + + house_details + $..HOUSE_DETAILS + None + + + + + -1 + -1 + none + N + + + house_pic_urls + $..HOUSE_PIC_URLS + None + + + + + -1 + -1 + none + N + + + source + $..SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + house_type + $..HOUSE_TYPE + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 976 + 176 + Y + + + + 投诉建议表 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + report_by_user_phone + $..REPORT_BY_USER_PHONE + None + + + + + -1 + -1 + none + N + + + report_by_village_id + $..REPORT_BY_VILLAGE_ID + None + + + + + -1 + -1 + none + N + + + report_by_village_name + $..REPORT_BY_VILLAGE_NAME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + tenant_id + $..TENANT_ID + None + + + + + -1 + -1 + none + N + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + complaint_tag + $..COMPLAINT_TAG + None + + + + + -1 + -1 + none + N + + + detail + $..DETAIL + None + + + + + -1 + -1 + none + N + + + report_by_user_id + $..REPORT_BY_USER_ID + None + + + + + -1 + -1 + none + N + + + report_time + $..REPORT_TIME + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + complaint_type + $..COMPLAINT_TYPE + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 1056 + 176 + Y + + + + 机动车数据 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + vehicle_no + $..VEHICLE_NO + None + + + + + -1 + -1 + none + N + + + source_type + $..SOURCE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_type + $..PLATE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_no + $..PLATE_NO + None + + + + + -1 + -1 + none + N + + + region + $..REGION + None + + + + + -1 + -1 + none + N + + + certification_official + $..CERTIFICATION_OFFICIAL + None + + + + + -1 + -1 + none + N + + + vehicle_brand + $..VEHICLE_BRAND + None + + + + + -1 + -1 + none + N + + + vehicle_model + $..VEHICLE_MODEL + None + + + + + -1 + -1 + none + N + + + vehicle_identification_code + $..VEHICLE_IDENTIFICATION_CODE + None + + + + + -1 + -1 + none + N + + + engine_no + $..ENGINE_NO + None + + + + + -1 + -1 + none + N + + + vehicle_type + $..VEHICLE_TYPE + None + + + + + -1 + -1 + none + N + + + vehicle_color + $..VEHICLE_COLOR + None + + + + + -1 + -1 + none + N + + + use_nature + $..USE_NATURE + None + + + + + -1 + -1 + none + N + + + first_regist_date + $..FIRST_REGIST_DATE + None + + + + + -1 + -1 + none + N + + + vehicle_status + $..VEHICLE_STATUS + None + + + + + -1 + -1 + none + N + + + engine_model + $..ENGINE_MODEL + None + + + + + -1 + -1 + none + N + + + fuel_type + $..FUEL_TYPE + None + + + + + -1 + -1 + none + N + + + displacement + $..DISPLACEMENT + None + + + + + -1 + -1 + none + N + + + power + $..POWER + None + + + + + -1 + -1 + none + N + + + total_mass + $..TOTAL_MASS + None + + + + + -1 + -1 + none + N + + + approved_passenger_capatity + $..APPROVED_PASSENGER_CAPATITY + None + + + + + -1 + -1 + none + N + + + production_date + $..PRODUCTION_DATE + None + + + + + -1 + -1 + none + N + + + update_date + $..UPDATE_DATE + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + vehicle_category + $..VEHICLE_CATEGORY + None + + + + + -1 + -1 + none + N + + + credential_type + $..CREDENTIAL_TYPE + None + + + + + -1 + -1 + none + N + + + credential_no + $..CREDENTIAL_NO + None + + + + + -1 + -1 + none + N + + + owner_name + $..OWNER_NAME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 784 + 176 + Y + + + + 添加字段信息 + ExecSQL + + Y + + 1 + + none + + + 163_casic_people_livelihood + Y + N + Y + N + alter table ? add ? ? COMMENT '?'; + N + + + + + + + tablename + + + name + + + type + + + comment + + + + + + + + + + + + 352 + 64 + Y + + + 表输入 TableInput @@ -571,48 +2965,21 @@ none - 10.225.240.21-ent - SELECT - qylx -, tzze -, zczb -, yzbm -, qymc -, fddbr -, sszb -, bz -, gq -, djjg -, djjgbm -, qyzt -, hyml -, hydm -, czfs -, clrq -, dzyj -, ybjyxm -, xkjyxm -, sdjggss -, gxjg -, jyqxq -, jyqxz -, zs -, sfzrd -, sfgsq -, hzrq -, gpz -, sjly -, sfcqyx -, dabh -, wxl -, tyshxydm -, zch -, ins -, seq -, updatestatus -, updatetime -FROM resmg.qyjbxxmd127142 - + 交通前置_10.225.240.12 + SELECT + col_description ( A.attrelid, A.attnum ) AS COMMENT, + format_type ( A.atttypid, A.atttypmod ) AS type, + A.attname AS NAME, + 'parking_zh_order_record' as TABLENAME +FROM + pg_class AS C, + pg_attribute AS A +WHERE + C.relname = 'tcjlzfjlb103634' + AND A.attrelid = C.oid + AND A.attnum > 0 + and a.attname not in('ins','seq') + 0 N @@ -623,11 +2990,11 @@ String normal - qylx - 800 + comment + 2147483647 -1 表输入 - qylx + comment . , @@ -646,11 +3013,11 @@ String normal - tzze - 800 + type + 2147483647 -1 表输入 - tzze + type . , @@ -669,11 +3036,11 @@ String normal - zczb - 800 + name + 2147483647 -1 表输入 - zczb + name . , @@ -692,793 +3059,11 @@ String normal - yzbm - 800 - -1 - 表输入 - yzbm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - qymc - 800 - -1 - 表输入 - qymc - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - fddbr - 800 - -1 - 表输入 - fddbr - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sszb - 800 - -1 - 表输入 - sszb - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - bz - 800 - -1 - 表输入 - bz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gq - 800 - -1 - 表输入 - gq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - djjg - 800 - -1 - 表输入 - djjg - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - djjgbm - 800 - -1 - 表输入 - djjgbm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - qyzt - 800 - -1 - 表输入 - qyzt - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hyml - 800 - -1 - 表输入 - hyml - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hydm - 800 - -1 - 表输入 - hydm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - czfs - 800 - -1 - 表输入 - czfs - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - clrq - 50 - -1 - 表输入 - clrq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - dzyj - 800 - -1 - 表输入 - dzyj - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - ybjyxm - 1600 - -1 - 表输入 - ybjyxm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - xkjyxm - 1600 - -1 - 表输入 - xkjyxm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sdjggss - 800 - -1 - 表输入 - sdjggss - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gxjg - 800 - -1 - 表输入 - gxjg - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - jyqxq - 50 - -1 - 表输入 - jyqxq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - jyqxz - 50 - -1 - 表输入 - jyqxz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - zs - 800 - -1 - 表输入 - zs - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfzrd - 800 - -1 - 表输入 - sfzrd - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfgsq - 800 - -1 - 表输入 - sfgsq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hzrq - 50 - -1 - 表输入 - hzrq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gpz - 800 - -1 - 表输入 - gpz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sjly - 800 - -1 - 表输入 - sjly - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfcqyx - 800 - -1 - 表输入 - sfcqyx - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - dabh - 800 - -1 - 表输入 - dabh - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - wxl - 800 - -1 - 表输入 - wxl - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - tyshxydm - 400 - -1 - 表输入 - tyshxydm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - zch - 250 - -1 - 表输入 - zch - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - ins - 9 + tablename + -1 0 表输入 - ins - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - seq - 15 - 0 - 表输入 - seq - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - updatestatus - 15 - 0 - 表输入 - updatestatus - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - updatetime - 50 - -1 - 表输入 - updatetime + tablename . , @@ -1504,52 +3089,8 @@ - 768 - 176 - Y - - - - 表输出 - TableOutput - - Y - - 1 - - none - - - scyy_local - scyy - enterprise_info
- 1000 - N - N - Y - N - N - - N - Y - N - - Y - N - - - - - - - - - - - - - 928 - 176 + 176 + 64 Y diff --git a/casic-web/etl/demo/rest-demo.ktr b/casic-web/etl/demo/rest-demo.ktr index 2ebb670..561eaf8 100644 --- a/casic-web/etl/demo/rest-demo.ktr +++ b/casic-web/etl/demo/rest-demo.ktr @@ -527,6 +527,198 @@ + REST client + Rest + + Y + + 1 + + none + + + TEXT PLAIN + GET + + Y + N + + host + + + Encrypted + + + N + + Encrypted + + + + + + + + result + + + + + + + + + + + + + + 544 + 32 + Y + + + + json转换 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + simcardnum + $..simcardnum + String + + + + + -1 + -1 + none + N + + + recordTime + $..recordTime + None + + + + + -1 + -1 + none + N + + + 0 + Y + N + result + + + + + + + + + + + + + + + + + + 688 + 96 + Y + + + + 文本文件输出 + TextFileOutput + + Y + + 1 + + none + + + ; + " + N + N +
Y
+
N
+ DOS + None + + + N + + Y + + E:\\test.txt + N + N + txt + N + N + N + N + N + N + + Y + N + N + + + + + + + + + + + + + + 480 + 208 + Y + + + 日期参数encode UserDefinedJavaClass @@ -592,6 +784,50 @@ + 更新上报时间 + ExecSQL + + Y + + 1 + + none + + + 163_casic_urban_governance + Y + N + Y + N + update dcms_car_info set recordTime = from_unixtime(?/1000) where simcardnum='?' + N + + + + + + + recordTime + + + simcardnum + + + + + + + + + + + + 688 + 208 + Y + + + 生成随机数 RandomValue @@ -751,242 +987,6 @@ Y - - json转换 - JsonInput - - Y - - 1 - - none - - - N - - N - N - N - N - N - Y - Y - Y - - - - - - N - N - - - - simcardnum - $..simcardnum - String - - - - - -1 - -1 - none - N - - - recordTime - $..recordTime - None - - - - - -1 - -1 - none - N - - - 0 - Y - N - result - - - - - - - - - - - - - - - - - - 688 - 96 - Y - - - - 更新上报时间 - ExecSQL - - Y - - 1 - - none - - - 163_casic_urban_governance - Y - N - Y - N - update dcms_car_info set recordTime = from_unixtime(?/1000) where simcardnum='?' - N - - - - - - - recordTime - - - simcardnum - - - - - - - - - - - - 688 - 208 - Y - - - - 文本文件输出 - TextFileOutput - - Y - - 1 - - none - - - ; - " - N - N -
Y
-
N
- DOS - None - - - N - - Y - - E:\\test.txt - N - N - txt - N - N - N - N - N - N - - Y - N - N - - - - - - - - - - - - - - 480 - 208 - Y - - - - REST client - Rest - - Y - - 1 - - none - - - TEXT PLAIN - GET - - Y - N - - host - - - Encrypted - - - N - - Encrypted - - - - - - - - result - - - - - - - - - - - - - - 544 - 32 - Y - - diff --git a/casic-web/src/main/java/com/casic/missiles/controller/MockController.java b/casic-web/src/main/java/com/casic/missiles/controller/MockController.java index b5de41c..1283383 100644 --- a/casic-web/src/main/java/com/casic/missiles/controller/MockController.java +++ b/casic-web/src/main/java/com/casic/missiles/controller/MockController.java @@ -7,6 +7,7 @@ import com.casic.missiles.core.log.LogManager; import com.casic.missiles.core.log.factory.LogTaskFactory; import com.casic.missiles.core.service.IDynamicJobService; +import com.casic.missiles.core.shiro.CasicCustomeToken; import com.casic.missiles.core.shiro.ShiroKit; import com.casic.missiles.core.shiro.ShiroUser; import com.casic.missiles.core.util.RSAUtils; @@ -73,10 +74,10 @@ } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } +// UsernamePasswordToken token = new UsernamePasswordToken(username, password.toCharArray()); +// token.setRememberMe(false); + CasicCustomeToken token = new CasicCustomeToken(username); - - UsernamePasswordToken token = new UsernamePasswordToken(username, password.toCharArray()); - token.setRememberMe(false); try { currentUser.login(token); } catch (Exception e) { diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java index 7f389ec..59fc808 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/enums/ResTypeEnums.java @@ -2,7 +2,7 @@ /** * @ClassName ResTypeEnums - * @Description TODO + * @Description TODO * @Author lenovo * @Date 2020/9/18 18:08 * @Version 1.0 diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java index 7d5c105..efa941b 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/ExternalViewConfigServiceImpl.java @@ -24,10 +24,10 @@ /** *

* 共享交换数据集配置表 - * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 + * 共享交换数字模型地址:http://11.100.5.8:8080/platformbigdata/modelservlet 服务实现类 *

* - * @author stylefeng123 + * @author stylefeng123 * @since 2020-10-19 */ @Service diff --git a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr index f9ba53e..02363d6 100644 --- a/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr +++ b/casic-web/etl/casic_industrial_economy/enterprise_trans.ktr @@ -435,1224 +435,8 @@ - - 163_casic_optmonitoring - 11.100.6.163 - MYSQL - Native - casic_optmonitoring - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 163_casic_industrial_economy - 11.100.6.163 - MYSQL - Native - casic_industrial_economy - 3306 - root - Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 - - - - - - EXTRA_OPTION_MYSQL.characterEncoding - utf8 - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 3306 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - STREAM_RESULTS - Y - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - 企业信息服务接口 - 解析code信息 - Y - - - 生成随机数 - 读取项目任务增量时间 - Y - - - 解析code信息 - 企业数据同步更新 - Y - - - 参数转换 - 企业信息服务接口 - Y - - - 读取项目任务增量时间 - 参数转换 - Y - - - 企业信息服务接口 - Rest - - Y - - 1 - - none - - - JSON - GET - http://11.100.5.8:8080/platformbigdata/modelservlet?appkey=53a21bdd-626a-4b3b-9170-0c79498193e6&id=155&param_dsid=1138&flag=97&format=json&&param_PAGESIZE=100000 - Y - N - - HOST - - - Encrypted - - - N - - Encrypted - - - - - - - - result - - - - - - - - - - - - - - 544 - 160 - Y - - - - 企业数据同步更新 - InsertUpdate - - Y - - 1 - - none - - - 163_casic_industrial_economy - 500 - N - - casic_industrial_economy - enterprise_info
- - zch - zch - = - - - - zch - zch - N - - - qylx - qylx - Y - - - tzze - tzze - Y - - - zczb - zczb - Y - - - yzbm - yzbm - Y - - - qymc - qymc - Y - - - fddbr - fddbr - Y - - - sszb - sszb - Y - - - bz - bz - Y - - - gq - gq - Y - - - djjg - djjg - Y - - - djjgbm - djjgbm - Y - - - qyzt - qyzt - Y - - - hyml - hyml - Y - - - hydm - hydm - Y - - - czfs - czfs - Y - - - clrq - clrq - Y - - - dzyj - dzyj - Y - - - ybjyxm - ybjyxm - Y - - - xkjyxm - xkjyxm - Y - - - sdjggss - sdjggss - Y - - - gxjg - gxjg - Y - - - jyqxq - jyqxq - Y - - - jyqxz - jyqxz - Y - - - zs - zs - Y - - - sfzrd - sfzrd - Y - - - sfgsq - sfgsq - Y - - - hzrq - hzrq - Y - - - gpz - gpz - Y - - - sjly - sjly - Y - - - sfcqyx - sfcqyx - Y - - - dabh - dabh - Y - - - tyshxydm - tyshxydm - Y - - - updatetime - updatetime - Y - - - - - - - - - - - - 816 - 160 - Y - - - - 参数转换 - UserDefinedJavaClass - - Y - - 1 - - none - - - - - TRANSFORM_CLASS - Processor - // 生成的代码片段 -public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws Exception { - if (first) { - first = false; - } - - Object[] r = getRow(); - - - if (r == null) { - setOutputDone(); - return false; - } - - r = createOutputRow(r, data.outputRowMeta.size()); - String condition= get(Fields.In, "REST_RULE").getString(r); - String host= get(Fields.In, "HOST").getString(r); - String value= get(Fields.In, "REST_PARAMS").getString(r); - Object[] params = value.split(","); - String outcondition =host+"&param_condition="+java.net.URLEncoder.encode(String.format(condition,params),"UTF-8"); - get(Fields.Out,"HOST").setValue(r,outcondition); - putRow(data.outputRowMeta, r); - - return true; -} - - - - - - N - - - - - - - - - - - - - 384 - 160 - Y - - - - 生成随机数 - RandomValue - - Y - - 1 - - none - - - - - - - - - - - - - - 80 - 160 - Y - - - - 解析code信息 - JsonInput - - Y - - 1 - - none - - - N - - N - N - N - N - N - Y - Y - Y - - - - - - N - N - - - - zch - $..ZCH - None - - - - - -1 - -1 - none - N - - - qylx - $..QYLX - None - - - - - -1 - -1 - none - N - - - tzze - $..TZZE - None - - - - - -1 - -1 - none - N - - - zczb - $..ZCZB - None - - - - - -1 - -1 - none - N - - - yzbm - $..YZBM - None - - - - - -1 - -1 - none - N - - - qymc - $..QYMC - None - - - - - -1 - -1 - none - N - - - fddbr - $..FDDBR - None - - - - - -1 - -1 - none - N - - - sszb - $..SSZB - None - - - - - -1 - -1 - none - N - - - bz - $..BZ - None - - - - - -1 - -1 - none - N - - - gq - $..GQ - None - - - - - -1 - -1 - none - N - - - djjg - $..DJJG - None - - - - - -1 - -1 - none - N - - - djjgbm - $..DJJGBM - None - - - - - -1 - -1 - none - N - - - qyzt - $..QYZT - None - - - - - -1 - -1 - none - N - - - hyml - $..HYML - None - - - - - -1 - -1 - none - N - - - hydm - $..HYDM - None - - - - - -1 - -1 - none - N - - - czfs - $..CZFS - None - - - - - -1 - -1 - none - N - - - clrq - $..CLRQ - None - - - - - -1 - -1 - none - N - - - dzyj - $..DZYJ - None - - - - - -1 - -1 - none - N - - - ybjyxm - $..YBJYXM - None - - - - - -1 - -1 - none - N - - - xkjyxm - $..XKJYXM - None - - - - - -1 - -1 - none - N - - - sdjggss - $..SDJGGSS - None - - - - - -1 - -1 - none - N - - - gxjg - $..GXJG - None - - - - - -1 - -1 - none - N - - - jyqxq - $..JYQXQ - None - - - - - -1 - -1 - none - N - - - jyqxz - $..JYQXZ - None - - - - - -1 - -1 - none - N - - - zs - $..ZS - None - - - - - -1 - -1 - none - N - - - sfzrd - $..SFZRD - None - - - - - -1 - -1 - none - N - - - sfgsq - $..SFGSQ - None - - - - - -1 - -1 - none - N - - - hzrq - $..HZRQ - None - - - - - -1 - -1 - none - N - - - gpz - $..GPZ - None - - - - - -1 - -1 - none - N - - - sjly - $..SJLY - None - - - - - -1 - -1 - none - N - - - sfcqyx - $..SFCQYX - None - - - - - -1 - -1 - none - N - - - dabh - $..DABH - None - - - - - -1 - -1 - none - N - - - tyshxydm - $..TYSHXYDM - None - - - - - -1 - -1 - none - N - - - updatetime - $..UPDATETIME - None - - - - - -1 - -1 - none - N - - - 0 - Y - N - result - - - - - - - - - - - - - - - - - - 704 - 160 - Y - - - - 读取项目任务增量时间 - TableInput - - Y - - 1 - - none - - - 163_casic_optmonitoring - SELECT - ID -, CODE,REST_RULE,REST_PARAMS -, TITLE,concat(HOST,DEFAULT_PARAMS) as HOST -, REST_PARAMS,DATE_FORMAT(NOW(),'%Y-%m-%d %H:%i:%s') as CURR_INCREMENT_DATE -FROM casic_optmonitoring.kettle_increment_config where code='entprise' - 0 - - N - N - N - N - - - Integer - normal - ID - 15 - 0 - 读取项目任务增量时间 - ID - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CODE - 32 - -1 - 读取项目任务增量时间 - CODE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_RULE - 255 - -1 - 读取项目任务增量时间 - REST_RULE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - REST_PARAMS - 255 - -1 - 读取项目任务增量时间 - REST_PARAMS - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - TITLE - 64 - -1 - 读取项目任务增量时间 - TITLE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - HOST - 319 - -1 - 读取项目任务增量时间 - HOST - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - INCREMENT_DATE - 64 - -1 - 读取项目任务增量时间 - INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - CURR_INCREMENT_DATE - 24 - -1 - 读取项目任务增量时间 - CURR_INCREMENT_DATE - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - - - - - - - - - - 224 - 160 - Y - - diff --git a/casic-web/etl/demo/front_db_demo.ktr b/casic-web/etl/demo/front_db_demo.ktr index e606d8c..d170fef 100644 --- a/casic-web/etl/demo/front_db_demo.ktr +++ b/casic-web/etl/demo/front_db_demo.ktr @@ -436,73 +436,14 @@ - 10.225.240.21-ent - 10.225.240.21 - POSTGRESQL - Native - front_db - 5432 - resmg - Encrypted 2be98afc86aa7f2e4cb79bc75cd9fa88b - - - - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - INITIAL_POOL_SIZE - 10 - - - IS_CLUSTERED - N - - - MAXIMUM_POOL_SIZE - 5 - - - PORT_NUMBER - 5432 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - Y - - - - - scyy_local - ${source_local.server} + 163_casic_people_livelihood + 11.100.6.163 MYSQL Native - ${source_local.database} + casic_people_livelihood 3306 - ${source_local.username} - ${source_local.password} + root + Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89 @@ -553,14 +494,2467 @@ + + 交通前置_10.225.240.12 + 10.225.240.12 + POSTGRESQL + Native + front_db + 5432 + resmg + Encrypted 2be98afc86aa7f2e4cb79bc75cd9fa88b + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + 表输入 - 表输出 + 添加字段信息 Y + 家庭关系映射 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + vehicle_no + $..VEHICLE_NO + None + + + + + -1 + -1 + none + N + + + source_type + $..SOURCE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_type + $..PLATE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_no + $..PLATE_NO + None + + + + + -1 + -1 + none + N + + + region + $..REGION + None + + + + + -1 + -1 + none + N + + + certification_official + $..CERTIFICATION_OFFICIAL + None + + + + + -1 + -1 + none + N + + + vehicle_brand + $..VEHICLE_BRAND + None + + + + + -1 + -1 + none + N + + + vehicle_model + $..VEHICLE_MODEL + None + + + + + -1 + -1 + none + N + + + vehicle_identification_code + $..VEHICLE_IDENTIFICATION_CODE + None + + + + + -1 + -1 + none + N + + + engine_no + $..ENGINE_NO + None + + + + + -1 + -1 + none + N + + + vehicle_type + $..VEHICLE_TYPE + None + + + + + -1 + -1 + none + N + + + vehicle_color + $..VEHICLE_COLOR + None + + + + + -1 + -1 + none + N + + + use_nature + $..USE_NATURE + None + + + + + -1 + -1 + none + N + + + first_regist_date + $..FIRST_REGIST_DATE + None + + + + + -1 + -1 + none + N + + + vehicle_status + $..VEHICLE_STATUS + None + + + + + -1 + -1 + none + N + + + engine_model + $..ENGINE_MODEL + None + + + + + -1 + -1 + none + N + + + fuel_type + $..FUEL_TYPE + None + + + + + -1 + -1 + none + N + + + displacement + $..DISPLACEMENT + None + + + + + -1 + -1 + none + N + + + power + $..POWER + None + + + + + -1 + -1 + none + N + + + total_mass + $..TOTAL_MASS + None + + + + + -1 + -1 + none + N + + + approved_passenger_capatity + $..APPROVED_PASSENGER_CAPATITY + None + + + + + -1 + -1 + none + N + + + production_date + $..PRODUCTION_DATE + None + + + + + -1 + -1 + none + N + + + update_date + $..UPDATE_DATE + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + vehicle_category + $..VEHICLE_CATEGORY + None + + + + + -1 + -1 + none + N + + + credential_type + $..CREDENTIAL_TYPE + None + + + + + -1 + -1 + none + N + + + credential_no + $..CREDENTIAL_NO + None + + + + + -1 + -1 + none + N + + + owner_name + $..OWNER_NAME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 880 + 176 + Y + + + + 订单支付数据转换 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + order_no + $..ORDER_NO + None + + + + + -1 + -1 + none + N + + + park_id + $..PARK_ID + None + + + + + -1 + -1 + none + N + + + car_no + $..CAR_NO + None + + + + + -1 + -1 + none + N + + + car_user_id + $..CAR_USER_ID + None + + + + + -1 + -1 + none + N + + + biz_code + $..BIZ_CODE + None + + + + + -1 + -1 + none + N + + + order_type + $..ORDER_TYPE + None + + + + + -1 + -1 + none + N + + + coupon_detail_id + $..COUPON_DETAIL_ID + None + + + + + -1 + -1 + none + N + + + pay_type + $..PAY_TYPE + None + + + + + -1 + -1 + none + N + + + pay_code + $..PAY_CODE + None + + + + + -1 + -1 + none + N + + + trade_no + $..TRADE_NO + None + + + + + -1 + -1 + none + N + + + receivable_amount + $..RECEIVABLE_AMOUNT + None + + + + + -1 + -1 + none + N + + + receive_amount + $..RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + local_receive_amount + $..LOCAL_RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + online_receive_amount + $..ONLINE_RECEIVE_AMOUNT + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + update_time + $..UPDATE_TIME + None + + + + + -1 + -1 + none + N + + + version + $..VERSION + None + + + + + -1 + -1 + none + N + + + status + $..STATUS + None + + + + + -1 + -1 + none + N + + + sync_status + $..SYNC_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + 0 + Y + N + result + + + + + + + + + + + + + + + + + + 313 + 421 + Y + + + + 房屋数据映射 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + house_purpose_type + $..HOUSE_PURPOSE_TYPE + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + tenant_id + $..TENANT_ID + None + + + + + -1 + -1 + none + N + + + house_number + $..HOUSE_NUMBER + None + + + + + -1 + -1 + none + N + + + province_name + $..PROVINCE_NAME + None + + + + + -1 + -1 + none + N + + + province_type + $..PROVINCE_TYPE + None + + + + + -1 + -1 + none + N + + + city_name + $..CITY_NAME + None + + + + + -1 + -1 + none + N + + + city_type + $..CITY_TYPE + None + + + + + -1 + -1 + none + N + + + district_name + $..DISTRICT_NAME + None + + + + + -1 + -1 + none + N + + + district_type + $..DISTRICT_TYPE + None + + + + + -1 + -1 + none + N + + + street_name + $..STREET_NAME + None + + + + + -1 + -1 + none + N + + + road_name + $..ROAD_NAME + None + + + + + -1 + -1 + none + N + + + card_name + $..CARD_NAME + None + + + + + -1 + -1 + none + N + + + community_name + $..COMMUNITY_NAME + None + + + + + -1 + -1 + none + N + + + community_id + $..COMMUNITY_ID + None + + + + + -1 + -1 + none + N + + + village_tenant_no + $..VILLAGE_TENANT_NO + None + + + + + -1 + -1 + none + N + + + village_name + $..VILLAGE_NAME + None + + + + + -1 + -1 + none + N + + + village_id + $..VILLAGE_ID + None + + + + + -1 + -1 + none + N + + + zone_name + $..ZONE_NAME + None + + + + + -1 + -1 + none + N + + + zone_id + $..ZONE_ID + None + + + + + -1 + -1 + none + N + + + building_name + $..BUILDING_NAME + None + + + + + -1 + -1 + none + N + + + building_id + $..BUILDING_ID + None + + + + + -1 + -1 + none + N + + + unit_name + $..UNIT_NAME + None + + + + + -1 + -1 + none + N + + + unit_id + $..UNIT_ID + None + + + + + -1 + -1 + none + N + + + house_name + $..HOUSE_NAME + None + + + + + -1 + -1 + none + N + + + address + $..ADDRESS + None + + + + + -1 + -1 + none + N + + + built_area + $..BUILT_AREA + None + + + + + -1 + -1 + none + N + + + actual_area + $..ACTUAL_AREA + None + + + + + -1 + -1 + none + N + + + floor + $..FLOOR + None + + + + + -1 + -1 + none + N + + + room_count + $..ROOM_COUNT + None + + + + + -1 + -1 + none + N + + + office_count + $..OFFICE_COUNT + None + + + + + -1 + -1 + none + N + + + wc_count + $..WC_COUNT + None + + + + + -1 + -1 + none + N + + + max_people_number + $..MAX_PEOPLE_NUMBER + None + + + + + -1 + -1 + none + N + + + lon + $..LON + None + + + + + -1 + -1 + none + N + + + lat + $..LAT + None + + + + + -1 + -1 + none + N + + + alt + $..ALT + None + + + + + -1 + -1 + none + N + + + gis_area + $..GIS_AREA + None + + + + + -1 + -1 + none + N + + + gis_type + $..GIS_TYPE + None + + + + + -1 + -1 + none + N + + + house_details + $..HOUSE_DETAILS + None + + + + + -1 + -1 + none + N + + + house_pic_urls + $..HOUSE_PIC_URLS + None + + + + + -1 + -1 + none + N + + + source + $..SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + house_type + $..HOUSE_TYPE + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 976 + 176 + Y + + + + 投诉建议表 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + report_by_user_phone + $..REPORT_BY_USER_PHONE + None + + + + + -1 + -1 + none + N + + + report_by_village_id + $..REPORT_BY_VILLAGE_ID + None + + + + + -1 + -1 + none + N + + + report_by_village_name + $..REPORT_BY_VILLAGE_NAME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + tenant_id + $..TENANT_ID + None + + + + + -1 + -1 + none + N + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + complaint_tag + $..COMPLAINT_TAG + None + + + + + -1 + -1 + none + N + + + detail + $..DETAIL + None + + + + + -1 + -1 + none + N + + + report_by_user_id + $..REPORT_BY_USER_ID + None + + + + + -1 + -1 + none + N + + + report_time + $..REPORT_TIME + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + complaint_type + $..COMPLAINT_TYPE + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 1056 + 176 + Y + + + + 机动车数据 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + tenant_no + $..TENANT_NO + None + + + + + -1 + -1 + none + N + + + vehicle_no + $..VEHICLE_NO + None + + + + + -1 + -1 + none + N + + + source_type + $..SOURCE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_type + $..PLATE_TYPE + None + + + + + -1 + -1 + none + N + + + plate_no + $..PLATE_NO + None + + + + + -1 + -1 + none + N + + + region + $..REGION + None + + + + + -1 + -1 + none + N + + + certification_official + $..CERTIFICATION_OFFICIAL + None + + + + + -1 + -1 + none + N + + + vehicle_brand + $..VEHICLE_BRAND + None + + + + + -1 + -1 + none + N + + + vehicle_model + $..VEHICLE_MODEL + None + + + + + -1 + -1 + none + N + + + vehicle_identification_code + $..VEHICLE_IDENTIFICATION_CODE + None + + + + + -1 + -1 + none + N + + + engine_no + $..ENGINE_NO + None + + + + + -1 + -1 + none + N + + + vehicle_type + $..VEHICLE_TYPE + None + + + + + -1 + -1 + none + N + + + vehicle_color + $..VEHICLE_COLOR + None + + + + + -1 + -1 + none + N + + + use_nature + $..USE_NATURE + None + + + + + -1 + -1 + none + N + + + first_regist_date + $..FIRST_REGIST_DATE + None + + + + + -1 + -1 + none + N + + + vehicle_status + $..VEHICLE_STATUS + None + + + + + -1 + -1 + none + N + + + engine_model + $..ENGINE_MODEL + None + + + + + -1 + -1 + none + N + + + fuel_type + $..FUEL_TYPE + None + + + + + -1 + -1 + none + N + + + displacement + $..DISPLACEMENT + None + + + + + -1 + -1 + none + N + + + power + $..POWER + None + + + + + -1 + -1 + none + N + + + total_mass + $..TOTAL_MASS + None + + + + + -1 + -1 + none + N + + + approved_passenger_capatity + $..APPROVED_PASSENGER_CAPATITY + None + + + + + -1 + -1 + none + N + + + production_date + $..PRODUCTION_DATE + None + + + + + -1 + -1 + none + N + + + update_date + $..UPDATE_DATE + None + + + + + -1 + -1 + none + N + + + create_time + $..CREATE_TIME + None + + + + + -1 + -1 + none + N + + + modify_time + $..MODIFY_TIME + None + + + + + -1 + -1 + none + N + + + operation_source + $..OPERATION_SOURCE + None + + + + + -1 + -1 + none + N + + + operation_tag + $..OPERATION_TAG + None + + + + + -1 + -1 + none + N + + + vehicle_category + $..VEHICLE_CATEGORY + None + + + + + -1 + -1 + none + N + + + credential_type + $..CREDENTIAL_TYPE + None + + + + + -1 + -1 + none + N + + + credential_no + $..CREDENTIAL_NO + None + + + + + -1 + -1 + none + N + + + owner_name + $..OWNER_NAME + None + + + + + -1 + -1 + none + N + + + data_status + $..DATA_STATUS + None + + + + + -1 + -1 + none + N + + + updatestatus + $..UPDATESTATUS + None + + + + + -1 + -1 + none + N + + + updatetime + $..UPDATETIME + None + + + + + -1 + -1 + none + N + + + id + $..ID + None + + + + + -1 + -1 + none + N + + + 0 + N + N + + + + + + + + + + + + + + + + + + + 784 + 176 + Y + + + + 添加字段信息 + ExecSQL + + Y + + 1 + + none + + + 163_casic_people_livelihood + Y + N + Y + N + alter table ? add ? ? COMMENT '?'; + N + + + + + + + tablename + + + name + + + type + + + comment + + + + + + + + + + + + 352 + 64 + Y + + + 表输入 TableInput @@ -571,48 +2965,21 @@ none - 10.225.240.21-ent - SELECT - qylx -, tzze -, zczb -, yzbm -, qymc -, fddbr -, sszb -, bz -, gq -, djjg -, djjgbm -, qyzt -, hyml -, hydm -, czfs -, clrq -, dzyj -, ybjyxm -, xkjyxm -, sdjggss -, gxjg -, jyqxq -, jyqxz -, zs -, sfzrd -, sfgsq -, hzrq -, gpz -, sjly -, sfcqyx -, dabh -, wxl -, tyshxydm -, zch -, ins -, seq -, updatestatus -, updatetime -FROM resmg.qyjbxxmd127142 - + 交通前置_10.225.240.12 + SELECT + col_description ( A.attrelid, A.attnum ) AS COMMENT, + format_type ( A.atttypid, A.atttypmod ) AS type, + A.attname AS NAME, + 'parking_zh_order_record' as TABLENAME +FROM + pg_class AS C, + pg_attribute AS A +WHERE + C.relname = 'tcjlzfjlb103634' + AND A.attrelid = C.oid + AND A.attnum > 0 + and a.attname not in('ins','seq') + 0 N @@ -623,11 +2990,11 @@ String normal - qylx - 800 + comment + 2147483647 -1 表输入 - qylx + comment . , @@ -646,11 +3013,11 @@ String normal - tzze - 800 + type + 2147483647 -1 表输入 - tzze + type . , @@ -669,11 +3036,11 @@ String normal - zczb - 800 + name + 2147483647 -1 表输入 - zczb + name . , @@ -692,793 +3059,11 @@ String normal - yzbm - 800 - -1 - 表输入 - yzbm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - qymc - 800 - -1 - 表输入 - qymc - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - fddbr - 800 - -1 - 表输入 - fddbr - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sszb - 800 - -1 - 表输入 - sszb - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - bz - 800 - -1 - 表输入 - bz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gq - 800 - -1 - 表输入 - gq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - djjg - 800 - -1 - 表输入 - djjg - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - djjgbm - 800 - -1 - 表输入 - djjgbm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - qyzt - 800 - -1 - 表输入 - qyzt - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hyml - 800 - -1 - 表输入 - hyml - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hydm - 800 - -1 - 表输入 - hydm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - czfs - 800 - -1 - 表输入 - czfs - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - clrq - 50 - -1 - 表输入 - clrq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - dzyj - 800 - -1 - 表输入 - dzyj - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - ybjyxm - 1600 - -1 - 表输入 - ybjyxm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - xkjyxm - 1600 - -1 - 表输入 - xkjyxm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sdjggss - 800 - -1 - 表输入 - sdjggss - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gxjg - 800 - -1 - 表输入 - gxjg - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - jyqxq - 50 - -1 - 表输入 - jyqxq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - jyqxz - 50 - -1 - 表输入 - jyqxz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - zs - 800 - -1 - 表输入 - zs - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfzrd - 800 - -1 - 表输入 - sfzrd - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfgsq - 800 - -1 - 表输入 - sfgsq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - hzrq - 50 - -1 - 表输入 - hzrq - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - gpz - 800 - -1 - 表输入 - gpz - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sjly - 800 - -1 - 表输入 - sjly - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - sfcqyx - 800 - -1 - 表输入 - sfcqyx - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - dabh - 800 - -1 - 表输入 - dabh - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - wxl - 800 - -1 - 表输入 - wxl - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - tyshxydm - 400 - -1 - 表输入 - tyshxydm - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - zch - 250 - -1 - 表输入 - zch - - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - ins - 9 + tablename + -1 0 表输入 - ins - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - seq - 15 - 0 - 表输入 - seq - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - Integer - normal - updatestatus - 15 - 0 - 表输入 - updatestatus - ####0;-####0 - . - , - - none - N - Y - 0 - N - N - N - zh_CN - Asia/Shanghai - N - - - String - normal - updatetime - 50 - -1 - 表输入 - updatetime + tablename . , @@ -1504,52 +3089,8 @@ - 768 - 176 - Y - - - - 表输出 - TableOutput - - Y - - 1 - - none - - - scyy_local - scyy - enterprise_info
- 1000 - N - N - Y - N - N - - N - Y - N - - Y - N - - - - - - - - - - - - - 928 - 176 + 176 + 64 Y diff --git a/casic-web/etl/demo/rest-demo.ktr b/casic-web/etl/demo/rest-demo.ktr index 2ebb670..561eaf8 100644 --- a/casic-web/etl/demo/rest-demo.ktr +++ b/casic-web/etl/demo/rest-demo.ktr @@ -527,6 +527,198 @@ + REST client + Rest + + Y + + 1 + + none + + + TEXT PLAIN + GET + + Y + N + + host + + + Encrypted + + + N + + Encrypted + + + + + + + + result + + + + + + + + + + + + + + 544 + 32 + Y + + + + json转换 + JsonInput + + Y + + 1 + + none + + + N + + N + N + N + N + N + Y + Y + Y + + + + + + N + N + + + + simcardnum + $..simcardnum + String + + + + + -1 + -1 + none + N + + + recordTime + $..recordTime + None + + + + + -1 + -1 + none + N + + + 0 + Y + N + result + + + + + + + + + + + + + + + + + + 688 + 96 + Y + + + + 文本文件输出 + TextFileOutput + + Y + + 1 + + none + + + ; + " + N + N +
Y
+
N
+ DOS + None + + + N + + Y + + E:\\test.txt + N + N + txt + N + N + N + N + N + N + + Y + N + N + + + + + + + + + + + + + + 480 + 208 + Y + + + 日期参数encode UserDefinedJavaClass @@ -592,6 +784,50 @@ + 更新上报时间 + ExecSQL + + Y + + 1 + + none + + + 163_casic_urban_governance + Y + N + Y + N + update dcms_car_info set recordTime = from_unixtime(?/1000) where simcardnum='?' + N + + + + + + + recordTime + + + simcardnum + + + + + + + + + + + + 688 + 208 + Y + + + 生成随机数 RandomValue @@ -751,242 +987,6 @@ Y - - json转换 - JsonInput - - Y - - 1 - - none - - - N - - N - N - N - N - N - Y - Y - Y - - - - - - N - N - - - - simcardnum - $..simcardnum - String - - - - - -1 - -1 - none - N - - - recordTime - $..recordTime - None - - - - - -1 - -1 - none - N - - - 0 - Y - N - result - - - - - - - - - - - - - - - - - - 688 - 96 - Y - - - - 更新上报时间 - ExecSQL - - Y - - 1 - - none - - - 163_casic_urban_governance - Y - N - Y - N - update dcms_car_info set recordTime = from_unixtime(?/1000) where simcardnum='?' - N - - - - - - - recordTime - - - simcardnum - - - - - - - - - - - - 688 - 208 - Y - - - - 文本文件输出 - TextFileOutput - - Y - - 1 - - none - - - ; - " - N - N -
Y
-
N
- DOS - None - - - N - - Y - - E:\\test.txt - N - N - txt - N - N - N - N - N - N - - Y - N - N - - - - - - - - - - - - - - 480 - 208 - Y - - - - REST client - Rest - - Y - - 1 - - none - - - TEXT PLAIN - GET - - Y - N - - host - - - Encrypted - - - N - - Encrypted - - - - - - - - result - - - - - - - - - - - - - - 544 - 32 - Y - - diff --git a/casic-web/src/main/java/com/casic/missiles/controller/MockController.java b/casic-web/src/main/java/com/casic/missiles/controller/MockController.java index b5de41c..1283383 100644 --- a/casic-web/src/main/java/com/casic/missiles/controller/MockController.java +++ b/casic-web/src/main/java/com/casic/missiles/controller/MockController.java @@ -7,6 +7,7 @@ import com.casic.missiles.core.log.LogManager; import com.casic.missiles.core.log.factory.LogTaskFactory; import com.casic.missiles.core.service.IDynamicJobService; +import com.casic.missiles.core.shiro.CasicCustomeToken; import com.casic.missiles.core.shiro.ShiroKit; import com.casic.missiles.core.shiro.ShiroUser; import com.casic.missiles.core.util.RSAUtils; @@ -73,10 +74,10 @@ } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } +// UsernamePasswordToken token = new UsernamePasswordToken(username, password.toCharArray()); +// token.setRememberMe(false); + CasicCustomeToken token = new CasicCustomeToken(username); - - UsernamePasswordToken token = new UsernamePasswordToken(username, password.toCharArray()); - token.setRememberMe(false); try { currentUser.login(token); } catch (Exception e) { diff --git a/casic-web/src/main/resources/config/application.yml b/casic-web/src/main/resources/config/application.yml index f2590f2..fd9bafb 100644 --- a/casic-web/src/main/resources/config/application.yml +++ b/casic-web/src/main/resources/config/application.yml @@ -36,7 +36,7 @@ password: a58cc7c077b1ece3fad6923bf8f35d71 appKey: 53a21bdd-626a-4b3b-9170-0c79498193e6 #可视化应用app key elasticjob: - enabled: true + enabled: false reg-center: serverLists: zookeeper.com:2181 namespace: elasticjob-lite-springboot