From a99c53cea03d87e71109824edb56cfcd33c38cbb Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期五, 31 五月 2024 15:54:48 +0800
Subject: [PATCH] 代码初始化

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java |  217 ++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 179 insertions(+), 38 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java
index ad7ed25..72e088c 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java
@@ -1,16 +1,20 @@
 package com.doumee.service.business.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.doumee.biz.system.SystemDictDataBiz;
 import com.doumee.core.constants.ResponseStatus;
 import com.doumee.core.exception.BusinessException;
 import com.doumee.core.model.PageData;
 import com.doumee.core.model.PageWrap;
 import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.DateUtil;
 import com.doumee.core.utils.Utils;
 import com.doumee.dao.business.*;
 import com.doumee.dao.business.dao.CompanyMapper;
 import com.doumee.dao.business.dto.ApproveDTO;
 import com.doumee.dao.business.join.ApproveJoinMapper;
+import com.doumee.dao.business.join.CarUseBookJoinMapper;
+import com.doumee.dao.business.join.VisitsJoinMapper;
 import com.doumee.dao.business.model.*;
 import com.doumee.dao.business.vo.ApproveDataVO;
 import com.doumee.dao.system.join.NoticesJoinMapper;
@@ -74,7 +78,14 @@
     private VisitsMapper visitsMapper;
 
     @Autowired
+    private VisitsJoinMapper visitsJoinMapper;
+
+    @Autowired
+    private CarUseBookJoinMapper carUseBookJoinMapper;
+    @Autowired
     private NoticesJoinMapper noticesJoinMapper;
