feat: 增加旧版EquipController相关接口

src/main/java/com/xydl/cac/old/AjaxResult.java

@@ -0,0 +1,145 @@
+package com.xydl.cac.old;
+
+
+
+import java.util.HashMap;
+
+/**
+ * @ClassName：AjaxResult
+ * @Description： Ajax操作返回
+ * @Author： Arno_Fu
+ * @CreatTime：11/26/2019 - 12:51 PM
+ * @Version V1.0
+ */
+public class AjaxResult extends HashMap<String, Object> {
+
+    /**
+     * 状态码
+     */
+    public static final String CODE_TAG = "code";
+
+    /**
+     * 返回内容
+     */
+    public static final String MSG_TAG = "msg";
+
+    /**
+     * 数据对象
+     */
+    public static final String DATA_TAG = "data";
+
+    /**
+     * 初始化一个新创建的 AjaxResult 对象，使其表示一个空消息。
+     */
+    public AjaxResult() {
+
+    }
+
+    /**
+     * 初始化一个新创建的 AjaxResult 对象
+     *
+     * @param code 状态码
+     * @param msg  返回内容
+     */
+    public AjaxResult(int code, String msg) {
+        super.put(CODE_TAG, code);
+        super.put(MSG_TAG, msg);
+    }
+
+    /**
+     * 初始化一个新创建的 AjaxResult 对象
+     *
+     * @param code 状态码
+     * @param msg  返回内容
+     * @param data 数据对象
+     */
+    public AjaxResult(int code, String msg, Object data) {
+        super.put(CODE_TAG, code);
+        super.put(MSG_TAG, msg);
+        if (data != null) {
+            super.put(DATA_TAG, data);
+        }
+    }
+
+
+    /**
+     * 返回成功消息
+     *
+     * @return 成功消息
+     */
+    public static AjaxResult success() {
+        return AjaxResult.success("操作成功");
+    }
+
+    /**
+     * 返回成功数据
+     *
+     * @return 成功消息
+     */
+    public static AjaxResult success(Object data) {
+        return AjaxResult.success("操作成功", data);
+    }
+
+    /**
+     * 返回成功消息
+     *
+     * @param msg 返回内容
+     * @return 成功消息
+     */
+    public static AjaxResult success(String msg) {
+        return AjaxResult.success(msg, null);
+    }
+
+    /**
+     * 返回成功消息
+     *
+     * @param msg  返回内容
+     * @param data 数据对象
+     * @return 成功消息
+     */
+    public static AjaxResult success(String msg, Object data) {
+        return new AjaxResult(HttpStatusCode.SUCCESS, msg, data);
+    }
+
+
+    /**
+     * 返回错误消息
+     *
+     * @return
+     */
+    public static AjaxResult error() {
+        return AjaxResult.error("操作失败");
+    }
+
+    /**
+     * 返回错误消息
+     *
+     * @param msg 返回内容
+     * @return 警告消息
+     */
+    public static AjaxResult error(String msg) {
+        return AjaxResult.error(msg, null);
+    }
+
+    /**
+     * 返回错误消息
+     *
+     * @param msg  返回内容
+     * @param data 数据对象
+     * @return 警告消息
+     */
+    public static AjaxResult error(String msg, Object data) {
+        return new AjaxResult(HttpStatusCode.ERROR, msg, data);
+    }
+
+    /**
+     * 返回错误消息
+     *
+     * @param code 状态码
+     * @param msg  返回内容
+     * @return 警告消息
+     */
+    public static AjaxResult error(int code, String msg) {
+        return new AjaxResult(code, msg, null);
+    }
+}

src/main/java/com/xydl/cac/old/BaseEqmDevice.java

@@ -0,0 +1,24 @@
+package com.xydl.cac.old;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class BaseEqmDevice implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * eqmid
+     */
+    @ApiModelProperty(value="设备id", name="id")
+    private String id;
+
+    /**
+     * name
+     */
+    @ApiModelProperty(value="设备名称", name="name")
+    private String name;
+}

src/main/java/com/xydl/cac/old/BaseLxDevice.java

@@ -0,0 +1,30 @@
+package com.xydl.cac.old;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class BaseLxDevice implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * lxid
+     */
+    @ApiModelProperty(value="设备类型id", name="lxid")
+    private String lxid;
+
+    /**
+     * lmc
+     */
+    @ApiModelProperty(value="设备类型名称", name="lmc")
+    private String lmc;
+
+    /**
+     * zmc
+     */
+    @ApiModelProperty(value="设备类型名称", name="lmc")
+    private String zmc;
+}

src/main/java/com/xydl/cac/old/Equipment.java

@@ -0,0 +1,51 @@
+package com.xydl.cac.old;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+public class Equipment {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 变压器个数
+     */
+    @ApiModelProperty(value = "变压器个数", name = "byqNum")
+    private long byqNum;
+
+    /**
+     * GIS个数
+     */
+    @ApiModelProperty(value = "GIS个数", name = "gisNum")
+    private long gisNum;
+
+    /**
+     * 避雷器个数
+     */
+    @ApiModelProperty(value = "避雷器个数", name = "blqNum")
+    private long blqNum;
+
+    /**
+     * 电缆个数
+     */
+    @ApiModelProperty(value = "电缆个数", name = "dlNum")
+    private long dlNum;
+
+    /**
+     * 测温个数
+     */
+    @ApiModelProperty(value = "测温个数", name = "cwNum")
+    private long cwNum;
+
+    /**
+     * 其他个数
+     */
+    @ApiModelProperty(value = "其他个数", name = "otherNum")
+    private long otherNum;
+
+    /**
+     * 总数
+     */
+    @ApiModelProperty(value = "总数", name = "totalNum")
+    private long totalNum;
+}

src/main/java/com/xydl/cac/old/EquipmentController.java

@@ -0,0 +1,119 @@
+package com.xydl.cac.old;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+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.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Api(tags = "旧接口")
+@RestController
+@RequestMapping("EquipController")
+public class EquipmentController {
+
+    @Resource
+    OldService service;
+
+    /**
+     * 获取设备数量
+     *
+     * @return
+     */
+    @ApiOperation(value = "获取设备数量数据")
+    @GetMapping(value = "/queryEquipNum")
+    public AjaxResult queryEquipNum() {
+        Equipment equipment = service.queryEquipNum();
+        return AjaxResult.success(equipment);
+    }
+
+//    /**
+//     * 获取微气象数据（默认取主变1）
+//     */
+//    @ApiOperation(value = "获取微气象数据")
+//    @GetMapping(value = "/queryMicroclimate")
+//    public AjaxResult queryMicroclimate() {
+//        // 取主变1的微气象设备id
+//        Integer eqmid = 186;
+//        MicroclimateVo microclimateVo = cableCirculationMapper.getMicroclimate(eqmid);
+//        return AjaxResult.success(microclimateVo);
+//    }
+//
+//    /**
+//     * return:
+//     * {
+//     * "变压器": 1,
+//     * "GIS": 2,
+//     * "避雷器": 3,
+//     * "开关柜": 4,
+//     * "电缆": 5,
+//     * "发电机": 6
+//     * }
+//     */
+//    @ApiOperation(value = "获取变电设备类型")
+//    @GetMapping(value = "/queryJg")
+//    public AjaxResult queryJgEqm() {
+//        List<BaseDevice> jgDevices = cableCirculationMapper.getJgDevice(1);
+//        Map<String, String> jgMap = new HashMap<>();
+//        for (BaseDevice device : jgDevices) {
+//            jgMap.put(device.getMc(), device.getId());
+//        }
+//        return AjaxResult.success(jgMap);
+//    }
+
+    /**
+     * 获取设备小类类型
+     */
+    @ApiOperation(value = "获取设备小类类型")
+    @GetMapping(value = "/getLxType/{jgid}")
+    public AjaxResult getLxType(@PathVariable @ApiParam(value = "变电设备id") Integer jgid) throws Exception {
+        List<BaseLxDevice> lxDevices = service.getLxDevice(jgid);
+        return AjaxResult.success(lxDevices);
+    }
+
+    //
+//    /**
+//     * 获取设备小类类型
+//     */
+//    @ApiOperation(value = "获取监测设备类型")
+//    @GetMapping(value = "/getEqType/{jgid}/{lxid}")
+//    public AjaxResult geteqType(@PathVariable @ApiParam(value = "变电设备id") Integer jgid, @PathVariable @ApiParam(value = "监测设备类型id") Integer lxid) {
+//        List<BaseEqmDevice> eqTypes = equipmentMapper.getEqType(jgid,lxid);
+//        return AjaxResult.success(eqTypes);
+//    }
+
+    /**
+     * return
+     * {
+     * "lxid": "1",
+     * "lmc": "1#主变"
+     * },
+     * {
+     * "lxid": "2",
+     * "lmc": "2#主变"
+     * }
+     */
+    @ApiOperation(value = "获取设备类型(lxid)")
+    @GetMapping(value = "/queryLx/{jgid}/{mtid}")
+    public AjaxResult queryLxEqm(@PathVariable @ApiParam(value = "间隔id") Integer jgid, @PathVariable @ApiParam(value = "监测设备类型id") List<String> mtid) throws Exception {
+        List<BaseLxDevice> lxDevices = service.getLxDevice(jgid, mtid);
+        return AjaxResult.success(lxDevices);
+    }
+
+    /**
+     * {
+     * "id": "1",  -》eqmid(传给图表数据接口，用于获取监测设备的图表数据)
+     * "name": "铁芯"
+     * }
+     */
+    @ApiOperation(value = "获取设备id(eqmid)")
+    @GetMapping(value = "/queryEqmId/{jgid}/{lxid}/{mtid}")
+    public AjaxResult queryEqmId(@PathVariable @ApiParam(value = "间隔id") Integer jgid, @PathVariable @ApiParam(value = "设备类型id") Integer lxid, @PathVariable @ApiParam(value = "监测设备类型id") List<String> mtid) throws Exception {
+        List<BaseEqmDevice> eqmDevice = service.getEqmDevice(jgid, lxid, mtid);
+        return AjaxResult.success(eqmDevice);
+    }
+}

