记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit ecd385e5 authored by 张国柄's avatar 张国柄
Browse files
Options

~日志;

parent 1079ac40
Hide whitespace changes
Inline Side-by-side
Showing with 12 additions and 11 deletions
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/candy/PlatformCandyCouponService.java
View file @ ecd385e5
......@@ -157,13 +157,14 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
List<CandyCommonCoupon> initCommonCouponList = new ArrayList<>();
LocalDateTime now = LocalDateTime.now();
String mcouponId = mgtCoupon.getMcouponId();
Integer eventAmt = mgtCoupon.getEventAmt();
log.info("发放券处理中:目标全体用户[发放量:{}]", eventAmt);
log.info("发放券处理中:{}-目标全体用户[发放量:{}]", mcouponId, eventAmt);
for (int i = 0; i < eventAmt; i++) {
CandyCommonCoupon commonCoupon = new CandyCommonCoupon();
commonCoupon.setCcouponId(IDGenerator.nextTimeId2());
commonCoupon.setMcouponId(mgtCoupon.getMcouponId());
commonCoupon.setMcouponId(mcouponId);
commonCoupon.setCouponId(coupon.getCouponId());
commonCoupon.setExclusive(mgtCoupon.getExclusively());
commonCoupon.setState(1);
......@@ -189,10 +190,10 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
redisCandyUtil.set(ccKey, vos);
});
} else {
throw new LiquidnetServiceException("-1", String.format("券发放失败[mcouponId=%s]", mgtCoupon.getMcouponId()));
throw new LiquidnetServiceException("-1", String.format("券发放失败[mcouponId=%s]", mcouponId));
}
}
log.info("发放券处理中:目标全体用户[发放量:{},实际发放:{}]", eventAmt, initCommonCouponList.size());
log.info("发放券处理中:{}-目标全体用户[发放量:{},实际发放:{}]", mcouponId, eventAmt, initCommonCouponList.size());
}
/**
......@@ -213,7 +214,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
.gt(AdamUserMember::getExpiryAt, nowEndTime);
int userMemberCount = platformAdamUserMemberService.count(queryWrapper), num = 0, pSize = 1000;
int totalCount = userMemberCount, eventAmt = mgtCoupon.getEventAmt();
log.info("发放券处理中:目标全体会员[总数:{},发放量:{}]", userMemberCount, eventAmt);
log.info("发放券处理中:{}-目标全体会员[总数:{},发放量:{}]", mgtCoupon.getMcouponId(), userMemberCount, eventAmt);
String mcouponId = mgtCoupon.getMcouponId();
String operator = mgtCoupon.getOperator();
......@@ -253,7 +254,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
} else if (null != couponExpireAt && couponExpireAt.isAfter(now)) {
userCoupon.setDuedAt(couponExpireAt);
} else {
log.warn("发放券处理中:目标全体会员，该券生效日期或失效日期无效[mcouponId:{},couponId:{},effectAt:{},expireAt:{}]", mcouponId, couponId, couponEffectAt, couponExpireAt);
log.warn("发放券处理中:{}-目标全体会员，该券生效日期或失效日期无效[couponId:{},effectAt:{},expireAt:{}]", mcouponId, couponId, couponEffectAt, couponExpireAt);
continue;
}
userCoupon.setOperator(operator);
......@@ -285,7 +286,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
num++;
totalCount -= pSize;
log.info("发放券处理中:目标全体会员[总数:{},发放量:{},单次处理:{},剩余:{}]", userMemberCount, eventAmt, lastLimitSql, totalCount);
log.info("发放券处理中:{}-目标全体会员[总数:{},发放量:{},单次处理:{},剩余:{}]", mcouponId, userMemberCount, eventAmt, lastLimitSql, totalCount);
}
}
......@@ -305,7 +306,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
String eventLimit = mgtCoupon.getEventLimit();
String[] eventLimitArr = eventLimit.split(",");
int eventAmt = mgtCoupon.getEventAmt(), pl = 0, limitSize = eventLimitArr.length;
log.info("发放券处理中:目标指定手机号[总数:{},发放量:{}]", limitSize, eventAmt);
log.info("发放券处理中:{}-目标指定手机号[总数:{},发放量:{}]", mgtCoupon.getMcouponId(), limitSize, eventAmt);
AbstractRedisUtil redisAdamUtil = redisDataSourceUtil.getRedisAdamUtil();
......@@ -343,13 +344,13 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
if (null != vo && vo.isActive()) {
userCoupon.setDuedAt(vo.getExpiryAt());
} else {// 非会员（或无效会员）跳过
log.warn("发放券处理中:目标指定手机号，该用户非会员或会员已过期[mcouponId:{},couponId:{},uid:{}]", mcouponId, couponId, uid);
log.warn("发放券处理中:{}-目标指定手机号，该用户非会员或会员已过期[couponId:{},uid:{}]", mcouponId, couponId, uid);
continue;
}
} else if (null != couponExpireAt && couponExpireAt.isAfter(now)) {
userCoupon.setDuedAt(couponExpireAt);
} else {
log.warn("发放券处理中:目标指定手机号，该券生效日期或失效日期无效[mcouponId:{},couponId:{},effectAt:{},expireAt:{}]", mcouponId, couponId, couponEffectAt, couponExpireAt);
log.warn("发放券处理中:{}-目标指定手机号，该券生效日期或失效日期无效[couponId:{},effectAt:{},expireAt:{}]", mcouponId, couponId, couponEffectAt, couponExpireAt);
continue;
}
userCoupon.setOperator(operator);
......@@ -381,7 +382,7 @@ public class PlatformCandyCouponService extends ServiceImpl<CandyCouponMapper, C
throw new LiquidnetServiceException("-1", String.format("券发放失败[mcouponId=%s]", mcouponId));
}
}
log.info("发放券处理中:目标指定手机号[总数:{},发放量:{},实际处理:{}]", limitSize, eventAmt, pl);
log.info("发放券处理中:{}-目标指定手机号[总数:{},发放量:{},实际处理:{}]", mcouponId, limitSize, eventAmt, pl);
}
/**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment