迭代需求

src/main/java/com/mokamrp/privates/controller/pangu/FosterwxFlowListController.java

@@ -0,0 +1,52 @@
+package com.mokamrp.privates.controller.pangu;
+
+import com.mokamrp.privates.constant.HttpStatus;
+import com.mokamrp.privates.controller.BaseController;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.help.AjaxResult;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxFlowList;
+import com.mokamrp.privates.service.pangu.FosterwxFlowListService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Map;
+
+
+/**
+ * <p>
+ * 盘古个微池时段列表 前端控制器
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+@RestController
+@RequestMapping("/pangu/fosterwxFlowList")
+public class FosterwxFlowListController extends BaseController<FosterwxFlowList> {
+
+    @Autowired
+    public FosterwxFlowListService fosterwxFlowListService;
+
+    /*
+     * @fast
+     * 默认生成的控制器所继承的父类中有index/add/edit/del四个基础方法,均为post json请求
+     * 如果需要定制化，需要将BaseController中对应的方法复制到当前控制器,然后进行修改
+     */
+
+    @PostMapping("/list")
+    public Object list(@Valid @RequestBody PostBasePageHandle postBasePageHandle, BindingResult bindingResult) {
+        if (bindingResult.hasErrors()) {
+            return AjaxResult.error(HttpStatus.ERROR, bindingResult.getFieldError().getDefaultMessage());
+        }
+        Map<String, Object> res = fosterwxFlowListService.getList(postBasePageHandle);
+        return AjaxResult.success(res);
+    }
+
+
+}
+

src/main/java/com/mokamrp/privates/controller/pangu/FosterwxMobileController.java

@@ -14,6 +14,7 @@ import com.mokamrp.privates.help.AjaxResult;
 import com.mokamrp.privates.help.Analysis;
 import com.mokamrp.privates.interceptor.AuthUser;
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobile;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobilePool;
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobileWxfriend;
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxStation;
 import com.mokamrp.privates.mapper.pojo.User;
@@ -26,11 +27,7 @@ import org.springframework.web.multipart.MultipartFile;
 
 import javax.validation.Valid;
 import java.time.LocalDateTime;
