From 1b7a35ff790fc52bfecb4e7a0fb318eac986ac46 Mon Sep 17 00:00:00 2001
From: 18756 <1875631620@qq.com>
Date: 星期四, 22 八月 2024 14:41:15 +0800
Subject: [PATCH] 会议室功能访问签到记录8.22

---
 src/main/java/com/product/administration/service/ConferenceManagerService.java |  146 +++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 131 insertions(+), 15 deletions(-)

diff --git a/src/main/java/com/product/administration/service/ConferenceManagerService.java b/src/main/java/com/product/administration/service/ConferenceManagerService.java
index f221f49..dbcc4c3 100644
--- a/src/main/java/com/product/administration/service/ConferenceManagerService.java
+++ b/src/main/java/com/product/administration/service/ConferenceManagerService.java
@@ -4,7 +4,6 @@
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSONObject;
-import com.google.errorprone.annotations.Var;
 import com.google.zxing.BarcodeFormat;
 import com.google.zxing.EncodeHintType;
 import com.google.zxing.MultiFormatWriter;
@@ -19,25 +18,19 @@
 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;
@@ -505,16 +498,23 @@
     }
 
     @Override
-    public HashMap getSignInfo(FieldSetEntity fse) throws BaseException {
+    public HashMap getSignOrVisitInfo(FieldSetEntity fse) throws BaseException {
 
        String meeting_uuid = fse.getString("meeting_uuid");
+       //type=1灏辨槸绛惧埌鏁版嵁锛宼ype=2灏辨槸璁块棶鏁版嵁
+       String type = fse.getString("type");
         List<Object> params=new ArrayList<>();
         params.add(meeting_uuid);
         params.add(meeting_uuid);
 
         StringBuilder sb=new StringBuilder();
         sb.append(" SELECT c.* FROM ( ");
-        sb.append(" SELECT b.staff_id,b.uuid as meeting_uuid,f.show_name,l.uuid as dept_uuid,l.org_level_name,n.sign_status ");
+        sb.append(" SELECT b.staff_id,b.uuid as meeting_uuid,f.show_name,l.uuid as dept_uuid,l.org_level_name,");
+        if(type.equals("1")){
+         sb.append(" n.sign_status");
+        }else {
+            sb.append(" n.visit_status");
+        }
         sb.append(" FROM (" );
         sb.append(" SELECT y.*, ");
         sb.append(" SUBSTRING_INDEX( SUBSTRING_INDEX( participator, ',', n ), ',', - 1 ) AS staff_id");
@@ -526,7 +526,12 @@
         sb.append(" )b ");
         sb.append(" LEFT JOIN product_sys_staffs f on b.staff_id=f.user_id ");
         sb.append(" LEFT JOIN product_sys_org_levels l on f.dept_uuid=l.uuid ");
-        sb.append(" LEFT JOIN product_oa_conference_sign n on b.staff_id=n.user_id and n.meeting_uuid=? ");
+        if(type.equals("1")){
+            sb.append(" LEFT JOIN product_oa_conference_sign n ");
+        }else {
+            sb.append(" LEFT JOIN product_oa_conference_visit n ");
+        }
+        sb.append(" on b.staff_id=n.user_id and n.meeting_uuid=? ");
         sb.append(" )c");
 
         DataTableEntity dataTableEntity = baseDao.listTable(sb.toString(),params.toArray());
@@ -595,11 +600,90 @@
             }
         }
         sign_down=sign_all-sign_count;
-        hashMapResult.put("sign_down",sign_count);
-        hashMapResult.put("no_sign",sign_down);
-        hashMapResult.put("listDateNoSign",listDateNoSign);
-        hashMapResult.put("listDateSign",listDateSign);
+        hashMapResult.put("signOrvisit_down",sign_count);
+        hashMapResult.put("no_signOrvisit",sign_down);
+        hashMapResult.put("listDateNoSignOrVisit",listDateNoSign);
+        hashMapResult.put("listDateSignOrVisit",listDateSign);
         return  hashMapResult;
