| | |
| | | &&"开工".equals(machine.getState())){ |
| | | int loadCount=0; |
| | | if(machine.getMode()==1){ |
| | | |
| | | //标准模式 找已领取未完成的第一条任务 |
| | | LineConfiguration lineConfiguration=lineConfigurationService.machineLineConfiguration(machine); |
| | | List<PrimitiveTask> findPrimitiveTasking=primitiveTaskService.findPrimitiveTasking(machine,lineConfiguration.getLineId()); |
| | |
| | | //任务数>已上数量 |
| | | List<Tasking> taskingTopList=taskingMapper.selectList(new QueryWrapper<Tasking>().lambda() |
| | | .eq(Tasking::getScanId,primitiveTask.getScanId()) |
| | | .eq(Tasking::getState,"线上") |
| | | .eq(Tasking::getGlassState,"正常") |
| | | ); |
| | | loadCount=primitiveTask.getTaskQuantity()-taskingTopList.size(); |
| | | loadCount=(loadCount>0?loadCount:0); |
| | | if (primitiveTask.getTaskQuantity()>primitiveTask.getReportCount()){ |
| | | loadCount=primitiveTask.getTaskQuantity()-taskingTopList.size(); |
| | | loadCount=(loadCount>0?loadCount:0); |
| | | } |
| | | break; |
| | | } |
| | | }else{ |
| | |
| | | modbusTcp1.writeString(send,HexUtil.intTo2ByteHex(mesSend.getAddressStart()/2)); |
| | | log.info("发送任务发送报文内容:{},发送起始地址:{}",send,HexUtil.intTo2ByteHex(mesSend.getAddressStart()/2)); |
| | | modbusTcp1.close(); |
| | | SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | String sendRecord=df.format(new Date())+" "+"1 "+ loadCount; |
| | | if (sendRecords.size()>7){ |
| | | sendRecords.remove(0); |
| | | } |
| | | Map sendContentMap=new HashMap(); |
| | | sendContentMap.put("sendContent",sendRecord); |
| | | sendRecords.add(sendContentMap); |
| | | return; |
| | | } |
| | | } |