1688 lines
63 KiB
Go
1688 lines
63 KiB
Go
package mysql
|
||
|
||
import (
|
||
"context"
|
||
"errors"
|
||
"finclip-app-manager/domain/entity"
|
||
"finclip-app-manager/domain/entity/proto/apiproto"
|
||
"finclip-app-manager/domain/repository"
|
||
"finclip-app-manager/infrastructure/config"
|
||
"finclip-app-manager/infrastructure/db/entity/sql"
|
||
"finclip-app-manager/infrastructure/utility"
|
||
"fmt"
|
||
"time"
|
||
|
||
"gorm.io/gorm"
|
||
)
|
||
|
||
var _ repository.IBindingRepo = new(BindingByMysqlRepo)
|
||
|
||
type BindingByMysqlRepo struct {
|
||
}
|
||
|
||
func NewBindingByMysqlRepo() *BindingByMysqlRepo {
|
||
return &BindingByMysqlRepo{}
|
||
}
|
||
|
||
type Bundle struct {
|
||
Id uint64 `json:"id" gorm:"primary_key;column:id;type:BIGINT(16) AUTO_INCREMENT;comment:'自增id'" sql:"auto_increment;primary_key"`
|
||
BundleID string `json:"bundleId" gorm:"column:bundle_id;type:varchar(512);default:'';comment:bundleId"`
|
||
Remark string `json:"remark" gorm:"column:remark;type:varchar(512);default:'';comment:类型"`
|
||
SDKKey string `json:"SDKKey" gorm:"column:sdk_key;type:varchar(512);default:'';comment:sdkKey"`
|
||
SDKID string `json:"SDKID" gorm:"column:sdk_id;type:varchar(64);default:'';comment:sdkid"`
|
||
IsFirstCreate bool `json:"isFirstCreate" gorm:"column:is_first_create;type:bool;default:false;comment:是否第一次创建"` //是否第一次创建
|
||
CreatedAt int64 `json:"createdAt" gorm:"column:created_at;type:BIGINT(16);default:0;comment:创建时间"`
|
||
CreatedAccount string `json:"createdAccount" bson:"created_account" gorm:"column:created_account;type:varchar(64);default:'';comment:创建账号"`
|
||
CreatedBy string `json:"createdBy" bson:"created_by" gorm:"column:created_by;type:varchar(64);default:'';comment:创建人"`
|
||
IsForbidden int `json:"isForbidden" bson:"is_forbidden" gorm:"column:is_forbidden;type:BIGINT(16);default:0;comment:是否禁用"` //是否禁用 0:可用 1:禁用
|
||
}
|
||
|
||
func (Bundle) TableName() string {
|
||
return "bundle"
|
||
}
|
||
|
||
type BundleInfo struct {
|
||
Id uint64 `json:"id" gorm:"primary_key;column:id;type:BIGINT(16) AUTO_INCREMENT;comment:'自增id'" sql:"auto_increment;primary_key"`
|
||
BindingId string `json:"bindingId" gorm:"column:binding_id;key;type:varchar(64);default:'';comment:应用Id"`
|
||
GroupID string `json:"groupId" gorm:"column:group_id;key;type:varchar(64);default:'';comment:企业ID"`
|
||
BundleID string `json:"bundleId" gorm:"column:bundle_id;type:varchar(512);default:'';comment:bundleId"`
|
||
Remark string `json:"remark" gorm:"column:remark;type:varchar(512);default:'';comment:类型"`
|
||
SDKKey string `json:"SDKKey" gorm:"column:sdk_key;type:varchar(512);default:'';comment:sdkKey"`
|
||
SDKID string `json:"SDKID" gorm:"column:sdk_id;type:varchar(64);default:'';comment:sdkid"`
|
||
IsFirstCreate bool `json:"isFirstCreate" gorm:"column:is_first_create;type:bool;default:false;comment:是否第一次创建"` //是否第一次创建
|
||
CreatedAt int64 `json:"createdAt" gorm:"column:created_at;type:BIGINT(16);default:0;comment:创建时间"`
|
||
CreatedAccount string `json:"createdAccount" gorm:"column:created_account;type:varchar(64);default:'';comment:创建账号"`
|
||
CreatedBy string `json:"createdBy" gorm:"column:created_by;type:varchar(64);default:'';comment:创建人"`
|
||
IsForbidden int `json:"isForbidden" gorm:"column:is_forbidden;type:BIGINT(16);default:0;comment:是否禁用"` //是否禁用 0:未禁用 1:禁用
|
||
IsReview int `json:"isReview" gorm:"column:is_review;type:tinyint;default:0;comment:是否审核应用"` //是否禁用 0:未禁用 1:禁用
|
||
}
|
||
|
||
func (BundleInfo) TableName() string {
|
||
return "bundle_info"
|
||
}
|
||
|
||
type BindingMysql struct {
|
||
Id uint64 `json:"id" gorm:"primary_key;column:id;type:BIGINT(16) AUTO_INCREMENT;comment:'自增id'" sql:"auto_increment;primary_key"`
|
||
BindingID string `json:"bindingID" gorm:"column:binding_id;unique;type:varchar(64);comment:'应用的id'"`
|
||
Name string `json:"name" gorm:"column:name;type:varchar(64);default:'';comment:'应用名称'"`
|
||
//BundleInfos string `json:"bundleInfos" gorm:"column:bundle_infos;type:text;comment:'bundle ids'"`
|
||
CreatedInfoBy string `json:"createdInfoBy" gorm:"column:created_info_by;type:varchar(64);default:'';comment:''"`
|
||
CreatedInfoAt int64 `json:"createdInfoAt" gorm:"column:created_info_at;type:BIGINT(16);default:0;comment:''"`
|
||
CreatedInfoAccount string `json:"createdInfoAccount" gorm:"column:created_info_account;type:varchar(64);default:'';comment:''"`
|
||
GroupID string `json:"groupId" gorm:"column:group_id;type:varchar(64);default:'';comment:'企业ID'"`
|
||
GroupName string `json:"groupName" gorm:"column:group_name;type:varchar(64);default:'';comment:'企业名称（为了查询）'"`
|
||
CooperateStatusValue string `json:"cooperateStatusValue" gorm:"column:cooperate_status_value;type:varchar(256);default:'';comment:''"`
|
||
CooperateStatusReason string `json:"cooperateStatusReason" gorm:"column:cooperate_status_reason;type:varchar(256);default:'';comment:''"`
|
||
CooperateStatusLastUpdated int64 `json:"cooperateStatusLastUpdated" gorm:"column:cooperate_status_last_updated;type:BIGINT(16);default:0;comment:''"`
|
||
CooperateStatusModifiedBy string `json:"cooperateStatusModifiedBy" gorm:"column:cooperate_status_modified_by;type:varchar(256);default:0;comment:''"`
|
||
CooperateValidStatusReason string `json:"cooperateValidStatusReason" gorm:"column:cooperate_valid_status_reson;type:varchar(256);default:'';comment:''"`
|
||
CooperateValidStatusLastUpdated int64 `json:"cooperateValidStatusLastUpdated" gorm:"column:cooperate_valid_status_last_updated;type:BIGINT(16);default:0;comment:''"`
|
||
CooperateValidStatusModifiedBy string `json:"cooperateValidStatusModifiedBy" gorm:"column:cooperate_valid_status_modified_by;type:varchar(256);default:0;comment:''"`
|
||
CooperateInvalidStatusReason string `json:"cooperateInvalidStatusReason" gorm:"column:cooperate_invalid_status_reson;type:varchar(256);default:'';comment:''"`
|
||
CooperateInvalidStatusLastUpdated int64 `json:"cooperateInvalidStatusLastUpdated" gorm:"column:cooperate_invalid_status_last_updated;type:BIGINT(16);default:0;comment:''"`
|
||
CooperateInvalidStatusModifiedBy string `json:"cooperateInvalidStatusModifiedBy" gorm:"column:cooperate_invalid_status_modified_by;type:varchar(256);default:0;comment:''"`
|
||
BundleInfos []BundleInfo `json:"bundleInfos" gorm:"ForeignKey:binding_id;AssociationForeignKey:binding_id"`
|
||
AppInfos []LinkAppInfo `json:"appInfos" gorm:"ForeignKey:binding_id;AssociationForeignKey:binding_id"`
|
||
//sAppInfos string `json:"appInfos" gorm:"column:app_infos;type:text;comment:'appid 的信息'"`
|
||
Owner string `json:"owner" gorm:"column:owner;type:varchar(64);default:'';comment:'所属企业'"`
|
||
Expire int64 `json:"expire" gorm:"column:expire;type:BIGINT(16);default:0;comment:''"`
|
||
ApiServer string `json:"apiServer" gorm:"column:api_server;type:varchar(256);default:'';comment:'子域名'"`
|
||
PlatForm int `json:"platform" gorm:"column:platform;type:tinyint;comment:'来源平台'"`
|
||
AutoBind int `json:"autoBind" gorm:"column:auto_bind;type:tinyint;comment:'自动绑定'"`
|
||
HiddenBundle int `json:"hiddenBundle" gorm:"column:hidden_bundle;type:tinyint;comment:'隐藏bundle信息'"`
|
||
FromBindingID string `json:"fromBindingId" gorm:"column:from_binding_id;type:varchar(64);default:'';comment:'来源bindingid'"`
|
||
}
|
||
|
||
type BindingMysqlV2 struct {
|
||
Id uint64 `json:"id" gorm:"primary_key;column:id;type:BIGINT(16) AUTO_INCREMENT;comment:'自增id'" sql:"auto_increment;primary_key"`
|
||
BindingID string `json:"bindingID" gorm:"column:binding_id;unique;type:varchar(64);comment:'应用的id'"`
|
||
Name string `json:"name" gorm:"column:name;type:varchar(64);default:'';comment:'应用名称'"`
|
||
CreatedInfoBy string `json:"createdInfoBy" gorm:"column:created_info_by;type:varchar(64);default:'';comment:''"`
|
||
CreatedInfoAt int64 `json:"createdInfoAt" gorm:"column:created_info_at;type:BIGINT(16);default:0;comment:''"`
|
||
CreatedInfoAccount string `json:"createdInfoAccount" gorm:"column:created_info_account;type:varchar(64);default:'';comment:''"`
|
||
GroupID string `json:"groupId" gorm:"column:group_id;type:varchar(64);default:'';comment:'企业ID'"`
|
||
GroupName string `json:"groupName" gorm:"column:group_name;type:varchar(64);default:'';comment:'企业名称（为了查询）'"`
|
||
CooperateStatusValue string `json:"cooperateStatusValue" gorm:"column:cooperate_status_value;type:varchar(256);default:'';comment:''"`
|
||
CooperateStatusReason string `json:"cooperateStatusReason" gorm:"column:cooperate_status_reason;type:varchar(256);default:'';comment:''"`
|
||
CooperateStatusLastUpdated int64 `json:"cooperateStatusLastUpdated" gorm:"column:cooperate_status_last_updated;type:BIGINT(16);default:0;comment:''"`
|
||
CooperateStatusModifiedBy string `json:"cooperateStatusModifiedBy" gorm:"column:cooperate_status_modified_by;type:varchar(256);default:0;comment:''"`
|
||
CooperateValidStatusReason string `json:"cooperateValidStatusReason" gorm:"column:cooperate_valid_status_reson;type:varchar(256);default:'';comment:''"`
|
||
CooperateValidStatusLastUpdated int64 `json:"cooperateValidStatusLastUpdated" gorm:"column:cooperate_valid_status_last_updated;type:BIGINT(16);default:0;comment:''"`
|
||
CooperateValidStatusModifiedBy string `json:"cooperateValidStatusModifiedBy" gorm:"column:cooperate_valid_status_modified_by;type:varchar(256);default:0;comment:''"`
|
||
CooperateInvalidStatusReason string `json:"cooperateInvalidStatusReason" gorm:"column:cooperate_invalid_status_reson;type:varchar(256);default:'';comment:''"`
|
||
CooperateInvalidStatusLastUpdated int64 `json:"cooperateInvalidStatusLastUpdated" gorm:"column:cooperate_invalid_status_last_updated;type:BIGINT(16);default:0;comment:''"`
|
||
CooperateInvalidStatusModifiedBy string `json:"cooperateInvalidStatusModifiedBy" gorm:"column:cooperate_invalid_status_modified_by;type:varchar(256);default:0;comment:''"`
|
||
Owner string `json:"owner" gorm:"column:owner;type:varchar(64);default:'';comment:'所属企业'"`
|
||
Expire int64 `json:"expire" gorm:"column:expire;type:BIGINT(16);default:0;comment:''"`
|
||
ApiServer string `json:"apiServer" gorm:"column:api_server;type:varchar(256);default:'';comment:'子域名'"`
|
||
PlatForm int `json:"platform" gorm:"column:platform;type:tinyint;comment:'来源平台'"`
|
||
AutoBind int `json:"autoBind" gorm:"column:auto_bind;type:tinyint;comment:'自动绑定'"`
|
||
HiddenBundle int `json:"hiddenBundle" gorm:"column:hidden_bundle;type:tinyint;comment:'隐藏bundle信息'"`
|
||
FromBindingID string `json:"fromBindingId" gorm:"column:from_binding_id;type:varchar(64);default:'';comment:'来源bindingid'"`
|
||
}
|
||
|
||
type LinkAppInfo struct {
|
||
Id uint64 `gorm:"primary_key;column:id;type:BIGINT(16) AUTO_INCREMENT;comment:'自增id'" sql:"auto_increment;primary_key"`
|
||
BindingId string `gorm:"column:binding_id;key;type:varchar(64);comment:'关联应用的id'"`
|
||
AppId string `gorm:"column:app_id;key;type:varchar(64);comment:'小程序id'"`
|
||
AssociatedAt int64 `gorm:"column:associated_at;type:BIGINT(16);default:0;comment:'关联时间'"`
|
||
AssociatedBy string `gorm:"column:associated_by;type:varchar(64);default:'';comment:'关联人'"`
|
||
}
|
||
|
||
func (LinkAppInfo) TableName() string {
|
||
return "link_app_infos"
|
||
}
|
||
|
||
func (BindingMysql) TableName() string {
|
||
return "binding"
|
||
}
|
||
|
||
func (BindingMysqlV2) TableName() string {
|
||
return "binding"
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetInfo(ctx context.Context, bindingId string) (*entity.Binding, error) {
|
||
info := BindingMysql{}
|
||
err := DB.Model(&BindingMysql{}).WithContext(ctx).
|
||
Where("binding_id=?", bindingId).
|
||
//Preload("BundleInfos").
|
||
//Preload("AppInfos").
|
||
First(&info).Error
|
||
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, info.BindingID)
|
||
|
||
if len(linkAppInfos) > 0 {
|
||
info.AppInfos = linkAppInfos
|
||
}
|
||
|
||
if len(bundleInfos) > 0 {
|
||
info.BundleInfos = bundleInfos
|
||
}
|
||
|
||
result := convertBindingMysqlToBinding(info)
|
||
return &result, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetByGroupIdAndName(ctx context.Context, groupId string, name string, isAdmin bool) (*entity.Binding, error) {
|
||
query := "group_id = ? and name = ? "
|
||
args := []interface{}{groupId, name}
|
||
if isAdmin {
|
||
query += "and platform = ? "
|
||
args = append(args, entity.BINGING_PLATFORM_OPER)
|
||
} else {
|
||
query += "and platform = ? "
|
||
args = append(args, entity.BINGING_PLATFORM_ORGAN)
|
||
}
|
||
bindingMysql := BindingMysql{}
|
||
err := DB.Model(&BindingMysql{}).Where(query, args...).
|
||
//Preload("BundleInfos").Preload("AppInfos").
|
||
First(&bindingMysql).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, bindingMysql.BindingID)
|
||
|
||
if len(linkAppInfos) > 0 {
|
||
bindingMysql.AppInfos = linkAppInfos
|
||
}
|
||
|
||
if len(bundleInfos) > 0 {
|
||
bindingMysql.BundleInfos = bundleInfos
|
||
}
|
||
|
||
result := convertBindingMysqlToBinding(bindingMysql)
|
||
return &result, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetByApiServer(ctx context.Context, apiServer string) (entity.Binding, error) {
|
||
query := "api_server = ?"
|
||
args := []interface{}{apiServer}
|
||
res := entity.Binding{}
|
||
bindingMysql := BindingMysql{}
|
||
err := DB.Model(&BindingMysql{}).Where(query, args...).First(&bindingMysql).Error
|
||
if err != nil {
|
||
return res, err
|
||
}
|
||
|
||
query = "binding_id = ?"
|
||
args = []interface{}{bindingMysql.BindingID}
|
||
|
||
bundleInfoMysqls := make([]BundleInfo, 0)
|
||
err = DB.Model(&BindingMysql{}).Where(query, args...).Find(&bundleInfoMysqls).Error
|
||
if err != nil {
|
||
return res, err
|
||
}
|
||
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, bindingMysql.BindingID)
|
||
|
||
if len(linkAppInfos) > 0 {
|
||
bindingMysql.AppInfos = linkAppInfos
|
||
}
|
||
|
||
if len(bundleInfos) > 0 {
|
||
bindingMysql.BundleInfos = bundleInfos
|
||
}
|
||
|
||
result := convertBindingMysqlToBinding(bindingMysql)
|
||
return result, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetInfoByParams(ctx context.Context, sdkKey, organId, appId string) (*entity.Binding, error) {
|
||
db := DB.Model(&BindingMysql{})
|
||
//db = db.Preload("BundleInfos").Preload("AppInfos")
|
||
|
||
db.Where("bundle_info.sdk_key like ?", sdkKey)
|
||
|
||
if appId != "" {
|
||
db.Where("link_app_infos.app_id like ?", appId)
|
||
}
|
||
|
||
if organId != "" {
|
||
db.Where("binding.group_id = ?", organId)
|
||
}
|
||
|
||
bindingMysql := BindingMysql{}
|
||
err := db.
|
||
Select("DISTINCT(binding.id), binding.*").
|
||
Joins("left join bundle_info on binding.binding_id = bundle_info.binding_id").
|
||
Joins("left join link_app_infos on binding.binding_id = link_app_infos.binding_id").
|
||
First(&bindingMysql).Error
|
||
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, bindingMysql.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
bindingMysql.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
bindingMysql.BundleInfos = bundleInfos
|
||
}
|
||
|
||
binding := convertBindingMysqlToBinding(bindingMysql)
|
||
|
||
return &binding, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetInfoBySdkKeyOrganId(ctx context.Context, organId, sdkKey string) (*entity.Binding, error) {
|
||
query := "group_id = ? and sdk_key = ?"
|
||
args := []interface{}{organId, sdkKey}
|
||
|
||
bundleInfoMysql := BundleInfo{}
|
||
err := DB.Model(&BundleInfo{}).Where(query, args...).First(&bundleInfoMysql).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
return b.GetInfo(ctx, bundleInfoMysql.BindingId)
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetAllSdkKey(ctx context.Context, organId string) ([]string, error) {
|
||
query := "group_id = ?"
|
||
args := []interface{}{organId}
|
||
|
||
bundleInfoMysqls := make([]BundleInfo, 0)
|
||
err := DB.Model(&BundleInfo{}).Where(query, args...).Find(&bundleInfoMysqls).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
result := make([]string, 0)
|
||
for _, v := range bundleInfoMysqls {
|
||
result = append(result, v.SDKKey)
|
||
}
|
||
|
||
return result, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBindListBySdkKey(ctx context.Context, sdkKey string) ([]entity.Binding, error) {
|
||
query := "sdk_key = ?"
|
||
args := []interface{}{sdkKey}
|
||
|
||
bundleInfoMysqls := make([]BundleInfo, 0)
|
||
err := DB.Model(&BundleInfo{}).Where(query, args...).Order("created_at").Find(&bundleInfoMysqls).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
bindings := make([]entity.Binding, 0)
|
||
for _, bundleInfoMysql := range bundleInfoMysqls {
|
||
binding, _ := b.GetInfo(ctx, bundleInfoMysql.BindingId)
|
||
bindings = append(bindings, *binding)
|
||
}
|
||
|
||
return bindings, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) SdkKeyExi(ctx context.Context, sdkKey string) (bool, error) {
|
||
if _, ok := entity.SdkExiCache.Get(sdkKey); ok {
|
||
return true, nil
|
||
}
|
||
|
||
var count int64
|
||
err := DB.Model(&BundleInfo{}).
|
||
Where("sdk_key=?", sdkKey).
|
||
Count(&count).Error
|
||
if err != nil {
|
||
return false, err
|
||
}
|
||
|
||
if count > 0 {
|
||
entity.SdkExiCache.Set(sdkKey, true, -1)
|
||
return true, err
|
||
}
|
||
return false, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) Insert(ctx context.Context, bind *entity.Binding) error {
|
||
info := convertBindingToBindingMysql(bind)
|
||
infoV2 := convertBindingMysqlToBindingMysqlV2(&info)
|
||
err := DB.WithContext(ctx).Model(&BindingMysqlV2{}).Create(&infoV2).Error
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if len(info.BundleInfos) > 0 {
|
||
for _, v := range info.BundleInfos {
|
||
DB.Model(&BundleInfo{}).Create(&v)
|
||
}
|
||
}
|
||
if len(info.AppInfos) > 0 {
|
||
for _, v := range info.AppInfos {
|
||
DB.Model(&LinkAppInfo{}).Create(&v)
|
||
}
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) Count(ctx context.Context) (int, error) {
|
||
query := ""
|
||
args := []interface{}{}
|
||
var count int64
|
||
err := DB.Model(&BindingMysql{}).Where(query, args...).Count(&count).Error
|
||
return int(count), err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetCountByStatus(ctx context.Context, status string, platform int) (int, error) {
|
||
query := "cooperate_status_value = ?"
|
||
args := []interface{}{"Valid"}
|
||
/*switch platform {
|
||
case entity.BINGING_PLATFORM_OPER:
|
||
query += " and platform = ? and from_binding_id = ?"
|
||
args = append(args, platform)
|
||
args = append(args, "")
|
||
case entity.BINGING_PLATFORM_ORGAN:
|
||
query += " and platform = ?"
|
||
args = append(args, platform)
|
||
default:
|
||
query += " and ( ( platform = ? and from_binding_id = ? ) or ( platform = ? ) )"
|
||
args = append(args, entity.BINGING_PLATFORM_OPER)
|
||
args = append(args, "")
|
||
args = append(args, entity.BINGING_PLATFORM_ORGAN)
|
||
}*/
|
||
query += " and ( ( platform = ? and group_id = ? ) or ( platform = ? ) )"
|
||
args = append(args, entity.BINGING_PLATFORM_OPER)
|
||
args = append(args, "")
|
||
args = append(args, entity.BINGING_PLATFORM_ORGAN)
|
||
var count int64
|
||
err := DB.Model(&BindingMysql{}).Where(query, args...).Count(&count).Error
|
||
return int(count), err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBundleIdNum(ctx context.Context) (int, error) {
|
||
query := "is_forbidden = ?"
|
||
args := []interface{}{0}
|
||
var count int64
|
||
err := DB.Model(&BundleInfo{}).Where(query, args...).Count(&count).Error
|
||
return int(count), err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBundleIdLimitHand(ctx context.Context, groupId string) (int, error) {
|
||
var total int64
|
||
err := DB.Model(&BundleInfo{}).
|
||
Select("select * from bundle_info").Joins("left join binding on binding.binding_id = bundle_info.binding_id").
|
||
Where("binding.group_id = ? and bundle_info.is_forbidden = ?", groupId, 0).
|
||
Count(&total).Error
|
||
|
||
return int(total), err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBundleLimit(ctx context.Context) (int, error) {
|
||
/*query := ""
|
||
args := []interface{}{}*/
|
||
query := "is_forbidden = ?"
|
||
args := []interface{}{0}
|
||
var count int64
|
||
err := DB.Model(&Bundle{}).Where(query, args...).Count(&count).Error
|
||
return int(count), err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBindingByBindingId(ctx context.Context, bindingId string) (*entity.Binding, error) {
|
||
bindingMysql := BindingMysql{}
|
||
err := DB.Model(&BindingMysql{}).
|
||
Where("binding_id = ?", bindingId).
|
||
//Preload("BundleInfos").Preload("AppInfos").
|
||
First(&bindingMysql).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, bindingMysql.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
bindingMysql.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
bindingMysql.BundleInfos = bundleInfos
|
||
}
|
||
|
||
result := convertBindingMysqlToBinding(bindingMysql)
|
||
return &result, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBindingByGroupIdAndBindingId(ctx context.Context, groupId string, bindingId string) (*entity.Binding, error) {
|
||
info := BindingMysql{}
|
||
err := DB.Model(&BindingMysql{}).WithContext(ctx).
|
||
Where("group_id = ? and binding_id = ?", []interface{}{groupId}, []interface{}{bindingId}).
|
||
//Preload("BundleInfos").
|
||
//Preload("AppInfos").
|
||
First(&info).Error
|
||
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, info.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
info.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
info.BundleInfos = bundleInfos
|
||
}
|
||
result := convertBindingMysqlToBinding(info)
|
||
return &result, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBindingByGroupIdAndSdkKey(ctx context.Context, groupId string, sdkKey string) (*entity.Binding, error) {
|
||
query := "group_id = ? and sdk_key = ?"
|
||
args := []interface{}{groupId, sdkKey}
|
||
|
||
bundleInfoMysql := BundleInfo{}
|
||
err := DB.Model(&BundleInfo{}).Where(query, args...).First(&bundleInfoMysql).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
return b.GetInfo(ctx, bundleInfoMysql.BindingId)
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateBundleInfosByGroupIdAndBindId(ctx context.Context, groupId string, bindingId string, infos []entity.BundleInfo) error {
|
||
return DB.Transaction(func(tx *gorm.DB) error {
|
||
var err error
|
||
for _, v := range infos {
|
||
query := "group_id = ? and binding_id = ?"
|
||
args := []interface{}{groupId, bindingId}
|
||
err = tx.Model(&BundleInfo{}).
|
||
Where(query, args...).
|
||
Updates(convertBundleInfoToBundleInfoMysql(bindingId, groupId, v)).Error
|
||
}
|
||
return err
|
||
})
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) AppendBundles(ctx context.Context, bindingId, groupId string, bundles []entity.BundleInfo) error {
|
||
return DB.Transaction(func(tx *gorm.DB) error {
|
||
var err error
|
||
for _, v := range bundles {
|
||
item := convertBundleInfoToBundleInfoMysql(bindingId, groupId, v)
|
||
|
||
if config.Cfg.PublishEnv == entity.ENV_PRIVATE {
|
||
//私有化环境中，如果要变为启用状态，要先判断该bundleId运营端是否已启用
|
||
if v.IsForbidden == 0 {
|
||
info := BundleMysql{}
|
||
err := DB.Debug().Model(&BundleMysql{}).Where("binary bundle_id=?", v.BundleID).First(&info).Error
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if info.IsForbidden == 1 {
|
||
return errors.New(utility.FS_BIND_IS_FORBIDDEN)
|
||
}
|
||
}
|
||
}
|
||
|
||
if err = tx.Model(&BundleInfo{}).Create(&item).Error; err != nil {
|
||
return err
|
||
}
|
||
}
|
||
return nil
|
||
})
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateBundleIsView(ctx context.Context, reviews []apiproto.BundleReviewItem, isReview int) error {
|
||
return DB.Transaction(func(tx *gorm.DB) error {
|
||
var err error
|
||
for _, review := range reviews {
|
||
query := "binding_id = ? and binary bundle_id= ?"
|
||
args := []interface{}{review.BindingId, review.BundleId}
|
||
params := map[string]interface{}{
|
||
"is_review": isReview,
|
||
}
|
||
err = tx.Model(&BundleInfo{}).Debug().
|
||
Where(query, args...).
|
||
Updates(params).Error
|
||
}
|
||
return err
|
||
})
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) ListReviewBundle(ctx context.Context, pageSize int, pageNo int, searchText string, isReview int) (int64, []entity.ReviewBundleInfo, error) {
|
||
query := "binding.platform = ? AND binding.from_binding_id = ? AND bundle_info.is_review = ?"
|
||
args := []interface{}{entity.BINGING_PLATFORM_OPER, "", isReview}
|
||
if searchText != "" {
|
||
query += " AND (binding.name LIKE ? OR bundle_info.bundle_id LIKE ?) "
|
||
args = append(args, genLike(searchText))
|
||
args = append(args, genLike(searchText))
|
||
}
|
||
list := []entity.ReviewBundleInfo{}
|
||
var total int64
|
||
var err error
|
||
DB.Debug().Model(&BindingMysql{}).
|
||
Joins("LEFT JOIN bundle_info ON binding.binding_id = bundle_info.binding_id").
|
||
Where(query, args...).
|
||
Count(&total)
|
||
if pageSize == 0 && pageNo == 0 {
|
||
err = DB.Debug().Model(&BindingMysql{}).
|
||
Select("binding.binding_id as binding_id, binding.created_info_at as created_info_at, binding.name as name, binding.cooperate_status_value as status, bundle_info.bundle_id as bundle_id, bundle_info.remark as remark, bundle_info.sdk_key as sdk_key, bundle_info.sdk_id as sdk_id, bundle_info.is_forbidden as is_forbidden, bundle_info.is_review as is_review").
|
||
Joins("LEFT JOIN bundle_info ON binding.binding_id = bundle_info.binding_id").
|
||
Order("binding.created_info_at desc").
|
||
Where(query, args...).
|
||
Scan(&list).Error
|
||
} else {
|
||
err = DB.Debug().Model(&BindingMysql{}).
|
||
Select("binding.binding_id as binding_id, binding.created_info_at as created_info_at, binding.name as name, binding.cooperate_status_value as status, bundle_info.bundle_id as bundle_id, bundle_info.remark as remark, bundle_info.sdk_key as sdk_key, bundle_info.sdk_id as sdk_id, bundle_info.is_forbidden as is_forbidden, bundle_info.is_review as is_review").
|
||
Joins("LEFT JOIN bundle_info ON binding.binding_id = bundle_info.binding_id").
|
||
Order("binding.created_info_at desc").
|
||
Where(query, args...).
|
||
Offset((pageNo - 1) * pageSize).
|
||
Limit(pageSize).
|
||
Scan(&list).Error
|
||
}
|
||
return total, list, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) CheckReviewBySdkKey(ctx context.Context, sdkKey string) bool {
|
||
query := "binding.platform = ? AND binding.from_binding_id = ? AND binding.cooperate_status_value = ? AND bundle_info.is_review = ? and bundle_info.sdk_key = ? AND bundle_info.is_forbidden = ?"
|
||
args := []interface{}{entity.BINGING_PLATFORM_OPER, "", entity.StBindValid, 1, sdkKey, 0}
|
||
var total int64
|
||
DB.Debug().Model(&BindingMysql{}).
|
||
Joins("LEFT JOIN bundle_info ON binding.binding_id = bundle_info.binding_id").
|
||
Where(query, args...).
|
||
Count(&total)
|
||
return total > 0
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetReviewBindBySdkKey(ctx context.Context, sdkKey string) (*entity.ReviewBundleInfo, error) {
|
||
query := "binding.platform = ? AND binding.from_binding_id = ? AND bundle_info.sdk_key = ?"
|
||
args := []interface{}{entity.BINGING_PLATFORM_OPER, "", sdkKey}
|
||
list := []entity.ReviewBundleInfo{}
|
||
|
||
err := DB.Debug().Model(&BindingMysql{}).
|
||
Select("binding.binding_id as binding_id, binding.created_info_at as created_info_at, binding.name as name, binding.cooperate_status_value as status, bundle_info.bundle_id as bundle_id, bundle_info.remark as remark, bundle_info.sdk_key as sdk_key, bundle_info.sdk_id as sdk_id, bundle_info.is_forbidden as is_forbidden, bundle_info.is_review as is_review").
|
||
Joins("LEFT JOIN bundle_info ON binding.binding_id = bundle_info.binding_id").
|
||
Order("binding.created_info_at desc").
|
||
Where(query, args...).
|
||
Scan(&list).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
if len(list) > 0 {
|
||
return &list[0], nil
|
||
} else {
|
||
return nil, nil
|
||
}
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateBundles(ctx context.Context, bindingId, groupId string, bundles []entity.BundleInfo) error {
|
||
return DB.Transaction(func(tx *gorm.DB) error {
|
||
var err error
|
||
for _, v := range bundles {
|
||
if config.Cfg.PublishEnv == entity.ENV_PRIVATE {
|
||
//私有化环境中，如果要变为启用状态，要先判断该bundleId运营端是否已启用
|
||
if v.IsForbidden == 0 {
|
||
info := BundleMysql{}
|
||
err := DB.Debug().Model(&BundleMysql{}).Where("binary bundle_id=?", v.BundleID).First(&info).Error
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if info.IsForbidden == 1 {
|
||
return errors.New(utility.FS_BIND_IS_FORBIDDEN)
|
||
}
|
||
}
|
||
}
|
||
query := "binding_id = ? and binary bundle_id= ?"
|
||
args := []interface{}{bindingId, v.BundleID}
|
||
|
||
params := map[string]interface{}{
|
||
"is_forbidden": v.IsForbidden,
|
||
"remark": v.Remark,
|
||
}
|
||
err = tx.Model(&BundleInfo{}).Debug().
|
||
Where(query, args...).
|
||
Updates(params).Error
|
||
}
|
||
return err
|
||
})
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetByBindIdList(ctx context.Context, ids []string) ([]entity.Binding, error) {
|
||
query := "binding_id in ?"
|
||
args := []interface{}{ids}
|
||
|
||
bindingMysqls := make([]BindingMysql, 0)
|
||
err := DB.Model(&BindingMysql{}).Where(query, args...).Find(&bindingMysqls).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
bindings := make([]entity.Binding, 0)
|
||
for _, bindingMysql := range bindingMysqls {
|
||
query = "binding_id = ?"
|
||
args = []interface{}{bindingMysql.BindingID}
|
||
|
||
bundleInfoMysqls := make([]BundleInfo, 0)
|
||
err = DB.Model(&BundleInfo{}).Where(query, args...).Find(&bundleInfoMysqls).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
bindingMysql.BundleInfos = bundleInfoMysqls
|
||
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, bindingMysql.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
bindingMysql.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
bindingMysql.BundleInfos = bundleInfos
|
||
}
|
||
|
||
bindings = append(bindings, convertBindingMysqlToBinding(bindingMysql))
|
||
}
|
||
|
||
return bindings, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBindListByGroupId(ctx context.Context, groupId string, pageSize int, pageNo int) ([]entity.Binding, int, error) {
|
||
bindingMysqls := make([]BindingMysql, 0)
|
||
var total int64
|
||
err := DB.Model(&BindingMysql{}).WithContext(ctx).
|
||
Where("group_id = ? and platform = 0", groupId).
|
||
//Preload("BundleInfos").
|
||
//Preload("AppInfos").
|
||
Order("created_info_at desc").
|
||
Offset((pageNo - 1) * pageSize).
|
||
Limit(pageSize).
|
||
Find(&bindingMysqls).Error
|
||
DB.Model(&BindingMysql{}).WithContext(ctx).
|
||
Where("group_id = ? and platform = 0", groupId).Count(&total)
|
||
bindings := make([]entity.Binding, 0)
|
||
for _, bindingMysql := range bindingMysqls {
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, bindingMysql.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
bindingMysql.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
bindingMysql.BundleInfos = bundleInfos
|
||
}
|
||
bindings = append(bindings, convertBindingMysqlToBinding(bindingMysql))
|
||
}
|
||
return bindings, int(total), err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) AppendApps(ctx context.Context, bindingId string, apps []entity.AppInfo) error {
|
||
for _, app := range apps {
|
||
linkApp := LinkAppInfo{
|
||
BindingId: bindingId,
|
||
AppId: app.AppID,
|
||
AssociatedAt: app.AssociatedAt,
|
||
AssociatedBy: app.AssociatedBy,
|
||
}
|
||
DB.Model(&LinkAppInfo{}).Create(&linkApp)
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) RemoveApps(ctx context.Context, bindingId string, appIds []string) error {
|
||
err := DB.Where("binding_id = ? AND app_id IN ?", bindingId, appIds).Delete(&LinkAppInfo{}).Error
|
||
if err != nil {
|
||
log.Errorf("RemoveApps delete binding:%s LinkAppInfo err:%s", bindingId, err.Error())
|
||
} else {
|
||
log.Infof("RemoveApps delete binding:%s LinkAppInfo succ", bindingId)
|
||
}
|
||
return err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateByBindId(ctx context.Context, bindingId string, bind *entity.Binding) error {
|
||
info := convertBindingToBindingMysql(bind)
|
||
|
||
data := make(map[string]interface{})
|
||
data["name"] = info.Name
|
||
data["cooperate_status_value"] = info.CooperateStatusValue
|
||
data["cooperate_status_reason"] = info.CooperateStatusReason
|
||
data["cooperate_status_last_updated"] = info.CooperateStatusLastUpdated
|
||
data["cooperate_status_modified_by"] = info.CooperateStatusModifiedBy
|
||
data["cooperate_valid_status_reson"] = info.CooperateValidStatusReason
|
||
data["cooperate_valid_status_last_updated"] = info.CooperateValidStatusLastUpdated
|
||
data["cooperate_valid_status_modified_by"] = info.CooperateValidStatusModifiedBy
|
||
data["cooperate_invalid_status_reson"] = info.CooperateInvalidStatusReason
|
||
data["cooperate_invalid_status_last_updated"] = info.CooperateInvalidStatusLastUpdated
|
||
data["cooperate_invalid_status_modified_by"] = info.CooperateInvalidStatusModifiedBy
|
||
data["owner"] = info.Owner
|
||
data["expire"] = info.Expire
|
||
data["api_server"] = info.ApiServer
|
||
//DB.Delete(&BundleInfo{}, "binding_id=?", bindingId)
|
||
//DB.Delete(&LinkAppInfo{}, "binding_id=?", bindingId)
|
||
err := DB.Where("binding_id=?", bindingId).Delete(&BundleInfo{}).Error
|
||
if err != nil {
|
||
log.Errorf("UpdateByBindId delete binding:%s BundleInfo err:%s", bindingId, err.Error())
|
||
} else {
|
||
log.Infof("UpdateByBindId delete binding:%s BundleInfo succ", bindingId)
|
||
}
|
||
err = DB.Where("binding_id=?", bindingId).Delete(&LinkAppInfo{}).Error
|
||
if err != nil {
|
||
log.Errorf("UpdateByBindId delete binding:%s LinkAppInfo err:%s", bindingId, err.Error())
|
||
} else {
|
||
log.Infof("UpdateByBindId delete binding:%s LinkAppInfo succ", bindingId)
|
||
}
|
||
for _, v := range info.AppInfos {
|
||
DB.Model(&LinkAppInfo{}).Create(&v)
|
||
}
|
||
for _, v := range info.BundleInfos {
|
||
DB.Model(&BundleInfo{}).Create(&v)
|
||
}
|
||
|
||
return DB.Model(&BindingMysql{}).Where("binding_id=?", bindingId).Updates(data).Error
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateExpire(ctx context.Context, bindingId string, expire int64) error {
|
||
return DB.WithContext(ctx).Model(&sql.AppVersion{}).Where("binding_id=? ", bindingId).Update("expire", expire).Error
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateBindingInfo(ctx context.Context, bindingId string, info map[string]interface{}, platform int) error {
|
||
if platform == entity.BINGING_PLATFORM_OPER {
|
||
query := "binding_id = ? "
|
||
args := []interface{}{bindingId}
|
||
err := DB.Model(&BindingMysqlV2{}).Debug().
|
||
Where(query, args...).
|
||
Updates(info).Error
|
||
if err != nil {
|
||
return err
|
||
}
|
||
query = "from_binding_id = ? "
|
||
args = []interface{}{bindingId}
|
||
return DB.Model(&BindingMysqlV2{}).Debug().
|
||
Where(query, args...).
|
||
Updates(info).Error
|
||
|
||
} else {
|
||
query := "binding_id = ? "
|
||
args := []interface{}{bindingId}
|
||
return DB.Model(&BindingMysqlV2{}).Debug().
|
||
Where(query, args...).
|
||
Updates(info).Error
|
||
}
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateBindingGroupName(ctx context.Context, groupId, groupName string) error {
|
||
info := make(map[string]interface{})
|
||
info["group_name"] = groupName
|
||
query := "group_id = ? "
|
||
args := []interface{}{groupId}
|
||
return DB.Model(&BindingMysqlV2{}).Debug().
|
||
Where(query, args...).
|
||
Updates(info).Error
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) BundleIdCount(ctx context.Context, groupId string) (int, error) {
|
||
if groupId == "" {
|
||
query := "is_forbidden = 0"
|
||
args := make([]interface{}, 0)
|
||
var count int64
|
||
err := DB.Model(&BundleInfo{}).Where(query, args...).Count(&count).Error
|
||
return int(count), err
|
||
} else {
|
||
query := "group_id = ? and is_forbidden = 0"
|
||
args := []interface{}{groupId}
|
||
var count int64
|
||
err := DB.Model(&BundleInfo{}).Where(query, args...).Count(&count).Error
|
||
return int(count), err
|
||
}
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBundleByGroupIdAndBundleId(ctx context.Context, groupId string, bundleId string) (*entity.Binding, error) {
|
||
bindingMysql := BindingMysql{}
|
||
err := DB.Model(&BindingMysql{}).
|
||
Select("binding.*").Joins("left join bundle_info on binding.binding_id = bundle_info.binding_id").
|
||
Where("binding.group_id = ? and binary bundle_info.bundle_id = ?", []interface{}{groupId}, []interface{}{bundleId}).
|
||
First(&bindingMysql).Error
|
||
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, bindingMysql.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
bindingMysql.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
bindingMysql.BundleInfos = bundleInfos
|
||
}
|
||
|
||
binding := convertBindingMysqlToBinding(bindingMysql)
|
||
|
||
return &binding, err
|
||
|
||
//query := "group_id = ? and bundle_id = ?"
|
||
//args := []interface{}{groupId, bundleId}
|
||
//
|
||
//bundleInfoMysql := BundleInfo{}
|
||
//err := DB.Model(&BundleInfo{}).Where(query, args...).First(&bundleInfoMysql).Error
|
||
//if err != nil {
|
||
// return nil, err
|
||
//}
|
||
//
|
||
//return b.GetInfo(ctx, bundleInfoMysql.BindingId)
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetbundlesByBundleId(ctx context.Context, bundleId string) (*entity.Binding, error) {
|
||
query := "binary bundle_id = ?"
|
||
args := []interface{}{bundleId}
|
||
|
||
bundleInfoMysql := BundleInfo{}
|
||
err := DB.Model(&BundleInfo{}).Where(query, args...).First(&bundleInfoMysql).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
return b.GetInfo(ctx, bundleInfoMysql.BindingId)
|
||
}
|
||
|
||
type BindingsResult struct {
|
||
BindingId string `json:"bindingId" gorm:"column:binding_id"`
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBindingsBySearch(ctx context.Context, pageSize int, pageNo int, sort string, searchText string, searchFields string, cooperateStatus string, platform int) ([]entity.Binding, int, error) {
|
||
log.Infof("ListBindings req,groupId:[%s],searchText:[%s],pageNo:[%d],pageSize:[%d]", searchText, pageNo, pageSize)
|
||
var sortColumn string
|
||
switch sort {
|
||
case "-created":
|
||
sortColumn = "binding.created_info_at DESC" //按创建时间排序
|
||
case "-expire":
|
||
sortColumn = "binding.expire DESC" //按过期时间倒序排序
|
||
case "expire":
|
||
sortColumn = "binding.expire ASC" //按过期时间正序排序
|
||
default:
|
||
sortColumn = "binding.created_info_at DESC" //按创建时间倒序排序
|
||
}
|
||
list := make([]BindingMysql, 0)
|
||
var total int64
|
||
if searchText == "" {
|
||
if cooperateStatus != "all" {
|
||
query := "cooperate_status_value = ?"
|
||
queryList := []interface{}{cooperateStatus}
|
||
switch platform {
|
||
case entity.BINGING_PLATFORM_OPER:
|
||
query += " AND platform = ? and group_id = ?"
|
||
queryList = append(queryList, platform)
|
||
queryList = append(queryList, "")
|
||
case entity.BINGING_PLATFORM_ORGAN:
|
||
query += " AND platform = ?"
|
||
queryList = append(queryList, platform)
|
||
default:
|
||
query += " AND ( ( platform = ? AND group_id = ? ) OR ( platform = ? ) )"
|
||
queryList = append(queryList, entity.BINGING_PLATFORM_OPER)
|
||
queryList = append(queryList, "")
|
||
queryList = append(queryList, entity.BINGING_PLATFORM_ORGAN)
|
||
}
|
||
err := DB.
|
||
Where(query, queryList...).
|
||
//Preload("BundleInfos").
|
||
Order(sortColumn).
|
||
Offset(genOffset(pageNo, pageSize)).Limit(pageSize).
|
||
Find(&list).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
err = DB.Model(&BindingMysql{}).
|
||
Where(query, queryList...).
|
||
Count(&total).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
} else {
|
||
query := ""
|
||
queryList := []interface{}{}
|
||
switch platform {
|
||
case entity.BINGING_PLATFORM_OPER:
|
||
query += "platform = ? and group_id = ?"
|
||
queryList = append(queryList, platform)
|
||
queryList = append(queryList, "")
|
||
case entity.BINGING_PLATFORM_ORGAN:
|
||
query += "platform = ?"
|
||
queryList = append(queryList, platform)
|
||
default:
|
||
query += "( platform = ? AND group_id = ? ) OR ( platform = ? )"
|
||
queryList = append(queryList, entity.BINGING_PLATFORM_OPER)
|
||
queryList = append(queryList, "")
|
||
queryList = append(queryList, entity.BINGING_PLATFORM_ORGAN)
|
||
}
|
||
err := DB.
|
||
Where(query, queryList...).
|
||
//Preload("BundleInfos").
|
||
Order(sortColumn).
|
||
Offset(genOffset(pageNo, pageSize)).Limit(pageSize).
|
||
Find(&list).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
err = DB.Model(&BindingMysql{}).
|
||
Where(query, queryList...).
|
||
Count(&total).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
}
|
||
} else {
|
||
|
||
query := ""
|
||
queryList := []interface{}{}
|
||
if cooperateStatus != "all" {
|
||
query = "(binding.name LIKE ? OR binding.group_name LIKE ? OR bundle_info.bundle_id LIKE ?) AND binding.cooperate_status_value = ? "
|
||
s := genLike(searchText)
|
||
queryList = []interface{}{s, s, s, cooperateStatus}
|
||
switch platform {
|
||
case entity.BINGING_PLATFORM_OPER:
|
||
query += " AND binding.platform = ? and binding.group_id = ?"
|
||
queryList = append(queryList, platform)
|
||
queryList = append(queryList, "")
|
||
case entity.BINGING_PLATFORM_ORGAN:
|
||
query += " AND binding.platform = ?"
|
||
queryList = append(queryList, platform)
|
||
default:
|
||
query += " AND ( ( binding.platform = ? AND binding.group_id = ? ) OR ( binding.platform = ? ) )"
|
||
queryList = append(queryList, entity.BINGING_PLATFORM_OPER)
|
||
queryList = append(queryList, "")
|
||
queryList = append(queryList, entity.BINGING_PLATFORM_ORGAN)
|
||
}
|
||
} else {
|
||
query = "(binding.name LIKE ? OR binding.group_name LIKE ? OR bundle_info.bundle_id LIKE ?) "
|
||
s := genLike(searchText)
|
||
queryList = []interface{}{s, s, s}
|
||
switch platform {
|
||
case entity.BINGING_PLATFORM_OPER:
|
||
query += " AND binding.platform = ? and binding.group_id = ?"
|
||
queryList = append(queryList, platform)
|
||
queryList = append(queryList, "")
|
||
case entity.BINGING_PLATFORM_ORGAN:
|
||
query += " AND binding.platform = ?"
|
||
queryList = append(queryList, platform)
|
||
default:
|
||
query += " AND ( ( binding.platform = ? AND binding.group_id = ? ) OR ( binding.platform = ? ) )"
|
||
queryList = append(queryList, entity.BINGING_PLATFORM_OPER)
|
||
queryList = append(queryList, "")
|
||
queryList = append(queryList, entity.BINGING_PLATFORM_ORGAN)
|
||
}
|
||
}
|
||
resultArr := []BindingsResult{}
|
||
/*err := mysql.MysqlDB.Table(dao.SDK_DATA_OPEN_INFO_C_NAME).Debug().Select("sum(app_open_count) as app_open_count, sum(total_app_stay_time) as total_app_stay_time, sum(app_close_count) as app_close_count, day_time").
|
||
Where(query, args...).Group("day_time").Order("day_time").
|
||
Scan(&resultArr).Error*/
|
||
|
||
err := DB.Debug().Model(&BindingMysql{}).
|
||
Joins("LEFT JOIN `bundle_info` ON `binding`.`binding_id` = `bundle_info`.`binding_id` ").
|
||
Select("binding.binding_id").
|
||
Where(query, queryList...).
|
||
Group("binding.binding_id").
|
||
Scan(&resultArr).Error
|
||
|
||
/*err := DB.Debug().Model(&BindingMysql{}).Preload("BundleInfos").
|
||
Joins("LEFT JOIN `bundle_info` `BundleInfos` ON `binding`.`binding_id` = `BundleInfos`.`binding_id` ").
|
||
Select("binding.*,GROUP_CONCAT(BundleInfos.bundle_id) AS `bundle_ids`").
|
||
Group("binding.binding_id").
|
||
Having(query, queryList...).
|
||
Order(sortColumn).
|
||
Offset(genOffset(pageNo, pageSize)).Limit(pageSize).
|
||
Find(&list).Error*/
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
|
||
fmt.Printf("resultArr = %s\n", utility.InterfaceToJsonString(resultArr))
|
||
/*t := DB.Model(&BindingMysql{}).Joins("LEFT JOIN `bundle_info` `BundleInfos` ON `binding`.`binding_id` = `BundleInfos`.`binding_id`").
|
||
Select("binding.*,GROUP_CONCAT(BundleInfos.bundle_id) AS `bundle_ids`").
|
||
Group("binding.binding_id").
|
||
Having(query, queryList...)
|
||
err = DB.Debug().Table("(?) t", t).Count(&total).Error*/
|
||
|
||
t := DB.Model(&BindingMysql{}).Joins("LEFT JOIN `bundle_info` ON `binding`.`binding_id` = `bundle_info`.`binding_id`").
|
||
Select("binding.binding_id").
|
||
Where(query, queryList...).
|
||
Group("binding.binding_id")
|
||
err = DB.Debug().Table("(?) t", t).Count(&total).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
|
||
bindingIds := []string{}
|
||
for _, id := range resultArr {
|
||
bindingIds = append(bindingIds, id.BindingId)
|
||
}
|
||
query = "binding_id in (?)"
|
||
queryList = []interface{}{bindingIds}
|
||
|
||
err = DB.Model(&BindingMysql{}).
|
||
//Preload("BundleInfos").
|
||
Where(query, queryList...).
|
||
Order(sortColumn).
|
||
Offset(genOffset(pageNo, pageSize)).Limit(pageSize).
|
||
Find(&list).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
}
|
||
|
||
bindings := make([]entity.Binding, 0)
|
||
for _, v := range list {
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, v.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
v.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
v.BundleInfos = bundleInfos
|
||
}
|
||
bindings = append(bindings, convertBindingMysqlToBinding(v))
|
||
}
|
||
return bindings, int(total), nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBindingsByAppId(ctx context.Context, pageSize int, pageNo int, appId string) ([]entity.Binding, int, error) {
|
||
list := make([]BindingMysql, 0)
|
||
var total int64
|
||
|
||
err := DB.Debug().Model(&BindingMysql{}).
|
||
//Preload("BundleInfos").Preload("AppInfos").
|
||
Where("link_app_infos.app_id = ?", appId).
|
||
Select("DISTINCT(binding.id), binding.*").
|
||
Joins("left join bundle_info on binding.binding_id = bundle_info.binding_id").
|
||
Joins("left join link_app_infos on binding.binding_id = link_app_infos.binding_id").
|
||
Order("binding.created_info_at DESC").
|
||
Offset(genOffset(pageNo, pageSize)).Limit(pageSize).
|
||
Find(&list).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
|
||
err = DB.Debug().Model(&BindingMysql{}).
|
||
//Preload("BundleInfos").Preload("AppInfos").
|
||
Where("link_app_infos.app_id = ?", appId).
|
||
Select("DISTINCT(binding.id), binding.*").
|
||
Joins("left join bundle_info on binding.binding_id = bundle_info.binding_id").
|
||
Joins("left join link_app_infos on binding.binding_id = link_app_infos.binding_id").
|
||
Order("binding.created_info_at DESC").
|
||
Offset(genOffset(pageNo, pageSize)).Limit(pageSize).
|
||
Count(&total).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
|
||
bindings := make([]entity.Binding, 0)
|
||
for _, v := range list {
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, v.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
v.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
v.BundleInfos = bundleInfos
|
||
}
|
||
bindings = append(bindings, convertBindingMysqlToBinding(v))
|
||
}
|
||
return bindings, int(total), nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetDevListBinding(ctx context.Context, pageSize int, pageNo int, sort string, searchText string, pullType string, groupId string, bindStatus string, platform int) ([]entity.Binding, int, error) {
|
||
bindingMysqls := make([]BindingMysql, 0)
|
||
var sortColumn string
|
||
switch sort {
|
||
case "-created":
|
||
sortColumn = "created_info_at DESC" //按创建时间排序
|
||
case "-expire":
|
||
sortColumn = "expire DESC" //按过期时间倒序排序
|
||
case "expire":
|
||
sortColumn = "expire ASC" //按过期时间正序排序
|
||
default:
|
||
sortColumn = "created_info_at DESC" //按创建时间倒序排序
|
||
}
|
||
|
||
query := "group_id = ? "
|
||
args := []interface{}{groupId}
|
||
|
||
switch pullType {
|
||
case "recently-expire":
|
||
beginData := time.Now().UnixNano() / 1e6
|
||
endData := time.Now().AddDate(0, 0, 30).UnixNano() / 1e6
|
||
query = query + "AND expire > ? and expire < ? "
|
||
args = append(args, beginData, endData)
|
||
}
|
||
|
||
switch bindStatus {
|
||
case "Valid":
|
||
query = query + "AND cooperate_status_value = ? "
|
||
args = append(args, entity.StBindValid)
|
||
case "Invalid":
|
||
query = query + "AND cooperate_status_value = ? "
|
||
args = append(args, entity.StBindInvalid)
|
||
}
|
||
|
||
if searchText != "" {
|
||
query += "AND name LIKE ? "
|
||
args = append(args, "%"+searchText+"%")
|
||
}
|
||
|
||
switch platform {
|
||
case entity.BINGING_PLATFORM_OPER:
|
||
query += "AND platform = ? "
|
||
args = append(args, platform)
|
||
case entity.BINGING_PLATFORM_ORGAN:
|
||
query += "AND platform = ? "
|
||
args = append(args, platform)
|
||
default:
|
||
query += "AND ( ( platform = ? ) OR ( platform = ? ) ) "
|
||
args = append(args, entity.BINGING_PLATFORM_OPER)
|
||
args = append(args, entity.BINGING_PLATFORM_ORGAN)
|
||
}
|
||
|
||
var total int64
|
||
err := DB.Model(&BindingMysql{}).
|
||
Where(query, args...).
|
||
//Preload("BundleInfos").
|
||
//Preload("AppInfos").
|
||
Count(&total).
|
||
Order(sortColumn).
|
||
Offset((pageNo - 1) * pageSize).Limit(pageSize).
|
||
Find(&bindingMysqls).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
|
||
bindings := make([]entity.Binding, 0)
|
||
for _, bindingMysql := range bindingMysqls {
|
||
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, bindingMysql.BindingID)
|
||
|
||
if len(linkAppInfos) > 0 {
|
||
bindingMysql.AppInfos = linkAppInfos
|
||
}
|
||
|
||
if len(bundleInfos) > 0 {
|
||
bindingMysql.BundleInfos = bundleInfos
|
||
}
|
||
|
||
bindings = append(bindings, convertBindingMysqlToBinding(bindingMysql))
|
||
}
|
||
|
||
return bindings, int(total), err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBundleInfoAndLinkAppInfo(ctx context.Context, bindingId string) ([]BundleInfo, []LinkAppInfo, error) {
|
||
tmpQuery := "binding_id = ?"
|
||
tmpArgs := []interface{}{bindingId}
|
||
|
||
var bundleInfos []BundleInfo
|
||
err := DB.Model(&BundleInfo{}).Where(tmpQuery, tmpArgs...).Find(&bundleInfos).Error
|
||
|
||
var linkAppInfos []LinkAppInfo
|
||
err = DB.Model(&LinkAppInfo{}).Where(tmpQuery, tmpArgs...).Find(&linkAppInfos).Error
|
||
|
||
return bundleInfos, linkAppInfos, err
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetBindingBySdkKey(ctx context.Context, sdkKey string) (*entity.Binding, error) {
|
||
query := "sdk_key = ?"
|
||
args := []interface{}{sdkKey}
|
||
|
||
bundleInfoMysql := BundleInfo{}
|
||
err := DB.Model(&BundleInfo{}).Where(query, args...).First(&bundleInfoMysql).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
return b.GetInfo(ctx, bundleInfoMysql.BindingId)
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) ListAutoBindAppBinding(ctx context.Context, groupId string) ([]string, error) {
|
||
query := "auto_bind = ? and platform = ? and group_id = ?"
|
||
args := []interface{}{1, entity.BINGING_PLATFORM_OPER, groupId}
|
||
|
||
bindingMysqls := make([]BindingMysql, 0)
|
||
err := DB.Model(&BindingMysql{}).Where(query, args...).Find(&bindingMysqls).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := []string{}
|
||
for _, binding := range bindingMysqls {
|
||
result = append(result, binding.BindingID)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) ListCopyOperBinding(ctx context.Context, bindingId string) ([]string, []entity.Binding, error) {
|
||
query := "platform = ? and from_binding_id = ?"
|
||
args := []interface{}{entity.BINGING_PLATFORM_OPER, bindingId}
|
||
|
||
bindingMysqls := make([]BindingMysql, 0)
|
||
err := DB.Model(&BindingMysql{}).Where(query, args...).Find(&bindingMysqls).Error
|
||
if err != nil {
|
||
return nil, nil, err
|
||
}
|
||
bindings := make([]entity.Binding, 0)
|
||
result := []string{}
|
||
for _, binding := range bindingMysqls {
|
||
result = append(result, binding.BindingID)
|
||
bindings = append(bindings, convertBindingMysqlToBinding(binding))
|
||
}
|
||
return result, bindings, nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) ListBindings(ctx context.Context, groupId string, searchText string, pageNo int, pageSize int) ([]entity.Binding, int, error) {
|
||
log.Infof("ListBindings req,groupId:[%s],searchText:[%s],pageNo:[%d],pageSize:[%d]", searchText, groupId, pageNo, pageSize)
|
||
var (
|
||
sortColumn = "binding.created_info_at DESC"
|
||
list = make([]BindingMysql, 0)
|
||
total int64
|
||
)
|
||
|
||
if searchText == "" {
|
||
if groupId != "" {
|
||
err := DB.Debug().
|
||
Where("binding.group_id=?", groupId).
|
||
Order(sortColumn).
|
||
Offset(genOffset(pageNo, pageSize)).Limit(pageSize).
|
||
Find(&list).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
err = DB.Model(&BindingMysql{}).
|
||
Where("binding.group_id=?", groupId).
|
||
Count(&total).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
} else {
|
||
err := DB.Debug().
|
||
Where("binding.group_id <> ?", "").
|
||
//Preload("BundleInfos").
|
||
Order(sortColumn).
|
||
Offset(genOffset(pageNo, pageSize)).Limit(pageSize).
|
||
Find(&list).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
err = DB.Model(&BindingMysql{}).
|
||
Where("binding.group_id <> ?", "").
|
||
Count(&total).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
}
|
||
} else {
|
||
query := "(binding.name LIKE ? OR binding.group_name LIKE ? OR bundle_ids LIKE ?) "
|
||
s := genLike(searchText)
|
||
queryList := []interface{}{s, s, s}
|
||
if groupId != "" {
|
||
query += " AND binding.group_id=? "
|
||
queryList = append(queryList, groupId)
|
||
} else {
|
||
query += " AND binding.group_id <> ? "
|
||
queryList = append(queryList, "")
|
||
}
|
||
|
||
err := DB.Debug().Model(&BindingMysql{}).
|
||
//Select("select * from binding").
|
||
//Preload("BundleInfos").
|
||
Joins("LEFT JOIN `bundle_info` ON `binding`.`binding_id` = `bundle_info`.`binding_id` ").
|
||
Where("binding.name LIKE ? OR binding.group_name LIKE ? OR bundle_info.bundle_id LIKE ?", s, s, s).
|
||
//Select("binding.*,GROUP_CONCAT(bundle_id.bundle_id) AS `bundle_ids`").
|
||
Group("binding.id").
|
||
//Having(query, queryList...).
|
||
Order(sortColumn).
|
||
Offset(genOffset(pageNo, pageSize)).Limit(pageSize).
|
||
Find(&list).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
t := DB.Model(&BindingMysql{}).
|
||
Joins("LEFT JOIN `bundle_info` ON `binding`.`binding_id` = `bundle_info`.`binding_id`").
|
||
//Select("binding.*,GROUP_CONCAT(bundle_info.bundle_id) AS `bundle_ids`").
|
||
Group("binding.id").
|
||
Where("binding.name LIKE ? OR binding.group_name LIKE ? OR bundle_info.bundle_id LIKE ?", s, s, s)
|
||
//Having(query, queryList...)
|
||
err = DB.Debug().Table("(?) t", t).Count(&total).Error
|
||
if err != nil {
|
||
return nil, 0, err
|
||
}
|
||
}
|
||
|
||
bindings := make([]entity.Binding, 0)
|
||
for _, v := range list {
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, v.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
v.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
v.BundleInfos = bundleInfos
|
||
}
|
||
bindings = append(bindings, convertBindingMysqlToBinding(v))
|
||
}
|
||
return bindings, int(total), nil
|
||
//
|
||
//db := DB.Model(&BindingMysql{})
|
||
//if groupId != "" {
|
||
// db = db.Where("binding.group_id = ?", groupId)
|
||
//}
|
||
//
|
||
//if searchText != "" {
|
||
// db = db.Where("binding.name LIKE ?", searchText).
|
||
// Or("binding.group_name LIKE ?", searchText).
|
||
// Or("bundle_info.bundle_id LIKE ?", searchText)
|
||
//}
|
||
//
|
||
//var total int
|
||
//bindingMysqls := make([]BindingMysql, 0)
|
||
//db = db.
|
||
// Select("DISTINCT(binding.id), binding.*").
|
||
// Joins("LEFT JOIN bundle_info on binding.binding_id = bundle_info.binding_id").
|
||
// Joins("LEFT JOIN link_app_infos on binding.binding_id = link_app_infos.binding_id").
|
||
// Find(&bindingMysqls)
|
||
//total = len(bindingMysqls)
|
||
//
|
||
//err := db.Order("created_info_at desc").Offset((pageNo - 1) * pageSize).Limit(pageSize).Find(&bindingMysqls).Error
|
||
//if err != nil {
|
||
// return nil, 0, err
|
||
//}
|
||
//bindings := make([]entity.Binding, 0)
|
||
//for _, bindingMysql := range bindingMysqls {
|
||
// bindings = append(bindings, convertBindingMysqlToBinding(bindingMysql))
|
||
//}
|
||
//return bindings, int(total), nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) GetAllAssBinds(ctx context.Context, appId string) ([]entity.Binding, error) {
|
||
//bindings := make([]BindingMongo, 0)
|
||
//err := bindingTable.OnlyGetAll(ctx, bson.M{"app_infos.app_id": appId}, []string{}, &bindings)
|
||
//if err != nil {
|
||
// return nil, err
|
||
//}
|
||
//result := make([]entity.Binding, 0)
|
||
//for _, bindingMongo := range bindings {
|
||
// result = append(result, convertBindingMongoToBinding(bindingMongo))
|
||
//}
|
||
//return result, nil
|
||
list := make([]BindingMysql, 0)
|
||
err := DB.Debug().Model(&BindingMysql{}).
|
||
//Preload("BundleInfos").Preload("AppInfos").
|
||
Where("link_app_infos.app_id = ?", appId).
|
||
Select("DISTINCT(binding.id), binding.*").
|
||
Joins("left join bundle_info on binding.binding_id = bundle_info.binding_id").
|
||
Joins("left join link_app_infos on binding.binding_id = link_app_infos.binding_id").
|
||
Find(&list).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
bindings := make([]entity.Binding, 0)
|
||
for _, v := range list {
|
||
bundleInfos, linkAppInfos, _ := b.GetBundleInfoAndLinkAppInfo(ctx, v.BindingID)
|
||
if len(linkAppInfos) > 0 {
|
||
v.AppInfos = linkAppInfos
|
||
}
|
||
if len(bundleInfos) > 0 {
|
||
v.BundleInfos = bundleInfos
|
||
}
|
||
bindings = append(bindings, convertBindingMysqlToBinding(v))
|
||
}
|
||
return bindings, nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateRelatedBindingCooperate(ctx context.Context, bindingId string, status entity.Status, specificStatus entity.SpecificStatus, cooperate bool) error {
|
||
query := "from_binding_id = ? and platform = ?"
|
||
args := []interface{}{bindingId, entity.BINGING_PLATFORM_OPER}
|
||
params := map[string]interface{}{}
|
||
if cooperate {
|
||
params = map[string]interface{}{
|
||
"cooperate_status_value": status.Value,
|
||
"cooperate_status_last_updated": status.LastUpdated,
|
||
"cooperate_status_modified_by": status.ModifiedBy,
|
||
"cooperate_valid_status_last_updated": specificStatus.LastUpdated,
|
||
"cooperate_valid_status_modified_by": specificStatus.ModifiedBy,
|
||
}
|
||
} else {
|
||
params = map[string]interface{}{
|
||
"cooperate_status_value": status.Value,
|
||
"cooperate_status_last_updated": status.LastUpdated,
|
||
"cooperate_status_modified_by": status.ModifiedBy,
|
||
"cooperate_invalid_status_last_updated": specificStatus.LastUpdated,
|
||
"cooperate_invalid_status_modified_by": specificStatus.ModifiedBy,
|
||
}
|
||
}
|
||
err := DB.Model(&BindingMysqlV2{}).Debug().
|
||
Where(query, args...).
|
||
Updates(params).Error
|
||
if err != nil {
|
||
return err
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateBundleIdIsForbidden(ctx context.Context, bundleId string) error {
|
||
query := "binary bundle_id= ?"
|
||
args := []interface{}{bundleId}
|
||
|
||
params := map[string]interface{}{
|
||
"is_forbidden": 1,
|
||
}
|
||
err := DB.Model(&BundleInfo{}).Debug().
|
||
Where(query, args...).
|
||
Updates(params).Error
|
||
if err != nil {
|
||
return err
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateBundleIdPlatform(ctx context.Context, bundleId, platform string) error {
|
||
query := "binary bundle_id= ?"
|
||
args := []interface{}{bundleId}
|
||
|
||
params := map[string]interface{}{
|
||
"remark": platform,
|
||
}
|
||
err := DB.Model(&BundleInfo{}).Debug().
|
||
Where(query, args...).
|
||
Updates(params).Error
|
||
if err != nil {
|
||
return err
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) NotFound(err error) bool {
|
||
return err == gorm.ErrRecordNotFound || errors.Is(err, gorm.ErrRecordNotFound)
|
||
}
|
||
|
||
func (b BindingByMysqlRepo) UpdateBundleBindingId(ctx context.Context, bundleId, bindingId, toBindingId string) error {
|
||
query := "binding_id = ? and bundle_id= ?"
|
||
args := []interface{}{bindingId, bundleId}
|
||
|
||
params := map[string]interface{}{
|
||
"binding_id": toBindingId,
|
||
}
|
||
err := DB.Model(&BundleInfo{}).Debug().
|
||
Where(query, args...).
|
||
Updates(params).Error
|
||
if err != nil {
|
||
return err
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func convertBindingMysqlToBinding(info BindingMysql) entity.Binding {
|
||
result := entity.Binding{}
|
||
|
||
bundleInfos := make([]entity.BundleInfo, 0)
|
||
for _, v := range info.BundleInfos {
|
||
item := entity.BundleInfo{
|
||
//Id: v.Id,
|
||
BundleID: v.BundleID,
|
||
Remark: v.Remark,
|
||
SDKKey: v.SDKKey,
|
||
SDKID: v.SDKID,
|
||
IsFirstCreate: v.IsFirstCreate,
|
||
CreatedAt: v.CreatedAt,
|
||
CreatedAccount: v.CreatedAccount,
|
||
CreatedBy: v.CreatedBy,
|
||
IsForbidden: v.IsForbidden,
|
||
IsReview: v.IsReview,
|
||
}
|
||
|
||
bundleInfos = append(bundleInfos, item)
|
||
}
|
||
|
||
createInfo := entity.CreatedInfo{
|
||
CreatedBy: info.CreatedInfoBy,
|
||
CreatedAt: info.CreatedInfoAt,
|
||
CreatedAccount: info.CreatedInfoAccount,
|
||
}
|
||
|
||
cooperateStatus := entity.Status{
|
||
Value: info.CooperateStatusValue,
|
||
Reason: info.CooperateStatusReason,
|
||
LastUpdated: info.CooperateStatusLastUpdated,
|
||
ModifiedBy: info.CooperateStatusModifiedBy,
|
||
}
|
||
|
||
cooperateValidStatus := entity.SpecificStatus{
|
||
Reason: info.CooperateValidStatusReason,
|
||
LastUpdated: info.CooperateValidStatusLastUpdated,
|
||
ModifiedBy: info.CooperateValidStatusModifiedBy,
|
||
}
|
||
|
||
cooperateInvalidStatus := entity.SpecificStatus{
|
||
Reason: info.CooperateInvalidStatusReason,
|
||
LastUpdated: info.CooperateInvalidStatusLastUpdated,
|
||
ModifiedBy: info.CooperateInvalidStatusModifiedBy,
|
||
}
|
||
|
||
//var appInfos []entity.AppInfo
|
||
//json.Unmarshal([]byte(bindingMysql.AppInfos), &appInfos)
|
||
|
||
result.BindingID = info.BindingID
|
||
result.Name = info.Name
|
||
result.BundleInfos = bundleInfos
|
||
result.CreatedInfo = createInfo
|
||
result.GroupID = info.GroupID
|
||
result.GroupName = info.GroupName
|
||
result.CooperateStatus = cooperateStatus
|
||
result.CooperateValidStatus = cooperateValidStatus
|
||
result.CooperateInvalidStatus = cooperateInvalidStatus
|
||
//result.AppInfos = appInfos
|
||
result.Owner = info.Owner
|
||
result.Expire = info.Expire
|
||
result.ApiServer = info.ApiServer
|
||
result.AppInfos = make([]entity.AppInfo, 0)
|
||
for _, v := range info.AppInfos {
|
||
item := entity.AppInfo{
|
||
//Id: v.Id,
|
||
AppID: v.AppId,
|
||
AssociatedAt: v.AssociatedAt,
|
||
AssociatedBy: v.AssociatedBy,
|
||
}
|
||
result.AppInfos = append(result.AppInfos, item)
|
||
}
|
||
|
||
result.GroupID = info.GroupID
|
||
result.PlatForm = info.PlatForm
|
||
result.AutoBind = info.AutoBind
|
||
result.HiddenBundle = info.HiddenBundle
|
||
result.FromBindingID = info.FromBindingID
|
||
return result
|
||
}
|
||
|
||
func convertBindingToBindingMysql(binding *entity.Binding) BindingMysql {
|
||
result := BindingMysql{}
|
||
|
||
result.BindingID = binding.BindingID
|
||
result.Name = binding.Name
|
||
result.CreatedInfoBy = binding.CreatedInfo.CreatedBy
|
||
result.CreatedInfoAt = binding.CreatedInfo.CreatedAt
|
||
result.CreatedInfoAccount = binding.CreatedInfo.CreatedAccount
|
||
result.GroupID = binding.GroupID
|
||
result.GroupName = binding.GroupName
|
||
result.CooperateStatusValue = binding.CooperateStatus.Value
|
||
result.CooperateStatusReason = binding.CooperateStatus.Reason
|
||
result.CooperateStatusLastUpdated = binding.CooperateStatus.LastUpdated
|
||
result.CooperateStatusModifiedBy = binding.CooperateStatus.ModifiedBy
|
||
result.CooperateValidStatusReason = binding.CooperateValidStatus.Reason
|
||
result.CooperateValidStatusLastUpdated = binding.CooperateValidStatus.LastUpdated
|
||
result.CooperateValidStatusModifiedBy = binding.CooperateValidStatus.ModifiedBy
|
||
result.CooperateInvalidStatusReason = binding.CooperateInvalidStatus.Reason
|
||
result.CooperateInvalidStatusLastUpdated = binding.CooperateInvalidStatus.LastUpdated
|
||
result.CooperateInvalidStatusModifiedBy = binding.CooperateInvalidStatus.ModifiedBy
|
||
result.AppInfos = make([]LinkAppInfo, 0)
|
||
for _, v := range binding.AppInfos {
|
||
item := LinkAppInfo{
|
||
//Id: v.Id,
|
||
BindingId: binding.BindingID,
|
||
AppId: v.AppID,
|
||
AssociatedAt: v.AssociatedAt,
|
||
AssociatedBy: v.AssociatedBy,
|
||
}
|
||
result.AppInfos = append(result.AppInfos, item)
|
||
}
|
||
result.BundleInfos = make([]BundleInfo, 0)
|
||
for _, v := range binding.BundleInfos {
|
||
item := BundleInfo{
|
||
//Id: v.Id,
|
||
BindingId: binding.BindingID,
|
||
GroupID: binding.GroupID,
|
||
BundleID: v.BundleID,
|
||
Remark: v.Remark,
|
||
SDKKey: v.SDKKey,
|
||
SDKID: v.SDKID,
|
||
IsFirstCreate: v.IsFirstCreate,
|
||
CreatedAt: v.CreatedAt,
|
||
CreatedAccount: v.CreatedAccount,
|
||
CreatedBy: v.CreatedBy,
|
||
IsForbidden: v.IsForbidden,
|
||
IsReview: v.IsReview,
|
||
}
|
||
result.BundleInfos = append(result.BundleInfos, item)
|
||
}
|
||
result.Owner = binding.Owner
|
||
result.Expire = binding.Expire
|
||
result.ApiServer = binding.ApiServer
|
||
result.GroupID = binding.GroupID
|
||
result.PlatForm = binding.PlatForm
|
||
result.AutoBind = binding.AutoBind
|
||
result.HiddenBundle = binding.HiddenBundle
|
||
result.FromBindingID = binding.FromBindingID
|
||
return result
|
||
}
|
||
|
||
func convertBindingMysqlToBindingMysqlV2(binding *BindingMysql) BindingMysqlV2 {
|
||
result := BindingMysqlV2{}
|
||
|
||
result.BindingID = binding.BindingID
|
||
result.Name = binding.Name
|
||
result.CreatedInfoBy = binding.CreatedInfoBy
|
||
result.CreatedInfoAt = binding.CreatedInfoAt
|
||
result.CreatedInfoAccount = binding.CreatedInfoAccount
|
||
result.GroupID = binding.GroupID
|
||
result.GroupName = binding.GroupName
|
||
result.CooperateStatusValue = binding.CooperateStatusValue
|
||
result.CooperateStatusReason = binding.CooperateStatusReason
|
||
result.CooperateStatusLastUpdated = binding.CooperateStatusLastUpdated
|
||
result.CooperateStatusModifiedBy = binding.CooperateStatusModifiedBy
|
||
result.CooperateValidStatusReason = binding.CooperateValidStatusReason
|
||
result.CooperateValidStatusLastUpdated = binding.CooperateValidStatusLastUpdated
|
||
result.CooperateValidStatusModifiedBy = binding.CooperateValidStatusModifiedBy
|
||
result.CooperateInvalidStatusReason = binding.CooperateInvalidStatusReason
|
||
result.CooperateInvalidStatusLastUpdated = binding.CooperateInvalidStatusLastUpdated
|
||
result.CooperateInvalidStatusModifiedBy = binding.CooperateInvalidStatusModifiedBy
|
||
result.Owner = binding.Owner
|
||
result.Expire = binding.Expire
|
||
result.ApiServer = binding.ApiServer
|
||
result.GroupID = binding.GroupID
|
||
result.PlatForm = binding.PlatForm
|
||
result.AutoBind = binding.AutoBind
|
||
result.HiddenBundle = binding.HiddenBundle
|
||
result.FromBindingID = binding.FromBindingID
|
||
return result
|
||
}
|
||
|
||
func convertBundleInfoToBundleInfoMysql(bindId, groupId string, bundleInfo entity.BundleInfo) BundleInfo {
|
||
result := BundleInfo{}
|
||
|
||
result.BindingId = bindId
|
||
result.GroupID = groupId
|
||
result.BundleID = bundleInfo.BundleID
|
||
result.Remark = bundleInfo.Remark
|
||
result.SDKKey = bundleInfo.SDKKey
|
||
result.SDKID = bundleInfo.SDKID
|
||
result.IsFirstCreate = bundleInfo.IsFirstCreate
|
||
result.CreatedAt = bundleInfo.CreatedAt
|
||
result.CreatedAccount = bundleInfo.CreatedAccount
|
||
result.CreatedBy = bundleInfo.CreatedBy
|
||
result.IsForbidden = bundleInfo.IsForbidden
|
||
return result
|
||
}
|
||
|
||
func convertBundleInfoMysqlToBundleInfo(bundleInfoMysql BundleInfo) entity.BundleInfo {
|
||
result := entity.BundleInfo{}
|
||
|
||
result.BundleID = bundleInfoMysql.BundleID
|
||
result.Remark = bundleInfoMysql.Remark
|
||
result.SDKKey = bundleInfoMysql.SDKKey
|
||
result.SDKID = bundleInfoMysql.SDKID
|
||
result.IsFirstCreate = bundleInfoMysql.IsFirstCreate
|
||
result.CreatedAt = bundleInfoMysql.CreatedAt
|
||
result.CreatedAccount = bundleInfoMysql.CreatedAccount
|
||
result.CreatedBy = bundleInfoMysql.CreatedBy
|
||
|
||
return result
|
||
}
|