排班

controllers/schedule_api_controller.go

@@ -86,6 +86,7 @@ func ScheduleApiRegistRouters() {
 
 	beego.Router("/api/sch/exchange", &ScheduleApiController{}, "Get:ExchangeSch")
 	beego.Router("/api/sch/coversch", &ScheduleApiController{}, "Get:CoverSch")
+	beego.Router("/api/schedule/delete_two", &ScheduleApiController{}, "Delete:DeleteScheduleTwo")
 
 }
 func (c *ScheduleApiController) CoverSch() {
@@ -103,16 +104,13 @@ func (c *ScheduleApiController) CoverSch() {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientDialysisOrderTwo)
 		return
 	}
-	count, _ := service.GetScheduleCountByDate(c.GetAdminUserInfo().CurrentOrgId, sch_two.ScheduleDate, sch_two.PatientId)
-	if count > 1 {
-		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
-		return
-	}
-
-	count1, _ := service.GetScheduleCountByDate(c.GetAdminUserInfo().CurrentOrgId, sch_two.ScheduleDate, sch.PatientId)
-	if count1 > 0 {
-		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
-		return
+	//替换者和被替换的排班日期不是同一天，则进行一个患者一天不能有多个排班提醒
+	if sch.ScheduleDate != sch_two.ScheduleDate && sch.PatientId != sch_two.PatientId {
+		count, _ := service.GetScheduleCountByDate(c.GetAdminUserInfo().CurrentOrgId, sch_two.ScheduleDate, sch.PatientId)
+		if count > 0 {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
+			return
+		}
 	}
 
 	var new_sch models.Schedule
@@ -148,16 +146,21 @@ func (c *ScheduleApiController) ExchangeSch() {
 		return
 	}
 
-	//count1, _ := service.GetScheduleCountByDate(c.GetAdminUserInfo().CurrentOrgId,sch.ScheduleDate,sch.PatientId)
-	//if count1 > 0 {
-	//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
-	//	return
-	//}
-	//count2, _ := service.GetScheduleCountByDate(c.GetAdminUserInfo().CurrentOrgId,sch_two.ScheduleDate,sch_two.PatientId)
-	//if count2 > 0 {
-	//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
-	//	return
-	//}
+	//替换者和被替换的排班日期不是同一天，则进行一个患者一天不能有多个排班提醒
+	if sch.ScheduleDate != sch_two.ScheduleDate && sch.PatientId != sch_two.PatientId {
+		count, _ := service.GetScheduleCountByDate(c.GetAdminUserInfo().CurrentOrgId, sch_two.ScheduleDate, sch.PatientId)
+		if count > 0 {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
+			return
+		}
+
+		count1, _ := service.GetScheduleCountByDate(c.GetAdminUserInfo().CurrentOrgId, sch.ScheduleDate, sch_two.PatientId)
+		if count1 > 0 {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientScheduleRepeat)
+			return
+		}
+	}
+
 	service.UpdateScheduleThree(sch, sch_two)
 	c.ServeSuccessJSON(map[string]interface{}{
 		"msg": "交换成功",
@@ -651,6 +654,13 @@ func (c *ScheduleApiController) BatchPostSmartSch() {
 				sch_id := int64(items["sch_id"].(float64))
 				if sch_id > 0 { //修改排班信息
 					schedule, _ = service.GetScheduleTwo(adminInfo.CurrentOrgId, sch_id)
+
+					order, _ := service.GetDialysisOrderByPatientAndBed(adminInfo.CurrentOrgId, schedule.ScheduleDate, schedule.BedId, schedule.PatientId)
+					if order.ID > 0 {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDelScheduleFailByDialysis)
+						return
+					}
+
 					schedule.Status = 0
 					service.SaveSch(schedule)
 				}
@@ -1001,6 +1011,10 @@ func (c *ScheduleApiController) BatchPostSmartSch() {
 				HandleRedis(adminInfo.CurrentOrgId, schedule.ScheduleDate)
 
 			}
+		} else {
+			c.ServeSuccessJSON(map[string]interface{}{
+				"msg": "保存成功",
+			})
 		}
 	}
 
@@ -4497,3 +4511,79 @@ func RemoveRepeatedScheduleTemplate(arr []*models.VmPatientScheduleTemplateItem)
 	}
 	return
 }
