package org.springblade.modules.task.service.impl;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import org.springblade.common.utils.SpringUtils;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.mp.support.Query;
|
import org.springblade.modules.customTask.entity.CustomTaskEntity;
|
import org.springblade.modules.place.service.IPlaceService;
|
import org.springblade.modules.place.vo.PlaceVO;
|
import org.springblade.modules.task.entity.TaskEntity;
|
import org.springblade.modules.task.entity.TaskPlaceSelfCheckEntity;
|
import org.springblade.modules.task.service.ITaskPlaceSelfCheckService;
|
import org.springblade.modules.task.service.ITaskService;
|
import org.springblade.modules.task.service.TaskHandle;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
|
/**
|
* 自查任务ServiceImpl
|
*/
|
@Component("SelfExaminationTaskHandler")
|
public class SelfExaminationTaskHandler implements TaskHandle {
|
|
@Autowired
|
private IPlaceService placeService;
|
|
@Autowired
|
private ITaskPlaceSelfCheckService taskPlaceSelfCheckService;
|
|
@Override
|
public void taskHandle(CustomTaskEntity customTask) {
|
try {
|
Query query = new Query();
|
IPage<PlaceVO> page = Condition.getPage(query);
|
PlaceVO placeVO = new PlaceVO();
|
placeVO.setPoiCodes(customTask.getPlaceLabel().toString());
|
placeVO.setNineType(customTask.getNineType());
|
IPage<PlaceVO> placePage = placeService.getPlacePage(page, placeVO);
|
ITaskService iTaskService = SpringUtils.getBean(ITaskService.class);
|
// 计算总页数
|
long pages = placePage.getPages();
|
for (int i = 1; i <= pages; i++) {
|
page = Condition.getPage(query);
|
page.setCurrent(i);
|
placePage = placeService.getPlacePage(page, placeVO);
|
placePage.getRecords().forEach(place -> {
|
TaskEntity taskEntity = new TaskEntity();
|
taskEntity.setType(1);
|
taskEntity.setName("自查");
|
taskEntity.setCreateTime(new Date());
|
taskEntity.setHouseCode(place.getHouseCode());
|
taskEntity.setReportType(7);
|
taskEntity.setStatus(4);
|
taskEntity.setFrequency(2);
|
// taskEntitiesList.add(taskEntity);
|
iTaskService.save(taskEntity);
|
|
TaskPlaceSelfCheckEntity taskPlaceSelfCheck = new TaskPlaceSelfCheckEntity();
|
taskPlaceSelfCheck.setTaskId(taskEntity.getId());
|
taskPlaceSelfCheck.setHouseCode(place.getHouseCode());
|
taskPlaceSelfCheck.setPlaceName(place.getPlaceName());
|
taskPlaceSelfCheck.setStatus(4);
|
taskPlaceSelfCheckService.save(taskPlaceSelfCheck);
|
// taskPlaceSelfCheckList.add(taskPlaceSelfCheck);
|
});
|
}
|
} catch (Exception e) {
|
System.out.println("自查任务异常" + e);
|
}
|
// iTaskService.saveBatch(taskEntitiesList);
|
// boolean save = taskPlaceSelfCheckService.saveBatch(taskPlaceSelfCheckList);
|
|
}
|
}
|