src/main/java/com/xydl/cac/old/HttpStatusCode.java

@@ -0,0 +1,106 @@
+package com.xydl.cac.old;
+
+
+/**
+ *
+ * @Description: 返回状态码
+ *
+ * @Author: Arno_Fu
+ *
+ * @Since:  11/26/2019 11:21 AM
+ *
+ * @Version: 1.0.0
+
+ **/
+public interface HttpStatusCode
+{
+    /**
+     * 操作成功
+     */
+    public static final int SUCCESS = 200;
+
+    /**
+     * 对象创建成功
+     */
+    public static final int CREATED = 201;
+
+    /**
+     * 请求已经被接受
+     */
+    public static final int ACCEPTED = 202;
+
+    /**
+     * 操作已经执行成功，但是没有返回数据
+     */
+    public static final int NO_CONTENT = 204;
+
+    /**
+     * 资源已被移除
+     */
+    public static final int MOVED_PERM = 301;
+
+    /**
+     * 重定向
+     */
+    public static final int SEE_OTHER = 303;
+
+    /**
+     * 资源没有被修改
+     */
+    public static final int NOT_MODIFIED = 304;
+
+    /**
+     * 参数列表错误（缺少，格式不匹配）
+     */
+    public static final int BAD_REQUEST = 400;
+
+    /**
+     * 未授权
+     */
+    public static final int UNAUTHORIZED = 401;
+
+    /**
+     * 访问受限，授权过期
+     */
+    public static final int FORBIDDEN = 403;
+
+    /**
+     * 资源，服务未找到
+     */
+    public static final int NOT_FOUND = 404;
+
+    /**
+     * 不允许的http方法
+     */
+    public static final int BAD_METHOD = 405;
+
+    /**
+     * 资源冲突，或者资源被锁
+     */
+    public static final int CONFLICT = 409;
+
+    /**
+     * 不支持的数据，媒体类型
+     */
+    public static final int UNSUPPORTED_TYPE = 415;
+
+    /**
+     * 系统内部错误
+     */
+    public static final int ERROR = 500;
+
+    /**
+     * 接口未实现
+     */
+    public static final int NOT_IMPLEMENTED = 501;
+
+    /**
+     * token无效
+     */
+    public static final int TOKEN_INVALID= 601;
+
+    /**
+     * 暂无数据
+     */
+    public static final int NO_DATA = 10000;
+}

src/main/java/com/xydl/cac/old/OldService.java

