代码备份,解决多个问题

master
anthonyywj2 3 years ago
parent b8a992ac13
commit af431517e2

@ -186,6 +186,11 @@
</dependency>
<!-- PDF打印 -->
<dependency>
<groupId>com.glxp</groupId>
<artifactId>tochina</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.itextpdf</groupId>
<artifactId>itextpdf</artifactId>
@ -265,7 +270,11 @@
<artifactId>itext-pdfa</artifactId>
<version>5.5.0</version>
</dependency>
<dependency>
<groupId>org.codehaus.groovy</groupId>
<artifactId>groovy</artifactId>
<version>3.0.7</version>
</dependency>
<dependency>
<groupId>cn.lesper</groupId>
<artifactId>iTextAsian</artifactId>

@ -11,12 +11,13 @@ import org.springframework.boot.web.servlet.support.SpringBootServletInitializer
@ServletComponentScan
public class ApiAdminApplication extends SpringBootServletInitializer {
public static void main(String[] args) {
SpringApplication.run(ApiAdminApplication.class, args);
SpringApplication application = new SpringApplication(ApiAdminApplication.class);
application.addInitializers(new ToolApplicationContextInitializer());
application.run(args);
}
@Override
protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) {
return builder.sources(ApiAdminApplication.class);

@ -0,0 +1,32 @@
package com.glxp.api;
import com.glxp.api.admin.util.HardWareUtils;
import com.glxp.api.admin.util.RsaUtils;
import org.springframework.context.ApplicationContextInitializer;
import org.springframework.context.ConfigurableApplicationContext;
public class ToolApplicationContextInitializer implements ApplicationContextInitializer {
@Override
public void initialize(ConfigurableApplicationContext configurableApplicationContext) {
String myKey = RsaUtils.readFileContent("");
System.out.println(myKey);
String publicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAtaHLiDtscnwyee4lG9jC" +
"8GUEZYIuBoz49W3GSy2LEOVpKRyiQNCjRmybvQS5qKdsb3pV720HQJnv/nQLnsg/" +
"vWbFc9L09fEeJdDZxQOf8D7CHeVgLd8+fh/GezQCVLijGlbAVORXOrFo5McdyOds" +
"LJey1x4HxIR13a79JHB7sdve14A2aS6bQ7NPWu8hM9LpJd1hylsXgdBpR+iX3DPF" +
"eep8Sx8jPnWfUfGF2pDNE3h1uz9RylGBYUz4tDPzz0IXO7vZkyUFXeslzKFDFcmh" +
"hbn1tobX+al4XvfRpjoCjST2mRfqCt4aNuBDM1LHMzyMBVJpfui91ikLGMgP4Gdf" +
"swIDAQAB";
try {
String result = RsaUtils.publicKeyDecrypt(myKey, publicKey);
String hardInfo = HardWareUtils.getMachineInfo();
// if (!result.equals(hardInfo)) {
// System.exit(1);
// }
} catch (Exception e) {
e.printStackTrace();
System.exit(1);
}
}
}

@ -0,0 +1,7 @@
package com.glxp.api.admin.constant;
public class Constant {
public static String SYSTEM_CUSTOMER_ID = "110";
public static String MUTI = "MUTI";
}

@ -11,6 +11,7 @@ public class ConstantStatus {
public static final Integer ORDER_STATUS_CHECK = 2; //等待校验
public static final Integer ORDER_STATUS_FAIL = 3; //重码校验失败
public static final Integer ORDER_STATUS_SUCCESS = 4; //已校验
public static final Integer ORDER_STATUS_ADDITIONAL = 5; //
//ERP校验状态
public static final Integer ORDER_CHECK_SUCCESS = 2; //校验成功
@ -39,7 +40,6 @@ public class ConstantStatus {
public static final Integer DI_TYPE_BZBS = 4;//包装标识
//业务单据状态
public static String SORDER_DRAFT = "1";//草稿
public static String SORDER_ALLOC = "2";//未配货
@ -56,4 +56,50 @@ public class ConstantStatus {
public static String ST_SCAN_ADD = "3"; //扫码单据转换
//业务单据详情DI绑定状态
public static int ORDER_DETAIL_DI_MUTI = 1;
public static int ORDER_DETAIL_DI_ONE = 0;
//业务单据来源
public static final int SORDER_FROM_ONLINE = 2; //在线实时拉取第三方业务单据
public static final int SORDER_FROM_CACHE = 0; //本地缓存第三方业务单据
public static final int SORDER_FROM_LOCAL = 1; //本地生成业务单据
//往来单位类型
public static final int CORP_SICK = 1; //病人
public static final int CORP_SP = 2; //供应商
public static final int CORP_INTTERNAL = 3; //内部科室等
//采购类型
public static final Integer PRUCHASE_ADVANCE = 1; //预入库
public static final Integer PRUCHASE_COMMON = 2; //普通采购
//单据来源
public static final int FROM_UDIMS = 1; //1.UDIMS平台
public static final int FROM_WEBNEW = 2; //网页新增
public static final int FROM_PDAED = 3; //pda已校验
public static final int FROM_PDAUN = 4; //pda未校验
public static final int FROM_PC = 5; //pc端扫码精灵
public static final int FROM_CHANGE = 6; //单据流转
public static final int FROM_UDISP = 7; //供应商平台
//业务单据详情DI绑定供应商状态
public static int ORDER_DETAIL_SUP_NONE = 2;
public static int ORDER_DETAIL_SUP_MUTI = 1;
public static int ORDER_DETAIL_SUP_ONE = 0;
//DI类型
public static final int DITYPE_MAIN = 1; //主标识
public static final int DITYPE_SYDY = 2; //使用单元标识
public static final int DITYPE_OWN = 3; //本体标识
public static final int DITYPE_PACK = 4; //包装标识
//
}

@ -0,0 +1,5 @@
package com.glxp.api.admin.constant;
public class RedisContant {
public static String DL_ORDER_STATUS = "udiwms_dl_order_status";
}

@ -7,11 +7,14 @@ import com.glxp.api.admin.entity.basic.BasicThirdSysDetailEntity;
import com.glxp.api.admin.entity.basic.BasicThirdSysEntity;
import com.glxp.api.admin.entity.basic.BasicUnitMaintainEntity;
import com.glxp.api.admin.entity.basic.UdiRelevanceEntity;
import com.glxp.api.admin.entity.info.CompanyEntity;
import com.glxp.api.admin.entity.info.SystemParamConfigEntity;
import com.glxp.api.admin.entity.inout.OrderEntity;
import com.glxp.api.admin.entity.thrsys.ThrCorpEntity;
import com.glxp.api.admin.httpclient.ErpBasicClient;
import com.glxp.api.admin.req.basic.*;
import com.glxp.api.admin.req.inout.DeleteRequest;
import com.glxp.api.admin.req.inout.OrderFilterRequest;
import com.glxp.api.admin.req.receipt.CombineUnitRequest;
import com.glxp.api.admin.req.thrsys.FilterThrCorpRequest;
import com.glxp.api.admin.res.PageSimpleResponse;
@ -21,6 +24,7 @@ import com.glxp.api.admin.service.basic.BasicThirdSysDetailService;
import com.glxp.api.admin.service.basic.BasicThirdSysService;
import com.glxp.api.admin.service.basic.BasicUnitMaintainService;
import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.admin.service.thrsys.ThrCorpService;
import com.glxp.api.admin.thread.BasicUnitImportService;
import com.glxp.api.admin.util.CustomUtil;
@ -59,6 +63,8 @@ public class BasicUnitMaintainController {
private ThrCorpService thrCorpService;
@Resource
BasicUnitImportService basicUnitImportService;
@Resource
private OrderService orderService;
@GetMapping("/udiwms/basic/unit/maintain/filter")
public BaseResponse filterBasicUnitMaintain(BasicUnitMaintainFilterRequest basicUnitMaintainFilterRequest,
@ -198,9 +204,9 @@ public class BasicUnitMaintainController {
}
basicUnitMaintainEntity.setErpId(CustomUtil.getId());
basicUnitMaintainEntity.setName(erpUnitsResponse.getName());
if(erpUnitsResponse.getSpell()==null || "".equals(erpUnitsResponse.getSpell())){
basicUnitMaintainEntity.setSpell(PinyinUtil.getFirstLetter(erpUnitsResponse.getName(),"").toUpperCase(Locale.ROOT));
}else{
if (erpUnitsResponse.getSpell() == null || "".equals(erpUnitsResponse.getSpell())) {
basicUnitMaintainEntity.setSpell(PinyinUtil.getFirstLetter(erpUnitsResponse.getName(), "").toUpperCase(Locale.ROOT));
} else {
basicUnitMaintainEntity.setSpell(erpUnitsResponse.getSpell());
}
basicUnitMaintainEntity.setAddr(erpUnitsResponse.getAddr());
@ -264,7 +270,7 @@ public class BasicUnitMaintainController {
basicUnitMaintainEntity.setThirdName4(erpUnitsResponse.getName());
}
}
basicUnitMaintainEntity.setThirdName(erpUnitsResponse.getName());
// basicUnitMaintainEntity.setThirdName(erpUnitsResponse.getName());
// basicUnitMaintainEntity.setSpell(erpUnitsResponse.getSpell());
// basicUnitMaintainEntity.setAddr(erpUnitsResponse.getAddr());
// basicUnitMaintainEntity.setCreditNo(erpUnitsResponse.getCreditNo());
@ -307,9 +313,17 @@ public class BasicUnitMaintainController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
String id = deleteRequest.getId();
BasicUnitMaintainEntity basicUnitMaintainEntity = basicUnitMaintainService.selectById(id);
//判断是否被单据绑定
OrderFilterRequest orderFilterRequest = new OrderFilterRequest();
orderFilterRequest.setFromCorpId(basicUnitMaintainEntity.getErpId());
OrderEntity orderEntity = orderService.findOne(orderFilterRequest);
if (orderEntity != null) {
return ResultVOUtils.error(500, "已存在该供应商单据,无法删除!");
}
basicUnitMaintainService.deleteById(id);
return ResultVOUtils.success("删除成功");
}

@ -0,0 +1,111 @@
package com.glxp.api.admin.controller.basic;
import com.glxp.api.admin.constant.ConstantType;
import com.glxp.api.admin.entity.basic.BussinessChangeTypeEntity;
import com.glxp.api.admin.entity.basic.BussinessLocalTypeEntity;
import com.glxp.api.admin.entity.basic.BussinessTypeEntity;
import com.glxp.api.admin.req.inout.DeleteRequest;
import com.glxp.api.admin.req.receipt.BussinessTypeFilterRequest;
import com.glxp.api.admin.service.basic.BussinessChangeTypeService;
import com.glxp.api.admin.service.basic.BussinessLocalTypeService;
import com.glxp.api.admin.service.basic.BussinessTypeService;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
@RestController
public class BussinessChangeTypeController {
@Resource
private BussinessChangeTypeService bussinessChangeTypeService;
@Resource
private BussinessTypeService bussinessTypeService;
@Resource
private BussinessLocalTypeService bussinessLocalTypeService;
@GetMapping("/spms/bussinessChangeType/filter")
public BaseResponse filterBussinessType(BussinessTypeFilterRequest bussinessTypeFilterRequest,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
List<BussinessChangeTypeEntity> bussinessTypeEntities;
BussinessLocalTypeEntity bussinessLocalTypeEntity = bussinessLocalTypeService.findBTByAction(bussinessTypeFilterRequest.getAction());
if (bussinessLocalTypeEntity == null) {
return ResultVOUtils.error(500, "业务单据类型错误");
}
BussinessTypeEntity bussinessTypeEntity = bussinessTypeService.findBTByAction(bussinessLocalTypeEntity.getAction());
bussinessTypeEntities = bussinessChangeTypeService.findByAction(bussinessTypeFilterRequest.getAction());
if (bussinessTypeEntities == null || bussinessTypeEntities.size() == 0) {
//创建对应流转单据
if (bussinessTypeFilterRequest.getType() != null
&& "changeEnable".equals(bussinessTypeFilterRequest.getType())
) {
if (ConstantType.TYPE_OUT.equals(bussinessTypeEntity.getMainAction())) {
bussinessTypeEntities = bussinessChangeTypeService.findByAction(bussinessTypeFilterRequest.getAction());
BussinessChangeTypeEntity bussinessChangeTypeEntity1 = new BussinessChangeTypeEntity();
bussinessChangeTypeEntity1.setIntro("出库自动补\"采购入库单\"");
bussinessChangeTypeEntity1.setIndex(1);
bussinessChangeTypeEntity1.setAction(bussinessTypeFilterRequest.getAction());
bussinessChangeTypeService.insertBusChangeTypee(bussinessChangeTypeEntity1);
}
}
}
return ResultVOUtils.success(bussinessTypeEntities);
}
@PostMapping("/spms/bussinessChangeType/delete")
public BaseResponse deleteBussinessType(@RequestBody DeleteRequest deleteRequest, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
String id = deleteRequest.getId();
bussinessChangeTypeService.deleteById(id);
return ResultVOUtils.success("删除成功");
}
@PostMapping("/spms/bussinessChangeType/update")
public BaseResponse updateBussinessType(@RequestBody BussinessChangeTypeEntity bussinessTypeEntity,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
if (bussinessTypeEntity != null) {
bussinessChangeTypeService.updateBusChangeType(bussinessTypeEntity);
} else {
ResultVOUtils.error(999, "参数错误");
}
return ResultVOUtils.success("更新成功");
}
@PostMapping("/spms/bussinessChangeType/insert")
public BaseResponse insertBussinessType(@RequestBody BussinessChangeTypeEntity
bussinessTypeEntity, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
if (bussinessTypeEntity != null) {
bussinessChangeTypeService.insertBusChangeTypee(bussinessTypeEntity);
} else {
ResultVOUtils.error(999, "参数错误");
}
return ResultVOUtils.success("添加成功");
}
}

@ -1,11 +1,19 @@
package com.glxp.api.admin.controller.basic;
import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.entity.basic.BussinessChangeTypeEntity;
import com.glxp.api.admin.entity.basic.BussinessLocalTypeEntity;
import com.glxp.api.admin.entity.business.StockOrderEntity;
import com.glxp.api.admin.req.basic.BussinessLocalTypeFilterRequest;
import com.glxp.api.admin.req.business.StockOrderFilterRequest;
import com.glxp.api.admin.req.inout.DeleteRequest;
import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.service.auth.AuthAdminService;
import com.glxp.api.admin.service.basic.BussinessChangeTypeService;
import com.glxp.api.admin.service.basic.BussinessLocalTypeService;
import com.glxp.api.admin.service.basic.BussinessTypeService;
import com.glxp.api.admin.service.business.StockOrderService;
import com.glxp.api.admin.util.CustomUtil;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
@ -21,9 +29,16 @@ import java.util.List;
@RestController
public class BussinessLocalTypeController {
@Resource
private BussinessLocalTypeService bussinessTypeService;
private BussinessChangeTypeService bussinessChangeTypeService;
@Resource
private AuthAdminService authAdminService;
@Resource
private BussinessTypeService bussinessTypeService;
@Resource
private StockOrderService stockOrderService;
@Resource
private BussinessLocalTypeService bussinessLocalTypeService;
@GetMapping("/udiwms/localBusType/filterJoin")
public BaseResponse filterJoin(BussinessLocalTypeFilterRequest bussinessTypeFilterRequest,
@ -33,7 +48,7 @@ public class BussinessLocalTypeController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
List<BussinessLocalTypeEntity> bussinessTypeEntities;
bussinessTypeEntities = bussinessTypeService.filterJoin(
bussinessTypeEntities = bussinessLocalTypeService.filterJoin(
bussinessTypeFilterRequest);
PageInfo<BussinessLocalTypeEntity> pageInfo;
pageInfo = new PageInfo<>(bussinessTypeEntities);
@ -51,7 +66,7 @@ public class BussinessLocalTypeController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
List<BussinessLocalTypeEntity> bussinessTypeEntities;
bussinessTypeEntities = bussinessTypeService.filterList(bussinessTypeFilterRequest);
bussinessTypeEntities = bussinessLocalTypeService.filterList(bussinessTypeFilterRequest);
PageInfo<BussinessLocalTypeEntity> pageInfo;
pageInfo = new PageInfo<>(bussinessTypeEntities);
PageSimpleResponse<BussinessLocalTypeEntity> pageSimpleResponse = new PageSimpleResponse<>();
@ -68,7 +83,20 @@ public class BussinessLocalTypeController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
String id = deleteRequest.getId();
bussinessTypeService.deleteById(id);
BussinessLocalTypeEntity bussinessLocalTypeEntity = bussinessLocalTypeService.selectById(id);
StockOrderFilterRequest stockOrderFilterRequest = new StockOrderFilterRequest();
stockOrderFilterRequest.setBillType(bussinessLocalTypeEntity.getAction());
StockOrderEntity stockOrderEntity = stockOrderService.findOne(stockOrderFilterRequest);
if (stockOrderEntity != null) {
return ResultVOUtils.error(500, "已存在该类型码业务单据,无法删除!");
}
BussinessChangeTypeEntity bussinessChangeTypeEntity = bussinessChangeTypeService.findFirstByAction(bussinessLocalTypeEntity.getAction());
if (bussinessChangeTypeEntity != null && bussinessChangeTypeEntity.getScAction() != null) {
return ResultVOUtils.error(500, "该业务单据类型已绑定流转单据类型,无法删除!");
}
bussinessLocalTypeService.deleteById(id);
return ResultVOUtils.success("删除成功");
}
@ -80,12 +108,34 @@ public class BussinessLocalTypeController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
if (bussinessTypeEntity != null) {
bussinessTypeService.updateBusLocalType(bussinessTypeEntity);
bussinessLocalTypeService.updateBusLocalType(bussinessTypeEntity);
} else {
ResultVOUtils.error(999, "参数错误");
}
return ResultVOUtils.success("更新成功");
}
@PostMapping("/udiwms/localBusType/add")
public BaseResponse addBussinessType(@RequestBody BussinessLocalTypeEntity bussinessTypeEntity,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
if (bussinessTypeEntity != null) {
bussinessTypeEntity.setAction("ST" + CustomUtil.getId());
BussinessLocalTypeEntity bussinessLocalTypeEntity = bussinessLocalTypeService.findBTByAction(bussinessTypeEntity.getAction());
if (bussinessLocalTypeEntity != null) {
return ResultVOUtils.error(999, "业务类型已存在!");
} else {
bussinessLocalTypeService.insertBussinessType(bussinessTypeEntity);
}
} else {
return ResultVOUtils.error(999, "参数错误");
}
return ResultVOUtils.success("更新成功");
}
}

@ -1,15 +1,19 @@
package com.glxp.api.admin.controller.basic;
import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.entity.basic.BussinessLocalTypeEntity;
import com.glxp.api.admin.entity.basic.BussinessOriginTypeEntity;
import com.glxp.api.admin.req.basic.BussinessOriginTypeFilterRequest;
import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.service.basic.BussinessOriginTypeService;
import com.glxp.api.admin.util.CustomUtil;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@ -41,4 +45,35 @@ public class BussinessOriginTypeController {
return ResultVOUtils.success(pageSimpleResponse);
}
@PostMapping("/udiwms/originBusType/update")
public BaseResponse updateBussinessType(@RequestBody BussinessOriginTypeEntity bussinessTypeEntity,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
if (bussinessTypeEntity != null) {
bussinessOriginTypeService.updateBusOriginType(bussinessTypeEntity);
} else {
ResultVOUtils.error(999, "参数错误");
}
return ResultVOUtils.success("更新成功");
}
@PostMapping("/udiwms/originBusType/add")
public BaseResponse addBussinessType(@RequestBody BussinessOriginTypeEntity bussinessTypeEntity,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
if (bussinessTypeEntity != null) {
bussinessOriginTypeService.insertBusOriginType(bussinessTypeEntity);
} else {
return ResultVOUtils.error(999, "参数错误");
}
return ResultVOUtils.success("更新成功");
}
}

@ -1,28 +1,44 @@
package com.glxp.api.admin.controller.basic;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.annotation.AuthRuleAnnotation;
import com.glxp.api.admin.constant.BussinessTypeUtils;
import com.glxp.api.admin.constant.ConstantStatus;
import com.glxp.api.admin.entity.basic.BusDataEntity;
import com.glxp.api.admin.entity.basic.BussinessTypeEntity;
import com.glxp.api.admin.entity.inout.OrderEntity;
import com.glxp.api.admin.entity.inout.WarehouseEntity;
import com.glxp.api.admin.req.inout.DeleteRequest;
import com.glxp.api.admin.req.inout.OrderFilterRequest;
import com.glxp.api.admin.req.inout.PostOrderRequest;
import com.glxp.api.admin.req.receipt.BussinessTypeFilterRequest;
import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.basic.BasicThirdSysResponse;
import com.glxp.api.admin.res.basic.BussinessTypExportResponse;
import com.glxp.api.admin.res.basic.BussinessTypResponse;
import com.glxp.api.admin.res.basic.SrBtResponse;
import com.glxp.api.admin.service.basic.BussinessTypeService;
import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.admin.util.CustomUtil;
import com.glxp.api.admin.util.FileUtils;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.stream.Collectors;
@ -36,7 +52,8 @@ public class BussinessTypeController {
@Resource
private BussinessTypeService bussinessTypeService;
@Resource
private OrderService orderService;
@GetMapping("/udiwms/bussinessType/filter")
public BaseResponse filterBussinessType(BussinessTypeFilterRequest bussinessTypeFilterRequest,
@ -57,7 +74,7 @@ public class BussinessTypeController {
@GetMapping("/udiwms/bussinessType/joinFilter")
public BaseResponse filterJoinBussinessType(BussinessTypeFilterRequest bussinessTypeFilterRequest,
BindingResult bindingResult) {
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
@ -72,10 +89,10 @@ public class BussinessTypeController {
return ResultVOUtils.success(pageSimpleResponse);
}
// @AuthRuleAnnotation("")
// @AuthRuleAnnotation("")
@GetMapping("/udiwms/bussinessType/download")
public BaseResponse downloadJoinBussinessType(BussinessTypeFilterRequest bussinessTypeFilterRequest,
BindingResult bindingResult) {
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
@ -107,6 +124,21 @@ public class BussinessTypeController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
String id = deleteRequest.getId();
BussinessTypeEntity bussinessTypeEntity = bussinessTypeService.selectById(id);
OrderFilterRequest orderFilterRequest = new OrderFilterRequest();
orderFilterRequest.setAction(bussinessTypeEntity.getAction());
OrderEntity orderEntity = orderService.findOne(orderFilterRequest);
if (orderEntity != null) {
return ResultVOUtils.error(500, "已存在该类型扫码单据,无法删除!");
}
if (bussinessTypeEntity.getLocalAction() != null && !"".equals(bussinessTypeEntity.getLocalAction())) {
return ResultVOUtils.error(500, "该扫码单据类型已绑定业务单据类型,无法删除!");
}
bussinessTypeService.deleteById(id);
return ResultVOUtils.success("删除成功");
}
@ -134,6 +166,7 @@ public class BussinessTypeController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
if (bussinessTypeEntity != null) {
bussinessTypeEntity.setAction("SC" + CustomUtil.getId());
bussinessTypeService.insertBussinessType(bussinessTypeEntity);
} else {
ResultVOUtils.error(999, "参数错误");
@ -141,4 +174,69 @@ public class BussinessTypeController {
return ResultVOUtils.success("添加成功");
}
//扫码单据类型文件导入
@PostMapping("/udiwms/busstiness/file/upload")
public BaseResponse uploadProducts(@RequestParam("file") List<MultipartFile> files) {
for (int i = 0; i < files.size(); i++) {
MultipartFile file = files.get(i);
if (file.isEmpty()) {
return ResultVOUtils.error(500, "上传第" + (i++) + "个文件失败");
}
try {
InputStream inputStream = file.getInputStream();
String json = FileUtils.readStream(inputStream);
String[] list = json.split("\r\n");
if (list != null && list.length > 0) {
for (String item : list) {
item.replace(" ", "");
String[] data = item.split(",");
BussinessTypeEntity bussinessTypeEntity = new BussinessTypeEntity();
bussinessTypeEntity.setIndex(Integer.parseInt(data[0]));
bussinessTypeEntity.setMainAction(data[1]);
bussinessTypeEntity.setAction(data[2]);
bussinessTypeEntity.setName(data[3]);
bussinessTypeService.insertIgnoreBussinessType(bussinessTypeEntity);
}
}
System.out.println(json.toUpperCase(Locale.ROOT));
} catch (Exception e) {
e.printStackTrace();
return ResultVOUtils.error(500, "文件格式错误!");
}
}
return ResultVOUtils.success("导入成功!");
}
//扫码单据类型导出
@PostMapping("udiwms/busstiness/file/export")
public void exportXml(HttpServletResponse res) {
BussinessTypeFilterRequest bussinessTypeFilterRequest = new BussinessTypeFilterRequest();
bussinessTypeFilterRequest.setEnabled(true);
List<BussinessTypeEntity> bussinessTypeEntities;
List<BussinessTypExportResponse> bussinessTypExportResponses = new ArrayList<>();
bussinessTypeEntities = bussinessTypeService.filterList(bussinessTypeFilterRequest);
for (BussinessTypeEntity bussinessTypeEntity : bussinessTypeEntities) {
BussinessTypExportResponse bussinessTypExportResponse = new BussinessTypExportResponse();
BeanUtils.copyProperties(bussinessTypeEntity, bussinessTypExportResponse);
bussinessTypExportResponses.add(bussinessTypExportResponse);
}
String json = JSONObject.toJSON(bussinessTypExportResponses).toString();
String fileName = "扫码单据类型导出" + CustomUtil.getId() + ".json";
res.setHeader("Content-disposition", "attachment;fileName=" + fileName);
res.setContentType("text/plain;charset=UTF-8");
try {
res.getOutputStream().write(json.getBytes(StandardCharsets.UTF_8));
} catch (IOException e) {
e.printStackTrace();
}
// return ResultVOUtils.success("文件生成成功!!");
}
}

@ -90,6 +90,31 @@ public class UdiRelevanceController {
}
//客户端器械信息下载
@GetMapping("/udi/udirel/bind/select")
public BaseResponse selectBindProducts(FilterUdiInfoRequest filterUdiInfoRequest,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
if (filterUdiInfoRequest.getNameCode() == null) {
return ResultVOUtils.error(500, "该产品信息未维护!");
}
List<UdiRelevanceResponse> udiRelevanceResponses = null;
udiRelevanceResponses = udiRelevanceService.filterUdiRelevance(filterUdiInfoRequest);
PageInfo<UdiRelevanceResponse> pageInfo;
pageInfo = new PageInfo<>(udiRelevanceResponses);
PageSimpleResponse<UdiRelevanceResponse> pageSimpleResponse = new PageSimpleResponse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(udiRelevanceResponses);
return ResultVOUtils.success(pageSimpleResponse);
}
//器械信息维护首页
@GetMapping("/udi/udirel/filterUdi")
public BaseResponse filterUdiGp(FilterUdiInfoRequest filterUdiInfoRequest,

@ -318,7 +318,7 @@ public class StockOrderDetailController {
}
@GetMapping("/udiwms/stock/order/detail/queryProduct")
public BaseResponse queryProduct(@RequestParam("code") String code, @RequestParam("customerId") String customerId) {
public BaseResponse queryProduct(@RequestParam("code") String code) {
UdiEntity udiEntity = null;
if (StringUtils.isNotBlank(code)) {
@ -363,7 +363,6 @@ public class StockOrderDetailController {
public BaseResponse filterProduct(FilterUdiInfoRequest filterUdiInfoRequest) {
String nameCode = null;
UdiEntity udiEntity = null;
if (filterUdiInfoRequest.getUdiCode() != null && !filterUdiInfoRequest.getUdiCode().isEmpty()) {

@ -2,14 +2,21 @@ package com.glxp.api.admin.controller.info;
import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.annotation.AuthRuleAnnotation;
import com.glxp.api.admin.entity.basic.BussinessLocalTypeEntity;
import com.glxp.api.admin.entity.info.SystemPDFModuleEntity;
import com.glxp.api.admin.entity.info.SystemPDFTemplateEntity;
import com.glxp.api.admin.entity.info.SystemPDFTemplateRelevanceEntity;
import com.glxp.api.admin.req.basic.BussinessLocalTypeFilterRequest;
import com.glxp.api.admin.req.info.SystemPDFModuleRequest;
import com.glxp.api.admin.req.info.SystemPDFModuleSaveRequest;
import com.glxp.api.admin.req.itextpdf.SystemPDFTemplateRelevanceRequest;
import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.basic.SystemPDFTemplateRelevanceResponse;
import com.glxp.api.admin.res.info.SystemPDFModuleResponse;
import com.glxp.api.admin.res.info.SystemPDFModuleSelectResponse;
import com.glxp.api.admin.service.basic.BussinessLocalTypeService;
import com.glxp.api.admin.service.info.SystemPDFModuleService;
import com.glxp.api.admin.service.info.SystemPDFTemplateRelevanceService;
import com.glxp.api.admin.service.info.SystemPDFTemplateService;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
@ -32,6 +39,12 @@ public class SystemPDFModuleController {
@Resource
private SystemPDFTemplateService systemPDFTemplateService;
@Resource
private SystemPDFTemplateRelevanceService systemPDFTemplateRelevanceService;
@Resource
BussinessLocalTypeService bussinessLocalTypeService;
@AuthRuleAnnotation("system/pdf/module/list")
@GetMapping("/system/pdf/module/list")
public BaseResponse list(@Valid SystemPDFModuleRequest systemPDFModuleRequest,
@ -62,10 +75,46 @@ public class SystemPDFModuleController {
return ResultVOUtils.success(pageSimpleResponse);
}
@AuthRuleAnnotation("system/pdf/module/detail")
@GetMapping("/system/pdf/module/detail")
public BaseResponse moduleDetail(@Valid SystemPDFTemplateRelevanceRequest systemPDFModuleRequest,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
if (systemPDFModuleRequest.getTemplateType() != null && systemPDFModuleRequest.getTemplateType() == 2) {
BussinessLocalTypeFilterRequest bussinessLocalTypeFilterRequest = new BussinessLocalTypeFilterRequest();
List<BussinessLocalTypeEntity> bussinessLocalTypeEntities = bussinessLocalTypeService.filterList(bussinessLocalTypeFilterRequest);
for (BussinessLocalTypeEntity bussinessLocalTypeEntity : bussinessLocalTypeEntities) {
SystemPDFTemplateRelevanceEntity systemPDFTemplateRelevanceEntity = new SystemPDFTemplateRelevanceEntity();
systemPDFTemplateRelevanceEntity.setLocalAction(bussinessLocalTypeEntity.getAction());
systemPDFTemplateRelevanceEntity.setModuleId(systemPDFModuleRequest.getModuleId());
systemPDFTemplateRelevanceService.insert(systemPDFTemplateRelevanceEntity);
}
List<SystemPDFTemplateRelevanceResponse> systemPDFTemplateRelevanceEntityList =
systemPDFTemplateRelevanceService.filterList(systemPDFModuleRequest);
return ResultVOUtils.success(systemPDFTemplateRelevanceEntityList);
}
return ResultVOUtils.success(null);
}
@AuthRuleAnnotation("system/pdf/module/update")
@PostMapping("/system/pdf/module/updateRl")
public BaseResponse updateRl(@RequestBody SystemPDFTemplateRelevanceEntity systemPDFModuleSaveRequest) {
systemPDFTemplateRelevanceService.udpateRl(systemPDFModuleSaveRequest);
return ResultVOUtils.success("修改成功");
}
@AuthRuleAnnotation("system/pdf/module/list")
@GetMapping("/system/pdf/module/pdfModules")
public BaseResponse pdfModules(@RequestParam(value = "page", defaultValue = "1") Integer page,
@RequestParam(value = "limit", defaultValue = "100") Integer limit) {
@RequestParam(value = "limit", defaultValue = "100") Integer limit) {
List<SystemPDFModuleEntity> systemPDFModuleEntityList = systemPDFModuleService.listPDFModules(page, limit);
PageInfo<SystemPDFModuleEntity> pageInfo = new PageInfo<>(systemPDFModuleEntityList);

@ -2,6 +2,8 @@ package com.glxp.api.admin.controller.info;
import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.annotation.AuthRuleAnnotation;
import com.glxp.api.admin.dao.schedule.ScheduledDao;
import com.glxp.api.admin.entity.info.ScheduledEntity;
import com.glxp.api.admin.entity.info.SystemParamConfigEntity;
import com.glxp.api.admin.req.info.SystemParamConfigRequest;
import com.glxp.api.admin.req.info.SystemParamConfigSaveRequest;
@ -9,6 +11,7 @@ import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.info.SystemParamConfigResponse;
import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.thread.IoModifyErpTask;
import com.glxp.api.admin.util.CronUtils;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
@ -29,6 +32,8 @@ public class SystemParamConfigController {
@Resource
private SystemParamConfigService systemParamConfigService;
@Resource
ScheduledDao scheduledDao;
@AuthRuleAnnotation("system/param/config/list")
@GetMapping("/system/param/config/list")
@ -102,7 +107,31 @@ public class SystemParamConfigController {
systemParamConfigService.updateParentId(systemParamConfigSaveRequest1);
}
//toDo //各种设置所需执行操作
//出入库新增单据校验
if (systemParamConfigSaveRequest.getParamKey().equals("io_transInout_interval")) {
try {
int time = Integer.parseInt(systemParamConfigSaveRequest.getParamValue());
String cronStr = CronUtils.parseMinuteIntervel(time);
ScheduledEntity scheduledEntity = new ScheduledEntity();
scheduledEntity.setCron(cronStr);
scheduledEntity.setCronName("transInout");
scheduledDao.modifyScheduled(scheduledEntity);
} catch (Exception e) {
return ResultVOUtils.error(500, "格式错误!");
}
} else if (systemParamConfigSaveRequest.getParamKey().equals("io_erpcheck_interval")) {
try {
int time = Integer.parseInt(systemParamConfigSaveRequest.getParamValue());
String cronStr = CronUtils.parseMinuteIntervel(time);
ScheduledEntity scheduledEntity = new ScheduledEntity();
scheduledEntity.setCron(cronStr);
scheduledEntity.setCronName("erpCheck");
scheduledDao.modifyScheduled(scheduledEntity);
} catch (Exception e) {
return ResultVOUtils.error(500, "格式错误!");
}
}
return ResultVOUtils.success("修改成功");
}

@ -0,0 +1,84 @@
package com.glxp.api.admin.controller.inout;
import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.entity.inout.ErpOrderEntity;
import com.glxp.api.admin.entity.inout.IOOrderStatusEntity;
import com.glxp.api.admin.entity.inout.OrderEntity;
import com.glxp.api.admin.entity.inout.WarehouseEntity;
import com.glxp.api.admin.req.inout.OrderStatusFilterRequest;
import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.inout.DlOrderResponse;
import com.glxp.api.admin.service.inout.CodesService;
import com.glxp.api.admin.service.inout.IOOrderStatusService;
import com.glxp.api.admin.service.inout.OrderDetailService;
import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
@RestController
public class IOOrderStatusController {
@Resource
private OrderService orderService;
@Resource
private CodesService codesService;
@Resource
private OrderDetailService orderDetailService;
@Resource
private IOOrderStatusService ioOrderStatusService;
@GetMapping("spms/inout/order/status")
public BaseResponse listOrderStatus(OrderStatusFilterRequest orderStatusFilterRequest) {
List<IOOrderStatusEntity> orderStatusEntities = ioOrderStatusService.filterOrderStatus(orderStatusFilterRequest);
PageInfo<IOOrderStatusEntity> pageInfo;
pageInfo = new PageInfo<>(orderStatusEntities);
PageSimpleResponse<IOOrderStatusEntity> pageSimpleResponse = new PageSimpleResponse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(orderStatusEntities);
return ResultVOUtils.success(pageSimpleResponse);
}
@GetMapping("spms/inout/order/dlByStatus")
public BaseResponse dlByStatus(OrderStatusFilterRequest orderStatusFilterRequest) {
List<DlOrderResponse> dlOrderResponses = new ArrayList<>();
List<IOOrderStatusEntity> orderStatusEntities = ioOrderStatusService.filterOrderStatus(orderStatusFilterRequest);
if (orderStatusEntities != null && orderStatusEntities.size() > 0) {
for (IOOrderStatusEntity orderStatusEntity : orderStatusEntities) {
DlOrderResponse dlOrderResponse = new DlOrderResponse();
OrderEntity orderEntity = orderService.findById(orderStatusEntity.getOrderId());
dlOrderResponse.setOrderEntity(orderEntity);
List<ErpOrderEntity> orderDetailEntityList = orderDetailService.filterAllByOrderIdFk(orderStatusEntity.getOrderId());
dlOrderResponse.setOrderDetails(orderDetailEntityList);
List<WarehouseEntity> codes = codesService.findByReceiptId(orderStatusEntity.getOrderId());
dlOrderResponse.setCodes(codes);
dlOrderResponses.add(dlOrderResponse);
}
}
return ResultVOUtils.success(dlOrderResponses);
}
//更新订单
@PostMapping("/spms/inout/order/deleteStatus")
public BaseResponse updateStatus(@RequestBody OrderStatusFilterRequest orderStatusFilterRequest,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
boolean b = ioOrderStatusService.deleteByOrderId(orderStatusFilterRequest.getOrderId());
if (!b) {
return ResultVOUtils.error(ResultEnum.NOT_NETWORK);
}
return ResultVOUtils.success("更新成功");
}
}

@ -19,6 +19,7 @@ import com.glxp.api.admin.service.basic.BussinessTypeService;
import com.glxp.api.admin.service.basic.UdiInfoService;
import com.glxp.api.admin.service.basic.UdiRelevanceService;
import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.service.inout.CodesTempService;
import com.glxp.api.admin.service.inout.OrderDetailService;
import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.admin.service.inout.CodesService;
@ -49,6 +50,8 @@ public class OrderController {
@Resource
private CodesService warehouseService;
@Resource
private CodesTempService codesTempService;
@Resource
private OrderDetailService myErpOrderService;
@Resource
private UdiInfoService udiInfoService;
@ -164,8 +167,90 @@ public class OrderController {
return ResultVOUtils.success("更新成功");
}
// @PostMapping("/warehouse/inout/order/mergeOrder")
// public BaseResponse mergeOrder(@RequestBody OrderMergeRequest orderMergeRequest, BindingResult bindingResult) {
//
// if (bindingResult.hasErrors()) {
// return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
// }
//
// List<String> orderList = orderMergeRequest.getOrderList();
// List<OrderEntity> mergeList = new ArrayList<>();
// if (orderList != null && orderList.size() > 1) {
// for (String orderId : orderList) {
// FilterErpOrderRequest filterErpOrderRequest = new FilterErpOrderRequest();
// filterErpOrderRequest.setOrderId(orderId);
// OrderEntity orderEntity = orderService.findById(orderId);
// if (orderEntity != null) {
// mergeList.add(orderEntity);
// }
// myErpOrderService.deleteByOrderId(orderId);
//
// }
// String mainOrder = orderList.get(0);
// for (int i = 1; i < orderList.size(); i++) {
// warehouseService.updateOrderId(orderList.get(i), mainOrder);
// orderService.deleteByOrderId(orderList.get(i));
// }
// OrderEntity mainOrderEntity = orderService.findById(mainOrder);
// BussinessTypeEntity bussinessTypeEntity = bussinessTypeService.findBTByAction(mainOrderEntity.getAction());
// List<String> docids = getDocids(mergeList);
// String docidStr = "";
// if (docids != null && docids.size() > 0) {
// for (String temp : docids) {
// docidStr = docidStr + "," + temp;
// }
// docidStr = docidStr.substring(1);
// }
// mainOrderEntity.setErpFk(docidStr);
// orderService.updateOrder(mainOrderEntity);
// if (docidStr.length() > 0) {
// BasicThirdSysDetailEntity basicThirdSysDetailEntity = bussinessTypeService.findByActionKey(mainOrderEntity.getAction(), "orderQueryUrl");
// if (basicThirdSysDetailEntity == null) {
// return ResultVOUtils.error(500, "ERP出入库单据查询接口地址未定义");
// }
// List<ErpOrderEntity> erpOrderEntities = null;
// if (basicThirdSysDetailEntity.getEnabled()) {
// if (basicThirdSysDetailEntity.getFromType() == 0) {
// erpOrderEntities = new ErpOrderClient(basicThirdSysDetailEntity.getValue()).getErpOrder(docids, mainOrderEntity.getAction());
// } else {
// erpOrderEntities = thrOrderService.filterAllOrders(docids, basicThirdSysDetailEntity.getThirdSysFk());
// }
// } else {
// return ResultVOUtils.error(500, "第三方业务单据服务未启用!");
// }
//
// if (erpOrderEntities != null && erpOrderEntities.size() > 0) {
// List<ErpOrderEntity> returnOrders = new ContrastErpUtil().transErp(erpOrderEntities, udiRelevanceService, mainOrder,bussinessTypeEntity);
// myErpOrderService.insertErpOrders(returnOrders);
// List<WarehouseEntity> warehouseEntityList = warehouseService.findByReceiptId(mainOrder);
// new ContrastErpUtil().contrastErp(udiInfoService, udiRelevanceService, myErpOrderService,
// orderService, warehouseEntityList, systemParamConfigService, erpOrderEntities);
// } else {
// mainOrderEntity.setContrastStatus(ConstantStatus.ORDER_CHECK_FAIL);
// mainOrderEntity.setRemark("获取ERP单失败");
// orderService.updateOrder(mainOrderEntity);
// List<WarehouseEntity> datas = warehouseService.findByReceiptId(mainOrder);
// inoutUtils.generateConstrastDetail(udiInfoService, udiRelevanceService, myErpOrderService, datas);
// return ResultVOUtils.error(500, "获取ERP单失败");
// }
// } else {
// new Thread(() -> {
// List<WarehouseEntity> datas = warehouseService.findByReceiptId(mainOrder);
// inoutUtils.generateConstrastDetail(udiInfoService, udiRelevanceService, myErpOrderService, datas);
// }).start();
// }
//
// } else {
// return ResultVOUtils.error(ResultEnum.DATA_ERROR);
// }
//
//
// return ResultVOUtils.success("合并成功,后台正在数据转换,请稍后刷新重试!");
// }
@PostMapping("/warehouse/inout/order/mergeOrder")
public BaseResponse mergeOrder(@RequestBody OrderMergeRequest orderMergeRequest, BindingResult bindingResult) {
public BaseResponse mergeOrders(@RequestBody OrderMergeRequest orderMergeRequest, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
@ -187,10 +272,10 @@ public class OrderController {
String mainOrder = orderList.get(0);
for (int i = 1; i < orderList.size(); i++) {
warehouseService.updateOrderId(orderList.get(i), mainOrder);
codesTempService.updateOrderId(orderList.get(i), mainOrder);
orderService.deleteByOrderId(orderList.get(i));
}
OrderEntity mainOrderEntity = orderService.findById(mainOrder);
BussinessTypeEntity bussinessTypeEntity = bussinessTypeService.findBTByAction(mainOrderEntity.getAction());
List<String> docids = getDocids(mergeList);
String docidStr = "";
if (docids != null && docids.size() > 0) {
@ -201,49 +286,9 @@ public class OrderController {
}
mainOrderEntity.setErpFk(docidStr);
orderService.updateOrder(mainOrderEntity);
if (docidStr.length() > 0) {
BasicThirdSysDetailEntity basicThirdSysDetailEntity = bussinessTypeService.findByActionKey(mainOrderEntity.getAction(), "orderQueryUrl");
if (basicThirdSysDetailEntity == null) {
return ResultVOUtils.error(500, "ERP出入库单据查询接口地址未定义");
}
List<ErpOrderEntity> erpOrderEntities = null;
if (basicThirdSysDetailEntity.getEnabled()) {
if (basicThirdSysDetailEntity.getFromType() == 0) {
erpOrderEntities = new ErpOrderClient(basicThirdSysDetailEntity.getValue()).getErpOrder(docids, mainOrderEntity.getAction());
} else {
erpOrderEntities = thrOrderService.filterAllOrders(docids, basicThirdSysDetailEntity.getThirdSysFk());
}
} else {
return ResultVOUtils.error(500, "第三方业务单据服务未启用!");
}
if (erpOrderEntities != null && erpOrderEntities.size() > 0) {
List<ErpOrderEntity> returnOrders = new ContrastErpUtil().transErp(erpOrderEntities, udiRelevanceService, mainOrder);
myErpOrderService.insertErpOrders(returnOrders);
List<WarehouseEntity> warehouseEntityList = warehouseService.findByReceiptId(mainOrder);
new ContrastErpUtil().contrastErp(udiInfoService, udiRelevanceService, myErpOrderService,
orderService, warehouseEntityList, systemParamConfigService, bussinessTypeEntity);
} else {
mainOrderEntity.setContrastStatus(ConstantStatus.ORDER_CHECK_FAIL);
mainOrderEntity.setRemark("获取ERP单失败");
orderService.updateOrder(mainOrderEntity);
List<WarehouseEntity> datas = warehouseService.findByReceiptId(mainOrder);
inoutUtils.generateConstrastDetail(udiInfoService, udiRelevanceService, myErpOrderService, datas);
return ResultVOUtils.error(500, "获取ERP单失败");
}
} else {
new Thread(() -> {
List<WarehouseEntity> datas = warehouseService.findByReceiptId(mainOrder);
inoutUtils.generateConstrastDetail(udiInfoService, udiRelevanceService, myErpOrderService, datas);
}).start();
}
} else {
return ResultVOUtils.error(ResultEnum.DATA_ERROR);
}
return ResultVOUtils.success("合并成功,后台正在数据转换,请稍后刷新重试!");
}

@ -4,7 +4,9 @@ import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.constant.ConstantStatus;
import com.glxp.api.admin.controller.inout.utils.ContrastErpUtil;
import com.glxp.api.admin.entity.basic.BasicThirdSysDetailEntity;
import com.glxp.api.admin.entity.basic.BussinessOriginTypeEntity;
import com.glxp.api.admin.entity.basic.BussinessTypeEntity;
import com.glxp.api.admin.entity.basic.UdiRelevanceEntity;
import com.glxp.api.admin.entity.business.StockOrderDetailEntity;
import com.glxp.api.admin.entity.business.StockOrderEntity;
import com.glxp.api.admin.entity.inout.*;
@ -15,9 +17,11 @@ import com.glxp.api.admin.req.business.StockOrderDetailFilterRequest;
import com.glxp.api.admin.req.business.StockOrderFilterRequest;
import com.glxp.api.admin.req.thrsys.FilterThrOrderDetailRequest;
import com.glxp.api.admin.req.thrsys.FilterThrOrderRequest;
import com.glxp.api.admin.res.basic.BussinessOriginTypeResponse;
import com.glxp.api.admin.res.inout.ErpOrderResponse;
import com.glxp.api.admin.req.inout.*;
import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.service.basic.BussinessOriginTypeService;
import com.glxp.api.admin.service.basic.BussinessTypeService;
import com.glxp.api.admin.service.basic.UdiInfoService;
import com.glxp.api.admin.service.basic.UdiRelevanceService;
@ -28,6 +32,8 @@ import com.glxp.api.admin.service.inout.*;
import com.glxp.api.admin.service.thrsys.ThrOrderDetailService;
import com.glxp.api.admin.service.thrsys.ThrOrderService;
import com.glxp.api.admin.thread.IoTransInoutService;
import com.glxp.api.admin.util.CustomUtil;
import com.glxp.api.admin.util.DateUtil;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
@ -41,6 +47,7 @@ import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
@ -76,7 +83,10 @@ public class OrderDetailController {
private StockOrderDetailService stockOrderDetailService;
@Resource
ContrastErpUtil contrastErpUtil;
@Resource
BussinessOriginTypeService bussinessOriginTypeService;
//查询本地单据和第三方单据
@GetMapping("/udiwms/erpOrder/filter")
public BaseResponse filterErpOrder(FilterOrderRequest filterErpOrderRequest,
BindingResult bindingResult) {
@ -84,10 +94,7 @@ public class OrderDetailController {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
BasicThirdSysDetailEntity basicThirdSysDetailEntity = bussinessTypeService.findByActionKey(filterErpOrderRequest.getBillAction(), "orderQueryUrl");
if (basicThirdSysDetailEntity == null || !basicThirdSysDetailEntity.getEnabled()) {
return ResultVOUtils.error(500, "第三方业务单据服务未启用");
}
@ -113,6 +120,7 @@ public class OrderDetailController {
if (basicThirdSysDetailEntity.getValue() == null) {
return ResultVOUtils.error(500, "业务单据查询接口未定义");
}
filterErpOrderRequest.setBillAction(basicThirdSysDetailEntity.getThirdAction());
BaseResponse<PageSimpleResponse<ErpOrderResponse>> baseResponse = new ErpOrderClient(basicThirdSysDetailEntity.getValue()).getErpOrderResponse(filterErpOrderRequest);
//
@ -129,6 +137,7 @@ public class OrderDetailController {
} else {
FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest();
BeanUtils.copyProperties(filterErpOrderRequest, filterThrOrderRequest);
filterThrOrderRequest.setBillAction(basicThirdSysDetailEntity.getThirdAction());
filterThrOrderRequest.setPage(filterErpOrderRequest.getPage());
filterThrOrderRequest.setLimit(filterErpOrderRequest.getLimit());
List<ErpOrderResponse> erpOrderResponses = new ArrayList<>();
@ -151,9 +160,137 @@ public class OrderDetailController {
erpOrderResponse.setSubErpOrders(subErpOrders);
erpOrderResponses.add(erpOrderResponse);
}
} else {
// if (basicThirdSysDetailEntity.getIsLocal())
// return getLoaclData(filterErpOrderRequest);
}
if (basicThirdSysDetailEntity.getLocalAction() != null) {
BaseResponse<PageSimpleResponse<ErpOrderResponse>> loca = getLoaclData(filterErpOrderRequest);
erpOrderResponses.addAll(loca.getData().getList());
}
PageInfo<ThrOrderEntity> pageInfo;
pageInfo = new PageInfo<>(data);
PageSimpleResponse<ErpOrderResponse> pageSimpleResponse = new PageSimpleResponse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(erpOrderResponses);
return ResultVOUtils.success(pageSimpleResponse);
}
}
@GetMapping("/udiwms/erpOrder/addStockOrder")
public BaseResponse addStockOrder(FilterOrderRequest filterErpOrderRequest,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
ThrOrderEntity thrOrderEntity = thrOrderService.findById(String.valueOf(filterErpOrderRequest.getId()));
if (thrOrderEntity == null) {
return ResultVOUtils.error(ResultEnum.DATA_NOT);
}
StockOrderEntity temp = stockOrderService.findByBillNo(thrOrderEntity.getBillNo() + "");
if (temp != null) {
return ResultVOUtils.error(500, "单据已被选入,请勿重复选入!");
}
StockOrderEntity stockOrderEntity = new StockOrderEntity();
BeanUtils.copyProperties(thrOrderEntity, stockOrderEntity);
String billNo = CustomUtil.getId();
stockOrderEntity.setBillNo(billNo);
BussinessOriginTypeResponse bussinessOriginTypeResponse = bussinessOriginTypeService.finAllByAction(thrOrderEntity.getBillType());
stockOrderEntity.setBillType(bussinessOriginTypeResponse.getLocalAction());
stockOrderEntity.setId(null);
stockOrderEntity.setStatus(ConstantStatus.SORDER_ALLOC);//未提交
stockOrderEntity.setThirdOrderFk(thrOrderEntity.getBillNo());
stockOrderEntity.setSourceType(ConstantStatus.ST_THIRD_SEL);//外部提交
stockOrderEntity.setPrintStatus(ConstantStatus.SORDER_PRINT_UN);//未打印
stockOrderEntity.setBilldate(DateUtil.formatDate(new Date()));
stockOrderEntity = stockOrderService.findByBillNo(billNo);
FilterThrOrderDetailRequest filterThrOrderDetailRequest = new FilterThrOrderDetailRequest();
filterThrOrderDetailRequest.setOrderIdFk(thrOrderEntity.getId() + "");
List<ThrOrderDetailEntity> thrOrderDetailEntities =
thrOrderDetailService.filterThrOrderDetailDetail(filterThrOrderDetailRequest);
if (thrOrderDetailEntities != null && thrOrderDetailEntities.size() > 0) {
List<StockOrderDetailEntity> stockOrderDetailEntityList = new ArrayList<>();
for (ThrOrderDetailEntity thrOrderDetailEntity : thrOrderDetailEntities) {
StockOrderDetailEntity stockOrderDetailEntity = new StockOrderDetailEntity();
UdiRelevanceEntity udiRelevanceEntity = udiRelevanceService.selectByThirdId(thrOrderDetailEntity.getProductId(), thrOrderDetailEntity.getThirdSysFk());
if (udiRelevanceEntity == null) {
return ResultVOUtils.error(500, "单据里含有未维护的产品信息,选入失败!");
}
BeanUtils.copyProperties(thrOrderDetailEntity, stockOrderDetailEntity);
stockOrderDetailEntity.setProductId(udiRelevanceEntity.getId());
stockOrderDetailEntity.setCount(thrOrderDetailEntity.getCount() + "");
stockOrderDetailEntity.setReCount(thrOrderDetailEntity.getReCount() + "");
stockOrderDetailEntity.setOrderIdFk(stockOrderEntity.getId());
stockOrderDetailEntity.setSweepCount(0 + "");
stockOrderDetailEntityList.add(stockOrderDetailEntity);
}
stockOrderDetailService.insertStockOrderDetails(stockOrderDetailEntityList);
}
boolean b = stockOrderService.insertStockOrder(stockOrderEntity);
return ResultVOUtils.success();
}
//只查询第三方单据
@GetMapping("/udiwms/thirdOrder/filter")
public BaseResponse filterThirdOrder(FilterOrderRequest filterErpOrderRequest,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
BasicThirdSysDetailEntity basicThirdSysDetailEntity = bussinessOriginTypeService.findSysByAction(filterErpOrderRequest.getBillAction(), "orderQueryUrl");
if (basicThirdSysDetailEntity == null || !basicThirdSysDetailEntity.getEnabled()) {
return ResultVOUtils.error(500, "第三方业务单据服务未启用");
}
if (basicThirdSysDetailEntity.getThirdSysFk() == null) {
return ResultVOUtils.error(500, "第三方业务单据服务未关联");
}
if (filterErpOrderRequest.getIsDownThrSys() != null && filterErpOrderRequest.getIsDownThrSys()) {
return new ErpOrderClient(basicThirdSysDetailEntity.getValue()).getErpOrderResponse(filterErpOrderRequest);
}
if (basicThirdSysDetailEntity.getFromType() != null && basicThirdSysDetailEntity.getFromType() == 0) {
if (basicThirdSysDetailEntity.getValue() == null) {
return ResultVOUtils.error(500, "业务单据查询接口未定义");
}
BaseResponse<PageSimpleResponse<ErpOrderResponse>> baseResponse = new ErpOrderClient(basicThirdSysDetailEntity.getValue()).getErpOrderResponse(filterErpOrderRequest);
return baseResponse;
} else {
FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest();
BeanUtils.copyProperties(filterErpOrderRequest, filterThrOrderRequest);
filterThrOrderRequest.setPage(filterErpOrderRequest.getPage());
filterThrOrderRequest.setLimit(filterErpOrderRequest.getLimit());
List<ErpOrderResponse> erpOrderResponses = new ArrayList<>();
List<ThrOrderEntity> data = thrOrderService.filterThrOrder(filterThrOrderRequest);
if (data != null && data.size() > 0) {
for (ThrOrderEntity thrOrderEntity : data) {
FilterThrOrderDetailRequest filterThrOrderDetailRequest = new FilterThrOrderDetailRequest();
filterThrOrderDetailRequest.setOrderIdFk(thrOrderEntity.getId() + "");
List<ThrOrderDetailEntity> thrOrderDetailEntities = thrOrderDetailService.filterThrOrderDetailDetail(filterThrOrderDetailRequest);
ErpOrderResponse erpOrderResponse = new ErpOrderResponse();
BeanUtils.copyProperties(thrOrderEntity, erpOrderResponse);
List<ErpOrderResponse.SubErpOrder> subErpOrders = new ArrayList<>();
if (thrOrderDetailEntities != null && thrOrderDetailEntities.size() > 0) {
for (ThrOrderDetailEntity thrOrderDetailEntity : thrOrderDetailEntities) {
ErpOrderResponse.SubErpOrder subErpOrder = new ErpOrderResponse.SubErpOrder();
BeanUtils.copyProperties(thrOrderDetailEntity, subErpOrder);
subErpOrders.add(subErpOrder);
}
}
erpOrderResponse.setSubErpOrders(subErpOrders);
erpOrderResponses.add(erpOrderResponse);
}
}
if (basicThirdSysDetailEntity.getLocalAction() != null) {
BaseResponse<PageSimpleResponse<ErpOrderResponse>> loca = getLoaclData(filterErpOrderRequest);
erpOrderResponses.addAll(loca.getData().getList());
}
PageInfo<ThrOrderEntity> pageInfo;
pageInfo = new PageInfo<>(data);
@ -186,6 +323,7 @@ public class OrderDetailController {
for (StockOrderDetailEntity thrOrderDetailEntity : thrOrderDetailEntities) {
ErpOrderResponse.SubErpOrder subErpOrder = new ErpOrderResponse.SubErpOrder();
BeanUtils.copyProperties(thrOrderDetailEntity, subErpOrder);
subErpOrder.setRelId(thrOrderDetailEntity.getProductId());
subErpOrders.add(subErpOrder);
}
}
@ -331,9 +469,12 @@ public class OrderDetailController {
erpOrderEntity.setCredate(purchaseinResponse.getBilldate());
erpOrderEntity.setGoodsid(subPurchase.getProductId());
erpOrderEntity.setGoodsname(subPurchase.getProductName());
erpOrderEntity.setRelIdFk(subPurchase.getRelId());
erpOrderEntity.setBatchNo(subPurchase.getBatchNo());
erpOrderEntity.setErpCount(Math.abs(subPurchase.getCount()));
erpOrderEntity.setReCount(Math.abs(subPurchase.getReCount()));
if (subPurchase.getCount() != null)
erpOrderEntity.setErpCount(Math.abs(Integer.parseInt(subPurchase.getCount())));
if (subPurchase.getReCount() != null)
erpOrderEntity.setReCount(Math.abs(Integer.parseInt(subPurchase.getReCount())));
erpOrderEntity.setGoodsunit(subPurchase.getSpec());
erpOrderEntities.add(erpOrderEntity);
}
@ -361,15 +502,10 @@ public class OrderDetailController {
orderEntity.setErpFk(docidStr);
orderService.updateOrder(orderEntity);
}
myErpOrderService.deleteByOrderId(importErpOrderRequest.getOrderId());
List<ErpOrderEntity> returnOrders = contrastErpUtil.transErp(erpOrderEntities, udiRelevanceService, importErpOrderRequest.getOrderId());
myErpOrderService.insertErpOrders(returnOrders);
List<ErpOrderEntity> returnOrders = contrastErpUtil.transErp(erpOrderEntities, udiRelevanceService, importErpOrderRequest.getOrderId(), bussinessTypeEntity);
List<WarehouseEntity> warehouseEntityList = warehouseService.findByReceiptId(importErpOrderRequest.getOrderId());
contrastErpUtil.contrastErp(udiInfoService, udiRelevanceService,
myErpOrderService, orderService, warehouseEntityList, systemParamConfigService, bussinessTypeEntity);
myErpOrderService, orderService, warehouseEntityList, systemParamConfigService, returnOrders);
} else {
return ResultVOUtils.error(500, "ERP订单不能为空");
}
@ -377,6 +513,40 @@ public class OrderDetailController {
return ResultVOUtils.success("导入成功");
}
@PostMapping("/udiwms/erpOrder/updateBind")
public BaseResponse updateBind(@RequestBody ErpOrderEntity erpOrderEntity, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
ErpOrderEntity erpOrderEntity1 = myErpOrderService.findById(erpOrderEntity.getId() + "");
warehouseService.updateRelId(erpOrderEntity.getBindRlFk(), erpOrderEntity1.getNameCode(), erpOrderEntity1.getOrderIdFk());
boolean b = myErpOrderService.updateErpOrder(erpOrderEntity);
if (b) {
return ResultVOUtils.success("绑定成功");
} else {
return ResultVOUtils.error(500, "绑定失败");
}
}
@PostMapping("/udiwms/erpOrder/updateBindSup")
public BaseResponse updateBindSup(@RequestBody ErpOrderEntity erpOrderEntity, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
erpOrderEntity.setBindSupStatus(ConstantStatus.ORDER_DETAIL_SUP_ONE);
boolean b = myErpOrderService.updateErpOrder(erpOrderEntity);
erpOrderEntity = myErpOrderService.findById(erpOrderEntity.getId() + "");
warehouseService.updateSupId(erpOrderEntity.getSupId(), erpOrderEntity.getNameCode(), erpOrderEntity.getOrderIdFk());
if (b) {
return ResultVOUtils.success("绑定成功");
} else {
return ResultVOUtils.error(500, "绑定失败");
}
}
@PostMapping("/warehouse/repeatCheck")
public BaseResponse repeatCheck(@RequestBody FilterErpOrderRequest filterErpOrderRequest, BindingResult bindingResult) {

@ -1,6 +1,8 @@
package com.glxp.api.admin.controller.inout;
import com.alibaba.fastjson.JSON;
import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.constant.Constant;
import com.glxp.api.admin.constant.ConstantStatus;
import com.glxp.api.admin.entity.basic.BussinessTypeEntity;
import com.glxp.api.admin.entity.basic.UdiEntity;
@ -15,6 +17,7 @@ import com.glxp.api.admin.service.inout.CodesService;
import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.admin.thread.IoTransInoutService;
import com.glxp.api.admin.util.DateUtil;
import com.glxp.api.admin.util.FileUtils;
import com.glxp.api.admin.util.FilterUdiUtils;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
@ -23,8 +26,11 @@ import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@ -132,7 +138,7 @@ public class WareHouseController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
try {
transInoutService.creatOrder(postOrderRequest);
transInoutService.creatOrderAsycn(postOrderRequest, null);
} catch (Exception e) {
return ResultVOUtils.error(ResultEnum.NOT_NETWORK);
}
@ -169,7 +175,7 @@ public class WareHouseController {
List<PostOrderRequest.PostOrder> postOrders = new ArrayList<>();
postOrders.add(postOrder);
commit.setPostOrder(postOrders);
transInoutService.creatOrder(commit);
transInoutService.creatOrderAsycn(commit, ConstantStatus.FROM_PC);
} catch (Exception e) {
return ResultVOUtils.error(ResultEnum.NOT_NETWORK);
}
@ -202,7 +208,7 @@ public class WareHouseController {
if (StringUtils.isBlank(code)) return ResultVOUtils.error(ResultEnum.DATA_ERROR);
UdiEntity udiEntity = FilterUdiUtils.getUdi(code);
if (udiEntity == null)
return ResultVOUtils.error(500,"UDI码格式错误");
return ResultVOUtils.error(500, "UDI码格式错误");
String orderId = addOrderRequest.getOrderId();
if (StringUtils.isBlank(orderId)) {
orderId = System.currentTimeMillis() + new Random().nextInt(10) + "";
@ -220,7 +226,7 @@ public class WareHouseController {
orderSaveRequest.setCorpOrderId(addOrderRequest.getCorpOrderId());
orderSaveRequest.setFromCorpId(addOrderRequest.getFromCorpId());
orderSaveRequest.setFromCorp(addOrderRequest.getFromCorp());
orderSaveRequest.setFromType(addOrderRequest.getFromType());
orderSaveRequest.setFromType(ConstantStatus.FROM_WEBNEW);
orderSaveRequest.setStatus(ConstantStatus.ORDER_STATUS_TEMP_SAVE);
orderSaveRequest.setExportStatus(ConstantStatus.ORDER_EXPORT_UN);
orderSaveRequest.setContrastStatus(ConstantStatus.ORDER_CHECK_UN);
@ -249,6 +255,7 @@ public class WareHouseController {
warehouseEntity.setMainAction(bussinessTypeEntity.getMainAction());
warehouseEntity.setAction(addOrderRequest.getAction());
warehouseEntity.setActor(addOrderRequest.getActor());
warehouseEntity.setNameCode(udiEntity.getUdi());
warehouseEntity.setFromCorpId(addOrderRequest.getFromCorpId());
warehouseEntity.setFromCorp(addOrderRequest.getFromCorp());
warehouseEntity.setBatchNo(udiEntity.getBatchNo());
@ -285,6 +292,27 @@ public class WareHouseController {
}
//往来单位信息文件导入
@PostMapping("/udiwms/orders/file/upload")
public BaseResponse uploadProducts(@RequestParam("file") List<MultipartFile> files) {
for (int i = 0; i < files.size(); i++) {
MultipartFile file = files.get(i);
if (file.isEmpty()) {
return ResultVOUtils.error(500, "上传第" + (i++) + "个文件失败");
}
try {
InputStream inputStream = file.getInputStream();
String json = FileUtils.readStream(inputStream);
PostOrderRequest postOrderRequest = (PostOrderRequest) JSON.parseObject(json, PostOrderRequest.class);
transInoutService.creatOrderAsycn(postOrderRequest, ConstantStatus.FROM_UDISP);
} catch (IOException e) {
e.printStackTrace();
}
}
return ResultVOUtils.success("后台正在生成导入生成订单,请稍后查看!");
}
@GetMapping("warehouse/inout/submitOrderWeb")
public BaseResponse submitOrderWeb(@RequestParam("orderId") String orderId) {
orderService.updateOrderStatus(orderId, ConstantStatus.ORDER_STATUS_PROCESS);

@ -18,9 +18,12 @@ import com.glxp.api.admin.service.basic.CustomService;
import com.glxp.api.admin.service.basic.UdiInfoService;
import com.glxp.api.admin.service.basic.UdiRelevanceService;
import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.service.inout.CodesService;
import com.glxp.api.admin.service.inout.OrderDetailService;
import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.admin.thread.InvProductsTrService;
import com.glxp.api.admin.thread.IoTransInoutService;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@ -33,7 +36,6 @@ import java.util.Map;
public class ContrastErpUtil {
int erpTotalCount;
List<ErpOrderEntity> mErpOrderEntities;
String udiUrl = "";
@Resource
InvProductsTrService invProductsTrService;
@ -41,6 +43,16 @@ public class ContrastErpUtil {
CustomService customService;
@Resource
InoutUtils inoutUtils;
@Resource
UdiRelevanceService udiRelevanceService;
@Resource
private OrderDetailService myErpOrderService;
@Resource
private CodesService codesService;
@Resource
private OrderService orderService;
@Resource
IoTransInoutService ioTransInoutService;
public ContrastErpUtil() {
@ -53,60 +65,103 @@ public class ContrastErpUtil {
public void contrastErp(UdiInfoService udiInfoService, UdiRelevanceService udiRelevanceService,
OrderDetailService myErpOrderService,
OrderService orderService,
List<WarehouseEntity> warehouseEntityList, SystemParamConfigService setupService, BussinessTypeEntity bussinessTypeEntity) {
List<WarehouseEntity> warehouseEntityList,
SystemParamConfigService setupService, List<ErpOrderEntity> vailErpOrders) {
//获取订单
String orderIdFk = warehouseEntityList.get(0).getOrderId();
OrderFilterRequest orderFilterRequest = new OrderFilterRequest();
orderFilterRequest.setId(orderIdFk);
OrderEntity orderEntity = orderService.findOne(orderFilterRequest);
//获取生成的本地单据详情,未校验
FilterErpOrderRequest filterErpOrderRequest = new FilterErpOrderRequest();
filterErpOrderRequest.setOrderId(orderIdFk);
mErpOrderEntities = myErpOrderService.filterAllMyErpOrder(filterErpOrderRequest);
if (mErpOrderEntities != null && mErpOrderEntities.size() > 0)
for (ErpOrderEntity erpOrderEntity : mErpOrderEntities) {
List<ErpOrderEntity> orderDetails = myErpOrderService.filterAllMyErpOrder(filterErpOrderRequest);
//校验本地单据详情是否有包含一个di多个绑定
String errMsg = null;
errMsg = vailMutiDi(orderDetails);
if (errMsg != null) {
orderEntity.setStatus(ConstantStatus.ORDER_STATUS_SUCCESS);
orderEntity.setContrastStatus(ConstantStatus.ORDER_CHECK_FAIL);
orderEntity.setRemark(errMsg);
orderService.updateOrder(orderEntity);
return;
}
//为每个条码赋值:基础信息表主键
// for (WarehouseEntity warehouseEntity : warehouseEntityList) {
// for (ErpOrderEntity erpOrderEntity : orderDetails) {
// if ((erpOrderEntity.getNameCode() != null && erpOrderEntity.getNameCode().equals(warehouseEntity.getNameCode()))
// && (erpOrderEntity.getBatchNo() != null && erpOrderEntity.getBatchNo().equals(warehouseEntity.getBatchNo()))
// && (erpOrderEntity.getWarehouseCode() != null && erpOrderEntity.getWarehouseCode().equals(warehouseEntity.getWarehouseCode()))) {
// if (erpOrderEntity.getBindRlFk() != null) {
// warehouseEntity.setRelId(erpOrderEntity.getBindRlFk());
// } else {
// warehouseEntity.setRelId(erpOrderEntity.getRelIdFk());
// }
// }
//
// }
// }
//初始化,并计算扫码总数
if (vailErpOrders != null && vailErpOrders.size() > 0) {
for (ErpOrderEntity erpOrderEntity : vailErpOrders) {
if (erpOrderEntity.getErpCount() == null) {
erpOrderEntity.setErpCount(0);
}
erpTotalCount = erpTotalCount + erpOrderEntity.getErpCount();
erpOrderEntity.setCount(0);
}
String errMsg = null;
String resultMsg = null;
}
//校验单据是否已被校验
ErpOrderEntity vailExitMsg = vailErpExit(myErpOrderService, vailErpOrders, orderIdFk);
SystemParamConfigEntity systemParamConfigEntity = setupService.selectByParamKey("erp_forbidSameErp");
if (vailExitMsg != null && systemParamConfigEntity != null && systemParamConfigEntity.getParamValue().equals("1")) {
errMsg = "所选ERP单" + vailExitMsg.getErpOrderId() + "已被其他出入库单" + vailExitMsg.getOrderIdFk() + "绑定!";
returnData(errMsg, orderEntity);
return;
}
List<WarehouseEntity> errorData = new ArrayList<>();
for (WarehouseEntity warehouseEntity : warehouseEntityList) {
UdiInfoEntity udiInfoEntity = inoutUtils.getUdiInfo(udiInfoService, udiRelevanceService, warehouseEntity.getCode());
// if (warehouseEntity.getCount() > 1) {
// udiInfoEntity.setCount(warehouseEntity.getCount());
// }
//根据条码获取产品详情,数量等
UdiInfoEntity udiInfoEntity = inoutUtils.getUdiInfoByRlId(udiInfoService, udiRelevanceService, warehouseEntity.getCode());
udiInfoEntity.setCount(customService.getActCount(warehouseEntity));
List<UdiRelevanceEntity> udiRelevanceEntities = udiRelevanceService.selectByUuid(udiInfoEntity.getUuid());
if (udiRelevanceEntities != null && udiRelevanceEntities.size() > 0) {
UdiRelevanceEntity udiRelevanceEntity = checkGoodsId(udiRelevanceEntities, bussinessTypeEntity);
if (udiRelevanceEntity != null) {
udiInfoEntity.setThirdId(udiRelevanceEntity.getThirdId());
udiInfoEntity.setThirdName(udiRelevanceEntity.getThirdName());
udiInfoEntity.setWarehouseCode(warehouseEntity.getWarehouseCode());
errMsg = vaildErpOrder(warehouseEntityList, udiInfoEntity);
if (errMsg != null && (errMsg.equals("产品信息不匹配") || errMsg.equals("非此单产品批次号"))) {
errorData.add(warehouseEntity);
}
} else {
errMsg = "产品信息不匹配";
if (warehouseEntity.getRelId() == null) {
errMsg = warehouseEntity.getCode() + "产品信息未维护";
returnData(errMsg, orderEntity);
return;
}
UdiRelevanceResponse udiRelevanceEntity = udiRelevanceService.selectGroupById(warehouseEntity.getRelId());
if (udiRelevanceEntity != null) {
udiInfoEntity.setThirdId(udiRelevanceEntity.getThirdId());
udiInfoEntity.setThirdName(udiRelevanceEntity.getThirdName());
udiInfoEntity.setWarehouseCode(warehouseEntity.getWarehouseCode());
udiInfoEntity.setRelId(udiRelevanceEntity.getId() + "");
errMsg = vaildErpOrder(vailErpOrders, warehouseEntityList, udiInfoEntity);
if (errMsg != null && (errMsg.equals("产品信息不匹配") || errMsg.equals("非此单产品批次号"))) {
errorData.add(warehouseEntity);
}
} else {
errMsg = "产品信息未维护";
errorData.add(warehouseEntity);
}
if (resultMsg == null && errMsg != null) {
resultMsg = errMsg;
if (errMsg != null) {
returnData(errMsg, orderEntity);
}
}
myErpOrderService.insertErpOrders(mErpOrderEntities);
OrderFilterRequest orderFilterRequest = new OrderFilterRequest();
orderFilterRequest.setId(orderIdFk);
OrderEntity orderEntity = orderService.findOne(orderFilterRequest);
ErpOrderEntity vailExitMsg = vailErpExit(myErpOrderService, mErpOrderEntities, orderIdFk);
SystemParamConfigEntity systemParamConfigEntity = setupService.selectByParamKey("erp_forbidSameErp");
if (vailExitMsg != null && systemParamConfigEntity != null && systemParamConfigEntity.getParamValue().equals("1")) {
errMsg = "所选ERP单" + vailExitMsg.getErpOrderId() + "已被其他出入库单" + vailExitMsg.getOrderIdFk() + "绑定!";
}
if (mErpOrderEntities != null && mErpOrderEntities.size() > 0)
for (ErpOrderEntity erpOrderEntity : mErpOrderEntities) {
myErpOrderService.deleteByOrderId(orderIdFk);
myErpOrderService.insertErpOrders(vailErpOrders);
if (vailErpOrders != null && vailErpOrders.size() > 0)
for (ErpOrderEntity erpOrderEntity : vailErpOrders) {
if (erpOrderEntity.getErpCount() != erpOrderEntity.getCount()) {
errMsg = "所选ERP单" + erpOrderEntity.getErpOrderId() + "下" + erpOrderEntity.getGoodsname() + "数量不匹配";
}
@ -115,61 +170,59 @@ public class ContrastErpUtil {
if (errMsg != null) {
orderEntity.setContrastStatus(ConstantStatus.ORDER_CHECK_FAIL);
orderEntity.setRemark(errMsg);
orderEntity.setStatus(ConstantStatus.ORDER_STATUS_SUCCESS);
orderService.updateOrder(orderEntity);
} else {
orderEntity.setContrastStatus(ConstantStatus.ORDER_CHECK_SUCCESS);
orderEntity.setStatus(ConstantStatus.ORDER_STATUS_SUCCESS);
orderService.updateOrder(orderEntity);
ioTransInoutService.printOrder(orderEntity.getId());
invProductsTrService.genInvProducts(orderEntity.getId());
}
orderEntity.setStatus(ConstantStatus.ORDER_STATUS_SUCCESS);
orderService.updateOrder(orderEntity);
if (errorData.size() > 0) {
inoutUtils.generateConstrastDetail(udiInfoService, udiRelevanceService, myErpOrderService, errorData);
}
}
public UdiRelevanceEntity checkGoodsId(List<UdiRelevanceEntity> udiRelevanceEntities, BussinessTypeEntity bussinessTypeEntity) {
if (mErpOrderEntities.size() > 0) {
for (ErpOrderEntity erpOrderEntity : mErpOrderEntities) {
for (UdiRelevanceEntity udiRelevanceEntity : udiRelevanceEntities) {
if (bussinessTypeEntity.getThirdSysFk() == null) {
if (erpOrderEntity.getGoodsid().equals(udiRelevanceEntity.getThirdId())) {
return udiRelevanceEntity;
}
} else if (bussinessTypeEntity.getThirdSysFk().equals("thirdId")) {
if (erpOrderEntity.getGoodsid().equals(udiRelevanceEntity.getThirdId())) {
return udiRelevanceEntity;
}
} else if (bussinessTypeEntity.getThirdSysFk().equals("thirdId1")) {
if (erpOrderEntity.getGoodsid().equals(udiRelevanceEntity.getThirdId1())) {
udiRelevanceEntity.setThirdId(udiRelevanceEntity.getThirdId1());
udiRelevanceEntity.setThirdName(udiRelevanceEntity.getThirdName1());
return udiRelevanceEntity;
}
} else if (bussinessTypeEntity.getThirdSysFk().equals("thirdId2")) {
if (erpOrderEntity.getGoodsid().equals(udiRelevanceEntity.getThirdId2())) {
udiRelevanceEntity.setThirdId(udiRelevanceEntity.getThirdId2());
udiRelevanceEntity.setThirdName(udiRelevanceEntity.getThirdName2());
return udiRelevanceEntity;
}
} else if (bussinessTypeEntity.getThirdSysFk().equals("thirdId3")) {
if (erpOrderEntity.getGoodsid().equals(udiRelevanceEntity.getThirdId3())) {
udiRelevanceEntity.setThirdId(udiRelevanceEntity.getThirdId3());
udiRelevanceEntity.setThirdName(udiRelevanceEntity.getThirdName3());
return udiRelevanceEntity;
}
} else if (bussinessTypeEntity.getThirdSysFk().equals("thirdId4")) {
if (erpOrderEntity.getGoodsid().equals(udiRelevanceEntity.getThirdId4())) {
udiRelevanceEntity.setThirdId(udiRelevanceEntity.getThirdId4());
udiRelevanceEntity.setThirdName(udiRelevanceEntity.getThirdName4());
return udiRelevanceEntity;
}
}
public void returnData(String errMsg, OrderEntity orderEntity) {
if (errMsg != null) {
orderEntity.setStatus(ConstantStatus.ORDER_STATUS_SUCCESS);
orderEntity.setContrastStatus(ConstantStatus.ORDER_CHECK_FAIL);
orderEntity.setRemark(errMsg);
orderService.updateOrder(orderEntity);
}
}
public String vailMutiDi(List<ErpOrderEntity> mErpOrderEntities) {
String errMsg = null;
for (ErpOrderEntity erpOrderEntity : mErpOrderEntities) {
// FilterUdiInfoRequest filterUdiInfoRequest = new FilterUdiInfoRequest();
// filterUdiInfoRequest.setNameCode(erpOrderEntity.getNameCode());
// List<UdiRelevanceResponse> udiRelevanceEntities = udiRelevanceService.filterUdiRelevance(filterUdiInfoRequest);
WarehouseEntity warehouseEntity = codesService.findOneByNameCode(erpOrderEntity.getOrderIdFk(), erpOrderEntity.getNameCode());
if (warehouseEntity != null && warehouseEntity.getStatus() == ConstantStatus.ORDER_DETAIL_DI_MUTI) {
// erpOrderEntity.setBindStatus(ConstantStatus.ORDER_DETAIL_DI_MUTI);
// myErpOrderService.updateErpOrder(erpOrderEntity);
if (warehouseEntity.getRelId() == null) {
errMsg = "该产品DI绑定多个产品ID请在扫码单据详情绑定对应产品ID";
}
}
// if (udiRelevanceEntities != null && udiRelevanceEntities.size() > 1 && warehouseEntity.getRelId() == null) {
// erpOrderEntity.setBindStatus(ConstantStatus.ORDER_DETAIL_DI_MUTI);
// myErpOrderService.updateErpOrder(erpOrderEntity);
// errMsg = "该产品DI绑定多个产品ID请在扫码单据详情绑定对应产品ID";
// }
}
return null;
return errMsg;
}
public int getSelectedCount(List<WarehouseEntity> warehouseEntityList) {
int total = 0;
for (WarehouseEntity warehouseEntity : warehouseEntityList) {
@ -179,7 +232,7 @@ public class ContrastErpUtil {
}
//验证产品ID,批次号,仓位号
public String vaildErpOrder(List<WarehouseEntity> warehouseEntityList, UdiInfoEntity udiInfoEntity) {
public String vaildErpOrder(List<ErpOrderEntity> mErpOrderEntities, List<WarehouseEntity> warehouseEntityList, UdiInfoEntity udiInfoEntity) {
String errMsg = "产品信息不匹配";
if (mErpOrderEntities.size() > 0) {
for (ErpOrderEntity erpOrderEntity : mErpOrderEntities) {
@ -205,7 +258,7 @@ public class ContrastErpUtil {
public String isPass(ErpOrderEntity erpOrderEntity, UdiInfoEntity udiInfoEntity) {
String errMsg = null;
if (erpOrderEntity.getBatchNo().equals(udiInfoEntity.getBatchNo())) {
if (erpOrderEntity.getGoodsid().equals(udiInfoEntity.getThirdId())) {
if (erpOrderEntity.getRelIdFk().equals(udiInfoEntity.getRelId())) {
if (erpOrderEntity.getWarehouseCode() != null && udiInfoEntity.getWarehouseCode() != null) {
if (erpOrderEntity.getWarehouseCode().equals(udiInfoEntity.getWarehouseCode())) {
return null;
@ -221,32 +274,37 @@ public class ContrastErpUtil {
return errMsg;
}
public List<ErpOrderEntity> transErp(List<ErpOrderEntity> erpOrderEntities, UdiRelevanceService udiRelevanceService, String orderFk) {
//把第三方单据加工转换,新增属性
public List<ErpOrderEntity> transErp(List<ErpOrderEntity> erpOrderEntities, UdiRelevanceService udiRelevanceService, String orderFk, BussinessTypeEntity bussinessTypeEntity) {
List<ErpOrderEntity> returnOrders = new ArrayList<>();
Map<String, ErpOrderEntity> filterMap = new HashMap<>();
if (erpOrderEntities != null && erpOrderEntities.size() > 0) {
for (ErpOrderEntity erpOrderEntity : erpOrderEntities) {
UdiRelevanceResponse udiRelevanceResponse = null;
if (erpOrderEntity.getRelIdFk() != null) {
udiRelevanceResponse = udiRelevanceService.selectGroupById(erpOrderEntity.getRelIdFk());
} else {
UdiRelevanceEntity udiRelevanceEntity = udiRelevanceService.selectByThirdId(erpOrderEntity.getGoodsid(), bussinessTypeEntity.getThirdSys());
if (udiRelevanceEntity != null) {
udiRelevanceResponse = udiRelevanceService.selectGroupById(udiRelevanceEntity.getId());
erpOrderEntity.setRelIdFk(udiRelevanceEntity.getId());
}
FilterUdiInfoRequest filterUdiInfoRequest = new FilterUdiInfoRequest();
filterUdiInfoRequest.setThirdId(erpOrderEntity.getGoodsid());
filterUdiInfoRequest.setPage(1);
filterUdiInfoRequest.setLimit(100);
List<UdiRelevanceResponse> udiRelevanceResponses = udiRelevanceService.filterUdiRelevance(filterUdiInfoRequest);
if (udiRelevanceResponses != null && udiRelevanceResponses.size() > 0) {
UdiRelevanceResponse temp = udiRelevanceResponses.get(0);
erpOrderEntity.setCoName(temp.getCpmctymc());
erpOrderEntity.setAuthCode(temp.getZczbhhzbapzbh());
erpOrderEntity.setPackSpec(temp.getGgxh());
erpOrderEntity.setPackRatio(temp.getPackRatio());
erpOrderEntity.setProductCompany(temp.getYlqxzcrbarmc());
}
if (udiRelevanceResponse != null) {
erpOrderEntity.setNameCode(udiRelevanceResponse.getNameCode());
erpOrderEntity.setCoName(udiRelevanceResponse.getCpmctymc());
erpOrderEntity.setAuthCode(udiRelevanceResponse.getZczbhhzbapzbh());
erpOrderEntity.setPackSpec(udiRelevanceResponse.getGgxh());
erpOrderEntity.setPackRatio(udiRelevanceResponse.getPackRatio());
erpOrderEntity.setProductCompany(udiRelevanceResponse.getYlqxzcrbarmc());
erpOrderEntity.setOrderIdFk(orderFk);
}else {
} else {
erpOrderEntity.setCoName(erpOrderEntity.getGoodsname());
erpOrderEntity.setPackSpec(erpOrderEntity.getGoodsunit());
}
erpOrderEntity.setOrderIdFk(orderFk);
String key = erpOrderEntity.getBatchNo() + erpOrderEntity.getGoodsid() + erpOrderEntity.getWarehouseCode();
String key = erpOrderEntity.getBatchNo() + erpOrderEntity.getRelIdFk() + erpOrderEntity.getWarehouseCode();
ErpOrderEntity filterTemp = filterMap.get(key);
if (filterTemp != null) {
filterTemp.setErpCount(filterTemp.getErpCount() + erpOrderEntity.getErpCount());
@ -294,8 +352,8 @@ public class ContrastErpUtil {
FilterErpOrderRequest filterErpOrderRequest = new FilterErpOrderRequest();
filterErpOrderRequest.setOrderId(orderId);
List<ErpOrderEntity> docids = myErpOrderService.filterAllDocidE(filterErpOrderRequest);
List<String> bDocids = getDocids(erpOrderEntities);
if (docids != null && docids.size() > 0) {
List<String> bDocids = getDocids(erpOrderEntities);
for (ErpOrderEntity docid : docids) {
for (String temp : bDocids) {
if (docid.getErpOrderId() != null && docid.getErpOrderId().contains(temp)) {

@ -17,6 +17,8 @@ import com.glxp.api.admin.service.inout.OrderDetailService;
import com.glxp.api.admin.service.inout.CodesService;
import com.glxp.api.admin.util.DateUtil;
import com.glxp.api.admin.util.FilterUdiUtils;
import org.apache.bcel.classfile.Code;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
@ -31,6 +33,8 @@ public class InoutUtils {
@Resource
CustomService customService;
@Resource
CodesService codesService;
@Value("${UDI_SERVER_URL}")
private String udiUrl;
@ -153,30 +157,61 @@ public class InoutUtils {
UdiRelevanceEntity udiRelevanceEntity = new UdiRelevanceEntity();
udiRelevanceEntity.setUuid(udiInfoEntity.getUuid());
udiRelevanceEntity.setUpdateTime(DateUtil.getDateTime());
udiRelevanceEntity.setThirdId(udiInfoEntity.getThirdId());
udiRelevanceEntity.setThirdName(udiInfoEntity.getThirdName());
udiRelevanceService.insertUdiRelevance(udiRelevanceEntity);
List<UdiRelevanceEntity> udiRelevanceEntities = udiRelevanceService.selectByUuid(udiInfoEntity.getUuid());
udiInfoEntity.setRelId(udiRelevanceEntities.get(0).getId());
} else {
udiInfoEntity = new UdiInfoEntity();
}
}
udiInfoEntity.setCode(code);
udiInfoEntity = FilterUdiUtils.transUdi(udiInfoEntity);
return udiInfoEntity;
}
public UdiInfoEntity getUdiInfoByRlId(UdiInfoService udiInfoService, UdiRelevanceService udiRelevanceService, String code) {
String prefix;
prefix = FilterUdiUtils.getDiStr(code);
UdiInfoEntity udiInfoEntity = new UdiInfoEntity();
UdiRelevanceResponse udiRelevanceResponse = udiRelevanceService.selectByNameCode(prefix);
if (udiRelevanceResponse == null) {
udiRelevanceResponse = udiRelevanceService.selectByMainId(prefix);
}
if (udiRelevanceResponse == null) {
udiInfoEntity = getUdiInfo(udiInfoService, udiRelevanceService, code);
} else {
BeanUtils.copyProperties(udiRelevanceResponse, udiInfoEntity);
udiInfoEntity.setRelId(udiRelevanceResponse.getId() + "");
udiInfoEntity.setCode(code);
udiInfoEntity = FilterUdiUtils.transUdi(udiInfoEntity);
udiInfoEntity.setNameCode(udiRelevanceResponse.getNameCode());
}
udiInfoEntity.setCode(code);
return udiInfoEntity;
}
public void generateConstrastDetail(UdiInfoService udiInfoService, UdiRelevanceService udiRelevanceService,
OrderDetailService myErpOrderService,
List<WarehouseEntity> warehouseEntityList) {
if (warehouseEntityList != null && warehouseEntityList.size() > 0) {
List<UdiInfoEntity> udiInfoEntities = new ArrayList<>();
for (WarehouseEntity warehouseEntity : warehouseEntityList) {
UdiInfoEntity udiInfoEntity = getUdiInfo(udiInfoService, udiRelevanceService, warehouseEntity.getCode());
UdiInfoEntity udiInfoEntity = getUdiInfoByRlId(udiInfoService, udiRelevanceService, warehouseEntity.getCode());
if (udiInfoEntity != null) {
if (warehouseEntity.getCount() != null)
udiInfoEntity.setCount(customService.getActCount(warehouseEntity));
// udiInfoEntity.setCount(warehouseEntity.getCount());
udiInfoEntity.setCount(warehouseEntity.getCount() * customService.getActCount(warehouseEntity));
else {
udiInfoEntity.setCount(customService.getActCount(warehouseEntity));
}
udiInfoEntity.setRelId(warehouseEntity.getRelId());
udiInfoEntity.setSupId(warehouseEntity.getSupId());
udiInfoEntity.setStatus(warehouseEntity.getStatus());
udiInfoEntities.add(udiInfoEntity);
}
}
@ -202,21 +237,28 @@ public class InoutUtils {
for (UdiInfoEntity erpDetailCodeEntity : returnOrderDetail) {
ErpOrderEntity erpOrderEntity = new ErpOrderEntity();
erpOrderEntity.setNameCode(erpDetailCodeEntity.getNameCode());
erpOrderEntity.setGoodsid(erpDetailCodeEntity.getRelId());
erpOrderEntity.setPackRatio(erpDetailCodeEntity.getPackRatio());
erpOrderEntity.setCoName(erpDetailCodeEntity.getCpmctymc());
erpOrderEntity.setBatchNo(erpDetailCodeEntity.getBatchNo());
erpOrderEntity.setCount(erpDetailCodeEntity.getCount());
erpOrderEntity.setOrderIdFk(warehouseEntityList.get(0).getOrderId());
erpOrderEntity.setProductDate(erpDetailCodeEntity.getProduceDate());
erpOrderEntity.setRelIdFk(erpDetailCodeEntity.getRelId());
erpOrderEntity.setExpireDate(erpDetailCodeEntity.getExpireDate());
erpOrderEntity.setUuidFk(erpDetailCodeEntity.getUuid());
erpOrderEntity.setBindStatus(erpDetailCodeEntity.getStatus());
// erpOrderEntity.setProductCompany(erpDetailCodeEntity.getYlqxzcrbarmc());
erpOrderEntity.setAuthCode(erpDetailCodeEntity.getZczbhhzbapzbh());
erpOrderEntity.setPackSpec(erpDetailCodeEntity.getGgxh());
erpOrderEntity.setSupId(erpDetailCodeEntity.getSupId());
erpOrderEntities.add(erpOrderEntity);
}
if (!erpOrderEntities.isEmpty())
if (!erpOrderEntities.isEmpty()) {
// myErpOrderService.deleteByOrderId(warehouseEntityList.get(0).getOrderId());
myErpOrderService.insertErpOrders(erpOrderEntities);
}
}
}

@ -1,18 +1,33 @@
package com.glxp.api.admin.controller.inventory;
import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.constant.ConstantStatus;
import com.glxp.api.admin.constant.ConstantType;
import com.glxp.api.admin.entity.basic.UdiEntity;
import com.glxp.api.admin.entity.basic.UdiInfoEntity;
import com.glxp.api.admin.entity.inout.OrderEntity;
import com.glxp.api.admin.entity.inventory.InvProductDetailEntity;
import com.glxp.api.admin.entity.inventory.InvProductEntity;
import com.glxp.api.admin.req.inout.DeleteRequest;
import com.glxp.api.admin.req.inventory.FilterCodeTraceRequest;
import com.glxp.api.admin.req.inventory.FilterInvProductDetailRequest;
import com.glxp.api.admin.req.inventory.FilterInvProductRequest;
import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.basic.UdiRelevanceResponse;
import com.glxp.api.admin.res.inventory.InvProductDetailResponse;
import com.glxp.api.admin.res.inventory.InvProductPageRespnonse;
import com.glxp.api.admin.res.inventory.InvProductResponse;
import com.glxp.api.admin.res.inventory.InvProductStatResponse;
import com.glxp.api.admin.service.basic.UdiInfoService;
import com.glxp.api.admin.service.basic.UdiRelevanceService;
import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.admin.service.inventory.InvProductDetailService;
import com.glxp.api.admin.service.inventory.InvProductService;
import com.glxp.api.admin.util.FilterUdiUtils;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
@ -20,7 +35,15 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.glxp.api.admin.constant.Constant;
import static com.glxp.api.admin.constant.Constant.SYSTEM_CUSTOMER_ID;
@RestController
public class InvProductsController {
@ -29,27 +52,57 @@ public class InvProductsController {
InvProductService invProductService;
@Resource
InvProductDetailService invProductDetailService;
@Resource
OrderService orderService;
@Resource
private UdiRelevanceService udiRelevanceService;
@Resource
private UdiInfoService udiInfoService;
@GetMapping("spms/inv/products/filter")
public BaseResponse filterInvProduct(FilterInvProductRequest filterInvProductRequest) {
boolean showSup = false;
List<InvProductResponse> invProductResponses = invProductService.filterJoinInvProduct(filterInvProductRequest);
PageInfo<InvProductResponse> pageInfo;
pageInfo = new PageInfo<>(invProductResponses);
PageSimpleResponse<InvProductResponse> pageSimpleResponse = new PageSimpleResponse<>();
InvProductPageRespnonse<InvProductResponse> pageSimpleResponse = new InvProductPageRespnonse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(invProductResponses);
pageSimpleResponse.setShowSup(showSup);
return ResultVOUtils.success(pageSimpleResponse);
}
@GetMapping("spms/inv/products/filterDetail")
public BaseResponse filterInvProductDetail(FilterInvProductDetailRequest filterInvProductRequest) {
if (SYSTEM_CUSTOMER_ID.equals(filterInvProductRequest.getCustomerId())) {
filterInvProductRequest.setCustomerId(null);
}
List<InvProductDetailEntity> invProductDetailEntities = invProductDetailService.filterInvProduct(filterInvProductRequest);
PageInfo<InvProductDetailEntity> pageInfo;
pageInfo = new PageInfo<>(invProductDetailEntities);
PageSimpleResponse<InvProductDetailEntity> pageSimpleResponse = new PageSimpleResponse<>();
List<InvProductDetailResponse> invProductDetailResponses = new ArrayList<>();
if (invProductDetailEntities.size() > 0) {
for (InvProductDetailEntity invProductDetailEntity : invProductDetailEntities) {
InvProductDetailResponse invProductDetailResponse = new InvProductDetailResponse();
BeanUtils.copyProperties(invProductDetailEntity, invProductDetailResponse);
if (invProductDetailEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
invProductDetailResponse.setMainActionStr("出库");
invProductDetailResponse.setOutCount(invProductDetailEntity.getCount());
} else {
invProductDetailResponse.setMainActionStr("入库");
invProductDetailResponse.setInCount(invProductDetailEntity.getCount());
}
invProductDetailResponses.add(invProductDetailResponse);
}
}
PageSimpleResponse<InvProductDetailResponse> pageSimpleResponse = new PageSimpleResponse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(invProductDetailEntities);
pageSimpleResponse.setList(invProductDetailResponses);
return ResultVOUtils.success(pageSimpleResponse);
}
@ -64,12 +117,139 @@ public class InvProductsController {
InvProductEntity invProductEntity = invProductService.selectById(id);
if (invProductEntity != null) {
invProductService.deleteById(id);
invProductDetailService.deleteByProductId(invProductEntity.getId() + "");
FilterInvProductDetailRequest detailRequest = new FilterInvProductDetailRequest();
detailRequest.setSupId(invProductEntity.getSupId());
detailRequest.setBatchNo(invProductEntity.getBatchNo());
detailRequest.setProductIdFk(invProductEntity.getRelIdFk());
invProductDetailService.deleteByProductId(detailRequest);
return ResultVOUtils.success("删除成功");
} else {
return ResultVOUtils.error(500, "删除失败!");
}
}
@GetMapping("spms/inv/products/stat")
public BaseResponse statInvProduct(FilterInvProductDetailRequest filterInvProductDetailRequest) {
if (filterInvProductDetailRequest.getCustomerId() != null && filterInvProductDetailRequest.getCustomerId().equals(SYSTEM_CUSTOMER_ID)) {
filterInvProductDetailRequest.setCustomerId(null);
}
InvProductStatResponse invProductStatResponse = new InvProductStatResponse();
//统计预入库数量
FilterInvProductDetailRequest temp1 = new FilterInvProductDetailRequest();
BeanUtils.copyProperties(filterInvProductDetailRequest, temp1);
temp1.setPurchaseType(ConstantStatus.PRUCHASE_ADVANCE);
invProductStatResponse.setAdvanceCount(invProductDetailService.statCount(temp1));
//统计普通采购数量
FilterInvProductDetailRequest temp2 = new FilterInvProductDetailRequest();
BeanUtils.copyProperties(filterInvProductDetailRequest, temp2);
temp2.setPurchaseType(ConstantStatus.PRUCHASE_COMMON);
invProductStatResponse.setCommonCount(invProductDetailService.statCount(temp2));
//统计入库数量
FilterInvProductDetailRequest temp3 = new FilterInvProductDetailRequest();
BeanUtils.copyProperties(filterInvProductDetailRequest, temp3);
temp3.setMainAction(ConstantType.TYPE_PUT);
invProductStatResponse.setInCount(invProductDetailService.statCount(temp3));
//统计出库数量
FilterInvProductDetailRequest temp4 = new FilterInvProductDetailRequest();
BeanUtils.copyProperties(filterInvProductDetailRequest, temp4);
temp4.setMainAction(ConstantType.TYPE_OUT);
invProductStatResponse.setOutCount(invProductDetailService.statCount(temp4));
return ResultVOUtils.success(invProductStatResponse);
}
@GetMapping("spms/inv/products/trace")
public BaseResponse filterTrace(FilterCodeTraceRequest filterCodeTraceRequest) {
if (filterCodeTraceRequest.getCode() == null) {
return ResultVOUtils.success();
}
FilterInvProductDetailRequest filterInvProductDetailRequest = new FilterInvProductDetailRequest();
filterInvProductDetailRequest.setCode(filterCodeTraceRequest.getCode());
filterInvProductDetailRequest.setSupId(filterCodeTraceRequest.getSupId());
List<InvProductDetailEntity> invProductDetailEntities = invProductDetailService.filterInvProduct(filterInvProductDetailRequest);
if (invProductDetailEntities.size() > 0) {
InvProductDetailEntity invProductDetailEntity = new InvProductDetailEntity();
FilterInvProductDetailRequest filterRequest = new FilterInvProductDetailRequest();
filterRequest.setBatchNo(invProductDetailEntity.getBatchNo());
filterRequest.setProductIdFk(invProductDetailEntity.getProductIdFk());
filterRequest.setSupId(filterCodeTraceRequest.getSupId());
List<InvProductDetailEntity> resultLists = invProductDetailService.filterInvProduct(filterInvProductDetailRequest);
List<InvProductDetailResponse> invProductDetailResponses = new ArrayList<>();
if (invProductDetailEntities.size() > 0) {
for (InvProductDetailEntity temp : resultLists) {
InvProductDetailResponse invProductDetailResponse = new InvProductDetailResponse();
BeanUtils.copyProperties(temp, invProductDetailResponse);
if (temp.getMainAction().equals(ConstantType.TYPE_OUT)) {
invProductDetailResponse.setMainActionStr("出库");
invProductDetailResponse.setOutCount(temp.getCount());
} else {
invProductDetailResponse.setMainActionStr("入库");
invProductDetailResponse.setInCount(temp.getCount());
}
invProductDetailResponses.add(invProductDetailResponse);
}
}
PageInfo<InvProductDetailResponse> pageInfo;
pageInfo = new PageInfo<>(invProductDetailResponses);
InvProductPageRespnonse<InvProductDetailResponse> pageSimpleResponse = new InvProductPageRespnonse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(invProductDetailResponses);
return ResultVOUtils.success(pageSimpleResponse);
} else {
return ResultVOUtils.error(500, "未查询到数据!");
}
}
@GetMapping("spms/inv/products/order/trace")
public BaseResponse filterOrderTrace(FilterCodeTraceRequest filterCodeTraceRequest) {
if (filterCodeTraceRequest.getCode() == null) {
return ResultVOUtils.success();
}
UdiEntity udiEntity = FilterUdiUtils.getUdi(filterCodeTraceRequest.getCode());
UdiRelevanceResponse udiInfoBean = udiRelevanceService.selectByNameCode(udiEntity.getUdi());
List<UdiInfoEntity> udiInfoEntities = udiInfoService.findByUuids(udiInfoBean.getUuid());
String code = null;
if (udiInfoEntities != null && udiInfoEntities.size() > 1) {
code = FilterUdiUtils.transGlxpNoSerStr(udiEntity);
} else {
code = filterCodeTraceRequest.getCode();
}
FilterInvProductDetailRequest filterInvProductDetailRequest = new FilterInvProductDetailRequest();
filterInvProductDetailRequest.setCode(code);
filterInvProductDetailRequest.setSupId(filterCodeTraceRequest.getSupId());
List<InvProductDetailEntity> invProductDetailEntities = invProductDetailService.filterInvProduct(filterInvProductDetailRequest);
if (invProductDetailEntities.size() > 0) {
Map<String, String> filterMap = new HashMap<>();
for (InvProductDetailEntity invProductDetailEntity : invProductDetailEntities) {
filterMap.put(invProductDetailEntity.getOrderIdFk(), invProductDetailEntity.getOrderIdFk());
}
List<String> orderIds = new ArrayList<>();
for (String key : filterMap.keySet()) {
orderIds.add(key);
}
List<OrderEntity> orderEntities = orderService.filterListByOrder(orderIds);
PageInfo<OrderEntity> pageInfo;
pageInfo = new PageInfo<>(orderEntities);
InvProductPageRespnonse<OrderEntity> pageSimpleResponse = new InvProductPageRespnonse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(orderEntities);
return ResultVOUtils.success(pageSimpleResponse);
} else {
return ResultVOUtils.error(500, "未查询到数据!");
}
}
}

@ -83,7 +83,7 @@ public class PDFDawnloadController {
}
inoutOrderDetailPDFCodeRequest.setFromCorp(orderEntity.getFromCorp());
inoutOrderDetailPDFCodeRequest.setFromType(orderEntity.getFromType());
inoutOrderDetailPDFCodeRequest.setFromType(orderEntity.getFromType()+"");
BussinessTypeEntity bussinessTypeEntity = bussinessTypeService.findBTByAction(orderEntity.getAction());
inoutOrderDetailPDFCodeRequest.setActionName(bussinessTypeEntity == null ? " " : bussinessTypeEntity.getName());
@ -124,7 +124,7 @@ public class PDFDawnloadController {
inoutOrderDetailPDFCodeRequest.setSettingData(settingData);
//-----------------------------------------------
inoutOrderDetailPDFCodeRequest.setFromCorp(orderEntity.getFromCorp());
inoutOrderDetailPDFCodeRequest.setFromType(orderEntity.getFromType());
inoutOrderDetailPDFCodeRequest.setFromType(orderEntity.getFromType()+"");
BussinessTypeEntity bussinessTypeEntity = bussinessTypeService.findBTByAction(orderEntity.getAction());
inoutOrderDetailPDFCodeRequest.setActionName(bussinessTypeEntity == null ? " " : bussinessTypeEntity.getName());
@ -158,7 +158,7 @@ public class PDFDawnloadController {
inoutOrderDetailPDFFileRequest.setQrcodeCount(systemPDFTemplateEntity.getQrcodeCount());
//-----------------------------------------------
inoutOrderDetailPDFFileRequest.setFromCorp(orderEntity.getFromCorp());
inoutOrderDetailPDFFileRequest.setFromType(orderEntity.getFromType());
inoutOrderDetailPDFFileRequest.setFromType(orderEntity.getFromType()+"");
inoutOrderDetailPDFFileRequest.setActDate(orderEntity.getActDate());
BussinessTypeEntity bussinessTypeEntity = bussinessTypeService.findBTByAction(orderEntity.getAction());
inoutOrderDetailPDFFileRequest.setActionName(bussinessTypeEntity == null ? " " : bussinessTypeEntity.getName());
@ -241,7 +241,7 @@ public class PDFDawnloadController {
SystemPDFTemplateRelevanceEntity systemPDFTemplateRelevanceEntity = systemPDFTemplateRelevanceEntityList.get(0);
SystemPDFTemplateRequest systemPDFTemplateRequest = new SystemPDFTemplateRequest();
systemPDFTemplateRequest.setId(systemPDFTemplateRelevanceEntity.getTemplate_id());
systemPDFTemplateRequest.setId(systemPDFTemplateRelevanceEntity.getTemplateId());
SystemPDFTemplateEntity systemPDFTemplateEntity =
systemPDFTemplateService.findSystemPDFTemplate(systemPDFTemplateRequest);

@ -14,6 +14,8 @@ public interface BasicUnitMaintainDao {
boolean insertBasicUnitMaintain(BasicUnitMaintainEntity basicUnitMaintainEntity);
boolean insert(BasicUnitMaintainEntity basicUnitMaintainEntity);
boolean updateById(BasicUnitMaintainEntity basicUnitMaintainSaveRequest);
BasicUnitMaintainEntity selectByThirdId(BasicUnitMaintainFilterRequest basicUnitMaintainFilterRequest);
@ -21,4 +23,6 @@ public interface BasicUnitMaintainDao {
boolean deleteById(@Param("id") String id);
BasicUnitMaintainEntity selectById(@Param("id") String id);
BasicUnitMaintainEntity selectByName(@Param("name") String name);
}

@ -0,0 +1,21 @@
package com.glxp.api.admin.dao.basic;
import com.glxp.api.admin.entity.basic.BussinessChangeTypeEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@Mapper
public interface BussinessChangeTypeDao {
List<BussinessChangeTypeEntity> findByAction(String action);
boolean updateBusChangeType(BussinessChangeTypeEntity bussinessTypeEntity);
boolean insertBusChangeTypee(BussinessChangeTypeEntity bussinessTypeEntity);
boolean deleteById(@Param("id") String id);
}

@ -10,6 +10,7 @@ import java.util.List;
@Mapper
public interface BussinessLocalTypeDao {
BussinessLocalTypeEntity selectById(String id);
List<BussinessLocalTypeEntity> filterList(BussinessLocalTypeFilterRequest bussinessTypeFilterRequest);
@ -21,5 +22,7 @@ public interface BussinessLocalTypeDao {
boolean updateBusLocalType(BussinessLocalTypeEntity bussinessTypeEntity);
boolean insertBussinessType(BussinessLocalTypeEntity bussinessTypeEntity);
boolean deleteById(@Param("id") String id);
}

@ -1,7 +1,9 @@
package com.glxp.api.admin.dao.basic;
import com.glxp.api.admin.entity.basic.BussinessLocalTypeEntity;
import com.glxp.api.admin.entity.basic.BussinessOriginTypeEntity;
import com.glxp.api.admin.req.basic.BussinessOriginTypeFilterRequest;
import com.glxp.api.admin.res.basic.BussinessOriginTypeResponse;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
@ -10,4 +12,12 @@ import java.util.List;
public interface BussinessOriginTypeDao {
List<BussinessOriginTypeEntity> filterList(BussinessOriginTypeFilterRequest bussinessOriginTypeFilterRequest);
List<BussinessOriginTypeResponse> filterJoinList(BussinessOriginTypeFilterRequest bussinessOriginTypeFilterRequest);
List<BussinessOriginTypeEntity> filterEnableList(BussinessOriginTypeFilterRequest bussinessOriginTypeFilterRequest);
boolean updateBusOriginType(BussinessOriginTypeEntity bussinessTypeEntity);
boolean insertBusOriginType(BussinessOriginTypeEntity bussinessTypeEntity);
}

@ -10,6 +10,7 @@ import java.util.List;
@Mapper
public interface BussinessTypeDao {
BussinessTypeEntity selectById(String id);
List<BussinessTypeEntity> filterList(BussinessTypeFilterRequest bussinessTypeFilterRequest);
@ -17,6 +18,8 @@ public interface BussinessTypeDao {
boolean insertBussinessType(BussinessTypeEntity bussinessTypeEntity);
boolean insertIgnoreBussinessType(BussinessTypeEntity bussinessTypeEntity);
boolean updateBussinessType(BussinessTypeEntity bussinessTypeEntity);
boolean deleteById(@Param("id") String id);

@ -1,6 +1,8 @@
package com.glxp.api.admin.dao.info;
import com.glxp.api.admin.entity.info.SystemPDFTemplateRelevanceEntity;
import com.glxp.api.admin.req.itextpdf.SystemPDFTemplateRelevanceRequest;
import com.glxp.api.admin.res.basic.SystemPDFTemplateRelevanceResponse;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
@ -9,8 +11,12 @@ import java.util.List;
@Mapper
public interface SystemPDFTemplateRelevanceDao {
List<SystemPDFTemplateRelevanceResponse> filterList(SystemPDFTemplateRelevanceRequest systemPDFModuleRequest);
/**
* customerId
*
* @param customerId customerId
* @return
*/
@ -18,6 +24,7 @@ public interface SystemPDFTemplateRelevanceDao {
/**
* customerId
*
* @param customerIds customerIds
* @return
*/
@ -25,6 +32,7 @@ public interface SystemPDFTemplateRelevanceDao {
/**
* template_id customer_id
*
* @param templateId templateId
* @return
*/
@ -32,6 +40,7 @@ public interface SystemPDFTemplateRelevanceDao {
/**
*
*
* @param systemPDFTemplateRelevanceEntityList
* @return
*/
@ -42,8 +51,10 @@ public interface SystemPDFTemplateRelevanceDao {
/**
* customerId
* @param customerId
*
* @return
*/
boolean deleteByCustomerId(Long customerId);
boolean deleteById(Integer id);
boolean udpateRl(SystemPDFTemplateRelevanceEntity systemPDFTemplateRelevanceEntity);
}

@ -30,8 +30,14 @@ public interface CodesDao {
boolean updateOrderId(@Param("oldOrderId") String oldOrderId, @Param("newOrderId") String newOrderId);
boolean updateCode(WarehouseEntity warehouseEntity);
boolean updateUnit(@Param("orderId") String orderId, @Param("fromCorpId") String fromCorpId, @Param("fromCorp") String fromCorp);
List<String> findCodesById(@Param("orderId") String orderId);
boolean updateRelId(@Param("relId") String relId, @Param("nameCode") String nameCode, @Param("orderId") String orderId);
boolean updateSupId(@Param("supId") String supId, @Param("nameCode") String nameCode, @Param("orderId") String orderId);
}

@ -21,6 +21,9 @@ public interface CodesTempDao {
int updateById(WarehouseEntity warehouseEntitie);
boolean updateOrderId(@Param("oldOrderId") String oldOrderId, @Param("newOrderId") String newOrderId);
int deleteCodesTempById(WarehouseEntity warehouseEntitie);
List<WarehouseEntity> findByOrderIdAndCode(WarehouseQueryRequest warehouseQueryRequest);

@ -0,0 +1,21 @@
package com.glxp.api.admin.dao.inout;
import com.glxp.api.admin.entity.inout.IOOrderStatusEntity;
import com.glxp.api.admin.req.inout.OrderStatusFilterRequest;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@Mapper
public interface IOOrderStatusDao {
List<IOOrderStatusEntity> filterOrderStatus(OrderStatusFilterRequest warehouseQueryRequest);
boolean insertOrderStatus(IOOrderStatusEntity ioOrderStatusEntity);
boolean deleteByOrderId(@Param("orderId") String orderId);
boolean updateOrderStatus(IOOrderStatusEntity warehouseEntity);
}

@ -44,6 +44,8 @@ public interface OrderDao {
List<OrderEntity> filterListByCode(@Param("warehouseEntityList") List<WarehouseEntity> warehouseEntityList);
List<OrderEntity> filterListByOrder(@Param("orderList") List<String> orderList);
OrderEntity findOne(OrderFilterRequest orderFilterRequest);

@ -40,4 +40,6 @@ public interface OrderDetailDao {
List<String> selectAllIds(@Param("docids") List<String> docids);
boolean deleteByOrderId(@Param("id") String id);
public ErpOrderEntity findById(@Param("id") String id);
}

@ -23,5 +23,4 @@ public interface InvProductDao {
InvProductEntity selectById(@Param("id") String id);
boolean deleteById(@Param("id") String id);
}

@ -2,6 +2,7 @@ package com.glxp.api.admin.dao.inventory;
import com.glxp.api.admin.entity.inventory.InvProductDetailEntity;
import com.glxp.api.admin.req.inventory.FilterInvProductDetailRequest;
import com.glxp.api.admin.res.inventory.InvProductDetailJoinResponse;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@ -12,14 +13,18 @@ public interface InvProductDetailDao {
List<InvProductDetailEntity> filterInvProductDetail(FilterInvProductDetailRequest filterInvProductDetailRequest);
List<InvProductDetailJoinResponse> filterJoinInvProduct(FilterInvProductDetailRequest filterInvProductDetailRequest);
boolean insertInvProductDetail(InvProductDetailEntity invProductDetailEntity);
boolean insertInvProductDetails(List<InvProductDetailEntity> invProductDetailEntitys);
boolean insertInvProductDetails(@Param("invProductDetailEntitys") List<InvProductDetailEntity> invProductDetailEntitys);
boolean updateInvProductDetail(InvProductDetailEntity invProductDetailEntity);
boolean deleteById(@Param("id") String id);
boolean deleteByProductId(@Param("productIdFk") String productIdFk);
boolean deleteByProductId(FilterInvProductDetailRequest productIdFk);
int statCount(FilterInvProductDetailRequest filterInvProductDetailRequest);
}

@ -1,4 +1,4 @@
package com.glxp.api.admin.dao.info;
package com.glxp.api.admin.dao.schedule;
import com.glxp.api.admin.entity.info.ScheduledEntity;
import com.glxp.api.admin.req.info.ScheduledRequest;

@ -1,4 +1,4 @@
package com.glxp.api.admin.dao.info;
package com.glxp.api.admin.dao.schedule;
import com.glxp.api.admin.entity.info.SystemParamConfigEntity;
import com.glxp.api.admin.req.info.SystemParamConfigRequest;

@ -17,6 +17,7 @@ public class BasicThirdSysDetailEntity {
private String name;
private Integer fromType;
private String localAction;
private String thirdAction;
public String getValue() {
if (value == null)

@ -31,5 +31,6 @@ public class BasicUnitMaintainEntity {
private String thirdName4;
private Date updateTime;
private int corpType;
}

@ -0,0 +1,10 @@
package com.glxp.api.admin.entity.basic;
import lombok.Data;
import java.util.List;
@Data
public class BusDataEntity {
private List<BussinessTypeEntity> data;
}

@ -0,0 +1,24 @@
package com.glxp.api.admin.entity.basic;
import lombok.Data;
@Data
public class BussinessChangeTypeEntity {
private Integer id;
private String intro;
private String action;
private String scAction;
private Integer index;
private Integer beforeTime;
private String remark;
private String name;
public Integer getBeforeTime() {
if (beforeTime == null)
return 0;
return beforeTime;
}
}

@ -4,13 +4,15 @@ import lombok.Data;
@Data
public class BussinessLocalTypeEntity {
private Integer id;
private String action;
private String name;
private String remark;
private Boolean enable;
private String localAction;
private String originAction;
private String localName;
private String localAction;
private String remark;
private Boolean enable;
private Boolean checkEnable;
private Boolean advanceType;
private Boolean changeEnable;
}

@ -7,5 +7,8 @@ public class BussinessOriginTypeEntity {
private String id;
private String name;
private String action;
private String thirdSys;
private String thirdSysName;
private Boolean enable;
private String remark;
}

@ -12,5 +12,29 @@ public class BussinessTypeEntity {
private String mainAction;
private String thirdSysFk;
private String localAction;
private String thirdAction;
private boolean checkEnable;
private boolean genUnit;
private boolean innerOrder;
private boolean secCheckEnable;
private String thirdSys;
private boolean checkUdims;
private boolean checkPdaEd;
private boolean checkPdaUn;
private boolean checkPc;
private boolean checkWebNew;
private boolean checkChange;
private boolean checkSp;
private boolean secCheckUdims;
private boolean secCheckPdaEd;
private boolean secCheckPdaUn;
private boolean secCheckPc;
private boolean secCheckWebNew;
private boolean secCheckChange;
private boolean secCheckSp;
private Integer index;
}

@ -1,6 +1,8 @@
package com.glxp.api.admin.entity.basic;
import lombok.Data;
@Data
public class UdiInfoEntity {
private Integer id;
@ -35,6 +37,7 @@ public class UdiInfoEntity {
private String manufactory;
private String measname;
private Integer productType;
private String supId;
//本地生成信息
@ -47,6 +50,9 @@ public class UdiInfoEntity {
private Integer count;
private String warehouseCode;
private String relId;
private Integer status;
private Boolean isCheck;

@ -1,12 +1,16 @@
package com.glxp.api.admin.entity.business;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.math.BigDecimal;
@Data
public class StockOrderEntity {
private String id;
private String billNo;
@JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
private String billdate;
private String corpId;
private String corpName;
@ -20,4 +24,7 @@ public class StockOrderEntity {
private String printStatus;
private String unitIdFk;
private String customerId;
private String thirdOrderFk;
private String orderIdFk;
private BigDecimal totalPrice;
}

@ -18,4 +18,5 @@ public class SystemPDFTemplateEntity {
private String remark;
private Date create_time;
private Date update_time;
private String jrxmlPath;
}

@ -7,9 +7,11 @@ import lombok.Data;
*/
@Data
public class SystemPDFTemplateRelevanceEntity {
private int id;
private int template_id;
private Long customerId;
private int admin_id;
private int id;
private Integer templateId;
private Long customerId;
private Integer adminId;
private Integer moduleId;
private String localAction;
}

@ -6,21 +6,6 @@ import lombok.Data;
public class ErpOrderEntity {
/**
* companyid : 31443
* docid : 200959
* iodtlid : 1108752
* inoutid : 1064084
* credate : 2020-10-14 10:24:56.0
* goodsunit :
* goodsid : 26
* lotid : 84392
* goodsname : 120ml
* companyname :
* lotno : 1912198
* dtlgoodsqty : 4000
*/
private long id;
private String erpOrderId;
private String iodtlId;
@ -36,9 +21,9 @@ public class ErpOrderEntity {
private String warehouseCode;
private String productDate;
private String expireDate;
private int erpCount;
private Integer erpCount;
private String originType;
private int reCount;
private Integer reCount;
private String uuidFk;
private String nameCode;
@ -53,7 +38,16 @@ public class ErpOrderEntity {
private String orderIdFk;
private String nameCodes;
private String status;
private int count;
private Integer count;
private String relIdFk;
private Integer bindStatus;
private String bindRlFk;
private int orderFromType; //1.本地业务单据0.本地缓存第三方业务单据;(默认02.实时拉取第三方业务单据
private String supId;
private Integer bindSupStatus;
}

@ -0,0 +1,13 @@
package com.glxp.api.admin.entity.inout;
import lombok.Data;
import java.util.Date;
@Data
public class IOOrderStatusEntity {
private Integer id;
private String orderId;
private Integer status;
private Date updateTime;
}

@ -15,7 +15,7 @@ public class OrderEntity {
private String fromCorp;
private Integer status;
private Integer exportStatus;
private String fromType;
private Integer fromType;
private Integer contrastStatus;
private String erpFk;
private Integer signStatus;

@ -23,4 +23,7 @@ public class WarehouseEntity {
private String warehouseCode;
private String nameCode;
private Integer sCount;
private String relId;
private Integer status;
private String supId;
}

@ -10,8 +10,17 @@ public class InvProductDetailEntity {
private String code;
private String productIdFk;
private String orderIdFk;
private String customerId;
private String mainAction;
private String action;
private Integer count;
private Date updateTime;
private Integer purchaseType;
private String batchNo;
private String productionDate;
private String expireDate;
private String unitFk;
private String stockIdFk;
private String supId;
private String originCode;
}

@ -17,6 +17,9 @@ public class InvProductEntity {
private Integer inCount;
private Integer outCount;
private Integer reCount;
private String customerId;
private String supId;
private String unitFk;
public Integer getInCount() {
if (inCount == null)
@ -28,5 +31,4 @@ public class InvProductEntity {
if (outCount == null)
return 0;
return outCount;
}
}
}}

@ -25,7 +25,7 @@ public class ThrProductsEntity {
private String ylqxzcrbarywmc;
private String cpms;
private Date updateTime;
private String supName;
private String thirdSysName;
private boolean isChecked;

@ -25,5 +25,6 @@ public class ThrProductsImportDetailEntity {
private String ylqxzcrbarywmc;
private String cpms;
private Date updateTime;
private String supName;
private String genKeyFk;
}

@ -2,6 +2,7 @@ package com.glxp.api.admin.httpclient;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.glxp.api.admin.httpclient.req.UdiwmsUnitRequest;
import com.glxp.api.admin.req.basic.BasicUnitMaintainFilterRequest;
import com.glxp.api.admin.res.basic.ErpProductsResponse;
import com.glxp.api.admin.res.basic.ErpUnitsResponse;
@ -10,6 +11,7 @@ import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.util.HttpClient;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import org.springframework.beans.BeanUtils;
import java.util.HashMap;
import java.util.Map;
@ -28,7 +30,11 @@ public class ErpBasicClient {
paramMap.put("key", unitMaintainFilterRequest.getKey());
paramMap.put("page", unitMaintainFilterRequest.getPage());
paramMap.put("limit", unitMaintainFilterRequest.getLimit());
String response = HttpClient.mipsGet(url, paramMap);
// String response = HttpClient.mipsGet(url, paramMap);
UdiwmsUnitRequest udiwmsUnitRequest = new UdiwmsUnitRequest();
BeanUtils.copyProperties(unitMaintainFilterRequest, udiwmsUnitRequest);
udiwmsUnitRequest.setUnitId(unitMaintainFilterRequest.getErpId());
String response = HttpClient.uCloudPost(url, udiwmsUnitRequest);
try {
BaseResponse<PageSimpleResponse<ErpUnitsResponse>> udiDlDeviceResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<ErpUnitsResponse>>>() {
@ -50,8 +56,8 @@ public class ErpBasicClient {
paramMap.put("manufactory", filterErpGoodsRequest.getManufactory());
paramMap.put("limit", filterErpGoodsRequest.getLimit());
paramMap.put("page", filterErpGoodsRequest.getPage());
String response = HttpClient.mipsGet(url, paramMap);
String response = HttpClient.uCloudPost(url, filterErpGoodsRequest);
// String response = HttpClient.mipsGet(url, paramMap);
try {
BaseResponse<PageSimpleResponse<ErpProductsResponse>> udiDlDeviceResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<ErpProductsResponse>>>() {

@ -36,7 +36,8 @@ public class ErpInvClient {
paramMap.put("page", onhandRequest.getPage());
if (onhandRequest.getLimit() != null)
paramMap.put("limit", onhandRequest.getLimit());
String response = HttpClient.mipsGet(url, paramMap);
// String response = HttpClient.mipsGet(url, paramMap);
String response = HttpClient.uCloudPost(url, onhandRequest);
try {
BaseResponse<PageSimpleResponse<ErpOnHandResponse>> onHandsResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<ErpOnHandResponse>>>() {
@ -72,7 +73,8 @@ public class ErpInvClient {
paramMap.put("page", onhandRequest.getPage());
if (onhandRequest.getLimit() != null)
paramMap.put("limit", onhandRequest.getLimit());
String response = HttpClient.mipsGet(url, paramMap);
// String response = HttpClient.mipsGet(url, paramMap);
String response = HttpClient.uCloudPost(url, onhandRequest);
try {
BaseResponse<PageSimpleResponse<ErpInvProductResponse>> onHandsResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<ErpInvProductResponse>>>() {

@ -2,6 +2,7 @@ package com.glxp.api.admin.httpclient;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.glxp.api.admin.constant.ConstantStatus;
import com.glxp.api.admin.entity.inout.ErpOrderEntity;
import com.glxp.api.admin.req.inout.ERPPostBillRequest;
import com.glxp.api.admin.req.inout.FilterOrderRequest;
@ -62,8 +63,8 @@ public class ErpOrderClient {
paramMap.put("startDate", filterOrderRequest.getStartDate());
paramMap.put("endDate", filterOrderRequest.getEndDate());
String response = "";
response = HttpClient.mipsGet(url, paramMap);
String response = HttpClient.uCloudPost(url, filterOrderRequest);
// response = HttpClient.mipsGet(url, paramMap);
try {
BaseResponse<PageSimpleResponse<ErpOrderResponse>> responseBaseResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<ErpOrderResponse>>>() {
@ -96,10 +97,11 @@ public class ErpOrderClient {
erpOrderEntity.setBatchNo(subPurchase.getBatchNo());
erpOrderEntity.setProductDate(subPurchase.getProductDate());
erpOrderEntity.setExpireDate(subPurchase.getExpireDate());
erpOrderEntity.setErpCount(Math.abs(subPurchase.getCount()));
erpOrderEntity.setReCount(Math.abs(subPurchase.getReCount()));
erpOrderEntity.setErpCount(Math.abs(Integer.parseInt(subPurchase.getCount())));
erpOrderEntity.setReCount(Math.abs(Integer.parseInt(subPurchase.getReCount())));
erpOrderEntity.setOriginType(erpOrderResponse.getOriginType());
erpOrderEntity.setGoodsunit(subPurchase.getSpec());
erpOrderEntity.setOrderFromType(ConstantStatus.SORDER_FROM_ONLINE);
erpOrderEntities.add(erpOrderEntity);
}
}

@ -0,0 +1,97 @@
package com.glxp.api.admin.httpclient;
import com.alibaba.fastjson.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
import java.io.UnsupportedEncodingException;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLEncoder;
import java.util.Iterator;
import java.util.Map;
public class UHttpClient {
private static final Logger logger = LoggerFactory.getLogger(UHttpClient.class);
public static String post(String url, Object object) {
SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
factory.setConnectTimeout(600000);
factory.setReadTimeout(100000);
RestTemplate restTemplate = new RestTemplate();
String json = JSONObject.toJSON(object).toString();
MultiValueMap<String, Object> postParameters = new LinkedMultiValueMap<>();
postParameters.add("params", json);
HttpHeaders headers = new HttpHeaders();
headers.add("Content-Type", "application/x-www-form-urlencoded");
HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity<>(postParameters, headers);
String response = restTemplate.postForObject(url, httpEntity, String.class);
System.out.println(response);
return response;
}
public static String postJson(String url, Object object) {
SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
factory.setConnectTimeout(600000);
factory.setReadTimeout(20000);
RestTemplate restTemplate = new RestTemplate(factory);
String json = JSONObject.toJSON(object).toString();
logger.info(url + "\n" + json);
HttpHeaders headers = new HttpHeaders();
headers.add("Content-Type", "application/json");
HttpEntity<String> httpEntity = new HttpEntity<>(json, headers);
String response = restTemplate.postForObject(url, httpEntity, String.class);
logger.info(response);
return response;
}
public static String mipsGet(String url, Map params) {
StringBuffer stringBuffer = new StringBuffer(url);
if (params instanceof Map) {
Iterator iterator = ((Map) params).entrySet().iterator();
if (iterator.hasNext()) {
stringBuffer.append("?");
Object element;
while (iterator.hasNext()) {
element = iterator.next();
Map.Entry<String, Object> entry = (Map.Entry) element;
//过滤value为nullvalue为null时进行拼接字符串会变成 "null"字符串
if (entry.getValue() != null) {
String value = String.valueOf(((Map.Entry) element).getValue());
if (value.contains("#")) {
try {
String ps = URLEncoder.encode(value, "UTF-8");
((Map.Entry) element).setValue(ps);
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
}
stringBuffer.append(element).append("&");
}
url = stringBuffer.substring(0, stringBuffer.length() - 1);
}
}
} else {
throw new RuntimeException("url请求:" + url + "请求参数有误不是map类型");
}
RestTemplate restTemplate = new RestTemplate();
String accessTokenRequestUrl = null;
try {
accessTokenRequestUrl = new URL(url).toString();
} catch (MalformedURLException e) {
e.printStackTrace();
}
logger.info(accessTokenRequestUrl);
String response = restTemplate.getForObject(accessTokenRequestUrl, String.class);
return response;
}
}

@ -0,0 +1,11 @@
package com.glxp.api.admin.httpclient.req;
import com.glxp.api.admin.req.ListPageRequest;
import lombok.Data;
@Data
public class UdiwmsUnitRequest extends ListPageRequest {
String key;
private String unitId;
private String name;
}

@ -24,7 +24,8 @@ public class BasicUnitMaintainFilterRequest extends ListPageRequest {
private Boolean isDownThrSys;
List<ErpUnitsResponse> thrCorpEntities;
private int corpType;
private String unitId;
}

@ -5,10 +5,10 @@ import lombok.Data;
@Data
public class BussinessLocalTypeFilterRequest extends ListPageRequest {
private String action;
private String name;
private String mainAction;
private Boolean enabled;
private String originAction;
private Boolean changeEnable;
}

@ -7,4 +7,7 @@ import lombok.Data;
public class BussinessOriginTypeFilterRequest extends ListPageRequest {
private String action;
private String name;
private String thirdSys;
private String thirdSysName;
private Boolean enable;
}

@ -39,6 +39,7 @@ public class FilterUdiInfoRequest extends ListPageRequest {
private Boolean isCheck;
private Integer filterType; //0:全部1.对照完成2.未对照DI3.未对照产品编码4.未对照其他产品编码
private String udplatCode;
private String mainId;
}

@ -3,6 +3,8 @@ package com.glxp.api.admin.req.business;
import com.glxp.api.admin.req.ListPageRequest;
import lombok.Data;
import java.math.BigDecimal;
@Data
public class StockOrderFilterRequest extends ListPageRequest {
@ -24,4 +26,7 @@ public class StockOrderFilterRequest extends ListPageRequest {
private String customerId;
private String startTime; //起始日期
private String endTime; //结束日期
private String orderIdFk;
private BigDecimal totalPrice;
private String thirdOrderFk;
}

@ -16,4 +16,5 @@ public class SystemPDFModuleSaveRequest {
private Date create_time;
private Date update_time;
private String templateDlUrl;
private Integer templateType;
}

@ -21,4 +21,5 @@ public class SystemPDFTemplateRequest extends ListPageRequest {
private String remark;
private Date create_time;
private Date update_time;
private String jrxmlPath;
}

@ -18,4 +18,5 @@ public class SystemPDFTemplateSaveRequest {
private String remark;
private Date create_time;
private Date update_time;
private String jrxmlPath;
}

@ -4,7 +4,7 @@ import lombok.Data;
@Data
public class FilterOrderRequest {
private Integer id;
private String startDate; //起始日期
private String endDate; //结束日期
private String billNo; //单据号
@ -16,5 +16,5 @@ public class FilterOrderRequest {
private String corpName;
private Boolean isLocal;
private String localAction;
private String thirdOrderFk;
}

@ -20,4 +20,5 @@ public class OrderFilterRequest extends ListPageRequest {
private String stockCheckFk;
private Integer process;
private String unionStatus;
private String fromCorpId;
}

@ -0,0 +1,10 @@
package com.glxp.api.admin.req.inout;
import com.glxp.api.admin.req.ListPageRequest;
import lombok.Data;
@Data
public class OrderStatusFilterRequest extends ListPageRequest {
private String orderId;
private Integer status;
}

@ -12,4 +12,5 @@ public class WarehouseQueryRequest extends ListPageRequest {
private String batchNo;
private String orderId;
private String nameCode;
private String supId;
}

@ -0,0 +1,9 @@
package com.glxp.api.admin.req.inventory;
import lombok.Data;
@Data
public class FilterCodeTraceRequest {
private String code;
private String supId;
}

@ -6,10 +6,21 @@ import lombok.Data;
@Data
public class FilterInvProductDetailRequest extends ListPageRequest {
private String id;
private String code;
private String productIdFk;
private String customerId;
private String mainAction;
private String action;
private Integer count;
private Integer purchaseType;
private String batchNo;
private String productionDate;
private String expireDate;
private String unitFk;
private String stockIdFk;
private String supId;
private String originCode;
}

@ -16,7 +16,9 @@ public class FilterInvProductRequest extends ListPageRequest {
private String expireDate;
private String ylqxzcrbarmc;
private String zczbhhzbapzbh;
private String customerId;
private String productsName;
private String supId;
private String unitFk;
}

@ -0,0 +1,10 @@
package com.glxp.api.admin.req.itextpdf;
import lombok.Data;
@Data
public class SystemPDFTemplateRelevanceRequest {
private Integer moduleId;
private Integer templateType;
private String localAction;
}

@ -6,9 +6,14 @@ import lombok.Data;
@Data
public class BussinessTypeFilterRequest extends ListPageRequest {
private Boolean enable;
private String action;
private String thirdAction;
private String name;
private String mainAction;
private Boolean enabled;
private Boolean enable;
private Boolean checkEnable;
private Boolean advanceType;
private String type;
private Integer index;
}

@ -19,6 +19,7 @@ public class FilterThrProductsRequest extends ListPageRequest {
private String unionCode;
private String sptm;
private String ybbm;
private String supName;
}

@ -0,0 +1,11 @@
package com.glxp.api.admin.res.basic;
import lombok.Data;
@Data
public class BussinessOriginTypeResponse {
private String name;
private String action;
private String localAction;
private String thirdAction;
}

@ -0,0 +1,13 @@
package com.glxp.api.admin.res.basic;
import lombok.Data;
@Data
public class BussinessTypExportResponse {
private Integer id;
private String action;
private String name;
private Boolean enable;
private String remark;
private String mainAction;
}

@ -16,6 +16,27 @@ public class BussinessTypResponse {
private String thirdName;
private Boolean enabled;
private String localAction;
private Boolean checkEnable; //是否根据业务单据类型校验
private Boolean advanceType; //是否预入库
private Boolean changeEnable;
private Boolean genUnit;
private Boolean innerOrder;
private String thirdAction;
private boolean checkUdims;
private boolean checkPdaEd;
private boolean checkPdaUn;
private boolean checkPc;
private boolean checkWebNew;
private boolean checkChange;
private boolean checkSp;
private boolean secCheckUdims;
private boolean secCheckPdaEd;
private boolean secCheckPdaUn;
private boolean secCheckPc;
private boolean secCheckWebNew;
private boolean secCheckChange;
private boolean secCheckSp;
}

@ -21,7 +21,7 @@ public class ErpProductsResponse {
private String ylqxzcrbarmc;
private String ylqxzcrbarywmc;
private String cpms;
private String supName; //配送企业
//辅助字段

@ -0,0 +1,23 @@
package com.glxp.api.admin.res.basic;
import lombok.Data;
@Data
public class SystemPDFTemplateRelevanceResponse {
private String param;
private String fieldExplain;
private String templateDlUrl;
private Integer templateType;
private int id;
private String moduleName;
private String templateName;
private int templateId;
private String localAction;
private String localActionName;
}

@ -51,4 +51,12 @@ public class UdiRelevanceResponse {
private Integer productType;
private String mainId;
private String mainName;
public int getBhzxxsbzsl() {
if (bhzxxsbzsl == null || bhzxxsbzsl == 0) {
return 1;
} else
return bhzxxsbzsl;
}
}

@ -18,4 +18,5 @@ public class SystemPDFTemplateResponse {
private String remark;
private Date create_time;
private Date update_time;
private String jrxmlPath;
}

@ -0,0 +1,16 @@
package com.glxp.api.admin.res.inout;
import com.glxp.api.admin.entity.inout.ErpOrderEntity;
import com.glxp.api.admin.entity.inout.OrderEntity;
import com.glxp.api.admin.entity.inout.WarehouseEntity;
import lombok.Data;
import java.util.List;
@Data
public class DlOrderResponse {
private OrderEntity orderEntity;
private List<ErpOrderEntity> orderDetails;
private List<WarehouseEntity> codes;
}

@ -3,7 +3,7 @@ package com.glxp.api.admin.res.inout;
import java.util.List;
public class ErpOrderResponse {
private Integer id;
private String billNo;
private String billdate;
private String corpId;
@ -78,6 +78,14 @@ public class ErpOrderResponse {
this.originType = originType;
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public static class SubErpOrder {
private String productId;
private String productName;
@ -85,8 +93,10 @@ public class ErpOrderResponse {
private String batchNo;
private String expireDate;
private String productDate;
private Integer count; //账面数量
private Integer reCount; //实际数量
private String count; //账面数量
private String reCount; //实际数量
private String sweepCount;
private String relId; //基础信息关联表主键
public String getProductId() {
return productId;
@ -136,21 +146,37 @@ public class ErpOrderResponse {
this.productDate = productDate;
}
public Integer getCount() {
public String getCount() {
return count;
}
public void setCount(Integer count) {
public void setCount(String count) {
this.count = count;
}
public Integer getReCount() {
public String getReCount() {
return reCount;
}
public void setReCount(Integer reCount) {
public void setReCount(String reCount) {
this.reCount = reCount;
}
public String getSweepCount() {
return sweepCount;
}
public void setSweepCount(String sweepCount) {
this.sweepCount = sweepCount;
}
public String getRelId() {
return relId;
}
public void setRelId(String relId) {
this.relId = relId;
}
}
}

@ -0,0 +1,26 @@
package com.glxp.api.admin.res.inventory;
import lombok.Data;
import java.util.Date;
@Data
public class InvProductDetailJoinResponse {
private Integer id;
private String code;
private String productIdFk;
private String orderIdFk;
private String customerId;
private String mainAction;
private String action;
private Integer count;
private Date updateTime;
private Integer purchaseType;
private String batchNo;
private String productionDate;
private String expireDate;
private String unitFk;
private String stockIdFk;
private String fromCorpId;
private String fromCorp;
}

@ -0,0 +1,32 @@
package com.glxp.api.admin.res.inventory;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.util.Date;
@Data
public class InvProductDetailResponse {
private Integer id;
private String code;
private String productIdFk;
private String orderIdFk;
private String customerId;
private String mainAction;
private String action;
private Integer count;
@JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
private Date updateTime;
private Integer purchaseType;
private String batchNo;
private String productionDate;
private String expireDate;
private String unitFk;
private String stockIdFk;
private Integer inCount;
private Integer outCount;
private String mainActionStr;
private String originCode;
}

@ -0,0 +1,11 @@
package com.glxp.api.admin.res.inventory;
import com.glxp.api.admin.res.PageSimpleResponse;
import lombok.Data;
@Data
public class InvProductPageRespnonse<T> extends PageSimpleResponse<T> {
private Boolean showSup;
}

@ -18,6 +18,9 @@ public class InvProductResponse {
private Integer outCount;
private Integer reCount;
private String customerId;
private String companyName;
private String supId;
private String unitFk;
public Integer getInCount() {
if (inCount == null)

@ -0,0 +1,11 @@
package com.glxp.api.admin.res.inventory;
import lombok.Data;
@Data
public class InvProductStatResponse {
private int advanceCount;
private int commonCount;
private int inCount;
private int outCount;
}

@ -15,10 +15,19 @@ public interface BasicUnitMaintainService {
boolean updateById(BasicUnitMaintainEntity basicUnitMaintainEntity);
boolean insert(BasicUnitMaintainEntity basicUnitMaintainEntity);
// boolean updateById(BasicUnitMaintainSaveRequest basicUnitMaintainSaveRequest);
boolean deleteById(String id);
BasicUnitMaintainEntity selectByThirdId(String thirdId, String thirdSys);
BasicUnitMaintainEntity selectById(String id);
BasicUnitMaintainEntity selectByErpId(String id);
BasicUnitMaintainEntity selectByName(String name);
boolean isExit();
}

@ -0,0 +1,22 @@
package com.glxp.api.admin.service.basic;
import com.glxp.api.admin.entity.basic.BussinessChangeTypeEntity;
import java.util.List;
public interface BussinessChangeTypeService {
List<BussinessChangeTypeEntity> findByAction(String action);
BussinessChangeTypeEntity findByName(String name);
public BussinessChangeTypeEntity findFirstByAction(String action);
boolean updateBusChangeType(BussinessChangeTypeEntity bussinessTypeEntity);
boolean insertBusChangeTypee(BussinessChangeTypeEntity bussinessTypeEntity);
boolean deleteById(String id);
}

@ -7,6 +7,7 @@ import java.util.List;
public interface BussinessLocalTypeService {
BussinessLocalTypeEntity selectById(String id);
List<BussinessLocalTypeEntity> filterList(BussinessLocalTypeFilterRequest bussinessTypeFilterRequest);
@ -16,6 +17,8 @@ public interface BussinessLocalTypeService {
BussinessLocalTypeEntity findBTByName(String name);
boolean insertBussinessType(BussinessLocalTypeEntity bussinessLocalTypeEntity);
boolean updateBusLocalType(BussinessLocalTypeEntity bussinessTypeEntity);
boolean deleteById(String id);

@ -1,13 +1,27 @@
package com.glxp.api.admin.service.basic;
import com.glxp.api.admin.entity.basic.BasicThirdSysDetailEntity;
import com.glxp.api.admin.entity.basic.BussinessOriginTypeEntity;
import com.glxp.api.admin.req.basic.BussinessOriginTypeFilterRequest;
import com.glxp.api.admin.res.basic.BussinessOriginTypeResponse;
import java.util.List;
public interface BussinessOriginTypeService {
BussinessOriginTypeEntity findByAction(String action);
BasicThirdSysDetailEntity findSysByAction(String action, String key);
List<BussinessOriginTypeEntity> filterEnableList(BussinessOriginTypeFilterRequest bussinessOriginTypeFilterRequest);
BussinessOriginTypeResponse finAllByAction(String action);
List<BussinessOriginTypeEntity> filterList(BussinessOriginTypeFilterRequest bussinessOriginTypeFilterRequest);
boolean updateBusOriginType(BussinessOriginTypeEntity bussinessTypeEntity);
boolean insertBusOriginType(BussinessOriginTypeEntity bussinessTypeEntity);
}

@ -9,6 +9,7 @@ import com.glxp.api.admin.res.basic.BussinessTypResponse;
import java.util.List;
public interface BussinessTypeService {
BussinessTypeEntity selectById(String id);
List<BussinessTypeEntity> filterList(BussinessTypeFilterRequest bussinessTypeFilterRequest);
@ -24,6 +25,8 @@ public interface BussinessTypeService {
boolean insertBussinessType(BussinessTypeEntity bussinessTypeEntity);
boolean insertIgnoreBussinessType(BussinessTypeEntity bussinessTypeEntity);
boolean updateBussinessType(BussinessTypeEntity bussinessTypeEntity);
boolean deleteById(String id);

@ -13,7 +13,11 @@ public class CustomService {
UdiRelevanceService udiRelevanceService;
public int getActCount(WarehouseEntity warehouseEntity) {
UdiRelevanceResponse udiInfoBean = udiRelevanceService.selectByNameCode(warehouseEntity.getNameCode());
UdiRelevanceResponse udiInfoBean;
if (warehouseEntity.getRelId() != null) {
udiInfoBean = udiRelevanceService.selectGroupById(warehouseEntity.getRelId());
} else
udiInfoBean = udiRelevanceService.selectByNameCode(warehouseEntity.getNameCode());
if (udiInfoBean != null) {
if (udiInfoBean.getIsUseDy() == 1 && udiInfoBean.getDiType() != 2) {
if (udiInfoBean.getBhzxxsbzsl() == 0)

Some files were not shown because too many files have changed in this diff Show More

Loading…
Cancel
Save