internal/controller/bundle.go

@@ -127,6 +127,3 @@ func (b *BundleProvider) ListUnfinishedInfos(_ context.Context, req *bundle.Auto
 func (b *BundleProvider) SoftDeleteUnfinishedInfo(_ context.Context, req *bundle.SoftDeleteUnfinishedInfoRequest) (res *bundle.CommonResponse, err error) {
 	return logic.SoftDeleteUnfinishedInfo(req)
 }
-func (b *BundleProvider) ReSignTheContract(_ context.Context, req *bundle.ReSignTheContractRequest) (res *bundle.CommonResponse, err error) {
-	return logic.ReSignTheContract(req)
-}

internal/controller/bundleV2.go

@@ -51,6 +51,3 @@ func (b *BundleProvider) BatchGetValueAddServiceLang(ctx context.Context, req *b
 func (b *BundleProvider) BundleListH5V2(_ context.Context, req *bundle.BundleListRequest) (res *bundle.BundleListResponse, err error) {
 	return logic.BundleListH5V2(req)
 }
-func (b *BundleProvider) QueryTheOrderSnapshotInformation(_ context.Context, req *bundle.QueryTheOrderSnapshotInformationReq) (res *bundle.QueryTheOrderSnapshotInformationResp, err error) {
-	return logic.QueryTheOrderSnapshotInformation(req)
-}

internal/controller/task.go

@@ -590,35 +590,3 @@ func (b *BundleProvider) AddHiddenTaskAssignee(_ context.Context, req *bundle.Ad
 	}
 	return &bundle.ComResponse{Msg: "删除该指派人成功"}, nil
 }
-
-// CreateTaskWorkLog 创建任务日志记录
-func (b *BundleProvider) CreateTaskWorkLog(_ context.Context, req *bundle.CreateTaskWorkLogRequest) (*bundle.CommonResponse, error) {
-	// 转换请求参数
-	daoReq := &dao.CreateTaskWorkLogRequest{
-		AssignRecordsUUID: req.AssignRecordsUUID,
-		WorkUUID:          req.WorkUUID,
-		Title:             req.Title,
-		ArtistUUID:        req.ArtistUUID,
-		SubNum:            req.SubNum,
-		TelNum:            req.TelNum,
-		ArtistName:        req.ArtistName,
-		OperationType:     int(req.OperationType),
-		TaskType:          int(req.TaskType),
-		TaskCount:         int(req.TaskCount),
-		Remark:            req.Remark,
-		OperatorName:      req.OperatorName,
-		OperatorNum:       req.OperatorNum,
-	}
-
-	// 调用logic层
-	err := logic.CreateTaskWorkLog(daoReq)
-	if err != nil {
-		return &bundle.CommonResponse{
-			Msg: err.Error(),
-		}, err
-	}
-
-	return &bundle.CommonResponse{
-		Msg: "任务日志创建成功",
-	}, nil
-}

internal/dao/bundleDao.go

@@ -1,7 +1,6 @@
 package dao
 
 import (
-	"encoding/json"
 	"micro-bundle/internal/model"
 	"micro-bundle/pb/bundle"
 	"micro-bundle/pkg/app"
@@ -469,36 +468,3 @@ func GetUnconfirmed() (data []model.CastWork, err error) {
 	err = app.ModuleClients.BundleDB.Model(&model.CastWork{}).Where("status = ? and update_time < ?", 4, time.Now().Add(-time.Hour*24)).Find(&data).Error
 	return
 }
-func QueryTheOrderSnapshotInformation(req *bundle.QueryTheOrderSnapshotInformationReq) (res *bundle.QueryTheOrderSnapshotInformationResp, err error) {
-	res = new(bundle.QueryTheOrderSnapshotInformationResp)
-	var record model.BundleOrderRecords
-	err = app.ModuleClients.BundleDB.
-		Preload("BundleOrderValueAdd").
-		Where("order_no = ?", req.OrderNo).
-		First(&record).Error
-	if err != nil {
-		return
-	}
-	var temp struct {
-		Content string `json:"content"`
-	}
-	if len(record.BundleCommonJson) > 0 {
-		_ = json.Unmarshal(record.BundleCommonJson, &temp) // 失败也不会影响
-	}
-	res.BundleContent = temp.Content // 如果失败，这里就是空字符串
-	res.BundleOrder = make([]*bundle.ServiceInformation, 0)
-	res.AddBundleOrder = make([]*bundle.ServiceInformation, 0)
-	for _, v := range record.BundleOrderValueAdd {
-		info := &bundle.ServiceInformation{
-			ServiceType: uint64(v.ServiceType),
-			Num:         uint64(v.Num),
-			Unit:        v.Unit,
-		}
-		if v.EquityType == 1 {
-			res.BundleOrder = append(res.BundleOrder, info)
-		} else if v.EquityType == 2 {
-			res.AddBundleOrder = append(res.AddBundleOrder, info)
-		}
-	}
-	return
-}

internal/dao/bundleExtend.go

@@ -135,11 +135,11 @@ func GetBundleBalanceList(req *bundle.GetBundleBalanceListReq) (data []model.Bun
 			}
 		}
 	}
