提交会议会议审批

zqy

2024-04-30 50f8c2d9841ee74006ac25cc5e022eae69c55d2c

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

@@ -1,4 +1,130 @@
package com.ruoyi.service.impl;



public class MeetingRatifyServiceImpl {

}

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.Meeting;

import com.ruoyi.domain.ZInfoUser;

import com.ruoyi.domain.ZfLog;

import com.ruoyi.mapper.MeetingRatifyMapper;

import com.ruoyi.service.*;

import lombok.extern.slf4j.Slf4j;

import org.elasticsearch.action.update.UpdateRequest;

import org.elasticsearch.client.RequestOptions;

import org.elasticsearch.client.RestHighLevelClient;

import org.springframework.stereotype.Service;



import javax.annotation.Resource;

import java.io.IOException;

import java.time.LocalDateTime;

import java.util.HashMap;

import java.util.List;



@Slf4j

@Service

public class MeetingRatifyServiceImpl extends ServiceImpl<MeetingRatifyMapper, Meeting> implements MeetingRatifyService {



    @Resource

    ZInfoUserService zInfoUserService;



    @Resource

    ZfLogService zfLogService;



    @Resource

    private EsService esSer;



    @Resource

    private RestHighLevelClient restHighLevelClient;



    private LambdaQueryWrapper<Meeting> buildCondition(Meeting meeting) {

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

        //    lqw.in(ZfDoctor::getFamilyId,familyIdList);

        lqw.orderByDesc(Meeting::getCreateTime);

        lqw.like(StringUtils.isNotEmpty(meeting.getPlace()), Meeting::getPlace, meeting.getPlace())

                .like(StringUtils.isNotEmpty(meeting.getApplyApart()), Meeting::getApplyApart, meeting.getApplyApart());

//                .like(Integer.valueOf(meeting.getApplyPerson())!=null, Meeting::getApplyPerson, meeting.getApplyPerson());

        lqw.between(meeting.getHappenStartTime() != null && meeting.getHappenEndTime() != null, Meeting::getStartTime, meeting.getHappenStartTime(), meeting.getHappenEndTime());



        return lqw;

    }





    @Override

    public AjaxResult selectDataList(Meeting meeting, 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<Meeting> lqw = buildCondition(meeting);





        Page<Meeting> meetingPage = new Page<>(pageNum, pageSize);

        Page<Meeting> pageResult = page(meetingPage, lqw);



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

//        System.out.println(beanRecords);







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

        return AjaxResult.success(data);    }





    @Override

    public AjaxResult updateData(Meeting meeting) {



        ZfLog zfLog = new ZfLog();

        zfLog.setUpdateTime(LocalDateTime.now());

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

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

        zfLogService.save(zfLog);



        if (updateById(meeting)) {

            //到数据库中查询对应的数据

            Meeting dataById = getById(meeting.getId());



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

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

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

            if (esResult == null) {

                return AjaxResult.success();

            }



            //操作es修改数据

            EsModel newModel = new EsModel();

            if (meeting.getStatu() != 0) {

                newModel.setBy13(meeting.getStatu());

            } else {

                newModel.setBy13(dataById.getStatu());

            }



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

            updateRequest.doc(

                    "by12", newModel.getBy13()

            );

            try {

                restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);

            } catch (IOException e) {

                throw new RuntimeException(e);

            }



            return AjaxResult.success();

        } else {

            return AjaxResult.error();

        }

    }}