[golang]fiber API3~Checkout: Email送信の実装

こんにちは、KOUKIです。

GolangのWebフレームワークであるfiberを使って、APIを開発しています。

前回は、Stripeでチェックアウト機能を実装しました。

今回は、Email送信機能を実装しましょう。そして、API側の開発は、本記事で最後になります。

尚、本記事は「React, NextJS and Golang: A Rapid Guide – Advanced」コースを参考にしています。解釈は私が勝手に付けているので、本物をみたい場合は受講をお勧めします!

[golang]fiber API作成~まとめ~

<目次>

前回

[golang]fiber API2~Checkout: Stripeでチェックアウトの実装

作るもの

Checkout機能を作りたいと思います。エンドポイントは、次の通りです。

エンドポイント

GET /api/checkout/links/{code}
POST /api/checkout/orders
POST /api/checkout/orders/confirm

Email送信

商品をカートに入れて、Checkoutを済ませると、Emailを飛ばせるようにしたいと思います。

Mailhog

Mailhogは、ローカル上でEmailの送受信をテストできる便利ツールです。

以前、これを使って、Email送信機能を実装したことがあるので、DockerにMailhogを導入したいと思います。

Go言語とVue.jsで作るユーザー認証アプリ~環境構築編~

docker-compose.ymlに、smtpサービスを追加します。

# docker-compose.yml
version: "3.3"
services:
...

  smtp:
    image: mailhog/mailhog
    ports:
      - "1025:1025"
      - "8025:8025"

# docker-compose.yml

version: "3.3"

services:

...

smtp:

image: mailhog/mailhog

ports:

- "1025:1025"

- "8025:8025"

1025ポートは、プログラム内からMailhogにアクセスする用のポートで、8025ポートは、ブラウザからMailhogにアクセスするためのポートです。

以下のコマンドで、コンテナを立ち上げてみましょう。

docker-compose up

1	docker-compose up

ブラウザから「http://localhost:8025/」へアクセスしてみましょう。

ここに、メールが飛んでくるようにします。

SendMailの実装

smtpパッケージのSendMailメソッドを使って、Mailの送信機能を実装しましょう。

実装する場所は、前回作成したCompleteOrder関数の中です。

// controllers/orderController.go
func CompleteOrder(ctx *fiber.Ctx) error {
	...
	go func(order models.Order) {
		ambassadorRevenue := 0.0
		adminRevenue := 0.0

		for _, item := range order.OrderItems {
			ambassadorRevenue += item.AmbassadorRevenue
			adminRevenue += item.AdminRevenue
		}

		user := models.User{}
		user.ID = order.UserID

		database.DB.First(&user)
		// https://redis.io/commands/zincrby
		database.Cache.ZIncrBy(context.Background(), "rankings", ambassadorRevenue, user.Name())

		// Email to ambassador
		ambassadorMessage := []byte(
			fmt.Sprintf("貴方の収益は、$%fです。Link: #%s",
				ambassadorRevenue,
				order.Code))
		// MailhogへのPort
		smtp.SendMail(
			":1025",     // 宛先のアドレス
			nil,                             // Authentication
			"no-reply@email.com",            // from
			[]string{order.AmbassadorEmail}, // To
			ambassadorMessage)               // Message

		// Email to admin
		adminMessage := []byte(
			fmt.Sprintf("Order: #%d, Total: %f",
				order.ID,
				adminRevenue))
		// MailhogへのPort
		smtp.SendMail(
			":1025", // 宛先のアドレス
			nil,                         // Authentication
			"no-reply@email.com",        // from
			[]string{"admin@admin.com"}, // To
			adminMessage)                // Message

	}(order)
...
}

// controllers/orderController.go

func CompleteOrder(ctx *fiber.Ctx) error {

...

go func(order models.Order) {

ambassadorRevenue := 0.0

adminRevenue := 0.0

for _, item := range order.OrderItems {

ambassadorRevenue += item.AmbassadorRevenue

adminRevenue += item.AdminRevenue

}

user := models.User{}

user.ID = order.UserID

database.DB.First(&user)

// https://redis.io/commands/zincrby

database.Cache.ZIncrBy(context.Background(), "rankings", ambassadorRevenue, user.Name())

// Email to ambassador

ambassadorMessage := []byte(

fmt.Sprintf("貴方の収益は、$%fです。Link: #%s",

ambassadorRevenue,

order.Code))

// MailhogへのPort

smtp.SendMail(

":1025", // 宛先のアドレス

nil, // Authentication

"no-reply@email.com", // from

[]string{order.AmbassadorEmail}, // To

ambassadorMessage) // Message

// Email to admin

adminMessage := []byte(

fmt.Sprintf("Order: #%d, Total: %f",

order.ID,

adminRevenue))

// MailhogへのPort

smtp.SendMail(

":1025", // 宛先のアドレス

nil, // Authentication

"no-reply@email.com", // from

[]string{"admin@admin.com"}, // To

adminMessage) // Message

}(order)

...

}

