From 81da61b828e29b7745e1382dfbbaeb685dc083ef Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 23 一月 2024 17:17:55 +0800
Subject: [PATCH] 抖音转链修改
---
fanli/src/main/java/com/yeshi/fanli/controller/admin/order/TaoBaoOrderController.java | 157 ++++++++++++++++++++++++++++++++++++++++++----------
1 files changed, 126 insertions(+), 31 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/admin/order/TaoBaoOrderController.java b/fanli/src/main/java/com/yeshi/fanli/controller/admin/order/TaoBaoOrderController.java
index 9ffd6f8..347f94b 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/admin/order/TaoBaoOrderController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/admin/order/TaoBaoOrderController.java
@@ -2,16 +2,25 @@
import com.google.gson.*;
import com.yeshi.common.entity.PageEntity;
+import com.yeshi.fanli.dao.mybatis.HongBaoV2Mapper;
+import com.yeshi.fanli.dao.mybatis.order.CommonOrderMapper;
+import com.yeshi.fanli.dao.mybatis.order.HongBaoOrderMapper;
+import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoOrderMapper;
import com.yeshi.fanli.dao.taobao.TaoBaoOrderBackUpDao;
import com.yeshi.fanli.entity.accept.AdminAcceptData;
+import com.yeshi.fanli.entity.bus.user.HongBaoV2;
+import com.yeshi.fanli.entity.order.CommonOrder;
+import com.yeshi.fanli.entity.order.HongBaoOrder;
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
import com.yeshi.fanli.entity.taobao.TaoBaoOrderBackUp;
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
+import com.yeshi.fanli.job.order.taobao.TaoBaoOrderUpdateJob;
import com.yeshi.fanli.job.order.taobao.UpdateOrderJob;
import com.yeshi.fanli.job.order.taobao.UpdateTBRelationAndSpecialOrderJob;
import com.yeshi.fanli.service.inter.order.OrderProcessService;
import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;
import com.yeshi.fanli.service.inter.order.tb.TaoBaoWeiQuanOrderService;
+import com.yeshi.fanli.util.BeanUtil;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.ThreadUtil;
@@ -31,6 +40,7 @@
import java.io.IOException;
import java.io.PrintWriter;
import java.lang.reflect.Type;
+import java.math.BigDecimal;
import java.util.*;
@Controller
@@ -44,16 +54,18 @@
private TaoBaoWeiQuanOrderService taoBaoWeiQuanOrderService;
@Resource
- private UpdateTBRelationAndSpecialOrderJob updateRelationAndSpecialOrderJob;
-
- @Resource
- private UpdateOrderJob updateOrderJob;
-
- @Resource
private OrderProcessService orderProcessService;
@Resource
- private TaoBaoOrderBackUpDao taoBaoOrderBackUpDao;
+ private TaoBaoOrderUpdateJob taoBaoOrderUpdateJob;
+
+
+ @Resource
+ private CommonOrderMapper commonOrderMapper;
+ @Resource
+ private HongBaoOrderMapper hongBaoOrderMapper;
+ @Resource
+ private HongBaoV2Mapper hongBaoV2Mapper;
/**
* 鏌ヨ鍒楄〃 - 鏂板悗鍙�
@@ -178,34 +190,11 @@
int p = 0;
for (Iterator<String> its = orderIds.iterator(); its.hasNext(); ) {
String orderId = its.next();
- List<TaoBaoOrder> list = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId);
- try {
- //濡傛灉鍒涘缓鏃堕棿瓒呰繃浜�90澶╃殑鎶涘嚭寮傚父
- if (list.size() == 0 || TimeUtil.convertToTimeTemp(list.get(0).getCreateTime(), "yyyy-MM-dd HH:mm:ss") < System.currentTimeMillis() - 1000 * 60 * 60L * 24 * 90)
- throw new Exception("闇�瑕佹湰鍦版洿鏂�");
- long startTime = TimeUtil.convertToTimeTemp(list.get(0).getCreateTime(), "yyyy-MM-dd HH:mm:ss") - 1000L;
- long endTime = TimeUtil.convertToTimeTemp(list.get(0).getCreateTime(), "yyyy-MM-dd HH:mm:ss") + 1000L;
- updateRelationAndSpecialOrderJob.updateRelationAndSpecialOrder(startTime, endTime);
- updateOrderJob.updateOrder(startTime, endTime);
- } catch (Exception e) {
- //浠庢湰鍦板浠芥嬁鍑鸿鍗�
- List<String> tradeIds = new ArrayList<>();
- for (TaoBaoOrder order : list) {
- tradeIds.add(order.getTradeId());
- }
- List<TaoBaoOrderBackUp> orderBackUps = taoBaoOrderBackUpDao.listByIds(tradeIds);
- List<TaoBaoOrder> orderList = new ArrayList<>();
- for (TaoBaoOrderBackUp backUp : orderBackUps) {
- orderList.add(TaoKeOrderApiUtil.parseTaoBaoOrderNew(JSONObject.fromObject(backUp.getContent())));
- }
- updateOrderJob.addOrder(orderList);
- }
+ taoBaoOrderUpdateJob.updateTaoBaoOrder(orderId);
}
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鏇存柊鎴愬姛"));
} catch (Exception e) {
-
-
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏇存柊澶辫触"));
e.printStackTrace();
}
@@ -302,4 +291,110 @@
});
}
+
+ /**
+ * @return void
+ * @author hxh
+ * @description 杩濊璁㈠崟澶勭悊
+ * @date 15:06 2021/10/23
+ * @param: acceptData
+ * @param: content
+ * @param: out
+ **/
+ @RequestMapping(value = "weiGui")
+ public void weiGuiOrder(AdminAcceptData acceptData, String content, String callback, PrintWriter out) {
+
+ if (StringUtil.isNullOrEmpty(content)) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇蜂笂浼犺鍗曞彿"));
+ return;
+ }
+
+ List<String> orderIdList = new ArrayList<>();
+ Scanner scanner = new Scanner(content);
+ while (scanner.hasNextLine()) {
+ String line = scanner.nextLine();
+ if (!StringUtil.isNullOrEmpty(line))
+ orderIdList.add(line.trim());
+ }
+ scanner.close();
+
+ if (orderIdList.size() == 0) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇蜂笂浼犺鍗曞彿"));
+ return;
+ }
+
+ BigDecimal fanliMoney = new BigDecimal(0);
+ BigDecimal unFanliMoney = new BigDecimal(0);
+ BigDecimal childFanliMoney = new BigDecimal(0);
+ int validCount = 0;
+ int inValidCount = 0;
+ Set<Long> uids = new HashSet<>();
+ try {
+ for (int c = 0; c < orderIdList.size(); c++) {
+ String orderId = orderIdList.get(c);
+ List<CommonOrder> orderList = commonOrderMapper.listBySourceTypeAndOrderNo(Constant.SOURCE_TYPE_TAOBAO,
+ orderId);
+ if (orderList.size() > 0) {
+ validCount++;
+ for (CommonOrder commonOrder : orderList) {
+ uids.add(commonOrder.getUserInfo().getId());
+ HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByCommonOrderId(commonOrder.getId());
+ if (hongBaoOrder != null) {
+ HongBaoV2 v2 = hongBaoOrder.getHongBaoV2();
+ if (v2.getState() == 3) {
+ fanliMoney = fanliMoney.add(v2.getMoney());
+ // 鏌ヨ涓婄骇鏄惁鍒拌处
+ List<HongBaoV2> children = hongBaoV2Mapper.listChildrenById(v2.getId());
+ if (children != null && children.size() > 0) {
+ for (HongBaoV2 hongBao : children) {
+ if (hongBao.getState() == HongBaoV2.STATE_BUKELINGQU
+ || hongBao.getState() == HongBaoV2.STATE_KELINGQU) {
+ HongBaoV2 updateHongBao = new HongBaoV2(hongBao.getId());
+ updateHongBao.setState(HongBaoV2.STATE_SHIXIAO);
+ updateHongBao.setBeizhu("鑱旂洘杩濊");
+ updateHongBao.setUpdateTime(new Date());
+ hongBaoV2Mapper.updateByPrimaryKeySelective(updateHongBao);
+ } else {//
+ childFanliMoney = childFanliMoney.add(hongBao.getMoney());
+ }
+ }
+ }
+ } else if (v2.getState() == 1 || v2.getState() == 2) {
+ unFanliMoney = unFanliMoney.add(v2.getMoney());
+ HongBaoV2 update = new HongBaoV2(v2.getId());
+ update.setState(HongBaoV2.STATE_SHIXIAO);
+ update.setBeizhu("鑱旂洘杩濊");
+ update.setUpdateTime(new Date());
+ hongBaoV2Mapper.updateByPrimaryKeySelective(update);
+ // 鍙戠幇瀛愯鍗�
+ List<HongBaoV2> children = hongBaoV2Mapper.listChildrenById(v2.getId());
+ if (children != null && children.size() > 0) {
+ for (HongBaoV2 hongBao : children) {
+ HongBaoV2 updateHongBao = new HongBaoV2(hongBao.getId());
+ updateHongBao.setState(HongBaoV2.STATE_SHIXIAO);
+ updateHongBao.setBeizhu("鑱旂洘杩濊");
+ updateHongBao.setUpdateTime(new Date());
+ hongBaoV2Mapper.updateByPrimaryKeySelective(updateHongBao);
+ }
+ }
+ }
+ }
+ }
+ } else
+ inValidCount++;
+ }
+
+ System.out.println(
+ validCount + "-" + inValidCount + "-" + fanliMoney + "-" + unFanliMoney + "-" + childFanliMoney);
+ Iterator<Long> its = uids.iterator();
+ while (its.hasNext()) {
+ System.out.println(its.next());
+ }
+ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("澶勭悊鎴愬姛"));
+ } catch (Exception e) {
+ e.printStackTrace();
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("澶勭悊鍑洪敊锛�" + e.getMessage()));
+ }
+ }
+
}
--
Gitblit v1.8.0