增加动态用户

admin

2019-05-16 4114e871bcb3dce771b6aed64a1027d0bbb95ca6

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
85
86
87
88
89
90
91
92
93
94
package com.yeshi.fanli.service.impl.activity; 
 
import java.util.Date; 
import java.util.List; 
 
import javax.annotation.Resource; 
 
import org.springframework.stereotype.Service; 
 
import com.yeshi.fanli.dao.mybatis.activity.ActivityRuleUserMapper; 
import com.yeshi.fanli.dao.mybatis.activity.ActivityUserMapper; 
import com.yeshi.fanli.entity.bus.activity.ActivityRuleUser; 
import com.yeshi.fanli.entity.bus.activity.ActivityUser; 
import com.yeshi.fanli.service.inter.activity.ActivityUserService; 
 
@Service 
public class ActivityUserServiceImpl implements ActivityUserService { 
 
    @Resource 
    private ActivityUserMapper activityUserMapper; 
 
    @Resource 
    private ActivityRuleUserMapper activityRuleUserMapper; 
 
    @Override 
    public ActivityUser selectByPrimaryKey(Long id) { 
        return activityUserMapper.selectByPrimaryKey(id); 
    } 
 
    @Override 
    public List<ActivityUser> listRand(int count) { 
        return activityUserMapper.listRand(count); 
    } 
 
    @Override 
    public void addActivityRuleUser(ActivityRuleUser ruleUser) { 
        if (ruleUser == null || ruleUser.getActivityUser() == null) 
            return; 
        // 添加用户 
        ActivityUser user = activityUserMapper.selectByName(ruleUser.getActivityUser().getNickName()); 
        if (user == null) { 
            user = ruleUser.getActivityUser(); 
            user.setCreateTime(new Date()); 
            activityUserMapper.insertSelective(user); 
        } 
        ActivityRuleUser oldRuleUser = activityRuleUserMapper.selectByUserIdAndRuleCode(user.getId(), 
                ruleUser.getRuleCode()); 
        if (oldRuleUser == null) { 
            ruleUser.setActivityUser(user); 
            ruleUser.setCreateTime(new Date()); 
            activityRuleUserMapper.insertSelective(ruleUser); 
        } else { 
            ActivityRuleUser update = new ActivityRuleUser(); 
            update.setId(oldRuleUser.getId()); 
            update.setOrderBy(ruleUser.getOrderBy()); 
            activityRuleUserMapper.updateByPrimaryKeySelective(update); 
        } 
    } 
 
    @Override 
    public List<ActivityRuleUser> listByRuleCode(Integer ruleCode, int page, int pageSize) { 
        return activityRuleUserMapper.listByRuleCode(ruleCode, (page - 1) * pageSize, pageSize); 
    } 
 
    @Override 
    public long countByRuleCode(Integer ruleCode) { 
        return activityRuleUserMapper.countByRuleCode(ruleCode); 
    } 
 
    @Override 
    public void deleteByRuleUserId(Long id) { 
        ActivityRuleUser user = activityRuleUserMapper.selectByPrimaryKey(id); 
        if (user.getActivityUser() != null) 
            activityUserMapper.deleteByPrimaryKey(user.getActivityUser().getId()); 
        activityRuleUserMapper.deleteByPrimaryKey(id); 
    } 
 
    @Override 
    public ActivityRuleUser selectRuleUserByPrimaryKey(Long id) { 
 
        return activityRuleUserMapper.selectByPrimaryKey(id); 
    } 
 
    @Override 
    public void updateActivityUser(ActivityUser au) { 
        activityUserMapper.updateByPrimaryKeySelective(au); 
    } 
 
    @Override 
    public void updateActivityRuleUser(ActivityRuleUser au) { 
        activityRuleUserMapper.updateByPrimaryKeySelective(au); 
    } 
 
}