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 //}