package com.sysware.cloud.dts.annotation;import java.lang.annotation.*;

@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
@Inherited
@Documented
public @interface DtTransactional {/** Whether need to rollback*/public boolean includeLocalTransaction() default true;public boolean confirmMethodExist() default false;/** Allow [confirmMethod] is null if [confirmMethodExist] is false*/public String confirmMethod() default "";public String cancelMethod() default "";}

• ElementType.TYPE //类、接口、枚举
• ElementType.FIELD //属性
• ElementType.METHOD //方法
• ElementType.PARAMETER //参数
• ElementType.CONSTRUCTOR //构造器
• ElementType.LOCAL_VARIABLE //局部变量
• ElementType.ANNOTATION_TYPE //注解
• ElementType.PACKAGE //包

package com.sysware.cloud.dts.service.impl;import com.sysware.cloud.commons.util.idwork.LongIdGenerator;
import com.sysware.cloud.dts.annotation.DtTransactional;
import com.sysware.cloud.dts.entity.PointEntity;
import com.sysware.cloud.dts.repository.PointRepository;
import com.sysware.cloud.dts.service.PointService;
import com.sysware.cloud.po.CriteriaQuery;
import com.sysware.cloud.service.impl.BaseServiceImpl;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;import java.util.List;
import java.util.concurrent.CancellationException;

@Service
public class PointServiceImpl extends BaseServiceImpl<PointEntity,PointRepository,Long> implements PointService {@Override@Transactional@DtTransactional(cancelMethod = "cancel")public PointEntity add(PointEntity entity) {//根据用户ID查询是否积分记录，没有则生成积分，有的话，则修改添加积分PointEntity pointEntity = super.repository.findPointEntitiesByUserId(entity.getUserId());if(pointEntity==null){entity.setId((LongIdGenerator.getId()));return super.repository.save(entity);}else {pointEntity.setPoint(pointEntity.getPoint()+entity.getPoint());return super.repository.save(pointEntity);}}public PointEntity cancel(PointEntity entity) {PointEntity pointEntity = super.repository.findPointEntitiesByUserId(entity.getUserId());if (pointEntity != null) {pointEntity.setPoint(pointEntity.getPoint() - entity.getPoint());return super.repository.save(pointEntity);}return null;}
}