Merge branch 'master' into ls-dev
# Conflicts: # ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/order/ordercluster/OrderclusterService.javadev
xiaocui
commit
e024cdcb0a
|
|
@ -21,7 +21,7 @@ public class Const {
|
||||||
public static final long SUP_OFFLINE_TIME = 5 * 60 * 1000L; // 砂站离线时间限制，单位 毫秒
|
public static final long SUP_OFFLINE_TIME = 5 * 60 * 1000L; // 砂站离线时间限制，单位 毫秒
|
||||||
|
|
||||||
public static final String TEMP_CODE_AGGR_STAT = "SMS_205434464"; // 累计销售汇总
|
public static final String TEMP_CODE_AGGR_STAT = "SMS_205434464"; // 累计销售汇总
|
||||||
public static final String TEMP_CODE_AGGR_STAT_2 = "SMS_212486582"; // 累计销售汇总-实际营收
|
public static final String TEMP_CODE_AGGR_STAT_2 = "SMS_213772873"; // 累计销售汇总-实际营收
|
||||||
public static final String TEMP_CODE_DAY_STAT = "SMS_205430436"; // 日销售汇总
|
public static final String TEMP_CODE_DAY_STAT = "SMS_205430436"; // 日销售汇总
|
||||||
public static final String TEMP_CODE_CUSTOMER_DAY_STAT = "SMS_208985081"; // 客户日销售汇总
|
public static final String TEMP_CODE_CUSTOMER_DAY_STAT = "SMS_208985081"; // 客户日销售汇总
|
||||||
public static final String TEMP_CODE_PEIE = "SMS_203673037"; // 配额分配通知
|
public static final String TEMP_CODE_PEIE = "SMS_203673037"; // 配额分配通知
|
||||||
|
|
@ -39,7 +39,7 @@ public class Const {
|
||||||
SMS_TEMP_MAP.put(TEMP_CODE_DEPOSIT_SUCCESS, "${time}${customer_name}在${vendor}的预存${amount}元，合计余额${surplus}元。");
|
SMS_TEMP_MAP.put(TEMP_CODE_DEPOSIT_SUCCESS, "${time}${customer_name}在${vendor}的预存${amount}元，合计余额${surplus}元。");
|
||||||
SMS_TEMP_MAP.put(TEMP_CODE_DEPOSIT_FAIL, "${time}${customer_name}在${vendor}预存的${amount}元审核未通过，若有疑问请及时联系结算中心。");
|
SMS_TEMP_MAP.put(TEMP_CODE_DEPOSIT_FAIL, "${time}${customer_name}在${vendor}预存的${amount}元审核未通过，若有疑问请及时联系结算中心。");
|
||||||
SMS_TEMP_MAP.put(TEMP_CODE_AGGR_STAT, "截至${time1}累计销售黄砂${aggr_weight}吨，共计${aggr_price}元，运输${aggr_cnt}辆次。账户累计${aggr_total_price}元，其中预付费客户总余额${customer_total_surplus}元。${time2}当日销售黄砂${total_weight}吨，共计${total_price}元，运输${total_cnt}辆次。");
|
SMS_TEMP_MAP.put(TEMP_CODE_AGGR_STAT, "截至${time1}累计销售黄砂${aggr_weight}吨，共计${aggr_price}元，运输${aggr_cnt}辆次。账户累计${aggr_total_price}元，其中预付费客户总余额${customer_total_surplus}元。${time2}当日销售黄砂${total_weight}吨，共计${total_price}元，运输${total_cnt}辆次。");
|
||||||
SMS_TEMP_MAP.put(TEMP_CODE_AGGR_STAT_2, "截至${time1}累计销售黄砂${aggr_weight}吨，共计${aggr_price}元，运输${aggr_cnt}辆次；其中2020年充值客户销售${customer_weight}吨，共${customer_price}元，2021年新增客户销售${revenue_weight}吨，共${revenue}元。账户累计${aggr_total_price}元，其中预付费客户总余额${customer_total_surplus}元。${time2}当日销售黄砂${total_weight}吨，共计${total_price}元，运输${total_cnt}辆次。");
|
SMS_TEMP_MAP.put(TEMP_CODE_AGGR_STAT_2, "截至${time1}累计销售黄砂${aggr_weight}吨，共计${aggr_price}元，运输${aggr_cnt}辆次；其中2020年充值客户销售${customer_weight}吨，共${customer_price}元，2021年新增客户销售${revenue_weight}吨，共${revenue}元。${time2}当日销售黄砂${total_weight}吨，共计${total_price}元，运输${total_cnt}辆次。");
|
||||||
SMS_TEMP_MAP.put(TEMP_CODE_SURPLUS_WARN, "截至${time}${customer_name}在${vendor}的预存账户余额为${surplus}元。请及时关注。");
|
SMS_TEMP_MAP.put(TEMP_CODE_SURPLUS_WARN, "截至${time}${customer_name}在${vendor}的预存账户余额为${surplus}元。请及时关注。");
|
||||||
SMS_TEMP_MAP.put(TEMP_CODE_REFUND_SUCCESS, "${time}${customer_name}在${vendor}的退款${amount}元，合计余额${surplus}元。");
|
SMS_TEMP_MAP.put(TEMP_CODE_REFUND_SUCCESS, "${time}${customer_name}在${vendor}的退款${amount}元，合计余额${surplus}元。");
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -767,4 +767,13 @@ public class OrderclusterService extends BaseService {
|
||||||
|
|
||||||
return out == null ? new BigDecimal("0") : out;
|
return out == null ? new BigDecimal("0") : out;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取用户未完成订单id
|
||||||
|
*/
|
||||||
|
public List<Record> getUncompletedOrdersFromUsers(Integer customer_id){
|
||||||
|
String sql = "select t.id from ordercluster t join supermarket s on s.id = t.supermarket_id \n " +
|
||||||
|
" where t.customer_id is not null and state<5 and customer_id=?";
|
||||||
|
return Db.find(sql,customer_id);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -4,8 +4,10 @@ import com.cowr.common.Const;
|
||||||
import com.cowr.common.base.BaseService;
|
import com.cowr.common.base.BaseService;
|
||||||
import com.cowr.common.view.PageParam;
|
import com.cowr.common.view.PageParam;
|
||||||
import com.cowr.model.Customer;
|
import com.cowr.model.Customer;
|
||||||
|
import com.cowr.model.PrepayCustomer;
|
||||||
import com.cowr.model.PrepayDetail;
|
import com.cowr.model.PrepayDetail;
|
||||||
import com.cowr.model.RefundDetail;
|
import com.cowr.model.RefundDetail;
|
||||||
|
import com.cowr.ssjygl.prepay.prepaycustomer.PrepayCustomerService;
|
||||||
import com.jfinal.kit.StrKit;
|
import com.jfinal.kit.StrKit;
|
||||||
import com.jfinal.log.Log;
|
import com.jfinal.log.Log;
|
||||||
import com.jfinal.plugin.activerecord.Db;
|
import com.jfinal.plugin.activerecord.Db;
|
||||||
|
|
@ -92,7 +94,7 @@ public class RefundDetailService extends BaseService {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取账户可用余额
|
* 根据账户ID和账户金额，获取账户可用余额
|
||||||
* @param customer_id 客户ID
|
* @param customer_id 客户ID
|
||||||
* @param surplus 账户余额
|
* @param surplus 账户余额
|
||||||
* @return
|
* @return
|
||||||
|
|
@ -106,5 +108,16 @@ public class RefundDetailService extends BaseService {
|
||||||
return surplus.subtract(amount);
|
return surplus.subtract(amount);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取账户的可用余额
|
||||||
|
* @param customer_id 客户ID
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
public BigDecimal getCustomerAccountBalance(Integer customer_id){
|
||||||
|
PrepayCustomer prepayCustomer = PrepayCustomerService.me.getPrepayCustomer(customer_id);
|
||||||
|
if(prepayCustomer==null){
|
||||||
|
return new BigDecimal("-1");
|
||||||
|
}
|
||||||
|
return getAvailableBalance(customer_id,prepayCustomer.getSurplus());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -11,6 +11,7 @@ import com.jfinal.kit.StrKit;
|
||||||
import com.jfinal.log.Log;
|
import com.jfinal.log.Log;
|
||||||
import com.jfinal.plugin.activerecord.Db;
|
import com.jfinal.plugin.activerecord.Db;
|
||||||
import com.jfinal.plugin.activerecord.Record;
|
import com.jfinal.plugin.activerecord.Record;
|
||||||
|
import org.apache.poi.hssf.usermodel.HSSFCellStyle;
|
||||||
import org.apache.poi.ss.usermodel.*;
|
import org.apache.poi.ss.usermodel.*;
|
||||||
import org.apache.poi.ss.util.CellRangeAddress;
|
import org.apache.poi.ss.util.CellRangeAddress;
|
||||||
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
|
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
|
||||||
|
|
@ -1837,4 +1838,401 @@ public class OrderStatService {
|
||||||
|
|
||||||
return wb;
|
return wb;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public Workbook trafficStatisticsOfEachSandStationExport(String stm, String etm){
|
||||||
|
List<Record> list=trafficStatisticsOfEachSandStation(stm, etm);
|
||||||
|
Workbook wb = new XSSFWorkbook();
|
||||||
|
|
||||||
|
Sheet sheet = wb.createSheet(stm + " ~ " + etm + "各砂站运输量统计表");
|
||||||
|
|
||||||
|
sheet.setColumnWidth(1,40*256);
|
||||||
|
for(int i=2;i<28;i++){
|
||||||
|
sheet.setColumnWidth(i,15*256);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 表头 start
|
||||||
|
Row row = sheet.createRow(0);
|
||||||
|
sheet.addMergedRegion(new CellRangeAddress(0,1,0,0));
|
||||||
|
sheet.addMergedRegion(new CellRangeAddress(0,1,1,1));
|
||||||
|
sheet.addMergedRegion(new CellRangeAddress(0,1,2,2));
|
||||||
|
sheet.addMergedRegion(new CellRangeAddress(0,1,3,3));
|
||||||
|
int num = 4;
|
||||||
|
for(int i=0;i<12;i++){
|
||||||
|
sheet.addMergedRegion(new CellRangeAddress(0,0,num,num+1));
|
||||||
|
num=num+2;
|
||||||
|
}
|
||||||
|
// 通用单元格格式
|
||||||
|
Font font = wb.createFont();
|
||||||
|
CellStyle cellStyle = wb.createCellStyle();
|
||||||
|
// font.setFontHeight((short) (10 * 20));
|
||||||
|
// font.setFontName("宋体");
|
||||||
|
cellStyle.setBorderBottom(BorderStyle.THIN);
|
||||||
|
cellStyle.setBorderLeft(BorderStyle.THIN);
|
||||||
|
cellStyle.setBorderTop(BorderStyle.THIN);
|
||||||
|
cellStyle.setBorderRight(BorderStyle.THIN);
|
||||||
|
cellStyle.setAlignment(HorizontalAlignment.CENTER);//水平居中
|
||||||
|
cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);//垂直居中
|
||||||
|
cellStyle.setFont(font);
|
||||||
|
|
||||||
|
num = 0;
|
||||||
|
row.createCell(0).setCellValue("序号");
|
||||||
|
row.createCell(1).setCellValue("客户名称");
|
||||||
|
row.createCell(2).setCellValue("总销售量（吨）");
|
||||||
|
row.createCell(3).setCellValue("总销售额（元）");
|
||||||
|
row.createCell(4).setCellValue("竹瓦");
|
||||||
|
row.createCell(6).setCellValue("竹瓦水厂");
|
||||||
|
row.createCell(8).setCellValue("竹瓦合计");
|
||||||
|
row.createCell(10).setCellValue("团陂");
|
||||||
|
row.createCell(12).setCellValue("城隍");
|
||||||
|
row.createCell(14).setCellValue("石畈");
|
||||||
|
row.createCell(16).setCellValue("融嘉");
|
||||||
|
row.createCell(17).setCellValue("水利站");
|
||||||
|
row.createCell(20).setCellValue("融嘉合计");
|
||||||
|
row.createCell(22).setCellValue("盐港");
|
||||||
|
row.createCell(24).setCellValue("永安");
|
||||||
|
row.createCell(26).setCellValue("盐港合计");
|
||||||
|
|
||||||
|
row = sheet.createRow(1);
|
||||||
|
num = 4;
|
||||||
|
for(int i=0;i<12;i++){
|
||||||
|
row.createCell(num++).setCellValue("总销售量（吨）");
|
||||||
|
row.createCell(num++).setCellValue("总销售额（元）");
|
||||||
|
}
|
||||||
|
int datalen = list.size();
|
||||||
|
for (int i = 0; i < datalen; i++) {
|
||||||
|
Record sales = list.get(i);
|
||||||
|
row = sheet.createRow(i + 2);
|
||||||
|
num = 0;
|
||||||
|
row.createCell(num++).setCellValue(i+1);
|
||||||
|
row.createCell(num++).setCellValue(sales.getStr("customer_name"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "weight"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "total_price"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "zw_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "zw_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "zwsc_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "zwsc_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "zwhj_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "zwhj_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "tp_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "tp_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "sc_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "sc_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "sb_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "sb_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "jr_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "jr_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "sl_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "sl_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "jrhj_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "jrhj_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "yg_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "yg_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "ya_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "ya_xse"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "yghj_xsl"));
|
||||||
|
row.createCell(num++).setCellValue(DataUtil.getDefaultByRecord(sales, "yghj_xse"));
|
||||||
|
}
|
||||||
|
|
||||||
|
for (int r = 0; r < datalen + 2; r++) {
|
||||||
|
row = sheet.getRow(r);
|
||||||
|
if (row == null) {
|
||||||
|
row = sheet.createRow(r);
|
||||||
|
}
|
||||||
|
for (int c = 0; c < 28; c++) {
|
||||||
|
Cell cell = row.getCell(c);
|
||||||
|
|
||||||
|
if (cell == null) {
|
||||||
|
cell = row.createCell(c);
|
||||||
|
}
|
||||||
|
cell.setCellStyle(cellStyle);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return wb;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 各砂站运输量统计表
|
||||||
|
*/
|
||||||
|
public List<Record> trafficStatisticsOfEachSandStation( String stm, String etm){
|
||||||
|
List<Record> dataList = new ArrayList<>();
|
||||||
|
//零散用户统计
|
||||||
|
Record scattered=scatteredUsersAreNotClassified(stm,etm);
|
||||||
|
if(scattered.getBigDecimal("weight").compareTo(new BigDecimal("0"))>0||scattered.getBigDecimal("total_price").compareTo(new BigDecimal("0"))>0){
|
||||||
|
Record scatteredSandStation=scatteredUsersClassificationStatistics(stm,etm);
|
||||||
|
scattered.setColumns(scatteredSandStation);
|
||||||
|
dataList.add(scattered);
|
||||||
|
}
|
||||||
|
//固定用户统计
|
||||||
|
List<Record> recordList = fixedUserUnclassified(stm,etm);
|
||||||
|
if(recordList!=null&&!recordList.isEmpty()){
|
||||||
|
for (Record record : recordList) {
|
||||||
|
if(record.getBigDecimal("weight").compareTo(new BigDecimal("0"))>0||record.getBigDecimal("total_price").compareTo(new BigDecimal("0"))>0){
|
||||||
|
Integer customer_id=record.getInt("customer_id");
|
||||||
|
Record sandStation=fixedUserClassificationStatistics(stm, etm,customer_id);
|
||||||
|
record.setColumns(sandStation);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
dataList.addAll(recordList);
|
||||||
|
return dataList;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* 零散用户
|
||||||
|
*/
|
||||||
|
/**
|
||||||
|
* 固定用户不分类统计：统计各个固定用户在所有砂站的销量和销售额
|
||||||
|
*/
|
||||||
|
public List<Record> fixedUserUnclassified(String stm, String etm){
|
||||||
|
String sql="SELECT\n" +
|
||||||
|
"a.customer_name,\n" +
|
||||||
|
" a.customer_id,\n" +
|
||||||
|
"ifnull(sum( a.weight ),0) weight,\n" +
|
||||||
|
"ifnull(sum( a.total_price ),0) total_price\n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"(\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"t.customer_id,\n" +
|
||||||
|
"t.customer_name,\n" +
|
||||||
|
"t.weight,\n" +
|
||||||
|
"t.total_price,\n" +
|
||||||
|
"t.product_id,\n" +
|
||||||
|
"t.product_name \n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"order_sale t \n" +
|
||||||
|
"WHERE\n" +
|
||||||
|
"t.state = 5 \n" +
|
||||||
|
"AND t.create_time >=? \n" +
|
||||||
|
"AND t.create_time <=? \n" +
|
||||||
|
"AND t.isprepaid = 1 UNION\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"t.customer_id,\n" +
|
||||||
|
"t.customer_name,\n" +
|
||||||
|
"t.weight,\n" +
|
||||||
|
"t.total_price,\n" +
|
||||||
|
"t.product_id,\n" +
|
||||||
|
"t.product_name \n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"order_temp t \n" +
|
||||||
|
"WHERE\n" +
|
||||||
|
"t.state = 5 \n" +
|
||||||
|
"AND t.create_time >=? \n" +
|
||||||
|
"AND t.create_time <=? \n" +
|
||||||
|
"AND t.isprepaid = 1 \n" +
|
||||||
|
") a\n" +
|
||||||
|
" JOIN customer c ON c.id = a.customer_id \n" +
|
||||||
|
"GROUP BY\n" +
|
||||||
|
"a.customer_id,a.customer_name";
|
||||||
|
List<Record> recordList = Db.find(sql, stm, etm, stm, etm);
|
||||||
|
return recordList;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 固定用户分类统计：统计各个固定用户在不同砂站的销量以及销售额
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
public Record fixedUserClassificationStatistics(String stm, String etm,Integer customer_id){
|
||||||
|
String sql="SELECT\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 1 THEN g.weight END ), 0.00 ) zw_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 1 THEN g.total_price END ), 0.00 ) zw_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 2 THEN g.weight END ), 0.00 ) tp_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 2 THEN g.total_price END ), 0.00 ) tp_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 3 THEN g.weight END ), 0.00 ) sc_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 3 THEN g.total_price END ), 0.00 ) sc_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 4 THEN g.weight END ), 0.00 ) sb_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 4 THEN g.total_price END ), 0.00 ) sb_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 5 THEN g.weight END ), 0.00 ) jr_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 5 THEN g.total_price END ), 0.00 ) jr_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 6 THEN g.weight END ), 0.00 ) yg_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 6 THEN g.total_price END ), 0.00 ) yg_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 7 THEN g.weight END ), 0.00 ) zwsc_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 7 THEN g.total_price END ), 0.00 ) zwsc_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 8 THEN g.weight END ), 0.00 ) ya_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 8 THEN g.total_price END ), 0.00 ) ya_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 9 THEN g.weight END ), 0.00 ) sl_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 9 THEN g.total_price END ), 0.00 ) sl_xse \n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"(\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"m.id,\n" +
|
||||||
|
"n.customer_id,\n" +
|
||||||
|
"IFNULL( n.weight, 0.00 ) weight,\n" +
|
||||||
|
"IFNULL( n.total_price, 0.00 ) total_price \n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"( SELECT id, NAME FROM supermarket ) m\n" +
|
||||||
|
"JOIN (\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"a.id,\n" +
|
||||||
|
"sum( a.weight ) weight,\n" +
|
||||||
|
"sum( a.total_price ) total_price,\n" +
|
||||||
|
"a.customer_id \n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"(\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"t.supermarket_id AS id,\n" +
|
||||||
|
"t.customer_id,\n" +
|
||||||
|
"t.customer_name,\n" +
|
||||||
|
"t.weight,\n" +
|
||||||
|
"t.total_price,\n" +
|
||||||
|
"t.product_id,\n" +
|
||||||
|
"t.product_name \n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"order_sale t \n" +
|
||||||
|
"WHERE\n" +
|
||||||
|
"t.state = 5 \n" +
|
||||||
|
"AND t.create_time >=? \n" +
|
||||||
|
"AND t.create_time <=? \n" +
|
||||||
|
"AND t.isprepaid = 1 UNION\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"t.supermarket_id AS id,\n" +
|
||||||
|
"t.customer_id,\n" +
|
||||||
|
"t.customer_name,\n" +
|
||||||
|
"t.weight,\n" +
|
||||||
|
"t.total_price,\n" +
|
||||||
|
"t.product_id,\n" +
|
||||||
|
"t.product_name \n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"order_temp t \n" +
|
||||||
|
"WHERE\n" +
|
||||||
|
"t.state = 5 \n" +
|
||||||
|
"AND t.create_time >=? \n" +
|
||||||
|
"AND t.create_time <=? \n" +
|
||||||
|
"AND t.isprepaid = 1 \n" +
|
||||||
|
") a\n" +
|
||||||
|
"JOIN customer c ON c.id = a.customer_id \n" +
|
||||||
|
"WHERE\n" +
|
||||||
|
"a.customer_id = ? \n" +
|
||||||
|
"GROUP BY\n" +
|
||||||
|
"a.id \n" +
|
||||||
|
") n ON m.id = n.id \n" +
|
||||||
|
") g \n" +
|
||||||
|
"GROUP BY\n" +
|
||||||
|
"g.customer_id";
|
||||||
|
Record record = Db.findFirst(sql, stm,etm, stm,etm, customer_id);
|
||||||
|
return total(record);
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* 零散用户不分类统计：统计所有零散用户在所有砂站的销量和销售额
|
||||||
|
*/
|
||||||
|
public Record scatteredUsersAreNotClassified(String stm, String etm){
|
||||||
|
String sql="SELECT '零散用户' customer_name, 0 customer_id,\n" +
|
||||||
|
"ifnull(sum( a.weight ),0) weight,\n" +
|
||||||
|
"ifnull(sum( a.total_price ),0) total_price\n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"(\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"t.weight,\n" +
|
||||||
|
"t.total_price,\n" +
|
||||||
|
"t.product_id\n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"order_sale t \n" +
|
||||||
|
"WHERE\n" +
|
||||||
|
"t.state = 5 \n" +
|
||||||
|
"AND t.create_time >=?\n" +
|
||||||
|
"AND t.create_time <=?\n" +
|
||||||
|
"AND t.isprepaid = 0 UNION\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"t.weight,\n" +
|
||||||
|
"t.total_price,\n" +
|
||||||
|
"t.product_id\n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"order_temp t \n" +
|
||||||
|
"WHERE\n" +
|
||||||
|
"t.state = 5 \n" +
|
||||||
|
"AND t.create_time >=?\n" +
|
||||||
|
"AND t.create_time <=?\n" +
|
||||||
|
"AND t.isprepaid = 0 \n" +
|
||||||
|
") a";
|
||||||
|
Record record = Db.findFirst(sql, stm, etm, stm, etm);
|
||||||
|
return record;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 零散用户分类统计：统计所有零散用户在各个沙场的销量和销售额
|
||||||
|
* @param stm
|
||||||
|
* @param etm
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
public Record scatteredUsersClassificationStatistics(String stm, String etm){
|
||||||
|
String sql="select \n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 1 THEN IFNULL( g.weight, 0 ) END ), 0 ) zw_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 1 THEN IFNULL( g.total_price, 0 ) END ), 0 ) zw_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 2 THEN IFNULL( g.weight, 0 ) END ), 0 ) tp_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 2 THEN IFNULL( g.total_price, 0 ) END ), 0 ) tp_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 3 THEN IFNULL( g.weight, 0 ) END ), 0 ) sc_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 3 THEN IFNULL( g.total_price, 0 ) END ), 0 ) sc_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 4 THEN IFNULL( g.weight, 0 ) END ), 0 ) sb_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 4 THEN IFNULL( g.total_price, 0 ) END ), 0 ) sb_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 5 THEN IFNULL( g.weight, 0 ) END ), 0 ) jr_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 5 THEN IFNULL( g.total_price, 0 ) END ), 0 ) jr_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 6 THEN IFNULL( g.weight, 0 ) END ), 0 ) yg_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 6 THEN IFNULL( g.total_price, 0 ) END ), 0 ) yg_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 7 THEN IFNULL( g.weight, 0 ) END ), 0 ) zwsc_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 7 THEN IFNULL( g.total_price, 0 ) END ), 0 ) zwsc_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 8 THEN IFNULL( g.weight, 0 ) END ), 0 ) ya_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 8 THEN IFNULL( g.total_price, 0 ) END ), 0 ) ya_xse,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 9 THEN IFNULL( g.weight, 0 ) END ), 0 ) sl_xsl,\n" +
|
||||||
|
"ifnull( sum( CASE g.id WHEN 9 THEN IFNULL( g.total_price, 0 ) END ), 0 ) sl_xse \n" +
|
||||||
|
" from (\n" +
|
||||||
|
"select m.id,n.weight,n.total_price from \n" +
|
||||||
|
"( SELECT id, NAME FROM supermarket ) m join \n" +
|
||||||
|
"(\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"t.supermarket_id AS id,\n" +
|
||||||
|
"t.customer_id,\n" +
|
||||||
|
"t.customer_name,\n" +
|
||||||
|
"t.weight,\n" +
|
||||||
|
"t.total_price,\n" +
|
||||||
|
"t.product_id,\n" +
|
||||||
|
"t.product_name \n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"order_sale t \n" +
|
||||||
|
"WHERE\n" +
|
||||||
|
"t.state = 5 \n" +
|
||||||
|
"AND t.create_time >=?\n" +
|
||||||
|
"AND t.create_time <=?\n" +
|
||||||
|
"AND t.isprepaid = 0 UNION\n" +
|
||||||
|
"SELECT\n" +
|
||||||
|
"t.supermarket_id AS id,\n" +
|
||||||
|
"t.customer_id,\n" +
|
||||||
|
"t.customer_name,\n" +
|
||||||
|
"t.weight,\n" +
|
||||||
|
"t.total_price,\n" +
|
||||||
|
"t.product_id,\n" +
|
||||||
|
"t.product_name \n" +
|
||||||
|
"FROM\n" +
|
||||||
|
"order_temp t \n" +
|
||||||
|
"WHERE\n" +
|
||||||
|
"t.state = 5 \n" +
|
||||||
|
"AND t.create_time >=?\n" +
|
||||||
|
"AND t.create_time <=?\n" +
|
||||||
|
"AND t.isprepaid = 0 ) n on m.id=n.id\n" +
|
||||||
|
") g";
|
||||||
|
Record record = Db.findFirst(sql, stm,etm, stm,etm);
|
||||||
|
return total(record);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 合计
|
||||||
|
* @param record
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
public Record total(Record record){
|
||||||
|
//竹瓦合计
|
||||||
|
BigDecimal zwhj_xsl=new BigDecimal(record.getStr("zw_xsl")).add(new BigDecimal(record.getStr("zwsc_xsl")));
|
||||||
|
BigDecimal zwhj_xse=new BigDecimal(record.getStr("zw_xse")).add(new BigDecimal(record.getStr("zwsc_xse")));
|
||||||
|
record.set("zwhj_xsl",zwhj_xsl);
|
||||||
|
record.set("zwhj_xse",zwhj_xse);
|
||||||
|
//融嘉合计
|
||||||
|
BigDecimal jrhj_xsl=new BigDecimal(record.getStr("jr_xsl")).add(new BigDecimal(record.getStr("sl_xsl")));
|
||||||
|
BigDecimal jrhj_xse=new BigDecimal(record.getStr("jr_xse")).add(new BigDecimal(record.getStr("sl_xse")));
|
||||||
|
record.set("jrhj_xsl",jrhj_xsl);
|
||||||
|
record.set("jrhj_xse",jrhj_xse);
|
||||||
|
//盐港合计
|
||||||
|
BigDecimal yghj_xsl=new BigDecimal(record.getStr("yg_xsl")).add(new BigDecimal(record.getStr("ya_xsl")));
|
||||||
|
BigDecimal yghj_xse=new BigDecimal(record.getStr("yg_xse")).add(new BigDecimal(record.getStr("ya_xse")));
|
||||||
|
record.set("yghj_xsl",yghj_xsl);
|
||||||
|
record.set("yghj_xse",yghj_xse);
|
||||||
|
return record;
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue