diff --git a/src/main/java/com/weaver/seconddev/jcldoor/controller/HrmSelfHelpController.java b/src/main/java/com/weaver/seconddev/jcldoor/controller/HrmSelfHelpController.java index e1cd822..fd9bcb2 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/controller/HrmSelfHelpController.java +++ b/src/main/java/com/weaver/seconddev/jcldoor/controller/HrmSelfHelpController.java @@ -11,14 +11,13 @@ import com.weaver.framework.remote.client.rest.RestClient; import com.weaver.framework.rpc.annotation.RpcReference; import com.weaver.mc.api.async.AsyncSystemMessageRest; import com.weaver.mc.api.rest.SystemMessageRest; +import com.weaver.seconddev.jcldoor.util.ChatDayUtils; +import com.weaver.seconddev.jcldoor.util.ChatGroupUtils; import com.weaver.seconddev.jcldoor.util.DatabaseUtils; import com.weaver.seconddev.jcldoor.util.JucailinPortalUtils; import com.weaver.teams.blog.domain.RemoteBlogInfoService; import com.weaver.teams.client.doc.remote.DocClientService; import com.weaver.teams.domain.hr.RemoteHrKpiService; -import com.weaver.teams.domain.hr.entity.FlowData; -import com.weaver.teams.domain.hr.entity.FlowDataListReq; -import com.weaver.teams.domain.hr.entity.FlowDataListRes; import com.weaver.teams.domain.user.SimpleEmployee; import com.weaver.teams.security.context.UserContext; import com.weaver.workflow.common.constant.list.api.DateTimeConditionEnum; @@ -74,6 +73,14 @@ public class HrmSelfHelpController { @Autowired private JucailinPortalUtils jucailinPortalUtils; + + @Autowired + private ChatDayUtils chatDayUtils; + + @Autowired + private ChatGroupUtils chatGroupUtils; + + @Autowired private AsyncSystemMessageRest asyncSystemMessageRest; @@ -83,31 +90,90 @@ public class HrmSelfHelpController { public String tenant_key = "t7akvdnf84" ; - @GetMapping("/testSapi13") + @GetMapping("/testSapi12") @WeaPermission(publicPermission = true) - public WeaResult testSapi13(HttpServletRequest request){ + public WeaResult testSapi12(HttpServletRequest request){ Map dataMap = new HashMap(); dataMap.put("test","testSapi13"); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); try { + String pageSize = request.getParameter("pagesize"); + String pageNum = request.getParameter("pagenum"); + SimpleEmployee employee = UserContext.getCurrentUser(); + String startDate = "2001-01-01"; + Calendar cal = Calendar.getInstance(); - int year = cal.get(Calendar.YEAR); - String startDate = "2018-01-01"; - String endDate = "2024-03-28"; + //设置当前时间 + cal.setTime(new Date()); + //同理增加一天的方法： + cal.add(Calendar.DATE, -1); + String endDate = format.format(cal.getTime()); + Long cid = employee.getCid(); + dataMap.put("startDate",startDate); + dataMap.put("endDate",endDate); + dataMap.put("cid",cid); + + dataMap.put("pageSize",pageSize); + dataMap.put("pageNum",pageNum); + + + Map json = new HashMap(); + json.put("cid",cid); + json.put("pageNum",pageNum); + json.put("pageSize",pageSize); + json.put("startDate",startDate); + json.put("endDate",endDate); + + com.weaver.em.msg.api.entity.Request emrequest = new com.weaver.em.msg.api.entity.Request(); + emrequest.setUrl("/user-profile/dailySingleSession"); + emrequest.setParamsMap(json); + emrequest.setAsync(false); + com.weaver.em.msg.api.entity.Response response2 = oaRest.executeIm(emrequest); + String data = response2.getData(); + dataMap.put("datas",data); + } catch (Exception e) { + e.printStackTrace(); + log.error("testSapi13:"+e); + dataMap.put("count","-1"); + } + return WeaResult.success(dataMap); + } + + + @GetMapping("/testSapi13") + @WeaPermission(publicPermission = true) + public WeaResult testSapi13(HttpServletRequest request){ + Map dataMap = new HashMap(); + dataMap.put("test","testSapi13"); + + SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); + try { - log.error("startDate:"+startDate); - log.error("endDate:"+endDate); + String pageSize = request.getParameter("pagesize"); + String pageNum = request.getParameter("pagenum"); + SimpleEmployee employee = UserContext.getCurrentUser(); + + String startDate = "2001-01-01"; + + Calendar cal = Calendar.getInstance(); + //设置当前时间 + cal.setTime(new Date()); + //同理增加一天的方法： + cal.add(Calendar.DATE, -1); + String endDate = format.format(cal.getTime()); Long cid = employee.getCid(); + dataMap.put("startDate",startDate); + dataMap.put("endDate",endDate); + dataMap.put("cid",cid); - log.error("cid:"+cid); + dataMap.put("pageSize",pageSize); + dataMap.put("pageNum",pageNum); - String pageSize = "100"; - String pageNum = "1"; Map json = new HashMap(); json.put("cid",cid); @@ -115,20 +181,13 @@ public class HrmSelfHelpController { json.put("pageSize",pageSize); json.put("startDate",startDate); json.put("endDate",endDate); - log.error("json:"+ JSON.toJSONString(json)); com.weaver.em.msg.api.entity.Request emrequest = new com.weaver.em.msg.api.entity.Request(); emrequest.setUrl("/user-profile/groupSession"); emrequest.setParamsMap(json); emrequest.setAsync(false); - log.error("request:"+ emrequest.toString()); - com.weaver.em.msg.api.entity.Response response2 = oaRest.executeIm(emrequest); - log.error("response2:"+ response2.toString()); - String data = response2.getData(); - log.error("data:"+data); - dataMap.put("datas",data); } catch (Exception e) { e.printStackTrace(); @@ -1315,10 +1374,10 @@ public class HrmSelfHelpController { List> recordList = databaseUtils.getDataSourceList(result); if(!recordList.isEmpty()){ log.error("!recordList.isEmpty()"); - jucailinPortalUtils.updateChatDayDate(userid,amount,sourceType,groupId,tenant_key,tablename); + jucailinPortalUtils.updateChatGroupDate(userid,amount,sourceType,groupId,tenant_key,tablename); }else{ log.error("recordList.isEmpty()"); - jucailinPortalUtils.insertChatDayDate(userid,amount,employeeId,sourceType,groupId,tenant_key,tablename); + jucailinPortalUtils.insertChatGroupDate(userid,amount,employeeId,sourceType,groupId,tenant_key,tablename); } } } @@ -1390,4 +1449,51 @@ public class HrmSelfHelpController { return WeaResult.success(dataMap); } + + @GetMapping("/testSapi115") + @WeaPermission(publicPermission = true) + public WeaResult testSapi115(HttpServletRequest request){ + //com.weaver.workrelate.performance.api.rest.RemotePerformanceService#queryFlowData + Map dataMap = new HashMap(); + dataMap.put("test","testSapi115"); + try { + String tablename = "uf_nj_cyqltjb" ; + dataMap.put("tablename",tablename); + String pagesize = request.getParameter("pagesize"); + String pagenum = request.getParameter("pagenum"); + + Map dMap = chatGroupUtils.getChatGroup(tenant_key,tablename,pagesize,pagenum); + dataMap.putAll(dMap); + } catch (Exception e) { + e.printStackTrace(); + log.error("testSapi14:"+e); + dataMap.put("count","-1"); + } + return WeaResult.success(dataMap); + } + + + @GetMapping("/testSapi116") + @WeaPermission(publicPermission = true) + public WeaResult testSapi116(HttpServletRequest request){ + //com.weaver.workrelate.performance.api.rest.RemotePerformanceService#queryFlowData + Map dataMap = new HashMap(); + dataMap.put("test","testSapi116"); + try { + + String pagesize = request.getParameter("pagesize"); + String pagenum = request.getParameter("pagenum"); + + String tablename = "uf_nj_pjmrdlhhsl" ; + dataMap.put("tablename",tablename); + Map dMap = chatDayUtils.getChatDay(tenant_key,tablename,pagesize,pagenum); + dataMap.putAll(dMap); + } catch (Exception e) { + e.printStackTrace(); + log.error("testSapi14:"+e); + dataMap.put("count","-1"); + } + return WeaResult.success(dataMap); + } + } diff --git a/src/main/java/com/weaver/seconddev/jcldoor/util/ChatDayUtils.java b/src/main/java/com/weaver/seconddev/jcldoor/util/ChatDayUtils.java new file mode 100644 index 0000000..a30f160 --- /dev/null +++ b/src/main/java/com/weaver/seconddev/jcldoor/util/ChatDayUtils.java @@ -0,0 +1,211 @@ +package com.weaver.seconddev.jcldoor.util; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.weaver.common.distribution.genid.IdGenerator; +import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity; +import com.weaver.ebuilder.datasource.api.enums.SqlParamType; +import com.weaver.em.msg.api.entity.Request; +import com.weaver.em.msg.api.entity.Response; +import com.weaver.framework.rpc.annotation.RpcReference; +import com.weaver.teams.domain.user.SimpleEmployee; +import com.weaver.teams.security.context.UserContext; +import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.text.SimpleDateFormat; +import java.util.*; + +@Component +public class ChatDayUtils { + + private final Logger log = LoggerFactory.getLogger(ChatDayUtils.class); + + @RpcReference + private com.weaver.em.msg.api.rest.OaRest oaRest; + + @Autowired + private DatabaseUtils databaseUtils; + + + public Map getChatDay(String tenant_key, String tablename,String pageSize,String pageNum){ + Map dataMap = new HashMap(); + SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); + + String groupId = "weaver-ebuilder-form-service"; + String sourceType = "LOGIC"; + + try { + SimpleEmployee employee = UserContext.getCurrentUser(); + + String startDate = "2001-01-01"; + + Calendar cal = Calendar.getInstance(); + //设置当前时间 + cal.setTime(new Date()); + //同理增加一天的方法： + cal.add(Calendar.DATE, -1); + String endDate = format.format(cal.getTime()); + + log.error("startDate:"+startDate); + log.error("endDate:"+endDate); + Long cid = employee.getCid(); + log.error("getChatGroup--cid:"+cid); + Long employeeId = employee.getEmployeeId(); + + Map json = new HashMap(); + json.put("cid",cid); + json.put("pageNum",pageNum); + json.put("pageSize",pageSize); + json.put("startDate",startDate); + json.put("endDate",endDate); + + log.error("json:"+ JSON.toJSONString(json)); + + Request request = new Request(); + request.setUrl("/user-profile/dailySingleSession"); + request.setParamsMap(json); + request.setAsync(false); + + log.error("request:"+ request.toString()); + Response response = oaRest.executeIm(request); + log.error("getChatGroup--isSuccess"+response.isSuccess()); + if (response.isSuccess()){ + String data = response.getData(); + if(StringUtils.isNotBlank(data)){ + JSONObject dataJson = JSONObject.parseObject(data); + JSONObject actionMsg = dataJson.getJSONObject("actionMsg"); + if(actionMsg.containsKey("code")){ + String code = actionMsg.getString("code"); + if("0".equals(code)){ + JSONObject dataObject = dataJson.getJSONObject("data"); + if(dataObject.containsKey("data")){ + JSONArray dataArray = dataObject.getJSONArray("data"); + for(int i=0;i sqlparam = new ArrayList(); + SqlParamEntity sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(userid+""); + sqlparam.add(sqlParamEntity); + + sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(tenant_key+""); + sqlparam.add(sqlParamEntity); + + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + List> recordList = databaseUtils.getDataSourceList(result); + if(!recordList.isEmpty()){ + updateChatDayDate(userid,amount,sourceType,groupId,tenant_key,tablename); + }else{ + insertChatDayDate(userid,amount,employeeId,sourceType,groupId,tenant_key,tablename); + } + } + } + } + } + } + } + } catch (Exception e) { + e.printStackTrace(); + log.error("testSapi13:"+e); + } + return dataMap; + } + + /*** + * + * @param userid + * @param amount + * @param employeeId + * @param sourceType + * @param groupId + * @param tenant_key + */ + public void insertChatDayDate(String userid,String amount,long employeeId,String sourceType,String groupId,String tenant_key,String tablename){ + + try { + long generate = IdGenerator.generate(); + 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("insertChatDayDate-sql:"+sql); + Map result = databaseUtils.execute(sourceType, groupId, sql); + + Iterator> iterator = result.entrySet().iterator(); + while (iterator.hasNext()){ + Map.Entry next = iterator.next(); + log.error("insertChatDayDate--key="+next.getKey()+" value="+String.valueOf(next.getValue())); + } + + List> recordList = databaseUtils.getDataSourceList(result); + for(int i=0;i 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); + } + } + + /*** + * + * @param userid + * @param amount + * @param sourceType + * @param groupId + * @param tenant_key + */ + public void updateChatDayDate(String userid,String amount,String sourceType,String groupId,String tenant_key,String tablename){ + try { + String sql =" update "+tablename+" set amount=?,update_time=now() where ry = ? and tenant_key= ? and delete_type=0 "; + log.error("insertChatDayDate-sql:"+sql); + + List sqlparam = new ArrayList(); + SqlParamEntity sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(amount+""); + sqlparam.add(sqlParamEntity); + + sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(userid+""); + sqlparam.add(sqlParamEntity); + + sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(tenant_key); + sqlparam.add(sqlParamEntity); + + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + Iterator> iterator = result.entrySet().iterator(); + while (iterator.hasNext()){ + Map.Entry next = iterator.next(); + log.error("insertChatDayDate--key="+next.getKey()+" value="+String.valueOf(next.getValue())); + } + + List> recordList = databaseUtils.getDataSourceList(result); + for(int i=0;i 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); + } + } + +} diff --git a/src/main/java/com/weaver/seconddev/jcldoor/util/ChatGroupUtils.java b/src/main/java/com/weaver/seconddev/jcldoor/util/ChatGroupUtils.java new file mode 100644 index 0000000..99034ea --- /dev/null +++ b/src/main/java/com/weaver/seconddev/jcldoor/util/ChatGroupUtils.java @@ -0,0 +1,219 @@ +package com.weaver.seconddev.jcldoor.util; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.weaver.common.distribution.genid.IdGenerator; +import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity; +import com.weaver.ebuilder.datasource.api.enums.SqlParamType; +import com.weaver.em.msg.api.entity.Request; +import com.weaver.em.msg.api.entity.Response; +import com.weaver.framework.rpc.annotation.RpcReference; +import com.weaver.teams.domain.user.SimpleEmployee; +import com.weaver.teams.security.context.UserContext; +import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import com.weaver.em.msg.api.rest.OaRest; +import org.springframework.stereotype.Component; + +import java.text.SimpleDateFormat; +import java.util.*; + +@Component +public class ChatGroupUtils { + + + private final Logger log = LoggerFactory.getLogger(ChatGroupUtils.class); + + @RpcReference + private OaRest oaRest; + + @Autowired + private DatabaseUtils databaseUtils; + + /*** + * + * + */ + public Map getChatGroup(String tenant_key, String tablename,String pageSize,String pageNum){ + Map dataMap = new HashMap(); + SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); + + String groupId = "weaver-ebuilder-form-service"; + String sourceType = "LOGIC"; + + try { + + String startDate = "2001-01-01"; + //设置当前时间 + + Calendar cal = Calendar.getInstance(); + cal.setTime(new Date()); + //同理增加一天的方法： + cal.add(Calendar.DATE, -1); + String endDate = format.format(cal.getTime()); + + log.error("startDate:"+startDate); + log.error("endDate:"+endDate); + + SimpleEmployee employee = UserContext.getCurrentUser(); + Long cid = employee.getCid(); + long employeeId = employee.getEmployeeId(); + log.error("getChatGroup--cid:"+cid); + + Map json = new HashMap(); + json.put("cid",cid); + json.put("pageNum",pageNum); + json.put("pageSize",pageSize); + json.put("startDate",startDate); + json.put("endDate",endDate); + + log.error("json:"+ JSON.toJSONString(json)); + + Request request = new Request(); + request.setUrl("/user-profile/groupSession"); + request.setParamsMap(json); + request.setAsync(false); + + Response response = oaRest.executeIm(request); + log.error("getChatGroup--isSuccess"+response.isSuccess()); + if(response.isSuccess()){ + String data = response.getData(); + if(StringUtils.isNotBlank(data)){ + JSONObject dataJson = JSONObject.parseObject(data); + JSONObject actionMsg = dataJson.getJSONObject("actionMsg"); + if(actionMsg.containsKey("code")){ + String code = actionMsg.getString("code"); + log.error("getChatGroup--code"+code); + if("0".equals(code)){ + JSONObject dataObject = dataJson.getJSONObject("data"); + if(dataObject.containsKey("data")){ + JSONArray dataArray = dataObject.getJSONArray("data"); + for(int i=0;i sqlparam = new ArrayList(); + SqlParamEntity sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(userid+""); + sqlparam.add(sqlParamEntity); + + sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(tenant_key+""); + sqlparam.add(sqlParamEntity); + + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + List> recordList = databaseUtils.getDataSourceList(result); + if(!recordList.isEmpty()){ + + log.error("getChatGroup--!isEmpty"); + updateChatGroupDate(userid,amount,sourceType,groupId,tenant_key,tablename); + }else{ + log.error("getChatGroup--isEmpty"); + insertChatGroupDate(userid,amount,employeeId,sourceType,groupId,tenant_key,tablename); + } + } + } + } + } + } + } + } catch (Exception e) { + e.printStackTrace(); + log.error("getChatGroup:"+e); + } + return dataMap; + } + + /*** + * + * @param userid + * @param amount + * @param employeeId + * @param sourceType + * @param groupId + * @param tenant_key + */ + public void insertChatGroupDate(String userid,String amount,long employeeId,String sourceType,String groupId,String tenant_key,String tablename){ + + try { + long generate = IdGenerator.generate(); + 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 result = databaseUtils.execute(sourceType, groupId, sql); + Iterator> iterator = result.entrySet().iterator(); + while (iterator.hasNext()){ + Map.Entry next = iterator.next(); + log.error("insertChatGroupDate--key="+next.getKey()+" value="+String.valueOf(next.getValue())); + } + + List> recordList = databaseUtils.getDataSourceList(result); + for(int i=0;i map = recordList.get(i); + for (String key:map.keySet()){ + System.out.println("insertChatGroupDate--key= "+key+" and value= "+String.valueOf(map.get(key))); + } + } + }catch (Exception e){ + e.printStackTrace(); + log.error("insertChatGroupDate:"+e); + } + } + + /*** + * + * @param userid + * @param amount + * @param sourceType + * @param groupId + * @param tenant_key + */ + public void updateChatGroupDate(String userid,String amount,String sourceType,String groupId,String tenant_key,String tablename){ + try { + String sql =" update "+tablename+" set amount=?,update_time=now() where ry = ? and tenant_key= ? and delete_type=0 "; + List sqlparam = new ArrayList(); + SqlParamEntity sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(amount+""); + sqlparam.add(sqlParamEntity); + + sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(userid+""); + sqlparam.add(sqlParamEntity); + + sqlParamEntity = new SqlParamEntity(); + sqlParamEntity.setParamType(SqlParamType.VARCHAR); + sqlParamEntity.setValue(tenant_key); + sqlparam.add(sqlParamEntity); + + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + Iterator> iterator = result.entrySet().iterator(); + while (iterator.hasNext()){ + Map.Entry next = iterator.next(); + log.error("updateChatGroupDate--key="+next.getKey()+" value="+String.valueOf(next.getValue())); + } + + List> recordList = databaseUtils.getDataSourceList(result); + for(int i=0;i map = recordList.get(i); + for (String key:map.keySet()){ + System.out.println("updateChatGroupDate--key= "+key+" and value= "+String.valueOf(map.get(key))); + } + } + }catch (Exception e){ + e.printStackTrace(); + log.error("updateChatGroupDate:"+e); + } + } + +} diff --git a/src/main/java/com/weaver/seconddev/jcldoor/util/JucailinPortalUtils.java b/src/main/java/com/weaver/seconddev/jcldoor/util/JucailinPortalUtils.java index 23d234f..e75c3cd 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/util/JucailinPortalUtils.java +++ b/src/main/java/com/weaver/seconddev/jcldoor/util/JucailinPortalUtils.java @@ -6,7 +6,6 @@ import com.alibaba.fastjson.JSONObject; import com.weaver.common.distribution.genid.IdGenerator; import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity; import com.weaver.ebuilder.datasource.api.enums.SqlParamType; -import com.weaver.ebuilder.form.client.entity.obj.Obj; import com.weaver.em.msg.api.entity.Request; import com.weaver.em.msg.api.entity.Response; import com.weaver.framework.rpc.annotation.RpcReference; @@ -264,18 +263,19 @@ public class JucailinPortalUtils { long generate = IdGenerator.generate(); 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 result = databaseUtils.execute(sourceType, groupId, sql); Iterator> iterator = result.entrySet().iterator(); while (iterator.hasNext()){ Map.Entry next = iterator.next(); - log.error("insertChatDayDate--key="+next.getKey()+" value="+String.valueOf(next.getValue())); + log.error("insertChatGroupDate--key="+next.getKey()+" value="+String.valueOf(next.getValue())); } List> recordList = databaseUtils.getDataSourceList(result); for(int i=0;i map = recordList.get(i); for (String key:map.keySet()){ - System.out.println("insertChatDayDate222--key= "+key+" and value= "+String.valueOf(map.get(key))); + System.out.println("insertChatGroupDate--key= "+key+" and value= "+String.valueOf(map.get(key))); } } }catch (Exception e){