package com.product.data.sync.util;
|
|
import com.product.common.lang.StringUtils;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.data.sync.config.CmnConst;
|
import com.product.util.BaseUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.sql.Connection;
|
import java.sql.SQLException;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
public class ExceptionLog extends AbstractBaseService {
|
@Autowired
|
public BaseDao baseDao;
|
|
@Override
|
public BaseDao getBaseDao() {
|
return baseDao;
|
}
|
|
@Override
|
public void setBaseDao(BaseDao baseDao) {
|
this.baseDao = baseDao;
|
}
|
|
/**
|
* 新增修改失败修改日志,添加错误详情子表
|
* @param sync_config_log_uuid 日志主表uuid
|
* @param list 错误数据唯一标识集合
|
* @param e 异常
|
*/
|
public void addSubExceptionLog(String sync_config_log_uuid, List<String> list, Exception e) {
|
FieldSetEntity subException = new FieldSetEntity();
|
subException.setTableName(CmnConst.PRODUCT_SYS_DATABASE_SYNC_CONFIG_LOG_SUB);
|
subException.setValue(CmnConst.SYNC_CONFIG_LOG_UUID, sync_config_log_uuid);
|
subException.setValue(CmnConst.ERROR_INFO, e.getMessage());
|
//直接开集合并去掉括号
|
subException.setValue(CmnConst.WRONG_DATA_KEY, StringUtils.strip(list.toString(), "[]"));
|
baseDao.add(subException);
|
}
|
|
/**
|
* 新增修改失败修改日志,添加错误详情子表
|
* @param sync_config_log_uuid 日志主表uuid
|
* @param e 异常
|
* @param currentPage 含错误数据的页数
|
*/
|
public void addSubExceptionLog(String sync_config_log_uuid, Exception e, Integer currentPage) {
|
FieldSetEntity subException = new FieldSetEntity();
|
subException.setTableName(CmnConst.PRODUCT_SYS_DATABASE_SYNC_CONFIG_LOG_SUB);
|
subException.setValue(CmnConst.SYNC_CONFIG_LOG_UUID, sync_config_log_uuid);
|
subException.setValue(CmnConst.ERROR_INFO, e.getMessage());
|
Integer startIndex = (currentPage - 1) * 1000;
|
Integer endIndex = currentPage * 1000;
|
//直接开集合并去掉括号
|
subException.setValue(CmnConst.WRONG_DATA_KEY, "[" + startIndex + "-" + endIndex + "]");
|
//添加时间
|
subException.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
|
baseDao.add(subException);
|
}
|
|
/**
|
* 启动数据同步默认创建日志
|
* @param configUuid 同步配置uuid
|
* @param data_origin_name 数据源表名
|
* @param system_table_name 系统表名
|
* @return 日志uuid
|
*/
|
public String addExceptionLog(String configUuid, String data_origin_name, String system_table_name) {
|
FieldSetEntity exceptionLog = new FieldSetEntity();
|
exceptionLog.setTableName(CmnConst.PRODUCT_SYS_DATABASE_SYNC_CONFIG_LOG);
|
exceptionLog.setValue(CmnConst.SYNC_CONFIG_UUID, configUuid);
|
exceptionLog.setValue(CmnConst.DATA_ORIGIN_NAME, data_origin_name);
|
exceptionLog.setValue(CmnConst.SYNC_TIME, new Date());
|
exceptionLog.setValue(CmnConst.SYSTEM_TABLE_NAME, system_table_name);
|
return baseDao.add(exceptionLog);
|
}
|
|
/**
|
* 查询成功或中途失败修改同步日志
|
* @param conn 数据源连接
|
* @param uuid 日志uuid
|
* @param e 查询时异常
|
* @param addNum 新增条数
|
* @param upNum 修改条数
|
* @param errorNum 错误条数
|
* @param totalNumber 总条数
|
*/
|
public void upExceptionLog(Connection conn, String uuid, Exception e, Integer addNum, Integer upNum, Integer deleteNumber, Integer errorNum, Integer totalNumber) {
|
StringBuffer exception = new StringBuffer();
|
if (e != null) {
|
exception.append(e.getMessage());
|
}
|
if (conn != null) {
|
try {
|
conn.close();
|
} catch (SQLException ex) {
|
ex.printStackTrace();
|
exception.append("\n");
|
exception.append(ex.getMessage());
|
}
|
}
|
FieldSetEntity exceptionLog = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_DATABASE_SYNC_CONFIG_LOG, uuid, false);
|
String errInfo = exceptionLog.getString(CmnConst.ERR_INFO);
|
if(!BaseUtil.strIsNull(errInfo)){
|
exception.append("\n").append(errInfo);
|
}
|
exceptionLog.setValue(CmnConst.ERR_INFO, exception.toString());
|
exceptionLog.setValue(CmnConst.SYNC_TIME, new Date());
|
exceptionLog.setValue(CmnConst.ADD_NUM, addNum);
|
exceptionLog.setValue(CmnConst.UPDATE_NUM, upNum);
|
exceptionLog.setValue(CmnConst.DELETE_NUM, deleteNumber);
|
exceptionLog.setValue(CmnConst.FAIL_NUM, errorNum);
|
exceptionLog.setValue(CmnConst.TOTAL_NUMBER, totalNumber);
|
baseDao.update(exceptionLog);
|
}
|
|
/**
|
* 修改日志
|
* @param uuid 日志uuid
|
* @param e 查询时异常
|
*/
|
public void upExceptionLog(String uuid, Exception e) {
|
StringBuffer exception = new StringBuffer();
|
if (e != null) {
|
exception.append(e.getMessage());
|
}
|
FieldSetEntity exceptionLog = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_DATABASE_SYNC_CONFIG_LOG, uuid, false);
|
String errInfo = exceptionLog.getString(CmnConst.ERR_INFO);
|
if(!BaseUtil.strIsNull(errInfo)){
|
exception.append("\n").append(errInfo);
|
}
|
exceptionLog.setValue(CmnConst.ERR_INFO, exception.toString());
|
baseDao.update(exceptionLog);
|
}
|
}
|
