医保对接

.idea/XT_New.iml

 <?xml version="1.0" encoding="UTF-8"?>
 <module type="WEB_MODULE" version="4">
+  <component name="Go" enabled="true" />
   <component name="NewModuleRootManager">
     <content url="file://$MODULE_DIR$" />
     <orderEntry type="inheritedJdk" />

.idea/misc.xml

   <component name="JavaScriptSettings">
     <option name="languageLevel" value="ES6" />
   </component>
-  <component name="RustProjectSettings">
-    <option name="toolchainHomeDirectory" value="$USER_HOME$/.cargo/bin" />
-  </component>
   <component name="SvnBranchConfigurationManager">
     <option name="myConfigurationMap">
       <map>

conf/app.conf

 appname = 血透
-httpport = 9529
+httpport = 9531
 runmode =dev
 #dev/prod
 

controllers/mobile_api_controllers/dialysis_api_controller.go

 	template, _ := service.GetOrgInfoTemplate(adminUserInfo.Org.Id)
 
 	//查询更改的机号，是否有人用了,如果只是排班了，但是没上机，直接替换，如果排班且上机了，就提示他无法上机
+	//sch, _ := service.GetSourceSch(adminUserInfo.Org.Id, patientID, scheduleendTime)
 
 	schedule, err := service.GetDayScheduleByBedid(adminUserInfo.Org.Id, schedulestartTime, bedID, schedual_type)
 
 	//查询该床位是否有人用了
-	order, order_err := service.GetDialysisOrderByBedId(adminUserInfo.Org.Id, schedulestartTime, bedID, schedual_type)
+	order, _ := service.GetDialysisOrderByBedIdTwo(adminUserInfo.Org.Id, schedulestartTime, bedID, schedual_type)
 
 	if err == gorm.ErrRecordNotFound { //空床位
 		// 修改了床位逻辑
 	} else if err == nil {
 		if schedule.ID > 0 && schedule.DialysisOrder.ID == 0 { //有排班没上机记录
 
-			if order_err == nil {
-				if order.ID > 0 { //该机位被其他人占用了
-					this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderRepeatBed)
-					return
-
-				} else {
-					daySchedule, _ := service.GetDaySchedule(adminUserInfo.Org.Id, schedulestartTime, scheduleendTime, patientID)
-					if daySchedule.ID > 0 {
-						//daySchedule.PartitionId = deviceNumber.ZoneID
-						//daySchedule.BedId = bedID
-						//daySchedule.ScheduleType = schedual_type
-						//daySchedule.UpdatedTime = time.Now().Unix()
-						//err := service.UpdateSchedule(&daySchedule)
-						xtSchedule := models.Schedule{
-							PartitionId:  deviceNumber.ZoneID,
-							BedId:        bedID,
-							ScheduleType: schedual_type,
-							UpdatedTime:  time.Now().Unix(),
-						}
-						err := service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
-						if err != nil {
-							this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-							return
-						}
-					}
-				}
-			} else if order_err == gorm.ErrRecordNotFound { //该床位没被占用
+			if order.ID > 0 { //该机位被其他人占用了
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderRepeatBed)
+				return
+			} else { //2022-11-04 更变需求，如果改床位有排班，但是没上机，则进行互换床位操作
 				daySchedule, _ := service.GetDaySchedule(adminUserInfo.Org.Id, schedulestartTime, scheduleendTime, patientID)
 				if daySchedule.ID > 0 {
 					//daySchedule.PartitionId = deviceNumber.ZoneID
 					//daySchedule.ScheduleType = schedual_type
 					//daySchedule.UpdatedTime = time.Now().Unix()
 					//err := service.UpdateSchedule(&daySchedule)
-					xtSchedule := models.Schedule{
-						PartitionId:  deviceNumber.ZoneID,
-						BedId:        bedID,
-						ScheduleType: schedual_type,
-						UpdatedTime:  time.Now().Unix(),
-					}
-					err := service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
-					if err != nil {
-						this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-						return
-					}
+					//xtSchedule := models.Schedule{
+					//	PartitionId:  deviceNumber.ZoneID,
+					//	BedId:        bedID,
+					//	ScheduleType: schedual_type,
+					//	UpdatedTime:  time.Now().Unix(),
+					//}
+					//err := service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
+					service.UpdateScheduleTwo(daySchedule, schedule)
+
 				}
 			}
 		} else if schedule.ID > 0 && schedule.DialysisOrder.ID > 0 { //有排班且有上机记录
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderRepeatBed)
 			return
 		}
+		//else if order.ID == 0 { //该床位没被占用
+		//	daySchedule, _ := service.GetDaySchedule(adminUserInfo.Org.Id, schedulestartTime, scheduleendTime, patientID)
+		//	if daySchedule.ID > 0 {
+		//		//daySchedule.PartitionId = deviceNumber.ZoneID
+		//		//daySchedule.BedId = bedID
+		//		//daySchedule.ScheduleType = schedual_type
+		//		//daySchedule.UpdatedTime = time.Now().Unix()
+		//		//err := service.UpdateSchedule(&daySchedule)
+		//		xtSchedule := models.Schedule{
+		//			PartitionId:  deviceNumber.ZoneID,
+		//			BedId:        bedID,
+		//			ScheduleType: schedual_type,
+		//			UpdatedTime:  time.Now().Unix(),
+		//		}
+		//		err := service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
+		//		if err != nil {
+		//			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		//			return
+		//		}
+		//	}
+		//}
+		//}
+
 	} else if err != nil {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 		"dialysisOrder": dialysisOrder,
 	})
 }
