|
|
|
|
@ -1,6 +1,7 @@
|
|
|
|
|
package com.glxp.api.admin.controller.basic;
|
|
|
|
|
|
|
|
|
|
import cn.hutool.extra.pinyin.PinyinUtil;
|
|
|
|
|
import cn.hutool.core.io.IoUtil;
|
|
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
|
|
import com.github.pagehelper.PageInfo;
|
|
|
|
|
import com.glxp.api.admin.constant.BasicProcessStatus;
|
|
|
|
|
import com.glxp.api.admin.entity.basic.UdiInfoImportDetailEntity;
|
|
|
|
|
@ -9,16 +10,16 @@ import com.glxp.api.admin.req.basic.FilterUdiIpLogRequest;
|
|
|
|
|
import com.glxp.api.admin.req.basic.PostUdiInfoRequest;
|
|
|
|
|
import com.glxp.api.admin.req.inout.DeleteRequest;
|
|
|
|
|
import com.glxp.api.admin.res.PageSimpleResponse;
|
|
|
|
|
import com.glxp.api.admin.service.basic.UdiInfoImportLogService;
|
|
|
|
|
import com.glxp.api.admin.res.basic.UdiRelevanceExportJsonResponse;
|
|
|
|
|
import com.glxp.api.admin.service.basic.UdiInfoImportDetailService;
|
|
|
|
|
import com.glxp.api.admin.service.basic.UdiInfoImportLogService;
|
|
|
|
|
import com.glxp.api.admin.thread.BasicUdiInfoImportService;
|
|
|
|
|
import com.glxp.api.admin.util.CustomUtil;
|
|
|
|
|
import com.glxp.api.common.enums.ResultEnum;
|
|
|
|
|
import com.glxp.api.common.res.BaseResponse;
|
|
|
|
|
import com.glxp.api.common.util.ResultVOUtils;
|
|
|
|
|
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
|
|
|
|
|
import org.apache.poi.ss.usermodel.*;
|
|
|
|
|
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
|
|
|
|
|
import org.apache.poi.ss.usermodel.CellType;
|
|
|
|
|
import org.apache.poi.ss.usermodel.Row;
|
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
import org.springframework.validation.BindingResult;
|
|
|
|
|
@ -27,10 +28,7 @@ import org.springframework.web.multipart.MultipartFile;
|
|
|
|
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
|
|
import java.io.File;
|
|
|
|
|
import java.io.IOException;
|
|
|
|
|
import java.io.InputStream;
|
|
|
|
|
import java.sql.Date;
|
|
|
|
|
import java.util.ArrayList;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
@ -48,6 +46,7 @@ public class UdiInfoImportLogController {
|
|
|
|
|
BasicUdiInfoImportService basicUdiInfoImportService;
|
|
|
|
|
private static final String TAG = "UdiInfoImportLogControl";
|
|
|
|
|
private static final Logger log = LoggerFactory.getLogger(UdiInfoImportLogController.class);
|
|
|
|
|
|
|
|
|
|
@GetMapping("/udiwms/products/importLog/filter")
|
|
|
|
|
public BaseResponse filter(FilterUdiIpLogRequest filterUdiIpLogRequest,
|
|
|
|
|
BindingResult bindingResult) {
|
|
|
|
|
@ -130,121 +129,33 @@ public class UdiInfoImportLogController {
|
|
|
|
|
}
|
|
|
|
|
String fileName = file.getOriginalFilename();
|
|
|
|
|
try {
|
|
|
|
|
InputStream inputStream = file.getInputStream();
|
|
|
|
|
Workbook workbook = null;
|
|
|
|
|
String filetype = fileName.substring(fileName.lastIndexOf("."));
|
|
|
|
|
|
|
|
|
|
if (".xls".equals(filetype)) {
|
|
|
|
|
workbook = new HSSFWorkbook(inputStream);
|
|
|
|
|
} else if (".xlsx".equals(filetype)) {
|
|
|
|
|
workbook = new XSSFWorkbook(inputStream);
|
|
|
|
|
} else {
|
|
|
|
|
return ResultVOUtils.error(500, "请上传excel文件");
|
|
|
|
|
}
|
|
|
|
|
Sheet sheet = null;
|
|
|
|
|
Row row = null;
|
|
|
|
|
UdiInfoImportLogEntity udiInfoImportLogEntity = new UdiInfoImportLogEntity();
|
|
|
|
|
String genKey = CustomUtil.getId();
|
|
|
|
|
udiInfoImportLogEntity.setGenKey(genKey);
|
|
|
|
|
udiInfoImportLogEntity.setFromType("文件导入");
|
|
|
|
|
udiInfoImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_UNPROCESS);
|
|
|
|
|
udiInfoImportLogEntity.setUpdateTime(new Date(System.currentTimeMillis()));
|
|
|
|
|
udiInfoImportLogService.insertImportLog(udiInfoImportLogEntity);
|
|
|
|
|
List<UdiInfoImportDetailEntity> udiInfoImportEntities = new ArrayList<>();
|
|
|
|
|
for (int j = 0; j < 1; j++) {
|
|
|
|
|
sheet = workbook.getSheetAt(j);
|
|
|
|
|
if (sheet == null) {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
// 滤过第一行标题
|
|
|
|
|
row = sheet.getRow(0);
|
|
|
|
|
if ((row.getCell(0) == null || row.getCell(1) == null || row.getCell(2) == null
|
|
|
|
|
|| row.getCell(3) == null || row.getCell(4) == null || row.getCell(5) == null || row.getCell(6) == null) ||
|
|
|
|
|
(!"udiCode".equals(row.getCell(0).getStringCellValue())
|
|
|
|
|
|| !"医保编码".equals(row.getCell(1).getStringCellValue())
|
|
|
|
|
|| !"商品条码".equals(row.getCell(2).getStringCellValue())
|
|
|
|
|
|| !"thirdId".equals(row.getCell(3).getStringCellValue())
|
|
|
|
|
|| !"thirdId1".equals(row.getCell(4).getStringCellValue())
|
|
|
|
|
|| !"thirdId2".equals(row.getCell(5).getStringCellValue())
|
|
|
|
|
|| !"thirdId3".equals(row.getCell(6).getStringCellValue()))) {
|
|
|
|
|
return ResultVOUtils.error(500, "文件格式错误！");
|
|
|
|
|
}
|
|
|
|
|
for (int k = sheet.getFirstRowNum() + 1; k <= sheet.getLastRowNum(); k++) {
|
|
|
|
|
row = sheet.getRow(k);
|
|
|
|
|
if (row == null || row.getRowNum() <= 0) {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
if (filterEmpty(row)) {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
UdiInfoImportDetailEntity udiInfoImportEntity = new UdiInfoImportDetailEntity();
|
|
|
|
|
Cell cell1 = row.getCell(0);
|
|
|
|
|
if (cell1 != null) {
|
|
|
|
|
cell1.setCellType(CellType.STRING);
|
|
|
|
|
udiInfoImportEntity.setUdiCode(cell1.getStringCellValue());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Cell cell2 = row.getCell(1);
|
|
|
|
|
if (cell2 != null) {
|
|
|
|
|
cell2.setCellType(CellType.STRING);
|
|
|
|
|
udiInfoImportEntity.setYbbm(cell2.getStringCellValue());
|
|
|
|
|
String fileType = fileName.substring(fileName.lastIndexOf("."));
|
|
|
|
|
if (!".json".equals(fileType.toLowerCase())) {
|
|
|
|
|
return ResultVOUtils.error(500, "请上传json文件");
|
|
|
|
|
}
|
|
|
|
|
Cell cell3 = row.getCell(2);
|
|
|
|
|
if (cell3 != null) {
|
|
|
|
|
cell3.setCellType(CellType.STRING);
|
|
|
|
|
udiInfoImportEntity.setSptm(cell3.getStringCellValue());
|
|
|
|
|
//导入数据
|
|
|
|
|
String jsonData = IoUtil.read(file.getInputStream()).toString();
|
|
|
|
|
UdiRelevanceExportJsonResponse importData = JSONUtil.toBean(jsonData, UdiRelevanceExportJsonResponse.class);
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
Cell cell4 = row.getCell(3);
|
|
|
|
|
if (cell4 != null) {
|
|
|
|
|
cell4.setCellType(CellType.STRING);
|
|
|
|
|
udiInfoImportEntity.setThirdId(cell4.getStringCellValue());
|
|
|
|
|
//导入日志
|
|
|
|
|
UdiInfoImportLogEntity importLog = new UdiInfoImportLogEntity();
|
|
|
|
|
String genKey = CustomUtil.getId();
|
|
|
|
|
importLog.setGenKey(genKey);
|
|
|
|
|
importLog.setFromType("文件导入");
|
|
|
|
|
importLog.setStatus(BasicProcessStatus.UDIINFO_IMPORT_UNPROCESS);
|
|
|
|
|
|
|
|
|
|
importLog.setUpdateTime(new Date(System.currentTimeMillis()));
|
|
|
|
|
udiInfoImportLogService.insertImportLog(importLog);
|
|
|
|
|
udiInfoImportService.importJsonData(importData);
|
|
|
|
|
importLog.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS);
|
|
|
|
|
udiInfoImportLogService.updateImportLog(importLog);
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("产品信息导入失败", e);
|
|
|
|
|
}
|
|
|
|
|
Cell cell5 = row.getCell(4);
|
|
|
|
|
if (cell5 != null) {
|
|
|
|
|
cell5.setCellType(CellType.STRING);
|
|
|
|
|
udiInfoImportEntity.setThirdId1(cell5.getStringCellValue());
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
Cell cell6 = row.getCell(5);
|
|
|
|
|
if (cell6 != null) {
|
|
|
|
|
cell6.setCellType(CellType.STRING);
|
|
|
|
|
udiInfoImportEntity.setThirdId2(cell6.getStringCellValue());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Cell cell7 = row.getCell(6);
|
|
|
|
|
if (cell7 != null) {
|
|
|
|
|
cell7.setCellType(CellType.STRING);
|
|
|
|
|
udiInfoImportEntity.setThirdId3(cell7.getStringCellValue());
|
|
|
|
|
}
|
|
|
|
|
Cell cell8 = row.getCell(7);
|
|
|
|
|
if (cell8 != null) {
|
|
|
|
|
cell8.setCellType(CellType.STRING);
|
|
|
|
|
udiInfoImportEntity.setThirdId4(cell8.getStringCellValue());
|
|
|
|
|
}
|
|
|
|
|
Cell cell9 = row.getCell(8);
|
|
|
|
|
if (cell9 != null) {
|
|
|
|
|
cell9.setCellType(CellType.STRING);
|
|
|
|
|
udiInfoImportEntity.setIsUseDy(cell9.getStringCellValue());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
udiInfoImportEntity.setGenKeyFk(genKey);
|
|
|
|
|
udiInfoImportEntity.setStatus(0);
|
|
|
|
|
udiInfoImportEntity.setUpdateTime(new Date(System.currentTimeMillis()));
|
|
|
|
|
udiInfoImportEntities.add(udiInfoImportEntity);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
udiInfoImportService.insertUdiInfoImports(udiInfoImportEntities);
|
|
|
|
|
udiInfoImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_UNPROCESS);
|
|
|
|
|
udiInfoImportLogService.updateImportLog(udiInfoImportLogEntity);
|
|
|
|
|
workbook.close();
|
|
|
|
|
basicUdiInfoImportService.importUdiInfo(genKey);
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return ResultVOUtils.success("上传成功");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -378,7 +289,7 @@ public class UdiInfoImportLogController {
|
|
|
|
|
udiInfoImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_CODE_UNPROCESS);
|
|
|
|
|
udiInfoImportLogEntity.setUpdateTime(new java.util.Date());
|
|
|
|
|
udiInfoImportLogService.insertImportLog(udiInfoImportLogEntity);
|
|
|
|
|
basicUdiInfoImportService.downloadSmpUdiInfo(genKey,filterUdiIpLogRequest.getLastUpdateTime());
|
|
|
|
|
basicUdiInfoImportService.downloadSmpUdiInfo(genKey, filterUdiIpLogRequest.getLastUpdateTime());
|
|
|
|
|
return ResultVOUtils.success("后台已开始下载并更新，请稍后刷新查看!");
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
MrZhai
3 years ago