修改redis消费队列方式

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/pom.xml

@@ -64,8 +64,9 @@
         </dependency>
         <dependency>
             <groupId>com.liquidnet</groupId>
-            <artifactId>liquidnet-service-dragon-api</artifactId>
+            <artifactId>liquidnet-service-dragon-do</artifactId>
             <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
         </dependency>
     </dependencies>
 

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/dragon/DragonPayController.java

 package com.liquidnet.service.platform.controller.dragon;
 
-import io.swagger.annotations.Api;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.liquidnet.commons.lang.util.BeanUtil;
+import com.liquidnet.commons.lang.util.StringUtil;
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.dto.DragonOrdersDto;
+import com.liquidnet.service.dragon.entity.DragonOrders;
+import com.liquidnet.service.platform.service.dragon.IDragonOrdersService;
+import io.swagger.annotations.*;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.constraints.NotNull;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -14,9 +23,31 @@ import org.springframework.web.bind.annotation.RestController;
  * @Copyright: LightNet @ Copyright (c) 2021
  * @date 2021/7/20 14:11
  */
-@Api(tags = "前端-订单相关")
+@Api(tags = "支付-查询接口")
 @RestController
 @RequestMapping("dragon")
 @Validated
 public class DragonPayController {
+    @Autowired
+    IDragonOrdersService dragonOrdersService;
+
+    @GetMapping("/getDragonOrderDto")
+    @ApiOperation("订单查询")
+    @ApiResponse(code = 200, message = "接口返回对象参数")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "code", value = "", example = "PAY202107131522368438531155")
+    })
+    @ResponseBody
+    public ResponseDto<DragonOrdersDto> getDragonOrderDto(@RequestParam(value = "code") @NotNull(message = "支付编号不能为空！") String code){
+        //获取用户会员信息
+        LambdaQueryWrapper<DragonOrders> lambdaQueryWrapper = new LambdaQueryWrapper();
+        lambdaQueryWrapper.eq(DragonOrders::getCode,code);
+        DragonOrders respDto = dragonOrdersService.getOne(lambdaQueryWrapper);
+        if(StringUtil.isNull(respDto)){
+            return ResponseDto.failure("订单不存在！code: "+code);
+        }
+        DragonOrdersDto newDto = new DragonOrdersDto();
+        BeanUtil.copy(respDto,newDto);
+        return ResponseDto.success(newDto);
+    }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/dragon/IDragonOrdersService.java

+package com.liquidnet.service.platform.service.dragon;
+
+import com.liquidnet.service.dragon.entity.DragonOrders;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 支付订单表 服务类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+public interface IDragonOrdersService extends IService<DragonOrders> {
+
+}

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/dragon/DragonOrdersServiceImpl.java

+package com.liquidnet.service.platform.service.impl.dragon;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.service.dragon.entity.DragonOrders;
+import com.liquidnet.service.dragon.mapper.DragonOrdersMapper;
+import com.liquidnet.service.platform.service.dragon.IDragonOrdersService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 支付订单表 服务实现类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+@Service
+public class DragonOrdersServiceImpl extends ServiceImpl<DragonOrdersMapper, DragonOrders> implements IDragonOrdersService {
+
+}