采购-供应商报价看板：供应商报价项目看板未结束实时推送服务

+package com.lframework.xingyun.sc.listeners.app;
+
+import com.lframework.xingyun.sc.events.quotation.CommonChangedEvent;
+import com.lframework.xingyun.sc.procurement.impl.quotation.SupplierQuotationProjectQuoteServiceImpl;
+import com.lframework.xingyun.sc.procurement.impl.quotation.SupplierQuotationProjectServiceImpl;
+import com.lframework.xingyun.sc.procurement.websocket.quotation.project.SupplierQuotationProjectRealtimePushService;
+import javax.annotation.Resource;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+/**
+ * 供应商报价项目看板实时推送监听器
+ */
+@Component
+public class SupplierQuotationProjectRealtimeListener {
+
+    @Resource
+    private SupplierQuotationProjectRealtimePushService realtimePushService;
+
+    /**
+     * 报价项目或供应商报价变更后，广播当日完整看板数据
+     *
+     * @param event 变更事件
+     */
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void handleChanged(CommonChangedEvent event) {
+        if (!(event.getSource() instanceof SupplierQuotationProjectServiceImpl)
+                && !(event.getSource() instanceof SupplierQuotationProjectQuoteServiceImpl)) {
+            return;
+        }
+        realtimePushService.broadcastCurrentDayFullData(event.getEventType());
+    }
+}

+package com.lframework.xingyun.sc.procurement.dto.quotation;
+
+import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProject;
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+import lombok.Data;
+
+@Data
+public class SupplierQuotationProjectRealtimeMessage implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 消息类型
+     */
+    private String messageType;
+
+    /**
+     * 事件类型
+     */
+    private String eventType;
+
+    /**
+     * 业务日期
+     */
+    private LocalDate businessDate;
+
+    /**
+     * 推送时间
+     */
+    private LocalDateTime pushTime;
+
+    /**
+     * 项目列表（内含供应商报价子表）
+     */
+    private List<SupplierQuotationProject> records;
+}
+

@@ -17,6 +17,7 @@ import com.lframework.starter.web.inner.service.system.SysRoleService;
 import com.lframework.starter.web.inner.service.system.SysUserService;
 import com.lframework.xingyun.basedata.entity.BreedRelationship;
 import com.lframework.xingyun.basedata.service.breed.BreedRelationshipService;
+import com.lframework.xingyun.sc.events.quotation.CommonChangedEvent;
 import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProject;
 import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProjectQuote;
 import com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationProjectMapper;
@@ -32,6 +33,7 @@ import java.util.Set;
 import java.util.stream.Collectors;
 import javax.annotation.Resource;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -63,6 +65,8 @@ public class SupplierQuotationProjectQuoteServiceImpl
     private SysRoleService sysRoleService;
     @Resource
     private BreedRelationshipService breedRelationshipService;
+    @Resource
+    private ApplicationEventPublisher applicationEventPublisher;
 
     @OpLog(type = OtherOpLogType.class, name = "供应商报价项目报价，项目ID：{}", params = {"#vo.projectId"})
     @Transactional(rollbackFor = Exception.class)
@@ -102,6 +106,7 @@ public class SupplierQuotationProjectQuoteServiceImpl
                     .eq(SupplierQuotationProjectQuote::getId, exist.getId());
             getBaseMapper().update(updateWrapper);
         }
+        publishChangedEvent(vo.getProjectId(), "QUOTE");
 
         OpLogUtil.setExtra(vo);
     }
