account.go 54 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807
  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:"password" 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. }
  33. // TableName is LOGINACCOUNT
  34. func (Loginaccount) TableName() string {
  35. return "LOGINACCOUNT"
  36. }
  37. // Taaccount 资金账户表 - 导历史
  38. type Taaccount struct {
  39. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账户ID
  40. Userid int64 `json:"userid" xorm:"'USERID'" binding:"required"` // 用户ID
  41. Currencyid int64 `json:"currencyid" xorm:"'CURRENCYID'"` // 货币ID
  42. Changeflag int32 `json:"changeflag" xorm:"'CHANGEFLAG'"` // 变动标志(当前账户资金有任何变动更新为1系统结算时更新0;供清算时使用) 0:无变动 1:有变动
  43. Password string `json:"password" xorm:"'PASSWORD'"` // 资金密码
  44. Tradestatus int32 `json:"tradestatus" xorm:"'TRADESTATUS'"` // 交易状态 - 1:正常 2:受限 3:冻结 4:禁止建仓(人工受限) 5:禁止交易(人工冻结) 6:待激活 7:已注销
  45. Signstatus int32 `json:"signstatus" xorm:"'SIGNSTATUS'"` // 签约状态 - 1:未签约 2:签约待审核 3:签约中 4:已签约 5:解约待审核 6:解约中 7:已解约 8:已解绑 9:绑卡中
  46. Ismain int32 `json:"ismain" xorm:"'ISMAIN'"` // 是否母账号 0:不是母账户 1:是母账户
  47. Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属根账号
  48. Relateduserid int64 `json:"relateduserid" xorm:"'RELATEDUSERID'"` // 关联用户
  49. Relatedaccountstatus int32 `json:"relatedaccountstatus" xorm:"'RELATEDACCOUNTSTATUS'"` // 关联用户交易权限状态 - 1:正常(可交易) 2:受限(可平仓,不可建仓) 3:冻结(不可交易)
  50. Taaccounttype int32 `json:"taaccounttype" xorm:"'TAACCOUNTTYPE'"` // 账号类型 - 1:外部账号 2:内部账号 3:内部做市自营账号 4:内部做市接单账号
  51. Isreckonaccount int32 `json:"isreckonaccount" xorm:"'ISRECKONACCOUNT'"` // 是否机构分润账号 0:不是 1:是
  52. Ismarketaccount int32 `json:"ismarketaccount" xorm:"'ISMARKETACCOUNT'"` // 是否机构接单账号 0:不是 1:是
  53. Balance float64 `json:"balance" xorm:"'BALANCE'"` // 期初余额
  54. Orifreezemargin float64 `json:"orifreezemargin" xorm:"'ORIFREEZEMARGIN'"` // 期初冻结保证金
  55. Oriusedmargin float64 `json:"oriusedmargin" xorm:"'ORIUSEDMARGIN'"` // 期初占用保证金
  56. Oriotherfreezemargin float64 `json:"oriotherfreezemargin" xorm:"'ORIOTHERFREEZEMARGIN'"` // 期初其他冻结保证金(出金冻结资金 交割买方冻结 申购冻结 全款买入 商城买入)
  57. Orifreezecharge float64 `json:"orifreezecharge" xorm:"'ORIFREEZECHARGE'"` // 期初手续费冻结
  58. Orimortgagecredit float64 `json:"orimortgagecredit" xorm:"'ORIMORTGAGECREDIT'"` // 期初授信金额
  59. Oriothercredit float64 `json:"oriothercredit" xorm:"'ORIOTHERCREDIT'"` // 期初其它授信金额
  60. Orioutamountfreeze float64 `json:"orioutamountfreeze" xorm:"'ORIOUTAMOUNTFREEZE'"` // 期初出金冻结
  61. Currentbalance float64 `json:"currentbalance" xorm:"'CURRENTBALANCE'"` // 期末余额
  62. Freezemargin float64 `json:"freezemargin" xorm:"'FREEZEMARGIN'"` // 冻结保证金
  63. Usedmargin float64 `json:"usedmargin" xorm:"'USEDMARGIN'"` // 占用保证金
  64. Otherfreezemargin float64 `json:"otherfreezemargin" xorm:"'OTHERFREEZEMARGIN'"` // 其他冻结保证金(交割买方冻结 申购冻结 全款买入 商城买入)
  65. Freezecharge float64 `json:"freezecharge" xorm:"'FREEZECHARGE'"` // 手续费冻结
  66. Mortgagecredit float64 `json:"mortgagecredit" xorm:"'MORTGAGECREDIT'"` // 授信金额
  67. Othercredit float64 `json:"othercredit" xorm:"'OTHERCREDIT'"` // 其它授信金额
  68. Outamountfreeze float64 `json:"outamountfreeze" xorm:"'OUTAMOUNTFREEZE'"` // 出金冻结
  69. Inamount float64 `json:"inamount" xorm:"'INAMOUNT'"` // 今日入金金额(包括三方入金)
  70. Outamount float64 `json:"outamount" xorm:"'OUTAMOUNT'"` // 今日出金金额(包括三方出金)
  71. Paycharge float64 `json:"paycharge" xorm:"'PAYCHARGE'"` // 今日手续费支出
  72. Closepl float64 `json:"closepl" xorm:"'CLOSEPL'"` // 今日平仓盈亏
  73. Creditincrease float64 `json:"creditincrease" xorm:"'CREDITINCREASE'"` // 今日授信增加
  74. Creditdecrease float64 `json:"creditdecrease" xorm:"'CREDITDECREASE'"` // 今日授信减少
  75. Othercreditincrease float64 `json:"othercreditincrease" xorm:"'OTHERCREDITINCREASE'"` // 今日其它授信增加
  76. Othercreditdecrease float64 `json:"othercreditdecrease" xorm:"'OTHERCREDITDECREASE'"` // 今日其它授信减少
  77. Transferamount float64 `json:"transferamount" xorm:"'TRANSFERAMOUNT'"` // 今日划转金额(母子账号资金划转,从划入账号为正,从账号划出为负)
  78. Otherpay float64 `json:"otherpay" xorm:"'OTHERPAY'"` // 其他支出(交割付款 申购付款 全款买入 商城买入 卖家退货)
  79. Otherincome float64 `json:"otherincome" xorm:"'OTHERINCOME'"` // 其他收入(交割收款 申购收款 全款卖出 商城卖出 买家退货 会员手续费收入)
  80. Outthreshold float64 `json:"outthreshold" xorm:"'OUTTHRESHOLD'"` // 出金阈值
  81. Tradestatuschangetime time.Time `json:"tradestatuschangetime" xorm:"'TRADESTATUSCHANGETIME'"` // 激活时间
  82. Changetime time.Time `json:"changetime" xorm:"'CHANGETIME'"` // 账户状态变更时间
  83. Thirdinamount float64 `json:"thirdinamount" xorm:"'THIRDINAMOUNT'"` // 今日三方入金
  84. Thirdoutamount float64 `json:"thirdoutamount" xorm:"'THIRDOUTAMOUNT'"` // 今日三方出金
  85. Capitalbalance float64 `json:"capitalbalance" xorm:"'CAPITALBALANCE'"` // 本金余额[外部子账户实际出入金余额]
  86. Fromaccountid int64 `json:"fromaccountid" xorm:"'FROMACCOUNTID'"` // 所属上级账户
  87. Sublevelpath string `json:"sublevelpath" xorm:"'SUBLEVELPATH'"` // 账号层级路径(逗号分隔,首尾加逗号)
  88. Serivcegroup int64 `json:"serivcegroup" xorm:"'SERIVCEGROUP'"` // 服务分组
  89. Accountname string `json:"accountname" xorm:"'ACCOUNTNAME'"` // 账户名称
  90. Accountflag int32 `json:"accountflag" xorm:"'ACCOUNTFLAG'"` // 账户标识 - 0\1 (默认为0, 当上级账户与本账户的关联用户均为自己时更新为1)
  91. }
  92. // TableName is TAACCOUNT
  93. func (Taaccount) TableName() string {
  94. return "TAACCOUNT"
  95. }
  96. // Logintaaccount 登录账户资金权限表 - 自营会员
  97. type Logintaaccount struct {
  98. Loginid int64 `json:"loginid" xorm:"'LOGINID'" binding:"required"` // 登录账号ID
  99. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账号ID
  100. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  101. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  102. }
  103. // TableName is LOGINTAACCOUNT
  104. func (Logintaaccount) TableName() string {
  105. return "LOGINTAACCOUNT"
  106. }
  107. // Arearolemarket 机构角色市场权限表
  108. type Arearolemarket struct {
  109. Areauserid int64 `json:"areauserid" xorm:"'AREAUSERID'" binding:"required"` // 机构用户ID
  110. Roletype int32 `json:"roletype" xorm:"'ROLETYPE'" binding:"required"` // 角色类型 - 6:自营会员 7:经纪会员
  111. Marketid int32 `json:"marketid" xorm:"'MARKETID'" binding:"required"` // 市场ID
  112. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  113. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人ID
  114. Spotrighttype int32 `json:"spotrighttype" xorm:"'SPOTRIGHTTYPE'"` // 现货权限类型 - 0:无 1:可挂可摘 2:可挂 3:可摘 [现货类](卖大厅)
  115. Buyspotrighttype int32 `json:"buyspotrighttype" xorm:"'BUYSPOTRIGHTTYPE'"` // 现货权限类型 - 0:无 1:可挂可摘 2:可挂 3:可摘 [现货类](买大厅)
  116. }
  117. // TableName is AREAROLEMARKET
  118. func (Arearolemarket) TableName() string {
  119. return "AREAROLEMARKET"
  120. }
  121. // Taaccountmarket 资金账号市场权限表
  122. type Taaccountmarket struct {
  123. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账号ID
  124. Marketid int32 `json:"marketid" xorm:"'MARKETID'" binding:"required"` // 市场ID
  125. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  126. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  127. Spotrighttype int32 `json:"spotrighttype" xorm:"'SPOTRIGHTTYPE'"` // 现货权限类型 - 0:无1:可挂可摘 2:可挂 3:可摘 [现货类](卖大厅)
  128. Buyspotrighttype int32 `json:"buyspotrighttype" xorm:"'BUYSPOTRIGHTTYPE'"` // 现货权限类型 - 0:无1:可挂可摘 2:可挂 3:可摘 [现货类](买大厅)
  129. }
  130. // TableName is TAACCOUNTMARKET
  131. func (Taaccountmarket) TableName() string {
  132. return "TAACCOUNTMARKET"
  133. }
  134. // Useraccount 用户表
  135. type Useraccount struct {
  136. Userid int64 `json:"userid" xorm:"'USERID'" binding:"required"` // 用户ID
  137. Usertype int32 `json:"usertype" xorm:"'USERTYPE'"` // 账户类型 - 1:交易所 2:机构 3:会员子机构 4:经纪人 5:投资者 6:客户
  138. Accountname string `json:"accountname" xorm:"'ACCOUNTNAME'"` // 账户名称(机构名称)
  139. Parentuserid int64 `json:"parentuserid" xorm:"'PARENTUSERID'"` // 所属机构ID
  140. Broker int64 `json:"broker" xorm:"'BROKER'"` // 所属经纪人ID
  141. Subarealevelpath string `json:"subarealevelpath" xorm:"'SUBAREALEVELPATH'"` // 子机构层级路径(逗号分隔,首尾加逗号)
  142. Refereeuserid int64 `json:"refereeuserid" xorm:"'REFEREEUSERID'"` // 推荐人ID
  143. Memberuserid int64 `json:"memberuserid" xorm:"'MEMBERUSERID'"` // 所属会员ID
  144. Accountstatus int32 `json:"accountstatus" xorm:"'ACCOUNTSTATUS'"` // 账户状态 - 1:待激活 2:待审核 3:待复审 4:正常 5:审核拒绝 6:注销
  145. Reckonaccountid int64 `json:"reckonaccountid" xorm:"'RECKONACCOUNTID'"` // 默认结算资金账号ID(机构分润使用) 作废
  146. Modifystatus int32 `json:"modifystatus" xorm:"'MODIFYSTATUS'"` // 变更状态 1 未变更 2 变更中 3 变更待审核 4 变更待复核(投资者)
  147. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间
  148. Creatorid int64 `json:"creatorid" xorm:"'CREATORID'"` // 创建人
  149. Audittime time.Time `json:"audittime" xorm:"'AUDITTIME'"` // 审核时间
  150. Audituserid int64 `json:"audituserid" xorm:"'AUDITUSERID'"` // 审核人
  151. Auditremark string `json:"auditremark" xorm:"'AUDITREMARK'"` // 审核备注
  152. Canceltime time.Time `json:"canceltime" xorm:"'CANCELTIME'"` // 销户时间
  153. Canceluserid int64 `json:"canceluserid" xorm:"'CANCELUSERID'"` // 销户人
  154. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  155. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  156. Modifyremark string `json:"modifyremark" xorm:"'MODIFYREMARK'"` // 变更备注
  157. Maxinvestornum int64 `json:"maxinvestornum" xorm:"'MAXINVESTORNUM'"` // 最大用户数(经纪会员下投资者个数)
  158. Hasauth int32 `json:"hasauth" xorm:"'HASAUTH'"` // 是否已实名认证 - 0:未认证 1:已认证 2:已提交(待审核) 3:已拒绝
  159. Refercount int32 `json:"refercount" xorm:"'REFERCOUNT'"` // 推荐总人数
  160. Refernum string `json:"refernum" xorm:"'REFERNUM'"` // 推荐码
  161. Isanonymous int32 `json:"isanonymous" xorm:"'ISANONYMOUS'"` // 是否匿名下单 - 0:否 1:是
  162. }
  163. // TableName is USERACCOUNT
  164. func (Useraccount) TableName() string {
  165. return "USERACCOUNT"
  166. }
  167. // Userinfo 用户信息表
  168. type Userinfo struct {
  169. Userid int64 `json:"userid" xorm:"'USERID'" binding:"required"` // 用户ID
  170. Userinfotype int32 `json:"userinfotype" xorm:"'USERINFOTYPE'"` // 用户信息类型 - 1:个人 2:企业
  171. Customername string `json:"customername" xorm:"'CUSTOMERNAME'"` // 客户名称(企业名称)
  172. Userstatus int32 `json:"userstatus" xorm:"'USERSTATUS'"` // 用户状态 - 1:正常 2:注销
  173. Usertype int32 `json:"usertype" xorm:"'USERTYPE'"` // 账户类型 - 1:交易所 2:机构 3:会员子机构 4:经纪人 5:投资者 6:客户
  174. Openmode int32 `json:"openmode" xorm:"'OPENMODE'"` // 开户方式 - 1:管理端开户 2:网上开户注册(会员官网) 3:微信开户 4:网页交易端注册 5:安卓手机端注册 6:苹果手机端注册 7:PC交易端注册 8:微信快速开户 9:支付宝快速开户 10:手机号快速开户
  175. Cardtypeid int32 `json:"cardtypeid" xorm:"'CARDTYPEID'"` // 证件类型ID
  176. Cardnum string `json:"cardnum" xorm:"'CARDNUM'"` // 证件号码(加密存储)
  177. Halfbodyphotourl string `json:"halfbodyphotourl" xorm:"'HALFBODYPHOTOURL'"` // 半身照地址
  178. Cardfrontphotourl string `json:"cardfrontphotourl" xorm:"'CARDFRONTPHOTOURL'"` // 证件正面图片地址
  179. Cardbackphotourl string `json:"cardbackphotourl" xorm:"'CARDBACKPHOTOURL'"` // 证件背面图片地址
  180. Biznature int32 `json:"biznature" xorm:"'BIZNATURE'"` // 企业性质( 企业) - 1:国有控股企业 2:集体控股企业 3:私人控股企业 4:港澳台商控股企业 5:外商控股企业 6:其它
  181. Bizscope string `json:"bizscope" xorm:"'BIZSCOPE'"` // 企业经营范围(企业)
  182. Legalpersonname string `json:"legalpersonname" xorm:"'LEGALPERSONNAME'"` // 法人姓名(企业)
  183. Contactname string `json:"contactname" xorm:"'CONTACTNAME'"` // 联系人
  184. Sex int32 `json:"sex" xorm:"'SEX'"` // 用户性别 0: 女 1: 男
  185. Telphone string `json:"telphone" xorm:"'TELPHONE'"` // 联系电话(加密存储)
  186. Mobile string `json:"mobile" xorm:"'MOBILE'"` // 手机号码(加密存储)
  187. Fax string `json:"fax" xorm:"'FAX'"` // 传真(加密存储)
  188. Email string `json:"email" xorm:"'EMAIL'"` // 邮件(加密存储)
  189. Qq string `json:"qq" xorm:"'QQ'"` // QQ(加密存储
  190. Wechat string `json:"wechat" xorm:"'WECHAT'"` // 微信(加密存储)
  191. Countryid int32 `json:"countryid" xorm:"'COUNTRYID'"` // 国家
  192. Provinceid int32 `json:"provinceid" xorm:"'PROVINCEID'"` // 省
  193. Cityid int32 `json:"cityid" xorm:"'CITYID'"` // 市
  194. Districtid int32 `json:"districtid" xorm:"'DISTRICTID'"` // 地区
  195. Company string `json:"company" xorm:"'COMPANY'"` // 公司(个人)
  196. Address string `json:"address" xorm:"'ADDRESS'"` // 地址
  197. Postalcode string `json:"postalcode" xorm:"'POSTALCODE'"` // 邮政编码
  198. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间
  199. Creatorid int64 `json:"creatorid" xorm:"'CREATORID'"` // 创建人
  200. Modifiertime time.Time `json:"modifiertime" xorm:"'MODIFIERTIME'"` // 修改时间
  201. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  202. Remark string `json:"remark" xorm:"'REMARK'"` // 备注
  203. Wskhinfo string `json:"wskhinfo" xorm:"'WSKHINFO'"` // 开户申请信息(JSON)
  204. Signpdfurl string `json:"signpdfurl" xorm:"'SIGNPDFURL'"` // 签约pdf文件
  205. Legalcardfrontphotourl string `json:"legalcardfrontphotourl" xorm:"'LEGALCARDFRONTPHOTOURL'"` // 法人身份证正面照地址
  206. Legalcardbackphotourl string `json:"legalcardbackphotourl" xorm:"'LEGALCARDBACKPHOTOURL'"` // 法人身份证背面照地址
  207. Otherurl string `json:"otherurl" xorm:"'OTHERURL'"` // 其它图片地址[使用分号分隔]
  208. Hasencrypt int32 `json:"hasencrypt" xorm:"'HASENCRYPT'"` // 数据是否已加密 - 0:未加密 1:已加密
  209. Bankname string `json:"bankname" xorm:"'BANKNAME'"` // 银行名称
  210. Bankaccount string `json:"bankaccount" xorm:"'BANKACCOUNT'"` // 银行帐号 (加密存储)
  211. Bankcardfrontphotourl string `json:"bankcardfrontphotourl" xorm:"'BANKCARDFRONTPHOTOURL'"` // 银行卡正面照地址
  212. Needinvoice int32 `json:"needinvoice" xorm:"'NEEDINVOICE'"` // 是否需要发票 - 0:不需要 1:需要
  213. Bankid string `json:"bankid" xorm:"'BANKID'"` // 银行编码
  214. Attachment1 string `json:"attachment1" xorm:"'ATTACHMENT1'"` // 附件1
  215. Attachment2 string `json:"attachment2" xorm:"'ATTACHMENT2'"` // 附件2
  216. Bankaccountname string `json:"bankaccountname" xorm:"'BANKACCOUNTNAME'"` // 收款人名称
  217. Headurl string `json:"headurl" xorm:"'HEADURL'"` // 头像地址
  218. Nickname string `json:"nickname" xorm:"'NICKNAME'"` // 昵称:默认为名称脱敏(张**) 或 手机号脱敏(139****9999)
  219. Mobile2 string `json:"mobile2" xorm:"'MOBILE2'"` // 手机号码[明文-尚志]
  220. }
  221. // TableName is USERINFO
  222. func (Userinfo) TableName() string {
  223. return "USERINFO"
  224. }
  225. // Quoter 报价商表
  226. type Quoter struct {
  227. Quoterid int64 `json:"quoterid" xorm:"'QUOTERID'" binding:"required"` // 报价商ID(自增ID)
  228. Quotername string `json:"quotername" xorm:"'QUOTERNAME'" binding:"required"` // 报价商名称
  229. Areauserid int64 `json:"areauserid" xorm:"'AREAUSERID'" binding:"required"` // 所属机构ID
  230. Tradeproperty int32 `json:"tradeproperty" xorm:"'TRADEPROPERTY'"` // 交易属性
  231. Defaultmakerid int64 `json:"defaultmakerid" xorm:"'DEFAULTMAKERID'"` // 默认做市商ID(UserID)
  232. Quoterstatus int32 `json:"quoterstatus" xorm:"'QUOTERSTATUS'"` // 报价商状态 - 1:正常 2:注销
  233. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人
  234. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  235. Matchmode int32 `json:"matchmode" xorm:"'MATCHMODE'"` // 对手模式: 1-经纪会员自接 2:按对手关系[收益权用]
  236. }
  237. // TableName is QUOTER
  238. func (Quoter) TableName() string {
  239. return "QUOTER"
  240. }
  241. // Arearole 机构角色表
  242. type Arearole struct {
  243. Userid int64 `json:"userid" xorm:"'USERID'" binding:"required"` // 机构用户ID其他做市关系,都设置为 1
  244. 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:顶级机构
  245. Tradeaccountid int64 `json:"tradeaccountid" xorm:"'TRADEACCOUNTID'"` // 默认交易资金账号ID(做市会员被动接单使用、商城店铺默认资金账 号、圈内会员默认资金账号) - 作废, 使用UserReckonAccount
  246. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间
  247. Creatorid int64 `json:"creatorid" xorm:"'CREATORID'"` // 创建人ID
  248. Modifytime time.Time `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  249. Modifierid int64 `json:"modifierid" xorm:"'MODIFIERID'"` // 修改人ID
  250. Shoppassword string `json:"shoppassword" xorm:"'SHOPPASSWORD'"` // 商城店铺登陆密码(商城店铺角色使用)
  251. Isreturnscore int32 `json:"isreturnscore" xorm:"'ISRETURNSCORE'"` // 是否返还积分 [经纪会员-辽东湾] - 0:不返还 1:返还
  252. Transurl string `json:"transurl" xorm:"'TRANSURL'"` // 物流地址(物流机构)
  253. Outuserid string `json:"outuserid" xorm:"'OUTUSERID'"` // 外部账户[场外期权做市商]
  254. Parentuserid int64 `json:"parentuserid" xorm:"'PARENTUSERID'"` // 上级组织机构(组织机构)
  255. Rootuserid int64 `json:"rootuserid" xorm:"'ROOTUSERID'"` // 顶级组织机构用户ID(组织机构)
  256. Sublevelpath string `json:"sublevelpath" xorm:"'SUBLEVELPATH'"` // 组织机构层级路径(逗号分隔,首尾加逗号)
  257. Orgtype int32 `json:"orgtype" xorm:"'ORGTYPE'"` // 组织机构类型 1:机构 2:交易员
  258. }
  259. // TableName is AREAROLE
  260. func (Arearole) TableName() string {
  261. return "AREAROLE"
  262. }
  263. // Taaccountlog 资金账户记账流水表 - 导历史
  264. type Taaccountlog struct {
  265. Autoid int64 `json:"autoid" xorm:"'AUTOID'" binding:"required"` // 流水ID(220+Unix秒时间戳(10位)+xxxxxx)
  266. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账户ID
  267. Relationorderid string `json:"relationorderid" xorm:"'RELATIONORDERID'"` // 关联单号
  268. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  269. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  270. Currencyid int64 `json:"currencyid" xorm:"'CURRENCYID'"` // 币种ID
  271. Amount float64 `json:"amount" xorm:"'AMOUNT'" binding:"required"` // 资金金额
  272. Amountadjusttype int32 `json:"amountadjusttype" xorm:"'AMOUNTADJUSTTYPE'" binding:"required"` // 资金调整类型(默认值为0) - 0:系统 1:单边账调整 2:人工调整
  273. Balance float64 `json:"balance" xorm:"'BALANCE'" binding:"required"` // 期初余额
  274. Currentbalance float64 `json:"currentbalance" xorm:"'CURRENTBALANCE'" binding:"required"` // 期末余额(变动后金额)
  275. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'" binding:"required"` // 发生时间
  276. 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:营销收款
  277. Moneyticket int64 `json:"moneyticket" xorm:"'MONEYTICKET'"` // 资金流水号:银行端流水号
  278. Remark string `json:"remark" xorm:"'REMARK'"` // 备注
  279. Businesscode int32 `json:"businesscode" xorm:"'BUSINESSCODE'"` // 业务编号
  280. }
  281. // TableName is TAACCOUNTLOG
  282. func (Taaccountlog) TableName() string {
  283. return "TAACCOUNTLOG"
  284. }
  285. // Histaaccountlog 历史资金账户记账流水表
  286. type Histaaccountlog struct {
  287. Autoid int64 `json:"autoid" xorm:"'AUTOID'" binding:"required"` // 流水ID(220+Unix秒时间戳(10位)+xxxxxx)
  288. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账户ID
  289. Relationorderid string `json:"relationorderid" xorm:"'RELATIONORDERID'"` // 关联单号
  290. Marketid int32 `json:"marketid" xorm:"'MARKETID'"` // 市场ID
  291. Goodsid int32 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID
  292. Currencyid int64 `json:"currencyid" xorm:"'CURRENCYID'"` // 币种ID
  293. Amount float64 `json:"amount" xorm:"'AMOUNT'" binding:"required"` // 资金金额
  294. Amountadjusttype int32 `json:"amountadjusttype" xorm:"'AMOUNTADJUSTTYPE'" binding:"required"` // 资金调整类型(默认值为0) - 0:系统 1:单边账调整 2:人工调整
  295. Balance float64 `json:"balance" xorm:"'BALANCE'" binding:"required"` // 期初余额
  296. Currentbalance float64 `json:"currentbalance" xorm:"'CURRENTBALANCE'" binding:"required"` // 期末余额(变动后金额)
  297. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'" binding:"required"` // 发生时间
  298. 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:营销收款
  299. Moneyticket int64 `json:"moneyticket" xorm:"'MONEYTICKET'"` // 资金流水号:银行端流水号
  300. Remark string `json:"remark" xorm:"'REMARK'"` // 备注
  301. Businesscode int32 `json:"businesscode" xorm:"'BUSINESSCODE'"` // 业务编号
  302. Histradedate string `json:"histradedate" xorm:"'HISTRADEDATE'" binding:"required"` // 历史交易日
  303. Isvaliddata int32 `json:"isvaliddata" xorm:"'ISVALIDDATA'"` // 是否有效 - 0:无效 1:有效
  304. }
  305. // TableName is HIS_TAACCOUNTLOG
  306. func (Histaaccountlog) TableName() string {
  307. return "HIS_TAACCOUNTLOG"
  308. }
  309. // Userfavoritegoods 用户商品收藏表
  310. type Userfavoritegoods struct {
  311. Userid int64 `json:"-" xorm:"'USERID'" binding:"required"` // 用户
  312. Goodsid int64 `json:"goodsid" xorm:"'GOODSID'" binding:"required"` // 商品ID
  313. Marketid int32 `json:"-" xorm:"'MARKETID'"` // 市场ID
  314. Modifytime time.Time `json:"-" xorm:"'MODIFYTIME'"` // 修改时间
  315. }
  316. // TableName is USERFAVORITEGOODS
  317. func (Userfavoritegoods) TableName() string {
  318. return "USERFAVORITEGOODS"
  319. }
  320. // Messageboard 留言簿表
  321. type Messageboard struct {
  322. Messageboardid int64 `json:"messageboardid" xorm:"'MESSAGEBOARDID'" binding:"required"` // 留言簿ID(SEQ_MessageBoard)
  323. Userid int64 `json:"userid" xorm:"'USERID'"` // 用户ID
  324. Message string `json:"message" xorm:"'MESSAGE'"` // 留言信息
  325. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间
  326. }
  327. // TableName is MESSAGEBOARD
  328. func (Messageboard) TableName() string {
  329. return "MESSAGEBOARD"
  330. }
  331. // Wskhuserinfo 网上开户用户表 (开户成功删除记录)
  332. type Wskhuserinfo struct {
  333. Userid int64 `json:"userid" xorm:"'USERID'" binding:"required"` // 用户ID(自增ID)
  334. Username string `json:"username" xorm:"'USERNAME'"` // 用户姓名
  335. Sex int32 `json:"sex" xorm:"'SEX'"` // 性别 - 0:女 1:男
  336. Cardtype int32 `json:"cardtype" xorm:"'CARDTYPE'"` // 证件类型
  337. Cardnum string `json:"cardnum" xorm:"'CARDNUM'"` // 证件号码 (加密存储)
  338. Cardaddress string `json:"cardaddress" xorm:"'CARDADDRESS'"` // 证件地址 (加密存储)
  339. Mobilephone string `json:"mobilephone" xorm:"'MOBILEPHONE'"` // 手机号码 (加密存储)
  340. Wechat string `json:"wechat" xorm:"'WECHAT'"` // 微信号 (加密存储)
  341. Email string `json:"email" xorm:"'EMAIL'"` // Email地址(加密存储)
  342. Ipaddress string `json:"ipaddress" xorm:"'IPADDRESS'"` // IP地址
  343. Halfbodyphotourl string `json:"halfbodyphotourl" xorm:"'HALFBODYPHOTOURL'"` // 半身照地址
  344. Cardfrontphotourl string `json:"cardfrontphotourl" xorm:"'CARDFRONTPHOTOURL'"` // 正面证件照地址
  345. Cardbackphotourl string `json:"cardbackphotourl" xorm:"'CARDBACKPHOTOURL'"` // 背面证件照地址
  346. Bankid string `json:"bankid" xorm:"'BANKID'"` // 银行编码
  347. Bankname string `json:"bankname" xorm:"'BANKNAME'"` // 银行名称
  348. Bankaccount string `json:"bankaccount" xorm:"'BANKACCOUNT'"` // 银行帐号 (加密存储)
  349. Bankcardfrontphotourl string `json:"bankcardfrontphotourl" xorm:"'BANKCARDFRONTPHOTOURL'"` // 银行卡正面照地址
  350. Bankcardbackphotourl string `json:"bankcardbackphotourl" xorm:"'BANKCARDBACKPHOTOURL'"` // 银行卡背面照地址
  351. Areacode string `json:"areacode" xorm:"'AREACODE'"` // 机构代码
  352. Areaid int64 `json:"areaid" xorm:"'AREAID'"` // 机构Id
  353. Memberareaid int64 `json:"memberareaid" xorm:"'MEMBERAREAID'"` // 所属会员ID
  354. Brokerid string `json:"brokerid" xorm:"'BROKERID'"` // 经纪人ID(加密存储)
  355. Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 交易系统帐号Id (加密存储)
  356. Logincode string `json:"logincode" xorm:"'LOGINCODE'"` // 登录帐号 (加密存储)
  357. Openmode int32 `json:"openmode" xorm:"'OPENMODE'"` // 开户方式 - 1:管理端开户 2:网上开户注册(会员官网-手机号) 3:微信开户 4:网页交易端注册 5:安卓手机端注册 6:苹果手机端注册 7:PC交易端注册 8:微信快速开户 9:支付宝快速开户 10:手机号快速开户 11:网上开户注册(会员官网-微信认证) 12:网上开户注册(会员官网-支付宝认证)
  358. Userstate int32 `json:"userstate" xorm:"'USERSTATE'"` // 开户状态 - 1:未提交 2: 待初审 3:初审拒绝 4:待复审 5:复审拒绝 6:测评不通过
  359. Remark string `json:"remark" xorm:"'REMARK'"` // 备注
  360. Isvalidate string `json:"isvalidate" xorm:"'ISVALIDATE'"` // 是否有效 (删除后标记为失效) - 0:无效 1:有效
  361. Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 开户申请时间
  362. Modifiedtime time.Time `json:"modifiedtime" xorm:"'MODIFIEDTIME'"` // 修改时间
  363. Modifiedby int64 `json:"modifiedby" xorm:"'MODIFIEDBY'"` // 修改人帐号
  364. Removebeforestatus int32 `json:"removebeforestatus" xorm:"'REMOVEBEFORESTATUS'"` // REMOVEBEFORESTATUS
  365. Cusbankid string `json:"cusbankid" xorm:"'CUSBANKID'"` // 签约类型
  366. Cusbankname string `json:"cusbankname" xorm:"'CUSBANKNAME'"` // 签约类型名称
  367. Signpdfurl string `json:"signpdfurl" xorm:"'SIGNPDFURL'"` // 签约pdf文件
  368. Referral string `json:"referral" xorm:"'REFERRAL'"` // 推荐人编码
  369. Subbranch string `json:"subbranch" xorm:"'SUBBRANCH'"` // 开户支行
  370. Bankpictureurl string `json:"bankpictureurl" xorm:"'BANKPICTUREURL'"` // 银行卡正面地址
  371. Auditime time.Time `json:"auditime" xorm:"'AUDITIME'"` // 审核时间
  372. Auditedby time.Time `json:"auditedby" xorm:"'AUDITEDBY'"` // 审核人
  373. Videourl string `json:"videourl" xorm:"'VIDEOURL'"` // 视频地址
  374. Signedstatus int32 `json:"signedstatus" xorm:"'SIGNEDSTATUS'"` // 账户一号签签约状态
  375. Userinfotype int32 `json:"userinfotype" xorm:"'USERINFOTYPE'"` // 用户信息类型 - 1:个人 2:企业
  376. Customername string `json:"customername" xorm:"'CUSTOMERNAME'"` // 客户名称(企业名称)
  377. Biznature int32 `json:"biznature" xorm:"'BIZNATURE'"` // 企业性质( 企业) - 1:国有控股企业 2:集体控股企业 3:私人控股企业 4:港澳台商控股企业 5:外商控股企业 6:其它
  378. Bizscope string `json:"bizscope" xorm:"'BIZSCOPE'"` // 企业经营范围(企业)
  379. Legalpersonname string `json:"legalpersonname" xorm:"'LEGALPERSONNAME'"` // 法人姓名(企业)
  380. Contactname string `json:"contactname" xorm:"'CONTACTNAME'"` // 联系人
  381. Countryid int32 `json:"countryid" xorm:"'COUNTRYID'"` // 国家
  382. Provinceid int32 `json:"provinceid" xorm:"'PROVINCEID'"` // 省
  383. Cityid int32 `json:"cityid" xorm:"'CITYID'"` // 市
  384. Districtid int32 `json:"districtid" xorm:"'DISTRICTID'"` // 地区
  385. Postalcode string `json:"postalcode" xorm:"'POSTALCODE'"` // 邮政编码
  386. Company string `json:"company" xorm:"'COMPANY'"` // 公司(个人)
  387. Legalcardfrontphotourl string `json:"legalcardfrontphotourl" xorm:"'LEGALCARDFRONTPHOTOURL'"` // 法人身份证正面照地址
  388. Legalcardbackphotourl string `json:"legalcardbackphotourl" xorm:"'LEGALCARDBACKPHOTOURL'"` // 法人身份证背面照地址
  389. Otherurl string `json:"otherurl" xorm:"'OTHERURL'"` // 其它图片地址[使用分号分隔]
  390. Usertype int32 `json:"usertype" xorm:"'USERTYPE'"` // 用户类型 - 1:投资者 2:机构
  391. Qq string `json:"qq" xorm:"'QQ'"` // QQ(加密存储
  392. Telphone string `json:"telphone" xorm:"'TELPHONE'"` // 联系电话(加密存储)
  393. Attachment1 string `json:"attachment1" xorm:"'ATTACHMENT1'"` // 附件1
  394. Attachment2 string `json:"attachment2" xorm:"'ATTACHMENT2'"` // 附件2
  395. Bankaccountname string `json:"bankaccountname" xorm:"'BANKACCOUNTNAME'"` // 收款人名称
  396. Nickname string `json:"nickname" xorm:"'NICKNAME'"` // 昵称:默认为手机号脱敏(139****9999) 或 名称脱敏(张**)
  397. Headurl string `json:"headurl" xorm:"'HEADURL'"` // 头像地址
  398. Mobile2 string `json:"mobile2" xorm:"'MOBILE2'"` // 手机号码[明文-尚志]
  399. Biztype int32 `json:"biztype" xorm:"'BIZTYPE'"` // 企业类型 - 1:进口/生产 2:销售 3:零售 4:运输 5:仓储
  400. Proxystatementurl string `json:"proxystatementurl" xorm:"'PROXYSTATEMENTURL'"` // 授权委托书
  401. Contactcardfrontphotourl string `json:"contactcardfrontphotourl" xorm:"'CONTACTCARDFRONTPHOTOURL'"` // 联系人证件正面图片地址
  402. Contactcardbackphotourl string `json:"contactcardbackphotourl" xorm:"'CONTACTCARDBACKPHOTOURL'"` // 联系人证件背面图片地址
  403. Attachment3 string `json:"attachment3" xorm:"'ATTACHMENT3'"` // 附件3
  404. Attachment4 string `json:"attachment4" xorm:"'ATTACHMENT4'"` // 附件4
  405. Attachment5 string `json:"attachment5" xorm:"'ATTACHMENT5'"` // 附件5
  406. }
  407. // TableName is WSKH_USERINFO
  408. func (Wskhuserinfo) TableName() string {
  409. return "WSKH_USERINFO"
  410. }
  411. // GetLoginAccountByLoginCode 通过登录代码查询登录账号信息
  412. func GetLoginAccountByLoginCode(loginCode string) (*Loginaccount, error) {
  413. engine := db.GetEngine()
  414. // 如果要使用 *Loginaccount, 则应初始化后再使用
  415. var loginaccount *Loginaccount
  416. loginaccount = &Loginaccount{}
  417. // var loginaccount Loginaccount
  418. has, err := engine.Where("LOGINCODE = ?", loginCode).Get(loginaccount)
  419. if err != nil {
  420. return nil, err
  421. }
  422. if has {
  423. return loginaccount, nil
  424. }
  425. return nil, nil
  426. }
  427. // GetLoginAccountByMobile 通过手机号码查询登录账号信息
  428. func GetLoginAccountByMobile(mobile string) (*Loginaccount, error) {
  429. engine := db.GetEngine()
  430. var loginaccount Loginaccount
  431. var has bool
  432. // 手机号码需要AES加密
  433. key, _ := hex.DecodeString(utils.AESSecretKey)
  434. if mobileEncrypted, err := utils.AESEncrypt([]byte(mobile), key); err == nil {
  435. // 加密成功后进行查询
  436. has, err = engine.Join("INNER", "USERINFO", "USERINFO.USERID = LOGINACCOUNT.USERID").
  437. Where("USERINFO.MOBILE = ?", hex.EncodeToString(mobileEncrypted)).Get(&loginaccount)
  438. if err != nil {
  439. return nil, err
  440. }
  441. }
  442. if has {
  443. return &loginaccount, nil
  444. }
  445. return nil, nil
  446. }
  447. // GetUserAccount 获取用户账户信息
  448. func GetUserAccount(userID int) (*Useraccount, error) {
  449. engine := db.GetEngine()
  450. var userAccount Useraccount
  451. has, err := engine.Where("USERID = ?", userID).Get(&userAccount)
  452. if err != nil {
  453. // 查询失败
  454. return nil, err
  455. }
  456. if !has {
  457. return nil, nil
  458. }
  459. return &userAccount, nil
  460. }
  461. // GetUserInfo 获取用户信息
  462. func GetUserInfo(userID int) (*Userinfo, error) {
  463. engine := db.GetEngine()
  464. var userInfo Userinfo
  465. _, err := engine.Where("USERID = ?", userID).Get(&userInfo)
  466. if err != nil {
  467. // 查询失败
  468. return nil, err
  469. }
  470. return &userInfo, nil
  471. }
  472. // GetUserInfoByLoginID 通过登录账号获取用户信息的方法
  473. func GetUserInfoByLoginID(loginID int) (*Userinfo, error) {
  474. engine := db.GetEngine()
  475. var userInfo Userinfo
  476. _, err := engine.Table("USERINFO U").Join("INNER", "LOGINACCOUNT L", "L.USERID = U.USERID").Where("L.LOGINID = ?", loginID).Get(&userInfo)
  477. if err != nil {
  478. // 查询失败
  479. return nil, err
  480. }
  481. return &userInfo, nil
  482. }
  483. // GetUserInfoByIDS 批量获取用户信息.
  484. func GetUserInfoByIDS(userids []int64) ([]Userinfo, error) {
  485. engine := db.GetEngine()
  486. infos := make([]Userinfo, 0)
  487. err := engine.In("USERID", userids).Find(&infos)
  488. return infos, err
  489. }
  490. // GetUserFavoriteGoodses 获取用户商品收藏信息
  491. func GetUserFavoriteGoodses(userID int) ([]Userfavoritegoods, error) {
  492. engine := db.GetEngine()
  493. favoriteGoodses := make([]Userfavoritegoods, 0)
  494. if err := engine.Where("USERID = ?", userID).Find(&favoriteGoodses); err != nil {
  495. return nil, err
  496. }
  497. return favoriteGoodses, nil
  498. }
  499. // InsertUserFavoriteGoods 新增用户商品收藏信息
  500. func InsertUserFavoriteGoods(userID int, goodsID int) error {
  501. engine := db.GetEngine()
  502. userfavoritegoods := &Userfavoritegoods{
  503. Userid: int64(userID),
  504. Goodsid: int64(goodsID),
  505. }
  506. has, err := engine.Get(userfavoritegoods)
  507. if err != nil {
  508. return err
  509. }
  510. if !has {
  511. // 不存在时则插入一条新记录
  512. // userfavoritegoods.Modifytime = time.Now()
  513. if _, err := engine.Insert(userfavoritegoods); err != nil {
  514. return err
  515. }
  516. }
  517. return nil
  518. }
  519. // DelUserFavoriteGoods 删除用户商品收藏信息
  520. func DelUserFavoriteGoods(userID int, goodsID int) error {
  521. engine := db.GetEngine()
  522. userfavoritegoods := &Userfavoritegoods{
  523. Userid: int64(userID),
  524. Goodsid: int64(goodsID),
  525. }
  526. if _, err := engine.Delete(userfavoritegoods); err != nil {
  527. return err
  528. }
  529. return nil
  530. }
  531. // GetMessageBoard 获取用户留言板信息
  532. func GetMessageBoard(userID int) ([]Messageboard, error) {
  533. engine := db.GetEngine()
  534. messageBoards := make([]Messageboard, 0)
  535. if err := engine.Where("USERID = ?", userID).Desc("CREATETIME").Find(&messageBoards); err != nil {
  536. return nil, err
  537. }
  538. return messageBoards, nil
  539. }
  540. // InsertMessageBoard 新增用户留言板信息
  541. func InsertMessageBoard(userID int, message string) int {
  542. engine := db.GetEngine()
  543. // 一天最多只能新增3条留言
  544. messageBoard := new(Messageboard)
  545. total, err := engine.Where("USERID = ? and (CREATETIME >=TRUNC(SYSDATE) and CREATETIME < TRUNC(SYSDATE)+1)", userID).Count(messageBoard)
  546. if err != nil {
  547. return e.ERROR_OPERATION_FAILED
  548. }
  549. if total >= 3 {
  550. return e.ERROR_ADD_MAX_3
  551. }
  552. // 由于XORM对ORACLE支持不行,有时间字段更新的直接使用SQL语句执行
  553. sql := fmt.Sprintf("insert into MESSAGEBOARD (MESSAGEBOARDID, USERID, MESSAGE, CREATETIME) values (SEQ_MessageBoard.nextval, %d, '%s', (select sysdate from dual))", userID, message)
  554. if _, err := engine.Exec(sql); err != nil {
  555. return e.ERROR_OPERATION_FAILED
  556. }
  557. return 0
  558. }
  559. // GetUsersByUserType 获取批量指定类型的用户信息
  560. // 输入 userType int 账户类型 - 1:交易所 2:机构 3:会员子机构 4:经纪人 5:投资者 6:客户
  561. func GetUsersByUserType(userType int) ([]Userinfo, error) {
  562. engine := db.GetEngine()
  563. userInfos := make([]Userinfo, 0)
  564. if err := engine.Where("USERTYPE = ?", userType).Find(&userInfos); err != nil {
  565. return nil, err
  566. }
  567. return userInfos, nil
  568. }
  569. // GetTaAccountsByType 获取指定用户的资金账户列表
  570. // 输入 userID int 关联用户ID
  571. // 输入 taAccountType int 账号类型 - 1:外部账号 2:内部账号 3:内部做市自营账号 4:内部做市接单账号
  572. func GetTaAccountsByType(userID, taAccountType int) ([]Taaccount, error) {
  573. engine := db.GetEngine()
  574. taAccounts := make([]Taaccount, 0)
  575. session := engine.Where("RELATEDUSERID = ?", userID)
  576. if taAccountType != 0 {
  577. session = session.And("TAACCOUNTTYPE = ?", taAccountType)
  578. }
  579. if err := session.Find(&taAccounts); err != nil {
  580. return nil, err
  581. }
  582. return taAccounts, nil
  583. }
  584. // GetTaAccountsByLoginID 通过登录账号获取对应资金账户列表的方法,一般用于获取自己的资金账号时使用
  585. // 输入 loginID int 登录账号
  586. // 输入 taAccountType int 账号类型 - 1:外部账号 2:内部账号 3:内部做市自营账号 4:内部做市接单账号
  587. func GetTaAccountsByLoginID(loginID, taAccountType int) ([]Taaccount, error) {
  588. engine := db.GetEngine()
  589. taAccounts := make([]Taaccount, 0)
  590. // 注意:获取自身的资金账号列表,先要从LoginTAAccount表中判断是否有关联关系,如没配置关系则直接从TaAccount表中获取
  591. loginTaAccounts := make([]Logintaaccount, 0)
  592. if err := engine.Where("LOGINID = ?", loginID).Find(&loginTaAccounts); err != nil {
  593. return nil, err
  594. }
  595. if len(loginTaAccounts) > 0 {
  596. // 获取资金账号ID列表
  597. accountIDs := ""
  598. for _, v := range loginTaAccounts {
  599. if len(accountIDs) == 0 {
  600. accountIDs = strconv.Itoa(int(v.Accountid))
  601. } else {
  602. accountIDs += "," + strconv.Itoa(int(v.Accountid))
  603. }
  604. }
  605. // 获取资金账号列表
  606. session := engine.Where(fmt.Sprintf("ACCOUNTID in (%s)", accountIDs))
  607. if taAccountType != 0 {
  608. session = session.And("TAACCOUNTTYPE = ?", taAccountType)
  609. }
  610. if err := session.Find(&taAccounts); err != nil {
  611. return nil, err
  612. }
  613. } else {
  614. // 直接从TaAccount表中获取
  615. session := engine.Table("TAACCOUNT").
  616. Join("INNER", "LOGINACCOUNT L", "L.USERID = TAACCOUNT.RELATEDUSERID").
  617. Where("L.LOGINID = ?", loginID)
  618. if taAccountType != 0 {
  619. session = session.And("TAACCOUNT.TAACCOUNTTYPE = ?", taAccountType)
  620. }
  621. if err := session.Find(&taAccounts); err != nil {
  622. return nil, err
  623. }
  624. }
  625. return taAccounts, nil
  626. }
  627. // InsertWSKHUserInfo 新增网上开户账户信息(客户资料申请)
  628. func InsertWSKHUserInfo(userinfo Wskhuserinfo) error {
  629. engine := db.GetEngine()
  630. // 加密数据
  631. key, _ := hex.DecodeString(utils.AESSecretKey)
  632. // 证件号码
  633. if len(userinfo.Cardnum) > 0 {
  634. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Cardnum), key); err == nil {
  635. userinfo.Cardnum = hex.EncodeToString(encrypted)
  636. }
  637. }
  638. // 证件地址
  639. if len(userinfo.Cardaddress) > 0 {
  640. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Cardaddress), key); err == nil {
  641. userinfo.Cardaddress = hex.EncodeToString(encrypted)
  642. }
  643. }
  644. // 手机
  645. if len(userinfo.Mobilephone) > 0 {
  646. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Mobilephone), key); err == nil {
  647. userinfo.Mobilephone = hex.EncodeToString(encrypted)
  648. }
  649. }
  650. // 微信
  651. if len(userinfo.Wechat) > 0 {
  652. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Wechat), key); err == nil {
  653. userinfo.Wechat = hex.EncodeToString(encrypted)
  654. }
  655. }
  656. // 邮件
  657. if len(userinfo.Email) > 0 {
  658. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Email), key); err == nil {
  659. userinfo.Email = hex.EncodeToString(encrypted)
  660. }
  661. }
  662. // 银行帐号
  663. if len(userinfo.Bankaccount) > 0 {
  664. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Bankaccount), key); err == nil {
  665. userinfo.Bankaccount = hex.EncodeToString(encrypted)
  666. }
  667. }
  668. // 经纪人ID
  669. if len(userinfo.Brokerid) > 0 {
  670. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Brokerid), key); err == nil {
  671. userinfo.Brokerid = hex.EncodeToString(encrypted)
  672. }
  673. }
  674. // 登录帐号
  675. if len(userinfo.Logincode) > 0 {
  676. if encrypted, err := utils.AESEncrypt([]byte(userinfo.Logincode), key); err == nil {
  677. userinfo.Logincode = hex.EncodeToString(encrypted)
  678. }
  679. }
  680. // 自增ID
  681. seqMap, err := engine.QueryString("SELECT SEQ_WSKH_USERINFO.nextval USERID FROM dual")
  682. if err != nil {
  683. return err
  684. }
  685. if len(seqMap) <= 0 {
  686. return errors.New("获取自增ID错误")
  687. }
  688. userID, _ := strconv.Atoi(seqMap[0]["USERID"])
  689. userinfo.Userid = int64(userID)
  690. // 插入数据
  691. if _, err = engine.Insert(&userinfo); err != nil {
  692. return err
  693. }
  694. return nil
  695. }
  696. // GetWSKHUserInfos 获取开户信息列表
  697. func GetWSKHUserInfos(userName string) ([]Wskhuserinfo, error) {
  698. engine := db.GetEngine()
  699. userInfos := make([]Wskhuserinfo, 0)
  700. session := engine.Table("WSKH_USERINFO")
  701. if len(userName) > 0 {
  702. session = session.Where(fmt.Sprintf("USERNAME like '%%%s%%'", userName))
  703. }
  704. if err := session.Find(&userInfos); err != nil {
  705. return nil, err
  706. }
  707. return userInfos, nil
  708. }
  709. // GetUserInfos 获取用户信息
  710. // 输入 userName string 客户名称,支持模糊查询
  711. func GetUserInfos(userName string) ([]Userinfo, error) {
  712. engine := db.GetEngine()
  713. userInfos := make([]Userinfo, 0)
  714. session := engine.Table("USERINFO")
  715. if len(userName) > 0 {
  716. session = session.Where(fmt.Sprintf("CUSTOMERNAME like '%%%s%%'", userName))
  717. }
  718. if err := session.Find(&userInfos); err != nil {
  719. return nil, err
  720. }
  721. return userInfos, nil
  722. }