LÁZÁR Imre AI Agent
c2cf6dab13
common_cadline_libraries (CRM hardlock/db/users classes; upstream cadline_web/cadcommonlib), maintenance/ (ARCHLine.XP license backend; upstream cadline_web/maintenance), maintenance2/. Vetted live files (byte-truth); upstream repos in PROVENANCE.md. NOTE: could be git submodules — kept as live files for byte-fidelity. Signed-off-by: LÁZÁR Imre <imre@illusion.hu> Assisted-by: claude-code@claude-opus-4-8
159 lines
7.4 KiB
PHP
159 lines
7.4 KiB
PHP
<?php
|
|
|
|
/*******************************************************************************
|
|
* Az eseményekre jelentkezések alapján a fizetéseket kikeresi az
|
|
* Instant Payment Terminal adatbázisából, és beírja a crm rendszerbe
|
|
******************************************************************************/
|
|
|
|
$message = "Sync Fizetés teszt";
|
|
|
|
mail('mate.nagy@cadline.hu', 'Cron', $message);
|
|
|
|
if (!isset($config)) {
|
|
require_once('config.php');
|
|
require_once('libraries/phpmailer/PHPMailerAutoload.php');
|
|
}
|
|
|
|
if (!class_exists('crm_users')) require_once("../common_cadline_libraries/crm_users.class.php");
|
|
include('config.course.php');
|
|
|
|
//if (!isset($jmdb)) { $jmdb=((isset($_GET['jmdb']) && in_array($_GET['jmdb'], array('jml','eng'))) ? $_GET['jmdb'] : 'jml'); }
|
|
//$jmdb='jml';
|
|
|
|
$msh->query("SELECT *
|
|
FROM `" . JMLADATBAZIS . "`.`alworkshops_application`
|
|
WHERE `published`='Y' AND `price_total`>0 AND (`pay_id` IS NULL OR `pay_id`=0) AND DATE(`date`)>='" . date('Y-m-d', time() - 86400 * _DAYS_) . "'
|
|
ORDER BY id DESC;");
|
|
$res = $msh->fetchAssoc();
|
|
|
|
if (count($res)) {
|
|
foreach ($res as $application) {
|
|
$msh->query("SELECT * FROM `pay_archline_hu`.`pos_transactions` WHERE `order_id`='" . $application['transaction_id'] . "' AND `remote_status`='Succeeded' AND `remote_message`='Succeeded' AND `payment_status`='completed' AND `transaction_status`='completed' LIMIT 1;");
|
|
$pay = $msh->fetchAssoc();
|
|
|
|
if (count($pay) && (int)$pay[0]['transaction_id'] > 0) {
|
|
$pay = $pay[0];
|
|
|
|
$msh->query("SELECT * FROM `" . JMLADATBAZIS . "`.`jml_users` WHERE id=" . (int)$application['user_id'] . " LIMIT 1;");
|
|
$user = $msh->fetchAssoc();
|
|
$user = $user[0];
|
|
|
|
$msh->query("SELECT * FROM `" . CRMADATBAZIS . "`.`users` WHERE nUserID=" . (int)$user['nUserID'] . " LIMIT 1;");
|
|
$crmUser = $msh->fetchAssoc();
|
|
$crmUser = $crmUser[0];
|
|
|
|
$msh->query("SELECT * FROM `" . JMLADATBAZIS . "`.`alworkshops_courses` WHERE id=" . (int)$application['course_id'] . " LIMIT 1;");
|
|
$course = $msh->fetchAssoc();
|
|
$course = $course[0];
|
|
|
|
$msh->query("SELECT * FROM `" . JMLADATBAZIS . "`.`alworkshops_switch` WHERE `alias`='" . $course['alias'] . "' LIMIT 1;");
|
|
$switch = $msh->fetchAssoc();
|
|
$switch = $switch[0];
|
|
|
|
$msh->query("SELECT * FROM `" . JMLADATBAZIS . "`.`jml_content` WHERE id=" . (int)$course['email_template'] . " LIMIT 1;");
|
|
$tmpl = $msh->fetchAssoc();
|
|
|
|
$msh->query("SELECT * FROM `" . CRMADATBAZIS . "`.`u_history` WHERE `nUserID`=" . (int)$user['nUserID'] . " AND `strAccno`='" . $application['transaction_id'] . "' LIMIT 1;");
|
|
$exist = $msh->fetchAssoc();
|
|
|
|
$nTopicID = 0;
|
|
if ($switch['workshop'] == 'Y') {
|
|
$nTopicID = _WORKSHOP_PRICE_;
|
|
}
|
|
if ($switch['kurzus'] == 'Y' && (int)$switch['level'] == 1) {
|
|
$nTopicID = _COURSE_PRICE_PRELIMINARY_;
|
|
}
|
|
if ($switch['kurzus'] == 'Y' && (int)$switch['level'] == 2) {
|
|
$nTopicID = _COURSE_PRICE_INTERMEDIATE_;
|
|
}
|
|
if ($switch['vizsga'] == 'Y' && (int)$switch['level'] == 1) {
|
|
$nTopicID = _COURSE_EXAM_PRICE_PRELIMINARY_;
|
|
}
|
|
if ($switch['vizsga'] == 'Y' && (int)$switch['level'] == 2) {
|
|
$nTopicID = _COURSE_EXAM_PRICE_INTERMEDIATE_;
|
|
}
|
|
if ($switch['vizsga'] == 'Y' && (int)$switch['level'] == 3) {
|
|
$nTopicID = _TUTOR_EXAM_PRICE_;
|
|
}
|
|
if ($switch['vizsga'] == 'Y' && (int)$switch['level'] == 4) {
|
|
$nTopicID = _TUTOR_EXAM_PRICE_;
|
|
}
|
|
|
|
if ($nTopicID > 0 && count($tmpl) && empty($exist)) {
|
|
$mit = array('{NAME}', '{TITLE}', '{START_DATE}', '{START_TIME}', '{FINISH_DATE}', '{FINISH_TIME}', '{LOCATION}', '{ATTENDEES}', '{PRICE}', '{PRICE_TOTAL}', '{VAT}');
|
|
$mire = array(
|
|
$user['name'], $course['title'],
|
|
($switch['kurzus'] === 'Y' && (int)$switch['level'] == 2 ? date("Y-m-d", _TIME_) : $course['start_date']),
|
|
($switch['kurzus'] === 'Y' && (int)$switch['level'] == 2 ? "" : $course['start_time']),
|
|
($switch['kurzus'] === 'Y' && (int)$switch['level'] == 2 ? date("Y-m-d", _TIME_ + (_LEASE_VALID_DAYS_ * 86400)) : $course['finish_date']),
|
|
($switch['kurzus'] === 'Y' && (int)$switch['level'] == 2 ? "" : $course['finish_time']),
|
|
$course['location'], $application['attendees'], $course['price'], $application['price_total'], $course['vat']
|
|
);
|
|
|
|
$msg = str_replace($mit, $mire, $tmpl[0]['introtext'] . $tmpl[0]['fulltext']);
|
|
|
|
$mail = new PHPMailer;
|
|
$mail->CharSet = 'UTF-8';
|
|
$mail->isSMTP();
|
|
$mail->Host = $mailconfig['Host'];
|
|
$mail->SMTPAuth = true;
|
|
$mail->Username = $mailconfig['Username'];
|
|
$mail->Password = $mailconfig['Password'];
|
|
$mail->SMTPSecure = $mailconfig['SMTPSecure'];
|
|
$mail->Port = $mailconfig['Port'];
|
|
$mail->isHTML(TRUE);
|
|
$mail->setFrom('info@cadline.hu');
|
|
$mail->addAddress($user['email']);
|
|
$mail->addBCC('webdeveloper@cadline.hu');
|
|
$mail->addBCC('marketing@cadline.hu');
|
|
$mail->Subject = $tmpl[0]['title'];
|
|
$mail->msgHTML($msg);
|
|
$mail->AltBody = strip_tags($msg);
|
|
$mail->send();
|
|
unset($mail);
|
|
|
|
crm_users::AddUserHistory(array(
|
|
'nUserID' => $user['nUserID'],
|
|
'nTopicID' => $nTopicID,
|
|
'dateEvent' => ($switch['kurzus'] === 'Y' && (int)$switch['level'] == 2 ? date('Y-m-d', _TIME_) : $course['start_date']),
|
|
'strInfo' => 'Barionon keresztül fizetett: ' . $pay['amount'] . ' ' . $pay['currency_code'],
|
|
'strPlace' => $switch['title'],
|
|
'datePaydate' => date('Y-m-d', _TIME_),
|
|
'strAccno' => $application['transaction_id'],
|
|
'applicationID' => (int)$application['id'],
|
|
));
|
|
|
|
$arrUpdate = array('pay_id' => (int)$pay['transaction_id']);
|
|
if ($application['berletem_van'] == 'N' && $switch['kurzus'] == 'Y' && in_array($switch['level'], array(1, 2))) $arrUpdate['berletem_van'] = 'Y';
|
|
$msh->update("`" . JMLADATBAZIS . "`.`alworkshops_application`", $arrUpdate, array('id' => (int)$application['id']));
|
|
|
|
crm_users::SetUserStatus($user['nUserID'], 8);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// lejárt jelentkezések unpublish-re állítása
|
|
$msh->query("SELECT s.`level`,s.`kurzus`,s.`workshop`,s.`vizsga`,s.`esemeny`,s.`webinair`,a.*,u.nUserID,c.`start_date`,s.`tanfsor`
|
|
FROM `" . JMLADATBAZIS . "`.`alworkshops_application` a
|
|
LEFT OUTER JOIN `" . JMLADATBAZIS . "`.`jml_users` u ON a.user_id=u.id
|
|
LEFT OUTER JOIN `" . JMLADATBAZIS . "`.`alworkshops_courses` c ON a.course_id=c.id
|
|
LEFT OUTER JOIN `" . JMLADATBAZIS . "`.`alworkshops_switch` s ON c.alias=s.alias
|
|
WHERE (a.pay_id IS NULL OR a.pay_id='') AND
|
|
a.`published`='Y' AND
|
|
a.`price_total`>0 AND
|
|
c.start_date>CURRENT_DATE AND
|
|
a.`date`<'" . date('Y-m-d H:i:s', _TIME_ - (_EXPIRE_TIME_MINUTES_ * 60)) . "';");
|
|
$res = $msh->fetchAssoc();
|
|
if (count($res)) {
|
|
foreach ($res as $row) {
|
|
// !!! Ha a fizetős workshop jelentkezés a utoljára vásárolt bérlet időszakába beleesik, akkor nem törli!!!
|
|
$currentLease = crm_users::GetValidLease((int)$row['nUserID'], (int)$row['level']);
|
|
if ($currentLease && $row['vizsga'] == 'N' && $row['start_date'] >= $currentLease['validFrom'] && $row['start_date'] <= $currentLease['validThrough'] && (int)$row['tanfsor'] > 0) {
|
|
continue;
|
|
}
|
|
|
|
$msh->update("`" . JMLADATBAZIS . "`.`alworkshops_application`", array('published' => 'N'), array('id' => (int)$row['id']));
|
|
}
|
|
}
|