From 94f074a323f2e12d74461b7154ef6bcd70328937 Mon Sep 17 00:00:00 2001 From: shilei <798989044@qq.com> Date: Fri, 12 Apr 2024 15:05:11 +0800 Subject: [PATCH] =?UTF-8?q?#E10-24#=20=E7=BE=A4=E8=81=8A=E6=95=B0=E9=87=8F?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E4=BC=98=E5=8C=96=E5=8F=8A=E8=87=AA=E4=B8=BB?= =?UTF-8?q?=E6=9C=8D=E5=8A=A1=E5=88=9D=E5=A7=8B=E5=8C=96=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../jcldoor/cmd/SelfServiceInfoCmd.java | 263 ++++++++++++++++++ .../controller/HrmSelfHelpController.java | 19 +- .../controller/JucailinPortalController.java | 25 ++ .../service/JucailinPortalService.java | 2 + .../impl/JucailinPortalServiceImpl.java | 6 + .../seconddev/jcldoor/util/ChatDayUtils.java | 61 ++-- .../jcldoor/util/ChatGroupUtils.java | 62 +++-- 7 files changed, 379 insertions(+), 59 deletions(-) diff --git a/src/main/java/com/weaver/seconddev/jcldoor/cmd/SelfServiceInfoCmd.java b/src/main/java/com/weaver/seconddev/jcldoor/cmd/SelfServiceInfoCmd.java index 5d1a17c..c420397 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/cmd/SelfServiceInfoCmd.java +++ b/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 initSelfServiceData(String employeeId){ + + Map recordMap = new HashMap(); + 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 strlist = new ArrayList<>(100); + strlist.add(employeeId); + strlist.add(tenant_key); + List sqlparam = databaseUtils.getSqlParamEntity(strlist); + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + List> 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 paramList = new ArrayList<>(100); + paramList.add(field_id); + paramList.add(tenant_key); + + List sqlparam = databaseUtils.getSqlParamEntity(paramList); + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + List> recordList = databaseUtils.getDataSourceList(result); + for(int i=0;i 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 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 sqlparam = databaseUtils.getSqlParamEntity(paramList); + Map 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 paramList = new ArrayList<>(100); + paramList.add(employeeId); + paramList.add(name); + paramList.add(qy); + List sqlparam = databaseUtils.getSqlParamEntity(paramList); + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + List> recordList = databaseUtils.getDataSourceList(result); + if(!recordList.isEmpty() && recordList.size()>0){ + Map 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 paramList = new ArrayList<>(100); + paramList.add(selectvalue); + paramList.add(tenant_key); + List sqlparam = databaseUtils.getSqlParamEntity(paramList); + Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); + List> recordList = databaseUtils.getDataSourceList(result); + for(int i=0;i 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 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 sqlparam = databaseUtils.getSqlParamEntity(paramlist); + Map 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 ; + } + + } 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 fd9bcb2..9aeb834 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/controller/HrmSelfHelpController.java +++ b/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> 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 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 dMap = chatDayUtils.getChatDay(tenant_key,tablename,pagesize,pagenum); diff --git a/src/main/java/com/weaver/seconddev/jcldoor/controller/JucailinPortalController.java b/src/main/java/com/weaver/seconddev/jcldoor/controller/JucailinPortalController.java index f128a6c..125e396 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/controller/JucailinPortalController.java +++ b/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 initSelfServiceData(HttpServletRequest request){ + log.error("initSelfServiceData"); + Map dataMap = new HashMap(); + + 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); + } diff --git a/src/main/java/com/weaver/seconddev/jcldoor/service/JucailinPortalService.java b/src/main/java/com/weaver/seconddev/jcldoor/service/JucailinPortalService.java index 63cc5c2..6ae07b2 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/service/JucailinPortalService.java +++ b/src/main/java/com/weaver/seconddev/jcldoor/service/JucailinPortalService.java @@ -54,4 +54,6 @@ public interface JucailinPortalService { public Map getUserType(HttpServletRequest request,SimpleEmployee simpleEmployee); + public Map initSelfServiceData(String employeeId); + } diff --git a/src/main/java/com/weaver/seconddev/jcldoor/service/impl/JucailinPortalServiceImpl.java b/src/main/java/com/weaver/seconddev/jcldoor/service/impl/JucailinPortalServiceImpl.java index 75800a4..42c717c 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/service/impl/JucailinPortalServiceImpl.java +++ b/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 initSelfServiceData(String employeeId) { + Map dataMap = selfServiceInfoCmd.initSelfServiceData(employeeId); + return 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 index a30f160..1162312 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/util/ChatDayUtils.java +++ b/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 json = new HashMap(); @@ -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 sqlparam = new ArrayList(); @@ -105,8 +114,10 @@ public class ChatDayUtils { Map result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); List> 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 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))); - } + 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 sqlparam = new ArrayList(); SqlParamEntity sqlParamEntity = new SqlParamEntity(); @@ -189,23 +196,17 @@ public class ChatDayUtils { 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())); + if(result.containsKey("code")){ + code = String.valueOf(result.get("code")); } - 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); + code = "-100"; } + + return code; } } diff --git a/src/main/java/com/weaver/seconddev/jcldoor/util/ChatGroupUtils.java b/src/main/java/com/weaver/seconddev/jcldoor/util/ChatGroupUtils.java index 99034ea..89d7685 100644 --- a/src/main/java/com/weaver/seconddev/jcldoor/util/ChatGroupUtils.java +++ b/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 json = new HashMap(); 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 sqlparam = new ArrayList(); 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 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))); - } +// Iterator> iterator = result.entrySet().iterator(); +// while (iterator.hasNext()){ +// Map.Entry 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 sqlparam = new ArrayList(); SqlParamEntity sqlParamEntity = new SqlParamEntity(); sqlParamEntity.setParamType(SqlParamType.VARCHAR); @@ -197,23 +214,16 @@ public class ChatGroupUtils { 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))); - } + if(result.containsKey("code")){ + code = String.valueOf(result.get("code")); } }catch (Exception e){ e.printStackTrace(); log.error("updateChatGroupDate:"+e); + code = "-200"; } + + return code ; } }