交易流水列表接口实现

wisenergy-mapper/src/main/java/cn/wisenergy/mapper/TradeRecordMapper.java

@@ -8,6 +8,7 @@ import org.apache.ibatis.annotations.Param;
 
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 /**
  * @author 86187
@@ -106,4 +107,19 @@ public interface TradeRecordMapper extends BaseMapper<TradeRecord> {
      */
     Double queryByUserLevel(@Param("userLevel") Integer userLevel, @Param("yearMonth") Date yearMonth);
 
+    /**
+     * 统计交易流水总记录数
+     *
+     * @param map 入参
+     * @return 结果
+     */
+    int count( Map<String, Object> map);
+
+    /**
+     * 获取交易流水列表
+     * @param map 入参
+     * @return 结果集
+     */
+    List<TradeRecord> getList(Map<String, Object> map);
+
 }

wisenergy-mapper/src/main/resources/mapper/TradeRecordMapper.xml

@@ -201,4 +201,29 @@
         </where>
     </select>
 
+    <select id="count" resultType="java.lang.Integer">
+        select count(1)
+        from
+        <include refid="table"/>
+        <where>
+            <if test="userId != null and userId != ''">
+                user_id = #{userId}
+            </if>
+        </where>
+    </select>
+
+    <select id="getList" resultType="cn.wisenergy.model.app.TradeRecord">
+        select
+        <include refid="cols_all"/>
+        from
+        <include refid="table"/>
+        <where>
+            <if test="userId != null and userId != ''">
+                user_id = #{userId}
+            </if>
+        </where>
+        order by create_time desc
+        limit #{startNum},#{endNum}
+    </select>
+
 </mapper>
\ No newline at end of file

wisenergy-model/src/main/java/cn/wisenergy/model/dto/TradeRecordQuery.java

+package cn.wisenergy.model.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * @author 86187
+ * @ Description: 交易流水列表查询参数封装
+ * @ Author     : 86187
+ * @ Date       : 2021/3/22 14:59
+ */
+@Data
+@ApiModel("TradeRecordQuery")
+public class TradeRecordQuery {
+    /**
+     * 用户id
+     */
+    @ApiModelProperty(value = "用户id", name = "userId")
+    private String userId;
+
+    /**
+     * 页码
+     */
+    @ApiModelProperty(value = "页码", name = "pageNo")
+    private Integer pageNo;
+
+    /**
+     * 页条数
+     */
+    @ApiModelProperty(value = "页条数", name = "pageSize")
+    private Integer pageSize;
+
+
+    private Integer startNum;
+
+    private Integer endNum;
+
+}

wisenergy-service/src/main/java/cn/wisenergy/service/app/TradeRecordService.java

 package cn.wisenergy.service.app;
 
+import cn.wisenergy.common.utils.R;
+import cn.wisenergy.model.app.TradeRecord;
+import cn.wisenergy.model.dto.TradeRecordQuery;
+import com.github.pagehelper.PageInfo;
+
+import java.util.List;
+
 /**
  * @author 86187
  */
@@ -10,4 +17,12 @@ public interface TradeRecordService {
      * @return true or false
      */
     Boolean monthAwardCount();
+
+    /**
+     * 交易流水列表查询
+     *
+     * @param tradeRecordQuery 查询参数
+     * @return 列表集合
+     */
+    R<PageInfo<TradeRecord>> queryList(TradeRecordQuery tradeRecordQuery);
 }

wisenergy-service/src/main/java/cn/wisenergy/service/app/impl/TradeRecordServiceImpl.java

 package cn.wisenergy.service.app.impl;
 
+import cn.wisenergy.common.constant.CommonAttributes;
 import cn.wisenergy.common.utils.DateUtil;
+import cn.wisenergy.common.utils.R;
 import cn.wisenergy.mapper.MonthAwardMapper;
 import cn.wisenergy.mapper.MonthManureMapper;
 import cn.wisenergy.mapper.TradeRecordMapper;
 import cn.wisenergy.model.app.MonthAward;
 import cn.wisenergy.model.app.MonthManure;
 import cn.wisenergy.model.app.TradeRecord;
