From 28a0efc6ec16f3f82eb8e16e87269300d6744fd4 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 25 九月 2019 19:18:17 +0800 Subject: [PATCH] 金币版本拦截与频率拦截bug修改 --- fanli/src/main/java/com/yeshi/fanli/controller/TestController.java | 105 +++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 103 insertions(+), 2 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 91896fe..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; @@ -34,14 +36,19 @@ import com.google.gson.Gson; import com.google.gson.GsonBuilder; +import com.yeshi.fanli.dao.dynamic.DynamicInfoDao; import com.yeshi.fanli.dao.mybatis.help.HelpCenterMapper; import com.yeshi.fanli.dto.jd.JDSearchResult; import com.yeshi.fanli.entity.bus.activity.ActivityShareResult; import com.yeshi.fanli.entity.bus.activity.RecommendActivity; +import com.yeshi.fanli.entity.dynamic.DynamicInfo; +import com.yeshi.fanli.entity.dynamic.GoodsPicture; import com.yeshi.fanli.entity.dynamic.InviteMaterial; import com.yeshi.fanli.entity.jd.JDGoods; 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; @@ -50,16 +57,16 @@ 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; import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; -import com.yeshi.fanli.util.TimeUtil; 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; @@ -102,6 +109,9 @@ @Resource private InviteMaterialService inviteMaterialService; + + @Resource + private DynamicInfoDao dynamicInfoDao; @Resource private JedisPool jedisPool; @@ -470,8 +480,99 @@ } } + /** + * 鎻掑叆閭�璇风礌鏉� + * + * @param out + */ + @RequestMapping(value = "queryExistsId") + public void queryExistsAuctionId(PrintWriter out) { + try { + List<DynamicInfo> list = dynamicInfoDao.queryExistsAuctionId(); + for (DynamicInfo dynamicInfo : list) { + List<GoodsPicture> imgs = dynamicInfo.getImgs(); + if (imgs == null || imgs.size() == 0) { + continue; + } + + boolean update = false; + 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))); + } 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