CRM邮箱收件和发件调整

xinyb

5 天以前 56d9f6a0b1ecfce70da391d406fcc92274cc1b03

 src/com/yc/crm/mail/action/MailController.java

@@ -26,6 +26,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

/**
@@ -56,7 +57,7 @@


    /**
     * 左边结构层
     * 左边结构上层
     *
     * @return
     */
@@ -83,13 +84,40 @@
    }

    /**
     * 左边结构下层
     *
     * @return
     */
    @GetMapping("/getEmailModuleBelow.do")
    public AllBackMsg getEmailModuleBelow(HttpServletRequest request, HttpServletResponse response) throws Exception {
        AllBackMsg msg = new AllBackMsg();
        try {
            HttpSession session = request.getSession();
            String userCode = (String) session.getAttribute(SessionKey.USERCODE);//当前登录用户
            if (StringUtils.isBlank(userCode)) {//获取不到当前用户直接结束
                msg.setFail("获取不到用户信息");
                return msg;
            }
            DataSourceEntity dataSourceEntity = MultiDataSource.getDataSourceMap(request);//获取数据源信息
            SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());//切换数据源
            List<MailModuleBelowEntity> list = emailIfc.getMailModuleBelowList(userCode);
            msg.setSuccess("执行成功", list);
        } catch (Exception e) {
            msg.setFail(e.getCause() != null ? e.getCause().getMessage() : e.getMessage());
        } finally {
            SpObserver.setDBtoInstance();
        }
        return msg;
    }

    /**
     * 获取邮件列表（包括草稿箱，收件箱）
     *
     * @return
     */
    @GetMapping("/getMailList.do")
    public AllBackMsg getMailList(String mail, @RequestParam(defaultValue = "1") Integer mailType,
                                  @RequestParam(defaultValue = "1") Integer page,@RequestParam(defaultValue = "20") Integer limit, boolean isNoRead, HttpServletRequest request, HttpServletResponse response) throws Exception {
                                  @RequestParam(defaultValue = "1") Integer page, @RequestParam(defaultValue = "20") Integer limit, boolean isNoRead, HttpServletRequest request, HttpServletResponse response) throws Exception {
        AllBackMsg msg = new AllBackMsg();
        try {
            if (StringUtils.isNotBlank(mail)) {
@@ -106,10 +134,17 @@
            }
            DataSourceEntity dataSourceEntity = MultiDataSource.getDataSourceMap(request);//获取数据源信息
            SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());//切换数据源
            List<t482101HList> t482101HEntityList = emailIfc.getReceivingMailList(mail, mailType, isNoRead, userCode,page,limit);
            List<t482101HList> t482101HEntityList = emailIfc.getReceivingMailList(mail, mailType, isNoRead, userCode, page, limit);
            Map<String, Object> map = new HashMap<>();
            map.put("page", page);
            map.put("limit", limit);
            if (t482101HEntityList.size() > 0) {
                msg.setSuccess("执行完成", t482101HEntityList);
                map.put("total", emailIfc.getMailTotal(mail, mailType, isNoRead, null, userCode));
                map.put("list", t482101HEntityList);
            } else {
                map.put("list", new ArrayList<>());
            }
            msg.setSuccess("执行完成", map);
        } catch (Exception e) {
            msg.setFail(e.getCause() != null ? e.getCause().getMessage() : e.getMessage());
        } finally {
@@ -124,7 +159,7 @@
     * @return
     */
    @GetMapping("/getHandleMailList.do")
    public AllBackMsg getHandleMailList(String mail,@RequestParam(defaultValue = "1") Integer page,@RequestParam(defaultValue = "20") Integer limit,
    public AllBackMsg getHandleMailList(String mail, @RequestParam(defaultValue = "1") Integer page, @RequestParam(defaultValue = "20") Integer limit,
                                        HttpServletRequest request, HttpServletResponse response) throws Exception {
        AllBackMsg msg = new AllBackMsg();
        try {
@@ -142,10 +177,17 @@
            }
            DataSourceEntity dataSourceEntity = MultiDataSource.getDataSourceMap(request);//获取数据源信息
            SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());//切换数据源
            List<t482101HList> t482101HEntityList = emailIfc.getHandleMailList(mail, userCode,page,limit);
            List<t482101HList> t482101HEntityList = emailIfc.getHandleMailList(mail, userCode, page, limit);
            Map<String, Object> map = new HashMap<>();
            map.put("page", page);
            map.put("limit", limit);
            if (t482101HEntityList.size() > 0) {
                msg.setSuccess("执行完成", t482101HEntityList);
                map.put("total", emailIfc.getMailTotal(mail, 3, false, null, userCode));
                map.put("list", t482101HEntityList);
            } else {
                map.put("list", new ArrayList<>());
            }
            msg.setSuccess("执行完成", map);
        } catch (Exception e) {
            msg.setFail(e.getCause() != null ? e.getCause().getMessage() : e.getMessage());
        } finally {
@@ -174,10 +216,15 @@
                if (StringUtils.isNotBlank(t482101HEntity.getAttachmentList())) {//附件的处理
                    //获取到附件内容
                    List<AttachmentEntity> attachmentEntities = mailFileIfc.getAttachmentEntityList(t482101HEntity.getAttachmentList());
                    List<String> list = new ArrayList<>();
                    List<Map<String,Object>> list = new ArrayList<>();
                    if (attachmentEntities.size() > 0) {
                        for (AttachmentEntity a : attachmentEntities) {
                            list.add(shoppingImageServer + "/uploads/email/" + dataSourceEntity.getDbId() + "/482101/" + a.getUnid() + "@p@" + a.getPhysicalFile());
                            Map<String,Object> map=new HashMap<>();
                            map.put("url",shoppingImageServer + "/uploads/email/" + dataSourceEntity.getDbId() + "/482101/" + a.getUnid() + "@p@" + a.getPhysicalFile());
                            map.put("name",a.getOriginalFileName());
                            map.put("size",a.getFileSize());
                            map.put("fileType",a.getFileType());
                            list.add(map);
                        }
                        t482101HEntity.setAttachmentPath(list);
                    }
@@ -493,14 +540,14 @@
    }

    /**
     * 待处理邮件
     * 移动邮件分类
     *
     * @param request
     * @param response
     * @return
     */
    @GetMapping("/updateHandle.do")
    public AllBackMsg updateHandle(String handleTime, String docCode, HttpServletRequest request, HttpServletResponse response) throws Exception {
    @PostMapping("/updateMailType.do")
    public AllBackMsg updateMailType(@RequestBody Map<String, Object> map, HttpServletRequest request, HttpServletResponse response) throws Exception {
        AllBackMsg msg = new AllBackMsg();
        try {
            HttpSession session = request.getSession();
@@ -509,14 +556,119 @@
                msg.setFail("获取不到用户信息");
                return msg;
            }
            if (map.get("docCode") == null) {
                msg.setFail("获取不到移动邮件编号docCode");
                return msg;
            }
            String docCode = (String) map.get("docCode");
            Integer folderId = map.get("folderId") == null ? 0 : (Integer) map.get("folderId");
            List<String> tagArray = (List<String>) map.get("tagId");
            if (folderId.equals(0) && (tagArray == null || tagArray.size() == 0)) {
                msg.setFail("移动邮件分类不能为空");
                return msg;
            }
            String tagId = "";
            if (tagArray != null && tagArray.size() > 0) {
                tagId = StringUtils.join(tagArray, ",");
            }
            DataSourceEntity dataSourceEntity = MultiDataSource.getDataSourceMap(request);//获取数据源信息
            SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());//切换数据源
            emailIfc.updateMailType(docCode, folderId, tagId);
            msg.setOk("移动成功");
        } catch (Exception e) {
            msg.setFail(e.getCause() != null ? e.getCause().getMessage() : e.getMessage());
        } finally {
            SpObserver.setDBtoInstance();
        }
        return msg;
    }

            if (StringUtils.isBlank(docCode)) {
    /**
     * 加载不同目录里的邮件
     *
     * @param request
     * @param response
     * @return
     */
    @GetMapping("/classificationMail.do")
    public AllBackMsg classificationMail(@RequestParam(defaultValue = "-1") Integer id, String type, @RequestParam(defaultValue = "1") Integer page, @RequestParam(defaultValue = "20") Integer limit,
                                         HttpServletRequest request, HttpServletResponse response) throws Exception {
        AllBackMsg msg = new AllBackMsg();
        try {
            HttpSession session = request.getSession();
            String userCode = (String) session.getAttribute(SessionKey.USERCODE);//当前登录用户
            if (StringUtils.isBlank(userCode)) {//获取不到当前用户直接结束
                msg.setFail("获取不到用户信息");
                return msg;
            }
            if (id == null || id.equals(-1)) {
                msg.setFail("获取不到文件Id");
                return msg;
            }
            if (StringUtils.isBlank(type)) {
                msg.setFail("获取不到文件类型");
                return msg;
            }
            type = type + "_" + id;//组装下
            DataSourceEntity dataSourceEntity = MultiDataSource.getDataSourceMap(request);//获取数据源信息
            SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());//切换数据源
            List<t482101HList> t482101 = emailIfc.getFolderMailList(type, userCode, page, limit);
            Map<String, Object> map = new HashMap<>();
            map.put("page", page);
            map.put("limit", limit);
            if (t482101.size() > 0) {
                map.put("total", emailIfc.getMailTotal(null, 6, false, type, userCode));
                map.put("list", t482101);
            } else {
                map.put("list", new ArrayList<>());
            }
            msg.setSuccess("执行完成", map);
        } catch (Exception e) {
            msg.setFail(e.getCause() != null ? e.getCause().getMessage() : e.getMessage());
        } finally {
            SpObserver.setDBtoInstance();
        }
        return msg;
    }

    /**
     * 待处理邮件
     *
     * @param request
     * @param response
     * @return
     */
    @PostMapping("/updateHandle.do")
    public AllBackMsg updateHandle(@RequestBody Map<String, Object> param, HttpServletRequest request, HttpServletResponse response) throws Exception {
        AllBackMsg msg = new AllBackMsg();
        try {
            HttpSession session = request.getSession();
            String userCode = (String) session.getAttribute(SessionKey.USERCODE);//当前登录用户
            if (StringUtils.isBlank(userCode)) {//获取不到当前用户直接结束
                msg.setFail("获取不到用户信息");
                return msg;
            }
            if (param.get("docCode") == null) {
                msg.setFail("邮件唯一标识docCode不能空");
                return msg;
            }
            if (param.get("handleTime") == null) {
                msg.setFail("待处理时间不能空");
                return msg;
            }
            List<String> docCode = (List<String>) param.get("docCode");
            String handleTime = (String) param.get("handleTime");
            // 正则表达式，用于匹配日期格式
            String regex = "\\d{4}-\\d{2}-\\d{2} \\d{2}:\\d{2}";
            Pattern pattern = Pattern.compile(regex);
            Matcher matcher = pattern.matcher(handleTime);
            if (!matcher.matches()) {
                msg.setFail("待处理日期格式为：yyyy-MM-dd HH:mm（如：1900-08-01 08:00）。请检查");
                return msg;
            }
            DataSourceEntity dataSourceEntity = MultiDataSource.getDataSourceMap(request);//获取数据源信息
            SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());//切换数据源
            emailIfc.updateMailHandle(handleTime, docCode);
            emailIfc.updateMailHandle(handleTime, StringUtils.join(docCode, ","));
            msg.setOk("成功标记为待处理邮件");
        } catch (Exception e) {
            msg.setFail(e.getCause() != null ? e.getCause().getMessage() : e.getMessage());