+
+func (this *DialysisAPIController) CheckSchedule() {
+
+	patientID, _ := this.GetInt64("patient_id")
+	recordDateStr := this.GetString("record_date")
+	nurseID, _ := this.GetInt64("nurse")
+	schedual_type, _ := this.GetInt64("schedual_type")
+
+	bedID, _ := this.GetInt64("bed")
+	start_time := this.GetString("start_time")
+
+	if patientID <= 0 || len(recordDateStr) == 0 || nurseID <= 0 || bedID <= 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	startDate, parseStartDateErr := utils.ParseTimeStringToTime("2006-01-02 15:04:05", start_time)
+	if parseStartDateErr != nil {
+		this.ErrorLog("时间解析失败:%v", parseStartDateErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	recordDate, parseErr := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+	if parseErr != nil {
+		this.ErrorLog("时间解析失败:%v", parseErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	patient, getPatientErr := service.MobileGetPatientById(adminUserInfo.Org.Id, patientID)
+	if getPatientErr != nil {
+		this.ErrorLog("获取患者信息失败：%v", getPatientErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if patient == nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
+		return
+	}
+
+	nurse, getNurseErr := service.GetAdminUserByUserID(nurseID)
+	if getNurseErr != nil {
+		this.ErrorLog("获取护士失败:%v", getNurseErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if nurse == nil {
+		this.ErrorLog("护士不存在")
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	deviceNumber, getDeviceNumberErr := service.GetDeviceNumberByID(adminUserInfo.Org.Id, bedID)
+	if getDeviceNumberErr != nil {
+		this.ErrorLog("获取床位号失败:%v", getDeviceNumberErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if deviceNumber == nil {
+		this.ErrorLog("床位号不存在")
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	dialysisRecord, getRecordErr := service.MobileGetDialysisRecord(adminUserInfo.Org.Id, patientID, recordDate.Unix())
+	if getRecordErr != nil {
+		this.ErrorLog("获取透析记录失败:%v", getRecordErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if dialysisRecord != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderRepeatStart)
+		return
+	}
+
+	scheduleDateStart := startDate.Format("2006-01-02") + " 00:00:00"
+	scheduleDateEnd := startDate.Format("2006-01-02") + " 23:59:59"
+	timeLayout := "2006-01-02 15:04:05"
+	loc, _ := time.LoadLocation("Local")
+	theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
+	theEndTime, _ := time.ParseInLocation(timeLayout, scheduleDateEnd, loc)
+	schedulestartTime := theStartTime.Unix()
+	scheduleendTime := theEndTime.Unix()
+
+	//查询更改的机号，是否有人用了,如果只是排班了，但是没上机，直接替换，如果排班且上机了，就提示他无法上机
+	//sch, _ := service.GetSourceSch(adminUserInfo.Org.Id, patientID, scheduleendTime)
+
+	schedule, err := service.GetDayScheduleByBedid(adminUserInfo.Org.Id, schedulestartTime, bedID, schedual_type)
+
+	//查询该床位是否有人用了
+	order, _ := service.GetDialysisOrderByBedIdTwo(adminUserInfo.Org.Id, schedulestartTime, bedID, schedual_type)
+
+	if err == nil {
+		if schedule.ID == 0 {
+			this.ServeSuccessJSON(map[string]interface{}{
+				"status": 0,
+			})
+
+		} else {
+
+			if schedule.ID > 0 && schedule.DialysisOrder.ID == 0 { //有排班没上机记录
+				if order.ID > 0 { //该机位被其他人占用了
+					this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderRepeatBed)
+					return
+				} else { //2022-11-04 更变需求，如果改床位有排班，但是没上机，则进行互换床位操作,如果改床位是本人的话，不做处理
+					daySchedule, _ := service.GetDaySchedule(adminUserInfo.Org.Id, schedulestartTime, scheduleendTime, patientID)
+					if daySchedule.ID > 0 && schedule.PatientId != daySchedule.PatientId {
+
+						this.ServeSuccessJSON(map[string]interface{}{
+							"status": 1,
+							"msg":    "该机位已有排班，继续操作将会与原来的排班信息进行互调，请问是否继续?",
+						})
+						return
+					} else {
+						this.ServeSuccessJSON(map[string]interface{}{
+							"status": 0,
+						})
+					}
+				}
+			} else if schedule.ID > 0 && schedule.DialysisOrder.ID > 0 {
+				this.ServeSuccessJSON(map[string]interface{}{
+					"status": 2,
+					"msg":    "当前机位已有患者在使用，请重新选择！",
+				})
+
+			}
+
+		}
+
+	} else {
+		this.ServeSuccessJSON(map[string]interface{}{
+			"status": 0,
+		})
+
+	}
+
+}

controllers/mobile_api_controllers/mobile_api_router_register.go

 	beego.Router("/m/api/savepatientsign", &DialysisAPIController{}, "Post:SavePatientSign")
 	beego.Router("/m/api/getpatientsign", &DialysisAPIController{}, "Get:GetPatientSign")
 
+	beego.Router("/m/api/checksch/get", &DialysisAPIController{}, "Get:CheckSchedule")
+
 }

controllers/schedule_api_controller.go

 	beego.Router("/api/schedule/synchroschedule", &ScheduleApiController{}, "Get:SynchroSchedule")
 	beego.Router("/api/schedule/getpatientscheduletemplate", &ScheduleApiController{}, "Get:GetPatientScheduleTempalate")
 	beego.Router("/api/schedule/getsolutionschedule", &ScheduleApiController{}, "Get:GetSolutionSchedule")
+
+	beego.Router("/api/schedule/smartpatientsch", &ScheduleApiController{}, "Get:GetPatientSch")
+	beego.Router("/api/schedule/smartpatientschtemplate", &ScheduleApiController{}, "Get:GetPatientSchTemplate")
+
+	beego.Router("/api/patient/smartpatientsch", &ScheduleApiController{}, "Get:GetPatientSmartSch")
+
+	beego.Router("/api/patient/smartpatientschtemplate", &ScheduleApiController{}, "Get:GetPatientSmartSchTemplate")
+
+	beego.Router("/api/device/get", &ScheduleApiController{}, "Get:GetDevicesNumbers")
+
+	beego.Router("/api/smartsch/batch", &ScheduleApiController{}, "Post:BatchPostSmartSch")
+
+}
+func (c *ScheduleApiController) BatchPostSmartSch() {
+	patient_id, _ := c.GetInt64("patient_id")
+	adminInfo := c.GetAdminUserInfo()
+
+	patientInfo, _ := service.FindPatientById(adminInfo.CurrentOrgId, patient_id)
+	if patientInfo.ID == 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
+		return
+	}
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	//数据校验
+	if dataBody["smart_schs"] != nil && reflect.TypeOf(dataBody["smart_schs"]).String() == "[]interface {}" {
+
+		schs, _ := dataBody["smart_schs"].([]interface{})
+		if len(schs) > 0 {
+			for _, item := range schs {
+				items := item.(map[string]interface{})
+				if items["sch_id"] == nil || reflect.TypeOf(items["sch_id"]).String() != "float64" {
+					utils.ErrorLog("id")
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+					return
+				}
+				var schedule models.Schedule
+				//var oldSchedule *models.Schedule
+				sch_id := int64(items["sch_id"].(float64))
+				if sch_id > 0 { //修改排班信息
+					schedule, _ = service.GetScheduleTwo(adminInfo.CurrentOrgId, sch_id)
+
+					if items["mode_id"] == nil || reflect.TypeOf(items["mode_id"]).String() != "float64" {
+						utils.ErrorLog("mode_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					modeId := int64(items["mode_id"].(float64))
+					if modeId < 1 {
+						utils.ErrorLog("modeId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ModeId = modeId
+
+					order, err := service.GetOneDialysisOrder(adminInfo.CurrentOrgId, schedule.ScheduleDate, schedule.PatientId)
+					if err != nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+						return
+					}
+
+					if order != nil {
+						week_type, _ := items["week_type"].(string)
+						week_name, _ := items["week_name"].(string)
+
+						switch week_type {
+						case "1":
+							json := make(map[string]interface{})
+							json["msg"] = "本周" + week_name + "的床位已经有人上机,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "2":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "的床位已经有人上机,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "3":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "的床位已经有人上机,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+
+						}
+
+						return
+					}
+
+					if order != nil {
+						week_type, _ := items["week_type"].(string)
+						week_name, _ := items["week_name"].(string)
+
+						switch week_type {
+						case "1":
+							json := make(map[string]interface{})
+							json["msg"] = "本周" + week_name + "的床位已经有人上机,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "2":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "的床位已经有人上机,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "3":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "的床位已经有人上机,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						}
+						return
+					}
+
+					if items["schedule_type"] == nil || reflect.TypeOf(items["schedule_type"]).String() != "float64" {
+						utils.ErrorLog("schedule_type")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					scheduleType := int64(items["schedule_type"].(float64))
+					if scheduleType < 1 || scheduleType > 3 {
+						utils.ErrorLog("scheduleType < 3")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ScheduleType = scheduleType
+
+					if items["bed_id"] == nil || reflect.TypeOf(items["bed_id"]).String() != "float64" {
+						utils.ErrorLog("bed_id")
+						fmt.Println("~~~~~~333333333")
+
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					bedId := int64(items["bed_id"].(float64))
+					if bedId < 1 {
+						utils.ErrorLog("bedId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.BedId = bedId
+
+					if items["zone_id"] == nil || reflect.TypeOf(items["zone_id"]).String() != "float64" {
+						utils.ErrorLog("zone_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					partitionId := int64(items["zone_id"].(float64))
+					if partitionId < 1 {
+						utils.ErrorLog("partitionId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.PartitionId = partitionId
+
+					bed, _ := service.GetDeviceNumberByID(adminInfo.CurrentOrgId, schedule.BedId)
+					if bed == nil {
+
+						week_type, _ := items["week_type"].(string)
+						week_name, _ := items["week_name"].(string)
+
+						switch week_type {
+						case "1":
+							json := make(map[string]interface{})
+							json["msg"] = "本周" + week_name + "的机号不存在,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "2":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "的机号不存在,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "3":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "的机号不存在,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						}
+
+						return
+					}
+					if bed.ZoneID != schedule.PartitionId {
+
+						week_type, _ := items["week_type"].(string)
+						week_name, _ := items["week_name"].(string)
+
+						switch week_type {
+						case "1":
+							json := make(map[string]interface{})
+							json["msg"] = "本周" + week_name + "所选机号不在选择分区中,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "2":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "所选机号不在选择分区中,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "3":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "所选机号不在选择分区中,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						}
+
+						return
+					}
+
+					startTime := schedule.ScheduleDate
+					endTime := startTime + 86399
+
+					//一天只有排班一次
+					daySchedule, err := service.GetDaySchedule(adminInfo.CurrentOrgId, startTime, endTime, schedule.PatientId)
+					if daySchedule.ID > 0 && daySchedule.ID != schedule.ID {
+						week_type, _ := items["week_type"].(string)
+						week_name, _ := items["week_name"].(string)
+
+						switch week_type {
+						case "1":
+							json := make(map[string]interface{})
+							json["msg"] = "本周" + week_name + "已有排班，同一天不可有两次排班,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "2":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "已有排班，同一天不可有两次排班,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "3":
+							json := make(map[string]interface{})
+							json["msg"] = "下下周" + week_name + "已有排班，同一天不可有两次排班,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						}
+
+						return
+					}
+
+					//同天同位置只能排一个
+					pointSchedule, err := service.GetPointSchedule(adminInfo.CurrentOrgId, schedule.ScheduleDate, schedule.ScheduleWeek, schedule.ScheduleType, schedule.BedId)
+					if err != nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+						return
+					}
+					if pointSchedule.ID > 0 && pointSchedule.PatientId != patient_id {
+						week_type, _ := items["week_type"].(string)
+						week_name, _ := items["week_name"].(string)
+
+						switch week_type {
+						case "1":
+							json := make(map[string]interface{})
+							json["msg"] = "本周" + week_name + "所先位置排班已经存在,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "2":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "所先位置排班已经存在,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "3":
+							json := make(map[string]interface{})
+							json["msg"] = "下下周" + week_name + "所先位置排班已经存在,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						}
+
+						return
+					}
+
+				} else { //新的排班信息
+
+					if items["schedule_date"] == nil || reflect.TypeOf(items["schedule_date"]).String() != "string" {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					scheduleDate, _ := items["schedule_date"].(string)
+					if len(scheduleDate) == 0 {
+						utils.ErrorLog("len(schedule_date) == 0")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					timeLayout := "2006-01-02"
+					loc, _ := time.LoadLocation("Local")
+					theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", scheduleDate+" 00:00:00", loc)
+					if err != nil {
+						utils.ErrorLog(err.Error())
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ScheduleDate = theTime.Unix()
+					timeNow := time.Now().Format("2006-01-02")
+					if timeNow > scheduleDate {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCantSetScheduleBeforeNow)
+						return
+					}
+					scheduleType := int64(items["schedule_type"].(float64))
+					if scheduleType < 1 || scheduleType > 3 {
+						utils.ErrorLog("scheduleType < 3")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ScheduleType = scheduleType
+
+					if items["bed_id"] == nil || reflect.TypeOf(items["bed_id"]).String() != "float64" {
+						fmt.Println("~~~~~~22222")
+						utils.ErrorLog("bed_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					bedId := int64(items["bed_id"].(float64))
+					if bedId < 1 {
+						utils.ErrorLog("bedId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.BedId = bedId
+
+					if items["zone_id"] == nil || reflect.TypeOf(items["zone_id"]).String() != "float64" {
+						utils.ErrorLog("zone_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					partitionId := int64(items["zone_id"].(float64))
+					if partitionId < 1 {
+						utils.ErrorLog("zone_id < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.PartitionId = partitionId
+
+					if items["schedule_week"] == nil || reflect.TypeOf(items["schedule_week"]).String() != "float64" {
+						utils.ErrorLog("schedule_week")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					scheduleWeek := int64(items["schedule_week"].(float64))
+					if scheduleWeek < 1 || scheduleWeek > 7 {
+						utils.ErrorLog("scheduleWeek < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ScheduleWeek = scheduleWeek
+
+					if items["mode_id"] == nil || reflect.TypeOf(items["mode_id"]).String() != "float64" {
+						utils.ErrorLog("mode_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					modeId := int64(items["mode_id"].(float64))
+					if modeId < 1 && modeId > 14 {
+						utils.ErrorLog("modeId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					//校验当天改床位是否有排班，如果有排班则不能替换排班
+
+					sch, _ := service.GetScheduleByZoneAndBed(adminInfo.CurrentOrgId, partitionId, bedId, schedule.ScheduleDate, schedule.ScheduleType)
+
+					if sch.ID > 0 {
+						week_type, _ := items["week_type"].(string)
+						week_name, _ := items["week_name"].(string)
+
+						switch week_type {
+						case "1":
+							json := make(map[string]interface{})
+							json["msg"] = "本周" + week_name + "该床位已经有人排班,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "2":
+							json := make(map[string]interface{})
+							json["msg"] = "下周" + week_name + "该床位已经有人排班,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						case "3":
+							json := make(map[string]interface{})
+							json["msg"] = "下下周" + week_name + "该床位已经有人排班,无法保存"
+							json["state"] = 0
+							c.Data["json"] = json
+							c.ServeJSON()
+							break
+						}
+
+						return
+					}
+
+				}
+
+			}
+		}
+	}
+
+	if dataBody["smart_schs"] != nil && reflect.TypeOf(dataBody["smart_schs"]).String() == "[]interface {}" {
+
+		schs, _ := dataBody["smart_schs"].([]interface{})
+		if len(schs) > 0 {
+			for _, item := range schs {
+				items := item.(map[string]interface{})
+				if items["sch_id"] == nil || reflect.TypeOf(items["sch_id"]).String() != "float64" {
+					utils.ErrorLog("id")
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+					return
+				}
+				var schedule models.Schedule
+				//var oldSchedule *models.Schedule
+				sch_id := int64(items["sch_id"].(float64))
+				if sch_id > 0 { //修改排班信息
+					fmt.Println("!!!!!!!")
+					schedule, _ = service.GetScheduleTwo(adminInfo.CurrentOrgId, sch_id)
+					if items["mode_id"] == nil || reflect.TypeOf(items["mode_id"]).String() != "float64" {
+						fmt.Println(reflect.TypeOf(items["mode_id"]))
+
+						utils.ErrorLog("mode_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					modeId := int64(items["mode_id"].(float64))
+					if modeId < 1 {
+						utils.ErrorLog("modeId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ModeId = modeId
+
+					order, err := service.GetOneDialysisOrder(adminInfo.CurrentOrgId, schedule.ScheduleDate, schedule.PatientId)
+					if err != nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+						return
+					}
+
+					if order != nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeChangeMode)
+						return
+					}
+
+					if order != nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeChangeDeviceNumber)
+						return
+					}
+
+					if items["schedule_type"] == nil || reflect.TypeOf(items["schedule_type"]).String() != "float64" {
+						utils.ErrorLog("schedule_type")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					scheduleType := int64(items["schedule_type"].(float64))
+					if scheduleType < 1 || scheduleType > 3 {
+						utils.ErrorLog("scheduleType < 3")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ScheduleType = scheduleType
+
+					if items["bed_id"] == nil || reflect.TypeOf(items["bed_id"]).String() != "float64" {
+						utils.ErrorLog("bed_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					bedId := int64(items["bed_id"].(float64))
+					if bedId < 1 {
+						utils.ErrorLog("bedId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.BedId = bedId
+
+					if items["zone_id"] == nil || reflect.TypeOf(items["zone_id"]).String() != "float64" {
+						utils.ErrorLog("zone_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					partitionId := int64(items["zone_id"].(float64))
+					if partitionId < 1 {
+						utils.ErrorLog("partitionId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.PartitionId = partitionId
+
+					bed, _ := service.GetDeviceNumberByID(adminInfo.CurrentOrgId, schedule.BedId)
+					if bed == nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDeviceNumberNotExist)
+						return
+					}
+					if bed.ZoneID != schedule.PartitionId {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDeviceNumberNotTheZone)
+						return
+					}
+
+					startTime := schedule.ScheduleDate
+					endTime := startTime + 86399
+
+					//一天只有排班一次
+					daySchedule, err := service.GetDaySchedule(adminInfo.CurrentOrgId, startTime, endTime, schedule.PatientId)
+					if daySchedule.ID > 0 && daySchedule.ID != schedule.ID {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCantSetScheduleAgainOneDay)
+						return
+					}
+
+					//同天同位置只能排一个
+					pointSchedule, err := service.GetPointSchedule(adminInfo.CurrentOrgId, schedule.ScheduleDate, schedule.ScheduleWeek, schedule.ScheduleType, schedule.BedId)
+					if err != nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+						return
+					}
+					if pointSchedule.ID > 0 && pointSchedule.PatientId != patient_id {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePointScheduleExist)
+						return
+					}
+
+					so, _ := service.GetDialysisSolutionTwo(adminInfo.CurrentOrgId, schedule.PatientId, schedule.ModeId)
+					filedRecordOne, _ := service.FindFiledBy(adminInfo.CurrentOrgId, "透析器")
+					filedRecordTwo, _ := service.FindFiledBy(adminInfo.CurrentOrgId, "灌流器")
+					filedRecordThree, _ := service.FindFiledBy(adminInfo.CurrentOrgId, "透析器/灌流器")
+
+					if filedRecordOne.IsShow == 1 {
+						schedule.DialysisMachineName = so.DialysisDialyszers
+						//service.UpdateSchDName(schedule)
+					}
+					if filedRecordTwo.IsShow == 1 {
+						schedule.DialysisMachineName = so.DialysisIrrigation
+						//service.UpdateSchDName(schedule)
+					}
+
+					if filedRecordThree.IsShow == 1 {
+						schedule.DialysisMachineName = so.DialyzerPerfusionApparatus
+						//service.UpdateSchDName(schedule)
+					}
+
+					service.SaveSch(schedule)
+
+				} else { //新的排班信息
+					if items["schedule_date"] == nil || reflect.TypeOf(items["schedule_date"]).String() != "string" {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					scheduleDate, _ := items["schedule_date"].(string)
+					if len(scheduleDate) == 0 {
+						utils.ErrorLog("len(schedule_date) == 0")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					timeLayout := "2006-01-02"
+					loc, _ := time.LoadLocation("Local")
+					theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", scheduleDate+" 00:00:00", loc)
+					if err != nil {
+						utils.ErrorLog(err.Error())
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ScheduleDate = theTime.Unix()
+					timeNow := time.Now().Format("2006-01-02")
+					if timeNow > scheduleDate {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCantSetScheduleBeforeNow)
+						return
+					}
+					scheduleType := int64(items["schedule_type"].(float64))
+					if scheduleType < 1 || scheduleType > 3 {
+						utils.ErrorLog("scheduleType < 3")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ScheduleType = scheduleType
+
+					if items["bed_id"] == nil || reflect.TypeOf(items["bed_id"]).String() != "float64" {
+						utils.ErrorLog("bed_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					bedId := int64(items["bed_id"].(float64))
+					if bedId < 1 {
+						utils.ErrorLog("bedId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.BedId = bedId
+
+					if items["zone_id"] == nil || reflect.TypeOf(items["zone_id"]).String() != "float64" {
+						utils.ErrorLog("zone_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					partitionId := int64(items["zone_id"].(float64))
+					if partitionId < 1 {
+						utils.ErrorLog("zone_id < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.PartitionId = partitionId
+
+					if items["schedule_week"] == nil || reflect.TypeOf(items["schedule_week"]).String() != "float64" {
+						utils.ErrorLog("schedule_week")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					scheduleWeek := int64(items["schedule_week"].(float64))
+					if scheduleWeek < 1 || scheduleWeek > 7 {
+						utils.ErrorLog("scheduleWeek < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					schedule.ScheduleWeek = scheduleWeek
+
+					if items["mode_id"] == nil || reflect.TypeOf(items["mode_id"]).String() != "float64" {
+						fmt.Println(reflect.TypeOf(items["mode_id"]))
+
+						utils.ErrorLog("mode_id")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					modeId := int64(items["mode_id"].(float64))
+					if modeId < 1 && modeId > 14 {
+						utils.ErrorLog("modeId < 1")
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+						return
+					}
+					//校验当天改床位是否有排班，如果有排班则不能替换排班
+
+					sch, _ := service.GetScheduleByZoneAndBed(adminInfo.CurrentOrgId, partitionId, bedId, schedule.ScheduleDate, schedule.ScheduleType)
+
+					if sch.ID > 0 {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorSchedualcRepeatBed)
+						return
+					}
+
+					schedule.ModeId = modeId
+					schedule.PatientId = patient_id
+					schedule.CreatedTime = time.Now().Unix()
+					schedule.UpdatedTime = time.Now().Unix()
+					schedule.Status = 1
+					schedule.UserOrgId = adminInfo.CurrentOrgId
+
+					so, _ := service.GetDialysisSolutionTwo(adminInfo.CurrentOrgId, schedule.PatientId, schedule.ModeId)
+					filedRecordOne, _ := service.FindFiledBy(adminInfo.CurrentOrgId, "透析器")
+					filedRecordTwo, _ := service.FindFiledBy(adminInfo.CurrentOrgId, "灌流器")
+					filedRecordThree, _ := service.FindFiledBy(adminInfo.CurrentOrgId, "透析器/灌流器")
+
+					if filedRecordOne.IsShow == 1 {
+						schedule.DialysisMachineName = so.DialysisDialyszers
+						//service.UpdateSchDName(schedule)
+					}
+					if filedRecordTwo.IsShow == 1 {
+						schedule.DialysisMachineName = so.DialysisIrrigation
+						//service.UpdateSchDName(schedule)
+					}
+
+					if filedRecordThree.IsShow == 1 {
+						schedule.DialysisMachineName = so.DialyzerPerfusionApparatus
+						//service.UpdateSchDName(schedule)
+					}
+
+					service.CreateSchedule(&schedule)
+
+				}
+				c.ServeSuccessJSON(map[string]interface{}{
+					"msg": "保存成功",
+				})
+
+				HandleRedis(adminInfo.CurrentOrgId, schedule.ScheduleDate)
+
+			}
+		}
+	}
+}
+func HandleRedis(org_id int64, sch_date int64) {
+	redis := service.RedisClient()
+	//处方
+	keyOne := strconv.FormatInt(org_id, 10) + ":" + strconv.FormatInt(sch_date, 10) + ":prescriptions_list_all"
+	redis.Set(keyOne, "", time.Second)
+	//医嘱
+	keyTwo := strconv.FormatInt(org_id, 10) + ":" + strconv.FormatInt(sch_date, 10) + ":advice_list_all"
+	redis.Set(keyTwo, "", time.Second)
+	keySix := strconv.FormatInt(org_id, 10) + ":" + strconv.FormatInt(sch_date, 10) + ":assessment_befores_list_all"
+	redis.Set(keySix, "", time.Second)
+	keyThree := strconv.FormatInt(org_id, 10) + ":" + strconv.FormatInt(sch_date, 10) + ":assessment_after_dislysis_list_all"
+	redis.Set(keyThree, "", time.Second)
+	keyFour := strconv.FormatInt(org_id, 10) + ":" + strconv.FormatInt(sch_date, 10) + ":monitor_record_list_all"
+	redis.Set(keyFour, "", time.Second)
+	keyFive := strconv.FormatInt(org_id, 10) + ":" + strconv.FormatInt(sch_date, 10) + ":treatment_summarys_list_all"
+	redis.Set(keyFive, "", time.Second)
+	keySeven := strconv.FormatInt(org_id, 10) + ":" + strconv.FormatInt(sch_date, 10) + ":dialysis_orders_list_all"
+	redis.Set(keySeven, "", time.Second)
+	defer redis.Close()
+
+}
+
+func (c *ScheduleApiController) GetPatientSch() {
+	keyWord := c.GetString("keyword")
+	adminUserInfo := c.GetAdminUserInfo()
+	patient, err := service.GetSmartSchPatientByKeyWord(adminUserInfo.CurrentOrgId, keyWord)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+	})
+}
+
+func (c *ScheduleApiController) GetPatientSchTemplate() {
+	keyWord := c.GetString("keyword")
+	adminUserInfo := c.GetAdminUserInfo()
+	patient, err := service.GetSmartSchTemplatePatientByKeyWord(adminUserInfo.CurrentOrgId, keyWord)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+	})
+}
+
+func (c *ScheduleApiController) GetPatientSmartSch() {
+	patient_id, _ := c.GetInt64("patient_id", 0)
+	adminUserInfo := c.GetAdminUserInfo()
+	schs, err := service.GetSmartSchPatientByID(adminUserInfo.CurrentOrgId, patient_id)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"schedules": schs,
+	})
+}
+func (c *ScheduleApiController) GetPatientSmartSchTemplate() {
+	patient_id, _ := c.GetInt64("patient_id", 0)
+	adminUserInfo := c.GetAdminUserInfo()
+	mode, _ := service.GetOrgPatientScheduleTemplateModeTwo(adminUserInfo.CurrentOrgId)
+	if mode.ID > 0 {
+		if mode.Mode == 0 {
+			//schs, _ := service.GetSmartSchTemplatePatientByID(adminUserInfo.CurrentOrgId, patient_id)
+			c.ServeSuccessJSON(map[string]interface{}{
+				"status": 0,
+			})
+
+		} else if mode.Mode == 1 {
+			schs, _ := service.GetSmartSchTemplatePatientByID(adminUserInfo.CurrentOrgId, patient_id, 1)
+			c.ServeSuccessJSON(map[string]interface{}{
+				"status":             0,
+				"schedules_template": schs,
+			})
+
+		} else if mode.Mode == 2 {
+			schs, _ := service.GetSmartSchTemplatePatientByID(adminUserInfo.CurrentOrgId, patient_id, 2)
+			c.ServeSuccessJSON(map[string]interface{}{
+				"status":             1,
+				"schedules_template": schs,
+			})
+
+		} else if mode.Mode == 3 {
+
+			schs, _ := service.GetSmartSchTemplatePatientByID(adminUserInfo.CurrentOrgId, patient_id, 3)
+			c.ServeSuccessJSON(map[string]interface{}{
+				"status":             1,
+				"schedules_template": schs,
+			})
+		} else if mode.Mode == 4 {
+
+			schs, _ := service.GetSmartSchTemplatePatientByID(adminUserInfo.CurrentOrgId, patient_id, 4)
+			c.ServeSuccessJSON(map[string]interface{}{
+				"status":             1,
+				"schedules_template": schs,
+			})
+		}
+
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"status": 0,
+		})
+
+	}
+}
+
+func (c *ScheduleApiController) GetDevicesNumbers() {
+	sch_type, _ := c.GetInt("sch_type", 0)
+	zone_id, _ := c.GetInt64("zone_id", 0)
+	patient_id, _ := c.GetInt64("patient_id", 0)
+
+	schedule_date := c.GetString("schedule_date")
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", schedule_date+" 00:00:00", loc)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	recordDateTime := theTime.Unix()
+
+	deviceNumbers, getDeviceNumbersErr := service.GetAllAvaildDeviceNumbersByZone(c.GetAdminUserInfo().CurrentOrgId, recordDateTime, sch_type, zone_id, patient_id)
+	if getDeviceNumbersErr != nil {
+		c.ErrorLog("获取所有床位失败：%v", getDeviceNumbersErr)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"devices": deviceNumbers,
+	})
+
 }
 
 func (c *ScheduleApiController) GetWeekPanels() {
 	schedule.Status = 1
 	schedule.UserOrgId = adminUserInfo.CurrentOrgId
 
+	so, _ := service.GetDialysisSolutionTwo(adminUserInfo.CurrentOrgId, schedule.PatientId, schedule.ModeId)
+	filedRecordOne, _ := service.FindFiledBy(adminUserInfo.CurrentOrgId, "透析器")
+	filedRecordTwo, _ := service.FindFiledBy(adminUserInfo.CurrentOrgId, "灌流器")
+	filedRecordThree, _ := service.FindFiledBy(adminUserInfo.CurrentOrgId, "透析器/灌流器")
+
+	if filedRecordOne.IsShow == 1 {
+		schedule.DialysisMachineName = so.DialysisDialyszers
+		//service.UpdateSchDName(schedule)
+	}
+	if filedRecordTwo.IsShow == 1 {
+		schedule.DialysisMachineName = so.DialysisIrrigation
+		//service.UpdateSchDName(schedule)
+	}
+
+	if filedRecordThree.IsShow == 1 {
+		schedule.DialysisMachineName = so.DialyzerPerfusionApparatus
+		//service.UpdateSchDName(schedule)
+	}
 	bed, _ := service.GetDeviceNumberByID(adminUserInfo.CurrentOrgId, schedule.BedId)
 	if bed == nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDeviceNumberNotExist)
 	adminINfo := c.GetAdminUserInfo()
 
 	schedule, _ := service.GetSchedule(adminINfo.CurrentOrgId, id)
+	timeNow := time.Now().Format("2006-01-02")
+	timeTemplate := "2006-01-02"
+
+	tm := time.Unix(int64(schedule.ScheduleDate), 0)
+	timeStr := tm.Format(timeTemplate)
+	if timeNow > timeStr {
+		utils.ErrorLog(timeNow)
+		utils.ErrorLog(timeStr)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCantSetScheduleBeforeNow)
+		return
+	}
 	if schedule == nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeScheduleNotExist)
 		return
 		}
 		schedule.ModeId = modeId
 
+		so, _ := service.GetDialysisSolutionTwo(adminINfo.CurrentOrgId, schedule.PatientId, schedule.ModeId)
+		filedRecordOne, _ := service.FindFiledBy(adminINfo.CurrentOrgId, "透析器")
+		filedRecordTwo, _ := service.FindFiledBy(adminINfo.CurrentOrgId, "灌流器")
+		filedRecordThree, _ := service.FindFiledBy(adminINfo.CurrentOrgId, "透析器/灌流器")
+
+		if filedRecordOne.IsShow == 1 {
+			schedule.DialysisMachineName = so.DialysisDialyszers
+			//service.UpdateSchDName(schedule)
+		}
+		if filedRecordTwo.IsShow == 1 {
+			schedule.DialysisMachineName = so.DialysisIrrigation
+			//service.UpdateSchDName(schedule)
+		}
+
+		if filedRecordThree.IsShow == 1 {
+			schedule.DialysisMachineName = so.DialyzerPerfusionApparatus
+			//service.UpdateSchDName(schedule)
+		}
+
 		order, err := service.GetOneDialysisOrder(adminINfo.CurrentOrgId, schedule.ScheduleDate, schedule.PatientId)
 		if err != nil {
 			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		}
 
 	} else if changeAction == "change_device" {
-
 		order, err := service.GetOneDialysisOrder(adminINfo.CurrentOrgId, schedule.ScheduleDate, schedule.PatientId)
 		if err != nil {
 			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 			sch.Status = 1
 			sch.UserOrgId = this.GetAdminUserInfo().CurrentOrgId
 			sch.IsExport = 1
+			so, _ := service.GetDialysisSolutionTwo(sch.UserOrgId, sch.PatientId, sch.ModeId)
+			filedRecordOne, _ := service.FindFiledBy(sch.UserOrgId, "透析器")
+			filedRecordTwo, _ := service.FindFiledBy(sch.UserOrgId, "灌流器")
+			filedRecordThree, _ := service.FindFiledBy(sch.UserOrgId, "透析器/灌流器")
+
+			if filedRecordOne.IsShow == 1 {
+				sch.DialysisMachineName = so.DialysisDialyszers
+				//service.UpdateSchDName(schedule)
+			}
+			if filedRecordTwo.IsShow == 1 {
+				sch.DialysisMachineName = so.DialysisIrrigation
+				//service.UpdateSchDName(schedule)
+			}
+
+			if filedRecordThree.IsShow == 1 {
+				sch.DialysisMachineName = so.DialyzerPerfusionApparatus
+				//service.UpdateSchDName(schedule)
+			}
 			schedules = append(schedules, &sch)
 		}
 

controllers/schedule_template_api_controller.go

 	"XT_New/enums"
 	"XT_New/models"
 	"XT_New/service"
-	"XT_New/utils"
 	"encoding/json"
 	"fmt"
 	"time"
 	beego.Router("/api/schtemp/p/setmode", &PatientScheduleTemplateAPIController{}, "post:SetMode")
 	beego.Router("/api/schtemp/p/update_sch", &PatientScheduleTemplateAPIController{}, "post:UpdateSchedules")
 
+	beego.Router("/api/patients/list", &PatientScheduleTemplateAPIController{}, "get:GetPatientList")
+
 	// beego.Router("/api/test", &TestCtr{}, "get:Test")
 }
 
 		return
 	}
 	if len(templates) == 0 {
-		firstTemp, secondTemp, createTempErr := service.CreateTwoPatientScheduleTemplates(adminUserInfo.CurrentOrgId)
+		firstTemp, secondTemp, thirdTemp, fourTemp, createTempErr := service.CreateTwoPatientScheduleTemplates(adminUserInfo.CurrentOrgId)
 		if createTempErr != nil {
-			this.ErrorLog("创建两个排班模板失败：%v", createTempErr)
+			this.ErrorLog("创建4个排班模板失败：%v", createTempErr)
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 			return
 		}
-		templates = append(templates, firstTemp, secondTemp)
+		templates = append(templates, firstTemp, secondTemp, thirdTemp, fourTemp)
 
 	} else if len(templates) == 1 {
-		temp, createTempErr := service.CreatePatientScheduleTemplate(adminUserInfo.CurrentOrgId)
+		temp, thirdTemp, fourTemp, createTempErr := service.CreatePatientScheduleTemplate(adminUserInfo.CurrentOrgId)
+		if createTempErr != nil {
+			this.ErrorLog("创建3个排班模板失败：%v", createTempErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		templates = append(templates, temp, thirdTemp, fourTemp)
+	} else if len(templates) == 2 {
+		thirdTemp, fourTemp, createTempErr := service.CreatePatientScheduleTemplateTwo(adminUserInfo.CurrentOrgId)
 		if createTempErr != nil {
-			this.ErrorLog("创建两个排班模板失败：%v", createTempErr)
+			this.ErrorLog("创建2个排班模板失败：%v", createTempErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		templates = append(templates, thirdTemp, fourTemp)
+	} else if len(templates) == 3 {
+		temp, createTempErr := service.CreatePatientScheduleTemplateThree(adminUserInfo.CurrentOrgId)
+		if createTempErr != nil {
+			this.ErrorLog("创建1个排班模板失败：%v", createTempErr)
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 			return
 		}
 	}
 
 	// 获取本周的排班
-	monday, sunday := utils.GetMondayAndSundayOfWeekDate(&now)
-	schedules, getScheduleErr := service.GetWeekSchedule(adminUserInfo.CurrentOrgId, monday.Unix(), sunday.Unix())
-	if getScheduleErr != nil {
-		this.ErrorLog("获取本周排班失败：%v", getScheduleErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	//monday, sunday := utils.GetMondayAndSundayOfWeekDate(&now)
+	//schedules, getScheduleErr := service.GetWeekSchedule(adminUserInfo.CurrentOrgId, monday.Unix(), sunday.Unix())
+	//if getScheduleErr != nil {
+	//	this.ErrorLog("获取本周排班失败：%v", getScheduleErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	this.ServeSuccessJSON(map[string]interface{}{
 		"template_mode":  mode,
 		"device_numbers": deviceNumbers,
 		"templates":      templates,
 		"patients":       patients,
-		"schedules":      schedules,
+		//"schedules":      schedules,
 	})
 }
 
 // /api/schtemp/p/setmode [post]
-// @param mode:int 0.不启用模板 1.单周模板 2.双周模板
+// @param mode:int 0.不启用模板 1.单周模板 2.双周模板 3.三周模版   4.四周模版
 func (this *PatientScheduleTemplateAPIController) SetMode() {
 	mode, _ := this.GetInt8("mode")
+	week_time, _ := this.GetInt8("week_time")
+
 	if mode != 1 && mode != 2 && mode != 0 && mode != 3 && mode != 4 {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
+	if mode > 0 {
+		if week_time == 0 {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+	}
 
 	adminUserInfo := this.GetAdminUserInfo()
 
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
+	templateMode.Week = int64(week_time)
 
 	if mode != templateMode.Mode {
-		if templateMode.Mode == 0 { // 0 -> 1 或 0 -> 2 则直接清除下两周的排班
+		if templateMode.Mode == 0 { // 0 -> 1 或 0 -> 2 则直接清除下四周的排班
 			templateMode.Mode = mode
 			templateMode.ExecuteTimes = 0
 			templateMode.ModifyTime = time.Now().Unix()
 				return
 			}
 
-		} else if templateMode.Mode == 2 && mode == 1 { // 2 -> 1 清除第二周模板item，清除第二周排班，将第一周的排班重复到第二周
+		} else if templateMode.Mode == 1 && mode == 3 {
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SaveTemplateMode(templateMode)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（1 -> 3）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+		} else if templateMode.Mode == 1 && mode == 4 {
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SaveTemplateMode(templateMode)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（1 -> 4）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+		} else if templateMode.Mode == 2 && mode == 1 { // 2 -> 1 清除第二周模板item，清除第二周排班
 			templateIDs, getTemplateIDsErr := service.GetOrgPatientScheduleTemplateIDs(adminUserInfo.CurrentOrgId)
 			if getTemplateIDsErr != nil {
 				this.ErrorLog("获取排班模板失败：%v", getTemplateIDsErr)
 				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 				return
 			}
+		} else if templateMode.Mode == 2 && mode == 3 { // 2 -> 1 清除第二周模板item，清除第二周排班
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SaveTemplateMode(templateMode)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（1 -> 4）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+		} else if templateMode.Mode == 2 && mode == 4 { // 2 -> 1 清除第二周模板item，清除第二周排班
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SaveTemplateMode(templateMode)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（1 -> 4）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+		} else if templateMode.Mode == 3 && mode == 1 { // 3 -> 1 清除第三，二周模板item，清除第三，二周排班
+			templateIDs, getTemplateIDsErr := service.GetOrgPatientScheduleTemplateIDs(adminUserInfo.CurrentOrgId)
+			if getTemplateIDsErr != nil {
+				this.ErrorLog("获取排班模板失败：%v", getTemplateIDsErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SavePatientScheduleTemplateMode3To1(templateMode, templateIDs[1].ID, templateIDs[2].ID)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（1 -> 3）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+		} else if templateMode.Mode == 3 && mode == 2 { // 3 -> 1 清除第三周模板item，清除第三周排班，将第一周的排班重复到第二周
+			templateIDs, getTemplateIDsErr := service.GetOrgPatientScheduleTemplateIDs(adminUserInfo.CurrentOrgId)
+			if getTemplateIDsErr != nil {
+				this.ErrorLog("获取排班模板失败：%v", getTemplateIDsErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SavePatientScheduleTemplateMode3To2(templateMode, templateIDs[2].ID)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（2 -> 3）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+		} else if templateMode.Mode == 3 && mode == 4 { // 2 -> 1 清除第二周模板item，清除第二周排班
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SaveTemplateMode(templateMode)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（1 -> 4）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+		} else if templateMode.Mode == 4 && mode == 1 { // 4 -> 1 清除第三周模板item，清除第三周排班，将第一周的排班重复到第二周
+			templateIDs, getTemplateIDsErr := service.GetOrgPatientScheduleTemplateIDs(adminUserInfo.CurrentOrgId)
+			if getTemplateIDsErr != nil {
+				this.ErrorLog("获取排班模板失败：%v", getTemplateIDsErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SavePatientScheduleTemplateMode4To1(templateMode, templateIDs[1].ID, templateIDs[2].ID, templateIDs[3].ID)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（1 -> 4）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+		} else if templateMode.Mode == 4 && mode == 2 { // 4 -> 2
+			templateIDs, getTemplateIDsErr := service.GetOrgPatientScheduleTemplateIDs(adminUserInfo.CurrentOrgId)
+			if getTemplateIDsErr != nil {
+				this.ErrorLog("获取排班模板失败：%v", getTemplateIDsErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SavePatientScheduleTemplateMode4To2(templateMode, templateIDs[2].ID, templateIDs[3].ID)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（2 -> 4）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+		} else if templateMode.Mode == 4 && mode == 3 { // 4 -> 3
+			templateIDs, getTemplateIDsErr := service.GetOrgPatientScheduleTemplateIDs(adminUserInfo.CurrentOrgId)
+			if getTemplateIDsErr != nil {
+				this.ErrorLog("获取排班模板失败：%v", getTemplateIDsErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			templateMode.Mode = mode
+			templateMode.ExecuteTimes = 0
+			templateMode.ModifyTime = time.Now().Unix()
+			updateErr := service.SavePatientScheduleTemplateMode4To3(templateMode, templateIDs[3].ID)
+			if updateErr != nil {
+				this.ErrorLog("更新排班模板启用方式（3 -> 4）时失败：%v", updateErr)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+		}
+		templates, _ := service.GetOrgPatientScheduleTemplateIDs(adminUserInfo.CurrentOrgId)
+		//处理第几周数问题
+		if mode == 1 {
+			service.UpdateTemplateItemWeek(templates[0].OrgID, templates[0].ID, week_time)
+
+		} else if mode == 2 {
+			service.UpdateTemplateItemWeek(templates[0].OrgID, templates[0].ID, week_time)
+			service.UpdateTemplateItemWeek(templates[1].OrgID, templates[1].ID, week_time+1)
+
+		} else if mode == 3 {
+			service.UpdateTemplateItemWeek(templates[0].OrgID, templates[0].ID, week_time)
+			service.UpdateTemplateItemWeek(templates[1].OrgID, templates[1].ID, week_time+1)
+			service.UpdateTemplateItemWeek(templates[2].OrgID, templates[2].ID, week_time+2)
+
+		} else if mode == 4 {
+			service.UpdateTemplateItemWeek(templates[0].OrgID, templates[0].ID, week_time)
+			service.UpdateTemplateItemWeek(templates[1].OrgID, templates[1].ID, week_time+1)
+			service.UpdateTemplateItemWeek(templates[2].OrgID, templates[2].ID, week_time+2)
+			service.UpdateTemplateItemWeek(templates[3].OrgID, templates[3].ID, week_time+3)
 		}
+
 	}
+
 	this.ServeSuccessJSON(nil)
 }
 
 	addSchedulesJSON := this.GetString("add_schs")
 	delSchedulesJSON := this.GetString("del_schs")
 	changeSchedulesJSON := this.GetString("change_schs")
-	if templateID <= 0 || len(addSchedulesJSON) == 0 || len(delSchedulesJSON) == 0 || len(changeSchedulesJSON) == 0 {
+	if len(addSchedulesJSON) == 0 || len(delSchedulesJSON) == 0 || len(changeSchedulesJSON) == 0 {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
 		return
 	}
 
-	shouldUpdateNextWeekSchedules := false
-	shouldUpdateNextSecondWeekSchedules := false
+	//shouldUpdateNextWeekSchedules := false
+	//shouldUpdateNextSecondWeekSchedules := false
+	//shouldUpdateNextThirdWeekSchedules := false
+	//shouldUpdateNextFourWeekSchedules := false
+	//
 	if templateMode.Mode == 0 {
 		this.ErrorLog("当前未开启排班模板，所以更新模板的操作将被无视")
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
-	templateIDIndex := 1
-	for index, templateIDObject := range templateIDs {
-		if templateIDObject.ID == templateID {
-			templateIDIndex = index + 1
-		}
-	}
-	if templateMode.Mode == 1 {
-		if templateIDIndex == 1 {
-			shouldUpdateNextWeekSchedules = true
-			shouldUpdateNextSecondWeekSchedules = true
-		} else {
-			this.ErrorLog("当前开启的是单周模板，所以不会更新第二个模板")
-			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-			return
-		}
-
-	} else { // mode == 2 => 开启双周模板时，只需更新一周排班
-		if templateIDIndex == 1 {
-			if templateMode.ExecuteTimes%2 == 0 {
-				shouldUpdateNextWeekSchedules = true
-				shouldUpdateNextSecondWeekSchedules = false
-			} else {
-				shouldUpdateNextWeekSchedules = false
-				shouldUpdateNextSecondWeekSchedules = true
-			}
-
-		} else {
-			if templateMode.ExecuteTimes%2 == 0 {
-				shouldUpdateNextWeekSchedules = false
-				shouldUpdateNextSecondWeekSchedules = true
-			} else {
-				shouldUpdateNextWeekSchedules = true
-				shouldUpdateNextSecondWeekSchedules = false
-			}
-
-		}
-	}
-
-	updateErr := service.UpdateScheduleTemplate(adminUserInfo.CurrentOrgId, templateID, addTemplateItems, delTemplateItems, changeTemplateItems, shouldUpdateNextWeekSchedules, shouldUpdateNextSecondWeekSchedules)
+	//判断当前用的是模版几
+	//templateIDIndex := 1
+	//for index, templateIDObject := range templateIDs {
+	//	if templateIDObject.ID == templateID {
+	//		//templateIDIndex = index + 1
+	//	}
+	//}
+	//if templateMode.Mode == 1 {
+	//	if templateIDIndex == 1 {
+	//		shouldUpdateNextWeekSchedules = true
+	//		shouldUpdateNextSecondWeekSchedules = true
+	//	} else {
+	//		this.ErrorLog("当前开启的是单周模板，所以不会更新第二个模板")
+	//		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+	//		return
+	//	}
+	//
+	//} else if templateMode.Mode == 2 { // mode == 2 => 开启双周模板时，只需更新一周排班
+	//	if templateIDIndex == 1 {
+	//		if templateMode.ExecuteTimes%2 == 0 {
+	//			shouldUpdateNextWeekSchedules = true
+	//			shouldUpdateNextSecondWeekSchedules = false
+	//		} else {
+	//			shouldUpdateNextWeekSchedules = false
+	//			shouldUpdateNextSecondWeekSchedules = true
+	//		}
+	//
+	//	} else {
+	//		if templateMode.ExecuteTimes%2 == 0 {
+	//			shouldUpdateNextWeekSchedules = false
+	//			shouldUpdateNextSecondWeekSchedules = true
+	//		} else {
+	//			shouldUpdateNextWeekSchedules = true
+	//			shouldUpdateNextSecondWeekSchedules = false
+	//		}
+	//
+	//	}
+	//} else if templateMode.Mode == 3 { // mode == 2 => 开启双周模板时，只需更新一周排班
+	//	if templateIDIndex == 1 { //当前修改的是第一个模版
+	//		if templateMode.ExecuteTimes%3 == 0 {
+	//			shouldUpdateNextWeekSchedules = true
+	//			shouldUpdateNextSecondWeekSchedules = false
+	//			shouldUpdateNextThirdWeekSchedules = false
+	//		} else if templateMode.ExecuteTimes%3 == 1 {
+	//			shouldUpdateNextWeekSchedules = false
+	//			shouldUpdateNextSecondWeekSchedules = true
+	//			shouldUpdateNextThirdWeekSchedules = false
+	//		} else {
+	//			shouldUpdateNextWeekSchedules = false
+	//			shouldUpdateNextSecondWeekSchedules = false
+	//			shouldUpdateNextThirdWeekSchedules = true
+	//		}
+	//	} else if templateIDIndex == 2 {
+	//		if templateMode.ExecuteTimes%2 == 0 {
+	//			shouldUpdateNextWeekSchedules = false
+	//			shouldUpdateNextSecondWeekSchedules = true
+	//		} else {
+	//			shouldUpdateNextWeekSchedules = true
+	//			shouldUpdateNextSecondWeekSchedules = false
+	//		}
+	//
+	//	} else {
+	//
+	//	}
+	//}
+
+	updateErr := service.UpdateScheduleTemplate(adminUserInfo.CurrentOrgId, templateID, addTemplateItems, delTemplateItems, changeTemplateItems)
 	if updateErr != nil {
 		this.ErrorLog("更新排班模板排班失败：%v", updateErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBUpdate)
 		return
 	}
 
-	newItems, getTemplateItemsErr := service.GetOrgPatientScheduleTemplateItemsByTemplateID(adminUserInfo.CurrentOrgId, templateID)
+	newItems, getTemplateItemsErr := service.GetOrgPatientScheduleTemplateItemsByTemplateID(adminUserInfo.CurrentOrgId)
 	if getTemplateItemsErr != nil {
 		this.ErrorLog("获取排班模板排班失败：%v", getTemplateItemsErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 	Weekday        int8  `json:"weekday"`
 	TimeType       int8  `json:"time_type"`
 }
+
+func (this *PatientScheduleTemplateAPIController) GetPatientList() {
+	patients, err := service.GetSchTemplatePatientList(this.GetAdminUserInfo().CurrentOrgId)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list": patients,
+	})
+
+}

enums/error_code.go

 	ErrorCodeDeletePChargeWrongTwo = 3900004
 
 	ErrorCodeHisPatientNoRegException = 4000000
+
+	ErrorCodeCantDeleteScheduleBeforeNow = 40000001
 )
 
 var ErrCodeMsgs = map[int]string{
 	ErrorCodeCreateScheduleFail:             "添加排班失败",
 	ErrorCodeCantSetScheduleAgainOneDay:     "同一天不可有两次排班",
 	ErrorCodeCantSetScheduleBeforeNow:       "不能给今天之前的日期排班",
-	ErrorCodeScheduleNotExist:               "排班不存在",
+	ErrorCodeCantDeleteScheduleBeforeNow:    "不能删除今天之前的日期排班",
+	ErrorCodeScheduleNotExist:               "排班不存go在",
 	ErrorCodePointScheduleExist:             "所先位置排班已经存在",
 	ErrorCodeDeleteScheduleFail:             "取消排班失败",
 	ErrorCodeChangeScheduleFail:             "修改排班失败",

models/patient_schedule_template_models.go

 	Status       int8  `gorm:"column:status" json:"-" form:"status"`
 	CreateTime   int64 `gorm:"column:ctime" json:"-" form:"ctime"`
 	ModifyTime   int64 `gorm:"column:mtime" json:"-" form:"mtime"`
+	Week         int64 `gorm:"column:week" json:"-" form:"week"`
 }
 
 func (PatientScheduleTemplateMode) TableName() string {
 	Status     int8  `gorm:"column:status" json:"-" form:"status"`
 	CreateTime int64 `gorm:"column:ctime" json:"-" form:"ctime"`
 	ModifyTime int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Week       int   `gorm:"column:week" json:"week" form:"week"`
 }
 
 func (PatientScheduleTemplateId) TableName() string {

models/schedule_models.go

 	UpdatedTime  int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
 	IsExport     int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
 
-	Patient                   string               `gorm:"-" json:"patient" form:"patient"`
-	DeviceZone                DeviceZone           `json:"zone" gorm:"foreignkey:ID;AssociationForeignKey:PartitionId;"`
-	DeviceNumber              DeviceNumber         `json:"number" gorm:"foreignkey:ID;AssociationForeignKey:BedId;"`
+	Patient      string       `gorm:"-" json:"patient" form:"patient"`
+	DeviceZone   DeviceZone   `json:"zone" gorm:"foreignkey:ID;AssociationForeignKey:PartitionId;"`
+	DeviceNumber DeviceNumber `json:"number" gorm:"foreignkey:ID;AssociationForeignKey:BedId;"`
+
 	TreatmentMode             TreatmentMode        `json:"mode" gorm:"foreignkey:ModeId"`
 	DialysisOrder             DialysisOrder        `json:"order" gorm:"foreignkey:DialysisDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId;"`
 	DialysisPrescription      DialysisPrescription `json:"dialysis_prescription" gorm:"foreignkey:RecordDate,PatientId;AssociationForeignKey:RecordDate,PatientId;"`
 	PatientInfectiousDiseases []InfectiousDiseases `json:"patient_contagions" gorm:"foreignkey:PatientId;AssociationForeignKey:PatientId;"`
+	DialysisMachineName       string               `gorm:"column:dialysis_machine_name" json:"dialysis_machine_name" form:"dialysis_machine_name"`
 }
 
 func (Schedule) TableName() string {

models/smart_sch.go

+package models
+
+type SmartSchPatient 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"`
+	Name          string           `gorm:"column:name" json:"name" form:"name"`
+	SmartSchedule []*SmartSchedule `gorm:"-" json:"sch"`
+}
+
+func (SmartSchPatient) TableName() string {
+	return "xt_patients"
+}
+
+type SmartSchTemplatePatient 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"`
+	Name                        string `gorm:"column:name" json:"name" form:"name"`
+	XtPatientScheduleTemplateId []*XtPatientScheduleTemplateId
+}
+
+func (SmartSchTemplatePatient) TableName() string {
+	return "xt_patients"
+}
+
+type SmartSchedule 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"`
+	PartitionId  int64        `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
+	BedId        int64        `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	PatientId    int64        `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	ScheduleDate int64        `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
+	ScheduleType int64        `gorm:"column:schedule_type" json:"schedule_type" form:"schedule_type"`
+	ScheduleWeek int64        `gorm:"column:schedule_week" json:"schedule_week" form:"schedule_week"`
+	ModeId       int64        `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	Status       int64        `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime  int64        `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime  int64        `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	IsExport     int64        `gorm:"column:is_export" json:"is_export" form:"is_export"`
+	DeviceZone   DeviceZone   `json:"zone" gorm:"foreignkey:ID;AssociationForeignKey:PartitionId;"`
+	DeviceNumber DeviceNumber `json:"number" gorm:"foreignkey:ID;AssociationForeignKey:BedId;"`
+}
+
+func (SmartSchedule) TableName() string {
+	return "xt_schedule"
+}
+
+type XtPatientScheduleTemplateId struct {
+	ID                            int64                            `gorm:"column:id" json:"id" form:"id"`
+	OrgId                         int64                            `gorm:"column:org_id" json:"org_id" form:"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"`
+	Week                          int64                            `gorm:"column:week" json:"week" form:"week"`
+	XtPatientScheduleTemplateItem []*XtPatientScheduleTemplateItem `gorm:"foreignkey:TemplateId;AssociationForeignKey:ID;" json:"template" form:"template"`
+}
+
+func (XtPatientScheduleTemplateId) TableName() string {
+	return "xt_patient_schedule_template_id"
+}
+
+type XtPatientScheduleTemplateItem struct {
+	ID             int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId          int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	TemplateId     int64 `gorm:"column:template_id" json:"template_id" form:"template_id"`
+	DeviceNumberId int64 `gorm:"column:device_number_id" json:"device_number_id" form:"device_number_id"`
+	PatientId      int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	TreatMode      int64 `gorm:"column:treat_mode" json:"treat_mode" form:"treat_mode"`
+	Weekday        int64 `gorm:"column:weekday" json:"weekday" form:"weekday"`
+	TimeType       int64 `gorm:"column:time_type" json:"time_type" form:"time_type"`
+	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"`
+	IsExport       int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
+	ZoneId         int64 `gorm:"-" json:"zone_id" form:"zone_id"`
+}
+
+func (XtPatientScheduleTemplateItem) TableName() string {
+	return "xt_patient_schedule_template_item"
+}

models/vm_models.go

 	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"`
+	Week         int64 `gorm:"column:week" json:"-" form:"week"`
 }
 
 func (VMPatientScheduleTemplateMode) TableName() string {

routers/router.go

 		AllowOrigins: []string{"https://xt.kuyicloud.com", "http://localhost:9528", "http://localhost:9529", "http://localhost:9531", "http://xt.test.shengws.com", "http://new_mobile.test.sgjyun.com", "https://xt.test.shengws.com", "http://xt.test.sgjyun.com", "https://xt.test.sgjyun.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com", "https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com", "http://mobile.sgjyun.com", "http://mobile.kuyicloud.com"},
 		//AllowOrigins:     []string{"https://xt.kuyicloud.com", "http://localhost:9528", "http://xt.test.shengws.com","https://xt.test.shengws.com", "http://xt.test.sgjyun.com","https://xt.test.sgjyun.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com","https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com","http://mobile.sgjyun.com","http://mobile.kuyicloud.com"},
 		AllowMethods:     []string{"GET", "POST", "PUT", "DELETE", "OPTIONS"},
-		AllowHeaders:     []string{"Origin", "Authorization", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type", "X-XSRF-TOKEN", "Permission"},
+		AllowHeaders:     []string{"Origin", "Authorization", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type", "X-XSRF-TOKEN", "Permission", "KyToken"},
 		ExposeHeaders:    []string{"Content-Length", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},
 		AllowCredentials: true,
 	}))

service/auto_create_week_schedules_service.go

 	//spec := "0 */1 * * * ?"
 	createWeekSchedulesCronJob.AddFunc(spec, func() {
 		AutoCreateWeekSchedules()
+		NewAutoCreateWeekSchedules()
 	})
 }
 
 	createWeekSchedulesCronJob.Start()
 }
 
+func NewAutoCreateWeekSchedules() {
+	utils.TraceLog("自动排班任务开始执行")
+	var modes []*models.PatientScheduleTemplateMode
+	getModesErr := readDb.Model(&models.PatientScheduleTemplateMode{}).Where("mode <> 0 AND status = 1").Find(&modes).Error
+	if getModesErr != nil {
+		utils.ErrorLog("自动排班-获取启用模板模式列表失败:%v", getModesErr)
+		CreateDBErrorRecord(0, "自动排班-获取启用模板模式列表失败:%v", getModesErr)
+		return
+	}
+
+	for _, mode := range modes {
+		templates, getTemplatesErr := GetOrgPatientScheduleTemplateIDs(mode.OrgID)
+		if getTemplatesErr != nil {
+			utils.ErrorLog("自动排班-org_id: %v ：获取模板 ID 失败：%v", mode.OrgID, getTemplatesErr)
+			CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取模板 ID 失败：%v", mode.OrgID, getTemplatesErr)
+			continue
+		} else if len(templates) == 0 {
+			utils.WarningLog("自动排班-org_id: %v ：没有模板", mode.OrgID)
+			continue
+		}
+
+		now := time.Now()
+		nextSecWeek := now.AddDate(0, 0, 14)
+		//nextThridWeek := now.AddDate(0, 0, 21)
+		//nextFourWeek := now.AddDate(0, 0, 28)
+
+		tx := writeDb.Begin()
+
+		thisTime := time.Now()
+		_, theWeek := thisTime.ISOWeek()
+
+		//mode.Week == 0 为了兼容开发新功能前的老数据
+		//新功能加了，预约排班生成的，int64(theWeek) >= mode.Week 当判断当前周数是否小大于或者等于模版预约第几周生成的周数
+		if mode.Week == 0 || int64(theWeek) >= mode.Week {
+
+			if mode.Mode == 1 { // 用第一周模板生成下第二周的排班
+
+				items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[0].ID)
+				if getItemsErr != nil {
+					utils.ErrorLog("自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+					CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+					continue
+				}
+				insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+				if insertErr != nil {
+					utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+					CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+					tx.Rollback()
+					continue
+				} else {
+					//更新周次
+					templates[0].Week = count
+					UpdateTemplateItemWeek(templates[0].OrgID, templates[0].ID, int8(templates[0].Week))
+					continue
+				}
+			} else if mode.Mode == 2 { // mode.ExecuteTimes % 2 的结果，如果为0，用第一周模板生成下第二周的排班，否则用第二周的模板生成排班
+				if mode.ExecuteTimes%2 == 0 {
+					items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[0].ID)
+					if getItemsErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						continue
+					}
+
+					insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+					if insertErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						tx.Rollback()
+						continue
+					} else {
+						//更新周次
+						templates[0].Week = count
+						UpdateTemplateItemWeek(templates[0].OrgID, templates[0].ID, int8(templates[0].Week))
+
+						continue
+					}
+
+				} else {
+					if len(templates) < 2 {
+						utils.WarningLog("自动排班-org_id: %v ：没有第二周的模板")
+						continue
+					}
+					items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[1].ID)
+					if getItemsErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：获取第二周模板Item失败：%v", mode.OrgID, getItemsErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第二周模板Item失败：%v", mode.OrgID, getItemsErr)
+						continue
+					}
+
+					insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+					if insertErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：使用第二周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第二周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						tx.Rollback()
+						continue
+					} else {
+						//更新周次
+						templates[1].Week = count
+						UpdateTemplateItemWeek(templates[1].OrgID, templates[1].ID, int8(templates[1].Week))
+
+						continue
+					}
+				}
+			} else if mode.Mode == 3 { // mode.ExecuteTimes % 2 的结果，如果为0，用第一周模板生成下第二周的排班，否则用第二周的模板生成排班
+				if mode.ExecuteTimes%3 == 0 {
+					items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[0].ID)
+					if getItemsErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						continue
+					}
+
+					insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+					if insertErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第三周排班失败：%v", mode.OrgID, insertErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第三周排班失败：%v", mode.OrgID, insertErr)
+						tx.Rollback()
+						continue
+					} else {
+						templates[0].Week = count
+						UpdateTemplateItemWeek(templates[0].OrgID, templates[0].ID, int8(templates[0].Week))
+
+						continue
+
+					}
+
+				} else if mode.ExecuteTimes%3 == 1 {
+					if len(templates) < 2 {
+						utils.WarningLog("自动排班-org_id: %v ：没有第二周的模板")
+						continue
+					}
+					items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[1].ID)
+					if getItemsErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						continue
+					}
+
+					insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+					if insertErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第三周排班失败：%v", mode.OrgID, insertErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第三周排班失败：%v", mode.OrgID, insertErr)
+						tx.Rollback()
+						continue
+					} else {
+						//更新周次
+						templates[1].Week = count
+						UpdateTemplateItemWeek(templates[1].OrgID, templates[1].ID, int8(templates[1].Week))
+
+						continue
+					}
+
+				} else {
+					if len(templates) < 3 {
+						utils.WarningLog("自动排班-org_id: %v ：没有第三周的模板")
+						continue
+					}
+					items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[2].ID)
+					if getItemsErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：获取第三周模板Item失败：%v", mode.OrgID, getItemsErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第三周模板Item失败：%v", mode.OrgID, getItemsErr)
+						continue
+					}
+
+					insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+					if insertErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：使用第三周模板插入下第三周排班失败：%v", mode.OrgID, insertErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第三周模板插入下第三周排班失败：%v", mode.OrgID, insertErr)
+						tx.Rollback()
+						continue
+					} else {
+						//更新周次
+						templates[2].Week = count
+						UpdateTemplateItemWeek(templates[2].OrgID, templates[2].ID, int8(templates[2].Week))
+
+						continue
+					}
+				}
+			} else if mode.Mode == 4 { // mode.ExecuteTimes % 2 的结果，如果为0，用第一周模板生成下第二周的排班，否则用第二周的模板生成排班
+				if mode.ExecuteTimes%4 == 0 {
+					items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[0].ID)
+					if getItemsErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						continue
+					}
+
+					insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+					if insertErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						tx.Rollback()
+						continue
+					} else {
+						//更新周次
+						templates[0].Week = count
+						UpdateTemplateItemWeek(templates[0].OrgID, templates[0].ID, int8(templates[0].Week))
+
+						continue
+
+					}
+
+				} else if mode.ExecuteTimes%4 == 1 {
+					items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[1].ID)
+					if getItemsErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						continue
+					}
+
+					insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+					if insertErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						tx.Rollback()
+						continue
+					} else {
+
+						//更新周次
+						templates[1].Week = count
+						UpdateTemplateItemWeek(templates[1].OrgID, templates[1].ID, int8(templates[1].Week))
+
+						continue
+					}
+
+				} else if mode.ExecuteTimes%4 == 2 {
+					if len(templates) < 2 {
+						utils.WarningLog("自动排班-org_id: %v ：没有第二周的模板")
+						continue
+					}
+					items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[2].ID)
+					if getItemsErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
+						continue
+					}
+
+					insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+					if insertErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
+						tx.Rollback()
+						continue
+					} else {
+
+						//更新周次
+						templates[2].Week = count
+						UpdateTemplateItemWeek(templates[2].OrgID, templates[2].ID, int8(templates[2].Week))
+
+						continue
+					}
+
+				} else if mode.ExecuteTimes%4 == 3 {
+					if len(templates) < 3 {
+						utils.WarningLog("自动排班-org_id: %v ：没有第三周的模板")
+						continue
+					}
+					items, getItemsErr := GetOrgPatientScheduleTemplateItemsWithoutPatientByTemplateID(mode.OrgID, templates[3].ID)
+					if getItemsErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：获取第三周模板Item失败：%v", mode.OrgID, getItemsErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第三周模板Item失败：%v", mode.OrgID, getItemsErr)
+						continue
+					}
+
+					insertErr, count := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+					if insertErr != nil {
+						utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第四周排班失败：%v", mode.OrgID, insertErr)
+						CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第三周排班失败：%v", mode.OrgID, insertErr)
+						tx.Rollback()
+						continue
+					} else {
+						//更新周次
+						templates[3].Week = count
+						UpdateTemplateItemWeek(templates[3].OrgID, templates[3].ID, int8(templates[3].Week))
+						continue
+					}
+
+				}
+			}
+			mode.ExecuteTimes += 1
+			mode.ModifyTime = now.Unix()
+			updateModeErr := tx.Save(mode).Error
+			if updateModeErr != nil {
+				utils.ErrorLog("自动排班-org_id：%v ：更新启用模板模式的执行次数失败：%v", mode.OrgID, updateModeErr)
+				CreateDBErrorRecord(mode.OrgID, "自动排班-org_id：%v ：更新启用模板模式的执行次数失败：%v", mode.OrgID, updateModeErr)
+				tx.Rollback()
+				continue
+			}
+			tx.Commit()
+			utils.SuccessLog("自动排班-插入排班成功：org_id: %v", mode.OrgID)
+			time.Sleep(time.Second * 30)
+		}
+		utils.SuccessLog("自动排班任务完成")
+
+	}
+
+}
+
 func AutoCreateWeekSchedules() {
 	utils.TraceLog("自动排班任务开始执行")
 	var modes []*models.PatientScheduleTemplateMode
 				CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：获取第一周模板Item失败：%v", mode.OrgID, getItemsErr)
 				continue
 			}
-			insertErr := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+			insertErr, _ := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
 			if insertErr != nil {
 				utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
 				CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
 					continue
 				}
 
-				insertErr := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+				insertErr, _ := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
 				if insertErr != nil {
 					utils.ErrorLog("自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
 					CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
 					continue
 				}
 
-				insertErr := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
+				insertErr, _ := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, nextSecWeek, items, nil)
 				if insertErr != nil {
 					utils.ErrorLog("自动排班-org_id: %v ：使用第二周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
 					CreateDBErrorRecord(mode.OrgID, "自动排班-org_id: %v ：使用第二周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
 					tx.Rollback()
 					continue
+				} else {
+
 				}
 			}
 		}
-
 		mode.ExecuteTimes += 1
 		mode.ModifyTime = now.Unix()
 		updateModeErr := tx.Save(mode).Error
 			tx.Rollback()
 			continue
 		}
-
 		tx.Commit()
 		utils.SuccessLog("自动排班-插入排班成功：org_id: %v", mode.OrgID)
-
 		time.Sleep(time.Second * 30)
 	}
 
 	utils.SuccessLog("自动排班任务完成")
 }
 
-func _refreshWeekSchedulesWithTemplateItems(tx *gorm.DB, orgID int64, week time.Time, templateItems []*models.PatientScheduleTemplateItem, deviceNumberMap map[int64]*DeviceNumberViewModel) error {
+func _refreshWeekSchedulesWithTemplateItems(tx *gorm.DB, orgID int64, week time.Time, templateItems []*models.PatientScheduleTemplateItem, deviceNumberMap map[int64]*DeviceNumberViewModel) (error, int) {
 	if deviceNumberMap == nil {
 		deviceNumbers, getDeviceNumbersErr := GetAllValidDeviceNumbers(orgID)
 		//fmt.Println("getDeviceNumbersErr3232322332323232323323223232323",getDeviceNumbersErr)
 		if getDeviceNumbersErr != nil {
-			return getDeviceNumbersErr
+			return getDeviceNumbersErr, 0
 		}
 		deviceNumberMap = make(map[int64]*DeviceNumberViewModel, 0)
 		for _, deviceNumber := range deviceNumbers {
 	disableErr := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", orgID, monday.Unix(), sunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
 	//fmt.Println("disableErr323232332323232233222332232332",disableErr)
 	if disableErr != nil {
-		return disableErr
+		return disableErr, 0
 	}
 
+	var week_count int
 	// 批量插入排班
 	if len(templateItems) > 0 {
 
+		timeLayout := "20060102"
+		loc, _ := time.LoadLocation("Local")
+		tmp, _ := time.ParseInLocation(timeLayout, time.Unix(monday.Unix(), 0).Format("2006-01-02"), loc)
+		_, weeks := tmp.ISOWeek()
+		week_count = weeks
 		valueStrs := make([]string, 0, len(templateItems))
 		values := make([]interface{}, 0, len(templateItems)*11)
 
 				continue
 			}
 
-			valueStrs = append(valueStrs, "(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)")
+			so, _ := GetDialysisSolutionTwo(item.OrgID, item.PatientID, item.TreatMode)
+			filedRecordOne, _ := FindFiledBy(item.OrgID, "透析器")
+			filedRecordTwo, _ := FindFiledBy(item.OrgID, "灌流器")
+			filedRecordThree, _ := FindFiledBy(item.OrgID, "透析器/灌流器")
+			var DialysisMachineName string
+			if filedRecordOne.IsShow == 1 {
+				DialysisMachineName = so.DialysisDialyszers
+				//service.UpdateSchDName(schedule)
+			}
+			if filedRecordTwo.IsShow == 1 {
+				DialysisMachineName = so.DialysisIrrigation
+				//service.UpdateSchDName(schedule)
+			}
+
+			if filedRecordThree.IsShow == 1 {
+				DialysisMachineName = so.DialyzerPerfusionApparatus
+				//service.UpdateSchDName(schedule)
+			}
+
+			valueStrs = append(valueStrs, "(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,?)")
 			values = append(values, orgID)
 			values = append(values, deviceNumber.ZoneID)
 			values = append(values, item.DeviceNumberID)
 			values = append(values, 1)
 			values = append(values, now.Unix())
 			values = append(values, now.Unix())
+			values = append(values, DialysisMachineName)
 		}
-
-		sql := fmt.Sprintf("INSERT INTO xt_schedule (user_org_id, partition_id, bed_id, patient_id, schedule_date, schedule_week, schedule_type, mode_id, status, created_time, updated_time) VALUES %v;", strings.Join(valueStrs, ", "))
+		sql := fmt.Sprintf("INSERT INTO xt_schedule (user_org_id, partition_id, bed_id, patient_id, schedule_date, schedule_week, schedule_type, mode_id, status, created_time, updated_time,dialysis_machine_name) VALUES %v;", strings.Join(valueStrs, ", "))
 		if insertErr := tx.Exec(sql, values...).Error; insertErr != nil {
 			//fmt.Println("insertErr232332233223332232323222222www",insertErr)
-			return insertErr
+			return insertErr, 0
 		}
 	}
-	return nil
+
+	return nil, week_count
 }
 
 func FakeAutoCreateNextTwoWeekSchedules(orgID int64) {
 			utils.ErrorLog("获取第一周模板Item失败：%v", getItemsErr)
 			return
 		}
-		insertErr := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 7), items, deviceNumberMap)
+		insertErr, _ := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 7), items, deviceNumberMap)
 		if insertErr != nil {
 			utils.ErrorLog("使用第一周模板插入下第一周排班失败：%v", insertErr)
 			tx.Rollback()
 			return
 		}
-		insertErr = _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 14), items, deviceNumberMap)
+		insertErr, _ = _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 14), items, deviceNumberMap)
 		if insertErr != nil {
 			utils.ErrorLog("使用第一周模板插入下第二周排班失败：%v", insertErr)
 			tx.Rollback()
 		}
 
 		if mode.ExecuteTimes%2 == 0 {
-			insertErr := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 7), firstItems, deviceNumberMap)
+			insertErr, _ := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 7), firstItems, deviceNumberMap)
 			if insertErr != nil {
 				utils.ErrorLog("使用第一周模板插入下第一周排班失败：%v", insertErr)
 				tx.Rollback()
 				return
 			}
-			insertErr = _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 14), secItems, deviceNumberMap)
+			insertErr, _ = _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 14), secItems, deviceNumberMap)
 			if insertErr != nil {
 				utils.ErrorLog("使用第二周模板插入下第二周排班失败：%v", insertErr)
 				tx.Rollback()
 			}
 
 		} else { // mode.ExecuteTimes%2 == 1
-			insertErr := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 7), secItems, deviceNumberMap)
+			insertErr, _ := _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 7), secItems, deviceNumberMap)
 			if insertErr != nil {
 				utils.ErrorLog("使用第二周模板插入下第一周排班失败：%v", mode.OrgID, insertErr)
 				tx.Rollback()
 				return
 			}
-			insertErr = _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 14), firstItems, deviceNumberMap)
+			insertErr, _ = _refreshWeekSchedulesWithTemplateItems(tx, mode.OrgID, now.AddDate(0, 0, 14), firstItems, deviceNumberMap)
 			if insertErr != nil {
 				utils.ErrorLog("使用第一周模板插入下第二周排班失败：%v", mode.OrgID, insertErr)
 				tx.Rollback()

service/patient_schedule_template_service.go

 // 获取至多两个模板ID
 func GetOrgPatientScheduleTemplateIDs(orgID int64) ([]*models.PatientScheduleTemplateId, error) {
 	var ids []*models.PatientScheduleTemplateId
-	err := readDb.Model(&models.PatientScheduleTemplateId{}).Where("org_id = ? AND status = 1", orgID).Limit(2).Find(&ids).Error
+	err := readDb.Model(&models.PatientScheduleTemplateId{}).Where("org_id = ? AND status = 1", orgID).Limit(4).Find(&ids).Error
 	if err != nil {
 		return nil, err
 	}
 		Preload("Items", "org_id = ? AND status = 1", orgID).
 		Preload("Items.Patient", "user_org_id = ? AND status = 1", orgID).
 		Where("org_id = ? AND status = 1", orgID).
-		Limit(2).
+		Limit(4).
 		Find(&vms).
 		Error
 	if err != nil {
 }
 
 // 获取指定模板ID的模板排班列表
-func GetOrgPatientScheduleTemplateItemsByTemplateID(orgID int64, templateID int64) ([]*PatientScheduleTemplateItemViewModel, error) {
+func GetOrgPatientScheduleTemplateItemsByTemplateID(orgID int64) ([]*PatientScheduleTemplateItemViewModel, error) {
 	var vms []*PatientScheduleTemplateItemViewModel
 	err := readDb.
 		Model(&PatientScheduleTemplateItemViewModel{}).
 		Preload("Patient", "user_org_id = ? AND status = 1", orgID).
-		Where("org_id = ? AND template_id = ? AND status = 1", orgID, templateID).
+		Where("org_id = ? AND template_id = ? AND status = 1", orgID, 0).
 		Find(&vms).
 		Error
 	if err != nil {
 }
 
 // 创建两个默认模板
-func CreateTwoPatientScheduleTemplates(orgID int64) (*PatientScheduleTemplateViewModel, *PatientScheduleTemplateViewModel, error) {
+func CreateTwoPatientScheduleTemplates(orgID int64) (*PatientScheduleTemplateViewModel, *PatientScheduleTemplateViewModel, *PatientScheduleTemplateViewModel, *PatientScheduleTemplateViewModel, error) {
 	now := time.Now().Unix()
 	firstTemp := models.PatientScheduleTemplateId{}
 	firstTemp.OrgID = orgID
 	secondTemp.CreateTime = now
 	secondTemp.ModifyTime = now
 
+	thirdTemp := models.PatientScheduleTemplateId{}
+	thirdTemp.OrgID = orgID
+	thirdTemp.Status = 1
+	thirdTemp.CreateTime = now
+	thirdTemp.ModifyTime = now
+
+	fourTemp := models.PatientScheduleTemplateId{}
+	fourTemp.OrgID = orgID
+	fourTemp.Status = 1
+	fourTemp.CreateTime = now
+	fourTemp.ModifyTime = now
+
 	tx := writeDb.Begin()
 	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&firstTemp).Error; err != nil {
 		tx.Rollback()
-		return nil, nil, err
+		return nil, nil, nil, nil, err
 	}
 	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&secondTemp).Error; err != nil {
 		tx.Rollback()
-		return nil, nil, err
+		return nil, nil, nil, nil, err
+	}
+
+	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&thirdTemp).Error; err != nil {
+		tx.Rollback()
+		return nil, nil, nil, nil, err
+	}
+
+	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&fourTemp).Error; err != nil {
+		tx.Rollback()
+		return nil, nil, nil, nil, err
 	}
 
 	vm1 := PatientScheduleTemplateViewModel{}
 	vm2 := PatientScheduleTemplateViewModel{}
 	vm2.ID = secondTemp.ID
 	vm2.Items = make([]*PatientScheduleTemplateItemViewModel, 0, 0)
+
+	vm3 := PatientScheduleTemplateViewModel{}
+	vm3.ID = thirdTemp.ID
+	vm3.Items = make([]*PatientScheduleTemplateItemViewModel, 0, 0)
+
+	vm4 := PatientScheduleTemplateViewModel{}
+	vm4.ID = fourTemp.ID
+	vm4.Items = make([]*PatientScheduleTemplateItemViewModel, 0, 0)
+
 	tx.Commit()
-	return &vm1, &vm2, nil
+	return &vm1, &vm2, &vm3, &vm4, nil
 }
 
-func CreatePatientScheduleTemplate(orgID int64) (*PatientScheduleTemplateViewModel, error) {
+func CreatePatientScheduleTemplate(orgID int64) (*PatientScheduleTemplateViewModel, *PatientScheduleTemplateViewModel, *PatientScheduleTemplateViewModel, error) {
 	now := time.Now().Unix()
 	temp := models.PatientScheduleTemplateId{}
 	temp.OrgID = orgID
 	tx := writeDb.Begin()
 	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&temp).Error; err != nil {
 		tx.Rollback()
-		return nil, err
+		return nil, nil, nil, err
+	}
+
+	thirdTemp := models.PatientScheduleTemplateId{}
+	thirdTemp.OrgID = orgID
+	thirdTemp.Status = 1
+	thirdTemp.CreateTime = now
+	thirdTemp.ModifyTime = now
+
+	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&thirdTemp).Error; err != nil {
+		tx.Rollback()
+		return nil, nil, nil, err
+	}
+
+	fourTemp := models.PatientScheduleTemplateId{}
+	fourTemp.OrgID = orgID
+	fourTemp.Status = 1
+	fourTemp.CreateTime = now
+	fourTemp.ModifyTime = now
+
+	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&fourTemp).Error; err != nil {
+		tx.Rollback()
+		return nil, nil, nil, err
 	}
+
 	vm := PatientScheduleTemplateViewModel{}
 	vm.ID = temp.ID
 	vm.Items = make([]*PatientScheduleTemplateItemViewModel, 0, 0)
+
+	vm3 := PatientScheduleTemplateViewModel{}
+	vm3.ID = thirdTemp.ID
+	vm3.Items = make([]*PatientScheduleTemplateItemViewModel, 0, 0)
+
+	vm4 := PatientScheduleTemplateViewModel{}
+	vm4.ID = fourTemp.ID
+	vm4.Items = make([]*PatientScheduleTemplateItemViewModel, 0, 0)
+
+	tx.Commit()
+	return &vm, &vm3, &vm4, nil
+}
+func CreatePatientScheduleTemplateTwo(orgID int64) (*PatientScheduleTemplateViewModel, *PatientScheduleTemplateViewModel, error) {
+	now := time.Now().Unix()
+
+	tx := writeDb.Begin()
+
+	thirdTemp := models.PatientScheduleTemplateId{}
+	thirdTemp.OrgID = orgID
+	thirdTemp.Status = 1
+	thirdTemp.CreateTime = now
+	thirdTemp.ModifyTime = now
+
+	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&thirdTemp).Error; err != nil {
+		tx.Rollback()
+		return nil, nil, err
+	}
+
+	fourTemp := models.PatientScheduleTemplateId{}
+	fourTemp.OrgID = orgID
+	fourTemp.Status = 1
+	fourTemp.CreateTime = now
+	fourTemp.ModifyTime = now
+
+	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&fourTemp).Error; err != nil {
+		tx.Rollback()
+		return nil, nil, err
+	}
+
+	vm3 := PatientScheduleTemplateViewModel{}
+	vm3.ID = thirdTemp.ID
+	vm3.Items = make([]*PatientScheduleTemplateItemViewModel, 0, 0)
+
+	vm4 := PatientScheduleTemplateViewModel{}
+	vm4.ID = fourTemp.ID
+	vm4.Items = make([]*PatientScheduleTemplateItemViewModel, 0, 0)
+
+	tx.Commit()
+	return &vm3, &vm4, nil
+}
+func CreatePatientScheduleTemplateThree(orgID int64) (*PatientScheduleTemplateViewModel, error) {
+	now := time.Now().Unix()
+	tx := writeDb.Begin()
+	fourTemp := models.PatientScheduleTemplateId{}
+	fourTemp.OrgID = orgID
+	fourTemp.Status = 1
+	fourTemp.CreateTime = now
+	fourTemp.ModifyTime = now
+	if err := tx.Model(&models.PatientScheduleTemplateId{}).Create(&fourTemp).Error; err != nil {
+		tx.Rollback()
+		return nil, err
+	}
+	vm4 := PatientScheduleTemplateViewModel{}
+	vm4.ID = fourTemp.ID
+	vm4.Items = make([]*PatientScheduleTemplateItemViewModel, 0, 0)
+
 	tx.Commit()
-	return &vm, nil
+	return &vm4, nil
 }
 
 type PatientScheduleTemplatePatientVM struct {
 	return vms, nil
 }
 
