contentmanagementservices.java

Sequoia ERP是一个真正的企业级开源ERP解决方案。它提供的模块包括：电子商务应用(e-commerce), POS系统(point of sales),知识管理,存货与仓库管理

                      permResults = dispatcher.runSync("createContentRole", serviceContext);
                      String errMsg = ServiceUtil.getErrorMessage(permResults);
                      if (UtilValidate.isNotEmpty(errMsg)) 
                        return ServiceUtil.returnError(errMsg);
                      //addRoleToUser(delegator, dispatcher, serviceContext);
                  } catch (GenericServiceException e) {
                      Debug.logError(e, e.getMessage(), module);
                      return ServiceUtil.returnError( e.getMessage());
                  } catch (Exception e2) {
                      Debug.logError(e2, e2.getMessage(), module);
                      return ServiceUtil.returnError( e2.getMessage());
                  }
              }
          } else {
              if (fromDate != null ) {
                      // for now, will assume that any error is due to non-existence - ignore
                      //return ServiceUtil.returnError(e.getMessage());
                  try {
Debug.logInfo("updateSiteRoles, serviceContext(2):" + serviceContext, module);
                      //Timestamp thruDate = UtilDateTime.nowTimestamp();
                      //serviceContext.put("thruDate", thruDate);
                      //serviceContext.put("fromDate", fromDate);
                      Map newContext = new HashMap();
                      newContext.put("contentId", serviceContext.get("contentId"));
                      newContext.put("partyId", serviceContext.get("partyId"));
                      newContext.put("roleTypeId", serviceContext.get("roleTypeId"));
                      newContext.put("userLogin", userLogin);
                      Map permResults = dispatcher.runSync("deactivateAllContentRoles", newContext);
                      String errMsg = ServiceUtil.getErrorMessage(permResults);
                      if (UtilValidate.isNotEmpty(errMsg)) 
                        return ServiceUtil.returnError(errMsg);
                  } catch (GenericServiceException e) {
                      Debug.logError(e, e.getMessage(), module);
                      return ServiceUtil.returnError( e.getMessage());
                  } catch (Exception e2) {
                      Debug.logError(e2, e2.getMessage(), module);
                      return ServiceUtil.returnError( e2.getMessage());
                  }
              }
          }
      }
      return results;
  }
  
    public static Map persistDataResourceAndData(DispatchContext dctx, Map context) {
      //GenericDelegator delegator = dctx.getDelegator();
      LocalDispatcher dispatcher = dctx.getDispatcher();
      //String contentId = (String)context.get("contentId");
      Map result = new HashMap();
      try {
          //GenericValue content = delegator.findByPrimaryKey("Content", UtilMisc.toMap("contentId", contentId));
          ModelService checkPermModel = dispatcher.getDispatchContext().getModelService("checkContentPermission");
          Map ctx = checkPermModel.makeValid(context, "IN");
          Map thisResult = dispatcher.runSync("checkContentPermission", ctx);
          String permissionStatus = (String)thisResult.get("permissionStatus");
          if (UtilValidate.isNotEmpty(permissionStatus) && permissionStatus.equalsIgnoreCase("granted")) {
              result = persistDataResourceAndDataMethod(dctx, context);
          }
      } catch (GenericServiceException e) {
          return ServiceUtil.returnError(e.getMessage());
      } catch (GenericEntityException e) {
          return ServiceUtil.returnError(e.getMessage());
      } catch (Exception e) {
          return ServiceUtil.returnError(e.getMessage());
      }
      String errorMsg = ServiceUtil.getErrorMessage(result);
      if (UtilValidate.isNotEmpty(errorMsg)) {
          return ServiceUtil.returnError(errorMsg);
      }
      return result;
    }
  
    public static Map persistDataResourceAndDataMethod(DispatchContext dctx, Map context) throws GenericServiceException, GenericEntityException, Exception {
      GenericDelegator delegator = dctx.getDelegator();
      LocalDispatcher dispatcher = dctx.getDispatcher();
      Map result = new HashMap();
      Map newDrContext = new HashMap();
      GenericValue dataResource = delegator.makeValue("DataResource", null);
      dataResource.setPKFields(context);
      dataResource.setNonPKFields(context);
      dataResource.setAllFields(context, false, "dr", null);
      context.putAll(dataResource);
      
      GenericValue electronicText = delegator.makeValue("ElectronicText", null);
      electronicText.setPKFields(context);
      electronicText.setNonPKFields(context);
      String textData = (String)electronicText.get("textData");

      
      String dataResourceId = (String)dataResource.get("dataResourceId");
      String dataResourceTypeId = (String)dataResource.get("dataResourceTypeId");
      if (Debug.infoOn()) Debug.logInfo("in persist... dataResourceId(0):" + dataResourceId, null);
      context.put("skipPermissionCheck", "granted"); // TODO: a temp hack because I don't want to bother with DataResource permissions at this time.
      boolean dataResourceExists = true;
      if (UtilValidate.isEmpty(dataResourceId)) {
          dataResourceExists = false;
      } else {
          try {
              GenericValue val = delegator.findByPrimaryKey("DataResource", UtilMisc.toMap("dataResourceId", dataResourceId));
              if (val == null)
                  dataResourceExists = false;
          } catch(GenericEntityException e) {
              return ServiceUtil.returnError(e.getMessage());
          }
      }
      GenericValue userLogin = (GenericValue) context.get("userLogin"); 
      //String userLoginId = (String)userLogin.get("userLoginId");
      ModelService dataResourceModel = dispatcher.getDispatchContext().getModelService("updateDataResource");
      Map ctx = dataResourceModel.makeValid(dataResource, "IN");
      newDrContext.putAll(ctx);
      newDrContext.put("userLogin", userLogin);
      newDrContext.put("skipPermissionCheck", context.get("skipPermissionCheck"));
      ByteWrapper byteWrapper = (ByteWrapper)context.get("imageData");
      String mimeTypeId = (String) newDrContext.get("mimeTypeId");
      if (byteWrapper != null && (mimeTypeId == null || (mimeTypeId.indexOf("image") >= 0) || (mimeTypeId.indexOf("application") >= 0))) {
          mimeTypeId = (String) context.get("_imageData_contentType");
          String fileName = (String) context.get("_imageData_fileName");
          newDrContext.put("objectInfo", fileName);
          newDrContext.put("mimeTypeId", mimeTypeId);
      }
      
      if (!dataResourceExists) {
          Map thisResult = dispatcher.runSync("createDataResource", newDrContext);
      String errorMsg = ServiceUtil.getErrorMessage(thisResult);
      if (UtilValidate.isNotEmpty(errorMsg)) {
          throw(new Exception(errorMsg));
      }
      dataResourceId = (String)thisResult.get("dataResourceId");
      if (Debug.infoOn()) Debug.logInfo("in persist... dataResourceId(0):" + dataResourceId, null);
      dataResource = (GenericValue)thisResult.get("dataResource");
      Map fileContext = new HashMap();
      fileContext.put("userLogin", userLogin);
      if ( dataResourceTypeId.indexOf("_FILE") >=0) {
          boolean hasData = false;
          if (textData != null) {
              fileContext.put("textData", textData);
              hasData = true;
          }
          if (byteWrapper != null) {
              fileContext.put("binData", byteWrapper);
              hasData = true;
          }
          if (hasData) {
              fileContext.put("rootDir", context.get("rootDir"));
              fileContext.put("dataResourceTypeId", dataResourceTypeId);
              fileContext.put("objectInfo", dataResource.get("objectInfo"));
              thisResult = dispatcher.runSync("createFile", fileContext);
              errorMsg = ServiceUtil.getErrorMessage(thisResult);
              if (UtilValidate.isNotEmpty(errorMsg)) {
                  return ServiceUtil.returnError(errorMsg);
              }
          }
      } else if (dataResourceTypeId.equals("IMAGE_OBJECT")) {
          if (byteWrapper != null) {
              fileContext.put("dataResourceId", dataResourceId);
              fileContext.put("imageData", byteWrapper);
              thisResult = dispatcher.runSync("createImage", fileContext);
              errorMsg = ServiceUtil.getErrorMessage(thisResult);
              if (UtilValidate.isNotEmpty(errorMsg)) {
                  return ServiceUtil.returnError(errorMsg);
              }
          } else {
              //return ServiceUtil.returnError("'byteWrapper' empty when trying to create database image.");
          }
      } else if (dataResourceTypeId.equals("SHORT_TEXT")) {
      } else if (dataResourceTypeId.startsWith("SURVEY")) {
      } else {
          // assume ELECTRONIC_TEXT
          if (UtilValidate.isNotEmpty(textData)) {
              fileContext.put("dataResourceId", dataResourceId);
              fileContext.put("textData", textData);
              thisResult = dispatcher.runSync("createElectronicText", fileContext);
              errorMsg = ServiceUtil.getErrorMessage(thisResult);
              if (UtilValidate.isNotEmpty(errorMsg)) {
                  return ServiceUtil.returnError(errorMsg);
              }
          }
      }
    } else {
      Map thisResult = dispatcher.runSync("updateDataResource", newDrContext);
      String errorMsg = ServiceUtil.getErrorMessage(thisResult);
      if (UtilValidate.isNotEmpty(errorMsg)) {
          return ServiceUtil.returnError(errorMsg);
      }
      //Map thisResult = DataServices.updateDataResourceMethod(dctx, context);
      if (Debug.infoOn()) Debug.logInfo("in persist... thisResult.permissionStatus(0):" + thisResult.get("permissionStatus"), null);
          //thisResult = DataServices.updateElectronicTextMethod(dctx, context);
      Map fileContext = new HashMap();
      fileContext.put("userLogin", userLogin);
      String forceElectronicText = (String)context.get("forceElectronicText");
      if (dataResourceTypeId.indexOf("_FILE") >=0) {
          boolean hasData = false;
          if (textData != null) {
              fileContext.put("textData", textData);
              hasData = true;
          }
          if (byteWrapper != null) {
              fileContext.put("binData", byteWrapper);
              hasData = true;
          }
          if (hasData || "true".equalsIgnoreCase(forceElectronicText)) {
              fileContext.put("rootDir", context.get("rootDir"));
              fileContext.put("dataResourcetype", dataResourceTypeId);
              fileContext.put("objectInfo", dataResource.get("objectInfo"));
              thisResult = dispatcher.runSync("updateFile", fileContext);
              errorMsg = ServiceUtil.getErrorMessage(thisResult);
              if (UtilValidate.isNotEmpty(errorMsg)) {
                  return ServiceUtil.returnError(errorMsg);
              }
          }
      } else if (dataResourceTypeId.equals("IMAGE_OBJECT")) {
          if (byteWrapper != null || "true".equalsIgnoreCase(forceElectronicText)) {
              fileContext.put("dataResourceId", dataResourceId);
              fileContext.put("imageData", byteWrapper);
              thisResult = dispatcher.runSync("updateImage", fileContext);
              errorMsg = ServiceUtil.getErrorMessage(thisResult);
              if (UtilValidate.isNotEmpty(errorMsg)) {
                  return ServiceUtil.returnError(errorMsg);
              }
          } else {
              //return ServiceUtil.returnError("'byteWrapper' empty when trying to create database image.");
          }
      } else if (dataResourceTypeId.equals("SHORT_TEXT")) {
      } else if (dataResourceTypeId.startsWith("SURVEY")) {
      } else {
          if (UtilValidate.isNotEmpty(textData) || "true".equalsIgnoreCase(forceElectronicText)) {
              fileContext.put("dataResourceId", dataResourceId);
              fileContext.put("textData", textData);
              thisResult = dispatcher.runSync("updateElectronicText", fileContext);
              errorMsg = ServiceUtil.getErrorMessage(thisResult);
              if (UtilValidate.isNotEmpty(errorMsg)) {
                  return ServiceUtil.returnError(errorMsg);
              }
          }
      }
    }
    
    result.put("dataResourceId", dataResourceId);
    result.put("drDataResourceId", dataResourceId);
    context.put("dataResourceId", dataResourceId);
    return result;
  }
  
    public static void addRoleToUser(GenericDelegator delegator, LocalDispatcher dispatcher, Map serviceContext) throws GenericServiceException, GenericEntityException {
    String partyId = (String)serviceContext.get("partyId");
    Map findMap = UtilMisc.toMap("partyId", partyId);
        List userLoginList = delegator.findByAnd("UserLogin", findMap);
        Iterator iter = userLoginList.iterator();
        while (iter.hasNext()) {
            GenericValue partyUserLogin = (GenericValue)iter.next();
            String partyUserLoginId = partyUserLogin.getString("userLoginId");
            serviceContext.put("contentId", partyUserLoginId); // author contentId
            dispatcher.runSync("createContentRole", serviceContext);
        }
}