添加邀请队列处理问题

admin

2019-03-04 424af15ba8eb28816e243b1c547b8543a3c41be5

添加邀请队列处理问题

 fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java

@@ -64,10 +64,9 @@


    @Resource

    private QualityFactoryService qualityFactoryService;

	


    @Resource

    private UserSystemCouponService userSystemCouponService;

	


    private static boolean isInited = false;



@@ -95,6 +94,7 @@
            doOrderTiChengFanLi();// 处理订单提成返利

            doWeiQuanOrder();// 处理维权订单

            doPushIOS();// 处理发送IOS消息

            doThreeSaleUserCouponJob();// 处理邀请队列

        } else if (!Constant.IS_TEST) {

            initScheduler();// 启动定时任务

            // doUpdateGoodsJob();

@@ -420,7 +420,7 @@
                                        ThreeSale threeSale = map.get(key);

                                        if (threeSale != null) {

                                            if (threeSale.getState() != null && threeSale.getState() == true) {

                                                // 邀请成功  - 券激活生效

                                                // 邀请成功 - 券激活生效

                                                Long bossId = threeSale.getBoss().getId();

                                                userSystemCouponService.activatedWelfareFreeCoupon(bossId);

                                            }


 fanli/src/main/java/com/yeshi/fanli/util/ThreeSaleCMQManager.java

@@ -1,20 +1,14 @@
package com.yeshi.fanli.util;



import java.lang.reflect.Type;

import java.util.HashMap;

import java.util.Iterator;

import java.util.List;

import java.util.Map;



import org.yeshi.utils.CMQUtil;



import com.google.gson.Gson;

import com.google.gson.reflect.TypeToken;

import com.qcloud.cmq.Message;

import com.yeshi.fanli.entity.bus.user.ThreeSale;

import com.yeshi.fanli.entity.taobao.TaoBaoOrder;



import net.sf.json.JSONObject;



public class ThreeSaleCMQManager {