nft:platform:增加统计待支付订单task

liquidnet-bus-do/liquidnet-service-goblin-do/src/main/java/com/liquidnet/service/goblin/dto/PlatformGoblinNftOrderNotPayDto.java

+package com.liquidnet.service.goblin.dto;
+
+import lombok.Data;
+
+@Data
+public class PlatformGoblinNftOrderNotPayDto {
+    private String skuId;
+    private String listId;
+    private int notPayNum;
+}

liquidnet-bus-do/liquidnet-service-goblin-do/src/main/java/com/liquidnet/service/goblin/mapper/GoblinNftOrderMapper.java

 package com.liquidnet.service.goblin.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.liquidnet.service.goblin.dto.PlatformGoblinNftOrderNotPayDto;
 import com.liquidnet.service.goblin.dto.admin.GoblinNftOrderListDto;
 import com.liquidnet.service.goblin.entity.GoblinNftOrder;
 
@@ -19,4 +20,5 @@ public interface GoblinNftOrderMapper extends BaseMapper<GoblinNftOrder> {
 
     List<GoblinNftOrderListDto> searchList(Map<String, Object> convertBeanToMap);
 
+    List<PlatformGoblinNftOrderNotPayDto> selectOrderList();
 }

liquidnet-bus-do/liquidnet-service-goblin-do/src/main/resources/com.liquidnet.service.goblin.mapper/GoblinNftOrderMapper.xml

@@ -55,4 +55,18 @@
         -- order by a.created_at desc
         order by a.mid desc
     </select>
+    <select id="selectOrderList" resultType="com.liquidnet.service.goblin.dto.PlatformGoblinNftOrderNotPayDto">
+        select sku_id,
+               list_id,
+               sum(if(status = 1, num, 0)) as notPayNum
+--             # select status, created_at,pay_time,updated_at,cancel_time,sku_id,list_id
+        from goblin_nft_order
+        where 1 > 0
+--             # and sku_title = '正在现场盲盒  正在现场盲盒'
+          and pay_type != 'EXCODE'
+--             #     and status = 3
+          and created_at > DATE_SUB(NOW(), INTERVAL 10 MINUTE)
+--             #   and created_at > DATE_SUB('2022-06-07 12:10:24', INTERVAL 10 MINUTE)
+        group by sku_id, list_id;
+    </select>
 </mapper>

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/goblin/task/PlatformGoblinNftOrderController.java

+package com.liquidnet.service.platform.controller.goblin.task;
+
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.goblin.dto.PlatformGoblinNftOrderNotPayDto;
+import com.liquidnet.service.goblin.mapper.GoblinNftOrderMapper;
+import com.liquidnet.service.platform.utils.GoblinRedisUtils;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * NFT订单相关定时任务
+ *
+ * @author jiangxiulng
+ */
+@Api(tags = "NFT订单相关定时任务")
+@Slf4j
+@RestController
+@RequestMapping("task/nft/order")
+public class PlatformGoblinNftOrderController {
+    @Autowired
+    private GoblinNftOrderMapper goblinNftOrderMapper;
+    @Autowired
+    private GoblinRedisUtils goblinRedisUtils;
+
+    @ApiOperation(value = "查询待支付订单数量")
+    @GetMapping("notPayNum")
+    public ResponseDto<String> getNotPayNum() {
+        List<PlatformGoblinNftOrderNotPayDto> goblinNftOrderList = goblinNftOrderMapper.selectOrderList();
+        for (PlatformGoblinNftOrderNotPayDto notPayDto : goblinNftOrderList) {
+            goblinRedisUtils.setNotPayNum(notPayDto.getSkuId(), notPayDto.getListId(), notPayDto.getNotPayNum());
+        }
+        return ResponseDto.success("查询待支付订单完成");
+    }
+}

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/GoblinRedisUtils.java

@@ -292,6 +292,15 @@ public class GoblinRedisUtils {
 
     // 获取sku配置库存
 
+    // 设置skuId listId 代付款数量
+    public void setNotPayNum(String skuId, String listId, int notPayNum) {
+        String redisKey = GoblinRedisConst.REDIS_GOBLIN_NFT_NOT_PAY_NUM.concat(skuId);
+        if (null != listId) {
+            redisKey = redisKey.concat(":").concat(listId);
+        }
+        getRedis().set(redisKey, notPayNum);
+    }
+