解决冲突

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/src/main/java/com/yeejoin/amos/boot/module/ccs/api/dto/FireVideoDto.java

@@ -53,4 +53,11 @@ public class FireVideoDto extends BaseDto {
 
     @ApiModelProperty(value = "纬度")
     private String lat;
+
+    @ApiModelProperty(value = "关联的电力设备mrids")
+    private String relationEquipmentMrids;
+
+    @ApiModelProperty(value = "关联的消防设备mrids")
+    private String relationFireEquipmentMrids;
+
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/src/main/java/com/yeejoin/amos/boot/module/ccs/api/entity/FireVideo.java

@@ -91,4 +91,14 @@ public class FireVideo extends BaseEntity {
      */
     @TableField("lat")
     private String lat;
+
+    /**
+     * 关联的电力设备mrids
+     */
+    private String relationEquipmentMrids;
+    
+    /**
+     * 关联的消防设备mrids
+     */
+    private String relationFireEquipmentMrids;
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/src/main/java/com/yeejoin/amos/boot/module/ccs/api/mapper/FireVideoMapper.java

 package com.yeejoin.amos.boot.module.ccs.api.mapper;
 
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.ccs.api.dto.FireVideoDto;
 import com.yeejoin.amos.boot.module.ccs.api.entity.FireVideo;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 
+import java.util.List;
+
 /**
  * 消防视频表 Mapper 接口
  *
@@ -11,4 +15,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  */
 public interface FireVideoMapper extends BaseMapper<FireVideo> {
 
+    Page<FireVideoDto> listByRelationMrid(Page page, String relationId);
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/src/main/java/com/yeejoin/amos/boot/module/ccs/api/service/IFireVehicleService.java

 package com.yeejoin.amos.boot.module.ccs.api.service;
 
 
+import com.yeejoin.amos.boot.module.ccs.api.dto.FireVehicleDto;
+
+import java.util.List;
+
 /**
  * 消防车辆信息接口类
  *
@@ -9,4 +13,5 @@ package com.yeejoin.amos.boot.module.ccs.api.service;
  */
 public interface IFireVehicleService {
 
+    List<FireVehicleDto> queryForFireVehicleList(String stationCode);
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/src/main/java/com/yeejoin/amos/boot/module/ccs/api/service/IFireVideoService.java

 package com.yeejoin.amos.boot.module.ccs.api.service;
 
 
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.ccs.api.dto.FireVideoDto;
+
+import java.util.List;
+
 /**
  * 消防视频表接口类
  *
@@ -9,4 +14,5 @@ package com.yeejoin.amos.boot.module.ccs.api.service;
  */
 public interface IFireVideoService {
 
+    Page<FireVideoDto> listByRelationMrid(Page page, String relationId);
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/src/main/resources/mapper/FireEquipmentSignalLogMapper.xml

@@ -26,11 +26,13 @@
             a.station_code,
             a.lat as sourceLat,
             a.lng as sourceLng,
+            a.fire_equipment_mrid,
             a.protected_object_mrid,
             a.protected_object_name,
             a.system_names,
             s.station_charge_person,
-            s.charge_person_phone
+            s.charge_person_phone,
+            a.fire_building_mrid
         from
             asf_fire_equipment_signal_log a,
             asf_fire_station_info s

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/src/main/resources/mapper/FireVideoMapper.xml

@@ -2,4 +2,16 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.yeejoin.amos.boot.module.ccs.api.mapper.FireVideoMapper">
 
+    <select id="listByRelationMrid" resultType="com.yeejoin.amos.boot.module.ccs.api.dto.FireVideoDto">
+        SELECT
+            v.id,
+            v.mrid,
+            v.name,
+            v.position,
+            v.play_url
+        FROM `ast_fire_video` v
+        where
+        FIND_IN_SET(#{relationId},v.relation_equipment_mrids) or
+        FIND_IN_SET(#{relationId},v.relation_fire_equipment_mrids)
+    </select>
 </mapper>

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/feign/EquipFeignClient.java

 package com.yeejoin.amos.boot.module.common.api.feign;
 
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-
-import io.swagger.annotations.ApiOperation;
-import org.springframework.cloud.openfeign.FeignClient;
-import org.springframework.web.bind.annotation.*;
-import org.typroject.tyboot.core.restful.utils.ResponseModel;
-
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.module.common.api.dto.EquipmentIndexDto;
 import com.yeejoin.amos.boot.module.common.api.dto.PerfQuotaIotDTO;
 import com.yeejoin.amos.boot.module.common.api.dto.VideoDto;
 import com.yeejoin.amos.component.feign.config.InnerInvokException;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.*;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
 
 /**
  * 装备服务feign
@@ -208,7 +206,7 @@ public interface EquipFeignClient {
 
 
     @RequestMapping(value = "/confirmAlarm/getDetailsById", method = RequestMethod.GET)
-    public Map<String, Object> getDetailsById(@RequestParam Long alamId, @RequestParam Long equipId, @RequestParam String type, @RequestParam String area) ;
+    public ResponseModel<Map<String, Object>>  getDetailsById(@RequestParam Long alamId, @RequestParam(required = false) Long equipId, @RequestParam(required = false) String type, @RequestParam String area) ;
 
 
 

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/api/dto/EquipmentDto.java

@@ -95,4 +95,10 @@ public class EquipmentDto extends BaseDto {
     @ApiModelProperty(value = "设备参数")
     private List<EquipmentIndexDto> equipmentIndex;
 
+    @ApiModelProperty(value = "设备所属单位id")
+    private Long equipUnitId;
+
+    @ApiModelProperty(value = "设备所属单位")
+    private String equipUnit;
+
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/api/entity/Equipment.java

@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.tzs.flc.api.entity;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
+import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
@@ -142,4 +143,16 @@ public class Equipment extends BaseEntity {
 	@TableField("status")
     private String status;
 
+    /**
+     * 设备所属单位id
+     */
+    @TableField("equip_unit_id")
+    private Long equipUnitId;
+
+    /**
+     * 设备所属单位
+     */
+    @TableField("equip_unit")
+    private String equipUnit;
+
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/api/service/IEquipmentService.java

@@ -36,4 +36,6 @@ public interface IEquipmentService {
     List<Object> getEquipmentClass(String typeCode);
 
     EquipmentDto getEquipmentById(Long sequenceNbr);
+
+    Boolean batchDelete(List<Long> sequenceNbrList);
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-ccs-biz/src/main/java/com/yeejoin/amos/boot/module/ccs/biz/controller/FireBuildingController.java

 package com.yeejoin.amos.boot.module.ccs.biz.controller;
 
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.module.ccs.api.dto.FireBuildingDto;
 import com.yeejoin.amos.boot.module.ccs.biz.service.impl.FireBuildingServiceImpl;
+
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
-import org.typroject.tyboot.core.foundation.enumeration.UserType;
-import org.typroject.tyboot.core.restful.doc.TycloudOperation;
-import org.typroject.tyboot.core.restful.utils.ResponseHelper;
-import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 /**
  * 消防建筑表
@@ -71,4 +77,12 @@ public class FireBuildingController extends BaseController {
             @ApiParam(value = "建筑code") @PathVariable String mrid) {
         return ResponseHelper.buildResponse(fireBuildingServiceImpl.getBuildingByMrid(mrid));
     }
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @GetMapping(value = "stationBuildingTree")
+    @ApiOperation(httpMethod = "GET", value = "换流站建筑树", notes = "换流站建筑树")
+    public ResponseModel stationBuildingTree (@ApiParam(value = "换流站code")
+             @RequestParam(value = "stationCode", required = false) String stationCode) {
+        return ResponseHelper.buildResponse(fireBuildingServiceImpl.stationBuildingTree(stationCode));
+    }
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-ccs-biz/src/main/java/com/yeejoin/amos/boot/module/ccs/biz/controller/FireVehicleController.java

@@ -14,6 +14,8 @@ import org.typroject.tyboot.core.restful.doc.TycloudOperation;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
+import java.util.List;
+
 /**
  * 消防车辆信息
  *
@@ -48,4 +50,17 @@ public class FireVehicleController extends BaseController {
         page.setSize(size);
         return ResponseHelper.buildResponse(fireVehicleServiceImpl.queryForFireVehiclePage(page, name, stationCode));
     }
+
+    /**
+     * 消防车辆信息列表
+     *
+     * @return List<FireVehicleDto>
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @GetMapping(value = "/{stationCode}/list")
+    @ApiOperation(httpMethod = "GET", value = "消防车辆信息列表", notes = "消防车辆信息列表")
+    public ResponseModel<List<FireVehicleDto>> queryForList(
+            @ApiParam(value = "换流站code", required = true) @PathVariable String stationCode) {
+        return ResponseHelper.buildResponse(fireVehicleServiceImpl.queryForFireVehicleList(stationCode));
+    }
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-ccs-biz/src/main/java/com/yeejoin/amos/boot/module/ccs/biz/controller/FireVideoController.java

@@ -51,6 +51,7 @@ public class FireVideoController extends BaseController {
             @ApiParam(value = "当前页", required = true) @RequestParam(value = "current") int current,
             @ApiParam(value = "页大小", required = true) @RequestParam(value = "size") int size,
             @ApiParam(value = "换流站code", required = true) @PathVariable String stationCode,
+            @ApiParam(value = "摄像头编码") @RequestParam(value = "videoMrid", required = false) String videoMrid,
             @ApiParam(value = "所在建筑,多个用逗号分隔") @RequestParam(value = "buildingMrids", required = false) String buildingMrids) {
         List<String> buildingMridList = new ArrayList<>();
         //根节点id(全部建筑时使用，本来可以不送来实现过滤，但是地图前端不支持)
@@ -61,7 +62,23 @@ public class FireVideoController extends BaseController {
         Page<FireVideoDto> page = new Page<>();
         page.setCurrent(current);
         page.setSize(size);
-        return ResponseHelper.buildResponse(fireVideoServiceImpl.queryForFireVideoPage(page, name, stationCode, buildingMridList));
+        String code = ("-1").equals(stationCode) ? "" : stationCode;
+        return ResponseHelper.buildResponse(fireVideoServiceImpl.queryForFireVideoPage(page, name, code, buildingMridList, videoMrid));
+    }
+
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(httpMethod = "GET", value = "查询关联的摄像头", notes = "查询关联的摄像头")
+    @GetMapping(value = "/relation-list")
+    public ResponseModel<Page<FireVideoDto>> getVideoByRelationMrids(
+            @ApiParam(value = "当前页", required = true) @RequestParam(value = "current") int current,
+            @ApiParam(value = "页大小", required = true) @RequestParam(value = "size") int size,
+            @ApiParam(value = "关联id,重点设备mrid或者消防装备mrid", required = true) @RequestParam String relationId
+    ) {
+        Page<FireVideoDto> page = new Page<>();
+        page.setCurrent(current);
+        page.setSize(size);
+        return ResponseHelper.buildResponse(fireVideoServiceImpl.listByRelationMrid(page, relationId));
     }
 
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-ccs-biz/src/main/java/com/yeejoin/amos/boot/module/ccs/biz/service/impl/FireBuildingServiceImpl.java

@@ -52,7 +52,31 @@ public class FireBuildingServiceImpl extends BaseService<FireBuildingDto, FireBu
     }
 
     private List<FireBuildingDto> getChildren(String mrid, List<FireBuildingDto> dtoList) {
-        return dtoList.stream().filter(d -> StringUtils.isNotBlank(d.getParentMrid()) && d.getParentMrid().equals(mrid)).peek(s -> s.setChildren(this.getChildren(s.getMrid(), dtoList))).sorted(Comparator.comparing(BaseDto::getCreateDate)).collect(Collectors.toList());
+        return dtoList.stream().filter(d -> StringUtils.isNotBlank(d.getParentMrid()) && d.getParentMrid().equals(mrid)).
+                peek(s -> s.setChildren(this.getChildren(s.getMrid(), dtoList))).
+                sorted(Comparator.comparing(BaseDto::getCreateDate)).collect(Collectors.toList());
+    }
+
+    public List<FireBuildingDto> stationBuildingTree(String stationCode) {
+        List<FireBuildingDto> dtoList = this.queryForList("create_date", true, stationCode);
+        // 根据换流站code分组list
+        Map<String, List<FireBuildingDto>> stationMap = dtoList.stream().collect(Collectors.groupingBy(f  -> f.getStationName()+"_"+f.getStationCode()));
+        return stationMap.keySet().stream().map(key -> {
+            FireBuildingDto parentNode = new FireBuildingDto();
+            String[] temp = key.split("_");
+            String name = temp[0];
+            String code = temp[1];
+            parentNode.setStationCode(code);
+            parentNode.setStationName(name);
+            parentNode.setId(code);
+            parentNode.setType("station");
+            parentNode.setName(name);
+            List<FireBuildingDto> childrenNode = stationMap.get(key).stream().filter(d -> StringUtils.isBlank(d.getParentMrid()) || "0".equals(d.getParentMrid()) || "-1".equals(d.getParentMrid())).
+                    peek(s -> s.setChildren(this.getChildren(s.getMrid(), dtoList))).
+                    sorted(Comparator.comparing(BaseDto::getCreateDate)).collect(Collectors.toList());
+            parentNode.setChildren(childrenNode);
+            return parentNode;
+        }).collect(Collectors.toList());
     }
     
     public Map<String, Object> getBuildingByMrid(String mrid){

amos-boot-module/amos-boot-module-biz/amos-boot-module-ccs-biz/src/main/java/com/yeejoin/amos/boot/module/ccs/biz/service/impl/FireVehicleServiceImpl.java

@@ -10,6 +10,8 @@ import org.typroject.tyboot.core.rdbms.annotation.Condition;
 import org.typroject.tyboot.core.rdbms.annotation.Operator;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
 
+import java.util.List;
+
 /**
  * 消防车辆信息服务实现类
  *
@@ -24,4 +26,9 @@ public class FireVehicleServiceImpl extends BaseService<FireVehicleDto, FireVehi
     public Page<FireVehicleDto> queryForFireVehiclePage(Page<FireVehicleDto> page, @Condition(Operator.like) String name, String stationCode) {
         return this.queryForPage(page, "create_date", false, name, stationCode);
     }
+
+    @Override
+    public List<FireVehicleDto> queryForFireVehicleList(String stationCode) {
+        return this.queryForList("syn_date", false, stationCode);
+    }
 }
\ No newline at end of file

amos-boot-module/amos-boot-module-biz/amos-boot-module-ccs-biz/src/main/java/com/yeejoin/amos/boot/module/ccs/biz/service/impl/FireVideoServiceImpl.java

@@ -23,8 +23,13 @@ public class FireVideoServiceImpl extends BaseService<FireVideoDto, FireVideo, F
     /**
      * 分页查询
      */
-    public Page<FireVideoDto> queryForFireVideoPage(Page<FireVideoDto> page, @Condition(Operator.like) String name, String stationCode, @Condition(Operator.in) List<String> buildingMrid) {
-        return this.queryForPage(page, "create_date", false, name, stationCode, buildingMrid);
+    public Page<FireVideoDto> queryForFireVideoPage(Page<FireVideoDto> page, @Condition(Operator.like) String name, String stationCode, @Condition(Operator.in) List<String> buildingMrid,
+                                                     @Condition(Operator.like) String mrid) {
+        return this.queryForPage(page, "create_date", false, name, stationCode, buildingMrid, mrid);
     }
 
+    @Override
+    public Page<FireVideoDto> listByRelationMrid(Page page, String relationId) {
+        return this.baseMapper.listByRelationMrid(page, relationId);
+    }
 }
\ No newline at end of file

amos-boot-module/amos-boot-module-biz/amos-boot-module-command-biz/src/main/java/com/yeejoin/amos/boot/module/command/biz/controller/CommandController.java

@@ -23,18 +23,7 @@ import com.yeejoin.amos.boot.module.common.api.entity.FireTeam;
 import com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient;
 import com.yeejoin.amos.boot.module.common.api.feign.IotFeignClient;
 import com.yeejoin.amos.boot.module.common.api.feign.VideoFeignClient;
-import com.yeejoin.amos.boot.module.common.api.service.IDutyCarService;
-import com.yeejoin.amos.boot.module.common.api.service.IDutyPersonService;
-import com.yeejoin.amos.boot.module.common.api.service.IFireChemicalService;
-import com.yeejoin.amos.boot.module.common.api.service.IFireExpertsService;
-import com.yeejoin.amos.boot.module.common.api.service.IFireStationService;
-import com.yeejoin.amos.boot.module.common.api.service.IFireTeamService;
-import com.yeejoin.amos.boot.module.common.api.service.IFirefightersService;
-import com.yeejoin.amos.boot.module.common.api.service.IKeySiteService;
-import com.yeejoin.amos.boot.module.common.api.service.ILinkageUnitService;
-import com.yeejoin.amos.boot.module.common.api.service.IOrgUsrService;
-import com.yeejoin.amos.boot.module.common.api.service.ISourceFileService;
-import com.yeejoin.amos.boot.module.common.api.service.IWaterResourceService;
+import com.yeejoin.amos.boot.module.common.api.service.*;
 import com.yeejoin.amos.boot.module.jcs.api.dto.*;
 import com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled;
 import com.yeejoin.amos.boot.module.jcs.api.entity.AlertFormValue;
@@ -48,7 +37,6 @@ import com.yeejoin.amos.boot.module.jcs.api.service.*;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
@@ -67,13 +55,7 @@ import javax.servlet.http.HttpServletResponse;
 import java.io.File;
 import java.io.FileInputStream;
 import java.lang.reflect.Method;
-import java.time.LocalDateTime;
-import java.time.ZoneOffset;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * *指挥资源Api
@@ -369,10 +351,9 @@ public class CommandController extends BaseController {
     @GetMapping(value = "confirmAlarm/getDetailsById")
     @ApiOperation(value = "根据id，type查询确警页面相关数据")
     public ResponseModel<Map<String, Object>> getDetailsById(@RequestParam Long alamId, @RequestParam Long equipId, @RequestParam String type, @RequestParam String area) {
-
-        Map<String, Object> data = equipFeignClient.getDetailsById( alamId,  equipId,   type,   area);
+        ResponseModel<Map<String, Object>> response = equipFeignClient.getDetailsById( alamId,  equipId,   type,   area);
+        Map<String, Object> data = response.getResult();
         List<Map<String, Object>> records = data != null ? (List<Map<String, Object>>)data.get("video") : null;
-
         if (records != null && records.size() > 0) {
             for (Map<String, Object> record : records) {
                 ResponseModel<String> da = videoFeignClient.videoUrlByIndexCode(record.get("code") + "");

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/controller/WechatController.java

@@ -121,6 +121,8 @@ public class WechatController extends BaseController {
 	@Autowired
 	ISourceFileService sourceFileService;
 
+	private Long TOKEN_TIME = 1209600l;
+
 
 	/**
 	 * 获取微信回调信息返回验证是否通过
@@ -331,7 +333,7 @@ public class WechatController extends BaseController {
 		if(loginResult.getStatus() == 200) {
 			HashMap resultMap = (HashMap) loginResult.getResult();
 			dto.setToken(resultMap.get("token").toString());
-			redisUtils.set(model.getPhone() + "_token",  resultMap.get("token").toString(), 25920000l);
+			redisUtils.set(model.getPhone() + "_token",  resultMap.get("token").toString(), TOKEN_TIME);
 		}
 
 		return ResponseHelper.buildResponse(dto);
@@ -349,7 +351,7 @@ public class WechatController extends BaseController {
 		if(loginResult.getStatus() == 200) {
 			HashMap resultMap = (HashMap) loginResult.getResult();
 			token =  resultMap.get("token").toString();
-			redisUtils.set(tel + "_token",   resultMap.get("token").toString(), 25920000l);
+			redisUtils.set(tel + "_token",   resultMap.get("token").toString(), TOKEN_TIME);
 		}
 		return token;
 	}

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/biz/controller/EquipmentController.java

 package com.yeejoin.amos.boot.module.tzs.flc.biz.controller;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
+import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr;
+import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
 import com.yeejoin.amos.boot.module.tzs.biz.utils.BeanDtoVoUtils;
 import com.yeejoin.amos.boot.module.tzs.flc.api.dto.EquipmentDto;
 import com.yeejoin.amos.boot.module.tzs.flc.api.dto.UnitInfoDto;
 import com.yeejoin.amos.boot.module.tzs.flc.api.entity.Equipment;
 import com.yeejoin.amos.boot.module.tzs.flc.api.entity.UnitInfo;
 import com.yeejoin.amos.boot.module.tzs.flc.biz.service.impl.EquipmentServiceImpl;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.CompanyModel;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.apache.commons.lang3.StringUtils;
@@ -49,6 +55,10 @@ public class EquipmentController extends BaseController {
     @Autowired
     EquipmentServiceImpl equipmentServiceImpl;
 
+
+    @Autowired
+    OrgUsrServiceImpl iOrgUsrService;
+
     /**
      * 新增装备信息表
      *
@@ -108,6 +118,18 @@ public class EquipmentController extends BaseController {
         return ResponseHelper.buildResponse(equipmentServiceImpl.deleteById(sequenceNbr));
     }
 
+    /**
+     * 根据sequenceNbr删除
+     *
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @DeleteMapping(value = "/delete_batch")
+    @ApiOperation(httpMethod = "DELETE", value = "批量删除装备信息", notes = "批量删除装备信息")
+    public ResponseModel<Boolean> deleteBySequenceNbr(@RequestParam(value = "sequenceNbrList") List<Long> sequenceNbrList){
+        return ResponseHelper.buildResponse(equipmentServiceImpl.batchDelete(sequenceNbrList));
+    }
+
 
     /**
      * 列表分页查询
@@ -139,6 +161,19 @@ public class EquipmentController extends BaseController {
 
     private QueryWrapper<Equipment> setQueryWrapper(QueryWrapper<Equipment> queryWrapper, EquipmentDto equipmentDto, String sort) {
         queryWrapper.eq("is_delete", false);
+
+        // 获取用户所在单位 保存设备所属单位
+        OrgUsr myUnit = null;
+        AgencyUserModel user = Privilege.agencyUserClient.getme().getResult();
+        List<CompanyModel> companys = user.getCompanys();
+        for(CompanyModel c : companys) {
+            myUnit = iOrgUsrService.getOne(new LambdaQueryWrapper<OrgUsr>().eq(OrgUsr::getIsDelete,false).eq(OrgUsr::getAmosOrgId,c.getSequenceNbr()));
+        }
+        if(myUnit == null) {
+            throw  new BadRequest("该用户非企业人员无法查询企业设备");
+        }
+        queryWrapper.eq("equip_unit_id", myUnit.getSequenceNbr());
+
         if(sort!=null) {  // 排序失效
             String[] date=  sort.split(",");
             if(date[1].equals("ascend")) {

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/biz/controller/UnitPersonController.java

@@ -386,4 +386,45 @@ public class UnitPersonController extends BaseController {
 
 
 
+	/**
+	 * 监管端-根据当前登录人获取企业列表
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/companyTreeSup")
+	@ApiOperation(httpMethod = "GET",value = "监管端-根据当前登录人获取企业列表",  notes = "监管端-根据当前登录人获取企业列表")
+	public ResponseModel<List<CompanyModel>> getUserUnitSup()  throws Exception {
+		AgencyUserModel user = Privilege.agencyUserClient.getme().getResult();
+		List<CompanyModel> companys = user.getCompanys();
+		return ResponseHelper.buildResponse(companys);
+	}
+
+
+
+	/**
+	 * 监管端-角色信息
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/listMyUnitRolesSup")
+	@ApiOperation(httpMethod = "GET",value = "监管端-获取本单位拥有的角色信息",  notes = "监管端-获取本单位拥有的角色信息")
+	public ResponseModel<List<RoleModel>> listMyUnitRolesSup() {
+		FeignClientResult<List<RoleModel>> roleListResult = Privilege.roleClient.queryRoleList(null,null);
+		List<RoleModel> allRoleList = roleListResult.getResult();
+		return ResponseHelper.buildResponse(allRoleList);
+	}
+
+	/**
+	 * 监管端-应用信息
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/listMyUnitAppSup")
+	@ApiOperation(httpMethod = "GET",value = "监管端-获取本单位拥有的应用信息",  notes = "监管端-获取本单位拥有的应用信息")
+	public ResponseModel<List<ApplicationModel>> listMyUnitAppSup() {
+		List<ApplicationModel> allApp = Privilege.applicationClient.queryAgencyApplications().getResult();
+		return ResponseHelper.buildResponse(allApp);
+	}
+
+
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/biz/service/impl/EquipmentServiceImpl.java

@@ -3,7 +3,9 @@ package com.yeejoin.amos.boot.module.tzs.flc.biz.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr;
 import com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient;
+import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
 import com.yeejoin.amos.boot.module.common.biz.service.impl.SourceFileServiceImpl;
 import com.yeejoin.amos.boot.module.tzs.flc.api.dto.EquipmentDto;
 import com.yeejoin.amos.boot.module.tzs.flc.api.dto.EquipmentIndexDto;
@@ -12,12 +14,17 @@ import com.yeejoin.amos.boot.module.tzs.flc.api.entity.EquipmentIndex;
 import com.yeejoin.amos.boot.module.tzs.flc.api.enums.EquipmentStatusEnum;
 import com.yeejoin.amos.boot.module.tzs.flc.api.mapper.EquipmentMapper;
 import com.yeejoin.amos.boot.module.tzs.flc.api.service.IEquipmentService;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.CompanyModel;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.typroject.tyboot.core.foundation.utils.Bean;
 import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
+import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -42,6 +49,9 @@ public class EquipmentServiceImpl extends BaseService<EquipmentDto, Equipment, E
     @Autowired
     EquipmentIndexServiceImpl equipmentIndexServiceImpl;
 
+    @Autowired
+    OrgUsrServiceImpl iOrgUsrService;
+
 
     /**
      * 分页查询
@@ -60,9 +70,23 @@ public class EquipmentServiceImpl extends BaseService<EquipmentDto, Equipment, E
     @Override
     public EquipmentDto createEquipment(EquipmentDto model) {
         model.setStatus(EquipmentStatusEnum.未安装.getCode()); // 0 未安装 1 已安装
+        // 获取用户所在单位 保存设备所属单位
+        OrgUsr myUnit = null;
+        AgencyUserModel user = Privilege.agencyUserClient.getme().getResult();
+        List<CompanyModel> companys = user.getCompanys();
+        for(CompanyModel c : companys) {
+            myUnit = iOrgUsrService.getOne(new LambdaQueryWrapper<OrgUsr>().eq(OrgUsr::getIsDelete,false).eq(OrgUsr::getAmosOrgId,c.getSequenceNbr()));
+        }
+        if(myUnit == null) {
+            throw  new BadRequest("该用户非企业人员无法添加设备");
+        }
+        model.setEquipUnitId(myUnit.getSequenceNbr());
+        model.setEquipUnit(myUnit.getBizOrgName());
         model = this.createWithModel(model);
         // 保存设备参数信息
         List<EquipmentIndexDto> equipmentIndex = model.getEquipmentIndex();
+
+
         if(equipmentIndex != null && equipmentIndex.size()>0) {
             for(EquipmentIndexDto t : equipmentIndex) {
                 t.setEquipmentId(model.getSequenceNbr());
@@ -137,6 +161,20 @@ public class EquipmentServiceImpl extends BaseService<EquipmentDto, Equipment, E
         return result;
     }
 
+    @Transactional
+    @Override
+    public Boolean batchDelete(List<Long> sequenceNbrList) {
+        for(Long sequenceNbr : sequenceNbrList) {
+            EquipmentDto equipmentDto = this.queryBySeq(sequenceNbr);
+            // 未安装设备可删除
+            if (!ValidationUtil.isEmpty(equipmentDto) && EquipmentStatusEnum.未安装.getCode().equals(equipmentDto.getStatus())) {
+                equipmentDto.setIsDelete(true);
+                this.updateWithModel(equipmentDto);
+            }
+        }
+        return true;
+    }
+
     // 保存附件信息
     public void saveSourceFile(EquipmentDto model) {
         if (model.getAttachments() != null) {

amos-boot-system-tzs/src/main/resources/db/changelog/tzs-1.0.0.0.xml

@@ -467,6 +467,18 @@
 		</sql>
 	</changeSet>
 
+	<changeSet author="kongfm" id="2021-12-07-01">
+		<preConditions onFail="MARK_RAN">
+			<tableExists tableName="tcb_equipment"/>
+		</preConditions>
+		<comment>modify table tcb_equipment add equip_unit, equip_unit_id columns</comment>
+		<sql>
+			ALTER TABLE `tcb_equipment` add equip_unit_id bigint(32) COMMENT '设备所属单位id';
+			ALTER TABLE `tcb_equipment` add equip_unit varchar(104) COMMENT '设备所属单位';
+		</sql>
+	</changeSet>
+
+
 
- </databaseChangeLog>
+</databaseChangeLog>