diff --git a/6.program/wms-basic/src/main/java/com/mt/wms/basic/vo/VehicleVo.java b/6.program/wms-basic/src/main/java/com/mt/wms/basic/vo/VehicleVo.java index 47e814c..49e0e62 100644 --- a/6.program/wms-basic/src/main/java/com/mt/wms/basic/vo/VehicleVo.java +++ b/6.program/wms-basic/src/main/java/com/mt/wms/basic/vo/VehicleVo.java @@ -60,4 +60,10 @@ public class VehicleVo extends BaseVo implements PageVo.ConvertVo{ */ @ApiModelProperty(value = "描述信息", example = "1") private String description; + + /** + * 描述信息 + */ + @ApiModelProperty(value = "车辆状态:0-空闲,1-占用", example = "1") + private Integer status; } diff --git a/6.program/wms-empty/src/main/java/com/mt/wms/empty/service/impl/CurrTaskServiceImpl.java b/6.program/wms-empty/src/main/java/com/mt/wms/empty/service/impl/CurrTaskServiceImpl.java index 947c93e..7c7f9e7 100644 --- a/6.program/wms-empty/src/main/java/com/mt/wms/empty/service/impl/CurrTaskServiceImpl.java +++ b/6.program/wms-empty/src/main/java/com/mt/wms/empty/service/impl/CurrTaskServiceImpl.java @@ -121,6 +121,7 @@ public class CurrTaskServiceImpl extends BaseService implements CurrTaskService public R> currentTaskPage(CurrTaskQueryParam param) { QueryWrapper currTaskQueryWrapper = new QueryWrapper<>(); currTaskQueryWrapper.eq(CurrTask.VALID, 1); + currTaskQueryWrapper.in(CurrTask.STATUS,0,1); Page page = currTaskServiceBiz.page(new Page<>(param.getCurrent(), param.getSize()), currTaskQueryWrapper); return successful(new PageVo<>(page, CurrTaskQueryVo.class)); } diff --git a/6.program/wms-empty/src/main/java/com/mt/wms/empty/task/ScheduledTask.java b/6.program/wms-empty/src/main/java/com/mt/wms/empty/task/ScheduledTask.java index 966bcd5..d4e9c0e 100644 --- a/6.program/wms-empty/src/main/java/com/mt/wms/empty/task/ScheduledTask.java +++ b/6.program/wms-empty/src/main/java/com/mt/wms/empty/task/ScheduledTask.java @@ -77,7 +77,7 @@ public class ScheduledTask extends BaseService { @Test public void test() throws IOException { } - @Scheduled(fixedDelay = 1000*60) + //@Scheduled(fixedDelay = 1000*60) public void testWebsocket() throws IOException { //查询出正在进炉加工的curr_task,查询对应炉号是否Working,查询计划时间,剩余时间,查询标识卡详情 List currTaskList = currTaskServiceBiz.list(new QueryWrapper().eq(CurrTask.IS_IN, 1)); @@ -123,7 +123,7 @@ public class ScheduledTask extends BaseService { /** * 正在加工的加工任务详情 */ - //@Scheduled(fixedDelay = 1000*60) + @Scheduled(fixedDelay = 1000*60) public void screen() throws IOException { //查询出正在进炉加工的curr_task,查询对应炉号是否Working,查询计划时间,剩余时间,查询标识卡详情 List currTaskList = currTaskServiceBiz.list(new QueryWrapper().eq(CurrTask.IS_IN, 1)); @@ -179,7 +179,7 @@ public class ScheduledTask extends BaseService { /** * 查询加工完成的窑炉 */ - //@Scheduled(fixedDelay = 1000*60*2) + @Scheduled(fixedDelay = 1000*60*2) public void taskForStockToKiln() throws IOException { //两辆车是否都空闲,只有两辆车都空闲才被允许做任务 List vehicleInfoList = vehicleInfoServiceBiz.list(new QueryWrapper().eq(VehicleInfo.STATUS, 0)); @@ -212,7 +212,7 @@ public class ScheduledTask extends BaseService { } //查询出正在加工的窑炉,遍历,根据采集频率的不同,采集高频数据能源消耗。暂定30秒 - //@Scheduled(fixedDelay = 1000*30) + @Scheduled(fixedDelay = 1000*30) public void getFastValue(){ logger.info("==采集高频能耗数据开始=="); //加工炉列表 @@ -307,7 +307,7 @@ public class ScheduledTask extends BaseService { } //查询出正在加工的窑炉,遍历,根据采集频率的不同,采集低频数据能源消耗。暂定3分钟一次 - //@Scheduled(fixedDelay = 1000*60*3) + @Scheduled(fixedDelay = 1000*60*3) public void getSlowValue(){ logger.info("==开始采集低频数据=="); List kilnInfoList = kilnInfoServiceBiz.list(); @@ -455,7 +455,7 @@ public class ScheduledTask extends BaseService { //遍历窑炉,空窑炉查询缓存区是否有等待加工的任务, //待加工任务存在且没有状态为正在进炉的情况下,按照先进先出的规则选择待加工任务呼叫车辆进炉 - //@Scheduled(fixedDelay = 1000*60) + @Scheduled(fixedDelay = 1000*60) public void runTaskForEmptyKiln() throws IOException { List kilnInfoList = kilnInfoServiceBiz.list(new QueryWrapper() .eq(KilnInfo.VALID, 1).eq(KilnInfo.STATUS, 0).orderByAsc(KilnInfo.TYPE)); @@ -471,7 +471,7 @@ public class ScheduledTask extends BaseService { } Boolean kilnReadyIn=false; if (kilnInfo.getType()==1){ - kilnReadyIn = kilnReadyIn(kilnInfo.getId()); + kilnReadyIn=kilnReadyIn(kilnInfo.getId()); } //查询炉子是否allowIn Boolean kilnAllowIn = kilnAllowIn(kilnInfo.getId()); @@ -506,7 +506,7 @@ public class ScheduledTask extends BaseService { } //遍历正在工作炉子的报警变量,记录报警 - //@Scheduled(fixedDelay = 1000*60) + @Scheduled(fixedDelay = 1000*60) public void listenKilnAlarm(){ List kilnInfoList = kilnInfoServiceBiz.list(); logger.info("==开始查询炉子是否有报警=="); @@ -626,7 +626,6 @@ public class ScheduledTask extends BaseService { String result = readPlcToString(nameSpaceNote, "AllowIn"); return Boolean.valueOf(JSONObject.parseObject(result).get("result").toString()); } - private Boolean kilnReadyIn(Long kilnId){ PlcNameSpace nameSpace = plcNameSpaceServiceBiz.getOne(new QueryWrapper() .eq(PlcNameSpace.EQ_TYPE, 0) @@ -636,7 +635,6 @@ public class ScheduledTask extends BaseService { String result = readPlcToString(nameSpaceNote, "ReadyIn"); return Boolean.valueOf(JSONObject.parseObject(result).get("result").toString()); } - private Boolean kilnWorking(Long kilnId){ PlcNameSpace nameSpace = plcNameSpaceServiceBiz.getOne(new QueryWrapper() .eq(PlcNameSpace.EQ_TYPE, 0)