@ -20,6 +20,8 @@ import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils ;
import org.checkerframework.checker.units.qual.A ;
import org.springframework.beans.factory.annotation.Autowired ;
import org.springframework.boot.autoconfigure.cache.CacheProperties ;
import org.springframework.boot.autoconfigure.data.redis.RedisProperties ;
import org.springframework.web.bind.annotation.* ;
import javax.servlet.ServletInputStream ;
@ -124,10 +126,16 @@ public class YunguanInterfaceController {
queryWrapper . lambda ( ) . eq ( OrganizeEntity : : getEnCode , ObjectUtil . isEmpty ( jsonObject . get ( "ATTR3" ) ) ? null : jsonObject . get ( "ATTR3" ) . toString ( ) ) ;
List < OrganizeEntity > orgList = organizeService . list ( queryWrapper ) ;
if ( orgList ! = null & & orgList . size ( ) > 0 ) {
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Company IdTree( ) . split ( "," ) ) ;
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Organize IdTree( ) . split ( "," ) ) ;
String organizeId = JSON . toJSONString ( conpanyIdList ) ;
entity . setOrganizeJsonId ( organizeId ) ; //分支机构编码
}
QueryWrapper < OrganizeEntity > queryWrapper1 = new QueryWrapper < > ( ) ;
queryWrapper1 . lambda ( ) . eq ( OrganizeEntity : : getEnCode , ObjectUtil . isEmpty ( jsonObject . get ( "ATTR1" ) ) ? null : jsonObject . get ( "ATTR1" ) . toString ( ) ) ;
List < OrganizeEntity > companyId = organizeService . list ( queryWrapper ) ;
if ( companyId ! = null & & companyId . size ( ) > 0 ) {
entity . setCompanyId ( companyId . get ( 0 ) . getId ( ) ) ; //公司id
}
entity . setReservedFields1 ( ObjectUtil . isEmpty ( jsonObject . get ( "ACCOUNT_TYPE" ) ) ? null : jsonObject . get ( "ACCOUNT_TYPE" ) . toString ( ) ) ; //账户类型
entity . setReservedFields2 ( ObjectUtil . isEmpty ( jsonObject . get ( "CLIENT_CLASSIFY" ) ) ? null : jsonObject . get ( "CLIENT_CLASSIFY" ) . toString ( ) ) ; //客户类型
entity . setCountry ( ObjectUtil . isEmpty ( jsonObject . get ( "COUNTRY" ) ) ? null : jsonObject . get ( "COUNTRY" ) . toString ( ) ) ; //国家
@ -153,6 +161,7 @@ public class YunguanInterfaceController {
} else {
//新增客户
SubjectbasicEntity subjectbasicEntity = new SubjectbasicEntity ( ) ;
subjectbasicEntity . setCollaborationMethod ( "1" ) ;
subjectbasicEntity . setId ( ObjectUtil . isEmpty ( jsonObject . get ( "ID" ) ) ? null : jsonObject . get ( "ID" ) . toString ( ) ) ; //ID
subjectbasicEntity . setName ( ObjectUtil . isEmpty ( jsonObject . get ( "CUST_FULL_NAME" ) ) ? null : jsonObject . get ( "CUST_FULL_NAME" ) . toString ( ) ) ; //名称
subjectbasicEntity . setCalssify ( "1" ) ; //一级
@ -171,10 +180,16 @@ public class YunguanInterfaceController {
queryWrapper . lambda ( ) . eq ( OrganizeEntity : : getEnCode , ObjectUtil . isEmpty ( jsonObject . get ( "ATTR3" ) ) ? null : jsonObject . get ( "ATTR3" ) . toString ( ) ) ;
List < OrganizeEntity > orgList = organizeService . list ( queryWrapper ) ;
if ( orgList ! = null & & orgList . size ( ) > 0 ) {
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Company IdTree( ) . split ( "," ) ) ;
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Organize IdTree( ) . split ( "," ) ) ;
String organizeId = JSON . toJSONString ( conpanyIdList ) ;
subjectbasicEntity . setOrganizeJsonId ( organizeId ) ; //分支机构编码
}
QueryWrapper < OrganizeEntity > queryWrapper1 = new QueryWrapper < > ( ) ;
queryWrapper1 . lambda ( ) . eq ( OrganizeEntity : : getEnCode , ObjectUtil . isEmpty ( jsonObject . get ( "ATTR1" ) ) ? null : jsonObject . get ( "ATTR1" ) . toString ( ) ) ;
List < OrganizeEntity > companyId = organizeService . list ( queryWrapper ) ;
if ( companyId ! = null & & companyId . size ( ) > 0 ) {
subjectbasicEntity . setCompanyId ( companyId . get ( 0 ) . getId ( ) ) ; //公司id
}
subjectbasicEntity . setReservedFields1 ( ObjectUtil . isEmpty ( jsonObject . get ( "ACCOUNT_TYPE" ) ) ? null : jsonObject . get ( "ACCOUNT_TYPE" ) . toString ( ) ) ; //账户类型
subjectbasicEntity . setReservedFields2 ( ObjectUtil . isEmpty ( jsonObject . get ( "CLIENT_CLASSIFY" ) ) ? null : jsonObject . get ( "CLIENT_CLASSIFY" ) . toString ( ) ) ; //客户类型
if ( ObjectUtil . isNotEmpty ( jsonObject . get ( "COUNTRY" ) ) ) {
@ -243,9 +258,10 @@ public class YunguanInterfaceController {
queryWrapper . lambda ( ) . eq ( OrganizeEntity : : getEnCode , ObjectUtil . isEmpty ( jsonObject . get ( "ORG_ID" ) ) ? null : jsonObject . get ( "ORG_ID" ) . toString ( ) ) ;
List < OrganizeEntity > orgList = organizeService . list ( queryWrapper ) ;
if ( orgList ! = null & & orgList . size ( ) > 0 ) {
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Company IdTree( ) . split ( "," ) ) ;
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Organize IdTree( ) . split ( "," ) ) ;
String organizeId = JSON . toJSONString ( conpanyIdList ) ;
entity . setOrganizeJsonId ( organizeId ) ; //分支机构编码
entity . setCompanyId ( orgList . get ( 0 ) . getId ( ) ) ; //公司id
}
entity . setReservedFields2 ( ObjectUtil . isEmpty ( jsonObject . get ( "VENDOR_TYPE" ) ) ? null : jsonObject . get ( "VENDOR_TYPE" ) . toString ( ) ) ;
entity . setCountry ( ObjectUtil . isEmpty ( jsonObject . get ( "COUNTRY" ) ) ? null : jsonObject . get ( "COUNTRY" ) . toString ( ) ) ; //国家
@ -269,6 +285,7 @@ public class YunguanInterfaceController {
} else {
//新增供应商
SubjectbasicEntity subjectbasicEntity = new SubjectbasicEntity ( ) ;
subjectbasicEntity . setCollaborationMethod ( "1" ) ;
subjectbasicEntity . setId ( ObjectUtil . isEmpty ( jsonObject . get ( "ID" ) ) ? null : jsonObject . get ( "ID" ) . toString ( ) ) ; //ID
subjectbasicEntity . setName ( ObjectUtil . isEmpty ( jsonObject . get ( "VENDOR_NAME" ) ) ? null : jsonObject . get ( "VENDOR_NAME" ) . toString ( ) ) ; //名称
subjectbasicEntity . setCalssify ( "1" ) ; //一级
@ -287,9 +304,10 @@ public class YunguanInterfaceController {
queryWrapper . lambda ( ) . eq ( OrganizeEntity : : getEnCode , ObjectUtil . isEmpty ( jsonObject . get ( "ORG_ID" ) ) ? null : jsonObject . get ( "ORG_ID" ) . toString ( ) ) ;
List < OrganizeEntity > orgList = organizeService . list ( queryWrapper ) ;
if ( orgList ! = null & & orgList . size ( ) > 0 ) {
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Company IdTree( ) . split ( "," ) ) ;
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Organize IdTree( ) . split ( "," ) ) ;
String organizeId = JSON . toJSONString ( conpanyIdList ) ;
subjectbasicEntity . setOrganizeJsonId ( organizeId ) ; //分支机构编码
entity . setCompanyId ( orgList . get ( 0 ) . getId ( ) ) ; //公司id
}
subjectbasicEntity . setReservedFields2 ( ObjectUtil . isEmpty ( jsonObject . get ( "VENDOR_TYPE" ) ) ? null : jsonObject . get ( "VENDOR_TYPE" ) . toString ( ) ) ; //供应商类型
if ( ObjectUtil . isNotEmpty ( jsonObject . get ( "COUNTRY" ) ) ) {
@ -348,10 +366,13 @@ public class YunguanInterfaceController {
//库存组织编码,库存组织名称
if ( ObjectUtil . isNotEmpty ( jsonObject . get ( "ORG_CD" ) ) ) {
contractLEntity . setKucunOrgCode ( jsonObject . get ( "ORG_CD" ) . toString ( ) ) ;
DictionaryyunguandataEntity dictionaryyunguandataEntity = dictionaryyunguandataService . getDateValueInfo ( "564773000885326917" , contractLEntity . getKucunOrgCode ( ) ) ;
if ( ObjectUtil . isNotEmpty ( dictionaryyunguandataEntity ) ) {
contractLEntity . setKucunOrgName ( dictionaryyunguandataEntity . getZhihuiValue ( ) ) ;
// DictionaryyunguandataEntity dictionaryyunguandataEntity = dictionaryyunguandataService.getDateValueInfo("564773000885326917",contractLEntity.getKucunOrgCode());
// if (ObjectUtil.isNotEmpty(dictionaryyunguandataEntity)) {
// contractLEntity.setKucunOrgName(dictionaryyunguandataEntity.getZhihuiValue());
// }
}
if ( ObjectUtil . isNotEmpty ( jsonObject . get ( "ORG_NM" ) ) ) {
contractLEntity . setKucunOrgName ( jsonObject . get ( "ORG_NM" ) . toString ( ) ) ;
}
//组织,公司,部门,签约主体
if ( ObjectUtil . isNotEmpty ( jsonObject . get ( "DEPT_CD" ) ) ) {
@ -359,7 +380,7 @@ public class YunguanInterfaceController {
queryWrapper . lambda ( ) . eq ( OrganizeEntity : : getEnCode , jsonObject . get ( "DEPT_CD" ) . toString ( ) ) ;
List < OrganizeEntity > orgList = organizeService . list ( queryWrapper ) ;
if ( orgList ! = null & & orgList . size ( ) > 0 ) {
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Company IdTree( ) . split ( "," ) ) ;
List < String > conpanyIdList = Arrays . asList ( orgList . get ( 0 ) . get Organize IdTree( ) . split ( "," ) ) ;
String organizeId = JSON . toJSONString ( conpanyIdList ) ;
contractLEntity . setDepartmentId ( orgList . get ( 0 ) . getId ( ) ) ;
contractLEntity . setCompanyId ( orgList . get ( 0 ) . getParentId ( ) ) ;
@ -826,6 +847,12 @@ public class YunguanInterfaceController {
businessOrderProductRelationalEntity . setYunguanMassage ( yunguanPurchaseOrderProductModel . getERR_MESSAGE ( ) ) ;
businessOrderProductRelationalService . updateById ( businessOrderProductRelationalEntity ) ;
}
if ( yunguanPurchaseOrderProductModel . getREAD_FLAG ( ) . equals ( "N" ) ) {
businessOrderEntity . setYunguanMark ( yunguanPurchaseOrderProductModel . getREAD_FLAG ( ) ) ;
businessOrderEntity . setYunguanTime ( yunguanPurchaseOrderProductModel . getREAD_TIME ( ) ) ;
businessOrderEntity . setYunguanMassage ( yunguanPurchaseOrderProductModel . getERR_MESSAGE ( ) ) ;
businessOrderService . updateById ( businessOrderEntity ) ;
}
}
}
} else if ( jsonObject . get ( "TYPE" ) . equals ( "销售订单头" ) ) {
@ -858,6 +885,12 @@ public class YunguanInterfaceController {
businessOrderProductRelationalEntity . setYunguanMassage ( yunguanSaleOrderProductModel . getERR_MESSAGE ( ) ) ;
businessOrderProductRelationalService . updateById ( businessOrderProductRelationalEntity ) ;
}
if ( yunguanSaleOrderProductModel . getREAD_FLAG ( ) . equals ( "N" ) ) {
businessOrderEntity . setYunguanMark ( yunguanSaleOrderProductModel . getREAD_FLAG ( ) ) ;
businessOrderEntity . setYunguanTime ( yunguanSaleOrderProductModel . getREAD_TIME ( ) ) ;
businessOrderEntity . setYunguanMassage ( yunguanSaleOrderProductModel . getERR_MESSAGE ( ) ) ;
businessOrderService . updateById ( businessOrderEntity ) ;
}
}
}
} else if ( jsonObject . get ( "TYPE" ) . equals ( "采购入库" ) ) {
@ -894,19 +927,24 @@ public class YunguanInterfaceController {
}
QueryWrapper < WarehousingStorageProductEntity > warehousingStorageProductQueryWrapper = new QueryWrapper < > ( ) ;
warehousingStorageProductQueryWrapper . lambda ( ) . eq ( WarehousingStorageProductEntity : : getWarehousingStorageId , warehousingStorageEntity . getId ( ) ) ;
warehousingStorageProductQueryWrapper . lambda ( ) . eq ( WarehousingStorageProductEntity : : getOrdLn , yunguanPurchaseInBoundModel . getORD_LN ( ) );
warehousingStorageProductQueryWrapper . lambda ( ) . eq ( WarehousingStorageProductEntity : : getOrdLn , yunguanPurchaseInBoundModel . getORD_LN ( ) .replaceFirst ( "^0*" , "" ) );
WarehousingStorageProductEntity warehousingStorageProductEntity = warehousingStorageProductService . getOne ( warehousingStorageProductQueryWrapper ) ;
if ( ObjectUtil . isNotEmpty ( warehousingStorageProductEntity ) ) {
warehousingStorageProductEntity . setYunguanMark ( yunguanPurchaseInBoundModel . getREAD_FLAG ( ) ) ;
warehousingStorageProductEntity . setYunguanTime ( yunguanPurchaseInBoundModel . getREAD_TIME ( ) ) ;
warehousingStorageProductEntity . setYunguanMassage ( yunguanPurchaseInBoundModel . getERR_MESSAGE ( ) ) ;
warehousingStorageProductService . updateById ( warehousingStorageProductEntity ) ;
}
if ( yunguanPurchaseInBoundModel . getREAD_FLAG ( ) . equals ( "N" ) ) {
if ( StringUtils . isEmpty ( warehousingStorageEntity . getYunguanMark ( ) ) ) {
warehousingStorageEntity . setYunguanMark ( yunguanPurchaseInBoundModel . getREAD_FLAG ( ) ) ;
warehousingStorageEntity . setYunguanTime ( yunguanPurchaseInBoundModel . getREAD_TIME ( ) ) ;
warehousingStorageEntity . setYunguanMassage ( yunguanPurchaseInBoundModel . getERR_MESSAGE ( ) ) ;
warehousingStorageService . updateById ( warehousingStorageEntity ) ;
} else if ( warehousingStorageEntity . getYunguanMark ( ) . equals ( "Y" ) ) {
warehousingStorageEntity . setYunguanMark ( yunguanPurchaseInBoundModel . getREAD_FLAG ( ) ) ;
warehousingStorageEntity . setYunguanTime ( yunguanPurchaseInBoundModel . getREAD_TIME ( ) ) ;
warehousingStorageEntity . setYunguanMassage ( yunguanPurchaseInBoundModel . getERR_MESSAGE ( ) ) ;
warehousingStorageService . updateById ( warehousingStorageEntity ) ;
}
}
}
}
@ -926,10 +964,16 @@ public class YunguanInterfaceController {
warehousingOutboundProductEntity . setYunguanTime ( yunguanSaleOutBoundModel . getREAD_TIME ( ) ) ;
warehousingOutboundProductEntity . setYunguanMassage ( yunguanSaleOutBoundModel . getERR_MESSAGE ( ) ) ;
warehousingOutboundProductService . updateById ( warehousingOutboundProductEntity ) ;
if ( ! warehousingOutboundEntity . getYunguanMark ( ) . equals ( "N" ) ) {
if ( StringUtils . isEmpty ( warehousingOutboundEntity . getYunguanMark ( ) ) ) {
warehousingOutboundEntity . setYunguanMark ( yunguanSaleOutBoundModel . getREAD_FLAG ( ) ) ;
warehousingOutboundEntity . setYunguanTime ( yunguanSaleOutBoundModel . getREAD_TIME ( ) ) ;
warehousingOutboundEntity . setYunguanMassage ( yunguanSaleOutBoundModel . getERR_MESSAGE ( ) ) ;
warehousingOutboundService . updateById ( warehousingOutboundEntity ) ;
} else if ( warehousingOutboundEntity . getYunguanMark ( ) . equals ( "Y" ) ) {
warehousingOutboundEntity . setYunguanMark ( yunguanSaleOutBoundModel . getREAD_FLAG ( ) ) ;
warehousingOutboundEntity . setYunguanTime ( yunguanSaleOutBoundModel . getREAD_TIME ( ) ) ;
warehousingOutboundEntity . setYunguanMassage ( yunguanSaleOutBoundModel . getERR_MESSAGE ( ) ) ;
warehousingOutboundService . updateById ( warehousingOutboundEntity ) ;
}
}
}
@ -964,6 +1008,12 @@ public class YunguanInterfaceController {
cwsettlementsummaryEntity . setYunguanMassage ( yunguanPurchaseSettlementProductModel . getERR_MESSAGE ( ) ) ;
cwsettlementsummaryService . updateById ( cwsettlementsummaryEntity ) ;
}
if ( yunguanPurchaseSettlementProductModel . getREAD_FLAG ( ) . equals ( "N" ) ) {
cwsettlementEntity . setYunguanMark ( yunguanPurchaseSettlementProductModel . getREAD_FLAG ( ) ) ;
cwsettlementEntity . setYunguanTime ( yunguanPurchaseSettlementProductModel . getREAD_TIME ( ) ) ;
cwsettlementEntity . setYunguanMassage ( yunguanPurchaseSettlementProductModel . getERR_MESSAGE ( ) ) ;
cwsettlementService . updateById ( cwsettlementEntity ) ;
}
}
}
} else if ( jsonObject . get ( "TYPE" ) . equals ( "销售结算头" ) ) {
@ -986,9 +1036,12 @@ public class YunguanInterfaceController {
cwsettlementQueryWrapper . lambda ( ) . eq ( CwsettlementEntity : : getCode , yunguanSaleSettlementProductModel . getINVOICE_NO ( ) ) ;
CwsettlementEntity cwsettlementEntity = cwsettlementService . getOne ( cwsettlementQueryWrapper ) ;
if ( ObjectUtil . isNotEmpty ( cwsettlementEntity ) ) {
if ( StringUtils . isNotEmpty ( yunguanSaleSettlementProductModel . getATTRIBUTE4 ( ) ) ) {
int index = yunguanSaleSettlementProductModel . getATTRIBUTE4 ( ) . lastIndexOf ( "-" ) ;
String lineNo = yunguanSaleSettlementProductModel . getATTRIBUTE4 ( ) . substring ( index + 1 ) . replaceFirst ( "^0*" , "" ) ;
QueryWrapper < CwsettlementsummaryEntity > cwsettlementsummaryQueryWrapper = new QueryWrapper < > ( ) ;
cwsettlementsummaryQueryWrapper . lambda ( ) . eq ( CwsettlementsummaryEntity : : getSettlementId , cwsettlementEntity . getId ( ) ) ;
cwsettlementsummaryQueryWrapper . lambda ( ) . eq ( CwsettlementsummaryEntity : : getLineNo , yunguanSaleSettlementProductModel . getATTRIBUTE4 ( ) ) ;
cwsettlementsummaryQueryWrapper . lambda ( ) . eq ( CwsettlementsummaryEntity : : getLineNo , lineNo ) ;
CwsettlementsummaryEntity cwsettlementsummaryEntity = cwsettlementsummaryService . getOne ( cwsettlementsummaryQueryWrapper ) ;
if ( ObjectUtil . isNotEmpty ( cwsettlementsummaryEntity ) ) {
cwsettlementsummaryEntity . setYunguanMark ( yunguanSaleSettlementProductModel . getREAD_FLAG ( ) ) ;
@ -996,6 +1049,13 @@ public class YunguanInterfaceController {
cwsettlementsummaryEntity . setYunguanMassage ( yunguanSaleSettlementProductModel . getERR_MESSAGE ( ) ) ;
cwsettlementsummaryService . updateById ( cwsettlementsummaryEntity ) ;
}
if ( yunguanSaleSettlementProductModel . getREAD_FLAG ( ) . equals ( "N" ) ) {
cwsettlementEntity . setYunguanMark ( yunguanSaleSettlementProductModel . getREAD_FLAG ( ) ) ;
cwsettlementEntity . setYunguanTime ( yunguanSaleSettlementProductModel . getREAD_TIME ( ) ) ;
cwsettlementEntity . setYunguanMassage ( yunguanSaleSettlementProductModel . getERR_MESSAGE ( ) ) ;
cwsettlementService . updateById ( cwsettlementEntity ) ;
}
}
}
}
} else if ( jsonObject . get ( "TYPE" ) . equals ( "生产加工" ) ) {
@ -1005,30 +1065,39 @@ public class YunguanInterfaceController {
workOrderQueryWrapper . lambda ( ) . eq ( WorkOrderEntity : : getCode , yunguanProductProcessModel . getTASK_NO ( ) ) ;
WorkOrderEntity workOrderEntity = workOrderService . getOne ( workOrderQueryWrapper ) ;
if ( ObjectUtil . isNotEmpty ( workOrderEntity ) ) {
QueryWrapper < ProductWarehouseEntity > productQueryWrapper = new QueryWrapper < > ( ) ;
productQueryWrapper . lambda ( ) . eq ( ProductWarehouseEntity : : getCode , yunguanProductProcessModel . getITEM_CD ( ) ) ;
ProductWarehouseEntity productWarehouseEntity = productWarehouseService . getOne ( productQueryWrapper ) ;
// QueryWrapper<ProductWarehouseEntity> productQueryWrapper = new QueryWrapper<>();
// productQueryWrapper.lambda().eq(ProductWarehouseEntity::getCode,yunguanProductProcessModel.getITEM_CD());
// productQueryWrapper.lambda().isNull(ProductWarehouseEntity::getDeleteMark);
// ProductWarehouseEntity productWarehouseEntity = productWarehouseService.getOne(productQueryWrapper);
if ( StringUtils . isNotEmpty ( yunguanProductProcessModel . getPRD_TY ( ) ) & & yunguanProductProcessModel . getPRD_TY ( ) . equals ( "投入" ) ) {
QueryWrapper < WorkOrderPrimaryEntity > workOrderPrimaryQueryWrapper = new QueryWrapper < > ( ) ;
workOrderPrimaryQueryWrapper . lambda ( ) . eq ( WorkOrderPrimaryEntity : : getWorkId , workOrderEntity . getId ( ) ) ;
workOrderPrimaryQueryWrapper . lambda ( ) . eq ( WorkOrderPrimaryEntity : : get ProductId, productWarehouseEntity . getId ( ) ) ;
workOrderPrimaryQueryWrapper . lambda ( ) . eq ( WorkOrderPrimaryEntity : : get Code, yunguanProductProcessModel . getITEM_CD ( ) ) ;
WorkOrderPrimaryEntity workOrderPrimaryEntity = workOrderPrimaryService . getOne ( workOrderPrimaryQueryWrapper ) ;
if ( ObjectUtil . isNotEmpty ( workOrderPrimaryEntity ) ) {
workOrderPrimaryEntity . setYunguanMark ( yunguanProductProcessModel . getREAD_FLAG ( ) ) ;
workOrderPrimaryEntity . setYunguanTime ( yunguanProductProcessModel . getREAD_TIME ( ) ) ;
workOrderPrimaryEntity . setYunguanMassage ( yunguanProductProcessModel . getERR_MESSAGE ( ) ) ;
workOrderPrimaryService . updateById ( workOrderPrimaryEntity ) ;
workOrderEntity . setYunguanMark ( yunguanProductProcessModel . getREAD_FLAG ( ) ) ;
workOrderEntity . setYunguanTime ( yunguanProductProcessModel . getREAD_TIME ( ) ) ;
workOrderEntity . setYunguanMassage ( yunguanProductProcessModel . getERR_MESSAGE ( ) ) ;
workOrderService . updateById ( workOrderEntity ) ;
}
} else if ( StringUtils . isNotEmpty ( yunguanProductProcessModel . getPRD_TY ( ) ) & & yunguanProductProcessModel . getPRD_TY ( ) . equals ( "产出" ) ) {
QueryWrapper < WorkOrderProductEntity > workOrderProductQueryWrapper = new QueryWrapper < > ( ) ;
workOrderProductQueryWrapper . lambda ( ) . eq ( WorkOrderProductEntity : : getWorkId , workOrderEntity . getId ( ) ) ;
workOrderProductQueryWrapper . lambda ( ) . eq ( WorkOrderProductEntity : : get ProductId, productWarehouseEntity . getId ( ) ) ;
workOrderProductQueryWrapper . lambda ( ) . eq ( WorkOrderProductEntity : : get Code, yunguanProductProcessModel . getITEM_CD ( ) ) ;
WorkOrderProductEntity workOrderProductEntity = workOrderProductService . getOne ( workOrderProductQueryWrapper ) ;
if ( ObjectUtil . isNotEmpty ( workOrderProductEntity ) ) {
workOrderProductEntity . setYunguanMark ( yunguanProductProcessModel . getREAD_FLAG ( ) ) ;
workOrderProductEntity . setYunguanTime ( yunguanProductProcessModel . getREAD_TIME ( ) ) ;
workOrderProductEntity . setYunguanMassage ( yunguanProductProcessModel . getERR_MESSAGE ( ) ) ;
workOrderProductService . updateById ( workOrderProductEntity ) ;
workOrderEntity . setYunguanMark ( yunguanProductProcessModel . getREAD_FLAG ( ) ) ;
workOrderEntity . setYunguanTime ( yunguanProductProcessModel . getREAD_TIME ( ) ) ;
workOrderEntity . setYunguanMassage ( yunguanProductProcessModel . getERR_MESSAGE ( ) ) ;
workOrderService . updateById ( workOrderEntity ) ;
}
}
}