Compare commits
No commits in common. "a7847185fd084126306e4eed4dc0fc13e87690ac" and "99259b69a26e0f68e61d303d70121fd6888b8087" have entirely different histories.
a7847185fd
...
99259b69a2
|
|
@ -1,12 +1,10 @@
|
||||||
const { StatusCodes } = require("http-status-codes")
|
const { StatusCodes } = require("http-status-codes")
|
||||||
const API_Pricing = require("../models/API_Pricing.js")
|
const API_Pricing = require("../models/API_Pricing.js")
|
||||||
const mongoose = require('mongoose');
|
|
||||||
const {
|
const {
|
||||||
mustContainProperties,
|
mustContainProperties,
|
||||||
calculateApiUsage,
|
calculateApiUsage,
|
||||||
} = require('../utils')
|
} = require('../utils')
|
||||||
const API_Usage = require("../models/API_Usage.js")
|
const API_Usage = require("../models/API_Usage.js")
|
||||||
const API_Products = require("../models/API_Products.js")
|
|
||||||
const billingSumUsage = require("../utils/billingSumUsage.js")
|
const billingSumUsage = require("../utils/billingSumUsage.js")
|
||||||
const moment = require('moment')
|
const moment = require('moment')
|
||||||
const API_Call = require("../models/API_Call.js")
|
const API_Call = require("../models/API_Call.js")
|
||||||
|
|
@ -15,7 +13,7 @@ const API_Usage_Whatsapp = require("../models/API_Usage_Whatsapp.js")
|
||||||
|
|
||||||
const setApiPricing = async (req, res) => {
|
const setApiPricing = async (req, res) => {
|
||||||
|
|
||||||
const { provider, product, currency, price, billingBy, billingUnit, type, clientPrice, format } = req.body
|
const { provider, product, currency, price, billingBy, billingUnit, type } = req.body
|
||||||
|
|
||||||
mustContainProperties(req, ['provider',
|
mustContainProperties(req, ['provider',
|
||||||
'product',
|
'product',
|
||||||
|
|
@ -39,9 +37,7 @@ const setApiPricing = async (req, res) => {
|
||||||
price,
|
price,
|
||||||
billingBy,
|
billingBy,
|
||||||
billingUnit,
|
billingUnit,
|
||||||
type,
|
type
|
||||||
clientPrice,
|
|
||||||
format
|
|
||||||
}
|
}
|
||||||
const options = { new: true, upsert: true }
|
const options = { new: true, upsert: true }
|
||||||
|
|
||||||
|
|
@ -50,145 +46,6 @@ const setApiPricing = async (req, res) => {
|
||||||
res.status(StatusCodes.OK).json({ apiPricing })
|
res.status(StatusCodes.OK).json({ apiPricing })
|
||||||
}
|
}
|
||||||
|
|
||||||
const updateProductPricing = async (req, res) => {
|
|
||||||
const { price, name, description } = req.body;
|
|
||||||
const { id } = req.params;
|
|
||||||
|
|
||||||
if (!mongoose.Types.ObjectId.isValid(id)) {
|
|
||||||
return res.status(StatusCodes.BAD_REQUEST).json({
|
|
||||||
error: 'ID do produto inválido.'
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
let existingProduct = await API_Products.findById(id);
|
|
||||||
|
|
||||||
if (!existingProduct) {
|
|
||||||
return res.status(StatusCodes.NOT_FOUND).json({
|
|
||||||
error: 'Produto não encontrado.'
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
if (price) {
|
|
||||||
const activePriceIndex = existingProduct.priceHistory.findIndex(priceEntry => !priceEntry.endDate);
|
|
||||||
|
|
||||||
if (activePriceIndex !== -1 && existingProduct.priceHistory[activePriceIndex].price != price) {
|
|
||||||
existingProduct.priceHistory[activePriceIndex].endDate = new Date();
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
return res.status(StatusCodes.BAD_REQUEST).json({
|
|
||||||
msg: `Product with the same price ${price}`
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const newPriceEntry = {
|
|
||||||
startDate: new Date(),
|
|
||||||
endDate: null, // Novo preço ativo
|
|
||||||
price
|
|
||||||
};
|
|
||||||
|
|
||||||
if (description) existingProduct.description = description.trim();
|
|
||||||
if (name) existingProduct.name = name.trim();
|
|
||||||
if (price) existingProduct.priceHistory.push(newPriceEntry);
|
|
||||||
|
|
||||||
await existingProduct.save();
|
|
||||||
|
|
||||||
res.status(StatusCodes.OK).json({
|
|
||||||
msg: 'Preço do produto atualizado com sucesso!',
|
|
||||||
product: existingProduct
|
|
||||||
});
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
const setProductPricing = async (req, res) => {
|
|
||||||
const { name, description, price } = req.body;
|
|
||||||
|
|
||||||
console.log("price: ", price)
|
|
||||||
|
|
||||||
mustContainProperties(req, ['name']);
|
|
||||||
|
|
||||||
const normalizedName = name.trim();
|
|
||||||
|
|
||||||
let existingProduct = await API_Products.findOne({ name: normalizedName });
|
|
||||||
|
|
||||||
if (existingProduct) {
|
|
||||||
if (price) {
|
|
||||||
|
|
||||||
const activePriceIndex = existingProduct.priceHistory.findIndex(priceEntry => !priceEntry.endDate);
|
|
||||||
|
|
||||||
if (activePriceIndex !== -1 && existingProduct.priceHistory[activePriceIndex].price != price) {
|
|
||||||
existingProduct.priceHistory[activePriceIndex].endDate = new Date();
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
return res.status(StatusCodes.BAD_REQUEST).json({
|
|
||||||
msg: `Product with the same price ${price}`
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
const newPriceEntry = {
|
|
||||||
startDate: new Date(),
|
|
||||||
endDate: null, // Novo preço ativo
|
|
||||||
price
|
|
||||||
};
|
|
||||||
|
|
||||||
existingProduct.priceHistory.push(newPriceEntry);
|
|
||||||
|
|
||||||
if (description) existingProduct.description = description.trim();
|
|
||||||
|
|
||||||
await existingProduct.save();
|
|
||||||
|
|
||||||
return res.status(StatusCodes.OK).json({
|
|
||||||
msg: 'Preço do produto atualizado com sucesso!',
|
|
||||||
product: existingProduct
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
return res.status(StatusCodes.CONFLICT).json({
|
|
||||||
error: 'Produto já existe. Para atualizar o preço, forneça o campo "price".',
|
|
||||||
product: existingProduct
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Se o produto não existe, criar um novo
|
|
||||||
const productData = {
|
|
||||||
name: normalizedName,
|
|
||||||
description: description?.trim() || '',
|
|
||||||
priceHistory: []
|
|
||||||
};
|
|
||||||
|
|
||||||
if (price) {
|
|
||||||
const priceEntry = {
|
|
||||||
startDate: new Date(), // Data atual automática
|
|
||||||
endDate: null, // Preço ativo (sem data de fim)
|
|
||||||
price,
|
|
||||||
};
|
|
||||||
|
|
||||||
productData.priceHistory.push(priceEntry);
|
|
||||||
}
|
|
||||||
|
|
||||||
console.log('---------> Dados do produto a ser criado:', productData);
|
|
||||||
|
|
||||||
// Criar o produto
|
|
||||||
const newProduct = new API_Products(productData);
|
|
||||||
await newProduct.save();
|
|
||||||
|
|
||||||
res.status(StatusCodes.CREATED).json({
|
|
||||||
msg: 'Produto criado com sucesso!',
|
|
||||||
product: newProduct
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
const listProductPricing = async (req, res) => {
|
|
||||||
|
|
||||||
const products = await API_Products.find();
|
|
||||||
|
|
||||||
res.status(StatusCodes.OK).json({
|
|
||||||
msg: 'ok',
|
|
||||||
products
|
|
||||||
})
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
const registerUsage = async (req, res) => {
|
const registerUsage = async (req, res) => {
|
||||||
const {
|
const {
|
||||||
provider,
|
provider,
|
||||||
|
|
@ -197,7 +54,6 @@ const registerUsage = async (req, res) => {
|
||||||
callerId,
|
callerId,
|
||||||
sessionId,
|
sessionId,
|
||||||
companyId,
|
companyId,
|
||||||
format
|
|
||||||
|
|
||||||
} = req.body
|
} = req.body
|
||||||
|
|
||||||
|
|
@ -229,8 +85,7 @@ const registerUsage = async (req, res) => {
|
||||||
billingBy,
|
billingBy,
|
||||||
billingUnit,
|
billingUnit,
|
||||||
companyId,
|
companyId,
|
||||||
total_cost: calculateApiUsage(price, billingUnit, usage),
|
total_cost: calculateApiUsage(price, billingUnit, usage)
|
||||||
format
|
|
||||||
})
|
})
|
||||||
|
|
||||||
return res.status(StatusCodes.OK).json({ apiUsage })
|
return res.status(StatusCodes.OK).json({ apiUsage })
|
||||||
|
|
@ -266,7 +121,7 @@ const registerWhatsappUsage = async (req, res) => {
|
||||||
'billable',
|
'billable',
|
||||||
'pricing_model',
|
'pricing_model',
|
||||||
'companyPhone',
|
'companyPhone',
|
||||||
'clientPhone',
|
'clientPhone',
|
||||||
])
|
])
|
||||||
|
|
||||||
const apiPricing = await API_Pricing.findOne({
|
const apiPricing = await API_Pricing.findOne({
|
||||||
|
|
@ -464,9 +319,6 @@ const getUsage = async (req, res) => {
|
||||||
|
|
||||||
module.exports = {
|
module.exports = {
|
||||||
setApiPricing,
|
setApiPricing,
|
||||||
setProductPricing,
|
|
||||||
updateProductPricing,
|
|
||||||
listProductPricing,
|
|
||||||
registerUsage,
|
registerUsage,
|
||||||
registerAPICall,
|
registerAPICall,
|
||||||
registerOperation,
|
registerOperation,
|
||||||
|
|
|
||||||
|
|
@ -1,49 +1,40 @@
|
||||||
const mongoose = require("../db/connect");
|
const mongoose = require('../db/connect')
|
||||||
|
|
||||||
const { Schema } = mongoose;
|
const { Schema } = mongoose
|
||||||
|
|
||||||
const apiPricing = new Schema(
|
const apiPricing = new Schema({
|
||||||
{
|
|
||||||
provider: {
|
provider: {
|
||||||
type: String,
|
type: String,
|
||||||
required: true,
|
required: true,
|
||||||
},
|
},
|
||||||
product: {
|
product: {
|
||||||
type: String,
|
type: String,
|
||||||
required: true,
|
required: true,
|
||||||
},
|
},
|
||||||
currency: {
|
currency: {
|
||||||
type: String,
|
type: String,
|
||||||
enum: ["dollar", "real"],
|
enum: ['dollar', 'real',],
|
||||||
default: "dollar",
|
default: 'dollar'
|
||||||
},
|
},
|
||||||
price: {
|
price: {
|
||||||
type: String,
|
type: String,
|
||||||
required: true,
|
required: true
|
||||||
|
},
|
||||||
|
billingBy:{
|
||||||
|
type: String,
|
||||||
|
enum: ['minute', 'character', 'token', 'second', 'hour'],
|
||||||
|
required: true,
|
||||||
},
|
},
|
||||||
clientPrice: {
|
billingUnit:{
|
||||||
type: String,
|
type: Number,
|
||||||
},
|
required: true
|
||||||
billingBy: {
|
|
||||||
type: String,
|
|
||||||
enum: ["minute", "character", "token", "second", "hour"],
|
|
||||||
required: true,
|
|
||||||
},
|
|
||||||
billingUnit: {
|
|
||||||
type: Number,
|
|
||||||
required: true,
|
|
||||||
},
|
},
|
||||||
type: {
|
type: {
|
||||||
type: String,
|
type: String,
|
||||||
},
|
}
|
||||||
format: {
|
|
||||||
type: String,
|
|
||||||
enum: ["text", "audio", "image", "video"],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
{ timestamps: true }
|
|
||||||
);
|
|
||||||
|
|
||||||
const API_Pricing = mongoose.model("API_Pricing", apiPricing);
|
}, { timestamps: true })
|
||||||
|
|
||||||
|
const API_Pricing = mongoose.model('API_Pricing', apiPricing)
|
||||||
|
|
||||||
module.exports = API_Pricing;
|
module.exports = API_Pricing
|
||||||
|
|
|
||||||
|
|
@ -1,55 +0,0 @@
|
||||||
const mongoose = require('../db/connect');
|
|
||||||
|
|
||||||
const { Schema } = mongoose;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @description Sub-schema para o histórico de preços.
|
|
||||||
* A opção `strict: false` permite adicionar campos de preço dinâmicos (ex: tokenPrice, sttSecondPrice)
|
|
||||||
* que podem variar conforme o `pricingModel` do produto principal.
|
|
||||||
* A opção `_id: false` evita que o Mongoose crie um ObjectId para cada entrada no histórico.
|
|
||||||
*/
|
|
||||||
const priceHistorySchema = new Schema({
|
|
||||||
startDate: {
|
|
||||||
type: Date,
|
|
||||||
required: [true, 'A data de início da vigência é obrigatória.'],
|
|
||||||
},
|
|
||||||
endDate: {
|
|
||||||
type: Date,
|
|
||||||
default: null, // Um valor nulo significa que o preço está atualmente vigente.
|
|
||||||
},
|
|
||||||
// price: {
|
|
||||||
// type: String,
|
|
||||||
// required: [true, 'O preço é obrigatório'],
|
|
||||||
// }
|
|
||||||
}, { _id: false, strict: false });
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @description Schema principal para os produtos da API.
|
|
||||||
*/
|
|
||||||
const apiProductSchema = new Schema({
|
|
||||||
name: {
|
|
||||||
type: String,
|
|
||||||
required: [true, 'O nome do produto é obrigatório.'],
|
|
||||||
trim: true,
|
|
||||||
unique: true, // Garante que não hajam produtos com o mesmo nome.
|
|
||||||
},
|
|
||||||
description: {
|
|
||||||
type: String,
|
|
||||||
trim: true,
|
|
||||||
},
|
|
||||||
// pricingModel: {
|
|
||||||
// type: String,
|
|
||||||
// required: [true, 'O modelo de precificação é obrigatório.'],
|
|
||||||
// trim: true,
|
|
||||||
// },
|
|
||||||
priceHistory: {
|
|
||||||
type: [priceHistorySchema],
|
|
||||||
default: [], // O produto pode ser criado sem um histórico de preços inicial.
|
|
||||||
},
|
|
||||||
}, {
|
|
||||||
timestamps: true, // Adiciona os campos `createdAt` e `updatedAt` automaticamente.
|
|
||||||
});
|
|
||||||
|
|
||||||
const API_Products = mongoose.model('API_Products', apiProductSchema);
|
|
||||||
|
|
||||||
module.exports = API_Products;
|
|
||||||
|
|
@ -7443,8 +7443,7 @@
|
||||||
"version": "4.4.0",
|
"version": "4.4.0",
|
||||||
"resolved": "https://registry.npmjs.org/cosmiconfig-typescript-loader/-/cosmiconfig-typescript-loader-4.4.0.tgz",
|
"resolved": "https://registry.npmjs.org/cosmiconfig-typescript-loader/-/cosmiconfig-typescript-loader-4.4.0.tgz",
|
||||||
"integrity": "sha512-BabizFdC3wBHhbI4kJh0VkQP9GkBfoHPydD0COMce1nJ1kJAB3F2TmJ/I7diULBKtmEWSwEbuN/KDtgnmUUVmw==",
|
"integrity": "sha512-BabizFdC3wBHhbI4kJh0VkQP9GkBfoHPydD0COMce1nJ1kJAB3F2TmJ/I7diULBKtmEWSwEbuN/KDtgnmUUVmw==",
|
||||||
"dev": true,
|
"dev": true
|
||||||
"requires": {}
|
|
||||||
},
|
},
|
||||||
"create-require": {
|
"create-require": {
|
||||||
"version": "1.1.1",
|
"version": "1.1.1",
|
||||||
|
|
@ -7749,8 +7748,7 @@
|
||||||
"express-async-errors": {
|
"express-async-errors": {
|
||||||
"version": "3.1.1",
|
"version": "3.1.1",
|
||||||
"resolved": "https://registry.npmjs.org/express-async-errors/-/express-async-errors-3.1.1.tgz",
|
"resolved": "https://registry.npmjs.org/express-async-errors/-/express-async-errors-3.1.1.tgz",
|
||||||
"integrity": "sha512-h6aK1da4tpqWSbyCa3FxB/V6Ehd4EEB15zyQq9qe75OZBp0krinNKuH4rAY+S/U/2I36vdLAUFSjQJ+TFmODng==",
|
"integrity": "sha512-h6aK1da4tpqWSbyCa3FxB/V6Ehd4EEB15zyQq9qe75OZBp0krinNKuH4rAY+S/U/2I36vdLAUFSjQJ+TFmODng=="
|
||||||
"requires": {}
|
|
||||||
},
|
},
|
||||||
"express-fileupload": {
|
"express-fileupload": {
|
||||||
"version": "1.2.1",
|
"version": "1.2.1",
|
||||||
|
|
|
||||||
|
|
@ -2,9 +2,6 @@ const express = require('express')
|
||||||
const router = express.Router()
|
const router = express.Router()
|
||||||
const { authorization, } = require('../middleware/authentication')
|
const { authorization, } = require('../middleware/authentication')
|
||||||
const { setApiPricing,
|
const { setApiPricing,
|
||||||
setProductPricing,
|
|
||||||
updateProductPricing,
|
|
||||||
listProductPricing,
|
|
||||||
registerUsage,
|
registerUsage,
|
||||||
getUsage,
|
getUsage,
|
||||||
registerAPICall,
|
registerAPICall,
|
||||||
|
|
@ -13,9 +10,6 @@ const { setApiPricing,
|
||||||
registerWhatsappUsage} = require('../controllers/apiUsagePricing')
|
registerWhatsappUsage} = require('../controllers/apiUsagePricing')
|
||||||
|
|
||||||
router.route('/create').post(authorization, setApiPricing)
|
router.route('/create').post(authorization, setApiPricing)
|
||||||
router.route('/product').post(authorization, setProductPricing)
|
|
||||||
router.route('/products').get(authorization, listProductPricing)
|
|
||||||
router.route('/product/:id').patch(authorization, updateProductPricing)
|
|
||||||
router.route('/usage').post(authorization, registerUsage)
|
router.route('/usage').post(authorization, registerUsage)
|
||||||
router.route('/usage-whatsapp').post(authorization, registerWhatsappUsage)
|
router.route('/usage-whatsapp').post(authorization, registerWhatsappUsage)
|
||||||
router.route('/report').post(authorization, getUsage)
|
router.route('/report').post(authorization, getUsage)
|
||||||
|
|
@ -23,4 +17,6 @@ router.route('/api-call').post(authorization, registerAPICall)
|
||||||
router.route('/api-operation').post(authorization, registerOperation)
|
router.route('/api-operation').post(authorization, registerOperation)
|
||||||
router.route('/api-register-all').post(authorization, registerAll)
|
router.route('/api-register-all').post(authorization, registerAll)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
module.exports = router
|
module.exports = router
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue