getAttFileInfo(AttFileEO attFileEO){
+ createConvertMQService.sendConvertMQ(attFileEO);
+ return Result.success("");
+ }
+}
diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/dao/OtConvertDao.java b/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/dao/OtConvertDao.java
new file mode 100644
index 00000000..736f8ebd
--- /dev/null
+++ b/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/dao/OtConvertDao.java
@@ -0,0 +1,16 @@
+package com.adc.da.convert.OtConvert.dao;
+
+import com.adc.da.convert.OtConvert.entity.OtConvert;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ *
+ * 流程文档转换记录表 Mapper 接口
+ *
+ *
+ * @author super_liu
+ * @since 2021-08-12
+ */
+public interface OtConvertDao extends BaseMapper {
+
+}
diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/entity/OtConvert.java b/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/entity/OtConvert.java
new file mode 100644
index 00000000..a6f90a3c
--- /dev/null
+++ b/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/entity/OtConvert.java
@@ -0,0 +1,66 @@
+package com.adc.da.convert.OtConvert.entity;
+
+import com.adc.da.base.entity.BaseEntity;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.springframework.format.annotation.DateTimeFormat;
+
+/**
+ *
+ * 流程文档转换记录表
+ *
+ *
+ * @author super_liu
+ * @since 2021-08-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@ApiModel(value="OtConvert对象", description="流程文档转换记录表")
+public class OtConvert extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ @ApiModelProperty(value = "主键")
+ @TableId("ID")
+ private String id;
+
+ @ApiModelProperty(value = "待转换文件ID")
+ @TableField("ACT_FILE_ID")
+ private String actFileId;
+
+ @ApiModelProperty(value = "转换状态：LODING:待转换 SUCCESS:成功 ERROR:错误")
+ @TableField("CONVERT_STATE")
+ private String convertState;
+
+ @ApiModelProperty(value = "转换后文件ID")
+ @TableField("CONVERT_FILE_ID")
+ private String convertFileId;
+
+ @ApiModelProperty(value = "数据创建时间")
+ @TableField("CREATE_TIME")
+ @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
+ @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
+ private Date createTime;
+
+ @ApiModelProperty(value = "数据修改时间")
+ @TableField("MODIFY_TIME")
+ @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
+ @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
+ private Date modifyTime;
+
+ @ApiModelProperty(value = "是否有效")
+ @TableField("VALID_FLAG")
+ private Integer validFlag;
+
+
+}
diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/service/IOtConvertService.java b/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/service/IOtConvertService.java
new file mode 100644
index 00000000..5533a728
--- /dev/null
+++ b/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/service/IOtConvertService.java
@@ -0,0 +1,16 @@
+package com.adc.da.convert.OtConvert.service;
+
+import com.adc.da.convert.OtConvert.entity.OtConvert;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ *
+ * 流程文档转换记录表 服务类
+ *
+ *
+ * @author super_liu
+ * @since 2021-08-12
+ */
+public interface IOtConvertService extends IService {
+
+}
diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/service/impl/OtConvertServiceImpl.java b/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/service/impl/OtConvertServiceImpl.java
new file mode 100644
index 00000000..f873f1a6
--- /dev/null
+++ b/adc-da-convert/src/main/java/com/adc/da/convert/OtConvert/service/impl/OtConvertServiceImpl.java
@@ -0,0 +1,20 @@
+package com.adc.da.convert.OtConvert.service.impl;
+
+import com.adc.da.convert.OtConvert.entity.OtConvert;
+import com.adc.da.convert.OtConvert.dao.OtConvertDao;
+import com.adc.da.convert.OtConvert.service.IOtConvertService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 流程文档转换记录表 服务实现类
+ *
+ *
+ * @author super_liu
+ * @since 2021-08-12
+ */
+@Service
+public class OtConvertServiceImpl extends ServiceImpl implements IOtConvertService {
+
+}
diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/common/DocConverter.java b/adc-da-convert/src/main/java/com/adc/da/convert/common/DocConverter.java
index 30d1d95e..5febe5de 100644
--- a/adc-da-convert/src/main/java/com/adc/da/convert/common/DocConverter.java
+++ b/adc-da-convert/src/main/java/com/adc/da/convert/common/DocConverter.java
@@ -4,7 +4,6 @@ import com.artofsolving.jodconverter.DocumentConverter;
import com.artofsolving.jodconverter.openoffice.connection.OpenOfficeConnection;
import com.artofsolving.jodconverter.openoffice.connection.SocketOpenOfficeConnection;
import com.artofsolving.jodconverter.openoffice.converter.OpenOfficeDocumentConverter;
-import com.itextpdf.kernel.pdf.PdfReader;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/mq/CreateConvertMQService.java b/adc-da-convert/src/main/java/com/adc/da/convert/mq/CreateConvertMQService.java
new file mode 100644
index 00000000..0a01541f
--- /dev/null
+++ b/adc-da-convert/src/main/java/com/adc/da/convert/mq/CreateConvertMQService.java
@@ -0,0 +1,27 @@
+package com.adc.da.convert.mq;
+
+import com.adc.da.att.entity.AttFileEO;
+import net.sf.json.JSONObject;
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Component
+public class CreateConvertMQService {
+ @Autowired
+ private AmqpTemplate rabbitTemplate;
+
+ /**
+ *
+ * @param attFileEO 文件对象
+ * @throws Exception
+ */
+ public void sendConvertMQ(AttFileEO attFileEO){
+ // 中间转换业务逻辑
+ //发送消息队列
+ this.rabbitTemplate.convertAndSend("convert-exchange_SQ_GSAR", "convert-key_SQ_GSAR", attFileEO);
+ }
+}
diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java b/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java
new file mode 100644
index 00000000..a8ead8d3
--- /dev/null
+++ b/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java
@@ -0,0 +1,63 @@
+package com.adc.da.convert.mq;
+
+import com.adc.da.att.entity.AttFileEO;
+import com.adc.da.att.service.IAttFileEOService;
+import com.rabbitmq.client.Channel;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.rabbit.annotation.Exchange;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.QueueBinding;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.support.AmqpHeaders;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.messaging.Message;
+import org.springframework.stereotype.Component;
+
+@Component
+public class SendConvertMQService {
+
+ // 文档转换远程服务IP地址
+ @Value("${convert.host}")
+ private String convertHost;
+
+ @Autowired
+ private IAttFileEOService iAttFileEOService;
+
+ private static final Logger logger = LoggerFactory.getLogger(SendConvertMQService.class);
+
+ @RabbitListener(bindings = @QueueBinding(
+ value = @Queue(value = "createStandMQ_SQ_GSAR", durable = "true"),
+ exchange = @Exchange(value = "convert-exchange_SQ_GSAR", ignoreDeclarationExceptions = "true"),
+ key = "convert-key_SQ_GSAR"))
+ public void createMQ(AttFileEO attFileEO, Message message, Channel channel) throws Exception{
+ try{
+ try{
+ Thread.sleep(5000);
+ insertOrUpdateStandInfo(attFileEO);
+ }catch(InterruptedException e){
+ logger.error(e.toString());
+ Thread.currentThread().interrupt();
+ }
+ } catch (Exception e) {
+ logger.error("文档转换消息队列进入添加数据方法前失败！");
+ logger.error(e.getMessage(),e);
+ }finally {
+ Long tag = (Long) message.getHeaders().get(AmqpHeaders.DELIVERY_TAG);
+ channel.basicAck(tag,false);
+ logger.debug("文档转换消息确认成功！！！！！！！！！");
+ }
+
+ }
+
+ /**
+ * 文档转换逻辑
+ * @param attFileEO
+ */
+ public void insertOrUpdateStandInfo(AttFileEO attFileEO){
+
+ }
+
+
+}
diff --git a/adc-da-convert/src/main/resources/mybatis/mapper/OtConvert/OtConvertMapper.xml b/adc-da-convert/src/main/resources/mybatis/mapper/OtConvert/OtConvertMapper.xml
new file mode 100644
index 00000000..b7f1df3f
--- /dev/null
+++ b/adc-da-convert/src/main/resources/mybatis/mapper/OtConvert/OtConvertMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/adc-da-main/pom.xml b/adc-da-main/pom.xml
index cb376f0d..cf4b3bc8 100644
--- a/adc-da-main/pom.xml
+++ b/adc-da-main/pom.xml
@@ -24,6 +24,11 @@
org.springframework.boot
spring-boot-starter
+
+ com.adc
+ adc-da-convert
+ 3.0.0
+
com.adc
adc-da-slrs