fiee/fonchain-fiee
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改查询条件

Browse Source
This commit is contained in:
孙肖扬 2025-08-11 15:50:18 +08:00
parent 3c964140f3
commit 2c49b28d0f
4 changed files with 47 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/service/import/artist.go
View File

@ -16,7 +16,7 @@ type ArtistMedia struct {
Video string `json:"video"` Video string `json:"video"`
} }
type failedRecord struct { type FailedRecord struct {
name string Name string `json:"name"`
msg string Msg string `json:"msg"`
} }

44
pkg/service/import/binding.go
View File

@ -27,7 +27,7 @@ type artu struct {
} }
func ImportBind(c *gin.Context) { func ImportBind(c *gin.Context) {
var failedRecords []failedRecord var failedRecords []FailedRecord
// 1. 上传文件 // 1. 上传文件
excelFile, err := c.FormFile("excel") excelFile, err := c.FormFile("excel")
if err != nil { if err != nil {
@ -61,9 +61,9 @@ func ImportBind(c *gin.Context) {
Name: artist.Name, Name: artist.Name,
}) })
if err != nil { if err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("获取用户信息失败: %s", err.Error()), Msg: fmt.Sprintf("获取用户信息失败: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error())) log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
continue continue
@ -78,9 +78,9 @@ func ImportBind(c *gin.Context) {
Domain: "app", Domain: "app",
}) })
if err != nil { if err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("查询艺人的信息失败: %s", err.Error()), Msg: fmt.Sprintf("查询艺人的信息失败: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("查询艺人的信息失败: %s", err.Error())) log.Printf(fmt.Sprintf("查询艺人的信息失败: %s", err.Error()))
continue continue
@ -92,17 +92,17 @@ func ImportBind(c *gin.Context) {
} }
} }
if _, ok := apiCast.PlatformIDENUM_name[int32(accountType)]; !ok { if _, ok := apiCast.PlatformIDENUM_name[int32(accountType)]; !ok {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: errors.New("查询平台信息失败:").Error(), Msg: errors.New("查询平台信息失败:").Error(),
}) })
log.Printf(errors.New("查询平台信息失败:").Error()) log.Printf(errors.New("查询平台信息失败:").Error())
continue continue
} }
if err = cast.CheckUserBundleBalance(int32(res.UserList[0].Id), modelCast.BalanceTypeAccountValue); err != nil { if err = cast.CheckUserBundleBalance(int32(res.UserList[0].Id), modelCast.BalanceTypeAccountValue); err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("查询检查用户账户数量失败: %s", err.Error()), Msg: fmt.Sprintf("查询检查用户账户数量失败: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("查询检查用户账户数量失败: %s", err.Error())) log.Printf(fmt.Sprintf("查询检查用户账户数量失败: %s", err.Error()))
continue continue
@ -112,9 +112,9 @@ func ImportBind(c *gin.Context) {
AccountConsumptionNumber: 1, AccountConsumptionNumber: 1,
}) })
if err != nil { if err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("增加账户数量失败: %s", err.Error()), Msg: fmt.Sprintf("增加账户数量失败: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("增加账户数量失败: %s", err.Error())) log.Printf(fmt.Sprintf("增加账户数量失败: %s", err.Error()))
continue continue
@ -129,18 +129,18 @@ func ImportBind(c *gin.Context) {
ArtistPhoneAreaCode: infoResp.TelAreaCode, ArtistPhoneAreaCode: infoResp.TelAreaCode,
}) })
if err != nil { if err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("绑定账户信息失败: %s", err.Error()), Msg: fmt.Sprintf("绑定账户信息失败: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("绑定账户信息失败: %s", err.Error())) log.Printf(fmt.Sprintf("绑定账户信息失败: %s", err.Error()))
_, err = service.BundleProvider.AddBundleBalance(context.Background(), &bundle.AddBundleBalanceReq{ _, err = service.BundleProvider.AddBundleBalance(context.Background(), &bundle.AddBundleBalanceReq{
UserId: int32(res.UserList[0].Id), UserId: int32(res.UserList[0].Id),
AccountConsumptionNumber: -1, AccountConsumptionNumber: -1,
}) })
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("绑定失败后减少余额失败: %s", err.Error()), Msg: fmt.Sprintf("绑定失败后减少余额失败: %s", err.Error()),
}) })
log.Println(fmt.Sprintf("绑定失败后减少余额失败: %s", err.Error()), errors.New(e.GetMsg(e.InvalidParams))) log.Println(fmt.Sprintf("绑定失败后减少余额失败: %s", err.Error()), errors.New(e.GetMsg(e.InvalidParams)))
continue continue

