linjj
/
docus-collector2.0
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

retry log

Browse Source
segment2.0
beeajax 2 years ago
parent 027d21d849
commit 09adcf995d
16 changed files with 33 additions and 24 deletions
Show Stats Download Patch File Download Diff File

2
collect-sdry/src/main/java/com/docus/server/collect/report/ReportConverter.java
Unescape Escape View File

@ -5,7 +5,7 @@ import com.docus.core.util.Func;
import com.docus.core.util.ParamsUtils;
import com.docus.core.util.XmlUtil;
import com.docus.infrastructure.core.exception.BaseException;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.dto.ReportDTO;
import com.docus.server.collect.IConverter;
import com.docus.server.collect.web.utils.TableJsonRead;
import org.springframework.stereotype.Component;

2
common-collect/src/main/java/com/docus/server/collect/report/event/TaskConsumptionReportDownEvent.java
Unescape Escape View File

@ -1,6 +1,6 @@
package com.docus.server.collect.report.event;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.dto.ReportDTO;
import lombok.Getter;
import org.springframework.context.ApplicationEvent;

10
common-collect/src/main/java/com/docus/server/collect/report/listener/ReportDownListener.java
Unescape Escape View File

@ -6,14 +6,14 @@ import cn.hutool.http.HttpUtil;
import com.docus.core.util.Func;
import com.docus.infrastructure.web.api.CommonResult;
import com.docus.infrastructure.web.api.ResultCode;
import com.docus.server.archivefile.infrastructure.mapper.AfReportRecordMapper;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDownDTO;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDownPatientDTO;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDownScanFileDTO;
import com.docus.server.archivefile.infrastructure.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.entity.AfReportRecord;
import com.docus.server.archivefile.infrastructure.mapper.AfReportRecordMapper;
import com.docus.server.collect.report.event.TaskConsumptionReportDownEvent;
import com.docus.server.collect.report.event.ThreePartyPushReportDownEvent;
import com.docus.server.collect.web.common.pojo.dto.ReportDownDTO;
import com.docus.server.collect.web.common.pojo.dto.ReportDownPatientDTO;
import com.docus.server.collect.web.common.pojo.dto.ReportDownScanFileDTO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;

2
common-collect/src/main/java/com/docus/server/collect/report/service/IReportService.java
Unescape Escape View File

@ -1,7 +1,7 @@
package com.docus.server.collect.report.service;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.dto.ReportDTO;
import java.util.List;

6
common-collect/src/main/java/com/docus/server/collect/report/service/impl/ReportServiceImpl.java
Unescape Escape View File

@ -3,14 +3,14 @@ package com.docus.server.collect.report.service.impl;
import com.docus.core.util.Func;
import com.docus.infrastructure.redis.service.IdService;
import com.docus.log.annotation.TrackRetryListener;
import com.docus.server.archivefile.infrastructure.mapper.AfCollectTaskMapper;
import com.docus.server.archivefile.infrastructure.mapper.AfReportRecordMapper;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.entity.AfCollectTask;
import com.docus.server.archivefile.infrastructure.entity.AfReportRecord;
import com.docus.server.archivefile.infrastructure.mapper.AfCollectTaskMapper;
import com.docus.server.archivefile.infrastructure.mapper.AfReportRecordMapper;
import com.docus.server.collect.report.event.TaskConsumptionReportDownEvent;
import com.docus.server.collect.report.event.ThreePartyPushReportDownEvent;
import com.docus.server.collect.report.service.IReportService;
import com.docus.server.archivefile.infrastructure.dto.ReportDTO;
import com.docus.server.record.mapper.TBasicMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationContext;

4
common-collect/src/main/java/com/docus/server/collect/report/ws/impl/ReportServerImpl.java
Unescape Escape View File

@ -3,13 +3,13 @@ package com.docus.server.collect.report.ws.impl;
import com.docus.core.util.json.JSON;
import com.docus.log.annotation.TrackGroup;
import com.docus.log.context.TrackHelper;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.dto.ReportDTO;
import com.docus.server.collect.IConverter;
import com.docus.server.collect.IWsResult;
import com.docus.server.collect.report.service.IReportService;
import com.docus.server.collect.report.ws.IReportServer;
import com.docus.server.enums.CollectTypeEnum;
import com.docus.server.collect.web.process.VisitorProcessor;
import com.docus.server.enums.CollectTypeEnum;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

3
common-collect/src/main/java/com/docus/server/collect/web/common/pojo/dto/ReportDownPatientDTO.java
Unescape Escape View File

@ -1,6 +1,7 @@
package com.docus.server.collect.web.common.pojo.dto;
import com.docus.server.collect.web.common.pojo.entity.AfReportRecord;
import com.docus.server.archivefile.infrastructure.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.entity.AfReportRecord;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

3
common-collect/src/main/java/com/docus/server/collect/web/common/pojo/dto/ReportDownScanFileDTO.java
Unescape Escape View File

@ -1,6 +1,7 @@
package com.docus.server.collect.web.common.pojo.dto;
import com.docus.server.collect.web.common.pojo.entity.AfReportRecord;
import com.docus.server.archivefile.infrastructure.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.entity.AfReportRecord;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

