Browse Source

更新房屋内数据

feature/evaluate
jianjun 3 years ago
parent
commit
89df790fd2
  1. 13
      epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/IcHouseServiceImpl.java

13
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;
@ -300,18 +301,22 @@ public class IcHouseServiceImpl extends BaseServiceImpl<IcHouseDao, IcHouseEntit
IcHouseEntity entity = new IcHouseEntity();
AtomicInteger effects = new AtomicInteger(0);
LambdaUpdateWrapper<IcHouseEntity> updateWrapper = new LambdaUpdateWrapper();
paramList.forEach(o -> {
Object houseId = o.get("houseId");
Object resiNumber = o.get("resiNumber");
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);
}

Loading…
Cancel
Save