Merge branch '20230223_xt_api_new_branch' of http://git.shengws.com/csx/XT_New into 20230223_xt_api_new_branch

controllers/mobile_api_controllers/check_weight_api_controller.go

@@ -547,7 +547,7 @@ func (c *CheckWeightApiController) SavePatientInfoDialysis() {
 				}
 				//err := service.AddSigleRecord(&newprescribe)
 				var err error
-				if adminUserInfo.Org.Id == 10597 || adminUserInfo.Org.Id == 10599 {
+				if adminUserInfo.Org.Id == 10597 || adminUserInfo.Org.Id == 10599 || adminUserInfo.Org.Id == 3877 {
 					prescriptionTwenty, _ := service.GetLastDialysisPrescriptionTwenty(newprescribe.PatientId, newprescribe.RecordDate, newprescribe.UserOrgId)
 					if prescriptionTwenty.ID == 0 {
 						//插入透析处方
@@ -654,7 +654,19 @@ func (c *CheckWeightApiController) SavePatientInfoDialysis() {
 					lastDialysisPrescription, _ := service.GetLastDialysisPrescription(id, adminUserInfo.Org.Id)
 					newprescribe.Remark = lastDialysisPrescription.Remark
 				}
-				err := service.AddSigleRecord(&newprescribe)
+
+				if adminUserInfo.Org.Id == 10597 || adminUserInfo.Org.Id == 10599 || adminUserInfo.Org.Id == 3877 {
+					prescriptionTwenty, _ := service.GetLastDialysisPrescriptionTwenty(newprescribe.PatientId, newprescribe.RecordDate, newprescribe.UserOrgId)
+					if prescriptionTwenty.ID == 0 {
+						//插入透析处方
+						service.AddSigleRecord(&newprescribe)
+					} else {
+						//插入透析处方
+						service.UpdateAddSigleRecord(prescriptionTwenty.ID, newprescribe.TargetUltrafiltration)
+					}
+				} else {
+					service.AddSigleRecord(&newprescribe)
+				}
 
 				//记录日志
 				byterequest, _ := json.Marshal(newprescribe)
@@ -681,9 +693,6 @@ func (c *CheckWeightApiController) SavePatientInfoDialysis() {
 				keyThree := "scheduals_" + scheduleDateStartOne + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
 				redis.Set(keyThree, "", time.Second)
 				defer redis.Close()
-				if err != nil {
-					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCommitFail)
-				}
 
 			} else {
 				var newprescribe models.DialysisPrescription

controllers/mobile_api_controllers/dialysis_api_controller.go

@@ -2330,7 +2330,7 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 
 		prescription.ID = dialysisPrescription.ID
 
-		err := service.UpDateDialysisPrescription(&prescription)
+		service.UpDateDialysisPrescription(&prescription)
 
 		//记录日志
 		byterequest, _ := json.Marshal(prescription)
@@ -2360,7 +2360,7 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 			PatientId:  id,
 		}
 
-		dialysisFinish, err := service.GetDialysisFinish(adminUserInfo.Org.Id, recordDate.Unix(), 1, id)
+		dialysisFinish, _ := service.GetDialysisFinish(adminUserInfo.Org.Id, recordDate.Unix(), 1, id)
 		if dialysisFinish.ID == 0 {
 			service.CreateDialysisFinish(finish)
 		}
@@ -2400,21 +2400,20 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 		keySeven := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":dialysis_prescribe_by_mode"
 		redis.Set(keySeven, "", time.Second)
 
-		if err == nil {
-			updateErr := service.UpdateScheduleModeId(patient.ID, adminUserInfo.Org.Id, recordDate.Unix(), mode_id)
-			keyOne := "scheduals_" + recordDateStr + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
-
-			//清空key 值
-			redis.Set(keyOne, "", time.Second)
-			defer redis.Close()
-			if updateErr != nil {
-				utils.ErrorLog("%v", updateErr)
-			}
+		updateErr := service.UpdateScheduleModeId(patient.ID, adminUserInfo.Org.Id, recordDate.Unix(), mode_id)
+		keyTwoOne := "scheduals_" + recordDateStr + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
 
-			c.ServeSuccessJSON(map[string]interface{}{
-				"prescription": prescription,
-			})
+		//清空key 值
+		redis.Set(keyTwoOne, "", time.Second)
+		defer redis.Close()
+		if updateErr != nil {
+			utils.ErrorLog("%v", updateErr)
 		}
+
+		c.ServeSuccessJSON(map[string]interface{}{
+			"prescription": prescription,
+		})
+
 	}
 
 }
@@ -3421,6 +3420,11 @@ func (this *DialysisAPIController) StartDialysis() {
 				ultrafiltration_rate = ultrafiltration_rate / 1000
 			}
 
+			if adminUserInfo.Org.Id == 10612 {
+				ultrafiltration_rate = math.Floor(prescription.TargetUltrafiltration * 1000 / float64(totalMin) * 60 * 1000)
+				ultrafiltration_rate = ultrafiltration_rate / 1000
+			}
+
 		}
 	}
 
@@ -4069,7 +4073,7 @@ func (c *DialysisAPIController) PostSolution() {
 		AdminUserId: adminUserInfo.AdminUser.Id,
 		RecordDate:  prescription.RecordDate,
 		PatientId:   prescription.PatientId,
-		Source:      "手机端新增处方",
+		Source:      "手机端新增长期处方",
 		Status:      1,
 	}
 
@@ -4457,8 +4461,10 @@ func (this *DialysisAPIController) GetLastMonitorRecordTody() {
 
 			}
 
-			if adminInfo.Org.Id == 10551 {
+			if adminInfo.Org.Id == 10551 || adminInfo.Org.Id == 10617 {
+
 				ultrafiltration_rate = math.Floor(prescription.TargetUltrafiltration * 1000 / float64(totalMin) * 60 * 1000)
+				fmt.Println("金阿迪发到付阿道夫", ultrafiltration_rate)
 				record.UltrafiltrationRate = ultrafiltration_rate / 1000
 			}
 
@@ -4520,7 +4526,7 @@ func (this *DialysisAPIController) GetLastMonitorRecordTody() {
 		record.UltrafiltrationVolume = ultrafiltration_volume / 1000
 	}
 
-	if adminInfo.Org.Id == 10551 {
+	if adminInfo.Org.Id == 10551 || adminInfo.Org.Id == 10617 {
 		ultrafiltration_volume := math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime) / 3600 * ultrafiltration_rate)
 
 		record.UltrafiltrationVolume = ultrafiltration_volume / 1000
@@ -10489,3 +10495,129 @@ func (c *DialysisAPIController) GetLastAcceptRecrods() {
 		"recrods": recrods,
 	})
 }
