From 7d013331f10c993692d5fcceb42fbc960a7033cc Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期五, 18 四月 2025 16:19:08 +0800
Subject: [PATCH] 工单业务

---
 server/src/main/java/com/doumee/service/business/impl/WorkorderServiceImpl.java |   64 +++++++++++++++++++++----------
 1 files changed, 43 insertions(+), 21 deletions(-)

diff --git a/server/src/main/java/com/doumee/service/business/impl/WorkorderServiceImpl.java b/server/src/main/java/com/doumee/service/business/impl/WorkorderServiceImpl.java
index 06e4bb2..0507cab 100644
--- a/server/src/main/java/com/doumee/service/business/impl/WorkorderServiceImpl.java
+++ b/server/src/main/java/com/doumee/service/business/impl/WorkorderServiceImpl.java
@@ -24,6 +24,7 @@
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.doumee.service.common.EmailService;
 import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import com.sun.corba.se.spi.orbutil.threadpool.Work;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.catalina.Manager;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -123,6 +124,9 @@
      * @param csInfo 鎶勯�佷俊鎭�
      */
     public void sendQwMsg(Workorder workorder,String qwIds,Member member,String categoryName,Integer contentType,String csInfo){
+        if(Constants.equalsInteger(workorder.getType(),Constants.TWO)){
+            workorder = workorderMapper.selectById(workorder.getDcaRecordId());
+        }
         if(StringUtils.isEmpty(qwIds)){
             return;
         }
@@ -164,8 +168,10 @@
         QywxTextCardMsgRequest textCard = new QywxTextCardMsgRequest();
         String message = "";
         String url = jumpUrl.replace("{corpId}",systemDictDataBiz.queryByCode(Constants.QYWX,Constants.QYWX_CORPID).getCode());
-        String jumpOurUrl = systemDictDataBiz.queryByCode(Constants.QYWX,Constants.JUMP_OUT_URL).getCode().replace("{status}",workorder.getType()+"_"+workorder.getId());
+        String jumpOurUrl = systemDictDataBiz.queryByCode(Constants.QYWX,Constants.JUMP_OUT_URL).getCode().replace("{status}",
+                workorder.getType()+"_"+workorder.getId());
         textCard.setUrl(url.replace("{ourUrl}",jumpOurUrl));
+        log.error("浼佸井閾炬帴鍦板潃"+url);
         if(Constants.equalsInteger(workorder.getType(),Constants.ZERO)){
             textCard.setTitle("銆怱HE浜嬩欢涓婃姤銆�");
             if(Constants.equalsInteger(workorder.getMemberType(),Constants.ZERO)){
@@ -266,6 +272,10 @@
                     workorderMapper.insert(dcaWorkOrder);
                     //瀛樺偍鏃ュ織
                     this.dealLogData(dcaWorkOrder,workOrderStatus);
+
+                    //瀛樺偍寰呭姙浜哄憳淇℃伅
+                    this.saveNotice(Arrays.asList(dcaWorkOrder.getQwnoticeMemberIds().split(",")),dcaWorkOrder.getId(),Constants.ZERO,Constants.ZERO);
+
                     List<Multifile> multifileList = dcaNoProblemDTO.getMultifileList();
                     if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(multifileList)){
                         for (Multifile multifile:multifileList) {
@@ -392,7 +402,7 @@
      * @param afterWorkorder
      * @param objType 鎿嶄綔绫诲瀷 0浠诲姟涓婃姤 1浠诲姟鍒嗛厤鐗╀笟涓荤 2浠诲姟鍒嗛厤澶勭悊浜� 3浠诲姟澶勭悊鍏抽棴 4浠诲姟鍌績
      * @param memberId
-     * @param paramr2 澶勭悊浜�
+     * @param paramr2 杞氦缁欑殑澶勭悊浜�
      */
     public Integer saveLog(String beforeJson,Workorder afterWorkorder,Integer objType,Integer memberId,String title,String content,String paramr2){
         WorkorderLog workorderLog = new WorkorderLog();
@@ -506,13 +516,18 @@
         }
 
         //鏌ヨ鏃ュ織淇℃伅
-        workorder.setLogList(this.getLogList(workorder));
+        workorder.setLogList(this.getLogList(workorder,member));
         if(Constants.equalsInteger(workorder.getType(),Constants.ONE)){
             //濡傛灉鏄疍CA鎻愪氦璁板綍锛屾煡璇㈠瓙宸ュ崟闆嗗悎
             Workorder param = new Workorder();
             param.setIsdeleted(Constants.ZERO);
             param.setDcaRecordId(workorder.getId());
-            workorder.setDcaChildList(findList(param));
+            List<Workorder> dcaChildList = findList(param);
+            for (Workorder dcaChild:dcaChildList) {
+                this.dealButton(dcaChild,member);
+            }
+
+            workorder.setDcaChildList(dcaChildList);
         }
         return workorder;
     }
@@ -540,10 +555,13 @@
             }
             List<String> passOnUserList = new ArrayList<>();
             //寰呭垎閰嶇姸鎬� 澶勭悊杞氦鎸夐挳
-            if(Constants.equalsInteger(workorder.getStatus(),Constants.WorkOrderStatus.waitConfirm.getKey())&&Constants.equalsInteger(workorder.getStatus(),Constants.ZERO)){
+            if(Constants.equalsInteger(workorder.getStatus(),Constants.WorkOrderStatus.waitConfirm.getKey())
+            ){
                 passOnUserList.addAll(Arrays.asList(workorder.getQwnoticeMemberIds().split(",")));
-            }else if(Constants.equalsInteger(workorder.getStatus(),Constants.WorkOrderStatus.waitAllocation.getKey())&&(Constants.equalsInteger(workorder.getStatus(),Constants.ONE)
-            || Constants.equalsInteger(workorder.getStatus(),Constants.TWO))){
+            }
+            if(Constants.equalsInteger(workorder.getStatus(),Constants.WorkOrderStatus.waitAllocation.getKey())
+                || Constants.equalsInteger(workorder.getStatus(),Constants.WorkOrderStatus.waitDeal.getKey())
+            ){
                 passOnUserList.add(workorder.getManagerId());
             }
             if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(passOnUserList)){
@@ -554,7 +572,7 @@
     }
 
 
-    public List<WorkorderLog> getLogList(Workorder workorder){
+    public List<WorkorderLog> getLogList(Workorder workorder,Member loginMember){
         List<WorkorderLog> logList = workorderLogMapper.selectJoinList(WorkorderLog.class,
                 new MPJLambdaWrapper<WorkorderLog>()
                         .selectAll(WorkorderLog.class)
@@ -564,7 +582,6 @@
                         .eq(WorkorderLog::getObjId,workorder.getId())
                         .orderByDesc(WorkorderLog::getId)
         );
-
 
         if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(logList)){
             String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode()
@@ -576,6 +593,7 @@
                 if(Constants.equalsInteger(workorder.getStatus(),Constants.ONE)){
                     Member member = memberMapper.selectById(workorderLog.getParam1());
                     if(Objects.nonNull(member) && org.apache.commons.lang3.StringUtils.isNotBlank(member.getQwId())
+                            && Objects.nonNull(loginMember) &&  Constants.equalsInteger(member.getId(),loginMember.getId())
                             && workorder.getQwnoticeMemberIds().indexOf(member.getQwId())>=Constants.ZERO){
                         workorderLog.setUrgeButton(Constants.ONE);
                     }
@@ -584,7 +602,9 @@
                 if(Constants.equalsInteger(workorder.getStatus(),Constants.TWO)){
                     Member member = memberMapper.selectById(workorderLog.getParam1());
                     if(Objects.nonNull(member) && org.apache.commons.lang3.StringUtils.isNotBlank(member.getQwId())
-                            && member.getQwId().equals(workorder.getManagerId()) && canOpenUrgeButton){
+                            && canOpenUrgeButton
+                            && (workorder.getQwnoticeMemberIds().indexOf(member.getQwId()) >= Constants.ZERO ||  member.getQwId().equals(workorder.getManagerId()) )
+                    ){
                         workorderLog.setUrgeButton(Constants.ONE);
                         canOpenUrgeButton = false;
                     }
@@ -902,7 +922,7 @@
             workorder.setStatus(Constants.WorkOrderStatus.waitDeal.getKey());
         }
         workorder.setEditDate(new Date());
-        workorder.setUrgeDate(DateUtil.afterHoursDate(new Date(),24));
+        workorder.setUrgeDate(DateUtil.afterMinutesDate(new Date(),2));
         workorderMapper.updateById(workorder);
         String paramr2 = member.getCompanyName()+"/"+member.getName();
         //澶勭悊涓婃姤鏃ュ織
@@ -923,10 +943,12 @@
         Category category = categoryMapper.selectById(workorder.getTypeId());
         if(Objects.nonNull(passOnDTO.getMember())&&Objects.nonNull(category)){
             // 鍙戦�佷紒寰�氱煡
-            this.sendQwMsg(workorder,member.getQwId(),passOnDTO.getMember(),category.getName(),Constants.ZERO,null);
+            this.sendQwMsg(workorder,passOnDTO.getPassOnUserId(),passOnDTO.getMember(),category.getName(),Constants.ZERO,null);
         }
         //瀛樺偍寰呭姙浜哄憳淇℃伅
-        this.saveNotice(Arrays.asList(passOnDTO.getMember().getQwId().split(",")),workorder.getId(),Constants.ZERO,Constants.TWO);
+        this.saveNotice(Arrays.asList(passOnDTO.getPassOnUserId().split(",")),
+                Constants.equalsInteger(workorder.getType(),Constants.TWO)?workorder.getDcaRecordId():workorder.getId(),Constants.ZERO,Constants.TWO);
+
     }
 
 
@@ -943,16 +965,16 @@
         }
         List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda().eq(Member::getIsdeleted, Constants.ZERO)
                 .isNotNull(Member::getQwId)
-                .in(Member::getId, sendCopyDTO.getUserIds().split(",")));
+                .in(Member::getQwId, sendCopyDTO.getUserIds().split(",")));
         if (com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(memberList)) {
             List<String> qwIdList = memberList.stream().map(i -> i.getQwId()).collect(Collectors.toList());
             Category category = categoryMapper.selectById(workorder.getTypeId());
             if (Objects.nonNull(category)) {
                 // 鍙戦�佷紒寰�氱煡
-                this.sendQwMsg(workorder, String.join(",", qwIdList), sendCopyDTO.getMember(), category.getName(), Constants.ONE, null);
+                this.sendQwMsg(workorder, String.join(",", qwIdList), sendCopyDTO.getMember(), category.getName(), Constants.TWO, sendCopyDTO.getInfo());
             }
             //瀛樺偍寰呭姙淇℃伅
-            this.saveNotice(qwIdList, workorder.getId(), Constants.ONE, Constants.ONE);
+            this.saveNotice(qwIdList, Constants.equalsInteger(workorder.getType(),Constants.TWO)?workorder.getDcaRecordId():workorder.getId(), Constants.ONE, Constants.ONE);
         }
 
     }