+
+
 
     @Override
     public Integer create(Approve approve) {
@@ -301,11 +312,33 @@
         for (int i = 0; i < approveParamList.size(); i++) {
             ApproveParam approveParam = approveParamList.get(i);
             List<Integer> ids = this.getApproveUserIds(approveParam,createMember);
-            //鐢熸垚寰呭姙 notices 琛ㄦ暟鎹�
-            if(i==0){
-
-            }
-            for (Integer memberId:ids) {
+            Integer noticeType = Constants.approveTypeToNoticeType(approveTempl.getType());
+            String title = "銆愯瀹㈢敵璇枫�戠敵璇蜂汉 - ";
+            Map<String,Object> jsonMap = new HashMap<>();
+            for (int j = 0; j < ids.size(); j++) {
+                Integer memberId = ids.get(j);
+                //鐢熸垚寰呭姙 notices 琛ㄦ暟鎹�
+                if(i==0){
+                    if(jsonMap.isEmpty()){
+                        title = this.createNoticesData(noticeType,businessId,title,jsonMap);
+                    }
+                    Notices notices = new Notices();
+                    notices.setCreateDate(new Date());
+                    notices.setIsdeleted(Constants.ZERO);
+                    notices.setObjId(businessId);
+                    notices.setObjType(noticeType);
+                    notices.setType(noticeType);
+                    notices.setTitle(title);
+                    notices.setParam1(JSONObject.toJSONString(jsonMap));
+                    notices.setUserId(memberId);
+                    notices.setPalt(Constants.ZERO);
+                    notices.setStatus(Constants.ZERO);
+                    notices.setReaded(Constants.ZERO);
+                    notices.setSendacopy(Constants.ZERO);
+                    notices.setParam2("0");
+                    notices.setInfo("寰呭鐞�");
+                    noticesJoinMapper.insert(notices);
+                }
                 Approve approve = new Approve();
                 approve.setRemark(approveParam.getRemark());
                 approve.setCreateDate(new Date());
@@ -327,29 +360,59 @@
         }
     }
 
-    public void createNoticesData(List<Approve> approveList){
-        for (Approve approve:approveList) {
-            Notices notices = new Notices();
-            notices.setCreateDate(new Date());
-            notices.setIsdeleted(Constants.ZERO);
-            notices.setObjId(approve.getObjId());
-            notices.setObjId(approve.getApproveType());
-            if(Constants.equalsInteger(approve.getType(),Constants.approveObjectType.unConstructionVisit)
-            || Constants.equalsInteger(approve.getType(),Constants.approveObjectType.constructionVisit)){
-                notices.setType(Constants.ZERO);
-            }else if(Constants.equalsInteger(approve.getType(),Constants.approveObjectType.visitReporting)){
-                notices.setType(Constants.ONE);
+
+
+    public String createNoticesData(Integer noticeType,Integer businessId,String title,Map<String,Object> jsonMap){
+        jsonMap.clear();
+        if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visit)
+                || Constants.equalsInteger(noticeType,Constants.noticesObjectType.visitReporting)){
+            //璁垮璁板綍涓庤瀹㈡姤澶�
+            Visits visits = visitsJoinMapper.selectJoinOne(Visits.class,
+                    new MPJLambdaWrapper<Visits>().selectAll(Visits.class)
+                            .selectAs(Member::getName,Visits::getReceptMemberName)
+                            .selectAs(Company::getName,Visits::getReceptMemberDepartment)
+                            .leftJoin(Member.class,Member::getId,Visits::getReceptMemberId)
+                            .leftJoin(Company.class,Company::getId,Member::getCompanyId)
+                            .eq(Visits::getId,businessId)
+                            .last(" limit 1 ")
+            );
+            if(Objects.isNull(visits)){
+                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈煡璇㈠埌涓氬姟鏁版嵁淇℃伅");
             }
-
-            
-            
+            if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visit)){
+                title = title + visits.getName();
+            }else{
+                title = "銆愯瀹㈡姤澶囥�戠敵璇蜂汉 - " + visits.getName();
+            }
+            jsonMap.put("name", "璁块棶浜�:" + visits.getCompanyName() + " - " + visits.getReceptMemberName());
+            jsonMap.put("sTime", "鍏ュ洯鏃堕棿:" + DateUtil.DateToStr(visits.getStarttime() , "yyyy-MM-dd HH:mm"));
+            jsonMap.put("eTime", "绂诲洯鏃堕棿:" + DateUtil.DateToStr(visits.getEndtime() , "yyyy-MM-dd HH:mm"));
+            jsonMap.put("reason", StringUtils.isBlank(visits.getReason())?"鏉ヨ浜嬬敱: - ": "鏉ヨ浜嬬敱:" +visits.getReason());
+            jsonMap.put("carNos", StringUtils.isBlank(visits.getCarNos())?"闅忚杞﹁締: - ": "闅忚杞﹁締:" +visits.getCarNos());
+        }else if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.useCar)){
+            //鐢ㄨ溅鐢宠
+            CarUseBook carUseBook = carUseBookJoinMapper.selectJoinOne(CarUseBook.class,
+                    new MPJLambdaWrapper<CarUseBook>().selectAll(CarUseBook.class)
+                            .selectAs(Member::getName,CarUseBook::getMemberName)
+                            .selectAs(Company::getName,CarUseBook::getCompanyName)
+                            .leftJoin(Member.class,Member::getId,CarUseBook::getMemberId)
+                            .leftJoin(Company.class,Company::getId,Member::getCompanyId)
+                            .eq(CarUseBook::getId,businessId)
+                            .last(" limit 1 ")
+            );
+            if(Objects.isNull(carUseBook)){
+                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈煡璇㈠埌涓氬姟鏁版嵁淇℃伅");
+            }
+            title = "銆愮敤杞︾敵璇枫�戠敵璇蜂汉 - " + carUseBook.getMemberName();
+            jsonMap.put("name", "鐢宠浜�:" + carUseBook.getCompanyName() + " - " + carUseBook.getMemberName());
+            jsonMap.put("sTime", "寮�濮嬫椂闂�:" + DateUtil.DateToStr(carUseBook.getStartTime() , "yyyy-MM-dd HH:mm"));
+            jsonMap.put("eTime", "缁撴潫鏃堕棿:" + DateUtil.DateToStr(carUseBook.getEndTime() , "yyyy-MM-dd HH:mm"));
+            jsonMap.put("usrNum", StringUtils.isBlank(carUseBook.getMemberIds())?"涔樿溅浜烘暟: 0浜�": "涔樿溅浜烘暟: " +carUseBook.getMemberIds().split(",").length +"浜�");
+            jsonMap.put("mdd", StringUtils.isBlank(carUseBook.getAddr())?"鐩殑鍦�: - ": "鐩殑鍦�:" +carUseBook.getAddr());
+        }else {
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED);
         }
-        
-        
-
-
-
-
+        return title;
     }
 
 
