diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/util/SaveOrUpdateBusinessLogUtilsNew240919.java b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/util/SaveOrUpdateBusinessLogUtilsNew240919.java new file mode 100644 index 00000000..4a7e3393 --- /dev/null +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/util/SaveOrUpdateBusinessLogUtilsNew240919.java @@ -0,0 +1,169 @@ +//package com.hzya.frame.plugin.lets.util; +// +//import cn.hutool.core.lang.Assert; +//import com.hzya.frame.sysnew.integtationTaskLivingDetails.dao.IIntegrationTaskLivingDetailsDao; +//import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity; +//import com.hzya.frame.uuid.UUIDLong; +//import org.slf4j.Logger; +//import org.slf4j.LoggerFactory; +//import org.springframework.beans.factory.annotation.Autowired; +//import org.springframework.stereotype.Component; +// +//import java.util.List; +// +///** +// * 中台保存日志 +// * integration_task_living_details 失败 +// * integration_task_living_details_success 成功 +// */ +//@Component +//public class SaveOrUpdateBusinessLogUtilsNew240919 { +// Logger logger = LoggerFactory.getLogger(SaveOrUpdateBusinessLogUtilsNew240919.class); +// private static final Object insertOrUpdateLock = new Object(); +// private static final Object queryDetailsLock = new Object(); +// private static final String successY = "Y"; +// private static final String failN = "N"; +// +// @Autowired +// private IIntegrationTaskLivingDetailsDao integrationTaskLivingDetailsDao; +// +// +// /** +// * 保存更新日志,可能是N→Y / N→N +// */ +// public void saveOrUpdate(IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity) { +// Assert.notNull(integrationTaskLivingDetailsEntity, "integrationTaskLivingDetailsEntity不能为空"); +// Assert.notNull(integrationTaskLivingDetailsEntity.getRootAppPk(), "源系统单号不能为空"); +// Assert.notNull(integrationTaskLivingDetailsEntity.getPluginId(), "场景id不能为空"); +// try { +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetails = null; +// synchronized (queryDetailsLock) { +// //根据appPk+plugin判断是否存在 +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity1 = new IntegrationTaskLivingDetailsEntity(); +// integrationTaskLivingDetailsEntity1.setRootAppPk(integrationTaskLivingDetailsEntity.getRootAppPk()); +// integrationTaskLivingDetailsEntity1.setPluginId(integrationTaskLivingDetailsEntity.getPluginId()); +// List integrationTaskLivingDetailsEntities = integrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity1); +// if (integrationTaskLivingDetailsEntities != null && integrationTaskLivingDetailsEntities.size() > 0) { +// integrationTaskLivingDetails = integrationTaskLivingDetailsEntities.get(0); +// } +// } +// if (integrationTaskLivingDetails != null) { +// //存在,则更新,可能是N→Y / N→N +// synchronized (insertOrUpdateLock) { +// 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("SaveOrUpdateBusinessLogUtilsNew240919对应的saveOrUpdate方法抛出异常,日志详情保存失败!", e); +// +// } +// } +// +// /** +// * 更新日志 存在,则更新,可能是N→Y / N→N +// * 肯定有id +// * @param integrationTaskLivingDetailsEntity +// */ +// private void updateSuccessMessage(IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity) { +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity1 = queryIntegrationTaskLivingDetailsEntityN(integrationTaskLivingDetailsEntity.getId()); +// if (successY.equals(integrationTaskLivingDetailsEntity.getNewState())) { +// //N→Y +// integrationTaskLivingDetailsDao.deleteEntity(integrationTaskLivingDetailsEntity1); +// +// String successIdentification = "success"; +// integrationTaskLivingDetailsEntity.setRootAppNewData(successIdentification); +// integrationTaskLivingDetailsEntity.setNewTransmitInfo(successIdentification); +// integrationTaskLivingDetailsDao.saveSuccessLog(integrationTaskLivingDetailsEntity); +// +// } else if (failN.equals(integrationTaskLivingDetailsEntity.getNewState())) { +// //N→N +// String rootAppNewData = integrationTaskLivingDetailsEntity.getRootAppNewData(); +// if (integrationTaskLivingDetailsEntity.getRootAppNewData() != null && !integrationTaskLivingDetailsEntity.getRootAppNewData().trim().equals("") && integrationTaskLivingDetailsEntity.getRootAppNewData().length() >= 500) { +// rootAppNewData = integrationTaskLivingDetailsEntity.getRootAppNewData().substring(0, 500); +// } +// String newTransmitInfo = integrationTaskLivingDetailsEntity.getNewTransmitInfo(); +// if (integrationTaskLivingDetailsEntity.getNewTransmitInfo() != null && !integrationTaskLivingDetailsEntity.getNewTransmitInfo().trim().equals("") && integrationTaskLivingDetailsEntity.getNewTransmitInfo().length() >= 500) { +// newTransmitInfo = integrationTaskLivingDetailsEntity.getNewTransmitInfo().substring(0, 500); +// } +// integrationTaskLivingDetailsEntity.setRootAppNewData(rootAppNewData); +// integrationTaskLivingDetailsEntity.setNewTransmitInfo(newTransmitInfo); +// integrationTaskLivingDetailsDao.entity_updatebyid(integrationTaskLivingDetailsEntity); +// } +// } +// +// /** +// * 新增日志 不存在,则新增,可能是→Y / →N +// * @param integrationTaskLivingDetailsEntity +// */ +// private void saveSuccessMessage(IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity) { +// if (successY.equals(integrationTaskLivingDetailsEntity.getNewState())) { +// //→Y +// String successIdentification = "success"; +// integrationTaskLivingDetailsEntity.setRootAppNewData(successIdentification); +// integrationTaskLivingDetailsEntity.setNewTransmitInfo(successIdentification); +// integrationTaskLivingDetailsDao.saveSuccessLog(integrationTaskLivingDetailsEntity); +// +// } else if (failN.equals(integrationTaskLivingDetailsEntity.getNewState())) { +// //→N +// String rootAppNewData = integrationTaskLivingDetailsEntity.getRootAppNewData(); +// if (integrationTaskLivingDetailsEntity.getRootAppNewData() != null && !integrationTaskLivingDetailsEntity.getRootAppNewData().trim().equals("") && integrationTaskLivingDetailsEntity.getRootAppNewData().length() >= 500) { +// rootAppNewData = integrationTaskLivingDetailsEntity.getRootAppNewData().substring(0, 500); +// } +// String newTransmitInfo = integrationTaskLivingDetailsEntity.getNewTransmitInfo(); +// if (integrationTaskLivingDetailsEntity.getNewTransmitInfo() != null && !integrationTaskLivingDetailsEntity.getNewTransmitInfo().trim().equals("") && integrationTaskLivingDetailsEntity.getNewTransmitInfo().length() >= 500) { +// newTransmitInfo = integrationTaskLivingDetailsEntity.getNewTransmitInfo().substring(0, 500); +// } +// integrationTaskLivingDetailsEntity.setRootAppNewData(rootAppNewData); +// integrationTaskLivingDetailsEntity.setNewTransmitInfo(newTransmitInfo); +// integrationTaskLivingDetailsDao.save(integrationTaskLivingDetailsEntity); +// } +// +// } +// /** +// * 不区分成功失败,union all了表 +// * @param integration_task_living_details_id +// * @return +// */ +// public IntegrationTaskLivingDetailsEntity queryIntegrationTaskLivingDetailsEntityById(String integration_task_living_details_id) { +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); +// integrationTaskLivingDetailsEntity.setId(integration_task_living_details_id); +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity1 = integrationTaskLivingDetailsDao.queryEntityById(integrationTaskLivingDetailsEntity); +// if(integrationTaskLivingDetailsEntity1==null){ +// return null; +// } +// return integrationTaskLivingDetailsEntity1; +// } +// +// /** +// * 根据明细id查询明细信息,成功表 integration_task_living_details_success +// */ +// public IntegrationTaskLivingDetailsEntity queryIntegrationTaskLivingDetailsEntityY(IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity) { +//// Assert.notNull(integration_task_living_details_id, "业务明细id不能为空"); +//// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); +//// integrationTaskLivingDetailsEntity.setId(integration_task_living_details_id); +//// integrationTaskLivingDetailsEntity.setNewState("Y");//查询成功表 +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity1 = integrationTaskLivingDetailsDao.queryEntity(integrationTaskLivingDetailsEntity); +// Assert.notNull(integrationTaskLivingDetailsEntity1, "根据主键id没有查询到明细信息"); +// return integrationTaskLivingDetailsEntity1; +// } +// /** +// * 根据明细id查询明细信息,错误表 integration_task_living_details +// */ +// public IntegrationTaskLivingDetailsEntity queryIntegrationTaskLivingDetailsEntityN(String integration_task_living_details_id) { +// Assert.notNull(integration_task_living_details_id, "业务明细id不能为空"); +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); +// integrationTaskLivingDetailsEntity.setId(integration_task_living_details_id); +// integrationTaskLivingDetailsEntity.setNewState("N");//查询失败表 +// IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity1 = integrationTaskLivingDetailsDao.queryEntity(integrationTaskLivingDetailsEntity); +// Assert.notNull(integrationTaskLivingDetailsEntity1, "根据主键id没有查询到明细信息"); +// return integrationTaskLivingDetailsEntity1; +// } +// +//}