package admin_api_controllers import ( "XT_Admin_Api/enums" "XT_Admin_Api/models/admin_models" "XT_Admin_Api/service" "XT_Admin_Api/utils" "fmt" "time" ) type OrgAPIController struct { AdminBaseAPIAuthController } func (this *OrgAPIController) GetOrgList() { active_status, _ := this.GetInt64("active_status") depth_active_status, _ := this.GetInt64("depth_active_status") start_time := this.GetString("start_time") end_time := this.GetString("end_time") province, _ := this.GetInt64("province") city, _ := this.GetInt64("city") district, _ := this.GetInt64("district") follow, _ := this.GetInt64("follow") keyword := this.GetString("keyword") page, _ := this.GetInt64("page", 0) limit, _ := this.GetInt64("limit", 0) if page <= 0 { page = 1 } if limit <= 0 { limit = 10 } timeLayout := "2006-01-02" loc, _ := time.LoadLocation("Local") var startTime int64 if len(start_time) > 0 { theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc) if err != nil { fmt.Println(err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong) return } startTime = theTime.Unix() } var endTime int64 if len(end_time) > 0 { theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc) if err != nil { utils.ErrorLog(err.Error()) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong) return } endTime = theTime.Unix() } list, err, total := service.GetAllOrgList(active_status, depth_active_status, startTime, endTime, province, city, district, follow, keyword, page, limit, this.GetAdminInfo().IsAdmin) if err != nil { } else { this.ServeSuccessJSON(map[string]interface{}{ "list": list, "total": total, }) } } func (this *OrgAPIController) GetOrgInfo() { org_id, _ := this.GetInt64("org_id", 0) info, err := service.GetOrgDetailInfo(org_id) province, _ := service.GetDistrictsById(info.Province) city, _ := service.GetDistrictsById(info.City) district, _ := service.GetDistrictsById(info.District) orgType, err := service.GetAllOrgType() if err != nil { this.ErrorLog("错误:%v", err) return } else { this.ServeSuccessJSON(map[string]interface{}{ "info": info, "area": province.Name + city.Name + district.Name, "org_type": orgType, }) } } func (this *OrgAPIController) GetOrgDialysisOrderStatistics() { org_id, _ := this.GetInt64("org_id", 0) range_data := this.GetString("range_data") range_type, _ := this.GetInt64("range_type") statistics_type, _ := this.GetInt64("type") var rangeDate *time.Time var parseDateErr error var rangeTimeStamp int64 var orgDialysisOrderStatistics []*admin_models.Statistics switch range_type { case 1: //今天 if len(range_data) > 0 { rangeDate, parseDateErr = utils.ParseTimeStringToTime("2006-01-02", range_data) if parseDateErr != nil { this.ErrorLog("日期(%v)解析错误:%v", range_data, parseDateErr) return } rangeTimeStamp = rangeDate.Unix() } else { rangeTimeStamp = 0 } now := time.Now().Unix() count, err := service.GetOrgDialysisCount(statistics_type, org_id, rangeTimeStamp, now) if err != nil { this.ErrorLog("错误:%v", err) return } else { this.ServeSuccessJSON(map[string]interface{}{ "count": count, }) } break case 2: //昨天 var err error orgDialysisOrderStatistics, err = service.GetYesterDayOrgDialysisCount(statistics_type, org_id) if err != nil { this.ErrorLog("错误:%v", err) return } else { this.ServeSuccessJSON(map[string]interface{}{ "list": orgDialysisOrderStatistics, }) } break case 3: //一周 var err error orgDialysisOrderStatistics, err = service.GetWeekOrgDialysisCount(statistics_type, org_id) if err != nil { this.ErrorLog("错误:%v", err) return } else { this.ServeSuccessJSON(map[string]interface{}{ "list": orgDialysisOrderStatistics, }) } break case 4: //一个月 var err error orgDialysisOrderStatistics, err = service.GetMonthOrgDialysisCount(statistics_type, org_id) if err != nil { this.ErrorLog("错误:%v", err) return } else { this.ServeSuccessJSON(map[string]interface{}{ "list": orgDialysisOrderStatistics, }) } break case 5: //三个月 var err error orgDialysisOrderStatistics, err = service.GetThreeMonthOrgDialysisCount(statistics_type, org_id) if err != nil { this.ErrorLog("错误:%v", err) return } else { this.ServeSuccessJSON(map[string]interface{}{ "list": orgDialysisOrderStatistics, }) } break case 6: //半年 var err error orgDialysisOrderStatistics, err = service.GetSixMonthOrgDialysisCount(statistics_type, org_id) if err != nil { this.ErrorLog("错误:%v", err) return } else { this.ServeSuccessJSON(map[string]interface{}{ "list": orgDialysisOrderStatistics, }) } break case 7: //一年 var err error orgDialysisOrderStatistics, err = service.GetYearOrgDialysisCount(statistics_type, org_id) if err != nil { this.ErrorLog("错误:%v", err) return } else { this.ServeSuccessJSON(map[string]interface{}{ "list": orgDialysisOrderStatistics, }) } break } } func (c *OrgAPIController) GetDistrictsByUpid() { id, _ := c.GetInt64("id", 0) citys, _ := service.GetDistrictsByUpid(id) c.ServeSuccessJSON(map[string]interface{}{ "citys": citys, }) return } func (this *OrgAPIController) GetInitData() { provinces, _ := service.GetDistrictsByUpid(0) follower, _ := service.FindAllFollower() orgType, _ := service.GetAllOrgType() this.ServeSuccessJSON(map[string]interface{}{ "provinces": provinces, "follower": follower, "org_type": orgType, }) } func (this *OrgAPIController) GetOrgPatientList() { org_id, _ := this.GetInt64("org_id", 0) page, _ := this.GetInt64("page", 0) limit, _ := this.GetInt64("limit", 0) if page <= 0 { page = 1 } if limit <= 0 { limit = 7 } patients, _, total := service.FindPatientById(org_id, page, limit) this.ServeSuccessJSON(map[string]interface{}{ "patients": patients, "total": total, }) } func (this *OrgAPIController) GetOrgRoleList() { org_id, _ := this.GetInt64("org_id") page, _ := this.GetInt("page") if page <= 0 { page = 1 } appType, _ := service.GetAppTypeByOrgId(org_id) roles, total, getRoleErr := service.GetRoles(org_id, appType.Id, page, 10) if getRoleErr != nil { //beego.Error("获取角色列表失败:", getRoleErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) } else { this.ServeSuccessJSON(map[string]interface{}{ "roles": roles, "total_count": total, }) } } func (this *OrgAPIController) GetOrgAdminUser() { org_id, _ := this.GetInt64("org_id", 0) page, _ := this.GetInt64("page", 0) limit, _ := this.GetInt64("limit", 0) if page <= 0 { page = 1 } if limit <= 0 { limit = 7 } appType, _ := service.GetAppTypeByOrgId(org_id) viewModels, total, getAdminsErr := service.GetAdminUsersAndLoginInfo(org_id, appType.Id, page, 10) if getAdminsErr != nil { //beego.Error("获取管理员列表失败:", getAdminsErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) } else { this.ServeSuccessJSON(map[string]interface{}{ "admins": viewModels, "total_count": total, }) } } func (this *OrgAPIController) GetOrgZones() { org_id, _ := this.GetInt64("org_id", 0) zones, getZonesErr := service.GetAllValidDeviceZones(org_id) if getZonesErr != nil { this.ErrorLog("获取设备分区列表失败:%v", getZonesErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } this.ServeSuccessJSON(map[string]interface{}{ "zones": zones, }) } func (this *OrgAPIController) GetOrgGroup() { org_id, _ := this.GetInt64("org_id", 0) groups, getGroupsErr := service.GetAllValidDeviceGroups(org_id) if getGroupsErr != nil { //beego.Error("获取设备分组列表失败:", getGroupsErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } this.ServeSuccessJSON(map[string]interface{}{ "groups": groups, }) } func (this *OrgAPIController) GetOrgBed() { org_id, _ := this.GetInt64("org_id", 0) numbers, getNumbersErr := service.GetAllValidDeviceNumbers(org_id) if getNumbersErr != nil { //beego.Error("获取机号列表失败:", getNumbersErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } this.ServeSuccessJSON(map[string]interface{}{ "numbers": numbers, }) } func (this *OrgAPIController) GetOrgListOther() { follow, _ := this.GetInt64("follow") list, err := service.GetFollowOrgList(follow) if err != nil { } else { this.ServeSuccessJSON(map[string]interface{}{ "list": list, }) } } func (this *OrgAPIController) GetActiveOrgList() { range_data := this.GetString("range_data") var rangeDate *time.Time var parseDateErr error var rangeTimeStamp int64 if len(range_data) > 0 { rangeDate, parseDateErr = utils.ParseTimeStringToTime("2006-01-02", range_data) if parseDateErr != nil { this.ErrorLog("日期(%v)解析错误:%v", range_data, parseDateErr) return } rangeTimeStamp = rangeDate.Unix() } else { rangeTimeStamp = 0 } now := time.Now().Unix() list, err := service.GetActiveOrgList(rangeTimeStamp, now) if err != nil { } else { this.ServeSuccessJSON(map[string]interface{}{ "list": list, }) } } func (this *OrgAPIController) GetNewCreateOrgList() { range_data := this.GetString("range_data") var rangeDate *time.Time var parseDateErr error var rangeTimeStamp int64 if len(range_data) > 0 { rangeDate, parseDateErr = utils.ParseTimeStringToTime("2006-01-02", range_data) if parseDateErr != nil { this.ErrorLog("日期(%v)解析错误:%v", range_data, parseDateErr) return } rangeTimeStamp = rangeDate.Unix() } else { rangeTimeStamp = 0 } now := time.Now().Unix() list, err := service.GetNewCreateOrgList(rangeTimeStamp, now) if err != nil { } else { this.ServeSuccessJSON(map[string]interface{}{ "list": list, }) } } func (this *OrgAPIController) GetNewDoctorNurseList() { range_data := this.GetString("range_data") var rangeDate *time.Time var parseDateErr error var rangeTimeStamp int64 if len(range_data) > 0 { rangeDate, parseDateErr = utils.ParseTimeStringToTime("2006-01-02", range_data) if parseDateErr != nil { this.ErrorLog("日期(%v)解析错误:%v", range_data, parseDateErr) return } rangeTimeStamp = rangeDate.Unix() } else { rangeTimeStamp = 0 } now := time.Now().Unix() list, err := service.GetNewDoctorNurseList(rangeTimeStamp, now) if err != nil { } else { this.ServeSuccessJSON(map[string]interface{}{ "list": list, }) } } func (this *OrgAPIController) GetNewPatientList() { range_data := this.GetString("range_data") var rangeDate *time.Time var parseDateErr error var rangeTimeStamp int64 if len(range_data) > 0 { rangeDate, parseDateErr = utils.ParseTimeStringToTime("2006-01-02", range_data) if parseDateErr != nil { this.ErrorLog("日期(%v)解析错误:%v", range_data, parseDateErr) return } rangeTimeStamp = rangeDate.Unix() } else { rangeTimeStamp = 0 } now := time.Now().Unix() list, err := service.GetNewPatientList(rangeTimeStamp, now) if err != nil { } else { this.ServeSuccessJSON(map[string]interface{}{ "list": list, }) } }