|
|
@@ -1498,7 +1498,7 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
|
|
|
* @param userId 用户ID(企业用户,对应user_type=2)
|
|
|
* @return 包含各指标今日数据及较昨日变化的Map
|
|
|
*/
|
|
|
- public HashMap<String, Object> userYesterdayData(Long userId,Integer dateType) {
|
|
|
+ public HashMap<String, Object> userYesterdayData(Long userId,Integer dateType,Integer postPushId) {
|
|
|
HashMap<String, Object> resultMap = new HashMap<>();
|
|
|
LocalDateTime todayStart;
|
|
|
LocalDateTime todayEnd;
|
|
|
@@ -1549,37 +1549,37 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
|
|
|
List<Long> myPostIds = postIdObjs.stream()
|
|
|
.map(obj -> Long.valueOf(obj.toString()))
|
|
|
.collect(Collectors.toList());
|
|
|
- int todaySawMe = userBrowseService.count(new QueryWrapper<UserBrowse>().in("post_push_id",myPostIds).between("update_time",todayStart,todayEnd));
|
|
|
- int yesterdaySawMe = userBrowseService.count(new QueryWrapper<UserBrowse>().in("post_push_id",myPostIds).between("update_time",yesterdayStart,yesterdayEnd));
|
|
|
+ int todaySawMe = userBrowseService.count(new QueryWrapper<UserBrowse>().in("post_push_id",myPostIds).between("update_time",todayStart,todayEnd).eq("post_push_id",postPushId));
|
|
|
+ int yesterdaySawMe = userBrowseService.count(new QueryWrapper<UserBrowse>().in("post_push_id",myPostIds).between("update_time",yesterdayStart,yesterdayEnd).eq("post_push_id",postPushId));
|
|
|
resultMap.put("sawMe",todaySawMe);
|
|
|
resultMap.put("tySawMe",todaySawMe-yesterdaySawMe);
|
|
|
|
|
|
// 4.3 我沟通(企业主动发起的沟通数量)
|
|
|
- int todayICommunicated =chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("type",2).between("create_time",todayStart,todayEnd));
|
|
|
- int yesterdayICommunicated = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("type",2).between("create_time",yesterdayStart,yesterdayEnd));
|
|
|
+ int todayICommunicated =chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("type",2).between("create_time",todayStart,todayEnd).eq("post_push_id",postPushId));
|
|
|
+ int yesterdayICommunicated = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("type",2).between("create_time",yesterdayStart,yesterdayEnd).eq("post_push_id",postPushId));
|
|
|
resultMap.put("iCommunicated",todayICommunicated);
|
|
|
resultMap.put("tyICommunicated",todayICommunicated-yesterdayICommunicated);
|
|
|
// 4.4 求职者沟通(求职者主动发起的沟通数量)
|
|
|
- int todayCandidateCommunicated =chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("type",1).between("create_time",todayStart,todayEnd));
|
|
|
- int yesterdayCandidateCommunicated = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("type",1).between("create_time",yesterdayStart,yesterdayEnd));
|
|
|
+ int todayCandidateCommunicated =chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("type",1).between("create_time",todayStart,todayEnd).eq("post_push_id",postPushId));
|
|
|
+ int yesterdayCandidateCommunicated = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("type",1).between("create_time",yesterdayStart,yesterdayEnd).eq("post_push_id",postPushId));
|
|
|
resultMap.put("candidateCommunicated", todayCandidateCommunicated);
|
|
|
resultMap.put("tyCandidateCommunicated",todayCandidateCommunicated-yesterdayCandidateCommunicated);
|
|
|
|
|
|
// 4.5 收获简历(企业收到的简历数量,对应is_send_resumes=1)
|
|
|
- int todayReceivedResumes = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("is_send_resumes",1).between("update_time",todayStart,todayEnd));
|
|
|
- int yesterdayReceivedResumes =chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("is_send_resumes",1).between("update_time",yesterdayStart,yesterdayEnd));
|
|
|
+ int todayReceivedResumes = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("is_send_resumes",1).between("update_time",todayStart,todayEnd).eq("post_push_id",postPushId));
|
|
|
+ int yesterdayReceivedResumes =chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).eq("is_send_resumes",1).between("update_time",yesterdayStart,yesterdayEnd).eq("post_push_id",postPushId));
|
|
|
resultMap.put("receivedResumes", todayReceivedResumes);
|
|
|
resultMap.put("tyReceivedResumes",todayReceivedResumes-yesterdayReceivedResumes);
|
|
|
|
|
|
// 4.6 交换电话微信(电话/微信交换成功数量,对应is_send_phone=1或is_send_wx=1)
|
|
|
- int todayExchangedContact = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).and(qw -> qw.eq("is_send_phone", 1).or().eq("is_send_wx", 1)) .between("update_time",todayStart,todayEnd));
|
|
|
- int yesterdayExchangedContact = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).and(qw -> qw.eq("is_send_phone", 1).or().eq("is_send_wx", 1)) .between("update_time",todayStart,todayEnd));
|
|
|
+ int todayExchangedContact = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).and(qw -> qw.eq("is_send_phone", 1).or().eq("is_send_wx", 1)) .between("update_time",todayStart,todayEnd).eq("post_push_id",postPushId));
|
|
|
+ int yesterdayExchangedContact = chatConversationService.count(new QueryWrapper<ChatConversation>().eq("focused_user_id",userId).and(qw -> qw.eq("is_send_phone", 1).or().eq("is_send_wx", 1)) .between("update_time",todayStart,todayEnd).eq("post_push_id",postPushId));
|
|
|
resultMap.put("exchangedContact", todayExchangedContact);
|
|
|
resultMap.put("tyExchangeContact",todayExchangedContact-yesterdayExchangedContact);
|
|
|
|
|
|
// 4.7 接受面试(求职者接受面试的数量,需结合status字段定义)
|
|
|
- int todayAcceptedInterview = interviewRecordService.count(new QueryWrapper<InterviewRecord>().eq("user_id",userId).eq("status",2).between("create_time",todayStart,todayEnd));
|
|
|
- int yesterdayAcceptedInterview = interviewRecordService.count(new QueryWrapper<InterviewRecord>().eq("user_id",userId).eq("status",2).between("create_time",yesterdayStart,yesterdayEnd));
|
|
|
+ int todayAcceptedInterview = interviewRecordService.count(new QueryWrapper<InterviewRecord>().eq("user_id",userId).eq("status",2).between("create_time",todayStart,todayEnd).eq("post_push_id",postPushId));
|
|
|
+ int yesterdayAcceptedInterview = interviewRecordService.count(new QueryWrapper<InterviewRecord>().eq("user_id",userId).eq("status",2).between("create_time",yesterdayStart,yesterdayEnd).eq("post_push_id",postPushId));
|
|
|
resultMap.put("acceptedInterview", todayAcceptedInterview);
|
|
|
resultMap.put("tyAcceptedInterview",todayAcceptedInterview-yesterdayAcceptedInterview);
|
|
|
|