MTP20_IF/models/ermcpAccMgr.go

/**
* @Author: zou.yingbin
* @Create  : 2021/3/30 13:38
* @Modify  : 2021/3/30 13:38
* @note    : 账户管理
**/

package models

import (
	"fmt"
	"mtp2_if/db"
	"mtp2_if/mtpcache"
	"mtp2_if/utils"
	"strings"
)

// ErmcpLoginUserEx 登录账号(按角色)
type ErmcpLoginUserEx struct {
	ROLENAME      string           `json:"rolename"`                              // 角色名称(交易账户->用户名称)
	USERTYPE      int32            `json:"usertype"`                              // 用户类型 2-机构 7-企业成员(云平台)
	UserList      []ErmcpLoginUser `json:"userlist"`                              // 用户列表
	RoleId        int64            `json:"roleid"`                                // 角色id(交易账户->用户id)
	MOBILE        string           `json:"mobile"  xorm:"'MOBILE'"`               // 手机号
	ACCOUNTSTATUS int32            `json:"accountstatus"  xorm:"'ACCOUNTSTATUS'"` // 账户的状态 - 1:待激活 2:待审核 3:待复审 4:正常 5:审核拒绝 6:停用(注销) 7:注销(删除)
	QUERYTYPE     int32            `json:"querytype"`                             // 查询类型 1-业务账户 2-交易账户 3-管理账户
}

// ErmcpLoginUser 查询登录账户
type ErmcpLoginUser struct {
	USERID        int64                 `json:"userid"  xorm:"'USERID'"`             // 用户id
	MEMBERUSERID  int64                 `json:"memberuserid"  xorm:"'MEMBERUSERID'"` // 所属会员id
	ACCOUNTNAME   string                `json:"accountname"  xorm:"'ACCOUNTNAME'"`   // 用户名称
	USERTYPE      int32                 `json:"usertype"  xorm:"'USERTYPE'"`         // 用户类型 -  1:交易所 2:机构 3:会员子机构 4:经纪人 5:投资者 6:客户 7:企业成员(云平台)
	ACCOUNTSTATUS int32                 `json:"-"  xorm:"'ACCOUNTSTATUS'"`           // 所属账户的状态 - 1:待激活 2:待审核 3:待复审 4:正常 5:审核拒绝 6:停用(注销) 7:注销(删除)
	LOGINSTATUS   int32                 `json:"loginstatus"  xorm:"'LOGINSTATUS'"`   // 登录账户状态 - 1:正常 2:冻结 3:无效
	CREATETIME    string                `json:"createtime"  xorm:"'CREATETIME'"`     // 创建时间
	MODIFYTIME    string                `json:"modifytime"  xorm:"'MODIFYTIME'"`     // 修改时间
	ROLETYPE      string                `json:"roletype"  xorm:"'ROLETYPE'"`         // 角色类型(逗号隔开,如22,23), 22:业务员 23:跟单员 24:交易员
	CLIENTROLEID  int32                 `json:"clientroleid"  xorm:"'CLIENTROLEID'"` // 角色id(usertype=2)
	ROLENAME      string                `json:"rolename"  xorm:"'ROLENAME'"`         // 角色名称
	ROLESTATUS    int32                 `json:"rolestatus"  xorm:"'ROLESTATUS'"`     // 角色状态 1-启用 2-停用
	LOGINCODE     string                `json:"logincode"  xorm:"'LOGINCODE'"`       // 登录代码
	LOGINID       int64                 `json:"loginid"  xorm:"'LOGINID'"`           // 登录id(LOGINID)
	PASSWORD      string                `json:"password"  xorm:"'PASSWORD'"`         // 密码(不可解密)
	MOBILE        string                `json:"mobile"  xorm:"'MOBILE'"`             // 手机号
	LOGINNAME     string                `json:"loginname"  xorm:"'LOGINNAME'"`       // 登录名称(loginaccount表中的accountname字段)
	USERMOBILE    string                `json:"-"  xorm:"'usermobile'"`              // 所属用户手机号码
	AccList       []ErmcpLoginTaAccount `json:"acclist"`                             // 关联资金账号

	QueryType int32 `json:"-"` // 过滤条件 查询类型 1-业务账户 2-交易账户 3-管理账户
}

func (r *ErmcpLoginUser) addAcc(accLst []ErmcpLoginTaAccount) {
	for i := range accLst {
		if accLst[i].LOGINID == r.LOGINID {
			r.AccList = append(r.AccList, accLst[i])
		}
	}
}

func (r *ErmcpLoginUser) calc() {
	r.MOBILE = DecryptField(r.MOBILE)
	r.USERMOBILE = DecryptField(r.USERMOBILE)
}

func (r *ErmcpLoginUser) buildSqlRoleAcc() string {
	var sqlId utils.SQLVal = "with tmp as" +
		" (select userid, wm_concat(roletype) roletype from arearole group by userid)" +
		"select t.userid," +
		"       t.memberuserid," +
		"       t.usertype," +
		"       t.accountname," +
		"       t.accountstatus," +
		"       u.mobile usermobile," +
		"       to_char(t.createtime, 'yyyy-mm-dd hh24:mi:ss') createtime," +
		"       to_char(t.modifytime, 'yyyy-mm-dd hh24:mi:ss') modifytime," +
		"       r.roletype," +
		"       1 as rolestatus," +
		"       l.logincode," +
		"       l.loginid," +
		"       l.clientroleid," +
		"       '企业成员' rolename," +
		"       l.loginstatus," +
		"       l.password," +
		"       l.mobile," +
		"       l.accountname loginname" +
		"  from useraccount t" +
		"  left join loginaccount l" +
		"    on t.userid = l.userid" +
		"  left join userinfo u on t.userid=u.userid" +
		"  left join tmp r" +
		"    on t.userid = r.userid" +
		" where 1 = 1" +
		"   and t.memberuserid = %v" +
		"   and t.usertype = 7"
	sqlId.FormatParam(r.USERID)
	return sqlId.String()
}