-import java.util.ArrayList;
-import java.util.Calendar;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 
 /**
@@ -57,6 +54,9 @@ public class FosterwxMobileController extends BaseController<FosterwxMobile> {
     @Autowired
     private FosterwxTaskScheduleService fosterwxTaskScheduleService;
 
+    @Autowired
+    private FosterwxMobilePoolService fosterwxMobilePoolService;
+
     /*
      * @fast
      * 默认生成的控制器所继承的父类中有index/add/edit/del四个基础方法,均为post json请求
@@ -303,7 +303,120 @@ public class FosterwxMobileController extends BaseController<FosterwxMobile> {
         } catch (Exception e) {
             return AjaxResult.error(e.getMessage());
         }
-        Boolean res = fosterwxMobileService.importData(row,authUser);
+        Boolean res = fosterwxMobileService.importData(row, authUser);
+        return AjaxResult.success(HttpMsg.importSuccess);
+    }
+
+
+    /**
+     * 设置账号个微二维码
+     * @param editHandle
+     * @param bindingResult
+     * @return
+     */
+    @PostMapping("/setCodeUrl")
+    public Object setCodeUrl(
+            @Valid @RequestBody EditHandle<FosterwxMobile> editHandle, BindingResult bindingResult) {
+        if (bindingResult.hasErrors()) {
+            return AjaxResult.error(HttpStatus.ERROR, bindingResult.getFieldError().getDefaultMessage());
+        }
+        //.登录验证
+        this.onUpdate(editHandle);
+        fosterwxMobileService.update(editHandle.getRaw(),
+                new QueryWrapper<FosterwxMobile>()
+                        .eq("mobile_unio_code", editHandle.getRaw().getMobileUnioCode()));
+        return AjaxResult.success(Constants.SUCCESS, true);
+    }
+
+
+    /**
+     * 导入个微池
+     * @param fosterwxMobileList
+     * @param authUser
+     * @return
+     */
+    @PostMapping("/loadPool")
+    @Transactional(rollbackFor = Exception.class)
+    public Object loadPool(
+            @Valid @RequestBody List<FosterwxMobile> fosterwxMobileList, @AuthUser User authUser) {
+        StringBuffer sb = new StringBuffer();
+        fosterwxMobileList.forEach(fosterwxMobile -> {
+            LambdaQueryWrapper<FosterwxMobilePool> fosterwxMobilePoolLambdaQueryWrapper = new LambdaQueryWrapper<>();
+            fosterwxMobilePoolLambdaQueryWrapper.eq(FosterwxMobilePool::getPoolIndex, fosterwxMobile.getMobileUnioCode());
+
+            if (fosterwxMobilePoolService.getOne(fosterwxMobilePoolLambdaQueryWrapper) != null) {
+                sb.append(fosterwxMobile.getMobileUnioCode() + "已经导入个微池中了，不能重复导入!<br>");
+            }
+        });
+
+        if (sb.length() > 0) {
+            return AjaxResult.error(sb.toString());
+        }
+        fosterwxMobileList.forEach(fosterwxMobile -> {
+            FosterwxMobilePool fosterwxMobilePool = new FosterwxMobilePool();
+            fosterwxMobilePool.setPoolIndex(fosterwxMobile.getMobileUnioCode());
+            fosterwxMobilePool.setStationId(fosterwxMobile.getStationId());
+            FosterwxStation fosterwxStation = fosterwxStationService.getById(fosterwxMobile.getStationId());
+            fosterwxMobilePool.setStationName(fosterwxStation.getStationName());
+            fosterwxMobilePool.setMobileCode(fosterwxMobile.getMobileCode());
+            fosterwxMobilePool.setMobileNo(fosterwxMobile.getMobileNo());
+            fosterwxMobilePool.setCodeUrl(fosterwxMobile.getCodeUrl());
+            fosterwxMobilePool.setStatus(1);
+            fosterwxMobilePool.setMaxFans("");
+            fosterwxMobilePool.setBusMobileNo(fosterwxMobile.getMobileNo());
+            fosterwxMobilePool.setFlowPosition("");
+            fosterwxMobilePool.setCreateUid(authUser.getId());
+            fosterwxMobilePool.setUpdateUid(authUser.getId());
+            fosterwxMobilePool.setCreateAt(LocalDateTime.now());
+            fosterwxMobilePool.setUpdateAt(LocalDateTime.now());
+
+            fosterwxMobilePoolService.save(fosterwxMobilePool);
+        });
+
+        return AjaxResult.success("导入成功");
+    }
+
+    /**
+     * 导入
+     *
+     * @param file
+     * @return
+     */
+    @PostMapping("/importCode")
+    @Transactional(rollbackFor = Exception.class)
+    public Object uploadFile(@RequestBody MultipartFile file) {
+        Map<Integer, String> field = new HashMap<>(2);
+        field.put(0, "mobileUnioCode");
+        field.put(1, "codeUrl");
+        List<Map<String, String>> row;
+        try {
+            row = Analysis.analysis(file, field);
+        } catch (Exception e) {
+            return AjaxResult.error(e.getMessage());
+        }
+
+        StringBuffer sb = new StringBuffer();
+        row.forEach(map -> {
+            LambdaQueryWrapper<FosterwxMobile> fosterwxMobileLambdaQueryWrapper = new LambdaQueryWrapper<>();
+            fosterwxMobileLambdaQueryWrapper.eq(FosterwxMobile::getMobileCode, map.get("mobileUnioCode"));
+            // 手机唯一编码不存在
+            if (fosterwxMobileService.count(fosterwxMobileLambdaQueryWrapper) == 0)
+                sb.append("手机唯一编码:" + map.get("mobileUnioCode") + "不存在<br>");
+        });
+
+        if (sb.length() > 0) return AjaxResult.error(sb.toString());
+
+        row.forEach(map -> {
+            LambdaQueryWrapper<FosterwxMobile> fosterwxMobileLambdaQueryWrapper = new LambdaQueryWrapper<>();
+            fosterwxMobileLambdaQueryWrapper.eq(FosterwxMobile::getMobileCode, map.get("mobileUnioCode"));
+
+            FosterwxMobile updateVO = new FosterwxMobile();
+            updateVO.setCodeUrl(map.get("codeUrl"));
+            updateVO.setUpdateAt(LocalDateTime.now());
+
+            fosterwxMobileService.update(updateVO, fosterwxMobileLambdaQueryWrapper);
+        });
+
         return AjaxResult.success(HttpMsg.importSuccess);
     }
 }

