设备管理

huimv-farm-environ/src/main/java/com/huimv/environ/eco/controller/EcoDeviceController.java

@@ -1,10 +1,18 @@
 package com.huimv.environ.eco.controller;
 
 
+import com.huimv.common.utils.Result;
+import com.huimv.environ.eco.entity.EcoDevice;
+import com.huimv.environ.eco.service.EcoDeviceService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.Map;
+
 /**
  * <p>
  *  前端控制器
@@ -16,6 +24,26 @@ import org.springframework.web.bind.annotation.RestController;
 @RestController
 @RequestMapping("/ecoDevice")
 public class EcoDeviceController {
+    @Autowired
+    private EcoDeviceService ecoDeviceService;
+    @PostMapping("/add")
+    public Result add(@RequestBody EcoDevice ecoDevice) {
+        return ecoDeviceService.add(ecoDevice);
+    }
+
+    @PostMapping("/edit")
+    public Result edit(@RequestBody EcoDevice ecoDevice) {
+        return ecoDeviceService.edit(ecoDevice);
+    }
+
+    @PostMapping("/remove")
+    public Result remove(@RequestBody Map<String,String> paramsMap) {
+        return ecoDeviceService.remove(paramsMap);
+    }
 
+    @PostMapping("/list")
+    public Result list(@RequestBody Map<String,String> paramsMap) {
+        return ecoDeviceService.list(paramsMap);
+    }
 }
 

huimv-farm-environ/src/main/java/com/huimv/environ/eco/entity/EcoDevice.java

@@ -30,5 +30,7 @@ public class EcoDevice implements Serializable {
 
     private String unitId;
 
+    private Integer farmId;
+
 
 }

huimv-farm-environ/src/main/java/com/huimv/environ/eco/service/EcoDeviceService.java

@@ -1,8 +1,11 @@
 package com.huimv.environ.eco.service;
 
+import com.huimv.common.utils.Result;
 import com.huimv.environ.eco.entity.EcoDevice;
 import com.baomidou.mybatisplus.extension.service.IService;
 
+import java.util.Map;
+
 /**
  * <p>
  *  服务类
@@ -12,5 +15,11 @@ import com.baomidou.mybatisplus.extension.service.IService;
  * @since 2022-11-09
  */
 public interface EcoDeviceService extends IService<EcoDevice> {
+    Result add(EcoDevice ecoDevice);
+
+    Result edit(EcoDevice ecoDevice);
+
+    Result remove(Map<String,String> paramsMap);
 
+    Result list(Map<String,String> paramsMap);
 }

huimv-farm-environ/src/main/java/com/huimv/environ/eco/service/impl/EcoDeviceServiceImpl.java

@@ -1,11 +1,22 @@
 package com.huimv.environ.eco.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.huimv.common.utils.Result;
+import com.huimv.common.utils.ResultCode;
 import com.huimv.environ.eco.entity.EcoDevice;
 import com.huimv.environ.eco.mapper.EcoDeviceMapper;
 import com.huimv.environ.eco.service.EcoDeviceService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.PrimitiveIterator;
+
 /**
  * <p>
  *  服务实现类
@@ -17,4 +28,118 @@ import org.springframework.stereotype.Service;
 @Service
 public class EcoDeviceServiceImpl extends ServiceImpl<EcoDeviceMapper, EcoDevice> implements EcoDeviceService {
 
+    @Autowired
+    private EcoDeviceMapper ecoDeviceMapper;
+    @Autowired
+    private static final String globalFarmCode = "330211";
+    @Override
+    public Result add(EcoDevice ecoDevice) {
+        Integer code = DeviceType.SUPERVISE.code;
+        Integer code1 = DeviceType.DRYING.code;
+        Integer farmId = ecoDevice.getFarmId();
+        if (farmId==null) {
+            farmId = Integer.parseInt(globalFarmCode);
+        }
+        EcoDevice device = new EcoDevice();
+
+        device.setFarmId(farmId);
+        device.setDeviceCode(ecoDevice.getDeviceCode());
+        device.setUnitId(ecoDevice.getUnitId());
+        if (ecoDevice.getDeviceType().equals(code)) {
+            device.setDeviceType(code);
+        }
+        if (ecoDevice.getDeviceType().equals(code1)) {
+            device.setDeviceType(code1);
+        }
+        ecoDeviceMapper.insert(device);
+        return new Result(ResultCode.SUCCESS,"添加成功");
+    }
+
+    @Override
+    public Result edit(EcoDevice ecoDevice) {
+        QueryWrapper<EcoDevice> wrapper = new QueryWrapper<>();
+        String deviceCode = ecoDevice.getDeviceCode();
+        wrapper.eq(StringUtils.isNotBlank(deviceCode),"device_code",deviceCode);
+        EcoDevice ecoDevice1 = ecoDeviceMapper.selectOne(wrapper);
+        if (ecoDevice1==null) {
+            EcoDevice ecoDevice2 = new EcoDevice();
+            ecoDevice2.setFarmId(Integer.parseInt(globalFarmCode));
+            ecoDevice2.setDeviceCode(ecoDevice.getDeviceCode());
+            ecoDevice2.setDeviceType(ecoDevice.getDeviceType());
+            ecoDevice2.setUnitId(ecoDevice.getUnitId());
+            baseMapper.insert(ecoDevice2);
+        } else {
+            ecoDevice1.setFarmId(Integer.parseInt(globalFarmCode));
+            ecoDevice1.setDeviceCode(ecoDevice.getDeviceCode());
+            ecoDevice1.setDeviceType(ecoDevice.getDeviceType());
+            ecoDevice1.setUnitId(ecoDevice.getUnitId());
+            baseMapper.updateById(ecoDevice1);
+        }
+        return new Result(ResultCode.SUCCESS,"编辑成功");
+    }
+
+    @Override
+    public Result remove(Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        String[] split = ids.split(",");
+        List<String> list = Arrays.asList(split);
+
+        return new Result(ResultCode.SUCCESS,ecoDeviceMapper.deleteBatchIds(list));
+    }
+
+    @Override
+    public Result list(Map<String,String> paramsMap) {
+        //pageNo
+        String pageNo = paramsMap.get("pageNo");
+        if (StringUtils.isBlank(pageNo)) {
+            pageNo = "1";
+        }
+        //pageSize
+        String pageSize = paramsMap.get("pageSize");
+        if (StringUtils.isBlank(pageSize)) {
+            pageSize = "10";
+        }
+        //farmId
+        String farmId = paramsMap.get("farm_id");
+        if (farmId == null) {
+            farmId = globalFarmCode;
+        }
+        QueryWrapper<EcoDevice> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("farm_id", farmId);
+        Page<EcoDevice> page = new Page<>(Integer.parseInt(pageNo), Integer.parseInt(pageSize));
+        return new Result(ResultCode.SUCCESS,ecoDeviceMapper.selectPage(page,queryWrapper));
+    }
+
+
+    //内部关键字枚举
+    public enum DeviceType{
+        SUPERVISE( 1,"监测设备"),
+        DRYING(2,"烘干设备")
+        ;
+
+        private Integer code;
+        private String type;
+
+        DeviceType(Integer code,String type) {
+            this.code = code;
+            this.type = type;
+        }
+
+        public Integer getCode() {
+            return code;
+        }
+
+        private String getType() {
+            return type;
+        }
+
+        @Override
+        public String toString() {
+            return "DeviceType{" +
+                    "code=" + code +
+                    ", type='" + type + '\'' +
+                    '}';
+        }
+    }
+
 }