Commit 32c21c15 authored by luojun's avatar luojun

基础版完成

parent 582be208
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
......
......@@ -25,7 +25,7 @@ public class DataSourceConfig{
// @Primary
@ConfigurationProperties(prefix = "spring.datasource.dynamic.datasource.master")
public DataSource createDataSourceYdp(){
System.out.println("ydp数据源");
System.out.println("zhjt数据源");
return DruidDataSourceBuilder.create().build();
}
......
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @author lj
* @date 2024-12-16
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("api_analysis_info")
public class ApiAnalysisInfo implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "主键")
@TableId(type= IdType.AUTO)
private Long id;
@ApiModelProperty(value = "日期")
@NotBlank
private String timeInterval;
@ApiModelProperty(value = "接口访问总量")
private BigDecimal totalCount;
@ApiModelProperty(value = "成功访问量")
private BigDecimal sucCount;
@ApiModelProperty(value = "失败访问量")
private BigDecimal failCount;
@ApiModelProperty(value = "接口平均反应时长")
private BigDecimal avgTime;
public void copyFrom(ApiAnalysisInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;
/**
* @author lj
* @date 2024-12-17
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("api_call_info")
public class ApiCallInfo implements Serializable {
private static final long serialVersionUID = 1L;
@TableId(type= IdType.AUTO)
private Long id;
@ApiModelProperty(value = "日期 年月日")
private String date;
@ApiModelProperty(value = "1-成功 0-失败")
private Integer result;
@ApiModelProperty(value = "响应时间")
private Long responseTime;
public void copyFrom(ApiCallInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @author lj
* @date 2024-12-16
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("car_analysis_info")
public class CarAnalysisInfo implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "主键")
@TableId(type= IdType.ASSIGN_ID)
private Long id;
@ApiModelProperty(value = "流量预测车辆数")
private BigDecimal carPredictNum;
@ApiModelProperty(value = "流量预测准确率")
private String carNum;
private BigDecimal oneInterval;
private String timeInterval;
private BigDecimal twoInterval;
private BigDecimal threeInterval;
private BigDecimal fourInterval;
private BigDecimal fiveInterval;
private BigDecimal sixInterval;
private BigDecimal sevenInterval;
private BigDecimal eightInterval;
private BigDecimal nineInterval;
private BigDecimal tenInterval;
private BigDecimal elevenInterval;
private BigDecimal twelveInterval;
public void copyFrom(CarAnalysisInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @author lj
* @date 2024-12-16
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("data_analysis_info")
public class DataAnalysisInfo implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "主键")
@TableId(type= IdType.AUTO)
private Long id;
@ApiModelProperty(value = "日存储量")
private BigDecimal dailyStorageCapacity;
@ApiModelProperty(value = "图片存储量")
private BigDecimal imgStorageCapacity;
@ApiModelProperty(value = "总空间")
private BigDecimal totalSpace;
@ApiModelProperty(value = "剩余空间")
private BigDecimal remainingSpace;
@ApiModelProperty(value = "占用率")
private String utilizationRatio;
@ApiModelProperty(value = "日环比")
private String dailyRingRatio;
@ApiModelProperty(value = "日期")
private String timeInterval;
public void copyFrom(DataAnalysisInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;
/**
* @author lj
* @date 2024-12-16
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("device_analysis_info")
public class DeviceAnalysisInfo implements Serializable {
private static final long serialVersionUID = 1L;
@TableId(type= IdType.AUTO)
private Long id;
@ApiModelProperty(value = "时间")
private String date;
@ApiModelProperty(value = "总数据量")
private Long totalCount;
@ApiModelProperty(value = "清洗数据量")
private Long clearCount;
@ApiModelProperty(value = "标准数据量")
private Long stardCount;
@ApiModelProperty(value = "每小时平均数据量")
private Long avgCount;
public void copyFrom(DeviceAnalysisInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;
/**
* @author lj
* @date 2024-12-16
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("msg_analysis_info")
public class MsgAnalysisInfo implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "主键")
@TableId(type= IdType.AUTO)
private Long id;
@ApiModelProperty(value = "消息主题数")
private Integer topicCount;
@ApiModelProperty(value = "入场消息数量")
private Integer inNum;
@ApiModelProperty(value = "出场消息数量")
private Integer outNum;
@ApiModelProperty(value = "消息消费数")
private Integer consumeCount;
@ApiModelProperty(value = "触达率")
private String reachRate;
@ApiModelProperty(value = "日期")
private String timeInterval;
public void copyFrom(MsgAnalysisInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @author lj
* @date 2024-12-16
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("order_analysis_info")
public class OrderAnalysisInfo implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "主键")
@TableId(type= IdType.AUTO)
private Long id;
@ApiModelProperty(value = "日期")
private String timeInterval;
@ApiModelProperty(value = "云端识别次数")
private BigDecimal cloudIdentifyNum;
@ApiModelProperty(value = "云端识别修复次数")
private BigDecimal cloudIdentifyRepairNum;
@ApiModelProperty(value = "订单纠正次数")
private BigDecimal orderRepairNum;
@ApiModelProperty(value = "提交人工处理次数")
private BigDecimal submitManualProcessingNum;
@ApiModelProperty(value = "处理率")
private String processingRate;
@ApiModelProperty(value = "日环比")
private String dailyRingRatio;
public void copyFrom(OrderAnalysisInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @author lj
* @date 2024-12-16
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("pay_analysis_info")
public class PayAnalysisInfo implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "主键")
@TableId(type= IdType.AUTO)
private Long id;
@ApiModelProperty(value = "支付消息数")
private BigDecimal payMsgNum;
@ApiModelProperty(value = "0-2")
private BigDecimal oneInterval;
@ApiModelProperty(value = "日期")
private String timeInterval;
@ApiModelProperty(value = "2-4")
private BigDecimal twoInterval;
@ApiModelProperty(value = "4-6")
private BigDecimal threeInterval;
@ApiModelProperty(value = "6-8")
private BigDecimal fourInterval;
@ApiModelProperty(value = "8-10")
private BigDecimal fiveInterval;
@ApiModelProperty(value = "10-12")
private BigDecimal sixInterval;
@ApiModelProperty(value = "12-14")
private BigDecimal sevenInterval;
@ApiModelProperty(value = "14-16")
private BigDecimal eightInterval;
@ApiModelProperty(value = "16-18")
private BigDecimal nineInterval;
@ApiModelProperty(value = "18-20")
private BigDecimal tenInterval;
@ApiModelProperty(value = "20-22")
private BigDecimal elevenInterval;
@ApiModelProperty(value = "22-24")
private BigDecimal twelveInterval;
public void copyFrom(PayAnalysisInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @author lj
* @date 2024-12-16
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("plate_identify_analysis_info")
public class PlateIdentifyAnalysisInfo implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "主键")
@TableId(type= IdType.AUTO)
private Long id;
@ApiModelProperty(value = "日期")
private String timeInterval;
@ApiModelProperty(value = "车牌识别数")
private BigDecimal plateIdentifyNum;
@ApiModelProperty(value = "成功识别数")
private BigDecimal sucIdentifyNum;
@ApiModelProperty(value = "失败识别次数")
private BigDecimal failIdentifyNum;
@ApiModelProperty(value = "成功率")
private String sucRatio;
@ApiModelProperty(value = "日环比")
private String dailyRingRatio;
public void copyFrom(PlateIdentifyAnalysisInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @author lj
* @date 2024-12-16
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("push_analysis_info")
public class PushAnalysisInfo implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "主键")
@TableId(type= IdType.AUTO)
private Long id;
@ApiModelProperty(value = "消息推送数")
private BigDecimal pushMsgNum;
@ApiModelProperty(value = "日期")
private String timeInterval;
@ApiModelProperty(value = "成功数")
private BigDecimal sucNum;
@ApiModelProperty(value = "失败数")
private BigDecimal failNum;
@ApiModelProperty(value = "成功率")
private String sucRatio;
@ApiModelProperty(value = "日环比")
private String dailyRingRatio;
public void copyFrom(PushAnalysisInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.domain;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;
import org.springframework.data.annotation.Id;
import java.io.Serializable;
/**
* @author lj
* @date 2024-12-18
*/
@Data
@Builder
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = false)
@TableName("push_detail_info")
public class PushDetailInfo implements Serializable {
private static final long serialVersionUID = 1L;
@TableId(type= IdType.AUTO)
@Id
private Long id;
@ApiModelProperty(value = "1 入场 2-离场 3 付费 4 离场 5 即将产生费用 100 超时补拍通知")
private Integer msgSubType;
@ApiModelProperty(value = "1-成功 0-失败")
private Integer resulte;
@ApiModelProperty(value = "日期")
private String date;
@ApiModelProperty(value = "消息")
private String content;
public void copyFrom(PushDetailInfo source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
}
package admin.modules.analysis.service;
import admin.base.CommonService;
import admin.base.PageInfo;
import admin.modules.analysis.domain.ApiAnalysisInfo;
import admin.modules.analysis.service.dto.ApiAnalysisInfoDto;
import admin.modules.analysis.service.dto.ApiAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.springframework.data.domain.Pageable;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
public interface ApiAnalysisInfoService extends CommonService<ApiAnalysisInfo> {
static final String CACHE_KEY = "apiAnalysisInfo";
/**
* 查询数据分页
* @param query 条件
* @param pageable 分页参数
* @return PageInfo<ApiAnalysisInfoDto>
*/
PageInfo<ApiAnalysisInfoDto> queryAll(ApiAnalysisInfoQueryCriteria query, Pageable pageable);
/**
* 查询所有数据不分页
* @param query 条件参数
* @return List<ApiAnalysisInfoDto>
*/
List<ApiAnalysisInfoDto> queryAll(ApiAnalysisInfoQueryCriteria query);
ApiAnalysisInfo getById(Long id);
ApiAnalysisInfoDto findById(Long id);
/**
* 插入一条新数据。
*/
int insert(ApiAnalysisInfoDto resources);
int updateById(ApiAnalysisInfoDto resources);
int removeById(Long id);
int removeByIds(Set<Long> ids);
/**
* 根据日期查询
* @param substring
* @return
*/
ApiAnalysisInfoDto findByTimeInterval(String date);
/**
* 导出数据
* @param all 待导出的数据
* @param response /
* @throws IOException /
*/
// void download(List<ApiAnalysisInfoDto> all, HttpServletResponse response) throws IOException;
PageInfo<ApiAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size);
}
package admin.modules.analysis.service;
import admin.base.CommonService;
import admin.base.PageInfo;
import admin.modules.analysis.domain.CarAnalysisInfo;
import admin.modules.analysis.service.dto.ApiAnalysisInfoDto;
import admin.modules.analysis.service.dto.CarAnalysisInfoDto;
import admin.modules.analysis.service.dto.CarAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.springframework.data.domain.Pageable;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
public interface CarAnalysisInfoService extends CommonService<CarAnalysisInfo> {
static final String CACHE_KEY = "carAnalysisInfo";
/**
* 查询数据分页
* @param query 条件
* @param pageable 分页参数
* @return PageInfo<CarAnalysisInfoDto>
*/
PageInfo<CarAnalysisInfoDto> queryAll(CarAnalysisInfoQueryCriteria query, Pageable pageable);
/**
* 查询所有数据不分页
* @param query 条件参数
* @return List<CarAnalysisInfoDto>
*/
List<CarAnalysisInfoDto> queryAll(CarAnalysisInfoQueryCriteria query);
CarAnalysisInfo getById(Long id);
CarAnalysisInfoDto findById(Long id);
/**
* 插入一条新数据。
*/
int insert(CarAnalysisInfoDto resources);
int updateById(CarAnalysisInfoDto resources);
int removeById(Long id);
int removeByIds(Set<Long> ids);
/**
* 导出数据
* @param all 待导出的数据
* @param response /
* @throws IOException /
*/
// void download(List<CarAnalysisInfoDto> all, HttpServletResponse response) throws IOException;
PageInfo<CarAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size);
}
package admin.modules.analysis.service;
import admin.base.CommonService;
import admin.base.PageInfo;
import admin.modules.analysis.domain.DataAnalysisInfo;
import admin.modules.analysis.service.dto.DataAnalysisInfoDto;
import admin.modules.analysis.service.dto.DataAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.springframework.data.domain.Pageable;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
public interface DataAnalysisInfoService extends CommonService<DataAnalysisInfo> {
static final String CACHE_KEY = "dataAnalysisInfo";
/**
* 查询数据分页
* @param query 条件
* @param pageable 分页参数
* @return PageInfo<DataAnalysisInfoDto>
*/
PageInfo<DataAnalysisInfoDto> queryAll(DataAnalysisInfoQueryCriteria query, Pageable pageable);
/**
* 查询所有数据不分页
* @param query 条件参数
* @return List<DataAnalysisInfoDto>
*/
List<DataAnalysisInfoDto> queryAll(DataAnalysisInfoQueryCriteria query);
DataAnalysisInfo getById(Long id);
DataAnalysisInfoDto findById(Long id);
/**
* 插入一条新数据。
*/
int insert(DataAnalysisInfoDto resources);
int updateById(DataAnalysisInfoDto resources);
int removeById(Long id);
int removeByIds(Set<Long> ids);
/**
* 导出数据
* @param all 待导出的数据
* @param response /
* @throws IOException /
*/
// void download(List<DataAnalysisInfoDto> all, HttpServletResponse response) throws IOException;
PageInfo<DataAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size);
}
package admin.modules.analysis.service;
import admin.base.CommonService;
import admin.base.PageInfo;
import admin.modules.analysis.domain.DeviceAnalysisInfo;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoDto;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.springframework.data.domain.Pageable;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
public interface DeviceAnalysisInfoService extends CommonService<DeviceAnalysisInfo> {
static final String CACHE_KEY = "deviceAnalysisInfo";
/**
* 查询数据分页
* @param query 条件
* @param pageable 分页参数
* @return PageInfo<DeviceAnalysisInfoDto>
*/
PageInfo<DeviceAnalysisInfoDto> queryAll(DeviceAnalysisInfoQueryCriteria query, Pageable pageable);
/**
* 查询所有数据不分页
* @param query 条件参数
* @return List<DeviceAnalysisInfoDto>
*/
List<DeviceAnalysisInfoDto> queryAll(DeviceAnalysisInfoQueryCriteria query);
DeviceAnalysisInfo getById(Long id);
DeviceAnalysisInfoDto findById(Long id);
/**
* 插入一条新数据。
*/
int insert(DeviceAnalysisInfoDto resources);
int updateById(DeviceAnalysisInfoDto resources);
int removeById(Long id);
int removeByIds(Set<Long> ids);
/**
* 导出数据
* @param all 待导出的数据
* @param response /
* @throws IOException /
*/
// void download(List<DeviceAnalysisInfoDto> all, HttpServletResponse response) throws IOException;
PageInfo<DeviceAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size);
}
package admin.modules.analysis.service;
import admin.base.CommonService;
import admin.base.PageInfo;
import admin.modules.analysis.domain.MsgAnalysisInfo;
import admin.modules.analysis.service.dto.MsgAnalysisInfoDto;
import admin.modules.analysis.service.dto.MsgAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.springframework.data.domain.Pageable;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
public interface MsgAnalysisInfoService extends CommonService<MsgAnalysisInfo> {
static final String CACHE_KEY = "msgAnalysisInfo";
/**
* 查询数据分页
* @param query 条件
* @param pageable 分页参数
* @return PageInfo<MsgAnalysisInfoDto>
*/
PageInfo<MsgAnalysisInfoDto> queryAll(MsgAnalysisInfoQueryCriteria query, Pageable pageable);
/**
* 查询所有数据不分页
* @param query 条件参数
* @return List<MsgAnalysisInfoDto>
*/
List<MsgAnalysisInfoDto> queryAll(MsgAnalysisInfoQueryCriteria query);
MsgAnalysisInfo getById(Long id);
MsgAnalysisInfoDto findById(Long id);
/**
* 插入一条新数据。
*/
int insert(MsgAnalysisInfoDto resources);
int updateById(MsgAnalysisInfoDto resources);
int removeById(Long id);
int removeByIds(Set<Long> ids);
/**
* 导出数据
* @param all 待导出的数据
* @param response /
* @throws IOException /
*/
// void download(List<MsgAnalysisInfoDto> all, HttpServletResponse response) throws IOException;
PageInfo<MsgAnalysisInfoDto>queryPage(String startDate, String endDate, Integer page, Integer size);
}
package admin.modules.analysis.service;
import admin.base.CommonService;
import admin.base.PageInfo;
import admin.modules.analysis.domain.OrderAnalysisInfo;
import admin.modules.analysis.service.dto.OrderAnalysisInfoDto;
import admin.modules.analysis.service.dto.OrderAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.springframework.data.domain.Pageable;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
public interface OrderAnalysisInfoService extends CommonService<OrderAnalysisInfo> {
static final String CACHE_KEY = "orderAnalysisInfo";
/**
* 查询数据分页
* @param query 条件
* @param pageable 分页参数
* @return PageInfo<OrderAnalysisInfoDto>
*/
PageInfo<OrderAnalysisInfoDto> queryAll(OrderAnalysisInfoQueryCriteria query, Pageable pageable);
/**
* 查询所有数据不分页
* @param query 条件参数
* @return List<OrderAnalysisInfoDto>
*/
List<OrderAnalysisInfoDto> queryAll(OrderAnalysisInfoQueryCriteria query);
OrderAnalysisInfo getById(Long id);
OrderAnalysisInfoDto findById(Long id);
/**
* 插入一条新数据。
*/
int insert(OrderAnalysisInfoDto resources);
int updateById(OrderAnalysisInfoDto resources);
int removeById(Long id);
int removeByIds(Set<Long> ids);
/**
* 导出数据
* @param all 待导出的数据
* @param response /
* @throws IOException /
*/
// void download(List<OrderAnalysisInfoDto> all, HttpServletResponse response) throws IOException;
PageInfo<OrderAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size);
}
package admin.modules.analysis.service;
import admin.base.CommonService;
import admin.base.PageInfo;
import admin.modules.analysis.domain.PayAnalysisInfo;
import admin.modules.analysis.service.dto.PayAnalysisInfoDto;
import admin.modules.analysis.service.dto.PayAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.springframework.data.domain.Pageable;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
public interface PayAnalysisInfoService extends CommonService<PayAnalysisInfo> {
static final String CACHE_KEY = "payAnalysisInfo";
/**
* 查询数据分页
* @param query 条件
* @param pageable 分页参数
* @return PageInfo<PayAnalysisInfoDto>
*/
PageInfo<PayAnalysisInfoDto> queryAll(PayAnalysisInfoQueryCriteria query, Pageable pageable);
/**
* 查询所有数据不分页
* @param query 条件参数
* @return List<PayAnalysisInfoDto>
*/
List<PayAnalysisInfoDto> queryAll(PayAnalysisInfoQueryCriteria query);
PayAnalysisInfo getById(Long id);
PayAnalysisInfoDto findById(Long id);
/**
* 插入一条新数据。
*/
int insert(PayAnalysisInfoDto resources);
int updateById(PayAnalysisInfoDto resources);
int removeById(Long id);
int removeByIds(Set<Long> ids);
/**
* 导出数据
* @param all 待导出的数据
* @param response /
* @throws IOException /
*/
// void download(List<PayAnalysisInfoDto> all, HttpServletResponse response) throws IOException;
PageInfo<PayAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size);
}
package admin.modules.analysis.service;
import admin.base.CommonService;
import admin.base.PageInfo;
import admin.modules.analysis.domain.PlateIdentifyAnalysisInfo;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoQueryCriteria;
import org.springframework.data.domain.Pageable;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
public interface PlateIdentifyAnalysisInfoService extends CommonService<PlateIdentifyAnalysisInfo> {
static final String CACHE_KEY = "plateIdentifyAnalysisInfo";
/**
* 查询数据分页
* @param query 条件
* @param pageable 分页参数
* @return PageInfo<PlateIdentifyAnalysisInfoDto>
*/
PageInfo<PlateIdentifyAnalysisInfoDto> queryAll(PlateIdentifyAnalysisInfoQueryCriteria query, Pageable pageable);
/**
* 查询所有数据不分页
* @param query 条件参数
* @return List<PlateIdentifyAnalysisInfoDto>
*/
List<PlateIdentifyAnalysisInfoDto> queryAll(PlateIdentifyAnalysisInfoQueryCriteria query);
PlateIdentifyAnalysisInfo getById(Long id);
PlateIdentifyAnalysisInfoDto findById(Long id);
/**
* 插入一条新数据。
*/
int insert(PlateIdentifyAnalysisInfoDto resources);
int updateById(PlateIdentifyAnalysisInfoDto resources);
int removeById(Long id);
int removeByIds(Set<Long> ids);
PageInfo<PlateIdentifyAnalysisInfoDto> queryPage(String startDate,String endDate,Integer page,Integer size);
/**
* 导出数据
* @param all 待导出的数据
* @param response /
* @throws IOException /
*/
// void download(List<PlateIdentifyAnalysisInfoDto> all, HttpServletResponse response) throws IOException;
}
package admin.modules.analysis.service;
import admin.base.CommonService;
import admin.base.PageInfo;
import admin.modules.analysis.domain.PushAnalysisInfo;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import admin.modules.analysis.service.dto.PushAnalysisInfoDto;
import admin.modules.analysis.service.dto.PushAnalysisInfoQueryCriteria;
import org.springframework.data.domain.Pageable;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
public interface PushAnalysisInfoService extends CommonService<PushAnalysisInfo> {
static final String CACHE_KEY = "pushAnalysisInfo";
/**
* 查询数据分页
* @param query 条件
* @param pageable 分页参数
* @return PageInfo<PushAnalysisInfoDto>
*/
PageInfo<PushAnalysisInfoDto> queryAll(PushAnalysisInfoQueryCriteria query, Pageable pageable);
/**
* 查询所有数据不分页
* @param query 条件参数
* @return List<PushAnalysisInfoDto>
*/
List<PushAnalysisInfoDto> queryAll(PushAnalysisInfoQueryCriteria query);
PushAnalysisInfo getById(Long id);
PushAnalysisInfoDto findById(Long id);
/**
* 插入一条新数据。
*/
int insert(PushAnalysisInfoDto resources);
int updateById(PushAnalysisInfoDto resources);
int removeById(Long id);
int removeByIds(Set<Long> ids);
/**
* 导出数据
* @param all 待导出的数据
* @param response /
* @throws IOException /
*/
// void download(List<PushAnalysisInfoDto> all, HttpServletResponse response) throws IOException;
PageInfo<PushAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size);
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @website https://el-admin.vip
* @description /
* @author lj
* @date 2024-12-16
**/
@Data
public class ApiAnalysisInfoDto implements Serializable {
/** 主键 */
private Long id;
/** 日期 */
private String timeInterval;
/** 接口访问总量 */
private BigDecimal totalCount;
/** 成功访问量 */
private BigDecimal sucCount;
/** 失败访问量 */
private BigDecimal failCount;
/** 接口平均反应时长 */
private BigDecimal avgTime;
}
package admin.modules.analysis.service.dto;
import admin.annotation.Query;
import lombok.Data;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Data
public class ApiAnalysisInfoQueryCriteria{
@Query(type = Query.Type.BETWEEN)
private List<String> date;
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import lombok.Data;
import java.io.Serializable;
/**
* @website https://el-admin.vip
* @description /
* @author lj
* @date 2024-12-17
**/
@Data
public class ApiCallInfoDto implements Serializable {
private Long id;
/** 日期 年月日 */
private String date;
/** 1-成功 0-失败 */
private Integer result;
/** 响应时间 */
private Long responseTime;
}
package admin.modules.analysis.service.dto;
import admin.annotation.Query;
import lombok.Data;
import java.util.List;
/**
* @author lj
* @date 2024-12-17
*/
@Data
public class ApiCallInfoQueryCriteria{
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @website https://el-admin.vip
* @description /
* @author lj
* @date 2024-12-16
**/
@Data
public class CarAnalysisInfoDto implements Serializable {
/** 主键 */
/** 防止精度丢失 */
@JsonSerialize(using= ToStringSerializer.class)
private Long id;
/** 流量预测车辆数 */
private BigDecimal carPredictNum;
/** 流量预测准确率 */
private String carNum;
private BigDecimal oneInterval;
private String timeInterval;
private BigDecimal twoInterval;
private BigDecimal threeInterval;
private BigDecimal fourInterval;
private BigDecimal fiveInterval;
private BigDecimal sixInterval;
private BigDecimal sevenInterval;
private BigDecimal eightInterval;
private BigDecimal nineInterval;
private BigDecimal tenInterval;
private BigDecimal elevenInterval;
private BigDecimal twelveInterval;
}
package admin.modules.analysis.service.dto;
import lombok.Data;
/**
* @author lj
* @date 2024-12-16
*/
@Data
public class CarAnalysisInfoQueryCriteria{
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @website https://el-admin.vip
* @description /
* @author lj
* @date 2024-12-16
**/
@Data
public class DataAnalysisInfoDto implements Serializable {
/** 主键 */
private Long id;
/** 日存储量 */
private BigDecimal dailyStorageCapacity;
/** 图片存储量 */
private BigDecimal imgStorageCapacity;
/** 总空间 */
private BigDecimal totalSpace;
/** 剩余空间 */
private BigDecimal remainingSpace;
/** 占用率 */
private String utilizationRatio;
/** 日环比 */
private String dailyRingRatio;
/** 日期 */
private String timeInterval;
}
package admin.modules.analysis.service.dto;
import lombok.Data;
/**
* @author lj
* @date 2024-12-16
*/
@Data
public class DataAnalysisInfoQueryCriteria{
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import lombok.Data;
import java.io.Serializable;
/**
* @website https://el-admin.vip
* @description /
* @author lj
* @date 2024-12-16
**/
@Data
public class DeviceAnalysisInfoDto implements Serializable {
private Long id;
/**
* 时间
*/
private String date;
/**
* 总数据量
*/
private Long totalCount;
/**
* 清洗数据量
*/
private Long clearCount;
/**
* 标准数据量
*/
private Long stardCount;
/**
* 每小时平均数据量
*/
private Long avgCount;
}
package admin.modules.analysis.service.dto;
import admin.annotation.Query;
import lombok.Data;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Data
public class DeviceAnalysisInfoQueryCriteria{
@Query(type = Query.Type.BETWEEN)
private List<String> date;
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import lombok.Data;
import java.io.Serializable;
/**
* @author lj
* @website https://el-admin.vip
* @description /
* @date 2024-12-16
**/
@Data
public class MsgAnalysisInfoDto implements Serializable {
/**
* 主键
*/
private Long id;
/**
* 消息推送数
*/
private Integer topicCount;
/**
* 入场消息数量
*/
private Integer inNum;
/**
* 出场消息数量
*/
private Integer outNum;
/**
* 消息消费数
*/
private String consumeCount;
/**
* 触达率
*/
private String reachRate;
/**
* 日期
*/
private String timeInterval;
}
package admin.modules.analysis.service.dto;
import lombok.Data;
/**
* @author lj
* @date 2024-12-16
*/
@Data
public class MsgAnalysisInfoQueryCriteria{
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @website https://el-admin.vip
* @description /
* @author lj
* @date 2024-12-16
**/
@Data
public class OrderAnalysisInfoDto implements Serializable {
/** 主键 */
private Long id;
/** 日期 */
private String timeInterval;
/** 云端识别次数 */
private BigDecimal cloudIdentifyNum;
/** 云端识别修复次数 */
private BigDecimal cloudIdentifyRepairNum;
/** 订单纠正次数 */
private BigDecimal orderRepairNum;
/** 提交人工处理次数 */
private BigDecimal submitManualProcessingNum;
/** 处理率 */
private String processingRate;
/** 日环比 */
private String dailyRingRatio;
}
package admin.modules.analysis.service.dto;
import lombok.Data;
/**
* @author lj
* @date 2024-12-16
*/
@Data
public class OrderAnalysisInfoQueryCriteria{
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @website https://el-admin.vip
* @description /
* @author lj
* @date 2024-12-16
**/
@Data
public class PayAnalysisInfoDto implements Serializable {
/** 主键 */
private Long id;
/** 支付消息数 */
private BigDecimal payMsgNum;
/** 0-2 */
private BigDecimal oneInterval;
/** 日期 */
private String timeInterval;
/** 2-4 */
private BigDecimal twoInterval;
/** 4-6 */
private BigDecimal threeInterval;
/** 6-8 */
private BigDecimal fourInterval;
/** 8-10 */
private BigDecimal fiveInterval;
/** 10-12 */
private BigDecimal sixInterval;
/** 12-14 */
private BigDecimal sevenInterval;
/** 14-16 */
private BigDecimal eightInterval;
/** 16-18 */
private BigDecimal nineInterval;
/** 18-20 */
private BigDecimal tenInterval;
/** 20-22 */
private BigDecimal elevenInterval;
/** 22-24 */
private BigDecimal twelveInterval;
}
package admin.modules.analysis.service.dto;
import lombok.Data;
/**
* @author lj
* @date 2024-12-16
*/
@Data
public class PayAnalysisInfoQueryCriteria{
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @website https://el-admin.vip
* @description /
* @author lj
* @date 2024-12-16
**/
@Data
public class PlateIdentifyAnalysisInfoDto implements Serializable {
/** 主键 */
private Long id;
/** 日期 */
private String timeInterval;
/** 车牌识别数 */
private BigDecimal plateIdentifyNum;
/** 成功识别数 */
private BigDecimal sucIdentifyNum;
/** 失败识别次数 */
private BigDecimal failIdentifyNum;
/** 成功率 */
private String sucRatio;
/** 日环比 */
private String dailyRingRatio;
}
package admin.modules.analysis.service.dto;
import lombok.Data;
/**
* @author lj
* @date 2024-12-16
*/
@Data
public class PlateIdentifyAnalysisInfoQueryCriteria{
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import lombok.Data;
import org.apache.kafka.common.protocol.types.Field;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* @website https://el-admin.vip
* @description /
* @author lj
* @date 2024-12-16
**/
@Data
public class PushAnalysisInfoDto implements Serializable {
/** 主键 */
private Long id;
/** 消息推送数 */
private BigDecimal pushMsgNum;
/** 日期 */
private String timeInterval;
/** 成功数 */
private BigDecimal sucNum;
/** 失败数 */
private BigDecimal failNum;
/** 成功率 */
private String sucRatio;
/** 日环比 */
private String dailyRingRatio;
}
package admin.modules.analysis.service.dto;
import lombok.Data;
/**
* @author lj
* @date 2024-12-16
*/
@Data
public class PushAnalysisInfoQueryCriteria{
}
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package admin.modules.analysis.service.dto;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import lombok.Data;
import java.io.Serializable;
/**
* @author lj
* @website https://el-admin.vip
* @description /
* @date 2024-12-18
**/
@Data
public class PushDetailInfoDto implements Serializable {
/**
* 防止精度丢失
*/
@JsonSerialize(using = ToStringSerializer.class)
private Long id;
/**
* 1 入场 2-离场 3 付费 4 离场 5 即将产生费用 100 超时补拍通知
*/
private Integer msgSubType;
/**
* 1-成功 0-失败
*/
private Integer resulte;
/**
* 日期
*/
private String date;
/**
* 消息
*/
private String content;
}
package admin.modules.analysis.service.dto;
import lombok.Data;
/**
* @author lj
* @date 2024-12-18
*/
@Data
public class PushDetailInfoQueryCriteria{
}
package admin.modules.analysis.service.impl;
import admin.base.PageInfo;
import admin.base.QueryHelpMybatisPlus;
import admin.base.impl.CommonServiceImpl;
import admin.modules.analysis.domain.ApiAnalysisInfo;
import admin.modules.analysis.service.ApiAnalysisInfoService;
import admin.modules.analysis.service.dto.ApiAnalysisInfoDto;
import admin.modules.analysis.service.dto.ApiAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoDto;
import admin.modules.analysis.service.mapper.ApiAnalysisInfoMapper;
import admin.utils.ConvertUtil;
import admin.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
@Service
@AllArgsConstructor
// @CacheConfig(cacheNames = ApiAnalysisInfoService.CACHE_KEY)
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
public class ApiAnalysisInfoServiceImpl extends CommonServiceImpl<ApiAnalysisInfoMapper, ApiAnalysisInfo> implements ApiAnalysisInfoService {
// private final RedisUtils redisUtils;
private final ApiAnalysisInfoMapper apiAnalysisInfoMapper;
@Override
public PageInfo<ApiAnalysisInfoDto> queryAll(ApiAnalysisInfoQueryCriteria query, Pageable pageable) {
IPage<ApiAnalysisInfo> queryPage = PageUtil.toMybatisPage(pageable);
IPage<ApiAnalysisInfo> page = apiAnalysisInfoMapper.selectPage(queryPage, QueryHelpMybatisPlus.getPredicate(query));
return ConvertUtil.convertPage(page, ApiAnalysisInfoDto.class);
}
@Override
public List<ApiAnalysisInfoDto> queryAll(ApiAnalysisInfoQueryCriteria query){
return ConvertUtil.convertList(apiAnalysisInfoMapper.selectList(QueryHelpMybatisPlus.getPredicate(query)), ApiAnalysisInfoDto.class);
}
@Override
public ApiAnalysisInfo getById(Long id) {
return apiAnalysisInfoMapper.selectById(id);
}
@Override
// @Cacheable(key = "'id:' + #p0")
public ApiAnalysisInfoDto findById(Long id) {
return ConvertUtil.convert(getById(id), ApiAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(ApiAnalysisInfoDto resources) {
ApiAnalysisInfo entity = ConvertUtil.convert(resources, ApiAnalysisInfo.class);
return apiAnalysisInfoMapper.insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int updateById(ApiAnalysisInfoDto resources){
ApiAnalysisInfo entity = ConvertUtil.convert(resources, ApiAnalysisInfo.class);
int ret = apiAnalysisInfoMapper.updateById(entity);
// delCaches(resources.id);
return ret;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeByIds(Set<Long> ids){
// delCaches(ids);
return apiAnalysisInfoMapper.deleteBatchIds(ids);
}
@Override
public ApiAnalysisInfoDto findByTimeInterval(String date) {
ApiAnalysisInfo analysisInfo = this.lambdaQuery().eq(ApiAnalysisInfo::getTimeInterval, date).one();
return ConvertUtil.convert(analysisInfo,ApiAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeById(Long id){
Set<Long> set = new HashSet<>(1);
set.add(id);
return this.removeByIds(set);
}
@Override
public PageInfo<ApiAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size) {
PageInfo<ApiAnalysisInfoDto> pageInfo = new PageInfo<>();
Integer count = apiAnalysisInfoMapper.findCount();
List<ApiAnalysisInfoDto> byPage = apiAnalysisInfoMapper.findByPage(startDate, endDate, page * size, size);
pageInfo.setTotalElements(count);
pageInfo.setContent(byPage);
return pageInfo;
}
/*
private void delCaches(Long id) {
redisUtils.delByKey(CACHE_KEY + "::id:", id);
}
private void delCaches(Set<Long> ids) {
for (Long id: ids) {
delCaches(id);
}
}*/
/*
@Override
public void download(List<ApiAnalysisInfoDto> all, HttpServletResponse response) throws IOException {
List<Map<String, Object>> list = new ArrayList<>();
for (ApiAnalysisInfoDto apiAnalysisInfo : all) {
Map<String,Object> map = new LinkedHashMap<>();
map.put("日期", apiAnalysisInfo.getTimeInterval());
map.put("接口访问总量", apiAnalysisInfo.getTotalCount());
map.put("成功访问量", apiAnalysisInfo.getSucCount());
map.put("失败访问量", apiAnalysisInfo.getFailCount());
map.put("接口平均反应时长", apiAnalysisInfo.getAvgTime());
list.add(map);
}
FileUtil.downloadExcel(list, response);
}*/
}
package admin.modules.analysis.service.impl;
import admin.base.PageInfo;
import admin.base.QueryHelpMybatisPlus;
import admin.base.impl.CommonServiceImpl;
import admin.modules.analysis.domain.CarAnalysisInfo;
import admin.modules.analysis.service.CarAnalysisInfoService;
import admin.modules.analysis.service.dto.ApiAnalysisInfoDto;
import admin.modules.analysis.service.dto.CarAnalysisInfoDto;
import admin.modules.analysis.service.dto.CarAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoDto;
import admin.modules.analysis.service.mapper.CarAnalysisInfoMapper;
import admin.utils.ConvertUtil;
import admin.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
@Service
@AllArgsConstructor
// @CacheConfig(cacheNames = CarAnalysisInfoService.CACHE_KEY)
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
public class CarAnalysisInfoServiceImpl extends CommonServiceImpl<CarAnalysisInfoMapper, CarAnalysisInfo> implements CarAnalysisInfoService {
// private final RedisUtils redisUtils;
private final CarAnalysisInfoMapper carAnalysisInfoMapper;
@Override
public PageInfo<CarAnalysisInfoDto> queryAll(CarAnalysisInfoQueryCriteria query, Pageable pageable) {
IPage<CarAnalysisInfo> queryPage = PageUtil.toMybatisPage(pageable);
IPage<CarAnalysisInfo> page = carAnalysisInfoMapper.selectPage(queryPage, QueryHelpMybatisPlus.getPredicate(query));
return ConvertUtil.convertPage(page, CarAnalysisInfoDto.class);
}
@Override
public List<CarAnalysisInfoDto> queryAll(CarAnalysisInfoQueryCriteria query){
return ConvertUtil.convertList(carAnalysisInfoMapper.selectList(QueryHelpMybatisPlus.getPredicate(query)), CarAnalysisInfoDto.class);
}
@Override
public CarAnalysisInfo getById(Long id) {
return carAnalysisInfoMapper.selectById(id);
}
@Override
// @Cacheable(key = "'id:' + #p0")
public CarAnalysisInfoDto findById(Long id) {
return ConvertUtil.convert(getById(id), CarAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(CarAnalysisInfoDto resources) {
CarAnalysisInfo entity = ConvertUtil.convert(resources, CarAnalysisInfo.class);
return carAnalysisInfoMapper.insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int updateById(CarAnalysisInfoDto resources){
CarAnalysisInfo entity = ConvertUtil.convert(resources, CarAnalysisInfo.class);
int ret = carAnalysisInfoMapper.updateById(entity);
// delCaches(resources.id);
return ret;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeByIds(Set<Long> ids){
// delCaches(ids);
return carAnalysisInfoMapper.deleteBatchIds(ids);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeById(Long id){
Set<Long> set = new HashSet<>(1);
set.add(id);
return this.removeByIds(set);
}
@Override
public PageInfo<CarAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size) {
PageInfo<CarAnalysisInfoDto> pageInfo = new PageInfo<>();
Integer count = carAnalysisInfoMapper.findCount();
List<CarAnalysisInfoDto> byPage = carAnalysisInfoMapper.findByPage(startDate, endDate, page * size, size);
pageInfo.setTotalElements(count);
pageInfo.setContent(byPage);
return pageInfo;
}
/*
private void delCaches(Long id) {
redisUtils.delByKey(CACHE_KEY + "::id:", id);
}
private void delCaches(Set<Long> ids) {
for (Long id: ids) {
delCaches(id);
}
}*/
/*
@Override
public void download(List<CarAnalysisInfoDto> all, HttpServletResponse response) throws IOException {
List<Map<String, Object>> list = new ArrayList<>();
for (CarAnalysisInfoDto carAnalysisInfo : all) {
Map<String,Object> map = new LinkedHashMap<>();
map.put("流量预测车辆数", carAnalysisInfo.getCarPredictNum());
map.put("流量预测准确率", carAnalysisInfo.getCarNum());
map.put(" oneInterval", carAnalysisInfo.getOneInterval());
map.put(" timeInterval", carAnalysisInfo.getTimeInterval());
map.put(" twoInterval", carAnalysisInfo.getTwoInterval());
map.put(" threeInterval", carAnalysisInfo.getThreeInterval());
map.put(" fourInterval", carAnalysisInfo.getFourInterval());
map.put(" fiveInterval", carAnalysisInfo.getFiveInterval());
map.put(" sixInterval", carAnalysisInfo.getSixInterval());
map.put(" sevenInterval", carAnalysisInfo.getSevenInterval());
map.put(" eightInterval", carAnalysisInfo.getEightInterval());
map.put(" nineInterval", carAnalysisInfo.getNineInterval());
map.put(" tenInterval", carAnalysisInfo.getTenInterval());
map.put(" elevenInterval", carAnalysisInfo.getElevenInterval());
map.put(" twelveInterval", carAnalysisInfo.getTwelveInterval());
list.add(map);
}
FileUtil.downloadExcel(list, response);
}*/
}
package admin.modules.analysis.service.impl;
import admin.base.PageInfo;
import admin.base.QueryHelpMybatisPlus;
import admin.base.impl.CommonServiceImpl;
import admin.modules.analysis.domain.DataAnalysisInfo;
import admin.modules.analysis.service.DataAnalysisInfoService;
import admin.modules.analysis.service.dto.CarAnalysisInfoDto;
import admin.modules.analysis.service.dto.DataAnalysisInfoDto;
import admin.modules.analysis.service.dto.DataAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoDto;
import admin.modules.analysis.service.mapper.DataAnalysisInfoMapper;
import admin.utils.ConvertUtil;
import admin.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
@Service
@AllArgsConstructor
// @CacheConfig(cacheNames = DataAnalysisInfoService.CACHE_KEY)
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
public class DataAnalysisInfoServiceImpl extends CommonServiceImpl<DataAnalysisInfoMapper, DataAnalysisInfo> implements DataAnalysisInfoService {
// private final RedisUtils redisUtils;
private final DataAnalysisInfoMapper dataAnalysisInfoMapper;
@Override
public PageInfo<DataAnalysisInfoDto> queryAll(DataAnalysisInfoQueryCriteria query, Pageable pageable) {
IPage<DataAnalysisInfo> queryPage = PageUtil.toMybatisPage(pageable);
IPage<DataAnalysisInfo> page = dataAnalysisInfoMapper.selectPage(queryPage, QueryHelpMybatisPlus.getPredicate(query));
return ConvertUtil.convertPage(page, DataAnalysisInfoDto.class);
}
@Override
public List<DataAnalysisInfoDto> queryAll(DataAnalysisInfoQueryCriteria query){
return ConvertUtil.convertList(dataAnalysisInfoMapper.selectList(QueryHelpMybatisPlus.getPredicate(query)), DataAnalysisInfoDto.class);
}
@Override
public DataAnalysisInfo getById(Long id) {
return dataAnalysisInfoMapper.selectById(id);
}
@Override
// @Cacheable(key = "'id:' + #p0")
public DataAnalysisInfoDto findById(Long id) {
return ConvertUtil.convert(getById(id), DataAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(DataAnalysisInfoDto resources) {
DataAnalysisInfo entity = ConvertUtil.convert(resources, DataAnalysisInfo.class);
return dataAnalysisInfoMapper.insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int updateById(DataAnalysisInfoDto resources){
DataAnalysisInfo entity = ConvertUtil.convert(resources, DataAnalysisInfo.class);
int ret = dataAnalysisInfoMapper.updateById(entity);
// delCaches(resources.id);
return ret;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeByIds(Set<Long> ids){
// delCaches(ids);
return dataAnalysisInfoMapper.deleteBatchIds(ids);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeById(Long id){
Set<Long> set = new HashSet<>(1);
set.add(id);
return this.removeByIds(set);
}
@Override
public PageInfo<DataAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size) {
PageInfo<DataAnalysisInfoDto> pageInfo = new PageInfo<>();
Integer count = dataAnalysisInfoMapper.findCount();
List<DataAnalysisInfoDto> byPage = dataAnalysisInfoMapper.findByPage(startDate, endDate, page * size, size);
pageInfo.setTotalElements(count);
pageInfo.setContent(byPage);
return pageInfo;
}
/*
private void delCaches(Long id) {
redisUtils.delByKey(CACHE_KEY + "::id:", id);
}
private void delCaches(Set<Long> ids) {
for (Long id: ids) {
delCaches(id);
}
}*/
/*
@Override
public void download(List<DataAnalysisInfoDto> all, HttpServletResponse response) throws IOException {
List<Map<String, Object>> list = new ArrayList<>();
for (DataAnalysisInfoDto dataAnalysisInfo : all) {
Map<String,Object> map = new LinkedHashMap<>();
map.put("日存储量", dataAnalysisInfo.getDailyStorageCapacity());
map.put("图片存储量", dataAnalysisInfo.getImgStorageCapacity());
map.put("总空间", dataAnalysisInfo.getTotalSpace());
map.put("剩余空间", dataAnalysisInfo.getRemainingSpace());
map.put("占用率", dataAnalysisInfo.getUtilizationRatio());
map.put("日环比", dataAnalysisInfo.getDailyRingRatio());
map.put("日期", dataAnalysisInfo.getTimeInterval());
list.add(map);
}
FileUtil.downloadExcel(list, response);
}*/
}
package admin.modules.analysis.service.impl;
import admin.base.PageInfo;
import admin.base.QueryHelpMybatisPlus;
import admin.base.impl.CommonServiceImpl;
import admin.modules.analysis.domain.DeviceAnalysisInfo;
import admin.modules.analysis.service.DeviceAnalysisInfoService;
import admin.modules.analysis.service.dto.DataAnalysisInfoDto;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoDto;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PayAnalysisInfoDto;
import admin.modules.analysis.service.mapper.DeviceAnalysisInfoMapper;
import admin.utils.ConvertUtil;
import admin.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
@Service
@AllArgsConstructor
// @CacheConfig(cacheNames = DeviceAnalysisInfoService.CACHE_KEY)
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
public class DeviceAnalysisInfoServiceImpl extends CommonServiceImpl<DeviceAnalysisInfoMapper, DeviceAnalysisInfo> implements DeviceAnalysisInfoService {
// private final RedisUtils redisUtils;
private final DeviceAnalysisInfoMapper deviceAnalysisInfoMapper;
@Override
public PageInfo<DeviceAnalysisInfoDto> queryAll(DeviceAnalysisInfoQueryCriteria query, Pageable pageable) {
IPage<DeviceAnalysisInfo> queryPage = PageUtil.toMybatisPage(pageable);
IPage<DeviceAnalysisInfo> page = deviceAnalysisInfoMapper.selectPage(queryPage, QueryHelpMybatisPlus.getPredicate(query));
return ConvertUtil.convertPage(page, DeviceAnalysisInfoDto.class);
}
@Override
public List<DeviceAnalysisInfoDto> queryAll(DeviceAnalysisInfoQueryCriteria query){
return ConvertUtil.convertList(deviceAnalysisInfoMapper.selectList(QueryHelpMybatisPlus.getPredicate(query)), DeviceAnalysisInfoDto.class);
}
@Override
public DeviceAnalysisInfo getById(Long id) {
return deviceAnalysisInfoMapper.selectById(id);
}
@Override
// @Cacheable(key = "'id:' + #p0")
public DeviceAnalysisInfoDto findById(Long id) {
return ConvertUtil.convert(getById(id), DeviceAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(DeviceAnalysisInfoDto resources) {
DeviceAnalysisInfo entity = ConvertUtil.convert(resources, DeviceAnalysisInfo.class);
return deviceAnalysisInfoMapper.insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int updateById(DeviceAnalysisInfoDto resources){
DeviceAnalysisInfo entity = ConvertUtil.convert(resources, DeviceAnalysisInfo.class);
int ret = deviceAnalysisInfoMapper.updateById(entity);
// delCaches(resources.id);
return ret;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeByIds(Set<Long> ids){
// delCaches(ids);
return deviceAnalysisInfoMapper.deleteBatchIds(ids);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeById(Long id){
Set<Long> set = new HashSet<>(1);
set.add(id);
return this.removeByIds(set);
}
@Override
public PageInfo<DeviceAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size) {
PageInfo<DeviceAnalysisInfoDto> pageInfo = new PageInfo<>();
Integer count = deviceAnalysisInfoMapper.findCount();
List<DeviceAnalysisInfoDto> byPage = deviceAnalysisInfoMapper.findByPage(startDate, endDate, page * size, size);
pageInfo.setTotalElements(count);
pageInfo.setContent(byPage);
return pageInfo;
}
/*
private void delCaches(Long id) {
redisUtils.delByKey(CACHE_KEY + "::id:", id);
}
private void delCaches(Set<Long> ids) {
for (Long id: ids) {
delCaches(id);
}
}*/
/*
@Override
public void download(List<DeviceAnalysisInfoDto> all, HttpServletResponse response) throws IOException {
List<Map<String, Object>> list = new ArrayList<>();
for (DeviceAnalysisInfoDto deviceAnalysisInfo : all) {
Map<String,Object> map = new LinkedHashMap<>();
map.put("创建时间", deviceAnalysisInfo.getCreateTime());
map.put("设备类型", deviceAnalysisInfo.getDeviceType());
map.put("泊位号", deviceAnalysisInfo.getParkingNo());
map.put("路段id", deviceAnalysisInfo.getRoadId());
map.put("车场id", deviceAnalysisInfo.getParkingId());
list.add(map);
}
FileUtil.downloadExcel(list, response);
}*/
}
package admin.modules.analysis.service.impl;
import admin.base.PageInfo;
import admin.base.QueryHelpMybatisPlus;
import admin.base.impl.CommonServiceImpl;
import admin.modules.analysis.domain.MsgAnalysisInfo;
import admin.modules.analysis.service.MsgAnalysisInfoService;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoDto;
import admin.modules.analysis.service.dto.MsgAnalysisInfoDto;
import admin.modules.analysis.service.dto.MsgAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PayAnalysisInfoDto;
import admin.modules.analysis.service.mapper.MsgAnalysisInfoMapper;
import admin.utils.ConvertUtil;
import admin.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
@Service
@AllArgsConstructor
// @CacheConfig(cacheNames = MsgAnalysisInfoService.CACHE_KEY)
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
public class MsgAnalysisInfoServiceImpl extends CommonServiceImpl<MsgAnalysisInfoMapper, MsgAnalysisInfo> implements MsgAnalysisInfoService {
// private final RedisUtils redisUtils;
private final MsgAnalysisInfoMapper msgAnalysisInfoMapper;
@Override
public PageInfo<MsgAnalysisInfoDto> queryAll(MsgAnalysisInfoQueryCriteria query, Pageable pageable) {
IPage<MsgAnalysisInfo> queryPage = PageUtil.toMybatisPage(pageable);
IPage<MsgAnalysisInfo> page = msgAnalysisInfoMapper.selectPage(queryPage, QueryHelpMybatisPlus.getPredicate(query));
return ConvertUtil.convertPage(page, MsgAnalysisInfoDto.class);
}
@Override
public List<MsgAnalysisInfoDto> queryAll(MsgAnalysisInfoQueryCriteria query){
return ConvertUtil.convertList(msgAnalysisInfoMapper.selectList(QueryHelpMybatisPlus.getPredicate(query)), MsgAnalysisInfoDto.class);
}
@Override
public MsgAnalysisInfo getById(Long id) {
return msgAnalysisInfoMapper.selectById(id);
}
@Override
// @Cacheable(key = "'id:' + #p0")
public MsgAnalysisInfoDto findById(Long id) {
return ConvertUtil.convert(getById(id), MsgAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(MsgAnalysisInfoDto resources) {
MsgAnalysisInfo entity = ConvertUtil.convert(resources, MsgAnalysisInfo.class);
return msgAnalysisInfoMapper.insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int updateById(MsgAnalysisInfoDto resources){
MsgAnalysisInfo entity = ConvertUtil.convert(resources, MsgAnalysisInfo.class);
int ret = msgAnalysisInfoMapper.updateById(entity);
// delCaches(resources.id);
return ret;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeByIds(Set<Long> ids){
// delCaches(ids);
return msgAnalysisInfoMapper.deleteBatchIds(ids);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeById(Long id){
Set<Long> set = new HashSet<>(1);
set.add(id);
return this.removeByIds(set);
}
@Override
public PageInfo<MsgAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size) {
PageInfo<MsgAnalysisInfoDto> pageInfo = new PageInfo<>();
Integer count = msgAnalysisInfoMapper.findCount();
List<MsgAnalysisInfoDto> byPage = msgAnalysisInfoMapper.findByPage(startDate, endDate, page * size, size);
pageInfo.setTotalElements(count);
pageInfo.setContent(byPage);
return pageInfo;
}
/*
private void delCaches(Long id) {
redisUtils.delByKey(CACHE_KEY + "::id:", id);
}
private void delCaches(Set<Long> ids) {
for (Long id: ids) {
delCaches(id);
}
}*/
/*
@Override
public void download(List<MsgAnalysisInfoDto> all, HttpServletResponse response) throws IOException {
List<Map<String, Object>> list = new ArrayList<>();
for (MsgAnalysisInfoDto msgAnalysisInfo : all) {
Map<String,Object> map = new LinkedHashMap<>();
map.put("消息推送数", msgAnalysisInfo.getPushMsgNum());
map.put("成功推送数", msgAnalysisInfo.getSucNum());
map.put("失败推送数", msgAnalysisInfo.getFailNum());
map.put("成功率", msgAnalysisInfo.getSucRatio());
map.put("日环比", msgAnalysisInfo.getDailyRingRatio());
map.put("日期", msgAnalysisInfo.getTimeInterval());
list.add(map);
}
FileUtil.downloadExcel(list, response);
}*/
}
package admin.modules.analysis.service.impl;
import admin.base.PageInfo;
import admin.base.QueryHelpMybatisPlus;
import admin.base.impl.CommonServiceImpl;
import admin.modules.analysis.domain.OrderAnalysisInfo;
import admin.modules.analysis.service.OrderAnalysisInfoService;
import admin.modules.analysis.service.dto.MsgAnalysisInfoDto;
import admin.modules.analysis.service.dto.OrderAnalysisInfoDto;
import admin.modules.analysis.service.dto.OrderAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PayAnalysisInfoDto;
import admin.modules.analysis.service.mapper.OrderAnalysisInfoMapper;
import admin.utils.ConvertUtil;
import admin.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
@Service
@AllArgsConstructor
// @CacheConfig(cacheNames = OrderAnalysisInfoService.CACHE_KEY)
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
public class OrderAnalysisInfoServiceImpl extends CommonServiceImpl<OrderAnalysisInfoMapper, OrderAnalysisInfo> implements OrderAnalysisInfoService {
// private final RedisUtils redisUtils;
private final OrderAnalysisInfoMapper orderAnalysisInfoMapper;
@Override
public PageInfo<OrderAnalysisInfoDto> queryAll(OrderAnalysisInfoQueryCriteria query, Pageable pageable) {
IPage<OrderAnalysisInfo> queryPage = PageUtil.toMybatisPage(pageable);
IPage<OrderAnalysisInfo> page = orderAnalysisInfoMapper.selectPage(queryPage, QueryHelpMybatisPlus.getPredicate(query));
return ConvertUtil.convertPage(page, OrderAnalysisInfoDto.class);
}
@Override
public List<OrderAnalysisInfoDto> queryAll(OrderAnalysisInfoQueryCriteria query){
return ConvertUtil.convertList(orderAnalysisInfoMapper.selectList(QueryHelpMybatisPlus.getPredicate(query)), OrderAnalysisInfoDto.class);
}
@Override
public OrderAnalysisInfo getById(Long id) {
return orderAnalysisInfoMapper.selectById(id);
}
@Override
// @Cacheable(key = "'id:' + #p0")
public OrderAnalysisInfoDto findById(Long id) {
return ConvertUtil.convert(getById(id), OrderAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(OrderAnalysisInfoDto resources) {
OrderAnalysisInfo entity = ConvertUtil.convert(resources, OrderAnalysisInfo.class);
return orderAnalysisInfoMapper.insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int updateById(OrderAnalysisInfoDto resources){
OrderAnalysisInfo entity = ConvertUtil.convert(resources, OrderAnalysisInfo.class);
int ret = orderAnalysisInfoMapper.updateById(entity);
// delCaches(resources.id);
return ret;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeByIds(Set<Long> ids){
// delCaches(ids);
return orderAnalysisInfoMapper.deleteBatchIds(ids);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeById(Long id){
Set<Long> set = new HashSet<>(1);
set.add(id);
return this.removeByIds(set);
}
@Override
public PageInfo<OrderAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size) {
PageInfo<OrderAnalysisInfoDto> pageInfo = new PageInfo<>();
Integer count = orderAnalysisInfoMapper.findCount();
List<OrderAnalysisInfoDto> byPage = orderAnalysisInfoMapper.findByPage(startDate, endDate, page * size, size);
pageInfo.setTotalElements(count);
pageInfo.setContent(byPage);
return pageInfo;
}
/*
private void delCaches(Long id) {
redisUtils.delByKey(CACHE_KEY + "::id:", id);
}
private void delCaches(Set<Long> ids) {
for (Long id: ids) {
delCaches(id);
}
}*/
/*
@Override
public void download(List<OrderAnalysisInfoDto> all, HttpServletResponse response) throws IOException {
List<Map<String, Object>> list = new ArrayList<>();
for (OrderAnalysisInfoDto orderAnalysisInfo : all) {
Map<String,Object> map = new LinkedHashMap<>();
map.put("日期", orderAnalysisInfo.getTimeInterval());
map.put("云端识别次数", orderAnalysisInfo.getCloudIdentifyNum());
map.put("云端识别修复次数", orderAnalysisInfo.getCloudIdentifyRepairNum());
map.put("订单纠正次数", orderAnalysisInfo.getOrderRepairNum());
map.put("提交人工处理次数", orderAnalysisInfo.getSubmitManualProcessingNum());
map.put("处理率", orderAnalysisInfo.getProcessingRate());
map.put("日环比", orderAnalysisInfo.getDailyRingRatio());
list.add(map);
}
FileUtil.downloadExcel(list, response);
}*/
}
package admin.modules.analysis.service.impl;
import admin.base.PageInfo;
import admin.base.QueryHelpMybatisPlus;
import admin.base.impl.CommonServiceImpl;
import admin.modules.analysis.domain.PayAnalysisInfo;
import admin.modules.analysis.service.PayAnalysisInfoService;
import admin.modules.analysis.service.dto.OrderAnalysisInfoDto;
import admin.modules.analysis.service.dto.PayAnalysisInfoDto;
import admin.modules.analysis.service.dto.PayAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.dto.PushAnalysisInfoDto;
import admin.modules.analysis.service.mapper.PayAnalysisInfoMapper;
import admin.utils.ConvertUtil;
import admin.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
@Service
@AllArgsConstructor
// @CacheConfig(cacheNames = PayAnalysisInfoService.CACHE_KEY)
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
public class PayAnalysisInfoServiceImpl extends CommonServiceImpl<PayAnalysisInfoMapper, PayAnalysisInfo> implements PayAnalysisInfoService {
// private final RedisUtils redisUtils;
private final PayAnalysisInfoMapper payAnalysisInfoMapper;
@Override
public PageInfo<PayAnalysisInfoDto> queryAll(PayAnalysisInfoQueryCriteria query, Pageable pageable) {
IPage<PayAnalysisInfo> queryPage = PageUtil.toMybatisPage(pageable);
IPage<PayAnalysisInfo> page = payAnalysisInfoMapper.selectPage(queryPage, QueryHelpMybatisPlus.getPredicate(query));
return ConvertUtil.convertPage(page, PayAnalysisInfoDto.class);
}
@Override
public List<PayAnalysisInfoDto> queryAll(PayAnalysisInfoQueryCriteria query){
return ConvertUtil.convertList(payAnalysisInfoMapper.selectList(QueryHelpMybatisPlus.getPredicate(query)), PayAnalysisInfoDto.class);
}
@Override
public PayAnalysisInfo getById(Long id) {
return payAnalysisInfoMapper.selectById(id);
}
@Override
// @Cacheable(key = "'id:' + #p0")
public PayAnalysisInfoDto findById(Long id) {
return ConvertUtil.convert(getById(id), PayAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(PayAnalysisInfoDto resources) {
PayAnalysisInfo entity = ConvertUtil.convert(resources, PayAnalysisInfo.class);
return payAnalysisInfoMapper.insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int updateById(PayAnalysisInfoDto resources){
PayAnalysisInfo entity = ConvertUtil.convert(resources, PayAnalysisInfo.class);
int ret = payAnalysisInfoMapper.updateById(entity);
// delCaches(resources.id);
return ret;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeByIds(Set<Long> ids){
// delCaches(ids);
return payAnalysisInfoMapper.deleteBatchIds(ids);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeById(Long id){
Set<Long> set = new HashSet<>(1);
set.add(id);
return this.removeByIds(set);
}
@Override
public PageInfo<PayAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size) {
PageInfo<PayAnalysisInfoDto> pageInfo = new PageInfo<>();
Integer count = payAnalysisInfoMapper.findCount();
List<PayAnalysisInfoDto> byPage = payAnalysisInfoMapper.findByPage(startDate, endDate, page * size, size);
pageInfo.setTotalElements(count);
pageInfo.setContent(byPage);
return pageInfo;
}
/*
private void delCaches(Long id) {
redisUtils.delByKey(CACHE_KEY + "::id:", id);
}
private void delCaches(Set<Long> ids) {
for (Long id: ids) {
delCaches(id);
}
}*/
/*
@Override
public void download(List<PayAnalysisInfoDto> all, HttpServletResponse response) throws IOException {
List<Map<String, Object>> list = new ArrayList<>();
for (PayAnalysisInfoDto payAnalysisInfo : all) {
Map<String,Object> map = new LinkedHashMap<>();
map.put("支付消息数", payAnalysisInfo.getPayMsgNum());
map.put("0-2", payAnalysisInfo.getOneInterval());
map.put("日期", payAnalysisInfo.getTimeInterval());
map.put("2-4", payAnalysisInfo.getTwoInterval());
map.put("4-6", payAnalysisInfo.getThreeInterval());
map.put("6-8", payAnalysisInfo.getFourInterval());
map.put("8-10", payAnalysisInfo.getFiveInterval());
map.put("10-12", payAnalysisInfo.getSixInterval());
map.put("12-14", payAnalysisInfo.getSevenInterval());
map.put("14-16", payAnalysisInfo.getEightInterval());
map.put("16-18", payAnalysisInfo.getNineInterval());
map.put("18-20", payAnalysisInfo.getTenInterval());
map.put("20-22", payAnalysisInfo.getElevenInterval());
map.put("22-24", payAnalysisInfo.getTwelveInterval());
list.add(map);
}
FileUtil.downloadExcel(list, response);
}*/
}
package admin.modules.analysis.service.impl;
import admin.base.PageInfo;
import admin.base.QueryHelpMybatisPlus;
import admin.base.impl.CommonServiceImpl;
import admin.modules.analysis.domain.PlateIdentifyAnalysisInfo;
import admin.modules.analysis.service.PlateIdentifyAnalysisInfoService;
import admin.modules.analysis.service.dto.PayAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.mapper.PlateIdentifyAnalysisInfoMapper;
import admin.utils.ConvertUtil;
import admin.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
@Service
@AllArgsConstructor
// @CacheConfig(cacheNames = PlateIdentifyAnalysisInfoService.CACHE_KEY)
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
public class PlateIdentifyAnalysisInfoServiceImpl extends CommonServiceImpl<PlateIdentifyAnalysisInfoMapper, PlateIdentifyAnalysisInfo> implements PlateIdentifyAnalysisInfoService {
// private final RedisUtils redisUtils;
private final PlateIdentifyAnalysisInfoMapper plateIdentifyAnalysisInfoMapper;
@Override
public PageInfo<PlateIdentifyAnalysisInfoDto> queryAll(PlateIdentifyAnalysisInfoQueryCriteria query, Pageable pageable) {
IPage<PlateIdentifyAnalysisInfo> queryPage = PageUtil.toMybatisPage(pageable);
IPage<PlateIdentifyAnalysisInfo> page = plateIdentifyAnalysisInfoMapper.selectPage(queryPage, QueryHelpMybatisPlus.getPredicate(query));
return ConvertUtil.convertPage(page, PlateIdentifyAnalysisInfoDto.class);
}
@Override
public List<PlateIdentifyAnalysisInfoDto> queryAll(PlateIdentifyAnalysisInfoQueryCriteria query){
return ConvertUtil.convertList(plateIdentifyAnalysisInfoMapper.selectList(QueryHelpMybatisPlus.getPredicate(query)), PlateIdentifyAnalysisInfoDto.class);
}
@Override
public PlateIdentifyAnalysisInfo getById(Long id) {
return plateIdentifyAnalysisInfoMapper.selectById(id);
}
@Override
// @Cacheable(key = "'id:' + #p0")
public PlateIdentifyAnalysisInfoDto findById(Long id) {
return ConvertUtil.convert(getById(id), PlateIdentifyAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(PlateIdentifyAnalysisInfoDto resources) {
PlateIdentifyAnalysisInfo entity = ConvertUtil.convert(resources, PlateIdentifyAnalysisInfo.class);
return plateIdentifyAnalysisInfoMapper.insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int updateById(PlateIdentifyAnalysisInfoDto resources){
PlateIdentifyAnalysisInfo entity = ConvertUtil.convert(resources, PlateIdentifyAnalysisInfo.class);
int ret = plateIdentifyAnalysisInfoMapper.updateById(entity);
// delCaches(resources.id);
return ret;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeByIds(Set<Long> ids){
// delCaches(ids);
return plateIdentifyAnalysisInfoMapper.deleteBatchIds(ids);
}
@Override
public PageInfo<PlateIdentifyAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size) {
PageInfo<PlateIdentifyAnalysisInfoDto> pageInfo = new PageInfo<>();
Integer count = plateIdentifyAnalysisInfoMapper.findCount();
List<PlateIdentifyAnalysisInfoDto> byPage = plateIdentifyAnalysisInfoMapper.findByPage(startDate, endDate, page * size, size);
pageInfo.setTotalElements(count);
pageInfo.setContent(byPage);
return pageInfo;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeById(Long id){
Set<Long> set = new HashSet<>(1);
set.add(id);
return this.removeByIds(set);
}
/*
private void delCaches(Long id) {
redisUtils.delByKey(CACHE_KEY + "::id:", id);
}
private void delCaches(Set<Long> ids) {
for (Long id: ids) {
delCaches(id);
}
}*/
/*
@Override
public void download(List<PlateIdentifyAnalysisInfoDto> all, HttpServletResponse response) throws IOException {
List<Map<String, Object>> list = new ArrayList<>();
for (PlateIdentifyAnalysisInfoDto plateIdentifyAnalysisInfo : all) {
Map<String,Object> map = new LinkedHashMap<>();
map.put("日期", plateIdentifyAnalysisInfo.getTimeInterval());
map.put("车牌识别数", plateIdentifyAnalysisInfo.getPlateIdentifyNum());
map.put("成功识别数", plateIdentifyAnalysisInfo.getSucIdentifyNum());
map.put("失败识别次数", plateIdentifyAnalysisInfo.getFailIdentifyNum());
map.put("成功率", plateIdentifyAnalysisInfo.getSucRatio());
map.put("日环比", plateIdentifyAnalysisInfo.getDailyRingRatio());
list.add(map);
}
FileUtil.downloadExcel(list, response);
}*/
}
package admin.modules.analysis.service.impl;
import admin.base.PageInfo;
import admin.base.QueryHelpMybatisPlus;
import admin.base.impl.CommonServiceImpl;
import admin.modules.analysis.domain.PushAnalysisInfo;
import admin.modules.analysis.service.PushAnalysisInfoService;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import admin.modules.analysis.service.dto.PushAnalysisInfoDto;
import admin.modules.analysis.service.dto.PushAnalysisInfoQueryCriteria;
import admin.modules.analysis.service.mapper.PushAnalysisInfoMapper;
import admin.utils.ConvertUtil;
import admin.utils.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import lombok.AllArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
*/
@Service
@AllArgsConstructor
// @CacheConfig(cacheNames = PushAnalysisInfoService.CACHE_KEY)
@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
public class PushAnalysisInfoServiceImpl extends CommonServiceImpl<PushAnalysisInfoMapper, PushAnalysisInfo> implements PushAnalysisInfoService {
// private final RedisUtils redisUtils;
private final PushAnalysisInfoMapper pushAnalysisInfoMapper;
@Override
public PageInfo<PushAnalysisInfoDto> queryAll(PushAnalysisInfoQueryCriteria query, Pageable pageable) {
IPage<PushAnalysisInfo> queryPage = PageUtil.toMybatisPage(pageable);
IPage<PushAnalysisInfo> page = pushAnalysisInfoMapper.selectPage(queryPage, QueryHelpMybatisPlus.getPredicate(query));
return ConvertUtil.convertPage(page, PushAnalysisInfoDto.class);
}
@Override
public List<PushAnalysisInfoDto> queryAll(PushAnalysisInfoQueryCriteria query){
return ConvertUtil.convertList(pushAnalysisInfoMapper.selectList(QueryHelpMybatisPlus.getPredicate(query)), PushAnalysisInfoDto.class);
}
@Override
public PushAnalysisInfo getById(Long id) {
return pushAnalysisInfoMapper.selectById(id);
}
@Override
// @Cacheable(key = "'id:' + #p0")
public PushAnalysisInfoDto findById(Long id) {
return ConvertUtil.convert(getById(id), PushAnalysisInfoDto.class);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(PushAnalysisInfoDto resources) {
PushAnalysisInfo entity = ConvertUtil.convert(resources, PushAnalysisInfo.class);
return pushAnalysisInfoMapper.insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int updateById(PushAnalysisInfoDto resources){
PushAnalysisInfo entity = ConvertUtil.convert(resources, PushAnalysisInfo.class);
int ret = pushAnalysisInfoMapper.updateById(entity);
// delCaches(resources.id);
return ret;
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeByIds(Set<Long> ids){
// delCaches(ids);
return pushAnalysisInfoMapper.deleteBatchIds(ids);
}
@Override
@Transactional(rollbackFor = Exception.class)
public int removeById(Long id){
Set<Long> set = new HashSet<>(1);
set.add(id);
return this.removeByIds(set);
}
@Override
public PageInfo<PushAnalysisInfoDto> queryPage(String startDate, String endDate, Integer page, Integer size) {
PageInfo<PushAnalysisInfoDto> pageInfo = new PageInfo<>();
Integer count = pushAnalysisInfoMapper.findCount();
List<PushAnalysisInfoDto> byPage = pushAnalysisInfoMapper.findByPage(startDate, endDate, page * size, size);
pageInfo.setTotalElements(count);
pageInfo.setContent(byPage);
return pageInfo;
}
/*
private void delCaches(Long id) {
redisUtils.delByKey(CACHE_KEY + "::id:", id);
}
private void delCaches(Set<Long> ids) {
for (Long id: ids) {
delCaches(id);
}
}*/
/*
@Override
public void download(List<PushAnalysisInfoDto> all, HttpServletResponse response) throws IOException {
List<Map<String, Object>> list = new ArrayList<>();
for (PushAnalysisInfoDto pushAnalysisInfo : all) {
Map<String,Object> map = new LinkedHashMap<>();
map.put("消息推送数", pushAnalysisInfo.getPushMsgNum());
map.put("日期", pushAnalysisInfo.getTimeInterval());
map.put("成功数", pushAnalysisInfo.getSucNum());
map.put("失败数", pushAnalysisInfo.getFailNum());
map.put("成功率", pushAnalysisInfo.getSucRatio());
map.put("日环比", pushAnalysisInfo.getDailyRingRatio());
list.add(map);
}
FileUtil.downloadExcel(list, response);
}*/
}
package admin.modules.analysis.service.mapper;
import admin.annotation.CurDataSource;
import admin.base.CommonMapper;
import admin.modules.analysis.domain.ApiAnalysisInfo;
import admin.modules.analysis.service.dto.ApiAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Repository
public interface ApiAnalysisInfoMapper extends CommonMapper<ApiAnalysisInfo> {
@CurDataSource(value = "slaver")
List<ApiAnalysisInfoDto> findByPage(@Param("startDate") String startTime,
@Param("endDate") String endTime,
@Param("page") Integer page,
@Param("size") Integer size);
@CurDataSource(value = "slaver")
Integer findCount();
}
package admin.modules.analysis.service.mapper;
import admin.annotation.CurDataSource;
import admin.base.CommonMapper;
import admin.modules.analysis.domain.CarAnalysisInfo;
import admin.modules.analysis.service.dto.CarAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Repository
public interface CarAnalysisInfoMapper extends CommonMapper<CarAnalysisInfo> {
@CurDataSource(value = "slaver")
List<CarAnalysisInfoDto> findByPage(@Param("startDate") String startTime,
@Param("endDate") String endTime,
@Param("page") Integer page,
@Param("size") Integer size);
@CurDataSource(value = "slaver")
Integer findCount();
}
package admin.modules.analysis.service.mapper;
import admin.annotation.CurDataSource;
import admin.base.CommonMapper;
import admin.modules.analysis.domain.DataAnalysisInfo;
import admin.modules.analysis.service.dto.DataAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Repository
public interface DataAnalysisInfoMapper extends CommonMapper<DataAnalysisInfo> {
List<DataAnalysisInfo> selectOne();
@CurDataSource(value = "slaver")
List<DataAnalysisInfoDto> findByPage(@Param("startDate") String startTime,
@Param("endDate") String endTime,
@Param("page") Integer page,
@Param("size") Integer size);
@CurDataSource(value = "slaver")
Integer findCount();
}
package admin.modules.analysis.service.mapper;
import admin.annotation.CurDataSource;
import admin.base.CommonMapper;
import admin.modules.analysis.domain.DeviceAnalysisInfo;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Repository
public interface DeviceAnalysisInfoMapper extends CommonMapper<DeviceAnalysisInfo> {
@CurDataSource(value = "slaver")
List<DeviceAnalysisInfoDto> findByPage(@Param("startDate") String startTime,
@Param("endDate") String endTime,
@Param("page") Integer page,
@Param("size") Integer size);
@CurDataSource(value = "slaver")
Integer findCount();
}
package admin.modules.analysis.service.mapper;
import admin.annotation.CurDataSource;
import admin.base.CommonMapper;
import admin.modules.analysis.domain.MsgAnalysisInfo;
import admin.modules.analysis.service.dto.MsgAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Repository
public interface MsgAnalysisInfoMapper extends CommonMapper<MsgAnalysisInfo> {
@CurDataSource(value = "slaver")
List<MsgAnalysisInfoDto> findByPage(@Param("startDate") String startTime,
@Param("endDate") String endTime,
@Param("page") Integer page,
@Param("size") Integer size);
@CurDataSource(value = "slaver")
Integer findCount();
}
package admin.modules.analysis.service.mapper;
import admin.annotation.CurDataSource;
import admin.base.CommonMapper;
import admin.modules.analysis.domain.OrderAnalysisInfo;
import admin.modules.analysis.service.dto.OrderAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Repository
public interface OrderAnalysisInfoMapper extends CommonMapper<OrderAnalysisInfo> {
@CurDataSource(value = "slaver")
List<OrderAnalysisInfoDto> findByPage(@Param("startDate") String startTime,
@Param("endDate") String endTime,
@Param("page") Integer page,
@Param("size") Integer size);
@CurDataSource(value = "slaver")
Integer findCount();
}
package admin.modules.analysis.service.mapper;
import admin.annotation.CurDataSource;
import admin.base.CommonMapper;
import admin.modules.analysis.domain.PayAnalysisInfo;
import admin.modules.analysis.service.dto.PayAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Repository
public interface PayAnalysisInfoMapper extends CommonMapper<PayAnalysisInfo> {
@CurDataSource(value = "slaver")
List<PayAnalysisInfoDto> findByPage(@Param("startDate") String startTime,
@Param("endDate") String endTime,
@Param("page") Integer page,
@Param("size") Integer size);
@CurDataSource(value = "slaver")
Integer findCount();
}
package admin.modules.analysis.service.mapper;
import admin.annotation.CurDataSource;
import admin.base.CommonMapper;
import admin.modules.analysis.domain.PlateIdentifyAnalysisInfo;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Repository
public interface PlateIdentifyAnalysisInfoMapper extends CommonMapper<PlateIdentifyAnalysisInfo> {
@CurDataSource(value = "slaver")
List<PlateIdentifyAnalysisInfoDto> findByPage(@Param("startDate") String startTime,
@Param("endDate") String endTime,
@Param("page") Integer page,
@Param("size") Integer size);
@CurDataSource(value = "slaver")
Integer findCount();
}
package admin.modules.analysis.service.mapper;
import admin.annotation.CurDataSource;
import admin.base.CommonMapper;
import admin.modules.analysis.domain.PushAnalysisInfo;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import admin.modules.analysis.service.dto.PushAnalysisInfoDto;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author lj
* @date 2024-12-16
*/
@Repository
public interface PushAnalysisInfoMapper extends CommonMapper<PushAnalysisInfo> {
@CurDataSource(value = "slaver")
List<PushAnalysisInfoDto> findByPage(@Param("startDate") String startTime,
@Param("endDate") String endTime,
@Param("page") Integer page,
@Param("size") Integer size);
@CurDataSource(value = "slaver")
Integer findCount();
}
package admin.rest.analysis;
import admin.annotation.Log;
import admin.annotation.rest.AnonymousGetMapping;
import admin.modules.analysis.service.ApiAnalysisInfoService;
import admin.modules.analysis.service.dto.ApiAnalysisInfoDto;
import admin.modules.analysis.service.dto.ApiAnalysisInfoQueryCriteria;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
**/
@RestController
@RequiredArgsConstructor
@Api(tags = "ApiAnalysisService管理")
@RequestMapping("/api/apiAnalysisInfo")
public class ApiAnalysisInfoController {
private final ApiAnalysisInfoService apiAnalysisInfoService;
@AnonymousGetMapping
@Log("查询ApiAnalysisService")
@ApiOperation("查询ApiAnalysisService")
@PreAuthorize("@el.check('apiAnalysisInfo:list')")
public ResponseEntity query(ApiAnalysisInfoQueryCriteria query, Pageable pageable){
return new ResponseEntity<>(apiAnalysisInfoService.queryAll(query,pageable),HttpStatus.OK);
}
@GetMapping ("queryPage")
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity queryPage(String startDate,String endDate, Pageable pageable){
return new ResponseEntity<>(apiAnalysisInfoService.queryPage(startDate,endDate,pageable.getPageNumber(),pageable.getPageSize()),HttpStatus.OK);
}
@PostMapping
@Log("新增ApiAnalysisService")
@ApiOperation("新增ApiAnalysisService")
@PreAuthorize("@el.check('apiAnalysisInfo:add')")
public ResponseEntity create(@Validated @RequestBody ApiAnalysisInfoDto resources){
return new ResponseEntity<>(apiAnalysisInfoService.insert(resources),HttpStatus.CREATED);
}
@PutMapping
@Log("修改ApiAnalysisService")
@ApiOperation("修改ApiAnalysisService")
@PreAuthorize("@el.check('apiAnalysisInfo:edit')")
public ResponseEntity update(@Validated @RequestBody ApiAnalysisInfoDto resources){
apiAnalysisInfoService.updateById(resources);
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
}
@DeleteMapping
@Log("删除ApiAnalysisService")
@ApiOperation("删除ApiAnalysisService")
@PreAuthorize("@el.check('apiAnalysisInfo:del')")
public ResponseEntity delete(@RequestBody Set<Long> ids) {
apiAnalysisInfoService.removeByIds(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
/*
@Log("导出ApiAnalysisService")
@ApiOperation("导出ApiAnalysisService")
@GetMapping(value = "/download")
@PreAuthorize("@el.check('apiAnalysisInfo:list')")
public void download(HttpServletResponse response, ApiAnalysisInfoQueryCriteria query) throws IOException {
apiAnalysisInfoService.download(apiAnalysisInfoService.queryAll(query), response);
}*/
}
package admin.rest.analysis;
import admin.annotation.Log;
import admin.modules.analysis.service.CarAnalysisInfoService;
import admin.modules.analysis.service.dto.CarAnalysisInfoDto;
import admin.modules.analysis.service.dto.CarAnalysisInfoQueryCriteria;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
**/
@RestController
@RequiredArgsConstructor
@Api(tags = "CarAnalysisService管理")
@RequestMapping("/api/carAnalysisInfo")
public class CarAnalysisInfoController {
private final CarAnalysisInfoService carAnalysisInfoService;
@GetMapping
@Log("查询CarAnalysisService")
@ApiOperation("查询CarAnalysisService")
@PreAuthorize("@el.check('carAnalysisInfo:list')")
public ResponseEntity query(CarAnalysisInfoQueryCriteria query, Pageable pageable){
return new ResponseEntity<>(carAnalysisInfoService.queryAll(query,pageable),HttpStatus.OK);
}
@GetMapping ("queryPage")
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity queryPage(String startDate,String endDate, Pageable pageable){
return new ResponseEntity<>(carAnalysisInfoService.queryPage(startDate,endDate,pageable.getPageNumber(),pageable.getPageSize()),HttpStatus.OK);
}
@PostMapping
@Log("新增CarAnalysisService")
@ApiOperation("新增CarAnalysisService")
@PreAuthorize("@el.check('carAnalysisInfo:add')")
public ResponseEntity create(@Validated @RequestBody CarAnalysisInfoDto resources){
return new ResponseEntity<>(carAnalysisInfoService.insert(resources),HttpStatus.CREATED);
}
@PutMapping
@Log("修改CarAnalysisService")
@ApiOperation("修改CarAnalysisService")
@PreAuthorize("@el.check('carAnalysisInfo:edit')")
public ResponseEntity update(@Validated @RequestBody CarAnalysisInfoDto resources){
carAnalysisInfoService.updateById(resources);
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
}
@DeleteMapping
@Log("删除CarAnalysisService")
@ApiOperation("删除CarAnalysisService")
@PreAuthorize("@el.check('carAnalysisInfo:del')")
public ResponseEntity delete(@RequestBody Set<Long> ids) {
carAnalysisInfoService.removeByIds(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
/*
@Log("导出CarAnalysisService
")
@ApiOperation("导出CarAnalysisService
")
@GetMapping(value = "/download")
@PreAuthorize("@el.check('carAnalysisInfo:list')")
public void download(HttpServletResponse response, CarAnalysisInfoQueryCriteria query) throws IOException {
carAnalysisInfoService.download(carAnalysisInfoService.queryAll(query), response);
}*/
}
package admin.rest.analysis;
import admin.annotation.Log;
import admin.modules.analysis.service.DataAnalysisInfoService;
import admin.modules.analysis.service.dto.DataAnalysisInfoDto;
import admin.modules.analysis.service.dto.DataAnalysisInfoQueryCriteria;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
**/
@RestController
@RequiredArgsConstructor
@Api(tags = "DataAnalysisService管理")
@RequestMapping("/api/dataAnalysisInfo")
public class DataAnalysisInfoController {
private final DataAnalysisInfoService dataAnalysisInfoService;
@GetMapping
@Log("查询DataAnalysisService")
@ApiOperation("查询DataAnalysisService")
@PreAuthorize("@el.check('dataAnalysisInfo:list')")
public ResponseEntity query(DataAnalysisInfoQueryCriteria query, Pageable pageable){
return new ResponseEntity<>(dataAnalysisInfoService.queryAll(query,pageable),HttpStatus.OK);
}
@GetMapping ("queryPage")
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity queryPage(String startDate,String endDate, Pageable pageable){
return new ResponseEntity<>(dataAnalysisInfoService.queryPage(startDate,endDate,pageable.getPageNumber(),pageable.getPageSize()),HttpStatus.OK);
}
@PostMapping
@Log("新增DataAnalysisService")
@ApiOperation("新增DataAnalysisService")
@PreAuthorize("@el.check('dataAnalysisInfo:add')")
public ResponseEntity create(@Validated @RequestBody DataAnalysisInfoDto resources){
return new ResponseEntity<>(dataAnalysisInfoService.insert(resources),HttpStatus.CREATED);
}
@PutMapping
@Log("修改DataAnalysisService")
@ApiOperation("修改DataAnalysisService")
@PreAuthorize("@el.check('dataAnalysisInfo:edit')")
public ResponseEntity update(@Validated @RequestBody DataAnalysisInfoDto resources){
dataAnalysisInfoService.updateById(resources);
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
}
@DeleteMapping
@Log("删除DataAnalysisService")
@ApiOperation("删除DataAnalysisService")
@PreAuthorize("@el.check('dataAnalysisInfo:del')")
public ResponseEntity delete(@RequestBody Set<Long> ids) {
dataAnalysisInfoService.removeByIds(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
/*
@Log("导出DataAnalysisService")
@ApiOperation("导出DataAnalysisService")
@GetMapping(value = "/download")
@PreAuthorize("@el.check('dataAnalysisInfo:list')")
public void download(HttpServletResponse response, DataAnalysisInfoQueryCriteria query) throws IOException {
dataAnalysisInfoService.download(dataAnalysisInfoService.queryAll(query), response);
}*/
}
package admin.rest.analysis;
import admin.annotation.Log;
import admin.annotation.rest.AnonymousGetMapping;
import admin.modules.analysis.service.DeviceAnalysisInfoService;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoDto;
import admin.modules.analysis.service.dto.DeviceAnalysisInfoQueryCriteria;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
**/
@RestController
@RequiredArgsConstructor
@Api(tags = "DeviceAnalysisService管理")
@RequestMapping("/api/deviceAnalysisInfo")
public class DeviceAnalysisInfoController {
private final DeviceAnalysisInfoService deviceAnalysisInfoService;
@AnonymousGetMapping
@Log("查询DeviceAnalysisService")
@ApiOperation("查询DeviceAnalysisService")
@PreAuthorize("@el.check('deviceAnalysisInfo:list')")
public ResponseEntity query(DeviceAnalysisInfoQueryCriteria query, Pageable pageable){
return new ResponseEntity<>(deviceAnalysisInfoService.queryAll(query,pageable),HttpStatus.OK);
}
@GetMapping ("queryPage")
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity queryPage(String startDate,String endDate, Pageable pageable){
return new ResponseEntity<>(deviceAnalysisInfoService.queryPage(startDate,endDate,pageable.getPageNumber(),pageable.getPageSize()),HttpStatus.OK);
}
@PostMapping
@Log("新增DeviceAnalysisService")
@ApiOperation("新增DeviceAnalysisService")
@PreAuthorize("@el.check('deviceAnalysisInfo:add')")
public ResponseEntity create(@Validated @RequestBody DeviceAnalysisInfoDto resources){
return new ResponseEntity<>(deviceAnalysisInfoService.insert(resources),HttpStatus.CREATED);
}
@PutMapping
@Log("修改DeviceAnalysisService")
@ApiOperation("修改DeviceAnalysisService")
@PreAuthorize("@el.check('deviceAnalysisInfo:edit')")
public ResponseEntity update(@Validated @RequestBody DeviceAnalysisInfoDto resources){
deviceAnalysisInfoService.updateById(resources);
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
}
@DeleteMapping
@Log("删除DeviceAnalysisService")
@ApiOperation("删除DeviceAnalysisService")
@PreAuthorize("@el.check('deviceAnalysisInfo:del')")
public ResponseEntity delete(@RequestBody Set<Long> ids) {
deviceAnalysisInfoService.removeByIds(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
/*
@Log("导出DeviceAnalysisService
")
@ApiOperation("导出DeviceAnalysisService
")
@GetMapping(value = "/download")
@PreAuthorize("@el.check('deviceAnalysisInfo:list')")
public void download(HttpServletResponse response, DeviceAnalysisInfoQueryCriteria query) throws IOException {
deviceAnalysisInfoService.download(deviceAnalysisInfoService.queryAll(query), response);
}*/
}
package admin.rest.analysis;
import admin.annotation.Log;
import admin.modules.analysis.service.MsgAnalysisInfoService;
import admin.modules.analysis.service.dto.MsgAnalysisInfoDto;
import admin.modules.analysis.service.dto.MsgAnalysisInfoQueryCriteria;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
**/
@RestController
@RequiredArgsConstructor
@Api(tags = "MsgAnalysisService管理")
@RequestMapping("/api/msgAnalysisInfo")
public class MsgAnalysisInfoController {
private final MsgAnalysisInfoService msgAnalysisInfoService;
@GetMapping
@Log("查询MsgAnalysisService")
@ApiOperation("查询MsgAnalysisService")
@PreAuthorize("@el.check('msgAnalysisInfo:list')")
public ResponseEntity query(MsgAnalysisInfoQueryCriteria query, Pageable pageable){
return new ResponseEntity<>(msgAnalysisInfoService.queryAll(query,pageable),HttpStatus.OK);
}
@GetMapping ("queryPage")
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity queryPage(String startDate,String endDate, Pageable pageable){
return new ResponseEntity<>(msgAnalysisInfoService.queryPage(startDate,endDate,pageable.getPageNumber(),pageable.getPageSize()),HttpStatus.OK);
}
@PostMapping
@Log("新增MsgAnalysisService")
@ApiOperation("新增MsgAnalysisService")
@PreAuthorize("@el.check('msgAnalysisInfo:add')")
public ResponseEntity create(@Validated @RequestBody MsgAnalysisInfoDto resources){
return new ResponseEntity<>(msgAnalysisInfoService.insert(resources),HttpStatus.CREATED);
}
@PutMapping
@Log("修改MsgAnalysisService")
@ApiOperation("修改MsgAnalysisService")
@PreAuthorize("@el.check('msgAnalysisInfo:edit')")
public ResponseEntity update(@Validated @RequestBody MsgAnalysisInfoDto resources){
msgAnalysisInfoService.updateById(resources);
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
}
@DeleteMapping
@Log("删除MsgAnalysisService")
@ApiOperation("删除MsgAnalysisService")
@PreAuthorize("@el.check('msgAnalysisInfo:del')")
public ResponseEntity delete(@RequestBody Set<Long> ids) {
msgAnalysisInfoService.removeByIds(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
/*
@Log("导出MsgAnalysisService
")
@ApiOperation("导出MsgAnalysisService
")
@GetMapping(value = "/download")
@PreAuthorize("@el.check('msgAnalysisInfo:list')")
public void download(HttpServletResponse response, MsgAnalysisInfoQueryCriteria query) throws IOException {
msgAnalysisInfoService.download(msgAnalysisInfoService.queryAll(query), response);
}*/
}
package admin.rest.analysis;
import admin.annotation.Log;
import admin.modules.analysis.service.OrderAnalysisInfoService;
import admin.modules.analysis.service.dto.OrderAnalysisInfoDto;
import admin.modules.analysis.service.dto.OrderAnalysisInfoQueryCriteria;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
**/
@RestController
@RequiredArgsConstructor
@Api(tags = "OrderAnalysisService管理")
@RequestMapping("/api/orderAnalysisInfo")
public class OrderAnalysisInfoController {
private final OrderAnalysisInfoService orderAnalysisInfoService;
@GetMapping
@Log("查询OrderAnalysisService")
@ApiOperation("查询OrderAnalysisService")
@PreAuthorize("@el.check('orderAnalysisInfo:list')")
public ResponseEntity query(OrderAnalysisInfoQueryCriteria query, Pageable pageable){
return new ResponseEntity<>(orderAnalysisInfoService.queryAll(query,pageable),HttpStatus.OK);
}
@PostMapping
@Log("新增OrderAnalysisService")
@ApiOperation("新增OrderAnalysisService")
@PreAuthorize("@el.check('orderAnalysisInfo:add')")
public ResponseEntity create(@Validated @RequestBody OrderAnalysisInfoDto resources){
return new ResponseEntity<>(orderAnalysisInfoService.insert(resources),HttpStatus.CREATED);
}
@GetMapping ("queryPage")
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity queryPage(String startDate,String endDate, Pageable pageable){
return new ResponseEntity<>(orderAnalysisInfoService.queryPage(startDate,endDate,pageable.getPageNumber(),pageable.getPageSize()),HttpStatus.OK);
}
@PutMapping
@Log("修改OrderAnalysisService")
@ApiOperation("修改OrderAnalysisService")
@PreAuthorize("@el.check('orderAnalysisInfo:edit')")
public ResponseEntity update(@Validated @RequestBody OrderAnalysisInfoDto resources){
orderAnalysisInfoService.updateById(resources);
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
}
@DeleteMapping
@Log("删除OrderAnalysisService")
@ApiOperation("删除OrderAnalysisService")
@PreAuthorize("@el.check('orderAnalysisInfo:del')")
public ResponseEntity delete(@RequestBody Set<Long> ids) {
orderAnalysisInfoService.removeByIds(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
/*
@Log("导出OrderAnalysisService
")
@ApiOperation("导出OrderAnalysisService
")
@GetMapping(value = "/download")
@PreAuthorize("@el.check('orderAnalysisInfo:list')")
public void download(HttpServletResponse response, OrderAnalysisInfoQueryCriteria query) throws IOException {
orderAnalysisInfoService.download(orderAnalysisInfoService.queryAll(query), response);
}*/
}
package admin.rest.analysis;
import admin.annotation.Log;
import admin.modules.analysis.service.PayAnalysisInfoService;
import admin.modules.analysis.service.dto.PayAnalysisInfoDto;
import admin.modules.analysis.service.dto.PayAnalysisInfoQueryCriteria;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
**/
@RestController
@RequiredArgsConstructor
@Api(tags = "PayAnalysisService管理")
@RequestMapping("/api/payAnalysisInfo")
public class PayAnalysisInfoController {
private final PayAnalysisInfoService payAnalysisInfoService;
@GetMapping
@Log("查询PayAnalysisService")
@ApiOperation("查询PayAnalysisService")
@PreAuthorize("@el.check('payAnalysisInfo:list')")
public ResponseEntity query(PayAnalysisInfoQueryCriteria query, Pageable pageable){
return new ResponseEntity<>(payAnalysisInfoService.queryAll(query,pageable),HttpStatus.OK);
}
@GetMapping ("queryPage")
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity queryPage(String startDate,String endDate, Pageable pageable){
return new ResponseEntity<>(payAnalysisInfoService.queryPage(startDate,endDate,pageable.getPageNumber(),pageable.getPageSize()),HttpStatus.OK);
}
@PostMapping
@Log("新增PayAnalysisService")
@ApiOperation("新增PayAnalysisService")
@PreAuthorize("@el.check('payAnalysisInfo:add')")
public ResponseEntity create(@Validated @RequestBody PayAnalysisInfoDto resources){
return new ResponseEntity<>(payAnalysisInfoService.insert(resources),HttpStatus.CREATED);
}
@PutMapping
@Log("修改PayAnalysisService")
@ApiOperation("修改PayAnalysisService")
@PreAuthorize("@el.check('payAnalysisInfo:edit')")
public ResponseEntity update(@Validated @RequestBody PayAnalysisInfoDto resources){
payAnalysisInfoService.updateById(resources);
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
}
@DeleteMapping
@Log("删除PayAnalysisService")
@ApiOperation("删除PayAnalysisService")
@PreAuthorize("@el.check('payAnalysisInfo:del')")
public ResponseEntity delete(@RequestBody Set<Long> ids) {
payAnalysisInfoService.removeByIds(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
/*
@Log("导出PayAnalysisService
")
@ApiOperation("导出PayAnalysisService
")
@GetMapping(value = "/download")
@PreAuthorize("@el.check('payAnalysisInfo:list')")
public void download(HttpServletResponse response, PayAnalysisInfoQueryCriteria query) throws IOException {
payAnalysisInfoService.download(payAnalysisInfoService.queryAll(query), response);
}*/
}
package admin.rest.analysis;
import admin.annotation.Log;
import admin.annotation.rest.AnonymousGetMapping;
import admin.modules.analysis.service.PlateIdentifyAnalysisInfoService;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto;
import admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoQueryCriteria;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
**/
@RestController
@RequiredArgsConstructor
@Api(tags = "PlateIdentifyAnalysisService管理")
@RequestMapping("/api/plateIdentifyAnalysisInfo")
public class PlateIdentifyAnalysisInfoController {
private final PlateIdentifyAnalysisInfoService plateIdentifyAnalysisInfoService;
@GetMapping
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity query(PlateIdentifyAnalysisInfoQueryCriteria query, Pageable pageable){
return new ResponseEntity<>(plateIdentifyAnalysisInfoService.queryAll(query,pageable),HttpStatus.OK);
}
@GetMapping ("queryPage")
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity queryPage(String startDate,String endDate, Pageable pageable){
return new ResponseEntity<>(plateIdentifyAnalysisInfoService.queryPage(startDate,endDate,pageable.getPageNumber(),pageable.getPageSize()),HttpStatus.OK);
}
@PostMapping
@Log("新增PlateIdentifyAnalysisService")
@ApiOperation("新增PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:add')")
public ResponseEntity create(@Validated @RequestBody PlateIdentifyAnalysisInfoDto resources){
return new ResponseEntity<>(plateIdentifyAnalysisInfoService.insert(resources),HttpStatus.CREATED);
}
@PutMapping
@Log("修改PlateIdentifyAnalysisService")
@ApiOperation("修改PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:edit')")
public ResponseEntity update(@Validated @RequestBody PlateIdentifyAnalysisInfoDto resources){
plateIdentifyAnalysisInfoService.updateById(resources);
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
}
@DeleteMapping
@Log("删除PlateIdentifyAnalysisService")
@ApiOperation("删除PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:del')")
public ResponseEntity delete(@RequestBody Set<Long> ids) {
plateIdentifyAnalysisInfoService.removeByIds(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
/*
@Log("导出PlateIdentifyAnalysisService
")
@ApiOperation("导出PlateIdentifyAnalysisService
")
@GetMapping(value = "/download")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public void download(HttpServletResponse response, PlateIdentifyAnalysisInfoQueryCriteria query) throws IOException {
plateIdentifyAnalysisInfoService.download(plateIdentifyAnalysisInfoService.queryAll(query), response);
}*/
}
package admin.rest.analysis;
import admin.annotation.Log;
import admin.modules.analysis.service.PushAnalysisInfoService;
import admin.modules.analysis.service.dto.PushAnalysisInfoDto;
import admin.modules.analysis.service.dto.PushAnalysisInfoQueryCriteria;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Set;
/**
* @author lj
* @date 2024-12-16
**/
@RestController
@RequiredArgsConstructor
@Api(tags = "PushAnalysisService管理")
@RequestMapping("/api/pushAnalysisInfo")
public class PushAnalysisInfoController {
private final PushAnalysisInfoService pushAnalysisInfoService;
@GetMapping
@Log("查询PushAnalysisService")
@ApiOperation("查询PushAnalysisService")
@PreAuthorize("@el.check('pushAnalysisInfo:list')")
public ResponseEntity query(PushAnalysisInfoQueryCriteria query, Pageable pageable){
return new ResponseEntity<>(pushAnalysisInfoService.queryAll(query,pageable),HttpStatus.OK);
}
@GetMapping ("queryPage")
@Log("查询PlateIdentifyAnalysisService")
@ApiOperation("查询PlateIdentifyAnalysisService")
@PreAuthorize("@el.check('plateIdentifyAnalysisInfo:list')")
public ResponseEntity queryPage(String startDate,String endDate, Pageable pageable){
return new ResponseEntity<>(pushAnalysisInfoService.queryPage(startDate,endDate,pageable.getPageNumber(),pageable.getPageSize()),HttpStatus.OK);
}
@PostMapping
@Log("新增PushAnalysisService")
@ApiOperation("新增PushAnalysisService")
@PreAuthorize("@el.check('pushAnalysisInfo:add')")
public ResponseEntity create(@Validated @RequestBody PushAnalysisInfoDto resources){
return new ResponseEntity<>(pushAnalysisInfoService.insert(resources),HttpStatus.CREATED);
}
@PutMapping
@Log("修改PushAnalysisService")
@ApiOperation("修改PushAnalysisService")
@PreAuthorize("@el.check('pushAnalysisInfo:edit')")
public ResponseEntity update(@Validated @RequestBody PushAnalysisInfoDto resources){
pushAnalysisInfoService.updateById(resources);
return new ResponseEntity<>(HttpStatus.NO_CONTENT);
}
@DeleteMapping
@Log("删除PushAnalysisService")
@ApiOperation("删除PushAnalysisService")
@PreAuthorize("@el.check('pushAnalysisInfo:del')")
public ResponseEntity delete(@RequestBody Set<Long> ids) {
pushAnalysisInfoService.removeByIds(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
/*
@Log("导出PushAnalysisService
")
@ApiOperation("导出PushAnalysisService
")
@GetMapping(value = "/download")
@PreAuthorize("@el.check('pushAnalysisInfo:list')")
public void download(HttpServletResponse response, PushAnalysisInfoQueryCriteria query) throws IOException {
pushAnalysisInfoService.download(pushAnalysisInfoService.queryAll(query), response);
}*/
}
......@@ -46,7 +46,7 @@ spring:
# 连接在池中最大生存的时间
max-evictable-idle-time-millis: 900000
test-while-idle: true
test-on-borrow: false
test-on-borrow: true
test-on-return: false
# 检测连接是否有效
validation-query: select 1
......@@ -62,7 +62,7 @@ spring:
enabled: true
# 记录慢SQL
log-slow-sql: true
slow-sql-millis: 2000
slow-sql-millis: 1000
merge-sql: true
wall:
config:
......
......@@ -2,12 +2,12 @@
spring:
redis:
#数据库索引
database: 12
host: 10.175.207.202
port: 32723
password: $JmFi$bD73R2GvJbt
database: 13
host: r-wz97b4dt5z54p1x73i.redis.rds.aliyuncs.com
port: 6379
password: Hzzy891212
#连接超时时间
timeout: 8000
timeout: 5000
# cluster:
# expire-seconds: 120
......
<?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="admin.modules.analysis.service.mapper.ApiAnalysisInfoMapper">
<!-- 通用查询结果列 -->
<!--
<sql id="Base_Column_List">
a.id, a.time_interval, a.total_count, a.suc_count, a.fail_count, a.avg_time
</sql>
-->
<select id="findByPage" resultType="admin.modules.analysis.service.dto.ApiAnalysisInfoDto">
select *
from api_analysis_info where `time_interval` between #{startDate} and #{endDate} limit #{page},#{size};
</select>
<select id="findCount" resultType="java.lang.Integer">
select count(*)
from api_analysis_info;
</select>
</mapper>
<?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="admin.modules.analysis.service.mapper.CarAnalysisInfoMapper">
<!-- 通用查询结果列 -->
<!--
<sql id="Base_Column_List">
a.id, a.car_predict_num, a.car_num, a.one_interval, a.time_interval, a.two_interval, a.three_interval, a.four_interval, a.five_interval, a.six_interval, a.seven_interval, a.eight_interval, a.nine_interval, a.ten_interval, a.eleven_interval, a.twelve_interval
</sql>
-->
<select id="findByPage" resultType="admin.modules.analysis.service.dto.CarAnalysisInfoDto">
select *
from car_analysis_info where `time_interval` between #{startDate} and #{endDate} limit #{page},#{size};
</select>
<select id="findCount" resultType="java.lang.Integer">
select count(*)
from car_analysis_info;
</select>
</mapper>
<?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="admin.modules.analysis.service.mapper.DataAnalysisInfoMapper">
<!-- 通用查询结果列 -->
<!--
<sql id="Base_Column_List">
a.id, a.daily_storage_capacity, a.img_storage_capacity, a.total_space, a.remaining_space, a.utilization_ratio, a.daily_ring_ratio, a.time_interval
</sql>
-->
<select id="selectOne" resultType="admin.modules.analysis.domain.DataAnalysisInfo">
select * from data_analysis_info order by time_interval desc limit 2
</select>
<select id="findByPage" resultType="admin.modules.analysis.service.dto.DataAnalysisInfoDto">
select *
from data_analysis_info where `time_interval` between #{startDate} and #{endDate} limit #{page},#{size};
</select>
<select id="findCount" resultType="java.lang.Integer">
select count(*)
from data_analysis_info;
</select>
</mapper>
<?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="admin.modules.analysis.service.mapper.DeviceAnalysisInfoMapper">
<!-- 通用查询结果列 -->
<!--
<sql id="Base_Column_List">
a.id, a.create_time, a.device_type, a.parking_no, a.road_id, a.parking_id
</sql>
-->
<select id="findByPage" resultType="admin.modules.analysis.service.dto.DeviceAnalysisInfoDto">
select *
from device_analysis_info where
`date` between #{startDate} and #{endDate}
limit #{page},#{size};
</select>
<select id="findCount" resultType="java.lang.Integer">
select count(*)
from device_analysis_info;
</select>
</mapper>
<?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="admin.modules.analysis.service.mapper.MsgAnalysisInfoMapper">
<!-- 通用查询结果列 -->
<!--
<sql id="Base_Column_List">
a.id, a.push_msg_num, a.suc_num, a.fail_num, a.suc_ratio, a.daily_ring_ratio, a.time_interval
</sql>
-->
<select id="findByPage" resultType="admin.modules.analysis.service.dto.MsgAnalysisInfoDto">
select *
from msg_analysis_info where `time_interval` between #{startDate} and #{endDate} limit #{page},#{size};
</select>
<select id="findCount" resultType="java.lang.Integer">
select count(*)
from msg_analysis_info;
</select>
</mapper>
<?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="admin.modules.analysis.service.mapper.OrderAnalysisInfoMapper">
<!-- 通用查询结果列 -->
<!--
<sql id="Base_Column_List">
a.id, a.time_interval, a.cloud_identify_num, a.cloud_identify_repair_num, a.order_repair_num, a.submit_manual_processing_num, a.processing_rate, a.daily_ring_ratio
</sql>
-->
<select id="findByPage" resultType="admin.modules.analysis.service.dto.OrderAnalysisInfoDto">
select *
from order_analysis_info where `time_interval` between #{startDate} and #{endDate} limit #{page},#{size};
</select>
<select id="findCount" resultType="java.lang.Integer">
select count(*)
from order_analysis_info;
</select>
</mapper>
<?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="admin.modules.analysis.service.mapper.PayAnalysisInfoMapper">
<!-- 通用查询结果列 -->
<!--
<sql id="Base_Column_List">
a.id, a.pay_msg_num, a.one_interval, a.time_interval, a.two_interval, a.three_interval, a.four_interval, a.five_interval, a.six_interval, a.seven_interval, a.eight_interval, a.nine_interval, a.ten_interval, a.eleven_interval, a.twelve_interval
</sql>
-->
<select id="findByPage" resultType="admin.modules.analysis.service.dto.PayAnalysisInfoDto">
select *
from pay_analysis_info where `time_interval` between #{startDate} and #{endDate} limit #{page},#{size};
</select>
<select id="findCount" resultType="java.lang.Integer">
select count(*)
from pay_analysis_info;
</select>
</mapper>
<?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="admin.modules.analysis.service.mapper.PlateIdentifyAnalysisInfoMapper">
<!-- 通用查询结果列 -->
<!--
<sql id="Base_Column_List">
a.id, a.time_interval, a.plate_identify_num, a.suc_identify_num, a.fail_identify_num, a.suc_ratio, a.daily_ring_ratio
</sql>
-->
<select id="findByPage" resultType="admin.modules.analysis.service.dto.PlateIdentifyAnalysisInfoDto">
select *
from plate_identify_analysis_info where `time_interval` between #{startDate} and #{endDate} limit #{page},#{size};
</select>
<select id="findCount" resultType="java.lang.Integer">
select count(*)
from plate_identify_analysis_info;
</select>
</mapper>
<?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="admin.modules.analysis.service.mapper.PushAnalysisInfoMapper">
<!-- 通用查询结果列 -->
<!--
<sql id="Base_Column_List">
a.id, a.push_msg_num, a.time_interval, a.suc_num, a.fail_num, a.suc_ratio, a.daily_ring_ratio
</sql>
-->
<select id="findByPage" resultType="admin.modules.analysis.service.dto.PushAnalysisInfoDto">
select *
from push_analysis_info where `time_interval` between #{startDate} and #{endDate} limit #{page},#{size};
</select>
<select id="findCount" resultType="java.lang.Integer">
select count(*)
from push_analysis_info;
</select>
</mapper>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment