More than 3 years have passed since last update.

忙しいエンジニアに捧げる！obnizとLINE APIでレトルト在庫管理！

Last updated at 2021-10-28Posted at 2021-10-28

　レトルト食品最高

突然ですが、レトルト食品って最高ですよね。
茹でればすぐに食べられて、なおかつ食費も抑えられる。時間・価格ともにコスパ最高です。
日夜忙しく働くエンジニアの皆さんの心強い味方といっても過言ではありません。

さらに、「安い、早い！！」だけではなく、最近のレトルトはシェフ監修なんて書かれていたりして、非常においしいものがたくさんあります。スーパーで選ぶのもちょっとした楽しみになるくらいです。

↓推しレトルトパスタ

忙しい時に限ってなくなる

しかし、忙しい日が続いてしまうと、いつの間にかレトルト食品も底をつき、
一生懸命働いて帰ってきたのに食べるものがない...なんてことも。
そこでobniz Board 1YというIoT向けのマイコンを使って、レトルトが尽きない仕組みを整えてみました！

仕組み

1. obniz Board 1Yに超音波距離センサーを装着！

2. パッケージまでの距離を図って、パッケージが何個並んでいるかを算出

便宜上、本棚にレトルトを置いています。

3. LINE Messageing API を利用して、LINEからいつでも在庫数を確認！

実行環境

API
・LINE Messaging API
・obniz ハードウェアAPI

実行環境
・obniz.js(JavaScript SDK)
・Node.js v6.10.0
・LINE Messaging API SDK 7.4.0
・Express 4.17.1
・ngrok 2.3.4
・Powershell 5.1.19041

機材
・obniz Board 1Y
・超音波距離センサー　HC-SR04

コード

前準備部分

各種APIの利用準備や変数・定数を定義します。

// ########################################
//             Initialize Section
// ########################################

// パッケージを使用します
const express = require('express');
const line = require('@line/bot-sdk');
const Obniz = require('obniz');

// ngrokを介してローカル（自分のPC）でサーバーを公開するときのポート番号です
const PORT = process.env.PORT || 3000;

// LINE Messaging APIで利用するクレデンシャル（秘匿情報）です。
const config = {
    channelSecret: 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx',
    channelAccessToken: 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
  };
  
//obniz APIを利用
const obniz = new Obniz('obniz_ID'); // obniz_IDに自分のIDを入れます

//変数
var distance = 0; //壁からの距離(mm)

//定数
const Thickness = 22; //レトルトのパッケージの厚み(mm)

obnizで距離を計測する

定期的に距離を測定して、変数に値を記録しておきます。
精度は重視していないため小数点は丸め込み、計測した距離を整数として扱います。

// ########################################
//               obniz Section 
// ########################################

obniz.onconnect = async function () {
    // 超音波距離センサを利用する
    const hcsr04 = obniz.wired('HC-SR04', { gnd: 0, echo: 1, trigger: 2, vcc: 3 });

    // ディスプレイ
    obniz.display.clear(); // クリア
    obniz.display.print('Ready');

    
    // setIntervalで一定間隔で処理
    setInterval(async function () {
        // 距離を取得
        distance = await hcsr04.measureWait();
        // そのままだと小数点以下の桁数がやたら多いので整数に丸める
        distance = Math.floor(distance);

        // 距離(mm)をターミナルに表示
        console.log(distance + ' mm');
        // obnizディスプレイに表示
        // 一度消してから距離+mmの単位を表示
        obniz.display.clear();
        obniz.display.print(distance + ' mm');

    }, 1000*60); //  1分ごとに取得
}

LINE Messanging API でLINEに通知する

今回は、クライアントから「在庫確認」というメッセージを受け取ったら、
距離から在庫数を算出してユーザーに通知します。
なお、在庫数の算出は以下の通り。

(棚の幅　- 　壁から在庫までの距離 - センサーの厚み)  /　パッケージの厚み

// ########################################
//      LINE Messaging API  Section
// ########################################
const sampleFunction = async (event) => {
    // ユーザーメッセージが「在庫確認」かどうか
    if (event.message.text !== '在庫確認') {
        return client.replyMessage(event.replyToken, {
            type: 'text',
            text: '「在庫確認」と話しかけてね'
        });
    } else {
        // 「リプライ」を使って先に返事しておきます
        await client.replyMessage(event.replyToken, {
            type: 'text',
            text: '調べています……'
        });     
        
        let pushText = '';
        let today_stock = Math.floor(
             //(棚の幅　- 壁から在庫までの距離 - センサーの厚み)  /　パッケージの厚み
            (300 - distance - 22) / Thickness );

        try {
            //返信用のテキストを作成
            pushText = `現在のレトルトの在庫は\n${today_stock}\nです！`;
        } catch (error) {
            pushText = '検索中にエラーが発生しました。ごめんね。';
            // APIからエラーが返ってきたらターミナルに表示する
            console.error(error);
        }

        // 「プッシュ」で後からユーザーに通知します
        return client.pushMessage(event.source.userId, {
            type: 'text',
            text: pushText
        });
    }
};



// ########################################
//  LINEサーバーからのWebhookデータを処理する部分
// ########################################

// LINE SDKを初期化します
const client = new line.Client(config);

// LINEサーバーからWebhookがあると「サーバー部分」から以下の "handleEvent" という関数が呼び出されます
async function handleEvent(event) {
    // 受信したWebhookが「テキストメッセージ以外」であればnullを返すことで無視します
    if (event.type !== 'message' || event.message.type !== 'text') {
        return Promise.resolve(null);
    }
    // サンプル関数を実行します
    return sampleFunction(event);
}



// ########################################
//          Express Section
// ########################################

// expressを初期化します
const app = express();

// HTTP POSTによって '/webhook' のパスにアクセスがあったら、POSTされた内容に応じて様々な処理をします
app.post('/webhook', line.middleware(config), (req, res) => {
  
  // 検証ボタンをクリックしたときに飛んできたWebhookを受信したときのみ以下のif文内を実行
  if (req.body.events.length === 0) {
    res.send('Hello LINE BOT! (HTTP POST)'); // LINEサーバーに返答します（なくてもよい）
    console.log('検証イベントを受信しました！'); // ターミナルに表示します
    return; // これより下は実行されません
  } else {
    // 通常のメッセージなど … Webhookの中身を確認用にターミナルに表示します
    console.log('受信しました:', req.body.events);
  }

  // あらかじめ宣言しておいた "handleEvent" 関数にWebhookの中身を渡して処理してもらい、
  // 関数から戻ってきたデータをそのままLINEサーバーに「レスポンス」として返します
  Promise.all(req.body.events.map(handleEvent)).then((result) => res.json(result));
});

// 最初に決めたポート番号でサーバーをPC内だけに公開します
// （環境によってはローカルネットワーク内にも公開されます）
app.listen(PORT);
console.log(`ポート${PORT}番でExpressサーバーを実行中です…`);