package Account import ( "ERP_user/logs" "git.baozhida.cn/ERP_libs/lib" "github.com/beego/beego/v2/adapter/orm" "sync" "time" ) type Dept struct { Id int `orm:"column(ID);size(11);auto;pk"` T_name string `orm:"size(256);null"` // 部门名称 T_mid int `orm:"size(256);null"` // Dept.Id T_mid=0 部门 T_mid>0岗位 T_State int `orm:"size(200);default(1)"` // 0删除 1 正常 } var Dept_list *sync.Map func init() { //注册模型 orm.RegisterModel(new(Dept)) Dept_list = new(sync.Map) } // 获取全部 func Read_Dept_All_Map() { logs.Println("=========== 初始化部门类型 =========") o := orm.NewOrm() for true { var r []Dept qs := o.QueryTable(new(Dept)) _, err := qs.Filter("T_State", 1).All(&r) if err != nil { logs.Error(lib.FuncName(), err) } for _, v := range r { Dept_list.Store(v.Id, v.T_name) } time.Sleep(1 * time.Hour) } } func Read_Dept_Get(Id int) string { v, ok := Dept_list.Load(Id) if ok { return v.(string) } else { return "" } } func Read_Dept_List() (r []Dept) { o := orm.NewOrm() qs := o.QueryTable(new(Dept)) _, err := qs.Filter("T_State", 1).Filter("T_mid", 0).All(&r) if err != nil { logs.Error(lib.FuncName(), err) return r } return r } func Read_Post_List(T_dept int) (r []Dept) { o := orm.NewOrm() qs := o.QueryTable(new(Dept)) _, err := qs.Filter("T_State", 1).Filter("T_mid", T_dept).All(&r) if err != nil { logs.Error(lib.FuncName(), err) return r } return r }