fanli/libs/osp-sdk-1.0.jar | 补丁 | 查看 | 原始文档 | blame | 历史 | |
fanli/libs/vop-sdk-1.0.jar | 补丁 | 查看 | 原始文档 | blame | 历史 | |
fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
fanli/src/main/java/com/yeshi/fanli/util/factory/goods/CommonOrderFactory.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoBaoOrderUtil.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
fanli/src/main/webapp/WEB-INF/lib/osp-sdk.jar | 补丁 | 查看 | 原始文档 | blame | 历史 | |
fanli/src/main/webapp/WEB-INF/lib/vop-sdk.jar | 补丁 | 查看 | 原始文档 | blame | 历史 |
fanli/libs/osp-sdk-1.0.jarBinary files differ
fanli/libs/vop-sdk-1.0.jarBinary files differ
fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java
@@ -102,10 +102,9 @@ @Resource private TaoBaoWeiQuanOrderService taoBaoWeiQuanOrderService; @Resource private UserInfoExtraService userInfoExtraService; /** * @@ -397,6 +396,11 @@ if (adminUser == null) { record.setAdminUser(new AdminUser()); } // 查询用户备注信息 UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(record.getExtract().getUserInfo().getId()); if (extra != null) { record.getExtract().getUserInfo().setStateDesc(extra.getMark()); } int warnLevel = 0; Extract extract = record.getExtract(); @@ -446,7 +450,7 @@ GsonBuilder gsonBuilder = new GsonBuilder(); gsonBuilder.serializeNulls(); gsonBuilder.setDateFormat("yyyy-MM-dd HH:mm:ss"); Gson gson = gsonBuilder.create(); JSONObject data = new JSONObject(); @@ -560,14 +564,14 @@ } else { surplusTime = DateUtil.dateDiff(formattodayTime, formatTime); } String mark = ""; UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(extract.getUserInfo().getId()); if (userInfoExtra != null && !StringUtil.isNullOrEmpty(userInfoExtra.getMark())) { mark = "警惕!! " + userInfoExtra.getMark(); } data.put("mark",mark); data.put("mark", mark); data.put("extract", extract); data.put("beforeMoney", beforeMoney); data.put("surplusTime", surplusTime); @@ -637,7 +641,7 @@ mark = "警惕!! " + userInfoExtra.getMark(); } data.put("mark",mark); data.put("mark", mark); data.put("extract", extract); data.put("beforeMoney", beforeMoney); data.put("surplusTime", surplusTime); @@ -850,8 +854,8 @@ innerList.put("name", "驳回数"); } List<ChartTDO> list = extractAuditRecordService.countAuditTotal(state, dateType, year, startTime, endTime); List<ChartTDO> list = extractAuditRecordService.countAuditTotal(state, dateType, year, startTime, endTime); if (dateType != 3) { innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); } else { @@ -935,8 +939,8 @@ JSONObject innerList = new JSONObject(); innerList.put("name", "总计"); List<ChartTDO> list = extractAuditRecordService.countExtractApplyMoney(null, dateType, year, startTime, endTime); List<ChartTDO> list = extractAuditRecordService.countExtractApplyMoney(null, dateType, year, startTime, endTime); if (dateType != 3) { innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); @@ -1020,12 +1024,11 @@ Gson gson = new Gson(); List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); JSONObject innerList = new JSONObject(); innerList.put("name", "总计"); List<ChartTDO> list = extractAuditRecordService.countExtractApplyNumber(null, dateType, year, startTime, endTime); List<ChartTDO> list = extractAuditRecordService.countExtractApplyNumber(null, dateType, year, startTime, endTime); if (dateType != 3) { innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); @@ -1056,7 +1059,7 @@ e.printStackTrace(); } } @RequestMapping(value = "downAutoExtractTxt") public void downAutoExtractTxt(String callback, HttpServletResponse response, PrintWriter out) { try { @@ -1065,35 +1068,35 @@ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无用户满足自动提现条件")); return; } String filepath = "自动提现OpenId "+ java.lang.System.currentTimeMillis() + ".txt"; String filepath = "自动提现OpenId " + java.lang.System.currentTimeMillis() + ".txt"; response.reset(); response.setContentType("application/octet-stream"); String fileName= URLDecoder.decode(filepath,"utf-8"); response.addHeader("Content-Disposition","attachment;"+ "filename=\"" +URLEncoder.encode(fileName, "utf-8") + "\""); response.setContentType("application/octet-stream"); String fileName = URLDecoder.decode(filepath, "utf-8"); response.addHeader("Content-Disposition", "attachment;" + "filename=\"" + URLEncoder.encode(fileName, "utf-8") + "\""); StringBuilder sb = new StringBuilder(); for(String t:list){ sb.append(t+"\r\n"); for (String t : list) { sb.append(t + "\r\n"); } String opid_str = sb.toString(); if (!StringUtil.isNullOrEmpty(opid_str) && opid_str.endsWith("\r\n")) { opid_str = opid_str.substring(0, opid_str.length() - 2); } OutputStream os = response.getOutputStream(); byte[] byt = opid_str.getBytes(); os.write(byt); os.flush(); os.close(); OutputStream os = response.getOutputStream(); byte[] byt = opid_str.getBytes(); os.write(byt); os.flush(); os.close(); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); e.printStackTrace(); } } @RequestMapping(value = "uploadExcel", method = RequestMethod.POST) public void uploadExcel(@RequestParam("file") CommonsMultipartFile file, PrintWriter out) { if (file == null) { @@ -1112,9 +1115,7 @@ out.print(JsonUtil.loadFalseResult("上传失败")); } } @RequestMapping(value = "preAutoUser") public void preAutoUser(String callback, Integer pageIndex, Integer pageSize, PrintWriter out) { try { @@ -1123,7 +1124,7 @@ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无用户满足自动提现条件")); return; } if (pageIndex == null || pageIndex < 1) { pageIndex = 1; } @@ -1131,22 +1132,22 @@ if (pageSize == null || pageSize < 1) { pageSize = Constant.PAGE_SIZE; } int count = list.size(); int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); List<UserInfo> listResult = null; if (pageIndex < totalPage) { int start = (pageIndex - 1) * pageSize; listResult = list.subList(start, start + pageSize); } else if (pageIndex == totalPage) { listResult = list.subList((pageIndex - 1) * pageSize, list.size()); listResult = list.subList((pageIndex - 1) * pageSize, list.size()); } else { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("没有更多了")); return; } JSONObject data = new JSONObject(); data.put("pe", pe); data.put("result_list", listResult); fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java
@@ -322,9 +322,9 @@ // 每15分钟爬取一次 @Scheduled(cron = "0 0/15 * * * ? ") public void pullCommonOrder() { LogHelper.job("正在执行15min订单爬取"); if (!Constant.IS_TASK) return; LogHelper.job("正在执行15min订单爬取"); long currentTime = System.currentTimeMillis() - 1000 * 60; String h = TimeUtil.getGernalTime(currentTime, "HH"); String m = TimeUtil.getGernalTime(currentTime, "mm"); fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
@@ -173,7 +173,7 @@ doJDOrderJob();// 京东订单处理 doPDDOrderJob();// 拼多多订单处理 doImportantTaoBaoGoodsUpdateJob();// 淘宝重要商品的信息更新 // doHongBaoRecieveIntegralGetJob();// 返利到账,金币增加 doHongBaoRecieveIntegralGetJob();// 返利到账,金币增加 // doPlaceOrderIntegralJob();// 下单赠送金币任务 // doDouYinDeviceActiveJob();// 抖音设备激活广告监测 } @@ -722,7 +722,6 @@ } } }); } /** @@ -792,8 +791,9 @@ if (threeSale.getSucceedTime() > TimeUtil.convertToTimeTemp("20190901", "yyyyMMdd")) { if (firstLevelMoney.compareTo(new BigDecimal("0.01")) < 0) {// 一级返利小于0.01 // integralTaskRecordService.firstRebateOrderRewardBoss(threeSale.getBoss().getId(), // hongBaoV2.getUserInfo().getId(), null); integralTaskRecordService.firstRebateOrderRewardBoss( threeSale.getBoss().getId(), hongBaoV2.getUserInfo().getId(), null); LogHelper.test("自购-一级用户-" + threeSale.getBoss().getId() + "-hongBaoId:" + hongBaoV2.getId()); } @@ -809,8 +809,9 @@ if (threeSale.getSucceedTime() > TimeUtil .convertToTimeTemp("20190901", "yyyyMMdd")) { if (secondLevelMoney.compareTo(new BigDecimal("0.01")) < 0) {// 二级返利小于0.01 // integralTaskRecordService.firstRebateOrderRewardBossSuper(threeSale.getBoss().getId(), // hongBaoV2.getUserInfo().getId(), null); integralTaskRecordService.firstRebateOrderRewardBossSuper( threeSale.getBoss().getId(), hongBaoV2.getUserInfo().getId(), null); LogHelper.test("自购-二级用户-" + threeSale.getBoss().getId() + "-hongBaoId:" + hongBaoV2.getId()); } @@ -864,8 +865,9 @@ if (threeSale.getSucceedTime() > TimeUtil.convertToTimeTemp("20190901", "yyyyMMdd")) { if (firstLevelMoney.compareTo(new BigDecimal("0.01")) < 0) {// 一级返利小于0.01 // integralTaskRecordService.firstSharerOrderRewardBoss(threeSale.getBoss().getId(), // hongBaoV2.getUserInfo().getId(), null); integralTaskRecordService.firstSharerOrderRewardBoss( threeSale.getBoss().getId(), hongBaoV2.getUserInfo().getId(), null); LogHelper.test("分享-一级用户-" + threeSale.getBoss().getId() + "-hongBaoId:" + hongBaoV2.getId()); } @@ -874,9 +876,8 @@ } } } // HongBaoRecieveCMQManager.getInstance() // .deleteQueueMsg(HongBaoRecieveCMQManager.QUEUE_INTEGRAL, // key); HongBaoRecieveCMQManager.getInstance() .deleteQueueMsg(HongBaoRecieveCMQManager.QUEUE_INTEGRAL, key); } catch (Exception e) { try { LogHelper.errorDetailInfo(e); fanli/src/main/java/com/yeshi/fanli/util/factory/goods/CommonOrderFactory.java
@@ -45,8 +45,8 @@ } else if (0 == order.getOrderStatus()) { state = CommonOrder.STATE_FK; } else if (1 == order.getOrderStatus()) { state = CommonOrder.STATE_FK; } else if (2 == order.getOrderStatus()) {// 确认收货 state = CommonOrder.STATE_FK; } else if (2 == order.getOrderStatus()) {// 确认收货 state = CommonOrder.STATE_JS; } else if (3 == order.getOrderStatus()) { state = CommonOrder.STATE_FK; @@ -89,6 +89,26 @@ int state = 0; if (order.getValidCode() < 16) { state = CommonOrder.STATE_SX; String stateDesc = null; if (order.getValidCode() == 4) stateDesc = "京东帮主订单"; else if (order.getValidCode() == 5) stateDesc = "账号异常"; else if (order.getValidCode() == 6) stateDesc = "赠品类目"; else if (order.getValidCode() == 7) stateDesc = "校园订单"; else if (order.getValidCode() == 8) stateDesc = "企业订单"; else if (order.getValidCode() == 9) stateDesc = "团购订单"; else if (order.getValidCode() == 10) stateDesc = "专用发票"; else if (order.getValidCode() == 11) stateDesc = "乡村推广员"; else if (order.getValidCode() == 13) stateDesc = "违规订单"; commonOrder.setStateDesc(stateDesc); } else if (order.getValidCode() == 16) { state = CommonOrder.STATE_FK; } else if (order.getValidCode() == 17) { fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoBaoOrderUtil.java
@@ -734,7 +734,7 @@ String tradeId = taoBaoOrder.getTradeId(); String orderByStr = tradeId.substring(startIndex, endIndex + 1); if (orderByStr.length() > 8) { LogHelper.error(taoBaoOrder.getOrderId()+ "-订单的orderBy超过8位:" + taoBaoOrder.getOrderBy()); LogHelper.error(taoBaoOrder.getOrderId() + "-订单的orderBy超过8位:" + taoBaoOrder.getOrderBy()); } int orderBy = Integer.parseInt(orderByStr); // taoBaoOrder.setOrderBy(orderBy); @@ -821,7 +821,7 @@ Collections.sort(orderList, orderCM); String sts = ""; for (TaoBaoOrder order : orderList) { sts += order.getTradeId(); sts += (order.getTradeId() + "-" + order.getSpecialId() + "-" + order.getRelationId()); } return StringUtil.Md5(sts); } fanli/src/main/webapp/WEB-INF/lib/osp-sdk.jarBinary files differ
fanli/src/main/webapp/WEB-INF/lib/vop-sdk.jarBinary files differ