Explorar o código

取消erp用户缓存

icole %!s(int64=4) %!d(string=hai) anos
pai
achega
ae10a63329
Modificáronse 1 ficheiros con 14 adicións e 10 borrados
  1. 14 10
      model/sys_user_model.go

+ 14 - 10
model/sys_user_model.go

@@ -77,12 +77,14 @@ func (m *defaultSysUserModel) Insert(data SysUser) (sql.Result, error) {
 }
 
 func (m *defaultSysUserModel) FindOne(id string) (*SysUser, error) {
-	sysUserIdKey := fmt.Sprintf("%s%v", cacheSysUserIdPrefix, id)
+	//sysUserIdKey := fmt.Sprintf("%s%v", cacheSysUserIdPrefix, id)
 	var resp SysUser
-	err := m.QueryRow(&resp, sysUserIdKey, func(conn sqlx.SqlConn, v interface{}) error {
-		query := fmt.Sprintf("select %s from %s where `id` = ? and  status = 0 and del_flag = 0 limit 1", sysUserRows, m.table)
-		return conn.QueryRow(v, query, id)
-	})
+	query := fmt.Sprintf("select %s from %s where `id` = ? and  status = 0 and del_flag = 0 limit 1", sysUserRows, m.table)
+	err := m.QueryRowNoCache(&resp, query, id)
+	//err := m.QueryRow(&resp, sysUserIdKey, func(conn sqlx.SqlConn, v interface{}) error {
+	//	query := fmt.Sprintf("select %s from %s where `id` = ? and  status = 0 and del_flag = 0 limit 1", sysUserRows, m.table)
+	//	return conn.QueryRow(v, query, id)
+	//})
 	switch err {
 	case nil:
 		return &resp, nil
@@ -94,12 +96,14 @@ func (m *defaultSysUserModel) FindOne(id string) (*SysUser, error) {
 }
 
 func (m *defaultSysUserModel) FindOneByPhone(phone string) (*SysUser, error) {
-	sysUserIPhoneKey := fmt.Sprintf("%s%v", cacheSysUserPhonePrefix, phone)
+	//sysUserIPhoneKey := fmt.Sprintf("%s%v", cacheSysUserPhonePrefix, phone)
 	var resp SysUser
-	err := m.QueryRow(&resp, sysUserIPhoneKey, func(conn sqlx.SqlConn, v interface{}) error {
-		query := fmt.Sprintf("select %s from %s where `mobile` = ? and status = 0  and del_flag = 0 limit 1 ", sysUserRows, m.table)
-		return conn.QueryRow(v, query, phone)
-	})
+	query := fmt.Sprintf("select %s from %s where `mobile` = ? and status = 0  and del_flag = 0 limit 1 ", sysUserRows, m.table)
+	err := m.QueryRowNoCache(&resp, query, phone)
+	//err := m.QueryRow(&resp, sysUserIPhoneKey, func(conn sqlx.SqlConn, v interface{}) error {
+	//	query := fmt.Sprintf("select %s from %s where `mobile` = ? and status = 0  and del_flag = 0 limit 1 ", sysUserRows, m.table)
+	//	return conn.QueryRow(v, query, phone)
+	//})
 	switch err {
 	case nil:
 		return &resp, nil