overtime

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/refund/OrderRefundsCallbackServiceImpl.java

@@ -76,6 +76,9 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
     @Autowired
     private DataUtils dataUtils;
 
+    @Autowired
+    private TaobaoTicketUtils taobaoTicketUtils;
+
     public String refundCallback(RefundCallbackParam refundCallbackParam) {
         log.info("refundCallback订单退款回调参数: [RefundCallbackParam={}]", refundCallbackParam);
         KylinOrderRefunds refundInfo = kylinOrderRefundsMapper.selectOne(
@@ -221,6 +224,8 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
             dataUtils.delOrderRefundVo(refundId);
             dataUtils.delOrderRefundVoByOrderId(orderId);
 
+
+
             KylinOrderTickets oderInfo = kylinOrderTicketsMapper.selectOne(
                     Wrappers.lambdaQuery(KylinOrderTickets.class)
                             .eq(KylinOrderTickets::getOrderTicketsId, orderId)
@@ -262,17 +267,27 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
                     // 修改缓存
                     KylinOrderRefundsVo kylinOrderRefundsVoFail = new KylinOrderRefundsVo();
                     BeanUtils.copyProperties(kylinOrderRefundsFail, kylinOrderRefundsVoFail);
-                    BasicDBObject objectFail = new BasicDBObject("$set", mongoConverter.convertToMongoType(kylinOrderRefundsVoFail));
+                    /*BasicDBObject objectFail = new BasicDBObject("$set", mongoConverter.convertToMongoType(kylinOrderRefundsVoFail));
                     UpdateResult updateFailResult = mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateOne(
                             Query.query(Criteria.where("orderRefundsId").is(refundId)).getQueryObject(),
                             objectFail
+                    );*/
+                    UpdateResult failResult = mongoTemplate.updateFirst(
+                            Query.query(Criteria.where("orderRefundsId").is(refundId)),
+                            Update.fromDocument(Document.parse(JsonUtils.toJson(kylinOrderRefundsVoFail))),
+                            KylinOrderRefundsVo.class, KylinOrderRefundsVo.class.getSimpleName()
                     );
-//                    List<String> strings = Arrays.asList(refund.getOrderRefundsId());
-//                    List<String> strings1 = Arrays.asList(refund.getOrderTicketsId());
-//                    dataUtils.delOrderRefundVo(strings);
-//                    dataUtils.delOrderRefundVoByOrderId(strings1);
+                    dataUtils.delOrderRefundVo(refundId);
+                    dataUtils.delOrderRefundVoByOrderId(orderId);
 
                     continue;
+                } else {
+                    //TODO 秀龙 大麦退款
+                    for (KylinOrderRefunds item : refundList) {
+                        KylinOrderTicketVo orderData = dataUtils.getOrderTicketVo(item.getOrderTicketsId());
+                        KylinPerformanceVo vo = dataUtils.getPerformanceVo(orderData.getPerformanceId());
+                        taobaoTicketUtils.refundDamaiOrder(orderData,vo);
+                    }
                 }
             } catch (Exception e) {
                 log.info("退款请求pay失败e" + e.getMessage());