package com.whyc.controller;
|
|
import com.whyc.dto.Response;
|
import com.whyc.factory.BattinfGroupFactory;
|
import com.whyc.pojo.*;
|
import com.whyc.service.BattInfService;
|
import com.whyc.service.CircleInfService;
|
import com.whyc.service.StationInfService;
|
import com.whyc.service.SubInfService;
|
import com.whyc.util.ActionUtil;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.bind.annotation.*;
|
|
@RestController
|
@RequestMapping("circle")
|
@Api(tags = "动环管理")
|
public class CircleInfController {
|
@Autowired
|
private CircleInfService service;
|
|
@Autowired
|
private StationInfService sinfService;
|
|
@Autowired
|
private BattInfService binfService;
|
|
@Autowired
|
private SubInfService subService;
|
|
|
@PostMapping("add")
|
@ApiOperation(value = "添加动环")
|
@Transactional
|
public Response add(@RequestBody CircleInf circleInf){
|
int userId = ActionUtil.getUser().getUId().intValue();
|
Response res = new Response();
|
//校验机房站点是否存在,存在则不需要新建StationId
|
StationInf sinf = sinfService.judgeStationName(circleInf.getStationName());
|
if (sinf!=null) {
|
circleInf.setStationId(sinf.getStationId());
|
}else {
|
//站点不存在,需要新建站点记录
|
String nextStationId = binfService.getNextStationId();
|
StationInf station = new StationInf();
|
station.setStationId(nextStationId);
|
station.setStationName(circleInf.getStationName());
|
station.setStationName1(circleInf.getStationName1());
|
station.setStationName2(circleInf.getStationName2());
|
station.setStationName3(circleInf.getStationName3());
|
station.setStationName5(circleInf.getStationName5());
|
sinfService.insertStation(station);
|
//powerInf.setStationId(String.valueOf(battInfService.searchMaxId_zj()));
|
circleInf.setStationId(nextStationId);
|
}
|
//获取动环的设备id
|
String devId = service.getDeviceId();
|
circleInf.setDeviceId(devId);
|
//存入自建数量
|
if(circleInf.getSubList()!=null){
|
circleInf.setSubCount(circleInf.getSubList().size());
|
}
|
if (service.add(circleInf)>0){
|
//添加机房站点到用户对应的包机组
|
binfService.insertUserBattgroupBaojigroupBattgroupSelect(circleInf.getStationId(),0,userId);
|
//添加子件信息
|
if(circleInf.getSubList()!=null&&circleInf.getSubList().size()>0){
|
subService.addSubList(devId,circleInf.getSubList());
|
}
|
|
//添加电源站点时,更新ReInit字段为1,通讯程序监控变化重新初始化
|
/*if(powerInf.getPowerDeviceType()== BattinfGroupFactory.DEVICE_POWER) {
|
boolean flag = powerAppSysService.updateFlag("AppServer_Reinit_PowerData_EN");
|
if (!flag) {
|
System.out.println("更新updateReInit接口失败");
|
}
|
}else{
|
//充电机和绝缘装置的,更新另一个ReInit字段为1
|
boolean flag = powerAppSysService.updateFlag("AppServer_Reinit_BattGroupData_EN");
|
if (!flag) {
|
System.out.println("更新updateReInit接口失败");
|
}
|
}*/
|
res.set(1,true,"添加成功");
|
}else{
|
res.set(1,false,"添加失败");
|
}
|
|
return res;
|
}
|
@PostMapping("update")
|
@ApiOperation(value = "更新电源")
|
public Response updateByDeviceId(@RequestBody CircleInf circleInf){
|
service.updateByDeviceId(circleInf);
|
return new Response().set(1,true,"更新成功");
|
}
|
@PostMapping("delete")
|
@ApiOperation(value = "删除电源")
|
public Response deleteByDeviceId(@RequestParam Integer deviceId){
|
service.deleteByDeviceId(deviceId);
|
return new Response().set(1,true,"删除成功");
|
}
|
|
}
|
