Browse Source

快照增加销售订单各分类数量,商城获取接口调用

hejq 7 years ago
parent
commit
c1eac2a5c2

+ 38 - 0
src/main/java/com/uas/platform/b2b/model/util/SnapshotSqlUtil.java

@@ -193,4 +193,42 @@ public class SnapshotSqlUtil {
      */
     public static final String SALE_TENDER_WAITING_SQL = "select 'saletenderwaiting' as category, ? as enuu, count(1) as count from v$purc$tender " +
             "where pt_ispublish = 1 and pt_overdue = 1 and pt_result = 0 and pt_status = '待评标' and pt_enuu = ?";
+
+    /**
+     * 获取全部销售订单(供应商)
+     */
+    public static final String SALE_ORDER_ALL_SQL = "select 'saleOrderAll' as category, ? as enuu, count(1) as count from purc$orders " +
+            "where pu_venduu = ?";
+
+    /**
+     * 获取待回复销售订单(供应商)
+     */
+    public static final String SALE_ORDER_TODO_SQL = "select 'saleOrderTodo' as category, ? as enuu, count(1) as count from purc$orders " +
+            "where pu_venduu = ? and pu_status=200 and coalesce(pu_end,0) <> 1";
+
+    /**
+     * 获取已回复销售订单(供应商)
+     */
+    public static final String SALE_ORDER_DONE_SQL = "select 'saleOrderDone' as category, ? as enuu, count(1) as count from purc$orders " +
+            "where pu_venduu = ? and pu_reply=1 and (pu_end = 0 or pu_end is null)";
+
+    /**
+     * 获取已结案的订单(供应商)
+     */
+    public static final String SALE_ORDER_END_SQL = "select 'saleOrderEnd' as category, ? as enuu, count(1) as count from purc$orders " +
+            "where pu_venduu = ? and pu_end = 1";
+
+    /**
+     * 获取已发货的订单(供应商)
+     */
+    public static final String SALE_ORDER_RECEIVED_SQL = "select 'saleOrderReceived' as category, ? as enuu, count(1) as count from purc$orders " +
+            "where pu_venduu = ? and (pu_end is null or pu_end = 0) " +
+            "and pu_id in (select i.pd_puid from purc$orderitems i where IFNULL(i.pd_acceptqty,0)>=IFNULL(i.pd_qty,0)+IFNULL(i.pd_returnqty,0))";
+
+    /**
+     * 获取待发货的订单(供应商)
+     */
+    public static final String SALE_ORDER_WAITING_SQL = "select 'saleOrderWaiting' as category, ? as enuu, count(1) as count from purc$orders " +
+            "where pu_venduu = ? and (pu_end is null or pu_end = 0) " +
+            "and (pu_end=0 or pu_end is null) and pu_id in (select i.pd_puid from purc$orderitems i where ifnull(i.pd_acceptqty,0)<ifnull(i.pd_qty,0)+ifnull(i.pd_returnqty,0)) and pu_status <> 311";
 }

+ 78 - 0
src/main/java/com/uas/platform/b2b/service/impl/SnapshotServiceImpl.java

@@ -132,10 +132,88 @@ public class SnapshotServiceImpl implements SnapshotService {
         }).task(() -> {
             // 获取待评标招标单
             getSaleTenderWaiting(snapshots, enUU);
+        }).task(() -> {
+            // 获取全部销售订单
+            getSaleOrderAll(snapshots, enUU);
+        }).task(() -> {
+            // 获取待回复销售订单
+            getSaleOrderTodo(snapshots, enUU);
+        }).task(() -> {
+            // 获取已回复销售订单
+            getSaleOrderDone(snapshots, enUU);
+        }).task(() -> {
+            // 获取已结案的订单
+            getSaleOrderEnd(snapshots, enUU);
+        }).task(() -> {
+            // 获取已发货的订单
+            getSaleOrderReceived(snapshots, enUU);
+        }).task(() -> {
+            // 获取待发货的订单
+            getSaleOrderWaiting(snapshots, enUU);
         }).run();
         return snapshots;
     }
 
+    /**
+     * 获取待发货的订单
+     *
+     * @param snapshots 快照
+     * @param vendUU 企业UU
+     */
+    private void getSaleOrderWaiting(List<Snapshot> snapshots, Long vendUU) {
+        snapshots.addAll(commonDao.query(SnapshotSqlUtil.SALE_ORDER_WAITING_SQL, Snapshot.class, vendUU, vendUU));
+    }
+
+    /**
+     * 获取已发货的订单
+     *
+     * @param snapshots 快照
+     * @param vendUU 企业UU
+     */
+    private void getSaleOrderReceived(List<Snapshot> snapshots, Long vendUU) {
+        snapshots.addAll(commonDao.query(SnapshotSqlUtil.SALE_ORDER_RECEIVED_SQL, Snapshot.class, vendUU, vendUU));
+    }
+
+    /**
+     * 获取已结案的订单
+     *
+     * @param snapshots 快照
+     * @param vendUU 企业UU
+     */
+    private void getSaleOrderEnd(List<Snapshot> snapshots, Long vendUU) {
+        snapshots.addAll(commonDao.query(SnapshotSqlUtil.SALE_ORDER_END_SQL, Snapshot.class, vendUU, vendUU));
+    }
+
+    /**
+     * 获取已回复销售订单
+     *
+     * @param snapshots 快照
+     * @param vendUU 企业UU
+     */
+    private void getSaleOrderDone(List<Snapshot> snapshots, Long vendUU) {
+        snapshots.addAll(commonDao.query(SnapshotSqlUtil.SALE_ORDER_DONE_SQL, Snapshot.class, vendUU, vendUU));
+    }
+
+    /**
+     * 获取待回复销售订单
+     *
+     * @param snapshots 快照
+     * @param vendUU 企业UU
+     */
+    private void getSaleOrderTodo(List<Snapshot> snapshots, Long vendUU) {
+        snapshots.addAll(commonDao.query(SnapshotSqlUtil.SALE_ORDER_TODO_SQL, Snapshot.class, vendUU, vendUU));
+    }
+
+    /**
+     * 获取全部销售订单
+     *
+     * @param snapshots 快照
+     * @param vendUU 企业UU
+     */
+    private void getSaleOrderAll(List<Snapshot> snapshots, Long vendUU) {
+        snapshots.addAll(commonDao.query(SnapshotSqlUtil.SALE_ORDER_ALL_SQL, Snapshot.class, vendUU, vendUU));
+    }
+
     /**
      * 获取待评标招标单
      *