西部数码主机 | 阿里云主机| 虚拟主机 | 服务器 | 返回乐道官网
当前位置: 主页 > php教程 > magento教程 >

在Magento中用MySQL模拟队列发送电子邮件

时间:2017-03-14 10:46来源:未知 作者:好模板 点击:
1.顾客在magento网站上购买特定商品并且这些商品的总金额超过特定金额后,使用email给顾客发送一个优惠券;假如某件商品已经降价了,则此商品的金额不计算在目标总金额内; 2. 需求
1.顾客在magento网站上购买特定商品并且这些商品的总金额超过特定金额后,使用email给顾客发送一个优惠券;假如某件商品已经降价了,则此商品的金额不计算在目标总金额内;
 
2. 需求分析
①发送优惠券的规则:i. 购物车中包换特定商品;ii. 这些商品的总金额大于预先设定的特定金额
②顾客本次购买的订单中,如果某个商品的实际价格小于原价,则表示此件商品的实际价格是打折后的,则它的价格不会计算在目标总金额内
③每次顾客完成支付后,需要对所有的订单商品验证是否符合发送优惠券的规则,此操作可能会比较耗费时间
④如果某一个订单验证通过,则生成优惠券并通过email发送,但是发送email这一操作比较耗时
 
Magento 里可以很方便的 observer 订单保存( sales_order_save_after )的操作, 在 observer 的方法中,只需要判断这个订单的状态为’processing’即表示为“已支付”,此时可以进行优惠规则验证。
验证通过,即可通过 email 发送优惠券。但是考虑到验证规则和发送email比较耗时,而 observer 又是实时的,假如直接在 sales_order_save_after 之后进行这两项操作,订单成功页面会出现比较大的延迟。
 
3. 解决办法
 
在这里,我为 验证优惠规则 和 通过email发送优惠券 这两个操作建立了一个 mysql 表
 
 
CREATE TABLE `coupon_queue` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT 'Queue Id',
  `event_code` varchar(255) DEFAULT '' COMMENT 'Event Code',
  `event_identifier` varchar(255) DEFAULT '' COMMENT 'Event Identifier',
  `event_data` varchar(255) DEFAULT '' COMMENT 'Event Data',
  `created_at` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00' COMMENT 'Created At',
  `executed_at` timestamp NULL DEFAULT NULL COMMENT 'Execute At',
  `execute_result` varchar(255) DEFAULT '' COMMENT 'Event Execute Result',
  `is_executed` tinyint(1) NOT NULL DEFAULT '0' COMMENT 'Event Execute Status',
  PRIMARY KEY (`id`),
  UNIQUE KEY `UNQ_COUPON_QUEUE_EVENT_IDENTIFIER` (`event_identifier`),
  KEY `IDX_COUPON_QUEUE_EVENT_CODE_IS_EXECUTED` (`event_code`,`is_executed`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Event Queue Table';
其中,
event_code 表示某类事件,
event_identifier 表示某一个事件, 具有唯一性;
event_data 是执行事件所必需的数据, 它是一个对 array 进行序列化后的得到的字符串;
execute_result 是事件执行的结果,如果事件执行中有报错,会将报错信息写入这里;
created_at, executed_at 分别是事件的创建时间和执行时间
is_executed 表示此事件是否已经执行过了
 
通过 observer ‘sales_order_save_after’, 每次当有’processing’的订单的时候, 会在 coupon_queue 中插入一行数据:
 
 
INSERT INTO coupon_queue (event_code, event_identifier, event_data, created_at, is_executed)
 VALUES ( 'add_order_to_queue', '9200000217_processing', 'a:2:{s:8:"order_id";s:10:"9200000217";s:12:"order_status";s:10:"processing";}', '2017-02-23 11:06:40', 0 )
在 coupon_queue 表中插入一行的代价是很小的,对性能的影响可以忽略不计。然后再通过计划任务来每5分钟执行 coupon_queue 表中未执行的项目:
首先是读取未执行的 add_order_to_queue 事件:
 
 
SELECT * FROM coupon_queue WHERE event_code = 'add_order_to_queue' AND is_executed = 0;
coupon_queue 表中 event_data 是已经经过序列化的 array, 对其反序列化后可以得到执行事件时所需要数据。
在取得 add_order_to_queue 事件的数据后,通过对 event_data 反序列化,可以得到预先为执行此事件准备的数据。事件 add_order_to_queue 的作用是验证order是否符合发放优惠券的条件,如果验证通过,则会在 coupon_queue 表中插入另一个新的事件:
 
 
INSERT INTO coupon_queue (event_code, event_identifier, event_data, created_at, is_executed) 
VALUES ('send_coupon_code_by_email', '9200000217_processing_1_14', 'a:4:{s:8:"order_id";s:10:"9200000217";s:12:"order_status";s:10:"processing";s:13:"promo_rule_id";s:2:"14";s:8:"promo_id";s:1:"1";}', '2017-02-23 11:10:10', 0);
和上面 add_order_to_queue 事件一样,可以通过如下SQL来获取即将执行的事件的数据:
 
 
SELECT * FROM coupon_queue WHERE event_code = 'send_coupon_code_by_email' AND is_executed = 0;
这个事件是用来发送email的。和处理 add_order_to_queue 事件一样, 通过反序列 event_data 后可以获得执行发送 email 事件的数据,然后发送email给顾客。
 
这样一来,就把订单成功 -> 验证优惠券发放规则 -> 发送email 这一流程转换为两个队列,避免在订单高峰期时,这个非常耗时的流程,对网站业务逻辑的冲击,将实时性不高的业务推迟处理,有效减少了下单成功页面的响应时间。
(责任编辑:好模板)
顶一下
(0)
0%
踩一下
(0)
0%
------分隔线----------------------------
栏目列表
热点内容