后台退款流程 updateAt更新 增加退款vo mongo

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinOrderRefundsServiceImpl.java

@@ -194,7 +194,6 @@ public class KylinOrderRefundsServiceImpl extends ServiceImpl<KylinOrderRefundsM
                 ticketEntityIds, realRefundPriceList
         );
 
-//        KylinOrderTicketVo vo = new KylinOrderTicketVo();
         HashMap<String,Object> map = new HashMap<>();
         map.put("isHaveRefundDetails",1);
         BasicDBObject obj = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));

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

@@ -8,11 +8,14 @@ import com.liquidnet.client.admin.common.utils.StringUtils;
 import com.liquidnet.client.admin.zhengzai.kylin.utils.DataUtils;
 import com.liquidnet.client.admin.zhengzai.kylin.utils.MongoVoUtils;
 import com.liquidnet.commons.lang.util.*;
+import com.liquidnet.service.base.UserPathDto;
 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.KylinOrderRefundEntitiesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
+import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderRefundsVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
 import com.mongodb.BasicDBObject;
@@ -21,6 +24,7 @@ import com.mongodb.client.model.ReturnDocument;
 import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
 import org.bson.Document;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.mongodb.core.MongoTemplate;
@@ -105,11 +109,13 @@ public class KylinRefundsStatusServiceImpl {
         // 订单状态表 和 缓存
         KylinOrderTicketStatus orderStatusTable = new KylinOrderTicketStatus();
         orderStatusTable.setStatus(KylinTableStatusConst.ORDER_STATUS3);
+        orderStatusTable.setUpdatedAt(LocalDateTime.now());
         kylinOrderTicketStatusMapper.update(orderStatusTable, new UpdateWrapper<KylinOrderTicketStatus>()
                 .eq("order_id", orderTicketsId));
 
         KylinOrderTicketVo kylinOrderTicketVo = new KylinOrderTicketVo();
         kylinOrderTicketVo.setStatus(KylinTableStatusConst.ORDER_STATUS3);
+        kylinOrderTicketVo.setUpdatedAt(DateUtil.getNowTime());
         BasicDBObject orderObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketVo)));
         Document orderDoc = mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).findOneAndUpdate(
                 Query.query(Criteria.where("orderTicketsId").is(orderTicketsId)).getQueryObject(),
@@ -124,11 +130,13 @@ public class KylinRefundsStatusServiceImpl {
         for (String v : ticketEntityIds) {
             KylinOrderTicketEntities entitiesTable = new KylinOrderTicketEntities();
             entitiesTable.setIsPayment(KylinTableStatusConst.ENTITIES_IS_PAYMENT2);
+            entitiesTable.setUpdatedAt(LocalDateTime.now());
             kylinOrderTicketEntitiesMapper.update(entitiesTable, new UpdateWrapper<KylinOrderTicketEntities>()
                     .eq("order_ticket_entities_id", v));
 
             KylinOrderTicketEntitiesVo kylinOrderTicketEntitiesVo = new KylinOrderTicketEntitiesVo();
             kylinOrderTicketEntitiesVo.setIsPayment(KylinTableStatusConst.ENTITIES_IS_PAYMENT2);
+            kylinOrderTicketEntitiesVo.setUpdatedAt(DateUtil.getNowTime());
             BasicDBObject entitiesObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketEntitiesVo)));
             Document entitiesDoc = mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).findOneAndUpdate(
                     Query.query(Criteria.where("orderTicketEntitiesId").is(v)).getQueryObject(),
@@ -172,6 +180,10 @@ public class KylinRefundsStatusServiceImpl {
         }
         kylinOrderRefunds.setCreatedAt(LocalDateTime.now());
         int rows = kylinOrderRefundsMapper.insert(kylinOrderRefunds);
+        // 添加缓存
+        KylinOrderRefundsVo kylinOrderRefundsVo = new KylinOrderRefundsVo();
+        BeanUtils.copyProperties(kylinOrderRefunds, kylinOrderRefundsVo);
+        mongoTemplate.insert(kylinOrderRefundsVo, KylinOrderRefundsVo.class.getSimpleName());
 
         // 退款入场人表
         KylinOrderRefundEntities kylinOrderRefundEntities = new KylinOrderRefundEntities();
@@ -183,6 +195,10 @@ public class KylinRefundsStatusServiceImpl {
             kylinOrderRefundEntities.setOrderTicketEntitiesId(ticketEntityIds.get(i));
             kylinOrderRefundEntities.setCreatedAt(LocalDateTime.now());
             int rowsR = kylinOrderRefundsEntitiesMapper.insert(kylinOrderRefundEntities);
+            // 添加缓存
+            KylinOrderRefundEntitiesVo kylinOrderRefundEntitiesVo = new KylinOrderRefundEntitiesVo();
+            BeanUtils.copyProperties(kylinOrderRefundEntities, kylinOrderRefundEntitiesVo);
+            mongoTemplate.insert(kylinOrderRefundEntitiesVo, KylinOrderRefundEntitiesVo.class.getSimpleName());
         }
 
         return true;
@@ -222,11 +238,13 @@ public class KylinRefundsStatusServiceImpl {
 
             KylinOrderTicketStatus orderStatusTable = new KylinOrderTicketStatus();
             orderStatusTable.setStatus(newStatus);
+            orderStatusTable.setUpdatedAt(LocalDateTime.now());
             kylinOrderTicketStatusMapper.update(orderStatusTable, new UpdateWrapper<KylinOrderTicketStatus>()
                     .eq("order_id", orderTicketsId));
 
             KylinOrderTicketVo kylinOrderTicketVo = new KylinOrderTicketVo();
             kylinOrderTicketVo.setStatus(newStatus);
+            kylinOrderTicketVo.setUpdatedAt(DateUtil.getNowTime());
             BasicDBObject orderObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketVo)));
             Document orderDoc = mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).findOneAndUpdate(
                     Query.query(Criteria.where("orderTicketsId").is(orderTicketsId)).getQueryObject(),
@@ -258,6 +276,7 @@ public class KylinRefundsStatusServiceImpl {
                 }
                 KylinOrderTicketEntities entitiesTable = new KylinOrderTicketEntities();
                 entitiesTable.setIsPayment(newIsPayment);
+                entitiesTable.setUpdatedAt(LocalDateTime.now());
                 kylinOrderTicketEntitiesMapper.update(entitiesTable, new UpdateWrapper<KylinOrderTicketEntities>()
                         .eq("order_ticket_entities_id", entitiesId)
                         .eq("is_payment", KylinTableStatusConst.ENTITIES_IS_PAYMENT2)
@@ -265,6 +284,7 @@ public class KylinRefundsStatusServiceImpl {
 
                 KylinOrderTicketEntitiesVo kylinOrderTicketEntitiesVo = new KylinOrderTicketEntitiesVo();
                 kylinOrderTicketEntitiesVo.setIsPayment(newIsPayment);
+                kylinOrderTicketEntitiesVo.setUpdatedAt(DateUtil.getNowTime());
                 BasicDBObject entitiesObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketEntitiesVo)));
                 Document entitiesDoc = mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).findOneAndUpdate(
                         Query.query(Criteria.where("orderTicketEntitiesId").is(entitiesId)).getQueryObject(),
@@ -281,6 +301,15 @@ public class KylinRefundsStatusServiceImpl {
             kylinOrderRefunds.setUpdatedAt(LocalDateTime.now());
             kylinOrderRefundsMapper.update(kylinOrderRefunds, new UpdateWrapper<KylinOrderRefunds>()
                     .eq("order_refunds_id", orderRefundsId));
+            // 修改缓存
+            KylinOrderRefundsVo kylinOrderRefundsVo = new KylinOrderRefundsVo();
+            kylinOrderRefundsVo.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL);
+            kylinOrderRefundsVo.setUpdatedAt(LocalDateTime.now());
+            BasicDBObject object = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderRefundsVo)));
+            UpdateResult updateResult = mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateOne(
+                    Query.query(Criteria.where("orderRefundsId").is(orderRefundsId)).getQueryObject(),
+                    object
+            );
 
         }
         return true;
