package com.ruoyi.productionPlan.service.impl;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.common.utils.http.HttpUtils;
|
import com.ruoyi.framework.config.AliDingConfig;
|
import com.ruoyi.productionPlan.dto.ProductionPlanDto;
|
import com.ruoyi.productionPlan.mapper.ProductionPlanMapper;
|
import com.ruoyi.productionPlan.pojo.ProductionPlan;
|
import com.ruoyi.productionPlan.service.ProductionPlanService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.nio.charset.StandardCharsets;
|
import java.time.Instant;
|
import java.time.LocalDateTime;
|
import java.time.OffsetDateTime;
|
import java.time.ZoneId;
|
import java.time.format.DateTimeParseException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* <br>
|
* 销售生产需求接口实现类
|
* </br>
|
*
|
* @author deslrey
|
* @version 1.0
|
* @since 2026/03/10 10:00
|
*/
|
|
@Slf4j
|
@Service
|
public class ProductionPlanServiceImpl extends ServiceImpl<ProductionPlanMapper, ProductionPlan> implements ProductionPlanService {
|
|
@Autowired
|
private AliDingConfig aliDingConfig;
|
|
@Autowired
|
private ProductionPlanMapper productionPlanMapper;
|
|
@Override
|
public IPage<ProductionPlanDto> listPage(Page page, ProductionPlanDto productionPlanDto) {
|
return productionPlanMapper.listPage(page, productionPlanDto);
|
}
|
|
/**
|
* 页面手动同步
|
*/
|
@Override
|
public void loadProdData() {
|
syncProdData(1);
|
}
|
|
/**
|
* 定时任务同步
|
*/
|
@Override
|
public void syncProdDataJob() {
|
syncProdData(2);
|
}
|
|
/**
|
* 同步数据
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void syncProdData(Integer dataSyncType) {
|
try {
|
// 获取AccessToken
|
String params = "appkey=" + aliDingConfig.getAppKey()
|
+ "&appsecret=" + aliDingConfig.getAppSecret();
|
|
String tokenRes = HttpUtils.sendGet(aliDingConfig.getAccessTokenUrl(), params);
|
|
JSONObject tokenObj = JSON.parseObject(tokenRes);
|
|
String accessToken = tokenObj.getString("access_token");
|
if (StringUtils.isEmpty(accessToken)) {
|
log.error("获取钉钉AccessToken失败: {}", tokenRes);
|
return;
|
}
|
|
log.info("获取AccessToken成功: {}", accessToken);
|
|
// 查询表单数据
|
JSONObject searchParam = new JSONObject();
|
searchParam.put("appType", aliDingConfig.getAppType());
|
searchParam.put("systemToken", aliDingConfig.getSystemToken());
|
searchParam.put("userId", aliDingConfig.getUserId());
|
searchParam.put("formUuid", aliDingConfig.getFormUuid());
|
|
String dataRes = HttpUtils.sendPostJson(
|
aliDingConfig.getSearchFormDataUrl(),
|
searchParam.toJSONString(),
|
StandardCharsets.UTF_8.name(),
|
null,
|
accessToken
|
);
|
|
if (StringUtils.isEmpty(dataRes)) {
|
log.error("拉取宜搭数据为空");
|
return;
|
}
|
|
JSONObject resultObj = JSON.parseObject(dataRes);
|
JSONArray dataArr = resultObj.getJSONArray("data");
|
|
if (dataArr == null || dataArr.isEmpty()) {
|
log.warn("没有获取到表单数据");
|
return;
|
}
|
|
List<ProductionPlan> list = new ArrayList<>();
|
|
// 解析表单
|
for (int i = 0; i < dataArr.size(); i++) {
|
|
JSONObject item = dataArr.getJSONObject(i);
|
|
String formInstanceId = item.getString("formInstanceId");
|
String serialNo = item.getString("serialNo");
|
// 发起人
|
JSONObject originator = item.getJSONObject("originator");
|
String originatorName = originator.getJSONObject("userName").getString("nameInChinese");
|
|
JSONObject formData = item.getJSONObject("formData");
|
// 明细表
|
JSONArray tableArr = formData.getJSONArray("tableField_l7fytfcn");
|
if (tableArr == null || tableArr.isEmpty()) {
|
continue;
|
}
|
|
// 解析明细
|
for (int j = 0; j < tableArr.size(); j++) {
|
JSONObject row = tableArr.getJSONObject(j);
|
ProductionPlan plan = new ProductionPlan();
|
|
// 表单信息
|
plan.setFormInstanceId(formInstanceId);
|
plan.setSerialNo(serialNo);
|
|
// 表头字段
|
plan.setApplyNo(formData.getString("textField_l7fytfco"));
|
plan.setCustomerName(formData.getString("textField_lbkozohg"));
|
|
// 明细字段
|
plan.setMaterialCode(row.getString("textField_l9xo62q5"));
|
plan.setProductName(row.getString("textField_l9xo62q7"));
|
plan.setProductSpec(row.getString("textField_l9xo62q8"));
|
plan.setLength(row.getInteger("numberField_lb7lgatg_value"));
|
plan.setWidth(row.getInteger("numberField_lb7lgath_value"));
|
plan.setHeight(row.getInteger("numberField_lb7lgati_value"));
|
plan.setQuantity(row.getInteger("numberField_lb7lgatj_value"));
|
plan.setVolume(row.getBigDecimal("numberField_l7fytfd3_value"));
|
plan.setStrength(row.getString("radioField_m9urarr2_id"));
|
|
// 日期区间
|
JSONArray dateArr = row.getJSONArray("cascadeDateField_lfxqqluw");
|
|
if (dateArr != null && dateArr.size() == 2) {
|
long start = Long.parseLong(dateArr.getString(0));
|
long end = Long.parseLong(dateArr.getString(1));
|
|
plan.setStartDate(Instant.ofEpochMilli(start)
|
.atZone(ZoneId.systemDefault())
|
.toLocalDateTime());
|
|
plan.setEndDate(Instant.ofEpochMilli(end)
|
.atZone(ZoneId.systemDefault())
|
.toLocalDateTime());
|
}
|
|
// 提交人
|
plan.setSubmitter(originatorName);
|
// 组织
|
plan.setSubmitOrg("宁夏中创绿能实业集团有限公司");
|
// 备注
|
plan.setRemarkOne(formData.getString("textareaField_l7fytfcy"));
|
plan.setRemarkTwo(formData.getString("textField_l7fytfcx"));
|
// 创建人
|
plan.setCreatorName(originatorName);
|
// 修改人
|
JSONObject modifyUser = item.getJSONObject("modifyUser");
|
if (modifyUser != null) {
|
plan.setModifierName(modifyUser.getJSONObject("userName").getString("nameInChinese"));
|
}
|
// 表单时间
|
plan.setFormCreatedTime(parseUtcTime(item.getString("createdTimeGMT")));
|
plan.setFormModifiedTime(parseUtcTime(item.getString("modifiedTimeGMT")));
|
// 同步信息
|
plan.setDataSyncType(dataSyncType);
|
plan.setDataSourceType(1);
|
// 数据库时间
|
LocalDateTime now = LocalDateTime.now();
|
plan.setCreateTime(now);
|
plan.setUpdateTime(now);
|
|
list.add(plan);
|
}
|
}
|
|
if (!list.isEmpty()) {
|
saveBatch(list);
|
}
|
log.info("生产计划同步完成，共 {} 条", list.size());
|
} catch (Exception e) {
|
log.error("同步生产计划异常", e);
|
}
|
}
|
|
private LocalDateTime parseUtcTime(String utcString) {
|
if (StringUtils.isEmpty(utcString)) {
|
return null;
|
}
|
try {
|
OffsetDateTime odt = OffsetDateTime.parse(utcString);
|
return odt.toLocalDateTime();
|
} catch (DateTimeParseException ex) {
|
log.warn("解析时间 {} 失败: {}", utcString, ex.getMessage());
|
return null;
|
}
|
}
|
}
|