func (r *ErmcpLoginUser) buildSqlManageAcc() string {
	var sqlId utils.SQLVal = "select t.userid," +
		"       t.memberuserid," +
		"       t.usertype," +
		"       t.accountname," +
		"       to_char(t.createtime, 'yyyy-mm-dd hh24:mi:ss') createtime," +
		"       to_char(t.modifytime, 'yyyy-mm-dd hh24:mi:ss') modifytime," +
		"       to_char(r.roletype) roletype," +
		"       r.rolestatus," +
		"       l.logincode," +
		"       l.loginid," +
		"       l.clientroleid," +
		"       Nvl(r.rolename, l.clientroleid) rolename," +
		"       l.loginstatus," +
		"       l.password," +
		"       l.mobile," +
		"       l.accountname loginname" +
		"  from useraccount t" +
		"  left join loginaccount l" +
		"    on t.userid = l.userid" +
		"  left join systemmanagerrole r" +
		"    on l.clientroleid = r.autoid" +
		"   and r.areauserid = l.userid" +
		" where 1 = 1" +
		"   and t.userid = %v" +
		"   and t.usertype = 2"
	sqlId.FormatParam(r.USERID)
	return sqlId.String()
}

// hasRoletype 是否拥用某种角色
func (r *ErmcpLoginUser) hasRoletype(nType int32) bool {
	sType := strings.Split(r.ROLETYPE, ",")
	strType := fmt.Sprintf("%v", nType)
	for i := range sType {
		if sType[i] == strType {
			return true
		}
	}
	return false
}

// getBizLoginAcc 获取业务账号(角色为22, 23)
func (r *ErmcpLoginUser) getBizLoginAcc() ([]ErmcpLoginUserEx, error) {
	sDataEx := make([]ErmcpLoginUserEx, 0)
	sDataEx = append(sDataEx, ErmcpLoginUserEx{
		ROLENAME:  "业务员",
		RoleId:    22,
		UserList:  make([]ErmcpLoginUser, 0),
		USERTYPE:  7,
		QUERYTYPE: r.QueryType})
	sDataEx = append(sDataEx, ErmcpLoginUserEx{
		ROLENAME:  "跟单员",
		RoleId:    23,
		UserList:  make([]ErmcpLoginUser, 0),
		USERTYPE:  7,
		QUERYTYPE: r.QueryType})
	// 查询用户
	sData := make([]ErmcpLoginUser, 0)
	err := db.GetEngine().SQL(r.buildSqlRoleAcc()).Find(&sData)
	for i := range sData {
		sData[i].calc()
		sData[i].AccList = make([]ErmcpLoginTaAccount, 0)
	}
	// 查询登录账号关联的资金账号
	if len(sData) > 0 {
		m := ErmcpLoginTaAccount{}
		if accLst, err := m.GetData(); err == nil {
			for i := range sData {
				sData[i].addAcc(accLst)
			}
		}
	}
	// 按角色分组
	for _, v := range sData {
		for i := range sDataEx {
			// 企业成员usertype=7需根据roletype判断
			if sDataEx[i].RoleId == 22 && v.hasRoletype(22) {
				v.ROLENAME = sDataEx[i].ROLENAME
				sDataEx[i].UserList = append(sDataEx[i].UserList, v)
			}
			if sDataEx[i].RoleId == 23 && v.hasRoletype(23) {
				v.ROLENAME = sDataEx[i].ROLENAME
				sDataEx[i].UserList = append(sDataEx[i].UserList, v)
			}
		}
	}

	return sDataEx, err
}

// getTradeLoginAcc 获取交易账号(角色id为24, 但是要按用户分组)
func (r *ErmcpLoginUser) getTradeLoginAcc() ([]ErmcpLoginUserEx, error) {
	sDataEx := make([]ErmcpLoginUserEx, 0)
	// 查询用户
	sData := make([]ErmcpLoginUser, 0)
	err := db.GetEngine().SQL(r.buildSqlRoleAcc()).Find(&sData)
	for i := range sData {
		sData[i].calc()
		sData[i].AccList = make([]ErmcpLoginTaAccount, 0)
	}
	// 查询登录账号关联的资金账号
	if len(sData) > 0 {
		m := ErmcpLoginTaAccount{}
		if accLst, err := m.GetData(); err == nil {
			for i := range sData {
				sData[i].addAcc(accLst)
			}
		}
	}
	// 按用户分组
	for _, v := range sData {
		if v.hasRoletype(24) {
			bExist := false
			for i := range sDataEx {
				if sDataEx[i].RoleId == v.USERID {
					sDataEx[i].UserList = append(sDataEx[i].UserList, v)
					bExist = true
					break
				}
			}
			if !bExist {
				val := ErmcpLoginUserEx{RoleId: v.USERID, ROLENAME: v.ACCOUNTNAME, USERTYPE: 7,
					MOBILE: v.USERMOBILE, ACCOUNTSTATUS: v.ACCOUNTSTATUS,
					UserList: make([]ErmcpLoginUser, 0), QUERYTYPE: r.QueryType}
				if v.LOGINID > 0 {
					val.UserList = append(val.UserList, v)
				}
				sDataEx = append(sDataEx, val)
			}
		}
	}

	return sDataEx, err
}

