同步标志

airport-common/src/main/java/com/sundot/airport/common/enums/LedgerSyncFlagEnum.java

@@ -0,0 +1,28 @@
+package com.sundot.airport.common.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * 台账同步标志枚举
+ */
+@Getter
+@AllArgsConstructor
+public enum LedgerSyncFlagEnum {
+
+    ZERO("0", "未同步"),
+    ONE("1", "已同步");
+
+    private final String code;
+    private final String desc;
+
+    public static LedgerSyncFlagEnum getByCode(String code) {
+        for (LedgerSyncFlagEnum itemEnum : values()) {
+            if (itemEnum.getCode().equals(code)) {
+                return itemEnum;
+            }
+        }
+        return null;
+    }
+
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerBannerLetter.java

@@ -53,6 +53,9 @@ public class LedgerBannerLetter extends BaseEntity {
     @Excel(name = "备注")
     private String remark;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -88,4 +91,7 @@ public class LedgerBannerLetter extends BaseEntity {
 
     public String getRemark() { return remark; }
     public void setRemark(String remark) { this.remark = remark; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerChannelPassRate.java

@@ -50,6 +50,9 @@ public class LedgerChannelPassRate extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -82,4 +85,7 @@ public class LedgerChannelPassRate extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerComplaint.java

@@ -62,6 +62,9 @@ public class LedgerComplaint extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -106,4 +109,7 @@ public class LedgerComplaint extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerDailyTraining.java

@@ -55,6 +55,9 @@ public class LedgerDailyTraining extends BaseEntity {
     private String importBatch;
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -99,4 +102,7 @@ public class LedgerDailyTraining extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerDormFireSafety.java

@@ -54,6 +54,9 @@ public class LedgerDormFireSafety extends BaseEntity {
     private String importBatch;
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -95,4 +98,7 @@ public class LedgerDormFireSafety extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerExamScore.java

@@ -56,6 +56,9 @@ public class LedgerExamScore extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -94,4 +97,7 @@ public class LedgerExamScore extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerHealthSoldier.java

@@ -57,6 +57,9 @@ public class LedgerHealthSoldier extends BaseEntity {
     private String importBatch;
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -128,4 +131,7 @@ public class LedgerHealthSoldier extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerLeaderDuty.java

@@ -34,6 +34,9 @@ public class LedgerLeaderDuty extends BaseEntity {
     private String importBatch;
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -60,4 +63,7 @@ public class LedgerLeaderDuty extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerLeaveSpecial.java

@@ -51,6 +51,9 @@ public class LedgerLeaveSpecial extends BaseEntity {
     @Excel(name = "备注")
     private String remark;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -83,4 +86,7 @@ public class LedgerLeaveSpecial extends BaseEntity {
 
     public String getRemark() { return remark; }
     public void setRemark(String remark) { this.remark = remark; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerPatrolInspection.java

@@ -77,6 +77,9 @@ public class LedgerPatrolInspection extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -136,4 +139,7 @@ public class LedgerPatrolInspection extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerRealtimeInterception.java

@@ -170,6 +170,9 @@ public class LedgerRealtimeInterception extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -328,4 +331,7 @@ public class LedgerRealtimeInterception extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerRewardApproval.java

@@ -50,6 +50,9 @@ public class LedgerRewardApproval extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -82,4 +85,7 @@ public class LedgerRewardApproval extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerRewardPenalty.java

@@ -53,6 +53,9 @@ public class LedgerRewardPenalty extends BaseEntity {
     @Excel(name = "备注")
     private String remark;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -88,4 +91,7 @@ public class LedgerRewardPenalty extends BaseEntity {
 
     public String getRemark() { return remark; }
     public void setRemark(String remark) { this.remark = remark; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerSecurityTest.java

@@ -118,6 +118,9 @@ public class LedgerSecurityTest extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -225,4 +228,7 @@ public class LedgerSecurityTest extends BaseEntity {
 
     public String getTeamLeader() { return teamLeader; }
     public void setTeamLeader(String teamLeader) { this.teamLeader = teamLeader; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerSeizureStats.java

@@ -137,6 +137,9 @@ public class LedgerSeizureStats extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -262,4 +265,7 @@ public class LedgerSeizureStats extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerServicePatrol.java

@@ -74,6 +74,9 @@ public class LedgerServicePatrol extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -130,4 +133,7 @@ public class LedgerServicePatrol extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerSupervisionProblem.java

@@ -138,6 +138,9 @@ public class LedgerSupervisionProblem extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -263,4 +266,7 @@ public class LedgerSupervisionProblem extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerTerminalBonus.java

@@ -50,6 +50,9 @@ public class LedgerTerminalBonus extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -82,4 +85,7 @@ public class LedgerTerminalBonus extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerTrainingIssue.java

@@ -40,6 +40,9 @@ public class LedgerTrainingIssue extends BaseEntity {
     private String importBatch;
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -69,4 +72,7 @@ public class LedgerTrainingIssue extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerUnsafeEvent.java

@@ -92,6 +92,9 @@ public class LedgerUnsafeEvent extends BaseEntity {
     @Excel(name = "数据来源")
     private String sourceType;
 
+    @Excel(name = "同步标志(0=未同步;1=已同步)")
+    private String syncFlag;
+
     public Long getId() { return id; }
     public void setId(Long id) { this.id = id; }
 
@@ -172,4 +175,7 @@ public class LedgerUnsafeEvent extends BaseEntity {
 
     public String getSourceType() { return sourceType; }
     public void setSourceType(String sourceType) { this.sourceType = sourceType; }
+
+    public String getSyncFlag() { return syncFlag; }
+    public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerBannerLetterMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerBannerLetter;
 
@@ -9,4 +10,6 @@ import com.sundot.airport.ledger.domain.LedgerBannerLetter;
  */
 public interface LedgerBannerLetterMapper extends BaseMapper<LedgerBannerLetter> {
     List<LedgerBannerLetter> selectList(LedgerBannerLetter query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerChannelPassRateMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerChannelPassRate;
 
@@ -9,4 +10,6 @@ import com.sundot.airport.ledger.domain.LedgerChannelPassRate;
  */
 public interface LedgerChannelPassRateMapper extends BaseMapper<LedgerChannelPassRate> {
     List<LedgerChannelPassRate> selectList(LedgerChannelPassRate query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerComplaintMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerComplaint;
 
@@ -9,4 +10,6 @@ import com.sundot.airport.ledger.domain.LedgerComplaint;
  */
 public interface LedgerComplaintMapper extends BaseMapper<LedgerComplaint> {
     List<LedgerComplaint> selectList(LedgerComplaint query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerDailyTrainingMapper.java

@@ -1,9 +1,12 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerDailyTraining;
 
 public interface LedgerDailyTrainingMapper extends BaseMapper<LedgerDailyTraining> {
     List<LedgerDailyTraining> selectList(LedgerDailyTraining query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerDormFireSafetyMapper.java

@@ -1,9 +1,12 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerDormFireSafety;
 
 public interface LedgerDormFireSafetyMapper extends BaseMapper<LedgerDormFireSafety> {
     List<LedgerDormFireSafety> selectList(LedgerDormFireSafety query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerExamScoreMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerExamScore;
 
@@ -9,4 +10,6 @@ import com.sundot.airport.ledger.domain.LedgerExamScore;
  */
 public interface LedgerExamScoreMapper extends BaseMapper<LedgerExamScore> {
     List<LedgerExamScore> selectList(LedgerExamScore query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerHealthSoldierMapper.java

@@ -1,9 +1,12 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerHealthSoldier;
 
 public interface LedgerHealthSoldierMapper extends BaseMapper<LedgerHealthSoldier> {
     List<LedgerHealthSoldier> selectList(LedgerHealthSoldier query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerLeaderDutyMapper.java

@@ -1,9 +1,12 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerLeaderDuty;
 
 public interface LedgerLeaderDutyMapper extends BaseMapper<LedgerLeaderDuty> {
     List<LedgerLeaderDuty> selectList(LedgerLeaderDuty query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerLeaveSpecialMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerLeaveSpecial;
 
@@ -9,4 +10,6 @@ import com.sundot.airport.ledger.domain.LedgerLeaveSpecial;
  */
 public interface LedgerLeaveSpecialMapper extends BaseMapper<LedgerLeaveSpecial> {
     List<LedgerLeaveSpecial> selectList(LedgerLeaveSpecial query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerPatrolInspectionMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerPatrolInspection;
 import org.apache.ibatis.annotations.Param;
@@ -10,7 +11,9 @@ import org.apache.ibatis.annotations.Param;
  */
 public interface LedgerPatrolInspectionMapper extends BaseMapper<LedgerPatrolInspection> {
     List<LedgerPatrolInspection> selectList(LedgerPatrolInspection query);
-    
+
+    int updateSyncFlag();
+
     /**
      * 根据被查人姓名和时间范围统计三级质控巡查次数
      * @param inspectedName 被查人姓名
@@ -18,7 +21,7 @@ public interface LedgerPatrolInspectionMapper extends BaseMapper<LedgerPatrolIns
      * @param endTime 结束时间
      * @return 巡查次数
      */
-    int countByInspectedNameAndDateRange(@Param("inspectedName") String inspectedName, 
-                                         @Param("beginTime") String beginTime, 
+    int countByInspectedNameAndDateRange(@Param("inspectedName") String inspectedName,
+                                         @Param("beginTime") String beginTime,
                                          @Param("endTime") String endTime);
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerRealtimeInterceptionMapper.java

@@ -13,5 +13,7 @@ import com.sundot.airport.ledger.domain.LedgerRealtimeInterception;
 public interface LedgerRealtimeInterceptionMapper extends BaseMapper<LedgerRealtimeInterception> {
     List<LedgerRealtimeInterception> selectList(LedgerRealtimeInterception query);
 
+    int updateSyncFlag();
+
     List<LedgerCommonResVO> realtimeInterceptionItem(LedgerCommonQueryReqVO query);
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerRewardApprovalMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerRewardApproval;
 
@@ -9,4 +10,6 @@ import com.sundot.airport.ledger.domain.LedgerRewardApproval;
  */
 public interface LedgerRewardApprovalMapper extends BaseMapper<LedgerRewardApproval> {
     List<LedgerRewardApproval> selectList(LedgerRewardApproval query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerRewardPenaltyMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerRewardPenalty;
 
@@ -9,4 +10,6 @@ import com.sundot.airport.ledger.domain.LedgerRewardPenalty;
  */
 public interface LedgerRewardPenaltyMapper extends BaseMapper<LedgerRewardPenalty> {
     List<LedgerRewardPenalty> selectList(LedgerRewardPenalty query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerSecurityTestMapper.java

@@ -13,6 +13,8 @@ import com.sundot.airport.common.dto.LedgerCommonResVO;
 public interface LedgerSecurityTestMapper extends BaseMapper<LedgerSecurityTest> {
     List<LedgerSecurityTest> selectList(LedgerSecurityTest query);
 
+    int updateSyncFlag();
+
     List<LedgerCommonResVO> securityTestItemClassification(LedgerCommonQueryReqVO queryReq);
 
     List<LedgerCommonResVO> securityTestPassingStatus(LedgerCommonQueryReqVO queryReq);

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerSeizureStatsMapper.java

@@ -18,6 +18,8 @@ import org.apache.ibatis.annotations.Param;
 public interface LedgerSeizureStatsMapper extends BaseMapper<LedgerSeizureStats> {
     List<LedgerSeizureStats> selectList(LedgerSeizureStats query);
 
+    int updateSyncFlag();
+
     int countByInspectorAndDateRange(@Param("inspectorName") String inspectorName,
                                      @Param("beginTime") String beginTime,
                                      @Param("endTime") String endTime);

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerServicePatrolMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerServicePatrol;
 
@@ -9,4 +10,6 @@ import com.sundot.airport.ledger.domain.LedgerServicePatrol;
  */
 public interface LedgerServicePatrolMapper extends BaseMapper<LedgerServicePatrol> {
     List<LedgerServicePatrol> selectList(LedgerServicePatrol query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerSupervisionProblemMapper.java

@@ -14,4 +14,6 @@ public interface LedgerSupervisionProblemMapper extends BaseMapper<LedgerSupervi
     List<LedgerSupervisionProblem> selectList(LedgerSupervisionProblem query);
 
     List<LedgerCommonResVO> supervisionProblemPosition(LedgerCommonQueryReqVO query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerTerminalBonusMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerTerminalBonus;
 
@@ -9,4 +10,6 @@ import com.sundot.airport.ledger.domain.LedgerTerminalBonus;
  */
 public interface LedgerTerminalBonusMapper extends BaseMapper<LedgerTerminalBonus> {
     List<LedgerTerminalBonus> selectList(LedgerTerminalBonus query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerTrainingIssueMapper.java

@@ -1,9 +1,12 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerTrainingIssue;
 
 public interface LedgerTrainingIssueMapper extends BaseMapper<LedgerTrainingIssue> {
     List<LedgerTrainingIssue> selectList(LedgerTrainingIssue query);
+
+    int updateSyncFlag();
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerUnsafeEventMapper.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.mapper;
 
 import java.util.List;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.sundot.airport.ledger.domain.LedgerUnsafeEvent;
 import com.sundot.airport.ledger.domain.vo.CountQueryReqVO;
@@ -14,6 +15,8 @@ import com.sundot.airport.ledger.domain.vo.UnsafeTypeVO;
 public interface LedgerUnsafeEventMapper extends BaseMapper<LedgerUnsafeEvent> {
     List<LedgerUnsafeEvent> selectList(LedgerUnsafeEvent query);
 
+    int updateSyncFlag();
+
     /**
      * 功能描述：不安全事件物品分布
      *

airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/LedgerSyncServiceImpl.java

@@ -4,6 +4,7 @@ import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.sundot.airport.common.core.domain.entity.SysDept;
 import com.sundot.airport.common.core.domain.entity.SysUser;
+import com.sundot.airport.common.enums.LedgerSyncFlagEnum;
 import com.sundot.airport.common.utils.DateUtils;
 import com.sundot.airport.ledger.domain.*;
 import com.sundot.airport.ledger.mapper.*;
@@ -184,7 +185,9 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
 
     /** 1. 部门监察问题记录 → 安全防控能力/员工规范化操作（按问题层级区分L3） */
     private SyncResult syncSupervisionProblem() {
-        List<LedgerSupervisionProblem> list = supervisionMapper.selectList(new LedgerSupervisionProblem());
+        LedgerSupervisionProblem query = new LedgerSupervisionProblem();
+        query.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
+        List<LedgerSupervisionProblem> list = supervisionMapper.selectList(query);
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_SUPERVISION_L2);
         int ins = 0, skip = 0;
@@ -207,11 +210,14 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        supervisionMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 
     /** 2. 实时质控拦截 → 安全防控能力/后台实时质控拦截（按问题层级区分L3） */
     private SyncResult syncRealtimeInterception() {
+        LedgerRealtimeInterception query = new LedgerRealtimeInterception();
+        query.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
         List<LedgerRealtimeInterception> list = interceptionMapper.selectList(new LedgerRealtimeInterception());
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_INTERCEPT_L2);
@@ -242,12 +248,15 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        interceptionMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 
     /** 3. 安保测试（仅"未通过"才计分，按层级选L3，分值均为-0.5） */
     private SyncResult syncSecurityTest() {
-        List<LedgerSecurityTest> list = securityTestMapper.selectList(new LedgerSecurityTest());
+        LedgerSecurityTest query = new LedgerSecurityTest();
+        query.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
+        List<LedgerSecurityTest> list = securityTestMapper.selectList(query);
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_SECTEST_L2);
         int ins = 0, skip = 0;
@@ -270,12 +279,15 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        securityTestMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 
     /** 4. 不安全事件（按类别选L3和默认分值） */
     private SyncResult syncUnsafeEvent() {
-        List<LedgerUnsafeEvent> list = unsafeEventMapper.selectList(new LedgerUnsafeEvent());
+        LedgerUnsafeEvent query = new LedgerUnsafeEvent();
+        query.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
+        List<LedgerUnsafeEvent> list = unsafeEventMapper.selectList(query);
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_UNSAFE_L2);
         int ins = 0, skip = 0;
@@ -299,12 +311,15 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        unsafeEventMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 
     /** 5. 查获违规品统计（加分，按类别选L3） */
     private SyncResult syncSeizureStats() {
-        List<LedgerSeizureStats> list = seizureMapper.selectList(new LedgerSeizureStats());
+        LedgerSeizureStats query = new LedgerSeizureStats();
+        query.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
+        List<LedgerSeizureStats> list = seizureMapper.selectList(query);
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_SEIZURE_L2);
         int ins = 0, skip = 0;
@@ -326,12 +341,15 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        seizureMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 
     /** 6. 小额奖励审批单（安全类查获加分，按类别选L3） */
     private SyncResult syncRewardApproval() {
-        List<LedgerRewardApproval> list = rewardApprovalMapper.selectList(new LedgerRewardApproval());
+        LedgerRewardApproval query = new LedgerRewardApproval();
+        query.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
+        List<LedgerRewardApproval> list = rewardApprovalMapper.selectList(query);
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_SEIZURE_L2);
         int ins = 0, skip = 0;
@@ -352,12 +370,15 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        rewardApprovalMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 
     /** 7. 服务巡查 → 服务响应能力/服务监察（按问题层级区分L3） */
     private SyncResult syncServicePatrol() {
-        List<LedgerServicePatrol> list = servicePatrolMapper.selectList(new LedgerServicePatrol());
+        LedgerServicePatrol query = new LedgerServicePatrol();
+        query.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
+        List<LedgerServicePatrol> list = servicePatrolMapper.selectList(query);
         Long dimId = dimCache.get("服务响应能力");
         ScoreIndicator lv2 = getIndicator(IND_SVCPATROL_L2);
         int ins = 0, skip = 0;
@@ -379,12 +400,15 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        servicePatrolMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 
     /** 8. 投诉情况（有责任人才计分；旅客服务投诉为L2叶子节点，无L3） */
     private SyncResult syncComplaint() {
-        List<LedgerComplaint> list = complaintMapper.selectList(new LedgerComplaint());
+        LedgerComplaint quey = new LedgerComplaint();
+        quey.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
+        List<LedgerComplaint> list = complaintMapper.selectList(quey);
         Long dimId = dimCache.get("服务响应能力");
         ScoreIndicator lv2 = getIndicator(IND_COMPLAINT_L2);
         int ins = 0, skip = 0;
@@ -400,12 +424,15 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        complaintMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 
     /** 9. 航站楼加分 → 服务响应能力/典型服务案例/航站楼加分（分值取台账add_score） */
     private SyncResult syncTerminalBonus() {
-        List<LedgerTerminalBonus> list = terminalBonusMapper.selectList(new LedgerTerminalBonus());
+        LedgerTerminalBonus query = new LedgerTerminalBonus();
+        query.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
+        List<LedgerTerminalBonus> list = terminalBonusMapper.selectList(query);
         Long dimId = dimCache.get("服务响应能力");
         ScoreIndicator lv2 = getIndicator(IND_TYPCASE_L2);
         ScoreIndicator lv3 = getIndicator(IND_TYPCASE_L3);
@@ -422,12 +449,15 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        terminalBonusMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 
     /** 10. 成绩收集（≥98加5分；其余不计分，暂无台账规则） */
     private SyncResult syncExamScore() {
-        List<LedgerExamScore> list = examScoreMapper.selectList(new LedgerExamScore());
+        LedgerExamScore query = new LedgerExamScore();
+        query.setSyncFlag(LedgerSyncFlagEnum.ZERO.getCode());
+        List<LedgerExamScore> list = examScoreMapper.selectList(query);
         Long dimId = dimCache.get("业务实操能力");
         ScoreIndicator lv2 = getIndicator(IND_EXAM_L2);
         int ins = 0, skip = 0;
@@ -451,6 +481,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             scoreEventMapper.insert(e);
             ins++;
         }
+        examScoreMapper.updateSyncFlag();
         return new SyncResult(ins, skip, "");
     }
 

airport-ledger/src/main/resources/mapper/ledger/LedgerBannerLetterMapper.xml

@@ -18,10 +18,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, record_date,dept_name,team_name,person_name,person_user_id,type,giver,content_desc,add_score,evidence_file,remark, create_by, create_time, update_by, update_time
+        SELECT id, record_date,dept_name,team_name,person_name,person_user_id,type,giver,content_desc,add_score,evidence_file,remark, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_banner_letter
         WHERE del_flag = '0'
     </sql>
@@ -31,6 +32,7 @@
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="personName != null and personName != ''">AND person_name LIKE CONCAT('%', #{personName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -40,4 +42,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_banner_letter
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerChannelPassRateMapper.xml

@@ -17,10 +17,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, record_date,dept_name,team_name,channel_no,total_count,pass_count,pass_rate,remark,import_batch,source_type, create_by, create_time, update_by, update_time
+        SELECT id, record_date,dept_name,team_name,channel_no,total_count,pass_count,pass_rate,remark,import_batch,source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_channel_pass_rate
         WHERE del_flag = '0'
     </sql>
@@ -29,6 +30,7 @@
         <include refid="selectVo"/>
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -38,4 +40,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_channel_pass_rate
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerComplaintMapper.xml

@@ -21,10 +21,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, record_date,dept_name,team_name,responsible_name,flight_no,passenger_name,complaint_type,complaint_desc,result_handling,deduct_score,evidence_file,remark,import_batch,source_type, create_by, create_time, update_by, update_time
+        SELECT id, record_date,dept_name,team_name,responsible_name,flight_no,passenger_name,complaint_type,complaint_desc,result_handling,deduct_score,evidence_file,remark,import_batch,source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_complaint
         WHERE del_flag = '0'
     </sql>
@@ -33,6 +34,7 @@
         <include refid="selectVo"/>
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -42,4 +44,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_complaint
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerDailyTrainingMapper.xml

@@ -22,12 +22,13 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy" column="update_by" />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
         SELECT id, record_date, team_name, responsible_teacher, responsible_leader, hours,
                project_name, training_content, trainer, training_location, participant_count,
-               is_completed, remark, import_batch, source_type, create_by, create_time, update_by, update_time
+               is_completed, remark, import_batch, source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_daily_training
         WHERE del_flag = '0'
     </sql>
@@ -36,6 +37,7 @@
         <include refid="selectVo"/>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="projectName != null and projectName != ''">AND project_name LIKE CONCAT('%', #{projectName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND record_date &gt;= #{params.beginTime}
         </if>
@@ -45,4 +47,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_daily_training
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerDormFireSafetyMapper.xml

@@ -21,12 +21,13 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy" column="update_by" />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
         SELECT id, check_date, dorm_location, dorm_no, check_items, risk_status, found_risk,
                photos, rectify_person, rectify_time, submit_time, submitter,
-               import_batch, source_type, create_by, create_time, update_by, update_time
+               import_batch, source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_dorm_fire_safety
         WHERE del_flag = '0'
     </sql>
@@ -36,6 +37,7 @@
         <if test="dormLocation != null and dormLocation != ''">AND dorm_location LIKE CONCAT('%', #{dormLocation}, '%')</if>
         <if test="submitter != null and submitter != ''">AND submitter LIKE CONCAT('%', #{submitter}, '%')</if>
         <if test="dormNo != null and dormNo != ''">AND dorm_no LIKE CONCAT('%', #{dormNo}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND check_date &gt;= #{params.beginTime}
         </if>
@@ -45,4 +47,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_dorm_fire_safety
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerExamScoreMapper.xml

@@ -19,10 +19,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, exam_date, dept_name, team_name, group_name, person_name, exam_category, exam_period, theory_score, image_score, remark, import_batch, source_type, create_by, create_time, update_by, update_time
+        SELECT id, exam_date, dept_name, team_name, group_name, person_name, exam_category, exam_period, theory_score, image_score, remark, import_batch, source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_exam_score
         WHERE del_flag = '0'
     </sql>
@@ -31,6 +32,7 @@
         <include refid="selectVo"/>
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -40,4 +42,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_exam_score
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerHealthSoldierMapper.xml

@@ -31,6 +31,7 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy" column="update_by" />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
@@ -38,7 +39,7 @@
                major_disease_recent, daily_habits, mental_state, work_pressure, evidence_file,
                ext_major_disease, ext_exam_abnormal, ext_recent_symptoms, ext_chronic_mild, ext_chronic_severe,
                medical_history, ext_medical_history, submit_time, team_name, team_leader, sub_health_status,
-               import_batch, source_type, create_by, create_time, update_by, update_time
+               import_batch, source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_health_soldier
         WHERE del_flag = '0'
     </sql>
@@ -49,6 +50,7 @@
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="teamLeader != null and teamLeader != ''">AND team_leader LIKE CONCAT('%', #{teamLeader}, '%')</if>
         <if test="subHealthStatus != null and subHealthStatus != ''">AND sub_health_status LIKE CONCAT('%', #{subHealthStatus}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND submit_time &gt;= #{params.beginTime}
         </if>
@@ -58,4 +60,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_health_soldier
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerLeaderDutyMapper.xml

@@ -16,11 +16,12 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy" column="update_by" />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
         SELECT id, class_comment, problem_handling, work_tip, submitter, team_leader,
-               quality_officer, import_batch, source_type, create_by, create_time, update_by, update_time
+               quality_officer, import_batch, source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_leader_duty
         WHERE del_flag = '0'
     </sql>
@@ -29,6 +30,7 @@
         <include refid="selectVo"/>
         <if test="submitter != null and submitter != ''">AND submitter LIKE CONCAT('%', #{submitter}, '%')</if>
         <if test="teamLeader != null and teamLeader != ''">AND team_leader LIKE CONCAT('%', #{teamLeader}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND create_time &gt;= #{params.beginTime}
         </if>
@@ -38,4 +40,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_leader_duty
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerLeaveSpecialMapper.xml

@@ -17,10 +17,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, dept_name,team_name,person_name,person_user_id,leave_type,start_date,end_date,days,deduct_score,remark, create_by, create_time, update_by, update_time
+        SELECT id, dept_name,team_name,person_name,person_user_id,leave_type,start_date,end_date,days,deduct_score,remark, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_leave_special
         WHERE del_flag = '0'
     </sql>
@@ -30,6 +31,7 @@
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="personName != null and personName != ''">AND person_name LIKE CONCAT('%', #{personName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -39,4 +41,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_leave_special
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerPatrolInspectionMapper.xml

@@ -27,10 +27,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, record_date, dept_name, team_name, group_name, inspector_name, inspected_name, patrol_type, patrol_item, problem_desc, location, channel_no, result_handling, deduct_score, score_dimension, score_indicator, evidence_file, remark, import_batch, source_type, create_by, create_time, update_by, update_time
+        SELECT id, record_date, dept_name, team_name, group_name, inspector_name, inspected_name, patrol_type, patrol_item, problem_desc, location, channel_no, result_handling, deduct_score, score_dimension, score_indicator, evidence_file, remark, import_batch, source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_patrol_inspection
         WHERE del_flag = '0'
     </sql>
@@ -40,6 +41,7 @@
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="inspectorName != null and inspectorName != ''">AND inspector_name LIKE CONCAT('%', #{inspectorName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND record_date &gt;= #{params.beginTime}
         </if>
@@ -49,6 +51,12 @@
         ORDER BY record_date DESC, id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_patrol_inspection
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
+
     <select id="countByInspectedNameAndDateRange" resultType="int">
         SELECT COUNT(*)
         FROM ledger_patrol_inspection

airport-ledger/src/main/resources/mapper/ledger/LedgerRealtimeInterceptionMapper.xml

@@ -60,6 +60,7 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
@@ -72,7 +73,7 @@
                monthly_problem_count, last_month_problem_count, image_miss_difficulty, check_personnel,
                dept_training_instructor, manage_qc_manager, team_internal_duty, remark, team_leader,
                deduct_score, add_score, score_dimension, score_indicator, evidence_file, import_batch, source_type,
-               create_by, create_time, update_by, update_time
+               create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_realtime_interception
         WHERE del_flag = '0'
     </sql>
@@ -82,6 +83,7 @@
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="inspectorName != null and inspectorName != ''">AND inspector_name LIKE CONCAT('%', #{inspectorName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -91,6 +93,12 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_realtime_interception
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
+
     <select id="realtimeInterceptionItem"
             parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
             resultType="com.sundot.airport.common.dto.LedgerCommonResVO">

airport-ledger/src/main/resources/mapper/ledger/LedgerRewardApprovalMapper.xml

@@ -17,10 +17,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, approve_date,dept_name,team_name,person_name,reward_type,reward_amount,approval_status,remark,import_batch,source_type, create_by, create_time, update_by, update_time
+        SELECT id, approve_date,dept_name,team_name,person_name,reward_type,reward_amount,approval_status,remark,import_batch,source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_reward_approval
         WHERE del_flag = '0'
     </sql>
@@ -30,6 +31,7 @@
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="personName != null and personName != ''">AND person_name LIKE CONCAT('%', #{personName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -39,4 +41,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_reward_approval
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerRewardPenaltyMapper.xml

@@ -18,10 +18,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, record_date,dept_name,team_name,person_name,person_user_id,type,event_desc,score_change,score_dimension,evidence_file,remark, create_by, create_time, update_by, update_time
+        SELECT id, record_date,dept_name,team_name,person_name,person_user_id,type,event_desc,score_change,score_dimension,evidence_file,remark, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_reward_penalty
         WHERE del_flag = '0'
     </sql>
@@ -31,6 +32,7 @@
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="personName != null and personName != ''">AND person_name LIKE CONCAT('%', #{personName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -40,4 +42,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_reward_penalty
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerSecurityTestMapper.xml

@@ -43,6 +43,7 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
@@ -50,7 +51,7 @@
                tester_name, tester_id, tested_name, tested_id, test_type, position_id, test_item, test_result,
                problem_desc, result_handling, review_location_time, review_material, push_team_qc, push_qc_captain,
                team_internal_duty, push_to_relevant, team_leader, deduct_score, add_score, score_dimension,
-               score_indicator, evidence_file, remark, import_batch, source_type, create_by, create_time, update_by, update_time
+               score_indicator, evidence_file, remark, import_batch, source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_security_test
         WHERE del_flag = '0'
     </sql>
@@ -60,6 +61,7 @@
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="testedName != null and testedName != ''">AND tested_name LIKE CONCAT('%', #{testedName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -69,6 +71,12 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_security_test
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
+
     <select id="securityTestItemClassification"
             parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
             resultType="com.sundot.airport.common.dto.LedgerCommonResVO">

airport-ledger/src/main/resources/mapper/ledger/LedgerServicePatrolMapper.xml

@@ -25,10 +25,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, record_date,dept_name,team_name,group_name,inspector_name,inspected_name,service_type,problem_desc,location,result_handling,deduct_score,add_score,score_dimension,score_indicator,evidence_file,remark,import_batch,source_type, create_by, create_time, update_by, update_time
+        SELECT id, record_date,dept_name,team_name,group_name,inspector_name,inspected_name,service_type,problem_desc,location,result_handling,deduct_score,add_score,score_dimension,score_indicator,evidence_file,remark,import_batch,source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_service_patrol
         WHERE del_flag = '0'
     </sql>
@@ -38,6 +39,7 @@
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="inspectedName != null and inspectedName != ''">AND inspected_name LIKE CONCAT('%', #{inspectedName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -47,4 +49,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_service_patrol
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerSupervisionProblemMapper.xml

@@ -49,6 +49,7 @@
         <result property="createTime"       column="create_time"      />
         <result property="updateBy"         column="update_by"        />
         <result property="updateTime"       column="update_time"      />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
@@ -58,7 +59,7 @@
                rectification_status, evidence_material, send_to_relevant, monthly_problem_count, last_month_exceed_three,
                check_personnel, manage_qc_manager, input_time, dept_training_instructor, team_internal_duty, team_leader,
                deduct_score, add_score, score_dimension, score_indicator, evidence_file, remark,
-               import_batch, source_type, create_by, create_time, update_by, update_time
+               import_batch, source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_supervision_problem
         WHERE del_flag = '0'
     </sql>
@@ -69,6 +70,7 @@
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="inspectorName != null and inspectorName != ''">AND inspector_name LIKE CONCAT('%', #{inspectorName}, '%')</if>
         <if test="inspectedName != null and inspectedName != ''">AND inspected_name LIKE CONCAT('%', #{inspectedName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND record_date &gt;= #{params.beginTime}
         </if>
@@ -78,6 +80,12 @@
         ORDER BY record_date DESC, id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_supervision_problem
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
+
     <select id="supervisionProblemPosition"
             parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
             resultType="com.sundot.airport.common.dto.LedgerCommonResVO">

airport-ledger/src/main/resources/mapper/ledger/LedgerTerminalBonusMapper.xml

@@ -17,10 +17,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, approve_date,dept_name,team_name,person_name,bonus_type,add_score,evidence_file,remark,import_batch,source_type, create_by, create_time, update_by, update_time
+        SELECT id, approve_date,dept_name,team_name,person_name,bonus_type,add_score,evidence_file,remark,import_batch,source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_terminal_bonus
         WHERE del_flag = '0'
     </sql>
@@ -29,6 +30,7 @@
         <include refid="selectVo"/>
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -38,4 +40,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_terminal_bonus
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerTrainingIssueMapper.xml

@@ -17,12 +17,13 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy" column="update_by" />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
         SELECT id, record_date, ledger_content, specific_problem, handler, team_name,
                recheck_problem, is_rectified, import_batch, source_type,
-               create_by, create_time, update_by, update_time
+               create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_training_issue
         WHERE del_flag = '0'
     </sql>
@@ -32,6 +33,7 @@
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="handler != null and handler != ''">AND handler LIKE CONCAT('%', #{handler}, '%')</if>
         <if test="isRectified != null and isRectified != ''">AND is_rectified = #{isRectified}</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND record_date &gt;= #{params.beginTime}
         </if>
@@ -41,4 +43,9 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_training_issue
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
 </mapper>

airport-ledger/src/main/resources/mapper/ledger/LedgerUnsafeEventMapper.xml

@@ -34,10 +34,11 @@
         <result property="createTime" column="create_time" />
         <result property="updateBy"   column="update_by"   />
         <result property="updateTime" column="update_time" />
+        <result property="syncFlag" column="sync_flag" />
     </resultMap>
 
     <sql id="selectVo">
-        SELECT id, record_date, flight_no, dept_name, dept_id, team_name, team_internal_duty, team_id, group_name, group_id, responsible_name, responsible_id, event_type, involved_items, position, position_id, area, area_id, channel_no, image, event_desc, result_handling, deduct_score, evidence_file, remark, import_batch, source_type, create_by, create_time, update_by, update_time
+        SELECT id, record_date, flight_no, dept_name, dept_id, team_name, team_internal_duty, team_id, group_name, group_id, responsible_name, responsible_id, event_type, involved_items, position, position_id, area, area_id, channel_no, image, event_desc, result_handling, deduct_score, evidence_file, remark, import_batch, source_type, create_by, create_time, update_by, update_time, sync_flag
         FROM ledger_unsafe_event
         WHERE del_flag = '0'
     </sql>
@@ -47,6 +48,7 @@
         <if test="deptName != null and deptName != ''">AND dept_name LIKE CONCAT('%', #{deptName}, '%')</if>
         <if test="teamName != null and teamName != ''">AND team_name LIKE CONCAT('%', #{teamName}, '%')</if>
         <if test="responsibleName != null and responsibleName != ''">AND responsible_name LIKE CONCAT('%', #{responsibleName}, '%')</if>
+        <if test="syncFlag != null and syncFlag != ''">AND sync_flag = #{syncFlag}</if>
         <if test="params != null and params.beginTime != null and params.beginTime != ''">
             AND (record_date &gt;= #{params.beginTime} OR approve_date &gt;= #{params.beginTime} OR exam_date &gt;= #{params.beginTime})
         </if>
@@ -56,6 +58,12 @@
         ORDER BY id DESC
     </select>
 
+    <update id="updateSyncFlag">
+        update ledger_unsafe_event
+        set sync_flag = '1'
+        where sync_flag = '0'
+    </update>
+
     <select id="countSeizureStatsItem" parameterType="com.sundot.airport.ledger.domain.vo.CountQueryReqVO" resultType="com.sundot.airport.ledger.domain.vo.UnsafeItemVO">
         SELECT involved_items AS itemName, COUNT(*) AS itemNum
         FROM ledger_unsafe_event