From 66cba54f3b0748a9a9a33258dfe04dc3a4ba8687 Mon Sep 17 00:00:00 2001 From: xhxu Date: Fri, 11 Mar 2022 13:39:48 +0800 Subject: [PATCH] //test --- .../schedule/ChartDataScheduleTest.java | 656 +++++++++--------- 1 file changed, 328 insertions(+), 328 deletions(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/ChartDataScheduleTest.java b/mallinkSchedule/src/main/java/com/iformall/schedule/ChartDataScheduleTest.java index 51c5c94a4..48252a711 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/ChartDataScheduleTest.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/ChartDataScheduleTest.java @@ -1,331 +1,331 @@ -package com.iformall.schedule; - -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.iformall.common.IdWorker; -import com.iformall.domain.dto.WxCUserBasicInfoDto; -import com.iformall.domain.po.WxChartDataEntity; -import com.iformall.domain.po.WxCouponOrder; -import com.iformall.domain.po.WxMall; -import com.iformall.domain.po.WxMerchantTradeDaily; -import com.iformall.domain.po.base.TenantEntity; -import com.iformall.enums.EnumAppPlat; -import com.iformall.enums.EnumCarCmd; -import com.iformall.enums.EnumChartType; -import com.iformall.mapper.WxCUserCarMapper; -import com.iformall.mapper.WxChartDataMapper; -import com.iformall.mapper.WxMallMapper; -import com.iformall.service.*; -import com.iformall.service.cuser.CUserServiceFactory; -import com.iformall.utils.DateUtils; -import org.apache.commons.lang3.StringUtils; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.scheduling.annotation.Async; -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Component; - -import java.math.BigDecimal; -import java.util.Date; -import java.util.HashMap; -import java.util.List; - -/** - * @author gongbiao - */ -@Component -public class ChartDataScheduleTest { - - private final Logger logger = LoggerFactory.getLogger(this.getClass()); - - @Autowired - WxCarCmdLogService wxCarCmdLogService; - - @Autowired - WxMallMapper wxMallMapper; - - @Autowired - WxCUserCarMapper wxCUserCarMapper; - - @Autowired - WxChartDataMapper wxChartDataMapper; - - @Autowired - WxCouponOrderService wxCouponOrderService; - - @Autowired - WxMerchantTradeDailyService wxMerchantTradeDailyService; - - @Autowired - WxCUserCarService wxCUserCarService; - - @Autowired - private WxCUserBasicInfoService wxCUserBasicInfoService; - - @Autowired - private CUserServiceFactory cuserFactory; - - @Async - @Scheduled(cron = "0 30 22 10 3 ?") - public void testCreateData() { - createUserData(); - createCarData(); - createSaleData(); - createMerchantTradeData(); - } - - - /** - * 微信新增用户、抖音新增用户、ali新增用户,新增会员 - */ - public void createUserData() { - Date createtime = new Date(); - for (int i = 30;i > 0; i--){ - String yesterday = DateUtils.getTimeBefore(i, createtime); - Date date = DateUtils.stringToDate(yesterday); - String today = DateUtils.getTimeBefore(i-1, createtime); - Date endDate = DateUtils.stringToDate(today); - - logger.info("createUserData--date{}"+yesterday+"----- endDate{}"+today); - - WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); - wxChartDataEntity.setQuerytime(date); - WxCUserBasicInfoDto dto = new WxCUserBasicInfoDto(); - dto.setEndTime(endDate); - - List wxMalls = wxMallMapper.findList(null); - for (WxMall wxMall : wxMalls) { - TenantEntity tenantEntity = wxMall.getTenantInfo(); - dto.updateTenantInfo(tenantEntity); - wxChartDataEntity.updateTenantInfo(tenantEntity); - wxChartDataEntity.setType(EnumChartType.WX_USER.getCode()); - int count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("微信用户总数>>>>>>>>>>>>>>>>>>>>>>>>>>"); - long wxUserCount = cuserFactory.getCUserService(EnumAppPlat.WX).findCount(dto); - addChartData(tenantEntity, String.valueOf(wxUserCount), EnumChartType.WX_USER.getCode(), date, createtime); - } - wxChartDataEntity.setType(EnumChartType.TT_USER.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("抖音用户总数>>>>>>>>>>>>>>>>>>>>>>>>>>"); - long ttUserCount = cuserFactory.getCUserService(EnumAppPlat.TOUTIAO).findCount(dto); - addChartData(tenantEntity, String.valueOf(ttUserCount), EnumChartType.TT_USER.getCode(), date, createtime); - } -// wxChartDataEntity.setType(EnumChartType.ALI_USER.getCode()); -// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); -// if (count == 0) { -// logger.info("支付宝用户总数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +//package com.iformall.schedule; +// +//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +//import com.iformall.common.IdWorker; +//import com.iformall.domain.dto.WxCUserBasicInfoDto; +//import com.iformall.domain.po.WxChartDataEntity; +//import com.iformall.domain.po.WxCouponOrder; +//import com.iformall.domain.po.WxMall; +//import com.iformall.domain.po.WxMerchantTradeDaily; +//import com.iformall.domain.po.base.TenantEntity; +//import com.iformall.enums.EnumAppPlat; +//import com.iformall.enums.EnumCarCmd; +//import com.iformall.enums.EnumChartType; +//import com.iformall.mapper.WxCUserCarMapper; +//import com.iformall.mapper.WxChartDataMapper; +//import com.iformall.mapper.WxMallMapper; +//import com.iformall.service.*; +//import com.iformall.service.cuser.CUserServiceFactory; +//import com.iformall.utils.DateUtils; +//import org.apache.commons.lang3.StringUtils; +//import org.slf4j.Logger; +//import org.slf4j.LoggerFactory; +//import org.springframework.beans.factory.annotation.Autowired; +//import org.springframework.scheduling.annotation.Async; +//import org.springframework.scheduling.annotation.Scheduled; +//import org.springframework.stereotype.Component; +// +//import java.math.BigDecimal; +//import java.util.Date; +//import java.util.HashMap; +//import java.util.List; +// +///** +// * @author gongbiao +// */ +//@Component +//public class ChartDataScheduleTest { +// +// private final Logger logger = LoggerFactory.getLogger(this.getClass()); +// +// @Autowired +// WxCarCmdLogService wxCarCmdLogService; +// +// @Autowired +// WxMallMapper wxMallMapper; +// +// @Autowired +// WxCUserCarMapper wxCUserCarMapper; +// +// @Autowired +// WxChartDataMapper wxChartDataMapper; +// +// @Autowired +// WxCouponOrderService wxCouponOrderService; +// +// @Autowired +// WxMerchantTradeDailyService wxMerchantTradeDailyService; +// +// @Autowired +// WxCUserCarService wxCUserCarService; +// +// @Autowired +// private WxCUserBasicInfoService wxCUserBasicInfoService; +// +// @Autowired +// private CUserServiceFactory cuserFactory; +// +// @Async +// @Scheduled(cron = "0 30 22 10 3 ?") +// public void testCreateData() { +// createUserData(); +// createCarData(); +// createSaleData(); +// createMerchantTradeData(); +// } +// +// +// /** +// * 微信新增用户、抖音新增用户、ali新增用户,新增会员 +// */ +// public void createUserData() { +// Date createtime = new Date(); +// for (int i = 30;i > 0; i--){ +// String yesterday = DateUtils.getTimeBefore(i, createtime); +// Date date = DateUtils.stringToDate(yesterday); +// String today = DateUtils.getTimeBefore(i-1, createtime); +// Date endDate = DateUtils.stringToDate(today); +// +// logger.info("createUserData--date{}"+yesterday+"----- endDate{}"+today); +// +// WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); +// wxChartDataEntity.setQuerytime(date); +// WxCUserBasicInfoDto dto = new WxCUserBasicInfoDto(); +// dto.setEndTime(endDate); +// +// List wxMalls = wxMallMapper.findList(null); +// for (WxMall wxMall : wxMalls) { +// TenantEntity tenantEntity = wxMall.getTenantInfo(); +// dto.updateTenantInfo(tenantEntity); +// wxChartDataEntity.updateTenantInfo(tenantEntity); +// wxChartDataEntity.setType(EnumChartType.WX_USER.getCode()); +// int count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("微信用户总数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// long wxUserCount = cuserFactory.getCUserService(EnumAppPlat.WX).findCount(dto); +// addChartData(tenantEntity, String.valueOf(wxUserCount), EnumChartType.WX_USER.getCode(), date, createtime); +// } +// wxChartDataEntity.setType(EnumChartType.TT_USER.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("抖音用户总数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// long ttUserCount = cuserFactory.getCUserService(EnumAppPlat.TOUTIAO).findCount(dto); +// addChartData(tenantEntity, String.valueOf(ttUserCount), EnumChartType.TT_USER.getCode(), date, createtime); +// } +//// wxChartDataEntity.setType(EnumChartType.ALI_USER.getCode()); +//// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +//// if (count == 0) { +//// logger.info("支付宝用户总数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +//// } +// wxChartDataEntity.setType(EnumChartType.BASIC_USER.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("会员总数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// long basicUserCount = wxCUserBasicInfoService.findCount(dto); +// addChartData(tenantEntity, String.valueOf(basicUserCount), EnumChartType.BASIC_USER.getCode(), date, createtime); +// } +// dto.setStartTime(date); +// wxChartDataEntity.setType(EnumChartType.WX_USER_ADD.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("微信用户增加数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// long wxUserCount = cuserFactory.getCUserService(EnumAppPlat.WX).findCount(dto); +// addChartData(tenantEntity, String.valueOf(wxUserCount), EnumChartType.WX_USER_ADD.getCode(), date, createtime); +// } +// wxChartDataEntity.setType(EnumChartType.TT_USER_ADD.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("抖音用户增加数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// long ttUserCount = cuserFactory.getCUserService(EnumAppPlat.TOUTIAO).findCount(dto); +// addChartData(tenantEntity, String.valueOf(ttUserCount), EnumChartType.TT_USER_ADD.getCode(), date, createtime); +// } +//// wxChartDataEntity.setType(EnumChartType.ALI_USER_ADD.getCode()); +//// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +//// if (count == 0) { +//// logger.info("支付宝用户增加数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +//// } +// wxChartDataEntity.setType(EnumChartType.BASIC_USER_ADD.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("会员增加数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// long basicUserCount = wxCUserBasicInfoService.findCount(dto); +// addChartData(tenantEntity, String.valueOf(basicUserCount), EnumChartType.BASIC_USER_ADD.getCode(), date, createtime); +// } +// // } - wxChartDataEntity.setType(EnumChartType.BASIC_USER.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("会员总数>>>>>>>>>>>>>>>>>>>>>>>>>>"); - long basicUserCount = wxCUserBasicInfoService.findCount(dto); - addChartData(tenantEntity, String.valueOf(basicUserCount), EnumChartType.BASIC_USER.getCode(), date, createtime); - } - dto.setStartTime(date); - wxChartDataEntity.setType(EnumChartType.WX_USER_ADD.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("微信用户增加数>>>>>>>>>>>>>>>>>>>>>>>>>>"); - long wxUserCount = cuserFactory.getCUserService(EnumAppPlat.WX).findCount(dto); - addChartData(tenantEntity, String.valueOf(wxUserCount), EnumChartType.WX_USER_ADD.getCode(), date, createtime); - } - wxChartDataEntity.setType(EnumChartType.TT_USER_ADD.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("抖音用户增加数>>>>>>>>>>>>>>>>>>>>>>>>>>"); - long ttUserCount = cuserFactory.getCUserService(EnumAppPlat.TOUTIAO).findCount(dto); - addChartData(tenantEntity, String.valueOf(ttUserCount), EnumChartType.TT_USER_ADD.getCode(), date, createtime); - } -// wxChartDataEntity.setType(EnumChartType.ALI_USER_ADD.getCode()); -// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); -// if (count == 0) { -// logger.info("支付宝用户增加数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// } +// +// } +// +// /** +// * 出场车辆、缴费车辆、缴费金额、新增会员、新增停车会员、已绑车辆 +// */ +// public void createCarData() { +// Date createtime = new Date(); +// for (int i = 30;i > 0; i--) { +// String yesterday = DateUtils.getTimeBefore(i, createtime); +// Date date = DateUtils.stringToDate(yesterday); +// String today = DateUtils.getTimeBefore(i - 1, createtime); +// Date endDate = DateUtils.stringToDate(today); +// +// logger.info("createCarData--date{}" + yesterday + "----- endDate{}" + today); +// +// HashMap params = new HashMap<>(); +// params.put("startdate", yesterday + " 00:00:00"); +// params.put("enddate", today + " 00:00:00"); +// +// WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); +// wxChartDataEntity.setQuerytime(date); +// +// List wxMalls = wxMallMapper.findList(null); +// for (WxMall wxMall : wxMalls) { +// TenantEntity tenantEntity = wxMall.getTenantInfo(); +// params.put("tenantId", tenantEntity.getTenantId()); +// params.put("parentTenantId", tenantEntity.getParentTenantId()); +// wxChartDataEntity.updateTenantInfo(tenantEntity); +// wxChartDataEntity.setType(EnumChartType.CAR_IN.getCode()); +// int count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("入场车数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// params.put("cmdTypes",EnumCarCmd.getCarIn()); +// Long carOutCount = wxCarCmdLogService.queryHistoryCount(params); +// addChartData(tenantEntity, carOutCount.toString(), EnumChartType.CAR_IN.getCode(), date, createtime); +// } +// wxChartDataEntity.setType(EnumChartType.CAR_OUT.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("出场车数>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// params.put("cmdTypes",EnumCarCmd.getCarOut()); +// Long carOutCount = wxCarCmdLogService.queryHistoryCount(params); +// addChartData(tenantEntity, carOutCount.toString(), EnumChartType.CAR_OUT.getCode(), date, createtime); +// } +// wxChartDataEntity.setType(EnumChartType.CAR_PAID.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("缴费车辆>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// params.put("cmdTypes", EnumCarCmd.getCarPay()); +// Long carPayFeeCount = wxCarCmdLogService.queryHistoryCount(params); +// addChartData(tenantEntity, carPayFeeCount.toString(), EnumChartType.CAR_PAID.getCode(), date, createtime); +// } +// wxChartDataEntity.setType(EnumChartType.CAR_PAY_FEE.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("缴费金额>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// params.put("cmdTypes", EnumCarCmd.getCarPay()); +// String fee = wxCarCmdLogService.queryCarPay(params); +// addChartData(tenantEntity, fee, EnumChartType.CAR_PAY_FEE.getCode(), date, createtime); +// } +//// wxChartDataEntity.setType(EnumChartType.CAR_MEMBER.getCode()); +//// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +//// if (count == 0) { +//// logger.info("新增会员>>>>>>>>>>>>>>>>>>>>>>>>>>"); +//// carMemberData(params, createtime, date, tenantEntity); +//// } +// wxChartDataEntity.setType(EnumChartType.CAR_NEW_MEMBER.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("新增停车会员>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// WxCUserBasicInfoDto wxCUserBasicInfoDto = new WxCUserBasicInfoDto(); +// wxCUserBasicInfoDto.updateTenantInfo(tenantEntity); +// wxCUserBasicInfoDto.setStartTime(date); +// wxCUserBasicInfoDto.setEndTime(endDate); +// Integer carUserCount = wxCUserCarService.countUser(wxCUserBasicInfoDto); +// addChartData(tenantEntity, carUserCount.toString(), EnumChartType.CAR_NEW_MEMBER.getCode(), date, createtime); +// } +// wxChartDataEntity.setType(EnumChartType.CAR_BIND.getCode()); +// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("已绑车辆>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// Long todaybindcar = wxCUserCarService.queryCarCount(params); +// addChartData(tenantEntity, todaybindcar.toString(), EnumChartType.CAR_BIND.getCode(), date, createtime); +// } // } - wxChartDataEntity.setType(EnumChartType.BASIC_USER_ADD.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("会员增加数>>>>>>>>>>>>>>>>>>>>>>>>>>"); - long basicUserCount = wxCUserBasicInfoService.findCount(dto); - addChartData(tenantEntity, String.valueOf(basicUserCount), EnumChartType.BASIC_USER_ADD.getCode(), date, createtime); - } - - } - } - - } - - /** - * 出场车辆、缴费车辆、缴费金额、新增会员、新增停车会员、已绑车辆 - */ - public void createCarData() { - Date createtime = new Date(); - for (int i = 30;i > 0; i--) { - String yesterday = DateUtils.getTimeBefore(i, createtime); - Date date = DateUtils.stringToDate(yesterday); - String today = DateUtils.getTimeBefore(i - 1, createtime); - Date endDate = DateUtils.stringToDate(today); - - logger.info("createCarData--date{}" + yesterday + "----- endDate{}" + today); - - HashMap params = new HashMap<>(); - params.put("startdate", yesterday + " 00:00:00"); - params.put("enddate", today + " 00:00:00"); - - WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); - wxChartDataEntity.setQuerytime(date); - - List wxMalls = wxMallMapper.findList(null); - for (WxMall wxMall : wxMalls) { - TenantEntity tenantEntity = wxMall.getTenantInfo(); - params.put("tenantId", tenantEntity.getTenantId()); - params.put("parentTenantId", tenantEntity.getParentTenantId()); - wxChartDataEntity.updateTenantInfo(tenantEntity); - wxChartDataEntity.setType(EnumChartType.CAR_IN.getCode()); - int count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("入场车数>>>>>>>>>>>>>>>>>>>>>>>>>>"); - params.put("cmdTypes",EnumCarCmd.getCarIn()); - Long carOutCount = wxCarCmdLogService.queryHistoryCount(params); - addChartData(tenantEntity, carOutCount.toString(), EnumChartType.CAR_IN.getCode(), date, createtime); - } - wxChartDataEntity.setType(EnumChartType.CAR_OUT.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("出场车数>>>>>>>>>>>>>>>>>>>>>>>>>>"); - params.put("cmdTypes",EnumCarCmd.getCarOut()); - Long carOutCount = wxCarCmdLogService.queryHistoryCount(params); - addChartData(tenantEntity, carOutCount.toString(), EnumChartType.CAR_OUT.getCode(), date, createtime); - } - wxChartDataEntity.setType(EnumChartType.CAR_PAID.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("缴费车辆>>>>>>>>>>>>>>>>>>>>>>>>>>"); - params.put("cmdTypes", EnumCarCmd.getCarPay()); - Long carPayFeeCount = wxCarCmdLogService.queryHistoryCount(params); - addChartData(tenantEntity, carPayFeeCount.toString(), EnumChartType.CAR_PAID.getCode(), date, createtime); - } - wxChartDataEntity.setType(EnumChartType.CAR_PAY_FEE.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("缴费金额>>>>>>>>>>>>>>>>>>>>>>>>>>"); - params.put("cmdTypes", EnumCarCmd.getCarPay()); - String fee = wxCarCmdLogService.queryCarPay(params); - addChartData(tenantEntity, fee, EnumChartType.CAR_PAY_FEE.getCode(), date, createtime); - } -// wxChartDataEntity.setType(EnumChartType.CAR_MEMBER.getCode()); -// count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); -// if (count == 0) { -// logger.info("新增会员>>>>>>>>>>>>>>>>>>>>>>>>>>"); -// carMemberData(params, createtime, date, tenantEntity); +// } +// +// } +// +// /** +// * 销售总交易额 +// */ +// public void createSaleData() { +// Date createtime = new Date(); +// for (int i = 30;i > 0; i--) { +// String yesterday = DateUtils.getTimeBefore(i, createtime); +// Date date = DateUtils.stringToDate(yesterday); +// String today = DateUtils.getTimeBefore(i - 1, createtime); +// Date endDate = DateUtils.stringToDate(today); +// +// logger.info("createSaleData--date{}" + yesterday + "----- endDate{}" + today); +// +// WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); +// wxChartDataEntity.setQuerytime(date); +// List wxMalls = wxMallMapper.findList(null); +// for (WxMall wxMall : wxMalls) { +// TenantEntity tenantEntity = wxMall.getTenantInfo(); +// wxChartDataEntity.updateTenantInfo(tenantEntity); +// wxChartDataEntity.setType(EnumChartType.SALE_COUPON_PRICE.getCode()); +// int count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("销售总交易额>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// WxCouponOrder wxCouponOrder = new WxCouponOrder(); +// wxCouponOrder.updateTenantInfo(tenantEntity); +// wxCouponOrder.setStartTime(date); +// wxCouponOrder.setEndTime(endDate); +// Integer price = wxCouponOrderService.queryPriceTotal(wxCouponOrder); +// addChartData(tenantEntity, price.toString(), EnumChartType.SALE_COUPON_PRICE.getCode(), date, createtime); +// } // } - wxChartDataEntity.setType(EnumChartType.CAR_NEW_MEMBER.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("新增停车会员>>>>>>>>>>>>>>>>>>>>>>>>>>"); - WxCUserBasicInfoDto wxCUserBasicInfoDto = new WxCUserBasicInfoDto(); - wxCUserBasicInfoDto.updateTenantInfo(tenantEntity); - wxCUserBasicInfoDto.setStartTime(date); - wxCUserBasicInfoDto.setEndTime(endDate); - Integer carUserCount = wxCUserCarService.countUser(wxCUserBasicInfoDto); - addChartData(tenantEntity, carUserCount.toString(), EnumChartType.CAR_NEW_MEMBER.getCode(), date, createtime); - } - wxChartDataEntity.setType(EnumChartType.CAR_BIND.getCode()); - count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("已绑车辆>>>>>>>>>>>>>>>>>>>>>>>>>>"); - Long todaybindcar = wxCUserCarService.queryCarCount(params); - addChartData(tenantEntity, todaybindcar.toString(), EnumChartType.CAR_BIND.getCode(), date, createtime); - } - } - } - - } - - /** - * 销售总交易额 - */ - public void createSaleData() { - Date createtime = new Date(); - for (int i = 30;i > 0; i--) { - String yesterday = DateUtils.getTimeBefore(i, createtime); - Date date = DateUtils.stringToDate(yesterday); - String today = DateUtils.getTimeBefore(i - 1, createtime); - Date endDate = DateUtils.stringToDate(today); - - logger.info("createSaleData--date{}" + yesterday + "----- endDate{}" + today); - - WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); - wxChartDataEntity.setQuerytime(date); - List wxMalls = wxMallMapper.findList(null); - for (WxMall wxMall : wxMalls) { - TenantEntity tenantEntity = wxMall.getTenantInfo(); - wxChartDataEntity.updateTenantInfo(tenantEntity); - wxChartDataEntity.setType(EnumChartType.SALE_COUPON_PRICE.getCode()); - int count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("销售总交易额>>>>>>>>>>>>>>>>>>>>>>>>>>"); - WxCouponOrder wxCouponOrder = new WxCouponOrder(); - wxCouponOrder.updateTenantInfo(tenantEntity); - wxCouponOrder.setStartTime(date); - wxCouponOrder.setEndTime(endDate); - Integer price = wxCouponOrderService.queryPriceTotal(wxCouponOrder); - addChartData(tenantEntity, price.toString(), EnumChartType.SALE_COUPON_PRICE.getCode(), date, createtime); - } - } - } - - } - - /** - * 解单金额 - */ - public void createMerchantTradeData() { - Date createtime = new Date(); - for (int i = 30;i > 0; i--) { - String yesterday = DateUtils.getTimeBefore(i, createtime); - Date date = DateUtils.stringToDate(yesterday); - String today = DateUtils.getTimeBefore(i - 1, createtime); - Date endDate = DateUtils.stringToDate(today); - - logger.info("createSaleData--date{}" + yesterday + "----- endDate{}" + today); - WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); - wxChartDataEntity.setQuerytime(date); - List wxMalls = wxMallMapper.findList(null); - for (WxMall wxMall : wxMalls) { - TenantEntity tenantEntity = wxMall.getTenantInfo(); - - wxChartDataEntity.updateTenantInfo(tenantEntity); - wxChartDataEntity.setType(EnumChartType.MERCHANT_TRADE.getCode()); - int count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); - if (count == 0) { - logger.info("解单金额>>>>>>>>>>>>>>>>>>>>>>>>>>"); - WxMerchantTradeDaily wxMerchantTradeDaily = new WxMerchantTradeDaily(); - wxMerchantTradeDaily.updateTenantInfo(tenantEntity); - wxMerchantTradeDaily.setReportDate(yesterday); - Integer price = wxMerchantTradeDailyService.findSumMoney(wxMerchantTradeDaily); - addChartData(tenantEntity, price.toString(), EnumChartType.MERCHANT_TRADE.getCode(), date, createtime); - } - } - } - - } - - private void addChartData(TenantEntity tenantEntity, String result, Integer type, Date querytime, Date createtime) { - logger.info("即将插入数据>>>>>>>>>>>>>>>>>>>>>>>"); - final IdWorker idWorker = IdWorker.get(); - long id = idWorker.nextId(); - WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); - wxChartDataEntity.setId(id); - wxChartDataEntity.updateTenantInfo(tenantEntity); - wxChartDataEntity.setResult(result); - wxChartDataEntity.setType(type); - wxChartDataEntity.setQuerytime(querytime); - wxChartDataEntity.setCreatetime(createtime); - logger.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>" + wxChartDataEntity.toString()); - wxChartDataMapper.insert(wxChartDataEntity); - } - -} \ No newline at end of file +// } +// +// } +// +// /** +// * 解单金额 +// */ +// public void createMerchantTradeData() { +// Date createtime = new Date(); +// for (int i = 30;i > 0; i--) { +// String yesterday = DateUtils.getTimeBefore(i, createtime); +// Date date = DateUtils.stringToDate(yesterday); +// String today = DateUtils.getTimeBefore(i - 1, createtime); +// Date endDate = DateUtils.stringToDate(today); +// +// logger.info("createSaleData--date{}" + yesterday + "----- endDate{}" + today); +// WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); +// wxChartDataEntity.setQuerytime(date); +// List wxMalls = wxMallMapper.findList(null); +// for (WxMall wxMall : wxMalls) { +// TenantEntity tenantEntity = wxMall.getTenantInfo(); +// +// wxChartDataEntity.updateTenantInfo(tenantEntity); +// wxChartDataEntity.setType(EnumChartType.MERCHANT_TRADE.getCode()); +// int count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); +// if (count == 0) { +// logger.info("解单金额>>>>>>>>>>>>>>>>>>>>>>>>>>"); +// WxMerchantTradeDaily wxMerchantTradeDaily = new WxMerchantTradeDaily(); +// wxMerchantTradeDaily.updateTenantInfo(tenantEntity); +// wxMerchantTradeDaily.setReportDate(yesterday); +// Integer price = wxMerchantTradeDailyService.findSumMoney(wxMerchantTradeDaily); +// addChartData(tenantEntity, price.toString(), EnumChartType.MERCHANT_TRADE.getCode(), date, createtime); +// } +// } +// } +// +// } +// +// private void addChartData(TenantEntity tenantEntity, String result, Integer type, Date querytime, Date createtime) { +// logger.info("即将插入数据>>>>>>>>>>>>>>>>>>>>>>>"); +// final IdWorker idWorker = IdWorker.get(); +// long id = idWorker.nextId(); +// WxChartDataEntity wxChartDataEntity = new WxChartDataEntity(); +// wxChartDataEntity.setId(id); +// wxChartDataEntity.updateTenantInfo(tenantEntity); +// wxChartDataEntity.setResult(result); +// wxChartDataEntity.setType(type); +// wxChartDataEntity.setQuerytime(querytime); +// wxChartDataEntity.setCreatetime(createtime); +// logger.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>" + wxChartDataEntity.toString()); +// wxChartDataMapper.insert(wxChartDataEntity); +// } +// +//} \ No newline at end of file