11月8日库存管理

controllers/schedule_api_controller.go

@@ -949,6 +949,7 @@ func Struct2Map(obj interface{}) map[string]interface{} {
 }
 
 func (this *ScheduleApiController) ExportSchedule() {
+
 	dataBody := make(map[string]interface{}, 0)
 	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
 	if err != nil {
@@ -964,6 +965,20 @@ func (this *ScheduleApiController) ExportSchedule() {
 
 	patients, _, _ = service.GetAllPatientList(this.GetAdminUserInfo().CurrentOrgId)
 
+	start_time := dataBody["start_time"].(string)
+
+	end_time := dataBody["end_time"].(string)
+
+	delete_type := int64(dataBody["delete_type"].(float64))
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	theTimeStart, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+	theTimeEnd, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 00:00:00", loc)
+
+	fmt.Println("theTimeStart23232322332322323", theTimeStart.Unix())
+	fmt.Println("theTimeStart23232322332322323", theTimeEnd.Unix())
+
 	if dataBody["failed_schedule"] != nil || reflect.TypeOf(dataBody["failed_schedule"]).String() == "[]interface {}" {
 		tempSchedule := dataBody["failed_schedule"].([]interface{})
 		failed_total = len(tempSchedule)
@@ -1403,15 +1418,24 @@ func (this *ScheduleApiController) ExportSchedule() {
 			//clear_schedule_date := date.Unix() //根据日期去清除，该日期未来的排班数据
 			//err := service.UpdateScheduleStatus(clear_schedule_date, this.GetAdminUserInfo().CurrentOrgId)
 			if err == nil {
+				//清除该机构的排班
+				if delete_type == 1 {
+					service.ModeScheduleByTimeOne(theTimeStart.Unix(), theTimeEnd.Unix(), this.GetAdminUserInfo().CurrentOrgId)
+				}
+				if delete_type == 0 {
+					service.ModeScheduleByTime(theTimeStart.Unix(), theTimeEnd.Unix(), this.GetAdminUserInfo().CurrentOrgId)
+				}
+
 				for _, item := range schedules {
 					//删除当天的日期排班
-					service.DeleteScheduleExist(item.ScheduleDate, item.UserOrgId)
+					/*service.DeleteScheduleExist(item.ScheduleDate, item.UserOrgId)*/
 					//查找当天日期是否存在
-					_, errcode := service.GetTodayScheduleIsExist(item.PatientId, item.ScheduleDate, item.UserOrgId, item.ModeId, item.ScheduleType)
+					_, errcode := service.GetTodayScheduleIsExistOne(item.PatientId, item.ScheduleDate, item.UserOrgId)
 					if errcode == gorm.ErrRecordNotFound {
+						//清除当天该床位已有的患者
+						// service.ModeFyScheduleById(item.ScheduleDate,item.BedId,item.ScheduleType)
 						service.CreateSchedule(item)
 					} else if errcode == nil {
-
 						schedule := models.XtSchedule{
 							PartitionId:  item.PartitionId,
 							BedId:        item.BedId,
@@ -1423,7 +1447,7 @@ func (this *ScheduleApiController) ExportSchedule() {
 							Status:       1,
 						}
 
-						service.UpdateScheduleByOrgId(item.PatientId, item.ScheduleDate, item.UserOrgId, item.ModeId, item.ScheduleType, &schedule)
+						service.UpdateScheduleByOrgIdOne(item.PatientId, item.ScheduleDate, item.UserOrgId, &schedule)
 					}
 
 				}

service/schedule_service.go

@@ -169,7 +169,7 @@ func CreateSchedule(m *models.Schedule) error {
 
 func DeleteScheduleExist(scheduleData int64, user_org_id int64) (models.XtSchedule, error) {
 	schedule := models.XtSchedule{}
-	err := XTWriteDB().Where("schedule_date= ? and user_org_id = ? and status = 1", scheduleData, user_org_id).Updates(map[string]interface{}{"status": 0}).Error
+	err := XTWriteDB().Model(&schedule).Where("schedule_date= ? and user_org_id = ? and status = 1", scheduleData, user_org_id).Updates(map[string]interface{}{"status": 0}).Error
 	return schedule, err
 }
 
@@ -186,11 +186,52 @@ func GetTodayScheduleIsExist(patientid int64, schedudate int64, orgid int64, mod
 	return &scheudle, nil
 }
 
+func GetTodayScheduleIsExistOne(patientid int64, schedudate int64, orgid int64) (*models.XtSchedule, error) {
+	var scheudle models.XtSchedule
+	var err error
+	err = XTReadDB().Model(&scheudle).Where("patient_id = ? and schedule_date= ? and user_org_id = ? and status = 1", patientid, schedudate, orgid).Find(&scheudle).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &scheudle, nil
+}
+
+func ModeFyScheduleById(schedule_date int64, bedid int64, scheduletype int64) error {
+
+	schedule := models.XtSchedule{}
+	err := XTWriteDB().Model(&schedule).Where("schedule_date = ? and bed_id =? and schedule_type = ? and status = 1", schedule_date, bedid, scheduletype).Updates(map[string]interface{}{"status": 0}).Error
+	return err
+}
+
+func ModeScheduleByTime(startime int64, endtime int64, orgid int64) error {
+
+	schedule := models.XtSchedule{}
+
+	err := XTWriteDB().Model(&schedule).Where("schedule_date >? and schedule_date<=? and status = 1 and user_org_id = ?", startime, endtime, orgid).Updates(map[string]interface{}{"status": 0}).Error
+	return err
+}
+
+func ModeScheduleByTimeOne(startime int64, endtime int64, orgid int64) error {
+
+	schedule := models.XtSchedule{}
+
+	err := XTWriteDB().Model(&schedule).Where("schedule_date >=? and schedule_date<=? and status = 1 and user_org_id = ?", startime, endtime, orgid).Updates(map[string]interface{}{"status": 0}).Error
+	return err
+}
+
 func UpdateScheduleByOrgId(patientid int64, scheduledate int64, orgid int64, mode_id int64, schedule_type int64, sch *models.XtSchedule) error {
 	err := XTWriteDB().Model(&sch).Where("patient_id = ? and schedule_date= ? and user_org_id = ? and status = 1 and mode_id = ? and schedule_type = ?", patientid, scheduledate, orgid, mode_id, schedule_type).Updates(map[string]interface{}{"partition_id": sch.PartitionId, "bed_id": sch.BedId, "schedule_type": sch.ScheduleType, "schedule_week": sch.ScheduleWeek, "mode_id": sch.ModeId, "updated_time": time.Now().Unix()}).Error
 	return err
 }
 
+func UpdateScheduleByOrgIdOne(patientid int64, scheduledate int64, orgid int64, sch *models.XtSchedule) error {
+	err := XTWriteDB().Model(&sch).Where("patient_id = ? and schedule_date= ? and user_org_id = ? and status = 1", patientid, scheduledate, orgid).Updates(map[string]interface{}{"partition_id": sch.PartitionId, "bed_id": sch.BedId, "schedule_type": sch.ScheduleType, "schedule_week": sch.ScheduleWeek, "mode_id": sch.ModeId, "updated_time": time.Now().Unix()}).Error
+	return err
+}
+
 func GetSchedule(orgID, id int64) (*models.Schedule, error) {
 	var schedule models.Schedule
 	var err error