From 9a66d3a382406eda71b09ed06ddb5d4a0dc95989 Mon Sep 17 00:00:00 2001
From: liukangdong <898885815@qq.com>
Date: 星期一, 24 二月 2025 16:38:22 +0800
Subject: [PATCH] Merge branch 'master' of http://139.186.142.91:10010/r/productDev/dmvisit

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java |   86 ++++++++++++++++++++++++++++++++++++++----
 1 files changed, 77 insertions(+), 9 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java
index 26effca..5d6d27b 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java
@@ -8,9 +8,9 @@
 import com.doumee.biz.system.SystemDictDataBiz;
 import com.doumee.core.constants.ResponseStatus;
 import com.doumee.core.exception.BusinessException;
-import com.doumee.core.model.LoginUserInfo;
-import com.doumee.core.model.PageData;
-import com.doumee.core.model.PageWrap;
+import com.doumee.service.business.third.model.LoginUserInfo;
+import com.doumee.service.business.third.model.PageData;
+import com.doumee.service.business.third.model.PageWrap;
 import com.doumee.core.utils.Constants;
 import com.doumee.core.utils.DateUtil;
 import com.doumee.core.utils.SmsConstants;
@@ -18,9 +18,11 @@
 import com.doumee.core.wx.wxPlat.WxPlatConstants;
 import com.doumee.core.wx.wxPlat.WxPlatNotice;
 import com.doumee.dao.business.*;
+import com.doumee.dao.business.dao.MemberMapper;
 import com.doumee.dao.business.dao.SmsConfigMapper;
 import com.doumee.dao.business.dao.SmsEmailMapper;
 import com.doumee.dao.business.model.*;
+import com.doumee.dao.business.model.Member;
 import com.doumee.dao.system.MultifileMapper;
 
 import com.doumee.dao.system.SystemUserMapper;
@@ -32,6 +34,7 @@
 import com.doumee.service.business.third.EmayService;
 import com.github.yulichang.wrapper.MPJLambdaWrapper;
 import org.apache.commons.lang3.StringUtils;
