update

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

@@ -3,7 +3,9 @@ package com.eazytec.hkydatabasessynchronization.entity;
 import java.io.Serializable;
 import java.util.Date;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 
 /**
@@ -55,6 +57,7 @@ public class OTBaseAjqy implements Serializable {
 
     private String cfqkJg;
 
+    @TableId(type = IdType.INPUT)
     private String idOld;
 
     private String cfqkCq;

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

@@ -3,7 +3,9 @@ package com.eazytec.hkydatabasessynchronization.entity;
 import java.io.Serializable;
 import java.util.Date;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 
 /**
@@ -17,6 +19,7 @@ public class OTEmerspsSpsEnterpriseMajorHazard implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
+    @TableId(type = IdType.INPUT)
     private String enterpriseMajorHazardId;
 
     private String enterpriseId;

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

@@ -3,7 +3,9 @@ package com.eazytec.hkydatabasessynchronization.entity;
 import java.io.Serializable;
 import java.util.Date;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 
 /**
@@ -17,6 +19,7 @@ public class OTEmerspsSpsEnterpriseMaterialInfo implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
+    @TableId(type = IdType.INPUT)
     private String enterpriseMaterialInfoId;
 
     private String enterpriseId;

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

@@ -3,7 +3,9 @@ package com.eazytec.hkydatabasessynchronization.entity;
 import java.io.Serializable;
 import java.util.Date;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 
 /**
@@ -17,6 +19,7 @@ public class OTEmerspsSpsEnterpriseRiskIdentification implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
+    @TableId(type = IdType.INPUT)
     private String enterpriseRiskIdentificationId;
 
     private String enterpriseId;

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

 package com.eazytec.hkydatabasessynchronization.entity;
 
 import java.io.Serializable;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 
 /**
@@ -16,6 +19,7 @@ public class OTSyrk implements Serializable {
 
     private String mz;
 
+    @TableId(type = IdType.INPUT)
     private String sfz;
 
     private String jd;

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

@@ -4,7 +4,9 @@ import java.io.Serializable;
 import java.math.BigDecimal;
 import java.util.Date;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 
 /**
@@ -18,6 +20,7 @@ public class OTYqydEnterprise implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
+    @TableId(type = IdType.INPUT)
     private String eid;
 
     private Long id;

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

@@ -2,6 +2,9 @@ package com.eazytec.hkydatabasessynchronization.entity;
 
 import java.io.Serializable;
 import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 
 /**
@@ -19,6 +22,7 @@ public class PartyMember implements Serializable {
 
     private String xb;
 
+    @TableId(type = IdType.INPUT)
     private String sfzh;
 
     private String csrq;

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

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