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); + } } }