diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/EpsInitialTrafficDataMapper.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/EpsInitialTrafficDataMapper.java index 98893aa..aa57fbd 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/EpsInitialTrafficDataMapper.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/EpsInitialTrafficDataMapper.java @@ -82,4 +82,6 @@ public interface EpsInitialTrafficDataMapper { void createMountPointInfo(String tableName); void createDockerInfo(String tableName); + + void createNetBusinessInfo(String tableName); } diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/EpsInitialTrafficDataServiceImpl.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/EpsInitialTrafficDataServiceImpl.java index df07616..884aa87 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/EpsInitialTrafficDataServiceImpl.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/EpsInitialTrafficDataServiceImpl.java @@ -82,6 +82,8 @@ public class EpsInitialTrafficDataServiceImpl implements EpsInitialTrafficDataSe createMountPointInfo(year, month); // 创建容器信息表 createDockerInfo(year, month); + // 创建业务流量信息表 + createNetBusinessInfo(year, month); } public void createNextMonthTables(Long plusMonth) { LocalDate nextMonth = LocalDate.now().plusMonths(plusMonth); @@ -110,6 +112,8 @@ public class EpsInitialTrafficDataServiceImpl implements EpsInitialTrafficDataSe createMountPointInfo(year, month); // 创建容器信息表 createDockerInfo(year, month); + // 创建业务流量表 + createNetBusinessInfo(year, month); } private void createTrafficDetailsTable(int year, int month) { createRangeTables(year, month, "eps_traffic_details", (tableName) -> { @@ -171,6 +175,12 @@ public class EpsInitialTrafficDataServiceImpl implements EpsInitialTrafficDataSe }); } + private void createNetBusinessInfo(int year, int month) { + createRangeTables(year, month, "initial_net_business_traffic", (tableName) -> { + epsInitialTrafficDataMapper.createNetBusinessInfo(tableName); + }); + } + /** * 通用创建表方法 * @param year 年份 diff --git a/tongran-modules/tongran-system/src/main/resources/mapper/system/EpsInitialTrafficDataMapper.xml b/tongran-modules/tongran-system/src/main/resources/mapper/system/EpsInitialTrafficDataMapper.xml index 61d3ad9..f26783d 100644 --- a/tongran-modules/tongran-system/src/main/resources/mapper/system/EpsInitialTrafficDataMapper.xml +++ b/tongran-modules/tongran-system/src/main/resources/mapper/system/EpsInitialTrafficDataMapper.xml @@ -291,7 +291,29 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" UNIQUE INDEX `idx_unique_key`(`client_id`, `mount`, `create_time`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT = '挂载点监控信息表'; - + + CREATE TABLE ${tableName} ( + `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键ID', + `client_id` varchar(255) comment '客户端唯一标识', + `mac` varchar(255) comment 'mac地址', + `name` varchar(255) DEFAULT NULL COMMENT '网卡名称', + `pid` int(11) DEFAULT NULL COMMENT '进程ID', + `process_name` varchar(255) DEFAULT NULL COMMENT '进程名', + `in_speed` varchar(50) DEFAULT NULL COMMENT '累计接收字节数', + `out_speed` varchar(50) DEFAULT NULL COMMENT '累计发送字节数', + `connection_count` int(11) DEFAULT NULL COMMENT '当前连接数', + `ipv4_in_speed` varchar(50) DEFAULT NULL COMMENT 'IPv4接收流量', + `ipv4_out_speed` varchar(50) DEFAULT NULL COMMENT 'IPv4发送流量', + `ipv6_in_speed` varchar(50) DEFAULT NULL COMMENT 'IPv6接收流量', + `ipv6_out_speed` varchar(50) DEFAULT NULL COMMENT 'IPv6发送流量', + `create_by` varchar(64) DEFAULT '' COMMENT '创建者', + `create_time` datetime DEFAULT NULL COMMENT '创建时间', + `update_by` varchar(64) DEFAULT '' COMMENT '更新者', + `update_time` datetime DEFAULT NULL COMMENT '更新时间', + `remark` varchar(500) DEFAULT NULL COMMENT '备注', + PRIMARY KEY (`id`) + ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='网络业务流量监控表'; + INSERT INTO ${tableName} ( diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialNetBusinessTrafficController.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialNetBusinessTrafficController.java new file mode 100644 index 0000000..b4679c3 --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialNetBusinessTrafficController.java @@ -0,0 +1,93 @@ +package com.tongran.rocketmq.controller; + +import com.tongran.common.core.utils.poi.ExcelUtil; +import com.tongran.common.core.web.controller.BaseController; +import com.tongran.common.core.web.domain.AjaxResult; +import com.tongran.common.core.web.page.TableDataInfo; +import com.tongran.common.log.annotation.Log; +import com.tongran.common.log.enums.BusinessType; +import com.tongran.common.security.annotation.RequiresPermissions; +import com.tongran.rocketmq.domain.InitialNetBusinessTraffic; +import com.tongran.rocketmq.service.IInitialNetBusinessTrafficService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import javax.servlet.http.HttpServletResponse; +import java.util.List; + +/** + * 网络业务流量监控Controller + * + * @author gyt + * @date 2026-03-06 + */ +@RestController +@RequestMapping("/initialNetBusinessTraffic") +@RequiresPermissions("rocketmq:traffic") +public class InitialNetBusinessTrafficController extends BaseController +{ + @Autowired + private IInitialNetBusinessTrafficService initialNetBusinessTrafficService; + + /** + * 查询网络业务流量监控列表 + */ + @GetMapping("/list") + public TableDataInfo list(InitialNetBusinessTraffic initialNetBusinessTraffic) + { + startPage(); + List list = initialNetBusinessTrafficService.selectInitialNetBusinessTrafficList(initialNetBusinessTraffic); + return getDataTable(list); + } + + /** + * 导出网络业务流量监控列表 + */ + @Log(title = "网络业务流量监控", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, InitialNetBusinessTraffic initialNetBusinessTraffic) + { + List list = initialNetBusinessTrafficService.selectInitialNetBusinessTrafficList(initialNetBusinessTraffic); + ExcelUtil util = new ExcelUtil(InitialNetBusinessTraffic.class); + util.exportExcel(response, list, "网络业务流量监控数据"); + } + + /** + * 获取网络业务流量监控详细信息 + */ + @GetMapping(value = "/{id}") + public AjaxResult getInfo(@PathVariable("id") Long id) + { + return success(initialNetBusinessTrafficService.selectInitialNetBusinessTrafficById(id)); + } + + /** + * 新增网络业务流量监控 + */ + @Log(title = "网络业务流量监控", businessType = BusinessType.INSERT) + @PostMapping + public AjaxResult add(@RequestBody InitialNetBusinessTraffic initialNetBusinessTraffic) + { + return toAjax(initialNetBusinessTrafficService.insertInitialNetBusinessTraffic(initialNetBusinessTraffic)); + } + + /** + * 修改网络业务流量监控 + */ + @Log(title = "网络业务流量监控", businessType = BusinessType.UPDATE) + @PutMapping + public AjaxResult edit(@RequestBody InitialNetBusinessTraffic initialNetBusinessTraffic) + { + return toAjax(initialNetBusinessTrafficService.updateInitialNetBusinessTraffic(initialNetBusinessTraffic)); + } + + /** + * 删除网络业务流量监控 + */ + @Log(title = "网络业务流量监控", businessType = BusinessType.DELETE) + @DeleteMapping("/{ids}") + public AjaxResult remove(@PathVariable Long[] ids) + { + return toAjax(initialNetBusinessTrafficService.deleteInitialNetBusinessTrafficByIds(ids)); + } +} diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialNetBusinessTrafficTempController.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialNetBusinessTrafficTempController.java new file mode 100644 index 0000000..e4bd8a4 --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialNetBusinessTrafficTempController.java @@ -0,0 +1,91 @@ +package com.tongran.rocketmq.controller; + +import com.tongran.common.core.utils.poi.ExcelUtil; +import com.tongran.common.core.web.controller.BaseController; +import com.tongran.common.core.web.domain.AjaxResult; +import com.tongran.common.core.web.page.TableDataInfo; +import com.tongran.common.log.annotation.Log; +import com.tongran.common.log.enums.BusinessType; +import com.tongran.rocketmq.domain.InitialNetBusinessTrafficTemp; +import com.tongran.rocketmq.service.IInitialNetBusinessTrafficTempService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import javax.servlet.http.HttpServletResponse; +import java.util.List; + +/** + * 网络业务流量监控Controller + * + * @author gyt + * @date 2026-03-06 + */ +@RestController +@RequestMapping("/initialNetBusinessTrafficTemp") +public class InitialNetBusinessTrafficTempController extends BaseController +{ + @Autowired + private IInitialNetBusinessTrafficTempService initialNetBusinessTrafficTempService; + + /** + * 查询网络业务流量监控列表 + */ + @GetMapping("/list") + public TableDataInfo list(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp) + { + startPage(); + List list = initialNetBusinessTrafficTempService.selectInitialNetBusinessTrafficTempList(initialNetBusinessTrafficTemp); + return getDataTable(list); + } + + /** + * 导出网络业务流量监控列表 + */ + @Log(title = "网络业务流量监控", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp) + { + List list = initialNetBusinessTrafficTempService.selectInitialNetBusinessTrafficTempList(initialNetBusinessTrafficTemp); + ExcelUtil util = new ExcelUtil(InitialNetBusinessTrafficTemp.class); + util.exportExcel(response, list, "网络业务流量监控数据"); + } + + /** + * 获取网络业务流量监控详细信息 + */ + @GetMapping(value = "/{id}") + public AjaxResult getInfo(@PathVariable("id") Long id) + { + return success(initialNetBusinessTrafficTempService.selectInitialNetBusinessTrafficTempById(id)); + } + + /** + * 新增网络业务流量监控 + */ + @Log(title = "网络业务流量监控", businessType = BusinessType.INSERT) + @PostMapping + public AjaxResult add(@RequestBody InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp) + { + return toAjax(initialNetBusinessTrafficTempService.insertInitialNetBusinessTrafficTemp(initialNetBusinessTrafficTemp)); + } + + /** + * 修改网络业务流量监控 + */ + @Log(title = "网络业务流量监控", businessType = BusinessType.UPDATE) + @PutMapping + public AjaxResult edit(@RequestBody InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp) + { + return toAjax(initialNetBusinessTrafficTempService.updateInitialNetBusinessTrafficTemp(initialNetBusinessTrafficTemp)); + } + + /** + * 删除网络业务流量监控 + */ + @Log(title = "网络业务流量监控", businessType = BusinessType.DELETE) + @DeleteMapping("/{ids}") + public AjaxResult remove(@PathVariable Long[] ids) + { + return toAjax(initialNetBusinessTrafficTempService.deleteInitialNetBusinessTrafficTempByIds(ids)); + } +} diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialNetBusinessTraffic.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialNetBusinessTraffic.java new file mode 100644 index 0000000..5194477 --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialNetBusinessTraffic.java @@ -0,0 +1,78 @@ +package com.tongran.rocketmq.domain; + +import com.tongran.common.core.annotation.Excel; +import com.tongran.common.core.web.domain.BaseEntity; +import lombok.Data; + +import java.util.List; + +/** + * 网络业务流量监控对象 initial_net_business_traffic + * + * @author gyt + * @date 2026-03-06 + */ +@Data +public class InitialNetBusinessTraffic extends BaseEntity +{ + private static final long serialVersionUID = 1L; + + /** 主键ID */ + private Long id; + + /** 客户端唯一标识 */ + @Excel(name = "客户端唯一标识") + private String clientId; + + /** mac地址 */ + @Excel(name = "mac地址") + private String mac; + + /** 网卡名称 */ + @Excel(name = "网卡名称") + private String name; + + /** 进程ID */ + @Excel(name = "进程ID") + private Long pid; + + /** 进程名 */ + @Excel(name = "进程名") + private String processName; + + /** 累计接收字节数 */ + @Excel(name = "累计接收字节数") + private String inSpeed; + + /** 累计发送字节数 */ + @Excel(name = "累计发送字节数") + private String outSpeed; + + /** 当前连接数 */ + @Excel(name = "当前连接数") + private Long connectionCount; + + /** IPv4接收流量 */ + @Excel(name = "IPv4接收流量") + private String ipv4InSpeed; + + /** IPv4发送流量 */ + @Excel(name = "IPv4发送流量") + private String ipv4OutSpeed; + + /** IPv6接收流量 */ + @Excel(name = "IPv6接收流量") + private String ipv6InSpeed; + + /** IPv6发送流量 */ + @Excel(name = "IPv6发送流量") + private String ipv6OutSpeed; + + private List list; + + private String tableName; + + private String startTime; + + private String endTime; +} diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialNetBusinessTrafficTemp.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialNetBusinessTrafficTemp.java new file mode 100644 index 0000000..e87a7d3 --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialNetBusinessTrafficTemp.java @@ -0,0 +1,222 @@ +package com.tongran.rocketmq.domain; + +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; +import com.tongran.common.core.annotation.Excel; +import com.tongran.common.core.web.domain.BaseEntity; + +/** + * 网络业务流量监控对象 initial_net_business_traffic_temp + * + * @author gyt + * @date 2026-03-06 + */ +public class InitialNetBusinessTrafficTemp extends BaseEntity +{ + private static final long serialVersionUID = 1L; + + /** 主键ID */ + private Long id; + + /** 客户端唯一标识 */ + @Excel(name = "客户端唯一标识") + private String clientId; + + /** mac地址 */ + @Excel(name = "mac地址") + private String mac; + + /** 网卡名称 */ + @Excel(name = "网卡名称") + private String name; + + /** 进程ID */ + @Excel(name = "进程ID") + private Long pid; + + /** 进程名 */ + @Excel(name = "进程名") + private String processName; + + /** 累计接收字节数 */ + @Excel(name = "累计接收字节数") + private String inSpeed; + + /** 累计发送字节数 */ + @Excel(name = "累计发送字节数") + private String outSpeed; + + /** 当前连接数 */ + @Excel(name = "当前连接数") + private Long connectionCount; + + /** IPv4接收流量 */ + @Excel(name = "IPv4接收流量") + private String ipv4InSpeed; + + /** IPv4发送流量 */ + @Excel(name = "IPv4发送流量") + private String ipv4OutSpeed; + + /** IPv6接收流量 */ + @Excel(name = "IPv6接收流量") + private String ipv6InSpeed; + + /** IPv6发送流量 */ + @Excel(name = "IPv6发送流量") + private String ipv6OutSpeed; + + public void setId(Long id) + { + this.id = id; + } + + public Long getId() + { + return id; + } + + public void setClientId(String clientId) + { + this.clientId = clientId; + } + + public String getClientId() + { + return clientId; + } + + public void setMac(String mac) + { + this.mac = mac; + } + + public String getMac() + { + return mac; + } + + public void setName(String name) + { + this.name = name; + } + + public String getName() + { + return name; + } + + public void setPid(Long pid) + { + this.pid = pid; + } + + public Long getPid() + { + return pid; + } + + public void setProcessName(String processName) + { + this.processName = processName; + } + + public String getProcessName() + { + return processName; + } + + public void setInSpeed(String inSpeed) + { + this.inSpeed = inSpeed; + } + + public String getInSpeed() + { + return inSpeed; + } + + public void setOutSpeed(String outSpeed) + { + this.outSpeed = outSpeed; + } + + public String getOutSpeed() + { + return outSpeed; + } + + public void setConnectionCount(Long connectionCount) + { + this.connectionCount = connectionCount; + } + + public Long getConnectionCount() + { + return connectionCount; + } + + public void setIpv4InSpeed(String ipv4InSpeed) + { + this.ipv4InSpeed = ipv4InSpeed; + } + + public String getIpv4InSpeed() + { + return ipv4InSpeed; + } + + public void setIpv4OutSpeed(String ipv4OutSpeed) + { + this.ipv4OutSpeed = ipv4OutSpeed; + } + + public String getIpv4OutSpeed() + { + return ipv4OutSpeed; + } + + public void setIpv6InSpeed(String ipv6InSpeed) + { + this.ipv6InSpeed = ipv6InSpeed; + } + + public String getIpv6InSpeed() + { + return ipv6InSpeed; + } + + public void setIpv6OutSpeed(String ipv6OutSpeed) + { + this.ipv6OutSpeed = ipv6OutSpeed; + } + + public String getIpv6OutSpeed() + { + return ipv6OutSpeed; + } + + @Override + public String toString() { + return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) + .append("id", getId()) + .append("clientId", getClientId()) + .append("mac", getMac()) + .append("name", getName()) + .append("pid", getPid()) + .append("processName", getProcessName()) + .append("inSpeed", getInSpeed()) + .append("outSpeed", getOutSpeed()) + .append("connectionCount", getConnectionCount()) + .append("ipv4InSpeed", getIpv4InSpeed()) + .append("ipv4OutSpeed", getIpv4OutSpeed()) + .append("ipv6InSpeed", getIpv6InSpeed()) + .append("ipv6OutSpeed", getIpv6OutSpeed()) + .append("createBy", getCreateBy()) + .append("createTime", getCreateTime()) + .append("updateBy", getUpdateBy()) + .append("updateTime", getUpdateTime()) + .append("remark", getRemark()) + .toString(); + } +} diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/mapper/InitialNetBusinessTrafficMapper.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/mapper/InitialNetBusinessTrafficMapper.java new file mode 100644 index 0000000..4fb8552 --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/mapper/InitialNetBusinessTrafficMapper.java @@ -0,0 +1,68 @@ +package com.tongran.rocketmq.mapper; + +import com.tongran.rocketmq.domain.InitialNetBusinessTraffic; + +import java.util.List; + +/** + * 网络业务流量监控Mapper接口 + * + * @author gyt + * @date 2026-03-06 + */ +public interface InitialNetBusinessTrafficMapper +{ + /** + * 查询网络业务流量监控 + * + * @param id 网络业务流量监控主键 + * @return 网络业务流量监控 + */ + public InitialNetBusinessTraffic selectInitialNetBusinessTrafficById(Long id); + + /** + * 查询网络业务流量监控列表 + * + * @param initialNetBusinessTraffic 网络业务流量监控 + * @return 网络业务流量监控集合 + */ + public List selectInitialNetBusinessTrafficList(InitialNetBusinessTraffic initialNetBusinessTraffic); + + /** + * 新增网络业务流量监控 + * + * @param initialNetBusinessTraffic 网络业务流量监控 + * @return 结果 + */ + public int insertInitialNetBusinessTraffic(InitialNetBusinessTraffic initialNetBusinessTraffic); + + /** + * 修改网络业务流量监控 + * + * @param initialNetBusinessTraffic 网络业务流量监控 + * @return 结果 + */ + public int updateInitialNetBusinessTraffic(InitialNetBusinessTraffic initialNetBusinessTraffic); + + /** + * 删除网络业务流量监控 + * + * @param id 网络业务流量监控主键 + * @return 结果 + */ + public int deleteInitialNetBusinessTrafficById(Long id); + + /** + * 批量删除网络业务流量监控 + * + * @param ids 需要删除的数据主键集合 + * @return 结果 + */ + public int deleteInitialNetBusinessTrafficByIds(Long[] ids); + + void batchInsertBusinessTraffic(InitialNetBusinessTraffic batchData); + + void batchInsertBusinessRecoverTraffic(InitialNetBusinessTraffic batchData); + + List getNetBusinessTrafficList(InitialNetBusinessTraffic condition); +} diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/mapper/InitialNetBusinessTrafficTempMapper.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/mapper/InitialNetBusinessTrafficTempMapper.java new file mode 100644 index 0000000..feaeadd --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/mapper/InitialNetBusinessTrafficTempMapper.java @@ -0,0 +1,70 @@ +package com.tongran.rocketmq.mapper; + +import com.tongran.rocketmq.domain.InitialNetBusinessTrafficTemp; + +import java.util.List; + +/** + * 网络业务流量监控Mapper接口 + * + * @author gyt + * @date 2026-03-06 + */ +public interface InitialNetBusinessTrafficTempMapper +{ + /** + * 查询网络业务流量监控 + * + * @param id 网络业务流量监控主键 + * @return 网络业务流量监控 + */ + public InitialNetBusinessTrafficTemp selectInitialNetBusinessTrafficTempById(Long id); + + /** + * 查询网络业务流量监控列表 + * + * @param initialNetBusinessTrafficTemp 网络业务流量监控 + * @return 网络业务流量监控集合 + */ + public List selectInitialNetBusinessTrafficTempList(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp); + + /** + * 新增网络业务流量监控 + * + * @param initialNetBusinessTrafficTemp 网络业务流量监控 + * @return 结果 + */ + public int insertInitialNetBusinessTrafficTemp(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp); + + /** + * 修改网络业务流量监控 + * + * @param initialNetBusinessTrafficTemp 网络业务流量监控 + * @return 结果 + */ + public int updateInitialNetBusinessTrafficTemp(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp); + + /** + * 删除网络业务流量监控 + * + * @param id 网络业务流量监控主键 + * @return 结果 + */ + public int deleteInitialNetBusinessTrafficTempById(Long id); + + /** + * 批量删除网络业务流量监控 + * + * @param ids 需要删除的数据主键集合 + * @return 结果 + */ + public int deleteInitialNetBusinessTrafficTempByIds(Long[] ids); + + int deleteBusinessTempMsgByClientId(String clientId); + + int deleteBusinessTempMsgByClientIdAndTime(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp); + + int batchInsertBusinessTemp(List interfaces); + + int batchInsertBusinessRecoverTemp(List interfaces); +} diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/IInitialNetBusinessTrafficService.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/IInitialNetBusinessTrafficService.java new file mode 100644 index 0000000..fa5dc17 --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/IInitialNetBusinessTrafficService.java @@ -0,0 +1,64 @@ +package com.tongran.rocketmq.service; + +import com.tongran.rocketmq.domain.InitialNetBusinessTraffic; + +import java.util.List; + +/** + * 网络业务流量监控Service接口 + * + * @author gyt + * @date 2026-03-06 + */ +public interface IInitialNetBusinessTrafficService +{ + /** + * 查询网络业务流量监控 + * + * @param id 网络业务流量监控主键 + * @return 网络业务流量监控 + */ + public InitialNetBusinessTraffic selectInitialNetBusinessTrafficById(Long id); + + /** + * 查询网络业务流量监控列表 + * + * @param initialNetBusinessTraffic 网络业务流量监控 + * @return 网络业务流量监控集合 + */ + public List selectInitialNetBusinessTrafficList(InitialNetBusinessTraffic initialNetBusinessTraffic); + + /** + * 新增网络业务流量监控 + * + * @param initialNetBusinessTraffic 网络业务流量监控 + * @return 结果 + */ + public int insertInitialNetBusinessTraffic(InitialNetBusinessTraffic initialNetBusinessTraffic); + + /** + * 修改网络业务流量监控 + * + * @param initialNetBusinessTraffic 网络业务流量监控 + * @return 结果 + */ + public int updateInitialNetBusinessTraffic(InitialNetBusinessTraffic initialNetBusinessTraffic); + + /** + * 批量删除网络业务流量监控 + * + * @param ids 需要删除的网络业务流量监控主键集合 + * @return 结果 + */ + public int deleteInitialNetBusinessTrafficByIds(Long[] ids); + + /** + * 删除网络业务流量监控信息 + * + * @param id 网络业务流量监控主键 + * @return 结果 + */ + public int deleteInitialNetBusinessTrafficById(Long id); + void batchInsertBusinessTraffic(InitialNetBusinessTraffic data); + void batchInsertBusinessRecoverTraffic(InitialNetBusinessTraffic data); +} diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/IInitialNetBusinessTrafficTempService.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/IInitialNetBusinessTrafficTempService.java new file mode 100644 index 0000000..24f898f --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/IInitialNetBusinessTrafficTempService.java @@ -0,0 +1,68 @@ +package com.tongran.rocketmq.service; + +import com.tongran.rocketmq.domain.InitialNetBusinessTrafficTemp; + +import java.util.List; + +/** + * 网络业务流量监控Service接口 + * + * @author gyt + * @date 2026-03-06 + */ +public interface IInitialNetBusinessTrafficTempService +{ + /** + * 查询网络业务流量监控 + * + * @param id 网络业务流量监控主键 + * @return 网络业务流量监控 + */ + public InitialNetBusinessTrafficTemp selectInitialNetBusinessTrafficTempById(Long id); + + /** + * 查询网络业务流量监控列表 + * + * @param initialNetBusinessTrafficTemp 网络业务流量监控 + * @return 网络业务流量监控集合 + */ + public List selectInitialNetBusinessTrafficTempList(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp); + + /** + * 新增网络业务流量监控 + * + * @param initialNetBusinessTrafficTemp 网络业务流量监控 + * @return 结果 + */ + public int insertInitialNetBusinessTrafficTemp(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp); + + /** + * 修改网络业务流量监控 + * + * @param initialNetBusinessTrafficTemp 网络业务流量监控 + * @return 结果 + */ + public int updateInitialNetBusinessTrafficTemp(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp); + + /** + * 批量删除网络业务流量监控 + * + * @param ids 需要删除的网络业务流量监控主键集合 + * @return 结果 + */ + public int deleteInitialNetBusinessTrafficTempByIds(Long[] ids); + + /** + * 删除网络业务流量监控信息 + * + * @param id 网络业务流量监控主键 + * @return 结果 + */ + public int deleteInitialNetBusinessTrafficTempById(Long id); + + int deleteBusinessTempMsgByClientId(String clientId); + public int deleteBusinessTempMsgByClientIdAndTime(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp); + + public int batchInsertBusinessTemp(List interfaces); + public int batchInsertBusinessRecoverTemp(List interfaces); +} diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialNetBusinessTrafficServiceImpl.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialNetBusinessTrafficServiceImpl.java new file mode 100644 index 0000000..f968aa9 --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialNetBusinessTrafficServiceImpl.java @@ -0,0 +1,231 @@ +package com.tongran.rocketmq.service.impl; + +import com.tongran.common.core.utils.DateUtils; +import com.tongran.common.core.utils.TableSubUtil; +import com.tongran.rocketmq.domain.InitialNetBusinessTraffic; +import com.tongran.rocketmq.mapper.InitialNetBusinessTrafficMapper; +import com.tongran.rocketmq.service.IInitialNetBusinessTrafficService; +import com.tongran.rocketmq.utils.TableRouterUtil; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.BeanUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Isolation; +import org.springframework.transaction.annotation.Transactional; + +import java.util.*; +import java.util.stream.Collectors; + +/** + * 网络业务流量监控Service业务层处理 + * + * @author gyt + * @date 2026-03-06 + */ +@Service +@Slf4j +public class InitialNetBusinessTrafficServiceImpl implements IInitialNetBusinessTrafficService +{ + @Autowired + private InitialNetBusinessTrafficMapper initialNetBusinessTrafficMapper; + + /** + * 查询网络业务流量监控 + * + * @param id 网络业务流量监控主键 + * @return 网络业务流量监控 + */ + @Override + public InitialNetBusinessTraffic selectInitialNetBusinessTrafficById(Long id) + { + return initialNetBusinessTrafficMapper.selectInitialNetBusinessTrafficById(id); + } + + /** + * 查询网络业务流量监控列表 + * + * @param initialNetBusinessTraffic 网络业务流量监控 + * @return 网络业务流量监控 + */ + @Override + public List selectInitialNetBusinessTrafficList(InitialNetBusinessTraffic initialNetBusinessTraffic) + { + return initialNetBusinessTrafficMapper.selectInitialNetBusinessTrafficList(initialNetBusinessTraffic); + } + + /** + * 新增网络业务流量监控 + * + * @param initialNetBusinessTraffic 网络业务流量监控 + * @return 结果 + */ + @Override + public int insertInitialNetBusinessTraffic(InitialNetBusinessTraffic initialNetBusinessTraffic) + { + initialNetBusinessTraffic.setCreateTime(DateUtils.getNowDate()); + return initialNetBusinessTrafficMapper.insertInitialNetBusinessTraffic(initialNetBusinessTraffic); + } + + /** + * 修改网络业务流量监控 + * + * @param initialNetBusinessTraffic 网络业务流量监控 + * @return 结果 + */ + @Override + public int updateInitialNetBusinessTraffic(InitialNetBusinessTraffic initialNetBusinessTraffic) + { + initialNetBusinessTraffic.setUpdateTime(DateUtils.getNowDate()); + return initialNetBusinessTrafficMapper.updateInitialNetBusinessTraffic(initialNetBusinessTraffic); + } + + /** + * 批量删除网络业务流量监控 + * + * @param ids 需要删除的网络业务流量监控主键 + * @return 结果 + */ + @Override + public int deleteInitialNetBusinessTrafficByIds(Long[] ids) + { + return initialNetBusinessTrafficMapper.deleteInitialNetBusinessTrafficByIds(ids); + } + + /** + * 删除网络业务流量监控信息 + * + * @param id 网络业务流量监控主键 + * @return 结果 + */ + @Override + public int deleteInitialNetBusinessTrafficById(Long id) + { + return initialNetBusinessTrafficMapper.deleteInitialNetBusinessTrafficById(id); + } + + @Override + @Transactional(rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED) + public void batchInsertBusinessTraffic(InitialNetBusinessTraffic data) { + if (data == null) { + return; + } + List dataList = data.getList(); + if (dataList == null || dataList.isEmpty()) { + return; + } + + // 按表名分组批量插入 + Map> groupedData = dataList.stream() + .map(item -> { + try { + InitialNetBusinessTraffic processed = new InitialNetBusinessTraffic(); + BeanUtils.copyProperties(item, processed); + + // 设置创建时间 + if (item.getCreateTime() == null) { + item.setCreateTime(DateUtils.getNowDate()); + } + + // 根据创建时间获取表名 + Date createTime = item.getCreateTime(); + processed.setTableName(TableSubUtil.getTableName(createTime, "initial_net_business_traffic")); + + return processed; + } catch (Exception e) { + log.error("业务流量数据处理失败: {}", e.getMessage()); + return null; + } + }) + .filter(Objects::nonNull) + .collect(Collectors.groupingBy( + InitialNetBusinessTraffic::getTableName, + LinkedHashMap::new, // 保持插入顺序 + Collectors.toList() + )); + + groupedData.forEach((tableName, list) -> { + try { + InitialNetBusinessTraffic batchData = new InitialNetBusinessTraffic(); + BeanUtils.copyProperties(data, batchData); + batchData.setTableName(tableName); + batchData.setList(list); + initialNetBusinessTrafficMapper.batchInsertBusinessTraffic(batchData); + } catch (Exception e) { + log.error("业务流量数据表{}插入失败", tableName, e); + throw new RuntimeException("业务流量数据批量插入失败", e); + } + }); + } + + @Override + @Transactional(rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED) + public void batchInsertBusinessRecoverTraffic(InitialNetBusinessTraffic data) { + if (data == null) { + return; + } + List dataList = data.getList(); + if (dataList == null || dataList.isEmpty()) { + return; + } + + // 按表名分组批量插入 + Map> groupedData = dataList.stream() + .map(item -> { + try { + InitialNetBusinessTraffic processed = new InitialNetBusinessTraffic(); + BeanUtils.copyProperties(item, processed); + + // 设置创建时间 + if (item.getCreateTime() == null) { + item.setCreateTime(DateUtils.getNowDate()); + } + + // 根据创建时间获取表名（恢复数据可能使用不同的表名规则） + Date createTime = item.getCreateTime(); + processed.setTableName(TableSubUtil.getTableName(createTime, "initial_net_business_traffic")); + + return processed; + } catch (Exception e) { + log.error("业务流量恢复数据处理失败: {}", e.getMessage()); + return null; + } + }) + .filter(Objects::nonNull) + .collect(Collectors.groupingBy( + InitialNetBusinessTraffic::getTableName, + LinkedHashMap::new, // 保持插入顺序 + Collectors.toList() + )); + + groupedData.forEach((tableName, list) -> { + try { + InitialNetBusinessTraffic batchData = new InitialNetBusinessTraffic(); + BeanUtils.copyProperties(data, batchData); + batchData.setTableName(tableName); + batchData.setList(list); + initialNetBusinessTrafficMapper.batchInsertBusinessRecoverTraffic(batchData); + } catch (Exception e) { + log.error("业务流量恢复数据表{}插入失败", tableName, e); + throw new RuntimeException("业务流量恢复数据批量插入失败", e); + } + }); + } + + public List getListByTableName(InitialNetBusinessTraffic initialNetBusinessTraffic){ + // 获取涉及的表名 + Set tableNames = TableRouterUtil.getTableNamesBetween(initialNetBusinessTraffic.getStartTime(), initialNetBusinessTraffic.getEndTime()); + // 并行查询各表 + List list = tableNames.parallelStream() + .flatMap(tableName -> { + InitialNetBusinessTraffic condition = new InitialNetBusinessTraffic(); + condition.setTableName(tableName); + condition.setStartTime(initialNetBusinessTraffic.getStartTime()); + condition.setEndTime(initialNetBusinessTraffic.getEndTime()); + condition.setClientId(initialNetBusinessTraffic.getClientId()); + condition.setName(initialNetBusinessTraffic.getName()); + return initialNetBusinessTrafficMapper.getNetBusinessTrafficList(condition).stream(); + }) + .collect(Collectors.toList()); + return list; + } +} diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialNetBusinessTrafficTempServiceImpl.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialNetBusinessTrafficTempServiceImpl.java new file mode 100644 index 0000000..218fc2c --- /dev/null +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialNetBusinessTrafficTempServiceImpl.java @@ -0,0 +1,114 @@ +package com.tongran.rocketmq.service.impl; + +import com.tongran.common.core.utils.DateUtils; +import com.tongran.rocketmq.domain.InitialNetBusinessTrafficTemp; +import com.tongran.rocketmq.mapper.InitialNetBusinessTrafficTempMapper; +import com.tongran.rocketmq.service.IInitialNetBusinessTrafficTempService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * 网络业务流量监控Service业务层处理 + * + * @author gyt + * @date 2026-03-06 + */ +@Service +public class InitialNetBusinessTrafficTempServiceImpl implements IInitialNetBusinessTrafficTempService +{ + @Autowired + private InitialNetBusinessTrafficTempMapper initialNetBusinessTrafficTempMapper; + + /** + * 查询网络业务流量监控 + * + * @param id 网络业务流量监控主键 + * @return 网络业务流量监控 + */ + @Override + public InitialNetBusinessTrafficTemp selectInitialNetBusinessTrafficTempById(Long id) + { + return initialNetBusinessTrafficTempMapper.selectInitialNetBusinessTrafficTempById(id); + } + + /** + * 查询网络业务流量监控列表 + * + * @param initialNetBusinessTrafficTemp 网络业务流量监控 + * @return 网络业务流量监控 + */ + @Override + public List selectInitialNetBusinessTrafficTempList(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp) + { + return initialNetBusinessTrafficTempMapper.selectInitialNetBusinessTrafficTempList(initialNetBusinessTrafficTemp); + } + + /** + * 新增网络业务流量监控 + * + * @param initialNetBusinessTrafficTemp 网络业务流量监控 + * @return 结果 + */ + @Override + public int insertInitialNetBusinessTrafficTemp(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp) + { + initialNetBusinessTrafficTemp.setCreateTime(DateUtils.getNowDate()); + return initialNetBusinessTrafficTempMapper.insertInitialNetBusinessTrafficTemp(initialNetBusinessTrafficTemp); + } + + /** + * 修改网络业务流量监控 + * + * @param initialNetBusinessTrafficTemp 网络业务流量监控 + * @return 结果 + */ + @Override + public int updateInitialNetBusinessTrafficTemp(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp) + { + initialNetBusinessTrafficTemp.setUpdateTime(DateUtils.getNowDate()); + return initialNetBusinessTrafficTempMapper.updateInitialNetBusinessTrafficTemp(initialNetBusinessTrafficTemp); + } + + /** + * 批量删除网络业务流量监控 + * + * @param ids 需要删除的网络业务流量监控主键 + * @return 结果 + */ + @Override + public int deleteInitialNetBusinessTrafficTempByIds(Long[] ids) + { + return initialNetBusinessTrafficTempMapper.deleteInitialNetBusinessTrafficTempByIds(ids); + } + + /** + * 删除网络业务流量监控信息 + * + * @param id 网络业务流量监控主键 + * @return 结果 + */ + @Override + public int deleteInitialNetBusinessTrafficTempById(Long id) + { + return initialNetBusinessTrafficTempMapper.deleteInitialNetBusinessTrafficTempById(id); + } + @Override + public int deleteBusinessTempMsgByClientId(String clientId) { + return initialNetBusinessTrafficTempMapper.deleteBusinessTempMsgByClientId(clientId); + } + @Override + public int deleteBusinessTempMsgByClientIdAndTime(InitialNetBusinessTrafficTemp initialNetBusinessTrafficTemp) { + return initialNetBusinessTrafficTempMapper.deleteBusinessTempMsgByClientIdAndTime(initialNetBusinessTrafficTemp); + } + + @Override + public int batchInsertBusinessTemp(List interfaces) { + return initialNetBusinessTrafficTempMapper.batchInsertBusinessTemp(interfaces); + } + @Override + public int batchInsertBusinessRecoverTemp(List interfaces) { + return initialNetBusinessTrafficTempMapper.batchInsertBusinessRecoverTemp(interfaces); + } +} diff --git a/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialNetBusinessTrafficMapper.xml b/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialNetBusinessTrafficMapper.xml new file mode 100644 index 0000000..27e52e1 --- /dev/null +++ b/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialNetBusinessTrafficMapper.xml @@ -0,0 +1,177 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + select id, client_id, mac, name, pid, process_name, in_speed, out_speed, connection_count, ipv4_in_speed, ipv4_out_speed, ipv6_in_speed, ipv6_out_speed, create_by, create_time, update_by, update_time, remark from initial_net_business_traffic + + + + + + + + insert into initial_net_business_traffic + + client_id, + mac, + name, + pid, + process_name, + in_speed, + out_speed, + connection_count, + ipv4_in_speed, + ipv4_out_speed, + ipv6_in_speed, + ipv6_out_speed, + create_by, + create_time, + update_by, + update_time, + remark, + + + #{clientId}, + #{mac}, + #{name}, + #{pid}, + #{processName}, + #{inSpeed}, + #{outSpeed}, + #{connectionCount}, + #{ipv4InSpeed}, + #{ipv4OutSpeed}, + #{ipv6InSpeed}, + #{ipv6OutSpeed}, + #{createBy}, + #{createTime}, + #{updateBy}, + #{updateTime}, + #{remark}, + + + + + update initial_net_business_traffic + + client_id = #{clientId}, + mac = #{mac}, + name = #{name}, + pid = #{pid}, + process_name = #{processName}, + in_speed = #{inSpeed}, + out_speed = #{outSpeed}, + connection_count = #{connectionCount}, + ipv4_in_speed = #{ipv4InSpeed}, + ipv4_out_speed = #{ipv4OutSpeed}, + ipv6_in_speed = #{ipv6InSpeed}, + ipv6_out_speed = #{ipv6OutSpeed}, + create_by = #{createBy}, + create_time = #{createTime}, + update_by = #{updateBy}, + update_time = #{updateTime}, + remark = #{remark}, + + where id = #{id} + + + + delete from initial_net_business_traffic where id = #{id} + + + + delete from initial_net_business_traffic where id in + + #{id} + + + + insert into initial_net_business_traffic + (client_id, mac, name, pid, process_name, in_speed, out_speed, + connection_count, ipv4_in_speed, ipv4_out_speed, ipv6_in_speed, + ipv6_out_speed, create_by, create_time, update_by, update_time, remark) + values + + (#{item.clientId}, #{item.mac}, #{item.name}, #{item.pid}, + #{item.processName}, #{item.inSpeed}, #{item.outSpeed}, + #{item.connectionCount}, #{item.ipv4InSpeed}, #{item.ipv4OutSpeed}, + #{item.ipv6InSpeed}, #{item.ipv6OutSpeed}, #{item.createBy}, + #{item.createTime}, #{item.updateBy}, #{item.updateTime}, #{item.remark}) + + + + insert into initial_net_business_traffic + (client_id, mac, name, pid, process_name, in_speed, out_speed, + connection_count, ipv4_in_speed, ipv4_out_speed, ipv6_in_speed, + ipv6_out_speed, create_by, create_time, update_by, update_time, remark) + values + + (#{item.clientId}, #{item.mac}, #{item.name}, #{item.pid}, + #{item.processName}, #{item.inSpeed}, #{item.outSpeed}, + #{item.connectionCount}, #{item.ipv4InSpeed}, #{item.ipv4OutSpeed}, + #{item.ipv6InSpeed}, #{item.ipv6OutSpeed}, #{item.createBy}, + #{item.createTime}, #{item.updateBy}, #{item.updateTime}, #{item.remark}) + + + + \ No newline at end of file diff --git a/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialNetBusinessTrafficTempMapper.xml b/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialNetBusinessTrafficTempMapper.xml new file mode 100644 index 0000000..9fbcf33 --- /dev/null +++ b/tongran-rocketmq/src/main/resources/mapper/rocketmq/InitialNetBusinessTrafficTempMapper.xml @@ -0,0 +1,165 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + select id, client_id, mac, name, pid, process_name, in_speed, out_speed, connection_count, ipv4_in_speed, ipv4_out_speed, ipv6_in_speed, ipv6_out_speed, create_by, create_time, update_by, update_time, remark from initial_net_business_traffic_temp + + + + + + + + insert into initial_net_business_traffic_temp + + client_id, + mac, + name, + pid, + process_name, + in_speed, + out_speed, + connection_count, + ipv4_in_speed, + ipv4_out_speed, + ipv6_in_speed, + ipv6_out_speed, + create_by, + create_time, + update_by, + update_time, + remark, + + + #{clientId}, + #{mac}, + #{name}, + #{pid}, + #{processName}, + #{inSpeed}, + #{outSpeed}, + #{connectionCount}, + #{ipv4InSpeed}, + #{ipv4OutSpeed}, + #{ipv6InSpeed}, + #{ipv6OutSpeed}, + #{createBy}, + #{createTime}, + #{updateBy}, + #{updateTime}, + #{remark}, + + + + + update initial_net_business_traffic_temp + + client_id = #{clientId}, + mac = #{mac}, + name = #{name}, + pid = #{pid}, + process_name = #{processName}, + in_speed = #{inSpeed}, + out_speed = #{outSpeed}, + connection_count = #{connectionCount}, + ipv4_in_speed = #{ipv4InSpeed}, + ipv4_out_speed = #{ipv4OutSpeed}, + ipv6_in_speed = #{ipv6InSpeed}, + ipv6_out_speed = #{ipv6OutSpeed}, + create_by = #{createBy}, + create_time = #{createTime}, + update_by = #{updateBy}, + update_time = #{updateTime}, + remark = #{remark}, + + where id = #{id} + + + + delete from initial_net_business_traffic_temp where id = #{id} + + + + delete from initial_net_business_traffic_temp where id in + + #{id} + + + + delete from initial_net_business_traffic_temp where client_id = #{clientId} + + + delete from initial_bandwidth_traffic_recover_temp where client_id = #{clientId} and create_time=#{createTime} + + + insert into initial_net_business_traffic_temp + (client_id, mac, name, pid, process_name, in_speed, out_speed, + connection_count, ipv4_in_speed, ipv4_out_speed, ipv6_in_speed, + ipv6_out_speed, create_by, create_time, update_by, update_time, remark) + values + + (#{item.clientId}, #{item.mac}, #{item.name}, #{item.pid}, + #{item.processName}, #{item.inSpeed}, #{item.outSpeed}, + #{item.connectionCount}, #{item.ipv4InSpeed}, #{item.ipv4OutSpeed}, + #{item.ipv6InSpeed}, #{item.ipv6OutSpeed}, #{item.createBy}, + #{item.createTime}, #{item.updateBy}, #{item.updateTime}, #{item.remark}) + + + + insert into initial_net_business_traffic_temp + (client_id, mac, name, pid, process_name, in_speed, out_speed, + connection_count, ipv4_in_speed, ipv4_out_speed, ipv6_in_speed, + ipv6_out_speed, create_by, create_time, update_by, update_time, remark) + values + + (#{item.clientId}, #{item.mac}, #{item.name}, #{item.pid}, + #{item.processName}, #{item.inSpeed}, #{item.outSpeed}, + #{item.connectionCount}, #{item.ipv4InSpeed}, #{item.ipv4OutSpeed}, + #{item.ipv6InSpeed}, #{item.ipv6OutSpeed}, #{item.createBy}, + #{item.createTime}, #{item.updateBy}, #{item.updateTime}, #{item.remark}) + + + \ No newline at end of file