From c84108aec79cc3243d29366e07992b4316e1d7a8 Mon Sep 17 00:00:00 2001 From: MaxKey Date: Thu, 5 Jan 2023 13:53:24 +0800 Subject: [PATCH] Update ProvisioningRunner.java --- .../maxkey/provision/thread/ProvisioningRunner.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/maxkey-persistence/src/main/java/org/maxkey/provision/thread/ProvisioningRunner.java b/maxkey-persistence/src/main/java/org/maxkey/provision/thread/ProvisioningRunner.java index fe435c082..dd05fccc0 100644 --- a/maxkey-persistence/src/main/java/org/maxkey/provision/thread/ProvisioningRunner.java +++ b/maxkey-persistence/src/main/java/org/maxkey/provision/thread/ProvisioningRunner.java @@ -67,7 +67,9 @@ public class ProvisioningRunner { List listConnectors = connectorsService.query(new Query().eq("status", 1).eq("justintime", 1)); List listProvisionMessage = jdbcTemplate.query(PROVISION_SELECT_STATEMENT, new ProvisionMessageRowMapper()); for(ProvisionMessage msg : listProvisionMessage) { + _logger.debug("Provision message {}",msg); for(Connectors connector: listConnectors) { + _logger.debug("Provision message to connector {}",connector); provision(msg,connector); } } @@ -134,10 +136,12 @@ public class ProvisioningRunner { public void provisionLog(String conName,String topic,String actionType,String sourceId,String sourceName,String resultMessage,int instid) { Message resultMsg = null; - if(resultMessage != null) { - JsonUtils.stringToObject(resultMessage, Message.class); - } String result = "success"; + + if(resultMessage != null) { + resultMsg = JsonUtils.stringToObject(resultMessage, Message.class); + } + if(resultMsg == null || resultMsg.getCode() != 0) { result = "fail"; }