diff --git a/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/controller/BusinessApplyStartController.java b/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/controller/BusinessApplyStartController.java index 756512a7a..c1a693fc8 100644 --- a/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/controller/BusinessApplyStartController.java +++ b/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/controller/BusinessApplyStartController.java @@ -126,5 +126,24 @@ public class BusinessApplyStartController { } } + //邮寄归档发起 + @Path("/mail/start") + @POST + public Map MailStart(@Context HttpServletRequest request, + @Context HttpServletResponse response, @Context JBOTransaction tx, + @Context Transaction sqlca) throws Exception { + ReturnMapUtil ReturnMapUtil = new ReturnMapUtil(tx, sqlca); + ARE.getLog().info( + "[CONTROLLER] BusinessApplyStartController run ................."); + ARE.getLog().info("[Path] /apply/mail/start" + " run ................."); + + BusinessApplyStartService service = new BusinessApplyStartServiceImpl(); + try { + return service.MailStart(request, response, tx, sqlca, ReturnMapUtil); + } catch (Exception e) { + return ReturnMapUtil.rollback(e); + } + } + } diff --git a/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/initiate/MailArchiveBO.java b/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/initiate/MailArchiveBO.java new file mode 100644 index 000000000..86ead8b7b --- /dev/null +++ b/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/initiate/MailArchiveBO.java @@ -0,0 +1,329 @@ +package apx.com.amarsoft.als.apzl.apply.business.start.initiate; + +import java.io.Serializable; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +import com.amarsoft.are.ARE; +import com.amarsoft.are.jbo.BizObject; +import com.amarsoft.are.jbo.BizObjectManager; +import com.amarsoft.are.jbo.BizObjectQuery; +import com.amarsoft.are.jbo.JBOException; +import com.amarsoft.are.jbo.JBOFactory; +import com.amarsoft.are.jbo.JBOTransaction; +import com.amarsoft.are.lang.StringX; +import com.base.constant.RestfullConstant; +import com.base.util.JsonUtil; +import com.base.util.StringUtil; +import com.tenwa.flow.action.comm.BaseFlowStartAction; +import com.tenwa.util.SerialNumberUtil; + +import jbo.app.LB_DOCLIBRARY; +import jbo.app.tenwa.calc.LC_CALC_CONDITION_TEMP; +import jbo.app.tenwa.calc.LC_RENT_PLAN_TEMP; +import jbo.app.tenwa.doc.LB_DOCATTRIBUTE; +import jbo.app.tenwa.doc.LB_DOCRELATIVE; +import jbo.com.tenwa.entity.comm.flow.FLOW_BUSSINESS_OBJECT; +import net.sf.json.JSONObject; + +public class MailArchiveBO implements Serializable{ + private static final long serialVersionUID = -266598671717858119L; + private String ApplyType; + private String CurUserID; + private String ProjectName; + private String ContractNumber; + private String ContractId; + + private String customertype; + private String msg; + private Map params; + private String fixedFlowParam; + private String objectNo; + private String serialNo; + + public void setParam(Map fieldMap, String param, Object obj) { + obj = fieldMap.get(param.toLowerCase()) == null ? null : fieldMap.get( + param.toLowerCase()).toString(); + } + + public boolean checkKeyField() { + if (StringX.isSpace(ApplyType)) { + msg = "申请编号不能为空！"; + return false; + } + if (StringX.isSpace(ProjectName)) { + msg = "项目名称不能为空！"; + return false; + } + if (StringX.isSpace(CurUserID)) { + msg = "用户id不能为空！"; + return false; + } + if (StringX.isSpace(ContractNumber)) { + msg = "互斥id不能为空！"; + return false; + } + return true; + } + + + public MailArchiveBO(Map fieldMap, JBOTransaction tx) throws Exception { + this.ApplyType = fieldMap.get("ApplyType".toLowerCase()) == null ? "" + : fieldMap.get("ApplyType".toLowerCase()).toString(); // 流程实例号 + this.ProjectName = fieldMap.get("projectName".toLowerCase()) == null ? "" + : fieldMap.get("projectName".toLowerCase()).toString(); // 项目名称 + this.customertype = fieldMap.get("customertype".toLowerCase()) == null ? "" + : fieldMap.get("customertype".toLowerCase()).toString(); // 租赁类型 + this.CurUserID = fieldMap.get("userid".toLowerCase()) == null ? "" + : fieldMap.get("userid".toLowerCase()).toString(); // 客户id + this.ContractNumber = fieldMap.get("CONTRACT_NUMBER".toLowerCase()) == null ? "" + : fieldMap.get("CONTRACT_NUMBER".toLowerCase()).toString(); // 邮寄号 + + } + + public void businessAppStart(JBOTransaction tx) throws Exception { + if (!checkKeyField()) // 校验非空字段 + return; + + Map map = new HashMap(); + BaseFlowStartAction action = new BaseFlowStartAction(); + + map.put("ApplyType", ApplyType); + action.setApplyType(ApplyType); + map.put("ProjectName", ProjectName); + action.setProjectName(ProjectName); + map.put("ContractNumber", ContractNumber); + map.put("customertype", customertype); + action.setCustomertype(customertype); + map.put("CurUserID", CurUserID); + action.setCurUserID(CurUserID); + + JSONObject jsonObject = JSONObject.fromObject(map); + this.fixedFlowParam = jsonObject.toString(); + action.setFixedFlowParam(fixedFlowParam); + msg = action.initFLow(tx); // 定义流程中需要的参数 + params = action.getFlowParam(); + + objectNo = params.get("FlowUnid"); + ContractId = params.get("ProjectId"); + if (msg.startsWith("success")) { + serialNo = msg.split("@")[1]; + } + } + + public boolean checkDoc() throws JBOException { + BizObjectManager fboM = JBOFactory + .getBizObjectManager(FLOW_BUSSINESS_OBJECT.CLASS_NAME); + + BizObject fbo = fboM.createQuery("flow_unid=:flow_unid") + .setParameter("flow_unid", objectNo).getSingleResult(false); + if (null == fbo) { + msg = "未找到流程实例!"; + return false; + } + try { + String flowPara = fbo.getAttribute("FixedFlowParam") == null ? "" + : fbo.getAttribute("FixedFlowParam").toString(); + JSONObject jo = JsonUtil.str2JSONObject(flowPara.trim()); + customertype = jo.get("CustomerType") == null ? "" : jo + .getString("CustomerType"); + } catch (Exception e) { + ARE.getLog().error(e); + msg = "获取客户信息失败!"; + return false; + } + String proj_id = fbo.getAttribute("proj_id").getString(); + String sql = ""; + sql = "SELECT DISTINCT O.ID, O.DOC_NAME,r.id " + "FROM O, " + + LB_DOCRELATIVE.CLASS_NAME + " R " + + "WHERE O.RELATIVE_ID = R.ID " + + "AND O.ID NOT IN (SELECT A.LIBRARY_ID FROM " + + LB_DOCATTRIBUTE.CLASS_NAME + " A) " + + "AND R.ObjectType='BusinessApplyFlow' and R.proj_id=:projid " + "AND o.DOC_NATURE='01' " + + "ORDER BY SERIAL_NUM"; + BizObjectManager libraryManage = JBOFactory + .getBizObjectManager(LB_DOCLIBRARY.CLASS_NAME); + BizObjectQuery query = libraryManage.createQuery(sql).setParameter( + "projid", proj_id); + @SuppressWarnings("unchecked") + List librarys = query.getResultList(false); + + String docNameConfig = "01".equals(customertype) ? RestfullConstant.baseProperty + .get("COMPANY_DOC_NAME").toString() + : "03".equals(customertype) ? RestfullConstant.baseProperty + .get("PERSON_DOC_NAME").toString() : ""; + String[] array = docNameConfig.trim().split(","); + String docName = ""; + for (String str : array) { + String[] array2 = str.trim().split("@"); + docName += array2[0].trim() + ","; + } + String[] docArr = docName.split(","); + Object[] arr2 = StringUtil.removalDuplicate(docArr); + msg = ""; + for (int i = 0; i < arr2.length; i++) { + String doc = arr2[i].toString(); + for (BizObject library : librarys) { + if (doc.trim().equals( + library.getAttribute("DOC_NAME").toString().trim())) { + msg += " [" + doc + "] 必备 未上传资料照片!\r\n"; + } + } + } + + BizObjectManager conditionM = JBOFactory.getBizObjectManager(LC_CALC_CONDITION_TEMP.CLASS_NAME); + BizObjectManager rentM = JBOFactory.getBizObjectManager(LC_RENT_PLAN_TEMP.CLASS_NAME); + BizObject condition = conditionM.createQuery("FLOWUNID=:FLOWUNID").setParameter("FLOWUNID", objectNo).getSingleResult(false); + BizObject rent = rentM.createQuery("FLOWUNID=:FLOWUNID").setParameter("FLOWUNID", objectNo).getSingleResult(false); + + if (null == condition || null == rent) { + msg += " [商务条件] 没有找到业务测算信息!\r\n"; + } + + + if (msg.equals("")) { + return true; + } + // msg += "业务申请 提交风险预警报告"; + return false; + } + + + + + public String getApplyType() { + return ApplyType; + } + + + + public void setApplyType(String applyType) { + ApplyType = applyType; + } + + + + public String getCurUserID() { + return CurUserID; + } + + + + public void setCurUserID(String curUserID) { + CurUserID = curUserID; + } + + + + public String getProjectName() { + return ProjectName; + } + + + + public void setProjectName(String projectName) { + ProjectName = projectName; + } + + + +/* public String getFlowKey() { + return FlowKey; + } + + + + public void setFlowKey(String flowKey) { + FlowKey = flowKey; + }*/ + + + + public String getCustomertype() { + return customertype; + } + + + + public void setCustomertype(String customertype) { + this.customertype = customertype; + } + + + + public String getMsg() { + return msg; + } + + + + public void setMsg(String msg) { + this.msg = msg; + } + + + + public Map getParams() { + return params; + } + + + + public void setParams(Map params) { + this.params = params; + } + + + + public String getFixedFlowParam() { + return fixedFlowParam; + } + + + + public void setFixedFlowParam(String fixedFlowParam) { + this.fixedFlowParam = fixedFlowParam; + } + + + + public String getObjectNo() { + return objectNo; + } + + + + public void setObjectNo(String objectNo) { + this.objectNo = objectNo; + } + + + + public String getSerialNo() { + return serialNo; + } + + + + public void setSerialNo(String serialNo) { + this.serialNo = serialNo; + } + + + + public static long getSerialversionuid() { + return serialVersionUID; + } + + public String getContractId() { + return ContractId; + } + + public void setContractId(String contractId) { + ContractId = contractId; + } + + + +} diff --git a/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/service/BusinessApplyStartService.java b/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/service/BusinessApplyStartService.java index da07cdbf1..d9da42119 100644 --- a/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/service/BusinessApplyStartService.java +++ b/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/service/BusinessApplyStartService.java @@ -34,4 +34,8 @@ public interface BusinessApplyStartService { Map OverseersStart(@Context HttpServletRequest request, @Context HttpServletResponse response, @Context JBOTransaction tx, @Context Transaction sqlca, ReturnMapUtil ReturnMapUtil) throws Exception; + + Map MailStart(@Context HttpServletRequest request, + @Context HttpServletResponse response, @Context JBOTransaction tx, + @Context Transaction sqlca, ReturnMapUtil ReturnMapUtil) throws Exception; } diff --git a/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/service/impl/BusinessApplyStartServiceImpl.java b/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/service/impl/BusinessApplyStartServiceImpl.java index 20cfd8647..0dfbea54e 100644 --- a/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/service/impl/BusinessApplyStartServiceImpl.java +++ b/src_app_fresh/apx/com/amarsoft/als/apzl/apply/business/start/service/impl/BusinessApplyStartServiceImpl.java @@ -14,6 +14,7 @@ import apx.com.amarsoft.als.apzl.apply.business.start.bo.BusinessBO; import apx.com.amarsoft.als.apzl.apply.business.start.bo.ChangeBusinessBO; import apx.com.amarsoft.als.apzl.apply.business.start.bo.MakeContractBusinessBO; import apx.com.amarsoft.als.apzl.apply.business.start.init.InitDocListTools; +import apx.com.amarsoft.als.apzl.apply.business.start.initiate.MailArchiveBO; import apx.com.amarsoft.als.apzl.apply.business.start.initiate.OverseersBO; import apx.com.amarsoft.als.apzl.apply.business.start.initiate.PaymentRequestBO; import apx.com.amarsoft.als.apzl.apply.business.start.service.BusinessApplyStartService; @@ -274,5 +275,39 @@ public class BusinessApplyStartServiceImpl implements BusinessApplyStartService return ReturnMapUtil.getReturnMap(); } + + @SuppressWarnings("unchecked") + @Override + public Map MailStart(HttpServletRequest request, HttpServletResponse response, JBOTransaction tx, + Transaction sqlca, ReturnMapUtil ReturnMapUtil) throws Exception { + Map testMap = (Map) MultipartDataUtil + .readRequestParam(request, "UTF-8"); + System.out.println("=============发起邮寄归档申请参数================================"); + System.out.println(testMap.toString()); + System.out.println("======================================="); + fieldMap = (Map) testMap.get("fieldMap"); + MailArchiveBO bo = new MailArchiveBO(fieldMap, tx); + bo.businessAppStart(tx); + tx.commit(); + String sReturnInfo = bo.getMsg(); + if (sReturnInfo.startsWith("success")) { + Map body = new HashMap(); + body.put("flowUnid", bo.getObjectNo()); + body.put("objectNo", bo.getObjectNo()); + //body.put("projectId", bo.getProjectId()); + body.put("taskNo", bo.getSerialNo()); + body.put("serialNo", bo.getSerialNo()); + ReturnMapUtil.setReturnMap(body, + RestfullConstant.baseProperty.get("success").toString(), + "发起成功"); + }else{ + ReturnMapUtil.setReturnMap(null, + RestfullConstant.baseProperty.get("fail").toString(), + sReturnInfo); + } + + return ReturnMapUtil.getReturnMap(); + } + }