增加获取联系人信息接口
This commit is contained in:
@@ -1,5 +1,6 @@
|
||||
const express = require("express");
|
||||
const router = express.Router();
|
||||
const db = require("../db/mysql");
|
||||
const authMiddleware = require("../middleware/authMiddleware");
|
||||
|
||||
|
||||
@@ -19,5 +20,52 @@ router.get(
|
||||
}
|
||||
);
|
||||
|
||||
router.get(
|
||||
"/contactInfo",
|
||||
authMiddleware,
|
||||
(req, res) => {
|
||||
const sql = `
|
||||
SELECT
|
||||
u.user_id,
|
||||
u.username
|
||||
FROM chat_mysql.contacts c
|
||||
JOIN chat_mysql.users u
|
||||
ON c.contact_id = u.user_id
|
||||
WHERE c.user_id = ?;
|
||||
`;
|
||||
db.query(sql, [req.user.userId], (error, results) => {
|
||||
if (error) {
|
||||
console.error("数据库查询失败:", error);
|
||||
|
||||
return res.status(500).json({
|
||||
code: 500,
|
||||
message: "查询失败",
|
||||
});
|
||||
}
|
||||
if (results.length > 0) {
|
||||
res.json({
|
||||
code: 200,
|
||||
message: "查询成功",
|
||||
data: {
|
||||
contacts: results.map(contact => ({
|
||||
contactId: contact.user_id,
|
||||
contactName: contact.username
|
||||
}))
|
||||
},
|
||||
});
|
||||
} else {
|
||||
res.json({
|
||||
code: 401,
|
||||
message: "未找到联系人",
|
||||
data: {
|
||||
contacts: []
|
||||
}
|
||||
});
|
||||
}
|
||||
});
|
||||
|
||||
}
|
||||
);
|
||||
|
||||
|
||||
module.exports = router;
|
||||
Reference in New Issue
Block a user