mt-ck/mt-qj-wms-hd
7
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

查询能源消耗

Browse Source
This commit is contained in:
李广豪 2022-03-05 18:21:13 +08:00
parent bb957ab4ea
commit edd0f8c77b
3 changed files with 174 additions and 135 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
6.program/wms-empty/src/main/java/com/mt/wms/empty/controller/CurrTaskController.java
View File

@ -269,8 +269,8 @@ public class CurrTaskController extends BaseController {
} }
@PostMapping(value = "runTask") @PostMapping(value = "runTask")
@ApiOperation(value = "执行任务") @ApiOperation(value = "执行任务")
public R<String> runTask(@Validated @RequestBody Long taskId) { public R<String> runTask(@Validated @RequestBody IdParam param) {
//点击执行按钮会判断当前任务是否为自动任务，如果是自动任务会去自动任务查一下该自动任务的上一步是否已完成（仅非一步时） //点击执行按钮会判断当前任务是否为自动任务，如果是自动任务会去自动任务查一下该自动任务的上一步是否已完成（仅非一步时）
return currTaskService.runTask(taskId); return currTaskService.runTask(param.getId());
} }
} }

300
6.program/wms-empty/src/main/java/com/mt/wms/empty/controller/EnergyController.java
View File

@ -223,39 +223,48 @@ public class EnergyController extends BaseController {
//传入任务号，窑炉号，查询消耗数据，返回json字符串 //传入任务号，窑炉号，查询消耗数据，返回json字符串
JSONObject jsonObject=new JSONObject(); JSONObject jsonObject=new JSONObject();
ConsumeDataVo consumeDataVo=ConsumeDataVo.builder().build(); ConsumeDataVo consumeDataVo=ConsumeDataVo.builder().build();
Map map=new HashMap();
//电能消耗 //电能消耗
List<ParEleValue> parEleValueList = parEleValueServiceBiz.list(new QueryWrapper<ParEleValue>() List<ParEleValue> parEleValueList = parEleValueServiceBiz.list(new QueryWrapper<ParEleValue>()
.eq(ParEleValue.KILN_ID, electricQueryParam.getKilnId()) .eq(ParEleValue.KILN_ID, kilnId)
.eq(ParEleValue.TASK_ID, electricQueryParam.getTaskId())); .eq(ParEleValue.TASK_ID, electricQueryParam.getTaskId()));
if (parEleValueList.size()>0){ if (parEleValueList.size()>0){
List eleList=new ArrayList(); List eleList=new ArrayList();
//电能消耗 //电能消耗
List<ConsumeDataVo> eleConsume=new ArrayList<>(); List eleConsume=new ArrayList<>();
//A向电压 //A向电压
List<ConsumeDataVo> aVolConsume=new ArrayList<>(); List aVolConsume=new ArrayList<>();
//B向电压 //B向电压
List<ConsumeDataVo> bVolConsume=new ArrayList<>(); List bVolConsume=new ArrayList<>();
//C向电压 //C向电压
List<ConsumeDataVo> cVolConsume=new ArrayList<>(); List cVolConsume=new ArrayList<>();
for (ParEleValue parEleValue:parEleValueList for (ParEleValue parEleValue:parEleValueList
) { ) {
consumeDataVo.setCreateTime(parEleValue.getCreateTime()); map.put("time",parEleValue.getCreateTime());
consumeDataVo.setValue(parEleValue.getTotalBat()); map.put("value",parEleValue.getTotalBat());
consumeDataVo.setName("耗电量"); map.put("name","耗电量");
consumeDataVo.setUnit("KW"); map.put("unit","KW");
eleConsume.add(consumeDataVo); eleConsume.add(JSONObject.toJSON(map));
consumeDataVo.setValue(parEleValue.getAVoltagevValue()); map.clear();
consumeDataVo.setName("A向电压"); map.put("time",parEleValue.getCreateTime());
consumeDataVo.setUnit("V"); map.put("value",parEleValue.getAVoltagevValue());
aVolConsume.add(consumeDataVo); map.put("name","A向电压");
consumeDataVo.setValue(parEleValue.getBVoltagevValue()); map.put("unit","V");
consumeDataVo.setName("B向电压"); aVolConsume.add(JSONObject.toJSON(map));
consumeDataVo.setUnit("V"); map.clear();
bVolConsume.add(consumeDataVo); map.put("time",parEleValue.getCreateTime());
consumeDataVo.setValue(parEleValue.getCVoltagevValue()); map.put("value",parEleValue.getBVoltagevValue());
consumeDataVo.setName("C向电压"); map.put("name","B向电压");
consumeDataVo.setUnit("V"); map.put("unit","V");
cVolConsume.add(consumeDataVo); bVolConsume.add(JSONObject.toJSON(map));
map.clear();
map.put("time",parEleValue.getCreateTime());
map.put("value",parEleValue.getCVoltagevValue());
map.put("name","C向电压");
map.put("unit","V");
cVolConsume.add(JSONObject.toJSON(map));
map.clear();
} }
eleList.add(eleConsume); eleList.add(eleConsume);
eleList.add(aVolConsume); eleList.add(aVolConsume);
@ -265,38 +274,45 @@ public class EnergyController extends BaseController {
} }
//氮气、甲醇、丙烷、氨气消耗量 //氮气、甲醇、丙烷、氨气消耗量
List<ParGasValue> parGasValueList = parGasValueServiceBiz.list(new QueryWrapper<ParGasValue>() List<ParGasValue> parGasValueList = parGasValueServiceBiz.list(new QueryWrapper<ParGasValue>()
.eq(ParEleValue.KILN_ID, electricQueryParam.getKilnId()) .eq(ParEleValue.KILN_ID, kilnId)
.eq(ParEleValue.TASK_ID, electricQueryParam.getTaskId())); .eq(ParEleValue.TASK_ID, electricQueryParam.getTaskId()));
if (parGasValueList.size()>0){ if (parGasValueList.size()>0){
if (kilnType==1){ if (kilnType==1){
List gasList=new ArrayList(); List gasList=new ArrayList();
//氮气 //氮气
List<ConsumeDataVo> nitConsume=new ArrayList<>(); List nitConsume=new ArrayList<>();
//甲醇 //甲醇
List<ConsumeDataVo> metConsume=new ArrayList<>(); List metConsume=new ArrayList<>();
//丙烷 //丙烷
List<ConsumeDataVo> propaneConsume=new ArrayList<>(); List propaneConsume=new ArrayList<>();
//氨气 //氨气
List<ConsumeDataVo> ammoniaConsume=new ArrayList<>(); List ammoniaConsume=new ArrayList<>();
for (ParGasValue parGasValue:parGasValueList for (ParGasValue parGasValue:parGasValueList
) { ) {
consumeDataVo.setCreateTime(parGasValue.getCreateTime()); map.put("time",parGasValue.getCreateTime());
consumeDataVo.setValue(parGasValue.getNitFlowValue()); map.put("value",parGasValue.getNitFlowValue());
consumeDataVo.setName("氮气"); map.put("name","氮气");
consumeDataVo.setUnit("m³"); map.put("unit","m³");
nitConsume.add(consumeDataVo); nitConsume.add(JSONObject.toJSON(map));
consumeDataVo.setValue(parGasValue.getMethanolFlow()); map.clear();
consumeDataVo.setName("甲醇"); map.put("time",parGasValue.getCreateTime());
consumeDataVo.setUnit("m³"); map.put("value",parGasValue.getMethanolFlow());
metConsume.add(consumeDataVo); map.put("name","甲醇");
consumeDataVo.setValue(parGasValue.getPropaneFlow()); map.put("unit","m³");
consumeDataVo.setName("丙烷"); metConsume.add(JSONObject.toJSON(map));
consumeDataVo.setUnit("m³"); map.clear();
propaneConsume.add(consumeDataVo); map.put("time",parGasValue.getCreateTime());
consumeDataVo.setValue(parGasValue.getAmmoniaFlowValue()); map.put("value",parGasValue.getPropaneFlow());
consumeDataVo.setName("氨气"); map.put("name","丙烷");
consumeDataVo.setUnit("m³"); map.put("unit","m³");
ammoniaConsume.add(consumeDataVo); propaneConsume.add(JSONObject.toJSON(map));
map.clear();
map.put("time",parGasValue.getCreateTime());
map.put("value",parGasValue.getAmmoniaFlowValue());
map.put("name","氨气");
map.put("unit","m³");
ammoniaConsume.add(JSONObject.toJSON(map));
map.clear();
} }
gasList.add(nitConsume); gasList.add(nitConsume);
gasList.add(metConsume); gasList.add(metConsume);
@ -307,26 +323,31 @@ public class EnergyController extends BaseController {
if (kilnType==3){ if (kilnType==3){
List gasList=new ArrayList(); List gasList=new ArrayList();
//氮气 //氮气
List<ConsumeDataVo> nitConsume=new ArrayList<>(); List nitConsume=new ArrayList<>();
//二氧化碳 //二氧化碳
List<ConsumeDataVo> carbonConsume=new ArrayList<>(); List carbonConsume=new ArrayList<>();
//氨气 //氨气
List<ConsumeDataVo> ammoniaConsume=new ArrayList<>(); List ammoniaConsume=new ArrayList<>();
for (ParGasValue parGasValue:parGasValueList for (ParGasValue parGasValue:parGasValueList
) { ) {
consumeDataVo.setCreateTime(parGasValue.getCreateTime()); map.put("time",parGasValue.getCreateTime());
consumeDataVo.setValue(parGasValue.getNitFlowValue()); map.put("value",parGasValue.getNitFlowValue());
consumeDataVo.setName("氮气"); map.put("name","氮气");
consumeDataVo.setUnit("m³"); map.put("unit","m³");
nitConsume.add(consumeDataVo); nitConsume.add(JSONObject.toJSON(map));
consumeDataVo.setValue(parGasValue.getCarDioxideFlowValue()); map.clear();
consumeDataVo.setName("二氧化碳"); map.put("time",parGasValue.getCreateTime());
consumeDataVo.setUnit("m³"); map.put("value",parGasValue.getCarDioxideFlowValue());
carbonConsume.add(consumeDataVo); map.put("name","二氧化碳");
consumeDataVo.setValue(parGasValue.getAmmoniaFlowValue()); map.put("unit","m³");
consumeDataVo.setName("氨气"); carbonConsume.add(JSONObject.toJSON(map));
consumeDataVo.setUnit("m³"); map.clear();
ammoniaConsume.add(consumeDataVo); map.put("time",parGasValue.getCreateTime());
map.put("value",parGasValue.getAmmoniaFlowValue());
map.put("name","氨气");
map.put("unit","m³");
ammoniaConsume.add(JSONObject.toJSON(map));
map.clear();
} }
gasList.add(nitConsume); gasList.add(nitConsume);
gasList.add(carbonConsume); gasList.add(carbonConsume);
@ -336,24 +357,27 @@ public class EnergyController extends BaseController {
} }
//油搅拌转速趋势 //油搅拌转速趋势
List<ParRotSpeedValue> parRotSpeedValueList = parRotSpeedValueServiceBiz.list(new QueryWrapper<ParRotSpeedValue>() List<ParRotSpeedValue> parRotSpeedValueList = parRotSpeedValueServiceBiz.list(new QueryWrapper<ParRotSpeedValue>()
.eq(ParEleValue.KILN_ID, electricQueryParam.getKilnId()) .eq(ParEleValue.KILN_ID, kilnId)
.eq(ParEleValue.TASK_ID, electricQueryParam.getTaskId())); .eq(ParEleValue.TASK_ID, electricQueryParam.getTaskId()));
if (parRotSpeedValueList.size()>0){ if (parRotSpeedValueList.size()>0){
if (kilnType==1){ if (kilnType==1){
List rotList=new ArrayList(); List rotList=new ArrayList();
List<ConsumeDataVo> rot1Consume=new ArrayList<>(); List rot1Consume=new ArrayList<>();
List<ConsumeDataVo> rot2Consume=new ArrayList<>(); List rot2Consume=new ArrayList<>();
for (ParRotSpeedValue parRotSpeedValue:parRotSpeedValueList for (ParRotSpeedValue parRotSpeedValue:parRotSpeedValueList
) { ) {
consumeDataVo.setCreateTime(parRotSpeedValue.getCreateTime()); map.put("time",parRotSpeedValue.getCreateTime());
consumeDataVo.setValue(parRotSpeedValue.getOilStiSpeedAValue()); map.put("value",parRotSpeedValue.getOilStiSpeedAValue());
consumeDataVo.setName("1号油搅拌转速"); map.put("name","1号油搅拌转速");
consumeDataVo.setUnit("转/min"); map.put("unit","转/min");
rot1Consume.add(consumeDataVo); rot1Consume.add(JSONObject.toJSON(map));
consumeDataVo.setValue(parRotSpeedValue.getOilStiSpeedBValue()); map.clear();
consumeDataVo.setName("2号油搅拌转速"); map.put("time",parRotSpeedValue.getCreateTime());
consumeDataVo.setUnit("转/min"); map.put("value",parRotSpeedValue.getOilStiSpeedBValue());
rot2Consume.add(consumeDataVo); map.put("name","2号油搅拌转速");
map.put("unit","转/min");
rot2Consume.add(JSONObject.toJSON(map));
map.clear();
} }
rotList.add(rot1Consume); rotList.add(rot1Consume);
rotList.add(rot2Consume); rotList.add(rot2Consume);
@ -362,37 +386,41 @@ public class EnergyController extends BaseController {
} }
//温度趋势（实际温度、设定温度） //温度趋势（实际温度、设定温度）
List<ParTemValue> parTemValueList = parTemValueServiceBiz.list(new QueryWrapper<ParTemValue>() List<ParTemValue> parTemValueList = parTemValueServiceBiz.list(new QueryWrapper<ParTemValue>()
.eq(ParEleValue.KILN_ID, electricQueryParam.getKilnId()) .eq(ParEleValue.KILN_ID, kilnId)
.eq(ParEleValue.TASK_ID, electricQueryParam.getTaskId())); .eq(ParEleValue.TASK_ID, electricQueryParam.getTaskId()));
if (parTemValueList.size()>0){ if (parTemValueList.size()>0){
if (kilnType==1){ if (kilnType==1){
List tempList=new ArrayList(); List tempList=new ArrayList();
List<ConsumeDataVo> actualTempConsume=new ArrayList<>(); List actualTempConsume=new ArrayList<>();
List<ConsumeDataVo> setupTempConsume=new ArrayList<>(); List setupTempConsume=new ArrayList<>();
List<ConsumeDataVo> actualOilTempConsume=new ArrayList<>(); List actualOilTempConsume=new ArrayList<>();
List<ConsumeDataVo> setupOilTempConsume=new ArrayList<>(); List setupOilTempConsume=new ArrayList<>();
for (ParTemValue parTemValue:parTemValueList for (ParTemValue parTemValue:parTemValueList
) { ) {
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); map.put("time",parTemValue.getCreateTime());
consumeDataVo.setName("实际温度"); map.put("value",parTemValue.getActTemValue());
consumeDataVo.setValue(parTemValue.getActTemValue()); map.put("name","实际温度");
consumeDataVo.setUnit("℃"); map.put("unit","℃");
actualTempConsume.add(consumeDataVo); actualTempConsume.add(JSONObject.toJSON(map));
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); map.clear();
consumeDataVo.setName("设定温度"); map.put("time",parTemValue.getCreateTime());
consumeDataVo.setValue(parTemValue.getSetTemValue()); map.put("value",parTemValue.getSetTemValue());
consumeDataVo.setUnit("℃"); map.put("name","设定温度");
setupTempConsume.add(consumeDataVo); map.put("unit","℃");
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); setupTempConsume.add(JSONObject.toJSON(map));
consumeDataVo.setName("油槽实际温度"); map.clear();
consumeDataVo.setValue(parTemValue.getOilTankActTemValue()); map.put("time",parTemValue.getCreateTime());
consumeDataVo.setUnit("℃"); map.put("value",parTemValue.getOilTankActTemValue());
actualOilTempConsume.add(consumeDataVo); map.put("name","油槽实际温度");
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); map.put("unit","℃");
consumeDataVo.setName("油槽设定温度"); actualOilTempConsume.add(JSONObject.toJSON(map));
consumeDataVo.setValue(parTemValue.getOilTankSetTemValue()); map.clear();
consumeDataVo.setUnit("℃"); map.put("time",parTemValue.getCreateTime());
setupOilTempConsume.add(consumeDataVo); map.put("value",parTemValue.getOilTankSetTemValue());
map.put("name","油槽设定温度");
map.put("unit","℃");
setupOilTempConsume.add(JSONObject.toJSON(map));
map.clear();
} }
tempList.add(actualTempConsume); tempList.add(actualTempConsume);
tempList.add(setupTempConsume); tempList.add(setupTempConsume);
@ -402,20 +430,22 @@ public class EnergyController extends BaseController {
} }
if (kilnType==2){ if (kilnType==2){
List tempList=new ArrayList(); List tempList=new ArrayList();
List<ConsumeDataVo> actualTempConsume=new ArrayList<>(); List actualTempConsume=new ArrayList<>();
List<ConsumeDataVo> setupTempConsume=new ArrayList<>(); List setupTempConsume=new ArrayList<>();
for (ParTemValue parTemValue:parTemValueList for (ParTemValue parTemValue:parTemValueList
) { ) {
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); map.put("time",parTemValue.getCreateTime());
consumeDataVo.setName("实际温度"); map.put("value",parTemValue.getActTemValue());
consumeDataVo.setValue(parTemValue.getActTemValue()); map.put("name","实际温度");
consumeDataVo.setUnit("℃"); map.put("unit","℃");
actualTempConsume.add(consumeDataVo); actualTempConsume.add(JSONObject.toJSON(map));
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); map.clear();
consumeDataVo.setName("设定温度"); map.put("time",parTemValue.getCreateTime());
consumeDataVo.setValue(parTemValue.getSetTemValue()); map.put("value",parTemValue.getSetTemValue());
consumeDataVo.setUnit("℃"); map.put("name","设定温度");
setupTempConsume.add(consumeDataVo); map.put("unit","℃");
setupTempConsume.add(JSONObject.toJSON(map));
map.clear();
} }
tempList.add(actualTempConsume); tempList.add(actualTempConsume);
tempList.add(setupTempConsume); tempList.add(setupTempConsume);
@ -424,32 +454,36 @@ public class EnergyController extends BaseController {
if (kilnType==3){ if (kilnType==3){
List tempList=new ArrayList(); List tempList=new ArrayList();
List<ConsumeDataVo> actualTempConsume=new ArrayList<>(); List actualTempConsume=new ArrayList<>();
List<ConsumeDataVo> setupTempConsume=new ArrayList<>(); List setupTempConsume=new ArrayList<>();
List<ConsumeDataVo> outerZone1TempConsume=new ArrayList<>(); List outerZone1TempConsume=new ArrayList<>();
List<ConsumeDataVo> outerZone2TempConsume=new ArrayList<>(); List outerZone2TempConsume=new ArrayList<>();
for (ParTemValue parTemValue:parTemValueList for (ParTemValue parTemValue:parTemValueList
) { ) {
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); map.put("time",parTemValue.getCreateTime());
consumeDataVo.setName("实际温度"); map.put("value",parTemValue.getActTemValue());
consumeDataVo.setValue(parTemValue.getActTemValue()); map.put("name","实际温度");
consumeDataVo.setUnit("℃"); map.put("unit","℃");
actualTempConsume.add(consumeDataVo); actualTempConsume.add(JSONObject.toJSON(map));
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); map.clear();
consumeDataVo.setName("设定温度"); map.put("time",parTemValue.getCreateTime());
consumeDataVo.setValue(parTemValue.getSetTemValue()); map.put("value",parTemValue.getSetTemValue());
consumeDataVo.setUnit("℃"); map.put("name","设定温度");
setupTempConsume.add(consumeDataVo); map.put("unit","℃");
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); setupTempConsume.add(JSONObject.toJSON(map));
consumeDataVo.setName("外一区温度"); map.clear();
consumeDataVo.setValue(parTemValue.getOuterZone1Temp()); map.put("time",parTemValue.getCreateTime());
consumeDataVo.setUnit("℃"); map.put("value",parTemValue.getOuterZone1Temp());
outerZone1TempConsume.add(consumeDataVo); map.put("name","外一区温度");
consumeDataVo.setCreateTime(parTemValue.getCreateTime()); map.put("unit","℃");
consumeDataVo.setName("外二区温度"); outerZone1TempConsume.add(JSONObject.toJSON(map));
consumeDataVo.setValue(parTemValue.getOuterZone2Temp()); map.clear();
consumeDataVo.setUnit("℃"); map.put("time",parTemValue.getCreateTime());
outerZone2TempConsume.add(consumeDataVo); map.put("value",parTemValue.getOuterZone2Temp());
map.put("name","外二区温度");
map.put("unit","℃");
outerZone2TempConsume.add(JSONObject.toJSON(map));
map.clear();
} }
tempList.add(actualTempConsume); tempList.add(actualTempConsume);
tempList.add(setupTempConsume); tempList.add(setupTempConsume);

5
6.program/wms-empty/src/main/java/com/mt/wms/empty/vo/CurrTaskQueryVo.java
View File

@ -51,6 +51,11 @@ public class CurrTaskQueryVo extends BaseVo implements PageVo.ConvertVo {
*/ */
@ApiModelProperty("任务类型") @ApiModelProperty("任务类型")
private Integer taskType; private Integer taskType;
/**
* 是否自动执行： 0手动，1自动，如果是自动任务这里要监控进出和到缓存区的调度任务
*/
@ApiModelProperty("是否自动执行：手动，1自动")
private Integer is_auto;
/** /**
* 开始加工时间 * 开始加工时间
*/ */