EC-CUBEの顧客情報を、SugarCRMの取引担当者に変換して移行してみた

admin

11年前

わりとタイトルのままですが、EC-CUBEの顧客情報をSugarCRMを使って管理したいという要望が結構あるようなので試してみました。
実際にはプラグイン化して、EC-CUBEの登録時にSugarCRMに同期する感じかな？

&lt;?php
	//SugarCRMのURLとDBのID/PASS
    $url = &quot;http://www.sample.com/sugarcrm/soap.php?wsdl&quot;;
    $username = &quot;admin&quot;;
    $password = &quot;admin&quot;;

    //SOAPのライブラリファイルをダウンロードして
    require_once(&quot;./lib/nusoap.php&quot;);

    //WSDLで通信オブジェクトを生成
    $client = new nusoap_client($url, 'wsdl');

    //エラーがあったら表示して終了
    $err = $client-&gt;getError();
    if ($err)
    {
        echo '&lt;h2&gt;Constructor error&lt;/h2&gt;&lt;pre&gt;' . $err . '&lt;/pre&gt;';
        echo '&lt;h2&gt;Debug&lt;/h2&gt;&lt;pre&gt;' . htmlspecialchars($client-&gt;getDebug(), ENT_QUOTES) . '&lt;/pre&gt;';
        exit();
    }

    //ログイン配列を生成
    $login_parameters = array(
         'user_auth' =&gt; array(
              'user_name' =&gt; $username,
              'password' =&gt; md5($password),
              'version' =&gt; '1'
         ),
         'application_name' =&gt; 'SoapTest',
         'name_value_list' =&gt; array(
         ),
    );

	//ログイン
    $login_result = $client-&gt;call('login', $login_parameters);

	//ログイン結果を表示
    echo '&lt;pre&gt;';
    print_r($login_result);
    echo '&lt;/pre&gt;';

    //ログイン成功ならセッションIDが返ってくるので、それを使ってDB操作
    $session_id =  $login_result['id'];
    

    //DB接続情報を読み込む
    require_once &quot;./dsn.php&quot;;

    //EC-CUBEのデータベースにログインする。
    try {
      $pdo = new PDO('mysql:dbname='. $dsn['dbname'] .&quot;;host=&quot; . $dsn['host'], $dsn['user'], $dsn['pass']);
	} catch (PDOException $e) {
	  exit('データベースに接続できませんでした。' . $e-&gt;getMessage());
	}

	$stmt = $pdo-&gt;query('SET NAMES utf8');
	if (!$stmt) {
	  $info = $pdo-&gt;errorInfo();

	  exit($info[2]);
	}


	//EC-CUBEの全個客情報を持ってくる
	$stmt = $pdo-&gt;prepare('SELECT * FROM dtb_customer');
	$stmt-&gt;execute();


	if (!$stmt) {
	  $info = $pdo-&gt;errorInfo();

	  exit($info[2]);
	}

	while ($data = $stmt-&gt;fetch(PDO::FETCH_ASSOC)) {

		//ループ毎に顧客情報を配列にPUSHしていく
		$arr_data[] = array(
			
			//対応するフィールドが無かったらコメントアウトしておく。
			
			//array('name' =&gt;'id', 'value' =&gt; $data['']), 
			array('name' =&gt;'date_entered', 'value' =&gt; $data['create_date']), 
			array('name' =&gt;'date_modified', 'value' =&gt; $data['update_date']), 
			//array('name' =&gt;'modified_user_id', 'value' =&gt; $data['']), 
			//array('name' =&gt;'created_by', 'value' =&gt; $data['']), 
			array('name' =&gt;'description', 'value' =&gt; $data['note']), 
			//array('name' =&gt;'deleted', 'value' =&gt; $data['']), 
			//array('name' =&gt;'assigned_user_id', 'value' =&gt; $data['']), 
			//array('name' =&gt;'salutation', 'value' =&gt; $data['']), 
			array('name' =&gt;'last_name', 'value' =&gt; $data['name01']), 
			array('name' =&gt;'first_name', 'value' =&gt; $data['name02']), 
			//array('name' =&gt;'title', 'value' =&gt; $data['']), 
			//array('name' =&gt;'department', 'value' =&gt; $data['']), 
			//array('name' =&gt;'do_not_call', 'value' =&gt; $data['']), 
			//array('name' =&gt;'phone_home', 'value' =&gt; $data['']), 
			//array('name' =&gt;'phone_mobile', 'value' =&gt; $data['']), 
			array('name' =&gt;'phone_work', 'value' =&gt; $data['tel01'].$data['tel02'].$data['tel03']), 
			//array('name' =&gt;'phone_other', 'value' =&gt; $data['']), 
			array('name' =&gt;'phone_fax', 'value' =&gt; $data['fax01'].$data['fax02'].$data['fax03']), 
			array('name' =&gt;'primary_address_street', 'value' =&gt; $data['addr02']), 
			array('name' =&gt;'primary_address_city', 'value' =&gt; $data['addr01']), 
			array('name' =&gt;'primary_address_state', 'value' =&gt; $data['pref']), 
			array('name' =&gt;'primary_address_postalcode', 'value' =&gt; $data['zip01'].$data['zip02']), 
			//array('name' =&gt;'primary_address_country', 'value' =&gt; $data['']), 
			//array('name' =&gt;'alt_address_street', 'value' =&gt; $data['']), 
			//array('name' =&gt;'alt_address_city', 'value' =&gt; $data['']), 
			//array('name' =&gt;'alt_address_state', 'value' =&gt; $data['']), 
			//array('name' =&gt;'alt_address_postalcode', 'value' =&gt; $data['']), 
			//array('name' =&gt;'alt_address_country', 'value' =&gt; $data['']), 
			//array('name' =&gt;'assistant', 'value' =&gt; $data['']), 
			//array('name' =&gt;'assistant_phone', 'value' =&gt; $data['']), 
			//array('name' =&gt;'lead_source', 'value' =&gt; $data['']), 
			//array('name' =&gt;'reports_to_id', 'value' =&gt; $data['']), 
			array('name' =&gt;'birthdate', 'value' =&gt; $data['birth']), 
			//array('name' =&gt;'portal_name', 'value' =&gt; $data['']), 
			//array('name' =&gt;'portal_active', 'value' =&gt; $data['']), 
			//array('name' =&gt;'portal_app', 'value' =&gt; $data['']), 
			//array('name' =&gt;'campaign_id', 'value' =&gt; $data['']),
		);
	}      
	
	//SugarCRMに送るデータを、配列に入れる。
	$set_entry_params = array( 
	    'session' =&gt; $session_id, 
	    'module_name' =&gt; 'Contacts', 
	    'name_value_lists' =&gt; $arr_data
	);
		 
	//複数のINSERT文を、配列で一気に送る   
	$set_entry_result = $client-&gt;call('set_entries', $set_entry_params);  	
	echo &quot;set_entries_result=&quot;;
	print_r($set_entry_result);
	    
	//PDOを廃棄(DBログアウト)
	$pdo = null;

	//最後にちゃんとログアウト操作をする
	$result = $client-&gt;call('logout', array('session'=&gt;$session_id));
	
	//ログアウト結果を表示
	echo &quot;logout_result=&quot;;
	print_r($result); 
