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

Commit 69a10652 authored by jiangxiulong's avatar jiangxiulong

类型5也减实物总库存 中积分该已发放状态

parent 2f0d6261
...@@ -13,6 +13,7 @@ import com.liquidnet.service.feign.adam.api.FeignAdamBaseClient; ...@@ -13,6 +13,7 @@ import com.liquidnet.service.feign.adam.api.FeignAdamBaseClient;
import com.liquidnet.service.feign.candy.api.FeignCandyBaseClient; import com.liquidnet.service.feign.candy.api.FeignCandyBaseClient;
import com.liquidnet.service.feign.stone.api.FeignStoneIntegralClient; import com.liquidnet.service.feign.stone.api.FeignStoneIntegralClient;
import com.liquidnet.service.stone.dto.StoneScoreListDto; import com.liquidnet.service.stone.dto.StoneScoreListDto;
import com.liquidnet.service.sweet.constant.StatusConst;
import com.liquidnet.service.sweet.dto.vo.*; import com.liquidnet.service.sweet.dto.vo.*;
import com.liquidnet.service.sweet.entity.SweetIntegralActivityDraw; import com.liquidnet.service.sweet.entity.SweetIntegralActivityDraw;
import com.liquidnet.service.sweet.mapper.SweetIntegralActivityDrawMapper; import com.liquidnet.service.sweet.mapper.SweetIntegralActivityDrawMapper;
...@@ -170,8 +171,6 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg ...@@ -170,8 +171,6 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
integralParamDe.setContent(integralActivity.getActivityTitle()); integralParamDe.setContent(integralActivity.getActivityTitle());
queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_STONE_INTEGRAL.getKey(), queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_STONE_INTEGRAL.getKey(),
JsonUtils.toJson(integralParamDe)); JsonUtils.toJson(integralParamDe));
// ResponseDto<String> de2111 = feignStoneIntegralClient.de2111(userId, integralActivity.getActivityNum(), integralActivity.getActivityTitle());
// log.info("减积分返回值情况 de2111:{}", de2111);
// 抽奖入库 // 抽奖入库
String drawId = IDGenerator.nextSnowId(); String drawId = IDGenerator.nextSnowId();
IntegralActivityDrawVo integralActivityDrawVo = IntegralActivityDrawVo.getNew(); IntegralActivityDrawVo integralActivityDrawVo = IntegralActivityDrawVo.getNew();
...@@ -188,7 +187,7 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg ...@@ -188,7 +187,7 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
integralActivityDrawVo.setCreatedAt(nowTime); integralActivityDrawVo.setCreatedAt(nowTime);
Integer receivingStatus = 1; Integer receivingStatus = 1;
Integer prizeType = integralActivityPrizeVo.getPrizeType(); Integer prizeType = integralActivityPrizeVo.getPrizeType();
if (prizeType == 1) {// 中奖积分 if (prizeType == StatusConst.PRIZE_TYPE1) {// 中奖积分
SweetStoneIntegralParam integralParamIn = SweetStoneIntegralParam.getNew(); SweetStoneIntegralParam integralParamIn = SweetStoneIntegralParam.getNew();
integralParamIn.setType(1); integralParamIn.setType(1);
integralParamIn.setUid(userId); integralParamIn.setUid(userId);
...@@ -196,20 +195,12 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg ...@@ -196,20 +195,12 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
integralParamIn.setContent(integralActivity.getActivityTitle()); integralParamIn.setContent(integralActivity.getActivityTitle());
queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_STONE_INTEGRAL.getKey(), queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_STONE_INTEGRAL.getKey(),
JsonUtils.toJson(integralParamIn)); JsonUtils.toJson(integralParamIn));
/*try { receivingStatus = 2;
// 增加积分
ResponseDto<String> in2111 = feignStoneIntegralClient.in2112(userId, integralActivityPrizeVo.getPrizeTypeNum(), integralActivity.getActivityTitle());
log.info("中奖加积分返回值情况 in2111:{}", in2111);
// 发放状态
receivingStatus = 2;
} catch (Exception e) {
log.error("抽奖发放积分失败 [userId:{}, num:{}]", userId, integralActivityPrizeVo.getPrizeTypeNum());
}*/
} }
integralActivityDrawVo.setReceivingStatus(receivingStatus); integralActivityDrawVo.setReceivingStatus(receivingStatus);
// redis // redis
redisDataUtils.setIntegralActivityDraw(integralActivityDrawVo); redisDataUtils.setIntegralActivityDraw(integralActivityDrawVo);
if (prizeType == 3 || prizeType == 4) { // 中实物减实物总库存 if (prizeType == StatusConst.PRIZE_TYPE3 || prizeType == StatusConst.PRIZE_TYPE4 || prizeType == StatusConst.PRIZE_TYPE5) { // 中实物减实物总库存
redisDataUtils.decrIntegralActivityTotalPrizeNum(integralActivityId); redisDataUtils.decrIntegralActivityTotalPrizeNum(integralActivityId);
} }
// mongo // mongo
......
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