package com.moral.api.controller; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.moral.api.entity.Device; import com.moral.api.entity.Organization; import com.moral.api.mapper.DeviceMapper; import com.moral.api.mapper.OrganizationMapper; import com.moral.api.service.AlarmInfoService; import com.moral.api.service.HistoryHourlyService; import com.moral.api.vo.HistoryHourlyVo; import com.moral.constant.Constants; import com.moral.constant.ResponseCodeEnum; import com.moral.constant.ResultMessage; import com.moral.util.WebUtils; import io.swagger.annotations.Api; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.util.List; import java.util.Map; /** * @program: screen * @description: 设备小时数据 * @author: lizijie * @create: 2021-11-10 16:05 **/ @Slf4j @Api(tags = {"设备小时数据"}) @RestController @CrossOrigin(origins = "*", maxAge = 3600) @RequestMapping("/historyHourly") public class HistoryHourlyController { @Resource private OrganizationMapper organizationMapper; @Resource private DeviceMapper deviceMapper; @Resource private HistoryHourlyService historyHourlyService; @RequestMapping(value = "getLastHourDataByOrgIdAndSensorCode", method = RequestMethod.GET) @ResponseBody public ResultMessage getLastHourDataByOrgIdAndSensorCode(HttpServletRequest request){ Map parameters = WebUtils.getParametersStartingWith(request,null); Object orgid = parameters.get("organization_id"); Object sensorCode = parameters.get("sensor_code"); if (ObjectUtils.isEmpty(orgid) || ObjectUtils.isEmpty(sensorCode)){ return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); } Organization organization = organizationMapper.selectById(Integer.parseInt(orgid.toString())); if (ObjectUtils.isEmpty(organization)){ return ResultMessage.fail(ResponseCodeEnum.ORGANIZATION_NOT_EXIST.getCode(), ResponseCodeEnum.ORGANIZATION_NOT_EXIST.getMsg()); } Map resultMap = historyHourlyService.getLastHourDataByOrgIdAndSensorCode(parameters); return ResultMessage.ok(resultMap); } @RequestMapping(value = "getLastTwelveHourDataByOrgIdAndSensorCode", method = RequestMethod.GET) @ResponseBody public ResultMessage getLastTwelveHourDataByOrgIdAndSensorCode(HttpServletRequest request){ Map parameters = WebUtils.getParametersStartingWith(request,null); Object orgid = parameters.get("organization_id"); Object sensorCode = parameters.get("sensor_code"); if (ObjectUtils.isEmpty(orgid) || ObjectUtils.isEmpty(sensorCode)){ return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); } Organization organization = organizationMapper.selectById(Integer.parseInt(orgid.toString())); if (ObjectUtils.isEmpty(organization)){ return ResultMessage.fail(ResponseCodeEnum.ORGANIZATION_NOT_EXIST.getCode(), ResponseCodeEnum.ORGANIZATION_NOT_EXIST.getMsg()); } Map resultMap = historyHourlyService.getLastTwelveHourDataByOrgIdAndSensorCode(parameters); return ResultMessage.ok(resultMap); } @RequestMapping(value = "getHourCompleteDataByMacSensorCodeDate", method = RequestMethod.GET) @ResponseBody public ResultMessage getHourCompleteDataByMacSensorCodeDate(HttpServletRequest request){ Map parameters = WebUtils.getParametersStartingWith(request,null); Object mac = parameters.get("mac"); Object sensorCode = parameters.get("sensor_code"); // Object date = parameters.get("date"); Object startTime = parameters.get("startTime"); Object endTime = parameters.get("endTime"); if (ObjectUtils.isEmpty(mac) || ObjectUtils.isEmpty(sensorCode) || ObjectUtils.isEmpty(startTime)){ return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); } QueryWrapper deviceQueryWrapper = new QueryWrapper<>(); deviceQueryWrapper.eq("is_delete",Constants.NOT_DELETE); deviceQueryWrapper.eq("mac",mac); Device device = deviceMapper.selectOne(deviceQueryWrapper); if (ObjectUtils.isEmpty(device)){ return ResultMessage.fail(ResponseCodeEnum.ORGANIZATION_NOT_EXIST.getCode(), ResponseCodeEnum.ORGANIZATION_NOT_EXIST.getMsg()); } List> resultList = historyHourlyService.getHourCompleteDataByMacSensorCodeDate(parameters); return ResultMessage.ok(resultList); } @RequestMapping(value = "test2", method = RequestMethod.GET) @ResponseBody public ResultMessage test2(HttpServletRequest request){ Map parameters = WebUtils.getParametersStartingWith(request,null); Object mac = parameters.get("mac"); Object sensorCode = parameters.get("sensor_code"); // Object date = parameters.get("date"); Object startTime = parameters.get("startTime"); Object endTime = parameters.get("endTime"); if (ObjectUtils.isEmpty(mac) || ObjectUtils.isEmpty(sensorCode) || ObjectUtils.isEmpty(startTime)|| ObjectUtils.isEmpty(endTime)){ return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); } QueryWrapper deviceQueryWrapper = new QueryWrapper<>(); deviceQueryWrapper.eq("is_delete",Constants.NOT_DELETE); deviceQueryWrapper.eq("mac",mac); Device device = deviceMapper.selectOne(deviceQueryWrapper); if (ObjectUtils.isEmpty(device)){ return ResultMessage.fail(ResponseCodeEnum.ORGANIZATION_NOT_EXIST.getCode(), ResponseCodeEnum.ORGANIZATION_NOT_EXIST.getMsg()); } List> resultList = historyHourlyService.getHourCompleteDataByMacSensorCodeDate(parameters); return ResultMessage.ok(resultList); } @RequestMapping(value = "historyHourlyTest", method = RequestMethod.POST) public ResultMessage historyHourlyTest(HistoryHourlyVo historyHourlyVo){ historyHourlyService.historyHourly(historyHourlyVo); return ResultMessage.ok(); } }