设备分享3

fys-admin/src/main/java/com/fuyuanshen/web/controller/device/DeviceShareController.java

@@ -67,7 +67,7 @@ public class DeviceShareController extends BaseController {
     @RepeatSubmit()
     @PostMapping("/permission")
     public R<Void> permission(@Validated(AddGroup.class) @RequestBody AppDeviceShareBo bo) {
-        return toAjax(deviceShareService.deviceShare(bo));
+        return toAjax(deviceShareService.permission(bo));
     }
 
     /**

fys-admin/src/main/java/com/fuyuanshen/web/controller/device/DeviceXinghanController.java

@@ -1,106 +0,0 @@
-package com.fuyuanshen.web.controller.device;
-
-import com.fuyuanshen.app.domain.bo.AppPersonnelInfoBo;
-import com.fuyuanshen.app.domain.dto.AppDeviceLogoUploadDto;
-import com.fuyuanshen.app.domain.dto.DeviceInstructDto;
-import com.fuyuanshen.common.core.domain.R;
-import com.fuyuanshen.common.core.validate.AddGroup;
-import com.fuyuanshen.common.ratelimiter.annotation.FunctionAccessAnnotation;
-import com.fuyuanshen.common.ratelimiter.annotation.FunctionAccessBatcAnnotation;
-import com.fuyuanshen.common.web.core.BaseController;
-import com.fuyuanshen.equipment.domain.dto.AppDeviceSendMsgBo;
-import com.fuyuanshen.web.service.device.DeviceXinghanBizService;
-import lombok.RequiredArgsConstructor;
-import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-
-/**
- * 设备控制类  HBY670
- */
-@Validated
-@RequiredArgsConstructor
-@RestController
-@RequestMapping("/api/xinghan/device")
-public class DeviceXinghanController extends BaseController {
-
-    private final DeviceXinghanBizService deviceXinghanBizService;
-
-    /**
-     * 人员信息登记
-     */
-    @PostMapping(value = "/registerPersonInfo")
-//    @FunctionAccessAnnotation("registerPersonInfo")
-    public R<Void> registerPersonInfo(@Validated(AddGroup.class) @RequestBody AppPersonnelInfoBo bo) {
-        return toAjax(deviceXinghanBizService.registerPersonInfo(bo));
-    }
-
-    /**
-     * 发送紧急通知
-     */
-    @PostMapping(value = "/sendAlarmMessage")
-    @FunctionAccessBatcAnnotation(value = "sendAlarmMessage", timeOut = 5, batchMaxTimeOut = 10)
-    public R<Void> sendAlarmMessage(@RequestBody AppDeviceSendMsgBo bo) {
-        return toAjax(deviceXinghanBizService.sendAlarmMessage(bo));
-    }
-
-    /**
-     * 上传设备logo图片
-     */
-    @PostMapping("/uploadLogo")
-    @FunctionAccessAnnotation("uploadLogo")
-    public R<Void> upload(@Validated @ModelAttribute AppDeviceLogoUploadDto bo) {
-
-        MultipartFile file = bo.getFile();
-        if(file.getSize()>1024*1024*2){
-            return R.warn("图片不能大于2M");
-        }
-        deviceXinghanBizService.uploadDeviceLogo(bo);
-
-        return R.ok();
-    }
-
-    /**
-     * 静电预警档位
-     * 3,2,1,0,分别表示高档/中档/低挡/关闭
-     */
-    @PostMapping("/DetectGradeSettings")
-    public R<Void> DetectGradeSettings(@RequestBody DeviceInstructDto params) {
-        // params 转 JSONObject
-        deviceXinghanBizService.upDetectGradeSettings(params);
-        return R.ok();
-    }
-
-    /**
-     * 照明档位
-     * 照明档位，2,1,0,分别表示弱光/强光/关闭
-     */
-    @PostMapping("/LightGradeSettings")
-    public R<Void> LightGradeSettings(@RequestBody DeviceInstructDto params) {
-        // params 转 JSONObject
-        deviceXinghanBizService.upLightGradeSettings(params);
-        return R.ok();
-    }
-
-    /**
-     * SOS档位
-     * SOS档位，2,1,0, 分别表示红蓝模式/爆闪模式/关闭
-     */
-    @PostMapping("/SOSGradeSettings")
-    public R<Void> SOSGradeSettings(@RequestBody DeviceInstructDto params) {
-        // params 转 JSONObject
-        deviceXinghanBizService.upSOSGradeSettings(params);
-        return R.ok();
-    }
-
-    /**
-     * 静止报警状态
-     * 静止报警状态，0-未静止报警，1-正在静止报警。
-     */
-    @PostMapping("/ShakeBitSettings")
-    public R<Void> ShakeBitSettings(@RequestBody DeviceInstructDto params) {
-        // params 转 JSONObject
-        deviceXinghanBizService.upShakeBitSettings(params);
-        return R.ok();
-    }
-}

fys-admin/src/main/java/com/fuyuanshen/web/controller/device/HomePageController.java

@@ -61,15 +61,13 @@ public class HomePageController {
     /**
      * 获取设备使用数据
      *
-     * @param deviceTypeId 设备ID (可选)
+     * @param deviceId 设备ID
      * @param range    时间范围 1:半年 2:一年
      * @return 每月使用数据列表
      */
-    @GetMapping("/getEquipmentUsageData/{range}")
-    public R<List<Map<String, Object>>> getEquipmentUsageData(@PathVariable Integer range,
-                                                              @RequestParam(required = false) Long deviceTypeId) {
-        return R.ok(deviceService.getEquipmentUsageData(deviceTypeId, range));
+    @GetMapping("/getEquipmentUsageData/{deviceId}/{range}")
+    public R<List<Map<String, Object>>> getEquipmentUsageData(@PathVariable Long deviceId, @PathVariable Integer range) {
+        return R.ok(deviceService.getEquipmentUsageData(deviceId, range));
     }
 
-
 }

fys-admin/src/main/java/com/fuyuanshen/web/service/DeviceShareService.java

@@ -212,6 +212,46 @@ public class DeviceShareService {
         LambdaQueryWrapper<AppDeviceBindRecord> qw = new LambdaQueryWrapper<>();
         qw.eq(AppDeviceBindRecord::getDeviceId, bo.getDeviceId());
         AppDeviceBindRecord bindRecord = appDeviceBindRecordMapper.selectOne(qw);
+        if (bindRecord == null) {
+            throw new ServiceException("设备未绑定");
+        }
+        Long userId = bindRecord.getBindingUserId();
+
+        LambdaQueryWrapper<AppDeviceShare> lqw = new LambdaQueryWrapper<>();
+        lqw.eq(AppDeviceShare::getDeviceId, bo.getDeviceId());
+        lqw.eq(AppDeviceShare::getPhonenumber, bo.getPhonenumber());
+        Long count = appDeviceShareMapper.selectCount(lqw);
+        if (count > 0) {
+
+            UpdateWrapper<AppDeviceShare> uw = new UpdateWrapper<>();
+            uw.eq("device_id", bo.getDeviceId());
+            uw.eq("phonenumber", bo.getPhonenumber());
+            uw.set("permission", bo.getPermission());
+            uw.set("update_by", userId);
+            uw.set("update_time", new Date());
+
+            return appDeviceShareMapper.update(uw);
+        } else {
+            AppDeviceShare appDeviceShare = new AppDeviceShare();
+            appDeviceShare.setDeviceId(bo.getDeviceId());
+            appDeviceShare.setPhonenumber(bo.getPhonenumber());
+            appDeviceShare.setPermission(bo.getPermission());
+            appDeviceShare.setCreateBy(userId);
+            return appDeviceShareMapper.insert(appDeviceShare);
+        }
+    }
+
+    public int permission(AppDeviceShareBo bo) {
+        Device device = deviceMapper.selectById(bo.getDeviceId());
+        if (device == null) {
+            throw new ServiceException("设备不存在");
+        }
+        LambdaQueryWrapper<AppDeviceBindRecord> qw = new LambdaQueryWrapper<>();
+        qw.eq(AppDeviceBindRecord::getDeviceId, bo.getDeviceId());
+        AppDeviceBindRecord bindRecord = appDeviceBindRecordMapper.selectOne(qw);
+        if (bindRecord == null) {
+            throw new ServiceException("设备未绑定");
+        }
         Long userId = bindRecord.getBindingUserId();
 
         LambdaQueryWrapper<AppDeviceShare> lqw = new LambdaQueryWrapper<>();

fys-modules/fys-app/src/main/java/com/fuyuanshen/app/domain/bo/AppDeviceShareBo.java

@@ -60,7 +60,7 @@ public class AppDeviceShareBo extends BaseEntity {
     /**
      * 分享时间
      */
-    private Date shareStartTime;
-    private Date shareEndTime;
+    private String shareStartTime;
+    private String shareEndTime;
 
 }

fys-modules/fys-app/src/main/java/com/fuyuanshen/app/domain/vo/AppDeviceShareVo.java

@@ -109,4 +109,9 @@ public class AppDeviceShareVo implements Serializable {
      * 告警状态(0解除告警，1告警)
      */
     private String alarmStatus;
+
+    /**
+     * 创建时间
+     */
+    private String createTime;
 }

fys-modules/fys-app/src/main/resources/mapper/app/AppDeviceShareMapper.xml

@@ -72,9 +72,12 @@
                 and ad.device_id = #{bo.deviceId}
             </if>
             <if test="bo.shareUser != null">
-                and u.user_name = #{bo.shareUser}
+                and ad.phonenumber like concat('%',#{bo.shareUser},'%')
             </if>
-            <if test="bo.shareStartTime != null and bo.hareEndTime != null">
+            <if test="bo.phonenumber != null">
+                and ad.phonenumber like concat('%',#{bo.phonenumber},'%')
+            </if>
+            <if test="bo.shareStartTime != null and bo.shareEndTime != null">
                 and ad.create_time between #{bo.shareStartTime} and #{bo.shareEndTime}
             </if>
         </where>

fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/vo/AlarmInformationVo.java

@@ -21,18 +21,6 @@ public class AlarmInformationVo {
      */
     private Integer processingAlarm = 0;
 
-
-    /**
-     * 今日报警总数
-     */
-    private Integer alarmsTotalToday = 0;
-
-    /**
-     * 今日总处理报警
-     */
-    private Integer processingAlarmToday = 0;
-
-
     /**
      * 强制报警
      */

fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/vo/EquipmentClassificationVo.java

@@ -26,24 +26,4 @@ public class EquipmentClassificationVo {
      */
     private Integer devices4GAndBluetooth = 0;
 
-    /**
-     * 设备总数
-     */
-    private Integer total;
-
-
-    /**
-     * 计算设备总数
-     *
-     * @return 设备总数
-     */
-    public Integer getTotal() {
-        if (total == null) {
-            total = (equipment4G == null ? 0 : equipment4G) +
-                    (deviceBluetooth == null ? 0 : deviceBluetooth) +
-                    (devices4GAndBluetooth == null ? 0 : devices4GAndBluetooth);
-        }
-        return total;
-    }
-
 }

fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/mapper/DeviceMapper.java

@@ -99,11 +99,11 @@ public interface DeviceMapper extends BaseMapper<Device> {
     /**
      * 获取设备使用数据
      *
-     * @param deviceTypeId 设备ID
+     * @param deviceId 设备ID
      * @param range    时间范围 1:半年 2:一年
      * @return 每月使用数据列表
      */
-    List<Map<String, Object>> getEquipmentUsageData(@Param("deviceTypeId") Long deviceTypeId, @Param("range") Integer range);
+    List<Map<String, Object>> getEquipmentUsageData(Long deviceId, Integer range);
 
     // 在DeviceMapper.java中添加方法
     int getUsageDataForMonth(@Param("deviceId") Long deviceId,

fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/DeviceService.java

@@ -139,9 +139,9 @@ public interface DeviceService extends IService<Device> {
     /**
      * 获取设备使用数据
      *
-     * @param deviceTypeId
+     * @param deviceId
      * @param range
      * @return
      */
-    List<Map<String, Object>> getEquipmentUsageData(Long deviceTypeId, Integer range);
+    List<Map<String, Object>> getEquipmentUsageData(Long deviceId, Integer range);
 }

fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/impl/DeviceServiceImpl.java

@@ -630,7 +630,6 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> impleme
     @Override
     public EquipmentClassificationVo getEquipmentClassification() {
         EquipmentClassificationVo equipmentClassification = deviceMapper.getEquipmentClassification();
-        equipmentClassification.getTotal();
         return equipmentClassification;
     }
 
@@ -649,13 +648,13 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> impleme
     /**
      * 获取设备使用数据
      *
-     * @param deviceTypeId 设备ID
+     * @param deviceId 设备ID
      * @param range    时间范围 1:半年 2:一年
      * @return 每月使用数据列表
      */
     @Override
-    public List<Map<String, Object>> getEquipmentUsageData(Long deviceTypeId, Integer range) {
-        List<Map<String, Object>> equipmentUsageData = deviceMapper.getEquipmentUsageData(deviceTypeId, range);
+    public List<Map<String, Object>> getEquipmentUsageData(Long deviceId, Integer range) {
+        List<Map<String, Object>> equipmentUsageData = deviceMapper.getEquipmentUsageData(deviceId, range);
         return equipmentUsageData;
 
     }

fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml

@@ -321,11 +321,11 @@
     <!-- 获取数据总览 -->
     <select id="getDataOverview" resultType="com.fuyuanshen.equipment.domain.vo.DataOverviewVo">
         SELECT (SELECT COUNT(1) FROM device)                         AS devicesNumber,
-               (SELECT COUNT(1) FROM device WHERE online_status = 1) AS equipmentOnline,
-               (SELECT COUNT(1) FROM device WHERE DATE (create_time) = CURDATE() AND binding_status = 1 ) AS bindingNew, (
+               (SELECT COUNT(1) FROM device WHERE device_status = 1) AS equipmentOnline,
+               (SELECT COUNT(1) FROM device WHERE DATE (create_time) = CURDATE()) AS bindingNew, (
         SELECT COUNT (1)
         FROM device
-        WHERE online_status = 2) AS equipmentAbnormal
+        WHERE device_status = 2) AS equipmentAbnormal
     </select>
 
     <!-- 获取设备分类 -->
@@ -347,67 +347,55 @@
 
     <!-- 获取告警信息 -->
     <select id="getAlarmInformation" resultType="com.fuyuanshen.equipment.domain.vo.AlarmInformationVo">
-        SELECT (SELECT COUNT(1) FROM device_alarm WHERE treatment_state = 0) AS alarmsTotal
-             , (SELECT COUNT(1)
-                FROM device_alarm
-                WHERE treatment_state = 0)                                   AS processingAlarm
-             , (SELECT COUNT(1)
-                FROM device_alarm
-                WHERE treatment_state = 0 AND
-            DATE (create_time) = CURDATE()) AS alarmsTotalToday
-             , (
+        SELECT (SELECT COUNT(1) FROM device_alarm WHERE treatment_state = 0 AND DATE (create_time) = CURDATE()) AS alarmsTotal, (
         SELECT COUNT (1)
         FROM device_alarm
         WHERE treatment_state = 0
-          AND DATE (create_time) = CURDATE()) AS processingAlarmToday
+          AND DATE (create_time) = CURDATE()) AS processingAlarm
             , (
         SELECT COUNT (1)
         FROM device_alarm
         WHERE device_action = 0
-            ) AS alarmForced
+          AND DATE (create_time) = CURDATE()) AS alarmForced
             , (
         SELECT COUNT (1)
         FROM device_alarm
         WHERE device_action = 1
-            ) AS intrusionImpact
+          AND DATE (create_time) = CURDATE()) AS intrusionImpact
             , (
         SELECT COUNT (1)
         FROM device_alarm
         WHERE device_action = 2
-            ) AS alarmManual
+          AND DATE (create_time) = CURDATE()) AS alarmManual
             , (
         SELECT COUNT (1)
         FROM device_alarm
-        WHERE device_action = 3) AS fenceElectronic
+        WHERE device_action = 3 AND DATE (create_time) = CURDATE()) AS fenceElectronic
 
     </select>
 
     <!-- 获取设备使用数据 -->
     <select id="getEquipmentUsageData" resultType="map">
-        SELECT COUNT(CASE WHEN MONTH (dl.create_time) = 1 THEN 1 END) AS m1,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 2 THEN 1 END) AS m2,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 3 THEN 1 END) AS m3,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 4 THEN 1 END) AS m4,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 5 THEN 1 END) AS m5,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 6 THEN 1 END) AS m6,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 7 THEN 1 END) AS m7,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 8 THEN 1 END) AS m8,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 9 THEN 1 END) AS m9,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 10 THEN 1 END) AS m10,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 11 THEN 1 END) AS m11,
-        COUNT(CASE WHEN MONTH (dl.create_time) = 12 THEN 1 END) AS m12
+        SELECT COUNT(CASE WHEN MONTH (dl.create_time) = 1 THEN 1 END)  AS m1,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 2 THEN 1 END)  AS m2,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 3 THEN 1 END)  AS m3,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 4 THEN 1 END)  AS m4,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 5 THEN 1 END)  AS m5,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 6 THEN 1 END)  AS m6,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 7 THEN 1 END)  AS m7,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 8 THEN 1 END)  AS m8,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 9 THEN 1 END)  AS m9,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 10 THEN 1 END) AS m10,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 11 THEN 1 END) AS m11,
+               COUNT(CASE WHEN MONTH (dl.create_time) = 12 THEN 1 END) AS m12
         FROM device_log dl
-        LEFT JOIN device d ON dl.device_id = d.id
-        LEFT JOIN device_type dt ON d.device_type = dt.id
-        <where>
-            <if test="deviceTypeId != null">
-                dt.id = #{deviceTypeId}
-            </if>
-            AND (
+                 LEFT JOIN device d ON dl.device_id = d.id
+                 LEFT JOIN device_type dt ON d.device_type = dt.id
+        WHERE dt.id = #{deviceId}
+          AND (
             (#{range} = 1 AND dl.create_time >= DATE_SUB(NOW(), INTERVAL 6 MONTH)) OR
             (#{range} = 2 AND dl.create_time >= DATE_SUB(NOW(), INTERVAL 12 MONTH))
             )
-        </where>
     </select>
 
     <select id="getUsageDataForMonth" resultType="java.lang.Integer">