diff --git a/pgweb/src/api/businessManage/inquiry.js b/pgweb/src/api/businessManage/inquiry.js
index 0a9e54b..dccd227 100644
--- a/pgweb/src/api/businessManage/inquiry.js
+++ b/pgweb/src/api/businessManage/inquiry.js
@@ -140,3 +140,9 @@ export async function checkBusinessNoIsValid (params) {
   const res = await post('admin/Bussiness/checkBusinessNoIsValid', params)
   return res
 }
+
+// 获取未回价数量（return_price_status=2）
+export async function getUnreturnedPriceCount (params) {
+  const res = await post('admin/Pending/getUnreturnedPriceCount', params)
+  return res
+}
diff --git a/pgweb/src/components/menu/nxIconMenu.vue b/pgweb/src/components/menu/nxIconMenu.vue
index f90f6c7..9fbf43d 100644
--- a/pgweb/src/components/menu/nxIconMenu.vue
+++ b/pgweb/src/components/menu/nxIconMenu.vue
@@ -1,9 +1,8 @@
 <template>
     <div style="height: 100%;">
-  
+
       <el-menu
         :default-active="'0'"
-        
         @select="handleSelect"
         @open="handleOpen"
         :collapse="collapse"
@@ -11,22 +10,25 @@
       >
         <template v-for="(menuItem, i_index) in menuData">
          <el-menu-item :index="String(i_index)" :key="i_index">
-            <template >                    
-              <!-- <i  style="margin-top: -18px;color: #444444;" :class=" replacePhrases( menuItem.title, iconsRule) "></i>
-              <div style="margin-top:-48px;" class="menu-custom">{{ replacePhrases( menuItem.title, replaceRule1)}}</div>          -->
+            <template >
               <div style="display: flex; align-items: center;" class="menu-custom">
                 <i :class="replacePhrases(menuItem.title, iconsRule)"></i>
-                <div style="margin-left: 8px;">{{ replacePhrases(menuItem.title, replaceRule1) }}</div>
+                <div style="display: flex; align-items: center; margin-left: 8px;">
+                  {{ replacePhrases(menuItem.title, replaceRule1) }}
+                </div>
+                <div v-if="isHuiJiaMenu(menuItem) && unreturnedCount >= 1" class="push-value-badge">{{ unreturnedCount }}</div>
               </div>
-            </template>        
-        </el-menu-item>          
+            </template>
+        </el-menu-item>
         </template>
       </el-menu>
     </div>
   </template>
-  
+
   <script>
   import "@/styles/globalSetting.less";
