项目初始化

zhuguifei

2026-03-10 58402bd5e762361363a0f7d7907153c77dbb819f

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
package com.shlanbao.tzsc.pms.sys.msgqueue.service.impl;
 
import java.util.Date;
 
import com.shlanbao.tzsc.utils.tools.LogAnno;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import com.shlanbao.tzsc.base.dao.SysMessageQueueDaoI;
import com.shlanbao.tzsc.base.mapping.SysMessageQueue;
import com.shlanbao.tzsc.base.model.DataGrid;
import com.shlanbao.tzsc.base.model.PageParams;
import com.shlanbao.tzsc.base.service.BaseService;
import com.shlanbao.tzsc.pms.sys.msgqueue.beans.MessageQueueBean;
import com.shlanbao.tzsc.pms.sys.msgqueue.service.MessageQueueServiceI;
import com.shlanbao.tzsc.utils.tools.BeanConvertor;
import com.shlanbao.tzsc.utils.tools.StringUtil;
/**
 * 消息队列
 * @author Leejean
 * @create 2014年12月5日上午11:23:51
 */
@Service
public class MessageQueueServiceImpl extends BaseService implements
        MessageQueueServiceI {
    @Autowired
    private SysMessageQueueDaoI sysMessageQueueDao;
 
    @Override
    public void saveMessageQueue(MessageQueueBean messageQueueBean)
            throws Exception {
        sysMessageQueueDao.save(new SysMessageQueue(messageQueueBean.getMsgType(),
                messageQueueBean.getContent(),
                messageQueueBean.getSysSend(),
                messageQueueBean.getSysReceive(),
                new Date(),
                0L));
    }
 
    @Override
    public DataGrid getAllMessageQueues(MessageQueueBean messageQueueBean,
                                        PageParams pageParams) throws Exception {
        String hql="from SysMessageQueue o where o.del='0' ";
        if(messageQueueBean.getMsgType()!=null){
            hql=hql.concat(" and o.msgType = "+messageQueueBean.getMsgType());
        }
        if(messageQueueBean.getFlag()!=null){
            hql=hql.concat(" and o.flag = "+messageQueueBean.getFlag());
        }
        if(messageQueueBean.getSysSend()!=null){
            hql=hql.concat(" and o.sysSend = "+messageQueueBean.getSysSend());
        }
        if(messageQueueBean.getSysReceive()!=null){
            hql=hql.concat(" and o.sysReceive = "+messageQueueBean.getSysReceive());
        }
        /*if(StringUtil.notNull(messageQueueBean.getDes())){
            hql=hql.concat(" and o.des like '%"+messageQueueBean.getDes()+"%'");
        }*/
        if(StringUtil.notNull(messageQueueBean.getDate())){
            hql=hql.concat(" and to_char(o.date,'yyyy-MM-dd') >='"+messageQueueBean.getDate()+"'");
        }
        if(StringUtil.notNull(messageQueueBean.getDate())){
            hql=hql.concat(" and to_char(o.date,'yyyy-MM-dd') <='"+messageQueueBean.getEndTime()+"'");
        }
        //接口类型也参与关键字的模糊查询
        if(messageQueueBean.getContent()!=null){
            hql=hql.concat(" and o.content like '%"+messageQueueBean.getContent()+"%' ");
        }
        hql=hql.concat(" ORDER BY o.date");
 
        return new DataGrid(BeanConvertor.copyList(sysMessageQueueDao.queryByPage(hql, pageParams), MessageQueueBean.class), sysMessageQueueDao.queryTotal("select count(1) ".concat(hql)));
    }
 
    @LogAnno(operateType = "批量删除接口日志")
    @Override
    public void batchDeleteMessageQueues(String ids) throws Exception {
        for (String id : StringUtil.splitToStringList(ids, ",")) {
            this.deleteMessageQueue(id);
        }
    }
 
    @LogAnno(operateType = "删除接口日志")
    @Override
    public void deleteMessageQueue(String id) throws Exception {
        sysMessageQueueDao.updateByParams("update SysMessageQueue o set o.del='1' where o.id=?", id);
    }
}