// getMangeLoginAcc 获取管理账户(角色表中创建的角色)
func (r *ErmcpLoginUser) getMangeLoginAcc() ([]ErmcpLoginUserEx, error) {
	sDataEx := make([]ErmcpLoginUserEx, 0)
	// 查询角色
	m := ErmcpRole{AREAUSERID: r.USERID}
	roles, _ := m.GetData()
	if len(roles) == 0 {
		return sDataEx, nil
	}
	// 初始化角色列表
	for _, val := range roles {
		sDataEx = append(sDataEx, ErmcpLoginUserEx{
			ROLENAME:  val.ROLENAME,
			RoleId:    int64(val.AUTOID),
			UserList:  make([]ErmcpLoginUser, 0),
			USERTYPE:  2,
			QUERYTYPE: r.QueryType,
		})
	}
	// 查询用户
	sData := make([]ErmcpLoginUser, 0)
	err := db.GetEngine().SQL(r.buildSqlManageAcc()).Find(&sData)
	for i := range sData {
		sData[i].calc()
		sData[i].AccList = make([]ErmcpLoginTaAccount, 0)
	}
	// 查询登录账号关联的资金账号
	if len(sData) > 0 {
		m := ErmcpLoginTaAccount{}
		if accLst, err := m.GetData(); err == nil {
			for i := range sData {
				sData[i].addAcc(accLst)
			}
		}
	}
	// 管理员用户分组(按角色)
	for _, v := range sData {
		for i := range sDataEx {
			// 企业管理角色直接使用CLIENTROLEID判断
			if sDataEx[i].RoleId == int64(v.CLIENTROLEID) {
				sDataEx[i].UserList = append(sDataEx[i].UserList, v)
			}
		}
	}

	return sDataEx, err
}

// GetDataEx 查询登录用户
func (r *ErmcpLoginUser) GetDataEx() (interface{}, error) {
	if r.QueryType == 1 {
		return r.getBizLoginAcc()
	} else if r.QueryType == 2 {
		return r.getTradeLoginAcc()
	} else {
		return r.getMangeLoginAcc()
	}
}

// ErmcpTaAccount 期货账户(分组)
type ErmcpTaAccountEx struct {
	MainAcc    ErmcpTaAccountM  `json:"mainAcc"`    // 主账号
	SubAccList []ErmcpTaAccount `json:"subacclist"` // 子账号列表
}

// 显示主账户额外信息
type ErmcpTaAccountM struct {
	ErmcpTaAccount
	FCID   int32  `json:"fcid"  xorm:"'FCID'"`     // 期货公司id
	FCNAME string `json:"fcname"  xorm:"'FCNAME'"` // 期货公司代码
}

// ErmcpTaAccount 期货账户
type ErmcpTaAccount struct {
	ACCOUNTID          int64  `json:"accountid"  xorm:"'ACCOUNTID'"`                   // 账户id
	CURRENCYID         int32  `json:"currencyid"  xorm:"'CURRENCYID'"`                 // 币种id
	TRADESTATUS        int32  `json:"tradestatus"  xorm:"'TRADESTATUS'"`               // 交易状态 - 1:正常 2:受限 3:冻结 4:禁止建仓(人工受限) 5:禁止交易(人工冻结) 6:待激活 7:已注销
	ISMAIN             int32  `json:"ismain"  xorm:"'ISMAIN'"`                         // 是否主账户 0-否 1-是
	USERID             int64  `json:"userid"  xorm:"'USERID'"`                         // 用户id
	RELATEDUSERID      int64  `json:"relateduserid"  xorm:"'RELATEDUSERID'"`           // 关联userid
	ACCOUNTNAME        string `json:"accountname"  xorm:"'ACCOUNTNAME'"`               // 账户名称
	PARENTACCOUNTID    int64  `json:"parentaccountid"  xorm:"'PARENTACCOUNTID'"`       // 父账户id
	TRADEMARGINTMPID   int32  `json:"trademargintmpid"  xorm:"'TRADEMARGINTMPID'"`     // 保证金模板id
	TRADEFEETMPID      int32  `json:"tradefeetmpid"  xorm:"'TRADEFEETMPID'"`           // 手续费模板id
	TRADERATETMPID     int32  `json:"traderatetmpid"  xorm:"'TRADERATETMPID'"`         // 汇率模板id
	TRADEMARGINTMPNAME string `json:"trademargintmpname"  xorm:"'TRADEMARGINTMPNAME'"` // 保证金模板名称
	TRADEFEETMPNAME    string `json:"tradefeetmpname"  xorm:"'TRADEFEETMPNAME'"`       // 手续费模板名称
	TRADERATETMPNAME   string `json:"traderatetmpname"  xorm:"'TRADERATETMPNAME'"`     // 汇率模板名称

	HEDGEACCOUNTCODE string `json:"hedgeaccountcode"  xorm:"'HEDGEACCOUNTCODE'"` // 主账号登录代码(仅当是主账号时有值,子账号没有登录账号)
}

func (r *ErmcpTaAccount) calc() {

}

func (r *ErmcpTaAccount) buildSql() string {
	var sqlId utils.SQLVal = "select t.accountid," +
		"       t.currencyid," +
		"       t.tradestatus," +
		"       t.ismain," +
		"       t.userid," +
		"       t.relateduserid," +
		"       t.accountname," +
		"       t.parentaccountid," +
		"       l.hedgeaccountcode," +
		"       c.trademargintmpid," +
		"       c.tradefeetmpid," +
		"       c.traderatetmpid," +
		"       a.tradeconfigtmpname trademargintmpname," +
		"       b.tradeconfigtmpname tradefeetmpname," +
		"       k.tradeconfigtmpname traderatetmpname" +
		"  from taaccount t" +
		"  left join hedge_outmainconfig l" +
		"    on t.accountid = l.accountid" +
		"   and t.ismain = 1" +
		"  left join taaccountconfig c on t.accountid=c.accountid" +
		"  left join tradeconfigtmp a on c.trademargintmpid = a.tradeconfigtmpid" +
		"  left join tradeconfigtmp b on c.tradefeetmpid = b.tradeconfigtmpid" +
		"  left join tradeconfigtmp k on c.traderatetmpid = k.tradeconfigtmpid" +
		" where 1 = 1" +
		"   and t.taaccounttype = 1"
	sqlId.And("t.userid", r.USERID)
	return sqlId.String()
}

