| | |
| | | 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;
|
| | | import com.yeshi.fanli.log.LogHelper;
|
| | |
|
| | | public class ThreeSaleCMQManager {
|
| | |
|
| | |
| | | if (threeSale == null)
|
| | | return;
|
| | | cmqUtil.publishTopicMessage(TOPIC_NAME, new Gson().toJson(threeSale));
|
| | | LogHelper.test("邀请消息投递成功");
|
| | | }
|
| | |
|
| | | /**
|