From 6fbdaa6f6d9da6d489d079f3b8b8820e49be26c8 Mon Sep 17 00:00:00 2001
From: lxw <810412026@qq.com>
Date: 星期五, 19 八月 2022 11:07:20 +0800
Subject: [PATCH] 根据产品id查询子件及其关联的物料信息,websoket的/product 推送
---
src/main/java/com/whyc/webSocket/ProductSocket.java | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/whyc/webSocket/BomVersionSocket.java b/src/main/java/com/whyc/webSocket/ProductSocket.java
similarity index 79%
rename from src/main/java/com/whyc/webSocket/BomVersionSocket.java
rename to src/main/java/com/whyc/webSocket/ProductSocket.java
index 203c53e..abf54e7 100644
--- a/src/main/java/com/whyc/webSocket/BomVersionSocket.java
+++ b/src/main/java/com/whyc/webSocket/ProductSocket.java
@@ -1,9 +1,9 @@
package com.whyc.webSocket;
import com.whyc.config.WebSocketConfig;
-import com.whyc.dto.BomVersionSocketDto;
+import com.whyc.dto.ProductSocketDto;
import com.whyc.dto.Response;
-import com.whyc.service.ProductBomService;
+import com.whyc.service.ProductService;
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -17,8 +17,8 @@
* 浜у搧淇℃伅鍙婄増鏈�
*/
@Component
-@ServerEndpoint(value = "/bomversion",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
-public class BomVersionSocket {
+@ServerEndpoint(value = "/product",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
+public class ProductSocket {
private Session session;
private static final int executeTime = 2000;
@@ -31,11 +31,11 @@
private volatile Map<Long,Boolean> threadFlagMap = new HashMap<>();
- private static ProductBomService bomService;
+ private static ProductService productService;
@Autowired
- public void setBomService(ProductBomService bomService) {
- BomVersionSocket.bomService = bomService;
+ public void setBomService(ProductService productService) {
+ ProductSocket.productService = productService;
}
@OnOpen
@@ -46,7 +46,7 @@
@OnMessage
public void onMessage(Session session, String message){
this.session=session;
- BomVersionSocketDto bomVersion=ActionUtil.getGson().fromJson(message,BomVersionSocketDto.class);
+ ProductSocketDto productDto=ActionUtil.getGson().fromJson(message, ProductSocketDto.class);
thread = new Thread("Thread_RealTime") {
@Override
public void run() {
@@ -54,7 +54,7 @@
Thread thread = currentThread();
threadFlagMap.put(thread.getId(), true);
try {
- Response res = bomService.getAllBom(bomVersion.getParentCode(),bomVersion.getParentName(),bomVersion.getParentModel(),bomVersion.getPageCurr(),bomVersion.getPageSize());
+ Response res = productService.getAllProduct(productDto.getParentCode(),productDto.getParentName(),productDto.getParentModel(),productDto.getCustomCode(),productDto.getPageCurr(),productDto.getPageSize());
if (session.isOpen()) {
//鎺ㄩ�佷俊鎭�
synchronized (session) {
--
Gitblit v1.9.1