|
|
@@ -1,6 +1,7 @@
|
|
|
package com.cyksj.service.fission.impl;
|
|
|
|
|
|
import cn.hutool.core.date.DateTime;
|
|
|
+import cn.hutool.core.util.RandomUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.cyksj.common.constant.Constant;
|
|
|
@@ -74,13 +75,14 @@ public class UserMirrorFissionFrontServiceImpl implements UserMirrorFissionFront
|
|
|
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Throwable.class)
|
|
|
- public UserMirrorFissionReceiveResp receiveTrialMirrorTicket(long userId, Long fissionId) {
|
|
|
+ public UserMirrorFissionReceiveResp receiveTrialMirrorTicket(long userId, String code) {
|
|
|
UserMirrorFissionRecord userMirrorFissionRecord = userMirrorFissionRecordMapper.selectOne(Wrappers.lambdaQuery(UserMirrorFissionRecord.class)
|
|
|
- .eq(UserMirrorFissionRecord::getId, fissionId)
|
|
|
+ .eq(UserMirrorFissionRecord::getCode, code)
|
|
|
.last("limit 1"));
|
|
|
if (userMirrorFissionRecord == null) {
|
|
|
throw BusinessRuntimeException.getInstance("活动不存在");
|
|
|
}
|
|
|
+ Long fissionId = userMirrorFissionRecord.getId();
|
|
|
UserMirrorFissionReceiveResp resp = new UserMirrorFissionReceiveResp();
|
|
|
resp.setStatus(UserMirrorFissionReceiveResp.Status.success);
|
|
|
if (userMirrorFissionRecord.getRemainNum() == 0) {
|
|
|
@@ -210,6 +212,7 @@ public class UserMirrorFissionFrontServiceImpl implements UserMirrorFissionFront
|
|
|
userMirrorFissionRecord.setNum(userMirrorFissionTicketConfig.getNum());
|
|
|
userMirrorFissionRecord.setRemainNum(userMirrorFissionTicketConfig.getNum());
|
|
|
userMirrorFissionRecord.setTrialSkuId(userMirrorFissionTicketConfig.getTrialSkuId());
|
|
|
+ userMirrorFissionRecord.setCode(RandomUtil.randomString(6));
|
|
|
userMirrorFissionRecordMapper.insert(userMirrorFissionRecord);
|
|
|
} catch (DuplicateKeyException e) {
|
|
|
userMirrorFissionRecord = userMirrorFissionRecordMapper.selectOne(Wrappers.lambdaQuery(UserMirrorFissionRecord.class)
|