MqSendLogServiceImpl.java 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. package com.fdkankan.fusion.service.impl;
  2. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  3. import com.fdkankan.fusion.entity.MqSendLog;
  4. import com.fdkankan.fusion.mapper.IMqSendLogMapper;
  5. import com.fdkankan.fusion.service.IMqSendLogService;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import org.springframework.stereotype.Service;
  8. import java.util.HashMap;
  9. import java.util.List;
  10. /**
  11. * <p>
  12. * 服务实现类
  13. * </p>
  14. *
  15. * @author
  16. * @since 2024-08-07
  17. */
  18. @Service
  19. public class MqSendLogServiceImpl extends ServiceImpl<IMqSendLogMapper, MqSendLog> implements IMqSendLogService {
  20. @Override
  21. public HashMap<String, Boolean> getMapByNumList(List<String> numList) {
  22. HashMap<String, Boolean> map = new HashMap<>();
  23. if(numList == null || numList.isEmpty()){
  24. return map;
  25. }
  26. LambdaQueryWrapper<MqSendLog> wrapper = new LambdaQueryWrapper<>();
  27. wrapper.in(MqSendLog::getNum,numList);
  28. List<MqSendLog> list = this.list(wrapper);
  29. for (MqSendLog mqSendLog : list) {
  30. map.put(mqSendLog.getNum(), mqSendLog.getStatus() == 1);
  31. }
  32. return map;
  33. }
  34. }