@@ -82,13 +82,14 @@ public function campaignRebuildCheck(OutputInterface $output = null, $verbose =
82
82
$ query ->select (
83
83
'cl.campaign_id as campaign_id, c.name as campaign_name, count(DISTINCT(cl.lead_id)) as contact_count '
84
84
);
85
+ $ query ->leftJoin ('cl ' , MAUTIC_TABLE_PREFIX .'campaigns ' , 'c ' , 'c.id = cl.campaign_id ' );
85
86
$ query ->from (MAUTIC_TABLE_PREFIX .'campaign_leads ' , 'cl ' );
86
87
$ query ->where ('cl.manually_removed IS NOT NULL AND cl.manually_removed = 0 ' );
87
88
$ query ->andWhere (
88
89
'NOT EXISTS (SELECT null FROM ' .MAUTIC_TABLE_PREFIX .'campaign_lead_event_log e WHERE (cl.lead_id = e.lead_id) AND (e.campaign_id = cl.campaign_id)) '
89
90
);
91
+ $ query ->andWhere ('c.is_published = 1 ' );
90
92
$ query ->groupBy ('cl.campaign_id ' );
91
- $ query ->leftJoin ('cl ' , MAUTIC_TABLE_PREFIX .'campaigns ' , 'c ' , 'c.id = cl.campaign_id ' );
92
93
$ campaigns = $ query ->execute ()->fetchAll ();
93
94
foreach ($ campaigns as $ campaign ) {
94
95
$ id = $ campaign ['campaign_id ' ];
@@ -132,10 +133,13 @@ public function campaignTriggerCheck(OutputInterface $output = null, $verbose =
132
133
'el.campaign_id as campaign_id, c.name as campaign_name, COUNT(DISTINCT(el.lead_id)) as contact_count '
133
134
);
134
135
$ query ->from (MAUTIC_TABLE_PREFIX .'campaign_lead_event_log ' , 'el ' );
136
+ $ query ->leftJoin ('el ' , MAUTIC_TABLE_PREFIX .'campaigns ' , 'c ' , 'c.id = el.campaign_id ' );
137
+ $ query ->leftJoin ('el ' , MAUTIC_TABLE_PREFIX .'campaign_events ' , 'e ' , 'e.id = el.event_id ' );
135
138
$ query ->where ('el.is_scheduled = 1 ' );
136
139
$ query ->andWhere ('el.trigger_date <= NOW() ' );
140
+ $ query ->andWhere ('e.is_published = 1 ' );
141
+ $ query ->andWhere ('c.is_published = 1 ' );
137
142
$ query ->groupBy ('el.campaign_id ' );
138
- $ query ->leftJoin ('el ' , MAUTIC_TABLE_PREFIX .'campaigns ' , 'c ' , 'c.id = el.campaign_id ' );
139
143
$ campaigns = $ query ->execute ()->fetchAll ();
140
144
foreach ($ campaigns as $ campaign ) {
141
145
$ id = $ campaign ['campaign_id ' ];
0 commit comments