go_rely_warehouse
/
zyos_go_order_relate_rule
4
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 253 Wiki Activity
Browse Source

add reverse:for v3.9.3 积分释放规则

tags/v3.9.3
huangjiajun 2 years ago
parent
33441c0ed5
commit
45c862e372
1 changed files with 0 additions and 157 deletions
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. +0
    -157
      db/db_integral_release_interposition_user_records.go

+ 0
- 157
db/db_integral_release_interposition_user_records.go View File

@@ -1,157 +0,0 @@
package db

import (
"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/db/model"
zhios_order_relate_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/utils"
zhios_order_relate_logx "code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/utils/logx"
"errors"
"fmt"
"reflect"
"xorm.io/xorm"
)

// BatchSelectIntegralReleaseInterpositionUserRecords 批量查询数据 TODO::和下面的方法重复了，建议采用下面的 `IntegralReleaseInterpositionUserRecordsFindByParams` 方法
func BatchSelectIntegralReleaseInterpositionUserRecords(Db *xorm.Engine, params map[string]interface{}) (*[]model.IntegralReleaseInterpositionUserRecords, error) {
var IntegralReleaseInterpositionUserRecordsData []model.IntegralReleaseInterpositionUserRecords
if err := Db.In(zhios_order_relate_utils.AnyToString(params["key"]), params["value"]).
Find(&IntegralReleaseInterpositionUserRecordsData); err != nil {
return nil, zhios_order_relate_logx.Warn(err)
}
return &IntegralReleaseInterpositionUserRecordsData, nil
}

// IntegralReleaseInterpositionUserRecordsInsert 插入单条数据
func IntegralReleaseInterpositionUserRecordsInsert(Db *xorm.Engine, IntegralReleaseInterpositionUserRecords *model.IntegralReleaseInterpositionUserRecords) (int, error) {
_, err := Db.InsertOne(IntegralReleaseInterpositionUserRecords)
if err != nil {
return 0, err
}
return IntegralReleaseInterpositionUserRecords.Id, nil
}

// BatchAddIntegralReleaseInterpositionUserRecords 批量新增数据
func BatchAddIntegralReleaseInterpositionUserRecords(Db *xorm.Engine, IntegralReleaseInterpositionUserRecordsData []*model.IntegralReleaseInterpositionUserRecords) (int64, error) {
affected, err := Db.Insert(IntegralReleaseInterpositionUserRecordsData)
if err != nil {
return 0, err
}
return affected, nil
}

func GetIntegralReleaseInterpositionUserRecordsCount(Db *xorm.Engine) int {
var IntegralReleaseInterpositionUserRecords model.IntegralReleaseInterpositionUserRecords
session := Db.Where("")
count, err := session.Count(&IntegralReleaseInterpositionUserRecords)
if err != nil {
return 0
}
return int(count)
}

// IntegralReleaseInterpositionUserRecordsDelete 删除记录
func IntegralReleaseInterpositionUserRecordsDelete(Db *xorm.Engine, id interface{}) (int64, error) {
if reflect.TypeOf(id).Kind() == reflect.Slice {
return Db.In("id", id).Delete(model.IntegralReleaseInterpositionUserRecords{})
} else {
return Db.Where("id = ?", id).Delete(model.IntegralReleaseInterpositionUserRecords{})
}
}

// IntegralReleaseInterpositionUserRecordsUpdate 更新记录
func IntegralReleaseInterpositionUserRecordsUpdate(session *xorm.Session, id interface{}, IntegralReleaseInterpositionUserRecords *model.IntegralReleaseInterpositionUserRecords, forceColums ...string) (int64, error) {
var (
affected int64
err error
)
if forceColums != nil {
affected, err = session.Where("id=?", id).Cols(forceColums...).Update(IntegralReleaseInterpositionUserRecords)
} else {
affected, err = session.Where("id=?", id).Update(IntegralReleaseInterpositionUserRecords)
}
if err != nil {
return 0, err
}
return affected, nil
}

// IntegralReleaseInterpositionUserRecordsGetOneByParams 通过传入的参数查询数据(单条)
func IntegralReleaseInterpositionUserRecordsGetOneByParams(session *xorm.Session, params map[string]interface{}) (*model.IntegralReleaseInterpositionUserRecords, error) {
var m model.IntegralReleaseInterpositionUserRecords
var query = fmt.Sprintf("%s =?", params["key"])
has, err := session.Where(query, params["value"]).Get(&m)
if err != nil {
return nil, zhios_order_relate_logx.Error(err)
}
if has == false {
return nil, errors.New("未查询到相应的 block_star_chain 记录")
}
return &m, nil
}

// IntegralReleaseInterpositionUserRecordsFindByParams 通过传入的参数查询数据(多条)
func IntegralReleaseInterpositionUserRecordsFindByParams(Db *xorm.Engine, params map[string]interface{}) (*[]model.IntegralReleaseInterpositionUserRecords, error) {
var m []model.IntegralReleaseInterpositionUserRecords
if params["value"] == nil {
return nil, errors.New("参数有误")
}
if params["key"] == nil {
//查询全部数据
err := Db.Find(&m)
if err != nil {
return nil, zhios_order_relate_logx.Error(err)
}
return &m, nil
} else {
if reflect.TypeOf(params["value"]).Kind() == reflect.Slice {
//指定In查询
if err := Db.In(zhios_order_relate_utils.AnyToString(params["key"]), params["value"]).Find(&m); err != nil {
return nil, zhios_order_relate_logx.Warn(err)
}
return &m, nil
} else {
var query = fmt.Sprintf("%s =?", params["key"])
err := Db.Where(query, params["value"]).Find(&m)
if err != nil {
return nil, zhios_order_relate_logx.Error(err)
}
return &m, nil
}

}
}

func IntegralReleaseInterpositionUserRecordsFindByParamsByPage(Db *xorm.Engine, params map[string]interface{}, page, pageSize int) (*[]model.IntegralReleaseInterpositionUserRecords, error) {
var m []model.IntegralReleaseInterpositionUserRecords
if params["value"] == nil {
return nil, errors.New("参数有误")
}
if page == 0 && pageSize == 0 {
page = 1
pageSize = 10
}

if params["key"] == nil {
//查询全部数据
err := Db.Limit(pageSize, (page-1)*pageSize).Find(&m)
if err != nil {
return nil, zhios_order_relate_logx.Error(err)
}
return &m, nil
} else {
if reflect.TypeOf(params["value"]).Kind() == reflect.Slice {
//指定In查询
if err := Db.In(zhios_order_relate_utils.AnyToString(params["key"]), params["value"]).Limit(pageSize, (page-1)*pageSize).Find(&m); err != nil {
return nil, zhios_order_relate_logx.Warn(err)
}
return &m, nil
} else {
var query = fmt.Sprintf("%s =?", params["key"])
err := Db.Where(query, params["value"]).Limit(pageSize, (page-1)*pageSize).Find(&m)
if err != nil {
return nil, zhios_order_relate_logx.Error(err)
}
return &m, nil
}

}
}

Write Preview
Loading…
Cancel
Save