TEquipmentServiceImpl.java 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. package com.szwl.service.impl;
  2. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  3. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  4. import com.szwl.model.entity.TEquipment;
  5. import com.szwl.mapper.TEquipmentMapper;
  6. import com.szwl.model.query.StatisticsParam;
  7. import com.szwl.model.utils.PushUtils;
  8. import com.szwl.service.TEquipmentService;
  9. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  10. import org.apache.commons.lang.StringUtils;
  11. import org.springframework.amqp.core.AmqpTemplate;
  12. import org.springframework.amqp.core.MessageProperties;
  13. import org.springframework.beans.factory.annotation.Autowired;
  14. import org.springframework.stereotype.Service;
  15. import java.util.List;
  16. /**
  17. * <p>
  18. * 服务实现类
  19. * </p>
  20. *
  21. * @author wuhs
  22. * @since 2023-10-25
  23. */
  24. @Service
  25. public class TEquipmentServiceImpl extends ServiceImpl<TEquipmentMapper, TEquipment> implements TEquipmentService {
  26. @Autowired
  27. private AmqpTemplate amqpTemplate;
  28. @Autowired
  29. TEquipmentMapper tEquipmentMapper;
  30. @Override
  31. public String sentMessage(String clientId, String json) {
  32. LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
  33. query.eq(TEquipment::getClientId,clientId);
  34. List<TEquipment> equipmentList = tEquipmentMapper.selectList(query);
  35. if(equipmentList.size()==0){
  36. return "该设备不存在";
  37. }
  38. TEquipment equipment = equipmentList.get(0);
  39. if (equipment == null) {
  40. return "该设备不存在";
  41. }
  42. String channel = equipment.getChannel();
  43. String equimentType = equipment.getEquimentType();
  44. if(StringUtils.isEmpty(channel)||channel.equals("1")||StringUtils.isEmpty(equimentType)){
  45. //用个推
  46. PushUtils.push(equipment.getGtClientId(), "", "", json);
  47. }
  48. if(StringUtils.isNotEmpty(channel)&&channel.equals("2")&&StringUtils.isNotEmpty(equimentType)){
  49. //用Mq
  50. //1 创建消息
  51. MessageProperties messageProperties = new MessageProperties();
  52. messageProperties.setContentType("text/plain");
  53. org.springframework.amqp.core.Message message = new org.springframework.amqp.core.Message(json.getBytes(), messageProperties);
  54. amqpTemplate.send(equimentType, clientId, message);
  55. }
  56. return "success";
  57. }
  58. @Override
  59. public String findMachineTotalNum(StatisticsParam param) {
  60. return tEquipmentMapper.findMachineTotalNum(param);
  61. }
  62. @Override
  63. public String findMachineUseNum(StatisticsParam param) {
  64. return tEquipmentMapper.findMachineUseNum(param);
  65. }
  66. // @Override
  67. // public Integer insertBatchSomeColumn(List<TEquipment> entityList) {
  68. // return tEquipmentMapper.insertBatchSomeColumn(entityList);
  69. // }
  70. }