Merge remote-tracking branch 'origin/master'
郑明梁
2 years ago
commit
44c9481ccb
@ -0,0 +1,105 @@
|
||||
package com.glxp.api.controller.inv;
|
||||
|
||||
import cn.hutool.core.bean.BeanUtil;
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import com.github.pagehelper.PageInfo;
|
||||
import com.glxp.api.common.res.BaseResponse;
|
||||
import com.glxp.api.common.util.ResultVOUtils;
|
||||
import com.glxp.api.entity.inv.InvPreInProductDetailEntity;
|
||||
import com.glxp.api.entity.inv.InvPreProductDetailEntity;
|
||||
import com.glxp.api.req.inv.FilterInvPreProductDetailRequest;
|
||||
import com.glxp.api.req.inv.FilterInvPreinDetailRequest;
|
||||
import com.glxp.api.req.inv.FilterInvPreinProductRequest;
|
||||
import com.glxp.api.res.PageSimpleResponse;
|
||||
import com.glxp.api.res.inv.InvPreProductDetailResponse;
|
||||
import com.glxp.api.res.inv.InvPreProductPageResponse;
|
||||
import com.glxp.api.res.inv.InvPreinDetailResponse;
|
||||
import com.glxp.api.res.inv.InvPreinProductResponse;
|
||||
import com.glxp.api.service.auth.CustomerService;
|
||||
import com.glxp.api.service.auth.WarehouseUserService;
|
||||
import com.glxp.api.service.inv.InvPreinDetailService;
|
||||
import com.glxp.api.service.inv.InvPreinProductDetailService;
|
||||
import com.glxp.api.service.inv.InvPreinProductService;
|
||||
import com.glxp.api.util.udi.FilterUdiUtils;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 预验收库存接口
|
||||
*/
|
||||
@Slf4j
|
||||
@RestController
|
||||
public class InvPreinProductController {
|
||||
@Resource
|
||||
private InvPreinProductDetailService invPreinProductDetailService;
|
||||
@Resource
|
||||
private InvPreinProductService invPreinProductService;
|
||||
@Resource
|
||||
private WarehouseUserService warehouseUserService;
|
||||
@Resource
|
||||
private CustomerService customerService;
|
||||
|
||||
/**
|
||||
* 预验收库存查询接口
|
||||
*
|
||||
* @param filterInvPreinProductRequest
|
||||
* @return
|
||||
*/
|
||||
@GetMapping("/spms/inv/pre/in/product/filter")
|
||||
public BaseResponse filterList(FilterInvPreinProductRequest filterInvPreinProductRequest) {
|
||||
boolean showSup = false; //前端控制表格显示字段
|
||||
if (StrUtil.isNotBlank(filterInvPreinProductRequest.getUdiCode())) {
|
||||
filterInvPreinProductRequest.setNameCode(FilterUdiUtils.getDiStr(filterInvPreinProductRequest.getUdiCode()));
|
||||
}
|
||||
|
||||
if (StrUtil.isBlank(filterInvPreinProductRequest.getInvCode())) {
|
||||
List<String> invCodes = warehouseUserService.selectCodeByUser(customerService.getUserIdStr());
|
||||
if (CollUtil.isNotEmpty(invCodes)) {
|
||||
filterInvPreinProductRequest.setInvCodes(invCodes);
|
||||
}
|
||||
}
|
||||
List<InvPreinProductResponse> list = invPreinProductService.filterList(filterInvPreinProductRequest);
|
||||
PageInfo<InvPreinProductResponse> pageInfo = new PageInfo<>(list);
|
||||
InvPreProductPageResponse<InvPreinProductResponse> pageResponse = new InvPreProductPageResponse<>();
|
||||
pageResponse.setList(pageInfo.getList());
|
||||
pageResponse.setTotal(pageInfo.getTotal());
|
||||
pageResponse.setShowSup(showSup);
|
||||
return ResultVOUtils.success(pageResponse);
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询预验收库存详情
|
||||
*
|
||||
* @param detailRequest
|
||||
* @return
|
||||
*/
|
||||
@GetMapping("/spms/inv/pre/in/product/filterDetail")
|
||||
public BaseResponse filterInvPreProductDetail(FilterInvPreProductDetailRequest detailRequest) {
|
||||
List<InvPreInProductDetailEntity> invPreProductDetailEntities = invPreinProductDetailService.filterPreProductDetailList(detailRequest);
|
||||
PageInfo<InvPreInProductDetailEntity> pageInfo = new PageInfo<>(invPreProductDetailEntities);
|
||||
|
||||
List<InvPreProductDetailResponse> list = new ArrayList<>();
|
||||
if (CollUtil.isNotEmpty(invPreProductDetailEntities)) {
|
||||
invPreProductDetailEntities.forEach(invPreProductDetailEntity -> {
|
||||
InvPreProductDetailResponse response = new InvPreProductDetailResponse();
|
||||
BeanUtil.copyProperties(invPreProductDetailEntity, response);
|
||||
//设置单据类型名称等单据相关参数
|
||||
invPreinProductDetailService.setOrderInfo(response);
|
||||
list.add(response);
|
||||
});
|
||||
}
|
||||
|
||||
PageSimpleResponse<InvPreProductDetailResponse> pageSimpleResponse = new PageSimpleResponse<>();
|
||||
pageSimpleResponse.setList(list);
|
||||
pageSimpleResponse.setTotal(pageInfo.getTotal());
|
||||
return ResultVOUtils.success(pageSimpleResponse);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,30 @@
|
||||
package com.glxp.api.dao.inv;
|
||||
|
||||
import com.glxp.api.dao.BaseMapperPlus;
|
||||
import com.glxp.api.entity.inv.InvPreInProductDetailEntity;
|
||||
import com.glxp.api.req.inv.FilterInvPreProductDetailRequest;
|
||||
import com.glxp.api.req.inv.FilterInvProductDetailRequest;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 预验收库存详情Dao
|
||||
*/
|
||||
public interface InvPreInProductDetailDao extends BaseMapperPlus<InvPreInProductDetailDao, InvPreInProductDetailEntity, InvPreInProductDetailEntity> {
|
||||
|
||||
/**
|
||||
* 查询库存详情实体列表
|
||||
*
|
||||
* @param filterInvPreProductDetailRequest
|
||||
* @return
|
||||
*/
|
||||
List<InvPreInProductDetailEntity> filterPreProductDetailList(FilterInvPreProductDetailRequest filterInvPreProductDetailRequest);
|
||||
|
||||
/**
|
||||
* 删除寄预验收库存详情
|
||||
*
|
||||
* @param detailRequest
|
||||
* @return
|
||||
*/
|
||||
boolean deleteInvPreProductDetail(FilterInvProductDetailRequest detailRequest);
|
||||
}
|
||||
@ -0,0 +1,31 @@
|
||||
package com.glxp.api.dao.inv;
|
||||
|
||||
import com.glxp.api.dao.BaseMapperPlus;
|
||||
import com.glxp.api.entity.inv.InvPreinProductEntity;
|
||||
import com.glxp.api.req.inv.FilterInvPreinProductRequest;
|
||||
import com.glxp.api.res.inv.InvPreinProductResponse;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 预验收库存Dao
|
||||
*/
|
||||
public interface InvPreinProductDao extends BaseMapperPlus<InvPreinProductDao, InvPreinProductEntity, InvPreinProductEntity> {
|
||||
|
||||
/**
|
||||
* 查询寄售库存VO列表
|
||||
*
|
||||
* @param invPreProductRequest
|
||||
* @return
|
||||
*/
|
||||
List<InvPreinProductResponse> filterList(FilterInvPreinProductRequest invPreProductRequest);
|
||||
|
||||
/**
|
||||
* 查询寄售库存实体列表
|
||||
*
|
||||
* @param invPreProductRequest
|
||||
* @return
|
||||
*/
|
||||
List<InvPreinProductEntity> filterPreProductList(FilterInvPreinProductRequest invPreProductRequest);
|
||||
|
||||
}
|
||||
@ -0,0 +1,7 @@
|
||||
package com.glxp.api.dao.sync;
|
||||
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.glxp.api.entity.sync.SyncDataChangeBustypesEntity;
|
||||
|
||||
public interface SyncDataChangeBustypesDao extends BaseMapper<SyncDataChangeBustypesEntity> {
|
||||
}
|
||||
@ -0,0 +1,167 @@
|
||||
package com.glxp.api.entity.inv;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* 寄售库存详情表
|
||||
*/
|
||||
@Data
|
||||
@TableName(value = "inv_pre_product_detail")
|
||||
public class InvPreInProductDetailEntity {
|
||||
@TableId(value = "id", type = IdType.AUTO)
|
||||
private Integer id;
|
||||
|
||||
/**
|
||||
* UDI码
|
||||
*/
|
||||
@TableField(value = "code")
|
||||
private String code;
|
||||
|
||||
/**
|
||||
* 出入单据类型
|
||||
*/
|
||||
@TableField(value = "mainAction")
|
||||
private String mainAction;
|
||||
|
||||
/**
|
||||
* 单据类型
|
||||
*/
|
||||
@TableField(value = "`action`")
|
||||
private String action;
|
||||
|
||||
/**
|
||||
* 订单号外键
|
||||
*/
|
||||
@TableField(value = "orderId")
|
||||
private String orderId;
|
||||
|
||||
/**
|
||||
* 耗材字典ID
|
||||
*/
|
||||
@TableField(value = "relId")
|
||||
private Long relId;
|
||||
|
||||
/**
|
||||
* 最小销售标识
|
||||
*/
|
||||
@TableField(value = "nameCode")
|
||||
private String nameCode;
|
||||
|
||||
/**
|
||||
* 批次号
|
||||
*/
|
||||
@TableField(value = "batchNo")
|
||||
private String batchNo;
|
||||
|
||||
/**
|
||||
* 生产日期
|
||||
*/
|
||||
@TableField(value = "produceDate")
|
||||
private String produceDate;
|
||||
|
||||
/**
|
||||
* 失效日期
|
||||
*/
|
||||
@TableField(value = "expireDate")
|
||||
private String expireDate;
|
||||
|
||||
/**
|
||||
* 序列号
|
||||
*/
|
||||
@TableField(value = "serialNo")
|
||||
private String serialNo;
|
||||
|
||||
/**
|
||||
* 供应商
|
||||
*/
|
||||
@TableField(value = "supId")
|
||||
private String supId;
|
||||
|
||||
/**
|
||||
* 扫码数量
|
||||
*/
|
||||
@TableField(value = "`count`")
|
||||
private int count;
|
||||
|
||||
/**
|
||||
* 实际数量
|
||||
*/
|
||||
@TableField(value = "reCount")
|
||||
private int reCount;
|
||||
|
||||
/**
|
||||
* 部门编码
|
||||
*/
|
||||
@TableField(value = "deptCode")
|
||||
private String deptCode;
|
||||
|
||||
/**
|
||||
* 仓库编码
|
||||
*/
|
||||
@TableField(value = "invCode")
|
||||
private String invCode;
|
||||
|
||||
/**
|
||||
* 货位编码
|
||||
*/
|
||||
@TableField(value = "invSpaceCode")
|
||||
private String invSpaceCode;
|
||||
|
||||
/**
|
||||
* 采购类型
|
||||
*/
|
||||
@TableField(value = "purchaseType")
|
||||
private Integer purchaseType;
|
||||
|
||||
/**
|
||||
* 更新时间
|
||||
*/
|
||||
@TableField(value = "updateTime")
|
||||
private Date updateTime;
|
||||
|
||||
|
||||
|
||||
public static final String COL_ID = "id";
|
||||
|
||||
public static final String COL_CODE = "code";
|
||||
|
||||
public static final String COL_MAINACTION = "mainAction";
|
||||
|
||||
public static final String COL_ACTION = "action";
|
||||
|
||||
public static final String COL_ORDERID = "orderId";
|
||||
|
||||
public static final String COL_RELID = "relId";
|
||||
|
||||
public static final String COL_NAMECODE = "nameCode";
|
||||
|
||||
public static final String COL_BATCHNO = "batchNo";
|
||||
|
||||
public static final String COL_PRODUCEDATE = "produceDate";
|
||||
|
||||
public static final String COL_EXPIREDATE = "expireDate";
|
||||
|
||||
public static final String COL_SERIALNO = "serialNo";
|
||||
|
||||
public static final String COL_SUPID = "supId";
|
||||
|
||||
public static final String COL_COUNT = "count";
|
||||
|
||||
public static final String COL_RECOUNT = "reCount";
|
||||
|
||||
public static final String COL_DEPTCODE = "deptCode";
|
||||
|
||||
public static final String COL_INVCODE = "invCode";
|
||||
|
||||
public static final String COL_INVSPACECODE = "invSpaceCode";
|
||||
|
||||
public static final String COL_PURCHASETYPE = "purchaseType";
|
||||
|
||||
public static final String COL_UPDATETIME = "updateTime";
|
||||
}
|
||||
@ -0,0 +1,133 @@
|
||||
package com.glxp.api.entity.inv;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* 预验收库存表
|
||||
*/
|
||||
@Data
|
||||
@TableName(value = "inv_prein_product")
|
||||
public class InvPreinProductEntity {
|
||||
@TableId(value = "id", type = IdType.AUTO)
|
||||
private Integer id;
|
||||
|
||||
/**
|
||||
* 耗材字典ID
|
||||
*/
|
||||
@TableField(value = "relIdFk")
|
||||
private Long relIdFk;
|
||||
|
||||
/**
|
||||
* 最小销售标识
|
||||
*/
|
||||
@TableField(value = "nameCode")
|
||||
private String nameCode;
|
||||
|
||||
/**
|
||||
* 批次号
|
||||
*/
|
||||
@TableField(value = "batchNo")
|
||||
private String batchNo;
|
||||
|
||||
/**
|
||||
* 生产日期
|
||||
*/
|
||||
@TableField(value = "productionDate")
|
||||
private String productionDate;
|
||||
|
||||
/**
|
||||
* 失效日期
|
||||
*/
|
||||
@TableField(value = "expireDate")
|
||||
private String expireDate;
|
||||
|
||||
/**
|
||||
* 入库数量
|
||||
*/
|
||||
@TableField(value = "inCount")
|
||||
private int inCount;
|
||||
|
||||
/**
|
||||
* 出库数量
|
||||
*/
|
||||
@TableField(value = "outCount")
|
||||
private int outCount;
|
||||
|
||||
/**
|
||||
* 实际数量
|
||||
*/
|
||||
@TableField(value = "reCount")
|
||||
private int reCount;
|
||||
|
||||
/**
|
||||
* 客户ID
|
||||
*/
|
||||
@TableField(value = "customerId")
|
||||
private String customerId;
|
||||
|
||||
/**
|
||||
* 供应商ID
|
||||
*/
|
||||
@TableField(value = "supId")
|
||||
private String supId;
|
||||
|
||||
/**
|
||||
* 部门编码
|
||||
*/
|
||||
@TableField(value = "deptCode")
|
||||
private String deptCode;
|
||||
|
||||
/**
|
||||
* 仓库编码
|
||||
*/
|
||||
@TableField(value = "invCode")
|
||||
private String invCode;
|
||||
|
||||
/**
|
||||
* 创建时间
|
||||
*/
|
||||
@TableField(value = "createTime")
|
||||
private Date createTime;
|
||||
|
||||
/**
|
||||
* 更新时间
|
||||
*/
|
||||
@TableField(value = "updateTime")
|
||||
private Date updateTime;
|
||||
|
||||
public static final String COL_ID = "id";
|
||||
|
||||
public static final String COL_RELIDFK = "relIdFk";
|
||||
|
||||
public static final String COL_NAMECODE = "nameCode";
|
||||
|
||||
public static final String COL_BATCHNO = "batchNo";
|
||||
|
||||
public static final String COL_PRODUCTIONDATE = "productionDate";
|
||||
|
||||
public static final String COL_EXPIREDATE = "expireDate";
|
||||
|
||||
public static final String COL_INCOUNT = "inCount";
|
||||
|
||||
public static final String COL_OUTCOUNT = "outCount";
|
||||
|
||||
public static final String COL_RECOUNT = "reCount";
|
||||
|
||||
public static final String COL_CUSTOMERID = "customerId";
|
||||
|
||||
public static final String COL_SUPID = "supId";
|
||||
|
||||
public static final String COL_DEPTCODE = "deptCode";
|
||||
|
||||
public static final String COL_INVCODE = "invCode";
|
||||
|
||||
public static final String COL_CREATETIME = "createTime";
|
||||
|
||||
public static final String COL_UPDATETIME = "updateTime";
|
||||
}
|
||||
@ -1,14 +1,27 @@
|
||||
package com.glxp.api.entity.sync;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 同步数据扫码单据类型
|
||||
*/
|
||||
@Data
|
||||
@TableName(value = "sync_data_bustypes")
|
||||
public class SyncDataBustypeEntity {
|
||||
|
||||
@TableId(value = "id", type = IdType.AUTO)
|
||||
private Integer id;
|
||||
@TableField(value = "`action`")
|
||||
private String action;
|
||||
@TableField(value = "`name`")
|
||||
private String name;
|
||||
@TableField(value = "`outChange`")
|
||||
private boolean outChange;
|
||||
@TableField(value = "`orderStatus`")
|
||||
private Integer orderStatus; //单据状态
|
||||
|
||||
@TableField(value = "`direct`")
|
||||
private int direct; //1:UDI管理系统->SPMS 2:SPMS->UDI管理系统
|
||||
}
|
||||
|
||||
@ -0,0 +1,31 @@
|
||||
package com.glxp.api.entity.sync;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 单据同步 - 业务单据类型
|
||||
*/
|
||||
@Data
|
||||
@TableName(value = "sync_data_change_bustypes")
|
||||
public class SyncDataChangeBustypesEntity {
|
||||
|
||||
@TableId(value = "id", type = IdType.AUTO)
|
||||
private Integer id;
|
||||
|
||||
@TableField(value = "`action`")
|
||||
private String action;
|
||||
|
||||
@TableField(value = "`name`")
|
||||
private String name;
|
||||
|
||||
@TableField(value = "outChange")
|
||||
private boolean outChange;
|
||||
|
||||
@TableField(value = "orderStatus")
|
||||
private Integer orderStatus;
|
||||
|
||||
}
|
||||
@ -0,0 +1,33 @@
|
||||
package com.glxp.api.idc.controller;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
|
||||
import org.springframework.web.bind.annotation.RequestBody;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.ResponseBody;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
import com.glxp.api.common.res.BaseResponse;
|
||||
import com.glxp.api.common.util.ResultVOUtils;
|
||||
import com.glxp.api.idc.service.DeleteService;
|
||||
|
||||
|
||||
|
||||
|
||||
@RestController
|
||||
public class DeleteController {
|
||||
@Resource
|
||||
DeleteService deleteService;
|
||||
|
||||
@RequestMapping(value = "/spssync/common/delete")
|
||||
@ResponseBody
|
||||
public BaseResponse delete(HttpServletRequest request, @RequestBody Map<String, Object> params) {
|
||||
if(deleteService.syncDelete(params))
|
||||
return ResultVOUtils.success();
|
||||
return ResultVOUtils.error(9999, "失败");
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,10 @@
|
||||
package com.glxp.api.idc.service;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
/*数据中继删除数据处理*/
|
||||
public interface DeleteService {
|
||||
|
||||
boolean syncDelete(String tableName,String uniqueValue);
|
||||
boolean syncDelete(Map<String,Object> params);
|
||||
}
|
||||
@ -0,0 +1,58 @@
|
||||
package com.glxp.api.idc.service.impl;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.jdbc.core.JdbcTemplate;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import com.alibaba.fastjson2.JSON;
|
||||
import com.glxp.api.dao.idc.DbDao;
|
||||
import com.glxp.api.idc.service.DeleteService;
|
||||
import com.glxp.api.util.CustomUtil;
|
||||
|
||||
|
||||
@Service
|
||||
public class DeleteServiceImpl implements DeleteService {
|
||||
private static final Logger logger = LoggerFactory.getLogger(DeleteServiceImpl.class);
|
||||
@Resource
|
||||
private JdbcTemplate jdbcTemplate;
|
||||
@Resource
|
||||
private DbDao dbDao;
|
||||
|
||||
@Override
|
||||
public boolean syncDelete(String tableName,String uniqueValue) {
|
||||
Map<String,Object> map = new HashMap<>();
|
||||
map.put("tableName", tableName);
|
||||
map.put("uniqueValue", uniqueValue);
|
||||
return syncDelete(map);
|
||||
}
|
||||
@Override
|
||||
public boolean syncDelete(Map<String,Object> params) {
|
||||
createTable();
|
||||
String sql = "insert into idc_delete (id,tableName,updateTime,uniqueValue) values ('"+CustomUtil.getId()+"','"+params.get("tableName").toString().toLowerCase()+"',now(),'"+JSON.toJSONString(params.get("uniqueValue"))+"')";
|
||||
|
||||
if(dbDao.save(sql)>0)
|
||||
return true;
|
||||
return false;
|
||||
}
|
||||
|
||||
private void createTable() {
|
||||
try {
|
||||
jdbcTemplate.execute("create table idc_delete (id varchar(36),tableName varchar(100),uniqueValue varchar(600),updateTime datetime,PRIMARY KEY (id))");
|
||||
|
||||
} catch (Exception e) {
|
||||
|
||||
}
|
||||
try {
|
||||
jdbcTemplate.execute("create index i_idc_delete_table_name on idc_delete (tableName asc)");
|
||||
|
||||
} catch (Exception e) {
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,101 @@
|
||||
package com.glxp.api.req.inv;
|
||||
|
||||
import com.glxp.api.util.page.ListPageRequest;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 预验收库存查询参数
|
||||
*/
|
||||
@Data
|
||||
public class FilterInvPreinProductRequest extends ListPageRequest {
|
||||
|
||||
private String id;
|
||||
|
||||
/**
|
||||
* 产品名称
|
||||
*/
|
||||
private String cpmctymc;
|
||||
|
||||
/**
|
||||
* 产品标识DI
|
||||
*/
|
||||
private String nameCode;
|
||||
|
||||
/**
|
||||
* UDI码
|
||||
*/
|
||||
private String udiCode;
|
||||
|
||||
/**
|
||||
* 耗材字典ID
|
||||
*/
|
||||
private String relIdFk;
|
||||
|
||||
/**
|
||||
* 规格型号
|
||||
*/
|
||||
private String ggxh;
|
||||
|
||||
/**
|
||||
* 批次号
|
||||
*/
|
||||
private String batchNo;
|
||||
|
||||
/**
|
||||
* 生产日期
|
||||
*/
|
||||
private String productionDate;
|
||||
|
||||
/**
|
||||
* 失效日期
|
||||
*/
|
||||
private String expireDate;
|
||||
|
||||
/**
|
||||
* 生产厂家
|
||||
*/
|
||||
private String ylqxzcrbarmc;
|
||||
|
||||
/**
|
||||
* 批准文号
|
||||
*/
|
||||
private String zczbhhzbapzbh;
|
||||
|
||||
/**
|
||||
* 客户ID
|
||||
*/
|
||||
private String customerId;
|
||||
|
||||
/**
|
||||
* 供应商ID
|
||||
*/
|
||||
private String supId;
|
||||
|
||||
/**
|
||||
* 供应商名称
|
||||
*/
|
||||
private String supName;
|
||||
|
||||
/**
|
||||
* 部门编码
|
||||
*/
|
||||
private String deptCode;
|
||||
|
||||
/**
|
||||
* 仓库编码
|
||||
*/
|
||||
private String invCode;
|
||||
|
||||
/**
|
||||
* 仓库数组
|
||||
*/
|
||||
private List<String> invCodes;
|
||||
|
||||
/**
|
||||
* 产品类别
|
||||
*/
|
||||
private String cplb;
|
||||
|
||||
}
|
||||
@ -0,0 +1,108 @@
|
||||
package com.glxp.api.res.inv;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 预验收库存VO
|
||||
*/
|
||||
@Data
|
||||
public class InvPreinProductResponse {
|
||||
|
||||
private Integer id;
|
||||
|
||||
/**
|
||||
* 产品标识DI
|
||||
*/
|
||||
private String nameCode;
|
||||
|
||||
/**
|
||||
* 产品名称
|
||||
*/
|
||||
private String cpmctymc;
|
||||
|
||||
/**
|
||||
* 耗材字典ID
|
||||
*/
|
||||
private String relIdFk;
|
||||
|
||||
/**
|
||||
* 规格型号
|
||||
*/
|
||||
private String ggxh;
|
||||
|
||||
/**
|
||||
* 批次号
|
||||
*/
|
||||
private String batchNo;
|
||||
|
||||
/**
|
||||
* 生产日期
|
||||
*/
|
||||
private String productionDate;
|
||||
|
||||
/**
|
||||
* 过期时间
|
||||
*/
|
||||
private String expireDate;
|
||||
|
||||
/**
|
||||
* 生产厂家名称
|
||||
*/
|
||||
private String ylqxzcrbarmc;
|
||||
|
||||
/**
|
||||
* 批准文号
|
||||
*/
|
||||
private String zczbhhzbapzbh;
|
||||
|
||||
/**
|
||||
* 入库数量
|
||||
*/
|
||||
private int inCount;
|
||||
|
||||
/**
|
||||
* 出库数量
|
||||
*/
|
||||
private int outCount;
|
||||
|
||||
/**
|
||||
* 实际数量
|
||||
*/
|
||||
private int reCount;
|
||||
|
||||
/**
|
||||
* 客户ID
|
||||
*/
|
||||
private String customerId;
|
||||
|
||||
/**
|
||||
* 供应商名称
|
||||
*/
|
||||
private String supName;
|
||||
|
||||
/**
|
||||
* 供应商ID
|
||||
*/
|
||||
private String supId;
|
||||
|
||||
/**
|
||||
* 部门名称
|
||||
*/
|
||||
private String deptName;
|
||||
|
||||
/**
|
||||
* 仓库名称
|
||||
*/
|
||||
private String invName;
|
||||
|
||||
/**
|
||||
* 部门编码
|
||||
*/
|
||||
private String deptCode;
|
||||
|
||||
/**
|
||||
* 仓库编码
|
||||
*/
|
||||
private String invCode;
|
||||
|
||||
}
|
||||
@ -0,0 +1,14 @@
|
||||
package com.glxp.api.res.sync;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Data
|
||||
public class BaseSyncResponse {
|
||||
|
||||
private String taskId;
|
||||
private List<String> files;
|
||||
private String updateTime;
|
||||
|
||||
}
|
||||
@ -0,0 +1,53 @@
|
||||
package com.glxp.api.service.inv;
|
||||
|
||||
import com.glxp.api.entity.inv.InvPreInProductDetailEntity;
|
||||
import com.glxp.api.entity.inv.InvPreProductDetailEntity;
|
||||
import com.glxp.api.req.inv.FilterInvPreProductDetailRequest;
|
||||
import com.glxp.api.req.inv.FilterInvProductDetailRequest;
|
||||
import com.glxp.api.res.inv.InvPreProductDetailResponse;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 预验收库存详情Service
|
||||
*/
|
||||
public interface InvPreinProductDetailService {
|
||||
|
||||
int insert(InvPreInProductDetailEntity invPreInProductDetailEntity);
|
||||
|
||||
boolean insertList(List<InvPreInProductDetailEntity> invPreProductDetailEntities);
|
||||
|
||||
List<InvPreInProductDetailEntity> selectByOrderIdFk(String billNo);
|
||||
|
||||
InvPreInProductDetailEntity selectByCode(String billNo, String code);
|
||||
|
||||
boolean update(InvPreInProductDetailEntity invPreInProductDetailEntity);
|
||||
|
||||
boolean deleteById(String id);
|
||||
|
||||
int deleteByOrderId(String billNo);
|
||||
|
||||
/**
|
||||
* 查询寄售库存详情列表
|
||||
*
|
||||
* @param invPreProductDetailRequest
|
||||
* @return
|
||||
*/
|
||||
List<InvPreInProductDetailEntity> filterPreProductDetailList(FilterInvPreProductDetailRequest invPreProductDetailRequest);
|
||||
|
||||
/**
|
||||
* 设置单据类型名称等单据相关参数
|
||||
*
|
||||
* @param response
|
||||
*/
|
||||
void setOrderInfo(InvPreProductDetailResponse response);
|
||||
|
||||
/**
|
||||
* 删除寄售库存详情
|
||||
*
|
||||
* @param detailRequest
|
||||
*/
|
||||
boolean deleteInvPreProductDetail(FilterInvProductDetailRequest detailRequest);
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,49 @@
|
||||
package com.glxp.api.service.inv;
|
||||
|
||||
import com.glxp.api.entity.inv.InvPreinProductEntity;
|
||||
import com.glxp.api.req.inv.FilterInvPreinDetailRequest;
|
||||
import com.glxp.api.req.inv.FilterInvPreinProductRequest;
|
||||
import com.glxp.api.res.inv.InvPreinProductResponse;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 预验收库存Service
|
||||
*/
|
||||
public interface InvPreinProductService {
|
||||
|
||||
int insert(InvPreinProductEntity invPreinProductEntity);
|
||||
|
||||
|
||||
boolean update(InvPreinProductEntity invPreinProductEntity);
|
||||
|
||||
InvPreinProductEntity selectByUnique(Long relId, String batchNo, String supId, String deptCode, String invCode);
|
||||
|
||||
boolean deleteById(Integer id);
|
||||
|
||||
/**
|
||||
* 查询寄售库存VO
|
||||
*
|
||||
* @param filterInvPreinDetailRequest
|
||||
* @return
|
||||
*/
|
||||
List<InvPreinProductResponse> filterList(FilterInvPreinProductRequest filterInvPreinDetailRequest);
|
||||
|
||||
/**
|
||||
* 查询寄售库存列表
|
||||
*
|
||||
* @param invPreProductRequest
|
||||
* @return
|
||||
*/
|
||||
List<InvPreinProductEntity> filterPreinProductList(FilterInvPreinProductRequest invPreProductRequest);
|
||||
|
||||
/**
|
||||
* 根据ID查询寄售库存信息
|
||||
*
|
||||
* @param id
|
||||
* @return
|
||||
*/
|
||||
InvPreinProductEntity findById(String id);
|
||||
|
||||
boolean isExitByRelId(String relId);
|
||||
}
|
||||
@ -0,0 +1,83 @@
|
||||
package com.glxp.api.service.inv.impl;
|
||||
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import com.github.pagehelper.PageHelper;
|
||||
import com.glxp.api.dao.inv.InvPreinProductDao;
|
||||
import com.glxp.api.entity.inv.InvPreinProductEntity;
|
||||
import com.glxp.api.req.inv.FilterInvPreinProductRequest;
|
||||
import com.glxp.api.res.inv.InvPreinProductResponse;
|
||||
import com.glxp.api.service.inv.InvPreinProductService;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
|
||||
@Slf4j
|
||||
@Service
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public class InvPreinProductServiceImpl implements InvPreinProductService {
|
||||
|
||||
@Resource
|
||||
private InvPreinProductDao invPreinProductDao;
|
||||
|
||||
@Override
|
||||
public int insert(InvPreinProductEntity invPreinProductEntity) {
|
||||
return invPreinProductDao.insert(invPreinProductEntity);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean update(InvPreinProductEntity invPreinProductEntity) {
|
||||
return invPreinProductDao.updateById(invPreinProductEntity) == 1 ? true : false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public InvPreinProductEntity selectByUnique(Long relId, String batchNo, String supId, String deptCode, String invCode) {
|
||||
return invPreinProductDao.selectOne(new QueryWrapper<InvPreinProductEntity>().eq("relIdFk", relId).eq(StrUtil.isNotEmpty(batchNo), "batchNo", batchNo)
|
||||
.isNull(StrUtil.isEmpty(batchNo), "batchNo").eq("supId", supId).eq("deptCode", deptCode).eq("invCode", invCode));
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteById(Integer id) {
|
||||
return invPreinProductDao.deleteById(id) == 1 ? true : false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<InvPreinProductResponse> filterList(FilterInvPreinProductRequest invPreProductRequest) {
|
||||
if (null == invPreProductRequest) {
|
||||
return Collections.emptyList();
|
||||
}
|
||||
if (null != invPreProductRequest.getPage()) {
|
||||
PageHelper.offsetPage((invPreProductRequest.getPage() - 1) * invPreProductRequest.getLimit(), invPreProductRequest.getLimit());
|
||||
}
|
||||
return invPreinProductDao.filterList(invPreProductRequest);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<InvPreinProductEntity> filterPreinProductList(FilterInvPreinProductRequest invPreProductRequest) {
|
||||
if (null == invPreProductRequest) {
|
||||
return Collections.emptyList();
|
||||
}
|
||||
if (null != invPreProductRequest.getPage() && null != invPreProductRequest.getLimit()) {
|
||||
PageHelper.offsetPage((invPreProductRequest.getPage() - 1) * invPreProductRequest.getLimit(), invPreProductRequest.getLimit());
|
||||
}
|
||||
return invPreinProductDao.filterPreProductList(invPreProductRequest);
|
||||
}
|
||||
|
||||
@Override
|
||||
public InvPreinProductEntity findById(String id) {
|
||||
return invPreinProductDao.selectById(id);
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public boolean isExitByRelId(String relId) {
|
||||
return invPreinProductDao.exists(new QueryWrapper<InvPreinProductEntity>().eq("relIdFk", relId));
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,19 @@
|
||||
package com.glxp.api.service.sync;
|
||||
|
||||
|
||||
import com.glxp.api.entity.sync.SyncDataChangeBustypesEntity;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 单据同步 - 业务单据类型 Service
|
||||
*/
|
||||
public interface SyncDataChangeBustypeService {
|
||||
|
||||
List<SyncDataChangeBustypesEntity> findAll();
|
||||
|
||||
boolean deleteAll();
|
||||
|
||||
void inserts(List<SyncDataChangeBustypesEntity> syncDataChangeBustypesEntities);
|
||||
|
||||
}
|
||||
@ -0,0 +1,44 @@
|
||||
package com.glxp.api.service.sync.impl;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import com.glxp.api.dao.sync.SyncDataChangeBustypesDao;
|
||||
import com.glxp.api.entity.sync.SyncDataChangeBustypesEntity;
|
||||
import com.glxp.api.service.sync.SyncDataChangeBustypeService;
|
||||
import org.apache.ibatis.session.ExecutorType;
|
||||
import org.apache.ibatis.session.SqlSession;
|
||||
import org.apache.ibatis.session.SqlSessionFactory;
|
||||
import org.apache.ibatis.session.TransactionIsolationLevel;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.List;
|
||||
|
||||
@Service
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public class SyncDataChangeBustypeServiceImpl implements SyncDataChangeBustypeService {
|
||||
|
||||
@Resource
|
||||
private SyncDataChangeBustypesDao syncDataChangeBustypesDao;
|
||||
@Resource
|
||||
private SqlSessionFactory sqlSessionFactory;
|
||||
|
||||
@Override
|
||||
public List<SyncDataChangeBustypesEntity> findAll() {
|
||||
return syncDataChangeBustypesDao.selectList(null);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean deleteAll() {
|
||||
syncDataChangeBustypesDao.delete(null);
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void inserts(List<SyncDataChangeBustypesEntity> syncDataChangeBustypesEntities) {
|
||||
if (CollUtil.isNotEmpty(syncDataChangeBustypesEntities)) {
|
||||
SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
|
||||
syncDataChangeBustypesEntities.forEach(item -> syncDataChangeBustypesDao.insert(item));
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,53 @@
|
||||
server:
|
||||
port: 9993
|
||||
spring:
|
||||
datasource:
|
||||
driver-class-name: com.p6spy.engine.spy.P6SpyDriver
|
||||
jdbc-url: jdbc:p6spy:mysql://127.0.0.1:3306/udi_spms?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
|
||||
username: root
|
||||
password: 123456
|
||||
hikari:
|
||||
connection-timeout: 60000
|
||||
maximum-pool-size: 60
|
||||
minimum-idle: 10
|
||||
redis:
|
||||
database: 10
|
||||
host: 127.0.0.1
|
||||
port: 6379
|
||||
# password: 123456
|
||||
timeout: 300
|
||||
jedis:
|
||||
pool:
|
||||
max-active: 8
|
||||
max-wait: -1
|
||||
max-idle: 8
|
||||
min-idle: 0
|
||||
jackson:
|
||||
date-format: yyyy-MM-dd HH:mm:ss
|
||||
time-zone: GMT+8
|
||||
servlet:
|
||||
multipart:
|
||||
max-file-size: 500MB
|
||||
max-request-size: 500MB
|
||||
|
||||
ok:
|
||||
http:
|
||||
connect-timeout: 3000
|
||||
read-timeout: 3000
|
||||
write-timeout: 3000
|
||||
max-idle-connections: 200
|
||||
keep-alive-duration: 300
|
||||
|
||||
|
||||
logging:
|
||||
level:
|
||||
com.glxp.api.dao: debug
|
||||
|
||||
file_path: d:/udi/udiwms/udiwmsfile/
|
||||
back_file_path: d:/share/udisps/back/
|
||||
UDI_KEY: 6b137c66-6286-46c6-8efa-c2f5dd9237df
|
||||
UDI_SERVER_URL: https://www.udims.com/UDI_DL_Server_test
|
||||
SPMS_KEY: lCOdWCBKS6Kw45wdnnqUTELXyuSKnXEs
|
||||
|
||||
API_KEY: 1101
|
||||
API_SECRET: zBITspLNvuoEd4FaamlSoqxRHmNsmQ9L
|
||||
@ -0,0 +1,53 @@
|
||||
server:
|
||||
port: 9993
|
||||
spring:
|
||||
datasource:
|
||||
driver-class-name: com.mysql.cj.jdbc.Driver
|
||||
jdbc-url: jdbc:mysql://192.168.0.66:3364/udi_spms_ljy?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
|
||||
username: root
|
||||
password: Glxp@6066
|
||||
hikari:
|
||||
connection-timeout: 60000
|
||||
maximum-pool-size: 60
|
||||
minimum-idle: 10
|
||||
redis:
|
||||
database: 10
|
||||
host: 127.0.0.1
|
||||
port: 6404
|
||||
# password: 123456
|
||||
timeout: 300
|
||||
jedis:
|
||||
pool:
|
||||
max-active: 8
|
||||
max-wait: -1
|
||||
max-idle: 8
|
||||
min-idle: 0
|
||||
jackson:
|
||||
date-format: yyyy-MM-dd HH:mm:ss
|
||||
time-zone: GMT+8
|
||||
servlet:
|
||||
multipart:
|
||||
max-file-size: 500MB
|
||||
max-request-size: 500MB
|
||||
|
||||
ok:
|
||||
http:
|
||||
connect-timeout: 3000
|
||||
read-timeout: 3000
|
||||
write-timeout: 3000
|
||||
max-idle-connections: 200
|
||||
keep-alive-duration: 300
|
||||
|
||||
|
||||
logging:
|
||||
level:
|
||||
com.glxp.api.dao: debug
|
||||
|
||||
file_path: /udi/udiwms/udiwmsfile/
|
||||
back_file_path: /share/udisps/back/
|
||||
UDI_KEY: 6b137c66-6286-46c6-8efa-c2f5dd9237df
|
||||
UDI_SERVER_URL: https://www.udims.com/UDI_DL_Server_test
|
||||
SPMS_KEY: lCOdWCBKS6Kw45wdnnqUTELXyuSKnXEs
|
||||
|
||||
API_KEY: 1101
|
||||
API_SECRET: zBITspLNvuoEd4FaamlSoqxRHmNsmQ9L
|
||||
@ -0,0 +1,53 @@
|
||||
server:
|
||||
port: 9993
|
||||
spring:
|
||||
datasource:
|
||||
driver-class-name: com.mysql.cj.jdbc.Driver
|
||||
jdbc-url: jdbc:mysql://192.168.0.66:3364/udi_spms_ljy?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
|
||||
username: root
|
||||
password: Glxp@6066
|
||||
hikari:
|
||||
connection-timeout: 60000
|
||||
maximum-pool-size: 60
|
||||
minimum-idle: 10
|
||||
redis:
|
||||
database: 10
|
||||
host: 127.0.0.1
|
||||
port: 6404
|
||||
# password: 123456
|
||||
timeout: 300
|
||||
jedis:
|
||||
pool:
|
||||
max-active: 8
|
||||
max-wait: -1
|
||||
max-idle: 8
|
||||
min-idle: 0
|
||||
jackson:
|
||||
date-format: yyyy-MM-dd HH:mm:ss
|
||||
time-zone: GMT+8
|
||||
servlet:
|
||||
multipart:
|
||||
max-file-size: 500MB
|
||||
max-request-size: 500MB
|
||||
|
||||
ok:
|
||||
http:
|
||||
connect-timeout: 3000
|
||||
read-timeout: 3000
|
||||
write-timeout: 3000
|
||||
max-idle-connections: 200
|
||||
keep-alive-duration: 300
|
||||
|
||||
|
||||
logging:
|
||||
level:
|
||||
com.glxp.api.dao: debug
|
||||
|
||||
file_path: /udi/udiwms/udiwmsfile/
|
||||
back_file_path: /share/udisps/back/
|
||||
UDI_KEY: 6b137c66-6286-46c6-8efa-c2f5dd9237df
|
||||
UDI_SERVER_URL: https://www.udims.com/UDI_DL_Server_test
|
||||
SPMS_KEY: lCOdWCBKS6Kw45wdnnqUTELXyuSKnXEs
|
||||
|
||||
API_KEY: 1101
|
||||
API_SECRET: zBITspLNvuoEd4FaamlSoqxRHmNsmQ9L
|
||||
@ -0,0 +1,53 @@
|
||||
server:
|
||||
port: 9993
|
||||
spring:
|
||||
datasource:
|
||||
driver-class-name: com.mysql.cj.jdbc.Driver
|
||||
jdbc-url: jdbc:mysql://192.168.0.66:3364/udi_spms_wqq?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
|
||||
username: root
|
||||
password: Glxp@6066
|
||||
hikari:
|
||||
connection-timeout: 60000
|
||||
maximum-pool-size: 60
|
||||
minimum-idle: 10
|
||||
redis:
|
||||
database: 10
|
||||
host: 127.0.0.1
|
||||
port: 6405
|
||||
# password: 123456
|
||||
timeout: 300
|
||||
jedis:
|
||||
pool:
|
||||
max-active: 8
|
||||
max-wait: -1
|
||||
max-idle: 8
|
||||
min-idle: 0
|
||||
jackson:
|
||||
date-format: yyyy-MM-dd HH:mm:ss
|
||||
time-zone: GMT+8
|
||||
servlet:
|
||||
multipart:
|
||||
max-file-size: 500MB
|
||||
max-request-size: 500MB
|
||||
|
||||
ok:
|
||||
http:
|
||||
connect-timeout: 3000
|
||||
read-timeout: 3000
|
||||
write-timeout: 3000
|
||||
max-idle-connections: 200
|
||||
keep-alive-duration: 300
|
||||
|
||||
|
||||
logging:
|
||||
level:
|
||||
com.glxp.api.dao: debug
|
||||
|
||||
file_path: /udi/udiwms/udiwmsfile/
|
||||
back_file_path: /share/udisps/back/
|
||||
UDI_KEY: 6b137c66-6286-46c6-8efa-c2f5dd9237df
|
||||
UDI_SERVER_URL: https://www.udims.com/UDI_DL_Server_test
|
||||
SPMS_KEY: lCOdWCBKS6Kw45wdnnqUTELXyuSKnXEs
|
||||
|
||||
API_KEY: 1101
|
||||
API_SECRET: zBITspLNvuoEd4FaamlSoqxRHmNsmQ9L
|
||||
@ -0,0 +1,77 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.glxp.api.dao.inv.InvPreInProductDetailDao">
|
||||
<select id="filterPreProductDetailList" resultType="com.glxp.api.entity.inv.InvPreInProductDetailEntity">
|
||||
select *
|
||||
from inv_prein_product_detail
|
||||
<where>
|
||||
<if test="code != null and code != ''">
|
||||
AND code = #{code}
|
||||
</if>
|
||||
<if test="mainAction != null and mainAction != ''">
|
||||
AND mainAction = #{mainAction}
|
||||
</if>
|
||||
<if test="action != null and action != ''">
|
||||
AND action = #{action}
|
||||
</if>
|
||||
<if test="supId != null and supId != ''">
|
||||
and supId = #{supId}
|
||||
</if>
|
||||
<if test="relId != null and relId != ''">
|
||||
AND relId = #{relId}
|
||||
</if>
|
||||
<if test="nameCode != null and nameCode != ''">
|
||||
AND nameCode like concat('%', #{nameCode}, '%')
|
||||
</if>
|
||||
<if test="orderId != null and orderId != ''">
|
||||
AND orderId = #{orderId}
|
||||
</if>
|
||||
<if test="deptCode != null and deptCode != ''">
|
||||
AND deptCode = #{deptCode}
|
||||
</if>
|
||||
<if test="invCode != null and invCode != ''">
|
||||
AND invCode = #{invCode}
|
||||
</if>
|
||||
<if test="invSpaceCode != null and invSpaceCode != ''">
|
||||
AND invSpaceCode = #{invSpaceCode}
|
||||
</if>
|
||||
<if test="batchNo != null and batchNo != ''">
|
||||
AND batchNo = #{batchNo}
|
||||
</if>
|
||||
<if test="batchNo == null and batchNo == ''">
|
||||
AND batchNo is null
|
||||
</if>
|
||||
<if test="productIdList != null and productIdList.size() != 0">
|
||||
AND relId in
|
||||
<foreach collection="productIdList" item="item" index="index" open="(" close=")" separator=",">
|
||||
#{item}
|
||||
</foreach>
|
||||
</if>
|
||||
<if test="updateTime != null and updateTime != ''">
|
||||
AND updateTime <![CDATA[ <= ]]> #{updateTime}
|
||||
</if>
|
||||
</where>
|
||||
</select>
|
||||
|
||||
<delete id="deleteInvPreProductDetail">
|
||||
delete
|
||||
from inv_prein_product_detail
|
||||
<where>
|
||||
<if test="relId != null and relId != ''">
|
||||
AND relId = #{relId}
|
||||
</if>
|
||||
<if test="batchNo != null and batchNo != '' and batchNo != 'empty'">
|
||||
AND batchNo = #{batchNo}
|
||||
</if>
|
||||
<if test="batchNo == 'empty'">
|
||||
AND batchNo is null
|
||||
</if>
|
||||
<if test="supId != null and supId != ''">
|
||||
AND supId = #{supId}
|
||||
</if>
|
||||
<if test="invCode != null and invCode != ''">
|
||||
AND invCode = #{invCode}
|
||||
</if>
|
||||
</where>
|
||||
</delete>
|
||||
</mapper>
|
||||
@ -0,0 +1,138 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.glxp.api.dao.inv.InvPreinProductDao">
|
||||
<select id="filterList" resultType="com.glxp.api.res.inv.InvPreinProductResponse">
|
||||
select ipp.id,
|
||||
ipp.nameCode,
|
||||
bp.cpmctymc,
|
||||
ipp.relIdFk,
|
||||
bp.ggxh,
|
||||
ipp.batchNo,
|
||||
ipp.productionDate,
|
||||
ipp.expireDate,
|
||||
bp.ylqxzcrbarmc,
|
||||
bp.zczbhhzbapzbh,
|
||||
ipp.inCount,
|
||||
ipp.outCount,
|
||||
ipp.reCount,
|
||||
ipp.customerId,
|
||||
basic_corp.name supName,
|
||||
ipp.supId,
|
||||
auth_dept.name deptName,
|
||||
auth_warehouse.name invName,
|
||||
ipp.deptCode,
|
||||
ipp.invCode
|
||||
from inv_prein_product ipp
|
||||
inner join basic_udirel on ipp.relIdFk = basic_udirel.id
|
||||
inner join basic_products bp on basic_udirel.uuid = bp.uuid
|
||||
left join basic_corp on ipp.supId = basic_corp.erpId
|
||||
left join auth_dept on auth_dept.code = ipp.deptCode
|
||||
left join auth_warehouse on auth_warehouse.code = ipp.invCode
|
||||
<where>
|
||||
bp.diType = 1
|
||||
<if test="cpmctymc != null and cpmctymc != ''">
|
||||
AND bp.cpmctymc like concat('%', #{cpmctymc}, '%')
|
||||
</if>
|
||||
<if test="nameCode != null and nameCode != ''">
|
||||
AND ipp.nameCode like concat('%', #{nameCode}, '%')
|
||||
</if>
|
||||
<if test="relIdFk != null and relIdFk != ''">
|
||||
AND ipp.relIdFk = #{relIdFk}
|
||||
</if>
|
||||
<if test="ggxh != null and ggxh != ''">
|
||||
AND bp.ggxh like concat('%', #{ggxh}, '%')
|
||||
</if>
|
||||
<if test="batchNo != null and batchNo != ''">
|
||||
AND ipp.batchNo like concat('%', #{batchNo}, '%')
|
||||
</if>
|
||||
<if test="productionDate != null and productionDate != ''">
|
||||
AND ipp.productionDate = #{productionDate}
|
||||
</if>
|
||||
<if test="expireDate != null and expireDate != ''">
|
||||
AND ipp.expireDate = #{expireDate}
|
||||
</if>
|
||||
<if test="ylqxzcrbarmc != null and ylqxzcrbarmc != ''">
|
||||
AND bp.ylqxzcrbarmc like concat('%', #{ylqxzcrbarmc}, '%')
|
||||
</if>
|
||||
<if test="zczbhhzbapzbh != null and zczbhhzbapzbh != ''">
|
||||
AND bp.zczbhhzbapzbh like concat('%', #{zczbhhzbapzbh}, '%')
|
||||
</if>
|
||||
<if test="customerId != null and customerId != ''">
|
||||
AND ipp.customerId = #{customerId}
|
||||
</if>
|
||||
<if test="supId != null and supId != ''">
|
||||
AND ipp.supId = #{supId}
|
||||
</if>
|
||||
<if test="deptCode != null and deptCode != ''">
|
||||
AND ipp.deptCode = #{deptCode}
|
||||
</if>
|
||||
<if test="invCode != null and invCode != ''">
|
||||
AND ipp.invCode = #{invCode}
|
||||
</if>
|
||||
<if test="invCodes != null and invCodes.size() != 0">
|
||||
AND ipp.invCode in
|
||||
<foreach collection="invCodes" item="item" index="index" open="(" close=")" separator=",">
|
||||
#{item}
|
||||
</foreach>
|
||||
</if>
|
||||
</where>
|
||||
</select>
|
||||
|
||||
<select id="filterPreProductList" resultType="com.glxp.api.entity.inv.InvPreinProductEntity">
|
||||
select ipp.*
|
||||
from inv_prein_product ipp
|
||||
inner join basic_udirel on ipp.relIdFk = basic_udirel.id
|
||||
inner join basic_products bp on basic_udirel.uuid = bp.uuid
|
||||
left join basic_corp on ipp.supId = basic_corp.erpId
|
||||
left join auth_dept on auth_dept.code = ipp.deptCode
|
||||
left join auth_warehouse on auth_warehouse.code = ipp.invCode
|
||||
<where>
|
||||
bp.diType = 1
|
||||
<if test="cpmctymc != null and cpmctymc != ''">
|
||||
AND bp.cpmctymc like concat('%', #{cpmctymc}, '%')
|
||||
</if>
|
||||
<if test="nameCode != null and nameCode != ''">
|
||||
AND ipp.nameCode like concat('%', #{nameCode}, '%')
|
||||
</if>
|
||||
<if test="relIdFk != null and relIdFk != ''">
|
||||
AND ipp.relIdFk = #{relIdFk}
|
||||
</if>
|
||||
<if test="ggxh != null and ggxh != ''">
|
||||
AND bp.ggxh like concat('%', #{ggxh}, '%')
|
||||
</if>
|
||||
<if test="batchNo != null and batchNo != ''">
|
||||
AND ipp.batchNo like concat('%', #{batchNo}, '%')
|
||||
</if>
|
||||
<if test="productionDate != null and productionDate != ''">
|
||||
AND ipp.productionDate = #{productionDate}
|
||||
</if>
|
||||
<if test="expireDate != null and expireDate != ''">
|
||||
AND ipp.expireDate = #{expireDate}
|
||||
</if>
|
||||
<if test="ylqxzcrbarmc != null and ylqxzcrbarmc != ''">
|
||||
AND bp.ylqxzcrbarmc like concat('%', #{ylqxzcrbarmc}, '%')
|
||||
</if>
|
||||
<if test="zczbhhzbapzbh != null and zczbhhzbapzbh != ''">
|
||||
AND bp.zczbhhzbapzbh like concat('%', #{zczbhhzbapzbh}, '%')
|
||||
</if>
|
||||
<if test="customerId != null and customerId != ''">
|
||||
AND ipp.customerId = #{customerId}
|
||||
</if>
|
||||
<if test="supId != null and supId != ''">
|
||||
AND ipp.supId = #{supId}
|
||||
</if>
|
||||
<if test="deptCode != null and deptCode != ''">
|
||||
AND ipp.deptCode = #{deptCode}
|
||||
</if>
|
||||
<if test="invCode != null and invCode != ''">
|
||||
AND ipp.invCode = #{invCode}
|
||||
</if>
|
||||
<if test="invCodes != null and invCodes.size() != 0">
|
||||
AND ipp.invCode in
|
||||
<foreach collection="invCodes" item="item" index="index" open="(" close=")" separator=",">
|
||||
#{item}
|
||||
</foreach>
|
||||
</if>
|
||||
</where>
|
||||
</select>
|
||||
</mapper>
|
||||
@ -0,0 +1,17 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.glxp.api.dao.sync.SyncDataChangeBustypesDao">
|
||||
<resultMap id="BaseResultMap" type="com.glxp.api.entity.sync.SyncDataChangeBustypesEntity">
|
||||
<!--@mbg.generated-->
|
||||
<!--@Table sync_data_change_bustypes-->
|
||||
<id column="id" jdbcType="INTEGER" property="id"/>
|
||||
<result column="action" jdbcType="VARCHAR" property="action"/>
|
||||
<result column="name" jdbcType="VARCHAR" property="name"/>
|
||||
<result column="outChange" jdbcType="TINYINT" property="outChange"/>
|
||||
<result column="orderStatus" jdbcType="TINYINT" property="orderStatus"/>
|
||||
</resultMap>
|
||||
<sql id="Base_Column_List">
|
||||
<!--@mbg.generated-->
|
||||
id, `action`, `name`, outChange, orderStatus
|
||||
</sql>
|
||||
</mapper>
|
||||
Loading…
Reference in New Issue