Nemcio/meanTorrent
1
0
Fork 0
mirror of https://github.com/taobataoma/meanTorrent.git synced 2026-06-18 18:22:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(announce): fixed data log issue

Browse Source
This commit is contained in:
OldHawk
2018-05-06 16:33:21 +08:00
parent c26e3a1df6
commit e141a9a9da
1 changed files with 74 additions and 120 deletions
Download Patch File Download Diff File Expand all files Collapse all files

194
config/lib/data-log.js
View File

@@ -58,81 +58,56 @@ module.exports.announceLog = function (user, torrent, data) {
var m = mom.get('month') + 1;
var d = mom.get('date');
UserDaysLog.findOne({
UserDaysLog.findOneAndUpdate({
user: user,
year: y,
month: m,
date: d
}).exec(function (err, l) {
if (l) {
l.uploaded += data.write_uploaded || 0;
l.downloaded += data.write_downloaded || 0;
l.score += data.write_score || 0;
l.updatedAt = Date.now();
l.save(function (err) {
if (err) {
logger.error(err);
}
});
} else {
var udl = new UserDaysLog();
udl.user = user;
udl.year = y;
udl.month = m;
udl.date = d;
udl.uploaded = data.write_uploaded || 0;
udl.downloaded = data.write_downloaded || 0;
udl.score = data.write_score || 0;
udl.save(function (err) {
if (err) {
logger.error(err);
}
});
}
});
//remove user-days-log old data
UserDaysLog.remove({
month: {$lt: mom.subtract(12, 'months').get('month') + 1}
}, function (err) {
}, {
$inc: {
uploaded: data.write_uploaded,
downloaded: data.write_downloaded,
score: data.write_score
},
updatedAt: Date.now()
}, {
upsert: true,
setDefaultsOnInsert: true
}).then(function (err) {
if (err) {
logger.error(err);
}
});
//write userMonthsLog
UserMonthsLog.findOne({
user: user,
year: y,
month: m
}).exec(function (err, l) {
if (l) {
l.uploaded += data.write_uploaded || 0;
l.downloaded += data.write_downloaded || 0;
l.score += data.write_score || 0;
l.updatedAt = Date.now();
l.save(function (err) {
if (err) {
logger.error(err);
}
});
} else {
var udl = new UserMonthsLog();
udl.user = user;
udl.year = y;
udl.month = m;
udl.uploaded = data.write_uploaded || 0;
udl.downloaded = data.write_downloaded || 0;
udl.score = data.write_score || 0;
udl.save(function (err) {
//remove user-days-log old data
UserDaysLog.remove({
month: {$lt: mom.subtract(12, 'months').get('month') + 1}
}, function (err) {
if (err) {
logger.error(err);
}
});
//write userMonthsLog
UserMonthsLog.findOneAndUpdate(
{
user: user,
year: y,
month: m
}, {
$inc: {
uploaded: data.write_uploaded,
downloaded: data.write_downloaded,
score: data.write_score
},
updatedAt: Date.now()
}, {
upsert: true,
setDefaultsOnInsert: true
}, function (err) {
if (err) {
logger.error(err);
}
}
);
}
});
};
@@ -149,73 +124,52 @@ module.exports.scoreLog = function (user, score) {
var m = mom.get('month') + 1;
var d = mom.get('date');
UserDaysLog.findOne({
UserDaysLog.findOneAndUpdate({
user: user,
year: y,
month: m,
date: d
}).exec(function (err, l) {
if (l) {
l.score += score || 0;
l.updatedAt = Date.now();
l.save(function (err) {
if (err) {
logger.error(err);
}
});
} else {
var udl = new UserDaysLog();
udl.user = user;
udl.year = y;
udl.month = m;
udl.date = d;
udl.score = score || 0;
udl.save(function (err) {
if (err) {
logger.error(err);
}
});
}
});
//remove user-days-log old data
UserDaysLog.remove({
month: {$lt: mom.subtract(12, 'months').get('month') + 1}
}, function (err) {
}, {
$inc: {
score: score
},
updatedAt: Date.now()
}, {
upsert: true,
setDefaultsOnInsert: true
}).then(function (err) {
if (err) {
logger.error(err);
}
});
//write userMonthsLog
UserMonthsLog.findOne({
user: user,
year: y,
month: m
}).exec(function (err, l) {
if (l) {
l.score += score || 0;
l.updatedAt = Date.now();
l.save(function (err) {
if (err) {
logger.error(err);
}
});
} else {
var udl = new UserMonthsLog();
udl.user = user;
udl.year = y;
udl.month = m;
udl.score = score || 0;
udl.save(function (err) {
//remove user-days-log old data
UserDaysLog.remove({
month: {$lt: mom.subtract(12, 'months').get('month') + 1}
}, function (err) {
if (err) {
logger.error(err);
}
});
//write userMonthsLog
UserMonthsLog.findOneAndUpdate(
{
user: user,
year: y,
month: m
}, {
$inc: {
score: score
},
updatedAt: Date.now()
}, {
upsert: true,
setDefaultsOnInsert: true
}, function (err) {
if (err) {
logger.error(err);
}
}
);
}
});
};