@@ -510,7 +573,7 @@
         if (CollectionUtils.isNotEmpty(copyList)) {
             Approve waitModel = new Approve();
             waitModel.setApproveType(Constants.ONE);
-            waitModel.setStatusInfo("鎶勯��");
+            waitModel.setTitle("鎶勯�佷汉");
             waitModel.setStatus(Constants.ONE);
             waitModel.setType(Constants.ONE);
             waitModel.setApproveList(copyList);
@@ -531,6 +594,7 @@
     private List<Approve> getLevelInfoFromList(Approve level,List<Approve> approveGroupList) {
         List<Approve> list = new ArrayList<>();
         if(Constants.equalsInteger(level.getApproveType(),Constants.TWO)){
+            level.setApproveType(Constants.ZERO);
             //濡傛灉鏄崟浜哄鎵�
             list.add(level);
             return list;
@@ -544,32 +608,48 @@
         dealGroupListBiz(level,levelApprove,approveGroupList,passList,refuseModel,waitList,otherPassList);
         if(Objects.nonNull(refuseModel) && Objects.nonNull(refuseModel.getId())){
             //瀛樺湪鎷掔粷鐨勶紝鍙渶瑕佽繑鍥炰竴鏉″鐞嗘暟鎹紝鍚庣画涓嶉渶瑕佸洖鏄�
+            refuseModel.setApproveType(Constants.ZERO);
             list.add(refuseModel);
             return list;
         }
         list.addAll(sortByCreateTime(passList));
         if(Constants.equalsInteger(level.getApproveType(),Constants.ONE)){
             //濡傛灉鏄細绛�
-            if(waitList.size()>0){
+            if(waitList.size()>1){
                 Approve waitModel = new Approve();
                 waitModel.setApproveType(Constants.ONE);
-                waitModel.setStatusInfo(StringUtils.defaultString(level.getTitle(),"瀹℃壒浜�")+"澶勭悊涓�");
+                waitModel.setTitle(StringUtils.defaultString(level.getTitle(),"瀹℃壒浜�"));
                 waitModel.setStatus(Constants.equalsInteger(waitList.get(Constants.ZERO).getStatus(),Constants.ONE)?Constants.ONE:Constants.ZERO);
+                waitModel.setStatusInfo("澶勭悊涓�");
+                if(Constants.equalsInteger(level.getStatus(),Constants.approveStatus.auditIng)
+                        ||Constants.equalsInteger(level.getStatus(),Constants.approveStatus.pass)){
+                    waitModel.setMemberName(waitList.size() +"浜轰細绛�");
+                }
                 waitModel.setApproveList(waitList);
                 list.add(waitModel);
+            }else if(waitList.size()>0){
+                Approve approve = waitList.get(Constants.ZERO);
+                approve.setApproveType(Constants.ZERO);
+                list.add(approve);
             }
         }else {
             if((waitList.size()> 0 || otherPassList.size()>0)){
                 Approve waitModel = new Approve();
                 waitModel.setApproveType(Constants.ONE);
-                waitModel.setStatusInfo(passList.size()<=0?StringUtils.defaultString(level.getTitle(),"瀹℃壒浜�"):"鎶勯�佹垨绛惧鎵逛汉");
-                waitModel.setStatus(passList.size()>0?Constants.ONE:Constants.ZERO);
+                if(Constants.equalsInteger(level.getStatus(),Constants.approveStatus.pass)){
+                    waitModel.setStatus(Constants.approveStatus.pass);
+                    waitModel.setTitle("瀹℃壒浜猴紙鎶勯�佹垨绛惧鎵逛汉锛�");
+                }else{
+                    waitModel.setStatusInfo(passList.size()<=0?StringUtils.defaultString(level.getTitle(),"瀹℃壒浜�"):"鎶勯�佹垨绛惧鎵逛汉");
+                    waitModel.setStatus(passList.size()>0?Constants.ONE:Constants.ZERO);
+                }
                 List<Approve> approveList = new ArrayList<>();
                 approveList.addAll(waitList);
                 //濡傛灉鏄垨绛�
                 if(passList.size()>0){
                     approveList.addAll(otherPassList);
                 }
+                waitModel.setMemberName("宸叉妱閫�"+ approveList.size() +"浜�");
                 waitModel.setApproveList(approveList);
                 list.add(waitModel);
             }
@@ -822,16 +902,18 @@
                     .ne(Approve::getId,approve.getId()));
         }else{
             //澶勭悊鍏朵粬涓氬姟鏁版嵁
-            if(approve.getApproveType().equals(Constants.ZERO)&&approve.getIsEndCheck()==Constants.ONE){
-                //鎴栫  涓� 缁堝
+            if((approve.getApproveType().equals(Constants.ZERO)
+                    || approve.getApproveType().equals(Constants.TWO)) &&approve.getIsEndCheck()==Constants.ONE){
+                //鎴栫 / 鍗曚汉瀹� 涓� 缁堝
                 approveJoinMapper.update(null,new UpdateWrapper<Approve>()
                         .lambda()
                         .set(Approve::getStatus,Constants.approveStatus.otherDeal)
                         .in(Approve::getId,approveList.stream().map(m->m.getId()).collect(Collectors.toList())));
                 dealBusinessBean = true;
 
-            }else if(approve.getApproveType().equals(Constants.ZERO)&&approve.getIsEndCheck()!=Constants.ONE){
-                //鎴栫 闈炵粓瀹� 鍒欏紑鍚笅涓�姝ヤ笟鍔℃祦绋�
+            }else if((approve.getApproveType().equals(Constants.ZERO)
+                    || approve.getApproveType().equals(Constants.TWO)) &&approve.getIsEndCheck()!=Constants.ONE){
+                //鎴栫 / 鍗曚汉瀹� 闈炵粓瀹� 鍒欏紑鍚笅涓�姝ヤ笟鍔℃祦绋�
                 /**澶勭悊鏈骇鏁版嵁**/
                 approveJoinMapper.update(null,new UpdateWrapper<Approve>()
                         .lambda()
@@ -846,7 +928,7 @@
                         .eq(Approve::getObjType,approve.getObjType())
                         .eq(Approve::getLevel,(approve.getLevel()+1))
                 );
-
+                //TODO 鏇存柊娑堟伅鏁版嵁  鍙戦�佷笅涓�绾ф暟鎹秷鎭�
             }else if(approve.getApproveType().equals(Constants.ONE)&&approve.getIsEndCheck()==Constants.ONE){
             //浼氱 涓旂粓瀹�
                 if(approveList.size()==Constants.ZERO){
@@ -867,8 +949,6 @@
                 //TODO 瀹℃壒鏈�氳繃閫氱煡
 
             }
-
-
         }else if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals(
                 Constants.approveObjectType.unCityUseCar)){
             // 甯傚唴澶栫敤杞︾敵璇�
@@ -886,6 +966,67 @@
         }
     }
 
+    public void passNextNotices(Boolean dealBusinessBean,Approve approve){
+        //鏍规嵁瀹℃壒璁板綍鏌ヨ 閫氱煡璁板綍
+        Integer noticeType = Constants.approveTypeToNoticeType(approve.getObjType());
+        Notices  notices = noticesJoinMapper.selectOne(new QueryWrapper<Notices>().lambda()
+                .eq(Notices::getObjId,approve.getObjId())
+                .eq(Notices::getObjType,noticeType)
+                .eq(Notices::getUserId,approve.getChekorId())
+                .eq(Notices::getSendacopy,Constants.ZERO)
+                .eq(Notices::getIsdeleted,Constants.ZERO)
+        );
+        if(Objects.isNull(notices)){
+            return;
+        }
+
+
+        if(Constants.equalsInteger(approve.getApproveType(),Constants.ZERO)){
+            //鎴栫
+            //1銆佷慨鏀硅嚜宸辩殑鏁版嵁璁板綍
+
+            //2銆佹洿鏂颁粬浜虹殑鍚岀骇璁板綍 涓烘妱閫�
+
+            //3銆佸鏋滀笉鏄粓瀹$敓鎴愪笅涓�绾х殑鏁版嵁璁板綍
+
+
+        }else if(Constants.equalsInteger(approve.getApproveType(),Constants.ONE)){
+            //浼氱
+            //1銆佷慨鏀硅嚜宸辩殑鏁版嵁璁板綍
+
+            //2銆佹牴鎹槸鍚︿负鏈�鍚庝竴浣嶅鎵逛汉   濡傛灉涓嶆槸 鍒欑粨鏉�
+
+            //3銆� 濡傛灉鏄渶鍚庝竴浣嶅鎵逛汉 涓斾笉鏄粓瀹″紑鍚笅涓�绾ф暟鎹�
+
+        }else{
+            //鍗曚汉绛�
+            //1銆佷慨鏀硅嚜宸辩殑鏁版嵁璁板綍
+
+            //2銆� 鏄惁鏄粓瀹� 寮�鍚笅涓�绾ф暟鎹�
+
+
+        }
+        //涓氬姟閫氳繃 淇敼瀹℃壒瀵瑰簲娑堟伅璁板綍
+        if(Constants.equalsInteger(approve.getStatus(),Constants.approveStatus.pass)){
+
+        }
+        //
+
+        //缁堝涓氬姟 鍙戦�佹妱閫�
+        if (Constants.equalsInteger(approve.getIsEndCheck(),Constants.ONE)) {
+
+
+
+        }
+
+
+
+
+
+
+
+    }
+
     public void dealBusinessData(ApproveDTO approveDTO,Approve approve,Visits visits,CarUseBook carUseBook){
         if(approveDTO.getObjType().equals(Constants.approveObjectType.unConstructionVisit)
                 ||approveDTO.getObjType().equals(Constants.approveObjectType.constructionVisit)

--
Gitblit v1.9.3