diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/common/job/CollectorDataJob.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/common/job/CollectorDataJob.java
new file mode 100644
index 0000000..da767b9
--- /dev/null
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/common/job/CollectorDataJob.java
@@ -0,0 +1,23 @@
+package com.nu.modules.tq.common.job;
+
+import com.nu.modules.tq.common.service.ITqDeviceInfoService;
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * 表设备状态信息同步
+ */
+@Slf4j
+public class CollectorDataJob implements Job {
+
+    @Autowired
+    ITqDeviceInfoService service;
+
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+        service.getAllCollector();
+    }
+}
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/common/job/MeterStatusJob.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/common/job/MeterStatusJob.java
new file mode 100644
index 0000000..6fe7cb1
--- /dev/null
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/common/job/MeterStatusJob.java
@@ -0,0 +1,23 @@
+package com.nu.modules.tq.common.job;
+
+import com.nu.modules.tq.common.service.ITqDeviceInfoService;
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * 表设备状态信息同步
+ */
+@Slf4j
+public class MeterStatusJob implements Job {
+
+    @Autowired
+    ITqDeviceInfoService service;
+
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+        service.getAllMeter();
+    }
+}
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/job/ElectricityReadJob.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/job/ElectricityReadJob.java
new file mode 100644
index 0000000..26758d1
--- /dev/null
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/job/ElectricityReadJob.java
@@ -0,0 +1,34 @@
+package com.nu.modules.tq.electricity.job;
+
+import com.nu.modules.tq.electricity.entity.ElectricityMeter;
+import com.nu.modules.tq.electricity.service.IElectricityMeterService;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.util.DateUtils;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.beans.factory.annotation.Autowired;
+import java.util.List;
+
+/**
+ * 电表设备抄表信息同步
+ */
+@Slf4j
+public class ElectricityReadJob implements Job {
+
+    @Autowired
+    IElectricityMeterService service;
+
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+        List<ElectricityMeter> electricityList = service.findAllList();
+        if(electricityList!=null&&electricityList.size()>0){
+            for(int i=0;i< electricityList.size();i++){
+                ElectricityMeter electricityMeter = electricityList.get(i);
+                Result<String> result = service.eleRead(electricityMeter);
+                log.error("ElectricityReadJob:{}-{}", DateUtils.now(),result.getResult());
+            }
+        }
+    }
+}
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/ElectricityMeterMapper.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/ElectricityMeterMapper.java
index 18cf663..9164e53 100644
--- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/ElectricityMeterMapper.java
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/ElectricityMeterMapper.java
@@ -5,9 +5,11 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.nu.modules.tq.electricity.entity.ElectricityMeter;
 import org.apache.ibatis.annotations.Param;
