|
@@ -498,13 +498,14 @@ public class TEquipmentController {
|
|
|
equipmentDTO.setCouponStatus(equipmentDesc.getCouponStatus());
|
|
|
equipmentDTO.setInDoor(equipmentDesc.getInDoor());
|
|
|
equipmentDTO.setOutDoor(equipmentDesc.getOutDoor());
|
|
|
- if (equipmentDesc.getFlowers() != null) {
|
|
|
+ if (StringUtils.isNotEmpty(equipmentDesc.getFlowers())) {
|
|
|
equipmentDTO.setFlowers(equipmentDesc.getFlowers());
|
|
|
}
|
|
|
equipmentDTO.setNumberOne(equipmentDesc.getNumberOne());
|
|
|
equipmentDTO.setCandyGeneratorTm(equipmentDesc.getCandyGeneratorTm());
|
|
|
equipmentDTO.setOutsideHd(equipmentDesc.getOutsideHd());
|
|
|
equipmentDTO.setOutsideTm(equipmentDesc.getOutsideTm());
|
|
|
+ equipmentDTO.setIsMaterialUse(equipmentDesc.getIsMaterialUse());
|
|
|
equipmentDTO.setDiyFlowerStatus(equipmentDesc.getDiyFlowerStatus());
|
|
|
equipmentDTO.setCleanFunction(equipmentDesc.getCleanFunction());
|
|
|
equipmentDTO.setTaxStatus(equipmentDesc.getTaxStatus());
|
|
@@ -673,18 +674,12 @@ public class TEquipmentController {
|
|
|
return R.ok(tEquipment);
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 更新
|
|
|
- */
|
|
|
@ApiOperation(value = "更新机器")
|
|
|
@RequestMapping(value = "/update", method = RequestMethod.POST)
|
|
|
public ResponseModel<?> update(@RequestBody TEquipmentDTO equipment) {
|
|
|
//获取修改前的设备
|
|
|
TEquipment oldEquipment = tEquipmentService.getById(equipment.getId());
|
|
|
TEquipmentDesc equipmentDesc = equipmentDescService.getById(equipment.getId());
|
|
|
- if (StringUtils.isNotEmpty(equipment.getSn())) {
|
|
|
- oldEquipment.setSn(equipment.getSn());
|
|
|
- }
|
|
|
String name = equipment.getName();
|
|
|
if (StringUtils.isNotEmpty(name) && !name.equals(oldEquipment.getName())) {
|
|
|
LambdaQueryWrapper<TEquipment> queryWrapper = new LambdaQueryWrapper<>();
|
|
@@ -699,9 +694,6 @@ public class TEquipmentController {
|
|
|
if (StringUtils.isNotEmpty(equipment.getSelfName())) {
|
|
|
oldEquipment.setSelfName(equipment.getSelfName());
|
|
|
}
|
|
|
- if (equipment.getAreaId() != null) {
|
|
|
- oldEquipment.setAreaId(equipment.getAreaId());
|
|
|
- }
|
|
|
if (StringUtils.isNotEmpty(equipment.getContactName())) {
|
|
|
oldEquipment.setContactName(equipment.getContactName());
|
|
|
}
|
|
@@ -714,24 +706,12 @@ public class TEquipmentController {
|
|
|
if (StringUtils.isNotEmpty(equipment.getOperationalPhone())) {
|
|
|
oldEquipment.setOperationalPhone(equipment.getOperationalPhone());
|
|
|
}
|
|
|
- if (StringUtils.isNotEmpty(equipment.getOperator())) {
|
|
|
- oldEquipment.setOperator(equipment.getOperator());
|
|
|
- }
|
|
|
- if (StringUtils.isNotEmpty(equipment.getSimNo())) {
|
|
|
- oldEquipment.setSimNo(equipment.getSimNo());
|
|
|
- }
|
|
|
if (equipment.getTimeRuleId() != null) {
|
|
|
oldEquipment.setTimeRuleId(equipment.getTimeRuleId());
|
|
|
}
|
|
|
- if (StringUtils.isNotEmpty(equipment.getPlcVersion())) {
|
|
|
- oldEquipment.setPlcVersion(equipment.getPlcVersion());
|
|
|
- }
|
|
|
if (StringUtils.isNotEmpty(equipment.getChannel())) {
|
|
|
oldEquipment.setChannel(equipment.getChannel());
|
|
|
}
|
|
|
- if (equipment.getPayType() != null) {
|
|
|
- oldEquipment.setPayType(equipment.getPayType());
|
|
|
- }
|
|
|
if (equipment.getEndDate() != null) {
|
|
|
oldEquipment.setEndDate(equipment.getEndDate());
|
|
|
}
|
|
@@ -764,28 +744,13 @@ public class TEquipmentController {
|
|
|
oldEquipment.setMessageReceiver(message[0] + "," + message[1] + "," + message[2]);
|
|
|
}
|
|
|
tEquipmentService.updateById(oldEquipment);
|
|
|
- if (equipment.getPayType() != null) {
|
|
|
- tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("payType", oldEquipment.getPayType().toString() + ":" + oldEquipment.getTimeRuleId()).toString());
|
|
|
- }
|
|
|
if (StringUtils.isNotEmpty(oldEquipment.getContactName()) && StringUtils.isNotEmpty(oldEquipment.getContactPhone())) {
|
|
|
+ // MQ消息
|
|
|
tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("phone", oldEquipment.getContactName() + ":" + oldEquipment.getContactPhone()).toString());
|
|
|
}
|
|
|
- if (StringUtils.isNotEmpty(oldEquipment.getCompanyPhone())) {
|
|
|
- tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("companyPhone", oldEquipment.getCompanyPhone()).toString());
|
|
|
- }
|
|
|
- if (StringUtils.isNotEmpty(oldEquipment.getPlcVersion())) {
|
|
|
- tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("plcVersion", oldEquipment.getPlcVersion()).toString());
|
|
|
- }
|
|
|
- if (StringUtils.isNotEmpty(oldEquipment.getSelfName())) {
|
|
|
- tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("selfName", oldEquipment.getSelfName()).toString());
|
|
|
- }
|
|
|
if (oldEquipment.getTimeRuleId() != null) {
|
|
|
tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("pushTimeRule", oldEquipment.getTimeRuleId() + "").toString());
|
|
|
}
|
|
|
- if (StringUtils.isNotEmpty(oldEquipment.getOperationalName())) {
|
|
|
- tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("operational", oldEquipment.getOperationalName() + ":" + oldEquipment.getOperationalPhone()).toString());
|
|
|
- }
|
|
|
-
|
|
|
return R.ok("null", "更新成功!");
|
|
|
}
|
|
|
|
|
@@ -895,41 +860,6 @@ public class TEquipmentController {
|
|
|
|
|
|
}
|
|
|
|
|
|
- @ApiOperation(value = "消除报警")
|
|
|
- @PostMapping("/eliminate")
|
|
|
- public ResponseModel<?> eliminate(@RequestBody TAlarmRecord param) {
|
|
|
- UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
|
- .orElseThrow(() -> new BizException(ResponseCodesEnum.L0001));
|
|
|
- Long adminId = userDetailBO.getId();
|
|
|
- TAlarmRecord tAlarmRecord = tAlarmRecordService.getById(param.getId());
|
|
|
- TEquipment equipment = tEquipmentService.getById(tAlarmRecord.getEquipmentId());
|
|
|
- if (equipment == null) {
|
|
|
- return R.fail(A0001, "设备不存在");
|
|
|
- }
|
|
|
- String machineType = equipment.getMachineType();
|
|
|
- if (StringUtils.isNotEmpty(machineType) && "2".equals(machineType)) {
|
|
|
- // 消除过往的报警
|
|
|
- LambdaUpdateWrapper<TAlarmRecord> wrapper = Wrappers.lambdaUpdate();
|
|
|
- wrapper.eq(TAlarmRecord::getClientId, tAlarmRecord.getClientId());
|
|
|
- wrapper.eq(TAlarmRecord::getIsEliminate, 0);
|
|
|
- wrapper.le(TAlarmRecord::getCreateDate, new Date());
|
|
|
- wrapper.set(TAlarmRecord::getIsEliminate, 1);
|
|
|
- tAlarmRecordService.update(wrapper);
|
|
|
- // 更改机器状态
|
|
|
- equipment.setIsAlarm(false);
|
|
|
- tEquipmentService.updateById(equipment);
|
|
|
- } else {
|
|
|
- JSONObject kindData = new JSONObject();
|
|
|
- kindData.put("id", param.getId());
|
|
|
- kindData.put("content", tAlarmRecord.getAlarmContent());
|
|
|
- tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("eliminate", kindData.toString()).toString());
|
|
|
- // MQTT
|
|
|
- String message = PushUtils.buildJson(OperationType.ELIMINATE.getCode(), "1").toString();
|
|
|
- tEquipmentService.sendRemoteMessage(equipment.getClientId(), OperationType.ELIMINATE, message, adminId);
|
|
|
- }
|
|
|
- return R.ok();
|
|
|
- }
|
|
|
-
|
|
|
@ApiOperation(value = "修改机器音量")
|
|
|
@PostMapping("/updateVolume")
|
|
|
public ResponseEntity<?> updateVolume(@RequestBody TEquipment equipment) {
|
|
@@ -943,52 +873,6 @@ public class TEquipmentController {
|
|
|
|
|
|
}
|
|
|
|
|
|
- @ApiOperation(value = "修改机器信息")
|
|
|
- @PostMapping("/updateEquipment")
|
|
|
- public ResponseEntity<?> updateEquipment(@RequestBody TEquipment equipment) {
|
|
|
- TEquipment equipment1 = tEquipmentService.getById(equipment.getId());
|
|
|
- Integer type = equipment.getType();
|
|
|
- //修改基本信息
|
|
|
- if (type == 0) {
|
|
|
- equipment1.setName(equipment.getName());
|
|
|
- equipment1.setSimNo(equipment.getSimNo());
|
|
|
- equipment1.setOperator(equipment.getOperator());
|
|
|
- }
|
|
|
- //修改后台密码
|
|
|
- if (type == 1) {
|
|
|
- equipment1.setAdminPwd(equipment.getAdminPwd());
|
|
|
- equipment1.setGuestPwd(equipment.getGuestPwd());
|
|
|
- tEquipmentService.sentMessage(equipment1.getClientId(), PushUtils.buildJson("guestPwd", equipment1.getGuestPwd()).toString());
|
|
|
- tEquipmentService.sentMessage(equipment1.getClientId(), PushUtils.buildJson("adminPwd", equipment1.getAdminPwd()).toString());
|
|
|
-// PushUtils.push(equipment1.getGtClientId(), "【棉花糖】设备管理-更改密码", "修改guest密码", PushUtils.buildJson("guestPwd", equipment1.getGuestPwd()).toString());
|
|
|
-// PushUtils.push(equipment1.getGtClientId(), "【棉花糖】设备管理-更改密码", "修改admin密码", PushUtils.buildJson("adminPwd", equipment1.getAdminPwd()).toString());
|
|
|
- }
|
|
|
- //定时开机
|
|
|
-// if (type == 3) {
|
|
|
-// equipment1.setBootTime(equipment.getBootTime());
|
|
|
-// tEquipmentService.sentMessage(equipment1.getClientId(),PushUtils.buildJson("updateBootTime", equipment.getBootTime()).toString());
|
|
|
-// PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("updateBootTime", equipment.getBootTime()).toString());
|
|
|
-// }
|
|
|
- //定时关机
|
|
|
-// if (type == 4) {
|
|
|
-// equipment1.setOffTime(equipment.getOffTime());
|
|
|
-// tEquipmentService.sentMessage(equipment1.getClientId(), PushUtils.buildJson("updateOffTime", equipment.getBootTime()).toString());
|
|
|
-// PushUtils.push(equipment.getGtClientId(), "", "", PushUtils.buildJson("updateOffTime", equipment.getBootTime()).toString());
|
|
|
-// }
|
|
|
- if (type == 5) {
|
|
|
- equipment1.setMessageReceiver(equipment.getMessageReceiver());
|
|
|
- }
|
|
|
- Boolean t = tEquipmentService.updateById(equipment1);
|
|
|
- if (t) {
|
|
|
- return ResponseEntity.status(HttpStatus.OK)
|
|
|
- .body(new ResultMessage().setCode(true).setData(equipment1).setMessage("修改成功"));
|
|
|
- } else {
|
|
|
- return ResponseEntity.status(HttpStatus.OK)
|
|
|
- .body(new ResultMessage().setCode(false).setData(t).setMessage("修改失败"));
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
@ApiOperation(value = "根据机器id获取用户信息")
|
|
|
@PostMapping("/findByEquipment")
|
|
|
public ResponseEntity<?> findByEquipment(@RequestBody TEquipment equipment) {
|
|
@@ -1699,13 +1583,6 @@ public class TEquipmentController {
|
|
|
return R.ok();
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 下载日志
|
|
|
- *
|
|
|
- * @param equipmentId 设备id
|
|
|
- * @param day 日期
|
|
|
- * @param response 响应
|
|
|
- */
|
|
|
@ApiOperation(value = "下载日志")
|
|
|
@GetMapping("/downloadLog")
|
|
|
public ResponseModel<?> downloadLog(String equipmentId, String day, HttpServletResponse response) throws IOException, InterruptedException {
|
|
@@ -1854,13 +1731,6 @@ public class TEquipmentController {
|
|
|
return R.ok();
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 上传日志
|
|
|
- *
|
|
|
- * @param equipmentId 设备ID,用于标识上传日志的设备
|
|
|
- * @param day 日期,指定要上传日志的日期
|
|
|
- * @return 返回操作结果,成功则返回成功信息,失败则返回失败原因
|
|
|
- */
|
|
|
@ApiOperation(value = "上传日志")
|
|
|
@GetMapping("/uploadLog")
|
|
|
public ResponseModel<?> uploadLog(String equipmentId, String day) {
|
|
@@ -2147,7 +2017,7 @@ public class TEquipmentController {
|
|
|
return R.ok();
|
|
|
}
|
|
|
|
|
|
- @ApiOperation(value = "制作商品")
|
|
|
+ @ApiOperation("制作商品")
|
|
|
@PostMapping("/produceGoods")
|
|
|
public ResponseModel<?> produceGoods(@RequestBody DoSugarParam param) {
|
|
|
UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
@@ -2195,7 +2065,7 @@ public class TEquipmentController {
|
|
|
return R.fail(ResponseCodesEnum.A0001);
|
|
|
}
|
|
|
|
|
|
- @ApiOperation(value = "上传日志")
|
|
|
+ @ApiOperation("上传日志")
|
|
|
@GetMapping("/newUploadLog")
|
|
|
public ResponseModel<?> newUploadLog(String equipmentId, String day) {
|
|
|
UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
@@ -2225,7 +2095,7 @@ public class TEquipmentController {
|
|
|
return R.ok();
|
|
|
}
|
|
|
|
|
|
- @ApiOperation(value = "修改音量")
|
|
|
+ @ApiOperation("修改音量")
|
|
|
@PostMapping("/changeVolume")
|
|
|
public ResponseModel<?> changeVolume(@RequestBody TEquipment param) {
|
|
|
UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
@@ -2244,7 +2114,7 @@ public class TEquipmentController {
|
|
|
return R.fail(ResponseCodesEnum.A0001);
|
|
|
}
|
|
|
|
|
|
- @ApiOperation(value = "修改机器密码")
|
|
|
+ @ApiOperation("修改机器密码")
|
|
|
@PostMapping("/changePassword")
|
|
|
public ResponseModel<?> changePassword(@RequestBody EquipmentParam param) {
|
|
|
UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
@@ -2258,7 +2128,7 @@ public class TEquipmentController {
|
|
|
String guestPwd = param.getGuestPwd();
|
|
|
JSONObject kindData = new JSONObject();
|
|
|
if (StringUtils.isNotEmpty(guestPwd)) {
|
|
|
- kindData.put("type", "0");
|
|
|
+ kindData.put("type", "1");
|
|
|
kindData.put("password", guestPwd);
|
|
|
String message = PushUtils.buildJson(OperationType.PASSWORD.getCode(), kindData.toString()).toString();
|
|
|
// MQTT消息
|
|
@@ -2267,7 +2137,7 @@ public class TEquipmentController {
|
|
|
tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("guestPwd", guestPwd).toString());
|
|
|
}
|
|
|
if (StringUtils.isNotEmpty(adminPwd)) {
|
|
|
- kindData.put("type", "1");
|
|
|
+ kindData.put("type", "0");
|
|
|
kindData.put("password", adminPwd);
|
|
|
String message = PushUtils.buildJson(OperationType.PASSWORD.getCode(), kindData.toString()).toString();
|
|
|
// MQTT消息
|
|
@@ -2309,7 +2179,7 @@ public class TEquipmentController {
|
|
|
return R.fail(ResponseCodesEnum.A0001);
|
|
|
}
|
|
|
|
|
|
- @ApiOperation(value = "重启触摸屏")
|
|
|
+ @ApiOperation("重启触摸屏")
|
|
|
@GetMapping("/restartScreen")
|
|
|
public ResponseModel<?> restartScreen(String equipmentId) {
|
|
|
UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
@@ -2329,7 +2199,7 @@ public class TEquipmentController {
|
|
|
return R.fail(ResponseCodesEnum.A0001);
|
|
|
}
|
|
|
|
|
|
- @ApiOperation(value = "机器睡眠")
|
|
|
+ @ApiOperation("机器睡眠")
|
|
|
@PostMapping("/switchSleep")
|
|
|
public ResponseModel<?> switchSleep(@RequestBody EquipmentParam param) {
|
|
|
UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
@@ -2350,7 +2220,7 @@ public class TEquipmentController {
|
|
|
return R.fail(ResponseCodesEnum.A0001);
|
|
|
}
|
|
|
|
|
|
- @ApiOperation(value = "机器开关机")
|
|
|
+ @ApiOperation("机器开关机")
|
|
|
@PostMapping("/powerOnOff")
|
|
|
public ResponseModel<?> powerOnOff(@RequestBody EquipmentParam param) {
|
|
|
UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
@@ -2375,5 +2245,246 @@ public class TEquipmentController {
|
|
|
return R.fail(ResponseCodesEnum.A0001);
|
|
|
}
|
|
|
|
|
|
+ @ApiOperation("消除报警")
|
|
|
+ @PostMapping("/eliminate")
|
|
|
+ public ResponseModel<?> eliminate(@RequestBody TAlarmRecord param) {
|
|
|
+ UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
|
+ .orElseThrow(() -> new BizException(ResponseCodesEnum.L0001));
|
|
|
+ Long adminId = userDetailBO.getId();
|
|
|
+ TAlarmRecord tAlarmRecord = tAlarmRecordService.getById(param.getId());
|
|
|
+ TEquipment equipment = tEquipmentService.getById(tAlarmRecord.getEquipmentId());
|
|
|
+ if (equipment == null) {
|
|
|
+ return R.fail(A0001, "设备不存在");
|
|
|
+ }
|
|
|
+ String machineType = equipment.getMachineType();
|
|
|
+ if (StringUtils.isNotEmpty(machineType) && "2".equals(machineType)) {
|
|
|
+ // 消除过往的报警
|
|
|
+ LambdaUpdateWrapper<TAlarmRecord> wrapper = Wrappers.lambdaUpdate();
|
|
|
+ wrapper.eq(TAlarmRecord::getClientId, tAlarmRecord.getClientId());
|
|
|
+ wrapper.eq(TAlarmRecord::getIsEliminate, 0);
|
|
|
+ wrapper.le(TAlarmRecord::getCreateDate, new Date());
|
|
|
+ wrapper.set(TAlarmRecord::getIsEliminate, 1);
|
|
|
+ tAlarmRecordService.update(wrapper);
|
|
|
+ // 更改机器状态
|
|
|
+ equipment.setIsAlarm(false);
|
|
|
+ tEquipmentService.updateById(equipment);
|
|
|
+ } else {
|
|
|
+ JSONObject kindData = new JSONObject();
|
|
|
+ kindData.put("id", param.getId());
|
|
|
+ kindData.put("content", tAlarmRecord.getAlarmContent());
|
|
|
+ tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("eliminate", kindData.toString()).toString());
|
|
|
+ // MQTT
|
|
|
+ String message = PushUtils.buildJson(OperationType.ELIMINATE.getCode(), "1").toString();
|
|
|
+ tEquipmentService.sendRemoteMessage(equipment.getClientId(), OperationType.ELIMINATE, message, adminId);
|
|
|
+ }
|
|
|
+ return R.ok();
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation("锁机")
|
|
|
+ @PostMapping("/block")
|
|
|
+ public ResponseModel<?> block(@RequestBody EquipmentParam param) {
|
|
|
+ UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
|
+ .orElseThrow(() -> new BizException(ResponseCodesEnum.L0001));
|
|
|
+ Long adminId = userDetailBO.getId();
|
|
|
+
|
|
|
+ Long equipmentId = param.getId();
|
|
|
+ TEquipment equipment = tEquipmentService.getById(equipmentId);
|
|
|
+ if (equipment != null) {
|
|
|
+ // MQTT消息
|
|
|
+ String clientId = equipment.getClientId();
|
|
|
+ String status = param.getStatus();
|
|
|
+ String message = PushUtils.buildJson(OperationType.BLOCK.getCode(), status).toString();
|
|
|
+ tEquipmentService.sendRemoteMessage(equipment.getClientId(), OperationType.BLOCK, message, adminId);
|
|
|
+ // MQ消息
|
|
|
+ tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("block", status).toString());
|
|
|
+ return R.ok();
|
|
|
+ }
|
|
|
+ return R.fail(ResponseCodesEnum.A0001);
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation("更新机器")
|
|
|
+ @PostMapping("/updateInfo")
|
|
|
+ public ResponseModel<?> updateInfo(@RequestBody TEquipmentDTO equipment) {
|
|
|
+ UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
|
+ .orElseThrow(() -> new BizException(ResponseCodesEnum.L0001));
|
|
|
+ Long adminId = userDetailBO.getId();
|
|
|
+
|
|
|
+ //获取修改前的设备
|
|
|
+ TEquipment oldEquipment = tEquipmentService.getById(equipment.getId());
|
|
|
+ TEquipmentDesc equipmentDesc = equipmentDescService.getById(equipment.getId());
|
|
|
+ String name = equipment.getName();
|
|
|
+ if (StringUtils.isNotEmpty(name) && !name.equals(oldEquipment.getName())) {
|
|
|
+ LambdaQueryWrapper<TEquipment> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ queryWrapper.eq(TEquipment::getAdminId, oldEquipment.getAdminId());
|
|
|
+ queryWrapper.eq(TEquipment::getName, name);
|
|
|
+ TEquipment tEquipment = tEquipmentService.getOne(queryWrapper);
|
|
|
+ if (tEquipment != null) {
|
|
|
+ return R.fail(A0001);
|
|
|
+ }
|
|
|
+ oldEquipment.setName(equipment.getName());
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(equipment.getSelfName())) {
|
|
|
+ oldEquipment.setSelfName(equipment.getSelfName());
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(equipment.getContactName())) {
|
|
|
+ oldEquipment.setContactName(equipment.getContactName());
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(equipment.getContactPhone())) {
|
|
|
+ oldEquipment.setContactPhone(equipment.getContactPhone());
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(equipment.getOperationalName())) {
|
|
|
+ oldEquipment.setOperationalName(equipment.getOperationalName());
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(equipment.getOperationalPhone())) {
|
|
|
+ oldEquipment.setOperationalPhone(equipment.getOperationalPhone());
|
|
|
+ }
|
|
|
+ if (equipment.getTimeRuleId() != null) {
|
|
|
+ oldEquipment.setTimeRuleId(equipment.getTimeRuleId());
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(equipment.getChannel())) {
|
|
|
+ oldEquipment.setChannel(equipment.getChannel());
|
|
|
+ }
|
|
|
+ if (equipment.getAreaId() != null) {
|
|
|
+ oldEquipment.setFullName(tAreaService.getById(equipment.getAreaId()).getFullName());
|
|
|
+ }
|
|
|
+ String[] message = new String[3];
|
|
|
+ message[0] = equipment.getMessageReceiver1();
|
|
|
+ message[1] = equipment.getMessageReceiver2();
|
|
|
+ message[2] = equipment.getMessageReceiver3();
|
|
|
+ if (message.length > 0) {
|
|
|
+ oldEquipment.setMessageReceiver(message[0] + "," + message[1] + "," + message[2]);
|
|
|
+ }
|
|
|
+ tEquipmentService.updateById(oldEquipment);
|
|
|
+ if (StringUtils.isNotEmpty(oldEquipment.getContactName()) && StringUtils.isNotEmpty(oldEquipment.getContactPhone())) {
|
|
|
+ // MQ消息
|
|
|
+ tEquipmentService.sentMessage(oldEquipment.getClientId(), PushUtils.buildJson("phone",
|
|
|
+ oldEquipment.getContactName() + ":" + oldEquipment.getContactPhone()).toString());
|
|
|
+
|
|
|
+ JSONObject kindData = new JSONObject();
|
|
|
+ kindData.put("contactName", oldEquipment.getContactName());
|
|
|
+ kindData.put("contactPhone", oldEquipment.getContactPhone());
|
|
|
+ // MQTT消息
|
|
|
+ String mqMessage = PushUtils.buildJson(OperationType.PHONE.getCode(), kindData.toString()).toString();
|
|
|
+ tEquipmentService.sendRemoteMessage(oldEquipment.getClientId(), OperationType.PHONE, mqMessage, adminId);
|
|
|
+ }
|
|
|
+ return R.ok();
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation("推送商品")
|
|
|
+ @PostMapping("/pushGoods")
|
|
|
+ public ResponseModel<?> pushGoods(@RequestBody EquipmentDescParam param) {
|
|
|
+ UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
|
+ .orElseThrow(() -> new BizException(ResponseCodesEnum.L0001));
|
|
|
+ Long adminId = userDetailBO.getId();
|
|
|
+
|
|
|
+ Long equipmentId = param.getId();
|
|
|
+ TEquipment equipment = tEquipmentService.getById(equipmentId);
|
|
|
+ if (equipment != null) {
|
|
|
+ // MQTT消息
|
|
|
+ String clientId = equipment.getClientId();
|
|
|
+ String flowers = param.getFlowers();
|
|
|
+ String message = PushUtils.buildJson(OperationType.FLOWERS.getCode(), flowers).toString();
|
|
|
+ tEquipmentService.sendRemoteMessage(equipment.getClientId(), OperationType.FLOWERS, message, adminId);
|
|
|
+ // MQ消息
|
|
|
+ tEquipmentService.sentMessage(clientId, PushUtils.buildJson("flowers", equipment.getFlowers()).toString());
|
|
|
+ // 通知客户
|
|
|
+ tEquipmentService.informClient(equipment.getAdminId(), clientId);
|
|
|
+ return R.ok();
|
|
|
+ }
|
|
|
+
|
|
|
+ return R.fail(ResponseCodesEnum.A0001);
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation("推送LOGO")
|
|
|
+ @PostMapping("/pushLogo")
|
|
|
+ public ResponseModel<?> pushLogo(@RequestBody EquipmentParam param) {
|
|
|
+ UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
|
+ .orElseThrow(() -> new BizException(ResponseCodesEnum.L0001));
|
|
|
+ Long adminId = userDetailBO.getId();
|
|
|
+ TEquipment equipment = tEquipmentService.getById(param.getId());
|
|
|
+
|
|
|
+ if (equipment != null) {
|
|
|
+ String clientId = equipment.getClientId();
|
|
|
+ String logoNumber = param.getLogoNumber();
|
|
|
+ // MQTT消息
|
|
|
+ String message = PushUtils.buildJson(OperationType.UPDATE_LOGO.getCode(), logoNumber).toString();
|
|
|
+ tEquipmentService.sendRemoteMessage(equipment.getClientId(), OperationType.UPDATE_LOGO, message, adminId);
|
|
|
+ // MQ消息
|
|
|
+ tEquipmentService.sentMessage(clientId, PushUtils.buildJson("updateLogo", logoNumber).toString());
|
|
|
+ return R.ok();
|
|
|
+ }
|
|
|
+ return R.fail(ResponseCodesEnum.A0001);
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation("脱机")
|
|
|
+ @PostMapping("/offline")
|
|
|
+ public ResponseModel<?> offline(@RequestBody EquipmentParam param) {
|
|
|
+ UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
|
+ .orElseThrow(() -> new BizException(ResponseCodesEnum.L0001));
|
|
|
+ Long adminId = userDetailBO.getId();
|
|
|
+
|
|
|
+ TEquipment equipment = tEquipmentService.getById(param.getId());
|
|
|
+ if (equipment != null) {
|
|
|
+ if ("xxx".equals(equipment.getClientId().substring(equipment.getClientId().length() - 3))) {
|
|
|
+ return R.fail("该设备已脱机");
|
|
|
+ }
|
|
|
+ // MQTT消息
|
|
|
+ String clientId = equipment.getClientId();
|
|
|
+ String message = PushUtils.buildJson(OperationType.OFFLINE.getCode(), "0").toString();
|
|
|
+ tEquipmentService.sendRemoteMessage(equipment.getClientId(), OperationType.OFFLINE, message, adminId);
|
|
|
+ // MQ消息
|
|
|
+ tEquipmentService.sentMessage(clientId, PushUtils.buildJson("tuoji", "0").toString());
|
|
|
+ return R.ok();
|
|
|
+ }
|
|
|
+ return R.fail(ResponseCodesEnum.A0001);
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation("睡眠描述")
|
|
|
+ @PostMapping("/sleepDesc")
|
|
|
+ public ResponseModel<?> sleepDesc(@RequestBody EquipmentDescParam param) {
|
|
|
+ UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
|
+ .orElseThrow(() -> new BizException(ResponseCodesEnum.L0001));
|
|
|
+ Long adminId = userDetailBO.getId();
|
|
|
+ TEquipment equipment = tEquipmentService.getById(param.getId());
|
|
|
+ if (equipment != null) {
|
|
|
+ // MQTT消息
|
|
|
+ String clientId = equipment.getClientId();
|
|
|
+ String sleepDesc = param.getSleepDesc();
|
|
|
+ String message = PushUtils.buildJson(OperationType.SLEEP_DESC.getCode(), sleepDesc).toString();
|
|
|
+ tEquipmentService.sendRemoteMessage(equipment.getClientId(), OperationType.SLEEP_DESC, message, adminId);
|
|
|
+ // MQ消息
|
|
|
+ tEquipmentService.sentMessage(clientId, PushUtils.buildJson("sleepDesc", sleepDesc).toString());
|
|
|
+ return R.ok();
|
|
|
+ }
|
|
|
+ return R.fail(ResponseCodesEnum.A0001);
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation("推送广告规则")
|
|
|
+ @PostMapping("/pushAdRule")
|
|
|
+ public ResponseModel<?> pushAdRule(@RequestBody EquipmentParam param) {
|
|
|
+ UserDetailBO userDetailBO = Optional.ofNullable(tokenManager.getLoginUserDetails())
|
|
|
+ .orElseThrow(() -> new BizException(ResponseCodesEnum.L0001));
|
|
|
+ Long adminId = userDetailBO.getId();
|
|
|
+ Long equipmentId = param.getId();
|
|
|
+
|
|
|
+ TEquipment equipment = tEquipmentService.getById(param.getId());
|
|
|
+ if (equipment != null) {
|
|
|
+ String clientId = equipment.getClientId();
|
|
|
+ String timeRuleId = param.getTimeRuleId();
|
|
|
+
|
|
|
+ equipment.setTimeRuleId(Long.valueOf(timeRuleId));
|
|
|
+ tEquipmentService.updateById(equipment);
|
|
|
+
|
|
|
+ // MQTT消息
|
|
|
+ String message = PushUtils.buildJson(OperationType.PUSH_TIME_RULE.getCode(), timeRuleId).toString();
|
|
|
+ tEquipmentService.sendRemoteMessage(equipment.getClientId(), OperationType.PUSH_TIME_RULE, message, adminId);
|
|
|
+
|
|
|
+ // MQ消息
|
|
|
+ tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("pushTimeRule", timeRuleId).toString());
|
|
|
+ return R.ok();
|
|
|
+ }
|
|
|
+ return R.fail(ResponseCodesEnum.A0001);
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
|