文件搬迁

src/main/java/com/ydw/bat/wkflow/business_main/datas/entity/OnlineFileLog.java

@@ -0,0 +1,51 @@
+package com.ydw.bat.wkflow.business_main.datas.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class OnlineFileLog {
+
+    @ApiModelProperty(value = "主键")
+    @TableId(value = "ID", type = IdType.UUID)
+    private String id;
+
+    @TableField("HIS_ID")
+    private String hisId;
+
+    @TableField("ATT_FILE_ID")
+    private String attFileId;
+
+    @TableField("FILE_NAME")
+    private String fileName;
+
+    @TableField("DLD_FILE_NAME")
+    private String oldFileName;
+
+    @TableField("FILE_SUFFIX")
+    private String fileSuffix;
+
+    @TableField("FILE_PATH")
+    private String filePath;
+
+    @TableField("COUNT")
+    private Integer count;
+
+    @TableField("CREATE_TIME")
+    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date createTime;
+
+    @TableField("UPDATE_TIME")
+    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private byte[] bytes;
+
+}

src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessModelHisService.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessEvaluationHis;
 import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessModelHis;
+import com.ydw.bat.wkflow.business_main.datas.entity.OnlineFileLog;
 
 import java.util.List;
 
@@ -37,5 +38,5 @@ public interface IBusProcessModelHisService extends IService<BusProcessModelHis>
 
     void saveBussTemplateFile(JSONObject object, String pid);
 
-    List<BusProcessModelHis> selectOnlineFile(String taskId);
+    OnlineFileLog selectOnlineFile(String onlineFileId);
 }

src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessModelHisServiceImpl.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessEvaluationHis;
 import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessModelHis;
+import com.ydw.bat.wkflow.business_main.datas.entity.OnlineFileLog;
 import com.ydw.bat.wkflow.business_main.datas.mapper.BusProcessEvaluationHisMapper;
 import com.ydw.bat.wkflow.business_main.datas.mapper.BusProcessModelHisMapper;
 import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessEvaluationHisService;
@@ -18,8 +19,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
-import java.io.File;
+import java.io.*;
-import java.io.IOException;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.List;
@@ -146,25 +146,38 @@ public class BusProcessModelHisServiceImpl extends ServiceImpl<BusProcessModelHi
     }
 
     @Override
-    public List<BusProcessModelHis> selectOnlineFile(String taskId) {
+    public OnlineFileLog selectOnlineFile(String onlineFileId) {
-        QueryWrapper<BusProcessModelHis> objectQueryWrapper = new QueryWrapper<>();
+        BusProcessModelHis busProcessModelHis = baseMapper.selectById(onlineFileId);
-        objectQueryWrapper.eq("TASK_ID",taskId);
+        OnlineFileLog onlineFileLog = new OnlineFileLog();
-        List<BusProcessModelHis> busProcessModelHis = baseMapper.selectList(objectQueryWrapper);
+        byte[] bytes = new byte[0];
-        if(!busProcessModelHis.isEmpty()){
+        if(busProcessModelHis!=null){
-             String pId = busProcessModelHis.get(0).getPId();
+             //获取当前文件路径 返回文件路径的数字组
-            QueryWrapper<BusProcessModelHis> objectQueryWrapperPid = new QueryWrapper<>();
+            try {
-            objectQueryWrapperPid.eq("P_ID",pId);
+                String editFilePath = busProcessModelHis.getEditFilePath();
-            List<BusProcessModelHis> busProcessModelHisList = baseMapper.selectList(objectQueryWrapperPid);
+                File file = new File(editFilePath);
-            if(!busProcessModelHisList.isEmpty()){
+                FileInputStream fileInputStream = new FileInputStream(file);
-                for(BusProcessModelHis data : busProcessModelHisList){
+                ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(1024);
-                    if(StringUtils.isNotBlank(data.getEditFilePath())){
+                byte [] aByte = new byte[1024];
-                        data.setEditFilePath(downloadUrl+filePath+data.getEditFilePath());
+                int n;
-                    }
+                while ((n = fileInputStream.read(aByte)) != -1){
+                    byteArrayOutputStream.write(aByte,0,n);
                 }
-                return busProcessModelHisList;
+                bytes = byteArrayOutputStream.toByteArray();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+            onlineFileLog.setHisId(busProcessModelHis.getId());
+            onlineFileLog.setFilePath(busProcessModelHis.getEditFilePath());
+            if(StringUtils.isNotBlank(busProcessModelHis.getEditFilePath())){
+                String[] split = busProcessModelHis.getEditFilePath().split("/.");
+                onlineFileLog.setFileSuffix(split[1]);
+            }
+            if(StringUtils.isNotBlank(busProcessModelHis.getEditFilePath())){
+                String[] split = busProcessModelHis.getEditFilePath().split("/");
+                onlineFileLog.setOldFileName(split[2]);
             }
         }
-        return null;
+        return onlineFileLog;
     }
 
     /**