+
+func (c *DialysisAPIController) ExMobileChangeSch() {
+
+	id_one, _ := c.GetInt64("id_one")
+	id_two, _ := c.GetInt64("id_two")
+	sch, _ := service.GetSchedule(c.GetMobileAdminUserInfo().Org.Id, id_one)
+	sch_two, _ := service.GetSchedule(c.GetMobileAdminUserInfo().Org.Id, id_two)
+
+	//order2, _ := service.GetDialysisOrder(sch_two.ScheduleDate, sch_two.PatientId, sch_two.UserOrgId)
+	//if order2.ID > 0 {
+	//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientDialysisOrderTwo)
+	//	return
+	//}
+
+	//替换者和被替换的排班日期不是同一天，则进行一个患者一天不能有多个排班提醒
+	if sch.ScheduleDate != sch_two.ScheduleDate && sch.PatientId != sch_two.PatientId {
+		count, _ := service.GetScheduleCountByDate(c.GetMobileAdminUserInfo().Org.Id, sch_two.ScheduleDate, sch.PatientId)
+		if count > 0 {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
+			return
+		}
+
+		count1, _ := service.GetScheduleCountByDate(c.GetMobileAdminUserInfo().Org.Id, sch.ScheduleDate, sch_two.PatientId)
+		if count1 > 0 {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
+			return
+		}
+	}
+
+	err := service.UpdateScheduleThree(sch, sch_two)
+
+	order, _ := service.GetOneDialysisOrderOne(sch.ScheduleDate, sch.PatientId, sch.UserOrgId)
+	if order.ID > 0 {
+		//查询该患者的排班机位
+		pSchedule, _ := service.GetPscheduleDate(sch.ScheduleDate, sch.PatientId, sch.UserOrgId)
+		service.UpdateDialysiOrderByPatientId(id_two, pSchedule.ScheduleType, pSchedule.PartitionId, pSchedule.BedId)
+		redis := service.RedisClient()
+		key := strconv.FormatInt(sch_two.UserOrgId, 10) + ":" + strconv.FormatInt(sch_two.PatientId, 10) + ":" + strconv.FormatInt(sch_two.ScheduleDate, 10) + ":dialysis_order"
+		redis.Set(key, "", time.Second)
+		keyOne := strconv.FormatInt(sch_two.UserOrgId, 10) + ":" + strconv.FormatInt(sch_two.ScheduleDate, 10) + ":dialysis_orders_list_all"
+
+		//清空key 值
+		redis.Set(keyOne, "", time.Second)
+		//c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientDialysisOrderOne)
+		//return
+	}
+	if err == nil {
+
+		//去除当天患者排班中重复数据，保留最后一条数据
+		service.UpdateRepeatSchStatus(sch.UserOrgId, sch.ScheduleDate)
+		service.UpdateRepeatSchStatus(sch_two.UserOrgId, sch_two.ScheduleDate)
+
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "交换成功",
+		})
+
+	} else {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+
+	}
+}
+
+func (c *DialysisAPIController) MobileCoverSch() {
+
+	id_one, _ := c.GetInt64("id_one")
+	id_two, _ := c.GetInt64("id_two")
+	sch, _ := service.GetScheduleTen(c.GetMobileAdminUserInfo().Org.Id, id_one)
+	sch_two, _ := service.GetScheduleTen(c.GetMobileAdminUserInfo().Org.Id, id_two)
+
+	order, _ := service.GetOneDialysisOrderOne(sch.ScheduleDate, sch.PatientId, sch.UserOrgId)
+	if order.ID > 0 {
+
+		service.UpdateDialysiOrderByPatientId(id_two, sch_two.ScheduleType, sch_two.PartitionId, sch_two.BedId)
+		redis := service.RedisClient()
+		key := strconv.FormatInt(sch_two.UserOrgId, 10) + ":" + strconv.FormatInt(sch_two.PatientId, 10) + ":" + strconv.FormatInt(sch_two.ScheduleDate, 10) + ":dialysis_order"
+		redis.Set(key, "", time.Second)
+		keyOne := strconv.FormatInt(sch_two.UserOrgId, 10) + ":" + strconv.FormatInt(sch_two.ScheduleDate, 10) + ":dialysis_orders_list_all"
+
+		//清空key 值
+		redis.Set(keyOne, "", time.Second)
+
+		//c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientDialysisOrderTwo)
+		//return
+	}
+	//替换者和被替换的排班日期不是同一天，则进行一个患者一天不能有多个排班提醒
+	if sch.ScheduleDate != sch_two.ScheduleDate && sch.PatientId != sch_two.PatientId {
+		count, _ := service.GetScheduleCountByDate(c.GetMobileAdminUserInfo().Org.Id, sch_two.ScheduleDate, sch.PatientId)
+		if count > 0 {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
+			return
+		}
+	}
+
+	var new_sch models.Schedule
+	new_sch = sch
+	new_sch.BedId = sch_two.BedId
+	new_sch.ScheduleDate = sch_two.ScheduleDate
+	new_sch.ScheduleWeek = sch_two.ScheduleWeek
+	new_sch.PartitionId = sch_two.PartitionId
+	new_sch.ScheduleType = sch_two.ScheduleType
+	new_sch.ID = 0
+	//删除原来的排班
+	err := service.SaveSchTwo(sch, sch_two)
+	//生成新的排班
+	if err == nil {
+		err2 := service.SaveSch(&new_sch)
+		if err2 == nil {
+			//去除当天患者排班中重复数据，保留最后一条数据
+			service.UpdateRepeatSchStatus(sch.UserOrgId, sch.ScheduleDate)
+			service.UpdateRepeatSchStatus(sch_two.UserOrgId, sch_two.ScheduleDate)
+			service.UpdateRepeatSchStatus(new_sch.UserOrgId, new_sch.ScheduleDate)
+
+			c.ServeSuccessJSON(map[string]interface{}{
+				"msg":     "覆盖成功",
+				"new_sch": new_sch,
+			})
+		} else {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+	} else {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+}

controllers/mobile_api_controllers/mobile_api_router_register.go

@@ -208,4 +208,8 @@ func MobileAPIControllersRegisterRouters() {
 
 	beego.Router("/m/api/getlastacceptrecrods", &DialysisAPIController{}, "Get:GetLastAcceptRecrods")
 
+	beego.Router("/m/api/sch/exchange", &DialysisAPIController{}, "Get:ExMobileChangeSch")
+
+	beego.Router("/m/api/sch/coversch", &DialysisAPIController{}, "Get:MobileCoverSch")
+
 }

controllers/new_mobile_api_controllers/staff_schedule_api_controller.go

@@ -1282,3 +1282,31 @@ func (c *StaffScheduleApiController) ChangeScheduleBed() {
 		}
 	}
 }
+
+func (c *StaffScheduleApiController) UpdateMobileSchedule() {
+
+	fmt.Println("hhahdhhfahdfhahdfhahfh")
+	id_one, _ := c.GetInt64("id_one")
+	id_two, _ := c.GetInt64("id_two")
+	schedule_date, _ := c.GetInt64("schedule_date")
+	//timeLayout := "2006-01-02"
+	//loc, _ := time.LoadLocation("Local")
+	//startTime, _ := time.ParseInLocation(timeLayout+" 15:04:05", schedule_date+" 00:00:00", loc)
+
+	mode_id, _ := c.GetInt64("mode_id")
+	bed_id, _ := c.GetInt64("bed_id")
+	zone_id, _ := c.GetInt64("zone_id")
+	schedule_type, _ := c.GetInt64("schedule_type")
+	orgId := c.GetMobileAdminUserInfo().Org.Id
+
+	schedule, _ := service.GetSchedulePatientIdByPatient(id_one, schedule_date, orgId)
+
+	if schedule.ID > 0 {
+		service.UpdateMobileSchedule(id_two, mode_id, bed_id, zone_id, schedule_type, schedule.ID)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"msg": "ok",
+	})
+	return
+}

controllers/new_mobile_api_controllers/staff_schedule_api_router.go

