package com.zy.sc.manager.controller;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.mapper.Wrapper;
|
import com.core.annotations.ManagerAuth;
|
import com.core.common.Cools;
|
import com.core.common.DateUtils;
|
import com.core.common.R;
|
import com.core.common.SnowflakeIdWorker;
|
import com.core.exception.CoolException;
|
import com.zy.sc.common.service.GeoService;
|
import com.zy.sc.common.web.BaseController;
|
import com.zy.sc.manager.controller.param.MobileIssueParam;
|
import com.zy.sc.manager.controller.result.AppHostIssueVo;
|
import com.zy.sc.manager.controller.result.AppIssueVo;
|
import com.zy.sc.manager.entity.Issue;
|
import com.zy.sc.manager.entity.IssueType;
|
import com.zy.sc.manager.service.IssueService;
|
import com.zy.sc.manager.service.IssueTypeService;
|
import com.zy.sc.system.entity.Host;
|
import com.zy.sc.system.service.HostService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.*;
|
|
/**
|
* Created by vincent on 2021/12/20
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("app")
|
public class AppController extends BaseController {
|
|
public static final String REGEX_MOBILE = "^((13[0-9])|(14[5|7])|(15([0-3]|[5-9]))|(17[013678])|(18[0,5-9]))\\d{8}$";
|
|
@Autowired
|
private HostService hostService;
|
@Autowired
|
private IssueTypeService issueTypeService;
|
@Autowired
|
private IssueService issueService;
|
@Autowired
|
private SnowflakeIdWorker snowflakeIdWorker;
|
@Autowired
|
private GeoService geoService;
|
|
@RequestMapping("/host/list/auth")
|
@ManagerAuth
|
public R hostList(){
|
Long hostId = getHostId();
|
Wrapper<Host> wrapper = new EntityWrapper<Host>().orderBy("id");
|
if (hostId != null) {
|
wrapper.eq("id", hostId);
|
}
|
List<Host> hostList = hostService.selectList(wrapper);
|
return R.ok().add(hostList);
|
}
|
|
@RequestMapping("/issue/type/auth")
|
public R issueType(){
|
List<IssueType> issueTypes = issueTypeService.selectList(new EntityWrapper<IssueType>().orderBy("id"));
|
return R.ok().add(issueTypes);
|
}
|
|
@RequestMapping("/issue/save/auth")
|
@ManagerAuth(memo = "故障上报")
|
public R issueSave(MobileIssueParam param){
|
if (Cools.isEmpty(param.getHostName())) {
|
return R.error("请选择所属项目");
|
}
|
Host host = hostService.selectByName(param.getHostName());
|
if (Cools.isEmpty(param.getIssueTypeName())) {
|
return R.error("请选择故障类型");
|
}
|
IssueType issueType = issueTypeService.selectByName(param.getIssueTypeName());
|
if (Cools.isEmpty(param.getTel())) {
|
return R.error("请输入联系方式");
|
}
|
if (!param.getTel().matches(REGEX_MOBILE)) {
|
return R.error("请输入正确的手机号");
|
}
|
if (Cools.isEmpty(param.getTitle())) {
|
return R.error("请输入问题概述");
|
}
|
Date now = new Date();
|
Date startTime = DateUtils.convert(param.getStartTime(), DateUtils.yyyyMMdd_F);
|
// 保存故障
|
Issue issue = new Issue(
|
String.valueOf(snowflakeIdWorker.nextId()), // 故障编号
|
host.getId(), // 所属项目
|
issueType.getId(), // 故障类型
|
param.getTitle(), // 问题概述
|
null, // 故障原因
|
null, // 解决办法
|
JSONArray.toJSONString(param.getVideoSrc()), // 文件列表
|
JSONArray.toJSONString(param.getImgArr()), // 图片
|
startTime, // 发生日期
|
null, // 处理日期
|
null, // 更新日期
|
param.getDiscoverer(), // 发现人
|
param.getTel(), // 联系方式
|
null, // 供应商
|
2, //
|
1, // 状态
|
getUserId(), // 添加人员
|
now, // 添加时间
|
getUserId(), // 修改人员
|
now, // 修改时间
|
param.getMemo() // 备注
|
);
|
if (!issueService.insert(issue)) {
|
throw new CoolException("反馈失败，请联系管理员");
|
}
|
return R.ok("问题上报成功");
|
}
|
|
@RequestMapping("/issue/list/auth")
|
@ManagerAuth
|
public R sensorList(@RequestParam(required = false) String condition){
|
Wrapper<Issue> wrapper = new EntityWrapper<Issue>()
|
.like("title", condition)
|
.orderBy("settle").orderBy("create_time", false);
|
Long hostId = getHostId();
|
if (hostId != null) {
|
wrapper.eq("host_id", hostId);
|
}
|
List<Issue> issues = issueService.selectList(wrapper);
|
List<AppHostIssueVo> result = new ArrayList<>();
|
Set<Long> hostSet = new HashSet<>();
|
for (Issue issue : issues) {
|
AppIssueVo vo = new AppIssueVo();
|
vo.setIssueId(issue.getId());
|
vo.setTitle(issue.getTitle().length()>12?issue.getTitle().substring(0, 12):issue.getTitle());
|
vo.setStartTime(issue.getStartTime$().length()>11?issue.getStartTime$().substring(0, 11):issue.getStartTime$());
|
vo.setSettle(issue.getSettle$());
|
|
if (!hostSet.contains(issue.getHostId())) {
|
hostSet.add(issue.getHostId());
|
Host host = hostService.selectById(issue.getHostId());
|
AppHostIssueVo hostVo = new AppHostIssueVo();
|
hostVo.setHostId(host.getId());
|
hostVo.setHostName(host.getName());
|
result.add(hostVo);
|
hostVo.getIssues().add(vo);
|
} else {
|
for (AppHostIssueVo hostVo : result) {
|
if (hostVo.getHostId().equals(issue.getHostId())) {
|
hostVo.getIssues().add(vo);
|
}
|
}
|
}
|
}
|
return R.ok().add(result);
|
}
|
|
@RequestMapping("/issue/detl/auth")
|
@ManagerAuth
|
public R issueDetl(@RequestParam Long issueId){
|
return R.ok().add(issueService.selectById(issueId));
|
}
|
|
}
|
