|
@@ -10,8 +10,11 @@ import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
|
|
|
import cn.iocoder.yudao.module.pms.constant.PmsConstants;
|
|
import cn.iocoder.yudao.module.pms.constant.PmsConstants;
|
|
|
import cn.iocoder.yudao.module.pms.controller.admin.iotryimprovedailyreport.vo.IotRyImproveDailyReportPageReqVO;
|
|
import cn.iocoder.yudao.module.pms.controller.admin.iotryimprovedailyreport.vo.IotRyImproveDailyReportPageReqVO;
|
|
|
import cn.iocoder.yudao.module.pms.controller.admin.iotryimprovedailyreport.vo.IotRyImproveDailyReportSaveReqVO;
|
|
import cn.iocoder.yudao.module.pms.controller.admin.iotryimprovedailyreport.vo.IotRyImproveDailyReportSaveReqVO;
|
|
|
|
|
+import cn.iocoder.yudao.module.pms.controller.admin.iotryimprovedailyreportdetail.vo.IotRyImproveDailyReportDetailSaveReqVO;
|
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.iotryimprovedailyreport.IotRyImproveDailyReportDO;
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.iotryimprovedailyreport.IotRyImproveDailyReportDO;
|
|
|
|
|
+import cn.iocoder.yudao.module.pms.dal.dataobject.iotryimprovedailyreportdetail.IotRyImproveDailyReportDetailDO;
|
|
|
import cn.iocoder.yudao.module.pms.dal.mysql.iotryimprovedailyreport.IotRyImproveDailyReportMapper;
|
|
import cn.iocoder.yudao.module.pms.dal.mysql.iotryimprovedailyreport.IotRyImproveDailyReportMapper;
|
|
|
|
|
+import cn.iocoder.yudao.module.pms.dal.mysql.iotryimprovedailyreportdetail.IotRyImproveDailyReportDetailMapper;
|
|
|
import cn.iocoder.yudao.module.pms.message.PmsMessage;
|
|
import cn.iocoder.yudao.module.pms.message.PmsMessage;
|
|
|
import cn.iocoder.yudao.module.supplier.enums.common.SupplierAuditStatusEnum;
|
|
import cn.iocoder.yudao.module.supplier.enums.common.SupplierAuditStatusEnum;
|
|
|
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
|
|
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
|
|
@@ -24,6 +27,7 @@ import cn.iocoder.yudao.module.system.dal.mysql.permission.UserRoleMapper;
|
|
|
import cn.iocoder.yudao.module.system.service.dept.DeptService;
|
|
import cn.iocoder.yudao.module.system.service.dept.DeptService;
|
|
|
import cn.iocoder.yudao.module.system.service.permission.RoleService;
|
|
import cn.iocoder.yudao.module.system.service.permission.RoleService;
|
|
|
import cn.iocoder.yudao.module.system.service.user.AdminUserService;
|
|
import cn.iocoder.yudao.module.system.service.user.AdminUserService;
|
|
|
|
|
+import com.google.common.collect.ImmutableMap;
|
|
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.validation.annotation.Validated;
|
|
import org.springframework.validation.annotation.Validated;
|
|
@@ -63,6 +67,8 @@ public class IotRyImproveDailyReportServiceImpl implements IotRyImproveDailyRepo
|
|
|
private ThreadPoolTaskExecutor pmsThreadPoolTaskExecutor;
|
|
private ThreadPoolTaskExecutor pmsThreadPoolTaskExecutor;
|
|
|
@Resource
|
|
@Resource
|
|
|
private PmsMessage pmsMessage;
|
|
private PmsMessage pmsMessage;
|
|
|
|
|
+ @Resource
|
|
|
|
|
+ private IotRyImproveDailyReportDetailMapper iotRyImproveDailyReportDetailMapper;
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public Long createIotRyImproveDailyReport(IotRyImproveDailyReportSaveReqVO createReqVO) {
|
|
public Long createIotRyImproveDailyReport(IotRyImproveDailyReportSaveReqVO createReqVO) {
|
|
@@ -80,6 +86,19 @@ public class IotRyImproveDailyReportServiceImpl implements IotRyImproveDailyRepo
|
|
|
iotRyImproveDailyReport.setAuditStatus(10);
|
|
iotRyImproveDailyReport.setAuditStatus(10);
|
|
|
iotRyImproveDailyReport.setCreator(loginUserDeptId.toString());
|
|
iotRyImproveDailyReport.setCreator(loginUserDeptId.toString());
|
|
|
iotRyImproveDailyReportMapper.insert(iotRyImproveDailyReport);
|
|
iotRyImproveDailyReportMapper.insert(iotRyImproveDailyReport);
|
|
|
|
|
+
|
|
|
|
|
+ // 创建生产动态明细
|
|
|
|
|
+ List<IotRyImproveDailyReportDetailSaveReqVO> details = createReqVO.getImproveReportDetails();
|
|
|
|
|
+ if (CollUtil.isNotEmpty(details)) {
|
|
|
|
|
+ List<IotRyImproveDailyReportDetailDO> tobeAddedReports = new ArrayList<>();
|
|
|
|
|
+ details.forEach(detail -> {
|
|
|
|
|
+ IotRyImproveDailyReportDetailDO tempDetail = BeanUtils.toBean(detail, IotRyImproveDailyReportDetailDO.class);
|
|
|
|
|
+ tempDetail.setReportId(iotRyImproveDailyReport.getId());
|
|
|
|
|
+ tobeAddedReports.add(tempDetail);
|
|
|
|
|
+ });
|
|
|
|
|
+ iotRyImproveDailyReportDetailMapper.insertBatch(tobeAddedReports);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
// 查找当前登录人的上级项目部审批人 发送审批通知
|
|
// 查找当前登录人的上级项目部审批人 发送审批通知
|
|
|
DataPermissionUtils.executeIgnore(() -> {
|
|
DataPermissionUtils.executeIgnore(() -> {
|
|
|
// 伊拉克项目部公共账号 填报 在当前部门内部查找 具有 审批权限 ‘项目部日报审批RY’ ‘项目部日报审批RYXJ’ 的人员
|
|
// 伊拉克项目部公共账号 填报 在当前部门内部查找 具有 审批权限 ‘项目部日报审批RY’ ‘项目部日报审批RYXJ’ 的人员
|
|
@@ -157,6 +176,22 @@ public class IotRyImproveDailyReportServiceImpl implements IotRyImproveDailyRepo
|
|
|
updateObj.setStatus(1);
|
|
updateObj.setStatus(1);
|
|
|
updateObj.setAuditStatus(10);
|
|
updateObj.setAuditStatus(10);
|
|
|
iotRyImproveDailyReportMapper.updateById(updateObj);
|
|
iotRyImproveDailyReportMapper.updateById(updateObj);
|
|
|
|
|
+
|
|
|
|
|
+ // 更新生成动态明细 先删除 再新增
|
|
|
|
|
+ int count = iotRyImproveDailyReportDetailMapper.deleteByMap(ImmutableMap.of(
|
|
|
|
|
+ "report_id", existReport.getId()
|
|
|
|
|
+ ));
|
|
|
|
|
+ List<IotRyImproveDailyReportDetailSaveReqVO> details = updateReqVO.getImproveReportDetails();
|
|
|
|
|
+ if (CollUtil.isNotEmpty(details)) {
|
|
|
|
|
+ List<IotRyImproveDailyReportDetailDO> tobeAddedReports = new ArrayList<>();
|
|
|
|
|
+ details.forEach(detail -> {
|
|
|
|
|
+ IotRyImproveDailyReportDetailDO tempDetail = BeanUtils.toBean(detail, IotRyImproveDailyReportDetailDO.class);
|
|
|
|
|
+ tempDetail.setReportId(existReport.getId());
|
|
|
|
|
+ tobeAddedReports.add(tempDetail);
|
|
|
|
|
+ });
|
|
|
|
|
+ iotRyImproveDailyReportDetailMapper.insertBatch(tobeAddedReports);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
// 钉钉 站内信 提醒项目部人员审批
|
|
// 钉钉 站内信 提醒项目部人员审批
|
|
|
// 查找当前登录人的上级项目部审批人 发送审批通知
|
|
// 查找当前登录人的上级项目部审批人 发送审批通知
|
|
|
DataPermissionUtils.executeIgnore(() -> {
|
|
DataPermissionUtils.executeIgnore(() -> {
|