From 1d53dd8f501a98ddcce8146443b51b357ef5f9b1 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期四, 29 十二月 2022 16:55:46 +0800
Subject: [PATCH] 1

---
 src/main/java/com/lf/server/service/data/DataUploadService.java |   82 ++++++++++++++++++++++++++++++++++++++--
 1 files changed, 77 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/lf/server/service/data/DataUploadService.java b/src/main/java/com/lf/server/service/data/DataUploadService.java
index e2df737..4e368c6 100644
--- a/src/main/java/com/lf/server/service/data/DataUploadService.java
+++ b/src/main/java/com/lf/server/service/data/DataUploadService.java
@@ -1,7 +1,10 @@
 package com.lf.server.service.data;
 
+import com.lf.server.entity.data.MetaEntity;
 import com.lf.server.entity.data.MetaFileEntity;
+import com.lf.server.helper.FileHelper;
 import com.lf.server.service.all.BaseUploadService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.io.File;
@@ -13,24 +16,35 @@
  */
 @Service
 public class DataUploadService extends BaseUploadService {
+    @Autowired
+    MetaService metaService;
+
+    @Autowired
+    MetaFileService metaFileService;
+
     /**
      * 鎻掑叆鏂囦欢
      */
-    public int insertFiles(List<MetaFileEntity> list) {
+    public int insertFiles(MetaEntity entity, List<MetaFileEntity> list) {
         int count = 0;
         try {
             String temp = pathHelper.getConfig().getTempPath();
             String root = pathHelper.getUploadFullPath();
 
             for (MetaFileEntity mf : list) {
-                // 绉诲姩鏂囦欢
-                File file = new File(temp + File.separator + mf.getPath());
-                File newFile = new File(root + File.separator + mf.getName());
-                file.renameTo(newFile);
+                String filePath = getFilePath(temp, root, mf);
 
                 // 鍏冩暟鎹�
+                MetaEntity me = createMetaEntity(entity, mf);
+                if (metaService.insert(me) < 1) {
+                    continue;
+                }
 
                 // 鍏冩暟鎹枃浠�
+                MetaFileEntity mfe = createMetaFileEntity(me, mf, filePath);
+                if (metaFileService.insert(mfe) > 0) {
+                    count++;
+                }
             }
         } catch (Exception ex) {
             log.error(ex.getMessage(), ex);
@@ -38,4 +52,62 @@
 
         return count;
     }
+
+    /**
+     * 鑾峰彇鏂囦欢璺緞
+     */
+    private String getFilePath(String temp, String root, MetaFileEntity mf) {
+        // 绉诲姩鏂囦欢
+        File file = new File(temp + File.separator + mf.getPath());
+        File newFile = new File(root + File.separator + mf.getGuid());
+
+        MetaFileEntity old = metaFileService.selectByGuid(mf.getGuid());
+
+        String filePath = null;
+        if (null == old) {
+            filePath = newFile.getPath();
+            file.renameTo(newFile);
+        } else {
+            filePath = old.getPath();
+            file.delete();
+        }
+
+        return filePath;
+    }
+
+    /**
+     * 鍒涘缓鍏冩暟鎹疄浣�
+     */
+    private MetaEntity createMetaEntity(MetaEntity entity, MetaFileEntity mf) {
+        MetaEntity me = new MetaEntity();
+        me.setDepid(entity.getDepid());
+        me.setDirid(entity.getDirid());
+        me.setVerid(entity.getVerid());
+        me.setType("file");
+        me.setGather(entity.getGather());
+        me.setBatch(entity.getBatch());
+        me.setDescr(entity.getDescr());
+        me.setName(mf.getName());
+        me.setSizes(mf.getSizes());
+        me.setCreateTime(entity.getCreateTime());
+        me.setCreateUser(entity.getCreateUser());
+
+        return me;
+    }
+
+    /**
+     * 鍒涘缓鍏冩暟鎹枃浠跺疄浣�
+     */
+    private MetaFileEntity createMetaFileEntity(MetaEntity me, MetaFileEntity entity, String filePath) {
+        MetaFileEntity mfe = new MetaFileEntity();
+        mfe.setName(entity.getName());
+        mfe.setMetaid(me.getId());
+        mfe.setGuid(entity.getGuid());
+        mfe.setSizes(entity.getSizes());
+        mfe.setPath(FileHelper.getRelativePath(filePath));
+        mfe.setCreateUser(me.getCreateUser());
+        mfe.setCreateTime(me.getCreateTime());
+
+        return mfe;
+    }
 }

--
Gitblit v1.9.3