From ecc8ce7c34da0c45bf8bd2276801cfbd94af8dca Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期六, 14 十二月 2024 11:13:32 +0800 Subject: [PATCH] pipIrr-web-temp增加数据事务和增加一些日志信息 --- pipIrr-platform/pipIrr-web/pipIrr-web-temp/src/main/java/com/dy/pipIrrTemp/changeSome/ChSomeIntakeAmountSv.java | 25 ++++++++++++++++++++----- 1 files changed, 20 insertions(+), 5 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-temp/src/main/java/com/dy/pipIrrTemp/changeSome/ChSomeIntakeAmountSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-temp/src/main/java/com/dy/pipIrrTemp/changeSome/ChSomeIntakeAmountSv.java index fa7191c..4b690b7 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-temp/src/main/java/com/dy/pipIrrTemp/changeSome/ChSomeIntakeAmountSv.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-temp/src/main/java/com/dy/pipIrrTemp/changeSome/ChSomeIntakeAmountSv.java @@ -7,6 +7,7 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import java.util.List; @@ -43,7 +44,7 @@ if(lastAd == null){ lastAd = ad ; if(lastAd.amount != null && lastAd.amount > IntakeAmountDayFlag){ - dao.updateOneIntakeAmountDay(lastAd.id, 0.0); + this.doUpdateOneIntakeAmountDay(lastAd.id, 0.0); } }else{ if(ad.amount != null && ad.amount > IntakeAmountDayFlag){ @@ -63,14 +64,15 @@ if(ad.dt != null && lastAd.dt != null){ if(DateTime.daysBetweenyyyy_MM_dd(ad.dt, lastAd.dt) == 1){ //鍙浉宸竴澶� - ad.amount = 0.0 ; log.info("鍑虹幇鐩稿樊涓�澶╀絾鏃ュ彇姘撮噺澶т簬" + IntakeAmountDayFlag + "鐨勬儏鍐碉紝鏁版嵁id=" + ad.id + "锛屽彇姘村彛id=" + ad.intakeId + "锛屾棩鏈�=" + ad.dt - + "锛屾按閲�=" + ad.amount + + "锛岃缃按閲�=0.0" + + "锛岃缃墠姘撮噺= " + ad.amount ); + ad.amount = 0.0 ; }else{ //宸茬粡淇敼鍚庣殑鏁板�间粛鐒跺ぇ浜嶪ntakeAmountDayFlag锛岃鏄庢槸澶ф棩鏈笂鎶ユ暟鎹�岀Н绱笅鏉�,鍙互澶т簬IntakeAmountDayFlag //ad.amount = ad.amount ; @@ -79,15 +81,23 @@ + "鐨勬儏鍐碉紝鏁版嵁id=" + ad.id + "锛屽彇姘村彛id=" + ad.intakeId + "锛屾棩鏈�=" + ad.dt - + "锛屾按閲�=" + ad.amount + + "锛屾按閲忎繚鎸佷笉鍙�=" + ad.amount ); } } } }else{ + log.info("鍑虹幇鐩稿樊澶氬ぉ鏃ュ彇姘撮噺澶т簬" + + IntakeAmountDayFlag + + "骞朵笖灞炴�otalAmountLast涓簄ull鐨勬儏鍐碉紝鏁版嵁id=" + ad.id + + "锛屽彇姘村彛id=" + ad.intakeId + + "锛屾棩鏈�=" + ad.dt + + "锛岃缃按閲�=0.0" + + "锛岃缃墠姘撮噺= " + ad.amount + ); ad.amount = 0.0 ; } - dao.updateOneIntakeAmountDay(ad.id, 0.0); + this.doUpdateOneIntakeAmountDay(ad.id, 0.0); } } } @@ -95,4 +105,9 @@ } } } + + @Transactional + int doUpdateOneIntakeAmountDay(Long id, Double amount){ + return dao.updateOneIntakeAmountDay(id, amount); + } } -- Gitblit v1.8.0