基于JavaScript和Java的水产养殖物联网系统设计源码

package com.example.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.example.mapper.LogMapper; import com.example.pojo.*; import com.example.service.DeviceService; import com.example.service.FamilyService; import com.example.service.LogService; import com.example.service.UserService; import com.tencentcloudapi.common.Credential; import com.tencentcloudapi.common.exception.TencentCloudSDKException; import com.tencentcloudapi.common.profile.ClientProfile; import com.tencentcloudapi.common.profile.HttpProfile; import com.tencentcloudapi.iotexplorer.v20190423.IotexplorerClient; import com.tencentcloudapi.iotexplorer.v20190423.models.*; import io.swagger.annotations.Api; import io.swagger.annotations.ApiKeyAuthDefinition; import io.swagger.annotations.ApiOperation; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpSession; import java.io.*; import java.math.BigDecimal; import java.net.MalformedURLException; import java.net.URL; import java.net.URLConnection; import java.net.URLEncoder; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.*; /** * <p> * 前端控制器 设备管理 * </p> * * @author sensordata * @since 2021-10-27 */ @Controller @Api(tags = "设备接口") //@ResponseBody public class DeviceController { @Resource private DeviceService deviceService; @Resource private UserService userService; @Resource private LogService logService; @Resource private LogMapper logMapper; @ApiOperation(value = "添加设备") @PostMapping("/adddevice") @ResponseBody public String adddevice(HttpSession session, Device device, @RequestParam(value = "productid") String productid, @RequestParam(value = "status") String status, @RequestParam(value = "tip") String tip,@RequestParam(value = "devicename") String devicename,@RequestParam(value = "x") String x, @RequestParam(value = "ownphone", defaultValue = "无") String ownphone) throws IOException { Webuser loginUser = (Webuser) session.getAttribute("loginUser"); QueryWrapper<Device> wrapper = new QueryWrapper<>(); wrapper.eq("deviceName", devicename); Device serviceOne = deviceService.getOne(wrapper); if (serviceOne == null) {//设备不存在 if (!ownphone.equals("无")) { QueryWrapper<User> wrapper1 = new QueryWrapper<>(); wrapper1.eq("phone", ownphone); User serviceOne1 = userService.getOne(wrapper1); if (serviceOne1 != null) {//用户存在 device.setStatus(status); device.setTip(tip); device.setX(x); device.setY(100); SimpleDateFormat df1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");// 设置日期格式 device.setCtime(df1.format(new Date())); Object[] objects = deviceService.getCoordinate(x); device.setLat((String) objects[0]); device.setLng((String) objects[1]); device.setDevicename(devicename); device.setOwnphone(ownphone); device.setProductid(productid); device.setOperate(loginUser.getAccount()); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");// 设置日期格式 device.setTime(df.format(new Date())); deviceService.save(device); } return "-1";//用户不存在，请先注册用户 } else { device.setStatus(status); device.setTip(tip); device.setX(x); device.setY(100); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");// 设置日期格式 device.setCtime(df.format(new Date())); Object[] objects = deviceService.getCoordinate(x); device.setLat((String) objects[0]); device.setLng((String) objects[1]); device.setDevicename(devicename); device.setOwnphone(ownphone); device.setOperate(loginUser.getAccount()); device.setTime("无"); device.setProductid(productid); deviceService.save(device); return "0"; } } return "1";//设备已存在 } //显示所有设备信息,按页显示 @ApiOperation(value = "显示所有设备信息") @GetMapping("/equList") @ResponseBody public Page list(HttpSession session, @RequestParam(value = "page", defaultValue = "1") Integer pageNumber, @RequestParam(value = "limit", defaultValue = "6") Integer pageLimit, Model model) { QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); Page<Device> Tpage = new Page<>(pageNumber, pageLimit); //deviceService.DescribeDevice(devicename,productid) Page<Device> page = deviceService.page(Tpage, queryWrapper); // model.addAttribute("device",page); return page; } //显示所有设备信息,按页显示 @ApiOperation(value = "显示所有在线设备状态") @GetMapping("/equStatus") @ResponseBody public Page equStatus(HttpSession session, @RequestParam(value = "page", defaultValue = "1") Integer pageNumber, @RequestParam(value = "limit", defaultValue = "6") Integer pageLimit, Model model) { QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("status", "1"); Page<Device> Tpage = new Page<>(pageNumber, pageLimit); //deviceService.DescribeDevice(devicename,productid) Page<Device> page = deviceService.page(Tpage, queryWrapper); // model.addAttribute("device",page); return page; } SimpleDateFormat df1; //更改设备状态 @ApiOperation(value = "更改设备状态") @ResponseBody @PostMapping(value = "/changed", produces = "application/json;charset=UTF-8") public String getByJSON(@RequestBody(required = false) JSONObject jsonParam) { //System.out.println(jsonParam); String devicename = jsonParam.getString("devicename"); String status = jsonParam.getJSONObject("payload").getString("event"); if (status.equals("EV_ONLINE")) { deviceService.updateDevice1("1", devicename); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");// 设置日期格式 String ltime = df.format(new Date()); QueryWrapper<Log> wrapper1 = new QueryWrapper<>(); wrapper1.eq("message", devicename).eq("Ltime", ltime); Log log = logService.getOne(wrapper1); if (log == null) { System.out.println(devicename); System.out.println(ltime); Log log1 = new Log(); log1.setMessage(devicename); log1.setLtime(ltime); log1.setIdentity("1"); logService.save(log1); } } if(status.equals("EV_OFFLINE")){ deviceService.updateDevice1("0",devicename); } // 将获取的json数据封装一层，然后在给返回 JSONObject result = new JSONObject(); result.put("msg", "ok"); result.put("method", "json"); result.put("data", json