专题标签 + 微信红包

yujian

2019-10-16 c91ccd847a5c31391ddd41b3e464bc2ca02b7ac6

 fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java

@@ -1,11 +1,5 @@
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;

@@ -33,7 +27,6 @@
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;

@@ -61,7 +54,6 @@
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;

@@ -1065,8 +1057,13 @@
            sb.append(t+"\r\n");

         }

         

         String opid_str = sb.toString();

         if (!StringUtil.isNullOrEmpty(opid_str) && opid_str.endsWith("\r\n")) {

            opid_str = opid_str.substring(0, opid_str.length() - 2);

         }

			
          OutputStream os = response.getOutputStream();

            byte[] byt = sb.toString().getBytes();

            byte[] byt = opid_str.getBytes();

            os.write(byt);

            os.flush();

          os.close();

@@ -1097,4 +1094,47 @@
   }

   



	
   @RequestMapping(value = "preAutoUser")

   public void preAutoUser(String callback, Integer pageIndex, Integer pageSize, PrintWriter out) {

      try {

         List<UserInfo> list = extractService.preAutoUser();

         if (list == null || list.isEmpty()) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无用户满足自动提现条件"));

            return;

         }

			
         if (pageIndex == null || pageIndex < 1) {

            pageIndex = 1;

         }



         if (pageSize == null || pageSize < 1) {

            pageSize = Constant.PAGE_SIZE;

         }

			
         int count = list.size();

         int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;

         PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);

			
         List<UserInfo> listResult = null;

         if (pageIndex < totalPage) {

            int start = (pageIndex - 1) * pageSize;

            listResult = list.subList(start, start + pageSize);

         } else if (pageIndex == totalPage) {

             listResult = list.subList((pageIndex - 1) * pageSize, list.size());

         } else {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("没有更多了"));

            return;

         }

			
         JSONObject data = new JSONObject();

         data.put("pe", pe);

         data.put("result_list", listResult);

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));

      } catch (Exception e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));

         e.printStackTrace();

      }

   }



}