Commit c04082e8 authored by co_dengxiongwen's avatar co_dengxiongwen

切换人工/节能,室外气象站接口

parent f1969325
package com.devplatform.admin.modules.eq.controller;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.devplatform.admin.common.utils.AbstractController;
import com.devplatform.admin.common.utils.Constants;
import com.devplatform.admin.modules.eq.service.EquipmentService;
import com.devplatform.admin.modules.sys.bean.SysSystemParams;
import com.devplatform.admin.modules.sys.bean.SysSystemRunningTime;
import com.devplatform.admin.modules.sys.service.SysSystemParamsService;
import com.devplatform.admin.modules.sys.service.SysSystemRunningTimeService;
import com.devplatform.common.util.R;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
......@@ -10,6 +16,7 @@ import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Date;
import java.util.List;
import java.util.Map;
......@@ -23,6 +30,10 @@ import java.util.Map;
public class EquipmentController extends AbstractController {
@Autowired
private EquipmentService equipmentService;
@Autowired
private SysSystemParamsService sysSystemParamsService;
@Autowired
private SysSystemRunningTimeService sysSystemRunningTimeService;
/**
* 获取每个设备最新的参数值
......@@ -34,4 +45,35 @@ public class EquipmentController extends AbstractController {
List<Map<String,Object>> list = equipmentService.getList();
return R.ok().put("list", list);
}
/**
* 切换人工/节能模式
* @return
*/
@ApiOperation(value="切换人工/节能模式", notes="切换人工/节能模式")
@GetMapping("/changeType")
public R changeType(Integer type) {
Date time = new Date();
SysSystemParams sysSystemParams = new SysSystemParams();
sysSystemParams.setId(Constants.STRING_1);
sysSystemParams.setType(type);
sysSystemParams.setUpdateTime(time);
sysSystemParamsService.update(sysSystemParams,new LambdaQueryWrapper<SysSystemParams>()
.eq(SysSystemParams::getId,Constants.STRING_1));
SysSystemRunningTime sysSystemRunningTime = sysSystemRunningTimeService.getOne(new LambdaQueryWrapper<SysSystemRunningTime>()
.orderByDesc(SysSystemRunningTime::getUpdateTime).last("limit 1"));
sysSystemRunningTime.setEndTime(time);
sysSystemRunningTime.setUpdateTime(time);
sysSystemRunningTimeService.update(sysSystemRunningTime,new LambdaQueryWrapper<SysSystemRunningTime>()
.eq(SysSystemRunningTime::getId,sysSystemRunningTime.getId()));
SysSystemRunningTime temp = new SysSystemRunningTime();
temp.setStartTime(time);
temp.setType(type);
temp.setEndTime(time);
temp.setUpdateTime(time);
sysSystemRunningTimeService.save(temp);
return R.ok();
}
}
package com.devplatform.admin.modules.eq.controller;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.devplatform.admin.common.utils.AbstractController;
import com.devplatform.admin.common.utils.Constants;
import com.devplatform.admin.common.utils.DateUtil;
import com.devplatform.admin.modules.eq.bean.SwqxzInfoHour;
import com.devplatform.admin.modules.eq.model.SwqxzInfoHourModel;
import com.devplatform.admin.modules.eq.service.SwqxzInfoHourService;
import com.devplatform.common.util.R;
import com.devplatform.common.util.StringUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
/**
* 看板
* @author dxw
......@@ -13,5 +27,79 @@ import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/kanban")
public class KanBanController extends AbstractController {
@Autowired
private SwqxzInfoHourService swqxzInfoHourService;
/**
* 获取室外气象站数据
* @return
*/
@ApiOperation(value="获取室外气象站数据", notes="获取室外气象站数据")
@GetMapping("/getSwqxzInfo")
public R getSwqxzInfo() {
SwqxzInfoHourModel model = new SwqxzInfoHourModel();
if(StringUtil.isEmpty(model.getSort())){
model.setSort("create_time");
}
List<SwqxzInfoHour> list = swqxzInfoHourService.queryPageList(model);
return R.ok().put("list", getMyPage(list,model));
}
/**
* 获取室外气象站数据
* @return
*/
@ApiOperation(value="获取室外气象站数据", notes="获取室外气象站数据")
@GetMapping("/getSwqxzInfo")
public R getSwqxzInfoTj() {
List<SwqxzInfoHour> list = swqxzInfoHourService.list(new LambdaQueryWrapper<SwqxzInfoHour>().orderByAsc(SwqxzInfoHour::getCreateTime));
//还未写完
List<String> temperatureList = new ArrayList<String>();
List<String> humidityList = new ArrayList<String>();
List<String> windSpeedList = new ArrayList<String>();
List<String> windDirectionList = new ArrayList<String>();
List<String> illuminanceList = new ArrayList<String>();
List<String> carbonDioxideList = new ArrayList<String>();
List<String> fineParticlesList = new ArrayList<String>();
List<String> radiationList = new ArrayList<String>();
List<List<String>> allList = new ArrayList<List<String>>();
for (int i = 0; i < Constants.INT_24; i++) {
Boolean flag = true;
for(SwqxzInfoHour swqxzInfoHour : list){
String hour = DateUtil.convertDateToHour(swqxzInfoHour.getCreateTime());
if(i == Integer.parseInt(hour)){
temperatureList.add(swqxzInfoHour.getTemperature());
humidityList.add(swqxzInfoHour.getHumidity());
windSpeedList.add(swqxzInfoHour.getWindSpeed());
windDirectionList.add(swqxzInfoHour.getWindDirection());
illuminanceList.add(swqxzInfoHour.getIlluminance());
carbonDioxideList.add(swqxzInfoHour.getCarbonDioxide());
fineParticlesList.add(swqxzInfoHour.getFineParticles());
radiationList.add(swqxzInfoHour.getRadiation());
flag = false;
break;
}
}
if(flag){
temperatureList.add(Constants.STRING_0);
humidityList.add(Constants.STRING_0);
windSpeedList.add(Constants.STRING_0);
windDirectionList.add(Constants.STRING_0);
illuminanceList.add(Constants.STRING_0);
carbonDioxideList.add(Constants.STRING_0);
fineParticlesList.add(Constants.STRING_0);
radiationList.add(Constants.STRING_0);
}
}
allList.add(temperatureList);
allList.add(humidityList);
allList.add(windSpeedList);
allList.add(windDirectionList);
allList.add(illuminanceList);
allList.add(carbonDioxideList);
allList.add(fineParticlesList);
allList.add(radiationList);
return R.ok().put("list", allList);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment