product-server-administration
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
许鹏程
2024-08-21 ab7ddb13ba6ea769748d1ee67255a53ad7913554 
 src/main/java/com/product/administration/service/ConferenceManagerService.java


@@ -1,6 +1,13 @@


package com.product.administration.service;




import cn.hutool.core.util.ObjectUtil;


import com.alibaba.fastjson.JSONObject;


import com.google.zxing.BarcodeFormat;


import com.google.zxing.EncodeHintType;


import com.google.zxing.MultiFormatWriter;


import com.google.zxing.WriterException;


import com.google.zxing.common.BitMatrix;


import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;


import com.product.administration.config.CmnConst;


import com.product.administration.config.SystemCode;


import com.product.administration.service.ide.IConferenceManagerService;


@@ -9,18 +16,26 @@


import com.product.core.dao.BaseDao;


import com.product.core.entity.DataTableEntity;


import com.product.core.entity.FieldSetEntity;


import com.product.core.entity.RequestParameterEntity;


import com.product.core.exception.BaseException;


import com.product.core.permission.PermissionService;


import com.product.core.service.support.AbstractBaseService;


import com.product.core.service.support.QueryFilterService;


import com.product.core.spring.context.SpringMVCContextHolder;


import com.product.core.transfer.Transactional;


import com.product.core.util.QuickResponUtil;


import com.product.core.websocket.service.WebsocketMesssageServiceThread;


import com.product.module.sys.entity.SystemUser;


import com.product.util.BaseUtil;


import org.apache.poi.hssf.usermodel.HSSFCellStyle;


import org.omg.CORBA.OBJ_ADAPTER;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;




import javax.imageio.ImageIO;


import java.awt.image.BufferedImage;


import java.io.File;


import java.io.IOException;


import java.text.DecimalFormat;


import java.text.Format;


import java.text.SimpleDateFormat;


