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