From 788deca1b4a24f8a24e49c24f7d89975a1d74bbe Mon Sep 17 00:00:00 2001 From: admin <2780501319@qq.com> Date: 星期日, 03 十一月 2019 23:31:25 +0800 Subject: [PATCH] 商城订单退款处理 --- fanli/src/main/java/com/yeshi/fanli/controller/TestController.java | 171 ++++++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 157 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..776f331 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; @@ -36,6 +38,7 @@ 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.ConfigParamsDTO; import com.yeshi.fanli.dto.jd.JDSearchResult; import com.yeshi.fanli.entity.bus.activity.ActivityShareResult; import com.yeshi.fanli.entity.bus.activity.RecommendActivity; @@ -43,9 +46,12 @@ 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.SearchFilter; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra; +import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult; 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 +60,8 @@ 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.service.inter.user.integral.IntegralGetService; import com.yeshi.fanli.tag.PageEntity; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.FileUtil; @@ -63,10 +70,16 @@ 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.util.push.VIVOPushUtil; +import com.yeshi.fanli.util.taobao.TaoBaoUtil; +import com.yeshi.fanli.util.taobao.TaoKeApiUtil; 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 +110,21 @@ @Resource private ConfigService configService; - + @Resource private HongBaoManageService hongBaoManageService; @Resource private InviteMaterialService inviteMaterialService; - + @Resource private DynamicInfoDao dynamicInfoDao; - + + @Resource + private JedisPool jedisPool; + + @Resource + private IntegralGetService integralGetService; @RequestMapping(value = "testimg") public void testImg(HttpServletRequest request, PrintWriter out) { @@ -431,9 +449,10 @@ e.printStackTrace(); } } - + /** * 鎻掑叆閭�璇风礌鏉� + * * @param out */ @RequestMapping(value = "getJingFenList") @@ -453,10 +472,12 @@ if (goodsList != null && goodsList.size() > 0) { BigDecimal fanLiRate = hongBaoManageService.getFanLiRate(); BigDecimal shareRate = hongBaoManageService.getShareRate(); + ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE); + 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, paramsDTO); array.add(gson.toJson(goodsDetailVO)); } } @@ -470,8 +491,7 @@ e.printStackTrace(); } } - - + /** * 鎻掑叆閭�璇风礌鏉� * @@ -481,35 +501,158 @@ 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"); + } + + @RequestMapping(value = "testListTLJGoods") + public void getGoodsList(String callback, PrintWriter out) { + SearchFilter sf = new SearchFilter(); + sf.setQuan(1); + sf.setTmall(true); + // sf.setEndPrice(new BigDecimal(1000)); + sf.setPage(1); + sf.setPage(100); + sf.setCateIds("16"); + sf.setSort(TaoBaoUtil.SORT_SALE_HIGH_TO_LOW); + + TaoBaoSearchResult result = TaoKeApiUtil.searchWuLiao(sf); + Gson gson = new Gson(); + JSONArray array = new JSONArray(); + for (TaoBaoGoodsBrief goods : result.getTaoBaoGoodsBriefs()) { + array.add(gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(goods, "100", null))); + } + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(array))); + } + + /** + * 鎻掑叆閭�璇风礌鏉� + * + * @param out + */ + @RequestMapping(value = "addInviteOrderLevelOne") + public void addInviteOrderLevelOne(PrintWriter out) { + try { + System.out.println("-------------璇锋眰---------------"); + integralGetService.addShareSingleGoods(974767L); + JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("鎿嶄綔鎴愬姛")); + } catch (Exception e) { + JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("鎿嶄綔澶辫触")); + e.printStackTrace(); + } + } + + @RequestMapping("pushVIVO") + public void pushVIVO(PrintWriter out) { + List<String> regList = new ArrayList<>(); + regList.add("15710270630271520610033"); + // regList.add("15711218630321520681531"); + // try { + // VIVOPushUtil.pushUrl(regList, "鏍囬", "缃戦〉鍐呭", "http://www.baidu.com"); + // } catch (Exception e) { + // } + + try { + VIVOPushUtil.pushBaiChuanUrl(regList, "鏍囬", "鐧惧窛鍐呭", "http://www.taobao.com");// 鏈塨ug + // VIVOPushUtil.pushGoods(regList, "鏍囬", "鍟嗗搧鍐呭", 2, 100005625634L); + // VIVOPushUtil.pushUserSignInNotification(regList, "鏍囬", "绛惧埌"); + // VIVOPushUtil.pushWelfareCenter(regList,"鏍囬", "绂忓埄涓績"); + } catch (PushException e) { + e.printStackTrace(); + } + } + + @RequestMapping("getSchedulerList") + public void getSchedulerList(PrintWriter out) { + try { + for (String groupName : scheduler.getJobGroupNames()) { + System.out.println(groupName); + } + } catch (Exception e) { + } + } + } -- Gitblit v1.8.0