SendMailの「”:1025″」にて、MailhogへのAddressを指定しています。

検証

以下のパラメーターで、Checkoutをしましょう。

URL: http://localhost:8000/api/checkout/orders/confirm
形式: POST

ブラウザから「http://localhost:8025/」へアクセスして、メールが飛んでいるか確認しましょう。

OKですね。

次回

次回からは、Reactを使ってフロントエンド側の実装に入ります。

Go言語まとめ

[golang]fiber API作成~まとめ~

Go言語 ~ 記事まとめ ~

入門Goプログラミング【電子書籍】[ Nathan Youngman ]

楽天で購入

Head First Go【電子書籍】[ Jay McGavren ]

楽天で購入

ソースコード

ここまでのソースコードを以下に記載します。

docker-compose.go

# docker-compose.yml
version: "3.3"
services:
  backend:
    # docker-composeファイルと同階層のDockerfileをビルド
    build: .
    ports:
      # ローカル:Docker
      - 8000:3000
      # DockerとローカルのFSをマウント
    volumes:
      - .:/app
    # dbを先に起動させる
    # ただし、初回起動時はDBの準備に手間取るので、コネクトに失敗する
    # 可能性がある
    depends_on:
      - db
      - redis

  db:
    image: mysql:5.7.22
    # restart: always
    environment:
      MYSQL_DATABASE: ambassador
      MYSQL_USER: admin
      MYSQL_PASSWORD: admin
      MYSQL_ROOT_PASSWORD: root
    # ローカルに.dbdataを作成し、dbコンテナとFSをマウントする
    volumes:
      - .dbdata:/var/lib/mysql
    ports:
      - 33066:3306

  redis:
    image: redis:latest
    ports:
      - 6379:6379

  smtp:
    image: mailhog/mailhog
    ports:
      - "1025:1025"
      - "8025:8025"

# docker-compose.yml

version: "3.3"

services:

backend:

# docker-composeファイルと同階層のDockerfileをビルド

build: .

ports:

# ローカル:Docker

- 8000:3000

# DockerとローカルのFSをマウント

volumes:

- .:/app

# dbを先に起動させる

# ただし、初回起動時はDBの準備に手間取るので、コネクトに失敗する

# 可能性がある

depends_on:

- db

- redis

db:

image: mysql:5.7.22

# restart: always

environment:

MYSQL_DATABASE: ambassador

MYSQL_USER: admin

MYSQL_PASSWORD: admin

MYSQL_ROOT_PASSWORD: root

# ローカルに.dbdataを作成し、dbコンテナとFSをマウントする

volumes:

- .dbdata:/var/lib/mysql

ports:

- 33066:3306

redis:

image: redis:latest

ports:

- 6379:6379

smtp:

image: mailhog/mailhog

ports:

- "1025:1025"

- "8025:8025"

orderController.go

// controllers/orderController.go
package controllers

import (
	"admin/internal"
	"admin/src/database"
	"admin/src/models"
	"context"
	"fmt"
	"net/smtp"

	"github.com/gofiber/fiber/v2"
	"github.com/stripe/stripe-go"
	"github.com/stripe/stripe-go/checkout/session"
)

func Orders(ctx *fiber.Ctx) error {
	var orders []models.Order

	// DB検索
	database.DB.Preload("OrderItems").Find(&orders)

	for i, order := range orders {
		orders[i].Name = order.FullName()
		orders[i].Total = order.GetTotal()
	}

	return ctx.JSON(orders)
}

type CreateOrderRequest struct {
	Code      string
	FirstName string
	LastName  string
	Email     string
	Address   string
	Country   string
	City      string
	Zip       string
	Products  []map[string]int
}

