判断是否可退款判断

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/KylinOrderTicketsController.java

@@ -115,7 +115,7 @@ public class KylinOrderTicketsController {
     @ApiResponse(code = 200, message = "接口返回对象参数")
     public ResponseDto<OrderRefundVo> orderRefundDetails(@RequestParam(value = "orderId", required = true) @NotNull(message = "订单id不能为空") String orderId,
                                                          @RequestParam(value = "orderRefundId", required = true) @NotNull(message = "退款订单id不能为空") String orderRefundId) {
-        return ResponseDto.success(orderTicketsService.orderRefundDetails(orderId, orderRefundId));
+        return orderTicketsService.orderRefundDetails(orderId, orderRefundId)==null?ResponseDto.failure("获取失败"):ResponseDto.success(orderTicketsService.orderRefundDetails(orderId, orderRefundId));
     }
 
     @PostMapping("orderRefundWithdraw")

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketsServiceImpl.java

@@ -36,6 +36,7 @@ import com.taobao.api.response.AlibabaDamaiMevOpenBatchpushticketResponse;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
 import org.apache.commons.lang.time.DateUtils;
+import org.bson.Document;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -849,7 +850,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
             log.info(UserPathDto.setData("订单支付成功回调", syncOrderParam, ""));
             return "success";
         } catch (Exception e) {
-            log.error("SYNCE ORDER E = "+e.getMessage());
+            log.error("SYNCE ORDER E = " + e.getMessage());
             e.printStackTrace();
             return "fail";
         }
@@ -1121,19 +1122,23 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
 
     @Override
     public OrderRefundVo orderRefundDetails(String orderId, String orderRefundId) {
-        OrderRefundVo vo = new OrderRefundVo();
-        String uid = CurrentUtil.getCurrentUid();
-        KylinOrderTicketVo orderTicketVo = dataUtils.getOrderTicketVo(orderId);
-        KylinPerformanceVo performanceVo = dataUtils.getPerformanceVo(orderTicketVo.getPerformanceId());
+        try {
+            OrderRefundVo vo = new OrderRefundVo();
+            String uid = CurrentUtil.getCurrentUid();
+            KylinOrderTicketVo orderTicketVo = dataUtils.getOrderTicketVo(orderId);
+            KylinPerformanceVo performanceVo = dataUtils.getPerformanceVo(orderTicketVo.getPerformanceId());
 
-        if (!orderTicketVo.getUserId().equals(uid)) {
+            if (!orderTicketVo.getUserId().equals(uid)) {
+                return null;
+            }
+            orderTicketVo.setFieldName(performanceVo.getFieldName());
+            KylinOrderRefundsVo kylinOrderRefundsVoBase = dataUtils.getOrderRefundVo(orderRefundId);
+            vo.setKylinOrderRefundsVoBaseList(kylinOrderRefundsVoBase);
+            vo.setOrderTicketVo(orderTicketVo);
+            return vo;
+        } catch (Exception e) {
             return null;
         }
-        orderTicketVo.setFieldName(performanceVo.getFieldName());
-        KylinOrderRefundsVo kylinOrderRefundsVoBase = dataUtils.getOrderRefundVo(orderRefundId);
-        vo.setKylinOrderRefundsVoBaseList(kylinOrderRefundsVoBase);
-        vo.setOrderTicketVo(orderTicketVo);
-        return vo;
     }
 
     @Override
@@ -1295,17 +1300,13 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
             kylinOrderRefunds.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL);
             kylinOrderRefunds.setUpdatedAt(LocalDateTime.now());
 
-            KylinOrderRefundsVo orderRefundsVoBase = new KylinOrderRefundsVo();
-            orderRefundsVoBase.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL);
-            orderRefundsVoBase.setUpdatedAt(time);
-            BasicDBObject refundObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(orderRefundsVoBase)));
             mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateOne(
                     Query.query(Criteria.where("orderRefundsId").is(orderRefundsId)).getQueryObject(),
-                    refundObject
+                    new Document("$set", new Document("status", KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL).append("updatedAt", time))
             );
 
             sqlsDataC.add(new Object[]{
-                    orderRefundsVoBase.getStatus(), orderRefundsVoBase.getUpdatedAt(), orderRefundsId
+                    KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL, time, orderRefundsId
             });
 
             dataUtils.delOrderRefundVo(orderRefundsId);