修改BUG

.gitignore

@@ -39,4 +39,5 @@ build/
 .gitconfig
 .mymetadata
 Thumbs.db
-logs
+logs
+.DS_Store

src/main/java/com/care/bms/service/BmsEventOrderService.java

@@ -191,8 +191,10 @@ public class BmsEventOrderService {
                 resVO.setOrderTypeName(OrderTypeEnum.getCodeToName(item.getOrderType()));
                 resVO.setStatusName(OrderStatusEnum.getCodeToName(item.getStatus()));
                 QueryWrapper<CareEventOrderHandleHis> queryWrapper2 = new QueryWrapper<>();
-                queryWrapper2.lambda().eq(CareEventOrderHandleHis::getOrderId, item.getId()).eq(CareEventOrderHandleHis::getLogType, LogTypeEnum.DEV_EVENT.getValue());
-                resVO.setWarnCount(careEventOrderHandleHisService.count(queryWrapper2));
+                queryWrapper2.select("distinct org_id,station_id,house_id,order_id,log_type,order_type,log_object_id,log_object_name,log_result," +
+                        "op_user_role,op_user_id,op_user_name,create_time,relation_type_desc,call_result_id").lambda().eq(CareEventOrderHandleHis::getOrderId, item.getId()).eq(CareEventOrderHandleHis::getLogType, LogTypeEnum.DEV_EVENT.getValue());
+                List tmpList = careEventOrderHandleHisService.list(queryWrapper2);
+                resVO.setWarnCount(CollUtil.isNotEmpty(tmpList)?tmpList.size():0);
                 list.add(resVO);
             });
             results.setRecords(list);
