Tweet
<?php
namespace Espo\Custom\Jobs;
use Espo\Core\ORM\{
Entity,
EntityManager,
ServiceFactory,
Jobs\Job,
};
use League\Flysystem\{
Filesystem,
PhpseclibV2\SftpConnectionProvider,
PhpseclibV2\SftpAdapter,
UnixVisibility\PortableVisibilityConverter,
};
class SftpJobs extends \Espo\Core\Jobs\Base
{
public function run()
{
$em = $this->getEntityManager();
$integration = $em->getEntity('Integration', 'sftp');
$filesystem = new Filesystem(
new SftpAdapter(
new SftpConnectionProvider(
$integration->get('host'), // host (required)
$integration->get('login'), // username (required)
$integration->get('password'), // password (optional, default: null) set to null if privateKey is used
null, // private key (optional, default: null) can be used instead of password, set to null if password is set
null, // passphrase (optional, default: null), set to null if privateKey is not used or has no passphrase
$integration->get('port'), // port (optional, default: 22)
false, // use agent (optional, default: false)
30, // timeout (optional, default: 10)
3, // max tries (optional, default: 4)
null, // host fingerprint (optional, default: null),
null, // connectivity checker (must be an implementation of 'League\Flysystem\PhpseclibV2\ConnectivityChecker' to check if a connection can be established (optional, omit if you don't need some special handling for setting reliable connections)
),
'/', // root path (required)
PortableVisibilityConverter::fromArray([
'file' => [
'public' => 0640,
'private' => 0604,
],
'dir' => [
'public' => 0740,
'private' => 7604,
],
])
));
$path = "/home/data/";
$fileDate = date('Y-n', strtotime(date('Y-m')." -1 month"));
$fileName = "file-" .$fileDate .".csv";
$file = $path .$fileName;
if ($filesystem->fileExists($file))
{
$content = $filesystem->read($file);
file_put_contents ( 'data/data.csv' , $content);
$filesystem->move($file, $path .'Backup/' .$fileName, [] );
}
return true;
}
}
Comment