|
|
@ -32,11 +32,11 @@ import com.epmet.opendata.dao.PatrolRoutineWorkDao; |
|
|
|
import com.epmet.opendata.dto.ExDeptDTO; |
|
|
|
import com.epmet.opendata.dto.ExUserDTO; |
|
|
|
import com.epmet.opendata.dto.form.UpsertPatrolRecordForm; |
|
|
|
import com.epmet.opendata.entity.PatrolRoutineWorkEntity; |
|
|
|
import com.epmet.opendata.entity.BaseGridDailyworkEntity; |
|
|
|
import com.epmet.opendata.entity.UserPatrolDetailEntity; |
|
|
|
import com.epmet.opendata.service.ExDeptService; |
|
|
|
import com.epmet.opendata.service.ExUserService; |
|
|
|
import com.epmet.opendata.service.PatrolRoutineWorkService; |
|
|
|
import com.epmet.opendata.service.BaseGridDailyworkService; |
|
|
|
import com.epmet.opendata.service.UserPatrolDetailService; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.jetbrains.annotations.NotNull; |
|
|
@ -57,7 +57,7 @@ import java.util.Map; |
|
|
|
*/ |
|
|
|
@Slf4j |
|
|
|
@Service |
|
|
|
public class PatrolRoutingWorkServiceImpl extends BaseServiceImpl<PatrolRoutineWorkDao, PatrolRoutineWorkEntity> implements PatrolRoutineWorkService { |
|
|
|
public class BaseGridDailyworkServiceImpl extends BaseServiceImpl<PatrolRoutineWorkDao, BaseGridDailyworkEntity> implements BaseGridDailyworkService { |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private EpmetUserOpenFeignClient epmetUserOpenFeignClient; |
|
|
@ -121,7 +121,7 @@ public class PatrolRoutingWorkServiceImpl extends BaseServiceImpl<PatrolRoutineW |
|
|
|
return null; |
|
|
|
} |
|
|
|
private Boolean insertRecordBatch(List<PatrolRoutineWorkResult> list, boolean isReload, Map<String, ExDeptDTO> deptMap, Map<String, ExUserDTO> userMap){ |
|
|
|
List<PatrolRoutineWorkEntity> insertList = new ArrayList<>(); |
|
|
|
List<BaseGridDailyworkEntity> insertList = new ArrayList<>(); |
|
|
|
list.forEach(o-> insertList.add(buildEntity(o, deptMap, userMap))); |
|
|
|
//insert
|
|
|
|
if (CollectionUtils.isEmpty(insertList)){ |
|
|
@ -132,8 +132,8 @@ public class PatrolRoutingWorkServiceImpl extends BaseServiceImpl<PatrolRoutineW |
|
|
|
int i = userPatrolDetailService.deleteByCustomerId(list.get(0).getCustomerId()); |
|
|
|
log.info("insertRecordBatch del patrol effectRow:{}",i); |
|
|
|
} |
|
|
|
LambdaQueryWrapper<PatrolRoutineWorkEntity> wrapper = new LambdaQueryWrapper<>(); |
|
|
|
wrapper.eq(PatrolRoutineWorkEntity::getCustomerId, list.get(0).getCustomerId()); |
|
|
|
LambdaQueryWrapper<BaseGridDailyworkEntity> wrapper = new LambdaQueryWrapper<>(); |
|
|
|
wrapper.eq(BaseGridDailyworkEntity::getCustomerId, list.get(0).getCustomerId()); |
|
|
|
int delete = baseDao.delete(wrapper); |
|
|
|
log.info("insertRecordBatch del patrol effectRow:{}",delete); |
|
|
|
this.saveOrUpdateBatch(insertList, NumConstant.ONE_HUNDRED); |
|
|
@ -157,8 +157,8 @@ public class PatrolRoutingWorkServiceImpl extends BaseServiceImpl<PatrolRoutineW |
|
|
|
return detailEntity; |
|
|
|
} |
|
|
|
|
|
|
|
private PatrolRoutineWorkEntity buildEntity(PatrolRoutineWorkResult record, Map<String, ExDeptDTO> deptMap, Map<String, ExUserDTO> userMap) { |
|
|
|
PatrolRoutineWorkEntity entity = new PatrolRoutineWorkEntity(); |
|
|
|
private BaseGridDailyworkEntity buildEntity(PatrolRoutineWorkResult record, Map<String, ExDeptDTO> deptMap, Map<String, ExUserDTO> userMap) { |
|
|
|
BaseGridDailyworkEntity entity = new BaseGridDailyworkEntity(); |
|
|
|
entity.setCustomerId(record.getCustomerId()); |
|
|
|
|
|
|
|
ExDeptDTO exDeptDTO = deptMap.getOrDefault(record.getGridId(),new ExDeptDTO()); |