@@ -321,6 +350,7 @@ public class KylinRefundsStatusServiceImpl {
                 break;
         }
 
+        kylinOrderRefunds.setUpdatedAt(LocalDateTime.now());
         List<String> orderRefundIds = refundList.stream().map(
                 KylinOrderRefunds -> KylinOrderRefunds.getOrderRefundsId()).collect(Collectors.toList()
         );
@@ -328,6 +358,14 @@ public class KylinRefundsStatusServiceImpl {
                 kylinOrderRefunds,
                 new UpdateWrapper<KylinOrderRefunds>().in("order_refunds_id", orderRefundIds)
         );
+        // 修改缓存
+        KylinOrderRefundsVo kylinOrderRefundsVo = new KylinOrderRefundsVo();
+        BeanUtils.copyProperties(kylinOrderRefunds, kylinOrderRefundsVo);
+        BasicDBObject object = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderRefundsVo)));
+        UpdateResult updateResult = mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateOne(
+                Query.query(Criteria.where("orderRefundsId").in(orderRefundIds)).getQueryObject(),
+                object
+        );
 
         return true;
     }
@@ -342,6 +380,7 @@ public class KylinRefundsStatusServiceImpl {
         kylinOrderRefunds.setExecutorName(authName);
         kylinOrderRefunds.setExecutorAt(LocalDateTime.now());
         kylinOrderRefunds.setRefuse(refuse);
+        kylinOrderRefunds.setUpdatedAt(LocalDateTime.now());
 
         for (KylinOrderRefunds refund : refundList) {
             KylinOrderTickets oderInfo = kylinOrderTicketsMapper.selectOne(
@@ -368,7 +407,15 @@ public class KylinRefundsStatusServiceImpl {
             // 更新退款表
             kylinOrderRefundsMapper.update(
                     kylinOrderRefunds,
-                    new UpdateWrapper<KylinOrderRefunds>().in("order_refunds_id", refund.getOrderRefundsId())
+                    new UpdateWrapper<KylinOrderRefunds>().eq("order_refunds_id", refund.getOrderRefundsId())
+            );
+            // 修改缓存
+            KylinOrderRefundsVo kylinOrderRefundsVo = new KylinOrderRefundsVo();
+            BeanUtils.copyProperties(kylinOrderRefunds, kylinOrderRefundsVo);
+            BasicDBObject object = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderRefundsVo)));
+            UpdateResult updateResult = mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateOne(
+                    Query.query(Criteria.where("orderRefundsId").is(refund.getOrderRefundsId())).getQueryObject(),
+                    object
             );
         }
 