func CreateOrder(ctx *fiber.Ctx) error {
	var request CreateOrderRequest

	// リクエストデータを取得
	if err := ctx.BodyParser(&request); err != nil {
		return err
	}

	// リクエストからコードを抜き出す
	link := models.Link{
		Code: request.Code,
	}

	// DB検索
	database.DB.Preload("User").First(&link)

	// 該当データがない場合はエラー
	if link.ID == 0 {
		ctx.Status(fiber.StatusBadRequest)
		return ctx.JSON(fiber.Map{
			"message": "無効なリンクです",
		})
	}

	// Orderを作成する
	order := models.Order{
		Code:            link.Code,
		UserID:          link.UserID,
		AmbassadorEmail: link.User.Email,
		FirstName:       request.FirstName,
		LastName:        request.LastName,
		Email:           request.Email,
		Address:         request.Address,
		Country:         request.Country,
		City:            request.City,
		Zip:             request.Zip,
	}

	// トランザクション
	tx := database.DB.Begin()
	// OrderをDBに保存
	if err := tx.Create(&order).Error; err != nil {
		tx.Rollback()
		ctx.Status(fiber.StatusBadRequest)
		return ctx.JSON(fiber.Map{
			"message": err.Error(),
		})
	}

	// stripeパラメーター
	var lineItems []*stripe.CheckoutSessionLineItemParams

	// リクエストからプロダクトを取得
	for _, requestProduct := range request.Products {
		product := models.Product{}
		product.ID = uint(requestProduct["product_id"])

		// product検索
		database.DB.First(&product)

		// トータルを算出
		total := product.Price * float64(requestProduct["quantity"])

		// OrderItemを作成
		item := models.OrderItem{
			OrderID:           order.ID,
			ProductTitle:      product.Title,
			Price:             product.Price,
			Quantity:          uint(requestProduct["quantity"]),
			AmbassadorRevenue: 0.1 * total,
			AdminRevenue:      0.9 * total,
		}

		// トランザクション
		// OrderItemをDBに保存
		if err := tx.Create(&item).Error; err != nil {
			tx.Rollback()
			ctx.Status(fiber.StatusBadRequest)
			return ctx.JSON(fiber.Map{
				"message": err.Error(),
			})
		}

		// stripeアイテムセット
		lineItems = append(lineItems, &stripe.CheckoutSessionLineItemParams{
			Name:        stripe.String(product.Title),
			Description: stripe.String(product.Description),
			Images:      []*string{stripe.String(product.Image)},
			Amount:      stripe.Int64(100 * int64(product.Price)),
			Currency:    stripe.String("usd"),
			Quantity:    stripe.Int64(int64(requestProduct["quantity"])),
		})
	}

	// stripe checkout
	stripe.Key = internal.StripeSecretKey()
	params := stripe.CheckoutSessionParams{
		// http://localhost:5000はフロントエンド側のリンク(まだ作成していない)
		SuccessURL:         stripe.String("http://localhost:5000/success?source={CHECKOUT_SESSION_ID}"),
		CancelURL:          stripe.String("http://localhost:5000/error"),
		PaymentMethodTypes: stripe.StringSlice([]string{"card"}),
		LineItems:          lineItems,
	}

	source, err := session.New(&params)
	if err != nil {
		tx.Rollback()
		ctx.Status(fiber.StatusBadRequest)
		return ctx.JSON(fiber.Map{
			"message": err.Error(),
		})
	}

	// トランザクションIDを登録
	order.TransactionID = source.ID
	// データを書き換えたので、上書き保存
	if err := tx.Save(&order).Error; err != nil {
		tx.Rollback()
		ctx.Status(fiber.StatusBadRequest)
		return ctx.JSON(fiber.Map{
			"message": err.Error(),
		})
	}

	// 実行
	tx.Commit()

	return ctx.JSON(source)
}

