#E10-24# 群聊数量接口优化及自主服务初始化接口

src/main/java/com/weaver/seconddev/jcldoor/cmd/SelfServiceInfoCmd.java

@@ -1,11 +1,14 @@
 package com.weaver.seconddev.jcldoor.cmd;
 
+import com.weaver.common.distribution.genid.IdGenerator;
 import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity;
+import com.weaver.ebuilder.form.client.entity.obj.Obj;
 import com.weaver.seconddev.jcldoor.util.DatabaseUtils;
 import com.weaver.seconddev.jcldoor.util.JucailinPortalUtils;
 import com.weaver.teams.domain.user.SimpleEmployee;
 import com.weaver.teams.security.context.UserContext;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.tools.ant.types.selectors.modifiedselector.Cache;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -317,6 +320,266 @@ public class SelfServiceInfoCmd {
     }
 
 
+    /***
+     *
+     * @param employeeId
+     * @return
+     */
+    public Map<String,Object> initSelfServiceData(String employeeId){
+
+        Map<String,Object> recordMap = new HashMap<String,Object>();
+        String pkey = "uf_zzfwcsh.taby.fieldId";
+        String field_id =  jucailinPortalUtils.getUfPropData(pkey,tenant_key);
+
+        pkey = "uf_zzfwcsh.taby.url";
+        String taburl =  jucailinPortalUtils.getUfPropData(pkey,tenant_key);
+
+        String groupId = "weaver-ebuilder-form-service";
+        String sourceType = "LOGIC";
+
+        try{
+            String sql = " select distinct taby from uf_zzfwrkpz where ry=? and qy is not null and taby is not null and delete_type=0 and tenant_key =?";
+
+            List<String> strlist = new ArrayList<>(100);
+            strlist.add(employeeId);
+            strlist.add(tenant_key);
+            List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(strlist);
+            Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
+            List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
+            if(recordList.size()>0){
+                recordMap.put("code","200");
+                recordMap.put("type","1");
+            }else{
+                int count = initCustomServiceData(groupId,sourceType,field_id,employeeId);
+                if(count > 0){
+                    recordMap.put("code","-100");
+                }else{
+                    recordMap.put("code","200");
+                }
+                recordMap.put("type","0");
+            }
+        }catch (Exception e){
+            log.error("testSapi51-Exception:"+e.getMessage());
+            recordMap.put("code","-200");
+        }
+
+        return recordMap;
+    }
+
+
+    /***
+     *  默认数据
+     * @param groupId
+     * @param sourceType
+     * @return
+     */
+    public int initCustomServiceData(String groupId,String sourceType,String field_id,String employeeId){
+        int errcount = 0;
+        try{
+            String sql = " select name,value_key as taby from field_option where field_id=? and  delete_type=0 and tenant_key = ?";
+            log.info("sql:"+sql);
+            List<String> paramList = new ArrayList<>(100);
+            paramList.add(field_id);
+            paramList.add(tenant_key);
+
+            List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList);
+            Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
+            List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
+            for(int i=0;i<recordList.size();i++){
+                Map<String,Object> recordMap = recordList.get(i);
+                String taby = String.valueOf(recordMap.get("taby"));
+                String name = String.valueOf(recordMap.get("name"));
+                String code = insertTabData(employeeId,name,i+"",groupId,sourceType);
+                if("200".equals(code)){
+                    String tabid = getTabId(employeeId,name,groupId,sourceType);
+                    log.error("tabid:"+tabid);
+                    if(StringUtils.isNotBlank(tabid)){
+                        int count = initCustomServiceDataByType(employeeId,groupId,sourceType,taby,tabid);
+                        if(count>0){
+                            errcount++;
+                        }
+                    }
+                }else{
+                    errcount++;
+                }
+            }
+
+        }catch (Exception e){
+            errcount++;
+        }
+        return errcount;
+    }
+
+    /***
+     *
+     * @param employeeId
+     * @param name
+     * @param xssx
+     * @param groupId
+     * @param sourceType
+     * @return
+     */
+    public String insertTabData(String employeeId,String name,String xssx,String groupId,String sourceType){
+
+        String qy = "1";
+        String code = "" ;
+        try{
+            log.error("insertTabData");
+            long generate = IdGenerator.generate();
+
+            log.error("insertTabData--id:"+generate+"  ry:"+employeeId+" tabymmc:"+name+"  xssx:"+xssx);
+
+            String sql =" insert into uf_zzfwrktaby(id,ry,tabymmc,qy,xssx,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type)  " +
+                        " values(?,?,?,?,?,?,?,?,0,now(),now(),?,0,?,0)";
+
+            List<String> paramList = new ArrayList<>(100);
+            paramList.add(generate+"");
+            paramList.add(employeeId);
+            paramList.add(name);
+            paramList.add(qy);
+            paramList.add(xssx);
+            paramList.add(generate+"");
+            paramList.add(tenant_key);
+            paramList.add(employeeId);
+            List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList);
+            Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
+            if(result.containsKey("code")){
+                code = String.valueOf(result.get("code"));
+            }
+            log.error("code:"+code);
+
+        }catch (Exception e){
+            code = "-200";
+            log.error("insertTabData-e:"+e);
+        }
+        return code;
+    }
+
+    /***
+     *
+     * @param employeeId
+     * @param name
+     * @param groupId
+     * @param sourceType
+     * @return
+     */
+    public String getTabId(String employeeId,String name,String groupId,String sourceType){
+
+        String qy = "1";
+        String tabid = "" ;
+        try{
+            String sql = "select id from uf_zzfwrktaby where ry = ? and tabymmc = ? and qy = ?";
+            log.info("sql:"+sql);
+
+            List<String> paramList = new ArrayList<>(100);
+            paramList.add(employeeId);
+            paramList.add(name);
+            paramList.add(qy);
+            List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList);
+            Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
+            List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
+            if(!recordList.isEmpty() && recordList.size()>0){
+                Map<String, Object> recordMap = recordList.get(0);
+                tabid = String.valueOf(recordMap.get("id"));
+            }
+        }catch (Exception e){
+            log.error("getTabId-e:"+e);
+        }
+        return tabid;
+    }
+
+    /**
+     *
+     * @param employeeId
+     * @param groupId
+     * @param sourceType
+     * @param selectvalue
+     * @param tabid
+     * @return
+     */
+    public int initCustomServiceDataByType(String employeeId,String groupId,String sourceType,String selectvalue,String tabid){
+
+        int errcount = 0 ;
+        try{
+            String sql =" select t.taby,t.fwtb,t.fwmc,t.fwdz " +
+                        " from uf_zzfwcsh t \n" +
+                        " where t.delete_type=0 \n" +
+                        " and t.taby= ?" +
+                        " and t.tenant_key = ?" +
+                        " order by ifnull(t.xssx,0) ";
+
+            List<String> paramList = new ArrayList<>(100);
+            paramList.add(selectvalue);
+            paramList.add(tenant_key);
+            List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList);
+            Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
+            List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
+            for(int i=0;i<recordList.size();i++){
+                Map<String,Object> recordMap = recordList.get(i);
+                String fwtb = String.valueOf(recordMap.get("fwtb"));
+                String fwmc = String.valueOf(recordMap.get("fwmc"));
+                String fwdz = String.valueOf(recordMap.get("fwdz"));
+                String code = insertCustomServiceData(employeeId,fwmc,fwdz,fwtb,i+"",groupId,sourceType,tabid);
+                if(!"200".equals(code)){
+                    errcount++;
+                }
+            }
+        }catch (Exception e){
+            errcount++;
+        }
+        return errcount;
+    }
+
+    /**
+     *
+     * @param employeeId
+     * @param name
+     * @param fwdz
+     * @param fwtb
+     * @param xssx
+     * @param groupId
+     * @param sourceType
+     * @param tabid
+     * @return
+     */
+    public String insertCustomServiceData(String employeeId,String name,String fwdz,String fwtb,String xssx,String groupId,String sourceType,String tabid){
+
+        String qy = "1";
+        String code = "";
+        try {
+
+            long generate = IdGenerator.generate();
+            log.error("insertCustomServiceData--id:"+generate+"  ry:"+employeeId+" fwmc:"+name+" fwdz:"+fwdz+" fwtb:"+fwtb+" taby:"+tabid+" xssx:"+xssx);
+
+            String sql =" insert into uf_zzfwrkpz(id,ry,fwmc,fwdz,fwtb,taby,qy,xssx,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type)  " +
+                        " values(?,?,?,?,?,?,?,?,?,0,now(),now(),?,0,?,0)";
+
+            List<String> paramlist = new ArrayList<>(100);
+            paramlist.add(generate+"");
+            paramlist.add(employeeId);
+            paramlist.add(name);
+            paramlist.add(fwdz);
+            paramlist.add(fwtb);
+            paramlist.add(tabid);
+            paramlist.add(qy);
+            paramlist.add(xssx);
+            paramlist.add(generate+"");
+            paramlist.add(tenant_key);
+            paramlist.add(employeeId);
+            List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramlist);
+            Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
+            if(result.containsKey("code")){
+                code = String.valueOf(result.get("code"));
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            log.error("insertCustomServiceData-e:"+e);
+            code = "-200";
+        }
+        return code ;
+    }
+
+
 
 
 }

src/main/java/com/weaver/seconddev/jcldoor/controller/HrmSelfHelpController.java

@@ -1,6 +1,5 @@
 package com.weaver.seconddev.jcldoor.controller;
 
-import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.weaver.common.authority.annotation.WeaPermission;
@@ -1085,8 +1084,14 @@ public class HrmSelfHelpController {
     }
 
 
-
-
+    /***
+     *
+     * @param groupId
+     * @param sourceType
+     * @param value
+     * @param employeeId
+     * @return
+     */
     public List<Map<String,Object>> getCustomeServiceDataByType(String groupId,String sourceType,String value,String employeeId){
         String sql = " select fwmc,fwdz,fwtb,taby from uf_zzfwrkpz where ry=? and qy is not null and taby is not null and taby="+value+" and delete_type=0 and tenant_key = '"+tenant_key+"'";
         log.info("getSelfServiceData--sql:"+sql);
@@ -1462,6 +1467,10 @@ public class HrmSelfHelpController {
             String pagesize = request.getParameter("pagesize");
             String pagenum = request.getParameter("pagenum");
 
+            dataMap.put("tenant_key",tenant_key);
+            dataMap.put("pagesize",pagesize);
+            dataMap.put("pagesize",pagesize);
+
             Map<String,Object> dMap = chatGroupUtils.getChatGroup(tenant_key,tablename,pagesize,pagenum);
             dataMap.putAll(dMap);
         } catch (Exception e) {
@@ -1484,6 +1493,10 @@ public class HrmSelfHelpController {
             String pagesize = request.getParameter("pagesize");
             String pagenum = request.getParameter("pagenum");
 
+            dataMap.put("tenant_key",tenant_key);
+            dataMap.put("pagesize",pagesize);
+            dataMap.put("pagesize",pagesize);
+
             String tablename = "uf_nj_pjmrdlhhsl" ;
             dataMap.put("tablename",tablename);
             Map<String,Object> dMap = chatDayUtils.getChatDay(tenant_key,tablename,pagesize,pagenum);

src/main/java/com/weaver/seconddev/jcldoor/controller/JucailinPortalController.java

@@ -619,7 +619,32 @@ public class JucailinPortalController {
     }
 
 
+    /**
+     * 自助服务(新增点击次数接口)
+     * @param request
+     * @return
+     */
+    @GetMapping("/initSelfServiceData")
+    @WeaPermission(publicPermission = true)
+    public WeaResult<Object> initSelfServiceData(HttpServletRequest request){
+        log.error("initSelfServiceData");
+        Map<String, Object> dataMap = new HashMap<String, Object>();
+
+        try{
+            SimpleEmployee employee = UserContext.getCurrentUser();
+
+            String employeeId = request.getParameter("employeeId");
+            if(StringUtils.isBlank(employeeId)){
+                employeeId = String.valueOf(employee.getEmployeeId());
+            }
+            log.error("employeeId:"+employeeId);
 
+            dataMap = jucailinPortalService.initSelfServiceData(employeeId);
+        }catch (Exception e){
+            log.error("addSelfServiceCount-Exception:"+e.getMessage());
+        }
+        return WeaResult.success(dataMap);
+    }
 
 
 

src/main/java/com/weaver/seconddev/jcldoor/service/JucailinPortalService.java

@@ -54,4 +54,6 @@ public interface JucailinPortalService {
 
     public Map<String, Object> getUserType(HttpServletRequest request,SimpleEmployee simpleEmployee);
 
+    public Map<String, Object> initSelfServiceData(String employeeId);
+
 }

src/main/java/com/weaver/seconddev/jcldoor/service/impl/JucailinPortalServiceImpl.java

@@ -331,4 +331,10 @@ public class JucailinPortalServiceImpl implements JucailinPortalService {
         return dataMap;
     }
 
+    @Override
+    public Map<String, Object> initSelfServiceData(String employeeId) {
+        Map<String,Object> dataMap = selfServiceInfoCmd.initSelfServiceData(employeeId);
+        return dataMap;
+    }
+
 }

src/main/java/com/weaver/seconddev/jcldoor/util/ChatDayUtils.java

@@ -54,7 +54,7 @@ public class ChatDayUtils {
             log.error("startDate:"+startDate);
             log.error("endDate:"+endDate);
             Long cid = employee.getCid();
-            log.error("getChatGroup--cid:"+cid);
+            log.error("ChatDayUtils--cid:"+cid);
             Long employeeId = employee.getEmployeeId();
 
             Map<String, Object> json = new HashMap<String, Object>();
@@ -66,6 +66,8 @@ public class ChatDayUtils {
 
             log.error("json:"+ JSON.toJSONString(json));
 
+            dataMap.put("json",JSON.toJSONString(json));
+
             Request request = new Request();
             request.setUrl("/user-profile/dailySingleSession");
             request.setParamsMap(json);
@@ -73,9 +75,12 @@ public class ChatDayUtils {
 
             log.error("request:"+ request.toString());
             Response response = oaRest.executeIm(request);
-            log.error("getChatGroup--isSuccess"+response.isSuccess());
+            log.error("getChatDay--isSuccess"+response.isSuccess());
             if (response.isSuccess()){
+                dataMap.put("isSuccess","1");
+
                 String data = response.getData();
+                dataMap.put("data",data);
                 if(StringUtils.isNotBlank(data)){
                     JSONObject dataJson = JSONObject.parseObject(data);
                     JSONObject actionMsg = dataJson.getJSONObject("actionMsg");
@@ -85,10 +90,14 @@ public class ChatDayUtils {
                             JSONObject dataObject =  dataJson.getJSONObject("data");
                             if(dataObject.containsKey("data")){
                                 JSONArray dataArray = dataObject.getJSONArray("data");
+                                log.error("getChatDay--dataArray"+dataArray.size());
+
+
                                 for(int i=0;i<dataArray.size();i++){
                                     JSONObject dataInfo = dataArray.getJSONObject(i);
                                     String userid = dataInfo.getString("userid");
                                     String amount = dataInfo.getString("amount");
+                                    log.error("getChatDay--userid"+userid+"   amount:"+amount);
 
                                     String sql = " select id from "+tablename+" where ry=? and tenant_key=? and delete_type=0 ";
                                     List<SqlParamEntity> sqlparam = new ArrayList<SqlParamEntity>();
@@ -105,8 +114,10 @@ public class ChatDayUtils {
                                     Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
                                     List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
                                     if(!recordList.isEmpty()){
+                                        log.error("getChatDay--!isEmpty");
                                         updateChatDayDate(userid,amount,sourceType,groupId,tenant_key,tablename);
                                     }else{
+                                        log.error("getChatDay--isEmpty");
                                         insertChatDayDate(userid,amount,employeeId,sourceType,groupId,tenant_key,tablename);
                                     }
                                 }
@@ -114,6 +125,8 @@ public class ChatDayUtils {
                         }
                     }
                 }
+            }else{
+                dataMap.put("isSuccess","0");
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -132,30 +145,23 @@ public class ChatDayUtils {
      * @param tenant_key
      */
     public void insertChatDayDate(String userid,String amount,long employeeId,String sourceType,String groupId,String tenant_key,String tablename){
-
+        String code = "";
         try {
             long generate = IdGenerator.generate();
+            log.error("insertChatDayDate-generate:"+generate+" userid:"+userid+" amount"+amount+" employeeId:"+employeeId);
+
             String sql =" insert into "+tablename+"(id,ry,amount,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type)  " +
-                    " values (" + generate + "," + userid + ",'"+amount+"'," + generate + ",0,now(),now(),'"+tenant_key+"',0," + employeeId + ",0)";
+                        " values (" + generate + "," + userid + ",'"+amount+"'," + generate + ",0,now(),now(),'"+tenant_key+"',0," + employeeId + ",0)";
+
             log.error("insertChatDayDate-sql:"+sql);
             Map<String, Object> result = databaseUtils.execute(sourceType, groupId, sql);
-
-            Iterator<Map.Entry<String, Object>> iterator = result.entrySet().iterator();
-            while (iterator.hasNext()){
-                Map.Entry<String, Object> next = iterator.next();
-                log.error("insertChatDayDate--key="+next.getKey()+"  value="+String.valueOf(next.getValue()));
-            }
-
-            List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
-            for(int i=0;i<recordList.size();i++){
-                Map<String,Object> map = recordList.get(i);
-                for (String key:map.keySet()){
-                    System.out.println("insertChatDayDate222--key=  "+key+"   and value=  "+String.valueOf(map.get(key)));
-                }
+            if(result.containsKey("code")){
+                code = String.valueOf(result.get("code"));
             }
         }catch (Exception e){
             e.printStackTrace();
             log.error("insertChatDayDate:"+e);
+            code = "-100";
         }
     }
 
@@ -167,10 +173,11 @@ public class ChatDayUtils {
      * @param groupId
      * @param tenant_key
      */
-    public void updateChatDayDate(String userid,String amount,String sourceType,String groupId,String tenant_key,String tablename){
+    public String updateChatDayDate(String userid,String amount,String sourceType,String groupId,String tenant_key,String tablename){
+        String code = "" ;
         try {
             String sql =" update "+tablename+" set amount=?,update_time=now() where ry = ? and tenant_key= ? and delete_type=0 ";
-            log.error("insertChatDayDate-sql:"+sql);
+            log.error("insertChatDayDate-sql:"+sql + " amount:"+amount+" userid:"+userid);
 
             List<SqlParamEntity> sqlparam = new ArrayList<SqlParamEntity>();
             SqlParamEntity sqlParamEntity = new SqlParamEntity();
@@ -189,23 +196,17 @@ public class ChatDayUtils {
             sqlparam.add(sqlParamEntity);
 
             Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
-            Iterator<Map.Entry<String, Object>> iterator = result.entrySet().iterator();
-            while (iterator.hasNext()){
-                Map.Entry<String, Object> next = iterator.next();
-                log.error("insertChatDayDate--key="+next.getKey()+"  value="+String.valueOf(next.getValue()));
+            if(result.containsKey("code")){
+                code = String.valueOf(result.get("code"));
             }
 
-            List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
-            for(int i=0;i<recordList.size();i++){
-                Map<String,Object> map = recordList.get(i);
-                for (String key:map.keySet()){
-                    System.out.println("insertChatDayDate222--key=  "+key+"   and value=  "+String.valueOf(map.get(key)));
-                }
-            }
         }catch (Exception e){
             e.printStackTrace();
             log.error("insertChatDayDate:"+e);
+            code = "-100";
         }
+
+        return code;
     }
 
 }

src/main/java/com/weaver/seconddev/jcldoor/util/ChatGroupUtils.java

@@ -63,6 +63,7 @@ public class ChatGroupUtils {
             long employeeId = employee.getEmployeeId();
             log.error("getChatGroup--cid:"+cid);
 
+
             Map<String, Object> json = new HashMap<String, Object>();
             json.put("cid",cid);
             json.put("pageNum",pageNum);
@@ -70,6 +71,8 @@ public class ChatGroupUtils {
             json.put("startDate",startDate);
             json.put("endDate",endDate);
 
+            dataMap.put("json",JSON.toJSONString(json));
+
             log.error("json:"+ JSON.toJSONString(json));
 
             Request request = new Request();
@@ -79,8 +82,12 @@ public class ChatGroupUtils {
 
             Response response = oaRest.executeIm(request);
             log.error("getChatGroup--isSuccess"+response.isSuccess());
+
             if(response.isSuccess()){
+                dataMap.put("isSuccess","1");
                 String data = response.getData();
+                dataMap.put("data",data);
+
                 if(StringUtils.isNotBlank(data)){
                     JSONObject dataJson = JSONObject.parseObject(data);
                     JSONObject actionMsg = dataJson.getJSONObject("actionMsg");
@@ -91,13 +98,16 @@ public class ChatGroupUtils {
                             JSONObject dataObject =  dataJson.getJSONObject("data");
                             if(dataObject.containsKey("data")){
                                 JSONArray dataArray = dataObject.getJSONArray("data");
+
+                                log.error("getChatGroup--dataArray"+dataArray.size());
+
                                 for(int i=0;i<dataArray.size();i++){
                                     JSONObject dataInfo = dataArray.getJSONObject(i);
                                     String userid = dataInfo.getString("userid");
                                     String amount = dataInfo.getString("amount");
+                                    log.error("getChatGroup--userid"+userid+" amount:"+amount);
 
                                     String sql = " select id from "+tablename+" where ry=? and tenant_key=? and delete_type=0 ";
-                                    log.error("getChatGroup--sql"+sql);
 
                                     List<SqlParamEntity> sqlparam = new ArrayList<SqlParamEntity>();
                                     SqlParamEntity sqlParamEntity = new SqlParamEntity();
@@ -125,6 +135,8 @@ public class ChatGroupUtils {
                         }
                     }
                 }
+            }else{
+                dataMap.put("isSuccess","0");
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -142,31 +154,33 @@ public class ChatGroupUtils {
      * @param groupId
      * @param tenant_key
      */
-    public void insertChatGroupDate(String userid,String amount,long employeeId,String sourceType,String groupId,String tenant_key,String tablename){
+    public String insertChatGroupDate(String userid,String amount,long employeeId,String sourceType,String groupId,String tenant_key,String tablename){
 
+        String code = "";
         try {
             long generate = IdGenerator.generate();
+            log.error("insertChatGroupDate-generate:"+generate+" userid:"+userid+" amount"+amount+" employeeId:"+employeeId);
+
             String sql =" insert into "+tablename+"(id,ry,amount,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type)  " +
                         " values(" + generate + "," + userid + ",'"+amount+"'," + generate + ",0,now(),now(),'"+tenant_key+"',0," + employeeId + ",0)";
             log.error("insertChatGroupDate-sql:"+sql);
             Map<String, Object> result = databaseUtils.execute(sourceType, groupId, sql);
-            Iterator<Map.Entry<String, Object>> iterator = result.entrySet().iterator();
-            while (iterator.hasNext()){
-                Map.Entry<String, Object> next = iterator.next();
-                log.error("insertChatGroupDate--key="+next.getKey()+"  value="+String.valueOf(next.getValue()));
-            }
 
-            List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
-            for(int i=0;i<recordList.size();i++){
-                Map<String,Object> map = recordList.get(i);
-                for (String key:map.keySet()){
-                    System.out.println("insertChatGroupDate--key=  "+key+"   and value=  "+String.valueOf(map.get(key)));
-                }
+//            Iterator<Map.Entry<String, Object>> iterator = result.entrySet().iterator();
+//            while (iterator.hasNext()){
+//                Map.Entry<String, Object> next = iterator.next();
+//                log.error("insertChatGroupDate--key="+next.getKey()+"  value="+String.valueOf(next.getValue()));
+//            }
+
+            if(result.containsKey("code")){
+                code = String.valueOf(result.get("code"));
             }
+
         }catch (Exception e){
             e.printStackTrace();
             log.error("insertChatGroupDate:"+e);
         }
+        return code ;
     }
 
     /***
@@ -177,9 +191,12 @@ public class ChatGroupUtils {
      * @param groupId
      * @param tenant_key
      */
-    public void updateChatGroupDate(String userid,String amount,String sourceType,String groupId,String tenant_key,String tablename){
+    public String updateChatGroupDate(String userid,String amount,String sourceType,String groupId,String tenant_key,String tablename){
+
+        String code = "";
         try {
             String sql =" update "+tablename+" set amount=?,update_time=now() where ry = ? and tenant_key= ? and delete_type=0 ";
+            log.error("updateChatGroupDate-sql:"+sql+"  amount:"+amount+" userid:"+userid);
             List<SqlParamEntity> sqlparam = new ArrayList<SqlParamEntity>();
             SqlParamEntity sqlParamEntity = new SqlParamEntity();
             sqlParamEntity.setParamType(SqlParamType.VARCHAR);
@@ -197,23 +214,16 @@ public class ChatGroupUtils {
             sqlparam.add(sqlParamEntity);
 
             Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
-            Iterator<Map.Entry<String, Object>> iterator = result.entrySet().iterator();
-            while (iterator.hasNext()){
-                Map.Entry<String, Object> next = iterator.next();
-                log.error("updateChatGroupDate--key="+next.getKey()+"  value="+String.valueOf(next.getValue()));
-            }
-
-            List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
-            for(int i=0;i<recordList.size();i++){
-                Map<String,Object> map = recordList.get(i);
-                for (String key:map.keySet()){
-                    System.out.println("updateChatGroupDate--key=  "+key+"   and value=  "+String.valueOf(map.get(key)));
-                }
+            if(result.containsKey("code")){
+                code = String.valueOf(result.get("code"));
             }
         }catch (Exception e){
             e.printStackTrace();
             log.error("updateChatGroupDate:"+e);
+            code = "-200";
         }
+
+        return code ;
     }
 
 }