文件目录：org.jeecg.modules.demo.apimanage.service
    image.png

    1. @Transactional(rollbackFor = Exception.class)
    2.     public ResponseResult addIotGreenHouseDeviceIn(Map<String, Object> map, JSONObject jsonObject) {
    3.         try {
    4.             JSONObject json = JSONObject.parseObject(jsonObject.toString());
    5.             Nhiotgreenhousedeviceinfo nhiotgreenhousedeviceinfo = JSON.toJavaObject(json, Nhiotgreenhousedeviceinfo.class);
    6.             //查询当前设备是否已经被绑定  被绑定 无法绑定
    7.             String did = nhiotgreenhousedeviceinfo.getDid();
    8.          /*   int deviceExitsReuslt = nhiotgreenhousedeviceinfoService.selectHourseDeviceDidIsExits(did);
    9.             if (deviceExitsReuslt >= 1) {
    10.                 return ResponseResult.error(ResponseResultEnum.DEVICE_HAS_BEEN_BOUND);
    11.             }*/
    12.            List<Map<String,Object>> list=nhiotgreenhousedeviceinfoService.isBind(did);
    13.            if (!list.isEmpty()){
    14.                return ResponseResult.error(ResponseResultEnum.DEVICE_HAS_BEEN_BOUND);
    15.            }
    17.             String uid = nhiotgreenhousedeviceinfo.getUid();
    18.             String dpId = nhiotgreenhousedeviceinfo.getGhId();
    19.             //查询用户大棚是否存在  没有大棚不予许绑定设备
    20.             int hourseExitisResult = inhiotgreenhouseService.selectHourseExits(uid, dpId);
    21.             if (hourseExitisResult == 0) {
    22.                 return ResponseResult.error(ResponseResultEnum.NOT_FOUND_GREENHOUSES_INFO);
    23.             }
    25.             // 添加成功后 往设备的缓存中扔数据
    26.             nhiotgreenhousedeviceinfoService.save(nhiotgreenhousedeviceinfo);
    27.             // 把nh_iot_greenhouse_device_info 表的所有以前这个设备的信息（大棚id和用户id） 全部更新为新的大棚
    28.             //TODO 这个地方可能会更新几万条数据 或者更多
    29.             int updateState=nhiotgreenhousedeviceinfoService.updateUserIdDpId(uid,dpId,did);
    30.             // 添加数据后第一次处理数据 处理大棚的数据
    31.             updateDpData(nhiotgreenhousedeviceinfo, 1);
    32.             //把当前信息放入缓存
    33.             Map<String, Object> deviceInfo = new HashMap<>();
    34.             deviceInfo.put("uid", nhiotgreenhousedeviceinfo.getUid());
    35.             deviceInfo.put("did", nhiotgreenhousedeviceinfo.getDid());
    36.             deviceInfo.put("gh_id", nhiotgreenhousedeviceinfo.getGhId());
    37.             deviceInfo.put("gh_is_auto", 0);
    38.             List<Map<String, Object>> resultList = new ArrayList<>();
    39. /*            if (null == redisUtil.get("deviceList")) {
    40.                 resultList.add(deviceInfo);
    41.                 // TODO redisSet
    42.                 redisUtil.set("deviceList", resultList);
    43.             } else {
    44.                 resultList = (List<Map<String, Object>>) redisUtil.get("deviceList");
    45.                 resultList.add(deviceInfo);
    46.                 // TODO redisSet
    47.                 redisUtil.set("deviceList", resultList);
    48.             }*/
    49.             // 开始添加智能设备需要的表结构数据
    50.             List<Nhiotdevice> nhiotdeviceList = new ArrayList<>();
    52.             for (int i = 0; i < 5; i++) {
    54.                 Nhiotdevice nhiotdevice = new Nhiotdevice();
    55.                 nhiotdevice.setId(IdGenerator.uuid());
    56.                 nhiotdevice.setCreateBy("user");
    57.                 nhiotdevice.setDeviceId(did);
    58.                 nhiotdevice.setDeviceRuleIsUse(0);
    59.                 nhiotdevice.setDeviceType(i + 1);
    60.                 nhiotdevice.setGhId(nhiotgreenhousedeviceinfo.getGhId());
    61.                 nhiotdevice.setUserId(nhiotgreenhousedeviceinfo.getUid());
    63.                 //TODO 此处改为枚举方式直接在枚举中取出
    64.                 String name = "浇水";
    65.                 switch (i) {
    66.                     case 0:
    67.                         name = "浇水";
    68.                         break;
    69.                     case 1:
    70.                         name = "卷帘";
    71.                         break;
    72.                     case 2:
    73.                         name = "通风1";
    74.                         break;
    75.                     case 3:
    76.                         name = "通风2";
    77.                         break;
    78.                     case 4:
    79.                         name = "通风3";
    80.                         break;
    81.                     default:
    82.                 }
    83.                 nhiotdevice.setDeviceRuleName(name);
    85.                 nhiotdeviceList.add(nhiotdevice);
    87.             }
    89.             // 创建默认时间5个  农嗨云设备操作的默认时间
    90.             List<nhiotgreenousedeviceconfig> nhiotgreenousedeviceconfigList = new ArrayList<>();
    91.             Date date=new Date();
    92.             String relay=null;
    93.             for (int j = 0; j < 5; j++) {
    94.                 switch (j) {
    95.                     case 0:
    96.                         relay = "01";
    97.                         break;
    98.                     case 1:
    99.                         relay = "03";
    100.                         break;
    101.                     case 2:
    102.                         relay = "05";
    103.                         break;
    104.                     case 3:
    105.                         relay = "07";
    106.                         break;
    107.                     case 4:
    108.                         relay = "09";
    109.                         break;
    110.                     default:
    111.                 }
    112.                 nhiotgreenousedeviceconfig config=new nhiotgreenousedeviceconfig();
    113.                 config.setId(IdGenerator.uuid());
    114.                 config.setGhId(nhiotgreenhousedeviceinfo.getGhId());
    115.                 config.setUserId(nhiotgreenhousedeviceinfo.getUid());
    116.                 config.setRelay(relay);
    117.                 config.setCreateTime(date);
    118.                 config.setTime("50");
    119.                 if (relay==("09")){
    120.                     config.setTime("13,97,179");
    121.                 }
    123.                 config.setDeviceId(did);
    125.                 config.setCreateBy("jeecg");
    127.                 nhiotgreenousedeviceconfigList.add(config);
    128.             }
    129.             // 保存设备操作时间
    130.             int index=inhiotgreenousedeviceconfigService.inserdefaultTime(nhiotgreenousedeviceconfigList);
    131.             if (index>0){
    132.                 //添加默认时间成功
    133.                 //添加设备记录表
    134.                 int deviceIndex = iNhiotdeviceService.addHourseDeviceMarstInfo(nhiotdeviceList);
    135.                 if (deviceIndex>0){
    136.                     //添加最新数据
    137.                     //TODO 添加大棚成功,十分钟之后会更新数据,在添加成功获取一条数据保存到nh_iot_greenhouse_device_info_latest表
    138.                     /**
    139.                      * 往nh_iot_greenhouse_device_info_latest 表写入设备的最新数据  目的是 定时器十分钟更新数据 来不及
    140.                      * 1.根据设备id  请求http://app.sinoverse.cn:9090/api/wlw/json/3E0BF339BDF6.json 获取最新数据
    141.                      * 2.把数据save到 nh_iot_greenhouse_device_info_latest
    142.                      */
    143.                     String url = "http://app.sinoverse.cn:9090/api/wlw/json/" + did + ".json";
    144.                     String result = HttpClientHelpers.httpClientGet(url, new HashMap<>(), "UTF-8");
    146.                     if(result.equals("")){
    147.                         return ResponseResult.error("获取设备信息失败!");
    148.                     }else {
    149.                         JSONObject jsonResult = JSONObject.parseObject(result);
    150.                         Nhiotgreenhousedeviceinfo deviceinfo = JSON.toJavaObject(jsonResult, Nhiotgreenhousedeviceinfo.class);
    151.                         //根据大棚id查询数据是否存在
    152.                         QueryWrapper<Nhiotgreenhousedeviceinfolatest> queryWrapper = new QueryWrapper();
    153.                         queryWrapper.eq("gh_id",nhiotgreenhousedeviceinfo.getGhId());
    154.                         Nhiotgreenhousedeviceinfolatest nhiotgreenhousedeviceinfolatest = iNhiotgreenhousedeviceinfolatestService.selectByDeviceIdDeviceInfo(queryWrapper);
    156.                         if(nhiotgreenhousedeviceinfolatest==null){
    157.                             //添加数据
    158.                             String uuid = IdGenerator.uuid();
    159.                             deviceinfo.setId(uuid);
    160.                             deviceinfo.setCreateTime(new Date());
    161.                             deviceinfo.setUid(nhiotgreenhousedeviceinfo.getUid());
    162.                             deviceinfo.setDataState(1);//设备正常
    163.                             deviceinfo.setDataOnline(1);//设备在线
    164.                             iNhiotgreenhousedeviceinfolatestService.saveDeviceInfo(deviceinfo);
    165.                         }else {
    166.                             return ResponseResult.error("数据添加失败!");
    167.                         }
    168.                     }
    169.                     return ResponseResult.success();
    170.                 }
    171.                 return ResponseResult.error("设备添加失败!");
    173.             }
    174.             return ResponseResult.error("默认时间添加失败!");
    175.         } catch (Exception e) {
    176.             e.printStackTrace();
    177.             System.out.println("扫码后添加设备失败");
    178.         }
    179.         return ResponseResult.error(ResponseResultEnum.ADD_DEVICE_ERROR);
    180.     }