BaseService.java 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
  1. package com.jkcredit.invoice.hub.service.base;
  2. import com.alibaba.fastjson.JSON;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.baidu.unbiz.fluentvalidator.FluentValidator;
  5. import com.baidu.unbiz.fluentvalidator.Result;
  6. import com.baidu.unbiz.fluentvalidator.jsr303.HibernateSupportedValidator;
  7. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  8. import com.baomidou.mybatisplus.extension.service.IService;
  9. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  10. import com.jkcredit.invoice.hub.constant.CommonConstant;
  11. import com.jkcredit.invoice.hub.enums.ApiResponseCodeEnum;
  12. import com.jkcredit.invoice.hub.spi.rest.data.ApiResponseData;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.hibernate.service.spi.ServiceException;
  15. import org.springframework.beans.factory.annotation.Autowired;
  16. import javax.validation.Validator;
  17. import static com.baidu.unbiz.fluentvalidator.ResultCollectors.toSimple;
  18. /**
  19. * @description:
  20. * @author: xusonglin
  21. * @create: 2019/12/29 20:55
  22. * @version: V1.0
  23. **/
  24. @Slf4j
  25. public class BaseService {
  26. @Autowired
  27. private Validator validator;
  28. protected <T> void validate(T fb) {
  29. Result result = FluentValidator.checkAll()
  30. .on(fb, new HibernateSupportedValidator<T>().setHiberanteValidator(validator))
  31. .doValidate()
  32. .result(toSimple());
  33. if (!result.isSuccess()) {
  34. throw new ServiceException(result.getErrors().toString());
  35. }
  36. }
  37. protected ApiResponseData analyzeApiResult(String result) {
  38. try {
  39. JSONObject jsonObject = JSON.parseObject(result);
  40. String item = jsonObject.getString("items");
  41. return ApiResponseData.success(ApiResponseCodeEnum.CODE_200.getValue(), item);
  42. } catch (Exception e) {
  43. log.info("[-companyQuery-] 解析异常:" + e.getMessage());
  44. throw new com.jkcredit.invoice.hub.spi.lang.exception.ServiceException(CommonConstant.QUERY_FAILED);
  45. }
  46. }
  47. }