@@ -1106,7 +1128,7 @@
     public void urge(Integer workorderId,Member member){
         Workorder workorder = workorderMapper.selectById(workorderId);
         workorder.setEditDate(new Date());
-        workorder.setUrgeDate(DateUtil.afterHoursDate(new Date(),24));
+        workorder.setUrgeDate(DateUtil.afterMinutesDate(new Date(),2));//DateUtil.afterHoursDate(new Date(),24));
         workorderMapper.updateById(workorder);
         if(Objects.isNull(workorder)){
             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌宸ュ崟鏁版嵁");
@@ -1115,7 +1137,7 @@
         //濡傛灉宸插垎閰� wts 鍒欐槸鍌績wts
         if(Constants.equalsInteger(workorder.getStatus(),Constants.WorkOrderStatus.waitAllocation.getKey())){
             urgeUser = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getIsdeleted,Constants.ZERO).eq(Member::getQwId,workorder.getManagerId()).last("limit 1 "));
-        }else if(Constants.equalsInteger(workorder.getStatus(),Constants.WorkOrderStatus.waitAllocation.getKey())){
+        }else if(Constants.equalsInteger(workorder.getStatus(),Constants.WorkOrderStatus.waitDeal.getKey())){
             urgeUser = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getIsdeleted,Constants.ZERO).eq(Member::getQwId,workorder.getDealerId()).last("limit 1 "));
         }else{
             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鐘舵�佸凡娴佽浆鏃犳硶杩涜璇ユ搷浣�");
@@ -1128,7 +1150,7 @@
         Category category = categoryMapper.selectById(workorder.getTypeId());
         if(Objects.nonNull(category)){
             // 鍙戦�佷紒寰�氱煡
-            this.sendQwMsg(workorder,urgeUser.getQwId(),null,category.getName(),Constants.ONE,null);
+            this.sendQwMsg(workorder,urgeUser.getQwId(),member,category.getName(),Constants.ONE,null);
         }
 
     }
@@ -1143,7 +1165,7 @@
             for (Workorder workorder:workorderList) {
                 this.autoUrge(workorder);
                 workorder.setEditDate(new Date());
-                workorder.setUrgeDate(DateUtil.afterHoursDate(new Date(),24));
+                workorder.setUrgeDate(DateUtil.afterMinutesDate(new Date(),2));//DateUtil.afterHoursDate(new Date(),24));
                 workorderMapper.updateById(workorder);
             }
         }
@@ -1173,7 +1195,7 @@
     }
 
 
-    public void saveNotice(List<String> qwIdList ,Integer workorderId,Integer isSendCopy,Integer type){
+    public void saveNotice(List<String> qwIdList , Integer workorderId, Integer isSendCopy, Integer type){
         List<Notices> noticesList = new ArrayList<>();
         for (String qwId:qwIdList) {
             //瀛樺偍鎶勯�佽褰�

--
Gitblit v1.9.3