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; } }