func CompleteOrder(ctx *fiber.Ctx) error {
	var data map[string]string

	// リクエストデータを取得
	if err := ctx.BodyParser(&data); err != nil {
		return err
	}

	order := models.Order{}
	// OrderItemを検索
	database.DB.Preload("OrderItems").First(&order, models.Order{
		TransactionID: data["source"],
	})

	if order.ID == 0 {
		ctx.Status((fiber.StatusNotFound))
		return ctx.JSON(fiber.Map{
			"message": "オーダーが見つかりません",
		})
	}

	// Orderを保存
	order.Complete = true
	database.DB.Save(&order)

	// Redisキャッシュに保存したRankingも更新
	// Rankingはユーザーの購入金額を示す
	go func(order models.Order) {
		ambassadorRevenue := 0.0
		adminRevenue := 0.0

		for _, item := range order.OrderItems {
			ambassadorRevenue += item.AmbassadorRevenue
			adminRevenue += item.AdminRevenue
		}

		user := models.User{}
		user.ID = order.UserID

		database.DB.First(&user)
		// https://redis.io/commands/zincrby
		database.Cache.ZIncrBy(context.Background(), "rankings", ambassadorRevenue, user.Name())

		// Email to ambassador
		ambassadorMessage := []byte(
			fmt.Sprintf("貴方の収益は、$%fです。Link: #%s",
				ambassadorRevenue,
				order.Code))
		// MailhogへのPort
		smtp.SendMail(
			":1025",                         // 宛先のアドレス
			nil,                             // Authentication
			"no-reply@email.com",            // from
			[]string{order.AmbassadorEmail}, // To
			ambassadorMessage)               // Message

		// Email to admin
		adminMessage := []byte(
			fmt.Sprintf("Order: #%d, Total: %f",
				order.ID,
				adminRevenue))
		// MailhogへのPort
		smtp.SendMail(
			":1025",                     // 宛先のアドレス
			nil,                         // Authentication
			"no-reply@email.com",        // from
			[]string{"admin@admin.com"}, // To
			adminMessage)                // Message

	}(order)

	return ctx.JSON(fiber.Map{
		"message": "success",
	})
}

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

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

// controllers/orderController.go

package controllers

import (

"admin/internal"

"admin/src/database"

"admin/src/models"

"context"

"fmt"

"net/smtp"

"github.com/gofiber/fiber/v2"

"github.com/stripe/stripe-go"

"github.com/stripe/stripe-go/checkout/session"

)

func Orders(ctx *fiber.Ctx) error {

var orders []models.Order

// DB検索

database.DB.Preload("OrderItems").Find(&orders)

for i, order := range orders {

orders[i].Name = order.FullName()

orders[i].Total = order.GetTotal()

}

return ctx.JSON(orders)

}

type CreateOrderRequest struct {

Code string

FirstName string

LastName string

Email string

Address string

Country string

City string

Zip string

Products []map[string]int

}

func CreateOrder(ctx *fiber.Ctx) error {

var request CreateOrderRequest

// リクエストデータを取得

if err := ctx.BodyParser(&request); err != nil {

return err

}

// リクエストからコードを抜き出す

link := models.Link{

Code: request.Code,

}

// DB検索

database.DB.Preload("User").First(&link)

// 該当データがない場合はエラー

if link.ID == 0 {

ctx.Status(fiber.StatusBadRequest)

return ctx.JSON(fiber.Map{

"message": "無効なリンクです",

})

}

// Orderを作成する

order := models.Order{

Code: link.Code,

UserID: link.UserID,

AmbassadorEmail: link.User.Email,

FirstName: request.FirstName,

LastName: request.LastName,

Email: request.Email,

Address: request.Address,

Country: request.Country,

City: request.City,

Zip: request.Zip,

}

// トランザクション

tx := database.DB.Begin()

// OrderをDBに保存

if err := tx.Create(&order).Error; err != nil {

tx.Rollback()

ctx.Status(fiber.StatusBadRequest)

return ctx.JSON(fiber.Map{

"message": err.Error(),

})

}

// stripeパラメーター

var lineItems []*stripe.CheckoutSessionLineItemParams

// リクエストからプロダクトを取得

for _, requestProduct := range request.Products {

product := models.Product{}

product.ID = uint(requestProduct["product_id"])

// product検索

database.DB.First(&product)

// トータルを算出

total := product.Price * float64(requestProduct["quantity"])

// OrderItemを作成

item := models.OrderItem{

OrderID: order.ID,

ProductTitle: product.Title,

Price: product.Price,

Quantity: uint(requestProduct["quantity"]),

AmbassadorRevenue: 0.1 * total,

AdminRevenue: 0.9 * total,

}

// トランザクション

// OrderItemをDBに保存

if err := tx.Create(&item).Error; err != nil {

tx.Rollback()

ctx.Status(fiber.StatusBadRequest)

return ctx.JSON(fiber.Map{

"message": err.Error(),

})

}

// stripeアイテムセット

lineItems = append(lineItems, &stripe.CheckoutSessionLineItemParams{

Name: stripe.String(product.Title),

Description: stripe.String(product.Description),

Images: []*string{stripe.String(product.Image)},

Amount: stripe.Int64(100 * int64(product.Price)),

Currency: stripe.String("usd"),

Quantity: stripe.Int64(int64(requestProduct["quantity"])),

})

}

// stripe checkout

stripe.Key = internal.StripeSecretKey()

params := stripe.CheckoutSessionParams{

// http://localhost:5000はフロントエンド側のリンク(まだ作成していない)

SuccessURL: stripe.String("http://localhost:5000/success?source={CHECKOUT_SESSION_ID}"),

CancelURL: stripe.String("http://localhost:5000/error"),

PaymentMethodTypes: stripe.StringSlice([]string{"card"}),

LineItems: lineItems,

}

source, err := session.New(&params)

if err != nil {

tx.Rollback()

ctx.Status(fiber.StatusBadRequest)

return ctx.JSON(fiber.Map{

"message": err.Error(),

})

}

// トランザクションIDを登録

order.TransactionID = source.ID

// データを書き換えたので、上書き保存

if err := tx.Save(&order).Error; err != nil {

tx.Rollback()

ctx.Status(fiber.StatusBadRequest)

return ctx.JSON(fiber.Map{

"message": err.Error(),

})

}

// 実行

tx.Commit()

return ctx.JSON(source)

}

