From 7489b89fc98bcbab4c66cbe3d4c4e994bbf68aad Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=83=91=E7=9A=87?= <236220500@qq.com> Date: Sun, 24 May 2020 18:01:33 +0800 Subject: [PATCH] 1 --- .../listener/GenerateQRCodeListener.java | 33 +++++++++++-------- 1 file changed, 19 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/kiisoo/ic/activity/listener/GenerateQRCodeListener.java b/src/main/java/com/kiisoo/ic/activity/listener/GenerateQRCodeListener.java index fcaf639..a54a810 100644 --- a/src/main/java/com/kiisoo/ic/activity/listener/GenerateQRCodeListener.java +++ b/src/main/java/com/kiisoo/ic/activity/listener/GenerateQRCodeListener.java @@ -36,19 +36,24 @@ public class GenerateQRCodeListener { //后台创建活动实例并绑定店铺之后,给店铺批量生成二维码 public void GenerateQRCode(ActivityInstanceCreatedEvent event) { log.info("生成店铺码: {}", event.instance()); - PmnActivityInstance instance = event.instance(); - List relationList = pmnActivityStoreRelationService.list(Wrappers.lambdaQuery().eq(PmnActivityStoreRelation::getInstanceId, instance.getId()).select(PmnActivityStoreRelation::getStoreId).eq(PmnActivityStoreRelation::getStatus, 1)); - List storeIds = relationList.stream().map(PmnActivityStoreRelation::getStoreId).collect(Collectors.toList()); - log.info("storeIds: {}", storeIds); - List staffs = poiStoreStaffDOMapper.selectList(Wrappers.lambdaQuery().in(PoiStoreStaff::getStoreId, storeIds).eq(PoiStoreStaff::getType, 1).eq(PoiStoreStaff::getStatus, 1)); - log.info("staffs: {}", staffs); - List fails = new LinkedList<>(); - staffs.stream().forEach(item -> { - boolean save = pmnPromotionSrcService.createCode(item, instance.getId()); - if(!save) { - fails.add(item); - } - }); - log.info("生成失败数据: {}", fails); + try { + PmnActivityInstance instance = event.instance(); + List relationList = pmnActivityStoreRelationService.list(Wrappers.lambdaQuery().eq(PmnActivityStoreRelation::getInstanceId, instance.getId()).select(PmnActivityStoreRelation::getStoreId).eq(PmnActivityStoreRelation::getStatus, 1)); + List storeIds = relationList.stream().map(PmnActivityStoreRelation::getStoreId).collect(Collectors.toList()); + log.info("storeIds: {}", storeIds); + List staffs = poiStoreStaffDOMapper.selectList(Wrappers.lambdaQuery().in(PoiStoreStaff::getStoreId, storeIds).eq(PoiStoreStaff::getType, 1).eq(PoiStoreStaff::getStatus, 1)); + log.info("staffs: {}", staffs); + List fails = new LinkedList<>(); + staffs.stream().forEach(item -> { + boolean save = pmnPromotionSrcService.createCode(item, instance.getId()); + if (!save) { + fails.add(item); + } + }); + log.info("生成失败数据: {}", fails); + }catch (Exception e) { + e.printStackTrace(); + log.error("生成失败: {}", e); + } } }