From f2b9497a003c576e1a18d813fa2abdc9ec91edb9 Mon Sep 17 00:00:00 2001
From: caiyuchao <caiyuchao@agrandtech.com>
Date: Fri, 3 Jan 2025 14:56:46 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=E5=AE=A2=E6=88=B7?=
 =?UTF-8?q?=E5=B9=B3=E5=8F=B0-=E8=AF=9D=E5=8D=95=E7=AE=A1=E7=90=86?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../wfc/system/controller/UCdrController.java | 43 ++++++++++++
 .../main/java/org/wfc/system/domain/UCdr.java | 66 +++++++++++++++++++
 .../system/domain/vo/UCdrHistoryUserVo.java   | 22 +++++++
 .../org/wfc/system/mapper/UCdrMapper.java     | 24 +++++++
 .../org/wfc/system/service/IUCdrService.java  | 20 ++++++
 .../system/service/impl/UCdrServiceImpl.java  | 27 ++++++++
 .../resources/mapper/system/UCdrMapper.xml    | 37 +++++++++++
 7 files changed, 239 insertions(+)
 create mode 100644 wfc-modules/wfc-system/src/main/java/org/wfc/system/controller/UCdrController.java
 create mode 100644 wfc-modules/wfc-system/src/main/java/org/wfc/system/domain/UCdr.java
 create mode 100644 wfc-modules/wfc-system/src/main/java/org/wfc/system/domain/vo/UCdrHistoryUserVo.java
 create mode 100644 wfc-modules/wfc-system/src/main/java/org/wfc/system/mapper/UCdrMapper.java
 create mode 100644 wfc-modules/wfc-system/src/main/java/org/wfc/system/service/IUCdrService.java
 create mode 100644 wfc-modules/wfc-system/src/main/java/org/wfc/system/service/impl/UCdrServiceImpl.java
 create mode 100644 wfc-modules/wfc-system/src/main/resources/mapper/system/UCdrMapper.xml

