@ -14,6 +14,7 @@ import weaver.hrm.company.DepartmentComInfo;
import weaver.hrm.resource.ResourceComInfo ;
import weaver.hrm.roles.RolesComInfo ;
import weaver.interfaces.dito.comInfo.PropBean ;
import weaver.systeminfo.systemright.CheckUserRight ;
import java.text.SimpleDateFormat ;
import java.util.* ;
@ -190,30 +191,33 @@ public class RocketmqUtil {
boolean flag = rs . executeUpdate ( userUpdateSql , new Object [ ] { lastname , deptId , subcompanyid1 , creator , email ,
pwdSmsTel , jobTitleId , status , loginedNum , currentDate , currentDateTime , staffCode } ) ;
bb . writeLog ( "flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "人员信息更新sql执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData ( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "人员信息更新sql执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else if ( "D" . equals ( actType ) ) {
status = "5" ;
String userUpdateSql = " update hrmresource set status=? where workcode=? " ;
bb . writeLog ( "userUpdateSql:" + userUpdateSql ) ;
boolean flag = rs . executeUpdate ( userUpdateSql , new Object [ ] { status , staffCode } ) ;
bb . writeLog ( "flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "人员离职更新sql执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "人员离职更新sql执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
@ -244,14 +248,16 @@ public class RocketmqUtil {
creator , email , pwdSmsTel , jobTitleId , status , loginedNum , systemlanguage , currentDate , currentDate , currentDateTime , currentDateTime ,
locationid , seclevel , createrid , lastmodid } ) ;
bb . writeLog ( "flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "人员新增sql执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "人员新增sql执行成功" ) ;
}
recordErrorData ( dataMap ) ;
}
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
@ -357,14 +363,16 @@ public class RocketmqUtil {
bb . writeLog ( "deptUpdateSql:" + deptUpdateSql ) ;
boolean flag = rs . executeUpdate ( deptUpdateSql , new Object [ ] { departmentmark , departmentmark , subcompanyid1 , orgId , supdepid , orgCode } ) ;
bb . writeLog ( "flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "更新部门SQL语句执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "更新部门SQL语句执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else if ( "D" . equalsIgnoreCase ( actType ) )
{
canceled = "1" ;
@ -382,15 +390,16 @@ public class RocketmqUtil {
bb . writeLog ( "deptUpdateSql:" + deptUpdateSql ) ;
boolean flag = rs . executeUpdate ( deptUpdateSql , new Object [ ] { departmentmark , departmentmark , canceled , subcompanyid1 , orgId , supdepid , orgCode } ) ;
bb . writeLog ( "flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "封存部门SQL语句执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData ( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "封存部门SQL语句执行成功" ) ;
}
recordErrorData ( dataMap ) ;
}
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
@ -407,14 +416,16 @@ public class RocketmqUtil {
bb . writeLog ( "deptInsertSql:" + deptInsertSql ) ;
boolean flag = rs . executeUpdate ( deptInsertSql , new Object [ ] { departmentmark , departmentmark , orgCode , subcompanyid1 , supdepid , orgId } ) ;
bb . writeLog ( "flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "新增部门SQL语句执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "新增部门SQL语句执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
@ -530,7 +541,7 @@ public class RocketmqUtil {
if ( StringUtils . isNotEmpty ( roleCode ) ) {
String queryRoleIdSql = " select id from hrmroles where ecology_pinyin_search=?";
String queryRoleIdSql = " select id from hrmroles where ecology_pinyin_search=?";
rs . executeQuery ( queryRoleIdSql , new Object [ ] { roleCode } ) ;
if ( rs . next ( ) ) {
roleId = rs . getString ( "id" ) ;
@ -552,14 +563,16 @@ public class RocketmqUtil {
String delHrmrolemembersSql = " delete from hrmrolemembers where id = ?" ;
boolean flag = rs . executeUpdate ( delHrmrolemembersSql , releationId ) ;
bb . writeLog ( "delHrmrolemembersSql : " + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "角色成员新增失败" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "角色成员新增成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
@ -573,14 +586,16 @@ public class RocketmqUtil {
String insertHrmrolemembersSql = "insert into hrmrolemembers(roleid,resourceid,rolelevel,resourcetype,uuid) values(?,?,?,?,?)" ;
boolean flag = rs . executeUpdate ( insertHrmrolemembersSql , new Object [ ] { roleId , userId , rolelevel , resourcetype , UUID . randomUUID ( ) . toString ( ) } ) ;
bb . writeLog ( "insertHrmrolemembersSql : " + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "角色成员新增失败" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "角色成员新增成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
@ -611,6 +626,11 @@ public class RocketmqUtil {
RolemembersComInfo RolemembersComInfo = new RolemembersComInfo ( ) ;
RolemembersComInfo . removeCache ( ) ;
CheckUserRight CheckUserRight = new CheckUserRight ( ) ;
CheckUserRight . removeMemberRoleCache ( ) ;
CheckUserRight . removeRoleRightdetailCache ( ) ;
}
@ -645,6 +665,7 @@ public class RocketmqUtil {
String systemUserCode = Util . null2String ( jsonObject . get ( "systemUserCode" ) ) ;
String orgCode = Util . null2String ( jsonObject . get ( "orgCode" ) ) ;
String actType = Util . null2String ( jsonObject . get ( "actType" ) ) ;
String defaultFlag = Util . null2String ( jsonObject . get ( "defaultFlag" ) ) ;
String currentDateTime = TimeUtil . getCurrentTimeString ( ) ; //当前时间
String updateStaff = Util . null2String ( jsonObject . get ( "updateStaff" ) ) ;
if ( StringUtils . isEmpty ( updateStaff ) ) {
@ -685,32 +706,39 @@ public class RocketmqUtil {
{
if ( "A" . equals ( actType ) | | "M" . equals ( actType ) )
{
String updateUserJobSql = " update hrmresource set jobtitle=?,modified=?,modifier=? where id=? " ;
bb . writeLog ( "updateUserJobSql:" + updateUserJobSql ) ;
boolean flag = rs . executeUpdate ( updateUserJobSql , new Object [ ] { jobtitlesId , currentDateTime , updateStaff , userId } ) ;
bb . writeLog ( " updateUserJobFlag: " + flag ) ;
if ( ! flag ) {
//当岗位为主岗位时才更新, 1: 主岗位
if ( "1" . equals ( defaultFlag ) ) {
String updateUserJobSql = " update hrmresource set jobtitle=?,modified=?,modifier=? where id=? " ;
bb . writeLog ( "updateUserJobSql:" + updateUserJobSql ) ;
boolean flag = rs . executeUpdate ( updateUserJobSql , new Object [ ] { jobtitlesId , currentDateTime , updateStaff , userId } ) ;
bb . writeLog ( " updateUserJobFlag: " + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "更新人员岗位sql执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
dataMap . put ( "errmessage" , "更新人员岗位sql执行错误" ) ;
} else {
dataMap . put ( "errmessage" , "更新人员岗位sql执行成功" ) ;
}
recordErrorData ( dataMap ) ;
}
} else if ( "D" . equals ( actType ) ) {
jobtitlesId = "" ;
jobtitlesId = null ;
String updateUserJobSql = " update hrmresource set jobtitle=?,modified=?,modifier=? where id=? " ;
bb . writeLog ( "updateUserJobSql:" + updateUserJobSql ) ;
boolean flag = rs . executeUpdate ( updateUserJobSql , new Object [ ] { jobtitlesId , currentDateTime , updateStaff , userId } ) ;
bb . writeLog ( " updateUserJobFlag: " + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "删除人员岗位sql执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "删除人员岗位sql执行成功" ) ;
}
recordErrorData ( dataMap ) ;
}
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
@ -815,14 +843,16 @@ public class RocketmqUtil {
String updateHrmrolesSql = " update hrmroles set rolesmark=?,rolesname=? where id=?" ;
boolean flag = rs . executeUpdate ( updateHrmrolesSql , new Object [ ] { sysRoleName , sysRoleName , rolesid } ) ;
bb . writeLog ( "updateHrmroles : " + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "系统角色更新SQL执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "系统角色更新SQL执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else if ( "D" . equals ( actType ) ) {
int membercount = 0 ;
String queryHrmRolesSql = " select id from hrmrolemembers where roleid = ?" ;
@ -833,14 +863,16 @@ public class RocketmqUtil {
if ( membercount = = 0 ) {
String deleteHrmRolesSql = " delete from hrmroles where id = ?" ;
boolean flag = rs . executeUpdate ( deleteHrmRolesSql , rolesid ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "系统角色删除SQL执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "系统角色删除SQL执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
@ -862,14 +894,16 @@ public class RocketmqUtil {
String insertHrmrolesSql = " insert into hrmroles(rolesmark,rolesname,type,subcompanyid,ecology_pinyin_search,uuid) values(?,?,?,?,?,?)" ;
boolean flag = rs . executeUpdate ( insertHrmrolesSql , new Object [ ] { rolesmark , rolesname , type , subcompanyid , sysRoleCode , uuid } ) ;
bb . writeLog ( "insertHrmroles : " + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "新增系统角色SQL执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "新增系统角色SQL执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
@ -1002,27 +1036,31 @@ public class RocketmqUtil {
String updateHrmjobactivitiesSql = "update hrmjobtitles set jobtitlemark=?,jobtitlename=?,modified=?,modifier=? where id=?" ;
boolean flag = rs . executeUpdate ( updateHrmjobactivitiesSql , new Object [ ] { jobtitlemark , jobtitlename , modified , modifier , jobtitleid } ) ;
bb . writeLog ( "insertHrmjobactivitiesSql flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "系统岗位更新SQL执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "系统岗位更新SQL执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else if ( "D" . equals ( actType ) ) {
String canceled = "1" ;
String updateHrmjobactivitiesSql = "update hrmjobtitles set jobtitlemark=?,jobtitlename=?,modified=?,modifier=?,canceled = ? where id=?" ;
boolean flag = rs . executeUpdate ( updateHrmjobactivitiesSql , new Object [ ] { jobtitlemark , jobtitlename , modified , modifier , canceled , jobtitleid } ) ;
bb . writeLog ( "insertHrmjobactivitiesSql flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "系统岗位封存SQL执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "系统岗位封存SQL执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
@ -1037,14 +1075,16 @@ public class RocketmqUtil {
String insertHrmjobactivitiesSql = " insert into hrmjobtitles(jobtitlemark,jobtitlename,jobactivityid,jobdepartmentid,jobtitlecode,created,creater,modified,modifier,uuid) values(?,?,?,?,?,?,?,?,?,?)" ;
boolean flag = rs . executeUpdate ( insertHrmjobactivitiesSql , new Object [ ] { jobtitlemark , jobtitlename , jobactivitiesid , departmentId , sysPostCode , created , creater , modified , modifier , uuid } ) ;
bb . writeLog ( "insertHrmjobactivitiesSql flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "系统岗位新增SQL执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "系统岗位新增SQL执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
@ -1089,8 +1129,10 @@ public class RocketmqUtil {
String lastmodid = "1" ;
String creator = "1" ;
String systemlanguage = "8" ;
String pwd = "1" ;
String pwd = PropBean . getUfPropValue ( "user_pwd" ) ;
String password = DigestUtils . md5Hex ( pwd ) . toUpperCase ( ) ; //MD5加密
bb . writeLog ( "password:" + password ) ;
String scopeid = "-1" ;
String scope = "HrmCustomFieldByInfoType" ;
@ -1176,28 +1218,32 @@ public class RocketmqUtil {
bb . writeLog ( "userUpdateSql:" + userUpdateSql ) ;
boolean flag = rs . executeUpdate ( userUpdateSql , new Object [ ] { lastname , deptId , subcompanyid1 , creator , email , pwdSmsTel , jobTitleId , status , loginedNum , currentDate , currentDateTime , staffCode } ) ;
bb . writeLog ( "flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "人员更新SQL执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "人员更新SQL执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else if ( "D" . equals ( actType ) ) {
status = "5" ;
String userUpdateSql = " update hrmresource set status=? where workcode=? " ;
bb . writeLog ( "userUpdateSql:" + userUpdateSql ) ;
boolean flag = rs . executeUpdate ( userUpdateSql , new Object [ ] { status , staffCode } ) ;
bb . writeLog ( "flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "人员离职SQL执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "人员离职SQL执行成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
@ -1225,16 +1271,17 @@ public class RocketmqUtil {
creator , email , pwdSmsTel , jobTitleId , status , loginedNum , systemlanguage , currentDate , currentDate , currentDateTime , currentDateTime ,
locationid , seclevel , createrid , lastmodid } ) ;
bb . writeLog ( "flag:" + flag ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( flag ) {
userid = id + "" ;
dataMap . put ( "errmessage" , "人员新增SQL执行成功" ) ;
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "人员新增SQL执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData ( dataMap ) ;
}
recordErrorData ( dataMap ) ;
}
} else {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
@ -1258,26 +1305,30 @@ public class RocketmqUtil {
String cusUpdateSql = " update cus_fielddata set " + cus_staff + "=?," + cus_eid + "=? where scope=? and scopeid=? and id=?" ;
bb . writeLog ( cusUpdateSql ) ;
boolean deflag = rs . executeUpdate ( cusUpdateSql , new Object [ ] { staffId , eId , scope , scopeid , userid } ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! deflag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "更新人员自定义信息失败" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "更新人员自定义信息成功" ) ;
}
recordErrorData ( dataMap ) ;
} else {
String cusInsertSql = " insert into cus_fielddata(scope,scopeid,id," + cus_staff + "," + cus_eid + ") values(?,?,?,?,?)" ;
bb . writeLog ( cusInsertSql ) ;
boolean deflag = rs . executeUpdate ( cusInsertSql , new Object [ ] { scope , scopeid , userid , staffId , eId } ) ;
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "systable" , tableName ) ;
if ( ! deflag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , nowDateTime ) ;
dataMap . put ( "reqmessage" , jsonObject . toJSONString ( ) ) ;
dataMap . put ( "errmessage" , "新增人员自定义信息失败" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData( dataMap ) ;
} else {
dataMap . put ( "errmessage" , "新增人员自定义信息成功" ) ;
}
recordErrorData ( dataMap ) ;
}
}
} else {