#weaver-njpmsreport-1# 初始化代码

devlop
shilei 1 year ago
commit f5f3d5d1df

@ -0,0 +1,781 @@
package com.weaver.seconddev.njprojectreport.controller;
import com.weaver.common.authority.annotation.WeaPermission;
import com.weaver.common.base.entity.result.WeaResult;
import com.weaver.common.hrm.service.HrmCommonEmployeeService;
import com.weaver.seconddev.njprojectreport.util.ColumnsUtils;
import com.weaver.seconddev.njprojectreport.util.CommonUtils;
import com.weaver.teams.domain.user.SimpleEmployee;
import com.weaver.teams.security.context.UserContext;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@RestController
@RequestMapping("/api/secondev/njpmscolum")
public class ProjectColumnsController {
//日志
private final Logger log = LoggerFactory.getLogger(ProjectColumnsController.class);
@Autowired
private ColumnsUtils columnsUtils;
@Autowired
private HrmCommonEmployeeService hrmCommonEmployeeService;
public String tenant_key = "t7akvdnf84" ;
public String subcompany_sw = "4969965898641618640" ;
public String subcompany_sd = "4969965907418519261" ;
public String subcompany_sx = "4969965916961119875" ;
public String subcompany_hn = "4969965914880119650" ;
public String jtjname = "第三集团军";
public String qiyuesuoid = "9081413488803384317";
public String group_id = "" ;
public String permissionEmployee = "9078080309085655917,6488080121949444347" ;
/**
*
* @param request
* @return
*/
@GetMapping("/getColumsCustomerName")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getColumsCustomerName(HttpServletRequest request){
String customerid = CommonUtils.null2String(request.getParameter("customerid")).trim();
Map<String, Object> recordMap = columnsUtils.getColumsCustomerName(customerid,tenant_key);
return WeaResult.success(recordMap);
}
/**
*
* @param request
* @return
*/
@PostMapping("/queryColumsCustomerName")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryColumsCustomerName(HttpServletRequest request){
String customerid = CommonUtils.null2String(request.getParameter("customerid")).trim();
Map<String, Object> recordMap = columnsUtils.getColumsCustomerName(customerid,tenant_key);
return WeaResult.success(recordMap);
}
/**
*
* @param request
* @return
*/
@GetMapping("/getColumsSubcompanyManager")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getColumsSubcompanyManager(HttpServletRequest request){
String departmentid = CommonUtils.null2String(request.getParameter("departmentid")).trim();
Map<String, Object> recordMap = columnsUtils.getColumsSubcompanyManager(departmentid,tenant_key);
return WeaResult.success(recordMap);
}
/**
*
* @param request
* @return
*/
@PostMapping("/queryColumsSubcompanyManager")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryColumsSubcompanyManager(HttpServletRequest request){
String departmentid = CommonUtils.null2String(request.getParameter("departmentid")).trim();
Map<String, Object> recordMap = columnsUtils.getColumsSubcompanyManager(departmentid,tenant_key);
return WeaResult.success(recordMap);
}
/**
*
* @param request
* @return
*/
@GetMapping("/getProjectContractNo")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getProjectContractNo(HttpServletRequest request){
String mainline_id = CommonUtils.null2String(request.getParameter("mainlineid")).trim();
Map<String, Object> recordMap = columnsUtils.getContractByMainlineId(mainline_id,tenant_key);
return WeaResult.success(recordMap);
}
/**
*
* @param request
* @return
*/
@PostMapping("/queryProjectContractNo")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryProjectContractNo(HttpServletRequest request){
String mainline_id = CommonUtils.null2String(request.getParameter("mainlineid")).trim();
Map<String, Object> recordMap = columnsUtils.getContractByMainlineId(mainline_id,tenant_key);
return WeaResult.success(recordMap);
}
/***
*
* @param request
* @return
*/
@GetMapping("/getColumsProjectStatus")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getColumsProjectStatus(HttpServletRequest request){
String actual_val_date = CommonUtils.null2String(request.getParameter("actual_val_date")).trim() ;
String proj_amount = CommonUtils.null2String(request.getParameter("proj_amount")).trim() ;
String mainlineid = CommonUtils.null2String(request.getParameter("mainlineid")).trim() ;
Map<String, String> recordMap = columnsUtils.getColumsProjectStatus(actual_val_date,proj_amount,mainlineid,tenant_key);
return WeaResult.success(recordMap);
}
/***
*
* @param request
* @return
*/
@PostMapping("/queryColumsProjectStatus")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryColumsProjectStatus(HttpServletRequest request){
String actual_val_date = CommonUtils.null2String(request.getParameter("actual_val_date")).trim() ;
String proj_amount = CommonUtils.null2String(request.getParameter("proj_amount")).trim() ;
String mainlineid = CommonUtils.null2String(request.getParameter("mainlineid")).trim() ;
Map<String, String> recordList = columnsUtils.getColumsProjectStatus(actual_val_date,proj_amount,mainlineid,tenant_key);
return WeaResult.success(recordList);
}
@GetMapping("/getColumsRequestExtension")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getColumsRequestExtension(HttpServletRequest request){
String mainlineid = CommonUtils.null2String(request.getParameter("mainlineid")).trim() ;
Map<String, String> recordList = columnsUtils.queryColumsRequestExtension(mainlineid,tenant_key);
return WeaResult.success(recordList);
}
@PostMapping("/queryColumsRequestExtension")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryColumsRequestExtension(HttpServletRequest request){
String mainlineid = CommonUtils.null2String(request.getParameter("mainlineid")).trim() ;
Map<String, String> recordList = columnsUtils.queryColumsRequestExtension(mainlineid,tenant_key);
return WeaResult.success(recordList);
}
/**
*
* @param request
* @return
*/
@PostMapping("/queryProjectRequestId")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryProjectRequestId(HttpServletRequest request){
String mainline_id = CommonUtils.null2String(request.getParameter("mainlineid")).trim();
List<Map<String,Object>> recordList = columnsUtils.getColumsRequestId(mainline_id,tenant_key);
return WeaResult.success(recordList);
}
@GetMapping("/getProjectRequestId")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getProjectRequestId(HttpServletRequest request){
String mainline_id = CommonUtils.null2String(request.getParameter("mainlineid")).trim();
List<Map<String,Object>> recordList = columnsUtils.getColumsRequestId(mainline_id,tenant_key);
return WeaResult.success(recordList);
}
/***
*
* @param request
* @return
*/
@GetMapping("/getprojectlist")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getprojectlist(HttpServletRequest request){
String otherid = CommonUtils.null2String(request.getParameter("otherid")).trim();
if(StringUtils.isBlank(otherid)){
otherid = permissionEmployee;
}
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
String employee_id = CommonUtils.null2String(employeeId);
log.info("queryprojectlist-employeeId----:"+employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
log.info("queryprojectlist-employee----:"+employee.toString());
log.info("queryprojectlist-getUserId----:"+employee.getUserId().toString());
String userid = CommonUtils.null2String(employee.getUserId());
String subcompanyids = "" ;
if(otherid.contains(employee_id)){
subcompanyids = columnsUtils.getEmployeeByProjectTeam4Other(jtjname,qiyuesuoid,employee_id,tenant_key);
}else{
subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
}
Map<String, Object> data = new HashMap<String, Object>();
log.info("queryprojectlist----:"+userid);
// String subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,userid,tenant_key);
List<Map<String,Object>> recordList = new ArrayList<Map<String,Object>>();
if(StringUtils.isNotBlank(subcompanyids)){
String baseSql = columnsUtils.queryProjectSql(subcompanyids,xm_mc,xm_xmjl,xm_bm,xm_id,xm_jg,xm_ysrq_start,xm_ysrq_end);
recordList = columnsUtils.queryProjectList(baseSql);
}
log.info("queryprojectlist---recordList:"+recordList.size());
log.info("totalSize:"+recordList.size());
data.put("prodata", recordList);
data.put("totalSize", recordList.size());
data.put("total", recordList.size());
return WeaResult.success(data);
}
@PostMapping("/queryprojectlist")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryprojectlist(HttpServletRequest request){
String otherid = CommonUtils.null2String(request.getParameter("otherid")).trim();
if(StringUtils.isBlank(otherid)){
otherid = permissionEmployee;
}
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
log.info("queryprojectlist-employeeId----:"+employeeId);
String employee_id = CommonUtils.null2String(employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
String userid = CommonUtils.null2String(employee.getUserId());
log.info("queryprojectlist-employee----:"+employee.toString());
log.info("queryprojectlist-getUserId----:"+employee.getUserId().toString());
String subcompanyids = "" ;
if(otherid.contains(employee_id)){
subcompanyids = columnsUtils.getEmployeeByProjectTeam4Other(jtjname,qiyuesuoid,employee_id,tenant_key);
}else{
subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
}
Map<String, Object> data = new HashMap<String, Object>();
log.info("queryprojectlist----:"+userid);
// String subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,userid,tenant_key);
String baseSql = columnsUtils.queryProjectSql(subcompanyids,xm_mc,xm_xmjl,xm_bm,xm_id,xm_jg,xm_ysrq_start,xm_ysrq_end);
List<Map<String,Object>> recordList = columnsUtils.queryProjectList(baseSql);
log.info("queryprojectlist---recordList:"+recordList.size());
log.info("totalSize:"+recordList.size());
data.put("prodata", recordList);
data.put("totalSize", recordList.size());
data.put("total", recordList.size());
return WeaResult.success(data);
}
@GetMapping("/getprojectlistbypage")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getprojectlistbypage(HttpServletRequest request){
int pageNo = CommonUtils.getIntValue(request.getParameter("pageNo"),1);
int pageSize = CommonUtils.getIntValue(request.getParameter("pageSize"),20);
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
String employee_id = CommonUtils.null2String(employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
String userid = CommonUtils.null2String(employee.getUserId());
Map<String, Object> data = new HashMap<String, Object>();
log.info("queryprojectlistdata3----:"+userid);
String subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
String baseSql = columnsUtils.queryProjectSql(subcompanyids,xm_mc,xm_xmjl,xm_bm,xm_id,xm_jg,xm_ysrq_start,xm_ysrq_end);
int total = columnsUtils.queryProjectCount(baseSql);
List<Map<String,Object>> recordList = columnsUtils.queryProjectListByPage(baseSql,pageNo,pageSize);
log.info("queryprojectlist---recordList:"+recordList.size());
data.put("prodata", recordList);
data.put("totalSize",total);
data.put("total", total);
return WeaResult.success(data);
}
@PostMapping("/queryprojectlistbypage")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryprojectlistbypage(HttpServletRequest request){
int pageNo = CommonUtils.getIntValue(request.getParameter("pageNo"),1);
int pageSize = CommonUtils.getIntValue(request.getParameter("pageSize"),20);
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
String employee_id = CommonUtils.null2String(employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
String userid = CommonUtils.null2String(employee.getUserId());
Map<String, Object> data = new HashMap<String, Object>();
log.info("queryprojectlistdata3----:"+userid);
String subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
String baseSql = columnsUtils.queryProjectSql(subcompanyids,xm_mc,xm_xmjl,xm_bm,xm_id,xm_jg,xm_ysrq_start,xm_ysrq_end);
int total = columnsUtils.queryProjectCount(baseSql);
List<Map<String,Object>> recordList = columnsUtils.queryProjectListByPage(baseSql,pageNo,pageSize);
log.info("queryprojectlist---recordList:"+recordList.size());
data.put("prodata", recordList);
data.put("totalSize",total);
data.put("total", total);
return WeaResult.success(data);
}
@GetMapping("/getprojectlistbypage2")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getprojectlistbypage2(HttpServletRequest request){
log.info("getprojectlistbypage2");
int pageNo = CommonUtils.getIntValue(request.getParameter("pageNo"),1);
int pageSize = CommonUtils.getIntValue(request.getParameter("pageSize"),20);
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
String employee_id = CommonUtils.null2String(employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
String userid = CommonUtils.null2String(employee.getUserId());
log.info("getprojectlistbypage2--xm_id:"+xm_id);
Map<String, Object> data = new HashMap<String, Object>();
String subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
String baseSql = columnsUtils.queryProjectSql(subcompanyids,xm_mc,xm_xmjl,xm_bm,xm_id,xm_jg,xm_ysrq_start,xm_ysrq_end);
int total = columnsUtils.queryProjectCount(baseSql);
log.info("total:"+total);
data.put("totalSize", total);
data.put("total", total);
List<Map<String,Object>> recordList = columnsUtils.queryProjectListByPage(baseSql,pageNo,pageSize);
log.info("getprojectlistbypage2--recordList:"+recordList.size());
for(int i=0;i<recordList.size();i++)
{
Map<String, Object> recordMap = recordList.get(i);
String mainline_id = String.valueOf(recordMap.get("mainline_id"));
String managerid = String.valueOf(recordMap.get("manager_id"));
String rel_custom = String.valueOf(recordMap.get("rel_custom"));
String actual_val_date = String.valueOf(recordMap.get("actual_val_date"));
String proj_amount = String.valueOf(recordMap.get("proj_amount"));
String departmentid = String.valueOf(recordMap.get("department_id"));
log.info("getprojectlistbypage2--mainline_id:"+mainline_id);
String hths = "" ;
if(StringUtils.isNotBlank(mainline_id)){
Map<String,Object> mainlineMap = columnsUtils.getContractByMainlineId(mainline_id,tenant_key);
if(mainlineMap.containsKey("hth")){
hths = CommonUtils.null2String(mainlineMap.get("hth")) ;
}
}
log.info("hths:"+hths);
recordMap.put("hth",hths);
String customername = "" ;
if(StringUtils.isNotBlank(rel_custom)){
Map<String,Object> customMap = columnsUtils.getColumsCustomerName(rel_custom,tenant_key);
if(!customMap.isEmpty()){
customername = String.valueOf(customMap.get("name"));
}
}
String zt = "" ;
String cjrq = "" ;
String sqyy = "" ;
String wdfj = "" ;
String sqyqys = "" ;
String ztmc = "" ;
String requestname = "" ;
String requestid = "" ;
log.info("getprojectlistbypage2--actual_val_date:"+actual_val_date);
if(StringUtils.isNotBlank(actual_val_date)){
Map<String,String> shareMap = columnsUtils.getColumsProjectStatus(actual_val_date,proj_amount,mainline_id,tenant_key);
if(shareMap.containsKey("zt")){
zt = shareMap.get("zt");
}
if(shareMap.containsKey("cjrq")){
cjrq = shareMap.get("cjrq");
}
if(shareMap.containsKey("sqyy")){
sqyy = shareMap.get("sqyy");
}
if(shareMap.containsKey("wdfj")){
wdfj = shareMap.get("wdfj");
}
if(shareMap.containsKey("ztmc")){
ztmc = shareMap.get("ztmc");
}
if(shareMap.containsKey("sqyqys")){
sqyqys = shareMap.get("sqyqys");
}
if(shareMap.containsKey("requestid")){
requestid = shareMap.get("requestid");
}
if(shareMap.containsKey("requestname")){
requestname = shareMap.get("requestname");
}
}
log.info("zt:"+zt);
log.info("cjrq:"+cjrq);
log.info("sqyy:"+sqyy);
log.info("wdfj:"+wdfj);
String fzrid = "" ;
String fzrxm = "" ;
if(StringUtils.isNotBlank(departmentid)){
Map<String,Object> fzrMap = columnsUtils.getColumsSubcompanyManager(departmentid,tenant_key);
if(fzrMap.containsKey("id")){
fzrid = String.valueOf(fzrMap.get("id"));
}
if(fzrMap.containsKey("username")){
fzrxm = String.valueOf(fzrMap.get("username"));
}
}
log.info("fzrid:"+fzrid);
log.info("fzrxm:"+fzrxm);
log.info("customername:"+customername);
recordMap.put("fzrid",fzrid);
recordMap.put("fzrxm",fzrxm);
recordMap.put("customername",customername);
recordMap.put("zt",zt);
recordMap.put("cjrq",cjrq);
recordMap.put("sqyy",sqyy);
recordMap.put("wdfj",wdfj);
recordMap.put("sqyqys",sqyqys);
recordMap.put("ztmc",ztmc);
recordMap.put("requestid",requestid);
recordMap.put("requestname",requestname);
}
data.put("prodata", recordList);
return WeaResult.success(data);
}
@PostMapping("/queryprojectlistbypage2")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryprojectlistbypage2(HttpServletRequest request){
int pageNo = CommonUtils.getIntValue(request.getParameter("pageNo"),1);
int pageSize = CommonUtils.getIntValue(request.getParameter("pageSize"),20);
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
String employee_id = CommonUtils.null2String(employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
String userid = CommonUtils.null2String(employee.getUserId());
Map<String, Object> data = new HashMap<String, Object>();
log.info("getprojectlist:"+userid);
String subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
String baseSql = columnsUtils.queryProjectSql(subcompanyids,xm_mc,xm_xmjl,xm_bm,xm_id,xm_jg,xm_ysrq_start,xm_ysrq_end);
int total = columnsUtils.queryProjectCount(baseSql);
data.put("totalSize", total);
data.put("total", total);
List<Map<String,Object>> recordList = columnsUtils.queryProjectListByPage(baseSql,pageNo,pageSize);
log.info("recordList:"+recordList.size());
for(int i=0;i<recordList.size();i++)
{
Map<String, Object> recordMap = recordList.get(i);
String projectid = String.valueOf(recordMap.get("mainline_id"));
String managerid = String.valueOf(recordMap.get("manager_id"));
String rel_custom = String.valueOf(recordMap.get("rel_custom"));
String actual_val_date = String.valueOf(recordMap.get("actual_val_date"));
String proj_amount = String.valueOf(recordMap.get("proj_amount"));
String departmentid = String.valueOf(recordMap.get("department_id"));
log.info("projectid:"+projectid);
String hths = "" ;
if(StringUtils.isNotBlank(projectid)){
Map<String,Object> mainlineMap = columnsUtils.getContractByMainlineId(projectid,tenant_key);
if(mainlineMap.containsKey("hth")){
hths = CommonUtils.null2String(mainlineMap.get("hth"));
}
}
log.info("hths:"+hths);
recordMap.put("hth",hths);
String customername = "" ;
if(StringUtils.isNotBlank(rel_custom)){
Map<String,Object> customMap = columnsUtils.getColumsCustomerName(rel_custom,tenant_key);
if(!customMap.isEmpty()){
customername = String.valueOf(customMap.get("name"));
}
}
String zt = "" ;
String cjrq = "" ;
String sqyy = "" ;
String wdfj = "" ;
String sqyqys = "" ;
String ztmc = "" ;
String requestname = "" ;
String requestid = "" ;
if(StringUtils.isNotBlank(actual_val_date)){
Map<String,String> shareMap = columnsUtils.getColumsProjectStatus(actual_val_date,proj_amount,projectid,tenant_key);
if(shareMap.containsKey("zt")){
zt = shareMap.get("zt");
}
if(shareMap.containsKey("cjrq")){
cjrq = shareMap.get("cjrq");
}
if(shareMap.containsKey("sqyy")){
sqyy = shareMap.get("sqyy");
}
if(shareMap.containsKey("wdfj")){
wdfj = shareMap.get("wdfj");
}
if(shareMap.containsKey("ztmc")){
ztmc = shareMap.get("ztmc");
}
if(shareMap.containsKey("sqyqys")){
sqyqys = shareMap.get("sqyqys");
}
if(shareMap.containsKey("requestid")){
requestid = shareMap.get("requestid");
}
if(shareMap.containsKey("requestname")){
requestname = shareMap.get("requestname");
}
}
log.info("zt:"+zt);
log.info("cjrq:"+cjrq);
log.info("sqyy:"+sqyy);
log.info("wdfj:"+wdfj);
String fzrid = "" ;
String fzrxm = "" ;
if(StringUtils.isNotBlank(departmentid)){
Map<String,Object> fzrMap = columnsUtils.getColumsSubcompanyManager(departmentid,tenant_key);
if(fzrMap.containsKey("id")){
fzrid = String.valueOf(fzrMap.get("id"));
}
if(fzrMap.containsKey("username")){
fzrxm = String.valueOf(fzrMap.get("username"));
}
}
log.info("fzrid:"+fzrid);
log.info("fzrxm:"+fzrxm);
recordMap.put("fzrid",fzrid);
recordMap.put("fzrxm",fzrxm);
log.info("customername:"+customername);
recordMap.put("customername",customername);
recordMap.put("zt",zt);
recordMap.put("cjrq",cjrq);
recordMap.put("sqyy",sqyy);
recordMap.put("wdfj",wdfj);
recordMap.put("sqyqys",sqyqys);
recordMap.put("ztmc",ztmc);
recordMap.put("requestid",requestid);
recordMap.put("requestname",requestname);
}
data.put("prodata", recordList);
return WeaResult.success(data);
}
/***
*
* @param request
* @return
*/
@GetMapping("/getAllProjectData")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getAllProjectData(HttpServletRequest request){
List<Map<String, Object>> list = columnsUtils.getdataBysql();
return WeaResult.success(list);
}
/**
*
* @return
*/
@GetMapping("/queryTableData")
@WeaPermission(publicPermission = true)
public WeaResult<Object> queryTableData(HttpServletRequest request){
int pageNo = CommonUtils.getIntValue(request.getParameter("pageNo"),1);
int pageSize = CommonUtils.getIntValue(request.getParameter("pageSize"),20);
String tablename = CommonUtils.null2String(request.getParameter("tablename"));
String sourceType = CommonUtils.null2String(request.getParameter("sourceType"));
String groupId = CommonUtils.null2String(request.getParameter("groupId"));
String datakey = CommonUtils.null2String(request.getParameter("datakey"));
String datavalue = CommonUtils.null2String(request.getParameter("datavalue"));
List<Map<String, Object>> recordList = columnsUtils.queryTableData(sourceType,groupId,tablename,pageNo,pageSize,datakey,datavalue);
return WeaResult.success(recordList);
}
@GetMapping("/getprojectcount")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getprojectcount(HttpServletRequest request){
String otherid = CommonUtils.null2String(request.getParameter("otherid")).trim();
if(StringUtils.isBlank(otherid)){
otherid = permissionEmployee;
}
int pageSize = CommonUtils.getIntValue(request.getParameter("pageSize"),150);
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
String employee_id = CommonUtils.null2String(employeeId);
// SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
// String userid = CommonUtils.null2String(employee.getUserId());
Map<String, Object> data = new HashMap<String, Object>();
// log.info("queryprojectlistdata3----:"+userid);
String subcompanyids = "" ;
if(otherid.contains(employee_id)){
subcompanyids = columnsUtils.getEmployeeByProjectTeam4Other(jtjname,qiyuesuoid,employee_id,tenant_key);
}else{
subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
}
String baseSql = columnsUtils.queryProjectSql(subcompanyids,xm_mc,xm_xmjl,xm_bm,xm_id,xm_jg,xm_ysrq_start,xm_ysrq_end);
int total = columnsUtils.queryProjectCount(baseSql);
List<Map<String,Object>> recordList = columnsUtils.getprojectcount(baseSql,pageSize);
log.info("queryprojectlist---recordList:"+recordList.size());
data.put("prodata", recordList);
data.put("totalSize",total);
data.put("total", total);
return WeaResult.success(data);
}
}

@ -0,0 +1,425 @@
package com.weaver.seconddev.njprojectreport.controller;
import com.weaver.common.authority.annotation.WeaPermission;
import com.weaver.common.base.entity.result.WeaResult;
import com.weaver.common.hrm.service.HrmCommonEmployeeService;
import com.weaver.seconddev.njprojectreport.util.ColumnsUtils;
import com.weaver.seconddev.njprojectreport.util.CommonUtils;
import com.weaver.teams.domain.user.SimpleEmployee;
import com.weaver.teams.security.context.UserContext;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.xssf.streaming.SXSSFWorkbook;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@RestController
@RequestMapping("/api/secondev/njpmsdownload")
public class ProjectDownloadController {
//日志
private final Logger log = LoggerFactory.getLogger(ProjectColumnsController.class);
@Autowired
private ColumnsUtils columnsUtils;
@Autowired
private HrmCommonEmployeeService hrmCommonEmployeeService;
public String tenant_key = "t7akvdnf84" ;
public String permissionEmployee = "9078080309085655917,6488080121949444347" ;
public String jtjname = "第三集团军";
public String qiyuesuoid = "9081413488803384317";
@GetMapping(value = "/excledownload",produces = MediaType.APPLICATION_OCTET_STREAM_VALUE)
@WeaPermission(publicPermission = true)
public void downloadExcel(HttpServletRequest request, HttpServletResponse response) throws Exception {
String otherid = CommonUtils.null2String(request.getParameter("otherid")).trim();
if(StringUtils.isBlank(otherid)){
otherid = permissionEmployee;
}
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
log.info("downloadExcel----employeeId:"+employeeId);
String employee_id = CommonUtils.null2String(employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
String userid = CommonUtils.null2String(employee.getUserId());
log.info("downloadExcel----userid:"+userid);
String subcompanyids = "" ;
if(otherid.contains(employee_id)){
subcompanyids = columnsUtils.getEmployeeByProjectTeam4Other(jtjname,qiyuesuoid,employee_id,tenant_key);
}else{
subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
}
log.info("downloadExcel----2222:"+employee_id);
List<Map<String,Object>> recordList = new ArrayList<Map<String,Object>>();
log.info("downloadExcel----recordList:" + recordList.size());
String name = "第三集团军知识分享报表.xlsx";
String sheetName = "知识分享报表" ;
// 1.创建一个工作簿。
SXSSFWorkbook workbook = new SXSSFWorkbook();
// 2.创建一个工作表
Sheet sheet = workbook.createSheet(sheetName);
// 3.创建行。
List<Map<String,String>> headList = columnsUtils.getExcelHead();
Row headRow = sheet.createRow(0);
for (int i = 0; i < headList.size(); i++) {
Map<String,String> headData = headList.get(i);
Cell cell = headRow.createCell(i);
cell.setCellValue(headData.get("name"));
}
if(StringUtils.isNotBlank(subcompanyids)) {
String baseSql = columnsUtils.queryProjectSql(subcompanyids, xm_mc, xm_xmjl, xm_bm, xm_id, xm_jg, xm_ysrq_start, xm_ysrq_end);
columnsUtils.queryProjectListByExcel(baseSql, tenant_key,jtjname,headList,sheet);
}
response.reset();
response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(name, "UTF-8"));
response.setContentType("application/vnd.ms-excel");
response.setHeader("Access-Control-Expose-Headers", "Content-Disposition");
OutputStream output = response.getOutputStream();
workbook.write(output);
output.flush();
output.close();
workbook.dispose();
}
// @ApiOperation(notes = "文件下载", value = "文件下载")
// @GetMapping("/downloadfile")
// public org.springframework.http.ResponseEntity<FileSystemResource> downloadFile(HttpServletResponse response) {
// String fileName = null; // 文件名称的编码
// InputStream in = null;
// OutputStream out = null;
// try {
//
// List<Map<String,Object>> recordList = new ArrayList<Map<String,Object>>();
// log.info("downloadExcel----recordList:" + recordList.size());
// String name = "第三集团军知识分享报表.xlsx";
// String sheetName = "知识分享报表" ;
// // 1.创建一个工作簿。
// SXSSFWorkbook workbook = new SXSSFWorkbook();
// // 2.创建一个工作表
// Sheet sheet = workbook.createSheet(sheetName);
// // 3.创建行。
// List<Map<String,String>> headList = columnsUtils.getExcelHead();
//
// Row headRow = sheet.createRow(0);
// for (int i = 0; i < headList.size(); i++) {
// Map<String,String> headData = headList.get(i);
// Cell cell = headRow.createCell(i);
// cell.setCellValue(headData.get("name"));
// }
//
// for (int i = 0; i < recordList.size(); i++) {
// Row row = sheet.createRow(i+1);
// Map<String,Object> dataMap = recordList.get(i);
// System.out.println("i:"+i);
//
// for (int k = 0; k < headList.size(); k++) {
// Map<String,String> headData = headList.get(k);
// String key = headData.get("key");
// System.out.println("key:"+key);
// if(StringUtils.isNotBlank(key) && dataMap.containsKey(key)){
// Cell cell = row.createCell(k);
// cell.setCellValue(CommonUtils.null2String(dataMap.get(key)));
// }else{
// Cell cell = row.createCell(k);
// cell.setCellValue("");
// }
// }
// }
//
//
// ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
// workbook.write(byteArrayOutputStream);
//
//
// byte[] buffer = byteArrayOutputStream.toByteArray();
// InputStream inputStream = new ByteArrayInputStream(buffer);
//
//
//
// HttpHeaders headers = new HttpHeaders();
// headers.add("Cache-Control", "no-cache, no-store, must-revalidate");
// headers.add("Content-Disposition", "attachment; filename=" + fileName);
// headers.add("Pragma", "no-cache");
// headers.add("Expires", "0");
// headers.add("Last-Modified", new Date().toString());
// headers.add("ETag", String.valueOf(System.currentTimeMillis()));
// return org.springframework.http.ResponseEntity
// .ok()
// .headers(headers)
// .contentType(MediaType.parseMediaType("application/octet-stream"))
// .);
//
// } catch (Exception e) {
// e.printStackTrace();
// log.info("dfsId:{}下载文件失败cause:{}",fielId,e);
// }finally {
// }
// return org.springframework.http.ResponseEntity.status(Integer.parseInt(MsgCode.DEFINED_ERROR.getCode())).build();
// }
// @GetMapping("/downloadFile2")
// public void downloadFile2(HttpServletResponse response) throws IOException {
// // 设置响应头,指定文件名
// response.setHeader("Content-Disposition", "attachment; filename=file.txt");
//
// // 获取文件输入流
// InputStream inputStream = new FileInputStream("path/to/file.txt");
//
//
// List<Map<String,Object>> recordList = new ArrayList<Map<String,Object>>();
//
// log.info("downloadExcel----recordList:" + recordList.size());
// String name = "第三集团军知识分享报表.xlsx";
// String sheetName = "知识分享报表" ;
// // 1.创建一个工作簿。
// SXSSFWorkbook workbook = new SXSSFWorkbook();
// // 2.创建一个工作表
// Sheet sheet = workbook.createSheet(sheetName);
// // 3.创建行。
// List<Map<String,String>> headList = columnsUtils.getExcelHead();
//
// Row headRow = sheet.createRow(0);
// for (int i = 0; i < headList.size(); i++) {
// Map<String,String> headData = headList.get(i);
// Cell cell = headRow.createCell(i);
// cell.setCellValue(headData.get("name"));
// }
//
// for (int i = 0; i < recordList.size(); i++) {
// Row row = sheet.createRow(i+1);
// Map<String,Object> dataMap = recordList.get(i);
// System.out.println("i:"+i);
//
// for (int k = 0; k < headList.size(); k++) {
// Map<String,String> headData = headList.get(k);
// String key = headData.get("key");
// System.out.println("key:"+key);
// if(StringUtils.isNotBlank(key) && dataMap.containsKey(key)){
// Cell cell = row.createCell(k);
// cell.setCellValue(CommonUtils.null2String(dataMap.get(key)));
// }else{
// Cell cell = row.createCell(k);
// cell.setCellValue("");
// }
// }
// }
//
// workbook.
// FileOutputStream fileOutputStream = new FileOutputStream(path + URLEncoder.encode(filename, "utf-8")+".xlsx");
// // 输出
// workbook.write(fileOutputStream);
// // 6.关闭流
// fileOutputStream.close();
// // 7.清除临时文件
// ((SXSSFWorkbook) workbook).dispose();
//
//
// // 创建StreamingResponseBody对象将文件内容写入响应输出流
// StreamingResponseBody responseBody = outputStream -> {
// byte[] buffer = new byte[1024];
// int bytesRead;
// while ((bytesRead = inputStream.read(buffer)) != -1) {
// outputStream.write(buffer, 0, bytesRead);
// }
// inputStream.close();
// };
//
// // 返回StreamingResponseBody对象
// response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE);
// responseBody.writeTo(response.getOutputStream());
// }
@GetMapping(value = "/excledownload2",produces = MediaType.APPLICATION_OCTET_STREAM_VALUE)
@WeaPermission(publicPermission = true)
public void downloadExcel2(HttpServletRequest request, HttpServletResponse response) throws Exception {
String otherid = CommonUtils.null2String(request.getParameter("otherid")).trim();
if(StringUtils.isBlank(otherid)){
otherid = permissionEmployee;
}
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
int pageNo = CommonUtils.getIntValue(request.getParameter("pageNo"),1);
int pageSize = CommonUtils.getIntValue(request.getParameter("pageSize"),20);
Long employeeId = UserContext.getCurrentEmployeeId();
log.info("downloadExcel----employeeId:"+employeeId);
String employee_id = CommonUtils.null2String(employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
String userid = CommonUtils.null2String(employee.getUserId());
log.info("downloadExcel----userid:"+userid);
String subcompanyids = "" ;
if(otherid.contains(employee_id)){
subcompanyids = columnsUtils.getEmployeeByProjectTeam4Other(jtjname,qiyuesuoid,employee_id,tenant_key);
}else{
subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
}
log.info("downloadExcel----2222:"+employee_id);
List<Map<String,Object>> recordList = new ArrayList<Map<String,Object>>();
log.info("downloadExcel----recordList:" + recordList.size());
String name = "第三集团军知识分享报表.xlsx";
String sheetName = "知识分享报表" ;
// 1.创建一个工作簿。
SXSSFWorkbook workbook = new SXSSFWorkbook();
// 2.创建一个工作表
Sheet sheet = workbook.createSheet(sheetName);
// 3.创建行。
List<Map<String,String>> headList = columnsUtils.getExcelHead();
Row headRow = sheet.createRow(0);
for (int i = 0; i < headList.size(); i++) {
Map<String,String> headData = headList.get(i);
Cell cell = headRow.createCell(i);
cell.setCellValue(headData.get("name"));
}
if(StringUtils.isNotBlank(subcompanyids)) {
String baseSql = columnsUtils.queryProjectSql(subcompanyids, xm_mc, xm_xmjl, xm_bm, xm_id, xm_jg, xm_ysrq_start, xm_ysrq_end);
columnsUtils.queryProjectListByExcel2(baseSql, tenant_key,jtjname,headList,sheet,pageNo,pageSize);
}
response.reset();
response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(name, "UTF-8"));
response.setContentType("application/vnd.ms-excel");
response.setHeader("Access-Control-Expose-Headers", "Content-Disposition");
OutputStream output = response.getOutputStream();
workbook.write(output);
output.flush();
output.close();
workbook.dispose();
}
/**
*
* @param request
* @return
*/
@GetMapping("/getProjectListCount")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getProjectListCount(HttpServletRequest request){
String otherid = CommonUtils.null2String(request.getParameter("otherid")).trim();
if(StringUtils.isBlank(otherid)){
otherid = permissionEmployee;
}
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
log.info("downloadExcel----employeeId:"+employeeId);
String employee_id = CommonUtils.null2String(employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
String userid = CommonUtils.null2String(employee.getUserId());
log.info("downloadExcel----userid:"+userid);
String subcompanyids = "" ;
if(otherid.contains(employee_id)){
subcompanyids = columnsUtils.getEmployeeByProjectTeam4Other(jtjname,qiyuesuoid,employee_id,tenant_key);
}else{
subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
}
log.info("downloadExcel----2222:"+employee_id);
List<Map<String,Object>> dataList = new ArrayList<Map<String,Object>>();
int count = 0;
if(StringUtils.isNotBlank(subcompanyids)) {
String baseSql = columnsUtils.queryProjectSql(subcompanyids, xm_mc, xm_xmjl, xm_bm, xm_id, xm_jg, xm_ysrq_start, xm_ysrq_end);
count = columnsUtils.getProjectListCount(baseSql);
}
Map<String, Object> data = new HashMap<String, Object>();
data.put("count",count);
return WeaResult.success(data);
}
@GetMapping("/getprojectlist")
@WeaPermission(publicPermission = true)
public WeaResult<Object> getprojectlist(HttpServletRequest request){
int pageNo = CommonUtils.getIntValue(request.getParameter("pageNo"),1);
int pageSize = CommonUtils.getIntValue(request.getParameter("pageSize"),20);
String xm_id = CommonUtils.null2String(request.getParameter("xmid")).trim();
String xm_mc = CommonUtils.null2String(request.getParameter("xmmc")).trim();
String xm_xmjl = CommonUtils.null2String(request.getParameter("xmjl")).trim();
String xm_bm = CommonUtils.null2String(request.getParameter("bm")).trim();
String xm_jg = CommonUtils.null2String(request.getParameter("jg")).trim();
String xm_ysrq_start = CommonUtils.null2String(request.getParameter("ysrq_start")).trim();
String xm_ysrq_end = CommonUtils.null2String(request.getParameter("ysrq_end")).trim();
Long employeeId = UserContext.getCurrentEmployeeId();
String employee_id = CommonUtils.null2String(employeeId);
SimpleEmployee employee = hrmCommonEmployeeService.getEmployeeById(employeeId, tenant_key);
String userid = CommonUtils.null2String(employee.getUserId());
Map<String, Object> data = new HashMap<String, Object>();
log.info("queryprojectlistdata3----:"+userid);
String subcompanyids = columnsUtils.getEmployeeByProjectTeam(jtjname,qiyuesuoid,employee_id,tenant_key);
String baseSql = columnsUtils.queryProjectSql(subcompanyids,xm_mc,xm_xmjl,xm_bm,xm_id,xm_jg,xm_ysrq_start,xm_ysrq_end);
int total = columnsUtils.queryProjectCount(baseSql);
data.put("count", total);
return WeaResult.success(data);
}
}

@ -0,0 +1,199 @@
package com.weaver.seconddev.njprojectreport.controller;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.weaver.common.authority.annotation.WeaPermission;
import com.weaver.common.cache.tablecache.impl.ComInfoCache;
import com.weaver.project.service.RemoteMainlineService;
import com.weaver.teams.security.context.UserContext;
import com.weaver.workflow.common.util.OrgUtil;
import com.weaver.workflow.core.entity.publicApi.RequestPAResultMessageEntity;
import com.weaver.workflow.common.entity.org.WeaUser;
import com.weaver.workflow.common.framework.util.ServiceUtil;
import com.weaver.workflow.core.entity.publicApi.RequestPAResultEntity;
import com.weaver.workflow.core.services.RequestPAService;
import com.weaver.workflow.core.services.impl.RequestPAServiceImpl;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import com.weaver.seconddev.njprojectreport.util.RequestUtil;
import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.Map;
@RestController
@RequestMapping("/api/secondev/njpmsrequest")
public class ProjectRequestController {
//日志
private final Logger log = LoggerFactory.getLogger(ProjectRequestController.class);
public String tenant_key = "t7akvdnf84" ;
/**
*
* @param request
* @return
*/
@RequestMapping({"/doCreateRequest"})
@WeaPermission(publicPermission = true)
public RequestPAResultEntity doCreateRequest(HttpServletRequest request) {
log.info("doCreateRequest");
RequestPAResultEntity paResult = new RequestPAResultEntity();
Long employeeId = UserContext.getCurrentEmployeeId();
String requestname = "验收项目知识分享流程超时未提交提醒" ;
String remark = "请尽快提交" ;
String userId = request.getParameter("userId");
String workflowId = request.getParameter("workflowId");
String isnextflow = request.getParameter("isnextflow");
String requestLevel= request.getParameter("requestLevel");
String managerid = request.getParameter("managerid");
String mainlineid = request.getParameter("mainlineid");
if(StringUtils.isBlank(requestLevel)){
requestLevel = "0";
}
if(StringUtils.isBlank(isnextflow)){
isnextflow = "0";
}
log.info("doCreateRequest-userId:"+userId);
log.info("doCreateRequest-workflowId:"+workflowId);
log.info("doCreateRequest-isnextflow:"+isnextflow);
log.info("doCreateRequest-requestLevel:"+requestLevel);
log.info("doCreateRequest-managerid:"+managerid);
log.info("doCreateRequest-mainlineid:"+mainlineid);
if(StringUtils.isBlank(workflowId)){
RequestPAResultMessageEntity resultMessage = new RequestPAResultMessageEntity();
resultMessage.setErrcode("300");
resultMessage.setErrmsg("获取创建的流程为空,无法提交");
paResult.setMessage(resultMessage);
return paResult;
}
if(StringUtils.isBlank(userId)){
RequestPAResultMessageEntity resultMessage = new RequestPAResultMessageEntity();
resultMessage.setErrcode("300");
resultMessage.setErrmsg("获取创建人为空,无法提交");
paResult.setMessage(resultMessage);
return paResult;
}
// if(StringUtils.isBlank(managerid)){
// RequestPAResultMessageEntity resultMessage = new RequestPAResultMessageEntity();
// resultMessage.setErrcode("300");
// resultMessage.setErrmsg("项目的项目经理为空,无法提交");
// paResult.setMessage(resultMessage);
// return paResult;
// }
//
// if(StringUtils.isBlank(mainlineid)){
// RequestPAResultMessageEntity resultMessage = new RequestPAResultMessageEntity();
// resultMessage.setErrcode("300");
// resultMessage.setErrmsg("项目编码空,无法提交");
// paResult.setMessage(resultMessage);
// return paResult;
// }
String managerSubcompanyId = "" ;
String mainlinename = "" ;
String username = "";
// if(StringUtils.isNotEmpty(userId)){
// HrmEmployeeComInfo hrmEmployeeComInfo = comInfoCache.getCacheById(HrmEmployeeComInfo.class,userId) ;
// username = CommonUtils.null2String(hrmEmployeeComInfo.getUsername()+"") ;
// }
//
// if(StringUtils.isNotEmpty(managerid)){
// HrmEmployeeComInfo hrmEmployeeComInfo = comInfoCache.getCacheById(HrmEmployeeComInfo.class,managerid) ;
// managerSubcompanyId = CommonUtils.null2String(hrmEmployeeComInfo.getSubcompanyId()+"") ;
// }
// if(StringUtils.isNotEmpty(mainlineid)){
// SimpleMainline simpleMainline = remoteMainlineService.get(Long.parseLong(mainlineid),tenant_key);
// log.info("simpleMainline:"+simpleMainline.toString());
// Map<String, Object> recordMap = RequestUtil.getmainlinename(mainlineid,tenant_key);
// if(recordMap !=null && recordMap.size()>0){
// mainlinename = CommonUtils.null2String(recordMap.get("name"));
// }
// }
Map<String, Object> requestMap = new HashMap<String, Object>();
requestMap.put("userId",userId);
requestMap.put("workflowId",workflowId);
requestMap.put("requestname",requestname);
requestMap.put("remark",remark);
requestMap.put("isnextflow",isnextflow);
requestMap.put("requestLevel",requestLevel);
JSONObject formData = new JSONObject();
JSONArray dataDetails = new JSONArray();
JSONObject dataDetail = new JSONObject();
dataDetail.put("dataKey","resource_n");
dataDetail.put("content",employeeId);
dataDetails.add(dataDetail);
// dataDetail = new JSONObject();
// dataDetail.put("dataKey","mutiresource");
// dataDetail.put("content",managerid);
// dataDetails.add(dataDetail);
dataDetail = new JSONObject();
dataDetail.put("dataKey","fenbu");
dataDetail.put("content",managerSubcompanyId);
dataDetails.add(dataDetail);
// dataDetail = new JSONObject();
// dataDetail.put("dataKey","Project");
// dataDetail.put("content",mainlineid);
// dataDetails.add(dataDetail);
dataDetail = new JSONObject();
dataDetail.put("dataKey","description");
dataDetail.put("content","1111");
dataDetails.add(dataDetail);
dataDetail = new JSONObject();
dataDetail.put("dataKey","duohangwenbenhtml");
dataDetail.put("content","<p>项目:"+mainlinename+" 未提交<第三集团军知识分享提交流程>,请务必尽快提交,如有疑问,请联系:"+username+"</p>");
dataDetails.add(dataDetail);
formData.put("dataDetails",dataDetails);
requestMap.put("formData",formData);
log.info("doCreateRequest-create:params:{}", JSON.toJSONString(requestMap));
WeaUser user = getUser(Long.parseLong(userId));
RequestPAService paService = (RequestPAService) ServiceUtil.getService(RequestPAServiceImpl.class, user);
return paService.create(requestMap);
}
/***
*
* @param userId
* @return
*/
private WeaUser getUser(long userId) {
if (userId > 0L) {
WeaUser user = OrgUtil.getUser(userId);
if (user != null && user.getUserId() != null && user.getUserId() > 0L) {
return user;
}
}
return null;
}
}

@ -0,0 +1,118 @@
package com.weaver.seconddev.njprojectreport.test;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.Month;
import java.time.YearMonth;
import java.time.format.DateTimeFormatter;
import java.time.temporal.TemporalAdjusters;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
public class test1 {
// public static void main(String[] args) {
//// int count = 200;
//// int size = 30;
//// System.out.println((int)Math.ceil(count/(size*1.0)));
//
// LocalDate currentDate = LocalDate.now();
// LocalDate lastMonthDate = currentDate.minusMonths(1);
//
// LocalDate firstDay = lastMonthDate.with(TemporalAdjusters.firstDayOfMonth());
// // 获取当前月的最后一天
// LocalDate lastDay = lastMonthDate.with(TemporalAdjusters.lastDayOfMonth());
//
// // System.out.println(lastMonthDate.getMonth().toString());
//
// System.out.println("firstDay" + firstDay.toString());
// System.out.println("lastDay" + lastDay.toString());
//
// }
// public static void main(String[] args) {
//
// Calendar calendar = Calendar.getInstance();
// int year = calendar.get(Calendar.YEAR);
// int dayOfYear = 1 ;
//
// LocalDate localDate = LocalDate.now();
// int year1 = localDate.getYear() ;
// System.out.println("year1 " + year1);
//
// for(int i=0;i<=12;i++){
// LocalDate previousMonth = localDate.minusMonths(i);
// String startDay = previousMonth.with(TemporalAdjusters.lastDayOfMonth()).toString();
// String endDay = previousMonth.with(TemporalAdjusters.firstDayOfMonth()).toString();
// System.out.println("startDay:"+startDay);
// System.out.println("endDay:"+endDay);
// }
//
// for (int i = 1; i <= 12; i++) {
// Month month = Month.of(i);
// LocalDate firstDayOfMonth = YearMonth.of(year, month).atDay(dayOfYear); // 计算当前月份的首日
// LocalDate lastDayOfMonth = YearMonth.of(year, month).atEndOfMonth(); // 计算当前月份的最后一天
// String yearMonth = "";
// if(i<10){
// yearMonth = year+"-0"+i ;
// }else{
// yearMonth = year+"-"+i ;
// }
//
// System.out.println("月份 " + yearMonth + ":");
// System.out.println("开始日期: " + firstDayOfMonth);
// System.out.println("结束日期: " + lastDayOfMonth);
// System.out.println("\n");
// }
//
//
// List<String> dataList = new ArrayList<String>();
// dataList.add("1");
// dataList.add("2");
// dataList.add("3");
// dataList.add("4");
// System.out.println(dataList.subList(0,2).toString());
//
// }
// public static void main(String[] args) {
//
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
//
// Calendar calendar = Calendar.getInstance();
// for(int i=0;i<12;i++){
// calendar.set(Calendar.MONTH, i);
// String dat = sdf.format(calendar.getTime());
// System.out.println("dat:"+dat);
//
//
// }
// }
public static void main(String[] args) {
// Calendar calendar = Calendar.getInstance();
// int year = calendar.get(Calendar.YEAR);
//
// calendar.set(Calendar.MONTH,calendar.getActualMaximum(Calendar.MONTH));
// calendar.set(Calendar.DAY_OF_MONTH,calendar.getActualMaximum(Calendar.DAY_OF_MONTH));
// Date currYearLast = calendar.getTime();
// String lastDayOfYear = new SimpleDateFormat("yyyy-MM-dd").format(currYearLast)+" 23:59:59";
// System.out.println("本年度的最后一天: " + lastDayOfYear);
LocalDate today = LocalDate.now(); // 获取当前日期
LocalDate tenDaysBefore = today.minusDays(30); // 当前日期前10天
System.out.println("10天前的日期是: " + tenDaysBefore.toString());
}
}

@ -0,0 +1,395 @@
package com.weaver.seconddev.njprojectreport.util;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang3.math.NumberUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.List;
import java.util.Map;
@Component
public class CommonUtils {
private final static Logger log = LoggerFactory.getLogger(CommonUtils.class);
public static JSONObject toJSON(String data){
if(!StringUtils.isEmpty(data)){
try {
return JSONObject.parseObject(data);
}catch (Throwable t){
log.error(t.getMessage(),t);
}
}
return null;
}
public static Long getJSONLong(JSONObject json,String key){
if(json != null && json.containsKey(key)){
try {
return json.getLong(key);
}catch (Throwable t){
log.error(t.getMessage(),t);
}
}
return null;
}
public static Integer getJSONInteger(JSONObject json,String key){
if(json != null && json.containsKey(key)){
try {
return json.getInteger(key);
}catch (Throwable t){
log.error(t.getMessage(),t);
}
}
return -1;
}
public static String getJSONString(JSONObject json,String key){
if(json != null && json.containsKey(key)){
try {
return null2String(json.getString(key));
}catch (Throwable t){
log.error(t.getMessage(),t);
}
}
return "";
}
public static JSONObject getJSONObject(JSONObject json,String key){
if(json != null && json.containsKey(key)){
try {
return json.getJSONObject(key);
}catch (Throwable t){
log.error(t.getMessage(),t);
}
}
return null;
}
public static JSONArray getJSONArray(JSONObject json, String key){
if(json != null && json.containsKey(key)){
try {
return json.getJSONArray(key);
}catch (Throwable t){
log.error(t.getMessage(),t);
}
}
return null;
}
public static JSONObject getJSONObject(JSONArray json, int idx){
if(json != null && json.size() > idx){
try {
return json.getJSONObject(idx);
}catch (Throwable t){
log.error(t.getMessage(),t);
}
}
return null;
}
public static String mapToStrData(Map<String, Object> para){
if(para != null) {
return JSONObject.toJSON(para).toString();
}
return "";
}
public static void strToLongList(List<Long> list,String strs){
strToLongList(list,strs,true);
}
public static void strToLongList(List<Long> list,String strs,boolean isDist){
if(list == null){
return;
}
if(StringUtils.isEmpty(strs)){
return;
}
String[] strList = StringUtils.split(strs, ",");
for(String str:strList){
if(StringUtils.isEmpty(str)){
continue;
}
long id = getLongValue(str);
if(id > 0l && (isDist == false || !list.contains(id))){
list.add(id);
}
}
}
public static long getLongValue(Object v){
return getLongValue(null2String(v));
}
public static long getLongValue(String v) {
return getLongValue(v, -1);
}
public static long getLongValue(String v, long def) {
try {
return Long.parseLong(v);
} catch (Exception ex) {
return def;
}
}
public static int getIntValue(Object o){
return getIntValue(null2String(o));
}
public static int getIntValue(String s){
return getIntValue(s,-1);
}
public static int getIntValue(String s, int def){
try {
return NumberUtils.toInt(s);
} catch (Exception ex) {
return def;
}
}
public static String null2String(Object s) {
return s == null ? "" : s.toString();
}
public static String null2String(Object s, String def) {
return s == null ? (def == null ? "" : def) : s.toString();
}
public static String stringReplace(String sou, String s1, String s2) {
//int idx = sou.indexOf(s1);
//if (idx < 0) {
// return sou;
//}
//return sou.substring(0, idx) + s2 + StringReplace(sou.substring(idx + s1.length()), s1, s2);
sou = null2String(sou);
s1 = null2String(s1);
s2 = null2String(s2);
try{
sou = sou.replace(s1, s2);
}catch(Exception e){
//System.out.println(e);//将未知异常打印出来,便于检查错误。
}
return sou;
}
/**
*
*
* @param s
* @return
*/
public static String toScreen(String s) {
char c[] = s.toCharArray();
char ch;
int i = 0;
StringBuffer buf = new StringBuffer();
while (i < c.length) {
ch = c[i++];
if (ch == '\r')
buf.append("");
else if (ch == '\n')
buf.append("");
else
buf.append(ch);
}
return buf.toString();
}
/**
*
*
* @param s
* @return
*/
public static String toExcel(String s) {
if (s == null) return "";
//因本方法会将字符串 &符号转换故先将欧元符号转义符转换为其Unicode码
s = s.replaceAll("&euro;", "\u20AC");
String str = toScreen(s);
str = stringReplace(str, "&ang;", "∠");
str = stringReplace(str, "&phi;", "φ");
str = stringReplace(str, "&quot;", "\"");
str = stringReplace(str, "&nbsp", "%nbsp");
//str=Util.StringReplace(str,"'","");
str = stringReplace(str, "&lt;", "<");
str = stringReplace(str, "&gt;", ">");
str = stringReplace(str, "&dt;&at;", "<br>");
str = stringReplace(str, "&", "&amp;");
str = stringReplace(str, "<br>", "&dt;&at;");
if ("&dt;&at;".equals(str)) {
str = "";
}
//在方法最后,又将欧元符号置换为转义符
str = str.replaceAll("\u20AC", "&euro;");
return str;
}
public static String delHtml(final String inputString) {
String htmlStr = toExcel(inputString); // 含html标签的字符串
String textStr = "";
java.util.regex.Pattern p_script;
java.util.regex.Matcher m_script;
java.util.regex.Pattern p_html;
java.util.regex.Matcher m_html;
try {
String regEx_html = "<[^>]+>"; // 定义HTML标签的正则表达式
String regEx_script = "<[/s]*?script[^>]*?>[/s/S]*?<[/s]*?//[/s]*?script[/s]*?>"; // 定义script的正则表达式{或<script[^>]*?>[/s/S]*?<//script>
p_script = java.util.regex.Pattern.compile(regEx_script, java.util.regex.Pattern.CASE_INSENSITIVE);
m_script = p_script.matcher(htmlStr);
htmlStr = m_script.replaceAll(""); // 过滤script标签
p_html = java.util.regex.Pattern.compile(regEx_html, java.util.regex.Pattern.CASE_INSENSITIVE);
m_html = p_html.matcher(htmlStr);
htmlStr = m_html.replaceAll(""); // 过滤html标签
textStr = htmlStr;
} catch (Exception e) {
System.err.println("Html2Text: " + e.getMessage());
}
return htmlToTxt(textStr).trim();// 返回文本字符串
}
/**
* html
*
* @param input
* @return
*/
public static String htmlToTxt(String input) {
if (input == null || input.trim().equals("")) {
return "";
}
// 去掉所有html元素,
String str = input.replaceAll("<[a-zA-Z]+[1-9]?[^><]*>", "");
return str;
}
//==new=
public static int getIntValue(Object s, int def){
return getIntValue(null2String(s));
}
public static List<Long> strToLongList(String strs){
List<Long> list = new ArrayList<Long>();
strToLongList(list,strs,true);
return list;
}
public static int dateInterval(String fromdate, String todate) {
Calendar fromcalendar = getCalendar(fromdate);
Calendar tocalendar = getCalendar(todate);
if (fromcalendar == null || tocalendar == null)
return 0;
return (int) ((tocalendar.getTimeInMillis() - fromcalendar.getTimeInMillis()) / 3600 / 24 / 1000);
}
/**
* @param datetime - '2004-05-12 12:00:23' '2004-05-12'
* @return null
*/
public static Calendar getCalendar(String datetime) {
int datetimelength = datetime.length() ;
switch(datetimelength) {
case 19 :
return getCalendar(datetime , "yyyy'-'MM'-'dd' 'HH:mm:ss") ;
case 10 :
return getCalendar(datetime , "yyyy'-'MM'-'dd") ;
default :
return null ;
}
}
/**
* @param datetime -
* @param formart -
* @return null
*/
public static Calendar getCalendar(String datetime, String formart) {
SimpleDateFormat SDF = new SimpleDateFormat(formart) ;
Calendar calendar = Calendar.getInstance() ;
try {
calendar.setTime(SDF.parse(datetime)) ;
} catch (ParseException e) {
return null ;
}
return calendar ;
}
/**
* @return yyyy'-'MM'-'dd
*
* yyyy'-'MM'-'dd
*
* 2004-09-07
*/
public static String getCurrentDateString() {
String timestrformart = "yyyy'-'MM'-'dd" ;
SimpleDateFormat SDF = new SimpleDateFormat(timestrformart) ;
Calendar calendar = Calendar.getInstance() ;
return SDF.format(calendar.getTime()) ;
}
public static String getMessage(String msgMode,String key,String val){
key = null2String(key).trim();
val = null2String(val).trim();
msgMode = null2String(msgMode).trim();
if(!"".equals(msgMode) && !"".equals(key)) {
msgMode = msgMode.replaceAll(key, val);
}
return msgMode;
}
public static List<Long> tranStrToLongList(Object idListObj){
List<Long> docIds = new ArrayList<Long>();
if(idListObj != null) {
try {
JSONArray idObjs = JSONArray.parseArray(null2String(idListObj));
for (Object idObj : idObjs) {
long id = getLongValue(idObj);
if (id > 0l) {
docIds.add(id);
}
}
} catch (Exception e) {
log.error("trans error :{}", idListObj);
log.error(e.getMessage(), e);
}
}
return docIds;
}
}

@ -0,0 +1,297 @@
package com.weaver.seconddev.njprojectreport.util;
import cn.hutool.core.codec.Base64;
import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSONObject;
import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity;
import com.weaver.ebuilder.datasource.api.enums.SqlParamType;
import com.weaver.ebuilder.datasource.api.query.dto.dw.DynamicParamDto;
import com.weaver.ebuilder.datasource.api.query.dto.dw.FieldQuery;
import com.weaver.ebuilder.datasource.api.query.dto.dw.GroupQuery;
import com.weaver.ebuilder.datasource.api.query.dto.dw.TableQuery;
import com.weaver.ebuilder.datasource.api.entity.ExecuteSqlEntity;
import com.weaver.ebuilder.datasource.api.enums.SourceType;
import com.weaver.ebuilder.datasource.api.service.DataSetService;
import com.weaver.ebuilder.datasource.api.service.impl.EbFormDataService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.*;
/**
* DatabaseUtil SQL
*/
@Component
public class DatabaseUtils {
private final static Logger log = LoggerFactory.getLogger(DatabaseUtils.class);
@Autowired
private DataSetService dataSetService;
@Autowired
private EbFormDataService dataService;
/**
* SQL
*
* @param entity SQL
* @return Map
* @throws RuntimeException SQL
*/
public Map<String, Object> executeSql(ExecuteSqlEntity entity) {
Map<String, Object> map = dataSetService.executeSql(entity);
if ("FAIL".equals(CommonUtils.null2String(map.get("status")).toUpperCase(Locale.ROOT))) {
log.error("sql执行失败=>{}", JSONObject.toJSONString(map));
throw new RuntimeException("sql执行异常");
} else {
return map;
}
}
/**
* SQL
*
* @param entity SQL
* @param pageNo
* @param pageSize
* @return Map
* @throws RuntimeException SQL
*/
public Map<String, Object> executeSql(ExecuteSqlEntity entity, int pageNo, int pageSize) {
entity.setPageNo(pageNo);
entity.setPageSize(pageSize);
Map<String, Object> map = dataSetService.executeForQuery(entity);
if ("FAIL".equals(CommonUtils.null2String(map.get("status")).toUpperCase(Locale.ROOT))) {
log.error("sql执行失败=>{}", JSONObject.toJSONString(map));
throw new RuntimeException("sql执行异常");
} else {
return map;
}
}
/**
* SQL
*
* @param sql SQL
* @param groupId ID
* @paramDesc ID select APPLICATION_MARK,APPLICATION_name from eteams.ds_mark_service_relation
* @return SQL
*/
public ExecuteSqlEntity getExecuteSqlEntity(String sql, String groupId) {
log.error("sql=>{}", sql);
ExecuteSqlEntity executeSqlEntity = new ExecuteSqlEntity();
executeSqlEntity.setSql(base64(sql));
executeSqlEntity.setGroupId(groupId);
executeSqlEntity.setSourceType(SourceType.LOGIC);
executeSqlEntity.setGroupKey("0");
return executeSqlEntity;
}
/**
* SQL Base64
*
* @param sql SQL
* @return
*/
public String base64(String sql) {
return Base64.encode(sql);
}
/**
*
*
* @param map Map
* @return Map
*/
public List<Map<String, Object>> getDataSourceList(Map<String, Object> map) {
List<Map<String, Object>> entity = new ArrayList();
if ("OK".equals(CommonUtils.null2String(map.get("status")).toUpperCase(Locale.ROOT)) && map.get("count") != null && CommonUtils.getIntValue(map.get("count")) > 0) {
entity = (List) map.get("records");
}
return keyToLowerCase((List) entity);
}
public Map<String, Object> getOneDataSource(Map<String, Object> map) {
List<Map<String, Object>> entity = getDataSourceList(map);
return (Map)(CollectionUtil.isNotEmpty(entity) ? (Map)entity.get(0) : new HashMap());
}
/**
* Map
*
* @param orgMapList Map
* @return Map
*/
public List<Map<String, Object>> keyToLowerCase(List<Map<String, Object>> orgMapList) {
List<Map<String, Object>> resultList = new ArrayList();
Iterator var2 = orgMapList.iterator();
while (var2.hasNext()) {
Map<String, Object> stringObjectMap = (Map) var2.next();
resultList.add(keyToLowerCase(stringObjectMap));
}
return resultList;
}
/**
* Map
*
* @param orgMap Map
* @return Map
*/
public Map<String, Object> keyToLowerCase(Map<String, Object> orgMap) {
Map<String, Object> resultMap = new HashMap();
if (orgMap != null && !orgMap.isEmpty()) {
Set<Map.Entry<String, Object>> entrySet = orgMap.entrySet();
Iterator var3 = entrySet.iterator();
while (var3.hasNext()) {
Map.Entry<String, Object> entry = (Map.Entry) var3.next();
String key = (String) entry.getKey();
Object value = entry.getValue();
resultMap.put(key.toLowerCase(), value);
}
return resultMap;
} else {
return resultMap;
}
}
/**
*
*
* @param sourceType sourceType
* ETEAMS :
* FORM: ebuilder
* LOGIC: ()
* EXTERNAL
* @return
*/
public List<Map<String, Object>> getDataGroups(String sourceType, Boolean flag) {
GroupQuery query = new GroupQuery();
query.setSourceType(SourceType.valueOf(sourceType));
query.setShowSqlDataset(flag);
DynamicParamDto dynamicParamDto = new DynamicParamDto();
dynamicParamDto.setUserId(10000L);
dynamicParamDto.setTenantKey("tk");
query.setDynamicParamDto(dynamicParamDto);
return dataSetService.getDataGroups(query);
}
/**
*
*
* @param sourceType
* @param groupId
* @param pageNum
* @param pageSize
* @return
*/
public Map<String, Object> getDataSets(String sourceType, String groupId, Integer pageNum, Integer pageSize) {
TableQuery tableQuery = new TableQuery();
tableQuery.setSourceType(SourceType.valueOf(sourceType));
tableQuery.setGroupId(groupId);
//非必传
//tableQuery.setName(name);
tableQuery.setPageNo(pageNum);
tableQuery.setPageSize(pageSize);
return dataSetService.getDataSetsByPage(tableQuery);
}
/**
*
* sourceType :LOGIC
* sourceId : 8494845523559165780
* groupId : weaver-crm-service
*
* @param
* @return
*/
public List<Map<String, Object>> getFields(String sourceType, String sourceId, String groupId) {
FieldQuery query = new FieldQuery();
query.setSourceType(SourceType.valueOf(sourceType));
query.setSourceId(sourceId);
query.setGroupId(groupId);
return dataSetService.getFields(query);
}
/**
* sql
* sourceType :LOGIC
* groupId : weaver-ebuilder-app-service
* sql : select * from ebda_app limit 10
*
* @param
* @return
*/
public Map<String, Object> execute(String sourceType, String groupId, String sql) {
//执行sql 参数sourceType groupId sql
ExecuteSqlEntity executeSqlEntity = new ExecuteSqlEntity();
executeSqlEntity.setSql(base64(sql));
executeSqlEntity.setGroupId(groupId);
executeSqlEntity.setSourceType(SourceType.valueOf(sourceType));
return dataSetService.executeSql(executeSqlEntity);
}
public String getMysqlPagedSql(String sql,int pageNo, int pageSize) {
if(pageNo<=0){
pageNo = 1;
}
if(pageSize<=0){
pageSize = 20;
}
int start = (pageNo-1)*pageSize;
int end = pageNo*pageSize;
return new StringBuffer().append(sql).append(
" LIMIT "+start+","+(end-start)).toString();
}
public Map<String, Object> executeForQuery(String sourceType, String groupId, String sql,List<SqlParamEntity> sqlparam) {
//执行sql 参数sourceType groupId sql sqlparam
ExecuteSqlEntity executeSqlEntity = new ExecuteSqlEntity();
executeSqlEntity.setSql(base64(sql));
executeSqlEntity.setGroupId(groupId);
executeSqlEntity.setSourceType(SourceType.valueOf(sourceType));
executeSqlEntity.setParams(sqlparam);
return dataSetService.executeSql(executeSqlEntity);
}
/**
* sql
* @param list
* @return
*/
public List<SqlParamEntity> getSqlParamEntity(List<String> list){
List<SqlParamEntity> sqlparam = new ArrayList<SqlParamEntity>();
for (String str : list){
SqlParamEntity sqlParamEntity = new SqlParamEntity();
sqlParamEntity.setParamType(SqlParamType.VARCHAR);
sqlParamEntity.setValue(str);
sqlparam.add(sqlParamEntity);
}
return sqlparam;
}
}

@ -0,0 +1,35 @@
package com.weaver.seconddev.njprojectreport.util;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Component
public class RequestUtil {
@Autowired
private DatabaseUtils databaseUtils;
public Map<String,Object> getmainlinename(String mainlineid, String tenant_key){
Map<String,Object> recordMap = new HashMap<String,Object>();
String groupId = "weaver-crm-service";
String sourceType = "LOGIC";
if(StringUtils.isNotBlank(mainlineid)){
String sql =" select id,name from mainline " +
" where id='"+mainlineid+"' " +
" and tenant_key='"+tenant_key+"' " +
" and delete_type='0' " ;
Map<String, Object> result = databaseUtils.execute(sourceType, groupId, sql);
List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
if(CollectionUtils.isNotEmpty(recordList)){
recordMap = recordList.get(0);
}
}
return recordMap;
}
}
Loading…
Cancel
Save