jiuzhoutong/websrc/com/kingdee/eas/custom/compensation/service/SynIncomeTaxDeclareService.java

package com.kingdee.eas.custom.compensation.service;

import cn.com.servyou.dto.ApiResponse;
import cn.com.servyou.dto.declare.Feedback;
import cn.com.servyou.rmi.client.ClientProxyFactory;
import cn.com.servyou.service.DeclarationRequest;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.kingdee.bos.BOSException;
import com.kingdee.bos.Context;
import com.kingdee.bos.bsf.service.app.IHRMsfService;
import com.kingdee.eas.common.EASBizException;
import com.kingdee.eas.custom.shuiyou.interfacelog.LogInfoFactory;
import com.kingdee.eas.custom.shuiyou.interfacelog.LogInfoInfo;
import com.kingdee.eas.custom.shuiyou.task.MessageResult;
import com.kingdee.eas.custom.shuiyou.utils.ClientProxyFactoryUtils;
import org.apache.log4j.Logger;

import java.io.IOException;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * @author qingwu
 * @date 2024/9/19
 * @apiNote
 */
public class SynIncomeTaxDeclareService implements IHRMsfService {
    Logger logger = Logger.getLogger("com.kingdee.eas.custom.compensation.service.SynIncomeTaxDeclareService");

    public Object process(Context context, Map map) throws EASBizException, BOSException {
        //接口日志实体
        LogInfoInfo logInfo = new LogInfoInfo();
        //入口
        logInfo.setEntrance(this.getClass().getName());
        logInfo.setBizDate(new Date());
        Map resMap = new HashMap();
        logger.error("SynIncomeTaxDeclareService----------OSF----Start");
        JSONObject paramData = JSONObject.parseObject((String) map.get("paramData"));
        logger.error("paramData--------" + paramData);
        String requestId = paramData.getString("requestId");
        //JSONObject param = paramData.getJSONObject("param");
        logger.error("requestId--------" + requestId);
        //logger.error("param--------" + param);
        ObjectMapper mapper = new ObjectMapper();
        try {
            //客户端代理工厂
            ClientProxyFactory clientProxyFactory = ClientProxyFactoryUtils.getClientProxyFactory();
            //算税请求接口
            DeclarationRequest declarationRequest = clientProxyFactory.getDeclarationRequest();
            //申报数据反馈  requestId：请求Id   reportType:申报所得类型[1:综合所得;2:分类所得;3:非居民所得;4:限售股所得]
            ApiResponse<Feedback> feedback = declarationRequest.getFeedback(requestId, "1");
            logInfo.setInterfaceAddress("/gateway/iit/report/getFeedback");//接口地址
            logInfo.setInterfaceName("getFeedback");//接口名
            logger.error("feedback--------" + mapper.writeValueAsString(feedback));
            String status = feedback.getHead().getStatus();
            Feedback body = null;
            if ("N".equals(status)) {
                //请求失败响应
                String msg = feedback.getHead().getMsg();
                //throw new BOSException(msg);
                return MessageResult.FAILED(msg);
            } else {
                //调用成功
                //请求id
                body = feedback.getBody();
                logInfo.setOutParameter(mapper.writeValueAsString(body));//回参
                LogInfoFactory.getLocalInstance(context).addnew(logInfo);
            }
            return MessageResult.SUCCESS(mapper.writeValueAsString(body));
        } catch (IOException e) {
            e.printStackTrace();
            logInfo.setErrorInfo(e.getMessage());//错误信息
            LogInfoFactory.getLocalInstance(context).save(logInfo);
            //throw new BOSException(e);
            return MessageResult.ERROR(e.getMessage());
        }
    }

}