|
@@ -8,11 +8,16 @@ import java.util.concurrent.locks.Lock;
|
|
import java.util.concurrent.locks.ReentrantLock;
|
|
import java.util.concurrent.locks.ReentrantLock;
|
|
|
|
|
|
import com.iamberry.wechat.core.entity.admin.ShopSystemRule;
|
|
import com.iamberry.wechat.core.entity.admin.ShopSystemRule;
|
|
|
|
+import com.iamberry.wechat.core.entity.coupon.CouponItem;
|
|
import com.iamberry.wechat.core.entity.order.NumberBacklogDto;
|
|
import com.iamberry.wechat.core.entity.order.NumberBacklogDto;
|
|
|
|
+import com.iamberry.wechat.core.entity.report.Report;
|
|
import com.iamberry.wechat.face.admin.SystemService;
|
|
import com.iamberry.wechat.face.admin.SystemService;
|
|
import com.iamberry.wechat.face.agentInfo.AgentPurchaseOrderService;
|
|
import com.iamberry.wechat.face.agentInfo.AgentPurchaseOrderService;
|
|
|
|
+import com.iamberry.wechat.face.coupon.CouponItemService;
|
|
import com.iamberry.wechat.face.integral.UseIntegralService;
|
|
import com.iamberry.wechat.face.integral.UseIntegralService;
|
|
|
|
+import com.iamberry.wechat.face.member.MemberService;
|
|
import com.iamberry.wechat.face.order.AdminOrderService;
|
|
import com.iamberry.wechat.face.order.AdminOrderService;
|
|
|
|
+import com.iamberry.wechat.face.report.ReportService;
|
|
import com.iamberry.wechat.service.ImberryConfig;
|
|
import com.iamberry.wechat.service.ImberryConfig;
|
|
import com.iamberry.wechat.tools.HttpClient431Util;
|
|
import com.iamberry.wechat.tools.HttpClient431Util;
|
|
import com.iamberry.wechat.tools.NameUtils;
|
|
import com.iamberry.wechat.tools.NameUtils;
|
|
@@ -51,22 +56,16 @@ public class MQTask implements InitializingBean {
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private MQServiceProxy mQSerivce;
|
|
private MQServiceProxy mQSerivce;
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private RatFWLogger logger;
|
|
private RatFWLogger logger;
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private WechatTaskService wechatTaskService;
|
|
private WechatTaskService wechatTaskService;
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private RebackServices rebackServices;
|
|
private RebackServices rebackServices;
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private ProbationShopOrderService probationShopOrderService;
|
|
private ProbationShopOrderService probationShopOrderService;
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private SendMessageUtil sendMessageUtil;
|
|
private SendMessageUtil sendMessageUtil;
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private CodeService codeService;
|
|
private CodeService codeService;
|
|
@Autowired
|
|
@Autowired
|
|
@@ -77,6 +76,12 @@ public class MQTask implements InitializingBean {
|
|
private UseIntegralService useIntegralService;
|
|
private UseIntegralService useIntegralService;
|
|
@Autowired
|
|
@Autowired
|
|
private AdminOrderService adminOrderService;
|
|
private AdminOrderService adminOrderService;
|
|
|
|
+ @Autowired
|
|
|
|
+ private CouponItemService couponItemService;
|
|
|
|
+ @Autowired
|
|
|
|
+ private MemberService memberService;
|
|
|
|
+ @Autowired
|
|
|
|
+ private ReportService reportService;
|
|
|
|
|
|
private Lock lock = new ReentrantLock();
|
|
private Lock lock = new ReentrantLock();
|
|
|
|
|
|
@@ -451,4 +456,44 @@ public class MQTask implements InitializingBean {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 每天0点统计上朵领取优惠券信息
|
|
|
|
+ *
|
|
|
|
+ * 领券人数:
|
|
|
|
+ * 使用券人数:
|
|
|
|
+ * 注册人数:
|
|
|
|
+ */
|
|
|
|
+ @SuppressWarnings(value = {"unchecked", "rawtypes"})
|
|
|
|
+ // @Scheduled(cron = "0 0/3 * * * ?")//每三分钟执行一次
|
|
|
|
+ @Scheduled(cron = "0 0 0 * * ?") //每天0点触发
|
|
|
|
+ public void report() {
|
|
|
|
+ logger.info("统计上朵领取优惠券信息");
|
|
|
|
+ Report report = new Report();
|
|
|
|
+ //获取需要查询的优惠券类型的id
|
|
|
|
+ String ids = systemService.selectOneShopRuleById(256).getRuleDesc();
|
|
|
|
+ String[] newIds = ids.split(",");
|
|
|
|
+ if(newIds == null){
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+ Integer[] couponIds = new Integer[newIds.length];
|
|
|
|
+ for (int i=0;i<newIds.length;i++) {
|
|
|
|
+ couponIds[i] = Integer.valueOf(newIds[i]);
|
|
|
|
+ }
|
|
|
|
+ CouponItem couponItem = new CouponItem();
|
|
|
|
+ couponItem.setCouponIds(couponIds);
|
|
|
|
+ Integer number = couponItemService.allCouponItemNumber(couponItem);
|
|
|
|
+ report.setReportCouponNumber(number);
|
|
|
|
+
|
|
|
|
+ couponItem.setCouponUseStatus(2);
|
|
|
|
+ number = couponItemService.allCouponItemNumber(couponItem);
|
|
|
|
+ report.setReportCouponUseNumber(number);
|
|
|
|
+
|
|
|
|
+ number = memberService.getRegisteredNumber();
|
|
|
|
+ report.setReportRegisteredNumber(number);
|
|
|
|
+
|
|
|
|
+ Integer flag = reportService.save(report);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
}
|
|
}
|