Browse Source

Merge branch 'dev_epidemic_situation' of http://git.elinkit.com.cn:7070/r/epmet-cloud into develop

master
jianjun 4 years ago
parent
commit
7e05c3abf6
  1. 2
      epmet-module/epmet-common-service/common-service-server/src/main/resources/db/migration/V0.0.14__add_areacode_flag.sql
  2. 2
      epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcNatController.java
  3. 1
      epmet-user/epmet-user-server/src/main/java/com/epmet/excel/data/IcNatImportExcelData.java
  4. 46
      epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcNatServiceImpl.java

2
epmet-module/epmet-common-service/common-service-server/src/main/resources/db/migration/V0.0.14__add_areacode_flag.sql

@ -13,7 +13,7 @@ SELECT ID, `CODE`, `NAME`, `P_CODE`, `LEVEL`, `CATAGORY`, `DEL_FLAG`, `REVISION`
SELECT * FROM area_code_new WHERE county_code = '441900'; SELECT * FROM area_code_new WHERE county_code = '441900';
#清空数据 #清空数据
DELETE FROM area_code; DELETE FROM area_code where 1=1;
#插入数据 #插入数据
INSERT INTO `epmet_common_service`.`area_code` INSERT INTO `epmet_common_service`.`area_code`
SELECT * FROM area_code_new; SELECT * FROM area_code_new;

2
epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcNatController.java

@ -278,7 +278,7 @@ public class IcNatController implements ResultDataResolver {
data = icNucleinService.natList(formDTO); data = icNucleinService.natList(formDTO);
data.getList().forEach(o-> { data.getList().forEach(o-> {
o.setNatResult(NumConstant.ONE_STR.equals(o.getNatResult()) ? "阳性" : "阴性"); o.setNatResult(NumConstant.ONE_STR.equals(o.getNatResult()) ? "阳性" : "阴性");
o.setIsResiUser(NumConstant.ONE_STR.equals(o.getNatResult()) ? "是" : "否"); o.setIsResiUser(NumConstant.ONE_STR.equals(o.getIsResiUser()) ? "是" : "否");
}); });
formDTO.setPageNo(++pageNo); formDTO.setPageNo(++pageNo);
if ("current".equals(formDTO.getOrgType())) { if ("current".equals(formDTO.getOrgType())) {

1
epmet-user/epmet-user-server/src/main/java/com/epmet/excel/data/IcNatImportExcelData.java

@ -31,7 +31,6 @@ public class IcNatImportExcelData {
@ExcelProperty("检测时间") @ExcelProperty("检测时间")
private Date natTime; private Date natTime;
@NotBlank(message = "检测地点为必填项")
@ExcelProperty("检测地点") @ExcelProperty("检测地点")
private String natAddress; private String natAddress;

46
epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcNatServiceImpl.java

@ -279,7 +279,7 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
relationEntity.setCustomerId(formDTO.getCustomerId()); relationEntity.setCustomerId(formDTO.getCustomerId());
relationEntity.setIcNatId(formDTO.getIcNatId()); relationEntity.setIcNatId(formDTO.getIcNatId());
relationEntity.setAgencyId(staffInfo.getAgencyId()); relationEntity.setAgencyId(staffInfo.getAgencyId());
relationEntity.setPids(StringUtils.isNotBlank(staffInfo.getAgencyPIds())?staffInfo.getAgencyPIds()+":"+formDTO.getAgencyId():staffInfo.getAgencyId()); relationEntity.setPids(StringUtils.isNotBlank(staffInfo.getAgencyPIds())?staffInfo.getAgencyPIds()+":"+staffInfo.getAgencyId():staffInfo.getAgencyId());
relationEntity.setUserType("synchro"); relationEntity.setUserType("synchro");
icNatRelationDao.insert(relationEntity); icNatRelationDao.insert(relationEntity);
} }
@ -334,27 +334,29 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
// 合并到一起写入 // 合并到一起写入
errorRows.addAll(otherRows); errorRows.addAll(otherRows);
// 生成并上传错误文件 // 生成并上传描述文件
try { if (errorRows.size() > 0) {
// 文件生成 try {
Path errorDescDir = FileUtils.getAndCreateDirUnderEpmetFilesDir("ic_nat", "import", "error_des"); // 文件生成
String fileName = UUID.randomUUID().toString().concat(".xlsx"); Path errorDescDir = FileUtils.getAndCreateDirUnderEpmetFilesDir("ic_nat", "import", "error_des");
errorDescFile = errorDescDir.resolve(fileName); String fileName = UUID.randomUUID().toString().concat(".xlsx");
errorDescFile = errorDescDir.resolve(fileName);
FileItemFactory factory = new DiskFileItemFactory(16, errorDescDir.toFile());
FileItem fileItem = factory.createItem("file", ContentType.APPLICATION_OCTET_STREAM.toString(), true, fileName); FileItemFactory factory = new DiskFileItemFactory(16, errorDescDir.toFile());
OutputStream os = fileItem.getOutputStream(); FileItem fileItem = factory.createItem("file", ContentType.APPLICATION_OCTET_STREAM.toString(), true, fileName);
OutputStream os = fileItem.getOutputStream();
EasyExcel.write(os, IcNatImportExcelData.RowRemarkMessage.class).sheet("信息列表").doWrite(errorRows);
EasyExcel.write(os, IcNatImportExcelData.RowRemarkMessage.class).sheet("信息列表").doWrite(errorRows);
// 文件上传oss // 文件上传oss
Result<UploadImgResultDTO> errorDesFileUploadResult = ossFeignClient.uploadImportTaskDescFile(new CommonsMultipartFile(fileItem)); Result<UploadImgResultDTO> errorDesFileUploadResult = ossFeignClient.uploadImportTaskDescFile(new CommonsMultipartFile(fileItem));
if (errorDesFileUploadResult.success()) { if (errorDesFileUploadResult.success()) {
errorDesFileUrl = errorDesFileUploadResult.getData().getUrl(); errorDesFileUrl = errorDesFileUploadResult.getData().getUrl();
} }
} finally {
if (Files.exists(errorDescFile)) { } finally {
Files.delete(errorDescFile); if (Files.exists(errorDescFile)) {
Files.delete(errorDescFile);
}
} }
} }

Loading…
Cancel
Save