skjcmanager/skjcmanager-service-api/skjcmanager-nky-api/src/main/java/cn/gistack/nky/entity/RequestRecord.java
New file @@ -0,0 +1,40 @@ package cn.gistack.nky.entity; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import com.fasterxml.jackson.annotation.JsonFormat; import lombok.Data; import org.springframework.format.annotation.DateTimeFormat; import java.util.Date; /** * 南科院请求记录表 */ @Data @TableName( value = "NKY_REQUEST_RECORD",autoResultMap = true) public class RequestRecord { @TableId(value = "id", type = IdType.ASSIGN_ID) private String id; private String resGuid; private String pointId; private String requestUrl; private String sendParams; private String result; @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") private Date createTime; private String type; private String errorDesc; } skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/mapper/RequestRecordMapper.java
New file @@ -0,0 +1,15 @@ package cn.gistack.nky.mapper; import cn.gistack.nky.entity.HstPredict; import cn.gistack.nky.entity.RequestRecord; import cn.gistack.nky.vo.HstPredictVO; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.apache.ibatis.annotations.Param; import java.util.List; public interface RequestRecordMapper extends BaseMapper<RequestRecord> { } skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/IRequestRecordService.java
New file @@ -0,0 +1,7 @@ package cn.gistack.nky.service; import cn.gistack.nky.entity.RequestRecord; import com.baomidou.mybatisplus.extension.service.IService; public interface IRequestRecordService extends IService<RequestRecord> { } skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/AlarmGetServiceImpl.java
@@ -30,7 +30,7 @@ List<DataResPo> cdList = getResCdList(type); cdList.forEach(dataResPo -> { if (dataResPo.getChildren() != null){ if (dataResPo.getChildren() != null && dataResPo.getChildren().size()>0){ BatchDataPo batchDataPo = new BatchDataPo(dataResPo, type); nkyService.batchData(batchDataPo); } skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/NkyServiceImpl.java
@@ -4,13 +4,16 @@ import cn.gistack.nky.entity.AlarmGet; import cn.gistack.nky.entity.ArimaPredict; import cn.gistack.nky.entity.HstPredict; import cn.gistack.nky.entity.RequestRecord; import cn.gistack.nky.requestpojo.*; import cn.gistack.nky.service.INkyService; import cn.gistack.nky.service.IRequestRecordService; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springblade.core.tool.utils.DateUtil; import org.springframework.http.*; import org.springframework.stereotype.Service; import org.springframework.web.client.RestTemplate; @@ -28,7 +31,7 @@ @AllArgsConstructor @Slf4j public class NkyServiceImpl implements INkyService { private final IRequestRecordService requestRecordService; private static final String API_PREFIX = "http://10.42.7.146:9503/"; private static final String LOCAL_API_PREFIX = "https://sk.hubeishuiyi.cn/warnIp/"; @@ -50,12 +53,40 @@ @Override public Boolean arimaPredict(ArimaPredictReqPo po) { JSONObject jsonObject = requestNkyApi(ARIMA_PREDICT, JSON.toJSONString(po)); RequestRecord requestRecord = new RequestRecord(); try { requestRecord.setRequestUrl(ARIMA_PREDICT); requestRecord.setResGuid(po.getDamId()); requestRecord.setPointId(po.getPointId()); requestRecord.setSendParams(JSON.toJSONString(po)); requestRecord.setResult(JSON.toJSONString(jsonObject)); requestRecord.setCreateTime(DateUtil.now()); requestRecord.setType(po.getType()); }catch (Exception e){ requestRecord.setErrorDesc(e.toString()); } requestRecordService.save(requestRecord); return jsonObject.get("status").equals(200); } @Override public Boolean hstPredict(HstPredictReqPo po) { JSONObject jsonObject = requestNkyApi(HST_PREDICT, JSON.toJSONString(po)); RequestRecord requestRecord = new RequestRecord(); try { requestRecord.setRequestUrl(HST_PREDICT); requestRecord.setResGuid(po.getDamId()); requestRecord.setPointId(po.getPointId()); requestRecord.setSendParams(JSON.toJSONString(po)); requestRecord.setResult(JSON.toJSONString(jsonObject)); requestRecord.setCreateTime(DateUtil.now()); requestRecord.setType(po.getType()); }catch (Exception e){ requestRecord.setErrorDesc(e.toString()); } requestRecordService.save(requestRecord); return jsonObject.get("status").equals(200); } @@ -92,6 +123,21 @@ @Override public Boolean batchData(BatchDataPo po) { JSONObject jsonObject = requestNkyApi(ORIGIN_BATCHDATA, JSON.toJSONString(po)); RequestRecord requestRecord = new RequestRecord(); try { requestRecord.setRequestUrl(ORIGIN_BATCHDATA); if (po.getDatas().size()>0){ requestRecord.setResGuid(po.getDatas().get(0).getDamId()); requestRecord.setType(po.getDatas().get(0).getType()); } requestRecord.setSendParams(JSON.toJSONString(po)); requestRecord.setResult(JSON.toJSONString(jsonObject)); requestRecord.setCreateTime(DateUtil.now()); }catch (Exception e){ e.printStackTrace(); requestRecord.setErrorDesc(e.toString()); } requestRecordService.save(requestRecord); return jsonObject.get("status").equals(200); }
New file @@ -0,0 +1,11 @@ package cn.gistack.nky.service.impl; import cn.gistack.nky.entity.RequestRecord; import cn.gistack.nky.mapper.RequestRecordMapper; import cn.gistack.nky.service.IRequestRecordService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.springframework.stereotype.Service; @Service public class RequestRecordServiceImpl extends ServiceImpl<RequestRecordMapper, RequestRecord> implements IRequestRecordService { } skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/ZtApiServiceImpl.java
@@ -55,10 +55,25 @@ private static final String SL_API ="/services/1234567890ABCDEFGHIJKLMN/monitor/sl/api?res_nm=&cd=&city_cd=&county_cd=&pageNo=1&pageSize=9999"; int getSyCount = 0; @Override public List<DataResChildrenPo> getSy() { getSyCount = getSyCount +1; Map<String, Object> params = new LinkedHashMap<>(); return getData(LASTEST_OSMOTIC_PRESSURE, "get", params); try { log.info("第{}次请求",getSyCount); List<DataResChildrenPo> get = getData(LASTEST_OSMOTIC_PRESSURE, "get", params); getSyCount = 0; return get; }catch (Exception e){ e.printStackTrace(); if (getSyCount<=5){ return this.getSy(); }else { List<DataResChildrenPo> list = new ArrayList<>(); return list; } } } @Override @@ -67,10 +82,25 @@ return getData(WY_API, "get", params); } int getResSyCount = 0; @Override public List<DataResPo> getResSy() { getResSyCount = getResSyCount +1; Map<String, Object> params = new LinkedHashMap<>(); return getResData(LASTEST_OSMOTIC_PRESSURE, "get", params); try { log.info("第{}次请求",getResSyCount); List<DataResPo> get = getResData(LASTEST_OSMOTIC_PRESSURE, "get", params); getResSyCount = 0; return get; }catch (Exception e){ e.printStackTrace(); if (getResSyCount<=5){ return this.getResSy(); }else { List<DataResPo> list = new ArrayList<>(); return list; } } } @Override
