trans_changeNickName.go 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. package transaction
  2. import (
  3. "runtime/debug"
  4. "bet24.com/database"
  5. "bet24.com/log"
  6. )
  7. // 修改昵称
  8. type (
  9. trans_changeNickName_in struct {
  10. UserID int `binding:"required"`
  11. NewNickName string `binding:"required"`
  12. }
  13. trans_changeNickName_out struct {
  14. RetCode int
  15. ErrorMsg string
  16. }
  17. trans_changeNickName struct {
  18. database.Trans_base
  19. In trans_changeNickName_in
  20. Out trans_changeNickName_out
  21. }
  22. )
  23. func NewTransChangeNickName() *trans_changeNickName {
  24. obj := new(trans_changeNickName)
  25. return obj
  26. }
  27. func (this *trans_changeNickName) DoAction(ch chan<- interface{}) {
  28. defer func() {
  29. if err := recover(); err != nil {
  30. log.Release("transaction recover %v", err)
  31. log.Release("%s", debug.Stack())
  32. }
  33. if ch != nil {
  34. ch <- this
  35. }
  36. }()
  37. statement := database.NewStatement()
  38. statement.SetNeedReturnValue(false)
  39. statement.SetOpenRecordSet(false)
  40. statement.SetProcName("WS_AllUser_ChangeNickName")
  41. statement.AddParamter("@UserID", database.AdParamInput, database.AdInteger, 4, this.In.UserID)
  42. statement.AddParamter("@NickName", database.AdParamInput, database.AdNVarChar, 32, this.In.NewNickName)
  43. statement.AddParamter("@RetCode", database.AdParamOutput, database.AdInteger, 4, this.Out.RetCode)
  44. sqlstring := statement.GenSql()
  45. //log.Debug(sqlstring)
  46. retRows := CenterDB.ExecSql(sqlstring)
  47. if len(retRows) <= 0 {
  48. this.State = false
  49. return
  50. }
  51. ret := retRows[0]
  52. this.Out.RetCode = int((ret[0]).(int64))
  53. this.State = true
  54. }
  55. // 修改昵称次数
  56. func ChangeNameTimes(userId int) int {
  57. defer func() {
  58. if err := recover(); err != nil {
  59. log.Error("transaction recover err %v", err)
  60. log.Error("%s", debug.Stack())
  61. }
  62. }()
  63. statement := database.NewStatement()
  64. statement.SetNeedReturnValue(false)
  65. statement.SetOpenRecordSet(true)
  66. statement.SetProcName("WS_AllUser_ChangeNameTimes")
  67. statement.AddParamter("@UserID", database.AdParamInput, database.AdInteger, 4, userId)
  68. sqlString := statement.GenSql()
  69. retRows := CenterDB.ExecSql(sqlString)
  70. if len(retRows) <= 0 {
  71. return -1
  72. }
  73. return int((retRows[0][0]).(int64))
  74. }