|
|
|
@ -59,7 +59,7 @@ public class TransDetailDataListener extends AnalysisEventListener<TbTransDetail |
|
|
|
public void invoke(TbTransDetailEntity data, AnalysisContext context) { |
|
|
|
LOGGER.info("解析到一条数据:{}", JSON.toJSONString(data)); |
|
|
|
if(StringUtils.isNotEmpty(data.getBusiType()) && |
|
|
|
(data.getBusiType().equals("证券买入") || data.getBusiType().equals("证券卖出") )) { |
|
|
|
(data.getBusiType().equals("证券买入") || data.getBusiType().equals("证券卖出") || data.getBusiType().equals("红股入帐") )) { |
|
|
|
data.setImportId(Integer.parseInt(importId)); |
|
|
|
//stockCode补零
|
|
|
|
if (data.getStockCode() != null) { |
|
|
|
|