sis-background/power-fitting-JN/src/main/java/com.gyee.power.fitting/service/impl/ProEconPowerModelServiceImpl.java

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;

/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author chenmh
 * @since 2023-10-09
 */
@Service
public class ProEconPowerModelServiceImpl extends ServiceImpl<ProEconPowerModelMapper, ProEconPowerModel> implements ProEconPowerModelService {


    @Override
    public void insertBatch(List<ProEconPowerModel> list) {
        list.forEach(item -> item.setId(SnowFlakeUtil.generateId()));
        try{
            if (list.size() > 1000){
                List<List<ProEconPowerModel>> 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<ProEconPowerModel> 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<ProEconPowerModel> selectByWtId(String wtId) {
        ExcludeQueryWrapper<ProEconPowerModel> 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<ProEconPowerModel> selectList() {
        try{
            return baseMapper.selectList(null);
        }catch (Exception e){
            log.error("ProEconPowerModelServiceImpl--selectList", e);
        }
        return Collections.EMPTY_LIST;
    }
}