| | |
| | | @Autowired |
| | | private BasStationService basStationService; |
| | | @Autowired |
| | | private StationOperateProcessUtils stationOperateProcessUtils; |
| | | @Autowired |
| | | private RedisUtil redisUtil; |
| | | |
| | | //申请入库任务 |
| | |
| | | String wmsSystemInUrl = systemConfigMap.get("wmsSystemInUrl"); |
| | | if(wmsSystemInUrl == null){ |
| | | News.error("未配置WMS入库接口地址,配置文件Code编码:wmsSystemInUrl"); |
| | | return null; |
| | | } |
| | | |
| | | int conveyorStationTaskLimit = 30; |
| | | String conveyorStationTaskLimitStr = systemConfigMap.get("conveyorStationTaskLimit"); |
| | | if(conveyorStationTaskLimitStr != null){ |
| | | conveyorStationTaskLimit = Integer.parseInt(conveyorStationTaskLimitStr); |
| | | } |
| | | int currentStationTaskCount = stationOperateProcessUtils.getCurrentStationTaskCount(); |
| | | if (currentStationTaskCount > conveyorStationTaskLimit) { |
| | | News.error("输送站点任务已达到上限,上限值:{},站点任务数:{}", conveyorStationTaskLimit, currentStationTaskCount); |
| | | return null; |
| | | } |
| | | |
| | |
| | | .setUri(wmsUrl) |
| | | .setPath(wmsSystemInUrl) |
| | | .setJson(JSON.toJSONString(requestParam)) |
| | | .setTimeout(360, TimeUnit.SECONDS) |
| | | .setTimeout(30, TimeUnit.SECONDS) |
| | | .build() |
| | | .doPost(); |
| | | if (response != null) { |
| | |
| | | .setUri(wmsUrl) |
| | | .setPath(wmsSystemReassignInTaskUrl) |
| | | .setJson(JSON.toJSONString(requestParam)) |
| | | .setTimeout(360, TimeUnit.SECONDS) |
| | | .setTimeout(30, TimeUnit.SECONDS) |
| | | .build() |
| | | .doPost(); |
| | | if (response != null) { |
| | |
| | | .setUri(wmsUrl) |
| | | .setPath(wmsSystemChangeLocNoUrl) |
| | | .setJson(JSON.toJSONString(requestParam)) |
| | | .setTimeout(360, TimeUnit.SECONDS) |
| | | .setTimeout(30, TimeUnit.SECONDS) |
| | | .build() |
| | | .doPost(); |
| | | |