@ -3,12 +3,15 @@ package com.weaver.seconddev.jcldoor.util;
import com.alibaba.fastjson.JSON ; import com.alibaba.fastjson.JSON ;
import com.alibaba.fastjson.JSONArray ; import com.alibaba.fastjson.JSONArray ;
import com.alibaba.fastjson.JSONObject ; import com.alibaba.fastjson.JSONObject ;
import com.weaver.common.distribution.genid.IdGenerator ; //import com.weaver.common.distribution.genid.IdGenerator;
import com.weaver.ebuilder.form.client.entity.data.EBDataReqDetailDto ;
import com.weaver.ebuilder.form.client.entity.data.EBDataReqDto ;
import com.weaver.em.msg.api.entity.Request ; import com.weaver.em.msg.api.entity.Request ;
import com.weaver.em.msg.api.entity.Response ; import com.weaver.em.msg.api.entity.Response ;
import com.weaver.framework.rpc.annotation.RpcReference ; import com.weaver.framework.rpc.annotation.RpcReference ;
import com.weaver.teams.domain.user.SimpleEmployee ; import com.weaver.teams.domain.user.SimpleEmployee ;
import com.weaver.teams.security.context.UserContext ; import com.weaver.teams.security.context.UserContext ;
import org.apache.commons.compress.utils.Lists ;
import org.apache.commons.lang3.StringUtils ; import org.apache.commons.lang3.StringUtils ;
import org.slf4j.Logger ; import org.slf4j.Logger ;
import org.slf4j.LoggerFactory ; import org.slf4j.LoggerFactory ;
@ -40,6 +43,11 @@ public class ChatDayUtils {
String sourceType = "LOGIC" ;
String sourceType = "LOGIC" ;
try {
try {
String field_ry = "985461236726857729" ;
String field_amount = "985461236726857730" ;
String objId = "985461167965437954" ;
SimpleEmployee employee = UserContext . getCurrentUser ( ) ;
SimpleEmployee employee = UserContext . getCurrentUser ( ) ;
String startDate = "2001-01-01" ;
String startDate = "2001-01-01" ;
@ -92,6 +100,8 @@ public class ChatDayUtils {
JSONArray dataArray = dataObject . getJSONArray ( "data" ) ;
JSONArray dataArray = dataObject . getJSONArray ( "data" ) ;
log . error ( "getChatDay--dataArray" + dataArray . size ( ) ) ;
log . error ( "getChatDay--dataArray" + dataArray . size ( ) ) ;
List < EBDataReqDto > insertEbDataReqDtoList = Lists . newArrayList ( ) ;
List < EBDataReqDto > updateEbDataReqDtoList = Lists . newArrayList ( ) ;
for ( int i = 0 ; i < dataArray . size ( ) ; i + + ) {
for ( int i = 0 ; i < dataArray . size ( ) ; i + + ) {
JSONObject dataInfo = dataArray . getJSONObject ( i ) ;
JSONObject dataInfo = dataArray . getJSONObject ( i ) ;
@ -100,27 +110,44 @@ public class ChatDayUtils {
log . error ( "getChatDay--userid" + userid + " amount:" + amount ) ;
log . error ( "getChatDay--userid" + userid + " amount:" + amount ) ;
String sql = " select id from " + tablename + " where ry='" + userid + "' and tenant_key='" + tenant_key + "' and delete_type=0 " ;
String sql = " select id from " + tablename + " where ry='" + userid + "' and tenant_key='" + tenant_key + "' and delete_type=0 " ;
// List<SqlParamEntity> sqlparam = new ArrayList<SqlParamEntity>();
// 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<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
//
Map < String , Object > result = databaseUtils . execute ( sourceType , groupId , sql ) ;
Map < String , Object > result = databaseUtils . execute ( sourceType , groupId , sql ) ;
List < Map < String , Object > > recordList = databaseUtils . getDataSourceList ( result ) ;
List < Map < String , Object > > recordList = databaseUtils . getDataSourceList ( result ) ;
if ( ! recordList . isEmpty ( ) ) {
if ( ! recordList . isEmpty ( ) ) {
log . error ( "getChatDay--!isEmpty" ) ;
log . error ( "getChatDay--!isEmpty" ) ;
updateChatDayDate ( userid , amount , sourceType , groupId , tenant_key , tablename , employeeId ) ;
String id = String . valueOf ( recordList . get ( 0 ) . get ( "id" ) ) ;
log . error ( "id:" + id ) ;
EBDataReqDto ebDataReqDto = new EBDataReqDto ( ) ;
List < EBDataReqDetailDto > mainData = Lists . newArrayList ( ) ;
// 设置更新id
mainData . add ( new EBDataReqDetailDto ( "id" , id ) ) ;
mainData . add ( new EBDataReqDetailDto ( field_amount , amount ) ) ;
ebDataReqDto . setMainDatas ( mainData ) ;
updateEbDataReqDtoList . add ( ebDataReqDto ) ;
} else {
} else {
log . error ( "getChatDay--isEmpty" ) ;
log . error ( "getChatDay--isEmpty" ) ;
insertChatDayDate ( userid , amount , employeeId , sourceType , groupId , tenant_key , tablename ) ;
EBDataReqDto ebDataReqDto = new EBDataReqDto ( ) ;
List < EBDataReqDetailDto > mainData = Lists . newArrayList ( ) ;
mainData . add ( new EBDataReqDetailDto ( field_ry , userid ) ) ;
mainData . add ( new EBDataReqDetailDto ( field_amount , amount ) ) ;
ebDataReqDto . setMainDatas ( mainData ) ;
insertEbDataReqDtoList . add ( ebDataReqDto ) ;
}
}
}
}
log . error ( "getChatDay-insertEbDataReqDtoList:" + insertEbDataReqDtoList . size ( ) ) ;
if ( insertEbDataReqDtoList ! = null & & insertEbDataReqDtoList . size ( ) > 0 ) {
jucailinPortalUtils . saveModeData ( objId , employeeId + "" , tenant_key , insertEbDataReqDtoList ) ;
}
log . error ( "getChatDay-updateEbDataReqDtoList:" + updateEbDataReqDtoList . size ( ) ) ;
if ( updateEbDataReqDtoList ! = null & & updateEbDataReqDtoList . size ( ) > 0 ) {
jucailinPortalUtils . updateModeDataById ( objId , employeeId + "" , tenant_key , updateEbDataReqDtoList , false ) ;
}
}
}
}
}
}
}
@ -144,105 +171,105 @@ public class ChatDayUtils {
* @param groupId
* @param groupId
* @param tenant_key
* @param tenant_key
* /
* /
public void insertChatDayDate ( String userid , String amount , long employeeId , String sourceType , String groupId , String tenant_key , String tablename ) {
// public void insertChatDayDate(String userid,String amount,long employeeId,String sourceType,String groupId,String tenant_key,String tablename){
String code = "" ;
// String code = "";
SimpleDateFormat sdf = new SimpleDateFormat ( "yyyy-MM-dd HH:mm:ss" ) ;
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
try {
// try {
long generate = IdGenerator . generate ( ) ;
// long generate = IdGenerator.generate();
log . error ( "insertChatDayDate-generate:" + generate + " userid:" + userid + " amount" + amount + " employeeId:" + employeeId ) ;
// log.error("insertChatDayDate-generate:"+generate+" userid:"+userid+" amount"+amount+" employeeId:"+employeeId);
SimpleEmployee user = jucailinPortalUtils . getSimpleEmployee ( Long . parseLong ( userid ) ) ;
String username = user . getUsername ( ) ;
String name = user . getName ( ) ;
log . error ( "username:" + username ) ;
log . error ( "name:" + name ) ;
String modename = "平均每日单聊会话数量-" + username + " " + sdf . format ( new Date ( ) ) ;
String sql = " insert into " + tablename + "(id,ry,amount,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type,updater,name,is_flow,data_status) " +
" values (" + generate + "," + userid + ",'" + amount + "'," + generate + ",0,now(),now(),'" + tenant_key + "',0," + employeeId + ",0," + employeeId + ",'" + modename + "',0,1)" ;
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 ( "insertCustomServiceData--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 ( "insertChatDayDate:" + e ) ;
code = "-100" ;
}
log . error ( "insertChatDayDate-code:" + code ) ;
}
/ * * *
*
* @param userid
* @param amount
* @param sourceType
* @param groupId
* @param tenant_key
* /
public String updateChatDayDate ( String userid , String amount , String sourceType , String groupId , String tenant_key , String tablename , long employeeId ) {
String code = "" ;
SimpleDateFormat sdf = new SimpleDateFormat ( "yyyy-MM-dd HH:mm:ss" ) ;
try {
// String sql =" update "+tablename+" set amount=?,update_time=now() where ry = ? and tenant_key= ? and delete_type=0 ";
// log.error("insertChatDayDate-sql:"+sql + " amount:"+amount+" userid:"+userid);
// List<SqlParamEntity> sqlparam = new ArrayList<SqlParamEntity>();
// SqlParamEntity sqlParamEntity = new SqlParamEntity();
// sqlParamEntity.setParamType(SqlParamType.VARCHAR);
// sqlParamEntity.setValue(amount+"");
// sqlparam.add(sqlParamEntity);
//
//
// sqlParamEntity = new SqlParamEntity();
// SimpleEmployee user = jucailinPortalUtils.getSimpleEmployee(Long.parseLong(userid));
// sqlParamEntity.setParamType(SqlParamType.VARCHAR);
// String username = user.getUsername();
// sqlParamEntity.setValue(userid+"");
// String name = user.getName();
// sqlparam.add(sqlParamEntity);
// log.error("username:"+username);
// log.error("name:"+name);
//
//
// sqlParamEntity = new SqlParamEntity();
// String modename = "平均每日单聊会话数量-"+username+" "+sdf.format(new Date());
// sqlParamEntity.setParamType(SqlParamType.VARCHAR);
//
// sqlParamEntity.setValue(tenant_key);
// String sql =" insert into "+tablename+"(id,ry,amount,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type,updater,name,is_flow,data_status) " +
// sqlparam.add(sqlParamEntity);
// " values (" + generate + "," + userid + ",'"+amount+"'," + generate + ",0,now(),now(),'"+tenant_key+"',0," + employeeId + ",0,"+employeeId+",'"+modename+"',0,1)";
// Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
//
// log.error("insertChatDayDate-sql:"+sql);
SimpleEmployee user = jucailinPortalUtils . getSimpleEmployee ( Long . parseLong ( userid ) ) ;
// Map<String, Object> result = databaseUtils.execute(sourceType, groupId, sql);
String username = user . getUsername ( ) ;
//
String name = user . getName ( ) ;
// Iterator<Map.Entry<String, Object>> iterator = result.entrySet().iterator();
log . error ( "username:" + username ) ;
// while (iterator.hasNext()){
log . error ( "name:" + name ) ;
// Map.Entry<String, Object> next = iterator.next();
// log.error("insertCustomServiceData--key="+next.getKey()+" value="+String.valueOf(next.getValue()));
String modename = "平均每日单聊会话数量-" + username + " " + sdf . format ( new Date ( ) ) ;
// }
//
String sql = " update " + tablename + " set amount='" + amount + "',updater=" + employeeId + ",update_time=now(),is_flow=0,data_status=1,modename='" + modename + "' where ry = " + userid + " and tenant_key= '" + tenant_key + "' and delete_type=0 " ;
// if(result.containsKey("code")){
log . error ( "insertChatDayDate-sql:" + sql ) ;
// code = String.valueOf(result.get("code"));
// }
//
Map < String , Object > result = databaseUtils . execute ( sourceType , groupId , sql ) ;
// }catch (Exception e){
Iterator < Map . Entry < String , Object > > iterator = result . entrySet ( ) . iterator ( ) ;
// e.printStackTrace();
while ( iterator . hasNext ( ) ) {
// log.error("insertChatDayDate:"+e);
Map . Entry < String , Object > next = iterator . next ( ) ;
// code = "-100";
log . error ( "updateChatDayDate--key=" + next . getKey ( ) + " value=" + String . valueOf ( next . getValue ( ) ) ) ;
// }
}
// log.error("insertChatDayDate-code:"+code);
// }
if ( result . containsKey ( "code" ) ) {
//
code = String . valueOf ( result . get ( "code" ) ) ;
// /***
}
// *
} catch ( Exception e ) {
// * @param userid
e . printStackTrace ( ) ;
// * @param amount
log . error ( "insertChatDayDate:" + e ) ;
// * @param sourceType
code = "-100" ;
// * @param groupId
}
// * @param tenant_key
return code ;
// */
}
// public String updateChatDayDate(String userid,String amount,String sourceType,String groupId,String tenant_key,String tablename,long employeeId){
// String code = "" ;
//
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
// try {
//// String sql =" update "+tablename+" set amount=?,update_time=now() where ry = ? and tenant_key= ? and delete_type=0 ";
//// log.error("insertChatDayDate-sql:"+sql + " amount:"+amount+" userid:"+userid);
//// List<SqlParamEntity> sqlparam = new ArrayList<SqlParamEntity>();
//// 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<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
//
// SimpleEmployee user = jucailinPortalUtils.getSimpleEmployee(Long.parseLong(userid));
// String username = user.getUsername();
// String name = user.getName();
// log.error("username:"+username);
// log.error("name:"+name);
//
// String modename = "平均每日单聊会话数量-"+username+" "+sdf.format(new Date());
//
// String sql =" update "+tablename+" set amount='"+amount+"',updater="+employeeId+",update_time=now(),is_flow=0,data_status=1,modename='"+modename+"' where ry = "+userid+" and tenant_key= '"+tenant_key+"' and delete_type=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("updateChatDayDate--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("insertChatDayDate:"+e);
// code = "-100";
// }
// return code;
// }
} }