@@ -496,15 +543,26 @@ public class KylinRefundsStatusServiceImpl {
                 kylinOrderRefunds,
                 new UpdateWrapper<KylinOrderRefunds>().in("order_refunds_id", refundInfo.getOrderRefundsId())
         );
+        // 修改缓存
+        KylinOrderRefundsVo kylinOrderRefundsVo = new KylinOrderRefundsVo();
+        BeanUtils.copyProperties(kylinOrderRefunds, kylinOrderRefundsVo);
+        BasicDBObject object = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderRefundsVo)));
+        UpdateResult updateResult = mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateOne(
+                Query.query(Criteria.where("orderRefundsId").is(refundInfo.getOrderRefundsId())).getQueryObject(),
+                object
+        );
 
         if (refundInfo.getType() == KylinTableStatusConst.ORDER_REFUND_TYPE_APPLY) {
             // 退还库存
             for (String entitiesId : orderTicketEntitiesIdsArr) {
-                dataUtils.changeSurplusGeneral(entitiesId, 1);
                 KylinOrderTicketEntities entitiesInfo = kylinOrderTicketEntitiesMapper.selectOne(
                         new QueryWrapper<KylinOrderTicketEntities>().eq("order_ticket_entities_id", entitiesId)
                 );
-                dataUtils.changeBuyInfo(orderInfo.getUserId(), "", orderRelations.getPerformanceId(), entitiesInfo.getTicketId(), -1);
+                if (entitiesInfo.getIsPayment() == KylinTableStatusConst.ENTITIES_IS_PAYMENT3) {
+                    dataUtils.changeSurplusGeneral(entitiesInfo.getTicketId(), 1);
+                    log.info(UserPathDto.setData("changeBuyInfo", "UserId=" + orderInfo.getUserId() + "idCard=" + entitiesInfo.getEnterIdCode() + " PerformanceId=" + orderRelations.getPerformanceId() + " TicketId=" + entitiesInfo.getTicketId(), "info"));
+                    dataUtils.changeBuyInfo(orderInfo.getUserId(), entitiesInfo.getEnterIdCode(), orderRelations.getPerformanceId(), entitiesInfo.getTicketId(), -1);
+                }
             }
         }