yangjun
/
hldy_java_monomer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

智能电表水表定时更新接口

This commit is contained in:
曹磊 2025-06-16 18:14:05 +08:00
parent 2392459838
commit edbe07ca0e
12 changed files with 178 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/common/job/CollectorDataJob.java Normal file
View File

@ -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();
}
}

23
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/common/job/MeterStatusJob.java Normal file
View File

@ -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();
}
}

34
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/job/ElectricityReadJob.java Normal file
View File

@ -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());
}
}
}
}

2
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/ElectricityMeterMapper.java
View File

@ -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);

27
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/xml/ElectricityMeterMapper.xml
View File

@ -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

3
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/IElectricityMeterService.java
View File

@ -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);

6
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java
View File

@ -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();
}
/**
* 清零
*/

35
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/job/WaterReadJob.java Normal file
View File

@ -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());
}
}
}
}

3
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/WaterMeterMapper.java
View File

@ -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);

17
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/xml/WaterMeterMapper.xml
View File

@ -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

3
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/IWaterMeterService.java
View File

@ -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);

6
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java
View File

@ -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();
}
/**
* 清零
*/