shasteel-biz/src/main/java/com/iailab/module/shasteel/job/service/impl/MessageInfoServiceImpl.java

@@ -8,8 +8,12 @@
import com.iailab.module.shasteel.job.dao.MessageInfoDao;
import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
import com.iailab.module.shasteel.job.service.MessageInfoService;
import com.mysql.cj.util.TimeUtil;
import org.springframework.stereotype.Service;

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

@Service
@@ -23,7 +27,7 @@
    @Override
    public PageResult<MessageInfoEntity> getMessagePage(Integer pageNo, Integer pageSize) {
        Page<MessageInfoEntity> params = new Page<>(pageNo, pageSize);
        IPage<MessageInfoEntity> page = baseDao.selectPage(params, new QueryWrapper<MessageInfoEntity>().eq(  "read_status", 0));
        IPage<MessageInfoEntity> page = baseDao.selectPage(params, new QueryWrapper<MessageInfoEntity>().orderByAsc("read_status").orderByDesc("send_time"));
        return new PageResult<>(page.getRecords(), page.getTotal());
    }

@@ -31,12 +35,26 @@
    public void readMessage(List<String> ids) {
        List<MessageInfoEntity> list = baseDao.selectBatchIds(ids);
        list.forEach(
                item->item.setReadStatus("1")
                item -> item.setReadStatus("1")
        );
        baseDao.updateById(list);
    }

    @Override
    public boolean getIsSuggestKeep(String title) {
        Date currentDate = new Date();
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(currentDate);
        calendar.add(Calendar.MINUTE, -15);
        Date keepDate = calendar.getTime();
        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        return baseDao.selectCount(new QueryWrapper<MessageInfoEntity>()
                .ge("send_time",formatter.format(keepDate))
                .eq("title",title)
        ) > 0;
    }

    @Override
    public List<MessageInfoEntity> getMessageList() {
        return baseDao.selectList(new QueryWrapper<MessageInfoEntity>());
    }