三江业务中台定时同步进度
This commit is contained in:
parent
ac955351e2
commit
8fd79fc354
@ -8,6 +8,7 @@ import cn.hutool.core.date.DateUtil;
|
|||||||
import cn.hutool.core.util.NumberUtil;
|
import cn.hutool.core.util.NumberUtil;
|
||||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
||||||
import com.zhgd.xmgl.async.AsyncCommon;
|
import com.zhgd.xmgl.async.AsyncCommon;
|
||||||
|
import com.zhgd.xmgl.call.SanjiangDataCall;
|
||||||
import com.zhgd.xmgl.modules.basicdata.entity.SystemUser;
|
import com.zhgd.xmgl.modules.basicdata.entity.SystemUser;
|
||||||
import com.zhgd.xmgl.modules.basicdata.service.ISystemUserService;
|
import com.zhgd.xmgl.modules.basicdata.service.ISystemUserService;
|
||||||
import com.zhgd.xmgl.modules.project.constants.ProgressTaskConstant;
|
import com.zhgd.xmgl.modules.project.constants.ProgressTaskConstant;
|
||||||
@ -35,6 +36,8 @@ import java.util.stream.Collectors;
|
|||||||
@Slf4j
|
@Slf4j
|
||||||
@Component
|
@Component
|
||||||
public class ProgressAlarmTask {
|
public class ProgressAlarmTask {
|
||||||
|
@Autowired
|
||||||
|
SanjiangDataCall sanjiangDataCall;
|
||||||
@Autowired
|
@Autowired
|
||||||
ProgressTaskService progressTaskService;
|
ProgressTaskService progressTaskService;
|
||||||
|
|
||||||
@ -111,8 +114,11 @@ public class ProgressAlarmTask {
|
|||||||
progressTask.setStatus(ProgressTaskConstant.FINISH);
|
progressTask.setStatus(ProgressTaskConstant.FINISH);
|
||||||
progressTask.setActualFinishDate(currentDate);
|
progressTask.setActualFinishDate(currentDate);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
sanjiangDataCall.sendUpdateProgressTask(progressTask);
|
||||||
}
|
}
|
||||||
progressTaskService.updateBatchById(autoTask);
|
progressTaskService.updateBatchById(autoTask);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user