服务商

jiangping

2023-12-29 f9691d544e62d6c04dbfe45d05a6c7bc5e004291

 server/services/src/main/java/com/doumee/service/business/impl/SitesServiceImpl.java

@@ -119,6 +119,7 @@
        update.setName(sites.getName());
        update.setLockNum(sites.getLockNum());
        update.setIp(sites.getIp());
        update.setNeedNotice(sites.getNeedNotice());
        sitesMapper.updateById(update);
    }

@@ -147,6 +148,42 @@
    public List<Sites> findList(Sites sites) {
        QueryWrapper<Sites> wrapper = new QueryWrapper<>(sites);
        return sitesMapper.selectList(wrapper);
    }
    @Override
    public void  noticeNoLinkList(Sites sites) {
        //发送钉钉通知
        int second  =0;
        try {
            second = Integer.parseInt(systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.NOTICE_SITE_LINK_LIMIT).getCode());
        }catch (Exception e){

        }
        if(second <=0){
            return ;
        }
        sites.setIsdeleted(Constants.ZERO);
        sites.setStatus(Constants.ZERO);
        QueryWrapper<Sites> wrapper = new QueryWrapper<>(sites);
        wrapper.lambda().orderByDesc(Sites::getLastLinkDate);
        List<Sites> siteList =sitesMapper.selectList(wrapper);
        List<Sites> errorList = new ArrayList<>();
        for(Sites site : siteList){
            //时间查过通信异常阈值
            if(Constants.formatIntegerNum(site.getNeedNotice()) == Constants.ZERO
                    && System.currentTimeMillis()-site.getLastLinkDate().getTime() > second*1000){
                errorList.add(site);
            }
        }
        if(errorList.size()>0){
            try {
                DingDingNotice.siteNoLink(errorList,
                        systemDictDataBiz.queryByCode(Constants.DINGDING,Constants.DINGDING_URL).getCode(),
                        systemDictDataBiz.queryByCode(Constants.DINGDING,Constants.DINGDING_SECRET).getCode());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

    }

    @Override
@@ -195,13 +232,14 @@
        if (pageWrap.getModel().getClientVersion() != null) {
            queryWrapper.lambda().eq(Sites::getClientVersion, pageWrap.getModel().getClientVersion());
        }
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
         /*for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                queryWrapper.orderByDesc(sortData.getProperty());
            } else {
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        }*/
        queryWrapper.lambda().orderByAsc(Sites::getCode);
        return PageData.from(sitesMapper.selectPage(page, queryWrapper));
    }