ERP系统
查看 | 历史 | 提交 | 提交对比
xinyb
6 天以前 aad276da26b3b44b7622343fa0bf15583e803585
提交 | 用户 | age
385e2d 1 package com.yc.crm.mail.service;
X 2
3 import com.yc.action.grid.GridUtils;
b7ef4b 4 import com.yc.crm.base.entity.T482115Entity;
658898 5 import com.yc.crm.mail.action.MailFolder;
b7ef4b 6 import com.yc.crm.mail.action.MailTag;
7caeae 7 import com.yc.crm.mail.entity.*;
385e2d 8 import com.yc.entity.AttachmentConfig;
X 9 import com.yc.sdk.shopping.service.imagedata.ShoppingImageDataIfc;
7caeae 10 import com.yc.sdk.weixincp.util.UploadFiles;
385e2d 11 import com.yc.service.BaseService;
X 12 import org.apache.commons.lang3.StringUtils;
13 import org.springframework.beans.factory.annotation.Autowired;
14 import org.springframework.jdbc.core.BeanPropertyRowMapper;
15 import org.springframework.stereotype.Service;
048b74 16 import org.springframework.transaction.annotation.Transactional;
385e2d 17
7caeae 18 import java.util.ArrayList;
X 19 import java.util.List;
f5cc47 20 import java.util.stream.Collectors;
385e2d 21
X 22 /**
23  * @BelongsProject: eCoWorksV3
24  * @BelongsPackage: com.yc.crm.mail.service
25  * @author: xinyb
26  * @CreateTime: 2024-08-06  09:57
27  * @Description:
28  */
29 @Service
30 public class MailImpl extends BaseService implements MailIfc {
31     @Autowired
32     MailAccountIfc emailAccountIfc;
33     @Autowired
34     ShoppingImageDataIfc imgData;
658898 35     @Autowired
X 36     MailTagIfc mailTagIfc;
37     @Autowired
38     MailFolderIfc mailFolderIfc;
385e2d 39
X 40     final static String shoppingImageServer = AttachmentConfig.get("attachment.server");
ad7c8d 41
048b74 42     @Transactional(rollbackFor = Exception.class)
385e2d 43     @Override
X 44     public t482101HEntity saveReceivingMail(t482101HEntity m) {
45         String sql = "set nocount on\n";
46         try {
3c2c1b 47             if (StringUtils.isBlank(m.getDocCode())) {
7cf738 48                 sql += "declare @docCode varchar(50) ,@unid varchar(50),@fieldId varchar(100),@originalFileName varchar(100)," +
X 49                         "@physicalFile varchar(50),@OriginalPicture varbinary(max) \n";
385e2d 50                 sql += "exec sp_newdoccode 482101," + GridUtils.prossSqlParm(m.getUserCode()) + ",@docCode output \n";
53241c 51                 sql += "insert into t482101H(companyId,companyName,formId,docCode,docdate,PeriodID,postCode,postname,mailType,senderName,sender,sender_time,receiver,receiving_time," +
57c8bf 52                         "cc,bcc,subject,userCode,userName,content,plain_text,messageId,read_flag,delete_flag,create_time,update_time," +//receive_time
d8f4b9 53                         "attach_flag,attachment_list) values ";
385e2d 54                 sql += "(" + GridUtils.prossSqlParm(m.getCompanyId()) + "," + GridUtils.prossSqlParm(m.getCompanyName()) + ",482101," +
X 55                         "@docCode,convert(varchar(10),getdate(),120),convert(varchar(7),getdate(),120),"
56                         + GridUtils.prossSqlParm(m.getUserCode()) + "," + GridUtils.prossSqlParm(m.getUserName()) + "," +
53241c 57                         +m.getMailType() + "," + GridUtils.prossSqlParm(m.getSenderName()) + "," + GridUtils.prossSqlParm(m.getSender()) + "," + GridUtils.prossSqlParm(m.getSenderTime()) + "," +
X 58                         GridUtils.prossSqlParm(StringUtils.join(m.getReceiver(), ",")) + "," + GridUtils.prossSqlParm(m.getReceivingTime()) + "," + GridUtils.prossSqlParm(StringUtils.join(m.getCc(), ",")) + "," +
f4c162 59                         GridUtils.prossSqlParm(StringUtils.join(m.getBcc(), ",")) + "," +
385e2d 60                         GridUtils.prossSqlParm(m.getSubject()) + "," + GridUtils.prossSqlParm(m.getUserCode()) + "," + GridUtils.prossSqlParm(m.getUserName()) + "," +
7caeae 61                         GridUtils.prossSqlParm(m.getContent()) + "," + GridUtils.prossSqlParm(m.getPlainText()) + "," + GridUtils.prossSqlParm(m.getMessageId()) + "," +
57c8bf 62                         m.getReadFlag() + "," + m.getDeleteFlag() + ",getdate(),getdate()," + m.getAttachFlag() + "," + GridUtils.prossSqlParm(m.getAttachmentList()) + ") \n" +
7caeae 63                         mailFileSql(m.getMailFile());
385e2d 64                 sql += "select @docCode as docCode";
X 65                 String docCode = jdbcTemplate.queryForObject(sql, String.class);
66                 if (StringUtils.isNotBlank(docCode)) {
67                     m.setDocCode(docCode);
68                 }
3c2c1b 69             } else {
385e2d 70                 updateReceivingMail(m);//修改
X 71             }
72             return m;
73         } catch (Exception e) {
74             throw e;
75         }
76     }
ad7c8d 77
048b74 78     @Transactional(rollbackFor = Exception.class)
385e2d 79     @Override
18553a 80     public String saveReceivingMailList(List<t482101HEntity> mail) {
385e2d 81         String sql = "set nocount on\n";
X 82         try {
18553a 83             sql += "declare @docCode varchar(50) ,@unid varchar(50),@fieldId varchar(100),@originalFileName varchar(100),@docCodeList varchar(3000)=''," +
7cf738 84                     "@physicalFile varchar(50),@OriginalPicture varbinary(max) \n";
385e2d 85             for (t482101HEntity m : mail) {//遍历内容
X 86                 sql += "exec sp_newdoccode 482101," + GridUtils.prossSqlParm(m.getUserCode()) + ",@docCode output \n";
18553a 87                 sql += " select @docCodeList=@docCodeList+@docCode+';'\n" +//返回单号
F 88                         "insert into t482101H(companyId,companyName,formId,docCode,docdate,PeriodID,postCode,postname,mailType,senderName,sender,sender_time,receiver,receiving_time," +
57c8bf 89                         "cc,bcc,subject,userCode,userName,content,plain_text,messageId,read_flag,delete_flag,create_time,update_time," +
d8f4b9 90                         "attach_flag,attachment_list) values ";
385e2d 91                 sql += "(" + GridUtils.prossSqlParm(m.getCompanyId()) + "," + GridUtils.prossSqlParm(m.getCompanyName()) + ",482101," +
X 92                         "@docCode,convert(varchar(10),getdate(),120),convert(varchar(7),getdate(),120),"
93                         + GridUtils.prossSqlParm(m.getUserCode()) + "," + GridUtils.prossSqlParm(m.getUserName()) + "," +
53241c 94                         +m.getMailType() + "," + GridUtils.prossSqlParm(m.getSenderName()) + "," + GridUtils.prossSqlParm(m.getSender()) + "," + GridUtils.prossSqlParm(m.getSenderTime()) + "," +
X 95                         GridUtils.prossSqlParm(StringUtils.join(m.getReceiver(), ",")) + "," + GridUtils.prossSqlParm(m.getReceivingTime()) + "," + GridUtils.prossSqlParm(StringUtils.join(m.getCc(), ",")) + "," +
f4c162 96                         GridUtils.prossSqlParm(StringUtils.join(m.getBcc(), ",")) + "," +
385e2d 97                         GridUtils.prossSqlParm(m.getSubject()) + "," + GridUtils.prossSqlParm(m.getUserCode()) + "," + GridUtils.prossSqlParm(m.getUserName()) + "," +
7caeae 98                         GridUtils.prossSqlParm(m.getContent()) + "," + GridUtils.prossSqlParm(m.getPlainText()) + "," + GridUtils.prossSqlParm(m.getMessageId()) + "," +
57c8bf 99                         m.getReadFlag() + "," + m.getDeleteFlag() + ",getdate(),getdate()," + m.getAttachFlag() + "," + GridUtils.prossSqlParm(m.getAttachmentList()) + ") \n" +
7caeae 100                         mailFileSql(m.getMailFile());
385e2d 101             }
b7ef4b 102             return jdbcTemplate.queryForObject(sql + "\n select @docCodeList", String.class);
385e2d 103         } catch (Exception e) {
X 104             throw e;
7caeae 105         }
X 106     }
107
108     /**
109      * 邮件附件的处理
110      *
111      * @param mailFile
112      * @return
113      */
114     private String mailFileSql(MailFileEntity mailFile) {
115         if (mailFile == null) {//附件保存
116             return "";
117         }
118         String sql = "";
119         String originalFileName = "";
120         String fileType = "";
121         try {
122             for (MailFileEntity.MailBodyPart file : mailFile.getPart()) {
123                 originalFileName = file.getFileName();
124                 fileType = file.getFileType();
125                 sql += "select @unid=" + GridUtils.prossSqlParm(mailFile.getUnId()) + "\n" +
7cf738 126                         ",@fieldId=" + GridUtils.prossSqlParm(file.getFieldId()) + "\n" +
7caeae 127                         ",@originalFileName=" + GridUtils.prossSqlParm(originalFileName) + "\n" +
7cf738 128                         ",@physicalFile=" + GridUtils.prossSqlParm(file.getPhysicalFile()) + "\n" +
7caeae 129                         ",@OriginalPicture=" + UploadFiles.byteToHexString(file.getByteFile()) + "\n";
X 130                 sql += "insert into _sys_Attachment(unId,formId,docCode,fieldId,physicalFile,originalFileName,FileSize,fileType,UploadTime,LastUpdateTime,OriginalPicture) values ";
7cf738 131                 sql += " (@unid,482101,@docCode,@fieldId,@physicalFile,@originalFileName," + file.getFileSize() + "," + GridUtils.prossSqlParm(fileType) + ",getdate(),getdate(),@OriginalPicture) \n";
7caeae 132             }
X 133             return sql;
134         } catch (Exception e) {
135             return "";
385e2d 136         }
X 137     }
ad7c8d 138
048b74 139     @Transactional(rollbackFor = Exception.class)
385e2d 140     @Override
X 141     public Integer updateReceivingMail(t482101HEntity mail) {
142         String sql = "set nocount on\n";
143         try {
f4c162 144             sql += "update t482101H set sender=" + GridUtils.prossSqlParm(mail.getSender()) + ",receiver=" + GridUtils.prossSqlParm(StringUtils.join(mail.getReceiver(), ",")) + "," +
X 145                     "cc=" + GridUtils.prossSqlParm(StringUtils.join(mail.getCc(), ",")) + ",bcc=" + GridUtils.prossSqlParm(StringUtils.join(mail.getBcc(), ",")) + ",subject=" + GridUtils.prossSqlParm(mail.getSubject()) + "," +
7caeae 146                     "content=" + GridUtils.prossSqlParm(mail.getContent()) + ",attachment_list=" + GridUtils.prossSqlParm(mail.getAttachmentList()) + ",mailType=" + mail.getMailType() + "," +
f4c162 147                     "update_time=getdate() \n";
5b1a4a 148             sql += " where docCode=" + GridUtils.prossSqlParm(mail.getDocCode()) + "\n";
428443 149             sql += "select @@ROWCOUNT";
X 150             return jdbcTemplate.queryForObject(sql, Integer.class);
f4c162 151         } catch (Exception e) {
X 152             throw e;
153         }
154     }
ad7c8d 155
048b74 156     @Transactional(rollbackFor = Exception.class)
f4c162 157     @Override
X 158     public Integer updateDeleteFlag(String userCode, String docCode) {
159         String sql = "set nocount on\n";
160         try {
161             sql += "declare @docCode varchar(200) ='" + docCode + "' \n";
162             sql += "update t482101H deleteFlag=1 where userCode =" + GridUtils.prossSqlParm(userCode) +
163                     " and docCode in (select list from GetInStr(@docCode))\n";//标记删除
5b1a4a 164             sql += " select @@ROWCOUNT";
428443 165             return jdbcTemplate.queryForObject(sql, Integer.class);
385e2d 166         } catch (Exception e) {
X 167             throw e;
168         }
169     }
ad7c8d 170
048b74 171     @Transactional(rollbackFor = Exception.class)
385e2d 172     @Override
5b1a4a 173     public Integer deleteEmail(String userCode, String docCode) {
385e2d 174         String sql = "set nocount on\n";
X 175         try {
f4c162 176             sql += "declare @docCode varchar(200) ='" + docCode + "' \n";
b7ef4b 177             sql += "update t482101H deleteFlag=1 where userCode =" + GridUtils.prossSqlParm(userCode) +
f4c162 178                     " and docCode in (select list from GetInStr(@docCode))\n";//标记删除
5b1a4a 179             sql += " select @@ROWCOUNT";
428443 180             return jdbcTemplate.queryForObject(sql, Integer.class);
f5cc47 181         } catch (Exception e) {
X 182             throw e;
183         }
184     }
185
186     @Override
5b1a4a 187     public Integer deleteEmail(String messageId) {
f5cc47 188         String sql = "set nocount on\n";
X 189         try {
f4c162 190             sql += "declare @messageId varchar(200) ='" + messageId + "' \n";
b7ef4b 191             sql += " delete t482101H where messageId in (select list from GetInStr(@messageId))\n";//删除
5b1a4a 192             sql += " select @@ROWCOUNT";
428443 193             return jdbcTemplate.queryForObject(sql, Integer.class);
385e2d 194         } catch (Exception e) {
X 195             throw e;
196         }
197     }
198
199     @Override
f4c162 200     public t482101HEntity getReceivingMailInfo(String docCode) {
385e2d 201         String sql = "set nocount on\n";
X 202         try {
ad7c8d 203             sql += "select top 1 DocCode,companyId,companyName,senderName,senderName,sender,receiver,mailType,subject,content,plain_text,file_unid as fileUNID,messageId," +
5b1a4a 204                     "read_flag,delete_flag,attach_flag,urgent_flag,receipt_flag,track_flag,userCode,userName,create_time,update_time," +
658898 205                     "send_status,receive_time,sign_id,attachment_list,remark,remark,sender_time,receiving_time," +
ad7c8d 206                     "(case when (isnull(handle_time,'') <> '' and isnull(handle_time,'') < getdate()) then 1 else 0 end) as handle,handle_time," +
X 207                     "DocVersion from t482101H " +
f4c162 208                     "where docCode=" + GridUtils.prossSqlParm(docCode);
385e2d 209             return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(t482101HEntity.class)).get(0);
X 210         } catch (Exception e) {
211             throw e;
212         }
213     }
214
215     @Override
195685 216     public List<t482101HList> getReceivingMailList(String email, Integer mailType, boolean isNoRead, String userCode, Integer page, Integer limit) {
385e2d 217         String sql = "set nocount on\n";
X 218         try {
ad7c8d 219             sql += "select companyId,companyName,mailType,DocCode,senderName,sender,receiver,subject,plain_text," +
658898 220                     "receive_time,update_time,create_time,senderName,sender,userCode,userName,folder_id,delete_Flag,attachment_list," +
7cf738 221                     "read_Flag,(case when (isnull(handle_time,'') <> '' and isnull(handle_time,'') < getdate()) then 1 else 0 end) as handle," +
658898 222                     "handle_time,sender_time,receiving_time from t482101H ";
5b1a4a 223             sql += " where userCode=" + GridUtils.prossSqlParm(userCode);
X 224             sql += " and mailType=" + mailType;//0：草稿箱 1：收件箱 2：发件箱
225             if (StringUtils.isNotBlank(email)) {
226                 if (mailType == 1) {
227                     sql += " and receiver like '%" + email + "%'";
228                 } else if (mailType == 2) {
229                     sql += " and sender =" + GridUtils.prossSqlParm(email);
230                 }
7cf738 231             }
X 232             if (isNoRead) {//0表示未读，1表示已读
233                 sql += " and isnull(read_flag,0) = 0";
385e2d 234             }
195685 235             sql += " order by docCode asc \n";
X 236             sql += " OFFSET (" + page + " - 1) * " + limit + " ROWS FETCH NEXT " + limit + " ROWS ONLY";
d8f4b9 237             return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(t482101HList.class));
X 238         } catch (Exception e) {
239             throw e;
240         }
241     }
242
243     @Override
195685 244     public List<t482101HList> getHandleMailList(String email, String userCode, Integer page, Integer limit) {
57c8bf 245         String sql = "set nocount on\n";
X 246         try {
247             sql += "select companyId,companyName,mailType,DocCode,senderName,sender,receiver,subject,plain_text," +
248                     "receive_time,update_time,create_time,senderName,sender,userCode,userName,folder_id,delete_Flag, " +
249                     "read_Flag,(case when (isnull(handle_time,'') <> '' and isnull(handle_time,'') < getdate()) then 1 else 0 end) as handle," +
658898 250                     "handle_time,sender_time,receiving_time from t482101H ";
57c8bf 251             sql += " where isnull(handle_time,'') <> '' and isnull(handle_time,'') < getdate()";
X 252             sql += " and userCode=" + GridUtils.prossSqlParm(userCode) + " and receiver like '%" + email + "%'";
195685 253             sql += " order by docCode asc \n";
X 254             sql += " OFFSET (" + page + " - 1) * " + limit + " ROWS FETCH NEXT " + limit + " ROWS ONLY";
57c8bf 255             return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(t482101HList.class));
X 256         } catch (Exception e) {
257             throw e;
258         }
259     }
260
261     @Override
aad276 262     public List<t482101HList> getFolderMailList(String type, String userCode, Integer page, Integer limit) throws Exception {
X 263         String sql = "set nocount on\n";
264         try {
265             String[] id = type.split("_");
266             if (id.length != 2) {
267                 throw new Exception("邮件类型Id格式不正确");
268             }
269             sql += "select companyId,companyName,mailType,DocCode,senderName,sender,receiver,subject,plain_text," +
270                     "receive_time,update_time,create_time,senderName,sender,userCode,userName,folder_id,delete_Flag, " +
271                     "read_Flag,(case when (isnull(handle_time,'') <> '' and isnull(handle_time,'') < getdate()) then 1 else 0 end) as handle," +
272                     "handle_time,sender_time,receiving_time from t482101H ";
273             sql += " where userCode=" + GridUtils.prossSqlParm(userCode) + " \n";
274             if (id[0].equals("folder")) {//是文件夹
275                 sql += " and folder_id=" + id[1] + " \n";
276             } else if (id[0].equals("tag")) {//是标签
277                 sql += " and tag_list like '%," + id[1] + ",%'";
278             }
279             sql += " order by docCode asc \n";
280             sql += " OFFSET (" + page + " - 1) * " + limit + " ROWS FETCH NEXT " + limit + " ROWS ONLY";
281             return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(t482101HList.class));
282         } catch (Exception e) {
283             throw e;
284         }
285     }
286
287     @Override
d8f4b9 288     public List<t482101HList> getUserMailList(String userCode) {
X 289         String sql = " set nocount on \n";
290         try {
7cf738 291             sql = "select a.DocCode,isnull(a.mailType,0) as mailType,isnull(a.read_flag,0) as read_flag,a.sender,a.receiver, " +
X 292                     "(case when (isnull(handle_time,'') <> '' and isnull(handle_time,'') < getdate()) then 1 else 0 end) as handle " +
293                     " from t482101H a where  a.userCode=" + GridUtils.prossSqlParm(userCode) + " order by a.mailType";
428443 294             return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(t482101HList.class));
385e2d 295         } catch (Exception e) {
X 296             throw e;
297         }
298     }
299
048b74 300     @Transactional(rollbackFor = Exception.class)
385e2d 301     @Override
X 302     public Integer updateMailDrafts(t482101HEntity mail) {
303         String sql = "set nocount on\n";
304         try {
f4c162 305             sql += "update t482101H set sender=" + GridUtils.prossSqlParm(mail.getSender()) + ",receiver=" + GridUtils.prossSqlParm(StringUtils.join(mail.getReceiver(), ",")) + "," +
f6ae0b 306                     "cc=" + GridUtils.prossSqlParm(StringUtils.join(mail.getCc(), ",")) + ",bcc=" + GridUtils.prossSqlParm(StringUtils.join(mail.getBcc(), ",")) + "," +
X 307                     "subject=" + GridUtils.prossSqlParm(mail.getSubject()) + ",messageId=" + GridUtils.prossSqlParm(mail.getMessageId()) + "," +
7caeae 308                     "content=" + GridUtils.prossSqlParm(mail.getContent()) + ",attachment_list=" + GridUtils.prossSqlParm(mail.getAttachmentList()) + ",mailType=" + mail.getMailType() + "," +
6a63e2 309                     "update_time=getdate() \n";
385e2d 310             sql += " where docCode=" + GridUtils.prossSqlParm(mail.getDocCode());
5b1a4a 311             sql += " select @@ROWCOUNT";
7caeae 312             return jdbcTemplate.queryForObject(sql, Integer.class);
X 313         } catch (Exception e) {
314             throw e;
315         }
3c2c1b 316     }
f5cc47 317
X 318     @Override
319     public List<String> getMessageIdList(String receiver) {
320         List<String> messageId = null;
321         String sql = " set nocount on \n";
322         try {
323             sql += "select messageId from t482101H where receiver='" + receiver + "'";
324             List<t482101HEntity> message = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(t482101HEntity.class));
325             if (message != null && message.size() > 0) {
326                 messageId = new ArrayList<>();
327                 messageId = message.stream().map(t482101HEntity::getMessageId).distinct().collect(Collectors.toList());//去重
328             }
329             return messageId;
330         } catch (Exception e) {
331             throw e;
332         }
333     }
57c8bf 334
048b74 335     @Transactional(rollbackFor = Exception.class)
f4c162 336     @Override
7cf738 337     public void updateRead(String docCode, boolean status) {
f4c162 338         String sql = " set nocount on \n";
X 339         try {
5b1a4a 340             sql += "declare @docCode varchar(200) ='" + docCode + "' \n";
7cf738 341             sql += "update t482101H set read_flag=" + (status ? 1 : 0) + " where docCode in (select list from GetInStr(@docCode))\n";
aad276 342             sql += "select @@ROWCOUNT";
X 343             jdbcTemplate.queryForObject(sql, Integer.class);
344         } catch (Exception e) {
345             throw e;
346         }
347     }
348
349     @Override
350     public void updateMailType(String docCode, Integer folderId, String tagId) {
351         String sql = " set nocount on \n";
352         try {
353             boolean bol = false;
354             sql += "declare @docCode varchar(200) ='" + docCode + "' \n";
355             sql += "update t482101H set \n";
356             if (!folderId.equals(0)) {
357                 sql += " folder_id=" + folderId + "\n";
358                 bol = true;
359             }
360             if (StringUtils.isNotBlank(tagId)) {
361                 sql += (bol ? "," : "") + " tag_list='," + tagId + ",' \n";
362             }
363             sql += " where docCode in (select list from GetInStr(@docCode))\n";
f4c162 364             sql += "select @@ROWCOUNT";
X 365             jdbcTemplate.queryForObject(sql, Integer.class);
366         } catch (Exception e) {
367             throw e;
368         }
369     }
d8f4b9 370
X 371     @Override
372     public List<MailModuleEntity> getMailModuleList(String userCode) {
373         List<MailModuleEntity> module = MailModuleEntity.setMailInitial();
374         try {
877259 375             List<T482102Entity> account = emailAccountIfc.getAccount(userCode);//获取这个账号绑定的邮箱
d8f4b9 376             List<t482101HList> userMail = getUserMailList(userCode);
X 377             for (MailModuleEntity m : module) {
378                 List<t482101HList> mailTypeList = null;
379                 int mailType = m.getMailType();//类型
380                 switch (mailType) {
381                     case 0://草稿箱
382                     case 1://收件箱
383                     case 2://发件箱
384                         if (mailType == 0) {
877259 385                             m.setChildren(new ArrayList<>());
d8f4b9 386                             if (userMail.size() > 0) {
X 387                                 m.setTotal((int) userMail.stream().filter(s -> s.getMailType().equals(mailType)).count());
388                             }
389                         } else {
390                             List<MailModuleEntity.MailCode> codeList = new ArrayList<>();
391                             MailModuleEntity.MailCode code = new MailModuleEntity.MailCode();
877259 392                             code.setKey(mailType == 1 ? "InboxPage1" : "IndexPage1");
d8f4b9 393                             code.setMailType(mailType);
X 394                             code.setMailName(mailType == 1 ? "全部收件" : "全部发件");
395                             codeList.add(code);
396                             if (account.size() == 0) {//没有直接跳过
877259 397                                 m.setChildren(codeList);
d8f4b9 398                                 continue;
X 399                             }
400                             int allCount = 0;
401                             int count = 0;
7caeae 402                             for (T482102Entity a : account) {
d8f4b9 403                                 MailModuleEntity.MailCode nextCode = new MailModuleEntity.MailCode();
6a63e2 404                                 String eMail = (mailType == 1 ? a.getReceiveEmail() : a.getSmtpEmail());//获取邮箱账号
7caeae 405                                 nextCode.setKey(mailType == 1 ? "receiver" : "sender");
6a63e2 406                                 nextCode.setMailName(eMail);
d8f4b9 407                                 nextCode.setMailType(m.getMailType());
7cf738 408 //                                if (userMail.size() > 0) {
X 409 //                                    count = (mailType == 1 ? (int) userMail.stream().filter(s -> s.getMailType().equals(mailType) && s.getReceiver().contains(eMail)).count() :
410 //                                            (int) userMail.stream().filter(s -> s.getMailType().equals(mailType) && s.getSender().contains(eMail)).count());
411 //                                    nextCode.setTotal(count);
412 //                                }
413                                 if (mailType == 1) {//是收件箱，统计未读数量
414                                     count = (int) userMail.stream().filter(s -> s.getMailType().equals(mailType) && s.getReceiver().contains(eMail) && s.getReadFlag().equals(0)).count();
d8f4b9 415                                     nextCode.setTotal(count);
X 416                                 }
417                                 codeList.add(nextCode);
418                                 allCount = (allCount + count);
419                             }
420                             codeList.get(0).setTotal(allCount);
421                             m.setTotal(allCount);
877259 422                             m.setChildren(codeList);
d8f4b9 423                         }
X 424                         break;
425                     case 3://待处理邮件
877259 426                         m.setChildren(new ArrayList<>());
d8f4b9 427                         if (userMail.size() > 0) {
7cf738 428                             m.setTotal((int) userMail.stream().filter(s -> s.getHandle().equals(1)).count());
d8f4b9 429                         }
X 430                         break;
431                     case 4://未读邮件
877259 432                         m.setChildren(new ArrayList<>());
d8f4b9 433                         if (userMail.size() > 0) {
7cf738 434                             m.setTotal((int) userMail.stream().filter(s -> s.getReadFlag().equals(0)).count());
d8f4b9 435                         }
X 436                         break;
437                     case 5://群邮箱
877259 438                         m.setChildren(new ArrayList<>());
d8f4b9 439                         break;
X 440                     default:
441                         break;
442                 }
443             }
444             return module;
445         } catch (Exception e) {
446             throw e;
447         }
448     }
57c8bf 449
658898 450     @Override
X 451     public List<MailModuleBelowEntity> getMailModuleBelowList(String userCode) {
452         List<MailModuleBelowEntity> below = MailModuleBelowEntity.setMailInitial();
453         try {
454             for (MailModuleBelowEntity b : below) {
455                 String key = b.getKey();
456                 if (key.equals("moduleBelowA")) {//文件夹
b7ef4b 457                     List<T482107Entity> t482107 = mailFolderIfc.getMailFolder(userCode);
X 458                     b.setList(MailFolder.getFolderModule(t482107, ""));
658898 459                 }
X 460                 if (key.equals("moduleBelowB")) {//标签邮件
b7ef4b 461                     List<T482115Entity> tag = mailTagIfc.getTagList(userCode, "", -1);
X 462                     b.setList(MailTag.getTagModule(tag));
658898 463                 }
X 464                 if (key.equals("moduleBelowC")) {//显示更多
465                     List<MailModuleBelowEntity> CList = new ArrayList<>();
b7ef4b 466                     MailModuleBelowEntity delete = new MailModuleBelowEntity();
X 467                     delete.setKey("deleteMail");
468                     delete.setName("已删除邮件");
469                     CList.add(delete);
470                     MailModuleBelowEntity waste = new MailModuleBelowEntity();
471                     waste.setKey("wasteMail");
472                     waste.setName("垃圾邮件");
473                     CList.add(waste);
474                     MailModuleBelowEntity track = new MailModuleBelowEntity();
475                     track.setKey("trackMail");
476                     track.setName("追踪信息");
477                     CList.add(track);
478                     b.setList(CList);
658898 479                 }
X 480             }
481             return below;
482         } catch (Exception e) {
483             throw e;
484         }
485     }
486
048b74 487     @Transactional(rollbackFor = Exception.class)
7cf738 488     @Override
X 489     public void updateMailHandle(String handleTime, String docCode) {
490         String sql = " set nocount on \n";
491         try {
492             sql += "declare @docCode varchar(200) ='" + docCode + "' \n";
493             sql += "update t482101H set handle_time=" + (StringUtils.isBlank(handleTime) ? "null" : GridUtils.prossSqlParm(handleTime)) +
562e20 494                     " where docCode in (select list from GetInStr(@docCode))\n";
7cf738 495             sql += "select @@ROWCOUNT";
X 496             jdbcTemplate.queryForObject(sql, Integer.class);
497         } catch (Exception e) {
498             throw e;
499         }
500     }
0c7568 501
X 502     @Override
aad276 503     public Integer getMailTotal(String email, Integer mailType, boolean isNoRead, String id, String userCode) {
0c7568 504         String sql = "set nocount on\n";
X 505         try {
506             sql += "select count(*) from t482101H ";
507             sql += " where userCode=" + GridUtils.prossSqlParm(userCode);
508             if (mailType < 3) {
509                 sql += " and mailType=" + mailType;//0：草稿箱 1：收件箱 2：发件箱
510             }
511             if (StringUtils.isNotBlank(email)) {
aad276 512                 if (mailType == 1) {
X 513                     sql += " and receiver like '%" + email + "%'";
0c7568 514                 } else if (mailType == 2) {
X 515                     sql += " and sender =" + GridUtils.prossSqlParm(email);
aad276 516                 } else if (mailType == 3) {
X 517                     sql += " and isnull(handle_time,'') <> '' and isnull(handle_time,'') < getdate() ";
0c7568 518                 }
X 519             }
520             if (isNoRead) {//0表示未读，1表示已读
521                 sql += " and isnull(read_flag,0) = 0";
522             }
aad276 523             if (StringUtils.isNotBlank(id)) {//文件夹
X 524                 String[] type = id.split("_");
525                 if (type.length == 2) {
526                     if (type[0].equals("folder")) {
527                         sql += " and folder_id=" + type[1];
528                     } else if (type[0].equals("tag")) {
529                         sql += " and tag_list like '%," + type[1] + ",%'";
530                     }
531                 }
532             }
0c7568 533             return jdbcTemplate.queryForObject(sql, Integer.class);
X 534         } catch (Exception e) {
535             return 0;
536         }
537     }
385e2d 538 }