|  |  |  | 
|---|
|  |  |  | import io.swagger.annotations.ApiOperation; | 
|---|
|  |  |  | import lombok.extern.slf4j.Slf4j; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | import org.springframework.util.ObjectUtils; | 
|---|
|  |  |  | import org.springframework.web.bind.annotation.RequestBody; | 
|---|
|  |  |  | import org.springframework.web.bind.annotation.RequestMapping; | 
|---|
|  |  |  | import org.springframework.web.bind.annotation.RequestMethod; | 
|---|
|  |  |  | 
|---|
|  |  |  | import java.util.List; | 
|---|
|  |  |  | import java.util.Map; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.baomidou.mybatisplus.core.metadata.IPage; | 
|---|
|  |  |  | import javax.servlet.http.HttpServletRequest; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; | 
|---|
|  |  |  | import com.moral.api.entity.Device; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.moral.api.entity.SpecialDevice; | 
|---|
|  |  |  | import com.moral.api.entity.Version; | 
|---|
|  |  |  | import com.moral.api.service.DeviceService; | 
|---|
|  |  |  | import com.moral.api.service.SpecialDeviceService; | 
|---|
|  |  |  | import com.moral.api.service.VersionService; | 
|---|
|  |  |  | import com.moral.constant.Constants; | 
|---|
|  |  |  | import com.moral.constant.ResponseCodeEnum; | 
|---|
|  |  |  | import com.moral.constant.ResultMessage; | 
|---|
|  |  |  | import com.moral.util.PageResult; | 
|---|
|  |  |  | import com.moral.util.WebUtils; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Slf4j | 
|---|
|  |  |  | @Api(tags = {"设备管理"}) | 
|---|
|  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private DeviceService deviceService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private VersionService versionService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SpecialDeviceService specialDeviceService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @ApiOperation(value = "添加设备", notes = "添加设备") | 
|---|
|  |  |  | @ApiImplicitParams({ | 
|---|
|  |  |  | @ApiImplicitParam(name = "token", value = "token", required = true, paramType = "header", dataType = "String") | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @RequestMapping(value = "insert", method = RequestMethod.POST) | 
|---|
|  |  |  | public ResultMessage insert(Device device) { | 
|---|
|  |  |  | public ResultMessage insert(@RequestBody Device device) { | 
|---|
|  |  |  | String name = device.getName(); | 
|---|
|  |  |  | String mac = device.getMac(); | 
|---|
|  |  |  | Integer monitorPointId = device.getMonitorPointId(); | 
|---|
|  |  |  | Integer versionId = device.getDeviceVersionId(); | 
|---|
|  |  |  | if (ObjectUtils.isEmpty(name) || ObjectUtils.isEmpty(mac) || ObjectUtils.isEmpty(monitorPointId) || ObjectUtils.isEmpty(versionId)) { | 
|---|
|  |  |  | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), | 
|---|
|  |  |  | ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //判断mac是否已存在,普通设备表和特殊设备表都要判断 | 
|---|
|  |  |  | QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); | 
|---|
|  |  |  | queryWrapper.eq("mac", device.getMac()).eq("is_delete", Constants.NOT_DELETE); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | QueryWrapper<SpecialDevice> specialDeviceQueryWrapper = new QueryWrapper<>(); | 
|---|
|  |  |  | specialDeviceQueryWrapper.eq("mac", device.getMac()).eq("is_delete", Constants.NOT_DELETE); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (deviceService.getOne(queryWrapper) != null || specialDeviceService.getOne(specialDeviceQueryWrapper) != null) { | 
|---|
|  |  |  | return ResultMessage.fail(ResponseCodeEnum.MAC_IS_EXIST.getCode(), ResponseCodeEnum.MAC_IS_EXIST.getMsg()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | deviceService.insert(device); | 
|---|
|  |  |  | return ResultMessage.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @RequestMapping(value = "delete", method = RequestMethod.GET) | 
|---|
|  |  |  | public ResultMessage delete(Integer deviceId) { | 
|---|
|  |  |  | if (deviceId == null) { | 
|---|
|  |  |  | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), | 
|---|
|  |  |  | ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | deviceService.delete(deviceId); | 
|---|
|  |  |  | return ResultMessage.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | @ApiImplicitParam(name = "token", value = "token", required = true, paramType = "header", dataType = "String") | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @RequestMapping(value = "update", method = RequestMethod.POST) | 
|---|
|  |  |  | public ResultMessage update(Device device) { | 
|---|
|  |  |  | public ResultMessage update(@RequestBody Device device) { | 
|---|
|  |  |  | if (device.getId() == null) { | 
|---|
|  |  |  | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), | 
|---|
|  |  |  | ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (device.getMac() != null) { | 
|---|
|  |  |  | //判断mac是否已存在,普通设备表和特殊设备表都要判断 | 
|---|
|  |  |  | QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); | 
|---|
|  |  |  | queryWrapper.eq("mac", device.getMac()).eq("is_delete", Constants.NOT_DELETE); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | QueryWrapper<SpecialDevice> specialDeviceQueryWrapper = new QueryWrapper<>(); | 
|---|
|  |  |  | specialDeviceQueryWrapper.eq("mac", device.getMac()).eq("is_delete", Constants.NOT_DELETE); | 
|---|
|  |  |  | if (deviceService.getOne(queryWrapper) != null || specialDeviceService.getOne(specialDeviceQueryWrapper) != null) { | 
|---|
|  |  |  | return ResultMessage.fail(ResponseCodeEnum.MAC_IS_EXIST.getCode(), ResponseCodeEnum.MAC_IS_EXIST.getMsg()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | deviceService.update(device); | 
|---|
|  |  |  | return ResultMessage.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @ApiOperation(value = "分页设备列表", notes = "分页设备列表") | 
|---|
|  |  |  | @ApiImplicitParams({ | 
|---|
|  |  |  | @ApiImplicitParam(name = "page", value = "当前页", required = false, paramType = "query", dataType = "Integer"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "size", value = "每页条数", required = false, paramType = "query", dataType = "Integer"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "page", value = "当前页", required = false, paramType = "query", dataType = "int"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "size", value = "每页条数", required = false, paramType = "query", dataType = "int"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "order", value = "排序字段", required = false, paramType = "query", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "orderType", value = "排序类型,升序:0,降序:1", required = false, paramType = "query", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "token", value = "token", required = true, paramType = "header", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "name", value = "设备名称模糊查询", required = false, paramType = "query", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "mac", value = "mac模糊查询", required = false, paramType = "query", dataType = "String"), | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @RequestMapping(value = "select", method = RequestMethod.POST) | 
|---|
|  |  |  | public ResultMessage select(@RequestBody Map<String, Object> parameters) { | 
|---|
|  |  |  | IPage<Device> page = deviceService.selectDevices(parameters); | 
|---|
|  |  |  | PageResult<Device> pageResult = new PageResult<>( | 
|---|
|  |  |  | page.getTotal(), page.getPages(), page.getRecords() | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | return ResultMessage.ok(pageResult); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | @ApiImplicitParam(name = "organizationId", value = "根据组织查询", required = false, paramType = "query", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "monitorPointId", value = "站点id", required = false, paramType = "query", dataType = "String") | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @ApiOperation(value = "查询设备信息", notes = "查询设备信息") | 
|---|
|  |  |  | @ApiImplicitParams({ | 
|---|
|  |  |  | @ApiImplicitParam(name = "token", value = "token", required = true, paramType = "header", dataType = "String") | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @RequestMapping(value = "deviceInfo", method = RequestMethod.GET) | 
|---|
|  |  |  | public ResultMessage selectDeviceInfoById(Integer deviceId) { | 
|---|
|  |  |  | Map<String, Object> result = deviceService.selectDeviceInfoById(deviceId); | 
|---|
|  |  |  | @RequestMapping(value = "select", method = RequestMethod.GET) | 
|---|
|  |  |  | public ResultMessage select(HttpServletRequest request) { | 
|---|
|  |  |  | Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); | 
|---|
|  |  |  | Map<String, Object> result = deviceService.selectDevices(parameters); | 
|---|
|  |  |  | return ResultMessage.ok(result); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @ApiOperation(value = "根据组织查设备", notes = "根据组织查设备") | 
|---|
|  |  |  | @ApiImplicitParams({ | 
|---|
|  |  |  | @ApiImplicitParam(name = "token", value = "token", required = true, paramType = "header", dataType = "String") | 
|---|
|  |  |  | @ApiImplicitParam(name = "page", value = "当前页", required = false, paramType = "query", dataType = "int"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "size", value = "每页条数", required = false, paramType = "query", dataType = "int"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "order", value = "排序字段", required = false, paramType = "query", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "orderType", value = "排序类型,升序:0,降序:1", required = false, paramType = "query", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "token", value = "token", required = true, paramType = "header", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "organizationId", value = "组织id", required = false, paramType = "query", dataType = "int"), | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @RequestMapping(value = "devicesByOrgId", method = RequestMethod.GET) | 
|---|
|  |  |  | public ResultMessage selectDevicesByOrg(Integer orgId) { | 
|---|
|  |  |  | List<Map<String, Object>> devices = deviceService.selectDevicesByOrgId(orgId); | 
|---|
|  |  |  | public ResultMessage selectDevicesByOrg(HttpServletRequest request) { | 
|---|
|  |  |  | Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); | 
|---|
|  |  |  | if (parameters.get("organizationId") == null) { | 
|---|
|  |  |  | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), | 
|---|
|  |  |  | ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | Map<String, Object> devices = deviceService.selectDevicesByOrgId(parameters); | 
|---|
|  |  |  | return ResultMessage.ok(devices); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @ApiOperation(value = "根据站点查设备", notes = "根据站点查设备") | 
|---|
|  |  |  | @ApiImplicitParams({ | 
|---|
|  |  |  | @ApiImplicitParam(name = "token", value = "token", required = true, paramType = "header", dataType = "String") | 
|---|
|  |  |  | @ApiImplicitParam(name = "page", value = "当前页", required = false, paramType = "query", dataType = "int"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "size", value = "每页条数", required = false, paramType = "query", dataType = "int"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "order", value = "排序字段", required = false, paramType = "query", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "orderType", value = "排序类型,升序:0,降序:1", required = false, paramType = "query", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "token", value = "token", required = true, paramType = "header", dataType = "String"), | 
|---|
|  |  |  | @ApiImplicitParam(name = "monitorPointId", value = "站点id", required = false, paramType = "query", dataType = "int"), | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @RequestMapping(value = "devicesByMpId", method = RequestMethod.GET) | 
|---|
|  |  |  | public ResultMessage selectDevicesByMp(Integer mpId) { | 
|---|
|  |  |  | List<Map<String, Object>> devices = deviceService.selectDevicesByMpId(mpId); | 
|---|
|  |  |  | public ResultMessage selectDevicesByMp(HttpServletRequest request) { | 
|---|
|  |  |  | Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); | 
|---|
|  |  |  | if (parameters.get("monitorPointId") == null) { | 
|---|
|  |  |  | return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), | 
|---|
|  |  |  | ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | Map<String, Object> devices = deviceService.selectDevicesByMpId(parameters); | 
|---|
|  |  |  | return ResultMessage.ok(devices); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @ApiOperation(value = "型号列表", notes = "型号列表") | 
|---|
|  |  |  | @ApiImplicitParams({ | 
|---|
|  |  |  | @ApiImplicitParam(name = "token", value = "token", required = true, paramType = "header", dataType = "String") | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @RequestMapping(value = "versions", method = RequestMethod.GET) | 
|---|
|  |  |  | public ResultMessage selectVersions() { | 
|---|
|  |  |  | return null; | 
|---|
|  |  |  | QueryWrapper<Version> queryWrapper = new QueryWrapper<>(); | 
|---|
|  |  |  | queryWrapper.select("id", "name").eq("is_delete", Constants.NOT_DELETE); | 
|---|
|  |  |  | List<Map<String, Object>> maps = versionService.listMaps(queryWrapper); | 
|---|
|  |  |  | return ResultMessage.ok(maps); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @ApiOperation(value = "维护人列表", notes = "维护人列表") | 
|---|
|  |  |  | 
|---|
|  |  |  | List<Map<String, Object>> professions = deviceService.selectDeviceDictData(Constants.SYSTEM_DICT_TYPE_PURCHASER); | 
|---|
|  |  |  | return ResultMessage.ok(professions); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RequestMapping(value = "selectMonitorPiontAndDeviceByOrgId", method = RequestMethod.GET) | 
|---|
|  |  |  | public ResultMessage selectMonitorPiontAndDeviceByOrgId(HttpServletRequest request){ | 
|---|
|  |  |  | Map parames = WebUtils.getParametersStartingWith(request,null); | 
|---|
|  |  |  | int id = Integer.parseInt(parames.get("organization_id").toString()); | 
|---|
|  |  |  | List<Map<String, Object>> maps = deviceService.selectMonitorPiontAndDeviceByOrgId(id); | 
|---|
|  |  |  | return ResultMessage.ok(maps); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|