一个linux下c++程序

#include "/ty_code/common/libyfun/libyfun.h"
2

//#include "libyfun.h"
3

#include "tjpro.h"
4

#include <time.h>
5

#include <stdio.h>
6

#include <memory.h>
7

#include <pthread.h>
8

GBLPARAM gb;//公有变量
10

void Init()
12

{
13

//得到调试信息
14

gb.is_debug = 1;
16

gb.debug_level = 3;
17

strcpy (gb.log_file, "/ty/log/tjpro.log");
18

}
20

int gethour()
22

{
23

time_t timep;
24

struct tm *p;
25

time(&timep);
26

p= localtime(&timep);
27

return p->tm_hour;
28

}
30

int datapro()
32

{
33

yCMysql da;
34

if(0 == da.Login("127.0.0.1","","","")) //连接数据库
35

{
36

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro login db fail!!\n");
37

return 0;
38

}
40

char sql[500];
41

memset(sql,0,500);
42

time_t m_ltime;
45

time(&m_ltime);
46

time_t m_btime;
47

time_t m_mtime;
48

m_btime = m_ltime - 86400;
49

m_mtime=m_ltime-300; //显示0点前一天的日期
50

time_t m_tmtime;
51

m_tmtime = m_ltime - 5184000; //60天以前
52

//删除60天以前的记录
54

sprintf(sql,"delete from tab_sxxrz where sjsj < %ld",m_tmtime);
55

if(da.QueryWrite(sql) == 0)
56

{
57

da.Logout();
58

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tab_sxxrz QueryWrite %s fail!!\n",sql);
59

return 0;
60

}
61

memset(sql,0,500);
63

sprintf(sql,"delete from tab_dxbj where dxsj < %ld",m_tmtime);
64

if(da.QueryWrite(sql) == 0)
65

{
66

da.Logout();
67

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tab_dxbj QueryWrite %s fail!!\n",sql);
68

return 0;
69

}
70

memset(sql,0,500);
73

sprintf(sql,"delete from tab_gkrz where tjsj < %ld",m_tmtime);
74

if(da.QueryWrite(sql) == 0)
75

{
76

da.Logout();
77

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tab_gkrz QueryWrite %s fail!!\n",sql);
78

return 0;
79

}
80

memset(sql,0,500);
82

sprintf(sql,"delete from tab_kkbj where tjsj < %ld",m_tmtime);
83

if(da.QueryWrite(sql) == 0)
84

{
85

da.Logout();
86

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tab_kkbj QueryWrite %s fail!!\n",sql);
87

return 0;
88

}
89

////统计开卡
92

memset(sql,0,500);
93

sprintf(sql,"select dwbh,count(dwbh) as kks from tab_kk where sfyx = 1 and kksj>=%ld and kksj<%ld group by dwbh",m_btime,m_ltime); //统计0点以前24小时
94

if(da.QueryRead(sql) == 0)
95

{
96

da.Logout(); //关闭连接
97

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryRead1 %s fail!!\n",sql);
98

return 0;
99

}
100

int k = da.GetRowNum();
101

if(k > 0)
102

{
103

char temp[1000][30]; //最高1000家网吧开卡
104

memset(temp,0,1000*30*sizeof(char));
105

for(int i=0;i<k;i++)
106

{
107

da.GetRow();
108

sprintf(temp[i],"%s,%s",da.row[0],da.row[1]);
109

}
110

da.FreeResult();
111

for (int j=0;j<k;j++)
112

{
113

// da.GetRow();
114

char m_dwbh[15] ={0};
115

char m_kks[15] ={0};
116

char *p = temp[j];
117

char *pt = temp[j];
118

while(1)
119

{
120

if(*p ==',')
121

{
122

*p = '\0';
123

sprintf(m_dwbh,"%s",pt);
124

p++;
125

pt = p;
126

}
127

else if(*p == '\0')
128

{
129

sprintf(m_kks,"%s",pt);
130

break;
131

}
132

else
133

p++;
134

135

}
136

137

138

if(atoi(m_kks) > 5) //网吧开卡数大于5张不进行统计,并删除原来当天的报警项
139

{
140

memset(sql,0,500);
141

sprintf(sql,"delete from tab_kkbj where tjsj >= %ld and dwbh = %s",m_btime,m_dwbh);
142

if(da.QueryWrite(sql) == 0)
143

{
144

da.Logout(); //关闭连接
145

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryWrite %s fail!!\n",sql);
146

return 0;
147

}
148

continue;
149

}
150

151

memset(sql,0,500);
152

sprintf(sql,"select dwbh from tab_kkbj where tjsj >= %ld and dwbh = %s",m_btime,m_dwbh); //查询开卡报警表中是否有今天网吧记录
153

if(da.QueryRead(sql) == 0)
154

{
155

da.Logout(); //关闭连接
156

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryRead2 %s fail!!\n",sql);
157

return 0;
158

}
159

if(da.GetRowNum() >0)
160

{
161

memset(sql,0,500);
162

sprintf(sql,"update tab_kkbj set kks = %s,tjsj = %ld where tjsj >= %ld and dwbh = %s",m_kks,m_mtime,m_btime,m_dwbh);
163

if(da.QueryWrite(sql) == 0)
164

{
165

da.Logout();
166

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryWrite1 %s fail!!\n",sql);
167

return 0;
168

}
169

}
170

else
171

{
172

memset(sql,0,500);
173

sprintf(sql,"insert into tab_kkbj(dwbh,kks,tjsj) values(%s,%s,%ld)",m_dwbh,m_kks,m_mtime);
174

if(da.QueryWrite(sql) == 0)
175

{
176

da.Logout();
177

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryWrite2 %s fail!!\n",sql);
178

return 0;
179

}
180

}
181

da.FreeResult();
182

}
183

}
184

185

186

/*
187

sprintf(sql,"select dwbh from tab_kk where kksj>%ld",m_btime);
188

if(da.QueryRead(sql) == 0)
189

{
190

da.Logout(); //关闭连接
191

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryRead %s fail!!\n",sql);
192

return 0;
193

}
194

195

if(da.GetRowNum() > 0)
196

{
197

da.FreeResult();
198

memset(sql,0,500);
199

sprintf(sql,"insert into tab_kkbj(dwbh,kks,tjsj) select dwbh,count(dwbh) as kks,%ld as tjsj from tab_kk where kksj>%ld group by dwbh",m_ltime,m_btime);
200

if(da.QueryWrite(sql) == 0)
201

{
202

da.Logout();
203

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryWrite %s fail!!\n",sql);
204

return 0;
205

}
206

}
207

*/
208

209

210

// 统计公卡日志
211

memset(sql,0,500);
212

sprintf(sql,"select sl from tab_tjpz where mc='gkcs'");
213

if(da.QueryRead(sql) == 0)
214

{
215

da.Logout(); //关闭连接
216

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryRead %s fail!!\n",sql);
217

return 0;
218

}
219

char gkcs[4] = {0};
220

da.GetRow();
221

sprintf(gkcs,"%s",da.row[0]);
222

da.FreeResult();
223

224

225

226

memset(sql,0,500);
227

sprintf(sql,"select kh,dwbh,count(kh) as sjcs from tab_sxxrz where sjsj>=%ld group by kh,dwbh",m_btime);
228

if(da.QueryRead(sql) == 0)
229

{
230

da.Logout(); //关闭连接
231

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryRead %s fail!!\n",sql);
232

return 0;
233

}
234

int gk = da.GetRowNum();
235

if(gk > 0)
236

{
237

char tempgk[200000][35]; //最高20万人次
238

memset(tempgk,0,200000*35*sizeof(char));
239

for(int i=0;i<gk;i++)
240

{
241

da.GetRow();
242

sprintf(tempgk[i],"%s,%s:%s",da.row[0],da.row[1],da.row[2]);
243

}
244

da.FreeResult();
245

for (int j=0;j<gk;j++)
246

{
247

// da.GetRow();
248

char m_kh[15] ={0};
249

char m_dwbh[15] ={0};
250

char m_sjcs[15] ={0};
251

char *p = tempgk[j];
252

char *pt = tempgk[j];
253

while(1)
254

{
255

if(*p ==',')
256

{
257

*p = '\0';
258

sprintf(m_kh,"%s",pt);
259

p++;
260

pt = p;
261

}
262

else if(*p == ':')
263

{
264

*p = '\0';
265

sprintf(m_dwbh,"%s",pt);
266

p++;
267

pt = p;
268

269

}
270

else if(*p == '\0')
271

{
272

273

sprintf(m_sjcs,"%s",pt);
274

break;
275

}
276

else
277

p++;
278

279

}
280

281

if(atoi(m_sjcs) < atoi(gkcs))
282

{
283

continue;
284

}
285

sprintf(sql,"insert into tab_gkrz(kh,dwbh,sjcs,tjsj) values('%s',%s,%s,%ld)",m_kh,m_dwbh,m_sjcs,m_mtime);
286

if(da.QueryWrite(sql) == 0)
287

{
288

da.Logout();
289

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryWrite3 %s fail!!\n",sql);
290

return 0;
291

}
292

293

294

}
295

}
296

/*
297

sprintf(sql,"insert into tab_gkrz(kh,dwbh,sjcs,tjsj) select kh,dwbh,count(kh) as sjcs,%ld as tjsj from tab_sxxrz where sjsj>%ld group by kh,dwbh",m_mtime,m_btime);
298

if(da.QueryWrite(sql) == 0)
299

{
300

da.Logout();
301

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"tjpro QueryWrite3 %s fail!!\n",sql);
302

return 0;
303

}
304

305

306

*/
307

308

da.Logout();
309

return 1;
310

311

}
312

