trans_changeUserWord.go 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. package transaction
  2. import (
  3. "runtime/debug"
  4. "bet24.com/database"
  5. "bet24.com/log"
  6. )
  7. type changeUserWord_in struct {
  8. UserID int
  9. UserWords string
  10. }
  11. type changeUserWord_out struct {
  12. RetCode int
  13. }
  14. type changeUserWord struct {
  15. database.Trans_base
  16. IN changeUserWord_in
  17. OUT changeUserWord_out
  18. }
  19. func NewChangeUserWord() *changeUserWord {
  20. return &changeUserWord{}
  21. }
  22. func (this *changeUserWord) DoAction(ch chan<- interface{}) {
  23. defer func() {
  24. if err := recover(); err != nil {
  25. log.Release("transaction recover %v", err)
  26. log.Release("%s", debug.Stack())
  27. }
  28. if ch != nil {
  29. ch <- this
  30. }
  31. }()
  32. statement := database.NewStatement()
  33. statement.SetNeedReturnValue(false)
  34. statement.SetOpenRecordSet(true)
  35. statement.SetProcName("WS_AllUser_ChangeUserWord")
  36. statement.AddParamter("@UserID", database.AdParamInput, database.AdInteger, 4, this.IN.UserID)
  37. statement.AddParamter("@UserWords", database.AdParamInput, database.AdNVarChar, 256, this.IN.UserWords)
  38. statement.AddParamter("@RetCode", database.AdParamOutput, database.AdInteger, 4, this.OUT.RetCode)
  39. sqlstring := statement.GenSql()
  40. //log.Debug(sqlstring)
  41. retRows := CenterDB.ExecSql(sqlstring)
  42. if len(retRows) <= 0 {
  43. this.State = false
  44. return
  45. }
  46. ret := retRows[0]
  47. this.OUT.RetCode = int((ret[0]).(int64))
  48. this.State = true
  49. }