|
|
@@ -85,26 +85,27 @@ public class AbstractCommNioManager extends AbstractManager { |
|
|
|
oldLog.setUpdateTime(LocalDateTime.now()); |
|
|
|
logRepo.save(oldLog); |
|
|
|
return; |
|
|
|
} |
|
|
|
//成功 |
|
|
|
if (log.getStatus() == InterfaceStatus.SUCCESS) { |
|
|
|
log.setUniqueId(uniqueId); |
|
|
|
log.setOperation(operation); |
|
|
|
log.setNioTransferType(cmd.getTransferType()); |
|
|
|
log.setUpdateTime(LocalDateTime.now()); |
|
|
|
log.setResendTimes(0); |
|
|
|
log.setSendStatus(YgzSendStatus.SEND_SUCCESS); |
|
|
|
log.setSource(dataSource); |
|
|
|
logRepo.persist(log); |
|
|
|
} else { |
|
|
|
log.setUniqueId(uniqueId); |
|
|
|
log.setOperation(operation); |
|
|
|
log.setNioTransferType(cmd.getTransferType()); |
|
|
|
log.setUpdateTime(LocalDateTime.now()); |
|
|
|
log.setResendTimes(0); |
|
|
|
log.setSendStatus(YgzSendStatus.WAIT_SEND); |
|
|
|
log.setSource(dataSource); |
|
|
|
logRepo.persist(log); |
|
|
|
}else{ |
|
|
|
//成功 |
|
|
|
if (log.getStatus() == InterfaceStatus.SUCCESS) { |
|
|
|
log.setUniqueId(uniqueId); |
|
|
|
log.setOperation(operation); |
|
|
|
log.setNioTransferType(cmd.getTransferType()); |
|
|
|
log.setUpdateTime(LocalDateTime.now()); |
|
|
|
log.setResendTimes(0); |
|
|
|
log.setSendStatus(YgzSendStatus.SEND_SUCCESS); |
|
|
|
log.setSource(dataSource); |
|
|
|
logRepo.persist(log); |
|
|
|
} else { |
|
|
|
log.setUniqueId(uniqueId); |
|
|
|
log.setOperation(operation); |
|
|
|
log.setNioTransferType(cmd.getTransferType()); |
|
|
|
log.setUpdateTime(LocalDateTime.now()); |
|
|
|
log.setResendTimes(0); |
|
|
|
log.setSendStatus(YgzSendStatus.WAIT_SEND); |
|
|
|
log.setSource(dataSource); |
|
|
|
logRepo.persist(log); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |