Андрей Николаев (Все сообщения пользователя)

if ($arFields["IBLOCK_ID"] == 14)
{
   ob_start();
   echo "<pre>".PHP_EOL;
   var_dump($arFields);
   file_put_contents($_SERVER['DOCUMENT_ROOT'].'/dbg.txt', ob_get_clean(), FILE_APPEND);

/**
 * @var array Список модулей, который нужны для работы
 */
$arRequiredModules = [
   'mail',
   'rest',
   'tasks',
   'disk',
   'blog',
   'socialnetwork',
];

foreach ($arRequiredModules as $module)
{
   if ( !\Bitrix\Main\Loader::IncludeModule($module) )
   {
      die('Не все обязательные модули подключены');
   }
}

/**
 * @var int Идентификатор обрабатываемого письма 
 */
$iMailMessageId = 14;

/**
 * @var array Массив обрабатываемых писем
 */
$arMails = [];

/**
 * @var CDBResult
 */
$resMailMessage = \CMailMessage::GetList(array('ID' => 'DESC'), ['ID'=>$iMailMessageId]);

while( $arMessage = $resMailMessage->fetch() )
{
   $arMails[ $arMessage['ID'] ] = [
      'ID'          => $arMessage['ID'],
      'SUBJECT'     => $arMessage['SUBJECT'],
      'BODY'        => $arMessage['BODY'],
      'ATTACHMENTS' => [],
   ];
}

$arMailIds = array_keys($arMails);


if ( !empty($arMailIds) )
{
   $attachment = new \CMailAttachment();

   foreach ($arMailIds as $iMessageId)
   {
      $resAttachments = $attachment->GetList(
         ['ID' => 'DESC'],
         ['MESSAGE_ID' => $iMessageId]
      );
      while( $arAttachment = $resAttachments->fetch() )
      {
         $arMails[ $arAttachment['MESSAGE_ID'] ]['ATTACHMENTS'][ $arAttachment['FILE_ID'] ] = [
            'ID'   => $arAttachment['FILE_ID'],
            'NAME' => $arAttachment['FILE_NAME'],
         ];
      }
   }
}

foreach ($arMails as $arMessage)
{
   $arBlogPostFields = [
      "TITLE"          => $arMessage['SUBJECT'],
      "DETAIL_TEXT"    => $arMessage['BODY'],
      "DATE_PUBLISH"   => date('d.m.Y H:i:s'),
      "PUBLISH_STATUS" => "P",
      "CATEGORY_ID"    => "",
      "PATH"           => "/company/personal/user/1/blog/#post_id#/",
      "URL"            => "admin-blog-s1",
      "SOCNET_RIGHTS"  => ['G2'],
      "=DATE_CREATE"   => "now()",
      "AUTHOR_ID"      => 1,
      "BLOG_ID"        => 1,
   ];

   $iPostId = \CBlogPost::Add($arBlogPostFields);

   if ( empty($iPostId) )
   {
      var_dump('Error'.($APPLICATION->LAST_ERROR));
      continue;
   }

   $arAdditionalFields = [];

   if (
      isset($arMessage["ATTACHMENTS"])
      && \Bitrix\Main\Config\Option::get('disk', 'successfully_converted', false)
      && ($storage = \Bitrix\Disk\Driver::getInstance()->getStorageByUserId($USER->GetID()))
      && ($folder = $storage->getFolderForUploadedFiles())
   )
   {
      // upload to storage
      $arResultFile = array();

      foreach($arMessage["ATTACHMENTS"] as $id => $arFileData)
      {
         $arFile = \CFile::MakeFileArray($id);

         if(is_array($arFile))
         {
            $file = $folder->uploadFile(
               $arFile, // file array
               array(
                  'NAME' => $arFileData["NAME"],
                  'CREATED_BY' => $USER->GetID()
               ),
               array(),
               true
            );

            if ($file)
            {
               $arResultFile[] = \Bitrix\Disk\Uf\FileUserType::NEW_FILE_PREFIX.$file->getId();
            }
         }
      }

      if (!empty($arResultFile)) // update post
      {
         $arAdditionalFields = [
            "HAS_PROPS"         => "Y",
            "UF_BLOG_POST_FILE" => $arResultFile
         ];

         CBlogPost::Update($iPostId, $arAdditionalFields);
      }
   }

   $arAdditionalFields['ID'] = $iPostId;


   $arBlogPostFields = array_merge($arBlogPostFields,$arAdditionalFields);

   $arParamsNotify = [
      "bSoNet"  => true,
      "UserID"  => 1,
      "user_id" => 1
   ];

   \CBlogPost::Notify($arBlogPostFields, array(), $arParamsNotify);

   echo 'ok';
}

   if($arParams["INCLUDE_IBLOCK_INTO_CHAIN"] && isset($arResult["NAME"]))
   {
      if($arParams["ADD_SECTIONS_CHAIN"] && is_array($arResult["SECTION"]))
         $APPLICATION->AddChainItem(
            $arResult["NAME"]
            ,strlen($arParams["IBLOCK_URL"]) > 0? $arParams["IBLOCK_URL"]: $arResult["LIST_PAGE_URL"]
         );
      else
         $APPLICATION->AddChainItem($arResult["NAME"]);
   }

   if($arParams["ADD_SECTIONS_CHAIN"] && is_array($arResult["SECTION"]))
   {
      foreach($arResult["SECTION"]["PATH"] as $arPath)
      {
         if ($arPath["IPROPERTY_VALUES"]["SECTION_PAGE_TITLE"] != "")
            $APPLICATION->AddChainItem($arPath["IPROPERTY_VALUES"]["SECTION_PAGE_TITLE"], $arPath["~SECTION_PAGE_URL"]);
         else
            $APPLICATION->AddChainItem($arPath["NAME"], $arPath["~SECTION_PAGE_URL"]);
      }
   }