采购计划自动化任务功能

dcs-plan-core/src/main/java/com/yonde/dcs/plan/core/service/ExtPuchasePlanAttributeService.java

@@ -22,4 +22,6 @@ public interface ExtPuchasePlanAttributeService<V extends ExtPuchasePlanAttribut
     public String importPurchasePlan(InputStream inputStream,String projectId);
 
     public String exportPurchasePlanFile(HttpServletResponse response, List<String> ids) throws IOException;
+
+    public String autoImportPurchasePlan(long id);
 }

dcs-plan-core/src/main/java/com/yonde/dcs/plan/core/service/impl/ExtPuchasePlanAttributeServiceImpl.java

@@ -3,6 +3,10 @@ package com.yonde.dcs.plan.core.service.impl;
 import cn.hutool.core.io.FileUtil;
 import com.alibaba.excel.EasyExcel;
 import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy;
+import com.yonde.dcs.document.common.entity.vo.DxDocumentVO;
+import com.yonde.dcs.document.feign.DocCenterFeignService;
+import com.yonde.dcs.document.feign.shadow.DxDocumentFeignShadow;
+import com.yonde.dcs.feign.expand.ExtDxDocumentServiceFeign;
 import com.yonde.dcs.plan.common.constants.Constants;
 import com.yonde.dcs.plan.common.vo.ExtPuchasePlanExcelVO;
 import com.yonde.dcs.plan.core.listener.PurchasePlanExcelReadListenner;
@@ -31,6 +35,7 @@ import com.yonde.dcs.plan.common.vo.ExtPuchasePlanAttributeVO;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Autowired;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.util.ObjectUtils;
 import org.springframework.web.bind.annotation.*;
 import com.yonde.dcs.plan.core.service.ExtPuchasePlanAttributeService;
 import com.yonde.dcs.plan.core.repository.ExtPuchasePlanAttributeRepository;
@@ -60,7 +65,9 @@ public class ExtPuchasePlanAttributeServiceImpl<V extends ExtPuchasePlanAttribut
     private FileManagerFeignService fileManagerFeignService;
     @Autowired
     private SystemFileFeignService systemFileFeignService;
-
+    @Qualifier("com.yonde.dcs.feign.expand.ExtDxDocumentServiceFeign")
+    @Autowired
+    private ExtDxDocumentServiceFeign docCenterFeignService;
 
     @Override
     public String importPurchasePlan(InputStream inputStream,String projectId) {
@@ -122,6 +129,40 @@ public class ExtPuchasePlanAttributeServiceImpl<V extends ExtPuchasePlanAttribut
         return ApiResult.SUCCESS;
     }
 
+    /**
+     * 计划文件签审通过之后，调用该方法，自动导入计划
+     * @param id  文档id
+     * @return
+     */
+    @Override
+    public String autoImportPurchasePlan(long id) {
+
+        InputStream inputStream = null;
+        CustomMultipartFile multipartFile = null;
+        Long fileId = null;
+        DxDocumentVO dxDocumentVO = docCenterFeignService.getDocumentWithFiles(id);
+        if(!ObjectUtils.isEmpty(dxDocumentVO)){
+            try {
+                fileId = dxDocumentVO.getObjFileLinks().get(0).getTarget().getId();
+                multipartFile = fileManagerFeignService.feignDownloadIO(fileId);
+            } catch (IOException e) {
+                log.info("[自动导入采购计划] >>> 文件服务下载文档附件：{}--失败！", fileId);
+                throw new DxBusinessException("500", "文件服务文档附件失败：" + fileId);
+            }
+            try {
+                inputStream = new ByteArrayInputStream(multipartFile.getBytes());
+                importPurchasePlan(inputStream,dxDocumentVO.getDxContextId().toString());
+            } catch (IOException e) {
+                log.info("[自动导入采购计划] >>> 文件服务下载的文件：{}--转换为输入流失败！", fileId);
+                throw new DxBusinessException("500", "文件服务下载的文件转换为输入流失败：" + fileId);
+            }
+        }else {
+            log.info("根据计划文档id:" + id + "未查到相关数据");
+        }
+
+        return ApiResult.SUCCESS;
+    }
+
     /**
      * 数据转换，将PO转换成EXCEL-VO;
      * @param content

dcs-plan-feign/pom.xml

@@ -46,7 +46,7 @@
         </dependency>
         <dependency>
             <groupId>com.yonde.dcs</groupId>
-            <artifactId>dcs-doc-feign</artifactId>
+            <artifactId>dcs-doc-expand-feign</artifactId>
             <version>4.1-20240919-RELEASE</version>
         </dependency>
         <dependency>

dcs-plan-feign/src/main/java/com/yonde/dcs/plan/feign/ExtPuchasePlanAttributeServiceFeign.java

@@ -2,6 +2,7 @@ package com.yonde.dcs.plan.feign;
 
 import com.yonde.dcs.plan.common.vo.ExtPuchasePlanAttributeVO;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.*;
 import com.yonde.dcs.plan.feign.shadow.ExtPuchasePlanAttributeServiceFeignShadow;
@@ -16,4 +17,8 @@ import com.yonde.dcs.plan.feign.shadow.ExtPuchasePlanAttributeServiceFeignShadow
 @FeignClient(value = "${dcs.feign.INET-PLAN}", path = "/ExtPuchasePlanAttribute")
 public interface ExtPuchasePlanAttributeServiceFeign<V extends ExtPuchasePlanAttributeVO> extends ExtPuchasePlanAttributeServiceFeignShadow<V> {
 
+
+    @ApiOperation("采购计划自动导入")
+    @GetMapping(value = "/autoImportPurchasePlan")
+    public String autoImportPurchasePlan( @RequestParam("id")long id);
 }