package com.gyee.power.fitting.service.impl;
import com.gyee.power.fitting.common.base.ExcludeQueryWrapper;
import com.gyee.power.fitting.common.util.CollectUtil;
import com.gyee.power.fitting.common.util.SnowFlakeUtil;
import com.gyee.power.fitting.model.ProEconPowerModel;
import com.gyee.power.fitting.mapper.ProEconPowerModelMapper;
import com.gyee.power.fitting.service.ProEconPowerModelService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import java.util.Collections;
import java.util.List;
/**
*
* 服务实现类
*
*
* @author chenmh
* @since 2023-10-09
*/
@Service
public class ProEconPowerModelServiceImpl extends ServiceImpl implements ProEconPowerModelService {
@Override
public void insertBatch(List list) {
list.forEach(item -> item.setId(SnowFlakeUtil.generateId()));
try{
if (list.size() > 1000){
List> coll = CollectUtil.groupListByQty(list, 1000);
coll.forEach(ls -> saveBatch(ls));
} else {
saveBatch(list);
}
}catch (Exception e){
log.error("ProEconPowerModelServiceImpl--insertBatch", e);
}
}
@Override
public boolean deleteItem(String wtId) {
ExcludeQueryWrapper wrapper = new ExcludeQueryWrapper<>();
wrapper.eq("windturbine_id", wtId);
int count = 0;
try{
count = baseMapper.delete(wrapper);
} catch (Exception e){
log.error("ProEconPowerModelServiceImpl--deleteItem", e);
return false;
}
return count > 0 ? true : false;
}
@Override
public List selectByWtId(String wtId) {
ExcludeQueryWrapper wrapper = new ExcludeQueryWrapper<>();
wrapper.eq("windturbine_id", wtId);
try{
return baseMapper.selectList(wrapper);
}catch (Exception e){
log.error("ProEconPowerModelServiceImpl--selectByWtId", e);
}
return Collections.EMPTY_LIST;
}
@Override
public List selectList() {
try{
return baseMapper.selectList(null);
}catch (Exception e){
log.error("ProEconPowerModelServiceImpl--selectList", e);
}
return Collections.EMPTY_LIST;
}
}