From 4efa8de2b8272470bb4022ca6f7d29647e0829a5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=AE=87=E5=AE=99=E7=9A=AE=E7=9A=AE=E5=A8=83?= <2964346877@qq.com> Date: Mon, 27 Feb 2023 16:17:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8D=E7=94=A8mybatisplus?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/docus/server/CxfConfig.java | 9 +++ .../server/collection/entity/TBasic.java | 2 +- .../collection/mapper/TBasicMapper.java | 6 +- .../collection/webservice/ReceiveServer.java | 23 ++++++++ .../webservice/impl/ReceiveServerImpl.java | 47 +++++++++++++++ .../webservice/impl/TBasicServiceImpl.java | 59 ++++++++++++------- src/main/resources/mapper/TBasicMapper.xml | 10 ++++ 7 files changed, 133 insertions(+), 23 deletions(-) create mode 100644 src/main/java/com/docus/server/collection/webservice/ReceiveServer.java create mode 100644 src/main/java/com/docus/server/collection/webservice/impl/ReceiveServerImpl.java diff --git a/src/main/java/com/docus/server/CxfConfig.java b/src/main/java/com/docus/server/CxfConfig.java index 9db76a2..2ab09d1 100644 --- a/src/main/java/com/docus/server/CxfConfig.java +++ b/src/main/java/com/docus/server/CxfConfig.java @@ -2,6 +2,7 @@ package com.docus.server; import com.docus.server.collection.webservice.IDeptServer; import com.docus.server.collection.webservice.IUserServer; +import com.docus.server.collection.webservice.ReceiveServer; import com.docus.server.collection.webservice.TBasicService; import org.apache.cxf.jaxws.EndpointImpl; import lombok.RequiredArgsConstructor; @@ -23,6 +24,7 @@ public class CxfConfig { private final IDeptServer deptServer; private final TBasicService tBasicService; + private final ReceiveServer receiveServer; /** * 注入Servlet，注意beanName不能为dispatcherServlet * @author Fang Ruichuan @@ -38,6 +40,13 @@ public class CxfConfig { return new SpringBus(); } + @Bean + public Endpoint endpoint() { + EndpointImpl endpoint = new EndpointImpl(springBus(), receiveServer); + endpoint.publish("/api"); + return endpoint; + } + @Bean @Qualifier("userEndPoint") public Endpoint userEndPoint() { diff --git a/src/main/java/com/docus/server/collection/entity/TBasic.java b/src/main/java/com/docus/server/collection/entity/TBasic.java index 7389ea5..9639219 100644 --- a/src/main/java/com/docus/server/collection/entity/TBasic.java +++ b/src/main/java/com/docus/server/collection/entity/TBasic.java @@ -27,7 +27,7 @@ public class TBasic implements Serializable { @ApiModelProperty(value = "病案主键") @TableId(value = "patient_id", type = IdType.ASSIGN_ID) - private String patientId; + private Long patientId; @ApiModelProperty(value = "住院次数") private Integer admissTimes; diff --git a/src/main/java/com/docus/server/collection/mapper/TBasicMapper.java b/src/main/java/com/docus/server/collection/mapper/TBasicMapper.java index e5dc000..835aec7 100644 --- a/src/main/java/com/docus/server/collection/mapper/TBasicMapper.java +++ b/src/main/java/com/docus/server/collection/mapper/TBasicMapper.java @@ -3,6 +3,7 @@ package com.docus.server.collection.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.docus.server.collection.entity.TBasic; +import org.apache.ibatis.annotations.Param; /** *

@@ -12,6 +13,9 @@ import com.docus.server.collection.entity.TBasic; * @author jiashi * @since 2021-04-14 */ -public interface TBasicMapper extends BaseMapper { +public interface TBasicMapper{ + Integer selectOne(@Param("jzh") String jzh); + + Integer insert(@Param("tBasic") TBasic tBasic); } diff --git a/src/main/java/com/docus/server/collection/webservice/ReceiveServer.java b/src/main/java/com/docus/server/collection/webservice/ReceiveServer.java new file mode 100644 index 0000000..b0e5fc9 --- /dev/null +++ b/src/main/java/com/docus/server/collection/webservice/ReceiveServer.java @@ -0,0 +1,23 @@ +package com.docus.server.collection.webservice; + +/** + * @author Fang Ruichuan + * @date 2022-11-14 19:03 + */ +public interface ReceiveServer { + /** + * 科室信息接收，进行操作 + * @param receiveUser 接收到的科室数据 + * @return 返回结果 + */ + String deptModify(String receiveUser); + + String setTBasic(String str); + + /** + * 用户信息接收，进行操作 + * @param receiveUser 接收到的用户参数 + * @return 返回结果 + */ + String userModify(String receiveUser); +} diff --git a/src/main/java/com/docus/server/collection/webservice/impl/ReceiveServerImpl.java b/src/main/java/com/docus/server/collection/webservice/impl/ReceiveServerImpl.java new file mode 100644 index 0000000..c2934d0 --- /dev/null +++ b/src/main/java/com/docus/server/collection/webservice/impl/ReceiveServerImpl.java @@ -0,0 +1,47 @@ +package com.docus.server.collection.webservice.impl; + +import com.docus.server.collection.webservice.IDeptServer; +import com.docus.server.collection.webservice.IUserServer; +import com.docus.server.collection.webservice.ReceiveServer; +import com.docus.server.collection.webservice.TBasicService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import javax.jws.WebService; + +/** + * @BelongsProject: docus-webservice-sdry + * @BelongsPackage: com.docus.server.collection.webservice.impl + * @Author: chierhao + * @CreateTime: 2023-02-27 10:02 + * @Description: TODO + * @Version: 1.0 + */ +@Service +@WebService +@Slf4j +public class ReceiveServerImpl implements ReceiveServer { + @Resource + private IUserServer userServer; + @Resource + private IDeptServer deptServer; + @Resource + private TBasicService tBasicService; + + + @Override + public String deptModify(String receiveDept) { + return deptServer.deptModify(receiveDept); + } + + @Override + public String setTBasic(String str) { + return tBasicService.setTBasic(str); + } + + @Override + public String userModify(String receiveUser) { + return userServer.userModify(receiveUser); + } +} diff --git a/src/main/java/com/docus/server/collection/webservice/impl/TBasicServiceImpl.java b/src/main/java/com/docus/server/collection/webservice/impl/TBasicServiceImpl.java index ad3d623..4456ab3 100644 --- a/src/main/java/com/docus/server/collection/webservice/impl/TBasicServiceImpl.java +++ b/src/main/java/com/docus/server/collection/webservice/impl/TBasicServiceImpl.java @@ -4,17 +4,20 @@ import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.docus.core.util.DateUtil; import com.docus.core.util.Func; +import com.docus.infrastructure.redis.service.IdService; import com.docus.server.collection.dto.TBasicDto; import com.docus.server.collection.entity.TBasic; import com.docus.server.collection.mapper.TBasicMapper; import com.docus.server.collection.util.Result; import com.docus.server.collection.util.XmlUtil; import com.docus.server.collection.webservice.TBasicService; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.w3c.dom.Node; +import javax.annotation.Resource; import javax.jws.WebService; import java.util.Date; import java.util.HashMap; @@ -29,38 +32,52 @@ import java.util.HashMap; */ @Service @WebService +@Slf4j public class TBasicServiceImpl implements TBasicService { - @Autowired + @Resource private TBasicMapper tBasicMapper; + @Resource + private IdService idService; + @Override public String setTBasic(String body) { if (Func.isEmpty(body)) { return Result.failed(null,"参数为空"); } //解析xml - TBasicDto tBasicDto = getTBasicDto(body); - //判断jzh是否重复 - TBasic selectTBasic = tBasicMapper.selectOne(new QueryWrapper().eq("jzh", tBasicDto.getJzh())); - if (selectTBasic != null) { - return Result.failed(tBasicDto.getSerialId(),"记帐号已存在"); + TBasicDto tBasicDto = null; + try { + tBasicDto=getTBasicDto(body); + //判断jzh是否重复 + Integer num = tBasicMapper.selectOne(tBasicDto.getJzh()); + if (num>0) { + return Result.failed(tBasicDto.getSerialId(),"记帐号已存在"); + } + + long patientId = idService.getDateSeq(); + + //组装数据 + TBasic tBasic=new TBasic(); + tBasic.setPatientId(patientId); + tBasic.setJzh(tBasicDto.getJzh()); + tBasic.setInpatientNo(tBasicDto.getInpatientNo()); + tBasic.setAdmissTimes(Integer.parseInt(tBasicDto.getAdmissTimes())); + tBasic.setName(tBasicDto.getName()); + Date admissDate = Func.parseDate(tBasicDto.getAdmissDate(), DateUtil.PATTERN_DATETIME_MINI); + tBasic.setAdmissDate(admissDate); + Date disDate = Func.parseDate(tBasicDto.getDisDate(), DateUtil.PATTERN_DATETIME_MINI); + tBasic.setDisDate(disDate); + tBasic.setAdmissDeptName(tBasicDto.getAdmissDeptName()); + tBasic.setDisDeptName(tBasicDto.getDisDeptName()); + tBasic.setAttendingName(tBasicDto.getAttendingName()); + //持久化 + tBasicMapper.insert(tBasic); + }catch (Exception e){ + e.printStackTrace(); + log.error(e.getMessage(), e); } - //组装数据 - TBasic tBasic=new TBasic(); - tBasic.setJzh(tBasicDto.getJzh()); - tBasic.setInpatientNo(tBasicDto.getInpatientNo()); - tBasic.setAdmissTimes(Integer.parseInt(tBasicDto.getAdmissTimes())); - tBasic.setName(tBasicDto.getName()); - Date admissDate = Func.parseDate(tBasicDto.getAdmissDate(), DateUtil.PATTERN_DATETIME_MINI); - tBasic.setAdmissDate(admissDate); - Date disDate = Func.parseDate(tBasicDto.getDisDate(), DateUtil.PATTERN_DATETIME_MINI); - tBasic.setDisDate(disDate); - tBasic.setAdmissDeptName(tBasicDto.getAdmissDeptName()); - tBasic.setDisDeptName(tBasicDto.getDisDeptName()); - tBasic.setAttendingName(tBasicDto.getAttendingName()); - //持久化 - tBasicMapper.insert(tBasic); return Result.success(tBasicDto.getSerialId()); } diff --git a/src/main/resources/mapper/TBasicMapper.xml b/src/main/resources/mapper/TBasicMapper.xml index 01f0423..92cd4da 100644 --- a/src/main/resources/mapper/TBasicMapper.xml +++ b/src/main/resources/mapper/TBasicMapper.xml @@ -3,5 +3,15 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> + + INSERT INTO `docus_medicalrecord`.`t_basic` + (`patient_id`, `admiss_times`, `inpatient_no`,`name`, `admiss_date`, `admiss_dept_name`, `dis_date`, `dis_dept_name`,`attending_name`,`jzh`) + VALUES + (#{tBasic.patientId},#{tBasic.admissTimes},#{tBasic.inpatientNo},#{tBasic.name}, + #{tBasic.admissDate},#{tBasic.admissDeptName},#{tBasic.disDate},#{tBasic.disDeptName},#{tBasic.attendingName},#{tBasic.jzh}) + +