2.7.18

shikeyin

2024-01-11 65da8373531677b1c37a98f53eaa30c892f35e5a

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
package com.iplatform.base.di;
 
import com.walker.di.DataImportException;
import com.walker.di.TemplateException;
import com.walker.di.TemplateGenerator;
import com.walker.infrastructure.utils.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
public abstract class AbstractDataImportEngine<T> implements DataImportEngine<T>{
 
    protected final transient Logger logger = LoggerFactory.getLogger(getClass());
 
    private TemplateGenerator<T> templateGenerator;
 
    private String saveFileRootInfo = null;
 
    @Override
    public void setTemplateGenerator(TemplateGenerator<T> templateGenerator) {
        if(templateGenerator == null){
            throw new IllegalArgumentException("templateGenerator 不能为空!");
        }
        this.templateGenerator = templateGenerator;
    }
 
    @Override
    public T generateTemplate(TemplateInfo templateInfo) {
        try {
            return this.templateGenerator.generate(templateInfo);
        } catch (TemplateException e) {
            logger.error("生成导入模板错误:" + e.getMessage(), e);
            return null;
        }
    }
 
    @Override
    public String executeImport(JdbcExcelDataImportor dataImportor, String loginId) throws DataImportException {
        // 保存导入历史记录（到数据库）供用户后台查询导入错误结果。
        if(dataImportor == null){
            throw new DataImportException("未传入导入器对象: JdbcExcelDataImportor", null);
        }
        String id = dataImportor.getId();
        if(StringUtils.isNotEmpty(id)){
            logger.debug("保存或者更新导入历史记录,id=" + id);
            try {
                this.saveImportHistory(id, loginId);
            } catch (Exception ex){
                throw new DataImportException("保存导入历史错误:" + ex.getMessage() + ", id=" + id, ex);
            }
        } else {
            logger.info("当前导入未设置id，不记录导入历史, loginId = " + loginId);
        }
 
        // 这里后续需要考虑ftp集中管理文件的情况。
        dataImportor.setSaveFileFolder(this.saveFileRootInfo);
 
        dataImportor.load();
        logger.info("导入成功写入{}条记录", dataImportor.getSuccessSize());
        return dataImportor.getErrorFile();
    }
 
    @Override
    public void setSaveFileRoot(String saveFileRootInfo){
        this.saveFileRootInfo = saveFileRootInfo;
    }
 
    /**
     * 保存导入历史记录，
     * @param id
     * @param userName
     */
    protected abstract void saveImportHistory(String id, String userName);
}