|
|
@ -23,6 +23,7 @@ import org.springblade.common.model.DistributionLoadVO; |
|
|
|
import org.springblade.common.model.NodeFanoutMsg; |
|
|
|
import org.springblade.common.model.NodeFanoutMsg; |
|
|
|
import org.springblade.common.model.PackageData; |
|
|
|
import org.springblade.common.model.PackageData; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
|
import javax.annotation.Resource; |
|
|
|
import java.util.HashMap; |
|
|
|
import java.util.HashMap; |
|
|
@ -48,6 +49,7 @@ public class LoadingReportListener implements ReportService { |
|
|
|
@Resource |
|
|
|
@Resource |
|
|
|
private DistributionProperties destinationProperties; |
|
|
|
private DistributionProperties destinationProperties; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Transactional |
|
|
|
public void buildReport(String msg) { |
|
|
|
public void buildReport(String msg) { |
|
|
|
NodeFanoutMsg bean = JSONUtil.toBean(msg, NodeFanoutMsg.class); |
|
|
|
NodeFanoutMsg bean = JSONUtil.toBean(msg, NodeFanoutMsg.class); |
|
|
|
Object main = bean.getMain(); |
|
|
|
Object main = bean.getMain(); |
|
|
|