api/bundle/bundle.validator.pb.go

@@ -574,9 +574,6 @@ func (this *TerminateTaskByUUIDRequest) Validate() error {
 func (this *BatchTerminateTaskRequest) Validate() error {
 	return nil
 }
-func (this *RevertTaskCompletionByUUIDItemRequest) Validate() error {
-	return nil
-}
 func (this *GetTaskActualStatusByUUIDRequest) Validate() error {
 	return nil
 }

api/bundle/bundle_triple.pb.go

@@ -111,7 +111,6 @@ type BundleClient interface {
 	GetPendingTaskLayout(ctx context.Context, in *GetPendingTaskLayoutReq, opts ...grpc_go.CallOption) (*GetPendingTaskLayoutResp, common.ErrorWithAttachment)
 	SetPendingTaskLayout(ctx context.Context, in *SetPendingTaskLayoutReq, opts ...grpc_go.CallOption) (*SetPendingTaskLayoutResp, common.ErrorWithAttachment)
 	GetPendingUploadBreakdown(ctx context.Context, in *PendingUploadBreakdownRequest, opts ...grpc_go.CallOption) (*PendingUploadBreakdownResponse, common.ErrorWithAttachment)
-	RevertTaskCompletionByUUIDItem(ctx context.Context, in *RevertTaskCompletionByUUIDItemRequest, opts ...grpc_go.CallOption) (*ComResponse, common.ErrorWithAttachment)
 }
 
 type bundleClient struct {
@@ -195,7 +194,6 @@ type BundleClientImpl struct {
 	GetPendingTaskLayout                     func(ctx context.Context, in *GetPendingTaskLayoutReq) (*GetPendingTaskLayoutResp, error)
 	SetPendingTaskLayout                     func(ctx context.Context, in *SetPendingTaskLayoutReq) (*SetPendingTaskLayoutResp, error)
 	GetPendingUploadBreakdown                func(ctx context.Context, in *PendingUploadBreakdownRequest) (*PendingUploadBreakdownResponse, error)
-	RevertTaskCompletionByUUIDItem           func(ctx context.Context, in *RevertTaskCompletionByUUIDItemRequest) (*ComResponse, error)
 }
 
 func (c *BundleClientImpl) GetDubboStub(cc *triple.TripleConn) BundleClient {
@@ -666,12 +664,6 @@ func (c *bundleClient) GetPendingUploadBreakdown(ctx context.Context, in *Pendin
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetPendingUploadBreakdown", in, out)
 }
 
-func (c *bundleClient) RevertTaskCompletionByUUIDItem(ctx context.Context, in *RevertTaskCompletionByUUIDItemRequest, opts ...grpc_go.CallOption) (*ComResponse, common.ErrorWithAttachment) {
-	out := new(ComResponse)
-	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
-	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/RevertTaskCompletionByUUIDItem", in, out)
-}
-
 // BundleServer is the server API for Bundle service.
 // All implementations must embed UnimplementedBundleServer
 // for forward compatibility
@@ -759,7 +751,6 @@ type BundleServer interface {
 	GetPendingTaskLayout(context.Context, *GetPendingTaskLayoutReq) (*GetPendingTaskLayoutResp, error)
 	SetPendingTaskLayout(context.Context, *SetPendingTaskLayoutReq) (*SetPendingTaskLayoutResp, error)
 	GetPendingUploadBreakdown(context.Context, *PendingUploadBreakdownRequest) (*PendingUploadBreakdownResponse, error)
-	RevertTaskCompletionByUUIDItem(context.Context, *RevertTaskCompletionByUUIDItemRequest) (*ComResponse, error)
 	mustEmbedUnimplementedBundleServer()
 }
 
@@ -996,9 +987,6 @@ func (UnimplementedBundleServer) SetPendingTaskLayout(context.Context, *SetPendi
 func (UnimplementedBundleServer) GetPendingUploadBreakdown(context.Context, *PendingUploadBreakdownRequest) (*PendingUploadBreakdownResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetPendingUploadBreakdown not implemented")
 }
-func (UnimplementedBundleServer) RevertTaskCompletionByUUIDItem(context.Context, *RevertTaskCompletionByUUIDItemRequest) (*ComResponse, error) {
-	return nil, status.Errorf(codes.Unimplemented, "method RevertTaskCompletionByUUIDItem not implemented")
-}
 func (s *UnimplementedBundleServer) XXX_SetProxyImpl(impl protocol.Invoker) {
 	s.proxyImpl = impl
 }
@@ -3231,35 +3219,6 @@ func _Bundle_GetPendingUploadBreakdown_Handler(srv interface{}, ctx context.Cont
 	return interceptor(ctx, in, info, handler)
 }
 
-func _Bundle_RevertTaskCompletionByUUIDItem_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
-	in := new(RevertTaskCompletionByUUIDItemRequest)
-	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("RevertTaskCompletionByUUIDItem", 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)
@@ -3571,10 +3530,6 @@ var Bundle_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "GetPendingUploadBreakdown",
 			Handler:    _Bundle_GetPendingUploadBreakdown_Handler,
 		},
-		{
-			MethodName: "RevertTaskCompletionByUUIDItem",
-			Handler:    _Bundle_RevertTaskCompletionByUUIDItem_Handler,
-		},
 	},
 	Streams:  []grpc_go.StreamDesc{},
 	Metadata: "pb/bundle.proto",

pkg/service/cast/work.go

@@ -402,13 +402,6 @@ func DelWork(ctx *gin.Context) {
 		service.Error(ctx, err)
 		return
 	}
-	if service.BundleProvider != nil {
-		if _, e := service.BundleProvider.RevertTaskCompletionByUUIDItem(context.Background(), &bundle.RevertTaskCompletionByUUIDItemRequest{Uuid: req.WorkUuid}); e != nil {
-			zap.L().Error("RevertTaskCompletionByUUIDItem failed", zap.Error(e))
-		}
-	} else {
-		zap.L().Warn("BundleProvider is nil, skipping RevertTaskCompletionByUUIDItem")
-	}
 	service.Success(ctx, nil)
 	return
 }

pkg/service/taskbench/taskBench.go

@@ -402,7 +402,6 @@ func UpdateWorkImageWithTaskUUID(ctx *gin.Context) {
 		EmployeeNum:       userInfo.TelNum, // 需要根据实际业务逻辑填充员工工号
 		TaskType:          "post",
 		CompleteCount:     1,
-		Uuid:              resp.WorkUuid,
 	})
 	if err != nil {
 		service.Error(ctx, err)
@@ -474,7 +473,6 @@ func UpdateWorkVideoWithUUID(ctx *gin.Context) {
 		EmployeeNum:       userInfo.TelNum, // 需要根据实际业务逻辑填充员工工号
 		TaskType:          "video",
 		CompleteCount:     1,
-		Uuid:              resp.WorkUuid,
 	})
 	if err != nil {
 		service.Error(ctx, err)
@@ -649,7 +647,6 @@ func UpdateVideoScriptWithUUID(ctx *gin.Context) {
 		EmployeeNum:       userInfo.TelNum, // 需要根据实际业务逻辑填充员工工号
 		TaskType:          "script",
 		CompleteCount:     1,
-		Uuid:              resp.WorkUuid,
 	})
 	if err != nil {
 		service.Error(ctx, err)