@@ -35,4 +35,7 @@ func StaffScheduleApiControllersRegisterRouters() {
 	beego.Router("m/api/schedule/changescheduletype", &StaffScheduleApiController{}, "Get:ChangeScheduleType")
 
 	beego.Router("m/api/schedule/changeschedulebed", &StaffScheduleApiController{}, "Get:ChangeScheduleBed")
+
+	beego.Router("m/api/schedule/updateschedule", &StaffScheduleApiController{}, "Get:UpdateMobileSchedule")
+
 }

controllers/patient_api_controller.go

@@ -84,6 +84,54 @@ func PatientApiRegistRouters() {
 
 	beego.Router("/api/patient/getexportlist", &PatientApiController{}, "Get:GetExportList")
 
+	beego.Router("/api/patient/savefalloutbedprint", &PatientApiController{}, "Post:SaveFallOutBedPrint")
+
+	beego.Router("/api/patient/getfalloutbedprintlist", &PatientApiController{}, "Get:GetFallOutBedPrintList")
+
+	beego.Router("/api/patient/savefilterinformed", &PatientApiController{}, "Post:SaveFilterInformed")
+
+	beego.Router("/api/patient/getfilterinformed", &PatientApiController{}, "Get:GetFilterInformed")
+
+	beego.Router("/api/patient/saveprofundainformed", &PatientApiController{}, "Post:SaveProfundaInformed")
+
+	beego.Router("/api/patient/getprofundainformed", &PatientApiController{}, "Get:GetProfundaInformed")
+
+	beego.Router("/api/patient/arterovenous", &PatientApiController{}, "Post:SaveArterOvenous")
+
+	beego.Router("/api/patient/getarterovernous", &PatientApiController{}, "Get:GetArterOverNous")
+
+	beego.Router("/api/patient/savehighrikinformed", &PatientApiController{}, "Post:SaveHighRikInformed")
+
+	beego.Router("/api/patient/gethighriskinformed", &PatientApiController{}, "Get:GetHighRiskInformed")
+
+	beego.Router("/api/patient/saveanticoagulation", &PatientApiController{}, "Post:SaveAnticoagulation")
+
+	beego.Router("/api/patient/getanticoagulationInformed", &PatientApiController{}, "Get:GetAnticoagulationInformed")
+
+	beego.Router("/api/patient/savecriticalinfomed", &PatientApiController{}, "Post:SaveCriticalInfomed")
+
+	beego.Router("/api/patient/getcriticalinformed", &PatientApiController{}, "Get:GetCriticalInformed")
+
+	beego.Router("/api/patient/savehemoperfusioninformed", &PatientApiController{}, "Post:SaveHemoperfusionInformed")
+
+	beego.Router("/api/patient/gethemoperfusioninformed", &PatientApiController{}, "Get:GetHemoperfusionInformed")
+
+	beego.Router("/api/patient/savebringinformed", &PatientApiController{}, "Post:SaveBringInformed")
+
+	beego.Router("/api/patient/getinformedcontsent", &PatientApiController{}, "Get:GetInformedContsent")
+
+	beego.Router("/api/patient/savecatheterization", &PatientApiController{}, "Post:SaveCatheterization")
+
+	beego.Router("/api/patient/getcatheterization", &PatientApiController{}, "Get:GetCatheterization")
+
+	beego.Router("/api/patient/savedialyzerInformed", &PatientApiController{}, "Post:SaveDialyzerInformed")
+
+	beego.Router("/api/patient/getdialyzerinformed", &PatientApiController{}, "Get:GetDialyzerInformed")
+
+	beego.Router("/api/patient/savetheapyinformed", &PatientApiController{}, "Post:SaveTheapyInformed")
+
+	beego.Router("api/patient/gettherapyinformed", &PatientApiController{}, "Get:GetTherapyInformed")
+
 }
 func (c *PatientApiController) GetExportList() {
 	startTime := c.GetString("start_time")
@@ -6060,3 +6108,526 @@ func (c *PatientApiController) GetDialysisSolutionDetailList() {
 		"total": total,
 	})
 }
