From bb115435923657acaafbe3602248b2ca421f8530 Mon Sep 17 00:00:00 2001 From: zhengyf Date: Fri, 25 Oct 2024 16:45:37 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=BD=E7=9F=A5=EF=BC=9A=E5=86=99=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E5=8A=A0=E9=94=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../util/SaveOrUpdateBusinessLogUtil.java | 55 +++++++++++-------- 1 file changed, 33 insertions(+), 22 deletions(-) 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); } } }