Commit ef3b0ba5 authored by yajun.zhang's avatar yajun.zhang

优化

parent 543be329
...@@ -3,10 +3,13 @@ package cn.quantgroup.customer.service.impl; ...@@ -3,10 +3,13 @@ package cn.quantgroup.customer.service.impl;
import static cn.quantgroup.customer.constant.Constant.GSON; import static cn.quantgroup.customer.constant.Constant.GSON;
import cn.quantgroup.customer.enums.ErrorCodeEnum; import cn.quantgroup.customer.enums.ErrorCodeEnum;
import cn.quantgroup.customer.model.kaordermapping.LoanOrderMapping;
import cn.quantgroup.customer.rest.vo.JsonResult; import cn.quantgroup.customer.rest.vo.JsonResult;
import cn.quantgroup.customer.rest.vo.thirdworkorder.ThirdWorkOrderExportVo; import cn.quantgroup.customer.rest.vo.thirdworkorder.ThirdWorkOrderExportVo;
import cn.quantgroup.customer.service.IKdspService; import cn.quantgroup.customer.service.IKdspService;
import cn.quantgroup.customer.service.http.IHttpService; import cn.quantgroup.customer.service.http.IHttpService;
import cn.quantgroup.customer.util.JSONTools;
import com.fasterxml.jackson.core.type.TypeReference;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
...@@ -44,7 +47,10 @@ public class KdspServiceImpl implements IKdspService { ...@@ -44,7 +47,10 @@ public class KdspServiceImpl implements IKdspService {
Map<String,String> header = new HashMap<>(); Map<String,String> header = new HashMap<>();
header.put("qg-tenant-id",tenantId.toString()); header.put("qg-tenant-id",tenantId.toString());
String result = httpService.post(url, header,orderNos); String result = httpService.post(url, header,orderNos);
jsonResult = GSON.fromJson(result, JsonResult.class);
TypeReference<JsonResult<List<ThirdWorkOrderExportVo>>> typeToken = new TypeReference<JsonResult<List<ThirdWorkOrderExportVo>>>() {
};
jsonResult = JSONTools.deserialize(result, typeToken);
log.info("工单查询订单详情返回值:{}", result); log.info("工单查询订单详情返回值:{}", result);
} catch (Exception ex) { } catch (Exception ex) {
log.error("工单查询订单详情异常",ex); log.error("工单查询订单详情异常",ex);
......
...@@ -289,8 +289,8 @@ public class ThirdWorkOrderServiceImpl implements IThirdWorkOrderService { ...@@ -289,8 +289,8 @@ public class ThirdWorkOrderServiceImpl implements IThirdWorkOrderService {
String tempSql = sql.toString() + " limit "+offset+","+pageSize; String tempSql = sql.toString() + " limit "+offset+","+pageSize;
Query nativeQuery = entityManager.createNativeQuery(tempSql); Query nativeQuery = entityManager.createNativeQuery(tempSql);
List<Object[]> result = nativeQuery.getResultList(); List<Object[]> result = nativeQuery.getResultList();
ThirdWorkOrderExportVo exportVo = new ThirdWorkOrderExportVo();
for (Object[] objects : result) { for (Object[] objects : result) {
ThirdWorkOrderExportVo exportVo = new ThirdWorkOrderExportVo();
if (objects[0] != null) { if (objects[0] != null) {
exportVo.setCreateTime(objects[0].toString()); exportVo.setCreateTime(objects[0].toString());
} }
...@@ -349,31 +349,31 @@ public class ThirdWorkOrderServiceImpl implements IThirdWorkOrderService { ...@@ -349,31 +349,31 @@ public class ThirdWorkOrderServiceImpl implements IThirdWorkOrderService {
} }
Map<String, List<ThirdWorkOrderExportVo>> groupBy = kdspResult.stream().collect(Collectors.groupingBy(ThirdWorkOrderExportVo::getOrderNo)); Map<String, List<ThirdWorkOrderExportVo>> groupBy = kdspResult.stream().collect(Collectors.groupingBy(ThirdWorkOrderExportVo::getOrderNo));
for (ThirdWorkOrderExportVo exportVo : dbAllData){ for (ThirdWorkOrderExportVo dbData : dbAllData){
List<ThirdWorkOrderExportVo> temp = groupBy.get(exportVo.getOrderNo()); List<ThirdWorkOrderExportVo> kdspOrders = groupBy.get(dbData.getOrderNo());
if (CollectionUtils.isEmpty(temp)){ if (CollectionUtils.isEmpty(kdspOrders)){
exportVos.add(exportVo); exportVos.add(dbData);
continue; continue;
} }
for (ThirdWorkOrderExportVo orderExportVo : temp){ for (ThirdWorkOrderExportVo kdspOrder : kdspOrders){
String orderStatus = exportVo.getOrderStatus(); String orderStatus = kdspOrder.getOrderStatus();
Integer code = StringUtils.isNotBlank(orderStatus)?Integer.parseInt(orderStatus):null; Integer code = StringUtils.isNotBlank(orderStatus)?Integer.parseInt(orderStatus):null;
KdspOrderStatusEnum orderStatusEnum = KdspOrderStatusEnum.getByCode(code); KdspOrderStatusEnum orderStatusEnum = KdspOrderStatusEnum.getByCode(code);
if (orderStatusEnum != null){ if (orderStatusEnum != null){
orderExportVo.setOrderStatus(orderStatusEnum.getDesc()); kdspOrder.setOrderStatus(orderStatusEnum.getDesc());
} }
orderExportVo.setId(exportVo.getId()); kdspOrder.setId(dbData.getId());
orderExportVo.setProcessInstanceId(exportVo.getProcessInstanceId()); kdspOrder.setProcessInstanceId(dbData.getProcessInstanceId());
orderExportVo.setCreateUser(exportVo.getCreateUser()); kdspOrder.setCreateUser(dbData.getCreateUser());
orderExportVo.setAcceptUser(exportVo.getAcceptUser()); kdspOrder.setAcceptUser(dbData.getAcceptUser());
orderExportVo.setStatus(exportVo.getStatus()); kdspOrder.setStatus(dbData.getStatus());
orderExportVo.setProblemDesc(exportVo.getProblemDesc()); kdspOrder.setProblemDesc(dbData.getProblemDesc());
orderExportVo.setCreateTime(exportVo.getCreateTime()); kdspOrder.setCreateTime(dbData.getCreateTime());
orderExportVo.setFeedbackChannel(exportVo.getFeedbackChannel()); kdspOrder.setFeedbackChannel(dbData.getFeedbackChannel());
orderExportVo.setQuestionLevel(exportVo.getQuestionLevel()); kdspOrder.setQuestionLevel(dbData.getQuestionLevel());
orderExportVo.setCloseTime(exportVo.getCloseTime()); kdspOrder.setCloseTime(dbData.getCloseTime());
exportVos.add(orderExportVo); exportVos.add(kdspOrder);
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment