|
@ -182,15 +182,20 @@ public class BlockChainProjectServiceImpl implements BlockChainProjectService, R |
|
|
@Override |
|
|
@Override |
|
|
public void blockChainProcessProject(BlockChainProcessProjectFormDTO input) { |
|
|
public void blockChainProcessProject(BlockChainProcessProjectFormDTO input) { |
|
|
|
|
|
|
|
|
|
|
|
BlockChainProjectFormDTO project = input.getProject(); |
|
|
BlockChainProjectProcessFormDTO process = input.getProcess(); |
|
|
BlockChainProjectProcessFormDTO process = input.getProcess(); |
|
|
List<BlockChainProjectProcessAssignedStaffFormDTO> assignedStaffs = input.getAssignedStaffs(); |
|
|
List<BlockChainProjectProcessAssignedStaffFormDTO> assignedStaffs = input.getAssignedStaffs(); |
|
|
BlockChainProjectProcessAssignedStaffFormDTO handledStaff = input.getHandledStaff(); |
|
|
BlockChainProjectProcessAssignedStaffFormDTO handledStaff = input.getHandledStaff(); |
|
|
|
|
|
|
|
|
fill(null, process, assignedStaffs, handledStaff); |
|
|
fill(project, process, assignedStaffs, handledStaff); |
|
|
|
|
|
|
|
|
String processString = JSON.toJSONString(process); |
|
|
String processString = JSON.toJSONString(process); |
|
|
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_PROCESS, processString); |
|
|
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_PROCESS, processString); |
|
|
|
|
|
|
|
|
|
|
|
if (project != null) { |
|
|
|
|
|
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_PROJECT, JSON.toJSONString(project)); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
if (assignedStaffs != null && assignedStaffs.size() > 0) { |
|
|
if (assignedStaffs != null && assignedStaffs.size() > 0) { |
|
|
String assignedStaffsString = JSON.toJSONString(assignedStaffs); |
|
|
String assignedStaffsString = JSON.toJSONString(assignedStaffs); |
|
|
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_ASSIGNED_STAFFS, assignedStaffsString); |
|
|
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_ASSIGNED_STAFFS, assignedStaffsString); |
|
|