新增vcc捞数据

src/main/java/cn/qg/qaplatform/controller/QueryVccController.java

+package cn.qg.qaplatform.controller;
+
+import cn.qg.qaplatform.common.JsonResult;
+import cn.qg.qaplatform.domain.QueryVccUser;
+import cn.qg.qaplatform.service.VccDataService;
+import cn.qg.qaplatform.utils.page.PageResult;
+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.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/vcc")
+public class QueryVccController {
+
+    @Autowired
+    VccDataService vccDataService;
+
+    @GetMapping("/getData")
+    public JsonResult getVccData(@RequestParam(value = "namespace") String namespace,
+                                 @RequestParam(value = "status") Integer status,
+                                 @RequestParam(defaultValue = "1") Integer pageNum,
+                                 @RequestParam(defaultValue = "10") Integer pageSize) {
+        PageResult vccData = vccDataService.getVccData(namespace, status, pageNum, pageSize);
+        return JsonResult.success(vccData);
+    }
+}

src/main/java/cn/qg/qaplatform/dao/QueryVccDataMapper.java

+package cn.qg.qaplatform.dao;
+
+import cn.qg.qaplatform.domain.QueryVccUser;
+
+import java.util.List;
+import java.util.Map;
+
+public interface QueryVccDataMapper {
+    /**
+     * 根据状态获取vcc用户
+     */
+    List<QueryVccUser> queryVccDataByStatus(Integer status);
+}

src/main/java/cn/qg/qaplatform/domain/QueryVccUser.java

+package cn.qg.qaplatform.domain;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 捞数据返回的享花卡用户实体类
+ */
+@Data
+public class QueryVccUser {
+    public String phoneNo;
+
+    public String userId;
+
+    public String uuid;
+
+    /**
+     * 注册渠道
+     */
+    public Long registeredFrom;
+
+    /**
+     * 过期时间
+     */
+    public Date nextApplyTime;
+
+    /**
+     * 创建时间
+     */
+    public Date createdAt;
+}

src/main/java/cn/qg/qaplatform/service/VccDataService.java

 package cn.qg.qaplatform.service;
 
 import cn.qg.qaplatform.domain.GenVccUser;
+import cn.qg.qaplatform.utils.page.PageResult;
 
 
+/**
+ * Vcc捞数据和造数据
+ * @author libo
+ */
 public interface VccDataService {
     GenVccUser makeVccUser(String namespace, String phoneNo, String openedChannel, Integer status) throws Exception;
+
+    PageResult getVccData(String namespace, Integer status, Integer pageNum, Integer pageSize);
 }

src/main/java/cn/qg/qaplatform/service/impl/VccDataServiceImpl.java

 package cn.qg.qaplatform.service.impl;
 
+import cn.qg.qaplatform.common.SwitchDataSource;
+import cn.qg.qaplatform.dao.QueryVccDataMapper;
 import cn.qg.qaplatform.domain.GenVccUser;
+import cn.qg.qaplatform.domain.QueryVccUser;
 import cn.qg.qaplatform.process.Vcc;
 import cn.qg.qaplatform.service.VccDataService;
+import cn.qg.qaplatform.utils.page.PageResult;
+import cn.qg.qaplatform.utils.page.PageUtil;
 import com.alibaba.fastjson.JSONObject;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
 import java.util.Map;
 
 
 @Service
 public class VccDataServiceImpl implements VccDataService {
 
+    @Autowired
+    QueryVccDataMapper queryVccDataMapper;
+
     /**
-     * @param namespace
-     * @param phoneNo
-     * @param openedChannel
+     * vcc造数据
+     * @param namespace 环境
+     * @param phoneNo 手机号
+     * @param openedChannel 创建渠道
      * @param status 0-未激活，1-已激活
      * @return
      * @throws Exception
@@ -93,4 +106,20 @@ public class VccDataServiceImpl implements VccDataService {
         }
         return genVccUser;
     }
+
+    /**
+     * vcc捞数据
+     * @param namespace 环境
+     * @param status 状态
+     * @return
+     */
+    @Override
+    public PageResult getVccData(String namespace, Integer status, Integer pageNum, Integer pageSize) {
+        SwitchDataSource.dataSourceSwitch(namespace, "vcc_talos");
+        PageHelper.startPage(pageNum, pageSize);
+        List<QueryVccUser> result =  queryVccDataMapper.queryVccDataByStatus(status);
+        PageInfo<QueryVccUser> pageList = new PageInfo<>(result);
+        PageResult pageResult = PageUtil.getPageResult(pageList, pageNum, pageSize);
+        return pageResult;
+    }
 }

src/main/resources/mapper/QueryVccDataMapper.xml

+<?xml version="1.0" encoding="utf-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="cn.qg.qaplatform.dao.QueryVccDataMapper">
+
+    <select id="queryVccDataByStatus" resultType="cn.qg.qaplatform.domain.QueryVccUser">
+        select
+        `phone_no` as phoneNo,
+        `user_id` as userId,
+        `uuid`,
+        `registered_from` as registeredFrom,
+        `next_apply_time` as nextApplyTime,
+        `created_at` as createdAt
+        from account
+         <where>
+             status = #{status} and `type` = 'xyqb_mall'
+         </where>
+         order by id desc
+    </select>
+</mapper>
\ No newline at end of file