|
@ -249,7 +249,7 @@ public class LingShanHelpCrowdServiceImpl implements LingShanHelpCrowdService, R |
|
|
|
|
|
|
|
|
// 创建导入任务
|
|
|
// 创建导入任务
|
|
|
ImportTaskCommonResultDTO importTaskRst = getResultDataOrThrowsException(ImportTaskUtils.createImportTask(originalFilename, |
|
|
ImportTaskCommonResultDTO importTaskRst = getResultDataOrThrowsException(ImportTaskUtils.createImportTask(originalFilename, |
|
|
BizTypeEnum.SPECIAL_CROWD.getType()), |
|
|
BizTypeEnum.HELP_CROWD.getType()), |
|
|
ServiceConstant.EPMET_COMMON_SERVICE, |
|
|
ServiceConstant.EPMET_COMMON_SERVICE, |
|
|
EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), |
|
|
EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), |
|
|
null, "【灵山街道-导入重点帮扶人群】创建导入任务失败"); |
|
|
null, "【灵山街道-导入重点帮扶人群】创建导入任务失败"); |
|
@ -261,7 +261,7 @@ public class LingShanHelpCrowdServiceImpl implements LingShanHelpCrowdService, R |
|
|
// 如果提交异步任务失败了,也要将导入任务置为结束,并且返回一个未知错误
|
|
|
// 如果提交异步任务失败了,也要将导入任务置为结束,并且返回一个未知错误
|
|
|
log.error("【灵山街道-导入重点帮扶人群】失败,错误信息:" + ExceptionUtils.getErrorStackTrace(e)); |
|
|
log.error("【灵山街道-导入重点帮扶人群】失败,错误信息:" + ExceptionUtils.getErrorStackTrace(e)); |
|
|
ImportTaskUtils.finishImportTask(importTaskRst.getTaskId(), |
|
|
ImportTaskUtils.finishImportTask(importTaskRst.getTaskId(), |
|
|
ImportTaskConstants.PROCESS_STATUS_FINISHED_FAIL, null, "未知错误"); |
|
|
ImportTaskConstants.PROCESS_STATUS_FINISHED_FAIL, null, "未知错误,创建异步任务失败", 0, 0); |
|
|
|
|
|
|
|
|
// 删除文件
|
|
|
// 删除文件
|
|
|
FileUtils.deleteFileIfExists(fileSavePath); |
|
|
FileUtils.deleteFileIfExists(fileSavePath); |
|
@ -288,7 +288,7 @@ public class LingShanHelpCrowdServiceImpl implements LingShanHelpCrowdService, R |
|
|
.sheet(0) |
|
|
.sheet(0) |
|
|
.doRead(); |
|
|
.doRead(); |
|
|
|
|
|
|
|
|
List<LingShanSpecialCrowdDetailBaseExcelData> errorDatas = listener.getErrorDatas(); |
|
|
List errorDatas = listener.getErrorDatas(); |
|
|
if (CollectionUtils.isNotEmpty(errorDatas)) { |
|
|
if (CollectionUtils.isNotEmpty(errorDatas)) { |
|
|
// 有错误数据需要提示
|
|
|
// 有错误数据需要提示
|
|
|
String resultDescFilePath = uploadResultDescFilePath(errorDatas, listener.getTemplateFileName()); |
|
|
String resultDescFilePath = uploadResultDescFilePath(errorDatas, listener.getTemplateFileName()); |
|
@ -301,9 +301,9 @@ public class LingShanHelpCrowdServiceImpl implements LingShanHelpCrowdService, R |
|
|
ImportTaskConstants.PROCESS_STATUS_FINISHED_SUCCESS, null, "成功", listener.getSuccessedItemsQty(), listener.getFailedItemsQty()); |
|
|
ImportTaskConstants.PROCESS_STATUS_FINISHED_SUCCESS, null, "成功", listener.getSuccessedItemsQty(), listener.getFailedItemsQty()); |
|
|
} |
|
|
} |
|
|
} catch (Exception e) { |
|
|
} catch (Exception e) { |
|
|
log.error("【灵山街道-导入重点帮扶人群】失败,错误信息:" + ExceptionUtils.getErrorStackTrace(e)); |
|
|
log.error("【灵山街道-导入重点帮扶人群】异步任务过程中失败,错误信息:" + ExceptionUtils.getErrorStackTrace(e)); |
|
|
ImportTaskUtils.finishImportTask(taskId, |
|
|
ImportTaskUtils.finishImportTask(taskId, |
|
|
ImportTaskConstants.PROCESS_STATUS_FINISHED_FAIL, null, "未知错误"); |
|
|
ImportTaskConstants.PROCESS_STATUS_FINISHED_FAIL, null, "未知错误,异步任务过程中失败", 0, 0); |
|
|
} finally { |
|
|
} finally { |
|
|
FileUtils.deleteFileIfExists(fileSavePath); |
|
|
FileUtils.deleteFileIfExists(fileSavePath); |
|
|
} |
|
|
} |
|
|