湖北水库项目
blame | history | patch | commit | commitdiff | ignore whitespace
zhongrj
2023-07-05 2a8f13fe78fbf4b74bd93bd43ae7b7e3e9211e79 
 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeHandle.java


@@ -3,19 +3,30 @@


import cn.gistack.alerts.alarmRule.entity.AlarmRecord;


import cn.gistack.alerts.alarmRule.entity.AlarmRule;


import cn.gistack.alerts.alarmRule.service.AlarmRecordService;


import cn.gistack.alerts.notice.constant.ZtApiUrlConstant;


import cn.gistack.alerts.notice.constant.ZtConfigConstant;


import cn.gistack.alerts.notice.enums.PersonEnum;


import cn.gistack.alerts.notice.util.FormatUtil;


import cn.gistack.alerts.sms.entity.SmsTemplate;


import cn.gistack.alerts.sms.service.ISmsTemplateService;


import cn.gistack.alerts.sms.vo.SmsRequestTemplate;


import cn.gistack.common.utils.SpringContextUtil;


import cn.gistack.sm.sjztmd.feign.IAttResManagePersonClient;


import cn.gistack.sm.sjztmd.vo.PersonVO;


import cn.gistack.system.feign.ISysClient;


import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONArray;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import org.jetbrains.annotations.NotNull;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.http.HttpEntity;


import org.springframework.http.HttpHeaders;


import org.springframework.http.HttpMethod;


import org.springframework.http.ResponseEntity;


import org.springframework.stereotype.Component;


import org.springframework.util.MultiValueMap;


import org.springframework.web.client.RestTemplate;




import java.util.ArrayList;


import java.util.List;


@@ -30,12 +41,14 @@


   @Autowired


   private ISmsTemplateService smsTemplateService;






   @Autowired


   private IAttResManagePersonClient attResManagePersonClient;




   @Autowired


   private ISysClient sysClient;




   @Autowired


   private RestTemplate restTemplate;






   /**


@@ -349,4 +362,42 @@


         }


      }


   }






   /**


    * 调用中台接口查询数据


    *


    * @param params


    * @param url


    * @return


    */


   public JSONArray getZtData(String params, String url) {


      // 获取环境


      String activeProfile = SpringContextUtil.getActiveProfile();


      if (activeProfile.equals("dev")){


         url = ZtApiUrlConstant.url_prefix_dev + url;


      }


      if (activeProfile.equals("prod")){


         url = ZtApiUrlConstant.url_prefix_prod + url;


      }


      //设置请求头


      HttpHeaders headers = new HttpHeaders();


      headers.add(ZtConfigConstant.header_key, ZtConfigConstant.header_value);


      //封装请求头


      HttpEntity<MultiValueMap<String, Object>> formEntity = new HttpEntity<MultiValueMap<String, Object>>(headers);


      try {


         //有请求头，有参数请求


         ResponseEntity<String> responseEntity =


            restTemplate.exchange(url + params,


               HttpMethod.GET,


               formEntity,


               String.class);


         JSONObject jsonObject = JSON.parseObject(responseEntity.getBody());


         // 返回


         return JSONArray.parseArray(jsonObject.get("data").toString());


      } catch (Exception e) {


         e.printStackTrace();


      }


      return null;


   }


}