消毒计划

controllers/doctor_schedule_api_controller.go

@@ -34,6 +34,8 @@ func DoctorScheduleRouters() {
 	beego.Router("/api/schedule/savenursesort", &DoctorScheduleApiController{}, "Get:SaveNureSort")
 	beego.Router("/api/schedule/saveisschedule", &DoctorScheduleApiController{}, "Get:SaveIsSchedule")
 	beego.Router("/api/schedule/getscheudlelisttotal", &DoctorScheduleApiController{}, "Get:GetScheduleListTotal")
+	beego.Router("/api/schedule/tosearchtotal", &DoctorScheduleApiController{}, "Get:ToSeachTotal")
+	beego.Router("/api/schedule/changeoption", &DoctorScheduleApiController{}, "Get:ChangeOption")
 }
 
 func (this *DoctorScheduleApiController) SaveDoctorSchedules() {
@@ -553,9 +555,14 @@ func (this *DoctorScheduleApiController) GetScheduleListTotal() {
 	fmt.Println("end_time", end_time)
 	adminUserInfo := this.GetAdminUserInfo()
 	orgId := adminUserInfo.CurrentOrgId
-	//统计总工时
+	//统计班次
 	scheudletotal, err := service.GetScheduleListTotal(orgId, start_time, end_time)
+	//统计总工时
 	list, err := service.GetTotalMinutes(orgId, start_time, end_time)
+	//统计出勤天数
+	workDay, err := service.GetTotalWorkDay(orgId, start_time, end_time)
+	//统计缺勤天数
+	noWorkDay, err := service.GetTotalNoWorkDay(orgId, start_time, end_time)
 	if err != nil {
 		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加设备失败")
 		return
@@ -564,5 +571,54 @@ func (this *DoctorScheduleApiController) GetScheduleListTotal() {
 	this.ServeSuccessJSON(map[string]interface{}{
 		"scheudletotal": scheudletotal,
 		"list":          list,
+		"workDay":       workDay,
+		"noWorkDay":     noWorkDay,
+	})
+}
+
+func (this *DoctorScheduleApiController) ToSeachTotal() {
+	start_time, _ := this.GetInt64("start_time")
+	fmt.Println(start_time)
+	end_time, _ := this.GetInt64("end_time")
+	fmt.Println("end_time", end_time)
+	adminUserInfo := this.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+	fmt.Println(orgId)
+	keyword := this.GetString("keyword")
+	fmt.Println("keyword", keyword)
+	scheduletotal, err := service.GetSearchScheduleListTotal(orgId, start_time, end_time, keyword)
+	list, err := service.GeSearchtTotalMinutes(orgId, start_time, end_time, keyword)
+	workDay, err := service.GetSearchWorkDay(orgId, start_time, end_time, keyword)
+	noWorkDay, err := service.GetSearchWorkNoDay(orgId, start_time, end_time, keyword)
+	if err != nil {
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加设备失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"scheduletotal": scheduletotal,
+		"list":          list,
+		"workDay":       workDay,
+		"noWorkDay":     noWorkDay,
+	})
+}
+
+func (this *DoctorScheduleApiController) ChangeOption() {
+
+	start_time, _ := this.GetInt64("start_time")
+	fmt.Println(start_time)
+	end_time, _ := this.GetInt64("end_time")
+	fmt.Println("end_time", end_time)
+	adminUserInfo := this.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+	fmt.Println(orgId)
+	doctor_type, _ := this.GetInt64("doctor_type")
+	fmt.Println("doctor_type", doctor_type)
+	scheduletotal, err := service.ChagneScheduleListTotal(orgId, start_time, end_time, doctor_type)
+	if err != nil {
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加设备失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"scheduletotal": scheduletotal,
 	})
 }

service/doctor_schedule_service.go

@@ -280,3 +280,121 @@ func GetTotalMinutes(orgid int64, startime int64, endtime int64) (schedule []*mo
 	err = db.Group("x.doctor_id").Select("x.doctor_id,x.schedule_type,x.start_time,x.end_time,x.schedule_date,r.user_name,s.class_name,r.sort,r.is_sort,sum(s.minute) as totalminute").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.doctor_id").Joins("left join xt_doctor_schedules as s on s.id = x.schedule_type").Where("r.org_id = ? and r.status = 1 and s.user_org_id = ? and s.status = 1", orgid, orgid).Scan(&schedule).Error
 	return schedule, err
 }
+
+func GetTotalWorkDay(orgid int64, startime int64, endtime int64) (schedule []*models.CountStaffSchedule, err error) {
+
+	db := XTReadDB().Table("xt_staff_schedule as x").Where("x.status = 1")
+	if startime > 0 {
+		db = db.Where("x.start_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.end_time <=?", endtime)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	err = db.Group("x.doctor_id").Select("x.doctor_id,x.schedule_type,x.start_time,x.end_time,x.schedule_date,r.user_name,s.class_name,r.sort,r.is_sort,count(x.id) as count").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.doctor_id").Joins("left join xt_doctor_schedules as s on s.id = x.schedule_type").Where("r.org_id = ? and r.status = 1 and s.user_org_id = ? and s.status = 1 and s.class_attributes = 1", orgid, orgid).Scan(&schedule).Error
+	return schedule, err
+}
+
+func GetTotalNoWorkDay(orgid int64, startime int64, endtime int64) (schedule []*models.CountStaffSchedule, err error) {
+
+	db := XTReadDB().Table("xt_staff_schedule as x").Where("x.status = 1")
+	if startime > 0 {
+		db = db.Where("x.start_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.end_time <=?", endtime)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	err = db.Group("x.doctor_id").Select("x.doctor_id,x.schedule_type,x.start_time,x.end_time,x.schedule_date,r.user_name,s.class_name,r.sort,r.is_sort,count(x.id) as count").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.doctor_id").Joins("left join xt_doctor_schedules as s on s.id = x.schedule_type").Where("r.org_id = ? and r.status = 1 and s.user_org_id = ? and s.status = 1 and s.class_attributes = 2", orgid, orgid).Scan(&schedule).Error
+	return schedule, err
+}
+
+func GetSearchScheduleListTotal(orgid int64, startime int64, endtime int64, keywords string) (schedule []*models.CountStaffSchedule, err error) {
+	likeKey := "%" + keywords + "%"
+	db := XTReadDB().Table("xt_staff_schedule as x").Where("x.status = 1")
+	if startime > 0 {
+		db = db.Where("x.start_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.end_time <=?", endtime)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	err = db.Group("x.doctor_id,x.schedule_type").Select("x.doctor_id,x.schedule_type,x.start_time,x.end_time,x.schedule_date,r.user_name,s.class_name,r.sort,r.is_sort,count(s.class_name) as count").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.doctor_id").Where("r.user_name like ?", likeKey).Joins("left join xt_doctor_schedules as s on s.id = x.schedule_type").Where("r.org_id = ? and r.status = 1 and s.user_org_id = ? and s.status = 1 ", orgid, orgid).Scan(&schedule).Error
+	return schedule, err
+}
+
+func GeSearchtTotalMinutes(orgid int64, startime int64, endtime int64, keywords string) (schedule []*models.CountStaffSchedule, err error) {
+	likeKey := "%" + keywords + "%"
+	db := XTReadDB().Table("xt_staff_schedule as x").Where("x.status = 1")
+	if startime > 0 {
+		db = db.Where("x.start_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.end_time <=?", endtime)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	err = db.Group("x.doctor_id").Select("x.doctor_id,x.schedule_type,x.start_time,x.end_time,x.schedule_date,r.user_name,s.class_name,r.sort,r.is_sort,sum(s.minute) as totalminute").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.doctor_id").Where("r.user_name like ?", likeKey).Joins("left join xt_doctor_schedules as s on s.id = x.schedule_type").Where("r.org_id = ? and r.status = 1 and s.user_org_id = ? and s.status = 1", orgid, orgid).Scan(&schedule).Error
+	return schedule, err
+}
+
+func GetSearchWorkDay(orgid int64, startime int64, endtime int64, keywords string) (schedule []*models.CountStaffSchedule, err error) {
+	likeKey := "%" + keywords + "%"
+	db := XTReadDB().Table("xt_staff_schedule as x").Where("x.status = 1")
+	if startime > 0 {
+		db = db.Where("x.start_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.end_time <=?", endtime)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	err = db.Group("x.doctor_id").Select("x.doctor_id,x.schedule_type,x.start_time,x.end_time,x.schedule_date,r.user_name,s.class_name,r.sort,r.is_sort,count(x.id) as count").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.doctor_id").Where("r.user_name like ?", likeKey).Joins("left join xt_doctor_schedules as s on s.id = x.schedule_type").Where("r.org_id = ? and r.status = 1 and s.user_org_id = ? and s.status = 1 and s.class_attributes = 1", orgid, orgid).Scan(&schedule).Error
+	return schedule, err
+}
+
+func GetSearchWorkNoDay(orgid int64, startime int64, endtime int64, keywords string) (schedule []*models.CountStaffSchedule, err error) {
+	likeKey := "%" + keywords + "%"
+	db := XTReadDB().Table("xt_staff_schedule as x").Where("x.status = 1")
+	if startime > 0 {
+		db = db.Where("x.start_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.end_time <=?", endtime)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	err = db.Group("x.doctor_id").Select("x.doctor_id,x.schedule_type,x.start_time,x.end_time,x.schedule_date,r.user_name,s.class_name,r.sort,r.is_sort,count(x.id) as count").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.doctor_id").Where("r.user_name like ?", likeKey).Joins("left join xt_doctor_schedules as s on s.id = x.schedule_type").Where("r.org_id = ? and r.status = 1 and s.user_org_id = ? and s.status = 1 and s.class_attributes = 2", orgid, orgid).Scan(&schedule).Error
+	return schedule, err
+}
+
+func ChagneScheduleListTotal(orgid int64, startime int64, endtime int64, doctortype int64) (schedule []*models.CountStaffSchedule, err error) {
+
+	db := XTReadDB().Table("xt_staff_schedule as x").Where("x.status = 1")
+	if startime > 0 {
+		db = db.Where("x.start_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.end_time <=?", endtime)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	if doctortype == 0 {
+		db = db.Where("x.doctor_type = 2 or x.doctor_type = 3")
+	}
+	if doctortype > 0 {
+		db = db.Where("x.doctor_type = ?", doctortype)
+	}
+	err = db.Group("x.doctor_id,x.schedule_type").Select("x.doctor_id,x.schedule_type,x.start_time,x.end_time,x.schedule_date,r.user_name,s.class_name,r.sort,r.is_sort,count(s.class_name) as count").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.doctor_id").Joins("left join xt_doctor_schedules as s on s.id = x.schedule_type").Where("r.org_id = ? and r.status = 1 and s.user_org_id = ? and s.status = 1 ", orgid, orgid).Scan(&schedule).Error
+	return schedule, err
+}