@@ -201,10 +216,11 @@


    }




    @Override


    @Transactional


    public List getKbData(FieldSetEntity fse) throws BaseException {




        List<Object>param=new ArrayList<>();


       String meeting_date= fse.getString("meeting_date");


        String meeting_date= fse.getString("meeting_date");


        String meeting_resource = fse.getString("meeting_resource");


        param.add(meeting_date);


        if(!StringUtils.isEmpty(meeting_resource)){


@@ -226,9 +242,26 @@


        DataTableEntity dataTableEntity = baseDao.listTable(bs.toString(), param.toArray());


        List<String> list=new ArrayList();


        List<HashMap> listDate=new ArrayList<>();


        //构造所需要的格式




        for(int i=0;i<dataTableEntity.getRows();i++){


            FieldSetEntity fieldSetEntity = dataTableEntity.getData().get(i);




            //初始化会议室的使用的状态


            String filter=" meeting_room = '"+fieldSetEntity.getString("meeting_room")+"' and DATE_FORMAT(start_time,\"%Y-%m-%d\") ='"+meeting_date+"'";


            DataTableEntity product_oa_conference_apply = baseDao.listTable("product_oa_conference_apply", filter, new Object[]{});


            for (int i1 = 0; i1 < product_oa_conference_apply.getRows(); i1++) {


                FieldSetEntity fieldSetEntity1 = product_oa_conference_apply.getFieldSetEntity(i1);


                Date date = new Date();


                if(date.before(fieldSetEntity1.getDate("start_time"))){


                    fieldSetEntity1.setValue("status","未开始");


                }else if(date.after(fieldSetEntity1.getDate("end_time"))){


                    fieldSetEntity1.setValue("status","已结束");


                }else {


                    fieldSetEntity1.setValue("status","会议中");


                }


               baseDao.executeUpdate("update product_oa_conference_apply set status='"+fieldSetEntity1.getString("status")+"' where uuid='"+fieldSetEntity1.getString("uuid")+"'");


            }


            //构造所需要的格式


            if(!list.contains(fieldSetEntity.getValue("room_name").toString())){


                HashMap<String,Object> hashMap=new HashMap<>();


                hashMap.put("room_name",fieldSetEntity.getValue("room_name").toString());


@@ -249,6 +282,11 @@


                    SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


                    String time = dateFormat.format(meeting_time);


                    hashMap.put(fieldSetEntity.getValues().keySet().toArray()[j].toString(),time);


                    if(fieldSetEntity.getValues().keySet().toArray()[j].equals("start_time")){


                        hashMap.put("start_date",time);


                    }else {


                        hashMap.put("end_date",time);


                    }


                }else {


                    hashMap.put(fieldSetEntity.getValues().keySet().toArray()[j].toString(),fieldSetEntity.getValue(fieldSetEntity.getValues().keySet().toArray()[j].toString()));


                }


@@ -261,53 +299,162 @@


    }




    @Override


    public DataTableEntity getMeetingDetails(FieldSetEntity fse) throws BaseException {




        //String uuid = fse.getString("uuid");


        String uuid="96f161b4-6360-40ba-8dc1-72bb39d56be4";


        /*if(!StringUtils.isEmpty(uuid)){*/


    public List getMeetingDetails(FieldSetEntity fse) throws BaseException {


        String meeting_room = fse.getString("meeting_room");


        String meeting_date = fse.getString("meeting_date");


        if(!StringUtils.isEmpty(meeting_room)&&!StringUtils.isEmpty(meeting_date)){


            List<Object>param=new ArrayList<>();


            param.add(uuid);


            param.add(meeting_room);


            param.add(meeting_date);


            StringBuilder sb=new StringBuilder();


            sb.append(" SELECT b.uuid,b.start_time,b.end_time,b.record_man,b.record_master,b.status, ");


            sb.append(" SELECT b.uuid,b.start_time,b.end_time,b.meeting_topic,b.status,b.record_man as record_man_uuid, ");


            sb.append(" (select user_name from product_sys_users where user_id=b.record_man) as record_man,");


            sb.append(" (select user_name from product_sys_users where user_id=b.record_master) as record_master,");


            sb.append(" CONCAT(DATE_FORMAT(b.start_time,\"%H-%i-%S\"),'~',DATE_FORMAT(b.end_time,\"%H-%i-%S\"))  as time_quantum,");


            sb.append(" DATE_FORMAT(b.start_time,\"%Y-%m-%d\") as meeting_date,");


            sb.append(" GROUP_CONCAT(b.dict_label   SEPARATOR ',') AS meeting_resouces ");


            sb.append(" FROM (");


            sb.append(" SELECT DISTINCT a.uuid,a.start_time,a.end_time,a.record_man,a.record_master,a.status,t.dict_label ");


            sb.append(" SELECT DISTINCT a.uuid,a.start_time,a.end_time,a.meeting_topic,a.record_man,a.record_master,a.status,t.dict_label ");


            sb.append(" FROM (");


            sb.append("  SELECT T1.*, ");


            sb.append(" SUBSTRING_INDEX( SUBSTRING_INDEX( T1.meeting_resource, ',', T2.digit + 1 ), ',',- 1 ) AS type ");


            sb.append(" FROM product_oa_conference_apply T1 ");


            sb.append(" JOIN ( SELECT 0 AS digit UNION ALL SELECT 1 UNION ALL SELECT 2 UNION ALL SELECT 3 UNION ALL SELECT 4 UNION ALL SELECT 5 ) T2");


            sb.append(" LEFT JOIN ( SELECT 0 AS digit UNION ALL SELECT 1 UNION ALL SELECT 2 UNION ALL SELECT 3 UNION ALL SELECT 4 UNION ALL SELECT 5 ) T2");


            sb.append(" ON T2.digit < ( length( T1.meeting_resource )- length( REPLACE ( T1.meeting_resource, ',', '' ))+ 1 )");


            sb.append(" WHERE t1.uuid = ? ");


            sb.append(" WHERE T1.meeting_room = ? ");


            sb.append(" and DATE_FORMAT(T1.start_time,\"%Y-%m-%d\")=? ");


            sb.append(" ) a");


            sb.append(" LEFT JOIN product_sys_dict t ON a.type = t.dict_value ");


            sb.append(" AND t.dict_name = '会议室资源'");


            sb.append(" )b ");


            sb.append(" group by b.uuid,b.start_time,b.end_time,b.record_man,b.record_master,b.status ");


            sb.append(" group by b.uuid,b.start_time,b.end_time,b.meeting_topic,b.record_man,b.record_master,b.status ");


            DataTableEntity dataTableEntity = baseDao.listTable(sb.toString(), param.toArray());




          List dataList =new ArrayList();


            for (int i = 0; i < dataTableEntity.getRows(); i++) {


                Date date = new Date();


                String uuid1 = dataTableEntity.getData().get(0).getString("uuid");


                String filter="uuid = '"+uuid1+"'";


                DataTableEntity product_oa_conference_apply = baseDao.listTable("product_oa_conference_apply", filter, new Object[]{});


                if(date.before(dataTableEntity.getData().get(0).getDate("start_time"))){


                    product_oa_conference_apply.getData().get(0).setValue("status","未开始");


                }else if(date.after(dataTableEntity.getData().get(0).getDate("end_time"))){


                    product_oa_conference_apply.getData().get(0).setValue("status","已取消");




                }else {


                    product_oa_conference_apply.getData().get(0).setValue("status","会议中");


                FieldSetEntity fieldSetEntity = dataTableEntity.getData().get(i);


                Map<Object, Object> MapValues = fieldSetEntity.getValues();


                if(ObjectUtil.isNotEmpty(MapValues.get("start_time")) || ObjectUtil.isNotEmpty( MapValues.get("end_time"))){


                    Object start_time = MapValues.get("start_time");


                    Object end_time = MapValues.get("end_time");


                    SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


                    String start_time_date = dateFormat.format(start_time);


                    String end_time_date = dateFormat.format(end_time);


                   MapValues.put("start_time",start_time_date);


                   MapValues.put("end_time",end_time_date);


                }


                baseDao.update(product_oa_conference_apply);




                Date date = new Date();


                //是否能够取消


                if(date.before(fieldSetEntity.getDate("start_time"))){


                   MapValues.put("isCancel",true);


                }


                //是否执行开启功能


                if(date.before(fieldSetEntity.getDate("start_time")) && fieldSetEntity.getString("status").equals("已取消")){


                    MapValues.put("isStart",true);


                }


                dataList.add(MapValues);


            }


            return  dataTableEntity;


       /* }else {


            return  dataList;


        }else {


            return null;


        }*/


        }




    }




    @Override


    @Transactional


    public HashMap saveOrUpdateMeetingInfo(FieldSetEntity fse) throws BaseException {




        Date start_time_date = fse.getDate("start_time");


        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


        String format = dateFormat.format(start_time_date);






        String filter=" DATE_FORMAT(start_time,\"%Y-%m-%d\") ='"+format.split(" ")[0]+"'";




        DataTableEntity dataTableEntity = baseDao.listTable("product_oa_conference_apply",filter,new Object[]{});


        boolean flag=true;


        for (int i = 0; i < dataTableEntity.getRows(); i++) {


            FieldSetEntity fieldSetEntity = dataTableEntity.getData().get(i);


            Date start_time = fse.getDate("start_time");


            Date end_time = fse.getDate("end_time");


            Date start_time1 =fieldSetEntity.getDate("start_time");


            Date end_time1 = fieldSetEntity.getDate("end_time");


            if(start_time1.before(start_time) && end_time1.after(start_time)){


                flag=false;


            }


            if(start_time1.before(end_time) && end_time1.after(end_time)){


                flag=false;


            }




            if(start_time1.after(start_time) && end_time1.before(end_time)){


                flag=false;


            }




        }


        HashMap<String,Object> hashMap=new HashMap<>();


        BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), fse);


        if(flag==false){


            hashMap.put("code","200");


            hashMap.put("msg","此时间段已被占用");


            hashMap.put("status","sucess");


        }else {


            if(ObjectUtil.isNotEmpty(fse.getValue("uuid"))){


                baseDao.update(fse);


            }else {


                baseDao.add(fse);


            }


            hashMap.put("code","200");


            hashMap.put("msg","成功");


            hashMap.put("status","sucess");


        }


        return hashMap;


    }




    @Override


    public BitMatrix getQrCode(String content) throws BaseException, WriterException, IOException {




        //二维码的宽高


        int width = 200;


        int height = 200;




        //其他参数，如字符集编码


        Map<EncodeHintType, Object> hints = new HashMap<EncodeHintType, Object>();


        hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");


        //容错级别为H


        hints.put(EncodeHintType.ERROR_CORRECTION , ErrorCorrectionLevel.H);


        //白边的宽度，可取0~4


        hints.put(EncodeHintType.MARGIN , 0);




        BitMatrix bitMatrix = null;


        try {




            bitMatrix = new MultiFormatWriter().encode(content,


                    BarcodeFormat.QR_CODE, width, height, hints);




        } catch (WriterException e) {


            e.printStackTrace();


        }




        return bitMatrix;


    }




    @Override


    public void CancelAndStart(FieldSetEntity fse) throws BaseException {




        String uuid = fse.getString("uuid");


        String filter=" uuid='"+uuid+"'";


        DataTableEntity product_oa_conference_apply = baseDao.listTable("product_oa_conference_apply", filter, new Object[]{});


        if(product_oa_conference_apply.getRows()!=0){


            FieldSetEntity fieldSetEntity = product_oa_conference_apply.getFieldSetEntity(0);


            if(fieldSetEntity.getString("status").equals("已取消")){


                fieldSetEntity.setValue("status","已启用");


            }else {


                fieldSetEntity.setValue("status","已取消");


            }


            baseDao.update(fieldSetEntity);


        }




    }




@@ -344,8 +491,8 @@


            sql.append(" b.end_time, ");


        }


        sql.append(" b.flow_flag, ");


        sql.append(" ( SELECT user_name FROM product_sys_users WHERE user_id = b.created_by ) proposer ");


        sql.append(" FROM ");


        sql.append(" ( SELECT user_name FROM product_sys_users WHERE user_id = b.created_by ) proposer ");


        sql.append(" product_oa_CONFERENCE_room_config a ");


        sql.append(" LEFT JOIN ( SELECT flow_flag,meeting_room,uuid,meeting_topic,start_time,end_time,created_by FROM  ");


        sql.append(" product_oa_conference_apply b WHERE ");