do not decrement new unsubscribed subscribers, fixes #83
This commit is contained in:
parent
fb7fd7238f
commit
ef4aa301ab
1 changed files with 2 additions and 2 deletions
|
@ -383,7 +383,7 @@ module.exports.insert = (listId, meta, subscription, callback) => {
|
||||||
if (statusChange) {
|
if (statusChange) {
|
||||||
keys.push('status', 'status_change');
|
keys.push('status', 'status_change');
|
||||||
values.push(meta.status, new Date());
|
values.push(meta.status, new Date());
|
||||||
statusDirection = !existing ? (meta.status === 1 ? '+' : '-') : (existing.status === 1 ? '-' : '+');
|
statusDirection = !existing ? (meta.status === 1 ? '+' : false) : (existing.status === 1 ? '-' : '+');
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!keys.length) {
|
if (!keys.length) {
|
||||||
|
@ -425,7 +425,7 @@ module.exports.insert = (listId, meta, subscription, callback) => {
|
||||||
|
|
||||||
entryId = result.insertId || entryId;
|
entryId = result.insertId || entryId;
|
||||||
|
|
||||||
if (statusChange) {
|
if (statusChange && statusDirection) {
|
||||||
connection.query('UPDATE lists SET `subscribers`=`subscribers`' + statusDirection + '1 WHERE id=?', [listId], err => {
|
connection.query('UPDATE lists SET `subscribers`=`subscribers`' + statusDirection + '1 WHERE id=?', [listId], err => {
|
||||||
if (err) {
|
if (err) {
|
||||||
return connection.rollback(() => {
|
return connection.rollback(() => {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue