【sap-cap】

初始化工程

• nodejs

cds init --add nodejs incident-management

• java

cds init --add java incident-management
npm install

启动

• nodejs

cds watch

• java 使用如下

mvn cds:watch

model

进入db目录下schema.cds

using{cuid, managed, sap.common.CodeList}from'@sap/cds/common';namespace sap.capire.incidents;/** * Incidents created by Customers. */ entity Incidents:cuid, managed{customer:Association to Customers;title:String @title:'Title';urgency:Association to Urgency default'M';status:Association to Status default'N';conversation:Composition of many{key ID:UUID;timestamp:typeof managed:createdAt;author:typeof managed:createdBy;message:String;};}/** * Customers entitled to create support Incidents. */ entity Customers:managed{key ID:String;firstName:String;lastName:String;name:String=trim(firstName||' '||lastName);email:EMailAddress;phone:PhoneNumber;incidents:Association to many Incidents on incidents.customer=$self;creditCardNo:String(16)@assert.format:'^[1-9]\d{15}$';addresses:Composition of many Addresses on addresses.customer=$self;}entity Addresses:cuid, managed{customer:Association to Customers;city:String;postCode:String;streetAddress:String;}entity Status:CodeList{key code:String enum{new='N';assigned='A';in_process='I';on_hold='H';resolved='R';closed='C';};criticality:Integer;}entity Urgency:CodeList{key code:String enum{high='H';medium='M';low='L';};}typeEMailAddress:String;typePhoneNumber:String;

服务

进入srv下的 services.cds文件

using{sap.capire.incidents as my}from'../db/schema';/** * Service used by support personell, i.e. the incidents' 'processors'. */serviceProcessorService{entity Incidents as projection on my.Incidents;@readonly entity Customers as projection on my.Customers;}/** * Service used by administrators to manage customers and incidents. */serviceAdminService{entity Customers as projection on my.Customers;entity Incidents as projection on my.Incidents;}

初始数据

cds add data

文件如下：

• db/data/sap.capire.incidents-Addresses.csv
• db/data/sap.capire.incidents-Customers.csv
• db/data/sap.capire.incidents-Incidents.csv
• db/data/sap.capire.incidents-Incidents.conversation.csv
• db/data/sap.capire.incidents-Status.csv
• db/data/sap.capire.incidents-Status.texts.csv
• db/data/sap.capire.incidents-Urgency.csv
• db/data/sap.capire.incidents-Urgency.texts.csv

server.js

• java

package customer.incident_management.handler;importcds.gen.processorservice.Incidents;importcds.gen.processorservice.ProcessorService_;importcds.gen.sap.capire.incidents.*;importcom.sap.cds.ql.Select;importcom.sap.cds.services.ErrorStatuses;importcom.sap.cds.services.ServiceException;importcom.sap.cds.services.cds.CqnService;importcom.sap.cds.services.handler.EventHandler;importcom.sap.cds.services.handler.annotations.Before;importcom.sap.cds.services.handler.annotations.ServiceName;importcom.sap.cds.services.persistence.PersistenceService;importorg.slf4j.Logger;importorg.slf4j.LoggerFactory;importorg.springframework.stereotype.Component;importjava.util.List;importjava.util.Locale;@Component @ServiceName(ProcessorService_.CDS_NAME)public class ProcessorServiceHandler implements EventHandler{private static final Logger logger=LoggerFactory.getLogger(ProcessorServiceHandler.class);private final PersistenceService db;public ProcessorServiceHandler(PersistenceService db){this.db=db;}/* * Change the urgency of an incident to"high"ifthe title contains the word"urgent"*/ @Before(event=CqnService.EVENT_CREATE)public void ensureHighUrgencyForIncidentsWithUrgentInTitle(List<Incidents>incidents){for(Incidents incident:incidents){if(incident.getTitle().toLowerCase(Locale.ENGLISH).contains("urgent")&&incident.getUrgencyCode()==null||!incident.getUrgencyCode().equals("H")){incident.setUrgencyCode("H");logger.info("Adjusted Urgency for incident '{}' to 'HIGH'.", incident.getTitle());}}}/* * Handler to avoid updating a"closed"incident */ @Before(event=CqnService.EVENT_UPDATE)public void ensureNoUpdateOnClosedIncidents(Incidents incident){Incidentsin=db.run(Select.from(Incidents_.class).where(i ->i.ID().eq(incident.getId()))).single(Incidents.class);if(in.getStatusCode().equals("C")){throw new ServiceException(ErrorStatuses.CONFLICT,"Can't modify a closed incident");}}}

• nodejs

const cds=require('@sap/cds')class ProcessorService extends cds.ApplicationService{/** Registering custom event handlers */init(){this.before("UPDATE","Incidents",(req)=>this.onUpdate(req));this.before("CREATE","Incidents",(req)=>this.changeUrgencyDueToSubject(req.data));returnsuper.init();}changeUrgencyDueToSubject(data){leturgent=data.title?.match(/urgent/i)if(urgent)data.urgency_code='H'}/** Custom Validation */ async onUpdate(req){letclosed=await SELECT.one(1).from(req.subject).where`status.code='C'`if(closed)req.reject`Can't modify a closed incident!`}}module.exports={ProcessorService}