iMessage

消息活动系统

使用方式

• HTTP Server

go run main.go -s server

接收并存储用户csv，以及消息模版等信息，csv格式如下

姓名,号码

上传文件方式

curl -X POST 'http://localhost:8080/upload?scheduled_time=2024-09-10%2000:00:00&message_template=dsfdsafdsfsd123099888222' -F "[email protected]"

• Message Server

go run main.go -s message

解析csv，并将用户、消息数据入库

• Producer Server

go run main.go -s producer

生产者服务，按配置好的消息发送时间，将消息投入队列

• Consumer Server

go run main.go -s consumer

消费者服务，消费队列中的任务，发送消息并修改消息状态

组建配置

// constant/net.go

package constant

const (
	QueueType   = queue.KafkaQueueType
	QueueAddr   = "127.0.0.1:9092"
	QueuePasswd = ""
	QueueKey    = "message"
)

const (
	MysqlUser   = "root"
	MysqlHost   = "127.0.0.1"
	MysqlPasswd = "Qwer1234!"
	MysqlDB     = "message"
	MysqlPort   = 3306
)

建表语句

活动表

CREATE TABLE `activities` (
  `id` int NOT NULL AUTO_INCREMENT,
  `activity_id` char(36) NOT NULL,
  `message_template` varchar(255) NOT NULL,
  `scheduled_time` datetime NOT NULL,
  `filename` varchar(255) NOT NULL,
  `status` int NOT NULL,
  PRIMARY KEY (`id`)
)

消息表

CREATE TABLE `messages` (
  `id` int NOT NULL AUTO_INCREMENT,
  `message` text NOT NULL,
  `user_id` int NOT NULL,
  `activity_id` int NOT NULL,
  `status` int DEFAULT '0',
  PRIMARY KEY (`id`)
)

用户表

CREATE TABLE `users` (
  `id` int NOT NULL AUTO_INCREMENT,
  `name` varchar(100) DEFAULT NULL,
  `phone` char(11) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `phone` (`phone`)
)