丽知：如插入日志报错，请立刻回滚上一版！！！
This commit is contained in:
parent
04e68d846b
commit
a5a7b112cc
|
|
@ -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<IntegrationTaskLivingDetailsEntity> 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;
|
||||||
|
// }
|
||||||
|
//
|
||||||
|
//}
|
||||||
Loading…
Reference in New Issue