3
common-collect/src/main/java/com/docus/server/collect/web/service/TrackRetryService.java
Unescape Escape View File

@ -1,5 +1,6 @@
package com.docus.server.collect.web.service;
import com.docus.core.util.DateUtil;
import com.docus.core.util.json.JSON;
import com.docus.infrastructure.redis.service.IdService;
import com.docus.log.executor.TrackRetrySpringExecutor;
@ -56,6 +57,8 @@ public class TrackRetryService {
BeanUtils.copyProperties(message, taskMessageRetryLog);
taskMessageRetryLog.setMessageId(message.getId());
taskMessageRetryLog.setId(idService.getDateSeq());
taskMessageRetryLog.setCreateTime(DateUtil.now());
taskMessageRetryLog.setUpdateTime(DateUtil.now());
return taskMessageRetryLog;
}

2
common-collect/src/main/java/com/docus/server/collect/web/common/pojo/dto/ReportDTO.java → common-docus/docus-archivefile/src/main/java/com/docus/server/archivefile/infrastructure/dto/ReportDTO.java
Unescape Escape View File

@ -1,4 +1,4 @@
package com.docus.server.collect.web.common.pojo.dto;
package com.docus.server.archivefile.infrastructure.dto;
import lombok.Data;

2
common-docus/docus-archivefile/src/main/java/com/docus/server/archivefile/infrastructure/entity/AfReportRecord.java
Unescape Escape View File

@ -1,6 +1,6 @@
package com.docus.server.archivefile.infrastructure.entity;
import com.docus.server.archivefile.infrastructure.pojo.dto.ReportDTO;
import com.docus.server.archivefile.infrastructure.dto.ReportDTO;
import lombok.Data;
import java.io.Serializable;

2
common-docus/docus-archivefile/src/main/java/com/docus/server/archivefile/service/impl/AfCollectSysDictionaryImpl.java
Unescape Escape View File

@ -1,6 +1,6 @@
package com.docus.server.archivefile.service.impl;
import com.docus.server.archivefile.infrastructure.dao.impl.IAfCollectSysDictionaryDao;
import com.docus.server.archivefile.infrastructure.dao.IAfCollectSysDictionaryDao;
import com.docus.server.archivefile.infrastructure.entity.CollectsysDictionary;
import com.docus.server.archivefile.service.IAfCollectSysDictionaryService;
import org.springframework.stereotype.Service;

2
common-docus/docus-archivefile/src/main/java/com/docus/server/archivefile/service/impl/AfViewCollectionLogServiceImpl.java
Unescape Escape View File

@ -1,7 +1,7 @@
package com.docus.server.archivefile.service.impl;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.server.archivefile.infrastructure.dao.impl.IAfViewCollectionLogDao;
import com.docus.server.archivefile.infrastructure.dao.IAfViewCollectionLogDao;
import com.docus.server.archivefile.infrastructure.entity.AfViewCollectionLog;
import com.docus.server.archivefile.service.IAfViewCollectionLogService;
import org.springframework.stereotype.Service;

2
common-docus/docus-archivefile/src/main/java/com/docus/server/archivefile/service/impl/TaskConfigServiceImpl.java
Unescape Escape View File

@ -1,7 +1,7 @@
package com.docus.server.archivefile.service.impl;
import com.docus.server.archivefile.infrastructure.dao.ITaskConfigDao;
import com.docus.server.archivefile.infrastructure.entity.TaskConfig;
import com.docus.server.archivefile.infrastructure.dao.impl.ITaskConfigDao;
import com.docus.server.archivefile.service.ITaskConfigService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

4
common-docus/docus-archivefile/src/main/java/com/docus/server/archivefile/service/impl/TaskMessageServiceImpl.java
Unescape Escape View File

@ -2,9 +2,9 @@ package com.docus.server.archivefile.service.impl;
import com.docus.core.util.DateUtil;
import com.docus.core.util.Func;
import com.docus.server.archivefile.infrastructure.entity.TaskMessage;
import com.docus.server.archivefile.convert.TaskMessageConverter;
import com.docus.server.archivefile.infrastructure.dao.impl.ITaskMessageDao;
import com.docus.server.archivefile.infrastructure.dao.ITaskMessageDao;
import com.docus.server.archivefile.infrastructure.entity.TaskMessage;
import com.docus.server.archivefile.service.ITaskMessageService;
import com.docus.server.enums.CollectTypeEnum;
import com.docus.server.enums.StateEnum;

8
docus-client-interface/src/main/java/com/docus/server/util/ExceptionUtils.java
Unescape Escape View File

@ -1,11 +1,15 @@
package com.docus.server.util;
import jodd.exception.ExceptionUtil;
import java.io.PrintWriter;
import java.io.StringWriter;
public class ExceptionUtils {
public static String getExceptionMessage(Throwable ex) {
String errorMessage = ExceptionUtil.exceptionChainToString(ex);
StringWriter stringWriter = new StringWriter();
ex.printStackTrace(new PrintWriter(stringWriter));
String errorMessage = stringWriter.toString();
if (null != errorMessage && errorMessage.length() > 1000) {
return errorMessage.substring(0, 1000);
}

Write Preview
Loading…
Cancel
Save