From 98da3c49584b4cd0bd69f3eb67fbfca2851252ba Mon Sep 17 00:00:00 2001 From: wangzhikun Date: Wed, 5 Apr 2023 13:33:33 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8B=89=E5=8F=96sap=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E5=BC=80=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/dxhy/core/dao/ConfirmDao.java | 2 + .../com/dxhy/core/task/PullSapDataTask.java | 85 +++++++++++++++++++ .../src/main/resources/mapper/ConfirmDao.xml | 7 ++ .../service/impl/InvoiceAuthServiceImpl.java | 4 +- .../controller/VouncherSyncController.java | 6 ++ 5 files changed, 102 insertions(+), 2 deletions(-) create mode 100644 dxhy-core/src/main/java/com/dxhy/core/task/PullSapDataTask.java diff --git a/dxhy-core/src/main/java/com/dxhy/core/dao/ConfirmDao.java b/dxhy-core/src/main/java/com/dxhy/core/dao/ConfirmDao.java index 92460a6c..142bd1c5 100644 --- a/dxhy-core/src/main/java/com/dxhy/core/dao/ConfirmDao.java +++ b/dxhy-core/src/main/java/com/dxhy/core/dao/ConfirmDao.java @@ -475,4 +475,6 @@ public interface ConfirmDao extends BaseMapper { List getHttpLog(); String selectByuuid(@Param("uuid")String uuid); + + List getPullSapDataTaxNo(); } diff --git a/dxhy-core/src/main/java/com/dxhy/core/task/PullSapDataTask.java b/dxhy-core/src/main/java/com/dxhy/core/task/PullSapDataTask.java new file mode 100644 index 00000000..4efc0afe --- /dev/null +++ b/dxhy-core/src/main/java/com/dxhy/core/task/PullSapDataTask.java @@ -0,0 +1,85 @@ +package com.dxhy.core.task; + +import com.alibaba.fastjson.JSONObject; +import com.dxhy.common.constant.DbConstant; +import com.dxhy.common.datasource.config.DynamicContextHolder; +import com.dxhy.core.dao.ConfirmDao; +import com.dxhy.core.job.entity.SNSAPObject; +import com.dxhy.core.job.entity.ScheduleJobEntity; +import com.dxhy.core.job.entity.TAcOrg; +import com.dxhy.core.job.service.ApplyService; +import com.dxhy.core.job.service.ScheduleJobService; +import com.dxhy.core.job.service.SysDeptService; +import com.dxhy.core.util.HttpRequestUtils; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.text.DateFormat; +import java.text.SimpleDateFormat; +import java.util.*; + +/** + * 申请统计，统计结果，申请确认，确认结果定时任务 + * + * @author fth + * @date 2019年05月28日 + **/ +@Component("pullSapData") +@Slf4j + +public class PullSapDataTask { + @Resource + private ApplyService applyService; + @Resource + ScheduleJobService scheduleJobService; + @Resource + SysDeptService sysDeptService; + @Resource + ConfirmDao confirmDao; + @Value("${sdny.snYxUrl}") + private String snYxUrl; + @Value("${po.userName}") + private String userName; + + @Value("${po.password}") + private String password; + + public void applyStat() { + log.info("拉取sap数据获取"); + //获取当前年月 + Date date = new Date(); + SimpleDateFormat format = new SimpleDateFormat("yyyyMM"); + String format1 = format.format(date); + String year = format1.substring(0, 4); + String month = format1.substring(4, 6); + + //获取公司代码 + List taxNos=confirmDao.getPullSapDataTaxNo(); + for(TAcOrg tAcOrg:taxNos){ + SNSAPObject object = new SNSAPObject(); + object.setSYSID("FPXT"); + object.setIFYWID("FI842"); + object.setBSKEY(UUID.randomUUID().toString().replace("-", "")); + object.setZFILED5("200"); + Map requestMap = new HashMap<>(); + //公司代码 + requestMap.put("ZGSDM",tAcOrg.getAccount()); + //年 + requestMap.put("GJAHR",year); + //月 + requestMap.put("MONAT",month); + object.setZDATA(JSONObject.toJSONString(requestMap)); + JSONObject request = new JSONObject(); + request.put("IS_INPUT",object); + String req = request.toJSONString(); + log.info("税号:{},发送获取sap数据{}",tAcOrg.getTaxno(),req); + String s = HttpRequestUtils.sendPo(snYxUrl, req, userName, password); + log.info("税号:{},拉去sap接口返回数据{}",tAcOrg.getTaxno(),s); + } + + } + + +} diff --git a/dxhy-core/src/main/resources/mapper/ConfirmDao.xml b/dxhy-core/src/main/resources/mapper/ConfirmDao.xml index e4e8544b..d1a05e55 100644 --- a/dxhy-core/src/main/resources/mapper/ConfirmDao.xml +++ b/dxhy-core/src/main/resources/mapper/ConfirmDao.xml @@ -18,6 +18,13 @@ and g.cj_status = '1' +