退款回调整理

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

@@ -3,27 +3,20 @@ package com.liquidnet.service.platform.service.refund;
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
-import com.liquidnet.common.mq.constant.MQConst;
-import com.liquidnet.commons.lang.util.CollectionUtil;
 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.base.SqlMapping;
 import com.liquidnet.service.base.UserPathDto;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
 import com.liquidnet.service.kylin.dto.param.RefundCallbackParam;
 import com.liquidnet.service.kylin.dto.vo.mongo.*;
+import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderRefundsVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.platform.utils.DataUtils;
 import com.liquidnet.service.platform.utils.MongoVoUtils;
 import com.mongodb.BasicDBObject;
-import com.mongodb.client.model.FindOneAndUpdateOptions;
-import com.mongodb.client.model.ReturnDocument;
 import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang.StringUtils;
-import org.bson.Document;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -36,7 +29,6 @@ import org.springframework.stereotype.Service;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.HashMap;
-import java.util.LinkedList;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -81,8 +73,6 @@ public class KylinRefundsStatusServiceImpl {
 
     @Autowired
     private MongoVoUtils mongoVoUtils;
-    @Autowired
-    private RabbitTemplate rabbitTemplate;
 
     public boolean orderTicketRefunded(RefundCallbackParam refundCallbackParam, KylinOrderRefunds refundInfo) {
         List<KylinOrderRefundEntities> refundEntities = kylinOrderRefundsEntitiesMapper.selectList(
@@ -205,6 +195,14 @@ 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) {
             // 退还库存
@@ -223,156 +221,4 @@ public class KylinRefundsStatusServiceImpl {
         return true;
     }
 
-    public Boolean userOrderTicketRefunding(
-            KylinOrderTicketVo orderInfo,
-            double refundPrice,
-            String orderEntitiesId,
-            String reason,
-            String picList,
-            String uid,
-            String username,
-            int refundCount
-    ) {
-        try {
-            LocalDateTime time = LocalDateTime.now();
-            String strTime = DateUtil.Formatter.yyyyMMddHHmmss.format(time);
-            // 订单状态表 和 缓存
-            KylinOrderTicketStatus orderStatusTable = new KylinOrderTicketStatus();
-            orderStatusTable.setStatus(KylinTableStatusConst.ORDER_STATUS3);
-            orderStatusTable.setUpdatedAt(time);
-
-
-            KylinOrderTicketVo kylinOrderTicketVo = new KylinOrderTicketVo();
-            kylinOrderTicketVo.setStatus(KylinTableStatusConst.ORDER_STATUS3);
-            kylinOrderTicketVo.setUpdatedAt(DateUtil.Formatter.yyyyMMddHHmmss.format(time));
-            BasicDBObject orderObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketVo)));
-            mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateOne(
-                    Query.query(Criteria.where("orderTicketsId").is(orderInfo.getOrderTicketsId())).getQueryObject(),
-                    orderObject
-            );
-            dataUtils.delOrderTicketRedis(orderInfo.getOrderTicketsId());
-            mongoVoUtils.resetOrderListVo(orderInfo.getUserId(), 2, orderInfo.getOrderTicketsId(), null);
-
-
-            // 订单入场人表 和 缓存
-            KylinOrderTicketEntities entitiesTable = new KylinOrderTicketEntities();
-            entitiesTable.setIsPayment(KylinTableStatusConst.ENTITIES_IS_PAYMENT2);
-            entitiesTable.setUpdatedAt(time);
-
-
-            KylinOrderTicketEntitiesVo kylinOrderTicketEntitiesVo = new KylinOrderTicketEntitiesVo();
-            kylinOrderTicketEntitiesVo.setIsPayment(KylinTableStatusConst.ENTITIES_IS_PAYMENT2);
-            kylinOrderTicketEntitiesVo.setUpdatedAt(strTime);
-            BasicDBObject entitiesObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketEntitiesVo)));
-            mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).updateOne(
-                    Query.query(Criteria.where("orderTicketEntitiesId").is(orderEntitiesId)).getQueryObject(),
-                    entitiesObject
-            );
-            dataUtils.delOrderTicketEntitiesRedis(orderEntitiesId);
-
-            // 退款明细
-            KylinOrderRefunds kylinOrderRefunds = new KylinOrderRefunds();
-            String orderRefundsId = IDGenerator.nextSnowId();
-            kylinOrderRefunds.setOrderRefundsId(orderRefundsId);
-            kylinOrderRefunds.setOrderTicketsId(orderInfo.getOrderTicketsId());
-            String orderRefundCode = orderInfo.getOrderCode();
-            String codeNum = StringUtils.leftPad(String.valueOf(refundCount), 3, "0");
-            kylinOrderRefunds.setOrderRefundCode(orderRefundCode.concat(codeNum));
-            kylinOrderRefunds.setPrice(BigDecimal.valueOf(refundPrice));
-            kylinOrderRefunds.setPriceExpress(orderInfo.getPriceExpress());
-            kylinOrderRefunds.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_APPLY);
-            kylinOrderRefunds.setType(KylinTableStatusConst.ORDER_REFUND_TYPE_APPLY);
-            kylinOrderRefunds.setApplicantId(uid);
-            kylinOrderRefunds.setApplicantName(username);
-            kylinOrderRefunds.setApplicantAt(time);
-            kylinOrderRefunds.setReason(reason);
-            if (orderInfo.getPriceExpress().doubleValue() > 0 && refundPrice > 0) {
-                kylinOrderRefunds.setRefundCate(KylinTableStatusConst.ORDER_REFUND_CATE3);
-            } else if (orderInfo.getPriceExpress().doubleValue() > 0) {
-                kylinOrderRefunds.setRefundCate(KylinTableStatusConst.ORDER_REFUND_CATE2);
-            } else if (refundPrice > 0) {
-                kylinOrderRefunds.setRefundCate(KylinTableStatusConst.ORDER_REFUND_CATE1);
-            }
-            kylinOrderRefunds.setCreatedAt(time);
-
-            KylinOrderRefundsVoBase orderRefundsVo = new KylinOrderRefundsVoBase();
-            BeanUtils.copyProperties(kylinOrderRefunds,orderRefundsVo);
-            orderRefundsVo.setCreatedAt(strTime);
-            orderRefundsVo.setApplicantAt(strTime);
-            mongoTemplate.insert(orderRefundsVo, KylinOrderRefundsVoBase.class.getSimpleName());
-
-
-
-            // 退款入场人表
-            KylinOrderRefundEntities kylinOrderRefundEntities = new KylinOrderRefundEntities();
-            String orderRefundsEntitiesId = IDGenerator.nextSnowId();
-            kylinOrderRefundEntities.setOrderRefundsEntitiesId(orderRefundsEntitiesId);
-            kylinOrderRefundEntities.setOrderRefundsId(orderRefundsId);
-            kylinOrderRefundEntities.setRefundPrice(BigDecimal.valueOf(refundPrice));
-            kylinOrderRefundEntities.setOrderTicketEntitiesId(orderEntitiesId);
-            kylinOrderRefundEntities.setCreatedAt(time);
-
-            KylinOrderRefundEntitiesVo orderRefundEntitiesVo = new KylinOrderRefundEntitiesVo();
-            BeanUtils.copyProperties(kylinOrderRefundEntities,orderRefundEntitiesVo);
-            orderRefundEntitiesVo.setCreatedAt(strTime);
-            mongoTemplate.insert(orderRefundEntitiesVo,KylinOrderRefundEntitiesVo.class.getSimpleName());
-
-            //退款图片
-            KylinOrderRefundPic orderRefundPic = new KylinOrderRefundPic();
-            orderRefundPic.setRefundPicId(IDGenerator.nextSnowId());
-            orderRefundPic.setOrderRefundsId(kylinOrderRefunds.getOrderRefundsId());
-            orderRefundPic.setPicUrl(picList);
-            orderRefundPic.setCreatedAt(time);
-
-            KylinOrderRefundPicVo orderRefundPicVo = new KylinOrderRefundPicVo();
-            BeanUtils.copyProperties(orderRefundPic,orderRefundPicVo);
-            orderRefundPicVo.setCreatedAt(strTime);
-            mongoTemplate.insert(orderRefundPicVo,KylinOrderRefundPicVo.class.getSimpleName());
-
-            dataUtils.delOrderRefundVoByOrderId(orderInfo.getOrderTicketsId());
-            //MQ
-            LinkedList<String> sqls = new LinkedList<>();
-            LinkedList<Object[]> sqlsDataA = new LinkedList<>();
-            LinkedList<Object[]> sqlsDataB = new LinkedList<>();
-            LinkedList<Object[]> sqlsDataC = new LinkedList<>();
-            LinkedList<Object[]> sqlsDataD = new LinkedList<>();
-            LinkedList  <Object[]> sqlsDataE = new LinkedList<>();
-
-            sqls.add(SqlMapping.get("kylin_order_ticket_status.refund"));
-            sqls.add(SqlMapping.get("kylin_order_ticket_entities.refund"));
-            sqls.add(SqlMapping.get("kylin_order_refund.refund"));
-            sqls.add(SqlMapping.get("kylin_order_refund_entities.refund"));
-            sqls.add(SqlMapping.get("kylin_order_refund_pic.refund"));
-
-            sqlsDataA.add(new Object[]{
-                    orderStatusTable.getStatus(), orderStatusTable.getUpdatedAt(), orderInfo.getOrderTicketsId(), orderInfo.getChangeDate(), orderInfo.getChangeDate()
-            });
-            sqlsDataB.add(new Object[]{
-                    entitiesTable.getIsPayment(), entitiesTable.getUpdatedAt(), orderEntitiesId, orderInfo.getChangeDate(), orderInfo.getChangeDate()
-            });
-            sqlsDataC.add(new Object[]{
-                    kylinOrderRefunds.getOrderRefundsId(), kylinOrderRefunds.getOrderTicketsId(), kylinOrderRefunds.getOrderRefundCode(),
-                    kylinOrderRefunds.getPrice(), kylinOrderRefunds.getPriceExpress(), kylinOrderRefunds.getStatus(),
-                    kylinOrderRefunds.getType(), kylinOrderRefunds.getApplicantId(), kylinOrderRefunds.getApplicantName(),
-                    kylinOrderRefunds.getApplicantAt(), kylinOrderRefunds.getReason(),
-                    kylinOrderRefunds.getRefundCate(), kylinOrderRefunds.getCreatedAt()
-            });
-            sqlsDataD.add(new Object[]{
-                    kylinOrderRefundEntities.getOrderRefundsEntitiesId(), kylinOrderRefundEntities.getOrderRefundsId(), kylinOrderRefundEntities.getRefundPrice(),
-                    kylinOrderRefundEntities.getOrderTicketEntitiesId(), kylinOrderRefundEntities.getCreatedAt()
-            });
-            sqlsDataE.add(new Object[]{
-                    orderRefundPic.getOrderRefundsId(), orderRefundPic.getOrderRefundsId(), orderRefundPic.getPicUrl(), orderRefundPic.getCreatedAt()
-            });
-
-            //TODO 生成新QUERY
-            rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND, MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
-                    SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD, sqlsDataE));
-
-            return true;
-        }catch (Exception e){
-            e.printStackTrace();
-            return false;
-        }
-    }
 }

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

 package com.liquidnet.service.platform.service.refund;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
 import com.liquidnet.service.kylin.dto.param.RefundCallbackParam;
+import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderRefundsVo;
 import com.liquidnet.service.kylin.entity.KylinOrderRefunds;
 import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.kylin.service.IKylinOrderRefundsService;
+import com.mongodb.BasicDBObject;
+import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
@@ -70,11 +78,18 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
             kylinOrderRefunds.setRefundAt(refundCallbackParam.getRefund_at());
             kylinOrderRefunds.setRefundError(refundCallbackParam.getRefund_error());
             kylinOrderRefunds.setUpdatedAt(LocalDateTime.now());
-
             kylinOrderRefundsMapper.update(
                     kylinOrderRefunds,
                     new UpdateWrapper<KylinOrderRefunds>().eq("order_refund_code", refundCallbackParam.getOrder_refund_code())
             );
+            // 修改缓存
+            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("orderRefundCode").is(refundCallbackParam.getOrder_refund_code())).getQueryObject(),
+                    object
+            );
         }
         return "success";
     }