淘礼金创建异常处理

admin

2019-08-26 d28bed1a1275131a5ca37f7da37961e2b518ac07

 fanli/src/main/java/com/yeshi/fanli/controller/TestController.java

@@ -12,6 +12,9 @@
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 org.jsoup.Jsoup;

@@ -53,6 +56,7 @@
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;

@@ -60,6 +64,8 @@


import net.sf.json.JSONArray;

import net.sf.json.JSONObject;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;



@Controller

@RequestMapping("test")

@@ -78,29 +84,28 @@
   private HelpCenterMapper helpCenterMapper;

   @Resource

   private Scheduler scheduler;

	


   @Resource

   private DynamicInfoService dynamicInfoService;

	


   @Resource

   private  TaoBaoGoodsBriefService taoBaoGoodsBriefService;

	
   private TaoBaoGoodsBriefService taoBaoGoodsBriefService;



   @Resource

   private EhCacheCacheManager ehCacheCacheManager;



   @Resource

   private ConfigService configService;

	


   @Resource

   private HongBaoManageService hongBaoManageService;



	
   @Resource

   private InviteMaterialService inviteMaterialService;

	
	
	


   @Resource

   private JedisPool jedisPool;



   @RequestMapping(value = "testimg")

   public void testImg(HttpServletRequest request, PrintWriter out) {

      long startTime = System.currentTimeMillis();

@@ -135,9 +140,9 @@
         long startDTime = System.currentTimeMillis();



         /*

          * try { //ImageUtil.drawGoodsShareImg(new FileInputStream(new File(destPath)),

          * portrait, goods, shareImgPath); } catch (FileNotFoundException e) {

          * e.printStackTrace(); }

          * try { //ImageUtil.drawGoodsShareImg(new FileInputStream(new

          * File(destPath)), portrait, goods, shareImgPath); } catch

          * (FileNotFoundException e) { e.printStackTrace(); }

          */

         System.out.println(System.currentTimeMillis() - startDTime);



@@ -221,8 +226,7 @@
      out.print("<script>yestv.finishPage();</script>");

      out.close();

   }

	
	


   /**

    * 清除缓存

    * 

@@ -233,13 +237,11 @@
      ehCacheCacheManager.getCacheManager().clearAll();

   }



	
   @RequestMapping(value = "removeRedisCache")

   public void removeRedisCache(String key, PrintWriter out) {

      redisManager.removeCommonString(key);

   }

	
	


   @RequestMapping(value = "testConfig")

   public void getTestConfig(PrintWriter pw) {

      pw.print(configService.get("test"));

@@ -247,41 +249,53 @@


   @RequestMapping(value = "testDaTaoKe")

   public void getTestDaTaoKe(PrintWriter pw) {

      Document doc = null;

      try {

         Document doc = Jsoup.connect("http://www.dataoke.com/brandFeature").get();

         Elements els = doc.getElementsByTag("script");

         for (int i = 0; i < els.size(); i++) {

            if (els.get(i).html().contains("var brandData")) {

               pw.print(els.get(i).html().replace("var brandData =", "").trim().split("};")[0] + "}");

         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();

            }

         }

      } catch (IOException e) {

         e.printStackTrace();

      }

   }

	


	
   @RequestMapping(value = "insertShop")

   public void insertShop(PrintWriter out) {

        try {

           dynamicInfoService.insertShopInfo();

           dynamicInfoService.insertTimeHotSale();

           dynamicInfoService.insertTimeRecommend();

      try {

         dynamicInfoService.insertShopInfo();

         dynamicInfoService.insertTimeHotSale();

         dynamicInfoService.insertTimeRecommend();

      } catch (Exception e) {

         e.printStackTrace();

      }

   }

	


   /**

    * 插入邀请素材

    * 
    * @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();

@@ -289,22 +303,22 @@
            String name = filePic.getName();

            String prefix = name.substring(name.lastIndexOf(".") + 1);

            // 上传文件相对位置

            String filePath = "/resource/invite/everyday/" + UUID.randomUUID().toString().replace("-", "") + "." + prefix;

            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);

				
            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文件

         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方法，一次读一行

@@ -318,7 +332,7 @@
         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));

@@ -330,17 +344,17 @@
         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文件

         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方法，一次读一行

@@ -354,10 +368,9 @@
            list.add(inviteMaterial);

         }

         brp.close();

			
			


         List<String> listTxt = new ArrayList<String>();

         File textfile = new File("E:\\Invite\\content.txt");//Text文件

         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方法，一次读一行

@@ -371,7 +384,7 @@
         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));

@@ -383,11 +396,10 @@
         e.printStackTrace();

      }

   }

	
	
	


   /**

    * 插入邀请素材

    * 
    * @param out

    */

   @RequestMapping(value = "saveInvite")

@@ -401,10 +413,10 @@
         e.printStackTrace();

      }

   }

	
	


   /**

    * 插入邀请素材

    * 
    * @param out

    */

   @RequestMapping(value = "insertTimeInvite")

@@ -417,9 +429,10 @@
         e.printStackTrace();

      }

   }

	


   /**

    * 插入邀请素材

    * 
    * @param out

    */

   @RequestMapping(value = "getJingFenList")

@@ -442,8 +455,7 @@
               Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

                     .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

               for (JDGoods goods : goodsList) {

                  GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, null, fanLiRate,

                        shareRate);

                  GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate);

                  array.add(gson.toJson(goodsDetailVO));

               }

            }

@@ -457,4 +469,9 @@
         e.printStackTrace();

      }

   }



   @RequestMapping(value = "getWaitingThreadsCount")

   public void getWaitingThreadsCount(PrintWriter out) {

      out.print(Constant.waitingThreadSet.size());

   }

}