diff --git a/wfc-modules/wfc-system/src/main/java/org/wfc/system/controller/UCdrController.java b/wfc-modules/wfc-system/src/main/java/org/wfc/system/controller/UCdrController.java
new file mode 100644
index 0000000..336f67c
--- /dev/null
+++ b/wfc-modules/wfc-system/src/main/java/org/wfc/system/controller/UCdrController.java
@@ -0,0 +1,43 @@
+package org.wfc.system.controller;
+
+import io.swagger.v3.oas.annotations.Operation;
+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 org.wfc.common.core.web.controller.BaseController;
+import org.wfc.common.core.web.page.TableDataInfo;
+import org.wfc.system.domain.vo.UCdrHistoryUserVo;
+import org.wfc.system.service.IUCdrService;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 用户平台_用户话单表 前端控制器
+ * </p>
+ *
+ * @author sys
+ * @since 2025-01-03
+ */
+@RestController
+@RequestMapping("/cdr")
+public class UCdrController extends BaseController {
+
+    @Autowired
+    private IUCdrService uCdrService;
+
+    /**
+     * 根据用户查询cdr记录
+     *
+     * @return 结果
+     */
+    @Operation(summary = "CDR记录")
+    @GetMapping("/pageHistory")
+    public TableDataInfo getHistoryByUser() {
+        startPage();
+        List<UCdrHistoryUserVo> result = uCdrService.getHistoryByUser(null);
+        return getDataTable(result);
+    }
+
+}
diff --git a/wfc-modules/wfc-system/src/main/java/org/wfc/system/domain/UCdr.java b/wfc-modules/wfc-system/src/main/java/org/wfc/system/domain/UCdr.java
new file mode 100644
index 0000000..841139e
--- /dev/null
+++ b/wfc-modules/wfc-system/src/main/java/org/wfc/system/domain/UCdr.java
@@ -0,0 +1,66 @@
+package org.wfc.system.domain;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Getter;
+import lombok.Setter;
+import org.wfc.common.mybatis.domain.BaseData;
+
+/**
+ * <p>
+ * 用户平台_用户话单表
+ * </p>
+ *
+ * @author sys
+ * @since 2025-01-03
+ */
+@Getter
+@Setter
+@TableName("u_cdr")
+@Schema(name = "UCdr", description = "用户平台_用户话单表")
+public class UCdr extends BaseData {
+
+    private static final long serialVersionUID = 1L;
+
+    @Schema(description = "User ID link to u_user")
+    private Long userId;
+
+    @Schema(description = "Client ID")
+    private Long clientId;
+
+    @Schema(description = "Device ID")
+    private Long deviceId;
+
+    @Schema(description = "Wireless SSID name ")
+    private String ssid;
+
+    @Schema(description = "tx rate ")
+    private Long rxRate;
+
+    @Schema(description = "tx rate")
+    private Long txRate;
+
+    @Schema(description = "Number of downstream packets.")
+    private Long downPacket;
+
+    @Schema(description = "Number of upstream packets.	")
+    private Long upPacket;
+
+    @Schema(description = "Downstream traffic (Byte)")
+    private Long trafficDown;
+
+    @Schema(description = "Upstream traffic (Byte)")
+    private Long trafficUp;
+
+    @Schema(description = "Rate limit profile ID. ")
+    private String rateLimitProfileId;
+
+    @Schema(description = "Up time (unit: s).")
+    private Long upTime;
+
+    @Schema(description = "Last found time, timestamp (ms).	")
+    private Long lastSeenTime;
+
+    @Schema(description = "Activity download speed (Bytes/s)")
+    private Long activity;
+}
diff --git a/wfc-modules/wfc-system/src/main/java/org/wfc/system/domain/vo/UCdrHistoryUserVo.java b/wfc-modules/wfc-system/src/main/java/org/wfc/system/domain/vo/UCdrHistoryUserVo.java
new file mode 100644
index 0000000..2fcff5c
--- /dev/null
+++ b/wfc-modules/wfc-system/src/main/java/org/wfc/system/domain/vo/UCdrHistoryUserVo.java
@@ -0,0 +1,22 @@
+package org.wfc.system.domain.vo;
+
+import lombok.Data;
+
+/**
+ * @description: cdr历史vo
+ * @author: cyc
+ * @since: 2024-12-17
+ */
+@Data
+public class UCdrHistoryUserVo {
+    private Long id;
+    private Long userId;
+    private String userName;
+    private String clientName;
+    private String clientMac;
+    private Long startTime;
+    private Long endTime;
+    private Long duration;
+    private Long trafficDown;
+    private Long trafficUp;
+}
diff --git a/wfc-modules/wfc-system/src/main/java/org/wfc/system/mapper/UCdrMapper.java b/wfc-modules/wfc-system/src/main/java/org/wfc/system/mapper/UCdrMapper.java
new file mode 100644
index 0000000..850b7c0
--- /dev/null
+++ b/wfc-modules/wfc-system/src/main/java/org/wfc/system/mapper/UCdrMapper.java
@@ -0,0 +1,24 @@
+package org.wfc.system.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
+import org.wfc.system.domain.UCdr;
+import org.wfc.system.domain.vo.UCdrHistoryUserVo;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 用户平台_用户话单表 Mapper 接口
+ * </p>
+ *
+ * @author sys
+ * @since 2025-01-03
+ */
+@DS("user")
+public interface UCdrMapper extends BaseMapper<UCdr> {
+
+    List<UCdrHistoryUserVo> getHistoryByUser(@Param("userId") Long userId);
+
+}
diff --git a/wfc-modules/wfc-system/src/main/java/org/wfc/system/service/IUCdrService.java b/wfc-modules/wfc-system/src/main/java/org/wfc/system/service/IUCdrService.java
new file mode 100644
index 0000000..d525dce
--- /dev/null
+++ b/wfc-modules/wfc-system/src/main/java/org/wfc/system/service/IUCdrService.java
@@ -0,0 +1,20 @@
+package org.wfc.system.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import org.wfc.system.domain.UCdr;
+import org.wfc.system.domain.vo.UCdrHistoryUserVo;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 用户平台_用户话单表 服务类
+ * </p>
+ *
+ * @author sys
+ * @since 2025-01-03
+ */
+public interface IUCdrService extends IService<UCdr> {
+
+    List<UCdrHistoryUserVo> getHistoryByUser(Long userId);
+}
diff --git a/wfc-modules/wfc-system/src/main/java/org/wfc/system/service/impl/UCdrServiceImpl.java b/wfc-modules/wfc-system/src/main/java/org/wfc/system/service/impl/UCdrServiceImpl.java
new file mode 100644
index 0000000..fa95d42
--- /dev/null
+++ b/wfc-modules/wfc-system/src/main/java/org/wfc/system/service/impl/UCdrServiceImpl.java
@@ -0,0 +1,27 @@
+package org.wfc.system.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+import org.wfc.system.domain.UCdr;
+import org.wfc.system.domain.vo.UCdrHistoryUserVo;
+import org.wfc.system.mapper.UCdrMapper;
+import org.wfc.system.service.IUCdrService;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 用户平台_用户话单表 服务实现类
+ * </p>
+ *
+ * @author sys
+ * @since 2025-01-03
+ */
+@Service
+public class UCdrServiceImpl extends ServiceImpl<UCdrMapper, UCdr> implements IUCdrService {
+
+    @Override
+    public List<UCdrHistoryUserVo> getHistoryByUser(Long userId) {
+        return this.baseMapper.getHistoryByUser(userId);
+    }
+}
diff --git a/wfc-modules/wfc-system/src/main/resources/mapper/system/UCdrMapper.xml b/wfc-modules/wfc-system/src/main/resources/mapper/system/UCdrMapper.xml
new file mode 100644
index 0000000..354bf33
--- /dev/null
+++ b/wfc-modules/wfc-system/src/main/resources/mapper/system/UCdrMapper.xml
@@ -0,0 +1,37 @@
+<?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="org.wfc.system.mapper.UCdrMapper">
+
+     <select id="getHistoryByUser" resultType="org.wfc.system.domain.vo.UCdrHistoryUserVo">
+        SELECT
+            ch.id,
+            u.user_id,
+            u.user_name,
+            c.client_name,
+            c.client_mac,
+            c.client_device_type,
+            ch.start_time,
+            ch.end_time,
+            ifnull( ch.duration, 0 ) duration,
+            ifnull( ch.traffic_down, 0 ) traffic_down,
+            ifnull( ch.traffic_up, 0 ) traffic_up
+        FROM
+            u_cdr cdr
+                LEFT JOIN u_cdr_history ch ON cdr.id = ch.cdr_id
+                AND ch.del_flag = 0
+                LEFT JOIN u_client c ON cdr.client_id = c.id
+                AND c.del_flag = 0
+                LEFT JOIN u_user u on cdr.user_id = u.user_id
+                AND u.del_flag = 0
+        WHERE
+            cdr.del_flag = 0
+            AND ch.id is not null
+            AND cdr.user_id is not null
+            <if test="userId != null and userId != ''">
+                AND cdr.user_id = #{userId}
+            </if>
+        ORDER BY
+            ch.start_time DESC
+    </select>
+
+</mapper>