From 42155cb925930831293dd10ac5037c04619e92c9 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期四, 17 十月 2024 16:05:08 +0800 Subject: [PATCH] 修改通信中间件上行数据的漏损量处理逻辑,对于当天绑定(发现并绑定)的控制器,控制器计算的漏损量一定不正确,强制设置成0,本次修改是把原实现用发现日期时间控制,变成绑定日期时间控制。 --- pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java | 7 ++++++- 1 files changed, 6 insertions(+), 1 deletions(-) diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java index 8ff25aa..c8e5bc5 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java @@ -10,7 +10,6 @@ import com.dy.pipIrrGlobal.pojoPr.PrControllerTramp; import com.dy.pipIrrGlobal.pojoRm.*; import com.dy.pipIrrGlobal.pojoSe.SeClient; -import com.dy.pipIrrGlobal.pojoSe.SeClientCard; import com.dy.pipIrrGlobal.voSe.VoCardInfo1; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -153,6 +152,9 @@ */ @Transactional(rollbackFor = Exception.class) public void savePrConctrollerTramp(PrControllerTramp po){ + if(po.getOrgTag().trim().length() > 2) { + po.setOrgTag("DY"); + } this.prControllerTrampMapperDao.insert(po) ; } /** @@ -675,6 +677,7 @@ * @param id * @param remainMoney */ + @Transactional(rollbackFor = Exception.class) public void updateIcCardRemainMoney(Long id , Double remainMoney){ seClientCardDao.updateMoney(id,remainMoney); } @@ -684,6 +687,7 @@ * @param id * @param remainMoney */ + @Transactional(rollbackFor = Exception.class) public void updateVirIcCardRemainMoney(Long id , Double remainMoney){ seVirtualCardDao.updateMoney(id,remainMoney); } @@ -696,6 +700,7 @@ public RmCommandHistory getCommandLog(String commandId){ return rmCommandHistoryDao.selectByPrimaryKey(Long.parseLong(commandId)) ; } + @Transactional(rollbackFor = Exception.class) public void updateCommandLog(RmCommandHistory po){ rmCommandHistoryDao.updateByPrimaryKey(po) ; } -- Gitblit v1.8.0