+    }
+
+    @Override
+    public void sendMsg(FieldSetEntity fse) throws BaseException {
+
+        String meeting_uuid= fse.getString("meeting_uuid");
+        String type = fse.getString("type");
+        FieldSetEntity product_oa_conference_apply = baseDao.getFieldSetEntity("product_oa_conference_apply", meeting_uuid, false);
+
+        List<Object> params=new ArrayList<>();
+        params.add(meeting_uuid);
+        params.add(meeting_uuid);
+
+        StringBuilder sb=new StringBuilder();
+        sb.append(" SELECT c.* FROM ( ");
+        sb.append(" SELECT b.staff_id,b.uuid as meeting_uuid,f.show_name,l.uuid as dept_uuid,l.org_level_name,");
+        if(type.equals("1")){
+            sb.append(" n.sign_status");
+        }else {
+            sb.append(" n.visit_status");
+        }
+        sb.append(" FROM (" );
+        sb.append(" SELECT y.*, ");
+        sb.append(" SUBSTRING_INDEX( SUBSTRING_INDEX( participator, ',', n ), ',', - 1 ) AS staff_id");
+        sb.append(" FROM product_oa_conference_apply y, ");
+        sb.append(" ( SELECT @rownum := @rownum + 1 AS n FROM ( SELECT @rownum := 0 ) r, product_oa_conference_apply ) x ");
+        sb.append(" WHERE 1 = 1 ");
+        sb.append(" AND n <= ( LENGTH( participator ) - LENGTH( REPLACE ( participator, ',', '' ) ) + 1 )");
+        sb.append(" and y.uuid= ? ");
+        sb.append(" )b ");
+        sb.append(" LEFT JOIN product_sys_staffs f on b.staff_id=f.user_id ");
+        sb.append(" LEFT JOIN product_sys_org_levels l on f.dept_uuid=l.uuid ");
+        if(type.equals("1")){
+            sb.append(" LEFT JOIN product_oa_conference_sign n ");
+        }else {
+            sb.append(" LEFT JOIN product_oa_conference_visit n ");
+        }
+        sb.append(" on b.staff_id=n.user_id and n.meeting_uuid=? ");
+        sb.append(" )c");
+        if(type.equals("1")){
+            sb.append("  where c.sign_status is NULL");
+        }else {
+            sb.append("  where c.visit_status is NULL");
+        }
+
+        DataTableEntity dataTableEntity = baseDao.listTable(sb.toString(), params.toArray());
+          String user_ids = "";
+        for (int i = 0; i < dataTableEntity.getRows(); i++) {
+            FieldSetEntity fieldSetEntity = dataTableEntity.getFieldSetEntity(i);
+            if((i+1)==dataTableEntity.getRows()){
+                user_ids=user_ids+fieldSetEntity.getString("staff_id");
+            }else {
+                user_ids=user_ids+fieldSetEntity.getString("staff_id")+",";
+            }
+
+        }
+        String content="";
+        if(type.equals("1")){
+            content="浼氳灏嗗紑濮嬬鍒�,"+product_oa_conference_apply.getString("meeting_topic")+"-"+product_oa_conference_apply.getString("start_time")+",璇锋寜鏃剁鍒�";
+        }else {
+            content="鎮ㄦ湁鍦轰細璁渶瑕佸弬涓�,"+product_oa_conference_apply.getString("meeting_topic")+"-"+product_oa_conference_apply.getString("start_time")+",璇锋煡鐪嬩細璁鎯�";
+        }
+        SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
+        int user_id = currentUser.getUser_id();
+        String send_user=user_id+"";
+        String reminder_mode = product_oa_conference_apply.getString("reminder_mode");
+     /*   //鐭俊
+        if(reminder_mode.equals("0")){
+        }
+        //閭欢
+        if(reminder_mode.equals("1")){
+
+        }
+        //绯荤粺娑堟伅
+        if(reminder_mode.equals("2")){
+
+        }*/
+        WebsocketMesssageServiceThread.getInstance().appendMessage(user_ids, content, "浼氳鎻愰啋", 1,"1", "", "", send_user, 1, 0, 0);
+
     }
 
 
@@ -841,6 +925,38 @@
             fieldSetEntity.setValue(CmnConst.CREATED_BY, fieldSetEntity.getString(CmnConst.CREATED_BY + "_save_value"));
             fieldSetEntity.setValue("meetint_type", fieldSetEntity.getString("meetint_type_save_value"));
         }
+
+
+        //瀛樺偍璁块棶璁板綍
+        SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
+        String fliter="meeting_uuid='"+fse.getUUID()+"' and  user_id='"+currentUser.getUser_id()+"'";
+        DataTableEntity product_oa_conference_visit = baseDao.listTable("product_oa_conference_visit", fliter);
+
+        if(product_oa_conference_visit.getRows()!=0){
+            FieldSetEntity fieldSetEntity1 = product_oa_conference_visit.getFieldSetEntity(0);
+            Integer visit_count = fieldSetEntity1.getInteger("visit_count");
+            visit_count++;
+            fieldSetEntity1.setValue("visit_count",visit_count);
+            fieldSetEntity1.setValue("visit_date_new",new Date());
+            baseDao.update(fieldSetEntity1);
+        }else {
+        FieldSetEntity fieldSetEntityVisit = new FieldSetEntity();
+        fieldSetEntityVisit.setTableName("product_oa_conference_visit");
+        fieldSetEntityVisit.setValue("visit_user",currentUser.getUser_name());
+        fieldSetEntityVisit.setValue("user_id",currentUser.getUser_id());
+        fieldSetEntityVisit.setValue("org_level_uuid","00000000-0000-0000-0000-000000000000");
+        fieldSetEntityVisit.setValue("organization",currentUser.getDept_uuid());
+        fieldSetEntityVisit.setValue("organization_name",currentUser.getCurrentDept().getString("org_level_name"));
+        fieldSetEntityVisit.setValue("visit_date_first",new Date());
+        fieldSetEntityVisit.setValue("visit_date_new",new Date());
+        fieldSetEntityVisit.setValue("visit_count",1);
+        fieldSetEntityVisit.setValue("visit_status","宸茶闂�");
+        fieldSetEntityVisit.setValue("meeting_uuid",fse.getUUID());
+        BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), fieldSetEntityVisit);
+        baseDao.add(fieldSetEntityVisit);
+        }
+
+
         return fieldSetEntity;
     }
 

--
Gitblit v1.9.2