|
@@ -1,5 +1,6 @@
|
|
|
package com.sqx.modules.app.service.impl;
|
|
package com.sqx.modules.app.service.impl;
|
|
|
|
|
|
|
|
|
|
+import cn.hutool.core.lang.Assert;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONException;
|
|
import com.alibaba.fastjson.JSONException;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
@@ -44,16 +45,24 @@ import com.sqx.modules.app.service.UserMoneyDetailsService;
|
|
|
import com.sqx.modules.app.service.UserService;
|
|
import com.sqx.modules.app.service.UserService;
|
|
|
import com.sqx.modules.app.utils.JwtUtils;
|
|
import com.sqx.modules.app.utils.JwtUtils;
|
|
|
import com.sqx.modules.app.utils.UserConstantInterface;
|
|
import com.sqx.modules.app.utils.UserConstantInterface;
|
|
|
|
|
+import com.sqx.modules.chat.entity.ChatContent;
|
|
|
|
|
+import com.sqx.modules.chat.entity.ChatConversation;
|
|
|
|
|
+import com.sqx.modules.chat.service.ChatContentService;
|
|
|
|
|
+import com.sqx.modules.chat.service.ChatConversationService;
|
|
|
import com.sqx.modules.common.entity.CommonInfo;
|
|
import com.sqx.modules.common.entity.CommonInfo;
|
|
|
import com.sqx.modules.common.service.CommonInfoService;
|
|
import com.sqx.modules.common.service.CommonInfoService;
|
|
|
import com.sqx.modules.file.utils.Md5Utils;
|
|
import com.sqx.modules.file.utils.Md5Utils;
|
|
|
|
|
+import com.sqx.modules.interviewRecord.entity.InterviewRecord;
|
|
|
|
|
+import com.sqx.modules.interviewRecord.service.InterviewRecordService;
|
|
|
import com.sqx.modules.invite.service.InviteService;
|
|
import com.sqx.modules.invite.service.InviteService;
|
|
|
import com.sqx.modules.message.entity.MessageInfo;
|
|
import com.sqx.modules.message.entity.MessageInfo;
|
|
|
import com.sqx.modules.message.service.MessageService;
|
|
import com.sqx.modules.message.service.MessageService;
|
|
|
import com.sqx.modules.myCollection.entity.MyCollection;
|
|
import com.sqx.modules.myCollection.entity.MyCollection;
|
|
|
import com.sqx.modules.myCollection.service.MyCollectionService;
|
|
import com.sqx.modules.myCollection.service.MyCollectionService;
|
|
|
import com.sqx.modules.resumes.entity.Company;
|
|
import com.sqx.modules.resumes.entity.Company;
|
|
|
|
|
+import com.sqx.modules.resumes.entity.PostPush;
|
|
|
import com.sqx.modules.resumes.service.CompanyService;
|
|
import com.sqx.modules.resumes.service.CompanyService;
|
|
|
|
|
+import com.sqx.modules.resumes.service.PostPushService;
|
|
|
import com.sqx.modules.sendRecord.entity.SendRecord;
|
|
import com.sqx.modules.sendRecord.entity.SendRecord;
|
|
|
import com.sqx.modules.sendRecord.service.SendRecordService;
|
|
import com.sqx.modules.sendRecord.service.SendRecordService;
|
|
|
import com.sqx.modules.utils.HttpClientUtil;
|
|
import com.sqx.modules.utils.HttpClientUtil;
|
|
@@ -63,6 +72,8 @@ import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.codec.digest.DigestUtils;
|
|
import org.apache.commons.codec.digest.DigestUtils;
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
import org.apache.http.client.utils.DateUtils;
|
|
import org.apache.http.client.utils.DateUtils;
|
|
|
|
|
+import org.apache.ibatis.jdbc.Null;
|
|
|
|
|
+import org.joda.time.DateTime;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.web.bind.annotation.RequestBody;
|
|
import org.springframework.web.bind.annotation.RequestBody;
|
|
@@ -72,9 +83,14 @@ import weixin.popular.util.JsonUtil;
|
|
|
import java.io.IOException;
|
|
import java.io.IOException;
|
|
|
import java.math.BigDecimal;
|
|
import java.math.BigDecimal;
|
|
|
import java.text.SimpleDateFormat;
|
|
import java.text.SimpleDateFormat;
|
|
|
|
|
+import java.time.DayOfWeek;
|
|
|
|
|
+import java.time.LocalDate;
|
|
|
import java.time.LocalDateTime;
|
|
import java.time.LocalDateTime;
|
|
|
|
|
+import java.time.LocalTime;
|
|
|
import java.time.format.DateTimeFormatter;
|
|
import java.time.format.DateTimeFormatter;
|
|
|
|
|
+import java.time.temporal.TemporalAdjusters;
|
|
|
import java.util.*;
|
|
import java.util.*;
|
|
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 用户
|
|
* 用户
|
|
@@ -116,6 +132,14 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
|
|
|
private UserMoneyDetailsDao detailsDao;
|
|
private UserMoneyDetailsDao detailsDao;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private MsgService msgService;
|
|
private MsgService msgService;
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private ChatConversationService chatConversationService;
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private ChatContentService chatContentService;
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private InterviewRecordService interviewRecordService;
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private PostPushService postPushService;
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public UserEntity queryByPhone(String phone) {
|
|
public UserEntity queryByPhone(String phone) {
|
|
@@ -877,14 +901,12 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
|
|
|
UserEntity userEntity = baseMapper.selectById(userId);
|
|
UserEntity userEntity = baseMapper.selectById(userId);
|
|
|
if (userEntity != null) {
|
|
if (userEntity != null) {
|
|
|
if (userEntity.getUserType() == 2) {
|
|
if (userEntity.getUserType() == 2) {
|
|
|
- Company company = companyService.getOne(new QueryWrapper<Company>().eq("user_id", userEntity.getUserId()));
|
|
|
|
|
|
|
+ Company company = companyService.getOne(new QueryWrapper<Company>().eq("user_id", userEntity.getUserId()).eq("status",2));
|
|
|
if (company != null) {
|
|
if (company != null) {
|
|
|
userEntity.setCompanyId(company.getCompanyId());
|
|
userEntity.setCompanyId(company.getCompanyId());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
return userEntity;
|
|
return userEntity;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -1141,22 +1163,38 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
|
|
|
HashMap<String, Object> map = new HashMap<>();
|
|
HashMap<String, Object> map = new HashMap<>();
|
|
|
UserEntity userEntity = baseMapper.selectById(userId);
|
|
UserEntity userEntity = baseMapper.selectById(userId);
|
|
|
QueryWrapper<UserBrowse> wrapper = new QueryWrapper<UserBrowse>().eq("user_id", userId);
|
|
QueryWrapper<UserBrowse> wrapper = new QueryWrapper<UserBrowse>().eq("user_id", userId);
|
|
|
- //个人
|
|
|
|
|
|
|
+ QueryWrapper<MyCollection> queryWrapper =new QueryWrapper<MyCollection>().eq("user_id",userId);
|
|
|
|
|
+ QueryWrapper<SendRecord> queryWrapper1 =new QueryWrapper<>();
|
|
|
|
|
+ QueryWrapper<InterviewRecord>queryWrapper2 =new QueryWrapper<>();
|
|
|
|
|
+ QueryWrapper<ChatConversation> queryWrapper3 =new QueryWrapper<>();
|
|
|
|
|
+
|
|
|
if (userEntity.getUserType() == 1) {
|
|
if (userEntity.getUserType() == 1) {
|
|
|
wrapper.eq("browse_type", 1);
|
|
wrapper.eq("browse_type", 1);
|
|
|
|
|
+ queryWrapper.eq("type",1);
|
|
|
|
|
+ queryWrapper1.eq("user_id",userId);
|
|
|
|
|
+ queryWrapper2.eq("interviewer_id",userId);
|
|
|
|
|
+ queryWrapper3.eq("use_id",userId);
|
|
|
//企业
|
|
//企业
|
|
|
} else {
|
|
} else {
|
|
|
wrapper.eq("browse_type", 2);
|
|
wrapper.eq("browse_type", 2);
|
|
|
|
|
+ queryWrapper.eq("type",2);
|
|
|
|
|
+ queryWrapper1.eq("company_user_id",userId);
|
|
|
|
|
+ queryWrapper2.eq("user_id",userId);
|
|
|
|
|
+ queryWrapper3.eq("focused_user_id",userId);
|
|
|
}
|
|
}
|
|
|
int browseCount = userBrowseService.count(wrapper);
|
|
int browseCount = userBrowseService.count(wrapper);
|
|
|
- int collectionCount = collectionService.count(new QueryWrapper<MyCollection>().eq("user_id", userId));
|
|
|
|
|
- int deliveryCount = sendRecordService.count(new QueryWrapper<SendRecord>().eq("user_id", userId));
|
|
|
|
|
|
|
+ int collectionCount = collectionService.count(queryWrapper);
|
|
|
|
|
+ int deliveryCount = sendRecordService.count(queryWrapper1);
|
|
|
|
|
+ int chatCount = chatConversationService.count();
|
|
|
|
|
+ int interviewCount = interviewRecordService.count(queryWrapper2);
|
|
|
//浏览记录
|
|
//浏览记录
|
|
|
map.put("browseCount", browseCount);
|
|
map.put("browseCount", browseCount);
|
|
|
//收藏记录
|
|
//收藏记录
|
|
|
map.put("collectionCount", collectionCount);
|
|
map.put("collectionCount", collectionCount);
|
|
|
//投递记录
|
|
//投递记录
|
|
|
map.put("deliveryCount", deliveryCount);
|
|
map.put("deliveryCount", deliveryCount);
|
|
|
|
|
+ map.put("chatCount",chatCount);
|
|
|
|
|
+ map.put("interviewCount",interviewCount);
|
|
|
return map;
|
|
return map;
|
|
|
|
|
|
|
|
}
|
|
}
|
|
@@ -1455,4 +1493,201 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
|
|
|
return Result.success();
|
|
return Result.success();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-}
|
|
|
|
|
|
|
+ @Override
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 获取指定用户的今日招聘数据
|
|
|
|
|
+ * @param userId 用户ID(企业用户,对应user_type=2)
|
|
|
|
|
+ * @return 包含各指标今日数据及较昨日变化的Map
|
|
|
|
|
+ */
|
|
|
|
|
+ public HashMap<String, Object> userYesterdayData(Long userId,LocalDateTime todayStart, LocalDateTime todayEnd, Integer postPushId) {
|
|
|
|
|
+
|
|
|
|
|
+ HashMap<String, Object> resultMap = new HashMap<>();
|
|
|
|
|
+ boolean isCalculateDiff = false; // 是否计算「今日-昨日」差值(默认不计算)
|
|
|
|
|
+ LocalDateTime yesterdayStart = null;
|
|
|
|
|
+ LocalDateTime yesterdayEnd = null;
|
|
|
|
|
+
|
|
|
|
|
+ // -------------------------- 1. 时间参数处理(核心改造)--------------------------
|
|
|
|
|
+ if (todayStart == null && todayEnd == null) {
|
|
|
|
|
+ // 场景1:未传时间 → 用今日+昨日时间范围,计算差值
|
|
|
|
|
+ isCalculateDiff = true;
|
|
|
|
|
+ // 今日:00:00:00 ~ 23:59:59
|
|
|
|
|
+ todayStart = LocalDateTime.of(LocalDate.now(), LocalTime.MIN);
|
|
|
|
|
+ todayEnd = LocalDateTime.of(LocalDate.now(), LocalTime.MAX);
|
|
|
|
|
+ // 昨日:00:00:00 ~ 23:59:59
|
|
|
|
|
+ yesterdayStart = LocalDateTime.of(LocalDate.now().minusDays(1), LocalTime.MIN);
|
|
|
|
|
+ yesterdayEnd = LocalDateTime.of(LocalDate.now().minusDays(1), LocalTime.MAX);
|
|
|
|
|
+ } else {
|
|
|
|
|
+ // 场景2:传了时间 → 校验时间合理性,不计算差值
|
|
|
|
|
+ Assert.notNull(todayStart, "传入时间时,todayStart不能为空");
|
|
|
|
|
+ Assert.notNull(todayEnd, "传入时间时,todayEnd不能为空");
|
|
|
|
|
+ Assert.isTrue(!todayStart.isAfter(todayEnd), "todayStart不能晚于todayEnd");
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // -------------------------- 2. 公共查询条件准备 --------------------------
|
|
|
|
|
+ // 「看过我」所需的:当前用户发布的岗位ID列表
|
|
|
|
|
+ List<Long> myPostIds = new ArrayList<>();
|
|
|
|
|
+ List<Object> postIdObjs = postPushService.listObjs(
|
|
|
|
|
+ new QueryWrapper<PostPush>()
|
|
|
|
|
+ .eq("user_id", userId)
|
|
|
|
|
+ .select("post_push_id")
|
|
|
|
|
+ );
|
|
|
|
|
+ if (postIdObjs != null && !postIdObjs.isEmpty()) {
|
|
|
|
|
+ myPostIds = postIdObjs.stream()
|
|
|
|
|
+ .map(obj -> Long.valueOf(obj.toString()))
|
|
|
|
|
+ .collect(Collectors.toList());
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // -------------------------- 3. 指标查询(按需求差异化处理)--------------------------
|
|
|
|
|
+ // 3.1 我看过(企业查看求职者数量)
|
|
|
|
|
+ int currentISaw = userBrowseService.count(
|
|
|
|
|
+ new QueryWrapper<UserBrowse>()
|
|
|
|
|
+ .eq("user_id", userId)
|
|
|
|
|
+ .eq("browse_type", 2)
|
|
|
|
|
+ .between("update_time", todayStart, todayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("iSaw", currentISaw);
|
|
|
|
|
+ if (isCalculateDiff) {
|
|
|
|
|
+ int yesterdayISaw = userBrowseService.count(
|
|
|
|
|
+ new QueryWrapper<UserBrowse>()
|
|
|
|
|
+ .eq("user_id", userId)
|
|
|
|
|
+ .eq("browse_type", 2)
|
|
|
|
|
+ .between("update_time", yesterdayStart, yesterdayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("tyIsaw", currentISaw - yesterdayISaw);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 3.2 看过我(求职者查看企业岗位数量)
|
|
|
|
|
+ int currentSawMe = 0;
|
|
|
|
|
+ if (!myPostIds.isEmpty()) {
|
|
|
|
|
+ currentSawMe = userBrowseService.count(
|
|
|
|
|
+ new QueryWrapper<UserBrowse>()
|
|
|
|
|
+ .in("post_push_id", myPostIds)
|
|
|
|
|
+ .eq("post_push_id", postPushId) // 筛选指定岗位
|
|
|
|
|
+ .between("update_time", todayStart, todayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ }
|
|
|
|
|
+ resultMap.put("sawMe", currentSawMe);
|
|
|
|
|
+ if (isCalculateDiff) {
|
|
|
|
|
+ int yesterdaySawMe = 0;
|
|
|
|
|
+ if (!myPostIds.isEmpty()) {
|
|
|
|
|
+ yesterdaySawMe = userBrowseService.count(
|
|
|
|
|
+ new QueryWrapper<UserBrowse>()
|
|
|
|
|
+ .in("post_push_id", myPostIds)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("update_time", yesterdayStart, yesterdayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ }
|
|
|
|
|
+ resultMap.put("tySawMe", currentSawMe - yesterdaySawMe);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 3.3 我沟通(企业主动发起沟通数量)
|
|
|
|
|
+ int currentICommunicated = chatConversationService.count(
|
|
|
|
|
+ new QueryWrapper<ChatConversation>()
|
|
|
|
|
+ .eq("focused_user_id", userId)
|
|
|
|
|
+ .eq("type", 2)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("create_time", todayStart, todayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("iCommunicated", currentICommunicated);
|
|
|
|
|
+ if (isCalculateDiff) {
|
|
|
|
|
+ int yesterdayICommunicated = chatConversationService.count(
|
|
|
|
|
+ new QueryWrapper<ChatConversation>()
|
|
|
|
|
+ .eq("focused_user_id", userId)
|
|
|
|
|
+ .eq("type", 2)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("create_time", yesterdayStart, yesterdayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("tyICommunicated", currentICommunicated - yesterdayICommunicated);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 3.4 求职者沟通(求职者主动发起沟通数量)
|
|
|
|
|
+ int currentCandidateCommunicated = chatConversationService.count(
|
|
|
|
|
+ new QueryWrapper<ChatConversation>()
|
|
|
|
|
+ .eq("focused_user_id", userId)
|
|
|
|
|
+ .eq("type", 1)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("create_time", todayStart, todayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("candidateCommunicated", currentCandidateCommunicated);
|
|
|
|
|
+ if (isCalculateDiff) {
|
|
|
|
|
+ int yesterdayCandidateCommunicated = chatConversationService.count(
|
|
|
|
|
+ new QueryWrapper<ChatConversation>()
|
|
|
|
|
+ .eq("focused_user_id", userId)
|
|
|
|
|
+ .eq("type", 1)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("create_time", yesterdayStart, yesterdayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("tyCandidateCommunicated", currentCandidateCommunicated - yesterdayCandidateCommunicated);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 3.5 收获简历(企业收到简历数量)
|
|
|
|
|
+ int currentReceivedResumes = chatConversationService.count(
|
|
|
|
|
+ new QueryWrapper<ChatConversation>()
|
|
|
|
|
+ .eq("focused_user_id", userId)
|
|
|
|
|
+ .eq("is_send_resumes", 1)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("update_time", todayStart, todayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("receivedResumes", currentReceivedResumes);
|
|
|
|
|
+ if (isCalculateDiff) {
|
|
|
|
|
+ int yesterdayReceivedResumes = chatConversationService.count(
|
|
|
|
|
+ new QueryWrapper<ChatConversation>()
|
|
|
|
|
+ .eq("focused_user_id", userId)
|
|
|
|
|
+ .eq("is_send_resumes", 1)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("update_time", yesterdayStart, yesterdayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("tyReceivedResumes", currentReceivedResumes - yesterdayReceivedResumes);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 3.6 交换电话微信(修复原Bug:昨日查询用昨日时间范围)
|
|
|
|
|
+ int currentExchangedContact = chatConversationService.count(
|
|
|
|
|
+ new QueryWrapper<ChatConversation>()
|
|
|
|
|
+ .eq("focused_user_id", userId)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .and(qw -> qw.eq("is_send_phone", 1).or().eq("is_send_wx", 1))
|
|
|
|
|
+ .between("update_time", todayStart, todayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("exchangedContact", currentExchangedContact);
|
|
|
|
|
+ if (isCalculateDiff) {
|
|
|
|
|
+ int yesterdayExchangedContact = chatConversationService.count(
|
|
|
|
|
+ new QueryWrapper<ChatConversation>()
|
|
|
|
|
+ .eq("focused_user_id", userId)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .and(qw -> qw.eq("is_send_phone", 1).or().eq("is_send_wx", 1))
|
|
|
|
|
+ .between("update_time", yesterdayStart, yesterdayEnd) // 原代码误用todayStart,现已修正
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("tyExchangeContact", currentExchangedContact - yesterdayExchangedContact);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 3.7 接受面试(求职者接受面试数量)
|
|
|
|
|
+ int currentAcceptedInterview = interviewRecordService.count(
|
|
|
|
|
+ new QueryWrapper<InterviewRecord>()
|
|
|
|
|
+ .eq("user_id", userId)
|
|
|
|
|
+ .eq("status", 2)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("create_time", todayStart, todayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("acceptedInterview", currentAcceptedInterview);
|
|
|
|
|
+ if (isCalculateDiff) {
|
|
|
|
|
+ int yesterdayAcceptedInterview = interviewRecordService.count(
|
|
|
|
|
+ new QueryWrapper<InterviewRecord>()
|
|
|
|
|
+ .eq("user_id", userId)
|
|
|
|
|
+ .eq("status", 2)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("create_time", yesterdayStart, yesterdayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("tyAcceptedInterview", currentAcceptedInterview - yesterdayAcceptedInterview);
|
|
|
|
|
+ }
|
|
|
|
|
+ int currentSendInterview = interviewRecordService.count(
|
|
|
|
|
+ new QueryWrapper<InterviewRecord>()
|
|
|
|
|
+ .eq("user_id", userId)
|
|
|
|
|
+ .eq("post_push_id", postPushId)
|
|
|
|
|
+ .between("create_time", todayStart, todayEnd)
|
|
|
|
|
+ );
|
|
|
|
|
+ resultMap.put("sendInterview", currentSendInterview);
|
|
|
|
|
+ return resultMap;
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|