-func UpdateScheduleTemplate(orgID int64, templateID int64,
+func UpdateScheduleTemplate(orgID int64, template_id int64,
 	addTemplateItems []*models.PatientScheduleTemplateItem,
 	delTemplateItems []*models.PatientScheduleTemplateItem,
 	changeTemplateItems []*models.PatientScheduleTemplateItem,
-	shouldUpdateNextWeekSchedules bool,
-	shouldUpdateNextSecondWeekSchedules bool) error {
+) error {
 
 	now := time.Now()
 	tx := writeDb.Begin()
 		for _, item := range addTemplateItems {
 			valueStrs = append(valueStrs, "(?, ?, ?, ?, ?, ?, ?, ?, ?, ?)")
 			values = append(values, orgID)
-			values = append(values, templateID)
+			values = append(values, template_id)
 			values = append(values, item.DeviceNumberID)
 			values = append(values, item.PatientID)
 			values = append(values, item.TreatMode)
 		// utils.TraceLog("delTemplateItems len: %v", len(delTemplateItems))
 		ins := make([]string, 0, len(delTemplateItems))
 		for _, item := range delTemplateItems {
-			ins = append(ins, fmt.Sprintf("(%v, %v, %v, %v, %v)", orgID, templateID, item.DeviceNumberID, item.Weekday, item.TimeType))
+			ins = append(ins, fmt.Sprintf("(%v, %v, %v, %v, %v)", orgID, template_id, item.DeviceNumberID, item.Weekday, item.TimeType))
 		}
 
 		sql := fmt.Sprintf("UPDATE xt_patient_schedule_template_item SET status = 0, mtime = %v WHERE status = 1 AND (org_id, template_id, device_number_id, weekday, time_type) IN (%v);", now.Unix(), strings.Join(ins, ","))
 	if len(changeTemplateItems) > 0 {
 		// utils.TraceLog("changeTemplateItems len: %v", len(changeTemplateItems))
 		for _, item := range changeTemplateItems {
-			if updateErr := tx.Exec("UPDATE xt_patient_schedule_template_item SET patient_id = ?, treat_mode = ?, mtime = ? WHERE status = 1 AND org_id = ? AND template_id = ? AND device_number_id = ? AND weekday = ? AND time_type = ?;", item.PatientID, item.TreatMode, now.Unix(), orgID, templateID, item.DeviceNumberID, item.Weekday, item.TimeType).Error; updateErr != nil {
+			if updateErr := tx.Exec("UPDATE xt_patient_schedule_template_item SET patient_id = ?, treat_mode = ?, mtime = ? WHERE status = 1 AND org_id = ? AND template_id = ? AND device_number_id = ? AND weekday = ? AND time_type = ?;", item.PatientID, item.TreatMode, now.Unix(), orgID, template_id, item.DeviceNumberID, item.Weekday, item.TimeType).Error; updateErr != nil {
 				tx.Rollback()
 				return updateErr
 			}
 		}
 	}
 
-	// 更改下两周的排班
+	// 更改下四周的排班
 	deviceNumbers, getDeviceNumbersErr := GetAllValidDeviceNumbers(orgID)
 	if getDeviceNumbersErr != nil {
 		tx.Rollback()
 	for _, deviceNumber := range deviceNumbers {
 		devicesMap[deviceNumber.ID] = deviceNumber
 	}
-	if shouldUpdateNextWeekSchedules {
-		nextWeek := now.AddDate(0, 0, 7)
-		if updateErr := _updateWeekSchedules(tx, orgID, nextWeek, addTemplateItems, delTemplateItems, changeTemplateItems, devicesMap); updateErr != nil {
-			tx.Rollback()
-			return updateErr
-		}
-	}
-	if shouldUpdateNextSecondWeekSchedules {
-		nextWeek := now.AddDate(0, 0, 14)
-		if updateErr := _updateWeekSchedules(tx, orgID, nextWeek, addTemplateItems, delTemplateItems, changeTemplateItems, devicesMap); updateErr != nil {
-			tx.Rollback()
-			return updateErr
-		}
-	}
+	//if shouldUpdateNextWeekSchedules {
+	//	nextWeek := now.AddDate(0, 0, 7)
+	//	if updateErr := _updateWeekSchedules(tx, orgID, nextWeek, addTemplateItems, delTemplateItems, changeTemplateItems, devicesMap); updateErr != nil {
+	//		tx.Rollback()
+	//		return updateErr
+	//	}
+	//}
+	//if shouldUpdateNextSecondWeekSchedules {
+	//	nextWeek := now.AddDate(0, 0, 14)
+	//	if updateErr := _updateWeekSchedules(tx, orgID, nextWeek, addTemplateItems, delTemplateItems, changeTemplateItems, devicesMap); updateErr != nil {
+	//		tx.Rollback()
+	//		return updateErr
+	//	}
+	//}
+	//
+	//if shouldUpdateNextThirdWeekSchedules {
+	//	nextWeek := now.AddDate(0, 0, 21)
+	//	if updateErr := _updateWeekSchedules(tx, orgID, nextWeek, addTemplateItems, delTemplateItems, changeTemplateItems, devicesMap); updateErr != nil {
+	//		tx.Rollback()
+	//		return updateErr
+	//	}
+	//}
+	//
+	//if shouldUpdateNextFourWeekSchedules {
+	//	nextWeek := now.AddDate(0, 0, 28)
+	//	if updateErr := _updateWeekSchedules(tx, orgID, nextWeek, addTemplateItems, delTemplateItems, changeTemplateItems, devicesMap); updateErr != nil {
+	//		tx.Rollback()
+	//		return updateErr
+	//	}
+	//}
 
 	tx.Commit()
 	return nil
 	now := time.Now()
 	nextWeek := now.AddDate(0, 0, 7)
 	nextMonday, _ := utils.GetMondayAndSundayOfWeekDate(&nextWeek)
-	nextSecWeek := now.AddDate(0, 0, 14)
+	nextSecWeek := now.AddDate(0, 0, 21)
 	_, nextSecSunday := utils.GetMondayAndSundayOfWeekDate(&nextSecWeek)
 	disableErr := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextMonday.Unix(), nextSecSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
 	if disableErr != nil {
 	now := time.Now()
 	nextSecWeek := now.AddDate(0, 0, 14)
 	nextSecMonday, nextSecSunday := utils.GetMondayAndSundayOfWeekDate(&nextSecWeek)
-	disableErr := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextSecMonday.Unix(), nextSecSunday.Unix()).Updates(map[string]interface{}{"status": 0, "mtime": now.Unix()}).Error
+
+	//tx.Model(&models.PatientScheduleTemplateId{}).Where("user_org_id = ? AND status = 1", templateMode.OrgID, nextSecMonday.Unix(), nextSecSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+
+	disableErr := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextSecMonday.Unix(), nextSecSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
 	if disableErr != nil {
 		tx.Rollback()
 		return disableErr
 	tx.Commit()
 	return nil
 }
+func SaveTemplateMode(templateMode *models.PatientScheduleTemplateMode) error {
+	err := writeDb.Model(&models.PatientScheduleTemplateMode{}).Where("id = ? AND status = 1", templateMode.ID).Updates(map[string]interface{}{"mode": templateMode.Mode, "mtime": templateMode.ModifyTime}).Error
+	return err
+}
 
 // 2 -> 1 清除第二周模板item，清除第二周排班，将第一周的排班重复到第二周
 func SavePatientScheduleTemplateMode2To1(templateMode *models.PatientScheduleTemplateMode, secondWeekTemplateID int64, firstWeekTemplateItems []*models.PatientScheduleTemplateItem) error {
 
 	nextSecWeek := now.AddDate(0, 0, 14)
 	nextSecMonday, nextSecSunday := utils.GetMondayAndSundayOfWeekDate(&nextSecWeek)
-	disableSchsErr := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextSecMonday.Unix(), nextSecSunday.Unix()).Updates(map[string]interface{}{"status": 0, "mtime": now.Unix()}).Error
+	disableSchsErr := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextSecMonday.Unix(), nextSecSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
 	if disableSchsErr != nil {
 		tx.Rollback()
 		return disableSchsErr
 	tx.Commit()
 	return nil
 }
+
+// 3 -> 1 清除第三，二周模板item，清除第三，二周排班
+func SavePatientScheduleTemplateMode3To1(templateMode *models.PatientScheduleTemplateMode, secondWeekTemplateID int64, thirdWeekTemplateID int64) error {
+	tx := writeDb.Begin()
+	saveErr := tx.Save(templateMode).Error
+	if saveErr != nil {
+		tx.Rollback()
+		return saveErr
+	}
+
+	now := time.Now()
+
+	disableItemsErr := tx.Model(&models.PatientScheduleTemplateItem{}).Where("(template_id = ? AND status = 1) OR (template_id = ? AND status = 1) ", secondWeekTemplateID, thirdWeekTemplateID).Updates(map[string]interface{}{"status": 0, "mtime": now.Unix()}).Error
+	if disableItemsErr != nil {
+		tx.Rollback()
+		return disableItemsErr
+	}
+
+	nextSecWeek := now.AddDate(0, 0, 14)
+	nextSecMonday, nextSecSunday := utils.GetMondayAndSundayOfWeekDate(&nextSecWeek)
+	disableSchsErr := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextSecMonday.Unix(), nextSecSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+	if disableSchsErr != nil {
+		tx.Rollback()
+		return disableSchsErr
+	}
+
+	nextThirdWeek := now.AddDate(0, 0, 21)
+	nextThirdMonday, nextThirdSunday := utils.GetMondayAndSundayOfWeekDate(&nextThirdWeek)
+	disableSchsErr2 := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextThirdMonday.Unix(), nextThirdSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+	if disableSchsErr2 != nil {
+		tx.Rollback()
+		return disableSchsErr2
+	}
+
+	tx.Commit()
+	return nil
+}
+
+// 3 -> 2 清除第三周模板item，清除第三周排班
+func SavePatientScheduleTemplateMode3To2(templateMode *models.PatientScheduleTemplateMode, thirdWeekTemplateID int64) error {
+	tx := writeDb.Begin()
+	saveErr := tx.Save(templateMode).Error
+	if saveErr != nil {
+		tx.Rollback()
+		return saveErr
+	}
+
+	now := time.Now()
+
+	disableItemsErr := tx.Model(&models.PatientScheduleTemplateItem{}).Where("template_id = ? AND status = 1", thirdWeekTemplateID).Updates(map[string]interface{}{"status": 0, "mtime": now.Unix()}).Error
+	if disableItemsErr != nil {
+		tx.Rollback()
+		return disableItemsErr
+	}
+	nextThirdWeek := now.AddDate(0, 0, 21)
+	nextThirdMonday, nextThirdSunday := utils.GetMondayAndSundayOfWeekDate(&nextThirdWeek)
+	disableSchsErr2 := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextThirdMonday.Unix(), nextThirdSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+	if disableSchsErr2 != nil {
+		tx.Rollback()
+		return disableSchsErr2
+	}
+
+	tx.Commit()
+	return nil
+}
+
+// 4 -> 1 清除第四，三，二周模板item，清除第四，三，二周排班
+func SavePatientScheduleTemplateMode4To1(templateMode *models.PatientScheduleTemplateMode, secondWeekTemplateID int64, thirdWeekTemplateID int64, fourWeekTemplateID int64) error {
+	tx := writeDb.Begin()
+	saveErr := tx.Save(templateMode).Error
+	if saveErr != nil {
+		tx.Rollback()
+		return saveErr
+	}
+
+	now := time.Now()
+
+	disableItemsErr := tx.Model(&models.PatientScheduleTemplateItem{}).Where("(template_id = ? AND status = 1)OR(template_id = ? AND status = 1)OR(template_id = ? AND status = 1)", secondWeekTemplateID, thirdWeekTemplateID, fourWeekTemplateID).Updates(map[string]interface{}{"status": 0, "mtime": now.Unix()}).Error
+	if disableItemsErr != nil {
+		tx.Rollback()
+		return disableItemsErr
+	}
+
+	nextSecWeek := now.AddDate(0, 0, 14)
+	nextSecMonday, nextSecSunday := utils.GetMondayAndSundayOfWeekDate(&nextSecWeek)
+	disableSchsErr := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextSecMonday.Unix(), nextSecSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+	if disableSchsErr != nil {
+		tx.Rollback()
+		return disableSchsErr
+	}
+
+	nextThirdWeek := now.AddDate(0, 0, 21)
+	nextThirdMonday, nextThirdSunday := utils.GetMondayAndSundayOfWeekDate(&nextThirdWeek)
+	disableSchsErr2 := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextThirdMonday.Unix(), nextThirdSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+	if disableSchsErr2 != nil {
+		tx.Rollback()
+		return disableSchsErr2
+	}
+
+	nextFourWeek := now.AddDate(0, 0, 28)
+	nextFourMonday, nextFourSunday := utils.GetMondayAndSundayOfWeekDate(&nextFourWeek)
+	disableSchsErr3 := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextFourMonday.Unix(), nextFourSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+	if disableSchsErr3 != nil {
+		tx.Rollback()
+		return disableSchsErr3
+	}
+
+	tx.Commit()
+	return nil
+}
+
+// 4 -> 2 清除第四，三模板item，清除第四，三排班
+func SavePatientScheduleTemplateMode4To2(templateMode *models.PatientScheduleTemplateMode, thirdWeekTemplateID int64, fourWeekTemplateID int64) error {
+	tx := writeDb.Begin()
+	saveErr := tx.Save(templateMode).Error
+	if saveErr != nil {
+		tx.Rollback()
+		return saveErr
+	}
+
+	now := time.Now()
+
+	disableItemsErr := tx.Model(&models.PatientScheduleTemplateItem{}).Where("(template_id = ? AND status = 1)OR(template_id = ? AND status = 1)", thirdWeekTemplateID, fourWeekTemplateID).Updates(map[string]interface{}{"status": 0, "mtime": now.Unix()}).Error
+	if disableItemsErr != nil {
+		tx.Rollback()
+		return disableItemsErr
+	}
+
+	nextThirdWeek := now.AddDate(0, 0, 21)
+	nextThirdMonday, nextThirdSunday := utils.GetMondayAndSundayOfWeekDate(&nextThirdWeek)
+	disableSchsErr2 := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextThirdMonday.Unix(), nextThirdSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+	if disableSchsErr2 != nil {
+		tx.Rollback()
+		return disableSchsErr2
+	}
+
+	nextFourWeek := now.AddDate(0, 0, 28)
+	nextFourMonday, nextFourSunday := utils.GetMondayAndSundayOfWeekDate(&nextFourWeek)
+	disableSchsErr3 := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextFourMonday.Unix(), nextFourSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+	if disableSchsErr3 != nil {
+		tx.Rollback()
+		return disableSchsErr3
+	}
+
+	tx.Commit()
+	return nil
+}
+
+// 4 -> 3 清除第四模板item，清除第四周排班
+func SavePatientScheduleTemplateMode4To3(templateMode *models.PatientScheduleTemplateMode, fourWeekTemplateID int64) error {
+	tx := writeDb.Begin()
+	saveErr := tx.Save(templateMode).Error
+	if saveErr != nil {
+		tx.Rollback()
+		return saveErr
+	}
+
+	now := time.Now()
+
+	disableItemsErr := tx.Model(&models.PatientScheduleTemplateItem{}).Where("(template_id = ? AND status = 1)", fourWeekTemplateID).Updates(map[string]interface{}{"status": 0, "mtime": now.Unix()}).Error
+	if disableItemsErr != nil {
+		tx.Rollback()
+		return disableItemsErr
+	}
+
+	nextFourWeek := now.AddDate(0, 0, 28)
+	nextFourMonday, nextFourSunday := utils.GetMondayAndSundayOfWeekDate(&nextFourWeek)
+	disableSchsErr3 := tx.Model(&models.Schedule{}).Where("user_org_id = ? AND status = 1 AND schedule_date >= ? AND schedule_date <= ?", templateMode.OrgID, nextFourMonday.Unix(), nextFourSunday.Unix()).Updates(map[string]interface{}{"status": 0, "updated_time": now.Unix()}).Error
+	if disableSchsErr3 != nil {
+		tx.Rollback()
+		return disableSchsErr3
+	}
+
+	tx.Commit()
+	return nil
+}
+
+type SchTemplatePatient 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"`
+	Name       string `gorm:"column:name" json:"name" form:"name"`
+	Lapseto    int64  `gorm:"column:lapseto" json:"lapseto" form:"lapseto"`
+	Status     int64  `gorm:"column:status" json:"status" form:"status"`
+	DialysisNo string `gorm:"column:dialysis_no" json:"dialysis_no" form:"dialysis_no"`
+}
+
+func (SchTemplatePatient) TableName() string {
+	return "xt_patients"
+}
+
+func GetSchTemplatePatientList(orgID int64) ([]*SchTemplatePatient, error) {
+	var patients []*SchTemplatePatient
+	err := readDb.Model(&SchTemplatePatient{}).Where("user_org_id = ? AND status = 1 AND lapseto = 1", orgID).Find(&patients).Error
+	return patients, err
+}
+
+func UpdateTemplateItemWeek(orgID int64, id int64, week_time int8) {
+	readDb.Model(&models.PatientScheduleTemplateId{}).Where("org_id = ? AND status = 1 AND id = ? ", orgID, id).Updates(map[string]interface{}{"week": week_time})
+	return
+}
+
+func GetOrgPatientScheduleTemplateModeTwo(orgID int64) (models.PatientScheduleTemplateMode, error) {
+	var mode models.PatientScheduleTemplateMode
+	err := readDb.Model(&models.PatientScheduleTemplateMode{}).Where("org_id = ? AND status = 1", orgID).First(&mode).Error
+	return mode, err
+}

service/schedule_service.go

 	err = readDb.Table("xt_schedule as s").Preload("PatientInfectiousDiseases", "status = 1 ").
 		Joins("JOIN xt_patients as p ON p.id = s.patient_id").
 		Where("s.user_org_id=? and s.schedule_date>=? and s.schedule_date<=? and s.status=1", orgID, start, end).
-		Select("s.id, s.user_org_id, s.partition_id, s.bed_id, s.patient_id, s.schedule_date, s.schedule_type, s.schedule_week, s.mode_id, s.status, s.created_time, s.updated_time, p.name as patient").
+		Select("s.id, s.user_org_id, s.partition_id, s.bed_id, s.patient_id, s.schedule_date, s.schedule_type, s.schedule_week, s.mode_id, s.status, s.created_time, s.updated_time,s.dialysis_machine_name, p.name as patient").
 		Order("updated_time asc").
 		Find(&schedules).Error
 	return
 	err = db.Preload("PatientInfectiousDiseases", "status = 1 ").
 		Joins("JOIN xt_patients as p ON p.id = s.patient_id").
 		Where("s.user_org_id=? and s.schedule_date>=? and s.schedule_date<=? and s.status=1", orgID, start, end).
-		Select("s.id, s.user_org_id, s.partition_id, s.bed_id, s.patient_id, s.schedule_date, s.schedule_type, s.schedule_week, s.mode_id, s.status, s.created_time, s.updated_time, p.name as patient").
+		Select("s.id, s.user_org_id, s.partition_id, s.bed_id, s.patient_id, s.schedule_date, s.schedule_type, s.schedule_week, s.mode_id, s.status, s.created_time,s.dialysis_machine_name, s.updated_time, p.name as patient").
 		Order("updated_time asc").
 		Find(&schedules).Error
 	return
 	err = db.Preload("PatientInfectiousDiseases", "status = 1 ").
 		Joins("JOIN xt_patients as p ON p.id = s.patient_id").
 		Where("s.user_org_id=? and s.schedule_date>=? and s.schedule_date<=? and s.status=1", orgID, start, end).
-		Select("s.id, s.user_org_id, s.partition_id, s.bed_id, s.patient_id, s.schedule_date, s.schedule_type, s.schedule_week, s.mode_id, s.status, s.created_time, s.updated_time, p.name as patient").
+		Select("s.id, s.user_org_id, s.partition_id, s.bed_id, s.patient_id, s.schedule_date, s.schedule_type, s.schedule_week, s.mode_id, s.status, s.created_time, s.updated_time,s.dialysis_machine_name, p.name as patient").
 		Order("updated_time asc").
 		Find(&schedules).Error
 	return
 	err = readDb.Model(&models.Schedule{}).Where("user_org_id=?  and schedule_date=? and bed_id=? and status=1 AND schedule_type = ?", orgID, start, bed_id, schedule_type).Preload("DialysisOrder", "status = 1").First(&schedule).Error
 	return
 }
+func GetSourceSch(orgId int64, patient_id int64, record_date int64) (schedule models.Schedule, err error) {
+	err = readDb.Model(&models.Schedule{}).Where("user_org_id=?  and schedule_date=? and patient_id =? and status=1", orgId, record_date, patient_id).First(&schedule).Error
+	return
 
+}
 func GetPatientScheduleFormDay(orgID, start, end, patientID int64) (schedules []*models.PatientSchedule, err error) {
 
 	err = readDb.Table("xt_schedule as s").
 	return err
 }
 
+//参数一：当前操作的患者的排班     参数二被替换床位对应的排班
+func UpdateScheduleTwo(schone models.Schedule, schtwo models.Schedule) {
+	utx := XTWriteDB()
+	var tempPatientID int64
+	var tempPatientIDTwo int64
+	tempPatientID = schone.PatientId
+	tempPatientIDTwo = schtwo.PatientId
+	schone.PatientId = tempPatientIDTwo
+	schtwo.PatientId = tempPatientID
+	utx.Save(schone)
+	utx.Save(schtwo)
+
+}
+
 func GetPatientScheduleFormToday(orgId, id, start int64) (schedules []*models.PatientSchedule, err error) {
 
 	err = readDb.Table("xt_schedule as s").
 	err := XTReadDB().Where("user_org_id = ? and  patient_id = ? and assessment_date < ? and status = 1", orgid, patient_id, scheduleDate).Order("id desc").First(&dislysis).Error
 	return dislysis, err
 }
+
+func GetScheduleTwo(orgID, id int64) (models.Schedule, error) {
+	var schedule models.Schedule
+	var err error
+	err = readDb.Model(&models.Schedule{}).Where("id = ? and user_org_id=? and status=1", id, orgID).First(&schedule).Error
+	return schedule, err
+}
+
+func UpdateSchDName(sch models.Schedule) (err error) {
+	err = writeDb.Model(&models.Schedule{}).Where("status=1 AND id = ?", sch.ID).Updates(map[string]interface{}{"dialysis_machine_name": sch.DialysisMachineName}).Error
+	return
+}
+
+func GetDialysisOrderByBedIdTwo(orgID, start, bed_id int64, schedule_type int64) (models.DialysisOrder, error) {
+	order := models.DialysisOrder{}
+	err = readDb.Model(&order).Where("user_org_id=?  and dialysis_date=? and bed_id=? and status=1 AND schedual_type = ?", orgID, start, bed_id, schedule_type).Find(&order).Error
+	return order, nil
+
+}

service/smart_sch.go

+package service
+
+import (
+	"XT_New/models"
+	"time"
+)
+
+func GetSmartSchPatientByKeyWord(orgID int64, keywords string) (patient []*models.SmartSchPatient, err error) {
+	db := readDb.Model(&models.SmartSchPatient{}).Where("user_org_id=? and status=1", orgID)
+	if len(keywords) > 0 {
+		likekey := "%" + keywords + "%"
+		err = db.Where("name LIKE ? OR dialysis_no LIKE ? ", likekey, likekey).Find(&patient).Error
+	} else {
+		err = db.Find(&patient).Error
+	}
+
+	for _, item := range patient {
+		var sch []*models.SmartSchedule
+		now := time.Now()
+
+		offset := int(time.Monday - now.Weekday())
+		if offset > 0 {
+			offset = -6
+		}
+
+		weekStart := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, time.Local).AddDate(0, 0, offset)
+		readDb.Model(&models.SmartSchedule{}).Where("user_org_id = ? AND status = 1 AND patient_id = ? AND schedule_date >= ?", orgID, item.ID, weekStart.Unix()).
+			Preload("DeviceZone", "status = 1").
+			Preload("DeviceNumber", "status = 1").Find(&sch)
+		item.SmartSchedule = sch
+	}
+
+	return
+}
+
+func GetSmartSchTemplatePatientByKeyWord(orgID int64, keywords string) (patient []*models.SmartSchTemplatePatient, err error) {
+	db := readDb.Model(&models.SmartSchTemplatePatient{}).Where("user_org_id=? and status=1", orgID)
+	if len(keywords) > 0 {
+		likekey := "%" + keywords + "%"
+		err = db.Where("name LIKE ? OR dialysis_no LIKE ? ", likekey, likekey).Find(&patient).Error
+	} else {
+		err = db.Find(&patient).Error
+	}
+
+	for _, item := range patient {
+		mode, _ := GetOrgPatientScheduleTemplateModeTwo(item.UserOrgId)
+		if mode.ID > 0 {
+			if mode.Mode == 1 {
+				schs, _ := GetSmartSchTemplatePatientByID(item.UserOrgId, item.ID, 1)
+				item.XtPatientScheduleTemplateId = schs
+
+			} else if mode.Mode == 2 {
+				schs, _ := GetSmartSchTemplatePatientByID(item.UserOrgId, item.ID, 2)
+
+				item.XtPatientScheduleTemplateId = schs
+
+			} else if mode.Mode == 3 {
+				schs, _ := GetSmartSchTemplatePatientByID(item.UserOrgId, item.ID, 3)
+				item.XtPatientScheduleTemplateId = schs
+
+			} else if mode.Mode == 4 {
+
+				schs, _ := GetSmartSchTemplatePatientByID(item.UserOrgId, item.ID, 4)
+				item.XtPatientScheduleTemplateId = schs
+
+			}
+		}
+
+	}
+	return
+}
+
+func GetSmartSchPatientByID(orgID int64, patient_id int64) (schs []*models.SmartSchedule, err error) {
+	now := time.Now()
+	offset := int(time.Monday - now.Weekday())
+	if offset > 0 {
+		offset = -6
+	}
+	weekStart := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, time.Local).AddDate(0, 0, offset)
+	err = readDb.Model(&models.SmartSchedule{}).Where("user_org_id = ? AND status = 1 AND patient_id = ? AND schedule_date >= ?", orgID, patient_id, weekStart.Unix()).
+		Preload("DeviceZone", "status = 1").
+		Preload("DeviceNumber", "status = 1").Find(&schs).Error
+	return
+}
+
+func GetSmartSchTemplatePatientByID(orgID int64, patient_id int64, count int) (schs []*models.XtPatientScheduleTemplateId, err error) {
+	err = readDb.Model(&models.XtPatientScheduleTemplateId{}).Preload("XtPatientScheduleTemplateItem", "status=1 AND patient_id = ?", patient_id).Where("org_id = ? AND status = 1", orgID).Limit(count).Find(&schs).Error
+	for _, items := range schs {
+		for _, subItems := range items.XtPatientScheduleTemplateItem {
+			number, _ := GetBedNumberById(subItems.DeviceNumberId, subItems.OrgId)
+			subItems.ZoneId = number.ZoneID
+		}
+	}
+	return
+}
+
+func GetAllAvaildDeviceNumbersByZone(orgID int64, record_date int64, schedule_type int, zone_id int64, patient_id int64) ([]*DeviceNumberViewModel, error) {
+	var vms []*DeviceNumberViewModel = make([]*DeviceNumberViewModel, 0)
+	rows, err := readDb.Raw("SELECT n.*, z.name as zone_name FROM xt_device_number as n join xt_device_zone as z on z.id = n.zone_id AND z.id = ?   WHERE (n.org_id = ? AND n.status = 1) AND NOT EXISTS (Select * FROM xt_schedule as s Where s.`schedule_date` = ? AND s.patient_id <> ?  AND  s.user_org_id = n.org_id AND s.`bed_id` = n.id  AND s.`schedule_type` = ? AND s.status = 1 )", zone_id, orgID, record_date, patient_id, schedule_type).Rows()
+	defer rows.Close()
+	if err != nil {
+		return nil, err
+	}
+	for rows.Next() {
+		var vm DeviceNumberViewModel
+		readDb.ScanRows(rows, &vm)
+		vms = append(vms, &vm)
+	}
+	return vms, nil
+}
+
+func GetScheduleByZoneAndBed(org_id int64, partitionId int64, bed_id int64, schedule_date int64, sch_type int64) (sch models.SmartSchedule, err error) {
+	err = readDb.Model(&models.SmartSchedule{}).Where("bed_id = ? AND user_org_id = ? AND schedule_date = ? AND partition_id = ? AND schedule_type = ?  AND status = 1", bed_id, org_id, schedule_date, partitionId, sch_type).First(&sch).Error
+	return
+}