// GetDataEx 查询企业期货账户
func (r *ErmcpTaAccount) GetDataEx() (interface{}, error) {
	sData := make([]ErmcpTaAccount, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	sDataEx := make([]ErmcpTaAccountEx, 0)
	// 主账号
	for i := range sData {
		if sData[i].ISMAIN == 1 {
			val := ErmcpTaAccountEx{MainAcc: ErmcpTaAccountM{ErmcpTaAccount: sData[i]},
				SubAccList: make([]ErmcpTaAccount, 0)}
			sDataEx = append(sDataEx, val)
		}
	}
	// 获取主账号额外信息
	m := MainAccountInfo{USERID: r.USERID}
	if d, err := m.GetDataEx(); err == nil {
		if acc, ok := d.([]MainAccountInfo); ok {
			for _, v := range acc {
				for i := range sDataEx {
					if sDataEx[i].MainAcc.ACCOUNTID == v.ACCOUNTID {
						sDataEx[i].MainAcc.FCID = v.FCID
						sDataEx[i].MainAcc.FCNAME = v.FCNAME
					}
				}
			}
		}
	}
	// 子账号
	for i := range sData {
		if sData[i].ISMAIN == 0 {
			for k := range sDataEx {
				if sDataEx[k].MainAcc.ACCOUNTID == sData[i].PARENTACCOUNTID {
					sDataEx[k].SubAccList = append(sDataEx[k].SubAccList, sData[i])
				}
			}
		}
	}

	return sDataEx, err
}

// MainAccountInfo 主账号详情
type MainAccountInfo struct {
	ACCOUNTID        int64  `json:"accountid"  xorm:"'ACCOUNTID'"`               // 账号id
	HEDGEACCOUNTCODE string `json:"hedgeaccountcode"  xorm:"'HEDGEACCOUNTCODE'"` // 外部账号代码(主账号登录代码)
	HEDGEACCOUNTPWD  string `json:"hedgeaccountpwd"  xorm:"'HEDGEACCOUNTPWD'"`   // 密码
	AUTHCODE         string `json:"authcode"  xorm:"'AUTHCODE'"`                 // 授权码
	APPID            string `json:"appid"  xorm:"'APPID'"`                       // AppID
	BROKERID         string `json:"brokerid"  xorm:"'BROKERID'"`                 // 经纪商id
	FCID             int32  `json:"fcid"  xorm:"'FCID'"`                         // 期货公司id
	FCNAME           string `json:"fcname"  xorm:"'FCNAME'"`                     // 期货公司代码
	ISMAIN           int32  `json:"ismain"  xorm:"'ISMAIN'"`                     // 是否主账号
	USERID           int64  `json:"userid"  xorm:"'USERID'"`                     // 关联用户id
	RELATEDUSERID    int64  `json:"relateduserid"  xorm:"'RELATEDUSERID'"`       // 关联用户id
	ACCOUNTNAME      string `json:"accountname"  xorm:"'ACCOUNTNAME'"`           // 账号名称(taaccount表中的名称)
}

func (r *MainAccountInfo) calc() {
	r.HEDGEACCOUNTPWD = DecryptField(r.HEDGEACCOUNTPWD)
}

func (r *MainAccountInfo) buildSql() string {
	var sqlId utils.SQLVal = "select c.accountid," +
		"       c.hedgeaccountcode," +
		"       c.hedgeaccountpwd," +
		"       c.authcode," +
		"       c.appid," +
		"       c.brokerid," +
		"       c.fcid," +
		"       f.fcname," +
		"       ta.ismain," +
		"       ta.relateduserid," +
		"       ta.userid," +
		"       ta.accountname" +
		"  from hedge_outmainconfig c" +
		"  left join ERMCP_FuturesCompany f" +
		"    on c.fcid = f.fcid" +
		"  left join taaccount ta" +
		"    on c.accountid = ta.accountid" +
		" where 1 = 1"

	sqlId.AndEx("ta.userid", r.USERID, r.USERID > 0)
	sqlId.AndEx("ta.relateduserid", r.RELATEDUSERID, r.RELATEDUSERID > 0)
	sqlId.AndInterEx("c.ACCOUNTID", r.ACCOUNTID, r.ACCOUNTID > 0)

	return sqlId.String()
}

// GetDataEx 查询主账号信息
func (r *MainAccountInfo) GetDataEx() (interface{}, error) {
	sData := make([]MainAccountInfo, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// ErmcpRole 角色
type ErmcpRole struct {
	AUTOID     int32  `json:"autoid"  xorm:"'AUTOID'"`         // 角色ID(自增ID)
	ROLENAME   string `json:"rolename"  xorm:"'ROLENAME'"`     // 角色名称
	AREAUSERID int64  `json:"areauserid"  xorm:"'AREAUSERID'"` // 所属机构
	ROLESTATUS int32  `json:"rolestatus"  xorm:"'ROLESTATUS'"` // 角色状态 - 1:启用  2：停用
	ROLETYPE   int32  `json:"roletype"  xorm:"'ROLETYPE'"`     // 角色类型 - 1- 管理端   2-  交易端
	MODIFYTIME string `json:"modifytime"  xorm:"'MODIFYTIME'"` // 修改时间(创建时间)
	MODIFIERID int64  `json:"modifierid"  xorm:"'MODIFIERID'"` // 修改人(创建人)

	MODIFIERNAME string `json:"modifiername"` // 修改人名称
}

func (r *ErmcpRole) calc() {
	if r.MODIFIERID > 0 {
		r.MODIFIERNAME = mtpcache.GetSystemmangerLoginCode(r.MODIFIERID)
		// 目前看表里修改人id存的是管理员id,为防止以后终端操作存的是登录id,多做一层判断
		// 如果按管理员id找不到，则按登录id试试
		if r.MODIFIERID > 1e8 && len(r.MODIFIERNAME) == 0 {
			r.MODIFIERNAME = mtpcache.GetLoginCodeByLoginId(r.MODIFIERID)
		}
	}
}

func (r *ErmcpRole) buildSql() string {
	var sqlId utils.SQLVal = "SELECT t.AUTOID," +
		"       t.ROLENAME," +
		"       t.AREAUSERID," +
		"       t.ROLESTATUS," +
		"       t.ROLETYPE," +
		"       t.SENSITIVEFIELDS," +
		"       to_char(t.MODIFYTIME, 'yyyy-mm-dd hh24:mi:ss') MODIFYTIME," +
		"       to_char(t.MODIFIERID) MODIFIERID" +
		"  FROM SYSTEMMANAGERROLE t" +
		" WHERE 1 = 1"
	if r.AREAUSERID > 0 {
		sqlId.And("t.AREAUSERID", r.AREAUSERID)
	}
	return sqlId.String()
}

// GetData
func (r *ErmcpRole) GetData() ([]ErmcpRole, error) {
	sData := make([]ErmcpRole, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// GetDataEx 查询角色
func (r *ErmcpRole) GetDataEx() (interface{}, error) {
	return r.GetData()
}

// ErmcpRoleMenuEx 角色菜单(分层级)
type ErmcpRoleMenuEx struct {
	Menu    ErmcpRoleMenu     // 父级菜单
	SubMenu []ErmcpRoleMenuEx // 子级菜单
}

// add 添加子级菜单
func (r *ErmcpRoleMenuEx) add(menu ErmcpRoleMenuEx) {
	if menu.Menu.PARENTCODE == r.Menu.RESOURCECODE {
		r.SubMenu = append(r.SubMenu, menu)
	}
}

// addEx 添加子级菜单（不包括PARENTCODE为空的）
func (r *ErmcpRoleMenuEx) addEx(menus []ErmcpRoleMenu) {
	for _, v := range menus {
		if v.PARENTCODE == r.Menu.RESOURCECODE {
			e := ErmcpRoleMenuEx{Menu: v, SubMenu: make([]ErmcpRoleMenuEx, 0)}
			// 递归构建子菜单
			e.addEx(menus)

			r.SubMenu = append(r.SubMenu, e)
		}
	}
}

// setRold 设置菜单权限（包括子菜单）
func (r *ErmcpRoleMenuEx) setRold(menus []ErmcpRoleMenu) {
	for _, v := range menus {
		if r.Menu.RESOURCECODE == v.RESOURCECODE {
			r.Menu.ISHADROLE = true
			break
		}
	}

	// 递归设置子菜单权限
	for i := range r.SubMenu {
		s := &r.SubMenu[i]
		s.setRold(menus)
	}
}

// ErmcpRoleMenu 角色菜单
type ErmcpRoleMenu struct {
	USERID        int64  `json:"userid"  xorm:"'USERID'"`               // 用户id
	ROLEID        int32  `json:"roleid"  xorm:"'ROLEID'"`               // 角色id
	RESOURCECODE  string `json:"resourcecode"  xorm:"'RESOURCECODE'"`   // 菜单代码
	RESOURCENAME  string `json:"resourcename"  xorm:"'RESOURCENAME'"`   // 菜单名称
	RESOURCELEVEL int32  `json:"resourcelevel"  xorm:"'RESOURCELEVEL'"` // 级别
	MENUTYPE      int32  `json:"menutype"  xorm:"'MENUTYPE'"`           // 菜单类型 1:管理端 2:交易端 3:终端(企业云平台)
	PARENTCODE    string `json:"parentcode"  xorm:"'PARENTCODE'"`       // 上级资源代码
	URL           string `json:"url"  xorm:"'URL'"`                     // URL
	SORT          int32  `json:"sort"  xorm:"'SORT'"`                   // 排序
	ICONAME       string `json:"iconame"  xorm:"'ICONAME'"`             // 菜单图标
	REMARK        string `json:"remark"  xorm:"'REMARK'"`               // 菜单备注

	ISHADROLE bool `json:"ishadrole" xorm:"-"` // 是否有权限

	FilterRoleId string `json:"-"` // 查询过滤条件, 角色 - 逗号隔开
}

func (r *ErmcpRoleMenu) calc() {
}

func (r *ErmcpRoleMenu) buildSql() string {
	var sqlId utils.SQLVal = "select distinct t.userid," +
		"       t.roleid," +
		"       f.resourcecode," +
		"       f.resourcename," +
		"       f.resourcelevel," +
		"       f.menutype," +
		"       f.parentcode," +
		"       f.url," +
		"       f.sort," +
		"       f.iconame," +
		"       f.remark" +
		"  from ermcp_memberfuncmenu t" +
		" inner join funcmenulist f" +
		"    on t.resourcecode = f.resourcecode and f.menutype = 3" +
		" where t.isvalid = 1"
	if r.USERID > 0 {
		sqlId.And("t.userid", r.USERID)
	}
	if len(r.FilterRoleId) > 0 {
		sqlId.Join(fmt.Sprintf(" and t.roleid in(%v)", r.FilterRoleId))
	}
	sqlId.Join(" order by f.resourcelevel, f.sort")

	return sqlId.String()
}

// GetDataEx 查询角色菜单
func (r *ErmcpRoleMenu) GetDataEx() (interface{}, error) {
	sDataEx := make([]ErmcpRoleMenuEx, 0)

	// 获取所有菜单
	sData := make([]ErmcpRoleMenu, 0)
	sql := "select 0 userid," +
		"       0 roleid," +
		"       f.resourcecode," +
		"       f.resourcename," +
		"       f.resourcelevel," +
		"       f.menutype," +
		"       f.parentcode," +
		"       f.url," +
		"       f.sort," +
		"       f.iconame," +
		"       f.remark" +
		" from funcmenulist f" +
		" where f.menutype = 3 and f.resourcelevel <> 0"
	_ = db.GetEngine().SQL(sql).Find(&sData)
	// 先创建PARENTCODE为空的记录
	for _, v := range sData {
		if v.PARENTCODE == "" {
			sDataEx = append(sDataEx, ErmcpRoleMenuEx{Menu: v, SubMenu: make([]ErmcpRoleMenuEx, 0)})
		}
	}
	// 再构建所有子菜单
	for i := range sDataEx {
		v := &sDataEx[i]
		v.addEx(sData)
	}

	// 获取有权限的菜单
	var err error
	if len(r.FilterRoleId) > 0 {
		rData := make([]ErmcpRoleMenu, 0)
		err = db.GetEngine().SQL(r.buildSql()).Find(&rData)
		// 判断权限
		for i := range sDataEx {
			s := &sDataEx[i]
			s.setRold(rData)
		}
	}

	return sDataEx, err
}

// ErmcpBizGroupSpotGoods 业务类型分组商品表
type ErmcpBizGroupSpotGoods struct {
	BIZTYPE           int32  `json:"biztype"  xorm:"'BIZTYPE'"`                     // 业务类型 1-套保 2-套利
	BIZGROUPID        int64  `json:"bizgroupid"  xorm:"'BIZGROUPID'"`               // 分组id
	DELIVERYGOODSID   int32  `json:"deliverygoodsid"  xorm:"'DELIVERYGOODSID'"`     // 现货商品id
	DELIVERYGOODSCODE string `json:"deliverygoodscode"  xorm:"'DELIVERYGOODSCODE'"` // 现货商品代码
	DELIVERYGOODSNAME string `json:"deliverygoodsname"  xorm:"'DELIVERYGOODSNAME'"` // 现货商品名称
	GOODSUNITID       int32  `json:"unitid"  xorm:"'UNITID'"`                       // 现货商品单位id
	AREAUSERID        int64  `json:"areauserid"  xorm:"'AREAUSERID'"`               // 所属机构id
}

func (r *ErmcpBizGroupSpotGoods) calc() {
}

func (r *ErmcpBizGroupSpotGoods) buildSql() string {
	var sqlId utils.SQLVal = "select t.biztype," +
		"       t.bizgroupid," +
		"       t.deliverygoodsid," +
		"       g.deliverygoodsname," +
		"       g.deliverygoodscode," +
		"       g.goodsunitid," +
		"       g.areauserid" +
		"  from ERMCP_BizGroupSpotGoods t" +
		"  left join deliverygoods g" +
		"    on t.deliverygoodsid = g.deliverygoodsid" +
		"  where 1=1"
	sqlId.AndEx("g.areauserid", r.AREAUSERID, r.AREAUSERID > 0)
	sqlId.AndEx("t.deliverygoodsid", r.DELIVERYGOODSID, r.DELIVERYGOODSID > 0)
	return sqlId.String()
}

// GetDataEx 获取业务类型分组商品
func (r *ErmcpBizGroupSpotGoods) GetDataEx() ([]ErmcpBizGroupSpotGoods, error) {
	sData := make([]ErmcpBizGroupSpotGoods, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// ErcmpBizGroupTaaccount 业务分组账号
type ErmcpBizGroupTaAccount struct {
	BIZGROUPID  int64  `json:"bizgroupid"  xorm:"'BIZGROUPID'"`   // 业务分组id
	ACCOUNTID   int64  `json:"accountid"  xorm:"'ACCOUNTID'"`     // 账号id
	AREAUSERID  int64  `json:"areauserid"  xorm:"'AREAUSERID'"`   // 所属机构id
	ACCOUNTNAME string `json:"accountname"  xorm:"'ACCOUNTNAME'"` // 账号名称
	ISMAIN      int32  `json:"ismain"  xorm:"'ISMAIN'"`           // 是否主账号 1-是 0-否
}

func (r *ErmcpBizGroupTaAccount) calc() {
}

func (r *ErmcpBizGroupTaAccount) buildSql() string {
	var sqlId utils.SQLVal = "select t.bizgroupid," +
		"       t.accountid," +
		"       ta.relateduserid areauserid," +
		"       ta.accountname," +
		"       ta.ismain" +
		"  from ermcp_bizgrouptaaccount t" +
		"  left join taaccount ta" +
		"    on t.accountid = ta.accountid" +
		" where 1 = 1"
	if r.AREAUSERID > 0 {
		sqlId.And("ta.relateduserid", r.AREAUSERID)
	}
	return sqlId.String()
}

// GetDataEx 获取业务分组账号
func (r *ErmcpBizGroupTaAccount) GetDataEx() ([]ErmcpBizGroupTaAccount, error) {
	sData := make([]ErmcpBizGroupTaAccount, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// 账户设置分组信息
type ErmcpBizGroupEx struct {
	BIZTYPE    int32 `json:"biztype"  xorm:"'BIZTYPE'"`       // 业务类型 1-套保 2-套利
	BIZGROUPID int64 `json:"bizgroupid"  xorm:"'BIZGROUPID'"` // 业务分组id

	AccList []ErmcpBizGroupTaAccount `json:"acclist"` // 账号列表
	WrList  []ErmcpBizGroupSpotGoods `json:"wrlist"`  // 现货商品表

	AREAUSERID      int64 `json:"-"` // 所属机构
	DELIVERYGOODSID int32 `json:"-"` // 现货商品id
}

// GetDataEx 获取账户设置分组信息
func (r *ErmcpBizGroupEx) GetDataEx() (interface{}, error) {
	sData := make([]ErmcpBizGroupEx, 0)
	mWr := ErmcpBizGroupSpotGoods{AREAUSERID: r.AREAUSERID, DELIVERYGOODSID: r.DELIVERYGOODSID}
	mAcc := ErmcpBizGroupTaAccount{AREAUSERID: r.AREAUSERID}
	if wrLst, err := mWr.GetDataEx(); err == nil {
		for i := range wrLst {
			var bFind = false
			for k := range sData {
				if sData[k].BIZGROUPID == wrLst[i].BIZGROUPID &&
					sData[k].BIZTYPE == wrLst[i].BIZTYPE {
					sData[k].WrList = append(sData[k].WrList, wrLst[i])
					bFind = true
				}
			}

			if !bFind {
				var d = ErmcpBizGroupEx{BIZGROUPID: wrLst[i].BIZGROUPID,
					BIZTYPE: wrLst[i].BIZTYPE,
					AccList: make([]ErmcpBizGroupTaAccount, 0),
					WrList:  make([]ErmcpBizGroupSpotGoods, 0)}
				d.WrList = append(d.WrList, wrLst[i])
				sData = append(sData, d)
			}
		}
	}

	if len(sData) == 0 {
		// 如果没有业务分组, 则不用查关联资金账户了
		return sData, nil
	}

	if accLst, err := mAcc.GetDataEx(); err == nil {
		for i := range accLst {
			for k := range sData {
				if sData[k].BIZGROUPID == accLst[i].BIZGROUPID {
					sData[k].AccList = append(sData[k].AccList, accLst[i])
				}
			}
		}
	}

	return sData, nil
}

// 资金账号信息
type ErmcpTaAccountInfo struct {
	CREDITDECREASE        float64 `json:"creditdecrease"  xorm:"'CREDITDECREASE'"`             // 今日授信减少
	OTHERCREDITINCREASE   float64 `json:"othercreditincrease"  xorm:"'OTHERCREDITINCREASE'"`   // 今日其它授信增加
	OTHERCREDITDECREASE   float64 `json:"othercreditdecrease"  xorm:"'OTHERCREDITDECREASE'"`   // 今日其它授信减少
	TRANSFERAMOUNT        float64 `json:"transferamount"  xorm:"'TRANSFERAMOUNT'"`             // 今日划转金额(母子账号资金划转，从划入账号为正，从账号划出为负)
	OTHERPAY              float64 `json:"-"  xorm:"'OTHERPAY'"`                                // 其他支出(交割付款 申购付款 全款买入 商城买入 卖家退货)
	OTHERINCOME           float64 `json:"-"  xorm:"'OTHERINCOME'"`                             // 其他收入(交割收款 申购收款 全款卖出 商城卖出 买家退货 会员手续费收入)
	OUTTHRESHOLD          float64 `json:"outthreshold"  xorm:"'OUTTHRESHOLD'"`                 // 出金阈值
	TRADESTATUSCHANGETIME string  `json:"-"  xorm:"'TRADESTATUSCHANGETIME'"`                   // 激活时间
	CHANGETIME            string  `json:"-"  xorm:"'CHANGETIME'"`                              // 账户状态变更时间
	THIRDINAMOUNT         float64 `json:"thirdinamount"  xorm:"'THIRDINAMOUNT'"`               // 今日三方入金
	THIRDOUTAMOUNT        float64 `json:"thirdoutamount"  xorm:"'THIRDOUTAMOUNT'"`             // 今日三方出金
	CAPITALBALANCE        float64 `json:"capitalbalance"  xorm:"'CAPITALBALANCE'"`             // 本金余额[外部子账户实际出入金余额]
	FROMACCOUNTID         int64   `json:"fromaccountid"  xorm:"'FROMACCOUNTID'"`               // 所属上级账户
	SUBLEVELPATH          string  `json:"sublevelpath"  xorm:"'SUBLEVELPATH'"`                 // 账号层级路径(逗号分隔,首尾加逗号)
	SERIVCEGROUP          int64   `json:"-"  xorm:"'SERIVCEGROUP'"`                            // 服务分组
	ACCOUNTNAME           string  `json:"accountname"  xorm:"'ACCOUNTNAME'"`                   // 账户名称
	ACCOUNTFLAG           int32   `json:"-"  xorm:"'ACCOUNTFLAG'"`                             // 账户标识 - 0\1 (默认为0， 当上级账户与本账户的关联用户均为自己时更新为1)
	ORIDEBT               float64 `json:"oridebt"  xorm:"'ORIDEBT'"`                           // 期初欠款
	CURDEBT               float64 `json:"curdebt"  xorm:"'CURDEBT'"`                           // 期末欠款
	ACCOUNTID             int64   `json:"accountid"  xorm:"'ACCOUNTID'"`                       // 资金账户ID
	USERID                int64   `json:"userid"  xorm:"'USERID'"`                             // 用户ID
	CURRENCYID            int64   `json:"currencyid"  xorm:"'CURRENCYID'"`                     // 货币ID
	CHANGEFLAG            int32   `json:"-"  xorm:"'CHANGEFLAG'"`                              // 变动标志(当前账户资金有任何变动更新为1系统结算时更新0;供清算时使用) 0：无变动 1：有变动
	PASSWORD              string  `json:"-"  xorm:"'PASSWORD'"`                                // 资金密码
	TRADESTATUS           int32   `json:"tradestatus"  xorm:"'TRADESTATUS'"`                   // 交易状态 - 1:正常 2:受限 3:冻结 4:禁止建仓(人工受限) 5:禁止交易(人工冻结) 6:待激活 7:已注销
	SIGNSTATUS            int32   `json:"signstatus"  xorm:"'SIGNSTATUS'"`                     // 签约状态 - 1:未签约 2:签约待审核 3:签约中 4:已签约 5:解约待审核 6:解约中 7:已解约 8:已解绑 9:绑卡中
	ISMAIN                int32   `json:"ismain"  xorm:"'ISMAIN'"`                             // 是否母账号 0:不是母账户 1:是母账户
	PARENTACCOUNTID       int64   `json:"parentaccountid"  xorm:"'PARENTACCOUNTID'"`           // 所属根账号
	RELATEDUSERID         int64   `json:"relateduserid"  xorm:"'RELATEDUSERID'"`               // 关联用户
	RELATEDACCOUNTSTATUS  int32   `json:"-"  xorm:"'RELATEDACCOUNTSTATUS'"`                    // 关联用户交易权限状态 - 1:正常(可交易) 2:受限(可平仓，不可建仓) 3:冻结(不可交易)
	TAACCOUNTTYPE         int32   `json:"taaccounttype"  xorm:"'TAACCOUNTTYPE'"`               // 账号类型 - 1:外部账号 2:内部账号 3:内部做市自营账号 4:内部做市接单账号
	ISRECKONACCOUNT       int32   `json:"-"  xorm:"'ISRECKONACCOUNT'"`                         // 是否机构分润账号 0:不是 1:是
	ISMARKETACCOUNT       int32   `json:"-"  xorm:"'ISMARKETACCOUNT'"`                         // 是否机构接单账号 0:不是 1:是
	BALANCE               float64 `json:"balance"  xorm:"'BALANCE'"`                           // 期初余额
	ORIFREEZEMARGIN       float64 `json:"orifreezemargin"  xorm:"'ORIFREEZEMARGIN'"`           // 期初冻结保证金
	ORIUSEDMARGIN         float64 `json:"oriusedmargin"  xorm:"'ORIUSEDMARGIN'"`               // 期初占用保证金
	ORIOTHERFREEZEMARGIN  float64 `json:"oriotherfreezemargin"  xorm:"'ORIOTHERFREEZEMARGIN'"` // 期初其他冻结保证金(出金冻结资金 交割买方冻结 申购冻结 全款买入 商城买入)
	ORIFREEZECHARGE       float64 `json:"orifreezecharge"  xorm:"'ORIFREEZECHARGE'"`           // 期初手续费冻结
	ORIMORTGAGECREDIT     float64 `json:"orimortgagecredit"  xorm:"'ORIMORTGAGECREDIT'"`       // 期初授信金额
	ORIOTHERCREDIT        float64 `json:"oriothercredit"  xorm:"'ORIOTHERCREDIT'"`             // 期初其它授信金额
	ORIOUTAMOUNTFREEZE    float64 `json:"orioutamountfreeze"  xorm:"'ORIOUTAMOUNTFREEZE'"`     // 期初出金冻结
	FREEZEMARGIN          float64 `json:"freezemargin"  xorm:"'FREEZEMARGIN'"`                 // 冻结保证金
	USEDMARGIN            float64 `json:"usedmargin"  xorm:"'USEDMARGIN'"`                     // 占用保证金
	OTHERFREEZEMARGIN     float64 `json:"otherfreezemargin"  xorm:"'OTHERFREEZEMARGIN'"`       // 其他冻结保证金(交割买方冻结 申购冻结 全款买入 商城买入)
	FREEZECHARGE          float64 `json:"freezecharge"  xorm:"'FREEZECHARGE'"`                 // 手续费冻结
	MORTGAGECREDIT        float64 `json:"mortgagecredit"  xorm:"'MORTGAGECREDIT'"`             // 授信金额
	OTHERCREDIT           float64 `json:"othercredit"  xorm:"'OTHERCREDIT'"`                   // 其它授信金额
	OUTAMOUNTFREEZE       float64 `json:"outamountfreeze"  xorm:"'OUTAMOUNTFREEZE'"`           // 出金冻结
	INAMOUNT              float64 `json:"inamount"  xorm:"'INAMOUNT'"`                         // 今日入金金额(包括三方入金)
	CURRENTBALANCE        float64 `json:"currentbalance"  xorm:"'CURRENTBALANCE'"`             // 期末余额
	OUTAMOUNT             float64 `json:"outamount"  xorm:"'OUTAMOUNT'"`                       // 今日出金金额(包括三方出金)
	PAYCHARGE             float64 `json:"paycharge"  xorm:"'PAYCHARGE'"`                       // 今日手续费支出
	CLOSEPL               float64 `json:"closepl"  xorm:"'CLOSEPL'"`                           // 今日平仓盈亏
	CREDITINCREASE        float64 `json:"creditincrease"  xorm:"'CREDITINCREASE'"`             // 今日授信增加
}

func (r *ErmcpTaAccountInfo) calc() {
}

func (r *ErmcpTaAccountInfo) buildSql() string {
	var sqlId utils.SQLVal = "select * from taaccount t where 1 = 1"
	if r.USERID > 0 {
		sqlId.And("t.RELATEDUSERID", r.RELATEDUSERID)
	}
	if r.ACCOUNTID > 0 {
		sqlId.And("t.accountid", r.ACCOUNTID)
	}
	return sqlId.String()
}

// 获取资金账号信息
func (r *ErmcpTaAccountInfo) GetDataEx() (interface{}, error) {
	sData := make([]ErmcpTaAccountInfo, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// ErmcpLoginTaAccount 登录id关联的资金账号
type ErmcpLoginTaAccount struct {
	ACCOUNTID   int64  `json:"accountid"  xorm:"'ACCOUNTID'"`     // 账号id
	ACCOUNTNAME string `json:"accountname"  xorm:"'ACCOUNTNAME'"` // 账号名称
	LOGINID     int64  `json:"-"  xorm:"'LOGINID'"`               // 登录id
}

func (r *ErmcpLoginTaAccount) buildSql() string {
	var sqlId utils.SQLVal = "select t.loginid, t.accountid, ta.accountname" +
		"  from logintaaccount t" +
		" inner join taaccount ta" +
		"    on t.accountid = ta.accountid"
	return sqlId.String()
}

// GetData
func (r *ErmcpLoginTaAccount) GetData() ([]ErmcpLoginTaAccount, error) {
	sData := make([]ErmcpLoginTaAccount, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	return sData, err
}