diff --git a/shuili-admin/src/main/java/com/kms/web/synchronous/YgSynchronous.java b/shuili-admin/src/main/java/com/kms/web/synchronous/YgSynchronous.java
index 67ac1033..f6265fee 100644
--- a/shuili-admin/src/main/java/com/kms/web/synchronous/YgSynchronous.java
+++ b/shuili-admin/src/main/java/com/kms/web/synchronous/YgSynchronous.java
@@ -22,14 +22,8 @@ import com.kms.yg.sk.domain.AttResBase;
 import com.kms.yg.sk.domain.AttResRspp;
 import com.kms.yg.sk.service.AttResBaseService;
 import com.kms.yg.sk.service.AttResRsppService;
-import com.kms.yg.sz.domain.BsSgcSzCxjl;
-import com.kms.yg.sz.domain.BsSgcSzGcjg;
-import com.kms.yg.sz.domain.BsSgcSzSafeJbxx;
-import com.kms.yg.sz.domain.BsSgcSzSwtz;
-import com.kms.yg.sz.service.BsSgcSzCxjlService;
-import com.kms.yg.sz.service.BsSgcSzGcjgService;
-import com.kms.yg.sz.service.BsSgcSzSafeJbxxService;
-import com.kms.yg.sz.service.BsSgcSzSwtzService;
+import com.kms.yg.sz.domain.*;
+import com.kms.yg.sz.service.*;
 import com.kms.yg.xgxd.domain.AttDpdsBase;
 import com.kms.yg.xgxd.service.AttDpdsBaseService;
 import com.shuili.common.utils.password.MD5Util;
@@ -398,13 +392,18 @@ public class YgSynchronous {
      * 水闸编码
      */
     @GetMapping("dawc")
-    @Scheduled(cron = "0 0 0 * * ?")
+    @Scheduled(initialDelay = 0, fixedRate = Long.MAX_VALUE)
     public void dawc(){
         int pageNum = 1;
-        int pageSize = 99999;
+        int pageSize = 99999999;
         String s = sendRequest( dawc+ "?pageNum=" + pageNum + "&pageSize=" + pageSize);
         String data = JSONObject.parseObject(s).getString("data");
-
+        List<AttWagaCode> codeList = JSONObject.parseArray(data, AttWagaCode.class);
+        for (AttWagaCode attWagaCode : codeList) {
+            attWagaCode.preInsert();
+            attWagaCode.setId(attWagaCode.getWagaCode());
+            attWagaCodeService.saveOrUpdate(attWagaCode);
+        }
     }
 
     @Autowired
@@ -417,6 +416,8 @@ public class YgSynchronous {
     BsSgcDfJyjlService bsSgcDfJyjlService;
     @Autowired
     BsSgcDfGcxyService bsSgcDfGcxyService;
+    @Autowired
+    AttWagaCodeService attWagaCodeService;
 
     /**
      * 水闸水文特征
diff --git a/shuili-system/src/main/java/com/kms/yg/sz/domain/AttWagaCode.java b/shuili-system/src/main/java/com/kms/yg/sz/domain/AttWagaCode.java
new file mode 100644
index 00000000..669d92b5
--- /dev/null
+++ b/shuili-system/src/main/java/com/kms/yg/sz/domain/AttWagaCode.java
@@ -0,0 +1,24 @@
+package com.kms.yg.sz.domain;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.shuili.common.core.domain.BaseEntity;
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+@TableName("att_waga_code")
+public class AttWagaCode extends BaseEntity {
+
+    private String wagaCode;
+
+    private String wagaCode2;
+
+    private String wagaCode3;
+
+    private String note;
+
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date updateDate;
+}
diff --git a/shuili-system/src/main/java/com/kms/yg/sz/mapper/AttWagaCodeMapper.java b/shuili-system/src/main/java/com/kms/yg/sz/mapper/AttWagaCodeMapper.java
new file mode 100644
index 00000000..e41d6c59
--- /dev/null
+++ b/shuili-system/src/main/java/com/kms/yg/sz/mapper/AttWagaCodeMapper.java
@@ -0,0 +1,11 @@
+package com.kms.yg.sz.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kms.yg.sz.domain.AttWagaCode;
+import com.kms.yg.sz.domain.BsSgcSzAqjc;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface AttWagaCodeMapper extends BaseMapper<AttWagaCode> {
+}
diff --git a/shuili-system/src/main/java/com/kms/yg/sz/service/AttWagaCodeService.java b/shuili-system/src/main/java/com/kms/yg/sz/service/AttWagaCodeService.java
new file mode 100644
index 00000000..2889b52f
--- /dev/null
+++ b/shuili-system/src/main/java/com/kms/yg/sz/service/AttWagaCodeService.java
@@ -0,0 +1,11 @@
+package com.kms.yg.sz.service;
+
+import com.kms.yg.sz.domain.AttWagaCode;
+
+import com.kms.yg.sz.mapper.AttWagaCodeMapper;
+import com.shuili.common.core.service.BaseService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class AttWagaCodeService extends BaseService<AttWagaCodeMapper, AttWagaCode> {
+}