dev_0531
郑皇 5 years ago
parent eb129e5354
commit 7489b89fc9

@ -36,19 +36,24 @@ public class GenerateQRCodeListener {
//后台创建活动实例并绑定店铺之后,给店铺批量生成二维码
public void GenerateQRCode(ActivityInstanceCreatedEvent event) {
log.info("生成店铺码: {}", event.instance());
PmnActivityInstance instance = event.instance();
List<PmnActivityStoreRelation> relationList = pmnActivityStoreRelationService.list(Wrappers.<PmnActivityStoreRelation>lambdaQuery().eq(PmnActivityStoreRelation::getInstanceId, instance.getId()).select(PmnActivityStoreRelation::getStoreId).eq(PmnActivityStoreRelation::getStatus, 1));
List<Long> storeIds = relationList.stream().map(PmnActivityStoreRelation::getStoreId).collect(Collectors.toList());
log.info("storeIds: {}", storeIds);
List<PoiStoreStaff> staffs = poiStoreStaffDOMapper.selectList(Wrappers.<PoiStoreStaff>lambdaQuery().in(PoiStoreStaff::getStoreId, storeIds).eq(PoiStoreStaff::getType, 1).eq(PoiStoreStaff::getStatus, 1));
log.info("staffs: {}", staffs);
List<PoiStoreStaff> 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<PmnActivityStoreRelation> relationList = pmnActivityStoreRelationService.list(Wrappers.<PmnActivityStoreRelation>lambdaQuery().eq(PmnActivityStoreRelation::getInstanceId, instance.getId()).select(PmnActivityStoreRelation::getStoreId).eq(PmnActivityStoreRelation::getStatus, 1));
List<Long> storeIds = relationList.stream().map(PmnActivityStoreRelation::getStoreId).collect(Collectors.toList());
log.info("storeIds: {}", storeIds);
List<PoiStoreStaff> staffs = poiStoreStaffDOMapper.selectList(Wrappers.<PoiStoreStaff>lambdaQuery().in(PoiStoreStaff::getStoreId, storeIds).eq(PoiStoreStaff::getType, 1).eq(PoiStoreStaff::getStatus, 1));
log.info("staffs: {}", staffs);
List<PoiStoreStaff> 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);
}
}
}

Loading…
Cancel
Save