2.1需求

yujian

2020-05-09 7e7db2fa55a9a3af46d4fd8ede0dee147f101d64

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
package com.yeshi.fanli.service.impl.user.vip; 
 
import java.util.Date; 
import java.util.List; 
 
import javax.annotation.Resource; 
 
import org.springframework.stereotype.Service; 
 
import com.yeshi.fanli.dao.user.vip.TeamDailyRecordDao; 
import com.yeshi.fanli.entity.bus.user.ThreeSale; 
import com.yeshi.fanli.entity.bus.user.vip.TeamDailyRecord; 
import com.yeshi.fanli.log.LogHelper; 
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce; 
import com.yeshi.fanli.service.inter.user.vip.TeamDailyRecordService; 
import com.yeshi.fanli.util.StringUtil; 
import com.yeshi.fanli.util.TimeUtil; 
 
@Service 
public class TeamDailyRecordServiceImpl implements TeamDailyRecordService { 
 
    @Resource 
    private TeamDailyRecordDao TeamDailyRecordDao; 
 
    @Resource 
    private ThreeSaleSerivce threeSaleSerivce; 
 
 
    @Override 
    public void addDailyRecord(Long uid) { 
        // 重新统计队员等级数量 
        recountRecord(uid); 
 
        // 统计上级队员数量 
        ThreeSale threeSale = threeSaleSerivce.getByWorkerId(uid); 
        if (threeSale != null) { 
            recountRecord(threeSale.getBoss().getId()); 
        } 
    } 
 
    private void recountRecord(Long uid) { 
        try { 
            // 直接粉丝 
            int firstCount = (int) threeSaleSerivce.countFirstTeamByDate(uid, 1); 
            // 间接粉丝 
            int secondCount = (int) threeSaleSerivce.countSecondTeamByDate(uid, 1); 
 
            int secondBeyond = 0; 
             
            // 每天只记录一次统计 
            String time = TimeUtil.getGernalTime(java.lang.System.currentTimeMillis()); 
            String id = StringUtil.Md5(uid + "#" + time); 
            TeamDailyRecord record = TeamDailyRecordDao.getById(id); 
            if (record == null) { 
                record = new TeamDailyRecord(); 
            } else if (record.getSecondCount() != null) { 
                secondBeyond = record.getSecondCount(); 
            } 
 
            record.setId(id); 
            record.setUid(uid); 
            record.setFirstCount(firstCount); 
            record.setSecondCount(secondCount); 
            record.setSecondBeyond(secondBeyond); 
            record.setStatisticDay(TimeUtil.parse(time)); 
            record.setUpdateTime(new Date()); 
            TeamDailyRecordDao.save(record); 
        } catch (Exception e) { 
            e.getSuppressed(); 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
 
    @Override 
    public List<TeamDailyRecord> getbyUid(Long uid) { 
        return TeamDailyRecordDao.getbyUid(uid); 
    } 
     
    @Override 
    public List<TeamDailyRecord> getbyUid(Long uid, Date minTime) { 
        return TeamDailyRecordDao.getbyUid(uid, minTime); 
    } 
     
}