From 451b90aae1d0cd68f347827f395081f8b0052c4a Mon Sep 17 00:00:00 2001 From: xiaocui <1334950895@qq.com> Date: Tue, 30 Mar 2021 20:00:28 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A0=82=E7=AB=99=E8=BF=90=E8=BE=93=E9=87=8F?= =?UTF-8?q?=E7=BB=9F=E8=AE=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/cowr/common/Const.java | 4 +- .../ordercluster/OrderclusterService.java | 88 +++- .../refunddetail/RefundDetailService.java | 17 +- .../ssjygl/stat/sale/OrderStatService.java | 398 ++++++++++++++++++ 4 files changed, 500 insertions(+), 7 deletions(-) diff --git a/ssjygl-xsx-common/src/main/java/com/cowr/common/Const.java b/ssjygl-xsx-common/src/main/java/com/cowr/common/Const.java index b9a7deb..8068a3c 100644 --- a/ssjygl-xsx-common/src/main/java/com/cowr/common/Const.java +++ b/ssjygl-xsx-common/src/main/java/com/cowr/common/Const.java @@ -21,7 +21,7 @@ public class Const { 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_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_CUSTOMER_DAY_STAT = "SMS_208985081"; // 客户日销售汇总 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_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_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_REFUND_SUCCESS, "${time}${customer_name}在${vendor}的退款${amount}元，合计余额${surplus}元。"); } diff --git a/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/order/ordercluster/OrderclusterService.java b/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/order/ordercluster/OrderclusterService.java index 0186407..7fa85a4 100644 --- a/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/order/ordercluster/OrderclusterService.java +++ b/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/order/ordercluster/OrderclusterService.java @@ -4,7 +4,6 @@ import com.cowr.common.Const; import com.cowr.common.base.BaseService; import com.cowr.common.enums.OrderStateEnum; import com.cowr.common.enums.UserTypeEnum; -import com.cowr.common.utils.DateTimeUtil; import com.cowr.common.view.PageParam; import com.cowr.common.view.Result; import com.cowr.model.Ordercluster; @@ -21,7 +20,10 @@ import com.jfinal.plugin.activerecord.Page; import com.jfinal.plugin.activerecord.Record; import java.math.BigDecimal; -import java.util.*; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; /** * Generated by COWR Fri Apr 17 16:59:39 CST 2020 @@ -637,7 +639,7 @@ public class OrderclusterService extends BaseService { } /** - * 获取集团订单剩余成量 + * 获取单个集团订单剩余成量 * * @param ordercluster_id * @return @@ -694,4 +696,84 @@ public class OrderclusterService extends BaseService { return out == null ? new BigDecimal(0) : out; } + + + /** + * 按客户查询未完成的配额量 + * + * @param customer_id + * @return + */ + public BigDecimal getOverTotalPriceByCustomer(int customer_id) { + String sql = "select sum(a.total_price) total_price from ( \n" + + " select t.ordercluster_id, sum(t.weight) weight, sum(t.total_price) total_price from order_sale t \n" + + " left join ordercluster o on o.id = t.ordercluster_id\n" + + " where t.state = ? \n" + + " and o.state < ? \n" + + " and o.customer_id = ? \n" + + " group by t.ordercluster_id \n" + + " \n" + + " union \n" + + " select t.ordercluster_id, sum(t.weight) weight, sum(t.total_price) total_price from order_temp t \n" + + " left join ordercluster o on o.id = t.ordercluster_id\n" + + " where t.state = ? \n" + + " and o.state < ? \n" + + " and o.customer_id = ? \n" + + " group by t.ordercluster_id \n" + + ") a \n" + + "group by a.ordercluster_id "; + + BigDecimal out = Db.queryBigDecimal( + sql, + OrderStateEnum.RECEIVED.getStateid(), OrderStateEnum.RECEIVED.getStateid(), customer_id, + OrderStateEnum.RECEIVED.getStateid(), OrderStateEnum.RECEIVED.getStateid(), customer_id + ); + + return out == null ? new BigDecimal(0) : out; + } + + /** + * 客户未完成的配额中，未执行完成的总金额 + * + * @param customer_id + * @return + */ + public BigDecimal undoPrice(int customer_id) { + String sql = "select(\n" + + " select sum(t.`total_weight` * t.`unit_price`) `total_price`\n" + + " from `ordercluster` t\n" + + " where t.`customer_id`= ?\n" + + " and t.state < ? ) - (\n" + + " select sum(t.`weight` * t.`unit_price`) total_price\n" + + " from order_temp t\n" + + " where exists(\n" + + " select 1 from `ordercluster` o\n" + + " where o.`customer_id`= ?\n" + + " and o.id= t.`ordercluster_id`\n" + + " and o.`state`< ?" + + " )\n" + + " and t.`customer_id`= ?\n" + + " and t.`state`= ?)"; + + BigDecimal out = Db.queryBigDecimal( + sql, + customer_id, + OrderStateEnum.RECEIVED.getStateid(), + customer_id, + OrderStateEnum.RECEIVED.getStateid(), + customer_id, + OrderStateEnum.RECEIVED.getStateid() + ); + + return out == null ? new BigDecimal("0") : out; + } + + /** + * 获取用户未完成订单id + */ + public List 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); + } } diff --git a/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/prepay/refunddetail/RefundDetailService.java b/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/prepay/refunddetail/RefundDetailService.java index 713c637..5eeda4a 100644 --- a/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/prepay/refunddetail/RefundDetailService.java +++ b/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/prepay/refunddetail/RefundDetailService.java @@ -4,8 +4,10 @@ import com.cowr.common.Const; import com.cowr.common.base.BaseService; import com.cowr.common.view.PageParam; import com.cowr.model.Customer; +import com.cowr.model.PrepayCustomer; import com.cowr.model.PrepayDetail; import com.cowr.model.RefundDetail; +import com.cowr.ssjygl.prepay.prepaycustomer.PrepayCustomerService; import com.jfinal.kit.StrKit; import com.jfinal.log.Log; import com.jfinal.plugin.activerecord.Db; @@ -92,7 +94,7 @@ public class RefundDetailService extends BaseService { } /** - * 获取账户可用余额 + * 根据账户ID和账户金额，获取账户可用余额 * @param customer_id 客户ID * @param surplus 账户余额 * @return @@ -106,5 +108,16 @@ public class RefundDetailService extends BaseService { 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()); + } } diff --git a/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/stat/sale/OrderStatService.java b/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/stat/sale/OrderStatService.java index 6229b2c..6260e59 100644 --- a/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/stat/sale/OrderStatService.java +++ b/ssjygl-xsx-common/src/main/java/com/cowr/ssjygl/stat/sale/OrderStatService.java @@ -11,6 +11,7 @@ import com.jfinal.kit.StrKit; import com.jfinal.log.Log; import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.Record; +import org.apache.poi.hssf.usermodel.HSSFCellStyle; import org.apache.poi.ss.usermodel.*; import org.apache.poi.ss.util.CellRangeAddress; import org.apache.poi.xssf.usermodel.XSSFWorkbook; @@ -1837,4 +1838,401 @@ public class OrderStatService { return wb; } + + public Workbook trafficStatisticsOfEachSandStationExport(String stm, String etm){ + List 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 trafficStatisticsOfEachSandStation( String stm, String etm){ + List 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 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 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 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; + } + }