From 69bee82b81626b82b7f39f0e459e4f56b1699b51 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 13 三月 2019 12:02:16 +0800 Subject: [PATCH] 正式数据库修改 --- fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java | 90 +++++++++++++++++++++------------------------ 1 files changed, 42 insertions(+), 48 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 9e38dea..0462f4f 100644 --- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java +++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java @@ -18,13 +18,10 @@ import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder; 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.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; @@ -44,17 +41,9 @@ System.out.println("鍒濆鍖�:UpdateOrderJob"); } - @Resource - private OrderItemServcie orderItemServcie; @Resource private ThreeSaleGiftService threeSaleGiftService; - - @Resource - private HongBaoService hongBaoService; - - @Resource - private PidOrderService pidOrderService; @Resource private OrderProcessService orderProcessService; @@ -104,9 +93,10 @@ } return orderList; } - + /** * 鑾峰彇绗笁鏂规櫘閫氳鍗� + * * @param startTime * @param span * @return @@ -128,13 +118,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++; @@ -152,17 +143,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++; @@ -199,36 +190,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) + // 鑰佺増鏈鐞嗘柟寮� + // 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); @@ -351,7 +344,7 @@ public void doJob1() { if (!Constant.IS_TASK) return; - long currentTime = System.currentTimeMillis(); + 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); @@ -370,8 +363,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); } // 杩斿埄 -- Gitblit v1.8.0