利用nodejs实现商品管理系统（二）

<% for(var i=0;i<list.length;i++){%> ????????????????????<tr> ???????????????????????<td><%=i+1%></td> ???????????????????????<td><img width="100" src="<%=list[i].pic%>" alt=""/></td> ???????????????????????<td><%=list[i].title%></td> ???????????????????????<td><%=list[i].price%></td> ????????????????????????<td><%=list[i].fee%></td> ???????????????????????<td class="text-center"> ???????????????????????????<a href="/productedit?id=<%=list[i]._id%>" class="btn btn-success">修改</a> ???????????????????????????<a href="/productdelete?id=<%=list[i]._id%>" class="btn btn-danger">删除</a> ??????????????????????</td> ???????????????????</tr> ???????????????????<%}%>

　　　　　　　　　　　　　　<form action="/doProductEdit" method="post" enctype="multipart/form-data"> ???????????????????????????<ul> ???????????????????????????????<input type="hidden" name="_id" value="<%=list._id%>"/> ???????????????????????????????<input type="hidden" name="pic" value="<%=list.pic%>"/> ???????????????????????????????<li> ?商品名称: <input type="text" name="title" value="<%=list.title%>"/></li> ???????????????????????????????<li> ?商品图片: <input type="file" name="pic"/> ???????????????????????????????????<br/> <br/> ??????????????????????????????????　　　　 <img src="<%=list.pic%>" width="100"/> ???????????????????????????????????<br/> <br/> ???????????????????????????????</li> ???????????????????????????????<li> ?商品价格: <input type="text" name="price" value="<%=list.price%>"/></li> ???????????????????????????????<li> ?商品邮费: <input type="text" name="fee" ?value="<%=list.fee%>"/></li> ???????????????????????????????<li> ???????????????????????????????????商品描述: ???????????????????????????????????<textarea name="description" id="" cols="60" rows="8"><%=list.description%></textarea> ???????????????????????????????</li> ???????????????????????????????<li> ???????????????????????????????????<br/> ???????????????????????????????????<button type="submit" class="btn btn-default">提交</button> ???????????????????????????????</li> ???????????????????????????</ul> ???????????????????????</form>

　　　　　　　　　　　　　　<form action="/doProductAdd" method="post" enctype="multipart/form-data"> ???????????????????????????<ul> ???????????????????????????????<li> ?商品名称: <input type="text" name="title"/></li> ???????????????????????????????<li> ?商品图片: <input type="file" name="pic"/></li> ???????????????????????????????<li> ?商品价格: <input type="text" name="price"/></li> ???????????????????????????????<li> ?商品邮费: <input type="text" name="fee"/></li> ???????????????????????????????<li> ???????????????????????????????????商品描述: ???????????????????????????????????<textarea name="description" id="" cols="60" rows="8"></textarea> ???????????????????????????????</li> ???????????????????????????????<li> ???????????????????????????????????<br/> ???????????????????????????????????<button type="submit" class="btn btn-default">提交</button> ???????????????????????????????</li> ???????????????????????????</ul> ???????????????????????</form>

var MongoClient=require(‘mongodb‘).MongoClient;var DbUrl=‘mongodb://localhost:27017/productmanage‘; ?var ObjectID = require(‘mongodb‘).ObjectID;function ?__connectDb(callback){ ???MongoClient.connect(DbUrl,function(err,db){ ???????if(err){ ???????????console.log(‘数据库连接失败‘); ???????????return; ???????} ???????//增加 修改 删除 ?????????callback(db); ???})}

exports.ObjectID=ObjectID;//查找数据exports.find=function(collectionname,json,callback){ ???__connectDb(function(db){ ???????var result=db.collection(collectionname).find(json); ???????result.toArray(function(error,data){ ???????????db.close();/* ???????????关闭数据库*/ ???????????callback(error,data);/*拿到数据执行回调函数*/ ???????}) ???})}//插入数据exports.insert=function(collectionname,json,callback){ ???__connectDb(function(db){ ???????db.collection(collectionname).insertOne(json,function(error,data){ ???????????callback(error,data); ???????}) ???})}//更新数据exports.update=function(collectionname,json1,json2,callback){ ???__connectDb(function(db){ ???????db.collection(collectionname).updateOne(json1,{$set:json2},function(error,data){ ???????????callback(error,data); ???????}) ???})}//删除数据exports.deleteOne=function(collectionname,json,callback){ ???__connectDb(function(db){ ???????db.collection(collectionname).deleteOne(json,function(error,data){ ???????????callback(error,data); ???????}) ???})}