+
+func (c *PatientApiController) SaveFallOutBedPrint() {
+
+	adminInfo := c.GetAdminUserInfo()
+	orgid := adminInfo.CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	outPrint := models.XtFallOutPrint{
+		UserOrgId: orgid,
+		Content:   content,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	//查询该机构是否存在
+	list, err := service.GetOutPrintList(orgid)
+
+	if list.ID == 0 {
+		service.CreateFallOutBedPrint(outPrint)
+	}
+
+	if list.ID > 0 {
+		service.UpdateFallOutBedPrint(list.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": list,
+	})
+}
+
+func (c *PatientApiController) GetFallOutBedPrintList() {
+
+	adminInfo := c.GetAdminUserInfo()
+	orgid := adminInfo.CurrentOrgId
+
+	list, _ := service.GetFallOutBedPrintList(orgid)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": list,
+	})
+}
+
+func (c *PatientApiController) SaveFilterInformed() {
+
+	adminInfo := c.GetAdminUserInfo()
+	orgid := adminInfo.CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+	informed := models.XtFilterInformed{
+		UserOrgId: orgid,
+		Content:   content,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	filterInformed, _ := service.GetFilterInformed(orgid)
+
+	if filterInformed.ID == 0 {
+
+		service.CreateFilterInformed(informed)
+	}
+
+	if filterInformed.ID > 0 {
+
+		service.UpdateFilterInformed(filterInformed.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"informed": informed,
+	})
+
+}
+
+func (c *PatientApiController) GetFilterInformed() {
+
+	adminInfo := c.GetAdminUserInfo()
+	orgid := adminInfo.CurrentOrgId
+	filterInformed, _ := service.GetFilterInformed(orgid)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": filterInformed,
+	})
+}
+
+func (c *PatientApiController) SaveProfundaInformed() {
+
+	adminInfo := c.GetAdminUserInfo()
+	orgid := adminInfo.CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	informed := models.XtProfundaInformed{
+		UserOrgId: orgid,
+		Content:   content,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	profundaInformed, _ := service.GetProfundaInformed(orgid)
+
+	if profundaInformed.ID == 0 {
+		service.CreateProfundaInformed(informed)
+	}
+
+	if profundaInformed.ID > 0 {
+
+		service.UpdateProfundaInformed(profundaInformed.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": profundaInformed,
+	})
+}
+
+func (c *PatientApiController) GetProfundaInformed() {
+
+	adminInfo := c.GetAdminUserInfo()
+	orgid := adminInfo.CurrentOrgId
+
+	profundaInformed, _ := service.GetProfundaInformed(orgid)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": profundaInformed,
+	})
+}
+
+func (c *PatientApiController) SaveArterOvenous() {
+
+	adminInfo := c.GetAdminUserInfo()
+	orgid := adminInfo.CurrentOrgId
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	arterOvenous := models.XtArterOvenous{
+		UserOrgId: orgid,
+		Content:   content,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	list, _ := service.GetArterOvenousList(orgid)
+
+	if list.ID == 0 {
+
+		service.CreateArterOvernous(arterOvenous)
+	}
+
+	if list.ID > 0 {
+		service.UpdateArterOvernous(list.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": list,
+	})
+}
+
+func (c *PatientApiController) GetArterOverNous() {
+
+	adminInfo := c.GetAdminUserInfo()
+	orgid := adminInfo.CurrentOrgId
+
+	list, _ := service.GetArterOvenousList(orgid)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": list,
+	})
+
+}
+
+func (c *PatientApiController) SaveHighRikInformed() {
+
+	adminInfo := c.GetAdminUserInfo()
+	orgid := adminInfo.CurrentOrgId
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	risk := models.XtHightRisk{
+		UserOrgId: orgid,
+		Content:   content,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	highRik, _ := service.GetHightRikInformed(orgid)
+
+	if highRik.ID == 0 {
+
+		service.CreateHighRik(risk)
+	}
+
+	if highRik.ID > 0 {
+
+		service.UpdateHighRik(highRik.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": risk,
+	})
+}
+
+func (c *PatientApiController) GetHighRiskInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+
+	rikInformed, _ := service.GetHightRikInformed(orgId)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": rikInformed,
+	})
+}
+
+func (c *PatientApiController) SaveAnticoagulation() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	auticoagutionPrint := models.XtAuticoagutionPrint{
+		Content:   content,
+		UserOrgId: orgId,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	anticoagulation, _ := service.GetAnticoagulation(orgId)
+
+	if anticoagulation.ID == 0 {
+
+		service.CreateAnticoagulation(auticoagutionPrint)
+	}
+
+	if anticoagulation.ID > 0 {
+
+		service.UpdateAnticoagulation(anticoagulation.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": auticoagutionPrint,
+	})
+
+}
+
+func (c *PatientApiController) GetAnticoagulationInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+
+	anticoagulation, _ := service.GetAnticoagulation(orgId)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": anticoagulation,
+	})
+}
+
+func (c *PatientApiController) SaveCriticalInfomed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	criticalinfomedPrint := models.XtCriticalinfomedPrint{
+		UserOrgId: orgId,
+		Content:   content,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	infomed, _ := service.GetCriticalInfomed(orgId)
+
+	if infomed.ID == 0 {
+		service.CreatedCriticalInfomed(criticalinfomedPrint)
+	}
+
+	if infomed.ID > 0 {
+		service.UpdateCriticalInfomed(infomed.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": criticalinfomedPrint,
+	})
+}
+
+func (c *PatientApiController) GetCriticalInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+
+	infomed, _ := service.GetCriticalInfomed(orgId)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": infomed,
+	})
+}
+
+func (c *PatientApiController) SaveHemoperfusionInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	hemoperfusionmedPrint := models.XtHemoperfusionmedPrint{
+		UserOrgId: orgId,
+		Content:   content,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	informed, _ := service.GetHemoperfusionInformed(orgId)
+
+	if informed.ID == 0 {
+
+		service.CreateHemoperfusionInformed(hemoperfusionmedPrint)
+	}
+
+	if informed.ID > 0 {
+
+		service.UpdateHemoperfusionInformed(informed.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": hemoperfusionmedPrint,
+	})
+}
+
+func (c *PatientApiController) GetHemoperfusionInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+
+	informed, _ := service.GetHemoperfusionInformed(orgId)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": informed,
+	})
+}
+
+func (c *PatientApiController) SaveBringInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	bringinformedPrint := models.XtBringinformedPrint{
+		Content:   content,
+		UserOrgId: orgId,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+		Status:    1,
+	}
+
+	informed, _ := service.GetBringInformed(orgId)
+
+	if informed.ID == 0 {
+		service.CreateBringInformed(bringinformedPrint)
+	}
+	if informed.ID > 0 {
+		service.UpdateBringInformed(informed.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": bringinformedPrint,
+	})
+}
+
+func (c *PatientApiController) GetInformedContsent() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	informed, _ := service.GetBringInformed(orgId)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": informed,
+	})
+}
+
+func (c *PatientApiController) SaveCatheterization() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	cathetercationPrint := models.XtCathetercationPrint{
+		UserOrgId: orgId,
+		Content:   content,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	catheterization, _ := service.GetCatheterization(orgId)
+
+	if cathetercationPrint.ID == 0 {
+
+		service.CreateCatheteriztion(cathetercationPrint)
+	}
+
+	if cathetercationPrint.ID > 0 {
+
+		service.UpdateCatheterization(catheterization.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": catheterization,
+	})
+}
+
+func (c *PatientApiController) GetCatheterization() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	catheterization, _ := service.GetCatheterization(orgId)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": catheterization,
+	})
+}
+
+func (c *PatientApiController) SaveDialyzerInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	dialyszerinformedPrint := models.XtDialyszerinformedPrint{
+		UserOrgId: orgId,
+		Content:   content,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	informed, _ := service.GetDialyzerInformed(orgId)
+
+	if informed.ID == 0 {
+
+		service.CreateDialyzerInformed(dialyszerinformedPrint)
+	}
+
+	if informed.ID > 0 {
+		service.UpdateDialyszerInformed(informed.ID, content)
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": dialyszerinformedPrint,
+	})
+}
+
+func (c *PatientApiController) GetDialyzerInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	informed, _ := service.GetDialyzerInformed(orgId)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": informed,
+	})
+}
+
+func (c *PatientApiController) SaveTheapyInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err", err)
+	content := dataBody["content"].(string)
+
+	theapyinformedPrint := models.XtTheapyinformedPrint{
+		Content:   content,
+		UserOrgId: orgId,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+	}
+
+	theapyInformed, _ := service.GetTheapyInformed(orgId)
+
+	if theapyInformed.ID == 0 {
+
+		service.CreateTheapyInformed(theapyinformedPrint)
+	}
+
+	if theapyInformed.ID > 0 {
+
+		service.UpdateTheaphInformed(theapyInformed.ID, content)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": theapyinformedPrint,
+	})
+
+}
+
+func (c *PatientApiController) GetTherapyInformed() {
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+	theapyInformed, _ := service.GetTheapyInformed(orgId)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list": theapyInformed,
+	})
+}

controllers/schedule_api_controller.go

