From 573c491b4a1ba60e12a5678a01c1546c0077c1ee Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 30 七月 2019 09:07:42 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java | 342 +++++++++++++++++++++++++++++++++++++++++--------------- 1 files changed, 249 insertions(+), 93 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java index 495afa7..25559c2 100644 --- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java +++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java @@ -1,31 +1,33 @@ package com.yeshi.fanli.job; +import java.math.BigDecimal; import java.util.ArrayList; +import java.util.Calendar; import java.util.Date; +import java.util.HashMap; +import java.util.HashSet; import java.util.Iterator; import java.util.List; import java.util.Map; +import java.util.Set; import javax.annotation.Resource; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; +import com.yeshi.fanli.dto.taobao.WeiQuanOrderResult; +import com.yeshi.fanli.entity.bus.user.LostOrder; import com.yeshi.fanli.entity.bus.user.Order; -import com.yeshi.fanli.entity.taobao.PidUser; +import com.yeshi.fanli.entity.order.CommonOrder; import com.yeshi.fanli.entity.taobao.TaoBaoOrder; -import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig; import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder; -import com.yeshi.fanli.exception.TaoBaoOrderException; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.common.DataMonitorService; -import com.yeshi.fanli.service.inter.hongbao.HongBaoService; -import com.yeshi.fanli.service.inter.hongbao.ThreeSaleGiftService; +import com.yeshi.fanli.service.inter.order.CommonOrderService; import com.yeshi.fanli.service.inter.order.LostOrderService; -import com.yeshi.fanli.service.inter.order.OrderItemServcie; import com.yeshi.fanli.service.inter.order.OrderProcessService; import com.yeshi.fanli.service.inter.order.OrderService; -import com.yeshi.fanli.service.inter.order.PidOrderService; import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService; import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService; import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService; @@ -33,6 +35,7 @@ import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; +import com.yeshi.fanli.util.TaoBaoConstant; import com.yeshi.fanli.util.TimeUtil; import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil; import com.yeshi.fanli.util.taobao.TaoKeOrderApiUtil; @@ -44,18 +47,6 @@ public UpdateOrderJob() { System.out.println("鍒濆鍖�:UpdateOrderJob"); } - - @Resource - private OrderItemServcie orderItemServcie; - - @Resource - private ThreeSaleGiftService threeSaleGiftService; - - @Resource - private HongBaoService hongBaoService; - - @Resource - private PidOrderService pidOrderService; @Resource private OrderProcessService orderProcessService; @@ -84,6 +75,9 @@ @Resource private OrderService orderService; + @Resource + private CommonOrderService commonOrderService; + /** * 鏂扮増鑾峰彇鏅�氳鍗� * @@ -95,19 +89,20 @@ int page = 1; String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss"); List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoAllOrder(startTimeStr, span, page, - Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET); + TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET); while (orderList.size() == 100 * page) { page++; List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoAllOrder(startTimeStr, span, page, - Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET); + TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET); if (tempOrderList != null && tempOrderList.size() > 0) orderList.addAll(tempOrderList); } return orderList; } - + /** * 鑾峰彇绗笁鏂规櫘閫氳鍗� + * * @param startTime * @param span * @return @@ -116,11 +111,11 @@ int page = 1; String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss"); List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoThirdAllOrder(startTimeStr, span, page, - Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET); + TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET); while (orderList.size() == 100 * page) { page++; List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoThirdAllOrder(startTimeStr, span, page, - Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET); + TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET); if (tempOrderList != null && tempOrderList.size() > 0) orderList.addAll(tempOrderList); } @@ -129,13 +124,14 @@ /** * 鑾峰彇鏌愪釜鍖洪棿娈电殑璁㈠崟 + * * @param startTime * @param endTime * @return */ public static List<TaoBaoOrder> getCommonOrder(long startTime, long endTime) { List<TaoBaoOrder> orderList = new ArrayList<>(); - long span =(endTime - startTime)%1000==0? (endTime - startTime)/1000:(endTime - startTime)/1000+1; + long span = (endTime - startTime) % 1000 == 0 ? (endTime - startTime) / 1000 : (endTime - startTime) / 1000 + 1; int count = (int) (span / 1200); if (span % 1200 != 0) count++; @@ -153,17 +149,17 @@ } return orderList; } - - + /** * 鐖彇涓夋柟璁㈠崟 + * * @param startTime * @param endTime * @return */ public static List<TaoBaoOrder> getThirdCommonOrder(long startTime, long endTime) { List<TaoBaoOrder> orderList = new ArrayList<>(); - long span =(endTime - startTime)%1000==0? (endTime - startTime)/1000:(endTime - startTime)/1000+1; + long span = (endTime - startTime) % 1000 == 0 ? (endTime - startTime) / 1000 : (endTime - startTime) / 1000 + 1; int count = (int) (span / 1200); if (span % 1200 != 0) count++; @@ -200,36 +196,38 @@ } public void updateOrder(long startTime, long endTime) { -// 鑰佺増鏈鐞嗘柟寮� - List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID); - List<TaoBaoOrder> orderList = new ArrayList<>(); - try { - orderList = TaoBaoOrderUtil.getOrderList(startTime, endTime, configList.get(0)); - } catch (TaoBaoOrderException e2) { - try { - LogHelper.errorDetailInfo(e2); - } catch (Exception e) { - e.printStackTrace(); - } - } - List<TaoBaoOrder> thirdOrderList = new ArrayList<>(); - try { - thirdOrderList = TaoBaoOrderUtil.getThirdServiceOrderList(startTime, endTime, configList.get(0)); - } catch (TaoBaoOrderException e2) { - try { - LogHelper.errorDetailInfo(e2); - } catch (Exception e) { - e.printStackTrace(); - } - } - if (thirdOrderList != null && thirdOrderList.size() > 0) - orderList.addAll(thirdOrderList); -//鏂扮増鏈鐞嗘柟寮� -// List<TaoBaoOrder> orderList= getCommonOrder(startTime, endTime); -// List<TaoBaoOrder> tempOrderList2=getThirdCommonOrder(startTime, endTime); -// if(tempOrderList2!=null&&tempOrderList2.size()>0) -// orderList.addAll(tempOrderList2); - + // 鑰佺増鏈鐞嗘柟寮� + // List<TaoBaoUnionConfig> configList = + // taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID); + // List<TaoBaoOrder> orderList = new ArrayList<>(); + // try { + // orderList = TaoBaoOrderUtil.getOrderList(startTime, endTime, + // configList.get(0)); + // } catch (TaoBaoOrderException e2) { + // try { + // LogHelper.errorDetailInfo(e2); + // } catch (Exception e) { + // e.printStackTrace(); + // } + // } + // List<TaoBaoOrder> thirdOrderList = new ArrayList<>(); + // try { + // thirdOrderList = TaoBaoOrderUtil.getThirdServiceOrderList(startTime, + // endTime, configList.get(0)); + // } catch (TaoBaoOrderException e2) { + // try { + // LogHelper.errorDetailInfo(e2); + // } catch (Exception e) { + // e.printStackTrace(); + // } + // } + // if (thirdOrderList != null && thirdOrderList.size() > 0) + // orderList.addAll(thirdOrderList); + // 鏂扮増鏈鐞嗘柟寮� + List<TaoBaoOrder> orderList = getCommonOrder(startTime, endTime); + List<TaoBaoOrder> tempOrderList2 = getThirdCommonOrder(startTime, endTime); + if (tempOrderList2 != null && tempOrderList2.size() > 0) + orderList.addAll(tempOrderList2); LogHelper.orderInfo("姝e湪鎵ц璁㈠崟鐖彇缁撴潫锛屽叡鏈夎鍗�:" + orderList.size()); addOrder(orderList); @@ -276,7 +274,7 @@ return orderList; } - private void addOrder(List<TaoBaoOrder> orderList) { + public void addOrder(List<TaoBaoOrder> orderList) { if (orderList != null) for (int i = 0; i < orderList.size(); i++) { @@ -303,11 +301,8 @@ try { taoBaoOrderService.addTaoBaoOrderList(orderList); } catch (Exception e) { - try { - LogHelper.errorDetailInfo(e); - } catch (Exception e1) { - e1.printStackTrace(); - } + LogHelper.errorDetailInfo(e); + } try { @@ -328,7 +323,7 @@ } - CMQManager.getInstance().addTaoBaoOrderMsg(key, orders); + CMQManager.getInstance().addTaoBaoOrderMsg(key); try { // 6灏忔椂鍐呬笉鍐嶅鐞� @@ -339,20 +334,16 @@ } } } catch (Exception e) { - try { - LogHelper.errorDetailInfo(e); - } catch (Exception e1) { - e1.printStackTrace(); - } + LogHelper.errorDetailInfo(e); } } // 姣�15鍒嗛挓鐖彇涓�娆� -// @Scheduled(cron = "0 0/15 * * * ? ") + @Scheduled(cron = "0 0/15 * * * ? ") public void doJob1() { -// if (!Constant.IS_TASK) -// return; - long currentTime = System.currentTimeMillis(); + if (!Constant.IS_TASK) + return; + long currentTime = System.currentTimeMillis() - 1000 * 60; String h = TimeUtil.getGernalTime(currentTime, "HH"); String m = TimeUtil.getGernalTime(currentTime, "mm"); int mm = Integer.parseInt(h) * 60 + Integer.parseInt(m); @@ -371,8 +362,9 @@ public void doJob6() { if (!Constant.IS_TASK) return; - long endTime=System.currentTimeMillis(); - updateOrder(endTime-1000*60*20L, endTime); + long endTime = System.currentTimeMillis() - 1000 * 60; + ; + updateOrder(endTime - 1000 * 60 * 20L, endTime); } // 杩斿埄 @@ -380,8 +372,7 @@ public void doJob2() { if (!Constant.IS_TASK) return; - doTaoBaoWeiQuan(); - + doTaoBaoWeiQuan(10); orderProcessService.fanli(); } @@ -399,28 +390,193 @@ public void doTaoBaoWeiQuan() { if (!Constant.IS_TASK) return; - List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID); - List<TaoBaoWeiQuanOrder> orderList = TaoBaoOrderUtil.getWeiQuanOrders( - System.currentTimeMillis() - 1000 * 60 * 60 * 24 * 60L, System.currentTimeMillis(), configList.get(0)); - if (orderList != null) - for (TaoBaoWeiQuanOrder order : orderList) - taoBaoWeiQuanOrderService.addWeiQuanOrder(order);// 娣诲姞缁存潈璁㈠崟鍒版暟鎹簱 - // 澶勭悊缁存潈璁㈠崟 - orderProcessService.weiQuanOrder(orderList); + // 鏂扮増缁存潈璁㈠崟澶勭悊 + doTaoBaoWeiQuan(60); } - // 澶勭悊鍒嗕韩鍟嗗搧鎵�浜х敓鐨勮鍗�(鍚庣画鐗堟湰搴熼櫎) - // @Scheduled(cron = "0 0/2 * * * ? ") - // public void doPidOrder() { - // if (!Constant.IS_TASK) - // return; - // pidOrderService.doPidOrder(); - // } + private void doTaoBaoWeiQuan(int day) { + for (int i = 0; i < day; i++) { + List<TaoBaoWeiQuanOrder> orderList = new ArrayList<>(); + WeiQuanOrderResult result = TaoKeOrderApiUtil + .getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp( + TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"), + "yyyy-MM-dd")), 1, false); + orderList.addAll(result.orderList); + + result = TaoKeOrderApiUtil.getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp( + TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"), + "yyyy-MM-dd")), 1, true); + orderList.addAll(result.orderList); + + result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp( + TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"), + "yyyy-MM-dd")), 1, false); + orderList.addAll(result.orderList); + + result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp( + TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"), + "yyyy-MM-dd")), 1, true); + orderList.addAll(result.orderList); + + for (TaoBaoWeiQuanOrder order : orderList) + taoBaoWeiQuanOrderService.addWeiQuanOrder(order);// 娣诲姞缁存潈璁㈠崟鍒版暟鎹簱 + // 澶勭悊缁存潈璁㈠崟 + orderProcessService.weiQuanOrder(orderList); + } + + } // 姣�6涓皬鏃舵墽琛屼竴娆� @Scheduled(cron = "0 0 0/6 * * ? ") public void doLostOrder() { + if (!Constant.IS_TASK) + return; lostOrderService.processFail(); } + // 姣�2鍒嗛挓鎵ц涓�娆� + @Scheduled(cron = "0 0/2 * * * ? ") + public void addLostOrder() { + if (!Constant.IS_TASK) + return; + LogHelper.test("澶勭悊涓㈠け璁㈠崟"); + List<LostOrder> list = lostOrderService.listByStateAndResultCode(LostOrder.STATE_PASS, + LostOrder.RESULT_CODE_VERFING, 1, 50); + if (list != null) + for (LostOrder lo : list) { + List<TaoBaoOrder> taoBaoOrderList = taoBaoOrderService.getTaoBaoOrderByOrderId(lo.getOrderId()); + // 娓呴櫎棰戠巼闄愬埗 + if (taoBaoOrderList != null && taoBaoOrderList.size() > 0) { + String key = "addorderqueue-" + lo.getOrderId(); + redisManager.removeCommonString(key); + addOrder(taoBaoOrderList); + LogHelper.test("鑷姩澶勭悊娣樺疂璁㈠崟:" + lo.getOrderId()); + } + } + } + + /** + * 澶勭悊娣樺疂缁撶畻璁㈠崟,30fen鎵ц涓�娆� + */ + @Scheduled(cron = "30 0 0/1 * * ? ") + public void doSettleOrders() { + if (!Constant.IS_TASK) + return; + // 澶勭悊3-15澶╁墠鐨勮鍗曪紝姣忓ぉ璺戜竴娆� + Calendar ca = Calendar.getInstance(); + int hour = ca.get(Calendar.HOUR_OF_DAY); + + long startTime = TimeUtil.convertToTimeTemp( + TimeUtil.getGernalTime(ca.getTimeInMillis() - 1000 * 60 * 60 * 24 * 3L, "yyyy-MM-dd"), "yyyy-MM-dd") + - hour * (1000 * 60 * 60 * 12L); + long endTime = startTime + 1000 * 60 * 60 * 12L; + List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, false); + List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, true); + if (tempOrderList != null && tempOrderList.size() > 0) + orderList.addAll(tempOrderList); + addOrder(orderList); + } + + /** + * 13鍒嗛挓鏇存柊鏈�杩�13鍒嗛挓鐨勭粨绠楁暟鎹� + */ + @Scheduled(cron = "0 0/13 * * * ? ") + public void doSettleOrdersToday() { + if (!Constant.IS_TASK) + return; + // 澶勭悊3-15澶╁墠鐨勮鍗曪紝姣忓ぉ璺戜竴娆� + Calendar ca = Calendar.getInstance(); + long startTime = ca.getTimeInMillis() - 1000 * 60 * 5L - 1000 * 60 * 13L; + long endTime = startTime + 1000 * 60 * 13L; + List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, false); + List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, true); + if (tempOrderList != null && tempOrderList.size() > 0) + orderList.addAll(tempOrderList); + addOrder(orderList); + } + + /** + * 鏇存柊鏈湴璁㈠崟锛堝噷鏅�25鍒嗘洿鏂帮級 + */ + @Scheduled(cron = "25 0 0 * * ? ") + public void doLocalTaoBaoOrder() { + if (!Constant.IS_TASK) + return; + // 澶勭悊3-15澶╁墠鐨勮鍗曪紝姣忓ぉ璺戜竴娆� + Long startTime = System.currentTimeMillis() - 1000 * 60 * 60 * 24 * 60L; + Long endTime = startTime + 1000 * 60 * 60 * 24 * 48L; + List<CommonOrder> commonOrderList = commonOrderService.listBySourceTypeAndStateAndThirdCrateTime( + Constant.SOURCE_TYPE_TAOBAO, CommonOrder.STATE_FK, startTime, endTime, 1, 500); + Set<String> orderIds = new HashSet<>(); + for (CommonOrder co : commonOrderList) { + orderIds.add(co.getOrderNo()); + } + + for (Iterator<String> its = orderIds.iterator(); its.hasNext();) { + String orderId = its.next(); + List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId); + Map<String, List<TaoBaoOrder>> orders = new HashMap<>(); + orders.put(orderId, orderList); + orderProcessService.processOrder(orders); + } + } + + /** + * 鏇存柊鏈�杩戠殑鏈湴鍗�(30鍒嗛挓鏇存柊涓�娆�) + */ + + @Scheduled(cron = "0 0/30 * * * ? ") + public void doLatestLocalTaoBaoOrder() { + if (!Constant.IS_TASK) + return; + Long endTime = System.currentTimeMillis() - 1000 * 60 * 10L; + Long startTime = endTime - 1000 * 60 * 60 * 12L; + updateLocalTaoBaoOrder(startTime, endTime, 1, 2000); + + } + + public void updateLocalTaoBaoOrder(Long startTime, Long endTime, int page, int count) { + List<TaoBaoOrder> list = taoBaoOrderService.listBySettlementTime(startTime, endTime, page, count); + Set<String> orderIds = new HashSet<>(); + for (TaoBaoOrder co : list) { + orderIds.add(co.getOrderId()); + } + + for (Iterator<String> its = orderIds.iterator(); its.hasNext();) { + String orderId = its.next(); + // 鏌ヨ鏄惁鏈夊浜庤鍗曚粯娆剧姸鎬佺殑鍗� + List<CommonOrder> commonOrderList = commonOrderService + .listBySourceTypeAndOrderId(Constant.SOURCE_TYPE_TAOBAO, orderId); + boolean update = false; + if (commonOrderList != null) + for (CommonOrder co : commonOrderList) { + if (co.getState() == CommonOrder.STATE_FK && co.getPayment().compareTo(new BigDecimal(0)) > 0) { + update = true; + break; + } + } + + if (update) { + List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId); + Map<String, List<TaoBaoOrder>> orders = new HashMap<>(); + orders.put(orderId, orderList); + orderProcessService.processOrder(orders); + } + } + } + + @Scheduled(cron = "30 13 3 * * ? ") + public void doLatest5DayLocalTaoBaoOrder() { + if (!Constant.IS_TASK) + return; + Long endTime = System.currentTimeMillis() - 1000 * 60 * 60 * 12L; + Long startTime = endTime - 1000 * 60 * 60 * 24 * 5L; + long count = taoBaoOrderService.countBySettlementTime(startTime, endTime); + int pageSize = 100; + long page = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; + for (int i = 0; i < page; i++) { + updateLocalTaoBaoOrder(startTime, endTime, i + 1, pageSize); + } + } + } -- Gitblit v1.8.0