fanli-server.git

			@@ -17,36 +17,51 @@
			import org.yeshi.utils.tencentcloud.COSManager;
			import org.yeshi.utils.tencentcloud.entity.COSInitParams;

			import com.yeshi.fanli.dto.ad.DouYinDeviceActiveQueueDTO;
			import com.yeshi.fanli.dto.money.UserMoneyChangeDTO;
			import com.yeshi.fanli.entity.ad.DouYinClickEvent;
			import com.yeshi.fanli.entity.bus.user.AlipayTransferResultInfo;
			import com.yeshi.fanli.entity.bus.user.HongBaoV2;
			import com.yeshi.fanli.entity.bus.user.Order;
			import com.yeshi.fanli.entity.bus.user.ThreeSale;
			import com.yeshi.fanli.entity.bus.user.UserInfo;
			import com.yeshi.fanli.entity.jd.JDOrder;
			import com.yeshi.fanli.entity.order.CommonOrder;
			import com.yeshi.fanli.entity.order.HongBaoOrder;
			import com.yeshi.fanli.entity.pdd.PDDOrder;
			import com.yeshi.fanli.entity.push.DeviceActive;
			import com.yeshi.fanli.entity.push.PushQueueRecord;
			import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
			import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
			import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
			import com.yeshi.fanli.exception.TaoBaoWeiQuanException;
			import com.yeshi.fanli.exception.order.TaoBaoWeiQuanException;
			import com.yeshi.fanli.log.LogHelper;
			import com.yeshi.fanli.service.inter.hongbao.HongBaoV2Service;
			import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
			import com.yeshi.fanli.service.inter.integral.IntegralGetService;
			import com.yeshi.fanli.service.inter.jd.JDOrderService;
			import com.yeshi.fanli.service.inter.ad.DouYinClickEventService;
			import com.yeshi.fanli.service.inter.lable.BoutiqueAutoRuleService;
			import com.yeshi.fanli.service.inter.lable.LabelService;
			import com.yeshi.fanli.service.inter.money.UserMoneyDebtService;
			import com.yeshi.fanli.service.inter.money.extract.ExtractService;
			import com.yeshi.fanli.service.inter.order.CommonOrderService;
			import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
			import com.yeshi.fanli.service.inter.order.HongBaoV2Service;
			import com.yeshi.fanli.service.inter.order.OrderProcessService;
			import com.yeshi.fanli.service.inter.pdd.PDDOrderService;
			import com.yeshi.fanli.service.inter.order.jd.JDOrderService;
			import com.yeshi.fanli.service.inter.order.pdd.PDDOrderService;
			import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;
			import com.yeshi.fanli.service.inter.push.DeviceActiveService;
			import com.yeshi.fanli.service.inter.push.IOSPushService;
			import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
			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;
			import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;
			import com.yeshi.fanli.service.inter.user.integral.IntegralTaskRecordService;
			import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
			import com.yeshi.fanli.util.ad.DouYinAdUtil;
			import com.yeshi.fanli.util.cmq.DouYinDeviceActiveCMQManager;
			import com.yeshi.fanli.util.cmq.HongBaoRecieveCMQManager;
			import com.yeshi.fanli.util.cmq.JDOrderCMQManager;
			import com.yeshi.fanli.util.cmq.PDDOrderCMQManager;
			import com.yeshi.fanli.util.cmq.PlaceOrderCMQManager;
			import com.yeshi.fanli.util.cmq.ThreeSaleCMQManager;
			import com.yeshi.fanli.util.cmq.UserMoneyChangeCMQManager;
			import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
			@@ -111,6 +126,18 @@
			@Resource
			private IntegralGetService integralGetService;

			@Resource
			private CommonOrderService commonOrderService;

			@Resource
			private HongBaoOrderService hongBaoOrderService;

			@Resource
			private IntegralTaskRecordService integralTaskRecordService;

			@Resource
			private DeviceActiveService deviceActiveService;

			private static boolean isInited = false;

			public void onApplicationEvent(ContextRefreshedEvent arg0) {
			@@ -146,6 +173,8 @@
			doPDDOrderJob();// 拼多多订单处理
			doImportantTaoBaoGoodsUpdateJob();// 淘宝重要商品的信息更新
			doHongBaoRecieveIntegralGetJob();// 返利到账，金币增加
			doPlaceOrderIntegralJob();// 下单赠送金币任务
			doDouYinDeviceActiveJob();// 抖音设备激活广告监测
			}

			}
			@@ -743,7 +772,201 @@
			}
			}
			});
			}

			private boolean isFirstValidOrder(String orderId, int sourceType, Long uid) {
			CommonOrder commonOrder = commonOrderService.selectLatestValidByUid(uid);
			if (commonOrder != null && commonOrder.getOrderNo().equalsIgnoreCase(orderId)
			&& sourceType == commonOrder.getSourceType())
			return true;
			else
			return false;
			}

			// 下单获取金币任务
			public void doPlaceOrderIntegralJob() {
			executor.execute(new Runnable() {
			@Override
			public void run() {
			while (true) {
			Map<String, Order> map = PlaceOrderCMQManager.getInstance()
			.consumeQueueMsg(PlaceOrderCMQManager.QUEUE_INTEGRAL, 16);
			if (map != null) {
			// 是否是首单
			for (Iterator<String> its = map.keySet().iterator(); its.hasNext();) {
			try {
			String key = its.next();
			Order order = map.get(key);
			// 统计订单下的用户所获得的返利金额
			List<CommonOrder> list = commonOrderService
			.listBySourceTypeAndOrderId(order.getOrderType(), order.getOrderId());
			Map<Long, BigDecimal> hongBaoMoney = new HashMap<>();
			if (list != null)
			for (CommonOrder commonOrder : list) {
			HongBaoOrder hongBaoOrder = hongBaoOrderService
			.selectDetailByCommonOrderId(commonOrder.getId());
			if (hongBaoOrder != null && hongBaoOrder.getHongBaoV2() != null) {
			Long mainUid = hongBaoOrder.getHongBaoV2().getUserInfo().getId();
			if (hongBaoMoney.get(mainUid) == null)
			hongBaoMoney.put(mainUid, new BigDecimal(0));
			hongBaoMoney.put(mainUid, hongBaoMoney.get(mainUid)
			.add(hongBaoOrder.getHongBaoV2().getMoney()));
			// 查询上级
			List<HongBaoV2> children = hongBaoV2Service
			.listChildrenById(hongBaoOrder.getHongBaoV2().getId());
			if (children != null) {
			for (HongBaoV2 hongBao : children) {
			Long uid = hongBao.getUserInfo().getId();
			if (hongBaoMoney.get(uid) == null)
			hongBaoMoney.put(uid, new BigDecimal(0));
			hongBaoMoney.put(uid,
			hongBaoMoney.get(uid).add(hongBao.getMoney()));
			}
			}
			}
			}

			if (isFirstValidOrder(order.getOrderId(), order.getOrderType(),
			order.getUserInfo().getId())) {// 有效的首单
			if (hongBaoMoney.get(order.getUserInfo().getId()) == null \|\| hongBaoMoney
			.get(order.getUserInfo().getId()).compareTo(new BigDecimal("0")) <= 0) {
			// 分享奖金是0
			integralTaskRecordService.firstShareOrderReward(order.getUserInfo().getId(),
			null);
			}

			// 获取上两级数据
			UserInfo boss = threeSaleSerivce.getBoss(order.getUserInfo().getId());
			if (boss != null) {// 判断上级的红包
			if (hongBaoMoney.get(boss.getId()) == null
			\|\| hongBaoMoney.get(boss.getId()).compareTo(new BigDecimal("0")) <= 0) {
			// 补偿金币
			integralTaskRecordService.firstSharerOrderRewardBoss(boss.getId(),
			order.getUserInfo().getId(), null);
			}
			}

			} else {// 自购订单
			UserInfo boss = threeSaleSerivce.getBoss(order.getUserInfo().getId());
			if (boss != null) {// 判断上级的红包
			if (hongBaoMoney.get(boss.getId()) == null
			\|\| hongBaoMoney.get(boss.getId()).compareTo(new BigDecimal("0")) <= 0) {
			// 补偿金币1级
			integralTaskRecordService.firstRebateOrderRewardBoss(boss.getId(),
			order.getUserInfo().getId(), null);
			}
			}

			boss = threeSaleSerivce.getBoss(boss.getId());
			if (boss != null) {// 判断上级的红包
			if (hongBaoMoney.get(boss.getId()) == null
			\|\| hongBaoMoney.get(boss.getId()).compareTo(new BigDecimal("0")) <= 0) {
			// 补偿金币2级
			integralTaskRecordService.firstRebateOrderRewardBossSuper(boss.getId(),
			order.getUserInfo().getId(), null);
			}
			}
			}
			PlaceOrderCMQManager.getInstance().deleteQueueMsg(PlaceOrderCMQManager.QUEUE_INTEGRAL,
			key);
			} catch (Exception e) {
			LogHelper.errorDetailInfo(e);
			}
			}

			}
			}
			}
			});
			}

			// 抖音广告监控
			public void doPlaceOrderAdJob() {
			executor.execute(new Runnable() {
			@Override
			public void run() {
			while (true) {
			Map<String, Order> map = PlaceOrderCMQManager.getInstance()
			.consumeQueueMsg(PlaceOrderCMQManager.QUEUE_AD, 16);
			if (map != null) {
			// 是否是首单
			for (Iterator<String> its = map.keySet().iterator(); its.hasNext();) {
			String key = its.next();
			Order order = map.get(key);
			if (isFirstValidOrder(order.getOrderId(), order.getOrderType(),
			order.getUserInfo().getId())) {// 有效的首单
			// TODO 抖音的数据回调
			}
			}
			}
			}
			}
			});
			}

			@Resource
			private DouYinClickEventService douYinClickEventService;

			// 抖音
			public void doDouYinDeviceActiveJob() {
			LogHelper.test("开始执行:doDouYinDeviceActiveJob");
			executor.execute(new Runnable() {
			@Override
			public void run() {
			LogHelper.test("开始执行:doDouYinDeviceActiveJob-run");
			while (true) {
			Map<String, DouYinDeviceActiveQueueDTO> map = DouYinDeviceActiveCMQManager.getInstance()
			.consume(16);
			if (map != null) {
			// 是否是首单
			for (Iterator<String> its = map.keySet().iterator(); its.hasNext();) {
			String key = its.next();
			DouYinDeviceActiveQueueDTO active = map.get(key);
			if (active.getType() == DouYinDeviceActiveQueueDTO.TYPE_AD) {// 抖音
			DouYinClickEvent event = douYinClickEventService.selectByAid(active.getAid());
			if (event != null) {
			if (event.getOs() == 0) {
			DeviceActive deviceActive = deviceActiveService
			.getFirstActiveInfoByImei(event.getUuid());
			if (deviceActive != null) {
			if (event != null) {
			if (event.getOs() == 0)
			DouYinAdUtil.activeAndroid(event.getCallback(), event.getImei(),
			deviceActive.getCreateTime().getTime());
			else if (event.getOs() == 1)
			DouYinAdUtil.activeIOS(event.getCallback(), event.getIdfa(),
			deviceActive.getCreateTime().getTime());
			}
			}
			} else {// TODO 处理IOS

			}
			}

			} else if (active.getType() == DouYinDeviceActiveQueueDTO.TYPE_DEVICE) {// 设备

			if (active.getPlatform() == 1) {
			DeviceActive deviceActive = deviceActiveService
			.getFirstActiveInfo(active.getDevice());
			if (deviceActive != null && deviceActive.getImei() != null) {
			DouYinClickEvent event = douYinClickEventService
			.selectByUuid(deviceActive.getImei());
			if (event != null) {// 回调
			if (deviceActive != null)
			DouYinAdUtil.activeAndroid(event.getCallback(), event.getImei(),
			deviceActive.getCreateTime().getTime());
			}
			}
			} else {
			// TODO 兼容IOS
			}
			}
			DouYinDeviceActiveCMQManager.getInstance().delete(key);
			}
			}
			}
			}
			});
			}

			}