暂时提交

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

@@ -2,10 +2,7 @@ package com.liquidnet.service.kylin.service.impl;
 
 import com.alibaba.fastjson.JSON;
 import com.github.pagehelper.PageInfo;
-import com.liquidnet.commons.lang.util.CollectionUtil;
-import com.liquidnet.commons.lang.util.CurrentUtil;
-import com.liquidnet.commons.lang.util.DateUtil;
-import com.liquidnet.commons.lang.util.JsonUtils;
+import com.liquidnet.commons.lang.util.*;
 import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
@@ -721,10 +718,11 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
             sqls.add(SqlMapping.get("kylin_order_ticket_relation.transfer.update"));
             LinkedList<Object[]> sqlsDataC = CollectionUtil.linkedListObjectArr();
             sqlsDataC.add(new Object[]{
-                    transferUid, now, orderTicketVo.getOrderTicketsId(), now, now
+                    transferUid,orderTicketVo.getOrderTicketsId(), now, orderTicketVo.getOrderTicketsId(), now, now
             });
 
             //生成被转赠订单独立redis
+            orderTicketVo.setOrderTicketsId(IDGenerator.nextSnowId());
             orderTicketVo.setTransferId(orderTicketVo.getOrderTicketsId());
             orderTicketVo.setTransferStatus(4);
             orderTicketVo.setUserId(transferUid);
@@ -775,7 +773,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
             sqls.add(SqlMapping.get("kylin_order_ticket_relation.transfer.update"));
             LinkedList<Object[]> sqlsDataC = CollectionUtil.linkedListObjectArr();
             sqlsDataC.add(new Object[]{
-                    "", now, orderTicketVo.getOrderTicketsId(), now, now
+                    "","", now, orderTicketVo.getOrderTicketsId(), now, now
             });
             //删除被转赠订单独立redis
             dataUtils.delTransferOrder(orderTicketVo.getTransferUid());
@@ -794,8 +792,53 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
     }
 
     @Override
-    public ResponseDto<String> orderTransferReject(String orderId) {
-        return null;
+    public ResponseDto<String> orderTransferReject() {
+        String uid = CurrentUtil.getCurrentUid();
+        KylinOrderTicketVo orderTicketVo = dataUtils.getTransferOrder(uid);
+        LocalDateTime now = LocalDateTime.now();
+        if (null != orderTicketVo) {
+            if (!orderTicketVo.getUserId().equals(uid)) {
+                return ResponseDto.success("无权查看");
+            }
+
+            KylinOrderTicketVo orderTicketVoTransfer = dataUtils.getOrderTicketVo(orderTicketVo.getTransferId());
+
+            LinkedList<String> sqls = CollectionUtil.linkedListString();
+            //删除持久化数据
+            sqls.add(SqlMapping.get("kylin_order_task.delete"));
+            LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+            sqlsDataA.add(new Object[]{
+                    orderTicketVo.getTransferId()
+            });
+            //修改被转赠订单 redis
+            orderTicketVoTransfer.setTransferStatus(0);
+            dataUtils.setOrderTicketVo(orderTicketVoTransfer.getOrderTicketsId(), orderTicketVoTransfer);
+            orderUtils.resetOrderListVo(uid, 2, orderTicketVoTransfer.getOrderTicketsId(), orderTicketVoTransfer);
+            //修改被转赠订单 mongo
+            mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateOne(
+                    Query.query(Criteria.where("orderTicketsId").is(orderTicketVoTransfer.getOrderTicketsId())).getQueryObject(),
+                    new Document("$set", new Document("transferStatus", orderTicketVoTransfer.getTransferStatus()).append("updatedAt", now))
+            );
+            //修改被转赠订单 mysql
+            sqls.add(SqlMapping.get("kylin_order_ticket_status.transfer.update"));
+            LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
+            sqlsDataB.add(new Object[]{
+                    0, now, orderTicketVoTransfer.getOrderTicketsId(), now, now
+            });
+            sqls.add(SqlMapping.get("kylin_order_ticket_relation.transfer.update"));
+            LinkedList<Object[]> sqlsDataC = CollectionUtil.linkedListObjectArr();
+            sqlsDataC.add(new Object[]{
+                    "","", now, orderTicketVoTransfer.getOrderTicketsId(), now, now
+            });
+            //删除被转赠订单独立redis
+            dataUtils.delTransferOrder(orderTicketVo.getUserId());
+            //入库
+            queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_TRANSFER.getKey(),
+                    SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC));
+        } else {
+            return ResponseDto.failure("退回失败");
+        }
+        return ResponseDto.failure("退回成功");
     }
 
 }

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/resources/sqlmap.properties

@@ -48,5 +48,5 @@ kylin_order_refund_entities.overtimeRefund=INSERT INTO kylin_order_refund_entiti
 kylin_order_task.insert = INSERT INTO `kylin_order_task`(`order_id` , `status` , `created_at`) VALUES (? ,? ,?);
 kylin_order_task.delete = DELETE FROM kylin_order_task WHERE order_id = ?;
 kylin_order_ticket_status.transfer.update = UPDATE kylin_order_tickets SET transfer_status = ? ,updated_at = ?  WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
-kylin_order_ticket_relation.transfer.update = UPDATE kylin_order_tickets SET transfer_uid = ? ,updated_at = ?  WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
+kylin_order_ticket_relation.transfer.update = UPDATE kylin_order_tickets SET transfer_uid = ?, transfer_id = ? ,updated_at = ?  WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)