hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

丽知：写日志加锁

This commit is contained in:
zhengyf 2024-10-25 16:45:37 +08:00
parent 6bbfc57c45
commit bb11543592
1 changed files with 33 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
buildpackage/src/main/java/com/hzya/frame/plugin/lets/util/SaveOrUpdateBusinessLogUtil.java
View File

@ -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<IntegrationTaskLivingDetailsEntity> 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<IntegrationTaskLivingDetailsEntity> 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);
}
}
}