//package com.zteits.pay.job.custcredit;
//
//
//import org.apache.commons.collections4.CollectionUtils;
//import com.alibaba.fastjson.JSONObject;
//import com.clouds.common.cache.pay.CustUserCreditCacheUtil;
//import com.clouds.common.constants.ExamineStateEnum;
//import com.clouds.common.utils.ResultUtils;
//import com.xxl.job.core.biz.model.ReturnT;
//import com.xxl.job.core.handler.IJobHandler;
//import com.xxl.job.core.handler.annotation.JobHander;
//import com.xxl.job.core.log.XxlJobLogger;
//import com.zteits.clouds.api.apibase.bean.BizResult;
//import com.zteits.clouds.api.apibase.constants.BasicEnum;
//import com.zteits.clouds.api.dto.pay.dto.CustPersonCreditDTO;
//import com.zteits.clouds.api.dto.pay.dto.CustPersonCreditWebserviceDTO;
//import com.zteits.clouds.api.dto.pay.param.CustPersonCreditRequest;
//import com.zteits.clouds.api.service.pay.CustPersonCreditService;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.beans.BeanUtils;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//import java.util.Date;
//import java.util.List;
//
///**
// * 用户信用积分更新
// * Copyright: Copyright (c) 2017  zteits
// *
// * @ClassName: CustCerDitDicJob.java
// * @Description:
// * @version: v1.0.0
// * @author: wb
// * @date: 2022年4月28日   下午2:53:38
// * Modification History:
// * Date         Author          Version      Description
// * ---------------------------------------------------------*
// */
//@JobHander(value="CustCreDitDicJob")
//@Component
//public class CustCreDitDicJob extends IJobHandler{
//    private static final Logger logger = LoggerFactory.getLogger(CustCreDitDicJob.class);
//    @Autowired
//    private CustPersonCreditService custPersonCreditService;
//
//    @Override
//    public ReturnT<String> execute(String... params) throws Exception {
//
//        this.logger("---begin开始更新用户信用积分：");
//        CustPersonCreditRequest request = new CustPersonCreditRequest();
//        request.setSysCode(BasicEnum.SYS_CODE.getValue());
//
//        BizResult<List<CustPersonCreditDTO>> rsList = custPersonCreditService.queryCustPersonCredit(request);
//        this.logger("本次查询需要更新等级条数=" +(CollectionUtils.isNotEmpty(rsList.getData())));
//        if(rsList.isSuccess() && rsList.getData()!=null && CollectionUtils.isNotEmpty(rsList.getData())) {
//            int index = 1;
//            for(CustPersonCreditDTO dto :rsList.getData()) {
//                this.logger("begin开始处理第"+(index++)+"条信息="+JSONObject.toJSON(dto));
//                if(dto == null ||  !dto.getExamineState().equals(ExamineStateEnum.ReviewPass.getValue())){
//                    this.logger("未审核通过的不更新信用积分！"+dto.getCustId());
//                    continue;
//                }
//                CustPersonCreditRequest custPersonCreditRequest = new CustPersonCreditRequest();
//                BeanUtils.copyProperties(dto,custPersonCreditRequest);
//                custPersonCreditRequest.setCustName(dto.getCustName());
//                custPersonCreditRequest.setCerNumber(dto.getCerNumber());
//                custPersonCreditRequest.setSysCode(BasicEnum.SYS_CODE.getValue());
//
////                BizResult<CustPersonCreditWebserviceDTO> userCreditFromWebservice = custPersonCreditService.getUserCreditFromWebservice(custPersonCreditRequest);
////                CustPersonCreditWebserviceDTO webserviceDTO = ResultUtils.getBizResultData(userCreditFromWebservice);
////                this.logger("webservice获取到的信用积分："+JSONObject.toJSON(webserviceDTO));
////                if(webserviceDTO!=null){
////                    CustPersonCreditWebserviceDTO.Data dtoData = webserviceDTO.getData();
////                    dto.setCreditScore(Integer.parseInt(dtoData.getPdfs()));
////                    dto.setCreditRating(dtoData.getPddj());
////                    dto.setCreditDic(CustUserCreditCacheUtil.getCreditDic(dtoData.getPddj()));
////                    dto.setModfiyDate(new Date());
////                }
//                Integer creditDic = CustUserCreditCacheUtil.getCreditDic(dto.getCreditRating());
//                this.logger(dto.getCustId()+" 获取等级："+creditDic);
//
//                if(creditDic !=null){
//                    custPersonCreditRequest.setCreditDic(creditDic);
//                    dto.setCreditDic(creditDic);
//                }else {
//                    custPersonCreditRequest.setCreditDic(100);
//                    dto.setCreditDic(100);
//                }
//                BizResult<Boolean> booleanBizResult = custPersonCreditService.updateByPrimaryKeySelective(custPersonCreditRequest);
//                if(booleanBizResult.getData()){
//                    CustUserCreditCacheUtil.setUserCredit(dto);
//                }
//            }
//        }
//        return ReturnT.SUCCESS;
//    }
//
//
//    private void logger(String msg){
//        XxlJobLogger.log(msg);
//        logger.info(msg);
//    }
//}