修改通用模板缓存事件

admin

2019-07-17 3b42472c47242aa72435902ba5e6870758189b5c

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

@@ -16,7 +16,6 @@


import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.yeshi.utils.DateUtil;

import org.yeshi.utils.IPUtil;

import org.yeshi.utils.JsonUtil;

@@ -42,7 +41,6 @@
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.AccountMessageService;

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

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

import com.yeshi.fanli.tag.PageEntity;

@@ -71,9 +69,6 @@
   private ExtractCountService extractCountService;



   @Resource

   private AccountMessageService accountMessageService;



   @Resource

   private PushRecordService pushRecordService;



   @Resource

@@ -88,7 +83,6 @@
   @Resource

   private AdminUserService adminUserService;





   @Resource

   private RedisManager redisManager;



@@ -97,66 +91,6 @@


   @Resource

   private TaoBaoWeiQuanOrderService taoBaoWeiQuanOrderService;

	


   private final static String TODAY = "1";

   private final static String THREE = "2";

   private final static String AWEEK = "3";



   @RequestMapping(value = "getExtractList", method = RequestMethod.POST)

   public void getExtractList(int pageIndex, PrintWriter out) {

      List<Extract> extractList = extractService.getExtractList(pageIndex - 1);

      int count = extractService.getCount();

      int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1;

      PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage);

      JSONObject data = new JSONObject();

      data.put("pe", pe);

      data.put("extractList", extractList);

      out.print(JsonUtil.loadTrueResult(data));

   }



   /**

    * 
    * 方法说明: 通过提现请求

    * 
    * @author mawurui createTime 2018年3月14日 下午3:15:42

    * @param id

    * @param out

    * @param request

    */

   @RequestMapping(value = "passExtract", method = RequestMethod.POST)

   public void passExtract(String callback, long id, PrintWriter out, HttpServletRequest request) {



      // TODO 需要邮箱发送短信验证



      AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);



      Integer integer = extractService.passExtract(id, admin);

      Extract extract = extractService.getExtractById(id);

      long uid = extract.getUserInfo().getId();



      if (integer == null) {

         out.print(JsonUtil.loadTrueResult("通过"));

         LogHelper

               .userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "通过了[id=" + id + "]的提现申请!"); // 同意之后成功

      } else if (integer == 1) {



         out.print(JsonUtil.loadFalseResult("不存在该对象")); // 同意之后失败

         LogHelper.userInfo(

               "[ip:" + IPUtil.getRemotIP(request) + "][管理员:" + admin.getName() + "] 同意提现id=" + id + "的提现申请不存在");

         String title = "你的提现申请被驳回";

         String content = "非常遗憾，你的提现申请被驳回。我们通过核对发现你的账目明细有误，我们会在审计完成之后给你发通知消息。如有疑问请联系客服。";

         // xingePushController.pushSystemZnx(uid, title, content, out);

      } else {



         LogHelper.userInfo(

               "[ip:" + IPUtil.getRemotIP(request) + "][管理员:" + admin.getName() + "] 同意提现id=" + id + "的提现申请状态异常");

         out.print(JsonUtil.loadFalseResult("该状态不等于不为初始状态"));

         String title = "你的提现申请不成功";

         String content = "请确保你的提现账户的隐私设置为 允许邮箱、手机号、会员名找到我。否则无法成功完成转账。如有疑问请联系客服。";

         // xingePushController.pushSystemZnx(uid, title, content, out);

      }

   }



   /**

    * 

@@ -188,74 +122,21 @@
      /* 允许提现 操作 */

      Integer integer = extractService.passExtract(id, admin);



      Extract extract = extractService.getExtractById(id);

      long uid = extract.getUserInfo().getId();



      // 日志记录

      if (integer == null) {

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("通过"));



         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("已通过"));

         LogHelper

               .userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "通过了[id=" + id + "]的提现申请!"); // 同意之后成功

               .userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "通过了[id=" + id + "]的提现申请!");

      } else if (integer == 1) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("不存在该对象"));



         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("该提现记录已不存在,请刷新"));

         LogHelper.userInfo(

               "[ip:" + IPUtil.getRemotIP(request) + "][管理员:" + admin.getName() + "] 同意提现id=" + id + "的提现申请不存在");

         String title = "你的提现申请被驳回";

         String content = "非常遗憾，你的提现申请被驳回。我们通过核对发现你的账目明细有误，我们会在审计完成之后给你发通知消息。如有疑问请联系客服。";

         // xingePushController.pushSystemZnx(uid, title, content, out);

      } else {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("该状态不等于不为初始状态"));



         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("该用户已被处理,请刷新"));

         LogHelper.userInfo(

               "[ip:" + IPUtil.getRemotIP(request) + "][管理员:" + admin.getName() + "] 同意提现id=" + id + "的提现申请状态异常");

         String title = "你的提现申请不成功";

         String content = "请确保你的提现账户的隐私设置为 允许邮箱、手机号、会员名找到我。否则无法成功完成转账。如有疑问请联系客服。";

         // xingePushController.pushSystemZnx(uid, title, content, out);

      }



   }



   /**

    * 
    * 方法说明: 拒绝提现请求

    * 
    * @author mawurui createTime 2018年3月14日 下午3:15:55

    * @param id

    * @param reason

    * @param out

    * @param request

    */

   @RequestMapping(value = "rejectExtract", method = RequestMethod.POST)

   public void rejectExtract(String callback, long id, String reason, PrintWriter out, HttpServletRequest request) {

      AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);



      Extract extract = extractService.getExtractById(id);

      long uid = extract.getUserInfo().getId();

      long extractTime = extract.getExtractTime();



      try {

         extractService.rejectExtract(id, reason, extractTime, admin);// 提现失败



         // 调用推送站内信给用户

         out.print(JsonUtil.loadTrueResult("拒绝"));

         LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "拒绝了[id=" + id

               + "]的提现申请!拒绝原因是" + reason);



         String title = "你的提现申请被驳回";

         String content = "非常遗憾，你的提现申请被驳回。我们通过核对发现你的账目明细有误，我们会在审计完成之后给你发通知消息。如有疑问请联系客服。";

         // xingePushController.pushSystemZnx(uid, title, content, out);

      } catch (ObjectStateException e) {

         LogHelper.userInfo(

               "[ip:" + IPUtil.getRemotIP(request) + "][管理员:" + admin.getName() + "] 拒绝提现id=" + id + "的提现申请状态异常!"); //



         out.print(JsonUtil.loadFalseResult(e.getMessage()));

      } catch (NotExistObjectException e) {

         LogHelper.userInfo(

               "[ip:" + IPUtil.getRemotIP(request) + "][管理员:" + admin.getName() + "] 拒绝提现id=" + id + "的提现申请不存在!");



         out.print(JsonUtil.loadFalseResult(e.getMessage()));

      }

   }



   /**

@@ -285,29 +166,22 @@
         return;

      }



      /* 拒绝提现 操作 */



      try {

         // 编码转换

         reason = URLDecoder.decode(reason, "UTF-8");

      } catch (Exception e1) {

         e1.printStackTrace();

      }



      try {

         Extract extract = extractService.getExtractById(id);

         long extractTime = extract.getExtractTime();

         extractService.rejectExtract(id, reason, extractTime, admin);// 提现失败



         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("拒绝"));

         extractService.rejectExtract(id, reason, admin);// 提现失败



         // 调用推送站内信给用户

         // out.print(JsonUtil.loadTrueResult("拒绝"));

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("拒绝成功"));



         LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "拒绝了[id=" + id

               + "]的提现申请!拒绝原因是" + reason);



         String title = "你的提现申请被驳回";

         String content = "非常遗憾，你的提现申请被驳回。我们通过核对发现你的账目明细有误，我们会在审计完成之后给你发通知消息。如有疑问请联系客服。";

         // xingePushController.pushSystemZnx(uid, title, content, out);

      } catch (ObjectStateException e) {

         LogHelper.userInfo(

               "[ip:" + IPUtil.getRemotIP(request) + "][管理员:" + admin.getName() + "] 拒绝提现id=" + id + "的提现申请状态异常!"); //

@@ -321,24 +195,6 @@
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMessage()));

      }



   }



   /**

    * 资金校验是否异常

    * 
    * @param uid

    * @param out

    */

   @RequestMapping(value = "checkExtract", method = RequestMethod.POST)

   public void checkExtract(String uid, PrintWriter out) {

      JSONObject data = new JSONObject();

      try {

         extractService.checkExtract(uid);

         data.put("code", "1"); // 正常

      } catch (ExtractException e) {

         data.put("code", "0");// 异常

      }

      out.print(data);

   }



   /**

@@ -438,8 +294,8 @@
               if (extract != null) {

                  UserInfo userInfo = extract.getUserInfo();

                  Long id = userInfo.getId();

                  countByUid = hongBaoService.getCountByUid(id);

                  countCancel = hongBaoV2CountService.countNumberByUidAndState(id, HongBaoV2.STATE_SHIXIAO); 
                  countByUid = hongBaoV2CountService.countNumberByUid(id);

                  countCancel = hongBaoV2CountService.countNumberByUidAndState(id, HongBaoV2.STATE_SHIXIAO);

               }

               extractAuditRecord.setCancelOrderNum((long) countCancel);

               extractAuditRecord.setOrderNum((long) countByUid);

@@ -492,13 +348,12 @@
         // }



         int pageSize = Constant.PAGE_SIZE;



         Integer days = null;

         if (TODAY.equals(timeSlot)) {

         if ("1".equals(timeSlot)) {

            days = 0; // 今日

         } else if (THREE.equals(timeSlot)) {

         } else if ("2".equals(timeSlot)) {

            days = 3; // 前3天

         } else if (AWEEK.equals(timeSlot)) {

         } else if ("3".equals(timeSlot)) {

            days = 7; // 前7天

         }



@@ -532,16 +387,39 @@
            Extract extract = record.getExtract();

            if (extract != null) {

               Integer extractState = extract.getState();

               if (extractState != null && extractState == 0) {

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

                  UserInfo userInfo = extract.getUserInfo();

                  if (userInfo != null) {

                     double countTodayMoney = extractService.countTodayMoney(userInfo.getId());

                     if (countTodayMoney >= 100) {

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

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

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

                        warnLevel = 1;

                     }

                  }

               }

            }



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

               StringBuffer desc = new StringBuffer();

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

         }

@@ -552,6 +430,8 @@


         GsonBuilder gsonBuilder = new GsonBuilder();

         gsonBuilder.serializeNulls();

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

			
         Gson gson = gsonBuilder.create();



         JSONObject data = new JSONObject();

@@ -776,6 +656,18 @@
            return;

         }



         for (ExtractAuditRecord record : list) {



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

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

               record.setExtraInfoStr(desc.toString());

            }

         }



         int count = extractAuditRecordService.getByUidCount(uid);

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

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

@@ -855,7 +747,7 @@
      }



      try {

         extractService.checkExtract(uid);

         extractService.checkExtract(Long.parseLong(uid));

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("资金正常"));

      } catch (ExtractException e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));