src/main/java/com/mokamrp/privates/controller/pangu/FosterwxMobilePoolController.java

@@ -0,0 +1,70 @@
+package com.mokamrp.privates.controller.pangu;
+
+import com.mokamrp.privates.constant.HttpStatus;
+import com.mokamrp.privates.controller.BaseController;
+import com.mokamrp.privates.entity.EditHandle;
+import com.mokamrp.privates.entity.pangu.FosterwxMobilePoolHandle;
+import com.mokamrp.privates.help.AjaxResult;
+import com.mokamrp.privates.interceptor.AuthUser;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobilePool;
+import com.mokamrp.privates.mapper.pojo.User;
+import com.mokamrp.privates.service.pangu.FosterwxMobilePoolService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Arrays;
+import java.util.Map;
+
+
+/**
+ * <p>
+ * 盘古个微池 前端控制器
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+@RestController
+@RequestMapping("/pangu/fosterwxMobilePool")
+public class FosterwxMobilePoolController extends BaseController<FosterwxMobilePool> {
+
+    @Autowired
+    public FosterwxMobilePoolService fosterwxMobilePoolService;
+
+    /*
+     * @fast
+     * 默认生成的控制器所继承的父类中有index/add/edit/del四个基础方法,均为post json请求
+     * 如果需要定制化，需要将BaseController中对应的方法复制到当前控制器,然后进行修改
+     */
+
+    @PostMapping("/list")
+    public Object list(@Valid @RequestBody FosterwxMobilePoolHandle fosterwxMobilePoolHandle, BindingResult bindingResult) {
+        if (bindingResult.hasErrors()) {
+            return AjaxResult.error(HttpStatus.ERROR, bindingResult.getFieldError().getDefaultMessage());
+        }
+        Map<String, Object> res = fosterwxMobilePoolService.getList(fosterwxMobilePoolHandle);
+        return AjaxResult.success(res);
+    }
+
+    @PostMapping("/editPro")
+    @Transactional(rollbackFor = Exception.class)
+    public Object add(@Valid @RequestBody EditHandle<FosterwxMobilePool> editHandle, @AuthUser User authUser) {
+        Arrays.asList(editHandle.getIds().split(",")).forEach(id -> {
+            this.onUpdate(editHandle);
+            editHandle.getRaw().setId(Integer.valueOf(id));
+
+            fosterwxMobilePoolService.updateById(editHandle.getRaw());
+        });
+
+        return AjaxResult.success("新增成功！");
+    }
+
+
+}
+

src/main/java/com/mokamrp/privates/entity/pangu/FosterwxMobilePoolHandle.java

@@ -0,0 +1,16 @@
+package com.mokamrp.privates.entity.pangu;
+
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+
+@Data
+public class FosterwxMobilePoolHandle extends Model<FosterwxMobilePoolHandle> {
+    private Integer page;
+    private Integer pageSize;
+    private Integer id;
+    private String poolIndex;
+    private String stationName;
+    private String mobileNo;
+    private Integer status;
+    private String flowPosition;
+}

src/main/java/com/mokamrp/privates/mapper/pangu/FosterwxFlowListMapper.java

@@ -0,0 +1,21 @@
+package com.mokamrp.privates.mapper.pangu;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxFlowList;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 盘古个微池时段列表 Mapper 接口
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+@Component
+public interface FosterwxFlowListMapper extends BaseMapper<FosterwxFlowList> {
+    public List<FosterwxFlowList> getList(Page<FosterwxFlowList> pageObj);
+}

src/main/java/com/mokamrp/privates/mapper/pangu/FosterwxFlowListMapper.xml

@@ -0,0 +1,28 @@
+<?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="com.mokamrp.privates.mapper.pangu.FosterwxFlowListMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.mokamrp.privates.mapper.pangu.pojo.FosterwxFlowList">
+        <id column="id" property="id"/>
+        <result column="time_line" property="timeLine"/>
+        <result column="flow_position" property="flowPosition"/>
+        <result column="bus_fans" property="busFans"/>
+        <result column="feeder_id" property="feederId"/>
+        <result column="status" property="status"/>
+        <result column="create_uid" property="createUid"/>
+        <result column="update_uid" property="updateUid"/>
+        <result column="create_at" property="createAt"/>
+        <result column="update_at" property="updateAt"/>
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id
+        , time_line, flow_position, bus_fans, feeder_id, status, create_uid, update_uid, create_at, update_at
+    </sql>
+    <select id="getList" resultType="com.mokamrp.privates.mapper.pangu.pojo.FosterwxFlowList">
+        SELECT *
+        FROM pan_fosterwx_flow_list
+    </select>
+</mapper>

src/main/java/com/mokamrp/privates/mapper/pangu/FosterwxMobileMapper.xml

@@ -22,12 +22,14 @@
         <result column="wx_real_name" property="wxRealName" />
         <result column="wx_identity_card_no" property="wxIdentityCardNo" />
         <result column="wx_register_at" property="wxRegisterAt" />
+        <result column="wx_appid" property="wxAppid"/>
         <result column="bank_card_no" property="bankCardNo" />
         <result column="bank_card_mobile_no" property="bankCardMobileNo" />
         <result column="work_wx_corp" property="workWxCorp" />
         <result column="work_wx_register_at" property="workWxRegisterAt" />
         <result column="work_wx_status" property="workWxStatus" />
         <result column="task_start_at" property="taskStartAt" />
+        <result column="code_url" property="codeUrl"/>
         <result column="create_at" property="createAt" />
         <result column="update_at" property="updateAt" />
     </resultMap>
@@ -35,7 +37,7 @@
     <!-- 通用查询结果列 -->
     <sql id="Base_Column_List">
         id
-        , station_id, mobile_code, mobile_unio_code, mobile_no, mobile_operator, mobile_create_at, mobile_advance_pay_amt, mobile_combo, mobile_combo_flow, mobile_real_name, mobile_identity_card_no, status, wx_status, wx_password, wx_real_name, wx_identity_card_no, wx_register_at, bank_card_no, bank_card_mobile_no, work_wx_corp, work_wx_register_at, work_wx_status, task_start_at, create_at, update_at
+        , station_id, mobile_code, mobile_unio_code, mobile_no, mobile_operator, mobile_create_at, mobile_advance_pay_amt, mobile_combo, mobile_combo_flow, mobile_real_name, mobile_identity_card_no, status, wx_status, wx_password, wx_real_name, wx_identity_card_no, wx_register_at, wx_appid, bank_card_no, bank_card_mobile_no, work_wx_corp, work_wx_register_at, work_wx_status, task_start_at, code_url, create_at, update_at
     </sql>
     <select id="getList" resultType="com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobile">
         SELECT * FROM pan_fosterwx_mobile

src/main/java/com/mokamrp/privates/mapper/pangu/FosterwxMobilePoolMapper.java

@@ -0,0 +1,21 @@
+package com.mokamrp.privates.mapper.pangu;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobilePool;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 盘古个微池 Mapper 接口
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+@Component
+public interface FosterwxMobilePoolMapper extends BaseMapper<FosterwxMobilePool> {
+    public List<FosterwxMobilePool> getList(Page<FosterwxMobilePool> pageObj);
+}

src/main/java/com/mokamrp/privates/mapper/pangu/FosterwxMobilePoolMapper.xml

@@ -0,0 +1,33 @@
+<?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="com.mokamrp.privates.mapper.pangu.FosterwxMobilePoolMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobilePool">
+        <id column="id" property="id"/>
+        <result column="pool_index" property="poolIndex"/>
+        <result column="station_id" property="stationId"/>
+        <result column="station_name" property="stationName"/>
+        <result column="mobile_code" property="mobileCode"/>
+        <result column="mobile_no" property="mobileNo"/>
+        <result column="code_url" property="codeUrl"/>
+        <result column="status" property="status"/>
+        <result column="max_fans" property="maxFans"/>
+        <result column="bus_mobile_no" property="busMobileNo"/>
+        <result column="flow_position" property="flowPosition"/>
+        <result column="create_uid" property="createUid"/>
+        <result column="update_uid" property="updateUid"/>
+        <result column="create_at" property="createAt"/>
+        <result column="update_at" property="updateAt"/>
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id
+        , pool_index, station_id, station_name, mobile_code, mobile_no, code_url, status, max_fans, bus_mobile_no, flow_position, create_uid, update_uid, create_at, update_at
+    </sql>
+    <select id="getList" resultType="com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobilePool">
+        SELECT *
+        FROM pan_fosterwx_mobile_pool
+    </select>
+</mapper>

