diff --git a/src/main/java/com/zhgd/xmgl/device/water/controller/CallBackController.java b/src/main/java/com/zhgd/xmgl/device/water/controller/CallBackController.java index f2e7234ff..b2ed4e4c2 100644 --- a/src/main/java/com/zhgd/xmgl/device/water/controller/CallBackController.java +++ b/src/main/java/com/zhgd/xmgl/device/water/controller/CallBackController.java @@ -3,6 +3,7 @@ package com.zhgd.xmgl.device.water.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.zhgd.jeecg.common.api.vo.Result; import com.zhgd.xmgl.async.AsyncDoubleCarbon; import com.zhgd.xmgl.device.water.util.MeterUtils; import com.zhgd.xmgl.device.water.util.ParserDataUtils; @@ -107,7 +108,7 @@ public class CallBackController { @PostMapping("/xmgl/callback/waterMeterInfo/v2") - public void uploadMeterInfoV2(@RequestBody String bodyStr) { + public Result uploadMeterInfoV2(@RequestBody String bodyStr) { log.info("=====bodyStr:" + bodyStr); logger.info("水表回调接收数据=====bodyStr :" + bodyStr); JSONObject jsonObject = JSONObject.parseObject(bodyStr); @@ -156,6 +157,7 @@ public class CallBackController { } else if ("commandResponse".equals(jsonObject.getString("messageType"))) { } + return Result.ok(); } public static void main(String[] args) { diff --git a/src/main/java/com/zhgd/xmgl/modules/frontier/service/impl/FrontierProtectionDevCurrentDataServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/frontier/service/impl/FrontierProtectionDevCurrentDataServiceImpl.java index bf44e39c1..0b8e7ee23 100644 --- a/src/main/java/com/zhgd/xmgl/modules/frontier/service/impl/FrontierProtectionDevCurrentDataServiceImpl.java +++ b/src/main/java/com/zhgd/xmgl/modules/frontier/service/impl/FrontierProtectionDevCurrentDataServiceImpl.java @@ -114,4 +114,4 @@ public class FrontierProtectionDevCurrentDataServiceImpl extends ServiceImpl queryWrapper1 = new QueryWrapper<>(); + queryWrapper1.lambda().eq(ProjectEnterprise::getEnterpriseId, ei.getId()) + .eq(ProjectEnterprise::getProjectSn, projectSn); + ProjectEnterprise projectEnterprise = projectEnterpriseMapper.selectOne(queryWrapper1); + if (projectEnterprise == null) { + saveEnterpriseInfo(ei); + } else { + updateEnterpriseInfo(ei); + } return Result.ok(); }