2023-05-22 15:34:46 完成设备管理的绑定用户接口!

psdc-business/src/main/java/com/psdc/entity/request/UpDevUserRequest.java

@@ -0,0 +1,33 @@
+package com.psdc.entity.request;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @Author：戴仕崑
+ * @Project：psdc
+ * @Date：2022/11/30 17:22
+ * @Version 1.0
+ */
+@Data
+@Component
+@NoArgsConstructor
+@AllArgsConstructor
+public class UpDevUserRequest {
+
+    /**
+     * 设备ID
+     */
+    private List<Integer> deviceIds;
+
+    /**
+     * 所属用户Id
+     */
+    private Long userId;
+
+
+}

psdc-business/src/main/java/com/psdc/mapper/PsdcDeviceMapper.java

@@ -32,6 +32,15 @@ public interface PsdcDeviceMapper{
     List<Integer> selMyWorkDevices(@Param(value = "devType") Integer devType,
                                    @Param(value = "userId") Long userId);
 
+     /**
+      * 设备绑定用户
+      * @param userId
+      * @param devId
+      * @return
+      */
+    Integer upDevStaUser(@Param(value = "userId") Long userId,
+                         @Param(value = "devId") Integer devId);
+
 
     /**
      * 分页查询指定行数据

psdc-business/src/main/java/com/psdc/service/IPsdcDeviceService.java

@@ -33,6 +33,7 @@ public interface IPsdcDeviceService {
 
     DeviceStatusVo queryDeviceStatusById(Integer deviceId);
 
+    Boolean upDevUser(Long userId, List<Integer> devList);
 
     /**
      * 新增数据

psdc-business/src/main/java/com/psdc/service/impl/PsdcDeviceServiceImpl.java

@@ -83,6 +83,20 @@ public class PsdcDeviceServiceImpl implements IPsdcDeviceService {
         return psdcDeviceMapper.queryDeviceStatusById(deviceId);
     }
 
+    @Override
+    public Boolean upDevUser(Long userId, List<Integer> devList) {
+        int up = 0;
+        for (Integer dev : devList){
+            int devUser = psdcDeviceMapper.upDevStaUser(userId, dev);
+            up = up + devUser;
+        }
+        if (up > 0){
+            return true;
+        } else {
+            return false;
+        }
+    }
+
     /**
      * 新增数据
      *

psdc-business/src/main/resources/mapper/business/PsdcDeviceMapper.xml

@@ -319,6 +319,10 @@
         update psdc_device set device_runstatus = #{runStatus} where device_id = #{deviceId}
     </update>
 
+    <update id="upDevStaUser">
+        Update psdc_device Set user_id = #{userId} Where device_id = ${devId}
+    </update>
+
     <!--    根据设备id查询设备名称-->
     <select id="queryDeviceNameByDeviceId" resultType="string">
         select device_name from psdc_device where device_id = #{deviceId}

psdc-web/src/main/java/com/psdc/controller/manager/PsdcDeviceController.java

@@ -8,14 +8,13 @@ import com.psdc.core.domain.AjaxResult;
 import com.psdc.core.domain.entity.SysUser;
 import com.psdc.core.page.TableDataInfo;
 import com.psdc.entity.PsdcDevice;
+import com.psdc.entity.request.UpDevUserRequest;
 import com.psdc.entity.res.PsdcDeviceInfoRes;
 import com.psdc.enums.BusinessType;
 import com.psdc.service.IPsdcDeviceService;
 import com.psdc.service.ISysUserService;
 import com.psdc.utils.SecurityUtils;
 import com.psdc.utils.poi.ExcelUtil;
-import org.apache.poi.xssf.usermodel.XSSFRow;
-import org.apache.poi.xssf.usermodel.XSSFSheet;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -169,4 +168,10 @@ public class PsdcDeviceController extends BaseController {
         return toAjax(psdcDeviceService.daoruDevicesData(file, cjr));
     }
 
+    @RequestMapping(value = "/upDevUser", method = RequestMethod.POST)
+    @PreAuthorize("@ss.hasPermi('system:device:list')")
+    public AjaxResult upDevStaUser(@RequestBody UpDevUserRequest query){
+        return toAjax(psdcDeviceService.upDevUser(query.getUserId(), query.getDeviceIds()));
+    }
+
 }