yujian
2019-11-27 e915a40b79552686b8d8a8cfc48a341fa2c0f518
fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java
@@ -22,11 +22,11 @@
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.WXRedPackUtil;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
@@ -50,6 +50,7 @@
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.CommonOrderCountService;
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;
@@ -105,6 +106,9 @@
   @Resource
   private UserInfoExtraService userInfoExtraService;
   @Resource
   private CommonOrderCountService commonOrderCountService;
   /**
    * 
@@ -440,7 +444,29 @@
               }
               record.setExtraInfoStr(desc.toString());
            }
            // if (warnLevel == 0) {
            // // 查询同店铺商品,同商品订单超过一定数量的
            // List<Integer> typeList = new ArrayList<>();
            // typeList.add(HongBaoV2.TYPE_ZIGOU);
            // long sameGoodsOrderCount =
            // commonOrderCountService.countSameGoodsOrderByUidAndHongBaoType(typeList,
            // record.getExtract().getUserInfo().getId(),
            // Integer.parseInt(configService.get("admin_min_same_goods_order_count")));
            // long sameShopOrderCount =
            // commonOrderCountService.countSameShopOrderByUidAndHongBaoType(typeList,
            // record.getExtract().getUserInfo().getId(),
            // Integer.parseInt(configService.get("admin_min_same_shop_order_count")));
            // if (sameGoodsOrderCount > 0 || sameShopOrderCount > 0) {
            // warnLevel = 3;
            // record.setExtraInfoStr(
            // String.format("同店铺:%s 同商品:%s", sameShopOrderCount,
            // sameGoodsOrderCount));
            // }
            // }
            record.setWarnLevel(warnLevel);
         }
         int count = extractAuditRecordService.getMyAuditedTimeSlotCount(key, state, null, days);
@@ -463,6 +489,27 @@
         e.printStackTrace();
         out.print(JsonUtil.loadFalseResult(e.getMessage()));
      }
   }
   @RequestMapping(value = "getMyAuditedDanger")
   public void getMyAuditedDanger(String callback, Long uid, PrintWriter out) {
      if (uid == null) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请登录"));
         return;
      }
      // 查询同店铺商品,同商品订单超过一定数量的
      List<Integer> typeList = new ArrayList<>();
      typeList.add(HongBaoV2.TYPE_ZIGOU);
      long sameGoodsOrderCount = commonOrderCountService.countSameGoodsOrderByUidAndHongBaoType(typeList, uid,
            Integer.parseInt(configService.get("admin_min_same_goods_order_count")));
      long sameShopOrderCount = commonOrderCountService.countSameShopOrderByUidAndHongBaoType(typeList, uid,
            Integer.parseInt(configService.get("admin_min_same_shop_order_count")));
      if (sameGoodsOrderCount > 0 || sameShopOrderCount > 0) {
         String text = (String.format("同店铺:%s 同商品:%s", sameShopOrderCount, sameGoodsOrderCount));
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(text));
         return;
      }
      JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("店铺/商品无异常"));
   }
   /**
@@ -1060,10 +1107,18 @@
      }
   }
   /**
    * 下载提现红包Openid
    *
    * @param callback
    * @param response
    * @param out
    */
   @RequestMapping(value = "downAutoExtractTxt")
   public void downAutoExtractTxt(String callback, HttpServletResponse response, PrintWriter out) {
      try {
         List<String> list = extractService.getAutoExtractOpenIds();
         //List<String> list = extractService.getAutoExtractOpenIds();
         List<String> list = extractService.getAutoExtractOpenIdsTo1212();
         if (list == null || list.size() <= 1) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无用户满足自动提现条件"));
            return;
@@ -1097,6 +1152,12 @@
      }
   }
   /**
    * 上传提现红包Excel
    *
    * @param file
    * @param out
    */
   @RequestMapping(value = "uploadExcel", method = RequestMethod.POST)
   public void uploadExcel(@RequestParam("file") CommonsMultipartFile file, PrintWriter out) {
      if (file == null) {
@@ -1105,7 +1166,7 @@
      }
      try {
         List<RedPackRecord> list = CsvUtil.getCsvData(file, RedPackRecord.class);
         List<RedPackRecord> list = WXRedPackUtil.readCsv(file.getInputStream());
         extractService.updateManualExtractRecord(list);
         out.print(JsonUtil.loadTrueResult("上传成功"));
      } catch (ExtractException e) {
@@ -1116,10 +1177,27 @@
      }
   }
   public static String getValue(String[] item,int index){
        if(item.length > index){
            String value = item[index];
            return value;
        }
        return "";
    }
   /**
    * 预览红包发生人
    *
    * @param callback
    * @param pageIndex
    * @param out
    */
   @RequestMapping(value = "preAutoUser")
   public void preAutoUser(String callback, Integer pageIndex, Integer pageSize, PrintWriter out) {
   public void preAutoUser(String callback, Integer pageIndex, PrintWriter out) {
      try {
         List<UserInfo> list = extractService.preAutoUser();
         //List<UserInfo> list = extractService.preAutoUser();
         List<UserInfo> list = extractService.preAutoUserTo1212();
         if (list == null || list.isEmpty()) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无用户满足自动提现条件"));
            return;
@@ -1129,6 +1207,7 @@
            pageIndex = 1;
         }
         Integer pageSize = 100;
         if (pageSize == null || pageSize < 1) {
            pageSize = Constant.PAGE_SIZE;
         }
@@ -1157,5 +1236,5 @@
         e.printStackTrace();
      }
   }
}