zelong.shao

dao|目录替换

Showing 17 changed files with 49 additions and 503 deletions
package com.fedex.connect.common.dao.base;
package com.fedex.connect.common.dao.bi;
import com.fedex.connect.common.model.base.DictionaryEntries;
import com.fedex.connect.common.model.base.DictionaryEntriesExample;
import com.fedex.connect.common.model.bi.DictionaryEntries;
import com.fedex.connect.common.model.bi.DictionaryEntriesExample;
import org.apache.ibatis.annotations.Param;
import java.util.List;
......
package com.fedex.connect.common.dao.base;
package com.fedex.connect.common.dao.bi;
import com.fedex.connect.common.model.base.Dictionary;
import com.fedex.connect.common.model.base.DictionaryExample;
import com.fedex.connect.common.model.bi.Dictionary;
import com.fedex.connect.common.model.bi.DictionaryExample;
import java.util.List;
import org.apache.ibatis.annotations.Param;
......
package com.fedex.connect.common.dao.sys;
import com.fedex.connect.common.model.sys.KafkaStorageHistory;
import com.fedex.connect.common.model.sys.KafkaStorageHistoryExample;
import java.util.List;
import org.apache.ibatis.annotations.Param;
public interface KafkaStorageHistoryMapper {
long countByExample(KafkaStorageHistoryExample example);
int deleteByExample(KafkaStorageHistoryExample example);
int deleteByPrimaryKey(Long id);
int insert(KafkaStorageHistory record);
int insertSelective(KafkaStorageHistory record);
List<KafkaStorageHistory> selectByExampleWithBLOBs(KafkaStorageHistoryExample example);
List<KafkaStorageHistory> selectByExample(KafkaStorageHistoryExample example);
KafkaStorageHistory selectByPrimaryKey(Long id);
int updateByExampleSelective(@Param("record") KafkaStorageHistory record, @Param("example") KafkaStorageHistoryExample example);
int updateByExampleWithBLOBs(@Param("record") KafkaStorageHistory record, @Param("example") KafkaStorageHistoryExample example);
int updateByExample(@Param("record") KafkaStorageHistory record, @Param("example") KafkaStorageHistoryExample example);
int updateByPrimaryKeySelective(KafkaStorageHistory record);
int updateByPrimaryKeyWithBLOBs(KafkaStorageHistory record);
int updateByPrimaryKey(KafkaStorageHistory record);
}
\ No newline at end of file
package com.fedex.connect.common.dao.sys;
import com.fedex.connect.common.model.sys.KafkaTemporaryStorage;
import com.fedex.connect.common.model.sys.KafkaTemporaryStorageExample;
import java.util.List;
import org.apache.ibatis.annotations.Param;
public interface KafkaTemporaryStorageMapper {
long countByExample(KafkaTemporaryStorageExample example);
int deleteByExample(KafkaTemporaryStorageExample example);
int deleteByPrimaryKey(Long id);
int insert(KafkaTemporaryStorage record);
int insertSelective(KafkaTemporaryStorage record);
List<KafkaTemporaryStorage> selectByExampleWithBLOBs(KafkaTemporaryStorageExample example);
List<KafkaTemporaryStorage> selectByExample(KafkaTemporaryStorageExample example);
KafkaTemporaryStorage selectByPrimaryKey(Long id);
int updateByExampleSelective(@Param("record") KafkaTemporaryStorage record, @Param("example") KafkaTemporaryStorageExample example);
int updateByExampleWithBLOBs(@Param("record") KafkaTemporaryStorage record, @Param("example") KafkaTemporaryStorageExample example);
int updateByExample(@Param("record") KafkaTemporaryStorage record, @Param("example") KafkaTemporaryStorageExample example);
int updateByPrimaryKeySelective(KafkaTemporaryStorage record);
int updateByPrimaryKeyWithBLOBs(KafkaTemporaryStorage record);
int updateByPrimaryKey(KafkaTemporaryStorage record);
}
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.fedex.connect.common.dao.base.DictionaryEntriesMapper">
<resultMap id="BaseResultMap" type="com.fedex.connect.common.model.base.DictionaryEntries">
<mapper namespace="com.fedex.connect.common.dao.bi.DictionaryEntriesMapper">
<resultMap id="BaseResultMap" type="com.fedex.connect.common.model.bi.DictionaryEntries">
<id column="ID" jdbcType="NUMERIC" property="id" />
<result column="CODE" jdbcType="VARCHAR" property="code" />
<result column="ENGLISH_NAME" jdbcType="VARCHAR" property="englishName" />
......@@ -85,7 +85,7 @@
EXT1, EXT2, EXT3, EXT4, CREATE_TIME, CREATE_USER_ID, CREATE_USER_NAME, MODIFY_TIME,
MODIFY_USER_ID, MODIFY_USER_NAME
</sql>
<select id="selectByExample" parameterType="com.fedex.connect.common.model.base.DictionaryEntriesExample" resultMap="BaseResultMap">
<select id="selectByExample" parameterType="com.fedex.connect.common.model.bi.DictionaryEntriesExample" resultMap="BaseResultMap">
<include refid="OracleDialectPrefix" />
select
<if test="distinct">
......@@ -112,13 +112,13 @@
delete from T_BI_DICTIONARY_ENTRIES
where ID = #{id,jdbcType=NUMERIC}
</delete>
<delete id="deleteByExample" parameterType="com.fedex.connect.common.model.base.DictionaryEntriesExample">
<delete id="deleteByExample" parameterType="com.fedex.connect.common.model.bi.DictionaryEntriesExample">
delete from T_BI_DICTIONARY_ENTRIES
<if test="_parameter != null">
<include refid="Example_Where_Clause" />
</if>
</delete>
<insert id="insert" parameterType="com.fedex.connect.common.model.base.DictionaryEntries">
<insert id="insert" parameterType="com.fedex.connect.common.model.bi.DictionaryEntries">
<selectKey keyProperty="id" order="BEFORE" resultType="java.lang.Long">
SELECT SEQ_T_BI_DICTIONARY_ENTRIES.NEXTVAL FROM DUAL
</selectKey>
......@@ -137,7 +137,7 @@
#{modifyTime,jdbcType=TIMESTAMP}, #{modifyUserId,jdbcType=NUMERIC}, #{modifyUserName,jdbcType=VARCHAR}
)
</insert>
<insert id="insertSelective" parameterType="com.fedex.connect.common.model.base.DictionaryEntries">
<insert id="insertSelective" parameterType="com.fedex.connect.common.model.bi.DictionaryEntries">
<selectKey keyProperty="id" order="BEFORE" resultType="java.lang.Long">
SELECT SEQ_T_BI_DICTIONARY_ENTRIES.NEXTVAL FROM DUAL
</selectKey>
......@@ -257,7 +257,7 @@
</if>
</trim>
</insert>
<select id="countByExample" parameterType="com.fedex.connect.common.model.base.DictionaryEntriesExample" resultType="java.lang.Long">
<select id="countByExample" parameterType="com.fedex.connect.common.model.bi.DictionaryEntriesExample" resultType="java.lang.Long">
select count(*) from T_BI_DICTIONARY_ENTRIES
<if test="_parameter != null">
<include refid="Example_Where_Clause" />
......@@ -353,7 +353,7 @@
<include refid="Update_By_Example_Where_Clause" />
</if>
</update>
<update id="updateByPrimaryKeySelective" parameterType="com.fedex.connect.common.model.base.DictionaryEntries">
<update id="updateByPrimaryKeySelective" parameterType="com.fedex.connect.common.model.bi.DictionaryEntries">
update T_BI_DICTIONARY_ENTRIES
<set>
<if test="code != null">
......@@ -413,7 +413,7 @@
</set>
where ID = #{id,jdbcType=NUMERIC}
</update>
<update id="updateByPrimaryKey" parameterType="com.fedex.connect.common.model.base.DictionaryEntries">
<update id="updateByPrimaryKey" parameterType="com.fedex.connect.common.model.bi.DictionaryEntries">
update T_BI_DICTIONARY_ENTRIES
set CODE = #{code,jdbcType=VARCHAR},
ENGLISH_NAME = #{englishName,jdbcType=VARCHAR},
......
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.fedex.connect.common.dao.base.DictionaryMapper">
<resultMap id="BaseResultMap" type="com.fedex.connect.common.model.base.Dictionary">
<mapper namespace="com.fedex.connect.common.dao.bi.DictionaryMapper">
<resultMap id="BaseResultMap" type="com.fedex.connect.common.model.bi.Dictionary">
<id column="ID" jdbcType="NUMERIC" property="id" />
<result column="CODE" jdbcType="VARCHAR" property="code" />
<result column="ENGLISH_NAME" jdbcType="VARCHAR" property="englishName" />
......@@ -81,7 +81,7 @@
ID, CODE, ENGLISH_NAME, DESCRIPTION, STATUS, PARENT_ID, EXT1, EXT2, EXT3, EXT4, CREATE_TIME,
CREATE_USER_ID, CREATE_USER_NAME, MODIFY_TIME, MODIFY_USER_ID, MODIFY_USER_NAME
</sql>
<select id="selectByExample" parameterType="com.fedex.connect.common.model.base.DictionaryExample" resultMap="BaseResultMap">
<select id="selectByExample" parameterType="com.fedex.connect.common.model.bi.DictionaryExample" resultMap="BaseResultMap">
<include refid="OracleDialectPrefix" />
select
<if test="distinct">
......@@ -108,13 +108,13 @@
delete from T_BI_DICTIONARY
where ID = #{id,jdbcType=NUMERIC}
</delete>
<delete id="deleteByExample" parameterType="com.fedex.connect.common.model.base.DictionaryExample">
<delete id="deleteByExample" parameterType="com.fedex.connect.common.model.bi.DictionaryExample">
delete from T_BI_DICTIONARY
<if test="_parameter != null">
<include refid="Example_Where_Clause" />
</if>
</delete>
<insert id="insert" parameterType="com.fedex.connect.common.model.base.Dictionary">
<insert id="insert" parameterType="com.fedex.connect.common.model.bi.Dictionary">
<selectKey keyProperty="id" order="BEFORE" resultType="java.lang.Long">
SELECT SEQ_T_BI_DICTIONARY.NEXTVAL FROM DUAL
</selectKey>
......@@ -131,7 +131,7 @@
#{modifyTime,jdbcType=TIMESTAMP}, #{modifyUserId,jdbcType=NUMERIC}, #{modifyUserName,jdbcType=VARCHAR}
)
</insert>
<insert id="insertSelective" parameterType="com.fedex.connect.common.model.base.Dictionary">
<insert id="insertSelective" parameterType="com.fedex.connect.common.model.bi.Dictionary">
<selectKey keyProperty="id" order="BEFORE" resultType="java.lang.Long">
SELECT SEQ_T_BI_DICTIONARY.NEXTVAL FROM DUAL
</selectKey>
......@@ -233,7 +233,7 @@
</if>
</trim>
</insert>
<select id="countByExample" parameterType="com.fedex.connect.common.model.base.DictionaryExample" resultType="java.lang.Long">
<select id="countByExample" parameterType="com.fedex.connect.common.model.bi.DictionaryExample" resultType="java.lang.Long">
select count(*) from T_BI_DICTIONARY
<if test="_parameter != null">
<include refid="Example_Where_Clause" />
......@@ -317,7 +317,7 @@
<include refid="Update_By_Example_Where_Clause" />
</if>
</update>
<update id="updateByPrimaryKeySelective" parameterType="com.fedex.connect.common.model.base.Dictionary">
<update id="updateByPrimaryKeySelective" parameterType="com.fedex.connect.common.model.bi.Dictionary">
update T_BI_DICTIONARY
<set>
<if test="code != null">
......@@ -368,7 +368,7 @@
</set>
where ID = #{id,jdbcType=NUMERIC}
</update>
<update id="updateByPrimaryKey" parameterType="com.fedex.connect.common.model.base.Dictionary">
<update id="updateByPrimaryKey" parameterType="com.fedex.connect.common.model.bi.Dictionary">
update T_BI_DICTIONARY
set CODE = #{code,jdbcType=VARCHAR},
ENGLISH_NAME = #{englishName,jdbcType=VARCHAR},
......
package com.fedex.connect.common.model.base;
package com.fedex.connect.common.model.bi;
import java.io.Serializable;
import java.util.Date;
......
package com.fedex.connect.common.model.base;
package com.fedex.connect.common.model.bi;
import java.io.Serializable;
import java.util.Date;
......
package com.fedex.connect.common.model.base;
package com.fedex.connect.common.model.bi;
import java.util.ArrayList;
import java.util.Date;
......
package com.fedex.connect.common.model.base;
package com.fedex.connect.common.model.bi;
import java.util.ArrayList;
import java.util.Date;
......
package com.fedex.connect.common.model.sys;
import java.io.Serializable;
import java.util.Date;
/**
* DESC: kafka数据历史表
* TABLE: T_KAFKA_STORAGE_HISTORY
*/
public class KafkaStorageHistory implements Serializable {
/**
* ID,自动增加
*/
private Long id;
/**
* 由发送方定义的序列号,唯一 UUID JSON自动生成
*/
private String messageId;
/**
* 消息代码/类型
*/
private String messageCode;
/**
* 发送程序ID
*/
private String senderId;
/**
* 接受程序ID
*/
private String receiverId;
/**
* DM发送时间
*/
private Date sendTime;
/**
* 运单号
*/
private String consignmentCode;
/**
* 记录处理次数
*/
private Long frequency;
/**
* 数据状态(0:待处理,1:已处理,2:处理失败)
*/
private Long status;
/**
* 备注,记录错误信息
*/
private String remark;
/**
* 系统入库创建时间
*/
private Date createTime;
/**
* 消息体(Json字符串)
*/
private String data;
private static final long serialVersionUID = 1L;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getMessageId() {
return messageId;
}
public void setMessageId(String messageId) {
this.messageId = messageId == null ? null : messageId.trim();
}
public String getMessageCode() {
return messageCode;
}
public void setMessageCode(String messageCode) {
this.messageCode = messageCode == null ? null : messageCode.trim();
}
public String getSenderId() {
return senderId;
}
public void setSenderId(String senderId) {
this.senderId = senderId == null ? null : senderId.trim();
}
public String getReceiverId() {
return receiverId;
}
public void setReceiverId(String receiverId) {
this.receiverId = receiverId == null ? null : receiverId.trim();
}
public Date getSendTime() {
return sendTime;
}
public void setSendTime(Date sendTime) {
this.sendTime = sendTime;
}
public String getConsignmentCode() {
return consignmentCode;
}
public void setConsignmentCode(String consignmentCode) {
this.consignmentCode = consignmentCode == null ? null : consignmentCode.trim();
}
public Long getFrequency() {
return frequency;
}
public void setFrequency(Long frequency) {
this.frequency = frequency;
}
public Long getStatus() {
return status;
}
public void setStatus(Long status) {
this.status = status;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark == null ? null : remark.trim();
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getData() {
return data;
}
public void setData(String data) {
this.data = data == null ? null : data.trim();
}
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
sb.append(", id=").append(id);
sb.append(", messageId=").append(messageId);
sb.append(", messageCode=").append(messageCode);
sb.append(", senderId=").append(senderId);
sb.append(", receiverId=").append(receiverId);
sb.append(", sendTime=").append(sendTime);
sb.append(", consignmentCode=").append(consignmentCode);
sb.append(", frequency=").append(frequency);
sb.append(", status=").append(status);
sb.append(", remark=").append(remark);
sb.append(", createTime=").append(createTime);
sb.append(", data=").append(data);
sb.append(", serialVersionUID=").append(serialVersionUID);
sb.append("]");
return sb.toString();
}
}
\ No newline at end of file
package com.fedex.connect.common.model.sys;
import java.io.Serializable;
import java.util.Date;
/**
* DESC: kafka数据临时表
* TABLE: T_KAFKA_TEMPORARY_STORAGE
*/
public class KafkaTemporaryStorage implements Serializable {
/**
* ID,自动增加
*/
private Long id;
/**
* 由发送方定义的序列号,唯一 UUID JSON自动生成
*/
private String messageId;
/**
* 消息代码/类型
*/
private String messageCode;
/**
* 发送程序ID
*/
private String senderId;
/**
* 接受程序ID
*/
private String receiverId;
/**
* DM发送时间
*/
private Date sendTime;
/**
* 运单号
*/
private String consignmentCode;
/**
* 记录处理次数
*/
private Long frequency;
/**
* 数据状态(0:待处理,1:已处理,2:处理失败)
*/
private Long status;
/**
* 备注,记录错误信息
*/
private String remark;
/**
* 系统入库创建时间
*/
private Date createTime;
/**
* 消息体(Json字符串)
*/
private String data;
private static final long serialVersionUID = 1L;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getMessageId() {
return messageId;
}
public void setMessageId(String messageId) {
this.messageId = messageId == null ? null : messageId.trim();
}
public String getMessageCode() {
return messageCode;
}
public void setMessageCode(String messageCode) {
this.messageCode = messageCode == null ? null : messageCode.trim();
}
public String getSenderId() {
return senderId;
}
public void setSenderId(String senderId) {
this.senderId = senderId == null ? null : senderId.trim();
}
public String getReceiverId() {
return receiverId;
}
public void setReceiverId(String receiverId) {
this.receiverId = receiverId == null ? null : receiverId.trim();
}
public Date getSendTime() {
return sendTime;
}
public void setSendTime(Date sendTime) {
this.sendTime = sendTime;
}
public String getConsignmentCode() {
return consignmentCode;
}
public void setConsignmentCode(String consignmentCode) {
this.consignmentCode = consignmentCode == null ? null : consignmentCode.trim();
}
public Long getFrequency() {
return frequency;
}
public void setFrequency(Long frequency) {
this.frequency = frequency;
}
public Long getStatus() {
return status;
}
public void setStatus(Long status) {
this.status = status;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark == null ? null : remark.trim();
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getData() {
return data;
}
public void setData(String data) {
this.data = data == null ? null : data.trim();
}
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
sb.append(", id=").append(id);
sb.append(", messageId=").append(messageId);
sb.append(", messageCode=").append(messageCode);
sb.append(", senderId=").append(senderId);
sb.append(", receiverId=").append(receiverId);
sb.append(", sendTime=").append(sendTime);
sb.append(", consignmentCode=").append(consignmentCode);
sb.append(", frequency=").append(frequency);
sb.append(", status=").append(status);
sb.append(", remark=").append(remark);
sb.append(", createTime=").append(createTime);
sb.append(", data=").append(data);
sb.append(", serialVersionUID=").append(serialVersionUID);
sb.append("]");
return sb.toString();
}
}
\ No newline at end of file
......@@ -40,7 +40,7 @@
sys:系统 系统相关表,例如kafka表
log: 日志 日志记录表,例如邮件发送日志表
-->
<javaModelGenerator targetPackage="com.fedex.connect.common.model.sys" targetProject="src/main/java">
<javaModelGenerator targetPackage="com.fedex.connect.common.model.bi" targetProject="src/main/java">
<!---enableSubPackages:如果true,MBG会根据catalog和schema来生成子包。如果false就会直接用targetPackage属性-->
<property name="enableSubPackages" value="false"/>
<!--该属性只对MyBatis3有效,如果true就会使用构造方法入参,如果false就会使用setter方式。默认为false-->
......@@ -52,13 +52,13 @@
</javaModelGenerator>
<!-- 生成映射文件*.xml的位置-->
<sqlMapGenerator targetPackage="mapper.sys" targetProject="src/main/java/com/fedex/connect/common">
<sqlMapGenerator targetPackage="mapper.bi" targetProject="src/main/java/com/fedex/connect/common">
<!--如果true,MBG会根据catalog和schema来生成子包。如果false就会直接用targetPackage属性。默认为false-->
<property name="enableSubPackages" value="false"/>
</sqlMapGenerator>
<!-- 生成DAO的包名和位置 -->
<javaClientGenerator type="XMLMAPPER" targetPackage="com.fedex.connect.common.dao.sys" targetProject="src/main/java">
<javaClientGenerator type="XMLMAPPER" targetPackage="com.fedex.connect.common.dao.bi" targetProject="src/main/java">
<!--如果true,MBG会根据catalog和schema来生成子包。如果false就会直接用targetPackage属性。默认为false-->
<property name="enableSubPackages" value="false"/>
</javaClientGenerator>
......@@ -74,24 +74,24 @@
sqlStatement 指定序列名称
-->
<table tableName="T_SYS_REDIS_SLAB" domainObjectName="redisSlab"
enableCountByExample="true" enableUpdateByExample="true"
enableDeleteByExample="true" enableSelectByExample="true"
selectByExampleQueryId="true">
<generatedKey column="ID" sqlStatement="SELECT SEQ_T_SYS_REDIS_SLAB.NEXTVAL FROM DUAL" />
</table>
<!-- <table tableName="T_KAFKA_TEMPORARY_STORAGE" domainObjectName="KafkaTemporaryStorage"-->
<!-- enableCountByExample="true" enableUpdateByExample="true"-->
<!-- enableDeleteByExample="true" enableSelectByExample="true"-->
<!-- selectByExampleQueryId="true">-->
<!-- <generatedKey column="ID" sqlStatement="SELECT SEQ_T_KAFKA_TEMPORARY_STORAGE.NEXTVAL FROM DUAL" />-->
<!-- </table>-->
<!-- <table tableName="T_KAFKA_STORAGE_HISTORY" domainObjectName="KafkaStorageHistory"-->
<!-- enableCountByExample="true" enableUpdateByExample="true"-->
<!-- enableDeleteByExample="true" enableSelectByExample="true"-->
<!-- selectByExampleQueryId="true">-->
<!-- <generatedKey column="ID" sqlStatement="SELECT SEQ_T_KAFKA_STORAGE_HISTORY.NEXTVAL FROM DUAL" />-->
<!-- </table>-->
<!-- <table tableName="T_SYS_REDIS_SLAB" domainObjectName="redisSlab"-->
<!-- enableCountByExample="true" enableUpdateByExample="true"-->
<!-- enableDeleteByExample="true" enableSelectByExample="true"-->
<!-- selectByExampleQueryId="true">-->
<!-- <generatedKey column="ID" sqlStatement="SELECT SEQ_T_SYS_REDIS_SLAB.NEXTVAL FROM DUAL" />-->
<!-- </table>-->
<table tableName="T_SYS_KAFKA_STORAGE_HISTORY" domainObjectName="KafkaTemporaryStorage"
enableCountByExample="true" enableUpdateByExample="true"
enableDeleteByExample="true" enableSelectByExample="true"
selectByExampleQueryId="true">
<generatedKey column="ID" sqlStatement="SELECT SEQ_T_SYS_KAFKA_STORAGE_HISTORY.NEXTVAL FROM DUAL" />
</table>
<table tableName="T_SYS_KAFKA_TEMPORARY_STORAGE" domainObjectName="KafkaStorageHistory"
enableCountByExample="true" enableUpdateByExample="true"
enableDeleteByExample="true" enableSelectByExample="true"
selectByExampleQueryId="true">
<generatedKey column="ID" sqlStatement="SELECT SEQ_T_SYS_KAFKA_TEMPORARY_STORAGE.NEXTVAL FROM DUAL" />
</table>
<!-- <table tableName="T_SYS_PARAM_CONFIG" domainObjectName="ParamConfig"-->
<!-- enableCountByExample="true" enableUpdateByExample="true"-->
<!-- enableDeleteByExample="true" enableSelectByExample="true"-->
......