From 0f52108bac0ebf47a563c41bcb97d934b7cf12ab Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期三, 11 十二月 2019 15:07:06 +0800 Subject: [PATCH] 订单筛选 --- fanli/src/main/java/com/yeshi/fanli/controller/TestController.java | 252 +++++++++++++++++--------------------------------- 1 files changed, 86 insertions(+), 166 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 b6e6e08..a69f674 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,22 @@ 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.ConfigParamsDTO; 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.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; @@ -50,19 +60,27 @@ 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.money.UserMoneyExtraService; +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; 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.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") @@ -93,12 +111,24 @@ @Resource private ConfigService configService; - + @Resource private HongBaoManageService hongBaoManageService; @Resource private InviteMaterialService inviteMaterialService; + + @Resource + private DynamicInfoDao dynamicInfoDao; + + @Resource + private JedisPool jedisPool; + + @Resource + private IntegralGetService integralGetService; + + @Resource + private UserMoneyExtraService userMoneyExtraService; @RequestMapping(value = "testimg") public void testImg(HttpServletRequest request, PrintWriter out) { @@ -280,187 +310,77 @@ } } - /** - * 鎻掑叆閭�璇风礌鏉� - * - * @param out - */ - @RequestMapping(value = "uploadInviteMaterial") - public void uploadInviteMaterial(PrintWriter out) { - try { - List<InviteMaterial> list = new ArrayList<InviteMaterial>(); - // 鍥剧墖鏂囦欢 - File file = new File("E:\\Invite\\Picture"); - File[] files = file.listFiles(); - for (File filePic : files) {// 閬嶅巻杩欎釜鏁扮粍 - String name = filePic.getName(); - String prefix = name.substring(name.lastIndexOf(".") + 1); - // 涓婁紶鏂囦欢鐩稿浣嶇疆 - String filePath = "/resource/invite/everyday/" + UUID.randomUUID().toString().replace("-", "") + "." - + prefix; - String fileUrl = COSManager.getInstance().uploadFile(filePic, filePath).getUrl(); - - System.out.println("FileName:" + name); - System.out.println("url:" + fileUrl); - - InviteMaterial inviteMaterial = new InviteMaterial(); - inviteMaterial.setState(0); - inviteMaterial.setPicture(fileUrl); - list.add(inviteMaterial); - } - - List<String> listTxt = new ArrayList<String>(); - File textfile = new File("E:\\Invite\\content.txt");// Text鏂囦欢 - BufferedReader br = new BufferedReader(new FileReader(textfile));// 鏋勯�犱竴涓狟ufferedReader绫绘潵璇诲彇鏂囦欢 - String s = ""; - while ((s = br.readLine()) != null) {// 浣跨敤readLine鏂规硶锛屼竴娆¤涓�琛� - if (StringUtil.isNullOrEmpty(s)) { - continue; - } - listTxt.add(s); - } - br.close(); - - if (list.size() == 0 || listTxt.size() == 0 || listTxt.size() < list.size()) { - return; - } - - for (int i = 0; i < list.size(); i++) { - InviteMaterial invite = list.get(i); - invite.setText(listTxt.get(i)); - inviteMaterialService.insert(invite); - } - JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("涓婁紶鎴愬姛")); - } catch (Exception e) { - JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("涓婁紶澶辫触")); - e.printStackTrace(); - } + @RequestMapping(value = "getWaitingThreadsCount") + public void getWaitingThreadsCount(PrintWriter out) { + out.print(Constant.waitingThreadSet.size()); } - /** - * 鎻掑叆閭�璇风礌鏉� - * - * @param out - */ - @RequestMapping(value = "uploadInviteMaterial2") - public void uploadInviteMaterial2(PrintWriter out) { + @RequestMapping(value = "getBinFaRedisKey") + public void getPinFaRedisKey(PrintWriter out) { + JSONArray array = new JSONArray(); + Jedis jedis = jedisPool.getResource(); try { - List<InviteMaterial> list = new ArrayList<InviteMaterial>(); - File picfile = new File("E:\\Invite\\pic.txt");// Text鏂囦欢 - BufferedReader brp = new BufferedReader(new FileReader(picfile));// 鏋勯�犱竴涓狟ufferedReader绫绘潵璇诲彇鏂囦欢 - String fileUrl = ""; - while ((fileUrl = brp.readLine()) != null) {// 浣跨敤readLine鏂规硶锛屼竴娆¤涓�琛� - if (StringUtil.isNullOrEmpty(fileUrl)) { - continue; - } - InviteMaterial inviteMaterial = new InviteMaterial(); - inviteMaterial.setId(UUID.randomUUID().toString().replace("-", "")); - inviteMaterial.setState(0); - inviteMaterial.setPicture(fileUrl); - list.add(inviteMaterial); - } - brp.close(); - - List<String> listTxt = new ArrayList<String>(); - File textfile = new File("E:\\Invite\\content.txt");// Text鏂囦欢 - BufferedReader br = new BufferedReader(new FileReader(textfile));// 鏋勯�犱竴涓狟ufferedReader绫绘潵璇诲彇鏂囦欢 - String s = ""; - while ((s = br.readLine()) != null) {// 浣跨敤readLine鏂规硶锛屼竴娆¤涓�琛� - if (StringUtil.isNullOrEmpty(s)) { - continue; - } - listTxt.add(s); - } - br.close(); - - if (list.size() == 0 || listTxt.size() == 0 || listTxt.size() < list.size()) { - return; - } - - for (int i = 0; i < list.size(); i++) { - InviteMaterial invite = list.get(i); - invite.setText(listTxt.get(i)); - inviteMaterialService.insert(invite); - } - JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("涓婁紶鎴愬姛")); - } catch (Exception e) { - JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("涓婁紶澶辫触")); - e.printStackTrace(); + Set<String> sets = jedis.keys("rs-*"); + for (Iterator<String> its = sets.iterator(); its.hasNext();) + array.add(its.next()); + } finally { + jedis.close(); } + out.println(array.toString()); } - /** - * 鎻掑叆閭�璇风礌鏉� - * - * @param out - */ - @RequestMapping(value = "saveInvite") - public void saveInvite(InviteMaterial inviteMaterial, PrintWriter out) { + @RequestMapping(value = "pushOppo") + public void pushOppo(String registerId, PrintWriter out) { + List<String> registerIds = new ArrayList<>(); + registerIds.add(registerId); try { - inviteMaterial.setState(0); - inviteMaterialService.insert(inviteMaterial); - JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("涓婁紶鎴愬姛")); - } catch (Exception e) { - JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("涓婁紶澶辫触")); + 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"); } - /** - * 鎻掑叆閭�璇风礌鏉� - * - * @param out - */ - @RequestMapping(value = "insertTimeInvite") - public void insertTimeInvite(PrintWriter out) { - try { - dynamicInfoService.insertTimeInvite(); - JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("鎿嶄綔鎴愬姛")); - } catch (Exception e) { - JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("鎿嶄綔澶辫触")); - e.printStackTrace(); - } - } + - /** - * 鎻掑叆閭�璇风礌鏉� - * @param out - */ - @RequestMapping(value = "getJingFenList") - public void getJingFenList(String callback, Integer page, Integer eliteId, PrintWriter out) { + + @RequestMapping("getLocalTime") + public void getLocalTime(PrintWriter out) { + out.print(TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss")); + } + + @RequestMapping("getSchedulerList") + public void getSchedulerList(PrintWriter out) { try { - JDSearchResult result = JDApiUtil.getJingFenGoods(page, eliteId); - long count = 0; - JSONObject data = new JSONObject(); - JSONArray array = new JSONArray(); - if (result != null) { - PageEntity pageEntity = result.getPageEntity(); - if (pageEntity != null) { - count = pageEntity.getTotalCount(); - } - - List<JDGoods> goodsList = result.getGoodsList(); - if (goodsList != null && goodsList.size() > 0) { - BigDecimal fanLiRate = hongBaoManageService.getFanLiRate(); - BigDecimal shareRate = hongBaoManageService.getShareRate(); - Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) - .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); - for (JDGoods goods : goodsList) { - GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, null, fanLiRate, - shareRate); - array.add(gson.toJson(goodsDetailVO)); - } - } + for (String groupName : scheduler.getJobGroupNames()) { + System.out.println(groupName); } - - data.put("count", count); - data.put("list", array); - JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔澶辫触")); - e.printStackTrace(); } } } -- Gitblit v1.8.0