diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/util/SaveOrUpdateBusinessLogUtil.java b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/util/SaveOrUpdateBusinessLogUtil.java index ff630756..966563ec 100644 --- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/util/SaveOrUpdateBusinessLogUtil.java +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/util/SaveOrUpdateBusinessLogUtil.java @@ -44,31 +44,42 @@ public class SaveOrUpdateBusinessLogUtil { Assert.notNull(integrationTaskLivingDetailsEntity.getPluginId(), "场景id不能为空"); synchronized (OBJECT_LOCK) { - try { - IntegrationTaskLivingDetailsEntity integrationTaskLivingDetails = null; - IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity1 = new IntegrationTaskLivingDetailsEntity(); - integrationTaskLivingDetailsEntity1.setNewState("N"); - integrationTaskLivingDetailsEntity1.setRootAppPk(integrationTaskLivingDetailsEntity.getRootAppPk()); - integrationTaskLivingDetailsEntity1.setPluginId(integrationTaskLivingDetailsEntity.getPluginId()); - List integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity1); - if (integrationTaskLivingDetailsEntities != null && integrationTaskLivingDetailsEntities.size() > 0) { - integrationTaskLivingDetails = integrationTaskLivingDetailsEntities.get(0); - } + Thread n = new Thread(new Runnable() { + @Override + public void run() { + try { + IntegrationTaskLivingDetailsEntity integrationTaskLivingDetails = null; + IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity1 = new IntegrationTaskLivingDetailsEntity(); + integrationTaskLivingDetailsEntity1.setNewState("N"); + integrationTaskLivingDetailsEntity1.setRootAppPk(integrationTaskLivingDetailsEntity.getRootAppPk()); + integrationTaskLivingDetailsEntity1.setPluginId(integrationTaskLivingDetailsEntity.getPluginId()); + List integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity1); + if (integrationTaskLivingDetailsEntities != null && integrationTaskLivingDetailsEntities.size() > 0) { + integrationTaskLivingDetails = integrationTaskLivingDetailsEntities.get(0); + } - if (integrationTaskLivingDetails != null) { - //存在,则更新,可能是N→Y / N→N - integrationTaskLivingDetailsEntity.setId(integrationTaskLivingDetails.getId()); - updateSuccessMessage(integrationTaskLivingDetailsEntity); - } else { - //不存在,则新增,可能是→Y / →N - Long uuid = UUIDLong.longUUID(); - integrationTaskLivingDetailsEntity.setId(String.valueOf(uuid)); - saveSuccessMessage(integrationTaskLivingDetailsEntity); + if (integrationTaskLivingDetails != null) { + //存在,则更新,可能是N→Y / N→N + integrationTaskLivingDetailsEntity.setId(integrationTaskLivingDetails.getId()); + updateSuccessMessage(integrationTaskLivingDetailsEntity); + } else { + //不存在,则新增,可能是→Y / →N + Long uuid = UUIDLong.longUUID(); + integrationTaskLivingDetailsEntity.setId(String.valueOf(uuid)); + saveSuccessMessage(integrationTaskLivingDetailsEntity); // logger.info("integration_task_living_details->日志保存成功,主键:{}", save.getId()); + } + } catch (Exception e) { + logger.error("SaveOrUpdateBusinessLogUtil对应的saveOrUpdate方法抛出异常,日志详情保存失败!", e); + //2024年9月3日 10:26:45 如果这里往上抛出异常,没有功能搭配处理 + } } - } catch (Exception e) { - logger.error("SaveOrUpdateBusinessLogUtil对应的saveOrUpdate方法抛出异常,日志详情保存失败!", e); - //2024年9月3日 10:26:45 如果这里往上抛出异常,没有功能搭配处理 + }); + n.start(); + try{ + n.join(); + }catch (Exception e){ + logger.error("",e); } } }