$sql_fields = [];
$data = $db::getRows("SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA='erp24' AND TABLE_NAME='orders_amo';");
- echo '<pre>';
- var_dump($data);
- echo '</pre>';
+// echo '<pre>';
+// var_dump($data);
+// echo '</pre>';
// $data = $db::getRows("SHOW COLUMNS FROM orders_amo");
- echo (" __ " . __LINE__);
+// echo (" __ " . __LINE__);
try {
foreach ($data as $col) {
- print "<br>\n";
- print "<br>\n";
+// print "<br>\n";
+// print "<br>\n";
$sql_fields[] = $col["column_name"];
//print_r($_SESSION["uping"]);
+ echo '<pre>';
+ if (!empty($deal0["_embedded"]["leads"])) {
+ var_dump(count($deal0["_embedded"]["leads"]));
+ } else {
+ echo 'нет записей';
+ }
+ echo '</pre>';
+
foreach($deal0["_embedded"]["leads"] ?? [] as $lid_id => $fieldarr) {
$amo_id=$fieldarr["id"];
$param_insert=array();
$i=0; $upper="";
foreach($result as $row =>$value) {
- if(!empty($sql_fields[$row]) and in_array($row,$update_fields) and !in_array($row,$unset_valiues) ) { // удаляем поля которых нет в таблице
+ if(in_array($row,$sql_fields) and in_array($row,$update_fields) and !in_array($row,$unset_valiues) ) { // удаляем поля которых нет в таблице
if($i!=0) { $sql_query.=","; $upper.=","; }
$sql_query.=" $row=:$row";
$upper .=" $row='$value' ";
if(!empty($result["nomer"])) {
try{
- echo" nomer=".$result["nomer"]." ";
+ echo" nomer=".$result["amo_id"]." ";
- $yes_in_table_sql=$db::getValue("SELECT id FROM orders_amo WHERE id=?",[(int)$result["nomer"]]);
+ $yes_in_table_sql=$db::getValue("SELECT id FROM orders_amo WHERE id=?",[(int)$result["amo_id"]]);
if(empty($yes_in_table_sql) ) {
// insert
- $z="INSERT INTO orders_amo (" . implode(", ", $insert_fields) . ", id, update_at) VALUES ('".implode("', '", $insert_values) ."' , '".$result["nomer"]."', NOW())";
+ $z="INSERT INTO orders_amo (" . implode(", ", $insert_fields) . ", id, update_at) VALUES ('".implode("', '", $insert_values) ."' , '".$result["amo_id"]."', NOW())";
$db::sql($z);
//$db::sql($z,$param_insert);
} else {
// update
if(!empty($sql_query)) {
- $z="UPDATE orders_amo SET $sql_query WHERE id='".$result["nomer"]."'";
+ $z="UPDATE orders_amo SET $sql_query WHERE id='".$result["amo_id"]."'";
$db::sql($z,$param);
//$db::sql($z,$param);
} // end
else {
- mess("Заказ $ami_id уже внесен в базу");
+ mess("Заказ $amo_id уже внесен в базу");
}
$mess["checks"] = ["start_time" => date("Y-m-d H:i:s", time() - 2 * 3600), "end_time" => date("Y-m-d H:i:s")];
// $mess["payment_types"] = false;
- $createChecks = CreateChecks::find()->where(['status' => '0'])->andWhere(['>', 'date', date('Y-m-d H:i:s', time() - 3 * 86400)])
+ //TODO ПОПРАВИТЬ ДАТУ ОТБОРА
+ $createChecks = CreateChecks::find()->where(['status' => '0'])->andWhere(['>', 'date', '2024-04-26'])
+// $createChecks = CreateChecks::find()->where(['status' => '0'])->andWhere(['>', 'date', date('Y-m-d H:i:s', time() - 3 * 86400)])
->orderBy(['date' => SORT_DESC])->limit(10)->all();
foreach ($createChecks as $createCheck) {
if (!empty($createCheck->kkm_id)) {
include_once(dirname(__DIR__, 2) . "/inc/base_new.php");
include_once(dirname(__DIR__, 2) . "/inc/design_new.php");
error_reporting(E_ALL);
-global $ACCESS_TOKEN;
+
try {
//include"templates/top.php";
$date1=mktime(0,0,0,date("n"),date("d",time()-86400),date("Y"));
$date2=mktime(0,0,0,date("n"),date("d"),date("Y"));
-include_once(dirname(__DIR__, 2) . "/inc/amo/amo_inc.php");
+global $ACCESS_TOKEN;
+include_once(dirname(__DIR__, 1) . "/../inc/amo/amo_inc.php");
$dt="updated_at";
$statuses=[38932165,142];
//$delivery__date='&filter['.$dt.'][from]='.$unix0.'&filter['.$dt.'][to]='.$date1.'';
$delivery__date='&filter[custom_fields_values][647935][from]='.$date1.'&filter[custom_fields_values][647935][to]='.$date2.'';
//&filter['.$dt.'][from]='.$date1.'&filter['.$dt.'][to]='.$date2.'
-
+$k=0;
foreach($statuses as $status) {
$deal0 = amo_rest($ACCESS_TOKEN, '/api/v4/leads?order[updated_at]=desc&limit=250&filter[statuses][0][pipeline_id]=4021495&filter[statuses][0][status_id]='.$status.''.$delivery__date.'', 'GET', []);