qt
/
weaver-hrm-salary
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

推送记录

This commit is contained in:
钱涛 2024-11-26 16:47:51 +08:00
parent 94da757524
commit 035209afa8
1 changed files with 22 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/com/engine/salary/service/impl/PushServiceImpl.java
View File

@ -26,6 +26,7 @@ import com.engine.salary.enums.push.PushItemFieldEnum;
import com.engine.salary.enums.push.PushRecordStatusEnum;
import com.engine.salary.enums.salaryformula.SalarySQLReferenceEnum;
import com.engine.salary.exception.SalaryRunTimeException;
import com.engine.salary.mapper.push.PushRecordMapper;
import com.engine.salary.mapper.push.PushSettingItemMapper;
import com.engine.salary.mapper.push.PushSettingMapper;
import com.engine.salary.service.*;
@ -37,6 +38,7 @@ import com.engine.salary.util.page.PageInfo;
import com.engine.salary.util.page.SalaryPageUtil;
import com.engine.salary.util.valid.ValidUtil;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.math.NumberUtils;
import weaver.conn.RecordSet;
import weaver.formmode.setup.ModeRightInfo;
import weaver.general.TimeUtil;
@ -64,6 +66,10 @@ public class PushServiceImpl extends Service implements PushService {
return MapperProxyFactory.getProxy(PushSettingItemMapper.class);
}
private PushRecordMapper getPushRecordMapper() {
return MapperProxyFactory.getProxy(PushRecordMapper.class);
}
private SalaryEmployeeService getSalaryEmployeeService(User user) {
return ServiceUtil.getService(SalaryEmployeeServiceImpl.class, user);
}
@ -352,21 +358,23 @@ public class PushServiceImpl extends Service implements PushService {
}
List<PushSettingPO> pushSettingPOS = getPushSettingMapper().listSome(PushSettingPO.builder().able(1).build());
pushSettingPOS.stream()
Date now = new Date();
List<PushRecordPO> pushRecordPOList = pushSettingPOS.stream()
.filter(po -> po.getSalarySobIds().contains(salaryAcctRecordPO.getSalarySobId()))
.map(po -> PushRecordPO.builder()
.id(IdGenerator.generate())
.name(po.getName())
.settingId()
.acctRecordId(salaryAcctRecordId)
.status(PushRecordStatusEnum.Waiting.getValue()))
.build();
.map(po -> PushRecordPO.builder()
.id(IdGenerator.generate())
.name(po.getName())
.settingId(po.getId())
.acctRecordId(salaryAcctRecordId)
.status(PushRecordStatusEnum.Waiting.getValue())
.createTime(now)
.updateTime(now)
.creator((long) user.getUID())
.deleteType(NumberUtils.INTEGER_ZERO)
.tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
.build()
)
.collect(Collectors.toList());
}