8
pkg/service/import/confirm.go
View File

@ -28,15 +28,15 @@ func WorkConfirm(c *gin.Context) { // 确认作品并扣除余量
return return
} }
//遍历更新状态 //遍历更新状态
var failedRecords []failedRecord var failedRecords []FailedRecord
for _, v := range list.Data { for _, v := range list.Data {
res, err := service.AccountFieeProvider.UserList(context.Background(), &account.UserListRequest{ res, err := service.AccountFieeProvider.UserList(context.Background(), &account.UserListRequest{
Name: v.ArtistName, Name: v.ArtistName,
}) })
if err != nil { if err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: v.ArtistName, Name: v.ArtistName,
msg: fmt.Sprintf("获取用户信息失败: %s", err.Error()), Msg: fmt.Sprintf("获取用户信息失败: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error())) log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
continue continue

36
pkg/service/import/publish.go
View File

@ -84,7 +84,7 @@ func ImportPublish(c *gin.Context) {
return return
} }
// 5.发布视频 // 5.发布视频
var failedRecords []failedRecord var failedRecords []FailedRecord
for _, artist := range artists { for _, artist := range artists {
var infoResp *accountFiee.UserInfoResponse var infoResp *accountFiee.UserInfoResponse
var err error var err error
@ -92,9 +92,9 @@ func ImportPublish(c *gin.Context) {
Name: artist.Name, Name: artist.Name,
}) })
if err != nil { if err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("获取用户信息失败: %s", err.Error()), Msg: fmt.Sprintf("获取用户信息失败: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error())) log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
continue continue
@ -105,21 +105,21 @@ func ImportPublish(c *gin.Context) {
Domain: "app", Domain: "app",
}) })
if err != nil { if err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("获取用户信息失败: %s", err.Error()), Msg: fmt.Sprintf("获取用户信息失败: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error())) log.Printf(fmt.Sprintf("获取用户信息失败: %s", err.Error()))
continue continue
} }
} }
if err = cast.CheckUserBundleBalance(int32(list.UserList[0].Id), modelCast.BalanceTypeAccountValue); err != nil { if err = cast.CheckUserBundleBalance(int32(list.UserList[0].Id), modelCast.BalanceTypeVideoValue); err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("检查用户账户数量: %s", err.Error()), Msg: fmt.Sprintf("检查用户视频可消耗数量: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("检查用户账户数量: %s", err.Error())) log.Printf(fmt.Sprintf("检查用户视频可消耗数量: %s", err.Error()))
continue continue
} }
//自媒体账号 //自媒体账号
@ -127,9 +127,9 @@ func ImportPublish(c *gin.Context) {
ArtistUuid: strconv.FormatUint(list.UserList[0].Id, 10), ArtistUuid: strconv.FormatUint(list.UserList[0].Id, 10),
}) })
if err != nil || accountList == nil { if err != nil || accountList == nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("自媒体账号数量获取失败: %s,账号数量:%d", err.Error(), len(accountList.Data)), Msg: fmt.Sprintf("自媒体账号数量获取失败: %s,账号数量:%d", err.Error(), len(accountList.Data)),
}) })
log.Printf(fmt.Sprintf("自媒体账号数量获取失败: %s,账号数量:%d", err.Error(), len(accountList.Data))) log.Printf(fmt.Sprintf("自媒体账号数量获取失败: %s,账号数量:%d", err.Error(), len(accountList.Data)))
continue continue
@ -183,9 +183,9 @@ func ImportPublish(c *gin.Context) {
Source: 2, Source: 2,
}) })
if err != nil { if err != nil {
failedRecords = append(failedRecords, failedRecord{ failedRecords = append(failedRecords, FailedRecord{
name: artist.Name, Name: artist.Name,
msg: fmt.Sprintf("发布"+artist.Name+"视频"+artist.Title+"失败: %s", err.Error()), Msg: fmt.Sprintf("发布"+artist.Name+"视频"+artist.Title+"失败: %s", err.Error()),
}) })
log.Printf(fmt.Sprintf("发布"+artist.Name+"视频"+artist.Title+"失败: %s", err.Error())) log.Printf(fmt.Sprintf("发布"+artist.Name+"视频"+artist.Title+"失败: %s", err.Error()))
continue continue