#大模型发电量

hzims-service-api/equipment-api/src/main/java/com/hnac/hzims/equipment/feign/IEmInfoClient.java

@@ -19,6 +19,7 @@ package com.hnac.hzims.equipment.feign;
 import com.hnac.hzims.EquipmentConstants;
 import com.hnac.hzims.equipment.entity.EmInfoEntity;
 import com.hnac.hzims.equipment.vo.DeviceVO;
+import com.hnac.hzims.equipment.vo.RideDeviceVo;
 import org.springblade.core.tool.api.R;
 import org.springblade.system.vo.CreateTableVO;
 import org.springframework.cloud.openfeign.FeignClient;
@@ -84,6 +85,9 @@ public interface IEmInfoClient {
 	String DEVICE_BY_PATH = API_PREFIX + "/deviceByPath";
 	String EM_INFO_LIST = API_PREFIX + "/emInfoList";
 
+	String RIDE_DEVICES = API_PREFIX + "/rideDevices";
+
+
 	@PostMapping(DETAIL)
 	EmInfoEntity getByCode(@RequestParam("code") String id);
 
@@ -169,4 +173,7 @@ public interface IEmInfoClient {
 
 	@GetMapping(EM_INFO_LIST)
 	R<List<EmInfoEntity>> emInfoList(EmInfoEntity req);
+
+	@GetMapping(RIDE_DEVICES)
+	List<RideDeviceVo> rideDevices(List<Long> longs);
 }

hzims-service-api/equipment-api/src/main/java/com/hnac/hzims/equipment/feign/IEmInfoClientBack.java

@@ -2,6 +2,7 @@ package com.hnac.hzims.equipment.feign;
 
 import com.hnac.hzims.equipment.entity.EmInfoEntity;
 import com.hnac.hzims.equipment.vo.DeviceVO;
+import com.hnac.hzims.equipment.vo.RideDeviceVo;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.tool.api.R;
 import org.springblade.system.vo.CreateTableVO;
@@ -114,4 +115,9 @@ public class IEmInfoClientBack implements IEmInfoClient {
 	public R<List<EmInfoEntity>> emInfoList(EmInfoEntity req) {
 		return R.fail("远程调用失败");
 	}
+
+	@Override
+	public List<RideDeviceVo> rideDevices(List<Long> longs) {
+		return new ArrayList<>();
+	}
 }

hzims-service/equipment/src/main/java/com/hnac/hzims/equipment/feign/EmInfoClient.java

@@ -9,6 +9,7 @@ import com.hnac.hzims.common.utils.Condition;
 import com.hnac.hzims.equipment.entity.EmInfoEntity;
 import com.hnac.hzims.equipment.service.IEmInfoService;
 import com.hnac.hzims.equipment.vo.DeviceVO;
+import com.hnac.hzims.equipment.vo.RideDeviceVo;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.CollectionUtil;
 import org.springblade.core.tool.utils.ObjectUtil;
@@ -155,6 +156,11 @@ public class EmInfoClient implements IEmInfoClient {
 		return R.data(service.list(queryWrapper));
 	}
 
+	@Override
+	public List<RideDeviceVo> rideDevices(List<Long> deptIds) {
+		return service.rideDevices(deptIds);
+	}
+
 	@PostMapping(GET_EM_CREATE_TABLE)
 	@Override
 	public List<CreateTableVO> getEmCreateTable(List<String> tableNames) {

hzims-service/equipment/src/main/java/com/hnac/hzims/equipment/mapper/EmParamMapper.java

@@ -19,4 +19,5 @@ public interface EmParamMapper extends UserDataScopeBaseMapper<EmParamEntity> {
 
 	List<EmParamEntity> selectRideCountGroupEmIdByDepts(@Param("list") List<Long> list);
 
+    List<EmParamEntity> rides(List<Long> deviceIds);
 }

hzims-service/equipment/src/main/java/com/hnac/hzims/equipment/mapper/EmParamMapper.xml

@@ -53,4 +53,13 @@
         'installedCapacity')
     </select>
 
+    <select id="rides" resultType="com.hnac.hzims.equipment.entity.EmParamEntity">
+        SELECT * FROM HZIMS_EM_PARAM
+        WHERE `IS_DELETED` = 0
+        AND (PARAM_NAME = 'ct' OR PARAM_NAME = 'CT' OR PARAM_NAME = 'PR'  OR PARAM_NAME = 'pt')
+        AND INFO_ID IN
+        <foreach collection="deviceIds" item="item" index="index" open="(" close=")" separator=",">
+            #{item}
+        </foreach>
+    </select>
 </mapper>

hzims-service/equipment/src/main/java/com/hnac/hzims/equipment/service/IEmInfoService.java

@@ -98,4 +98,6 @@ public interface IEmInfoService extends BaseService<EmInfoEntity> {
     List<EmInfoEntity> select(Long deptId);
 
 	List<EmInfoTreeVO> getEmInfoTree(EmInfoEntity req);
+
+    List<RideDeviceVo> rideDevices(List<Long> deptIds);
 }

hzims-service/equipment/src/main/java/com/hnac/hzims/equipment/service/IEmParamService.java

@@ -19,4 +19,5 @@ public interface IEmParamService extends BaseService<EmParamEntity> {
 
 	Map<Long, Map<String,Double>> getRideCountGroupEmIdByDepts(List<Long> emIds);
 
+    List<EmParamEntity> rides(List<Long> deviceIds);
 }

hzims-service/equipment/src/main/java/com/hnac/hzims/equipment/service/impl/EmInfoServiceImpl.java

@@ -949,4 +949,51 @@ public class EmInfoServiceImpl extends BaseServiceImpl<EmInfoMapper, EmInfoEntit
 		return this.baseMapper.getEmInfoTree(queryWrapper);
 	}
 
+	@Override
+	public List<RideDeviceVo> rideDevices(List<Long> deptIds) {
+		// 查询设备
+		List<EmInfoEntity> devices = this.list(Wrappers.<EmInfoEntity>lambdaQuery()
+				.in(EmInfoEntity::getDepartment,deptIds)
+				.eq(EmInfoEntity::getHomePageDisplay,"1")
+				.eq(EmInfoEntity::getEmType,"2")
+		);
+		if(CollectionUtil.isEmpty(devices)){
+			return new ArrayList<>();
+		}
+		List<EmParamEntity> paramList = paramService.rides(devices.stream().map(EmInfoEntity::getId).collect(Collectors.toList()));
+		return devices.stream().map(device->{
+			RideDeviceVo rideDevice = new RideDeviceVo();
+			BeanUtil.copyProperties(device,rideDevice);
+			// 寻找设备配置参数
+			List<EmParamEntity> itemParamList = paramList.stream().filter(o->device.getId().equals(o.getInfoId())).collect(Collectors.toList());
+			if(CollectionUtil.isNotEmpty(itemParamList)) {
+				// 遍历设备配置参数
+				for (EmParamEntity paramEntity : itemParamList) {
+					String paramName = paramEntity.getParamName();
+					switch (paramName) {
+						case "ct":
+						case "CT":
+							rideDevice.setCt(Double.parseDouble(paramEntity.getParamValue()));
+							break;
+						case "pt":
+						case "PT":
+							rideDevice.setPt(Double.parseDouble(paramEntity.getParamValue()));
+							break;
+						default:
+							break;
+					}
+				}
+				// 设置ct * pt
+				if (null != rideDevice.getCt() && null != rideDevice.getPt()) {
+					rideDevice.setRide(rideDevice.getCt() * rideDevice.getPt());
+				}else{
+					rideDevice.setRide(1.0);
+				}
+			}else{
+				rideDevice.setRide(1.0);
+			}
+			return rideDevice;
+		}).collect(Collectors.toList());
+	}
+
 }

