update

src/main/java/com/eazytec/hkydatabasessynchronization/entity/EnterpriseBaseInfo.java

@@ -708,6 +708,8 @@ public class EnterpriseBaseInfo implements Serializable {
     @TableField("odm_rksj")
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public String getEnterpriseId() {
         return enterpriseId;
     }
@@ -1811,4 +1813,12 @@ public class EnterpriseBaseInfo implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/EnterpriseRescueMaterial.java

@@ -128,6 +128,8 @@ public class EnterpriseRescueMaterial implements Serializable {
      */
     private String materialName;
 
+    private Integer editStatus;
+
     public String getEnterpriseEmergencyRescueMaterialId() {
         return enterpriseEmergencyRescueMaterialId;
     }
@@ -303,4 +305,12 @@ public class EnterpriseRescueMaterial implements Serializable {
     public void setMaterialName(String materialName) {
         this.materialName = materialName;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/EnterpriseRescueTeam.java

@@ -129,6 +129,8 @@ public class EnterpriseRescueTeam implements Serializable {
     @TableField("odm_rksj")
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public String getEnterpriseEmergencyRescueTeamId() {
         return enterpriseEmergencyRescueTeamId;
     }
@@ -304,4 +306,12 @@ public class EnterpriseRescueTeam implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/EnterpriseTestReport.java

@@ -93,6 +93,8 @@ public class EnterpriseTestReport implements Serializable {
     @TableField("odm_rksj")
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public String getEnterpriseRiskPartitionId() {
         return enterpriseRiskPartitionId;
     }
@@ -212,4 +214,12 @@ public class EnterpriseTestReport implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OTEmerspsSpsEnterpriseHazardousChemicals.java

@@ -140,6 +140,8 @@ public class OTEmerspsSpsEnterpriseHazardousChemicals implements Serializable {
      */
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public String getEnterpriseHazardousChemicalsId() {
         return enterpriseHazardousChemicalsId;
     }
@@ -339,4 +341,12 @@ public class OTEmerspsSpsEnterpriseHazardousChemicals implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OTEmerspsSpsEnterpriseHistoryHiddenTrouble.java

@@ -113,6 +113,8 @@ public class OTEmerspsSpsEnterpriseHistoryHiddenTrouble implements Serializable
     @TableField("odm_rksj")
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public String getEnterpriseHistoryHiddenTroubleId() {
         return enterpriseHistoryHiddenTroubleId;
     }
@@ -264,4 +266,12 @@ public class OTEmerspsSpsEnterpriseHistoryHiddenTrouble implements Serializable
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OTEmerspsSpsEnterpriseLeakPoint.java

@@ -118,6 +118,8 @@ public class OTEmerspsSpsEnterpriseLeakPoint implements Serializable {
     @TableField("odm_rksj")
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public String getEnterpriseLeakPointId() {
         return enterpriseLeakPointId;
     }
@@ -277,4 +279,12 @@ public class OTEmerspsSpsEnterpriseLeakPoint implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OTEmerspsSpsEnterpriseRealtimeAlarmRecord.java

@@ -68,6 +68,8 @@ public class OTEmerspsSpsEnterpriseRealtimeAlarmRecord implements Serializable {
     @TableField("odm_rksj")
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public String getEnterpriseRealtimeAlarmRecordId() {
         return enterpriseRealtimeAlarmRecordId;
     }
@@ -147,4 +149,12 @@ public class OTEmerspsSpsEnterpriseRealtimeAlarmRecord implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OTEmerspsSpsEnterpriseSpecialOperationPerson.java

@@ -126,6 +126,8 @@ public class OTEmerspsSpsEnterpriseSpecialOperationPerson implements Serializabl
     @TableField("odm_rksj")
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public String getEnterpriseSpecialOperationPersonId() {
         return enterpriseSpecialOperationPersonId;
     }
@@ -293,4 +295,12 @@ public class OTEmerspsSpsEnterpriseSpecialOperationPerson implements Serializabl
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/TProject.java

@@ -136,6 +136,8 @@ public class TProject implements Serializable {
     @TableField("odm_rksj")
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public Long getId() {
         return id;
     }
@@ -319,4 +321,12 @@ public class TProject implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/TProjectJg.java

@@ -126,6 +126,8 @@ public class TProjectJg implements Serializable {
     @TableField("odm_rksj")
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public Long getId() {
         return id;
     }
@@ -285,4 +287,12 @@ public class TProjectJg implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/TProjectNj.java

@@ -132,6 +132,8 @@ public class TProjectNj implements Serializable {
      */
     private Integer tdgzpSts;
 
+    private Integer editStatus;
+
     public Long getId() {
         return id;
     }
@@ -307,4 +309,12 @@ public class TProjectNj implements Serializable {
     public void setTdgzpSts(Integer tdgzpSts) {
         this.tdgzpSts = tdgzpSts;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/TProjectSchedule.java

@@ -93,6 +93,8 @@ public class TProjectSchedule implements Serializable {
      */
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public Long getId() {
         return id;
     }
@@ -212,4 +214,12 @@ public class TProjectSchedule implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/entity/TProjectZj.java

@@ -98,6 +98,8 @@ public class TProjectZj implements Serializable {
      */
     private Date odmRksj;
 
+    private Integer editStatus;
+
     public Long getId() {
         return id;
     }
@@ -225,4 +227,12 @@ public class TProjectZj implements Serializable {
     public void setOdmRksj(Date odmRksj) {
         this.odmRksj = odmRksj;
     }
+
+    public Integer getEditStatus() {
+        return editStatus;
+    }
+
+    public void setEditStatus(Integer editStatus) {
+        this.editStatus = editStatus;
+    }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/EOTEmerspsSpsEnterpriseMajorHazardEvent.java

@@ -32,6 +32,7 @@ public class EOTEmerspsSpsEnterpriseMajorHazardEvent implements IBinlogEventHand
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_major_hazard");
+//        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_major_hazard");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/EnterpriseBaseInfoEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class EnterpriseBaseInfoEvent implements IBinlogEventHandler<EnterpriseBaseInfo> {
 
@@ -17,7 +19,15 @@ public class EnterpriseBaseInfoEvent implements IBinlogEventHandler<EnterpriseBa
 
     @Override
     public void onInsert(BinlogEvent<EnterpriseBaseInfo> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        EnterpriseBaseInfo data = binlogEvent.getData();
+        EnterpriseBaseInfo enterpriseBaseInfo = mapper.selectById(data.getEnterpriseId());
+        if (Objects.isNull(enterpriseBaseInfo)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(enterpriseBaseInfo.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/EnterpriseRescueMaterialEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class EnterpriseRescueMaterialEvent implements IBinlogEventHandler<EnterpriseRescueMaterial> {
 
@@ -17,7 +19,15 @@ public class EnterpriseRescueMaterialEvent implements IBinlogEventHandler<Enterp
 
     @Override
     public void onInsert(BinlogEvent<EnterpriseRescueMaterial> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        EnterpriseRescueMaterial data = binlogEvent.getData();
+        EnterpriseRescueMaterial enterpriseRescueMaterial = mapper.selectById(data.getEnterpriseEmergencyRescueMaterialId());
+        if (Objects.isNull(enterpriseRescueMaterial)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(enterpriseRescueMaterial.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/EnterpriseRescueTeamEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class EnterpriseRescueTeamEvent implements IBinlogEventHandler<EnterpriseRescueTeam> {
 
@@ -17,7 +19,15 @@ public class EnterpriseRescueTeamEvent implements IBinlogEventHandler<Enterprise
 
     @Override
     public void onInsert(BinlogEvent<EnterpriseRescueTeam> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        EnterpriseRescueTeam data = binlogEvent.getData();
+        EnterpriseRescueTeam enterpriseRescueTeam = mapper.selectById(data.getEnterpriseEmergencyRescueTeamId());
+        if (Objects.isNull(enterpriseRescueTeam)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(enterpriseRescueTeam.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/EnterpriseTestReportEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class EnterpriseTestReportEvent implements IBinlogEventHandler<EnterpriseTestReport> {
 
@@ -17,7 +19,15 @@ public class EnterpriseTestReportEvent implements IBinlogEventHandler<Enterprise
 
     @Override
     public void onInsert(BinlogEvent<EnterpriseTestReport> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        EnterpriseTestReport data = binlogEvent.getData();
+        EnterpriseTestReport enterpriseTestReport = mapper.selectById(data.getEnterpriseRiskPartitionId());
+        if (Objects.isNull(enterpriseTestReport)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(enterpriseTestReport.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/OT12345SysAreaEvent.java

@@ -32,6 +32,7 @@ public class OT12345SysAreaEvent implements IBinlogEventHandler<OT12345SysArea>
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_12345_sys_area");
+//        return s.equals("digital_hky") && s1.equals("o_t_12345_sys_area");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OT12345SysGroupDataEvent.java

@@ -32,6 +32,7 @@ public class OT12345SysGroupDataEvent implements IBinlogEventHandler<OT12345SysG
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_12345_sys_group_data");
+//        return s.equals("digital_hky") && s1.equals("o_t_12345_sys_group_data");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OT12345TBusiAdviceEvent.java

@@ -32,6 +32,7 @@ public class OT12345TBusiAdviceEvent implements IBinlogEventHandler<OT12345TBusi
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_12345_t_busi_advice");
+//        return s.equals("digital_hky") && s1.equals("o_t_12345_t_busi_advice");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OT12345TBusiFormEvent.java

@@ -32,6 +32,7 @@ public class OT12345TBusiFormEvent implements IBinlogEventHandler<OT12345TBusiFo
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_12345_t_busi_form");
+//        return s.equals("digital_hky") && s1.equals("o_t_12345_t_busi_form");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTBaseAjqyEvent.java

@@ -32,6 +32,7 @@ public class OTBaseAjqyEvent implements IBinlogEventHandler<OTBaseAjqy> {
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_base_ajqy");
+//        return s.equals("digital_hky") && s1.equals("o_t_base_ajqy");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTBaseIstProjectEvent.java

@@ -32,6 +32,7 @@ public class OTBaseIstProjectEvent implements IBinlogEventHandler<OTBaseIstProje
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_base_ist_project");
+//        return s.equals("digital_hky") && s1.equals("o_t_base_ist_project");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTBaseJiyueMapQiyeEvent.java

@@ -32,6 +32,7 @@ public class OTBaseJiyueMapQiyeEvent implements IBinlogEventHandler<OTBaseJiyueM
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_base_jiyue_map_qiye");
+//        return s.equals("digital_hky") && s1.equals("o_t_base_jiyue_map_qiye");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsEmeCdeCodeDictoTEmerspsEmeCdeCodeDictEvent.java

@@ -32,6 +32,7 @@ public class OTEmerspsEmeCdeCodeDictoTEmerspsEmeCdeCodeDictEvent implements IBin
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_emersps_eme_cde_code_dicto_t_emersps_eme_cde_code_dict");
+//        return s.equals("digital_hky") && s1.equals("o_t_emersps_eme_cde_code_dicto_t_emersps_eme_cde_code_dict");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsEnterpriseEvaluationTestReportEvent.java

@@ -32,6 +32,7 @@ public class OTEmerspsSpsEnterpriseEvaluationTestReportEvent implements IBinlogE
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_evaluation_test_report");
+//        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_evaluation_test_report");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsEnterpriseHazardousChemicalsEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class OTEmerspsSpsEnterpriseHazardousChemicalsEvent implements IBinlogEventHandler<OTEmerspsSpsEnterpriseHazardousChemicals> {
 
@@ -17,7 +19,15 @@ public class OTEmerspsSpsEnterpriseHazardousChemicalsEvent implements IBinlogEve
 
     @Override
     public void onInsert(BinlogEvent<OTEmerspsSpsEnterpriseHazardousChemicals> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        OTEmerspsSpsEnterpriseHazardousChemicals data = binlogEvent.getData();
+        OTEmerspsSpsEnterpriseHazardousChemicals otEmerspsSpsEnterpriseHazardousChemicals = mapper.selectById(data.getEnterpriseHazardousChemicalsId());
+        if (Objects.isNull(otEmerspsSpsEnterpriseHazardousChemicals)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(otEmerspsSpsEnterpriseHazardousChemicals.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsEnterpriseHistoryHiddenTroubleEvent.java

@@ -8,6 +8,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class OTEmerspsSpsEnterpriseHistoryHiddenTroubleEvent implements IBinlogEventHandler<OTEmerspsSpsEnterpriseHistoryHiddenTrouble> {
 
@@ -19,7 +21,15 @@ public class OTEmerspsSpsEnterpriseHistoryHiddenTroubleEvent implements IBinlogE
 
     @Override
     public void onInsert(BinlogEvent<OTEmerspsSpsEnterpriseHistoryHiddenTrouble> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        OTEmerspsSpsEnterpriseHistoryHiddenTrouble data = binlogEvent.getData();
+        OTEmerspsSpsEnterpriseHistoryHiddenTrouble otEmerspsSpsEnterpriseHistoryHiddenTrouble = mapper.selectById(data.getEnterpriseHistoryHiddenTroubleId());
+        if (Objects.isNull(otEmerspsSpsEnterpriseHistoryHiddenTrouble)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(otEmerspsSpsEnterpriseHistoryHiddenTrouble.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsEnterpriseLeakPointEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class OTEmerspsSpsEnterpriseLeakPointEvent implements IBinlogEventHandler<OTEmerspsSpsEnterpriseLeakPoint> {
 
@@ -17,7 +19,15 @@ public class OTEmerspsSpsEnterpriseLeakPointEvent implements IBinlogEventHandler
 
     @Override
     public void onInsert(BinlogEvent<OTEmerspsSpsEnterpriseLeakPoint> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        OTEmerspsSpsEnterpriseLeakPoint data = binlogEvent.getData();
+        OTEmerspsSpsEnterpriseLeakPoint otEmerspsSpsEnterpriseLeakPoint = mapper.selectById(data.getEnterpriseLeakPointId());
+        if (Objects.isNull(otEmerspsSpsEnterpriseLeakPoint)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(otEmerspsSpsEnterpriseLeakPoint.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsEnterpriseMaterialInfoEvent.java

@@ -32,6 +32,7 @@ public class OTEmerspsSpsEnterpriseMaterialInfoEvent implements IBinlogEventHand
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_material_info");
+//        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_material_info");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsEnterpriseRealtimeAlarmRecordEvent.java

@@ -8,6 +8,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class OTEmerspsSpsEnterpriseRealtimeAlarmRecordEvent implements IBinlogEventHandler<OTEmerspsSpsEnterpriseRealtimeAlarmRecord> {
 
@@ -19,7 +21,15 @@ public class OTEmerspsSpsEnterpriseRealtimeAlarmRecordEvent implements IBinlogEv
 
     @Override
     public void onInsert(BinlogEvent<OTEmerspsSpsEnterpriseRealtimeAlarmRecord> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        OTEmerspsSpsEnterpriseRealtimeAlarmRecord data = binlogEvent.getData();
+        OTEmerspsSpsEnterpriseRealtimeAlarmRecord otEmerspsSpsEnterpriseRealtimeAlarmRecord = mapper.selectById(data.getEnterpriseRealtimeAlarmRecordId());
+        if (Objects.isNull(otEmerspsSpsEnterpriseRealtimeAlarmRecord)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(otEmerspsSpsEnterpriseRealtimeAlarmRecord.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsEnterpriseRiskIdentificationEvent.java

@@ -32,6 +32,7 @@ public class OTEmerspsSpsEnterpriseRiskIdentificationEvent implements IBinlogEve
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_risk_identification");
+//        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_risk_identification");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsEnterpriseRiskPartitionEvent.java

@@ -32,6 +32,7 @@ public class OTEmerspsSpsEnterpriseRiskPartitionEvent implements IBinlogEventHan
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_risk_partition");
+//        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_enterprise_risk_partition");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsEnterpriseSpecialOperationPersonEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class OTEmerspsSpsEnterpriseSpecialOperationPersonEvent implements IBinlogEventHandler<OTEmerspsSpsEnterpriseSpecialOperationPerson> {
 
@@ -17,7 +19,15 @@ public class OTEmerspsSpsEnterpriseSpecialOperationPersonEvent implements IBinlo
 
     @Override
     public void onInsert(BinlogEvent<OTEmerspsSpsEnterpriseSpecialOperationPerson> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        OTEmerspsSpsEnterpriseSpecialOperationPerson data = binlogEvent.getData();
+        OTEmerspsSpsEnterpriseSpecialOperationPerson otEmerspsSpsEnterpriseSpecialOperationPerson = mapper.selectById(data.getEnterpriseSpecialOperationPersonId());
+        if (Objects.isNull(otEmerspsSpsEnterpriseSpecialOperationPerson)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(otEmerspsSpsEnterpriseSpecialOperationPerson.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTEmerspsSpsSpSysCodeEvent.java

@@ -32,6 +32,7 @@ public class OTEmerspsSpsSpSysCodeEvent implements IBinlogEventHandler<OTEmersps
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_sp_sys_code");
+//        return s.equals("digital_hky") && s1.equals("o_t_emersps_sps_sp_sys_code");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTGaTJxwCzrkxxEvent.java

@@ -32,6 +32,7 @@ public class OTGaTJxwCzrkxxEvent implements IBinlogEventHandler<OTGaTJxwCzrkxx>
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_ga_t_jxw_czrkxx");
+//        return s.equals("digital_hky") && s1.equals("o_t_ga_t_jxw_czrkxx");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTGxjCydnJiyueMapDikuaiEvent.java

@@ -32,6 +32,7 @@ public class OTGxjCydnJiyueMapDikuaiEvent implements IBinlogEventHandler<OTGxjCy
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_gxj_cydn_jiyue_map_dikuai");
+//        return s.equals("digital_hky") && s1.equals("o_t_gxj_cydn_jiyue_map_dikuai");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTSthjTAirCityHourForecastEvent.java

@@ -32,6 +32,7 @@ public class OTSthjTAirCityHourForecastEvent implements IBinlogEventHandler<OTSt
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_air_city_hour_forecast");
+//        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_air_city_hour_forecast");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTSthjTAirStationBaseinfoEvent.java

@@ -32,6 +32,7 @@ public class OTSthjTAirStationBaseinfoEvent implements IBinlogEventHandler<OTSth
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_air_station_baseinfo");
+//        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_air_station_baseinfo");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTSthjTAirStationDayZhEvent.java

@@ -32,6 +32,7 @@ public class OTSthjTAirStationDayZhEvent implements IBinlogEventHandler<OTSthjTA
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_air_station_day_zh");
+//        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_air_station_day_zh");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTSthjTAirStationHourZhEvent.java

@@ -32,6 +32,7 @@ public class OTSthjTAirStationHourZhEvent implements IBinlogEventHandler<OTSthjT
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_air_station_hour_zh");
+//        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_air_station_hour_zh");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTSthjTWaterStationBaseinfoEvent.java

@@ -32,6 +32,7 @@ public class OTSthjTWaterStationBaseinfoEvent implements IBinlogEventHandler<OTS
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_water_station_baseinfo");
+//        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_water_station_baseinfo");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTSthjTWaterStationDayZhEvent.java

@@ -32,6 +32,7 @@ public class OTSthjTWaterStationDayZhEvent implements IBinlogEventHandler<OTSthj
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_water_station_day_zh");
+//        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_water_station_day_zh");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTSthjTWaterStationHourZhEvent.java

@@ -32,6 +32,7 @@ public class OTSthjTWaterStationHourZhEvent implements IBinlogEventHandler<OTSth
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_water_station_hour_zh");
+//        return s.equals("digital_hky") && s1.equals("o_t_sthj_t_water_station_hour_zh");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTSyrkEvent.java

@@ -32,6 +32,7 @@ public class OTSyrkEvent implements IBinlogEventHandler<OTSyrk> {
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_syrk");
+//        return s.equals("digital_hky") && s1.equals("o_t_syrk");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTWghsjTRyjcxxbEvent.java

@@ -32,6 +32,7 @@ public class OTWghsjTRyjcxxbEvent implements IBinlogEventHandler<OTWghsjTRyjcxxb
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_wghsj_t_ryjcxxb");
+//        return s.equals("digital_hky") && s1.equals("o_t_wghsj_t_ryjcxxb");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/OTYqydEnterpriseEvent.java

@@ -32,6 +32,7 @@ public class OTYqydEnterpriseEvent implements IBinlogEventHandler<OTYqydEnterpri
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("o_t_yqyd_enterprise");
+//        return s.equals("digital_hky") && s1.equals("o_t_yqyd_enterprise");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/PartyDictEvent.java

@@ -32,6 +32,7 @@ public class PartyDictEvent implements IBinlogEventHandler<PartyDict> {
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("party_dict");
+//        return s.equals("digital_hky") && s1.equals("party_dict");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/PartyMemberEvent.java

@@ -32,6 +32,7 @@ public class PartyMemberEvent implements IBinlogEventHandler<PartyMember> {
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("party_member");
+//        return s.equals("digital_hky") && s1.equals("party_member");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/PartyOrganizationEvent.java

@@ -32,6 +32,7 @@ public class PartyOrganizationEvent implements IBinlogEventHandler<PartyOrganiza
 
     @Override
     public boolean isHandle(String s, String s1) {
-        return s.equals("digital_hky") && s1.equals("party_organization");
+//        return s.equals("digital_hky") && s1.equals("party_organization");
+        return false;
     }
 }

src/main/java/com/eazytec/hkydatabasessynchronization/event/TProjectEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class TProjectEvent implements IBinlogEventHandler<TProject> {
 
@@ -17,7 +19,15 @@ public class TProjectEvent implements IBinlogEventHandler<TProject> {
 
     @Override
     public void onInsert(BinlogEvent<TProject> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        TProject data = binlogEvent.getData();
+        TProject tProject = mapper.selectById(data.getId());
+        if (Objects.isNull(tProject)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(tProject.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/TProjectJgEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class TProjectJgEvent implements IBinlogEventHandler<TProjectJg> {
 
@@ -17,7 +19,15 @@ public class TProjectJgEvent implements IBinlogEventHandler<TProjectJg> {
 
     @Override
     public void onInsert(BinlogEvent<TProjectJg> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        TProjectJg data = binlogEvent.getData();
+        TProjectJg tProjectJg = mapper.selectById(data.getId());
+        if (Objects.isNull(tProjectJg)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(tProjectJg.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/TProjectNjEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class TProjectNjEvent implements IBinlogEventHandler<TProjectNj> {
 
@@ -17,7 +19,15 @@ public class TProjectNjEvent implements IBinlogEventHandler<TProjectNj> {
 
     @Override
     public void onInsert(BinlogEvent<TProjectNj> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        TProjectNj data = binlogEvent.getData();
+        TProjectNj tProjectNj = mapper.selectById(data.getId());
+        if (Objects.isNull(tProjectNj)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(tProjectNj.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/TProjectScheduleEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class TProjectScheduleEvent implements IBinlogEventHandler<TProjectSchedule> {
 
@@ -17,7 +19,15 @@ public class TProjectScheduleEvent implements IBinlogEventHandler<TProjectSchedu
 
     @Override
     public void onInsert(BinlogEvent<TProjectSchedule> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        TProjectSchedule data = binlogEvent.getData();
+        TProjectSchedule tProjectSchedule = mapper.selectById(data.getId());
+        if (Objects.isNull(tProjectSchedule)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(tProjectSchedule.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/java/com/eazytec/hkydatabasessynchronization/event/TProjectZjEvent.java

@@ -6,6 +6,8 @@ import com.gitee.Jmysy.binlog4j.core.BinlogEvent;
 import com.gitee.Jmysy.binlog4j.core.IBinlogEventHandler;
 import jakarta.inject.Singleton;
 
+import java.util.Objects;
+
 @Singleton
 public class TProjectZjEvent implements IBinlogEventHandler<TProjectZj> {
 
@@ -17,7 +19,15 @@ public class TProjectZjEvent implements IBinlogEventHandler<TProjectZj> {
 
     @Override
     public void onInsert(BinlogEvent<TProjectZj> binlogEvent) {
-        mapper.insert(binlogEvent.getData());
+        TProjectZj data = binlogEvent.getData();
+        TProjectZj tProjectZj = mapper.selectById(data.getId());
+        if (Objects.isNull(tProjectZj)) {
+            mapper.insert(data);
+        } else {
+            if (Objects.isNull(tProjectZj.getEditStatus())) {
+                mapper.updateById(data);
+            }
+        }
     }
 
     @Override

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/EnterpriseBaseInfoMapper.xml

@@ -140,6 +140,7 @@
     <result column="legal_representative_age" jdbcType="VARCHAR" property="legalRepresentativeAge"/>
     <result column="enterprise_credit_grade" jdbcType="VARCHAR" property="enterpriseCreditGrade"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="com.eazytec.hkydatabasessynchronization.entity.EnterpriseBaseInfo">
     <result column="business_range" jdbcType="LONGVARCHAR" property="businessRange"/>
@@ -164,7 +165,7 @@
 	employ_tech_service_org, danger_chemical_level, safety_product_standard_level, key_regulatory_area, enterprise_level, move_supervise, move_supervise_reason, 
 	register_safety_engineer_num, safety_product_standard_explain, safety_manage_dept_name, declarant, declarant_phone, approvel_time, approvel_result, 
 	medicine_industry, fireworks_industry, chemical_industry, supervise_dept, video_monitor, sensor_monitor, city_supervision, 
-	legal_representative_gender, legal_representative_age, enterprise_credit_grade, odm_rksj
+	legal_representative_gender, legal_representative_age, enterprise_credit_grade, odm_rksj, edit_status
   </sql>
   <sql id="Blob_Column_List">
     business_range

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/EnterpriseRescueMaterialMapper.xml

@@ -25,11 +25,12 @@
     <result column="data_version" jdbcType="VARCHAR" property="dataVersion"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
     <result column="material_name" jdbcType="VARCHAR" property="materialName"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     enterprise_emergency_rescue_material_id, enterprise_id, enterprise_name, material_model, material_number, material_type, main_charge_person, 
 	charge_person_mobile, buy_date, manufacture_factory, expire_time, status, main_application, store_address, 
 	remark, gmt_created, search_title, data_source_id, gmt_modified, data_version, odm_rksj, 
-	material_name
+	material_name, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/EnterpriseRescueTeamMapper.xml

@@ -25,11 +25,12 @@
     <result column="data_version" jdbcType="VARCHAR" property="dataVersion"/>
     <result column="search_title" jdbcType="VARCHAR" property="searchTitle"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     enterprise_emergency_rescue_team_id, enterprise_name, team_name, full_or_part_time, dept, team_property, team_level, 
 	expert_accident_type, address, main_contact, contact_mobile, team_persons, remark, gmt_created, 
 	enterprise_id, found_date, service_area, data_source_id, gmt_modified, data_version, search_title, 
-	odm_rksj
+	odm_rksj, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/EnterpriseTestReportMapper.xml

@@ -18,10 +18,11 @@
     <result column="gmt_modified" jdbcType="TIMESTAMP" property="gmtModified"/>
     <result column="data_version" jdbcType="VARCHAR" property="dataVersion"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     enterprise_risk_partition_id, enterprise_id, enterprise_name, risk_photo_name, risk_photo_type, assessment_time, reevaluation_time, 
 	assessor, gmt_created, search_title, risk_photo, data_source_id, gmt_modified, data_version, 
-	odm_rksj
+	odm_rksj, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/OTEmerspsSpsEnterpriseHazardousChemicalsMapper.xml

@@ -28,11 +28,12 @@
     <result column="main_safe_risk" jdbcType="VARCHAR" property="mainSafeRisk"/>
     <result column="hazardous_chemical_kind" jdbcType="VARCHAR" property="hazardousChemicalKind"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     enterprise_hazardous_chemicals_id, enterprise_id, enterprise_name, hazardous_chemicals_name, hazardous_chemicals_alias, cas_no, specifications, 
 	purpose, category, inventory, maximum_reserves, storage_method, major_hazard, hazardous_waste, 
 	warehouse_name, data_source_id, gmt_created, gmt_modified, data_version, search_title, reserves_unit, 
-	hazard_level, main_safe_risk, hazardous_chemical_kind, odm_rksj
+	hazard_level, main_safe_risk, hazardous_chemical_kind, odm_rksj, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/OTEmerspsSpsEnterpriseHistoryHiddenTroubleMapper.xml

@@ -19,6 +19,7 @@
     <result column="hidden_trouble_source" jdbcType="VARCHAR" property="hiddenTroubleSource"/>
     <result column="co_area" jdbcType="VARCHAR" property="coArea"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="com.eazytec.hkydatabasessynchronization.entity.OTEmerspsSpsEnterpriseHistoryHiddenTrouble">
     <result column="hidden_trouble_content" jdbcType="LONGVARCHAR" property="hiddenTroubleContent"/>
@@ -28,7 +29,7 @@
   <sql id="Base_Column_List">
     enterprise_history_hidden_trouble_id, enterprise_id, enterprise_name, check_unit, check_person, check_time, hidden_trouble_factors, 
 	hidden_trouble_level, hidden_trouble_status, data_source_id, gmt_created, gmt_modified, data_version, hidden_trouble_source, 
-	co_area, odm_rksj
+	co_area, odm_rksj, edit_status
   </sql>
   <sql id="Blob_Column_List">
     hidden_trouble_content, hidden_trouble_describe, search_title

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/OTEmerspsSpsEnterpriseLeakPointMapper.xml

@@ -23,10 +23,11 @@
     <result column="data_version" jdbcType="VARCHAR" property="dataVersion"/>
     <result column="search_title" jdbcType="VARCHAR" property="searchTitle"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     enterprise_leak_point_id, enterprise_id, enterprise_name, enterprise_abbreviation, enterprise_unified_credit_code, leak_point_name, leak_point_code, 
 	major_hazard_sources, longitude, latitude, run_status, associated_video, creater, updater, 
-	data_source_id, gmt_created, gmt_modified, data_version, search_title, odm_rksj
+	data_source_id, gmt_created, gmt_modified, data_version, search_title, odm_rksj, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/OTEmerspsSpsEnterpriseRealtimeAlarmRecordMapper.xml

@@ -13,9 +13,10 @@
     <result column="unit" jdbcType="VARCHAR" property="unit"/>
     <result column="alarm_time" jdbcType="TIMESTAMP" property="alarmTime"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     enterprise_realtime_alarm_record_id, enterprise_id, device_id, device_name, monitoring_type, alarm_content, monitoring_value, 
-	unit, alarm_time, odm_rksj
+	unit, alarm_time, odm_rksj, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/OTEmerspsSpsEnterpriseSpecialOperationPersonMapper.xml

@@ -24,10 +24,11 @@
     <result column="approved_date" jdbcType="TIMESTAMP" property="approvedDate"/>
     <result column="date_of_certification" jdbcType="TIMESTAMP" property="dateOfCertification"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     enterprise_special_operation_person_id, enterprise_id, operation_type, name, gender, training_type, type_of_certificate, 
 	id_number, job_category, training_institution, first_date, validity_begin, validity_end, enterprise_name, 
-	data_source_id, gmt_created, gmt_modified, data_version, approved_date, date_of_certification, odm_rksj
+	data_source_id, gmt_created, gmt_modified, data_version, approved_date, date_of_certification, odm_rksj, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/TProjectJgMapper.xml

@@ -23,10 +23,11 @@
     <result column="xssr" jdbcType="VARCHAR" property="xssr"/>
     <result column="ydl" jdbcType="VARCHAR" property="ydl"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     id, create_date, creater, delete_date, deleter, update_date, updater, 
 	remark, sort, sts, record_code, complete_invest, end, sssr, 
-	start, tqsssr, tqxssr, xssr, ydl, odm_rksj
+	start, tqsssr, tqxssr, xssr, ydl, odm_rksj, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/TProjectMapper.xml

@@ -26,11 +26,12 @@
     <result column="record_date" jdbcType="TIMESTAMP" property="recordDate"/>
     <result column="stage" jdbcType="INTEGER" property="stage"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     id, create_date, creater, delete_date, deleter, update_date, updater, 
 	remark, sort, sts, area_id, company_name, description, great, 
 	invest, map_addr, mode, project_addr, project_name, record_code, record_date, 
-	stage, odm_rksj
+	stage, odm_rksj, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/TProjectNjMapper.xml

@@ -25,11 +25,12 @@
     <result column="ydps_sts" jdbcType="INTEGER" property="ydpsSts"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
     <result column="tdgzp_sts" jdbcType="INTEGER" property="tdgzpSts"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     id, create_date, creater, delete_date, deleter, update_date, updater, 
 	remark, sort, sts, ap_sts, hp_sts, jsgcghxkz_sts, jsydghxkz_sts, 
 	np_sts, plan_end, plan_start, record_code, sgxkz_sts, ydps_sts, odm_rksj,
-	tdgzp_sts
+	tdgzp_sts, edit_status
   </sql>
 </mapper>

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/TProjectScheduleMapper.xml

@@ -17,13 +17,14 @@
     <result column="staff_name" jdbcType="VARCHAR" property="staffName"/>
     <result column="record_code" jdbcType="VARCHAR" property="recordCode"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="com.eazytec.hkydatabasessynchronization.entity.TProjectSchedule">
     <result column="schedule_desc" jdbcType="LONGVARCHAR" property="scheduleDesc"/>
   </resultMap>
   <sql id="Base_Column_List">
     id, create_date, creater, delete_date, deleter, update_date, updater, 
-	remark, sort, sts, schedule_date, staff_name, record_code, odm_rksj
+	remark, sort, sts, schedule_date, staff_name, record_code, odm_rksj, edit_status
   </sql>
   <sql id="Blob_Column_List">
     schedule_desc

src/main/resources/com.eazytec.hkydatabasessynchronization/mapper/TProjectZjMapper.xml

@@ -19,10 +19,11 @@
     <result column="record_code" jdbcType="VARCHAR" property="recordCode"/>
     <result column="start" jdbcType="TIMESTAMP" property="start"/>
     <result column="odm_rksj" jdbcType="TIMESTAMP" property="odmRksj"/>
+    <result column="edit_status" jdbcType="INTEGER" property="editStatus"/>
   </resultMap>
   <sql id="Base_Column_List">
     id, create_date, creater, delete_date, deleter, update_date, updater, 
 	remark, sort, sts, complete_invest, in_storage, plan_end, record_code, 
-	start, odm_rksj
+	start, odm_rksj, edit_status
   </sql>
 </mapper>