|
@@ -8,6 +8,8 @@ import cn.hutool.core.date.DateUtil;
|
|
import cn.hutool.core.exceptions.ExceptionUtil;
|
|
import cn.hutool.core.exceptions.ExceptionUtil;
|
|
import cn.hutool.core.map.MapUtil;
|
|
import cn.hutool.core.map.MapUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
+import cn.hutool.http.HttpUtil;
|
|
|
|
+import cn.hutool.json.JSONUtil;
|
|
import com.simuwang.base.common.conts.*;
|
|
import com.simuwang.base.common.conts.*;
|
|
import com.simuwang.base.common.enums.ReportParserFileType;
|
|
import com.simuwang.base.common.enums.ReportParserFileType;
|
|
import com.simuwang.base.common.enums.ReportType;
|
|
import com.simuwang.base.common.enums.ReportType;
|
|
@@ -29,6 +31,8 @@ import com.simuwang.base.pojo.dto.report.ReportData;
|
|
import com.simuwang.base.pojo.dto.report.ReportParseStatus;
|
|
import com.simuwang.base.pojo.dto.report.ReportParseStatus;
|
|
import com.simuwang.base.pojo.dto.report.ReportParserParams;
|
|
import com.simuwang.base.pojo.dto.report.ReportParserParams;
|
|
import com.simuwang.base.pojo.valuation.CmValuationTableAttribute;
|
|
import com.simuwang.base.pojo.valuation.CmValuationTableAttribute;
|
|
|
|
+import com.simuwang.base.pojo.vo.*;
|
|
|
|
+import com.simuwang.daq.components.PythonReportConverter;
|
|
import com.simuwang.daq.components.report.parser.ReportParser;
|
|
import com.simuwang.daq.components.report.parser.ReportParser;
|
|
import com.simuwang.daq.components.report.parser.ReportParserFactory;
|
|
import com.simuwang.daq.components.report.parser.ReportParserFactory;
|
|
import com.simuwang.daq.components.report.writer.ReportWriter;
|
|
import com.simuwang.daq.components.report.writer.ReportWriter;
|
|
@@ -86,12 +90,15 @@ public class EmailParseService {
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private DaqProperties properties;
|
|
private DaqProperties properties;
|
|
|
|
+ @Autowired
|
|
|
|
+ private FundInfoMapper fundInfoMapper;
|
|
|
|
|
|
/* 报告解析和入库的方法 */
|
|
/* 报告解析和入库的方法 */
|
|
@Autowired
|
|
@Autowired
|
|
private ReportParserFactory reportParserFactory;
|
|
private ReportParserFactory reportParserFactory;
|
|
@Autowired
|
|
@Autowired
|
|
private ReportWriterFactory reportWriterFactory;
|
|
private ReportWriterFactory reportWriterFactory;
|
|
|
|
+ private String pyBaseUrl;
|
|
|
|
|
|
public EmailParseService(EmailTypeRuleMapper emailTypeRuleMapper, EmailRuleConfig emailRuleConfig,
|
|
public EmailParseService(EmailTypeRuleMapper emailTypeRuleMapper, EmailRuleConfig emailRuleConfig,
|
|
EmailFieldMappingMapper emailFieldMapper, EmailParserFactory emailParserFactory,
|
|
EmailFieldMappingMapper emailFieldMapper, EmailParserFactory emailParserFactory,
|