diff --git a/db/db_integral_release_user_with_ord.go b/db/db_integral_release_user_with_ord.go index 767145d..60fe6a4 100644 --- a/db/db_integral_release_user_with_ord.go +++ b/db/db_integral_release_user_with_ord.go @@ -28,6 +28,13 @@ func IntegralReleaseUserWithOrdInsert(Db *xorm.Engine, IntegralReleaseUserWithOr } return IntegralReleaseUserWithOrd.Id, nil } +func IntegralReleaseUserWithOrdInsertSess(sess *xorm.Session, IntegralReleaseUserWithOrd *model.IntegralReleaseUserWithOrd) (int, error) { + _, err := sess.Insert(IntegralReleaseUserWithOrd) + if err != nil { + return 0, err + } + return IntegralReleaseUserWithOrd.Id, nil +} // BatchAddIntegralReleaseUserWithOrds 批量新增数据 func BatchAddIntegralReleaseUserWithOrds(Db *xorm.Engine, IntegralReleaseUserWithOrdData []*model.IntegralReleaseUserWithOrd) (int64, error) { @@ -87,6 +94,17 @@ func IntegralReleaseUserWithOrdGetOneByParams(session *xorm.Session, params map[ } return &m, nil } +func IntegralReleaseUserWithOrdByUid(session *xorm.Session, uid, pvd int) (*model.IntegralReleaseUserWithOrd, error) { + var m model.IntegralReleaseUserWithOrd + has, err := session.Where("uid=? and pvd=?", uid, pvd).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 +} // IntegralReleaseUserWithOrdFindByParams 通过传入的参数查询数据(多条) func IntegralReleaseUserWithOrdFindByParams(session *xorm.Session, params map[string]interface{}) (*[]model.IntegralReleaseUserWithOrd, error) {