shilei
/
haojing
1
1
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

#EC_HJ2# 去掉测试开发的代码及使用配置文件替换代码固定的地址

Browse Source
dev
shilei 3 years ago
parent cb51b24c3d
commit 32b9414a31
24 changed files with 79 additions and 2267 deletions
Show Stats Download Patch File Download Diff File

23
WEB-INF/prop/PORTAL_INFO.properties
Unescape Escape View File

@ -0,0 +1,23 @@
##门户地址
portal_host = http://172.16.25.133
##门户人员认证接口
portal_user_auth = http://172.16.25.133/portal-web/user/current
##门户首页
portal_homepage = http://172.16.25.133/portal-web/#
##RocketMq的consumerGroup
consumerGroup = cbec-consumer-group_nj_133
##RocketMq的namesrvAddr
namesrvAddr = 172.16.84.183:9001;172.16.84.187:9001
##RocketMq的instanceName
instanceName = dataSync_topic_nj
##RocketMq的topic
topic = dataSync_topic_nj
##RocketMq的subExpression
subExpression = BPM

11
src/com/api/bpm/todo/WorkflowTodoActionApi.java
Unescape Escape View File

@ -1,11 +0,0 @@
package com.api.bpm.todo;
import com.engine.bpm.todo.web.WorkflowTodoAction;
import javax.ws.rs.Path;
@Path("/workflow")
public class WorkflowTodoActionApi extends WorkflowTodoAction {
}

10
src/com/api/mq/RocketMqActionApi.java
Unescape Escape View File

@ -1,10 +0,0 @@
package com.api.mq;
import com.engine.mq.RocketMqAction;
import javax.ws.rs.Path;
@Path("/kxn/spa")
public class RocketMqActionApi extends RocketMqAction {
}

82
src/com/api/mq/init/RocketmqInit.java
Unescape Escape View File

@ -1,82 +0,0 @@
package com.api.mq.init;
import com.api.mq.util.RocketmqUtil;
import com.sun.jersey.api.model.AbstractResourceModelContext;
import com.sun.jersey.api.model.AbstractResourceModelListener;
import com.sun.jersey.core.util.Priority;
//import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
//import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
//import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
//import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
//import org.apache.rocketmq.client.exception.MQClientException;
//import org.apache.rocketmq.common.message.MessageExt;
import weaver.general.BaseBean;
import javax.ws.rs.ext.Provider;
import java.io.*;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
@Provider
@Priority(100)
public class RocketmqInit implements AbstractResourceModelListener{
@Override
public void onLoaded(AbstractResourceModelContext abstractResourceModelContext) {
BaseBean bb = new BaseBean();
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
bb.writeLog("initiated---进入时间："+sdf.format(new Date()));
bb.writeLog("##### resource model initiated");
bb.writeLog("##### resource model initiated");
bb.writeLog("##### resource model initiated");
RocketmqUtil rocketmqUtil = new RocketmqUtil();
// try{
//
// DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("portal-producer-group_nj");
// consumer.setNamesrvAddr("172.16.84.183:9001;172.16.84.187:9001");
// consumer.setInstanceName("dataSync_topic_nj");
//// consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
// consumer.subscribe("dataSync_topic_nj", "*");
// consumer.registerMessageListener(new MessageListenerConcurrently() {
// @Override
// public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
// MessageExt msg = msgs.get(0);
// try {
// bb.writeLog("3----"+new String(msg.getBody()));
// String msgdata = new String(msg.getBody(),"UTF-8");
// if(!"".equals(msgdata))
// {
// String data = msgdata.substring(msgdata.indexOf("{"));
// int errcount = rocketmqUtil.updateOrgData(data);
// if(errcount >0){
// return ConsumeConcurrentlyStatus.RECONSUME_LATER;
// }
// }
// } catch (UnsupportedEncodingException e) {
// e.printStackTrace();
// bb.writeLog("UnsupportedEncodingException---e:"+e);
// return ConsumeConcurrentlyStatus.RECONSUME_LATER;
// }
// return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
// }
// });
//
// /**
// * Consumer对象在使用之前必须要调用start初始化，初始化一次即可<br>
// */
// consumer.start();
// bb.writeLog("Consumer Started.");
//
// }catch (MQClientException e){
// bb.writeLog("##### resource model initiated--MQClientException:"+e);
// }
bb.writeLog("##### resource model initiated");
bb.writeLog("##### resource model initiated");
bb.writeLog("##### resource model initiated");
}
}

494
src/com/api/mq/util/RocketmqUtil.java
Unescape Escape View File

