|
|
@@ -1,5 +1,6 @@
|
|
|
package org.dromara.order.service.impl;
|
|
|
|
|
|
+import org.apache.dubbo.config.annotation.DubboReference;
|
|
|
import org.dromara.common.core.utils.MapstructUtils;
|
|
|
import org.dromara.common.core.utils.StringUtils;
|
|
|
import org.dromara.common.mybatis.core.page.TableDataInfo;
|
|
|
@@ -8,7 +9,12 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
+import org.dromara.common.mybatis.utils.WrapperUtils;
|
|
|
+import org.dromara.common.satoken.utils.LoginHelper;
|
|
|
+import org.dromara.fulfiller.api.RemoteFulfillerService;
|
|
|
+import org.dromara.order.api.enums.OrderAppealAuditStatusEnum;
|
|
|
import org.dromara.order.domain.SysSubOrder;
|
|
|
+import org.dromara.order.domain.bo.SysSubOrderAppealAuditBo;
|
|
|
import org.dromara.order.mapper.SysSubOrderMapper;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.dromara.order.domain.bo.SysSubOrderAppealBo;
|
|
|
@@ -18,9 +24,7 @@ import org.dromara.order.mapper.SysSubOrderAppealMapper;
|
|
|
import org.dromara.order.service.ISysSubOrderAppealService;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
-import java.util.List;
|
|
|
-import java.util.Map;
|
|
|
-import java.util.Collection;
|
|
|
+import java.util.*;
|
|
|
|
|
|
/**
|
|
|
* 子订单申诉Service业务层处理
|
|
|
@@ -35,6 +39,9 @@ public class SysSubOrderAppealServiceImpl implements ISysSubOrderAppealService {
|
|
|
private final SysSubOrderAppealMapper baseMapper;
|
|
|
private final SysSubOrderMapper subOrderMapper;
|
|
|
|
|
|
+ @DubboReference
|
|
|
+ private final RemoteFulfillerService remoteFulfillerService;
|
|
|
+
|
|
|
/**
|
|
|
* 查询子订单申诉
|
|
|
*/
|
|
|
@@ -70,7 +77,24 @@ public class SysSubOrderAppealServiceImpl implements ISysSubOrderAppealService {
|
|
|
lqw.eq(bo.getService() != null, SysSubOrderAppeal::getService, bo.getService());
|
|
|
lqw.eq(StringUtils.isNotBlank(bo.getPhotos()), SysSubOrderAppeal::getPhotos, bo.getPhotos());
|
|
|
lqw.eq(bo.getFulfillmentCommission() != null, SysSubOrderAppeal::getFulfillmentCommission, bo.getFulfillmentCommission());
|
|
|
+ lqw.eq(bo.getFulfiller() != null, SysSubOrderAppeal::getFulfiller, bo.getFulfiller());
|
|
|
lqw.eq(StringUtils.isNotBlank(bo.getReason()), SysSubOrderAppeal::getReason, bo.getReason());
|
|
|
+ lqw.eq(bo.getAuditStatus() != null, SysSubOrderAppeal::getAuditStatus, bo.getAuditStatus());
|
|
|
+ lqw.eq(StringUtils.isNotBlank(bo.getRejectReason()), SysSubOrderAppeal::getRejectReason, bo.getRejectReason());
|
|
|
+ lqw.eq(bo.getAuditor() != null, SysSubOrderAppeal::getAuditor, bo.getAuditor());
|
|
|
+
|
|
|
+ if (StringUtils.isNotBlank(bo.getOrderCode())) {
|
|
|
+ List<Long> orderIds = new ArrayList<>();
|
|
|
+ subOrderMapper.selectList(Wrappers.lambdaQuery(SysSubOrder.class).select(SysSubOrder::getId)
|
|
|
+ .like(SysSubOrder::getCode, bo.getOrderCode())).forEach(e -> orderIds.add(e.getId()));
|
|
|
+ lqw.in(SysSubOrderAppeal::getOrderId, WrapperUtils.convertIds(orderIds));
|
|
|
+ }
|
|
|
+
|
|
|
+ if (StringUtils.isNotBlank(bo.getFulfillerName())) {
|
|
|
+ List<Long> fulfillerIds = remoteFulfillerService.listIdsByName(bo.getFulfillerName());
|
|
|
+ lqw.in(SysSubOrderAppeal::getFulfiller, WrapperUtils.convertIds(fulfillerIds));
|
|
|
+ }
|
|
|
+
|
|
|
return lqw;
|
|
|
}
|
|
|
|
|
|
@@ -85,6 +109,9 @@ public class SysSubOrderAppealServiceImpl implements ISysSubOrderAppealService {
|
|
|
|
|
|
SysSubOrder subOrder = subOrderMapper.selectById(bo.getOrderId());
|
|
|
|
|
|
+ if (add.getFulfiller() == null) {
|
|
|
+ add.setFulfiller(subOrder.getFulfiller());
|
|
|
+ }
|
|
|
add.setTenantId(subOrder.getTenantId());
|
|
|
boolean appealFlag = baseMapper.insert(add) == 0;
|
|
|
if (appealFlag) {
|
|
|
@@ -127,4 +154,32 @@ public class SysSubOrderAppealServiceImpl implements ISysSubOrderAppealService {
|
|
|
}
|
|
|
return baseMapper.deleteByIds(ids) > 0;
|
|
|
}
|
|
|
+
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ @Override
|
|
|
+ public boolean audit(SysSubOrderAppealAuditBo bo) {
|
|
|
+
|
|
|
+ SysSubOrderAppeal appeal = baseMapper.selectById(bo.getId());
|
|
|
+ appeal.setAuditStatus(bo.getResult());
|
|
|
+ appeal.setAuditor(LoginHelper.getUserId());
|
|
|
+ appeal.setRejectReason(bo.getReason());
|
|
|
+ appeal.setAuditTime(new Date());
|
|
|
+ boolean appealFlag = baseMapper.updateById(appeal) == 0;
|
|
|
+ if (appealFlag) {
|
|
|
+ throw new RuntimeException("修改申诉记录失败");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (OrderAppealAuditStatusEnum.isPass(appeal.getAuditStatus())) {
|
|
|
+ boolean orderFlag = subOrderMapper.update(Wrappers.lambdaUpdate(SysSubOrder.class)
|
|
|
+ .eq(SysSubOrder::getId, appeal.getOrderId())
|
|
|
+ .set(SysSubOrder::getService, appeal.getService())
|
|
|
+ .set(SysSubOrder::getFulfillmentCommission, appeal.getFulfillmentCommission())
|
|
|
+ .set(SysSubOrder::getServiceFlag, true)) == 0;
|
|
|
+ if (orderFlag) {
|
|
|
+ throw new RuntimeException("修改订单失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return true;
|
|
|
+ }
|
|
|
}
|