diff --git a/src/main/java/com/huaheng/api/wcs/service/warecellAllocation/LocationAllocationServiceImpl.java b/src/main/java/com/huaheng/api/wcs/service/warecellAllocation/LocationAllocationServiceImpl.java index 191f192..6ec6e92 100644 --- a/src/main/java/com/huaheng/api/wcs/service/warecellAllocation/LocationAllocationServiceImpl.java +++ b/src/main/java/com/huaheng/api/wcs/service/warecellAllocation/LocationAllocationServiceImpl.java @@ -210,8 +210,12 @@ public class LocationAllocationServiceImpl implements LocationAllocationService BigDecimal total_weight_bigdecimal=new BigDecimal(total_weight_config); BigDecimal total_weight= total_weight_bigdecimal.subtract(new BigDecimal(weight)); locationLambda.eq(Location::getZoneCode,QuantityConstant.ZONE_AGV); - locationLambda.inSql(Location::getIColumn, "select a.iColumn from (SELECT iColumn,ifnull(sum(weight),0) sum FROM `location` where zoneCode='B' group by iColumn) a where a.sum<="+total_weight); - locationLambda.orderByAsc(Location::getIRow,Location::getILayer); + locationLambda.last("and (iRow,iColumn) IN (select a.irow,a.iColumn\n" + + " FROM (SELECT irow,iColumn,ifnull(sum(weight),0) sum\n" + + " FROM `location`\n" + + " WHERE zoneCode='B' group by irow,iColumn) a\n" + + " WHERE a.sum<="+total_weight+")"); + //locationLambda.orderByAsc(Location::getIRow,Location::getILayer); } List<Location> locationList = locationService.list(locationLambda); diff --git a/src/main/java/com/huaheng/common/constant/QuantityConstant.java b/src/main/java/com/huaheng/common/constant/QuantityConstant.java index e40f583..1d0106d 100644 --- a/src/main/java/com/huaheng/common/constant/QuantityConstant.java +++ b/src/main/java/com/huaheng/common/constant/QuantityConstant.java @@ -537,11 +537,11 @@ public class QuantityConstant { public static final int AGV_TASK_SEND_TYPE_CREATE = 1; public static final int AGV_TASK_SEND_TYPE_CANCEL = 2; - //WCS任务下发 + //AGV任务下发 public static final String ADDRESS_AGV_TASK_ASSIGN = "AGV_TASK_ASSIGN"; - //WCS任务取消 + //AGV任务取消 public static final String ADDRESS_AGV_TASK_CANCEL = "AGV_TASK_CANCEL"; - //WCS任务更新 + //AGV任务更新 public static final String ADDRESS_AGV_TASK_UPDATE = "AGV_TASK_UPDATE"; diff --git a/src/main/java/com/huaheng/pc/monitor/job/task/RyTask.java b/src/main/java/com/huaheng/pc/monitor/job/task/RyTask.java index 62bfc4e..2822398 100644 --- a/src/main/java/com/huaheng/pc/monitor/job/task/RyTask.java +++ b/src/main/java/com/huaheng/pc/monitor/job/task/RyTask.java @@ -703,10 +703,10 @@ public class RyTask extends BaseController { } } - /* - ** 向AGV下发任务 - * 更新wms库agv任务状态下发状态 - * 三楼立库AGv任务 + /** + * 向AGV下发任务 + * 更新wms库agv任务状态下发状态 + * 三楼立库AGV任务 */ public void autoSendAgvTask(String params) { AjaxResult ajaxResult = handleMultiProcess(new MultiProcessListener() { @@ -729,10 +729,10 @@ public class RyTask extends BaseController { } - /* - ** 向AGV发送取消任务指令 - * 更新wms库agv任务状态下发状态 - * 三楼立库AGv任务 + /** + * 向AGV发送取消任务指令 + * 更新wms库agv任务状态下发状态 + * 三楼立库AGV任务 */ public void autoCancelAgvTask(String params) { AjaxResult ajaxResult = handleMultiProcess(new MultiProcessListener() { diff --git a/src/main/java/com/huaheng/pc/task/agvTask/domain/AgvTask.java b/src/main/java/com/huaheng/pc/task/agvTask/domain/AgvTask.java index 252ebef..9df77b5 100644 --- a/src/main/java/com/huaheng/pc/task/agvTask/domain/AgvTask.java +++ b/src/main/java/com/huaheng/pc/task/agvTask/domain/AgvTask.java @@ -18,7 +18,6 @@ public class AgvTask { @TableId(value = "id", type = IdType.AUTO) @ApiModelProperty(value="内部号") private Integer id; - /** * 仓库编码 */ @@ -29,12 +28,13 @@ public class AgvTask { @TableField(value = "zoneCode") @ApiModelProperty(value="库区编码") private String zoneCode; + //100 搬运任务,200行走任务,300 取货任务,400放货任务; @TableField(value = "taskType") @ApiModelProperty(value="任务类型") private Integer taskType; - //agv任务状态 1生成 10下发 20执行 100 完成 0错误 + //agv任务状态 1生成 10下发 20执行 100完成 0错误 @TableField(value = "status") @ApiModelProperty(value="任务状态") private Integer status; diff --git a/src/main/java/com/huaheng/pc/task/agvTask/service/AgvTaskServiceImpl.java b/src/main/java/com/huaheng/pc/task/agvTask/service/AgvTaskServiceImpl.java index cba01fd..e8e805a 100644 --- a/src/main/java/com/huaheng/pc/task/agvTask/service/AgvTaskServiceImpl.java +++ b/src/main/java/com/huaheng/pc/task/agvTask/service/AgvTaskServiceImpl.java @@ -55,7 +55,7 @@ public class AgvTaskServiceImpl extends ServiceImpl<AgvTaskMapper, AgvTask> impl } //下发任务给ACS AjaxResult ajaxResult = acsService.createAGVTask(agvTask); - if (ajaxResult!=null&&!ajaxResult.hasErr()) { + if (ajaxResult != null && !ajaxResult.hasErr()) { agvTask.setStatus(QuantityConstant.AGV_TASK_STATUS_RELEASE); agvTask.setLastUpdated(new Date()); agvTask.setLastUpdatedBy("Rytask");