Tweet
<?php
namespace Espo\Custom\Jobs;
use Espo\ORM\Entity;
class CareJobs extends \Espo\Core\Jobs\Base
{
public function run()
{
ini_set('memory_limit','16M');
$fileName = 'data/xxxx/care.csv';
if(!file_exists($fileName) || !is_readable($fileName))
{
$GLOBALS['log']->info( "CareJobs Nothing to process");
return false;
}
$GLOBALS['log']->warning( "Begin Jobs CareJobs");
if (($handle = fopen( $fileName, "r")) !== false) {
$entityManager = $this->getEntityManager();
$time_start = microtime(true);
$header = fgetcsv($handle);
while (($data = fgetcsv($handle, 2000, ",")) !== false) {
$practriceArray = explode("_", $data[0] );
$practrice = $practriceArray[1];
...<?php
namespace Espo\Custom\Jobs;
use Espo\ORM\Entity;
use phpseclib\Net\SFTP;
class SftpJobs extends \Espo\Core\Jobs\Base
{
public function run()
{
$GLOBALS['log']->warning( "Start SftpJobs : " );
$path = "/home/path/CSV/";
$fileDate = date('Y-n', strtotime(date('Y-m')." -1 month"));
$fileName = "xxx-" .$fileDate .".csv";
$file = $path .$fileName;
$sftp = new SFTP('10.10.10.10', 2121 );
$sftp_login = $sftp->login('login', 'password');
if($sftp_login) {
if( $sftp->file_exists( $file)) {
$GLOBALS['log']->warning( 'SftpJobs : File Exist' );
$sftp->get($file, 'data/path/care.csv');
$sftp->rename($file, '/home/path/CSV/Backup/' .$fileName);
$GLOBALS['log']->warning( 'SftpJobs : File Downloaded & Moved To Backup : ' .$fileName );
$entityManager = $this->getEntityManager();
$job = $entityManager->getEntity('Job');
$job->set([
'name' => 'Care Jobs',
'status' => 'Pending',
'serviceName' => 'CareJobs',
'methodName' => 'run',
'data' => NULL, // array('' => ''),
'executeTime' => date('Y-m-d H:i:s',strtotime(date("Y-m-d H:i:s")." +5 minutes")),
'scheduledJobId' => '5c7e592209b492e20',
]);
$entityManager->saveEntity($job);
}else{
$GLOBALS['log']->warning( 'SftpJobs : File Dont Exist');
}
}else{
$GLOBALS['log']->warning( 'SftpJobs : Cannot login into your server !');
}
$GLOBALS['log']->warning( "End SftpJobs : " );
return true;
}
}$header = fgetcsv($handle);
while (($data = fgetcsv($handle, 2000, ",")) !== false) {
//$data = mb_convert_encoding($data, 'ISO-8859-1','ISO-8859-1');
$practriceArray = explode("_", $data[0] );
$practrice = $practriceArray[1];
$inamiTo = substr($inamiNumberTo, 0, 8);
// ACCOUNT
$account = $entityManager->getRepository('Account')->where([ 'practrice' => $practrice ])->findOne();
if (!$account){
$account = $entityManager->getEntity('Account');
$account->set([
'name' => $practrice,
'practrice' => $practrice,
'teamsIds' => $teamsIds,
'assignedUserId' => '1'
]);
$entityManager->saveEntity($account);
}//else{
// foreach ($account->get('teams') as $team) {
// $teamsIds[] = $team->id;
// }
//}
// CONTACT
$contact = $entityManager->getRepository('Contact')->where([ 'inami' => $inami ])->findOne();
if (!$contact){
$contact = $entityManager->getEntity('Contact');
$contact->set([
'firstName' => ucwords(mb_strtolower($data[16])),
'lastName' => mb_strtoupper( $data[15]) ,
'inamiNumber' => $inamiNumber,
'practrice' => $practrice,
'dateFirstCare' => $dt->format('Y-m-d'),
'teamsIds' => $teamsIds,
'assignedUserId' => '1'
]);
$entityManager->saveEntity($contact);
}
// PATIENT
$patient = $entityManager->getRepository('Patient')->where([ 'nationalNumber' => $nationalNumber ])->findOne();
if (!$patient){
$patient = $entityManager->getEntity('Patient');
$patient->set([
'firstName' => ucwords(mb_strtolower($data[2] )),
'lastName' => mb_strtoupper($data[1] ),
'addressStreet' => $addressStreet,
'addressPostalCode' => $addressPostalCode,
'addressCity' => $addressCity,
'nationalNumber' => $nationalNumber,
'cg1' => $cg1,
'cg2' => $cg2,
'patHealth' => $patHealth,
'score' => $score,
'dateFirstCare' => $dt->format('Y-m-d'),
'teamsIds' => $teamsIds,
'assignedUserId' => '1'
]);
$entityManager->saveEntity($patient);
}
// CARE
$care = $entityManager->getEntity('Care');
$care->set(array(
'name' => $patient->get('name'),
'practrice' => $practrice,
'dateTime' => $dateTime,
));
$entityManager->saveEntity($care);
$convention = $entityManager->getRepository('Convention')->where([ 'name' => $year .$month ])->findOne();
if (!$convention){
$convention = $entityManager->getEntity('Convention');
$convention->set([
'name' => $year .$month,
'dateStart' => date('Y-m-01', strtotime($care->get('dateTime'))),
'dateEnd' => date('Y-m-t', strtotime($care->get('dateTime'))),
'teamsIds' => $teamsIds,
'assignedUserId' => '1',
]);
$entityManager->saveEntity($convention);
}
if (!$entityManager->getRepository('Convention')->isRelated($convention, 'contacts', $contact)){
$entityManager->getRepository('Convention')->relate($convention, 'contacts', $contact);
}
}
fclose($handle);
}
Comment