webservice new

ht
qijirenjian 2 months ago
parent d9e689188f
commit 4c7aaf9594

@ -35,7 +35,7 @@ public class AutoCreateWorkflowEncService {
String var5 = var1.getDATAS().getCreator();
String var6 = var1.getDATAS().getRequestLevel();
String var7 = var1.getDATAS().getMainTable();
String var8 = var1.getDATAS().getDetailTables();
String[] var8 = var1.getDATAS().getDetailTables();
String var9 = var1.getSYSID();
log.error("var9 " + var9);

@ -50,12 +50,17 @@ public class AutoCreateWorkflowService {
private static final String HOST = "http://10.6.23.235:20600/papi/openapi";
public String createWorkflow(String loginName, String password, String workflowId, String creator, String requestLevel, String mainTable , String detailTables){
public String createWorkflow(String loginName, String password, String workflowId, String creator, String requestLevel, String mainTable , String[] detailTables){
log.error("AutoCreateWorkflowService start");
log.error("loginName:"+loginName+"=> password:"+password+"=> workflowId:"+workflowId+"=> creator:"+creator);
//实现自定义webservice接口逻辑
String currentDate = DateUtils.getCurrentDate();
String curDateTime = DateUtils.getCurDateTime();
log.error("明细表数据detailTables:"+detailTables);
String detailTablesStr = String.join(",", detailTables);
log.error("明细表数据:"+detailTablesStr);
String workcode = creator;
//1.入参校验
String tips = SecondUtil.validationParam(loginName, password, workflowId, creator);
@ -99,6 +104,9 @@ public class AutoCreateWorkflowService {
log.error("创建人ID:" + creator + " 租户key:" + tenantKey);
if(StringUtils.isEmpty(creator)){
return "创建人ID信息为空请检查人员信息";
}
//紧急程度默认值
if ("".equals(requestLevel) || requestLevel == null) {
requestLevel = "0";
@ -205,9 +213,14 @@ public class AutoCreateWorkflowService {
}else {
log.error("普通字段值:"+value);
formDataDuty.setFieldType(1);
formDataDuty.setDataKey(key);
formDataDuty.setContent(code);
if(StringUtils.isNotEmpty(String.valueOf(value))){
formDataDuty.setFieldType(1);
formDataDuty.setDataKey(key);
formDataDuty.setContent(code);
}else{
log.error("普通字段值为空");
}
}
}
@ -215,91 +228,106 @@ public class AutoCreateWorkflowService {
formDataDutyList.add(formDataDuty);
}
log.error("明细表数据:"+detailTables);
///明细表数据
//[[{"wlbh":"1","wlms":"2","pjxhj3y":"3","bylj":"4","kcsl":"5","tksl":"6","jey":"7","cbzx":"8"},{"wlbh":"1","wlms":"2","pjxhj3y":"3","bylj":"4","kcsl":"5","tksl":"6","jey":"7","cbzx":"8"}],[{"aa":"1","bb":"2"}]]
JSONArray outerArray = JSON.parseArray(detailTables);
// 遍历外部 JSONArray
for (int i = 0; i < outerArray.size(); i++) {
JSONArray innerArray = outerArray.getJSONArray(i); // 获取内部的 JSONArray
//判断明细表id是否存在
if (detailFormId.size() < i+1) {
log.error("明细表"+(i+1)+"form_id未找到或不存在");
return "明细表"+(i+1)+"form_id未找到或不存在";
}
Long subFormId = detailFormId.get(i);
log.error("明细表"+(i+1)+"form_id"+subFormId);
// 遍历内部 JSONArray
for (int j = 0; j < innerArray.size(); j++) {
JSONObject jsonDetail = innerArray.getJSONObject(j);
Long optionId = null;
// 遍历 JSONObject 的键值对
for (String key : jsonDetail.keySet()) {
FormDataDuty formDataDuty = FormDataDuty.builder().build();
String value = jsonDetail.getString(key);
if (!"".equals(key)) {
if(key.contains("hrm:")){
//判断人力资源字段工号是否正确 (todo)
optionId = getIdByWorkcode(value);
if(optionId == null) {
return "工号为空或不存在";
}
key = key.replace("hrm:", "");
formDataDuty.setDataKey(key);
formDataDuty.setDataIndex((long) (j + 1));
formDataDuty.setSubFormId(subFormId);
DataOptions options = DataOptions.builder().optionId(optionId).build();
List<DataOptions> dataOptions = new ArrayList();
dataOptions.add(options);
formDataDuty.setDataOptions(dataOptions);
} else if (key.contains("com:") || key.contains("dep:")) { //e10 分部部门同一个字段
if(key.split(":").length != 3){
return "明细表表字段名"+key+"不符合规则...";
}
String str2 = key.split(":")[1];//关联人力资源字段
String str3 = key.split(":")[2];//当前字段
if(mainMap.get("hrm:"+str2) != null){
String hrmResource = (String) mainMap.get("hrm:"+str2);
Long id = getIdByWorkcode(hrmResource);
SimpleEmployee simpleEmployee = hrmCommonUtil.getSimpleEmployee(id);
optionId = simpleEmployee.getDepartmentId();
if (key.contains("com:")) {
optionId = Long.valueOf(departmentComInfo.getSubcompanyid1(String.valueOf(optionId)));
// if (detailTablesStr.startsWith("[") && detailTablesStr.endsWith("]")) {
// detailTablesStr = detailTablesStr.substring(1, detailTablesStr.length() - 1);
// }
// log.error("截取后的明细表数据:"+detailTablesStr);
JSONArray outerArray = JSON.parseArray(detailTablesStr);
if(outerArray.size()>0){
// 遍历外部 JSONArray
for (int i = 0; i < outerArray.size(); i++) {
JSONArray innerArray = outerArray.getJSONArray(i); // 获取内部的 JSONArray
//判断明细表id是否存在
if (detailFormId.size() < i+1) {
log.error("明细表"+(i+1)+"form_id未找到或不存在");
return "明细表"+(i+1)+"form_id未找到或不存在";
}
Long subFormId = detailFormId.get(i);
log.error("明细表"+(i+1)+"form_id"+subFormId);
// 遍历内部 JSONArray
for (int j = 0; j < innerArray.size(); j++) {
JSONObject jsonDetail = innerArray.getJSONObject(j);
Long optionId = null;
// 遍历 JSONObject 的键值对
for (String key : jsonDetail.keySet()) {
FormDataDuty formDataDuty = FormDataDuty.builder().build();
String value = jsonDetail.getString(key);
if (!"".equals(key)) {
if(key.contains("hrm:")){
//判断人力资源字段工号是否正确 (todo)
optionId = getIdByWorkcode(value);
if(optionId == null) {
return "工号为空或不存在";
}
key = str3;
key = key.replace("hrm:", "");
formDataDuty.setDataKey(key);
formDataDuty.setDataIndex((long) (j + 1));
formDataDuty.setSubFormId(subFormId);
DataOptions options = DataOptions.builder().optionId(optionId).build();
List<DataOptions> dataOptions = new ArrayList();
dataOptions.add(options);
formDataDuty.setDataOptions(dataOptions);
}else{
return "明细字段"+key+"不包含关联字段" ;
} else if (key.contains("com:") || key.contains("dep:")) { //e10 分部部门同一个字段
if(key.split(":").length != 3){
return "明细表表字段名"+key+"不符合规则...";
}
String str2 = key.split(":")[1];//关联人力资源字段
String str3 = key.split(":")[2];//当前字段
if(mainMap.get("hrm:"+str2) != null){
String hrmResource = (String) mainMap.get("hrm:"+str2);
Long id = getIdByWorkcode(hrmResource);
SimpleEmployee simpleEmployee = hrmCommonUtil.getSimpleEmployee(id);
optionId = simpleEmployee.getDepartmentId();
if (key.contains("com:")) {
optionId = Long.valueOf(departmentComInfo.getSubcompanyid1(String.valueOf(optionId)));
}
key = str3;
formDataDuty.setDataKey(key);
formDataDuty.setDataIndex((long) (j + 1));
formDataDuty.setSubFormId(subFormId);
DataOptions options = DataOptions.builder().optionId(optionId).build();
List<DataOptions> dataOptions = new ArrayList();
dataOptions.add(options);
formDataDuty.setDataOptions(dataOptions);
}else{
return "明细字段"+key+"不包含关联字段" ;
}
}else {
log.error("明细表普通字段值:"+value);
if(StringUtils.isNotEmpty(value)){
formDataDuty.setDataKey(key);
formDataDuty.setDataIndex((long) (j + 1));
formDataDuty.setContent(value);
//目前写死 后续在找方法
formDataDuty.setSubFormId(subFormId);
}else{
log.error("明细表普通字段值为空");
}
}
}else {
log.error("明细表普通字段值:"+value);
formDataDuty.setDataKey(key);
formDataDuty.setDataIndex((long) (j + 1));
formDataDuty.setContent(value);
//目前写死 后续在找方法
formDataDuty.setSubFormId(subFormId);
formDataDutyList.add(formDataDuty);
}
formDataDutyList.add(formDataDuty);
}
}
}
log.error("formDataDutyList数据"+formDataDutyList.size()+"-"+formDataDutyList);
}
log.error("formDataDutyList数据"+formDataDutyList.size()+"-"+formDataDutyList);
if(CollectionUtils.isNotEmpty(formDataDutyList)) {
JSONObject fromDataByDataDetails = getFromDataByDataDetails(formDataDutyList);

@ -0,0 +1,146 @@
package com.weaver.seconddev.njwebservice;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.weaver.common.hrm.util.Util;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.njwebservice.entity.BillingApplicationReq;
import com.weaver.seconddev.njwebservice.entity.ResponseInfo;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.Map;
/**
* @Author liang.cheng
* @Date 2025/1/21 15:56
* @Description: CW23-
* @Version 1.0
*/
@Service("billingApplicationService")
public class BillingApplicationService {
private final static Logger log = LoggerFactory.getLogger(BillingApplicationService.class);
@Autowired
private AutoCreateWorkflowService autoCreateWorkflowService;
public ResponseInfo billingApplicate(BillingApplicationReq param) {
log.error("BillingApplicationService:"+param.toString());
String systemFlag = param.getSystemFlag();
ResponseInfo res = new ResponseInfo();
if(!"SCF".equals(systemFlag)){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("系统标识不符!");
return res;
}
String creator = "";
String companycode = param.getCompanyCode();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
rs.executeSql("select oafqrgh from uf_applyUser where companycode='"+companycode+"' and lclx=0", CONN_TYPE.ebuilder.getType());
if(rs.next()){
creator = Util.null2String(rs.getString("oafqrgh"));
}
log.error("申请人:"+creator);
if("".equals(creator)){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE(param.getCompanyName()+"在OA系统里没有维护开票申请人");
return res;
}
if(param.getCompanyName() != null && !"".equals(param.getCompanyName())){
rs.executeSql("select id from eteams.dbo.department where type = 'subcompany' and name = '"+param.getCompanyName()+"'",CONN_TYPE.hrm.getType());
if(!rs.next()){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("申请公司在OA系统中不存在");
return res;
}
}
if(param.getApplyNo()!=null&&!"".equals(param.getApplyNo())){
rs.executeSql("select applyNo from formtable_main_2301 where applyNo='"+param.getApplyNo()+"'",CONN_TYPE.workflow.getType());
if(rs.next()){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("申请单号已存在,请不要重复申请!");
return res;
}
}
// if(param.getSh()==null||"".equals(param.getSh())){
// res.setISTAT("E");
// res.setRequestid("");
// res.setSRMSAGE("税号不能为空!");
// return res;
//
// }
String loginname = "SCF";
String password = "123456";
String workflowId = "4205";
String requestLevel = "0";
String billType = "";
if("1".equals(param.getBillType())){
billType = "0";
}else if ("2".equals(param.getBillType())){
billType = "1";
}
Map<String,String> map = new HashMap<String,String>();
map.put("hrm:sqr", creator);
map.put("com:sqr:sqdw", "");
map.put("dep:sqr:sqbm", "");
map.put("applyNo", param.getApplyNo());
map.put("companyName", param.getCompanyName());
map.put("companyCode", param.getCompanyCode());
map.put("billType", billType);
map.put("vendorName", param.getVendorName());
map.put("vendorCode", param.getVendorCode());
map.put("applyDate", param.getApplyDate());
map.put("amount", param.getAmount());
map.put("REMARKS", param.getRemarks());
String mainTable = JSON.toJSONString(map);
int len = param.getBillingApplicationResItem().length;
String detailTables = "";
if(len>0){
detailTables = "[[";
for(int i=0;i<len;i++){
detailTables += JSON.toJSONString(param.getBillingApplicationResItem()[i]);
detailTables += ",";
}
detailTables = detailTables.substring(0, detailTables.length()-1)+"]]";
}
log.error("明细表:"+detailTables);
//转成数组
JSONArray jsonArrays = JSON.parseArray(detailTables);
JSONArray innerArray = jsonArrays.getJSONArray(0);
String[] detailArray = new String[innerArray.size()];
String result = autoCreateWorkflowService.createWorkflow(loginname, password, workflowId, creator, requestLevel, mainTable, detailArray);
log.error("BillingApplicationImpl:"+result);
if(result.matches("^[1-9]+[0-9]*$")){
res.setISTAT("S");
res.setRequestid(result);
res.setSRMSAGE("流程创建成功!");
}else{
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE(result);
}
return res;
}
}

@ -1,21 +1,16 @@
package com.weaver.seconddev.njwebservice;
import com.weaver.common.hrm.util.Util;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.weaver.seconddev.njwebservice.entity.BillingApplicationResItem;
import com.weaver.seconddev.njwebservice.util.DocUtil;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import com.weaver.verupgrade.workflow.workflow.WorkflowAllComInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Service("demoService")
public class DemoService {
private final static Logger log = LoggerFactory.getLogger(DemoService.class);
@ -33,7 +28,9 @@ public class DemoService {
public String demo(String base64){
public String demo(String[] detailTables){
String detailTablesStr = String.join(",", detailTables);
// //实现自定义webservice接口逻辑
//String tips = SecondUtil.validationParam("OAAdmin", "123456", "100003460000005676", "2022050353");
@ -43,23 +40,23 @@ public class DemoService {
String workcodeId = "100003460000005676";
// 获取明细表表名
List<Map<String,Object>> list = new ArrayList<>();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
String formSql = "";
String sql = "SELECT * FROM form_table WHERE \n" +
" form_id IN ( SELECT id FROM sub_form WHERE form_id IN ( SELECT form_id FROM e10_core_business.dbo.form_table WHERE table_name = 'formtable_main_3540'))";
rs.executeSql(sql,poolname);
while (rs.next()){
Map<String,Object> map = new HashMap<>();
map.put("id", Util.getLongValue(rs.getString("id")));
map.put("table_type", Util.getIntValue(rs.getString("table_type")));
map.put("form_name", Util.null2String(rs.getString("form_name")));
list.add(map);
}
// List<Map<String,Object>> list = new ArrayList<>();
// RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
// String poolname = CONN_TYPE.workflow.getType();
//
// String formSql = "";
//
// String sql = "SELECT * FROM form_table WHERE \n" +
// " form_id IN ( SELECT id FROM sub_form WHERE form_id IN ( SELECT form_id FROM e10_core_business.dbo.form_table WHERE table_name = 'formtable_main_3540'))";
// rs.executeSql(sql,poolname);
// while (rs.next()){
// Map<String,Object> map = new HashMap<>();
// map.put("id", Util.getLongValue(rs.getString("id")));
// map.put("table_type", Util.getIntValue(rs.getString("table_type")));
// map.put("form_name", Util.null2String(rs.getString("form_name")));
// list.add(map);
//
// }
// String token = "";
@ -138,6 +135,71 @@ public class DemoService {
// e.printStackTrace();
// }
return "";
return detailTablesStr;
}
public static void main(String[] args) {
BillingApplicationResItem build = BillingApplicationResItem.builder()
.billNo("1")
.dueDate("2024-10-01")
.money("134")
.receiveAccountName("3432")
.build();
BillingApplicationResItem build1 = BillingApplicationResItem.builder()
.billNo("1")
.dueDate("2024-10-02")
.money("1344")
.receiveAccountName("3432")
.build();
BillingApplicationResItem[] param = {
build,
build1
};
String detailTables = "";
detailTables = "[[";
for(int i=0;i<param.length;i++){
detailTables += JSON.toJSONString(param[i]);
detailTables += ",";
}
detailTables = detailTables.substring(0, detailTables.length()-1)+"]]";
System.out.println(detailTables);
JSONArray jsonArrays = JSON.parseArray(detailTables);
// 获取第一个 JSONArray
JSONArray innerArray = jsonArrays.getJSONArray(0);
// 创建 String[] 数组
String[] resultArray = new String[innerArray.size()];
for (int i = 0; i < innerArray.size(); i++) {
JSONObject jsonObject = innerArray.getJSONObject(i);
resultArray[i] = jsonObject.toJSONString();
}
String detailTablesStr = String.join(",", detailTables);
System.out.println("新"+detailTablesStr);
// String detailTablesStr = "[[" + String.join(",", resultArray) + "]]";
// System.out.println("转换为 JSON 字符串:"+detailTablesStr);
//
//
// JSONArray outerArray = JSON.parseArray(detailTablesStr);
//
// // 遍历外部 JSONArray
// for (int i = 0; i < outerArray.size(); i++) {
// JSONArray t = outerArray.getJSONArray(i);
// System.out.println(t);
// }
}
}

@ -0,0 +1,133 @@
package com.weaver.seconddev.njwebservice;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.weaver.common.hrm.util.Util;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.njwebservice.entity.DiscountApplicationReq;
import com.weaver.seconddev.njwebservice.entity.ResponseInfo;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.Map;
/**
* @Author liang.cheng
* @Date 2025/1/21 17:44
* @Description: CW24-
* @Version 1.0
*/
@Service("discountApplicationService")
public class DiscountApplicationService {
private final static Logger log = LoggerFactory.getLogger(DiscountApplicationService.class);
@Autowired
private AutoCreateWorkflowService autoCreateWorkflowService;
public ResponseInfo discountApplicate(DiscountApplicationReq param) {
log.error("DiscountApplicationService:"+param.toString());
String systemFlag = param.getSystemFlag();
ResponseInfo res = new ResponseInfo();
if(!"SCF".equals(systemFlag)){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("系统标识不符!");
return res;
}
String creator = "";
String companycode = param.getCompanyCode();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
rs.executeSql("select oafqrgh from uf_applyUser where companycode='"+companycode+"' and lclx=0", CONN_TYPE.ebuilder.getType());
if(rs.next()){
creator = Util.null2String(rs.getString("oafqrgh"));
}
log.error("申请人:"+creator);
if("".equals(creator)){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE(param.getCompanyName()+"在OA系统里没有维护折现申请人");
return res;
}
if(param.getCompanyName() != null && !"".equals(param.getCompanyName())){
rs.executeSql("select id from eteams.dbo.department where type = 'subcompany' and name = '"+param.getCompanyName()+"'",CONN_TYPE.hrm.getType());
if(!rs.next()){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("申请公司在OA系统中不存在");
return res;
}
}
if(param.getDiscountNo() != null && !"".equals(param.getDiscountNo())){
rs.executeSql("select discountNo from e10_core_business.dbo.formtable_main_2302 where discountNo='"+param.getDiscountNo()+"'",CONN_TYPE.workflow.getType());
if(rs.next()){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("申请单号已存在,请不要重复申请!");
return res;
}
}
String loginname = "SCF";
String password = "123456";
String workflowId = "4206";
String requestLevel = "0";
Map<String,String> map = new HashMap<>();
map.put("hrm:sqr", creator);
map.put("com:sqr:sqdw", "");
map.put("dep:sqr:sqbm", "");
map.put("discountNo", param.getDiscountNo());
map.put("companyName", param.getCompanyName());
map.put("companyCode", param.getCompanyCode());
map.put("vendorName", param.getVendorName());
map.put("vendorCode", param.getVendorCode());
map.put("applyDate", param.getApplyDate());
map.put("amount", param.getAmount());
map.put("rate", param.getRate());
map.put("remarks", param.getRemarks());
map.put("busType",param.getBusType());
String mainTable = JSON.toJSONString(map);
int len = param.getDiscountApplicationReqItem().length;
String detailTables = "";
if(len>0){
detailTables = "[[";
for(int i=0;i<len;i++){
detailTables += JSON.toJSONString(param.getDiscountApplicationReqItem()[i]);
detailTables += ",";
}
detailTables = detailTables.substring(0, detailTables.length()-1)+"]]";
}
log.error("明细表:"+detailTables);
//转成数组
JSONArray jsonArrays = JSON.parseArray(detailTables);
JSONArray innerArray = jsonArrays.getJSONArray(0);
String[] detailArray = new String[innerArray.size()];
String result = autoCreateWorkflowService.createWorkflow(loginname, password, workflowId, creator, requestLevel, mainTable, detailArray);
log.error("DiscountApplicationImpl:"+result);
if(result.matches("^[1-9]+[0-9]*$")){
res.setISTAT("S");
res.setRequestid(result);
res.setSRMSAGE("流程创建成功!");
}else{
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE(result);
}
return res;
}
}

@ -0,0 +1,142 @@
package com.weaver.seconddev.njwebservice;
import com.alibaba.fastjson.JSON;
import com.weaver.common.hrm.util.Util;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.njwebservice.entity.DiscountedInvoiceInfoReq;
import com.weaver.seconddev.njwebservice.entity.ResponseInfo;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @Author liang.cheng
* @Date 2025/1/21 14:09
* @Description: ZWZX-YS05-
* @Version 1.0
*/
@Service("discountedInvoiceApplicationService")
public class DiscountedInvoiceApplicationService {
private final static Logger log = LoggerFactory.getLogger(AutoCreateWorkflowService.class);
@Autowired
private AutoCreateWorkflowService autoCreateWorkflowService;
public ResponseInfo discountedInvoiceApplicate(DiscountedInvoiceInfoReq param) {
log.error("DiscountedInvoiceApplicationService:"+param.toString());
ResponseInfo res = new ResponseInfo();
String systemFlag = param.getSystemFlag();
if(!"EAS".equals(systemFlag)){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("系统标识不符!");
return res;
}
String creator = "";
String companycode = param.getCompanyCode();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.ebuilder.getType();
rs.executeSql("select easfqrgh from uf_applyUser where companycode='"+companycode+"' and lclx=1",poolname);
if(rs.next()){
creator = Util.null2String(rs.getString("easfqrgh"));
}
log.error("发票申请人:"+creator);
if("".equals(creator)){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE(param.getCompanyName()+"在OA系统里没有维护应收折现发票申请人");
return res;
}
if(param.getCompanyName() != null && !"".equals(param.getCompanyName())){
rs.executeSql("select id from eteams.dbo.department where type = 'subcompany' and name = '"+param.getCompanyName()+"'",CONN_TYPE.hrm.getType());
if(!rs.next()){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("申请公司在OA系统中不存在");
return res;
}
}
if(param.getSh()==null||"".equals(param.getSh())){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("税号不能为空!");
return res;
}
//String gscode = Util.null2String(getPropValue("htwsaccount", "ZWZDYW")).trim();
//todo 配置文件未建立
String gscode = "";
List<String> list = Arrays.asList(gscode.split(","));
String workflowId = "100003460000004207";//e10 100003460000004207 e9 4207
String tablename = "formtable_main_2304";//e10 formtable_main_2304 e9 formtable_main_2304
if(list.contains(param.getCompanyCode())){
workflowId = "100003460000004574";//e10 100003460000004574 e9 4574
tablename = "formtable_main_2438";//e10 formtable_main_2638 e9 formtable_main_2638
}
if(param.getBoeNum()!=null&&!"".equals(param.getBoeNum())){
rs.executeSql("select boeNum from "+tablename+" where boeNum='"+param.getBoeNum()+"'",CONN_TYPE.workflow.getType());
if(rs.next()){
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE("申请单号已存在,请不要重复申请!");
log.error("DiscountedInvoiceApplicationImpl-Error:state="+res.getISTAT()+"||message="+res.getSRMSAGE());
return res;
}
}
String loginname = "EAS";
String password = "123456";
String requestLevel = "0";
Map<String,String> map = new HashMap<>();
map.put("hrm:sqr", creator);
map.put("com:sqr:sqdw", "");
map.put("dep:sqr:sqbm", "");
map.put("boeNum", param.getBoeNum());
map.put("boeHeaderId", param.getBoeHeaderId());
map.put("companyName", param.getCompanyName());
map.put("companyCode", param.getCompanyCode());
map.put("boeDeptName", param.getBoeDeptName());
map.put("boeDeptCode", param.getBoeDeptCode());
map.put("vendorCode", param.getVendorCode());
map.put("vendorName", param.getVendorName());
map.put("applyDate", param.getApplyDate());
map.put("applyAmount", param.getApplyAmount());
map.put("sh", param.getSh());
String mainTable = JSON.toJSONString(map);
String[] detailTables = {};
String result = autoCreateWorkflowService.createWorkflow(loginname, password, workflowId, creator, requestLevel, mainTable, detailTables);
log.error("DiscountedInvoiceApplicationImpl:"+result);
if(result.matches("^[1-9]+[0-9]*$")){
res.setISTAT("S");
res.setRequestid(result);
res.setSRMSAGE("流程创建成功!");
}else{
res.setISTAT("E");
res.setRequestid("");
res.setSRMSAGE(result);
}
return res;
}
}

@ -0,0 +1,74 @@
package com.weaver.seconddev.njwebservice;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.njwebservice.entity.EasSpzfResponseInfo;
import com.weaver.seconddev.njwebservice.entity.EasTzlhtSpzfRes;
import com.weaver.seconddev.njwebservice.entity.EasTzlhtSpzfResData;
import com.weaver.seconddev.njwebservice.util.SecondUtil;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
/**
* @Author liang.cheng
* @Date 2025/1/20 17:37
* @Description:
* @Version 1.0
*/
@Service("easTzlhtSpzfApplicationWebService")
public class EasTzlhtSpzfApplicationService {
private final static Logger log = LoggerFactory.getLogger(EasTzlhtSpzfApplicationService.class);
public EasSpzfResponseInfo easTzlhtSpzfApplicate(EasTzlhtSpzfRes param) {
log.error("EasTzlhtSpzfApplicationImpl-----start"+param.toString());
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
EasSpzfResponseInfo res = new EasSpzfResponseInfo();
// if(param.getDATAS()!=null&&param.getDATAS().length>0) {
EasTzlhtSpzfResData data = param.getDatas();
String loginName = data.getLoginname();
String password = data.getPassword();
String workflowId = data.getWorkflowId();
String requestId = data.getRequestId();
String optType = data.getOptType();
if (!"EAS".equals(loginName) && !"123456".equals(password)) {
res.setIsTat("F");
res.setMessage("接口用户名/密码不对!");
return res;
}
if (workflowId == null || workflowId.equals("")) {
res.setIsTat("F");
res.setMessage("流程id为空");
return res;
}
if (requestId == null || requestId.equals("")) {
res.setIsTat("F");
res.setMessage("请求id为空");
return res;
}
String tablename = SecondUtil.getTableName(workflowId);
log.error("tablename:"+tablename);
String isYX = "0";
if ("N".equals(optType)) {//流程作废
isYX = "1";
}
String sql = "update " + tablename + " set sfyx ='" + isYX + "' where requestId = " + requestId;
rs.executeSql(sql,poolname);
res.setIsTat("S");
res.setMessage("接口调用成功!");
return res;
// }else{
// res.setISTAT("F");
// res.setMESSAGE("请传入请求参数!");
// return res;
// }
}
}

@ -0,0 +1,52 @@
package com.weaver.seconddev.njwebservice;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.weaver.seconddev.njwebservice.entity.MeetingReq;
import com.weaver.seconddev.njwebservice.entity.MeetingRes;
import com.weaver.seconddev.njwebservice.entity.MeetingReturn;
import com.weaver.seconddev.njwebservice.util.SecondUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
@Service("meetingService")
public class MeetingService {
private final static Logger log = LoggerFactory.getLogger(MeetingService.class);
public MeetingRes getMeeting(MeetingReq param) {
String loginname = param.getDATAS().getLoginname();
String password = param.getDATAS().getPassword();
String companyIds = param.getDATAS().getCompanyIds();
String startdate = param.getDATAS().getStartdate();
String enddate = param.getDATAS().getEnddate();
String sysid = param.getSYSID();
String sendId = param.getSENDID();
String itfid = param.getITFID();
String message = SecondUtil.getMeetingInfo(loginname, password, companyIds, startdate, enddate);
MeetingRes res = new MeetingRes();
res.setSYSID(sysid);
res.setITFID(itfid);
res.setSENDID(sendId);
JSONObject object = JSONObject.parseObject(message);
String status = object.getString("status");
String msg = object.getString("msg");
if ("success".equals(status)) {
res.setISTAT("S");
res.setMESSAGE("获取成功");
res.setDATAS((MeetingReturn[]) JSONArray.parseObject(msg, MeetingReturn[].class));
log.error("获取公司ID为" + companyIds + ",开始时间为" + startdate + ",结束时间为" + enddate + "的会议室信息成功!");
} else {
res.setISTAT("F");
res.setMESSAGE(msg);
res.setDATAS((MeetingReturn[])null);
log.error("获取公司ID为" + companyIds + ",开始时间为" + startdate + ",结束时间为" + enddate + "的会议室信息失败:" + msg);
}
return res;
}
}

@ -0,0 +1,101 @@
package com.weaver.seconddev.njwebservice;
import com.alibaba.fastjson.JSON;
import com.weaver.common.hrm.util.Util;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.njwebservice.entity.ToDoCountReq;
import com.weaver.seconddev.njwebservice.entity.ToDoRequestReq;
import com.weaver.seconddev.njwebservice.entity.ToDoRequestRes;
import com.weaver.seconddev.njwebservice.entity.ToDoWorkFlow;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import com.weaver.verupgrade.workflow.webservices.WorkflowRequestInfo;
import com.weaver.verupgrade.workflow.webservices.WorkflowService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.net.URLEncoder;
/**
*
*/
@Service("outToDoWorkflowService")
public class OutToDoWorkflowService {
@Autowired
private WorkflowService workflowService;
private final static Logger log = LoggerFactory.getLogger(OutToDoWorkflowService.class);
public String outToDoWorkflowCount(String json) {
log.error("outToDoWorkflowCount入参:"+json);
ToDoCountReq param = JSON.parseObject(json, ToDoCountReq.class);
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.hrm.getType();
String sql = "select ID from eteams.employee where status = 'normal' and job_num = '"+param.getWorkcode()+"'";
rs.executeSql(sql,poolname);
if (rs.next()){
Long userId = Util.getLongValue(rs.getString("id"));
int toDoWorkflowRequestCount = workflowService.getToDoWorkflowRequestCount(userId, param.getConditions());
log.error("待办数量:"+toDoWorkflowRequestCount);
return String.valueOf(toDoWorkflowRequestCount);
}else {
return "未找到该用户";
}
}
public ToDoRequestRes outToDoWorkflowList(String json) {
// String pc_url = Util.null2String(this.getPropValue("htportaloaUrl", "pc_url")).trim();
// String mobile_url = Util.null2String(this.getPropValue("htportaloaUrl", "mobile_url")).trim();
log.error("outToDoWorkflowCount入参:"+json);
ToDoRequestReq param = JSON.parseObject(json, ToDoRequestReq.class);
// todo 访问ip 配置
String pc_url = "";
String mobile_url = "";
ToDoRequestRes res = new ToDoRequestRes();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.hrm.getType();
String sql = "select id from eteams.employee where status = 'normal' and job_num = '"+param.getWorkcode()+"'";
rs.executeSql(sql,poolname);
if (!rs.next()) {
res.setMsg("未找到该用户");
} else {
param.setWorkcode(Util.null2String(rs.getString("id")));
Long userId = Util.getLongValue(rs.getString("id"));
log.error("用户id:"+userId);
WorkflowRequestInfo[] info = workflowService.getToDoWorkflowRequestList(Integer.parseInt(param.getPageNo()), Integer.parseInt(param.getPageSize()),
Integer.parseInt(param.getRecordCount()), userId, param.getConditions());
res.setMsg("find:" + info.length);
ToDoWorkFlow[] todo = new ToDoWorkFlow[info.length];
for(int i = 0; i < info.length; ++i) {
ToDoWorkFlow wftodo = new ToDoWorkFlow();
wftodo.createTime = Util.null2String(info[i].getCreateTime());
wftodo.creatorName = Util.null2String(info[i].getCreatorName());
wftodo.currentNodeName = Util.null2String(info[i].getCurrentNodeName());
wftodo.lastOperateTime = Util.null2String(info[i].getLastOperateTime());
wftodo.lastOperatorName = Util.null2String(info[i].getLastOperatorName());
wftodo.receiveTime = Util.null2String(info[i].getReceiveTime());
wftodo.requestId = Util.null2String(info[i].getRequestId());
wftodo.requestLevel = Util.null2String(info[i].getRequestLevel());
wftodo.requestName = Util.null2String(info[i].getRequestName());
wftodo.workflowId = Util.null2String(info[i].getWorkflowBaseInfo().getWorkflowId());
wftodo.workflowName = Util.null2String(info[i].getWorkflowBaseInfo().getWorkflowName());
wftodo.workflowTypeId = Util.null2String(info[i].getWorkflowBaseInfo().getWorkflowTypeId());
wftodo.workflowTypeName = Util.null2String(info[i].getWorkflowBaseInfo().getWorkflowTypeName());
wftodo.mobileurl = mobile_url + URLEncoder.encode("/spa/workflow/static4mobileform/index.html#/req?requestid=" + wftodo.requestId);
wftodo.pcurl = pc_url + URLEncoder.encode("/spa/workflow/static4form/index.html#/main/workflow/req?requestid=" + wftodo.requestId);
todo[i] = wftodo;
}
res.setWorkFlow(todo);
}
return res;
}
}

@ -0,0 +1,114 @@
package com.weaver.seconddev.njwebservice;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.njwebservice.entity.VendorPunishReq;
import com.weaver.seconddev.njwebservice.entity.VendorPunishReqData;
import com.weaver.seconddev.njwebservice.entity.VendorPunishResponseInfo;
import com.weaver.seconddev.njwebservice.entity.VendorPunishReturnData;
import com.weaver.seconddev.njwebservice.util.SecondUtil;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
/**
* @Author liang.cheng
* @Date 2025/1/20 15:44
* @Description:
* @Version 1.0
*/
@Service("vendorPunishApplicationWebService")
public class VendorPunishApplicationService {
private final static Logger log = LoggerFactory.getLogger(VendorPunishApplicationService.class);
public VendorPunishResponseInfo vendorPunishApplicate(VendorPunishReq param) {
log.error("VendorPunishApplicationImpl-----start"+param.toString());
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
VendorPunishResponseInfo res = new VendorPunishResponseInfo();
res.setItfId(param.getItFid());
res.setSendId(param.getSendId());
res.setSysId(param.getSysId());
VendorPunishReturnData resData = new VendorPunishReturnData();
VendorPunishReqData data = param.getDatas();
String workflowId = data.getWorkflowId();
String requestId = data.getRequestId();
String type = data.getType();
String isAgree = data.getIsAgree();
String supplierOpinion = data.getSupplierOpinion();
int bearMoney = data.getBearMoney();
resData.setRequestId(requestId);
resData.setWorkflowId(workflowId);
res.setReturnData(resData);
if (workflowId == null || workflowId.equals("")) {
resData.setIsTat("E");
resData.setMessage("流程id为空");
return res;
}
String tablename = SecondUtil.getTableName(workflowId);
if (requestId == null || requestId.equals("")) {
resData.setIsTat("E");
resData.setMessage("请求id为空");
return res;
}
if (type == null || type.equals("")) {
resData.setIsTat("E");
resData.setMessage("类型为空!");
return res;
}else{
if("1".equals(type)){//质量问题确认
if (isAgree == null || isAgree.equals("")) {
resData.setIsTat("E");
resData.setMessage("供应商是否同意为空!");
return res;
}else if(!isAgree.equals("0")&&!isAgree.equals("1")){
resData.setIsTat("E");
resData.setMessage("供应商是否同意传错!");
return res;
}
if (supplierOpinion == null || supplierOpinion.equals("")) {
resData.setIsTat("E");
resData.setMessage("供应商厂商意见为空!");
return res;
}
String sql = "update "+tablename+" set sfty='"+isAgree+"',gyscsyj='"+supplierOpinion+"' where requestId= '"+requestId+"'";
rs.executeSql(sql,poolname);
log.error("VendorPunishApplicationImpl--"+requestId+"更新成功");
}else if("2".equals(type)){//罚款金额确认
if (supplierOpinion == null || supplierOpinion.equals("")) {
resData.setIsTat("E");
resData.setMessage("供应商厂商意见为空!");
return res;
}
if(bearMoney<=0){
resData.setIsTat("E");
resData.setMessage("愿意承担金额必须大于0");
return res;
}
String sql = "update "+tablename+" set gyscsfkyj='"+supplierOpinion+"',yycdje='"+bearMoney+"' where requestId= '"+requestId+"'";
rs.executeSql(sql,poolname);
log.error("VendorPunishApplicationImpl--"+requestId+"更新成功");
}else{
resData.setIsTat("E");
resData.setMessage("类型应为1或者2");
return res;
}
}
resData.setIsTat("S");
resData.setMessage("接口调用成功!");
return res;
}
}

@ -0,0 +1,56 @@
package com.weaver.seconddev.njwebservice;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.njwebservice.entity.WlpsSyResponse;
import com.weaver.seconddev.njwebservice.entity.WlpsSyReturn;
import com.weaver.seconddev.njwebservice.util.SecondUtil;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
/**
* @Author liang.cheng
* @Date 2025/1/20 13:54
* @Description:
* @Version 1.0
*/
@Service("wlpsSyGetResWebservice")
public class WlpsSyGetResService {
private final static Logger log = LoggerFactory.getLogger(WlpsSyGetResService.class);
public void getRes(WlpsSyResponse res) {
log.error("接收MesWLPS_SY接口返回值开始");
String isTat = res.getIsTat();
String systemId = res.getSysId();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
try{
if("S".equals(isTat)){
WlpsSyReturn[] ret = res.getWlpsSyReturn();
for(int i=0;i<ret.length;i++){
String workflowid = ret[i].getWorkflowID();
String tablename = SecondUtil.getTableName(workflowid);
String requestid = ret[i].getRequestId();
String state = ret[i].getIsTat();
String message = ret[i].getMessage();
if(!"".equals(workflowid)&&!"".equals(requestid)&&workflowid.equals(SecondUtil.getWorkflowIdByReq(requestid))){
String sql = "update "+tablename+" set state='"+state+"',message='"+message+"' where requestId="+requestid;
rs.executeSql(sql,poolname);
log.error(systemId+"--"+requestid+"更新成功");
}else{
log.error("MesWLPS_SY返回数据不符合要求"+res);
}
}
}
log.error("接收MesWLPS_SY接口返回值结束");
}catch(Exception e){
log.error("接收MesWLPS_SY接口返回值出错"+e.toString());
}
}
}

@ -0,0 +1,33 @@
package com.weaver.seconddev.njwebservice;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
@Service("workplanService")
public class WorkplanService {
private final static Logger log = LoggerFactory.getLogger(WorkplanService.class);
public String deleteWorkPlan(String var1, int var2) {
// String var3 = "";
// User var4 = new User(var2);
// HashMap var5 = new HashMap();
// new HashMap();
// var5.put("workid", var1);
// WorkPlanBaseService var7 = (WorkPlanBaseService)ServiceUtil.getService(WorkPlanBaseServiceImpl.class, var4);
// Map var6 = var7.deleteWorkPlan(var5);
// if (!(Boolean)var6.get("status")) {
// var3 = (String)var6.get("error");
// } else {
// var3 = "success";
// }
//
return "";
}
}

@ -0,0 +1,64 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Arrays;
/**
* @Author liang.cheng
* @Date 2025/1/21 15:45
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class BillingApplicationReq {
private String systemFlag;
private String applyNo;
private String companyName;
private String companyCode;
private String billType;
private String vendorName;
private String vendorCode;
private String applyDate;
private String amount;
private String remarks;
private String itFid;
private BillingApplicationResItem[] BillingApplicationResItem;
@Override
public String toString() {
return "BillingApplicationReq{" +
"systemFlag='" + systemFlag + '\'' +
", applyNo='" + applyNo + '\'' +
", companyName='" + companyName + '\'' +
", companyCode='" + companyCode + '\'' +
", billType='" + billType + '\'' +
", vendorName='" + vendorName + '\'' +
", vendorCode='" + vendorCode + '\'' +
", applyDate='" + applyDate + '\'' +
", amount='" + amount + '\'' +
", remarks='" + remarks + '\'' +
", itFid='" + itFid + '\'' +
", BillingApplicationResItem=" + Arrays.toString(BillingApplicationResItem) +
'}';
}
}

@ -0,0 +1,49 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/21 15:49
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class BillingApplicationResItem {
private String pid;
private String billNo;
private String paymentId;
private String dueDate;
private String receiveAccountName;
private String receiveAccount;
private String receiveBankName;
private String money;
@Override
public String toString() {
return "BillingApplicationResItem{" +
"pid='" + pid + '\'' +
", billNo='" + billNo + '\'' +
", paymentId='" + paymentId + '\'' +
", dueDate='" + dueDate + '\'' +
", receiveAccountName='" + receiveAccountName + '\'' +
", receiveAccount='" + receiveAccount + '\'' +
", receiveBankName='" + receiveBankName + '\'' +
", money='" + money + '\'' +
'}';
}
}

@ -0,0 +1,46 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/21 17:29
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class DiscountApplicationReq {
private String systemFlag;
private String discountNo;
private String companyName;
private String companyCode;
private String vendorName;
private String vendorCode;
private String applyDate;
private String amount;
private String rate;
private String remarks;
private String itFid;
private String busType;
private DiscountApplicationReqItem[] DiscountApplicationReqItem;
}

@ -0,0 +1,31 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/21 17:50
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class DiscountApplicationReqItem {
private String pid;
private String billNo;
private String paymentId;
private String dueDate;
private String money;
private String oriBillDate;
}

@ -0,0 +1,64 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/21 14:03
* @Description: TODO
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class DiscountedInvoiceInfoReq {
private String systemFlag;
private String boeNum;
private String boeHeaderId;
private String companyName;
private String companyCode;
private String boeDeptName;
private String boeDeptCode;
private String vendorCode;
private String vendorName;
private String applyDate;
private String applyAmount;
private String itFid;
private String sh;
@Override
public String toString() {
return "DiscountedInvoiceInfoReq{" +
"systemFlag='" + systemFlag + '\'' +
", boeNum='" + boeNum + '\'' +
", boeHeaderId='" + boeHeaderId + '\'' +
", companyName='" + companyName + '\'' +
", companyCode='" + companyCode + '\'' +
", boeDeptName='" + boeDeptName + '\'' +
", boeDeptCode='" + boeDeptCode + '\'' +
", vendorCode='" + vendorCode + '\'' +
", vendorName='" + vendorName + '\'' +
", applyDate='" + applyDate + '\'' +
", applyAmount='" + applyAmount + '\'' +
", itFid='" + itFid + '\'' +
", sh='" + sh + '\'' +
'}';
}
}

@ -0,0 +1,34 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/20 17:46
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class EasSpzfResponseInfo {
/**接口调用标识**/
private String sendId;
/**接口编号**/
private String itfId;
/**系统编号**/
private String sysId;
/**接口处理状态**/
private String isTat;
/**处理消息 **/
private String message;
}

@ -0,0 +1,31 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/20 17:27
* @Description: TODO
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class EasTzlhtSpzfRes {
/**接口调用标识**/
private String sendId;
/**接口编号**/
private String itfId;
/**系统编号**/
private String sysId;
/**业务数据结构**/
private EasTzlhtSpzfResData datas;
}

@ -0,0 +1,36 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/20 17:26
* @Description: TODO
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class EasTzlhtSpzfResData {
/**登录名**/
private String loginname;
/**密码**/
private String password;
/**流程ID**/
private String workflowId;
/**创建人工号**/
private String creator;
/**请求级别( 0正常,1重要,2紧急**/
private String requestLevel;
/**操作类型 标识为N使OA相应流程作废**/
private String optType;
/**报账单号**/
private String boeNum;
/**原请求号**/
private String requestId;
}

@ -0,0 +1,21 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class MeetingParam {
String loginname;
String password;
String companyIds;
String startdate;
String enddate;
}

@ -0,0 +1,20 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class MeetingReq {
String SENDID = "";
String ITFID = "";
String SYSID = "";
MeetingParam DATAS;
}

@ -0,0 +1,23 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class MeetingRes {
String SENDID = "";
String ITFID = "";
String SYSID = "";
String ISTAT = "";
String MESSAGE = "";
MeetingReturn[] DATAS;
}

@ -0,0 +1,31 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class MeetingReturn {
String roomname;
String meetingId;
String meetingname;
String begindate;
String enddate;
String caller;
String contacter;
String content;
String members;
int meetingstatus;
}

@ -0,0 +1,49 @@
package com.weaver.seconddev.njwebservice.entity;
/**
* @Author liang.cheng
* @Date 2025/1/21 13:57
* @Description:
* @Version 1.0
*/
public class ResponseInfo {
private String ISTAT;
private String requestid;
private String SRMSAGE;
public String getISTAT() {
return ISTAT;
}
public void setISTAT(String iSTAT) {
ISTAT = iSTAT;
}
public String getRequestid() {
return requestid;
}
public void setRequestid(String requestid) {
this.requestid = requestid;
}
public String getSRMSAGE() {
return SRMSAGE;
}
public void setSRMSAGE(String sRMSAGE) {
if("-1".equals(sRMSAGE)){
sRMSAGE = "创建流程失败";
}else if("-2".equals(sRMSAGE)){
sRMSAGE = "用户没有流程创建权限";
}else if("-3".equals(sRMSAGE)){
sRMSAGE = "创建流程基本信息失败";
}else if("-4".equals(sRMSAGE)){
sRMSAGE = "保存表单主表信息失败";
}else if("-5".equals(sRMSAGE)){
sRMSAGE = "更新紧急程度失败";
}else if("-6".equals(sRMSAGE)){
sRMSAGE = "流程操作者失败";
}else if("-7".equals(sRMSAGE)){
sRMSAGE = "流转至下一节点失败";
}else if("-8".equals(sRMSAGE)){
sRMSAGE = "节点附加操作失败";
}
SRMSAGE = sRMSAGE;
}
}

@ -16,6 +16,6 @@ public class SubmitWorkflowParam {
String creator;
String requestLevel;
String mainTable;
String detailTables;
String[] detailTables;
}

@ -0,0 +1,25 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/6 6:08 PM
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class ToDoCountReq {
private String workcode;
private String[] conditions;
}

@ -0,0 +1,31 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/6 6:08 PM
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class ToDoRequestReq {
private String pageNo;
private String pageSize;
private String recordCount;
private String workcode;
private String[] conditions;
}

@ -0,0 +1,26 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/6 6:08 PM
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class ToDoRequestRes {
private String msg;
private ToDoWorkFlow[] workFlow;
}

@ -0,0 +1,149 @@
package com.weaver.seconddev.njwebservice.entity;
/**
* @Author liang.cheng
* @Date 2025/1/6 6:08 PM
* @Description:
* @Version 1.0
*/
public class ToDoWorkFlow {
public String createTime = "";
public String creatorName = "";
public String currentNodeName = "";
public String lastOperateTime = "";
public String lastOperatorName = "";
public String receiveTime = "";
public String requestId = "";
public String requestLevel = "";
public String requestName = "";
public String workflowId = "";
public String workflowName = "";
public String workflowTypeId = "";
public String workflowTypeName = "";
public String pcurl = "";
public String mobileurl = "";
public String getCreateTime() {
return createTime;
}
public void setCreateTime(String createTime) {
this.createTime = createTime;
}
public String getCreatorName() {
return creatorName;
}
public void setCreatorName(String creatorName) {
this.creatorName = creatorName;
}
public String getCurrentNodeName() {
return currentNodeName;
}
public void setCurrentNodeName(String currentNodeName) {
this.currentNodeName = currentNodeName;
}
public String getLastOperateTime() {
return lastOperateTime;
}
public void setLastOperateTime(String lastOperateTime) {
this.lastOperateTime = lastOperateTime;
}
public String getLastOperatorName() {
return lastOperatorName;
}
public void setLastOperatorName(String lastOperatorName) {
this.lastOperatorName = lastOperatorName;
}
public String getReceiveTime() {
return receiveTime;
}
public void setReceiveTime(String receiveTime) {
this.receiveTime = receiveTime;
}
public String getRequestId() {
return requestId;
}
public void setRequestId(String requestId) {
this.requestId = requestId;
}
public String getRequestLevel() {
return requestLevel;
}
public void setRequestLevel(String requestLevel) {
this.requestLevel = requestLevel;
}
public String getRequestName() {
return requestName;
}
public void setRequestName(String requestName) {
this.requestName = requestName;
}
public String getWorkflowId() {
return workflowId;
}
public void setWorkflowId(String workflowId) {
this.workflowId = workflowId;
}
public String getWorkflowName() {
return workflowName;
}
public void setWorkflowName(String workflowName) {
this.workflowName = workflowName;
}
public String getWorkflowTypeId() {
return workflowTypeId;
}
public void setWorkflowTypeId(String workflowTypeId) {
this.workflowTypeId = workflowTypeId;
}
public String getWorkflowTypeName() {
return workflowTypeName;
}
public void setWorkflowTypeName(String workflowTypeName) {
this.workflowTypeName = workflowTypeName;
}
public String getPcurl() {
return pcurl;
}
public void setPcurl(String pcurl) {
this.pcurl = pcurl;
}
public String getMobileurl() {
return mobileurl;
}
public void setMobileurl(String mobileurl) {
this.mobileurl = mobileurl;
}
}

@ -0,0 +1,215 @@
package com.weaver.seconddev.njwebservice.entity;
public class UserWorkPlan {
String ID = "";
String Name = "";
String BeginDate = "";
String EndDate = "";
String BeginTime = "";
String EndTime = "";
String createrid = "";
String createrName = "";
String description = "";
String status = "";
int workPlanType = 0;
String urgentLevel = "";
String remindType = "";
String remindImmediately = "0";
String remindBeforeStart = "";
String remindBeforeEnd = "";
String remindDateBeforeStart = "";
String remindTimeBeforeStart = "";
String remindDateBeforeEnd = "";
String remindTimeBeforeEnd = "";
String resourceID = "";
String resourceNames = "";
String isMustEdit = "0";
public UserWorkPlan() {
}
public String getID() {
return this.ID;
}
public void setID(String var1) {
this.ID = var1;
}
public String getName() {
return this.Name;
}
public void setName(String var1) {
this.Name = var1;
}
public String getBeginDate() {
return this.BeginDate;
}
public void setBeginDate(String var1) {
this.BeginDate = var1;
}
public String getEndDate() {
return this.EndDate;
}
public void setEndDate(String var1) {
this.EndDate = var1;
}
public String getBeginTime() {
return this.BeginTime;
}
public void setBeginTime(String var1) {
this.BeginTime = var1;
}
public String getEndTime() {
return this.EndTime;
}
public void setEndTime(String var1) {
this.EndTime = var1;
}
public String getCreaterid() {
return this.createrid;
}
public void setCreaterid(String var1) {
this.createrid = var1;
}
public String getCreaterName() {
return this.createrName;
}
public void setCreaterName(String var1) {
this.createrName = var1;
}
public String getDescription() {
return this.description;
}
public void setDescription(String var1) {
this.description = var1;
}
public String getStatus() {
return this.status;
}
public void setStatus(String var1) {
this.status = var1;
}
public int getWorkPlanType() {
return this.workPlanType;
}
public void setWorkPlanType(int var1) {
this.workPlanType = var1;
}
public String getUrgentLevel() {
return this.urgentLevel;
}
public void setUrgentLevel(String var1) {
this.urgentLevel = var1;
}
public String getRemindType() {
return this.remindType;
}
public void setRemindType(String var1) {
this.remindType = var1;
}
public String getRemindImmediately() {
return this.remindImmediately;
}
public void setRemindImmediately(String var1) {
this.remindImmediately = var1;
}
public String getRemindBeforeStart() {
return this.remindBeforeStart;
}
public void setRemindBeforeStart(String var1) {
this.remindBeforeStart = var1;
}
public String getRemindBeforeEnd() {
return this.remindBeforeEnd;
}
public void setRemindBeforeEnd(String var1) {
this.remindBeforeEnd = var1;
}
public String getRemindDateBeforeStart() {
return this.remindDateBeforeStart;
}
public void setRemindDateBeforeStart(String var1) {
this.remindDateBeforeStart = var1;
}
public String getRemindTimeBeforeStart() {
return this.remindTimeBeforeStart;
}
public void setRemindTimeBeforeStart(String var1) {
this.remindTimeBeforeStart = var1;
}
public String getRemindDateBeforeEnd() {
return this.remindDateBeforeEnd;
}
public void setRemindDateBeforeEnd(String var1) {
this.remindDateBeforeEnd = var1;
}
public String getRemindTimeBeforeEnd() {
return this.remindTimeBeforeEnd;
}
public void setRemindTimeBeforeEnd(String var1) {
this.remindTimeBeforeEnd = var1;
}
public String getResourceID() {
return this.resourceID;
}
public void setResourceID(String var1) {
this.resourceID = var1;
}
public String getResourceNames() {
return this.resourceNames;
}
public void setResourceNames(String var1) {
this.resourceNames = var1;
}
public String getIsMustEdit() {
return this.isMustEdit;
}
public void setIsMustEdit(String var1) {
this.isMustEdit = var1;
}
}

@ -0,0 +1,29 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/6 6:08 PM
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class VendorPunishReq {
private String sendId;
private String itFid;
private String sysId;
private VendorPunishReqData datas;
}

@ -0,0 +1,32 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/20 16:46
* @Description: TODO
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class VendorPunishReqData {
/**流程ID**/
private String workflowId;
/**原请求号**/
private String requestId;
/**类型**/
private String type;
/**供应商是否同意**/
private String isAgree;
/**供应商厂商意见**/
private String supplierOpinion;
/**愿意承担金额**/
private int bearMoney;
}

@ -0,0 +1,30 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/20 16:54
* @Description: TODO
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class VendorPunishResponseInfo {
private String sendId;
/**接口编号**/
private String itfId;
/**系统编号**/
private String sysId;
private VendorPunishReturnData returnData;
}

@ -0,0 +1,29 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/20 16:55
* @Description: TODO
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class VendorPunishReturnData {
private String workflowId;
private String requestId;
/**接口处理状态**/
private String isTat;
/**处理消息 **/
private String message;
}

@ -0,0 +1,33 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/6 6:08 PM
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class WlpsSyResponse {
private String sendId;
private String itfId;
private String isTat;
private String message;
private String sysId;
private WlpsSyReturn[] wlpsSyReturn;
}

@ -0,0 +1,30 @@
package com.weaver.seconddev.njwebservice.entity;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author liang.cheng
* @Date 2025/1/6 6:08 PM
* @Description:
* @Version 1.0
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class WlpsSyReturn {
private String requestId;
private String isTat;
private String message;
private String workflowID;
}

@ -5,8 +5,8 @@ import cn.hutool.json.JSONUtil;
import com.weaver.datasource.utils.rest.CommonRestService;
import com.weaver.ebuilder.datasource.api.entity.ExecuteSqlEntity;
import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity;
import com.weaver.ebuilder.datasource.api.enums.SqlParamType;
import com.weaver.ebuilder.datasource.api.enums.SourceType;
import com.weaver.ebuilder.datasource.api.enums.SqlParamType;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;

@ -11,9 +11,11 @@ import com.weaver.seconddev.njwebservice.entity.DataOptions;
import com.weaver.seconddev.njwebservice.entity.FormDataDuty;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import com.weaver.verupgrade.hrm.resource.ResourceComInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.text.SimpleDateFormat;
import java.util.*;
/**
@ -26,8 +28,6 @@ public class SecondUtil {
private final static Logger log = LoggerFactory.getLogger(SecondUtil.class);
public static String getNacosContent(String dataId,String group,String key) {
String configSingle = "";
// 定义 Nacos 服务器地址和配置信息
@ -252,5 +252,195 @@ public class SecondUtil {
return formData;
}
/**
*
* @param workflowId
* @return
*/
public static String getTableName(String workflowId) {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
String tableName = "";
String sql = "select table_name from e10_core_business.dbo.form_table where \n" +
" form_id = (select relatekey from e10_core_business.dbo.wfp_relateform where workflowid = '"+workflowId+"')";
rs.executeSql(sql,poolname);
while (rs.next()){
tableName = Util.null2String(rs.getString("table_name"));
}
return tableName;
}
/**
* Id
* @param requestId
* @return
*/
public static String getWorkflowIdByReq(String requestId) {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
String workflowId = "";
String sql = "select workflowid from e10_core_business.dbo.wfc_form_data where requestid = '"+requestId+"'\n" +
" and delete_type = 0";
rs.executeSql(sql,poolname);
if (rs.next()){
workflowId = Util.null2String(rs.getString("workflowid"));
}
return workflowId;
}
public static String getMeetingInfo(String loginname,String password,String companyIds,String startdate,String enddate) {
net.sf.json.JSONObject object1 = new net.sf.json.JSONObject();
try {
//先判断是否有权限
//String pwd = Util.null2String(getPropValue("htwsaccount", loginname)).trim();
String pwd = getWorkflowConfig(loginname);
if(pwd == null || !pwd.equals(password)){
object1.put("status", "error");
object1.put("msg", "权限不足");
return object1.toString();
}
if(startdate==null||"".equals(startdate)||enddate==null||"".equals(enddate)){
object1.put("status", "error");
object1.put("msg", "时间不能为空");
return object1.toString();
}
//HttpServletRequest request = XFireServletController.getRequest();
//String ip = request.getRemoteAddr();//得到当前调用的主机IP
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String today = sdf.format(new Date());//当前时间
log.error("excute webservice MeetingServiceServiceImpl start...");
//writeLog("ip地址"+ip+" ,时间:" + today);
// RecordSet rs1 = new RecordSet();//把当前调用的主机IP和时间记录在数据库中
// rs1.execute("insert into uf_wslogs (host,datetime,type) values('"+ip+"','"+today+"','MeetingService')");
if(companyIds == null || "".equals(companyIds)){
object1.put("status", "error");
object1.put("msg", "公司ID不能为空");
return object1.toString();
}
//找出所有的会议室
Map<String , String> meetingMap = new HashMap<>();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
rs.executeSql("select id,name from mt_room where org_id in ("+companyIds+")",CONN_TYPE.meeting.getType());
while (rs.next()) {
String id = Util.null2String(rs.getString("id"));
String name = Util.null2String(rs.getString("name"));
meetingMap.put(id, name);
}
if(meetingMap == null || meetingMap.size() <= 0){
object1.put("status", "error");
object1.put("msg", "找不到该公司下的会议室");
return object1.toString();
}
log.error("找到会议室" + meetingMap.size() + "个");
net.sf.json.JSONArray array = new net.sf.json.JSONArray();
// String sql3 = "select t.id,t.name meetingname,t.address," +
// " t.begindate+' '+t.begintime as begindate," +
// " t.enddate+' '+t.endtime as enddate,t.caller,t.contacter,t.desc_n,t.hrmmembers,t.meetingstatus from Meeting t" +
// " where t.meetingstatus in (2,4) " +
// " and t.begindate+' '+begintime >= '"+startdate+"'" +
// " and t.enddate+' '+endtime <= '"+enddate+"'";
String sql3 = "select a.id,a.name as meetingname,a.address,a.begin_datetime,a.end_datetime,a.caller,a.contacter,b.member_id,\n" +
" a.mt_status from mt_detail a left join mt_receipt_member b on a.id = b.mt_id where a.begin_datetime >= '"+startdate+"' " +
" and a.end_datetime <= '"+enddate+"' and a.mt_status in (2,4)";
rs.execute(sql3,CONN_TYPE.meeting.getType());
log.error("找到会议" + rs.getCounts() + "个");
ResourceComInfo res = new ResourceComInfo();
while (rs.next()) {//寻找meeting表中address多个的
String address = Util.null2String(rs.getString("address"));
String meetingname = Util.null2String(rs.getString("meetingname"));
String begin = Util.null2String(rs.getString("begin_datetime"));
String end = Util.null2String(rs.getString("end_datetime"));
log.error("找到会议meetingname(" + meetingname + "),address(" + address + "),begin(" + begin + "),end(" + end + ")");
if(address != null && !"".equals(address)){//去需要查询的公司下面的会议室匹配
String[] addressArray = address.split(",");
for(int i=0;i<addressArray.length;i++){
String str = addressArray[i];
Object name = meetingMap.get(str);
if(name != null && !"".equals(name.toString())){
net.sf.json.JSONObject object = new net.sf.json.JSONObject();
object.put("roomname", name.toString());
object.put("meetingname", meetingname);
object.put("begindate", begin);
object.put("enddate", end);
object.put("meetingId",rs.getString("id"));
object.put("caller",res.getLastnames(rs.getString("caller")));
object.put("contacter",res.getLastnames(rs.getString("contacter")));
object.put("content","");
object.put("members",res.getLastnames(rs.getString("member_id")));
object.put("meetingstatus",rs.getInt("mt_status"));
array.add(object);
}
}
}
}
if(array != null && array.size() > 0){
object1.put("status", "success");
object1.put("msg", array.toString());
}else{
object1.put("status", "error");
object1.put("msg", "找不到该时间段内的会议");
}
} catch (Exception e) {
log.error("error" + e.getMessage() );
object1.put("status", "error");
object1.put("msg", e.getMessage());
return object1.toString();
}
return object1.toString();
}
public static String getUserId(int type,String value) {
String userId = "";
String columnName ="";
switch (type) {
case 2 :
columnName = "username";
break;
case 3 :
columnName = "USER_ID";
break;
case 4 :
columnName = "mobile";
break;
case 5 :
columnName = "email";
break;
default:
columnName = "job_num";
break;
}
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.hrm.getType();
String sql = "select ID from eteams.employee where delete_type = 0 and status = 'normal' and "+columnName+"= '"+value+"'";
rs.executeSql(sql,poolname);
if (rs.next()) {
userId = Util.null2String(rs.getString("ID"));
}
return userId;
}
}

Loading…
Cancel
Save