+
+func (c *ScheduleApiController) DeleteScheduleTwo() {
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	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
+	}
+
+	order, err := service.GetOneDialysisOrder(adminINfo.CurrentOrgId, schedule.ScheduleDate, schedule.PatientId)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	if order != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDelScheduleFailByDialysisTwo)
+		return
+	}
+
+	schedule.Status = 0
+	schedule.UpdatedTime = time.Now().Unix()
+	err = service.UpdateSchedule(schedule)
+	redis := service.RedisClient()
+
+	//处方
+	keyOne := strconv.FormatInt(adminINfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":prescriptions_list_all"
+	redis.Set(keyOne, "", time.Second)
+
+	//医嘱
+	keyTwo := strconv.FormatInt(adminINfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":advice_list_all"
+	redis.Set(keyTwo, "", time.Second)
+
+	keySix := strconv.FormatInt(adminINfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":assessment_befores_list_all"
+	redis.Set(keySix, "", time.Second)
+	keyThree := strconv.FormatInt(adminINfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":assessment_after_dislysis_list_all"
+	redis.Set(keyThree, "", time.Second)
+
+	keyFour := strconv.FormatInt(adminINfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":monitor_record_list_all"
+	redis.Set(keyFour, "", time.Second)
+
+	keyFive := strconv.FormatInt(adminINfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":treatment_summarys_list_all"
+	redis.Set(keyFive, "", time.Second)
+
+	keySeven := strconv.FormatInt(adminINfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(schedule.ScheduleDate, 10) + ":dialysis_orders_list_all"
+	redis.Set(keySeven, "", time.Second)
+	fmt.Println(err)
+	defer redis.Close()
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDeleteScheduleFail)
+		return
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"msg":      "ok",
+		"schedule": &schedule,
+	})
+}

controllers/schedule_template_api_controller.go

@@ -718,22 +718,26 @@ func (this *PatientScheduleTemplateAPIController) UpdateSchedulesTemplate() {
 		src_template, _ := service.GetScheduleTemplateItem(item.ID)
 		src_template.Status = 0
 		service.SaveSchTemplateItem(src_template)
-
 	}
-
 	for _, item := range addOrEditSchedules {
-
 		if item.ID > 0 { //已经存在的数据
 			src_template, _ := service.GetScheduleTemplateItem(item.ID)
 			src_template.DeviceNumberID = item.DeviceNumberID
 			src_template.TimeType = int8(item.TimeType)
 			src_template.TreatMode = item.Mode
+			schItem, _ := service.GetScheduleTemplateThree(this.GetAdminUserInfo().CurrentOrgId, src_template.DeviceNumberID, src_template.TemplateID, int64(src_template.Weekday), int64(src_template.TimeType), src_template.PatientID)
+			if schItem.ID > 0 {
+				json := make(map[string]interface{})
+				json["msg"] = item.Title + "周" + strconv.FormatInt(item.Weekday, 10) + "的床位已经有人排班无法保存,可能存在重复排班"
+				json["state"] = 0
+				this.Data["json"] = json
+				this.ServeJSON()
+				break
+			}
 			service.SaveSchTemplateItem(src_template)
-
 		} else {
 			schItemTwo, _ := service.GetScheduleTemplateTwo(this.GetAdminUserInfo().CurrentOrgId, item.TemplateID, item.Weekday, item.PatientID)
 			fmt.Println("222222")
-
 			if schItemTwo.ID > 0 { //当天存在排班，存在则为修改
 				fmt.Println("333333333")
 				src_template, _ := service.GetScheduleTemplateItem(schItemTwo.ID)

enums/error_code.go

@@ -269,9 +269,10 @@ const ( // ErrorCode
 
 	ErrorCodeParamWrongForSchMode = 40000002
 
-	ErrorCodePatientDialysisOrderOne = 60000000
-	ErrorCodePatientDialysisOrderTwo = 60000001
-	ErrorCodePatientScheduleRepeat   = 60000002
+	ErrorCodePatientDialysisOrderOne      = 60000000
+	ErrorCodePatientDialysisOrderTwo      = 60000001
+	ErrorCodePatientScheduleRepeat        = 60000002
+	ErrorCodeDelScheduleFailByDialysisTwo = 60000003
 )
 
 var ErrCodeMsgs = map[int]string{
@@ -526,9 +527,10 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodeSchedule:                 "该班次该床位已有患者",
 	ErrorCodeParamWrongForSchMode:     "透析模式不能为空",
 
-	ErrorCodePatientDialysisOrderOne: "替换的患者已经上机,无法替换排班",
-	ErrorCodePatientDialysisOrderTwo: "被替换的患者已经上机,无法替换排班",
-	ErrorCodePatientScheduleRepeat:   "一天只能存在一次排班",
+	ErrorCodePatientDialysisOrderOne:      "替换的患者已经上机,无法替换排班",
+	ErrorCodePatientDialysisOrderTwo:      "被替换的患者已经上机,无法替换排班",
+	ErrorCodePatientScheduleRepeat:        "一天只能存在一次排班",
+	ErrorCodeDelScheduleFailByDialysisTwo: "已经上机透析，不能操作排班",
 }
 
 type SGJError struct {

service/device_service.go

@@ -856,3 +856,10 @@ func GetScheduleTemplateTwo(orgID int64, template_id int64, week_type int64, pat
 	err := readDb.Model(&models.PatientScheduleTemplateItem{}).Where("patient_id = ? AND org_id = ? AND status = 1 AND template_id = ? AND weekday = ?", patient_id, orgID, template_id, week_type).First(&item).Error
 	return item, err
 }
+
+//某模板下，某周几下，该床位是否有患者(不包括当前排班的人)
+func GetScheduleTemplateThree(orgID int64, deviceNumberID int64, template_id int64, week_type int64, time_type int64, patient_id int64) (models.PatientScheduleTemplateItem, error) {
+	var item models.PatientScheduleTemplateItem
+	err := readDb.Model(&models.PatientScheduleTemplateItem{}).Where("device_number_id = ? AND org_id = ? AND status = 1 AND template_id = ? AND weekday = ? AND time_type = ? AND patient_id <> ?", deviceNumberID, orgID, template_id, week_type, time_type, patient_id).First(&item).Error
+	return item, err
+}

service/schedule_service.go

@@ -1457,3 +1457,8 @@ func GetScheduleTen(orgID, id int64) (models.Schedule, error) {
 	err = readDb.Model(&models.Schedule{}).Where("id = ? and user_org_id=? and status=1", id, orgID).First(&schedule).Error
 	return schedule, err
 }
+
+func GetDialysisOrderByPatientAndBed(org_id int64, record_date int64, bed_id int64, patient_id int64) (order models.DialysisOrder, err error) {
+	err = readDb.Model(&models.DialysisOrder{}).Where("user_org_id = ? AND status = 1 AND dialysis_date = ? AND bed_id = ? AND patient_id = ?", org_id, record_date, bed_id, patient_id).First(&order).Error
+	return
+}

service/smart_sch.go

@@ -48,7 +48,7 @@ func GetSmartSchPatientByPatientID(orgID int64, id int64) (sch []*models.SmartSc
 
 	for _, item := range sch {
 		var order models.SmSchDialysisOrder
-		readDb.Model(&models.SmSchDialysisOrder{}).Where("user_org_id = ? AND status = 1 AND patient_id = ? AND dialysis_date = ? AND bed_id = ?", orgID, item.PatientId, item.ScheduleDate, item.BedId).First(&order)
+		readDb.Model(&models.SmSchDialysisOrder{}).Where("user_org_id = ? AND status = 1 AND patient_id = ? AND dialysis_date = ? ", orgID, item.PatientId, item.ScheduleDate).First(&order)
 		item.SmSchDialysisOrder = order
 	}
 
@@ -98,13 +98,14 @@ func GetSmartSchPatientByID(orgID int64, patient_id int64) (schs []*models.Smart
 		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
 
 	for _, item := range schs {
 		var order models.SmSchDialysisOrder
-		readDb.Model(&models.SmSchDialysisOrder{}).Where("user_org_id = ? AND status = 1 AND patient_id = ? AND dialysis_date = ? AND bed_id = ?", orgID, item.PatientId, item.ScheduleDate, item.BedId).First(&order)
+		readDb.Model(&models.SmSchDialysisOrder{}).Where("user_org_id = ? AND status = 1 AND patient_id = ? AND dialysis_date = ? ", orgID, item.PatientId, item.ScheduleDate).First(&order)
 		item.SmSchDialysisOrder = order
 	}
 	return