SpringContext中的循环任务优化,添加业务监控

admin

2020-07-29 c338aa60df58bee9f4c25afedf94fe6930a119c1

 fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java

@@ -13,6 +13,7 @@

import javax.annotation.Resource;

import com.yeshi.fanli.entity.SystemEnum;
import org.apache.commons.beanutils.PropertyUtils;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.core.task.TaskExecutor;
@@ -24,7 +25,7 @@

import com.yeshi.fanli.dao.dynamic.DynamicInfoDao;
import com.yeshi.fanli.dto.ConfigParamsDTO;
import com.yeshi.fanli.dto.taobao.TaoBaoShopDTO;
import com.yeshi.goods.facade.dto.taobao.TaoBaoShopDTO;
import com.yeshi.fanli.entity.bus.activity.ActivityRuleUser;
import com.yeshi.fanli.entity.bus.activity.ActivityUser;
import com.yeshi.fanli.entity.bus.activity.RecommendActivity;
@@ -36,34 +37,33 @@
import com.yeshi.fanli.entity.dynamic.DynamicInfo;
import com.yeshi.fanli.entity.dynamic.GoodsPicture;
import com.yeshi.fanli.entity.dynamic.InviteMaterial;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;
import com.yeshi.fanli.entity.taobao.TaoBaoShop;
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBriefExtra;
import com.yeshi.common.entity.taobao.TaoBaoShop;
import com.yeshi.goods.facade.entity.taobao.dataoke.DaTaoKeDetailV2;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.activity.ActivityUserService;
import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
import com.yeshi.fanli.service.inter.dynamic.DynamicInfoService;
import com.yeshi.fanli.service.inter.dynamic.GoodsEvaluateService;
import com.yeshi.fanli.service.inter.dynamic.InviteMaterialService;
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoShopService;
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailV2Service;
import com.yeshi.goods.facade.service.DaTaoKeGoodsDetailV2Service;
import com.yeshi.fanli.service.inter.user.QrCodeService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import org.yeshi.utils.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.dataoke.DaTaoKeApiUtil;
import com.yeshi.goods.facade.utils.taobao.DaTaoKeApiUtil;
import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
import com.yeshi.fanli.util.taobao.DaTaoKeUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
import com.yeshi.fanli.vo.msg.ClientTextStyleVO;
import com.yeshi.common.vo.ClientTextStyleVO;

import net.sf.json.JSONObject;

@@ -106,9 +106,6 @@
   @Resource
   private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;

   @Resource
   private GoodsEvaluateService goodsEvaluateService;
	
   @Override
   public void insert(DynamicInfo record) {
      dynamicInfoDao.insert(record);
@@ -306,7 +303,7 @@
      // 商品信息
      List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();
      for (TaoBaoGoodsBrief goodsBrief : listGoods) {
         BigDecimal proportion = hongBaoManageService.getFanLiRate();
         BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks);
         TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief,
               proportion.toString(), null);
         taoBaoGoodsBriefExtra.setCouponInfo(null);
@@ -362,7 +359,7 @@
         // 分享奖金
         BigDecimal shareMoney = new BigDecimal(0);

         BigDecimal proportion = hongBaoManageService.getFanLiRate();
         BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks);
         for (DaTaoKeDetailV2 daTaoKe : listDaTaoKe) {
            if (daTaoKeDetail == null) {
               daTaoKeDetail = daTaoKe;
@@ -377,7 +374,7 @@
               taoBaoGoodsBriefExtra.setState(1);
            }

            BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);
            BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief,SystemEnum.blks);
            shareMoney = MoneyBigDecimalUtil.add(shareMoney, money);
            // 商品图片
            taoBaoGoodsBriefExtra.setUpdatetime(new Date());
@@ -495,7 +492,7 @@
      }

      TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);
      BigDecimal proportion = hongBaoManageService.getFanLiRate();
      BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks);
      TaoBaoGoodsBriefExtra goodsExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(),
            null);

@@ -543,7 +540,7 @@
      goodsExtra.setImgList(imgList);

      // 分享奖金
      BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);
      BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief,SystemEnum.blks);
      ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
      shareMoneyDesc.setColor("#FFFFFF");
      shareMoneyDesc.setBottomColor("#E8AE48");
@@ -813,7 +810,7 @@
         List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();
         // 商品列表
         List<GoodsPicture> listPicture = new ArrayList<GoodsPicture>();
         BigDecimal proportion = hongBaoManageService.getFanLiRate();
         BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks);
         // 分享奖金
         BigDecimal shareMoney = new BigDecimal(0);

@@ -832,7 +829,7 @@
                     taoBaoGoodsBriefExtra.setState(1);
                  }

                  BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief);
                  BigDecimal money = taoBaoGoodsBriefService.getShareGoodsUserHongBao(taoBaoGoodsBrief,SystemEnum.blks);
                  shareMoney = MoneyBigDecimalUtil.add(shareMoney, money);
               } catch (TaobaoGoodsDownException e) {
                  taoBaoGoodsBrief = activityGoods.getTaoBaoGoodsBrief();
@@ -978,9 +975,9 @@
         // 提取商品
         Map<Long, TaoBaoGoodsBrief> goodsMap = getFilterGoodsMap(list);

         BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
         BigDecimal shareRate = hongBaoManageService.getShareRate();
          ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getFanLiRate(UserLevelEnum.superVIP));
         BigDecimal fanLiRate = hongBaoManageService.getFanLiRate(SystemEnum.blks);
         BigDecimal shareRate = hongBaoManageService.getShareRate(SystemEnum.blks);
          ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,hongBaoManageService.getFanLiRate(UserLevelEnum.superVIP,SystemEnum.blks));

         for (DynamicInfo dynamicInfo : list) {
            DynamicInfo dynamicNew = new DynamicInfo();
@@ -1083,7 +1080,7 @@
      }

      try {
         BigDecimal proportion = hongBaoManageService.getFanLiRate();
         BigDecimal proportion = hongBaoManageService.getFanLiRate(SystemEnum.blks);
         for (DynamicInfo dynamicInfo : list) {
            // 邀请数据不做更新
            long classId = dynamicInfo.getClassId();
@@ -1170,7 +1167,7 @@

                  // 更新热销单品的分享奖金
                  if (classId == 1) {
                     BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(goodsBrief);
                     BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(goodsBrief,SystemEnum.blks);
                     ClientTextStyleVO shareMoneyDesc = new ClientTextStyleVO();
                     shareMoneyDesc.setColor("#FFFFFF");
                     shareMoneyDesc.setBottomColor("#E8AE48");