313

void * dxtjpro(void *arg)
314

{
315

316

317

while(1)
318

{
319

sleep(298); //等待5分钟
320

////////////
321

yCMysql da;
322

if(0 == da.Login("127.0.0.1","","","")) //连接数据库
323

{
324

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro login db fail!!\n");
325

return 0;
326

}
327

char sql[5100];
328

memset(sql,0,5100);
329

time_t m_ltime; //现在的时间
330

time_t m_btime;
331

time(&m_ltime);
332

m_btime = m_ltime - 300; //
333

334

335

memset(sql,0,5100);
336

337

sprintf(sql,"select dwbh from tab_dxbj where ljsj = 0");
338

if(da.QueryRead(sql) == 0)
339

{
340

da.Logout(); //关闭连接
341

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro QueryRead %s fail!!\n",sql);
342

return 0;
343

}
344

int m = da.GetRowNum();
345

if(m>0)
346

{
347

char tempdwbh[5000] = {0}; //最高500家9位编号
348

int k = 0;
349

for(int n=0;n<m;n++)
350

{
351

da.GetRow();
352

k+=sprintf(tempdwbh+k,"%s,", da.row[0]);
353

}
354

tempdwbh[k-1] ='\0';
355

da.FreeResult();
356

memset(sql,0,5100);
357

sprintf(sql,"insert into tab_dxbj(dwbh,dxsj,ljsj) (select dwbh,wssj,0 as ljsj from tab_dwzl where wssj<%ld and dwbh not in(%s))",m_btime,tempdwbh);
358

if(da.QueryWrite(sql) == 0)
359

{
360

da.Logout();
361

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro QueryWrite %s fail!!\n",sql);
362

return 0;
363

}
364

}
365

else
366

{
367

memset(sql,0,5100);
368

sprintf(sql,"insert into tab_dxbj(dwbh,dxsj,ljsj) (select dwbh,wssj,0 as ljsj from tab_dwzl where wssj<%ld)",m_btime);
369

if(da.QueryWrite(sql) == 0)
370

{
371

da.Logout();
372

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro QueryWrite %s fail!!\n",sql);
373

return 0;
374

}
375

}
376

377

378

379

///在5分钟内有握手的断线编号全部置为连接
380

memset(sql,0,5100);
381

sprintf(sql,"select dwbh from tab_dwzl where wssj>=%ld",m_btime);
382

if(da.QueryRead(sql) == 0)
383

{
384

da.Logout(); //关闭连接
385

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro QueryRead2 %s fail!!\n",sql);
386

return 0;
387

}
388

int j = da.GetRowNum();
389

if(j>0)
390

{
391

char tempCard[5000] = {0};
392

int k = 0;
393

for(int i=0;i<j;i++)
394

{
395

da.GetRow();
396

k+=sprintf(tempCard+k,"%s,", da.row[0]);
397

}
398

tempCard[k-1] ='\0';
399

da.FreeResult();
400

memset(sql,0,500);
401

sprintf(sql,"update tab_dxbj set ljsj = %ld where ljsj = 0 and dwbh in(%s)",m_ltime,tempCard);
402

if(da.QueryWrite(sql) == 0)
403

{
404

da.Logout();
405

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro QueryWrite2 %s fail!!\n",sql);
406

return 0;
407

}
408

}
409

da.Logout();
410

}
411

412

/*
413

414

/////////////
415

416

while(1)
417

{
418

sleep(88); //等待
419

// yCMysql da;
420

if(0 == da.Login("127.0.0.1","operator","operator","dbs_whbzx")) //连接数据库
421

{
422

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro login db fail!!\n");
423

return 0;
424

425

}
426

// char sql[500];
427

// memset(sql,0,5100);
428

// time_t m_ltime; //现在的时间
429

// time_t m_btime;
430

time(&m_ltime);
431

time_t m_bbtime;
432

m_btime = m_ltime - 90; //
433

m_bbtime = m_ltime - 180; //
434

435

memset(sql,0,5100);
436

sprintf(sql,"select dwbh from tab_dwzl where wssj>=%ld and wssj<%ld",m_bbtime,m_btime); //90至180新断线
437

if(da.QueryRead(sql) == 0)
438

{
439

da.Logout(); //关闭连接
440

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro QueryRead1 %s fail!!\n",sql);
441

return 0;
442

}
443

if(da.GetRowNum() > 0)
444

{
445

memset(sql,0,5100);
446

sprintf(sql,"insert into tab_dxbj(dwbh,dxsj,ljsj) (select dwbh,wssj,0 as ljsj from tab_dwzl where wssj>=%ld and wssj<%ld)",m_bbtime,m_btime); //握手时间前90至180的插入报警表
447

if(da.QueryWrite(sql) == 0)
448

{
449

da.Logout();
450

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro QueryWrite1 %s fail!!\n",sql);
451

return 0;
452

}
453

}
454

da.FreeResult();
455

456

///在90秒内有握手的断线编号全部置为连接
457

memset(sql,0,5100);
458

sprintf(sql,"select dwbh from tab_dwzl where wssj>=%ld",m_btime);
459

if(da.QueryRead(sql) == 0)
460

{
461

da.Logout(); //关闭连接
462

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro QueryRead2 %s fail!!\n",sql);
463

return 0;
464

}
465

int j = da.GetRowNum();
466

if(j>0)
467

{
468

char tempCard[5000] = {0};
469

int k = 0;
470

for(int i=0;i<j;i++)
471

{
472

da.GetRow();
473

k+=sprintf(tempCard+k,"%s,", da.row[0]);
474

}
475

tempCard[k-1] ='\0';
476

da.FreeResult();
477

memset(sql,0,500);
478

sprintf(sql,"update tab_dxbj set ljsj = %ld where ljsj = 0 and dwbh in(%s)",m_ltime,tempCard);
479

if(da.QueryWrite(sql) == 0)
480

{
481

da.Logout();
482

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro QueryWrite2 %s fail!!\n",sql);
483

return 0;
484

}
485

}
486

da.Logout();
487

}
488

*/
489

}
490

