1

zj

2025-04-11 d869f01aa59927d0b4c93c908dfdfb9ca6fb326f

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 systemuser.internal;
 
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
 
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.collections.Predicate;
 
import kernel.web.ApplicationUtil;
import systemuser.CustomerService;
import systemuser.model.Customer;
 
public class CustomerServiceImpl implements CustomerService {
 
    private Map<String, Customer> cache = new ConcurrentHashMap<String, Customer>();
 
    public void init() {
        List<Customer> list=ApplicationUtil.executeSelect(Customer.class);
        list.forEach(customer->cache.put(customer.getUsername(),customer));
    }
 
    public void save(Customer entity) {
        ApplicationUtil.executeInsert(entity);
        cache.put(entity.getUsername(), entity);
    }
 
    /**
     * 更新
     * @param entity
     * @param isOnline true:必须在线才更新，false：都能更新
     */
    public boolean update(Customer entity, boolean isOnline) {
        if (isOnline && cacheByUsername(entity.getUsername()).getOnline_state() != 1) return false;
        ApplicationUtil.executeUpdate(entity);
        cache.put(entity.getUsername(), entity);
        return true;
    }
 
    public void delete(String username) {
        Customer entity = cacheByUsername(username);
        ApplicationUtil.executeDelete(entity);
        cache.remove(entity.getUsername());
    }
 
    public Customer cacheByUsername(String username) {
        return cache.get(username);
    }
 
    /**
     * 分配一个在线客服给用户
     * 
     * @return
     */
    public Customer cacheOnlineOne() {
        List<Customer> list = new ArrayList<Customer>(cache.values());
        
        CollectionUtils.filter(list, new Predicate() {// 在线客服
            @Override
            public boolean evaluate(Object arg0) {
                return ((Customer) arg0).getOnline_state() == 1;
            }
        });
        
        if (CollectionUtils.isEmpty(list)) return null;
        
        Collections.sort(list, new Comparator<Customer>() {
            @Override
            public int compare(Customer arg0, Customer arg1) {
                if (arg0.getLast_customer_time() == null) {
                    return -1;
                } else if (arg1.getLast_customer_time() == null) {
                    return 1;
                }else {
                    return (int) (arg0.getLast_customer_time().getTime() - arg1.getLast_customer_time().getTime());
                }
            }
        });
        return list.get(0);
    }
}