func CompleteOrder(ctx *fiber.Ctx) error {

var data map[string]string

// リクエストデータを取得

if err := ctx.BodyParser(&data); err != nil {

return err

}

order := models.Order{}

// OrderItemを検索

database.DB.Preload("OrderItems").First(&order, models.Order{

TransactionID: data["source"],

})

if order.ID == 0 {

ctx.Status((fiber.StatusNotFound))

return ctx.JSON(fiber.Map{

"message": "オーダーが見つかりません",

})

}

// Orderを保存

order.Complete = true

database.DB.Save(&order)

// Redisキャッシュに保存したRankingも更新

// Rankingはユーザーの購入金額を示す

go func(order models.Order) {

ambassadorRevenue := 0.0

adminRevenue := 0.0

for _, item := range order.OrderItems {

ambassadorRevenue += item.AmbassadorRevenue

adminRevenue += item.AdminRevenue

}

user := models.User{}

user.ID = order.UserID

database.DB.First(&user)

// https://redis.io/commands/zincrby

database.Cache.ZIncrBy(context.Background(), "rankings", ambassadorRevenue, user.Name())

// Email to ambassador

ambassadorMessage := []byte(

fmt.Sprintf("貴方の収益は、$%fです。Link: #%s",

ambassadorRevenue,

order.Code))

// MailhogへのPort

smtp.SendMail(

":1025", // 宛先のアドレス

nil, // Authentication

"no-reply@email.com", // from

[]string{order.AmbassadorEmail}, // To

ambassadorMessage) // Message

// Email to admin

adminMessage := []byte(

fmt.Sprintf("Order: #%d, Total: %f",

order.ID,

adminRevenue))

// MailhogへのPort

smtp.SendMail(

":1025", // 宛先のアドレス

nil, // Authentication

"no-reply@email.com", // from

[]string{"admin@admin.com"}, // To

adminMessage) // Message

}(order)

return ctx.JSON(fiber.Map{

"message": "success",

})

}

[golang]fiber API3~Checkout: Email送信の実装

前回

作るもの

Email送信

Mailhog

SendMailの実装

検証

次回

Go言語まとめ

ソースコード

docker-compose.go

orderController.go

シェア！

コメントを残すコメントをキャンセル

スポンサーリンク

プロフィール

最近の投稿

最近のコメント

カテゴリー

メタ情報

にほんブログ村

スポンサーリンク

カレンダー

アーカイブ

2021年7月
月	火	水	木	金	土	日
			1	2	3	4
5	6	7	8	9	10	11
12	13	14	15	16	17	18
19	20	21	22	23	24	25
26	27	28	29	30	31

前回

作るもの

Email送信

Mailhog

SendMailの実装

検証

次回

Go言語まとめ

ソースコード

docker-compose.go

orderController.go

シェア！

コメントを残す コメントをキャンセル

RECOMMENDこちらの記事も人気です。

[Golang]文字列抽出処理

Djangoでテスト駆動開発を学ぼう！2~初めてのテスト編~

JavaScriptでカスタムレンジスライダーを作ろう!

Webデザイン1: リセットCSS

[React]~Ambassador画面3:ナビゲーションの実装~

Go言語とPostgreSQLで遊ぼう!~Unit Test編~

[Docker]alpine linuxベースのコンテナの時刻合わせ

[golang]fiber API1~Ambassador: マルチルートの…

スポンサーリンク

プロフィール

最近の投稿

最近のコメント

カテゴリー

メタ情報

にほんブログ村

スポンサーリンク

カレンダー

アーカイブ

コメントを残すコメントをキャンセル