491

void * kktjpro(void *arg)
492

{
493

494

char sql[500];
495

memset(sql,0,500);
496

time_t m_ltime; //现在的时间
497

long m_ttime; //当日0点的时间
498

struct tm *p;
499

time(&m_ltime);
500

p = localtime(&m_ltime);
501

m_ttime =m_ltime - ((p->tm_hour *60*60)+(p->tm_min *60)+(p->tm_sec));
502

// DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"0点时间：%ld!!\n",m_ttime);
503

504

while(1)
505

{
506

507

yCMysql da;
508

if(0 == da.Login("127.0.0.1","","","")) //连接数据库
509

{
510

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"kktjpro login db fail!!\n");
511

return 0;
512

513

}
514

sprintf(sql,"select dwbh,count(dwbh) as kks from tab_kk where sfyx = 1 and kksj>=%ld group by dwbh",m_ttime); //统计0点以后开卡网吧及开卡数
515

if(da.QueryRead(sql) == 0)
516

{
517

da.Logout(); //关闭连接
518

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"kktjpro QueryRead %s fail!!\n",sql);
519

return 0;
520

}
521

int k = da.GetRowNum();
522

if(k > 0)
523

{
524

char temp[1000][30]; //最高1000家
525

memset(temp,0,1000*30*sizeof(char));
526

for(int i=0;i<k;i++)
527

{
528

da.GetRow();
529

sprintf(temp[i],"%s,%s",da.row[0],da.row[1]);
530

}
531

da.FreeResult();
532

for (int j=0;j<k;j++)
533

{
534

// da.GetRow();
535

char m_dwbh[15] ={0};
536

char m_kks[15] ={0};
537

char *p = temp[j];
538

char *pt = temp[j];
539

while(1)
540

{
541

542

if(*p ==',')
543

{
544

*p = '\0';
545

sprintf(m_dwbh,"%s",pt);
546

p++;
547

pt = p;
548

}
549

else if(*p == '\0')
550

{
551

sprintf(m_kks,"%s",pt);
552

break;
553

}
554

else
555

p++;
556

}
557

558

if(atoi(m_kks) > 5) //网吧开卡数大于5张不进行统计,并删除原来当天的报警项
559

{
560

memset(sql,0,500);
561

sprintf(sql,"delete from tab_kkbj where tjsj >= %ld and dwbh = %s",m_ttime,m_dwbh);
562

if(da.QueryWrite(sql) == 0)
563

{
564

da.Logout(); //关闭连接
565

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"kktjpro QueryWrite %s fail!!\n",sql);
566

return 0;
567

}
568

continue;
569

}
570

memset(sql,0,500);
571

sprintf(sql,"select dwbh from tab_kkbj where tjsj >= %ld and dwbh = %s",m_ttime,m_dwbh); //查询开卡报警表中是否有今天网吧记录
572

if(da.QueryRead(sql) == 0)
573

{
574

da.Logout(); //关闭连接
575

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"kktjpro QueryRead %s fail!!\n",sql);
576

return 0;
577

}
578

