From 01945b192a2c3f93a8cb4aee04d9093a03957dee Mon Sep 17 00:00:00 2001 From: YXY <932687738@qq.com> Date: Thu, 12 Oct 2023 20:12:01 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9B=91=E5=90=AC=E5=9B=9E=E8=B0=83=E4=BA=8B?= =?UTF-8?q?=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/enums/CjtCallBackOperateEnum.java | 53 +++ .../com/ruoyi/common/utils/DateUtils.java | 5 + .../flyingbook/domain/ErpLarkRelation.java | 3 + .../flyingbook/domain/cjt/CJTRequest.java | 118 +++++ .../flyingbook/domain/cjt/CJTRequestBody.java | 34 ++ .../domain/cjt/CJTResponseBody.java | 18 + .../domain/edi/CJTEdiCallbackRequestVo.java | 53 ++- .../ruoyi/flyingbook/helper/OkHttpHelper.java | 48 ++ .../mapper/ErpLarkRelationMapper.java | 1 - .../mapper/ErpLarkTempRelationMapper.java | 1 + .../cjt/CJTOperateCallBackAbstract.java | 412 ++++++++++++++++++ .../cjt/ManufactureOrderSyncCallOperate.java | 118 +++++ .../cjt/SaleDispatchSyncCallOperate.java | 117 +++++ .../strategy/cjt/SaleOrderSyncCallBack.java | 126 ++++++ .../mapper/ErpLarkTempRelationMapper.xml | 5 + 15 files changed, 1110 insertions(+), 2 deletions(-) create mode 100644 ruoyi-common/src/main/java/com/ruoyi/common/enums/CjtCallBackOperateEnum.java create mode 100644 ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTRequest.java create mode 100644 ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTRequestBody.java create mode 100644 ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTResponseBody.java create mode 100644 ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/helper/OkHttpHelper.java create mode 100644 ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/CJTOperateCallBackAbstract.java create mode 100644 ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/ManufactureOrderSyncCallOperate.java create mode 100644 ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/SaleDispatchSyncCallOperate.java create mode 100644 ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/SaleOrderSyncCallBack.java diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/enums/CjtCallBackOperateEnum.java b/ruoyi-common/src/main/java/com/ruoyi/common/enums/CjtCallBackOperateEnum.java new file mode 100644 index 0000000..a4430e5 --- /dev/null +++ b/ruoyi-common/src/main/java/com/ruoyi/common/enums/CjtCallBackOperateEnum.java @@ -0,0 +1,53 @@ +package com.ruoyi.common.enums; + +/** + * 畅捷通反馈操作 + * + * @author ruoyi + */ +public enum CjtCallBackOperateEnum { + /** + * + */ + SALE_DISPATCH_CREATE("SaleDispatchVoucher_Delete", "删除销售出库单",AppType.SYNC_CJT_SALE_DISPATCH_DATA_TO_MULTI_TABLE.getCode()), + SALE_DISPATCH_UPDATE("SaleDispatchVoucher_Delete", "删除销售出库单",AppType.SYNC_CJT_SALE_DISPATCH_DATA_TO_MULTI_TABLE.getCode()), + SALE_DISPATCH_DELETE("SaleDispatchVoucher_Delete", "删除销售出库单",AppType.SYNC_CJT_SALE_DISPATCH_DATA_TO_MULTI_TABLE.getCode()), + MANUFACTURE_ORDER_CREATE("SaleDispatchVoucher_Delete", "删除销售出库单",AppType.SYNC_CJT_MANUFACTURE_ORDER_DATA_TO_MULTI_TABLE.getCode()), + MANUFACTURE_ORDER_UPDATE("SaleDispatchVoucher_Delete", "删除销售出库单",AppType.SYNC_CJT_MANUFACTURE_ORDER_DATA_TO_MULTI_TABLE.getCode()), + MANUFACTURE_ORDER_DELETE("SaleDispatchVoucher_Delete", "删除销售出库单",AppType.SYNC_CJT_MANUFACTURE_ORDER_DATA_TO_MULTI_TABLE.getCode()), + SALE_ORDER_CREATE("SaleDispatchVoucher_Delete", "删除销售出库单",AppType.SYNC_CJT_SALE_ORDER_DATA_TO_MULTI_TABLE.getCode()), + SALE_ORDER_UPDATE("SaleDispatchVoucher_Delete", "删除销售出库单",AppType.SYNC_CJT_SALE_ORDER_DATA_TO_MULTI_TABLE.getCode()), + SALE_ORDER_DELETE("SaleDispatchVoucher_Delete", "删除销售出库单",AppType.SYNC_CJT_SALE_ORDER_DATA_TO_MULTI_TABLE.getCode()); + + + private final String code; + private final String desc; + private final String larkCompanyCode; + + CjtCallBackOperateEnum(String code, String desc, String larkCompanyCode) { + this.code = code; + this.desc = desc; + this.larkCompanyCode = larkCompanyCode; + } + + public String getLarkCompanyCode() { + return larkCompanyCode; + } + + public String getCode() { + return code; + } + + public String getDesc() { + return desc; + } + + public static CjtCallBackOperateEnum getByCode(String code){ + for (CjtCallBackOperateEnum value : CjtCallBackOperateEnum.values()) { + if (value.getCode().equals(code)){ + return value; + } + } + return null; + } +} diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/utils/DateUtils.java b/ruoyi-common/src/main/java/com/ruoyi/common/utils/DateUtils.java index c9b2554..d040258 100644 --- a/ruoyi-common/src/main/java/com/ruoyi/common/utils/DateUtils.java +++ b/ruoyi-common/src/main/java/com/ruoyi/common/utils/DateUtils.java @@ -184,6 +184,11 @@ public class DateUtils extends org.apache.commons.lang3.time.DateUtils { return new Date(); } + public static Object str2long(String time, String pattern) { + LocalDateTime localDateTime = DateUtils.str2ldt(time, pattern); + return DateUtils.ldt2Long(localDateTime); + } + public static LocalDateTime long2ldt(long time) { return LocalDateTime.ofInstant(Instant.ofEpochSecond(time), ZoneOffset.ofHours(8)); } diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/ErpLarkRelation.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/ErpLarkRelation.java index 9158fba..2a8c368 100644 --- a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/ErpLarkRelation.java +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/ErpLarkRelation.java @@ -14,11 +14,14 @@ public class ErpLarkRelation extends BaseEntity { private Long id; + private String cjtId; + private String key; private String method; private String larkKey; + private String larkTable; /** * @see com.ruoyi.common.enums.FlagStatus */ diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTRequest.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTRequest.java new file mode 100644 index 0000000..a9e6092 --- /dev/null +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTRequest.java @@ -0,0 +1,118 @@ +package com.ruoyi.flyingbook.domain.cjt; + +import com.alibaba.fastjson.JSONObject; +import lombok.Data; +import lombok.NoArgsConstructor; +import okhttp3.Headers; +import org.springframework.util.StringUtils; + +import java.io.Serializable; + +/** + * @author yuxiangyong + * @create 2023-07-17 20:31 + */ +@Data +@NoArgsConstructor +public class CJTRequest implements Serializable { + + /** + * 请求地址 + */ + private String url; + /** + * 应用密钥 + */ + private String appKey; + private String appSecret; + /** + * 应用ticket和certificate 用于换取token + */ + private String appTicket; + private String certificate; + /** + * token，用于请求接口 + */ + private String openToken; + /** + * 请求体,获取token + */ + private JSONObject jsonBody; + + private String taskSessionId; + + /** + * 获取列信息 + */ + private CJTRequestBody body; + + /** + * 重置ticket + */ + public CJTRequest(String url, String appKey, String appSecret) { + this.url = url; + this.appKey = appKey; + this.appSecret = appSecret; + } + + /** + * 换取token + */ + public CJTRequest(String url, String appKey, String appSecret, String appTicket, String certificate) { + this.url = url; + this.appKey = appKey; + this.appSecret = appSecret; + this.appTicket = appTicket; + this.certificate = certificate; + } + + + /** + * 请求接口 + */ + public CJTRequest(String url, String appKey, String appSecret, String openToken) { + this.url = url; + this.appKey = appKey; + this.appSecret = appSecret; + this.openToken = openToken; + } + + public CJTRequest(String url, String appKey, String appSecret, String openToken,CJTRequestBody body) { + this.url = url; + this.appKey = appKey; + this.appSecret = appSecret; + this.openToken = openToken; + this.body = body; + } + + public Headers buildHeaders(){ + Headers.Builder builder = new Headers.Builder(); + builder.add("appKey",appKey); + builder.add("appSecret",appSecret); + builder.add("Content-Type","application/json"); + if (!StringUtils.isEmpty(openToken)) { + builder.add("openToken", openToken); + } + return builder.build(); + } + + /** + * 构建查询token的body + */ + public void buildGenerateBody(){ + JSONObject body = new JSONObject(); + body.put("appTicket",appTicket); + body.put("certificate",certificate); + this.jsonBody = body; + } + + public String getRequestBody(){ + if (this.body != null){ + return JSONObject.toJSONString(this.body); + } + if (this.jsonBody != null){ + return jsonBody.toJSONString(); + } + return "{}"; + } +} diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTRequestBody.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTRequestBody.java new file mode 100644 index 0000000..4afcfbf --- /dev/null +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTRequestBody.java @@ -0,0 +1,34 @@ +package com.ruoyi.flyingbook.domain.cjt; + +import com.alibaba.fastjson.JSONObject; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.List; + +/** + * @author yuxiangyong + * @create 2023-07-17 20:31 + */ +@Data +@NoArgsConstructor +public class CJTRequestBody { + private Integer pageIndex; + private Integer pageSize; + private List selectFields; + private JSONObject paramDic; + private JSONObject param; + + public CJTRequestBody(Integer pageIndex, Integer pageSize, List selectFields, JSONObject paramDic) { + this.pageIndex = pageIndex; + this.pageSize = pageSize; + this.selectFields = selectFields; + this.paramDic = paramDic == null ? new JSONObject() : paramDic; + } + + public CJTRequestBody(String voucherID) { + JSONObject jsonObject = new JSONObject(); + jsonObject.put("voucherID",voucherID); + this.param = jsonObject; + } +} diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTResponseBody.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTResponseBody.java new file mode 100644 index 0000000..e0d7c98 --- /dev/null +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/cjt/CJTResponseBody.java @@ -0,0 +1,18 @@ +package com.ruoyi.flyingbook.domain.cjt; + +import com.alibaba.fastjson.JSONObject; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * @author yuxiangyong + * @create 2023-07-17 20:31 + */ +@Data +@NoArgsConstructor +public class CJTResponseBody { + private String code; + private String message; + private String exception; + private JSONObject data; +} diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/edi/CJTEdiCallbackRequestVo.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/edi/CJTEdiCallbackRequestVo.java index efc9169..18783c9 100644 --- a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/edi/CJTEdiCallbackRequestVo.java +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/domain/edi/CJTEdiCallbackRequestVo.java @@ -1,5 +1,10 @@ package com.ruoyi.flyingbook.domain.edi; +import com.alibaba.fastjson.JSONObject; +import com.ruoyi.common.enums.CjtAccountEnum; +import com.ruoyi.common.enums.CjtCallBackOperateEnum; +import com.ruoyi.flyingbook.domain.LarkCompanyRelation; +import com.ruoyi.flyingbook.domain.LarkTableRelation; import lombok.Data; import lombok.NoArgsConstructor; @@ -15,16 +20,62 @@ public class CJTEdiCallbackRequestVo { * 畅捷通操作操作类型 * APP_TICKET 重置ticket * SaleDispatchVoucher_Delete 删除销售出库单 - * + * @see com.ruoyi.common.enums.CjtCallBackOperateEnum */ private String msgType; + private CjtCallBackOperateEnum msgTypeEnum; /** * 单据编码 */ private String voucherCode; + /** + * 单据编码 + */ + private String voucherId; + + /** + * 订单详细数据 + */ + private JSONObject body; + + /** + * 畅捷通账号标识 + * @see com.ruoyi.common.enums.CjtAccountEnum + */ + private String appId; + private CjtAccountEnum cjtAccountEnum; + /** + * 获取token的凭证 + */ + private String ticket; + /** + * 畅捷通token + */ + private String openToken; + + /** + * 飞书相关信息 + */ + private LarkCompanyRelation companyRelation; + private LarkTableRelation tableRelation; + + /** + * 临时的信息id + */ + private Long tempId; + + public CJTEdiCallbackRequestVo(String msgType, String voucherCode) { this.msgType = msgType; this.voucherCode = voucherCode; } + + public CJTEdiCallbackRequestVo(String appId,String msgType, JSONObject body) { + this.msgType = msgType; + this.body = body; + this.appId = appId; + this.cjtAccountEnum = CjtAccountEnum.getByCode(appId); + this.msgTypeEnum = CjtCallBackOperateEnum.getByCode(msgType); + } } diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/helper/OkHttpHelper.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/helper/OkHttpHelper.java new file mode 100644 index 0000000..06e0cdf --- /dev/null +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/helper/OkHttpHelper.java @@ -0,0 +1,48 @@ +package com.ruoyi.flyingbook.helper; + +import com.ruoyi.flyingbook.domain.cjt.CJTRequest; +import lombok.extern.slf4j.Slf4j; +import okhttp3.*; + +import java.nio.charset.StandardCharsets; +import java.util.concurrent.TimeUnit; + +/** + * @author yuxiangyong + * @create 2023-04-18 22:25 + */ +@Slf4j +public class OkHttpHelper { + + + + private static OkHttpClient client = new OkHttpClient().newBuilder() + .callTimeout(10, TimeUnit.SECONDS) + .connectTimeout(10, TimeUnit.SECONDS) + .readTimeout(10, TimeUnit.SECONDS) + .build(); + + + + + public static String post(CJTRequest req) { + Request request = new Request.Builder() + .headers(req.buildHeaders()) + .method("POST", + RequestBody.create(MediaType.get("application/json"), + req.getRequestBody().getBytes(StandardCharsets.UTF_8))) + .url(req.getUrl()) + .build(); + try { + Response execute = client.newCall(request).execute(); + ResponseBody responseBody = execute.body(); + if (responseBody != null){ + return responseBody.string(); + } + } catch (Exception e) { + log.error("http get 请求失败--{}", e); + } + return null; + } + +} diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/mapper/ErpLarkRelationMapper.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/mapper/ErpLarkRelationMapper.java index 1f71f0a..e4ea5bf 100644 --- a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/mapper/ErpLarkRelationMapper.java +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/mapper/ErpLarkRelationMapper.java @@ -68,7 +68,6 @@ public interface ErpLarkRelationMapper public List queryListByKeyListAndRemark(@Param("keyList") List keyList,@Param("method") String method,@Param("remark") String remark); public List queryWaitDeleteRecordList(@Param("currentDay") String currentDay,@Param("method") String method,@Param("remark") String remark); public void deleteRecordList(@Param("currentDay") String currentDay,@Param("method") String method,@Param("remark") String remark); - /** * 批量插入 */ diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/mapper/ErpLarkTempRelationMapper.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/mapper/ErpLarkTempRelationMapper.java index df4f9c6..7aa5d5f 100644 --- a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/mapper/ErpLarkTempRelationMapper.java +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/mapper/ErpLarkTempRelationMapper.java @@ -65,6 +65,7 @@ public interface ErpLarkTempRelationMapper public Long selectMaxId(@Param("method") String method, @Param("flag") Long flag,@Param("key") String key); public int updateByMethod(@Param("method") String method, @Param("flag") Long flag,@Param("id") Long id,@Param("key") String key); + public int updateForCjt(@Param("flag") Long flag,@Param("id") Long id,@Param("remark") String remark); public int deleteByMethod(@Param("method") String method,@Param("flag") Long flag,@Param("id") Long id,@Param("key") String key); diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/CJTOperateCallBackAbstract.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/CJTOperateCallBackAbstract.java new file mode 100644 index 0000000..f144a2f --- /dev/null +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/CJTOperateCallBackAbstract.java @@ -0,0 +1,412 @@ +package com.ruoyi.flyingbook.strategy.cjt; + +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.lark.oapi.service.bitable.v1.model.CreateAppTableRecordRespBody; +import com.ruoyi.common.constant.RedisConstants; +import com.ruoyi.common.core.redis.RedisCache; +import com.ruoyi.common.enums.AppType; +import com.ruoyi.common.enums.CjtAccountEnum; +import com.ruoyi.common.enums.FlagStatus; +import com.ruoyi.common.utils.DateUtils; +import com.ruoyi.flyingbook.LarkHelper.LarkRobotHelper; +import com.ruoyi.flyingbook.LarkHelper.LarkTableHelper; +import com.ruoyi.flyingbook.domain.ErpLarkRelation; +import com.ruoyi.flyingbook.domain.ErpLarkTempRelation; +import com.ruoyi.flyingbook.domain.LarkCompanyRelation; +import com.ruoyi.flyingbook.domain.LarkTableRelation; +import com.ruoyi.flyingbook.domain.cjt.CJTRequest; +import com.ruoyi.flyingbook.domain.cjt.CJTRequestBody; +import com.ruoyi.flyingbook.domain.cjt.CJTResponseBody; +import com.ruoyi.flyingbook.domain.edi.CJTEdiCallbackRequestVo; +import com.ruoyi.flyingbook.domain.lark.LarkTableRequest; +import com.ruoyi.flyingbook.helper.OkHttpHelper; +import com.ruoyi.flyingbook.mapper.ErpLarkRelationMapper; +import com.ruoyi.flyingbook.mapper.ErpLarkTempRelationMapper; +import com.ruoyi.flyingbook.mapper.LarkCompanyRelationMapper; +import com.ruoyi.flyingbook.mapper.LarkTableRelationMapper; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections4.CollectionUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.util.StringUtils; + +import javax.annotation.Resource; +import java.util.*; +import java.util.concurrent.TimeUnit; +import java.util.function.Function; +import java.util.stream.Collectors; + +/** + * 畅捷通回调接口操作 + * @author yuxiangyong + * @create 2023-10-11 19:54 + */ +@Slf4j +public abstract class CJTOperateCallBackAbstract { + @Autowired + private RedisCache redisCache; + @Resource + private LarkCompanyRelationMapper larkCompanyRelationMapper; + @Resource + private LarkTableRelationMapper larkTableRelationMapper; + @Autowired + private LarkRobotHelper larkRobotHelper; + @Autowired + private LarkTableHelper larkTableHelper; + @Autowired + protected ErpLarkRelationMapper erpLarkRelationMapper; + @Autowired + protected ErpLarkTempRelationMapper erpLarkTempRelationMapper; + @Value("${lark.robot.group}") + private String ROBOT_GROUP; + + /** + * 畅捷通域名 + */ + protected static final String REQUEST_ROOT_PATH = "https://openapi.chanjet.com"; + /** + * 重置畅捷通ticket的接口 + */ + private static final String REQUEST_RESET_TICKET_PATH = REQUEST_ROOT_PATH + "/auth/appTicket/resend"; + /** + * 生成调用畅捷通接口的token信息 + */ + private static final String REQUEST_GENERATE_TOKEN_PATH = REQUEST_ROOT_PATH + "/v1/common/auth/selfBuiltApp/generateToken"; + + public void execute(CJTEdiCallbackRequestVo req){ + try { + preHandle(req); + initContext(req); + resetTicket(req); + sync(req); + endHandle(req); + }catch (Exception e){ + errorHandle(req,e); + log.error("{} execute error",this.getClass().getSimpleName(),e); + larkRobotHelper.sendMessageByBot(ROBOT_GROUP, buildRobotErrorCountMessage(req,e)); + } + } + + private void preHandle(CJTEdiCallbackRequestVo req){ + Date date = new Date(); + ErpLarkTempRelation erpLarkTempRelation = new ErpLarkTempRelation(); + erpLarkTempRelation.setKey(req.getBody().getString("voucherID")); + erpLarkTempRelation.setMethod(req.getMsgType()); + erpLarkTempRelation.setLarkKey(req.getAppId()); + erpLarkTempRelation.setCreateBy("System"); + erpLarkTempRelation.setCreateTime(date); + erpLarkTempRelation.setUpdateTime(date); + erpLarkTempRelation.setFlag(FlagStatus.OK.getCode()); + erpLarkTempRelationMapper.insertErpLarkTempRelation(erpLarkTempRelation); + req.setTempId(erpLarkTempRelation.getId()); + } + + private void endHandle(CJTEdiCallbackRequestVo req){ + if (req.getTempId() != null){ + erpLarkTempRelationMapper.updateForCjt(FlagStatus.DELETED.getCode(), req.getTempId(),""); + } + } + + private void errorHandle(CJTEdiCallbackRequestVo req,Exception e){ + if (req.getTempId() != null){ + erpLarkTempRelationMapper.updateForCjt(FlagStatus.OK.getCode(), req.getTempId(),e.getMessage()); + } + } + + private void sync(CJTEdiCallbackRequestVo req){ + JSONObject body = req.getBody(); + CjtAccountEnum cjtAccountEnum = req.getCjtAccountEnum(); + String voucherID = body.getString("voucherID"); + req.setVoucherId(voucherID); + CJTRequestBody cjtRequestBody = new CJTRequestBody(req.getVoucherId()); + CJTRequest cjtRequest = new CJTRequest(getRequestUrl(), cjtAccountEnum.getAppKey(), cjtAccountEnum.getAppSecret(), generateToken(req),cjtRequestBody); + OkHttpHelper.post(cjtRequest); + JSONObject jsonObject = requestCjt(cjtRequest); + syncRecord(req,jsonObject); + } + + /** + * 解析实体，并构建 + * @param req + */ + protected abstract void syncRecord(CJTEdiCallbackRequestVo req,JSONObject returnBody); + + /** + * 获取请求明细的路径 + */ + protected abstract String getRequestUrl(); + + /** + * 获取请求明细的路径 + */ + protected abstract String getMethodUrl(); + + private void initContext(CJTEdiCallbackRequestVo req){ + LarkCompanyRelation queryCompany = new LarkCompanyRelation(); + String larkCompanyCode = req.getMsgTypeEnum().getLarkCompanyCode(); + queryCompany.setAppType(larkCompanyCode); + queryCompany.setFlag(FlagStatus.OK.getCode()); + queryCompany.setRemark(req.getAppId()); + List larkCompanyRelations = larkCompanyRelationMapper.selectLarkCompanyRelationList(queryCompany); + if (CollectionUtils.isEmpty(larkCompanyRelations)){ + throw new RuntimeException(String.format("%s 无larkCompany配置信息 appId:%s appType:%s",req.getMsgType(),req.getAppId(),larkCompanyCode)); + } + LarkCompanyRelation companyRelation = larkCompanyRelations.get(0); + req.setCompanyRelation(companyRelation); + LarkTableRelation queryTable = new LarkTableRelation(); + queryTable.setLarkCompanyRelationId(companyRelation.getId()); + queryTable.setFlag(FlagStatus.OK.getCode()); + List larkTableRelations = larkTableRelationMapper.selectLarkTableRelationList(queryTable); + if (CollectionUtils.isEmpty(larkTableRelations)){ + throw new RuntimeException(String.format("%s 无larkTableRelation配置信息 appId:%s appType:%s larkCompanyId:%s",req.getMsgType(),req.getAppId(),larkCompanyCode,companyRelation.getId())); + } + LarkTableRelation tableRelation = larkTableRelations.get(0); + req.setTableRelation(tableRelation); + } + + private String buildRobotErrorCountMessage(CJTEdiCallbackRequestVo req,Exception e){ + JSONObject body = new JSONObject(); + body.put("cjtId",req.getAppId()); + body.put("msgType",req.getMsgType()); + LarkCompanyRelation companyRelation = req.getCompanyRelation(); + if (companyRelation != null){ + body.put("companyRelationId",companyRelation.getId()); + } + LarkTableRelation tableRelation = req.getTableRelation(); + if (tableRelation != null){ + body.put("tableRelationId",tableRelation.getId()); + } + body.put("errorInfo",e.getMessage()); + return body.toJSONString(); + } + + protected LarkTableRequest buildLarkTableRequest(LarkCompanyRelation companyRelation,LarkTableRelation tableRelation){ + LarkTableRequest request = new LarkTableRequest(); + request.setAppId(companyRelation.getAppId()); + request.setAppSecret(companyRelation.getSecret()); + request.setAppToken(tableRelation.getToAppToken()); + request.setAppTable(tableRelation.getToTableId()); + return request; + } + + + + + + protected void addRecord(CJTEdiCallbackRequestVo req, JSONObject returnBody) { + LarkTableRelation tableRelation = req.getTableRelation(); + //多维表格id + String toTableId = tableRelation.getToTableId(); + //头部信息 + JSONObject header = returnBody.getJSONObject("data"); + //明细信息 + JSONArray saleOrderDetails = header.getJSONArray(getDetailName()); + //待创建关联关系 + List relationList = new ArrayList<>(); + LarkTableRequest request = this.buildLarkTableRequest(req.getCompanyRelation(), req.getTableRelation()); + CjtAccountEnum cjtAccountEnum = req.getCjtAccountEnum(); + for (int i = 0; i < saleOrderDetails.size(); i++) { + JSONObject detail = saleOrderDetails.getJSONObject(i); + String uniqueKey = buildUniqueKey(toTableId, header, detail,cjtAccountEnum); + Map larkBody = buildLarkBody(header, detail,cjtAccountEnum); + request.setBody(larkBody); + CreateAppTableRecordRespBody respBody = larkTableHelper.addTableRecord(request); + String larkKey = respBody.getRecord().getRecordId(); + relationList.add(buildErpLarkRelation(uniqueKey, larkKey, cjtAccountEnum.getCode())); + } + if (!org.springframework.util.CollectionUtils.isEmpty(relationList)) { + erpLarkRelationMapper.batchInsert(relationList); + } + } + + protected void updateRecord(CJTEdiCallbackRequestVo req, JSONObject returnBody) { + LarkTableRelation tableRelation = req.getTableRelation(); + //多维表格id + String toTableId = tableRelation.getToTableId(); + //头部信息 + JSONObject header = returnBody.getJSONObject("data"); + //明细信息 + JSONArray saleOrderDetails = header.getJSONArray(getDetailName()); + //待创建关联关系 + List waitCreateRelationList = new ArrayList<>(); + LarkTableRequest request = this.buildLarkTableRequest(req.getCompanyRelation(), req.getTableRelation()); + CjtAccountEnum cjtAccountEnum = req.getCjtAccountEnum(); + //获取已经存在的明细 + Map existMap = getExistRecords(req).stream().collect(Collectors.toMap(ErpLarkRelation::getKey, Function.identity(), (K1, k2) -> K1)); + for (int i = 0; i < saleOrderDetails.size(); i++) { + JSONObject detail = saleOrderDetails.getJSONObject(i); + String uniqueKey = buildUniqueKey(toTableId, header, detail,cjtAccountEnum); + Map larkBody = buildLarkBody(header, detail,cjtAccountEnum); + request.setBody(larkBody); + if (existMap.containsKey(uniqueKey)){ + ErpLarkRelation erpLarkRelation = existMap.get(uniqueKey); + request.setRecord(erpLarkRelation.getLarkKey()); + request.setAppTable(erpLarkRelation.getLarkTable()); + larkTableHelper.updateTableRecord(request); + }else { + request.setRecord(null); + request.setAppTable(toTableId); + CreateAppTableRecordRespBody respBody = larkTableHelper.addTableRecord(request); + String larkKey = respBody.getRecord().getRecordId(); + waitCreateRelationList.add(buildErpLarkRelation(uniqueKey, larkKey, cjtAccountEnum.getCode())); + } + } + if (!org.springframework.util.CollectionUtils.isEmpty(waitCreateRelationList)) { + erpLarkRelationMapper.batchInsert(waitCreateRelationList); + } + } + + protected abstract String getDetailName(); + + /** + * 构建唯一key + * @return + */ + protected abstract String buildUniqueKey(String toTableId, JSONObject header, JSONObject detail,CjtAccountEnum cjtAccountEnum); + + /** + * 构建多维表格请求体的body + * @return + */ + protected abstract Map buildLarkBody(JSONObject header, JSONObject detail,CjtAccountEnum cjtAccountEnum); + + //构建飞书行与cjt唯一键的对应关系对象 + private ErpLarkRelation buildErpLarkRelation(String key, String larkKey, String cjt) { + ErpLarkRelation erpLarkRelation = new ErpLarkRelation(); + erpLarkRelation.setKey(key); + erpLarkRelation.setLarkKey(larkKey); + erpLarkRelation.setMethod(getRequestUrl()); + erpLarkRelation.setFlag(FlagStatus.OK.getCode()); + erpLarkRelation.setRemark(cjt); + erpLarkRelation.setCreateBy("SYSTEM"); + erpLarkRelation.setCreateTime(new Date()); + erpLarkRelation.setUpdateTime(new Date()); + return erpLarkRelation; + } + + protected Object getSpecialKey(JSONObject detail,String key){ + JSONArray dynamicPropertyKeys = detail.getJSONArray("DynamicPropertyKeys"); + for (int i = 0; i < dynamicPropertyKeys.size(); i++) { + if (key.equals(dynamicPropertyKeys.get(i))) { + JSONArray DynamicPropertyValues = detail.getJSONArray("DynamicPropertyValues"); + return DynamicPropertyValues.get(i); + } + } + return null; + } + + /** + * 删除无效记录 + * @param req + */ + protected void deleteRecord(CJTEdiCallbackRequestVo req){ + LarkCompanyRelation companyRelation = req.getCompanyRelation(); + LarkTableRelation tableRelation = req.getTableRelation(); + LarkTableRequest request = new LarkTableRequest(companyRelation.getAppId(), companyRelation.getSecret(), tableRelation.getToAppToken()); + Map> waitDeleteLarkMap = new HashMap<>(); + List relationList = getExistRecords(req); + List waitDeleteIdList = new ArrayList<>(); + for (ErpLarkRelation record : relationList) { + String[] s = record.getKey().split("_"); + String appTable = s[s.length-1]; + List waitDeleteLarkList = waitDeleteLarkMap.getOrDefault(appTable, new ArrayList<>()); + waitDeleteLarkList.add(record.getLarkKey()); + waitDeleteLarkMap.put(appTable,waitDeleteLarkList); + waitDeleteIdList.add(record.getId()); + } + if (!waitDeleteLarkMap.isEmpty()) { + for (Map.Entry> entry : waitDeleteLarkMap.entrySet()) { + request.setAppTable(entry.getKey()); + request.setRecords(entry.getValue().toArray(new String[0])); + larkTableHelper.deleteTableRecordBatch(request); + } + } + if (CollectionUtils.isNotEmpty(waitDeleteIdList)) { + erpLarkRelationMapper.deleteErpLarkRelationByIds(waitDeleteIdList); + } + } + + protected List getExistRecords(CJTEdiCallbackRequestVo req){ + CjtAccountEnum cjtAccountEnum = req.getCjtAccountEnum(); + ErpLarkRelation erpLarkRelation = new ErpLarkRelation(); + erpLarkRelation.setRemark(cjtAccountEnum.getCode()); + erpLarkRelation.setCjtId(req.getVoucherId()); + erpLarkRelation.setMethod(getMethodUrl()); + return erpLarkRelationMapper.selectErpLarkRelationList(erpLarkRelation); + } + + /** + * 获取ticket,失效前重置 + */ + private void resetTicket(CJTEdiCallbackRequestVo req) { + CjtAccountEnum cjtAccountEnum = req.getCjtAccountEnum(); + String ticketCacheKey = buildCacheUniqueKey(RedisConstants.CJT_TICKET_CACHE_KEY, cjtAccountEnum.getAppKey()); + Long expireTime = redisCache.getExpireTime(ticketCacheKey); + //重置ticket存在响应时间，提前十秒重置 + if (expireTime == null || expireTime < 10) { + log.info("重置ticket"); + CJTRequest cjtRequest = new CJTRequest(REQUEST_RESET_TICKET_PATH + , cjtAccountEnum.getAppKey() + , cjtAccountEnum.getAppSecret()); + OkHttpHelper.post(cjtRequest); + } + try { + Thread.sleep(1000); + } catch (Exception e) { + e.printStackTrace(); + } + String ticket = (String) redisCache.getCacheObject(ticketCacheKey); + req.setTicket(ticket); + } + + private String buildCacheUniqueKey(String key, String appKey) { + return String.format("%s:%s", key, appKey); + } + + /** + * 生成调用接口的token信息 + */ + private String generateToken(CJTEdiCallbackRequestVo req) { + CjtAccountEnum cjtAccountEnum = req.getCjtAccountEnum(); + String tokenCacheKey = buildCacheUniqueKey(RedisConstants.CJT_TOKEN_CACHE_KEY, cjtAccountEnum.getAppKey()); + String openToken = (String) redisCache.getCacheObject(tokenCacheKey); + if (StringUtils.isEmpty(openToken)) { + CJTRequest cjtRequest = new CJTRequest(REQUEST_GENERATE_TOKEN_PATH + , cjtAccountEnum.getAppKey() + , cjtAccountEnum.getAppSecret() + , req.getTicket() + , cjtAccountEnum.getCertificate()); + cjtRequest.buildGenerateBody(); + JSONObject body = JSONObject.parseObject(OkHttpHelper.post(cjtRequest)); + JSONObject value = body.getJSONObject("value"); + String token = value.getString("accessToken"); + req.setOpenToken(token); + redisCache.setCacheObject(tokenCacheKey, token, 5, TimeUnit.MINUTES); + return token; + } else { + req.setOpenToken(openToken); + return openToken; + } + } + /** + * 请求接口并序列化返回对象 + */ + protected JSONObject requestCjt(CJTRequest req) { + String post = OkHttpHelper.post(req); + CJTResponseBody responseBody = JSONObject.parseObject(post, CJTResponseBody.class); + if (!"0".equals(responseBody.getCode())) { + log.error("{} exception", this.getClass().getSimpleName(), responseBody.getMessage()); + throw new RuntimeException(buildErrorBody(req, responseBody.getMessage())); + } + return responseBody.getData(); + } + protected String buildErrorBody(CJTRequest req, String errorMessage) { + JSONObject errorInfo = new JSONObject(); + errorInfo.put("url", req.getUrl()); + errorInfo.put("body", JSONObject.toJSONString(req.getBody())); + errorInfo.put("errorMessage", errorMessage); + return errorInfo.toJSONString(); + } + +} diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/ManufactureOrderSyncCallOperate.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/ManufactureOrderSyncCallOperate.java new file mode 100644 index 0000000..536608b --- /dev/null +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/ManufactureOrderSyncCallOperate.java @@ -0,0 +1,118 @@ +package com.ruoyi.flyingbook.strategy.cjt; + +import com.alibaba.fastjson.JSONObject; +import com.ruoyi.common.enums.*; +import com.ruoyi.common.utils.DateUtils; +import com.ruoyi.flyingbook.domain.edi.CJTEdiCallbackRequestVo; +import org.springframework.stereotype.Component; + +import java.util.HashMap; +import java.util.Map; + +/** + * 生产加工单 + * + * @author yuxiangyong + * @create 2023-07-17 21:21 + */ +@Component("manufactureOrderSyncCallOperate") +public class ManufactureOrderSyncCallOperate extends CJTOperateCallBackAbstract { + + @Override + protected void syncRecord(CJTEdiCallbackRequestVo req, JSONObject returnBody) { + CjtCallBackOperateEnum msgTypeEnum = req.getMsgTypeEnum(); + switch (msgTypeEnum) { + case MANUFACTURE_ORDER_CREATE: + addRecord(req, returnBody); + break; + case MANUFACTURE_ORDER_UPDATE: + updateRecord(req,returnBody); + break; + case MANUFACTURE_ORDER_DELETE: + deleteRecord(req); + break; + default: + break; + } + } + + + @Override + protected String buildUniqueKey(String toTableId, JSONObject header, JSONObject detail,CjtAccountEnum cjtAccountEnum) { + StringBuilder sb = new StringBuilder(); + if (cjtAccountEnum.getCode().equals(CjtAccountEnum.TWO.getCode())){ + sb.append(detail.get("Quantity")).append("_"); + sb.append(getSpecialKey(detail, "pubuserdefnvc3")).append("_"); + sb.append(getSpecialKey(detail, "pubuserdefnvc3")).append("_"); + }else { + sb.append(detail.get("SourceVoucherCode")).append("_"); + sb.append(header.get("Code")).append("_"); + JSONObject inventory = detail.getJSONObject("Inventory"); + if (inventory == null) { + sb.append("null").append("_"); + } else { + sb.append(inventory.get("Code")).append("_"); + } + sb.append(detail.get("Quantity")).append("_"); + sb.append(getSpecialKey(detail, "pubuserdefnvc2")).append("_"); + } + sb.append(toTableId); + return sb.toString(); + } + + + @Override + protected Map buildLarkBody(JSONObject header, JSONObject detail, CjtAccountEnum cjtAccountEnum) { + Map body = new HashMap<>(); + body.put("单据日期", DateUtils.str2long(header.getString("VoucherDate"), DateUtils.YYYY_MM_DD)); + body.put("来源单号", detail.getString("SourceVoucherCode")); + body.put("单据编号", header.getString("Code")); +//创建时间只有年月日 + body.put("创建时间", DateUtils.str2long(header.getString("CreatedTime"), DateUtils.YYYY_MM_DD)); + + JSONObject department = detail.getJSONObject("Department"); + body.put("生产车间", department.getString("Name")); + + JSONObject person = detail.getJSONObject("Person"); + body.put("负责人", person.getString("Name")); + + JSONObject inventory = detail.getJSONObject("Inventory"); + body.put("存货编码", inventory.getString("Code")); + body.put("存货", inventory.getString("Name")); + body.put("规格型号", inventory.getString("Specification")); + + JSONObject unit = detail.getJSONObject("Unit"); + body.put("生产单位", unit.getString("Name")); + + body.put("数量", detail.getDoubleValue("Quantity")); + body.put("备注1", getSpecialKey(detail, "pubuserdefnvc2")); + JSONObject customer = detail.getJSONObject("Customer"); + body.put("客户", customer.getString("Name")); + body.put("合并字段", getSpecialKey(detail, "priuserdefnvc1")); + switch (cjtAccountEnum) { + case ONE: + break; + case TWO: + body.put("钢板面", getSpecialKey(detail, "pubuserdefnvc1")); + break; + } + return body; + } + + @Override + protected String getRequestUrl() { + return "/tplus/api/v2/ManufactureOrderOpenApi/GetVoucherDTO"; + } + + @Override + protected String getMethodUrl() { + return REQUEST_ROOT_PATH + "/tplus/api/v2/ManufactureOrderOpenApi/FindVoucherList"; + } + + @Override + protected String getDetailName() { + return "ManufactureOrderDetails"; + } + + +} \ No newline at end of file diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/SaleDispatchSyncCallOperate.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/SaleDispatchSyncCallOperate.java new file mode 100644 index 0000000..672d3e6 --- /dev/null +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/SaleDispatchSyncCallOperate.java @@ -0,0 +1,117 @@ +package com.ruoyi.flyingbook.strategy.cjt; + +import com.alibaba.fastjson.JSONObject; +import com.ruoyi.common.enums.CjtAccountEnum; +import com.ruoyi.common.enums.CjtCallBackOperateEnum; +import com.ruoyi.common.utils.DateUtils; +import com.ruoyi.flyingbook.domain.edi.CJTEdiCallbackRequestVo; +import org.springframework.stereotype.Component; + +import java.util.*; + +/** + * 销售出库单 + * + * @author yuxiangyong + * @create 2023-07-17 21:21 + */ +@Component("saleDispatchSyncCallOperate") +public class SaleDispatchSyncCallOperate extends CJTOperateCallBackAbstract { + + @Override + protected void syncRecord(CJTEdiCallbackRequestVo req, JSONObject returnBody) { + CjtCallBackOperateEnum msgTypeEnum = req.getMsgTypeEnum(); + switch (msgTypeEnum) { + case SALE_DISPATCH_CREATE: + addRecord(req, returnBody); + break; + case SALE_DISPATCH_UPDATE: + updateRecord(req,returnBody); + break; + case SALE_DISPATCH_DELETE: + deleteRecord(req); + break; + default: + break; + } + } + + + @Override + protected String buildUniqueKey(String toTableId, JSONObject header, JSONObject detail,CjtAccountEnum cjtAccountEnum) { + StringBuilder sb = new StringBuilder(); + sb.append(detail.get("SourceVoucherCode")).append("_"); + sb.append(header.get("Code")).append("_"); + JSONObject inventory = detail.getJSONObject("Inventory"); + if (inventory == null) { + sb.append("null").append("_"); + } else { + sb.append(inventory.get("Code")).append("_"); + } + sb.append(detail.get("Quantity")).append("_"); + sb.append(detail.get("DetailMemo")).append("_"); + sb.append(header.get("SaleOrderCode")).append("_"); + sb.append(getSpecialKey(detail, "pubuserdefnvc3")).append("_"); + sb.append(toTableId); + return sb.toString(); + } + + + @Override + protected Map buildLarkBody(JSONObject header, JSONObject detail, CjtAccountEnum cjtAccountEnum) { + Map body = new HashMap<>(); + body.put("来源单号", detail.getString("SourceVoucherCode")); + body.put("单据日期", DateUtils.str2long(header.getString("VoucherDate"), DateUtils.YYYY_MM_DD)); + body.put("单据编号", header.getString("Code")); + + JSONObject partner = header.getJSONObject("Partner"); + body.put("客户", partner.getString("Name")); + body.put("客户编码", partner.getString("Code")); + body.put("客服", partner.getString("priuserdefnvc1")); + body.put("配送路线", partner.getString("priuserdefnvc2")); + + JSONObject inventory = detail.getJSONObject("Inventory"); + body.put("存货编码", inventory.getString("Code")); + body.put("存货", inventory.getString("Name")); + body.put("规格型号", inventory.getString("Specification")); + + JSONObject unit = detail.getJSONObject("Unit"); + body.put("计量单位", unit.getString("Name")); + + body.put("数量", detail.getDoubleValue("Quantity")); + body.put("送货地址", header.getString("DispatchAddress")); + //创建时间只有年月日 + body.put("创建时间", DateUtils.str2long(header.getString("CreatedTime"), DateUtils.YYYY_MM_DD)); + body.put("备注", detail.getString("DetailMemo")); + body.put("售价", detail.getDoubleValue("OrigSalePrice")); + body.put("销售金额", detail.getDoubleValue("OrigSaleAmount")); + + body.put("订单编号", header.getString("SaleOrderCode")); + body.put("客户备注", getSpecialKey(detail, "pubuserdefnvc3")); + switch (cjtAccountEnum) { + case ONE: + body.put("联系人", header.getString("contact")); + body.put("联系电话", header.getString("contactphone")); + break; + case TWO: + break; + } + return body; + } + + @Override + protected String getRequestUrl() { + return "/tplus/api/v2/SaleDispatchOpenApi/GetVoucherDTO"; + } + + @Override + protected String getMethodUrl() { + return REQUEST_ROOT_PATH + "/tplus/api/v2/SaleDispatchOpenApi/FindVoucherList"; + } + + @Override + protected String getDetailName() { + return "RDRecordDetails"; + } + +} diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/SaleOrderSyncCallBack.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/SaleOrderSyncCallBack.java new file mode 100644 index 0000000..985de39 --- /dev/null +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/strategy/cjt/SaleOrderSyncCallBack.java @@ -0,0 +1,126 @@ +package com.ruoyi.flyingbook.strategy.cjt; + +import com.alibaba.fastjson.JSONObject; +import com.ruoyi.common.enums.*; +import com.ruoyi.common.utils.DateUtils; +import com.ruoyi.flyingbook.domain.edi.CJTEdiCallbackRequestVo; +import org.springframework.stereotype.Component; + +import java.util.HashMap; +import java.util.Map; + +/** + * 销售订单 + * @author yuxiangyong + * @create 2023-07-17 21:21 + */ +@Component("saleOrderSyncCallBack") +public class SaleOrderSyncCallBack extends CJTOperateCallBackAbstract{ + + @Override + protected void syncRecord(CJTEdiCallbackRequestVo req, JSONObject returnBody) { + CjtCallBackOperateEnum msgTypeEnum = req.getMsgTypeEnum(); + switch (msgTypeEnum) { + case SALE_ORDER_CREATE: + addRecord(req, returnBody); + break; + case SALE_ORDER_UPDATE: + updateRecord(req,returnBody); + break; + case SALE_ORDER_DELETE: + deleteRecord(req); + break; + default: + break; + } + } + + + @Override + protected String buildUniqueKey(String toTableId, JSONObject header, JSONObject detail,CjtAccountEnum cjtAccountEnum) { + StringBuilder sb = new StringBuilder(); + if (cjtAccountEnum.getCode().equals(CjtAccountEnum.TWO.getCode())){ + sb.append(header.get("Code")).append("_"); + JSONObject inventory = detail.getJSONObject("Inventory"); + if (inventory == null) { + sb.append("null").append("_"); + } else { + sb.append(inventory.get("Code")).append("_"); + } + sb.append(detail.get("Quantity")).append("_"); + sb.append(getSpecialKey(detail, "pubuserdefnvc1")).append("_"); + sb.append(detail.get("DetailMemo")).append("_"); + }else { + sb.append(header.get("Code")).append("_"); + JSONObject inventory = detail.getJSONObject("Inventory"); + if (inventory == null) { + sb.append("null").append("_"); + } else { + sb.append(inventory.get("Code")).append("_"); + } + sb.append(detail.get("Quantity")).append("_"); + sb.append(detail.get("DetailMemo")).append("_"); + } + sb.append(toTableId); + return sb.toString(); + } + + + @Override + protected Map buildLarkBody(JSONObject header, JSONObject detail, CjtAccountEnum cjtAccountEnum) { + Map body = new HashMap<>(); + body.put("单据日期", DateUtils.str2long(header.getString("VoucherDate"), DateUtils.YYYY_MM_DD)); + body.put("编号", header.getString("Code")); + body.put("生单时间", DateUtils.str2long(header.getString("CreatedTime"), DateUtils.YYYY_MM_DD)); + + + JSONObject customer = header.getJSONObject("Customer"); + body.put("客户", customer.getString("Name")); + + body.put("审核日期", DateUtils.str2long(header.getString("AuditedDate"), DateUtils.YYYY_MM_DD)); + + JSONObject voucherState = header.getJSONObject("VoucherState"); + body.put("单据状态", voucherState.getString("Name")); + + JSONObject inventory = detail.getJSONObject("Inventory"); + body.put("存货编码", inventory.getString("Code")); + body.put("存货", inventory.getString("Name")); + body.put("规格型号", inventory.getString("Specification")); + + JSONObject unit = detail.getJSONObject("Unit"); + body.put("销售单位", unit.getString("Name")); + + body.put("数量", detail.getDoubleValue("Quantity")); + body.put("累计执行数量", detail.getDoubleValue("累计执行数量")); + body.put("明细备注", detail.getString("DetailMemo")); + body.put("钢板面", getSpecialKey(detail, "pubuserdefnvc1")); + switch (cjtAccountEnum) { + case ONE: + body.put("客户备注", header.getString("CustomerMemo")); + body.put("备注1", header.getString("Memo")); + break; + case TWO: + body.put("备注1", getSpecialKey(detail, "pubuserdefnvc2")); + break; + } + return body; + } + + @Override + protected String getRequestUrl() { + return "/tplus/api/v2/SaleOrderOpenApi/GetVoucherDTO"; + } + + @Override + protected String getMethodUrl() { + return REQUEST_ROOT_PATH + "/tplus/api/v2/SaleOrderOpenApi/FindVoucherList"; + } + + @Override + protected String getDetailName() { + return "SaleOrderDetails"; + } + + + +} diff --git a/ruoyi-flyingbook/src/main/resources/mapper/ErpLarkTempRelationMapper.xml b/ruoyi-flyingbook/src/main/resources/mapper/ErpLarkTempRelationMapper.xml index 7117eea..c9d2669 100644 --- a/ruoyi-flyingbook/src/main/resources/mapper/ErpLarkTempRelationMapper.xml +++ b/ruoyi-flyingbook/src/main/resources/mapper/ErpLarkTempRelationMapper.xml @@ -127,6 +127,11 @@ and `key` = #{key} and #{id} >= id + + update erp_lark_temp_relation + set flag = #{flag},remark = #{remark} + where #{id} = id +