| | |
| | | public void run() {
|
| | | while (true) {
|
| | | try {
|
| | |
|
| | | // 取16个订单
|
| | | List<String> orderIds = CMQManager.getInstance().consumeTaoBaoOrderMsg(16);
|
| | | Map<String, List<TaoBaoOrder>> map = new HashMap<>();
|
| | | if (orderIds != null) {
|
| | | for (String orderId : orderIds) {
|
| | | if (NumberUtil.isNumeric(orderId.trim())) {
|
| | | Map<String, List<TaoBaoOrder>> map = new HashMap<>();
|
| | | List<TaoBaoOrder> orderList = taoBaoOrderService
|
| | | .getTaoBaoOrderByOrderId(orderId);
|
| | | map.put(orderId, orderList);
|
| | |
| | | }
|
| | | } catch (Exception e) {
|
| | | LogHelper.error("还款出错:" + e.getMessage());
|
| | |
|
| | | }
|
| | | }
|
| | | }
|
| | |
| | | }
|
| | | PDDOrderCMQManager.getInstance().deletePDDOrder(key);
|
| | | } catch (Exception e) {
|
| | | try {
|
| | | LogHelper.errorDetailInfo(e);
|
| | | } catch (Exception e1) {
|
| | | e1.printStackTrace();
|
| | | }
|
| | | LogHelper.errorDetailInfo(e);
|
| | | }
|
| | | }
|
| | | }
|
| | | } catch (Exception e) {
|
| | | LogHelper.error("拼多多订单:" + e.getMessage());
|
| | |
|
| | | }
|
| | | }
|
| | | }
|