package com.gear.admin.Biz.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.gear.admin.Biz.SwxStatisticsBiz;
|
import com.gear.common.constant.SwxConstons;
|
import com.gear.swx.domain.*;
|
import com.gear.swx.service.*;
|
import com.gear.swx.service.impl.SwxUserServiceImpl;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
import java.util.Queue;
|
|
@Component
|
public class SwxStatisticsBizImpl implements SwxStatisticsBiz {
|
|
@Autowired
|
private ISwxRechargeRecordService swxRechargeRecordService;
|
|
@Autowired
|
private ISwxWithdrawalRecordService swxWithdrawalRecordService;
|
|
@Autowired
|
private ISwxLoanRecordService swxLoanRecordService;
|
|
@Autowired
|
private ISwxOptionsOrderService swxOptionsOrderService;
|
|
@Autowired
|
private ISwxSmartOrderService swxSmartOrderService;
|
|
@Autowired
|
private ISwxNftService swxNftService;
|
|
@Autowired
|
private ISwxIdentificationService swxIdentificationService;
|
|
@Autowired
|
private ISwxUserService swxUserService;
|
@Override
|
public Map<String, Object> getTop() {
|
|
Map<String,Object> result = new HashMap<>();
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
String dateNow = simpleDateFormat.format(new Date());
|
|
//获取今天开始时间
|
String startTime = dateNow + " 00:00:00";
|
//获取今天结束时间
|
String endTime = dateNow + " 23:59:59";
|
|
//今日充值
|
QueryWrapper<SwxRechargeRecord> swxRechargeRecordQueryWrapper = new QueryWrapper<>();
|
swxRechargeRecordQueryWrapper.lambda().ge(SwxRechargeRecord::getCreateTime,startTime);
|
swxRechargeRecordQueryWrapper.lambda().le(SwxRechargeRecord::getCreateTime,endTime);
|
swxRechargeRecordQueryWrapper.lambda().eq(SwxRechargeRecord::getStatus, SwxConstons.SWX_EXAMINE_STATUS_REVIEW);
|
Long rechargeCount = swxRechargeRecordService.count(swxRechargeRecordQueryWrapper);
|
result.put("rechargeCount",rechargeCount);
|
|
//今日提现
|
QueryWrapper<SwxWithdrawalRecord> swxWithdrawalRecordQueryWrapper = new QueryWrapper<>();
|
swxWithdrawalRecordQueryWrapper.lambda().ge(SwxWithdrawalRecord::getCreateTime,startTime);
|
swxWithdrawalRecordQueryWrapper.lambda().le(SwxWithdrawalRecord::getCreateTime,endTime);
|
swxWithdrawalRecordQueryWrapper.lambda().eq(SwxWithdrawalRecord::getStatus, SwxConstons.SWX_EXAMINE_STATUS_REVIEW);
|
Long withdrawalCount = swxWithdrawalRecordService.count(swxWithdrawalRecordQueryWrapper);
|
result.put("withdrawalCount",withdrawalCount);
|
|
//今日贷款
|
QueryWrapper<SwxLoanRecord> swxLoanRecordQueryWrapper = new QueryWrapper<>();
|
swxLoanRecordQueryWrapper.lambda().ge(SwxLoanRecord::getCreateTime,startTime);
|
swxLoanRecordQueryWrapper.lambda().le(SwxLoanRecord::getCreateTime,endTime);
|
swxLoanRecordQueryWrapper.lambda().eq(SwxLoanRecord::getStatus, SwxConstons.SWX_EXAMINE_STATUS_REVIEW);
|
Long loanCount = swxLoanRecordService.count(swxLoanRecordQueryWrapper);
|
result.put("loanCount",loanCount);
|
|
|
//今日期权
|
QueryWrapper<SwxOptionsOrder> swxOptionsOrderQueryWrapper = new QueryWrapper<>();
|
swxOptionsOrderQueryWrapper.lambda().ge(SwxOptionsOrder::getCreateTime,startTime);
|
swxOptionsOrderQueryWrapper.lambda().le(SwxOptionsOrder::getCreateTime,endTime);
|
Long optionsCount = swxOptionsOrderService.count(swxOptionsOrderQueryWrapper);
|
result.put("optionsCount",optionsCount);
|
|
//今日实名
|
QueryWrapper<SwxIdentification> swxIdentificationQueryWrapper = new QueryWrapper<>();
|
swxIdentificationQueryWrapper.lambda().ge(SwxIdentification::getCreateTime,startTime);
|
swxIdentificationQueryWrapper.lambda().le(SwxIdentification::getCreateTime,endTime);
|
Long identification = swxIdentificationService.count(swxIdentificationQueryWrapper);
|
result.put("identificationCount",identification);
|
|
return result;
|
}
|
|
@Override
|
public Map<String, Object> getIndexTop() {
|
Map<String,Object> result = new HashMap<>();
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
String dateNow = simpleDateFormat.format(new Date());
|
|
//获取今天开始时间
|
String startTime = dateNow + " 00:00:00";
|
//获取今天结束时间
|
String endTime = dateNow + " 23:59:59";
|
//查询累计充值
|
QueryWrapper<SwxRechargeRecord> swxRechargeRecordQueryWrapper = Wrappers.query();
|
swxRechargeRecordQueryWrapper.select("SUM(amount) AS total");
|
swxRechargeRecordQueryWrapper.lambda().eq(SwxRechargeRecord::getStatus,1);
|
Map<String,Object> allRechargeMap = swxRechargeRecordService.getMap(swxRechargeRecordQueryWrapper);
|
result.put("allRecharge",allRechargeMap == null ? 0:allRechargeMap.get("total"));
|
|
//查询累计提现
|
QueryWrapper<SwxWithdrawalRecord> swxWithdrawalRecordQueryWrapper = new QueryWrapper<>();
|
swxWithdrawalRecordQueryWrapper.select("SUM(amount) AS total");
|
swxWithdrawalRecordQueryWrapper.lambda().eq(SwxWithdrawalRecord::getStatus,1);
|
Map<String,Object> allWithdrawalMap = swxWithdrawalRecordService.getMap(swxWithdrawalRecordQueryWrapper);
|
result.put("allWithdrawal",allWithdrawalMap == null ? 0:allWithdrawalMap.get("total"));
|
|
//查询今日充值
|
swxRechargeRecordQueryWrapper.lambda().ge(SwxRechargeRecord::getCreateTime,startTime);
|
swxRechargeRecordQueryWrapper.lambda().le(SwxRechargeRecord::getCreateTime,endTime);
|
Map<String,Object> todayRechargeMap = swxRechargeRecordService.getMap(swxRechargeRecordQueryWrapper);
|
result.put("todayRecharge",todayRechargeMap == null ? 0:todayRechargeMap.get("total"));
|
|
//查询今日提现
|
swxWithdrawalRecordQueryWrapper.lambda().ge(SwxWithdrawalRecord::getCreateTime,startTime);
|
swxWithdrawalRecordQueryWrapper.lambda().le(SwxWithdrawalRecord::getCreateTime,endTime);
|
Map<String,Object> todayWithdarwalMap = swxWithdrawalRecordService.getMap(swxWithdrawalRecordQueryWrapper);
|
result.put("todayWithdarwal",todayWithdarwalMap == null ? 0:todayWithdarwalMap.get("total"));
|
|
//查询贷款总额
|
QueryWrapper<SwxLoanRecord> swxLoanRecordQueryWrapper = new QueryWrapper<>();
|
swxLoanRecordQueryWrapper.select("SUM(amount) AS total");
|
swxLoanRecordQueryWrapper.lambda().ge(SwxLoanRecord::getStatus,1);
|
Map<String,Object> allLoanMap = swxLoanRecordService.getMap(swxLoanRecordQueryWrapper);
|
result.put("allLoan",allLoanMap == null ? 0 : allLoanMap.get("total"));
|
|
|
//获取总期权交易
|
QueryWrapper<SwxOptionsOrder> swxOptionsOrderQueryWrapper = new QueryWrapper<>();
|
swxOptionsOrderQueryWrapper.select("SUM(amount) as total");
|
swxOptionsOrderQueryWrapper.lambda().eq(SwxOptionsOrder::getStatus,1);
|
Map<String,Object> allOptions = swxOptionsOrderService.getMap(swxOptionsOrderQueryWrapper);
|
result.put("allOptions",allOptions == null ? 0 : allOptions.get("total"));
|
|
|
//获取总用户数
|
result.put("allUser",swxUserService.count());
|
|
//获取总合约数
|
result.put("allContracts",0);
|
return result;
|
}
|
|
|
}
|
