RefundPrice

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

@@ -7,7 +7,6 @@ import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
-import com.liquidnet.service.kylin.dto.param.RefundApplyParam;
 import com.liquidnet.service.kylin.dto.param.RefundCallbackParam;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
@@ -24,12 +23,14 @@ import org.apache.commons.lang.StringUtils;
 import org.bson.Document;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.convert.MongoConverter;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
+import java.util.HashMap;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -66,6 +67,9 @@ public class KylinRefundsStatusServiceImpl {
     @Autowired
     MongoTemplate mongoTemplate;
 
+    @Autowired
+    private MongoConverter mongoConverter;
+
     @Autowired
     private DataUtils dataUtils;
 
@@ -144,12 +148,14 @@ public class KylinRefundsStatusServiceImpl {
                     .eq("is_payment", KylinTableStatusConst.ENTITIES_IS_PAYMENT2)
             );
 
+            HashMap<String, Object> EntitiesVo = new HashMap<>();
+            EntitiesVo.put("updatedAt", DateUtil.getNowTime());
+            EntitiesVo.put("refundPrice", BigDecimal.valueOf(priceNew));
+            EntitiesVo.put("isPayment", isPayment);
+            BasicDBObject EntitiesVov = new BasicDBObject("$set", mongoConverter.convertToMongoType(EntitiesVo));
             UpdateResult updateResult = mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).updateOne(
                 Query.query(Criteria.where("orderTicketEntitiesId").is(entitiesId)).getQueryObject(),
-                new Document("$set", new Document("updatedAt", DateUtil.getNowTime())
-//                        .append("refundPrice", BigDecimal.valueOf(priceNew))
-                        .append("isPayment", isPayment)
-                )
+                    EntitiesVov
             );
 
             dataUtils.delOrderTicketEntitiesRedis(entitiesId);
@@ -167,13 +173,15 @@ public class KylinRefundsStatusServiceImpl {
                         .eq("order_tickets_id", orderTicketsId)
         );
 
+        HashMap<String, Object> orderVo = new HashMap<>();
+        orderVo.put("updatedAt", DateUtil.getNowTime());
+        orderVo.put("priceRefund", BigDecimal.valueOf(price));
+        orderVo.put("status", newStatus);
+        orderVo.put("refundNumber", num);
+        BasicDBObject orderVov = new BasicDBObject("$set", mongoConverter.convertToMongoType(orderVo));
         UpdateResult orderUpdateResult = mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).updateOne(
                 Query.query(Criteria.where("orderTicketsId").is(orderTicketsId)).getQueryObject(),
-                new Document("$set", new Document("updatedAt", DateUtil.getNowTime())
-                        .append("priceRefund", BigDecimal.valueOf(price))
-                        .append("status", newStatus)
-                        .append("refundNumber", num)
-                )
+                orderVov
         );
         dataUtils.delOrderTicketRedis(orderTicketsId);
         mongoVoUtils.resetOrderListVo(orderInfo.getUserId(), 2, orderTicketsId);