| | |
|---|
| | | import com.java110.utils.factory.ApplicationContextFactory; |
|---|
| | | import com.java110.utils.util.*; |
|---|
| | | import com.java110.vo.ResultVo; |
|---|
| | | import importData.IImportDataCleaningAdapt; |
|---|
| | | import com.java110.api.importData.IImportDataCleaningAdapt; |
|---|
| | | import org.apache.poi.ss.usermodel.Workbook; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import com.java110.core.log.LoggerFactory; |
|---|
| | |
|---|
| | | import org.springframework.web.client.RestTemplate; |
|---|
| | | import org.springframework.web.multipart.MultipartFile; |
|---|
| | | |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.Calendar; |
|---|
| | | import java.util.List; |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public ResponseEntity<String> importExcelData(IPageData pd, MultipartFile uploadFile) throws Exception { |
|---|
| | | JSONObject paramIn = JSONObject.parseObject(pd.getReqData()); |
|---|
| | | paramIn.put("userId", pd.getUserId()); |
|---|
| | | Assert.hasKeyAndValue(paramIn, "importAdapt", "未包含模板"); |
|---|
| | | String importAdapt = paramIn.getString("importAdapt") + "DataCleaning"; |
|---|
| | | |
|---|
| | |
|---|
| | | } |
|---|
| | | try { |
|---|
| | | ComponentValidateResult result = this.validateStoreStaffCommunityRelationship(pd, restTemplate); |
|---|
| | | paramIn.put("storeId", result.getStoreId()); |
|---|
| | | |
|---|
| | | Workbook workbook = null; //工作簿 |
|---|
| | | //工作表 |
|---|
| | |
|---|
| | | List<AssetImportLogDetailPo> assetImportLogDetailPos = new ArrayList<>(); |
|---|
| | | AssetImportLogDetailPo assetImportLogDetailPo = null; |
|---|
| | | int flag = 0; |
|---|
| | | Calendar createTimeCal = Calendar.getInstance(); |
|---|
| | | for (Object data : datas) { |
|---|
| | | createTimeCal.add(Calendar.SECOND,1); |
|---|
| | | assetImportLogDetailPo = new AssetImportLogDetailPo(); |
|---|
| | | assetImportLogDetailPo.setDetailId(GenerateCodeFactory.getGeneratorId("11")); |
|---|
| | | assetImportLogDetailPo.setLogId(logId); |
|---|
| | |
|---|
| | | assetImportLogDetailPo.setMessage("待导入"); |
|---|
| | | assetImportLogDetailPo.setCommunityId(result.getCommunityId()); |
|---|
| | | assetImportLogDetailPo.setContent(JSONObject.toJSONString(data)); |
|---|
| | | assetImportLogDetailPo.setCreateTime(DateUtil.getFormatTimeStringA(createTimeCal.getTime())); |
|---|
| | | assetImportLogDetailPos.add(assetImportLogDetailPo); |
|---|
| | | if (assetImportLogDetailPos.size() > DEFAULT_ROWS) { |
|---|
| | | flag = assetImportLogDetailInnerServiceSMOImpl.saveAssetImportLogDetails(assetImportLogDetailPos); |
|---|
| | |
|---|
| | | // todo 调用 导入队列开始导入 |
|---|
| | | flag = userImportDataV1InnerServiceSMOImpl.importExcelData(assetImportLogPo); |
|---|
| | | if (flag > 0) { |
|---|
| | | return ResultVo.success(); |
|---|
| | | return ResultVo.createResponseEntity(assetImportLogPo); |
|---|
| | | } |
|---|
| | | return ResultVo.error("导入失败"); |
|---|
| | | } |
|---|
