package com.zy.acs.manager.manager.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.zy.acs.common.utils.GsonUtils; import com.zy.acs.framework.exception.CoolException; import com.zy.acs.manager.manager.entity.Code; import com.zy.acs.manager.manager.entity.Route; import com.zy.acs.manager.manager.mapper.RouteMapper; import com.zy.acs.manager.manager.service.CodeService; import com.zy.acs.manager.manager.service.RouteService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.*; @Service("routeService") public class RouteServiceImpl extends ServiceImpl implements RouteService { @Autowired private CodeService codeService; @Override public Route createRouteByCode(Code code0, Code code1) { return createRouteByCode(code0, code1, 0, null); } @Override public Route createRouteByCode(Code code0, Code code1, Integer direction, Long userId) { if (code0.getData().equals(code1.getData())) { return null; } Route route = this.findByCodeOfBoth(code0.getId(), code1.getId()); direction = Optional.ofNullable(direction).orElse(0); if (null == route) { Date now = new Date(); route = new Route(); route.setUuid(code0.getData() + "-" + code1.getData()); route.setStartCode(code0.getId()); route.setEndCode(code1.getId()); route.setDirection(direction); route.setCodeArr(GsonUtils.toJson(Arrays.asList(code0.getId(), code1.getId()))); route.setCreateBy(userId); route.setCreateTime(now); route.setUpdateBy(userId); route.setUpdateTime(now); if (!this.save(route)) { throw new CoolException(route.getCodeArr()+" save fail![Route]"); } } return route; } @Override public List findCodeDataOfSingle(Long code) { List neighborCodeList = new ArrayList<>(); for (Route route : this.list(new LambdaQueryWrapper().eq(Route::getStartCode, code))) { neighborCodeList.add(codeService.getById(route.getEndCode()).getData()); } for (Route route : this.list(new LambdaQueryWrapper().eq(Route::getEndCode, code))) { neighborCodeList.add(codeService.getById(route.getStartCode()).getData()); } return neighborCodeList; } @Override public Route findByCodeOfBoth(Long code0, Long code1) { Route route = getOne(new LambdaQueryWrapper().eq(Route::getStartCode, code0).eq(Route::getEndCode, code1).eq(Route::getStatus, 1)); if (null == route) { route = getOne(new LambdaQueryWrapper().eq(Route::getEndCode, code0).eq(Route::getStartCode, code1).eq(Route::getStatus, 1)); } return route; } }