@@ -114,18 +119,21 @@ public class SupplierQuotationProjectQuoteServiceImpl
 
     @Override
     public List<SupplierQuotationProjectQuote> listByProject(String projectId) {
+        String currentUserId = SecurityUtil.getCurrentUser().getId();
+        return listByProject(projectId, currentUserId);
+    }
+
+    @Override
+    public List<SupplierQuotationProjectQuote> listByProject(String projectId, String userId) {
         SupplierQuotationProject project = supplierQuotationProjectMapper.selectById(projectId);
         if (project == null) {
             throw new DefaultClientException("报价项目不存在！");
         }
 
-        List<SysRole> sysRoleList = sysRoleService.getByUserId(SecurityUtil.getCurrentUser().getId());
-        Set<String> roleCodeSet = sysRoleList.stream()
-                .map(SysRole::getCode)
-                .collect(Collectors.toSet());
+        Set<String> roleCodeSet = getRoleCodeSet(userId);
 
         if (roleCodeSet.contains("gys")) {
-            SupplierQuotationProjectQuote supplierQuotationProjectQuote = getMyQuote(projectId);
+            SupplierQuotationProjectQuote supplierQuotationProjectQuote = getBaseMapper().findByProjectAndSupplier(projectId, userId);
             if (supplierQuotationProjectQuote == null) {
                 return Collections.emptyList();
             }
@@ -166,6 +174,7 @@ public class SupplierQuotationProjectQuoteServiceImpl
                 .set(SupplierQuotationProjectQuote::getBidStatus, bidStatus)
                 .eq(SupplierQuotationProjectQuote::getId, exist.getId());
         getBaseMapper().update(updateWrapper);
+        publishChangedEvent(vo.getProjectId(), "BID_STATUS_UPDATE");
 
         OpLogUtil.setExtra(vo);
     }
@@ -217,6 +226,17 @@ public class SupplierQuotationProjectQuoteServiceImpl
         throw new DefaultClientException("中标状态不合法！");
     }
 
