Browse Source

insert之前对list进行非空判断

dev_shibei_match
wangchao 5 years ago
parent
commit
f4782aee3b
  1. 13
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenPartyUserRankDataServiceImpl.java
  2. 3
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenUserTotalDataServiceImpl.java

13
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenPartyUserRankDataServiceImpl.java

@ -28,6 +28,7 @@ import com.epmet.service.evaluationindex.screen.ScreenPartyUserRankDataService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import java.util.List; import java.util.List;
@ -55,10 +56,12 @@ public class ScreenPartyUserRankDataServiceImpl extends BaseServiceImpl<ScreenPa
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void dataClean(List<ScreenPartyUserRankDataEntity> dataList, String customerId, String dateId) { public void dataClean(List<ScreenPartyUserRankDataEntity> dataList, String customerId, String dateId) {
int affectedRows; if(!CollectionUtils.isEmpty(dataList)) {
do{ int affectedRows;
affectedRows = baseDao.deleteBatchByCustomerIdAndDateId(customerId,dateId); do {
}while (affectedRows > NumConstant.ZERO); affectedRows = baseDao.deleteBatchByCustomerIdAndDateId(customerId, dateId);
baseDao.insertBatch(dataList); } while (affectedRows > NumConstant.ZERO);
baseDao.insertBatch(dataList);
}
} }
} }

3
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenUserTotalDataServiceImpl.java

@ -51,12 +51,11 @@ public class ScreenUserTotalDataServiceImpl extends BaseServiceImpl<ScreenUserTo
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void dataClean(List<ScreenUserTotalDataEntity> list,String customerId) { public void dataClean(List<ScreenUserTotalDataEntity> list,String customerId) {
if(!CollectionUtils.isEmpty(list)){
int deleteNum; int deleteNum;
do { do {
deleteNum = baseDao.deleteUserTotalData(customerId); deleteNum = baseDao.deleteUserTotalData(customerId);
} while (deleteNum > NumConstant.ZERO); } while (deleteNum > NumConstant.ZERO);
if(!CollectionUtils.isEmpty(list)){
baseDao.insertBatch(list); baseDao.insertBatch(list);
} }
} }

Loading…
Cancel
Save