package record

import (
	"bet24.com/database"
	pb "bet24.com/servers/micros/userservices/proto"

	dbengine "bet24.com/servers/micros/dbengine/proto"
)

func trans_getUserRecord(userId int) []pb.Record {
	statement := database.NewStatement()
	statement.SetNeedReturnValue(false)
	statement.SetOpenRecordSet(true)
	statement.SetProcName("WS_UserRecord_GetInfo")
	statement.AddParamter("@UserID", database.AdParamInput, database.AdInteger, 4, userId)
	sqlstring := statement.GenSql()
	retRows := dbengine.ExecuteRs(sqlstring)
	if len(retRows) <= 0 {
		return []pb.Record{}
	}

	var out []pb.Record
	for i := 0; i < len(retRows); i++ {
		var ret pb.Record
		d := retRows[i]
		ret.RecordId = int((d[0]).(int64))
		ret.Count = int((d[1]).(int64))
		out = append(out, ret)
	}

	return out
}

func trans_updataUserRecord(userId, id, count int) {
	statement := database.NewStatement()
	statement.SetNeedReturnValue(false)
	statement.SetOpenRecordSet(true)
	statement.SetProcName("WS_UserRecord_Updata")
	statement.AddParamter("@UserID", database.AdParamInput, database.AdInteger, 4, userId)
	statement.AddParamter("@RecordId", database.AdParamInput, database.AdInteger, 4, id)
	statement.AddParamter("@RecordCount", database.AdParamInput, database.AdInteger, 4, count)
	sqlstring := statement.GenSql()
	dbengine.ExecuteRs(sqlstring)
}