@ -1,494 +0,0 @@
package com.api.mq.util;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.codec.digest.DigestUtils;
import weaver.conn.RecordSet;
import weaver.general.BaseBean;
import weaver.general.TimeUtil;
import weaver.general.Util;
import weaver.hrm.company.DepartmentComInfo;
import weaver.hrm.resource.ResourceComInfo;
public class RocketmqUtil {
public int updateOrgData(String data)
{
BaseBean bb = new BaseBean();
int errcount = 0;
JSONObject jsonObject = JSONObject.parseObject(data);
if(jsonObject.containsKey("requestObject"))
{
JSONArray requestArray = jsonObject.getJSONArray("requestObject");
for(int i=0;i<requestArray.size();i++)
{
JSONObject requestObject = requestArray.getJSONObject(i);
System.out.println(requestObject.toJSONString());
if(!requestObject.isEmpty()){
if(requestObject.containsKey("tableName") && requestObject.containsKey("content"))
{
String tableName = requestObject.getString("tableName");
bb.writeLog("tableName:"+tableName);
if("organization".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
int errcount1 = updasteSysOrgData(jsonArray);
errcount += errcount1;
}else if("system_user".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
int errcount2 = updateSysUserData(jsonArray);
errcount += errcount2;
}else if("system_role".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updasteSysRoleData(jsonArray);
}else if("system_post".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updasteSysPostData(jsonArray);
}else if("system_user_role".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updateSystemUserRoleData(jsonArray);
}else if("system_user_post".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updateSystemUserPostData(jsonArray);
}
}
}
}
}
bb.writeLog("errcount:"+errcount);
return errcount;
}
/***
*
* @param jsonArray
*/
public int updateSysUserData(JSONArray jsonArray){
RecordSet rs = new RecordSet();
BaseBean bb = new BaseBean();
//{"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},
// "svcCode":"70300100030001","requestObject":[{"content":[
// {"statusDate":"2022-07-18 11:25:41","updateDate":"2022-07-22 10:52:56",
// "regionNbr":"1","expDate":"2999-12-31 23:59:59","userOrgId":"2",
// "password":"{bcrypt}$2a$10$wQrGr6zHlqaKbAZGaK7PC.VdmZdq4HJn6t7R4XpGsf/yKqPj6smHq",
// "effDate":"2021-07-13 10:33:57","orgCode":"2",
// "staffName":"zhouhan","pwdNewtime":"2022-05-18 14:42:15",
// "pwdContinErrCnt":"0","actType":"M","sysUserId":"14002","email":"2112@qq.com",
// "createDate":"2021-07-13 10:33:58","staffCode":"zhouhan",
// "sysUserCode":"zhouhan","pwdErrCnt":"0","pwdEffectDays":"90","statusCd":"1000",
// "systemInfoId":"-1","userName":"zhouhan","createStaff":"1","pwdStatus":"1100",
// "regionId":"731","pwdSmsTel":"21423523523","loginedNum":"78","staffId":"12002",
// "updateStaff":"1"}],"tableName":"system_user","primaryKey":"sysUserId"}],"key":"svcCont"}
int errcount = 0;
for(int i=0;i<jsonArray.size();i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String statusDate = Util.null2String(jsonObject.get("statusDate"));
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String regionNbr = Util.null2String(jsonObject.get("regionNbr"));
String userOrgId = Util.null2String(jsonObject.get("userOrgId"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String staffId = Util.null2String(jsonObject.get("staffId"));
String staffName = Util.null2String(jsonObject.get("staffName"));
String staffCode = Util.null2String(jsonObject.get("staffCode"));
String actType = Util.null2String(jsonObject.get("actType"));
String email = Util.null2String(jsonObject.get("email"));
String sysUserId = Util.null2String(jsonObject.get("sysUserId"));
String sysUserCode = Util.null2String(jsonObject.get("sysUserCode"));
String userName = Util.null2String(jsonObject.get("userName"));
String pwdSmsTel = Util.null2String(jsonObject.get("pwdSmsTel"));
String loginedNum = Util.null2String(jsonObject.get("sysUserId"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String status = "1";
if("1100".equals(statusCd) || "1200".equals(statusCd) || "1300".equals(statusCd)){
status = "5";
}
bb.writeLog("status:"+status);
bb.writeLog("statusCd:"+statusCd);
String subcompanyid1 = "" ;
String deptId = "";
if(!"".equals(orgCode)){
String sql = " select id,subcompanyid1 from hrmdepartment where departmentcode = ?" ;
rs.executeQuery(sql,new Object[]{orgCode});
if(rs.next()){
deptId = Util.null2String(rs.getString("id"));
subcompanyid1 = Util.null2String(rs.getString("subcompanyid1"));
}
}
bb.writeLog("deptId:"+deptId);
bb.writeLog("subcompanyid1:"+subcompanyid1);
String locationid = "2" ;
String seclevel = "20" ;
String createrid = "1" ;
String lastmodid = "1" ;
String creator = "1";
String jobTitleId = "40";
String systemlanguage = "7" ;
String currentDate = TimeUtil.getCurrentDateString();//当前日期
String currentDateTime = TimeUtil.getCurrentTimeString(); //当前时间
bb.writeLog("status:"+status);
bb.writeLog("currentDate:"+currentDate);
String lastname = " ~`~`7 "+staffName+"`~`8 "+staffName+"`~`~";
String loginid = "";
String sql = " select loginid from hrmresource where workcode=?" ;
bb.writeLog("sql:"+sql);
bb.writeLog("staffCode:"+staffCode);
rs.executeQuery(sql,new Object[]{staffCode});
if(rs.next()){
loginid = Util.null2String(rs.getString("loginid"));
}
bb.writeLog("loginid:"+loginid);
if(!"".equals(deptId))
{
if(!"".equals(loginid))
{
if("M".equalsIgnoreCase(actType))
{
String userUpdateSql = " update hrmresource set lastname=?,departmentid=?,subcompanyid1=?," +
" creater=?,email=?,mobile=?,jobtitle=?,status=?,dsporder=?,lastmoddate=?,modified=? where workcode=? ";
bb.writeLog("userUpdateSql:"+userUpdateSql);
boolean flag = rs.executeUpdate(userUpdateSql,new Object[]{staffName,deptId,subcompanyid1,creator,email,
pwdSmsTel,jobTitleId,status,loginedNum,currentDate,currentDateTime,staffCode});
bb.writeLog("flag:"+flag);
if(!flag){
errcount++;
}
}
}else{
if("A".equalsIgnoreCase(actType))
{
// int tmpid = 0;
// rs.executeSql("select max(id) from HrmResourceVirtual ");
// if(rs.next()){
// tmpid = rs.getInt(1)+1;
// }
String pwd = "1";
String password = DigestUtils.md5Hex(pwd).toUpperCase(); //MD5加密
bb.writeLog("password:"+password);
rs.executeProc("HrmResourceMaxId_Get", "");
rs.next();
String id = "" + rs.getInt(1);
bb.writeLog("id:"+id);
if(!"".equals(id)){
String userInsertSql = " insert into hrmresource(id,loginid,password,workcode,lastname,departmentid,subcompanyid1," +
"creater,email,mobile,jobtitle,status,dsporder,systemlanguage,createdate,lastmoddate,created,modified," +
"locationid,seclevel,createrid,lastmodid) " +
" values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
bb.writeLog("userInsertSql:"+userInsertSql);
boolean flag = rs.executeUpdate(userInsertSql,new Object[]{id,staffCode,password,staffCode,lastname,deptId,subcompanyid1,
creator,email,pwdSmsTel,jobTitleId,status,loginedNum,systemlanguage,currentDate,currentDate,currentDateTime,currentDateTime,
locationid,seclevel,createrid,lastmodid});
bb.writeLog("flag:"+flag);
if(!flag){
errcount++;
}
}
}
}
}
}
return errcount;
}
public int updasteSysOrgData(JSONArray jsonArray){
RecordSet rs = new RecordSet();
BaseBean bb = new BaseBean();
int errcount = 0;
// {"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},"svcCode":
// "70300100030001","requestObject":[{"content":[{
// "updateDate":"2022-07-22 11:05:22","orgName":"testOrg722","parentOrgCode":"LNP000001",
// "regionNbr":"TST_PR_CSS","orgLevel":"2","statusCd":"1000",
// "parentOrgName":"Vivia","orgId":"17012",
// "createStaff":"1","orgType":"1000",
// "regionId":"36","parentOrgId":"1",
// "orgCode":"testOrg722",
// "pathCode":"-1.1.17012","actType":"A","partyId":"0",
// "parRegionNbr":"1",
// "createDate":"2022-07-22 11:05:22"
// }],"tableName":"organization","primaryKey":"orgId"}],"key":"svcCont"}
for(int i=0;i<jsonArray.size();i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String orgName = Util.null2String(jsonObject.get("orgName"));
String parentOrgCode = Util.null2String(jsonObject.get("parentOrgCode"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String parentOrgName = Util.null2String(jsonObject.get("parentOrgName"));
String orgId = Util.null2String(jsonObject.get("orgId"));
String orgType = Util.null2String(jsonObject.get("orgType"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String actType = Util.null2String(jsonObject.get("actType"));
String canceled = "";
if("1100".equals(statusCd)){
canceled = "1";
}
bb.writeLog("canceled:"+canceled);
String supdepid = "0";
String subcompanyid1 = "" ;
if(!"".equals(parentOrgCode))
{
rs.executeQuery(" select id from hrmsubcompany where subcompanycode=? ",new Object[]{parentOrgCode});
if(rs.next()){
subcompanyid1 = Util.null2String(rs.getString("id"));
}
if("".equals(subcompanyid1)){
String sql = " select id,subcompanyid1 from hrmdepartment where departmentcode = ?" ;
rs.executeQuery(sql,new Object[]{parentOrgCode});
if(rs.next()){
supdepid = Util.null2String(rs.getString("id"));
subcompanyid1 = Util.null2String(rs.getString("subcompanyid1"));
}
}
}
bb.writeLog("actType:"+actType);
bb.writeLog("supdepid:"+supdepid);
bb.writeLog("subcompanyid1:"+subcompanyid1);
if(!"".equals(subcompanyid1)){
String deptid = "" ;
String sql = " select id from hrmdepartment where departmentcode=?" ;
rs.executeQuery(sql,new Object[]{orgCode});
if(rs.next()){
deptid = Util.null2String(rs.getString("id"));
}
bb.writeLog("deptid:"+deptid);
if(!"".equals(deptid))
{
if("M".equalsIgnoreCase(actType))
{
String deptUpdateSql = " update hrmdepartment set departmentmark=?,departmentname=?,canceled=?," +
" subcompanyid1=?,showorder=?, supdepid=? where departmentcode=? ";
bb.writeLog("deptUpdateSql:"+deptUpdateSql);
boolean flag = rs.executeUpdate(deptUpdateSql,new Object[]{orgName,orgName,canceled,subcompanyid1,orgId,supdepid,orgCode});
bb.writeLog("flag:"+flag);
if(!flag){
errcount++;
}
}
}else{
if("A".equalsIgnoreCase(actType))
{
String deptInsertSql = " insert into hrmdepartment(departmentmark,departmentname,departmentcode," +
" canceled,subcompanyid1,supdepid,showorder) values(?,?,?,?,?,?,?) ";
bb.writeLog("deptInsertSql:"+deptInsertSql);
boolean flag = rs.executeUpdate(deptInsertSql,new Object[]{orgName,orgName,orgCode,canceled,subcompanyid1,supdepid,orgId});
bb.writeLog("flag:"+flag);
if(!flag){
errcount++;
}
}
}
}
}
return errcount;
}
// {"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},"svcCode":
// "70300100030001","requestObject":[{"content":[{"sysUserRoleId":"23444","updateDate":"2022-07-22 11:08:33",
// "systemInfoCode":"TYMH","sysRoleId":"17013","statusCd":"1000",
// "systemInfoId":"727001","operType":"1000",
// "systemUserCode":"finaceManager",
// "expDate":"2120-01-01 00:00:00","orgId":"17012",
// "createStaff":"1","effDate":"2022-07-21 10:17:51",
// "systemUserName":"financeManager",
// "orgCode":"testOrg722","roleCode":"orgManager","manageClass":"1000","roleName":"orgManager",
// "actType":"A","sysUserId":"20047","createDate":"2022-07-22 11:08:33"}],
// "tableName":"system_user_role","primaryKey":"sysUserRoleId"}],"key":"svcCont"}
/***
*
* @param jsonArray
*/
public static void updateSystemUserRoleData(JSONArray jsonArray) {
RecordSet rs = new RecordSet();
for (int i = 0; i < jsonArray.size(); i++) {
JSONObject jsonObject = jsonArray.getJSONObject(i);
String sysUserRoleId = Util.null2String(jsonObject.get("sysUserRoleId"));
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String systemInfoCode = Util.null2String(jsonObject.get("systemInfoCode"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String systemUserCode = Util.null2String(jsonObject.get("systemUserCode"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String roleCode = Util.null2String(jsonObject.get("roleCode"));
String manageClass = Util.null2String(jsonObject.get("manageClass"));
String actType = Util.null2String(jsonObject.get("actType"));
String createDate = Util.null2String(jsonObject.get("createDate"));
if(!"".equals(systemUserCode)){
String loginid = "";
String sql = " select loginid from hrmrole where workcode=?" ;
rs.executeQuery(sql,new Object[]{systemUserCode});
if(rs.next()){
loginid = Util.null2String(rs.getString("loginid"));
}
sql = " select loginid from hrmresource where workcode=?" ;
rs.executeQuery(sql,new Object[]{systemUserCode});
if(rs.next()){
loginid = Util.null2String(rs.getString("loginid"));
}
if(!"".equals(loginid)){
}
}
}
}
/***
*
* @param jsonArray
*/
public static void updateSystemUserPostData(JSONArray jsonArray) {
RecordSet rs = new RecordSet();
//{"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},
// "svcCode":"70300100030001","requestObject":[{"content":
// [{"updateDate":"2022-07-22 10:51:29","staffCode":"0009000380","orgName":"merchantLF",
// "sysPostId":"0","statusCd":"1000","relType":"1100",
// "systemUserCode":"0009000380","orgId":"9000331",
// "createStaff":"9000377",
// "sysUserPostId":"122952","orgType":"2400",
// "systemUserName":"liaofei",
// "orgCode":"GAM9000331","staffName":"liaofei","actType":"A","sysUserId":"20051",
// "staffId":9000380,"createDate":"2022-07-22 10:51:29"}],"tableName":"system_user_post","primaryKey":"sysUserPostId"}],"key":"svcCont"}
for (int i = 0; i < jsonArray.size(); i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String staffCode = Util.null2String(jsonObject.get("staffCode"));
String orgName = Util.null2String(jsonObject.get("orgName"));
String sysPostId = Util.null2String(jsonObject.get("sysPostId"));
String relType = Util.null2String(jsonObject.get("relType"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String systemUserCode = Util.null2String(jsonObject.get("systemUserCode"));
String orgType = Util.null2String(jsonObject.get("orgType"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String staffName = Util.null2String(jsonObject.get("staffName"));
String actType = Util.null2String(jsonObject.get("actType"));
String sysUserId = Util.null2String(jsonObject.get("sysUserId"));
}
}
/***
*
* @param jsonArray
*/
public static void updasteSysRoleData(JSONArray jsonArray) {
RecordSet rs = new RecordSet();
//{"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},
// "svcCode":"70300100030001","requestObject":[{"content":
// [{"updateDate":"2022-07-22 10:51:29","staffCode":"0009000380","orgName":"merchantLF",
// "sysPostId":"0","statusCd":"1000","relType":"1100",
// "systemUserCode":"0009000380","orgId":"9000331",
// "createStaff":"9000377",
// "sysUserPostId":"122952","orgType":"2400",
// "systemUserName":"liaofei",
// "orgCode":"GAM9000331","staffName":"liaofei","actType":"A","sysUserId":"20051",
// "staffId":9000380,"createDate":"2022-07-22 10:51:29"}],"tableName":"system_user_post","primaryKey":"sysUserPostId"}],"key":"svcCont"}
for (int i = 0; i < jsonArray.size(); i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String staffCode = Util.null2String(jsonObject.get("staffCode"));
String orgName = Util.null2String(jsonObject.get("orgName"));
String sysPostId = Util.null2String(jsonObject.get("sysPostId"));
String relType = Util.null2String(jsonObject.get("relType"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String systemUserCode = Util.null2String(jsonObject.get("systemUserCode"));
String orgType = Util.null2String(jsonObject.get("orgType"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String staffName = Util.null2String(jsonObject.get("staffName"));
String actType = Util.null2String(jsonObject.get("actType"));
String sysUserId = Util.null2String(jsonObject.get("sysUserId"));
}
}
/***
*
* @param jsonArray
*/
public static void updasteSysPostData(JSONArray jsonArray) {
RecordSet rs = new RecordSet();
//{"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},
// "svcCode":"70300100030001","requestObject":[{"content":
// [{"updateDate":"2022-07-22 10:51:29","staffCode":"0009000380","orgName":"merchantLF",
// "sysPostId":"0","statusCd":"1000","relType":"1100",
// "systemUserCode":"0009000380","orgId":"9000331",
// "createStaff":"9000377",
// "sysUserPostId":"122952","orgType":"2400",
// "systemUserName":"liaofei",
// "orgCode":"GAM9000331","staffName":"liaofei","actType":"A","sysUserId":"20051",
// "staffId":9000380,"createDate":"2022-07-22 10:51:29"}],"tableName":"system_user_post","primaryKey":"sysUserPostId"}],"key":"svcCont"}
for (int i = 0; i < jsonArray.size(); i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String staffCode = Util.null2String(jsonObject.get("staffCode"));
String orgName = Util.null2String(jsonObject.get("orgName"));
String sysPostId = Util.null2String(jsonObject.get("sysPostId"));
String relType = Util.null2String(jsonObject.get("relType"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String systemUserCode = Util.null2String(jsonObject.get("systemUserCode"));
String orgType = Util.null2String(jsonObject.get("orgType"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String staffName = Util.null2String(jsonObject.get("staffName"));
String actType = Util.null2String(jsonObject.get("actType"));
String sysUserId = Util.null2String(jsonObject.get("sysUserId"));
}
}
public void removeCache(){
ResourceComInfo resComInfo;
DepartmentComInfo deptComInfo;
try {
resComInfo = new ResourceComInfo();
resComInfo.removeResourceCache();
deptComInfo = new DepartmentComInfo();
deptComInfo.removeCompanyCache();
} catch (Exception e) {
new BaseBean().writeLog(e);
}
}
}

70
src/com/engine/bpm/todo/cmd/WorkflowTodoListCmd.java
Unescape Escape View File

@ -1,70 +0,0 @@
package com.engine.bpm.todo.cmd;
import com.engine.common.biz.AbstractCommonCommand;
import com.engine.common.entity.BizLogContext;
import com.engine.core.interceptor.CommandContext;
import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import weaver.conn.RecordSet;
import weaver.general.BaseBean;
import weaver.general.Util;
import java.io.IOException;
import java.nio.charset.Charset;
import java.util.*;
public class WorkflowTodoListCmd extends AbstractCommonCommand<Map<String,Object>> {
@Override
public BizLogContext getLogContext() {
return null;
}
public WorkflowTodoListCmd(Map<String,Object> params) {
this.params = params;
}
@Override
public Map<String, Object> execute(CommandContext commandContext) {
List<Map<String, String>> list = new ArrayList<Map<String, String>>();
Map<String, Object> apidatas = new HashMap<String, Object>();
RecordSet rs = new RecordSet();
BaseBean bb = new BaseBean();
String uid = Util.null2String(params.get("uid"));
String userCode = Util.null2String(params.get("userCode"));
String zsmartLocale = Util.null2String(params.get("zsmartLocale"));
String sql = "" ;
rs.executeQuery(sql);
Map<String,String> map = null;
while (rs.next()){
String requestname = Util.null2String(rs.getString("requestname"));
String requestid = Util.null2String(rs.getString("requestid"));
String createdate = Util.null2String(rs.getString("createdate"));
String createdtime = Util.null2String(rs.getString("createdtime"));
String creator = Util.null2String(rs.getString("creator"));
String type = Util.null2String(rs.getString("type"));
map = new HashMap<String,String>();
map.put("title", requestname); //标题
map.put("url", "bpm/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid); //待办信息的全量路径，如果有待办id的话也需要携带在url中方便业务采集到是哪个待办信息
map.put("date", createdate+" "+createdtime); //创建时间
map.put("creator", creator); //发起人
map.put("type",type); //待办类型
list.add(map);
}
apidatas.put("list",list);
return apidatas;
}
}

8
src/com/engine/bpm/todo/service/WorkflowTodoService.java
Unescape Escape View File

@ -1,8 +0,0 @@
package com.engine.bpm.todo.service;
import java.util.Map;
public interface WorkflowTodoService {
Map<String,Object> doGetTodoList(Map<String,Object> apidatas);
}

15
src/com/engine/bpm/todo/service/impl/WorkflowTodoServiceImpl.java
Unescape Escape View File

@ -1,15 +0,0 @@
package com.engine.bpm.todo.service.impl;
import com.engine.bpm.todo.cmd.WorkflowTodoListCmd;
import com.engine.bpm.todo.service.WorkflowTodoService;
import com.engine.core.impl.Service;
import java.util.Map;
public class WorkflowTodoServiceImpl extends Service implements WorkflowTodoService {
@Override
public Map<String, Object> doGetTodoList(Map<String, Object> apidatas) {
return commandExecutor.execute(new WorkflowTodoListCmd(apidatas));
}
}

108
src/com/engine/bpm/todo/web/WorkflowTodoAction.java
Unescape Escape View File

@ -1,108 +0,0 @@
package com.engine.bpm.todo.web;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.engine.bpm.todo.service.WorkflowTodoService;
import com.engine.bpm.todo.service.impl.WorkflowTodoServiceImpl;
import com.engine.common.util.ServiceUtil;
import weaver.general.BaseBean;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class WorkflowTodoAction {
/***
*
* @return
*/
public WorkflowTodoService getService(){
return (WorkflowTodoService) ServiceUtil.getService(WorkflowTodoServiceImpl.class);
}
@GET
@Path("/todolist")
@Produces(MediaType.TEXT_PLAIN)
public String doGetTodoList(@Context HttpServletRequest request, @Context HttpServletResponse response){
BaseBean bb = new BaseBean();
JSONArray jsonArray = new JSONArray();
List<Map<String,String>> list = new ArrayList<Map<String,String>>();
try{
String type = request.getParameter("type");
String uid = "" ;
String userCode = "" ;
String zsmartLocale = "";
String cookies = request.getHeader("cookie");
bb.writeLog("cookies:"+cookies);
if(!"".equals(cookies))
{
String[] cookievals = cookies.split(";");
for(int i=0;i<cookievals.length;i++)
{
String cookval = cookievals[i];
if(!"".equals(cookval) && cookval.contains("="))
{
String key = cookval.substring(0,cookval.indexOf("="));
String value = cookval.substring(cookval.indexOf("=")+1);
bb.writeLog("key:"+key + " value:"+value);
if("SESSION".equals(key.trim()) || key.contains("SESSION")){
uid = value;
}
if("userCode".equalsIgnoreCase(key.trim()) || key.contains("userCode") ){
userCode = value;
}
if("ZSMART_LOCALE".equalsIgnoreCase(key.trim()) || key.contains("ZSMART_LOCALE") ){
zsmartLocale = value;
}
}
}
}
Map<String,Object> dataMap = new HashMap<String,Object>();
dataMap.put("uid",uid);
dataMap.put("userCode",userCode);
dataMap.put("zsmartLocale",zsmartLocale);
Map<String,Object> map = getService().doGetTodoList(dataMap);
if(map !=null && map.containsKey("list")){
list = (List<Map<String,String>>)map.get("list");
}
jsonArray.addAll(list);
}catch (Exception e){
}
return jsonArray.toJSONString();
}
@POST
@Path("/posttodolist")
@Produces(MediaType.TEXT_PLAIN)
public String doPostTodoList(@Context HttpServletRequest request, @Context HttpServletResponse response){
BaseBean bb = new BaseBean();
JSONObject jsonObject = new JSONObject();
try{
}catch (Exception e){
}
return jsonObject.toJSONString();
}
}

87
src/com/engine/mq/RocketMqAction.java
Unescape Escape View File

@ -1,87 +0,0 @@
package com.engine.mq;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import com.alibaba.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import com.alibaba.rocketmq.client.exception.MQClientException;
import com.alibaba.rocketmq.common.message.MessageExt;
import com.alibaba.rocketmq.common.protocol.heartbeat.MessageModel;
import weaver.general.BaseBean;
import weaver.interfaces.qt.RocketmqUtil2;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import java.io.UnsupportedEncodingException;
import java.util.List;
public class RocketMqAction {
@GET
@Path("/getpurchasereq1")
@Produces(MediaType.TEXT_PLAIN)
public String doGetPurchaseReq1(@Context HttpServletRequest request, @Context HttpServletResponse response){
BaseBean bb = new BaseBean();
JSONObject jsonObject = new JSONObject();
try{
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("portal-producer-group_nj");
consumer.setNamesrvAddr("172.16.84.183:9001;172.16.84.187:9001");
consumer.setInstanceName("dataSync_topic_nj");
// consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
consumer.subscribe("dataSync_topic_nj", "*");
consumer.setConsumeThreadMin(20);
consumer.setConsumeThreadMax(60);
consumer.setConsumeMessageBatchMaxSize(1);
consumer.setMessageModel(MessageModel.BROADCASTING);
RocketmqUtil2 rocketmqUtil = new RocketmqUtil2();
bb.writeLog("Consumer begin.");
consumer.registerMessageListener(new MessageListenerConcurrently() {
@Override
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
MessageExt msg = msgs.get(0);
try {
bb.writeLog("Consumer---3----"+new String(msg.getBody()));
String msgdata = new String(msg.getBody(),"UTF-8");
if(!"".equals(msgdata))
{
String data = msgdata.substring(msgdata.indexOf("{"));
int errcount = rocketmqUtil.updateOrgData(data);
if(errcount >0){
return ConsumeConcurrentlyStatus.RECONSUME_LATER;
}
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
bb.writeLog("Consumer---UnsupportedEncodingException---e:"+e);
return ConsumeConcurrentlyStatus.RECONSUME_LATER;
}
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
});
/**
* Consumer对象在使用之前必须要调用start初始化，初始化一次即可<br>
*/
consumer.start();
bb.writeLog("Consumer Started.");
}catch (MQClientException e){
bb.writeLog("Consumer resource model initiated--MQClientException:"+e);
}
return jsonObject.toJSONString();
}
}

64
src/weaver/interfaces/esigns/ESiginsTest.java
Unescape Escape View File

@ -1,64 +0,0 @@
package weaver.interfaces.esigns;
import com.alibaba.fastjson.JSONObject;
import weaver.general.BaseBean;
import weaver.general.Util;
import weaver.hrm.User;
import weaver.interfaces.filter.HttpRequestUtil;
import java.util.HashMap;
import java.util.Map;
public class ESiginsTest {
public static void main(String[] args) {
BaseBean bb = new BaseBean();
HttpRequestUtil httpRequestUtil = new HttpRequestUtil();
try{
String uid = "" ;
String cookies = "" ;//request.getHeader("cookie");
bb.writeLog("cookies:"+cookies);
if(!"".equals(cookies))
{
String[] cookievals = cookies.split(";");
for(int i=0;i<cookievals.length;i++)
{
String cookval = cookievals[i];
if(!"".equals(cookval) && cookval.contains("="))
{
String key = cookval.substring(0,cookval.indexOf("="));
String value = cookval.substring(cookval.indexOf("=")+1);
bb.writeLog("key:"+key + " value:"+value);
if("SESSION".equals(key.trim()) || key.contains("SESSION")){
uid = value;
}
}
}
}
String sysUserCode = "staff727" ;
String url = "http://172.16.25.133/portal-web/v1/esign/"+sysUserCode+"/esigns" ;
Map<String,String> headMap = new HashMap<String,String>();
headMap.put("Cookie","SESSION="+uid);
String msg = HttpRequestUtil.httpGet2(url,headMap,"UTF-8");
System.out.println("msg ==" + msg);
if(!"".equals(msg))
{
JSONObject jsonObject = JSONObject.parseObject(msg);
if("1".equals(jsonObject.getString("resultCode")))
{
}else{
}
}
}catch (Exception e3){
System.out.println("e---2:"+e3);
}
}
}

11
src/weaver/interfaces/filter/HttpRequestUtil.java
Unescape Escape View File

@ -154,7 +154,14 @@ public class HttpRequestUtil extends BaseBean{
}
public static String httpGet1(String url, Map<String,String> headers, String encode){
/***
*
* @param url
* @param headers
* @param encode
* @return
*/
public String httpGet1(String url, Map<String,String> headers, String encode){
BaseBean bb = new BaseBean();
bb.writeLog("url",url);
@ -210,7 +217,7 @@ public class HttpRequestUtil extends BaseBean{
* @param encode
* @return
*/
public static String httpGet2(String url,Map<String,String> headers,String encode)
public String httpGet2(String url,Map<String,String> headers,String encode)
{
BaseBean bb = new BaseBean();

28
src/weaver/interfaces/filter/PortalLoginBeforeFilter.java
Unescape Escape View File

@ -1,8 +1,7 @@
package weaver.interfaces.filter;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.lang.StringUtils;
import weaver.conn.RecordSet;
import weaver.general.BaseBean;
import weaver.general.Util;
@ -34,17 +33,16 @@ public class PortalLoginBeforeFilter implements Filter
HttpServletRequest request = (HttpServletRequest)servletRequest;
HttpServletResponse response = (HttpServletResponse)servletResponse;
String ipAddress = request.getRequestURL().toString(); //先从nginx自定义配置获取，，可能unknown
if(ipAddress.contains("10.10.192.187")){
//bb.writeLog("10.10.192.187");
}else{
// String ipAddress = request.getRequestURL().toString(); //先从nginx自定义配置获取，，可能unknown
// if(ipAddress.contains("10.10.192.187")){
// //bb.writeLog("10.10.192.187");
// }else{
User loginuser = (User) request.getSession(true).getAttribute("weaver_user@bean");
if (loginuser == null)
{
String uid = "" ;
String cookies = request.getHeader("cookie");
// bb.writeLog("cookies:"+cookies);
if(!"".equals(cookies))
{
String[] cookievals = cookies.split(";");
@ -55,7 +53,6 @@ public class PortalLoginBeforeFilter implements Filter
{
String key = cookval.substring(0,cookval.indexOf("="));
String value = cookval.substring(cookval.indexOf("=")+1);
// bb.writeLog("key:"+key + " value:"+value);
if("SESSION".equals(key.trim()) || key.contains("SESSION")){
uid = value;
}
@ -70,16 +67,16 @@ public class PortalLoginBeforeFilter implements Filter
// CLOUD_APP_NAME=dbeptest7_pot-uportal-core;
// CLOUD_APP_ID=44074
// bb.writeLog("uid 777==" + (!"null".equals(uid) && uid !=null && !"".equals(uid) && uid !=""));
// bb.writeLog("uid 666 ==" + uid);
if(!"null".equals(uid) && uid !=null && !"".equals(uid) && uid !="")
if(StringUtils.isNotEmpty(uid))
{
String url = "http://172.16.25.133/portal-web/user/current" ;
String url = bb.getPropValue("PORTAL_INFO","portal_user_auth");
//String url = "http://172.16.25.133/portal-web/user/current" ;
bb.writeLog("url:"+url);
HttpRequestUtil HttpRequestUtil = new HttpRequestUtil();
Map<String,String> headMap = new HashMap<String,String>();
headMap.put("Cookie","SESSION="+uid);
String msg = HttpRequestUtil.httpGet1(url,headMap,"UTF-8");
if(!"".equals(msg))
{
JSONObject jsonObject = JSONObject.parseObject(msg);
@ -88,7 +85,6 @@ public class PortalLoginBeforeFilter implements Filter
JSONObject resultObject = jsonObject.getJSONObject("resultObject");
String staffCode = resultObject.getString("staffCode");
if(!"".equals(staffCode)){
User user_new = null;
String sql = "" ;
if("admin".equals(staffCode)){
@ -97,7 +93,7 @@ public class PortalLoginBeforeFilter implements Filter
}else{
sql = " select * from HrmResource where loginid =? ";
}
//bb.writeLog("sql:"+sql);
bb.writeLog("sql:"+sql);
rs.executeQuery(sql,new Object[]{staffCode});
if(rs.next()){
user_new = new User();
@ -151,7 +147,7 @@ public class PortalLoginBeforeFilter implements Filter
}
}
}
}
// }
filterChain.doFilter(request, response);
}

168
src/weaver/interfaces/filter/PortalLoginFilter.java
Unescape Escape View File

@ -77,17 +77,14 @@ public class PortalLoginFilter implements Filter
HttpServletRequest request = (HttpServletRequest)servletRequest;
HttpServletResponse response = (HttpServletResponse)servletResponse;
// if(StringUtils.isNotBlank(request.getHeader("x-requested-with"))){
// request.setCharacterEncoding("UTF-8");
// }
String ipAddress = request.getRequestURL().toString(); //先从nginx自定义配置获取，，可能unknown
//bb.writeLog("ipAddress1:"+ipAddress);
if(ipAddress.contains("10.10.192.187")){
//bb.writeLog("10.10.192.187");
}else{
// if(ipAddress.contains("10.10.192.187")){
// //bb.writeLog("10.10.192.187");
// }else{
String portal_homepage = bb.getPropValue("PORTAL_INFO","portal_homepage");
boolean isExcludedPage = false;
String getRequestURI = request.getRequestURI(); //请求地址
@ -97,60 +94,14 @@ public class PortalLoginFilter implements Filter
isExcludedPage = true;
}
// if(!isExcludedPage)
// {
// if(getRequestURI.startsWith(".js", getRequestURI.lastIndexOf(".")) && !getRequestURI.startsWith(".jsp", getRequestURI.lastIndexOf("."))){
// isExcludedPage = true;
// }
// }
// if(!isExcludedPage)
// {
// if(getRequestURI.contains(".js")){
// isExcludedPage = true;
// }
// }
if(!isExcludedPage)
{
if(uncheckurl_list==null || uncheckurl_list.size() == 0){
String uncheck_init = bb.getPropValue("weaver_session_filter","uncheckurl");
if(!"".equals(uncheck_init)){
String[] uncheck_url_arr = uncheck_init.split(";");
for(int i=0;i<uncheck_url_arr.length;i++){
if(uncheck_url_arr[i].startsWith(path)){
uncheckurl_list.add(uncheck_url_arr[i]);
}else{
uncheckurl_list.add(path+uncheck_url_arr[i]);
}
}
}
}
if(uncheckurl_list.contains(getRequestURI) || uncheckurl_list.contains(path+"/"+getRequestURI)){
isExcludedPage = true;
}
}
if(!isExcludedPage){
if(uncheck_sessionurl_list ==null || uncheck_sessionurl_list.size() == 0){
String uncheck_session_init = bb.getPropValue("weaver_session_filter","unchecksessionurl");
if(!"".equals(uncheck_session_init)){
String[] uncheck_session_url_arr = uncheck_session_init.split(";");
for(int i=0;i<uncheck_session_url_arr.length;i++){
if(uncheck_session_url_arr[i].startsWith(path)){
uncheck_sessionurl_list.add(uncheck_session_url_arr[i]);
}else{
uncheck_sessionurl_list.add(path+uncheck_session_url_arr[i]);
}
}
}
}
if(uncheck_sessionurl_list.contains(getRequestURI) || uncheck_sessionurl_list.contains(path+"/"+getRequestURI)){
isExcludedPage = true;
}
@ -159,66 +110,20 @@ public class PortalLoginFilter implements Filter
if(!isExcludedPage)
{
if(uncheck_sessionurl_custom_list ==null || uncheck_sessionurl_custom_list.size() == 0){
String uncheck_session_init = bb.getPropValue("weaver_session_filter_custom","unchecksessionurl");
if(!"".equals(uncheck_session_init))
{
String[] uncheck_session_url_arr = uncheck_session_init.split(";");
for(int i=0;i<uncheck_session_url_arr.length;i++){
if(uncheck_session_url_arr[i].startsWith(path)){
uncheck_sessionurl_custom_list.add(uncheck_session_url_arr[i]);
}else{
uncheck_sessionurl_custom_list.add(path+uncheck_session_url_arr[i]);
}
}
}
}
if(uncheck_sessionurl_custom_list.contains(getRequestURI) || uncheck_sessionurl_custom_list.contains(path+"/"+getRequestURI)){
isExcludedPage = true;
}
}
//bb.writeLog("getRequestURI:"+getRequestURI+" isExcludedPage:"+isExcludedPage);
bb.writeLog("getRequestURI:"+getRequestURI+" isExcludedPage:"+isExcludedPage);
if(!isExcludedPage){
// Enumeration headers = request.getHeaders("");
// while (headers.hasMoreElements()) {
// String key = (String) headers.nextElement();
// String value = request.getHeader(key);
// bb.writeLog("key1:"+key + "value1:"+value);
// }
//
// Cookie[] cookies = request.getCookies();
// for(int i=0;i<cookies.length;i++){
// bb.writeLog("cookies:"+cookies[i].getValue());
// }
// Enumeration headerNames = request.getHeaderNames();
// while (headerNames.hasMoreElements()) {
// String key = (String) headerNames.nextElement();
// String value = request.getHeader(key);
// bb.writeLog("key:"+key + "value:"+value);
// }
//
// Enumeration cookievalues2 = request.getHeaders("cookie");
// while (cookievalues2.hasMoreElements()) {
// String key = (String) cookievalues2.nextElement();
// String value = request.getHeader(key);
// bb.writeLog("key:"+key + "value:"+value);
// }
User loginuser = (User) request.getSession(true).getAttribute("weaver_user@bean");
if (loginuser == null)
{
String uid = "" ;
String cookies = request.getHeader("cookie");
// bb.writeLog("cookies:"+cookies);
if(!"".equals(cookies))
{
String[] cookievals = cookies.split(";");
@ -229,7 +134,6 @@ public class PortalLoginFilter implements Filter
{
String key = cookval.substring(0,cookval.indexOf("="));
String value = cookval.substring(cookval.indexOf("=")+1);
// bb.writeLog("key:"+key + " value:"+value);
if("SESSION".equals(key.trim()) || key.contains("SESSION")){
uid = value;
}
@ -237,27 +141,23 @@ public class PortalLoginFilter implements Filter
}
}
//ecology=BA0A2738FBB4C7664CEECCC8B0CF408B; HTML_VERSION=1603079097996;
// ZSMART_LOCALE=en; SESSION=4e101591-da0e-4425-b035-ffe684f85bca;
// areaId=731; userId=1; orgId=1;
// CLOUD_APP_NAME=dbeptest7_pot-uportal-core;
// CLOUD_APP_ID=44074
// bb.writeLog("uid 777==" + (!"null".equals(uid) && uid !=null && !"".equals(uid) && uid !=""));
// bb.writeLog("uid 666 ==" + uid);
if(!"null".equals(uid) && uid !=null && !"".equals(uid) && uid !="")
{
//bb.writeLog("uid is not null , "+uid);
try{
String url = "http://172.16.25.133/portal-web/user/current" ;
String url = bb.getPropValue("PORTAL_INFO","portal_user_auth");
bb.writeLog("url:"+url);
//String url = "http://172.16.25.133/portal-web/user/current" ;
HttpRequestUtil HttpRequestUtil = new HttpRequestUtil();
Map<String,String> headMap = new HashMap<String,String>();
headMap.put("Cookie","SESSION="+uid);
String msg = HttpRequestUtil.httpGet1(url,headMap,"UTF-8");
// bb.writeLog("msg ==" + msg);
if(!"".equals(msg))
{
JSONObject jsonObject = JSONObject.parseObject(msg);
@ -265,9 +165,7 @@ public class PortalLoginFilter implements Filter
{
JSONObject resultObject = jsonObject.getJSONObject("resultObject");
String staffCode = resultObject.getString("staffCode");
// bb.writeLog("staffCode:"+staffCode);
if(!"".equals(staffCode)){
User user_new = null;
String sql = "" ;
if("admin".equals(staffCode)){
@ -276,7 +174,7 @@ public class PortalLoginFilter implements Filter
}else{
sql = " select * from HrmResource where loginid =? ";
}
//bb.writeLog("sql:"+sql);
bb.writeLog("sql:"+sql);
rs.executeQuery(sql,new Object[]{staffCode});
if(rs.next()){
user_new = new User();
@ -325,16 +223,13 @@ public class PortalLoginFilter implements Filter
request.getSession(true).setAttribute("weaver_user@bean", user_new);
}else{
response.setHeader("Access-Control-Allow-Origin", "*"); //解决跨域访问报错
response.setHeader("Access-Control-Allow-Methods", "POST, PUT, GET, OPTIONS, DELETE");
response.setHeader("Access-Control-Max-Age", "3600"); //设置过期时间
response.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept, client_id, uuid, Authorization");
response.setHeader("Cache-Control", "no-cache, no-store, must-revalidate"); // 支持HTTP 1.1.
response.setHeader("Pragma", "no-cache"); // 支持HTTP 1.0. response.setHeader("Expires", "0");
//bb.writeLog("user is not in oa");
response.sendRedirect("http://172.16.25.133/portal-web/#");
response.sendRedirect(portal_homepage);
return;
}
}else{
@ -346,8 +241,7 @@ public class PortalLoginFilter implements Filter
response.setHeader("Cache-Control", "no-cache, no-store, must-revalidate"); // 支持HTTP 1.1.
response.setHeader("Pragma", "no-cache"); // 支持HTTP 1.0. response.setHeader("Expires", "0");
//bb.writeLog("cookie user not in null");
response.sendRedirect("http://172.16.25.133/portal-web/#");
response.sendRedirect(portal_homepage);
return;
}
}else{
@ -358,9 +252,7 @@ public class PortalLoginFilter implements Filter
response.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept, client_id, uuid, Authorization");
response.setHeader("Cache-Control", "no-cache, no-store, must-revalidate"); // 支持HTTP 1.1.
response.setHeader("Pragma", "no-cache"); // 支持HTTP 1.0. response.setHeader("Expires", "0");
//bb.writeLog("cookie user not in null");
response.sendRedirect("http://172.16.25.133/portal-web/#");
response.sendRedirect(portal_homepage);
return;
}
}else{
@ -372,36 +264,12 @@ public class PortalLoginFilter implements Filter
response.setHeader("Cache-Control", "no-cache, no-store, must-revalidate"); // 支持HTTP 1.1.
response.setHeader("Pragma", "no-cache"); // 支持HTTP 1.0. response.setHeader("Expires", "0");
response.sendRedirect("http://172.16.25.133/portal-web/#");
response.sendRedirect(portal_homepage);
return;
}
}catch (Exception e3){
bb.writeLog("e---2:"+e3);
}
// try{
// String url = "http://172.16.25.133/portal-web/user/current" ;
// HttpRequestUtil HttpRequestUtil = new HttpRequestUtil();
// Map<String,String> headMap = new HashMap<String,String>();
// headMap.put("Cookie","SESSION="+uid);
// String msg = HttpRequestUtil.sendGet(url,headMap,uid);
// bb.writeLog("msg2 ==" + msg);
// }catch (Exception e3){
// bb.writeLog("e---3:"+e3);
// }
//
// try{
// String url = "http://172.16.25.133/portal-web/user/current" ;
// HttpRequestUtil HttpRequestUtil = new HttpRequestUtil();
// Map<String,String> headMap = new HashMap<String,String>();
// headMap.put("Cookie","SESSION="+uid);
// String msg3 = HttpRequestUtil.sendPost(url,headMap,"UTF-8",uid);
// bb.writeLog("msg3 ==" + msg3);
// }catch (Exception e3){
// bb.writeLog("e---2:"+e3);
// }
}else{
response.setHeader("Access-Control-Allow-Origin", "*"); //解决跨域访问报错
@ -411,17 +279,13 @@ public class PortalLoginFilter implements Filter
response.setHeader("Cache-Control", "no-cache, no-store, must-revalidate"); // 支持HTTP 1.1.
response.setHeader("Pragma", "no-cache"); // 支持HTTP 1.0. response.setHeader("Expires", "0");
//http://172.16.25.133/portal-web/
String url = "http://172.16.25.133/portal-web/";
//String url = "https://www.baidu.com";
//response.setHeader("refresh", "0;url=" + url);
String url = portal_homepage;
response.sendRedirect(url);
return;
//response.setHeader("refresh", "0;url=" + url);
}
}
}
}
// }
filterChain.doFilter(request, response);
}

3
src/weaver/interfaces/mq/RocketMsgListener.java
Unescape Escape View File

@ -27,9 +27,6 @@ public class RocketMsgListener implements MessageListenerConcurrently {
String data = msgdata.substring(msgdata.indexOf("{"));
int errcount = rocketmqUtil.updateOrgData(data);
bb.writeLog("Consumer---errcount---:"+errcount);
// if(errcount >0){
// return ConsumeConcurrentlyStatus.RECONSUME_LATER;
// }
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();

52
src/weaver/interfaces/mq/RocketmqServlet.java
Unescape Escape View File

@ -21,6 +21,7 @@ import java.util.Date;
public class RocketmqServlet extends HttpServlet {
@Override
public void init() throws ServletException
{
@ -35,50 +36,33 @@ public class RocketmqServlet extends HttpServlet {
try{
//DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("portal-producer-group_nj");
//DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("cbec-consumer-group_nj_133");
//consumer.setNamesrvAddr("172.16.84.183:9001;172.16.84.187:9001");
// consumer.subscribe("dataSync_topic_nj", "BPM");
// consumer.setInstanceName("dataSync_topic_nj");
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("cbec-consumer-group_nj_133");
String consumerGroup = bb.getPropValue("PORTAL_INFO","consumerGroup");
bb.writeLog("consumerGroup:"+consumerGroup);
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(consumerGroup );
String namesrvAddr = bb.getPropValue("PORTAL_INFO","namesrvAddr");
bb.writeLog("namesrvAddr:"+namesrvAddr);
consumer.setNamesrvAddr(namesrvAddr);
consumer.setNamesrvAddr("172.16.84.183:9001;172.16.84.187:9001");
consumer.setInstanceName("dataSync_topic_nj");
String instanceName = bb.getPropValue("PORTAL_INFO","instanceName");
consumer.setInstanceName(instanceName);
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
consumer.subscribe("dataSync_topic_nj", "BPM");
String topic = bb.getPropValue("PORTAL_INFO","topic");
String subExpression = bb.getPropValue("PORTAL_INFO","subExpression");
consumer.subscribe(topic, subExpression);
consumer.setConsumeThreadMin(1);
consumer.setConsumeThreadMax(1);
consumer.setConsumeMessageBatchMaxSize(1);
consumer.setMessageModel(MessageModel.BROADCASTING);
// RocketmqUtil rocketmqUtil = new RocketmqUtil();
bb.writeLog("Consumer begin.");
consumer.registerMessageListener(new RocketMsgListener());
// consumer.registerMessageListener(new MessageListenerConcurrently() {
// @Override
// public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
// MessageExt msg = msgs.get(0);
// try {
// bb.writeLog("Consumer---3----"+new String(msg.getBody()));
// String msgdata = new String(msg.getBody(),"UTF-8");
// if(!"".equals(msgdata))
// {
// String data = msgdata.substring(msgdata.indexOf("{"));
// int errcount = rocketmqUtil.updateOrgData(data);
// if(errcount >0){
// return ConsumeConcurrentlyStatus.RECONSUME_LATER;
// }
// }
// } catch (UnsupportedEncodingException e) {
// e.printStackTrace();
// bb.writeLog("Consumer---UnsupportedEncodingException---e:"+e);
// return ConsumeConcurrentlyStatus.RECONSUME_LATER;
// }
// return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
// }
// });
/**
* Consumer对象在使用之前必须要调用start初始化，初始化一次即可<br>
*/
@ -92,7 +76,6 @@ public class RocketmqServlet extends HttpServlet {
bb.writeLog("***** resource model initiated");
bb.writeLog("***** resource model initiated");
bb.writeLog("***** resource model initiated");
}
@ -103,6 +86,7 @@ public class RocketmqServlet extends HttpServlet {
* @throws ServletException
* @throws IOException
*/
@Override
public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
doPost(request, response);
}
@ -115,9 +99,11 @@ public class RocketmqServlet extends HttpServlet {
* @throws IOException
*/
@Override
public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
}
@Override
public void destroy()
{
// 什么也不做

3
src/weaver/interfaces/mq/RocketmqUtil.java
Unescape Escape View File

@ -72,9 +72,6 @@ public class RocketmqUtil {
bb.writeLog("errcount2:"+errcount2);
errcount += errcount2;
}
}
}
}

134
src/weaver/interfaces/qt/Consumer.java
Unescape Escape View File

@ -1,134 +0,0 @@
package weaver.interfaces.qt;
import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import com.alibaba.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import com.alibaba.rocketmq.client.exception.MQClientException;
import com.alibaba.rocketmq.common.consumer.ConsumeFromWhere;
import com.alibaba.rocketmq.common.message.MessageExt;
import com.alibaba.rocketmq.common.protocol.heartbeat.MessageModel;
import java.io.*;
import java.util.List;
public class Consumer {
/**
* 内部是使用长轮询Pull方式从MetaQ服务器拉消息，然后再回调用户Listener方法<br>
*/
public static void main(String[] args) throws InterruptedException,
MQClientException {
/**
* 一个应用创建一个Consumer，由应用来维护此对象，可以设置为全局对象或者单例<br>
* 注意：ConsumerGroupName需要由应用来保证唯一。
*不同consumer group里的consumer即便是消费同一个topic下的同一个queue，
*那消费进度也是分开存储的。也就是说，不同的consumer group内的consumer的消费
*完全隔离，彼此不受影响。
*/
// mq.datasync.topic=dataSync_topic_nj
// ctgmq.producer.common.producerGroupName=portal-producer-group_nj
// ctgmq.producer.common.instanceName=dataSync_topic_nj
// ctgmq.producer.common.namesrvAddr=172.16.84.183:9001;172.16.84.187:9001
// ctgmq.producer.common.authId=rul
// ctgmq.producer.common.authPwd=rul
// ctgmq.producer.common.clusterName=CtgMQ_01
// ctgmq.producer.common.tenantID=100000
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(
"cbec-consumer-group_nj_133");
consumer.setNamesrvAddr("172.16.84.183:9001;172.16.84.187:9001");
//consumer.setInstanceName("dataSync_topic_nj");
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
//广播消费是指一个consumer只要订阅了某个topic的消息，那它就会收到该topic下的所有queue里的消息，
//而不管这个consumer的group是什么。所以对于广播消费来说，consumer group没什么实际意义。consumer可以在实例化时，我们可以指定是集群消费还是广播消费。
//consumer.setMessageModel(MessageModel.BROADCASTING);
consumer.setMessageModel(MessageModel.BROADCASTING);
/**
* 订阅指定topic下tags分别等于TagA或TagC或TagD
*/
//consumer.subscribe("dataSync_topic_nj", "TagA || TagC || TagD");
/**
* 订阅指定topic下所有消息<br>
* 注意：一个consumer对象可以订阅多个topic
*/
consumer.setConsumeMessageBatchMaxSize(1);
//关闭VIP通道，避免接收不了消息
consumer.subscribe("dataSync_topic_nj", "BPM");
int i = 0;
String path = "C:\\Users\\Administrator\\Desktop\\demo10.txt";
consumer.registerMessageListener(new MessageListenerConcurrently() {
/**
* 默认msgs里只有一条消息，可以通过设置consumeMessageBatchMaxSize参数来批量接收消息
*/
@Override
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
// System.out.println(Thread.currentThread().getName()
// + " Receive New Messages: " + msgs.size());
MessageExt msg = msgs.get(0);
try {
// System.out.println("11----"+new String(msg.getBody(), StandardCharsets.UTF_8));
// System.out.println("11----"+new String(msg.toString()));
// System.out.println("1----"+new String(msg.getBody(),"UTF-8"));
// System.out.println("2----"+new String(msg.getBody(),"GBK"));
System.out.println("3----"+new String(msg.getBody()));
String msgdata = new String(msg.getBody(),"UTF-8");
// System.out.println("5----"+msgdata.substring(msgdata.indexOf("{")));
if(!"".equals(msgdata)){
String data = msgdata.substring(msgdata.indexOf("{"));
//SymOrgUserData.updasteSysOrgData(data);
System.out.println(data);
System.out.println(context.getMessageQueue().toString());
BufferedWriter out = null;
try {
out = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(path,true)));
out.write(data+"\r\n");
out.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
System.out.println(e);
} catch (IOException e) {
e.printStackTrace();
System.out.println(e);
}
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
System.out.println(e);
}
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
});
/**
* Consumer对象在使用之前必须要调用start初始化，初始化一次即可<br>
*/
consumer.start();
System.out.println("Consumer Started.");
}
}

107
src/weaver/interfaces/qt/Consumer2.java
Unescape Escape View File

@ -1,107 +0,0 @@
package weaver.interfaces.qt;
//import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer;
//import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
//import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
//import com.alibaba.rocketmq.client.consumer.listener.MessageListenerConcurrently;
//import com.alibaba.rocketmq.client.exception.MQClientException;
//import com.alibaba.rocketmq.common.message.MessageExt;
//import com.alibaba.rocketmq.remoting.common.RemotingHelper;
import java.util.List;
public class Consumer2 {
/**
* 内部是使用长轮询Pull方式从MetaQ服务器拉消息，然后再回调用户Listener方法<br>
*/
// public static void main(String[] args) throws InterruptedException,
// MQClientException {
// /**
// * 一个应用创建一个Consumer，由应用来维护此对象，可以设置为全局对象或者单例<br>
// * 注意：ConsumerGroupName需要由应用来保证唯一。
// *不同consumer group里的consumer即便是消费同一个topic下的同一个queue，
// *那消费进度也是分开存储的。也就是说，不同的consumer group内的consumer的消费
// *完全隔离，彼此不受影响。
// */
//
//
//// mq.datasync.topic=dataSync_topic_nj
//// ctgmq.producer.common.producerGroupName=portal-producer-group_nj
//// ctgmq.producer.common.instanceName=dataSync_topic_nj
//// ctgmq.producer.common.namesrvAddr=172.16.84.183:9001;172.16.84.187:9001
//// ctgmq.producer.common.authId=rul
//// ctgmq.producer.common.authPwd=rul
//// ctgmq.producer.common.clusterName=CtgMQ_01
//// ctgmq.producer.common.tenantID=100000
//
//
// DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(
// "portal-producer-group_nj" );
// consumer.setNamesrvAddr("172.16.84.183:9001");
// consumer.setInstanceName("dataSync_topic_nj");
//
//
// //广播消费是指一个consumer只要订阅了某个topic的消息，那它就会收到该topic下的所有queue里的消息，
// //而不管这个consumer的group是什么。所以对于广播消费来说，consumer group没什么实际意义。consumer可以在实例化时，我们可以指定是集群消费还是广播消费。
// //consumer.setMessageModel(MessageModel.BROADCASTING);
// /**
// * 订阅指定topic下tags分别等于TagA或TagC或TagD
// */
// //consumer.subscribe("dataSync_topic_nj", "TagA || TagC || TagD");
// /**
// * 订阅指定topic下所有消息<br>
// * 注意：一个consumer对象可以订阅多个topic
// */
// consumer.subscribe("dataSync_topic_nj", "*");
// consumer.registerMessageListener(new MessageListenerConcurrently() {
// /**
// * 默认msgs里只有一条消息，可以通过设置consumeMessageBatchMaxSize参数来批量接收消息
// */
// @Override
// public ConsumeConcurrentlyStatus consumeMessage(
// List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
// System.out.println(Thread.currentThread().getName()
// + " Receive New Messages: " + msgs.size());
// MessageExt messageExt = msgs.get(0);
//
//
// try {
// String id = messageExt.getMsgId();
// String topic = messageExt.getTopic();
// String tags = messageExt.getTags();
// String keys = messageExt.getKeys();
// String msgBody = new String(messageExt.getBody());
// //模拟失败
// if ("key5".equals(keys)) {
// System.out.println(1 / 0);
// }
// System.out.println("topic: " + topic + ",tags: " + tags + ", id:" + id + ",keys: " + keys + ", body: " + msgBody);
// } catch (Exception e) {
// //失败后，默认会隔 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h 重试
// e.printStackTrace();
// int reconsumeTimes = messageExt.getReconsumeTimes();//失败重试次数
// if (reconsumeTimes == 3) {
// //记录日志 ...
// System.out.println("消息ID:" + messageExt.getMsgId() + "失败三次，执行补偿策略");
// //做补偿处理
// //TODO
// return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
// }
// return ConsumeConcurrentlyStatus.RECONSUME_LATER;
// }
// return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
//
// //System.out.println(new String(messageExt.getBody()));
// //return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
// }
// });
// /**
// * Consumer对象在使用之前必须要调用start初始化，初始化一次即可<br>
// */
// consumer.start();
// System.out.println("Consumer Started.");
// }
}

61
src/weaver/interfaces/qt/Consumer3.java
Unescape Escape View File

@ -1,61 +0,0 @@
package weaver.interfaces.qt;
//import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
//import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
//import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
//import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
//import org.apache.rocketmq.client.exception.MQClientException;
//import org.apache.rocketmq.common.message.MessageExt;
//
//import java.io.UnsupportedEncodingException;
//import java.util.List;
public class Consumer3 {
/**
* 内部是使用长轮询Pull方式从MetaQ服务器拉消息，然后再回调用户Listener方法<br>
*/
public static void main(String[] args) {
// try{
//
// DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("portal-producer-group_nj");
// consumer.setNamesrvAddr("172.16.84.183:9001;172.16.84.187:9001");
// consumer.setInstanceName("dataSync_topic_nj");
// consumer.subscribe("dataSync_topic_nj", "*");
//
//// RocketMsgListener msgListener = new RocketMsgListener();
//// consumer.registerMessageListener(msgListener);
//
//
// consumer.registerMessageListener(new MessageListenerConcurrently() {
// @Override
// public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
// MessageExt msg = msgs.get(0);
// try {
// System.out.println("3----"+new String(msg.getBody()));
// String msgdata = new String(msg.getBody(),"UTF-8");
// if(!"".equals(msgdata))
// {
// String data = msgdata.substring(msgdata.indexOf("{"));
//
// }
// } catch (UnsupportedEncodingException e) {
// e.printStackTrace();
// return ConsumeConcurrentlyStatus.RECONSUME_LATER;
// }
// return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
// }
// });
//
// /**
// * Consumer对象在使用之前必须要调用start初始化，初始化一次即可<br>
// */
// consumer.start();
//
// }catch (MQClientException e){
// }
}
}

57
src/weaver/interfaces/qt/RocketMqConsumer.java
Unescape Escape View File

@ -1,57 +0,0 @@
package weaver.interfaces.qt;
//import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer;
//import com.alibaba.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;
//import com.alibaba.rocketmq.client.consumer.listener.MessageListenerOrderly;
//import com.alibaba.rocketmq.common.consumer.ConsumeFromWhere;
//import com.alibaba.rocketmq.common.message.MessageExt;
//import com.alibaba.rocketmq.common.protocol.heartbeat.MessageModel;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.stereotype.Component;
public class RocketMqConsumer {
// private DefaultMQPushConsumer consumer;
//
// private final MessageModel messageModel = MessageModel.CLUSTERING;
//
//
// private String consumerGroupName = "portal-producer-group_nj";
// private String instanceName = "dataSync_topic_nj" ;
// private String nameServerAddr = "172.16.84.183:9001;172.16.84.187:9001";
// private int consumeThreadMin;
// private int consumeThreadMax;
// private String topicAndTags = "*" ;
// private int pullThresholdForQueue;
// private int pullBatchSize;
//
//
// public void afterPropertiesSet2() throws Exception {
// consumer = new DefaultMQPushConsumer(consumerGroupName);
// consumer.setInstanceName(instanceName);
// consumer.setMessageModel(messageModel);
// consumer.setNamesrvAddr(nameServerAddr);
// consumer.setConsumeThreadMax(consumeThreadMax);
// consumer.setConsumeThreadMin(consumeThreadMin);
// consumer.setPullBatchSize(pullBatchSize);
// consumer.setPullThresholdForQueue(pullThresholdForQueue);
// consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
// // 订阅的 topic 和 tags
// consumer.subscribe(topicAndTags, topicAndTags);
// // 注册监听方式 有序
// consumer.registerMessageListener((MessageListenerOrderly) (messageExtList, consumeOrderlyContext) -> {
// MessageExt msg = messageExtList.get(0);
// String messageBody = new String(msg.getBody());
// System.out.println("consume message, msgId={}, topic={}, tags={}, keys={},\n body={}"+ msg.getMsgId()+ msg.getTopic()+msg.getTags()+ msg.getKeys()+ messageBody);
// // todo: business code to consume message
// //yourService.xxx
// return ConsumeOrderlyStatus.SUCCESS;
// });
// consumer.start();
// System.out.println("rocketMQ consumer group [{}] started"+ consumerGroupName);
// }
}

39
src/weaver/interfaces/qt/RocketMsgOrderListener.java
Unescape Escape View File

@ -1,39 +0,0 @@
package weaver.interfaces.qt;
import com.alibaba.rocketmq.client.consumer.listener.*;
import com.alibaba.rocketmq.common.message.MessageExt;
import weaver.general.BaseBean;
import java.io.UnsupportedEncodingException;
import java.util.List;
public class RocketMsgOrderListener implements MessageListenerOrderly {
@Override
public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext consumeOrderlyContext) {
BaseBean bb = new BaseBean();
MessageExt msg = msgs.get(0);
RocketmqUtil2 rocketmqUtil = new RocketmqUtil2();
try {
bb.writeLog("Consumer---3----"+new String(msg.getBody()));
String msgdata = new String(msg.getBody(),"UTF-8");
if(!"".equals(msgdata))
{
String data = msgdata.substring(msgdata.indexOf("{"));
int errcount = rocketmqUtil.updateOrgData(data);
if(errcount >0){
return ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT;
}
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
bb.writeLog("Consumer---UnsupportedEncodingException---e:"+e);
return ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT;
}
return ConsumeOrderlyStatus.SUCCESS;
}
}

496
src/weaver/interfaces/qt/RocketmqUtil2.java
Unescape Escape View File

@ -1,496 +0,0 @@
package weaver.interfaces.qt;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import weaver.conn.RecordSet;
import weaver.general.BaseBean;
import weaver.general.TimeUtil;
import weaver.general.Util;
import weaver.hrm.company.DepartmentComInfo;
import weaver.hrm.resource.ResourceComInfo;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class RocketmqUtil2 {
private Lock lock = new ReentrantLock();
public int updateOrgData(String data)
{
lock.lock();
BaseBean bb = new BaseBean();
int errcount = 0;
try{
JSONObject jsonObject = JSONObject.parseObject(data);
if(jsonObject.containsKey("requestObject"))
{
JSONArray requestArray = jsonObject.getJSONArray("requestObject");
for(int i=0;i<requestArray.size();i++)
{
JSONObject requestObject = requestArray.getJSONObject(i);
System.out.println(requestObject.toJSONString());
if(!requestObject.isEmpty()){
if(requestObject.containsKey("tableName") && requestObject.containsKey("content"))
{
String tableName = requestObject.getString("tableName");
bb.writeLog("tableName:"+tableName);
if("organization".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
int errcount1 = updasteSysOrgData(jsonArray);
errcount += errcount1;
}else if("system_user".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
int errcount2 = updateSysUserData(jsonArray);
errcount += errcount2;
}else if("system_role".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updasteSysRoleData(jsonArray);
}else if("system_post".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updasteSysPostData(jsonArray);
}else if("system_user_role".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updateSystemUserRoleData(jsonArray);
}else if("system_user_post".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updateSystemUserPostData(jsonArray);
}
}
}
}
}
}catch (Exception e){
}finally {
lock.unlock();
}
bb.writeLog("errcount:"+errcount);
return errcount;
}
/***
*
* @param jsonArray
*/
public int updateSysUserData(JSONArray jsonArray){
RecordSet rs = new RecordSet();
BaseBean bb = new BaseBean();
//{"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},
// "svcCode":"70300100030001","requestObject":[{"content":[
// {"statusDate":"2022-07-18 11:25:41","updateDate":"2022-07-22 10:52:56",
// "regionNbr":"1","expDate":"2999-12-31 23:59:59","userOrgId":"2",
// "password":"{bcrypt}$2a$10$wQrGr6zHlqaKbAZGaK7PC.VdmZdq4HJn6t7R4XpGsf/yKqPj6smHq",
// "effDate":"2021-07-13 10:33:57","orgCode":"2",
// "staffName":"zhouhan","pwdNewtime":"2022-05-18 14:42:15",
// "pwdContinErrCnt":"0","actType":"M","sysUserId":"14002","email":"2112@qq.com",
// "createDate":"2021-07-13 10:33:58","staffCode":"zhouhan",
// "sysUserCode":"zhouhan","pwdErrCnt":"0","pwdEffectDays":"90","statusCd":"1000",
// "systemInfoId":"-1","userName":"zhouhan","createStaff":"1","pwdStatus":"1100",
// "regionId":"731","pwdSmsTel":"21423523523","loginedNum":"78","staffId":"12002",
// "updateStaff":"1"}],"tableName":"system_user","primaryKey":"sysUserId"}],"key":"svcCont"}
int errcount = 0;
for(int i=0;i<jsonArray.size();i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String statusDate = Util.null2String(jsonObject.get("statusDate"));
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String regionNbr = Util.null2String(jsonObject.get("regionNbr"));
String userOrgId = Util.null2String(jsonObject.get("userOrgId"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String staffId = Util.null2String(jsonObject.get("staffId"));
String staffName = Util.null2String(jsonObject.get("staffName"));
String staffCode = Util.null2String(jsonObject.get("staffCode"));
String actType = Util.null2String(jsonObject.get("actType"));
String email = Util.null2String(jsonObject.get("email"));
String sysUserId = Util.null2String(jsonObject.get("sysUserId"));
String sysUserCode = Util.null2String(jsonObject.get("sysUserCode"));
String userName = Util.null2String(jsonObject.get("userName"));
String pwdSmsTel = Util.null2String(jsonObject.get("pwdSmsTel"));
String loginedNum = Util.null2String(jsonObject.get("sysUserId"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String status = "1";
if("1100".equals(statusCd) || "1200".equals(statusCd) || "1300".equals(statusCd)){
status = "5";
}
bb.writeLog("status:"+status);
bb.writeLog("statusCd:"+statusCd);
String subcompanyid1 = "" ;
String deptId = "";
if(!"".equals(orgCode)){
String sql = " select id,subcompanyid1 from hrmdepartment where departmentcode = ?" ;
rs.executeQuery(sql,new Object[]{orgCode});
if(rs.next()){
deptId = Util.null2String(rs.getString("id"));
subcompanyid1 = Util.null2String(rs.getString("subcompanyid1"));
}
}
bb.writeLog("deptId:"+deptId);
bb.writeLog("subcompanyid1:"+subcompanyid1);
String locationid = "2" ;
String seclevel = "20" ;
String createrid = "1" ;
String lastmodid = "1" ;
String creator = "1";
String jobTitleId = "40";
String systemlanguage = "7" ;
String currentDate = TimeUtil.getCurrentDateString();//当前日期
String currentDateTime = TimeUtil.getCurrentTimeString(); //当前时间
bb.writeLog("status:"+status);
bb.writeLog("currentDate:"+currentDate);
String loginid = "";
String sql = " select loginid from hrmresource where workcode=?" ;
bb.writeLog("sql:"+sql);
bb.writeLog("staffCode:"+staffCode);
rs.executeQuery(sql,new Object[]{staffCode});
if(rs.next()){
loginid = Util.null2String(rs.getString("loginid"));
}
bb.writeLog("loginid:"+loginid);
if(!"".equals(deptId))
{
if(!"".equals(loginid))
{
if("M".equalsIgnoreCase(actType))
{
String userUpdateSql = " update hrmresource set lastname=?,departmentid=?,subcompanyid1=?," +
" creater=?,email=?,mobile=?,jobtitle=?,status=?,dsporder=?,lastmoddate=?,modified=? where workcode=? ";
bb.writeLog("userUpdateSql:"+userUpdateSql);
boolean flag = rs.executeUpdate(userUpdateSql,new Object[]{staffName,deptId,subcompanyid1,creator,email,
pwdSmsTel,jobTitleId,status,loginedNum,currentDate,currentDateTime,staffCode});
bb.writeLog("flag:"+flag);
if(!flag){
errcount++;
}
}
}else{
if("A".equalsIgnoreCase(actType))
{
// int tmpid = 0;
// rs.executeSql("select max(id) from HrmResourceVirtual ");
// if(rs.next()){
// tmpid = rs.getInt(1)+1;
// }
rs.executeProc("HrmResourceMaxId_Get", "");
rs.next();
String id = "" + rs.getInt(1);
bb.writeLog("id:"+id);
if(!"".equals(id)){
String userInsertSql = " insert into hrmresource(id,loginid,workcode,lastname,departmentid,subcompanyid1," +
"creater,email,mobile,jobtitle,status,dsporder,systemlanguage,createdate,lastmoddate,created,modified," +
"locationid,seclevel,createrid,lastmodid) " +
" values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
bb.writeLog("userInsertSql:"+userInsertSql);
boolean flag = rs.executeUpdate(userInsertSql,new Object[]{id,staffCode,staffCode,staffName,deptId,subcompanyid1,
creator,email,pwdSmsTel,jobTitleId,status,loginedNum,systemlanguage,currentDate,currentDate,currentDateTime,currentDateTime,
locationid,seclevel,createrid,lastmodid});
bb.writeLog("flag:"+flag);
if(!flag){
errcount++;
}
}
}
}
}
}
return errcount;
}
public int updasteSysOrgData(JSONArray jsonArray){
RecordSet rs = new RecordSet();
BaseBean bb = new BaseBean();
int errcount = 0;
// {"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},"svcCode":
// "70300100030001","requestObject":[{"content":[{
// "updateDate":"2022-07-22 11:05:22","orgName":"testOrg722","parentOrgCode":"LNP000001",
// "regionNbr":"TST_PR_CSS","orgLevel":"2","statusCd":"1000",
// "parentOrgName":"Vivia","orgId":"17012",
// "createStaff":"1","orgType":"1000",
// "regionId":"36","parentOrgId":"1",
// "orgCode":"testOrg722",
// "pathCode":"-1.1.17012","actType":"A","partyId":"0",
// "parRegionNbr":"1",
// "createDate":"2022-07-22 11:05:22"
// }],"tableName":"organization","primaryKey":"orgId"}],"key":"svcCont"}
for(int i=0;i<jsonArray.size();i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String orgName = Util.null2String(jsonObject.get("orgName"));
String parentOrgCode = Util.null2String(jsonObject.get("parentOrgCode"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String parentOrgName = Util.null2String(jsonObject.get("parentOrgName"));
String orgId = Util.null2String(jsonObject.get("orgId"));
String orgType = Util.null2String(jsonObject.get("orgType"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String actType = Util.null2String(jsonObject.get("actType"));
String canceled = "";
if("1100".equals(statusCd)){
canceled = "1";
}
bb.writeLog("canceled:"+canceled);
String supdepid = "0";
String subcompanyid1 = "" ;
if(!"".equals(parentOrgCode))
{
rs.executeQuery(" select id from hrmsubcompany where subcompanycode=? ",new Object[]{parentOrgCode});
if(rs.next()){
subcompanyid1 = Util.null2String(rs.getString("id"));
}
if("".equals(subcompanyid1)){
String sql = " select id,subcompanyid1 from hrmdepartment where departmentcode = ?" ;
rs.executeQuery(sql,new Object[]{parentOrgCode});
if(rs.next()){
supdepid = Util.null2String(rs.getString("id"));
subcompanyid1 = Util.null2String(rs.getString("subcompanyid1"));
}
}
}
bb.writeLog("actType:"+actType);
bb.writeLog("supdepid:"+supdepid);
bb.writeLog("subcompanyid1:"+subcompanyid1);
if(!"".equals(subcompanyid1)){
String deptid = "" ;
String sql = " select id from hrmdepartment where departmentcode=?" ;
rs.executeQuery(sql,new Object[]{orgCode});
if(rs.next()){
deptid = Util.null2String(rs.getString("id"));
}
bb.writeLog("deptid:"+deptid);
if(!"".equals(deptid))
{
if("M".equalsIgnoreCase(actType))
{
String deptUpdateSql = " update hrmdepartment set departmentmark=?,departmentname=?,canceled=?," +
" subcompanyid1=?,showorder=?, supdepid=? where departmentcode=? ";
bb.writeLog("deptUpdateSql:"+deptUpdateSql);
boolean flag = rs.executeUpdate(deptUpdateSql,new Object[]{orgName,orgName,canceled,subcompanyid1,orgId,supdepid,orgCode});
bb.writeLog("flag:"+flag);
if(!flag){
errcount++;
}
}
}else{
if("A".equalsIgnoreCase(actType))
{
String deptInsertSql = " insert into hrmdepartment(departmentmark,departmentname,departmentcode," +
" canceled,subcompanyid1,supdepid,showorder) values(?,?,?,?,?,?,?) ";
bb.writeLog("deptInsertSql:"+deptInsertSql);
boolean flag = rs.executeUpdate(deptInsertSql,new Object[]{orgName,orgName,orgCode,canceled,subcompanyid1,supdepid,orgId});
bb.writeLog("flag:"+flag);
if(!flag){
errcount++;
}
}
}
}
}
return errcount;
}
// {"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},"svcCode":
// "70300100030001","requestObject":[{"content":[{"sysUserRoleId":"23444","updateDate":"2022-07-22 11:08:33",
// "systemInfoCode":"TYMH","sysRoleId":"17013","statusCd":"1000",
// "systemInfoId":"727001","operType":"1000",
// "systemUserCode":"finaceManager",
// "expDate":"2120-01-01 00:00:00","orgId":"17012",
// "createStaff":"1","effDate":"2022-07-21 10:17:51",
// "systemUserName":"financeManager",
// "orgCode":"testOrg722","roleCode":"orgManager","manageClass":"1000","roleName":"orgManager",
// "actType":"A","sysUserId":"20047","createDate":"2022-07-22 11:08:33"}],
// "tableName":"system_user_role","primaryKey":"sysUserRoleId"}],"key":"svcCont"}
/***
*
* @param jsonArray
*/
public static void updateSystemUserRoleData(JSONArray jsonArray) {
RecordSet rs = new RecordSet();
for (int i = 0; i < jsonArray.size(); i++) {
JSONObject jsonObject = jsonArray.getJSONObject(i);
String sysUserRoleId = Util.null2String(jsonObject.get("sysUserRoleId"));
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String systemInfoCode = Util.null2String(jsonObject.get("systemInfoCode"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String systemUserCode = Util.null2String(jsonObject.get("systemUserCode"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String roleCode = Util.null2String(jsonObject.get("roleCode"));
String manageClass = Util.null2String(jsonObject.get("manageClass"));
String actType = Util.null2String(jsonObject.get("actType"));
String createDate = Util.null2String(jsonObject.get("createDate"));
if(!"".equals(systemUserCode)){
// String loginid = "";
//
// String sql = " select loginid from hrmrole where workcode=?" ;
// rs.executeQuery(sql,new Object[]{systemUserCode});
// if(rs.next()){
// loginid = Util.null2String(rs.getString("loginid"));
// }
//
//
// sql = " select loginid from hrmresource where workcode=?" ;
// rs.executeQuery(sql,new Object[]{systemUserCode});
// if(rs.next()){
// loginid = Util.null2String(rs.getString("loginid"));
// }
//
// if(!"".equals(loginid)){
//
// }
}
}
}
/***
*
* @param jsonArray
*/
public static void updateSystemUserPostData(JSONArray jsonArray) {
RecordSet rs = new RecordSet();
//{"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},
// "svcCode":"70300100030001","requestObject":[{"content":
// [{"updateDate":"2022-07-22 10:51:29","staffCode":"0009000380","orgName":"merchantLF",
// "sysPostId":"0","statusCd":"1000","relType":"1100",
// "systemUserCode":"0009000380","orgId":"9000331",
// "createStaff":"9000377",
// "sysUserPostId":"122952","orgType":"2400",
// "systemUserName":"liaofei",
// "orgCode":"GAM9000331","staffName":"liaofei","actType":"A","sysUserId":"20051",
// "staffId":9000380,"createDate":"2022-07-22 10:51:29"}],"tableName":"system_user_post","primaryKey":"sysUserPostId"}],"key":"svcCont"}
for (int i = 0; i < jsonArray.size(); i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String staffCode = Util.null2String(jsonObject.get("staffCode"));
String orgName = Util.null2String(jsonObject.get("orgName"));
String sysPostId = Util.null2String(jsonObject.get("sysPostId"));
String relType = Util.null2String(jsonObject.get("relType"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String systemUserCode = Util.null2String(jsonObject.get("systemUserCode"));
String orgType = Util.null2String(jsonObject.get("orgType"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String staffName = Util.null2String(jsonObject.get("staffName"));
String actType = Util.null2String(jsonObject.get("actType"));
String sysUserId = Util.null2String(jsonObject.get("sysUserId"));
}
}
/***
*
* @param jsonArray
*/
public static void updasteSysRoleData(JSONArray jsonArray) {
RecordSet rs = new RecordSet();
//{"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},
// "svcCode":"70300100030001","requestObject":[{"content":
// [{"updateDate":"2022-07-22 10:51:29","staffCode":"0009000380","orgName":"merchantLF",
// "sysPostId":"0","statusCd":"1000","relType":"1100",
// "systemUserCode":"0009000380","orgId":"9000331",
// "createStaff":"9000377",
// "sysUserPostId":"122952","orgType":"2400",
// "systemUserName":"liaofei",
// "orgCode":"GAM9000331","staffName":"liaofei","actType":"A","sysUserId":"20051",
// "staffId":9000380,"createDate":"2022-07-22 10:51:29"}],"tableName":"system_user_post","primaryKey":"sysUserPostId"}],"key":"svcCont"}
for (int i = 0; i < jsonArray.size(); i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String staffCode = Util.null2String(jsonObject.get("staffCode"));
String orgName = Util.null2String(jsonObject.get("orgName"));
String sysPostId = Util.null2String(jsonObject.get("sysPostId"));
String relType = Util.null2String(jsonObject.get("relType"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String systemUserCode = Util.null2String(jsonObject.get("systemUserCode"));
String orgType = Util.null2String(jsonObject.get("orgType"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String staffName = Util.null2String(jsonObject.get("staffName"));
String actType = Util.null2String(jsonObject.get("actType"));
String sysUserId = Util.null2String(jsonObject.get("sysUserId"));
}
}
/***
*
* @param jsonArray
*/
public static void updasteSysPostData(JSONArray jsonArray) {
RecordSet rs = new RecordSet();
//{"authenticationInfo":{"sysUserPostId":"37484","sysUserId":"1","key":"authenticationInfo"},
// "svcCode":"70300100030001","requestObject":[{"content":
// [{"updateDate":"2022-07-22 10:51:29","staffCode":"0009000380","orgName":"merchantLF",
// "sysPostId":"0","statusCd":"1000","relType":"1100",
// "systemUserCode":"0009000380","orgId":"9000331",
// "createStaff":"9000377",
// "sysUserPostId":"122952","orgType":"2400",
// "systemUserName":"liaofei",
// "orgCode":"GAM9000331","staffName":"liaofei","actType":"A","sysUserId":"20051",
// "staffId":9000380,"createDate":"2022-07-22 10:51:29"}],"tableName":"system_user_post","primaryKey":"sysUserPostId"}],"key":"svcCont"}
for (int i = 0; i < jsonArray.size(); i++)
{
JSONObject jsonObject = jsonArray.getJSONObject(i);
String updateDate = Util.null2String(jsonObject.get("updateDate"));
String staffCode = Util.null2String(jsonObject.get("staffCode"));
String orgName = Util.null2String(jsonObject.get("orgName"));
String sysPostId = Util.null2String(jsonObject.get("sysPostId"));
String relType = Util.null2String(jsonObject.get("relType"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String systemUserCode = Util.null2String(jsonObject.get("systemUserCode"));
String orgType = Util.null2String(jsonObject.get("orgType"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String staffName = Util.null2String(jsonObject.get("staffName"));
String actType = Util.null2String(jsonObject.get("actType"));
String sysUserId = Util.null2String(jsonObject.get("sysUserId"));
}
}
public void removeCache(){
ResourceComInfo resComInfo;
DepartmentComInfo deptComInfo;
try {
resComInfo = new ResourceComInfo();
resComInfo.removeResourceCache();
deptComInfo = new DepartmentComInfo();
deptComInfo.removeCompanyCache();
} catch (Exception e) {
new BaseBean().writeLog(e);
}
}
}

215
src/weaver/interfaces/qt/SymOrgUserData.java
Unescape Escape View File

@ -1,215 +0,0 @@
package weaver.interfaces.qt;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import weaver.conn.RecordSet;
import weaver.general.Util;
public class SymOrgUserData {
public static void main(String[] args) {
String data = "{\n" +
" \"authenticationInfo\":{\n" +
" \"sysUserPostId\":\"37484\",\n" +
" \"sysUserId\":\"1\",\n" +
" \"key\":\"authenticationInfo\"\n" +
" },\n" +
" \"svcCode\":\"70300100030001\",\n" +
" \"requestObject\":[\n" +
" {\n" +
" \"content\":[\n" +
" {\n" +
" \"statusDate\":\"2022-03-17 11:08:18\",\n" +
" \"updateDate\":\"2022-07-14 01:00:04\",\n" +
" \"regionNbr\":\"1\",\n" +
" \"expDate\":\"2999-12-31 23:59:59\",\n" +
" \"userOrgId\":\"4\",\n" +
" \"password\":\"{bcrypt}$2a$10$cx6phvPFoHihrx3W1esWDObkQe3nh4rRknEEKd7yOO6PgxdpaNq/m\",\n" +
" \"effDate\":\"2020-04-22 14:24:41\",\n" +
" \"orgCode\":\"AGG000004\",\n" +
" \"staffName\":\"yueyy008\",\n" +
" \"pwdNewtime\":\"2020-04-22 14:24:41\",\n" +
" \"pwdContinErrCnt\":\"1\",\n" +
" \"actType\":\"M\",\n" +
" \"sysUserId\":\"2003\",\n" +
" \"createDate\":\"2020-04-22 14:24:42\",\n" +
" \"staffCode\":\"yueyy008\",\n" +
" \"sysUserCode\":\"yueyy008\",\n" +
" \"pwdErrCnt\":\"1\",\n" +
" \"pwdEffectDays\":\"90\",\n" +
" \"statusCd\":\"1000\",\n" +
" \"systemInfoId\":\"2034\",\n" +
" \"userName\":\"yueyy008\",\n" +
" \"createStaff\":\"1\",\n" +
" \"pwdStatus\":\"1200\",\n" +
" \"regionId\":\"731\",\n" +
" \"pwdSmsTel\":\"666666666\",\n" +
" \"staffId\":\"2003\"\n" +
" }\n" +
" ],\n" +
" \"tableName\":\"system_user\",\n" +
" \"primaryKey\":\"sysUserId\"\n" +
" }\n" +
" ],\n" +
" \"key\":\"svcCont\"\n" +
"}" ;
JSONObject jsonObject = JSONObject.parseObject(data);
if(jsonObject.containsKey("requestObject")){
JSONArray requestArray = jsonObject.getJSONArray("requestObject");
for(int i=0;i<requestArray.size();i++){
JSONObject requestObject = requestArray.getJSONObject(i);
System.out.println(requestObject.toJSONString());
if(!requestObject.isEmpty()){
if(requestObject.containsKey("tableName") && requestObject.containsKey("content")){
String tableName = requestObject.getString("tableName");
// if("system_user".equals(tableName)){
// JSONArray jsonArray = requestObject.getJSONArray("content");
// updateSysUserData2(jsonArray);
// }
System.out.println("tableName:"+tableName);
if("Organization".equals(tableName)){
System.out.println("");
}
}
}
}
}
}
public static void updateSysUserData(JSONArray jsonArray){
RecordSet rs = new RecordSet();
for(int i=0;i<jsonArray.size();i++){
JSONObject jsonObject = jsonArray.getJSONObject(i);
String userOrgId = Util.null2String(jsonObject.get("userOrgId"));
String orgCode = Util.null2String(jsonObject.get("orgCode"));
String staffName = Util.null2String(jsonObject.get("staffName"));
String actType = Util.null2String(jsonObject.get("actType"));
String sysUserId = Util.null2String(jsonObject.get("sysUserId"));
String email = Util.null2String(jsonObject.get("email"));
String staffCode = Util.null2String(jsonObject.get("staffCode"));
String sysUserCode = Util.null2String(jsonObject.get("sysUserCode"));
String userName = Util.null2String(jsonObject.get("userName"));
String pwdSmsTel = Util.null2String(jsonObject.get("pwdSmsTel"));
String staffId = Util.null2String(jsonObject.get("staffId"));
String statusCd = Util.null2String(jsonObject.get("statusCd"));
String status = "1";
if("1100".equals(status) || "1200".equals(status) || "1300".equals(status)){
status = "5";
}
String deptId = "";
if(!"".equals(orgCode)){
String sql = " select id from hrmdepartment where department = ? and departmentcode = ?" ;
rs.executeUpdate(sql,new Object[]{staffCode});
if(rs.next()){
deptId = Util.null2String(rs.getString("id"));
}
}
String subcompanyid1 = "" ;
String creator = "1";
String jobTitleId = "1";
String currentDate = "" ;
System.out.println("status:"+status);
String loginid = "";
String sql = " select loginid from hrmresource where workcode=?" ;
rs.executeUpdate(sql,new Object[]{staffCode});
if(rs.next()){
loginid = Util.null2String(rs.getString("loginid"));
}
if(!"".equals(deptId))
{
if(!"".equals(loginid))
{
if("M".equalsIgnoreCase(actType))
{
String userUpdateSql1 = " update hrmresource set lastname=?,departmentid=?,subcompanyid1=?," +
" creater=?,email=?,mobile=?,jobtitle=?,status=?,dsporder=?,lastmoddate=?,modified=systimestamp where workcode=? ";
boolean flag = rs.executeUpdate(userUpdateSql1,new Object[]{staffName,deptId,subcompanyid1,creator,email,
pwdSmsTel,jobTitleId,status,sysUserId,currentDate,staffCode});
}
}else{
if("A".equalsIgnoreCase(actType))
{
String userInsertSql = " insert into hrmresource(loginid,workcode,lastname,departmentid,subcompanyid1," +
" creater,email,mobile,jobtitle,status,dsporder,systemlanguage,createdate,lastmoddate,created,modified) " +
" values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,systimestamp,systimestamp)";
boolean flag = rs.executeUpdate(userInsertSql,new Object[]{staffCode,staffCode,staffName,deptId,subcompanyid1,
creator,email,pwdSmsTel,jobTitleId,status,sysUserId,7,currentDate,currentDate});
}
}
}
}
}
public static void updasteSysOrgData(String data){
JSONObject jsonObject = JSONObject.parseObject(data);
if(jsonObject.containsKey("requestObject")){
JSONArray requestArray = jsonObject.getJSONArray("requestObject");
for(int i=0;i<requestArray.size();i++){
JSONObject requestObject = requestArray.getJSONObject(i);
System.out.println(requestObject.toJSONString());
if(!requestObject.isEmpty()){
if(requestObject.containsKey("tableName") && requestObject.containsKey("content")){
String tableName = requestObject.getString("tableName");
if("system_user".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updateSysUserData2(jsonArray,data);
}else if("system_user_post".equals(tableName)){
JSONArray jsonArray = requestObject.getJSONArray("content");
updateSysUserPosta2(jsonArray,data);
}else if("organization".equalsIgnoreCase(tableName)){
System.out.println("data:"+data);
}else{
System.out.println("data:"+data);
}
}
}
}
}
}
public static void updateSysUserData2(JSONArray jsonArray,String data){
for(int i=0;i<jsonArray.size();i++) {
JSONObject jsonObject = jsonArray.getJSONObject(i);
String actType = Util.null2String(jsonObject.get("actType"));
if(!"M".equalsIgnoreCase(actType)){
System.out.println("actType:"+actType);
System.out.println("data:"+data);
}
}
}
public static void updateSysUserPosta2(JSONArray jsonArray,String data){
for(int i=0;i<jsonArray.size();i++) {
JSONObject jsonObject = jsonArray.getJSONObject(i);
String actType = Util.null2String(jsonObject.get("actType"));
if(!"M".equalsIgnoreCase(actType)){
System.out.println("actType:"+actType);
System.out.println("data:"+data);
}
}
}
}
Write Preview
Loading…
Cancel
Save