开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > DVD > 查看源码
Demand.c
资源名称：ST_5105DTV.rar　[点击查看]
上传用户：fy98168
上传日期：2015-06-26
资源大小：13771k
文件大小：36k
源码类别：

DVD

开发平台：

C/C++

Demand.c：源码内容
  1. //
  2. // (C)版权2006 深圳市键桥通讯技术有限公司
  3. // 
  4. // 文件名称: Demand.c
  5. // 
  6. // 创建日期: 2007.03.25
  7. //
  8. // 创建人 :wangxiaorong
  9. //
  10. // 修改人 : ***
  11. //
  12. //修改日期: 2007.3.29
  13. //
  14. // 描 述:  预约实现源文件
  15. //
  16. // 版 本：1.0.0
  17. //--------------------------------------------------------------------
  18. #include  <stdio.h>
  19. #include <string.h>
  20. #include <stdlib.h>
  21. #include <ctype.h>
  22. #include "osd.h"
  23. #include "db.h"
  24. #include "rckeymap.h"
  25. #include "epg.h"
  26. #include "timeclk.h"
  27. #include "Nvod.h"
  28. #include "Demand.h"
  29. #include "sr_time.h"
  30. static EPGDDataLink *EDDataLink=NULL;
  32. #if 0
  33. /*=============================================================
  34.  函数名称 : EDHF_AddDataLink
  35.  功    能 : 添加预约信息数据链
  36.  入    口 : int prgno --------节目号
  37.   int eid   -------- 事件号
  38.   USHORT mjd ------ 播放日期
  39.   int secs  --------播放起始时间
  40.   int dur   --------播放时长
  41.   int edt   --------事件类型
  42.  出    口 : 无
  43.  返    回 : TRUE---成功，FALSE---失败
  44. =============================================================*/
  45.  BOOL KB_AddDataLink(int prgno,int eid,USHORT mjd,int secs,int dur,int edt)
  46. {
  47. EPGDDataLink  **ppEDL=&EDDataLink;
  48. //搜索到最后
  49. while(*ppEDL != NULL)
  50. {
  51. ppEDL=&((*ppEDL)->nextnode);
  52. }
  53. //追加
  54. *ppEDL=(EPGDDataLink*)KB_OSPMalloc(sizeof(EPGDDataLink));
  55. if(*ppEDL == NULL)
  56. {
  57. printf("n预约信息存储空间分配失败!");
  58. return FALSE;
  59. }
  60. (*ppEDL)->prgno=prgno;
  61. (*ppEDL)->eid=eid;
  62. (*ppEDL)->mjd=mjd;
  63. (*ppEDL)->seconds=secs;
  64. (*ppEDL)->duration=dur;
  65. (*ppEDL)->edt=edt;
  66. (*ppEDL)->nextnode=NULL;
  67. return TRUE;
  68. }
  69. #else 
  70. /*=============================================================
  71.  函数名称 : KB_AddDataLink
  72.  功    能 : 添加预约信息数据链
  73.  入    口 : EPGDDataLink *Demanddata
  74.  出    口 : 无
  75.  返    回 : TRUE---成功，FALSE---失败
  76. =============================================================*/
  77.  BOOL KB_AddDataLink(EPGDDataLink *Demanddata)
  78. {
  79.      EPGDDataLink  **ppEDL=&EDDataLink;
  80. //搜索到最后
  81. while(*ppEDL != NULL)
  82. {
  83. ppEDL=&((*ppEDL)->nextnode);
  84. }
  85. //追加
  86. *ppEDL=(EPGDDataLink*)KB_OSPMalloc(sizeof(EPGDDataLink));
  87. if(*ppEDL == NULL)
  88. {
  89. printf("n预约信息存储空间分配失败!");
  90. return FALSE;
  91. }
  92. (*ppEDL)->prgno=Demanddata->prgno;
  93. (*ppEDL)->eid=Demanddata->eid;
  94. (*ppEDL)->mjd=Demanddata->mjd;
  95. (*ppEDL)->seconds=Demanddata->seconds;
  96. (*ppEDL)->duration=Demanddata->duration;
  97. (*ppEDL)->edt=Demanddata->edt;
  98. strcpy((*ppEDL)->chlname, Demanddata->chlname);
  99. strcpy((*ppEDL)->prgname, Demanddata->prgname);
  100. strcpy((*ppEDL)->date,Demanddata->date);
  101. strcpy((*ppEDL)->time,Demanddata->time);
  102. (*ppEDL)->nextnode=NULL;
  103. return TRUE;
  104. }
  105. #endif
  107. /*=============================================================
  108.  函数名称 : KD_DelDataLink
  109.  功    能 : 删除指定的预约信息
  110.  入    口 : USHORT mjd --- 指定的预约日期
  111.   int sec    -----指定的播出时间
  112.  出    口 : 无
  113.  返    回 : TRUE---成功，FALSE---失败
  114. =============================================================*/
  115. BOOL KB_DelDataLink(USHORT mjd,int sec)
  116. {
  117. EPGDDataLink  *pEDL=EDDataLink,*qEDL=NULL;
  118. //删除指定的节点
  119. while(pEDL != NULL)
  120. {
  121. if(pEDL->mjd== mjd && pEDL->seconds==sec)
  122. break;
  123. qEDL=pEDL;
  124. pEDL=pEDL->nextnode;
  125. }
  126. //如果没找到,返回
  127. if(pEDL == NULL)
  128. return FALSE;
  129. //找到删除
  130. if(qEDL== NULL)
  131. {
  132. EDDataLink=EDDataLink->nextnode;
  133. }
  134. else
  135. {
  136. qEDL->nextnode=pEDL->nextnode;
  137. }
  138. KB_OSPFree(pEDL);
  139. return TRUE;
  140. }
  141. /*=============================================================
  142.  函数名称 : KB_GetDataLink
  143.  功    能 : 获取指定索引的预约信息
  144.  入    口 : int nItemIdx --- 指定的预约索引
  145.  出    口 : struct  _EDHFDataLink* pdl --获取节点
  146.  返    回 : TRUE---成功，FALSE---失败
  147. =============================================================*/
  148. BOOL KB_GetDataLink(int nItemIdx,EPGDDataLink* pdl)
  149. {
  150. EPGDDataLink  *pEDL=EDDataLink;
  151. int i=0;
  152. if(pdl == NULL)
  153. {
  154. printf("n传入节点地址不存在!");
  155. return FALSE;
  156. }
  157. //获取指定的节点
  158. while(pEDL != NULL)
  159. {
  160. if(i == nItemIdx)
  161. {
  162. memcpy(pdl,pEDL,sizeof(EPGDDataLink));
  163. return TRUE;
  164. }
  165. pEDL=pEDL->nextnode;
  166. i++;
  167. }
  168. return FALSE;
  169. }
  170. /*=============================================================
  171.  函数名称 : KB_GetDataLinkNum
  172.  功    能 : 获取预约信息的总数
  173.  入    口 : 无
  174.  出    口 :UINT  *num--预约信息的总数
  175.  返    回 : TRUE---成功，FALSE---失败
  176. =============================================================*/
  177. BOOL KB_GetDataLinkNum(UINT *num)
  178. {
  179. EPGDDataLink  *pEDL=EDDataLink;
  180.        int i=0;
  182. while(pEDL != NULL)
  183. {
  184. pEDL=pEDL->nextnode;
  185. i++;
  186. }
  188. *num=i;
  190. return TRUE;
  192. }
  194. /*=============================================================
  195.  函数名称 : KB_ClearDataLink
  196.  功    能 : 清除所有预约信息
  197.  入    口 : 无
  198.  出    口 : 无
  199.  返    回 : 无
  200. =============================================================*/
  201. void   KB_ClearDataLink()
  202. {
  203. EPGDDataLink  *pEDL=EDDataLink,*qEDL;
  204. //删除所有的节点
  205. while(pEDL != NULL)
  206. {
  207. qEDL=pEDL->nextnode;
  208. KB_OSPFree(pEDL);
  209. pEDL=qEDL;
  210. }
  211. EDDataLink=NULL;
  212. }
  214. /*=============================================================
  215.  函数名称 : KB_DelOnTimeDmdEnt
  216.  功    能 : 清除预约到时节目
  217.  入    口 : 无
  218.  出    口 : 无
  219.  返    回 : 无
  220. =============================================================*/
  221. void KB_DelOnTimeDmdEnt()
  222. {
  223. time_t cur_seconds;
  224. EPGDChlLink  *pp=EDTLink,*pq=NULL;
  225. EPGDEntLink *sp,*sq;
  226. int CurWeekDay=0,nYear, nMonth, nDay;
  228. //先获取当前时间
  229. if(KB_TimeGetCurTime(&cur_seconds)==0)
  230. return;
  231. //检验前把所有今天之前预约的节目清除
  232. CurWeekDay=ConvertTimeStampToDate((U32)cur_seconds, (U32 *)&nYear, (U32 *)&nMonth, (U32 *)&nDay);
  234. while(pp != NULL)
  235. {
  236. sp=pp->DmdEnt;
  237. sq=NULL;
  238. while(sp!=NULL)
  239. {
  240. if((CurWeekDay)==sp->mjd)///////////////////////////////////////注意问题
  241. {
  242. //清除播放的预约节目
  243. if((cur_seconds >= sp->seconds-30)&&(cur_seconds<=sp->seconds + sp->duration))
  244. {
  245. KB_DelDataLink(sp->mjd,(int)sp->seconds);
  246. //printf("n---------del--------   yijingbofangjiemu");
  247. if(sq == NULL)
  248. {
  249. pp->DmdEnt=pp->DmdEnt->next;
  250. KB_OSPFree(sp);
  251. sp=pp->DmdEnt;
  252. }
  253. else
  254. {
  255. sq->next=sp->next;
  256. KB_OSPFree(sp);
  257. sp=sq->next;
  258. }
  259. }
  260. else
  261. {
  262. sq=sp;
  263. sp=sp->next;
  264. }
  265. }
  266. else
  267. {
  268. sq=sp;
  269. sp=sp->next;
  270. }
  271. }
  272. //如果当前频道没有任何预约节目，清除该频道
  273. if(pp->DmdEnt == NULL)
  274. {
  275. if(pq == NULL)
  276. {
  277. EDTLink=EDTLink->next;
  278. KB_OSPFree(pp);
  279. pp=EDTLink;
  280. }
  281. else
  282. {
  283. pq->next=pp->next;
  284. KB_OSPFree(pp);
  285. pp=pq->next;
  286. }
  287. }
  288. else
  289. {
  290. pq =pp;
  291. pp=pp->next;
  292. }
  293. }
  294. }
  297. /*=============================================================
  298.  函数名称 : KB_CheckOnlyOne
  299.  功    能 : 预约节目是否同时播出校验
  300.  入    口 : USHORT mjg-----------节目播出日期
  301.   int secs ------------节目播出起始秒
  302.  出    口 : int * nManiIdx------ 频道索引
  303.   int* nSubIdx ------- 节目索引
  304.  返    回 : TRUE---成功(有同时播出的节目，但不替换)，FALSE---失败(没有相同或者已经替换掉)
  305. =============================================================*/
  306. BOOL  KB_CheckOnlyOne(USHORT mjg,int secs,int * nManiIdx,int* nSubIdx)
  307. {
  308. EPGDChlLink  *pp=EDTLink;
  309. EPGDEntLink *sp;
  310. EPGDEntLink *p1,*p2;
  311. register int nm=0,ns;
  312. //char *pszInfo;
  313. int nLangType;
  314. nLangType=KB_DBGetLanguageFlag();
  315. //搜索同日期同时播出的节目
  316. while(pp != NULL)
  317. {
  318. sp=pp->DmdEnt;
  319. ns=0;
  320. p1=sp;
  321. while(sp != NULL)
  322. {
  324. if((sp->mjd == mjg )&&(sp->seconds == secs))
  325. {
  326. *nManiIdx=nm;
  327. *nSubIdx=ns;
  328. //pszInfo=KB_GetLanguageInfoStr(nLangType,STR_BEIJING);//提示只能同时播一个节目
  329. //if(pszInfo != NULL)
  330. //nRet=D_OSD_MSGBox("冲突替换原有的吗?", MB_YESNO|MB_ICONINFORMATION, 0,IDNO);
  331. //if(nRet == IDNO) //不替换
  332. //return TRUE;
  333. //替换
  334. if(sp==pp->DmdEnt)
  335. {
  336.      pp->DmdEnt=sp->next;
  337. }
  338. else
  339. {
  340.      p2->next=p1->next;
  341. }
  342. KB_OSPFree(sp);
  343. return FALSE;//替换
  344. }
  345. ns++;
  346. sp = sp->next;
  347. if(p1->next!=NULL)
  348. {
  349. p2=p1;
  350. p1=p1->next;
  351. }
  352. }
  353. nm++;
  354. pp = pp->next;
  355. }
  356. //没有找到
  357. *nManiIdx=-1;
  358. *nSubIdx=-1;
  360. return FALSE;//无冲突
  361. }
  362. /*=============================================================
  363.  函数名称 : KB_GetDmdEntCount
  364.  功    能 : 获取预约节目总数目
  365.  入    口 : 无
  366.  出    口 : 无
  367.  返    回 : 预约节目总数
  368. =============================================================*/
  369. int  KB_GetDmdEntCount()
  370. {
  371. EPGDChlLink  *pp=EDTLink;
  372. EPGDEntLink *sp;
  373. register int i=0;
  374. while(pp!=NULL)
  375. {
  376. sp=pp->DmdEnt;
  377. while(sp!=NULL)
  378. {
  379. i++;
  380. sp=sp->next;
  381. }
  382. pp=pp->next;
  383. }
  384. return i;
  385. }
  386. /*=============================================================
  387.  函数名称 : KB_CheckOntimeDemand
  388.  功    能 : 检验出到时间的预约节目,然后提示用户
  389.  入    口 : 无
  390.  出    口 : 无
  391.  返    回 : TRUE---有，FALSE---没有
  392. =============================================================*/
  393.  BOOL KB_CheckOntimeDemand(int *chno,int*type,int*entid)
  394. {
  396. EPGDChlLink  *pp=EDTLink,*pq=NULL;
  397. EPGDEntLink *sp,*sq;
  398. time_t cur_seconds;
  399. int nYear, nMonth, nDay;
  400. int sCurWeekDay=0;
  401. //先获取当前时间
  402. KB_TimeGetCurTime(&cur_seconds);
  403. sCurWeekDay=ConvertTimeStampToDate((U32)cur_seconds, (U32 *)&nYear, (U32 *)&nMonth, (U32 *)&nDay);
  404. //检验前把所有今天之前预约的节目清除
  405. while(pp != NULL)
  406. {
  407. sp=pp->DmdEnt;
  408. sq=NULL;
  409. while(sp!=NULL)
  410. {
  411. //凡是预约日期小于当天日期的，全部清除
  412. if(sp->mjd<sCurWeekDay)
  413. {
  414. if(sq == NULL)
  415. {
  416. pp->DmdEnt=pp->DmdEnt->next;
  417. KB_OSPFree(sp);
  418. sp=pp->DmdEnt;
  419. }
  420. else
  421. {
  422. sq->next=sp->next;
  423. KB_OSPFree(sp);
  424. sp=sq->next;
  425. }
  426. }
  427. else if(sCurWeekDay==sp->mjd)
  428. {
  429. //当天如果已经被播放过，清除它
  430. if (cur_seconds >= sp->seconds+24)
  431. {
  432. if(sq == NULL)
  433. {
  434. pp->DmdEnt=pp->DmdEnt->next;
  435. KB_OSPFree(sp);
  436. sp=pp->DmdEnt;
  437. }
  438. else
  439. {
  440. sq->next=sp->next;
  441. KB_OSPFree(sp);
  442. sp=sq->next;
  443. }
  444. }
  445. else
  446. {
  447. sq=sp;
  448. sp=sp->next;
  449. }
  450. }
  451. else
  452. {
  453. sq=sp;
  454. sp=sp->next;
  455. }
  456. }
  457. //如果当前频道没有任何预约节目，清除该频道
  458. if(pp->DmdEnt == NULL)
  459. {
  460. if(pq == NULL)
  461. {
  462. EDTLink=EDTLink->next;
  463. KB_OSPFree(pp);
  464. pp=EDTLink;
  465. }
  466. else
  467. {
  468. pq->next=pp->next;
  469. KB_OSPFree(pp);
  470. pp=pq->next;
  471. }
  472. }
  473. else
  474. {
  475. pq =pp;
  476. pp=pp->next;
  477. }
  478. }
  479. //开始校验
  480. pq=EDTLink;
  481. while(pq != NULL)
  482. {
  483. sq=pq->DmdEnt;
  484. while(sq != NULL)
  485. {
  486. //持续秒
  487. //printf("n----left  time------%d",cur_seconds - sq->seconds);
  488. if ((cur_seconds >= (sq->seconds-30))&& (cur_seconds < sq->seconds) )
  489. {
  490. if(chno != NULL&&type!= NULL&&entid!= NULL)
  491. {
  492. *chno=pq->ProgIndex;
  493. *type=pq->edt;
  494. *entid=sq->eventid;
  495.   }
  496. return TRUE;
  497. }
  499. sq=sq->next;
  500. }
  502. pq=pq->next;
  503. }
  505. return FALSE;
  506. }
  508. /*=============================================================
  509.  函数名称 : KB_SaveDmdEnt
  510.  功    能 : 存储预约信息到NVM,前4个字节是操作标记,紧接着4个字节
  511.   放数据信息的大小,其次接着4个字节是频道数,每个频道的
  512.   数据信息前面4个字节存放当前频道预约节目个数,
  513. ---------------------------------------------------------------------------------
  514. | 标记 | 总数 | 频道 | 类型 | 节目 | 事件 | mjd | sec | dur | eid |
  515. |  | 据大 | 总数 |  | id  | 总数 | | | | |
  516. | 4b  | 小4b | 4b  | 4b  | 4b  | 4b  | 4b | 4b | 4b | 4b |
  517. --------------------------------------------------------------------------------- 
  518.  --------------------------------------------------------
  519.  | 类型 | 节目 | 事件 | mjd | sec | dur | eid |
  520.  |  | id  | 总数 | | | | |
  521.  | 4b  | 4b  | 4b  | 4b | 4b | 4b | 4b |
  522.  -------------------------------------------------------- 
  523.  --------------------------------------------------------
  524.  | 类型 | 节目 | 事件 | mjd | sec | dur | eid |
  525.  |  | id  | 总数 | | | | |
  526.  | 4b  | 4b  | 4b  | 4b | 4b | 4b | 4b |
  527.  -------------------------------------------------------- 
  528.  入    口 : 无
  529.  出    口 : 无
  530.  返    回 : OSD_RETURN_FAIL:失败,OSD_RETURN_OK:成功
  531. =============================================================*/
  532. int KB_SaveDmdEnt()
  533. {
  534. EPGDChlLink  *pp=EDTLink;
  535. EPGDEntLink *sp;
  536. char *debuf;
  537. UINT  nSize=12;
  538. int ret;
  539. int nchlsum=0,npgmsum,*pnde,*ppnde;
  540. //先计算数据信息的大小
  541. while(pp!= NULL)
  542. {
  543. nchlsum+=1;
  544. nSize+=8;
  545. sp=pp->DmdEnt;
  546. while(sp != NULL)
  547. {
  548. nSize+=16;
  549. sp=sp->next;
  550. }
  551. pp=pp->next;
  552. }
  553. //总字节数
  554. nSize+=nchlsum*4;
  555. debuf=(char*)KB_OSPMalloc(nSize);
  556. if(NULL==debuf)
  557. return OSD_RETURN_FAIL;
  558. memset(debuf,0x00,nSize);
  559. strcpy(debuf,EDHF_OPER_FLAG);
  560. //存储预约信息
  561. pnde=(int*)(debuf+4);
  562. pp=EDTLink;
  563. *(pnde++)=nSize;
  564. *(pnde++)=nchlsum;
  565. while(pp!= NULL)
  566. {
  567. *(pnde++)=pp->edt;
  568. *(pnde++)=pp->ProgIndex;
  569. sp=pp->DmdEnt;
  570. ppnde=pnde++;
  571. npgmsum=0;
  572. while(sp != NULL)
  573. {
  574. npgmsum+=1;
  575. *(pnde++)=(int)(sp->mjd&0x0000FFFF);
  576. *(pnde++)=(int)sp->seconds;
  577. *(pnde++)=(int)sp->duration;
  578. *(pnde++)=(int)(sp->eventid&0x0000FFFF);
  579. sp=sp->next;
  580. }
  581. *ppnde=npgmsum;
  582. pp=pp->next;
  583. }
  585. //写入NVM
  586. // ret=BQ_Storage_DmdEntSave((ULONG)nSize,debuf);
  587. KB_DBSaveDemandInfo(nSize, (UINT8 *)debuf );//存储到e2p
  588. KB_OSPFree(debuf);
  589. return ret;
  590. }
  591. /*=============================================================
  592.  函数名称 : KB_LoadDmdEnt
  593.  功    能 : 加载预约信息到预约结构
  594. ---------------------------------------------------------------------------------
  595. | 标记 | 总数 | 频道 | 类型 | 节目 | 事件 | mjd | sec | dur | eid |
  596. |  | 据大 | 总数 |  | id  | 总数 | | | | |
  597. | 4b  | 小4b | 4b  | 4b  | 4b  | 4b  | 4b | 4b | 4b | 4b |
  598. --------------------------------------------------------------------------------- 
  599.  --------------------------------------------------------
  600.  | 类型 | 节目 | 事件 | mjd | sec | dur | eid |
  601.  |  | id  | 总数 | | | | |
  602.  | 4b  | 4b  | 4b  | 4b | 4b | 4b | 4b |
  603.  -------------------------------------------------------- 
  604.  --------------------------------------------------------
  605.  | 类型 | 节目 | 事件 | mjd | sec | dur | eid |
  606.  |  | id  | 总数 | | | | |
  607.  | 4b  | 4b  | 4b  | 4b | 4b | 4b | 4b |
  608.  -------------------------------------------------------- 
  609.  入    口 : 无
  610.  出    口 : 无
  611.  返    回 : OSD_RETURN_FAIL:失败,OSD_RETURN_OK:成功
  612. =============================================================*/
  613. int KB_LoadDmdEnt()
  614. {
  615. char *debuf,head[9];
  616. UINT nSize;
  617. int *pnde;
  618. register int chlsum,i,j,npgmsum;
  619. int pi,sec,dur;
  620. USHORT mjd;
  621. short eventid;
  622. KB_DBRET ret;
  623. enumDemandType edt;
  624. EPGDChlLink  **pp;
  625. EPGDEntLink **sp;
  626. BOOL bFind;
  627. //先读取信息的总长度
  628. memset(head,0x00,9);
  629. ret=KB_DBGetDemandInfo(8,(UINT8 *)head);
  630. if(ret==RET_FAIL)
  631. return OSD_RETURN_FAIL;
  632. if(strncmp(head,EDHF_OPER_FLAG,4)!=0)
  633. return OSD_RETURN_FAIL;
  635. pnde=(int*)head;
  636. nSize=*(pnde+1);
  637. //分配信息内存
  638. debuf=(char*)KB_OSPMalloc(nSize);
  639. if(NULL == debuf)
  640. return OSD_RETURN_FAIL;
  641. memset(debuf,0x00,nSize);
  642. //读取信息
  643. ret=KB_DBGetDemandInfo(nSize,(UINT8 *)debuf);
  644. if(ret==RET_FAIL)
  645. {
  646. KB_OSPFree(debuf);
  647. return OSD_RETURN_FAIL;
  648. }
  649. pnde=(int*)(debuf+8);
  650. chlsum=*(pnde++);
  651. for(i=0;i<chlsum;i++)
  652. {
  653. edt=*(pnde++);
  654. pi=*(pnde++);
  655. pp=&EDTLink;
  656. bFind=FALSE;
  657. //添加预约项
  658. //搜索到到指定的频道,如果没有添加指定频道
  659. while(*pp != NULL)
  660. {
  661. if((*pp)->ProgIndex == pi)
  662. {
  663. bFind = TRUE;
  664. break;
  665. }
  666. pp = &((*pp)->next);
  667. }
  668. //没有找到
  669. if(!bFind)
  670. {
  671. //先添加频道
  672. *pp=(EPGDChlLink*)KB_OSPMalloc(sizeof(EPGDChlLink));
  673. if(*pp == NULL)
  674. {
  675. printf("nEPG节目预约内存分配失败!");
  676. KB_OSPFree(debuf);
  677. return OSD_RETURN_FAIL;
  678. }
  679. memset(*pp,0x00,sizeof(EPGDChlLink));
  680. (*pp)->edt=edt;
  681. (*pp)->ProgIndex = pi;
  682. }
  683. npgmsum=*(pnde++);
  684. for(j=0;j<npgmsum;j++)
  685. {
  686. mjd=(USHORT)(*(pnde++)&0xFFFF);
  687. sec=*(pnde++);
  688. dur=*(pnde++);
  689. eventid=(short)(*(pnde++)&0xFFFF);
  690. //搜索到预约节目
  691. bFind=FALSE;
  692. sp=&((*pp)->DmdEnt);
  693. while(*sp != NULL)
  694. {
  695. if((*sp)->mjd == mjd &&(*sp)->seconds == sec&&(*sp)->eventid==eventid)
  696. {
  697. bFind = TRUE;
  698. break;
  699. }
  700. sp = &((*sp)->next);
  701. }
  702. //如果找到，说明已经被添加
  703. if(bFind)
  704. {
  705. continue;
  706. }
  707. //添加预约节目
  708. *sp=(EPGDEntLink*)KB_OSPMalloc(sizeof(EPGDEntLink));
  709. if(*sp == NULL)
  710. {
  711. printf("nEPG节目预约内存分配失败!");
  712. KB_OSPFree(debuf);
  713. return OSD_RETURN_FAIL;
  714. }
  715. memset(*sp,0x00,sizeof(EPGDEntLink));
  716. (*sp)->seconds=sec;
  717. (*sp)->mjd=mjd;
  718. (*sp)->duration=dur;
  719. (*sp)->eventid=eventid;
  720. (*sp)->next=NULL;
  721. }
  722. }
  723. KB_OSPFree(debuf);
  725. return OSD_RETURN_OK;
  726. }
  728. /*=============================================================
  729.  函数名称 : KB_AddDmdEnt
  730.  功    能 : 预约节目
  731.  入    口 : int nChlNo----------频道索引号
  732.   int nent------------事件索引号
  733.   int  nWeekCurTab----预约日期
  734.  出    口 : 无
  735.  返    回 : OSD_RETURN_OK---成功，OSD_RETURN_FAIL---失败
  736. =============================================================*/
  737.  int KB_AddDmdEnt(int nChlNo,int nent,int  nWeekCurTab,int Evntid,int type)
  738. {
  739. EPGDChlLink  **pp=&EDTLink;
  740. EPGDEntLink **sp;
  741. //EPGDEntLink **p1,**p2;
  742. BOOL bFind=FALSE;
  743. time_t cur_seconds,start_time,duration_time;
  744. KB_SIEitSchEvent po;
  745. //U32 year, month, day;
  746. //USHORT po_MJD;
  747. int sum;
  748. //UINT nRet=IDYES;
  749. int nLangType;
  750. //char *pszInfo;
  751. //BOOL displace_order;
  752. KB_EPGDayInfo *dateinfo;
  753. int ncurday=0;
  754. //int nYear, nMonth, nDay;
  755.        KB_NVODStruct       *curNvodNodeHead;
  756.     unsigned long fre, sym;
  757. unsigned char qam;
  758. UINT16 tsid;
  760. nLangType=KB_DBGetLanguageFlag();
  761. KB_TimeGetCurTime(&cur_seconds);
  763. if(type==DT_EPG)
  764. {
  765. KB_DBGetChnlInfoByPrgNO(DTVPRG, nChlNo+1, &fre, &sym, &qam);
  766. KB_DBGetTsIDByFre(&tsid, fre/100000);
  767. dateinfo= KB_EPGGetSchInfo(tsid, KB_DBGetSvcIDByNO(DTVPRG, nChlNo),nWeekCurTab);
  768. po =dateinfo->ptEvent[nent];
  769. start_time=po.start_time;
  770. duration_time=po.duration;
  771. ncurday=nWeekCurTab;
  772. Evntid=nent;
  773. }
  774. if(type==DT_NVOD)
  775. {  
  776. curNvodNodeHead=KB_NVOD_GetTsIndexFromCur(nChlNo);
  777. start_time=curNvodNodeHead->TimeNode[nent].startTime;
  778. duration_time=curNvodNodeHead->durTime;
  779. Evntid=-1;
  780. }
  781. if(type==DT_MANAGE)
  782. {
  783. start_time=nent;
  784. ncurday=nWeekCurTab;
  785. }
  786. //printf("nshengyushijian----%d",cur_seconds - start_time);
  788. //当天当时以后的节目都可以预约
  790.        //printf("n[KB_AddDmdEnt]: cur_seconds=%ld,start_time=%ld,nent=%ld",cur_seconds,start_time,nent);
  791. //cur_seconds-=100000;
  792. if (cur_seconds >= Time_2_Local_Tiem(start_time))
  793. {
  794. #if 0 //在老版本的代码中打开这段代码
  795. pszInfo=KB_GetLanguageInfoStr(nLangType,STR_SYSSETTING);
  796. if(pszInfo != NULL)
  797.     D_OSD_MSGBox("已经过时", MB_OK|MB_ICONINFORMATION, 0,IDOK);
  798. #endif
  799. return OSD_RETURN_FAIL;
  800. }
  801. //在老版本的代码中打开这段代码，用于检测是否有冲突预定节目并判断是否替换
  802. #if 0
  803. //同时播出校验
  804. displace_order=KB_CheckOnlyOne((USHORT)nWeekCurTab,start_time,&nm,&ns);
  805. if (displace_order==TRUE)
  806. {
  807. printf("n有相同，但不替换");
  808. return OSD_RETURN_FAIL;
  809. }
  810. #endif
  812. sum=KB_GetDmdEntCount();
  813. if(sum>=10)
  814. {
  815.        #if 0//在老版本代码中打开
  816. pszInfo=KB_GetLanguageInfoStr(nLangType,STR_SYSSETTING);
  817. if(pszInfo != NULL)
  818. D_OSD_MSGBox("已经满10个", MB_OK, 0,IDOK);
  819. #endif
  820. return OSD_RETURN_FAIL;
  821. }
  822. //添加
  823. while(*pp != NULL)
  824. {
  825. if(type==DT_MANAGE)
  826. type=(*pp)->edt;
  827. if((*pp)->ProgIndex == nChlNo&&(*pp)->edt==type)
  828. {
  829. bFind = TRUE;
  830. //printf("n-----------find the same chl");
  832. break;
  833. }
  834. pp = &((*pp)->next);
  835. }
  836. //没有找到相同的频道
  837. if(!bFind)
  838. {
  839. //先添加频道
  840. *pp=(EPGDChlLink*)KB_OSPMalloc(sizeof(EPGDChlLink));
  841. if(*pp == NULL)
  842. {
  843. printf("nEPG节目预约内存分配失败!");
  844. return OSD_RETURN_FAIL;
  845. }
  846. memset(*pp,0x00,sizeof(EPGDChlLink));
  847. (*pp)->edt=type;
  848. (*pp)->ProgIndex = nChlNo;
  849. //printf("n--------no--find ");
  851. }
  852. sp=&((*pp)->DmdEnt);
  853. //搜索到预约节目的末尾
  854. bFind=FALSE;
  855. while(*sp != NULL)
  856. {
  857. if((*sp)->seconds == start_time)
  858. {
  859. bFind = TRUE;
  860. printf("n---------find event");
  862. break;
  863. }
  864. sp = &((*sp)->next);
  865. }
  866. //如果找到，说明已经被预约
  867. if(bFind)
  868. {
  869. //pszInfo=KB_GetLanguageInfoStr(nLangType,STR_SYSSETTING);
  870. #if 0//在老版本代码中打开
  871. if(pszInfo != NULL)
  872. D_OSD_MSGBox("已经被预约", MB_OK|MB_ICONINFORMATION, 0,IDOK);
  873.               #endif
  874. return OSD_RETURN_FAIL;
  875. }
  876. //添加预约节目
  877. *sp=(EPGDEntLink*)KB_OSPMalloc(sizeof(EPGDEntLink));
  878. if(*sp == NULL)
  879. {
  880. printf("nEPG节目预约内存分配失败!");
  881. return OSD_RETURN_FAIL;
  882. }
  883. memset(*sp,0x00,sizeof(EPGDEntLink));
  884. (*sp)->seconds=start_time;
  885. (*sp)->duration=duration_time;
  886. (*sp)->mjd=(USHORT)ncurday;
  887. (*sp)->eventid=Evntid;
  888. (*sp)->next=NULL;
  890. return OSD_RETURN_OK;
  891. }
  892. /*=============================================================
  893.  函数名称 : KB_DelDmdEnt
  894.  功    能 : 取消预约
  895.  入    口 : int nChlNo----------频道索引号
  896.   int nent-----------事件索引号
  897.    int  nWeekCurTab----预约日期
  899.  出    口 : 无
  900.  返    回 : OSD_RETURN_OK---成功，OSD_RETURN_FAIL---失败
  901. =============================================================*/
  902.  int KB_DelDmdEnt(int nChlNo,int nent,int nWeekCurTab ,int type)
  903. {
  904. EPGDChlLink  *pp=EDTLink,*pq=NULL;
  905. EPGDEntLink *sp,*sq;
  906. BOOL bFind=FALSE;
  907. //int seconds,dtv_type;
  908. KB_EPGDayInfo *dateinfo;
  909. KB_SIEitSchEvent po;
  910. KB_NVODStruct       *curNvodNodeHead;
  911.    time_t cur_seconds,start_time;
  912.    int ncurday,nYear, nMonth, nDay;
  913. unsigned long fre, sym;
  914. unsigned char qam;
  915. UINT16 tsid;   
  916.    
  917. //printf("n-----------------del");
  918. if(type==DT_EPG)
  919. {
  920. KB_DBGetChnlInfoByPrgNO(DTVPRG, nChlNo+1, &fre, &sym, &qam);
  921. KB_DBGetTsIDByFre(&tsid, fre/100000);
  922. dateinfo= KB_EPGGetSchInfo(tsid, KB_DBGetSvcIDByNO(DTVPRG, nChlNo),nWeekCurTab);
  923. po =dateinfo->ptEvent[nent];
  924. ncurday=nWeekCurTab;
  925. start_time=po.start_time;
  926. }
  927. if(type==DT_NVOD)
  928. {
  929. KB_TimeGetCurTime(&cur_seconds);
  930. ncurday=ConvertTimeStampToDate((U32)cur_seconds, (U32 *)&nYear, (U32 *)&nMonth, (U32 *)&nDay);
  932. curNvodNodeHead=KB_NVOD_GetTsIndexFromCur(nChlNo);
  933. start_time=curNvodNodeHead->TimeNode[nent].startTime;
  934. }
  935. if(type==DT_MANAGE)
  936. {
  937. ncurday=nWeekCurTab;
  938. start_time=nent;
  939. }
  941. //搜查指定频道,如果指定频道没有预定节目，清除此频道
  942. while(pp != NULL)
  943. {
  944. if(type==DT_MANAGE)
  945.         type=pp->edt;
  946. if(pp->ProgIndex ==nChlNo&&pp->edt==type)
  947. {
  948. bFind=TRUE;
  949. break;
  950. }
  951. pq=pp;
  952. pp =pp->next;
  953. }
  954. //没有找到,并且是第一个节点，而且还是没有节目
  955. //删除它
  956. if(!bFind)
  957. {
  958. if(pq == NULL && pp->DmdEnt==NULL)
  959. {
  960. EDTLink=EDTLink->next;
  961. KB_OSPFree(pp);
  962. }
  963. return OSD_RETURN_OK;
  964. }
  965. sp=pp->DmdEnt;
  966. sq =NULL;
  967. bFind=FALSE;
  968. //搜索指定的预约节目
  969. while(sp != NULL)
  970. {
  971. if(sp->mjd== ncurday && sp->seconds==start_time)
  972. {
  973. bFind=TRUE;
  974. break;
  975. }
  976. sq =sp;
  977. sp=sp->next;
  978. }
  979. //找到,释放,如果频道没有预约节目，释放频道
  980. if(bFind)
  981. {
  982. if(sq == NULL)
  983. pp->DmdEnt=pp->DmdEnt->next;
  984. else
  985. sq->next=sp->next;
  986. KB_OSPFree(sp);
  987. if(pp->DmdEnt == NULL)
  988. {
  989. if(pq==NULL)
  990. EDTLink=EDTLink->next;
  991. else
  992. pq->next=pp->next;
  993. KB_OSPFree(pp);
  994. }
  995. }
  997. return OSD_RETURN_OK;
  998. }
  1000. /*=============================================================
  1001.  函数名称 : KB_CheckDmdEnt
  1002.  功    能 : 预约校验,检查该事件是否预约
  1003.  入    口 : int nChlNo----------频道索引号
  1004.   int nent-----------事件索引号
  1005.    int  nWeekCurTab----预约日期//NVOD时无效
  1006. int type---------------类别
  1007.  出    口 : 无
  1008.  返    回 : TRUE---预约，FALSE---没有预约
  1009. =============================================================*/
  1010.  BOOL KB_CheckDmdEnt(int nChlNo,int nent,int  nWeekCurTab,int type)
  1011. {
  1012. EPGDChlLink  *pp=EDTLink;
  1013. EPGDEntLink *sp;
  1014. BOOL bFind=FALSE;
  1015. int seconds;
  1016. KB_EPGDayInfo *dateinfo;
  1017. KB_SIEitSchEvent po;
  1018. KB_NVODStruct       *curNvodNodeHead;
  1019.    time_t cur_seconds;
  1020.    int ncurday,nYear, nMonth, nDay;
  1021. unsigned long fre, sym;
  1022. unsigned char qam;
  1023. UINT16 tsid;
  1024.    
  1025. if(type==DT_EPG)
  1026. {
  1027. KB_DBGetChnlInfoByPrgNO(DTVPRG, nChlNo+1, &fre, &sym, &qam);
  1028. KB_DBGetTsIDByFre(&tsid, fre/100000);
  1029. dateinfo= KB_EPGGetSchInfo(tsid, KB_DBGetSvcIDByNO(DTVPRG, nChlNo),nWeekCurTab);
  1030. po =dateinfo->ptEvent[nent];
  1031. ncurday=nWeekCurTab;
  1032. seconds=(int)po.start_time;
  1033. }
  1034. if(type==DT_NVOD)
  1035.   {
  1036. KB_TimeGetCurTime(&cur_seconds);
  1037. ncurday=ConvertTimeStampToDate((U32)cur_seconds, (U32 *)&nYear, (U32 *)&nMonth, (U32 *)&nDay);
  1038. curNvodNodeHead=KB_NVOD_GetTsIndexFromCur(nChlNo);
  1039. seconds = (int)curNvodNodeHead->TimeNode[nent].startTime;
  1040.   }
  1041.   if(type==DT_MANAGE)
  1042.   {
  1043.   seconds=nent;
  1044.   ncurday=nWeekCurTab;
  1045.   }
  1046. //搜查指定频道,如果指定频道没有预定节目，清除此频道
  1047. while(pp != NULL)
  1048. {
  1049. if(type==DT_MANAGE)
  1050. type=pp->edt;
  1052. if(pp->ProgIndex == nChlNo&&pp->edt==type)
  1053. {
  1054. bFind=TRUE;
  1055. break;
  1056. }
  1057. pp =pp->next;
  1058. }
  1059. //没有找到,返回
  1060. if(!bFind)
  1061. return FALSE;
  1062. //搜索指定的预约节目
  1063. sp=pp->DmdEnt;
  1064. while(sp != NULL)
  1065. {
  1066. if(sp->mjd==ncurday && sp->seconds == seconds)
  1067. {
  1068. return TRUE;
  1069. }
  1070. sp=sp->next;
  1071. }
  1073. return FALSE;
  1074. }
  1076. //added by whale 07/06/08 start
  1077. /*=============================================================
  1078.  函数名称 : KB_CreatDmdDataLink
  1079.  功    能 : 预约管理列表内容初始化
  1080.  入    口 : BOOL bOnTime------显示标志(TRUE:所有预约到时节目,FALSE:所有预约节目)
  1081.   BOOL bNoList------没有列表显示
  1082.  出    口 : 无
  1083.  返    回 : OSD_RETURN_OK---成功，OSD_RETURN_FAIL---失败
  1084. =============================================================*/
  1085. int KB_CreatDmdDataLink(void)
  1086. {
  1087. time_t cur_seconds;
  1088. int nYear, nMonth, nDay,nHour,nMinute,nSec;
  1089. EPGDChlLink  *pq=EDTLink;
  1090. EPGDEntLink *sq;
  1091. //int nRet,si=0;
  1092. char strname[50],*pszName;
  1093. U32 nLocalTime;
  1094. KB_EPGDayInfo * pEPGInfo;
  1095. KB_SIEitSchEvent po;
  1096. KB_NVODStruct *curNvodNodeHead;
  1097. int nLangType;
  1098. int i=0,sCurWeekDay=0;
  1099. //added by yyj 2007.6.11
  1100.        EPGDDataLink demanddata;
  1101. unsigned long fre, sym;
  1102. unsigned char qam;
  1103. UINT16 tsid;
  1105. nLangType=KB_DBGetLanguageFlag();
  1106. //先获取当前时间
  1107. KB_TimeGetCurTime(&cur_seconds);
  1108. //printf("n[KB_CreatDmdDataLink]:cur_seconds=%ld",cur_seconds);
  1109. sCurWeekDay=ConvertTimeStampToDate((U32)cur_seconds, (U32 *)&nYear, (U32 *)&nMonth, (U32 *)&nDay);
  1110.       // printf("n[KB_CreatDmdDataLink]:sCurWeekDay=%d",sCurWeekDay);
  1111. KB_ClearDataLink();
  1113. while(pq != NULL)
  1114. {
  1115. sq=pq->DmdEnt;
  1116. if(pq->edt == DT_EPG)
  1117. {
  1118. //pEPGInfo =KB_EPGGetSchInfo(KB_DBGetSvcIDByNO(DTVPRG, pq->ProgIndex), pq->DmdEnt->mjd);
  1119. KB_DBGetChnlInfoByPrgNO(DTVPRG, pq->ProgIndex+1, &fre, &sym, &qam);
  1120. KB_DBGetTsIDByFre(&tsid, fre/100000);
  1121. pEPGInfo=KB_EPGGetSchInfo(tsid, KB_DBGetSvcIDByNO(DTVPRG, pq->ProgIndex),pq->DmdEnt->mjd);
  1123. }
  1124. else
  1125. {   
  1126. curNvodNodeHead=KB_NVOD_GetTsIndexFromCur(pq->ProgIndex);
  1127. }
  1129. while(sq != NULL)
  1130. {
  1131. if(pq->edt == DT_EPG)
  1132. {
  1133. po=pEPGInfo->ptEvent[sq->eventid];
  1134. }
  1137. {
  1138. //设置0单元频道名称
  1139. if(pq->edt == DT_EPG)
  1140. {
  1141. if(pq->ProgIndex<0)
  1142. ;
  1143. else
  1144. {
  1145. pszName=(char *)KB_DBGetPrgName(DTVPRG,pq->ProgIndex+1);
  1146. memset(strname,0x00,50);
  1147. sprintf(strname,"%02d%s",++i,pszName);
  1148. if(strname!=NULL)
  1149. printf("-=频道名称:%s=-n", strname);
  1150.                             strcpy(demanddata.chlname, strname);
  1151.       /*
  1152.      if(strname!=NULL)
  1153.             nRet= AddListViewItem(&hEDHFlv,demanddata.chlname);
  1154.      if(-1 == nRet)
  1155.     {
  1156.    printf("n添加预约节目列表项0失败!");
  1157.    return OSD_RETURN_FAIL;
  1158.     }
  1159.     */
  1161. }
  1162. }
  1163. else
  1164. {
  1165. memset(strname,0x00,50);
  1166. sprintf(strname,"%02d%s",++i,"NVOD");
  1167. printf("-=频道名称:%s=-n", strname);
  1168. strcpy(demanddata.chlname, strname);
  1169. /*
  1170. nRet= AddListViewItem(&hEDHFlv,strname);
  1171.                              if(-1 == nRet)
  1172.  {
  1173.    printf("n添加预约节目列表项0失败!");
  1174.    return OSD_RETURN_FAIL;
  1175.  }
  1176.  */
  1177. }
  1179. nLocalTime = (U32)Time_2_Local_Tiem(sq->seconds);
  1180. //printf("n[KB_CreatDmdDataLink]:nLocalTime=%ld,sq->seconds=%ld",nLocalTime,sq->seconds);
  1182. //节目播放日期
  1183. ConvertTimeStampToDate(nLocalTime, (U32 *)&nYear, (U32 *)&nMonth, (U32 *)&nDay);
  1184. memset(demanddata.date,0x00,20);
  1185.          sprintf(demanddata.date,"%04d-%02d-%02d",nYear, nMonth, nDay);
  1186. printf("n[KB_CreatDmdDataLink]:date=%sn",demanddata.date);  
  1188. //节目播放时间
  1189. ConvertTimeStampToTime(nLocalTime,( U32 * )&nHour, (U32 *)&nMinute, (U32 *)&nSec);
  1190. memset(demanddata.time,0x00,20);
  1191. sprintf(demanddata.time,"%02d:%02d",nHour, nMinute);
  1192. printf("n[KB_CreatDmdDataLink]:time=%sn",demanddata.time);
  1193. //memset(str,0x00,50);
  1194. //sprintf(str,"%04ld-%02ld-%02ld %02d:%02d",nYear,nMonth,nDay,nHour,nMinute);
  1197. /*
  1198. //设置1单元节目播放时间
  1199. sprintf(str,"%s %s",demanddata.date,demanddata.time);
  1200. printf("n[KB_CreatDmdDataLink]:str=%s",str);
  1201. if(strlen(str)<=0)
  1202. nRet = SetLVItemText(&hEDHFlv,nRet,1,"---");
  1203. else
  1204. nRet = SetLVItemText(&hEDHFlv,nRet,1,str);
  1205. if(-1 == nRet)
  1206. {
  1207. printf("n添加预约节目列表项1失败!");
  1208. return OSD_RETURN_FAIL;
  1209. }
  1210. */
  1212.        //设置2单元频道名称
  1213. if(pq->edt == DT_EPG)
  1214. {
  1215. memset(strname,0x00,50);
  1216. sprintf(strname,"%s",(char*)po.chinese.event_name);
  1217. if(strlen((char*)po.chinese.event_name)>0)
  1218. printf("-=epg节目名称:%s=-n", strname);
  1219. strcpy(demanddata.prgname, strname);
  1220. /*
  1221. if(strlen((char*)po.chinese.event_name)>0)
  1222.            nRet= SetLVItemText(&hEDHFlv,nRet,2,demanddata.prgname);
  1223.        else
  1224.            nRet= SetLVItemText(&hEDHFlv,nRet,2,"- - -");
  1225.                      if(-1 == nRet)
  1226.        {
  1227.    printf("n添加预约节目列表项2失败!");
  1228.    return OSD_RETURN_FAIL;
  1229. }
  1230. */
  1231. }
  1232. else
  1233. {
  1234. memset(strname,0x00,50);
  1235. sprintf(strname,"%s",(char*)curNvodNodeHead->PrgName);
  1236. if(strlen((char*)curNvodNodeHead->PrgName)>0)
  1237. printf("-=nvod节目名称:%s=-n", strname);
  1238. strcpy(demanddata.prgname, strname);
  1239. /*
  1240.        if(strlen((char*)curNvodNodeHead.PrgName)>0)
  1241.            nRet= SetLVItemText(&hEDHFlv,nRet,2,demanddata.prgname);
  1242.        else
  1243.            nRet= SetLVItemText(&hEDHFlv,nRet,2,"- - -");
  1244.                      if(-1 == nRet)
  1245.        {
  1246.    printf("n添加预约节目列表项2失败!");
  1247.    return OSD_RETURN_FAIL;
  1248. }
  1249. */
  1250. }
  1252.               #if 0
  1253. if(!KB_AddDataLink(pq->ProgIndex,sq->eventid, sq->mjd,sq->seconds,sq->duration,pq->edt))
  1254. continue;
  1255. #else
  1256.        if(!KB_AddDataLink(&demanddata))
  1257. continue;
  1258. #endif
  1259. }
  1260. sq=sq->next;
  1261. }
  1262. pq=pq->next;
  1263. }
  1264. return OSD_RETURN_OK;
  1265. }
  1266. //added by whale 07/06/08 end
  1268. //added by yyj 2007.7.3 start
  1269. /*=============================================================
  1270.  函数名称 : KB_ClearAllDmdEnt
  1271.  功    能 : 清除预约链表中的所有节目
  1272.  入    口 : 无
  1273.  出    口 : 无
  1274.  返    回 : 无
  1275. =============================================================*/
  1276. void KB_ClearAllDmdEnt(void)
  1277. {
  1278. EPGDChlLink  *pp=EDTLink,*pq=NULL;
  1280. while(pp != NULL)
  1281. {
  1282.     pq = pp->next;
  1283.     while(pp->DmdEnt!=NULL)
  1284.     {
  1285.          pq->DmdEnt = pp->DmdEnt->next;
  1286.          KB_OSPFree(pp->DmdEnt);
  1287.   pp->DmdEnt = pq->DmdEnt;
  1288.     }
  1289.     KB_OSPFree(pp);
  1290.     pp = pq;
  1291. }
  1293.        EDTLink = NULL;
  1294. }
  1296. //added by yyj 2007.7.3 end
  1298. //added by yyj 2007.7.4 start
  1299. /*=============================================================
  1300.  函数名称 : KB_CheckConfilictDmdEnt
  1301.  功    能 : 检测预约节目是否同时播出
  1302.  入    口 : USHORT mjg-----------节目播出日期
  1303.   int nChlNo----------节目频道号
  1304.   int nent-------------事件索引号
  1305.   int type------------节目类型
  1306.  出    口 : int * nManiIdx------ 频道索引
  1307.   int* nSubIdx ------- 节目索引
  1308.  返    回 : DEMAND_PGM_OVERTIME----预约节目过时
  1309.                    DEMAND_PGM_CONFLICT----有冲突的预定节目
  1310.                    DEMAND_PGM_NO_CONFLICT----没有冲突的预定节目
  1311. =============================================================*/
  1312. BOOL KB_CheckConfilictDmdEnt(USHORT mjg,int nChlNo,int nent,int * nManiIdx,int* nSubIdx,int type)
  1313. {
  1314. EPGDChlLink  *pp=EDTLink;
  1315. EPGDEntLink *sp;
  1316. register int nm=0,ns;
  1317. //char *pszInfo;
  1318. int nLangType;
  1319. time_t cur_seconds,start_time,duration_time;
  1320. KB_EPGDayInfo *dateinfo;
  1321. KB_SIEitSchEvent po;
  1322. int ncurday=0;
  1323. KB_NVODStruct       *curNvodNodeHead;
  1324. unsigned long fre, sym;
  1325. unsigned char qam;
  1326. UINT16 tsid;
  1327. //UINT8 sum;
  1329. nLangType=KB_DBGetLanguageFlag();
  1330. KB_TimeGetCurTime(&cur_seconds);
  1332. if(type==DT_EPG)
  1333. {
  1334.        KB_DBGetChnlInfoByPrgNO(DTVPRG, nChlNo+1, &fre, &sym, &qam);
  1335. KB_DBGetTsIDByFre(&tsid, fre/100000);
  1336. dateinfo= KB_EPGGetSchInfo(tsid, KB_DBGetSvcIDByNO(DTVPRG, nChlNo),mjg);
  1337. po =dateinfo->ptEvent[nent];
  1338. start_time=po.start_time;
  1339. duration_time=po.duration;
  1340. ncurday=mjg;
  1341. //Evntid=nent;
  1342. }
  1343. if(type==DT_NVOD)
  1344. {  
  1345. curNvodNodeHead=KB_NVOD_GetTsIndexFromCur(nChlNo);
  1346. start_time=curNvodNodeHead->TimeNode[nent].startTime;
  1347. duration_time=curNvodNodeHead->durTime;
  1348. //Evntid=-1;
  1349. }
  1350. if(type==DT_MANAGE)
  1351. {
  1352. start_time=nent;
  1353. ncurday=mjg;
  1354. }
  1355.    
  1356. if (cur_seconds >= Time_2_Local_Tiem(start_time))
  1357. {
  1358.        printf("n预定节目过时!");
  1359. return DEMAND_PGM_OVERTIME;
  1360. }
  1362. //搜索同日期同时播出的节目
  1363. while(pp != NULL)
  1364. {
  1365. sp=pp->DmdEnt;
  1366. ns=0;
  1367. while(sp != NULL)
  1368. {
  1369. if((sp->mjd == mjg )&&(sp->seconds == start_time))
  1370. {
  1371. *nManiIdx=nm;
  1372. *nSubIdx=ns;
  1374.  return DEMAND_PGM_CONFLICT;//有冲突的预定节目
  1375. }
  1376. ns++;
  1377. sp = sp->next;
  1378. }
  1379. nm++;
  1380. pp = pp->next;
  1381. }
  1382. //没有找到
  1383. *nManiIdx=-1;
  1384. *nSubIdx=-1;
  1385. return DEMAND_PGM_NO_CONFLICT;//没有冲突的预定节目
  1386. }
  1388. /*=============================================================
  1389.  函数名称 : KB_DelConfilictDmdEnt
  1390.  功    能 : 删除同时播出的预约节目
  1391.  入    口 : USHORT mjg-----------节目播出日期
  1392.   int nChlNo----------节目频道号
  1393.   int nent-------------事件索引号
  1394.   int type------------节目类型
  1395.  出    口 : int * nManiIdx------ 频道索引
  1396.   int* nSubIdx ------- 节目索引
  1397.  返    回 : TRUE---成功(删除冲突的预约节目)，FALSE---失败(没有冲突节目)
  1398. =============================================================*/
  1399. BOOL KB_DelConfilictDmdEnt(USHORT mjg,int nChlNo,int nent,int * nManiIdx,int* nSubIdx,int type)
  1400. {
  1401. EPGDChlLink  *pp=EDTLink;
  1402. EPGDEntLink *sp;
  1403. EPGDEntLink *p1,*p2;
  1404. register int nm=0,ns;
  1405. //char *pszInfo;
  1406. int nLangType;
  1407. time_t cur_seconds,start_time,duration_time;
  1408. KB_EPGDayInfo *dateinfo;
  1409. KB_SIEitSchEvent po;
  1410. int ncurday=0;
  1411. KB_NVODStruct       *curNvodNodeHead;
  1412. unsigned long fre, sym;
  1413. unsigned char qam;
  1414. UINT16 tsid;
  1416. nLangType=KB_DBGetLanguageFlag();
  1417. KB_TimeGetCurTime(&cur_seconds);
  1419. if(type==DT_EPG)
  1420. {
  1421.        KB_DBGetChnlInfoByPrgNO(DTVPRG, nChlNo+1, &fre, &sym, &qam);
  1422. KB_DBGetTsIDByFre(&tsid, fre/100000);
  1423. dateinfo= KB_EPGGetSchInfo(tsid, KB_DBGetSvcIDByNO(DTVPRG, nChlNo),mjg);
  1424. po =dateinfo->ptEvent[nent];
  1425. start_time=po.start_time;
  1426. duration_time=po.duration;
  1427. ncurday=mjg;
  1428. //Evntid=nent;
  1429. }
  1430. if(type==DT_NVOD)
  1431. {  
  1432. curNvodNodeHead=KB_NVOD_GetTsIndexFromCur(nChlNo);
  1433. start_time=curNvodNodeHead->TimeNode[nent].startTime;
  1434. duration_time=curNvodNodeHead->durTime;
  1435. //Evntid=-1;
  1436. }
  1437. if(type==DT_MANAGE)
  1438. {
  1439. start_time=nent;
  1440. ncurday=mjg;
  1441. }
  1443. while(pp != NULL)
  1444. {
  1445. sp=pp->DmdEnt;
  1446. ns=0;
  1447. p1=sp;
  1448. while(sp != NULL)
  1449. {
  1450. if((sp->mjd == mjg )&&(sp->seconds == start_time))
  1451. {
  1452. *nManiIdx=nm;
  1453. *nSubIdx=ns;
  1454. //删除冲突节目
  1455. if(sp==pp->DmdEnt)
  1456. {
  1457.      pp->DmdEnt=sp->next;
  1458. }
  1459. else
  1460. {
  1461.      p2->next=p1->next;
  1462. }
  1463. KB_OSPFree(sp);
  1464. return TRUE;//删除冲突节目
  1465. }
  1466. ns++;
  1467. sp = sp->next;
  1468. if(p1->next!=NULL)
  1469. {
  1470. p2=p1;
  1471. p1=p1->next;
  1472. }
  1473. }
  1474. nm++;
  1475. pp = pp->next;
  1476. }
  1477. //没有找到
  1478. *nManiIdx=-1;
  1479. *nSubIdx=-1;
  1480. return FALSE;//无相同
  1481. }
  1483. //added by yyj 2007.7.4 end