业务服务向mq/websocket服务推送数据

1. 引入jar包：

//RabbitMQ消息队列
implementation 'org.springframework.boot:spring-boot-starter-amqp'

2. 引入util：

MQUtil.java

@RefreshScope
@Component
public class MQUtil {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(Msg msg, String queueName) throws Exception {
        String jsonString = JSONUtil.toJSONString(msg);// 实体转换JSON字符串
        rabbitTemplate.convertAndSend(queueName, jsonString);// 向队列发送数据
    }
}

Msg是推送前端时发送/接收实体，实体详见4，推送业务服务用业务实体（比如推送仓库、质检，用仓库和质检的实体）
queueName参数表示队列，队列值详见5

3. controller/service引入推送：

1）以下是给单用户多端推送示例

// ===============================发送站内消息===============================
Map<String, Object> sendMap = ObjectToMap.objectToMap(task);// 将实体转map对象
sendMap.put("createTime", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));// 创建时间
JSONObject jsonObject = new JSONObject(sendMap);// 将Map对象转换为JSONObject
String jsonString = jsonObject.toString();// 将JSONObject转换为JSON字符串
/**
 * 推送当前审批层级人员提醒通知 CompletableFuture异步发送消息
 */
CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
    try {
        Msg msg = new Msg();
        msg.setType(8);// 推送待办已处理通知
        msg.setSendMethod(1);// 单发
        msg.setSendFormat(2);// 发送格式（2：json字符串）
        msg.setMessage(jsonString);// 发送内容
        msg.setToSid(taskNode.getUserId().toString());// 发送给PC端
        mQUtil.send(msg);// 推送用户
        msg.setToSid(taskNode.getUserId().toString()+"-PAD");// 发送给PAD端
        mQUtil.send(msg);// 推送用户
    } catch (Exception e) {
        log.error("推送待办已处理通知异常：{}", e);
    }
});
// ===============================发送站内消息===============================

2）以下是给多用户单端推送示例

4. 推送前端数据实体（推送后端业务用业务实体）：

private Integer sendMethod;// 发送方式（1：单发；2：群发）
private String toSid;// 接收者ID
private Integer type;// 发送类别（详见6）
private Integer sendFormat;// 发送格式（1：文本；2：JSON字符串）
private String message;// 消息内容（sendFormat=1时，前端、C/S端提示此内容；sendFormat=2时前端、C/S端解析消息内容处理）

5. queueName队列值对应表：

queueName	推送给
user	用户
workshop	车间
productLine	产线
lineBody	线体
workStation	工位
workOrder	工单
print	打印
resume	履历
warehouse	仓库
quality	质检
bomEcn	ECN
producePlan	生产计划

6. 发送类别对应表

type	备注
1	文件下发工位
2	通知公告下发工位
3	线体切换型号
4	异常播报
5	审批人提醒通知
6	审批抄送提醒通知
7	审批发起人提醒通知
8	已审批提醒同级审批人通知
9	出入库通知
10	MIP通知
20	排产通知
30	意见反馈状态更新通知
95	MIP未处理单通知
95	SCM未处理单通知
96	APS未处理单通知
97	QMS未处理单通知
98	WMS未处理单通知
99	角色权限更新提醒通知
100	调用打印
101	打印结果反馈
102	停线控制推送

业务服务向mq/websocket服务推送数据

1. 引入jar包：#

2. 引入util：#

3. controller/service引入推送：#

1）以下是给单用户多端推送示例#

2）以下是给多用户单端推送示例#

4. 推送前端数据实体（推送后端业务用业务实体）：#

5. queueName队列值对应表：#

6. 发送类别对应表#

1. 引入jar包：

2. 引入util：

3. controller/service引入推送：

1）以下是给单用户多端推送示例

2）以下是给多用户单端推送示例

4. 推送前端数据实体（推送后端业务用业务实体）：

5. queueName队列值对应表：

6. 发送类别对应表