From acccff9860b271d55c55dc87486f7c20b9896e6c Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期一, 13 一月 2025 16:19:54 +0800
Subject: [PATCH] 修改bug
---
ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java | 233 ++++++++++++++++++++++++++++++++++-----------------------
1 files changed, 138 insertions(+), 95 deletions(-)
diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java
index 6153bb3..45a70ba 100644
--- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java
+++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java
@@ -22,14 +22,12 @@
import com.ruoyi.order.model.OrderBalancePayment;
import com.ruoyi.order.model.OrderGood;
import com.ruoyi.order.model.RefundPass;
-import com.ruoyi.order.service.CommissionService;
-import com.ruoyi.order.service.OrderBalancePaymentService;
-import com.ruoyi.order.service.OrderService;
-import com.ruoyi.order.service.RefundPassService;
+import com.ruoyi.order.service.*;
import com.ruoyi.order.util.ExpressDeliveryUtil;
import com.ruoyi.order.util.payment.PaymentUtil;
import com.ruoyi.order.util.payment.model.RefundCallbackResult;
import com.ruoyi.order.util.payment.model.RefundResult;
+import com.ruoyi.order.util.vo.MapTrackKD100Vo;
import com.ruoyi.order.util.vo.QueryKD100Vo;
import com.ruoyi.order.vo.*;
import com.ruoyi.other.api.domain.*;
@@ -37,6 +35,7 @@
import com.ruoyi.system.api.domain.SysUser;
import com.ruoyi.system.api.feignClient.SysUserClient;
import com.ruoyi.system.api.model.LoginUser;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -44,6 +43,7 @@
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.LocalDateTime;
+import java.time.ZoneOffset;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.stream.Collectors;
@@ -98,6 +98,16 @@
@Resource
private RefundPassService refundPassService;
+ @Resource
+ private TechnicianSubscribeClient technicianSubscribeClient;
+ @Resource
+ private ShopBalanceStatementClient shopBalanceStatementClient;
+
+ @Resource
+ private RedisTemplate redisTemplate;
+
+ @Resource
+ private SystemConfigClient systemConfigClient;
@@ -135,8 +145,8 @@
orderGoodsVO.setGoodsName(goods.getName());
orderGoodsVO.setType(goods.getType());
orderGoodsVO.setGoodsPic(goods.getHomePagePicture());
- orderGoodsVO.setSellingPrice(goods.getSellingPrice());
- orderGoodsVO.setIntegral(goods.getIntegral());
+ orderGoodsVO.setSellingPrice(orderGood.getSellingPrice());
+ orderGoodsVO.setIntegral(orderGood.getIntegral());
orderGoodsVO.setOriginalPrice(goods.getOriginalPrice());
goodsList.add(orderGoodsVO);
}
@@ -256,6 +266,7 @@
order.setIsCommission(0);
order.setAfterSaleTime(LocalDateTime.now().plusDays(days));
order.setEndTime(LocalDateTime.now());
+ order.setCancellerAppUserId(loginUserApplet.getUserid());
orderMapper.updateById(order);
}
@@ -440,6 +451,45 @@
balanceChangeRecord.setDelFlag(0);
balanceChangeRecord.setCreateTime(LocalDateTime.now());
balanceChangeRecordClient.saveBalanceChangeRecord(balanceChangeRecord);
+
+ //退回获得的消费积分
+ //需要先检查会员等级时候回回退，使用回退后的会员等级查询配置
+ Integer lavePoint = appUser.getLavePoint();
+
+ UserPoint userPoint1 = new UserPoint();
+ userPoint1.setType(1);
+ userPoint1.setAppUserId(appUser.getId());
+ userPoint1.setObjectId(order.getId());
+ UserPoint userPoint2 = userPointClient.getUserPointList(userPoint1).getData().get(0);
+ JSONObject jsonObject = JSON.parseObject(userPoint2.getExtention());
+ Integer shopPoint = jsonObject.getInteger("shopPoint");
+ Integer availablePoint = jsonObject.getInteger("availablePoint");
+ Integer transferablePoint = jsonObject.getInteger("transferablePoint");
+ appUser.setShopPoint(appUser.getShopPoint() - shopPoint);
+ appUser.setLavePoint(appUser.getLavePoint() - shopPoint);
+ appUser.setAvailablePoint(appUser.getAvailablePoint() - availablePoint);
+ appUser.setTotalAvailablePoint(appUser.getTotalAvailablePoint() - availablePoint);
+ if(null != transferablePoint){
+ appUser.setTransferablePoint(appUser.getTransferablePoint() - transferablePoint);
+ }
+ appUser.setTotalPoint(appUser.getTotalPoint() - shopPoint);
+
+ boolean vipDemotion = vipDemotion(appUser.getShopPoint(), appUser.getVipId());
+ if(vipDemotion){
+ appUser.setVipId(appUser.getVipId() - 1);
+ }
+
+ //构建积分流水明细
+ UserPoint userPoint = new UserPoint();
+ userPoint.setType(1);
+ userPoint.setHistoricalPoint(lavePoint);
+ userPoint.setVariablePoint(shopPoint);
+ userPoint.setBalance(appUser.getLavePoint());
+ userPoint.setCreateTime(LocalDateTime.now());
+ userPoint.setAppUserId(order.getAppUserId());
+ userPoint.setObjectId(order.getId());
+ userPointClient.saveUserPoint(userPoint);
+ appUserClient.editAppUserById(appUser);
}
if(3 == payMethod){
//开始运费退款，积分支付，运费是单独进行支付的，所以需要单独退款
@@ -504,39 +554,6 @@
userPoint.setObjectId(order.getId());
userPointClient.saveUserPoint(userPoint);
}
- //退回获得的消费积分
- //需要先检查会员等级时候回回退，使用回退后的会员等级查询配置
- Integer lavePoint = appUser.getLavePoint();
- Integer getPoint = order.getGetPoint();
- boolean vipDemotion = vipDemotion(appUser.getShopPoint() - getPoint, appUser.getVipId());
- PointSetting pointSetting = pointSettingClient.getPointSetting(vipDemotion ? appUser.getVipId() - 1 : appUser.getVipId()).getData();
- int earnPoint1 = 0;
- if(null != pointSetting && 1 == pointSetting.getBuyPointOpen()){
- earnPoint1 = new BigDecimal(getPoint).divide(pointSetting.getBuyPoint().divide(new BigDecimal(100))).intValue();
- }
- appUser.setShopPoint(appUser.getShopPoint() - getPoint);
- appUser.setLavePoint(appUser.getLavePoint() - getPoint);
- appUser.setAvailablePoint(appUser.getAvailablePoint() - earnPoint1);
- appUser.setTotalAvailablePoint(appUser.getTotalAvailablePoint() - earnPoint1);
- if(null != pointSetting && 1 == pointSetting.getBuyPointGift()){
- appUser.setTransferablePoint(appUser.getTransferablePoint() - earnPoint1);
- }
- appUser.setTotalPoint(appUser.getTotalPoint() - getPoint);
- if(vipDemotion){
- appUser.setVipId(appUser.getVipId() - 1);
- }
-
- //构建积分流水明细
- UserPoint userPoint = new UserPoint();
- userPoint.setType(1);
- userPoint.setHistoricalPoint(lavePoint);
- userPoint.setVariablePoint(getPoint);
- userPoint.setBalance(appUser.getLavePoint());
- userPoint.setCreateTime(LocalDateTime.now());
- userPoint.setAppUserId(order.getAppUserId());
- userPoint.setObjectId(order.getId());
- userPointClient.saveUserPoint(userPoint);
- appUserClient.editAppUserById(appUser);
order.setRefundStatus(2);
order.setRefundTime(LocalDateTime.now());
@@ -559,26 +576,29 @@
order.setRefundStatus(2);
order.setRefundTime(LocalDateTime.now());
this.updateById(order);
-
//退回获得的消费积分
//需要先检查会员等级时候回回退，使用回退后的会员等级查询配置
AppUser appUser = appUserClient.getAppUserById(order.getAppUserId());
Integer lavePoint = appUser.getLavePoint();
- Integer getPoint = order.getGetPoint();
- boolean vipDemotion = vipDemotion(appUser.getShopPoint() - getPoint, appUser.getVipId());
- PointSetting pointSetting = pointSettingClient.getPointSetting(vipDemotion ? appUser.getVipId() - 1 : appUser.getVipId()).getData();
- int earnPoint1 = 0;
- if(null != pointSetting && 1 == pointSetting.getBuyPointOpen()){
- earnPoint1 = new BigDecimal(getPoint).divide(pointSetting.getBuyPoint().divide(new BigDecimal(100))).intValue();
+ UserPoint userPoint1 = new UserPoint();
+ userPoint1.setType(1);
+ userPoint1.setAppUserId(appUser.getId());
+ userPoint1.setObjectId(order.getId());
+ UserPoint userPoint2 = userPointClient.getUserPointList(userPoint1).getData().get(0);
+ JSONObject jsonObject = JSON.parseObject(userPoint2.getExtention());
+ Integer shopPoint = jsonObject.getInteger("shopPoint");
+ Integer availablePoint = jsonObject.getInteger("availablePoint");
+ Integer transferablePoint = jsonObject.getInteger("transferablePoint");
+ appUser.setShopPoint(appUser.getShopPoint() - shopPoint);
+ appUser.setLavePoint(appUser.getLavePoint() - shopPoint);
+ appUser.setAvailablePoint(appUser.getAvailablePoint() - availablePoint);
+ appUser.setTotalAvailablePoint(appUser.getTotalAvailablePoint() - availablePoint);
+ if(null != transferablePoint){
+ appUser.setTransferablePoint(appUser.getTransferablePoint() - transferablePoint);
}
- appUser.setShopPoint(appUser.getShopPoint() - getPoint);
- appUser.setLavePoint(appUser.getLavePoint() - getPoint);
- appUser.setAvailablePoint(appUser.getAvailablePoint() - earnPoint1);
- appUser.setTotalAvailablePoint(appUser.getTotalAvailablePoint() - earnPoint1);
- if(null != pointSetting && 1 == pointSetting.getBuyPointGift()){
- appUser.setTransferablePoint(appUser.getTransferablePoint() - earnPoint1);
- }
- appUser.setTotalPoint(appUser.getTotalPoint() - getPoint);
+ appUser.setTotalPoint(appUser.getTotalPoint() - shopPoint);
+
+ boolean vipDemotion = vipDemotion(appUser.getShopPoint(), appUser.getVipId());
if(vipDemotion){
appUser.setVipId(appUser.getVipId() - 1);
}
@@ -587,7 +607,7 @@
UserPoint userPoint = new UserPoint();
userPoint.setType(1);
userPoint.setHistoricalPoint(lavePoint);
- userPoint.setVariablePoint(getPoint);
+ userPoint.setVariablePoint(shopPoint);
userPoint.setBalance(appUser.getLavePoint());
userPoint.setCreateTime(LocalDateTime.now());
userPoint.setAppUserId(order.getAppUserId());
@@ -640,44 +660,7 @@
userPoint.setAppUserId(order.getAppUserId());
userPoint.setObjectId(order.getId());
userPointClient.saveUserPoint(userPoint);
-
- //退回获得的消费积分
- //需要先检查会员等级时候回回退，使用回退后的会员等级查询配置
- lavePoint = appUser.getLavePoint();
- Integer getPoint = order.getGetPoint();
- boolean vipDemotion = vipDemotion(appUser.getShopPoint() - getPoint, appUser.getVipId());
- PointSetting pointSetting = pointSettingClient.getPointSetting(vipDemotion ? appUser.getVipId() - 1 : appUser.getVipId()).getData();
- int earnPoint1 = 0;
- if(null != pointSetting && 1 == pointSetting.getBuyPointOpen()){
- earnPoint1 = new BigDecimal(getPoint).divide(pointSetting.getBuyPoint().divide(new BigDecimal(100))).intValue();
- }
- appUser.setShopPoint(appUser.getShopPoint() - getPoint);
- appUser.setLavePoint(appUser.getLavePoint() - getPoint);
- appUser.setAvailablePoint(appUser.getAvailablePoint() - earnPoint1);
- appUser.setTotalAvailablePoint(appUser.getTotalAvailablePoint() - earnPoint1);
- if(null != pointSetting && 1 == pointSetting.getBuyPointGift()){
- appUser.setTransferablePoint(appUser.getTransferablePoint() - earnPoint1);
- }
- appUser.setTotalPoint(appUser.getTotalPoint() - getPoint);
- if(vipDemotion){
- appUser.setVipId(appUser.getVipId() - 1);
- }
-
- //构建积分流水明细
- userPoint = new UserPoint();
- userPoint.setType(1);
- userPoint.setHistoricalPoint(lavePoint);
- userPoint.setVariablePoint(getPoint);
- userPoint.setBalance(appUser.getLavePoint());
- userPoint.setCreateTime(LocalDateTime.now());
- userPoint.setAppUserId(order.getAppUserId());
- userPoint.setObjectId(order.getId());
- userPointClient.saveUserPoint(userPoint);
- appUserClient.editAppUserById(appUser);
-
- order.setRefundStatus(2);
- order.setRefundTime(LocalDateTime.now());
- return null;
+ return R.ok();
}
/**
@@ -755,13 +738,13 @@
orderInfo.setDiscountAmount(order.getDiscountTotalAmount());
orderInfo.setExpressAmount(order.getExpressAmount());
orderInfo.setPaymentAmount(order.getPaymentAmount());
- orderInfo.setPoint(order.getGetPoint());
+ orderInfo.setGetPoint(order.getGetPoint());
if(StringUtils.isNotEmpty(order.getAddressJson())){
UserAddress userAddress = JSON.parseObject(order.getAddressJson(), UserAddress.class);
orderInfo.setRecipient(userAddress.getRecieveName() + "-" + userAddress.getRecievePhone());
orderInfo.setAddress(userAddress.getRecieveAddress());
}
- if(StringUtils.isNotEmpty(order.getExpressJson())){
+ if(StringUtils.isNotEmpty(order.getExpressJson()) && !"NULL".equals(order.getExpressJson())){
JSONObject jsonObject = JSON.parseObject(order.getExpressJson());
String com = jsonObject.getString("com");
String num = jsonObject.getString("num");
@@ -781,6 +764,30 @@
goodsJson.add(map);
}
orderInfo.setGoodsJson(JSON.toJSONString(goodsJson));
+ orderInfo.setPoint(order.getPoint());
+ if(null != order.getAfterSaleTime()){
+ orderInfo.setAfterSaleTime(order.getAfterSaleTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+ }
+ if(StringUtils.isNotEmpty(order.getActivityJson())){
+ OrderActivityInfo activityInfo = JSON.parseObject(order.getActivityJson(), OrderActivityInfo.class);
+ orderInfo.setActivityName(activityInfo.getActivityName());
+ }
+ if(null != order.getEndTime()){
+ AppUser user = appUserClient.getAppUserById(order.getCancellerAppUserId());
+ orderInfo.setCanceller(user.getName());
+ orderInfo.setWriteOffTime(order.getEndTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+ }
+ if(order.getOrderType() == 1){
+ List<TechnicianSubscribe> technicianSubscribes = technicianSubscribeClient.getTechnicianSubscribeList(order.getId()).getData();
+ if(technicianSubscribes.size() > 0){
+ Set<Integer> collect = technicianSubscribes.stream().map(TechnicianSubscribe::getTechnicianId).collect(Collectors.toSet());
+ List<Technician> data = technicianClient.getTechnicianByIds(collect).getData();
+ orderInfo.setTechnicianName(data.stream().map(Technician::getName).collect(Collectors.joining(",")));
+ }
+ }
+ List<ShopBalanceStatement> data = shopBalanceStatementClient.getShopBalanceStatementList(Arrays.asList(1, 2, 3), order.getId()).getData();
+ BigDecimal reduce = data.stream().map(ShopBalanceStatement::getVariableAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
+ orderInfo.setSubcommission(reduce);
return orderInfo;
}
@@ -806,4 +813,40 @@
public Integer getShopSaleNum(Integer shopId, Integer type) {
return this.baseMapper.getShopSaleNum(shopId, type);
}
+
+
+ /**
+ * 定时查询快递信息
+ */
+ @Override
+ public void taskExpress() {
+ Set<Long> order_express = redisTemplate.opsForZSet().rangeByScore("order_express", 0, LocalDateTime.now().toEpochSecond(ZoneOffset.UTC));
+ if(order_express.size() > 0){
+ for (Long id : order_express) {
+ Order order = this.getById(id);
+ if(order.getOrderStatus() != 2){
+ redisTemplate.opsForZSet().remove("order_express", id);
+ continue;
+ }
+ String expressJson = order.getExpressJson();
+ if(StringUtils.isEmpty(expressJson)){
+ redisTemplate.opsForZSet().remove("order_express", id);
+ continue;
+ }
+ //{"com":"jd","num":"JDV016336234367"}
+ JSONObject jsonObject = JSON.parseObject(expressJson);
+ String com = jsonObject.getString("com");
+ String num = jsonObject.getString("num");
+ UserAddress userAddress = JSON.parseObject(order.getAddressJson(), UserAddress.class);
+ MapTrackKD100Vo mapTrackKD100Vo = ExpressDeliveryUtil.kd100MapTrack(com, num, "", userAddress.getRecieveAddress());
+ order.setExpressResult(JSON.toJSONString(mapTrackKD100Vo));
+ this.updateById(order);
+ //延长时间x小时
+ SystemConfig systemConfig = systemConfigClient.getSystemConfig(3).getData();
+ JSONObject jsonObject1 = JSON.parseObject(systemConfig.getContent());
+ Integer waitTime = jsonObject1.getInteger("waitTime");
+ redisTemplate.opsForZSet().add("order_express", order.getId(), LocalDateTime.now().plusHours(waitTime).toEpochSecond(ZoneOffset.UTC));
+ }
+ }
+ }
}
--
Gitblit v1.7.1