admin
2019-07-23 496c2842240eae09bb56e98e1fae71540a85befa
fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
@@ -1,12 +1,15 @@
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;
@@ -31,6 +34,7 @@
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;
@@ -39,10 +43,12 @@
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;
@@ -79,6 +85,12 @@
   @Resource
   private ConfigService configService;
   @Resource
   private InviteMaterialService inviteMaterialService;
   @RequestMapping(value = "testimg")
   public void testImg(HttpServletRequest request, PrintWriter out) {
      long startTime = System.currentTimeMillis();
@@ -211,6 +223,13 @@
      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"));
@@ -231,35 +250,6 @@
      }
   }
   
   @RequestMapping(value = "insetDynamicInfo")
   public void insetDynamicInfo(PrintWriter out) {
      String content= "emoji六一儿童节来了\r\n" +
            "老少儿童们到快活起来吧:用童真憧憬人生\r\n" +
            "emoji用童趣装点人生emoji\r\n" +
            "用童话描绘人生emoji\r\n" +
            "用童心度过人生 emoji \r\n" +
            "--------------------- \r\n今天 : 6月1日     ️  星期四\r\n" +
            "天气 : 晴转多云   15-24℃\r\n" +
            "各位亲爱的你      早安~\r\n" +
            "购物省钱返利券App:【邀请链接】\r\n" +
            "我的邀请码:【邀请码】" ;
      dynamicInfoService.insertInviteMaterial(content, null, null, null);
      String content2= "emoji六一儿童节来了\r\n" +
            "老少儿童们到快活起来吧:用童真憧憬人生\r\n" +
            "emoji用童趣装点人生emoji\r\n" +
            "用童话描绘人生emoji\r\n" +
            "用童心度过人生 emoji \r\n" +
            "--------------------- \r\n今天 : 6月1日     ️  星期四\r\n" +
            "天气 : 晴转多云   15-24℃\r\n" +
            "各位亲爱的你      早安~\r\n" +
            "购物省钱返利券App:【邀请链接】\r\n" +
            "我的邀请码:【邀请码】" ;
      dynamicInfoService.insertInviteMaterial(content2, "http://ec-1255749512.file.myqcloud.com/img/invite/53420a05de1644bd947fa23800ab0131.jpeg", null, null);
   }
   
   @RequestMapping(value = "insertShop")
@@ -273,5 +263,148 @@
      }
   }
   
   /**
    * 插入邀请素材
    * @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();
      }
   }
}