From 9a27d315252ef975ac6eb3f37769d694aa04f17b Mon Sep 17 00:00:00 2001
From: changpengfei <changpengfei@lymsh.com>
Date: Wed, 22 Sep 2021 16:38:16 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=B7=BB=E5=8A=A0=E9=97=AE?=
 =?UTF-8?q?=E8=AF=8A=E8=AE=B0=E5=BD=95=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/TkRecordController.java             | 55 ++++++++++++++++++++--
 1 file changed, 51 insertions(+), 4 deletions(-)

diff --git a/talkonlineweb/src/main/java/com/lyms/talkonlineweb/controller/TkRecordController.java b/talkonlineweb/src/main/java/com/lyms/talkonlineweb/controller/TkRecordController.java
index 8b392b1..bb197a9 100644
--- a/talkonlineweb/src/main/java/com/lyms/talkonlineweb/controller/TkRecordController.java
+++ b/talkonlineweb/src/main/java/com/lyms/talkonlineweb/controller/TkRecordController.java
@@ -1,16 +1,18 @@
 package com.lyms.talkonlineweb.controller;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import com.lyms.talkonlineweb.domain.LymsTkrecord;
-import com.lyms.talkonlineweb.domain.TkrecordInfo;
+import com.lyms.talkonlineweb.domain.*;
 import com.lyms.talkonlineweb.result.BaseResponse;
-import com.lyms.talkonlineweb.service.LymsTkrecordService;
-import com.lyms.talkonlineweb.service.TkrecordInfoService;
+import com.lyms.talkonlineweb.service.*;
+import com.lyms.talkonlineweb.util.HXService;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
+
 @RestController
 @RequestMapping("tk")
 @Log4j2
@@ -21,6 +23,18 @@ public class TkRecordController {
     @Autowired
     private TkrecordInfoService tkrecordInfoService;
 
+    @Autowired
+    private LymsTcardService lymsTcardService;
+    @Autowired
+    private HXService hxService;
+    @Autowired
+    private LymsChatgroupService lymsChatgroupService;
+
+    @Autowired
+    private LymsDoctorService lymsDoctorService;
+    @Autowired
+    private LymsPatientService lymsPatientService;
+
     /**
      * 保存问诊记录
      * @param tkrecord
@@ -30,7 +44,40 @@ public class TkRecordController {
     public BaseResponse saveTkRecord(@RequestBody @Validated LymsTkrecord tkrecord){
         BaseResponse baseResponse=new BaseResponse();
         try {
+
+            LymsTcard tcard=new LymsTcard();
+            tcard.setPid(tkrecord.getPid());
+            tcard.setPcid(tkrecord.getPcid());
+//            获取问诊卡按照先从医院购买的问诊卡消费
+            List<LymsTcard> rLst=lymsTcardService.list(Wrappers.query(tcard).notInSql("id","SELECT r.cid FROM lyms_tkrecord r").orderByDesc("fid"));
+
+            if(rLst.size()>0){
+               tkrecord.setCid(rLst.get(0).getId());
+            }else{
+                baseResponse.setErrorcode(1);
+                baseResponse.setErrormsg("已经没有了问诊卡");
+                return baseResponse;
+            }
             lymsTkrecordService.save(tkrecord);
+
+            LymsChatgroup group =new LymsChatgroup();
+            LymsDoctor doctor=lymsDoctorService.getById(tkrecord.getDid());
+            LymsPatient patient=lymsPatientService.getById(tkrecord.getPid());
+
+            group.setFromp(patient.getIdno());
+            group.setTarget(doctor.getDlogin());
+            group.setOwnerk("test");
+
+            log.info("创建环信组:{} from:{} target:{}", group.getOwnerk(), group.getFromp(), group.getTarget());
+            JSONObject rJson = hxService.addChatGroups(group.getFromp() + "," + group.getTarget(), group.getOwnerk(), new String[]{group.getFromp(), group.getTarget()});
+            log.info("rJson:" + rJson);
+            group.setHxgroupid(rJson.getJSONObject("data").getString("groupid"));
+            group.setDescription(group.getFromp() + "," + group.getTarget());
+            group.setGroupname(group.getFromp() + "," + group.getTarget());
+            lymsChatgroupService.saveOrUpdate(group);
+
+            baseResponse.setObject(group);
+
             baseResponse.setErrormsg("成功");
         } catch (Exception e) {
             baseResponse.setErrormsg("失败");
-- 
1.8.3.1