之前通过参照日本朋友的blog，我也实现了乐天pay消费记录自动同步到zaim的功能。在这个过程中，我发现只要满足“消费记录都会以一定的各自用邮件通知”这个条件，就可以用类似的代码完成其他pay的自动同步。
这也给了我一定的启发，因为我的ANApay在使用时也有类似的邮件。
对比乐天的邮件内容
你会发现，ANApay的内容甚至比乐天更加简单。
主要简单的地方在于
- 没有point等干扰因素
- 格式也比较简介，方便内容的抓取
所以我就做了一个大胆的决定
几乎原样留下了原作者本用于乐天pay的代码，仅做了非常小的修改。（甚至很多备注我都懒得动）
主要做了如下修改
- 代码里的一些rakuten的字样改成了ana，方便自己辨认（理论上不改也没有问题）
- 抓取邮件的标题改为ANA pay的格式“［ANA Pay］ご利用のお知らせ”
- 修改邮件内容中使用日期的抓取，内容改成了“抓取第一个空格前的字符”，以避免把ANApay发来的时间也抓进去
body.match(/ご利用日時：([^ ]+) .*/)[1].trim();- 修改生成的数据库名称，避免与现存乐天pay用的数据库重复
- 修改了comment（这个也不必须）
其余能不动的我都原封不动，直接复制粘贴可用的代码我就贴在下面：
const CONSUMER_KEY = PropertiesService.getScriptProperties().getProperty("ZAIM_CONSUMER_ID");
const CONSUMER_SECRET = PropertiesService.getScriptProperties().getProperty("ZAIM_CONSUMER_SECRET")
const ANAPAY_PAYMENT_ID = parseFloat(PropertiesService.getScriptProperties().getProperty("ANAPAY_PAYMENT_ID"));
const DEFAULT_CATEGORY_ID = parseFloat(PropertiesService.getScriptProperties().getProperty("DEFAULT_CATEGORY_ID"));
const DEFAULT_GENRE_ID = parseFloat(PropertiesService.getScriptProperties().getProperty("DEFAULT_GENRE_ID"));
// 今日の日付を取得
var date = new Date(); // 現在の日付と時刻を取得
var today = Utilities.formatDate(date, Session.getScriptTimeZone(), "yyyy-MM-dd");
// 1日前の日付を取得
var yesterday = new Date(date.getFullYear(), date.getMonth(), date.getDate() - 1);
yesterday = Utilities.formatDate(yesterday, Session.getScriptTimeZone(), "yyyy-MM-dd");
// 認証のリセット
function reset() {
var service = getService();
service.reset();
}
// 認証サービスの設定
function getService() {
return OAuth1.createService("Zaim")
// Set the endpoint URLs.
.setAccessTokenUrl("https://api.zaim.net/v2/auth/access")
.setRequestTokenUrl("https://api.zaim.net/v2/auth/request")
.setAuthorizationUrl("https://auth.zaim.net/users/auth")
// Set the consumer key and secret.
.setConsumerKey(CONSUMER_KEY)
.setConsumerSecret(CONSUMER_SECRET)
// Set the name of the callback function in the script referenced
// above that should be invoked to complete the OAuth flow.
.setCallbackFunction("authCallback")
// Set the property store where authorized tokens should be persisted.
.setPropertyStore(PropertiesService.getUserProperties());
}
// OAuth Callbackの設定
function authCallback(request) {
var service = getService();
var authorized = service.handleCallback(request);
if (authorized) {
return HtmlService.createHtmlOutput("認証できました！このページを閉じて再びスクリプトを実行してください。");
} else {
return HtmlService.createHtmlOutput("認証に失敗");
}
}
// GETパラメーターを作成
function encodeParams(params) {
var encodedParams = [];
for (var key in params) {
encodedParams.push(encodeURIComponent(key) + "=" + encodeURIComponent(params[key]));
}
return encodedParams.join("&");
}
// 過去の支払いデータを取得
function getPastData(service) {
var url = "https://api.zaim.net/v2/home/money";
// 日付で検索
var params = {
"start_date": yesterday,
"end_date": today,
}
// 日付指定したい場合は日付を指定してコメントアウトを外す
// params = {
// "start_date": "2024-04-20",
// "end_date": "2024-04-23",
// }
// データの取得
var response = service.fetch(url + "?" + encodeParams(params));
var result = JSON.parse(response.getContentText());
// Logger.log(result); // 取得したデータを見たい場合コメントアウトを外す
// 楽天ペイのみの支払いでフィルタリング
var rakutenPayData = result.money.filter(function(item) {
return item.from_account_id === ANAPAY_PAYMENT_ID;
});
return rakutenPayData
}
// 楽天ペイ情報をZaimに登録（メイン関数）
function rakutenPayToZaim() {
// Gmailで該当メールを検索
var start = 0;
var max = 2; // 過去いくつまでメールを遡るか
var query = 'subject: ("［ANA Pay］ご利用のお知らせ") ';
var threads = GmailApp.search(query, start, max);
// 既存のデータを取得
var service = getService();
if (service.hasAccess()) {
var existingData = getPastData(service)
} else {
var authorizationUrl = service.authorize();
Logger.log("次のURLを開いてZaimで認証したあと、再度スクリプトを実行してください。: %s",
authorizationUrl);
}
// 各楽天ペイの支払いについて登録
for (var i = 0; i < threads.length; i++) {
var messages = threads[i].getMessages();
for (var j = 0; j < messages.length; j++) {
var message = messages[j];
var subject = message.getSubject();
var body = message.getPlainBody();
// ご利用日時、ご利用店舗、楽天キャッシュの金額を抽出
if (subject == "［ANA Pay］ご利用のお知らせ") {
var usageDate = body.match(/ご利用日時：([^ ]+) .*/)[1].trim();
var cash = body.match(/ご利用金額：\s*([\s\S]*?)\s*円/)[1].trim().replace(/,/g, "");
var shop = body.match(/ご利用店舗：\s*([\s\S]*?)(?:\n|-{40})/)[1].trim();
cash = parseInt(cash, 10)
usageDate = usageDate.replace(/^(\d{4})\/(\d{2})\/(\d{2}).*/, "$1-$2-$3")
} else {
continue;
}
var isExisting = false;
Logger.log("日付:" + usageDate + ", 支払金額:" + cash + ", お店:" + shop)
// ポイント払いの場合はスキップ
if (cash == 0) {
Logger.log("ポイント払いのためスキップ");
continue;
}
// 指定の日付範囲に入っていなければスキップ
if (usageDate != yesterday & usageDate != today) continue;
// 既存のデータと比較して、新しいデータのみを追加
for (var k = 0; k < existingData.length; k++) {
if (existingData[k]["date"] == usageDate && existingData[k]["amount"] == cash && existingData[k]["place"] == shop) {
isExisting = true;
Logger.log("既に入力済み")
break;
}
}
if (!isExisting) {
// 登録カテゴリーシートからデータを取得
var files = DriveApp.getFilesByName("ZAIM_DB_ANA");
var originalData = []
if (files.hasNext()) {
spreadsheet = SpreadsheetApp.open(files.next());
var originalSheet = spreadsheet.getSheetByName("登録カテゴリー");
originalData = originalSheet.getRange(2, 1, originalSheet.getLastRow() - 1, 4).getValues();
}
// 登録カテゴリーシートを検索して適切なカテゴリとジャンルを設定
var category_id = DEFAULT_CATEGORY_ID;
var genre_id = DEFAULT_GENRE_ID;
for (var k = 0; k < originalData.length; k++) {
var [storeName, exactMatch, categoryId, genreId] = originalData[k];
if ((exactMatch && storeName === shop) || (!exactMatch && shop.includes(storeName))) {
category_id = categoryId;
genre_id = genreId;
break;
}
}
// 支払い情報の登録
var url = "https://api.zaim.net/v2/home/money/payment";
var payload = {
"category_id": category_id,
"genre_id": genre_id,
"amount": cash,
"date": usageDate,
"place": shop,
"from_account_id": ANAPAY_PAYMENT_ID,
"comment": "GoogleAppsScriptから自動登録"
};
var options = {
"method": "post",
"payload": payload
};
service.fetch(url, options);
Logger.log("支払い入力完了")
}
}
}
}
// Spreadsheetに書き込み
function writeCategoriesToSpreadsheet(categories, genres, accounts) {
const SPREADSHEET_NAME = "ZAIM_DB_ANA";
const CATEGORY_SHEET_NAME = "カテゴリと内訳";
const ACCOUNT_SHEET_NAME = "支払方法";
const ORIGINAL_SHEET_NAME = "登録カテゴリー";
// スプレッドシートを取得または作成
let spreadsheet;
var files = DriveApp.getFilesByName(SPREADSHEET_NAME);
if (files.hasNext()) {
spreadsheet = SpreadsheetApp.open(files.next());
} else {
spreadsheet = SpreadsheetApp.create(SPREADSHEET_NAME);
}
// カテゴリとジャンルのシートを作成
let categorySheet = spreadsheet.getSheetByName(CATEGORY_SHEET_NAME);
if (categorySheet) {
categorySheet.clear(); // 既存のシートをクリア
} else {
categorySheet = spreadsheet.insertSheet(CATEGORY_SHEET_NAME);
}
// アカウントのシートを作成
let accountSheet = spreadsheet.getSheetByName(ACCOUNT_SHEET_NAME);
if (accountSheet) {
accountSheet.clear(); // 既存のシートをクリア
} else {
accountSheet = spreadsheet.insertSheet(ACCOUNT_SHEET_NAME);
}
// オリジナルカテゴリーシートの作成
let originalSheet = spreadsheet.getSheetByName(ORIGINAL_SHEET_NAME);
if (!originalSheet) {
originalSheet = spreadsheet.insertSheet(ORIGINAL_SHEET_NAME);
var originalHeaders = ["店舗名", "完全一致", "カテゴリーID", "内訳ID"];
originalSheet.getRange(1, 1, 1, originalHeaders.length).setValues([originalHeaders]);
}
// 最初のシートが存在する場合、削除する
let defaultSheet = spreadsheet.getSheetByName("シート1");
if (defaultSheet) {
spreadsheet.deleteSheet(defaultSheet);
}
// カテゴリとジャンルのヘッダーを作成
var categoryHeaders = ["カテゴリーID", "カテゴリー名", "内訳ID", "内訳名"];
categorySheet.appendRow(categoryHeaders);
// アカウントのヘッダーを作成
var accountHeaders = ["支払ID", "支払方法"];
accountSheet.appendRow(accountHeaders);
// データ行を作成
var categoryRows = [];
categories.forEach(category => {
var categoryGenres = genres.filter(genre => genre.category_id === category.id);
if (categoryGenres.length > 0) {
categoryGenres.forEach(genre => {
categoryRows.push([
category.id,
category.name,
genre.id,
genre.name,
]);
});
} else {
categoryRows.push([
category.id,
category.name,
"",
"",
]);
}
});
var accountRows = accounts.map(account => [account.id, account.name]);
// 一括で書き込み
categorySheet.getRange(2, 1, categoryRows.length, categoryHeaders.length).setValues(categoryRows);
accountSheet.getRange(2, 1, accountRows.length, accountHeaders.length).setValues(accountRows);
Logger.log("カテゴリ情報、内訳、支払い方法一覧を取得しました: " + spreadsheet.getUrl());
}
// カテゴリと内訳の取得（スプレッドシート作成のメイン関数）
function getInfo() {
var service = getService();
if (!service.hasAccess()) {
var authorizationUrl = service.authorize();
Logger.log("次のURLを開いてZaimで認証したあと、再度スクリプトを実行してください。: %s",
authorizationUrl);
}
// カテゴリの取得
var categoryUrl = "https://api.zaim.net/v2/home/category";
var response = service.fetch(categoryUrl)
var category = JSON.parse(response.getContentText()).categories;
var filterCategory = category.filter(item => item.mode === "payment" && item.active === 1.0)
.sort((a, b) => a.sort - b.sort);
// ジャンルの取得
var genreUrl = "https://api.zaim.net/v2/home/genre";
response = service.fetch(genreUrl)
var genre = JSON.parse(response.getContentText()).genres;
var filterGenre = genre.filter(item => item.active === 1.0)
.sort((a, b) => a.sort - b.sort);
// アカウント一覧の取得
var accountUrl = "https://api.zaim.net/v2/home/account";
var response = service.fetch(accountUrl);
var account = JSON.parse(response.getContentText()).accounts;
account = account.filter(item => item.active === 1.0)
.sort((a, b) => a.sort - b.sort);
// スプレッドシートに書き込み
writeCategoriesToSpreadsheet(filterCategory, filterGenre, account);
}实际测试
由于这是个基于抓取邮件的方案，所以测试的方法也非常简单，自己写个一样的邮件发给自己即可。
执行以后，发现这个信息已经被抓取
目前我仅完成了消费记录的更新，还没弄完充值的自动设定，这就有待今后的探索了。
具体的操作顺序，参照这里。