全体の情報を取得することまではできた

Author: hatobus

smartagri.go

@@ -2,22 +2,41 @@ package main
 
 import (
 	"context"
+	"encoding/json"
 	"errors"
+	"fmt"
+	"io/ioutil"
 	"log"
+	"net/http"
 	"os"
+	"strconv"
+	"strings"
 
 	"github.com/aws/aws-lambda-go/lambda"
 	alexa "github.com/ericdaugherty/alexa-skills-kit-golang"
 	"github.com/joho/godotenv"
 )
 
 var err = godotenv.Load()
+var URL = os.Getenv("APIURL")
 var AppID = os.Getenv("APPID")
 
 var ALX = &alexa.Alexa{ApplicationID: AppID, RequestHandler: &SmartAgri{}, IgnoreApplicationID: true, IgnoreTimestamp: true}
 
 type SmartAgri struct{}
 
+type AgriData struct {
+	No               string `json:"no"`
+	Date             string `json:"date"`
+	Time             string `json:"time"`
+	Temperature      string `json:"temperature"`
+	Humidity         string `json:"humidity"`
+	SoilHumidity     string `json:"soil_humidity"`
+	Co2Concentration string `json:"co2_concentration"`
+	Wavelength       string `json:"wavelength"`
+	Illuminance      string `json:"illuminance"`
+}
+
 func (s *SmartAgri) OnSessionStarted(ctx context.Context, request *alexa.Request, session *alexa.Session, ctxPtr *alexa.Context, response *alexa.Response) error {
 
 	log.Printf("OnSessionStarted requestId=%s, sessionId=%s", request.RequestID, session.SessionID)
@@ -32,7 +51,9 @@ func Handle(ctx context.Context, requestEnv *alexa.RequestEnvelope) (interface{}
 
 // OnLaunch called with a reqeust is received of type LaunchRequest
 func (s *SmartAgri) OnLaunch(ctx context.Context, request *alexa.Request, session *alexa.Session, ctxPtr *alexa.Context, response *alexa.Response) error {
-	speechText := "こんにちは、これはローンチのテストです。"
+	speechText := "これはスマートアグリの情報を取得できます。"
+	speechText = speechText + "取得できる情報は 温度、湿度、二酸化炭素濃度、水分量に照度です。"
+	speechText = speechText + "一から三号機までの情報にそれぞれアクセスできます。"
 
 	log.Printf("OnLaunch requestId=%s, sessionId=%s", request.RequestID, session.SessionID)
 
@@ -53,7 +74,13 @@ func (s *SmartAgri) OnIntent(ctx context.Context, request *alexa.Request, sessio
 	switch request.Intent.Name {
 	case "getParamIntent":
 		log.Println("getParamIntent triggered")
-		speechText := "ハローワールド、これはインテントのテストです。"
+		speechText, err := Getsmartagriinfo(request.Intent.Slots)
+		if err != nil {
+			fmt.Println(err)
+			speechText = "すみません、情報を取得できませんでした。"
+		}
+
+		// speechText := "コレが聞こえているということはAPIとかがおかしいよ"
 
 		// response.SetSimpleCard(cardTitle, speechText)
 		response.SetOutputText(speechText)
@@ -81,6 +108,91 @@ func (s *SmartAgri) OnSessionEnded(ctx context.Context, request *alexa.Request,
 	return nil
 }
 
+func Getsmartagriinfo(slot map[string]alexa.IntentSlot) (string, error) {
+	var speech string
+
+	// 取得する機器が指定されなくてはいけないので確認する
+	if slot["machineNO"].Value == "" {
+		return "取得したい機器のナンバーを一から三号機で指定してください", nil
+	}
+
+	n := slot["machineNO"].Value
+
+	farmInfoMachineNO, err := GetFarmInfoMachineNO(n)
+	if err != nil {
+		return "", err
+	}
+
+	if slot["parameter"].Value == "" {
+		soilHumid, _ := strconv.ParseFloat(farmInfoMachineNO.SoilHumidity, 32)
+		soilHumid = (soilHumid / 1024) * 100
+		speech = n + "からの情報は、" +
+			"温度は" + farmInfoMachineNO.Temperature + "度、" +
+			"湿度は" + farmInfoMachineNO.Humidity + "パーセント、" +
+			"水分量は" + strconv.FormatFloat(soilHumid, 'f', 2, 64) + "パーセント、" +
+			"二酸化炭素濃度は" + farmInfoMachineNO.Co2Concentration + "ppm、" +
+			"照度は" + farmInfoMachineNO.Illuminance + "ルクスです。" +
+			"この情報は" + farmInfoMachineNO.Time + "に取得された情報です。"
+
+		return speech, nil
+	}
+
+	return speech, nil
+}
+
+func GetFarmInfoMachineNO(machine string) (AgriData, error) {
+	var machineNO string
+
+	switch machine {
+	case "一号機":
+		machineNO = "1"
+	case "二号機":
+		machineNO = "2"
+	case "三号機":
+		machineNO = "3"
+	}
+
+	farmstruct, err := getFarmInfoFromAPI(machineNO)
+
+	return farmstruct, err
+}
+
+// APIを叩いて情報を取得する
+func getFarmInfoFromAPI(machineNO string) (AgriData, error) {
+	var resdata []AgriData
+	var tmpdata AgriData
+
+	res, err := http.Get(URL)
+	if err != nil {
+		log.Println("API呼び出せてません！！！！")
+		return tmpdata, err
+	}
+
+	defer res.Body.Close()
+
+	body, err := ioutil.ReadAll(res.Body)
+	if err != nil {
+		log.Println(err)
+	}
+
+	// 返ってきたjsonじゃないjsonを}でsplitする
+	bodystring := strings.Split(string(body), "}")
+
+	// } で splitしたので消えているから } をくっつけてjson unmarshall
+	for _, jsondata := range bodystring {
+		jsondata = jsondata + "}"
+		json.Unmarshal([]byte(jsondata), &tmpdata)
+
+		// 機械Noにあった番号でstructを追加
+		if tmpdata.No == machineNO {
+			resdata = append(resdata, tmpdata)
+		}
+
+	}
+	log.Println(resdata[len(resdata)-1])
+	return resdata[len(resdata)-1], nil
+}
+
 func main() {
 	lambda.Start(Handle)
 }