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

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

DVD

开发平台：

C/C++

search.c：源码内容
  1. #include <stdio.h> 
  2. #include <string.h>
  4. #include "gendef.h"
  5. #include "dmd.h"
  6. #include "osp.h"
  7. #include "sipsi.h"
  9. #include "appltype.h"
  10. #include "db.h"
  11. #include "db.h"
  13. #include "search.h"
  14. #include "flash.h"
  16. #include "avplay.h"
  17. #include "kb_dc.h"
  19. #include "kb_machblue_client_task.h"
  22. INT32 g_srchMode;
  23. KB_SINitStruct  g_srchNit;
  24. KB_SISdtStruct  g_srchSDT[100];
  25. KB_SIPatStruct  g_srchPAT;
  26. KB_SIPmtStruct  g_srchPMT;
  28. KB_DBPrgNode     gSrchPrg[KB_DB_MAX_PGM_NODE];
  31. static T_SEARCH_PARA gSrchApp;         
  33. enum
  34. {
  35. SrchPat,
  36. SrchSDT,
  37. SrchPMT
  38. };
  40. struct HintDisplay_struct
  41. {
  42.     char *info;
  43.     char *englishinfo;
  44.     unsigned char hinttype;
  45.     unsigned char index;
  46. }_HintDisplay[];
  47. //}_HintDisplay[] =
  48. //{
  49. // {"信号不良", "Weak signal", 0, KB_SEARCH_HINT1},
  50. //};
  52. static INT32 g_WholeNetFreqs[] =
  53. {
  54. 107, 115, 123, 131, 139, 147, 155, 163, 171, 179, 187, 195, 203, 211,
  55. 219, 227, 235, 243, 251, 259, 267, 275, 283, 291, 299, 307, 315, 323, 
  56. 331, 339, 347, 355, 363, 371, 379, 387, 395, 403, 411, 419, 427, 435, 
  57. 443, 451, 459, 467, 474, 482, 490, 498, 506, 514, 522, 530, 538, 546, 
  58. 554, 562, 570, 578, 586, 594, 602, 610, 618, 626, 634, 642, 650, 658, 
  59. 666, 674, 682, 690, 698, 706, 714, 722, 730, 738, 746, 754, 762, 770, 
  60. 778, 786, 794, 802, 810, 818, 826, 834, 842, 850, 858
  61. };
  62. //#define WHOLE_NET_FREQ_SUM  (95)
  64. static int _iRefSvcNums;
  65. static KB_SIRefSvcCell _astNvodCell[KB_SI_MAX_REF_SVC_NUMS];
  66. static int _iTotalShiftSvcNums;
  67. //static unsigned long _alShiftSvc[KB_SI_MAX_REF_SVC_NUMS * KB_SI_MAX_SHIFT_SVC_NUMS];
  69. static UINT16 bCurrentFreqDtvNum;
  70. static UINT16 bCurrentFreqMusicNum;
  72. static KB_DMDTunerParameters gSrchFre[WHOLE_NET_FREQ_SUM];
  73. static UINT8 gSrchFreInx = 0;
  74. static UINT8 gSrchFreNum =0 ;
  76. static UINT32 gSrchTaskID;
  77. static UINT32 gSrchQueID;
  79. enum{PMTPID_GET_FIRST, PMTPID_GET_NEXT};
  80. static unsigned short KD_GetPmtPid(unsigned short i_nCallOpt, unsigned short * pmtPid, 
  81.                              unsigned short * pmtPgmno);
  83. static void KD_SRCHHandleNit(void);
  85. static void KD_SrchNvodInit(void);
  86. static void KD_SrchHandleNovd(KB_SISdtStruct * i_pstSdt, int i_nNum);
  87. static void KD_SrchAdjustNvod(void);
  89. static void KD_SrchDis(UINT32 nPara1, UINT32 nPara2, UINT8 nDisTypeEx, 
  90.                          UINT8 nDisType);
  92. static void  KD_SrchTask(void);
  93. static INT32 KD_SrchHandleMsg(KB_OSPMsgNode *i_pstMsg);
  95. static void KD_SrchToNext(void);
  97. static void KD_SrchSetFre(UINT8 srchMode);
  98. static void KD_SrchSaveResult(void);
  99. static void KD_Srchend(void);
  102. INT32 KB_SEARCHInit(void)
  103. {
  104.     int nReturn;
  105.     
  106. gSrchApp.tsParams.frequency = 0;
  107. gSrchApp.tsParams.details.qam.symbolRatekSs      = 0;
  108. gSrchApp.tsParams.details.qam.modulation      = 0;
  110. gSrchApp.srchMode  = KB_SEARCH_IN_NET;
  111. gSrchApp.srchState = KB_SEARCH_UNACTIVE;
  113. gSrchApp.pat         = NULL;
  114. gSrchApp.pmtCpt      = KB_DB_DTV_FAILURE;
  115.     gSrchApp.sdtCpt      = KB_DB_DTV_FAILURE;
  116. gSrchApp.nitCpt      = KB_DB_DTV_FAILURE;
  118. gSrchApp.dtvNum   = 0;
  119. gSrchApp.radNum   = 0;
  121. gSrchApp.svcIDnum = 0;
  123. memset(gSrchFre,0,sizeof(gSrchFre));
  124. gSrchFreInx = 0;          
  125. gSrchFreNum =0 ;          
  127.     nReturn = KB_OSPQueInit("SEAQ", 64, &gSrchQueID);
  128.     if (nReturn != Ret_OK)
  129.     {
  130.         return RETFIAL1;
  131.     }
  132.     
  133.     nReturn = KB_OSPTaskInit("SEAT", 64 * 1024, (void (*)(void*))KD_SrchTask, 
  134.                        SEARCH_PRIORITY, NULL, &gSrchTaskID);
  135.     if (nReturn != Ret_OK)
  136.     {
  137.         return RETFIAL1;
  138.     }
  140.     return RETOK;
  141. }
  143. static void KD_SrchTask(void)
  144. {
  145.     KB_OSPMsgNode msgNode;
  146.     int nReturn;
  148.     while (1)
  149.     {
  150.         nReturn = KB_OSPMsgGet(gSrchQueID, KB_Wait, 0, (KB_OSPMsgNode *)&msgNode);
  151. if(nReturn != Ret_OK)
  152. {            
  153. continue;
  154. }
  156.         KD_SrchHandleMsg(&msgNode);
  157.     }
  158. }
  160. void KB_SEARCHCreate(void)
  161. {
  162. gSrchApp.srchState = KB_SEARCH_WAITING_CNT;
  163. gSrchApp.pat         = NULL;
  164. gSrchApp.pmtCpt      = KB_DB_DTV_FAILURE;
  165.     gSrchApp.sdtCpt      = KB_DB_DTV_FAILURE;
  166. gSrchApp.nitCpt      = KB_DB_DTV_FAILURE;
  168. gSrchApp.dtvNum   = 0;
  169. gSrchApp.radNum   = 0;
  171. gSrchApp.svcIDnum = 0;
  172. memset(gSrchFre,0,sizeof(gSrchFre));
  173. gSrchFreInx = 0;
  174. gSrchFreNum = 0;
  176. KB_DBE2pCfgInfoRefresh(DTVPRG);
  177. KB_DBE2pCfgInfoRefresh(RADIOPRG);
  178. KB_DBE2pCfgInfoRefresh(DATAPRG);
  180. switch(gSrchApp.srchMode)
  181. {
  182. case KB_SEARCH_IN_TS://手动
  183. KB_DBGetAllPrgConfig();
  184. break;
  186. case KB_SEARCH_IN_NET:
  187. case KB_SEARCH_IN_WHOLE_NET:
  188. KB_DBResetDtvInfo(BufferSave);
  189. KB_DBResetRadInfo(BufferSave);
  190. KB_DBResetDataInfo(BufferSave);
  191. KB_DBResetChnnlInfo(BufferSave);
  192. KB_FlashErase(KB_DB_SECTOR);
  193. KD_SrchNvodInit();     
  195. break;
  196. default:
  197. break;
  198. }
  200.     KD_SrchSetFre(gSrchApp.srchMode);
  202. if (gSrchApp.srchMode != KB_SEARCH_IN_NET)
  203. {
  204. KD_SrchToNext();
  205. }
  206. }
  209. void KB_SEARCHSetPara(unsigned char i_cSearchMode,
  210.    unsigned long i_lFreq, unsigned long i_lSymb, 
  211.    unsigned short i_nQam)
  212. {
  213. if(i_cSearchMode == KB_SEARCH_IN_WHOLE_NET) 
  214. {
  215. gSrchApp.srchMode = KB_SEARCH_IN_WHOLE_NET;
  216. g_srchMode = KB_SEARCH_IN_WHOLE_NET;
  217. }
  218. else 
  219. {
  220. gSrchApp.tsParams.type = DMD_TYPE_QAM;
  221.        gSrchApp.tsParams.inversion = INVERSION_AUTO;
  222. gSrchApp.tsParams.frequency = i_lFreq;
  223. gSrchApp.tsParams.details.qam.symbolRatekSs = i_lSymb;
  224. gSrchApp.tsParams.details.qam.modulation = (unsigned char)i_nQam;
  226. if(i_cSearchMode == KB_SEARCH_IN_TS)
  227. {
  228. gSrchApp.srchMode = KB_SEARCH_IN_TS;
  229. g_srchMode = KB_SEARCH_IN_TS;
  230. }
  231. else
  232. {
  233. gSrchApp.srchMode = KB_SEARCH_IN_NET;
  234. g_srchMode = KB_SEARCH_IN_NET;
  235. }
  236. }
  237. }
  239. INT32 KB_SEARCHHandleMsg(KB_OSPMsgNode *i_pstMsg)
  240. {
  241.     int nReturn;
  243.     nReturn = KB_OSPMsgSend(gSrchQueID, i_pstMsg);
  245.     return RETOK;
  246. }
  248. void KD_SrchParseInit(unsigned short i_lFreq, unsigned short i_lSymb, 
  249.  unsigned char i_lQam)
  250. {
  251. unsigned short loop;
  253. for(loop = 0; loop < KB_DB_MAX_PGM_NODE; loop ++)
  254. {
  255. gSrchPrg[loop].freq = i_lFreq;
  256. gSrchPrg[loop].symb = i_lSymb;
  257. gSrchPrg[loop].qam  = i_lQam;
  259. gSrchPrg[loop].PATVersion = KB_DB_UNKNOWN_VERSION;
  260. gSrchPrg[loop].SDTVersion = KB_DB_UNKNOWN_VERSION;
  261. gSrchPrg[loop].PMTVersion = KB_DB_UNKNOWN_VERSION;
  263. }
  265. }
  267. void KD_SrchParseTable(unsigned char i_cTableType, void * i_pstTable, 
  268.  unsigned short i_nSvcNum)
  269. {
  270. KB_SIPatStruct    * pat;
  271. KB_SISdtStruct    * sdt;
  272. KB_SIPmtStruct    * pmt;
  273. int len;
  274. unsigned short i, j; 
  276. switch(i_cTableType)
  277. {
  278. case SrchPat:
  279. pat = (KB_SIPatStruct *)i_pstTable;
  281. for(j=0; j<i_nSvcNum; j++)
  282. {
  283.          for(i = 0; i < pat->num; i ++)
  284. {
  285. if (gSrchPrg[j].SerID == pat->program[i].program_number)
  286. {
  287.      gSrchPrg[j].PATVersion = pat->version_number;
  288.      gSrchPrg[j].PMTPid     = pat->program[i].program_map_PID;
  289. break;
  290. }
  291. }
  292. }
  293. break;
  295. case SrchSDT:
  296. sdt = (KB_SISdtStruct *)i_pstTable;
  298. for(i = 0; i < i_nSvcNum; i ++)
  299. {
  300. len = strlen((char*)sdt[i].chinese.service_name);
  301. if(len >= 20)
  302. {
  303. len = 18;
  304. }
  306. if(sdt[i].chinese.service_name[0] != '')
  307. {
  308. memcpy(gSrchPrg[i].name, sdt[i].chinese.service_name, len); 
  309. }
  310. else
  311. {
  312. if(sdt[i].english.service_name[0] != '')
  313. {
  314. memcpy(gSrchPrg[i].name, sdt[i].english.service_name, len); 
  315. }
  316. else
  317. {
  318. strcpy(gSrchPrg[i].name, "数字电视");   
  319. }
  320. }
  323. gSrchPrg[i].name[len ] = '';
  324. gSrchPrg[i].name[len + 1 ] = '';
  326. gSrchPrg[i].SDTVersion   = sdt[i].version_number;
  327. gSrchPrg[i].service_type = sdt[i].service_type; 
  328. //printf("-=gSrchPrg[%d].service_type=0x%x=-n", i, gSrchPrg[i].service_type);
  329. gSrchPrg[i].SerID= sdt[i].service_id;
  330. gSrchPrg[i].TSID         = sdt[i].TSID;
  331. }
  332. break;
  334. case SrchPMT:
  335. pmt = (KB_SIPmtStruct *)i_pstTable;
  336. for(i = 0; i < i_nSvcNum; i ++)
  337. {
  338. if(gSrchPrg[i].SerID== pmt->program_number) 
  339. {
  340. unsigned short loop;
  342. gSrchPrg[i].PCR_Pid    = pmt->PCR_PID;
  343. gSrchPrg[i].PMTVersion = pmt->version_number;
  345. if(pmt->CA_descriptor_buffer_len == 0)
  346. {
  347. gSrchPrg[i].bCAFlag = KB_DB_PGM_UNENCRYPT;
  348. }
  349. else
  350. {
  351. gSrchPrg[i].bCAFlag = KB_DB_PGM_ENCRYPT;
  352. }
  354. gSrchPrg[i].Audio_Pid = 0;
  355. gSrchPrg[i].Video_Pid = 0;
  357.                 for(loop = 0; loop < pmt->num; loop ++)
  358. {
  359. switch(pmt->stream[loop].stream_type)
  360. {
  361. case 1:
  362. case 2:
  363. if(gSrchPrg[i].Video_Pid != 0)
  364. {
  365. break;
  366. }
  368. gSrchPrg[i].Video_Pid = pmt->stream[loop].elementary_PID;
  370. if(pmt->stream[loop].CA_descriptor_buffer_len > 0)
  371. {
  372. gSrchPrg[i].bCAFlag = KB_DB_PGM_ENCRYPT;
  373. }
  374. break;
  376. case 3:
  377. case 4:
  378. if(gSrchPrg[i].Audio_Pid != 0) 
  379. {
  380. break;
  381. }
  382. gSrchPrg[i].Audio_Pid = pmt->stream[loop].elementary_PID;
  384. if(pmt->stream[loop].CA_descriptor_buffer_len > 0)
  385. {
  386. gSrchPrg[i].bCAFlag = KB_DB_PGM_ENCRYPT;
  387. }
  388. break;
  389. default :
  390. break;
  391. }
  392. }
  393. break;
  394. }
  395. }
  396. break;
  397. default:
  398. break;
  399. }
  400. }
  402. static INT32  KD_SrchHandleMsg(KB_OSPMsgNode *i_pstMsg)
  403. {
  404. switch(i_pstMsg->Word1)
  405. {
  406. case MOD_TUNER:
  407. //printf("-=MOD_TUNER:i_pstMsg->Word2=%d=-n", i_pstMsg->Word2);
  408. switch(i_pstMsg->Word2)
  409. {
  410. case DMD_CALLBACK_SIGNAL_CONNECTED:
  411. if (((gSrchApp.srchState == KB_SEARCH_WAITING_CNT)
  412.      && (gSrchApp.srchMode != KB_SEARCH_IN_NET))
  413. || ((gSrchApp.srchState == KB_SEARCH_WAITING_CNT)
  414.     && (gSrchApp.srchMode == KB_SEARCH_IN_NET)
  415.     && (gSrchApp.nitCpt == KB_DB_DTV_SUCCESS )))
  416. {
  417. KB_SIGetSdt(-1, 100, g_srchSDT, KB_SI_RECEIVE_ONCE, -1);
  418. gSrchApp.srchState = KB_SEARCH_WAITING_SDT;
  419. }
  421. break;
  423. case DMD_CALLBACK_SIGNAL_LOST:   //丢失连接
  424. if((gSrchApp.srchState == KB_SEARCH_WAITING_CNT) 
  425. || (gSrchApp.srchState == KB_SEARCH_WAITING_PAT) 
  426. || (gSrchApp.srchState == KB_SEARCH_WAITING_SDT)
  427. || (gSrchApp.srchState == KB_SEARCH_WAITING_PMT)
  428. || (gSrchApp.srchState == KB_SEARCH_WAITING_NIT)) 
  429. {
  431. if ((gSrchApp.srchMode == KB_SEARCH_IN_TS)
  432. /*|| ((gSrchApp.srchMode == KB_SEARCH_IN_NET)
  433.           && (gSrchApp.nitCpt != KB_DB_DTV_SUCCESS ))*/)
  434. {
  435.                  KD_SrchDis(0, 0, KB_SEARCH_HINT0, KB_SEARCH_DIS_HELPHINT);
  436. gSrchApp.srchState = KB_SEARCH_WAITING_EXIT;
  437. }
  438. else if (/*(gSrchApp.srchMode == KB_SEARCH_IN_TS)
  439. || */((gSrchApp.srchMode == KB_SEARCH_IN_NET)
  440.           && (gSrchApp.nitCpt != KB_DB_DTV_SUCCESS )))
  441. {
  442. KD_SrchDis(0, 0, KB_SEARCH_HINT1, KB_SEARCH_DIS_HELPHINT);
  443. gSrchApp.srchState = KB_SEARCH_WAITING_EXIT;
  444. }
  445. else
  446. {
  447. //added by whale 07/03/04
  448. KD_SrchDis(0, 0, KB_SEARCH_HINT2, KB_SEARCH_DIS_HELPHINT);
  449. KD_SrchToNext();
  450. }
  452. }
  454. break;
  455. default:
  456. break;
  457. }
  458. break;
  460. case MOD_SIPSI:
  461. //printf("-=MOD_SIPSI:i_pstMsg->Word2=%d=-n", i_pstMsg->Word2);
  462. switch(i_pstMsg->Word2)
  463. {
  464. case KB_SI_MSG_NIT_DONE:  
  465.   if ((gSrchApp.srchState == KB_SEARCH_WAITING_NIT)
  466. && (gSrchApp.srchMode == KB_SEARCH_IN_NET))
  467. {  
  469.   gSrchApp.nitCpt = KB_DB_DTV_SUCCESS;
  471. KD_SRCHHandleNit();
  473. KD_SrchToNext();
  474. }
  475. break;
  477. case KB_SI_MSG_NIT_TIMEOUT:           
  478.   if ((gSrchApp.srchState == KB_SEARCH_WAITING_NIT)
  479. && (gSrchApp.srchMode == KB_SEARCH_IN_NET))
  480. {
  481.                  KD_SrchDis(0, 0, KB_SEARCH_HINT3, KB_SEARCH_DIS_HELPHINT);
  482. gSrchApp.srchState = KB_SEARCH_WAITING_EXIT;
  483. }
  484. break;
  486. case KB_SI_MSG_PAT_DONE:      
  487. if(gSrchApp.srchState == KB_SEARCH_WAITING_PAT)
  488. {
  489. unsigned short ret, pmtPid, pmtPgmno;
  490. KB_DBRET dbRet;
  491. //KB_SIPmtStruct *pPmt=NULL;
  493. gSrchApp.pat = (KB_SIPatStruct *)i_pstMsg->Word3;
  494. KD_SrchParseTable(SrchPat, (void *)i_pstMsg->Word3, 
  495.                     gSrchApp.svcIDnum);
  496. dbRet = KB_DBSaveChlPatVer(
  497. (UINT16)(gSrchFre[gSrchFreInx-1].frequency / 100),
  498. (UINT16)gSrchApp.pat->version_number);
  500. if (KB_SEARCH_IN_TS == gSrchApp.srchMode)
  501. {
  502. KD_SrchDis(60, 0, KB_SEARCH_DISABLED, KB_SEARCH_DIS_PLANHINT);
  503. }
  505. ret = KD_GetPmtPid(PMTPID_GET_FIRST, &pmtPid, &pmtPgmno);
  507. if(ret != KB_DB_DTV_SUCCESS)    
  508. {
  509. KD_SrchToNext();
  510. }
  511. else
  512. {
  513. KB_SIGetPmt(pmtPid, pmtPgmno, &g_srchPMT,KB_SI_RECEIVE_ONCE, -1);
  514. gSrchApp.srchState = KB_SEARCH_WAITING_PMT;
  515. }
  516. }
  517. break;
  519. case KB_SI_MSG_PAT_TIMEOUT:
  521. if(gSrchApp.srchState == KB_SEARCH_WAITING_PAT)
  522. {
  523. KD_SrchDis(0, 0, KB_SEARCH_HINT4, KB_SEARCH_DIS_HELPHINT);
  524. KD_SrchToNext();
  525. }
  526. break;
  528. case KB_SI_MSG_SDT_DONE:
  530. if(gSrchApp.srchState == KB_SEARCH_WAITING_SDT)
  531. {
  532. KB_SISdtStruct        *pSdt;
  533. //KB_SIPatStruct        *pPat;
  534. KB_DBRET  ret;
  536. gSrchApp.sdtCpt = KB_DB_DTV_SUCCESS;
  537.       gSrchApp.srchState = KB_SEARCH_WAITING_PAT;
  539.   pSdt = (KB_SISdtStruct *)i_pstMsg->Word3;
  540.                 
  541. gSrchApp.svcIDnum = (UINT16)i_pstMsg->Word4;
  543. KD_SrchParseTable(SrchSDT, (void *)i_pstMsg->Word3,
  544.                 gSrchApp.svcIDnum);
  546.         ret = KB_DBSaveChlInfo(0,pSdt->OrgNetID,pSdt->TSID,
  547. (UINT16)(gSrchFre[gSrchFreInx-1].frequency / 100),
  548. (UINT16)gSrchFre[gSrchFreInx-1].details.qam.symbolRatekSs,
  549.         gSrchFre[gSrchFreInx-1].details.qam.modulation);
  551. ret = KB_DBSaveChlSdtVer(
  552. (UINT16)(gSrchFre[gSrchFreInx-1].frequency / 100),
  553. (UINT16)pSdt->version_number);
  555. KD_SrchHandleNovd((KB_SISdtStruct *)i_pstMsg->Word3, (int)i_pstMsg->Word4);
  557. KB_SIGetPat(&g_srchPAT, KB_SI_RECEIVE_ONCE, -1);
  559. if (KB_SEARCH_IN_TS == gSrchApp.srchMode)
  560. {
  561. KD_SrchDis(30, 0, KB_SEARCH_DISABLED, KB_SEARCH_DIS_PLANHINT);
  562. }
  564. }
  565. break;
  566. case KB_SI_MSG_SDT_TIMEOUT:  
  567. if(gSrchApp.srchState == KB_SEARCH_WAITING_SDT)
  568. {
  569. KD_SrchDis(0, 0, KB_SEARCH_HINT6, KB_SEARCH_DIS_HELPHINT);
  570. KD_SrchToNext();
  571. }
  572. break;
  574. case KB_SI_MSG_PMT_TIMEOUT:
  575. if (gSrchApp.srchState == KB_SEARCH_WAITING_PMT)
  576. {
  577. KD_SrchDis(0, 0, KB_SEARCH_HINT5, KB_SEARCH_DIS_HELPHINT);
  578. }
  579. case KB_SI_MSG_PMT_DONE:  
  580. if (gSrchApp.srchState == KB_SEARCH_WAITING_PMT)
  581. {
  582. unsigned short ret, pmtPid, pmtPgmno;
  584. if (i_pstMsg->Word2 == KB_SI_MSG_PMT_DONE)
  585. {
  586. KD_SrchParseTable(SrchPMT, (void *)i_pstMsg->Word3, 
  587.                 gSrchApp.svcIDnum);
  588. }
  590. ret = KD_GetPmtPid(PMTPID_GET_NEXT, &pmtPid, &pmtPgmno);
  591. if(ret != KB_DB_DTV_SUCCESS)
  592. {
  593. gSrchApp.pmtCpt = KB_DB_DTV_SUCCESS;
  595. KD_SrchAdjustNvod();
  596. KD_SrchSaveResult();
  598. KD_SrchToNext();
  599. }
  600. else
  601. {
  602. KB_SIGetPmt(pmtPid, pmtPgmno, &g_srchPMT, KB_SI_RECEIVE_ONCE, -1);
  603. gSrchApp.srchState = KB_SEARCH_WAITING_PMT;
  604. }
  605. }
  606. break;
  607. }
  609. break;
  611. case J_TIME_MODULE:
  612. break;
  613. default:
  614. break;
  615. }
  617. return KB_DB_DTV_SUCCESS;
  618. }
  620. void KB_SEARCHDestroy(void)
  621. {
  622. KB_SIStopAllSection();
  623. KB_DMDDropSignal();
  625.     KD_SrchDis(0, 0, KB_SEARCH_DISABLED, KB_SEARCH_DIS_CLEAN);
  626. }
  628. static void KD_SRCHHandleNit(void)
  629. {
  630. KB_DBNetInfo NetworkInfo;
  631. UINT16 i;
  633. gSrchFreNum = g_srchNit.num;
  635. for(i=0; i<gSrchFreNum; i++)
  636. {
  637. gSrchFre[i].type = DMD_TYPE_QAM;
  638. gSrchFre[i].inversion = INVERSION_AUTO;
  640. gSrchFre[i].frequency = g_srchNit.network[i].frequency / 10;
  641. gSrchFre[i].details.qam.modulation = g_srchNit.network[i].modulation;
  642. gSrchFre[i].details.qam.symbolRatekSs = g_srchNit.network[i].symbol_rate/10;
  643. gSrchFre[i].details.qam.fec_inner = g_srchNit.network[i].FEC_inner;
  644. }
  646. NetworkInfo.NitVersion = g_srchNit.version_number;
  647. memcpy(NetworkInfo.NetworkName,g_srchNit.network_name,20);
  648. NetworkInfo.NetworkName[21] = '';
  649. NetworkInfo.NetworkName[20] = '';
  651. KB_DBSaveNitInfo(&NetworkInfo);
  652. }
  654. static unsigned short KD_GetPmtPid(unsigned short i_nCallOpt, unsigned short * pmtPid, 
  655.                                     unsigned short * pmtPgmno)
  656. {
  657. static unsigned short count;
  659. if(i_nCallOpt == PMTPID_GET_FIRST)
  660. {
  661. count = 0;
  662. }
  664. if(count >= gSrchApp.pat->num)
  665. return KB_DB_DTV_FAILURE;
  667. while(gSrchApp.pat->program[count].program_number == 0)
  668. {
  669. count ++;
  670. if(count >= gSrchApp.pat->num)
  671. return KB_DB_DTV_FAILURE;
  672. }
  673. *pmtPid   = gSrchApp.pat->program[count].program_map_PID;
  674.        *pmtPgmno = gSrchApp.pat->program[count].program_number;
  675. count ++;
  676. return KB_DB_DTV_SUCCESS;
  678. }
  680. static void KD_SrchNvodInit(void)
  681. {
  682. _iRefSvcNums = _iTotalShiftSvcNums = 0;
  683. }
  685. static void KD_SrchHandleNovd(KB_SISdtStruct * i_pstSdt, int i_nNum)
  686. {
  687. int i;
  688. int loop;
  690. if(i_nNum > 1000)
  691. return;
  692. for(i = 0; i < i_nNum; i ++)
  693. {
  694. if(i_pstSdt[i].service_type == 0x04)
  695. {
  696. if(_iRefSvcNums >= KB_SI_MAX_REF_SVC_NUMS)
  697. {
  698. continue;
  699. }
  701. if( i_pstSdt[i].TimeShiftedNum == 0 ||
  702. i_pstSdt[i].TimeShiftedNum >= KB_SI_MAX_SHIFT_SVC_NUMS)
  703. {
  704. continue;
  705. }
  707. for(loop = 0; loop < _iRefSvcNums; loop ++)
  708. {
  709. if(i_pstSdt[i].service_id == _astNvodCell[loop].refScvId)
  710. {
  711. break;
  712. }
  713. }
  715. if(loop < _iRefSvcNums)
  716. {
  717. continue;
  718. }
  719. _astNvodCell[_iRefSvcNums].refScvId = i_pstSdt[i].service_id;
  720. _astNvodCell[_iRefSvcNums].freq = (UINT16)(gSrchApp.tsParams.frequency / 100);
  721. _astNvodCell[_iRefSvcNums].symb = (UINT16)gSrchApp.tsParams.details.qam.symbolRatekSs;
  722. _astNvodCell[_iRefSvcNums].qam  = gSrchApp.tsParams.details.qam.modulation;
  723. _astNvodCell[_iRefSvcNums].shiftSvcNum = i_pstSdt[i].TimeShiftedNum;
  725.             memcpy((char*)_astNvodCell[_iRefSvcNums].refScvName,(char*)i_pstSdt[i].chinese.service_name,18);
  726. _astNvodCell[_iRefSvcNums].refScvName[18]='';
  727. _astNvodCell[_iRefSvcNums].refScvName[19]='';
  728.             
  729. if(_astNvodCell[_iRefSvcNums].shiftSvcNum > 0)
  730. {
  731. _astNvodCell[_iRefSvcNums].TsID = i_pstSdt[i].TimeShift[0].TS_ID;
  732. }
  733. else
  734. {
  735. _astNvodCell[_iRefSvcNums].TsID = 0;
  736. }
  738. for(loop = 0; loop < _astNvodCell[_iRefSvcNums].shiftSvcNum; loop ++)
  739. {
  740. _astNvodCell[_iRefSvcNums].shiftSvc[loop].tsId = i_pstSdt[i].TimeShift[loop].TS_ID;
  741. _astNvodCell[_iRefSvcNums].shiftSvc[loop].netId = i_pstSdt[i].TimeShift[loop].OrgnetID;
  742. _astNvodCell[_iRefSvcNums].shiftSvc[loop].svcId = i_pstSdt[i].TimeShift[loop].ServiceID;
  743. }
  744. _iRefSvcNums ++;
  745. }
  746. #if 0
  747. else if(i_pstSdt[i].service_type == 0x05)
  748. {
  749. if(_iTotalShiftSvcNums >= KB_SI_MAX_REF_SVC_NUMS * KB_SI_MAX_SHIFT_SVC_NUMS)
  750. continue;
  751. _alShiftSvc[_iTotalShiftSvcNums] = 
  752. ( ((UINT32)i_pstSdt[i].service_id << 16) & 0xffff0000 ) | (UINT32)i_pstSdt[i].reference_service_id;
  753. _iTotalShiftSvcNums ++;
  754. }
  755. #endif
  756. }
  757. }
  760. static void KD_SrchAdjustNvod(void)
  761. {
  762. int i;
  763. //unsigned long temp;
  764. //int loop, j;
  766. //int sum;
  768. //KB_SIRefSvcCell refSvc;
  769. #if 0
  770. sum = 0;
  771. memset(&refSvc,0,sizeof(KB_SIRefSvcCell));
  772. for(i = 0; i < _iRefSvcNums; i ++)
  773. {
  774. refSvc.refScvId = _astNvodCell[i].refScvId;
  775. refSvc.TsID = _astNvodCell[i].TsID;
  776. refSvc.freq = _astNvodCell[i].freq;
  777. refSvc.symb = _astNvodCell[i].symb;
  778. refSvc.qam  = _astNvodCell[i].qam;
  779. refSvc.shiftSvcNum = 0;
  780.         strcpy((char*)refSvc.refScvName,(char*)_astNvodCell[i].refScvName);
  781.         
  782. for(j = 0; j < _astNvodCell[i].shiftSvcNum; j ++)
  783. {
  784. temp = ( ((UINT32)_astNvodCell[i].shiftSvc[j].svcId << 16) & 0xffff0000 ) | (UINT32)_astNvodCell[i].refScvId;
  785. for(loop = 0; loop < _iTotalShiftSvcNums; loop ++)
  786. {
  787. if(temp == _alShiftSvc[loop])
  788. break;
  789. }
  790. if(loop < _iTotalShiftSvcNums)
  791. {
  792. refSvc.shiftSvc[refSvc.shiftSvcNum].tsId = _astNvodCell[i].shiftSvc[j].tsId;
  793. refSvc.shiftSvc[refSvc.shiftSvcNum].netId = _astNvodCell[i].shiftSvc[j].netId;
  794. refSvc.shiftSvc[refSvc.shiftSvcNum].svcId = _astNvodCell[i].shiftSvc[j].svcId;
  795. refSvc.shiftSvcNum ++;
  796. }
  797. }
  798. if(refSvc.shiftSvcNum > 0)
  799. {
  800. memcpy(&_astNvodCell[sum], &refSvc, sizeof(KB_SIRefSvcCell));
  801. sum ++;
  802. }
  804. }
  805. _iRefSvcNums = sum;
  806. #endif
  807. for(i = 0; i < _iRefSvcNums; i ++)
  808. {
  809. KB_DBSaveNvodInfo(_astNvodCell[i]);
  810. }
  811. }
  812. /****///wisco
  813. int dtv_NUM,radio_NUM;
  814. int get_dtv_num(void)
  815. {
  816. int tv_no;
  817. tv_no = dtv_NUM;
  818. dtv_NUM = 0;
  819. return tv_no;
  820. }
  821. int get_radio_num(void)
  822. {
  823. int r_no;
  824. r_no = radio_NUM;
  825. radio_NUM = 0;
  826. return r_no;
  827. }
  829. /****/
  830. static void KD_SrchDis(UINT32 nPara1, UINT32 nPara2, UINT8 nDisTypeEx, 
  831.                          UINT8 nDisType)
  832. {    
  833. //int i;
  834. //int count;
  836.     KB_OSPMsgNode msgNode;
  838. memset(&msgNode,0,sizeof(KB_OSPMsgNode));
  840.     switch(nDisType)
  841.     {
  842.     case KB_SEARCH_DIS_PGMNUM:         
  843.  {
  844.   KB_OSPMsgNode movie_msg;
  846.      printf("-=KB_SEARCH_DIS_PGMNUM=-n");
  847.             msgNode.Word1 = J_AV_SEARCH_MODULE;
  848.      msgNode.Word2 = KB_SEARCH_MSG_UPDATE_AVPGM_NUM;
  849.           msgNode.Word3 = nPara1;
  850.      msgNode.Word4= nPara2;
  851.             dtv_NUM = (int)msgNode.Word3;
  852.             radio_NUM= (int)msgNode.Word4;
  854.      //send msg to movie client
  855.      movie_msg.Word1= KB_MOVIE_LC_TO_MOVIE;
  856.      movie_msg.Word2=20;
  857.      kb_machblue_task_post(&movie_msg);
  858.       }
  859.         break;
  860.     case KB_SEARCH_DIS_HELPHINT: 
  861. printf("-=KB_SEARCH_DIS_HELPHINT: nDisTypeEx=%d=-n", nDisTypeEx);
  862.         {
  863. msgNode.Word1 = J_AV_SEARCH_MODULE;
  864.    msgNode.Word2 = KB_SEARCH_MSG_UPDATE_HINT;
  865.    msgNode.Word3 = nDisTypeEx;
  866. if (nDisTypeEx!=2)
  867. {
  868. //send msg to movie client
  869. KB_OSPMsgNode movie_msg;
  871. movie_msg.Word1= KB_MOVIE_LC_TO_MOVIE;
  872. movie_msg.Word2=msgNode.Word3;
  873. kb_machblue_task_post(&movie_msg);
  874. }
  875. else
  876. {
  877. //send msg to movie client
  878. KB_OSPMsgNode movie_msg;
  880. movie_msg.Word1= KB_MOVIE_LC_TO_MOVIE;
  881. movie_msg.Word2=20;
  882. kb_machblue_task_post(&movie_msg);
  883. }
  884.         }
  885.         break;
  887.     case KB_SEARCH_DIS_PLANHINT:
  888. printf("-=KB_SEARCH_DIS_PLANHINT, nPara1:%ld=-n", nPara1);
  889.         {
  890. if (0 == nPara2)
  891. {
  892.             msgNode.Word1 = J_AV_SEARCH_MODULE;
  893.             msgNode.Word2 = KB_SEARCH_MSG_UPDATE_PROGRESS;
  894.             msgNode.Word3 = (UINT32)nPara1;
  895.             //KB_MENUTranslateMsg(&msgNode);
  896. }
  897.         }
  898.         break;
  899. case KB_SEARCH_DIS_FREQ:
  900. printf("-=KB_SEARCH_DIS_FREQ:nPara2=%ld=-n", nPara2);
  901. {
  904. if (0 == nPara1)
  905. {
  906.  KB_OSPMsgNode movie_msg;
  907.  
  908.         msgNode.Word1 = J_AV_SEARCH_MODULE;
  909.         msgNode.Word2 = KB_SEARCH_MSG_UPDATE_FREQ;
  910.         msgNode.Word3 = (UINT32)nPara2;
  911.        
  912.  //send msg to movie client
  913.  movie_msg.Word1= KB_MOVIE_LC_TO_MOVIE;
  914.  movie_msg.Word2=msgNode.Word3;
  915.  kb_machblue_task_post(&movie_msg);
  916. }
  917. }
  918. break;
  919. default:
  920. break;
  921.     }
  922. }
  924. static void   KD_SrchSetFre(UINT8 nSrchMode)
  925. {
  926. UINT8 i;
  927.     KB_DMDTunerParameters tTs;
  929. switch(nSrchMode)
  930. {
  931.   case  KB_SEARCH_IN_TS:
  932. gSrchFre[0] = gSrchApp.tsParams;
  933. gSrchFreNum   = 1;
  935. gSrchFre[0].frequency=gSrchApp.tsParams.frequency;
  936. gSrchFre[0].type = DMD_TYPE_QAM;
  937. gSrchFre[0].inversion = INVERSION_AUTO;
  938. gSrchFre[0].details.qam.symbolRatekSs = 6875;
  939. gSrchFre[0].details.qam.modulation = QAM_64;
  940. break;
  942. case KB_SEARCH_IN_NET:
  943. KB_SIStopAllSection();
  945. KB_DMDGetSignalParameters(&tTs);
  946.         if (memcmp(&tTs,&gSrchApp.tsParams,sizeof(KB_DMDTunerParameters)) != 0)
  947.         {
  948. KB_DMDDropSignal();
  949. //printf("-=KD_SrchSetFre:gSrchApp.tsParams.frequency=%ld=-n", gSrchApp.tsParams.frequency);
  950. KB_DMDConnectSignal(&gSrchApp.tsParams);
  951.         }
  953. KB_SIGetNit(0x10, &g_srchNit, KB_SI_RECEIVE_ONCE, -1);
  954. gSrchApp.srchState = KB_SEARCH_WAITING_NIT;
  955. break;
  957. case KB_SEARCH_IN_WHOLE_NET:
  958. gSrchFreNum   = WHOLE_NET_FREQ_SUM;
  960. for(i=0; i<gSrchFreNum; i++)
  961. {
  962. gSrchFre[i].frequency = g_WholeNetFreqs[i]* 1000;
  963. gSrchFre[i].type = DMD_TYPE_QAM;
  964.     gSrchFre[i].inversion = INVERSION_AUTO;
  965. gSrchFre[i].details.qam.symbolRatekSs = 6875;
  966. gSrchFre[i].details.qam.modulation = QAM_64;
  967. }
  968. break;
  970. default:
  971. break;
  972. }
  974. }
  976. static void KD_SrchToNext(void)
  977. {
  978. UINT8  bHintProgress;
  979. UINT32 wFreqToShow;
  981. if (gSrchFreInx < gSrchFreNum )
  982. {
  983. wFreqToShow = gSrchFre[gSrchFreInx].frequency/100;
  984.     KD_SrchDis(0,wFreqToShow,KB_SEARCH_DISABLED,KB_SEARCH_DIS_FREQ);
  986. bHintProgress = gSrchFreInx + 1;
  987. if (bHintProgress != gSrchFreNum)
  988. {
  989. bHintProgress = (bHintProgress * 100)/ (gSrchFreNum ) ;
  990. KD_SrchDis(bHintProgress, 0, KB_SEARCH_DISABLED, KB_SEARCH_DIS_PLANHINT);
  991. }
  992. else
  993. {
  994. if (gSrchApp.srchMode == KB_SEARCH_IN_WHOLE_NET)
  995. {
  996. bHintProgress = ((gSrchFreInx * 100) + 50)/ (gSrchFreNum ) ;
  997. KD_SrchDis(bHintProgress, 0, KB_SEARCH_DISABLED, KB_SEARCH_DIS_PLANHINT);
  998. }
  999. }
  1001. KD_SrchParseInit(
  1002. (unsigned short)(gSrchFre[gSrchFreInx].frequency/100),
  1003. (unsigned short)(gSrchFre[gSrchFreInx].details.qam.symbolRatekSs), 
  1004. (unsigned char)gSrchFre[gSrchFreInx].details.qam.modulation);
  1006. KB_SIStopAllSection();
  1008. bCurrentFreqDtvNum =0;
  1009. bCurrentFreqMusicNum =0;
  1011. KB_DMDDropSignal();
  1012. //printf("-=KD_SrchToNext:gSrchFre[%d].frequency=%ld=-n", gSrchFreInx, gSrchFre[gSrchFreInx].frequency);
  1013. gSrchApp.tsParams = gSrchFre[gSrchFreInx];
  1014. KB_DMDConnectSignal(&gSrchFre[gSrchFreInx]);
  1016. gSrchApp.srchState = KB_SEARCH_WAITING_CNT;
  1018. gSrchFreInx++;
  1020. }
  1021. else
  1022. {
  1023. KD_Srchend();
  1025. }
  1026. }
  1028. static void KD_SrchSaveResult(void)
  1029. {
  1030. KB_DBAddPrgInfo(gSrchPrg,gSrchApp.svcIDnum,
  1031.                 &bCurrentFreqDtvNum,&bCurrentFreqMusicNum);
  1033. gSrchApp.dtvNum += bCurrentFreqDtvNum;
  1034. gSrchApp.radNum += bCurrentFreqMusicNum;
  1036.     //因此, search搜索完成界面,只有视频、音频的更新
  1037.        KD_SrchDis(bCurrentFreqDtvNum, bCurrentFreqMusicNum, KB_SEARCH_DISABLED, 
  1038.               KB_SEARCH_DIS_PGMNUM);    
  1040. }
  1043. static void KD_Srchend(void)
  1044. {
  1045. gSrchApp.srchState = KB_SEARCH_WAITING_EXIT;
  1047. KD_SrchAdjustNvod();
  1049. KD_SrchDis(100, 0, KB_SEARCH_DISABLED, KB_SEARCH_DIS_PLANHINT);
  1050.      //KD_SrchDis(0, 0, KB_SEARCH_HINT7, KB_SEARCH_DIS_HELPHINT);
  1052. KB_DBSavePrgInfo(1);
  1054. switch(gSrchApp.srchMode)
  1055. {
  1056. case KB_SEARCH_IN_TS:     
  1057. KD_SrchDis(0, 0, KB_SEARCH_HINT8, KB_SEARCH_DIS_HELPHINT);
  1058. break;
  1060. case KB_SEARCH_IN_NET: 
  1061. KD_SrchDis(0, 0, KB_SEARCH_HINT9, KB_SEARCH_DIS_HELPHINT);
  1062. break;
  1064. case KB_SEARCH_IN_WHOLE_NET:
  1065. KD_SrchDis(0, 0, KB_SEARCH_HINT10, KB_SEARCH_DIS_HELPHINT);
  1066. break;
  1068. default:
  1069. break;
  1070. }
  1072. KB_DTVSetPreChnnl();
  1073. }
  1076. INT32 *KB_SrchGetWholeFreq(void)
  1077. {
  1078. return g_WholeNetFreqs;
  1079. }
  1081. KB_DMDTunerParameters *KB_SrchGetSrchFre(void)
  1082. {
  1083.  return gSrchFre;
  1084. }
  1086. T_SEARCH_PARA *KB_SrchGetSrchApp(void)
  1087. {
  1088. return  &gSrchApp;    
  1089. }
  1090. //added by whale 07/07/12 start
  1091. int KB_SrchGetNvodRefSrvNum(void)
  1092. {
  1093. return _iRefSvcNums;
  1094. }
  1095. //added by whale 07/07/12 end
  1097. /* EOF */