howec
/
sxjg_seconddev_e10
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

华康:获取人员信息列表

Browse Source
main
howec 1 year ago
parent ac8f288889
commit ed4baca120
2 changed files with 217 additions and 0 deletions
Show Stats Download Patch File Download Diff File

9
e9海康人员列表接口/src/com/api/haikangwh/hrm/web/UserInfoDetailIAction.java
Unescape Escape View File

@ -0,0 +1,9 @@
package com.api.haikangwh.hrm.web;
import com.engine.haikangwh.hrm.web.UserInfoDetailAction;
import javax.ws.rs.Path;
@Path("/haikang/user")
public class UserInfoDetailIAction extends UserInfoDetailAction {
}

208
e9海康人员列表接口/src/com/engine/haikangwh/hrm/web/UserInfoDetailAction.java
Unescape Escape View File

@ -0,0 +1,208 @@
package com.engine.haikangwh.hrm.web;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import io.swagger.v3.oas.annotations.parameters.RequestBody;
import org.apache.http.HttpResponse;
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.HttpClients;
import weaver.conn.RecordSet;
import weaver.file.ImageFileManager;
import weaver.general.Util;
import weaver.integration.logging.Logger;
import weaver.integration.logging.LoggerFactory;
import javax.servlet.http.HttpServletRequest;
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.io.*;
import static com.weaverboot.tools.logTools.LogTools.writeLog;
public class UserInfoDetailAction {
private final Logger log = LoggerFactory.getLogger(UserInfoDetailAction.class);
//测试
// private final static String CompanyID1 = "1521";
// private final static String photofieldName="field22";
//生产
private final static String CompanyID1 = "2021,521"; //外部,深圳骏友 不参与
private final static String photofieldName="field33"; //1寸白底照片 字段id
@POST
@Path("/getHrmUserInfoWithPage")
@Produces(MediaType.APPLICATION_JSON)
public JSONObject getHrmUserInfoWithPage(@Context HttpServletRequest request, @RequestBody JSONObject reqObj) {
JSONObject result = new JSONObject();
int curpage = 1;
int pagesize = 20;
int totalSize = 0;
if(reqObj.getString("curpage").length() > 0) {
curpage = Integer.parseInt(reqObj.getString("curpage"));
}
if(reqObj.getString("pagesize").length() > 0) {
pagesize = Integer.parseInt(reqObj.getString("pagesize"));
}
String workcode1 = "";
if(reqObj.getString("workcode").length() > 0) {
workcode1 = reqObj.getString("workcode");
}
int begin = (curpage-1)*pagesize;
String sqlcount = "";
RecordSet rs = new RecordSet();
RecordSet rscount = new RecordSet();
if(workcode1.length() > 0) {
sqlcount = "SELECT count(a.id) as sums FROM HRMRESOURCE a LEFT JOIN HrmStatusHistory b ON a.ID = b.RESOURCEID LEFT JOIN cus_fielddata c ON a.ID = c.ID AND c.scopeid = 3 WHERE" +
" 1 =1 and a.workcode = '"+workcode1+"' and a.subcompanyid1 not in ("+CompanyID1+")";
}else {
sqlcount = "SELECT count(a.id) as sums FROM HRMRESOURCE a LEFT JOIN HrmStatusHistory b ON a.ID = b.RESOURCEID LEFT JOIN cus_fielddata c ON a.ID = c.ID AND c.scopeid = 3 WHERE" +
" 1 =1 and a.subcompanyid1 not in ("+CompanyID1+")";
}
log.error(sqlcount);
rscount.executeQuery(sqlcount);
if(rscount.next()){
totalSize = rscount.getInt("sums");
log.error("sqlcount:"+totalSize);
}
JSONArray datalist = new JSONArray();
String sql = "";
if(workcode1.length() > 0) {
sql ="SELECT a.workcode, a.lastname, a.sex, a.departmentid, a.subcompanyid1, a.workstartdate, b.changedate, c."+photofieldName+", a.id aid, ROWNUM AS rn FROM HRMRESOURCE a LEFT JOIN HrmStatusHistory b ON a.ID = b.RESOURCEID LEFT JOIN cus_fielddata c ON a.ID = c.ID AND c.scopeid = 3 WHERE" +
" 1 = 1 and a.subcompanyid1 not in ("+CompanyID1+") and a.workcode = '"+workcode1+"' OFFSET "+begin+" ROWS FETCH NEXT "+pagesize+" ROWS ONLY";
}else {
sql ="SELECT a.workcode, a.lastname, a.sex, a.departmentid, a.subcompanyid1, a.workstartdate, b.changedate, c."+photofieldName+", a.id aid, ROWNUM AS rn FROM HRMRESOURCE a LEFT JOIN HrmStatusHistory b ON a.ID = b.RESOURCEID LEFT JOIN cus_fielddata c ON a.ID = c.ID AND c.scopeid = 3 WHERE" +
" 1 = 1 and a.subcompanyid1 not in ("+CompanyID1+") OFFSET "+begin+" ROWS FETCH NEXT "+pagesize+" ROWS ONLY";
}
log.error(sql);
rs.executeQuery(sql);
while (rs.next()) {
String workcode = Util.null2String(rs.getString("workcode"));
String lastname = Util.null2String(rs.getString("lastname"));
String sex = Util.null2String(rs.getString("sex"));
String departmentid = Util.null2String(rs.getString("departmentid"));
String subcompanyid1 = Util.null2String(rs.getString("subcompanyid1"));
String workstartdate = Util.null2String(rs.getString("workstartdate"));
String changedate = Util.null2String(rs.getString("changedate"));
String photofieldname1 = Util.null2String(rs.getString(photofieldName));
JSONObject dataobject = new JSONObject();
dataobject.put("workcode",workcode);
dataobject.put("lastname",lastname);
dataobject.put("sex",sex);
dataobject.put("departmentid",departmentid);
dataobject.put("subcompanyid1",subcompanyid1);
dataobject.put("workstartdate",workstartdate);
dataobject.put("changedate",changedate);
JSONArray imagelist = new JSONArray();
if(photofieldname1.length() > 0) {
RecordSet recordSet3 = new RecordSet();
String sql_3 = "select d.imagefilename,d.imagefileid,i.filesize,d.isextfile from docimagefile d left join imagefile i on " +
" i.imagefileid=d.imagefileid where docid in (" + photofieldname1 + ") " +
" and d.imagefileid in (select max(d.imagefileid) from DocImageFile d where docid in (" + photofieldname1 + ") group by d.docid,d.imagefilename)";
recordSet3.execute(sql_3);
log.info(sql_3);
while (recordSet3.next()) {
InputStream inputStream = ImageFileManager.getInputStreamById(recordSet3.getInt("imagefileid"));// 根据文件的图片id获取未加密的输入流
String base64FromInputStream = getBase64FromInputStream(inputStream);
JSONObject imageobj = new JSONObject();
imageobj.put("FILENAME",recordSet3.getString("imagefilename"));
imageobj.put("FILESIZE",recordSet3.getInt("filesize"));
imageobj.put("BASE64",base64FromInputStream);
if(recordSet3.getString("isextfile").equals("1")){
imageobj.put("TYPE","附件");
}else{
imageobj.put("TYPE","正文");
}
imagelist.add(imageobj);
}
}
dataobject.put("photo",imagelist);
datalist.add(dataobject);
}
JSONObject data = new JSONObject();
data.put("totalSize",totalSize);
data.put("dataList",datalist);
data.put("pageSize",pagesize);
data.put("curpage",curpage);
result.put("code",1);
result.put("data",data);
return result;
}
public String getBase64FromInputStream(InputStream in) {
// 将图片文件转化为字节数组字符串，并对其进行Base64编码处理
byte[] data = null;
// 读取图片字节数组
try {
ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
byte[] buff = new byte[100];
int rc = 0;
while ((rc = in.read(buff, 0, 100)) > 0) {
swapStream.write(buff, 0, rc);
}
data = swapStream.toByteArray();
} catch (IOException e) {
return "";
} finally {
if (in != null) {
try {
in.close();
} catch (IOException e) {
}
}
}
if(data == null) {
return "";
}
return new String(org.apache.commons.codec.binary.Base64.encodeBase64(data));
}
//调用获取人员列表接口
public static String doJsonPost(String json) {
String url = "/api/hrm/resful/getHrmUserInfoWithPage";
writeLog("查询人员列表接口"+url+"，推送报文：>>>>>>>>>>>>>>>>>>>>>>"+json);
CloseableHttpClient client = HttpClients.createDefault();
HttpPost post = new HttpPost(url);
post.setHeader("Content-Type", "application/json;charset=utf-8");
String result="";
try {
StringEntity s = new StringEntity(json,"UTF-8");
s.setContentEncoding("utf-8");
s.setContentType("application/json");
post.setEntity(s);
// 发送请求
HttpResponse httpResponse = client.execute(post);
// 获取响应输入流
InputStream inStream = httpResponse.getEntity().getContent();
BufferedReader reader = new BufferedReader(new InputStreamReader(
inStream,"utf-8"));
StringBuilder strber = new StringBuilder();
String line;
while ((line = reader.readLine()) != null)
strber.append(line + "\n");
inStream.close();
result = strber.toString();
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
}
Write Preview
Loading…
Cancel
Save