+import java.util.List;
 
 public interface ElectricityMeterMapper extends BaseMapper<ElectricityMeter> {
     IPage<ElectricityMeter> findPage(Page<ElectricityMeter> page, @Param("params") ElectricityMeter electricityMeter);
+    List<ElectricityMeter> findAllList();
     ElectricityMeter getElectricityMeter(ElectricityMeter electricityMeter);
     int insert(ElectricityMeter electricityMeter);
     int update(ElectricityMeter electricityMeter);
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/xml/ElectricityMeterMapper.xml b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/xml/ElectricityMeterMapper.xml
index c431477..853338c 100644
--- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/xml/ElectricityMeterMapper.xml
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/xml/ElectricityMeterMapper.xml
@@ -52,6 +52,29 @@
 		</where>
 	</select>
 
+	<select id="findAllList" parameterType="com.nu.modules.tq.electricity.entity.ElectricityMeter" resultType="com.nu.modules.tq.electricity.entity.ElectricityMeter">
+		select
+			a.id,
+			a.cid,
+			a.address,
+			a.ele_value as eleValue,
+			a.relay_state as relayState,
+			a.read_time as readTime,
+			a.remark,
+			b.online,
+			b.csq,
+			b.disconnect_time as disconnectTime,
+			b.connect_time as connectTime,
+			a.nu_id as nuId,
+			a.nu_name as nuName,
+			a.depart_id as departId,
+			a.depart_name as departName,
+			a.depart_server_url as departServerUrl,
+			a.old_server_url ,
+			a.sync_type
+		from nu_iot_tq_electricity_meter a
+	</select>
+
 	<select id="getElectricityMeter" parameterType="com.nu.modules.tq.electricity.entity.ElectricityMeter" resultType="com.nu.modules.tq.electricity.entity.ElectricityMeter">
 		select
 			id,
@@ -66,7 +89,7 @@
 		  and address = #{address}
 	</select>
 
-	<update id="insert" parameterType="com.nu.modules.tq.electricity.entity.ElectricityMeter">
+	<insert id="insert" parameterType="com.nu.modules.tq.electricity.entity.ElectricityMeter">
 		insert into nu_iot_tq_water_meter(
 			cid,
 			address,
@@ -81,7 +104,7 @@
 			#{remark},
 			now()
 		)
-	</update>
+	</insert>
 
 	<update id="update" parameterType="com.nu.modules.tq.electricity.entity.ElectricityMeter">
 		update nu_iot_tq_electricity_meter
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/IElectricityMeterService.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/IElectricityMeterService.java
index 05210ed..9be9315 100644
--- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/IElectricityMeterService.java
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/IElectricityMeterService.java
@@ -6,8 +6,11 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.nu.modules.tq.electricity.entity.ElectricityMeter;
 import org.jeecg.common.api.vo.Result;
 
+import java.util.List;
+
 public interface IElectricityMeterService extends IService<ElectricityMeter> {
     IPage<ElectricityMeter> findPage(Page<ElectricityMeter> page, ElectricityMeter electricityMeter);
+    List<ElectricityMeter> findAllList();
     Result<String> eleReset(ElectricityMeter electricityMeter);
     Result<String> eleControl(ElectricityMeter electricityMeter);
     Result<String> eleRead(ElectricityMeter electricityMeter);
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java
index 98787f8..d15b1a9 100644
--- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java
@@ -44,10 +44,16 @@ public class ElectricityMeterServiceImpl extends ServiceImpl<ElectricityMeterMap
     @Autowired
     private ElectricityMeterServiceImpl syncImpl;
 
+    @Override
     public IPage<ElectricityMeter> findPage(Page<ElectricityMeter> page, ElectricityMeter electricityMeter){
         return baseMapper.findPage(page,electricityMeter);
     }
 
+    @Override
+    public List<ElectricityMeter> findAllList(){
+        return baseMapper.findAllList();
+    }
+
     /**
      * 清零
      */
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/job/WaterReadJob.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/job/WaterReadJob.java
new file mode 100644
index 0000000..c821cd7
--- /dev/null
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/job/WaterReadJob.java
@@ -0,0 +1,35 @@
+package com.nu.modules.tq.water.job;
+
+import com.nu.modules.tq.water.entity.WaterMeter;
+import com.nu.modules.tq.water.service.IWaterMeterService;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.util.DateUtils;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.List;
+
+/**
+ * 水表设备抄表信息同步
+ */
+@Slf4j
+public class WaterReadJob implements Job {
+
+    @Autowired
+    IWaterMeterService service;
+
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+        List<WaterMeter> waterList = service.findAllList();
+        if(waterList!=null&&waterList.size()>0){
+            for(int i=0;i< waterList.size();i++){
+                WaterMeter waterMeter = waterList.get(i);
+                Result<String> result = service.waterRead(waterMeter);
+                log.error("WaterReadJob:{}-{}", DateUtils.now(),result.getResult());
+            }
+        }
+    }
+}
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/WaterMeterMapper.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/WaterMeterMapper.java
index d360554..ae33632 100644
--- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/WaterMeterMapper.java
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/WaterMeterMapper.java
@@ -6,8 +6,11 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.nu.modules.tq.water.entity.WaterMeter;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 public interface WaterMeterMapper extends BaseMapper<WaterMeter> {
     IPage<WaterMeter> findPage(Page<WaterMeter> page, @Param("params") WaterMeter waterMeter);
+    List<WaterMeter> findAllList();
     WaterMeter getWaterMeter(WaterMeter waterMeter);
     int insert(WaterMeter waterMeter);
     int update(WaterMeter waterMeter);
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/xml/WaterMeterMapper.xml b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/xml/WaterMeterMapper.xml
index 8606440..394ba3f 100644
--- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/xml/WaterMeterMapper.xml
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/xml/WaterMeterMapper.xml
@@ -50,6 +50,19 @@
 		</where>
 	</select>
 
+	<select id="findAllList" parameterType="com.nu.modules.tq.water.entity.WaterMeter" resultType="com.nu.modules.tq.water.entity.WaterMeter">
+		select
+			id,
+			cid,
+			address,
+			water_value as waterValue,
+			relay_state as relayState,
+			battery_state as batteryState,
+			read_time as readTime,
+			remark
+		from nu_iot_tq_water_meter
+	</select>
+
 	<select id="getWaterMeter" parameterType="com.nu.modules.tq.water.entity.WaterMeter" resultType="com.nu.modules.tq.water.entity.WaterMeter">
 		select
 			id,
@@ -65,7 +78,7 @@
 		  and address = #{address}
 	</select>
 
-	<update id="insert" parameterType="com.nu.modules.tq.water.entity.WaterMeter">
+	<insert id="insert" parameterType="com.nu.modules.tq.water.entity.WaterMeter">
 		insert into nu_iot_tq_water_meter(
 			cid,
 			address,
@@ -82,7 +95,7 @@
 			#{remark},
 			now()
 		)
-	</update>
+	</insert>
 
 	<update id="update" parameterType="com.nu.modules.tq.water.entity.WaterMeter">
 		update nu_iot_tq_water_meter
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/IWaterMeterService.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/IWaterMeterService.java
index 38dfabd..0661cd3 100644
--- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/IWaterMeterService.java
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/IWaterMeterService.java
@@ -6,8 +6,11 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.nu.modules.tq.water.entity.WaterMeter;
 import org.jeecg.common.api.vo.Result;
 
+import java.util.List;
+
 public interface IWaterMeterService extends IService<WaterMeter> {
     IPage<WaterMeter> findPage(Page<WaterMeter> page, WaterMeter waterMeter);
+    List<WaterMeter> findAllList();
     Result<String> waterReset(WaterMeter waterMeter);
     Result<String> waterControl(WaterMeter waterMeter);
     Result<String> waterRead(WaterMeter waterMeter);
diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java
index 193afb1..427b2dc 100644
--- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java
@@ -31,10 +31,16 @@ public class WaterMeterServiceImpl extends ServiceImpl<WaterMeterMapper, WaterMe
     @Autowired
     ITqApiLogService logService;
 
+    @Override
     public IPage<WaterMeter> findPage(Page<WaterMeter> page, WaterMeter waterMeter){
         return baseMapper.findPage(page,waterMeter);
     }
 
+    @Override
+    public List<WaterMeter> findAllList(){
+        return baseMapper.findAllList();
+    }
+
     /**
      * 清零
      */