| | |
|---|
| | | import com.panzhihua.common.model.vos.community.ComMngRealCompanyExcelVO; |
|---|
| | | import com.panzhihua.common.service.community.CommunityService; |
|---|
| | | import com.panzhihua.common.utlis.ListUtils; |
|---|
| | | import com.panzhihua.common.utlis.StringUtils; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | |
|---|
| | | import java.util.ArrayList; |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | private static final int BATCH_COUNT = 100; |
|---|
| | | private static final int BATCH_COUNT = 5000; |
|---|
| | | private List<ComMngRealCompanyExcelVO> list = new ArrayList<>(); |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void invoke(ComMngRealCompanyExcelVO comMngRealCompanyExcelVO, AnalysisContext analysisContext) { |
|---|
| | | if(StringUtils.isEmpty(comMngRealCompanyExcelVO.getCreditCode())){ |
|---|
| | | throw new ServiceException("统一社会信用代码不可为空"); |
|---|
| | | } |
|---|
| | | list.add(comMngRealCompanyExcelVO); |
|---|
| | | // 达到BATCH_COUNT了，需要去存储一次数据库，防止数据几万条数据在内存，容易OOM |
|---|
| | | if(list.size() >= BATCH_COUNT){ |
|---|
