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

1

Browse Source
This commit is contained in:
戴育兵 2025-12-19 20:45:25 +08:00
parent 0e5cb8a5ff
commit bc178ea266
1 changed files with 39 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
pkg/service/cast/media.go
View File

@ -567,8 +567,12 @@ func ImportMediaAccount(ctx *gin.Context) {
//查询艺人信息 //查询艺人信息
if config.AppConfig.System.AppMode == "dev" { if config.AppConfig.System.AppMode == "dev" {
subInfoResp = &accountFiee.UserInfoResponse{ subInfoResp = &accountFiee.UserInfoResponse{
Id: 0, Id: 1245,
SubNum: "", SubNum: "FL00023",
Status: 0,
Name: "测试远",
TelNum: "1826145872",
TelAreaCode: "86",
} }
} else { } else {
subInfoResp, err = service.AccountFieeProvider.SubNumGetInfo(context.Background(), &accountFiee.SubNumGetInfoRequest{ subInfoResp, err = service.AccountFieeProvider.SubNumGetInfo(context.Background(), &accountFiee.SubNumGetInfoRequest{
@ -576,7 +580,6 @@ func ImportMediaAccount(ctx *gin.Context) {
Domain: "app", Domain: "app",
}) })
} }
if err != nil { if err != nil {
excelSetRemark(excelData, line, "查询艺人出错") excelSetRemark(excelData, line, "查询艺人出错")
continue continue
@ -601,20 +604,26 @@ func ImportMediaAccount(ctx *gin.Context) {
} }
if tiktokName != "" { if tiktokName != "" {
if err = updateMediaAccount(tiktokName, cast.PlatformIDENUM_TIKTOK, subInfoResp, loginInfo); err != nil { if err = updateMediaAccount(tiktokName, cast.PlatformIDENUM_TIKTOK, subInfoResp, loginInfo); err != nil {
excelSetRemark(excelData, line, err.Error()) excelSetRemark(excelData, line, fmt.Sprintf("%s:%s", tiktokName, err.Error()))
} }
} }
if insName != "" { if insName != "" {
if err = updateMediaAccount(tiktokName, cast.PlatformIDENUM_INS, subInfoResp, loginInfo); err != nil { if err = updateMediaAccount(insName, cast.PlatformIDENUM_INS, subInfoResp, loginInfo); err != nil {
excelSetRemark(excelData, line, err.Error()) excelSetRemark(excelData, line, fmt.Sprintf("%s:%s", insName, err.Error()))
} }
} }
if dmName != "" { if dmName != "" {
if err = updateMediaAccount(tiktokName, cast.PlatformIDENUM_DM, subInfoResp, loginInfo); err != nil { if err = updateMediaAccount(dmName, cast.PlatformIDENUM_DM, subInfoResp, loginInfo); err != nil {
excelSetRemark(excelData, line, err.Error()) excelSetRemark(excelData, line, fmt.Sprintf("%s:%s", dmName, err.Error()))
} }
} }
} }
// 保存Excel文件到磁盘
resultPath := fmt.Sprintf("./runtime/media/%s", fileName)
if err = excelData.SaveAs(resultPath); err != nil {
service.Error(ctx, err)
return
}
urlHost := config.AppConfig.System.FieeHost urlHost := config.AppConfig.System.FieeHost
urlResult := fmt.Sprintf("%s/api/fiee/static/media/%s", urlHost, fileName) urlResult := fmt.Sprintf("%s/api/fiee/static/media/%s", urlHost, fileName)
service.Success(ctx, map[string]interface{}{ service.Success(ctx, map[string]interface{}{
@ -622,7 +631,6 @@ func ImportMediaAccount(ctx *gin.Context) {
"failCount": 0, "failCount": 0,
"url": urlResult, "url": urlResult,
}) })
return
} }
func excelSetRemark(excelData *excelize.File, line int, remark string) { func excelSetRemark(excelData *excelize.File, line int, remark string) {
@ -634,7 +642,20 @@ func excelSetRemark(excelData *excelize.File, line int, remark string) {
} }
func updateMediaAccount(platformName string, platformId cast.PlatformIDENUM, subInfoResp *accountFiee.UserInfoResponse, loginInfo login.Info) error { func updateMediaAccount(platformName string, platformId cast.PlatformIDENUM, subInfoResp *accountFiee.UserInfoResponse, loginInfo login.Info) error {
_, err := service.CastProvider.UpdateMediaAccount(context.Background(), &cast.UpdateMediaAccountReq{ var err error
if config.AppConfig.System.AppMode != "dev" {
if _, err = CheckUserBundleBalance(int32(subInfoResp.Id), modelCast.BalanceTypeAccountValue); err != nil {
return err
}
_, err = service.BundleProvider.AddBundleBalance(context.Background(), &bundle.AddBundleBalanceReq{
UserId: int32(subInfoResp.Id),
AccountConsumptionNumber: 1,
})
if err != nil {
return err
}
}
_, err = service.CastProvider.UpdateMediaAccount(context.Background(), &cast.UpdateMediaAccountReq{
PlatformID: platformId, PlatformID: platformId,
PlatformUserName: platformName, PlatformUserName: platformName,
PlatformUserID: "", PlatformUserID: "",
@ -646,5 +667,13 @@ func updateMediaAccount(platformName string, platformId cast.PlatformIDENUM, sub
ManagerUserName: loginInfo.Name, ManagerUserName: loginInfo.Name,
ArtistSubNum: subInfoResp.SubNum, ArtistSubNum: subInfoResp.SubNum,
}) })
if config.AppConfig.System.AppMode != "dev" {
if err != nil {
_, err = service.BundleProvider.AddBundleBalance(context.Background(), &bundle.AddBundleBalanceReq{
UserId: int32(subInfoResp.Id),
AccountConsumptionNumber: -1,
})
}
}
return err return err
} }