消息推送系统

智慧学工管理系统

import org.springframework.web.bind.annotation.*;

import java.util.HashMap;

import java.util.Map;

@RestController

public class TrialRequestController {

private static final Map trialStatus = new HashMap<>();

@PostMapping("/submitTrial")

public String submitTrial(@RequestBody Map request) {

String factoryName = (String) request.get("factoryName");

String statusMessage = "Trial submitted for " + factoryName;

trialStatus.put(factoryName, statusMessage);

publishToMessageHub(statusMessage);

return statusMessage;

}

private void publishToMessageHub(String message) {

// 调用消息中台API发送消息

System.out.println("Publishing to Message Hub: " + message);

}

}

]]>