whyclxw
2025-05-15 8364b1730e17da228e45e0675bdf2d6f42bc0691
用户修改
2个文件已修改
3个文件已添加
178 ■■■■■ 已修改文件
src/main/java/com/whyc/controller/BattInfController.java 45 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/mapper/BattInfMapper.java 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/pojo/db_user/User.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/service/BattInfService.java 123 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/UserMapper.xml 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/controller/BattInfController.java
New file
@@ -0,0 +1,45 @@
package com.whyc.controller;
import com.whyc.dto.PowerDto;
import com.whyc.dto.Response;
import com.whyc.pojo.db_station.BattInf;
import com.whyc.pojo.db_station.PowerInf;
import com.whyc.service.BattInfService;
import com.whyc.service.PowerInfService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@RestController
@Api(tags = "电池组管理")
@RequestMapping("battInf")
public class BattInfController {
    @Autowired
    private BattInfService service;
/*
    @ApiOperation(value = "添加电源")
    @PostMapping("addBatt")
    public Response addBatt(@RequestBody BattInf binf){
        return service.addBatt(binf);
    }
    @ApiOperation(value = "删除电源")
    @GetMapping("delBatt")
    public Response delBatt(@RequestParam Integer bid){
        return service.delBatt(bid);
    }
    @ApiOperation(value = "修改电源")
    @PostMapping("updateBatt")
    public Response updateBatt(@RequestBody BattInf binf){
        return service.updateBatt(binf);
    }
    @ApiOperation(value = "查询电源")
    @PostMapping("getBatt")
    public Response getBatt(@RequestBody PowerDto dto){
        return service.getBatt(dto);
    }*/
}
src/main/java/com/whyc/mapper/BattInfMapper.java
New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;
import com.whyc.pojo.db_station.BattInf;
public interface BattInfMapper extends CustomMapper<BattInf>{
}
src/main/java/com/whyc/pojo/db_user/User.java
@@ -30,7 +30,7 @@
    private String phoneNumber;
    @ApiModelProperty(value = "身份:1普通用户,2管理层,3领导层,4运维班组")
    private int role;
    private Integer role;
    @ApiModelProperty(value = "账号类型 1:长期,2:临时 ")
    private Integer type;
src/main/java/com/whyc/service/BattInfService.java
New file
@@ -0,0 +1,123 @@
package com.whyc.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.PowerDto;
import com.whyc.dto.Response;
import com.whyc.mapper.BattInfMapper;
import com.whyc.pojo.db_station.BattInf;
import com.whyc.pojo.db_station.PowerInf;
import com.whyc.pojo.db_station.StationInf;
import com.whyc.pojo.db_user.User;
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
@Service
public class BattInfService {
    @Autowired(required = false)
    private BattInfMapper mapper;
/*
    //添加电源
    @Transactional
    public Response addBatt(BattInf binf) {
        //先校验当前用户是否存在包机组不存在则不让添加电源
        User user= ActionUtil.getUser();
        int flag=bjService.checkUserBaojiGroup(user.getId());
        if(flag==0){
            return new Response().set(1,false,"当前用户不存在包机组");
        }
        //机房信息
        StationInf addsinf= addpinf.getSinf();
        //判断添加锁的时候机房是不是新机房
        String fullName=addsinf.getProvice()+"_"+addsinf.getCity()+"_"+addsinf.getCountry()+"_"+addsinf.getStationName();
        //判断机房是否存在
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("full_name",fullName);
        wrapper.last("limit 1");
        StationInf sinf=sinfMapper.selectOne(wrapper);
        int stationId=0;
        int powerId=0;
        if(sinf!=null){
            stationId=sinf.getStationId();
        }else {
            //获取对应的机房id
            stationId = sinfMapper.getMaxStationId();
            if (stationId == 0) {//数据库中没有站点
                stationId = 40000001;
            } else {
                stationId += 1;
            }
            addsinf.setFullName(fullName);
            addsinf.setStationId(stationId);
            sinfMapper.insert(addsinf);
        }
        //判断机房是否存在
        QueryWrapper wrapper1=new QueryWrapper();
        wrapper1.eq("power_name",addpinf.getPowerName());
        wrapper1.eq("station_id",stationId);
        wrapper1.last("limit 1");
        PowerInf juegep=mapper.selectOne(wrapper);
        if(juegep==null){
            return new Response().set(1, false, "当前机房下已添加过该电源");
        }
        //再添加电源信息
        addpinf.setStationId(stationId);
        //获取对应的电源id
        powerId = mapper.getMaxPowerId();
        if (powerId == 0) {//数据库中没有站点
            powerId = 10001;
        } else {
            powerId += 1;
        }
        addpinf.setPowerId(powerId);
        mapper.insert(addpinf);
        return new Response().set(1, true, "添加电源");
    }
    //删除电源
    public Response delBatt(Integer bid) {
        UpdateWrapper wrapper=new UpdateWrapper();
        wrapper.eq("battgroup_id",bid);
        mapper.delete(wrapper);
        return new Response().set(1,true);
    }
    //修改电源
    public Response updateBatt(BattInf binf) {
        UpdateWrapper wrapper=new UpdateWrapper();
        wrapper.eq("battgroup_id",binf.getBattgroupId());
        if(binf.getBattgroupName()!=null){
            wrapper.set("battgroup_name",binf.getBattgroupName());
        }
        if(binf.getCompany()!=null){
            wrapper.set("company",pinf.getCompany());
        }
        if(pinf.getModel()!=null){
            wrapper.set("model",pinf.getModel());
        }
        if(pinf.getProtocol()!=null){
            wrapper.set("protocol",pinf.getProtocol());
        }
        if(pinf.getPowerIp()!=null){
            wrapper.set("power_ip",pinf.getPowerIp());
        }
        mapper.update((PowerInf) ActionUtil.objeNull,wrapper);
        return new Response().set(1,true);
    }
    //查询电源
    public Response getBatt(PowerDto dto) {
        User user= ActionUtil.getUser();
        dto.setUid(user.getId());
        PageHelper.startPage(dto.getPageNum(),dto.getPageSize());
        List<PowerInf> list=mapper.getPower(dto);
        PageInfo pageInfo=new PageInfo(list);
        return new Response().setII(1,list!=null,pageInfo,"查询电源");
    }
*/
}
src/main/resources/mapper/UserMapper.xml
@@ -27,7 +27,7 @@
        select count(*) from  db_user.tb_user where id>10000
    </select>
    <select id="getAllUser" resultType="User">
        select distinct tb_user.id,tb_user.name,create_time,phone_number from db_user.tb_user
        select distinct tb_user.id,tb_user.name,tb_user.role,create_time,phone_number from db_user.tb_user
        <where>
            tb_user.id>100
            <if test="name!=null">