浏览代码

健康小屋- 临时提交

huangzhiyong 6 年之前
父节点
当前提交
9f68129a91

+ 4 - 2
svr/svr-healthy-house/src/main/java/com/yihu/jw/healthyhouse/controller/user/FacilityUsedRecordController.java

@ -79,7 +79,9 @@ public class FacilityUsedRecordController extends EnvelopRestEndpoint {
            @RequestBody FacilityUsedRecord facilityUsedRecord) throws IOException, ManageException {
        facilityUsedRecord.setUserId(facilityUsedRecord.getCreateUser());
        facilityUsedRecord = facilityUsedRecordService.save(facilityUsedRecord);
        userService.updateFacilityUse(facilityUsedRecord.getCreateUser());
        if (facilityUsedRecord.getCreateUser() != null) {
            userService.updateFacilityUse(facilityUsedRecord.getCreateUser());
        }
        return success(facilityUsedRecord);
    }
@ -223,7 +225,7 @@ public class FacilityUsedRecordController extends EnvelopRestEndpoint {
            }
            //根据设施编码获取 设施状态
            Facility facility = facilityService.findByCode(facilityCode);
            if (facility!=null) {
            if (facility != null) {
                record.setFacilitieStatus(facility.getStatus());
            }
        }

+ 7 - 4
svr/svr-healthy-house/src/main/java/com/yihu/jw/healthyhouse/job/ActivatedUserUpdateTask.java

@ -18,7 +18,7 @@ import java.util.*;
/**
 * Task - 定时检查集群状态,提高解析任务容错率
 * Task - 定时更新在线用户状态
 * Created by progr1mmer on 2017/12/15.
 */
@Component
@ -34,10 +34,13 @@ public class ActivatedUserUpdateTask {
        List<String> keys = new ArrayList<>();
        String pattern = "healthyHouse:*:activated";
        Set<String> keys1 = redisClient.keys(pattern);
        List<Serializable> ids = redisClient.multiGet(keys1);
        try {
            if (ids!=null && ids.size()>0) {
                userService.updateUserOffLine(ids);
            if (keys1 !=null && keys1.size()>0){
                List<Serializable> ids = redisClient.multiGet(keys1);
                if (ids!=null && ids.size()>0) {
                    userService.updateUserOffLine(ids);
                }
            }
        } catch (ManageException e) {
            e.printStackTrace();