Browse Source

Merge branch 'dev' into test

test
zhenghaoyu 2 years ago
parent
commit
3423298737
  1. 5
      blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionStockArticleClient.java
  2. 6
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionStockArticleClient.java
  3. 1
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.java
  4. 4
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml
  5. 3
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionStockArticleService.java
  6. 19
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionStockArticleServiceImpl.java
  7. 3
      blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/IMtFactoryDataService.java
  8. 9
      blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/impl/MtFactoryDataServiceImpl.java
  9. 8
      blade-service/logpm-factory/src/main/java/com/logpm/factory/pan/service/impl/PanFactoryDataServiceImpl.java

5
blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionStockArticleClient.java

@ -56,5 +56,8 @@ public interface IDistributionStockArticleClient {
DistributionStockArticleEntity findByAdvanceId(@RequestParam Integer advanceId);
@PostMapping(API_PREFIX + "/saveOrUpdate")
void saveOrUpdate(DistributionStockArticleEntity distributionStockArticleEntity);
void saveOrUpdate(@RequestBody DistributionStockArticleEntity distributionStockArticleEntity);
@GetMapping(API_PREFIX + "/addHandQuantity")
void addHandQuantity(@RequestParam("id") Long id,@RequestParam("num") int num);
}

6
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionStockArticleClient.java

@ -77,4 +77,10 @@ public class DistributionStockArticleClient implements IDistributionStockArticle
distributionStockArticleService.saveOrUpdate(distributionStockArticleEntity);
}
@Override
@GetMapping(API_PREFIX + "/addHandQuantity")
public void addHandQuantity(Long id, int num) {
distributionStockArticleService.addHandQuantity(id,num);
}
}

1
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.java

@ -51,4 +51,5 @@ public interface DistributionStockArticleMapper extends BaseMapper<DistributionS
*/
List<DistributionStockArticleExcel> exportDistributionStockArticle(@Param("ew") Wrapper<DistributionStockArticleEntity> queryWrapper);
void addHandQuantity(@Param("id") Long id,@Param("num") int num);
}

4
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml

@ -50,4 +50,8 @@
SELECT * FROM logpm_distribution_stock_article ${ew.customSqlSegment}
</select>
<update id="addHandQuantity" >
update logpm_distribution_stock_article set hand_quantity = hand_quantity + #{num} where id = #{id}
</update>
</mapper>

3
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionStockArticleService.java

@ -65,4 +65,7 @@ public interface IDistributionStockArticleService extends BaseService<Distributi
Boolean saveStockRow(DistributionStockArticleDTO distributionStockArticleDTO);
R<List<DistributionStockArticleVO>> getStockArticleInfo(String ids);
void addHandQuantity(Long id, int num);
}

19
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionStockArticleServiceImpl.java

@ -16,35 +16,31 @@
*/
package com.logpm.distribution.service.impl;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
import com.logpm.basic.feign.IBasicTenantCodeClient;
import com.logpm.distribution.dto.DistributionStockArticleDTO;
import com.logpm.distribution.dto.DistributionStockDTO;
import com.logpm.distribution.entity.*;
import com.logpm.distribution.service.*;
import com.logpm.distribution.vo.DistributionStockArticleVO;
import com.logpm.distribution.excel.DistributionStockArticleExcel;
import com.logpm.distribution.mapper.DistributionStockArticleMapper;
import com.sun.org.apache.xpath.internal.operations.Bool;
import com.logpm.distribution.service.*;
import com.logpm.distribution.vo.DistributionStockArticleVO;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.Func;
import org.springblade.core.tool.utils.RandomType;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springframework.transaction.annotation.Transactional;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Random;
/**
* 配送在库订单 服务实现类
@ -242,4 +238,9 @@ public class DistributionStockArticleServiceImpl extends BaseServiceImpl<Distrib
return R.data(distributionStockArticleEntityList);
}
@Override
public void addHandQuantity(Long id, int num) {
baseMapper.addHandQuantity(id,num);
}
}

3
blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/IMtFactoryDataService.java

@ -1,5 +1,6 @@
package com.logpm.factory.mt.service;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.logpm.factory.comfac.dto.OrderInfoDTO;
import com.logpm.factory.comfac.dto.OrderStatusDTO;
import com.logpm.factory.comfac.dto.ReceiveInfoDTO;
@ -15,7 +16,7 @@ public interface IMtFactoryDataService {
R handleData(OrderInfoDTO orderInfoDTO);
R handleStatusData(OrderStatusDTO orderStatusDTO);
R handleStatusData(OrderStatusDTO orderStatusDTO) throws JsonProcessingException;
R sendReceiveInfo(ReceiveInfoDTO receiveInfoDTO);
}

9
blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/impl/MtFactoryDataServiceImpl.java

@ -6,6 +6,9 @@ import com.alibaba.fastjson.JSONObject;
import com.alibaba.nacos.shaded.com.google.gson.Gson;
import com.alibaba.nacos.shaded.com.google.gson.GsonBuilder;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.json.JsonMapper;
import com.logpm.factory.comfac.dto.*;
import com.logpm.factory.mt.dto.*;
import com.logpm.factory.mt.service.IMtFactoryDataService;
@ -239,7 +242,7 @@ public class MtFactoryDataServiceImpl implements IMtFactoryDataService {
@Override
public R handleStatusData(OrderStatusDTO orderStatusDTO) throws CustomerException {
public R handleStatusData(OrderStatusDTO orderStatusDTO) throws CustomerException, JsonProcessingException {
String status = orderStatusDTO.getStatus();
String orderNo = orderStatusDTO.getOrderNo();
@ -279,7 +282,9 @@ public class MtFactoryDataServiceImpl implements IMtFactoryDataService {
mtOrderStatusDTO.setWarehouse(mtFactoryOrderMain.getCenterWarehouseCode());
mtOrderStatusDTO.setDealerName(mtFactoryOrder.getDealerName());
String s = JSONObject.toJSONString(mtOrderStatusDTO);
ObjectMapper objectMapper = new JsonMapper();
String s = objectMapper.writeValueAsString(mtOrderStatusDTO);
//先获取token
String token = getMtToken();

8
blade-service/logpm-factory/src/main/java/com/logpm/factory/pan/service/impl/PanFactoryDataServiceImpl.java

@ -363,8 +363,6 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
distributionStockArticleEntity.setGenre(1);
distributionStockArticleEntity.setState(2);
distributionStockArticleEntity.setAdvanceId(advanceId);
logger.info("#################handleDataToPlatform: 保存新的在库订单数据 {}",distributionStockArticleEntity);
id = distributionStockArticleClient.addData(distributionStockArticleEntity);
if(id == 0){
logger.warn("#################handleDataToPlatform: 保存订单信息失败 orderSelfNum={}",orderSelfNum);
@ -386,10 +384,8 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
logger.warn("#################handleDataToPlatform: 保存包件信息失败 orderSelfNum={}",orderSelfNum);
throw new CustomerException(405,"保存包件信息失败");
}
distributionStockArticleEntity.setHandQuantity(distributionStockArticleEntity.getHandQuantity()+1);
logger.info("#################handleDataToPlatform: 更新的数据 {}",distributionStockArticleEntity);
distributionStockArticleClient.saveOrUpdate(distributionStockArticleEntity);
//包件保存成功去修改订单的数量
distributionStockArticleClient.addHandQuantity(id,1);
logger.info("#################handleDataToPlatform: 数据处理完成");
}else{

Loading…
Cancel
Save