From 5c9375a49771db97e53626c89f437ad9dce7b8bd Mon Sep 17 00:00:00 2001
From: 07 <15989082884@163.com>
Date: Wed, 5 Oct 2022 21:37:04 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
pom.xml | 141 ++++++++++++++++++
.../controller/U8CallBackController.java | 8 +-
.../module/service/VmSupplierService.java | 81 +++++-----
.../resources/mapper/VmSupplierMapper.xml | 4 +-
4 files changed, 191 insertions(+), 43 deletions(-)
create mode 100644 pom.xml
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..fbfbaf5
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,141 @@
+
+
+ 4.0.0
+
+
+ org.springframework.boot
+ spring-boot-starter-parent
+ 2.7.0
+
+
+
+ 1.0.0
+
+ JSL订单服务拓展
+ supplier-ext
+ JSL供应商服务拓展
+
+
+
+ true
+
+ 1.8
+
+ 8.0.28
+
+ 3.5.1
+
+ 1.2.79
+
+ 1.18.22
+
+ 2.13.0
+
+ 4.5.7
+ 3.1
+
+ 8
+ 8
+ 3.1.0
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ org.springframework.boot
+ spring-boot-starter-tomcat
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-undertow
+
+
+
+ org.springframework.boot
+ spring-boot-starter-validation
+
+
+
+
+
+
+
+
+ com.microsoft.sqlserver
+ mssql-jdbc
+ 8.4.1.jre8
+
+
+
+
+ com.baomidou
+ mybatis-plus-boot-starter
+ ${mybatis.plus.version}
+
+
+
+ com.alibaba
+ fastjson
+ ${fastjson.version}
+
+
+
+ org.apache.httpcomponents
+ httpclient
+ ${httpclient.version}
+ compile
+
+
+ commons-httpclient
+ commons-httpclient
+ ${commons-httpclient.version}
+
+
+
+ org.projectlombok
+ lombok
+ ${lombok.version}
+ provided
+
+
+
+ cn.hutool
+ hutool-all
+ 5.6.2
+
+
+
+ junit
+ junit
+ RELEASE
+ test
+
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+
+
diff --git a/src/main/java/com/qs/cost/module/controller/U8CallBackController.java b/src/main/java/com/qs/cost/module/controller/U8CallBackController.java
index 9d0b4f8..40cc715 100644
--- a/src/main/java/com/qs/cost/module/controller/U8CallBackController.java
+++ b/src/main/java/com/qs/cost/module/controller/U8CallBackController.java
@@ -7,6 +7,7 @@ import com.qs.cost.module.mapper.VmSupplierMapper;
import com.qs.cost.module.service.VmSupplierService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.web.bind.annotation.*;
/**
@@ -29,13 +30,14 @@ public class U8CallBackController {
String pk = requestVo.getApiPk();
//回调更新状态
log.info("回调更新状态,PK:{}",pk);
- //vmSupplierMapper.updateSupplierFormState(pk);
- String testValue = vmSupplierMapper.testSupplierFormState(pk);
- log.debug("testValue:{}",testValue);
+ vmSupplierMapper.updateSupplierFormState(pk);
+// String testValue = vmSupplierMapper.testSupplierFormState(pk);
+// log.debug("testValue:{}",testValue);
}
return R.ok();
}
+ @Scheduled(cron = "0 */30 * * * ?")
@GetMapping("/test")
public R callback(){
//String testValue = vmSupplierMapper.testSupplierFormState("202209280264");
diff --git a/src/main/java/com/qs/cost/module/service/VmSupplierService.java b/src/main/java/com/qs/cost/module/service/VmSupplierService.java
index 54c23e7..bcd4f63 100644
--- a/src/main/java/com/qs/cost/module/service/VmSupplierService.java
+++ b/src/main/java/com/qs/cost/module/service/VmSupplierService.java
@@ -31,44 +31,49 @@ public class VmSupplierService {
String book = mainServerProperties.getBook();
List supplierPoList = vmSupplierMapper.selectList(new QueryWrapper<>());
for (VmSupplierPo supplierPo : supplierPoList) {
- U8Vendor vendor = new U8Vendor();
- //编辑属性：A表新增，M表修改 string类型
- vendor.setEditprop("A");
- //vendor.setCVenCode(supplierPo.getCVenCode());
- vendor.setCVenCode("123");
- vendor.setCVenName(supplierPo.getCVenName());
- vendor.setCVenAbbName(supplierPo.getCVenAbbName());
- vendor.setCDCCode(supplierPo.getCDCCode());
- vendor.setCVcCode(supplierPo.getCVCCode());
- vendor.setCVenAddress(supplierPo.getCCusAddress());
- vendor.setCVenPerson(supplierPo.getCCusPerson());
- vendor.setCVenPhone(supplierPo.getCCusPhone());
- vendor.setCVenEmail(supplierPo.getCCusEmail());
- vendor.setCVenLPerson(supplierPo.getCCusPerson());
- vendor.setCVenFax("");
- vendor.setCTrade("");
- vendor.setCVenPostCode("");
- vendor.setCVenRegCode("");
- vendor.setCVenBank("");
- vendor.setCVenAccount("");
- vendor.setCVenBusinessNo("");
- vendor.setCVenEnAddr1("");
- vendor.setCVenEnName("");
- String jsonBody = JsonUtil.objectToJson(Arrays.asList(vendor));
- //发起U8服务中台
- U8RequestBo requestBo = new U8RequestBo();
- requestBo.setPk(supplierPo.getSerialNumber());
- requestBo.setCmd("BasicVendor");
- requestBo.setYear(year);
- requestBo.setBook(book);
- requestBo.setJsonBody(jsonBody);
- requestBo.setKeyId("");
- requestBo.setSettingRetryTimes(2);
- requestBo.setCallbackState("1");
- requestBo.setCallbackHost( host + "/u8/callback");
- requestBo.setLogindate("2020-12-30");
- HttpUtil.post(mainServerProperties.getU8url(),JsonUtil.objectToJson(requestBo));
- return;
+ try {
+ U8Vendor vendor = new U8Vendor();
+ //编辑属性：A表新增，M表修改 string类型
+ vendor.setEditprop("A");
+ vendor.setCVenCode(supplierPo.getCVenCode());
+// vendor.setCVenCode("123");
+ vendor.setCVenName(supplierPo.getCVenName());
+ vendor.setCVenAbbName(supplierPo.getCVenAbbName());
+ vendor.setCDCCode(supplierPo.getCDCCode());
+ // vendor.setCVcCode("101");
+ vendor.setCVcCode(supplierPo.getCVCCode());
+ vendor.setCVenAddress(supplierPo.getCCusAddress());
+ vendor.setCVenPerson(supplierPo.getCCusPerson());
+ vendor.setCVenPhone(supplierPo.getCCusPhone());
+ vendor.setCVenEmail(supplierPo.getCCusEmail());
+ vendor.setCVenLPerson(supplierPo.getCCusPerson());
+ vendor.setCVenFax("");
+ vendor.setCTrade("");
+ vendor.setCVenPostCode("");
+ vendor.setCVenRegCode("");
+ vendor.setCVenBank("");
+ vendor.setCVenAccount("");
+ vendor.setCVenBusinessNo("");
+ vendor.setCVenEnAddr1("");
+ vendor.setCVenEnName("");
+ String jsonBody = JsonUtil.objectToJson(Arrays.asList(vendor));
+ //发起U8服务中台
+ U8RequestBo requestBo = new U8RequestBo();
+ requestBo.setPk(supplierPo.getSerialNumber());
+ requestBo.setCmd("BasicVendor");
+ requestBo.setYear(year);
+ requestBo.setBook(book);
+ requestBo.setJsonBody(jsonBody);
+ requestBo.setKeyId("");
+ requestBo.setSettingRetryTimes(1);
+ requestBo.setCallbackState("1");
+ requestBo.setCallbackHost( host + "/u8/callback");
+ requestBo.setLogindate("2020-12-30");
+
+ HttpUtil.post(mainServerProperties.getU8url(), JsonUtil.objectToJson(requestBo));
+ }catch (Exception e){
+ e.printStackTrace();
+ }
}
}
diff --git a/src/main/resources/mapper/VmSupplierMapper.xml b/src/main/resources/mapper/VmSupplierMapper.xml
index 90b1c46..d1b431e 100644
--- a/src/main/resources/mapper/VmSupplierMapper.xml
+++ b/src/main/resources/mapper/VmSupplierMapper.xml
@@ -7,12 +7,12 @@
update f1
set f1.field0004 = 1,f1.field0005 = GETDATE()
- from [OAdata].[dbo].formmain_1681 f1
+ from formmain_1681 f1
where f1.field0001 = #{serialNumber}