Support proxy class

framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/HangfireBackgroundWorkerManager.cs

@@ -4,6 +4,7 @@ using System.Threading;
 using System.Threading.Tasks;
 using Hangfire;
 using Volo.Abp.DependencyInjection;
+using Volo.Abp.DynamicProxy;
 using Volo.Abp.Threading;
 
 namespace Volo.Abp.BackgroundWorkers.Hangfire
@@ -64,7 +65,7 @@ namespace Volo.Abp.BackgroundWorkers.Hangfire
                     return;
                 }
 
-                var adapterType = typeof(HangfirePeriodicBackgroundWorkerAdapter<>).MakeGenericType(worker.GetType());
+                var adapterType = typeof(HangfirePeriodicBackgroundWorkerAdapter<>).MakeGenericType(ProxyHelper.GetUnProxiedType(worker));
                 var workerAdapter = Activator.CreateInstance(adapterType) as IHangfireBackgroundWorker;
 
                 RecurringJob.AddOrUpdate(() => workerAdapter.DoWorkAsync(), GetCron(period.Value));

framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzBackgroundWorkerManager.cs

@@ -3,6 +3,7 @@ using System.Threading;
 using System.Threading.Tasks;
 using Quartz;
 using Volo.Abp.DependencyInjection;
+using Volo.Abp.DynamicProxy;
 using Volo.Abp.Threading;
 
 namespace Volo.Abp.BackgroundWorkers.Quartz
@@ -56,7 +57,7 @@ namespace Volo.Abp.BackgroundWorkers.Quartz
             }
             else
             {
-                var adapterType = typeof(QuartzPeriodicBackgroundWorkerAdapter<>).MakeGenericType(worker.GetType());
+                var adapterType = typeof(QuartzPeriodicBackgroundWorkerAdapter<>).MakeGenericType(ProxyHelper.GetUnProxiedType(worker));
 
                 var workerAdapter = Activator.CreateInstance(adapterType) as IQuartzBackgroundWorkerAdapter;
 

framework/src/Volo.Abp.BackgroundWorkers.Quartz/Volo/Abp/BackgroundWorkers/Quartz/QuartzPeriodicBackgroundWorkerAdapter.cs

@@ -2,6 +2,7 @@
 using System.Reflection;
 using System.Threading.Tasks;
 using Quartz;
+using Volo.Abp.DynamicProxy;
 using Volo.Abp.Threading;
 
 namespace Volo.Abp.BackgroundWorkers.Quartz
@@ -26,16 +27,16 @@ namespace Volo.Abp.BackgroundWorkers.Quartz
         public void BuildWorker(IBackgroundWorker worker)
         {
             int? period;
-            var workerType = worker.GetType();
+            var workerType = ProxyHelper.GetUnProxiedType(worker);
 
             if (worker is AsyncPeriodicBackgroundWorkerBase or PeriodicBackgroundWorkerBase)
             {
-                if (typeof(TWorker) != worker.GetType())
+                if (typeof(TWorker) != workerType)
                 {
                     throw new ArgumentException($"{nameof(worker)} type is different from the generic type");
                 }
 
-                var timer = worker.GetType().GetProperty("Timer", BindingFlags.Instance | BindingFlags.NonPublic)?.GetValue(worker);
+                var timer = workerType.GetProperty("Timer", BindingFlags.Instance | BindingFlags.NonPublic)?.GetValue(worker);
 
                 if (worker is AsyncPeriodicBackgroundWorkerBase)
                 {

framework/src/Volo.Abp.Core/Volo/Abp/DynamicProxy/ProxyHelper.cs

@@ -7,9 +7,9 @@ namespace Volo.Abp.DynamicProxy
     public static class ProxyHelper
     {
         private const string ProxyNamespace = "Castle.Proxies";
-        
+
         /// <summary>
-        /// Returns dynamic proxy target object if this is a proxied object, otherwise returns the given object. 
+        /// Returns dynamic proxy target object if this is a proxied object, otherwise returns the given object.
         /// It supports Castle Dynamic Proxies.
         /// </summary>
         public static object UnProxy(object obj)
@@ -33,7 +33,21 @@ namespace Volo.Abp.DynamicProxy
 
         public static Type GetUnProxiedType(object obj)
         {
-            return UnProxy(obj).GetType();
+            if (obj.GetType().Namespace == ProxyNamespace)
+            {
+                var target = UnProxy(obj);
+                if (target != null)
+                {
+                    if (target == obj)
+                    {
+                        return obj.GetType().GetTypeInfo().BaseType;
+                    }
+
+                    return target.GetType();
+                }
+            }
+
+            return obj.GetType();
         }
     }
 }