物理区域修改同步风险区域

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/controller/RiskSourceController.java

@@ -759,4 +759,13 @@ public class RiskSourceController extends BaseController {
     public CommonResponse removeBind(@RequestParam Long instanceId){
         return CommonResponseUtil.success(riskSourceService.removeBind(instanceId));
     }
+
+    @Permission
+    @ApiOperation(value = "物理区域修改同步到风险区域",notes = "修改物理区域")
+    @PostMapping("/syn/updateAreaSyn")
+    public CommonResponse updateAreaSyn(@RequestBody RiskSourceSynBo synBo){
+        ReginParams reginParams = getSelectedOrgInfo();
+        String compCode = getOrgCode(reginParams);
+        return CommonResponseUtil.success(riskSourceService.updateAreaSyn(getUserId(),compCode,synBo));
+    }
 }

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/RiskSourceServiceImpl.java

@@ -1975,5 +1975,25 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
         List<String> ruleId = planDetailMapper.getRuleIdByEquipment(id);
         return ruleId;
     }
+
+    @Override
+    public RiskSource updateAreaSyn(String userId, String orgCode, RiskSourceSynBo synBo) {
+        // 1.根据sourceId查询之前节点，赋值null
+        Optional<RiskSource> op = iRiskSourceDao.findBySourceId(synBo.getId());
+        if (op.isPresent()) {
+            RiskSource riskSource = op.get();
+            riskSource.setSourceId(null);
+            iRiskSourceDao.save(riskSource);
+        }
+
+        // 新增
+        RiskSource  riskSource = new RiskSource();
+        Bean.copyExistPropertis(synBo, riskSource);
+        fillBasicParams(userId, orgCode, synBo.getId(), riskSource);
+        riskSource = iRiskSourceDao.save(riskSource);
+
+        return riskSource;
+    }
+
 }
 

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/intfc/IRiskSourceService.java

@@ -217,4 +217,6 @@ public interface IRiskSourceService {
     ReserveEnum startEquipReserve(Long id, String typeCode);
 
     void processProtalDataFromDanger(DangerResultBo dangerResultBo) throws Exception;
+
+    RiskSource updateAreaSyn(String code, String compCode, RiskSourceSynBo synBo);
 }