package project.monitor.report;
|
|
import java.io.Serializable;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
import kernel.util.Arith;
|
import kernel.util.DateUtils;
|
import kernel.web.ApplicationUtil;
|
import project.Constants;
|
import security.Role;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
public class DAppUserDataSumServiceImpl implements DAppUserDataSumService {
|
|
protected SecUserService secUserService;
|
|
private Map<String, DAppUserDataSum> cache = new ConcurrentHashMap<String, DAppUserDataSum>();
|
|
public void init() {
|
List<DAppUserDataSum> all = getAll();
|
for (int i=0;i<all.size();setCache(all.get(i++)));
|
}
|
|
public List<DAppUserDataSum> getAll() {
|
return ApplicationUtil.executeSelect(DAppUserDataSum.class);
|
}
|
|
public void setCache(DAppUserDataSum entity) {
|
cache.put(DateUtils.format(entity.getCreateTime(), DateUtils.DEFAULT_DATE_FORMAT), entity);
|
}
|
|
@Override
|
public DAppData cacheGetData(Date date) {
|
DAppData data = new DAppData();
|
DAppUserDataSum today = cache.get(DateUtils.format(date, DateUtils.DEFAULT_DATE_FORMAT));
|
if (today == null) today = new DAppUserDataSum();
|
data.setNewuser(today.getNewuser());
|
data.setApprove_user(today.getApprove_user());
|
data.setTransferfrom(today.getTransferfrom());
|
|
for (DAppUserDataSum item : cache.values()) {
|
// 总用户数
|
data.setUser(data.getUser() + item.getNewuser());
|
// 授权用户数
|
data.setUsdt_user_count(data.getUsdt_user_count() + item.getApprove_user());
|
// 授权转账总金额
|
data.setTransferfromsum(Arith.add(data.getTransferfromsum(), item.getTransferfrom()));
|
// 授权总金额(USDT)
|
data.setUsdt_user(Arith.add(data.getUsdt_user(), item.getUsdt_user()));
|
}
|
|
return data;
|
}
|
|
@Override
|
public void save(DAppUserDataSum entity) {
|
DAppUserDataSum db = findBydate(entity.getCreateTime());
|
if (null != db) {
|
db.setNewuser(db.getNewuser() + entity.getNewuser());
|
db.setApprove_user(db.getApprove_user() + entity.getApprove_user());
|
db.setUsdt_user(Arith.add(db.getUsdt_user(), entity.getUsdt_user()));
|
db.setTransferfrom(Arith.add(db.getTransferfrom(), entity.getTransferfrom()));
|
|
ApplicationUtil.executeUpdate(db);
|
setCache(db);
|
} else {
|
ApplicationUtil.executeInsert(entity);
|
setCache(entity);
|
}
|
}
|
|
private DAppUserDataSum findBydate(Date date) {
|
Date createTime_begin = null;
|
Date createTime_end = null;
|
if (date != null) {
|
createTime_begin = DateUtils.toDate(DateUtils.format(date, "yyyy-MM-dd"));
|
createTime_end = DateUtils.addDate(createTime_begin, 1);
|
}
|
|
List<DAppUserDataSum> list=ApplicationUtil.executeSelect(DAppUserDataSum.class,"WHERE CREATE_TIME>=? AND CREATE_TIME<?",new Object[] {createTime_begin,createTime_end});
|
return list.size()<=0?null:list.get(0);
|
}
|
|
public void saveRegister(Serializable partyId) {
|
SecUser user = this.secUserService.findUserByPartyId(partyId);
|
boolean guest = false;
|
for (Role role : user.getRoles()) {
|
if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
|
guest = true;
|
break;
|
}
|
}
|
|
if (guest) return;
|
|
DAppUserDataSum entity = new DAppUserDataSum();
|
entity.setNewuser(1);
|
entity.setCreateTime(new Date());
|
|
save(entity);
|
}
|
|
/**
|
* 授权通过
|
* @param partyId
|
*/
|
public void saveApprove(Serializable partyId) {
|
SecUser user = this.secUserService.findUserByPartyId(partyId);
|
boolean guest = false;
|
for (Role role : user.getRoles()) {
|
if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
|
guest = true;
|
break;
|
}
|
}
|
|
if (guest) return;
|
|
DAppUserDataSum entity = new DAppUserDataSum();
|
entity.setApprove_user(1);
|
entity.setCreateTime(new Date());
|
|
save(entity);
|
}
|
|
/**
|
* 授权通过变成不通过
|
*
|
* @param partyId
|
*/
|
public void saveApproveSuccessToFail(Serializable partyId) {
|
SecUser user = this.secUserService.findUserByPartyId(partyId);
|
boolean guest = false;
|
for (Role role : user.getRoles()) {
|
if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
|
guest = true;
|
break;
|
}
|
}
|
|
if (guest) return;
|
|
DAppUserDataSum entity = new DAppUserDataSum();
|
entity.setApprove_user(-1);
|
entity.setCreateTime(new Date());
|
|
save(entity);
|
}
|
|
/**
|
* 授权金额
|
*
|
* @param partyId
|
* @param amount
|
*/
|
public void saveUsdtUser(Serializable partyId, double amount) {
|
SecUser user = this.secUserService.findUserByPartyId(partyId);
|
boolean guest = false;
|
for (Role role : user.getRoles()) {
|
if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
|
guest = true;
|
break;
|
}
|
}
|
|
if (guest) return;
|
|
DAppUserDataSum entity = new DAppUserDataSum();
|
entity.setUsdt_user(amount);
|
entity.setCreateTime(new Date());
|
|
save(entity);
|
}
|
|
/**
|
* 授权转账金额
|
*
|
* @param partyId
|
* @param amount
|
*/
|
public void saveTransferfrom(Serializable partyId, double amount) {
|
SecUser user = this.secUserService.findUserByPartyId(partyId);
|
boolean guest = false;
|
for (Role role : user.getRoles()) {
|
if (Constants.SECURITY_ROLE_GUEST.equals(role.getRoleName())) {
|
guest = true;
|
break;
|
}
|
}
|
|
if (guest) return;
|
|
DAppUserDataSum entity = new DAppUserDataSum();
|
entity.setTransferfrom(amount);
|
entity.setCreateTime(new Date());
|
|
save(entity);
|
}
|
|
/**
|
* 清算金额
|
*
|
* @param amount
|
*/
|
public void saveSettle(double amount) {
|
DAppUserDataSum entity = new DAppUserDataSum();
|
entity.setSettle_amount(amount);
|
entity.setCreateTime(new Date());
|
save(entity);
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
}
|
