优化

Src/SampleExtension.cs

@@ -708,6 +708,13 @@ namespace Kivii.Samples
                 }
 
                 trans?.Commit();
+                
+            }
+            catch (Exception ex)
+            {
+                trans?.Rollback();
+                throw ex;
+            }
             if (package != null)
             {
                 if (!conn.Exists<Sample>(o => o.PackageKvid == package.Kvid && o.Type != SampleType.Package))
@@ -722,12 +729,6 @@ namespace Kivii.Samples
                 });
                 th.Start();
             }
-            }
-            catch (Exception ex)
-            {
-                trans?.Rollback();
-                throw ex;
-            }
             exist.RemoveAllOnlyProperties();
             return exist;
         }

Src/Transforms/RestfulSample.cs

@@ -323,6 +323,13 @@ namespace Kivii.Samples.Transforms
             {
                 rtns.Results = packages.PackageClear(local, Route, conn);
                 trans.Commit();
+                
+            }
+            catch (Exception ex)
+            {
+                trans.Rollback();
+                throw ex;
+            }
             var th = KiviiContext.NewThread(() =>
             {
                 foreach (var item in packages)
@@ -331,13 +338,6 @@ namespace Kivii.Samples.Transforms
                 }
             });
             th.Start();
-            }
-            catch (Exception ex)
-            {
-                trans.Rollback();
-                throw ex;
-            }
-
             return rtns;
         }
     }
@@ -650,18 +650,17 @@ namespace Kivii.Samples.Transforms
                 rtns.Results = samples.Packaging(package, local, Route, conn);
                 trans.Commit();
 
-                var th = KiviiContext.NewThread(() =>
-                {
-                    package.PackageCalculateTime();
-                });
-                th.Start();
             }
             catch (Exception ex)
             {
                 trans.Rollback();
                 throw ex;
             }
-
+            var th = KiviiContext.NewThread(() =>
+            {
+                package.PackageCalculateTime();
+            });
+            th.Start();
             return rtns;
         }
     }
@@ -707,20 +706,17 @@ namespace Kivii.Samples.Transforms
             {
                 rtns.Results = samples.PackageMoving(package, local, Route, conn);
                 trans.Commit();
-
-                var th = KiviiContext.NewThread(() =>
-                {
-                    package.PackageCalculateTime();
-                });
-                th.Start();
-
             }
             catch (Exception ex)
             {
                 trans.Rollback();
                 throw ex;
             }
-
+            var th = KiviiContext.NewThread(() =>
+            {
+                package.PackageCalculateTime();
+            });
+            th.Start();
             return rtns;
         }
     }