-	if len(req.Month) == 0 {
+	if req.Month == "" {
 		newestMonthQuery := app.ModuleClients.BundleDB.Model(&model.BundleBalance{}).Select("max(month) as month,user_id").Group("user_id")
 		session.Joins("LEFT JOIN (?) as newest_month on newest_month.user_id = bb.user_id", newestMonthQuery).Where("")
 	} else {
-		session = session.Where("bb.month in (?)", req.Month)
+		session = session.Where("bb.month = ?", req.Month)
 	}
 	err = session.Count(&total).Error
 	if err != nil {
@@ -694,9 +694,9 @@ inner join (
 		// 当月增值限制类会过期型数据分析可使用额度
 		v.MonthlyIncreaseLimitExpiredDataAnalysisNumber = cal(v.IncreaseLimitDataAnalysisExpiredNumber, v.MonthlyLimitDataAnalysisQuotaNumber)
 		// 当月套餐限制类型数据分析可使用额度
-		v.MonthlyBundleLimitDataAnalysisNumber = v.MonthlyBundleLimitDataAnalysisNumber - v.MonthlyBundleLimitDataAnalysisConsumptionNumber + cal(v.BundleLimitDataAnalysisNumber, v.MonthlyLimitDataAnalysisQuotaNumber)
+		v.MonthlyBundleLimitDataAnalysisNumber = v.MonthlyBundleLimitDataAnalysisNumber - v.MonthlyBundleLimitDataAnalysisConsumptionNumber + cal(v.BundleLimitImageNumber, v.MonthlyLimitImageQuotaNumber)
 		// 当月增值限制类型数据分析可使用额度
-		v.MonthlyIncreaseLimitDataAnalysisNumber = v.MonthlyIncreaseLimitDataAnalysisNumber - v.MonthlyIncreaseLimitDataAnalysisConsumptionNumber + cal(v.IncreaseLimitDataAnalysisNumber, v.MonthlyLimitDataAnalysisQuotaNumber)
+		v.MonthlyIncreaseLimitDataAnalysisNumber = v.MonthlyIncreaseLimitDataAnalysisNumber - v.MonthlyIncreaseLimitDataAnalysisConsumptionNumber + cal(v.IncreaseLimitImageNumber, v.MonthlyLimitImageQuotaNumber)
 
 		// 重置单月消耗数量
 		v.MonthlyBundleVideoConsumptionNumber = 0

internal/dao/bundleMetrics.go

@@ -6,7 +6,6 @@ import (
 	"micro-bundle/internal/model"
 	"micro-bundle/pb/bundle"
 	"micro-bundle/pkg/app"
-	"strings"
 	"time"
 
 	"github.com/duke-git/lancet/v2/datetime"
@@ -39,7 +38,7 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 	// }
 	err = query.First(result).Error
 	if err != nil {
-		return nil, fmt.Errorf("总金额统计失败")
+		return
 	}
 
 	// 将字符串转换为数值进行计算
@@ -73,7 +72,7 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 
 	subQuery = app.ModuleClients.BundleDB.Model(&model.Reconciliation{}).
 		Select("SUM(handling_fee) as new_fee_payment_amount, SUM(pay_amount) as new_payment_amount").
-		Joins("LEFT JOIN bundle_order_records bor ON bor.order_no COLLATE utf8mb4_general_ci = reconciliation.bundle_order_on COLLATE utf8mb4_general_ci").
+		Joins("LEFT JOIN bundle_order_records bor ON bor.order_no = bundle_order_on").
 		Where("`reconciliation`.pay_time >= ?", req.Start+" 00:00:00").
 		Where("`reconciliation`.pay_time <= ?", req.End+" 23:59:59").
 		Where("`reconciliation`.deleted_at is null and reconciliation.pay_status = 2 and bor.status=2 and bor.deleted_at is null")
@@ -192,7 +191,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		Where("cwe.cost_type = 1").
 		Where("cwl.update_time >= ?", req.Start+" 00:00:00").
 		Where("cwl.update_time <= ?", req.End+" 23:59:59").
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0 and ccl.deleted_at = 0 and cwe.deleted_at = 0")
 	if req.BundleUuid != "" {
 		query = query.Where("ccl.bundle_uuid = ?", req.BundleUuid)
@@ -211,7 +209,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		Where("cwe.cost_type != 1").
 		Where("cwl.update_time >= ?", req.Start+" 00:00:00").
 		Where("cwl.update_time <= ?", req.End+" 23:59:59").
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0 and ccl.deleted_at = 0 and cwe.deleted_at = 0")
 	if req.BundleUuid != "" {
 		query = query.Where("ccl.bundle_uuid = ?", req.BundleUuid)
@@ -243,7 +240,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		Where("cw.status in ?", []int{7, 6, 9}).
 		Where("cwl.update_time >= ?", req.Start+" 00:00:00").
 		Where("cwl.update_time <= ?", req.End+" 23:59:59").
-		Where("cw.origin_uuid = ''").
 		Where("cw.deleted_at = 0 and cwl.deleted_at = 0 and cwe.deleted_at = 0").
 		Group("cw.artist_uuid")
 
@@ -306,7 +302,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		Where("cast_work.work_category = 2").
 		Where("cast_work.submit_time >= ?", req.Start+" 00:00:00").
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0")
 
 	if req.BundleUuid != "" {
@@ -327,7 +322,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 			Where("cast_work.work_category = 2").
 			Where("cast_work.submit_time >= ?", req.Start+" 00:00:00").
 			Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
-			Where("cast_work.origin_uuid = ''").
 			Where("cast_work.deleted_at = 0 and bor.deleted_at IS NULL and bb.deleted_at IS NULL").
 			Where("bor.bundle_uuid = ?", req.BundleUuid)
 		err = query.Count(&newVideoUsed).Error
@@ -343,7 +337,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("cast_work.work_category = 2"). // 视频类型
 		Where("cwe.cost_type = 1").           // 套餐类型
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0")
 	if req.BundleUuid != "" {
 		queryBundleVideo = queryBundleVideo.Where("ccl.bundle_uuid = ?", req.BundleUuid)
@@ -360,7 +353,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("cast_work.work_category = 2").     // 视频类型
 		Where("cwe.cost_type in ?", []int{2, 3}). // 增值类型
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0")
 	if req.BundleUuid != "" {
 		queryIncreaseVideo = queryIncreaseVideo.Where("ccl.bundle_uuid = ?", req.BundleUuid)
@@ -444,7 +436,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		Where("cast_work.work_category = 1").
 		Where("cast_work.submit_time >= ?", req.Start+" 00:00:00").
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0")
 
 	if req.BundleUuid != "" {
@@ -464,7 +455,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 			Where("cast_work.work_category = 1").
 			Where("cast_work.submit_time >= ?", req.Start+" 00:00:00").
 			Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
-			Where("cast_work.origin_uuid = ''").
 			Where("cast_work.deleted_at = 0 and bor.deleted_at IS NULL and bb.deleted_at IS NULL").
 			Where("bor.bundle_uuid = ?", req.BundleUuid)
 		err = query.Count(&newImageUsed).Error
@@ -480,7 +470,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("cast_work.work_category = 1"). // 图文类型
 		Where("cwe.cost_type = 1 ").          // 套餐类型
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0")
 	if req.BundleUuid != "" {
 		queryBundleImage = queryBundleImage.Where("ccl.bundle_uuid = ?", req.BundleUuid)
@@ -497,7 +486,6 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("cast_work.work_category = 1").     // 图文类型
 		Where("cwe.cost_type in ?", []int{2, 3}). // 增值类型
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0")
 	if req.BundleUuid != "" {
 		queryIncreaseImage = queryIncreaseImage.Where("ccl.bundle_uuid = ?", req.BundleUuid)
@@ -514,15 +502,16 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 		UnUsedDataAnalysis int64 `gorm:"column:un_used_data_analysis"`
 	}
 	var dataAnalysisCountInfo DataAnalysisCountResult
-	query = app.ModuleClients.BundleDB.Table("cast_work_analysis as cwa").
+	query = app.ModuleClients.BundleDB.Model(&model.CastWork{}).
 		Select(`
-		SUM(CASE WHEN ccal.uuid IS NOT NULL AND ccal.deleted_at = 0 THEN 1 ELSE 0 END) AS data_analysis_used,
-		SUM(CASE WHEN ccal.uuid IS NULL THEN 1 ELSE 0 END) AS un_used_data_analysis
+		SUM(CASE WHEN ccl.uuid IS NOT NULL AND ccl.deleted_at = 0 THEN 1 ELSE 0 END) AS data_analysis_used,
+		SUM(CASE WHEN ccl.uuid IS NULL THEN 1 ELSE 0 END) AS un_used_data_analysis
 	`).
-		Joins("left join cast_cost_analysis_log ccal on ccal.analysis_uuid = cwa.uuid").
-		Where("cwa.submit_time >= ?", req.Start+" 00:00:00").
-		Where("cwa.submit_time <= ?", req.End+" 23:59:59").
-		Where("cwa.deleted_at = 0")
+		Joins("left join cast_cost_log ccl on ccl.work_uuid = cast_work.uuid").
+		Where("cast_work.work_category = 3").
+		Where("cast_work.submit_time >= ?", req.Start+" 00:00:00").
+		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
+		Where("cast_work.deleted_at = 0")
 	if req.BundleUuid != "" {
 		query = query.Where("ccl.bundle_uuid = ?", req.BundleUuid)
 	}
@@ -534,43 +523,46 @@ func MetricsBusiness(req *bundle.MetricsBusinessReq) (result *bundle.MetricsBusi
 	if req.BundleUuid == "" {
 		newDataAnalysisUsed = dataAnalysisCountInfo.DataAnalysisUsed + dataAnalysisCountInfo.UnUsedDataAnalysis
 	} else {
-		query = app.ModuleClients.BundleDB.Table("cast_work_analysis as cwa").
-			Joins("left join bundle_balance bb ON CAST(bb.user_id AS CHAR) COLLATE utf8mb4_general_ci = cwa.artist_id COLLATE utf8mb4_general_ci AND cwa.submit_time >= bb.start_at AND cwa.submit_time <= bb.expired_at and bb.month = DATE_FORMAT(cwa.submit_time, '%Y-%m')").
+		query = app.ModuleClients.BundleDB.Model(&model.CastWork{}).
+			Joins("left join bundle_balance bb ON CAST(bb.user_id AS CHAR) COLLATE utf8mb4_general_ci = cast_work.artist_uuid COLLATE utf8mb4_general_ci AND cast_work.submit_time >= bb.start_at AND cast_work.submit_time <= bb.expired_at and bb.month = DATE_FORMAT(cast_work.submit_time, '%Y-%m')").
 			Joins("left join bundle_order_records bor ON bor.uuid = bb.order_uuid").
-			Where("cwa.submit_time >= ?", req.Start+" 00:00:00").
-			Where("cwa.submit_time <= ?", req.End+" 23:59:59").
-			Where("cwa.deleted_at = 0 and bor.deleted_at IS NULL and bb.deleted_at IS NULL").
+			Where("cast_work.work_category = 3").
+			Where("cast_work.submit_time >= ?", req.Start+" 00:00:00").
+			Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
+			Where("cast_work.deleted_at = 0 and bor.deleted_at IS NULL and bb.deleted_at IS NULL").
 			Where("bor.bundle_uuid = ?", req.BundleUuid)
 		err = query.Count(&newDataAnalysisUsed).Error
 		if err != nil {
 			return
 		}
 	}
-	//数据分析套餐总已上传数
+
 	var totalUploadedBundleDataAnalysisCount int64
-	queryBundleDataAnalysis := app.ModuleClients.BundleDB.Table("cast_work_analysis as cwa").
-		Joins("left join cast_work_analysis_extra cwae on cwae.analysis_uuid = cwa.uuid AND cwae.deleted_at = 0").
-		Joins("left join cast_cost_analysis_log ccal on ccal.analysis_uuid = cwa.uuid AND ccal.deleted_at = 0").
-		Where("cwa.submit_time <= ?", req.End+" 23:59:59").
-		Where("cwae.cost_type = 1"). // 套餐类型
-		Where("cwa.deleted_at = 0")
+	queryBundleDataAnalysis := app.ModuleClients.BundleDB.Model(&model.CastWork{}).
+		Joins("left join cast_work_extra cwe on cwe.work_uuid = cast_work.uuid").
+		Joins("left join cast_cost_log ccl on ccl.work_uuid = cast_work.uuid AND ccl.deleted_at = 0").
+		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
+		Where("cast_work.work_category = 3"). // 数据分析类型
+		Where("cwe.cost_type = 1").           // 套餐类型
+		Where("cast_work.deleted_at = 0")
 	if req.BundleUuid != "" {
-		queryBundleDataAnalysis = queryBundleDataAnalysis.Where("ccal.bundle_uuid = ?", req.BundleUuid)
+		queryBundleDataAnalysis = queryBundleDataAnalysis.Where("ccl.bundle_uuid = ?", req.BundleUuid)
 	}
 	err = queryBundleDataAnalysis.Count(&totalUploadedBundleDataAnalysisCount).Error
 	if err != nil {
 		return
 	}
-	//数据分析增值总已上传数
+
 	var totalUploadedIncreaseDataAnalysisCount int64
-	queryIncreaseDataAnalysis := app.ModuleClients.BundleDB.Table("cast_work_analysis as cwa").
-		Joins("left join cast_work_analysis_extra cwae on cwae.analysis_uuid = cwa.uuid AND cwae.deleted_at = 0").
-		Joins("left join cast_cost_analysis_log ccal on ccal.analysis_uuid = cwa.uuid AND ccal.deleted_at = 0").
-		Where("cwa.submit_time <= ?", req.End+" 23:59:59").
-		Where("cwae.cost_type in ?", []int{2, 3}). // 增值类型
-		Where("cwa.deleted_at = 0")
+	queryIncreaseDataAnalysis := app.ModuleClients.BundleDB.Model(&model.CastWork{}).
+		Joins("left join cast_work_extra cwe on cwe.work_uuid = cast_work.uuid AND cwe.deleted_at = 0").
+		Joins("left join cast_cost_log ccl on ccl.work_uuid = cast_work.uuid AND ccl.deleted_at = 0").
+		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
+		Where("cast_work.work_category = 3").     // 数据分析类型
+		Where("cwe.cost_type in ?", []int{2, 3}). // 增值类型
+		Where("cast_work.deleted_at = 0")
 	if req.BundleUuid != "" {
-		queryIncreaseDataAnalysis = queryIncreaseDataAnalysis.Where("ccal.bundle_uuid = ?", req.BundleUuid)
+		queryIncreaseDataAnalysis = queryIncreaseDataAnalysis.Where("ccl.bundle_uuid = ?", req.BundleUuid)
 	}
 	err = queryIncreaseDataAnalysis.Count(&totalUploadedIncreaseDataAnalysisCount).Error
 	if err != nil {
@@ -653,7 +645,6 @@ func MetricsOperatingCreate(req *bundle.MetricsOperatingCreateReq) (result *bund
 		Where("cast_work.submit_time >= ?", req.Start+" 00:00:00").
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("work_category = 2"). // 视频类型
-		Where("cast_work.origin_uuid = ''").
 		// Where("cwe.cost_type = 1"). // 套餐类型
 		Where("deleted_at = 0").
 		Count(&newUploadedBundleVideoCount)
@@ -674,7 +665,6 @@ func MetricsOperatingCreate(req *bundle.MetricsOperatingCreateReq) (result *bund
 		// Joins("left join cast_work_extra cwe on cwe.work_uuid = cast_work.uuid").
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("work_category = 2"). // 视频类型
-		Where("cast_work.origin_uuid = ''").
 		// Where("cwe.cost_type = 1"). // 套餐类型
 		Where("deleted_at = 0").
 		Count(&totalUploadedVideoCount)
@@ -686,7 +676,6 @@ func MetricsOperatingCreate(req *bundle.MetricsOperatingCreateReq) (result *bund
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("work_category = 2"). // 视频类型
 		Where("cwe.cost_type = 1"). // 套餐类型
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0 and cwe.deleted_at = 0").
 		Count(&totalUploadedBundleVideoCount)
 
@@ -696,7 +685,6 @@ func MetricsOperatingCreate(req *bundle.MetricsOperatingCreateReq) (result *bund
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("work_category = 2").               // 视频类型
 		Where("cwe.cost_type in ?", []int{2, 3}). // 增值类型或扩展类型
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0 and cwe.deleted_at = 0").
 		Count(&totalUploadedIncreaseVideoCount)
 
@@ -723,7 +711,6 @@ func MetricsOperatingCreate(req *bundle.MetricsOperatingCreateReq) (result *bund
 		Where("cast_work.submit_time >= ?", req.Start+" 00:00:00").
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("work_category = 1"). // 图文类型
-		Where("cast_work.origin_uuid = ''").
 		// Where("cwe.cost_type = 1"). // 套餐类型
 		Where("deleted_at = 0").
 		Count(&newUploadedBundleImageCount)
@@ -744,7 +731,6 @@ func MetricsOperatingCreate(req *bundle.MetricsOperatingCreateReq) (result *bund
 		// Joins("left join cast_work_extra cwe on cwe.work_uuid = cast_work.uuid").
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("work_category = 1"). // 图文类型
-		Where("cast_work.origin_uuid = ''").
 		// Where("cwe.cost_type = 2"). // 套餐类型
 		Where("deleted_at = 0").
 		Count(&totalUploadedImageCount)
@@ -756,7 +742,6 @@ func MetricsOperatingCreate(req *bundle.MetricsOperatingCreateReq) (result *bund
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("work_category = 1"). // 图文类型
 		Where("cwe.cost_type = 1"). // 套餐类型
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0 and cwe.deleted_at = 0").
 		Count(&totalUploadedBundleImageCount)
 
@@ -766,40 +751,43 @@ func MetricsOperatingCreate(req *bundle.MetricsOperatingCreateReq) (result *bund
 		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
 		Where("work_category = 1").               // 图文类型
 		Where("cwe.cost_type in ?", []int{2, 3}). // 增值类型
-		Where("cast_work.origin_uuid = ''").
 		Where("cast_work.deleted_at = 0 and cwe.deleted_at = 0").
 		Count(&totalUploadedIncreaseImageCount)
 
 	//====================数据分析=======================
 	var newUploadedBundleDataAnalysisCount int64
-	app.ModuleClients.BundleDB.Table("cast_work_analysis as cwa").
-		Where("cwa.submit_time >= ?", req.Start+" 00:00:00").
-		Where("cwa.submit_time <= ?", req.End+" 23:59:59").
-		Where("cwa.deleted_at = 0").
+	app.ModuleClients.BundleDB.Model(&model.CastWork{}).
+		Where("cast_work.submit_time >= ?", req.Start+" 00:00:00").
+		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
+		Where("work_category = 3"). // 数据分析类型
+		Where("deleted_at = 0").
 		Count(&newUploadedBundleDataAnalysisCount)
 	result.NewUploadedBundleDataAnalysisCount = newUploadedBundleDataAnalysisCount
 
 	var totalUploadedDataAnalysisCount int64
-	app.ModuleClients.BundleDB.Table("cast_work_analysis as cwa").
-		Where("cwa.submit_time <= ?", req.End+" 23:59:59").
-		Where("cwa.deleted_at = 0").
+	app.ModuleClients.BundleDB.Model(&model.CastWork{}).
+		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
+		Where("work_category = 3"). // 数据分析类型
+		Where("deleted_at = 0").
 		Count(&totalUploadedDataAnalysisCount)
 	result.TotalUploadedBundleDataAnalysisCount = totalUploadedDataAnalysisCount
 
 	var totalUploadedBundleDataAnalysisCount int64
-	app.ModuleClients.BundleDB.Table("cast_work_analysis as cwa").
-		Joins("left join cast_work_analysis_extra cwae on cwae.analysis_uuid = cwa.uuid AND cwae.deleted_at = 0").
-		Where("cwa.submit_time <= ?", req.End+" 23:59:59").
-		Where("cwae.cost_type = 1"). // 套餐类型
-		Where("cwa.deleted_at = 0 and cwae.deleted_at = 0").
+	app.ModuleClients.BundleDB.Model(&model.CastWork{}).
+		Joins("left join cast_work_extra cwe on cwe.work_uuid = cast_work.uuid").
+		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
+		Where("work_category = 3"). // 数据分析类型
+		Where("cwe.cost_type = 1"). // 套餐类型
+		Where("cast_work.deleted_at = 0 and cwe.deleted_at = 0").
 		Count(&totalUploadedBundleDataAnalysisCount)
 
 	var totalUploadedIncreaseDataAnalysisCount int64
-	app.ModuleClients.BundleDB.Table("cast_work_analysis as cwa").
-		Joins("left join cast_work_analysis_extra cwae on cwae.analysis_uuid = cwa.uuid AND cwae.deleted_at = 0").
-		Where("cwa.submit_time <= ?", req.End+" 23:59:59").
-		Where("cwae.cost_type in ?", []int{2, 3}). // 增值类型
-		Where("cwa.deleted_at = 0 and cwe.deleted_at = 0").
+	app.ModuleClients.BundleDB.Model(&model.CastWork{}).
+		Joins("left join cast_work_extra cwe on cwe.work_uuid = cast_work.uuid AND cwe.deleted_at = 0").
+		Where("cast_work.submit_time <= ?", req.End+" 23:59:59").
+		Where("work_category = 3").               // 数据分析类型
+		Where("cwe.cost_type in ?", []int{2, 3}). // 增值类型
+		Where("cast_work.deleted_at = 0 and cwe.deleted_at = 0").
 		Count(&totalUploadedIncreaseDataAnalysisCount)
 
 	endMonth := timeParse(req.End + " 23:59:59").Format("2006-01")
@@ -1160,7 +1148,7 @@ func MetricsOperatingStatus(req *bundle.MetricsOperatingStatusReq) (data *bundle
 	app.ModuleClients.BundleDB.Model(model.CastWork{}).
 		Joins("left join cast_work_log cwl on cwl.work_uuid = cast_work.uuid").
 		Joins("left join cast_cost_log ccl on ccl.work_uuid = cast_work.uuid").
-		Where("cast_work.status  = 9 and cwl.work_category = 2 and cwl.work_status = 9 and ccl.operator_name != '系统自动确定'").
+		Where("cast_work.status  = 9 and cwl.work_category = 2 and cwl.work_status = 9 and ccl.operator_name != '系统自动确定' and ccl.operator_id != ? ", "0").
 		Where("cast_work.submit_time <= ?", req.Date+" 23:59:59").
 		Where("cwl.deleted_at = 0 and ccl.deleted_at = 0 and cast_work.deleted_at = 0").
 		Count(&data.ArtistConfirmVideoCount)
@@ -1185,7 +1173,7 @@ func MetricsOperatingStatus(req *bundle.MetricsOperatingStatusReq) (data *bundle
 	app.ModuleClients.BundleDB.Model(model.CastWork{}).
 		Joins("left join cast_work_log cwl on cwl.work_uuid = cast_work.uuid").
 		Joins("left join cast_cost_log ccl on ccl.work_uuid = cast_work.uuid").
-		Where("cast_work.status  = 9 and cwl.work_category = 1 and cwl.work_status = 9 and ccl.operator_name != '系统自动确定'").
+		Where("cast_work.status  = 9 and cwl.work_category = 1 and cwl.work_status = 9 and ccl.operator_name != '系统自动确定' and ccl.operator_id != ?", "0").
 		Where("cast_work.submit_time <= ?", req.Date+" 23:59:59").
 		Where("cwl.deleted_at = 0 and ccl.deleted_at = 0 and cast_work.deleted_at = 0").
 		Count(&data.ArtistConfirmImageCount)
@@ -1196,33 +1184,7 @@ func MetricsOperatingStatus(req *bundle.MetricsOperatingStatusReq) (data *bundle
 		Where("cast_work.submit_time <= ?", req.Date+" 23:59:59").
 		Where("cwl.deleted_at = 0 and ccl.deleted_at = 0 and cast_work.deleted_at = 0").
 		Count(&data.AutoConfirmImageCount)
-	//======================数据分析======================
-	var analysisStatistic = func(status int8) (i int64) {
-		app.ModuleClients.BundleDB.Table("cast_work_analysis").Where("work_analysis_status = ?", status).Where("deleted_at = 0 and submit_time <= ?", req.Date+" 23:59:59").Count(&i)
-		return
-	}
-	data.ReviewingDataAnalysisCount = analysisStatistic(2)
-	data.RejectDataAnalysisCount = analysisStatistic(3)
-	data.WaitConfirmDataAnalysisCount = analysisStatistic(4)
-	data.PendingUploadDataAnalysisCount = analysisStatistic(6)
-	data.UploadSuccessDataAnalysisCount = analysisStatistic(7)
-	data.UploadFailedDataAnalysisCount = analysisStatistic(5)
-
-	app.ModuleClients.BundleDB.Table("cast_work_analysis").
-		Joins("left join cast_cost_analysis_log ccal on ccal.analysis_uuid = cast_work_analysis.uuid AND ccal.deleted_at = 0").
-		Where("cast_work_analysis.work_analysis_status in ?", []int{6, 7}).
-		Where("cast_work_analysis.deleted_at = 0").
-		Where("ccal.operator_name != '系统自动确定'").
-		Where("cast_work_analysis.submit_time <= ?", req.Date+" 23:59:59").
-		Count(&data.ArtistConfirmDataAnalysisCount)
-	app.ModuleClients.BundleDB.Table("cast_work_analysis").
-		Joins("left join cast_cost_analysis_log ccal on ccal.analysis_uuid = cast_work_analysis.uuid AND ccal.deleted_at = 0").
-		Where("cast_work_analysis.work_analysis_status in ?", []int{6, 7}).
-		Where("cast_work_analysis.deleted_at = 0").
-		Where("ccal.operator_name = '系统自动确定'").
-		Where("cast_work_analysis.submit_time <= ?", req.Date+" 23:59:59").
-		Count(&data.AutoConfirmDataAnalysisCount)
-
+	//======================数据分析暂时未做======================
 	return
 }
 
@@ -1317,38 +1279,22 @@ func MetricsArtistAccountExport(req *bundle.MetricsArtistAccountExportReq) (*bun
 	var start time.Time
 	var end time.Time
 	var err error
-
-	subQuery := app.ModuleClients.BundleDB.Table("cast_media_account").
-		Select("artist_uuid,any_value(artist_name) as artist_name,any_value(created_at) as created_at").
-		Group("artist_uuid").
-		Where("deleted_at = 0 and expired != 2")
-	//如果选择了月份
-	if len(req.Month) > 0 {
-		// 构建多个月份的时间范围条件（使用 OR 连接）
-		var conditions []string
-		var args []interface{}
-		for _, month := range req.Month {
-			t, err := time.Parse("2006-01", month)
+	if req.Month != "" {
+		t, err := time.Parse("2006-01", req.Month)
 		if err != nil {
 			return nil, err
 		}
 		start = datetime.BeginOfMonth(t)
 		end = datetime.EndOfMonth(t)
-			// 为每个月添加时间范围条件
-			conditions = append(conditions, "(created_at >= ? AND created_at <= ?)")
-			args = append(args, start.Unix(), end.Unix())
-		}
-		// 使用 OR 连接所有月份条件
-		if len(conditions) > 0 {
-			subQuery = subQuery.Where(strings.Join(conditions, " OR "), args...)
-		}
 	} else {
 		start = time.Date(1970, 1, 1, 0, 0, 0, 0, time.UTC)    // Unix 时间戳起始时间
 		end = time.Date(2099, 12, 31, 23, 59, 59, 0, time.UTC) // 设置一个很远的未来日期
-		subQuery = subQuery.Where("created_at >= ?", start.Unix()).
-			Where("created_at <= ?", end.Unix())
 	}
-
+	subQuery := app.ModuleClients.BundleDB.Table("cast_media_account").
+		Select("artist_uuid,any_value(artist_name) as artist_name,any_value(created_at) as created_at").
+		Group("artist_uuid").
+		Where("created_at >= ?", start.Unix()).Where("created_at <= ?", end.Unix()).
+		Where("deleted_at = 0")
 	query := app.ModuleClients.BundleDB.Table("( ? ) cma", subQuery).
 		Select(`tiktok.platform_user_id as tiktok_account,
 		tiktok.platform_user_name as tiktok_nickname, 
@@ -1359,27 +1305,20 @@ func MetricsArtistAccountExport(req *bundle.MetricsArtistAccountExportReq) (*bun
 		ins.platform_user_id as instagram_account, 
 		ins.platform_user_name as instagram_nickname,
 		ins_auth.auth_status as ins_auth_status,
-		youtube.platform_user_id as youtube_account,
-		youtube.platform_user_name as youtube_nickname,
-		youtube_auth.auth_status as youtube_auth_status,
-		bluesky.platform_user_id as bluesky_account,
-		bluesky.platform_user_name as bluesky_nickname,
-		bluesky_auth.auth_status as bluesky_auth_status,
 		cma.artist_name,
 		bor.customer_num as user_num
 		`).
-		Joins(`left join (SELECT * FROM cast_media_account where platform_id = 1 and deleted_at = 0 and expired != 2) tiktok on tiktok.artist_uuid = cma.artist_uuid`).
+		Joins(`left join (SELECT * FROM cast_media_account where platform_id = 1 and deleted_at = 0) tiktok on tiktok.artist_uuid = cma.artist_uuid`).
 		Joins(`left join (Select * from cast_media_auth where platform_id = 1 and deleted_at = 0) tiktok_auth on tiktok_auth.user_id = tiktok.user_id`).
-		Joins(`left join (SELECT * FROM cast_media_account where platform_id = 4 and deleted_at = 0 and expired != 2) dm on dm.artist_uuid = cma.artist_uuid`).
+		Joins(`left join (SELECT * FROM cast_media_account where platform_id = 4 and deleted_at = 0) dm on dm.artist_uuid = cma.artist_uuid`).
 		Joins(`left join (Select * from cast_media_auth where platform_id = 4 and deleted_at = 0) dm_auth on dm_auth.user_id = dm.user_id`).
-		Joins(`left join (SELECT * FROM cast_media_account where platform_id = 3 and deleted_at = 0 and expired != 2) ins on ins.artist_uuid = cma.artist_uuid`).
+		Joins(`left join (SELECT * FROM cast_media_account where platform_id = 3 and deleted_at = 0) ins on ins.artist_uuid = cma.artist_uuid`).
 		Joins(`left join (Select * from cast_media_auth where platform_id = 3 and deleted_at = 0) ins_auth on ins_auth.user_id = ins.user_id`).
-		Joins(`left join (Select * from cast_media_account where platform_id = 2 and deleted_at = 0 and expired != 2) youtube on youtube.artist_uuid = cma.artist_uuid`).
-		Joins(`left join (Select * from cast_media_auth where platform_id = 2 and deleted_at = 0) youtube_auth on youtube_auth.user_id = youtube.user_id`).
-		Joins(`left join (Select * from cast_media_account where platform_id = 5 and deleted_at = 0 and expired != 2) bluesky on bluesky.artist_uuid = cma.artist_uuid`).
-		Joins(`left join (Select * from cast_media_auth where platform_id = 5 and deleted_at = 0) bluesky_auth on bluesky_auth.user_id = bluesky.user_id`).
 		Joins(`left join bundle_order_records bor on bor.customer_id  COLLATE utf8mb4_general_ci= cma.artist_uuid  COLLATE utf8mb4_general_ci`).
 		Where("bor.deleted_at is null")
+	if req.Month != "" {
+		query = query.Where("cma.created_at >= ?", start.Unix()).Where("cma.created_at <= ?", end.Unix())
+	}
 	err = query.Find(&data.Data).Error
 	if err != nil {
 		return nil, err
@@ -1390,7 +1329,7 @@ func MetricsArtistAccountExport(req *bundle.MetricsArtistAccountExportReq) (*bun
 func MetricsVideoSubmitExport(req *bundle.MetricsVideoSubmitExportReq) (result *bundle.MetricsVideoSubmitExportResp, err error) {
 	result = &bundle.MetricsVideoSubmitExportResp{}
 	var query *gorm.DB
-	if len(req.Month) == 0 {
+	if req.Month == "" {
 		query = app.ModuleClients.BundleDB.Table("cast_work AS cw").
 			Select(`cw.artist_name ,
 	cw.title as video_title, 
@@ -1402,64 +1341,25 @@ func MetricsVideoSubmitExport(req *bundle.MetricsVideoSubmitExportReq) (result *
 			Joins("left join (select  created_at,work_uuid  from cast_work_platform_info cwi where cwi.platform_id = 4) dm on dm.work_uuid = cw.uuid").
 			Joins("left join (select  created_at,work_uuid  from cast_work_platform_info cwi where cwi.platform_id = 3) ins on ins.work_uuid = cw.uuid").
 			Joins("left join bundle_order_records bor on bor.customer_id COLLATE utf8mb4_general_ci = cw.artist_uuid COLLATE utf8mb4_general_ci").
-			Where("(tiktok.created_at is not null or dm.created_at is not null or ins.created_at is not null) and cw.deleted_at = 0 and bor.deleted_at is null and cw.origin_uuid = ''").
+			Where("(tiktok.created_at is not null or dm.created_at is not null or ins.created_at is not null) and cw.deleted_at = 0 and bor.deleted_at is null").
 			Order("cw.artist_name")
 	} else {
-		// 构建多个月份的时间范围参数
-		var timeRanges []struct {
-			Start int64
-			End   int64
-		}
 
-		for _, month := range req.Month {
-			t, err := time.Parse("2006-01", month)
+		t, err := time.Parse("2006-01", req.Month)
 		if err != nil {
 			return nil, err
 		}
 		start := datetime.BeginOfMonth(t)
 		end := datetime.EndOfMonth(t)
-			timeRanges = append(timeRanges, struct {
-				Start int64
-				End   int64
-			}{Start: start.Unix(), End: end.Unix()})
-		}
-		// 构建时间筛选 SQL 条件的辅助函数
-		buildTimeFilterSQL := func(tableAlias string) (string, []interface{}) {
-			if len(timeRanges) == 0 {
-				return "", nil
-			}
-			var conditions []string
-			var args []interface{}
-			for _, tr := range timeRanges {
-				// 明确指定表别名，避免字段歧义
-				conditions = append(conditions, fmt.Sprintf("(%s.created_at >= ? AND %s.created_at <= ?)", tableAlias, tableAlias))
-				args = append(args, tr.Start, tr.End)
-			}
-			return "(" + strings.Join(conditions, " OR ") + ")", args
-		}
 		query = app.ModuleClients.BundleDB.Table("cast_work AS cw").
-			Select(`cw.artist_name, cw.title AS video_title, tiktok.created_at AS tiktok_upload_time, dm.created_at AS dm_upload_time, ins.created_at AS instagram_upload_time, bor.customer_num AS user_num`)
-
-		// 为每个平台添加时间筛选条件
-		if len(timeRanges) > 0 {
-			// TikTok JOIN
-			tiktokTimeSQL, tiktokArgs := buildTimeFilterSQL("tiktok")
-			joinSQL := `LEFT JOIN cast_work_platform_info tiktok ON tiktok.work_uuid = cw.uuid AND tiktok.platform_id = 1 AND ` + tiktokTimeSQL
-			query = query.Joins(joinSQL, tiktokArgs...)
-
-			// DM JOIN
-			dmTimeSQL, dmArgs := buildTimeFilterSQL("dm")
-			joinSQL = `LEFT JOIN cast_work_platform_info dm ON dm.work_uuid = cw.uuid AND dm.platform_id = 4 AND ` + dmTimeSQL
-			query = query.Joins(joinSQL, dmArgs...)
-
-			// Instagram JOIN
-			insTimeSQL, insArgs := buildTimeFilterSQL("ins")
-			joinSQL = `LEFT JOIN cast_work_platform_info ins ON ins.work_uuid = cw.uuid AND ins.platform_id = 3 AND ` + insTimeSQL
-			query = query.Joins(joinSQL, insArgs...)
-		}
-		query = query.Joins(`LEFT JOIN bundle_order_records bor ON bor.customer_id COLLATE utf8mb4_general_ci = cw.artist_uuid COLLATE utf8mb4_general_ci AND bor.deleted_at IS NULL`).
+			Select(`cw.artist_name, cw.title AS video_title, tiktok.created_at AS tiktok_upload_time, dm.created_at AS dm_upload_time, ins.created_at AS instagram_upload_time, bor.customer_num AS user_num`).
+			Joins(`LEFT JOIN cast_work_platform_info tiktok ON tiktok.work_uuid = cw.uuid AND tiktok.platform_id = 1 AND tiktok.created_at >= ? AND tiktok.created_at <= ?`, start.Unix(), end.Unix()).
+			Joins(`LEFT JOIN cast_work_platform_info dm ON dm.work_uuid = cw.uuid AND dm.platform_id = 4 AND dm.created_at >= ? AND dm.created_at <= ?`, start.Unix(), end.Unix()).
+			Joins(`LEFT JOIN cast_work_platform_info ins ON ins.work_uuid = cw.uuid AND ins.platform_id = 3 AND ins.created_at >= ? AND ins.created_at <= ?`, start.Unix(), end.Unix()).
+			Joins(`LEFT JOIN bundle_order_records bor ON bor.customer_id COLLATE utf8mb4_general_ci = cw.artist_uuid COLLATE utf8mb4_general_ci AND bor.deleted_at IS NULL`).
 			Where(`cw.deleted_at = 0 AND (tiktok.created_at IS NOT NULL OR dm.created_at IS NOT NULL OR ins.created_at IS NOT NULL)`).
 			Order("cw.artist_name")
+
 	}
 	err = query.Find(&result.Data).Error
 	return

internal/dao/orderRecordsDao.go

@@ -4,7 +4,6 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"github.com/shopspring/decimal"
 	"micro-bundle/internal/model"
 	"micro-bundle/pb/bundle"
 	"micro-bundle/pkg/app"
@@ -128,26 +127,6 @@ func UpdateOrderRecordByOrderNO(orderRecord *model.BundleOrderRecords) (res *bun
 				}
 			}
 		}
-
-		tempRecord := new(model.BundleOrderRecords)
-		if err := app.ModuleClients.BundleDB.Where("deleted_at is null and order_no = ?", orderRecord.OrderNo).First(&tempRecord).Error; err != nil {
-			if errors.Is(err, gorm.ErrRecordNotFound) {
-				return nil, errors.New("订单记录不存在")
-			}
-			return nil, fmt.Errorf("查询订单失败: %v", err)
-		}
-		if orderRecord.Status == 2 && tempRecord.AmountType == 2 && tempRecord.TotalAmount > 0 {
-			// 当回调支付成功，币种是美元，且订单金额大于0，计算美元手续费：订单金额*0.019(四舍五入保留两位小数字)+0.1
-			amount := decimal.NewFromFloat32(tempRecord.TotalAmount)
-			rate, _ := decimal.NewFromString("0.019")
-			fee := amount.Mul(rate)
-			// 4. 四舍五入保留两位小数
-			feeRounded := fee.Round(2)
-			addition, _ := decimal.NewFromString("0.1")
-			result := feeRounded.Add(addition)
-			valueAdd.HandlingFee = result.String()
-		}
-
 	}
 
 	err = app.ModuleClients.BundleDB.Model(&model.BundleOrderValueAdd{}).
@@ -380,7 +359,6 @@ func OrderRecordDetail(req *bundle.OrderRecordsDetailRequest) (res *bundle.Order
 		ValueAddBundleAmount: orderRecord.ValueAddBundleAmount,
 		TotalAmount:          orderRecord.TotalAmount,
 		ExpirationTime:       orderRecord.ExpirationTime,
-		ReSignature:          int32(orderRecord.ReSignature),
 	}
 	res.AddInfos = make([]*bundle.AddInfo, 0)
 	res.AddInfos = addInfos
@@ -539,7 +517,6 @@ func OrderRecordsListV2(req *bundle.OrderRecordsRequestV2) (res *bundle.OrderRec
 			Amount:         record.Amount,
 			CustomerId:     customerID,
 			PayTime:        record.PayTime,
-			InviterId:      record.InviterID,
 		}
 
 		// 聚合子订单
@@ -829,19 +806,6 @@ func UpdateReconciliationStatusBySerialNumber(req *bundle.UpdateStatusAndPayTime
 		PayStatus:    int(req.PaymentStatus),
 		SerialNumber: req.SerialNumber,
 	}
-
-	if req.PaymentStatus == 2 && existing.CurrencyType == 2 && existing.PayAmount > 0 {
-		// 当回调支付成功，币种是美元，且订单金额大于0，计算美元手续费：订单金额*0.019(四舍五入保留两位小数字)+0.1
-		amount := decimal.NewFromFloat32(existing.PayAmount)
-		rate, _ := decimal.NewFromString("0.019")
-		fee := amount.Mul(rate)
-		// 4. 四舍五入保留两位小数
-		feeRounded := fee.Round(2)
-		addition, _ := decimal.NewFromString("0.1")
-		result := feeRounded.Add(addition)
-		updates.HandlingFee = result.String()
-	}
-
 	if err := app.ModuleClients.BundleDB.Model(&existing).Updates(updates).Error; err != nil {
 		return nil, fmt.Errorf("更新对账单失败: %v", err)
 	}
@@ -885,7 +849,6 @@ func ListUnfinishedInfos(req *bundle.AutoCreateUserAndOrderRequest) (res *bundle
 		unfinishedInfo.OrderPayCurrency = info.OrderPayCurrency
 		unfinishedInfo.OrderAccountCurrency = info.OrderAccountCurrency
 		unfinishedInfo.PayTime = info.PayTime.Format("2006-01-02 15:04:05")
-		unfinishedInfo.CardNum = info.CardNum
 		res.UnfinishedInfos = append(res.UnfinishedInfos, unfinishedInfo)
 	}
 
@@ -911,71 +874,3 @@ func SoftDeleteUnfinishedInfo(req *bundle.SoftDeleteUnfinishedInfoRequest) (res
 
 	return res, nil
 }
-func ReSignTheContract(req *bundle.ReSignTheContractRequest) (*bundle.CommonResponse, error) {
-	res := new(bundle.CommonResponse)
-
-	// 验证请求参数
-	if req.OrderNo == "" {
-		return res, errors.New("订单号不能为空")
-	}
-
-	now := time.Now().Format("2006-01-02 15:04:05")
-
-	// 开启事务确保两个表的更新一致性
-	tx := app.ModuleClients.BundleDB.Begin()
-	defer func() {
-		if r := recover(); r != nil {
-			tx.Rollback()
-			//err = fmt.Errorf("事务执行失败: %v", r)
-		}
-	}()
-
-	// 1. 更新 BundleOrderRecords 表
-	recordsUpdate := map[string]interface{}{
-		"sign_contract": req.SignContract,
-		"signed_time":   now,
-		"contract_no":   req.ContractNo,
-		"re_signature":  2,
-	}
-
-	if err := tx.Model(&model.BundleOrderRecords{}).
-		Where("order_no = ?", req.OrderNo).
-		Updates(recordsUpdate).Error; err != nil {
-		tx.Rollback()
-		return res, fmt.Errorf("更新订单记录失败: %v", err)
-	}
-
-	// 2. 更新 BundleOrderValueAdd 表
-	valueAddUpdate := map[string]interface{}{
-		"sign_contract": req.SignContract,
-		"signed_time":   now,
-	}
-
-	if err := tx.Model(&model.BundleOrderValueAdd{}).
-		Where("order_no = ?", req.OrderNo).
-		Updates(valueAddUpdate).Error; err != nil {
-		tx.Rollback()
-		return res, fmt.Errorf("更新订单增值信息失败: %v", err)
-	}
-
-	// 3. 检查是否实际更新了记录
-	var affectedRecords, affectedValueAdd int64
-	tx.Model(&model.BundleOrderRecords{}).Where("order_no = ?", req.OrderNo).Count(&affectedRecords)
-	tx.Model(&model.BundleOrderValueAdd{}).Where("order_no = ?", req.OrderNo).Count(&affectedValueAdd)
-
-	if affectedRecords == 0 {
-		tx.Rollback()
-		return res, errors.New("未找到对应的订单记录")
-	}
-
-	// 提交事务
-	if err := tx.Commit().Error; err != nil {
-		return res, fmt.Errorf("事务提交失败: %v", err)
-	}
-
-	// 设置响应信息（如果有需要）
-	res.Msg = "重新签约成功"
-	res.OrderNo = req.OrderNo
-
-	return res, nil
-}

internal/dao/taskBalanceSync.go

@@ -334,8 +334,8 @@ inner join (
 		v.MonthlyIncreaseLimitImageNumber = v.MonthlyIncreaseLimitImageNumber - v.MonthlyIncreaseLimitImageConsumptionNumber + cal(v.IncreaseLimitImageNumber, v.MonthlyLimitImageQuotaNumber)
 		v.MonthlyBundleLimitExpiredDataAnalysisNumber = cal(v.BundleLimitDataAnalysisExpiredNumber, v.MonthlyLimitDataAnalysisQuotaNumber)
 		v.MonthlyIncreaseLimitExpiredDataAnalysisNumber = cal(v.IncreaseLimitDataAnalysisExpiredNumber, v.MonthlyLimitDataAnalysisQuotaNumber)
-		v.MonthlyBundleLimitDataAnalysisNumber = v.MonthlyBundleLimitDataAnalysisNumber - v.MonthlyBundleLimitDataAnalysisConsumptionNumber + cal(v.BundleLimitDataAnalysisNumber, v.MonthlyLimitDataAnalysisQuotaNumber)
-		v.MonthlyIncreaseLimitDataAnalysisNumber = v.MonthlyIncreaseLimitDataAnalysisNumber - v.MonthlyIncreaseLimitDataAnalysisConsumptionNumber + cal(v.IncreaseLimitDataAnalysisNumber, v.MonthlyLimitDataAnalysisQuotaNumber)
+		v.MonthlyBundleLimitDataAnalysisNumber = v.MonthlyBundleLimitDataAnalysisNumber - v.MonthlyBundleLimitDataAnalysisConsumptionNumber + cal(v.BundleLimitImageNumber, v.MonthlyLimitImageQuotaNumber)
+		v.MonthlyIncreaseLimitDataAnalysisNumber = v.MonthlyIncreaseLimitDataAnalysisNumber - v.MonthlyIncreaseLimitDataAnalysisConsumptionNumber + cal(v.IncreaseLimitImageNumber, v.MonthlyLimitImageQuotaNumber)
 		// 重置单月消耗数量
 		v.MonthlyBundleVideoConsumptionNumber = 0
 		v.MonthlyIncreaseVideoConsumptionNumber = 0

internal/dao/taskDao.go

@@ -3271,67 +3271,3 @@ func CreateMissingTaskManagementRecords(validArtist []ValidArtistInfo) error {
 
 	return nil
 }
-
-// CreateTaskWorkLogRequest 创建任务日志请求参数
-type CreateTaskWorkLogRequest struct {
-	AssignRecordsUUID string `json:"assignRecordsUUID"` // 任务指派记录UUID（必填）
-	WorkUUID          string `json:"workUUID"`          // 任务作品UUID（必填）
-	Title             string `json:"title"`             // 任务作品标题
-
-	ArtistUUID string `json:"artistUUID"` // 任务艺人UUID
-	SubNum     string `json:"subNum"`     // 任务用户编号（必填）
-	TelNum     string `json:"telNum"`     // 任务用户手机号（必填）
-	ArtistName string `json:"artistName"` // 任务艺人名称
-
-	// 操作信息
-	OperationType int    `json:"operationType"` // 任务操作类型 1:加任务 2:消耗任务 3:完成任务 4:任务过期（必填）
-	TaskType      int    `json:"taskType"`      // 任务类型 1:视频 2:图片 3:数据分析（必填）
-	TaskCount     int    `json:"taskCount"`     // 任务数量（必填）
-	Remark        string `json:"remark"`        // 任务备注
-
-	// 操作人信息
-	OperatorName string `json:"operatorName"` // 任务操作人姓名
-	OperatorNum  string `json:"operatorNum"`  // 任务操作人账号
-}
-
-// CreateTaskWorkLog 创建任务日志记录
-func CreateTaskWorkLog(req *CreateTaskWorkLogRequest) error {
-	// 参数校验
-	if req == nil {
-		return commonErr.ReturnError(nil, "参数错误", "请求参数不能为空")
-	}
-
-	// 生成日志UUID
-	workLogUUID := uuid.New().String()
-
-	// 获取当前时间戳（Unix时间戳，秒级）
-	now := int(time.Now().Unix())
-
-	// 构建日志记录
-	workLog := &model.TaskWorkLog{
-		WorkLogUUID:       workLogUUID,
-		AssignRecordsUUID: req.AssignRecordsUUID,
-		WorkUUID:          req.WorkUUID,
-		Title:             req.Title,
-		ArtistUUID:        req.ArtistUUID,
-		SubNum:            req.SubNum,
-		TelNum:            req.TelNum,
-		ArtistName:        req.ArtistName,
-		OperationType:     req.OperationType,
-		TaskType:          req.TaskType,
-		TaskCount:         req.TaskCount,
-		Remark:            req.Remark,
-		OperatorName:      req.OperatorName,
-		OperatorNum:       req.OperatorNum,
-		OperationTime:     now,
-		CreatedAt:         now,
-		UpdatedAt:         now,
-	}
-
-	// 插入数据库
-	if err := app.ModuleClients.TaskBenchDB.Create(workLog).Error; err != nil {
-		return commonErr.ReturnError(err, "创建任务日志失败", "创建任务日志失败: ")
-	}
-
-	return nil
-}

internal/logic/bundleExtendLogic.go

@@ -11,12 +11,9 @@ import (
 	"strconv"
 	"time"
 
-	"micro-bundle/pkg/msg"
-
 	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"github.com/jinzhu/copier"
 	"github.com/samber/lo"
-	"github.com/shopspring/decimal"
 )
 
 func BundleExtend(req *bundle.BundleExtendRequest) (*bundle.BundleExtendResponse, error) {
@@ -197,16 +194,9 @@ func GetBundleBalanceByUserId(req *bundle.GetBundleBalanceByUserIdReq) (*bundle.
 	if data.Activate != 2 {
 		return nil, errors.New("套餐未激活")
 	}
-	var IsExpired int32
-	if data.ExpiredAt.Before(time.Now()) {
-		IsExpired = msg.IsExpired //已过期
-	} else {
-		IsExpired = msg.NotExpired //未过期
-	}
 	result := &bundle.GetBundleBalanceByUserIdResp{
 		OrderUUID:                           data.OrderUUID,
 		BundleName:                          data.BundleName,
-		BundleStatus:                        IsExpired,
 		PayTime:                             data.StartAt.UnixMilli(),
 		ExpiredTime:                         data.ExpiredAt.UnixMilli(),
 		PaymentAmount:                       data.PaymentAmount,
@@ -283,7 +273,7 @@ func CreateBundleBalance(req *bundle.CreateBundleBalanceReq) (*bundle.CreateBund
 	data.ExpiredAt = time.Now()
 	userId, err := strconv.Atoi(addValues[0].CustomerID)
 	if err != nil {
-		return nil, errors.New("获取用户ID失败")
+		return nil, err
 	}
 	data.Month = time.Now().Format("2006-01")
 	data.UserId = userId
@@ -502,11 +492,11 @@ func BundleBalanceExport(req *bundle.BundleBalanceExportReq) (*bundle.BundleBala
 		PageSize:         99999,
 	})
 	if err != nil {
-		return nil, errors.New("余量列表数据失败")
+		return nil, err
 	}
 	prefixData, err := dao.BalanceExportPrefix()
 	if err != nil {
-		return nil, errors.New("获取前缀数据失败")
+		return nil, err
 	}
 
 	var prefixMap = map[int32]model.BundleExportDto{}
@@ -545,14 +535,6 @@ func BundleBalanceExport(req *bundle.BundleBalanceExportReq) (*bundle.BundleBala
 		} else {
 			item.IncreaseVideoUnitPrice = float32(math.Round(float64(item.IncreaseAmount/float32(v.IncreaseVideoNumber))*100) / 100)
 		}
-		bundleUnitPrice := decimal.NewFromFloat32(item.BundleVideoUnitPrice)
-		increaseUnitPrice := decimal.NewFromFloat32(item.IncreaseVideoUnitPrice)
-
-		bundlePriceTotal := bundleUnitPrice.Mul(decimal.NewFromInt32(v.MonthBundleVideoConsumptionNumber))
-		increasePriceTotal := increaseUnitPrice.Mul(decimal.NewFromInt32(v.MonthIncreaseVideoConsumptionNumber))
-
-		item.MonthlyBundleVideoConsumptionPrice = bundlePriceTotal.StringFixed(2)
-		item.MonthlyIncreaseVideoConsumptionPrice = increasePriceTotal.StringFixed(2)
 		items = append(items, item)
 	}
 	return &bundle.BundleBalanceExportResp{Total: int64(len(items)), Data: items}, nil

internal/logic/bundleLogic.go

@@ -73,7 +73,7 @@ func SaveBundle(req *bundle.BundleProfile) (res *bundle.SaveResponse, err error)
 		Content:     req.Content,
 		Price:       req.Price,
 		PriceType:   req.PriceType,
-		Contract:    "https://e-cdn.fontree.cn/fonchain-main/prod/file/contract/saas/template-25122501.pdf",
+		Contract:    "https://e-cdn.fontree.cn/fonchain-main/prod/file/saas/contract/template-25032801.pdf",
 		ImgOption:   int8(req.ImgOption),
 		BgImg1:      req.BgImg1,
 		BgImg2:      req.BgImg2,
@@ -698,13 +698,3 @@ func BundleListH5V2(req *bundle.BundleListRequest) (res *bundle.BundleListRespon
 	}
 	return res, nil
 }
-
-// 增加h5套餐列表
-func QueryTheOrderSnapshotInformation(req *bundle.QueryTheOrderSnapshotInformationReq) (res *bundle.QueryTheOrderSnapshotInformationResp, err error) {
-	res = new(bundle.QueryTheOrderSnapshotInformationResp)
-	res, err = dao.QueryTheOrderSnapshotInformation(req)
-	if err != nil {
-		return res, errors.New("获取套餐列表失败")
-	}
-	return res, nil
-}

internal/logic/orderRecordsLogic.go

@@ -68,8 +68,6 @@ func CreateOrderRecord(req *bundle.OrderCreateRecord) (res *bundle.CommonRespons
 		ExpirationTime:        req.ExpirationTime,
 		Language:              req.Language,
 		BundleOrderValueAdd:   addRecords,
-		PlatformIds:           req.PlatformIds,
-		InviterID:             req.InviterId,
 	}
 	res, err = dao.CreateOrderRecord(orderRecord)
 	return
@@ -184,8 +182,3 @@ func SoftDeleteUnfinishedInfo(req *bundle.SoftDeleteUnfinishedInfoRequest) (res
 	res, err = dao.SoftDeleteUnfinishedInfo(req)
 	return
 }
-func ReSignTheContract(req *bundle.ReSignTheContractRequest) (res *bundle.CommonResponse, err error) {
-	res = new(bundle.CommonResponse)
-	res, err = dao.ReSignTheContract(req)
-	return
-}

internal/logic/taskLogic.go

@@ -546,22 +546,3 @@ func AddHiddenTaskAssignee(taskAssignee string, taskAssigneeNum string) error {
 	}
 	return dao.AddHiddenTaskAssignee(taskAssignee, taskAssigneeNum)
 }
-
-// CreateTaskWorkLog 创建任务日志记录
-// 用于记录任务操作日志，包括加任务、消耗任务、完成任务、任务过期等操作
-func CreateTaskWorkLog(req *dao.CreateTaskWorkLogRequest) error {
-	// 参数校验已在 DAO 层完成，这里可以添加额外的业务逻辑校验
-	// 例如：校验操作类型是否合法、任务类型是否合法等
-	if req.OperationType < 1 || req.OperationType > 4 {
-		return commonErr.ReturnError(nil, "参数错误", "操作类型必须在1-4之间")
-	}
-	if req.TaskType < 1 || req.TaskType > 3 {
-		return commonErr.ReturnError(nil, "参数错误", "任务类型必须在1-3之间")
-	}
-	if req.TaskCount < 0 {
-		return commonErr.ReturnError(nil, "参数错误", "任务数量不能为负数")
-	}
-
-	// 调用 DAO 层创建日志
-	return dao.CreateTaskWorkLog(req)
-}

internal/model/bundle_order_records.go

@@ -1,9 +1,7 @@
 package model
 
 import (
-	"database/sql/driver"
 	"encoding/json"
-	"errors"
 
 	"gorm.io/gorm"
 )
@@ -43,9 +41,6 @@ type BundleOrderRecords struct {
 	BundleCommonJson      json.RawMessage       `json:"bundle_common_json" gorm:"column:bundle_common_json;type:json;serializer:json;comment:套餐信息"`
 	Language              string                `gorm:"column:language;comment:语言" json:"language"`
 	BundleOrderValueAdd   []BundleOrderValueAdd `gorm:"foreignKey:OrderUUID;references:UUID" json:"bundleOrderValueAdd"`
-	ReSignature           int                   `json:"reSignature" gorm:"column:re_signature;default:2;type:int;comment:是否重新签 1:是 2:否"`
-	PlatformIds           PlatformIDs           `gorm:"column:platform_ids;type:json;NOT NULL;comment:发布平台ID集合 TIKTOK= 1, YOUTUBE = 2, INS = 3 , DM = 4, BL = 5;" json:"platformIDs"`
-	InviterID             uint64                `gorm:"column:inviter_id;type:bigint;comment:邀请人ID" json:"inviterID"`
 }
 type BundleOrderValueAdd struct {
 	gorm.Model
@@ -77,30 +72,6 @@ type BundleOrderValueAdd struct {
 	QuotaValue         int32   `json:"quotaValue" gorm:"column:quota_value;type:int;comment:额度值"`
 	IsExpired          bool    `json:"isExpired" gorm:"column:is_expired;default:false;comment:是否过期作废 false:不作废 true:作废"`
 }
-type PlatformIDs []uint32
-
-// 实现 Scanner 接口
-func (p *PlatformIDs) Scan(value interface{}) error {
-	if value == nil {
-		*p = []uint32{}
-		return nil
-	}
-
-	bytes, ok := value.([]byte)
-	if !ok {
-		return errors.New("type assertion to []byte failed")
-	}
-
-	return json.Unmarshal(bytes, p)
-}
-
-// 实现 Valuer 接口
-func (p PlatformIDs) Value() (driver.Value, error) {
-	if len(p) == 0 {
-		return "[]", nil
-	}
-	return json.Marshal(p)
-}
 
 // 财务确认状态
 const (

internal/model/fiee_payment_auto.go

@@ -1,9 +1,8 @@
 package model
 
 import (
-	"time"
-
 	"gorm.io/gorm"
+	"time"
 )
 
 // 用来自动导入 来创建用户和订单的 数据
@@ -20,7 +19,6 @@ type FieePaymentAuto struct {
 	UserIdCardFrontUrl    string    `json:"userIdCardFrontUrl" gorm:"column:user_id_card_front_url;type:varchar(1024);comment:用户身份证正面"`
 	UserIdCardReverseUrl  string    `json:"userIdCardReverseUrl" gorm:"column:user_id_card_reverse_url;type:varchar(1024);comment:用户身份证反面"`
 	UserIdCardValidity    string    `json:"userIdCardValidity" gorm:"column:user_id_card_validity;type:varchar(64);comment:证件有效期"`
-	CardNum               string    `json:"cardNum" gorm:"column:card_num;type:varchar(64);comment:证件号码"`
 	OrderNo               string    `json:"orderNo" gorm:"column:order_no;type:varchar(128);comment:订单编号"`
 	OrderPayAmount        string    `gorm:"column:order_pay_amount;type:decimal(20,2);comment:订单支付金额" json:"orderPayAmount"`
 	OrderSettlementAmount string    `gorm:"column:order_settlement_amount;type:decimal(20,2);comment:订单结算金额" json:"orderSettlementAmount"`

internal/model/task.go

@@ -241,6 +241,41 @@ func (TaskSyncStatus) TableName() string { return "task_sync_status" }
 // InitialSyncKey 一次性同步的唯一标识键
 const InitialSyncKey = "bundle_to_task_balance_initial_sync"
 
+// 任务日志表
+type TaskLog struct {
+	LogUUID    string `gorm:"column:log_uuid;type:varchar(50);comment:任务日志UUID;not null" json:"taskLogUUID"`
+	SubNum     string `gorm:"column:sub_num;comment:任务用户编号;index:idx_task_log_sub_num;not null" json:"taskSubNum"`
+	TelNum     string `gorm:"column:tel_num;comment:任务用户手机号;index:idx_task_log_tel_num;not null" json:"taskTelNum"`
+	ArtistName string `gorm:"column:artist_name;comment:任务艺人名称;index:idx_task_log_artist_name" json:"taskArtistName"`
+
+	// ===== 操作信息 =====
+	OperationType int    `gorm:"column:operation_type;type:int(11);comment:任务操作类型 1:加任务 2:消耗任务 3:完成任务;4:任务过期;index:idx_task_operation_type;not null" json:"taskOperationType"`
+	TaskType      int    `gorm:"column:task_type;type:int(11);comment:任务类型 1:视频 2:图片 3:数据分析;index:idx_task_type;not null" json:"taskType"`
+	TaskCount     int    `gorm:"column:task_count;type:int(11);comment:任务数量;not null" json:"taskCount"`
+	Remark        string `gorm:"column:remark;type:varchar(500);comment:任务备注" json:"taskRemark"`
+
+	// ===== 操作人信息 =====
+	OperatorName  string `gorm:"column:operator_name;comment:任务操作人姓名;index:idx_task_operator_name" json:"taskOperatorName"`
+	OperatorNum   string `gorm:"column:operator_num;comment:任务操作人账号;index:idx_task_operator_num" json:"taskOperatorNum"`
+	CompletorName string `gorm:"column:completor_name;comment:任务完成人姓名;index:idx_task_completor_name" json:"taskCompletorName"`
+	CompletorNum  string `gorm:"column:completor_num;comment:任务完成人账号;index:idx_task_completor_num" json:"taskCompletorNum"`
+
+	// ===== 关联ID字段 =====
+	VideoPublishUUID string `gorm:"column:video_publish_id;type:varchar(50);comment:任务关联的发布视频UUID;index:idx_task_video_publish_id" json:"taskVideoPublishID"`
+	PostPublishUUID  string `gorm:"column:post_publish_id;type:varchar(50);comment:任务关联的图文发布UUID;index:idx_task_post_publish_id" json:"taskPostPublishID"`
+	DataAnalysisUUID string `gorm:"column:data_analysis_id;type:varchar(50);comment:任务关联的数据分析UUID;index:idx_task_data_analysis_id" json:"taskDataAnalysisID"`
+
+	// ===== 时间字段 =====
+	OperationTime int                   `gorm:"column:operation_time;type:int(11);comment:任务操作时间;index:idx_task_operation_time;not null" json:"taskOperationTime"`
+	CreatedAt     int                   `gorm:"column:created_at;type:int(11);comment:任务日志创建时间" json:"taskCreatedAt"`
+	UpdatedAt     int                   `gorm:"column:updated_at;type:int(11);comment:任务日志更新时间" json:"taskUpdatedAt"`
+	DeletedAt     soft_delete.DeletedAt `gorm:"column:deleted_at;type:int(11);index:idx_task_log_deleted_at" json:"taskDeletedAt"`
+}
+
+func (t *TaskLog) TableName() string {
+	return "task_log"
+}
+
 // 隐藏指派人表
 type TaskAssigneeHidden struct {
 	// 让id自增
@@ -256,36 +291,3 @@ type TaskAssigneeHidden struct {
 func (TaskAssigneeHidden) TableName() string {
 	return "task_assignee_hidden"
 }
-
-// 任务日志表
-type TaskWorkLog struct {
-	WorkLogUUID       string `gorm:"column:work_log_uuid;type:varchar(50);comment:任务作品日志UUID;primarykey;not null" json:"taskWorkLogUUID"`
-	AssignRecordsUUID string `gorm:"column:assign_records_uuid;type:varchar(50);comment:任务指派记录UUID;index:idx_assign_records_uuid;not null" json:"assignRecordsUUID"`
-	WorkUUID          string `gorm:"column:work_uuid;type:varchar(50);comment:任务作品UUID;index:idx_work_uuid;not null" json:"workUUID"`
-	Title             string `gorm:"column:title;type:varchar(50);comment:任务作品标题;not null" default:"" json:"title"`
-
-	ArtistUUID string `gorm:"column:artist_uuid;type:varchar(50);comment:任务艺人UUID;index:idx_artist_uuid;not null" default:"" json:"artistUUID"`
-	SubNum     string `gorm:"column:sub_num;comment:任务用户编号;index:idx_sub_num;not null" default:"" json:"subNum"`
-	TelNum     string `gorm:"column:tel_num;comment:任务用户手机号;index:idx_tel_num;not null" default:"" json:"telNum"`
-	ArtistName string `gorm:"column:artist_name;comment:任务艺人名称;index:idx_artist_name" default:"" json:"artistName"`
-
-	// ===== 操作信息 =====
-	OperationType int    `gorm:"column:operation_type;type:int(11);comment:任务操作类型 1:加任务 2:消耗任务 3:完成任务;4:任务过期;index:idx_operation_type;not null" default:"0" json:"operationType"`
-	TaskType      int    `gorm:"column:task_type;type:int(11);comment:任务类型 1:视频 2:图片 3:数据分析;index:idx_task_type;not null" default:"0" json:"taskType"`
-	TaskCount     int    `gorm:"column:task_count;type:int(11);comment:任务数量;not null" default:"0" json:"taskCount"`
-	Remark        string `gorm:"column:remark;type:varchar(500);comment:任务备注" default:"" json:"remark"`
-
-	// ===== 操作人信息 =====
-	OperatorName string `gorm:"column:operator_name;comment:任务操作人姓名;index:idx_operator_name" json:"taskOperatorName"`
-	OperatorNum  string `gorm:"column:operator_num;comment:任务操作人账号;index:idx_operator_num" json:"taskOperatorNum"`
-
-	// ===== 时间字段 =====
-	OperationTime int                   `gorm:"column:operation_time;type:int(11);comment:任务操作时间;index:idx_operation_time;not null" json:"taskOperationTime"`
-	CreatedAt     int                   `gorm:"column:created_at;type:int(11);comment:任务日志创建时间" json:"taskCreatedAt"`
-	UpdatedAt     int                   `gorm:"column:updated_at;type:int(11);comment:任务日志更新时间" json:"taskUpdatedAt"`
-	DeletedAt     soft_delete.DeletedAt `gorm:"column:deleted_at;type:int(11);index:idx_work_log_deleted_at" json:"taskDeletedAt"`
-}
-
-func (t *TaskWorkLog) TableName() string {
-	return "task_work_log"
-}

pb/bundle.proto

@@ -37,7 +37,6 @@ service Bundle {
   rpc  OrderRecordsListV2(OrderRecordsRequestV2) returns (OrderRecordsResponseV2) {}
   rpc  OrderListByOrderNo(OrderInfoByOrderNoRequest) returns (OrderInfoByOrderNoResp) {}
   rpc  OnlyAddValueListByOrderNo(OnlyAddValueListByOrderNoRequest) returns (OnlyAddValueListByOrderNoResp) {} // 根据orderNo只查增值服务
-  rpc  ReSignTheContract(ReSignTheContractRequest) returns (CommonResponse) {}
 
   //增值套餐 
   rpc CreateValueAddBundle(CreateValueAddBundleRequest) returns (CreateValueAddBundleResponse) {}
@@ -106,7 +105,6 @@ service Bundle {
   rpc GetPendingAssign(PendingAssignRequest) returns (PendingAssignResponse) {} // 查询艺人可指派数量
   rpc RevertTaskCompletionByUUIDItem(RevertTaskCompletionByUUIDItemRequest) returns (ComResponse) {}
   rpc AddHiddenTaskAssignee(AddHiddenTaskAssigneeRequest) returns (ComResponse) {}
-  rpc CreateTaskWorkLog(CreateTaskWorkLogRequest) returns (CommonResponse) {} // 创建任务日志记录
 
   //数据指标
   rpc MetricsBusiness(MetricsBusinessReq) returns (MetricsBusinessResp) {}
@@ -115,25 +113,7 @@ service Bundle {
   rpc MetricsBundlePurchaseExport(MetricsBundlePurchaseExportReq) returns (MetricsBundlePurchaseExportResp) {}
   rpc MetricsArtistAccountExport(MetricsArtistAccountExportReq) returns (MetricsArtistAccountExportResp) {}
   rpc MetricsVideoSubmitExport(MetricsVideoSubmitExportReq) returns (MetricsVideoSubmitExportResp) {}
-  rpc QueryTheOrderSnapshotInformation(QueryTheOrderSnapshotInformationReq) returns (QueryTheOrderSnapshotInformationResp) {}
-}
-message QueryTheOrderSnapshotInformationReq{
-  string orderNo = 1;
-}
-message QueryTheOrderSnapshotInformationResp{
-  repeated ServiceInformation bundleOrder = 1;
-  repeated ServiceInformation addBundleOrder = 2;
-  string bundleContent = 3;
-}
-message ServiceInformation{
-  uint64 serviceType = 1;
-  uint64 num = 2;
-  string unit = 3;
-}
-message ReSignTheContractRequest{
-  string orderNo = 1;
-  string contractNo = 2;
-  string signContract = 3;
+
 }
 message DeleteValueAddServiceRequest{
   string orderNo = 1;
@@ -217,8 +197,6 @@ message OrderCreateRecord{
   int32 payType = 19 [json_name = "payType"];
   repeated OrderCreateAddRecord addRecords = 20 [json_name = "addRecords"]; //增值服务
   string orderNo = 21 [json_name = "orderNo"];
-  repeated uint32 platformIds = 22;    // 发布平台ID集合 (json 格式字符串)
-  uint64 inviterId = 23;                 // 邀请人ID
 }
 message OrderCreateAddRecord{
   int32 serviceType = 1 [json_name = "serviceType"];
@@ -271,9 +249,6 @@ message OrderBundleRecordInfo{
   int64 customerId = 9;
   string payTime = 10;
   string subNum = 11;
-  uint64 inviterId = 12;
-  string inviterCode = 13;
-  string inviterName = 14;
 }
 message OrderAddBundleRecordInfo{
   string orderAddNo = 1;
@@ -454,7 +429,6 @@ message OrderRecord {
   string expirationTime = 37 [json_name = "expirationTime"];
   string snapshot = 38 [json_name = "snapshot"];
   repeated AddInfo addInfos = 39 [json_name = "addInfos"];
-  int32 reSignature = 40 [json_name = "reSignature"];
 }
 message AddInfo{
   string orderNo = 1 [json_name = "orderNo"];
@@ -731,7 +705,7 @@ message GetBundleBalanceListReq{
   int64 expiredTimeEnd = 8;
   int32 page = 9;
   int32 pageSize = 10;
-  repeated string month = 11;
+  string month = 11;
   int32 statusType = 12;
 }
 
@@ -915,15 +889,11 @@ message BundleBalanceExportItem {
   int32 monthlyManualVideoConsumptionNumber = 65; // 当月手动扩展视频使用数
   int32 monthlyManualImageConsumptionNumber = 66; // 当月手动扩展图文使用数
   int32 monthlyManualDataAnalysisConsumptionNumber = 67; // 当月手动扩展数据分析使用数
-
-  //视频当月消耗金额
-  string monthlyBundleVideoConsumptionPrice = 68;//当月套餐消耗总金额
-  string monthlyIncreaseVideoConsumptionPrice = 69;//当月增值消耗总金额
 }
 
 
 message BundleBalanceExportReq{
-  repeated string month = 1;
+  string month = 1;
   string userName = 2;
   uint64 expiredTimeStart = 3;
   uint64 expiredTimeEnd = 4;
@@ -1076,7 +1046,7 @@ message GetBundleBalanceByUserIdResp{
   string orderUUID = 1;
   string bundleUuid = 2;     // 套餐ID uuid
   string bundleName = 3;     // 套餐名称
-  int32 bundleStatus = 4;     // 套餐状态是否过期 1 是 0 否
+  string bundleStatus = 4;     // 套餐名称
   int64 payTime = 5;
   int64 expiredTime = 6;
   string paymentAmount = 7;
@@ -1175,7 +1145,6 @@ message UnfinishedInfo {
   string orderPayCurrency = 17;
   string orderAccountCurrency = 18;
   string payTime = 19;
-  string cardNum = 20;
 }
 
 message SoftDeleteUnfinishedInfoRequest {
@@ -1588,23 +1557,6 @@ message GetPendingTaskLayoutResp{ string data = 1; }
 message SetPendingTaskLayoutReq{ string data = 1; }
 message SetPendingTaskLayoutResp{}
 
-// 创建任务日志请求
-message CreateTaskWorkLogRequest {
-  string assignRecordsUUID = 1 [json_name = "assignRecordsUUID"]; // 任务指派记录UUID（必填）
-  string workUUID = 2 [json_name = "workUUID"];                    // 任务作品UUID（必填）
-  string title = 3 [json_name = "title"];                          // 任务作品标题
-  string artistUUID = 4 [json_name = "artistUUID"];                // 任务艺人UUID
-  string subNum = 5 [json_name = "subNum"];                        // 任务用户编号（必填）
-  string telNum = 6 [json_name = "telNum"];                        // 任务用户手机号（必填）
-  string artistName = 7 [json_name = "artistName"];                // 任务艺人名称
-  int32 operationType = 8 [json_name = "operationType"];           // 任务操作类型 1:加任务 2:消耗任务 3:完成任务 4:任务过期（必填）
-  int32 taskType = 9 [json_name = "taskType"];                     // 任务类型 1:视频 2:图片 3:数据分析（必填）
-  int32 taskCount = 10 [json_name = "taskCount"];                  // 任务数量（必填）
-  string remark = 11 [json_name = "remark"];                       // 任务备注
-  string operatorName = 12 [json_name = "operatorName"];           // 任务操作人姓名
-  string operatorNum = 13 [json_name = "operatorNum"];             // 任务操作人账号
-}
-
 message MetricsBusinessReq{
   string bundleUuid = 1;
   string start = 2;
@@ -1739,9 +1691,8 @@ message MetricsOperatingStatusResp {
   int64 autoConfirmDataAnalysisCount = 23;// 系统已自动确认数据数
   int64 pendingUploadDataAnalysisCount = 24;// 待发布数据数
   int64 uploadSuccessDataAnalysisCount = 25;// 发布成功数据数
-  int64 uploadFailedDataAnalysisCount = 26;// 发布异常数据数
 
-  int64 abnormalAccountAcount = 27;       // 触发预警的账号数
+  int64 abnormalAccountAcount = 26;       // 触发预警的账号数
 }
 
 message MetricsBundlePurchaseExportReq{
@@ -1770,7 +1721,7 @@ message MetricsBundlePurchaseItem{
 }
 
 message MetricsArtistAccountExportReq{
-  repeated string month = 1;
+  string month = 1;
 }
 
 message MetricsArtistAccountExportResp{
@@ -1783,24 +1734,20 @@ message MetricsArtistAccountExportItem{
   string dmAccount = 3;
   string dmNickname = 4;
   int32 dmAuthStatus = 5;
+  // string youtubeAccount = 3;  现在没有YouTube了
+  // string youtubeNickname = 4;
   string instagramAccount = 6;
   string instagramNickname = 7;
   int32 insAuthStatus = 8;
   string tiktokAccount = 9;
   string tiktokNickname = 10;
   int32 tiktokAuthStatus = 11;
-  string youtubeAccount = 12;
-  string youtubeNickname = 13;
-  int32 youtubeAuthStatus = 14;
-  string blueskyAccount = 15;
-  string blueskyNickname = 16;
-  int32 blueskyAuthStatus = 17;
 }
 
 
 
 message MetricsVideoSubmitExportReq{
-  repeated string month = 1;
+  string month = 1;
 }
 
 message MetricsVideoSubmitExportResp{

pb/bundle/bundle.validator.pb.go

@@ -17,32 +17,6 @@ var _ = proto.Marshal
 var _ = fmt.Errorf
 var _ = math.Inf
 
-func (this *QueryTheOrderSnapshotInformationReq) Validate() error {
-	return nil
-}
-func (this *QueryTheOrderSnapshotInformationResp) Validate() error {
-	for _, item := range this.BundleOrder {
-		if item != nil {
-			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
-				return github_com_mwitkow_go_proto_validators.FieldError("BundleOrder", err)
-			}
-		}
-	}
-	for _, item := range this.AddBundleOrder {
-		if item != nil {
-			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
-				return github_com_mwitkow_go_proto_validators.FieldError("AddBundleOrder", err)
-			}
-		}
-	}
-	return nil
-}
-func (this *ServiceInformation) Validate() error {
-	return nil
-}
-func (this *ReSignTheContractRequest) Validate() error {
-	return nil
-}
 func (this *DeleteValueAddServiceRequest) Validate() error {
 	return nil
 }
@@ -740,9 +714,6 @@ func (this *SetPendingTaskLayoutReq) Validate() error {
 func (this *SetPendingTaskLayoutResp) Validate() error {
 	return nil
 }
-func (this *CreateTaskWorkLogRequest) Validate() error {
-	return nil
-}
 func (this *MetricsBusinessReq) Validate() error {
 	return nil
 }

pb/bundle/bundle_triple.pb.go

@@ -50,7 +50,6 @@ type BundleClient interface {
 	OrderRecordsListV2(ctx context.Context, in *OrderRecordsRequestV2, opts ...grpc_go.CallOption) (*OrderRecordsResponseV2, common.ErrorWithAttachment)
 	OrderListByOrderNo(ctx context.Context, in *OrderInfoByOrderNoRequest, opts ...grpc_go.CallOption) (*OrderInfoByOrderNoResp, common.ErrorWithAttachment)
 	OnlyAddValueListByOrderNo(ctx context.Context, in *OnlyAddValueListByOrderNoRequest, opts ...grpc_go.CallOption) (*OnlyAddValueListByOrderNoResp, common.ErrorWithAttachment)
-	ReSignTheContract(ctx context.Context, in *ReSignTheContractRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
 	// 增值套餐
 	CreateValueAddBundle(ctx context.Context, in *CreateValueAddBundleRequest, opts ...grpc_go.CallOption) (*CreateValueAddBundleResponse, common.ErrorWithAttachment)
 	ValueAddBundleList(ctx context.Context, in *ValueAddBundleListRequest, opts ...grpc_go.CallOption) (*ValueAddBundleListResponse, common.ErrorWithAttachment)
@@ -110,7 +109,6 @@ type BundleClient interface {
 	GetPendingAssign(ctx context.Context, in *PendingAssignRequest, opts ...grpc_go.CallOption) (*PendingAssignResponse, common.ErrorWithAttachment)
 	RevertTaskCompletionByUUIDItem(ctx context.Context, in *RevertTaskCompletionByUUIDItemRequest, opts ...grpc_go.CallOption) (*ComResponse, common.ErrorWithAttachment)
 	AddHiddenTaskAssignee(ctx context.Context, in *AddHiddenTaskAssigneeRequest, opts ...grpc_go.CallOption) (*ComResponse, common.ErrorWithAttachment)
-	CreateTaskWorkLog(ctx context.Context, in *CreateTaskWorkLogRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
 	// 数据指标
 	MetricsBusiness(ctx context.Context, in *MetricsBusinessReq, opts ...grpc_go.CallOption) (*MetricsBusinessResp, common.ErrorWithAttachment)
 	MetricsOperatingCreate(ctx context.Context, in *MetricsOperatingCreateReq, opts ...grpc_go.CallOption) (*MetricsOperatingCreateResp, common.ErrorWithAttachment)
@@ -118,7 +116,6 @@ type BundleClient interface {
 	MetricsBundlePurchaseExport(ctx context.Context, in *MetricsBundlePurchaseExportReq, opts ...grpc_go.CallOption) (*MetricsBundlePurchaseExportResp, common.ErrorWithAttachment)
 	MetricsArtistAccountExport(ctx context.Context, in *MetricsArtistAccountExportReq, opts ...grpc_go.CallOption) (*MetricsArtistAccountExportResp, common.ErrorWithAttachment)
 	MetricsVideoSubmitExport(ctx context.Context, in *MetricsVideoSubmitExportReq, opts ...grpc_go.CallOption) (*MetricsVideoSubmitExportResp, common.ErrorWithAttachment)
-	QueryTheOrderSnapshotInformation(ctx context.Context, in *QueryTheOrderSnapshotInformationReq, opts ...grpc_go.CallOption) (*QueryTheOrderSnapshotInformationResp, common.ErrorWithAttachment)
 }
 
 type bundleClient struct {
@@ -148,7 +145,6 @@ type BundleClientImpl struct {
 	OrderRecordsListV2                       func(ctx context.Context, in *OrderRecordsRequestV2) (*OrderRecordsResponseV2, error)
 	OrderListByOrderNo                       func(ctx context.Context, in *OrderInfoByOrderNoRequest) (*OrderInfoByOrderNoResp, error)
 	OnlyAddValueListByOrderNo                func(ctx context.Context, in *OnlyAddValueListByOrderNoRequest) (*OnlyAddValueListByOrderNoResp, error)
-	ReSignTheContract                        func(ctx context.Context, in *ReSignTheContractRequest) (*CommonResponse, error)
 	CreateValueAddBundle                     func(ctx context.Context, in *CreateValueAddBundleRequest) (*CreateValueAddBundleResponse, error)
 	ValueAddBundleList                       func(ctx context.Context, in *ValueAddBundleListRequest) (*ValueAddBundleListResponse, error)
 	ValueAddBundleDetail                     func(ctx context.Context, in *ValueAddBundleDetailRequest) (*ValueAddBundleDetailResponse, error)
@@ -201,14 +197,12 @@ type BundleClientImpl struct {
 	GetPendingAssign                         func(ctx context.Context, in *PendingAssignRequest) (*PendingAssignResponse, error)
 	RevertTaskCompletionByUUIDItem           func(ctx context.Context, in *RevertTaskCompletionByUUIDItemRequest) (*ComResponse, error)
 	AddHiddenTaskAssignee                    func(ctx context.Context, in *AddHiddenTaskAssigneeRequest) (*ComResponse, error)
-	CreateTaskWorkLog                        func(ctx context.Context, in *CreateTaskWorkLogRequest) (*CommonResponse, error)
 	MetricsBusiness                          func(ctx context.Context, in *MetricsBusinessReq) (*MetricsBusinessResp, error)
 	MetricsOperatingCreate                   func(ctx context.Context, in *MetricsOperatingCreateReq) (*MetricsOperatingCreateResp, error)
 	MetricsOperatingStatus                   func(ctx context.Context, in *MetricsOperatingStatusReq) (*MetricsOperatingStatusResp, error)
 	MetricsBundlePurchaseExport              func(ctx context.Context, in *MetricsBundlePurchaseExportReq) (*MetricsBundlePurchaseExportResp, error)
 	MetricsArtistAccountExport               func(ctx context.Context, in *MetricsArtistAccountExportReq) (*MetricsArtistAccountExportResp, error)
 	MetricsVideoSubmitExport                 func(ctx context.Context, in *MetricsVideoSubmitExportReq) (*MetricsVideoSubmitExportResp, error)
-	QueryTheOrderSnapshotInformation         func(ctx context.Context, in *QueryTheOrderSnapshotInformationReq) (*QueryTheOrderSnapshotInformationResp, error)
 }
 
 func (c *BundleClientImpl) GetDubboStub(cc *triple.TripleConn) BundleClient {
@@ -355,12 +349,6 @@ func (c *bundleClient) OnlyAddValueListByOrderNo(ctx context.Context, in *OnlyAd
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/OnlyAddValueListByOrderNo", in, out)
 }
 
-func (c *bundleClient) ReSignTheContract(ctx context.Context, in *ReSignTheContractRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
-	out := new(CommonResponse)
-	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
-	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ReSignTheContract", in, out)
-}
-
 func (c *bundleClient) CreateValueAddBundle(ctx context.Context, in *CreateValueAddBundleRequest, opts ...grpc_go.CallOption) (*CreateValueAddBundleResponse, common.ErrorWithAttachment) {
 	out := new(CreateValueAddBundleResponse)
 	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@@ -673,12 +661,6 @@ func (c *bundleClient) AddHiddenTaskAssignee(ctx context.Context, in *AddHiddenT
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/AddHiddenTaskAssignee", in, out)
 }
 
-func (c *bundleClient) CreateTaskWorkLog(ctx context.Context, in *CreateTaskWorkLogRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
-	out := new(CommonResponse)
-	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
-	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateTaskWorkLog", in, out)
-}
-
 func (c *bundleClient) MetricsBusiness(ctx context.Context, in *MetricsBusinessReq, opts ...grpc_go.CallOption) (*MetricsBusinessResp, common.ErrorWithAttachment) {
 	out := new(MetricsBusinessResp)
 	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@@ -715,12 +697,6 @@ func (c *bundleClient) MetricsVideoSubmitExport(ctx context.Context, in *Metrics
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/MetricsVideoSubmitExport", in, out)
 }
 
-func (c *bundleClient) QueryTheOrderSnapshotInformation(ctx context.Context, in *QueryTheOrderSnapshotInformationReq, opts ...grpc_go.CallOption) (*QueryTheOrderSnapshotInformationResp, common.ErrorWithAttachment) {
-	out := new(QueryTheOrderSnapshotInformationResp)
-	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
-	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/QueryTheOrderSnapshotInformation", in, out)
-}
-
 // BundleServer is the server API for Bundle service.
 // All implementations must embed UnimplementedBundleServer
 // for forward compatibility
@@ -747,7 +723,6 @@ type BundleServer interface {
 	OrderRecordsListV2(context.Context, *OrderRecordsRequestV2) (*OrderRecordsResponseV2, error)
 	OrderListByOrderNo(context.Context, *OrderInfoByOrderNoRequest) (*OrderInfoByOrderNoResp, error)
 	OnlyAddValueListByOrderNo(context.Context, *OnlyAddValueListByOrderNoRequest) (*OnlyAddValueListByOrderNoResp, error)
-	ReSignTheContract(context.Context, *ReSignTheContractRequest) (*CommonResponse, error)
 	// 增值套餐
 	CreateValueAddBundle(context.Context, *CreateValueAddBundleRequest) (*CreateValueAddBundleResponse, error)
 	ValueAddBundleList(context.Context, *ValueAddBundleListRequest) (*ValueAddBundleListResponse, error)
@@ -807,7 +782,6 @@ type BundleServer interface {
 	GetPendingAssign(context.Context, *PendingAssignRequest) (*PendingAssignResponse, error)
 	RevertTaskCompletionByUUIDItem(context.Context, *RevertTaskCompletionByUUIDItemRequest) (*ComResponse, error)
 	AddHiddenTaskAssignee(context.Context, *AddHiddenTaskAssigneeRequest) (*ComResponse, error)
-	CreateTaskWorkLog(context.Context, *CreateTaskWorkLogRequest) (*CommonResponse, error)
 	// 数据指标
 	MetricsBusiness(context.Context, *MetricsBusinessReq) (*MetricsBusinessResp, error)
 	MetricsOperatingCreate(context.Context, *MetricsOperatingCreateReq) (*MetricsOperatingCreateResp, error)
@@ -815,7 +789,6 @@ type BundleServer interface {
 	MetricsBundlePurchaseExport(context.Context, *MetricsBundlePurchaseExportReq) (*MetricsBundlePurchaseExportResp, error)
 	MetricsArtistAccountExport(context.Context, *MetricsArtistAccountExportReq) (*MetricsArtistAccountExportResp, error)
 	MetricsVideoSubmitExport(context.Context, *MetricsVideoSubmitExportReq) (*MetricsVideoSubmitExportResp, error)
-	QueryTheOrderSnapshotInformation(context.Context, *QueryTheOrderSnapshotInformationReq) (*QueryTheOrderSnapshotInformationResp, error)
 	mustEmbedUnimplementedBundleServer()
 }
 
@@ -890,9 +863,6 @@ func (UnimplementedBundleServer) OrderListByOrderNo(context.Context, *OrderInfoB
 func (UnimplementedBundleServer) OnlyAddValueListByOrderNo(context.Context, *OnlyAddValueListByOrderNoRequest) (*OnlyAddValueListByOrderNoResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method OnlyAddValueListByOrderNo not implemented")
 }
-func (UnimplementedBundleServer) ReSignTheContract(context.Context, *ReSignTheContractRequest) (*CommonResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method ReSignTheContract not implemented")
-}
 func (UnimplementedBundleServer) CreateValueAddBundle(context.Context, *CreateValueAddBundleRequest) (*CreateValueAddBundleResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method CreateValueAddBundle not implemented")
 }
@@ -1049,9 +1019,6 @@ func (UnimplementedBundleServer) RevertTaskCompletionByUUIDItem(context.Context,
 func (UnimplementedBundleServer) AddHiddenTaskAssignee(context.Context, *AddHiddenTaskAssigneeRequest) (*ComResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method AddHiddenTaskAssignee not implemented")
 }
-func (UnimplementedBundleServer) CreateTaskWorkLog(context.Context, *CreateTaskWorkLogRequest) (*CommonResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method CreateTaskWorkLog not implemented")
-}
 func (UnimplementedBundleServer) MetricsBusiness(context.Context, *MetricsBusinessReq) (*MetricsBusinessResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method MetricsBusiness not implemented")
 }
@@ -1070,9 +1037,6 @@ func (UnimplementedBundleServer) MetricsArtistAccountExport(context.Context, *Me
 func (UnimplementedBundleServer) MetricsVideoSubmitExport(context.Context, *MetricsVideoSubmitExportReq) (*MetricsVideoSubmitExportResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method MetricsVideoSubmitExport not implemented")
 }
-func (UnimplementedBundleServer) QueryTheOrderSnapshotInformation(context.Context, *QueryTheOrderSnapshotInformationReq) (*QueryTheOrderSnapshotInformationResp, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method QueryTheOrderSnapshotInformation not implemented")
-}
 func (s *UnimplementedBundleServer) XXX_SetProxyImpl(impl protocol.Invoker) {
 	s.proxyImpl = impl
 }
@@ -1739,35 +1703,6 @@ func _Bundle_OnlyAddValueListByOrderNo_Handler(srv interface{}, ctx context.Cont
 	return interceptor(ctx, in, info, handler)
 }
 
-func _Bundle_ReSignTheContract_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
-	in := new(ReSignTheContractRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	base := srv.(dubbo3.Dubbo3GrpcService)
-	args := []interface{}{}
-	args = append(args, in)
-	md, _ := metadata.FromIncomingContext(ctx)
-	invAttachment := make(map[string]interface{}, len(md))
-	for k, v := range md {
-		invAttachment[k] = v
-	}
-	invo := invocation.NewRPCInvocation("ReSignTheContract", args, invAttachment)
-	if interceptor == nil {
-		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
-		return result, result.Error()
-	}
-	info := &grpc_go.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
-		return result, result.Error()
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
 func _Bundle_CreateValueAddBundle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
 	in := new(CreateValueAddBundleRequest)
 	if err := dec(in); err != nil {
@@ -3276,35 +3211,6 @@ func _Bundle_AddHiddenTaskAssignee_Handler(srv interface{}, ctx context.Context,
 	return interceptor(ctx, in, info, handler)
 }
 
-func _Bundle_CreateTaskWorkLog_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
-	in := new(CreateTaskWorkLogRequest)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	base := srv.(dubbo3.Dubbo3GrpcService)
-	args := []interface{}{}
-	args = append(args, in)
-	md, _ := metadata.FromIncomingContext(ctx)
-	invAttachment := make(map[string]interface{}, len(md))
-	for k, v := range md {
-		invAttachment[k] = v
-	}
-	invo := invocation.NewRPCInvocation("CreateTaskWorkLog", args, invAttachment)
-	if interceptor == nil {
-		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
-		return result, result.Error()
-	}
-	info := &grpc_go.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
-		return result, result.Error()
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
 func _Bundle_MetricsBusiness_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
 	in := new(MetricsBusinessReq)
 	if err := dec(in); err != nil {
@@ -3479,35 +3385,6 @@ func _Bundle_MetricsVideoSubmitExport_Handler(srv interface{}, ctx context.Conte
 	return interceptor(ctx, in, info, handler)
 }
 
-func _Bundle_QueryTheOrderSnapshotInformation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
-	in := new(QueryTheOrderSnapshotInformationReq)
-	if err := dec(in); err != nil {
-		return nil, err
-	}
-	base := srv.(dubbo3.Dubbo3GrpcService)
-	args := []interface{}{}
-	args = append(args, in)
-	md, _ := metadata.FromIncomingContext(ctx)
-	invAttachment := make(map[string]interface{}, len(md))
-	for k, v := range md {
-		invAttachment[k] = v
-	}
-	invo := invocation.NewRPCInvocation("QueryTheOrderSnapshotInformation", args, invAttachment)
-	if interceptor == nil {
-		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
-		return result, result.Error()
-	}
-	info := &grpc_go.UnaryServerInfo{
-		Server:     srv,
-		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
-	}
-	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
-		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
-		return result, result.Error()
-	}
-	return interceptor(ctx, in, info, handler)
-}
-
 // Bundle_ServiceDesc is the grpc_go.ServiceDesc for Bundle service.
 // It's only intended for direct use with grpc_go.RegisterService,
 // and not to be introspected or modified (even as a copy)
@@ -3603,10 +3480,6 @@ var Bundle_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "OnlyAddValueListByOrderNo",
 			Handler:    _Bundle_OnlyAddValueListByOrderNo_Handler,
 		},
-		{
-			MethodName: "ReSignTheContract",
-			Handler:    _Bundle_ReSignTheContract_Handler,
-		},
 		{
 			MethodName: "CreateValueAddBundle",
 			Handler:    _Bundle_CreateValueAddBundle_Handler,
@@ -3815,10 +3688,6 @@ var Bundle_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "AddHiddenTaskAssignee",
 			Handler:    _Bundle_AddHiddenTaskAssignee_Handler,
 		},
-		{
-			MethodName: "CreateTaskWorkLog",
-			Handler:    _Bundle_CreateTaskWorkLog_Handler,
-		},
 		{
 			MethodName: "MetricsBusiness",
 			Handler:    _Bundle_MetricsBusiness_Handler,
@@ -3843,10 +3712,6 @@ var Bundle_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "MetricsVideoSubmitExport",
 			Handler:    _Bundle_MetricsVideoSubmitExport_Handler,
 		},
-		{
-			MethodName: "QueryTheOrderSnapshotInformation",
-			Handler:    _Bundle_QueryTheOrderSnapshotInformation_Handler,
-		},
 	},
 	Streams:  []grpc_go.StreamDesc{},
 	Metadata: "pb/bundle.proto",

pkg/db/mysql.go

@@ -63,16 +63,7 @@ func loadMysqlConn(conn string) *gorm.DB {
 		&model.BundleActivate{},
 		&model.BundleBalanceLayout{},
 	)
-	if db.Migrator().HasColumn(&model.BundleOrderRecords{}, "platform_ids") == false {
-		if err := db.Migrator().AddColumn(&model.BundleOrderRecords{}, "platform_ids"); err != nil {
-			fmt.Println(err)
-		}
-	}
-	if db.Migrator().HasColumn(&model.BundleOrderRecords{}, "inviter_id") == false {
-		if err := db.Migrator().AddColumn(&model.BundleOrderRecords{}, "inviter_id"); err != nil {
-			fmt.Println(err)
-		}
-	}
+
 	if err != nil {
 		// return nil
 		panic(err)
@@ -115,12 +106,12 @@ func loadTaskBenchMysqlConn(conn string) *gorm.DB {
 		&model.TaskManagement{},
 		&model.TaskAssignRecords{},
 		// &model.TaskBalance{},
+		&model.TaskLog{},
 		&model.TaskSyncStatus{},
 		&model.TaskPendingLayout{},
 		&model.TaskAssignUUIDItems{},
 		// 隐藏人员人记录表
 		&model.TaskAssigneeHidden{},
-		&model.TaskWorkLog{},
 	)
 
 	if err != nil {

pkg/msg/msg.go

@@ -120,9 +120,3 @@ const (
 	AccountService       = 4 //账号数
 	AvailableTimeService = 5 //可用时长
 )
-
-// 套餐状态
-const (
-	IsExpired  = 1 //已过期
-	NotExpired = 0 //未过期
-)