记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit bde846fe authored by jiangxiulong's avatar jiangxiulong
Browse files
Options

失败也入库记录

parent e854d7b7
Hide whitespace changes
Inline Side-by-side
Showing with 43 additions and 31 deletions
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketsRefundServiceImpl.java
View file @ bde846fe
......@@ -405,6 +405,20 @@ public class KylinOrderTicketsRefundServiceImpl {
log.error("expressPlaceFromJsonException e:[{}]", e);
}
LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("kylin_order_refund.refundOrderExpress"));
LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
LocalDateTime now = LocalDateTime.now();
String remark = "";
String proName = "";
String goodsValueTotal = "";
String goodsNumber = "";
String mailno = "";
String filterResult = "";
String cargoTypeCode = "";
String limitTypeCode = "";
String expressTypeCode = "";
Integer orderExpressStatus = 0;
if (null == hashMap.get("succ") || hashMap.get("succ").equals("fail")) {
String msg = "";
if (null == hashMap.get("succ")) {
......@@ -412,50 +426,48 @@ public class KylinOrderTicketsRefundServiceImpl {
} else {
msg = (String) hashMap.get("msg");
}
orderExpressStatus = 1;
} else { // 成功下单记录缓存
// 生成快递单
HashMap hashMapResult = (HashMap) hashMap.get("result");
LocalDateTime now = LocalDateTime.now();
LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("kylin_order_refund.refundOrderExpress"));
LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
String remark = (String) hashMapResult.get("remark");
String proName = (String) hashMapResult.get("proName");
String goodsValueTotal = (String) hashMapResult.get("goodsValueTotal");
String goodsNumber = (String) hashMapResult.get("goodsNumber");
remark = (String) hashMapResult.get("remark");
proName = (String) hashMapResult.get("proName");
goodsValueTotal = (String) hashMapResult.get("goodsValueTotal");
goodsNumber = (String) hashMapResult.get("goodsNumber");
mailno = (String) hashMapResult.get("mailno");
filterResult = (String) hashMapResult.get("filter_result");
cargoTypeCode = (String) hashMapResult.get("cargoTypeCode");
limitTypeCode = (String) hashMapResult.get("limitTypeCode");
expressTypeCode = (String) hashMapResult.get("expressTypeCode");
remark = (null == remark) ? "" : remark;
proName = (null == proName) ? "" : proName;
goodsValueTotal = (null == goodsValueTotal) ? "" : goodsValueTotal;
goodsNumber = (null == goodsNumber) ? "" : goodsNumber;
String mailno = (String) hashMapResult.get("mailno");
String filterResult = (String) hashMapResult.get("filter_result");
String cargoTypeCode = (String) hashMapResult.get("cargoTypeCode");
String limitTypeCode = (String) hashMapResult.get("limitTypeCode");
String expressTypeCode = (String) hashMapResult.get("expressTypeCode");
mailno = (null == mailno) ? "" : mailno;
filterResult = (null == filterResult) ? "" : filterResult;
cargoTypeCode = (null == cargoTypeCode) ? "" : cargoTypeCode;
limitTypeCode = (null == limitTypeCode) ? "" : limitTypeCode;
expressTypeCode = (null == expressTypeCode) ? "" : expressTypeCode;
sqlsDataA.add(new Object[]{
orderExpressId, orderTicketVo.getPerformanceId(), orderTicketVo.getOrderTicketsId(), orderRefundId,
OrderExpressCode, mailno, expressType, filterResult, remark, KylinTableStatusConst.ORDER_EXPRESS_STATUS2
, 2, sendExpressType, expressContacts, expressPhone, sendExpressAddress, appointmentTime
, proName, cargoTypeCode, limitTypeCode, expressTypeCode, goodsValueTotal, goodsNumber
, now
});
queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_ORDER_REFUND_EXPRESS.getKey(),
SqlMapping.gets(sqls, sqlsDataA));
KylinOrderExpressVo kylinOrderExpressVo = KylinOrderExpressVo.getNew();
kylinOrderExpressVo.setOrderExpressId(orderExpressId);
kylinOrderExpressVo.setOrderTicketsId(orderTicketVo.getOrderTicketsId());
kylinOrderExpressVo.setOrderExpressCode(OrderExpressCode);
kylinOrderExpressVo.setMailno((String) hashMapResult.get("mailno"));
kylinOrderExpressVo.setExpressStatus(KylinTableStatusConst.ORDER_EXPRESS_STATUS2);
kylinOrderExpressVo.setSendExpressType(sendExpressType);
dataUtils.setOrderRefundExpressInfo(orderTicketVo.getOrderTicketsId(), kylinOrderExpressVo);
orderExpressStatus = 2;
}
sqlsDataA.add(new Object[]{
orderExpressId, orderTicketVo.getPerformanceId(), orderTicketVo.getOrderTicketsId(), orderRefundId,
OrderExpressCode, mailno, expressType, filterResult, remark, orderExpressStatus
, 2, sendExpressType, expressContacts, expressPhone, sendExpressAddress, appointmentTime
, proName, cargoTypeCode, limitTypeCode, expressTypeCode, goodsValueTotal, goodsNumber
, now
});
queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_ORDER_REFUND_EXPRESS.getKey(),
SqlMapping.gets(sqls, sqlsDataA));
KylinOrderExpressVo kylinOrderExpressVo = KylinOrderExpressVo.getNew();
kylinOrderExpressVo.setOrderExpressId(orderExpressId);
kylinOrderExpressVo.setOrderTicketsId(orderTicketVo.getOrderTicketsId());
kylinOrderExpressVo.setOrderExpressCode(OrderExpressCode);
kylinOrderExpressVo.setMailno(mailno);
kylinOrderExpressVo.setExpressStatus(orderExpressStatus);
kylinOrderExpressVo.setSendExpressType(sendExpressType);
dataUtils.setOrderRefundExpressInfo(orderTicketVo.getOrderTicketsId(), kylinOrderExpressVo);
} else if (sendExpressType == 2) { // 自主发货
// 生成快递单 REDIS 队列入数据库
String orderExpressId = IDGenerator.nextSnowId();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment