czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

积分兑换的类型统计

Browse Source
This commit is contained in:
wangw
2025-12-15 10:54:15 +08:00
parent 97ffb4c1ef
commit bf1a4fbff7
1 changed files with 17 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkShopCouponRecordServiceImpl.java
View File

@@ -66,21 +66,24 @@ public class MkShopCouponRecordServiceImpl extends ServiceImpl<MkShopCouponRecor
@Resource @Resource
private ShopCouponMapper couponService; private ShopCouponMapper couponService;
private static final List<String> TARGET_KEY = Arrays.asList("消费赠券", "充值赠券", "管理员赠送", "兑换码兑换", "群聊发放", "生日赠券", "购买会员赠券", "短信发放", "公众号发放", "用户弹窗领取"); private static final List<String> TARGET_KEY = Arrays.asList("消费赠券", "充值赠券", "管理员赠送", "兑换码兑换", "群聊发放", "生日赠券",
"购买会员赠券", "短信发放", "公众号发放", "用户弹窗领取", "积分兑换");
private static final Map<String, String> SOURCE_TO_CATEGORY = Map.of( private static final Map<String, String> SOURCE_TO_CATEGORY = Map.ofEntries(
"用户弹窗领取", "用户领取", Map.entry("用户弹窗领取", "用户领取"),
"兑换码兑换", "用户领取", Map.entry("兑换码兑换", "用户领取"),
"群聊发放", "群聊发放", Map.entry("积分兑换", "用户领取"),
"短信发放", "推广发放", Map.entry("群聊发放", "群聊发放"),
"公众号发放", "推广发放", Map.entry("短信发放", "推广发放"),
"管理员赠送", "管理员赠送", Map.entry("公众号发放", "推广发放"),
"消费赠券", "系统发送", Map.entry("管理员赠送", "管理员赠送"),
"充值赠券", "系统发送", Map.entry("消费赠券", "系统发送"),
"生日赠券", "系统发送", Map.entry("充值赠券", "系统发送"),
"购买会员赠券", "系统发送" Map.entry("生日赠券", "系统发送"),
Map.entry("购买会员赠券", "系统发送")
); );
//"积分兑换", "用户领取"
@Override @Override
public List<CouponReceiveVo> queryReceive(QueryReceiveDto param) { public List<CouponReceiveVo> queryReceive(QueryReceiveDto param) {
@@ -241,7 +244,7 @@ public class MkShopCouponRecordServiceImpl extends ServiceImpl<MkShopCouponRecor
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
try { try {
SmsPushEventUser smsPushEventUser = param.getPushEventUser(); SmsPushEventUser smsPushEventUser = param.getPushEventUser();
List<ShopUser> userList = new ArrayList<>(); List<ShopUser> userList;
if (param.getUserType() == 1) { if (param.getUserType() == 1) {
smsPushEventUser = new SmsPushEventUser(); smsPushEventUser = new SmsPushEventUser();
smsPushEventUser.setShopId(param.getShopId()); smsPushEventUser.setShopId(param.getShopId());
@@ -277,7 +280,7 @@ public class MkShopCouponRecordServiceImpl extends ServiceImpl<MkShopCouponRecor
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
try { try {
SmsPushEventUser smsPushEventUser = param.getSmsPushEventUser(); SmsPushEventUser smsPushEventUser = param.getSmsPushEventUser();
List<ShopUser> userList = new ArrayList<>(); List<ShopUser> userList;
if (param.getUserType() == 1) { if (param.getUserType() == 1) {
smsPushEventUser = new SmsPushEventUser(); smsPushEventUser = new SmsPushEventUser();
smsPushEventUser.setShopId(param.getShopId()); smsPushEventUser.setShopId(param.getShopId());