| | |
|---|
| | | if (Constant.IS_TASK) {
|
|---|
| | | doExtractResult();// 处理提现结果
|
|---|
| | | doTaoBaoOrders();// 处理淘宝订单
|
|---|
| | | doOrderFanLi();// 处理订单返利
|
|---|
| | | doOrderFanLiNew();// 新版返利
|
|---|
| | | doOrderTiChengFanLi();// 处理订单提成返利
|
|---|
| | | doWeiQuanOrder();// 处理维权订单
|
|---|
| | | doPushIOS();// 处理发送IOS消息
|
|---|
| | |
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 处理淘宝订单返利
|
|---|
| | | */
|
|---|
| | | public void doOrderFanLi() {
|
|---|
| | | executor.execute(new Runnable() {
|
|---|
| | | @Override
|
|---|
| | | public void run() {
|
|---|
| | | while (true) {
|
|---|
| | | try {
|
|---|
| | | Map<String, HongBao> map = CMQManager.getInstance().consumeFanLiMsg(16);
|
|---|
| | | if (map != null) {
|
|---|
| | | Iterator<String> its = map.keySet().iterator();
|
|---|
| | | while (its.hasNext()) {
|
|---|
| | | String handler = its.next();
|
|---|
| | | try {
|
|---|
| | | orderProcessService.fanli(map.get(handler));
|
|---|
| | | CMQManager.getInstance().deleteFanLiMsg(handler);
|
|---|
| | | } catch (TaoBaoWeiQuanException e) {
|
|---|
| | | try {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | } catch (Exception e1) {
|
|---|
| | | e1.printStackTrace();
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | try {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | } catch (Exception e1) {
|
|---|
| | | e1.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | } catch (Exception e) {
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
