From 2a790a07d7ed2b104d5356eb50a7e613e8c6b2b0 Mon Sep 17 00:00:00 2001 From: anthonywj Date: Thu, 3 Aug 2023 16:44:07 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=8F=91=E7=A5=A8=E7=A1=AE?= =?UTF-8?q?=E8=AE=A4=E5=AE=9E=E6=97=B6=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/glxp/api/config/WebSocketServer.java | 125 ------------------ .../com/glxp/api/constant/SocketMsgType.java | 8 +- .../controller/inout/IoOrderController.java | 28 +++- .../api/controller/sync/SpsSyncWebSocket.java | 7 +- .../api/service/thrsys/ThrCorpsDlService.java | 24 ++-- .../thrsys/ThrInvProductsDlService.java | 10 +- .../service/thrsys/ThrOrdersDlService.java | 11 +- 7 files changed, 54 insertions(+), 159 deletions(-) delete mode 100644 src/main/java/com/glxp/api/config/WebSocketServer.java diff --git a/src/main/java/com/glxp/api/config/WebSocketServer.java b/src/main/java/com/glxp/api/config/WebSocketServer.java deleted file mode 100644 index 6623e574..00000000 --- a/src/main/java/com/glxp/api/config/WebSocketServer.java +++ /dev/null @@ -1,125 +0,0 @@ -package com.glxp.api.config; - - -import com.alibaba.fastjson.JSON; -import com.glxp.api.entity.system.WebSocketEntity; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; -import org.springframework.stereotype.Service; - -import javax.websocket.*; -import javax.websocket.server.PathParam; -import javax.websocket.server.ServerEndpoint; -import java.io.IOException; -import java.util.concurrent.CopyOnWriteArraySet; - -@Component -@Slf4j -@Service -@ServerEndpoint("/api/websocket/{sid}") -public class WebSocketServer { - private static int onlineCount = 0; - private static CopyOnWriteArraySet webSocketSet = new CopyOnWriteArraySet(); - private Session session; - private String sid = ""; - - /** - * 连接建立成功调用的方法 - */ - @OnOpen - public void onOpen(Session session, @PathParam("sid") String sid) { - this.session = session; - webSocketSet.add(this); //加入set中 - this.sid = sid; - addOnlineCount(); //在线数加1 - try { - sendMessage(new WebSocketEntity("sys", "连接成功")); - log.info("有新窗口开始监听:" + sid + ",当前在线人数为:" + getOnlineCount()); - } catch (IOException e) { - log.error("websocket IO Exception"); - } - } - - /** - * 连接关闭调用的方法 - */ - @OnClose - public void onClose() { - webSocketSet.remove(this); //从set中删除 - subOnlineCount(); //在线数减1 - //断开连接情况下，更新主板占用情况为释放 - log.info("释放的sid为：" + sid); - //这里写你 释放的时候，要处理的业务 - log.info("有一连接关闭！当前在线人数为" + getOnlineCount()); - - } - - /** - * 收到客户端消息后调用的方法 - * - * @ Param message 客户端发送过来的消息 - */ - @OnMessage - public void onMessage(String message, Session session) { - log.info("收到来自窗口" + sid + "的信息:" + message); - //群发消息 - for (WebSocketServer item : webSocketSet) { - try { - item.sendMessage(new WebSocketEntity("back", message)); - } catch (IOException e) { - e.printStackTrace(); - } - } - } - - /** - * @ Param session - * @ Param error - */ - @OnError - public void onError(Session session, Throwable error) { - log.error("发生错误"); - error.printStackTrace(); - } - - /** - * 实现服务器主动推送 - */ - public void sendMessage(WebSocketEntity webSocketEntity) throws IOException { - String message = JSON.toJSON(webSocketEntity).toString(); - this.session.getBasicRemote().sendText(message); - } - - public static void sendInfo(String message, String type) { - log.info("推送消息到窗口" + type + "，推送内容:" + message); - - for (WebSocketServer item : webSocketSet) { - try { - if (type == null) { - item.sendMessage(new WebSocketEntity("sid", message)); - } else { - item.sendMessage(new WebSocketEntity(type, message)); - } - } catch (IOException e) { - continue; - } - } - } - - - public static synchronized int getOnlineCount() { - return onlineCount; - } - - public static synchronized void addOnlineCount() { - WebSocketServer.onlineCount++; - } - - public static synchronized void subOnlineCount() { - WebSocketServer.onlineCount--; - } - - public static CopyOnWriteArraySet getWebSocketSet() { - return webSocketSet; - } -} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/constant/SocketMsgType.java b/src/main/java/com/glxp/api/constant/SocketMsgType.java index 42d8f789..12997a66 100644 --- a/src/main/java/com/glxp/api/constant/SocketMsgType.java +++ b/src/main/java/com/glxp/api/constant/SocketMsgType.java @@ -3,6 +3,12 @@ package com.glxp.api.constant; public interface SocketMsgType { - String DL_ALL_DATA = "DL_ALL_DATA"; //生产入库 + String DL_ALL_DATA = "DL_ALL_DATA"; //基础数据同步 String DL_NOTICE = "DL_NOTICE"; //通知类消息 + + /** + * 任务类型 + */ + String TASK_INVOICE_CONFIRM = "TASK_INVOICE_CONFIRM"; //发票确认 + } diff --git a/src/main/java/com/glxp/api/controller/inout/IoOrderController.java b/src/main/java/com/glxp/api/controller/inout/IoOrderController.java index 9b67ba1f..b2e2a499 100644 --- a/src/main/java/com/glxp/api/controller/inout/IoOrderController.java +++ b/src/main/java/com/glxp/api/controller/inout/IoOrderController.java @@ -14,13 +14,16 @@ import com.glxp.api.common.util.ResultVOUtils; import com.glxp.api.constant.BusinessType; import com.glxp.api.constant.Constant; import com.glxp.api.constant.ConstantStatus; +import com.glxp.api.constant.SocketMsgType; import com.glxp.api.controller.BaseController; +import com.glxp.api.controller.sync.SpsSyncWebSocket; import com.glxp.api.entity.auth.AuthAdmin; import com.glxp.api.entity.auth.InvBusUserEntity; import com.glxp.api.entity.auth.InvWarehouseEntity; import com.glxp.api.entity.basic.BasicBussinessTypeEntity; import com.glxp.api.entity.basic.EntrustReceEntity; import com.glxp.api.entity.inout.*; +import com.glxp.api.entity.sync.SocketMsgEntity; import com.glxp.api.req.auth.FilterInvBusUserRequest; import com.glxp.api.req.basic.BasicEntrustRecRequest; import com.glxp.api.req.inout.*; @@ -28,7 +31,6 @@ import com.glxp.api.req.system.DeleteRequest; import com.glxp.api.req.udims.PostUdimsOrderRequest; import com.glxp.api.res.PageSimpleResponse; import com.glxp.api.res.inout.IoOrderDetailBizResponse; -import com.glxp.api.res.inout.IoOrderDetailCodeResponse; import com.glxp.api.res.inout.IoOrderResponse; import com.glxp.api.res.inout.PdaBusOrderResponse; import com.glxp.api.service.auth.InvBusUserService; @@ -45,13 +47,12 @@ import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; +import org.java_websocket.server.WebSocketServer; import org.springframework.beans.BeanUtils; -import org.springframework.scheduling.annotation.Async; import org.springframework.validation.BindingResult; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; -import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; @@ -661,6 +662,7 @@ public class IoOrderController extends BaseController { return orderService.submitToThrSys(billNo); } + @AuthRuleAnnotation("") @PostMapping("/udiwms/inout/order/updateOrderDetailBiz") @Log(title = "单据管理", businessType = BusinessType.UPDATE) public BaseResponse updateOrderDetailBiz(@RequestBody IoOrderDetailBizEntity ioOrderDetailBizEntity) { @@ -672,14 +674,18 @@ public class IoOrderController extends BaseController { return ResultVOUtils.success(); } + @AuthRuleAnnotation("") @PostMapping("/udiwms/inout/order/updateOrder") @Log(title = "单据管理", businessType = BusinessType.UPDATE) public BaseResponse updateOrder(@RequestBody IoOrderEntity ioOrderEntity) { ioOrderEntity.setUpdateTime(new Date()); orderService.updateByBillNo(ioOrderEntity); + webSocketServer.sendMessage(SocketMsgEntity.builder().type(SocketMsgType.TASK_INVOICE_CONFIRM).content(ioOrderEntity.getBillNo()).remark("发票确认").build(), null); return ResultVOUtils.success(); } + @Resource + SpsSyncWebSocket webSocketServer; // --------------------------------------------------------UDI_MS平台-------------------------------------------------------------------------------------- @ApiOperation("udims上传单据") @@ -803,12 +809,12 @@ public class IoOrderController extends BaseController { //这个不等于空表示要查询发票对应的单据 if (filterOrderRequest.getInvoiceEncode() != null) { //查询发票详情 - QueryWrapper ew=new QueryWrapper(); - ew.eq("invoiceEncode",filterOrderRequest.getInvoiceEncode()); + QueryWrapper ew = new QueryWrapper(); + ew.eq("invoiceEncode", filterOrderRequest.getInvoiceEncode()); List ioOrderInvoiceEntity = orderInvoiceService.list(ew); List orderIds = ioOrderInvoiceEntity.stream().map(IoOrderInvoiceEntity::getOrderIdFk).collect(Collectors.toList()); filterOrderRequest.setOrderIds(orderIds); - if(CollectionUtils.isEmpty(orderIds)){ + if (CollectionUtils.isEmpty(orderIds)) { PageInfo pageInfo = new PageInfo<>(); return ResultVOUtils.page(pageInfo); } @@ -864,4 +870,14 @@ public class IoOrderController extends BaseController { } + @GetMapping("/udiwms/inout/order/findByBillNo") + public BaseResponse findByBillNo(@RequestParam("billNo") String billNo) { + if (StrUtil.isBlank(billNo)) { + return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL); + } + IoOrderEntity orderEntity = orderService.findByBillNo(billNo); + return ResultVOUtils.success(orderEntity); + } + + } diff --git a/src/main/java/com/glxp/api/controller/sync/SpsSyncWebSocket.java b/src/main/java/com/glxp/api/controller/sync/SpsSyncWebSocket.java index 4109e7cc..d2583662 100644 --- a/src/main/java/com/glxp/api/controller/sync/SpsSyncWebSocket.java +++ b/src/main/java/com/glxp/api/controller/sync/SpsSyncWebSocket.java @@ -1,9 +1,6 @@ package com.glxp.api.controller.sync; -import cn.hutool.core.util.StrUtil; import com.glxp.api.entity.sync.SocketMsgEntity; -import com.glxp.api.exception.ServiceException; -import com.glxp.api.util.ByteArraySplitter; import com.glxp.api.util.JsonUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; @@ -13,7 +10,6 @@ import javax.websocket.*; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; import java.io.IOException; -import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; @@ -88,6 +84,9 @@ public class SpsSyncWebSocket { * @param sessionId token */ public synchronized void sendMessage(SocketMsgEntity socketMsgEntity, String sessionId) { + if (sessionId == null) { + sessionId = "1:" + socketToken; + } synchronized (this.getClass()) { for (Map.Entry stringMyWebSocketEntry : socketServersMap.entrySet()) { try { diff --git a/src/main/java/com/glxp/api/service/thrsys/ThrCorpsDlService.java b/src/main/java/com/glxp/api/service/thrsys/ThrCorpsDlService.java index 2ebc215f..3964e11c 100644 --- a/src/main/java/com/glxp/api/service/thrsys/ThrCorpsDlService.java +++ b/src/main/java/com/glxp/api/service/thrsys/ThrCorpsDlService.java @@ -5,7 +5,6 @@ import cn.hutool.json.JSONUtil; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.TypeReference; import com.glxp.api.common.res.BaseResponse; -import com.glxp.api.config.WebSocketServer; import com.glxp.api.constant.BasicProcessStatus; import com.glxp.api.constant.Constant; import com.glxp.api.entity.sync.SyncDataSetEntity; @@ -20,6 +19,7 @@ import com.glxp.api.service.sync.SyncDataSetService; import com.glxp.api.util.CustomUtil; import com.glxp.api.util.ExcelUtil; import com.glxp.api.util.RedisUtil; +import org.java_websocket.server.WebSocketServer; import org.springframework.beans.BeanUtils; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; @@ -45,7 +45,7 @@ public class ThrCorpsDlService { ThrCorpExportLogService thrCorpExportLogService; @Resource private ThrCorpImportDetailService thrCorpImportDetailService; -// @Value("${SPSYNC_IP}") + // @Value("${SPSYNC_IP}") // private String spsSyncUrl; @Resource ErpBasicClient erpBasicClient; @@ -66,7 +66,7 @@ public class ThrCorpsDlService { public void importSelectCorps(String genKey, List thrCorpsResponseList, String thirdSys) { ThrSystemDetailEntity piDetailEntity = thrSystemDetailService.selectByKey("corpUrl", thirdSys); if (piDetailEntity == null || piDetailEntity.getValue() == null) { - WebSocketServer.sendInfo("往来单位接口未设置！", "sid"); +// WebSocketServer.sendInfo("往来单位接口未设置！", "sid"); return; } ThrCorpImportLogEntity thrProductsImportLogEntity = thrCorpImportLogService.selectByGenKey(genKey); @@ -107,7 +107,7 @@ public class ThrCorpsDlService { thrCorpService.insertThrCorpss(thrCorpEntities); redisUtil.set(Constant.dlThrProducts, "false"); - WebSocketServer.sendInfo("往来单位信息下载已完成，请刷新查看！", "sid"); +// WebSocketServer.sendInfo("往来单位信息下载已完成，请刷新查看！", "sid"); thrProductsImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); thrProductsImportLogEntity.setUpdateTime(new Date()); thrCorpImportLogService.updateImportLog(thrProductsImportLogEntity); @@ -119,7 +119,7 @@ public class ThrCorpsDlService { public void importCorps(String genKey, ThrUnitMaintainFilterRequest thrUnitMaintainFilterRequest, String thirdSys) { ThrSystemDetailEntity piDetailEntity = thrSystemDetailService.selectByKey("corpUrl", thirdSys); if (piDetailEntity == null || piDetailEntity.getValue() == null) { - WebSocketServer.sendInfo("往来单位接口未设置！", "sid"); +// WebSocketServer.sendInfo("往来单位接口未设置！", "sid"); return; } ThrCorpImportLogEntity thrProductsImportLogEntity = thrCorpImportLogService.selectByGenKey(genKey); @@ -147,7 +147,7 @@ public class ThrCorpsDlService { thrCorpService.insertThrCorpss(data); } redisUtil.set(Constant.dlThrProducts, "false"); - WebSocketServer.sendInfo("往来单位信息下载已完成，请刷新查看！", "sid"); +// WebSocketServer.sendInfo("往来单位信息下载已完成，请刷新查看！", "sid"); thrProductsImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); thrProductsImportLogEntity.setUpdateTime(new Date()); thrCorpImportLogService.updateImportLog(thrProductsImportLogEntity); @@ -353,9 +353,9 @@ public class ThrCorpsDlService { public List> genExcelData(FilterThrCorpRequest filterThrOrderRequest) { List> excelData = new ArrayList<>(); - List thrCorpEntityList=new ArrayList<>(); + List thrCorpEntityList = new ArrayList<>(); List thrCorpsResponseList = thrCorpService.filterThrCorps(filterThrOrderRequest); - if(thrCorpsResponseList.size()>0){ + if (thrCorpsResponseList.size() > 0) { thrCorpEntityList = thrCorpsResponseList.stream().map( item -> { ThrCorpEntity thrCorpEntity = new ThrCorpEntity(); @@ -419,12 +419,12 @@ public class ThrCorpsDlService { exportData.addAll(thrCorpEntities); } else { //根据查询条件一键导出数据库往来单位 - List thrCorpEntityList=new ArrayList<>(); + List thrCorpEntityList = new ArrayList<>(); FilterThrCorpRequest filterThrCorpRequest = new FilterThrCorpRequest(); BeanUtils.copyProperties(thrCorpExportRequest, filterThrCorpRequest); filterThrCorpRequest.setPage(null); List thrCorpsResponseList = thrCorpService.filterThrCorps(filterThrCorpRequest); - if(thrCorpsResponseList.size()>0){ + if (thrCorpsResponseList.size() > 0) { thrCorpEntityList = thrCorpsResponseList.stream().map( item -> { ThrCorpEntity thrCorpEntity = new ThrCorpEntity(); @@ -476,12 +476,12 @@ public class ThrCorpsDlService { exportData.addAll(thrCorpEntities); } else { //根据查询条件一键导出数据库往来单位 - List thrCorpEntityList=new ArrayList<>(); + List thrCorpEntityList = new ArrayList<>(); FilterThrCorpRequest filterThrCorpRequest = new FilterThrCorpRequest(); BeanUtils.copyProperties(thrCorpExportRequest, filterThrCorpRequest); filterThrCorpRequest.setPage(null); List thrCorpsResponseList = thrCorpService.filterThrCorps(filterThrCorpRequest); - if(thrCorpsResponseList.size()>0){ + if (thrCorpsResponseList.size() > 0) { thrCorpEntityList = thrCorpsResponseList.stream().map( item -> { ThrCorpEntity thrCorpEntity = new ThrCorpEntity(); diff --git a/src/main/java/com/glxp/api/service/thrsys/ThrInvProductsDlService.java b/src/main/java/com/glxp/api/service/thrsys/ThrInvProductsDlService.java index 6ac7b4d4..2019d432 100644 --- a/src/main/java/com/glxp/api/service/thrsys/ThrInvProductsDlService.java +++ b/src/main/java/com/glxp/api/service/thrsys/ThrInvProductsDlService.java @@ -2,7 +2,6 @@ package com.glxp.api.service.thrsys; import com.glxp.api.common.res.BaseResponse; -import com.glxp.api.config.WebSocketServer; import com.glxp.api.constant.BasicProcessStatus; import com.glxp.api.constant.Constant; import com.glxp.api.entity.thrsys.*; @@ -13,6 +12,7 @@ import com.glxp.api.res.thrsys.ThrInvProductResponse; import com.glxp.api.service.auth.CustomerService; import com.glxp.api.util.ExcelUtil; import com.glxp.api.util.RedisUtil; +import org.java_websocket.server.WebSocketServer; import org.springframework.beans.BeanUtils; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; @@ -48,7 +48,7 @@ public class ThrInvProductsDlService { ThrInvProductsImportLogEntity thrInvProductsImportLogEntity = thrInvProductsImportLogService.selectByGenKey(genKey); ThrSystemDetailEntity piDetailEntity = thrSystemDetailService.selectByKey("invPiUrl", thirdSys); if (piDetailEntity == null || piDetailEntity.getValue() == null) { - WebSocketServer.sendInfo("库存产品信息接口未设置！", "sid"); +// WebSocketServer.sendInfo("库存产品信息接口未设置！", "sid"); return; } @@ -88,7 +88,7 @@ public class ThrInvProductsDlService { ).collect(Collectors.toList()); thrInvProductsService.insertThrInvProducts(thrInvProductsEntities); redisUtil.set(Constant.dlThrProducts, "false"); - WebSocketServer.sendInfo("库存产品信息下载已完成，请刷新查看！", "sid"); +// WebSocketServer.sendInfo("库存产品信息下载已完成，请刷新查看！", "sid"); thrInvProductsImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); thrInvProductsImportLogService.updateImportLog(thrInvProductsImportLogEntity); @@ -99,7 +99,7 @@ public class ThrInvProductsDlService { public void importProducrs(String genKey, String thirdSys, ThrOnhandRequest thrOnhandRequest) { ThrSystemDetailEntity thrSystemDetailEntity = thrSystemDetailService.selectByKey("invPiUrl", thirdSys); if (thrSystemDetailEntity == null || thrSystemDetailEntity.getValue() == null) { - WebSocketServer.sendInfo("库存产品信息接口未设置！", "sid"); +// WebSocketServer.sendInfo("库存产品信息接口未设置！", "sid"); return; } ThrInvProductsImportLogEntity thrInvProductsImportLogEntity = thrInvProductsImportLogService.selectByGenKey(genKey); @@ -124,7 +124,7 @@ public class ThrInvProductsDlService { ).collect(Collectors.toList()); thrInvProductsService.insertThrInvProducts(thrInvProductsEntities); redisUtil.set(Constant.dlThrProducts, "false"); - WebSocketServer.sendInfo("库存产品信息下载已完成，请刷新查看！", "sid"); +// WebSocketServer.sendInfo("库存产品信息下载已完成，请刷新查看！", "sid"); } @Async diff --git a/src/main/java/com/glxp/api/service/thrsys/ThrOrdersDlService.java b/src/main/java/com/glxp/api/service/thrsys/ThrOrdersDlService.java index 729e6f22..38905c2d 100644 --- a/src/main/java/com/glxp/api/service/thrsys/ThrOrdersDlService.java +++ b/src/main/java/com/glxp/api/service/thrsys/ThrOrdersDlService.java @@ -3,8 +3,6 @@ package com.glxp.api.service.thrsys; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.TypeReference; import com.glxp.api.common.res.BaseResponse; -import com.glxp.api.common.util.ResultVOUtils; -import com.glxp.api.config.WebSocketServer; import com.glxp.api.constant.BasicProcessStatus; import com.glxp.api.constant.Constant; import com.glxp.api.entity.sync.SyncDataSetEntity; @@ -19,6 +17,7 @@ import com.glxp.api.res.PageSimpleResponse; import com.glxp.api.res.thrsys.ThrOrderResponse; import com.glxp.api.service.sync.SyncDataSetService; import com.glxp.api.util.RedisUtil; +import org.java_websocket.server.WebSocketServer; import org.springframework.beans.BeanUtils; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; @@ -70,12 +69,12 @@ public class ThrOrdersDlService { ThrSystemDetailEntity thrSystemDetailEntity = iThrBusTypeOriginService.findSysByAction(action, "orderQueryUrl"); if (thrSystemDetailEntity == null || !thrSystemDetailEntity.getEnabled()) { - WebSocketServer.sendInfo("业务单据查询接口未设置！", "sid"); +// WebSocketServer.sendInfo("业务单据查询接口未设置！", "sid"); return; } if (thrSystemDetailEntity.getThirdSysFk() == null) { - WebSocketServer.sendInfo("业务单据查询接口未设置！", "sid"); +// WebSocketServer.sendInfo("业务单据查询接口未设置！", "sid"); return; } int page = 1; @@ -85,7 +84,7 @@ public class ThrOrdersDlService { } thrOrderImportLogService.importThrOrder(genKey); redisUtil.set(Constant.dlThrProducts, "false"); - WebSocketServer.sendInfo("业务单据信息下载已完成，请刷新查看！", "sid"); +// WebSocketServer.sendInfo("业务单据信息下载已完成，请刷新查看！", "sid"); thrOrderImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); thrOrderImportLogService.updateImportLog(thrOrderImportLogEntity); } @@ -117,7 +116,7 @@ public class ThrOrdersDlService { } } redisUtil.set(Constant.dlThrProducts, "false"); - WebSocketServer.sendInfo("业务单据信息下载已完成，请刷新查看！", "sid"); +// WebSocketServer.sendInfo("业务单据信息下载已完成，请刷新查看！", "sid"); thrOrderImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); thrOrderImportLogService.updateImportLog(thrOrderImportLogEntity); }