From 89df790fd255cb1788c64aabbed719edd3500798 Mon Sep 17 00:00:00 2001 From: jianjun Date: Mon, 27 Jun 2022 13:44:34 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=88=BF=E5=B1=8B=E5=86=85?= =?UTF-8?q?=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/IcHouseServiceImpl.java | 19 ++++++++++++------- 1 file changed, 12 insertions(+), 7 deletions(-) diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/IcHouseServiceImpl.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/IcHouseServiceImpl.java index f325b5f139..8e9c474bb8 100644 --- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/IcHouseServiceImpl.java +++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/IcHouseServiceImpl.java @@ -1,6 +1,7 @@ package com.epmet.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; import com.epmet.commons.tools.constant.NumConstant; @@ -293,25 +294,29 @@ public class IcHouseServiceImpl extends BaseServiceImpl> paramList) { - if (CollectionUtils.isEmpty(paramList)){ + if (CollectionUtils.isEmpty(paramList)) { log.warn("updateIcHouseResiNumber param is empty"); return 0; } IcHouseEntity entity = new IcHouseEntity(); AtomicInteger effects = new AtomicInteger(0); - paramList.forEach(o->{ + LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper(); + paramList.forEach(o -> { Object houseId = o.get("houseId"); Object resiNumber = o.get("resiNumber"); - if (houseId == null || resiNumber == null){ + if (houseId == null || resiNumber == null) { return; } - entity.setId(houseId.toString()); - - entity.setResiNumber(Integer.valueOf(resiNumber.toString())); - int i = baseDao.updateById(entity); + Integer resiNumber1 = Integer.valueOf(resiNumber.toString()); + entity.setResiNumber(resiNumber1); + entity.setUpdatedTime(new Date()); + updateWrapper.eq(IcHouseEntity::getId, houseId.toString()) + .ne(IcHouseEntity::getResiNumber, resiNumber1); + int i = baseDao.update(entity, updateWrapper); effects.incrementAndGet(); }); + log.debug("updateIcHouseResiNumber effectRow:{}", effects.intValue()); return effects.get(); // return baseDao.updateIcHouseResiNumber(paramList); }