提交代码

controllers/schedule_api_controller.go

@@ -130,6 +130,11 @@ func (c *ScheduleApiController) CoverSch() {
 	if err == nil {
 		err2 := service.SaveSch(&new_sch)
 		if err2 == nil {
+			//去除当天患者排班中重复数据，保留最后一条数据
+			service.UpdateRepeatSchStatus(sch.UserOrgId, sch.ScheduleDate)
+			service.UpdateRepeatSchStatus(sch_two.UserOrgId, sch_two.ScheduleDate)
+			service.UpdateRepeatSchStatus(new_sch.UserOrgId, new_sch.ScheduleDate)
+
 			c.ServeSuccessJSON(map[string]interface{}{
 				"msg":     "覆盖成功",
 				"new_sch": new_sch,
@@ -176,6 +181,11 @@ func (c *ScheduleApiController) ExchangeSch() {
 
 	err := service.UpdateScheduleThree(sch, sch_two)
 	if err == nil {
+
+		//去除当天患者排班中重复数据，保留最后一条数据
+		service.UpdateRepeatSchStatus(sch.UserOrgId, sch.ScheduleDate)
+		service.UpdateRepeatSchStatus(sch_two.UserOrgId, sch_two.ScheduleDate)
+
 		c.ServeSuccessJSON(map[string]interface{}{
 			"msg": "交换成功",
 		})
@@ -684,8 +694,13 @@ func (c *ScheduleApiController) BatchPostSmartSch() {
 					service.SaveSch(&schedule)
 				}
 				HandleRedis(adminInfo.CurrentOrgId, schedule.ScheduleDate)
+				//去除当天患者排班中重复数据，保留最后一条数据
+				service.UpdateRepeatSchStatus(adminInfo.CurrentOrgId, schedule.ScheduleDate)
+
 			}
+
 		}
+
 	}
 	////修改或保存数据
 	if dataBody["smart_schs"] != nil && reflect.TypeOf(dataBody["smart_schs"]).String() == "[]interface {}" {
@@ -835,6 +850,10 @@ func (c *ScheduleApiController) BatchPostSmartSch() {
 					schedule.DialysisMachineName = DialysisMachineName
 					schedule.IsExport = 3000
 					service.SaveSch(&schedule)
+
+					//去除当天患者排班中重复数据，保留最后一条数据
+					service.UpdateRepeatSchStatus(schedule.UserOrgId, schedule.ScheduleDate)
+
 				} else { //新的排班信息
 
 					if items["schedule_date"] == nil || reflect.TypeOf(items["schedule_date"]).String() != "string" {
@@ -1024,6 +1043,9 @@ func (c *ScheduleApiController) BatchPostSmartSch() {
 					}
 				}
 
+				//去除当天患者排班中重复数据，保留最后一条数据
+				service.UpdateRepeatSchStatus(schedule.UserOrgId, schedule.ScheduleDate)
+
 				c.ServeSuccessJSON(map[string]interface{}{
 					"msg": "保存成功",
 				})
@@ -1608,6 +1630,8 @@ func (c *ScheduleApiController) CreateSchedule() {
 	}
 	schedule.Patient = patientInfo.Name
 
+	service.UpdateRepeatSchStatus(schedule.UserOrgId, schedule.ScheduleDate)
+
 	c.ServeSuccessJSON(map[string]interface{}{
 		"msg":      "ok",
 		"schedule": schedule,
@@ -1867,6 +1891,10 @@ func (c *ScheduleApiController) CreateScheduleTwo() {
 		redis.Set(keySeven, "", time.Second)
 		defer redis.Close()
 		schedule.Patient = patientInfo.Name
+
+		//去除当天患者排班中重复数据，保留最后一条数据
+		service.UpdateRepeatSchStatus(schedule.UserOrgId, schedule.ScheduleDate)
+
 		c.ServeSuccessJSON(map[string]interface{}{
 			"msg":          "ok",
 			"schedule":     schedule,
@@ -2197,6 +2225,8 @@ func (c *ScheduleApiController) ChangeSchedule() {
 			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeChangeScheduleFail)
 			return
 		}
+		service.UpdateRepeatSchStatus(schedule.UserOrgId, schedule.ScheduleDate)
+
 		c.ServeSuccessJSON(map[string]interface{}{
 			"msg":      "ok",
 			"schedule": &schedule,
@@ -2208,6 +2238,8 @@ func (c *ScheduleApiController) ChangeSchedule() {
 			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeChangeScheduleFail)
 			return
 		}
+		service.UpdateRepeatSchStatus(schedule.UserOrgId, schedule.ScheduleDate)
+
 		c.ServeSuccessJSON(map[string]interface{}{
 			"msg":      "ok",
 			"schedule": &schedule,
@@ -5164,7 +5196,11 @@ func (c *ScheduleApiController) ChangeScheduleTen() {
 
 		}
 	}
+	//去除当天患者排班中重复数据，保留最后一条数据
+	service.UpdateRepeatSchStatus(schedule.UserOrgId, schedule.ScheduleDate)
+
 	scheduletwo, _ := service.GetSchedule(adminINfo.CurrentOrgId, id)
+
 	c.ServeSuccessJSON(map[string]interface{}{
 		"msg":      "ok",
 		"schedule": scheduletwo,

service/schedule_service.go

@@ -1739,3 +1739,21 @@ func GetLastSchedule(patient_id int64, user_org_id int64) (models.XtSchedule, er
 	err := XTReadDB().Where("patient_id = ? and status =1 and user_org_id = ?", patient_id, user_org_id).Find(&schedule).Error
 	return schedule, err
 }
+
+func UpdateRepeatSchStatus(user_org_id int64, schedule_date int64) {
+	var schedules []models.XtSchedule
+	// Find duplicate records based on patient_id, schedule_date, and user_org_id
+	XTReadDB().Where("user_org_id = ? AND schedule_date = ? AND status = ?", user_org_id, schedule_date, 1).
+		Group("patient_id, schedule_date").
+		Having("COUNT(*) > 1").
+		Select("patient_id, schedule_date, MAX(id) as max_id").
+		Find(&schedules)
+
+	for _, schedule := range schedules {
+		// Update records with status = 0 where id is less than max_id
+		XTReadDB().Model(&models.XtSchedule{}).
+			Where("patient_id = ? AND schedule_date = ? AND id < ?", schedule.PatientId, schedule.ScheduleDate, schedule.MaxId).
+			Update("status", 0)
+	}
+
+}