@@ -103,7 +103,7 @@ func (c *ScheduleApiController) CoverSch() {
 	//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientDialysisOrderOne)
 	//	return
 	//}
-	order, _ := service.GetDialysisOrder(sch.ScheduleDate, sch.PatientId, sch.UserOrgId)
+	order, _ := service.GetOneDialysisOrderOne(sch.ScheduleDate, sch.PatientId, sch.UserOrgId)
 	if order.ID > 0 {
 
 		service.UpdateDialysiOrderByPatientId(id_two, sch_two.ScheduleType, sch_two.PartitionId, sch_two.BedId)
@@ -188,7 +188,7 @@ func (c *ScheduleApiController) ExchangeSch() {
 
 	err := service.UpdateScheduleThree(sch, sch_two)
 
-	order, _ := service.GetDialysisOrder(sch.ScheduleDate, sch.PatientId, sch.UserOrgId)
+	order, _ := service.GetOneDialysisOrderOne(sch.ScheduleDate, sch.PatientId, sch.UserOrgId)
 	if order.ID > 0 {
 		//查询该患者的排班机位
 		pSchedule, _ := service.GetPscheduleDate(sch.ScheduleDate, sch.PatientId, sch.UserOrgId)
@@ -1679,15 +1679,16 @@ func (c *ScheduleApiController) CreateScheduleTwo() {
 	tm := time.Unix(int64(schedule_two.ScheduleDate), 0)
 	timeStr := tm.Format(timeTemplate)
 	if timeNow > timeStr {
+		fmt.Println("寄哪里地方")
 		utils.ErrorLog(timeNow)
 		utils.ErrorLog(timeStr)
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCantSetScheduleBeforeNow)
 		return
 	}
-	if schedule_two == nil {
-		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeScheduleNotExist)
-		return
-	}
+	//if schedule_two == nil {
+	//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeScheduleNotExist)
+	//	return
+	//}
 
 	//order, err := service.GetOneDialysisOrder(adminINfo.CurrentOrgId, schedule_two.ScheduleDate, schedule_two.PatientId)
 	//if err != nil {
@@ -1896,57 +1897,52 @@ func (c *ScheduleApiController) CreateScheduleTwo() {
 	lastSchedule, _ := service.GetLastSchedule(patientID, adminUserInfo.CurrentOrgId)
 
 	//查询上机床位号 更改床位号
-	order, err := service.GetOneDialysisOrder(adminINfo.CurrentOrgId, schedule_two.ScheduleDate, schedule_two.PatientId)
-
+	order, err := service.GetOneDialysisOrderOne(adminINfo.CurrentOrgId, schedule_two.ScheduleDate, schedule_two.PatientId)
+	fmt.Println("errw222222222222222222", order.ID)
 	if order.ID > 0 {
 		service.UpdateDialysiOrderByPatientId(order.ID, schedule.ScheduleType, schedule.PartitionId, order.BedID)
 		redis := service.RedisClient()
-		key := strconv.FormatInt(adminINfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":dialysis_order"
+		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":dialysis_order"
 		redis.Set(key, "", time.Second)
-		keyOne := strconv.FormatInt(adminINfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":dialysis_orders_list_all"
+		keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":dialysis_orders_list_all"
 
 		//清空key 值
 		redis.Set(keyOne, "", time.Second)
 
 	}
 
-	if err == nil {
-		redis := service.RedisClient()
-		key := "scheduals_" + scheduleDate + "_" + strconv.FormatInt(adminUserInfo.CurrentOrgId, 10)
-		redis.Set(key, "", time.Second)
-		//处方
-		keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":prescriptions_list_all"
-		redis.Set(keyOne, "", time.Second)
-		//医嘱
-		keyTwo := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":advice_list_all"
-		redis.Set(keyTwo, "", time.Second)
-		keySix := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":assessment_befores_list_all"
-		redis.Set(keySix, "", time.Second)
-		keyThree := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":assessment_after_dislysis_list_all"
-		redis.Set(keyThree, "", time.Second)
-		keyFour := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":monitor_record_list_all"
-		redis.Set(keyFour, "", time.Second)
-		keyFive := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":treatment_summarys_list_all"
-		redis.Set(keyFive, "", time.Second)
-		keySeven := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":dialysis_orders_list_all"
-		redis.Set(keySeven, "", time.Second)
-		defer redis.Close()
-		schedule.Patient = patientInfo.Name
+	redis := service.RedisClient()
+	key := "scheduals_" + scheduleDate + "_" + strconv.FormatInt(adminUserInfo.CurrentOrgId, 10)
+	redis.Set(key, "", time.Second)
+	//处方
+	keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":prescriptions_list_all"
+	redis.Set(keyOne, "", time.Second)
+	//医嘱
+	keyTwo := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":advice_list_all"
+	redis.Set(keyTwo, "", time.Second)
+	keySix := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":assessment_befores_list_all"
+	redis.Set(keySix, "", time.Second)
+	keyThree := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":assessment_after_dislysis_list_all"
+	redis.Set(keyThree, "", time.Second)
+	keyFour := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":monitor_record_list_all"
+	redis.Set(keyFour, "", time.Second)
+	keyFive := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":treatment_summarys_list_all"
+	redis.Set(keyFive, "", time.Second)
+	keySeven := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":dialysis_orders_list_all"
+	redis.Set(keySeven, "", time.Second)
+	defer redis.Close()
+	schedule.Patient = patientInfo.Name
 
-		//去除当天患者排班中重复数据，保留最后一条数据
-		service.UpdateRepeatSchStatus(schedule.UserOrgId, schedule.ScheduleDate)
+	//去除当天患者排班中重复数据，保留最后一条数据
+	service.UpdateRepeatSchStatus(schedule.UserOrgId, schedule.ScheduleDate)
 
-		c.ServeSuccessJSON(map[string]interface{}{
-			"msg":          "ok",
-			"schedule":     schedule,
-			"schedule_two": schedule_two,
-			"lastSchedule": lastSchedule,
-		})
-		return
-	} else {
-		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateScheduleFail)
-		return
-	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"msg":          "ok",
+		"schedule":     schedule,
+		"schedule_two": schedule_two,
+		"lastSchedule": lastSchedule,
+	})
+	return
 
 }
 

controllers/self_drug_api_congtroller.go

@@ -4361,6 +4361,9 @@ func (this *SelfDrugApiController) GetPurchaseStockQueryList() {
 		for _, it := range losses {
 			item.WareStartEndStockInventoryLosses = append(item.WareStartEndStockInventoryLosses, it)
 		}
+
+		//获取期初结余
+		//service.GetNewOverInCount(item.ID, orgId, startTime, storeConfig.StorehouseOutInfo)
 	}
 
 	if err != nil {

controllers/sign_api_controller.go

@@ -8,6 +8,7 @@ import (
 	"fmt"
 	"github.com/astaxie/beego"
 	"github.com/jung-kurt/gofpdf"
+	"github.com/mozillazg/go-pinyin"
 	"io/ioutil"
 	"time"
 )
@@ -664,12 +665,7 @@ func (this *SignApiController) GetEnterPriseDetail() {
 
 func (this *SignApiController) UploadPrintOrder() {
 
-	orderList, _ := service.GetWarehouseOutOrderList()
-
-	for _, item := range orderList {
-		service.UpdateWarehouseOutOrderInfo(item.ID, item.WarehouseOutOrderNumber)
-	}
-	//list, _ := service.GetAllPatientNew(10318)
+	//list, _ := service.GetAllPatientNew(10622)
 	//for _, item := range list {
 	//
 	//	hans := item.Name // 要转换的汉字字符串
@@ -696,23 +692,23 @@ func (this *SignApiController) UploadPrintOrder() {
 	//	//fmt.Println("First Letter:", firstLetter)
 	//}
 
-	//baseList, _ := service.GeteAllBaseList(10587)
-	//for _, item := range baseList {
-	//	hans := item.DrugName // 要转换的汉字字符串
-	//	// 创建一个拼音转换器
-	//	p := pinyin.NewArgs()
-	//	// 将汉字转为拼音
-	//	pinyinSlice := pinyin.Pinyin(hans, p)
-	//	// 获取首字母
-	//	firstLetter := ""
-	//	for _, py := range pinyinSlice {
-	//		if len(py) > 0 {
-	//			firstLetter += string(py[0][0])
-	//		}
-	//	}
-	//	item.FirstLetter = firstLetter
-	//	service.UpdateBaseList(item.ID, item.FirstLetter)
-	//}
+	baseList, _ := service.GeteAllBaseList(10622)
+	for _, item := range baseList {
+		hans := item.DrugName // 要转换的汉字字符串
+		// 创建一个拼音转换器
+		p := pinyin.NewArgs()
+		// 将汉字转为拼音
+		pinyinSlice := pinyin.Pinyin(hans, p)
+		// 获取首字母
+		firstLetter := ""
+		for _, py := range pinyinSlice {
+			if len(py) > 0 {
+				firstLetter += string(py[0][0])
+			}
+		}
+		item.FirstLetter = firstLetter
+		service.UpdateBaseList(item.ID, item.FirstLetter)
+	}
 	//pdf := gofpdf.New("P", "mm", "A4", "")
 	//pdf.AddPage()
 	//pdf.Text(5, 10, "血液净化治疗记录单")

go.mod

@@ -22,6 +22,7 @@ require (
 	github.com/jung-kurt/gofpdf v1.16.2 // indirect
 	github.com/kr/text v0.2.0 // indirect
 	github.com/matttproud/golang_protobuf_extensions v1.0.1 // indirect
+	github.com/mozillazg/go-pinyin v0.20.0 // indirect
 	github.com/prometheus/client_golang v1.7.0 // indirect
 	github.com/prometheus/client_model v0.2.0 // indirect
 	github.com/prometheus/common v0.10.0 // indirect

go.sum

@@ -112,6 +112,8 @@ github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJ
 github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
 github.com/modern-go/reflect2 v0.0.0-20180701023420-4b7aa43c6742/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
 github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
+github.com/mozillazg/go-pinyin v0.20.0 h1:BtR3DsxpApHfKReaPO1fCqF4pThRwH9uwvXzm+GnMFQ=
+github.com/mozillazg/go-pinyin v0.20.0/go.mod h1:iR4EnMMRXkfpFVV5FMi4FNB6wGq9NV6uDWbUuPhP4Yc=
 github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
 github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e h1:fD57ERR4JtEqsWbfPhv4DMiApHyliiK5xCTNVSPiaAs=
 github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno=

models/new_stock_models.go

@@ -145,32 +145,33 @@ func (NewBaseDrug) TableName() string {
 }
 
 type NewBaseDrugOne struct {
-	ID                  int64                  `gorm:"column:id" json:"id" form:"id"`
-	DrugName            string                 `gorm:"column:drug_name" json:"drug_name" form:"drug_name"`
-	DrugSpec            string                 `gorm:"column:drug_spec" json:"drug_spec" form:"drug_spec"`
-	DrugStockLimit      string                 `gorm:"column:drug_stock_limit" json:"drug_stock_limit" form:"drug_stock_limit"`
-	MaxUnit             string                 `gorm:"column:max_unit" json:"max_unit" form:"max_unit"`
-	MinNumber           int64                  `gorm:"column:min_number" json:"min_number" form:"min_number"`
-	MinUnit             string                 `gorm:"column:min_unit" json:"min_unit" form:"min_unit"`
-	Dose                string                 `gorm:"column:dose" json:"dose" form:"dose"`
-	DoseUnit            string                 `gorm:"column:dose_unit" json:"dose_unit" form:"dose_unit"`
-	RetailPrice         float64                `gorm:"column:retail_price" json:"retail_price" form:"retail_price"`
-	MinPrice            float64                `gorm:"column:min_price" json:"min_price" form:"min_price"`
-	LastPrice           float64                `gorm:"column:last_price" json:"last_price" form:"last_price"`
-	Number              string                 `gorm:"column:number" json:"number" form:"number"`
-	OrgId               int64                  `gorm:"column:org_id" json:"org_id" form:"org_id"`
-	DrugWarehouseInfo   []*VsDrugWarehouseInfo `gorm:"ForeignKey:DrugId;AssociationForeignKey:ID" json:"drug_warehouse_info"`
-	XtDrugStockCount    []*XtDrugStockCount    `gorm:"ForeignKey:DrugId;AssociationForeignKey:ID" json:"drug_stock_count"`
-	DrugStockCount      []*XtDrugStockCount    `gorm:"ForeignKey:DrugId;AssociationForeignKey:ID" json:"drug_stock_info"`
-	TotalCount          int64                  `gorm:"column:total_count" json:"total_count" form:"total_count"`
-	IsUser              int64                  `gorm:"column:is_user" json:"is_user" form:"is_user"`
-	BatchRetaiPrice     float64                `gorm:"column:batch_retai_price" json:"batch_retai_price" form:"batch_retai_price"`
-	DrugStockLimitCount int64                  `gorm:"column:drug_stock_limit_count" json:"drug_stock_limit_count" form:"drug_stock_limit_count"`
-	SumCount            int64                  `gorm:"column:sum_count" json:"sum_count" form:"sum_count"`
-	SumInCount          int64                  `gorm:"column:sum_in_count" json:"sum_in_count" form:"sum_in_count"`
-	IsPharmacy          int64                  `gorm:"column:is_pharmacy" json:"is_pharmacy" form:"is_pharmacy"`
-	Manufacturer        int64                  `gorm:"column:manufacturer" json:"manufacturer" form:"manufacturer"`
-	Dealer              int64                  `gorm:"column:dealer" json:"dealer" form:"dealer"`
+	ID                     int64                  `gorm:"column:id" json:"id" form:"id"`
+	DrugName               string                 `gorm:"column:drug_name" json:"drug_name" form:"drug_name"`
+	DrugSpec               string                 `gorm:"column:drug_spec" json:"drug_spec" form:"drug_spec"`
+	DrugStockLimit         string                 `gorm:"column:drug_stock_limit" json:"drug_stock_limit" form:"drug_stock_limit"`
+	MaxUnit                string                 `gorm:"column:max_unit" json:"max_unit" form:"max_unit"`
+	MinNumber              int64                  `gorm:"column:min_number" json:"min_number" form:"min_number"`
+	MinUnit                string                 `gorm:"column:min_unit" json:"min_unit" form:"min_unit"`
+	Dose                   string                 `gorm:"column:dose" json:"dose" form:"dose"`
+	DoseUnit               string                 `gorm:"column:dose_unit" json:"dose_unit" form:"dose_unit"`
+	RetailPrice            float64                `gorm:"column:retail_price" json:"retail_price" form:"retail_price"`
+	MinPrice               float64                `gorm:"column:min_price" json:"min_price" form:"min_price"`
+	LastPrice              float64                `gorm:"column:last_price" json:"last_price" form:"last_price"`
+	Number                 string                 `gorm:"column:number" json:"number" form:"number"`
+	OrgId                  int64                  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	DrugWarehouseInfo      []*VsDrugWarehouseInfo `gorm:"ForeignKey:DrugId;AssociationForeignKey:ID" json:"drug_warehouse_info"`
+	XtDrugStockCount       []*XtDrugStockCount    `gorm:"ForeignKey:DrugId;AssociationForeignKey:ID" json:"drug_stock_count"`
+	DrugStockCount         []*XtDrugStockCount    `gorm:"ForeignKey:DrugId;AssociationForeignKey:ID" json:"drug_stock_info"`
+	TotalCount             int64                  `gorm:"column:total_count" json:"total_count" form:"total_count"`
+	IsUser                 int64                  `gorm:"column:is_user" json:"is_user" form:"is_user"`
+	BatchRetaiPrice        float64                `gorm:"column:batch_retai_price" json:"batch_retai_price" form:"batch_retai_price"`
+	DrugStockLimitCount    int64                  `gorm:"column:drug_stock_limit_count" json:"drug_stock_limit_count" form:"drug_stock_limit_count"`
+	SumCount               int64                  `gorm:"column:sum_count" json:"sum_count" form:"sum_count"`
+	SumInCount             int64                  `gorm:"column:sum_in_count" json:"sum_in_count" form:"sum_in_count"`
+	IsPharmacy             int64                  `gorm:"column:is_pharmacy" json:"is_pharmacy" form:"is_pharmacy"`
+	Manufacturer           int64                  `gorm:"column:manufacturer" json:"manufacturer" form:"manufacturer"`
+	Dealer                 int64                  `gorm:"column:dealer" json:"dealer" form:"dealer"`
+	MedicalInsuranceNumber string                 `gorm:"column:medical_insurance_number" json:"medical_insurance_number" form:"medical_insurance_number"`
 }
 
 func (NewBaseDrugOne) TableName() string {
@@ -307,6 +308,10 @@ type GoodInfoTwenty struct {
 	WareStartEndStockInventoryProfit []*VmStockFlowTwenty //期间盘盈
 	WareStartEndStockInventoryLosses []*VmStockFlowTwenty //期间盘亏
 
+	//newOverInCount     []*VmStockFlowTwenty
+	//newOverOuntCount   []*VmStockFlowTwenty
+	//newOverCancelCount []*VmStockFlowTwenty
+
 	//期初结余
 	GoodStartFlowInfo VmStockFlowTwenty
 	//期末结余

models/patient_models.go

@@ -2376,3 +2376,159 @@ type PatientsTwenty struct {
 func (PatientsTwenty) TableName() string {
 	return "xt_patients"
 }
+
+type XtFallOutPrint struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtFallOutPrint) TableName() string {
+	return "xt_fall_out_print"
+}
+
+type XtFilterInformed struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtFilterInformed) TableName() string {
+	return "xt_filter_informed"
+}
+
+type XtProfundaInformed struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtProfundaInformed) TableName() string {
+	return "xt_profunda_informed"
+}
+
+type XtArterOvenous struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtArterOvenous) TableName() string {
+	return "xt_arter_ovenous"
+}
+
+type XtHightRisk struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtHightRisk) TableName() string {
+	return "xt_hight_risk"
+}
+
+type XtAuticoagutionPrint struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtAuticoagutionPrint) TableName() string {
+	return "xt_auticoagution_print"
+}
+
+type XtCriticalinfomedPrint struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtCriticalinfomedPrint) TableName() string {
+	return "xt_criticalinfomed_print"
+}
+
+type XtHemoperfusionmedPrint struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtHemoperfusionmedPrint) TableName() string {
+	return "xt_hemoperfusionmed_print"
+}
+
+type XtBringinformedPrint struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+}
+
+func (XtBringinformedPrint) TableName() string {
+	return "xt_bring_print"
+}
+
+type XtCathetercationPrint struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtCathetercationPrint) TableName() string {
+	return "xt_cathetercation_print"
+}
+
+type XtDialyszerinformedPrint struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtDialyszerinformedPrint) TableName() string {
+	return "xt_dialyszerinformed_print"
+}
+
+type XtTheapyinformedPrint struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	Content   string `gorm:"column:content" json:"content" form:"content"`
+	UserOrgId int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Status    int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime     int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (XtTheapyinformedPrint) TableName() string {
+	return "xt_theapyinformed_print"
+}

service/dialysis_service.go

@@ -1066,6 +1066,15 @@ func GetOneDialysisOrder(orgID, orderData int64, patient_id int64) (*models.Dial
 	return &order, nil
 }
 
+func GetOneDialysisOrderOne(orgID, orderData int64, patient_id int64) (models.DialysisOrder, error) {
+
+	order := models.DialysisOrder{}
+
+	err := readDb.Where("user_org_id=? and dialysis_date=? and status=1 and patient_id = ?", orgID, orderData, patient_id).Find(&order).Error
+
+	return order, err
+}
+
 func GetPscheduleDate(schedule_date int64, patient_id int64, user_org_id int64) (models.XtSchedule, error) {
 
 	schedule := models.XtSchedule{}

service/patient_service.go

@@ -1531,7 +1531,7 @@ func GetPatientDialysisRecord(orgID, patientID int64, page, limit, start, end, m
 		Preload("PredialysisEvaluation", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
 		Preload("DialysisPrescription", func(db *gorm.DB) *gorm.DB {
 			return readDb.Where("patient_id=? and user_org_id=? and status=1", patientID, orgID).Preload("UserAdminRole", func(db *gorm.DB) *gorm.DB {
-				return readUserDb.Where("status = 1")
+				return readUserDb.Where("status = 1 and org_id=?", orgID)
 			})
 		}).
 		Preload("AssessmentAfterDislysis", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
@@ -3404,3 +3404,281 @@ func GetLastAcceptRecrods(patient_id int64) (models.ReceiveTreatmentAsses, error
 	err := XTReadDB().Where("patient_id = ? and status= 1 and admission_number!=''", patient_id).Last(&treatmentAsses).Error
 	return treatmentAsses, err
 }
+
+func GetOutPrintList(user_org_id int64) (models.XtFallOutPrint, error) {
+
+	outPrint := models.XtFallOutPrint{}
+
+	err := XTReadDB().Where("user_org_id = ? and status =1", user_org_id).Find(&outPrint).Error
+
+	return outPrint, err
+}
+
+func CreateFallOutBedPrint(outPrint models.XtFallOutPrint) error {
+
+	err := XTWriteDB().Create(&outPrint).Error
+
+	return err
+}
+
+func UpdateFallOutBedPrint(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtFallOutPrint{}).Where("id = ? and status=1", id).Updates(map[string]interface{}{"content": content}).Error
+
+	return err
+}
+
+func GetFallOutBedPrintList(user_org_id int64) (models.XtFallOutPrint, error) {
+
+	outPrint := models.XtFallOutPrint{}
+
+	err := XTReadDB().Where("user_org_id = ? and status=1", user_org_id).Find(&outPrint).Error
+
+	return outPrint, err
+}
+
+func GetFilterInformed(user_org_id int64) (models.XtFilterInformed, error) {
+
+	informed := models.XtFilterInformed{}
+
+	err := XTReadDB().Where("user_org_id = ? and status =1", user_org_id).Find(&informed).Error
+
+	return informed, err
+}
+
+func CreateFilterInformed(informed models.XtFilterInformed) error {
+
+	err := XTWriteDB().Create(&informed).Error
+
+	return err
+}
+
+func UpdateFilterInformed(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtFilterInformed{}).Where("id = ? and status =1", id).Updates(map[string]interface{}{"content": content}).Error
+
+	return err
+}
+
+func GetProfundaInformed(user_org_id int64) (models.XtProfundaInformed, error) {
+
+	informed := models.XtProfundaInformed{}
+
+	err := XTReadDB().Where("user_org_id = ? and status =1", user_org_id).Find(&informed).Error
+
+	return informed, err
+}
+
+func CreateProfundaInformed(informed models.XtProfundaInformed) error {
+
+	err := XTWriteDB().Create(&informed).Error
+
+	return err
+}
+
+func UpdateProfundaInformed(id int64, content string) error {
+
+	profundaInformed := models.XtProfundaInformed{}
+
+	err := XTWriteDB().Model(&profundaInformed).Where("id = ? and status=1", id).Updates(map[string]interface{}{"content": content}).Error
+	return err
+}
+
+func GetArterOvenousList(user_org_id int64) (models.XtArterOvenous, error) {
+
+	ovenous := models.XtArterOvenous{}
+	err := XTReadDB().Where("user_org_id = ? and status=1", user_org_id).Find(&ovenous).Error
+	return ovenous, err
+}
+
+func CreateArterOvernous(ovenous models.XtArterOvenous) error {
+
+	err := XTWriteDB().Create(&ovenous).Error
+
+	return err
+}
+
+func UpdateArterOvernous(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtArterOvenous{}).Where("id = ? and status =1", id).Updates(map[string]interface{}{"content": content}).Error
+
+	return err
+}
+
+func GetHightRikInformed(user_org_id int64) (models.XtHightRisk, error) {
+
+	risk := models.XtHightRisk{}
+
+	err := XTReadDB().Where("user_org_id = ? and status =1", user_org_id).Find(&risk).Error
+
+	return risk, err
+}
+
+func CreateHighRik(risk models.XtHightRisk) error {
+
+	err := XTWriteDB().Create(&risk).Error
+
+	return err
+}
+
+func UpdateHighRik(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtHightRisk{}).Where("id = ? and status =1", id).Updates(map[string]interface{}{"content": content}).Error
+
+	return err
+}
+
+func GetAnticoagulation(user_org_id int64) (models.XtAuticoagutionPrint, error) {
+
+	auticoagutionPrint := models.XtAuticoagutionPrint{}
+
+	err := XTReadDB().Where("user_org_id = ? and status =1", user_org_id).Find(&auticoagutionPrint).Error
+
+	return auticoagutionPrint, err
+}
+
+func CreateAnticoagulation(auticoagutionPrint models.XtAuticoagutionPrint) error {
+
+	err := XTWriteDB().Create(&auticoagutionPrint).Error
+
+	return err
+}
+
+func UpdateAnticoagulation(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtAuticoagutionPrint{}).Where("id = ? and status =1", id).Updates(map[string]interface{}{"content": content}).Error
+
+	return err
+}
+
+func GetCriticalInfomed(org_id int64) (models.XtCriticalinfomedPrint, error) {
+
+	criticalinfomedPrint := models.XtCriticalinfomedPrint{}
+
+	err := XTReadDB().Where("user_org_id = ? and status=1", org_id).Find(&criticalinfomedPrint).Error
+
+	return criticalinfomedPrint, err
+}
+
+func CreatedCriticalInfomed(criticalinfomedPrint models.XtCriticalinfomedPrint) error {
+
+	err := XTWriteDB().Create(&criticalinfomedPrint).Error
+
+	return err
+}
+
+func UpdateCriticalInfomed(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtCriticalinfomedPrint{}).Where("id = ? and status=1", id).Updates(map[string]interface{}{"content": content}).Error
+
+	return err
+}
+
+func GetHemoperfusionInformed(user_org_id int64) (models.XtHemoperfusionmedPrint, error) {
+
+	hemoperfusionmedPrint := models.XtHemoperfusionmedPrint{}
+
+	err := XTReadDB().Where("user_org_id = ? and status =1", user_org_id).Find(&hemoperfusionmedPrint).Error
+
+	return hemoperfusionmedPrint, err
+}
+
+func CreateHemoperfusionInformed(hemoperfusionmedPrint models.XtHemoperfusionmedPrint) error {
+
+	err := XTWriteDB().Create(&hemoperfusionmedPrint).Error
+
+	return err
+}
+
+func UpdateHemoperfusionInformed(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtHemoperfusionmedPrint{}).Where("id = ? and status=1", id).Updates(map[string]interface{}{"content": content}).Error
+
+	return err
+}
+
+func GetBringInformed(org_id int64) (models.XtBringinformedPrint, error) {
+
+	bringinformedPrint := models.XtBringinformedPrint{}
+	err := XTReadDB().Where("user_org_id = ? and status=1", org_id).Find(&bringinformedPrint).Error
+
+	return bringinformedPrint, err
+}
+
+func CreateBringInformed(bringinformedPrint models.XtBringinformedPrint) error {
+
+	err := XTWriteDB().Create(&bringinformedPrint).Error
+
+	return err
+}
+
+func UpdateBringInformed(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtBringinformedPrint{}).Where("id =? and status= 1", id).Updates(map[string]interface{}{"content": content}).Error
+
+	return err
+}
+
+func GetCatheterization(user_org_id int64) (models.XtCathetercationPrint, error) {
+
+	cathetercationPrint := models.XtCathetercationPrint{}
+
+	err := XTReadDB().Where("user_org_id = ? and status= 1", user_org_id).Find(&cathetercationPrint).Error
+	return cathetercationPrint, err
+}
+
+func CreateCatheteriztion(cathetercationPrint models.XtCathetercationPrint) error {
+
+	err := XTWriteDB().Create(&cathetercationPrint).Error
+	return err
+}
+
+func UpdateCatheterization(id int64, content string) error {
+
+	err := XTWriteDB().Model(models.XtCathetercationPrint{}).Where("id=? and status =1", id).Updates(map[string]interface{}{"content": content}).Error
+
+	return err
+}
+
+func GetDialyzerInformed(org_id int64) (models.XtDialyszerinformedPrint, error) {
+
+	dialyszerinformedPrint := models.XtDialyszerinformedPrint{}
+
+	err := XTReadDB().Where("user_org_id = ? and status=1", org_id).Find(&dialyszerinformedPrint).Error
+
+	return dialyszerinformedPrint, err
+}
+
+func CreateDialyzerInformed(dialyszerinformedPrint models.XtDialyszerinformedPrint) error {
+
+	err := XTWriteDB().Create(&dialyszerinformedPrint).Error
+
+	return err
+}
+
+func UpdateDialyszerInformed(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtDialyszerinformedPrint{}).Where("id = ? and status=1", id).Updates(map[string]interface{}{"content": content}).Error
+	return err
+}
+
+func GetTheapyInformed(org_id int64) (models.XtTheapyinformedPrint, error) {
+
+	theapyinformedPrint := models.XtTheapyinformedPrint{}
+
+	err := XTReadDB().Where("user_org_id = ? and status=1", org_id).Find(&theapyinformedPrint).Error
+
+	return theapyinformedPrint, err
+}
+
+func CreateTheapyInformed(theapyinformedPrint models.XtTheapyinformedPrint) error {
+
+	err := XTWriteDB().Create(&theapyinformedPrint).Error
+	return err
+}
+
+func UpdateTheaphInformed(id int64, content string) error {
+
+	err := XTWriteDB().Model(&models.XtTheapyinformedPrint{}).Where("id = ? and status =1", id).Updates(map[string]interface{}{"content": content}).Error
+	return err
+}

service/schedule_service.go

@@ -1811,3 +1811,19 @@ func UpdateRepeatSchStatus(user_org_id int64, schedule_date int64) {
 	}
 
 }
+
+func GetSchedulePatientIdByPatient(patient_id int64, schedule_date int64, user_org_id int64) (models.Schedule, error) {
+
+	schedule := models.Schedule{}
+	err := XTReadDB().Where("patient_id = ? and schedule_date = ? and user_org_id = ? and status =1", patient_id, schedule_date, user_org_id).Find(&schedule).Error
+	return schedule, err
+}
+
+func UpdateMobileSchedule(id_two int64, mode_id int64, bed_id int64, zone_id int64, schedule_type int64, id int64) error {
+
+	schedule := models.Schedule{}
+
+	err = XTWriteDB().Model(&schedule).Where("id = ? and status=1", id).Updates(map[string]interface{}{"patient_id": id_two, "mode_id": mode_id, "bed_id": bed_id, "partition_id": zone_id, "schedule_type": schedule_type}).Error
+
+	return err
+}