0?total/sheelRow+1:total/sheelRow;
+ }
+
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/TaskCommonQuery.java b/adc-da-activiti/src/main/java/com/adc/da/common/TaskCommonQuery.java
new file mode 100644
index 00000000..926117d9
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/TaskCommonQuery.java
@@ -0,0 +1,40 @@
+package com.adc.da.common;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class TaskCommonQuery {
+
+ @ApiModelProperty(value = "当前页")
+ private int current;
+ @ApiModelProperty(value = "数量")
+ private int size;
+ @ApiModelProperty(value = "名称")
+ private String name;
+ @ApiModelProperty(value = "开始时间从")
+ private String startTime;
+ @ApiModelProperty(value = "到")
+ private String endTime;
+ @ApiModelProperty(value = "结束时间从")
+ private String finishStartTime;
+ @ApiModelProperty(value = "到")
+ private String finishEndTime;
+ @ApiModelProperty(value = "流程分类")
+ private String category_id;
+
+ @ApiModelProperty(value = "用户Id")
+ private String userId;
+
+ @ApiModelProperty(value = "流程名称")
+ private String prcName;
+
+ @ApiModelProperty(value = "流程编号")
+ private String prcNum;
+
+ @ApiModelProperty(value = "流程类型")
+ private String prcType;
+
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/TemplateOriData.java b/adc-da-activiti/src/main/java/com/adc/da/common/TemplateOriData.java
new file mode 100644
index 00000000..a2dcc2d4
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/TemplateOriData.java
@@ -0,0 +1,45 @@
+package com.adc.da.common;
+
+/**
+ * @Description:
+ * @Author: yangxuenan
+ * date: 2020/2/21 16:34
+ */
+public class TemplateOriData {
+ private String preMsg = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX。
本标准由广州汽车集团股份有限公司汽车工程研究院XXX提出。
本标准由广州汽车集团股份有限公司汽车工程研究院质量管理部归口。
本标准由广州汽车集团股份有限公司汽车工程研究院XXXX起草。
本标准由广州汽车集团股份有限公司汽车工程研究院XXXX解释。
本标准主要起草人：XXX、XXX、XXX。
本标准于20XX年XX月首次发布。
本标准于20XX年XX月进行第X次修订，标准修订人：XXX。
本次主要修订内容如下：
a) 增加内容的表述
——增加第X.X条XXXX的要求。
b）修改内容的表述
——第X.X条XXXX的要求由“XXX”改为“XXX”。
c）删除内容的表述
——删除原标准第X.X条XXXX的要求。
本标准所替代标准的历次版本发布情况为：
——QJ/GAC XXXX.XXX-XXXX。
";
+ private String titleOne = " 本标准规定了XXXX的术语和定义、技术要求、试验方法、检验规则和标志、包装、运输及贮存。
本标准适用于广汽研究院开发的乘用车用的XXXX。
";
+ private String titleTwo = " 下列文件对于本文件的应用是必不可少的。凡是注日期的引用文件，仅所注日期的版本适用于本文件。凡是不注日期的引用文件，其最新版本（包括所有的修改单）适用于本文件。
[国家标准]
[行业标准]
[地方标准]
[法规、规程、规范和其它有关文件]
[ISO标准]
[IEC标准]
[ISO、IEC有关文件]
[其它国际标准]
[其它国际有关文件]
[本企业已发布的院级标准]
";
+ private String titleThree = " 下列术语和定义适用于本标准。
";
+
+ public String getPreMsg() {
+ return preMsg;
+ }
+
+ public void setPreMsg(String preMsg) {
+ this.preMsg = preMsg;
+ }
+
+ public String getTitleOne() {
+ return titleOne;
+ }
+
+ public void setTitleOne(String titleOne) {
+ this.titleOne = titleOne;
+ }
+
+ public String getTitleTwo() {
+ return titleTwo;
+ }
+
+ public void setTitleTwo(String titleTwo) {
+ this.titleTwo = titleTwo;
+ }
+
+ public String getTitleThree() {
+ return titleThree;
+ }
+
+ public void setTitleThree(String titleThree) {
+ this.titleThree = titleThree;
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/TextCompare.java b/adc-da-activiti/src/main/java/com/adc/da/common/TextCompare.java
new file mode 100644
index 00000000..266a5916
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/TextCompare.java
@@ -0,0 +1,9 @@
+package com.adc.da.common;
+
+/**
+ * @Description:
+ * @Author: yangxuenan
+ * date: 2019/12/5 13:50
+ */
+public class TextCompare {
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/UploadFile.java b/adc-da-activiti/src/main/java/com/adc/da/common/UploadFile.java
new file mode 100644
index 00000000..6a96f877
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/UploadFile.java
@@ -0,0 +1,64 @@
+package com.adc.da.common;
+
+public class UploadFile {
+
+ private String id;
+
+ private String fileName;
+
+ private String oldFileName;
+
+ private String fileSuffix;
+
+ private String filePath;
+
+ private String attId;
+
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ public String getFileName() {
+ return fileName;
+ }
+
+ public void setFileName(String fileName) {
+ this.fileName = fileName;
+ }
+
+ public String getOldFileName() {
+ return oldFileName;
+ }
+
+ public void setOldFileName(String oldFileName) {
+ this.oldFileName = oldFileName;
+ }
+
+ public String getFileSuffix() {
+ return fileSuffix;
+ }
+
+ public void setFileSuffix(String fileSuffix) {
+ this.fileSuffix = fileSuffix;
+ }
+
+ public String getFilePath() {
+ return filePath;
+ }
+
+ public void setFilePath(String filePath) {
+ this.filePath = filePath;
+ }
+
+ public String getAttId() {
+ return attId;
+ }
+
+ public void setAttId(String attId) {
+ this.attId = attId;
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/UploadFileInfo.java b/adc-da-activiti/src/main/java/com/adc/da/common/UploadFileInfo.java
new file mode 100644
index 00000000..983d526b
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/UploadFileInfo.java
@@ -0,0 +1,36 @@
+package com.adc.da.common;
+
+/**
+ * @Description:
+ * @Author: yangxuenan
+ * date: 2020/1/9 18:59
+ */
+public class UploadFileInfo {
+ private String id;
+ private String filePath;
+ private String name;
+
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ public String getFilePath() {
+ return filePath;
+ }
+
+ public void setFilePath(String filePath) {
+ this.filePath = filePath;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/UseModuleEnum.java b/adc-da-activiti/src/main/java/com/adc/da/common/UseModuleEnum.java
new file mode 100644
index 00000000..ea7125c7
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/UseModuleEnum.java
@@ -0,0 +1,26 @@
+package com.adc.da.common;
+
+/**
+ * 标准库参数类型枚举设置
+ * @author gaoyan
+ * date 2018/09/03
+ */
+public enum UseModuleEnum {
+
+ SOURCE_FILE("SOURCE_FILE","源文件"),WEB_FILE("WEB_FILE","PC预览文件"),MOBLE_FILE("MOBLE_FILE","手机预览文件");
+
+ private String value;
+ private String lable;
+
+ private UseModuleEnum(String value, String lable) {
+ this.value = value;
+ this.lable = lable;
+ }
+ public String getValue() {
+ return value;
+ }
+ public String getLable() {
+ return lable;
+ }
+
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/WDWUtil.java b/adc-da-activiti/src/main/java/com/adc/da/common/WDWUtil.java
new file mode 100644
index 00000000..7abbc115
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/WDWUtil.java
@@ -0,0 +1,164 @@
+package com.adc.da.common;
+
+import org.apache.commons.lang3.StringUtils;
+
+import java.util.regex.Pattern;
+
+/**
+ * @des : excel版本判断类
+ * @author: duyunbao
+ * @email: 1114808306@qq.com
+ * @date 2017/10/27 16:59
+ **/
+public class WDWUtil {
+
+ /**
+ * @method_name: isExcel2003
+ * @des :是否是2003的excel，返回true是2003
+ * @author: duyunbao
+ * @param: [filePath]
+ * @return: boolean
+ * @date: 2017/10/27 16:57
+ **/
+ public static boolean isExcel2003(String filePath) {
+ return filePath.matches("^.+\\.(?i)(xls)$");
+ }
+
+ /**
+ * @method_name: isExcel2007
+ * @des : 是否是2007的excel，返回true是2007
+ * @author: duyunbao
+ * @param: [filePath]
+ * @return: boolean
+ * @date: 2017/10/27 16:57
+ **/
+ public static boolean isExcel2007(String filePath) {
+ return filePath.matches("^.+\\.(?i)(xlsx)$");
+ }
+
+
+ /**
+ * 判断字符串是否是整数
+ * @MethodName:isInteger
+ * @author: DuYunbao
+ * @date: 2018/5/22 18:00
+ */
+ public static boolean isNumeric(String str){
+ for (int i = str.length();--i>=0;){
+ if (!Character.isDigit(str.charAt(i))){
+ return false;
+ }
+ }
+ return true;
+ }
+
+ /**方法二：推荐，速度最快
+ * 判断是否为整数
+ * @param str 传入的字符串
+ * @return 是整数返回true,否则返回false
+ */
+ public static boolean isInteger(String str) {
+ Pattern pattern = Pattern.compile("^[-\\+]?[\\d]*$");
+ return pattern.matcher(str).matches();
+ }
+
+ /**
+ * 字母或数字
+ *
+ * @MethodName:isLetterDigitOrChinese
+ * @author: DuYunbao
+ * @date: 2018/5/30 15:26
+ */
+ public static boolean isLetterOrNumber(String str) {
+ String regex = "^(\\d|[a-zA-Z])+$";
+ return !str.matches(regex);
+ }
+
+ /**
+ * 汉字、字母、（）
+ *
+ * @MethodName:isLetterOrChineseOrChar1
+ * @author: DuYunbao
+ * @date: 2018/5/30 15:53
+ */
+ public static boolean isLetterOrChineseOrChar1(String str) {
+ String regex = "[^\\a-\\z\\A-\\Z\\u4E00-\\u9FA5\\（）\\()]";
+ return str.matches(regex);
+ }
+
+ /**
+ * 汉字、字母、数字
+ *
+ * @MethodName:isLetterOrChineseOrNumber
+ * @author: DuYunbao
+ * @date: 2018/5/30 15:56
+ */
+ public static boolean isLetterOrChineseOrNumber(String str) {
+ String regex = "^[\\u4E00-\\u9FA5A-Za-z0-9]+$";
+ return !str.matches(regex);
+ }
+
+ /**
+ * 汉字、字母、（）、-、下划线
+ *
+ * @MethodName:isChineseOrLetterOrUnderlineOrChar1
+ * @author: DuYunbao
+ * @date: 2018/5/30 16:03
+ */
+ public static boolean isChineseOrLetterOrUnderlineOrChar1(String str) {
+ String regex = "^[\\u4E00-\\u9FA5A-Za-z_\\-\\（）\\()]+$";
+ return !str.matches(regex);
+ }
+
+ /**
+ * 数字
+ *
+ * @MethodName:isNumbee
+ * @author: DuYunbao
+ * @date: 2018/5/30 16:09
+ */
+ public static boolean isNumber(String str) {
+ String regex = "\\D";
+ return str.matches(regex);
+ }
+
+ /**
+ * 数字、大写字母、-
+ *
+ * @MethodName:isNumberOrLowerLetterOrChar1
+ * @author: DuYunbao
+ * @date: 2018/5/30 16:41
+ */
+ public static boolean isNumberOrLowerLetterOrChar1(String str) {
+ String regex = "^[A-Z0-9\\-]+$";
+ return !str.matches(regex);
+ }
+
+ /**
+ * 汉字、数字、字母、（）、-、下划线
+ *
+ * @MethodName:isChineseOrNumberOrLetterOrUnderlineOrChar
+ * @author: DuYunbao
+ * @date: 2018/5/30 16:45
+ */
+ public static boolean isChineseOrNumberOrLetterOrUnderlineOrChar(String str) {
+ String regex = "^[\\u4E00-\\u9FA5A-Za-z0-9_\\-\\（）\\()]+$";
+ return !str.matches(regex);
+ }
+
+
+ /**
+ * 去除整数含有小数点
+ * @MethodName:subStr
+ * @author: DuYunbao
+ * @date: 2018/5/31 11:19
+ */
+ public static String subStr(String text) {
+ if (StringUtils.isNotEmpty(text)) {
+ if(text.contains(".0") && text.substring(text.length()-2,text.length()).equals(".0")) {
+ text = text.substring(0,text.length()-2);
+ }
+ }
+ return text;
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/WarnPutTypeEnum.java b/adc-da-activiti/src/main/java/com/adc/da/common/WarnPutTypeEnum.java
new file mode 100644
index 00000000..b670c489
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/WarnPutTypeEnum.java
@@ -0,0 +1,30 @@
+package com.adc.da.common;
+
+/**
+ * 标准法规分类
+ * @author gaoyan
+ * date 2018/09/19
+ */
+public enum WarnPutTypeEnum {
+
+ NEWCAR("NEWCAR","新定车型"),NEWPRODUCT("NEWPRODUCT","新生产车型"),
+ PRODUCT("PRODUCT","在产车型");
+
+ private String value;
+ private String lable;
+
+ private WarnPutTypeEnum(String value, String lable) {
+ this.value = value;
+ this.lable = lable;
+ }
+ public String getValue() {
+ return value;
+ }
+ public String getLable() {
+ return lable;
+ }
+
+
+
+
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/WarnTimeEnum.java b/adc-da-activiti/src/main/java/com/adc/da/common/WarnTimeEnum.java
new file mode 100644
index 00000000..9a8e3725
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/WarnTimeEnum.java
@@ -0,0 +1,33 @@
+package com.adc.da.common;
+
+/**
+ * 预警时间间隔
+ * @author syt
+ * date 2018/09/19
+ */
+public enum WarnTimeEnum {
+
+ THREEMONTH("THREEMONTH","三个月",3),SIXMONTH("SIXMONTH","六个月",6),
+ ONEYEAR("ONEYEAR","一年",12),TWOYEAR("TWOYEAR","两年",24);
+
+ private String value;
+ private String lable;
+ private int month;
+
+ private WarnTimeEnum(String value, String lable,int month) {
+ this.value = value;
+ this.lable = lable;
+ this.month = month;
+ }
+ public String getValue() {
+ return value;
+ }
+ public String getLable() {
+ return lable;
+ }
+
+
+ public int getMonth() {
+ return month;
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/common/Wrapper.java b/adc-da-activiti/src/main/java/com/adc/da/common/Wrapper.java
new file mode 100644
index 00000000..ebf1743f
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/common/Wrapper.java
@@ -0,0 +1,94 @@
+package com.adc.da.common;
+
+import java.io.Serializable;
+
+public class Wrapper implements Serializable {
+ private static final long serialVersionUID = 1L;
+ public static final int SUCCESS_CODE = 200;
+ public static final String SUCCESS_MESSAGE = "操作成功";
+ public static final int ERROR_CODE = 500;
+ public static final String ERROR_MESSAGE = "内部异常";
+ public static final int ILLEGAL_ARGUMENT_CODE_ = 100;
+ public static final String ILLEGAL_ARGUMENT_MESSAGE = "参数非法";
+ private boolean success;
+ private int code;
+ private String message;
+ private T result;
+
+ Wrapper() {
+ this(200, "操作成功");
+ }
+
+ Wrapper(int code, String message) {
+ this(code, message, (T) null);
+ }
+
+ Wrapper(int code, String message, T result) {
+ this.success = true;
+ this.code(code).message(message).result(result);
+ }
+
+ private Wrapper code(int code) {
+ this.setCode(code);
+ return this;
+ }
+
+ private Wrapper message(String message) {
+ this.setMessage(message);
+ return this;
+ }
+
+ public Wrapper result(T result) {
+ this.setResult(result);
+ return this;
+ }
+
+ public boolean success() {
+ return 200 == this.code;
+ }
+
+ public boolean error() {
+ return !this.success();
+ }
+
+ public boolean isSuccess() {
+ return this.success;
+ }
+
+ public int getCode() {
+ return this.code;
+ }
+
+ public String getMessage() {
+ return this.message;
+ }
+
+ public T getResult() {
+ return this.result;
+ }
+
+ public void setSuccess(boolean success) {
+ this.success = success;
+ }
+
+ public void setCode(int code) {
+ this.code = code;
+ }
+
+ public void setMessage(String message) {
+ this.message = message;
+ }
+
+ public void setResult(T result) {
+ this.result = result;
+ }
+
+ protected boolean canEqual(Object other) {
+ return other instanceof Wrapper;
+ }
+
+
+ public String toString() {
+ return "Wrapper(success=" + this.isSuccess() + ", code=" + this.getCode() + ", message=" + this.getMessage() + ", result=" + this.getResult() + ")";
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/common/ExportExcel.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/common/ExportExcel.java
new file mode 100644
index 00000000..0460891c
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/common/ExportExcel.java
@@ -0,0 +1,99 @@
+package com.adc.da.workFlow.common;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import org.apache.commons.lang.StringUtils;
+import org.apache.poi.ss.usermodel.*;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+import sun.awt.SunHints;
+
+
+import java.util.List;
+import java.util.Map;
+
+public class ExportExcel {
+
+ private String header;
+
+ private static String[] property;
+ Workbook workbook=new XSSFWorkbook();
+
+ public void setProperty(String property){
+ this.property=property.split(",");
+ }
+
+ public void setHeader(String header){
+ this.header=header;
+ }
+
+ public Workbook getWorkBook(T dataJson) throws Exception {
+ JSONArray dataArray = JSONObject.parseArray(dataJson.toString());
+
+ CellStyle cellStyle = workbook.createCellStyle();//初始化单元格格式对象
+ cellStyle.setAlignment(HorizontalAlignment.CENTER);
+
+
+ Sheet sheet = workbook.createSheet();
+ sheet.setDefaultColumnWidth(25);
+
+ createHeader(sheet,header);
+
+ createData(sheet,dataArray);
+
+ return workbook;
+ }
+
+
+ public static void createHeader(Sheet sheet, String header){
+
+ Row rowHeader = sheet.createRow(0);//开始创建标题行
+ if (StringUtils.isNotBlank(header)) {
+ String[] headerArr = header.split(",");
+ for (int i=0;i < headerArr.length; i++) {
+
+ rowHeader.createCell(i).setCellValue(headerArr[i]);
+
+ }
+ }
+ }
+
+
+
+ public static void createData(Sheet sheet, List data) throws Exception{
+
+ if (data != null && !data.isEmpty()) {
+ for (int i=0;i < data.size(); i++) {
+
+ Row row = sheet.createRow(i+1);
+
+ int sheetNum = 0;
+
+ JSONObject datumJson =(JSONObject)data.get(i);
+ /**
+ * 遍历jsonObject值填入一行的单元格中
+ */
+ for (String s : property) {
+ String value = datumJson.getString(s);
+ row.createCell(sheetNum).setCellValue(value);
+ sheetNum++;
+ }
+// Class cls = importDto.getClass();
+// Field[] fields = cls.getDeclaredFields();
+// for (Field field : fields) {
+// field.setAccessible(true);
+// if (field.get(importDto)!=null){
+// String value = field.get(importDto).toString();
+// row.createCell(sheetNum).setCellValue(value);
+// }else {
+// row.createCell(sheetNum).setCellValue("");
+// }
+// sheetNum++;
+// }
+ }
+ }
+ }
+
+
+
+
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsBussEOController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsBussEOController.java
new file mode 100644
index 00000000..b7628543
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsBussEOController.java
@@ -0,0 +1,124 @@
+package com.adc.da.workFlow.controller;
+
+
+import com.adc.da.base.web.BaseController;
+import com.adc.da.http.ResponseMessage;
+import com.adc.da.http.Result;
+import com.adc.da.slrs.sarStandardsInfo.entity.ActSarItemsEO;
+import com.adc.da.workFlow.entity.GetQBZXDExcelDto;
+import com.adc.da.workFlow.service.ActSarItemsBussEOService;
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.fastjson.JSON;
+import com.google.common.collect.Lists;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.net.URLEncoder;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@RestController
+@RequestMapping("/${restPath}/lawss/actSarItemsBuss")
+@Api(description = "|ActSarItemsBuss|")
+public class ActSarItemsBussEOController extends BaseController {
+
+ @Autowired
+ private ActSarItemsBussEOService actSarItemsEOService;
+
+// private static final Logger logger = LoggerFactory.getLogger(AttFileEOController.class);
+
+ @ApiOperation(value = "|SarBussionessStand|企标复审入库流程")
+ @PostMapping("/processCreateFsBuss")
+ public ResponseMessage processCreateFsBuss(String infoJson) throws Exception {
+ if (StringUtils.isNotBlank(infoJson)) {
+ actSarItemsEOService.processCreateFsBuss(infoJson);
+ return Result.success("入库成功");
+ } else {
+ return Result.error("传入数据json不能为空");
+ }
+ }
+
+ @ApiOperation(value = "|SarBussionessStand|企标入库流程")
+ @PostMapping("/processCreateBuss")
+ public ResponseMessage processCreateBuss(String infoJson) throws Exception {
+ if (StringUtils.isNotBlank(infoJson)) {
+ String bussId = actSarItemsEOService.processCreateBuss(infoJson);
+ return Result.success(bussId);
+ } else {
+ return Result.error("传入数据json不能为空");
+ }
+ }
+
+ @ApiOperation(value = "手动更新")
+ @GetMapping("/autoUpdIndex")
+ public void autoUpdIndex(@RequestParam("pid") String pid,@RequestParam("bussId") String bussId) {
+ actSarItemsEOService.autoUpdIndex(pid,bussId);
+ }
+
+ @ApiOperation(value = "导出全部意见-企标制修订-技术标准-起草单位高级经理审核节点")
+ @PostMapping("/exportAllBZZXDJSBZ")
+ public void getAllStandYJCL(HttpServletResponse response, @RequestBody Map params){
+ try {
+ net.sf.json.JSONArray jsonArray = net.sf.json.JSONArray.fromObject(params.get("json"));
+ List> data = (List>) jsonArray;
+
+ response.setContentType("application/vnd.ms-excel");
+ response.setCharacterEncoding("utf-8");
+ String textName="意见信息";
+
+ Map map=new HashMap<>();
+ map.put("1","采纳");
+ map.put("2","部分采纳");
+ map.put("3","不采纳");
+ String fileName = URLEncoder.encode(textName, "UTF-8").replaceAll("\\+", "%20");
+ response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName + ".xlsx");
+
+ data = data.stream().sorted(Comparator.comparing(m->m.get("modelNum"))).collect(Collectors.toList());
+ List standExcel=new ArrayList<>();
+ int i=0;
+ for (Map idea : data){
+ i++;
+ GetQBZXDExcelDto getExcelDto = GetQBZXDExcelDto.builder()
+ .partCode(idea.get("modelNum"))
+ .oldText(idea.get("modelUpdBefore"))
+ .newText(idea.get("modelUpdAfter"))
+ .reason(idea.get("modelContent"))
+ .userName(idea.get("zrUserIdName"))
+ .deptName(idea.get("zrDeptIdName"))
+ .state(map.get(idea.get("opinionsAdopted")))
+ .cause(idea.get("opinionsAdoptedCont"))
+ .num(String.valueOf(i))
+ .build();
+ standExcel.add(getExcelDto);
+ }
+
+ List> headList=new ArrayList>();
+ headList.add(Lists.newArrayList("序号"));
+ headList.add(Lists.newArrayList("条款号"));
+ headList.add(Lists.newArrayList("修改前"));
+ headList.add(Lists.newArrayList("修改后"));
+ headList.add(Lists.newArrayList("修改理由"));
+ headList.add(Lists.newArrayList("提出部门"));
+ headList.add(Lists.newArrayList("责任人"));
+ headList.add(Lists.newArrayList("意见是否采纳"));
+ headList.add(Lists.newArrayList("采纳原因"));
+ EasyExcel.write(response.getOutputStream(), GetQBZXDExcelDto.class).head(headList).autoCloseStream(Boolean.FALSE).sheet("sheet1")
+ .doWrite(standExcel);
+
+ } catch (Exception e) {
+ response.reset();
+ response.setContentType("application/json");
+ response.setCharacterEncoding("utf-8");
+ try {
+ response.getWriter().println(JSON.toJSONString(Result.error()));
+ } catch (IOException ioException) {
+ ioException.printStackTrace();
+ }
+ }
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsEOController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsEOController.java
new file mode 100644
index 00000000..321dbdd1
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsEOController.java
@@ -0,0 +1,39 @@
+package com.adc.da.workFlow.controller;
+
+
+import com.adc.da.base.web.BaseController;
+import com.adc.da.http.ResponseMessage;
+import com.adc.da.http.Result;
+import com.adc.da.slrs.sarStandardsInfo.entity.ActSarItemsEO;
+import com.adc.da.workFlow.service.ActSarItemsEOService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping("/${restPath}/lawss/actSarItems")
+@Api(description = "|ActSarItemsEO|")
+public class ActSarItemsEOController extends BaseController {
+
+ @Autowired
+ private ActSarItemsEOService actSarItemsEOService;
+
+// private static final Logger logger = LoggerFactory.getLogger(AttFileEOController.class);
+
+ @Value("${file.path}")
+ private String filePath;//文件存储路径
+
+ @ApiOperation(value = "|SarStandardsInfoEO|标准入库流程标准入库")
+ @PostMapping("/processCreateStand")
+ public ResponseMessage processCreateStand(String infoJson) throws Exception {
+ if (StringUtils.isNotBlank(infoJson)) {
+ actSarItemsEOService.processCreateStand(infoJson);
+ return Result.success("入库成功");
+ } else {
+ return Result.error("传入数据json不能为空");
+ }
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsLawsEOController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsLawsEOController.java
new file mode 100644
index 00000000..db5475cf
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsLawsEOController.java
@@ -0,0 +1,39 @@
+package com.adc.da.workFlow.controller;
+
+
+import com.adc.da.base.web.BaseController;
+import com.adc.da.http.ResponseMessage;
+import com.adc.da.http.Result;
+import com.adc.da.slrs.sarStandardsInfo.entity.ActSarItemsEO;
+import com.adc.da.workFlow.service.ActSarItemsEOService;
+import com.adc.da.workFlow.service.ActSarItemsLawsEOService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/${restPath}/lawss/actSarItemsLaws")
+@Api(description = "|ActSarItemsEO|")
+public class ActSarItemsLawsEOController extends BaseController {
+
+ @Autowired
+ private ActSarItemsLawsEOService actSarItemsEOService;
+
+// private static final Logger logger = LoggerFactory.getLogger(AttFileEOController.class);
+
+ @ApiOperation(value = "|SarLawsStandInfo|政策入库流程")
+ @PostMapping("/processCreateLaws")
+ public ResponseMessage processCreateLaws(String infoJson) throws Exception {
+ if (StringUtils.isNotBlank(infoJson)) {
+ actSarItemsEOService.processCreateLaws(infoJson);
+ return Result.success("入库成功");
+ } else {
+ return Result.error("传入数据json不能为空");
+ }
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsPlanController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsPlanController.java
new file mode 100644
index 00000000..722ad877
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarItemsPlanController.java
@@ -0,0 +1,41 @@
+package com.adc.da.workFlow.controller;
+
+
+import com.adc.da.base.web.BaseController;
+import com.adc.da.http.ResponseMessage;
+import com.adc.da.http.Result;
+import com.adc.da.slrs.sarStandardsInfo.entity.ActSarItemsEO;
+import com.adc.da.workFlow.service.ActSarItemsEOService;
+import com.adc.da.workFlow.service.ActSarItemsPlanService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/${restPath}/lawss/actSarItemsPlan")
+@Api(tags = "业务系统立项流程入库")
+public class ActSarItemsPlanController {
+
+ @Autowired
+ private ActSarItemsPlanService actSarItemsEOService;
+
+// private static final Logger logger = LoggerFactory.getLogger(AttFileEOController.class);
+
+ @Value("${file.path}")
+ private String filePath;//文件存储路径
+
+ @ApiOperation(value = "立项入库流程入库")
+ @PostMapping("/processCreatePlan")
+ public ResponseMessage processCreatePlan(String infoJson) throws Exception {
+ if (StringUtils.isNotBlank(infoJson)) {
+ return Result.success("200","入库成功",actSarItemsEOService.processCreatePlan(infoJson));
+ } else {
+ return Result.error("传入数据json不能为空");
+ }
+ }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/PolicyWorkFlowController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/PolicyWorkFlowController.java
new file mode 100644
index 00000000..f961bf6a
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/PolicyWorkFlowController.java
@@ -0,0 +1,69 @@
+package com.adc.da.workFlow.controller;
+
+import com.adc.da.common.ReadExcel;
+import com.adc.da.http.ResponseMessage;
+import com.adc.da.http.Result;
+import com.adc.da.workFlow.common.ExportExcel;
+import com.adc.da.workFlow.service.PolicyWorkFlowService;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+
+@RestController
+@RequestMapping("/${restPath}/policy/activiti")
+@Api(tags = "政策征求意见和重点法规或政策认证流程")
+public class PolicyWorkFlowController {
+
+
+ /**
+ * 政策征求意见导出
+ */
+ @PostMapping("/exportExcel")
+ @ApiOperation("导出政策征求意见为excel")
+ public void exportExcel(@RequestBody String dataJson, HttpServletResponse response, HttpServletRequest request) throws Exception {
+ JSONObject data = JSONObject.parseObject(dataJson);
+ JSONArray info = data.getJSONArray("dataList");
+
+
+ ExportExcel exportExcel = new ExportExcel();
+ exportExcel.setHeader("章节编号,章节名称,修改前,修改后,修改理由,原因,提出部门,提出人");
+ exportExcel.setProperty("chapterNumber,chapterName,oldText,newText,changeReason,reason,department,responUserName");
+ Workbook workbook=exportExcel.getWorkBook(info);
+
+
+ response.setContentType("application/vnd.ms-excel");
+ response.setHeader("Content-Disposition",
+ "attachment; filename=" + ReadExcel.encodeFileName("政策征求意见"+".xlsx",request));
+// response.setContentType("application/force-download");
+ ServletOutputStream outputStream = response.getOutputStream();
+ workbook.write(outputStream);
+ outputStream.flush();
+
+ }
+
+
+
+ @Autowired
+ private PolicyWorkFlowService policyWorkFlowService;
+
+ /**
+ * 纳入重点问题管控
+ */
+ @PostMapping("/enterIssue")
+ @ApiOperation("纳入重点问题管控")
+ public ResponseMessage enterIssue(@RequestBody String json){
+ boolean result = policyWorkFlowService.enterIssue(json);
+
+ return Result.success(result);
+ }
+
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java
new file mode 100644
index 00000000..3c6c4c82
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java
@@ -0,0 +1,956 @@
+package com.adc.da.workFlow.controller;
+
+import cn.afterturn.easypoi.excel.ExcelExportUtil;
+import cn.afterturn.easypoi.excel.entity.ExportParams;
+import cn.afterturn.easypoi.excel.entity.enmus.ExcelType;
+import cn.hutool.core.lang.UUID;
+import com.adc.da.FeignClientImpl.workFlowFeignClientImpl;
+import com.adc.da.Timer.ProcessTimer;
+import com.adc.da.common.*;
+import com.adc.da.exception.AdcDaBaseException;
+import com.adc.da.http.PageInfo;
+import com.adc.da.http.ResponseMessage;
+import com.adc.da.http.Result;
+import com.adc.da.common.Page;
+import com.adc.da.login.util.JwtUtils;
+import com.adc.da.slrs.esRevisePlan.dao.EsRevisePlanDao;
+import com.adc.da.slrs.esRevisePlan.entity.EsRevisePlan;
+import com.adc.da.slrs.esRevisePlan.service.IEsRevisePlanLogService;
+import com.adc.da.slrs.esRevisePlan.service.IEsRevisePlanService;
+import com.adc.da.slrs.sarUser.entity.TsUser;
+import com.adc.da.slrs.sarUser.service.ITsUserService;
+import com.adc.da.sys.common.EmailUtils;
+import com.adc.da.sys.entity.UserEO;
+import com.adc.da.sys.service.IUserEOService;
+import com.adc.da.util.LoginUserUtil;
+import com.adc.da.workFlow.dao.ExportExcelMapper;
+import com.adc.da.workFlow.entity.*;
+import com.adc.da.workFlow.service.WorkFlowService;
+import com.alibaba.fastjson.JSON;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.util.IOUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.*;
+import sun.misc.BASE64Encoder;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.URLConnection;
+import java.net.URLEncoder;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@RestController
+@RequestMapping("/${restPath}/lawss/activiti")
+@Api(tags = "福田标准法规-工作流管理")
+public class WorkFlowController {
+
+ private static final Logger logger = LoggerFactory.getLogger(WorkFlowController.class);
+
+ @Autowired
+ private workFlowFeignClientImpl workFlowFeignClient;
+
+ @Value("${stand.edit.file.path}")
+ private String standEditFilePath;
+
+ /**
+ * 文件下载路径
+ */
+ @Value("${file.downloadUrl}")
+ private String downloadUrl;
+
+ @Autowired
+ private JwtUtils jwtUtils;
+
+ @Autowired
+ private ITsUserService userService;
+
+ @Autowired
+ private IEsRevisePlanService iEsRevisePlanService;
+
+ @Autowired
+ private EsRevisePlanDao esRevisePlanDao;
+
+ @Autowired
+ private IEsRevisePlanLogService esRevisePlanLogService;
+
+// @Autowired
+// private ExportExcelMapper exportExcelMapper;
+
+ @ApiOperation(value = "|File|下载文件")
+ @GetMapping("/downloadFileForSar")
+ // @RequiresPermissions("sys:file:downloadFileForSar")
+ public void downloadFileForSar(String fileId, String oldFileName, HttpServletResponse response, HttpServletRequest request) throws Exception {
+ BusProcessModelHis modelHisOne = workFlowFeignClient.processEditFile(fileId);
+ OutputStream os = null;
+ // fileUrl为http或https链接
+ InputStream inputStream = null;
+ HttpURLConnection conn = null;
+ response.reset();
+ File file = new File(downloadUrl+modelHisOne.getEditFilePath());
+
+ if(file.exists()){
+ try {
+ String fileOldName = fileNameEncoding(oldFileName,request);
+ response.setHeader("Content-Disposition", "attachment;filename=\""+fileOldName+"\"");
+ response.setContentType("application/octet-stream");
+ inputStream = new FileInputStream(file);
+ os = response.getOutputStream();
+ org.apache.commons.io.IOUtils.copy(inputStream, os);
+ os.flush();
+ } catch (IOException e) {
+ logger.error(e.getMessage(), e);
+ } finally {
+ org.apache.commons.io.IOUtils.closeQuietly(inputStream);
+ org.apache.commons.io.IOUtils.closeQuietly(os);
+ }
+ }else {
+ URL url;
+ try {
+ String fileOldName = fileNameEncoding(oldFileName,request);
+ response.setHeader("Content-Disposition", "attachment;filename=\""+fileOldName+"\"");
+ response.setContentType("application/octet-stream");
+ url = new URL(downloadUrl+modelHisOne.getEditFilePath());
+ conn = (HttpURLConnection) url.openConnection();
+ // 设置超时间为5秒
+ conn.setConnectTimeout(3 * 1000);
+ // 得到输入流
+ inputStream = conn.getInputStream();
+ os = response.getOutputStream();
+ IOUtils.copy(inputStream, os);
+ os.flush();
+ //生成本地文件之类的省略了
+ } catch (Exception e) {
+ logger.error(e.getMessage(), e);
+ } finally {
+ if (conn != null) {
+ conn.disconnect();
+ }
+ try {
+ if (inputStream != null) {
+ inputStream.close();
+ }
+ IOUtils.closeQuietly(os);
+ } catch (IOException e) {
+ logger.error(e.getMessage(), e);
+ }
+ }
+ }
+ }
+
+ /**
+ * @Author super_liu
+ * @Description 根据不同浏览器定义下载文件编码
+ * Date 2018/10/11 10:40
+ * @Param [fileName, request]
+ * @return java.lang.String
+ **/
+ public String fileNameEncoding(String fileName, HttpServletRequest request) throws IOException {
+ String agent = request.getHeader("User-Agent");
+ if (agent.contains("Firefox")) {
+ /*BASE64Encoder base64Encoder = new BASE64Encoder();
+ fileName = "=?utf-8?B?"
+ + base64Encoder.encode(fileName.getBytes("utf-8")) + "?=";*/
+ fileName = new String(fileName.getBytes("UTF-8"), "ISO8859-1"); // firefox浏览器
+ } else {
+ fileName = URLEncoder.encode(fileName, "utf-8");
+ //谷歌中空格变为+问题
+ fileName = fileName.replaceAll("\\+","%20");
+ }
+ return fileName;
+ }
+
+ @ApiOperation(value = "存储在线编辑文件")
+ @GetMapping("/saveEditFile")
+ public BusProcessModelHis saveEditFile(String model){
+ return workFlowFeignClient.saveEditFile(model);
+ }
+
+ @ApiOperation(value = "查询在线编辑流程汇总文件编辑对象")
+ @GetMapping("/processEditFile")
+ public BusProcessModelHis processEditFile(@RequestParam("id") String id){
+ return workFlowFeignClient.processEditFile(id);
+ }
+
+ @ApiOperation(value = "手机获取token")
+ @PostMapping(value = "/loginMobile")
+ @ResponseBody
+ public ResponseMessage loginMobile(String taskIds, String pId) throws UnsupportedEncodingException {
+ BusProcessNew busProcessNew = workFlowFeignClient.queryDetail(taskIds);
+ if(busProcessNew == null || StringUtils.isBlank(busProcessNew.getUserId())){
+ return Result.error("r0011", "用户不存在");
+ }
+ TsUser userEO = userService.getById(busProcessNew.getUserId());
+ if (null == userEO) {
+ return Result.error("r0011", "用户不存在");
+ }
+ if(userEO.getDisableFlag().equals("1")){
+ return Result.error("r0011", "帐号已禁用");
+ }
+ String token = jwtUtils.generateToken(userEO.getUserId());
+ userEO.setToken(token);
+ // 加密重要信息
+ BASE64Encoder encoder = new BASE64Encoder();
+ String userStr = JSON.toJSONString(userEO);
+ String userStr2 = URLEncoder.encode(userStr,"UTF-8");
+ userStr = encoder.encode(userStr2.getBytes());
+ return Result.success(userStr);
+ }
+
+
+
+ @ApiOperation(value = "查询在线编辑流程汇总文件编辑对象")
+ @GetMapping("/processModelHisOneCount")
+ public BusProcessModelHis processModelHisOneCount(@RequestParam("pid") String pid){
+ return workFlowFeignClient.processModelHisOneCount(pid);
+ }
+
+ @ApiOperation(value = "更新在线编辑流程当前节点编辑状态")
+ @GetMapping("/processModelHisOneUpd")
+ public BusProcessModelHis processModelHisOneUpd(@RequestParam("pid") String pid,@RequestParam("taskId") String taskId){
+ return workFlowFeignClient.processModelHisOneUpdStatus(pid,taskId);
+ }
+
+ @ApiOperation(value = "查询在线编辑流程当前节点编辑对象")
+ @GetMapping("/processModelHisOne")
+ public BusProcessModelHis processModelHisOne(@RequestParam("pid") String pid,@RequestParam("taskId") String taskId){
+ return workFlowFeignClient.processModelHisOne(pid,taskId);
+ }
+
+ @ApiOperation(value = "根据pid 节点信息查询")
+ @GetMapping("/evaluationHisListByOne")
+ public BusProcessEvaluationHis evaluationHisListByOne(@RequestParam("pid") String pid,@RequestParam("taskInfo") String taskInfo){
+ return workFlowFeignClient.evaluationHisListByOne(pid,taskInfo);
+ }
+
+ @ApiOperation(value = "查询流程父节点所有评分(去重)返回节点评分总数")
+ @GetMapping("/evaluationHisListRepSum")
+ public Map evaluationHisListRepSum(@RequestParam("pid") String pid){
+ return workFlowFeignClient.evaluationHisListRepSum(pid);
+ }
+
+ @ApiOperation(value = "查询流程父节点所有评分(去重)")
+ @GetMapping("/evaluationHisListRep")
+ public List evaluationHisListRep(@RequestParam("pid") String pid){
+ return workFlowFeignClient.evaluationHisListRep(pid);
+ }
+
+ @ApiOperation(value = "查询流程父节点所有评分")
+ @GetMapping("/evaluationHisList")
+ public List evaluationHisList(@RequestParam("pid") String pid){
+ return workFlowFeignClient.evaluationHisList(pid);
+ }
+
+ @ApiOperation(value = "干活流程接收待办")
+ @GetMapping("/execTask")
+ public Map execTask(@RequestParam("todoId") String todoId){
+ return workFlowFeignClient.execTask(todoId);
+ }
+
+ @ApiOperation(value = "管控流程接收任务")
+ @GetMapping("/acceptTack")
+ public Integer acceptTack(@RequestParam("nowEsId") String nowEsId, @RequestParam("oaFlag") String oaFlag, @RequestParam("taskId") String taskId) {
+ return workFlowFeignClient.acceptTack(nowEsId,oaFlag,taskId);
+ }
+
+ @ApiOperation(value = "管控流程判断接收任务")
+ @GetMapping("/judgeAcceptTack")
+ public ResponseMessage judgeAcceptTack(@RequestParam("nowEsId") String nowEsId, @RequestParam("oaFlag") String oaFlag, @RequestParam("prcIdGk") String prcIdGk) {
+ return Result.success(workFlowFeignClient.judgeAcceptTack(nowEsId,oaFlag,prcIdGk));
+ }
+
+ @ApiOperation(value = "流程实例明细验证是否完成")
+ @GetMapping("/get_verify_by_instance")
+ public Map activiti_define_start1(@RequestParam("taskId") String taskId, @RequestParam("pId") String pId){
+ return workFlowFeignClient.get_verify_by_instance(taskId,pId);
+ }
+
+ @ApiOperation(value = "导出excel")
+ @PostMapping("/export_excel")
+ public void exportExcel(@RequestBody ExportExcelEO exportExcelEO, HttpServletResponse response, HttpServletRequest request) throws IOException {
+
+// ExportExcel exportExcel = exportExcelMapper.selectById(id);
+// if(exportExcel==null||exportExcel.getJson()==null)return;
+// ExportExcelEO exportExcelEO=JSON.parseObject(exportExcel.getJson(),ExportExcelEO.class);
+
+ if(exportExcelEO.getFileName()==null||exportExcelEO.getFileName().trim().length()==0){
+ exportExcelEO.setFileName(UUID.fastUUID().toString(true));
+ }
+ List> dataList = exportExcelEO.getDataList().stream()
+ .sorted(Comparator.comparing(a -> String.valueOf(a.get("chapterNumber").toString())))
+ .collect(Collectors.toList());
+
+ Workbook excel = TableToExcel.createExcel(exportExcelEO.getColumnName(), dataList, null, exportExcelEO.getFileName());
+
+ response.reset();
+
+ response.setContentType("application/vnd.ms-excel");
+
+ response.setHeader("Content-disposition", "attachment; filename=" + exportExcelEO.getFileName() + ".xls");
+ OutputStream outputStream = response.getOutputStream();
+
+ excel.write(outputStream);
+ outputStream.flush();
+ outputStream.close();
+ }
+
+// @ApiOperation(value = "导出excel数据暂留")
+// @PostMapping("/save_excel")
+// public ResponseMessage saveExcel(@RequestBody ExportExcel exportExcel){
+//
+// exportExcelMapper.insert(exportExcel);
+// return Result.success(exportExcel);
+//
+// }
+
+
+
+ @ApiOperation(value = "启动流程-以流程定义id")
+ @GetMapping("/activiti_define_start")
+ public ResponseMessage activiti_define_start(@RequestParam("id") String id, @RequestParam("userId") String userId, @RequestParam(value = "bpnId",required = false) String bpnId){
+ return workFlowFeignClient.activiti_define_start(id,userId,bpnId);
+ }
+
+ @ApiOperation(value = "启动流程-以流程定义id")
+ @GetMapping("/activiti_define_start_rollBack")
+ public ResponseMessage activiti_define_start_rollBack(@RequestParam("id") String id, @RequestParam("userId") String userId,
+ @RequestParam(value = "bpnId",required = false) String bpnId,@RequestParam(value = "json",required = false)String json){
+ return workFlowFeignClient.activiti_define_start_rollBack(id,userId,bpnId,json);
+ }
+ @ApiOperation(value = "启动流程-以流程定义id")
+ @GetMapping("/activiti_define_start1")
+ public Map activiti_define_start1(@RequestParam("id") String id, @RequestParam("userId") String userId, @RequestParam("standName") String standName){
+ return workFlowFeignClient.activiti_define_start1(id,userId,standName);
+ }
+
+ @ApiOperation(value = "启动流程-以流程定义id")
+ @GetMapping("/startProcess")
+ public ResponseMessage startProcess(@RequestParam("type") String type, @RequestParam(value="id",required = false) String id){
+ if(StringUtils.isNotBlank(type)){
+ return this.activiti_define_start(ActDefineStartMap.actDefineStartMap(type), LoginUserUtil.getUserId(),id);
+ }else {
+ return null;
+ }
+ }
+
+ @ApiOperation(value = "启动流程-以流程定义id-加上草稿内容（为了实现撤回）")
+ @PostMapping("/startProcessRollBack")
+ public ResponseMessage startProcessRollBack(ProcessRollBackEO processRollBackEO){
+ if(StringUtils.isNotBlank(processRollBackEO.getType())){
+ return this.activiti_define_start_rollBack(ActDefineStartMap.actDefineStartMap(processRollBackEO.getType()), LoginUserUtil.getUserId(),processRollBackEO.getId(),processRollBackEO.getJson());
+ }else {
+ return null;
+ }
+ }
+
+ @ApiOperation(value = "定时任务启动流程-以流程定义id")
+ @GetMapping("/startProcessNew")
+ public ResponseMessage startProcessNew(@RequestParam("type") String type, @RequestParam(value="userId",required = false) String userId, @RequestParam(value="id",required = false) String id){
+ if(StringUtils.isNotBlank(type)){
+ return this.activiti_define_start(ActDefineStartMap.actDefineStartMap(type), userId,id);
+ }else {
+ return null;
+ }
+ }
+
+ @ApiOperation(value = "待办任务详情")
+ @GetMapping("/todotask")
+ public PageInfo todotask(@RequestParam("userId") String userId, @RequestParam("pId") String pId){
+ workFlowFeignClient.todotask(userId, pId);
+ return null;
+ }
+
+ @ApiOperation(value = "详情")
+ @GetMapping("/queryDetail")
+ public BusProcessNew queryDetail(@RequestParam("taskIds") String taskIds){
+ return workFlowFeignClient.queryDetail(taskIds);
+ }
+
+ @ApiOperation(value = "入库联络人详情")
+ @GetMapping("/inboundLiaisonDetail")
+ public BusProcessNew inboundLiaisonDetail(@RequestParam("taskIds") String taskIds, @RequestParam("pId") String pId) {
+ return workFlowFeignClient.inboundLiaisonDetail(taskIds,pId);
+ }
+
+ @ApiOperation(value = "入库联络人详情")
+ @GetMapping("/nonconformity")
+ public String nonconformity(@RequestParam("taskIds") String taskIds){
+ return workFlowFeignClient.nonconformity(taskIds);
+ }
+
+ @ApiOperation(value = "国内法规入库评估流程详情")
+ @GetMapping("/inboundLiaisonDetailForLawsAss")
+ public String inboundLiaisonDetailForLawsAss(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.inboundLiaisonDetailForLawsAss(taskIds);
+ }
+
+ @ApiOperation(value = "项目评估流程详情")
+ @GetMapping("/projectAssessDetail")
+ public BusProcessNew projectAssessDetail(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.projectAssessDetail(taskIds);
+ }
+
+ @ApiOperation(value = "企标制修订申请流程详情")
+ @GetMapping("/qbzxdsqlcDetail")
+ public String qbzxdsqlcDetail(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.qbzxdsqlcDetail(taskIds);
+ }
+
+ @ApiOperation(value = "企标废止流程详情")
+ @GetMapping("/qbfzlcDetail")
+ public String qbfzlcDetail(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.qbfzDetail(taskIds);
+ }
+
+ @ApiOperation(value = "企标制修订流程详情")
+ @GetMapping("/qbzxdlcDetail")
+ public String qbzxdlcDetail(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.qbzxdDetail(taskIds);
+ }
+
+ @ApiOperation(value = "政策法规入库发起人查看流程详情")
+ @GetMapping("/zcfgrklcFqrDetail")
+ public String zcfgrklcFqrDetail(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.zcfgrklcFqrDetail(taskIds);
+ }
+
+ @ApiOperation(value = "政策法规入库流程详情")
+ @GetMapping("/zcfgrklcDetail")
+ public String zcfgrklcDetail(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.zcfgrklcDetail(taskIds);
+ }
+
+ @ApiOperation(value = "政策法规入库流程联络人选择FO详情")
+ @GetMapping("/zcfgrklcLlrDetail")
+ public String zcfgrklcLlrDetail(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.zcfgrklcLlrDetail(taskIds);
+ }
+
+ @ApiOperation(value = "企标制修订评估详情")
+ @GetMapping("/qbzxdpgDetail")
+ public String qbzxdpgDetail(@RequestParam("taskIds")String taskIds){
+ return workFlowFeignClient.qbzxdpgDetail(taskIds);
+ }
+
+ @ApiOperation(value = "采购申请流程详情")
+ @GetMapping("/cgsqDetail")
+ public String cgsqDetail(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.cgsqDetail(taskIds);
+ }
+
+ @ApiOperation(value = "复审流程详情")
+ @GetMapping("/fsDetail")
+ public String fsDetail(@RequestParam("taskIds") String taskIds) {
+ return workFlowFeignClient.fsDetail(taskIds);
+ }
+
+ @ApiOperation(value = "保存任务")
+ @PostMapping("/saveTask")
+ public Wrapper saveTask(@RequestBody BusMes busMes){
+ return workFlowFeignClient.saveTask(busMes);
+ }
+
+ @ApiOperation(value = "行政管理要求评估流程保存")
+ @PostMapping("/saveTaskForXZYQ")
+ public Wrapper saveTaskForXZYQ(BusMes busMes){
+ return workFlowFeignClient.saveTaskForXZYQ(busMes);
+ }
+
+ /**
+ * 复审流程使用
+ * @param busMes
+ * @return
+ */
+ @ApiOperation(value = "保存到代办")
+ @PostMapping("/autoSaveFirst1")
+ public Wrapper autoSaveFirst1(@RequestBody BusMes busMes){
+ return workFlowFeignClient.autoSaveFirst1(busMes);
+ }
+
+ @ApiOperation(value = "改派")
+ @GetMapping("/changeAssigneeNew")
+ public Wrapper run(@RequestParam("taskId")String taskId, @RequestParam("assignee") String assignee,
+ @RequestParam("userId")String userId, @RequestParam("pId") String pId) {
+ return workFlowFeignClient.run(taskId,assignee,userId,pId);
+ }
+
+ @ApiOperation(value = "我的已办任务列表")
+ @PostMapping("/hastodoTasksList")
+ public Wrapper> HastodoTasksListByUserId(@RequestBody TaskCommonQuery taskCommonQuery){
+ return workFlowFeignClient.HastodoTasksListByUserId(taskCommonQuery);
+ }
+
+ @ApiOperation(value = "我的待办任务列表")
+ @PostMapping("/todoTaskList")
+ public PageInfo todoTaskListByUserId(@RequestBody TaskCommonQuery taskCommonQuery){
+ List busProcessNames = workFlowFeignClient.todoTaskListByUserId(taskCommonQuery);
+ List list1 = this.startPage(busProcessNames, taskCommonQuery.getCurrent(), taskCommonQuery.getSize());
+ PageInfo pageInfo= new PageInfo();
+ if(busProcessNames!=null){
+ pageInfo.setList(list1);
+ pageInfo.setPageNo(taskCommonQuery.getCurrent());
+ pageInfo.setCount(Long.valueOf(busProcessNames.size()));
+ pageInfo.setPageSize(taskCommonQuery.getSize());
+ }else{
+ List list = new ArrayList<>();
+ pageInfo.setList(list);
+ pageInfo.setPageNo(taskCommonQuery.getCurrent());
+ pageInfo.setCount(Long.valueOf(0));
+ pageInfo.setPageSize(taskCommonQuery.getSize());
+ }
+ return pageInfo;
+ }
+
+ @ApiOperation(value = "我的待办任务列表")
+ @PostMapping("/todoTaskListNew")
+ public PageInfo todoTaskListNew(@RequestBody TaskCommonQuery taskCommonQuery){
+ List busProcessNames = workFlowFeignClient.todoTaskListByUserId(taskCommonQuery);
+ List list1 = this.startPage(busProcessNames, taskCommonQuery.getCurrent(), taskCommonQuery.getSize());
+ PageInfo pageInfo= new PageInfo();
+ if(busProcessNames!=null){
+ pageInfo.setList(list1);
+ pageInfo.setPageNo(taskCommonQuery.getCurrent());
+ pageInfo.setCount(Long.valueOf(busProcessNames.size()));
+ pageInfo.setPageSize(taskCommonQuery.getSize());
+ }else{
+ List list = new ArrayList<>();
+ pageInfo.setList(list);
+ pageInfo.setPageNo(taskCommonQuery.getCurrent());
+ pageInfo.setCount(Long.valueOf(0));
+ pageInfo.setPageSize(taskCommonQuery.getSize());
+ }
+ return pageInfo;
+ }
+
+ @ApiOperation(value = "完成任务")
+ @PostMapping("/completeTask")
+ public Wrapper completeTaskByUserId( BusMes busMes){
+ Wrapper str = workFlowFeignClient.completeTaskByUserId(busMes);
+ if(str.getCode() == 500){
+ str.setSuccess(false);
+ }
+ return str;
+ }
+
+ @ApiOperation(value = "特殊完成任务节点 会更·改草稿")
+ @PostMapping("/completeTaskNew")
+ public Wrapper completeTaskByUserIdNew( BusMesSpecial busMes){
+ Wrapper str = workFlowFeignClient.completeTaskByUserIdNew(busMes);
+ if(str.getCode() == 500){
+ str.setSuccess(false);
+ }
+ return str;
+ }
+
+ @ApiOperation(value = "保存标准入库流程")
+ @PostMapping("/saveinboundTask")
+ public Wrapper saveinboundTask(BusMes busMes){
+ return workFlowFeignClient.saveinboundTask(busMes);
+ }
+
+ @ApiOperation(value = "整改流程保存")
+ @PostMapping("/saveUnqualified")
+ public Wrapper saveUnqualified(BusMes busMes){
+ return workFlowFeignClient.saveUnqualified(busMes);
+ }
+
+ @ApiOperation(value = "国内法规入库技术评估流程保存")
+ @PostMapping("/saveInboundLiaisonDetailForLawsAss")
+ public Wrapper saveInboundLiaisonDetailForLawsAss(BusMes busMes){
+ return workFlowFeignClient.saveInboundLiaisonDetailForLawsAss(busMes);
+ }
+
+ @ApiOperation(value = "国内法规入库项目评估流程保存")
+ @PostMapping("/saveProjectAssessDetail2")
+ public Wrapper saveProjectAssessDetail2(BusMes busMes){
+ return workFlowFeignClient.saveProjectAssessDetail2(busMes);
+ }
+
+ @ApiOperation(value = "国内法规入库项目评估流程保存")
+ @PostMapping("/saveProjectAssessDetail3")
+ public Wrapper saveProjectAssessDetail3(BusMes busMes){
+ return workFlowFeignClient.saveProjectAssessDetail3(busMes);
+ }
+
+ @ApiOperation(value = "国内法规入库项目评估流程保存")
+ @PostMapping("/saveProjectAssessDetail4")
+ public Wrapper saveProjectAssessDetail4(BusMes busMes){
+ return workFlowFeignClient.saveProjectAssessDetail4(busMes);
+ }
+
+ @ApiOperation(value = "国内法规入库项目评估流程保存")
+ @PostMapping("/saveProjectAssessDetail5")
+ public Wrapper saveProjectAssessDetail5(BusMes busMes){
+ return workFlowFeignClient.saveProjectAssessDetail5(busMes);
+ }
+
+ @ApiOperation(value = "政策法规评估流程保存")
+ @PostMapping("/saveZcfgpg")
+ public Wrapper saveZcfgpg(BusMes busMes){
+ return workFlowFeignClient.saveZcfgpg(busMes);
+ }
+
+
+ @ApiOperation(value = "国内法规入库评估流程保存")
+ @PostMapping("/saveTaskForPub")
+ public Wrapper saveTaskForPub(BusMes busMes){
+ return workFlowFeignClient.saveTaskForPub(busMes);
+ }
+
+ @ApiOperation(value = "保存任务第一步")
+ @PostMapping("/saveTaskFirst")
+ public Wrapper saveTaskFirst(BusMes busMes){
+
+ return workFlowFeignClient.saveTaskFirst(busMes);
+ }
+
+ @ApiOperation(value = "查询任务第一步")
+ @GetMapping("/queryTaskFirst")
+ public BusProcessName queryTaskFirst(@RequestParam("bpnId")String bpnId) {
+ return workFlowFeignClient.queryTaskFirst(bpnId);
+ }
+
+ @ApiOperation(value = "查询taskid任务")
+ @GetMapping("/queryTaskIndex")
+ public BusProcessNew queryTaskIndex(@RequestParam("prcId") String prcId,@RequestParam("taskIds") String taskIds){
+ return workFlowFeignClient.queryTaskIndex(prcId,taskIds);
+ }
+
+ @ApiOperation(value = "查询草稿")
+ @PostMapping("/queryTaskDraft")
+ public PageInfo queryTaskDraft(@RequestBody TaskCommonQuery taskCommonQuery){
+ List busProcessNames = workFlowFeignClient.queryTaskDraft(taskCommonQuery);
+ List list1 = this.startPage(busProcessNames, taskCommonQuery.getCurrent(), taskCommonQuery.getSize());
+ PageInfo pageInfo= new PageInfo();
+ if(busProcessNames!=null){
+ pageInfo.setList(list1);
+ pageInfo.setPageNo(taskCommonQuery.getCurrent());
+ pageInfo.setCount(Long.valueOf(busProcessNames.size()));
+ pageInfo.setPageSize(taskCommonQuery.getSize());
+ }else{
+ List list = new ArrayList();
+ pageInfo.setList(list);
+ pageInfo.setPageNo(taskCommonQuery.getCurrent());
+ pageInfo.setCount(Long.valueOf(0));
+ pageInfo.setPageSize(taskCommonQuery.getSize());
+ }
+ return pageInfo;
+ }
+
+ @ApiOperation(value = "定时任务发起流程")
+ @PostMapping("/autoSaveFirst")
+ public Wrapper autoSaveFirst(@RequestBody BusMes busMes){
+ return workFlowFeignClient.autoSaveFirst(busMes);
+ }
+
+ @ApiOperation(value = "查询流程是否结束")
+ @GetMapping("/isEnd")
+ public String isEnd(@RequestParam("pId")String pId){
+ return workFlowFeignClient.isEnd(pId);
+ }
+
+ @ApiOperation(value = "删除流程")
+ @GetMapping("/deleteProcessInstance")
+ public Wrapper deleteProcessInstance(@RequestParam("pId")String pId){
+ return workFlowFeignClient.deleteProcessInstance(pId);
+ }
+
+ @ApiOperation(value = "删除草稿")
+ @GetMapping("/deleteDraft")
+ public Wrapper deleteDraft(@RequestParam("id")String id){
+ return workFlowFeignClient.deleteDraft(id);
+ }
+
+ @ApiOperation(value = "已发流程")
+ @PostMapping("/IssuedProcess")
+ public PageInfo IssuedProcess(@RequestBody TaskCommonQuery taskCommonQuery){
+ Page page = workFlowFeignClient.issuedProcess(taskCommonQuery);
+ PageInfo pageInfo= new PageInfo();
+ pageInfo.setList(page.getList());
+ pageInfo.setPageNo(taskCommonQuery.getCurrent());
+ pageInfo.setCount(Long.valueOf(page.getCount()));
+ pageInfo.setPageSize(page.getPageSize());
+ return pageInfo;
+ }
+
+ @ApiOperation(value = "已办流程")
+ @PostMapping("/doneProcess")
+ public PageInfo doneProcess(@RequestBody TaskCommonQuery taskCommonQuery){
+ Page page = workFlowFeignClient.doneProcess(taskCommonQuery);
+ PageInfo pageInfo= new PageInfo();
+ pageInfo.setList(page.getList());
+ pageInfo.setPageNo(page.getPageNo());
+ pageInfo.setCount(page.getCount());
+ pageInfo.setPageSize(page.getPageSize());
+ return pageInfo;
+ }
+
+ /**
+ * 开始分页
+ * @param list
+ * @param pageNum 页码
+ * @param pageSize 每页多少条数据
+ * @return
+ */
+ public static List startPage(List list, Integer pageNum,
+ Integer pageSize) {
+ if (list == null) {
+ return null;
+ }
+ if (list.size() == 0) {
+ return null;
+ }
+
+ Integer count = list.size(); // 记录总数
+ Integer pageCount = 0; // 页数
+ if (count % pageSize == 0) {
+ pageCount = count / pageSize;
+ } else {
+ pageCount = count / pageSize + 1;
+ }
+
+ int fromIndex = 0; // 开始索引
+ int toIndex = 0; // 结束索引
+
+ if (pageNum != pageCount) {
+ fromIndex = (pageNum - 1) * pageSize;
+ toIndex = fromIndex + pageSize;
+ } else {
+ fromIndex = (pageNum - 1) * pageSize;
+ toIndex = count;
+ }
+
+ List pageList = list.subList(fromIndex, toIndex);
+
+ return pageList;
+ }
+
+ @ApiOperation(value = "流程实例明细列表")
+ @GetMapping("/get_list_by_instance")
+ public List> get_list_by_instance(@RequestParam("prcNum") String prcNum, @RequestParam(value="sortWord",required = false)String sortWord, @RequestParam(value="shunxu",required = false) String shunxu){
+ return workFlowFeignClient.get_list_by_instance(prcNum,sortWord,shunxu);
+ }
+
+ @ApiOperation(value = "流程实例汇总列表")
+ @GetMapping("/get_gather_by_instance")
+ public List> get_gather_by_instance(@RequestParam("prcNum") String prcNum, @RequestParam(value="sortWord",required = false)String sortWord, @RequestParam(value="shunxu",required = false) String shunxu){
+ return workFlowFeignClient.get_gather_by_instance(prcNum,sortWord,shunxu);
+ }
+
+ @ApiOperation(value = "获取图片")
+ @GetMapping("/getImg")
+ public void getImg(@RequestParam("prcNum")String prcNum, HttpServletResponse response) throws IOException {
+ OutputStream os = null;
+ response.setContentType("image/jpg");
+ response.flushBuffer();
+ os = response.getOutputStream();
+ os.write(workFlowFeignClient.getImg(prcNum));
+ os.flush();
+ os.close();
+ }
+
+ @ApiOperation(value = "监控流程列表")
+ @PostMapping("/allProcess")
+ public PageInfo allProcess(@RequestBody TaskCommonQuery taskCommonQuery){
+ Page page= workFlowFeignClient.allProcess(taskCommonQuery);
+ PageInfo pageInfo= new PageInfo();
+ pageInfo.setPageNo(taskCommonQuery.getCurrent());
+ pageInfo.setList(page.getList() == null ? new ArrayList<>():page.getList());
+ pageInfo.setCount(page.getCount() == null ? 0 : page.getCount());
+ pageInfo.setPageSize(page.getPageSize() == null ? 0 : page.getPageSize());
+ return pageInfo;
+ }
+
+ @ApiOperation(value = "|exportProcessDetailInfo|导出excel")
+ @GetMapping(value = "/exportProcessDetailInfo")
+ public void exportProcessDetailInfo(String idAndSartypeList, String prcNum, HttpServletResponse response,
+ HttpServletRequest request, String exportName) throws Exception {
+ if (StringUtils.isEmpty(exportName)) {
+ exportName = "流程明细清单";
+ }
+ OutputStream os = null;
+ Workbook workbook = null;
+ try {
+ response.setHeader("Content-Disposition",
+ "attachment; filename=" + ReadExcel.encodeFileName(exportName + ".xlsx", request));
+ response.setContentType("application/force-download");
+ ExportParams exportParams = new ExportParams();
+ exportParams.setType(ExcelType.XSSF);
+ List