hzims-service/equipment/src/main/java/com/hnac/hzims/equipment/service/impl/EmParamServiceImpl.java

@@ -69,4 +69,9 @@ public class EmParamServiceImpl extends BaseServiceImpl<EmParamMapper, EmParamEn
 
 		return result;
 	}
+
+	@Override
+	public List<EmParamEntity> rides(List<Long> deviceIds) {
+		return this.baseMapper.rides(deviceIds);
+	}
 }

hzims-service/hzims-big-model/src/main/java/com/hnac/hzims/bigmodel/interactive/controller/InteractiveController.java

@@ -1,6 +1,5 @@
 package com.hnac.hzims.bigmodel.interactive.controller;
 
-import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.hnac.hzims.bigmodel.BigModelConstants;
@@ -8,7 +7,6 @@ import com.hnac.hzims.bigmodel.interactive.req.ModelFunctionReq;
 import com.hnac.hzims.bigmodel.interactive.service.IInteractiveService;
 import com.hnac.hzinfo.log.annotation.Business;
 import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiModelProperty;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
 import lombok.AllArgsConstructor;
@@ -16,9 +14,7 @@ import org.springblade.core.tool.api.R;
 import org.springblade.system.dto.ControlDTO;
 import org.springframework.web.bind.annotation.*;
 
