From 7a1d1ae5f7bb4fce96fb7a134d755765cd3c4e4a Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 26 十月 2023 10:51:50 +0800
Subject: [PATCH] 添加统计日志
---
server/src/main/java/doumeemes/service/business/impl/BizLingyangServiceImpl.java | 18 ++++++++++++------
1 files changed, 12 insertions(+), 6 deletions(-)
diff --git a/server/src/main/java/doumeemes/service/business/impl/BizLingyangServiceImpl.java b/server/src/main/java/doumeemes/service/business/impl/BizLingyangServiceImpl.java
index 230f60a..d4ae173 100644
--- a/server/src/main/java/doumeemes/service/business/impl/BizLingyangServiceImpl.java
+++ b/server/src/main/java/doumeemes/service/business/impl/BizLingyangServiceImpl.java
@@ -5,6 +5,7 @@
import doumeemes.core.model.PageData;
import doumeemes.core.model.PageWrap;
import doumeemes.core.utils.Constants;
+import doumeemes.core.utils.DateUtil;
import doumeemes.core.utils.Utils;
import doumeemes.dao.business.BizLingyangMapper;
import doumeemes.dao.business.model.BizLingyang;
@@ -85,27 +86,32 @@
}
@Override
@Transactional
- public void syncLingData() {
- Date date = new Date();
+ public void syncLingData(Date date) {
+// Date date = new Date();
QueryWrapper<SystemLoginLog> param = new QueryWrapper<>();
MPJLambdaWrapper<SystemLoginLog> mpjLambdaWrapper = new MPJLambdaWrapper<>();
mpjLambdaWrapper.selectAll(SystemLoginLog.class);
mpjLambdaWrapper.leftJoin(Company.class,Company::getId,SystemLoginLog::getCompanyId);
mpjLambdaWrapper.leftJoin(CompanyUser.class,CompanyUser::getId,SystemLoginLog::getCompanyUserId);
- mpjLambdaWrapper.select("(select count(b.id) from system_trace_log b where b.company_id=t1.id and b.company_user_id=t2.id) as logNum");
+ mpjLambdaWrapper.select("(select count(b.id) from system_trace_log b where to_days(b.OPERA_TIME) =to_days('"+ DateUtil.getPlusTime2(date) +"') and b.company_id=t1.id and b.company_user_id=t2.id) as logNum");
mpjLambdaWrapper.selectAs( CompanyUser::getLingyangUserid,SystemLoginLog::getLingyangUserid);
mpjLambdaWrapper.selectAs(Company::getCreditCode, SystemLoginLog::getCompanyCode);
mpjLambdaWrapper.eq(SystemLoginLog::getSuccess, Constants.ONE);
mpjLambdaWrapper.eq(SystemLoginLog::getOrgin, Constants.USER_LOGIN_ORIGIN.lingyang);
- mpjLambdaWrapper.apply("to_days(login_time) =to_days(now())" );
+ mpjLambdaWrapper.apply("to_days(login_time) =to_days('"+ DateUtil.getPlusTime2(date) +"')" );
mpjLambdaWrapper.select("count(t.id) as num");
mpjLambdaWrapper.groupBy(SystemLoginLog::getUserId);
List<SystemLoginLog> list = systemLoginLogJoinMapper.selectJoinList(SystemLoginLog.class,mpjLambdaWrapper);
+
if(list!=null && list.size()>0){
+ //鍒犻櫎鑰佺殑
+ bizLingyangMapper.delete(new QueryWrapper<BizLingyang>()
+ .lambda().apply("to_days(create_time) =to_days('"+ DateUtil.getPlusTime2(date) +"')" )
+ );
for(SystemLoginLog log : list){
BizLingyang model = new BizLingyang();
model.setCompanyId(log.getCompanyId());
- model.setCreateTime(new Date());
+ model.setCreateTime(date);
model.setUserPhone(log.getLoginUsername());
model.setCreditCode(log.getCompanyCode());
try {
@@ -114,7 +120,7 @@
}
model.setAppKey(systemDictDataBiz.queryByCode(Constants.LINGYANG_PARAM,Constants.LINGYANG_APPKEY ).getCode());
- model.setActionTimes(log.getLogNum());
+ model.setActionTimes(log.getNum() + log.getLogNum());
model.setLoginTimes(log.getNum());
bizLingyangMapper.insert(model);
}
--
Gitblit v1.9.3