|
|
@@ -0,0 +1,73 @@
|
|
|
+package com.sckw.order.dubbo;
|
|
|
+
|
|
|
+import com.alibaba.fastjson2.JSON;
|
|
|
+import com.sckw.core.exception.BusinessException;
|
|
|
+import com.sckw.core.utils.BeanUtils;
|
|
|
+import com.sckw.order.api.dubbo.TradeOrderInfoService;
|
|
|
+import com.sckw.order.api.model.OrderDetailRes;
|
|
|
+import com.sckw.order.api.model.UpdateOrderAmountParam;
|
|
|
+import com.sckw.order.model.KwoTradeOrder;
|
|
|
+import com.sckw.order.serivce.KwoTradeOrderService;
|
|
|
+import com.sckw.order.serivce.KwoTradeOrderTrackService;
|
|
|
+import com.sckw.stream.model.SckwBusSum;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.dubbo.config.annotation.DubboService;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.cloud.stream.function.StreamBridge;
|
|
|
+
|
|
|
+import java.util.Objects;
|
|
|
+
|
|
|
+/**
|
|
|
+ * @desc: 订单dubbo实现
|
|
|
+ * @author: yzc
|
|
|
+ * @date: 2023-07-18 18:26
|
|
|
+ */
|
|
|
+@DubboService(group = "design", version = "2.0.0")
|
|
|
+@Slf4j
|
|
|
+public class TradeOrderInfoServiceImpl implements TradeOrderInfoService {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private KwoTradeOrderService kwoTradeOrderService;
|
|
|
+ @Autowired
|
|
|
+ private StreamBridge streamBridge;
|
|
|
+ @Autowired
|
|
|
+ private KwoTradeOrderTrackService kwoTradeOrderTrackService;
|
|
|
+
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public OrderDetailRes getOrderDetailById(Long tOrderId) {
|
|
|
+ return BeanUtils.copyProperties(kwoTradeOrderService.detail(tOrderId), OrderDetailRes.class);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void updateOrderStatus(Long tOrderId, Integer status) {
|
|
|
+ KwoTradeOrder order = kwoTradeOrderService.getById(tOrderId);
|
|
|
+ if (Objects.isNull(order)) {
|
|
|
+ throw new BusinessException("订单不存在!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void updateOrderAmount(UpdateOrderAmountParam param) {
|
|
|
+ KwoTradeOrder order = kwoTradeOrderService.getById(param.getTOrderId());
|
|
|
+ if (Objects.isNull(order)) {
|
|
|
+ throw new BusinessException("订单不存在!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @desc: mq保存mongodb
|
|
|
+ * @author: yzc
|
|
|
+ * @date: 2023-07-17 8:43
|
|
|
+ * @Param method:
|
|
|
+ * @Param order:
|
|
|
+ * @return: void
|
|
|
+ */
|
|
|
+ private void saveMongoDb(Integer method, Object order) {
|
|
|
+ SckwBusSum busSum = new SckwBusSum();
|
|
|
+ busSum.setBusSumType("tradeOrder");
|
|
|
+ busSum.setMethod(method);
|
|
|
+ busSum.setObject(order);
|
|
|
+ streamBridge.send("sckw-busSum", JSON.toJSONString(busSum));
|
|
|
+ }
|
|
|
+}
|