?&gt;

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

<?php

//SugarCRMのURLとDBのID/PASS

$url = "http://www.sample.com/sugarcrm/soap.php?wsdl";

$username = "admin";

$password = "admin";

//SOAPのライブラリファイルをダウンロードして

require_once("./lib/nusoap.php");

//WSDLで通信オブジェクトを生成

$client = new nusoap_client($url, 'wsdl');

//エラーがあったら表示して終了

$err = $client->getError();

if ($err)

{

echo '<h2>Constructor error</h2><pre>' . $err . '</pre>';

echo '<h2>Debug</h2><pre>' . htmlspecialchars($client->getDebug(), ENT_QUOTES) . '</pre>';

exit();

}

//ログイン配列を生成

$login_parameters = array(

'user_auth' => array(

'user_name' => $username,

'password' => md5($password),

'version' => '1'

'application_name' => 'SoapTest',

'name_value_list' => array(

);

//ログイン

$login_result = $client->call('login', $login_parameters);

//ログイン結果を表示

echo '<pre>';

print_r($login_result);

echo '</pre>';

//ログイン成功ならセッションIDが返ってくるので、それを使ってDB操作

$session_id = $login_result['id'];

//DB接続情報を読み込む

require_once "./dsn.php";

//EC-CUBEのデータベースにログインする。

try {

$pdo = new PDO('mysql:dbname='. $dsn['dbname'] .";host=" . $dsn['host'], $dsn['user'], $dsn['pass']);

} catch (PDOException $e) {

exit('データベースに接続できませんでした。' . $e->getMessage());

}

$stmt = $pdo->query('SET NAMES utf8');

if (!$stmt) {

$info = $pdo->errorInfo();

exit($info[2]);

}

//EC-CUBEの全個客情報を持ってくる

$stmt = $pdo->prepare('SELECT * FROM dtb_customer');

$stmt->execute();

if (!$stmt) {

$info = $pdo->errorInfo();

exit($info[2]);

}

while ($data = $stmt->fetch(PDO::FETCH_ASSOC)) {

//ループ毎に顧客情報を配列にPUSHしていく

$arr_data[] = array(

//対応するフィールドが無かったらコメントアウトしておく。

//array('name' =>'id', 'value' => $data['']),

array('name' =>'date_entered', 'value' => $data['create_date']),

array('name' =>'date_modified', 'value' => $data['update_date']),

//array('name' =>'modified_user_id', 'value' => $data['']),

//array('name' =>'created_by', 'value' => $data['']),

array('name' =>'description', 'value' => $data['note']),

//array('name' =>'deleted', 'value' => $data['']),

//array('name' =>'assigned_user_id', 'value' => $data['']),

//array('name' =>'salutation', 'value' => $data['']),

array('name' =>'last_name', 'value' => $data['name01']),

array('name' =>'first_name', 'value' => $data['name02']),

//array('name' =>'title', 'value' => $data['']),

//array('name' =>'department', 'value' => $data['']),

//array('name' =>'do_not_call', 'value' => $data['']),

//array('name' =>'phone_home', 'value' => $data['']),

//array('name' =>'phone_mobile', 'value' => $data['']),

array('name' =>'phone_work', 'value' => $data['tel01'].$data['tel02'].$data['tel03']),

//array('name' =>'phone_other', 'value' => $data['']),

array('name' =>'phone_fax', 'value' => $data['fax01'].$data['fax02'].$data['fax03']),

array('name' =>'primary_address_street', 'value' => $data['addr02']),

array('name' =>'primary_address_city', 'value' => $data['addr01']),

array('name' =>'primary_address_state', 'value' => $data['pref']),

array('name' =>'primary_address_postalcode', 'value' => $data['zip01'].$data['zip02']),

//array('name' =>'primary_address_country', 'value' => $data['']),

//array('name' =>'alt_address_street', 'value' => $data['']),

//array('name' =>'alt_address_city', 'value' => $data['']),

//array('name' =>'alt_address_state', 'value' => $data['']),

//array('name' =>'alt_address_postalcode', 'value' => $data['']),

//array('name' =>'alt_address_country', 'value' => $data['']),

//array('name' =>'assistant', 'value' => $data['']),

//array('name' =>'assistant_phone', 'value' => $data['']),

//array('name' =>'lead_source', 'value' => $data['']),

//array('name' =>'reports_to_id', 'value' => $data['']),

array('name' =>'birthdate', 'value' => $data['birth']),

//array('name' =>'portal_name', 'value' => $data['']),

//array('name' =>'portal_active', 'value' => $data['']),

//array('name' =>'portal_app', 'value' => $data['']),

//array('name' =>'campaign_id', 'value' => $data['']),

);

}

//SugarCRMに送るデータを、配列に入れる。

$set_entry_params = array(

'session' => $session_id,

'module_name' => 'Contacts',

'name_value_lists' => $arr_data

);

//複数のINSERT文を、配列で一気に送る

$set_entry_result = $client->call('set_entries', $set_entry_params);

echo "set_entries_result=";

print_r($set_entry_result);

//PDOを廃棄(DBログアウト)

$pdo = null;

//最後にちゃんとログアウト操作をする

$result = $client->call('logout', array('session'=>$session_id));

//ログアウト結果を表示

echo "logout_result=";

print_r($result);

関連記事