MTP20_IF/models/bank.go

package models

import (
	"mtp2_if/db"
	"mtp2_if/utils"
)

// Bankcusbankextendconfig 托管银行扩展配置表
type Bankcusbankextendconfig struct {
	CUSBANKID     string `json:"cusbankid" xorm:"CUSBANKID" form:"cusbankid" binding:"required"` // 托管银行编号
	EXTENDBIZTYPE int32  `json:"extendbiztype" xorm:"EXTENDBIZTYPE" form:"extendbiztype"`        // 扩展业务类型 - 1:签约 2:入金 3:出金 4:签约信息修改
	FIELDID       int64  `json:"fieldid" xorm:"FIELDID"`                                         // 字段ID
	ISMANDATORY   int32  `json:"ismandatory" xorm:"ISMANDATORY"`                                 // 是否必填 - 0:不必填 1:必填

	FIELDCODE  string `json:"fieldcode" xorm:"FIELDCODE"`   // 字段代码
	FIELDNAME  string `json:"fieldname" xorm:"FIELDNAME"`   // 字段名称
	STATUS     int32  `json:"status" xorm:"STATUS"`         // 状态 - 0:正常 1:注销
	FIELDTYPE  int32  `json:"fieldtype" xorm:"FIELDTYPE"`   // 字段类型 - 1:扩展字段 2:协议字段
	USABLETYPE int32  `json:"usabletype" xorm:"USABLETYPE"` // 可用类型 - 1:通用 2:机构专用 3:投资者专用
}

func (r *Bankcusbankextendconfig) calc() {}

func (r *Bankcusbankextendconfig) buildSql() string {
	var sqlId utils.SQLVal = `
	SELECT 
		t.cusbankid,
		t.extendbiztype,
		t.fieldid,
		t.ismandatory,
		e.fieldcode,
		e.fieldname,
		e.status,
		e.fieldtype,
		e.usabletype
	FROM Bank_Cusbankextendconfig t
	LEFT JOIN BANK_EXTENDFIELD e ON
		e.fieldid = t.fieldid
	WHERE 1=1
	`
	sqlId.And("t.cusbankid", r.CUSBANKID)
	sqlId.AndEx("t.extendbiztype", r.EXTENDBIZTYPE, r.EXTENDBIZTYPE > 0)
	sqlId.OrderBy("t.fieldid")

	return sqlId.String()
}

// GetDataEx 获取掉期商品订单详情(交易确认书)
func (r *Bankcusbankextendconfig) GetDataEx() (interface{}, error) {
	sData := make([]Bankcusbankextendconfig, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	for i := range sData {
		sData[i].calc()
	}
	return sData, err
}

// Bankbranchnuminfo 银行支行联行号信息表
type Bankbranchnuminfo struct {
	BRANCHNUM      string `json:"branchnum" xorm:"BRANCHNUM"`                                        // 支行行号
	BRANCHNAME     string `json:"branchname" xorm:"BRANCHNAME" form:"branchname" binding:"required"` // 支行名称
	BRANCHPROVINCE string `json:"branchprovince" xorm:"BRANCHPROVINCE"`                              // 省份
	BRANCHCITY     string `json:"branchcity" xorm:"BRANCHCITY"`                                      // 市县
	ISEXPIRED      string `json:"isexpired" xorm:"ISEXPIRED"`                                        // 是否过期

	PageEx `xorm:"extends"` // 页码信息
}

func (r *Bankbranchnuminfo) calc() {

}

func (r *Bankbranchnuminfo) buildSql() string {
	var sqlId utils.SQLVal = `
	select t.branchnum,
		t.branchname,
		t.branchprovince,
		t.branchcity
	from  BANK_BRANCHNUMINFO t
	where t.branchname like '%%%v%%'
	`
	sqlId.FormatParam(r.BRANCHNAME)

	sqlId.Page(r.Page, r.PageSize)
	return sqlId.String()
}

func (r *Bankbranchnuminfo) GetDataByPage() (interface{}, error, int, int, int) {
	sData := make([]Bankbranchnuminfo, 0)
	err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
	total := 0
	for i := range sData {
		sData[i].calc()
		total = sData[i].Total
	}
	return sData, err, r.Page, r.PageSize, total
}

func GetAmtInByPaid(accountId int, exchticket string) string {
	engine := db.GetEngine()

	// 尝试 ChillPay
	var rec Chillpayamtinrec
	has, _ := engine.Where("accountid = ? and exch_seq = ? and deal_status = 2", accountId, exchticket).Get(&rec)
	if has {
		return rec.PAYMENTURL
	}

	// 尝试 PayerMax
	var rec1 Payermaxamtinrec
	has, _ = engine.Where("accountid = ? and exch_seq = ? and deal_status = 2", accountId, exchticket).Get(&rec1)
	if has {
		return rec1.REDIRECTURL
	}

	return ""
}

func GetCusBankInfos() ([]Bankcusbankinfo, error) {
	engine := db.GetEngine()

	infos := make([]Bankcusbankinfo, 0)
	if err := engine.Find(&infos); err != nil {
		return nil, err
	}

	return infos, nil
}