callback 修改订单数据

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

@@ -7,7 +7,6 @@ import com.fasterxml.jackson.databind.JsonNode;
 import com.liquidnet.commons.lang.util.HttpUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.commons.lang.util.JsonUtils;
-import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
 import com.liquidnet.service.kylin.dto.param.RefundCallbackParam;
 import com.liquidnet.service.kylin.dto.vo.KylinOrderTicketEntitiesVo;
@@ -31,9 +30,7 @@ import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
-import sun.security.krb5.internal.Ticket;
 
-import java.awt.print.Book;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.HashMap;
@@ -430,7 +427,7 @@ public class KylinRefundsStatusServiceImpl {
         // 更新数据
         // 订单状态表
         KylinOrderTickets orderInfo = kylinOrderTicketsMapper.selectOne(
-                new UpdateWrapper<KylinOrderTickets>().eq("order_tickets_id", orderTicketsId)
+                new QueryWrapper<KylinOrderTickets>().eq("order_tickets_id", orderTicketsId)
         );
         KylinOrderTicketStatus orderStatusTable = new KylinOrderTicketStatus();
         int newStatus = 0;
@@ -440,8 +437,6 @@ public class KylinRefundsStatusServiceImpl {
             newStatus = KylinTableStatusConst.ORDER_STATUS6;
         }
         orderStatusTable.setStatus(newStatus);
-        kylinOrderTicketStatusMapper.update(orderStatusTable, new UpdateWrapper<KylinOrderTicketStatus>()
-                .eq("order_ticket_status_id", orderTicketsId));
 
         KylinOrderTicketVo kylinOrderTicketVo = new KylinOrderTicketVo();
         kylinOrderTicketVo.setStatus(newStatus);
@@ -453,6 +448,25 @@ public class KylinRefundsStatusServiceImpl {
         );
         dataUtils.delOrderTicketRedis(orderTicketsId);
 
+        // 订单表
+        double price = orderInfo.getPriceRefund().doubleValue() + refundInfo.getPrice().doubleValue();
+        Integer num = orderInfo.getRefundNumber() + EntitiesIdsCount;
+        KylinOrderTickets update = new KylinOrderTickets();
+        update.setRefundNumber(num);
+        update.setPriceRefund(BigDecimal.valueOf(price));
+        kylinOrderTicketsMapper.update(
+                update, new UpdateWrapper<KylinOrderTickets>()
+                .eq("order_tickets_id", orderTicketsId)
+        );
+        KylinOrderTicketVo kylinOrderTicketVoOrder = new KylinOrderTicketVo();
+        kylinOrderTicketVoOrder.setRefundNumber(num);
+        kylinOrderTicketVoOrder.setPriceRefund(BigDecimal.valueOf(price));
+        BasicDBObject orderEntitiesObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketVoOrder)));
+        Document entitiesDocOrder = mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).findOneAndUpdate(
+                Query.query(Criteria.where("orderTicketsId").is(orderTicketsId)).getQueryObject(),
+                orderEntitiesObject,
+                new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)
+        );
 
         // 入场人
         for (String entitiesId : orderTicketEntitiesIdsArr) {