用户修改姓名和电话同步修改uaid

zqy

5 天以前 b02beccf4567068cb47a3f1181a00039456c872d

 zhang-content/src/main/java/com/ruoyi/service/impl/MeetingStatisticServiceImpl.java

@@ -1,9 +1,11 @@
package com.ruoyi.service.impl;



import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import com.ruoyi.common.core.domain.AjaxResult;

import com.ruoyi.common.core.domain.entity.EsModel;

import com.ruoyi.common.utils.MapUtils;

import com.ruoyi.common.utils.StringUtils;

import com.ruoyi.domain.*;

import com.ruoyi.mapper.MeetingStatisticMapper;

@@ -17,12 +19,7 @@
import javax.annotation.Resource;

import java.io.IOException;

import java.time.LocalDateTime;

import java.util.Arrays;

import java.util.List;

import java.util.UUID;

import java.util.stream.Collectors;



import static com.ruoyi.constant.MenuAuthority.EVENT_LIST_ADD;

import java.util.*;





@Slf4j

@@ -59,13 +56,72 @@
        lqw.eq(!StringUtils.isEmpty(String.valueOf(meetingStatistic.getFamilyId())), MeetingStatistic::getFamilyId, meetingStatistic.getFamilyId());

        return lqw;

    }

    public static void getDatePoor(Date endDate, Date nowDate, MeetingStatistic meetingStatistic) {



        long nd = 1000 * 24 * 60 * 60;

        long nh = 1000 * 60 * 60;

        long nm = 1000 * 60;

         long ns = 1000;

        // 获得两个时间的毫秒时间差异

        long diff = endDate.getTime() - nowDate.getTime();

        // 计算差多少天

//        long day = diff / nd;

        // 计算差多少小时

        long hour = diff % nd / nh;

        // 计算差多少分钟

        long min = diff % nd % nh / nm;

        // 计算差多少秒//输出结果

         long sec = diff % nd % nh % nm / ns;

        System.out.println(hour + "小时" + min + "分钟"+ sec + "秒");

        meetingStatistic.setUseTime(hour + "小时" + min + "分钟" + sec + "秒");

    }

    private LambdaQueryWrapper<MeetingStatistic> buildCondition(MeetingStatistic meetingStatistic) {

        LambdaQueryWrapper<MeetingStatistic> lqw = new LambdaQueryWrapper<>();

        lqw.select(MeetingStatistic::getFamilyId,MeetingStatistic::getCreateTime);

        return lqw;

    }

    @Override

    public AjaxResult selectDataList(MeetingStatistic meetingStatistic, Integer pageNum, Integer pageSize) {

        //要查自己家庭的

        ZInfoUser myself = zInfoUserService.getMyself();

        if(myself==null)

        {

            //   System.out.println("ssssss");

            return AjaxResult.success("您没加入到对应的家庭，请联系管理员");

        }

        Long familyId = myself.getFamilyId();

//        //也要查别人授权的

//        List<ZAuthority> authority = zAuthorityService.getAuthority();

//        List<Long> idList = authority.stream().filter(auth -> auth.getAuthority().toString().equals(DOCTOR_LIST)).map(ZAuthority::getFid).collect(Collectors.toList());

//        //加上自己家庭的id

//        idList.add(familyId);

//        String familyIds = listFamilyIds();

//        String secondFamilyAuthority = listSecondFamilyIds();

        LambdaQueryWrapper<MeetingStatistic> lqw = new LambdaQueryWrapper<>();

//        LambdaQueryWrapper<MeetingStatistic> lqw = buildCondition(meetingStatistic);





        Page<MeetingStatistic> meetingStatisticPage = new Page<>(pageNum, pageSize);

        Page<MeetingStatistic> pageResult = page(meetingStatisticPage, lqw);



        List<MeetingStatistic> beanRecords = pageResult.getRecords();//得到查询出来的数据

        System.out.println("-----------数据库-----------"+beanRecords);

        HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords);

        return AjaxResult.success(data);

    }

    @Override

    public AjaxResult DataList(MeetingStatistic meetingStatistic) {

        LambdaQueryWrapper<MeetingStatistic> lambdaQueryWrapper = buildCondition(meetingStatistic);

        List<MeetingStatistic> beanRecords = list(lambdaQueryWrapper);

        log.info("从数据库中查到的为:{}", beanRecords);

        return  AjaxResult.success(beanRecords);

    }



    @Override

    public AjaxResult updateData(MeetingStatistic meetingStatistic) {

        ZfLog zfLog = new ZfLog();

        zfLog.setUpdateTime(LocalDateTime.now());

        zfLog.setModule("会议审批");

        zfLog.setModule("会议统计");

        zfLog.setUpdater(zInfoUserService.getMyself().getNickName());

        zfLogService.save(zfLog);

        System.out.println("===================================="+meetingStatistic);

@@ -74,7 +130,7 @@
            MeetingStatistic dataById = getById(meetingStatistic.getId());



            //先到es中查询到对应那条数据在es的id

            EsModel esResult = esSer.findByCtId(dataById.getId().intValue(), "会议");

            EsModel esResult = esSer.findByCtId(dataById.getId().intValue(), "会议统计");

            System.out.println("===================================="+meetingStatistic);

            if (esResult == null){

                return AjaxResult.success();

@@ -85,26 +141,41 @@
//            System.out.println(meeting);

//            System.out.println("=============="+meetingStatistic.getConnPhone());



//            if(meetingStatistic.getUseTime()!=null){

//                newModel.setBy2(meetingStatistic.getUseTime());

//            }else {

//                newModel.setBy2(dataById.getUseTime());

//           if (meetingStatistic.getUseTime()==null){

//                if(meetingStatistic.getHappenEndTime()!=null && meetingStatistic.getHappenStartTime() !=null){

//                  getDatePoor(meetingStatistic.getHappenEndTime(),meetingStatistic.getHappenStartTime(),meetingStatistic);

//                    System.out.println("===============使用时间====================="+meetingStatistic.getUseTime());

//                    newModel.setBy2(meetingStatistic.getUseTime());

//                }else {

//                    newModel.setBy2(dataById.getUseTime());

//                }

//            }

            if (meetingStatistic.getUseTime()==null){

                if(meetingStatistic.getHappenEndTime()!=null && meetingStatistic.getHappenStartTime() !=null){

                    getDatePoor(meetingStatistic.getHappenEndTime(),meetingStatistic.getHappenStartTime(),meetingStatistic);

                    newModel.setBy1(meetingStatistic.getUseTime());

                }

                else {

                    newModel.setBy1(dataById.getUseTime());

                }

            }else {

                newModel.setBy1(dataById.getUseTime());

            }

//            if(meetingStatistic.getConferenceRoom()!=null){

//                newModel.setBy3(meetingStatistic.getConferenceRoom());

//            }else {

//                newModel.setBy3(dataById.getConferenceRoom());

//            }

            if(meetingStatistic.getTitle()!=null){

                newModel.setBy4(meetingStatistic.getTitle());

                newModel.setBy2(meetingStatistic.getTitle());

            }else {

                newModel.setBy4(dataById.getTitle());

                newModel.setBy2(dataById.getTitle());

            }

            if(meetingStatistic.getApplyPerson()!=null){

                newModel.setBy5(meetingStatistic.getApplyPerson());

            }else {

                newModel.setBy5(dataById.getApplyPerson());

            }

//            if(meetingStatistic.getApplyPerson()!=null){

//                newModel.setBy5(meetingStatistic.getApplyPerson());

//            }else {

//                newModel.setBy5(dataById.getApplyPerson());

//            }

//            if(meetingStatistic.getRatifyPerson() == 0){

//                newModel.setBy10(meetingStatistic.getRatifyPerson());

//            }else {

@@ -117,15 +188,21 @@
//            }

            UpdateRequest updateRequest = new UpdateRequest("allsearchdata", esResult.getId());

            updateRequest.doc(

                    "by1",newModel.getBy4(),

                    "by2",newModel.getBy5()

                    "by1",newModel.getBy1(),

                    "by2",newModel.getBy2()



            );



            LambdaQueryWrapper<MeetingStatistic> lqw = new LambdaQueryWrapper<>();

            List<MeetingStatistic> beanRecords = list(lqw);

            log.info("sss从数据库中查到的为:{}", beanRecords);



            try {

                restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);

            } catch (IOException e) {

                throw new RuntimeException(e);

            }





            return AjaxResult.success();

        }else {

@@ -139,7 +216,7 @@
        if (meetingStatisticService.removeByIds(Arrays.asList(ids))) {

            //删除es中的数据

            meetings.stream().forEach(meeting -> {

                EsModel esModel = esSer.findByCtId((meeting.getId().intValue()), "会议");

                EsModel esModel = esSer.findByCtId((meeting.getId().intValue()), "会议统计");

                if (esModel != null){

                    DeleteRequest deleteRequest = new DeleteRequest("allsearchdata", esModel.getId());

                    try {

@@ -158,33 +235,38 @@
    }



    @Override

    public AjaxResult countData(Long[] familyId ,String applyPerson) {

        return null;

    }

    public List<MeetingStatistic> selectByIds(Long[] ids) {

        List<MeetingStatistic> list = new ArrayList<>();

        if (ids.length != 0)

            list = listByIds(Arrays.asList(ids));

        else

            list = list();

        return list;



    }

    @Override

    public AjaxResult addData(MeetingStatistic meetingStatistic) {



        ZInfoUser myself = zInfoUserService.getMyself();

        Long familyId = myself.getFamilyId();



        if(familyId == null){

            throw new RuntimeException("您还未加入任何家庭");

        }



        List<ZAuthority> authority = zAuthorityService.getAuthority();

        List<Long> familyIdList = authority.stream().filter(auth -> auth.getAuthority().toString().equals(EVENT_LIST_ADD)).map(ZAuthority::getFid).collect(Collectors.toList());

        familyIdList.add(familyId);



        if (meetingStatistic.getFamilyId()!=null && !familyIdList.contains(meetingStatistic.getFamilyId())) {

            throw new RuntimeException("你没有权限操作此家庭的数据");

        }





        if(meetingStatistic.getFamilyId() == null){

            //默认添加自己家庭的数据

            meetingStatistic.setFamilyId(familyId);

        }

//        if(familyId == null){

//            throw new RuntimeException("您还未加入任何家庭");

//        }

//

//        List<ZAuthority> authority = zAuthorityService.getAuthority();

//        List<Long> familyIdList = authority.stream().filter(auth -> auth.getAuthority().toString().equals(EVENT_LIST_ADD)).map(ZAuthority::getFid).collect(Collectors.toList());

//        familyIdList.add(familyId);

//

//        if (meetingStatistic.getFamilyId()!=null && !familyIdList.contains(meetingStatistic.getFamilyId())) {

//            throw new RuntimeException("你没有权限操作此家庭的数据");

//        }

//

//

//        if(meetingStatistic.getFamilyId() == null){

//            //默认添加自己家庭的数据

//            meetingStatistic.setFamilyId(familyId);

//        }



        //判断是否有重复数据

        LambdaQueryWrapper<MeetingStatistic> lqw = uniqueCondition(meetingStatistic);

@@ -201,8 +283,11 @@
            esModel.setId(uuid);

            esModel.setCtId(inte);

            esModel.setCtTableName("会议统计");

            esModel.setBy1(meetingStatistic.getTitle());

            esModel.setBy5(meetingStatistic.getApplyPerson());

            getDatePoor(meetingStatistic.getHappenEndTime(),meetingStatistic.getHappenStartTime(),meetingStatistic);

            System.out.println("===============使用时间2====================="+meetingStatistic.getUseTime());

            esModel.setBy1(meetingStatistic.getUseTime());

            esModel.setBy2(meetingStatistic.getTitle());

//            esModel.setBy5(meetingStatistic.getApplyPerson());

            //这里存储查询详情的路径

            esModel.setBy5("/zMeetingStatistic");

            esModel.setFid(familyId);