//商品列表app.get(‘/product‘,function(req,res){ ???????DB.find(‘product‘,{},function(err,data){ ???????????res.render(‘product‘,{ ???????????????list:data ???????????}); ???????})})//显示增加商品的页面app.get(‘/productadd‘,function(req,res){ ???res.render(‘productadd‘);})

<form action="/doProductAdd" method="post" enctype="multipart/form-data">

npm install multiparty --save

var multiparty = require(‘multiparty‘);

app.post(‘/doProductAdd‘,function(req,res){ ???//获取表单的数据 以及post过来的图片 ???var form = new multiparty.Form(); ???form.uploadDir=‘upload‘ ??//上传图片保存的地址 ???upload目录必须存在 ???form.parse(req, function(err, fields, files) { ???????//获取提交的数据以及图片上传成功返回的图片信息
　　　　　//fields获取表单的数据 ?files得到图片上传成功返回的信息 ???????var title=fields.title[0]; ???????var price=fields.price[0]; ???????var fee=fields.fee[0]; ???????var description=fields.description[0]; ???????var pic=files.pic[0].path;
　　　　//在数据库中插入数据 ???????DB.insert(‘product‘,{ ???????????title:title, ???????????price:price, ???????????fee,//效果与上面一致 ???????????description, ???????????pic ???????},function(err,data){ ???????????if(!err){ ???????????????res.redirect(‘/product‘); /*上传成功跳转到首页*/ ???????????} ???????}) ???});})

app.use(‘/upload‘,express.static(‘upload‘));

app.use(express.static(‘upload‘));

 <a href="/productedit?id=<%=list[i]._id%>" class="btn btn-success">修改</a> <a href="/productdelete?id=<%=list[i]._id%>" class="btn btn-danger">删除</a>

app.get(‘/productedit‘,function(req,res){ ???//获取get传值 id ???var id=req.query.id; ???console.log(id); ???//去数据库查询这个id对应的数据 ????自增长的id 要用{"_id":new DB.ObjectID(id) ???DB.find(‘product‘,{"_id":new DB.ObjectID(id)},function(err,data){ ???????//console.log(data); ???????res.render(‘productedit‘,{ ???????????list:data[0] ???????}); ???});})

<form action="/doProductEdit" method="post" enctype="multipart/form-data">

app.post(‘/doProductEdit‘,function(req,res) { ???var form = new multiparty.Form(); ???form.uploadDir = ‘upload‘ ?// 上传图片保存的地址 ???form.parse(req, function (err, fields, files) { ???????//获取提交的数据以及图片上传成功返回的图片信息 ???????//console.log(fields); ???????console.log(files); ???????var _id = fields._id[0]; ???????/*修改的条件*/ ???????var title = fields.title[0]; ???????var price = fields.price[0]; ???????var fee = fields.fee[0]; ???????var description = fields.description[0]; ???????var originalFilename = files.pic[0].originalFilename; ???????var pic = files.pic[0].path; ???????if (originalFilename) { ?/*修改了图片*/ ???????????var setData = { ???????????????title, ???????????????price, ???????????????fee, ???????????????description, ???????????????pic ???????????}; ???????} else { /*没有修改图片*/ ???????????var setData = { ???????????????title, ???????????????price, ???????????????fee, ???????????????description ???????????}; ???????????//删除生成的临时文件 ???????????fs.unlink(pic); ???????} ???????DB.update(‘product‘, {"_id": new DB.ObjectID(_id)}, setData, function (err, data) { ???????????if (!err) { ???????????????res.redirect(‘/product‘); ???????????} ???????}) ???});})

app.get(‘/productdelete‘,function(req,res){ ???????//获取id ???????var ?id=req.query.id; ???????DB.deleteOne(‘product‘,{"_id":new DB.ObjectID(id)},function(err){ ???????????if(!err){ ???????????????res.redirect(‘/product‘); ???????????} ???????}) ???})