sql

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

@@ -50,153 +50,6 @@ public class KylinRefundsStatusServiceImpl {
     @Autowired
     private QueueUtils queueUtils;
 
-    public Boolean orderTicketRefunding(
-            KylinOrderTicketVo orderInfo, String orderTicketsId,
-            double RefundPriceExpress,
-            List<String> ticketEntityIds, List<Double> entitiesPrice
-    ) {
-        if (CollectionUtil.isEmpty(ticketEntityIds)) {
-            return false;
-        }
-        // 基础数据
-        String authId = "";
-        String authName = "system_overtime_order_refund";
-        String reason = "订单支付超时自动退款";
-        // 本次退款票总金额
-        double entitiesPriceSum = entitiesPrice.stream().mapToDouble(Double::doubleValue).sum();
-
-        // 更新数据
-        // 订单状态表 和 缓存
-        LocalDateTime nowTime = LocalDateTime.now();
-        String nowTimeStr = DateUtil.Formatter.yyyyMMddHHmmss.format(nowTime);
-        KylinOrderTicketStatus orderStatusTable = new KylinOrderTicketStatus();
-        orderStatusTable.setStatus(KylinTableStatusConst.ORDER_STATUS3);
-        orderStatusTable.setUpdatedAt(nowTime);
-
-        /*kylinOrderTicketStatusMapper.update(orderStatusTable, new UpdateWrapper<KylinOrderTicketStatus>()
-                .eq("order_id", orderTicketsId));*/
-
-        KylinOrderTicketVo kylinOrderTicketVo = KylinOrderTicketVo.getNew();
-        kylinOrderTicketVo.setStatus(KylinTableStatusConst.ORDER_STATUS3);
-        kylinOrderTicketVo.setUpdatedAt(nowTimeStr);
-        BasicDBObject orderObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketVo)));
-        UpdateResult orderResult = mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateOne(
-                Query.query(Criteria.where("orderTicketsId").is(orderTicketsId)).getQueryObject(),
-                orderObject
-        );
-        dataUtils.delOrderTicketRedis(orderTicketsId);
-        log.info("orderInfo.getUserId() = "+ orderInfo.getUserId());
-        orderUtils.resetOrderListVo(orderInfo.getUserId(), 2, orderTicketsId, null);
-
-
-        // 订单入场人表 和 缓存
-        KylinOrderTicketEntities entitiesTable = new KylinOrderTicketEntities();
-        entitiesTable.setIsPayment(KylinTableStatusConst.ENTITIES_IS_PAYMENT2);
-        entitiesTable.setUpdatedAt(nowTime);
-
-        KylinOrderTicketEntitiesVo kylinOrderTicketEntitiesVo = KylinOrderTicketEntitiesVo.getNew();
-        kylinOrderTicketEntitiesVo.setIsPayment(KylinTableStatusConst.ENTITIES_IS_PAYMENT2);
-        kylinOrderTicketEntitiesVo.setUpdatedAt(nowTimeStr);
-        BasicDBObject entitiesObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinOrderTicketEntitiesVo)));
-
-        LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
-        for (String v : ticketEntityIds) {
-            LocalDateTime now1 = LocalDateTime.now();
-            sqlsDataB.add(new Object[]{
-                    entitiesTable.getIsPayment(), entitiesTable.getUpdatedAt(), v, now1, now1
-            });
-            /*kylinOrderTicketEntitiesMapper.update(entitiesTable, new UpdateWrapper<KylinOrderTicketEntities>()
-                    .eq("order_ticket_entities_id", v));*/
-
-            UpdateResult entitiesResult = mongoTemplate.getCollection(KylinOrderTicketEntitiesVo.class.getSimpleName()).updateOne(
-                    Query.query(Criteria.where("orderTicketEntitiesId").is(v)).getQueryObject(),
-                    entitiesObject
-            );
-            dataUtils.delOrderTicketEntitiesRedis(v);
-        }
-
-        // 退款明细
-        KylinOrderRefunds kylinOrderRefunds = new KylinOrderRefunds();
-        String orderRefundsId = IDGenerator.nextSnowId();
-        kylinOrderRefunds.setOrderRefundsId(orderRefundsId);
-        kylinOrderRefunds.setOrderTicketsId(orderTicketsId);
-        String orderRefundCode = orderInfo.getOrderCode();
-        String codeNum = StringUtils.leftPad(String.valueOf(5), 3, "0");
-        kylinOrderRefunds.setOrderRefundCode(orderRefundCode.concat(codeNum));
-        kylinOrderRefunds.setPrice(BigDecimal.valueOf(entitiesPriceSum));
-        kylinOrderRefunds.setPriceExpress(BigDecimal.valueOf(RefundPriceExpress));
-        kylinOrderRefunds.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_APPLY);
-        kylinOrderRefunds.setType(KylinTableStatusConst.ORDER_REFUND_TYPE_AUTO);
-        kylinOrderRefunds.setApplicantId(authId);
-        kylinOrderRefunds.setApplicantName(authName);
-        kylinOrderRefunds.setApplicantAt(nowTime);
-        kylinOrderRefunds.setReason(reason);
-        if (RefundPriceExpress > 0 && entitiesPriceSum > 0) {
-            kylinOrderRefunds.setRefundCate(KylinTableStatusConst.ORDER_REFUND_CATE3);
-        } else if (RefundPriceExpress > 0) {
-            kylinOrderRefunds.setRefundCate(KylinTableStatusConst.ORDER_REFUND_CATE2);
-        } else if (entitiesPriceSum > 0) {
-            kylinOrderRefunds.setRefundCate(KylinTableStatusConst.ORDER_REFUND_CATE1);
-        }
-        kylinOrderRefunds.setCreatedAt(nowTime);
-
-        /*int rows = kylinOrderRefundsMapper.insert(kylinOrderRefunds);*/
-
-        KylinOrderRefundsVo orderRefundsVo = KylinOrderRefundsVo.getNew();
-        BeanUtils.copyProperties(kylinOrderRefunds, orderRefundsVo);
-        mongoTemplate.insert(orderRefundsVo, KylinOrderRefundsVo.class.getSimpleName());
-
-        // 退款入场人表
-        KylinOrderRefundEntities kylinOrderRefundEntities = new KylinOrderRefundEntities();
-        kylinOrderRefundEntities.setOrderRefundsId(orderRefundsId);
-        kylinOrderRefundEntities.setCreatedAt(LocalDateTime.now());
-        LinkedList<Object[]> sqlsDataD = CollectionUtil.linkedListObjectArr();
-        for (int i = 0; i <= ticketEntityIds.size() - 1; i++) {
-            String orderRefundsEntitiesId = IDGenerator.nextSnowId();
-            kylinOrderRefundEntities.setOrderRefundsEntitiesId(orderRefundsEntitiesId);
-            kylinOrderRefundEntities.setRefundPrice(BigDecimal.valueOf(entitiesPrice.get(i)));
-            kylinOrderRefundEntities.setOrderTicketEntitiesId(ticketEntityIds.get(i));
-
-            sqlsDataD.add(new Object[]{
-                    kylinOrderRefundEntities.getOrderRefundsEntitiesId(), kylinOrderRefundEntities.getOrderRefundsId(), kylinOrderRefundEntities.getRefundPrice(),
-                    kylinOrderRefundEntities.getOrderTicketEntitiesId(), kylinOrderRefundEntities.getCreatedAt()
-            });
-            /*int rowsR = kylinOrderRefundsEntitiesMapper.insert(kylinOrderRefundEntities);*/
-
-            KylinOrderRefundEntitiesVo orderRefundEntitiesVo = KylinOrderRefundEntitiesVo.getNew();
-            BeanUtils.copyProperties(kylinOrderRefundEntities, orderRefundEntitiesVo);
-            mongoTemplate.insert(orderRefundEntitiesVo, KylinOrderRefundEntitiesVo.class.getSimpleName());
-        }
-
-        //mq更改数据库
-        LinkedList<String> sqls = CollectionUtil.linkedListString();
-        LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-        LinkedList<Object[]> sqlsDataC = CollectionUtil.linkedListObjectArr();
-
-        sqls.add(SqlMapping.get("kylin_order_ticket_status.overtimeRefund"));
-        sqls.add(SqlMapping.get("kylin_order_ticket_entities.overtimeRefund"));
-        sqls.add(SqlMapping.get("kylin_order_refund.overtimeRefund"));
-        sqls.add(SqlMapping.get("kylin_order_refund_entities.overtimeRefund"));
-        LocalDateTime now1 = LocalDateTime.now();
-        sqlsDataA.add(new Object[]{
-                orderStatusTable.getStatus(), orderStatusTable.getUpdatedAt(), orderInfo.getOrderTicketsId(), now1, now1
-        });
-
-        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()
-        });
-
-        queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_ORDER_OVERTIME_REFUND.getKey(),
-                SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD));
-
-        return true;
-    }
-
-
     public String userOrderTicketRefunding(
             KylinOrderTicketVo orderInfo,
             double refundPrice,

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

@@ -27,7 +27,7 @@ kylin_order_ticket_entities.synPay=UPDATE kylin_order_ticket_entities SET is_pay
 
 # ------------------------用户发起订单退款----------------------------
 kylin_order_ticket_status.refund=UPDATE kylin_order_ticket_status SET status = ? ,updated_at = ?  WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
-wkylin_order_ticket_entities.refund=UPDATE kylin_order_ticket_entities SET is_payment = ? ,updated_at = ?  WHERE order_ticket_entities_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
+kylin_order_ticket_entities.refund=UPDATE kylin_order_ticket_entities SET is_payment = ? ,updated_at = ?  WHERE order_ticket_entities_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
 kylin_order_refund.refund=INSERT INTO kylin_order_refunds (order_refunds_id,order_tickets_id,order_refund_code,price,price_express,status,type,applicant_id,applicant_name,applicant_at,reason,refund_cate,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)
 kylin_order_refund_entities.refund=INSERT INTO kylin_order_refund_entities (order_refunds_entities_id,order_refunds_id,refund_price,order_ticket_entities_id,created_at) VALUES(?,?,?,?,?)
 kylin_order_refund_pic.refund=INSERT INTO kylin_order_refund_pic (refund_pic_id,order_refunds_id,pic_url,created_at) VALUES (?,?,?,?)