From 39fd893c2d4cf695284826655c3f59bd769cfedd Mon Sep 17 00:00:00 2001
From: huanghongfa <18228131219@163.com>
Date: 星期一, 04 一月 2021 19:45:05 +0800
Subject: [PATCH] 广告通知接口

---
 springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java |   84 ++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 84 insertions(+), 0 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
index ebfcaed..4fa52de 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
@@ -7,7 +7,10 @@
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.panzhihua.common.constants.SecurityConstants;
 import com.panzhihua.common.constants.UserConstants;
+import com.panzhihua.common.model.dtos.PageDTO;
+import com.panzhihua.common.model.dtos.community.NoticeReadDTO;
 import com.panzhihua.common.model.dtos.user.PageUserAppletsBackstageDTO;
+import com.panzhihua.common.model.dtos.user.SysUserFeedbackDTO;
 import com.panzhihua.common.model.vos.LoginUserInfoVO;
 import com.panzhihua.common.model.vos.R;
 import com.panzhihua.common.model.vos.SystemmanagementConfigVO;
@@ -56,6 +59,10 @@
     private SysOperLogDAO sysOperLogDAO;
     @Resource
     private SysUserAgreementDAO sysUserAgreementDAO;
+    @Resource
+    private SysUserFeedbackDAO sysUserFeedbackDAO;
+    @Resource
+    private SysUserNoticeDAO sysUserNoticeDAO;
 
 
     /**
@@ -935,6 +942,83 @@
         return R.fail("清除失败");
     }
 
+    /**
+     * 用户协议和隐私政策
+     *
+     * @param type 所属app 1居民端app 2网格员端app 3商家端app
+     * @return 协议内容
+     */
+    @Override
+    public R userAgreement(int type) {
+        SysUserAgreementDO sysUserAgreementDO = sysUserAgreementDAO.selectOne(new QueryWrapper<SysUserAgreementDO>().lambda().eq(SysUserAgreementDO::getType, type));
+        return R.ok(sysUserAgreementDO);
+    }
+
+    /**
+     * 意见反馈
+     *
+     * @param sysUserFeedbackDTO 反馈内容
+     * @return 反馈结果
+     */
+    @Override
+    public R addFeedback(SysUserFeedbackDTO sysUserFeedbackDTO) {
+        SysUserFeedbackDO sysUserFeedbackDO=new SysUserFeedbackDO();
+        BeanUtils.copyProperties(sysUserFeedbackDTO,sysUserFeedbackDO);
+        int insert = sysUserFeedbackDAO.insert(sysUserFeedbackDO);
+        if (insert>0) {
+            return R.ok();
+        }
+        return R.fail();
+    }
+
+    /**
+     * 分页通知列表
+     *
+     * @param pageDTO 分页参数
+     * @return 分页结果
+     */
+    @Override
+    public R pageNotice(PageDTO pageDTO) {
+        Long userId=pageDTO.getUserId();
+        Integer integer = sysUserNoticeDAO.selectCount(new QueryWrapper<SysUserNoticeDO>().lambda().eq(SysUserNoticeDO::getUserId, userId).eq(SysUserNoticeDO::getStatus, 0));
+        Page page = new Page<>();
+        Long pageNum = pageDTO.getPageNum();
+        Long pageSize = pageDTO.getPageSize();
+        page.setSize(pageSize);
+        page.setCurrent(pageNum);
+        IPage<SysUserNoticeVO> iPage = userDao.pageNotice(page, pageDTO);
+        Map<String,Object> map=new HashMap<>(2);
+        map.put("page",iPage);
+        map.put("unreadNum",null==integer?0:integer);
+        return R.ok(map);
+    }
+
+    /**
+     * 通知已读
+     *
+     * @param noticeReadDTO 通知已读
+     * @return 修改状态
+     */
+    @Override
+    public R putNotice(NoticeReadDTO noticeReadDTO) {
+        Integer all = noticeReadDTO.getAll();
+        Long userId = noticeReadDTO.getUserId();
+        int num=0;
+        SysUserNoticeDO sysUserNoticeDO=new SysUserNoticeDO();
+        if (null!=all&&1==all.intValue()) {
+            sysUserNoticeDO.setStatus(1);
+            num=sysUserNoticeDAO.update(sysUserNoticeDO,new UpdateWrapper<SysUserNoticeDO>().lambda().eq(SysUserNoticeDO::getUserId,userId).eq(SysUserNoticeDO::getStatus,0));
+        }else{
+            sysUserNoticeDO.setId(noticeReadDTO.getId());
+            sysUserNoticeDO.setStatus(1);
+            num=sysUserNoticeDAO.updateById(sysUserNoticeDO);
+        }
+        if (num>0) {
+            return R.ok();
+        }
+       return R.fail("通知不存在");
+    }
+
     public static void main(String[] args) {
         String encode = new BCryptPasswordEncoder().encode("123456");
         System.out.println(encode);

--
Gitblit v1.7.1