src/main/java/com/mokamrp/privates/mapper/pangu/pojo/FosterwxFlowList.java

@@ -0,0 +1,176 @@
+package com.mokamrp.privates.mapper.pangu.pojo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 盘古个微池时段列表
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+@TableName("pan_fosterwx_flow_list")
+public class FosterwxFlowList extends Model<FosterwxFlowList> {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 时间线
+     */
+    private LocalDateTime timeLine;
+
+    /**
+     * 流量位置
+     */
+    private String flowPosition;
+
+    /**
+     * 企微进粉数
+     */
+    private Integer busFans;
+
+    /**
+     * 供给记录ID
+     */
+    private Integer feederId;
+
+    /**
+     * 状态(1正常0超限)
+     */
+    private Integer status;
+
+    /**
+     * 创建人
+     */
+    private Integer createUid;
+
+    /**
+     * 更新人
+     */
+    private Integer updateUid;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updateAt;
+
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public LocalDateTime getTimeLine() {
+        return timeLine;
+    }
+
+    public void setTimeLine(LocalDateTime timeLine) {
+        this.timeLine = timeLine;
+    }
+
+    public String getFlowPosition() {
+        return flowPosition;
+    }
+
+    public void setFlowPosition(String flowPosition) {
+        this.flowPosition = flowPosition;
+    }
+
+    public Integer getBusFans() {
+        return busFans;
+    }
+
+    public void setBusFans(Integer busFans) {
+        this.busFans = busFans;
+    }
+
+    public Integer getFeederId() {
+        return feederId;
+    }
+
+    public void setFeederId(Integer feederId) {
+        this.feederId = feederId;
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public Integer getCreateUid() {
+        return createUid;
+    }
+
+    public void setCreateUid(Integer createUid) {
+        this.createUid = createUid;
+    }
+
+    public Integer getUpdateUid() {
+        return updateUid;
+    }
+
+    public void setUpdateUid(Integer updateUid) {
+        this.updateUid = updateUid;
+    }
+
+    public LocalDateTime getCreateAt() {
+        return createAt;
+    }
+
+    public void setCreateAt(LocalDateTime createAt) {
+        this.createAt = createAt;
+    }
+
+    public LocalDateTime getUpdateAt() {
+        return updateAt;
+    }
+
+    public void setUpdateAt(LocalDateTime updateAt) {
+        this.updateAt = updateAt;
+    }
+
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+
+    @Override
+    public String toString() {
+        return "FosterwxFlowList{" +
+                "id=" + id +
+                ", timeLine=" + timeLine +
+                ", flowPosition=" + flowPosition +
+                ", busFans=" + busFans +
+                ", feederId=" + feederId +
+                ", status=" + status +
+                ", createUid=" + createUid +
+                ", updateUid=" + updateUid +
+                ", createAt=" + createAt +
+                ", updateAt=" + updateAt +
+                "}";
+    }
+}

src/main/java/com/mokamrp/privates/mapper/pangu/pojo/FosterwxMobilePool.java

@@ -0,0 +1,246 @@
+package com.mokamrp.privates.mapper.pangu.pojo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 盘古个微池
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+@TableName("pan_fosterwx_mobile_pool")
+public class FosterwxMobilePool extends Model<FosterwxMobilePool> {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 池唯一码（站点id+手机编号）
+     */
+    private String poolIndex;
+
+    /**
+     * 站点id(pan_fosterwx_station.id)
+     */
+    private Integer stationId;
+
+    /**
+     * 站点名称
+     */
+    private String stationName;
+
+    /**
+     * 手机编号
+     */
+    private Integer mobileCode;
+
+    /**
+     * 手机号码
+     */
+    private String mobileNo;
+
+    /**
+     * 个微二维码
+     */
+    private String codeUrl;
+
+    /**
+     * 状态(二维码状态，0停用 1待使用 2使用中)
+     */
+    private Integer status;
+
+    /**
+     * 每天进粉阈值
+     */
+    private String maxFans;
+
+    /**
+     * 企微客服手机号（冗余）
+     */
+    private String busMobileNo;
+
+    /**
+     * 流量位置
+     */
+    private String flowPosition;
+
+    /**
+     * 创建人
+     */
+    private Integer createUid;
+
+    /**
+     * 更新人
+     */
+    private Integer updateUid;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updateAt;
+
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getPoolIndex() {
+        return poolIndex;
+    }
+
+    public void setPoolIndex(String poolIndex) {
+        this.poolIndex = poolIndex;
+    }
+
+    public Integer getStationId() {
+        return stationId;
+    }
+
+    public void setStationId(Integer stationId) {
+        this.stationId = stationId;
+    }
+
+    public String getStationName() {
+        return stationName;
+    }
+
+    public void setStationName(String stationName) {
+        this.stationName = stationName;
+    }
+
+    public Integer getMobileCode() {
+        return mobileCode;
+    }
+
+    public void setMobileCode(Integer mobileCode) {
+        this.mobileCode = mobileCode;
+    }
+
+    public String getMobileNo() {
+        return mobileNo;
+    }
+
+    public void setMobileNo(String mobileNo) {
+        this.mobileNo = mobileNo;
+    }
+
+    public String getCodeUrl() {
+        return codeUrl;
+    }
+
+    public void setCodeUrl(String codeUrl) {
+        this.codeUrl = codeUrl;
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public String getMaxFans() {
+        return maxFans;
+    }
+
+    public void setMaxFans(String maxFans) {
+        this.maxFans = maxFans;
+    }
+
+    public String getBusMobileNo() {
+        return busMobileNo;
+    }
+
+    public void setBusMobileNo(String busMobileNo) {
+        this.busMobileNo = busMobileNo;
+    }
+
+    public String getFlowPosition() {
+        return flowPosition;
+    }
+
+    public void setFlowPosition(String flowPosition) {
+        this.flowPosition = flowPosition;
+    }
+
+    public Integer getCreateUid() {
+        return createUid;
+    }
+
+    public void setCreateUid(Integer createUid) {
+        this.createUid = createUid;
+    }
+
+    public Integer getUpdateUid() {
+        return updateUid;
+    }
+
+    public void setUpdateUid(Integer updateUid) {
+        this.updateUid = updateUid;
+    }
+
+    public LocalDateTime getCreateAt() {
+        return createAt;
+    }
+
+    public void setCreateAt(LocalDateTime createAt) {
+        this.createAt = createAt;
+    }
+
+    public LocalDateTime getUpdateAt() {
+        return updateAt;
+    }
+
+    public void setUpdateAt(LocalDateTime updateAt) {
+        this.updateAt = updateAt;
+    }
+
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+
+    @Override
+    public String toString() {
+        return "FosterwxMobilePool{" +
+                "id=" + id +
+                ", poolIndex=" + poolIndex +
+                ", stationId=" + stationId +
+                ", stationName=" + stationName +
+                ", mobileCode=" + mobileCode +
+                ", mobileNo=" + mobileNo +
+                ", codeUrl=" + codeUrl +
+                ", status=" + status +
+                ", maxFans=" + maxFans +
+                ", busMobileNo=" + busMobileNo +
+                ", flowPosition=" + flowPosition +
+                ", createUid=" + createUid +
+                ", updateUid=" + updateUid +
+                ", createAt=" + createAt +
+                ", updateAt=" + updateAt +
+                "}";
+    }
+}

src/main/java/com/mokamrp/privates/service/pangu/FosterwxFlowListService.java

@@ -0,0 +1,20 @@
+package com.mokamrp.privates.service.pangu;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxFlowList;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古个微池时段列表 服务类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+public interface FosterwxFlowListService extends IService<FosterwxFlowList> {
+    //.@leon 获取数据列表
+    public Map<String, Object> getList(PostBasePageHandle handle);
+}

src/main/java/com/mokamrp/privates/service/pangu/FosterwxMobilePoolService.java

@@ -0,0 +1,20 @@
+package com.mokamrp.privates.service.pangu;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.mokamrp.privates.entity.pangu.FosterwxMobilePoolHandle;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobilePool;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古个微池 服务类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+public interface FosterwxMobilePoolService extends IService<FosterwxMobilePool> {
+    //.@leon 获取数据列表
+    public Map<String, Object> getList(FosterwxMobilePoolHandle handle);
+}

src/main/java/com/mokamrp/privates/service/pangu/impl/FosterwxFlowListServiceImpl.java

@@ -0,0 +1,45 @@
+package com.mokamrp.privates.service.pangu.impl;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.mapper.pangu.FosterwxFlowListMapper;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxFlowList;
+import com.mokamrp.privates.service.pangu.FosterwxFlowListService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古个微池时段列表 服务实现类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+@Service
+public class FosterwxFlowListServiceImpl extends ServiceImpl<FosterwxFlowListMapper, FosterwxFlowList> implements FosterwxFlowListService {
+
+    @Autowired
+    public FosterwxFlowListMapper fosterwxFlowListMapper;
+
+    /**
+     * 获取数据列表 支持分页
+     * @param handle
+     * @return
+     */
+    public Map<String, Object> getList(PostBasePageHandle handle) {
+        Integer pagesize = handle.getPagesize();
+        Integer page = handle.getPage();
+        Page<FosterwxFlowList> pageObj = new Page<FosterwxFlowList>(page, pagesize);
+        List<FosterwxFlowList> list = fosterwxFlowListMapper.getList(pageObj);
+        Map<String, Object> resMap = new HashMap<String, Object>();
+        resMap.put("list", list);
+        resMap.put("total", pageObj.getTotal());
+        return resMap;
+    }
+}

src/main/java/com/mokamrp/privates/service/pangu/impl/FosterwxMobilePoolServiceImpl.java

@@ -0,0 +1,62 @@
+package com.mokamrp.privates.service.pangu.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mokamrp.privates.entity.pangu.FosterwxMobilePoolHandle;
+import com.mokamrp.privates.mapper.pangu.FosterwxMobilePoolMapper;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobilePool;
+import com.mokamrp.privates.service.pangu.FosterwxMobilePoolService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古个微池 服务实现类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-30
+ */
+@Service
+public class FosterwxMobilePoolServiceImpl extends ServiceImpl<FosterwxMobilePoolMapper, FosterwxMobilePool> implements FosterwxMobilePoolService {
+
+    @Autowired
+    public FosterwxMobilePoolMapper fosterwxMobilePoolMapper;
+
+    /**
+     * 获取数据列表 支持分页
+     * @param handle
+     * @return
+     */
+    public Map<String, Object> getList(FosterwxMobilePoolHandle handle) {
+        Integer pageSize = handle.getPageSize();
+        Integer page = handle.getPage();
+        Page<FosterwxMobilePool> pageObj = new Page<>(page, pageSize);
+        LambdaQueryWrapper<FosterwxMobilePool> fosterwxMobilePoolLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        if (null != handle.getId()) fosterwxMobilePoolLambdaQueryWrapper.eq(FosterwxMobilePool::getId, handle.getId());
+        if (null != handle.getPoolIndex() && !handle.getPoolIndex().isEmpty()) {
+            fosterwxMobilePoolLambdaQueryWrapper.in(FosterwxMobilePool::getPoolIndex, Arrays.asList(handle.getPoolIndex().split(" ")));
+        }
+        if (null != handle.getStationName() && !handle.getStationName().isEmpty())
+            fosterwxMobilePoolLambdaQueryWrapper.like(FosterwxMobilePool::getStationName, handle.getStationName());
+        if (null != handle.getMobileNo() && !handle.getMobileNo().isEmpty())
+            fosterwxMobilePoolLambdaQueryWrapper.eq(FosterwxMobilePool::getMobileNo, handle.getMobileNo());
+        if (null != handle.getStatus())
+            fosterwxMobilePoolLambdaQueryWrapper.eq(FosterwxMobilePool::getStatus, handle.getStatus());
+        if (null != handle.getFlowPosition() && !handle.getFlowPosition().isEmpty())
+            fosterwxMobilePoolLambdaQueryWrapper.like(FosterwxMobilePool::getFlowPosition, handle.getFlowPosition());
+        fosterwxMobilePoolLambdaQueryWrapper.orderByDesc(FosterwxMobilePool::getId);
+
+        pageObj = fosterwxMobilePoolMapper.selectPage(pageObj, fosterwxMobilePoolLambdaQueryWrapper);
+
+        Map<String, Object> resMap = new HashMap<String, Object>();
+        resMap.put("list", pageObj.getRecords());
+        resMap.put("total", pageObj.getTotal());
+        return resMap;
+    }
+}