-import javax.servlet.http.HttpServletRequest;
+import java.text.DecimalFormat;
-import java.util.HashMap;
-import java.util.Map;
 
 /**
  * @Author: huangxing
@@ -84,6 +80,8 @@ public class InteractiveController {
     public R generation(@RequestParam @ApiParam("站点编号") String stationId,
                             @RequestParam @ApiParam("开始时间") String startTime,
                             @RequestParam @ApiParam("结束时间")String endTime) {
-        return R.data(interactiveService.generation(stationId,startTime,endTime) + "kwh");
+        double generate = interactiveService.generation(stationId,startTime,endTime);
+        DecimalFormat format = new DecimalFormat("0.00");
+        return R.data(format.format(generate) + "kwh");
     }
 }

hzims-service/hzims-big-model/src/main/java/com/hnac/hzims/bigmodel/interactive/service/impl/InteractiveServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.http.HttpResponse;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import com.hnac.hzims.bigmodel.configuration.BigModelInvokeUrl;
 import com.hnac.hzims.bigmodel.entity.FunctionEntity;
 import com.hnac.hzims.bigmodel.function.service.IFunctionService;
@@ -14,19 +15,26 @@ import com.hnac.hzims.bigmodel.interactive.service.IInteractiveService;
 import com.hnac.hzims.bigmodel.interactive.service.IJumpPageService;
 import com.hnac.hzims.bigmodel.interactive.service.IParamsService;
 import com.hnac.hzims.bigmodel.interactive.vo.AnswerVO;
+import com.hnac.hzims.equipment.feign.IEmInfoClient;
+import com.hnac.hzims.equipment.vo.EminfoAndEmParamVo;
+import com.hnac.hzims.equipment.vo.RideDeviceVo;
 import com.hnac.hzims.operational.fill.feign.IGenerateClient;
+import com.hnac.hzims.operational.main.constant.HomePageConstant;
 import com.hnac.hzims.operational.station.entity.StationEntity;
 import com.hnac.hzims.operational.station.feign.IStationClient;
+import com.hnac.hzinfo.datasearch.analyse.IAnalyseDataSearchClient;
+import com.hnac.hzinfo.datasearch.analyse.po.AnalyseCodeByAnalyseDataPO;
+import com.hnac.hzinfo.datasearch.analyse.po.AnalyzeDataConditionPO;
+import com.hnac.hzinfo.datasearch.analyse.vo.AnalyseDataTaosVO;
+import com.hnac.hzinfo.datasearch.analyse.vo.AnalyzeDataConditionVO;
 import com.xxl.job.core.log.XxlJobLogger;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.MapUtils;
 import org.springblade.core.log.exception.ServiceException;
 import org.springblade.core.log.logger.BladeLogger;
 import org.springblade.core.tool.api.R;
-import org.springblade.core.tool.utils.CollectionUtil;
+import org.springblade.core.tool.utils.*;
-import org.springblade.core.tool.utils.Func;
-import org.springblade.core.tool.utils.ObjectUtil;
-import org.springblade.core.tool.utils.StringUtil;
 import org.springblade.system.dto.ControlDTO;
 import org.springblade.system.dto.DeptStationDTO;
 import org.springblade.system.feign.IDeptClient;
@@ -38,7 +46,10 @@ import org.springframework.stereotype.Service;
 import org.springframework.util.Assert;
 
 import javax.servlet.http.HttpServletResponse;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
+import java.util.concurrent.*;
 import java.util.stream.Collectors;
 
 import static com.hnac.hzims.bigmodel.interactive.constants.FunctionConstants.TypeEnum;
@@ -55,6 +66,8 @@ public class InteractiveServiceImpl implements IInteractiveService {
 
     private final BladeLogger logger;
 
+    private final IEmInfoClient deviceClient;
+
     private final IRemoteClient remoteClient;
 
     private final IStationClient stationClient;
@@ -73,8 +86,12 @@ public class InteractiveServiceImpl implements IInteractiveService {
 
     private final RedisTemplate redisTemplate;
 
+    private final IAnalyseDataSearchClient analyseDataSearchClient;
+
     private final ExtraResolveStrategyService extraResolveStrategyService;
 
+    private static final ExecutorService pool = new ThreadPoolExecutor(10, 10, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(1024), new ThreadFactoryBuilder().setNameFormat("station-device-generate-%d").build(), new ThreadPoolExecutor.CallerRunsPolicy());
+
     @Value("${fdp.host}")
     private String fdpHost;
 
@@ -303,9 +320,78 @@ public class InteractiveServiceImpl implements IInteractiveService {
         double fill = generateClient.stationGenerateByTime(stationId,startTime,endTime);
 
         // 步骤3.查询设备
+        List<RideDeviceVo> devices = deviceClient.rideDevices(Collections.singletonList(station.getData().getRefDept()));
+        if(CollectionUtil.isEmpty(devices)){
+            return fill;
+        }
 
         // 步骤4.遍历设备查询发电量
+        // 监控线程执行完后返回结果
+        CountDownLatch countDownLatch = new CountDownLatch(devices.size());
+        List<Double> deviceGenerate = new CopyOnWriteArrayList();
+        for(RideDeviceVo device : devices){
+            pool.submit(()->{
+                deviceGenerate.add(this.periodTargetFloat(startTime,endTime,5,6,device.getNumber(),device.getRide(), HomePageConstant.HYDROPOWER_GENERATE_POWER));
+            });
+            countDownLatch.countDown();
+        }
+        //所有模板数据获取完成后释放锁
+        try {
+            countDownLatch.await();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+            Thread.currentThread().interrupt();
+        }
+        return fill + deviceGenerate.stream().mapToDouble(Double::doubleValue).sum();
+    }
 
-        return fill;
+    /***
+     * 指标数据列表查询
+     * @param startTime 开始时间
+     * @param endTime  结束时间
+     * @param accessRules 取数规则 : 0=最早值  1=最大值  2=最小值  3=平均值 4=和值 5=差值  6=最新值
+     * @param cycleType  间隔周期 : 0-> 秒  1-> 分 2-> 小时 3->天 4-> 周  5-> 月 6-> 年
+     * @param deviceCode 设备编号
+     * @param ride 配电比
+     * @param signages 指标
+     * @return
+     */
+    private Double periodTargetFloat(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode,Double ride,String signages) {
+        AnalyseCodeByAnalyseDataPO po = new AnalyseCodeByAnalyseDataPO();
+        List<AnalyzeDataConditionPO> signboardConditions = new ArrayList<>();
+        AnalyzeDataConditionPO analyzeDataConditionPO = new AnalyzeDataConditionPO();
+        analyzeDataConditionPO.setFull(1);
+        po.setDeviceCode(deviceCode);
+        analyzeDataConditionPO.setSignages(signages);
+        analyzeDataConditionPO.setKeepFigures(2);
+        analyzeDataConditionPO.setAccessRules(accessRules);
+        analyzeDataConditionPO.setSaveTimeType(cycleType);
+        // 间隔
+        analyzeDataConditionPO.setTimeInterval(1);
+        analyzeDataConditionPO.setBeginTime(LocalDateTime.parse(DateUtil.format(new Date(), startTime), DateTimeFormatter.ofPattern(DateUtil.PATTERN_DATETIME)));
+        analyzeDataConditionPO.setEndTime(LocalDateTime.parse(DateUtil.format(new Date(), endTime), DateTimeFormatter.ofPattern(DateUtil.PATTERN_DATETIME)));
+        signboardConditions.add(analyzeDataConditionPO);
+        po.setSignboardConditions(signboardConditions);
+        R<List<AnalyzeDataConditionVO>> result = analyseDataSearchClient.getAnalyzeDataByAnalyzeCodeAndSignages(po);
+        if (!result.isSuccess() || CollectionUtil.isEmpty(result.getData())) {
+            return 0.0;
+        }
+        List<AnalyzeDataConditionVO> records = result.getData();
+        if(CollectionUtil.isEmpty(records)){
+            return 0.0;
+        }
+        AnalyzeDataConditionVO analyzeDataConditionVO = records.get(0);
+        if (ObjectUtil.isEmpty(analyzeDataConditionVO)) {
+            return 0.0;
+        }
+        List<AnalyseDataTaosVO> analyseDataTaosVOList = analyzeDataConditionVO.getList();
+        if (CollectionUtil.isEmpty(analyseDataTaosVOList)) {
+            return 0.0;
+        }
+        AnalyseDataTaosVO analyseDataTaosVO = analyzeDataConditionVO.getList().get(0);
+        if (ObjectUtil.isEmpty(analyseDataTaosVO) || StringUtil.isBlank(analyseDataTaosVO.getVal())) {
+            return 0.0;
+        }
+        return Double.parseDouble(analyseDataTaosVO.getVal()) * ride;
     }
 }

hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/IAnalyseDataService.java

@@ -15,10 +15,13 @@ public interface IAnalyseDataService {
 
 	<T> List<AnalyzeCodeBySignagesVO> getAnalyzeCodeBySignages(Function<T, MultiAnalyzeCodePO> convert, T resource);
 
+	List<AnalyzeCodeBySignagesVO> analyzeCodeBySignages(List<MultiAnalyzeCodePO> list);
+
+	List<AnalyzeDataConditionVO> periodTargetSignages(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, List<String> signages);
 
 	List<AnalyseDataTaosVO>  periodTargetData(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, String signages);
 
 	List<AnalyseDataTaosVO>  periodTargetDatas(String startTime, String endTime, Integer accessRules, Integer cycleType, List<String> deviceCodes, String signages);
 
-	Float periodTargetFloat(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, Integer ride ,String signages);
+	Float periodTargetFloat(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, Double ride ,String signages);
 }

hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/AnalyseDataServiceImpl.java

@@ -22,7 +22,10 @@ import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Date;
+import java.util.List;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
@@ -47,6 +50,58 @@ public class AnalyseDataServiceImpl implements IAnalyseDataService {
 		return result;
 	}
 
+	/**
+	 * 查询设备实例属性标识
+	 * @param list
+	 * @return
+	 */
+	@Override
+	public List<AnalyzeCodeBySignagesVO> analyzeCodeBySignages(List<MultiAnalyzeCodePO> list) {
+		R<List<AnalyzeCodeBySignagesVO>> result = analyseDataSearchClient.getAnalyzeCodeBySignages(list);
+		if(!result.isSuccess() || CollectionUtil.isEmpty(result.getData())){
+			return new ArrayList<>();
+		}
+		return result.getData();
+	}
+
+	/***
+	 * 指标数据列表查询
+	 * @param startTime 开始时间
+	 * @param endTime  结束时间
+	 * @param accessRules 取数规则 : 0=最早值  1=最大值  2=最小值  3=平均值 4=和值 5=差值  6=最新值
+	 * @param cycleType  间隔周期 : 0-> 秒  1-> 分 2-> 小时 3->天 4-> 周  5-> 月 6-> 年
+	 * @param deviceCode 设备编号
+	 * @param signages 指标集合
+	 * @return
+	 */
+	@Override
+	public List<AnalyzeDataConditionVO> periodTargetSignages(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode, List<String> signages) {
+		AnalyseCodeByAnalyseDataPO po = new AnalyseCodeByAnalyseDataPO();
+		List<AnalyzeDataConditionPO> signboardConditions = new ArrayList<>();
+		signages.forEach(signage->{
+			AnalyzeDataConditionPO analyzeDataConditionPO = new AnalyzeDataConditionPO();
+			analyzeDataConditionPO.setFull(1);
+			po.setDeviceCode(deviceCode);
+			analyzeDataConditionPO.setKeepFigures(2);
+			analyzeDataConditionPO.setAccessRules(accessRules);
+			analyzeDataConditionPO.setSaveTimeType(cycleType);
+			analyzeDataConditionPO.setSignages(signage);
+			// 间隔
+			analyzeDataConditionPO.setTimeInterval(1);
+			analyzeDataConditionPO.setBeginTime(LocalDateTime.parse(DateUtil.format(new Date(), startTime), DateTimeFormatter.ofPattern(DateUtil.PATTERN_DATETIME)));
+			analyzeDataConditionPO.setEndTime(LocalDateTime.parse(DateUtil.format(new Date(), endTime), DateTimeFormatter.ofPattern(DateUtil.PATTERN_DATETIME)));
+			signboardConditions.add(analyzeDataConditionPO);
+		});
+		po.setSignboardConditions(signboardConditions);
+		log.error("period_targets_data_request {}",po);
+		R<List<AnalyzeDataConditionVO>> result = analyseDataSearchClient.getAnalyzeDataByAnalyzeCodeAndSignages(po);
+		if (!result.isSuccess() || CollectionUtil.isEmpty(result.getData())) {
+			return new ArrayList<>();
+		}
+		log.error("period_targets_data_resp {}",result);
+		return result.getData();
+	}
+
 	/***
 	 * 指标数据列表查询
 	 * @param startTime 开始时间
@@ -134,7 +189,7 @@ public class AnalyseDataServiceImpl implements IAnalyseDataService {
 	 * @return
 	 */
 	@Override
-	public Float periodTargetFloat(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode,Integer ride,String signages) {
+	public Float periodTargetFloat(String startTime, String endTime, Integer accessRules, Integer cycleType, String deviceCode,Double ride,String signages) {
 		AnalyseCodeByAnalyseDataPO po = new AnalyseCodeByAnalyseDataPO();
 		List<AnalyzeDataConditionPO> signboardConditions = new ArrayList<>();
 		AnalyzeDataConditionPO analyzeDataConditionPO = new AnalyzeDataConditionPO();
@@ -170,7 +225,7 @@ public class AnalyseDataServiceImpl implements IAnalyseDataService {
 		if (ObjectUtil.isEmpty(analyseDataTaosVO) || StringUtil.isBlank(analyseDataTaosVO.getVal())) {
 			return 0f;
 		}
-		return  Float.parseFloat(Optional.ofNullable(analyseDataTaosVO.getVal()).orElse("0")) * ride;
+		return Float.parseFloat(String.valueOf(Double.parseDouble(analyseDataTaosVO.getVal()) * ride)) ;
 	}