From 14d45c1a99ad606cec73ec5e66be5ebd484cacd1 Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期四, 26 九月 2019 11:55:11 +0800
Subject: [PATCH] 金币 bug
---
fanli/src/main/java/com/yeshi/fanli/controller/TestController.java | 91 ++++++++++++++++++++++++++++++++++++++-------
1 files changed, 77 insertions(+), 14 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java b/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
index 765adde..1d46d39 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
@@ -8,7 +8,9 @@
import java.io.PrintWriter;
import java.math.BigDecimal;
import java.util.ArrayList;
+import java.util.Iterator;
import java.util.List;
+import java.util.Set;
import java.util.UUID;
import javax.annotation.Resource;
@@ -46,6 +48,7 @@
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;
import com.yeshi.fanli.exception.ActivityException;
+import com.yeshi.fanli.exception.push.PushException;
import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
import com.yeshi.fanli.log.LogHelper;
@@ -54,7 +57,7 @@
import com.yeshi.fanli.service.inter.dynamic.DynamicInfoService;
import com.yeshi.fanli.service.inter.dynamic.InviteMaterialService;
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
-import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
+import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
import com.yeshi.fanli.tag.PageEntity;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.FileUtil;
@@ -63,10 +66,13 @@
import com.yeshi.fanli.util.db.MongoDBManager;
import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
import com.yeshi.fanli.util.jd.JDApiUtil;
+import com.yeshi.fanli.util.push.OPPOPushUtil;
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.JedisPool;
@Controller
@RequestMapping("test")
@@ -97,16 +103,18 @@
@Resource
private ConfigService configService;
-
+
@Resource
private HongBaoManageService hongBaoManageService;
@Resource
private InviteMaterialService inviteMaterialService;
-
+
@Resource
private DynamicInfoDao dynamicInfoDao;
-
+
+ @Resource
+ private JedisPool jedisPool;
@RequestMapping(value = "testimg")
public void testImg(HttpServletRequest request, PrintWriter out) {
@@ -431,9 +439,10 @@
e.printStackTrace();
}
}
-
+
/**
* 鎻掑叆閭�璇风礌鏉�
+ *
* @param out
*/
@RequestMapping(value = "getJingFenList")
@@ -456,7 +465,7 @@
Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
.excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
for (JDGoods goods : goodsList) {
- GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate);
+ GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate);
array.add(gson.toJson(goodsDetailVO));
}
}
@@ -470,8 +479,7 @@
e.printStackTrace();
}
}
-
-
+
/**
* 鎻掑叆閭�璇风礌鏉�
*
@@ -481,35 +489,90 @@
public void queryExistsAuctionId(PrintWriter out) {
try {
List<DynamicInfo> list = dynamicInfoDao.queryExistsAuctionId();
- for (DynamicInfo dynamicInfo: list) {
+ for (DynamicInfo dynamicInfo : list) {
List<GoodsPicture> imgs = dynamicInfo.getImgs();
if (imgs == null || imgs.size() == 0) {
continue;
}
-
+
boolean update = false;
- for (GoodsPicture goodsPicture: imgs) {
+ for (GoodsPicture goodsPicture : imgs) {
TaoBaoGoodsBriefExtra goods = goodsPicture.getGoods();
if (goods == null) {
continue;
}
-
+
if (goods.getAuctionId() == null) {
update = true;
goods.setAuctionId(goods.getId());
}
}
-
+
if (update) {
dynamicInfo.setImgs(imgs);
dynamicInfoDao.updateGoodInfo(dynamicInfo);
}
}
JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("鎿嶄綔鎴愬姛"));
-// JsonUtil.printMode(out, null, JsonUtil.loadTrueResult(JsonUtil.getSimpleGson().toJson(list)));
+ // JsonUtil.printMode(out, null,
+ // JsonUtil.loadTrueResult(JsonUtil.getSimpleGson().toJson(list)));
} catch (Exception e) {
JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("鎿嶄綔澶辫触"));
e.printStackTrace();
}
}
+
+ @RequestMapping(value = "getWaitingThreadsCount")
+ public void getWaitingThreadsCount(PrintWriter out) {
+ out.print(Constant.waitingThreadSet.size());
+ }
+
+ @RequestMapping(value = "getBinFaRedisKey")
+ public void getPinFaRedisKey(PrintWriter out) {
+ JSONArray array = new JSONArray();
+ Jedis jedis = jedisPool.getResource();
+ try {
+ Set<String> sets = jedis.keys("rs-*");
+ for (Iterator<String> its = sets.iterator(); its.hasNext();)
+ array.add(its.next());
+ } finally {
+ jedisPool.returnResource(jedis);
+ }
+ out.println(array.toString());
+ }
+
+ @RequestMapping(value = "pushOppo")
+ public void pushOppo(String registerId, PrintWriter out) {
+ List<String> registerIds = new ArrayList<>();
+ registerIds.add(registerId);
+ try {
+ OPPOPushUtil.pushUrl(registerIds, "娴嬭瘯缃戦〉鎺ㄩ��", "娴嬭瘯缃戦〉鎺ㄩ�佸唴瀹�", "http://www.baidu.com");
+ } catch (PushException e) {
+ e.printStackTrace();
+ }
+
+ try {
+ OPPOPushUtil.pushGoods(registerIds, "娴嬭瘯鍟嗗搧缃戦〉鎺ㄩ��", "娴嬭瘯鍟嗗搧鎺ㄩ�佸唴瀹�", 1, 577628549116L);
+ } catch (PushException e) {
+ e.printStackTrace();
+ }
+
+ try {
+ OPPOPushUtil.pushUserSignInNotification(registerIds, "娴嬭瘯绛惧埌鎺ㄩ��", "娴嬭瘯绛惧埌鎺ㄩ��");
+ } catch (PushException e) {
+ e.printStackTrace();
+ }
+ try {
+ OPPOPushUtil.pushWelfareCenter(registerIds, "娴嬭瘯绂忓埄涓績鎺ㄩ��", "娴嬭瘯绂忓埄涓績鎺ㄩ��");
+ } catch (PushException e) {
+ e.printStackTrace();
+ }
+ try {
+ OPPOPushUtil.pushZNX(registerIds, "娴嬭瘯绔欏唴淇℃帹閫�", "娴嬭瘯绔欏唴淇℃帹閫�");
+ } catch (PushException e) {
+ e.printStackTrace();
+ }
+
+ out.print("success");
+ }
}
--
Gitblit v1.8.0