{
+ setKey(key + 1)
+ }, [props]);
+ return (
+
- )
+
+
+ )
}
function HomeView() {
@@ -141,54 +147,54 @@ function HomeView() {
const location = useLocation()
const dispatch = useAppDispatch()
- const [messageCount, setMessageCount] = useState([])
+ const [messageCount, setMessageCount] = useState(0)
+ const [reimbursementCount, setReimbursementCount] = useState(0)
+ const [badgeTop, setBadgeTop] = useState(66 + 3 * 44)
+ const [eventSource, setEventSource] = useState
(null)
- // 新建Sse连接
const createSseConnect = () => {
- if (window.EventSource) {
+ if (eventSource === null) {
+ let source = new EventSourcePolyfill(baseUrl + 'common/notice/listen', {
+ headers: {
+ Authorization: "Bearer " + store.getState().token.accessToken
+ },
+ heartbeatTimeout: 21600000
+ })
- let source = new EventSource('http://localhost:3000/api1/sse/createConnect?clientId=001')
-
- // 监听打开事件
source.addEventListener('open', (e) => {
- console.log("打开连接 onopen==>", e)
+ console.log("open==>", e)
})
- // 监听消息事件
- source.addEventListener("message", (e) => {
-
+ source.addEventListener("init", (e) => {
+ console.log("init==>", e)
+ })
+
+ source.addEventListener("reimbursement", (e) => {
+ console.log("reimbursement==>", e)
+ // @ts-ignore
+ setReimbursementCount(reimbursementCount + Number(e.data))
+ })
+
+ source.addEventListener("notice", (e) => {
+ console.log("notice==>", e)
+ // @ts-ignore
+ setMessageCount(messageCount + Number(e.data))
})
- // 监听错误事件
source.addEventListener("error", (e) => {
-
+ console.log("error==>", e)
})
// 关闭连接
source.close = () => {
console.log("source.close")
}
-
- } else {
- alert("该浏览器不支持SSE")
+ setEventSource(source)
}
+
}
- // 获取系统消息
- const getSystemMessage = () => {
- // 发送网络请求
- axiosInstance.post(`http://localhost:3000/api1/sse/broadcast`).then(
- response => {
-
- },
- error => {
-
- }
- )
- }
-
-
- let items = [{
+ const items = [{
key: "/invoice/mine",
//icon: React.createElement(UserOutlined),
label: 我的发票
@@ -203,7 +209,7 @@ function HomeView() {
}, {
key: "/reimbursement/approval",
//icon: React.createElement(UserOutlined),
- label: 报销审批,
+ label: 报销审批
}, {
key: "/stat",
//icon: React.createElement(UserOutlined),
@@ -236,21 +242,59 @@ function HomeView() {
navigate('/invoice/mine')
}
+ let reimbursementStatus: number[] = []
+
if (token.staffId === 'manager') {
+ setBadgeTop(66 + 0 * 44)
setMenuItems(items.slice(3, 6))
+ reimbursementStatus.push(4)
} else if (staff.managingDepartment) {
+ setBadgeTop(66 + 3 * 44)
if (staff.managingDepartment.departmentId === 1) {
setMenuItems(items.slice(0, 5))
+ reimbursementStatus.push(3)
} else {
setMenuItems(items.slice(0, 4))
+ reimbursementStatus.push(1)
}
} else {
- if (staff.staffDepartments && staff.staffDepartments.find((value, index, obj) => value.departmentId === 1))
+ setBadgeTop(66 + 3 * 44)
+ if (staff.staffDepartments && staff.staffDepartments.find((value, index, obj) => value.departmentId === 1)) {
setMenuItems(items.slice(0, 5))
- else
+ reimbursementStatus.push(2)
+ } else
setMenuItems(items.slice(0, 2))
}
+ axiosInstance({
+ url: 'common/notice',
+ method: 'get',
+ params: {
+ pageNum: 0,
+ pageSize: 100
+ }
+ }).then(response => {
+ const data: NoticeResponse = response.data
+ let unreadCount = 0
+ for (const notice of data.records)
+ if (!notice.alreadyRead) unreadCount++
+ setMessageCount(unreadCount)
+ }).catch(function (error) {
+ console.log(error)
+ })
+
+ axiosInstance({
+ url: 'approval/reimbursement?'+ qs.stringify({
+ pageNum: 0,
+ pageSize: 1,
+ reimbursementStatus: reimbursementStatus
+ }, {skipNulls: true, arrayFormat: 'indices'}),
+ method: 'get'
+ }).then(response => {
+ setReimbursementCount(response.data.total)
+ }).catch(function (error) {
+ console.log(error)
+ })
}).catch(function (error) {
console.log(error)
})
@@ -261,7 +305,7 @@ function HomeView() {
navigate("/login")
}
getStaffInfo()
-
+ createSseConnect()
}, []);
useEffect(() => {
setDefaultSelectedKeys([location.pathname])
@@ -299,10 +343,26 @@ function HomeView() {
marginLeft: '4px'
}}>智能财务报销系统