@ -2,6 +2,8 @@ package com.engine.dito.excel.cmd;
import com.alibaba.fastjson.JSONObject ;
import org.apache.commons.lang3.StringUtils ;
import org.slf4j.Logger ;
import org.slf4j.LoggerFactory ;
import weaver.conn.RecordSet ;
import weaver.formmode.setup.ModeRightInfo ;
import weaver.general.BaseBean ;
@ -14,13 +16,13 @@ import java.util.*;
public class ImportExcelUserPostUtil {
private final static Logger logger = LoggerFactory . getLogger ( ImportExcelPostUtil . class ) ;
/ * * *
*
* @param datalists
* /
public Map < String , String > operatePostExcel ( List < Map < String , String > > datalists )
{
public Map < String , String > operatePostExcel ( List < Map < String , String > > datalists ) {
int scount = 0 ;
int fcount = 0 ;
int ecount = 0 ;
@ -31,16 +33,14 @@ public class ImportExcelUserPostUtil {
String updateStaff = "1" ;
String tableName = "system_user_post" ;
for ( int i = 0 ; i < datalists . size ( ) ; i + + )
{
try {
for ( int i = 0 ; i < datalists . size ( ) ; i + + ) {
try {
Map < String , String > m = datalists . get ( i ) ;
String SYS_POST_CODE = Util . null2String ( m . get ( "sys_post_code" ) ) ;
String SYS_USER_CODE = Util . null2String ( m . get ( "sys_user_code" ) ) ;
String jobtitlesId = "" ;
if ( StringUtils . isNotEmpty ( SYS_POST_CODE ) )
{
String jobtitlesId = "" ;
if ( StringUtils . isNotEmpty ( SYS_POST_CODE ) ) {
String queryRoleIdSql = " select id from hrmjobtitles where jobtitlecode=? " ;
bb . writeLog ( "queryRoleIdSql:" + queryRoleIdSql ) ;
rs . executeQuery ( queryRoleIdSql , new Object [ ] { SYS_POST_CODE } ) ;
@ -49,9 +49,8 @@ public class ImportExcelUserPostUtil {
}
}
String userId = "" ;
if ( StringUtils . isNotEmpty ( SYS_USER_CODE ) )
{
String userId = "" ;
if ( StringUtils . isNotEmpty ( SYS_USER_CODE ) ) {
String sql = " select id from hrmresource where workcode=?" ;
bb . writeLog ( "sql:" + sql ) ;
rs . executeQuery ( sql , new Object [ ] { SYS_USER_CODE } ) ;
@ -60,29 +59,28 @@ public class ImportExcelUserPostUtil {
}
}
if ( StringUtils . isNotEmpty ( userId ) )
{
if ( StringUtils . isNotEmpty ( userId ) ) {
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 ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , currentDateTime ) ;
bb . writeLog ( "updateUserJobSql:" + updateUserJobSql ) ;
boolean flag = rs . executeUpdate ( updateUserJobSql , new Object [ ] { jobtitlesId , currentDateTime , updateStaff , userId } ) ;
bb . writeLog ( " updateUserJobFlag: " + flag ) ;
if ( ! flag ) {
Map < String , String > dataMap = new HashMap < String , String > ( ) ;
dataMap . put ( "syndate" , currentDateTime ) ;
dataMap . put ( "reqmessage" , JSONObject . toJSONString ( m ) ) ;
dataMap . put ( "errmessage" , "更新人员岗位sql执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
dataMap . put ( "errmessage" , "更新人员岗位sql执行错误" ) ;
dataMap . put ( "systable" , tableName ) ;
recordErrorData ( dataMap ) ;
}
}
} catch ( Exception e ) {
} catch ( Exception e ) {
ecount + + ;
}
}
Map < String , String > map = new HashMap < String , String > ( ) ;
map . put ( "scount" , scount + "" ) ;
map . put ( "fcount" , fcount + "" ) ;
map . put ( "ecount" , ecount + "" ) ;
Map < String , String > map = new HashMap < String , String > ( ) ;
map . put ( "scount" , scount + "" ) ;
map . put ( "fcount" , fcount + "" ) ;
map . put ( "ecount" , ecount + "" ) ;
return map ;
}
@ -100,24 +98,21 @@ public class ImportExcelUserPostUtil {
* @param SYS_POST_DESC
* @return
* /
private boolean insertUserPost ( String SYS_POST_NAME , String creater , String created , String modified , String modifier , String sysPostCode , String departmentId , String SYS_POST_DESC ) {
private boolean insertUserPost ( String SYS_POST_NAME , String creater , String created , String modified , String modifier , String sysPostCode , String departmentId , String SYS_POST_DESC ) {
RecordSet rs = new RecordSet ( ) ;
String defaultJobActivityId = "" ;
String defaultJobActivityId = "" ;
String defaultJobActivityName = PropBean . getUfPropValue ( "defaultJobActivityName" ) ;
if ( StringUtils . isNotEmpty ( defaultJobActivityName ) )
{
String sql = " select * from hrmjobactivities where jobactivityname = ?" ;
rs . executeQuery ( sql , new Object [ ] { defaultJobActivityName } ) ;
if ( rs . next ( ) ) {
if ( StringUtils . isNotEmpty ( defaultJobActivityName ) ) {
String sql = " select * from hrmjobactivities where jobactivityname = ?" ;
rs . executeQuery ( sql , new Object [ ] { defaultJobActivityName } ) ;
if ( rs . next ( ) ) {
defaultJobActivityId = Util . null2String ( rs . getString ( "id" ) ) ;
}
if ( StringUtils . isEmpty ( defaultJobActivityId ) )
{
String defaultJobGroupsId = getDefaultJobGroupsId ( created , creater ) ;
if ( StringUtils . isNotEmpty ( defaultJobGroupsId ) )
{
defaultJobActivityId = getDefaultJobActivityId ( defaultJobActivityName , created , creater , defaultJobGroupsId ) ;
if ( StringUtils . isEmpty ( defaultJobActivityId ) ) {
String defaultJobGroupsId = getDefaultJobGroupsId ( created , creater ) ;
if ( StringUtils . isNotEmpty ( defaultJobGroupsId ) ) {
defaultJobActivityId = getDefaultJobActivityId ( defaultJobActivityName , created , creater , defaultJobGroupsId ) ;
}
}
}
@ -125,16 +120,16 @@ public class ImportExcelUserPostUtil {
boolean iflag = false ;
String jobtitlesid = "" ;
String sql = "select id from hrmjobtitles where jobtitlecode = ?" ;
rs . executeQuery ( sql , new Object [ ] { sysPostCode } ) ;
while ( rs . next ( ) ) {
rs . executeQuery ( sql , new Object [ ] { sysPostCode } ) ;
while ( rs . next ( ) ) {
jobtitlesid = Util . null2String ( rs . getString ( "id" ) ) ;
}
if ( StringUtils . isNotEmpty ( jobtitlesid ) ) {
if ( StringUtils . isNotEmpty ( jobtitlesid ) ) {
String updateHrmjobactivitiesSl = " update hrmjobtitles set jobtitlemark=?,jobtitlename=?,modified=?,modifier=? where id=?" ;
iflag = rs . executeUpdate ( updateHrmjobactivitiesSl , SYS_POST_DESC , SYS_POST_NAME , modified , modifier , jobtitlesid ) ;
iflag = rs . executeUpdate ( updateHrmjobactivitiesSl , SYS_POST_DESC , SYS_POST_NAME , modified , modifier , jobtitlesid ) ;
} else {
} else {
String uuid = UUID . randomUUID ( ) . toString ( ) ;
String insertHrmjobactivitiesSql = " insert into hrmjobtitles(jobtitlemark,jobtitlename,jobactivityid,jobdepartmentid,jobtitlecode,created,creater,modified,modifier,uuid) values(?,?,?,?,?,?,?,?,?,?)" ;
iflag = rs . executeUpdate ( insertHrmjobactivitiesSql , new Object [ ] { SYS_POST_DESC , SYS_POST_NAME , defaultJobActivityId , departmentId , sysPostCode , created , creater , modified , modifier , uuid } ) ;
@ -151,8 +146,8 @@ public class ImportExcelUserPostUtil {
private Map < String , String > getSubcompanyid1 ( String ORG_ID ) {
Map < String , String > res = new HashMap < String , String > ( ) ;
RecordSet rs = new RecordSet ( ) ;
String sql = " select h.id,h.subcompanyid1 from hrmdepartmentdefined t inner join hrmdepartment h on h.id = t.deptid where t.orgid = ? " ;
rs . executeQuery ( sql , new Object [ ] { ORG_ID } ) ;
String sql = " select h.id,h.subcompanyid1 from hrmdepartmentdefined t inner join hrmdepartment h on h.id = t.deptid where t.orgid = ? " ;
rs . executeQuery ( sql , new Object [ ] { ORG_ID } ) ;
if ( rs . next ( ) ) {
String deptid = Util . null2String ( rs . getString ( "id" ) ) ;
String subcompanyid1 = Util . null2String ( rs . getString ( "subcompanyid1" ) ) ;
@ -167,62 +162,58 @@ public class ImportExcelUserPostUtil {
*
* @return
* /
public String getDefaultJobGroupsId ( String created , String creater ) {
public String getDefaultJobGroupsId ( String created , String creater ) {
RecordSet rs = new RecordSet ( ) ;
String defaultJobGroupsId = "" ;
try {
String defaultJobGroupsId = "" ;
try {
String defaultJobGroupsName = PropBean . getUfPropValue ( "defaultJobGroupsName" ) ;
if ( StringUtils . isNotEmpty ( defaultJobGroupsName ) )
{
String sql = " select id from hrmjobgroups where jobgroupname = ?" ;
rs . executeQuery ( sql , new Object [ ] { defaultJobGroupsName } ) ;
if ( rs . next ( ) ) {
if ( StringUtils . isNotEmpty ( defaultJobGroupsName ) ) {
String sql = " select id from hrmjobgroups where jobgroupname = ?" ;
rs . executeQuery ( sql , new Object [ ] { defaultJobGroupsName } ) ;
if ( rs . next ( ) ) {
defaultJobGroupsId = Util . null2String ( rs . getString ( "id" ) ) ;
}
if ( StringUtils . isEmpty ( defaultJobGroupsId ) )
{
if ( StringUtils . isEmpty ( defaultJobGroupsId ) ) {
String uuid = UUID . randomUUID ( ) . toString ( ) ;
sql = " insert into hrmjobgroups(jobgroupname,jobgroupremark,created,creater,uuid) values(?,?,?,?,?) " ;
boolean flag = rs . executeUpdate ( sql , new Object [ ] { defaultJobGroupsName , defaultJobGroupsName , created , creater , uuid } ) ;
if ( flag ) {
sql = " select id from hrmjobgroups where jobgroupname = ?" ;
rs . executeQuery ( sql , new Object [ ] { defaultJobGroupsName } ) ;
if ( rs . next ( ) ) {
boolean flag = rs . executeUpdate ( sql , new Object [ ] { defaultJobGroupsName , defaultJobGroupsName , created , creater , uuid } ) ;
if ( flag ) {
sql = " select id from hrmjobgroups where jobgroupname = ?" ;
rs . executeQuery ( sql , new Object [ ] { defaultJobGroupsName } ) ;
if ( rs . next ( ) ) {
defaultJobGroupsId = Util . null2String ( rs . getString ( "id" ) ) ;
}
}
}
}
} catch ( Exception e ) {
} catch ( Exception e ) {
}
return defaultJobGroupsId ;
}
/ * *
*
* @return
* /
public String getDefaultJobActivityId ( String defaultJobActivityName , String created , String creater , String defaultJobGroupsId ) {
public String getDefaultJobActivityId ( String defaultJobActivityName , String created , String creater , String defaultJobGroupsId ) {
RecordSet rs = new RecordSet ( ) ;
String defaultJobActivityId = "" ;
try {
if ( StringUtils . isNotEmpty ( defaultJobActivityName ) )
{
String defaultJobActivityId = "" ;
try {
if ( StringUtils . isNotEmpty ( defaultJobActivityName ) ) {
String uuid = UUID . randomUUID ( ) . toString ( ) ;
String sql = " insert into hrmjobactivities(jobactivitymark,jobactivityname,jobgroupid,created,creater,uuid) values(?,?,?,?,?,?) " ;
boolean flag = rs . executeUpdate ( sql , new Object [ ] { defaultJobActivityName , defaultJobActivityName , defaultJobGroupsId , created , creater , uuid } ) ;
if ( flag ) {
sql = " select id from hrmjobgroups where jobgroupname = ?" ;
rs . executeQuery ( sql , new Object [ ] { defaultJobActivityName } ) ;
if ( rs . next ( ) ) {
boolean flag = rs . executeUpdate ( sql , new Object [ ] { defaultJobActivityName , defaultJobActivityName , defaultJobGroupsId , created , creater , uuid } ) ;
if ( flag ) {
sql = " select id from hrmjobgroups where jobgroupname = ?" ;
rs . executeQuery ( sql , new Object [ ] { defaultJobActivityName } ) ;
if ( rs . next ( ) ) {
defaultJobActivityId = Util . null2String ( rs . getString ( "id" ) ) ;
}
}
}
} catch ( Exception e ) {
} catch ( Exception e ) {
}
return defaultJobActivityId ;
@ -233,66 +224,64 @@ public class ImportExcelUserPostUtil {
*
* @param dataMap
* /
public void recordErrorData ( Map < String , String > dataMap ) {
public void recordErrorData ( Map < String , String > dataMap ) {
String uftable = "uf_orgmq" ;
String uftable = "uf_orgmq" ;
RecordSet rs = new RecordSet ( ) ;
BaseBean bb = new BaseBean ( ) ;
ModeRightInfo mode = new ModeRightInfo ( ) ;
ModeRightInfo mode = new ModeRightInfo ( ) ;
SimpleDateFormat sdf1 = new SimpleDateFormat ( "yyyy-MM-dd" ) ; //当前时间日期
SimpleDateFormat sdf2 = new SimpleDateFormat ( "HH:mm:ss" ) ;
int formmodeid = 0 ;
String modedatacreater = "1" ;
String modedatacreatertype = "0" ;
int formmodeid = 0 ;
String modedatacreater = "1" ;
String modedatacreatertype = "0" ;
String modedatacreatedate = sdf1 . format ( new Date ( ) ) ;
String modedatacreatetime = sdf2 . format ( new Date ( ) ) ;
String uuid = UUID . randomUUID ( ) . toString ( ) ;
try {
String sql = " select k.id from modeinfo k \n" +
String sql = " select k.id from modeinfo k \n" +
" inner join workflow_bill l on formid = l.id\n" +
" where l.tablename = ? " ;
rs . executeQuery ( sql , new Object [ ] { uftable } ) ;
if ( rs . next ( ) ) {
" where l.tablename = ? " ;
rs . executeQuery ( sql , new Object [ ] { uftable } ) ;
if ( rs . next ( ) ) {
formmodeid = Util . getIntValue ( Util . null2String ( rs . getString ( "id" ) ) ) ;
}
String syndate = Util . null2String ( dataMap . get ( "syndate" ) ) ;
String reqmessage = Util . null2String ( dataMap . get ( "reqmessage" ) ) ;
String errmessage = Util . null2String ( dataMap . get ( "errmessage" ) ) ;
String systable = Util . null2String ( dataMap . get ( "systable" ) ) ;
String syndate = Util . null2String ( dataMap . get ( "syndate" ) ) ;
String reqmessage = Util . null2String ( dataMap . get ( "reqmessage" ) ) ;
String errmessage = Util . null2String ( dataMap . get ( "errmessage" ) ) ;
String systable = Util . null2String ( dataMap . get ( "systable" ) ) ;
int bool = 0 ;
sql = " insert into " + uftable + "(uuid,formmodeid,modedatacreater,modedatacreatertype,modedatacreatedate,modedatacreatetime,syndate,reqmessage,errmessage,systable)" +
" values(?,?,?,?,?,?,?,?,?,?)" ;
boolean flag = rs . executeUpdate ( sql , new Object [ ] { uuid , formmodeid , modedatacreater , modedatacreatertype , modedatacreatedate , modedatacreatetime , syndate , reqmessage , errmessage , systable } ) ;
bb . writeLog ( "sql;" + sql ) ;
if ( flag ) {
sql = " insert into " + uftable + "(uuid,formmodeid,modedatacreater,modedatacreatertype,modedatacreatedate,modedatacreatetime,syndate,reqmessage,errmessage,systable)" +
" values(?,?,?,?,?,?,?,?,?,?)" ;
boolean flag = rs . executeUpdate ( sql , new Object [ ] { uuid , formmodeid , modedatacreater , modedatacreatertype , modedatacreatedate , modedatacreatetime , syndate , reqmessage , errmessage , systable } ) ;
bb . writeLog ( "sql;" + sql ) ;
if ( flag ) {
bool + + ;
}
bb . writeLog ( "bool;" + bool ) ;
if ( bool > 0 )
{
bb . writeLog ( "bool;" + bool ) ;
if ( bool > 0 ) {
String dataid = "" ;
sql = " select * from " + uftable + " where uuid=? " ;
sql = " select * from " + uftable + " where uuid=? " ;
bb . writeLog ( "sql:" + sql ) ;
rs . executeQuery ( sql , new Object [ ] { uuid } ) ;
rs . executeQuery ( sql , new Object [ ] { uuid } ) ;
if ( rs . next ( ) ) {
dataid = Util . null2String ( rs . getString ( "id" ) ) ;
}
bb . writeLog ( "sql:" + sql ) ;
bb . writeLog ( "dataid:" + dataid ) ;
bb . writeLog ( "modeid:" + formmodeid ) ;
if ( org . apache . commons . lang . StringUtils . isNotEmpty ( dataid ) )
{
if ( org . apache . commons . lang . StringUtils . isNotEmpty ( dataid ) ) {
mode . setNewRight ( true ) ;
mode . editModeDataShare ( Integer . valueOf ( modedatacreater ) , formmodeid , Integer . parseInt ( dataid ) ) ;
}
}
} catch ( Exception e ) {
bb . writeLog ( "e:" + e ) ;
} catch ( Exception e ) {
bb . writeLog ( "e:" + e ) ;
}
}
李栋
2 years ago