bileiqi/05.code/backend/rtelec_app_public_lib/service/region_service.go

package service

import (
	"rtzh_elec_temperature/enum"
	"rtzh_elec_temperature/global"
	"rtzh_elec_temperature/logger"
	"rtzh_elec_temperature/models/bo"

	"github.com/astaxie/beego/orm"
)

//区域服务对象
type RegionService struct {
	BaseService
}

// 获取当前变电站信息
func (t *RegionService) GetStationInfo() (orm.Params, error) {
	key := "GetStationInfo"
	if v, h := global.GoCahce.Get(key); h {
		return v.(orm.Params), nil
	}
	db := orm.NewOrm()
	db.Using("iss")
	sql := "select * from sys_station"
	rowset := []orm.Params{}
	_, err := db.Raw(sql).Values(&rowset)
	if err != nil {
		logger.Logger.Error(err, sql)
		new(bo.SystemLog).Fail(enum.AuditType_admin_station,
			enum.LogType_Query,
			enum.OptEventType_Bus,
			enum.OptEventLevel_Low, sql, map[string]interface{}{"name": t.UserInfo.Usrname, "ip": t.UserInfo.Ip})
		return nil, err
	}
	if len(rowset) == 0 {
		return orm.Params{"stationid": 0, "name": "未设置"}, nil
	}
	global.GoCahce.Set(key, rowset[0], -1)
	return rowset[0], nil
}

// 获取区域列表
func (t *RegionService) List(param map[string]interface{}) ([]orm.Params, error) {
	key := "RegionList"
	if v, h := global.GoCahce.Get(key); h {
		return v.([]orm.Params), nil
	}
	db := orm.NewOrm()
	db.Using("iss")
	sql := "select * from dev_region"
	rowset := []orm.Params{}
	_, err := db.Raw(sql).Values(&rowset)
	if err != nil {
		logger.Logger.Error(err, sql)
		new(bo.SystemLog).Fail(enum.AuditType_admin_station,
			enum.LogType_Query,
			enum.OptEventType_Bus,
			enum.OptEventLevel_Low, sql, map[string]interface{}{"name": t.UserInfo.Usrname, "ip": t.UserInfo.Ip})
		return rowset, err
	}
	global.GoCahce.Set(key, rowset, -1)
	return rowset, nil
}