光伏预警规则编辑和回显API

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/IdxBizFanWarningRecordController.java

@@ -9,8 +9,10 @@ import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.module.jxiop.biz.dto.IdxBizFanWarningRecordDto;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWarningRecord;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWarningRuleSet;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizPvWarningRuleSet;
 import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.IdxBizFanWarningRecordServiceImpl;
 import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.IdxBizFanWarningRuleSetServiceImpl;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.IdxBizPvWarningRuleSetServiceImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.apache.commons.beanutils.BeanMap;
@@ -44,6 +46,9 @@ public class IdxBizFanWarningRecordController extends BaseController {
     @Autowired
 	IdxBizFanWarningRuleSetServiceImpl idxBizFanWarningRuleSetService;
 
+    @Autowired
+	IdxBizPvWarningRuleSetServiceImpl idxBizPvWarningRuleSetService;
+
     /**
      * 新增
      *
@@ -190,4 +195,70 @@ public class IdxBizFanWarningRecordController extends BaseController {
 		boolean b = idxBizFanWarningRuleSetService.updateBatchById(idxBizFanWarningRecordList);
 		return ResponseHelper.buildResponse(b);
 	}
+
+
+	/**
+	 * 根据sequenceNbr查询
+	 *
+	 * @param ANALYSISPOINTID  主键
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/getInfoByPointIdPv")
+	@ApiOperation(httpMethod = "GET",value = "根据ANALYSIS_POINT_ID查询单个",  notes = "根据ANALYSIS_POINT_ID查询单个")
+	public ResponseModel<Map<String, Object>> getInfoByPointIdPv(@RequestParam String ANALYSISPOINTID) {
+
+		LambdaQueryWrapper<IdxBizPvWarningRuleSet>	query  =new LambdaQueryWrapper<>();
+		query.eq(IdxBizPvWarningRuleSet::getAnalysisPointId,ANALYSISPOINTID);
+		List<IdxBizPvWarningRuleSet> idxBizPvWarningRecordList = idxBizPvWarningRuleSetService.getBaseMapper().selectList(query);
+		Map<String,Object> map = new HashMap<>();
+		for (int i = 0; i < idxBizPvWarningRecordList.size(); i++) {
+			IdxBizPvWarningRuleSet idxBizPvWarningRecord = idxBizPvWarningRecordList.get(i);
+			if (idxBizPvWarningRecord.getWarningName().equals("注意")){
+				map.putAll(BeanUtil.beanToMap(idxBizPvWarningRecord));
+			}else if (idxBizPvWarningRecord.getWarningName().equals("警告")){
+				//警告周期
+				map.put("jgWarningCycle",idxBizPvWarningRecord.getWarningCycle());
+				map.put("jgWarningIf",idxBizPvWarningRecord.getWarningIf());
+			}else if (idxBizPvWarningRecord.getWarningName().equals("危险")){
+				//警告周期
+				map.put("wxWarningCycle",idxBizPvWarningRecord.getWarningCycle());
+				map.put("wxWarningIf",idxBizPvWarningRecord.getWarningIf());
+			}
+		}
+		return ResponseHelper.buildResponse(map);
+	}
+
+
+
+	/**
+	 * 根据pointId修改信息
+	 *
+	 * @param analysisInfo  主键
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/updateByPointInfoPv")
+	@ApiOperation(httpMethod = "POST", value = "根据pointId修改信息", notes = "根据pointId修改信息")
+	public ResponseModel<Boolean> updateByPointInfoPv(@RequestBody JSONObject analysisInfo) {
+		LambdaQueryWrapper<IdxBizPvWarningRuleSet> query = new LambdaQueryWrapper<>();
+		query.eq(IdxBizPvWarningRuleSet::getAnalysisPointId, analysisInfo.get("analysisPointId"));
+		List<IdxBizPvWarningRuleSet> idxBizFanWarningRecordList = idxBizPvWarningRuleSetService.getBaseMapper().selectList(query);
+		for (IdxBizPvWarningRuleSet idxBizPvWarningRuleSet : idxBizFanWarningRecordList) {
+			BeanUtil.copyProperties(analysisInfo, idxBizPvWarningRuleSet, "sequenceNbr", "warningName");
+			if (idxBizPvWarningRuleSet.getWarningName().equals("警告")) {
+				//警告周期
+				idxBizPvWarningRuleSet.setWarningIf(analysisInfo.get("jgWarningIf").toString());
+				idxBizPvWarningRuleSet.setWarningCycle(analysisInfo.get("jgWarningCycle").toString());
+			} else if (idxBizPvWarningRuleSet.getWarningName().equals("危险")) {
+				//警告周期
+				idxBizPvWarningRuleSet.setWarningIf(analysisInfo.get("wxWarningIf").toString());
+				idxBizPvWarningRuleSet.setWarningCycle(analysisInfo.get("wxWarningCycle").toString());
+			}
+		}
+		boolean b = idxBizPvWarningRuleSetService.updateBatchById(idxBizFanWarningRecordList);
+		return ResponseHelper.buildResponse(b);
+	}
+
+
 }