Compare commits
2 Commits
feature/im
...
feature/ma
| Author | SHA1 | Date | |
|---|---|---|---|
| 566bce4663 | |||
| c828718498 |
@@ -1,13 +1,24 @@
|
|||||||
const router = require('express').Router()
|
const router = require("express").Router();
|
||||||
const {MasterModel} = require('./model/master')
|
const { MasterModel } = require("./model/master");
|
||||||
const mongoose = require("mongoose")
|
const mongoose = require("mongoose");
|
||||||
const {OrderModel} = require("./model/order")
|
const { OrderModel } = require("./model/order");
|
||||||
|
|
||||||
|
|
||||||
router.get("/masters", async (req, res, next) => {
|
router.get("/masters", async (req, res, next) => {
|
||||||
try {
|
try {
|
||||||
const masters = await MasterModel.find({});
|
const masters = await MasterModel.find({});
|
||||||
const orders = await OrderModel.find({});
|
|
||||||
|
// Создаем объекты для начала и конца текущего дня
|
||||||
|
const today = new Date();
|
||||||
|
today.setHours(0, 0, 0, 0);
|
||||||
|
const tomorrow = new Date(today);
|
||||||
|
tomorrow.setDate(tomorrow.getDate() + 1);
|
||||||
|
|
||||||
|
const orders = await OrderModel.find({
|
||||||
|
startWashTime: {
|
||||||
|
$gte: today,
|
||||||
|
$lt: tomorrow,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
const mastersWithOrders = masters.map((master) => {
|
const mastersWithOrders = masters.map((master) => {
|
||||||
const masterOrders = orders.filter((order) => {
|
const masterOrders = orders.filter((order) => {
|
||||||
@@ -36,11 +47,11 @@ router.get("/masters", async (req, res, next) => {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
router.delete('/masters/:id', async (req, res,next) => {
|
router.delete("/masters/:id", async (req, res, next) => {
|
||||||
const { id } = req.params;
|
const { id } = req.params;
|
||||||
|
|
||||||
if (!mongoose.Types.ObjectId.isValid(id)) {
|
if (!mongoose.Types.ObjectId.isValid(id)) {
|
||||||
throw new Error('ID is required')
|
throw new Error("ID is required");
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
@@ -48,58 +59,52 @@ router.delete('/masters/:id', async (req, res,next) => {
|
|||||||
new: true,
|
new: true,
|
||||||
});
|
});
|
||||||
if (!master) {
|
if (!master) {
|
||||||
throw new Error('master not found')
|
throw new Error("master not found");
|
||||||
}
|
}
|
||||||
res.status(200).send({success: true, body: master})
|
res.status(200).send({ success: true, body: master });
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
next(error)
|
next(error);
|
||||||
}
|
}
|
||||||
})
|
});
|
||||||
|
|
||||||
|
router.post("/masters", async (req, res, next) => {
|
||||||
router.post('/masters', async (req, res,next) => {
|
const { name, phone } = req.body;
|
||||||
|
|
||||||
const {name, phone} = req.body
|
|
||||||
|
|
||||||
if (!name || !phone) {
|
if (!name || !phone) {
|
||||||
throw new Error('Enter name and phone')
|
throw new Error("Enter name and phone");
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
const master = await MasterModel.create({name, phone})
|
const master = await MasterModel.create({ name, phone });
|
||||||
res.status(200).send({success: true, body: master})
|
res.status(200).send({ success: true, body: master });
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
next(error)
|
next(error);
|
||||||
}
|
}
|
||||||
})
|
});
|
||||||
|
|
||||||
|
router.patch("/masters/:id", async (req, res, next) => {
|
||||||
router.patch('/masters/:id', async (req, res, next) => {
|
|
||||||
const { id } = req.params;
|
const { id } = req.params;
|
||||||
|
|
||||||
if (!mongoose.Types.ObjectId.isValid(id)) {
|
if (!mongoose.Types.ObjectId.isValid(id)) {
|
||||||
throw new Error('ID is required')
|
throw new Error("ID is required");
|
||||||
}
|
}
|
||||||
|
|
||||||
const { name, phone } = req.body;
|
const { name, phone } = req.body;
|
||||||
|
|
||||||
if (!name && !phone) {
|
if (!name && !phone) {
|
||||||
throw new Error('Enter name and phone')
|
throw new Error("Enter name and phone");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const updateData = {};
|
const updateData = {};
|
||||||
if (name) updateData.name = name;
|
if (name) updateData.name = name;
|
||||||
if (phone) updateData.phone = phone;
|
if (phone) updateData.phone = phone;
|
||||||
|
|
||||||
const master = await MasterModel.findByIdAndUpdate(
|
const master = await MasterModel.findByIdAndUpdate(id, updateData, {
|
||||||
id,
|
new: true,
|
||||||
updateData,
|
});
|
||||||
{ new: true }
|
|
||||||
);
|
|
||||||
|
|
||||||
if (!master) {
|
if (!master) {
|
||||||
throw new Error('master not found')
|
throw new Error("master not found");
|
||||||
}
|
}
|
||||||
|
|
||||||
res.status(200).send({ success: true, body: master });
|
res.status(200).send({ success: true, body: master });
|
||||||
@@ -108,4 +113,4 @@ router.patch('/masters/:id', async (req, res, next) => {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
module.exports = router
|
module.exports = router;
|
||||||
|
|||||||
@@ -1,91 +0,0 @@
|
|||||||
const API_URL = "https://gigachat.devices.sberbank.ru/api/v1"
|
|
||||||
const router = require('express').Router()
|
|
||||||
const { v4: uuidv4 } = require("uuid");
|
|
||||||
|
|
||||||
process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0"
|
|
||||||
|
|
||||||
const token = 'MTQwMmNmZjgtZjA5OC00OGMxLWI0OTUtNWU3ZTU4YzMzZjdjOmU5OGFiYmNiLThmMDItNGVmOC1hNjhhLTA4Y2QxYjVmOGRmMA=='
|
|
||||||
|
|
||||||
|
|
||||||
const getToken = async (req, res) => {
|
|
||||||
|
|
||||||
const rqUID = uuidv4()
|
|
||||||
const body = new URLSearchParams({
|
|
||||||
scope: "GIGACHAT_API_PERS",
|
|
||||||
})
|
|
||||||
|
|
||||||
const response = await fetch("https://ngw.devices.sberbank.ru:9443/api/v2/oauth", {
|
|
||||||
method: "POST",
|
|
||||||
headers: {
|
|
||||||
Authorization: `Basic ${token}`,
|
|
||||||
"Content-Type": "application/x-www-form-urlencoded",
|
|
||||||
Accept: "application/json",
|
|
||||||
RqUID: rqUID,
|
|
||||||
},
|
|
||||||
body,
|
|
||||||
})
|
|
||||||
|
|
||||||
if (!response.ok) {
|
|
||||||
const errorData = await response.json();
|
|
||||||
console.error(" Ошибка запроса:", errorData);
|
|
||||||
return res.status(response.status).json(errorData);
|
|
||||||
}
|
|
||||||
|
|
||||||
return await response.json()
|
|
||||||
}
|
|
||||||
|
|
||||||
async function analyzeImage(fileId,token) {
|
|
||||||
const response = await fetch(`${API_URL}/chat/completions`, {
|
|
||||||
method: "POST",
|
|
||||||
headers: {
|
|
||||||
"Content-Type": "application/json",
|
|
||||||
Accept: "application/json",
|
|
||||||
Authorization: `Bearer ${token}`,
|
|
||||||
},
|
|
||||||
body: JSON.stringify({
|
|
||||||
model: "GigaChat-Max",
|
|
||||||
stream: false,
|
|
||||||
update_interval: 0,
|
|
||||||
messages: [
|
|
||||||
{
|
|
||||||
role: "system",
|
|
||||||
content:
|
|
||||||
"Ты эксперт по оценке чистоты автомобилей. Твоя задача — анализировать фотографии машин и определять степень их чистоты по 10-балльной шкале, где 1 — очень грязная, 10 — полностью чистая. Отвечай только числом от 1 до 10, без пояснений и дополнительных слов.",
|
|
||||||
},
|
|
||||||
{
|
|
||||||
role: "user",
|
|
||||||
content: "Что с чистотой машины? Отвечай на основе приложенного документа",
|
|
||||||
attachments: [fileId],
|
|
||||||
},
|
|
||||||
],
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
|
|
||||||
const data = await response.json()
|
|
||||||
console.log(" Результат анализа:", data)
|
|
||||||
return data
|
|
||||||
}
|
|
||||||
|
|
||||||
router.post("/upload", async (req, res) => {
|
|
||||||
|
|
||||||
const {access_token} = await getToken(req, res)
|
|
||||||
|
|
||||||
const response = await fetch(`${API_URL}/files`, {
|
|
||||||
method: "POST",
|
|
||||||
headers: {
|
|
||||||
Authorization: `Bearer ${access_token}`,
|
|
||||||
contentType: "multipart/form-data",
|
|
||||||
},
|
|
||||||
body: req.body,
|
|
||||||
})
|
|
||||||
|
|
||||||
const data = await response.json()
|
|
||||||
|
|
||||||
const analysisResponse = await analyzeImage(data.id,access_token)
|
|
||||||
|
|
||||||
res.json({ fileId: data.id, analysis: analysisResponse })
|
|
||||||
})
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
module.exports = router
|
|
||||||
@@ -2,13 +2,11 @@ const router = require('express').Router()
|
|||||||
const armMasterRouter = require('./arm-master')
|
const armMasterRouter = require('./arm-master')
|
||||||
const armOrdersRouter = require('./arm-orders')
|
const armOrdersRouter = require('./arm-orders')
|
||||||
const orderRouter = require('./order')
|
const orderRouter = require('./order')
|
||||||
const imageRouter = require('./image')
|
|
||||||
|
|
||||||
|
|
||||||
router.use('/arm', armMasterRouter)
|
router.use('/arm', armMasterRouter)
|
||||||
router.use('/arm', armOrdersRouter)
|
router.use('/arm', armOrdersRouter)
|
||||||
router.use('/order', orderRouter)
|
router.use('/order', orderRouter)
|
||||||
router.use('/image', imageRouter)
|
|
||||||
|
|
||||||
|
|
||||||
module.exports = router
|
module.exports = router
|
||||||
|
|||||||
Reference in New Issue
Block a user