| | |
|---|
| | | package com.yeshi.fanli.controller;
|
|---|
| | |
|
|---|
| | | import java.io.BufferedReader;
|
|---|
| | | import java.io.File;
|
|---|
| | | import java.io.FileReader;
|
|---|
| | | import java.io.IOException;
|
|---|
| | | 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;
|
|---|
| | | import javax.script.Invocable;
|
|---|
| | | import javax.script.ScriptEngine;
|
|---|
| | | import javax.script.ScriptEngineManager;
|
|---|
| | | import javax.servlet.http.HttpServletRequest;
|
|---|
| | |
|
|---|
| | | import com.yeshi.fanli.entity.SystemEnum;
|
|---|
| | | import org.jsoup.Jsoup;
|
|---|
| | | import org.jsoup.nodes.Document;
|
|---|
| | | import org.jsoup.select.Elements;
|
|---|
| | | import org.quartz.JobExecutionContext;
|
|---|
| | | import org.quartz.Scheduler;
|
|---|
| | | import org.quartz.SchedulerException;
|
|---|
| | | import org.springframework.cache.ehcache.EhCacheCacheManager;
|
|---|
| | | import org.springframework.stereotype.Controller;
|
|---|
| | | import org.springframework.web.bind.annotation.RequestMapping;
|
|---|
| | | import org.yeshi.utils.JsonUtil;
|
|---|
| | | import org.yeshi.utils.wx.WXUtil;
|
|---|
| | |
|
|---|
| | | 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.entity.SystemEnum;
|
|---|
| | | import com.yeshi.fanli.entity.bus.activity.ActivityShareResult;
|
|---|
| | | import com.yeshi.fanli.entity.bus.activity.RecommendActivity;
|
|---|
| | | import com.yeshi.fanli.entity.dynamic.InviteMaterial;
|
|---|
| | | import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
|
|---|
| | | import com.yeshi.fanli.exception.ActivityException;
|
|---|
| | | import com.yeshi.fanli.exception.push.PushException;
|
|---|
| | | import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;
|
|---|
| | |
|---|
| | | 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.money.UserMoneyExtraService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.RedisManager;
|
|---|
| | | import com.yeshi.fanli.util.StringUtil;
|
|---|
| | | import org.yeshi.utils.TimeUtil;
|
|---|
| | | import com.yeshi.fanli.util.db.MongoDBManager;
|
|---|
| | | import com.yeshi.fanli.util.push.OPPOPushUtil;
|
|---|
| | | import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
|---|
| | |
|
|---|
| | | import com.yeshi.goods.facade.entity.taobao.TaoBaoCouponCache;
|
|---|
| | | import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
|
|---|
| | | import com.yeshi.goods.facade.service.TaoBaoCouponCacheService;
|
|---|
| | | import net.sf.json.JSONArray;
|
|---|
| | | import net.sf.json.JSONObject;
|
|---|
| | | import org.apache.dubbo.config.annotation.Reference;
|
|---|
| | | import org.jsoup.Jsoup;
|
|---|
| | | import org.jsoup.nodes.Document;
|
|---|
| | | import org.jsoup.select.Elements;
|
|---|
| | | import org.quartz.JobExecutionContext;
|
|---|
| | | import org.quartz.Scheduler;
|
|---|
| | | import org.quartz.SchedulerException;
|
|---|
| | | import org.springframework.cache.ehcache.EhCacheCacheManager;
|
|---|
| | | import org.springframework.stereotype.Controller;
|
|---|
| | | import org.springframework.web.bind.annotation.RequestMapping;
|
|---|
| | | import org.yeshi.utils.JsonUtil;
|
|---|
| | | import org.yeshi.utils.TimeUtil;
|
|---|
| | | import org.yeshi.utils.wx.WXUtil;
|
|---|
| | | import redis.clients.jedis.Jedis;
|
|---|
| | | import redis.clients.jedis.JedisPool;
|
|---|
| | |
|
|---|
| | | import javax.annotation.Resource;
|
|---|
| | | import javax.script.Invocable;
|
|---|
| | | import javax.script.ScriptEngine;
|
|---|
| | | import javax.script.ScriptEngineManager;
|
|---|
| | | import javax.servlet.http.HttpServletRequest;
|
|---|
| | | import java.io.*;
|
|---|
| | | import java.math.BigDecimal;
|
|---|
| | | import java.util.*;
|
|---|
| | |
|
|---|
| | | @Controller
|
|---|
| | | @RequestMapping("test")
|
|---|
| | | public class TestController {
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private RedisManager redisManager;
|
|---|
| | | @Resource
|
|---|
| | | private RedisManager redisManager;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private ActivityService activityService;
|
|---|
| | | @Resource
|
|---|
| | | private ActivityService activityService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private MongoDBManager mongoDBManager;
|
|---|
| | | @Resource
|
|---|
| | | private MongoDBManager mongoDBManager;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private HelpCenterMapper helpCenterMapper;
|
|---|
| | | @Resource
|
|---|
| | | private Scheduler scheduler;
|
|---|
| | | @Resource
|
|---|
| | | private HelpCenterMapper helpCenterMapper;
|
|---|
| | | @Resource
|
|---|
| | | private Scheduler scheduler;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private DynamicInfoService dynamicInfoService;
|
|---|
| | | @Resource
|
|---|
| | | private DynamicInfoService dynamicInfoService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private TaoBaoGoodsBriefService taoBaoGoodsBriefService;
|
|---|
| | | @Resource
|
|---|
| | | private TaoBaoGoodsBriefService taoBaoGoodsBriefService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private EhCacheCacheManager ehCacheCacheManager;
|
|---|
| | | @Resource
|
|---|
| | | private EhCacheCacheManager ehCacheCacheManager;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private ConfigService configService;
|
|---|
| | | @Resource
|
|---|
| | | private ConfigService configService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private HongBaoManageService hongBaoManageService;
|
|---|
| | | @Resource
|
|---|
| | | private HongBaoManageService hongBaoManageService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private InviteMaterialService inviteMaterialService;
|
|---|
| | | @Resource
|
|---|
| | | private InviteMaterialService inviteMaterialService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private DynamicInfoDao dynamicInfoDao;
|
|---|
| | | @Resource
|
|---|
| | | private DynamicInfoDao dynamicInfoDao;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private JedisPool jedisPool;
|
|---|
| | | @Resource
|
|---|
| | | private JedisPool jedisPool;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private IntegralGetService integralGetService;
|
|---|
| | | @Resource
|
|---|
| | | private TaoBaoCouponCacheService taoBaoCouponCacheService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserMoneyExtraService userMoneyExtraService;
|
|---|
| | | @RequestMapping(value = "kefu")
|
|---|
| | | public void kefu(HttpServletRequest request, PrintWriter out) {
|
|---|
| | | String content = WXUtil.getContent(request);
|
|---|
| | | LogHelper.test(content);
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "kefu")
|
|---|
| | | public void kefu(HttpServletRequest request, PrintWriter out) {
|
|---|
| | | String content = WXUtil.getContent(request);
|
|---|
| | | LogHelper.test(content);
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "testactivity")
|
|---|
| | | public void test2(PrintWriter out) {
|
|---|
| | | List<RecommendActivity> list = activityService.getRecommendActivityList(1, Constant.PAGE_SIZE);
|
|---|
| | | long count = activityService.getRecommendActivityCount(null);
|
|---|
| | | JSONObject data = new JSONObject();
|
|---|
| | | data.put("data", getGson().toJson(list));
|
|---|
| | | data.put("count", count);
|
|---|
| | | out.print(JsonUtil.loadTrueResult(data));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "testactivity")
|
|---|
| | | public void test2(PrintWriter out) {
|
|---|
| | | List<RecommendActivity> list = activityService.getRecommendActivityList(1, Constant.PAGE_SIZE);
|
|---|
| | | long count = activityService.getRecommendActivityCount(null);
|
|---|
| | | JSONObject data = new JSONObject();
|
|---|
| | | data.put("data", getGson().toJson(list));
|
|---|
| | | data.put("count", count);
|
|---|
| | | out.print(JsonUtil.loadTrueResult(data));
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "testactivitysharegoods")
|
|---|
| | | public void test3(PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | ActivityShareResult result = activityService.shareActivityGoods(343448L, 1L);
|
|---|
| | | out.print(JsonUtil.getSimpleGson().toJson(result));
|
|---|
| | | } catch (UserShareGoodsRecordException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | } catch (ActivityException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "testactivitysharegoods")
|
|---|
| | | public void test3(PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | ActivityShareResult result = activityService.shareActivityGoods(343448L, 1L);
|
|---|
| | | out.print(JsonUtil.getSimpleGson().toJson(result));
|
|---|
| | | } catch (UserShareGoodsRecordException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | } catch (ActivityException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "testactivityshareinvite")
|
|---|
| | | public void test4(PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | ActivityShareResult result = activityService.shareInviteImg(343448L, 2L);
|
|---|
| | | out.print(JsonUtil.getSimpleGson().toJson(result));
|
|---|
| | | } catch (ActivityException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "testactivityshareinvite")
|
|---|
| | | public void test4(PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | ActivityShareResult result = activityService.shareInviteImg(343448L, 2L);
|
|---|
| | | out.print(JsonUtil.getSimpleGson().toJson(result));
|
|---|
| | | } catch (ActivityException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "testnumber")
|
|---|
| | | public void test5(PrintWriter out) {
|
|---|
| | | JSONArray array = new JSONArray();
|
|---|
| | | for (int i = 0; i < 1000; i++) {
|
|---|
| | | JSONObject data = new JSONObject();
|
|---|
| | | data.put("number", new BigDecimal("10").add(new BigDecimal("0.1").multiply(new BigDecimal(i))));
|
|---|
| | | array.add(data);
|
|---|
| | | }
|
|---|
| | | out.print(array.toString());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "testnumber")
|
|---|
| | | public void test5(PrintWriter out) {
|
|---|
| | | JSONArray array = new JSONArray();
|
|---|
| | | for (int i = 0; i < 1000; i++) {
|
|---|
| | | JSONObject data = new JSONObject();
|
|---|
| | | data.put("number", new BigDecimal("10").add(new BigDecimal("0.1").multiply(new BigDecimal(i))));
|
|---|
| | | array.add(data);
|
|---|
| | | }
|
|---|
| | | out.print(array.toString());
|
|---|
| | | }
|
|---|
| | | private Gson getGson() {
|
|---|
| | | GsonBuilder gb = new GsonBuilder();
|
|---|
| | | gb.setDateFormat("MM-dd HH:mm");
|
|---|
| | | gb.excludeFieldsWithoutExposeAnnotation();
|
|---|
| | | Gson gson = gb.create();
|
|---|
| | | return gson;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | private Gson getGson() {
|
|---|
| | | GsonBuilder gb = new GsonBuilder();
|
|---|
| | | gb.setDateFormat("MM-dd HH:mm");
|
|---|
| | | gb.excludeFieldsWithoutExposeAnnotation();
|
|---|
| | | Gson gson = gb.create();
|
|---|
| | | return gson;
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "scheduler")
|
|---|
| | | public void test8(PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | List<JobExecutionContext> jobList = scheduler.getCurrentlyExecutingJobs();
|
|---|
| | | out.print("running job:" + jobList.size());
|
|---|
| | | } catch (SchedulerException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "scheduler")
|
|---|
| | | public void test8(PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | List<JobExecutionContext> jobList = scheduler.getCurrentlyExecutingJobs();
|
|---|
| | | out.print("running job:" + jobList.size());
|
|---|
| | | } catch (SchedulerException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "testhtml")
|
|---|
| | | public void testhtml(PrintWriter out) {
|
|---|
| | | out.print("<script>yestv.finishPage();</script>");
|
|---|
| | | out.close();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "testhtml")
|
|---|
| | | public void testhtml(PrintWriter out) {
|
|---|
| | | out.print("<script>yestv.finishPage();</script>");
|
|---|
| | | out.close();
|
|---|
| | | }
|
|---|
| | | /**
|
|---|
| | | * 清除缓存
|
|---|
| | | *
|
|---|
| | | * @param out
|
|---|
| | | */
|
|---|
| | | @RequestMapping(value = "removeCache")
|
|---|
| | | public void removeCache(PrintWriter out) {
|
|---|
| | | ehCacheCacheManager.getCacheManager().clearAll();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 清除缓存
|
|---|
| | | * |
|---|
| | | * @param out
|
|---|
| | | */
|
|---|
| | | @RequestMapping(value = "removeCache")
|
|---|
| | | public void removeCache(PrintWriter out) {
|
|---|
| | | ehCacheCacheManager.getCacheManager().clearAll();
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "removeRedisCache")
|
|---|
| | | public void removeRedisCache(String key, PrintWriter out) {
|
|---|
| | | redisManager.removeCommonString(key);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "removeRedisCache")
|
|---|
| | | public void removeRedisCache(String key, PrintWriter out) {
|
|---|
| | | redisManager.removeCommonString(key);
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "testConfig")
|
|---|
| | | public void getTestConfig(PrintWriter pw) {
|
|---|
| | | pw.print(configService.getValue("test", SystemEnum.blks));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "testConfig")
|
|---|
| | | public void getTestConfig(PrintWriter pw) {
|
|---|
| | | pw.print(configService.getValue("test", SystemEnum.blks));
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "testDaTaoKe")
|
|---|
| | | public void getTestDaTaoKe(PrintWriter pw) {
|
|---|
| | | Document doc = null;
|
|---|
| | | try {
|
|---|
| | | doc = Jsoup.connect("http://www.dataoke.com/ddq").get();
|
|---|
| | | } catch (IOException e1) {
|
|---|
| | | e1.printStackTrace();
|
|---|
| | | }
|
|---|
| | | Elements els = doc.getElementsByTag("script");
|
|---|
| | | for (int i = 0; i < els.size(); i++) {
|
|---|
| | | String content = els.get(i).html();
|
|---|
| | | if (content.indexOf("var dataDef") > -1) {
|
|---|
| | | ScriptEngineManager manager = new ScriptEngineManager();
|
|---|
| | | ScriptEngine engine = manager.getEngineByName("javascript");
|
|---|
| | | try {
|
|---|
| | | String js = "function getData(){return JSON.stringify(dataDef);}" + content;
|
|---|
| | | engine.eval(js);
|
|---|
| | | if (engine instanceof Invocable) {
|
|---|
| | | Invocable in = (Invocable) engine;
|
|---|
| | | pw.print(in.invokeFunction("getData"));
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "testDaTaoKe")
|
|---|
| | | public void getTestDaTaoKe(PrintWriter pw) {
|
|---|
| | | Document doc = null;
|
|---|
| | | try {
|
|---|
| | | doc = Jsoup.connect("http://www.dataoke.com/ddq").get();
|
|---|
| | | } catch (IOException e1) {
|
|---|
| | | e1.printStackTrace();
|
|---|
| | | }
|
|---|
| | | Elements els = doc.getElementsByTag("script");
|
|---|
| | | for (int i = 0; i < els.size(); i++) {
|
|---|
| | | String content = els.get(i).html();
|
|---|
| | | if (content.indexOf("var dataDef") > -1) {
|
|---|
| | | ScriptEngineManager manager = new ScriptEngineManager();
|
|---|
| | | ScriptEngine engine = manager.getEngineByName("javascript");
|
|---|
| | | try {
|
|---|
| | | String js = "function getData(){return JSON.stringify(dataDef);}" + content;
|
|---|
| | | engine.eval(js);
|
|---|
| | | if (engine instanceof Invocable) {
|
|---|
| | | Invocable in = (Invocable) engine;
|
|---|
| | | pw.print(in.invokeFunction("getData"));
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | /**
|
|---|
| | | * 插入邀请素材
|
|---|
| | | *
|
|---|
| | | * @param out
|
|---|
| | | */
|
|---|
| | | @RequestMapping(value = "uploadInviteMaterial2")
|
|---|
| | | public void uploadInviteMaterial2(PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | List<InviteMaterial> list = new ArrayList<InviteMaterial>();
|
|---|
| | | File picfile = new File("E:\\Invite\\pic.txt");// Text文件
|
|---|
| | | BufferedReader brp = new BufferedReader(new FileReader(picfile));// 构造一个BufferedReader类来读取文件
|
|---|
| | | 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();
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 插入邀请素材
|
|---|
| | | * |
|---|
| | | * @param out
|
|---|
| | | */
|
|---|
| | | @RequestMapping(value = "uploadInviteMaterial2")
|
|---|
| | | public void uploadInviteMaterial2(PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | List<InviteMaterial> list = new ArrayList<InviteMaterial>();
|
|---|
| | | File picfile = new File("E:\\Invite\\pic.txt");// Text文件
|
|---|
| | | BufferedReader brp = new BufferedReader(new FileReader(picfile));// 构造一个BufferedReader类来读取文件
|
|---|
| | | 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));// 构造一个BufferedReader类来读取文件
|
|---|
| | | String s = "";
|
|---|
| | | while ((s = br.readLine()) != null) {// 使用readLine方法，一次读一行
|
|---|
| | | if (StringUtil.isNullOrEmpty(s)) {
|
|---|
| | | continue;
|
|---|
| | | }
|
|---|
| | | listTxt.add(s);
|
|---|
| | | }
|
|---|
| | | br.close();
|
|---|
| | |
|
|---|
| | | List<String> listTxt = new ArrayList<String>();
|
|---|
| | | File textfile = new File("E:\\Invite\\content.txt");// Text文件
|
|---|
| | | BufferedReader br = new BufferedReader(new FileReader(textfile));// 构造一个BufferedReader类来读取文件
|
|---|
| | | 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;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | 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();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | 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();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | /**
|
|---|
| | | * 插入邀请素材
|
|---|
| | | *
|
|---|
| | | * @param out
|
|---|
| | | */
|
|---|
| | | @RequestMapping(value = "saveInvite")
|
|---|
| | | public void saveInvite(InviteMaterial inviteMaterial, PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | inviteMaterial.setState(0);
|
|---|
| | | inviteMaterialService.insert(inviteMaterial);
|
|---|
| | | JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("上传成功"));
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("上传失败"));
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 插入邀请素材
|
|---|
| | | * |
|---|
| | | * @param out
|
|---|
| | | */
|
|---|
| | | @RequestMapping(value = "saveInvite")
|
|---|
| | | public void saveInvite(InviteMaterial inviteMaterial, PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | inviteMaterial.setState(0);
|
|---|
| | | inviteMaterialService.insert(inviteMaterial);
|
|---|
| | | JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("上传成功"));
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("上传失败"));
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | /**
|
|---|
| | | * 插入邀请素材
|
|---|
| | | *
|
|---|
| | | * @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 = "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();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | @RequestMapping(value = "getWaitingThreadsCount")
|
|---|
| | | public void getWaitingThreadsCount(PrintWriter out) {
|
|---|
| | | out.print(Constant.waitingThreadSet.size());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @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 = redisManager.getJedis();
|
|---|
| | | try {
|
|---|
| | | 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());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping(value = "getBinFaRedisKey")
|
|---|
| | | public void getPinFaRedisKey(PrintWriter out) {
|
|---|
| | | JSONArray array = new JSONArray();
|
|---|
| | | Jedis jedis = redisManager.getJedis();
|
|---|
| | | try {
|
|---|
| | | 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());
|
|---|
| | | }
|
|---|
| | | @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();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @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.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();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | 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");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | out.print("success");
|
|---|
| | | }
|
|---|
| | | @RequestMapping("getLocalTime")
|
|---|
| | | public void getLocalTime(PrintWriter out) {
|
|---|
| | | out.print(TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss"));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @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 {
|
|---|
| | | for (String groupName : scheduler.getJobGroupNames()) {
|
|---|
| | | System.out.println(groupName);
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping("getSchedulerList")
|
|---|
| | | public void getSchedulerList(PrintWriter out) {
|
|---|
| | | try {
|
|---|
| | | for (String groupName : scheduler.getJobGroupNames()) {
|
|---|
| | | System.out.println(groupName);
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | @RequestMapping("getTBGoodsCate")
|
|---|
| | | public void getTaoBaoGoodsCat(Long id, PrintWriter out) {
|
|---|
| | | TaoBaoGoodsBrief goods = null;
|
|---|
| | | try {
|
|---|
| | | goods = TaoKeApiUtil.getSimpleGoodsInfo(id);
|
|---|
| | | } catch (TaobaoGoodsDownException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | if (goods == null)
|
|---|
| | | out.println("商品已下架");
|
|---|
| | | else
|
|---|
| | | out.println(
|
|---|
| | | "<html><head><meta charset=utf-8></head><body>" + String.format("cat_name:%s <br> cat_leaf_name:%s",
|
|---|
| | | goods.getRootCategoryName(), goods.getLeafName()) + "</body></html>");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping("getTBGoodsCate")
|
|---|
| | | public void getTaoBaoGoodsCat(Long id, PrintWriter out) {
|
|---|
| | | TaoBaoGoodsBrief goods = null;
|
|---|
| | | try {
|
|---|
| | | goods = TaoKeApiUtil.getSimpleGoodsInfo(id);
|
|---|
| | | } catch (TaobaoGoodsDownException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | if (goods == null)
|
|---|
| | | out.println("商品已下架");
|
|---|
| | | else
|
|---|
| | | out.println(
|
|---|
| | | "<html><head><meta charset=utf-8></head><body>" + String.format("cat_name:%s <br> cat_leaf_name:%s",
|
|---|
| | | goods.getRootCategoryName(), goods.getLeafName()) + "</body></html>");
|
|---|
| | | }
|
|---|
| | | @RequestMapping("getJedisInfo")
|
|---|
| | | public void getJedisInfo(PrintWriter out) {
|
|---|
| | | JSONObject data = new JSONObject();
|
|---|
| | | data.put("active", jedisPool.getNumActive());
|
|---|
| | | data.put("idle", jedisPool.getNumIdle());
|
|---|
| | | data.put("waiters", jedisPool.getNumWaiters());
|
|---|
| | | out.print(data.toString());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping("getJedisInfo")
|
|---|
| | | public void getJedisInfo(PrintWriter out) {
|
|---|
| | | JSONObject data = new JSONObject();
|
|---|
| | | data.put("active", jedisPool.getNumActive());
|
|---|
| | | data.put("idle", jedisPool.getNumIdle());
|
|---|
| | | data.put("waiters", jedisPool.getNumWaiters());
|
|---|
| | | out.print(data.toString());
|
|---|
| | | }
|
|---|
| | | @RequestMapping("log")
|
|---|
| | | public void log(PrintWriter out) {
|
|---|
| | | LogManager.getLogger(LogType.taobaoAuth).info("123123123");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping("log")
|
|---|
| | | public void log(PrintWriter out) {
|
|---|
| | | LogManager.getLogger(LogType.taobaoAuth).info("123123123");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @RequestMapping("dubbo")
|
|---|
| | | public void testDubbo() {
|
|---|
| | | TaoBaoCouponCache cache = new TaoBaoCouponCache();
|
|---|
| | | cache.setActivityId("123123123");
|
|---|
| | | cache.setPid("mm_12_12_12");
|
|---|
| | | cache.setAuctionId(123123L);
|
|---|
| | | taoBaoCouponCacheService.save(cache);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