@@ -209,7 +211,8 @@ public class BmsEventOrderService {
     public List<OrderHandleHisVO> listHisWarn(Long orderId) {
         CareEventOrder order = this.careEventOrderService.getById(orderId);
         QueryWrapper<CareEventOrderHandleHis> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda().eq(CareEventOrderHandleHis::getOrderId, order.getId()).eq(CareEventOrderHandleHis::getLogType, LogTypeEnum.DEV_EVENT.getValue()).orderByDesc(CareEventOrderHandleHis::getCreateTime);
+        queryWrapper.select("distinct org_id,station_id,house_id,order_id,log_type,order_type,log_object_id,log_object_name,log_result," +
+                "op_user_role,op_user_id,op_user_name,create_time,relation_type_desc,call_result_id").lambda().eq(CareEventOrderHandleHis::getOrderId, order.getId()).eq(CareEventOrderHandleHis::getLogType, LogTypeEnum.DEV_EVENT.getValue()).orderByDesc(CareEventOrderHandleHis::getCreateTime);
         List<CareEventOrderHandleHis> list = careEventOrderHandleHisService.list(queryWrapper);
         List<OrderHandleHisVO> listHisWarn = new ArrayList<>();
         if (CollUtil.isNotEmpty(list)) {
@@ -435,7 +438,8 @@ public class BmsEventOrderService {
     public List<OrderHandleHisVO> queryOrderHandleHis(Long orderId) {
         List<OrderHandleHisVO> result = Lists.newArrayList();
         QueryWrapper<CareEventOrderHandleHis> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda().eq(CareEventOrderHandleHis::getOrderId, orderId)
+        queryWrapper.select("distinct org_id,station_id,house_id,order_id,log_type,order_type,log_object_id,log_object_name,log_result," +
+                "op_user_role,op_user_id,op_user_name,create_time,relation_type_desc,call_result_id").lambda().eq(CareEventOrderHandleHis::getOrderId, orderId)
                 .orderByDesc(CareEventOrderHandleHis::getCreateTime);
         List<CareEventOrderHandleHis> datas = this.careEventOrderHandleHisService.list(queryWrapper);
         if (CollUtil.isNotEmpty(datas)) {

src/main/java/com/care/bms/service/BmsSysUserService.java

@@ -8,6 +8,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.care.common.entity.*;
 
+import com.care.common.enums.DeviceActiveStatusEnum;
+import com.care.common.enums.OlderLiveTypeEnum;
 import com.care.common.enums.UserRoleEnum;
 import com.care.common.exception.BDException;
 import com.care.common.service.*;
@@ -191,7 +193,7 @@ public class BmsSysUserService{
                             deviceVO.setHouseAddr(careHouse.getAddr());
                         }
                     }
-
+                    deviceVO.setActiveStatusName(DeviceActiveStatusEnum.getCodeToName(deviceVO.getActiveStatus()));
 
                     hasDeviceVOList.add(deviceVO);
                 });

src/main/java/com/care/client/controller/PassportController.java

@@ -1,5 +1,6 @@
 package com.care.client.controller;
 
+import cn.hutool.core.date.DateUtil;
 import com.care.client.service.PassportService;
 import com.care.client.vo.MemberInitParams;
 import com.care.common.entity.CareMemberInfo;
@@ -89,6 +90,7 @@ public class PassportController {
             CareMemberInfo careMemberInfo = new CareMemberInfo();
             careMemberInfo.setPhone(phone);
             careMemberInfo.setPassword(DigestUtils.md5Hex(password));
+            careMemberInfo.setCreateTime(DateUtil.date());
             boolean flag = careMemberInfoService.save(careMemberInfo);
             if (flag) {
                 return Result.success();

src/main/java/com/care/client/service/PinanbaoService.java

@@ -282,7 +282,8 @@ public class PinanbaoService {
     private  List<OrderHandleHisVO> queryOrderHandleHis(Long orderId){
         List<OrderHandleHisVO> orderHandleHisVOList = Lists.newArrayList();
         QueryWrapper<CareEventOrderHandleHis> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda().eq(CareEventOrderHandleHis::getOrderId,orderId)
+        queryWrapper.select("distinct org_id,station_id,house_id,order_id,log_type,order_type,log_object_id,log_object_name,log_result," +
+                "op_user_role,op_user_id,op_user_name,create_time,relation_type_desc,call_result_id").lambda().eq(CareEventOrderHandleHis::getOrderId,orderId)
                 .orderByDesc(CareEventOrderHandleHis::getCreateTime);
         List<CareEventOrderHandleHis> datas = this.careEventOrderHandleHisService.list(queryWrapper);
         if (CollUtil.isNotEmpty(datas)){

src/main/java/com/care/common/service/impl/CareEventOrderServiceImpl.java

@@ -13,6 +13,7 @@ import com.care.common.enums.*;
 import com.care.common.mapper.CareEventOrderMapper;
 import com.care.common.service.*;
 import com.care.common.vo.order.EventStaVO;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.compress.utils.Lists;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -28,6 +29,7 @@ import java.util.List;
  * @since 2021-05-21 00:08:29
  */
 @Service
+@Slf4j
 public class CareEventOrderServiceImpl extends ServiceImpl<CareEventOrderMapper, CareEventOrder> implements CareEventOrderService {
 
     @Resource
@@ -447,6 +449,8 @@ public class CareEventOrderServiceImpl extends ServiceImpl<CareEventOrderMapper,
                             his2.setCreateTime(DateUtil.date());
                             his2.setRelationTypeDesc(item.getRelationTypeDesc());
                             this.careEventOrderHandleHisService.save(his2);
+                        }else{
+                            log.error(" 事件取消短信通知失败 : 工单ID：{}, 联系人：{}",order.getId(),item);
                         }
                     });
                 }
@@ -472,6 +476,8 @@ public class CareEventOrderServiceImpl extends ServiceImpl<CareEventOrderMapper,
                             his2.setCreateTime(DateUtil.date());
                             his2.setRelationTypeDesc("管家");
                             this.careEventOrderHandleHisService.save(his2);
+                        }else {
+                            log.error(" 事件取消短信通知失败 : 工单ID：{}, 管家：{}",order.getId(),item);
                         }
                     });
                 }

src/main/java/com/care/installation/service/RoomService.java

@@ -3,6 +3,7 @@ package com.care.installation.service;
 
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.care.common.cache.RedisUtil;
@@ -435,7 +436,13 @@ public class RoomService {
                  mqttConnectorPoolService.addOne(careDevice);
                  //上线
                  careDevice.setStatus(DeviceStatusEnum.ONLINE.getValue());
-                 careDeviceService.updateById(careDevice);
+                 careDevice.setActiveTime(DateUtil.date());
+                 UpdateWrapper<CareDevice> updateWrapper = new UpdateWrapper<>();
+                 updateWrapper.lambda().eq(CareDevice::getId,careDevice.getId())
+                         .set(CareDevice::getStatus,careDevice.getStatus())
+                 .set(CareDevice::getActiveTime, careDevice.getActiveTime());
+                 careDeviceService.update(updateWrapper);
+                 //careDeviceService.updateById(careDevice);
 
                  //去除publish的客户端监听
                  mqttConnectorInstallPoolService.removeInstallOne(careDevice);

src/main/java/com/care/keeper/service/KeeperOrderApiService.java

@@ -404,7 +404,8 @@ public class KeeperOrderApiService {
     public List<OrderHandleHisVO> queryOrderHandleHis(Long orderId){
         List<OrderHandleHisVO> result = Lists.newArrayList();
         QueryWrapper<CareEventOrderHandleHis> queryWrapper = new QueryWrapper<>();
-        queryWrapper.lambda().eq(CareEventOrderHandleHis::getOrderId,orderId)
+        queryWrapper.select("distinct org_id,station_id,house_id,order_id,log_type,order_type,log_object_id,log_object_name,log_result," +
+                "op_user_role,op_user_id,op_user_name,create_time,relation_type_desc,call_result_id").lambda().eq(CareEventOrderHandleHis::getOrderId,orderId)
                 .orderByDesc(CareEventOrderHandleHis::getCreateTime);
         List<CareEventOrderHandleHis> datas = this.careEventOrderHandleHisService.list(queryWrapper);
         if (CollUtil.isNotEmpty(datas)){

src/main/resources/application-dev.properties

@@ -42,7 +42,7 @@ mqtt.username=shangxingkeji
 mqtt.password=sxkj@1234
 
 #是否开启mqtt消息接受服务，开启：1，不开启：0
-mqtt.on=1
+mqtt.on=0
 #设备激活返回消息超时(秒)
 mqtt.dev.jihuo.timeout=30
 

src/main/resources/application.properties

@@ -1,5 +1,5 @@
 # 激活指定环境配置文件
-spring.profiles.active=dev
+spring.profiles.active=prod
 
 # 配置服务端口号
 server.port=8889