+import org.checkerframework.checker.units.qual.C;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -210,7 +213,6 @@
         hiddenDanger.setMemberName(systemUser.getRealname());
         //鎻愪氦浜虹殑寰俊鍏紬鍙烽�氱煡
         if(Objects.nonNull(systemUser)&&StringUtils.isNotBlank(systemUser.getOpenid())){
-
             wxPlatNotice.sendHiddenDangerUploadTemplateNotice(systemDictDataBiz,
                     wxNoticeConfigMapper,hiddenDanger,
                     WxPlatConstants.hiddenDangerContent.hiddenDangerUpload,
@@ -222,10 +224,9 @@
                 .eq(SystemUser::getDeleted, Constants.ZERO)
                 .eq(SystemUser::getMemberId,hiddenDanger.getCheckUserId())
                 .last(" limit 1 "));
+
         //澶勭悊浜虹殑寰俊鍏紬鍙烽�氱煡
         if(Objects.nonNull(checkUser)&&StringUtils.isNotBlank(checkUser.getOpenid())){
-
-
             wxPlatNotice.sendHiddenDangerUploadTemplateNotice(systemDictDataBiz,
                     wxNoticeConfigMapper,hiddenDanger,
                     WxPlatConstants.hiddenDangerContent.hiddenDangerUpload,
@@ -238,6 +239,43 @@
     @Override
     public void deleteById(Integer id) {
         hiddenDangerMapper.deleteById(id);
+    }
+    @Override
+    public void deleteById(Integer id,LoginUserInfo user) {
+        if( Objects.isNull(id)   ){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        HiddenDanger model = hiddenDangerMapper.selectJoinOne(HiddenDanger.class,new MPJLambdaWrapper<HiddenDanger>()
+                .selectAll(HiddenDanger.class)
+                .selectAs(Member::getName,HiddenDanger::getCheckorName)
+                .leftJoin(Member.class,Member::getId,HiddenDanger::getCheckUserId)
+                .eq(HiddenDanger::getId,id)
+                .eq(HiddenDanger::getIsdeleted,Constants.ZERO)
+        );
+        if(Objects.isNull(model)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌闅愭偅鏁版嵁");
+        }
+        if (!Constants.equalsInteger(model.getStatus(),Constants.ZERO)) {
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏁版嵁鐘舵�佸凡娴佽浆,璇峰埛鏂版煡鐪�!");
+        }
+        HiddenDanger hiddenDanger  = new HiddenDanger();
+        hiddenDanger.setIsdeleted(Constants.ONE);
+        hiddenDanger.setId(id);
+        hiddenDanger.setEditor(user.getId());
+
+        hiddenDanger.setEditDate(new Date());
+        hiddenDangerMapper.updateById(hiddenDanger);
+        //瀛樺偍 鎿嶄綔鏃ュ織
+        HiddenDangerLog hiddenDangerLog = new HiddenDangerLog();
+        hiddenDangerLog.setIsdeleted(Constants.ZERO);
+        hiddenDangerLog.setCreateDate(new Date());
+        hiddenDangerLog.setCreator(hiddenDanger.getEditor());
+        hiddenDangerLog.setEditDate(hiddenDangerLog.getCreateDate());
+        hiddenDangerLog.setEditor(hiddenDanger.getCreator());
+        hiddenDangerLog.setTitle("鐢便��"+user.getRealname()+"銆戝垹闄よ褰�");
+        hiddenDangerLog.setHiddenDangerId(hiddenDanger.getId());
+        hiddenDangerLog.setObjType(Constants.FIVE);
+        hiddenDangerLogMapper.insert(hiddenDangerLog);
     }
 
     @Override
@@ -311,6 +349,17 @@
             for(Multifile f : multifiles){
                 if(StringUtils.isBlank(f.getFileurl())){
                     continue;
+                }
+                if(f.getType() == null){
+                    if(StringUtils.endsWithIgnoreCase(f.getFileurl(),".mp4")){
+                        f.setType(Constants.ONE);
+                    }else if(StringUtils.endsWithIgnoreCase(f.getFileurl(),".jpg")
+                            ||StringUtils.endsWithIgnoreCase(f.getFileurl(),".jpeg")
+                            ||StringUtils.endsWithIgnoreCase(f.getFileurl(),".png")){
+                        f.setType(Constants.ZERO);
+                    }else{
+                        f.setType(Constants.TWO);
+                    }
                 }
                 f.setFileurlFull(path+f.getFileurl());
                 if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.HIDDEN_DANGER_SUBMIT.getKey())){
@@ -426,8 +475,6 @@
         return hiddenDangerMapper.selectCount(wrapper);
     }
 
-
-
     @Override
     @Transactional(rollbackFor = {Exception.class,BusinessException.class})
     public void dealHiddenDanger(HiddenDanger hiddenDanger){
@@ -527,9 +574,21 @@
                 if(StringUtils.isBlank(multifile.getFileurl())){
                     continue;
                 }
+                multifile.setId(null);
                 multifile.setCreateDate(new Date());
                 multifile.setCreator(hiddenDanger.getEditor());
                 multifile.setIsdeleted(Constants.ZERO);
+                if(multifile.getType() == null){
+                    if(StringUtils.endsWithIgnoreCase(multifile.getFileurl(),".mp4")){
+                        multifile.setType(Constants.ONE);
+                    }else if(StringUtils.endsWithIgnoreCase(multifile.getFileurl(),".jpg")
+                    ||StringUtils.endsWithIgnoreCase(multifile.getFileurl(),".jpeg")
+                    ||StringUtils.endsWithIgnoreCase(multifile.getFileurl(),".png")){
+                        multifile.setType(Constants.ZERO);
+                    }else{
+                        multifile.setType(Constants.TWO);
+                    }
+                }
                 multifile.setObjId(hiddenDanger.getId());
                 multifile.setCreator(hiddenDanger.getLoginUserInfo().getId());
                 multifile.setObjType(Constants.MultiFile.HIDDEN_DANGER_DEAL_BEFORE.getKey());
@@ -540,6 +599,11 @@
             if(hiddenDanger.getStatus().equals(Constants.ONE) && !isTrue){
                 throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝璇锋寜瑕佹眰濉啓澶勭悊鏁版嵁");
             }
+            multifileMapper.update(null,new UpdateWrapper<Multifile>().lambda()
+                    .set(Multifile::getIsdeleted,Constants.ONE )
+                    .eq(Multifile::getObjType,Constants.MultiFile.HIDDEN_DANGER_DEAL_BEFORE.getKey())
+                    .eq(Multifile::getObjId,hiddenDanger.getId())
+            );
         }
         if(hiddenDanger.getStatus().equals(Constants.ONE)){
             boolean isTrue = false;
@@ -550,6 +614,7 @@
                     if(StringUtils.isBlank(multifile.getFileurl())){
                         continue;
                     }
+                    multifile.setId(null);
                     multifile.setCreateDate(new Date());
                     multifile.setCreator(hiddenDanger.getEditor());
                     multifile.setIsdeleted(Constants.ZERO);
@@ -605,6 +670,7 @@
         if(Objects.isNull(hiddenDangerCate)){
             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌闅愭偅绫诲瀷");
         }
+        model.setCategoryName(hiddenDangerCate.getName());
         hiddenDanger.setCategoryName(hiddenDangerCate.getName());
         hiddenDanger.setEditor(hiddenDanger.getLoginUserInfo().getId());
         hiddenDanger.setEditDate(new Date());
@@ -625,6 +691,7 @@
                 .eq(Notices::getObjId,hiddenDanger.getId())
                 .eq(Notices::getObjType,Constants.THREE)
                 .eq(Notices::getUserId,hiddenDanger.getLoginUserInfo().getMemberId())
+                .orderByDesc(Notices::getId)
                 .last(" limit  1 ")
         );
         if(Objects.nonNull(notices)){
@@ -651,6 +718,7 @@
           return;
         }
         hiddenDanger.setMemberName(memberUser.getRealname());
+        model.setMemberName(memberUser.getRealname());
         SystemUser checkUser = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda()
                 .eq(SystemUser::getDeleted, Constants.ZERO)
                 .eq(SystemUser::getMemberId,hiddenDanger.getCheckUserId()));
@@ -667,7 +735,7 @@
         if(Objects.nonNull(checkUser)&&StringUtils.isNotBlank(checkUser.getOpenid())){
             WxPlatNotice wxPlatNotice = new WxPlatNotice();
             wxPlatNotice.sendHiddenDangerUploadTemplateNotice(systemDictDataBiz,
-                    wxNoticeConfigMapper,hiddenDanger,
+                    wxNoticeConfigMapper,model,
                     WxPlatConstants.hiddenDangerContent.hiddenDangerUpload,
                     systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),
                     Arrays.asList(checkUser.getOpenid().split(",")));

--
Gitblit v1.9.3