XT_New/controllers/yh_api_controller.go

package controllers

//
//import (
//	"XT_New/models"
//	"XT_New/service"
//	"bytes"
//	"encoding/json"
//	"fmt"
//	"io"
//	"net/http"
//	"strconv"
//	"strings"
//	"time"
//)
//
//func UploadAllPatient(org_id int64) error {
//	//syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	//var sync_time int64
//	//if syncLastInfo.ID > 0 {
//	//	sync_time = syncLastInfo.SyncTime
//	//} else {
//	//	sync_time = 0
//	//}
//	patients := service.GetAllPatients(org_id)
//	var hdreq models.HDRequest
//	hdreq.Infno = "Z9609"
//
//	var yhps []models.PatientInfo
//	for _, item := range patients {
//		var yhp models.PatientInfo
//		str := strconv.Itoa(int(item.ID))
//		yhp.PatnID = str
//		yhp.PatnName = item.Name
//		yhp.IptOtpNo = item.DialysisNo
//		yhp.HdNo = item.DialysisNo
//		yhp.Insutype = "390"
//		if item.ReimbursementWayId == 1 {
//			yhp.Insutype = "310"
//		} else if item.ReimbursementWayId == 2 {
//			yhp.Insutype = "390"
//		}
//		yhp.CertType = "1"
//		yhp.Certno = item.IdCardNo
//		str2 := strconv.Itoa(int(item.Gender))
//		yhp.Gend = str2
//		yhp.Brdy = ""
//		yhp.FstHdDate = ""
//		yhp.Tel = item.Phone
//		yhp.FmTel = ""
//		yhp.Empr = ""
//		yhp.FmAddr = item.HomeAddress
//		yhp.IfetDiseName = ""
//		yhp.DiagName = "慢性肾脏病5期"
//		yhp.DiagCode = "N18.500"
//		yhp.Cop = ""
//		yhp.Algs = ""
//		yhp.Tmor = ""
//		yhp.DiagDrName = ""
//		yhp.RhabDate = ""
//		yhp.RecDate = ""
//		yhps = append(yhps, yhp)
//	}
//
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "patn", // 患者信息类型
//			"hd_data":      yhps,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func UploadDiase(org_id int64) error {
//	patients := service.GetAllPatients(org_id)
//	var hdreq models.HDRequest
//	hdreq.Infno = "Z9609"
//	var diags []models.DiseaseDiagnosis
//	for _, item := range patients {
//		//var yhp models.DiseaseDiagnosis
//		str := strconv.Itoa(int(item.ID))
//		Diagnose_str_arr := strings.Split(item.Diagnose, ",")
//		for _, subitem := range Diagnose_str_arr {
//			var yhp models.DiseaseDiagnosis
//			yhp.PatnID = str
//			yhp.DiagID = subitem
//			yhp.HdNo = item.DialysisNo
//			t := time.Unix(item.CreatedTime, 0)
//			yhp.DiagDate = t.Format("2006-01-02")
//			yhp.DiagType = "1"
//			yhp.DiagName = subitem
//			yhp.DiagAttr = ""
//			yhp.DrName = "谢虎"
//			yhp.RhabDate = ""
//			diags = append(diags, yhp)
//		}
//
//	}
//
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "diseDiag", // 患者信息类型
//			"hd_data":      diags,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func UploadZhuanGui(org_id int64) error {
//	//syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	//var sync_time int64
//	//if syncLastInfo.ID > 0 {
//	//	sync_time = syncLastInfo.SyncTime
//	//} else {
//	//	sync_time = 0
//	//}
//
//	patients := service.GetAllPatientLaspse(org_id)
//	var hdreq models.HDRequest
//	hdreq.Infno = "Z9609"
//	var diags []models.PatientOutcome
//	for _, item := range patients {
//		var yhp models.PatientOutcome
//		str := strconv.Itoa(int(item.PatientId))
//		str2 := strconv.Itoa(int(item.ID))
//		p, _ := service.GetPatientByID(org_id, item.PatientId)
//		//Diagnose_str_arr := strings.Split(item.Diagnose, ",")
//		yhp.PatnID = str
//		yhp.OutComeID = str2
//		yhp.HdNo = p.DialysisNo
//		if item.LapseType == 1 { //留治
//			yhp.OutComeType = "1"
//			yhp.OutComeCate = "留治" //转归分类
//
//		} else if item.LapseType == 2 { //转出
//
//			yhp.OutComeType = "2"
//			yhp.OutComeCate = "转出" //转归分类
//
//		} else if item.LapseType == 3 { //死亡
//			yhp.OutComeType = "3"
//			yhp.OutComeCate = "死亡" //转归分类
//
//		}
//		yhp.OutComeRea = ""
//		t := time.Unix(item.LapseDate, 0)
//		yhp.OutComeDate = t.Format("2006-01-02")
//		yhp.Remark = ""
//		yhp.Memo = ""
//	}
//
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "outCome", // 患者信息类型
//			"hd_data":      diags,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func UploadTrtPlan(org_id int64) error {
//	//syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	//var sync_time int64
//	//if syncLastInfo.ID > 0 {
//	//	sync_time = syncLastInfo.SyncTime
//	//} else {
//	//	sync_time = 0
//	//}
//	patients := service.GetAllPatientPre(org_id)
//	var hdreq models.HDRequest
//	hdreq.Infno = "Z9609"
//	var plans []models.TreatmentPlan
//	for _, item := range patients {
//		var yhp models.TreatmentPlan
//		str := strconv.Itoa(int(item.PatientID))
//		str2 := strconv.Itoa(int(item.ID))
//		p, _ := service.GetPatientByID(org_id, item.PatientID)
//		//Diagnose_str_arr := strings.Split(item.Diagnose, ",")
//		yhp.PatnID = str
//		yhp.HdID = str2
//		yhp.HdNo = p.DialysisNo
//		if item.ModeId == 1 {
//			yhp.HdMode = "HD"
//			yhp.Hd = item.DialysisDialyszers
//			yhp.Hf = item.DialysisStrainer
//			yhp.Hp = item.DialysisIrrigation
//		} else if item.ModeId == 2 {
//			yhp.HdMode = "HDF"
//			yhp.Hd = item.DialysisDialyszers
//			yhp.Hf = item.DialysisStrainer
//			yhp.Hp = item.DialysisIrrigation
//		} else if item.ModeId == 3 {
//			yhp.HdMode = "HP"
//			yhp.Hd = item.DialysisDialyszers
//			yhp.Hf = item.DialysisStrainer
//			yhp.Hp = item.DialysisIrrigation
//		}
//		yhp.HdFrqu = "1w:3c"
//		yhp.HdDura = item.DialysisDuration
//		yhp.MedcInfo = ""
//		yhp.BloVal = item.BloodFlowVolume
//		yhp.DsVal = item.DialysateFlow
//		s1 := fmt.Sprintf("%f", item.Kalium)
//		s2 := fmt.Sprintf("%f", item.Sodium)
//		s3 := fmt.Sprintf("%f", item.Bicarbonate)
//		s4 := fmt.Sprintf("%f", item.Glucose)
//		yhp.K = s1
//		yhp.FmlNa = s2
//		yhp.RxNa = s2
//		yhp.Hco3 = s3
//		yhp.Gs = s4
//		yhp.Acgl = ""
//		yhp.AcglFoml = ""
//		plans = append(plans, yhp)
//	}
//
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "trtPlan", // 患者信息类型
//			"hd_data":      plans,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func UploadSch(org_id int64) error {
//	//syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	//var sync_time int64
//	//if syncLastInfo.ID > 0 {
//	//	sync_time = syncLastInfo.SyncTime
//	//} else {
//	//	sync_time = 0
//	//}
//	schedules := service.GetAllPatientSch(org_id)
//	var hdreq models.HDRequest
//	hdreq.Infno = "Z9609"
//	var schs []models.YHSchedule
//	for _, item := range schedules {
//		var yhp models.YHSchedule
//		str := strconv.Itoa(int(item.PatientId))
//		str2 := strconv.Itoa(int(item.ID))
//		str3 := strconv.Itoa(int(item.ScheduleWeek))
//		str4 := strconv.Itoa(int(item.ScheduleType))
//
//		yhp.PatnID = str
//		yhp.ScheduleID = str2
//		yhp.IfetDiseName = ""
//		yhp.PatnSouc = "1"
//		t := time.Unix(item.ScheduleDate, 0)
//		yhp.HdDate = t.Format("2006-01-02")
//		yhp.Week = str3
//		yhp.ClssNo = str4
//		yhp.BlngPrtn = ""
//
//		de, _ := service.GetBedNumberById(item.BedId, org_id)
//		yhp.MchNo = de.Number
//		if item.ModeId == 1 {
//			yhp.HdMode = "HD"
//		} else if item.ModeId == 2 {
//			yhp.HdMode = "HDF"
//		} else if item.ModeId == 3 {
//			yhp.HdMode = "HP"
//		}
//		schs = append(schs, yhp)
//	}
//
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "schedule", // 患者信息类型
//			"hd_data":      schs,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func UploadOrder(org_id int64) error {
//	syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	var sync_time int64
//	if syncLastInfo.ID > 0 {
//		sync_time = syncLastInfo.SyncTime
//	} else {
//		sync_time = 0
//	}
//
//	ps := service.GetAllDialysisRecord(org_id, sync_time)
//
//	var drs []models.DialysisRecord
//
//	for _, item := range ps {
//		var dr models.DialysisRecord
//		order := service.GetAllPatientDialysisRecord(org_id, item.DialysisDate, item.PatientId)
//		sch, _ := service.GetScheduleByPatient(item.PatientId, item.DialysisDate, org_id)
//		p, _ := service.GetPatientByID(org_id, item.PatientId)
//		pre, _ := service.GetDialysisPrescribe(org_id, item.PatientId, item.DialysisDate)
//		str := strconv.Itoa(int(order.PatientId))
//		str2 := strconv.Itoa(int(sch.ID))
//
//		dr.PatnID = str
//		dr.BtchID = str2
//		t := time.Unix(item.DialysisDate, 0)
//		dr.HdDate = t.Format("2006-01-02")
//		dr.HdNo = p.DialysisNo
//		dr.IndeptWay = ""
//
//		if sch.ModeId == 1 {
//			dr.HdMode = "HD"
//		} else if sch.ModeId == 2 {
//			dr.HdMode = "HDF"
//		} else if sch.ModeId == 3 {
//			dr.HdMode = "HP"
//		}
//		s1 := fmt.Sprintf("%f", order.KyyPredialysisEvaluation.DryWeight)
//		dr.DryWt = s1
//		dr.Ivap = ""
//		dr.Hd = ""
//		dr.Hf = ""
//		dr.Hp = ""
//		dr.HdDura = pre.DialysisDuration
//		hours := order.KyyAssessmentAfterDislysis.ActualTreatmentMinute / 60
//		dr.ActTrtDura = float64(order.KyyAssessmentAfterDislysis.ActualTreatmentHour + hours)
//		dr.MchNo = order.DeviceNumber.Number
//		drs = append(drs, dr)
//	}
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "hdInfo", // 患者信息类型
//			"hd_data":      drs,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func Uploadbf(org_id int64) error {
//	syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	var sync_time int64
//	if syncLastInfo.ID > 0 {
//		sync_time = syncLastInfo.SyncTime
//	} else {
//		sync_time = 0
//	}
//
//	ps := service.GetAllDialysisRecord(org_id, sync_time)
//
//	var drs []models.PreDialysisRecord
//	for _, item := range ps {
//		var dr models.PreDialysisRecord
//		order := service.GetAllPatientDialysisRecord(org_id, item.DialysisDate, item.PatientId)
//		sch, _ := service.GetScheduleByPatient(item.PatientId, item.DialysisDate, org_id)
//		pre, _ := service.GetDialysisPrescribe(org_id, item.PatientId, item.DialysisDate)
//		str2 := strconv.Itoa(int(sch.ID))
//		dr.TagtWaterVal = pre.TargetUltrafiltration
//		dr.BtchID = str2
//		dr.RxWateVal = pre.PrescriptionDewatering
//		s1 := fmt.Sprintf("%f", order.KyyPredialysisEvaluation.WeightBefore)
//		dr.BfWt = s1
//		drs = append(drs, dr)
//	}
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "bfHd", // 患者信息类型
//			"hd_data":      drs,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func Uploadhdbf(org_id int64) error {
//	syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	var sync_time int64
//	if syncLastInfo.ID > 0 {
//		sync_time = syncLastInfo.SyncTime
//	} else {
//		sync_time = 0
//	}
//
//	ps := service.GetAllDialysisRecord(org_id, sync_time)
//
//	var drs []models.DialysisRecord
//
//	for _, item := range ps {
//		var dr models.DialysisRecord
//		order := service.GetAllPatientDialysisRecord(org_id, item.DialysisDate, item.PatientId)
//		sch, _ := service.GetScheduleByPatient(item.PatientId, item.DialysisDate, org_id)
//		p, _ := service.GetPatientByID(org_id, item.PatientId)
//		pre, _ := service.GetDialysisPrescribe(org_id, item.PatientId, item.DialysisDate)
//		str := strconv.Itoa(int(order.PatientId))
//		str2 := strconv.Itoa(int(sch.ID))
//
//		dr.PatnID = str
//		dr.BtchID = str2
//		t := time.Unix(item.DialysisDate, 0)
//		dr.HdDate = t.Format("2006-01-02")
//		dr.HdNo = p.DialysisNo
//		dr.IndeptWay = ""
//
//		if sch.ModeId == 1 {
//			dr.HdMode = "HD"
//		} else if sch.ModeId == 2 {
//			dr.HdMode = "HDF"
//		} else if sch.ModeId == 3 {
//			dr.HdMode = "HP"
//		}
//		s1 := fmt.Sprintf("%f", order.KyyPredialysisEvaluation.DryWeight)
//		dr.DryWt = s1
//		dr.Ivap = ""
//		dr.Hd = ""
//		dr.Hf = ""
//		dr.Hp = ""
//		dr.HdDura = pre.DialysisDuration
//		hours := order.KyyAssessmentAfterDislysis.ActualTreatmentMinute / 60
//		dr.ActTrtDura = float64(order.KyyAssessmentAfterDislysis.ActualTreatmentHour + hours)
//		dr.MchNo = order.DeviceNumber.Number
//		drs = append(drs, dr)
//	}
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "hdInfo", // 患者信息类型
//			"hd_data":      drs,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func Uploadmo(org_id int64) error {
//	syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	var sync_time int64
//	if syncLastInfo.ID > 0 {
//		sync_time = syncLastInfo.SyncTime
//	} else {
//		sync_time = 0
//	}
//
//	ps := service.GetAllDialysisRecord(org_id, sync_time)
//
//	var drs []models.DialysisMonitoring
//
//	for _, item := range ps {
//		order := service.GetAllPatientDialysisRecord(org_id, item.DialysisDate, item.PatientId)
//		sch, _ := service.GetScheduleByPatient(item.PatientId, item.DialysisDate, org_id)
//		for _, subitem := range order.KyyMonitoringRecord {
//			var dr models.DialysisMonitoring
//			t := time.Unix(subitem.MonitoringDate, 0)
//			dr.MnitTime = t.Format("2006-01-02") + " " + subitem.MonitoringTime
//			dr.DsTprt = ""
//			s1 := fmt.Sprintf("%f", subitem.PulseFrequency)
//			dr.Pule = s1
//			dr.BratFrqu = subitem.BreathingRate
//			s2 := fmt.Sprintf("%f", subitem.SystolicBloodPressure)
//			s3 := fmt.Sprintf("%f", subitem.DiastolicBloodPressure)
//			s4 := fmt.Sprintf("%f", subitem.ArterialPressure)
//			s5 := fmt.Sprintf("%f", subitem.VenousPressure)
//			s6 := fmt.Sprintf("%f", subitem.Temperature)
//			s7 := fmt.Sprintf("%f", sch.ID)
//			s8 := fmt.Sprintf("%f", subitem.ID)
//			dr.Bp = s2 + "/" + s3
//			dr.BloVal = subitem.BloodFlowVolume
//			dr.Abp = s4
//			dr.Vp = s5
//			dr.Tmp = s6
//			dr.OverFitrCnt = subitem.UltrafiltrationVolume
//			dr.CondChng = ""
//			dr.BtchID = s7
//			dr.HdMidID = s8
//			dr.ExchVal = ""
//			drs = append(drs, dr)
//		}
//
//	}
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "hdNnit", // 患者信息类型
//			"hd_data":      drs,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func Uploadaf(org_id int64) error {
//	syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	var sync_time int64
//	if syncLastInfo.ID > 0 {
//		sync_time = syncLastInfo.SyncTime
//	} else {
//		sync_time = 0
//	}
//
//	ps := service.GetAllDialysisRecord(org_id, sync_time)
//
//	var drs []models.PostDialysisRecord
//	for _, item := range ps {
//		var dr models.PostDialysisRecord
//		order := service.GetAllPatientDialysisRecord(org_id, item.DialysisDate, item.PatientId)
//		sch, _ := service.GetScheduleByPatient(item.PatientId, item.DialysisDate, org_id)
//		str2 := strconv.Itoa(int(sch.ID))
//		dr.AfSymp = order.KyyAssessmentAfterDislysis.SymptomAfterDialysis
//		dr.ClotDeg = str2
//		dr.ImptStas = order.KyyAssessmentAfterDislysis.InternalFistula
//		s2 := fmt.Sprintf("%f", order.KyyAssessmentAfterDislysis.WeightAfter)
//		s3 := fmt.Sprintf("%f", sch.ID)
//		dr.AfWt = s2
//		dr.ActFitrCnt = order.KyyAssessmentAfterDislysis.ActualUltrafiltration
//		dr.BtchID = s3
//		drs = append(drs, dr)
//	}
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "afHd", // 患者信息类型
//			"hd_data":      drs,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//func Uploadtrt(org_id int64) error {
//	syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	var sync_time int64
//	if syncLastInfo.ID > 0 {
//		sync_time = syncLastInfo.SyncTime
//	} else {
//		sync_time = 0
//	}
//
//	ps := service.GetAllDialysisRecord(org_id, sync_time)
//
//	var drs []models.YHTreatmentSummary
//	for _, item := range ps {
//		var dr models.YHTreatmentSummary
//		order := service.GetAllPatientDialysisRecord(org_id, item.DialysisDate, item.PatientId)
//		sch, _ := service.GetScheduleByPatient(item.PatientId, item.DialysisDate, org_id)
//		str2 := strconv.Itoa(int(sch.ID))
//		PunctureRole, _ := service.GetAdminUserRoleTwo(order.KyyTreatmentSummary.Puncture, org_id)
//		ZlRole, _ := service.GetAdminUserRole(order.KyyTreatmentSummary.ZlNurse, org_id)
//		FinishRole, _ := service.GetAdminUserRole(order.FinishNurse, org_id)
//		PrescriptionDoctor, _ := service.GetAdminUserRole(order.KYYPrescriptionVM.PrescriptionDoctor, org_id)
//		dr.PncrNurs = PunctureRole.UserName
//		dr.TrtNurs = ZlRole.UserName
//		dr.Chker = ""
//		dr.OffMchNurs = FinishRole.UserName
//		dr.TrtDr = PrescriptionDoctor.UserName
//		dr.BtchID = str2
//		dr.RsltCont = order.KyyTreatmentSummary.DialysisSummary
//		drs = append(drs, dr)
//	}
//	// 构建请求数据
//	requestData := map[string]interface{}{
//		"data": map[string]interface{}{
//			"hd_data_type": "trtRslt", // 患者信息类型
//			"hd_data":      drs,
//		},
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}
//
//func UploadDoc(org_id int64) error {
//
//	syncLastInfo, _ := service.GetSyncTimeByOrgId(org_id, 10)
//	var sync_time int64
//	if syncLastInfo.ID > 0 {
//		sync_time = syncLastInfo.SyncTime
//	} else {
//		sync_time = 0
//	}
//	ps := service.GetAllDialysisRecord(org_id, sync_time)
//
//	var drs []models.YHDialysisOrder
//	for _, item := range ps {
//		var dr models.YHDialysisOrder
//		order := service.GetAllPatientDialysisRecord(org_id, item.DialysisDate, item.PatientId)
//		sch, _ := service.GetScheduleByPatient(item.PatientId, item.DialysisDate, org_id)
//		str2 := strconv.Itoa(int(sch.ID))
//		PunctureRole, _ := service.GetAdminUserRoleTwo(order.KyyTreatmentSummary.Puncture, org_id)
//		ZlRole, _ := service.GetAdminUserRole(order.KyyTreatmentSummary.ZlNurse, org_id)
//		FinishRole, _ := service.GetAdminUserRole(order.FinishNurse, org_id)
//		PrescriptionDoctor, _ := service.GetAdminUserRole(order.KYYPrescriptionVM.PrescriptionDoctor, org_id)
//		dr.PncrNurs = PunctureRole.UserName
//		dr.TrtNurs = ZlRole.UserName
//		dr.Chker = ""
//		dr.OffMchNurs = FinishRole.UserName
//		dr.TrtDr = PrescriptionDoctor.UserName
//		dr.BtchID = str2
//		dr.RsltCont = order.KyyTreatmentSummary.DialysisSummary
//		drs = append(drs, dr)
//	}
//
//	// 转换为 JSON
//	jsonData, err := json.Marshal(requestData)
//	if err != nil {
//		return fmt.Errorf("JSON 编码失败: %v", err)
//	}
//
//	// 创建 HTTP 请求
//	req, err := http.NewRequest("POST", "https://ggfw.scyb.org.cn/ims/his/outside/api/scen/twoDecisions/hdDataUpload", bytes.NewBuffer(jsonData))
//	if err != nil {
//		return fmt.Errorf("创建请求失败: %v", err)
//	}
//
//	// 设置请求头
//	req.Header.Set("Content-Type", "application/json")
//	// 根据实际需要添加其他请求头，如认证信息等
//	// req.Header.Set("Authorization", "Bearer your_token")
//
//	// 发送请求
//	client := &http.Client{}
//	resp, err := client.Do(req)
//	if err != nil {
//		return fmt.Errorf("请求发送失败: %v", err)
//	}
//	defer resp.Body.Close()
//
//	// 读取响应
//	body, err := io.ReadAll(resp.Body)
//	if err != nil {
//		return fmt.Errorf("读取响应失败: %v", err)
//	}
//
//	// 检查响应状态
//	if resp.StatusCode != http.StatusOK {
//		return fmt.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
//	}
//
//	// 处理响应数据
//	fmt.Printf("上传成功，响应: %s\n", string(body))
//
//	return nil
//}