添加电源要加入包机组

whyclxw

2025-05-19 5c7bbb84d67016e7e798135584b9a2fd5524492b

添加电源要加入包机组

 src/main/java/com/whyc/service/PowerInfService.java

@@ -6,10 +6,14 @@
import com.github.pagehelper.PageInfo;
import com.whyc.dto.PowerDto;
import com.whyc.dto.Response;
import com.whyc.mapper.BaojigroupPowerMapper;
import com.whyc.mapper.BaojigroupUsrMapper;
import com.whyc.mapper.PowerInfMapper;
import com.whyc.mapper.StationInfMapper;
import com.whyc.pojo.db_station.PowerInf;
import com.whyc.pojo.db_station.StationInf;
import com.whyc.pojo.db_user.BaojigroupPower;
import com.whyc.pojo.db_user.BaojigroupUsr;
import com.whyc.pojo.db_user.User;
import com.whyc.util.ActionUtil;
import org.apache.commons.math3.analysis.function.Power;
@@ -17,6 +21,7 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.List;

@Service
@@ -27,6 +32,11 @@
    @Autowired(required = false)
    private StationInfMapper sinfMapper;

    @Autowired(required = false)
    private BaojigroupUsrMapper bjUserMapper;

    @Autowired(required = false)
    private BaojigroupPowerMapper bjPowerMapper;

    /*添加电源
    1.判断当前用户是否是包组用户
@@ -79,7 +89,32 @@
            powerId += 1;
        }
        addpinf.setPowerId(powerId);
        mapper.insert(addpinf);
        int flag=mapper.insert(addpinf);
        if(flag>0){
            //当前人所在的包机组添加电源机房
            insertInbaoji(stationId,powerId);
        }

    }
    //当前人所在的包机组添加电源机房
    public void insertInbaoji(Integer stationId,Integer powerId){
        //重启线程并将锁加到当前人的包机组
        User uinf= ActionUtil.getUser();
        QueryWrapper wrapper1=new QueryWrapper();
        wrapper1.eq("uid",uinf.getId());
        List<BaojigroupUsr> groupIdList=bjUserMapper.selectList(wrapper1);
        List<BaojigroupPower> baojigroupList=new ArrayList();
        if(groupIdList!=null&&groupIdList.size()>0){
            for (BaojigroupUsr bjUser:groupIdList) {
                BaojigroupPower bjPower=new BaojigroupPower();
                bjPower.setStationId(stationId);
                bjPower.setPowerId(powerId);
                bjPower.setBaojiGroupId(bjUser.getBaojiGroupId());
                baojigroupList.add(bjPower);
            }
        }
        bjPowerMapper.insertBatchSomeColumn(baojigroupList);
        //processSurveyService.setUpThreadRestart();
    }
    //获取电源品牌(下拉)
    public Response getCompanyByUid(Integer uid) {