合并分支 'dev_20230216' 到 'master'

在线编辑日志记录

查看合并请求 laws-foton-slrs/foton-wkflow-rest!45
This commit is contained in:
高嵩
2023-05-18 18:39:43 +08:00
3 changed files with 32 additions and 16 deletions
@@ -218,4 +218,7 @@ public interface LawsUserInfoService {
void updateEsRevisePlan(@RequestParam("esId")String esId, @RequestParam("date")Date date,@RequestParam("s") String s); void updateEsRevisePlan(@RequestParam("esId")String esId, @RequestParam("date")Date date,@RequestParam("s") String s);
@GetMapping("/esRevisePlan/es-revise-plan/getAllPlansByWkInfo") @GetMapping("/esRevisePlan/es-revise-plan/getAllPlansByWkInfo")
List<EsRevisePlanDTO> getAllPlansByWkInfo(); List<EsRevisePlanDTO> getAllPlansByWkInfo();
@GetMapping("lawss/activiti/selectOnlineFile")
ResponseMessage selectOnlineFile(@RequestParam("onlineFileId") String onlineFileId);
} }
@@ -1,15 +1,13 @@
package com.ydw.bat.wkflow.business_main.datas.controller; package com.ydw.bat.wkflow.business_main.datas.controller;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessEvaluationHis; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_auth.LawsUserInfoService;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessModelHis; 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.entity.OnlineFileLog;
import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessEvaluationHisService; import com.ydw.bat.wkflow.business_main.datas.mapper.BusProcessModelHisMapper;
import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessModelHisService; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessModelHisService;
import com.ydw.bat.wkflow.util.Utils;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -22,12 +20,8 @@ import javax.servlet.http.HttpServletResponse;
import java.io.*; import java.io.*;
import java.net.URL; import java.net.URL;
import java.net.URLConnection; import java.net.URLConnection;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Scanner; import java.util.Scanner;
import java.util.UUID;
/** /**
* <p> * <p>
@@ -49,10 +43,19 @@ public class BusProcessModelHisController {
@Autowired @Autowired
private IBusProcessModelHisService busProcessModelHisService; private IBusProcessModelHisService busProcessModelHisService;
@Autowired
private LawsUserInfoService lawsUserInfoService;
@Autowired
private BusProcessModelHisMapper busProcessModelHisMapper;
@ApiOperation(value = "|onlyOffice接收文件") @ApiOperation(value = "|onlyOffice接收文件")
@PostMapping("/recieveFile") @PostMapping("/recieveFile")
public void recieveFile(HttpServletRequest request, HttpServletResponse response, String fileNm, String standNo, String fileId){ public void recieveFile(HttpServletRequest request, HttpServletResponse response, String fileNm, String standNo, String fileId){
logger.info("**********进入onlyoffice接收文档接口************"); logger.info("**********进入onlyoffice接收文档接口************");
logger.info("**********fileNm************"+fileNm+"=======");
logger.info("**********standNo************"+standNo+"=======");
logger.info("**********fileId************"+fileId+"=======");
try { try {
PrintWriter writer = response.getWriter(); PrintWriter writer = response.getWriter();
String body = ""; String body = "";
@@ -92,6 +95,7 @@ public class BusProcessModelHisController {
downloadNetFile(downloadUri, file); downloadNetFile(downloadUri, file);
// 更新在线编辑当前节点编辑状态 // 更新在线编辑当前节点编辑状态
busProcessModelHisService.modelHisOneUpdStatusById(fileId); busProcessModelHisService.modelHisOneUpdStatusById(fileId);
lawsUserInfoService.selectOnlineFile(fileId);
} }
} catch (Exception ex) { } catch (Exception ex) {
saved = 1; saved = 1;
@@ -117,6 +121,10 @@ public class BusProcessModelHisController {
@PostMapping("/recieveFileBefore") @PostMapping("/recieveFileBefore")
public void recieveFileBefore(HttpServletRequest request, HttpServletResponse response, String fileNm, String standNo, String pid, String taskId){ public void recieveFileBefore(HttpServletRequest request, HttpServletResponse response, String fileNm, String standNo, String pid, String taskId){
logger.info("**********进入onlyoffice接收文档接口************"); logger.info("**********进入onlyoffice接收文档接口************");
logger.info("**********fileNm************"+fileNm+"=======");
logger.info("**********standNo************"+standNo+"=======");
logger.info("**********fileId************"+pid+"=======");
logger.info("**********fileId************"+taskId+"=======");
try { try {
PrintWriter writer = response.getWriter(); PrintWriter writer = response.getWriter();
String body = ""; String body = "";
@@ -156,6 +164,13 @@ public class BusProcessModelHisController {
downloadNetFile(downloadUri, file); downloadNetFile(downloadUri, file);
// 更新在线编辑当前节点编辑状态 // 更新在线编辑当前节点编辑状态
busProcessModelHisService.modelHisOneUpdStatus(pid,taskId); busProcessModelHisService.modelHisOneUpdStatus(pid,taskId);
QueryWrapper<BusProcessModelHis> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("P_ID",pid);
objectQueryWrapper.eq("TASK_ID",taskId);
BusProcessModelHis busProcessModelHis = busProcessModelHisMapper.selectOne(objectQueryWrapper);
if(busProcessModelHis!=null){
lawsUserInfoService.selectOnlineFile(busProcessModelHis.getId());
}
} }
} catch (Exception ex) { } catch (Exception ex) {
saved = 1; saved = 1;
@@ -3,14 +3,10 @@ package com.ydw.bat.wkflow.business_main.datas.service.impl;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; 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.BusProcessModelHis;
import com.ydw.bat.wkflow.business_main.datas.entity.OnlineFileLog; 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.mapper.BusProcessModelHisMapper;
import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessEvaluationHisService;
import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessModelHisService; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessModelHisService;
import com.ydw.bat.wkflow.listener.bussLibrary.Utils.PoiUtil;
import com.ydw.bat.wkflow.listener.bussLibrary.Utils.PoiWord; import com.ydw.bat.wkflow.listener.bussLibrary.Utils.PoiWord;
import org.apache.commons.io.FileUtils; import org.apache.commons.io.FileUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
@@ -154,7 +150,7 @@ public class BusProcessModelHisServiceImpl extends ServiceImpl<BusProcessModelHi
//获取当前文件路径 返回文件路径的数字组 //获取当前文件路径 返回文件路径的数字组
try { try {
String editFilePath = busProcessModelHis.getEditFilePath(); String editFilePath = busProcessModelHis.getEditFilePath();
File file = new File(editFilePath); File file = new File("/data/slrs/file/"+editFilePath);
FileInputStream fileInputStream = new FileInputStream(file); FileInputStream fileInputStream = new FileInputStream(file);
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(1024); ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(1024);
byte [] aByte = new byte[1024]; byte [] aByte = new byte[1024];
@@ -169,13 +165,15 @@ public class BusProcessModelHisServiceImpl extends ServiceImpl<BusProcessModelHi
onlineFileLog.setHisId(busProcessModelHis.getId()); onlineFileLog.setHisId(busProcessModelHis.getId());
onlineFileLog.setFilePath(busProcessModelHis.getEditFilePath()); onlineFileLog.setFilePath(busProcessModelHis.getEditFilePath());
if(StringUtils.isNotBlank(busProcessModelHis.getEditFilePath())){ if(StringUtils.isNotBlank(busProcessModelHis.getEditFilePath())){
String[] split = busProcessModelHis.getEditFilePath().split("/."); String[] split = busProcessModelHis.getEditFilePath().split("\\.");
onlineFileLog.setFileSuffix(split[1]); onlineFileLog.setFileSuffix(split[1]);
} }
if(StringUtils.isNotBlank(busProcessModelHis.getEditFilePath())){ if(StringUtils.isNotBlank(busProcessModelHis.getEditFilePath())){
String[] split = busProcessModelHis.getEditFilePath().split("/"); String[] split = busProcessModelHis.getEditFilePath().split("/");
onlineFileLog.setOldFileName(split[2]); String[] split1 = split[2].split("\\.");
onlineFileLog.setOldFileName(split1[0]);
} }
onlineFileLog.setBytes(bytes);
} }
return onlineFileLog; return onlineFileLog;
} }