#新增查询接口

#修改快递信息
This commit is contained in:
zhangjun 2020-08-06 17:33:12 +08:00
parent e084fdf26b
commit c63afef3a4
3 changed files with 49 additions and 11 deletions

View File

@ -53,6 +53,10 @@ public interface ApplyArchiveService {
@Context HttpServletResponse response, @Context JBOTransaction tx,
@Context Transaction sqlca, ReturnMapUtil ReturnMapUtil)
throws Exception;
Map<String, Object> BusinessRefer(@Context HttpServletRequest request,
@Context HttpServletResponse response, @Context JBOTransaction tx,
@Context Transaction sqlca, ReturnMapUtil ReturnMapUtil)
throws Exception;
Map<String, Object> BusinessUncommitted(@Context HttpServletRequest request,
@Context HttpServletResponse response, @Context JBOTransaction tx,
@Context Transaction sqlca, ReturnMapUtil ReturnMapUtil)

View File

@ -8,6 +8,7 @@ import java.util.Map.Entry;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.amarsoft.app.als.businesscomponent.analysis.checkmethod.impl.OrgIDChecker;
import com.amarsoft.are.jbo.BizObject;
import com.amarsoft.are.jbo.BizObjectManager;
import com.amarsoft.are.jbo.JBOFactory;
@ -92,27 +93,24 @@ public class ApplyArchiveServiceImpl implements ApplyArchiveService{
@Override
public Map<String, Object> saveCourierInformation(HttpServletRequest request, HttpServletResponse response,
JBOTransaction tx, Transaction sqlca, ReturnMapUtil ReturnMapUtil) throws Exception {
Map<String, Object> testMap = (Map<String, Object>) MultipartDataUtil.readRequestParam(request, "UTF-8");
BizObjectManager catManage = JBOFactory.getBizObjectManager(LB_FILE_MAILARCHIVING_INFO_TEMP.CLASS_NAME,sqlca);
BizObjectManager catManage = JBOFactory.getBizObjectManager(LB_FILE_MAILARCHIVING_INFO_TEMP.CLASS_NAME,tx);
fieldMap = (Map<String, Object>) testMap.get("fieldMap"); // 参数
String flowunid = fieldMap.get("flowunid") == null ? "" : fieldMap.get("flowunid").toString();
String userid = fieldMap.get("userid") == null ? "" : fieldMap.get("userid").toString();
ASUser CurUser = new ASUser(userid, sqlca);
BizObject cat = catManage.createQuery(" flowunid =:flowunid").setParameter("flowunid", flowunid).getSingleResult(true);
if( cat == null ){
cat = catManage.newObject();
cat.setAttributeValue("inputuserid", userid);
cat.setAttributeValue("inputorgid", CurUser.getOrgID());
cat.setAttributeValue("inputtime", DateUtil.getSystemTimeByFormat("yyyy/MM/dd HH:mm:ss"));
List<BizObject> cats = catManage.createQuery(" flowunid =:flowunid").setParameter("flowunid", flowunid).getResultList(true);
for (BizObject cat : cats) {
cat.setAttributeValue("updateuserid", userid);
cat.setAttributeValue("updateorgid", CurUser.getOrgID());
cat.setAttributeValue("updatetime", DateUtil.getSystemTimeByFormat("yyyy/MM/dd HH:mm:ss"));
cat.setAttributeValue("EXPNUMBER", fieldMap.get("EXPNUMBER") == null ? "" : fieldMap.get("EXPNUMBER").toString());
cat.setAttributeValue("EXPCOMPANY", fieldMap.get("EXPCOMPANY") == null ? "" : fieldMap.get("EXPCOMPANY").toString());
catManage.saveObject(cat);
}
cat.setAttributeValue("EXPNUMBER", fieldMap.get("EXPNUMBER") == null ? "" : fieldMap.get("EXPNUMBER").toString());
cat.setAttributeValue("EXPCOMPANY", fieldMap.get("EXPCOMPANY") == null ? "" : fieldMap.get("EXPCOMPANY").toString());
cat.setAttributeValue("flowunid",flowunid);
catManage.saveObject(cat);
ReturnMapUtil.setReturnMap(null,
RestfullConstant.baseProperty.get("success").toString(), "");
return ReturnMapUtil.getReturnMap();
@ -314,6 +312,23 @@ public class ApplyArchiveServiceImpl implements ApplyArchiveService{
return ReturnMapUtil.getReturnMap();
}
//»ñÈ¡²éѯÁ÷³ÌÃû³Æ²éѯ
@Override
public Map<String, Object> BusinessRefer(HttpServletRequest request, HttpServletResponse response,
JBOTransaction tx, Transaction sqlca, ReturnMapUtil ReturnMapUtil) throws Exception {
Map<String, Object> testMap = (Map<String, Object>) MultipartDataUtil
.readRequestParam(request, "UTF-8");
fieldMap = (Map<String, Object>) testMap.get("fieldMap");
String userId = fieldMap.get("userid") == null ? "" : fieldMap.get("userid").toString();
String sql = "";
sql = "SELECT O.FLOWNAME,O.ObjectType,O.PhaseType,O.ApplyType FROM FLOW_OBJECT O WHERE 1 = 1 AND O.ObjectType IN ('ProductDefaultObject','FlowDefaultObject') AND O.PhaseType='1010' AND O.ApplyType IN ('BusinessApplyApply','BContractChangeApply','BContractCancelApply','BContractApproveApply','BusinessChangeApply','BusinessCancelApply','MortgageFileMailApply','MortgageFileApply','FundPaymentCarApply') AND O.UserID='"+userId+"' GROUP BY O.ApplyType ";
List<Map<String, String>> dataList = DataOperatorUtil.getDataBySql(sql);
Map<String, Object> body = new HashMap<String, Object>();
body.put("datas", dataList);
ReturnMapUtil.setReturnMap(body,RestfullConstant.baseProperty.get("success").toString(), "");
return ReturnMapUtil.getReturnMap();
}
//获取业务未提交接口
@Override
public Map<String, Object> BusinessUncommitted(HttpServletRequest request, HttpServletResponse response,

View File

@ -551,6 +551,25 @@ public class ApplyChangeController {
}
}
//»ñÈ¡²éѯÁ÷³ÌÃû³Æ²éѯ
@Path("/business/refer")
@POST
public Map<String, Object> BusinessRefer(@Context HttpServletRequest request,
@Context HttpServletResponse response, @Context JBOTransaction tx,
@Context Transaction sqlca) throws Exception {
ReturnMapUtil ReturnMapUtil = new ReturnMapUtil(tx, sqlca);
ARE.getLog().info(
"[CONTROLLER] ApplyChangeController run .................");
ARE.getLog().info("[Path] /change/Business/refer" + " run .................");
ApplyArchiveService service = new ApplyArchiveServiceImpl();
try {
return service.BusinessRefer(request, response, tx, sqlca, ReturnMapUtil);
} catch (Exception e) {
return ReturnMapUtil.rollback(e);
}
}
//获取业务未提交数据
@Path("/business/uncommitted")
@POST