|
|
|
@@ -7,6 +7,7 @@ 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.EnumCarCmd; |
|
|
|
import com.iformall.enums.EnumChartType; |
|
|
|
import com.iformall.mapper.*; |
|
|
|
@@ -77,45 +78,45 @@ public class ChartDataSchedule { |
|
|
|
|
|
|
|
List<WxMall> wxMalls = wxMallMapper.findList(null); |
|
|
|
for (WxMall wxMall : wxMalls) { |
|
|
|
String tenantId = wxMall.getTenantId(); |
|
|
|
params.put("tenantId", tenantId); |
|
|
|
wxChartDataEntity.setTenantId(tenantId); |
|
|
|
TenantEntity tenantEntity = wxMall.getTenantInfo(); |
|
|
|
params.put("tenantId", tenantEntity.getTenantId()); |
|
|
|
wxChartDataEntity.updateTenantInfo(tenantEntity); |
|
|
|
wxChartDataEntity.setType(EnumChartType.CAR_OUT.getCode()); |
|
|
|
int count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); |
|
|
|
if (count == 0) { |
|
|
|
logger.info("出场车数>>>>>>>>>>>>>>>>>>>>>>>>>>"); |
|
|
|
carOutData(params, createtime, date, tenantId); |
|
|
|
carOutData(params, createtime, date, tenantEntity); |
|
|
|
} |
|
|
|
wxChartDataEntity.setType(EnumChartType.CAR_PAID.getCode()); |
|
|
|
count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); |
|
|
|
if (count == 0) { |
|
|
|
params.put("cmdType", EnumCarCmd.CAR_ETCP_CALLBACK_PAY_MANUAL.getCode()); |
|
|
|
logger.info("缴费车辆>>>>>>>>>>>>>>>>>>>>>>>>>>"); |
|
|
|
carPaidData(params, createtime, date, tenantId); |
|
|
|
carPaidData(params, createtime, date, tenantEntity); |
|
|
|
} |
|
|
|
wxChartDataEntity.setType(EnumChartType.CAR_PAY_FEE.getCode()); |
|
|
|
count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); |
|
|
|
if (count == 0) { |
|
|
|
logger.info("缴费金额>>>>>>>>>>>>>>>>>>>>>>>>>>"); |
|
|
|
carPayFeeData(params, createtime, date, tenantId); |
|
|
|
carPayFeeData(params, createtime, date, tenantEntity); |
|
|
|
} |
|
|
|
wxChartDataEntity.setType(EnumChartType.CAR_MEMBER.getCode()); |
|
|
|
count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); |
|
|
|
if (count == 0) { |
|
|
|
logger.info("新增会员>>>>>>>>>>>>>>>>>>>>>>>>>>"); |
|
|
|
carMemberData(params, createtime, date, tenantId); |
|
|
|
carMemberData(params, createtime, date, tenantEntity); |
|
|
|
} |
|
|
|
wxChartDataEntity.setType(EnumChartType.CAR_NEW_MEMBER.getCode()); |
|
|
|
count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); |
|
|
|
if (count == 0) { |
|
|
|
logger.info("新增停车会员>>>>>>>>>>>>>>>>>>>>>>>>>>"); |
|
|
|
carNewMemberData(createtime, date, tenantId); |
|
|
|
carNewMemberData(createtime, date, tenantEntity); |
|
|
|
} |
|
|
|
wxChartDataEntity.setType(EnumChartType.CAR_BIND.getCode()); |
|
|
|
count = wxChartDataMapper.selectCount(new QueryWrapper(wxChartDataEntity)); |
|
|
|
if (count == 0) { |
|
|
|
logger.info("已绑车辆>>>>>>>>>>>>>>>>>>>>>>>>>>"); |
|
|
|
carBindData(params, createtime, date, tenantId); |
|
|
|
carBindData(params, createtime, date, tenantEntity); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
@@ -136,19 +137,19 @@ public class ChartDataSchedule { |
|
|
|
|
|
|
|
List<WxMall> wxMalls = wxMallMapper.findList(null); |
|
|
|
for (WxMall wxMall : wxMalls) { |
|
|
|
String tenantId = wxMall.getTenantId(); |
|
|
|
params.put("tenantId", tenantId); |
|
|
|
wxChartDataEntity.setTenantId(tenantId); |
|
|
|
TenantEntity tenantEntity = wxMall.getTenantInfo(); |
|
|
|
params.put("tenantId", tenantEntity.getTenantId()); |
|
|
|
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.setTenantId(tenantId); |
|
|
|
wxCouponOrder.updateTenantInfo(tenantEntity); |
|
|
|
wxCouponOrder.setStartTime(startdate); |
|
|
|
wxCouponOrder.setEndTime(enddate); |
|
|
|
Integer price = wxCouponOrderMapper.queryPriceTotal(wxCouponOrder); |
|
|
|
addChartData(tenantId, price.toString(), EnumChartType.SALE_COUPON_PRICE.getCode(), startdate, createtime); |
|
|
|
addChartData(tenantEntity, price.toString(), EnumChartType.SALE_COUPON_PRICE.getCode(), startdate, createtime); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
@@ -167,72 +168,72 @@ public class ChartDataSchedule { |
|
|
|
|
|
|
|
List<WxMall> wxMalls = wxMallMapper.findList(null); |
|
|
|
for (WxMall wxMall : wxMalls) { |
|
|
|
String tenantId = wxMall.getTenantId(); |
|
|
|
params.put("tenantId", tenantId); |
|
|
|
TenantEntity tenantEntity = wxMall.getTenantInfo(); |
|
|
|
params.put("tenantId", tenantEntity.getTenantId()); |
|
|
|
|
|
|
|
wxChartDataEntity.setTenantId(tenantId); |
|
|
|
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.setTenantId(tenantId); |
|
|
|
wxMerchantTradeDaily.updateTenantInfo(tenantEntity); |
|
|
|
wxMerchantTradeDaily.setReportDate(yesterday); |
|
|
|
List<WxMerchantTradeDaily> recordList = wxMerchantTradeDailyMapper.findTotalListOfMonth(wxMerchantTradeDaily); |
|
|
|
Integer price = 0; |
|
|
|
if (!recordList.isEmpty()) { |
|
|
|
price = Integer.parseInt(recordList.get(0).getTradeAmt()); |
|
|
|
} |
|
|
|
addChartData(tenantId, price.toString(), EnumChartType.MERCHANT_TRADE.getCode(), querytime, createtime); |
|
|
|
addChartData(tenantEntity, price.toString(), EnumChartType.MERCHANT_TRADE.getCode(), querytime, createtime); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public void carBindData(HashMap<String, Object> params, Date createtime, Date date, String tenantId) { |
|
|
|
public void carBindData(HashMap<String, Object> params, Date createtime, Date date, TenantEntity tenantEntity) { |
|
|
|
Long todaybindcar = wxCUserCarMapper.queryCarCount(params); |
|
|
|
addChartData(tenantId, todaybindcar.toString(), EnumChartType.CAR_BIND.getCode(), date, createtime); |
|
|
|
addChartData(tenantEntity, todaybindcar.toString(), EnumChartType.CAR_BIND.getCode(), date, createtime); |
|
|
|
} |
|
|
|
|
|
|
|
public void carNewMemberData(Date createtime, Date date, String tenantId) { |
|
|
|
public void carNewMemberData(Date createtime, Date date, TenantEntity tenantEntity) { |
|
|
|
WxCUserBasicInfoDto wxCUserBasicInfoDto = new WxCUserBasicInfoDto(); |
|
|
|
wxCUserBasicInfoDto.setTenantId(tenantId); |
|
|
|
wxCUserBasicInfoDto.updateTenantInfo(tenantEntity); |
|
|
|
wxCUserBasicInfoDto.setStartTime(date); |
|
|
|
wxCUserBasicInfoDto.setEndTime(date); |
|
|
|
Integer carUserCount = wxCUserCarMapper.countUser(wxCUserBasicInfoDto); |
|
|
|
addChartData(tenantId, carUserCount.toString(), EnumChartType.CAR_NEW_MEMBER.getCode(), date, createtime); |
|
|
|
addChartData(tenantEntity, carUserCount.toString(), EnumChartType.CAR_NEW_MEMBER.getCode(), date, createtime); |
|
|
|
} |
|
|
|
|
|
|
|
public void carMemberData(HashMap<String, Object> params, Date createtime, Date date, String tenantId) { |
|
|
|
public void carMemberData(HashMap<String, Object> params, Date createtime, Date date, TenantEntity tenantEntity) { |
|
|
|
List<Map<String, Object>> carCountHistory = wxCUserCarMapper.queryCarCountHistory(params); |
|
|
|
Long userCount = carCountHistory.isEmpty() ? 0L : (Long) carCountHistory.get(0).get("count"); |
|
|
|
addChartData(tenantId, userCount.toString(), EnumChartType.CAR_MEMBER.getCode(), date, createtime); |
|
|
|
addChartData(tenantEntity, userCount.toString(), EnumChartType.CAR_MEMBER.getCode(), date, createtime); |
|
|
|
} |
|
|
|
|
|
|
|
public void carPayFeeData(HashMap<String, Object> params, Date createtime, Date date, String tenantId) { |
|
|
|
public void carPayFeeData(HashMap<String, Object> params, Date createtime, Date date, TenantEntity tenantEntity) { |
|
|
|
List<Map<String, Object>> weekCarPayHistoryList = wxCarCmdLogMapper.queryWeekCarPay(params); |
|
|
|
BigDecimal fee = weekCarPayHistoryList.isEmpty() ? new BigDecimal(0) : (BigDecimal) weekCarPayHistoryList.get(0).get("fee"); |
|
|
|
addChartData(tenantId, fee.toString(), EnumChartType.CAR_PAY_FEE.getCode(), date, createtime); |
|
|
|
addChartData(tenantEntity, fee.toString(), EnumChartType.CAR_PAY_FEE.getCode(), date, createtime); |
|
|
|
} |
|
|
|
|
|
|
|
public void carPaidData(HashMap<String, Object> params, Date createtime, Date date, String tenantId) { |
|
|
|
public void carPaidData(HashMap<String, Object> params, Date createtime, Date date, TenantEntity tenantEntity) { |
|
|
|
Long carPayFeeCount = wxCarCmdLogMapper.queryWeekCarPayCount(params); |
|
|
|
addChartData(tenantId, carPayFeeCount.toString(), EnumChartType.CAR_PAID.getCode(), date, createtime); |
|
|
|
addChartData(tenantEntity, carPayFeeCount.toString(), EnumChartType.CAR_PAID.getCode(), date, createtime); |
|
|
|
} |
|
|
|
|
|
|
|
public void carOutData(HashMap<String, Object> params, Date createtime, Date date, String tenantId) { |
|
|
|
public void carOutData(HashMap<String, Object> params, Date createtime, Date date, TenantEntity tenantEntity) { |
|
|
|
List<Map<String, Object>> historylist = wxCarCmdLogMapper.queryHistory(params); |
|
|
|
Long carOutCount = historylist.isEmpty() ? 0L : (Long) historylist.get(0).get("carcount"); |
|
|
|
addChartData(tenantId, carOutCount.toString(), EnumChartType.CAR_OUT.getCode(), date, createtime); |
|
|
|
addChartData(tenantEntity, carOutCount.toString(), EnumChartType.CAR_OUT.getCode(), date, createtime); |
|
|
|
} |
|
|
|
|
|
|
|
private void addChartData(String tenantId, String result, Integer type, Date querytime, 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.setTenantId(tenantId); |
|
|
|
wxChartDataEntity.updateTenantInfo(tenantEntity); |
|
|
|
wxChartDataEntity.setResult(result); |
|
|
|
wxChartDataEntity.setType(type); |
|
|
|
wxChartDataEntity.setQuerytime(querytime); |
|
|
|
|