流程-定时任务加日志。
This commit is contained in:
+2
@@ -50,6 +50,7 @@ public class InventoryAffirmJob implements Job {
|
|||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
||||||
|
log.info("清单确认流程,定时任务开启 =====================================================");
|
||||||
//获取状态为待确认的数据
|
//获取状态为待确认的数据
|
||||||
QueryWrapper<ProjectLawsInventoryEO> queryWrapperInventory = new QueryWrapper<>();
|
QueryWrapper<ProjectLawsInventoryEO> queryWrapperInventory = new QueryWrapper<>();
|
||||||
queryWrapperInventory.lambda().eq(ProjectLawsInventoryEO::getInventoryAffirmStatus, InventoryAffirmStatusEnum.LIST_TO_CONFIRM.getValue());
|
queryWrapperInventory.lambda().eq(ProjectLawsInventoryEO::getInventoryAffirmStatus, InventoryAffirmStatusEnum.LIST_TO_CONFIRM.getValue());
|
||||||
@@ -167,5 +168,6 @@ public class InventoryAffirmJob implements Job {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
log.info("清单确认流程,定时任务结束 =====================================================");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+3
-1
@@ -51,6 +51,7 @@ public class PrehomoJob implements Job {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
||||||
|
log.info("prehomo流程,定时任务开启 =====================================================");
|
||||||
|
|
||||||
//查询出已经启动了prehomo流程的数据。 并且流程没有结束。
|
//查询出已经启动了prehomo流程的数据。 并且流程没有结束。
|
||||||
QueryWrapper<ProjectTaskInventoryEO> queryProjectTaskInventoryWrapper = new QueryWrapper<>();
|
QueryWrapper<ProjectTaskInventoryEO> queryProjectTaskInventoryWrapper = new QueryWrapper<>();
|
||||||
@@ -98,7 +99,7 @@ public class PrehomoJob implements Job {
|
|||||||
for (ProjectTaskInventoryEO projectTaskInventoryEO : projectTaskInventoryEOList) {
|
for (ProjectTaskInventoryEO projectTaskInventoryEO : projectTaskInventoryEOList) {
|
||||||
if(StringUtils.equals(projectTaskInventoryEO.getProjectLawsInventoryId(),projectLawsInventoryEO.getId())){
|
if(StringUtils.equals(projectTaskInventoryEO.getProjectLawsInventoryId(),projectLawsInventoryEO.getId())){
|
||||||
if(projectLawsInventoryEO.getPrehomoDueDate() != null){
|
if(projectLawsInventoryEO.getPrehomoDueDate() != null){
|
||||||
//如果prehomo - 结束日期是当前日期
|
//如果prehomo - 结束日期是当前日期
|
||||||
if(StringUtils.equals(currentDateStr,sdf.format(projectLawsInventoryEO.getPrehomoDueDate()))){
|
if(StringUtils.equals(currentDateStr,sdf.format(projectLawsInventoryEO.getPrehomoDueDate()))){
|
||||||
if(StringUtils.isEmpty(projectTaskInventoryEO.getPrehomoSendMsgFlag())){
|
if(StringUtils.isEmpty(projectTaskInventoryEO.getPrehomoSendMsgFlag())){
|
||||||
if(StringUtils.isNotEmpty(projectLawsInventoryEO.getPrehomoDutyId())){
|
if(StringUtils.isNotEmpty(projectLawsInventoryEO.getPrehomoDutyId())){
|
||||||
@@ -177,5 +178,6 @@ public class PrehomoJob implements Job {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
log.info("prehomo流程,定时任务结束 =====================================================");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+2
-1
@@ -51,7 +51,7 @@ public class VerifyComplianceJob implements Job {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
||||||
|
log.info("验证符合性流程,定时任务开启 =====================================================");
|
||||||
//查询出已经启动了验证符合性流程的数据。 并且流程没有结束。
|
//查询出已经启动了验证符合性流程的数据。 并且流程没有结束。
|
||||||
QueryWrapper<ProjectTaskInventoryEO> queryProjectTaskInventoryWrapper = new QueryWrapper<>();
|
QueryWrapper<ProjectTaskInventoryEO> queryProjectTaskInventoryWrapper = new QueryWrapper<>();
|
||||||
queryProjectTaskInventoryWrapper.isNotNull("verify_p_id");
|
queryProjectTaskInventoryWrapper.isNotNull("verify_p_id");
|
||||||
@@ -177,5 +177,6 @@ public class VerifyComplianceJob implements Job {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
log.info("验证符合性流程,定时任务结束 =====================================================");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+2
-1
@@ -48,7 +48,7 @@ public class designComplianceJob implements Job {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
||||||
|
log.info("设计符合性确认流程,定时任务开启 =====================================================");
|
||||||
//查询出已经启动了设计符合性流程的数据。 并且流程没有结束。
|
//查询出已经启动了设计符合性流程的数据。 并且流程没有结束。
|
||||||
QueryWrapper<ProjectTaskInventoryEO> queryProjectTaskInventoryWrapper = new QueryWrapper<>();
|
QueryWrapper<ProjectTaskInventoryEO> queryProjectTaskInventoryWrapper = new QueryWrapper<>();
|
||||||
queryProjectTaskInventoryWrapper.isNotNull("design_p_id");
|
queryProjectTaskInventoryWrapper.isNotNull("design_p_id");
|
||||||
@@ -174,5 +174,6 @@ public class designComplianceJob implements Job {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
log.info("设计符合性确认流程,定时任务结束 =====================================================");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user