毎月受け取る CSV ファイルから、SugarCRM システムの特定のレコードの更新を自動化しようと取り組んでいます。
背景/紹介
Sugar が提供する以下のコードを使用して、REST 経由でレコードを更新/作成しています。
<?php
include_once('parsecsv.lib.php'); // Include the parsecsv-for-php library
$csv = new parseCSV('myCSV.csv'); // Parse through the CSV and store results in $csv
$url = "http://{site_url}/service/v4/rest.php";
$username = "admin";
$password = "password";
//function to make cURL request
function call($method, $parameters, $url)
{
ob_start();
$curl_request = curl_init();
curl_setopt($curl_request, CURLOPT_URL, $url);
curl_setopt($curl_request, CURLOPT_POST, 1);
curl_setopt($curl_request, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);
curl_setopt($curl_request, CURLOPT_HEADER, 1);
curl_setopt($curl_request, CURLOPT_SSL_VERIFYPEER, 0);
curl_setopt($curl_request, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($curl_request, CURLOPT_FOLLOWLOCATION, 0);
$jsonEncodedData = json_encode($parameters);
$post = array(
"method" => $method,
"input_type" => "JSON",
"response_type" => "JSON",
"rest_data" => $jsonEncodedData
);
curl_setopt($curl_request, CURLOPT_POSTFIELDS, $post);
$result = curl_exec($curl_request);
curl_close($curl_request);
$result = explode("\r\n\r\n", $result, 2);
$response = json_decode($result[1]);
ob_end_flush();
return $response;
}
//login -----------------------------------------------
$login_parameters = array(
"user_auth"=>array(
"user_name"=>$username,
"password"=>md5($password),
"version"=>"1"
),
"application_name"=>"RestTest",
"name_value_list"=>array(),
);
$login_result = call("login", $login_parameters, $url);
/*
echo "<pre>";
print_r($login_result);
echo "</pre>";
*/
//get session id
$session_id = $login_result->id;
//create contacts ---------------------------------------
$set_entries_parameters = array(
//session id
"session" => $session_id,
//The name of the module from which to retrieve records.
"module_name" => "Accounts",
//Record attributes
"name_value_list" => array(
array(
//to update a record, you will nee to pass in a record id as commented below
array("name" => "id", "value" => "111111111"),
array("name" => "jan_field_1", "value" => "Sample Value 1"),
array("name" => "jan_field_2", "value" => "Sample Value 2"),
// more fields could be added here
),
array(
//to update a record, you will nee to pass in a record id as commented below
array("name" => "id", "value" => "222222222"),
array("name" => "jan_field_1", "value" => "Sample Value 1"),
array("name" => "jan_field_2", "value" => "Sample Value 2"),
// more fields could be added here
),
),
);
$set_entries_result = call("set_entries", $set_entries_parameters, $url);
echo "<pre>";
print_r($set_entries_result);
echo "</pre>";
?>
次のように $set_entries_parameters 配列の値をハードコーディングすると、すべて正常に動作します。
//Record attributes
"name_value_list" => array(
array(
//to update a record, you will need to pass in a record id as commented below
array("name" => "id", "value" => "111111111"),
array("name" => "jan_field_1", "value" => "Sample Value 1"),
array("name" => "jan_field_2", "value" => "Sample Value 2"),
),
array(
//to update a record, you will need to pass in a record id as commented below
array("name" => "id", "value" => "222222222"),
array("name" => "jan_field_1", "value" => "Sample Value 1"),
array("name" => "jan_field_2", "value" => "Sample Value 2"),
),
),
);
以下は最終的にasprint_r($set_entry_parameters['name_value_list'])に渡される出力です-- すべて正常に動作し、各レコードは正しく更新されています。function call($method, $parameters, $url)$paramaters
Array
(
[0] => Array
(
[0] => Array
(
[name] => id
[value] => 111111111
)
[1] => Array
(
[name] => jan_field_1
[value] => Sample Value 1
)
[2] => Array
(
[name] => jan_field_2
[value] => Sample Value 2
)
)
[1] => Array
(
[0] => Array
(
[name] => id
[value] => 222222222
)
[1] => Array
(
[name] => jan_field_1
[value] => Sample Value 1
)
[2] => Array
(
[name] => jan_field_2
[value] => Sample Value 2
)
)
)
私が使用している CSV ファイルは次の形式になっています。ここで、id は CRM 内のレコードの ID であり、各追加の列ヘッダーは更新されるフィールドと値を設定する必要があるフィールドです。
id,field_1,field_2,field_3,field_4,field_5,field_6
111111111,21,10,8,0,1,1
222222222,32,8,7,0,0,1
333333333,17,11,7,0,0,4
時間が経つにつれて、新しい月ごとに複数の新しい列/ヘッダーがスプレッドシートに追加されます。
現在、 http: //code.google.com/p/parsecsv-for-php/ の parsecsv-for-php ライブラリを使用して CSV ファイルを解析しています。$csv->data'ライブラリはviaに次の配列を作成します$csv = new parseCSV('myCSV.csv');。
Array
(
[0] => Array
(
[id] => 111111111
[field_1] => 21
[field_2] => 10
[field_3] => 8
[field_4] => 0
[field_5] => 1
[field_6] => 1
)
[1] => Array
(
[id] => 222222222
[field_1] => 32
[field_2] => 8
[field_3] => 7
[field_4] => 0
[field_5] => 0
[field_6] => 1
)
)
質問/問題
最後に、私が苦労している問題に。
parsecsv-for-php ライブラリから作成された配列を取得し、最終的にすべてのレコードを更新する関数に渡される $set_entry_paramaters['name_value_list'] を作成する方法を見つける必要があります。
上記の例では、更新が必要な各サブ配列をレコードの ID と更新が必要な各フィールドでハードコードすると、すべてが正常に機能します。
ただし、$csv->data更新が必要な新しいレコードと更新が必要な新しいフィールドによって、配列は毎月変更されます。
$csv->data配列にあるものを再帰的に追加する必要があると思います$set_entry_parameters['name_value_list']が、のキー/インデックスは$csv->data送信する必要があるものと一致しません。
(うまくいけば) ご覧のとおり、更新される各アカウントは独自の配列です。更新されるレコードの ID はサブ配列であり、更新される各フィールドもサブ配列です。しかし、解析された CSV 配列はそれに近づきません。
したがって、解決する必要がある2つの問題があるように思えます。
- 解析された CSV を保持する配列は、 が
function call($method, $parameters, $url)として受け入れる配列の構造と一致する必要があります$paramaters。 - は
function call($method, $parameters, $url)、更新が必要なレコードごとに 1 回呼び出す必要があります。
array_walkPHP でorメソッドを使用することを検討しましたがcall_user_func_array、それが正しいかどうか、またはどのように実行するかはわかりません。
私はまだPHPを学んでいますが、現時点ではこれは私の理解を超えていると思いますが、これを行う方法を学べることを願っています. 十分な情報を提供できたことを願っています。助けの手を差し伸べてくれる親切な人がいることを願っています。追加情報があれば喜んで提供します。
よろしくお願いします！