blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yujian
2019-10-16 c91ccd847a5c31391ddd41b3e464bc2ca02b7ac6 
 fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java


@@ -1,8 +1,10 @@


package com.yeshi.fanli.controller.admin;







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,17 +15,24 @@






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 com.google.gson.Gson;



import com.google.gson.GsonBuilder;



import com.google.gson.reflect.TypeToken;



import com.yeshi.fanli.controller.admin.utils.AdminUtils;



import com.yeshi.fanli.dto.ChartTDO;



import com.yeshi.fanli.entity.bus.user.Extract;



import com.yeshi.fanli.entity.bus.user.ExtractAuditRecord;



import com.yeshi.fanli.entity.bus.user.HongBaoV2;



@@ -35,14 +44,14 @@


import com.yeshi.fanli.log.LogHelper;



import com.yeshi.fanli.service.AdminUserService;



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



import com.yeshi.fanli.service.inter.count.ExtractCountService;



import com.yeshi.fanli.service.inter.count.HongBaoV2CountService;



import com.yeshi.fanli.service.inter.count.UserInfoCountService;



import com.yeshi.fanli.service.inter.money.extract.ExtractAuditRecordService;



import com.yeshi.fanli.service.inter.money.extract.ExtractCountService;



import com.yeshi.fanli.service.inter.money.extract.ExtractService;



import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;



import com.yeshi.fanli.service.inter.order.tb.TaoBaoWeiQuanOrderService;



import com.yeshi.fanli.service.inter.push.PushRecordService;



import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService;



import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService;



import com.yeshi.fanli.service.inter.user.ExtractAuditRecordService;



import com.yeshi.fanli.service.inter.user.ExtractService;



import com.yeshi.fanli.tag.PageEntity;



import com.yeshi.fanli.util.Constant;



import com.yeshi.fanli.util.RedisManager;



@@ -390,25 +399,35 @@


               if (extractState != null && extractState == Extract.STATE_NOT_PROCESS) {



                  UserInfo userInfo = extract.getUserInfo();



                  if (userInfo != null) {



                     BigDecimal countTodayMoney = extractService.sumTodayApplyMoney(userInfo.getId());



                     BigDecimal countTodayMoney = extractService.sumTodayApplyMoney(userInfo.getId(),



                           TimeUtil.getGernalTime(extract.getExtractTime()));



                     if (countTodayMoney.compareTo(new BigDecimal(100)) > 0) {



                        warnLevel = 1;



                     }



                  }



               }







            }







            if (record.getExtraInfo() != null) {



               if (record.getExtraInfo().getOrderCount50More() > 0



                     || record.getExtraInfo().getWeiQuanOrderCount() > 0



                     || record.getExtraInfo().getWeiQuanOrderFanAmount().compareTo(new BigDecimal(0)) > 0)



                  warnLevel = 2;



               StringBuffer desc = new StringBuffer();



               desc.append("大于50元订单:" + record.getExtraInfo().getOrderCount50More() + "\n#");



               desc.append("维权订单数:" + record.getExtraInfo().getWeiQuanOrderCount() + "\n#");



               desc.append("维权订单退回金额:" + record.getExtraInfo().getWeiQuanOrderFanAmount() + "\n#");



               desc.append("180天安全订单数:" + record.getExtraInfo().getSafeOrderCount());



               if (System.currentTimeMillis() > TimeUtil.convertToTimeTemp("2019-06-21", "yyyy-MM-dd")) {



                  desc.append("大笔订单数:" + record.getExtraInfo().getOrderCount50More() + "\n#");



                  desc.append("维权订单数:" + record.getExtraInfo().getWeiQuanOrderCount() + "\n#");



                  desc.append("维权订单佣金:" + record.getExtraInfo().getWeiQuanOrderFanAmount() + "\n#");



                  if (record.getExtraInfo().getOrderCount50More() > 0



                        || record.getExtraInfo().getWeiQuanOrderCount() > 1



                        || record.getExtraInfo().getWeiQuanOrderFanAmount().compareTo(new BigDecimal(10)) >= 0)



                     warnLevel = 2;



               } else {



                  if (record.getExtraInfo().getOrderCount50More() > 0



                        || record.getExtraInfo().getWeiQuanOrderCount() > 0



                        || record.getExtraInfo().getWeiQuanOrderFanAmount().compareTo(new BigDecimal(0)) > 0)



                     warnLevel = 2;



                  desc.append("大于50元订单:" + record.getExtraInfo().getOrderCount50More() + "\n#");



                  desc.append("维权订单数:" + record.getExtraInfo().getWeiQuanOrderCount() + "\n#");



                  desc.append("维权订单退回金额:" + record.getExtraInfo().getWeiQuanOrderFanAmount() + "\n#");



                  desc.append("180天安全订单数:" + record.getExtraInfo().getSafeOrderCount());



               }



               record.setExtraInfoStr(desc.toString());



            }



            record.setWarnLevel(warnLevel);



@@ -420,6 +439,8 @@






         GsonBuilder gsonBuilder = new GsonBuilder();



         gsonBuilder.serializeNulls();



         gsonBuilder.setDateFormat("yyyy-MM-dd HH:mm:ss");



			


         Gson gson = gsonBuilder.create();







         JSONObject data = new JSONObject();



@@ -809,9 +830,8 @@


               innerList.put("name", "驳回数");



            }







            List<Map<String, Object>> list = extractAuditRecordService.countAuditTotal(state, dateType, year,



            List<ChartTDO> list = extractAuditRecordService.countAuditTotal(state, dateType, year,



                  startTime, endTime);







            if (dateType != 3) {



               innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list)));



            } else {



@@ -823,7 +843,6 @@


               }



               innerList.put("data", gson.toJson(map.get("value")));



            }







            line_list.add(innerList);



         }







@@ -835,9 +854,7 @@


         }







         data.put("line_list", line_list);







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







      } catch (Exception e) {



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



         e.printStackTrace();



@@ -863,7 +880,6 @@


   @RequestMapping(value = "getExtractApplyMoney")



   public void getExtractApplyMoney(String callback, Integer dateType, String year, String startTime, String endTime,



         PrintWriter out) {







      String validateMsg = AdminUtils.validateParams(dateType, startTime, endTime);



      if (validateMsg != null) {



         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(validateMsg));



@@ -896,12 +912,10 @@


         List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year);







         Gson gson = new Gson();



         JSONArray line_list = new JSONArray();







         JSONObject innerList = new JSONObject();



         innerList.put("name", "总计");







         List<Map<String, Object>> list = extractAuditRecordService.countExtractApplyMoney(null, dateType, year,



         List<ChartTDO> list = extractAuditRecordService.countExtractApplyMoney(null, dateType, year,



               startTime, endTime);







         if (dateType != 3) {



@@ -916,6 +930,7 @@


            innerList.put("data", gson.toJson(map.get("value")));



         }







         JSONArray line_list = new JSONArray();



         line_list.add(innerList);







         JSONObject data = new JSONObject();



@@ -926,9 +941,7 @@


         }







         data.put("line_list", line_list);







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







      } catch (Exception e) {



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



         e.printStackTrace();



@@ -956,7 +969,6 @@


   @RequestMapping(value = "getExtractApplyNumber")



   public void getExtractApplyNumber(String callback, Integer state, Integer dateType, String year, String startTime,



         String endTime, PrintWriter out) {







      String validateMsg = AdminUtils.validateParams(dateType, startTime, endTime);



      if (validateMsg != null) {



         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(validateMsg));



@@ -984,17 +996,15 @@


      }







      try {







         Object objectDate = null;



         Gson gson = new Gson();



         List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year);







         Gson gson = new Gson();



         JSONArray line_list = new JSONArray();







         JSONObject innerList = new JSONObject();



         innerList.put("name", "总计");







         List<Map<String, Object>> list = extractAuditRecordService.countExtractApplyNumber(null, dateType, year,



         List<ChartTDO> list = extractAuditRecordService.countExtractApplyNumber(null, dateType, year,



               startTime, endTime);







         if (dateType != 3) {



@@ -1009,6 +1019,7 @@


            innerList.put("data", gson.toJson(map.get("value")));



         }







         JSONArray line_list = new JSONArray();



         line_list.add(innerList);







         JSONObject data = new JSONObject();



@@ -1019,9 +1030,107 @@


         }







         data.put("line_list", line_list);







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



      } catch (Exception e) {



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



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



         }



			


         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 = opid_str.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("上传失败"));



      }



   }



	


	


	


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