edm/jb/daoru.php

<?php 

/**
 * 导入客户信息，导出客户信息
 */
require_once (__DIR__ . '/../config/config_db.php');
include_once "class.mysql.php";
$dbms = 'mysql';     //数据库类型
$host = 'localhost'; //数据库主机名
$DB_Database = $dbName = $_ONU_CONFIG['_db_conf']['db_name'];
$user = $_ONU_CONFIG['_db_conf']['user'];
$pass = $_ONU_CONFIG['_db_conf']['pwd'];
$db_charset = "utf8";

$db = new Daopdo($host, $user, $pass, $dbName, $db_charset);

$data_sql = "select id, sql_content from ly_im_data_tmp ";


while (1) {
	
	$db->query($data_sql);
	if( $db->next_record() ) {
		$data_array = $db->Record;
		if( count($data_array) > 0){
			foreach ($data_array as $k => $v) {
				$sql_content_array = unserialize($v['sql_content']);
				$tabname = $sql_content_array['tabname'];
				$exc = $sql_content_array['exc'];
				$data = $sql_content_array['data'];
              
				if($tabname == 'ly_customer'){
					$data['uname'] = addslashes($data['uname']);
					$sql  = "update ly_customer set uname='{$data['uname']}',group_name='{$data['group_name']}',country = '{$data['country']}',city = '{$data['city']}',tel='{$data['tel']}' where uid='{$data['uid']}' and email='{$data['email']}';";
                  	$db->query($sql);
					$id = $v['id'];
					$del_sql = "DELETE FROM ly_im_data_tmp WHERE id = $id";
					$db->query($del_sql);
					echo $id.PHP_EOL;
				}
				

			}
		}
		
	}
  sleep(60);
}



?>