| | |
| | | import com.mzl.flower.service.coupon.CouponRecordService; |
| | | import com.mzl.flower.service.coupon.CouponTemplateService2; |
| | | import com.mzl.flower.service.flower.FlowerCategoryService; |
| | | import com.mzl.flower.service.flower.FlowerService; |
| | | import com.mzl.flower.service.menber.impl.GrowthValueDealService; |
| | | import com.mzl.flower.service.payment.*; |
| | | import com.mzl.flower.thread.FlowerCategoryPriceThread; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.time.DateFormatUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | |
| | | @Autowired |
| | | private PartnerMapper partnerMapper; |
| | | |
| | | @Autowired |
| | | private FlowerService flowerService; |
| | | |
| | | @Autowired |
| | | private OrderMapper orderMapper; |
| | |
| | | @Autowired |
| | | private CouponTemplateService2 couponTemplateService2; |
| | | |
| | | @Scheduled(cron = "1 0/30 * * * ?") |
| | | @Autowired |
| | | private FlowerCategoryPriceThread thread; |
| | | |
| | | @Scheduled(cron = "1 1 0/2 * * ?") |
| | | public void calculateAvePrice() { |
| | | log.info("均价计算开始:" + DateFormatUtils.format(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss")); |
| | | List<FlowerCategory> cLs = categoryMapper.selectList(new QueryWrapper<FlowerCategory>() |
| | | .isNotNull("parent_id")); |
| | | if(cLs != null && cLs.size() > 0){ |
| | | List<Partner> ls = partnerMapper.selectList(new QueryWrapper<Partner>().eq("status", "P")); |
| | | for(FlowerCategory c : cLs){ |
| | | flowerService.calculateCategoryDaily(c.getId(), null); |
| | | |
| | | if(ls != null && ls.size() > 0){ |
| | | for(Partner p : ls){ |
| | | flowerService.calculateCategoryDaily(c.getId(), p.getId()); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | thread.run(); |
| | | log.info("均价计算结束:" + DateFormatUtils.format(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss")); |
| | | } |
| | | |