CustomerInfo_customerInfo=CustomerInfo.dao.findFirst("select * from customer_info where name = ? and data_status != ? limit 1",customerInfo.getName(),DataStatusEnum.delete.getValue());
CustomerInfo_customerInfo=CustomerInfo.dao.findFirst("select * from customer_info where name = ? and data_status != ? limit 1",customerInfo.getName(),DataStatusEnum.delete.getValue());
returnCustomerPriceLevel.dao.paginate(pageNumber,pageSize,"select * ","from customer_price_level "+where.toString()+" order by id desc",params.toArray());
}
/**
* 新增
*/
publicRetcreate(CustomerPriceLevelpriceLevel){
if(priceLevel==null){
returnRet.fail("参数错误");
}
if(StringUtils.isEmpty(priceLevel.getName())){
returnRet.fail("价格等级名称不能为空");
}
CustomerPriceLevel_priceLevel=CustomerPriceLevel.dao.findFirst("select * from customer_price_level where name = ? and data_status != ? limit 1",priceLevel.getName(),DataStatusEnum.delete.getValue());
CustomerPriceLevel_priceLevel=CustomerPriceLevel.dao.findFirst("select * from customer_price_level where name = ? and data_status != ? limit 1",priceLevel.getName(),DataStatusEnum.delete.getValue());
categoryFilter.setValue("select id from goods_info "+whereCategory.toString());
condKv.set("goods_info_id",categoryFilter);
}
conditionFilter(condKv,where,params);
Page<SaleOrderGoods>page=SaleOrderGoods.dao.paginate(pageNumber,pageSize,"select goods_info_id, sum(buy_number) as buy_number, sum(amount) as amount, sum(cost_amount) as cost_amount, sum(reject_number) as reject_number, sum(reject_amount) as reject_amount","from sale_order_goods "+where.toString()+" group by goods_info_id order by buy_number desc",params.toArray());
for(SaleOrderGoodssaleOrderGoods:page.getList()){
StringBufferrejectWhere=newStringBuffer();
List<Object>rejectParams=newArrayList<>();
rejectWhere.append("where 1 = 1 ");
rejectWhere.append(" and sale_reject_order_id in (select id from sale_reject_order where "+whereOrder.toString()+")");
if(goodsCategoryId!=null&&goodsCategoryId>0){
rejectWhere.append(" and goods_info_id in (select id from goods_info where goods_category_id = ? )");
SaleRejectOrderGoodssaleRejectOrderGoods=SaleRejectOrderGoods.dao.findFirst("select sum(buy_number) as buy_number, sum(amount) as amount from sale_reject_order_goods "+rejectWhere.toString()+" limit 1",rejectParams.toArray());
categoryFilter.setValue("select id from goods_info "+whereCategory.toString());
condKv.set("goods_info_id",categoryFilter);
conditionFilter(condKv,where,params);
SaleOrderGoodssaleOrderGoods=SaleOrderGoods.dao.findFirst("select sum(buy_number) as buy_number, sum(amount) as amount, sum(cost_amount) as cost_amount from sale_order_goods "+where.toString(),params.toArray());
StringBufferrejectWhere=newStringBuffer();
List<Object>rejectParams=newArrayList<>();
rejectWhere.append("where 1 = 1 ");
rejectWhere.append(" and sale_reject_order_id in (select id from sale_reject_order where "+whereOrder.toString()+")");
if(goodsCategoryId!=null&&goodsCategoryId>0){
rejectWhere.append(" and goods_info_id in (select id from goods_info where goods_category_id = ? )");
rejectParams.add(goodsCategoryId);
}
SaleRejectOrderGoodssaleRejectOrderGoods=SaleRejectOrderGoods.dao.findFirst("select sum(buy_number) as buy_number, sum(amount) as amount from sale_reject_order_goods "+rejectWhere.toString()+" limit 1",rejectParams.toArray());
returnSaleOrderGoods.dao.paginate(pageNumber,pageSize,"select goods_info_id,spec_1_id,spec_option_1_id,spec_2_id,spec_option_2_id,spec_3_id,spec_option_3_id,unit_id, sum(buy_number) as sum_buy_number ","from sale_order_goods "+where.toString()+" group by goods_info_id,spec_1_id,spec_option_1_id,spec_2_id,spec_option_2_id,spec_3_id,spec_option_3_id,unit_id order by id desc",params.toArray());
whereOrder.append(" order_time >= '"+startTime+"' and ");
}
if(StringUtils.isNotEmpty(endTime)){
whereOrder.append(" order_time <= '"+endTime+"' and ");
}
whereOrder.append("order_status = "+OrderStatusEnum.normal.getValue()+" and audit_status = "+AuditStatusEnum.pass.getValue());
where.append(" and sale_order_id in (select id from sale_order where "+whereOrder.toString()+")");
if(goodsInfoId!=null&&goodsInfoId>0){
where.append(" and goods_info_id = ?");
params.add(goodsInfoId);
}
Page<SaleOrderGoods>page=SaleOrderGoods.dao.paginate(pageNumber,pageSize,"select customer_info_id, sum(buy_number) as buy_number, sum(amount) as amount, sum(cost_amount) as cost_amount ","from sale_order_goods "+where.toString()+" group by customer_info_id order by buy_number desc",params.toArray());
for(SaleOrderGoodssaleOrderGoods:page.getList()){
StringBufferrejectWhere=newStringBuffer();
List<Object>rejectParams=newArrayList<>();
rejectWhere.append("where 1 = 1 ");
rejectWhere.append(" and sale_reject_order_id in (select id from sale_reject_order where "+whereOrder.toString()+")");
SaleRejectOrderGoodssaleRejectOrderGoods=SaleRejectOrderGoods.dao.findFirst("select sum(buy_number) as buy_number, sum(amount) as amount from sale_reject_order_goods "+rejectWhere.toString()+" limit 1",rejectParams.toArray());
whereOrder.append(" order_time >= '"+startTime+"' and ");
}
if(StringUtils.isNotEmpty(endTime)){
whereOrder.append(" order_time <= '"+endTime+"' and ");
}
whereOrder.append("order_status = "+OrderStatusEnum.normal.getValue()+" and audit_status = "+AuditStatusEnum.pass.getValue());
ConditionFilterfilter=newConditionFilter();
filter.setOperator(Operator.in);
filter.setValue("select id from sale_order where "+whereOrder.toString());
KvcondKv=Kv.create();
condKv.set("sale_order_id",filter);
condKv.set("goods_info_id",goodsInfoId);
conditionFilter(condKv,where,params);
SaleOrderGoodssaleOrderGoods=SaleOrderGoods.dao.findFirst("select sum(buy_number) as buy_number, sum(amount) as amount, sum(cost_amount) as cost_amount, sum(reject_number) as reject_number, sum(reject_amount) as reject_amount from sale_order_goods "+where.toString(),params.toArray());
StringBufferrejectWhere=newStringBuffer();
List<Object>rejectParams=newArrayList<>();
rejectWhere.append("where 1 = 1 ");
rejectWhere.append(" and sale_reject_order_id in (select id from sale_reject_order where "+whereOrder.toString()+")");
rejectWhere.append(" and goods_info_id = ?");
rejectParams.add(goodsInfoId);
SaleRejectOrderGoodssaleRejectOrderGoods=SaleRejectOrderGoods.dao.findFirst("select sum(buy_number) as buy_number, sum(amount) as amount from sale_reject_order_goods "+rejectWhere.toString()+" limit 1",rejectParams.toArray());
where.append(" and customer_info_id in (select id from customer_info where customer_category_id = ? and data_status = ?)");
params.add(customerCategoryId);
params.add(DataStatusEnum.enable.getValue());
}
Page<SaleOrder>page=SaleOrder.dao.paginate(pageNumber,pageSize,"select customer_info_id, sum(amount) as amount, sum(goods_cost_amount) as cost_amount, count(id) as order_count, sum(other_amount) as other_amount","from sale_order "+where.toString()+" group by customer_info_id order by amount desc",params.toArray());
SaleRejectOrdersaleRejectOrder=SaleRejectOrder.dao.findFirst("select sum(amount) as amount, count(id) as order_count from sale_reject_order "+_rejectWhere+" limit 1",_rejectParams.toArray());
where.append(" and customer_info_id in (select id from customer_info where customer_category_id = ? and data_status = ?)");
params.add(customerCategoryId);
params.add(DataStatusEnum.enable.getValue());
}
SaleOrdersaleOrder=SaleOrder.dao.findFirst("select sum(amount) as amount, sum(paid_amount) as paid_amount, sum(goods_cost_amount) as cost_amount, count(id) as order_count, sum(other_amount) as other_amount from sale_order "+where.toString()+" limit 1",params.toArray());
SaleRejectOrdersaleRejectOrder=SaleRejectOrder.dao.findFirst("select sum(amount) as amount, sum(paid_amount) as paid_amount, count(id) as order_count from sale_reject_order "+where.toString()+" limit 1",params.toArray());
whereOrder.append(" order_time >= '"+startTime+"' and ");
}
if(StringUtils.isNotEmpty(endTime)){
whereOrder.append(" order_time <= '"+endTime+"' and ");
}
whereOrder.append("customer_info_id = "+customerInfoId+" and order_status = "+OrderStatusEnum.normal.getValue()+" and audit_status = "+AuditStatusEnum.pass.getValue());
ConditionFilterfilter=newConditionFilter();
filter.setOperator(Operator.in);
filter.setValue("select id from sale_order where "+whereOrder.toString());
KvcondKv=Kv.create();
condKv.set("sale_order_id",filter);
conditionFilter(condKv,where,params);
returnSaleOrderGoods.dao.paginate(pageNumber,pageSize,"select goods_info_id, sum(buy_number) as buy_number, sum(amount) as amount, sum(cost_amount) as cost_amount, sum(reject_number) as reject_number, sum(reject_amount) as reject_amount","from sale_order_goods "+where.toString()+" group by goods_info_id order by buy_number desc",params.toArray());
Page<SaleOrder>page=SaleOrder.dao.paginate(pageNumber,pageSize,"select tenant_store_id, sum(amount) as amount, sum(goods_cost_amount) as cost_amount, count(id) as order_count, sum(other_amount) as other_amount","from sale_order "+where.toString()+" group by tenant_store_id order by amount desc",params.toArray());
SaleRejectOrdersaleRejectOrder=SaleRejectOrder.dao.findFirst("select sum(amount) as amount, count(id) as order_count from sale_reject_order "+_rejectWhere+" limit 1",_rejectParams.toArray());
SaleOrdersaleOrder=SaleOrder.dao.findFirst("select sum(amount) as amount, sum(goods_cost_amount) as cost_amount, count(id) as order_count, sum(other_amount) as other_amount from sale_order "+where.toString()+" limit 1",params.toArray());
SaleRejectOrdersaleRejectOrder=SaleRejectOrder.dao.findFirst("select sum(amount) as amount, count(id) as order_count from sale_reject_order "+where.toString()+" limit 1",params.toArray());
whereOrder.append(" order_time >= '"+startTime+"' and ");
}
if(StringUtils.isNotEmpty(endTime)){
whereOrder.append(" order_time <= '"+endTime+"' and ");
}
whereOrder.append(" order_status = "+OrderStatusEnum.normal.getValue()+" and audit_status = "+AuditStatusEnum.pass.getValue());
ConditionFilterfilter=newConditionFilter();
filter.setOperator(Operator.in);
filter.setValue("select id from sale_order where "+whereOrder.toString());
KvcondKv=Kv.create();
condKv.set("sale_order_id",filter);
conditionFilter(condKv,where,params);
returnSaleOrderGoods.dao.paginate(pageNumber,pageSize,"select goods_info_id, sum(buy_number) as buy_number, sum(amount) as amount, sum(cost_amount) as cost_amount, sum(reject_number) as reject_number, sum(reject_amount) as reject_amount","from sale_order_goods "+where.toString()+" group by goods_info_id order by buy_number desc",params.toArray());
