databus 加入名称处理

java110-bean/src/main/java/com/java110/dto/businessDatabus/BusinessDatabusDto.java

@@ -1,6 +1,7 @@
 package com.java110.dto.businessDatabus;
 
 import com.java110.dto.PageDto;
+
 import java.io.Serializable;
 import java.util.Date;
 
@@ -15,9 +16,12 @@ import java.util.Date;
 public class BusinessDatabusDto extends PageDto implements Serializable {
 
     private String businessTypeCd;
-private String databusId;
-private String beanName;
-private String seq;
+    private String databusId;
+    private String beanName;
+    private String seq;
+    private String databusName;
+    private String state;
+
 
 
     private Date createTime;
@@ -28,25 +32,32 @@ private String seq;
     public String getBusinessTypeCd() {
         return businessTypeCd;
     }
-public void setBusinessTypeCd(String businessTypeCd) {
+
+    public void setBusinessTypeCd(String businessTypeCd) {
         this.businessTypeCd = businessTypeCd;
     }
-public String getDatabusId() {
+
+    public String getDatabusId() {
         return databusId;
     }
-public void setDatabusId(String databusId) {
+
+    public void setDatabusId(String databusId) {
         this.databusId = databusId;
     }
-public String getBeanName() {
+
+    public String getBeanName() {
         return beanName;
     }
-public void setBeanName(String beanName) {
+
+    public void setBeanName(String beanName) {
         this.beanName = beanName;
     }
-public String getSeq() {
+
+    public String getSeq() {
         return seq;
     }
-public void setSeq(String seq) {
+
+    public void setSeq(String seq) {
         this.seq = seq;
     }
 
@@ -66,4 +77,20 @@ public void setSeq(String seq) {
     public void setStatusCd(String statusCd) {
         this.statusCd = statusCd;
     }
+
+    public String getDatabusName() {
+        return databusName;
+    }
+
+    public void setDatabusName(String databusName) {
+        this.databusName = databusName;
+    }
+
+    public String getState() {
+        return state;
+    }
+
+    public void setState(String state) {
+        this.state = state;
+    }
 }

java110-bean/src/main/java/com/java110/po/businessDatabus/BusinessDatabusPo.java

@@ -9,6 +9,8 @@ public class BusinessDatabusPo implements Serializable {
     private String beanName;
     private String statusCd = "0";
     private String seq;
+    private String databusName;
+    private String state;
 
     public String getBusinessTypeCd() {
         return businessTypeCd;
@@ -50,5 +52,19 @@ public class BusinessDatabusPo implements Serializable {
         this.seq = seq;
     }
 
+    public String getDatabusName() {
+        return databusName;
+    }
+
+    public void setDatabusName(String databusName) {
+        this.databusName = databusName;
+    }
 
+    public String getState() {
+        return state;
+    }
+
+    public void setState(String state) {
+        this.state = state;
+    }
 }

java110-db/src/main/resources/mapper/job/BusinessDatabusServiceDaoImplMapper.xml

@@ -7,9 +7,9 @@
     <!-- 保存业务数据同步信息 add by wuxw 2018-07-03 -->
     <insert id="saveBusinessDatabusInfo" parameterType="Map">
         insert into c_business_databus(
-        business_type_cd,databus_id,bean_name,seq
+        business_type_cd,databus_id,bean_name,seq,databus_name,state
         ) values (
-        #{businessTypeCd},#{databusId},#{beanName},#{seq}
+        #{businessTypeCd},#{databusId},#{beanName},#{seq},#{databusName},#{state}
         )
     </insert>
 
@@ -17,7 +17,8 @@
     <!-- 查询业务数据同步信息 add by wuxw 2018-07-03 -->
     <select id="getBusinessDatabusInfo" parameterType="Map" resultType="Map">
         select t.business_type_cd,t.business_type_cd businessTypeCd,t.databus_id,t.databus_id
-        databusId,t.bean_name,t.bean_name beanName,t.status_cd,t.status_cd statusCd,t.seq
+        databusId,t.bean_name,t.bean_name beanName,t.status_cd,t.status_cd statusCd,t.seq,
+        t.databus_name databusName,t.state
         from c_business_databus t
         where 1 =1
         <if test="businessTypeCd !=null and businessTypeCd != ''">
@@ -35,6 +36,12 @@
         <if test="seq !=null and seq != ''">
             and t.seq= #{seq}
         </if>
+        <if test="databusName !=null and databusName != ''">
+            and t.databus_name= #{databusName}
+        </if>
+        <if test="state !=null and state != ''">
+            and t.state= #{state}
+        </if>
         order by t.create_time desc
         <if test="page != -1 and page != null ">
             limit #{page}, #{row}
@@ -58,6 +65,12 @@
         <if test="seq !=null and seq != ''">
             , t.seq= #{seq}
         </if>
+        <if test="databusName !=null and databusName != ''">
+            , t.databus_name= #{databusName}
+        </if>
+        <if test="state !=null and state != ''">
+            , t.state= #{state}
+        </if>
         where 1=1
         <if test="databusId !=null and databusId != ''">
             and t.databus_id= #{databusId}
@@ -85,6 +98,12 @@
         <if test="seq !=null and seq != ''">
             and t.seq= #{seq}
         </if>
+        <if test="databusName !=null and databusName != ''">
+            and t.databus_name= #{databusName}
+        </if>
+        <if test="state !=null and state != ''">
+            and t.state= #{state}
+        </if>
 
 
     </select>