修改Postgres数据库帮助类

13693261870

2023-08-21 8482a6fef58c0d699795435ef525a8f188e502a1

 DataLoader/CS/Importor.cs

@@ -28,7 +28,7 @@
        {
            get
            {
                if (_ph == null) _ph = new PostgreHelper(DbEnum.langfang);
                if (_ph == null) _ph = new PostgreHelper();

                return _ph;
            }
@@ -95,7 +95,7 @@
            vd.Meta.create_user = Tool.UserId;
        }

        public static void ImportFiles(ObservableCollection<ViewData> viewDatas, string target)
        public static void ImportFiles(ObservableCollection<ViewData> viewDatas, string target, int start)
        {
            Parallel.ForEach(viewDatas, (vd, ParallelLoopState) =>
            {
@@ -109,21 +109,15 @@
                        return;
                    }

                    vd.Status = "插入数据库...";
                    int start = GetSubPath(target, 1);
                    SysMeta mf = GetMetaFile(vd, start, guid);
                    vd.Status = "获取数据目录...";
                    int subPath = GetSubPath(target, start);
                    SysMeta mf = GetMetaFile(vd, subPath, guid);

                    vd.Status = "复制文件...";
                    CopyFile(vd.FilePath, Path.Combine(target, mf.path));

                    int metaId = InsertMeta(mf);
                    if (metaId == 0)
                    {
                        vd.Status = "元数据出错！";
                        return;
                    }

                    vd.Status = "完成。";
                    vd.Status = "准备入库";
                    vd.Meta = mf;
                }
                catch (Exception ex)
                {
@@ -131,6 +125,12 @@
                    vd.Status = "失败！";
                }
            });

            foreach (ViewData vd in viewDatas)
            {
                int metaId = InsertMeta(vd.Meta);
                vd.Status = metaId == 0 ? "元数据出错！" : "完成。";
            }
        }

        public static void ImportFiles2(ObservableCollection<ViewData> viewDatas, string target)