dao|kafka实体创建

+package com.fedex.connect.common.dao.sys;
+
+import com.fedex.connect.common.model.sys.KafkaStorageHistory;
+import com.fedex.connect.common.model.sys.KafkaStorageHistoryExample;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+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

+package com.fedex.connect.common.model.sys;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * DESC: KAFKA临时表
+ * TABLE: T_SYS_KAFKA_TEMPORARY_STORAGE
+ */
+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;
+
+    /**
+     * KAFKA消息状态ID,关联数据字典表。指定字典目录CODE：KAFKA_MSG_STATUS
+     */
+    private Long statusId;
+
+    /**
+     * KAFKA消息状态NAME
+     */
+    private String statusName;
+
+    /**
+     * 备注，记录错误信息
+     */
+    private String remark;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人ID，关联用户表ID
+     */
+    private Long createUserId;
+
+    /**
+     * 创建人名称
+     */
+    private String createUserName;
+
+    /**
+     * 修改时间
+     */
+    private Date modifyTime;
+
+    /**
+     * 修改人ID，关联用户表ID
+     */
+    private Long modifyUserId;
+
+    /**
+     * 修改人名称
+     */
+    private String modifyUserName;
+
+    /**
+     * 消息体（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 getStatusId() {
+        return statusId;
+    }
+
+    public void setStatusId(Long statusId) {
+        this.statusId = statusId;
+    }
+
+    public String getStatusName() {
+        return statusName;
+    }
+
+    public void setStatusName(String statusName) {
+        this.statusName = statusName == null ? null : statusName.trim();
+    }
+
+    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 Long getCreateUserId() {
+        return createUserId;
+    }
+
+    public void setCreateUserId(Long createUserId) {
+        this.createUserId = createUserId;
+    }
+
+    public String getCreateUserName() {
+        return createUserName;
+    }
+
+    public void setCreateUserName(String createUserName) {
+        this.createUserName = createUserName == null ? null : createUserName.trim();
+    }
+
+    public Date getModifyTime() {
+        return modifyTime;
+    }
+
+    public void setModifyTime(Date modifyTime) {
+        this.modifyTime = modifyTime;
+    }
+
+    public Long getModifyUserId() {
+        return modifyUserId;
+    }
+
+    public void setModifyUserId(Long modifyUserId) {
+        this.modifyUserId = modifyUserId;
+    }
+
+    public String getModifyUserName() {
+        return modifyUserName;
+    }
+
+    public void setModifyUserName(String modifyUserName) {
+        this.modifyUserName = modifyUserName == null ? null : modifyUserName.trim();
+    }
+
+    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(", statusId=").append(statusId);
+        sb.append(", statusName=").append(statusName);
+        sb.append(", remark=").append(remark);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", createUserId=").append(createUserId);
+        sb.append(", createUserName=").append(createUserName);
+        sb.append(", modifyTime=").append(modifyTime);
+        sb.append(", modifyUserId=").append(modifyUserId);
+        sb.append(", modifyUserName=").append(modifyUserName);
+        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_SYS_KAFKA_STORAGE_HISTORY
+ */
+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;
+
+    /**
+     * KAFKA消息状态ID,关联数据字典表。指定字典目录CODE：KAFKA_MSG_STATUS
+     */
+    private Long statusId;
+
+    /**
+     * KAFKA消息状态NAME
+     */
+    private String statusName;
+
+    /**
+     * 备注，记录错误信息
+     */
+    private String remark;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人ID，关联用户表ID
+     */
+    private Long createUserId;
+
+    /**
+     * 创建人名称
+     */
+    private String createUserName;
+
+    /**
+     * 修改时间
+     */
+    private Date modifyTime;
+
+    /**
+     * 修改人ID，关联用户表ID
+     */
+    private Long modifyUserId;
+
+    /**
+     * 修改人名称
+     */
+    private String modifyUserName;
+
+    /**
+     * 消息体（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 getStatusId() {
+        return statusId;
+    }
+
+    public void setStatusId(Long statusId) {
+        this.statusId = statusId;
+    }
+
+    public String getStatusName() {
+        return statusName;
+    }
+
+    public void setStatusName(String statusName) {
+        this.statusName = statusName == null ? null : statusName.trim();
+    }
+
+    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 Long getCreateUserId() {
+        return createUserId;
+    }
+
+    public void setCreateUserId(Long createUserId) {
+        this.createUserId = createUserId;
+    }
+
+    public String getCreateUserName() {
+        return createUserName;
+    }
+
+    public void setCreateUserName(String createUserName) {
+        this.createUserName = createUserName == null ? null : createUserName.trim();
+    }
+
+    public Date getModifyTime() {
+        return modifyTime;
+    }
+
+    public void setModifyTime(Date modifyTime) {
+        this.modifyTime = modifyTime;
+    }
+
+    public Long getModifyUserId() {
+        return modifyUserId;
+    }
+
+    public void setModifyUserId(Long modifyUserId) {
+        this.modifyUserId = modifyUserId;
+    }
+
+    public String getModifyUserName() {
+        return modifyUserName;
+    }
+
+    public void setModifyUserName(String modifyUserName) {
+        this.modifyUserName = modifyUserName == null ? null : modifyUserName.trim();
+    }
+
+    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(", statusId=").append(statusId);
+        sb.append(", statusName=").append(statusName);
+        sb.append(", remark=").append(remark);
+        sb.append(", createTime=").append(createTime);
+        sb.append(", createUserId=").append(createUserId);
+        sb.append(", createUserName=").append(createUserName);
+        sb.append(", modifyTime=").append(modifyTime);
+        sb.append(", modifyUserId=").append(modifyUserId);
+        sb.append(", modifyUserName=").append(modifyUserName);
+        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表
             sys：系统 系统相关表，例如kafka表
             log: 日志 日志记录表，例如邮件发送日志表
             log: 日志 日志记录表，例如邮件发送日志表
         -->
         -->
-        <javaModelGenerator targetPackage="com.fedex.connect.common.model.bi" targetProject="src/main/java">
+        <javaModelGenerator targetPackage="com.fedex.connect.common.model.sys" targetProject="src/main/java">
             <!---enableSubPackages:如果true，MBG会根据catalog和schema来生成子包。如果false就会直接用targetPackage属性-->
             <!---enableSubPackages:如果true，MBG会根据catalog和schema来生成子包。如果false就会直接用targetPackage属性-->
             <property name="enableSubPackages" value="false"/>
             <property name="enableSubPackages" value="false"/>
             <!--该属性只对MyBatis3有效，如果true就会使用构造方法入参，如果false就会使用setter方式。默认为false-->
             <!--该属性只对MyBatis3有效，如果true就会使用构造方法入参，如果false就会使用setter方式。默认为false-->
@@ -52,13 +52,13 @@
         </javaModelGenerator>
         </javaModelGenerator>
 
 
         <!-- 生成映射文件*.xml的位置-->
         <!-- 生成映射文件*.xml的位置-->
-        <sqlMapGenerator targetPackage="mapper.bi" targetProject="src/main/java/com/fedex/connect/common">
+        <sqlMapGenerator targetPackage="mapper.sys" targetProject="src/main/java/com/fedex/connect/common">
             <!--如果true，MBG会根据catalog和schema来生成子包。如果false就会直接用targetPackage属性。默认为false-->
             <!--如果true，MBG会根据catalog和schema来生成子包。如果false就会直接用targetPackage属性。默认为false-->
             <property name="enableSubPackages" value="false"/>
             <property name="enableSubPackages" value="false"/>
         </sqlMapGenerator>
         </sqlMapGenerator>
 
 
         <!-- 生成DAO的包名和位置 -->
         <!-- 生成DAO的包名和位置 -->
-        <javaClientGenerator type="XMLMAPPER" targetPackage="com.fedex.connect.common.dao.bi" targetProject="src/main/java">
+        <javaClientGenerator type="XMLMAPPER" targetPackage="com.fedex.connect.common.dao.sys" targetProject="src/main/java">
             <!--如果true，MBG会根据catalog和schema来生成子包。如果false就会直接用targetPackage属性。默认为false-->
             <!--如果true，MBG会根据catalog和schema来生成子包。如果false就会直接用targetPackage属性。默认为false-->
             <property name="enableSubPackages" value="false"/>
             <property name="enableSubPackages" value="false"/>
         </javaClientGenerator>
         </javaClientGenerator>