diff --git a/src/main/java/com/xydl/cac/controller/IecServerController.java b/src/main/java/com/xydl/cac/controller/IecServerController.java index 149c4a7..2f1627f 100644 --- a/src/main/java/com/xydl/cac/controller/IecServerController.java +++ b/src/main/java/com/xydl/cac/controller/IecServerController.java @@ -1,10 +1,13 @@ package com.xydl.cac.controller; import com.xydl.cac.entity.IcdFile; +import com.xydl.cac.entity.IcdTransform; import com.xydl.cac.entity.constants.Constants; +import com.xydl.cac.exception.BusinessException; import com.xydl.cac.iec.IecServerService; import com.xydl.cac.model.Response; import com.xydl.cac.service.IcdFileConfigService; +import com.xydl.cac.service.IcdTransformService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; @@ -29,6 +32,8 @@ public class IecServerController extends BasicController { IcdFileConfigService configService; @Resource IecServerService iecServerService; + @Resource + IcdTransformService transformService; @PostMapping("upload") @ApiOperation("上传服务端icd文件") @@ -74,4 +79,35 @@ public class IecServerController extends BasicController { return Response.success(map); } + @PostMapping("addTransform") + @ApiOperation("addTransform") + public Response addTransform(@Validated @RequestBody IcdTransform icdTransform) throws Exception { + IcdTransform result = transformService.addTransform(icdTransform); + return Response.success(result); + } + + @PostMapping("delTransform") + @ApiOperation("delTransform") + public Response delTransform(@Validated @NotNull(message = "ID不能为空!") Integer id) throws Exception { + if (id == null) { + throw new BusinessException("id不能为空!"); + } + transformService.deleteTransform(id); + return Response.success("ok"); + } + + @PostMapping("clearTransform") + @ApiOperation("清空") + public Response clearTransform() { + transformService.clearTransform(); + return Response.success("ok"); + } + + @GetMapping("listTransform") + @ApiOperation("listTransform") + public Response> listTransform() throws Exception { + List result = transformService.listTransform(); + return Response.success(result); + } + } diff --git a/src/main/java/com/xydl/cac/entity/IcdTransform.java b/src/main/java/com/xydl/cac/entity/IcdTransform.java new file mode 100644 index 0000000..fdd44a3 --- /dev/null +++ b/src/main/java/com/xydl/cac/entity/IcdTransform.java @@ -0,0 +1,35 @@ +package com.xydl.cac.entity; + +import com.fasterxml.jackson.annotation.JsonInclude; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import javax.persistence.*; + +@JsonInclude(JsonInclude.Include.NON_NULL) +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +@Entity +@Table(name = "icd_transform") +@ApiModel("ICD") +public class IcdTransform { + + @Id + @GeneratedValue(strategy = GenerationType.IDENTITY) + @Column(name = "id") + private Integer id; + + @ApiModelProperty(name = "rpt_from") + @Column(name = "rpt_from") + private String rptFrom; + + @ApiModelProperty(name = "rpt_to") + @Column(name = "rpt_to") + private String rptTo; +} diff --git a/src/main/java/com/xydl/cac/repository/IcdTransformRepository.java b/src/main/java/com/xydl/cac/repository/IcdTransformRepository.java new file mode 100644 index 0000000..dad5dd8 --- /dev/null +++ b/src/main/java/com/xydl/cac/repository/IcdTransformRepository.java @@ -0,0 +1,10 @@ +package com.xydl.cac.repository; + +import com.xydl.cac.entity.IcdTransform; +import org.springframework.data.jpa.repository.JpaRepository; +import org.springframework.data.jpa.repository.JpaSpecificationExecutor; +import org.springframework.stereotype.Repository; + +@Repository +public interface IcdTransformRepository extends JpaRepository, JpaSpecificationExecutor { +} diff --git a/src/main/java/com/xydl/cac/service/IcdTransformService.java b/src/main/java/com/xydl/cac/service/IcdTransformService.java new file mode 100644 index 0000000..58b8ce1 --- /dev/null +++ b/src/main/java/com/xydl/cac/service/IcdTransformService.java @@ -0,0 +1,19 @@ +package com.xydl.cac.service; + +import com.xydl.cac.entity.IcdTransform; +import com.xydl.cac.exception.BusinessException; + +import java.util.List; +import java.util.Optional; + +public interface IcdTransformService { + + IcdTransform addTransform(IcdTransform icdTransform); + + void deleteTransform(Integer id) throws Exception; + + void clearTransform(); + + List listTransform(); + +} diff --git a/src/main/java/com/xydl/cac/service/impl/IcdTransformServiceImpl.java b/src/main/java/com/xydl/cac/service/impl/IcdTransformServiceImpl.java new file mode 100644 index 0000000..da1ffae --- /dev/null +++ b/src/main/java/com/xydl/cac/service/impl/IcdTransformServiceImpl.java @@ -0,0 +1,49 @@ +package com.xydl.cac.service.impl; + +import com.xydl.cac.entity.IcdTransform; +import com.xydl.cac.exception.BusinessException; +import com.xydl.cac.repository.IcdTransformRepository; +import com.xydl.cac.service.IcdTransformService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; +import java.util.Collections; +import java.util.List; +import java.util.Optional; + +@Service +@Slf4j +@Transactional(rollbackFor = Exception.class) +public class IcdTransformServiceImpl implements IcdTransformService { + + @Resource + IcdTransformRepository transformRepository; + + @Override + public IcdTransform addTransform(IcdTransform icdTransform) { + IcdTransform save = transformRepository.save(icdTransform); + return save; + } + + @Override + public void deleteTransform(Integer id) throws Exception { + Optional byId = transformRepository.findById(id); + if (!byId.isPresent()) { + throw new BusinessException("所需要删除的id不存在!"); + } + transformRepository.deleteById(id); + } + + @Override + public void clearTransform() { + transformRepository.deleteAll(); + } + + @Override + public List listTransform() { + return transformRepository.findAll(); + } + +}