9块9bug修改

admin

2019-06-15 4f947462f2ada97a32670cd3204680f8cc8f7792

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

@@ -1,18 +1,26 @@
package com.yeshi.fanli.controller;



import java.io.BufferedReader;

import java.io.File;

import java.io.FileReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.PrintWriter;

import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.List;

import java.util.UUID;



import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;



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.HttpUtil;

@@ -26,14 +34,21 @@
import com.yeshi.fanli.dao.mybatis.help.HelpCenterMapper;

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.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.exception.ActivityException;

import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.activity.ActivityService;

import com.yeshi.fanli.service.inter.config.ConfigService;

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.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.db.MongoDBManager;



import net.sf.json.JSONArray;

@@ -56,7 +71,26 @@
   private HelpCenterMapper helpCenterMapper;

   @Resource

   private Scheduler scheduler;

	
   @Resource

   private DynamicInfoService dynamicInfoService;

	
   @Resource

   private  TaoBaoGoodsBriefService taoBaoGoodsBriefService;

	


   @Resource

   private EhCacheCacheManager ehCacheCacheManager;



   @Resource

   private ConfigService configService;



	
   @Resource

   private InviteMaterialService inviteMaterialService;

	
	
	
   @RequestMapping(value = "testimg")

   public void testImg(HttpServletRequest request, PrintWriter out) {

      long startTime = System.currentTimeMillis();

@@ -91,9 +125,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);



@@ -114,7 +148,7 @@
   @RequestMapping(value = "testactivity")

   public void test2(PrintWriter out) {

      List<RecommendActivity> list = activityService.getRecommendActivityList(1, Constant.PAGE_SIZE);

      long count = activityService.getRecommendActivityCount();

      long count = activityService.getRecommendActivityCount(null);

      JSONObject data = new JSONObject();

      data.put("data", getGson().toJson(list));

      data.put("count", count);

@@ -126,6 +160,8 @@
      try {

         ActivityShareResult result = activityService.shareActivityGoods(343448L, 1L);

         out.print(JsonUtil.getSimpleGson().toJson(result));

      } catch (UserShareGoodsRecordException e) {

         e.printStackTrace();

      } catch (ActivityException e) {

         e.printStackTrace();

      }

@@ -169,4 +205,206 @@
         e.printStackTrace();

      }

   }



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

   }



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

   }



   @RequestMapping(value = "testDaTaoKe")

   public void getTestDaTaoKe(PrintWriter pw) {

      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] + "}");

            }

         }

      } catch (IOException e) {

         e.printStackTrace();

      }

   }

	


	
   @RequestMapping(value = "insertShop")

   public void insertShop(PrintWriter out) {

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

         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));// 构造一个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;

         }

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



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

      }

   }

	
	
	
   /**

    * 插入邀请素材

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

      }

   }

}