| | |
|---|
| | | import com.yeshi.fanli.service.inter.lable.QualityFactoryService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.OrderProcessService;
|
|---|
| | | import com.yeshi.fanli.service.inter.push.IOSPushService;
|
|---|
| | | import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.ExtractService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserInfoService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
|
|---|
| | |
|---|
| | | @Resource
|
|---|
| | | private ThreeSaleSerivce threeSaleSerivce;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private TaoBaoOrderService taoBaoOrderService;
|
|---|
| | |
|
|---|
| | | private static boolean isInited = false;
|
|---|
| | |
|
|---|
| | | public void onApplicationEvent(ContextRefreshedEvent arg0) {
|
|---|
| | |
|---|
| | | doUpdateGoodsJob();
|
|---|
| | | } else if (!Constant.IS_TEST) {
|
|---|
| | | initScheduler();// 启动定时任务
|
|---|
| | | // |
|---|
| | | //
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | | */
|
|---|
| | | public void doTaoBaoOrders() {
|
|---|
| | | // 同时开启3个线程处理
|
|---|
| | | for (int i = 0; i < 3; i++) {
|
|---|
| | | for (int i = 0; i < 1; i++) {
|
|---|
| | | executor.execute(new Runnable() {
|
|---|
| | | @Override
|
|---|
| | | public void run() {
|
|---|
| | |
|---|
| | | // 取16个订单
|
|---|
| | | Map<String, List<TaoBaoOrder>> map = CMQManager.getInstance().consumeTaoBaoOrderMsg(16);
|
|---|
| | | if (map != null) {
|
|---|
| | | // 从库里面查询
|
|---|
| | | Iterator<String> its = map.keySet().iterator();
|
|---|
| | | while (its.hasNext()) {
|
|---|
| | | String orderId = its.next();
|
|---|
| | | List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId);
|
|---|
| | | map.put(orderId, orderList);
|
|---|
| | | }
|
|---|
| | | orderProcessService.processOrder(map);
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
