| | |
|---|
| | | package com.ruoyi.chargingPile.service.impl; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson2.JSON; |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import com.ruoyi.chargingPile.api.model.Site; |
|---|
| | | import com.ruoyi.chargingPile.api.model.TChargingPile; |
|---|
| | | import com.ruoyi.chargingPile.api.model.TFaultMessage; |
|---|
| | | import com.ruoyi.chargingPile.mapper.TFaultMessageMapper; |
|---|
| | | import com.ruoyi.chargingPile.service.ISiteService; |
|---|
| | | import com.ruoyi.chargingPile.service.TChargingPileNotificationService; |
|---|
| | | import com.ruoyi.chargingPile.service.TChargingPileService; |
|---|
| | | import com.ruoyi.chargingPile.service.TFaultMessageService; |
|---|
| | | import com.ruoyi.common.core.utils.MsgUtil; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | * @author xiaochen |
|---|
| | | * @since 2024-08-08 |
|---|
| | | */ |
|---|
| | | @Slf4j |
|---|
| | | @Service |
|---|
| | | public class TFaultMessageServiceImpl extends ServiceImpl<TFaultMessageMapper, TFaultMessage> implements TFaultMessageService { |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private ISiteService siteService; |
|---|
| | | @Autowired |
|---|
| | | private TChargingPileService chargingPileService; |
|---|
| | | @Autowired |
|---|
| | | private TChargingPileNotificationService chargingPileNotificationService; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void add(TFaultMessage dto) { |
|---|
| | | // 故障短信提醒 |
|---|
| | | Site site = siteService.getById(dto.getSiteId()); |
|---|
| | | TChargingPile chargingPile = chargingPileService.getById(dto.getChargingPileId()); |
|---|
| | | String siteName = site.getName(); |
|---|
| | | String result = MsgUtil.faultMsg(site.getPhone(), site.getName(), chargingPile.getNumber() + ""); |
|---|
| | | log.info("故障短信提醒：{}",result); |
|---|
| | | if(siteName.length()>10){ |
|---|
| | | siteName = siteName.substring(0,10); |
|---|
| | | } |
|---|
| | | chargingPileNotificationService.saveData(4,dto.getSiteId(),dto.getChargingPileId(),site.getPhone(),"检测到"+siteName+"..."+chargingPile.getNumber()+"号桩设备离线，请及时查看处理！"); |
|---|
| | | this.save(dto); |
|---|
| | | } |
|---|
| | | } |
|---|
