From 4114e871bcb3dce771b6aed64a1027d0bbb95ca6 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 16 五月 2019 15:28:37 +0800 Subject: [PATCH] 增加动态用户 --- fanli/src/main/java/com/yeshi/fanli/controller/client/UserOrderController.java | 73 ++++++++++++++++++++++++++++++------ 1 files changed, 61 insertions(+), 12 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/UserOrderController.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/UserOrderController.java index 7f207cd..c455ab5 100644 --- a/fanli/src/main/java/com/yeshi/fanli/controller/client/UserOrderController.java +++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/UserOrderController.java @@ -18,16 +18,23 @@ import com.yeshi.fanli.entity.AppVersionInfo; import com.yeshi.fanli.entity.accept.AcceptData; +import com.yeshi.fanli.entity.bus.user.Order; import com.yeshi.fanli.entity.bus.user.UserExtraTaoBaoInfo; import com.yeshi.fanli.entity.bus.user.UserInfo; +import com.yeshi.fanli.entity.order.CommonOrder; +import com.yeshi.fanli.entity.taobao.TaoBaoOrder; import com.yeshi.fanli.exception.order.CommonOrderException; import com.yeshi.fanli.service.inter.config.AppVersionService; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.count.HongBaoV2CountService; import com.yeshi.fanli.service.inter.order.CommonOrderService; +import com.yeshi.fanli.service.inter.order.OrderService; +import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService; import com.yeshi.fanli.service.inter.user.UserExtraTaoBaoInfoService; import com.yeshi.fanli.service.inter.user.UserInfoExtraService; import com.yeshi.fanli.service.inter.user.UserInfoService; +import com.yeshi.fanli.util.CMQManager; +import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.account.UserUtil; import com.yeshi.fanli.vo.order.CommonOrderVO; @@ -59,6 +66,12 @@ @Resource private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService; + + @Resource + private TaoBaoOrderService taoBaoOrderService; + + @Resource + private OrderService orderService; /** * 璁㈠崟鍒楄〃 @@ -422,24 +435,60 @@ out.print(JsonUtil.loadFalseResult(1, "鏁版嵁閿欒")); return; } - String orderId = null; + + String[] orders = null; try { - orderId = DESUtil.decode(orderData, StringUtil.getBase64String("YeShiFANLI889*+"), + String orderIds = DESUtil.decode(orderData, StringUtil.getBase64String("YeShiFANLI889*+"), StringUtil.getBase64String("*M#34f?,")); - if (orderId != null && orderId.contains(",")) - orderId = orderId.split(",")[0]; + orders = orderIds.split(","); } catch (Exception e) { e.printStackTrace(); } - if (!StringUtil.isNullOrEmpty(orderId) && orderId.length() > 6) { - orderId = orderId.substring(orderId.length() - 6, orderId.length()); - UserExtraTaoBaoInfo info = userExtraTaoBaoInfoService.getByUid(uid); - if (info != null) { - UserExtraTaoBaoInfo update = new UserExtraTaoBaoInfo(); - update.setId(info.getId()); - update.setTaoBaoOrderEnd6Num(orderId); - userExtraTaoBaoInfoService.updateSelective(update); + if ("findOrder".equalsIgnoreCase(source)) { + // 鍖归厤璁㈠崟 + for (String order : orders) { + if (!StringUtil.isNullOrEmpty(order)) { + List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(order); + if (orderList != null && orderList.size() > 0) { + List<CommonOrder> commonOrderList = commonOrderService + .listBySourceTypeAndOrderId(Constant.SOURCE_TYPE_TAOBAO, order); + if (commonOrderList == null || commonOrderList.size() == 0) { + Order or = new Order(); + or.setBeizhu("浜哄伐鑷姩鎵惧洖琛ュ崟"); + or.setCreatetime(System.currentTimeMillis()); + or.setOrderId(order); + or.setOrderType(1); + or.setState(Order.STATE_YIZHIFU); + or.setUserInfo(new UserInfo(uid)); + or.setVersion(2); + // 鍔犲叆鍒拌鍗曡〃 + boolean isS; + try { + isS = orderService.addOrder(or); + if (isS) { + CMQManager.getInstance().addTaoBaoOrderMsg(order, orderList); + } + } catch (Exception e) { + e.printStackTrace(); + } + } + } + } + } + } else { + String orderId = null; + if (orders != null && orders.length > 0) + orderId = orders[0]; + if (!StringUtil.isNullOrEmpty(orderId) && orderId.length() > 6) { + orderId = orderId.substring(orderId.length() - 6, orderId.length()); + UserExtraTaoBaoInfo info = userExtraTaoBaoInfoService.getByUid(uid); + if (info != null) { + UserExtraTaoBaoInfo update = new UserExtraTaoBaoInfo(); + update.setId(info.getId()); + update.setTaoBaoOrderEnd6Num(orderId); + userExtraTaoBaoInfoService.updateSelective(update); + } } } out.print(JsonUtil.loadTrueResult("")); -- Gitblit v1.8.0