+import cn.wisenergy.model.dto.TradeRecordQuery;
 import cn.wisenergy.model.enums.UserLevelEnum;
 import cn.wisenergy.service.app.TradeRecordService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.pagehelper.PageInfo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 /**
  * @author 86187
@@ -28,6 +35,9 @@ public class TradeRecordServiceImpl extends ServiceImpl<TradeRecordMapper, Trade
     @Autowired
     private MonthAwardMapper monthAwardMapper;
 
+    @Autowired
+    private TradeRecordMapper tradeRecordMapper;
+
     @Override
     public Boolean monthAwardCount() {
         MonthAward result = new MonthAward();
@@ -89,4 +99,50 @@ public class TradeRecordServiceImpl extends ServiceImpl<TradeRecordMapper, Trade
             return count != 0;
         }
     }
+
+    @Override
+    public R<PageInfo<TradeRecord>> queryList(TradeRecordQuery query) {
+        log.info("shop-mall[]TradeRecordServiceImpl[]queryList[]input.param.query:" + query);
+        if (null == query) {
+            return R.error("入参不能为空!");
+        }
+
+        pageHandle(query);
+
+        Map<String, Object> map = new HashMap<>(8);
+        map.put("userId", query.getUserId());
+        int total = tradeRecordMapper.count(map);
+
+        map.put("startNum", query.getStartNum());
+        map.put("endNum", query.getEndNum());
+        List<TradeRecord> list = tradeRecordMapper.getList(map);
+        PageInfo<TradeRecord> info = new PageInfo<>();
+        info.setPageSize(query.getPageSize());
+        info.setPageNum(query.getPageNo());
+        info.setTotal(total);
+        info.setList(list);
+        return R.ok(info);
+    }
+
+    /**
+     * 分页处理方法
+     *
+     * @param schemeVo 参数
+     */
+    private void pageHandle(TradeRecordQuery schemeVo) {
+        Integer pageNum = schemeVo.getPageNo();
+        Integer pageSize = schemeVo.getPageSize();
+        if (null == pageSize || pageSize == 0) {
+            pageSize = 10;
+        }
+        if (null == pageNum || pageNum == 0) {
+            pageNum = 1;
+        }
+        Integer endNum = pageSize;
+        Integer startNum = (pageNum - CommonAttributes.NUM_ONE) * pageSize;
+        schemeVo.setEndNum(endNum);
+        schemeVo.setStartNum(startNum);
+        schemeVo.setPageNo(pageNum);
+        schemeVo.setPageSize(pageSize);
+    }
 }

wisenergy-web-admin/src/main/java/cn/wisenergy/web/admin/controller/app/TradeRecordController.java

+package cn.wisenergy.web.admin.controller.app;
+
+import cn.wisenergy.common.utils.R;
+import cn.wisenergy.model.app.TradeRecord;
+import cn.wisenergy.model.dto.TradeRecordQuery;
+import cn.wisenergy.model.vo.TaxRateVo;
+import cn.wisenergy.service.app.TradeRecordService;
+import com.github.pagehelper.PageInfo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+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;
+
+/**
+ * @author 86187
+ */
+@Api(tags = "交易流水-后台管理")
+@RestController
+@RequestMapping("/trade")
+@Slf4j
+public class TradeRecordController {
+    @Autowired
+    private TradeRecordService tradeRecordService;
+
+    @ApiOperation(value = "交易流水列表", notes = "交易流水列表", httpMethod = "GET")
+    @ApiImplicitParam(name = "query", value = "查询参数", dataType = "TradeRecordQuery")
+    @GetMapping("/queryList")
+    public R<PageInfo<TradeRecord>> queryList(TradeRecordQuery query) {
+        log.info("shop-mall[]TradeRecordController[]queryList[]input.param.query:" + query);
+        return tradeRecordService.queryList(query);
+    }
+}