account.go 70 KB

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