Живая лента

 
        global $USER;
        if(!is_object($USER)) $USER = new \CUser;
        $USER->Authorize(1);

        \Bitrix\Main\Loader::includeModule('mail');
        \Bitrix\Main\Loader::includeModule('rest');
        \Bitrix\Main\Loader::includeModule('tasks');
        \Bitrix\Main\Loader::includeModule('disk');
        \Bitrix\Main\Loader::includeModule('blog');
        \Bitrix\Main\Loader::includeModule('socialnetwork');
        \Bitrix\Main\Loader::includeModule('xdimport');

        $res = \CAgent::GetList(Array(), array("NAME" => "Posty::doit();"));
        while($arr = $res->NavNext(true, "agent_")){
            $arrAgent = $arr;
        }

        $agent_LAST_EXEC_timestamp = strtotime($arrAgent['LAST_EXEC']);

        $arFilter = array(
            'MAILBOX_ID' => 2,
            'FIELD_TO' => 'test@mail.ru',
        );

        $dbResult = \CMailMessage::GetList(array('ID' => 'DESC'), $arFilter);
        while($res = $dbResult->Fetch()){
            $date_insert_timestamp = strtotime($res['DATE_INSERT']);
            if($agent_LAST_EXEC_timestamp < $date_insert_timestamp){
                $result[] = array(
                    'ID' => $res['ID'],
                    'TITLE' => $res['SUBJECT'],
                    'DETAIL_TEXT' => $res['BODY'],
                );
            }
        }

        if($result){

            foreach ($result as $post){


                $arOrder = array('ID' => 'DESC');
                $arFilter = array('MESSAGE_ID' => $post['ID']);
                $attachment = new \CMailAttachment();
                $arrMessage = $attachment->GetList($arOrder, $arFilter);

                while ($row = $arrMessage->Fetch()){

                    $arrFileId[] = array(
                        'FILE_ID' => $row['FILE_ID'],
                        'FILE_NAME' => $row['FILE_NAME'],
                        'FILE_DATA' => $row['FILE_DATA'],
                    );

                }


                foreach ($arrFileId as $file){

                    if($file['FILE_ID']){
                        $fileParam = \CFile::GetFileArray($file['FILE_ID']);
                        $fileParam['NAME'] =  $file['FILE_NAME'];
                        $fileParam['CONTENT'] = $file['FILE_DATA'];

                        $param['USER_ID'] = 1;
                        $param['ENTITY_ID'] = 'BLOG_POST';
                        $param['FIELD_NAME'] = 'UF_BLOG_POST_FILE';


                        $newAttachId = \Bitrix\Tasks\Integration\Disk\Rest\Attachment::add(1, $fileParam, $param);
                        $newArrAttachData = \Bitrix\Tasks\Integration\Disk\Rest\Attachment::getById($newAttachId);
                        $arrAttachId[] = 'n' . $newArrAttachData['FILE_ID'];
                    }

                }

                $arFields= array(
                    "TITLE" => $post['TITLE'],
                    "DETAIL_TEXT" => $post['DETAIL_TEXT'],
                    "DATE_PUBLISH" => date('d.m.Y H:i:s'),
                    "UF_BLOG_POST_FILE" => ($arrAttachId) ? $arrAttachId : '',
                    "PUBLISH_STATUS" => "P",
                    "CATEGORY_ID" => "",
                    "PATH" => "/company/personal/user/1/blog/#post_id#/",
                    "URL" => "admin-blog-s1",
                    "PERMS_POST" => Array(),
                    "PERMS_COMMENT" => Array (),
                    "SOCNET_RIGHTS" => Array
                    (
                        "DR51"
                    ),
                    "=DATE_CREATE" => "now()",
                    "AUTHOR_ID" => 1,
                    "BLOG_ID" => 1,
                );

                $newID = CBlogPost::Add($arFields);
                $output['$newID'] = $newID;

                $arFields["ID"] = $newID;
                $arParamsNotify = Array(
                    "bSoNet" => true,
                    "UserID" => 1,
                    "user_id" => 1,
                );

                CBlogPost::Notify($arFields, array(), $arParamsNotify);

            }
        }

    

/**
 * @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';
}