account.go 64 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081
  1. package models
  2. import (
  3. "encoding/hex"
  4. "errors"
  5. "fmt"
  6. "mtp2_if/db"
  7. "mtp2_if/global/e"
  8. "mtp2_if/utils"
  9. "strconv"
  10. "time"
  11. )
  12. // Loginaccount 登录账户表
  13. type Loginaccount struct {
  14. Loginid int64 `json:"loginid" xorm:"'LOGINID'" binding:"required"` // 登陆账号
  15. Userid int64 `json:"userid" xorm:"'USERID'"` // 用户ID
  16. Loginfailnum int32 `json:"loginfailnum" xorm:"'LOGINFAILNUM'"` // 连续登录失败次数(登录成功时清零)
  17. Password string `json:"-" xorm:"'PASSWORD'"` // 登陆密码
  18. Loginusertype int32 `json:"loginusertype" xorm:"'LOGINUSERTYPE'"` // 登录账号类型 - 1:投资者 2:机构交易员
  19. Loginstatus int32 `json:"loginstatus" xorm:"'LOGINSTATUS'"` // 登录账号状态 1:正常 2:冻结 3:无效
  20. Lastlogintime time.Time `json:"lastlogintime" xorm:"'LASTLOGINTIME'"` // 最新登录时间
  21. Lastloginmode int32 `json:"lastloginmode" xorm:"'LASTLOGINMODE'"` // 最新登录方式(客户端类型) - 0:保留为未填终端类型 1:PC管理端 2:PC交易端 3:手机客户端_安卓 4:网页客户端 5:微信客户端 6:手机客户端_苹果 7:网上开户客户端 8:无效终端编号 9:报价终端(中江)
  22. Lastloginip string `json:"lastloginip" xorm:"'LASTLOGINIP'"` // 最新登录地址
  23. Loginport int32 `json:"loginport" xorm:"'LOGINPORT'"` // 最新登录端口
  24. Lastloginremark string `json:"lastloginremark" xorm:"'LASTLOGINREMARK'"` // 最新登录描述
  25. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  26. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  27. Pwdwrongcount int32 `json:"pwdwrongcount" xorm:"'PWDWRONGCOUNT'"` // 密码错误次数
  28. Unfreezetime time.Time `json:"unfreezetime" xorm:"'UNFREEZETIME'"` // 账户解冻时间
  29. Haslogined int32 `json:"haslogined" xorm:"'HASLOGINED'"` // 是否已登录 - 0:未登录 1:已登录
  30. Hasupdatedpwd int32 `json:"hasupdatedpwd" xorm:"'HASUPDATEDPWD'"` // 是否已更改密码 - 0:未修改 1:已修改
  31. Logincode string `json:"logincode" xorm:"'LOGINCODE'"` // 登录代码
  32. Canoutin int32 `json:"canoutin" xorm:"'CANOUTIN'"` // 是否可出入金 - 0:不可 1:可
  33. Clientroleid int32 `json:"clientroleid" xorm:"'CLIENTROLEID'"` // 终端角色ID
  34. Taaccountrighttype int32 `json:"taaccountrighttype" xorm:"'TAACCOUNTRIGHTTYPE'"` // 资金账号权限类型 - 1:不选默认为所有权限 2:不选默认为无权限
  35. }
  36. // TableName is LOGINACCOUNT
  37. func (Loginaccount) TableName() string {
  38. return "LOGINACCOUNT"
  39. }
  40. // Taaccount 资金账户表 - 导历史
  41. type Taaccount struct {
  42. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账户ID
  43. Userid int64 `json:"userid" xorm:"'USERID'" binding:"required"` // 用户ID
  44. Currencyid int64 `json:"currencyid" xorm:"'CURRENCYID'"` // 货币ID
  45. Changeflag int32 `json:"changeflag" xorm:"'CHANGEFLAG'"` // 变动标志(当前账户资金有任何变动更新为1系统结算时更新0;供清算时使用) 0:无变动 1:有变动
  46. // Password string `json:"password" xorm:"'PASSWORD'"` // 资金密码
  47. Password string `json:"-" xorm:"'PASSWORD'"` // 资金密码
  48. Tradestatus int32 `json:"tradestatus" xorm:"'TRADESTATUS'"` // 交易状态 - 1:正常 2:受限 3:冻结 4:禁止建仓(人工受限) 5:禁止交易(人工冻结) 6:待激活 7:已注销
  49. Signstatus int32 `json:"signstatus" xorm:"'SIGNSTATUS'"` // 签约状态 - 1:未签约 2:签约待审核 3:签约中 4:已签约 5:解约待审核 6:解约中 7:已解约 8:已解绑 9:绑卡中
  50. Ismain int32 `json:"ismain" xorm:"'ISMAIN'"` // 是否母账号 0:不是母账户 1:是母账户
  51. Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属根账号
  52. Relateduserid int64 `json:"relateduserid" xorm:"'RELATEDUSERID'"` // 关联用户
  53. Relatedaccountstatus int32 `json:"relatedaccountstatus" xorm:"'RELATEDACCOUNTSTATUS'"` // 关联用户交易权限状态 - 1:正常(可交易) 2:受限(可平仓,不可建仓) 3:冻结(不可交易)
  54. Taaccounttype int32 `json:"taaccounttype" xorm:"'TAACCOUNTTYPE'"` // 账号类型 - 1:外部账号 2:内部账号 3:内部做市自营账号 4:内部做市接单账号
  55. Isreckonaccount int32 `json:"isreckonaccount" xorm:"'ISRECKONACCOUNT'"` // 是否机构分润账号 0:不是 1:是
  56. Ismarketaccount int32 `json:"ismarketaccount" xorm:"'ISMARKETACCOUNT'"` // 是否机构接单账号 0:不是 1:是
  57. Balance float64 `json:"balance" xorm:"'BALANCE'"` // 期初余额
  58. Orifreezemargin float64 `json:"orifreezemargin" xorm:"'ORIFREEZEMARGIN'"` // 期初冻结保证金
  59. Oriusedmargin float64 `json:"oriusedmargin" xorm:"'ORIUSEDMARGIN'"` // 期初占用保证金
  60. Oriotherfreezemargin float64 `json:"oriotherfreezemargin" xorm:"'ORIOTHERFREEZEMARGIN'"` // 期初其他冻结保证金(出金冻结资金 交割买方冻结 申购冻结 全款买入 商城买入)
  61. Orifreezecharge float64 `json:"orifreezecharge" xorm:"'ORIFREEZECHARGE'"` // 期初手续费冻结
  62. Orimortgagecredit float64 `json:"orimortgagecredit" xorm:"'ORIMORTGAGECREDIT'"` // 期初授信金额
  63. Oriothercredit float64 `json:"oriothercredit" xorm:"'ORIOTHERCREDIT'"` // 期初其它授信金额
  64. Orioutamountfreeze float64 `json:"orioutamountfreeze" xorm:"'ORIOUTAMOUNTFREEZE'"` // 期初出金冻结
  65. Currentbalance float64 `json:"currentbalance" xorm:"'CURRENTBALANCE'"` // 期末余额
  66. Freezemargin float64 `json:"freezemargin" xorm:"'FREEZEMARGIN'"` // 冻结保证金
  67. Usedmargin float64 `json:"usedmargin" xorm:"'USEDMARGIN'"` // 占用保证金
  68. Otherfreezemargin float64 `json:"otherfreezemargin" xorm:"'OTHERFREEZEMARGIN'"` // 其他冻结保证金(交割买方冻结 申购冻结 全款买入 商城买入)
  69. Freezecharge float64 `json:"freezecharge" xorm:"'FREEZECHARGE'"` // 手续费冻结
  70. Mortgagecredit float64 `json:"mortgagecredit" xorm:"'MORTGAGECREDIT'"` // 授信金额
  71. Othercredit float64 `json:"othercredit" xorm:"'OTHERCREDIT'"` // 其它授信金额
  72. Outamountfreeze float64 `json:"outamountfreeze" xorm:"'OUTAMOUNTFREEZE'"` // 出金冻结
  73. Inamount float64 `json:"inamount" xorm:"'INAMOUNT'"` // 今日入金金额(包括三方入金)
  74. Outamount float64 `json:"outamount" xorm:"'OUTAMOUNT'"` // 今日出金金额(包括三方出金)
  75. Paycharge float64 `json:"paycharge" xorm:"'PAYCHARGE'"` // 今日手续费支出
  76. Closepl float64 `json:"closepl" xorm:"'CLOSEPL'"` // 今日平仓盈亏
  77. Creditincrease float64 `json:"creditincrease" xorm:"'CREDITINCREASE'"` // 今日授信增加
  78. Creditdecrease float64 `json:"creditdecrease" xorm:"'CREDITDECREASE'"` // 今日授信减少
  79. Othercreditincrease float64 `json:"othercreditincrease" xorm:"'OTHERCREDITINCREASE'"` // 今日其它授信增加
  80. Othercreditdecrease float64 `json:"othercreditdecrease" xorm:"'OTHERCREDITDECREASE'"` // 今日其它授信减少
  81. Transferamount float64 `json:"transferamount" xorm:"'TRANSFERAMOUNT'"` // 今日划转金额(母子账号资金划转,从划入账号为正,从账号划出为负)
  82. Otherpay float64 `json:"otherpay" xorm:"'OTHERPAY'"` // 其他支出(交割付款 申购付款 全款买入 商城买入 卖家退货)
  83. Otherincome float64 `json:"otherincome" xorm:"'OTHERINCOME'"` // 其他收入(交割收款 申购收款 全款卖出 商城卖出 买家退货 会员手续费收入)
  84. Outthreshold float64 `json:"outthreshold" xorm:"'OUTTHRESHOLD'"` // 出金阈值
  85. Tradestatuschangetime time.Time `json:"tradestatuschangetime" xorm:"'TRADESTATUSCHANGETIME'"` // 激活时间
  86. Changetime time.Time `json:"changetime" xorm:"'CHANGETIME'"` // 账户状态变更时间
  87. Thirdinamount float64 `json:"thirdinamount" xorm:"'THIRDINAMOUNT'"` // 今日三方入金
  88. Thirdoutamount float64 `json:"thirdoutamount" xorm:"'THIRDOUTAMOUNT'"` // 今日三方出金
  89. Capitalbalance float64 `json:"capitalbalance" xorm:"'CAPITALBALANCE'"` // 本金余额[外部子账户实际出入金余额]
  90. Fromaccountid int64 `json:"fromaccountid" xorm:"'FROMACCOUNTID'"` // 所属上级账户
  91. Sublevelpath string `json:"sublevelpath" xorm:"'SUBLEVELPATH'"` // 账号层级路径(逗号分隔,首尾加逗号)
  92. Serivcegroup int64 `json:"serivcegroup" xorm:"'SERIVCEGROUP'"` // 服务分组
  93. Accountname string `json:"accountname" xorm:"'ACCOUNTNAME'"` // 账户名称
  94. Accountflag int32 `json:"accountflag" xorm:"'ACCOUNTFLAG'"` // 账户标识 - 0\1 (默认为0, 当上级账户与本账户的关联用户均为自己时更新为1)
  95. }
  96. // TableName is TAACCOUNT
  97. func (Taaccount) TableName() string {
  98. return "TAACCOUNT"
  99. }
  100. // Hedgeouttaaccount 对冲外部资金账户表 - 导历史
  101. type Hedgeouttaaccount struct {
  102. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账号[外部母账户]
  103. Hedgeaccountcode string `json:"hedgeaccountcode" xorm:"'HEDGEACCOUNTCODE'"` // 对冲账号
  104. Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd)
  105. Prebalance float64 `json:"prebalance" xorm:"'PREBALANCE'"` // 期初余额
  106. Balance float64 `json:"balance" xorm:"'BALANCE'"` // 期末余额
  107. Usedmargin float64 `json:"usedmargin" xorm:"'USEDMARGIN'"` // 占用保证金
  108. Freezemargin float64 `json:"freezemargin" xorm:"'FREEZEMARGIN'"` // 冻结保证金
  109. Freezecharge float64 `json:"freezecharge" xorm:"'FREEZECHARGE'"` // 手续费冻结
  110. Otherfreezemargin float64 `json:"otherfreezemargin" xorm:"'OTHERFREEZEMARGIN'"` // 其他冻结保证金(交割买方冻结 申购冻结 全款买入 商城买入)
  111. Inamount float64 `json:"inamount" xorm:"'INAMOUNT'"` // 今日入金金额(包括三方入金)
  112. Outamount float64 `json:"outamount" xorm:"'OUTAMOUNT'"` // 今日出金金额(包括三方出金)
  113. Paycharge float64 `json:"paycharge" xorm:"'PAYCHARGE'"` // 今日手续费支出
  114. Closepl float64 `json:"closepl" xorm:"'CLOSEPL'"` // 今日平仓盈亏
  115. Positionprofit float64 `json:"positionprofit" xorm:"'POSITIONPROFIT'"` // 结算盈亏
  116. }
  117. // TableName is HEDGE_OUTTAACCOUNT
  118. func (Hedgeouttaaccount) TableName() string {
  119. return "HEDGE_OUTTAACCOUNT"
  120. }
  121. // Logintaaccount 登录账户资金权限表 - 自营会员
  122. type Logintaaccount struct {
  123. Loginid int64 `json:"loginid" xorm:"'LOGINID'" binding:"required"` // 登录账号ID
  124. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账号ID
  125. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  126. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  127. }
  128. // TableName is LOGINTAACCOUNT
  129. func (Logintaaccount) TableName() string {
  130. return "LOGINTAACCOUNT"
  131. }
  132. // Arearolemarket 机构角色市场权限表
  133. type Arearolemarket struct {
  134. Areauserid int64 `json:"areauserid" xorm:"'AREAUSERID'" binding:"required"` // 机构用户ID
  135. Roletype int32 `json:"roletype" xorm:"'ROLETYPE'" binding:"required"` // 角色类型 - 6:自营会员 7:经纪会员
  136. Marketid int32 `json:"marketid" xorm:"'MARKETID'" binding:"required"` // 市场ID
  137. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  138. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人ID
  139. Spotrighttype int32 `json:"spotrighttype" xorm:"'SPOTRIGHTTYPE'"` // 现货权限类型 - 0:无 1:可挂可摘 2:可挂 3:可摘 [现货类](卖大厅)
  140. Buyspotrighttype int32 `json:"buyspotrighttype" xorm:"'BUYSPOTRIGHTTYPE'"` // 现货权限类型 - 0:无 1:可挂可摘 2:可挂 3:可摘 [现货类](买大厅)
  141. }
  142. // TableName is AREAROLEMARKET
  143. func (Arearolemarket) TableName() string {
  144. return "AREAROLEMARKET"
  145. }
  146. // Taaccountmarket 资金账号市场权限表
  147. type Taaccountmarket struct {
  148. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账号ID
  149. Marketid int32 `json:"marketid" xorm:"'MARKETID'" binding:"required"` // 市场ID
  150. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  151. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  152. Spotrighttype int32 `json:"spotrighttype" xorm:"'SPOTRIGHTTYPE'"` // 现货权限类型 - 0:无1:可挂可摘 2:可挂 3:可摘 [现货类](卖大厅)
  153. Buyspotrighttype int32 `json:"buyspotrighttype" xorm:"'BUYSPOTRIGHTTYPE'"` // 现货权限类型 - 0:无1:可挂可摘 2:可挂 3:可摘 [现货类](买大厅)
  154. }
  155. // TableName is TAACCOUNTMARKET
  156. func (Taaccountmarket) TableName() string {
  157. return "TAACCOUNTMARKET"
  158. }
  159. // Useraccount 用户表
  160. type Useraccount struct {
  161. Userid int64 `json:"userid" xorm:"'USERID'" binding:"required"` // 用户ID
  162. Usertype int32 `json:"usertype" xorm:"'USERTYPE'"` // 账户类型 - 1:交易所 2:机构 3:会员子机构 4:经纪人 5:投资者 6:客户
  163. Accountname string `json:"accountname" xorm:"'ACCOUNTNAME'"` // 账户名称(机构名称)
  164. Parentuserid int64 `json:"parentuserid" xorm:"'PARENTUSERID'"` // 所属机构ID
  165. Broker int64 `json:"broker" xorm:"'BROKER'"` // 所属经纪人ID
  166. Subarealevelpath string `json:"subarealevelpath" xorm:"'SUBAREALEVELPATH'"` // 子机构层级路径(逗号分隔,首尾加逗号)
  167. Refereeuserid int64 `json:"refereeuserid" xorm:"'REFEREEUSERID'"` // 推荐人ID
  168. Memberuserid int64 `json:"memberuserid" xorm:"'MEMBERUSERID'"` // 所属会员ID
  169. Accountstatus int32 `json:"accountstatus" xorm:"'ACCOUNTSTATUS'"` // 账户状态 - 1:待激活 2:待审核 3:待复审 4:正常 5:审核拒绝 6:注销
  170. Reckonaccountid int64 `json:"reckonaccountid" xorm:"'RECKONACCOUNTID'"` // 默认结算资金账号ID(机构分润使用) 作废
  171. Modifystatus int32 `json:"modifystatus" xorm:"'MODIFYSTATUS'"` // 变更状态 1 未变更 2 变更中 3 变更待审核 4 变更待复核(投资者)
  172. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间
  173. Creatorid int64 `json:"creatorid" xorm:"'CREATORID'"` // 创建人
  174. Audittime time.Time `json:"audittime" xorm:"'AUDITTIME'"` // 审核时间
  175. Audituserid int64 `json:"audituserid" xorm:"'AUDITUSERID'"` // 审核人
  176. Auditremark string `json:"auditremark" xorm:"'AUDITREMARK'"` // 审核备注
  177. Canceltime time.Time `json:"canceltime" xorm:"'CANCELTIME'"` // 销户时间
  178. Canceluserid int64 `json:"canceluserid" xorm:"'CANCELUSERID'"` // 销户人
  179. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  180. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  181. Modifyremark string `json:"modifyremark" xorm:"'MODIFYREMARK'"` // 变更备注
  182. Maxinvestornum int64 `json:"maxinvestornum" xorm:"'MAXINVESTORNUM'"` // 最大用户数(经纪会员下投资者个数)
  183. Hasauth int32 `json:"hasauth" xorm:"'HASAUTH'"` // 是否已实名认证 - 0:未认证 1:已认证 2:已提交(待审核) 3:已拒绝
  184. Refercount int32 `json:"refercount" xorm:"'REFERCOUNT'"` // 推荐总人数
  185. Refernum string `json:"refernum" xorm:"'REFERNUM'"` // 推荐码
  186. Isanonymous int32 `json:"isanonymous" xorm:"'ISANONYMOUS'"` // 是否匿名下单 - 0:否 1:是
  187. }
  188. // TableName is USERACCOUNT
  189. func (Useraccount) TableName() string {
  190. return "USERACCOUNT"
  191. }
  192. // Userinfo 用户信息表
  193. type Userinfo struct {
  194. Userid int64 `json:"userid" xorm:"'USERID'" binding:"required"` // 用户ID
  195. Userinfotype int32 `json:"userinfotype" xorm:"'USERINFOTYPE'"` // 用户信息类型 - 1:个人 2:企业
  196. Customername string `json:"customername" xorm:"'CUSTOMERNAME'"` // 客户名称(企业名称)
  197. Userstatus int32 `json:"userstatus" xorm:"'USERSTATUS'"` // 用户状态 - 1:正常 2:注销
  198. Usertype int32 `json:"usertype" xorm:"'USERTYPE'"` // 账户类型 - 1:交易所 2:机构 3:会员子机构 4:经纪人 5:投资者 6:客户
  199. Openmode int32 `json:"openmode" xorm:"'OPENMODE'"` // 开户方式 - 1:管理端开户 2:网上开户注册(会员官网) 3:微信开户 4:网页交易端注册 5:安卓手机端注册 6:苹果手机端注册 7:PC交易端注册 8:微信快速开户 9:支付宝快速开户 10:手机号快速开户
  200. Cardtypeid int32 `json:"cardtypeid" xorm:"'CARDTYPEID'"` // 证件类型ID
  201. Cardnum string `json:"cardnum" xorm:"'CARDNUM'"` // 证件号码(加密存储)
  202. Halfbodyphotourl string `json:"halfbodyphotourl" xorm:"'HALFBODYPHOTOURL'"` // 半身照地址
  203. Cardfrontphotourl string `json:"cardfrontphotourl" xorm:"'CARDFRONTPHOTOURL'"` // 证件正面图片地址
  204. Cardbackphotourl string `json:"cardbackphotourl" xorm:"'CARDBACKPHOTOURL'"` // 证件背面图片地址
  205. Biznature int32 `json:"biznature" xorm:"'BIZNATURE'"` // 企业性质( 企业) - 1:国有控股企业 2:集体控股企业 3:私人控股企业 4:港澳台商控股企业 5:外商控股企业 6:其它
  206. Bizscope string `json:"bizscope" xorm:"'BIZSCOPE'"` // 企业经营范围(企业)
  207. Legalpersonname string `json:"legalpersonname" xorm:"'LEGALPERSONNAME'"` // 法人姓名(企业)
  208. Contactname string `json:"contactname" xorm:"'CONTACTNAME'"` // 联系人
  209. Sex int32 `json:"sex" xorm:"'SEX'"` // 用户性别 0: 女 1: 男
  210. Telphone string `json:"telphone" xorm:"'TELPHONE'"` // 联系电话(加密存储)
  211. Mobile string `json:"mobile" xorm:"'MOBILE'"` // 手机号码(加密存储)
  212. Fax string `json:"fax" xorm:"'FAX'"` // 传真(加密存储)
  213. Email string `json:"email" xorm:"'EMAIL'"` // 邮件(加密存储)
  214. Qq string `json:"qq" xorm:"'QQ'"` // QQ(加密存储
  215. Wechat string `json:"wechat" xorm:"'WECHAT'"` // 微信(加密存储)
  216. Countryid int32 `json:"countryid" xorm:"'COUNTRYID'"` // 国家
  217. Provinceid int32 `json:"provinceid" xorm:"'PROVINCEID'"` // 省
  218. Cityid int32 `json:"cityid" xorm:"'CITYID'"` // 市
  219. Districtid int32 `json:"districtid" xorm:"'DISTRICTID'"` // 地区
  220. Company string `json:"company" xorm:"'COMPANY'"` // 公司(个人)
  221. Address string `json:"address" xorm:"'ADDRESS'"` // 地址
  222. Postalcode string `json:"postalcode" xorm:"'POSTALCODE'"` // 邮政编码
  223. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间
  224. Creatorid int64 `json:"creatorid" xorm:"'CREATORID'"` // 创建人
  225. Modifiertime time.Time `json:"modifiertime" xorm:"'MODIFIERTIME'"` // 修改时间
  226. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  227. Remark string `json:"remark" xorm:"'REMARK'"` // 备注
  228. Wskhinfo string `json:"wskhinfo" xorm:"'WSKHINFO'"` // 开户申请信息(JSON)
  229. Signpdfurl string `json:"signpdfurl" xorm:"'SIGNPDFURL'"` // 签约pdf文件
  230. Legalcardfrontphotourl string `json:"legalcardfrontphotourl" xorm:"'LEGALCARDFRONTPHOTOURL'"` // 法人身份证正面照地址
  231. Legalcardbackphotourl string `json:"legalcardbackphotourl" xorm:"'LEGALCARDBACKPHOTOURL'"` // 法人身份证背面照地址
  232. Otherurl string `json:"otherurl" xorm:"'OTHERURL'"` // 其它图片地址[使用分号分隔]
  233. Hasencrypt int32 `json:"hasencrypt" xorm:"'HASENCRYPT'"` // 数据是否已加密 - 0:未加密 1:已加密
  234. Bankname string `json:"bankname" xorm:"'BANKNAME'"` // 银行名称
  235. Bankaccount string `json:"bankaccount" xorm:"'BANKACCOUNT'"` // 银行帐号 (加密存储)
  236. Bankcardfrontphotourl string `json:"bankcardfrontphotourl" xorm:"'BANKCARDFRONTPHOTOURL'"` // 银行卡正面照地址
  237. Needinvoice int32 `json:"needinvoice" xorm:"'NEEDINVOICE'"` // 是否需要发票 - 0:不需要 1:需要
  238. Bankid string `json:"bankid" xorm:"'BANKID'"` // 银行编码
  239. Attachment1 string `json:"attachment1" xorm:"'ATTACHMENT1'"` // 附件1
  240. Attachment2 string `json:"attachment2" xorm:"'ATTACHMENT2'"` // 附件2
  241. Bankaccountname string `json:"bankaccountname" xorm:"'BANKACCOUNTNAME'"` // 收款人名称
  242. Headurl string `json:"headurl" xorm:"'HEADURL'"` // 头像地址
  243. Nickname string `json:"nickname" xorm:"'NICKNAME'"` // 昵称:默认为名称脱敏(张**) 或 手机号脱敏(139****9999)
  244. Mobile2 string `json:"mobile2" xorm:"'MOBILE2'"` // 手机号码[明文-尚志]
  245. }
  246. // TableName is USERINFO
  247. func (Userinfo) TableName() string {
  248. return "USERINFO"
  249. }
  250. // Quoter 报价商表
  251. type Quoter struct {
  252. Quoterid int64 `json:"quoterid" xorm:"'QUOTERID'" binding:"required"` // 报价商ID(自增ID)
  253. Quotername string `json:"quotername" xorm:"'QUOTERNAME'" binding:"required"` // 报价商名称
  254. Areauserid int64 `json:"areauserid" xorm:"'AREAUSERID'" binding:"required"` // 所属机构ID
  255. Tradeproperty int32 `json:"tradeproperty" xorm:"'TRADEPROPERTY'"` // 交易属性
  256. Defaultmakerid int64 `json:"defaultmakerid" xorm:"'DEFAULTMAKERID'"` // 默认做市商ID(UserID)
  257. Quoterstatus int32 `json:"quoterstatus" xorm:"'QUOTERSTATUS'"` // 报价商状态 - 1:正常 2:注销
  258. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  259. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  260. Matchmode int32 `json:"matchmode" xorm:"'MATCHMODE'"` // 对手模式: 1-经纪会员自接 2:按对手关系[收益权用]
  261. }
  262. // TableName is QUOTER
  263. func (Quoter) TableName() string {
  264. return "QUOTER"
  265. }
  266. // Arearole 机构角色表
  267. type Arearole struct {
  268. Userid int64 `json:"userid" xorm:"'USERID'" binding:"required"` // 机构用户ID其他做市关系,都设置为 1
  269. Roletype int32 `json:"roletype" xorm:"'ROLETYPE'" binding:"required"` // 角色类型 - 1:交易所 2:运营机构 3:营销中心 4:仓库机构 5:三方服务机构 6:自营会员 7:经纪会员 8:做市会员 9:产业会员 10:金融机构 11:商城店铺 12:子机构 13:报价商 14:积分服务商 15:供货商 16:圈内会员 17:物流机构 18:报价配置机构 19:场外期权做市商 20:组织机构 21:顶级机构
  270. Tradeaccountid int64 `json:"tradeaccountid" xorm:"'TRADEACCOUNTID'"` // 默认交易资金账号ID(做市会员被动接单使用、商城店铺默认资金账 号、圈内会员默认资金账号) - 作废, 使用UserReckonAccount
  271. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间
  272. Creatorid int64 `json:"creatorid" xorm:"'CREATORID'"` // 创建人ID
  273. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  274. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人ID
  275. Shoppassword string `json:"shoppassword" xorm:"'SHOPPASSWORD'"` // 商城店铺登陆密码(商城店铺角色使用)
  276. Isreturnscore int32 `json:"isreturnscore" xorm:"'ISRETURNSCORE'"` // 是否返还积分 [经纪会员-辽东湾] - 0:不返还 1:返还
  277. Transurl string `json:"transurl" xorm:"'TRANSURL'"` // 物流地址(物流机构)
  278. Outuserid string `json:"outuserid" xorm:"'OUTUSERID'"` // 外部账户[场外期权做市商]
  279. Parentuserid int64 `json:"parentuserid" xorm:"'PARENTUSERID'"` // 上级组织机构(组织机构)
  280. Rootuserid int64 `json:"rootuserid" xorm:"'ROOTUSERID'"` // 顶级组织机构用户ID(组织机构)
  281. Sublevelpath string `json:"sublevelpath" xorm:"'SUBLEVELPATH'"` // 组织机构层级路径(逗号分隔,首尾加逗号)
  282. Orgtype int32 `json:"orgtype" xorm:"'ORGTYPE'"` // 组织机构类型 1:机构 2:交易员
  283. }
  284. // TableName is AREAROLE
  285. func (Arearole) TableName() string {
  286. return "AREAROLE"
  287. }
  288. // Taaccountlog 资金账户记账流水表 - 导历史
  289. type Taaccountlog struct {
  290. Autoid int64 `json:"autoid" xorm:"'AUTOID'" binding:"required"` // 流水ID(220+Unix秒时间戳(10位)+xxxxxx)
  291. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账户ID
  292. Relationorderid string `json:"relationorderid" xorm:"'RELATIONORDERID'"` // 关联单号
  293. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  294. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  295. Currencyid int64 `json:"currencyid" xorm:"'CURRENCYID'"` // 币种ID
  296. Amount float64 `json:"amount" xorm:"'AMOUNT'" binding:"required"` // 资金金额
  297. Amountadjusttype int32 `json:"amountadjusttype" xorm:"'AMOUNTADJUSTTYPE'" binding:"required"` // 资金调整类型(默认值为0) - 0:系统 1:单边账调整 2:人工调整
  298. Balance float64 `json:"balance" xorm:"'BALANCE'" binding:"required"` // 期初余额
  299. Currentbalance float64 `json:"currentbalance" xorm:"'CURRENTBALANCE'" binding:"required"` // 期末余额(变动后金额)
  300. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'" binding:"required"` // 发生时间
  301. Operatetype int32 `json:"operatetype" xorm:"'OPERATETYPE'" binding:"required"` // 资金操作类型 (AccountFundCmdOp)- 101:入金 102:入金手续费 103:出金 104:出金冻结 105:出金解冻 106:出金手续费 107:出金手续费冻结 108:出金手续费解冻 201:交易冻结 202:交易解冻 203:交易占用 204:交易解占用 205:交易手续费冻结 206:交易手续费解冻 207:交易手续费 208:交易货款 209:交易盈亏 301:交割冻结 302:交割解冻 303:交割手续费 304:交割手续费冻结 305:交割手续费解冻 306:交割货款 307:交割税款 401:结算盈亏 402:结算递延费 403:分润收入 404:延期分润 501:授信增加 502:授信减少 503:转积分 504:转入 505:转出 506:转出冻结 507:转出解冻 601:履约金额冻结 602:履约最大冻结 603:履约金额解冻 604:履约扣款 605:履约收款 606:履约违约手续费 607:履约违约收入 608:履约最大扣款 701:供应链金融冻结 702:供应链金融解冻 703:供应链金融最大冻结 704:供应链金融利息 705:供应链金融货款 706:供应链金融押金 707:供应链金融最大扣款 801:仓单贸易冻结 802:仓单贸易解冻 803:仓单贸易首付款 804:仓单贸易最大扣款 901:商城扣款冻结 902:商城扣款解冻 903:商城扣款 904:商城收款 1001:期权冻结 1002:期权解冻 1003:期权权力金 1004:期权手续费冻结 1005:期权手续费解冻 1006:期权手续费 1007:期权盈亏 1101:营销扣款 1102:营销收款
  302. Moneyticket int64 `json:"moneyticket" xorm:"'MONEYTICKET'"` // 资金流水号:银行端流水号
  303. Remark string `json:"remark" xorm:"'REMARK'"` // 备注
  304. Businesscode int32 `json:"businesscode" xorm:"'BUSINESSCODE'"` // 业务编号
  305. }
  306. // TableName is TAACCOUNTLOG
  307. func (Taaccountlog) TableName() string {
  308. return "TAACCOUNTLOG"
  309. }
  310. // Histaaccountlog 历史资金账户记账流水表
  311. type Histaaccountlog struct {
  312. Autoid int64 `json:"autoid" xorm:"'AUTOID'" binding:"required"` // 流水ID(220+Unix秒时间戳(10位)+xxxxxx)
  313. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账户ID
  314. Relationorderid string `json:"relationorderid" xorm:"'RELATIONORDERID'"` // 关联单号
  315. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  316. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  317. Currencyid int64 `json:"currencyid" xorm:"'CURRENCYID'"` // 币种ID
  318. Amount float64 `json:"amount" xorm:"'AMOUNT'" binding:"required"` // 资金金额
  319. Amountadjusttype int32 `json:"amountadjusttype" xorm:"'AMOUNTADJUSTTYPE'" binding:"required"` // 资金调整类型(默认值为0) - 0:系统 1:单边账调整 2:人工调整
  320. Balance float64 `json:"balance" xorm:"'BALANCE'" binding:"required"` // 期初余额
  321. Currentbalance float64 `json:"currentbalance" xorm:"'CURRENTBALANCE'" binding:"required"` // 期末余额(变动后金额)
  322. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'" binding:"required"` // 发生时间
  323. Operatetype int32 `json:"operatetype" xorm:"'OPERATETYPE'" binding:"required"` // 资金操作类型 (AccountFundCmdOp)- 101:入金 102:入金手续费 103:出金 104:出金冻结 105:出金解冻 106:出金手续费 107:出金手续费冻结 108:出金手续费解冻 201:交易冻结 202:交易解冻 203:交易占用 204:交易解占用 205:交易手续费冻结 206:交易手续费解冻 207:交易手续费 208:交易货款 209:交易盈亏 301:交割冻结 302:交割解冻 303:交割手续费 304:交割手续费冻结 305:交割手续费解冻 306:交割货款 307:交割税款 401:结算盈亏 402:结算递延费 403:分润收入 404:延期分润 501:授信增加 502:授信减少 503:转积分 504:转入 505:转出 506:转出冻结 507:转出解冻 601:履约金额冻结 602:履约最大冻结 603:履约金额解冻 604:履约扣款 605:履约收款 606:履约违约手续费 607:履约违约收入 608:履约最大扣款 701:供应链金融冻结 702:供应链金融解冻 703:供应链金融最大冻结 704:供应链金融利息 705:供应链金融货款 706:供应链金融押金 707:供应链金融最大扣款 801:仓单贸易冻结 802:仓单贸易解冻 803:仓单贸易首付款 804:仓单贸易最大扣款 901:商城扣款冻结 902:商城扣款解冻 903:商城扣款 904:商城收款 1001:期权冻结 1002:期权解冻 1003:期权权力金 1004:期权手续费冻结 1005:期权手续费解冻 1006:期权手续费 1007:期权盈亏 1101:营销扣款 1102:营销收款
  324. Moneyticket int64 `json:"moneyticket" xorm:"'MONEYTICKET'"` // 资金流水号:银行端流水号
  325. Remark string `json:"remark" xorm:"'REMARK'"` // 备注
  326. Businesscode int32 `json:"businesscode" xorm:"'BUSINESSCODE'"` // 业务编号
  327. Histradedate string `json:"histradedate" xorm:"'HISTRADEDATE'" binding:"required"` // 历史交易日
  328. Isvaliddata int32 `json:"isvaliddata" xorm:"'ISVALIDDATA'"` // 是否有效 - 0:无效 1:有效
  329. }
  330. // TableName is HIS_TAACCOUNTLOG
  331. func (Histaaccountlog) TableName() string {
  332. return "HIS_TAACCOUNTLOG"
  333. }
  334. // Userfavoritegoods 用户商品收藏表
  335. type Userfavoritegoods struct {
  336. Userid int64 `json:"-" xorm:"'USERID'" binding:"required"` // 用户
  337. Goodsid int64 `json:"goodsid" xorm:"'GOODSID'" binding:"required"` // 商品ID
  338. Marketid int32 `json:"-" xorm:"'MARKETID'"` // 市场ID
  339. Modifytime time.Time `json:"-" xorm:"'MODIFYTIME'"` // 修改时间
  340. }
  341. // TableName is USERFAVORITEGOODS
  342. func (Userfavoritegoods) TableName() string {
  343. return "USERFAVORITEGOODS"
  344. }
  345. // Messageboard 留言簿表
  346. type Messageboard struct {
  347. Messageboardid int64 `json:"messageboardid" xorm:"'MESSAGEBOARDID'" binding:"required"` // 留言簿ID(SEQ_MessageBoard)
  348. Userid int64 `json:"userid" xorm:"'USERID'"` // 用户ID
  349. Message string `json:"message" xorm:"'MESSAGE'"` // 留言信息
  350. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间
  351. Contactnum string `json:"contactnum" xorm:"'CONTACTNUM'"` // 联系电话
  352. }
  353. // TableName is MESSAGEBOARD
  354. func (Messageboard) TableName() string {
  355. return "MESSAGEBOARD"
  356. }
  357. // Wskhuserinfo 网上开户用户表 (开户成功删除记录)
  358. type Wskhuserinfo struct {
  359. Userid int64 `json:"userid" xorm:"USERID" binding:"required"` // 用户ID(自增ID)SEQ_WSKH_USERINFO
  360. Username string `json:"username" xorm:"USERNAME"` // 用户姓名
  361. Sex int32 `json:"sex" xorm:"SEX"` // 性别 - 0:女 1:男
  362. Cardtype int32 `json:"cardtype" xorm:"CARDTYPE"` // 证件类型
  363. Cardnum string `json:"cardnum" xorm:"CARDNUM"` // 证件号码 (加密存储)
  364. Cardaddress string `json:"cardaddress" xorm:"CARDADDRESS"` // 证件地址 (加密存储)
  365. Mobilephone string `json:"mobilephone" xorm:"MOBILEPHONE"` // 手机号码 (加密存储)
  366. Wechat string `json:"wechat" xorm:"WECHAT"` // 微信号 (加密存储)
  367. Email string `json:"email" xorm:"EMAIL"` // Email地址(加密存储)
  368. Ipaddress string `json:"ipaddress" xorm:"IPADDRESS"` // IP地址
  369. Halfbodyphotourl string `json:"halfbodyphotourl" xorm:"HALFBODYPHOTOURL"` // 半身照地址
  370. Cardfrontphotourl string `json:"cardfrontphotourl" xorm:"CARDFRONTPHOTOURL"` // 正面证件照地址
  371. Cardbackphotourl string `json:"cardbackphotourl" xorm:"CARDBACKPHOTOURL"` // 背面证件照地址
  372. Bankid string `json:"bankid" xorm:"BANKID"` // 银行编码
  373. Bankname string `json:"bankname" xorm:"BANKNAME"` // 银行名称
  374. Bankaccount string `json:"bankaccount" xorm:"BANKACCOUNT"` // 银行帐号 (加密存储)
  375. Bankcardfrontphotourl string `json:"bankcardfrontphotourl" xorm:"BANKCARDFRONTPHOTOURL"` // 银行卡正面照地址
  376. Bankcardbackphotourl string `json:"bankcardbackphotourl" xorm:"BANKCARDBACKPHOTOURL"` // 银行卡背面照地址
  377. Areacode string `json:"areacode" xorm:"AREACODE"` // 机构代码
  378. Areaid int64 `json:"areaid" xorm:"AREAID"` // 机构Id
  379. Memberareaid int64 `json:"memberareaid" xorm:"MEMBERAREAID"` // 所属会员ID
  380. Brokerid string `json:"brokerid" xorm:"BROKERID"` // 经纪人ID(加密存储)
  381. Accountid int64 `json:"accountid" xorm:"ACCOUNTID"` // 交易系统帐号Id (加密存储)
  382. Logincode string `json:"logincode" xorm:"LOGINCODE"` // 登录帐号 (加密存储)
  383. Openmode int32 `json:"openmode" xorm:"OPENMODE"` // 开户方式 - 1:管理端开户 2:网上开户注册(会员官网-手机号) 3:微信开户 4:网页交易端注册 5:安卓手机端注册 6:苹果手机端注册 7:PC交易端注册 8:微信快速开户 9:支付宝快速开户 10:手机号快速开户 11:网上开户注册(会员官网-微信认证) 12:网上开户注册(会员官网-支付宝认证)
  384. Userstate int32 `json:"userstate" xorm:"USERSTATE"` // 开户状态 - 1:未提交 2: 待初审 3:初审拒绝 4:待复审 5:复审拒绝 6:测评不通过
  385. Remark string `json:"remark" xorm:"REMARK"` // 备注
  386. Isvalidate string `json:"isvalidate" xorm:"ISVALIDATE"` // 是否有效 (删除后标记为失效) - 0:无效 1:有效
  387. Createtime time.Time `json:"createtime" xorm:"CREATETIME"` // 开户申请时间
  388. Modifiedtime time.Time `json:"modifiedtime" xorm:"MODIFIEDTIME"` // 修改时间
  389. Modifiedby int64 `json:"modifiedby" xorm:"MODIFIEDBY"` // 修改人帐号
  390. Removebeforestatus int32 `json:"removebeforestatus" xorm:"REMOVEBEFORESTATUS"` // REMOVEBEFORESTATUS
  391. Cusbankid string `json:"cusbankid" xorm:"CUSBANKID"` // 签约类型
  392. Cusbankname string `json:"cusbankname" xorm:"CUSBANKNAME"` // 签约类型名称
  393. Signpdfurl string `json:"signpdfurl" xorm:"SIGNPDFURL"` // 签约pdf文件
  394. Referral string `json:"referral" xorm:"REFERRAL"` // 推荐人编码
  395. Subbranch string `json:"subbranch" xorm:"SUBBRANCH"` // 开户支行
  396. Bankpictureurl string `json:"bankpictureurl" xorm:"BANKPICTUREURL"` // 银行卡正面地址
  397. Auditime time.Time `json:"auditime" xorm:"AUDITIME"` // 审核时间
  398. Auditedby time.Time `json:"auditedby" xorm:"AUDITEDBY"` // 审核人
  399. Videourl string `json:"videourl" xorm:"VIDEOURL"` // 视频地址
  400. Signedstatus int32 `json:"signedstatus" xorm:"SIGNEDSTATUS"` // 账户一号签签约状态
  401. Userinfotype int32 `json:"userinfotype" xorm:"USERINFOTYPE"` // 用户信息类型 - 1:个人 2:企业
  402. Customername string `json:"customername" xorm:"CUSTOMERNAME"` // 客户名称(企业名称)
  403. Biznature int32 `json:"biznature" xorm:"BIZNATURE"` // 企业性质( 企业) - 1:国有控股企业 2:集体控股企业 3:私人控股企业 4:港澳台商控股企业 5:外商控股企业 6:其它
  404. Bizscope string `json:"bizscope" xorm:"BIZSCOPE"` // 企业经营范围(企业)
  405. Legalpersonname string `json:"legalpersonname" xorm:"LEGALPERSONNAME"` // 法人姓名(企业)
  406. Contactname string `json:"contactname" xorm:"CONTACTNAME"` // 联系人
  407. Countryid int32 `json:"countryid" xorm:"COUNTRYID"` // 国家
  408. Provinceid int32 `json:"provinceid" xorm:"PROVINCEID"` // 省
  409. Cityid int32 `json:"cityid" xorm:"CITYID"` // 市
  410. Districtid int32 `json:"districtid" xorm:"DISTRICTID"` // 地区
  411. Postalcode string `json:"postalcode" xorm:"POSTALCODE"` // 邮政编码
  412. Company string `json:"company" xorm:"COMPANY"` // 公司(个人)
  413. Legalcardfrontphotourl string `json:"legalcardfrontphotourl" xorm:"LEGALCARDFRONTPHOTOURL"` // 法人身份证正面照地址
  414. Legalcardbackphotourl string `json:"legalcardbackphotourl" xorm:"LEGALCARDBACKPHOTOURL"` // 法人身份证背面照地址
  415. Otherurl string `json:"otherurl" xorm:"OTHERURL"` // 其它图片地址[使用分号分隔]
  416. Usertype int32 `json:"usertype" xorm:"USERTYPE"` // 用户类型 - 1:投资者 2:机构
  417. Qq string `json:"qq" xorm:"QQ"` // QQ(加密存储
  418. Telphone string `json:"telphone" xorm:"TELPHONE"` // 联系电话(加密存储)
  419. Attachment1 string `json:"attachment1" xorm:"ATTACHMENT1"` // 附件1
  420. Attachment2 string `json:"attachment2" xorm:"ATTACHMENT2"` // 附件2
  421. Bankaccountname string `json:"bankaccountname" xorm:"BANKACCOUNTNAME"` // 收款人名称
  422. Nickname string `json:"nickname" xorm:"NICKNAME"` // 昵称:默认为手机号脱敏(139****9999) 或 名称脱敏(张**)
  423. Headurl string `json:"headurl" xorm:"HEADURL"` // 头像地址
  424. Mobile2 string `json:"mobile2" xorm:"MOBILE2"` // 手机号码[明文-尚志]
  425. Biztype int32 `json:"biztype" xorm:"BIZTYPE"` // 企业类型 - 1:进口/生产 2:销售 3:零售 4:运输 5:仓储
  426. Proxystatementurl string `json:"proxystatementurl" xorm:"PROXYSTATEMENTURL"` // 授权委托书
  427. Contactcardfrontphotourl string `json:"contactcardfrontphotourl" xorm:"CONTACTCARDFRONTPHOTOURL"` // 联系人证件正面图片地址
  428. Contactcardbackphotourl string `json:"contactcardbackphotourl" xorm:"CONTACTCARDBACKPHOTOURL"` // 联系人证件背面图片地址
  429. Attachment3 string `json:"attachment3" xorm:"ATTACHMENT3"` // 附件3
  430. Attachment4 string `json:"attachment4" xorm:"ATTACHMENT4"` // 附件4
  431. Attachment5 string `json:"attachment5" xorm:"ATTACHMENT5"` // 附件5
  432. Auditsrc int32 `json:"auditsrc" xorm:"AUDITSRC"` // 审核来源 - 1:管理端 2:终端
  433. Taxpayernum string `json:"taxpayernum" xorm:"TAXPAYERNUM"` // 纳税人识别号
  434. }
  435. // TableName is WSKH_USERINFO
  436. func (Wskhuserinfo) TableName() string {
  437. return "WSKH_USERINFO"
  438. }
  439. // Systemmanager 系统管理员表
  440. type Systemmanager struct {
  441. Autoid int32 `json:"autoid" xorm:"'AUTOID'" binding:"required"` // 自增ID
  442. Reletype int32 `json:"reletype" xorm:"'RELETYPE'"` // 用户类型 - 1- 交易所管理员 2- 机构管理员 3-子机构管理员
  443. Logincode string `json:"logincode" xorm:"'LOGINCODE'"` // 用户登录账号,唯一索引
  444. Username string `json:"username" xorm:"'USERNAME'"` // 用户姓名
  445. Password string `json:"password" xorm:"'PASSWORD'"` // 加密方式采用 用户名+密码 ,采用 SHA 算法
  446. Areauserid int64 `json:"areauserid" xorm:"'AREAUSERID'"` // 所属机构ID
  447. Pwdexpdate time.Time `json:"pwdexpdate" xorm:"'PWDEXPDATE'"` // 密码失效日期
  448. Managerstatus int32 `json:"managerstatus" xorm:"'MANAGERSTATUS'"` // 用户状态: 1启用 2停用 3锁定(密码错误时锁定)
  449. Loginstatus int32 `json:"loginstatus" xorm:"'LOGINSTATUS'"` // 登录状态:1未登录 2已登录
  450. Isdefault int32 `json:"isdefault" xorm:"'ISDEFAULT'"` // 是否默认管理员 - 0:不是默认 1:默认管理员
  451. Logintime time.Time `json:"logintime" xorm:"'LOGINTIME'"` // 登录时间
  452. Loginip string `json:"loginip" xorm:"'LOGINIP'"` // 登录IP
  453. Loginport int64 `json:"loginport" xorm:"'LOGINPORT'"` // 登录端口
  454. Loginfailnum int64 `json:"loginfailnum" xorm:"'LOGINFAILNUM'"` // 登录失败次数
  455. Uploginid int64 `json:"uploginid" xorm:"'UPLOGINID'"` // 修改人ID
  456. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  457. Remark string `json:"remark" xorm:"'REMARK'"` // 备注
  458. Onymac int32 `json:"onymac" xorm:"'ONYMAC'"` // 是否启用MAC地址 - 0:否 1:是
  459. Managertype int32 `json:"managertype" xorm:"'MANAGERTYPE'"` // 账号类型 - 1:管理员 2:交易员
  460. }
  461. // TableName is SYSTEMMANAGER
  462. func (Systemmanager) TableName() string {
  463. return "SYSTEMMANAGER"
  464. }
  465. // GetLoginAccount 获取登录账户信息
  466. func GetLoginAccount(loginID int) (*Loginaccount, error) {
  467. var loginaccount Loginaccount
  468. // var loginaccount Loginaccount
  469. has, err := db.GetEngine().Where("LOGINID = ?", loginID).Get(&loginaccount)
  470. if err != nil {
  471. return nil, err
  472. }
  473. if !has {
  474. return nil, nil
  475. }
  476. return &loginaccount, nil
  477. }
  478. // GetLoginAccountByLoginCode 通过登录代码查询登录账号信息
  479. func GetLoginAccountByLoginCode(loginCode string) (*Loginaccount, error) {
  480. engine := db.GetEngine()
  481. // 如果要使用 *Loginaccount, 则应初始化后再使用
  482. var loginaccount *Loginaccount
  483. loginaccount = &Loginaccount{}
  484. // var loginaccount Loginaccount
  485. has, err := engine.Where("LOGINCODE = ?", loginCode).Get(loginaccount)
  486. if err != nil {
  487. return nil, err
  488. }
  489. if has {
  490. return loginaccount, nil
  491. }
  492. return nil, nil
  493. }
  494. // GetLoginAccountByMobile 通过手机号码查询登录账号信息
  495. func GetLoginAccountByMobile(mobile string) (*Loginaccount, error) {
  496. engine := db.GetEngine()
  497. var loginaccount Loginaccount
  498. var has bool
  499. // 手机号码需要AES加密
  500. key, _ := hex.DecodeString(utils.AESSecretKey)
  501. if mobileEncrypted, err := utils.AESEncrypt([]byte(mobile), key); err == nil {
  502. // 加密成功后进行查询
  503. has, err = engine.Join("INNER", "USERINFO", "USERINFO.USERID = LOGINACCOUNT.USERID").
  504. Where("USERINFO.MOBILE = ?", hex.EncodeToString(mobileEncrypted)).Get(&loginaccount)
  505. if err != nil {
  506. return nil, err
  507. }
  508. }
  509. if has {
  510. return &loginaccount, nil
  511. }
  512. return nil, nil
  513. }
  514. // GetUserAccount 获取用户账户信息
  515. func GetUserAccount(userID int) (*Useraccount, error) {
  516. engine := db.GetEngine()
  517. var userAccount Useraccount
  518. has, err := engine.Where("USERID = ?", userID).Get(&userAccount)
  519. if err != nil {
  520. // 查询失败
  521. return nil, err
  522. }
  523. if !has {
  524. return nil, nil
  525. }
  526. return &userAccount, nil
  527. }
  528. // GetUserInfo 获取用户信息
  529. func GetUserInfo(userID int) (*Userinfo, error) {
  530. engine := db.GetEngine()
  531. var userInfo Userinfo
  532. _, err := engine.Where("USERID = ?", userID).Get(&userInfo)
  533. if err != nil {
  534. // 查询失败
  535. return nil, err
  536. }
  537. return &userInfo, nil
  538. }
  539. // GetUserInfoByLoginID 通过登录账号获取用户信息的方法
  540. func GetUserInfoByLoginID(loginID int) (*Userinfo, error) {
  541. engine := db.GetEngine()
  542. var userInfo Userinfo
  543. _, err := engine.Table("USERINFO U").Join("INNER", "LOGINACCOUNT L", "L.USERID = U.USERID").Where("L.LOGINID = ?", loginID).Get(&userInfo)
  544. if err != nil {
  545. // 查询失败
  546. return nil, err
  547. }
  548. return &userInfo, nil
  549. }
  550. // GetUserInfoByIDS 批量获取用户信息.
  551. func GetUserInfoByIDS(userids []int64) ([]Userinfo, error) {
  552. engine := db.GetEngine()
  553. infos := make([]Userinfo, 0)
  554. err := engine.In("USERID", userids).Find(&infos)
  555. return infos, err
  556. }
  557. // GetUserAccountByAccountID 通过资金账户获取账户信息
  558. func GetUserAccountByAccountID(accountID int) (*Useraccount, error) {
  559. engine := db.GetEngine()
  560. infos := make([]Useraccount, 0)
  561. if err := engine.Table("USERACCOUNT U").
  562. Join("INNER", "TAACCOUNT TA", "TA.RELATEDUSERID = U.USERID").
  563. Where("TA.ACCOUNTID = ?", accountID).Find(&infos); err != nil {
  564. return nil, err
  565. }
  566. if len(infos) > 0 {
  567. return &infos[0], nil
  568. }
  569. return nil, nil
  570. }
  571. // GetUserInfoByAccountID 通过资金账户获取用户信息
  572. func GetUserInfoByAccountID(accountID int) (*Userinfo, error) {
  573. engine := db.GetEngine()
  574. infos := make([]Userinfo, 0)
  575. if err := engine.Table("USERINFO U").
  576. Join("INNER", "TAACCOUNT TA", "TA.RELATEDUSERID = U.USERID").
  577. Where("TA.ACCOUNTID = ?", accountID).Find(&infos); err != nil {
  578. return nil, err
  579. }
  580. if len(infos) > 0 {
  581. return &infos[0], nil
  582. }
  583. return nil, nil
  584. }
  585. // GetUserFavoriteGoodses 获取用户商品收藏信息
  586. func GetUserFavoriteGoodses(userID int) ([]Userfavoritegoods, error) {
  587. engine := db.GetEngine()
  588. favoriteGoodses := make([]Userfavoritegoods, 0)
  589. if err := engine.Where("USERID = ?", userID).Find(&favoriteGoodses); err != nil {
  590. return nil, err
  591. }
  592. return favoriteGoodses, nil
  593. }
  594. // InsertUserFavoriteGoods 新增用户商品收藏信息
  595. func InsertUserFavoriteGoods(userID int, goodsID int) error {
  596. engine := db.GetEngine()
  597. userfavoritegoods := &Userfavoritegoods{
  598. Userid: int64(userID),
  599. Goodsid: int64(goodsID),
  600. }
  601. has, err := engine.Get(userfavoritegoods)
  602. if err != nil {
  603. return err
  604. }
  605. if !has {
  606. // 不存在时则插入一条新记录
  607. // userfavoritegoods.Modifytime = time.Now()
  608. if _, err := engine.Insert(userfavoritegoods); err != nil {
  609. return err
  610. }
  611. }
  612. return nil
  613. }
  614. // DelUserFavoriteGoods 删除用户商品收藏信息
  615. func DelUserFavoriteGoods(userID int, goodsID int) error {
  616. engine := db.GetEngine()
  617. userfavoritegoods := &Userfavoritegoods{
  618. Userid: int64(userID),
  619. Goodsid: int64(goodsID),
  620. }
  621. if _, err := engine.Delete(userfavoritegoods); err != nil {
  622. return err
  623. }
  624. return nil
  625. }
  626. // GetMessageBoard 获取用户留言板信息
  627. func GetMessageBoard(userID int) ([]Messageboard, error) {
  628. engine := db.GetEngine()
  629. messageBoards := make([]Messageboard, 0)
  630. if err := engine.Where("USERID = ?", userID).Desc("CREATETIME").Find(&messageBoards); err != nil {
  631. return nil, err
  632. }
  633. return messageBoards, nil
  634. }
  635. // InsertMessageBoard 新增用户留言板信息
  636. func InsertMessageBoard(userID int, message, contactNum string) int {
  637. engine := db.GetEngine()
  638. // 一天最多只能新增3条留言
  639. messageBoard := new(Messageboard)
  640. total, err := engine.Where("USERID = ? and (CREATETIME >=TRUNC(SYSDATE) and CREATETIME < TRUNC(SYSDATE)+1)", userID).Count(messageBoard)
  641. if err != nil {
  642. return e.ERROR_OPERATION_FAILED
  643. }
  644. if total >= 3 {
  645. return e.ERROR_ADD_MAX_3
  646. }
  647. // 由于XORM对ORACLE支持不行,有时间字段更新的直接使用SQL语句执行
  648. sql := fmt.Sprintf("insert into MESSAGEBOARD (MESSAGEBOARDID, USERID, MESSAGE, CONTACTNUM ,CREATETIME) values (SEQ_MessageBoard.nextval, %d, '%s', '%s', (select sysdate from dual))", userID, message, contactNum)
  649. if _, err := engine.Exec(sql); err != nil {
  650. return e.ERROR_OPERATION_FAILED
  651. }
  652. return 0
  653. }
  654. // GetUsersByUserType 获取批量指定类型的用户信息
  655. // 输入 userType int 账户类型 - 1:交易所 2:机构 3:会员子机构 4:经纪人 5:投资者 6:客户
  656. func GetUsersByUserType(userType int) ([]Userinfo, error) {
  657. engine := db.GetEngine()
  658. userInfos := make([]Userinfo, 0)
  659. if err := engine.Where("USERTYPE = ?", userType).Find(&userInfos); err != nil {
  660. return nil, err
  661. }
  662. return userInfos, nil
  663. }
  664. // GetTaAccountsByType 获取指定用户的资金账户列表
  665. // 输入 userID int 关联用户ID
  666. // 输入 taAccountType int 账号类型 - 1:外部账号 2:内部账号 3:内部做市自营账号 4:内部做市接单账号
  667. func GetTaAccountsByType(userID, taAccountType int) ([]Taaccount, error) {
  668. engine := db.GetEngine()
  669. taAccounts := make([]Taaccount, 0)
  670. session := engine.Where("RELATEDUSERID = ?", userID)
  671. if taAccountType != 0 {
  672. session = session.And("TAACCOUNTTYPE = ?", taAccountType)
  673. }
  674. if err := session.Find(&taAccounts); err != nil {
  675. return nil, err
  676. }
  677. return taAccounts, nil
  678. }
  679. // GetTaAccountsByLoginID 通过登录账号获取对应资金账户列表的方法,一般用于获取自己的资金账号时使用
  680. // 输入 loginID int 登录账号
  681. // 输入 taAccountType int 账号类型 - 1:外部账号 2:内部账号 3:内部做市自营账号 4:内部做市接单账号
  682. func GetTaAccountsByLoginID(loginID, taAccountType int) ([]Taaccount, error) {
  683. engine := db.GetEngine()
  684. taAccounts := make([]Taaccount, 0)
  685. // 注意:获取自身的资金账号列表,先要从LoginTAAccount表中判断是否有关联关系,如没配置关系则直接从TaAccount表中获取
  686. loginTaAccounts := make([]Logintaaccount, 0)
  687. if err := engine.Where("LOGINID = ?", loginID).Find(&loginTaAccounts); err != nil {
  688. return nil, err
  689. }
  690. if len(loginTaAccounts) > 0 {
  691. // 获取资金账号ID列表
  692. accountIDs := ""
  693. for _, v := range loginTaAccounts {
  694. if len(accountIDs) == 0 {
  695. accountIDs = strconv.Itoa(int(v.Accountid))
  696. } else {
  697. accountIDs += "," + strconv.Itoa(int(v.Accountid))
  698. }
  699. }
  700. // 获取资金账号列表
  701. session := engine.Where(fmt.Sprintf("ACCOUNTID in (%s)", accountIDs))
  702. if taAccountType != 0 {
  703. session = session.And("TAACCOUNTTYPE = ?", taAccountType)
  704. }
  705. if err := session.Find(&taAccounts); err != nil {
  706. return nil, err
  707. }
  708. } else {
  709. // 获取登录账户信息
  710. loginAccount, err := GetLoginAccount(loginID)
  711. if err != nil {
  712. return nil, err
  713. }
  714. if loginAccount == nil {
  715. return make([]Taaccount, 0), nil
  716. }
  717. // 资金账号权限类型 - 1:不选默认为所有权限 2:不选默认为无权限
  718. if loginAccount.Taaccountrighttype == 2 {
  719. return make([]Taaccount, 0), nil
  720. }
  721. // 直接从TaAccount表中获取
  722. session := engine.Table("TAACCOUNT").
  723. Join("INNER", "LOGINACCOUNT L", "L.USERID = TAACCOUNT.RELATEDUSERID").
  724. Where("L.LOGINID = ?", loginID)
  725. if taAccountType != 0 {
  726. session = session.And("TAACCOUNT.TAACCOUNTTYPE = ?", taAccountType)
  727. }
  728. if err := session.Find(&taAccounts); err != nil {
  729. return nil, err
  730. }
  731. }
  732. return taAccounts, nil
  733. }
  734. // GetTaAccountByID 通过AccountID获取资金账户信息
  735. func GetTaAccountByID(accountID int) (*Taaccount, error) {
  736. engine := db.GetEngine()
  737. var taaccount Taaccount
  738. has, err := engine.Where("ACCOUNTID = ?", accountID).Get(&taaccount)
  739. if err != nil {
  740. return nil, err
  741. }
  742. if !has {
  743. return nil, nil
  744. }
  745. return &taaccount, nil
  746. }
  747. // InsertWSKHUserInfo 新增网上开户账户信息(客户资料申请)
  748. func InsertWSKHUserInfo(userinfo Wskhuserinfo) error {
  749. engine := db.GetEngine()
  750. // 加密数据
  751. key, _ := hex.DecodeString(utils.AESSecretKey)
  752. // 证件号码
  753. if len(userinfo.Cardnum) > 0 {
  754. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Cardnum), key); err == nil {
  755. userinfo.Cardnum = hex.EncodeToString(encrypted)
  756. }
  757. }
  758. // 证件地址
  759. if len(userinfo.Cardaddress) > 0 {
  760. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Cardaddress), key); err == nil {
  761. userinfo.Cardaddress = hex.EncodeToString(encrypted)
  762. }
  763. }
  764. // 手机
  765. if len(userinfo.Mobilephone) > 0 {
  766. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Mobilephone), key); err == nil {
  767. userinfo.Mobilephone = hex.EncodeToString(encrypted)
  768. }
  769. }
  770. // 微信
  771. if len(userinfo.Wechat) > 0 {
  772. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Wechat), key); err == nil {
  773. userinfo.Wechat = hex.EncodeToString(encrypted)
  774. }
  775. }
  776. // 邮件
  777. if len(userinfo.Email) > 0 {
  778. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Email), key); err == nil {
  779. userinfo.Email = hex.EncodeToString(encrypted)
  780. }
  781. }
  782. // 银行帐号
  783. if len(userinfo.Bankaccount) > 0 {
  784. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Bankaccount), key); err == nil {
  785. userinfo.Bankaccount = hex.EncodeToString(encrypted)
  786. }
  787. }
  788. // 经纪人ID
  789. if len(userinfo.Brokerid) > 0 {
  790. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Brokerid), key); err == nil {
  791. userinfo.Brokerid = hex.EncodeToString(encrypted)
  792. }
  793. }
  794. // 登录帐号
  795. if len(userinfo.Logincode) > 0 {
  796. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Logincode), key); err == nil {
  797. userinfo.Logincode = hex.EncodeToString(encrypted)
  798. }
  799. }
  800. // 自增ID
  801. seqMap, err := engine.QueryString("SELECT SEQ_WSKH_USERINFO.nextval USERID FROM dual")
  802. if err != nil {
  803. return err
  804. }
  805. if len(seqMap) <= 0 {
  806. return errors.New("获取自增ID错误")
  807. }
  808. userID, _ := strconv.Atoi(seqMap[0]["USERID"])
  809. userinfo.Userid = int64(userID)
  810. // 插入数据
  811. if _, err = engine.Insert(&userinfo); err != nil {
  812. return err
  813. }
  814. return nil
  815. }
  816. // UpdateWSKHUserInfo 修改网上开户账户信息(客户资料申请)
  817. func UpdateWSKHUserInfo(userinfo Wskhuserinfo) error {
  818. engine := db.GetEngine()
  819. // 加密数据
  820. key, _ := hex.DecodeString(utils.AESSecretKey)
  821. // 证件号码
  822. if len(userinfo.Cardnum) > 0 {
  823. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Cardnum), key); err == nil {
  824. userinfo.Cardnum = hex.EncodeToString(encrypted)
  825. }
  826. }
  827. // 证件地址
  828. if len(userinfo.Cardaddress) > 0 {
  829. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Cardaddress), key); err == nil {
  830. userinfo.Cardaddress = hex.EncodeToString(encrypted)
  831. }
  832. }
  833. // 手机
  834. if len(userinfo.Mobilephone) > 0 {
  835. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Mobilephone), key); err == nil {
  836. userinfo.Mobilephone = hex.EncodeToString(encrypted)
  837. }
  838. }
  839. // 微信
  840. if len(userinfo.Wechat) > 0 {
  841. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Wechat), key); err == nil {
  842. userinfo.Wechat = hex.EncodeToString(encrypted)
  843. }
  844. }
  845. // 邮件
  846. if len(userinfo.Email) > 0 {
  847. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Email), key); err == nil {
  848. userinfo.Email = hex.EncodeToString(encrypted)
  849. }
  850. }
  851. // 银行帐号
  852. if len(userinfo.Bankaccount) > 0 {
  853. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Bankaccount), key); err == nil {
  854. userinfo.Bankaccount = hex.EncodeToString(encrypted)
  855. }
  856. }
  857. // 经纪人ID
  858. if len(userinfo.Brokerid) > 0 {
  859. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Brokerid), key); err == nil {
  860. userinfo.Brokerid = hex.EncodeToString(encrypted)
  861. }
  862. }
  863. // 登录帐号
  864. if len(userinfo.Logincode) > 0 {
  865. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Logincode), key); err == nil {
  866. userinfo.Logincode = hex.EncodeToString(encrypted)
  867. }
  868. }
  869. // 修改数据
  870. // 由于表的主键未定义成ID,所以这里需要用where来过滤
  871. userID := userinfo.Userid
  872. userinfo.Userid = 0
  873. // m := make(map[string]interface{})
  874. // j, _ := json.Marshal(userinfo)
  875. // json.Unmarshal(j, &m)
  876. // delete(m, "USERID")
  877. if _, err := engine.Where("USERID = ?", userID).Update(&userinfo); err != nil {
  878. return err
  879. }
  880. return nil
  881. }
  882. // DeleteWSKHUserInfo 删除网上开户账户信息(客户资料申请)
  883. func DeleteWSKHUserInfo(userID int) error {
  884. if userID == 0 {
  885. return errors.New("userID为0")
  886. }
  887. sql := fmt.Sprintf("DELETE FROM WSKH_USERINFO WHERE USERSTATE = 1 AND USERID = %d", userID)
  888. if _, err := db.GetEngine().Exec(sql); err != nil {
  889. return err
  890. }
  891. return nil
  892. }
  893. // GetWSKHUserInfos 获取开户信息列表
  894. func GetWSKHUserInfos(userName string) ([]Wskhuserinfo, error) {
  895. engine := db.GetEngine()
  896. userInfos := make([]Wskhuserinfo, 0)
  897. session := engine.Table("WSKH_USERINFO")
  898. if len(userName) > 0 {
  899. session = session.Where(fmt.Sprintf("USERNAME like '%%%s%%'", userName))
  900. }
  901. if err := session.Find(&userInfos); err != nil {
  902. return nil, err
  903. }
  904. return userInfos, nil
  905. }
  906. // GetUserInfos 获取用户信息
  907. // 输入 userName string 客户名称,支持模糊查询
  908. func GetUserInfos(userName string) ([]Userinfo, error) {
  909. engine := db.GetEngine()
  910. userInfos := make([]Userinfo, 0)
  911. session := engine.Table("USERINFO")
  912. if len(userName) > 0 {
  913. session = session.Where(fmt.Sprintf("CUSTOMERNAME like '%%%s%%'", userName))
  914. }
  915. if err := session.Find(&userInfos); err != nil {
  916. return nil, err
  917. }
  918. return userInfos, nil
  919. }
  920. // UpdateUserAccountStatus 更新用户
  921. func UpdateUserAccountStatus(userID, accountStatus int) error {
  922. engine := db.GetEngine()
  923. if accountStatus != 4 && accountStatus != 6 {
  924. return errors.New("错误的状态值")
  925. }
  926. // 要同时改UserAccount表和UserInfo表的状态
  927. useraccount := Useraccount{Accountstatus: int32(accountStatus)}
  928. if _, err := engine.Table("USERACCOUNT").
  929. Where("USERID = ?", userID).
  930. Update(&useraccount); err != nil {
  931. return err
  932. }
  933. // UserInfo表的状态为1-正常;2-注销
  934. userStatus := 1
  935. if accountStatus == 6 {
  936. userStatus = 2
  937. }
  938. userinfo := Userinfo{Userstatus: int32(userStatus)}
  939. if _, err := engine.Table("USERINFO").
  940. Where("USERID = ?", userID).
  941. Update(&userinfo); err != nil {
  942. return err
  943. }
  944. return nil
  945. }
  946. // GetSysteMmanagerByLoginCode 通过LoginCode获取管理端账号
  947. func GetSysteMmanagerByLoginCode(loginCode string) (*Systemmanager, error) {
  948. tmp := make([]Systemmanager, 0)
  949. if err := db.GetEngine().Where("LOGINCODE = ?", loginCode).Find(&tmp); err != nil {
  950. return nil, err
  951. }
  952. if len(tmp) == 0 {
  953. return nil, nil
  954. }
  955. return &tmp[0], nil
  956. }
  957. // GetHedgeOutTaAccount 母账户资金账户获取对冲外部资金账户信息
  958. func GetHedgeOutTaAccount(accountID int) (*Hedgeouttaaccount, error) {
  959. var rst Hedgeouttaaccount
  960. has, err := db.GetEngine().Where("ACCOUNTID = ?", accountID).Get(&rst)
  961. if err != nil {
  962. return nil, err
  963. }
  964. if !has {
  965. return nil, nil
  966. }
  967. return &rst, nil
  968. }