| | |
|---|
| | | package com.nanometer.smartlab.email; |
|---|
| | | |
|---|
| | | import com.nanometer.smartlab.entity.EmailStatus; |
|---|
| | | import com.nanometer.smartlab.entity.OpeWarehouseReserve; |
|---|
| | | import com.nanometer.smartlab.entity.SysReagent; |
|---|
| | | import com.nanometer.smartlab.entity.enumtype.EmailSendStatus; |
|---|
| | | import com.nanometer.smartlab.exception.BusinessException; |
|---|
| | |
|---|
| | | private OpeOrderService opeOrderService; |
|---|
| | | |
|---|
| | | private static Logger logger = Logger.getLogger(EmailSendSchedule.class); |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private SysReagentService sysReagentService; |
|---|
| | | @Resource |
|---|
| | | private OpeWarehouseReserveService opeWarehouseReserveService; |
|---|
| | | @Resource |
|---|
| | | private SysUserService userService; |
|---|
| | | |
|---|
| | | @Scheduled(fixedDelayString = "${emailSend.schedule.delay}") |
|---|
| | | public void EmailSendSchedule(){ |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | // @Scheduled(cron = "0/5 * * * * ?") //每隔5秒执行一次 |
|---|
| | | @Scheduled(cron = "0 0 8 * * ?") //每天8点执行一次 |
|---|
| | | @Scheduled(cron = "0 0/3 * * * ?") //每天8点执行一次 |
|---|
| | | public void EmailSendStock(){ |
|---|
| | | List<String> revicerList = new ArrayList<>(); |
|---|
| | | |
|---|
| | | //收件人为人员角色为库管员的邮箱 |
|---|
| | | List<String> revicerList = userService.getLibrarianEmail(); |
|---|
| | | //先查试剂表 安全库存大于0，然后去查库存，实际库存小于安全库存的列表 |
|---|
| | | List<SysReagent> sysReagentList = new ArrayList<>(); |
|---|
| | | |
|---|
| | | |
|---|
| | | //已经填写安全库存的试剂 |
|---|
| | | List<SysReagent> alreadyFillIn = sysReagentService.selectReagentSafetyNum(); |
|---|
| | | if (alreadyFillIn.size() > 0) { |
|---|
| | | for (SysReagent reagent : alreadyFillIn) { |
|---|
| | | int actualNum = opeWarehouseReserveService.countByReagentId(reagent.getId()); |
|---|
| | | if (reagent.getSafetynum() > actualNum) { |
|---|
| | | reagent.setActualnum(actualNum); |
|---|
| | | sysReagentList.add(reagent); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | StringBuffer content = new StringBuffer("<html><body>"); |
|---|
| | | content.append("<div style=\"line-height:1.7;color:#000000;font-size:14px;font-family:Arial\">"); |
|---|
| | | content.append("<table border=\"1\">"); |
|---|
| | |
|---|
| | | content.append("<td>"+sysReagent.getName()+"</td>"); |
|---|
| | | content.append("<td>"+sysReagent.getProductSn()+"</td>"); |
|---|
| | | content.append("<td>"+sysReagent.getCas()+"</td>"); |
|---|
| | | content.append("<td>"+sysReagent.getReagentType()+"</td>"); |
|---|
| | | |
|---|
| | | content.append("<td>"+sysReagent.getReagentType()+"</td>");// |
|---|
| | | content.append("<td>"+sysReagent.getSupplierName()+"</td>"); |
|---|
| | | |
|---|
| | | content.append("<td>"+sysReagent.getProductHomeName()+"</td>"); |
|---|
| | | content.append("<td>"+sysReagent.getReagentFormat()+"</td>"); |
|---|
| | | content.append("<td>"+sysReagent.getReagentUnit()+"</td>"); |
|---|
| | | //content.append("<td>"+sysReagent+"</td>");安全库存 |
|---|
| | | //content.append("<td>"+sysReagent+"</td>");实际库存 |
|---|
| | | |
|---|
| | | content.append("<td>"+sysReagent.getReagentFormat()+"</td>");// |
|---|
| | | |
|---|
| | | content.append("<td>"+sysReagent.getReagentUnit()+"</td>");// |
|---|
| | | content.append("<td>"+sysReagent.getSafetynum()+"</td>"); |
|---|
| | | content.append("<td>"+sysReagent.getActualnum()+"</td>"); |
|---|
| | | content.append("</tr>"); |
|---|
| | | } |
|---|
| | | content.append("</tbody></table></div>"); |
|---|
| | | content.append("</body></html>"); |
|---|
| | | |
|---|
| | | try { |
|---|
| | | EmailSend.sendArrivalEmail(revicerList,content.toString()); |
|---|
| | | // EmailSend.sendArrivalEmail(revicerList,content.toString()); |
|---|
| | | // 发送成功，更新邮件发送状态为：已发送 |
|---|
| | | } catch (BusinessException e) { |
|---|
| | | // 发送失败，更新邮件发送状态为：发送失败 |
|---|
