package com.xiaopeng.map.controller;
|
|
import cn.afterturn.easypoi.excel.ExcelExportUtil;
|
import cn.afterturn.easypoi.excel.entity.ExportParams;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.xiaopeng.api.model.operation.XpElectronicFence;
|
import com.xiaopeng.api.model.operation.XpStation;
|
import com.xiaopeng.api.query.operation.XpStationQuery;
|
import com.xiaopeng.api.vo.account.LoginUser;
|
import com.xiaopeng.api.vo.operation.XpStationVo;
|
import com.xiaopeng.common.core.domain.R;
|
import com.xiaopeng.common.core.exception.ServiceException;
|
import com.xiaopeng.common.core.utils.WebUtils;
|
import com.xiaopeng.common.core.web.page.PageInfo;
|
import com.xiaopeng.common.security.service.TokenService;
|
import com.xiaopeng.map.exportExcel.XpStationExportExcel;
|
import com.xiaopeng.map.service.XpElectronicFenceService;
|
import com.xiaopeng.map.service.XpPointService;
|
import com.xiaopeng.map.service.XpStationService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.poi.ss.usermodel.Workbook;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import javax.servlet.ServletOutputStream;
|
import javax.servlet.http.HttpServletResponse;
|
import javax.validation.Valid;
|
import java.io.IOException;
|
import java.net.URLEncoder;
|
import java.nio.charset.StandardCharsets;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
|
@RestController
|
@Slf4j
|
@Api(tags = "场站管理")
|
@RequestMapping("/api/v1/station")
|
public class XpStationManagementController {
|
|
|
@Resource
|
private XpStationService xpStationService;
|
|
@Resource
|
private TokenService tokenService;
|
@Resource
|
private XpPointService xpPointService;
|
@Resource
|
private XpElectronicFenceService xpElectronicFenceService;
|
|
|
@ApiOperation(value = "场站管理已经启动列表", tags = {"管理后台-运营-场站管理"})
|
@GetMapping("/findListEnable")
|
public R<List<XpStation>> findListByCityCode(@RequestParam String cityCode) {
|
XpStationQuery query = new XpStationQuery();
|
query.setCityCode(cityCode);
|
return R.ok( xpStationService.findList(query));
|
}
|
|
|
@ApiOperation(value = "场站管理列表", tags = {"管理后台-运营-场站管理"})
|
@PostMapping("/findList")
|
public R<List<XpStation>> findList(@RequestBody XpStationQuery query) {
|
List<XpStation> list = xpStationService.findList(query);
|
return R.ok(list);
|
}
|
|
@ApiOperation(value = "场站管理分页列表", tags = {"管理后台-运营-场站管理"})
|
@PostMapping("/pageList")
|
public R<PageInfo<XpStation>> pageList(@RequestBody XpStationQuery query) {
|
PageInfo<XpStation> pageList = xpStationService.pageList(query);
|
return R.ok(pageList);
|
}
|
|
@GetMapping("/getById/{id}")
|
@ApiOperation(value = "详情场站管理", tags = {"管理后台-运营-场站管理"})
|
public R getById(@PathVariable Long id) {
|
XpStation bean = xpStationService.getById(id);
|
if (bean == null) {
|
return R.fail("参数错误");
|
}
|
XpStationVo beanVo = new XpStationVo();
|
BeanUtils.copyProperties(bean, beanVo);
|
beanVo.setXpPointList(xpPointService.listByStationId(bean.getId()));
|
|
XpElectronicFence electronicFence = xpElectronicFenceService.getById(bean.getElectronicId());
|
|
beanVo.setFenceEffectType(electronicFence.getEffectType());
|
beanVo.setFenceEffectTime(electronicFence.getEffectTime());
|
beanVo.setFenceFailureType(electronicFence.getFailureType());
|
beanVo.setFenceFailureTime(electronicFence.getFailureTime());
|
|
return R.ok(beanVo);
|
}
|
|
/**
|
* 新增电子围栏
|
*/
|
@PostMapping("/add")
|
@ApiOperation(value = "新增场站管理", tags = {"管理后台-运营-场站管理"})
|
public R add(@Valid @RequestBody XpStationVo vo) {
|
|
xpStationService.validate(vo);
|
|
LoginUser loginUser = tokenService.getLoginUser();
|
|
vo.setCreateBy(loginUser.getUsername());
|
vo.setCreateTime(LocalDateTime.now());
|
vo.setUpdateBy(loginUser.getUsername());
|
vo.setUpdateTime(LocalDateTime.now());
|
|
return xpStationService.add(vo);
|
}
|
|
/**
|
* 编辑电子围栏
|
*/
|
@PostMapping("/edit")
|
@ApiOperation(value = "编辑场站管理" , tags = {"管理后台-运营-场站管理"})
|
public R edit(@Valid @RequestBody XpStationVo vo) {
|
if(vo.getId() == null){
|
return R.fail("参数错误");
|
}
|
XpStation bean = xpStationService.getById(vo.getId());
|
if(bean == null){
|
return R.fail("参数错误");
|
}
|
xpStationService.validate(vo);
|
//场站状态 0=草稿 1=待启用 2=启用中 3=已停用 4=失效
|
// if(bean.getStatus() == 2){
|
// return R.fail("场站在启动中不能编辑");
|
// }
|
|
LoginUser loginUser = tokenService.getLoginUser();
|
|
vo.setUpdateBy(loginUser.getUsername());
|
vo.setUpdateTime(LocalDateTime.now());
|
|
return xpStationService.edit(vo);
|
}
|
|
|
/**
|
* 启用中状态： 操作项展示为 [停用]。 停用
|
* - 操作项展示为 [停用]。点击后弹出二次确认框，“当前场站包含12个点位，确认一起停用？
|
* - 是：确认后场站以及子点位状态流转至“已停用”。
|
* - 否：子点位维持当前状态，但自动退回为“独立点位”。
|
*/
|
@ApiOperation(value = "停用" , tags = {"管理后台-运营-场站管理"})
|
@GetMapping("/updateStatus/{id}")
|
public R updateStatus(@PathVariable Long id, @RequestParam Boolean isEnable, @RequestParam Boolean pointStop) {
|
XpStation bean = xpStationService.getById(id);
|
if (bean == null) {
|
throw new ServiceException("场站不存在,请刷新重试");
|
}
|
if(isEnable){
|
xpStationService.updateStatusEnable(bean);
|
}else{
|
// if(bean.getStatus() == 2){//场站状态 0=草稿 1=待启用 2=启用中 3=已停用 4=失效
|
// return R.fail("场站状态启动中，不能停用");
|
// }
|
//场站状态 0=草稿 1=待测试 2=测试中 3=测试不通过 4=可运营 5=待生效 6=启用中 7=已停用 8=失效
|
xpStationService.updateStatusStop(bean,pointStop);
|
}
|
|
return R.ok();
|
}
|
/**
|
* - 删除拦截逻辑：
|
* - 测试阶段（待测试、测试中等）：点击直接删除。
|
* - 历史运营阶段（已停用、失效）：点击弹出二次确认框“当前场站包含12个点位，确认一起删除？”
|
* - 是：点位统一一起删除
|
* - 否：不自动删除点位，点位自动退回为[待测试]的“独立点位”，并自动继承父级运营区的运营时段
|
* @param id
|
* @param pointDelete
|
* @return
|
*/
|
@ApiOperation(value = "删除场站管理", tags = {"管理后台-运营-场站管理"})
|
@PostMapping("/delete/{id}")
|
public R delete(@PathVariable Long id,@RequestParam Boolean pointDelete) {
|
XpStation bean = xpStationService.getById(id);
|
if (bean == null) {
|
throw new ServiceException("场站不存在,请刷新重试");
|
}
|
// 场站状态 0=草稿 1=待启用 2=启用中 3=已停用 4=失效
|
// 只有状态为已停用(7)时才能删除
|
if (bean.getStatus() == 2 ) {
|
throw new ServiceException("场站启用中，无法删除");
|
}
|
boolean b = xpStationService.removeById(bean,pointDelete);
|
if (b){
|
return R.ok();
|
}
|
return R.fail("删除失败");
|
}
|
|
|
|
@ApiOperation(value = "导出", tags = {"管理后台-运营-场站管理"})
|
@PostMapping("/exportExcel")
|
public void exportExcel(@RequestBody XpStationQuery query) {
|
if (query.getIds().isEmpty()) {
|
return;
|
}
|
List<XpStation> list = xpStationService.findList(query);
|
|
List<XpStationExportExcel> exportList = new ArrayList<>(list.size());
|
for (XpStation xpStation : list) {
|
XpStationExportExcel excel = new XpStationExportExcel();
|
BeanUtils.copyProperties(xpStation, excel);
|
excel.setStatusName(xpStation.getStatusName());
|
excel.setCreateTimeStr(xpStation.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
excel.setUpdateTimeStr(xpStation.getUpdateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
exportList.add(excel);
|
}
|
|
HttpServletResponse response = WebUtils.response();
|
if (response == null) {
|
throw new ServiceException("导出失败：未获取到响应对象");
|
}
|
response.setContentType("application/vnd.ms-excel");
|
response.setCharacterEncoding(StandardCharsets.UTF_8.name());
|
try {
|
String fileName = URLEncoder.encode("场站列表.xls", StandardCharsets.UTF_8.name());
|
response.setHeader("Content-disposition", "attachment;filename=" + fileName);
|
try (Workbook workbook = ExcelExportUtil.exportExcel(new ExportParams(), XpStationExportExcel.class, exportList);
|
ServletOutputStream outputStream = response.getOutputStream()) {
|
workbook.write(outputStream);
|
}
|
} catch (IOException e) {
|
log.error("点位导出失败 ids={}", query.getIds(), e);
|
throw new ServiceException("点位导出失败");
|
}
|
}
|
}
|
