更新CRM新邮件通知代码

fs-danaus

9 天以前 18553a7798e5e9947acd13d1bfdf16c0e78c8ed1

 src/com/yc/crm/mail/service/MailServiceImpl.java

@@ -2,11 +2,15 @@

import com.sun.mail.imap.IMAPBodyPart;
import com.sun.mail.imap.IMAPStore;
import com.sun.mail.util.MailSSLSocketFactory;
import com.yc.action.grid.GridUtils;
import com.yc.crm.mail.action.MailPush;
import com.yc.crm.mail.entity.FoundationEntity;
import com.yc.crm.mail.entity.MailFileEntity;
import com.yc.crm.mail.entity.T482102Entity;
import com.yc.crm.mail.entity.t482101HEntity;
import com.yc.entity.attachment.AttachmentEntity;
import com.yc.factory.FactoryBean;
import com.yc.service.BaseService;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.StringUtils;
@@ -139,7 +143,11 @@
            properties.setProperty("mail.smtp.ssl.enable", emailEntity.isSmtpSSL() + "");// // 设置启用SSL加密
            properties.setProperty("mail.smtp.host", emailEntity.getSmtpHost());
            properties.setProperty("mail.smtp.port", emailEntity.getSmtpPort() + "");

            //Could not connect to SMTP host: smtp.qq.com, port: 465, response: -1 by danaus 2024-09-23 11:01
           // properties.setProperty("mail.smtp.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
           // MailSSLSocketFactory sf = new MailSSLSocketFactory("TLSv1.2");
           // properties.put("mail.smtp.ssl.socketFactory", sf);
           // properties.setProperty("mail.smtp.ssl.protocols", "TLSv1.2");
//            properties.setProperty("mail.smtp.starttls.enable", "true");//// SMTP 协议设置 STARTTLS  开启tls
//            properties.setProperty("mail.smtp.socketFactory.port", emailEntity.getSmtpPort() + "");

@@ -271,6 +279,7 @@
     * @throws MessagingException
     * @throws IOException
     */
    @Override
    public void setMailContent(Message[] messages, T482102Entity email, FoundationEntity foundation) throws
            Exception {
        try {
@@ -390,8 +399,13 @@
                }
            }
            if (t482101HEntityList.size() > 0) {
                mailIfc.saveReceivingMailList(t482101HEntityList);//保存
                String docCodeList = mailIfc.saveReceivingMailList(t482101HEntityList);//保存
                mailAccountIfc.updateEmailTime(email.getAccountId());//更新一次配置
                //发送通知(极光和webscoket)
                //取用户的手机号
                BaseService baseService=(BaseService) FactoryBean.getBean("BaseService");
               String tel = baseService.getJdbcTemplate().queryForObject("select tel  from    _sys_LoginUser where usercode=" + GridUtils.prossSqlParm(foundation.getUserCode()), String.class);
                MailPush.pushEmailInfo(t482101HEntityList,docCodeList,foundation.getDbId(),tel);
            }
        } catch (Exception e) {
            throw e;