功能完善

admin

2020-12-25 25680e135b5bdc15658622cbfde74bab73cfee77

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
package com.ks.lucky.util.mq.consumer;
 
import com.ks.lucky.pojo.DTO.ActivityDrwanOutDateMsg;
import com.ks.lucky.service.impl.LuckyActivityAwardResultManager;
import com.ks.lucky.util.mq.CMQManager;
import com.ks.lucky.utils.mq.CMQConsumeRunner;
import org.yeshi.utils.mq.JobThreadExecutorServiceImpl;
 
import javax.annotation.Resource;
import java.util.Iterator;
import java.util.Map;
 
/**
 * 中奖领取过期
 */
public class AcitivtyDrawnRecieveOutDateConsumer implements CMQConsumeRunner {
 
    @Resource
    private LuckyActivityAwardResultManager luckyActivityAwardResultManager;
 
 
    @Override
    public void start() {
        new JobThreadExecutorServiceImpl().run(new Runnable() {
            @Override
            public void run() {
                Map<String, ActivityDrwanOutDateMsg> map = CMQManager.getInstance().consumeActivityDrawnOutDateMsg(16);
                if (map != null) {
                    for (Iterator<String> its = map.keySet().iterator(); its.hasNext(); ) {
                        String handler = its.next();
                        ActivityDrwanOutDateMsg msg = map.get(handler);
                        if (msg != null) {
                            //过期
                            luckyActivityAwardResultManager.setResultOutDate(msg.getResultId());
                        }
                        CMQManager.getInstance().deleteActivityDrawnOutDateMsg(handler);
                    }
                }
            }
        });
    }
 
    @Override
    public void destroy() {
 
    }
}