fix nil

liuxiaolong

2022-03-04 f64dd9f191dff341b4eb430d7bacc44a3db9a279

 models/userClient.go

@@ -1 +1,64 @@
package models

import (
   "fmt"
   "github.com/astaxie/beego/orm"
)

//cid和别名绑定记录
type UserClient struct {
   Id          string       `orm:"pk;size(50);column(id)" json:"id"`
   PhoneNum    string       `orm:"column(phoneNum)" json:"phoneNum"` //手机号
   ClientId    string       `orm:"column(clientId)" json:"clientId"` //手机客户端id
   BindTime    string       `orm:"column(bindTime)" json:"bindTime"`
}

func (uc *UserClient) TableName() string {
   return "user_client"
}

func (uc *UserClient) Insert() (int64,error) {
   o := orm.NewOrm()
   return o.Insert(uc)
}

func (uc *UserClient) Exist(phoneNum string) bool {
   var list []UserClient
   o := orm.NewOrm()
   o.QueryTable(uc.TableName()).Filter("phoneNum", phoneNum).All(&list)
   if len(list) >0 {
      return true
   }
   return false
}

func (uc *UserClient) ExistByCid(phoneNum string, cid string) bool {
   var list []UserClient
   o := orm.NewOrm()
   o.QueryTable(uc.TableName()).Filter("phoneNum", phoneNum).Filter("clientId", cid).All(&list)
   if len(list) >0 {
      return true
   }
   return false
}

func (uc *UserClient) GetByCid(cid string) []UserClient {
   var list []UserClient
   o := orm.NewOrm()
   _, err := o.QueryTable(uc.TableName()).Filter("clientId", cid).All(&list)
   if err != nil {
      return nil
   }
   return  list
}


func (uc *UserClient) DeleteByCid(clientId string) (int64, error) {
   o := orm.NewOrm()
   sql := fmt.Sprintf("delete from "+uc.TableName()+" where clientId='%s'", clientId)
   result, err := o.Raw(sql).Exec()
   if err != nil {
      return 0, err
   }
   return result.RowsAffected()
}