不用mybatisplus

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() {

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;

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;
 
 /**
  * <p>
@@ -12,6 +13,9 @@ import com.docus.server.collection.entity.TBasic;
  * @author jiashi
  * @since 2021-04-14
  */
-public interface TBasicMapper extends BaseMapper<TBasic> {
+public interface TBasicMapper{
 
+    Integer selectOne(@Param("jzh") String jzh);
+
+    Integer insert(@Param("tBasic") TBasic tBasic);
 }

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);
+}

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);
+    }
+}

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<TBasic>().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());
     }
 

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">
 <mapper namespace="com.docus.server.collection.mapper.TBasicMapper">
+    <insert id="insert">
+        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})
+    </insert>
 
+    <select id="selectOne" resultType="java.lang.Integer">
+        select count(patient_id) from t_basic where jzh=#{jzh}
+    </select>
 </mapper>