Quellcode durchsuchen

1、增加缺陷推送到his

liuqq vor 3 Jahren
Ursprung
Commit
067cf21325

+ 6 - 0
src/main/java/com/diagbot/facade/his/FeedbackHosFacade.java

@@ -2,6 +2,7 @@ package com.diagbot.facade.his;
 
 import com.diagbot.dto.RespDTO;
 import com.diagbot.util.PushFeedbackConn;
+import com.diagbot.util.StringUtil;
 import com.diagbot.vo.his.FeedbackHosVO;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
@@ -14,6 +15,11 @@ public class FeedbackHosFacade {
 
     public RespDTO pushFeedback(FeedbackHosVO feedbackHosVO){
         try{
+            if(StringUtil.isEmpty(feedbackHosVO.getBehospitalCode())){
+                return RespDTO.onError("病历号为空");
+            }else if(feedbackHosVO.getId()==null){
+                return RespDTO.onError("病历反馈缺陷ID为空");
+            }
             if("1".equals(feedbackHosVO.getOperationType())){
                 //修改
                 conn.UpdateQcMessAge(feedbackHosVO);

+ 12 - 6
src/main/java/com/diagbot/util/PushFeedbackConn.java

@@ -130,8 +130,8 @@ public class PushFeedbackConn {
             connection = getConnection();
             connection.setAutoCommit(false);//事物开始
             PreparedStatement state=connection.prepareStatement("insert into MEDICAL_QC_MSG " +
-                    "(PATIENT_ID,VISIT_ID,DOCTOR_IN_CHARGE,QA_EVENT_TYPE,QC_MSG_CODE,MESSAGE,ISSUED_BY,ISSUED_DATE_TIME,TOPIC_ID,DEPT_STAYED,MSG_STATUS)"+
-                    "values(?,?,?,?,?,?,?,to_date(?,'yyyy-mm-dd hh24:mi:ss'),?,?,?)");
+                    "(PATIENT_ID,VISIT_ID,DOCTOR_IN_CHARGE,QA_EVENT_TYPE,QC_MSG_CODE,MESSAGE,ISSUED_BY,ISSUED_DATE_TIME,TOPIC_ID,DEPT_STAYED,MSG_STATUS,EXPLAIN_INFO,QCRESULT_DETAI_SCORE,DETAIL_CODE)"+
+                    "values(?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
             state.setString(1, patientId);
             state.setString(2, visitId);
             state.setString(3,feedbackHosVO.getSenderName());
@@ -143,6 +143,9 @@ public class PushFeedbackConn {
             state.setString(9,feedbackHosVO.getModeName());
             state.setString(10,feedbackHosVO.getDeptId());
             state.setInt(11,0);
+            state.setString(12,feedbackHosVO.getExplainInfo());
+            state.setString(13, String.format("%.2f", feedbackHosVO.getQcresultDetaiScore()));
+            state.setString(14,Long.toString(feedbackHosVO.getId()));
             re = state.executeUpdate();
             if(re < 0){               //插入失败
                 connection.rollback();      //回滚
@@ -175,8 +178,8 @@ public class PushFeedbackConn {
             int re=0;
             connection = getConnection();
             connection.setAutoCommit(false);//事物开始
-            String sql ="delete from MEDICAL_QC_MSG  where  PATIENT_ID = '"+patientId+"' and VISIT_ID = '"
-                    +visitId+"' and MESSAGE = '"+feedbackHosVO.getExplainInfo()+"'";
+            String sql ="delete from MEDICAL_QC_MSG ";
+            sql+=" where PATIENT_ID = '"+patientId+"' and VISIT_ID = '"+visitId+"' and DETAIL_CODE='"+feedbackHosVO.getId()+"'";
             PreparedStatement state=connection.prepareStatement(sql);
             re = state.executeUpdate();
             if(re < 0){               //删除失败
@@ -209,8 +212,11 @@ public class PushFeedbackConn {
             int re=0;
             connection = getConnection();
             connection.setAutoCommit(false);//事物开始
-            String sql =" update MEDICAL_QC_MSG set MESSAGE = '"+feedbackHosVO.getExplainInfo()+"' where PATIENT_ID = '"+patientId+"' and VISIT_ID = '"
-                    +visitId+"'" ;
+            String sql =" update MEDICAL_QC_MSG set " +
+                    "MESSAGE = '"+feedbackHosVO.getQcresultDetailMsg()+"'" +
+                    ",EXPLAIN_INFO='"+feedbackHosVO.getExplainInfo()+"'" +
+                    ",QCRESULT_DETAI_SCORE='"+feedbackHosVO.getQcresultDetaiScore()+"'";
+            sql+="where PATIENT_ID = '"+patientId+"' and VISIT_ID = '"+visitId+"' and DETAIL_CODE='"+feedbackHosVO.getId()+"'";
             PreparedStatement state=connection.prepareStatement(sql);
             re = state.executeUpdate();
             if(re < 0){               //修改失败