消息修改
This commit is contained in:
liangqitao
+85
-1
@@ -3,9 +3,15 @@ package com.jero.payment.service.impl;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.jero.common.common.ProjectCommon;
|
||||
import com.jero.common.common.RoleCommon;
|
||||
import com.jero.common.dto.SendMessageDTO;
|
||||
import com.jero.common.enums.CompanyMessageEnums;
|
||||
import com.jero.common.enums.ManagementMessageEnums;
|
||||
import com.jero.common.enums.PaymentStatusEnum;
|
||||
import com.jero.common.exception.JeroBootException;
|
||||
import com.jero.common.service.SendMessageService;
|
||||
import com.jero.common.system.vo.LoginUser;
|
||||
import com.jero.common.util.PasswordUtil;
|
||||
import com.jero.contract.common.PayIncomeContractCommon;
|
||||
import com.jero.meeting.entity.PayMeetingSituation;
|
||||
import com.jero.meeting.mapper.PayMeetingSituationMapper;
|
||||
@@ -13,8 +19,10 @@ import com.jero.member.entity.PayMemberProjectSubitem;
|
||||
import com.jero.member.entity.TbMemberProjectSubitem;
|
||||
import com.jero.member.mapper.PayMemberProjectSubitemMapper;
|
||||
import com.jero.member.mapper.TbMemberProjectSubitemMapper;
|
||||
import com.jero.payment.entity.PayPaymentRecordSub;
|
||||
import com.jero.modules.system.entity.SysUser;
|
||||
import com.jero.modules.system.service.ISysUserService;
|
||||
import com.jero.payment.entity.PayPaymentRecord;
|
||||
import com.jero.payment.entity.PayPaymentRecordSub;
|
||||
import com.jero.payment.mapper.PayPaymentCheckMapper;
|
||||
import com.jero.payment.mapper.PayPaymentRecordMapper;
|
||||
import com.jero.payment.service.IPayPaymentCheckService;
|
||||
@@ -23,15 +31,21 @@ import com.jero.project.entity.PayCommonProject;
|
||||
import com.jero.project.entity.PayWorkingGroupSubItem;
|
||||
import com.jero.project.mapper.PayCommonProjectMapper;
|
||||
import com.jero.project.mapper.PayWorkingGroupSubItemMapper;
|
||||
import org.apache.commons.collections.CollectionUtils;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.apache.shiro.SecurityUtils;
|
||||
import org.springframework.beans.BeanUtils;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.core.env.Environment;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.math.BigDecimal;
|
||||
import java.util.Arrays;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Objects;
|
||||
|
||||
/**
|
||||
* 到账审核
|
||||
@@ -55,6 +69,12 @@ public class PayPaymentCheckServiceImpl extends ServiceImpl<PayPaymentCheckMappe
|
||||
private PayMemberProjectSubitemMapper payMemberProjectSubitemMapper;
|
||||
@Resource
|
||||
private TbMemberProjectSubitemMapper tbMemberProjectSubitemMapper;
|
||||
@Resource
|
||||
private Environment env;
|
||||
@Resource
|
||||
private ISysUserService sysUserService;
|
||||
@Resource
|
||||
private SendMessageService sendMessageService;
|
||||
|
||||
/**
|
||||
* 申请
|
||||
@@ -144,6 +164,70 @@ public class PayPaymentCheckServiceImpl extends ServiceImpl<PayPaymentCheckMappe
|
||||
BeanUtils.copyProperties(payPaymentRecord, payPaymentRecordSub);
|
||||
payPaymentCheckMapper.insert(payPaymentRecordSub);
|
||||
}
|
||||
/**
|
||||
* @Description 企业人员上传完汇款凭证之后 来款管理者 给财务人员 发送消息
|
||||
* @Date 2021/12/16 11:16
|
||||
* @param projectId 项目id
|
||||
* @param projectName 项目名称
|
||||
* @return void
|
||||
*/
|
||||
private void uploadSendMessage(String projectId,String projectName){
|
||||
// 来款管理者给财务人员发送消息
|
||||
List<SysUser> list = sysUserService.getRolesUser(Arrays.asList(RoleCommon.CWRY));
|
||||
if(!CollectionUtils.isEmpty(list)){
|
||||
list.forEach(item->{
|
||||
// 发送消息
|
||||
SendMessageDTO sendMessageDTO = new SendMessageDTO();
|
||||
if(!StringUtils.isBlank(item.getEmail())){
|
||||
sendMessageDTO.setEmail(PasswordUtil.decrypt(item.getEmail()));
|
||||
}
|
||||
if(!StringUtils.isEmpty(item.getPhone())){
|
||||
sendMessageDTO.setPhone(PasswordUtil.decrypt(item.getPhone()));
|
||||
}
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("projectName",projectName);
|
||||
sendMessageDTO.setFromUser(env.getProperty("message.systemEmailUser"));
|
||||
sendMessageDTO.setToUser(item.getUsername());
|
||||
sendMessageDTO.setTemplateCode(ManagementMessageEnums.MSG15.getCode());
|
||||
sendMessageDTO.setTemplateParam(map);
|
||||
sendMessageDTO.setBusType("M_OPEN_TYPE15");
|
||||
// todo 跳转未填写
|
||||
sendMessageService.SendMessageService(sendMessageDTO);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* @Description 汇款凭证审核不通过 审核人 给申请人发送消息
|
||||
* @Date 2021/12/16 11:34
|
||||
* @param userId 申请人id
|
||||
* @param projectId 项目id
|
||||
* @param projectName 项目名称
|
||||
* @return void
|
||||
*/
|
||||
private void checkSendMessage(String userId,String projectId,String projectName){
|
||||
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
||||
SysUser sysUserData = sysUserService.getById(userId);
|
||||
if(!Objects.isNull(sysUserData)){
|
||||
// 发送消息
|
||||
SendMessageDTO sendMessageDTO = new SendMessageDTO();
|
||||
if(!StringUtils.isBlank(sysUserData.getEmail())){
|
||||
sendMessageDTO.setEmail(PasswordUtil.decrypt(sysUserData.getEmail()));
|
||||
}
|
||||
if(!StringUtils.isEmpty(sysUserData.getPhone())){
|
||||
sendMessageDTO.setPhone(PasswordUtil.decrypt(sysUserData.getPhone()));
|
||||
sendMessageDTO.setToUser(PasswordUtil.decrypt(sysUserData.getPhone()));
|
||||
}
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("projectName",projectName);
|
||||
sendMessageDTO.setFromUser(sysUser.getUsername());
|
||||
sendMessageDTO.setTemplateCode(CompanyMessageEnums.MSG18.getCode());
|
||||
sendMessageDTO.setTemplateParam(map);
|
||||
sendMessageDTO.setBusType("C_OPEN_TYPE18");
|
||||
// todo 跳转未填写
|
||||
sendMessageService.SendMessageService(sendMessageDTO);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 审核
|
||||
|
||||
Reference in New Issue
Block a user