parcelvoy/platform
1
0
Fork 0
mirror of https://fast.feibisi.com/https://github.com/parcelvoy/platform.git synced 2025-08-28 11:46:02 +08:00
Code Issues Projects Packages Wiki Activity Actions 1

Selectively refresh stats for opened campaigns (#592)

Browse source
This commit is contained in:
Chris Anderson 2024-12-27 00:14:58 -06:00 • committed by GitHub
parent 69a5e9b174
commit 394504a023
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 14 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
apps/platform/src/campaigns/CampaignInteractJob.ts
View file

@ -1,7 +1,8 @@
import App from '../app'
import { Job } from '../queue'
import { unsubscribe } from '../subscriptions/SubscriptionService'
import { CampaignSend } from './Campaign'
import { getCampaignSend, updateCampaignSend } from './CampaignService'
import { CacheKeys, getCampaignSend, updateCampaignSend } from './CampaignService'
interface CampaignIteraction {
user_id: number
@ -25,6 +26,7 @@ export default class CampaignInteractJob extends Job {
if (type === 'opened' && !send.opened_at) {
await updateCampaignSend(send.id, { opened_at: new Date() })
await App.main.redis.sadd(CacheKeys.pendingStats, campaign_id)
}
if (type === 'clicked') {

4
apps/platform/src/campaigns/CampaignService.ts
View file

@ -23,6 +23,10 @@ import Template from '../render/Template'
import { differenceInDays, subDays } from 'date-fns'
import { raw } from '../core/Model'
export const CacheKeys = {
pendingStats: 'campaigns:pending_stats',
}
export const pagedCampaigns = async (params: PageParams, projectId: number) => {
const result = await Campaign.search(
{ ...params, fields: ['name'] },

9
apps/platform/src/campaigns/CampaignStateJob.ts
View file

@ -1,7 +1,8 @@
import { subDays } from 'date-fns'
import { Job } from '../queue'
import Campaign from './Campaign'
import { updateCampaignProgress } from './CampaignService'
import { CacheKeys, updateCampaignProgress } from './CampaignService'
import App from '../app'
export default class CampaignStateJob extends Job {
static $name = 'campaign_state_job'
@ -9,16 +10,20 @@ export default class CampaignStateJob extends Job {
static async handler() {
// Fetch anything that is currently running or has finished
// within the last two days
// within the last two days or has activity
const openedCampaignIds = await App.main.redis.smembers(CacheKeys.pendingStats)
const campaigns = await Campaign.query()
.whereIn('state', ['scheduled', 'running'])
.orWhere(function(qb) {
qb.where('state', 'finished')
.where('send_at', '>', subDays(Date.now(), 2))
})
.orWhereIn('id', openedCampaignIds.map(id => parseInt(id, 10))) as Campaign[]
for (const campaign of campaigns) {
await updateCampaignProgress(campaign)
}
await App.main.redis.srem(CacheKeys.pendingStats, ...campaigns.map(c => c.id))
}
}