耗材字典导入导出代码提交
郑明梁
2 years ago
parent
24b711893d
commit
4fd3f08bf1
@ -0,0 +1,295 @@
|
||||
package com.glxp.api.controller.basic;
|
||||
|
||||
import cn.hutool.core.io.IoUtil;
|
||||
import cn.hutool.json.JSONUtil;
|
||||
import com.github.pagehelper.PageInfo;
|
||||
import com.glxp.api.common.enums.ResultEnum;
|
||||
import com.glxp.api.common.res.BaseResponse;
|
||||
import com.glxp.api.common.util.ResultVOUtils;
|
||||
import com.glxp.api.constant.BasicProcessStatus;
|
||||
import com.glxp.api.entity.basic.BasicProductsImportDetailEntity;
|
||||
import com.glxp.api.entity.basic.BasicProductsImportLogEntity;
|
||||
import com.glxp.api.req.basic.FilterUdiIpLogRequest;
|
||||
import com.glxp.api.req.basic.PostUdiInfoRequest;
|
||||
import com.glxp.api.req.system.DeleteRequest;
|
||||
import com.glxp.api.res.PageSimpleResponse;
|
||||
import com.glxp.api.res.basic.UdiRelevanceExportJsonResponse;
|
||||
import com.glxp.api.service.basic.BasicProductsImportDetailService;
|
||||
import com.glxp.api.service.basic.BasicProductsImportLogService;
|
||||
import com.glxp.api.util.CustomUtil;
|
||||
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;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
import org.springframework.web.multipart.MultipartFile;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.io.File;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.sql.Date;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 医疗器械信息导入
|
||||
*/
|
||||
|
||||
@RestController
|
||||
public class BasicProductsImportLogController {
|
||||
|
||||
@Resource
|
||||
BasicProductsImportLogService basicProductsImportLogService;
|
||||
@Resource
|
||||
BasicProductsImportDetailService basicProductsImportDetailService;
|
||||
|
||||
|
||||
private static final String TAG = "UdiInfoImportLogControl";
|
||||
private static final Logger log = LoggerFactory.getLogger(BasicProductsImportLogController.class);
|
||||
|
||||
@GetMapping("/udiwms/products/importLog/filter")
|
||||
public BaseResponse filter(FilterUdiIpLogRequest filterUdiIpLogRequest,
|
||||
BindingResult bindingResult) {
|
||||
|
||||
if (bindingResult.hasErrors()) {
|
||||
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
|
||||
}
|
||||
List<BasicProductsImportLogEntity> udiInfoImportLogEntities
|
||||
= basicProductsImportLogService.filterImportLog(filterUdiIpLogRequest);
|
||||
PageInfo<BasicProductsImportLogEntity> pageInfo;
|
||||
pageInfo = new PageInfo<>(udiInfoImportLogEntities);
|
||||
PageSimpleResponse<BasicProductsImportLogEntity> pageSimpleResponse = new PageSimpleResponse<>();
|
||||
pageSimpleResponse.setTotal(pageInfo.getTotal());
|
||||
pageSimpleResponse.setList(udiInfoImportLogEntities);
|
||||
return ResultVOUtils.success(pageSimpleResponse);
|
||||
}
|
||||
|
||||
@GetMapping("/udiwms/products/importLog/filterDetail")
|
||||
public BaseResponse filterDetail(FilterUdiIpLogRequest filterUdiIpLogRequest,
|
||||
BindingResult bindingResult) {
|
||||
|
||||
if (bindingResult.hasErrors()) {
|
||||
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
|
||||
}
|
||||
List<BasicProductsImportDetailEntity> udiInfoImportEntities
|
||||
= basicProductsImportDetailService.filterUdiInfoImport(filterUdiIpLogRequest);
|
||||
PageInfo<BasicProductsImportDetailEntity> pageInfo;
|
||||
pageInfo = new PageInfo<>(udiInfoImportEntities);
|
||||
PageSimpleResponse<BasicProductsImportDetailEntity> pageSimpleResponse = new PageSimpleResponse<>();
|
||||
pageSimpleResponse.setTotal(pageInfo.getTotal());
|
||||
pageSimpleResponse.setList(udiInfoImportEntities);
|
||||
return ResultVOUtils.success(pageSimpleResponse);
|
||||
}
|
||||
|
||||
|
||||
@PostMapping("/udiwms/products/importLog/deleteLog")
|
||||
public BaseResponse deleteLog(@RequestBody DeleteRequest deleteRequest, BindingResult bindingResult) {
|
||||
|
||||
if (bindingResult.hasErrors()) {
|
||||
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
|
||||
}
|
||||
String id = deleteRequest.getId();
|
||||
FilterUdiIpLogRequest filterInCodeLogRequest = new FilterUdiIpLogRequest();
|
||||
filterInCodeLogRequest.setId(Integer.parseInt(id));
|
||||
List<BasicProductsImportLogEntity> importLogEntities = basicProductsImportLogService.filterImportLog(filterInCodeLogRequest);
|
||||
if (importLogEntities != null && importLogEntities.size() > 0) {
|
||||
BasicProductsImportLogEntity importLogEntity = importLogEntities.get(0);
|
||||
basicProductsImportLogService.deleteById(importLogEntity.getId() + "");
|
||||
basicProductsImportDetailService.deleteByGenkey(importLogEntity.getGenKey());
|
||||
}
|
||||
|
||||
return ResultVOUtils.success("删除成功");
|
||||
}
|
||||
|
||||
@PostMapping("/udiwms/products/importLog/delete")
|
||||
public BaseResponse delete(@RequestBody DeleteRequest deleteRequest, BindingResult bindingResult) {
|
||||
|
||||
if (bindingResult.hasErrors()) {
|
||||
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
|
||||
}
|
||||
if (basicProductsImportDetailService.deleteById(deleteRequest.getId()))
|
||||
return ResultVOUtils.success("删除成功");
|
||||
else
|
||||
return ResultVOUtils.error(500, "删除成功");
|
||||
}
|
||||
|
||||
|
||||
//产品信息文件导入
|
||||
@PostMapping("/udiwms/products/importLog/upload")
|
||||
public BaseResponse uploadProducts(@RequestParam("file") List<MultipartFile> files, @RequestParam("thirdSys") String thirdSys) {
|
||||
String filePath = "D:\\udiwms\\filePath\\";
|
||||
File createFile = new File(filePath);
|
||||
if (!createFile.exists()) {
|
||||
createFile.mkdirs();
|
||||
}
|
||||
for (int i = 0; i < files.size(); i++) {
|
||||
MultipartFile file = files.get(i);
|
||||
if (file.isEmpty()) {
|
||||
return ResultVOUtils.error(500, "上传第" + (i++) + "个文件失败");
|
||||
}
|
||||
String fileName = file.getOriginalFilename();
|
||||
try {
|
||||
String fileType = fileName.substring(fileName.lastIndexOf("."));
|
||||
if (!".udi".equalsIgnoreCase(fileType) && !".LowerIn".equalsIgnoreCase(fileType)) {
|
||||
return ResultVOUtils.error(500, "请上传udi文件或者LowerIn文件");
|
||||
}
|
||||
//导入数据
|
||||
String jsonData = IoUtil.read(file.getInputStream(), StandardCharsets.UTF_8);
|
||||
UdiRelevanceExportJsonResponse importData = JSONUtil.toBean(jsonData, UdiRelevanceExportJsonResponse.class);
|
||||
|
||||
//导入日志
|
||||
BasicProductsImportLogEntity importLog = new BasicProductsImportLogEntity();
|
||||
String genKey = CustomUtil.getId();
|
||||
importLog.setGenKey(genKey);
|
||||
importLog.setFromType("文件导入");
|
||||
importLog.setStatus(BasicProcessStatus.UDIINFO_IMPORT_UNPROCESS);
|
||||
|
||||
importLog.setUpdateTime(new Date(System.currentTimeMillis()));
|
||||
basicProductsImportLogService.insertImportLog(importLog);
|
||||
basicProductsImportDetailService.importJsonData(importData);
|
||||
importLog.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS);
|
||||
importLog.setRemark("本次耗材字典导入"+importData.getUdiProductEntities().size()+"条");
|
||||
basicProductsImportLogService.updateImportLog(importLog);
|
||||
} catch (Exception e) {
|
||||
log.error("产品信息导入失败", e);
|
||||
}
|
||||
}
|
||||
return ResultVOUtils.success("上传成功");
|
||||
}
|
||||
|
||||
public boolean filterEmpty(Row row) {
|
||||
|
||||
if (row.getCell(0) != null) {
|
||||
row.getCell(0).setCellType(CellType.STRING);
|
||||
}
|
||||
if (row.getCell(1) != null) {
|
||||
row.getCell(1).setCellType(CellType.STRING);
|
||||
}
|
||||
if (row.getCell(2) != null) {
|
||||
row.getCell(2).setCellType(CellType.STRING);
|
||||
}
|
||||
if (row.getCell(3) != null) {
|
||||
row.getCell(3).setCellType(CellType.STRING);
|
||||
}
|
||||
if (row.getCell(4) != null) {
|
||||
row.getCell(4).setCellType(CellType.STRING);
|
||||
}
|
||||
if (row.getCell(5) != null) {
|
||||
row.getCell(5).setCellType(CellType.STRING);
|
||||
}
|
||||
if (row.getCell(6) != null) {
|
||||
row.getCell(6).setCellType(CellType.STRING);
|
||||
}
|
||||
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) ||
|
||||
(
|
||||
(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) &&
|
||||
("".equals(row.getCell(0).getStringCellValue())
|
||||
&& "".equals(row.getCell(1).getStringCellValue())
|
||||
&& "".equals(row.getCell(2).getStringCellValue())
|
||||
&& "".equals(row.getCell(3).getStringCellValue())
|
||||
&& "".equals(row.getCell(4).getStringCellValue())
|
||||
&& "".equals(row.getCell(5).getStringCellValue())
|
||||
&& "".equals(row.getCell(6).getStringCellValue()))
|
||||
)) {
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
//产品信息接口上传
|
||||
@PostMapping("/udiwms/basic/products/upload")
|
||||
public BaseResponse postUdiInfo(@RequestBody PostUdiInfoRequest postUdiInfoRequest, BindingResult bindingResult) {
|
||||
if (bindingResult.hasErrors()) {
|
||||
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
|
||||
}
|
||||
|
||||
String genKey = postUdiInfoRequest.getGenKey();
|
||||
if (genKey == null) {
|
||||
genKey = CustomUtil.getId();
|
||||
}
|
||||
BasicProductsImportLogEntity basicProductsImportLogEntity = basicProductsImportLogService.selectByGenKey(genKey);
|
||||
List<BasicProductsImportDetailEntity> udiInfoImportEntities = postUdiInfoRequest.getDatas();
|
||||
if (udiInfoImportEntities != null) {
|
||||
for (BasicProductsImportDetailEntity udiInfoImportEntity : udiInfoImportEntities) {
|
||||
udiInfoImportEntity.setGenKeyFk(genKey);
|
||||
udiInfoImportEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_CODE_UNPROCESS);
|
||||
udiInfoImportEntity.setUpdateTime(new java.util.Date());
|
||||
basicProductsImportDetailService.insertUdiInfoImport(udiInfoImportEntity);
|
||||
}
|
||||
}
|
||||
if (basicProductsImportLogEntity == null) {
|
||||
basicProductsImportLogEntity = new BasicProductsImportLogEntity();
|
||||
basicProductsImportLogEntity.setGenKey(genKey);
|
||||
basicProductsImportLogEntity.setFromType("接口上传");
|
||||
basicProductsImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_UNPROCESS);
|
||||
basicProductsImportLogEntity.setUpdateTime(new Date(System.currentTimeMillis()));
|
||||
basicProductsImportLogService.insertImportLog(basicProductsImportLogEntity);
|
||||
} else {
|
||||
basicProductsImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_UNPROCESS);
|
||||
basicProductsImportLogService.updateImportLog(basicProductsImportLogEntity);
|
||||
}
|
||||
basicProductsImportLogService.importUdiInfo(genKey);
|
||||
return ResultVOUtils.success("上传成功");
|
||||
}
|
||||
|
||||
|
||||
//扫码精灵产品信息接口上传
|
||||
@PostMapping("/udiwms/basic/products/srUpload")
|
||||
public BaseResponse postSrUdiInfo(@RequestBody PostUdiInfoRequest postUdiInfoRequest, BindingResult bindingResult) {
|
||||
if (bindingResult.hasErrors()) {
|
||||
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
|
||||
}
|
||||
|
||||
String genKey = postUdiInfoRequest.getGenKey();
|
||||
if (genKey == null) {
|
||||
genKey = CustomUtil.getId();
|
||||
}
|
||||
BasicProductsImportLogEntity basicProductsImportLogEntity = basicProductsImportLogService.selectByGenKey(genKey);
|
||||
List<BasicProductsImportDetailEntity> udiInfoImportEntities = postUdiInfoRequest.getDatas();
|
||||
if (udiInfoImportEntities != null) {
|
||||
for (BasicProductsImportDetailEntity udiInfoImportEntity : udiInfoImportEntities) {
|
||||
udiInfoImportEntity.setGenKeyFk(genKey);
|
||||
udiInfoImportEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_CODE_UNPROCESS);
|
||||
udiInfoImportEntity.setUpdateTime(new java.util.Date());
|
||||
basicProductsImportDetailService.insertUdiInfoImport(udiInfoImportEntity);
|
||||
}
|
||||
}
|
||||
if (basicProductsImportLogEntity == null) {
|
||||
basicProductsImportLogEntity = new BasicProductsImportLogEntity();
|
||||
basicProductsImportLogEntity.setGenKey(genKey);
|
||||
basicProductsImportLogEntity.setFromType("扫码精灵上传");
|
||||
basicProductsImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_UNPROCESS);
|
||||
basicProductsImportLogEntity.setUpdateTime(new Date(System.currentTimeMillis()));
|
||||
basicProductsImportLogService.insertImportLog(basicProductsImportLogEntity);
|
||||
} else {
|
||||
basicProductsImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_UNPROCESS);
|
||||
basicProductsImportLogService.updateImportLog(basicProductsImportLogEntity);
|
||||
}
|
||||
basicProductsImportLogService.importUdiInfo(genKey);
|
||||
return ResultVOUtils.success("上传成功");
|
||||
}
|
||||
|
||||
//供应商平台产品信息下载
|
||||
@GetMapping("/udiwms/products/smp/download")
|
||||
public BaseResponse downloadSmpUdi(FilterUdiIpLogRequest filterUdiIpLogRequest,
|
||||
BindingResult bindingResult) {
|
||||
|
||||
if (bindingResult.hasErrors()) {
|
||||
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
|
||||
}
|
||||
String genKey = CustomUtil.getId();
|
||||
BasicProductsImportLogEntity basicProductsImportLogEntity = new BasicProductsImportLogEntity();
|
||||
basicProductsImportLogEntity.setGenKey(genKey);
|
||||
basicProductsImportLogEntity.setFromType("供应商平台下载");
|
||||
basicProductsImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_CODE_UNPROCESS);
|
||||
basicProductsImportLogEntity.setUpdateTime(new java.util.Date());
|
||||
basicProductsImportLogService.insertImportLog(basicProductsImportLogEntity);
|
||||
basicProductsImportLogService.downloadSmpUdiInfo(genKey, filterUdiIpLogRequest.getLastUpdateTime());
|
||||
return ResultVOUtils.success("后台已开始下载并更新，请稍后刷新查看!");
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,29 @@
|
||||
package com.glxp.api.dao.basic;
|
||||
|
||||
|
||||
import com.glxp.api.entity.basic.BasicProductsExportLogEntity;
|
||||
import com.glxp.api.req.basic.FilterUdiEpLogRequest;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
public interface BasicProductsExportLogDao {
|
||||
|
||||
List<BasicProductsExportLogEntity> filterUdiInfoExportLog(FilterUdiEpLogRequest filterInCodeLogRequest);
|
||||
|
||||
boolean insertUdiInfoExportLog(BasicProductsExportLogEntity udiInfoImportEntity);
|
||||
|
||||
boolean updateUdiInfoExportLog(BasicProductsExportLogEntity udiInfoImportEntity);
|
||||
|
||||
boolean deleteById(@Param("id") String id);
|
||||
|
||||
/**
|
||||
* 根据ID查询文件位置
|
||||
*
|
||||
* @param id
|
||||
* @return
|
||||
*/
|
||||
String selectFilePathById(@Param("id") String id);
|
||||
}
|
||||
@ -0,0 +1,26 @@
|
||||
package com.glxp.api.dao.basic;
|
||||
|
||||
|
||||
import com.glxp.api.entity.basic.BasicProductsImportDetailEntity;
|
||||
import com.glxp.api.req.basic.FilterUdiIpLogRequest;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
public interface BasicProductsImportDetailDao {
|
||||
|
||||
List<BasicProductsImportDetailEntity> filterUdiInfoImport(FilterUdiIpLogRequest filterInCodeLogRequest);
|
||||
|
||||
boolean insertUdiInfoImport(BasicProductsImportDetailEntity udiInfoImportEntity);
|
||||
|
||||
boolean updateUdiInfoImport(BasicProductsImportDetailEntity udiInfoImportEntity);
|
||||
|
||||
boolean insertUdiInfoImports(@Param("udiInfos") List<BasicProductsImportDetailEntity> udiInfos);
|
||||
|
||||
boolean deleteById(@Param("id") String id);
|
||||
|
||||
boolean deleteByGenkey(@Param("genKey") String genKey);
|
||||
|
||||
}
|
||||
@ -0,0 +1,23 @@
|
||||
package com.glxp.api.dao.basic;
|
||||
|
||||
|
||||
import com.glxp.api.entity.basic.BasicProductsImportLogEntity;
|
||||
import com.glxp.api.req.basic.FilterUdiIpLogRequest;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Mapper
|
||||
public interface BasicProductsImportLogDao {
|
||||
|
||||
List<BasicProductsImportLogEntity> filterImportLog(FilterUdiIpLogRequest filterInCodeLogRequest);
|
||||
|
||||
boolean insertImportLog(BasicProductsImportLogEntity basicProductsImportLogEntity);
|
||||
|
||||
boolean updateImportLog(BasicProductsImportLogEntity basicProductsImportLogEntity);
|
||||
|
||||
boolean deleteById(@Param("id") String id);
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,15 @@
|
||||
package com.glxp.api.req.basic;
|
||||
|
||||
|
||||
import com.glxp.api.util.page.ListPageRequest;
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class FilterUdiEpLogRequest extends ListPageRequest {
|
||||
|
||||
|
||||
|
||||
private String genKey;
|
||||
private Integer status;
|
||||
private Integer type;
|
||||
}
|
||||
@ -0,0 +1,17 @@
|
||||
package com.glxp.api.req.basic;
|
||||
|
||||
|
||||
import com.glxp.api.util.page.ListPageRequest;
|
||||
import lombok.Data;
|
||||
|
||||
|
||||
@Data
|
||||
public class FilterUdiIpLogRequest extends ListPageRequest {
|
||||
|
||||
private Integer id;
|
||||
private String genKey;
|
||||
private Integer status;
|
||||
private String thirdSysFk;
|
||||
private String fromType;
|
||||
private String lastUpdateTime;
|
||||
}
|
||||
@ -0,0 +1,13 @@
|
||||
package com.glxp.api.req.basic;
|
||||
|
||||
|
||||
import com.glxp.api.entity.basic.BasicProductsImportDetailEntity;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Data
|
||||
public class PostUdiInfoRequest {
|
||||
private String genKey;
|
||||
private List<BasicProductsImportDetailEntity> datas;
|
||||
}
|
||||
@ -0,0 +1,83 @@
|
||||
package com.glxp.api.req.basic;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class UdiInfoRequest {
|
||||
private Integer id;
|
||||
private String nameCode;
|
||||
private String packRatio;
|
||||
private String packLevel;
|
||||
private Integer bhxjsl;
|
||||
private Integer bhzxxsbzsl;
|
||||
private Integer zxxsbzbhsydysl;
|
||||
private String bhxjcpbm;
|
||||
private String sjcpbm; //
|
||||
private String bzcj;
|
||||
private String addType;
|
||||
private String deviceRecordKey;
|
||||
private String cpmctymc;
|
||||
private String cplb;
|
||||
private String flbm;
|
||||
private String ggxh;
|
||||
private String qxlb;
|
||||
private String tyshxydm;
|
||||
private String ylqxzcrbarmc;
|
||||
private String zczbhhzbapzbh;
|
||||
private String ylqxzcrbarywmc;
|
||||
private String sydycpbs;
|
||||
private String uuid;
|
||||
private Integer versionNumber;
|
||||
private Integer diType;
|
||||
private String thirdId;
|
||||
private String thirdName;
|
||||
private String ybbm;
|
||||
private String sptm;
|
||||
private String manufactory;
|
||||
private String measname;
|
||||
private Integer productType;
|
||||
private String scbssfbhph;
|
||||
private String scbssfbhxlh;
|
||||
private String scbssfbhscrq;
|
||||
private String scbssfbhsxrq;
|
||||
private String cpms;
|
||||
private String spmc;
|
||||
private String originUuid;
|
||||
|
||||
//本地生成信息
|
||||
private String batchNo;
|
||||
private String produceDate;
|
||||
private String expireDate;
|
||||
private String serialNo;
|
||||
private String udi;
|
||||
private String code;
|
||||
private Integer count;
|
||||
private String warehouseCode;
|
||||
private String udplatCode;
|
||||
private String relId;//关联ID主键
|
||||
private Integer status;
|
||||
private String supId;
|
||||
|
||||
private Boolean isCheck;
|
||||
private boolean allowNoBatch;
|
||||
private boolean allowNoExpire;
|
||||
private boolean allowNoProduct;
|
||||
|
||||
private String price;
|
||||
private String cplx;
|
||||
private String hchzsb;
|
||||
|
||||
//产品代理商
|
||||
private String cpdls;
|
||||
|
||||
|
||||
private String basicPrductRemak1;
|
||||
private String basicPrductRemak2;
|
||||
private String basicPrductRemak3;
|
||||
private String basicPrductRemak4;
|
||||
private String basicPrductRemak5;
|
||||
private String basicPrductRemak6;
|
||||
private String basicPrductRemak7;
|
||||
private String basicPrductRemak8;
|
||||
|
||||
}
|
||||
@ -0,0 +1,42 @@
|
||||
package com.glxp.api.req.basic;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class UdiRelevanceRequest {
|
||||
|
||||
private String id;
|
||||
private String thirdId;
|
||||
private String thirdName;
|
||||
private String uuid;
|
||||
private Boolean isUseDy;
|
||||
private String updateTime;
|
||||
private String thirdId1;
|
||||
private String thirdId2;
|
||||
private String thirdId3;
|
||||
private String thirdId4;
|
||||
private String thirdName1;
|
||||
private String thirdName2;
|
||||
private String thirdName3;
|
||||
private String thirdName4;
|
||||
private String manufactory;
|
||||
private String measname;
|
||||
private String ybbm;
|
||||
private String sptm;
|
||||
private Boolean isDisable;
|
||||
private Boolean isLock;
|
||||
private String mainId;
|
||||
private String mainName;
|
||||
private Integer lockStatus;
|
||||
private String udplatCode;
|
||||
private Boolean isAdavence;
|
||||
private String supName;
|
||||
private String originUuid;
|
||||
private String price;
|
||||
private String modifyTime; //修改时间
|
||||
|
||||
private Boolean useMuti; //是否多次使用
|
||||
private Integer useNum; //最小包装单元可使用次数
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,32 @@
|
||||
package com.glxp.api.res.basic;
|
||||
|
||||
|
||||
import com.glxp.api.entity.basic.*;
|
||||
import com.glxp.api.entity.thrsys.ThrProductsEntity;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 医疗器械信息导出实体类
|
||||
*/
|
||||
@Data
|
||||
public class UdiRelevanceExportJsonResponse {
|
||||
|
||||
List<UdiProductEntity> udiProductEntities;
|
||||
|
||||
List<UdiRelevanceEntity> udiRelevanceEntities;
|
||||
|
||||
//第三方产品信息
|
||||
List<ThrProductsEntity> thrProductsEntities;
|
||||
|
||||
public UdiRelevanceExportJsonResponse() {
|
||||
this.udiProductEntities = new ArrayList<>();
|
||||
this.udiRelevanceEntities = new ArrayList<>();
|
||||
this.udiRlSupEntityList = new ArrayList<>();
|
||||
this.thrProductsEntities = new ArrayList<>();
|
||||
}
|
||||
|
||||
private List<UdiRlSupEntity> udiRlSupEntityList;
|
||||
}
|
||||
@ -0,0 +1,54 @@
|
||||
package com.glxp.api.res.basic;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class UdiRlDlResponse {
|
||||
|
||||
private int id;
|
||||
private String thirdId;
|
||||
private String thirdName;
|
||||
private String uuid;
|
||||
private String nameCode;
|
||||
private String packLevel;
|
||||
private String packRatio;
|
||||
private Integer bhxjsl;
|
||||
private Integer bhzxxsbzsl;
|
||||
private Integer zxxsbzbhsydysl;
|
||||
private String bhxjcpbm;
|
||||
private String sjcpbm; //
|
||||
private String bzcj;
|
||||
private String addType;
|
||||
private String deviceRecordKey;
|
||||
private int isUseDy;
|
||||
private String cpmctymc;
|
||||
private String cplb;
|
||||
private String flbm;
|
||||
private String ggxh;
|
||||
private String qxlb;
|
||||
private String tyshxydm;
|
||||
private String ylqxzcrbarmc;
|
||||
private String zczbhhzbapzbh;
|
||||
private String ylqxzcrbarywmc;
|
||||
private String sydycpbs;
|
||||
private int versionNumber;
|
||||
private int diType;
|
||||
private String thirdId1;
|
||||
private String thirdName1;
|
||||
private String thirdId2;
|
||||
private String thirdName2;
|
||||
private String thirdId3;
|
||||
private String thirdName3;
|
||||
private String thirdId4;
|
||||
private String thirdName4;
|
||||
private String ybbm;
|
||||
private String sptm;
|
||||
private Integer productType;
|
||||
private String mainId;
|
||||
|
||||
public Integer getProductType() {
|
||||
if (productType == null) return 0
|
||||
;
|
||||
return productType;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,21 @@
|
||||
package com.glxp.api.service.basic;
|
||||
|
||||
|
||||
|
||||
import com.glxp.api.entity.basic.BasicProductsExportLogEntity;
|
||||
import com.glxp.api.req.basic.FilterUdiEpLogRequest;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface BasicProductsExportLogService {
|
||||
|
||||
BasicProductsExportLogEntity selectByGenKey(String genKey);
|
||||
List<BasicProductsExportLogEntity> filterUdiInfoExportLog(FilterUdiEpLogRequest filterInCodeLogRequest);
|
||||
|
||||
boolean insertUdiInfoExportLog(BasicProductsExportLogEntity udiInfoImportEntity);
|
||||
|
||||
boolean updateUdiInfoExportLog(BasicProductsExportLogEntity udiInfoImportEntity);
|
||||
|
||||
boolean deleteById( String id);
|
||||
|
||||
}
|
||||
@ -0,0 +1,34 @@
|
||||
package com.glxp.api.service.basic;
|
||||
|
||||
|
||||
|
||||
import com.glxp.api.entity.basic.BasicProductsImportDetailEntity;
|
||||
import com.glxp.api.req.basic.FilterUdiIpLogRequest;
|
||||
import com.glxp.api.res.basic.UdiRelevanceExportJsonResponse;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface BasicProductsImportDetailService {
|
||||
|
||||
|
||||
List<BasicProductsImportDetailEntity> filterUdiInfoImport(FilterUdiIpLogRequest filterInCodeLogRequest);
|
||||
|
||||
|
||||
boolean insertUdiInfoImport(BasicProductsImportDetailEntity udiInfoImportEntity);
|
||||
|
||||
boolean updateUdiInfoImport(BasicProductsImportDetailEntity udiInfoImportEntity);
|
||||
|
||||
boolean insertUdiInfoImports(List<BasicProductsImportDetailEntity> udiInfoImportEntities);
|
||||
|
||||
boolean deleteById(String id);
|
||||
|
||||
boolean deleteByGenkey(String genKey);
|
||||
|
||||
/**
|
||||
* 导入医疗器械信息
|
||||
*
|
||||
* @param udiRelevanceExportJsonResponse
|
||||
*/
|
||||
void importJsonData(UdiRelevanceExportJsonResponse udiRelevanceExportJsonResponse);
|
||||
|
||||
}
|
||||
@ -0,0 +1,34 @@
|
||||
package com.glxp.api.service.basic;
|
||||
|
||||
|
||||
|
||||
import com.glxp.api.entity.basic.BasicProductsImportDetailEntity;
|
||||
import com.glxp.api.entity.basic.BasicProductsImportLogEntity;
|
||||
import com.glxp.api.entity.basic.UdiRelevanceEntity;
|
||||
import com.glxp.api.req.basic.FilterUdiIpLogRequest;
|
||||
import com.glxp.api.res.basic.UdiRelevanceResponse;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface BasicProductsImportLogService {
|
||||
|
||||
|
||||
BasicProductsImportLogEntity selectByGenKey(String genKey);
|
||||
|
||||
List<BasicProductsImportLogEntity> filterImportLog(FilterUdiIpLogRequest filterInCodeLogRequest);
|
||||
|
||||
boolean insertImportLog(BasicProductsImportLogEntity basicProductsImportLogEntity);
|
||||
|
||||
boolean updateImportLog(BasicProductsImportLogEntity basicProductsImportLogEntity);
|
||||
|
||||
boolean deleteById(String id);
|
||||
//导入产品信息文件，生成产品信息，更新或插入对照表
|
||||
void importUdiInfo(String genKey);
|
||||
|
||||
void updateValue(UdiRelevanceEntity udiRelevanceEntity, BasicProductsImportDetailEntity basicProductsImportDetailEntity,
|
||||
BasicProductsImportLogEntity basicProductsImportLogEntity, String mainId);
|
||||
//下载供应商产品信息
|
||||
void downloadSmpUdiInfo(String genKey, String lastUpdateTime);
|
||||
|
||||
List<UdiRelevanceResponse> getUdiInfo(int page, int limit, String lastUpdateTime);
|
||||
}
|
||||
@ -0,0 +1,65 @@
|
||||
package com.glxp.api.service.basic.impl;
|
||||
|
||||
import cn.hutool.core.io.FileUtil;
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import com.github.pagehelper.PageHelper;
|
||||
import com.glxp.api.dao.basic.BasicProductsExportLogDao;
|
||||
import com.glxp.api.entity.basic.BasicProductsExportLogEntity;
|
||||
import com.glxp.api.req.basic.FilterUdiEpLogRequest;
|
||||
import com.glxp.api.service.basic.BasicProductsExportLogService;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
|
||||
@Service
|
||||
public class BasicProductsExportLogServiceImpl implements BasicProductsExportLogService {
|
||||
|
||||
@Resource
|
||||
BasicProductsExportLogDao udiInfoExportLogDao;
|
||||
|
||||
@Override
|
||||
public BasicProductsExportLogEntity selectByGenKey(String genKey) {
|
||||
FilterUdiEpLogRequest filterUdiEpLogRequest = new FilterUdiEpLogRequest();
|
||||
filterUdiEpLogRequest.setGenKey(genKey);
|
||||
List<BasicProductsExportLogEntity> data = udiInfoExportLogDao.filterUdiInfoExportLog(filterUdiEpLogRequest);
|
||||
if (data != null)
|
||||
return data.get(0);
|
||||
else
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<BasicProductsExportLogEntity> filterUdiInfoExportLog(FilterUdiEpLogRequest filterInCodeLogRequest) {
|
||||
if (filterInCodeLogRequest == null) {
|
||||
return Collections.emptyList();
|
||||
}
|
||||
if (filterInCodeLogRequest.getPage() != null) {
|
||||
int offset = (filterInCodeLogRequest.getPage() - 1) * filterInCodeLogRequest.getLimit();
|
||||
PageHelper.offsetPage(offset, filterInCodeLogRequest.getLimit());
|
||||
}
|
||||
List<BasicProductsExportLogEntity> data = udiInfoExportLogDao.filterUdiInfoExportLog(filterInCodeLogRequest);
|
||||
return data;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean insertUdiInfoExportLog(BasicProductsExportLogEntity udiInfoImportEntity) {
|
||||
return udiInfoExportLogDao.insertUdiInfoExportLog(udiInfoImportEntity);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean updateUdiInfoExportLog(BasicProductsExportLogEntity udiInfoImportEntity) {
|
||||
return udiInfoExportLogDao.updateUdiInfoExportLog(udiInfoImportEntity);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteById(String id) {
|
||||
//删除日志同步删除磁盘文件
|
||||
String filePath = udiInfoExportLogDao.selectFilePathById(id);
|
||||
if (StrUtil.isNotBlank(filePath)) {
|
||||
FileUtil.del(filePath);
|
||||
}
|
||||
return udiInfoExportLogDao.deleteById(id);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,141 @@
|
||||
package com.glxp.api.service.basic.impl;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import com.github.pagehelper.PageHelper;
|
||||
import com.glxp.api.dao.basic.BasicProductsImportDetailDao;
|
||||
import com.glxp.api.dao.basic.UdiProductDao;
|
||||
import com.glxp.api.dao.basic.UdiRelevanceDao;
|
||||
import com.glxp.api.dao.basic.UdiRlSupDao;
|
||||
import com.glxp.api.dao.thrsys.ThrProductsDao;
|
||||
import com.glxp.api.entity.basic.*;
|
||||
import com.glxp.api.entity.thrsys.ThrProductsEntity;
|
||||
import com.glxp.api.req.basic.FilterUdiIpLogRequest;
|
||||
import com.glxp.api.res.basic.UdiRelevanceExportJsonResponse;
|
||||
import com.glxp.api.service.basic.BasicProductsImportDetailService;
|
||||
import org.apache.ibatis.session.ExecutorType;
|
||||
import org.apache.ibatis.session.SqlSession;
|
||||
import org.apache.ibatis.session.SqlSessionFactory;
|
||||
import org.apache.ibatis.session.TransactionIsolationLevel;
|
||||
import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
|
||||
@Service
|
||||
public class BasicProductsImportDetailServiceImpl implements BasicProductsImportDetailService {
|
||||
|
||||
@Resource
|
||||
BasicProductsImportDetailDao udiInfoImportDao;
|
||||
@Resource
|
||||
UdiProductDao udiProductDao;
|
||||
@Resource
|
||||
UdiRelevanceDao udiRelevanceDao;
|
||||
@Resource
|
||||
ThrProductsDao thrProductsDao;
|
||||
@Resource
|
||||
SqlSessionFactory sqlSessionFactory;
|
||||
|
||||
@Override
|
||||
public List<BasicProductsImportDetailEntity> filterUdiInfoImport(FilterUdiIpLogRequest filterInCodeLogRequest) {
|
||||
if (filterInCodeLogRequest == null) {
|
||||
return Collections.emptyList();
|
||||
}
|
||||
if (filterInCodeLogRequest.getPage() != null) {
|
||||
int offset = (filterInCodeLogRequest.getPage() - 1) * filterInCodeLogRequest.getLimit();
|
||||
PageHelper.offsetPage(offset, filterInCodeLogRequest.getLimit());
|
||||
}
|
||||
List<BasicProductsImportDetailEntity> data = udiInfoImportDao.filterUdiInfoImport(filterInCodeLogRequest);
|
||||
return data;
|
||||
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public boolean insertUdiInfoImport(BasicProductsImportDetailEntity udiInfoImportEntity) {
|
||||
return udiInfoImportDao.insertUdiInfoImport(udiInfoImportEntity);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean updateUdiInfoImport(BasicProductsImportDetailEntity udiInfoImportEntity) {
|
||||
return udiInfoImportDao.updateUdiInfoImport(udiInfoImportEntity);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean insertUdiInfoImports(List<BasicProductsImportDetailEntity> udiInfoImportEntities) {
|
||||
return udiInfoImportDao.insertUdiInfoImports(udiInfoImportEntities);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteById(String id) {
|
||||
return udiInfoImportDao.deleteById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteByGenkey(String genKey) {
|
||||
return udiInfoImportDao.deleteByGenkey(genKey);
|
||||
}
|
||||
|
||||
@Override
|
||||
@Async
|
||||
public void importJsonData(UdiRelevanceExportJsonResponse udiRelevanceExportJsonResponse) {
|
||||
if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getUdiProductEntities())) {
|
||||
|
||||
//基础表导入
|
||||
SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
|
||||
if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getUdiProductEntities())) {
|
||||
List<UdiProductEntity> corpList = udiRelevanceExportJsonResponse.getUdiProductEntities();
|
||||
UdiProductDao mapper = batchSession.getMapper(UdiProductDao.class);
|
||||
for (UdiProductEntity udiProductEntity : corpList) {
|
||||
mapper.insertUdiInfo(udiProductEntity);
|
||||
}
|
||||
batchSession.commit();
|
||||
}
|
||||
batchSession.close();
|
||||
// udiInfoDao.importUdiInfo(udiRelevanceExportJsonResponse.getUdiInfoEntities());
|
||||
|
||||
}
|
||||
|
||||
//关联表导入
|
||||
if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getUdiRelevanceEntities())) {
|
||||
SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
|
||||
List<UdiRelevanceEntity> corpList = udiRelevanceExportJsonResponse.getUdiRelevanceEntities();
|
||||
UdiRelevanceDao mapper = batchSession.getMapper(UdiRelevanceDao.class);
|
||||
for (UdiRelevanceEntity basicUnitMaintainEntity : corpList) {
|
||||
mapper.insertUdiRelevance(basicUnitMaintainEntity);
|
||||
}
|
||||
batchSession.commit();
|
||||
batchSession.close();
|
||||
// udiRelevanceDao.importUdiRelevance(udiRelevanceExportJsonResponse.getUdiRelevanceEntities());
|
||||
}
|
||||
|
||||
//第三方产品信息导入
|
||||
if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getThrProductsEntities())) {
|
||||
|
||||
SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
|
||||
List<ThrProductsEntity> corpList = udiRelevanceExportJsonResponse.getThrProductsEntities();
|
||||
ThrProductsDao mapper = batchSession.getMapper(ThrProductsDao.class);
|
||||
for (ThrProductsEntity basicUnitMaintainEntity : corpList) {
|
||||
mapper.insertThrProducts(basicUnitMaintainEntity);
|
||||
}
|
||||
batchSession.commit();
|
||||
batchSession.close();
|
||||
// thrProductsDao.importThrProductss(udiRelevanceExportJsonResponse.getThrProductsEntities());
|
||||
}
|
||||
|
||||
//供应商关联表导入
|
||||
if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getUdiRlSupEntityList())) {
|
||||
|
||||
SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
|
||||
List<UdiRlSupEntity> udiRlSupEntityList = udiRelevanceExportJsonResponse.getUdiRlSupEntityList();
|
||||
UdiRlSupDao mapper = batchSession.getMapper(UdiRlSupDao.class);
|
||||
for (UdiRlSupEntity udiRlSupEntity : udiRlSupEntityList) {
|
||||
mapper.importCompanyProductRelevance(udiRlSupEntity);
|
||||
}
|
||||
batchSession.commit();
|
||||
batchSession.close();
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,56 @@
|
||||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
|
||||
|
||||
<mapper namespace="com.glxp.api.dao.basic.BasicProductsExportLogDao">
|
||||
|
||||
<select id="filterUdiInfoExportLog" parameterType="com.glxp.api.req.basic.FilterUdiEpLogRequest"
|
||||
resultType="com.glxp.api.entity.basic.BasicProductsExportLogEntity">
|
||||
SELECT * FROM basic_products_export_log
|
||||
<where>
|
||||
<if test="genKey != '' and genKey != null">
|
||||
AND genKey = #{genKey}
|
||||
</if>
|
||||
<if test="status != '' and status != null">
|
||||
AND status = #{status}
|
||||
</if>
|
||||
<if test="type != '' and type != null">
|
||||
AND `type` = #{type}
|
||||
</if>
|
||||
</where>
|
||||
ORDER BY updateTime DESC
|
||||
</select>
|
||||
|
||||
|
||||
<insert id="insertUdiInfoExportLog" keyProperty="id"
|
||||
parameterType="com.glxp.api.entity.basic.BasicProductsExportLogEntity">
|
||||
insert INTO basic_products_export_log
|
||||
(genKey,updateTime,dlCount,status,filePath,remark,`type`)
|
||||
values
|
||||
(
|
||||
#{genKey},
|
||||
#{updateTime},
|
||||
#{dlCount},#{status},#{filePath},#{remark},#{type}
|
||||
)
|
||||
</insert>
|
||||
|
||||
|
||||
<delete id="deleteById" parameterType="Map">
|
||||
DELETE FROM basic_products_export_log WHERE id = #{id}
|
||||
</delete>
|
||||
|
||||
<update id="updateUdiInfoExportLog" parameterType="com.glxp.api.entity.basic.BasicProductsExportLogEntity">
|
||||
UPDATE basic_products_export_log
|
||||
<set>
|
||||
<if test="updateTime != null">updateTime=#{updateTime},</if>
|
||||
<if test="dlCount != null">dlCount=#{dlCount},</if>
|
||||
<if test="status != null">status=#{status},</if>
|
||||
<if test="filePath != null">filePath=#{filePath},</if>
|
||||
<if test="remark != null">remark=#{remark},</if>
|
||||
</set>
|
||||
WHERE genKey = #{genKey}
|
||||
</update>
|
||||
|
||||
<select id="selectFilePathById" resultType="java.lang.String">
|
||||
select filePath from basic_products_export_log where id = #{id}
|
||||
</select>
|
||||
</mapper>
|
||||
@ -0,0 +1,82 @@
|
||||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
|
||||
|
||||
<mapper namespace="com.glxp.api.dao.basic.BasicProductsImportDetailDao">
|
||||
|
||||
<select id="filterUdiInfoImport" parameterType="com.glxp.api.req.basic.FilterUdiIpLogRequest"
|
||||
resultType="com.glxp.api.entity.basic.BasicProductsImportDetailEntity">
|
||||
SELECT * FROM basic_products_import_detail
|
||||
<where>
|
||||
<if test="genKey != '' and genKey != null">
|
||||
AND genKeyFk = #{genKey}
|
||||
</if>
|
||||
<if test="id != '' and id != null">
|
||||
AND id = #{id}
|
||||
</if>
|
||||
<if test="status != '' and status != null">
|
||||
AND status = #{status}
|
||||
</if>
|
||||
<if test="thirdSysFk != '' and thirdSysFk != null">
|
||||
AND thirdSysFk = #{thirdSysFk}
|
||||
</if>
|
||||
</where>
|
||||
|
||||
</select>
|
||||
|
||||
|
||||
<insert id="insertUdiInfoImport" keyProperty="id"
|
||||
parameterType="com.glxp.api.entity.basic.BasicProductsImportDetailEntity">
|
||||
insert INTO basic_products_import_detail
|
||||
(udiCode,ybbm,sptm,thirdId1,thirdId2,
|
||||
thirdId3,thirdId4,thirdId,status,updateTime,remark,genKeyFk,isUseDy)
|
||||
values
|
||||
(
|
||||
#{udiCode}, #{ybbm},#{sptm},
|
||||
#{thirdId1}, #{thirdId2},#{thirdId3},
|
||||
#{thirdId4}, #{thirdId},#{status},
|
||||
#{updateTime},#{remark}, #{genKeyFk},#{isUseDy}
|
||||
)
|
||||
</insert>
|
||||
|
||||
<insert id="insertUdiInfoImports" keyProperty="id" parameterType="java.util.List">
|
||||
insert INTO basic_products_import_detail
|
||||
(udiCode,ybbm,sptm,thirdId1,thirdId2,
|
||||
thirdId3,thirdId4,thirdId,status,updateTime,remark,genKeyFk,isUseDy)
|
||||
values
|
||||
<foreach collection="udiInfos" item="item" index="index"
|
||||
separator=",">
|
||||
(
|
||||
#{item.udiCode}, #{item.ybbm},#{item.sptm},
|
||||
#{item.thirdId1}, #{item.thirdId2},#{item.thirdId3},
|
||||
#{item.thirdId4}, #{item.thirdId},#{item.status},
|
||||
#{item.updateTime},#{item.remark}, #{item.genKeyFk},#{item.isUseDy}
|
||||
)
|
||||
</foreach>
|
||||
</insert>
|
||||
<delete id="deleteById" parameterType="Map">
|
||||
DELETE FROM basic_products_import_detail WHERE id = #{id}
|
||||
</delete>
|
||||
<delete id="deleteByGenkey" parameterType="Map">
|
||||
DELETE FROM basic_products_import_detail WHERE genKeyFk = #{genKey}
|
||||
</delete>
|
||||
|
||||
<update id="updateUdiInfoImport" parameterType="com.glxp.api.entity.basic.BasicProductsImportDetailEntity">
|
||||
UPDATE basic_products_import_detail
|
||||
<trim prefix="set" suffixOverrides=",">
|
||||
<if test="udiCode != null">udiCode=#{udiCode},</if>
|
||||
<if test="ybbm != null">ybbm=#{ybbm},</if>
|
||||
<if test="sptm != null">sptm=#{sptm},</if>
|
||||
<if test="thirdId1 != null">thirdId1=#{thirdId1},</if>
|
||||
<if test="thirdId2 != null">thirdId2=#{thirdId2},</if>
|
||||
<if test="thirdId3 != null">thirdId3=#{thirdId3},</if>
|
||||
<if test="thirdId4 != null">thirdId4=#{thirdId4},</if>
|
||||
<if test="thirdId != null">thirdId=#{thirdId},</if>
|
||||
<if test="status != null">status=#{status},</if>
|
||||
<if test="updateTime != null">updateTime=#{updateTime},</if>
|
||||
<if test="remark != null">remark=#{remark},</if>
|
||||
<if test="isUseDy != null">isUseDy=#{isUseDy},</if>
|
||||
</trim>
|
||||
WHERE id = #{id}
|
||||
</update>
|
||||
|
||||
</mapper>
|
||||
@ -0,0 +1,60 @@
|
||||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
|
||||
|
||||
<mapper namespace="com.glxp.api.dao.basic.BasicProductsImportLogDao">
|
||||
|
||||
<select id="filterImportLog" parameterType="com.glxp.api.req.basic.FilterUdiIpLogRequest"
|
||||
resultType="com.glxp.api.entity.basic.BasicProductsImportLogEntity">
|
||||
SELECT * FROM basic_products_import_log
|
||||
<where>
|
||||
<if test="genKey != '' and genKey != null">
|
||||
AND genKey = #{genKey}
|
||||
</if>
|
||||
<if test="id != '' and id != null">
|
||||
AND id = #{id}
|
||||
</if>
|
||||
<if test="fromType != '' and fromType != null">
|
||||
AND fromType = #{fromType}
|
||||
</if>
|
||||
<if test="status != '' and status != null">
|
||||
AND status = #{status}
|
||||
</if>
|
||||
<if test="thirdSysFk != '' and thirdSysFk != null">
|
||||
AND thirdSysFk = #{thirdSysFk}
|
||||
</if>
|
||||
</where>
|
||||
ORDER BY updateTime DESC
|
||||
</select>
|
||||
|
||||
|
||||
<insert id="insertImportLog" keyProperty="id" parameterType="com.glxp.api.entity.basic.BasicProductsImportLogEntity">
|
||||
insert INTO basic_products_import_log
|
||||
(genKey,fromType,updateTime,thirdSysFk,status)
|
||||
values
|
||||
(
|
||||
#{genKey},
|
||||
#{fromType},
|
||||
#{updateTime},
|
||||
#{thirdSysFk},#{status}
|
||||
)
|
||||
</insert>
|
||||
|
||||
|
||||
<delete id="deleteById" parameterType="Map">
|
||||
DELETE FROM basic_products_import_log WHERE id = #{id}
|
||||
</delete>
|
||||
|
||||
<update id="updateImportLog" parameterType="com.glxp.api.entity.basic.BasicProductsImportLogEntity">
|
||||
UPDATE basic_products_import_log
|
||||
<set>
|
||||
<if test="genKey != null">genKey=#{genKey},</if>
|
||||
<if test="fromType != null">fromType=#{fromType},</if>
|
||||
<if test="updateTime != null">updateTime=#{updateTime},</if>
|
||||
<if test="thirdSysFk != null">thirdSysFk=#{thirdSysFk},</if>
|
||||
<if test="status != null">status=#{status},</if>
|
||||
<if test="remark != null">remark=#{remark},</if>
|
||||
</set>
|
||||
WHERE genKey = #{genKey}
|
||||
</update>
|
||||
|
||||
</mapper>
|
||||
Loading…
Reference in New Issue