xuhy
2024-10-23 815ea3a4565daf9bb9053e0140aa7fd4a177e809
ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TRepairServiceImpl.java
@@ -3,14 +3,24 @@
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.chargingPile.api.feignClient.SiteClient;
import com.ruoyi.chargingPile.api.model.Site;
import com.ruoyi.chargingPile.api.model.TChargingPile;
import com.ruoyi.chargingPile.api.model.TRepair;
import com.ruoyi.chargingPile.mapper.TRepairMapper;
import com.ruoyi.chargingPile.service.ISiteService;
import com.ruoyi.chargingPile.service.TChargingPileNotificationService;
import com.ruoyi.chargingPile.service.TChargingPileService;
import com.ruoyi.chargingPile.service.TRepairService;
import com.ruoyi.common.core.constant.MsgConstants;
import com.ruoyi.common.core.utils.HttpUtils;
import com.ruoyi.common.core.utils.MsgUtil;
import com.ruoyi.common.core.web.page.BasePage;
import com.ruoyi.common.core.web.page.PageInfo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.Arrays;
import java.util.List;
@@ -22,10 +32,15 @@
 * @author xiaochen
 * @since 2024-08-08
 */
@Slf4j
@Service
public class TRepairServiceImpl extends ServiceImpl<TRepairMapper, TRepair> implements TRepairService {
   @Autowired
   private ISiteService siteService;
   @Autowired
   private TChargingPileService chargingPileService;
   @Autowired
   private TChargingPileNotificationService chargingPileNotificationService;
   /**
    * 获取报修记录列表
    * @param name
@@ -36,4 +51,21 @@
   public List<TRepair> getRepairList(PageInfo<TRepair> pageInfo, String name, String siteId) {
      return this.baseMapper.getRepairList(pageInfo, name, siteId);
   }
   @Override
   public void add(TRepair dto) {
      // 故障短信提醒
      Site site = siteService.getById(dto.getSiteId());
      TChargingPile chargingPile = chargingPileService.getById(dto.getChargingPileId());
      String siteName = site.getName();
      String reqStr = MsgUtil.faultMsg(site.getPhone(), site.getName(), chargingPile.getNumber() + "");
      String result = HttpUtils.post(MsgConstants.SEND_URL, reqStr);
      log.info("故障短信提醒:{}",result);
      if(siteName.length()>10){
         siteName = siteName.substring(0,10);
      }
      chargingPileNotificationService.saveData(4,dto.getSiteId(),dto.getChargingPileId(),site.getPhone(),"检测到"+siteName+"..."+chargingPile.getNumber()+"号桩设备离线,请及时查看处理!");
      dto.setRepairTime(LocalDateTime.now());
      this.save(dto);
   }
}