新增 宁波平台批量补推订单接口

This commit is contained in:
Lemon
2024-12-17 10:21:47 +08:00
parent 6c85fe49f8
commit ac62831a53
5 changed files with 29 additions and 4 deletions

View File

@@ -391,4 +391,7 @@ public interface OrderBasicInfoMapper {
List<BusinessOrderDetailInfoVO> getOrderDetailByStationIds(@Param("stationIds") List<String> stationIds, @Param("startTime") String startTime, @Param("endTime") String endTime);
List<OrderBasicInfo> queryOrdersByPileConnectorCodeAndStatus(@Param("pileConnectorCode") String pileConnectorCode, @Param("orderStatus") String orderStatus, @Param("payStatus") String payStatus);
List<String> tempGetOrderCodes(QueryOrderDTO dto);
}

View File

@@ -499,4 +499,11 @@ public interface OrderBasicInfoService{
* @param orderCode
*/
List<BusinessOrderBillingInfoVO> getOrderBillingDetail(String orderCode);
/**
* 临时接口根据站点id、订单创建时间区间查询订单编号
* @param dto
* @return
*/
List<String> tempGetOrderCodes(QueryOrderDTO dto);
}

View File

@@ -4192,5 +4192,10 @@ public class OrderBasicInfoServiceImpl implements OrderBasicInfoService {
}
return resultList;
}
@Override
public List<String> tempGetOrderCodes(QueryOrderDTO dto) {
return orderBasicInfoMapper.tempGetOrderCodes(dto);
}
}

View File

@@ -3071,4 +3071,13 @@
limit 20
</select>
<select id="tempGetOrderCodes" resultType="java.lang.String">
select
order_code
from
order_basic_info
where
station_id = #{stationId,jdbcType=VARCHAR}
and create_time between #{startTime,jdbcType=VARCHAR} and #{endTime,jdbcType=VARCHAR}
</select>
</mapper>

View File

@@ -974,12 +974,13 @@ public class ZhongDianLianPlatformServiceImpl implements ThirdPartyPlatformServi
ThirdPartySecretInfoVO ningBoSecretInfoVO = getNingBoSecretInfoVO();
// 根据站点id 开始时间,结束时间查询出所有的订单信息
List<OrderListVO> orderListVOS = orderBasicInfoService.selectOrderBasicInfoList(dto);
if (CollectionUtils.isEmpty(orderListVOS)) {
// List<OrderListVO> orderListVOS = orderBasicInfoService.selectOrderBasicInfoList(dto);
List<String> orderCodes = orderBasicInfoService.tempGetOrderCodes(dto);
if (CollectionUtils.isEmpty(orderCodes)) {
return "订单信息为空";
}
List<String> orderCodeList = orderListVOS.stream().map(OrderListVO::getOrderCode).collect(Collectors.toList());
for (String orderCode : orderCodeList) {
// List<String> orderCodeList = orderListVOS.stream().map(OrderListVO::getOrderCode).collect(Collectors.toList());
for (String orderCode : orderCodes) {
try {
String result = notificationChargeOrderInfo(orderCode, ningBoSecretInfoVO);
logger.info("订单:{} 推送结果:{}", orderCode, result);