+    private void publishChangedEvent(String id, String eventType) {
+        applicationEventPublisher.publishEvent(new CommonChangedEvent(this, id, eventType));
+    }
+
+    private Set<String> getRoleCodeSet(String userId) {
+        List<SysRole> sysRoleList = sysRoleService.getByUserId(userId);
+        return sysRoleList.stream()
+                .map(SysRole::getCode)
+                .collect(Collectors.toSet());
+    }
+
     private boolean isCentralBid(String projectType) {
         if (StringUtils.isBlank(projectType)) {
             return false;

@@ -17,6 +17,7 @@ import com.lframework.starter.web.core.utils.PageResultUtil;
 import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
 import com.lframework.xingyun.basedata.entity.BreedRelationship;
 import com.lframework.xingyun.basedata.service.breed.BreedRelationshipService;
+import com.lframework.xingyun.sc.events.quotation.CommonChangedEvent;
 import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProject;
 import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProjectQuote;
 import com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationProjectMapper;
@@ -32,6 +33,7 @@ import java.time.format.DateTimeFormatter;
 import java.util.List;
 import javax.annotation.Resource;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -59,6 +61,8 @@ public class SupplierQuotationProjectServiceImpl
     private BreedRelationshipService breedRelationshipService;
     @Resource
     private SupplierQuotationProjectQuoteService supplierQuotationProjectQuoteService;
+    @Resource
+    private ApplicationEventPublisher applicationEventPublisher;
 
     @Override
     public PageResult<SupplierQuotationProject> query(Integer pageIndex, Integer pageSize, QuerySupplierQuotationProjectVo vo) {
@@ -78,6 +82,20 @@ public class SupplierQuotationProjectServiceImpl
     }
 
     @Override
+    public List<SupplierQuotationProject> queryCurrentDayBoardList(LocalDate day, String userId) {
+        List<SupplierQuotationProject> datas = getBaseMapper().queryCurrentDayList(day);
+        fillComputedStatus(datas);
+        if (datas == null || datas.isEmpty()) {
+            return datas;
+        }
+        for (SupplierQuotationProject data : datas) {
+            List<SupplierQuotationProjectQuote> quoteList = supplierQuotationProjectQuoteService.listByProject(data.getId(), userId);
+            data.setSupplierQuotationProjectQuoteList(quoteList);
+        }
+        return datas;
+    }
+
+    @Override
     public SupplierQuotationProject findById(String id) {
         SupplierQuotationProject data = getBaseMapper().findById(id);
         if (data != null) {
@@ -109,6 +127,7 @@ public class SupplierQuotationProjectServiceImpl
         data.setStatus(null);
 
         getBaseMapper().insert(data);
+        publishChangedEvent(data.getId(), "CREATE");
 
         OpLogUtil.setVariable("id", data.getId());
         OpLogUtil.setExtra(vo);
@@ -139,6 +158,7 @@ public class SupplierQuotationProjectServiceImpl
                 .eq(SupplierQuotationProject::getId, vo.getId());
 
         getBaseMapper().update(updateWrapper);
+        publishChangedEvent(vo.getId(), "UPDATE");
 
         OpLogUtil.setVariable("id", vo.getId());
         OpLogUtil.setExtra(vo);
@@ -149,6 +169,7 @@ public class SupplierQuotationProjectServiceImpl
     @Override
     public void delete(String id) {
         getBaseMapper().deleteById(id);
+        publishChangedEvent(id, "DELETE");
 
         OpLogUtil.setVariable("id", id);
         OpLogUtil.setExtra(id);
@@ -168,6 +189,7 @@ public class SupplierQuotationProjectServiceImpl
                 .eq(SupplierQuotationProject::getId, id);
 
         getBaseMapper().update(updateWrapper);
+        publishChangedEvent(id, "STATUS_UPDATE");
 
         OpLogUtil.setVariable("id", id);
         OpLogUtil.setExtra(status);
@@ -257,5 +279,9 @@ public class SupplierQuotationProjectServiceImpl
         return data.getStatus();
     }
 
+    private void publishChangedEvent(String id, String eventType) {
+        applicationEventPublisher.publishEvent(new CommonChangedEvent(this, id, eventType));
+    }
+
 }
 

@@ -2,6 +2,7 @@ package com.lframework.xingyun.sc.procurement.mappers.quotation;
 
 import com.lframework.starter.web.core.mapper.BaseMapper;
 import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProject;
+import java.time.LocalDate;
 import com.lframework.xingyun.sc.procurement.vo.quotation.QuerySupplierQuotationProjectVo;
 import java.util.List;
 import org.apache.ibatis.annotations.Param;
@@ -13,5 +14,7 @@ public interface SupplierQuotationProjectMapper extends BaseMapper<SupplierQuota
     SupplierQuotationProject findById(@Param("id") String id);
 
     String getMaxCodeByDay(@Param("dayPrefix") String dayPrefix);
+
+    List<SupplierQuotationProject> queryCurrentDayList(@Param("day") LocalDate day);
 }
 

@@ -14,6 +14,8 @@ public interface SupplierQuotationProjectQuoteService extends BaseMpService<Supp
 
     List<SupplierQuotationProjectQuote> listByProject(String projectId);
 
+    List<SupplierQuotationProjectQuote> listByProject(String projectId, String userId);
+
     void updateBidStatus(UpdateSupplierQuotationProjectQuoteBidStatusVo vo);
 }
 

@@ -6,6 +6,7 @@ import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProject;
 import com.lframework.xingyun.sc.procurement.vo.quotation.CreateSupplierQuotationProjectVo;
 import com.lframework.xingyun.sc.procurement.vo.quotation.QuerySupplierQuotationProjectVo;
 import com.lframework.xingyun.sc.procurement.vo.quotation.UpdateSupplierQuotationProjectVo;
+import java.time.LocalDate;
 import java.util.List;
 
 public interface SupplierQuotationProjectService extends BaseMpService<SupplierQuotationProject> {
@@ -22,6 +23,8 @@ public interface SupplierQuotationProjectService extends BaseMpService<SupplierQ
 
     void delete(String id);
 
+    List<SupplierQuotationProject> queryCurrentDayBoardList(LocalDate day, String userId);
+
     /**
      * 更新项目状态
      *

+package com.lframework.xingyun.sc.procurement.websocket.quotation.project;
+
+import com.lframework.starter.web.core.utils.JsonUtil;
+import com.lframework.xingyun.sc.procurement.dto.quotation.SupplierQuotationProjectRealtimeMessage;
+import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProject;
+import com.lframework.xingyun.sc.procurement.service.quotation.SupplierQuotationProjectService;
+import java.io.IOException;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import javax.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.web.socket.TextMessage;
+import org.springframework.web.socket.WebSocketSession;
+
+/**
+ * 供应商报价项目看板实时推送服务
+ */
+@Slf4j
+@Service
+public class SupplierQuotationProjectRealtimePushService {
+
+    /**
+     * 当前在线连接
+     */
+    private final Map<String, WebSocketSession> sessionMap = new ConcurrentHashMap<>();
+
+    @Resource
+    private SupplierQuotationProjectService supplierQuotationProjectService;
+
+    /**
+     * 注册连接
+     *
+     * @param session WebSocket 会话
+     */
+    public void register(WebSocketSession session) {
+        sessionMap.put(session.getId(), session);
+    }
+
+    /**
+     * 注销连接
+     *
+     * @param session WebSocket 会话
+     */
+    public void unregister(WebSocketSession session) {
+        if (session != null) {
+            sessionMap.remove(session.getId());
+        }
+    }
+
+    /**
+     * 广播当日完整报价项目看板数据
+     *
+     * @param eventType 事件类型
+     */
+    public void broadcastCurrentDayFullData(String eventType) {
+        if (sessionMap.isEmpty()) {
+            return;
+        }
+
+        for (WebSocketSession session : sessionMap.values()) {
+            replayCurrentDayFullData(session, eventType);
+        }
+    }
+
+    /**
+     * 向单个连接补推当日完整报价项目看板数据
+     *
+     * @param session   WebSocket 会话
+     * @param eventType 事件类型
+     */
+    public void replayCurrentDayFullData(WebSocketSession session, String eventType) {
+        if (session == null) {
+            return;
+        }
+        sendMessage(session, JsonUtil.toJsonString(buildCurrentDayMessage(session, eventType)));
+    }
+
+    /**
+     * 构建当日完整数据消息
+     *
+     * @param session   WebSocket 会话
+     * @param eventType 事件类型
+     * @return 推送消息
+     */
+    private SupplierQuotationProjectRealtimeMessage buildCurrentDayMessage(WebSocketSession session, String eventType) {
+        LocalDate today = LocalDate.now();
+        String userId = getUserId(session);
+        List<SupplierQuotationProject> records = supplierQuotationProjectService.queryCurrentDayBoardList(today, userId);
+
+        SupplierQuotationProjectRealtimeMessage message = new SupplierQuotationProjectRealtimeMessage();
+        message.setMessageType("FULL_SYNC");
+        message.setEventType(eventType);
+        message.setBusinessDate(today);
+        message.setPushTime(LocalDateTime.now());
+        message.setRecords(records);
+        return message;
+    }
+
+    /**
+     * 发送消息
+     *
+     * @param session WebSocket 会话
+     * @param payload 消息体
+     */
+    private void sendMessage(WebSocketSession session, String payload) {
+        if (session == null || !session.isOpen()) {
+            unregister(session);
+            return;
+        }
+
+        try {
+            synchronized (session) {
+                session.sendMessage(new TextMessage(payload));
+            }
+        } catch (IOException e) {
+            log.warn("供应商报价项目看板实时推送失败，sessionId={}", session.getId(), e);
+            unregister(session);
+        }
+    }
+
+    /**
+     * 获取连接用户ID
+     *
+     * @param session WebSocket 会话
+     * @return 用户ID
+     */
+    private String getUserId(WebSocketSession session) {
+        Object userId = session.getAttributes().get(SupplierQuotationProjectWebSocketHandshakeInterceptor.ATTR_USER_ID);
+        return userId == null ? StringUtils.EMPTY : String.valueOf(userId);
+    }
+}
+

+package com.lframework.xingyun.sc.procurement.websocket.quotation.project;
+
+import javax.annotation.Resource;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.socket.config.annotation.EnableWebSocket;
+import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
+import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
+
+/**
+ * 供应商报价项目看板 WebSocket 配置
+ */
+@Configuration
+@EnableWebSocket
+public class SupplierQuotationProjectWebSocketConfig implements WebSocketConfigurer {
+
+    /**
+     * WebSocket 路径
+     */
+    public static final String ENDPOINT = "/ws/procurement/supplierQuotationProject/realtime";
+
+    @Resource
+    private SupplierQuotationProjectWebSocketHandler webSocketHandler;
+    @Resource
+    private SupplierQuotationProjectWebSocketHandshakeInterceptor handshakeInterceptor;
+
+    @Override
+    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
+        registry.addHandler(webSocketHandler, ENDPOINT)
+                .addInterceptors(handshakeInterceptor)
+                .setAllowedOrigins("*");
+    }
+}
+

+package com.lframework.xingyun.sc.procurement.websocket.quotation.project;
+
+import javax.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Component;
+import org.springframework.web.socket.CloseStatus;
+import org.springframework.web.socket.TextMessage;
+import org.springframework.web.socket.WebSocketSession;
+import org.springframework.web.socket.handler.TextWebSocketHandler;
+
+/**
+ * 供应商报价项目看板 WebSocket 处理器
+ */
+@Slf4j
+@Component
+public class SupplierQuotationProjectWebSocketHandler extends TextWebSocketHandler {
+
+    @Resource
+    private SupplierQuotationProjectRealtimePushService realtimePushService;
+
+    @Override
+    public void afterConnectionEstablished(WebSocketSession session) {
+        realtimePushService.register(session);
+        realtimePushService.replayCurrentDayFullData(session, "INIT");
+    }
+
+    @Override
+    protected void handleTextMessage(WebSocketSession session, TextMessage message) {
+        String payload = StringUtils.trimToEmpty(message.getPayload());
+        if ("SYNC_TODAY".equalsIgnoreCase(payload) || "RESYNC".equalsIgnoreCase(payload)) {
+            realtimePushService.replayCurrentDayFullData(session, "RESYNC");
+        }
+    }
+
+    @Override
+    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) {
+        realtimePushService.unregister(session);
+    }
+
+    @Override
+    public void handleTransportError(WebSocketSession session, Throwable exception) {
+        log.warn("供应商报价项目看板 WebSocket 连接异常，sessionId={}", session.getId(), exception);
+        realtimePushService.unregister(session);
+    }
+}
+

+package com.lframework.xingyun.sc.procurement.websocket.quotation.project;
+
+import com.lframework.starter.web.inner.entity.SysUser;
+import com.lframework.xingyun.sc.procurement.websocket.quotation.CommonWebSocketAuthService;
+import java.util.Map;
+import javax.annotation.Resource;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.server.ServerHttpRequest;
+import org.springframework.http.server.ServerHttpResponse;
+import org.springframework.stereotype.Component;
+import org.springframework.web.socket.WebSocketHandler;
+import org.springframework.web.socket.server.HandshakeInterceptor;
+
+/**
+ * 供应商报价项目看板 WebSocket 握手鉴权拦截器
+ */
+@Component
+public class SupplierQuotationProjectWebSocketHandshakeInterceptor implements HandshakeInterceptor {
+
+    /**
+     * 用户ID属性名
+     */
+    public static final String ATTR_USER_ID = "userId";
+
+    /**
+     * 用户名称属性名
+     */
+    public static final String ATTR_USER_NAME = "userName";
+
+    @Resource
+    private CommonWebSocketAuthService authService;
+
+    @Override
+    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response,
+                                   WebSocketHandler wsHandler, Map<String, Object> attributes) {
+        try {
+            SysUser user = authService.authenticateCurrentUser();
+            attributes.put(ATTR_USER_ID, user.getId());
+            attributes.put(ATTR_USER_NAME, user.getName());
+            return true;
+        } catch (Exception e) {
+            response.setStatusCode(HttpStatus.FORBIDDEN);
+            return false;
+        }
+    }
+
+    @Override
+    public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response,
+                               WebSocketHandler wsHandler, Exception exception) {
+    }
+}
+

@@ -89,5 +89,12 @@
         ORDER BY CAST(RIGHT(tb.code, 2) AS UNSIGNED) DESC
         LIMIT 1
     </select>
+
+    <select id="queryCurrentDayList" resultMap="SupplierQuotationProject">
+        <include refid="SupplierQuotationProjectSql"/>
+        WHERE DATE(tb.create_time) = #{day}
+        AND tb.status='PUBLISHED'
+        ORDER BY tb.create_time DESC, tb.id DESC
+    </select>
 </mapper>