10 Star 19 Fork 7

danfeng/nodewechat

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
storage.js 1.72 KB
一键复制 编辑 原始数据 按行查看 历史
unknown 提交于 2016-05-12 22:16 +08:00 . add some manage api
/*
* 存储微信内容,统计各个用户发送的微信数量
* 消息内容存mongodb
* 多媒体文件存BOS
*/
var mongodb = require('./mongodb');
var bos = require('./bos');
var getLatestPost = function(callback) {
// 读取最新的文章
mongodb.db.collection('posts').find({}, {sort: {'_id': -1}, limit: 1}, function (err, cursor) {
if (err) {
console.warn(err.message);
} else {
cursor.toArray(callback);
}
});
};
var putMessage = function(message) {
// 查找联系人
mongodb.db.collection('contacts').findOneAndUpdate({FromUserName: message.FromUserName}, {$inc: {"TotalMessage": 1}}, {
returnOriginal: false,
upsert: true
}, function (err, contact) {
if (err) {
console.warn(err.message);
} else {
console.dir(contact);
}
});
// 记录信息
mongodb.db.collection('messages').insertOne(message, function (err, message) {
if (err) {
console.warn(err.message);
} else {
console.dir(message);
}
});
};
var putMaterial = function(material) {
console.log(material);
// 保存素材
mongodb.db.collection('materials').updateOne({media_id: material.material},
{name: material.name}, {upsert: true, w: 1}, function (err, result) {
if (err) {
console.warn(err.message);
} else {
console.dir(result);
}
});
};
var putImage = function(picurl, object, callback) {
bos.putObject(picurl, object, callback);
};
exports.getLatestPost = getLatestPost;
exports.putMaterial = putMaterial;
exports.putMessage = putMessage;
exports.putImage = putImage;
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
NodeJS
1
https://gitee.com/killu/nodewechat.git
git@gitee.com:killu/nodewechat.git
killu
nodewechat
nodewechat
master

搜索帮助