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

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

DVD

开发平台：

C/C++

kb_machblue_client_data.c：源码内容
  1. /*---------------------------------------------------------------------------
  2.  *  mbtv_customer_struct_managemment.c
  3.  *
  4.  *--------------------------------------------------------------------------*/
  7. #include "db.h"
  8. #include "epg.h"
  9. #include "sipsi.h"
  10. #include "timeclk.h"
  11. #include "machblue_defines.h"
  12. #include "machblue_customer.h"
  13. #include "machblue_tv_defines.h"
  14. #include "machblue_tv_customer.h"
  15. #include "machblue_porting_core.h"
  16. #include "kb_machblue_client_data.h"
  17. #include "kb_machblue_client_define.h"
  18. #include "machblue_tv_porting.h"
  19. #include "appltype.h"
  20. #include "Demand.h"
  21. #include "sr_time.h"
  24. extern UINT16 KB_DBGetSvcIDByNO(UINT8 prgType, UINT16 prgInx);
  27. kb_movie_serviceList_t _kb_mb_serviceList[list_last];
  28. kb_movie_serviceContext_t _kb_mb_serviceContext;
  29. static kb_movie_stream_t _kb_mb_serviceStream;
  31. static unsigned long  _kb_mb_service_id=0;
  32. static unsigned long _kb_mb_radio_service_id = 0;
  33. static unsigned long _kb_mb_NVOD_service_id = 0;
  34. static unsigned long  _kb_mb_event_id=0;
  36. static mb_tv_notify_f  *_kb_mb_tvNotifyFun=NULL;
  37. static void  *_kb_mb_tvClientData=NULL;
  39. static mb_error_t kb_machblue_service_list_all_tv_init(void);
  40. static mb_error_t kb_machblue_service_list_radio_init(void);
  41. //void kb_machblue_search_schedule(void);
  42. extern int KB_TimeGetCurTime(time_t  *plTime);
  46. unsigned short getServiceIndex(unsigned short serviceID)
  47. {
  48. unsigned short index, videoCnt;
  49. videoCnt=(unsigned short )_kb_mb_serviceList[all_tv_list].count;
  50. for(index=0;index<videoCnt;index++)
  51. {
  53. if(_kb_mb_serviceList[all_tv_list].services[index].info.display_id==serviceID)
  54. break;
  55. }
  56. return index;
  57. }
  61. /**
  62. *This function initialize the present and the following event
  63. *@return MB_SUCCESS on success, MB_FAILURE on failure.
  64. */
  65. mb_error_t KB_mb_PF_Update(KB_SIEitPF *Cur_ptEitPf,KB_SIEitPF *Fol_ptEitPf)
  66. {
  67. _kb_mb_serviceList[all_tv_list].services[getServiceIndex(Cur_ptEitPf->service_id)].current_event.attributes.start_time = Cur_ptEitPf->start_time;
  68. _kb_mb_serviceList[all_tv_list].services[getServiceIndex(Cur_ptEitPf->service_id)].current_event.attributes.event_info.duration= Cur_ptEitPf->duration;
  69. _kb_mb_serviceList[all_tv_list].services[getServiceIndex(Cur_ptEitPf->service_id)].current_event.attributes.event_info.id= Cur_ptEitPf->event_id;
  70. mb_memcpy(_kb_mb_serviceList[all_tv_list].services[getServiceIndex(Cur_ptEitPf->service_id)].current_event.attributes.event_info.name,Cur_ptEitPf->chinese.event_name,51);
  71. mb_memcpy(_kb_mb_serviceList[all_tv_list].services[getServiceIndex(Cur_ptEitPf->service_id)].current_event.attributes.event_info.short_desc,Cur_ptEitPf->chinese.text,128);
  72. _kb_mb_serviceList[all_tv_list].services[getServiceIndex(Cur_ptEitPf->service_id)].current_event.service=&_kb_mb_serviceList[all_tv_list].services[getServiceIndex(Cur_ptEitPf->service_id)];
  74. _kb_mb_serviceList[all_tv_list].services[getServiceIndex(Fol_ptEitPf->service_id)].following_event.attributes.start_time = Fol_ptEitPf->start_time;
  75. _kb_mb_serviceList[all_tv_list].services[getServiceIndex(Fol_ptEitPf->service_id)].following_event.attributes.event_info.duration= Fol_ptEitPf->duration;
  76. _kb_mb_serviceList[all_tv_list].services[getServiceIndex(Fol_ptEitPf->service_id)].following_event.attributes.event_info.id= Fol_ptEitPf->event_id;
  77. mb_memcpy(_kb_mb_serviceList[all_tv_list].services[getServiceIndex(Fol_ptEitPf->service_id)].following_event.attributes.event_info.name,Fol_ptEitPf->chinese.event_name,51);
  78. mb_memcpy(_kb_mb_serviceList[all_tv_list].services[getServiceIndex(Fol_ptEitPf->service_id)].following_event.attributes.event_info.short_desc,Fol_ptEitPf->chinese.text,128);   
  79. _kb_mb_serviceList[all_tv_list].services[getServiceIndex(Fol_ptEitPf->service_id)].following_event.service= &_kb_mb_serviceList[all_tv_list].services[getServiceIndex(Fol_ptEitPf->service_id)];
  81. //KB_MB_lc_2_movie_Post_Task();
  82. KB_MB_lc_2_movie_word_Post_Task(1);
  83. return MB_SUCCESS;
  84. }
  86. /**
  87.  * This function init the service list information. 
  88.  * @return MB_SUCCESS on success, MB_FAILURE on failure.
  89.  */
  90. mb_error_t kb_mb_service_list_init(void)
  91. {
  92. kb_machblue_service_list_all_tv_init();
  93. kb_machblue_service_list_radio_init();
  94. return MB_SUCCESS;
  95. }
  98. mb_error_t kb_mb_schdule_clear(kb_movie_service_t *service)
  99. {
  100. unsigned char index;
  102. for(index=0;index<7;index++)
  103. {
  104. mb_free(service->evs[index].events);
  105. service->evs[index].evtCount=0;
  106. }
  108. return MB_SUCCESS;
  109. }
  112. mb_error_t kb_mb_service_list_clear(void)
  113. {
  114. unsigned short index;
  116. _kb_mb_service_id=0;
  117. _kb_mb_event_id=0;
  119. //clear
  120. for(index=0;index<_kb_mb_serviceList[all_tv_list].count;index++)
  121. {
  122. kb_mb_schdule_clear(&(_kb_mb_serviceList[all_tv_list].services[index]));
  123. mb_memset(&(_kb_mb_serviceList[all_tv_list].services[index]),0,sizeof(kb_movie_service_t));
  124. }
  125. mb_free(_kb_mb_serviceList[all_tv_list].services);
  126. mb_memset(&(_kb_mb_serviceList[all_tv_list]),0,sizeof(kb_movie_serviceList_t));
  128. for(index=0;index<_kb_mb_serviceList[radio_list].count;index++)
  129. {
  130. kb_mb_schdule_clear(&(_kb_mb_serviceList[radio_list].services[index]));
  131. mb_memset(&(_kb_mb_serviceList[radio_list].services[index]),0,sizeof(kb_movie_service_t));
  132. }
  133. mb_free(_kb_mb_serviceList[radio_list].services);
  134. mb_memset(&(_kb_mb_serviceList[radio_list]),0,sizeof(kb_movie_serviceList_t));
  136. return MB_SUCCESS;
  137. }
  140. mb_error_t kb_mb_service_list_reset(void)
  141. {
  142. //clear
  143. kb_mb_service_list_clear();
  145. //add
  146. kb_mb_service_list_init();
  148. //search
  149. //kb_machblue_search_schedule();
  150. return MB_SUCCESS;
  151. }
  152. mb_error_t kb_mb_service_list_resetEx(void)
  153. {
  154. //clear
  155. kb_mb_service_list_clear();
  157. //add
  158. kb_mb_service_list_init();
  160. kb_mb_chledit_list_reset();
  161. return MB_SUCCESS;
  162. }
  164. mb_error_t kb_mb_event_schedule_reset(void)
  165. {
  166. unsigned short index;
  168. //clear
  169. for(index=0;index<_kb_mb_serviceList[all_tv_list].count;index++)
  170. {
  171. kb_mb_schdule_clear(&(_kb_mb_serviceList[all_tv_list].services[index]));
  172. }
  174. for(index=0;index<_kb_mb_serviceList[radio_list].count;index++)
  175. {
  176. kb_mb_schdule_clear(&(_kb_mb_serviceList[radio_list].services[index]));
  177. }
  179. //search
  180. //kb_machblue_search_schedule();
  182. return MB_SUCCESS;
  183. }
  186. static mb_error_t kb_machblue_service_list_all_tv_init(void)
  187. {
  188. unsigned short videoCnt=0,index;
  189. UINT16 service_ID;
  190. unsigned char *service_name;
  193. _kb_mb_serviceList[all_tv_list].info.id=0;
  194. mb_memcpy(_kb_mb_serviceList[all_tv_list].info.name,"All Service",11);
  195. mb_memcpy(_kb_mb_serviceList[all_tv_list].info.logo_url," ",1);
  196. mb_memcpy(_kb_mb_serviceList[all_tv_list].info.extra_info," ",1);
  198. _kb_mb_serviceList[all_tv_list].services=NULL;
  199. _kb_mb_serviceList[all_tv_list].count=0;
  200. //_kb_mb_serviceList[all_tv_list].svl_manager=NULL;
  203. videoCnt=KB_DBGetPrgTotal(DTVPRG);
  205. if(videoCnt==0)
  206. return MB_SUCCESS;
  209. //malloc service memory
  210. _kb_mb_serviceList[all_tv_list].services=mb_malloc(sizeof(kb_movie_service_t)*videoCnt);
  211. if(_kb_mb_serviceList[all_tv_list].services==NULL)
  212. {
  213. mb_printf("n[Machblue]:Service list 1 init no memory.");
  214.        return MB_FAILURE;
  215. }
  216. mb_memset(_kb_mb_serviceList[all_tv_list].services,0,sizeof(kb_movie_service_t)*videoCnt);
  218. //insert video service
  219. for(index=0;index<videoCnt;index++)
  220. {
  221. //service info
  222. service_ID = KB_DBGetSvcIDByNO(DTVPRG, index);
  223. service_name = KB_DBGetPrgName(DTVPRG,index+1);
  224. _kb_mb_serviceList[all_tv_list].services[index].info.id=(int)_kb_mb_service_id++;
  225. _kb_mb_serviceList[all_tv_list].services[index].info.display_id=service_ID;//gPrgAllInfo.gDTVInfo.PgmList[index].SvcID;
  226. mb_memcpy(_kb_mb_serviceList[all_tv_list].services[index].info.name,service_name,MB_TV_SERVICE_NAME_LENGTH);
  227. _kb_mb_serviceList[all_tv_list].services[index].info.name[15]='';
  228. mb_memcpy(_kb_mb_serviceList[all_tv_list].services[index].info.logo_url,"0000 ",5);
  229. //mb_memcpy(_kb_mb_serviceList[all_tv_list].services[index].info.name[15],"",1);
  230. //mb_printf("nProgram [%d] name is [%s]",index+1,_kb_mb_serviceList[all_tv_list].services[index].info.name);
  231. _kb_mb_serviceList[all_tv_list].services[index].info.type=MB_TV_DIGITAL_SERVICE;
  233.    _kb_mb_serviceList[all_tv_list].services[index].info.source_info.id=0;
  234. _kb_mb_serviceList[all_tv_list].services[index].info.source_info.type=MB_TV_CABLE_SOURCE;
  237. //service state
  238. _kb_mb_serviceList[all_tv_list].services[index].state=MB_TV_SERVICE_DISCONNECTED;
  240. //authorization
  241. _kb_mb_serviceList[all_tv_list].services[index].auth=MB_TV_AF_AUTHORIZED;
  243. //
  244. _kb_mb_serviceList[all_tv_list].services[index].serInfo.tsID=KB_DBGetPrgTsID(DTVPRG,index+1);
  246. //event
  247. mb_memset(&(_kb_mb_serviceList[all_tv_list].services[index].evs),0,sizeof(kb_movie_eventSchedule_t));
  248. mb_memset(&(_kb_mb_serviceList[all_tv_list].services[index].current_event),0,sizeof(kb_movie_event_t));
  249. mb_memset(&(_kb_mb_serviceList[all_tv_list].services[index].following_event),0,sizeof(kb_movie_event_t));
  251. //pointer
  252. _kb_mb_serviceList[all_tv_list].services[index].svl=&_kb_mb_serviceList[all_tv_list];
  253. _kb_mb_serviceList[all_tv_list].services[index].svc=&_kb_mb_serviceContext;
  254. _kb_mb_serviceList[all_tv_list].services[index].streams=&_kb_mb_serviceStream;
  256. _kb_mb_serviceList[all_tv_list].services[index].current_event.service=&_kb_mb_serviceList[all_tv_list].services[index];
  257. _kb_mb_serviceList[all_tv_list].services[index].current_event.evs=&_kb_mb_serviceList[all_tv_list].services[index].evs[0];
  258. _kb_mb_serviceList[all_tv_list].services[index].following_event.service=&_kb_mb_serviceList[all_tv_list].services[index];
  259. _kb_mb_serviceList[all_tv_list].services[index].following_event.evs=&_kb_mb_serviceList[all_tv_list].services[index].evs[0];
  261. //service count
  262. _kb_mb_serviceList[all_tv_list].count+=1;
  263.      }
  265. return MB_SUCCESS;
  266. }
  267. static mb_error_t kb_machblue_service_list_radio_init(void)
  268. {
  269. unsigned short audioCnt=0,index;
  270. UINT16 service_ID;
  271. unsigned char *service_name;
  274. _kb_mb_serviceList[radio_list].info.id=1;
  275. mb_memcpy(_kb_mb_serviceList[radio_list].info.name,"Radio Service",13);
  276. mb_memcpy(_kb_mb_serviceList[radio_list].info.logo_url," ",1);
  277. mb_memcpy(_kb_mb_serviceList[radio_list].info.extra_info," ",1);
  279. _kb_mb_serviceList[radio_list].services=NULL;
  280. _kb_mb_serviceList[radio_list].count=0;
  281. //_kb_mb_serviceList[all_tv_list].svl_manager=NULL;
  284. audioCnt=KB_DBGetPrgTotal(RADIOPRG);
  286. if(audioCnt==0)
  287. return MB_SUCCESS;
  289. //malloc service memory
  290. _kb_mb_serviceList[radio_list].services=mb_malloc(sizeof(kb_movie_service_t)*audioCnt);
  291. if(_kb_mb_serviceList[radio_list].services==NULL)
  292. {
  293. mb_printf("n[Machblue]:Service list 2 init no memory.");
  294.        return MB_FAILURE;
  295. }
  296. mb_memset(_kb_mb_serviceList[radio_list].services,0,sizeof(kb_movie_service_t)*audioCnt);
  298. //insert video service
  299. for(index=0;index<audioCnt;index++)
  300. {
  301. //service info
  302. service_ID = KB_DBGetSvcIDByNO(RADIOPRG, index);
  303. service_name = KB_DBGetPrgName(RADIOPRG,index+1);
  304. _kb_mb_serviceList[radio_list].services[index].info.id=(int)_kb_mb_radio_service_id++;
  305. _kb_mb_serviceList[radio_list].services[index].info.display_id=service_ID;//gPrgAllInfo.gDTVInfo.PgmList[index].SvcID;
  306. mb_memcpy(_kb_mb_serviceList[radio_list].services[index].info.name,service_name,MB_TV_SERVICE_NAME_LENGTH);
  307. mb_memcpy(_kb_mb_serviceList[radio_list].services[index].info.logo_url,"0000 ",5);
  308. _kb_mb_serviceList[radio_list].services[index].info.type=MB_TV_DIGITAL_SERVICE;
  310.    _kb_mb_serviceList[radio_list].services[index].info.source_info.id=0;
  311. _kb_mb_serviceList[radio_list].services[index].info.source_info.type=MB_TV_CABLE_SOURCE;
  314. //service state
  315. _kb_mb_serviceList[radio_list].services[index].state=MB_TV_SERVICE_DISCONNECTED;
  317. //authorization
  318. _kb_mb_serviceList[radio_list].services[index].auth=MB_TV_AF_AUTHORIZED;
  320. //
  321. _kb_mb_serviceList[radio_list].services[index].serInfo.tsID=KB_DBGetPrgTsID(RADIOPRG,index+1);
  323. //event
  324. mb_memset(&(_kb_mb_serviceList[radio_list].services[index].evs),0,sizeof(kb_movie_eventSchedule_t));
  325. mb_memset(&(_kb_mb_serviceList[radio_list].services[index].current_event),0,sizeof(kb_movie_event_t));
  326. mb_memset(&(_kb_mb_serviceList[radio_list].services[index].following_event),0,sizeof(kb_movie_event_t));
  328. //pointer
  329. _kb_mb_serviceList[radio_list].services[index].svl=&_kb_mb_serviceList[radio_list];
  330. _kb_mb_serviceList[radio_list].services[index].svc=&_kb_mb_serviceContext;
  331. _kb_mb_serviceList[radio_list].services[index].streams=&_kb_mb_serviceStream;
  333. _kb_mb_serviceList[radio_list].services[index].current_event.service=&_kb_mb_serviceList[radio_list].services[index];
  334. _kb_mb_serviceList[radio_list].services[index].current_event.evs=&_kb_mb_serviceList[radio_list].services[index].evs[0];
  335. _kb_mb_serviceList[radio_list].services[index].following_event.service=&_kb_mb_serviceList[radio_list].services[index];
  336. _kb_mb_serviceList[radio_list].services[index].following_event.evs=&_kb_mb_serviceList[radio_list].services[index].evs[0];
  338. //service count
  339. _kb_mb_serviceList[radio_list].count+=1;
  340.      }
  342. return MB_SUCCESS;
  343. }
  345. mb_error_t kb_machblue_nvod_flag(time_t start_time,time_t duration )
  346. {
  347. time_t plTime, end_time;
  349. //KB_TimeGetCurTime(&plTime);
  350. plTime = KB_TimeGetCurGMTTime();
  351. end_time = start_time + duration;
  352. //mb_printf("nptime = %ld,start = %ld, end = %ld",plTime, start_time, end_time);
  353. if ((plTime>=start_time)&&(plTime<end_time))
  354. {
  355. /*
  356. {
  357. char out[30];
  358. ConvertTimeStampToHHMMSS(plTime, out);
  359. mb_printf("n[machblue]hhmmss is %sn",out);
  360. ConvertTimeStampToDateString(plTime, out);
  361. mb_printf("n[machblue]yymmdd is %sn",out);
  362. }
  363. */
  364. return MB_SUCCESS;
  365. }
  366. return MB_FAILURE;
  367. }
  368. mb_error_t kb_machblue_service_list_NVOD_init(UINT8 count,KB_NVOD_Info*pNVOD[])
  369. {
  370. unsigned short NVODCnt=0,index;
  371. char *service_name;
  372. int i,j,k=0;
  373. kb_movie_service_t *service;
  375. _kb_mb_serviceList[NVOD_list].info.id=2;
  376. mb_memcpy(_kb_mb_serviceList[NVOD_list].info.name,"NVOD Service",12);
  377. mb_memcpy(_kb_mb_serviceList[NVOD_list].info.logo_url," ",2);
  378. mb_memcpy(_kb_mb_serviceList[NVOD_list].info.extra_info," ",2);
  380. _kb_mb_serviceList[NVOD_list].services=NULL;
  381. _kb_mb_serviceList[NVOD_list].count=0;
  384. for(index = 0;index<count;index++)
  385. {
  386. NVODCnt = NVODCnt+pNVOD[index]->RefEventNum;
  387. }
  388. if(NVODCnt==0)
  389. return MB_SUCCESS;
  390. _kb_mb_serviceList[NVOD_list].services=mb_malloc(sizeof(kb_movie_service_t)*NVODCnt);
  391. if(_kb_mb_serviceList[NVOD_list].services==NULL)
  392. {
  393. mb_printf("n[Machblue]:Service list 2 init no memory.");
  394.        return MB_FAILURE;
  395. }
  396. //malloc service memory
  397. mb_memset(_kb_mb_serviceList[NVOD_list].services,0,sizeof(kb_movie_service_t)*NVODCnt);
  398. _kb_mb_NVOD_service_id = 0;
  399. for(index = 0;index<count;index++)
  400. {
  401. for(i = 0;i < pNVOD[index]->RefEventNum;i++,k++)
  402. {
  403. //service info
  404. //service_ID = i;
  405. service_name = pNVOD[index]->RefEventData[i].PrgName;
  406. _kb_mb_serviceList[NVOD_list].services[k].info.id=(int)_kb_mb_NVOD_service_id++;
  407. _kb_mb_serviceList[NVOD_list].services[k].info.display_id=k;//gPrgAllInfo.gDTVInfo.PgmList[index].SvcID;
  408. mb_memcpy(_kb_mb_serviceList[NVOD_list].services[k].info.name,service_name,MB_TV_SERVICE_NAME_LENGTH);
  409. _kb_mb_serviceList[NVOD_list].services[k].info.name[15]='';
  410. //mb_printf("nzhengyang_NVOD's name is %s,ID is %dn",pNVOD[index]->RefEventData[i].PrgName,k);
  411. //mb_printf("nwisco_NVOD's name is %sn",_kb_mb_serviceList[NVOD_list].services[i].info.name);
  413. _kb_mb_serviceList[NVOD_list].services[k].info.type=MB_TV_DIGITAL_SERVICE;
  414.    _kb_mb_serviceList[NVOD_list].services[k].info.source_info.id=0;
  415. _kb_mb_serviceList[NVOD_list].services[k].info.source_info.type=MB_TV_CABLE_SOURCE;
  416. //service state
  417. _kb_mb_serviceList[NVOD_list].services[k].state=MB_TV_SERVICE_DISCONNECTED;
  418. //authorization
  419. _kb_mb_serviceList[NVOD_list].services[k].auth=MB_TV_AF_AUTHORIZED;
  420. //event
  421. mb_memset(&(_kb_mb_serviceList[NVOD_list].services[k].evs),0,sizeof(kb_movie_eventSchedule_t));
  422. mb_memset(&(_kb_mb_serviceList[NVOD_list].services[k].current_event),0,sizeof(kb_movie_event_t));
  423. mb_memset(&(_kb_mb_serviceList[NVOD_list].services[k].following_event),0,sizeof(kb_movie_event_t));
  424. //pointer
  425. _kb_mb_serviceList[NVOD_list].services[k].svl=&_kb_mb_serviceList[NVOD_list];
  426. _kb_mb_serviceList[NVOD_list].services[k].svc=&_kb_mb_serviceContext;
  427. _kb_mb_serviceList[NVOD_list].services[k].streams=&_kb_mb_serviceStream;
  428. //service count
  429. _kb_mb_serviceList[NVOD_list].count+=1;
  430. service = &_kb_mb_serviceList[NVOD_list].services[k];
  431. //_kb_mb_event_id = 0;
  432. if (pNVOD[index]->RefEventData[i].TimeNum == 0)
  433. {
  434. continue;
  435. }
  436. service->evs[0].evtCount=pNVOD[index]->RefEventData[i].TimeNum;
  437. if (service->evs[0].evtCount > 30)
  438. service->evs[0].evtCount = 30;
  439. service->evs[0].events=mb_malloc((mb_size_t)(sizeof(kb_movie_event_t)*service->evs[0].evtCount));
  440. for(j = 0;j <service->evs[0].evtCount; j++)
  441. {
  443. service->evs[0].events[j].attributes.event_info.id=j;//_kb_mb_event_id++;
  444. service->evs[0].events[j].attributes.event_info.duration=pNVOD[index]->RefEventData[i].durTime;
  445. mb_memcpy(service->evs[0].events[j].attributes.event_info.name, "",1);
  446. mb_memcpy(service->evs[0].events[j].attributes.event_info.short_desc,
  447.  pNVOD[index]->RefEventData[i].PrgTxt,
  448.  MB_TV_EVENT_DESCRIPTION_LENGTH);
  449. service->evs[0].events[j].attributes.event_info.short_desc[MB_TV_EVENT_DESCRIPTION_LENGTH]='';
  450. service->evs[0].events[j].attributes.start_time=pNVOD[index]->RefEventData[i].TimeNode[j].startTime;//+8*3600;
  452. service->evs[0].events[j].attributes.cost=0;
  453. service->evs[0].events[j].attributes.expiration_date=0;
  454. service->evs[0].events[j].auth=MB_TV_AF_AUTHORIZED;
  455. service->evs[0].events[j].day=0;
  456. service->evs[0].events[j].service=service;
  457. service->evs[0].events[j].evs=&service->evs[0];
  458. if(kb_machblue_nvod_flag((time_t)pNVOD[index]->RefEventData[i].TimeNode[j].startTime,(time_t)pNVOD[index]->RefEventData[i].durTime))
  459. {
  460. //mb_printf("n在播节目%d == %s",j,service->info.name);
  461. //{
  462. // char out[30];
  463. // ConvertTimeStampToHHMMSS((time_t)service->evs[0].events[j].attributes.start_time, out);
  464. // mb_printf("n[machblue]hhmmss is %sn",out);
  465. // ConvertTimeStampToDateString((time_t)service->evs[0].events[j].attributes.start_time, out);
  466. // mb_printf("n[machblue]yymmdd is %sn",out);
  467. //}
  468. mb_memcpy((void*)service->evs[0].events[j].attributes.event_info.genre,"Y",2);
  469. }
  470. else
  471. mb_memcpy((void*)service->evs[0].events[j].attributes.event_info.genre,"N",2);
  472. }
  474. }
  476. }
  477. /*
  478. for(i=0;i<_kb_mb_serviceList[NVOD_list].services[1].evs[0].evtCount;i++)
  479. {
  480. mb_printf("n[machblue]service[%d]=id = %d,[%d]=name = %sn",i,_kb_mb_serviceList[NVOD_list].services[1].info.id,i,_kb_mb_serviceList[NVOD_list].services[1].info.name);
  481. mb_printf("n[machblue]event[%d]=id = %d,[%d]=name = %ldn",i,_kb_mb_serviceList[NVOD_list].services[1].evs[0].events[i].attributes.event_info.id,i,_kb_mb_serviceList[NVOD_list].services[1].evs[0].events[i].attributes.start_time);
  482. }
  483. */
  484. return MB_SUCCESS;
  485. }
  490. /**
  491.  * This function delete the service list information. 
  492.  * @return MB_SUCCESS on success, MB_FAILURE on failure.
  493.  */
  494. mb_error_t kb_mb_service_list_delete(void)
  495. {
  496. return MB_SUCCESS;
  497. }
  501. /**
  502.  * This function get the service list pointer. 
  503.  * @return pointer of service list.
  504.  */
  505. kb_movie_serviceList_t *kb_mb_service_list_get(void)
  506. {
  507. return _kb_mb_serviceList;
  508. }
  513. /**
  514.  * This function create event schedule of service. 
  516.  * service < service which event belong to >
  517.  
  518.  * @return MB_SUCCESS on success, MB_FAILURE on failure.
  519.  */
  521. mb_error_t kb_mb_event_schedule_create(kb_movie_service_t *service)
  522. {
  523. KB_EPGDayInfo  *pDayInfo;
  524. unsigned long  i,j,evtCount=0,count=0;
  525. time_t plTime;
  526. //U32 hour, min, seconds;
  527. //U32 y, m, d;
  528. int index;
  530. if(service==NULL)
  531. {
  532. mb_printf("n[Machblue]:TV notification send NULL.");
  533. return MB_FAILURE;
  534. }
  535. KB_TimeGetCurTime(&plTime);
  536. for(i=0;i<7;i++)
  537. {
  538. pDayInfo=(KB_EPGDayInfo *)KD_EPGGetSCH(KB_EPG_GetTsNumFromTsId(service->serInfo.tsID),service->info.display_id,i);
  540. evtCount=pDayInfo->nEventCount;
  542. count+=evtCount;
  544. if(evtCount==0)
  545. continue;
  547. service->evs[i].events=mb_malloc((mb_size_t)(sizeof(kb_movie_event_t)*evtCount));
  548. service->evs[i].service=service;
  549. service->evs[i].evtCount=evtCount;
  551. //add event information
  552. for(j=0;j<pDayInfo->nEventCount;j++)
  553. {
  554. service->evs[i].events[j].attributes.event_info.id=(int)_kb_mb_event_id++;
  555. service->evs[i].events[j].attributes.event_info.duration=pDayInfo->ptEvent[j].duration;
  556. mb_memcpy(service->evs[i].events[j].attributes.event_info.name,
  557.  pDayInfo->ptEvent[j].chinese.event_name,
  558.  sizeof(pDayInfo->ptEvent[j].chinese.event_name));
  559. mb_memcpy(service->evs[i].events[j].attributes.event_info.short_desc,
  560.  pDayInfo->ptEvent[j].chinese.text,
  561.  MB_TV_EVENT_DESCRIPTION_LENGTH);
  562. service->evs[i].events[j].attributes.start_time=pDayInfo->ptEvent[j].start_time;
  564. service->evs[i].events[j].attributes.cost=0;
  565. service->evs[i].events[j].attributes.expiration_date=0;
  567. service->evs[i].events[j].auth=MB_TV_AF_AUTHORIZED;
  568. service->evs[i].events[j].day=(unsigned char)i;
  569. service->evs[i].events[j].service=service;
  570. service->evs[i].events[j].evs=&service->evs[i];
  571. if(service->svl->info.id==0)
  572. {
  573. for(index = 0; index<_kb_mb_serviceList[all_tv_list].count;index++)
  574. {
  575. if(_kb_mb_serviceList[all_tv_list].services[index].info.display_id==service->info.display_id)//gPrgAllInfo.gDTVInfo.PgmList[index].SvcID;
  576. break;
  577. }
  578. if(KB_CheckDmdEnt(index,(int)j,(int)i,(int)DT_EPG))
  579. {
  580. mb_memcpy((void*)service->evs[i].events[j].attributes.event_info.genre,"Y",2);
  581. }
  582. else
  583. mb_memcpy((void*)service->evs[i].events[j].attributes.event_info.genre,"N",2);
  584. }
  585. }
  586. }
  588. //mb_printf("nkb_mb_event_schedule_create service [%s] event count[%d]",service->info.name,count);
  590. return MB_SUCCESS;
  591. }
  595. /**
  596.  * This function init the service context information. 
  597.  * @return MB_SUCCESS on success, MB_FAILURE on failure.
  598.  */
  599. mb_error_t kb_mb_service_context_init(void)
  600. {
  601. mb_memset(&_kb_mb_serviceContext,0,sizeof(_kb_mb_serviceContext));
  603. _kb_mb_serviceContext.info.id=1;
  604. //_kb_mb_serviceContext.info.
  605. _kb_mb_serviceContext.service=&_kb_mb_serviceList[all_tv_list].services[0];
  607. return MB_SUCCESS;
  608. }
  610. void kb_mb_service_context_evaluation(int serviceIndex,int service_type)
  611. {
  612. int ser_list_type;
  613.                  
  614. if(service_type == DTVPRG)
  615. ser_list_type =all_tv_list;
  616. if (service_type == RADIOPRG)
  617. ser_list_type = radio_list;
  618. if(serviceIndex>0)
  619. _kb_mb_serviceContext.service=&_kb_mb_serviceList[ser_list_type].services[serviceIndex-1];
  620. }
  625. /**
  626.  * This function get the service context pointer. 
  627.  * @return pointer of service context.
  628.  */
  629. kb_movie_serviceContext_t *kb_mb_service_context_get(void)
  630. {
  631. return &_kb_mb_serviceContext;
  632. }
  636. /**
  637.  * This function set notification and client data. 
  638.  * @return none.
  639.  */
  640. void kb_mb_notification_set(mb_tv_notify_f *notify_fct,void *clientdata)
  641. {
  642. _kb_mb_tvNotifyFun=notify_fct;
  643. _kb_mb_tvClientData=clientdata;
  644. }
  648. /**
  649.  * This function send notification to machblue player. 
  650.  * @return MB_SUCCESS on success, MB_FAILURE on failure.
  651.  */
  652. mb_error_t kb_mb_notification_send(mb_tv_notif_reason_t reason,mb_args_t *args)
  653. {
  654. if(_kb_mb_tvNotifyFun==NULL)
  655. {
  656. mb_printf("n[Machblue]:TV notification send NULL.");
  657. return MB_FAILURE;
  658. }
  660. // invokes native callback
  661. return _kb_mb_tvNotifyFun(reason,args,_kb_mb_tvClientData);
  662. }