From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 25 二月 2025 16:41:22 +0800 Subject: [PATCH] 淘宝转链接口更新 --- fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java | 94 +++++++++++++++++++++++++++++++++------------- 1 files changed, 67 insertions(+), 27 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java b/fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java index f78a52f..1213d00 100644 --- a/fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java +++ b/fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java @@ -7,17 +7,17 @@ import java.net.URLEncoder; import java.text.ParseException; import java.text.SimpleDateFormat; -import java.util.ArrayList; -import java.util.Calendar; -import java.util.Date; -import java.util.List; -import java.util.Map; +import java.util.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; +import com.yeshi.fanli.entity.SystemEnum; import com.yeshi.fanli.entity.accept.AdminAcceptData; +import com.yeshi.fanli.entity.order.CommonOrder; +import com.yeshi.fanli.service.inter.order.CommonOrderService; +import com.yeshi.fanli.service.inter.user.UserInfoService; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; @@ -42,7 +42,6 @@ import com.yeshi.fanli.exception.NotExistObjectException; import com.yeshi.fanli.exception.ObjectStateException; 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.HongBaoV2CountService; import com.yeshi.fanli.service.inter.count.UserInfoCountService; @@ -50,15 +49,11 @@ 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; import com.yeshi.fanli.service.inter.user.UserInfoExtraService; -import com.yeshi.fanli.tag.PageEntity; +import com.yeshi.common.entity.PageEntity; import com.yeshi.fanli.util.Constant; -import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; -import com.yeshi.fanli.util.TimeUtil; +import org.yeshi.utils.TimeUtil; import net.sf.json.JSONObject; @@ -90,6 +85,12 @@ @Resource private CommonOrderCountService commonOrderCountService; + @Resource + private CommonOrderService commonOrderService; + + @Resource + private UserInfoService userInfoService; + /** * 鏂规硶璇存槑: 閫氳繃鎻愮幇璇锋眰 鍙痡sonP鏂瑰紡 * @@ -99,7 +100,7 @@ * @param request */ @RequestMapping(value = "passExtractJP") - public void passExtractJP(String callback, Long id, String code, PrintWriter out, HttpServletRequest request) { + public void passExtractJP(AdminAcceptData acceptData, String callback, Long id, String code, PrintWriter out, HttpServletRequest request) { /* 妫�楠屾槸鍚︾櫥闄� */ AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); @@ -145,7 +146,7 @@ * @author mawurui createTime 2018骞�3鏈�14鏃� 涓嬪崍3:15:55 */ @RequestMapping(value = "rejectExtractJP") - public void rejectExtractJP(String callback, Long id, String code, String reason, PrintWriter out, + public void rejectExtractJP(AdminAcceptData acceptData, String callback, Long id, String code, String reason, PrintWriter out, HttpServletRequest request) { /* 妫�楠屾槸鍚︾櫥闄� */ AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); @@ -242,7 +243,7 @@ * @param out */ @RequestMapping(value = "getFinishRecordList") - public void getFinishRecordList(String callback, Integer pageIndex, String key, String startTime, String endTime, + public void getFinishRecordList(AdminAcceptData acceptData, String callback, Integer pageIndex, String key, String startTime, String endTime, PrintWriter out) { try { @@ -325,7 +326,7 @@ * @param request */ @RequestMapping(value = "getMyAuditedList") - public void getMyAuditedList(String callback, Integer pageIndex, String key, String timeSlot, Integer state, + public void getMyAuditedList(AdminAcceptData acceptData, String callback, Integer pageIndex, String key, String timeSlot, Integer state, PrintWriter out, HttpServletRequest request) { try { @@ -475,15 +476,54 @@ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇风櫥褰�")); return; } + SystemEnum system = userInfoService.getUserSystem(uid); + acceptData.setSystem(system); + + // 鏌ヨ鍚屽簵閾哄晢鍝侊紝鍚屽晢鍝佽鍗曡秴杩囦竴瀹氭暟閲忕殑 List<Integer> typeList = new ArrayList<>(); typeList.add(HongBaoV2.TYPE_ZIGOU); - long sameGoodsOrderCount = commonOrderCountService.countSameGoodsOrderByUidAndHongBaoType(typeList, uid, + + List<Long> goodsIds = commonOrderCountService.listSameGoodsIdByUidAndHongBaoType(typeList, uid, Integer.parseInt(configService.getValue(ConfigKeyEnum.adminMinSameGoodsOrderCount.getKey(), acceptData.getSystem()))); + int sameGoodsDangerCount = 0; + if (goodsIds.size() > 0) { + for (int i = 0; i < goodsIds.size(); i++) { + long goodsId = goodsIds.get(i); + Date minDate = new Date(System.currentTimeMillis() - 1000 * 60 * 60L * 24 * 365L); + List<CommonOrder> commonOrdersList = commonOrderService.listByGoodsIdAndUidAndMinThirdCreateTime(goodsId, uid, minDate); + Map<String, Date> cmap = new HashMap<>(); + if (commonOrdersList != null) + for (CommonOrder co : commonOrdersList) { + if (co.getState() == CommonOrder.STATE_FK || co.getState() == CommonOrder.STATE_JS || co.getState() == CommonOrder.STATE_WQ) + cmap.put(co.getOrderNo(), co.getThirdCreateTime()); + } + List<Date> dateList = new ArrayList<>(); + for (Iterator<String> its = cmap.keySet().iterator(); its.hasNext(); ) { + String orderNo = its.next(); + dateList.add(cmap.get(orderNo)); + } + Collections.sort(dateList); + Date lastDate = null; + + for (Date date : dateList) { + if (lastDate != null) { + if (Math.abs(date.getTime() - lastDate.getTime()) < 1000 * 60 * 60 * 24L * 15) { + sameGoodsDangerCount++; + break; + } + } else { + lastDate = date; + } + } + } + } + + long sameShopOrderCount = commonOrderCountService.countSameShopOrderByUidAndHongBaoType(typeList, uid, Integer.parseInt(configService.getValue(ConfigKeyEnum.adminMinSameShopOrderCount.getKey(), acceptData.getSystem()))); - if (sameGoodsOrderCount > 0 || sameShopOrderCount > 0) { - String text = (String.format("鍚屽簵閾�:%s 鍚屽晢鍝�:%s", sameShopOrderCount, sameGoodsOrderCount)); + if (sameGoodsDangerCount>0 || sameShopOrderCount > 0) { + String text = (String.format("鍚屽簵閾�:%s 鍚屽晢鍝�:%s", sameShopOrderCount, sameGoodsDangerCount)); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(text)); return; } @@ -496,7 +536,7 @@ * @param out */ @RequestMapping(value = "getMyAuditedCount") - public void getMyAuditedCount(String callback, HttpServletRequest request, PrintWriter out) { + public void getMyAuditedCount(AdminAcceptData acceptData, String callback, HttpServletRequest request, PrintWriter out) { AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); @@ -536,7 +576,7 @@ * @param out */ @RequestMapping(value = "getIaskInfo") - public void getIaskInfo(String callback, Long extractId, HttpServletRequest request, PrintWriter out) { + public void getIaskInfo(AdminAcceptData acceptData, String callback, Long extractId, HttpServletRequest request, PrintWriter out) { try { String surplusTime = ""; @@ -709,7 +749,7 @@ * @param out */ @RequestMapping(value = "getByUidList") - public void getByUidList(String callback, Integer pageIndex, Long uid, HttpServletRequest request, + public void getByUidList(AdminAcceptData acceptData, String callback, Integer pageIndex, Long uid, HttpServletRequest request, PrintWriter out) { try { if (uid == null) { @@ -770,7 +810,7 @@ * @param out */ @RequestMapping(value = "countByUid") - public void countByUid(String callback, Long uid, HttpServletRequest request, PrintWriter out) { + public void countByUid(AdminAcceptData acceptData, String callback, Long uid, HttpServletRequest request, PrintWriter out) { try { @@ -810,7 +850,7 @@ * @param out */ @RequestMapping(value = "checkMoney") - public void checkMoney(String callback, String uid, PrintWriter out) { + public void checkMoney(AdminAcceptData acceptData, String callback, String uid, PrintWriter out) { if (StringUtil.isNullOrEmpty(uid)) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("UID涓嶈兘涓虹┖")); @@ -834,7 +874,7 @@ * @param out */ @RequestMapping(value = "downAutoExtractTxt") - public void downAutoExtractTxt(String callback, HttpServletResponse response, PrintWriter out) { + public void downAutoExtractTxt(AdminAcceptData acceptData, String callback, HttpServletResponse response, PrintWriter out) { try { List<String> list = extractService.getAutoExtractOpenIds(); if (list == null || list.size() <= 1) { @@ -877,7 +917,7 @@ * @param out */ @RequestMapping(value = "uploadExcel", method = RequestMethod.POST) - public void uploadExcel(@RequestParam("file") CommonsMultipartFile file, PrintWriter out) { + public void uploadExcel(AdminAcceptData acceptData, @RequestParam("file") CommonsMultipartFile file, PrintWriter out) { if (file == null) { out.print(JsonUtil.loadFalseResult("涓婁紶鏂囦欢涓嶈兘涓虹┖锛�")); return; @@ -912,7 +952,7 @@ * @param out */ @RequestMapping(value = "preAutoUser") - public void preAutoUser(String callback, Integer pageIndex, PrintWriter out) { + public void preAutoUser(AdminAcceptData acceptData, String callback, Integer pageIndex, PrintWriter out) { try { List<UserInfo> list = extractService.preAutoUser(); if (list == null || list.isEmpty()) { -- Gitblit v1.8.0