| | |
| | | News.error("站点:{},未扫到码值:{}", staProtocol.getSiteId(), barcode); |
| | | continue; |
| | | } |
| | | Job job = jobService.getJobByBarcode(barcode); |
| | | Job job = jobService.getJobByJobNo(staProtocol.getWorkNo()); |
| | | //Job job = jobService.getJobByBarcode(barcode); |
| | | if (job == null) { |
| | | News.error("{}:站点:{},找不到任务", config.getMark(), staProtocol.getSiteId()); |
| | | continue; |
| | |
| | | staProtocol.setWorkNo(workNo); |
| | | staProtocol.setStaNo(inSta.getTargetSta()); |
| | | redis.push(RedisConveyorConstant.CONVEYOR_TASK_FLAG, staProtocol); |
| | | if (jobService.insert(initJob(locOfWms, barcode, workNo, inSta.getTargetSta() + ""))) { |
| | | job.setLoc(locOfWms.getLocNo()); |
| | | job.setTaskNo(locOfWms.getTaskNo()); |
| | | job.setBatchNo(locOfWms.getBatchNo()); |
| | | job.setBarcode(barcode); |
| | | job.setWmsTime(new Date()); |
| | | job.setJobSts(ConveyorStateType.INBOUND.getStatus()); |
| | | //if (jobService.insert(initJob(locOfWms, barcode, workNo, inSta.getTargetSta() + ""))) { |
| | | if (jobService.updateById(job)) { |
| | | News.info("申请入库成功,条码:{},站点:{}", barcode, inSta.getStaNo()); |
| | | |
| | | } |
| | | } else { |
| | | News.error("WMS未返回库位信息,条码:{},站点:{}", barcode, inSta.getStaNo()); |