|
@@ -1,6 +1,7 @@
|
|
|
package com.yonge.cooleshow.admin.service.impl;
|
|
|
|
|
|
import com.github.pagehelper.PageHelper;
|
|
|
+import com.ym.mec.common.dto.SchoolDto;
|
|
|
import com.ym.mec.common.entity.GoodsSubStockModel;
|
|
|
import com.ym.mec.common.entity.HttpResponseResult;
|
|
|
import com.ym.mec.common.exception.BizException;
|
|
@@ -77,6 +78,23 @@ public class OmsOrderServiceImpl implements OmsOrderService {
|
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
|
List<OrderVo> list = orderDao.getList(queryParam);
|
|
|
|
|
|
+ // 过滤出学校订单,查询学校信息
|
|
|
+ List<Long> schoolIds = list.stream().filter(o->o.getSourceType() ==2).map(OmsOrder::getMemberId).collect(Collectors.toList());
|
|
|
+
|
|
|
+ if (!CollectionUtils.isEmpty(schoolIds)) {
|
|
|
+ HttpResponseResult<List<SchoolDto>> schoolDtoHttpResponseResult = webFeignService.schoolListByIds(schoolIds);
|
|
|
+ if (schoolDtoHttpResponseResult.getCode() == 200 && schoolDtoHttpResponseResult.getStatus()) {
|
|
|
+ Map<Long, SchoolDto> schoolDtoMap = schoolDtoHttpResponseResult.getData().stream().collect(Collectors.toMap(SchoolDto::getId, o -> o));
|
|
|
+ list.forEach(o->{
|
|
|
+ if (o.getSourceType() == 2) {
|
|
|
+ SchoolDto schoolDto = schoolDtoMap.get(o.getMemberId());
|
|
|
+ if (schoolDto != null) {
|
|
|
+ o.setSchoolName(schoolDto.getName());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
return list;
|
|
|
}
|