From 8e575c1dc199ae0ee8d94ae5e8160283c95bb8be Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BD=AD=E6=96=8C?= Date: Wed, 19 Jul 2023 09:20:26 +0000 Subject: [PATCH] =?UTF-8?q?=E4=B9=8B=E5=89=8D=E5=88=9A=E5=AD=A6nodejs?= =?UTF-8?q?=E7=9A=84=E7=A5=9E=E6=93=8D=E4=BD=9C=EF=BC=8C=E4=B8=8D=E7=9F=A5?= =?UTF-8?q?=E9=81=93=E5=B0=81=E8=A3=85=E6=95=B0=E6=8D=AE=E5=BA=93=E6=96=B9?= =?UTF-8?q?=E6=B3=95=EF=BC=8C=E6=AF=8F=E6=AC=A1=E6=9F=A5=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BA=93=E9=83=BD=E9=87=8D=E6=96=B0=E5=86=99=E4=B8=80=E6=AC=A1?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E7=9A=84=E9=85=8D=E7=BD=AE=EF=BC=8C?= =?UTF-8?q?=E5=86=8D=E6=9F=A5=E8=AF=A2=EF=BC=8C=E7=AE=80=E7=9B=B4=E4=B8=8D?= =?UTF-8?q?=E8=A6=81=E5=A4=AA=E8=BE=A3=E7=9C=BC=E7=9D=9B=EF=BC=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: 彭斌 --- js/commodity.js | 293 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 293 insertions(+) create mode 100644 js/commodity.js diff --git a/js/commodity.js b/js/commodity.js new file mode 100644 index 0000000..06b57f1 --- /dev/null +++ b/js/commodity.js @@ -0,0 +1,293 @@ +const { json } = require('body-parser'); +var mysql = require('mysql'); +var fs = require('fs'); +var token = require('./token') + +// 查询商品列表 +module.exports.commodity = function(req, res) { + const tokenKey = req.headers.authorization; + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + //连接数据库 + connection.connect(); + connection.query(`SELECT * FROM users WHERE tokenKey='${tokenKey}'`, function(error, results, fields) { + if (error) throw error; + if(results.length == 0) { + return res.status(200).json({ + success:0, + message:'非法操作' + }); + } else { + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + //连接数据库 + connection.connect(); + connection.query(`SELECT * FROM commodity`, function(error, results, fields) { + if (error) throw res.status(200).json({success:0,message: '获取商品列表失败'}); + return res.status(200).json({ + success:200, + message:results + }); + }) + } + }) + connection.end(); +} + +// 获取与查询商品列表 +module.exports.commoditys = function(req, res) { + const tokenKey = req.headers.authorization; + const start = (req.query.start - 1) * req.query.limit; + const limit = req.query.start * req.query.limit; + const product = req.query.product + const commodity = req.query.commodity + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + //连接数据库 + connection.connect(); + connection.query(`SELECT * FROM users WHERE tokenKey='${tokenKey}'`, function(error, results, fields) { + if (error) throw error; + if(results.length == 0) { + return res.status(200).json({ + success:0, + message:'非法操作' + }); + } else { + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + var str = 0 + //连接数据库 + connection.connect(); + connection.query(`SELECT * FROM commodity WHERE product LIKE '%${product}%' AND commodity LIKE '%${commodity}%'`, function(error, results, fields) { + if (error) throw error; + // if (error) throw res.status(200).json({success:0,message: '查询失败'}); + str = results.length + }); + connection.query(`SELECT * FROM commodity WHERE product LIKE '%${product}%' AND commodity LIKE '%${commodity}%' ORDER BY ID DESC LIMIT ${start},${limit}`, function(error, results, fields) { + if (error) throw error; + // if (error) throw res.status(200).json({success:0,message: '查询失败'}); + console.log(results); + return res.status(200).json({ + success:200, + message: results, + sum:str + }); + }); + connection.end(); + } + }) + connection.end(); +} + + // 根据id删除商品数据 + module.exports.deleteCommod = function(req, res) { + const tokenKey = req.headers.authorization; + const orderId = req.body.deleteId + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + //连接数据库 + connection.connect(); + connection.query(`SELECT * FROM users WHERE tokenKey='${tokenKey}'`, function(error, results, fields) { + if (error) throw error; + if(results.length == 0) { + return res.status(200).json({ + success:0, + message:'非法操作' + }); + } else { + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + connection.connect(); + connection.query(`DELETE FROM commodity WHERE id IN (${orderId})`, function(error, results, fields) { + if (error) throw res.status(200).json({success:0,message: '删除失败'}); + // if (error) throw error; + return res.status(200).json({ + success:200, + message: '删除成功' + }); + + }) + } + }) + connection.end(); + } + + // 根据id查询商品数据 +module.exports.editCommodId = function(req, res) { + const tokenKey = req.headers.authorization; + const id = req.body.id + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + //连接数据库 + connection.connect(); + connection.query(`SELECT * FROM users WHERE tokenKey='${tokenKey}'`, function(error, results, fields) { + if (error) throw error; + if(results.length == 0) { + return res.status(200).json({ + success:0, + message:'非法操作' + }); + } else { + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + connection.connect(); + connection.query(`SELECT * FROM commodity WHERE id=${id}`, function(error, results, fields) { + if (error) throw res.status(200).json({success:0,message: '获取商品信息失败失败'}); + // if (error) throw error; + return res.status(200).json({ + success:200, + message: results[0] + }); + }) + } + }) + connection.end(); +} + + // 添加与修改商品数据 + module.exports.editCommodity = function(req, res) { + const tokenKey = req.headers.authorization; + const id = req.body.id + const product = req.body.product + const univalence = req.body.univalence + const commodity = req.body.commodity + const repertory = req.body.repertory + const operator = req.body.operator + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + //连接数据库 + connection.connect(); + connection.query(`SELECT * FROM users WHERE tokenKey='${tokenKey}'`, function(error, results, fields) { + if (error) throw error; + if(results.length == 0) { + return res.status(200).json({ + success:0, + message:'非法操作' + }); + } else { + if (id == null) { // 添加产品数据 + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + //连接数据库 + connection.connect(); + connection.query(`INSERT INTO commodity (product,univalence,commodity,repertory,operator) VALUES ('${product}','${univalence}','${commodity}','${repertory}','${operator}')`, function(error, results, fields) { + if (error) throw res.status(200).json({success:0,message: '操作失败'}); + return res.status(200).json({ + success:200, + message: '添加成功' + }); + }) + } else { // 修改产品数据 + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + connection.connect(); + connection.query(`UPDATE commodity SET product='${product}',univalence='${univalence}',commodity='${commodity}',repertory='${repertory}',operator='${operator}' WHERE id=${id}`, function(error, results, fields) { + if (error) throw res.status(200).json({success:0,message: '操作失败'}); + // if (error) throw error; + return res.status(200).json({ + success:200, + message: '修改成功' + }); + }) + } + } + connection.end(); + }) + } + + // 财务列表获取 + module.exports.commoditys = function(req, res) { + const tokenKey = req.headers.authorization; + const start = (req.query.start - 1) * req.query.limit; + const limit = req.query.start * req.query.limit; + const product = req.query.product + const commodity = req.query.commodity + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + //连接数据库 + connection.connect(); + connection.query(`SELECT * FROM users WHERE tokenKey='${tokenKey}'`, function(error, results, fields) { + if (error) throw error; + if(results.length == 0) { + return res.status(200).json({ + success:0, + message:'非法操作' + }); + } else { + var connection = mysql.createConnection({ + host:'localhost', + user: 'root', + password : '123456', + database : 'open_data' + }); + var str = 0 + //连接数据库 + connection.connect(); + connection.query(`SELECT * FROM commodity WHERE product LIKE '%${product}%' AND commodity LIKE '%${commodity}%'`, function(error, results, fields) { + if (error) throw error; + // if (error) throw res.status(200).json({success:0,message: '查询失败'}); + str = results.length + }); + connection.query(`SELECT * FROM commodity WHERE product LIKE '%${product}%' AND commodity LIKE '%${commodity}%' ORDER BY ID DESC LIMIT ${start},${limit}`, function(error, results, fields) { + if (error) throw error; + // if (error) throw res.status(200).json({success:0,message: '查询失败'}); + console.log(results); + return res.status(200).json({ + success:200, + message: results, + sum:str + }); + }); + connection.end(); + } + }) + connection.end(); + } \ No newline at end of file -- Gitee