优化了部分内容

This commit is contained in:
itzhang 2025-06-26 20:52:12 +08:00
parent 3b124aafa9
commit ea0cc44817
4 changed files with 261 additions and 13 deletions

View File

@ -218,12 +218,13 @@ public class GoodsPlanController {
log.info("要货计划明细存在,继续向下执行");
//延时执行非阻塞
ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
executor.schedule(() -> {
System.out.println("延时任务执行");
}, 10, TimeUnit.SECONDS); //10秒后执行
executor.shutdown(); // 关闭线程池
try {
System.out.println("暂停3秒");
Thread.sleep(3000);//单位毫秒
System.out.println("继续执行");
} catch (InterruptedException e) {
e.printStackTrace();//处理中断异常
}
//明细列表
List goodsPlanDetailList = new ArrayList<>();

View File

@ -0,0 +1,234 @@
package com.management.controller;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.management.constant.ERPURLConstant;
import com.management.constant.URLConstant;
import com.management.entity.Filter;
import com.management.utils.CrmRequestUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestClientException;
import org.springframework.web.client.RestTemplate;
import java.util.*;
@RestController
@RequestMapping("/api/vendor")
@Slf4j
public class VendorController {
private RestTemplate restTemplate = new RestTemplate();
public static void main(String[] args) {
new VendorController().syncVendor();
}
/**
* 供应商信息同步
*
* @return void
* @Author weiloong_zhang
*/
@PostMapping("/sync/create_vendor")
public void syncVendor() {
CrmRequestUtil crmRequestUtil = new CrmRequestUtil();
JSONObject getVendor = crmRequestUtil.getCRMList(Arrays.asList(
new Filter("EQ", "life_status", Arrays.asList("normal")),
new Filter("EQ", "name", Arrays.asList("山东研了究的僧教育科技有限公司")),
new Filter("EQ", "sync_status__c", Arrays.asList("option_pending_sync__c"))
), "SupplierObj");
JSONObject vendorRes = new JSONObject();
try {
vendorRes = restTemplate.postForObject(URLConstant.GET_CUSTOMIZE_LIST_URL, getVendor, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
if (!"success".equals(vendorRes.getString("errorDescription")) || vendorRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) {
log.info("供应商不存在");
return;
}
log.info("供应商存在,将继续向下执行");
for (Object vendorObj : vendorRes.getJSONObject("data").getJSONArray("dataList")) {
JSONObject vendorData = JSON.parseObject(JSON.toJSONString(vendorObj));
System.out.println("当前正在处理的供应商数据为:" + vendorData);
//开始截取关键数据
String vendorId = vendorData.getString("_id");
String vendorName = vendorData.getString("name");
String createTime = vendorData.getString("last_modified_time");
//开始查询日子是否存在当前单据
JSONObject isLog = new JSONObject();
try {
isLog = restTemplate.getForObject("http://localhost:18085/Log/query/log_data?table=send_log_vendor&log_type=供应商&dataId=" + vendorId + "&mark=" + createTime, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
if (!isLog.getJSONArray("data").isEmpty()) {
log.info("当前单据已经集成过了,将不再向下执行");
continue;
}
log.info("当前单据没有集成过,将开始向下执行");
Map vendorMap = new HashMap<>();
vendorMap.put("number", vendorData.getString("construction_unit_id__c"));
vendorMap.put("name", vendorName);
//简称
vendorMap.put("simplename", vendorData.getString("supplier_id") != null ? vendorData.getString("supplier_id") : vendorName);
//统一社会信用代码
vendorMap.put("societycreditcode", vendorData.getString("tax_identification_number") != null ? vendorData.getString("tax_identification_number") : "");
//纳税人识别号
vendorMap.put("tx_register_no", vendorData.getString("tax_identification_number") != null ? vendorData.getString("tax_identification_number") : "");
// //联系人封装
// Map contactMap = new HashMap<>();
// //联系人名称
// contactMap.put("contactperson", "");
// //联系人手机
// contactMap.put("phone", vendorData.getString("mobile") != null ? vendorData.getString("mobile") : "");
//银行分录
Map bankEntryMap = new HashMap<>();
//银行账户
bankEntryMap.put("bankaccount", vendorData.getString("bank") != null ? vendorData.getString("bank") : "");
//账户名称
bankEntryMap.put("accountname", vendorData.getString("bank_account") != null ? vendorData.getString("bank_account") : "");
//银行信息分录默认
bankEntryMap.put("isdefault_bank", "1");
//货币代码
bankEntryMap.put("currency_number", "CNY");
//开户银行
bankEntryMap.put("bank_number", vendorData.getString("bank_name__c__r") != null ? vendorData.getString("bank_name__c__r") : "");
vendorMap.put("entry_bank", Arrays.asList(bankEntryMap));
//分类标准
Map standardMap = new HashMap<>();
//分类编码
standardMap.put("groupid_number", vendorData.getString("find_association__c__r") != null ? vendorData.getString("find_association__c__r") : "");
//分类标准编码
standardMap.put("standardid_number", "JBFLBZ");
vendorMap.put("standard", Arrays.asList(standardMap));
//交易币
vendorMap.put("settlementcyid_number", "CNY");
//创建组织
//vendorMap.put("createorg_number", "zyierp");//归属部门
vendorMap.put("createorg_number", "ZHY");//归属部门
vendorMap.put("status", "C");//数据状态
vendorMap.put("enable", "1");//使用状态
//供应商最终请求
Map vendorReq = new HashMap<>();
vendorReq.put("data", Arrays.asList(vendorMap));
//开始获取token
String accessToken = new KDTokenController().getKDAccessTokenTest();
if (accessToken == null || accessToken.equals("")) {
log.info("金蝶token为空或不存在");
return;
}
String uuid = UUID.randomUUID().toString().replace("-", "");
//开始封装请求头
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
headers.set("accessToken", accessToken);
headers.set("Idempotency-Key", uuid);
HttpEntity vendorReqEntity = new HttpEntity(vendorReq, headers);
System.out.println(JSON.parseObject(JSON.toJSONString(vendorReqEntity)));
String vendorUrl = ERPURLConstant.ERP_URL + "/ierp/kapi/v2/f9w5/basedata/bd_supplier/bdSupplierSave";
JSONObject vendorERPRes = new JSONObject();
try {
vendorERPRes = restTemplate.postForObject(vendorUrl, vendorReqEntity, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
System.out.println(vendorERPRes);
//开始封装回写程序
Map backReqMap = new HashMap();
backReqMap.put("_id", vendorId);
backReqMap.put("dataObjectApiName", "SupplierObj");
//开始封装日志
Map logMap = new HashMap<>();
logMap.put("log_id", UUID.randomUUID().toString().replace("-", ""));
logMap.put("log_type", "供应商");
logMap.put("syn_type", "0");
logMap.put("data_name", vendorName);
logMap.put("data_id", vendorId);
logMap.put("mark", createTime);
logMap.put("send_body", JSON.toJSONString(vendorReqEntity));
logMap.put("send_res", JSON.toJSONString(vendorERPRes));
logMap.put("tableName", "send_log_vendor");
//判断是否执行成功
if ("0".equals(vendorERPRes.getString("errorCode"))) {
//同步成功
logMap.put("log_status", "0");
logMap.put("res_body", "同步成功");
backReqMap.put("erp_id__c", vendorERPRes.getJSONObject("data").getJSONArray("result").getJSONObject(0).getString("id"));
backReqMap.put("sync_status__c", "option_sync_success__c");
backReqMap.put("response_status__c", "同步成功");
} else {
//同步失败
logMap.put("log_status", "1");
logMap.put("res_body", "同步失败:" + vendorERPRes.getString("message"));
backReqMap.put("sync_status__c", "option_sync_failure__c");
backReqMap.put("response_status__c", vendorERPRes.getString("message"));
}
//开始回写
JSONObject backReq = crmRequestUtil.updateCRM(backReqMap);
JSONObject backRes = new JSONObject();
try {
backRes = restTemplate.postForObject(URLConstant.UPDATE_CRM_CUSTOMIZE, backReq, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
System.out.println("回写结果为:" + backRes);
//开始记录日志
JSONObject logRes = new JSONObject();
try {
logRes = restTemplate.postForObject("http://localhost:18085/Log/insert/log_data", logMap, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
System.out.println("日志插入结果为:" + logRes);
}
}
}

View File

@ -310,6 +310,17 @@ public class XSHTController {
//销售方式
erpContractReq.put("salesmethod", contractData.getString("sales_method__c") != null ? contractData.getString("sales_method__c") : "");
//付款方式
Map paymentMethodMap = new HashMap<>();
//收款比例
paymentMethodMap.put("payrate", contractData.getBigDecimal("prepayment_ratio__c") != null ? contractData.getBigDecimal("prepayment_ratio__c") : BigDecimal.ZERO);
//预付款金额
paymentMethodMap.put("payamount", contractData.getBigDecimal("pre_invoice_amount__c") != null ? contractData.getBigDecimal("pre_invoice_amount__c") : BigDecimal.ZERO);
//是否预收
paymentMethodMap.put("isprepay", false);
erpContractReq.put("payentry", Arrays.asList(paymentMethodMap));
//根据合同号查询合同明细
JSONObject contractDetailReq = crmRequestUtil.getCRMList(Arrays.asList(
new Filter("EQ", "sale_contract_id", Arrays.asList(contractId))
@ -345,9 +356,9 @@ public class XSHTController {
contractDetailMap.put("specification", contractDetailData.getString("specification__c") != null ? contractDetailData.getString("specification__c") : "");//规格
contractDetailMap.put("baseunit", contractDetailData.getString("unit__c__r") != null ? contractDetailData.getString("unit__c__r") : "");//单位
//contractDetailMap.put("baseunit", "TEST0001");//todo 单位
contractDetailMap.put("unit_number", "pcs");//单位编码
contractDetailMap.put("unit1_number", "pcs");//单位编码
contractDetailMap.put("f9w5_unit1_number", "pcs");//单位编码
contractDetailMap.put("unit_number", contractDetailData.getString("unit__c") != null ? contractDetailData.getString("unit__c") : "");//单位编码
contractDetailMap.put("unit1_number", contractDetailData.getString("unit__c") != null ? contractDetailData.getString("unit__c") : "");//单位编码
contractDetailMap.put("f9w5_unit1_number", contractDetailData.getString("unit__c") != null ? contractDetailData.getString("unit__c") : "");//单位编码
contractDetailMap.put("baseqty", contractDetailData.getBigDecimal("quantity") != null ? contractDetailData.getBigDecimal("quantity") : 0);//数量
contractDetailMap.put("qty", contractDetailData.getBigDecimal("quantity") != null ? contractDetailData.getBigDecimal("quantity") : 0);//数量
contractDetailMap.put("priceandtax", contractDetailData.getBigDecimal("sales_price") != null ? contractDetailData.getBigDecimal("sales_price") : 0);//含税单价

View File

@ -15,6 +15,8 @@ import org.springframework.web.client.RestClientException;
import org.springframework.web.client.RestTemplate;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
@RestController
@ -247,13 +249,13 @@ public class DeviceInstallController {
logMap.put("log_status", "0");
logMap.put("res_body", "同步成功");
backReqMap.put("ledger_sync_status__c", "option_sync_success__c");
backReqMap.put("ledger_response_status__c", deviceResult.getString("msg"));
backReqMap.put("ledger_response_status__c", "创建" + deviceResult.getString("msg"));
} else {
//同步失败
logMap.put("log_status", "1");
logMap.put("res_body", "同步失败:" + deviceResult.getString("msg"));
backReqMap.put("ledger_sync_status__c", "option_sync_failure__c");
backReqMap.put("ledger_response_status__c", deviceResult.getString("msg"));
backReqMap.put("ledger_response_status__c", "创建" + deviceResult.getString("msg"));
}
//开始回写
@ -436,13 +438,13 @@ public class DeviceInstallController {
logMap.put("log_status", "0");
logMap.put("res_body", "同步成功");
backReqMap.put("ledger_sync_status__c", "option_sync_success__c");
backReqMap.put("ledger_response_status__c", deviceResult.getString("msg"));
backReqMap.put("ledger_response_status__c", "更新成功" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
} else {
//同步失败
logMap.put("log_status", "1");
logMap.put("res_body", "同步失败:" + deviceResult.getString("msg"));
backReqMap.put("ledger_sync_status__c", "option_sync_failure__c");
backReqMap.put("ledger_response_status__c", deviceResult.getString("msg"));
backReqMap.put("ledger_response_status__c", "更新失败" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
}
//开始回写