ids);
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/cignacmb/BusinessRuleLogMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/cignacmb/BusinessRuleLogMapper.xml
new file mode 100644
index 0000000..9372328
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/cignacmb/BusinessRuleLogMapper.xml
@@ -0,0 +1,85 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/cignacmb/TBusinessRuleRelMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/cignacmb/TBusinessRuleRelMapper.java
new file mode 100644
index 0000000..558f84f
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/cignacmb/TBusinessRuleRelMapper.java
@@ -0,0 +1,16 @@
+package com.fibo.ddp.common.dao.cignacmb;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.cignacmb.TBusinessRuleRel;
+
+/**
+ *
+ * 业务类型与规则关联表 Mapper 接口
+ *
+ *
+ * @author oldRose
+ * @since 2021-11-10
+ */
+public interface TBusinessRuleRelMapper extends BaseMapper {
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/cignacmb/TBusinessRuleRelMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/cignacmb/TBusinessRuleRelMapper.xml
new file mode 100644
index 0000000..ef59c64
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/cignacmb/TBusinessRuleRelMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/AppTemplateMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/AppTemplateMapper.java
new file mode 100644
index 0000000..0bc4650
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/AppTemplateMapper.java
@@ -0,0 +1,16 @@
+package com.fibo.ddp.common.dao.common.message.template;
+
+import com.fibo.ddp.common.model.common.message.template.entity.AppTemplate;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * APP推送模板表(AppTemplate)表数据库访问层
+ *
+ * @author andy.wang
+ * @since 2022-01-07 18:11:16
+ */
+@Mapper
+public interface AppTemplateMapper extends BaseMapper{
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/AppTemplateMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/AppTemplateMapper.xml
new file mode 100644
index 0000000..93e40ab
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/AppTemplateMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/MessageSendRecordMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/MessageSendRecordMapper.java
new file mode 100644
index 0000000..623acf9
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/MessageSendRecordMapper.java
@@ -0,0 +1,16 @@
+package com.fibo.ddp.common.dao.common.message.template;
+
+import com.fibo.ddp.common.model.common.message.template.entity.MessageSendRecord;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 消息发送记录表(MessageSendRecord)表数据库访问层
+ *
+ * @author andy.wang
+ * @since 2022-01-07 18:13:24
+ */
+@Mapper
+public interface MessageSendRecordMapper extends BaseMapper{
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/MessageSendRecordMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/MessageSendRecordMapper.xml
new file mode 100644
index 0000000..9608f0c
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/MessageSendRecordMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/SmsTemplateMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/SmsTemplateMapper.java
new file mode 100644
index 0000000..d24425a
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/SmsTemplateMapper.java
@@ -0,0 +1,16 @@
+package com.fibo.ddp.common.dao.common.message.template;
+
+import com.fibo.ddp.common.model.common.message.template.entity.SmsTemplate;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 短信模板表(SmsTemplate)表数据库访问层
+ *
+ * @author andy.wang
+ * @since 2022-01-07 18:11:16
+ */
+@Mapper
+public interface SmsTemplateMapper extends BaseMapper{
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/SmsTemplateMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/SmsTemplateMapper.xml
new file mode 100644
index 0000000..cb4428d
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/SmsTemplateMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WebhookTemplateMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WebhookTemplateMapper.java
new file mode 100644
index 0000000..d9e730d
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WebhookTemplateMapper.java
@@ -0,0 +1,16 @@
+package com.fibo.ddp.common.dao.common.message.template;
+
+import com.fibo.ddp.common.model.common.message.template.entity.WebhookTemplate;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * webhook模板表(WebhookTemplate)表数据库访问层
+ *
+ * @author andy.wang
+ * @since 2022-01-07 18:12:03
+ */
+@Mapper
+public interface WebhookTemplateMapper extends BaseMapper{
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WebhookTemplateMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WebhookTemplateMapper.xml
new file mode 100644
index 0000000..719e584
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WebhookTemplateMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WechatTemplateMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WechatTemplateMapper.java
new file mode 100644
index 0000000..e436e80
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WechatTemplateMapper.java
@@ -0,0 +1,16 @@
+package com.fibo.ddp.common.dao.common.message.template;
+
+import com.fibo.ddp.common.model.common.message.template.entity.WechatTemplate;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 微信服务号模板表(WechatTemplate)表数据库访问层
+ *
+ * @author andy.wang
+ * @since 2022-01-07 18:11:16
+ */
+@Mapper
+public interface WechatTemplateMapper extends BaseMapper{
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WechatTemplateMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WechatTemplateMapper.xml
new file mode 100644
index 0000000..5d119f4
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/common/message/template/WechatTemplateMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datainterface/InterfaceMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datainterface/InterfaceMapper.java
new file mode 100644
index 0000000..55c403b
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datainterface/InterfaceMapper.java
@@ -0,0 +1,18 @@
+package com.fibo.ddp.common.dao.datax.datainterface;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.datax.datainterface.InterfaceInfo;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@Mapper
+public interface InterfaceMapper extends BaseMapper {
+ int updateStatus(@Param(value = "ids") Long[] ids, @Param(value = "status") Integer status);
+
+ List queryInterfaceList(InterfaceInfo interfaceInfo);
+
+ List queryLimit(@Param(value = "start") int start, @Param(value = "size") int size);
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datainterface/InterfaceMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datainterface/InterfaceMapper.xml
new file mode 100644
index 0000000..c8be5c4
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datainterface/InterfaceMapper.xml
@@ -0,0 +1,75 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ update riskmanage.t_field_interface set status = #{status}
+ where id in
+
+ #{interfaceId}
+
+
+
+
+
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/CustListMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/CustListMapper.java
new file mode 100644
index 0000000..45204a4
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/CustListMapper.java
@@ -0,0 +1,89 @@
+package com.fibo.ddp.common.dao.datax.datamanage;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.datax.datamanage.CustList;
+
+import java.util.List;
+import java.util.Map;
+
+public interface CustListMapper extends BaseMapper {
+
+ /**
+ * findCustList:(查找黑/白名单库的客户名单列表).
+ * @param paramMap 参数集合
+ * @return
+ * */
+ public List findCustList(Map paramMap);
+
+ /**
+ * checkDupCustList:(根据输入的客户信息参数在黑(白)名单库里查找是否存在).
+ * @param paramMap 参数集合
+ * @return 存在的结果
+ * */
+ public int checkDupCustList(Map paramMap);
+
+ /**
+ * importOneCustList:(导入一条黑(白)名单客户信息数据).
+ * @param paramMap 参数集合
+ * @return 存在的结果
+ * */
+ public int importOneCustList(CustList custList);
+
+ /**
+ * findValidColumnData:(导出黑/白名单库的客户名单列表).
+ * @param paramMap 参数集合
+ * @return
+ * */
+ public List findValidColumnData(Map paramMap);
+
+ /**
+ * searchTop4Column:(查找黑/白名单库的客户名单前4列数据列表).
+ * @param paramMap 参数集合
+ * @return
+ * */
+ public List searchTop4Column(Map paramMap);
+
+ /**
+ * findById:(根据黑/白名单库的客户id查找客户信息).
+ * @param paramMap 参数集合
+ * @return
+ * */
+ public CustList findById(Map paramMap);
+
+ /**
+ * createCustList:(新增黑/白名单的客户信息).
+ * @param paramMap 参数集合
+ * @return
+ * */
+ public boolean createCustList(Map paramMap);
+
+
+ /**
+ * updateCustList:(修改黑/白名单的客户信息).
+ * @param paramMap 参数集合
+ * @return
+ * */
+ public boolean updateCustList(Map paramMap);
+
+ /**
+ * deleteCustList:(删除黑/白名单的客户信息).
+ * @param paramMap 参数集合
+ * @return
+ * */
+ public boolean deleteCustList(Map paramMap);
+
+ /**
+ * findByQueryKey:(按照黑/白名单的查询key检索命中的客户信息).
+ * @param paramMap 参数集合
+ * @return
+ * */
+ public Integer findByQueryKey(Map paramMap);
+
+ /**
+ * revFindByQueryKey:(黑/白名单模糊搜索时补充按照查询key反向检索命中的客户信息).
+ * @param paramMap 参数集合
+ * @return
+ * */
+ public Integer revFindByQueryKey(Map paramMap);
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/CustListMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/CustListMapper.xml
new file mode 100644
index 0000000..879351e
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/CustListMapper.xml
@@ -0,0 +1,121 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ insert into ${tableName}
+ ( t0, t1, t2, t3, t4, t5, t6, t7, t8, t9
+ , t10, t11, t12, t13, t14, t15, t16, t17, t18, t19
+ , user_id, created, nick_name )
+ values ( #{t0}, #{t1}, #{t2}, #{t3}, #{t4}
+ , #{t5}, #{t6}, #{t7}, #{t8}, #{t9}
+ , #{t10}, #{t11}, #{t12}, #{t13}, #{t14}
+ , #{t15}, #{t16}, #{t17}, #{t18}, #{t19}
+ , #{userId}, now(), #{nickName} )
+
+
+
+ update ${tableName}
+ set t0 = #{t0}, t1 = #{t1}, t2 = #{t2}, t3 = #{t3}, t4 = #{t4}
+ , t5 = #{t5}, t6 = #{t6}, t7 = #{t7}, t8 = #{t8}, t9 = #{t9}
+ , t10 = #{t10}, t11 = #{t11}, t12 = #{t12}, t13 = #{t13}, t14 = #{t14}
+ , t15 = #{t15}, t16 = #{t16}, t17 = #{t17}, t18 = #{t18}, t19 = #{t19}
+ , user_id = #{userId}, created = now()
+ where id = #{id}
+
+
+
+ delete from ${tableName}
+ where id in
+
+ #{item}
+
+
+
+
+
+
+ insert into ${tableName}
+ ( t0, t1, t2, t3, t4, t5, t6, t7, t8, t9
+ , t10, t11, t12, t13, t14, t15, t16, t17, t18, t19
+ , user_id, created, nick_name )
+ values ( #{t0}, #{t1}, #{t2}, #{t3}, #{t4}
+ , #{t5}, #{t6}, #{t7}, #{t8}, #{t9}
+ , #{t10}, #{t11}, #{t12}, #{t13}, #{t14}
+ , #{t15}, #{t16}, #{t17}, #{t18}, #{t19}
+ , #{userId}, now(), #{nickName} )
+
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCallLogMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCallLogMapper.java
new file mode 100644
index 0000000..fd89283
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCallLogMapper.java
@@ -0,0 +1,25 @@
+package com.fibo.ddp.common.dao.datax.datamanage;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.datax.datamanage.FieldCall;
+import com.fibo.ddp.common.model.datax.datamanage.FieldCallLog;
+import com.fibo.ddp.common.model.datax.datamanage.request.FieldCallParam;
+
+import java.util.List;
+
+/**
+ * (FieldCallLog)表数据库访问层
+ *
+ * @author jgp
+ * @since 2021-12-08 14:18:29
+ */
+public interface FieldCallLogMapper extends BaseMapper {
+
+ List findFieldCallList(FieldCallParam param);
+
+ List findFieldCallLogList(FieldCallParam param);
+
+ List findFieldCallCountList(FieldCallParam param);
+
+}
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCallLogMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCallLogMapper.xml
new file mode 100644
index 0000000..95390b9
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCallLogMapper.xml
@@ -0,0 +1,123 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCondMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCondMapper.java
new file mode 100644
index 0000000..e0e1eb6
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCondMapper.java
@@ -0,0 +1,34 @@
+package com.fibo.ddp.common.dao.datax.datamanage;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.datax.datamanage.FieldCond;
+
+import java.util.List;
+
+public interface FieldCondMapper extends BaseMapper {
+
+ /**
+ * createFieldCond:(生成条件关系).
+ *
+ * @param
+ * @return 字段列表
+ */
+ public boolean createFieldCond(List fieldCondVoList);
+
+ /**
+ * deleteFieldCondById:(删除字段的条件设置).
+ *
+ * @param
+ * @return 是否删除成功
+ */
+ public boolean deleteFieldCondById(Long id);
+
+
+ /**
+ * getFieldCondList:(找出字段条件设置(去重)).
+ *
+ * @param
+ * @return 字段列表
+ */
+ public List getFieldCondList(Long fieldId);
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCondMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCondMapper.xml
new file mode 100644
index 0000000..dd8df42
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldCondMapper.xml
@@ -0,0 +1,41 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ insert into t_field_condition ( field_id, condition_value, content
+ , cond_field_id, cond_field_operator, cond_field_value, cond_field_logical
+ , created)
+ values
+
+ ( #{fieldCond.fieldId}, #{fieldCond.conditionValue}, #{fieldCond.content}
+ , #{fieldCond.condFieldId}, #{fieldCond.condFieldOperator}, #{fieldCond.condFieldValue},
+ #{fieldCond.condFieldLogical}
+ , now() )
+
+
+
+
+ delete from t_field_condition where field_id = #{id}
+
+
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldMapper.java
new file mode 100644
index 0000000..e304f8a
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldMapper.java
@@ -0,0 +1,170 @@
+package com.fibo.ddp.common.dao.datax.datamanage;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.common.requestParam.UpdateFolderParam;
+import com.fibo.ddp.common.model.datax.datamanage.Field;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+
+public interface FieldMapper extends BaseMapper {
+
+ /**
+ * findByFieldType:(根据字段类型名找出该用户可用的字段列表).
+ *
+ * @param paramMap 参数集合
+ * @return 字段列表
+ */
+ public List findByFieldType(Map paramMap);
+
+ /**
+ * checkField:(查找引用该字段的所有字段).
+ *
+ * @param paramMap 参数集合
+ * @return 字段id逗号分隔字符串
+ */
+ public String checkField(Map paramMap);
+
+ /**
+ * getSourceField:(查找构成该字段的子字段及原生字段).
+ *
+ * @param paramMap 参数集合
+ * @return
+ */
+ public String getSourceField(Map paramMap);
+
+ /**
+ * findFieldTypeIdsByFieldId:(在引擎里找出一批字段id对应的唯一字段类型id串).
+ *
+ * @param paramMap 参数集合
+ * @return 字段类型id逗号分隔字符串
+ */
+ public String findFieldTypeIdsByFieldId(Map paramMap);
+
+ /**
+ * findOrgFieldTypeIdsByIds:(在通用字段里找出一批字段id对应的唯一字段类型id串).
+ *
+ * @param paramMap 参数集合
+ * @return 字段类型id逗号分隔字符串
+ */
+ public String findOrgFieldTypeIdsByIds(Map paramMap);
+
+ /**
+ * findFieldByIdsForCheckField:(找出一批字段id的字段列表（包含引擎引用的通用字段，engineId为空是不加engineId=null条件）).
+ *
+ * @param paramMap 参数集合
+ * @return 字段列表
+ */
+ public List findFieldByIdsForCheckField(Map paramMap);
+
+ /**
+ * findByFieldName:(根据字段英文或中文名找出字段对象).
+ *
+ * @param paramMap 参数集合
+ * @return 字段对象
+ */
+ public Field findByFieldName(Map paramMap);
+
+ /**
+ * findByFieldCn:(根据字段中文名找出字段对象).
+ *
+ * @param paramMap 参数集合
+ * @return 字段对象
+ */
+ public Field findByFieldCn(Map paramMap);
+
+ /**
+ * findByUser:(找出该用户可用字段列表).
+ *
+ * @param paramMap 参数集合
+ * @return 字段类型列表
+ */
+ public List findByUser(Map paramMap);
+
+ /**
+ * findByFieldId:(根据字段Id查找字段对象).
+ *
+ * @param paramMap 参数集合
+ * @return 字段对象
+ */
+ public Field findByFieldId(Map paramMap);
+
+ /**
+ * createField:(添加字段).
+ *
+ * @param fieldVo 字段实体对象
+ * @return 插入是否成功
+ */
+ public boolean createField(Field fieldVo);
+
+ /**
+ * batchCreateField:(批量添加字段).
+ *
+ * @param fieldVoList 字段实体对象list集合
+ * @return 字段类型列表
+ */
+ public boolean batchCreateField(List fieldVoList);
+
+ /**
+ * updateField:(修改字段).
+ *
+ * @param paramMap 参数集合
+ * @return 更新是否成功
+ */
+
+ public boolean updateField(Map paramMap);
+
+ /**
+ * isExists:(根据字段英文或中文名查找字段是否存在).
+ *
+ * @param paramMap 参数集合
+ * @return 存在的记录条数
+ */
+ public int isExists(Map paramMap);
+
+ /**
+ * getFieldList:(获取组织的所有字段).
+ *
+ * @param paramMap 参数集合
+ * @return
+ */
+ public List getFieldList(Map paramMap);
+
+
+
+ public String findFieldNameById(Long fieldId);
+
+ int updateFieldFolder(UpdateFolderParam param);
+
+ List selectByIds(@Param("ids") Collection ids);
+
+ List selectByEns(@Param("ens") Collection ens);
+
+ List selectByOrganCns(@Param("cns") Collection cns, @Param("organId") Long organId);
+
+ // runner
+ /**
+ * findFieldByIds:(找出一批字段id对应的字段列表).
+ * @param paramMap 参数集合
+ * @return 字段列表
+ */
+ public List findFieldByIdsbyorganId(Map paramMap);
+
+ /**
+ * findByFieldEn:(根据引擎和字段英文名找出引擎所用字段对象).
+ * @param paramMap 参数集合
+ * @return 字段对象
+ */
+ public Field findByFieldEnbyorganId(Map paramMap);
+
+ /**
+ * findByFieldCn:(根据字段中文名找出字段对象).
+ * @param paramMap 参数集合
+ * @return 字段对象
+ */
+ public Field findByFieldCnbyorganId(Map paramMap);
+
+ List selectFieldListByEns(@Param("ens")List ens);
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldMapper.xml
new file mode 100644
index 0000000..275ae28
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldMapper.xml
@@ -0,0 +1,563 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ id, field_en, field_cn, field_typeid, value_type, value_scope, is_derivative, is_output, is_common, formula, formula_show, used_fieldid, orig_fieldid, author, created, is_use_sql, data_source_id, sql_statement, sql_variable, is_interface, interface_id, interface_parse_field, json_value,dict_variable,
+ source_type,mq_source_id
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ insert into t_field ( field_en, field_cn, field_typeid
+ , value_type, value_scope, is_derivative
+ , is_output, formula, formula_show, orig_fieldid, used_fieldid
+ , is_common, author, created, is_use_sql, data_source_id, sql_statement, sql_variable
+ , is_interface, interface_id, interface_parse_field, json_value, organ_id,dict_variable,source_type,mq_source_id)
+ values ( #{fieldEn}, #{fieldCn}, #{fieldTypeId}
+ , #{valueType}, #{valueScope}, #{isDerivative}
+ , #{isOutput}, #{formula}, #{formulaShow}, #{origFieldId}, #{usedFieldId}
+ , #{isCommon}, #{author}, now(), #{isUseSql}, #{dataSourceId}, #{sqlStatement}, #{sqlVariable}
+ , #{isInterface}, #{interfaceId}, #{interfaceParseField}, #{jsonValue}, #{organId},#{dictVariable},#{sourceType},#{mqSourceId})
+
+
+
+ insert into t_field ( field_en, field_cn, field_typeid
+ , value_type, value_scope, is_derivative
+ , is_output, formula, formula_show, is_common, author, created,
+ , is_interface, interface_id, interface_parse_field, json_value,dict_variable,source_type,mq_source_id)
+ values
+
+ (
+ #{field.fieldEn}, #{field.fieldCn}, #{field.fieldTypeId}
+ , #{field.valueType}, #{field.valueScope}, #{field.isDerivative}
+ , #{field.isOutput}, #{field.formula}, #{field.formulaShow}, #{field.isCommon}, #{field.author}, now()
+ , #{isInterface}, #{interfaceId}, #{interfaceParseField},
+ #{jsonValue},#{dictVariable},#{sourceType},#{mqSourceId}
+ )
+
+
+
+
+ update t_field
+ set field_en = #{fieldEn}, field_cn = #{fieldCn}, field_typeid = #{fieldTypeId}
+ , value_type = #{valueType}, value_scope = #{valueScope}, is_derivative = #{isDerivative}
+ , is_output = #{isOutput}, formula = #{formula}, formula_show = #{formulaShow}
+ , orig_fieldid = #{origFieldId}, used_fieldid = #{usedFieldId}, is_common = #{isCommon}
+ , is_use_sql = #{isUseSql}, data_source_id = #{dataSourceId}, sql_statement = #{sqlStatement}, sql_variable =
+ #{sqlVariable}
+ ,is_interface = #{isInterface}, interface_id = #{interfaceId}, interface_parse_field = #{interfaceParseField},
+ json_value = #{jsonValue},dict_variable = #{dictVariable}
+ ,source_type = #{sourceType},mq_source_id = #{mqSourceId}
+ where id = #{id}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ update t_field
+ set field_typeid = #{folderId}
+ where id in
+
+ #{id}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeMapper.java
new file mode 100644
index 0000000..ecfcd9d
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeMapper.java
@@ -0,0 +1,77 @@
+package com.fibo.ddp.common.dao.datax.datamanage;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.datax.datamanage.FieldType;
+import com.fibo.ddp.common.model.datax.datamanage.request.FieldTreeParam;
+
+import java.util.List;
+import java.util.Map;
+
+public interface FieldTypeMapper extends BaseMapper {
+
+ /**
+ * getFieldTypeList:(查找用户的字段类型列表).
+ *
+ * @param paramMap 参数集合
+ * @return 字段类型列表
+ */
+ public List getFieldTypeList(Map paramMap);
+
+ /**
+ * findTypeIdByParentId:(根据传入的字段类型父ID查找子类型ID).
+ *
+ * @param paramMap 参数集合
+ * @return 子字段类型ID
+ */
+ public String findTypeIdByParentId(Map paramMap);
+
+ /**
+ * findTypeIdByParentId:(根据传入的字段类型类型ID查找父ID).
+ *
+ * @param paramMap 参数集合
+ * @return 子字段类型ID
+ */
+ public String findParentIdByTypeId(Map paramMap);
+
+ /**
+ * createFieldType:(新增字段类型).
+ *
+ * @param fieldTypeVo 字段类型实体类
+ * @return 插入成功
+ */
+ public boolean createFieldType(FieldType fieldTypeVo);
+
+ /**
+ * findIdByFieldType:(新增字段类型).
+ *
+ * @param paramMap paramMap
+ * @return 字段类型编号
+ */
+ public long findIdByFieldType(Map paramMap);
+
+ /**
+ * updateFieldType:(更新字段类型名).
+ *
+ * @param paramMap 参数集合
+ * @return 更新成功
+ */
+ public boolean updateFieldType(FieldTreeParam param);
+
+ /**
+ * backFieldTypeByTypeIds:(更新字段类型状态为启用状态(1)).
+ *
+ * @param paramMap 参数集合
+ * @return 更新成功
+ */
+ public boolean backFieldTypeByTypeIds(Map paramMap);
+
+ /**
+ * isExists:(查找字段名是否存在).
+ *
+ * @param paramMap 参数集合
+ * @return 存在的记录条数
+ */
+ public int isExists(Map paramMap);
+
+ List selectFieldTypeList(FieldTreeParam param);
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeMapper.xml
new file mode 100644
index 0000000..4206549
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeMapper.xml
@@ -0,0 +1,131 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ insert into t_field_type ( field_type, parent_id, is_common ,type)
+ values ( #{fieldType}, #{parentId}, #{isCommon} ,#{type})
+
+
+
+ update t_field_type
+ set field_type = #{fieldType}
+ where id = #{id}
+
+
+
+ update t_field_type_user_rel
+ set status = 1
+ where organ_id = ( select organ_id from t_user where user_id = #{userId} )
+ and engine_id = #{engineId}
+ and field_typeid in
+
+ #{item}
+
+ and status = -1
+
+
+
+
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeUserMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeUserMapper.java
new file mode 100644
index 0000000..18e7764
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeUserMapper.java
@@ -0,0 +1,36 @@
+package com.fibo.ddp.common.dao.datax.datamanage;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.datax.datamanage.FieldTypeUser;
+import com.fibo.ddp.common.model.datax.datamanage.request.FieldTreeParam;
+
+import java.util.Map;
+
+public interface FieldTypeUserMapper extends BaseMapper {
+
+ /**
+ * createFieldTypeUserRel:(新增字段类型).
+ *
+ * @param paramMap 参数集合
+ * @return 插入成功
+ */
+ public boolean createFieldTypeUserRel(Map paramMap);
+
+ /**
+ * batchBindEngineFieldTypeUserRel:(把一批通用字段类型id中不存在的类型id批量绑定到引擎).
+ *
+ * @param paramMap 参数集合
+ * @return 插入成功
+ */
+ public boolean batchBindEngineFieldTypeUserRel(Map paramMap);
+
+ /**
+ * updateFieldTypeUserRel:(更新字段类型名).
+ *
+ * @param paramMap 参数集合
+ * @return 更新成功
+ */
+ public boolean updateFieldTypeUserRel(FieldTreeParam param);
+
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeUserMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeUserMapper.xml
new file mode 100644
index 0000000..1501d94
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldTypeUserMapper.xml
@@ -0,0 +1,41 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+ insert into t_field_type_user_rel ( field_typeid, organ_id, engine_id, user_id, created )
+ values ( #{fieldTypeId}, #{organId}, #{engineId}, #{userId}, now() )
+
+
+
+ insert into t_field_type_user_rel ( field_typeid, organ_id, engine_id, user_id, created )
+ select field_typeid, organ_id, #{engineId}, #{userId}, now()
+ from t_field_type_user_rel r
+ where r.field_typeid in
+
+ #{item}
+
+ and field_typeid not in ( select field_typeid from t_field_type_user_rel where engine_id = #{engineId})
+ and engine_id is null
+
+
+
+ update t_field_type_user_rel
+ set user_id = #{userId}, created = now()
+
+ ,status = #{status}
+
+ where organ_id =#{organId}
+ and field_typeid = #{id}
+
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldUserMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldUserMapper.java
new file mode 100644
index 0000000..864df0f
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldUserMapper.java
@@ -0,0 +1,62 @@
+package com.fibo.ddp.common.dao.datax.datamanage;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.datax.datamanage.FieldUser;
+
+import java.util.List;
+import java.util.Map;
+
+public interface FieldUserMapper extends BaseMapper {
+
+ /**
+ * createFieldUserRel:(绑定字段和用户关系).
+ *
+ * @param fieldUser 用户字段实体类
+ * @return 插入成功
+ * */
+ public boolean createFieldUserRel(FieldUser fieldUserVo);
+
+ /**
+ * batchCreateFieldUserRel:(批量导入字段信息后批量绑定字段和用户关系).
+ *
+ * @param paramMap 参数集合
+ * @return 插入成功
+ * */
+ public boolean batchCreateFieldUserRel(Map paramMap);
+
+ /**
+ * batchBindEngineFieldUserRel:(把一批通用字段id中未绑定的字段id批量绑定到引擎).
+ *
+ * @param paramMap 参数集合
+ * @return 插入成功
+ * */
+ public boolean batchBindEngineFieldUserRel(Map paramMap);
+
+ /**
+ * updateStatus:(单个或批量更新用户字段关系).
+ *
+ * @param paramMap 参数集合
+ * @return 更新成功
+ * */
+ public boolean updateStatus(Map paramMap);
+
+ /**
+ * deleteFieldByIds:(批量修改字段删除状态为启用状态(1)).
+ *
+ * @param paramMap 参数集合
+ * @return 更新是否成功
+ */
+ public boolean backFieldByIds(Map paramMap);
+
+ /**
+ * 统计组织内指标数
+ */
+ int countFieldByOrganId(Map paramMap);
+
+ /**
+ *
+ * @param paramMap
+ * @return
+ */
+ List> countFieldGroupByType(Map paramMap);
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldUserMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldUserMapper.xml
new file mode 100644
index 0000000..53090ef
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datamanage/FieldUserMapper.xml
@@ -0,0 +1,87 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ insert into t_field_user_rel (field_id, organ_id, engine_id, user_id, status, created, updated)
+ values (#{fieldId}, #{organId}, #{engineId}, #{userId}, #{status}, now(), now())
+
+
+
+ insert into t_field_user_rel (field_id, organ_id, engine_id, user_id, status, created, updated)
+ select id, #{organId}, #{engineId}, #{userId}, #{status}, now(), now()
+ from t_field t
+ where t.author = #{author}
+ and not exists ( select r.field_id from t_field_user_rel r where t.id = r.field_id )
+
+
+
+
+ insert into t_field_user_rel (field_id, organ_id, engine_id, user_id, status, created, updated)
+ select id, #{organId}, #{engineId}, #{userId}, 1, now(), now()
+ from t_field f
+ where f.id in
+
+ #{item}
+
+ and not exists ( select 1
+ from ( select f.id,f.field_en,f.field_cn
+ from t_field f,t_field_user_rel fu
+ where f.id = fu.field_id
+ and fu.organ_id = ( select organ_id from t_user where user_id = #{userId} )
+ and fu.engine_id = ${engineId} )y
+ where f.field_en = y.field_en or f.field_cn = y.field_cn or f.id = y.id
+ )
+
+
+
+
+ update t_field_user_rel
+ set status=#{status}
+ where organ_id = ( select organ_id from t_user where user_id = #{userId} )
+
+ and engine_id = #{engineId}
+
+
+ and engine_id is null
+
+ and field_id in
+
+ #{item}
+
+
+
+
+
+ update t_field_user_rel
+ set status = 1
+ where organ_id = ( select organ_id from t_user where user_id = #{userId} )
+ and engine_id = #{engineId}
+ and field_id in
+
+ #{item}
+
+ and status = -1
+
+
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/DataSourceMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/DataSourceMapper.java
new file mode 100644
index 0000000..9d1674f
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/DataSourceMapper.java
@@ -0,0 +1,9 @@
+package com.fibo.ddp.common.dao.datax.datasource;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.datax.datasource.DataSource;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface DataSourceMapper extends BaseMapper {
+}
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/MqSourceMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/MqSourceMapper.java
new file mode 100644
index 0000000..096c92c
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/MqSourceMapper.java
@@ -0,0 +1,15 @@
+package com.fibo.ddp.common.dao.datax.datasource;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.datax.datasource.MqSource;
+
+/**
+ * (MqSource)表数据库访问层
+ *
+ * @author jgp
+ * @since 2021-12-20 13:31:51
+ */
+public interface MqSourceMapper extends BaseMapper {
+
+}
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/SimpleMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/SimpleMapper.java
new file mode 100644
index 0000000..e3d4dd8
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/SimpleMapper.java
@@ -0,0 +1,11 @@
+package com.fibo.ddp.common.dao.datax.datasource;
+
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+
+public interface SimpleMapper {
+
+ List> customSelect(Map paramsMap);
+ List> test(Map paramsMap);
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/SimpleMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/SimpleMapper.xml
new file mode 100644
index 0000000..aa7bc9d
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/datax/datasource/SimpleMapper.xml
@@ -0,0 +1,12 @@
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/dataflow/EngineVersionContentMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/dataflow/EngineVersionContentMapper.java
new file mode 100644
index 0000000..544962f
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/dataflow/EngineVersionContentMapper.java
@@ -0,0 +1,17 @@
+package com.fibo.ddp.common.dao.enginex.dataflow;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.enginex.dataflow.EngineVersionContent;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * (EngineVersionContent)表数据库访问层
+ *
+ * @author jgp
+ * @since 2021-12-23 10:21:08
+ */
+ @Mapper
+public interface EngineVersionContentMapper extends BaseMapper{
+
+}
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeDateResultMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeDateResultMapper.java
new file mode 100644
index 0000000..fbaabe2
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeDateResultMapper.java
@@ -0,0 +1,16 @@
+package com.fibo.ddp.common.dao.enginex.marketing;
+
+import com.fibo.ddp.common.model.enginex.marketing.entity.MarketingEngineNodeDateResult;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 营销引擎节点当天结果表(MarketingEngineNodeDateResult)表数据库访问层
+ *
+ * @author andy.wang
+ * @since 2022-01-07 18:13:23
+ */
+@Mapper
+public interface MarketingEngineNodeDateResultMapper extends BaseMapper{
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeDateResultMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeDateResultMapper.xml
new file mode 100644
index 0000000..7d7926d
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeDateResultMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeResultMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeResultMapper.java
new file mode 100644
index 0000000..cdf6f92
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeResultMapper.java
@@ -0,0 +1,16 @@
+package com.fibo.ddp.common.dao.enginex.marketing;
+
+import com.fibo.ddp.common.model.enginex.marketing.entity.MarketingEngineNodeResult;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 营销引擎节点结果表(MarketingEngineNodeResult)表数据库访问层
+ *
+ * @author andy.wang
+ * @since 2022-01-07 18:13:24
+ */
+@Mapper
+public interface MarketingEngineNodeResultMapper extends BaseMapper{
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeResultMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeResultMapper.xml
new file mode 100644
index 0000000..6c89f91
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineNodeResultMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineResultMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineResultMapper.java
new file mode 100644
index 0000000..274f4f1
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineResultMapper.java
@@ -0,0 +1,16 @@
+package com.fibo.ddp.common.dao.enginex.marketing;
+
+import com.fibo.ddp.common.model.enginex.marketing.entity.MarketingEngineResult;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 营销引擎结果表(MarketingEngineResult)表数据库访问层
+ *
+ * @author andy.wang
+ * @since 2022-01-07 18:13:24
+ */
+@Mapper
+public interface MarketingEngineResultMapper extends BaseMapper{
+
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineResultMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineResultMapper.xml
new file mode 100644
index 0000000..e274b2a
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/marketing/MarketingEngineResultMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/personas/PersonasEngineResultDetailMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/personas/PersonasEngineResultDetailMapper.java
new file mode 100644
index 0000000..85a75f4
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/personas/PersonasEngineResultDetailMapper.java
@@ -0,0 +1,23 @@
+package com.fibo.ddp.common.dao.enginex.personas;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.enginex.personas.PersonasEngineResultDetail;
+import com.fibo.ddp.common.model.enginex.personas.vo.PersonasReport;
+import com.fibo.ddp.common.model.enginex.personas.vo.PersonasReportParam;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+
+/**
+ * (PersonasEngineResultDetail)表数据库访问层
+ *
+ * @author jgp
+ * @since 2022-01-06 14:24:57
+ */
+@Mapper
+public interface PersonasEngineResultDetailMapper extends BaseMapper {
+
+ List selectReportList(PersonasReportParam param);
+}
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/personas/PersonasEngineResultDetailMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/personas/PersonasEngineResultDetailMapper.xml
new file mode 100644
index 0000000..d3b2d34
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/personas/PersonasEngineResultDetailMapper.xml
@@ -0,0 +1,43 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/personas/PersonasEngineResultMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/personas/PersonasEngineResultMapper.java
new file mode 100644
index 0000000..11c085f
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/personas/PersonasEngineResultMapper.java
@@ -0,0 +1,19 @@
+package com.fibo.ddp.common.dao.enginex.personas;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.enginex.personas.PersonasEngineResult;
+import org.apache.ibatis.annotations.Mapper;
+
+
+/**
+ * (PersonasEngineResult)表数据库访问层
+ *
+ * @author jgp
+ * @since 2022-01-06 14:23:09
+ */
+ @Mapper
+public interface PersonasEngineResultMapper extends BaseMapper{
+
+}
+
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineMapper.java
new file mode 100644
index 0000000..02bb513
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineMapper.java
@@ -0,0 +1,60 @@
+package com.fibo.ddp.common.dao.enginex.risk;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.enginex.risk.Engine;
+import com.fibo.ddp.common.model.enginex.risk.IndexEngineReportVo;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+public interface EngineMapper extends BaseMapper {
+
+ List getEngineByList(Engine engineVo);
+
+ Engine getEngineById(Engine engineVo);
+
+ int updateEngine(Engine engineVo);
+
+ /**
+ * 创建引擎并返回ID
+ * @param engine
+ * @return
+ */
+ int insertEngineAndReturnId(Engine engine);
+
+ /**
+ * 查询本公司引擎
+ */
+ public List getEngineList(@Param("organId") long organId,
+ @Param("searchString") String searchString,
+ @Param("list") List list);
+
+ /**
+ * 查询首页引擎基本信息
+ * @param paramMap
+ * @return
+ */
+ Map getIndexEngineBaseInfo(Map paramMap);
+
+ /**
+ * 查询首页最近几天引擎使用情况
+ * @param paramMap
+ * @return
+ */
+ List getIndexRecentDayEngineUseInfo(Map paramMap);
+
+ /**
+ * 查询首页最近几个月引擎使用情况
+ * @param paramMap
+ * @return
+ */
+ List getIndexRecentMonthEngineUseInfo(Map paramMap);
+
+ /**
+ * 查询首页引擎使用占比
+ * @param paramMap
+ * @return
+ */
+ List> getIndexEngineUseRatio(Map paramMap);
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineMapper.xml
new file mode 100644
index 0000000..9752d05
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineMapper.xml
@@ -0,0 +1,266 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ INSERT INTO
+ t_engine
+
+
+ code,
+
+
+ name,
+
+
+ description,
+
+
+ creator,
+
+
+ user_id,
+
+
+ organ_id,
+
+
+ status,
+
+
+ callback_type,
+
+
+ callback_url,
+
+
+ exception_callback_url,
+
+ create_datetime,update_datetime
+
+ values
+
+
+ #{code},
+
+
+ #{name},
+
+
+ #{description},
+
+
+ #{creator},
+
+
+ #{userId},
+
+
+ #{organId},
+
+
+ #{status},
+
+
+ #{callbackType},
+
+
+ #{callbackUrl},
+
+
+ #{exceptionCallbackUrl},
+
+ now(),now()
+
+
+
+
+ UPDATE t_engine
+
+
+ code = #{code},
+
+
+ name = #{name},
+
+
+ description = #{description},
+
+
+ status = #{status},
+
+
+ creator = #{creator},
+
+
+ user_id = #{userId},
+
+
+ callback_type = #{callbackType},
+
+
+ callback_url = #{callbackUrl},
+
+
+ exception_callback_url = #{exceptionCallbackUrl},
+
+
+ WHERE
+ organ_id= #{organId}
+ and id = #{id}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineNodeMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineNodeMapper.java
new file mode 100644
index 0000000..0cae5ac
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineNodeMapper.java
@@ -0,0 +1,51 @@
+package com.fibo.ddp.common.dao.enginex.risk;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.enginex.risk.EngineNode;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+public interface EngineNodeMapper extends BaseMapper {
+
+ /**
+ * getEngineNodeListByEngineVersionId：(根据版本id获取版本下的所有节点)
+ *
+ * @param engineVersionId 引擎版本id
+ * @return 节点集合
+ *
+ */
+ List getEngineNodeListByEngineVersionId(@Param("engineVersionId") Long engineVersionId);
+
+ int insertNodeAndReturnId(EngineNode engineNode);
+
+ // V2
+ int insertNodeAndReturnIdV2(EngineNode engineNode);
+
+ int updateNodeForNextOrderAndParams(List eList);
+
+ int getMaxNodeOrder(@Param("versionId") Long versionId);
+
+ int renameNode(Map param);
+
+ int updateSnapshot(Map param);
+
+ int updateNextNodes(EngineNode engineNode);
+
+ int deleteNodesByNodeIds(@Param("commons") List commons);
+
+ List getEngineTypedNodeListByEngineVersionId(@Param("versionId") Long versionId, @Param("types") List types);
+
+ int updateParentIdByNodeId(Map map);
+
+ int updateNodePosition(EngineNode engineNode);
+
+ // runner
+ /**
+ * 根据版本id获取版本下的所有节点
+ * @param engineVersionId
+ * @return
+ */
+ List getEngineNodeListByVersionId(@Param("engineVersionId") Long engineVersionId);
+}
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineNodeMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineNodeMapper.xml
new file mode 100644
index 0000000..2082d8c
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineNodeMapper.xml
@@ -0,0 +1,151 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ node_id, parent_id, version_id, node_name, node_code, node_order, node_type, node_x, node_y,node_json,node_script,next_nodes,params
+
+
+
+
+
+
+
+ #{item}
+
+
+
+
+ insert into t_engine_node (node_id, parent_id,version_id, node_name,
+ node_code, node_order, node_type,
+ node_x, node_y, node_json,
+ node_script, next_nodes, params
+ )
+ values (#{nodeId,jdbcType=INTEGER},#{parentId,jdbcType=INTEGER}, #{versionId,jdbcType=INTEGER}, #{nodeName,jdbcType=VARCHAR},
+ #{nodeCode,jdbcType=VARCHAR}, #{nodeOrder,jdbcType=INTEGER}, #{nodeType,jdbcType=INTEGER},
+ #{nodeX,jdbcType=DECIMAL}, #{nodeY,jdbcType=DECIMAL}, #{nodeJson,jdbcType=LONGVARCHAR},
+ #{nodeScript,jdbcType=LONGVARCHAR}, #{nextNodes,jdbcType=LONGVARCHAR}, #{params,jdbcType=LONGVARCHAR}
+ )
+
+
+
+ insert into t_engine_node (version_id,parent_id, node_name,
+ node_code, node_order, node_type,
+ node_x, node_y, node_json,
+ node_script, next_nodes, params
+ )
+ values (#{versionId,jdbcType=INTEGER},#{parentId,jdbcType=INTEGER}, #{nodeName,jdbcType=VARCHAR},
+ #{nodeCode,jdbcType=VARCHAR}, #{nodeOrder,jdbcType=INTEGER}, #{nodeType,jdbcType=INTEGER},
+ #{nodeX,jdbcType=DECIMAL}, #{nodeY,jdbcType=DECIMAL}, #{nodeJson,jdbcType=LONGVARCHAR},
+ #{nodeScript,jdbcType=LONGVARCHAR}, #{nextNodes,jdbcType=LONGVARCHAR}, #{params,jdbcType=LONGVARCHAR}
+ )
+
+
+
+ insert into t_engine_node (version_id,parent_id, node_name,
+ node_code, node_order, node_type,
+ node_x, node_y, node_json,
+ node_script, next_nodes, params
+ )
+ values (#{versionId,jdbcType=INTEGER},#{parentId,jdbcType=INTEGER}, #{nodeName,jdbcType=VARCHAR},
+ #{nodeCode,jdbcType=VARCHAR}, #{nodeOrder,jdbcType=INTEGER}, #{nodeType,jdbcType=INTEGER},
+ #{nodeX,jdbcType=DECIMAL}, #{nodeY,jdbcType=DECIMAL}, #{nodeJson,jdbcType=LONGVARCHAR},
+ #{nodeScript,jdbcType=LONGVARCHAR}, #{nextNodes,jdbcType=LONGVARCHAR}, #{params,jdbcType=LONGVARCHAR}
+ )
+
+
+
+ update t_engine_node
+ set node_x = #{nodeX,jdbcType=DECIMAL},
+ node_y = #{nodeY,jdbcType=DECIMAL}
+ where node_id = #{nodeId,jdbcType=INTEGER}
+
+
+
+ update t_engine_node
+ set next_nodes = #{nextNodes}
+ where node_id = #{nodeId}
+
+
+
+ update t_engine_node
+ set parent_id = #{parentId}
+ where node_id = #{nodeId}
+
+
+
+
+ update t_engine_node
+ set node_name = #{nodeName,jdbcType=VARCHAR}
+ where node_id = #{nodeId,jdbcType=INTEGER}
+
+
+
+
+ update t_engine_node
+ set snapshot = #{snapshot,jdbcType=VARCHAR}
+ where node_id = #{nodeId,jdbcType=INTEGER}
+
+
+
+
+
+
+
+
+ update t_engine_node set
+
+ next_nodes = #{item.nextNodes},
+
+
+ params = #{item.params},
+
+
+ node_json = #{item.nodeJson},
+
+ parent_id = #{item.parentId }
+ where node_id = #{item.nodeId}
+
+
+
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineResultSetMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineResultSetMapper.java
new file mode 100644
index 0000000..9acb155
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineResultSetMapper.java
@@ -0,0 +1,71 @@
+package com.fibo.ddp.common.dao.enginex.risk;
+
+import com.fibo.ddp.common.model.analyse.AnalyseDecisionResult;
+import com.fibo.ddp.common.model.enginex.risk.EngineResultSet;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+public interface EngineResultSetMapper {
+ /**
+ *
+ * 增加结果集
+ * @param resultSet 结果集对象
+ * @return 返回结果
+ * @see
+ */
+ int insertResultSet(EngineResultSet resultSet);
+ /**
+ *
+ * 查询结果集列表
+ * @param resultSet 查询对象
+ * @return 返回结果集
+ * @see
+ */
+ List getResultSetByList(EngineResultSet resultSet);
+
+ /**
+ * 根据引擎编号和时间段获取结果集数据
+ * @param map
+ * @return
+ */
+ List getEngineResultSetBySegment(Map map);
+
+ /**
+ *
+ * 通过主键编号得到
+ * @param resultSet 对象
+ * @return 返回对象
+ * @see
+ */
+ EngineResultSet getResultSetById(EngineResultSet resultSet);
+
+ List getResultSetDetailsById(long resultSetId);
+
+ /**
+ * 查找引擎id的批量测试结果
+ * yuanlinfeng
+ * @param resultSetId
+ * @return
+ */
+ List getBatchTestResultSetByEngineId(Map paramMap);
+
+ /**
+ * 查找引擎批量测试批次号的所有测试结果
+ * yuanlinfeng
+ * @param resultSetId
+ * @return
+ */
+ List getBatchTestResultSetByBatchNo(Map paramMap);
+
+ /**
+ * 更新结果出参
+ * @param resultSet
+ */
+ void updateResultOutput(EngineResultSet resultSet);
+
+ List countDecisionCallNum();
+
+ void updateResultById(@Param("resultId") Integer resultId, @Param("rowKeyStr") String rowKeyStr);
+}
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineResultSetMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineResultSetMapper.xml
new file mode 100644
index 0000000..6654104
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineResultSetMapper.xml
@@ -0,0 +1,218 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ INSERT INTO
+ t_resultset
+
+
+ uid,
+
+
+ pid,
+
+
+ input,
+
+
+ output,
+
+
+ result,
+
+
+ engine_id,
+
+
+ uuid,
+
+
+ engine_version,
+
+
+ engine_name,
+
+
+ engine_code,
+
+
+ type,
+
+
+ sub_version,
+
+
+ scorecardscore,
+
+
+ batch_no,
+
+
+ datilResult,
+
+
+ values
+
+
+ #{uid},
+
+
+ #{pid},
+
+
+ #{input},
+
+
+ #{output},
+
+
+ #{result},
+
+
+ #{engineId},
+
+
+ #{uuid},
+
+
+ #{engineVersion},
+
+
+ #{engineName},
+
+
+ #{engineCode},
+
+
+ #{type},
+
+
+ #{subVersion},
+
+
+ #{scorecardscore},
+
+
+ #{batchNo},
+
+
+ #{datilResult},
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ update t_resultset t set t.`output` = #{output} where t.`id` = #{id}
+
+
+
+
+
+ UPDATE t_resultset
+ set hbase_row_key = #{rowKeyStr}
+ where id = #{resultId}
+
+
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineVersionMapper.java b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineVersionMapper.java
new file mode 100644
index 0000000..e8cf27a
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineVersionMapper.java
@@ -0,0 +1,67 @@
+package com.fibo.ddp.common.dao.enginex.risk;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fibo.ddp.common.model.enginex.risk.EngineResultSetDTO;
+import com.fibo.ddp.common.model.enginex.risk.EngineVersion;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+public interface EngineVersionMapper extends BaseMapper {
+
+ int insertOne(EngineVersion record);
+
+ EngineVersion selectByPrimaryKey(long versionId);
+
+ int updateByPrimaryKeySelective(EngineVersion record);
+
+ int updateByPrimaryKey(EngineVersion record);
+
+ int undeployVersion(long engineId);
+
+ int updateBootState(@Param("versionId") long versionId, @Param("bootState") int bootState);
+
+ /**
+ * getEngineVersionListByEngineId：(根据引擎id获取引擎下的所有版本)
+ *
+ * @param engineId 引擎id
+ * @return 版本集合
+ * */
+ List getEngineVersionListByEngineId(long engineId);
+
+ // 新增的V2
+ List getEngineVersionListByEngineIdV2(long engineId);
+
+ int insertEngineVersionAndReturnId(EngineVersion engineVersion);
+
+ EngineVersion getLatestEngineVersion(EngineVersion engineVersion);
+
+ EngineVersion getLatestEngineSubVersion(EngineVersion engineVersion);
+
+ /**
+ * 清除所有此版本下的小版本(除过0版本)
+ * @param map
+ * @return
+ */
+ int cleanSubVersionByVersion(Map map);
+
+ /**
+ * 获取引擎对应的版本及引擎名信息
+ * yuanlinfeng
+ * @param paramMap
+ * @return
+ */
+ public List getEngineVersionByEngineId(Map paramMap);
+
+ List selectAll();
+
+ List countDecisionResult();
+
+ /**
+ * 获取引擎正在运行中的版本
+ * @param engineId
+ * @return
+ */
+ EngineVersion getRunningVersion(@Param("engineId") Long engineId);
+}
\ No newline at end of file
diff --git a/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineVersionMapper.xml b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineVersionMapper.xml
new file mode 100644
index 0000000..bad765d
--- /dev/null
+++ b/ddp-common/ddp-dao/src/main/java/com/fibo/ddp/common/dao/enginex/risk/EngineVersionMapper.xml
@@ -0,0 +1,273 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ version_id, engine_id, version, boot_state, status, layout, user_id, create_time,
+ latest_user, latest_time, sub_version
+
+
+
+
+
+
+
+
+
+ delete from t_engine_version
+ where engine_id = #{engineId,jdbcType=INTEGER}
+ and version = #{version,jdbcType=INTEGER}
+ and sub_version != 0
+
+
+
+ insert into t_engine_version (version_id, engine_id, version,
+ sub_version, boot_state, status, layout, user_id,
+ create_time, latest_user, latest_time
+ )
+ values (#{versionId,jdbcType=INTEGER}, #{engineId,jdbcType=INTEGER}, #{version,jdbcType=INTEGER},
+ #{subVersion,jdbcType=INTEGER},#{bootState,jdbcType=BIT}, #{status,jdbcType=BIT}, #{layout,jdbcType=BIT},
+ #{userId,jdbcType=INTEGER}, #{createTime,jdbcType=VARCHAR}, #{latestUser,jdbcType=INTEGER},
+ #{latestTime,jdbcType=VARCHAR}
+ )
+
+
+
+ insert into t_engine_version
+
+