TargetSaleMailConnector::getData

public function getData()
	{
		$productIds = array();

		if (is_array($this->getFieldValue('PRODUCTS')) && count($this->getFieldValue('PRODUCTS')))
		{
			$productIds = array_values($this->getFieldValue('PRODUCTS'));
		}

		$userProducts = array();

		foreach ($productIds as $productId)
		{
			$response = BitrixSaleBigdataCloud::getPotentialConsumers($productId);

			if (!empty($response['users']))
			{
				foreach ($response['users'] as $userId)
				{
					$userProducts[(string) $userId][] = $productId;
				}
			}
		}

		$rows = array();

		if (!empty($userProducts))
		{
			$result = BitrixMainUserTable::getList(array(
				'select' => array('USER_ID' => 'ID', 'NAME', 'EMAIL'),
				'filter' => array(
					'=ID' => array_keys($userProducts)
				)
			));

			while ($row = $result->fetch())
			{
				$row['PRODUCTS'] = $userProducts[$row['USER_ID']];

				$rows[] = $row;
			}
		}

		return $rows;
	}