yujian
2019-10-14 05ca3b14bc7511c1d04f65d82378ae144461e43c
fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java
@@ -1,8 +1,16 @@
package com.yeshi.fanli.controller.admin;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.math.BigDecimal;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
@@ -13,12 +21,19 @@
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.multipart.commons.CommonsMultipartFile;
import org.yeshi.utils.CsvUtil;
import org.yeshi.utils.DateUtil;
import org.yeshi.utils.IPUtil;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.entity.wx.RedPackRecord;
import org.yeshi.utils.wx.WXUtil;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
@@ -46,6 +61,7 @@
import com.yeshi.fanli.service.inter.push.PushRecordService;
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;
@@ -1028,5 +1044,57 @@
         e.printStackTrace();
      }
   }
   @RequestMapping(value = "downAutoExtractTxt")
   public void downAutoExtractTxt(String callback, HttpServletResponse response, PrintWriter out) {
      try {
         List<String> list = extractService.getAutoExtractOpenIds();
         if (list == null || list.size() <= 1) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无用户满足自动提现条件"));
            return;
         }
         String filepath = "自动提现OpenId "+ java.lang.System.currentTimeMillis() + ".txt";
         response.reset();
          response.setContentType("application/octet-stream");
          String fileName= URLDecoder.decode(filepath,"utf-8");
          response.addHeader("Content-Disposition","attachment;"+ "filename=\"" +URLEncoder.encode(fileName, "utf-8") + "\"");
         StringBuilder sb = new StringBuilder();
         for(String t:list){
            sb.append(t+"\r\n");
         }
          OutputStream os = response.getOutputStream();
            byte[] byt = sb.toString().getBytes();
            os.write(byt);
            os.flush();
          os.close();
      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
         e.printStackTrace();
      }
   }
   @RequestMapping(value = "uploadExcel", method = RequestMethod.POST)
   public void uploadExcel(@RequestParam("file") CommonsMultipartFile file, PrintWriter out) {
      if (file == null) {
         out.print(JsonUtil.loadFalseResult("上传文件不能为空!"));
         return;
      }
      try {
         List<RedPackRecord> list = CsvUtil.getCsvData(file, RedPackRecord.class);
         extractService.updateManualExtractRecord(list);
         out.print(JsonUtil.loadTrueResult("上传成功"));
      } catch (ExtractException e) {
         out.print(JsonUtil.loadFalseResult(e.getMsg()));
      } catch (Exception e) {
         e.printStackTrace();
         out.print(JsonUtil.loadFalseResult("上传失败"));
      }
   }
}