268 void SmsReceiveHandler::CombineMessagePart(const std::shared_ptr<SmsReceiveIndexer> &indexer)  in CombineMessagePart()  argument
271     if ((indexer == nullptr) || (pdus == nullptr)) {  in CombineMessagePart()
280     if (indexer->IsSingleMsg()) {  in CombineMessagePart()
281         string pdu = StringUtils::StringToHex(indexer->GetPdu());  in CombineMessagePart()
284         if (!CombineMultiPageMessage(indexer, pdus, reliabilityHandler)) {  in CombineMessagePart()
290     if (indexer->GetIsWapPushMsg()) {  in CombineMessagePart()
292             auto rawWapPushUserData = indexer->GetRawWapPushUserData();  in CombineMessagePart()
293             if (!smsWapPushHandler_->DecodeWapPushPdu(indexer, rawWapPushUserData)) {  in CombineMessagePart()
300     reliabilityHandler->SendBroadcast(indexer, pdus);  in CombineMessagePart()
303 bool SmsReceiveHandler::CombineMultiPageMessage(const std::shared_ptr<SmsReceiveIndexer> &indexer,  in CombineMultiPageMessage()  argument
307     int msgSeg = static_cast<int>(indexer->GetMsgCount());  in CombineMultiPageMessage()
311     predicates.EqualTo(SmsSubsection::SENDER_NUMBER, indexer->GetOriginatingAddress())  in CombineMultiPageMessage()
313         ->EqualTo(SmsSubsection::SMS_SUBSECTION_ID, std::to_string(indexer->GetMsgRefId()))  in CombineMultiPageMessage()
315         ->EqualTo(SmsSubsection::SIZE, std::to_string(indexer->GetMsgCount()));  in CombineMultiPageMessage()
322             reliabilityHandler->DeleteMessageFormDb(indexer->GetMsgRefId());  in CombineMultiPageMessage()
333     UpdateMultiPageMessage(indexer, pdus);  in CombineMultiPageMessage()
338 … const std::shared_ptr<SmsReceiveIndexer> &indexer, std::shared_ptr<std::vector<std::string>> pdus)  in UpdateMultiPageMessage()  argument
340     if ((indexer == nullptr) || (pdus == nullptr) || (pdus->empty())) {  in UpdateMultiPageMessage()
357         if (!indexer->GetIsWapPushMsg()) {  in UpdateMultiPageMessage()
368     indexer->SetVisibleMessageBody(messagBody);  in UpdateMultiPageMessage()
369     indexer->SetRawUserData(userDataRaw);  in UpdateMultiPageMessage()
370     if (indexer->GetIsWapPushMsg()) {  in UpdateMultiPageMessage()
371         indexer->SetRawWapPushUserData(rawWapPushUserData);  in UpdateMultiPageMessage()
396 bool SmsReceiveHandler::AddMsgToDB(const std::shared_ptr<SmsReceiveIndexer> indexer)  in AddMsgToDB()  argument
398     if (indexer == nullptr) {  in AddMsgToDB()
405     bucket.Put(SmsSubsection::RECEIVER_NUMBER, indexer->GetOriginatingAddress());  in AddMsgToDB()
406     bucket.Put(SmsSubsection::SENDER_NUMBER, indexer->GetOriginatingAddress());  in AddMsgToDB()
407     bucket.Put(SmsSubsection::START_TIME, std::to_string(indexer->GetTimestamp()));  in AddMsgToDB()
408     bucket.Put(SmsSubsection::END_TIME, std::to_string(indexer->GetTimestamp()));  in AddMsgToDB()
409     bucket.Put(SmsSubsection::REW_PUD, StringUtils::StringToHex(indexer->GetPdu()));  in AddMsgToDB()
411     bucket.Put(SmsSubsection::FORMAT, indexer->GetIsCdma() ? SMS_TYPE_CDMA : SMS_TYPE_GSM);  in AddMsgToDB()
412     bucket.Put(SmsSubsection::DEST_PORT, indexer->GetDestPort());  in AddMsgToDB()
413     bucket.Put(SmsSubsection::SMS_SUBSECTION_ID, indexer->GetMsgRefId());  in AddMsgToDB()
414     bucket.Put(SmsSubsection::SIZE, indexer->GetMsgCount());  in AddMsgToDB()
415     bucket.Put(SmsSubsection::SUBSECTION_INDEX, indexer->GetMsgSeqId());  in AddMsgToDB()
418     indexer->SetDataBaseId(dataBaseId);  in AddMsgToDB()