+  import { EventBus } from '@/libs/eventBus'
+  import socket from '@/libs/socket'
   export default {
     name: 'NxIconMenu',
     props: {
@@ -42,16 +44,17 @@
     data() {
       return {
         activeMenu: '1-4-1',
+        unreturnedCount: 0,
         replaceRule1:[
           ['询价项目','询价'],
           ['回价项目','回价'],
           ['预估单','预估'],
           ['查勘项目','查勘'],
           ['报告项目','报告'],
-          ['分部管理','分部'], 
+          ['分部管理','分部'],
           ['财务项目','财务'],
           ['基础设置','设置'],
-          ['OA办公','OA'],// 隐藏
+          ['OA办公','OA'],
           ['银行对接','银行'],
         ],
         iconsRule:[
@@ -63,36 +66,47 @@
           ['报告项目','el-icon-tickets'],
           ['财务项目','el-icon-money'],
           ['基础设置','el-icon-setting'],
-          ['OA办公' , 'el-icon-bell'], // 隐藏
+          ['OA办公' , 'el-icon-bell'],
           ['银行对接','el-icon-bank-card'],
         ]
       };
     },
+    mounted() {
+      // 监听EventBus事件
+      this.eventBusCallback = (count) => {
+        this.$set(this, 'unreturnedCount', count)
+      }
+      this.socketCallback = (data) => {
+        if (data && data.count !== undefined) {
+          this.$set(this, 'unreturnedCount', data.count)
+        }
+      }
+      EventBus.$on('updateUnreturnedCount', this.eventBusCallback)
+      socket.on('updateUnreturnedCount', this.socketCallback)
+    },
+    beforeDestroy() {
+      EventBus.$off('updateUnreturnedCount', this.eventBusCallback)
+      socket.off('updateUnreturnedCount', this.socketCallback)
+    },
     methods: {
+        isHuiJiaMenu(menuItem) {
+          return menuItem.title === '回价项目' || menuItem.routerName === 'priceReturn'
+        },
         handleSelect(key, item , externalInfo ) {
-        console.log('menu-select', key, item,externalInfo);
-        this.$emit('menu-select', key, item.routerName, externalInfo);
-        console.log('externalInfo menu-select', externalInfo ,key,item );
+          this.$emit('menu-select', key, item.routerName, externalInfo);
       },
       handleOpen(key, keyPath) {
-        console.log('menu-open', key, keyPath, externalInfo );
-        this.$emit('menu-open', key, keyPath, externalInfo);
-        console.log('externalInfo menu-open', externalInfo ,key,item );
+        this.$emit('menu-open', key, keyPath);
       },
       handleClose(key, keyPath, externalInfo ) {
-        console.log('menu-close', key, keyPath, externalInfo);
         this.$emit('menu-close', key, keyPath, externalInfo);
       },
-      
+
       toggleCollapse() {
-        // 触发事件通知父组件改变collapse状态
         this.$emit('toggle-collapse', !this.collapse);
       },
-
       replacePhrases(text, replacementRules) {
-        // 遍历替换规则数组
         for (let i=0; i< replacementRules.length; i++) {
-          // 使用正则表达式查找匹配的短语
           if (text == replacementRules[i][0]) {
             return replacementRules[i][1];
         }
@@ -102,7 +116,7 @@
     },
   };
   </script>
-  
+
   <style scoped>
   .collapse-btn {
     height: 40px;
@@ -144,6 +158,8 @@
 }
 .menu-custom  {
   color: var(--menu-font-color);
+  display: flex;
+  align-items: center;
 }
 :deep .el-menu-item.is-active {
   background-color: var(--bg-color);
@@ -151,4 +167,20 @@
 :deep .el-menu-item.is-active .menu-custom {
   color: var(--main-color);
 }
-</style>
\ No newline at end of file
+.push-value-badge {
+  display: inline-flex;
+  align-items: center;
+  justify-content: center;
+  min-width: 18px;
+  height: 18px;
+  line-height: 18px;
+  padding: 0 4px;
+  font-size: 11px;
+  color: #fff;
+  background-color: #f56c6c;
+  border-radius: 9px;
+  margin-left: 4px;
+  text-align: center;
+  flex-shrink: 0;
+}
+</style>
diff --git a/pgweb/src/components/menu/nxMenu.vue b/pgweb/src/components/menu/nxMenu.vue
index c8861c1..387609d 100644
--- a/pgweb/src/components/menu/nxMenu.vue
+++ b/pgweb/src/components/menu/nxMenu.vue
@@ -3,27 +3,85 @@
     <div style="height: 100%;">
       <!-- 如果有子菜单，则渲染子菜单 -->
       <el-submenu style="height: 100%;" v-if="item.children && item.children.length > 0" :index="item.routerName" >
-        <template slot="title">          
+        <template slot="title">
           {{ item.title  }}
+          <!-- 一级菜单【回价】显示无数量红点 -->
+          <span v-if="isHuiJiaMenu && unreturnedCount >= 1" class="push-dot-badge"></span>
+          <!-- 二级菜单【未回价】显示带数量红点 -->
+          <span v-else-if="isUnreturnedPriceMenu && unreturnedCount > 0" class="push-value-badge">{{ unreturnedCount }}</span>
         </template>
         <!-- 递归调用MenuItem组件 -->
         <menu-item v-for="(child, index) in item.children" :key="index" :item="child" class="menu-custom"></menu-item>
       </el-submenu>
-      
+
       <!-- 如果没有子菜单，则渲染菜单项 -->
       <el-menu-item v-else :index="item.routerName" class="menu-custom">
         <!-- <i class="el-icon-document"></i> -->
         {{ item.title }}
+        <!-- 三级菜单【未回价列表】显示带数量红点 -->
+        <span v-if="isUnreturnedPriceListMenu && unreturnedCount > 0" class="push-value-badge">{{ unreturnedCount }}</span>
       </el-menu-item>
     </div>
   </template>
-  
+
   <script>
   import "@/styles/globalSetting.less";
+  import { EventBus } from '@/libs/eventBus'
+  import socket from '@/libs/socket'
   export default {
     name: 'MenuItem',
     props: {
       item: Object
+    },
+    data() {
+      return {
+        unreturnedCount: 0
+      }
+    },
+    computed: {
+      // 判断是否是一级菜单【回价项目】
+      isHuiJiaMenu() {
+        const isMatch = this.item.title === '回价项目' || this.item.routerName === 'priceReturn'
+        return isMatch
+      },
+      // 判断是否是二级菜单【未回价】
+      isUnreturnedPriceMenu() {
+        const isMatch = this.item.path === '/priceReturn/unreturnedPrice' || this.item.title === '未回价' || this.item.routerName === 'unreturnedPrice'
+        return isMatch
+      },
+      // 判断是否是三级菜单【未回价列表】
+      isUnreturnedPriceListMenu() {
+        const isMatch = this.item.title === '未回价列表'
+        return isMatch
+      }
+    },
+    mounted() {
+      console.log('菜单组件mounted - item:', this.item)
+
+      // 保存回调引用用于销毁时移除
+      this.eventBusCallback = (count) => {
+        this.unreturnedCount = count
+        console.log('EventBus收到未回价数量更新:', count, '当前item:', this.item.name || this.item.title)
+      }
+
+      this.socketCallback = (data) => {
+        if (data && data.count !== undefined) {
+          // 使用Vue.set确保响应式更新
+          this.$set(this, 'unreturnedCount', data.count)
+          console.log('WebSocket收到未回价数量更新:', data.count, '当前item:', this.item.name || this.item.title)
+        }
+      }
+
+      // 监听EventBus事件（页面初始化时）
+      EventBus.$on('updateUnreturnedCount', this.eventBusCallback)
+
+      // 监听WebSocket推送的未回价数量更新
+      socket.on('updateUnreturnedCount', this.socketCallback)
+    },
+    beforeDestroy() {
+      // 移除监听
+      EventBus.$off('updateUnreturnedCount', this.eventBusCallback)
+      socket.off('updateUnreturnedCount', this.socketCallback)
     }
   }
   </script>
@@ -37,4 +95,26 @@
   :deep .el-menu-item.is-active.menu-custom {
     color: var(--main-color);
   }
-</style>
\ No newline at end of file
+  .push-value-badge {
+    display: inline-block;
+    min-width: 20px;
+    height: 20px;
+    line-height: 20px;
+    padding: 0 6px;
+    font-size: 12px;
+    color: #fff;
+    background-color: #f56c6c;
+    border-radius: 10px;
+    margin-left: 8px;
+    text-align: center;
+  }
+  .push-dot-badge {
+    display: inline-block;
+    width: 8px;
+    height: 8px;
+    background-color: #f56c6c;
+    border-radius: 50%;
+    margin-left: 8px;
+    margin-top: 4px;
+  }
+</style>
diff --git a/pgweb/src/libs/socket.js b/pgweb/src/libs/socket.js
index 7c74449..1910f28 100644
--- a/pgweb/src/libs/socket.js
+++ b/pgweb/src/libs/socket.js
@@ -1,9 +1,65 @@
 import io from 'socket.io-client'
 
+// 使用 polling 模式以兼容 PHPSocketIO 1.1
 const socket = io(process.env.VUE_APP_SOCKET_URL, {
-  transports: ['websocket'],
-  reconnection: true, // 是否自动重新建立连接，默认为true
-  reconnectionAttempts: 1 // 尝试重连的次数，默认为无限次
+  transports: ['polling'],
+  reconnection: true,
+  reconnectionAttempts: 5,
+  autoConnect: false,
+  forceNew: true,
+  timeout: 10000,
+  jsonp: false,
+  query: {},
+  upgrade: false,
+  allowUpgrades: false,
+  rejectUnauthorized: false,
+  timestampRequests: true
 })
 
+// 添加连接状态监听
+socket.on('connect', () => {
+  console.log('WebSocket已成功连接到服务器:', process.env.VUE_APP_SOCKET_URL)
+})
+
+socket.on('disconnect', (reason) => {
+  console.log('WebSocket连接断开，原因:', reason)
+})
+
+socket.on('connect_error', (error) => {
+  console.error('WebSocket连接失败:', error)
+})
+
+socket.on('connect_timeout', () => {
+  console.error('WebSocket连接超时')
+})
+
+// 连接方法
+export const connectSocket = () => {
+  console.log('尝试启动WebSocket连接...')
+  console.log('当前连接状态:', socket.connected)
+  console.log('连接状态详细:', socket.io && socket.io.engine ? socket.io.engine.transport.name : '未知')
+  console.log('目标地址:', process.env.VUE_APP_SOCKET_URL)
+
+  // 如果未连接或者正在断开连接，尝试连接
+  if (!socket.connected || socket.disconnected) {
+    socket.connect()
+    console.log('WebSocket连接请求已发送')
+  } else {
+    console.log('WebSocket已经处于连接状态')
+  }
+}
+
+// 断开连接方法
+export const disconnectSocket = () => {
+  console.log('尝试断开WebSocket连接...')
+  console.log('当前连接状态:', socket.connected)
+
+  if (socket.connected) {
+    socket.disconnect()
+    console.log('WebSocket连接已断开')
+  } else {
+    console.log('WebSocket未连接，无需断开')
+  }
+}
+
 export default socket
diff --git a/pgweb/src/libs/unreturnedPrice.js b/pgweb/src/libs/unreturnedPrice.js
new file mode 100644
index 0000000..3260195
--- /dev/null
+++ b/pgweb/src/libs/unreturnedPrice.js
@@ -0,0 +1,26 @@
+import { EventBus } from './eventBus'
+import { getUnreturnedPriceCount } from '@/api/businessManage/inquiry'
+
+/**
+ * 获取并更新未回价数量
+ * 调用API获取最新数量，并通过EventBus广播给所有监听者
+ */
+export const fetchAndUpdateUnreturnedPriceCount = async () => {
+  console.log('fetchAndUpdateUnreturnedPriceCount: 开始获取未回价数量...')
+  try {
+    const response = await getUnreturnedPriceCount()
+    if (response && response.code === 1) {
+      const count = response.data.count || 0
+      console.log('fetchAndUpdateUnreturnedPriceCount: 获取到未回价数量:', count)
+      // 通过事件总线传递数量给菜单组件
+      EventBus.$emit('updateUnreturnedCount', count)
+      return count
+    } else {
+      console.warn('fetchAndUpdateUnreturnedPriceCount: 接口返回异常:', response)
+      return 0
+    }
+  } catch (error) {
+    console.error('fetchAndUpdateUnreturnedPriceCount: 获取未回价数量失败:', error)
+    return 0
+  }
+}
\ No newline at end of file
diff --git a/pgweb/src/router/index.js b/pgweb/src/router/index.js
index 46d61d8..d907be4 100644
--- a/pgweb/src/router/index.js
+++ b/pgweb/src/router/index.js
@@ -5,6 +5,8 @@ import iView from 'view-design'
 import { getToken, canTurnTo, initRouter, isRefreshToken } from '@/libs/util'
 import * as localStore from 'store'
 import store from '@/store'
+import { connectSocket } from '@/libs/socket'
+import { fetchAndUpdateUnreturnedPriceCount } from '@/libs/unreturnedPrice'
 
 Vue.use(Router)
 let routers = routes
@@ -30,6 +32,14 @@ const HOME_PAGE_NAME = 'home' // 平台首页
 router.beforeEach((to, from, next) => {
   iView.LoadingBar.start()
   const token = getToken()
+
+  // 如果用户已登录，确保WebSocket连接已建立并获取最新未回价数量
+  if (token && to.name !== LOGIN_PAGE_NAME) {
+    connectSocket()
+    // 每次刷新页面都获取最新的未回价数量
+    fetchAndUpdateUnreturnedPriceCount()
+  }
+
   if (!token && to.name !== LOGIN_PAGE_NAME) {
     localStore.clearAll()
     // 未登录且要跳转的页面不是登录页
diff --git a/pgweb/src/store/modules/user.js b/pgweb/src/store/modules/user.js
index e7ac8ea..a7c835f 100644
--- a/pgweb/src/store/modules/user.js
+++ b/pgweb/src/store/modules/user.js
@@ -3,6 +3,7 @@ import { login, checkLogin } from '@/api/user'
 import store from 'store'
 import config from '@/config'
 import Cookies from 'js-cookie'
+import { connectSocket } from '@/libs/socket'
 
 export default {
   state: {
@@ -33,8 +34,8 @@ export default {
     login (state, data) {
      console.log("user.js::login::userinfo",data.userinfo)
       // store.set('indexMenuList', JSON.stringify(data.menu['index']))
-    // store.set('busMenuList', JSON.stringify(data.menu))      
-      store.set('busMenuList', JSON.stringify(data.admmenu))    
+    // store.set('busMenuList', JSON.stringify(data.menu))
+      store.set('busMenuList', JSON.stringify(data.admmenu))
       store.set('userinfo', data.userinfo)
       store.set('isAdmin',data.userinfo.roleCode.includes("ROLE_ADMIN"))
       store.set('access', data.perFlags)
@@ -53,7 +54,7 @@ export default {
   },
   actions: {
     handleLogin ({ commit }, { username, password }) {
-     
+
       username = username.trim()
       return new Promise((resolve, reject) => {
         login({ username, password, version: config.version }).then(res => {
@@ -61,6 +62,8 @@ export default {
             store.clearAll()
             commit('setToken', res.data.apiAuth)
             commit('login', res.data)
+            // 登录成功后启动WebSocket连接
+            connectSocket()
           }
           resolve(res)
         }).catch(err => {
diff --git a/pgweb/src/views/home/components/message.vue b/pgweb/src/views/home/components/message.vue
index ae8a47e..8d8de99 100644
--- a/pgweb/src/views/home/components/message.vue
+++ b/pgweb/src/views/home/components/message.vue
@@ -196,13 +196,10 @@ export default {
         WorkflowProgressCount: 0 // 工作流进度-未读消息数量
       },
       label1: (h) => {
-        return h('div', [
+        const count = this.formItem.inquiryPendingCount || 0
+        return h('div', { style: { display: 'flex', alignItems: 'center' } }, [
           h('span', '询价待处理'),
-          h('Badge', {
-            props: {
-              count: this.formItem.inquiryPendingCount
-            }
-          })
+          count > 0 ? h('span', { class: 'message-badge' }, count) : null
         ])
       },
   /*   label2: (h) => {
@@ -321,6 +318,8 @@ export default {
       getMessageList().then(res => {
         if (res.code === 1) {
           this.formItem = res.data
+          console.log('message.vue 获取消息列表成功:', this.formItem)
+          console.log('询价待处理数量:', this.formItem.inquiryPendingCount)
         } else {
           this.$Message.error(res.msg)
         }
@@ -332,7 +331,7 @@ export default {
         if (res.code === 1) {
           if (row.message_type == 5 || row.message_type == 8 || row.message_type == 11 || row.message_type == 14 || row.message_type == 29 || row.message_type == 31){
             this.getMessageList()
-          } 
+          }
         } else {
           this.$Message.error(res.msg)
         }
@@ -372,4 +371,17 @@ export default {
 .issee {
   color: #ccc;
 }
+.message-badge {
+  display: inline-block;
+  min-width: 18px;
+  height: 18px;
+  line-height: 18px;
+  padding: 0 4px;
+  font-size: 11px;
+  color: #fff;
+  background-color: #f56c6c;
+  border-radius: 9px;
+  margin-left: 6px;
+  text-align: center;
+}
 </style>
diff --git a/pgweb/src/views/home/home.vue b/pgweb/src/views/home/home.vue
index 2b58a8a..aadaeb5 100644
--- a/pgweb/src/views/home/home.vue
+++ b/pgweb/src/views/home/home.vue
@@ -24,8 +24,33 @@
 </template>
 <script>
 import homePage from './components/message'
+import { connectSocket } from '@/libs/socket'
+import { EventBus } from '@/libs/eventBus'
+import { getUnreturnedPriceCount } from '@/api/businessManage/inquiry'
 export default {
-  components: { homePage }
+  components: { homePage },
+  mounted() {
+    // 进入首页时启动websocket连接
+    connectSocket()
 
+    // 获取未回价数量
+    this.getUnreturnedPriceCountData()
+  },
+  methods: {
+    // 获取未回价数量
+    async getUnreturnedPriceCountData() {
+      try {
+        const response = await getUnreturnedPriceCount()
+        if (response && response.code === 1) {
+          const count = response.data.count || 0
+          console.log('未回价数量:', count)
+          // 通过事件总线传递数量给菜单组件
+          EventBus.$emit('updateUnreturnedCount', count)
+        }
+      } catch (error) {
+        console.error('获取未回价数量失败:', error)
+      }
+    }
+  }
 }
 </script>
diff --git a/pgweb/src/views/main/components/avatar/avatar.vue b/pgweb/src/views/main/components/avatar/avatar.vue
index 5f8c1ab..ff23731 100644
--- a/pgweb/src/views/main/components/avatar/avatar.vue
+++ b/pgweb/src/views/main/components/avatar/avatar.vue
@@ -1,10 +1,10 @@
 <template>
   <div class="user-avator-dropdown">
-    <Dropdown @on-click="handleClick">              
+    <Dropdown @on-click="handleClick">
       <div style="display: inline-block; vertical-align: middle;">
         <Avatar :src="userAvator || require('@/assets/images/avatar.jpg')" size="small" style="margin-right: 10px" />
         <!-- <span style="color: #444;">{{username}}  - [退出]<i color="#444" class="el-icon-setting"></i></span>  -->
-        <span style="color: #444;">{{username}}</span>            
+        <span style="color: #444;">{{username}}</span>
       </div>
       <DropdownMenu slot="list" align="center">
         <!-- <DropdownItem name="usercenter">个人信息</DropdownItem> -->
@@ -27,6 +27,7 @@ import './avatar.less'
 import { logout } from '@/api/user'
 import store from 'store'
 import changePassword from './changePassword'
+import { disconnectSocket } from '@/libs/socket'
 export default {
   name: 'avatar',
   props: {
@@ -123,6 +124,8 @@ export default {
       switch (name) {
         case 'logout':
           logout({}).then(() => {
+            // 断开WebSocket连接
+            disconnectSocket()
             this.$store.commit('logout')
             location.reload()
           })
diff --git a/pgweb/src/views/main/components/user/user.vue b/pgweb/src/views/main/components/user/user.vue
index 6dd01c0..4671b1e 100644
--- a/pgweb/src/views/main/components/user/user.vue
+++ b/pgweb/src/views/main/components/user/user.vue
@@ -4,7 +4,7 @@
           <!--  <Avatar :src="userAvator"/> -->
             <span style="color: #444; ">{{username}}-[退出]</span>
             <i class="el-icon-setting"></i>
-            
+
             <DropdownMenu slot="list">
                  <!-- <DropdownItem name="usercenter">个人信息</DropdownItem>
                 <DropdownItem name="changePwd">修改密码</DropdownItem> -->
@@ -18,6 +18,7 @@
 import './user.less'
 import { logout } from '@/api/user'
 import store from 'store'
+import { disconnectSocket } from '@/libs/socket'
 export default {
   name: 'user',
   props: {
@@ -39,6 +40,8 @@ export default {
       switch (name) {
         case 'logout':
           logout({}).then(() => {
+            // 断开WebSocket连接
+            disconnectSocket()
             this.$store.commit('logout')
             location.reload()
           })