diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/entity/OnlineFileLog.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/entity/OnlineFileLog.java new file mode 100644 index 00000000..c82a3cc5 --- /dev/null +++ b/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; + +} diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessModelHisService.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessModelHisService.java index b76bbdf4..37e7c7ae 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessModelHisService.java +++ b/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 void saveBussTemplateFile(JSONObject object, String pid); - List selectOnlineFile(String taskId); + OnlineFileLog selectOnlineFile(String onlineFileId); } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessModelHisServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessModelHisServiceImpl.java index b20c5240..e040d1ba 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessModelHisServiceImpl.java +++ b/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.IOException; +import java.io.*; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; @@ -146,25 +146,38 @@ public class BusProcessModelHisServiceImpl extends ServiceImpl selectOnlineFile(String taskId) { - QueryWrapper objectQueryWrapper = new QueryWrapper<>(); - objectQueryWrapper.eq("TASK_ID",taskId); - List busProcessModelHis = baseMapper.selectList(objectQueryWrapper); - if(!busProcessModelHis.isEmpty()){ - String pId = busProcessModelHis.get(0).getPId(); - QueryWrapper objectQueryWrapperPid = new QueryWrapper<>(); - objectQueryWrapperPid.eq("P_ID",pId); - List busProcessModelHisList = baseMapper.selectList(objectQueryWrapperPid); - if(!busProcessModelHisList.isEmpty()){ - for(BusProcessModelHis data : busProcessModelHisList){ - if(StringUtils.isNotBlank(data.getEditFilePath())){ - data.setEditFilePath(downloadUrl+filePath+data.getEditFilePath()); - } + public OnlineFileLog selectOnlineFile(String onlineFileId) { + BusProcessModelHis busProcessModelHis = baseMapper.selectById(onlineFileId); + OnlineFileLog onlineFileLog = new OnlineFileLog(); + byte[] bytes = new byte[0]; + if(busProcessModelHis!=null){ + //获取当前文件路径 返回文件路径的数字组 + try { + String editFilePath = busProcessModelHis.getEditFilePath(); + File file = new File(editFilePath); + FileInputStream fileInputStream = new FileInputStream(file); + ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(1024); + byte [] aByte = new byte[1024]; + 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; } /**