scale-emkt-cpp/PecaHandler.cpp at master · scale/scale-emkt-cpp · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
/***************************************************************************
 * Copyright (C) 2003 by eddiedu *
 * eddiedu@scale.com.br *
 * *
 * This program is free software; you can redistribute it and/or modify *
 * it under the terms of the GNU General Public License as published by *
 * the Free Software Foundation; either version 2 of the License, or *
 * (at your option) any later version. *
 ***************************************************************************/

#include"PecaHandler.h"

#include"unistd.h"
#include<iostream>
#include<memory>
usingnamespacestd;

PecaHandler::PecaHandler() {
//	mutex.Acquire();
//	mutex.Release();
	debug = newDebug("PecaHandler");
}

PecaHandler::~PecaHandler() {
delete debug;
}

voidPecaHandler::resetEnvio(Peca &peca) {
//Definindo o stats de que esta em andamento
	database.executeQuery("update EmktPeca set stats=1 where "
"id_peca='%d' and id_campanha='%d'", peca.pecaId, peca.campanhaId);
}

voidPecaHandler::lePecasAtivas() {

	vector<Peca> v;

copy(pecas.begin(), pecas.end(), v);
try {
 Pointer
pointer("select * from "
"EmktPeca P inner join EmktCampanha C using(id_campanha, id_peca) "
"where P.data_enviar <= now() and C.stats = 0 and P.stats != 2");

while (pointer.next()) {

 Peca peca;
 peca.from = pointer.get("email_resposta");
 peca.subject = pointer.get("subject");
 peca.txt = pointer.get("corpoTXT");
 peca.html = pointer.get("corpoHTML");
 peca.html += "";

 peca.campanhaId = atoi(pointer.get("id_campanha").c_str());
 peca.pecaId = atoi(pointer.get("id_peca").c_str());

 debug->debug("Peca:%d/%d - %s", peca.campanhaId, peca.pecaId,
 peca.subject.c_str());

 vector<Peca>::iterator it;
for (it = v.begin(); it != v.end(); it++) {
if ((*it) == peca) {
 (*it).ativa = true;

//excluir aqui
 v.erase(it);
continue;
 }
 }
 peca.ativa = true;
 pecas.push_back(peca);
 }

// desativar as remanescentes
 vector<Peca>::iterator it;
for (it = v.begin(); it != v.end(); it++) {
 (*it).ativa = false;
 }

	} catch (DBException dbe) {
 debug->error("%s", dbe.err_description.c_str());
	}
}

void*
PecaHandler::Run(void* param) {

	Peca peca;

lePecasAtivas();

	vector<Peca>::iterator it;
for (it = pecas.begin(); it != pecas.end(); it++) {
resetEnvio(*it);
	}

while (1) {
lePecasAtivas();
Sleep(15);
	}

returnthis;
}

void
PecaHandler::finalizar_peca(const Peca &p) {
try {
 Database database;
 debug->info("Finalizando Peca: id_campanha='%d', id_peca='%d'",
 p.campanhaId, p.pecaId);
 database.executeQuery(
"update EmktPeca set stats=2 where id_campanha='%d' and id_peca='%d'",
 p.campanhaId, p.pecaId);

 p.ativa = false;
	} catch (DBException dbe) {
 debug->error("Peca %d - ERRO: %s", p.pecaId, dbe.err_description.c_str());
	}
}