From b63bb8568149eaf8650a10c8adca84f545fb58f2 Mon Sep 17 00:00:00 2001
From: wangxianzhang <ZHANGYUGE6666>
Date: Tue, 4 Jan 2022 13:28:27 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9A=201.=E9=A1=B9?=
 =?UTF-8?q?=E7=9B=AE=E4=B8=8A=E9=93=BEuploadServiceIMpl=E5=A2=9E=E5=8A=A0?=
 =?UTF-8?q?=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/BlockChainUploadServiceImpl.java  | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/BlockChainUploadServiceImpl.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/BlockChainUploadServiceImpl.java
index 718c5ea7ef..5197b2a20b 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/BlockChainUploadServiceImpl.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/BlockChainUploadServiceImpl.java
@@ -1,6 +1,7 @@
 package com.epmet.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.epmet.commons.tools.utils.Result;
 import com.epmet.dao.ProjectStaffDao;
 import com.epmet.dto.form.*;
 import com.epmet.entity.ProjectEntity;
@@ -8,6 +9,7 @@ import com.epmet.entity.ProjectProcessEntity;
 import com.epmet.entity.ProjectStaffEntity;
 import com.epmet.feign.EpmetThirdOpenFeignClient;
 import com.epmet.service.BlockChainUploadService;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -21,6 +23,7 @@ import java.util.stream.Collectors;
  * 区块链上链service实现
  */
 @Service
+@Slf4j
 public class BlockChainUploadServiceImpl implements BlockChainUploadService {
 
     @Autowired
@@ -129,20 +132,27 @@ public class BlockChainUploadServiceImpl implements BlockChainUploadService {
             handledStaff.setProjectId(handledStaffEntity.getProjectId());
         }
 
+        Result result;
         if (project == null) {
             // 处理
             BlockChainProcessProjectFormDTO processForm = new BlockChainProcessProjectFormDTO();
             processForm.setProcess(process);
             processForm.setAssignedStaffs(assignedStaffs);
             processForm.setHandledStaff(handledStaff);
-            thirdOpenFeignClient.blockChainProcessProject(processForm);
+            result = thirdOpenFeignClient.blockChainProcessProject(processForm);
         } else {
             // 立项
             BlockChainCreateProjectFormDTO createForm = new BlockChainCreateProjectFormDTO();
             createForm.setProject(project);
             createForm.setProcess(process);
             createForm.setAssignedStaffs(assignedStaffs);
-            thirdOpenFeignClient.blockChainCreateProject(createForm);
+            result = thirdOpenFeignClient.blockChainCreateProject(createForm);
+        }
+
+        if (result == null || !result.success()) {
+            log.error("项目处理信息，上链失败");
+        } else {
+            log.info("项目处理信息，上链成功");
         }
     }
 }