map2 = new HashMap<>();
+ map2.put("sql", "insert into "+CubeSaveInterccept.CompanyVersionMaintable+"_dt1(rq,bgxm,bgq,bgh,mainid)values(?,?,?,?,?) ");
+ map2.put("params", new Object[]{currentDate, labelname,oldprefieldvalue,fieldvalue,getBillid()});
+ sqlmaps.add(map2);
+
+
+ }
+ }
+ }
+
+ /**
+ * 获取区间版本
+ * @param current
+ * @param lastversion
+ * @param allversion
+ * @return
+ */
+ public static String getBetoowVersion(String current,String lastversion,String allversion){
+ current=Util.null2String(current);
+ lastversion=Util.null2String(lastversion);
+ if("".equals(lastversion)){//如果不存在中间版本直接 返回空数据
+ return "";
+ }
+ if("".equals(current)){//如果不存在中间版本直接 返回空数据
+ return "";
+ }
+ allversion=Util.null2String(allversion);
+ String betoowID="";
+ boolean isbegin=false;
+ String[] allversions=allversion.split(",");
+ for(String str:allversions){
+ str=Util.null2String(str).trim();
+ if("".equals(str)){
+ continue;
+ }
+ if(current.equals(str)){
+ isbegin=true;
+ continue;
+ }
+ if(lastversion.equals(str)){
+ break;
+ }
+ if(isbegin){
+ betoowID=betoowID+str+",";
+ }
+ }
+ if(betoowID.endsWith(",")){
+ betoowID=betoowID.substring(0,betoowID.length()-1);
+ }
+ return betoowID;
+ }
+ /**
+ * 获取版本ID
+ * @param type 0上一个版本 1 下一个版本
+ */
+ public String getAllVersion(String type){
+ JSONObject version=new JSONObject();
+ RecordSet re=new RecordSet();
+ String ids="";
+ String sql="select * from "+CubeSaveInterccept.CompanyVersionMaintable+" where qyid='"+this.qyid+"' and bbrq>'"+this.bbrq+"' order by bbrq asc";;
+// if("0".equals(type)){
+// sql=sql+" and bbrq<'"+this.bbrq+"' order by desc";
+// }
+// if("1".equals(type)){
+// sql=sql+" and bbrq>'"+this.bbrq+"' order by asc";
+// }else{
+// return version;
+// }
+ re.executeQuery(sql);
+ log.writeLog(sql);
+ while(re.next()){
+ String id=Util.null2String(re.getString("id")) ;
+ ids=ids+id+",";
+ }
+ if(ids.endsWith(",")){
+ ids=ids.substring(0,ids.length()-1);
+ }
+ return ids;
+ }
+ public String getOldAllVersion(){
+ JSONObject version=new JSONObject();
+ RecordSet re=new RecordSet();
+ String ids="";
+ String sql="select * from "+CubeSaveInterccept.CompanyVersionMaintable+" where qyid='"+this.qyid+"' and bbrq<'"+this.bbrq+"' order by bbrq desc";;
+// if("0".equals(type)){
+// sql=sql+" and bbrq<'"+this.bbrq+"' order by desc";
+// }
+// if("1".equals(type)){
+// sql=sql+" and bbrq>'"+this.bbrq+"' order by asc";
+// }else{
+// return version;
+// }
+ re.executeQuery(sql);
+ log.writeLog(sql);
+ while(re.next()){
+ String id=Util.null2String(re.getString("id")) ;
+ ids=ids+id+",";
+ }
+ if(ids.endsWith(",")){
+ ids=ids.substring(0,ids.length()-1);
+ }
+ return ids;
+ }
+ /**
+ * 返回 字段最新的 修改版本的ID
+ * @param ids 所有版本的 iD
+ * @param fieldname 字段名称
+ * @return
+ */
+ public String checkFieldCheck(String ids,String fieldname){
+ String id="";
+ RecordSet re=new RecordSet();
+ boolean flag=false;
+ String sql="select a.id from "+CubeSaveInterccept.CompanyVersionMaintable+" a, "+CubeSaveInterccept.CompanyVersionMaintable+"_dt1 b where a.id=b.mainid and a.qyid='"+this.qyid+"' and a.id in ("+ids+") and bgxm=? order by a.bbrq asc";
+ re.executeQuery(sql,fieldname);
+ log.writeLog(sql);
+ if(re.next()){
+ id=Util.null2String(re.getString("id")) ;
+ }
+ return id;
+ }
+
+ /**
+ * 明细表 返回 字段最新的 修改版本的ID
+ * @param ids 所有版本的 iD
+ * @param type 大于0 的版本 小于 0 之前的版本
+ * @return
+ */
+ public String checkDetailFieldCheck(String ids,String bgxm,int type){
+ String id="";
+ RecordSet re=new RecordSet();
+ boolean flag=false;
+ //String sql="select a.relatedid from ModeViewLog_84 a,ModeLogFieldDetail b where a.id=b.viewlogid and a.operateType=2 and (a.relatedid in ("+ids+") or a.relatedid="+billid+" ) and b.detailtable='"+tablename+"' ";
+ String sql="select a.id from "+CubeSaveInterccept.CompanyVersionMaintable+" a, "+CubeSaveInterccept.CompanyVersionMaintable+"_dt1 b where a.id=b.mainid and a.qyid='"+this.qyid+"' and a.id in ("+ids+") and bgxm=? ";
+ //改为按照版本日期 排序
+ if(type>0){
+ sql=sql+" order by a.bbrq asc";
+ }else{
+ sql=sql+" order by a.bbrq desc";
+ }
+// if(type>0){
+// sql=sql+" order by a.id asc";
+// }else{
+// sql=sql+" order by a.id desc";
+// }
+ re.executeQuery(sql,bgxm);
+ log.writeLog(sql);
+ if(re.next()){
+ id=Util.null2String(re.getString("id")) ;
+ }
+ return id;
+ }
+
+ public String getFieldNameByid(String fieldid){
+ RecordSet re=new RecordSet();
+ String fieldname="";
+ String sql="select fieldname from workflow_billfield where id="+fieldid;
+ re.execute(sql);
+ if(re.next()){
+ fieldname=Util.null2String(re.getString("fieldname")) ;
+ }
+ return fieldname;
+ }
+ //(fieldvalue, fieldhtmltype, fieldid, fielddbtype, viewtype, type)
+
+ public JSONObject getFieldIdByName(String fieldname,String detailtable){
+ RecordSet re=new RecordSet();
+ JSONObject json=new JSONObject();
+ String sql=" select c.id,fieldhtmltype, fielddbtype, viewtype, type from workflow_billfield c where c.billid="+formId+" and fieldname=? ";
+ if(formId<=0&&!"".equals(Util.null2String(detailtable).trim())){
+ sql=" select c.id,fieldhtmltype, fielddbtype, viewtype, type from workflow_billfield c where fieldname=? ";
+ }
+ if(!"".equals(Util.null2String(detailtable) )){
+ sql=sql+" and detailtable='"+detailtable+"'";
+ }
+ log.writeLog(sql);
+ re.executeQuery(sql,fieldname);
+ if(re.next()){
+ String id=Util.null2String(re.getString("id")) ;
+ String fieldhtmltype=Util.null2String(re.getString("fieldhtmltype")) ;
+ String fielddbtype=Util.null2String(re.getString("fielddbtype")) ;
+ String viewtype=Util.null2String(re.getString("viewtype")) ;
+ String type=Util.null2String(re.getString("type")) ;
+ json.put("fieldid",id);
+ json.put("fieldhtmltype",fieldhtmltype);
+ json.put("fielddbtype",fielddbtype);
+ json.put("viewtype",viewtype);
+ json.put("type",type);
+ }
+ return json;
+ }
+ public String getSingleFieldIdByName(String fieldname,String detailtable){
+ RecordSet re=new RecordSet();
+ JSONObject json=new JSONObject();
+ String sql=" select c.id,fieldhtmltype, fielddbtype, viewtype, type from workflow_billfield c where c.billid="+formId+" and fieldname=? ";
+ if(!"".equals(Util.null2String(detailtable) )){
+ sql=sql+" and detailtable='"+detailtable+"'";
+ }
+ String id="";
+ re.executeQuery(sql,fieldname);
+ if(re.next()){
+ id=Util.null2String(re.getString("id")) ;
+ }
+ return id;
+ }
+ /**
+ * 获取明细表的 所有值
+ * @param detailtable
+ * @param fields
+ * @return
+ */
+ public String getDetailAllValue(String detailtable,String fields,String billidval){
+ String result="";
+ detailtable=Util.null2String(detailtable).trim();
+ fields=Util.null2String(fields);
+ if("".equals(detailtable)||"".equals(fields)){
+ return "";
+ }
+ String[] fieldss=fields.split(",");
+ RecordSet re=new RecordSet();
+ String sql="select * from "+detailtable+" where mainid=";
+ if(!"".equals(billidval)){
+ sql=sql+""+billidval;
+ }
+ re.execute(sql);
+ while(re.next()){
+ String demostr="";
+ for(String str:fieldss){
+ str=Util.null2String(str).trim();
+ if(str.equals("")){
+ continue;
+ }
+ String fieldvalue=Util.null2String(re.getString(str)) ;
+ String newfieldvalue="";
+ try {
+ newfieldvalue=BaseUtil.Html2Text(transFieldValue(fieldvalue, getFieldIdByName(str,detailtable))) ;
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ demostr=demostr+newfieldvalue+"/";
+ }
+ if(demostr.endsWith("/")){
+ demostr=demostr.substring(0,demostr.length()-1);
+ }
+ result=result+demostr+"、\n";
+ }
+// if(result.endsWith("|")){
+// result=result.substring(0,result.length()-1);
+// }
+ return result;
+ }
+ //更新历史 版本的 新增的明细表对用的 企业信息明细ID
+ public void updateallmodflyuuid(){
+ RecordSet recordSet=new RecordSet();
+ String[] allmodflyuuids=Util.null2String(this.allmodflyuuid).trim().split(",");
+ for(String str:allmodflyuuids){
+ str=Util.null2String(str).trim();
+ if("".equals(str)||str.indexOf(",")<1){
+ continue;
+ }
+ String tableindex=str.substring(0,str.indexOf(","));
+ log.writeLog(str+"update "+CubeSaveInterccept.CompanyVersionMaintable+"_"+tableindex+" set mainbillid=(select id from "+CubeSaveInterccept.CompanyMaintable+"_"+tableindex+" where modflyuuid=?) where modflyuuid=?");
+ recordSet.executeUpdate("update "+CubeSaveInterccept.CompanyVersionMaintable+"_"+tableindex+" set mainbillid=(select id from "+CubeSaveInterccept.CompanyMaintable+"_"+tableindex+" where modflyuuid=?) where modflyuuid=?",str);
+ }
+ }
+
+ public String getFeildnameByNames(String names,int formid){
+ String resultnames="";
+ String result="";
+ names=Util.null2String(names).trim();
+ if("djgd,cgbl,cgfs,gfzl".equals(names)){
+ return "登记股东/持股比例/持股份数/股份种类";
+ }
+ String namesValue=","+names+",";
+ String[] namess=names.split(",");
+ for(String str:namess){
+ str=Util.null2String(str).trim();
+ if("".equals(str)){
+ continue;
+ }
+ result=result+"'"+str+"',";
+ }
+ if(result.endsWith(",")){
+ result=result.substring(0,result.length()-1);
+ }
+ if(!"".equals(result)){
+ RecordSet re=new RecordSet();
+ log.writeLog("select fieldname,fieldlabel from workflow_billfield where billid="+formid+" and fieldname in ("+result+")");
+ re.execute("select fieldname,fieldlabel from workflow_billfield where billid="+formid+" and fieldname in ("+result+")");
+
+ while(re.next()){
+ String fieldnameStr=Util.null2String(re.getString("fieldname"));
+ String fieldname=SystemEnv.getHtmlLabelName(re.getInt("fieldlabel"), 7);//Util.null2String(re.getString("fieldname")) .trim();
+ if("".equals(fieldname)){
+ continue;
+ }
+ namesValue=namesValue.replaceAll(","+fieldnameStr+",",","+fieldname+",");
+ resultnames=resultnames+fieldname+"/";
+ }
+ if(namesValue.endsWith(",")){
+ namesValue=namesValue.substring(0,namesValue.length()-1);
+ }
+ if(namesValue.startsWith(",")){
+ namesValue=namesValue.substring(1);
+ }
+ namesValue=namesValue.replaceAll(",","/");
+ if(resultnames.endsWith("/")){
+ resultnames=resultnames.substring(0,resultnames.length()-1);
+ }
+ }
+ return namesValue;
+ }
+
+ /**
+ *
+ * @param names
+ * @param tablename
+ * @param type 0主表 1明细表
+ * @return
+ */
+ public String getFeildnameByNames(String names,String tablename,int type){
+ String resultnames="";
+ String result="";
+ names=Util.null2String(names).trim();
+ String[] namess=names.split(",");
+ for(String str:namess){
+ str=Util.null2String(str).trim();
+ if("".equals(str)){
+ continue;
+ }
+ result=result+"'"+str+"',";
+ }
+ if(result.endsWith(",")){
+ result=result.substring(0,result.length()-1);
+ }
+ log.writeLog(result+" "+tablename+" "+type);
+ if(!"".equals(result)){
+ RecordSet re=new RecordSet();
+ //log.writeLog("select fieldname,fieldlabel from workflow_billfield where billid="+formid+" and fieldname in ("+result+")");
+ if(type==0){
+ re.executeQuery("select a.fieldname,a.fieldlabel from workflow_billfield a,workflow_bill b where a.billid=b.id and a.fieldname in ("+result+") and b.tablename=?",tablename);
+ }else{
+ log.writeLog("select a.fieldname,a.fieldlabel from workflow_billfield a,workflow_bill b where a.billid=b.id and a.fieldname in ("+result+") and a.detailtable=?"+tablename);
+ re.executeQuery("select a.fieldname,a.fieldlabel from workflow_billfield a,workflow_bill b where a.billid=b.id and a.fieldname in ("+result+") and a.detailtable=?",tablename);
+ }
+
+
+ while(re.next()){
+ String fieldname=SystemEnv.getHtmlLabelName(re.getInt("fieldlabel"), 7);//Util.null2String(re.getString("fieldname")) .trim();
+ if("".equals(fieldname)){
+ continue;
+ }
+ resultnames=resultnames+fieldname+"/";
+ }
+ if(resultnames.endsWith("/")){
+ resultnames=resultnames.substring(0,resultnames.length()-1);
+ }
+ }
+ return resultnames;
+ }
+
+ public static void main(String[] arg){
+ System.out.println(getBetoowVersion("3","21","1,2,3,21,4,5"));
+ }
+}
diff --git a/src/main/youhong_ai_jitu_src/com/jet/action/ApplyForFee.java b/src/main/youhong_ai_jitu_src/com/jet/action/ApplyForFee.java
new file mode 100644
index 0000000..60ec5d4
--- /dev/null
+++ b/src/main/youhong_ai_jitu_src/com/jet/action/ApplyForFee.java
@@ -0,0 +1,56 @@
+package com.jet.action;
+
+import weaver.soa.workflow.request.RequestInfo;
+import weaver.workflow.action.BaseAction;
+import weaver.conn.RecordSet;
+import weaver.general.Util;
+
+import com.working.util.LogTool;
+import com.working.util.WorkflowUtil;
+
+/**
+ * 02-费用报销申请-J&T中国
+ * @author lwt
+ *
+ */
+public class ApplyForFee extends BaseAction{
+
+ LogTool log = new LogTool("/log/feeChina/",false);
+
+ @Override
+ public String execute(RequestInfo requestInfo) {
+ // TODO Auto-generated method stub
+ String requestid = requestInfo.getRequestid();
+ RecordSet rs = new RecordSet();
+ RecordSet rs1 = new RecordSet();
+ String mainTable = WorkflowUtil.getMainTable(requestid);
+ String detail8Table = mainTable + "_dt8";
+ int mainId = requestInfo.getRequestManager().getBillid();//主表数据id
+ rs.execute("select * from " + detail8Table + " where mainid = '" + mainId + "' order by id desc");
+ String bxlx = "";//报销类型
+ String tdhdVal = "0";//团队活动费
+ String clVal = "0";//差旅费
+ while (rs.next()) {
+ bxlx = Util.null2String(rs.getString("BXLX"));
+ if (bxlx!=null) {
+ if (bxlx.equals("27")) {//团队活动费
+ tdhdVal = "1";
+ } else if (bxlx.equals("3")) {//差旅费
+ clVal = "1";
+ }
+ }
+ }
+ if (tdhdVal.equals("0")&&clVal.equals("0")) {//既没有团队活动费也没有差旅费,设置主表的报销类型为其他
+ rs1.execute("update " + mainTable + " set bxlxzb = '2' where requestid = '" + requestid +"'");
+ } else if (tdhdVal.equals("1")&&clVal.equals("0")) {//只有团队活动费,设置主表的报销类型为团队活动费
+ rs1.execute("update " + mainTable + " set bxlxzb = '0' where requestid = '" + requestid +"'");
+ } else if (tdhdVal.equals("0")&&clVal.equals("1")) {//只有差旅费,设置主表的报销类型为差旅费
+ rs1.execute("update " + mainTable + " set bxlxzb = '1' where requestid = '" + requestid +"'");
+ } else if (tdhdVal.equals("1")&&clVal.equals("1")) {//既有团队活动费也有差旅费,设置主表的报销类型为团队活动费&差旅费
+ rs1.execute("update " + mainTable + " set bxlxzb = '3' where requestid = '" + requestid +"'");
+ }
+
+ return SUCCESS;
+ }
+
+}
diff --git a/src/main/youhong_ai_jitu_src/com/jet/action/BusinessTripIntoHRAction.java b/src/main/youhong_ai_jitu_src/com/jet/action/BusinessTripIntoHRAction.java
new file mode 100644
index 0000000..efee31f
--- /dev/null
+++ b/src/main/youhong_ai_jitu_src/com/jet/action/BusinessTripIntoHRAction.java
@@ -0,0 +1,202 @@
+package com.jet.action;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.working.third.JwtUtil;
+import com.working.util.HttpManager;
+import com.working.util.WorkflowUtil;
+import selfdev.util.log.LogTool;
+import weaver.conn.RecordSet;
+import weaver.file.Prop;
+import weaver.general.Util;
+import weaver.soa.workflow.request.RequestInfo;
+import weaver.workflow.action.BaseAction;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Author Administrator
+ * @Description OA出差申请数据写入东宝HR系统
+ * @Date 2020/10/20 16:26
+ *
+ * 这两个值后需要写在配置文件中
+ * 正式环境
+ * https://hr.jtexpress.com.cn
+ * clientId：TPFKAGB3QGPM2LBD
+ * 测试环境
+ * http://121.36.223.187:9011
+ * clientId: P3F28BIFKGFL0ANX
+ */
+public class BusinessTripIntoHRAction extends BaseAction {
+
+ @Override
+ public String execute(RequestInfo requestInfo) {
+ LogTool log = new LogTool("/log/selfdev/action", false);
+ log.writeLog("-----------------------开始OA出差申请数据写入东宝HR系统-----------------------");
+ String requestId = requestInfo.getRequestid(); //获取requestid
+ log.writeLog("------------requestId值为：" + requestId);
+
+ String mainTable = WorkflowUtil.getMainTable(requestId);
+
+// String clientId = Prop.getPropValue("db_work", "clientId");
+ String clientId = "P3F28BIFKGFL0ANX";
+ String secret = Prop.getPropValue("db_work", "secret");
+ int second = Integer.parseInt(Prop.getPropValue("db_work", "second"));
+
+// String batchCardDataUrl = Prop.getPropValue("db_work", "batchCardDataUrl");
+ String batchCardDataUrl = "http://121.36.223.187:9011/third/api";
+
+ String code = "saveBusinessTripOrderToThirdNew";
+ String moduleCode = "attBusinessTripOrderService";
+ String token = JwtUtil.createThirdToken(clientId, secret, second).getToken();
+
+ HashMap headMap = new HashMap(); // 存放head的值
+ headMap.put("code", code);
+ headMap.put("moduleCode", moduleCode);
+ headMap.put("token", token);
+ headMap.put("clientId", clientId);
+
+ HashMap bodyMap = new HashMap(); // 存放body的值
+
+ String userId = ""; // 申请人id
+ String workCode = ""; //人员编号
+
+ String trip_category = "2"; // 出差类型(1-外出，2-出差)
+ String trip_area = ""; // 出差区域(1-市内，2-省内，3-国内，4-海外) 暂时只分3和4
+ String trip_way = "4"; // 出差方式(1-整天，2-上半天，3-下半天，4-连续时间段，5-每天固定时间)
+
+ String begin_date = ""; // 开始日期
+ String end_date = ""; // 结束日期
+ String begin_time = ""; // 开始时间
+ String end_time = ""; // 结束时间
+ String reason = ""; // 出差事由
+ String origin = ""; // 出发地
+ String destination = ""; // 目的地
+
+ String is_overtime = "1"; // 是否出差计加班（默认传入1）
+ String audit_status = "1"; // 提交状态 0-保存 1-提交
+
+ RecordSet rs = new RecordSet();
+ String sql = " select * from " + mainTable + " where requestid='" + requestId + "'";
+ rs.execute(sql);
+ while (rs.next()) {
+ HashMap empOrderMap = new HashMap(); // 存放empOrder的值
+ HashMap businessTripOrderMap = new HashMap(); // 存放businessTripOrder的值
+
+ userId = Util.null2String(rs.getString("sqr"));// 人员转换唯一标识
+ workCode = Util.null2String(WorkflowUtil.getUserInfo(userId).get("workcode"));
+ log.writeLog("------------人员转换唯一标识值为：" + workCode);
+
+ String trip_area1 = Util.null2String(rs.getString("cclb")); // 出差类别
+ if ("0".equals(trip_area1)) {
+ trip_area = "3"; // 国内
+ }
+ if ("1".equals(trip_area1)) {
+ trip_area = "4"; // 国外
+ }
+
+ begin_date = Util.null2String(rs.getString("fsrq")); // 开始日期
+ end_date = Util.null2String(rs.getString("jsrq")); // 结束日期
+ reason = Util.null2String(rs.getString("ccsy")); // 出差事由
+ origin = Util.null2String(rs.getString("cfd")); // 出发地
+ destination = Util.null2String(rs.getString("mdd")); // 目的地
+
+ String[] s = begin_date.split(" ");
+ begin_time = s[1];
+ String[] s1 = end_date.split(" ");
+ end_time = s1[1];
+
+ List> scheduleList = new ArrayList>(); // 出差行程记录
+ Map scheduleMap1 = new HashMap();
+ scheduleMap1.put("name", "出发地");
+ scheduleMap1.put("place", origin);
+ scheduleMap1.put("longitude", "");
+ scheduleMap1.put("latitude", "");
+ scheduleMap1.put("id", "");
+
+ Map scheduleMap2 = new HashMap();
+ scheduleMap2.put("name", "目的地");
+ scheduleMap2.put("place", destination);
+ scheduleMap2.put("longitude", "");
+ scheduleMap2.put("latitude", "");
+ scheduleMap2.put("id", "");
+ scheduleList.add(scheduleMap1);
+ scheduleList.add(scheduleMap2);
+
+ log.writeLog("------------出差类型值为：" + trip_category);
+ log.writeLog("------------出差区域值为：" + trip_area);
+ log.writeLog("------------出差方式值为：" + trip_way);
+ log.writeLog("------------开始日期值为：" + begin_date);
+ log.writeLog("------------结束日期值为：" + end_date);
+ log.writeLog("------------开始时间值为：" + begin_time);
+ log.writeLog("------------结束时间值为：" + end_time);
+ log.writeLog("------------出差事由值为：" + reason);
+ log.writeLog("------------出发地值为：" + origin);
+ log.writeLog("------------目的地值为：" + destination);
+
+ empOrderMap.put("empKey", workCode);
+ empOrderMap.put("empRule", "1"); // 人员转换规则(0-无，1-工号，2-身份证，3邮箱，4-手机号码)
+
+ businessTripOrderMap.put("trip_category", trip_category);
+ businessTripOrderMap.put("trip_area", trip_area);
+ businessTripOrderMap.put("trip_way", trip_way);
+ businessTripOrderMap.put("begin_date", begin_date);
+ businessTripOrderMap.put("end_date", end_date);
+ businessTripOrderMap.put("begin_time", begin_time);
+ businessTripOrderMap.put("end_time", end_time);
+ businessTripOrderMap.put("reason", reason);
+
+ businessTripOrderMap.put("is_overtime", is_overtime);
+ businessTripOrderMap.put("audit_status", audit_status);
+ businessTripOrderMap.put("isChangeTripOrder", false); // 是否变更出差单（默认传入false）
+
+ businessTripOrderMap.put("scheduleList", scheduleList);
+
+ empOrderMap.put("businessTripOrder", businessTripOrderMap);
+ bodyMap.put("empOrder", empOrderMap);
+ }
+
+ HashMap paramMap = new HashMap();
+ paramMap.put("header", headMap);
+ paramMap.put("body", bodyMap);
+
+ try {
+ String param = JSON.toJSONString(paramMap, SerializerFeature.DisableCircularReferenceDetect);
+ log.writeLog("---------------paramMap的值为：" + param);
+ String result = HttpManager.postMap(batchCardDataUrl, headMap, param);
+ log.writeLog("-----------发送请求返回的结果值为：" + result);
+
+ JSONObject jsonObject = JSONObject.parseObject(result);
+ String returnCode = Util.null2String(jsonObject.get("code"));
+ String data = Util.null2String(jsonObject.get("data"));
+ String message = Util.null2String(jsonObject.get("message"));
+ String id = Util.null2String(jsonObject.get("id"));
+
+ log.writeLog("--------发送请求返回的code值为：" + returnCode);
+ log.writeLog("--------发送请求返回的数据值为：" + data);
+ log.writeLog("--------发送请求返回的信息为：" + message);
+ log.writeLog("--------发送请求返回的id值为：" + id);
+
+ if (!"".equals(result) && result != null) {
+ if ("200".equals(returnCode)) {
+ return SUCCESS;
+ } else {
+ requestInfo.getRequestManager().setMessagecontent("写入HR系统失败，失败信息为：" + message);
+ return "0";
+ }
+ } else {
+ requestInfo.getRequestManager().setMessagecontent("写入HR系统失败，发送请求返回的结果值为" + result);
+ return "0";
+ }
+
+ } catch (IOException ioException) {
+ requestInfo.getRequestManager().setMessagecontent("发生异常了，写入HR系统失败");
+ return "0";
+ }
+ }
+}
diff --git a/src/main/youhong_ai_jitu_src/com/jet/action/CheckPayAction.java b/src/main/youhong_ai_jitu_src/com/jet/action/CheckPayAction.java
new file mode 100644
index 0000000..7ddef7a
--- /dev/null
+++ b/src/main/youhong_ai_jitu_src/com/jet/action/CheckPayAction.java
@@ -0,0 +1,124 @@
+package com.jet.action;
+
+import weaver.conn.RecordSet;
+import weaver.general.BaseBean;
+import weaver.general.Util;
+import weaver.interfaces.workflow.action.Action;
+import weaver.soa.workflow.request.RequestInfo;
+import selfdev.util.base.BaseUtil;
+import selfdev.util.log.LogTool;
+
+/**
+ * 付款申请流程申请节点提交时的校验判断
+ * 1、判断支付明细中的本次付款金额是否超出未付款金额
+ * 2、判断一个付款流程不能同时选择两行以上相同的批次
+ * @author KangMD
+ * 2019-11-04
+ */
+public class CheckPayAction extends BaseBean implements Action {
+
+ public String execute(RequestInfo ri) {
+ LogTool log=new LogTool("/log/selfdev/action", false);
+ //获取requestid
+ String requestid=ri.getRequestid();
+ String workflowid=ri.getWorkflowid();
+ //获取用户语言
+ int language=ri.getRequestManager().getUser().getLanguage();
+ log.writeLog("language---------->"+language);
+ String workflowname=BaseUtil.getBaseInfoByParm("workflowname", "workflow_base", "id", workflowid, "");
+ log.writeLog("---------------"+workflowname+"开始-------------requestId:" + requestid);
+ try {
+ RecordSet rs=new RecordSet();
+ String mainid="";//主键ID
+ String htxx="";//建模合同ID
+ //获取表名
+ String tablename=BaseUtil.getBaseInfoByParm("tablename", "workflow_bill", "1", "1", " and id in (select formid from workflow_base where id="+workflowid+")");;
+ String sql="select * from "+tablename+" where requestid="+requestid;
+ rs.execute(sql);
+ while(rs.next()){
+ mainid=Util.null2String(rs.getString("id"));
+ htxx=Util.null2String(rs.getString("htxx"));
+ }
+ String sfcc="0";//流程是否可通过 0表示可通过 1表示不可通过
+ String msg="";//提示信息
+ //查询1个流程中是否填写了2行相同付款批次
+ sql="select a.pc_num,b.* from (select fkpc,count(*) as pc_num from "+tablename+"_dt5 where mainid= "+mainid+" GROUP BY fkpc having count(*)>1) a left join V_uf_httz_dt1 b on a.fkpc=b.id";
+ log.writeLog("查询付款明细中不能有重复批次的SQL---------->"+sql);
+ rs.execute(sql);
+ while(rs.next()){
+ sfcc="1";//重复
+ if(language==0||language==7){//简体
+ msg+="明细中批次为【"+Util.null2String(rs.getString("fkpc"))+"】的付款重复选择了;
";//超出提示信息
+ }else if(language==8){//英语
+ msg+="明细中批次为【"+Util.null2String(rs.getString("fkpc"))+"】的付款重复选择了;
";//超出提示信息
+ }else if(language==9){//繁体
+ msg+="明细中批次为【"+Util.null2String(rs.getString("fkpc"))+"】的付款重复选择了;
";//超出提示信息
+ }else if(language==22){//印尼语
+ msg+="明细中批次为【"+Util.null2String(rs.getString("fkpc"))+"】的付款重复选择了;
";//超出提示信息
+ }
+ }
+ if("0".equals(sfcc)){
+ //当前明细汇总本次支付金额与批次未付金额对比，若超出未付金额，则不可提交
+ sql="select a.*,b.bcfkje from V_uf_httz_dt1 a,(select fkpc as fkpcid,sum(TO_NUMBER(replace(bcfkje,',',''))) as bcfkje from "+tablename+"_dt5 where mainid="+mainid+" GROUP BY fkpc ) b where a.id=b.fkpcid and a.wfkje"+sql);
+ rs.execute(sql);
+ while(rs.next()){
+ sfcc="1";//超出了
+ if(language==0||language==7){//简体
+ msg+="批次【"+Util.null2String(rs.getString("fkpc"))+"】未付金额【"+Util.null2String(rs.getString("wfkje"))+"】元，本次申请支付金额【"+Util.null2String(rs.getString("bcfkje"))+"】元已超出未付金额;
";//超出提示信息
+ }else if(language==8){//英语
+ msg+="批次【"+Util.null2String(rs.getString("fkpc"))+"】未付金额【"+Util.null2String(rs.getString("wfkje"))+"】元，本次申请支付金额【"+Util.null2String(rs.getString("bcfkje"))+"】元已超出未付金额;
";//超出提示信息
+ }else if(language==9){//繁体
+ msg+="批次【"+Util.null2String(rs.getString("fkpc"))+"】未付金额【"+Util.null2String(rs.getString("wfkje"))+"】元，本次申请支付金额【"+Util.null2String(rs.getString("bcfkje"))+"】元已超出未付金额;
";//超出提示信息
+ }else if(language==22){//印尼语
+ msg+="批次【"+Util.null2String(rs.getString("fkpc"))+"】未付金额【"+Util.null2String(rs.getString("wfkje"))+"】元，本次申请支付金额【"+Util.null2String(rs.getString("bcfkje"))+"】元已超出未付金额;
";//超出提示信息
+ }
+ }
+ }
+ if("0".equals(sfcc)){
+ //当前明细汇总本次支付金额+在途流程金额与批次未付金额对比，若超出未付金额，则不可提交
+ sql="select a.*,b.bcfkje,nvl(c.bcfkje_zt,0) as bcfkje_zt from V_uf_httz_dt1 a " +
+ "left join (select fkpc as fkpcid,sum(TO_NUMBER(replace(bcfkje,',',''))) as bcfkje from "+tablename+"_dt5 where mainid="+mainid+" GROUP BY fkpc ) b on a.id=b.fkpcid " +
+ "left join (select a.fkpc as fkpcid,sum(TO_NUMBER(replace(a.bcfkje,',',''))) as bcfkje_zt from "+tablename+"_dt5 a，"+tablename+" b,workflow_requestbase c where a.mainid=b.id and b.requestid=c.requestid and c.currentnodetype not in(0,3) and b.htxx='"+htxx+"' GROUP BY a.fkpc ) c on a.id=c.fkpcid " +
+ "where a.wfkje"+sql);
+ rs.execute(sql);
+ while(rs.next()){
+ sfcc="1";//超出了
+ if(language==0||language==7){//简体
+ msg+="批次【"+Util.null2String(rs.getString("fkpc"))+"】未付金额【"+Util.null2String(rs.getString("wfkje"))+"】元，已提交OA流程在途审批中【"+Util.null2String(rs.getString("bcfkje_zt"))+"】元，本次申请支付金额【"+Util.null2String(rs.getString("bcfkje"))+"】元已超出未付金额;
";//超出提示信息
+ }else if(language==8){//英语
+ msg+="批次【"+Util.null2String(rs.getString("fkpc"))+"】未付金额【"+Util.null2String(rs.getString("wfkje"))+"】元，已提交OA流程在途审批中【"+Util.null2String(rs.getString("bcfkje_zt"))+"】元，本次申请支付金额【"+Util.null2String(rs.getString("bcfkje"))+"】元已超出未付金额;
";//超出提示信息
+ }else if(language==9){//繁体
+ msg+="批次【"+Util.null2String(rs.getString("fkpc"))+"】未付金额【"+Util.null2String(rs.getString("wfkje"))+"】元，已提交OA流程在途审批中【"+Util.null2String(rs.getString("bcfkje_zt"))+"】元，本次申请支付金额【"+Util.null2String(rs.getString("bcfkje"))+"】元已超出未付金额;
";//超出提示信息
+ }else if(language==22){//印尼语
+ msg+="批次【"+Util.null2String(rs.getString("fkpc"))+"】未付金额【"+Util.null2String(rs.getString("wfkje"))+"】元，已提交OA流程在途审批中【"+Util.null2String(rs.getString("bcfkje_zt"))+"】元，本次申请支付金额【"+Util.null2String(rs.getString("bcfkje"))+"】元已超出未付金额;
";//超出提示信息
+ }
+ }
+ }
+ //超出未支付金额，则进行提醒，并阻止流程提交
+ if("1".equals(sfcc)){
+ ri.getRequestManager().setMessage("111100");
+ ri.getRequestManager().setMessagecontent(msg);
+ return "0";
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ String error_msg="付款流程提交失败，错误信息为：------>"+e.toString();
+ if(language==0||language==7){//简体
+
+ }else if(language==8){//英语
+ error_msg="付款流程提交失败，错误信息为：------>"+e.toString();
+ }else if(language==9){//繁体
+ error_msg="付款流程提交失败，错误信息为：------>"+e.toString();
+ }else if(language==22){//印尼语
+ error_msg="付款流程提交失败，错误信息为：------>"+e.toString();
+ }
+ log.writeLog(error_msg);
+ ri.getRequestManager().setMessage("111100");
+ ri.getRequestManager().setMessagecontent(error_msg);
+ return "0";
+ }
+ return SUCCESS;
+ }
+}
diff --git a/src/main/youhong_ai_jitu_src/com/jet/action/CheckReimbursementAction.java b/src/main/youhong_ai_jitu_src/com/jet/action/CheckReimbursementAction.java
new file mode 100644
index 0000000..d2ea039
--- /dev/null
+++ b/src/main/youhong_ai_jitu_src/com/jet/action/CheckReimbursementAction.java
@@ -0,0 +1,122 @@
+package com.jet.action;
+
+import weaver.conn.RecordSet;
+import weaver.general.BaseBean;
+import weaver.general.Util;
+import weaver.interfaces.workflow.action.Action;
+import weaver.soa.workflow.request.RequestInfo;
+import selfdev.util.base.BaseUtil;
+import selfdev.util.log.LogTool;
+
+/**
+ * 费用报销流程申请节点提交时的校验判断
+ * 1、报销明细若存在团队招待费，则明细dt2中的合计金额需与报销明细中的团队招待费金额相等
+ * 2、报销明细若存在客户招待费，则明细dt3中的合计金额需与报销明细中的客户招待费金额相等
+ * @author KangMD
+ * 2019-11-07
+ */
+public class CheckReimbursementAction extends BaseBean implements Action {
+
+ public String execute(RequestInfo ri) {
+ LogTool log=new LogTool("/log/selfdev/action", false);
+ //获取requestid
+ String requestid=ri.getRequestid();
+ String workflowid=ri.getWorkflowid();
+ //获取用户语言
+ int language=ri.getRequestManager().getUser().getLanguage();
+ log.writeLog("language---------->"+language);
+ String workflowname=BaseUtil.getBaseInfoByParm("workflowname", "workflow_base", "id", workflowid, "");
+ log.writeLog("---------------"+workflowname+"开始-------------requestId:" + requestid);
+ try {
+ RecordSet rs=new RecordSet();
+ String mainid="";//主键ID
+ //获取表名
+ String tablename=BaseUtil.getBaseInfoByParm("tablename", "workflow_bill", "1", "1", " and id in (select formid from workflow_base where id="+workflowid+")");;
+ String sql="select * from "+tablename+" where requestid="+requestid;
+ rs.execute(sql);
+ while(rs.next()){
+ mainid=Util.null2String(rs.getString("id"));
+ }
+ double tdzdf=0;//团队招待费（报销明细）
+ double khzdf=0;//客户招待费（报销明细）
+ double tdzdf_dt2=0;//团队招待费（团队招待费明细）
+ double khzdf_dt3=0;//客户招待费（客户招待费明细）
+ //查询报销明细中是否存在团队招待费和客户招待费的类型
+ sql="select bxlx1,sum(TO_NUMBER(replace(je,',',''))) as je from "+tablename+"_dt8 where mainid="+mainid+" and bxlx1 in ('3-05.02','3-05.03') group by bxlx1 ";
+ rs.execute(sql);
+ while(rs.next()){
+ if("3-05.02".equals(rs.getString("bxlx1"))){
+ khzdf=rs.getDouble("je");//客户招待费
+ }else if("3-05.03".equals(rs.getString("bxlx1"))){
+ tdzdf=rs.getDouble("je");//团队招待费
+ }
+ }
+ //查询团队招待费明细中金额合计
+ sql="select nvl(sum(TO_NUMBER(replace(je,',',''))),0) as je from "+tablename+"_dt2 where mainid="+mainid;
+ rs.execute(sql);
+ while(rs.next()){
+ tdzdf_dt2=rs.getDouble("je");
+ }
+ //查询客户招待费明细中金额合计
+ sql="select nvl(sum(TO_NUMBER(replace(je,',',''))),0) as je from "+tablename+"_dt3 where mainid="+mainid;
+ rs.execute(sql);
+ while(rs.next()){
+ khzdf_dt3=rs.getDouble("je");
+ }
+
+ String sftg="0";//流程是否可通过 0表示可通过 1表示不可通过
+ String msg="";//提示信息
+
+ //团队招待费校验
+ if(tdzdf!=tdzdf_dt2){
+ sftg="1";//
+ if(language==0||language==7){//简体
+ msg+="报销明细中报销类型为【团队招待费】金额需与团队招待费明细中的金额合计相等;
";//提示信息
+ }else if(language==8){//英语
+ msg+="报销明细中报销类型为【团队招待费】金额需与团队招待费明细中的金额合计相等;
";//提示信息
+ }else if(language==9){//繁体
+ msg+="报销明细中报销类型为【团队招待费】金额需与团队招待费明细中的金额合计相等;
";//提示信息
+ }else if(language==22){//印尼语
+ msg+="报销明细中报销类型为【团队招待费】金额需与团队招待费明细中的金额合计相等;
";//提示信息
+ }
+ }
+ //客户招待费校验
+ if(khzdf!=khzdf_dt3){
+ sftg="1";//
+ if(language==0||language==7){//简体
+ msg+="报销明细中报销类型为【客户招待费】金额需与客户招待费明细中的金额合计相等;
";//提示信息
+ }else if(language==8){//英语
+ msg+="报销明细中报销类型为【客户招待费】金额需与客户招待费明细中的金额合计相等;
";//提示信息
+ }else if(language==9){//繁体
+ msg+="报销明细中报销类型为【客户招待费】金额需与客户招待费明细中的金额合计相等;
";//提示信息
+ }else if(language==22){//印尼语
+ msg+="报销明细中报销类型为【客户招待费】金额需与客户招待费明细中的金额合计相等;
";//提示信息
+ }
+ }
+
+ //不通过则进行提醒，并阻止流程提交
+ if("1".equals(sftg)){
+ ri.getRequestManager().setMessage("111100");
+ ri.getRequestManager().setMessagecontent(msg);
+ return "0";
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ String error_msg="报销流程提交失败，错误信息为：------>"+e.toString();
+ if(language==0||language==7){//简体
+
+ }else if(language==8){//英语
+ error_msg="报销流程提交失败，错误信息为：------>"+e.toString();
+ }else if(language==9){//繁体
+ error_msg="报销流程提交失败，错误信息为：------>"+e.toString();
+ }else if(language==22){//印尼语
+ error_msg="报销流程提交失败，错误信息为：------>"+e.toString();
+ }
+ log.writeLog(error_msg);
+ ri.getRequestManager().setMessage("111100");
+ ri.getRequestManager().setMessagecontent(error_msg);
+ return "0";
+ }
+ return SUCCESS;
+ }
+}
diff --git a/src/main/youhong_ai_jitu_src/com/jet/action/CreateBxAP.java b/src/main/youhong_ai_jitu_src/com/jet/action/CreateBxAP.java
new file mode 100644
index 0000000..95916bf
--- /dev/null
+++ b/src/main/youhong_ai_jitu_src/com/jet/action/CreateBxAP.java
@@ -0,0 +1,296 @@
+package com.jet.action;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import org.apache.log4j.Logger;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.jet.util.InvokeHelper;
+
+import weaver.conn.RecordSet;
+import weaver.general.BaseBean;
+import weaver.general.Util;
+import weaver.interfaces.workflow.action.Action;
+import weaver.soa.workflow.request.Cell;
+import weaver.soa.workflow.request.DetailTable;
+import weaver.soa.workflow.request.DetailTableInfo;
+import weaver.soa.workflow.request.MainTableInfo;
+import weaver.soa.workflow.request.Property;
+import weaver.soa.workflow.request.RequestInfo;
+import weaver.soa.workflow.request.Row;
+
+public class CreateBxAP extends BaseBean implements Action{
+ public String execute(RequestInfo request) {
+ Logger log = Logger.getLogger(JSONObject.class);
+ RecordSet urlre=new RecordSet();
+ String urlsql="select * from uf_urlinfo where ms='model'";
+
+ urlre.execute(urlsql);
+ String url="";
+ String username="";
+ String password1="";
+ String dbid1="";
+ String uuid1="";
+ String password2="";
+ while(urlre.next()){
+ url=Util.null2String(urlre.getString("url"));
+ username=Util.null2String(urlre.getString("username"));
+ password1=Util.null2String(urlre.getString("password"));
+ dbid1=Util.null2String(urlre.getString("dbid"));
+ uuid1=Util.null2String(urlre.getString("uuid"));
+ password2=Util.null2String(urlre.getString("password1"));
+ }
+ String baseis=username+":"+password1;
+
+ // TODO Auto-generated method stub
+ SimpleDateFormat sim=new SimpleDateFormat("yyyy-MM-dd");
+ String CurretDate=sim.format(new Date());
+ String requestid=request.getRequestid();
+ String sfxr="";//是否写入标识
+ writeLog("CreateBxAP---->"+requestid);
+ MainTableInfo MainTableInfo=request.getMainTableInfo();
+ Property[] props=MainTableInfo.getProperty();
+ String zt="";//账套
+ String zz="";//组织
+ String K3depCode="";//K3部门编号
+ JSONObject MainJson=new JSONObject();
+ JSONObject FBillTypeID=new JSONObject();
+ FBillTypeID.put("FNumber", "YFD01_SYS");
+ MainJson.put("FBillTypeID", FBillTypeID);//默认应付单
+ MainJson.put("FDATE", CurretDate);//单据日期
+ MainJson.put("FENDDATE_H", CurretDate);//到期日
+ MainJson.put("FBUSINESSTYPE", "CG");
+ MainJson.put("FMatchMethodID", "0");//核销方式
+ MainJson.put("F_RTA_InvoiceNo", CurretDate+requestid+"66");//发票
+ MainJson.put("F_RTA_BusinessType", "");
+ //相关资料 json
+ JSONObject FSUPPLIERID=new JSONObject();//供应商
+ JSONObject FCURRENCYID=new JSONObject();//币别
+ JSONObject FCURRENCYID2=new JSONObject();//币别2
+ JSONObject FSETTLEORGID=new JSONObject();//结算组织
+ JSONObject FTaxType =new JSONObject();//税务分类
+ FTaxType.put("FNumber", "PKP");
+ JSONObject FPAYORGID=new JSONObject();//付款组织
+ MainJson.put("FSUPPLIERID", FSUPPLIERID);
+ MainJson.put("FCURRENCYID", FCURRENCYID);
+ MainJson.put("FSETTLEORGID", FSETTLEORGID);
+ MainJson.put("FTaxType", FTaxType);
+ MainJson.put("FPAYORGID", FPAYORGID);
+ //初始化其他供应商信息
+ JSONArray FsubHeadSuppilers=new JSONArray();
+ JSONObject FsubHeadSuppiler=new JSONObject();
+ MainJson.put("FsubHeadSuppiler", FsubHeadSuppiler);
+ for(Property prop:props){
+ String name=prop.getName();
+ String value=prop.getValue();
+ if("bxzje".equals(name)){//FALLAMOUNTFOR：合计金额
+ MainJson.put("FALLAMOUNTFOR", value);//默认应付单
+ writeLog("bxzje---->"+value);
+ }
+ if("gys".equals(name)){//FSUPPLIERID：供应商
+ FSUPPLIERID.put("FNumber", value);
+ JSONObject FORDERID=new JSONObject();
+ FORDERID.put("FNumber", value);
+ JSONObject FTRANSFERID=new JSONObject();
+ FTRANSFERID.put("FNumber", value);
+ JSONObject FChargeId=new JSONObject();
+ FChargeId.put("FNumber", value);
+ FsubHeadSuppiler.put("FEntryId", 0);
+ FsubHeadSuppiler.put("FORDERID", FORDERID);
+ FsubHeadSuppiler.put("FTRANSFERID", FTRANSFERID);
+ FsubHeadSuppiler.put("FChargeId", FChargeId);
+ //FsubHeadSuppilers.add(FsubHeadSuppiler);
+ writeLog("gys---->"+value);
+ }
+ if("k3bmbh".equals(name)){//FPURCHASEDEPTID：采购组织
+ //MainJson.put("FPURCHASEDEPTID", value);
+ K3depCode=value;
+ writeLog("k3bmbh---->"+value);
+ }
+ if("bz".equals(name)){//FCURRENCYID：币种
+ FCURRENCYID.put("FNumber", value);//默认应付单
+ FCURRENCYID2.put("FNumber", value);//默认应付单
+ writeLog("bz---->"+value);
+ }
+ if("zz".equals(name)){//FSETTLEORGID：结算组织 FPAYORGID：付款组织
+ FSETTLEORGID.put("FNumber", value);
+ FPAYORGID.put("FNumber", value);
+ zz=value;
+ writeLog("zz---->"+value);
+ }
+ if("bxms".equals(name)){//FAP_Remark：备注
+ MainJson.put("FAP_Remark", value);
+ writeLog("bxms---->"+value);
+ }
+ if("sfxr".equals(name)){
+ sfxr=value;
+ writeLog("sfxr---->"+value);
+ }
+ if("zt".equals(name)){
+ zt=value;
+ }
+
+ }
+ String K3bmID=getK3Departmet(K3depCode,zt,zz);//获取K3部门ID
+ if("".equals(K3depCode)){
+ request.getRequestManager().setMessageid("失败");
+ request.getRequestManager().setMessage("失败");//提醒信息id
+ request.getRequestManager().setMessagecontent("写入K3系统不成功:为获取采购组织");//提醒信息内容
+ return FAILURE_AND_CONTINUE;
+ }
+ JSONObject FPURCHASEDEPTID=new JSONObject();
+ FPURCHASEDEPTID.put("FNumber", K3depCode);
+ MainJson.put("FPURCHASEDEPTID", FPURCHASEDEPTID);
+ //初始化其他财务信息 FsubHeadFinc
+
+ JSONObject FsubHeadFinc=new JSONObject();
+ //JSONObject FMAINBOOKSTDCURRID=new JSONObject();
+ JSONObject FEXCHANGETYPE=new JSONObject();
+ FEXCHANGETYPE.put("FNumber", "HLTX01_SYS");
+ FsubHeadFinc.put("FEntryId", 0);
+ FsubHeadFinc.put("FACCNTTIMEJUDGETIME", CurretDate);
+ FsubHeadFinc.put("FMAINBOOKSTDCURRID", FCURRENCYID2);
+ FsubHeadFinc.put("FExchangeRate", 1);
+ FsubHeadFinc.put("FTaxAmountFor", MainJson.get("FALLAMOUNTFOR"));
+ FsubHeadFinc.put("FNoTaxAmountFor", MainJson.get("FALLAMOUNTFOR"));
+ MainJson.put("FsubHeadFinc", FsubHeadFinc);
+ //拼接明细表数据
+ JSONArray FEntityDetails=new JSONArray();
+ JSONArray FEntityPlans=new JSONArray();
+ MainJson.put("FEntityDetail", FEntityDetails) ;
+ MainJson.put("FEntityPlan", FEntityPlans) ;
+ JSONObject FEntityDetail=null;//new JSONObject();
+ JSONObject FEntityPlan=null;
+ FEntityPlan=new JSONObject();
+ DetailTableInfo DetailTableInfo=request.getDetailTableInfo();
+ DetailTable DetailTable=DetailTableInfo.getDetailTable(7);
+ Row[] Rows=DetailTable.getRow();
+ for(Row r:Rows){
+ FEntityDetail=new JSONObject();
+
+ JSONObject FMATERIALID=new JSONObject();//物料
+ JSONObject FPRICEUNITID=new JSONObject();//单位
+ JSONObject FMATERIALID1=new JSONObject();//物料
+ JSONObject FPRICEUNITID1=new JSONObject();//单位
+// FEntityPlan.put("FPRICEUNITID", FPRICEUNITID1);
+// FEntityPlan.put("FMATERIALID", FMATERIALID1);
+ //FEntityPlan.put("FEntityPlan", CurretDate);
+ FEntityDetail.put("FPriceQty","1");
+ FEntityDetail.put("FBASICUNITQTY","1");
+
+ FPRICEUNITID.put("FNumber", "Pcs");
+ FPRICEUNITID1.put("FNumber", "Pcs");
+
+ FEntityDetail.put("FPRICEUNITID", FPRICEUNITID);
+ FEntityDetail.put("FMATERIALID", FMATERIALID);
+ FEntityDetail.put("F_RTA_FakturPajakNo_d", "-");
+ FEntityDetail.put("F_RTA_AccumulatedAmount", 0);
+ Cell[] Cells=r.getCell();
+ for(Cell Cell:Cells){
+ String name=Cell.getName();
+ String value=Cell.getValue();
+ if("bxlx1".equals(name)){//物料编号
+ FMATERIALID.put("FNumber", value);
+ FMATERIALID1.put("FNumber", value);
+ writeLog("bxlx1---->"+value);
+ }
+ if("je".equals(name)){//金额
+ FEntityDetail.put("FPrice", value);
+ FEntityDetail.put("FTaxPrice", value);
+ FEntityDetail.put("FNoTaxAmountFor_D", value);
+ FEntityDetail.put("FALLAMOUNTFOR_D", value);
+
+ writeLog("je---->"+value);
+ }
+ if("bz".equals(name)){//备注
+ FEntityDetail.put("F_RTA_EntryRemarks", value);
+ writeLog("bz---->"+value);
+ }
+ }
+ FEntityDetails.add(FEntityDetail);
+
+ }
+ FEntityPlan.put("FPAYRATE",100);
+ FEntityPlan.put("FENDDATE", CurretDate);
+ FEntityPlan.put("FPAYAMOUNTFOR", MainJson.get("FALLAMOUNTFOR"));
+ FEntityPlan.put("FPAYAMOUNT", MainJson.get("FALLAMOUNTFOR"));
+ FEntityPlan.put("FPRICE_P", MainJson.get("FALLAMOUNTFOR"));
+ FEntityPlan.put("FQTY_P", 1);
+ FEntityPlans.add(FEntityPlan);
+ //数据提交
+ writeLog("FEntityDetails---->"+FEntityDetails.toJSONString());
+ writeLog("MainJson---->"+MainJson.toJSONString());
+ JSONObject Model=new JSONObject();
+ Model.put("NeedReturnFields", new String[]{"BillNo"});
+ Model.put("IsAutoSubmitAndAudit", true);
+ Model.put("Model", MainJson);
+
+ //数据写入
+ writeLog("Model--->"+Model.toJSONString());
+ if(Model!=null&&Model.size()>0&&("".equals(sfxr)||"1".equals(sfxr))){
+ RecordSet updRec=new RecordSet();
+ com.jet.util.InvokeHelper.POST_K3CloudURL="http://k3.jet.co.id:8880/k3cloud/";
+ String dbid="5d48f604c8361e";//dbid1;//"5d48f604c8361e";//"5a964ecc967246";
+ String uuid=uuid1;
+ String password=password2;
+ org.json.JSONObject resultjson=null;
+ int lang=2052;
+ try {
+ boolean flag=InvokeHelper.Login(dbid, uuid, password, lang);
+ //out.print(flag);
+ if(flag){//登陆成功
+ resultjson=com.jet.util.InvokeHelper.Save("AP_Payable",Model.toJSONString());
+ boolean flag1=resultjson.getBoolean("flag");
+ String resultstr=resultjson.getString("sResult");
+ log.error("resultstr"+resultstr);
+ if(flag1){
+ JSONObject HAHA=JSONObject.parseObject(resultstr);
+ JSONObject Result=HAHA.getJSONObject("Result");
+ JSONObject ResponseStatus=Result.getJSONObject("ResponseStatus");
+ boolean IsSuccess=ResponseStatus.getBoolean("IsSuccess");
+ if(IsSuccess){
+ JSONArray SuccessEntitys=ResponseStatus.getJSONArray("SuccessEntitys");
+ String Number=SuccessEntitys.getJSONObject(0).getString("Number");
+ updRec.execute("update formtable_main_22 set sfxr='0',yfdbh='"+Number+"' where requestid='"+requestid+"' ");
+
+ }else{
+ //out.print("失败");
+ request.getRequestManager().setMessageid("失败");
+ request.getRequestManager().setMessage("失败");//提醒信息id
+ request.getRequestManager().setMessagecontent("写入K3系统不成功，系统反馈信息如下："+HAHA.toString());//提醒信息内容
+
+ return Action.FAILURE_AND_CONTINUE;
+ }
+ }else{
+ //out.print("失败"+resultstr);
+ request.getRequestManager().setMessageid("失败");
+ request.getRequestManager().setMessage("失败");//提醒信息id
+ request.getRequestManager().setMessagecontent("写入K3系统不成功，系统反馈信息如下："+resultstr.toString());//提醒信息内容
+
+ return Action.FAILURE_AND_CONTINUE;
+ }
+
+ }
+ } catch (Exception e) {
+ //TODO Auto-generated catch block
+ log.error("AP_Payable--Exception"+e.getMessage());
+ e.printStackTrace();
+ }
+ }
+ return SUCCESS;
+ }
+ //获取K3 部门ID
+ public String getK3Departmet(String k3bm,String zt,String zz){
+ String bmID="";
+ RecordSet re=new RecordSet();
+ String sql="select b.ENTRYID from uf_K3baseinfo a,uf_K3baseinfo_dt1 b where a.id=b.mainid and a.zt='"+zt+"' and a.lx='FFLEX5' and b.FORGNAME='"+zz+"' and bh='"+k3bm+"' ";
+ writeLog("getK3Departmet--->"+sql);
+ re.execute(sql);
+ while(re.next()){
+ bmID=re.getString("ENTRYID");
+ }
+ return bmID;
+ }
+}
diff --git a/src/main/youhong_ai_jitu_src/com/jet/action/CreateJD.java b/src/main/youhong_ai_jitu_src/com/jet/action/CreateJD.java
new file mode 100644
index 0000000..01c3de0
--- /dev/null
+++ b/src/main/youhong_ai_jitu_src/com/jet/action/CreateJD.java
@@ -0,0 +1,266 @@
+package com.jet.action;
+
+import java.util.*;
+import weaver.soa.workflow.request.RequestInfo;
+import weaver.workflow.action.BaseAction;
+import weaver.conn.RecordSet;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import weaver.hrm.HrmUserVarify;
+import weaver.hrm.User;
+import weaver.general.BaseBean;
+import weaver.general.Util;
+import org.apache.log4j.Logger;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import java.text.SimpleDateFormat;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.Statement;
+import weaver.general.StaticObj;
+import weaver.interfaces.datasource.DataSource;
+import weaver.formmode.setup.ModeRightInfo;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import weaver.general.StaticObj;
+import weaver.interfaces.datasource.DataSource;
+import weaver.interfaces.workflow.action.Action;
+
+import java.math.BigDecimal;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.net.URL;
+import java.net.URLConnection;
+import org.apache.http.Header;
+import org.apache.http.HttpResponse;
+import org.apache.http.HttpStatus;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.*;
+import org.apache.http.*;
+import org.apache.http.util.*;
+import org.apache.http.impl.client.DefaultHttpClient;
+import org.apache.http.params.CoreConnectionPNames;
+import java.util.UUID;
+import java.nio.charset.Charset;
+import java.io.BufferedReader;
+import java.io.ByteArrayOutputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import weaver.conn.RecordSetTrans;
+import java.io.PrintWriter;
+
+public class CreateJD extends BaseAction{
+ @Override
+ public String execute(RequestInfo requestInfo) {
+ // TODO Auto-generated method stub
+ Logger log = Logger.getLogger(JSONObject.class);
+ Map Hswd=new HashMap();//核算维度对照表
+ Hswd.put("FFLEX4","gys");//供应商
+ Hswd.put("FFLEX6","kh");//客户
+ Hswd.put("FFLEX7","yg");//员工
+ Hswd.put("FFLEX5","bm");//部门
+ Hswd.put("FFLEX9","fyxm");//费用项目
+ Hswd.put("FFLEX8","wl");//物料
+ Hswd.put("FFLEX10","zc");//资产
+ Hswd.put("FFLEX12","wlz");//物料组
+ Hswd.put("FFLEX13","khz");//客户组
+
+ List jlist=new ArrayList();//借方
+ List dlist=new ArrayList();//贷方
+ String requestid=requestInfo.getRequestid();//
+ String mainid="";//
+ String zt="";//账套
+ String zz="";//组织
+ String zb="";//账薄
+ String zzjdhl="";//做账节点汇率
+ String bz="";//币种
+ RecordSet re=new RecordSet();
+ String jsql="";
+ String dsql="";
+ float zje=0.0f;
+ String sql="select a.zzjdhl,a.bz,a.id,a.zt,a.zz,a.zb,sum(je) je,b.bxr,b.bxlx from formtable_main_22 a,formtable_main_22_dt8 b where a.id=b.mainid and a.requestid='"+requestid+"' group by a.zzjdhl,a.bz,a.id,a.zt,a.zz,a.zb,b.bxr,b.bxlx";
+ log.error(requestid+"CreateJD"+sql);
+ re.execute(sql);
+ while(re.next()){
+ mainid=Util.null2String(re.getString("id")).trim();
+ zzjdhl=Util.null2String(re.getString("zzjdhl")).trim();
+ if("".equals(zzjdhl.trim())){
+ zzjdhl="1";
+ }
+ bz=Util.null2String(re.getString("bz")).trim();
+ int xsw=getXsw(bz);
+ zt=Util.null2String(re.getString("zt")).trim();
+ zz=Util.null2String(re.getString("zz")).trim();
+ zb=Util.null2String(re.getString("zb")).trim();
+ String bxlx= re.getString("bxlx");//报销科目
+ String je= Util.null2String(re.getString("je")).trim();//报销金额
+ //je=getfloats(je,zzjdhl,xsw)+"";
+ zje=getfloats1(je,zje+"",2);
+ String FDIMENSION=getFzhx(bxlx,zt,zz,zb,Hswd);
+ String accountname=getKmname(bxlx,zt,zz,zb);
+
+ jsql="insert into formtable_main_22_dt4(mainid,jfkmbm,jfkmmc,hswd,yje,zy)values("+mainid+",'"+bxlx+"','"+accountname+"','"+FDIMENSION+"',"+je+",'')";
+ jlist.add(jsql);
+ }
+ if(jlist.size()>0){
+ //插入贷方
+ jlist.add("insert into formtable_main_22_dt5(mainid,dfkmbm,dfkmmc,hswd,yje,zy)values("+mainid+",'2000.01','AccountPayableIDR','',"+zje+",'')");
+ }
+ if(jlist.size()>0){
+ log.error(jlist.toString());
+ boolean flag=SynInsert1(jlist);
+ if(!flag){
+ requestInfo.getRequestManager().setMessageid("创建借贷失败");
+ requestInfo.getRequestManager().setMessage("创建借贷失败");//提醒信息id
+ requestInfo.getRequestManager().setMessagecontent("创建借贷失败");//提醒信息内容
+
+ return Action.FAILURE_AND_CONTINUE;
+ }
+ }
+ return SUCCESS;
+ }
+ //获取赋值核算类型
+ public String getFzhx(String km,String zt,String zz,String zb,Map Hswd){
+ String FDIMENSION="";//核算维度
+ RecordSet re=new RecordSet();
+ String sql="select b.FDIMENSION from uf_accountinfo a,uf_accountinfo_dt1 b where a.id=b.mainid and a.zt='"+zt+"' and b.FNUMBER='"+km+"' and b.forgnumber='"+zz+"' and FAcctBookNumber='"+zb+"' ";
+ //out.print(sql);
+ re.execute(sql);
+ while(re.next()){
+ String str=Util.null2String(re.getString("FDIMENSION")).trim() ;
+ String[] FDIMENSIONs=str.split(",");
+ for(String demo:FDIMENSIONs){
+ if(demo!=null&&!"".equals(demo)){
+ FDIMENSION=FDIMENSION+Hswd.get(FDIMENSION)+",";
+ }
+ }
+ }
+ return FDIMENSION;
+ }
+ //insert 事务
+ public boolean SynInsert1(List array){
+ if(array==null||array.size()<=0){
+ return false;
+ }
+ Logger log = Logger.getLogger(DataSource.class);
+ RecordSetTrans RecordSetTrans=new RecordSetTrans();
+ RecordSetTrans.setAutoCommit(false);
+ boolean flag=true;
+
+ try{
+ RecordSetTrans.setAutoCommit(false);
+ // stmt = conn.createStatement();
+ for(String str:array){
+ //int index =RecordSetTrans.executeUpdate(str);
+ flag=RecordSetTrans.executeSql(str);
+ log.error("SynInsert--"+str);
+ if(!flag){
+ //flag=false;
+ break;
+ }
+ }
+ if(!flag){//事务回滚
+ RecordSetTrans.rollback();
+ }else{
+ RecordSetTrans.commit();
+ }
+ }catch(Exception e){
+ log.error("SynInsert--Exception "+e.getMessage());
+ flag=false;
+ }
+
+ return flag;
+ }
+ //获取科目名称
+ public String getKmname(String km,String zt,String zz,String zb){
+ String FNAME="";//核算维度
+ RecordSet re=new RecordSet();
+ String sql="select b.FNAME from uf_accountinfo a,uf_accountinfo_dt1 b where a.id=b.mainid and a.zt='"+zt+"' and b.FNUMBER='"+km+"' and b.forgnumber='"+zz+"' and FAcctBookNumber='"+zb+"' ";
+ re.execute(sql);
+ while(re.next()){
+ FNAME=Util.null2String(re.getString("FNAME"));
+ }
+ return FNAME;
+ }
+ //获取币种的小数位
+ public int getXsw(String bz){
+ int xsw=0;
+ RecordSet re=new RecordSet();
+ String sql="select * from uf_k3bz where bh='"+bz+"'";
+ re.execute(sql);
+ while(re.next()){
+ xsw=Integer.parseInt(Util.null2o(re.getString("xsw"))) ;
+ }
+ return xsw;
+ }
+
+ //浮点型转换
+ public static float getfloats(String demo,String demo1,int len){
+ Logger log = Logger.getLogger(BigDecimal.class);
+ if(len==0){
+ len=0;
+ }
+ String str=Util.null2String(demo);
+ String str1=Util.null2String(demo1);
+ if("".equals(str)||"".equals(str.trim())||"null".equalsIgnoreCase(str.trim())){
+ return 0;
+ }
+ if("".equals(str1)||"".equals(str.trim())||"null".equalsIgnoreCase(str1.trim())){
+ str1="1";
+ }
+ float fl=0.0f;
+ //String str=Util.null2String(demo);
+ try{
+ if(str.trim().length()>0){
+ BigDecimal b1 = new BigDecimal(str.trim());
+ BigDecimal b2 = new BigDecimal(str1.trim());
+ BigDecimal b3=b1.multiply(b2);
+ //System.out.println(b1.setScale(2,BigDecimal.ROUND_HALF_UP));
+ fl=b3.setScale(len,BigDecimal.ROUND_HALF_UP).floatValue();
+ }
+ log.error("getfloats"+fl);
+ }catch(Exception e){
+ log.error(demo+"getfloats异常"+e.getMessage());
+ }
+ return fl;
+ }
+
+
+ //浮点型转换
+ public static float getfloats1(String demo,String demo1,int len){
+ Logger log = Logger.getLogger(BigDecimal.class);
+ if(len==0){
+ len=0;
+ }
+ String str=Util.null2String(demo);
+ String str1=Util.null2String(demo1);
+ if("".equals(str)||"".equals(str.trim())||"null".equalsIgnoreCase(str.trim())){
+ str="0";
+ }
+ if("".equals(str1)||"".equals(str.trim())||"null".equalsIgnoreCase(str1.trim())){
+ str1="0";
+ }
+ float fl=0.0f;
+ //String str=Util.null2String(demo);
+ try{
+ if(str.trim().length()>0){
+ BigDecimal b1 = new BigDecimal(str.trim());
+ BigDecimal b2 = new BigDecimal(str1.trim());
+ BigDecimal b3=b1.add(b2);
+ //System.out.println(b1.setScale(2,BigDecimal.ROUND_HALF_UP));
+ fl=b3.setScale(len,BigDecimal.ROUND_HALF_UP).floatValue();
+ }
+ log.error("getfloats"+fl);
+ }catch(Exception e){
+ log.error(demo+"getfloats异常"+e.getMessage());
+ }
+ return fl;
+ }
+}
diff --git a/src/main/youhong_ai_jitu_src/com/jet/action/CreateJkJD.java b/src/main/youhong_ai_jitu_src/com/jet/action/CreateJkJD.java
new file mode 100644
index 0000000..bda34f1
--- /dev/null
+++ b/src/main/youhong_ai_jitu_src/com/jet/action/CreateJkJD.java
@@ -0,0 +1,398 @@
+package com.jet.action;
+
+import java.util.*;
+import weaver.soa.workflow.request.RequestInfo;
+import weaver.workflow.action.BaseAction;
+import weaver.conn.RecordSet;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import weaver.general.Util;
+import org.apache.log4j.Logger;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import java.text.SimpleDateFormat;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.Statement;
+import weaver.general.StaticObj;
+import weaver.interfaces.datasource.DataSource;
+import weaver.formmode.setup.ModeRightInfo;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import weaver.general.StaticObj;
+import weaver.interfaces.datasource.DataSource;
+import weaver.interfaces.workflow.action.Action;
+
+import java.math.BigDecimal;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.net.URL;
+import java.net.URLConnection;
+import org.apache.http.Header;
+import org.apache.http.HttpResponse;
+import org.apache.http.HttpStatus;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.*;
+import org.apache.http.*;
+import org.apache.http.util.*;
+import org.apache.http.impl.client.DefaultHttpClient;
+import org.apache.http.params.CoreConnectionPNames;
+import java.util.UUID;
+import java.nio.charset.Charset;
+import java.io.BufferedReader;
+import java.io.ByteArrayOutputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import weaver.conn.RecordSetTrans;
+import java.io.PrintWriter;
+
+public class CreateJkJD extends BaseAction{
+ @Override
+ public String execute(RequestInfo requestInfo) {
+ // TODO Auto-generated method stub
+ //创建借款的借贷方
+ //0:贷方现金
+ //1:借方还款(职员)
+ //2:借方借款(职员)
+ Logger log = Logger.getLogger(JSONObject.class);
+ Map Hswd=new HashMap();//核算维度对照表
+ Hswd.put("FFLEX4","gys");//供应商
+ Hswd.put("FFLEX6","kh");//客户
+ Hswd.put("FFLEX7","yg");//员工
+ Hswd.put("FFLEX5","bm");//部门
+ Hswd.put("FFLEX9","fyxm");//费用项目
+ Hswd.put("FFLEX8","wl");//物料
+ Hswd.put("FFLEX10","zc");//资产
+ Hswd.put("FFLEX12","wlz");//物料组
+ Hswd.put("FFLEX13","khz");//客户组
+ RecordSet urlre=new RecordSet();
+ String urlsql="select * from uf_urlinfo ";
+
+ String url="";
+ String username="";
+ String password="";
+ urlre.execute(urlsql);
+ while(urlre.next()){
+ url=Util.null2String(urlre.getString("url"));
+ username=Util.null2String(urlre.getString("username"));
+ password=Util.null2String(urlre.getString("password"));
+ }
+ List jlist=new ArrayList();//借方
+ List dlist=new ArrayList();//贷方
+ String requestid=requestInfo.getRequestid();//
+ String mainid="";//
+ String zt="";//账套
+ String zz="";//组织
+ String zb="";//账薄
+ String zzjdhl="";//做账节点汇率
+ String bz="";//币种
+ String fkyh="";//付款银行
+ String je="";//借款金额
+ String jklx="";//借款类型
+ String dls="";//代理商
+ String emp="";//代理商
+ RecordSet re=new RecordSet();
+ String jsql="";
+ String dsql="";
+ String sql="select * from formtable_main_24 where requestid='"+requestid+"'";
+ log.error(requestid+"CreateJkJD"+sql);
+ re.execute(sql);
+ while(re.next()){
+ emp=Util.null2String(re.getString("emp")).trim();
+ mainid=Util.null2String(re.getString("id")).trim();
+ zz=Util.null2String(re.getString("zz")).trim();//组织
+ zt=Util.null2String(re.getString("zt")).trim();//账套
+ zb=Util.null2String(re.getString("zb")).trim();//账薄
+
+ fkyh=Util.null2String(re.getString("fkyxzh")).trim();//付款银行
+ je=Util.null2String(re.getString("jkje")).trim();//金额
+ jklx=Util.null2String(re.getString("jklx")).trim();//借款类型
+ dls=Util.null2String(re.getString("dls")).trim();//代理商
+ }
+ //判定借方科目
+ String jfkm="";//借方科目
+ String jfkmDesc="";//借方科目
+ String dfkm="";//贷方科目
+ String dfkmDesc="";//贷方科目
+ if("0".equals(jklx)){//个人
+ jfkm=SpelKm(zt,zz,zb,"2");
+ if("".equals(fkyh)){//现金
+ dfkm=SpelKm(zt,zz,zb,"0");
+ }else{//转账
+ dfkm=fkyh;
+ }
+ }else{//代理商
+ if("".equals(fkyh)){//现金
+ dfkm=SpelKm(zt,zz,zb,"0");
+ }else{//转账
+ dfkm=fkyh;
+ }
+ //通过接口 获取贷方科目
+ if(!"".equals(dls)){
+ String result=sendGet(url+"CusGlbalance/"+dls,"",username+":"+password);
+ //out.print(result);
+ Map map=getJSONToMap(result);
+ jfkm=Util.null2String(map.get("FAcctNumber"));
+ }
+ }
+ if(!"".equals(jfkm)){
+ jfkmDesc=getKmname(jfkm,zt,zz,zb);
+ }
+ if(!"".equals(dfkm)){
+ dfkmDesc=getKmname(dfkm,zt,zz,zb);
+ }
+ if("0".equals(jklx)){
+ dls="";
+ }
+ jlist.add("insert into formtable_main_24_dt1(mainid,jfkmbm,jfkmmc,jfje,kh,yg)values('"+mainid+"','"+jfkm+"','"+jfkmDesc+"','"+je+"','"+dls+"','"+emp+"')");
+ jlist.add("insert into formtable_main_24_dt2(mainid,dfkmbm,dfkmmc,dfje)values('"+mainid+"','"+dfkm+"','"+dfkmDesc+"','"+je+"')");
+ if(jlist.size()>0){
+ log.error(jlist.toString());
+ boolean flag=SynInsert1(jlist);
+ if(!flag){
+ requestInfo.getRequestManager().setMessageid("创建借贷失败");
+ requestInfo.getRequestManager().setMessage("创建借贷失败");//提醒信息id
+ requestInfo.getRequestManager().setMessagecontent("创建借贷失败");//提醒信息内容
+
+ return Action.FAILURE_AND_CONTINUE;
+ }
+ }
+ return super.execute(requestInfo);
+ }
+ //将JSON 解析成 Map
+ public Map getJSONToMap(String str){
+ Map map=new HashMap();
+ try{
+ JSONArray jsons=JSONObject.parseArray(str);
+ if(jsons!=null&&jsons.size()>0){
+ JSONObject json=(JSONObject)jsons.get(0);
+ Set set=json.keySet();
+ for(String demo:set){
+ map.put(demo,Util.null2String(json.getString(demo)));
+ }
+ }
+ }catch(Exception e){
+
+ }
+ return map;
+ }
+ //取特殊科目编号
+ public String SpelKm(String zt,String zz,String zb,String lx){
+ Logger log = Logger.getLogger(BigDecimal.class);
+ RecordSet re=new RecordSet();
+ String km="";//科目
+ re.execute("select * from uf_k3tskm a,uf_k3tskm_dt1 b where a.id=b.mainid and zt='"+zt+"' and zz='"+zz+"' and zb='"+zb+"' and lx='"+lx+"'");
+ while(re.next()){
+ km=re.getString("km");
+ }
+ return km;
+ }
+ //获取赋值核算类型
+ public String getFzhx(String km,String zt,String zz,String zb,Map Hswd){
+ String FDIMENSION="";//核算维度
+ RecordSet re=new RecordSet();
+ String sql="select b.FDIMENSION from uf_accountinfo a,uf_accountinfo_dt1 b where a.id=b.mainid and a.zt='"+zt+"' and b.FNUMBER='"+km+"' and b.forgnumber='"+zz+"' and FAcctBookNumber='"+zb+"' ";
+ //out.print(sql);
+ re.execute(sql);
+ while(re.next()){
+ String str=Util.null2String(re.getString("FDIMENSION")).trim() ;
+ String[] FDIMENSIONs=str.split(",");
+ for(String demo:FDIMENSIONs){
+ if(demo!=null&&!"".equals(demo)){
+ FDIMENSION=FDIMENSION+Hswd.get(FDIMENSION)+",";
+ }
+ }
+ }
+ return FDIMENSION;
+ }
+ //insert 事务
+ public boolean SynInsert1(List array){
+ if(array==null||array.size()<=0){
+ return false;
+ }
+ Logger log = Logger.getLogger(DataSource.class);
+ RecordSetTrans RecordSetTrans=new RecordSetTrans();
+ RecordSetTrans.setAutoCommit(false);
+ boolean flag=true;
+
+ try{
+ RecordSetTrans.setAutoCommit(false);
+ // stmt = conn.createStatement();
+ for(String str:array){
+ //int index =RecordSetTrans.executeUpdate(str);
+ flag=RecordSetTrans.executeSql(str);
+ log.error("SynInsert--"+str);
+ if(!flag){
+ //flag=false;
+ break;
+ }
+ }
+ if(!flag){//事务回滚
+ RecordSetTrans.rollback();
+ }else{
+ RecordSetTrans.commit();
+ }
+ }catch(Exception e){
+ log.error("SynInsert--Exception "+e.getMessage());
+ flag=false;
+ }
+
+ return flag;
+ }
+ //获取科目名称
+ public String getKmname(String km,String zt,String zz,String zb){
+ String FNAME="";//核算维度
+ RecordSet re=new RecordSet();
+ String sql="select b.FNAME from uf_accountinfo a,uf_accountinfo_dt1 b where a.id=b.mainid and a.zt='"+zt+"' and b.FNUMBER='"+km+"' and b.forgnumber='"+zz+"' and FAcctBookNumber='"+zb+"' ";
+ re.execute(sql);
+ while(re.next()){
+ FNAME=Util.null2String(re.getString("FNAME"));
+ }
+ return FNAME;
+ }
+ //获取币种的小数位
+ public int getXsw(String bz){
+ int xsw=0;
+ RecordSet re=new RecordSet();
+ String sql="select * from uf_k3bz where bh='"+bz+"'";
+ re.execute(sql);
+ while(re.next()){
+ xsw=Integer.parseInt(Util.null2o(re.getString("xsw"))) ;
+ }
+ return xsw;
+ }
+
+ //浮点型转换
+ public static float getfloats(String demo,String demo1,int len){
+ Logger log = Logger.getLogger(BigDecimal.class);
+ if(len==0){
+ len=0;
+ }
+ String str=Util.null2String(demo);
+ String str1=Util.null2String(demo1);
+ if("".equals(str)||"".equals(str.trim())||"null".equalsIgnoreCase(str.trim())){
+ return 0;
+ }
+ if("".equals(str1)||"".equals(str.trim())||"null".equalsIgnoreCase(str1.trim())){
+ str1="1";
+ }
+ float fl=0.0f;
+ //String str=Util.null2String(demo);
+ try{
+ if(str.trim().length()>0){
+ BigDecimal b1 = new BigDecimal(str.trim());
+ BigDecimal b2 = new BigDecimal(str1.trim());
+ BigDecimal b3=b1.multiply(b2);
+ //System.out.println(b1.setScale(2,BigDecimal.ROUND_HALF_UP));
+ fl=b3.setScale(len,BigDecimal.ROUND_HALF_UP).floatValue();
+ }
+ log.error("getfloats"+fl);
+ }catch(Exception e){
+ log.error(demo+"getfloats异常"+e.getMessage());
+ }
+ return fl;
+ }
+
+
+ //浮点型转换
+ public static float getfloats1(String demo,String demo1,int len){
+ Logger log = Logger.getLogger(BigDecimal.class);
+ if(len==0){
+ len=0;
+ }
+ String str=Util.null2String(demo);
+ String str1=Util.null2String(demo1);
+ if("".equals(str)||"".equals(str.trim())||"null".equalsIgnoreCase(str.trim())){
+ str="0";
+ }
+ if("".equals(str1)||"".equals(str.trim())||"null".equalsIgnoreCase(str1.trim())){
+ str1="0";
+ }
+ float fl=0.0f;
+ //String str=Util.null2String(demo);
+ try{
+ if(str.trim().length()>0){
+ BigDecimal b1 = new BigDecimal(str.trim());
+ BigDecimal b2 = new BigDecimal(str1.trim());
+ BigDecimal b3=b1.add(b2);
+ //System.out.println(b1.setScale(2,BigDecimal.ROUND_HALF_UP));
+ fl=b3.setScale(len,BigDecimal.ROUND_HALF_UP).floatValue();
+ }
+ log.error("getfloats"+fl);
+ }catch(Exception e){
+ log.error(demo+"getfloats异常"+e.getMessage());
+ }
+ return fl;
+ }
+ public static String sendGet(String url, String param,String basis) {
+ String result = "";
+ InputStream in = null;
+ try {
+ String urlNameString = url ;
+ URL realUrl = new URL(urlNameString);
+ URLConnection connection = realUrl.openConnection();
+ String auth="JNT:JNT2019";
+ String code = new sun.misc.BASE64Encoder().encode(auth.getBytes());
+ connection.setRequestProperty("Authorization", "Basic " + code);
+ connection.connect();
+ Map> map = connection.getHeaderFields();
+
+
+ for (String key : map.keySet()) {
+ System.out.println(key + "--->" + map.get(key));
+ }
+ //接收核心返回过来的数据 xml 需要解析
+ in =connection.getInputStream();
+ byte[] b =getBytes(in);
+ if(b.length>0){
+ result=new String(b);
+ }
+ System.out.println(b.length);
+ } catch (Exception e) {
+
+ System.out.println(e.getMessage());
+ e.printStackTrace();
+ }finally {
+ try {
+ if (in != null) {
+ in.close();
+ }
+ } catch (Exception e2) {
+ System.out.println(e2.getMessage());
+ e2.printStackTrace();
+ }
+ }
+ //System.out.println("de"+result);
+ return result;
+ }
+ public static byte[] getBytes(InputStream fis){
+ Logger log = Logger.getLogger(Logger.class);
+ byte[] buffer = null;
+ try {
+ //File file = new File(filePath);
+ //FileInputStream fis = new FileInputStream(file);
+ ByteArrayOutputStream bos = new ByteArrayOutputStream(1000);
+ byte[] b = new byte[10000];
+ int n;
+ while ((n = fis.read(b)) != -1) {
+ bos.write(b, 0, n);
+ }
+ fis.close();
+ bos.close();
+ buffer = bos.toByteArray();
+ } catch (FileNotFoundException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ System.out.println("buffer--->"+buffer.length);
+ return buffer;
+ }
+}
diff --git a/src/main/youhong_ai_jitu_src/com/jet/action/CreateK3PayBillAction.java b/src/main/youhong_ai_jitu_src/com/jet/action/CreateK3PayBillAction.java
new file mode 100644
index 0000000..238dc49
--- /dev/null
+++ b/src/main/youhong_ai_jitu_src/com/jet/action/CreateK3PayBillAction.java
@@ -0,0 +1,319 @@
+package com.jet.action;
+
+import java.text.DecimalFormat;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import kingdee.bos.webapi.client.K3CloudApiClient;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.jet.k3.K3Connect;
+
+import weaver.conn.RecordSet;
+import weaver.general.BaseBean;
+import weaver.general.Util;
+import weaver.interfaces.workflow.action.Action;
+import weaver.soa.workflow.request.RequestInfo;
+import selfdev.util.base.BaseUtil;
+import selfdev.util.base.TimeCommonUtil;
+import selfdev.util.log.LogTool;
+
+/**
+ * 付款申请流程在AP付款节点提交时将数据写入K3生成付款单
+ * @author KangMD
+ * 2019-11-29
+ */
+public class CreateK3PayBillAction extends BaseBean implements Action {
+
+ public String execute(RequestInfo ri) {
+ LogTool log=new LogTool("/log/selfdev/action", false);
+ //获取requestid
+ String requestid=ri.getRequestid();
+ String workflowid=ri.getWorkflowid();
+ //获取用户语言
+ int language=ri.getRequestManager().getUser().getLanguage();
+ log.writeLog("language---------->"+language);
+ String workflowname=BaseUtil.getBaseInfoByParm("workflowname", "workflow_base", "id", workflowid, "");
+ log.writeLog("---------------"+workflowname+"开始写入K3生成付款单-------------requestId:" + requestid);
+ //获取表名
+ String tablename=BaseUtil.getBaseInfoByParm("tablename", "workflow_bill", "1", "1", " and id in (select formid from workflow_base where id="+workflowid+")");;
+ RecordSet rs=new RecordSet();
+ try {
+ //获取当前系统日期
+ String nowDate=TimeCommonUtil.obtainDate(0).substring(0,10);
+ String mainid="";//主键ID
+ String fkfs="";//付款方式
+ String gysmc="";//供应商名称
+ String gysmc2="";//供应商名称（无合同）
+ String fphm="";//发票号码
+ String fksm="";//付款说明
+ String zfrq="";//支付日期
+ String sfyht="";//是否有合同
+ double bcfkje=0;//本次付款金额
+ double bcfkje2=0;//本次付款金额（无合同）
+ String bz="";//币种
+ String zz="";//组织
+ String k3yfdh="";//K3应付单号
+ String fkyxzh="";//付款银行账号
+ double fpcfkje=0;//分批次付款金额
+ String sfpcfk="";//是否批次付款
+ double pcyfkzje=0;//批次已付款总金额
+ String htxx="";//相关合同
+ String sql="select * from "+tablename+" where requestid="+requestid;
+ rs.execute(sql);
+ while(rs.next()){
+ mainid=Util.null2String(rs.getString("id"));
+ fkfs=Util.null2String(rs.getString("fkfs"));
+ gysmc=Util.null2String(rs.getString("gysmc"));
+ gysmc2=Util.null2String(rs.getString("gysmc2"));
+ fphm=Util.null2String(rs.getString("fphm"));
+ fksm=Util.null2String(rs.getString("fksm"));
+ zfrq=Util.null2String(rs.getString("zfrq"));
+ sfyht=Util.null2String(rs.getString("sfyht"));
+ bcfkje=Double.parseDouble(Util.null2o(rs.getString("bcfkje")).replaceAll(",", ""));
+ bcfkje2=Double.parseDouble(Util.null2o(rs.getString("bcfkje2")).replaceAll(",", ""));
+ bz=Util.null2String(rs.getString("bz"));
+ zz=Util.null2String(rs.getString("zz"));
+ k3yfdh=Util.null2String(rs.getString("k3yfdh"));
+ fkyxzh=Util.null2String(rs.getString("fkyxzh"));
+ fpcfkje=Double.parseDouble(Util.null2o(rs.getString("fpcfkje")).replaceAll(",", ""));
+ sfpcfk=Util.null2String(rs.getString("sfpcfk"));
+ htxx=Util.null2String(rs.getString("htxx"));
+ pcyfkzje=Double.parseDouble(Util.null2o(rs.getString("pcyfkzje")).replaceAll(",", ""));
+ }
+ //没有合同
+ if("1".equals(sfyht)){
+ gysmc=gysmc2;
+ bcfkje=bcfkje2;
+ }
+ //付款方式
+ if("0".equals(fkfs)){//银行
+ fkfs="JSFS03_SYS";
+ }else{
+ fkfs="JSFS01_SYS";//现金
+ }
+
+ String msg="";
+ double je_k3=0;//传入K3金额
+ DecimalFormat df=new DecimalFormat( "###############0.00 ");// 16位整数位，两小数位
+ //本流程还需要付款金额=流程中本次付款金额-批次已付款总金额
+ double blchxfkje=bcfkje-pcyfkzje;
+ if("0".equals(sfpcfk)){//批次付款，则取输入的分批次付款金额
+ if(fpcfkje>blchxfkje){
+ msg="本流程需要付款金额"+df.format(bcfkje)+",批次已付款总金额"+df.format(pcyfkzje)+",当前批次付款金额"+df.format(fpcfkje)+",已超出剩余未付款金额"+df.format(blchxfkje);
+ //将错误信息更新至表单字段中
+ rs.execute("update "+tablename+" set sfcgsck3yfd='1',k3jkfhxx='"+msg.replaceAll("'", "''")+"' where requestid="+requestid);
+ //写入K3失败则进行提醒，并阻止流程提交
+ ri.getRequestManager().setMessage("111100");
+ ri.getRequestManager().setMessagecontent(msg);
+ return "0";
+ }
+ je_k3=fpcfkje;
+ }else{//全部付款
+ je_k3=blchxfkje;
+ }
+ double pcyfkzje_new=pcyfkzje+je_k3;//批次已付款金额(本次写入K3之后)
+
+ //***************************************拼接K3 Cloud付款单所需的JSON字符串***********************************************//
+ Map data=new HashMap();
+
+ Map Model=new HashMap();
+ //单据类型(必填项)--------默认为采购业务付款单FKDLX01_SYS
+ Map FBillTypeID=new HashMap();
+ FBillTypeID.put("FNUMBER", "FKDLX01_SYS");
+ Model.put("FBillTypeID", FBillTypeID);
+ //业务日期(必填项)--------默认为当前系统日期
+ Model.put("FDATE", nowDate);
+ //往来单位类型,默认为供应商
+ Model.put("FCONTACTUNITTYPE", "BD_Supplier");
+ //往来单位(必填项)--------
+ Map FCONTACTUNIT=new HashMap();
+ FCONTACTUNIT.put("FNUMBER", gysmc);
+ Model.put("FCONTACTUNIT", FCONTACTUNIT);
+
+ //收款单位类型,默认为供应商
+ Model.put("FRECTUNITTYPE", "BD_Supplier");
+ //收款单位(必填项)--------
+ Map FRECTUNIT=new HashMap();
+ FRECTUNIT.put("FNUMBER", gysmc);
+ Model.put("FRECTUNIT", FRECTUNIT);
+
+ //币别(必填项)--------
+ Map FCURRENCYID=new HashMap();
+ FCURRENCYID.put("FNUMBER", bz);
+ Model.put("FCURRENCYID", FCURRENCYID);
+ Model.put("FEXCHANGERATE", 1.0);//汇率
+ Model.put("FSETTLERATE", 1.0);//结算汇率
+
+ //采购部门**************
+ Map FPURCHASEDEPTID=new HashMap();
+ FPURCHASEDEPTID.put("FNUMBER", "BM000001");
+ Model.put("FPURCHASEDEPTID", FPURCHASEDEPTID);
+
+ //结算组织(必填项)----
+ Map FSETTLEORGID=new HashMap();
+ FSETTLEORGID.put("FNumber", zz);
+ Model.put("FSETTLEORGID", FSETTLEORGID);//结算组织(必填项)----
+ //采购组织
+ Model.put("FPURCHASEORGID", FSETTLEORGID);
+ //备注
+ Model.put("FREMARK", fksm);
+ //期望付款日期
+ Model.put("FBookingDate", nowDate);
+ Model.put("FDOCUMENTSTATUS", "Z");//单据状态
+ Model.put("FCancelStatus", "A");//作废状态(必填项)----默认为A
+ //结算组织
+ Model.put("FPAYORGID", FSETTLEORGID);
+ //结算币别
+ Model.put("FSETTLECUR", FCURRENCYID);
+ //结算本位币
+ Model.put("FSETTLEMAINBOOKID", FCURRENCYID);
+
+ //-----------------付款单明细 start-----------------//
+ List> FPAYBILLENTRY=new ArrayList>();
+ //定义一行明细
+ Map PAYBILLENTRY=new HashMap();
+ //结算方式
+ Map FSETTLETYPEID=new HashMap();
+ FSETTLETYPEID.put("FNUMBER", fkfs);
+ PAYBILLENTRY.put("FSETTLETYPEID", FSETTLETYPEID);
+
+ //付款用途，默认为SFKYT08_SYS采购付款
+ Map FPURPOSEID=new HashMap();
+ FPURPOSEID.put("FNUMBER", "SFKYT08_SYS");
+ PAYBILLENTRY.put("FPURPOSEID", FPURPOSEID);
+
+ PAYBILLENTRY.put("FPAYTOTALAMOUNTFOR", je_k3);//表体-应付金额
+ PAYBILLENTRY.put("FPAYAMOUNTFOR_E", je_k3);//付款金额
+ PAYBILLENTRY.put("FSETTLEPAYAMOUNTFOR", je_k3);//折后金额
+ PAYBILLENTRY.put("FREALPAYAMOUNTFOR_D", je_k3);//表体-实付金额
+ //我方银行账号
+ Map FACCOUNTID=new HashMap();
+ FACCOUNTID.put("FNUMBER", fkyxzh);
+ PAYBILLENTRY.put("FACCOUNTID", FACCOUNTID);
+
+ PAYBILLENTRY.put("FPAYAMOUNT_E", je_k3);//付款金额本位币
+ PAYBILLENTRY.put("FPOSTDATE", nowDate);//登账日期
+ PAYBILLENTRY.put("FRuZhangType", "1");//入账类型
+ PAYBILLENTRY.put("FPayType", "A");//支付类型
+
+ //将MAP添加至List中
+ FPAYBILLENTRY.add(PAYBILLENTRY);
+
+ Model.put("FPAYBILLENTRY", FPAYBILLENTRY);//
+ //-----------------付款单明细 end-----------------//
+
+
+ //-----------------付款单源单明细 start-----------------//
+ List> FPAYBILLSRCENTRY=new ArrayList>();
+ //定义一行明细
+ Map PAYBILLSRCENTRY=new HashMap();
+ //源单类型
+ PAYBILLSRCENTRY.put("FSOURCETYPE", "AP_Payable");
+ //源单编号,取K3应付单号
+ PAYBILLSRCENTRY.put("FSRCBILLNO", k3yfdh);
+ //本次付款金额
+ PAYBILLSRCENTRY.put("FREALPAYAMOUNT_S", je_k3);
+ //应付金额
+ PAYBILLSRCENTRY.put("FAFTTAXTOTALAMOUNT", bcfkje);
+ //计划付款金额
+ PAYBILLSRCENTRY.put("FPLANPAYAMOUNT", bcfkje);
+ //源单币别
+ PAYBILLSRCENTRY.put("FSRCCURRENCYID", FCURRENCYID);
+ //到期日
+ PAYBILLSRCENTRY.put("FEXPIRY", nowDate);
+
+ //将MAP添加至List中
+ FPAYBILLSRCENTRY.add(PAYBILLSRCENTRY);
+ Model.put("FPAYBILLSRCENTRY", FPAYBILLSRCENTRY);//
+
+ //-----------------付款单源单明细 end-----------------//
+
+ data.put("Model", Model);
+
+ //将MAP转JSON，fastjson默认开启引用检测将相同的对象写成引用的形式，所以必须加上SerializerFeature.DisableCircularReferenceDetect，否则转换的字符串会出现$ref
+ String jsonStr = JSON.toJSONString(data, SerializerFeature.DisableCircularReferenceDetect);
+ log.writeLog("调用付款单保存接口传入数据jsonStr---------->"+jsonStr);
+ //连接K3
+ K3CloudApiClient client =K3Connect.connect();
+ if(client!=null){
+ //调用付款单保存接口
+ String sResult = client.excuteOperation("AP_PAYBILL", "save", jsonStr);
+ log.writeLog("调用付款单保存接口返回数据sResult---------->"+sResult);
+ //解析K3返回的JSO字符串
+ JSONObject jsonObject = JSONObject.parseObject(sResult);
+ JSONObject ResponseStatus=jsonObject.getJSONObject("Result").getJSONObject("ResponseStatus");
+ //是否成功写入K3
+ String IsSuccess=ResponseStatus.get("IsSuccess").toString();
+ log.writeLog("是否成功写入K3结果IsSuccess---------->"+IsSuccess);
+ //成功写入K3
+ if("true".equals(IsSuccess)){
+ JSONArray SuccessJSONArray=ResponseStatus.getJSONArray("SuccessEntitys");
+ String Id="";//单据ID
+ String Number="";//单据编号
+ for(int p=0;p"+Id+",Number------>"+Number);
+ //将付款单号更新至表单字段中
+ rs.execute("update "+tablename+" set sfcgsck3yfd='0',k3fkdh='"+Number+"',fpcfkje='',k3jkfhxx='',pcyfkzje=TO_CHAR("+pcyfkzje_new+",'FM999,999,999,999,999,999,990.00') where requestid="+requestid);
+ //将付款信息插入至付款明细中
+ rs.execute("insert into "+tablename+"_dt1 (mainid,fkyxzh,fkrq,fkje,k3fkdh) values('"+mainid+"','"+fkyxzh+"','"+nowDate+"',TO_CHAR("+je_k3+",'FM999,999,999,999,999,999,990.00'),'"+Number+"')");
+
+ //存在合同并且是（不需要分批次付款或者分批次的最后一次付款），则将付款信息更新至至建模合同台账中
+ if("0".equals(sfyht)&&bcfkje==pcyfkzje+je_k3){
+ //更新至建模的批次明细中
+ sql="update uf_httz_dt1 a set (yfkje,fkzt)=(select TO_CHAR(to_number(replace(nvl(a.yfkje,0),',',''))+to_number(replace(nvl(b.bcfkje,0),',','')),'FM999,999,999,999,999,999,990.00'),(case when to_number(replace(nvl(a.yfkje,0),',',''))+to_number(replace(nvl(b.bcfkje,0),',',''))=to_number(replace(nvl(a.fkje,0),',','')) then 0 else 2 end) from "+tablename+"_dt5 b where a.id=b.fkpc and b.mainid='"+mainid+"') where a.mainid='"+htxx+"'";
+ log.writeLog("流程中支付金额更新至合同建模明细中的金额SQL---------->"+sql);
+ rs.execute(sql);
+ //更新至建模的主表中
+ sql="update uf_httz a set yfkje=TO_CHAR(to_number(replace(nvl(a.yfkje,0),',',''))+"+je_k3+",'FM999,999,999,999,999,999,990.00') where id='"+htxx+"'";
+ log.writeLog("流程中支付金额更新至合同建模主表中的金额SQL---------->"+sql);
+ rs.execute(sql);
+ }
+ }else{
+ JSONArray ErrorsJSONArray=ResponseStatus.getJSONArray("Errors");
+ for(int p=0;p"+language);
+ String workflowname=BaseUtil.getBaseInfoByParm("workflowname", "workflow_base", "id", workflowid, "");
+ log.writeLog("---------------"+workflowname+"开始写入K3生成应付单-------------requestId:" + requestid);
+ //获取表名
+ String tablename=BaseUtil.getBaseInfoByParm("tablename", "workflow_bill", "1", "1", " and id in (select formid from workflow_base where id="+workflowid+")");;
+ RecordSet rs=new RecordSet();
+ try {
+ //获取当前系统日期
+ String nowDate=TimeCommonUtil.obtainDate(0).substring(0,10);
+ String fkfs="";//付款方式
+ String fygsbm="";//财务K3所属部门
+ String gysmc="";//供应商名称
+ String gysmc2="";//供应商名称（无合同）
+ String fphm="";//发票号码
+ String fksm="";//付款说明
+ String zfrq="";//支付日期
+ String sfyht="";//是否有合同
+ String bcfkje="";//本次付款金额
+ String bcfkje2="";//本次付款金额（无合同）
+ String sqje="";//税前金额
+ String zzs="";//增值税
+ //String dks="";//代扣税
+ String bz="";//币种
+ String zz="";//组织
+ String sql="select * from "+tablename+" where requestid="+requestid;
+ rs.execute(sql);
+ while(rs.next()){
+ fkfs=Util.null2String(rs.getString("fkfs"));
+ gysmc=Util.null2String(rs.getString("gysmc"));
+ gysmc2=Util.null2String(rs.getString("gysmc2"));
+ fphm=Util.null2String(rs.getString("fphm"));
+ fksm=Util.null2String(rs.getString("fksm")).replaceAll(" ", " ");
+ zfrq=Util.null2String(rs.getString("zfrq"));
+ sfyht=Util.null2String(rs.getString("sfyht"));
+ bcfkje=Util.null2o(rs.getString("bcfkje")).replace(",", "");
+ bcfkje2=Util.null2o (rs.getString("bcfkje2")).replace(",", "");
+ bz=Util.null2String(rs.getString("bz"));
+ zz=Util.null2String(rs.getString("zz"));
+ fygsbm=Util.null2String(rs.getString("fygsbm"));
+ sqje=Util.null2o(rs.getString("sqje")).replace(",", "");
+ zzs=Util.null2o(rs.getString("zzs")).replace(",", "");
+ //dks=Util.null2o(rs.getString("dks")).replace(",", "");
+ }
+ //K3中表头备注字段最多只能存储255位,将付款说明进行截取
+ if(fksm.length()>255){
+ fksm=fksm.substring(0,255);
+ }
+
+ //没有合同
+ if("1".equals(sfyht)){
+ gysmc=gysmc2;
+ bcfkje=bcfkje2;
+ }
+ //付款方式
+ if("0".equals(fkfs)){//银行
+ fkfs="JSFS03_SYS";
+ }else{
+ fkfs="JSFS01_SYS";//现金
+ }
+
+ //含税单价=税前金额+增值税
+ String hsdj=new BigDecimal(sqje).add(new BigDecimal(zzs)).setScale(2, BigDecimal.ROUND_HALF_UP).toString();
+
+ //***************************************拼接K3 Cloud应付单所需的JSON字符串***********************************************//
+ Map data=new LinkedHashMap();
+
+ Map Model=new LinkedHashMap();
+ //单据类型(必填项)--------默认为标准应付单YFD01_SYS
+ Map FBillTypeID=new LinkedHashMap();
+ FBillTypeID.put("FNUMBER", "YFD01_SYS");
+ Model.put("FBillTypeID", FBillTypeID);
+
+ //是否期初单据
+ Model.put("FISINIT", false);
+ //业务日期(必填项)--------默认为当前系统日期
+ Model.put("FDATE", nowDate);
+ //到期日(必填项)--------
+ Model.put("FENDDATE_H", nowDate);
+ //单据状态，默认为创建 Z
+ Model.put("FDOCUMENTSTATUS", "Z");
+
+ //供应商(必填项)--------
+ Map FSUPPLIERID=new LinkedHashMap();
+ FSUPPLIERID.put("FNUMBER", gysmc);
+ Model.put("FSUPPLIERID", FSUPPLIERID);
+
+ //币别(必填项)--------
+ Map FCURRENCYID=new LinkedHashMap();
+ FCURRENCYID.put("FNUMBER", bz);
+ Model.put("FCURRENCYID", FCURRENCYID);
+
+ Model.put("FISPRICEEXCLUDETAX", true);//价外税
+ Model.put("FBUSINESSTYPE", "CG");//业务类型(必填项)----默认为CG
+ Model.put("FISTAX", true);//按含税单价录入----
+
+ //结算组织(必填项)----
+ Map FSETTLEORGID=new LinkedHashMap();
+ FSETTLEORGID.put("FNumber", zz);
+ Model.put("FSETTLEORGID", FSETTLEORGID);//结算组织(必填项)----
+
+ //采购部门----
+ Map FPURCHASEDEPTID=new LinkedHashMap();
+ FPURCHASEDEPTID.put("FNUMBER", fygsbm);
+ Model.put("FPURCHASEDEPTID", FPURCHASEDEPTID);
+
+ //付款组织(必填项)----
+ Map FPAYORGID=new LinkedHashMap();
+ FPAYORGID.put("FNUMBER", zz);
+ Model.put("FPAYORGID", FPAYORGID);
+
+ //作废状态(必填项)----默认为A
+ Model.put("FCancelStatus", "A");
+ //Invoice No(必填项)----
+ Model.put("F_RTA_InvoiceNo", fphm);
+ //business type(必填项)----默认为服务类S
+ Model.put("F_RTA_BusinessType", "S");
+ //备注
+ Model.put("FAP_Remark", fksm);
+
+ //PPH By Company
+ Model.put("F_RTA_PPHByComp", false);
+
+
+ //-----------------表头供应商 start-----------------//
+ Map FsubHeadSuppiler=new LinkedHashMap();
+ FsubHeadSuppiler.put("FORDERID", FSUPPLIERID);//订货方
+ FsubHeadSuppiler.put("FTRANSFERID", FSUPPLIERID);//供货方
+ FsubHeadSuppiler.put("FChargeId", FSUPPLIERID);//收款方
+ Model.put("FsubHeadSuppiler", FsubHeadSuppiler);//将供应商信息加入至Map中
+ //-----------------表头供应商 end-----------------//
+
+ //-----------------表头财务 start-----------------//
+ Map FsubHeadFinc=new LinkedHashMap();
+ FsubHeadFinc.put("FACCNTTIMEJUDGETIME", zfrq);//到期日计算日期(必填项)----
+ //结算方式
+ Map FSettleTypeID=new LinkedHashMap();
+ FSettleTypeID.put("FNUMBER", fkfs);
+ FsubHeadFinc.put("FSettleTypeID", FSettleTypeID);
+ //本位币
+ FsubHeadFinc.put("FMAINBOOKSTDCURRID", FCURRENCYID);
+ Model.put("FsubHeadFinc", FsubHeadFinc);//
+ //-----------------表头财务 end-----------------//
+
+ //-----------------明细 start-----------------//
+ List> FEntityDetail=new ArrayList>();
+ //定义一行明细
+ Map EntityDetail=new LinkedHashMap();
+ //物料编码
+ Map FMATERIALID=new LinkedHashMap();
+ FMATERIALID.put("FNUMBER", "100013");
+ EntityDetail.put("FMATERIALID", FMATERIALID);
+ //K3中明细备注字段最多只能存储50位,将付款说明进行截取
+ if(fksm.length()>50){
+ fksm=fksm.substring(0,50);
+ }
+ EntityDetail.put("F_RTA_EntryRemarks", fksm);//备 注
+ //计价单位
+ Map FPRICEUNITID=new LinkedHashMap();
+ FPRICEUNITID.put("FNUMBER", "Pcs");
+ EntityDetail.put("FPRICEUNITID", FPRICEUNITID);
+
+ EntityDetail.put("FPrice", sqje);//单价
+ EntityDetail.put("FPriceQty", 1.0);//计价数量
+ EntityDetail.put("FTaxPrice", hsdj);//含税单价=税前单价+增值税
+ //EntityDetail.put("F_RTA_PPHAmount", dks);//代扣税
+ EntityDetail.put("FPriceWithTax", bcfkje);//含税净价
+ //PPN Type
+ Map F_RTA_VATType_d=new LinkedHashMap();
+ F_RTA_VATType_d.put("FNUMBER", "000");
+ EntityDetail.put("F_RTA_VATType_d", F_RTA_VATType_d);
+
+ EntityDetail.put("FNoTaxAmountFor_D", sqje);//不含税金额
+ EntityDetail.put("FTAXAMOUNTFOR_D", 0);//税额
+ EntityDetail.put("FALLAMOUNTFOR_D", bcfkje);//价税合计bcfkje
+ EntityDetail.put("F_RTA_FakturPajakNo_d", "-");//Faktur Pajak No
+ EntityDetail.put("F_RTA_SUPPLIER_D", FSUPPLIERID);//表体供应商(用于校验税票号唯一)
+ //将MAP添加至List中
+ FEntityDetail.add(EntityDetail);
+ Model.put("FEntityDetail", FEntityDetail);//
+ //-----------------明细 end-----------------//
+
+ //-----------------付款计划 start-----------------//
+ List> FEntityPlan=new ArrayList>();
+ Map FPlan=new LinkedHashMap();
+ FPlan.put("FENDDATE", zfrq);//表头计划 - 到期日
+ FPlan.put("FPAYAMOUNTFOR", bcfkje);//应付金额
+ FPlan.put("FPAYRATE", 100);//应付比例(%)
+ FEntityPlan.add(FPlan);
+ Model.put("FEntityPlan", FEntityPlan);//
+ //-----------------付款计划 end-----------------//
+ data.put("Model", Model);
+
+
+ //将MAP转JSON，fastjson默认开启引用检测将相同的对象写成引用的形式，所以必须加上SerializerFeature.DisableCircularReferenceDetect，否则转换的字符串会出现$ref
+ String jsonStr = JSON.toJSONString(data, SerializerFeature.DisableCircularReferenceDetect);
+ log.writeLog("调用应付单保存接口传入数据jsonStr---------->"+jsonStr);
+ //连接K3
+ K3CloudApiClient client =K3Connect.connect();
+ if(client!=null){
+ //调用应付单保存接口
+ String sResult = client.excuteOperation("AP_Payable", "save", jsonStr);
+ log.writeLog("调用应付单保存接口返回数据sResult---------->"+sResult);
+ //解析K3返回的JSO字符串
+ JSONObject jsonObject = JSONObject.parseObject(sResult);
+ JSONObject ResponseStatus=jsonObject.getJSONObject("Result").getJSONObject("ResponseStatus");
+ //是否成功写入K3
+ String IsSuccess=ResponseStatus.get("IsSuccess").toString();
+ log.writeLog("是否成功写入K3结果IsSuccess---------->"+IsSuccess);
+ //成功写入K3
+ if("true".equals(IsSuccess)){
+ JSONArray SuccessJSONArray=ResponseStatus.getJSONArray("SuccessEntitys");
+ String Id="";//单据ID
+ String Number="";//单据编号
+ for(int p=0;p"+Id+",Number------>"+Number);
+ //将应付单号更新至表单字段中
+ rs.execute("update "+tablename+" set sfcgsck3yfd='0',sfpcfk='1',fpcfkje='"+bcfkje+"',pcyfkzje='0',gysmc='"+gysmc+"',bcfkje='"+bcfkje+"',k3yfdh='"+Number+"',k3jkfhxx='' where requestid="+requestid);
+ }else{
+ JSONArray ErrorsJSONArray=ResponseStatus.getJSONArray("Errors");
+ String msg="";
+ for(int p=0;p"+language);
+ String workflowname=BaseUtil.getBaseInfoByParm("workflowname", "workflow_base", "id", workflowid, "");
+ log.writeLog("---------------"+workflowname+"开始写入K3生成应付单或者其他应付单-------------requestId:" + requestid);
+ //获取表名
+ String tablename=BaseUtil.getBaseInfoByParm("tablename", "workflow_bill", "1", "1", " and id in (select formid from workflow_base where id="+workflowid+")");;
+ RecordSet rs=new RecordSet();
+ try {
+ //获取当前系统日期
+ String nowDate=TimeCommonUtil.obtainDate(0).substring(0,10);
+ String zffs="";//付款方式
+ String fygsbm="";//财务K3所属部门
+ String jklx="";//借款类型
+ String fphm="OA-"+requestid;//发票号码
+ String jkyy="";//借款原因
+ String dls="";//代理商
+ String jkrq="";//期望支付日期
+ String jkje="";//借款金额
+ String bz="";//币种
+ String zz="";//组织
+ String jkrdyk3ygbh="";//借款人对应K3员工编号
+ String sql="select * from "+tablename+" where requestid="+requestid;
+ rs.execute(sql);
+ while(rs.next()){
+ zffs=Util.null2String(rs.getString("zffs"));
+ jklx=Util.null2String(rs.getString("jklx"));
+ fygsbm=Util.null2String(rs.getString("fygsbm"));
+ jkyy=Util.null2String(rs.getString("jkyy")).replaceAll(" ", " ");
+ dls=Util.null2String(rs.getString("dls"));
+ jkrq=Util.null2String(rs.getString("jkrq"));
+ jkje=Util.null2String(rs.getString("jkje"));
+ bz=Util.null2String(rs.getString("bz"));
+ zz=Util.null2String(rs.getString("zz"));
+ jkrdyk3ygbh=Util.null2String(rs.getString("jkrdyk3ygbh"));
+ }
+
+ //K3中表头备注字段最多只能存储255位,将付款说明进行截取
+ if(jkyy.length()>255){
+ jkyy=jkyy.substring(0,255);
+ }
+
+ //付款方式
+ if("0".equals(zffs)){//银行
+ zffs="JSFS03_SYS";
+ }else{
+ zffs="JSFS01_SYS";//现金
+ }
+ //K3接口名
+ String interfaceName="AP_Payable";
+ //K3接口描述
+ String interfaceDesc="应付单";
+ //***************************************拼接K3 Cloud (其他)应付单所需的JSON字符串***********************************************//
+ Map data=new HashMap();
+ Map Model=new HashMap();
+
+ if("0".equals(jklx)){//员工借款,生成K3的其他应付单
+ interfaceName="AP_OtherPayable";
+ interfaceDesc="其他应付单";
+ //单据类型(必填项)--------默认为其他应付单QTYFD01_SYS
+ Map FBillTypeID=new HashMap();
+ FBillTypeID.put("FNUMBER", "QTYFD01_SYS");
+ Model.put("FBillTypeID", FBillTypeID);
+
+ Model.put("FDATE", nowDate);//业务日期(必填项)--------默认为申请日期
+ Model.put("FENDDATE_H", nowDate);//到期日(必填项)--------
+ Model.put("FCONTACTUNITTYPE", "BD_Empinfo");//往来单位类型，默认为员工BD_Empinfo
+
+ //往来单位编码（即员工编码）
+ Map FCONTACTUNIT=new HashMap();
+ FCONTACTUNIT.put("FNUMBER", jkrdyk3ygbh);
+ Model.put("FCONTACTUNIT", FCONTACTUNIT);
+
+ //币别(必填项)--------
+ Map FCURRENCYID=new HashMap();
+ FCURRENCYID.put("FNUMBER", bz);
+ Model.put("FCURRENCYID", FCURRENCYID);
+
+ Model.put("FTOTALAMOUNTFOR_H", jkje);//总金额
+ Model.put("FNOTSETTLEAMOUNTFOR", jkje);//未结算金额
+
+ //申请部门
+ Map FDEPARTMENTID=new HashMap();
+ FDEPARTMENTID.put("FNumber", fygsbm);
+ Model.put("FDEPARTMENTID", FDEPARTMENTID);
+
+ //付款组织(必填项)----
+ Map FPAYORGID=new HashMap();
+ FPAYORGID.put("FNUMBER", zz);
+ Model.put("FPAYORGID", FPAYORGID);
+ //结算组织
+ Model.put("FSETTLEORGID", FPAYORGID);
+ //采购组织
+ Model.put("FPURCHASEORGID", FPAYORGID);
+ //采购部门
+ Model.put("FPURCHASEDEPTID", FDEPARTMENTID);
+ //本位币
+ Model.put("FMAINBOOKSTDCURRID", FCURRENCYID);
+
+ //到期日计算日期(期望支付日期)
+ Model.put("FACCNTTIMEJUDGETIME", jkrq);
+ //作废状态
+ Model.put("FCancelStatus", "A");
+ //备注
+ Model.put("FRemarks", jkyy);
+
+ //-----------------明细 start-----------------//
+ List> FEntity=new ArrayList>();
+ //定义一行明细
+ Map EntityDetail=new HashMap();
+ //费用项目编码,默认为CI074
+ Map FCOSTID=new HashMap();
+ FCOSTID.put("FNUMBER", "CI074");
+ EntityDetail.put("FCOSTID", FCOSTID);
+ //费用归属部门
+ EntityDetail.put("FCOSTDEPARTMENTID", FDEPARTMENTID);
+ //不含税金额
+ EntityDetail.put("FNOTAXAMOUNTFOR", jkje);
+ //总金额
+ EntityDetail.put("FTOTALAMOUNTFOR", jkje);
+ //未结算金额
+ EntityDetail.put("FNOTSETTLEAMOUNTFOR_D", jkje);
+ //不含税金额本位币
+ EntityDetail.put("FNOTAXAMOUNT_D", jkje);
+ //发票类型
+ //EntityDetail.put("FINVOICETYPE", "");
+ //K3中明细备注字段最多只能存储50位,将借款原因进行截取
+ if(jkyy.length()>50){
+ jkyy=jkyy.substring(0,50);
+ }
+ //备注
+ EntityDetail.put("FCOMMENT", jkyy);
+ //将MAP添加至List中
+ FEntity.add(EntityDetail);
+ Model.put("FEntity", FEntity);//
+ //-----------------明细 end-----------------//
+ }else{//代理商借款,生成K3的应付单
+
+ //单据类型(必填项)--------默认为标准应付单YFD01_SYS
+ Map FBillTypeID=new HashMap();
+ FBillTypeID.put("FNUMBER", "YFD01_SYS");
+ Model.put("FBillTypeID", FBillTypeID);
+
+ //是否期初单据
+ Model.put("FISINIT", false);
+ //业务日期(必填项)--------默认为当前系统日期
+ Model.put("FDATE", nowDate);
+ //到期日(必填项)--------
+ Model.put("FENDDATE_H", nowDate);
+ //单据状态，默认为创建 Z
+ Model.put("FDOCUMENTSTATUS", "Z");
+
+ //供应商(必填项)--------
+ Map FSUPPLIERID=new HashMap();
+ FSUPPLIERID.put("FNUMBER", dls);
+ Model.put("FSUPPLIERID", FSUPPLIERID);
+
+ //币别(必填项)--------
+ Map FCURRENCYID=new HashMap();
+ FCURRENCYID.put("FNUMBER", bz);
+ Model.put("FCURRENCYID", FCURRENCYID);
+
+ Model.put("FISPRICEEXCLUDETAX", true);//价外税
+ Model.put("FBUSINESSTYPE", "CG");//业务类型(必填项)----默认为CG
+ Model.put("FISTAX", true);//按含税单价录入----
+
+ //结算组织(必填项)----
+ Map FSETTLEORGID=new HashMap();
+ FSETTLEORGID.put("FNumber", zz);
+ Model.put("FSETTLEORGID", FSETTLEORGID);//结算组织(必填项)----
+
+ //采购部门----
+ Map FPURCHASEDEPTID=new HashMap();
+ FPURCHASEDEPTID.put("FNUMBER", fygsbm);
+ Model.put("FPURCHASEDEPTID", FPURCHASEDEPTID);
+
+ //付款组织(必填项)----
+ Map