数据大盘

src/custom/restcontroller/R.java

@@ -6558,6 +6558,21 @@ public class R {
         public static class v1 {
         }
     }
+
+    public static class ID2024061113520802 {
+        public static class v1 {
+        }
+    }
+
+    public static class ID2024061113525202 {
+        public static class v1 {
+        }
+    }
+
+    public static class ID2024061114184602 {
+        public static class v1 {
+        }
+    }
 }
 
 

src/custom/restcontroller/webmanage/saletool/data/DataDashboard.java

@@ -1,15 +1,15 @@
 package restcontroller.webmanage.saletool.data;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import common.Controller;
 import common.YosException;
 import common.annotation.API;
-import common.data.QuerySQL;
-import common.data.Row;
-import common.data.Rows;
-import common.data.SQLFactory;
+import common.data.*;
 import restcontroller.R;
 
+import java.util.ArrayList;
+
 /**
  * 数据大盘
  */
@@ -64,8 +64,6 @@ public class DataDashboard extends Controller {
         if (type == 3) {
             querySQL.setWhere("t.userid in (" + DataDashboardHelper.getStopSql(this, usertype) + ")");
         }
-
-        System.err.println(querySQL.getSQL());
         querySQL.setPage(pageSize, pageNumber).setOrderBy(pageSorting);
         Rows rows = querySQL.query();
 
@@ -80,5 +78,160 @@ public class DataDashboard extends Controller {
         return getSucReturnObject().setData(rows).toString();
     }
 
+    @API(title = "添加分享记录", apiversion = R.ID2024061113525202.v1.class)
+    public String insertShareLog() throws YosException {
+
+        Long shareuserid = content.getLongValue("shareuserid");
+        String channel = content.getStringValue("channel");
+        String appname = content.getStringValue("appname");
+
+        InsertSQL insertSQL = SQLFactory.createInsertSQL(this, "sys_sharelog");
+        insertSQL.setSiteid(siteid);
+        insertSQL.setUniqueid(createTableID("sys_sharelog"));
+        insertSQL.setValue("shareuserid", shareuserid);
+        insertSQL.setValue("channel", channel);
+        insertSQL.setValue("appname", appname);
+        insertSQL.insert();
+
+        return getSucReturnObject().toString();
+    }
+
+    @API(title = "账户使用情况", apiversion = R.ID2024061114184602.v1.class)
+    public String accountInfo() throws YosException {
+
+        int usertype = content.getIntValue("usertype");
+        int type = 0;
+        String begindate = "";
+        String enddate = "";
+
+        if (content.containsKey("where")) {
+            JSONObject whereObject = content.getJSONObject("where");
+            if (whereObject.containsKey("type") && !"".equals(whereObject.getString("type"))) {
+                type = whereObject.getIntValue("type");
+            }
+            if (whereObject.containsKey("begindate") && !"".equals(whereObject.getString("begindate"))) {
+                begindate = whereObject.getStringValue("begindate");
+                type=0;
+            }
+            if (whereObject.containsKey("enddate") && !"".equals(whereObject.getString("enddate"))) {
+                enddate = whereObject.getStringValue("enddate");
+                type=0;
+            }
+        }
+
+
+        QuerySQL t2 = SQLFactory.createQuerySQL(this, "sys_userrequestlog", "userid", "usersiteid", "siteid");
+        t2.addGroupBy("userid", "usersiteid", "siteid");
+        if (type == 1) {
+            t2.setWhere("DATE(lastrequestdate) = CURDATE()");
+        }
+        if (type == 2) {
+            t2.setWhere("DATE(lastrequestdate) = CURDATE() - INTERVAL 1 DAY");
+        }
+        if (type == 3) {
+            t2.setWhere("lastrequestdate >= CURRENT_DATE - INTERVAL 7 DAY");
+        }
+        if (type == 4) {
+            t2.setWhere("lastrequestdate >= CURRENT_DATE - INTERVAL 30 DAY");
+        }
+        if (!begindate.isEmpty() && !enddate.isEmpty()) {
+            t2.setWhere("lastrequestdate >= '"+begindate+"' and lastrequestdate<='"+enddate+" 23:59:59'");
+        }
+        t2.addQueryFields("lastrequestdate", "max(lastrequestdate)");
+
+        QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_usersite", "userid").setTableAlias("t1");
+        querySQL.addJoinTable(JOINTYPE.left, t2, "t2", "t2.usersiteid=t1.usersiteid and t2.userid=t1.userid and t2.siteid=t1.siteid", "lastrequestdate");
+        querySQL.addJoinTable(JOINTYPE.inner, "sys_users", "t3", "t3.userid=t1.userid", "name");
+        querySQL.setSiteid(siteid);
+        querySQL.setWhere("usertype", usertype);
+        querySQL.setWhere("t3.`status` in ('active','inactive')");
+        querySQL.setPage(pageSize, pageNumber).setOrderBy(pageSorting);
+        Rows rows = querySQL.query();
+
+
+        ArrayList<Long> userids = rows.toArrayList("userid", new ArrayList<>());
+
+        QuerySQL share = SQLFactory.createQuerySQL(this, "sys_sharelog", "createuserid");
+        share.addQueryFields("count", "count(DISTINCT createuserid,shareuserid)");
+        share.setSiteid(siteid);
+        share.setWhere("createuserid", userids);
+        if (type == 1) {
+            share.setWhere("DATE(createdate) = CURDATE()");
+        }
+        if (type == 2) {
+            share.setWhere("DATE(createdate) = CURDATE() - INTERVAL 1 DAY");
+        }
+        if (type == 3) {
+            share.setWhere("createdate >= CURRENT_DATE - INTERVAL 7 DAY");
+        }
+        if (type == 4) {
+            share.setWhere("createdate >= CURRENT_DATE - INTERVAL 30 DAY");
+        }
+        if (!begindate.isEmpty() && !enddate.isEmpty()) {
+            t2.setWhere("createdate >= '"+begindate+"' and createdate<='"+enddate+" 23:59:59'");
+        }
+        share.addGroupBy("createuserid");
+        RowsMap shareRowsMap = share.query().toRowsMap("createuserid");
+
+        QuerySQL appointment = SQLFactory.createQuerySQL(this, "sa_appointment", "createuserid");
+        appointment.addQueryFields("count", "count(DISTINCT createuserid,shareuserid)");
+        appointment.setSiteid(siteid);
+        appointment.setWhere("createuserid", userids);
+        if (type == 1) {
+            appointment.setWhere("DATE(createdate) = CURDATE()");
+        }
+        if (type == 2) {
+            appointment.setWhere("DATE(createdate) = CURDATE() - INTERVAL 1 DAY");
+        }
+        if (type == 3) {
+            appointment.setWhere("createdate >= CURRENT_DATE - INTERVAL 7 DAY");
+        }
+        if (type == 4) {
+            appointment.setWhere("createdate >= CURRENT_DATE - INTERVAL 30 DAY");
+        }
+        if (!begindate.isEmpty() && !enddate.isEmpty()) {
+            appointment.setWhere("createdate >= '"+begindate+"' and createdate<='"+enddate+" 23:59:59'");
+        }
+        appointment.addGroupBy("createuserid");
+        RowsMap appointmentRowsMap = appointment.query().toRowsMap("createuserid");
+
+        RowsMap areaRowsMap;
+        if (usertype == 1) {
+            QuerySQL area = SQLFactory.createQuerySQL(this, "sa_salearea_hr", "siteid").setTableAlias("t1");
+            area.addJoinTable(JOINTYPE.inner, "sys_hr", "t2", "t2.hrid=t1.hrid and t2.siteid=t1.siteid", "userid");
+            area.addJoinTable(JOINTYPE.inner, "sa_salearea", "t3", "t3.sa_saleareaid = t1.sa_saleareaid and t3.siteid=t1.siteid");
+            area.addQueryFields("areaname", "GROUP_CONCAT(DISTINCT t3.areaname SEPARATOR',')");
+            area.addGroupBy("userid", "siteid");
+            area.setSiteid(siteid);
+            area.setWhere("t2.userid", userids);
+            areaRowsMap = area.query().toRowsMap("userid");
+        } else {
+            QuerySQL areaEnterprise = SQLFactory.createQuerySQL(this, "sys_enterprise_tradefield", "siteid").setTableAlias("t1");
+            areaEnterprise.addJoinTable(JOINTYPE.inner, "sys_enterprise_hr", "t2", "t2.sys_enterpriseid=t1.sys_enterpriseid and t2.siteid=t1.siteid", "userid");
+            areaEnterprise.addJoinTable(JOINTYPE.inner, "sa_salearea", "t3", "t3.sa_saleareaid = t1.sa_saleareaid and t3.siteid=t1.siteid");
+            areaEnterprise.addQueryFields("areaname", "GROUP_CONCAT(DISTINCT t3.areaname SEPARATOR',')");
+            areaEnterprise.addGroupBy("userid", "siteid");
+            areaEnterprise.setSiteid(siteid);
+            areaEnterprise.setWhere("t2.userid", userids);
+            areaRowsMap = areaEnterprise.query().toRowsMap("userid");
+        }
+
+
+        for (Row row : rows) {
+            row.putIfAbsent("lastrequestdate", "");
+            Rows shareRows = shareRowsMap.getOrDefault(row.getString("userid"), new Rows());
+            row.put("cust_count", shareRows.isEmpty() ? 0 : shareRows.get(0).getLong("count"));
+
+            Rows appointmentRows = appointmentRowsMap.getOrDefault(row.getString("userid"), new Rows());
+            row.put("appoint_count", appointmentRows.isEmpty() ? 0 : appointmentRows.get(0).getLong("count"));
+
+            Rows areaRows = areaRowsMap.getOrDefault(row.getString("userid"), new Rows());
+            row.put("areaname", areaRows.isEmpty() ? "" : areaRows.get(0).getString("areaname"));
+
+        }
+
+        return getSucReturnObject().setData(rows).toString();
+    }
+
 
 }