if(da.GetRowNum() >0)
579

{
580

da.FreeResult();
581

memset(sql,0,500);
582

sprintf(sql,"update tab_kkbj set kks = %s,tjsj = %ld where tjsj >= %ld and dwbh = %s",m_kks,m_ltime,m_ttime,m_dwbh);
583

if(da.QueryWrite(sql) == 0)
584

{
585

da.Logout();
586

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"kktjpro QueryWrite %s fail!!\n",sql);
587

return 0;
588

}
589

}
590

else
591

{
592

memset(sql,0,500);
593

sprintf(sql,"insert into tab_kkbj(dwbh,kks,tjsj) values(%s,%s,%ld)",m_dwbh,m_kks,m_ltime);
594

if(da.QueryWrite(sql) == 0)
595

{
596

da.Logout();
597

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"kktjpro QueryWrite %s fail!!\n",sql);
598

return 0;
599

}
600

}
601

602

}
603

}
604

da.Logout();
605

sleep(7200);
606

}
607

608

609

}
610

611

void main()
612

{
613

sleep(5); ///暂停五秒等待数据库
614

Init();
615

pthread_t id;
616

int ret = pthread_create(&id,NULL,dxtjpro,NULL); //创建统计断线线程
617

if(ret != 0)
618

{
619

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"dxtjpro create fail! errcode %d\n",ret);
620

exit(0) ;
621

}
622

623

pthread_t td;
624

int m_ret = pthread_create(&td,NULL,kktjpro,NULL); //创建统计开卡线程
625

if(m_ret != 0)
626

{
627

DEBUG(gb.is_debug,gb.debug_level,gb.log_file,"kktjpro create fail! errcode %d\n",ret);
628

exit(0) ;
629

}
630

631

if(gethour() == 0) //防止程序在0点至1点重启时进行重复统计
632

{
633

sleep(7200); //暂停2个小时
634

}
635

636

while(1)
637

{
638

if(gethour() == 0) //0点统计
639

{
640

datapro();
641

sleep(7200); //暂停2个小时
642

}
643

else
644

{
645

sleep(60); //暂停1分钟
646

}
647

}
648

649

}
650

651