京东/拼多多单品分享返回二维码

admin

2019-11-13 01d79990d0620bdb8900c9fe3d9b5cc7e843aa08

京东/拼多多单品分享返回二维码

 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/RedPackControllerV2.java

@@ -48,6 +48,7 @@
import com.yeshi.fanli.service.inter.redpack.RedPackWinNewUserService;

import com.yeshi.fanli.service.inter.user.UserInfoExtraService;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.service.inter.user.UserSystemCouponService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

@@ -94,6 +95,9 @@


    @Resource

    private SwiperPictureService swiperPictureService;

	
    @Resource

    private UserSystemCouponService userSystemCouponService;



    /**

     * 统计

@@ -413,6 +417,13 @@
        } else {

            data.put("inviteCode", "");

        }

		
        //

      long freeCouponCount=    userSystemCouponService.countUsableFreeCouponForBuy(uid);

      long     rewardCouponCount=  userSystemCouponService.countUsableRewardCoupon(uid);

	  
      data.put("freeCouponCount", freeCouponCount);

      data.put("rewardCouponCount", rewardCouponCount);



        if (!StringUtil.isNullOrEmpty(callback)) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));


 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareControllerV2.java

@@ -601,6 +601,7 @@


        ShareInfoVO shareInfo = new ShareInfoVO();

        shareInfo.setClickUrl(jumpLink);

        shareInfo.setWxErCode(jumpLink);

        shareInfo.setRule(configService.get("share_rule_link_jd"));

        shareInfo.setPictUrl(jdGoods.getPicUrl());



@@ -711,6 +712,7 @@


        ShareInfoVO shareInfo = new ShareInfoVO();

        shareInfo.setClickUrl(jumpLink);

        shareInfo.setWxErCode(jumpLink);

        shareInfo.setRule(configService.get("share_rule_link_pdd"));

        shareInfo.setPictUrl(goods.getGoodsImageUrl());




 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/coupon/SystemCouponMessageListener.java

@@ -31,8 +31,6 @@
                message.getTag(), new String(message.getBody()));

        String tag = message.getTag();

        BaseMQMsgBody baseBody = new Gson().fromJson(new String(message.getBody()), BaseMQMsgBody.class);

        if (baseBody.isTest() != Constant.IS_TEST)

            return Action.ReconsumeLater;



        if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {

            if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name()))// 实时到账


 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/BanLiShopOrderMessageListener.java

@@ -41,14 +41,7 @@


    @Override

    public Action consume(Message message, ConsumeContext context) {

        BaseMQMsgBody baseBody = null;

        try {

            baseBody = new Gson().fromJson(new String(message.getBody()), BaseMQMsgBody.class);

            if (baseBody.isTest() != Constant.IS_TEST)

                return Action.ReconsumeLater;

        } catch (Exception e) {

            e.printStackTrace();

        }

		
        LogHelper.mqInfo("consumer:BanLiShopOrderMessageListener",message.getMsgID(), message.getTopic(), message.getTag(),

                new String(message.getBody()));

        String tag = message.getTag();


 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/InviteOrderSubsidyMessageListener.java

@@ -62,10 +62,6 @@


    @Override

    public Action consume(Message message, ConsumeContext context) {



        BaseMQMsgBody baseBody = new Gson().fromJson(new String(message.getBody()), BaseMQMsgBody.class);

        if (baseBody.isTest() != Constant.IS_TEST)

            return Action.ReconsumeLater;

        LogHelper.mqInfo("consumer:InviteOrderSubsidyMessageListener", message.getMsgID(),message.getTopic(), message.getTag(),

                new String(message.getBody()));

        String tag = message.getTag();


 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java

@@ -50,9 +50,6 @@
        String tag = message.getTag();

        if (tag == null)

            tag = "";

        BaseMQMsgBody baseBody = new Gson().fromJson(new String(message.getBody()), BaseMQMsgBody.class);

        if (baseBody.isTest() != Constant.IS_TEST)

            return Action.ReconsumeLater;



        if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {

            if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {// 返利到账

@@ -112,6 +109,10 @@


            if (inviteSucceedReward) {

                try {// 邀请奖励

                    if(uid==6269748)

                    {

                        System.out.println(uid);

                    }

                    redPackWinInviteService.inviteSucceedReward(uid);

                } catch (Exception e) {

                    e.printStackTrace();


 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/token/InterTokenMessageListener.java

@@ -40,9 +40,6 @@
        String tag = message.getTag();

        if (tag == null)

            tag = "";

        BaseMQMsgBody baseBody = new Gson().fromJson(new String(message.getBody()), BaseMQMsgBody.class);

        if (baseBody.isTest() != Constant.IS_TEST)

            return Action.ReconsumeLater;



        if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {

            if (tag.equalsIgnoreCase(UserTopicTagEnum.tokenOutOfDate.name())) {// 口令过期