hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

丽知：店铺日志分割使用#

This commit is contained in:
zhengyf 2025-01-22 14:26:31 +08:00
parent a9a35f4aaf
commit 5306696062
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/ShopPluginInitializer.java
View File

@ -224,7 +224,7 @@ public class ShopPluginInitializer extends PluginBaseEntity {
* coed_lastDate * coed_lastDate
*/ */
public void startImplement(String code) { public void startImplement(String code) {
String[] split = code.split("_"); String[] split = code.split("#");
try { try {
OfsShopDto shopEntity = new OfsShopDto(); OfsShopDto shopEntity = new OfsShopDto();
@ -281,7 +281,7 @@ public class ShopPluginInitializer extends PluginBaseEntity {
if (ofsShopDto.getBizCode() != null && !"".equals(ofsShopDto.getBizCode().trim())) { if (ofsShopDto.getBizCode() != null && !"".equals(ofsShopDto.getBizCode().trim())) {
boolean isExis = true; boolean isExis = true;
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setRootAppPk(ofsShopDto.getBizCode() + "_" + ofsShopDto.getLastUpdated()); integrationTaskLivingDetailsEntity.setRootAppPk(ofsShopDto.getBizCode() + "#" + ofsShopDto.getLastUpdated());
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y); integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity); List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity);
@ -309,7 +309,7 @@ public class ShopPluginInitializer extends PluginBaseEntity {
if (ofsShopDto.getBizCode() != null && !"".equals(ofsShopDto.getBizCode().trim())) { if (ofsShopDto.getBizCode() != null && !"".equals(ofsShopDto.getBizCode().trim())) {
boolean isExis = true; boolean isExis = true;
IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
integrationTaskLivingDetailsEntity.setRootAppPk("defdoc_" + ofsShopDto.getBizCode() + "_" + ofsShopDto.getLastUpdated()); integrationTaskLivingDetailsEntity.setRootAppPk("defdoc#" + ofsShopDto.getBizCode() + "#" + ofsShopDto.getLastUpdated());
integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y); integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y);
integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity); List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities = iIntegrationTaskLivingDetailsDao.query(integrationTaskLivingDetailsEntity);
@ -401,7 +401,7 @@ public class ShopPluginInitializer extends PluginBaseEntity {
integrationTaskLivingDetailsEntity.setNewTransmitInfo(attribute.getData()); integrationTaskLivingDetailsEntity.setNewTransmitInfo(attribute.getData());
integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat); integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk(shopEntity.getBizCode() + "_" + businessFormat); integrationTaskLivingDetailsEntity.setRootAppPk(shopEntity.getBizCode() + "#" + businessFormat);
integrationTaskLivingDetailsEntity.setRootAppBill(shopEntity.getBizCode()); integrationTaskLivingDetailsEntity.setRootAppBill(shopEntity.getBizCode());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
if (res_custdoc != null) { if (res_custdoc != null) {
@ -419,7 +419,7 @@ public class ShopPluginInitializer extends PluginBaseEntity {
integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage); integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat); integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk(shopEntity.getBizCode() + "_" + businessFormat); integrationTaskLivingDetailsEntity.setRootAppPk(shopEntity.getBizCode() + "#" + businessFormat);
integrationTaskLivingDetailsEntity.setRootAppBill(shopEntity.getBizCode()); integrationTaskLivingDetailsEntity.setRootAppBill(shopEntity.getBizCode());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
if (bdCubasdocEntity_old != null) { if (bdCubasdocEntity_old != null) {
@ -522,8 +522,8 @@ public class ShopPluginInitializer extends PluginBaseEntity {
integrationTaskLivingDetailsEntity.setNewTransmitInfo(attribute.getData()); integrationTaskLivingDetailsEntity.setNewTransmitInfo(attribute.getData());
integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat); integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk("defdoc_" + shopEntity.getBizCode() + "_" + businessFormat); integrationTaskLivingDetailsEntity.setRootAppPk("defdoc#" + shopEntity.getBizCode() + "#" + businessFormat);
integrationTaskLivingDetailsEntity.setRootAppBill("defdoc_" + shopEntity.getBizCode()); integrationTaskLivingDetailsEntity.setRootAppBill("defdoc#" + shopEntity.getBizCode());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
@ -537,8 +537,8 @@ public class ShopPluginInitializer extends PluginBaseEntity {
integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage); integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat); integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk("defdoc_" + shopEntity.getBizCode() + "_" + businessFormat); integrationTaskLivingDetailsEntity.setRootAppPk("defdoc#" + shopEntity.getBizCode() + "#" + businessFormat);
integrationTaskLivingDetailsEntity.setRootAppBill("defdoc_" + shopEntity.getBizCode()); integrationTaskLivingDetailsEntity.setRootAppBill("defdoc#" + shopEntity.getBizCode());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);
@ -554,8 +554,8 @@ public class ShopPluginInitializer extends PluginBaseEntity {
integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage); integrationTaskLivingDetailsEntity.setNewTransmitInfo(ErrMessage);
integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); integrationTaskLivingDetailsEntity.setNewPushDate(new Date());
integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat); integrationTaskLivingDetailsEntity.setBusinessDate(businessFormat);
integrationTaskLivingDetailsEntity.setRootAppPk("defdoc_" + ofsShopDto.getBizCode() + "_" + businessFormat); integrationTaskLivingDetailsEntity.setRootAppPk("defdoc#" + ofsShopDto.getBizCode() + "#" + businessFormat);
integrationTaskLivingDetailsEntity.setRootAppBill("defdoc_" + ofsShopDto.getBizCode()); integrationTaskLivingDetailsEntity.setRootAppBill("defdoc#" + ofsShopDto.getBizCode());
integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); integrationTaskLivingDetailsEntity.setPluginId(getPluginId());
saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity);