提交代码

dev_xds
姜玉琦 2024-04-21 13:42:09 +08:00
parent 895c8df662
commit 65c562bdd8
4 changed files with 13 additions and 9 deletions

View File

@ -2,6 +2,7 @@ package com.ruoyi.system.mapper;
import java.util.List;
import com.ruoyi.system.domain.SysUserOpenid;
import org.apache.ibatis.annotations.Param;
/**
* openIdMapper
@ -55,9 +56,10 @@ public interface SysUserOpenidMapper
* openId[]
*
* @param proId
* @param deptId
* @return openId
*/
public List<SysUserOpenid> findMsgProOrgUsers(Long proId);
public List<SysUserOpenid> findMsgProOrgUsers(@Param("proId") Long proId, @Param("deptId") Long deptId);
/**
* openId[]

View File

@ -50,7 +50,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
from sys_user_openid suo
left join sys_user su on su.phonenumber = suo.loginName
left join sur_project_userinfo spu on spu.user_id = su.user_id
where spu.project_id = #{proId} and spu.job_type=24 and spu.is_del = 0 and su.del_flag = '0' and suo.isDel=0
where spu.project_id = #{proId} and spu.dept_id = #{deptId} and spu.job_type=24 and spu.is_del = 0 and su.del_flag = '0' and suo.isDel=0
</select>
<select id="findMsgProMagUsers" parameterType="Long" resultMap="SysUserOpenidResult">

View File

@ -5,6 +5,8 @@ import org.apache.commons.lang3.builder.ToStringStyle;
import com.ruoyi.common.annotation.Excel;
import com.ruoyi.common.core.domain.BaseEntity;
import java.math.BigDecimal;
/**
* flow_labour_info
*
@ -60,7 +62,7 @@ public class FlowLabourInfo extends BaseEntity
/** 欠薪金额 */
@Excel(name = "欠薪金额")
private Long laborAmount;
private BigDecimal laborAmount;
/** 欠薪原因说明 */
@Excel(name = "欠薪原因说明")
@ -177,12 +179,12 @@ public class FlowLabourInfo extends BaseEntity
{
return laborNumber;
}
public void setLaborAmount(Long laborAmount)
public void setLaborAmount(BigDecimal laborAmount)
{
this.laborAmount = laborAmount;
}
public Long getLaborAmount()
public BigDecimal getLaborAmount()
{
return laborAmount;
}

View File

@ -588,7 +588,7 @@ public class WeChatMessageServiceImpl {
}
/**
*
*
* @param flowLabourInfo
*/
@Async
@ -599,7 +599,7 @@ public class WeChatMessageServiceImpl {
/**
*
*/
String supMsgId = this.getMsgProOrgUsers(flowLabourInfo.getProjectId());
String supMsgId = this.getMsgProOrgUsers(flowLabourInfo.getProjectId(),flowLabourInfo.getDeptId());
//模板数据
WxMpTemplateMessage templateMessage = WxMpTemplateMessage.builder()
.toUser(supMsgId)
@ -670,13 +670,13 @@ public class WeChatMessageServiceImpl {
* @param proId
* @return
*/
private String getMsgProOrgUsers(Long proId){
private String getMsgProOrgUsers(Long proId,Long deptId){
List<SysUserOpenid> list = redisCache.getCacheObject(CacheConstants.WX_MPMESSAGE_P_ORG +proId);
if(list!=null){
List<String> strs = list.stream().map(SysUserOpenid :: getMsgOpenId).collect(Collectors.toList());
return String.join(",",strs);
}else{
list = sysUserOpenidMapper.findMsgProOrgUsers(proId);
list = sysUserOpenidMapper.findMsgProOrgUsers(proId,deptId);
if(StringUtils.isNotEmpty(list)){
//设置30分钟有效期
redisCache.setCacheObject(CacheConstants.WX_MPMESSAGE_P_ORG +proId,list,30, TimeUnit.MINUTES);