123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778 |
- package com.szwl.service.impl;
- import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
- import com.baomidou.mybatisplus.core.toolkit.Wrappers;
- import com.szwl.model.entity.TEquipment;
- import com.szwl.mapper.TEquipmentMapper;
- import com.szwl.model.query.StatisticsParam;
- import com.szwl.model.utils.PushUtils;
- import com.szwl.service.TEquipmentService;
- import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
- import org.apache.commons.lang.StringUtils;
- import org.springframework.amqp.core.AmqpTemplate;
- import org.springframework.amqp.core.MessageProperties;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.stereotype.Service;
- import java.util.List;
- /**
- * <p>
- * 服务实现类
- * </p>
- *
- * @author wuhs
- * @since 2023-10-25
- */
- @Service
- public class TEquipmentServiceImpl extends ServiceImpl<TEquipmentMapper, TEquipment> implements TEquipmentService {
- @Autowired
- private AmqpTemplate amqpTemplate;
- @Autowired
- TEquipmentMapper tEquipmentMapper;
- @Override
- public String sentMessage(String clientId, String json) {
- LambdaQueryWrapper<TEquipment> query = Wrappers.lambdaQuery();
- query.eq(TEquipment::getClientId,clientId);
- List<TEquipment> equipmentList = tEquipmentMapper.selectList(query);
- if(equipmentList.size()==0){
- return "该设备不存在";
- }
- TEquipment equipment = equipmentList.get(0);
- if (equipment == null) {
- return "该设备不存在";
- }
- String channel = equipment.getChannel();
- String equimentType = equipment.getEquimentType();
- if(StringUtils.isEmpty(channel)||channel.equals("1")||StringUtils.isEmpty(equimentType)){
- //用个推
- PushUtils.push(equipment.getGtClientId(), "", "", json);
- }
- if(StringUtils.isNotEmpty(channel)&&channel.equals("2")&&StringUtils.isNotEmpty(equimentType)){
- //用Mq
- //1 创建消息
- MessageProperties messageProperties = new MessageProperties();
- messageProperties.setContentType("text/plain");
- org.springframework.amqp.core.Message message = new org.springframework.amqp.core.Message(json.getBytes(), messageProperties);
- amqpTemplate.send(equimentType, clientId, message);
- }
- return "success";
- }
- @Override
- public String findMachineTotalNum(StatisticsParam param) {
- return tEquipmentMapper.findMachineTotalNum(param);
- }
- @Override
- public String findMachineUseNum(StatisticsParam param) {
- return tEquipmentMapper.findMachineUseNum(param);
- }
- // @Override
- // public Integer insertBatchSomeColumn(List<TEquipment> entityList) {
- // return tEquipmentMapper.insertBatchSomeColumn(entityList);
- // }
- }
|