@@ -0,0 +1,133 @@
+package com.xydl.cac.old;
+
+import com.xydl.cac.entity.NSensor;
+import com.xydl.cac.entity.Zsb;
+import com.xydl.cac.repository.NSensorRepository;
+import com.xydl.cac.repository.ZsbRepository;
+import com.xydl.cac.service.ZsbService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+@Service
+@Slf4j
+@Transactional(rollbackFor = Exception.class)
+public class OldService {
+
+    @Resource
+    ZsbService zsbService;
+    @Resource
+    ZsbRepository zsbRepository;
+    @Resource
+    NSensorRepository sensorRepository;
+
+    public List<BaseLxDevice> getLxDevice(Integer jgid, List<String> mtid) throws Exception {
+        List<BaseLxDevice> result = new ArrayList<>();
+        HashMap<Integer, String> doneMap = new HashMap<>();
+        List<Zsb> zsbList = zsbService.listAll(jgid);
+        for (Zsb zsb : zsbList) {
+            List<NSensor> sensorList = sensorRepository.findByZsbId(zsb.getId());
+            for (NSensor sensor : sensorList) {
+                String typeid = String.valueOf(sensor.getTypeId());
+                if (mtid.contains(typeid)) {
+                    if (!doneMap.containsKey(zsb.getLxid())) {
+                        BaseLxDevice item = new BaseLxDevice();
+                        item.setLxid(String.valueOf(zsb.getLxid()));
+                        item.setLmc(zsb.getLxName());
+                        result.add(item);
+                        doneMap.put(zsb.getLxid(), "done");
+                    }
+
+                }
+            }
+        }
+        return result;
+    }
+
+    public List<BaseLxDevice> getLxDevice(Integer jgid) throws Exception {
+        List<BaseLxDevice> result = new ArrayList<>();
+        HashMap<Integer, String> doneMap = new HashMap<>();
+        List<Zsb> zsbList = zsbService.listAll(jgid);
+        for (Zsb zsb : zsbList) {
+            if (!doneMap.containsKey(zsb.getLxid())) {
+                BaseLxDevice item = new BaseLxDevice();
+                item.setLxid(String.valueOf(zsb.getLxid()));
+                item.setLmc(zsb.getLxName());
+                result.add(item);
+                doneMap.put(zsb.getLxid(), "done");
+            }
+        }
+        return result;
+    }
+
+    public List<BaseEqmDevice> getEqmDevice(Integer jgid, Integer lxid, List<String> mtids) throws Exception {
+        List<BaseEqmDevice> result = new ArrayList<>();
+        HashMap<Integer, String> doneMap = new HashMap<>();
+        List<Zsb> zsbList = zsbRepository.findByJgidAndLxid(jgid, lxid);
+        for (Zsb zsb : zsbList) {
+            List<NSensor> sensorList = sensorRepository.findByZsbId(zsb.getId());
+            for (NSensor sensor : sensorList) {
+                String typeid = String.valueOf(sensor.getTypeId());
+                if (mtids.contains(typeid)) {
+                    if (!doneMap.containsKey(sensor.getDevId())) {
+                        BaseEqmDevice item = new BaseEqmDevice();
+                        item.setId(String.valueOf(sensor.getDevId()));
+                        item.setName(sensor.getName());
+                        result.add(item);
+                        doneMap.put(sensor.getDevId(), "done");
+                    }
+                }
+            }
+        }
+        return result;
+    }
+
+    public Equipment queryEquipNum() {
+        Equipment equipment = new Equipment();
+        long totalNum = sensorRepository.count();
+        List<Zsb> zsbList = zsbRepository.findByJgid(1);
+        List<Integer> idList = new ArrayList<>();
+        for (Zsb zsb : zsbList) {
+            idList.add(zsb.getId());
+        }
+        long byqNum = sensorRepository.countByZsbIdIn(idList);
+        zsbList = zsbRepository.findByJgid(2);
+        idList.clear();
+        for (Zsb zsb : zsbList) {
+            idList.add(zsb.getId());
+        }
+        long gisNum = sensorRepository.countByZsbIdIn(idList);
+        zsbList = zsbRepository.findByJgid(3);
+        idList.clear();
+        for (Zsb zsb : zsbList) {
+            idList.add(zsb.getId());
+        }
+        long blqNum = sensorRepository.countByZsbIdIn(idList);
+        zsbList = zsbRepository.findByJgid(5);
+        idList.clear();
+        for (Zsb zsb : zsbList) {
+            idList.add(zsb.getId());
+        }
+        long dlNum = sensorRepository.countByZsbIdIn(idList);
+        zsbList = zsbRepository.findByJgid(4);
+        idList.clear();
+        for (Zsb zsb : zsbList) {
+            idList.add(zsb.getId());
+        }
+        long cwNum = sensorRepository.countByZsbIdIn(idList);
+        long otherNum = totalNum - byqNum - gisNum - blqNum - dlNum - cwNum;
+        equipment.setTotalNum(totalNum);
+        equipment.setByqNum(byqNum);
+        equipment.setGisNum(gisNum);
+        equipment.setBlqNum(blqNum);
+        equipment.setDlNum(dlNum);
+        equipment.setCwNum(cwNum);
+        equipment.setOtherNum(otherNum);
+        return equipment;
+    }
+}

src/main/java/com/xydl/cac/repository/NSensorRepository.java

@@ -22,4 +22,6 @@ public interface NSensorRepository extends JpaRepository<NSensor, Integer>, JpaS
     List<NSensor> findByTypeId(Integer typeId);
 
     List<NSensor> findByDevId(Integer devId);
+
+    long countByZsbIdIn(List<Integer> list);
 }

src/main/java/com/xydl/cac/repository/ZsbRepository.java

@@ -16,4 +16,6 @@ public interface ZsbRepository extends JpaRepository<Zsb, Integer>, JpaSpecifica
     List<Zsb> findByJgidAndMc(Integer jgid, String mc);
 
     List<Zsb> findByJgidAndMcAndIdIsNot(Integer jgid, String mc, Integer id);
+
+    List<Zsb> findByJgidAndLxid(Integer jgid, Integer lxid);
 }