新增生产企业字典维护

zyy_db
anthonywj 1 year ago
parent 1ed3360997
commit 805c82e972

@ -1,11 +1,46 @@
package com.glxp.api.controller.basic; package com.glxp.api.controller.basic;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.IdUtil;
import com.github.pagehelper.PageInfo;
import com.glxp.api.annotation.AuthRuleAnnotation;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import com.glxp.api.constant.ConstantStatus;
import com.glxp.api.constant.SyncDelType;
import com.glxp.api.controller.BaseController; import com.glxp.api.controller.BaseController;
import com.glxp.api.entity.basic.BasicCorpEntity;
import com.glxp.api.entity.basic.BasicManufacturerEntity;
import com.glxp.api.entity.thrsys.ThrSystemDetailEntity;
import com.glxp.api.entity.thrsys.ThrSystemEntity;
import com.glxp.api.req.basic.BasicDataRequest;
import com.glxp.api.req.basic.BasicUnitMaintainFilterRequest;
import com.glxp.api.req.basic.CombineSingleUnitRequest;
import com.glxp.api.req.basic.CombineUnitRequest;
import com.glxp.api.req.system.DeleteRequest;
import com.glxp.api.req.thrsys.FilterBasicThirdSysRequest;
import com.glxp.api.req.thrsys.ThrUnitMaintainFilterRequest;
import com.glxp.api.res.PageSimpleResponse;
import com.glxp.api.res.basic.BasicErpUnitsResponse;
import com.glxp.api.res.basic.BasicProductThirdSysResponse;
import com.glxp.api.service.basic.BasicManufacturerService; import com.glxp.api.service.basic.BasicManufacturerService;
import com.glxp.api.service.thrsys.ThrSystemDetailService;
import com.glxp.api.service.thrsys.ThrSystemService;
import com.glxp.api.util.CustomUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
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.RestController;
import javax.annotation.Resource; import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
/** /**
* *
@ -17,4 +52,265 @@ public class BasicManufacturerController extends BaseController {
@Resource @Resource
BasicManufacturerService manufacturerService; BasicManufacturerService manufacturerService;
@GetMapping("/udiwms/basic/manu/maintain/filter")
public BaseResponse filterBasicUnitMaintain(BasicUnitMaintainFilterRequest basicUnitMaintainFilterRequest,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
List<BasicManufacturerEntity> basicUnitMaintainEntities;
basicUnitMaintainEntities = manufacturerService.filterList(basicUnitMaintainFilterRequest);
PageInfo<BasicManufacturerEntity> pageInfo = new PageInfo<>(basicUnitMaintainEntities);
PageSimpleResponse<BasicManufacturerEntity> pageSimpleResponse = new PageSimpleResponse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(basicUnitMaintainEntities);
return ResultVOUtils.success(pageSimpleResponse);
}
@AuthRuleAnnotation("")
@PostMapping("/udiwms/basic/manu/maintain/save")
public BaseResponse save(@RequestBody @Valid BasicManufacturerEntity basicUnitMaintainSaveRequest,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
boolean result = manufacturerService.verifyExists(basicUnitMaintainSaveRequest);
if (result) {
return ResultVOUtils.error(ResultEnum.DATA_REPEAT, "重复添加");
}
BasicManufacturerEntity basicUnitMaintainEntity = new BasicManufacturerEntity();
BeanUtils.copyProperties(basicUnitMaintainSaveRequest, basicUnitMaintainEntity);
basicUnitMaintainEntity.setErpId(CustomUtil.getId());
basicUnitMaintainEntity.setUpdateTime(new Date());
basicUnitMaintainEntity.setId(IdUtil.getSnowflakeNextId());
boolean b = manufacturerService.save(basicUnitMaintainEntity);
if (!b) {
return ResultVOUtils.error(ResultEnum.NOT_NETWORK);
}
return ResultVOUtils.success();
}
@AuthRuleAnnotation("")
@PostMapping("/udiwms/basic/manu/maintain/update")
public BaseResponse update(@RequestBody @Valid BasicManufacturerEntity basicUnitMaintainSaveRequest, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
boolean result = manufacturerService.verifyExists(basicUnitMaintainSaveRequest);
if (result) {
return ResultVOUtils.error(ResultEnum.DATA_REPEAT, "重复添加");
}
basicUnitMaintainSaveRequest.setOutType(ConstantStatus.CORP_SICK_CUS);
basicUnitMaintainSaveRequest.setUpdateTime(new Date());
manufacturerService.updateById(basicUnitMaintainSaveRequest);
return ResultVOUtils.success("修改成功");
}
@AuthRuleAnnotation("")
@PostMapping("/udiwms/basic/manu/maintain/delete")
public BaseResponse deleteBasicUnitMaintain(@RequestBody DeleteRequest deleteRequest) {
String id = deleteRequest.getId();
manufacturerService.removeById(id);
// //调用同步删除的方法
// BasicDataRequest basicDataRequest = new BasicDataRequest();
// basicDataRequest.setDeleteRequest(deleteRequest);
// basicDataRequest.setKey(SyncDelType.BASIC_CORP_MAINTAIN);
// Long userId = getUserId();
// spGetHttpClient.deleteBasicData(basicDataRequest, userId + "");
return ResultVOUtils.success("删除成功");
}
@AuthRuleAnnotation("")
@PostMapping("/udiwms/basic/manu/maintain/combine")
public BaseResponse combine(@RequestBody CombineUnitRequest combineRequest, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
List<BasicErpUnitsResponse> erpUnitsResponses = combineRequest.getCustmandocResponses();
if (erpUnitsResponses != null && erpUnitsResponses.size() > 0) {
for (BasicErpUnitsResponse erpUnitsResponse : erpUnitsResponses) {
BasicManufacturerEntity basicUnitMaintainEntity = new BasicManufacturerEntity();
if (combineRequest.getThirdSys() != null) {
if ("thirdId".equals(combineRequest.getThirdSys())) {
basicUnitMaintainEntity.setThirdId(erpUnitsResponse.getUnitId());
basicUnitMaintainEntity.setThirdName(erpUnitsResponse.getName());
} else if ("thirdId1".equals(combineRequest.getThirdSys())) {
basicUnitMaintainEntity.setThirdId1(erpUnitsResponse.getUnitId());
basicUnitMaintainEntity.setThirdName1(erpUnitsResponse.getName());
} else if ("thirdId2".equals(combineRequest.getThirdSys())) {
basicUnitMaintainEntity.setThirdId2(erpUnitsResponse.getUnitId());
basicUnitMaintainEntity.setThirdName2(erpUnitsResponse.getName());
} else if ("thirdId3".equals(combineRequest.getThirdSys())) {
basicUnitMaintainEntity.setThirdId3(erpUnitsResponse.getUnitId());
basicUnitMaintainEntity.setThirdName3(erpUnitsResponse.getName());
} else if ("thirdId4".equals(combineRequest.getThirdSys())) {
basicUnitMaintainEntity.setThirdId4(erpUnitsResponse.getUnitId());
basicUnitMaintainEntity.setThirdName4(erpUnitsResponse.getName());
}
}
basicUnitMaintainEntity.setErpId(CustomUtil.getId());
basicUnitMaintainEntity.setName(erpUnitsResponse.getName());
basicUnitMaintainEntity.setSpell(erpUnitsResponse.getSpell());
basicUnitMaintainEntity.setAddr(erpUnitsResponse.getAddr());
basicUnitMaintainEntity.setCreditNo(erpUnitsResponse.getCreditNo());
basicUnitMaintainEntity.setContact(erpUnitsResponse.getContact());
basicUnitMaintainEntity.setMobile(erpUnitsResponse.getMobile());
basicUnitMaintainEntity.setCorpType(ConstantStatus.CORP_SP);
basicUnitMaintainEntity.setUpdateTime(new Date());
basicUnitMaintainEntity.setId(IdUtil.getSnowflakeNextId());
manufacturerService.save(basicUnitMaintainEntity);
}
}
return ResultVOUtils.success("选入成功");
}
@Resource
ThrSystemDetailService thrSystemDetailService;
@AuthRuleAnnotation("")
@GetMapping("/udiwms/basic/manu/maintain/combineAll")
public BaseResponse combineAll(ThrUnitMaintainFilterRequest unitMaintainFilterRequest, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
ThrSystemDetailEntity basicThirdSysDetailEntity = thrSystemDetailService.selectByKey("manuUrl", unitMaintainFilterRequest.getThirdSys());
if (basicThirdSysDetailEntity == null || basicThirdSysDetailEntity.getValue() == null)
return ResultVOUtils.error(500, "往来单位接口地址未定义");
if (basicThirdSysDetailEntity.getEnabled()) {
manufacturerService.selectAllUnit(basicThirdSysDetailEntity, unitMaintainFilterRequest);
} else {
return ResultVOUtils.error(500, "第三方系统往来单位接口服务未启用");
}
return ResultVOUtils.success("后台正在添加,请稍后刷新查看!");
}
@AuthRuleAnnotation("")
@PostMapping("/udiwms/basic/manu/maintain/combineSingle")
public BaseResponse combineSingle(@RequestBody CombineSingleUnitRequest combineRequest, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
BasicErpUnitsResponse basicErpUnitsResponse = combineRequest.getBasicErpUnitsResponse();
BasicManufacturerEntity basicCorpEntity = new BasicManufacturerEntity();
basicCorpEntity.setId(Long.parseLong(combineRequest.getKey()));
if (combineRequest.getThirdSys() != null) {
if ("thirdId".equals(combineRequest.getThirdSys())) {
basicCorpEntity.setThirdId(basicErpUnitsResponse.getId());
basicCorpEntity.setThirdName(basicErpUnitsResponse.getName());
} else if ("thirdId1".equals(combineRequest.getThirdSys())) {
basicCorpEntity.setThirdId1(basicErpUnitsResponse.getId());
basicCorpEntity.setThirdName1(basicErpUnitsResponse.getName());
} else if ("thirdId2".equals(combineRequest.getThirdSys())) {
basicCorpEntity.setThirdId2(basicErpUnitsResponse.getId());
basicCorpEntity.setThirdName2(basicErpUnitsResponse.getName());
} else if ("thirdId3".equals(combineRequest.getThirdSys())) {
basicCorpEntity.setThirdId3(basicErpUnitsResponse.getId());
basicCorpEntity.setThirdName3(basicErpUnitsResponse.getName());
} else if ("thirdId4".equals(combineRequest.getThirdSys())) {
basicCorpEntity.setThirdId4(basicErpUnitsResponse.getId());
basicCorpEntity.setThirdName4(basicErpUnitsResponse.getName());
}
}
manufacturerService.updateById(basicCorpEntity);
return ResultVOUtils.success("关联成功");
}
@Resource
private ThrSystemService thrSystemService;
//获取产品信息详情(多平台)
@AuthRuleAnnotation("")
@GetMapping("/udiwms/manutMaintain/thirdSys/detail")
public BaseResponse getThirdSysDetail(BasicUnitMaintainFilterRequest basicUnitMaintainFilterRequest,
BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
BasicManufacturerEntity basicUnitMaintainEntity = manufacturerService.getById(basicUnitMaintainFilterRequest.getId() + "");
FilterBasicThirdSysRequest filterBasicThirdSysRequest = new FilterBasicThirdSysRequest();
filterBasicThirdSysRequest.setEnabled(true);
List<ThrSystemEntity> basicThirdSysEntities = thrSystemService.filterBasicThiSys(filterBasicThirdSysRequest);
List<BasicProductThirdSysResponse> basicProductThirdSysResponses = new ArrayList<>();
for (ThrSystemEntity basicThirdSysEntity : basicThirdSysEntities) {
if (basicThirdSysEntity.getThirdId().equals("thirdId")) {
BasicProductThirdSysResponse basicProductThirdSysResponse = new BasicProductThirdSysResponse();
basicProductThirdSysResponse.setSysId(basicThirdSysEntity.getThirdId());
basicProductThirdSysResponse.setSysName(basicThirdSysEntity.getThirdName());
if (basicUnitMaintainEntity != null) {
basicProductThirdSysResponse.setThirdId(basicUnitMaintainEntity.getThirdId());
basicProductThirdSysResponse.setThirdName(basicUnitMaintainEntity.getThirdName());
}
basicProductThirdSysResponses.add(basicProductThirdSysResponse);
} else if (basicThirdSysEntity.getThirdId().equals("thirdId1")) {
BasicProductThirdSysResponse basicProductThirdSysResponse = new BasicProductThirdSysResponse();
basicProductThirdSysResponse.setSysId(basicThirdSysEntity.getThirdId());
basicProductThirdSysResponse.setSysName(basicThirdSysEntity.getThirdName());
if (basicUnitMaintainEntity != null) {
basicProductThirdSysResponse.setThirdId(basicUnitMaintainEntity.getThirdId1());
basicProductThirdSysResponse.setThirdName(basicUnitMaintainEntity.getThirdName1());
}
basicProductThirdSysResponses.add(basicProductThirdSysResponse);
} else if (basicThirdSysEntity.getThirdId().equals("thirdId2")) {
BasicProductThirdSysResponse basicProductThirdSysResponse = new BasicProductThirdSysResponse();
basicProductThirdSysResponse.setSysId(basicThirdSysEntity.getThirdId());
basicProductThirdSysResponse.setSysName(basicThirdSysEntity.getThirdName());
if (basicUnitMaintainEntity != null) {
basicProductThirdSysResponse.setThirdId(basicUnitMaintainEntity.getThirdId2());
basicProductThirdSysResponse.setThirdName(basicUnitMaintainEntity.getThirdName2());
}
basicProductThirdSysResponses.add(basicProductThirdSysResponse);
} else if (basicThirdSysEntity.getThirdId().equals("thirdId3")) {
BasicProductThirdSysResponse basicProductThirdSysResponse = new BasicProductThirdSysResponse();
basicProductThirdSysResponse.setSysId(basicThirdSysEntity.getThirdId());
basicProductThirdSysResponse.setSysName(basicThirdSysEntity.getThirdName());
if (basicUnitMaintainEntity != null) {
basicProductThirdSysResponse.setThirdId(basicUnitMaintainEntity.getThirdId3());
basicProductThirdSysResponse.setThirdName(basicUnitMaintainEntity.getThirdName3());
}
basicProductThirdSysResponses.add(basicProductThirdSysResponse);
} else if (basicThirdSysEntity.getThirdId().equals("thirdId4")) {
BasicProductThirdSysResponse basicProductThirdSysResponse = new BasicProductThirdSysResponse();
basicProductThirdSysResponse.setSysId(basicThirdSysEntity.getThirdId());
basicProductThirdSysResponse.setSysName(basicThirdSysEntity.getThirdName());
if (basicUnitMaintainEntity != null) {
basicProductThirdSysResponse.setThirdId(basicUnitMaintainEntity.getThirdId4());
basicProductThirdSysResponse.setThirdName(basicUnitMaintainEntity.getThirdName4());
}
basicProductThirdSysResponses.add(basicProductThirdSysResponse);
}
}
PageInfo<BasicProductThirdSysResponse> pageInfo;
pageInfo = new PageInfo<>(basicProductThirdSysResponses);
PageSimpleResponse<BasicProductThirdSysResponse> pageSimpleResponse = new PageSimpleResponse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(basicProductThirdSysResponses);
return ResultVOUtils.success(pageSimpleResponse);
}
} }

@ -1,9 +1,30 @@
package com.glxp.api.dao.basic; package com.glxp.api.dao.basic;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.glxp.api.dao.BaseMapperPlus;
import com.glxp.api.entity.basic.BasicCorpEntity;
import com.glxp.api.entity.basic.BasicManufacturerEntity; import com.glxp.api.entity.basic.BasicManufacturerEntity;
import com.glxp.api.req.basic.BasicUnitMaintainFilterRequest;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@Mapper @Mapper
public interface BasicManufacturerMapper extends BaseMapper<BasicManufacturerEntity> { public interface BasicManufacturerMapper extends BaseMapperPlus<BasicManufacturerMapper, BasicManufacturerEntity, BasicManufacturerEntity> {
List<BasicManufacturerEntity> filterList(BasicUnitMaintainFilterRequest basicUnitMaintainFilterRequest);
List<BasicManufacturerEntity> batchSelectByErpIdsAndName(@Param("erpIds") List<String> erpIds, @Param("name") String name);
/**
*
*
* @param name
* @param creditNo
* @return
*/
List<BasicManufacturerEntity> selectByNameAndCreditNo(@Param("name") String name, @Param("creditNo") String creditNo);
} }

@ -4,8 +4,10 @@ import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable; import java.io.Serializable;
import java.util.Date; import java.util.Date;
import lombok.Data; import lombok.Data;
@Data @Data
@ -15,19 +17,19 @@ public class BasicManufacturerEntity implements Serializable {
private Long id; private Long id;
/** /**
* *
*/ */
@TableField(value = "code") @TableField(value = "erpId")
private String code; private String erpId;
/** /**
* *
*/ */
@TableField(value = "`name`") @TableField(value = "`name`")
private String name; private String name;
/** /**
* *
*/ */
@TableField(value = "spell") @TableField(value = "spell")
private String spell; private String spell;
@ -42,10 +44,10 @@ public class BasicManufacturerEntity implements Serializable {
* *
*/ */
@TableField(value = "`status`") @TableField(value = "`status`")
private String status; private Integer status;
/** /**
* *
*/ */
@TableField(value = "`type`") @TableField(value = "`type`")
private String type; private String type;
@ -57,22 +59,13 @@ public class BasicManufacturerEntity implements Serializable {
private String contact; private String contact;
/** /**
* *
*/ */
@TableField(value = "mobile") @TableField(value = "mobile")
private String mobile; private String mobile;
/** @TableField(value = "creditNo")
* private String creditNo;
*/
@TableField(value = "creditCode")
private String creditCode;
/**
*
*/
@TableField(value = "remark")
private String remark;
/** /**
* ID * ID
@ -80,30 +73,45 @@ public class BasicManufacturerEntity implements Serializable {
@TableField(value = "thirdId") @TableField(value = "thirdId")
private String thirdId; private String thirdId;
/**
* ID
*/
@TableField(value = "thirdId1") @TableField(value = "thirdId1")
private String thirdId1; private String thirdId1;
/**
* ID
*/
@TableField(value = "thirdId2") @TableField(value = "thirdId2")
private String thirdId2; private String thirdId2;
/**
* ID
*/
@TableField(value = "thirdId3") @TableField(value = "thirdId3")
private String thirdId3; private String thirdId3;
/**
* ID
*/
@TableField(value = "thirdId4") @TableField(value = "thirdId4")
private String thirdId4; private String thirdId4;
@TableField(value = "thirdName")
private String thirdName;
@TableField(value = "thirdName1")
private String thirdName1;
@TableField(value = "thirdName2")
private String thirdName2;
@TableField(value = "thirdName3")
private String thirdName3;
@TableField(value = "thirdName4")
private String thirdName4;
/**
* 1.23,4.
*/
@TableField(value = "corpType")
private Integer corpType;
/**
* 1.2.
*/
@TableField(value = "outType")
private Integer outType;
/** /**
* *
*/ */
@ -128,5 +136,12 @@ public class BasicManufacturerEntity implements Serializable {
@TableField(value = "updateTime") @TableField(value = "updateTime")
private Date updateTime; private Date updateTime;
/**
*
*/
@TableField(value = "remark")
private String remark;
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
} }

@ -1,10 +1,118 @@
package com.glxp.api.service.basic; package com.glxp.api.service.basic;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.extra.pinyin.PinyinUtil;
import com.github.pagehelper.PageHelper;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.constant.ConstantStatus;
import com.glxp.api.entity.basic.BasicCorpEntity;
import com.glxp.api.entity.thrsys.ThrManufacturerEntity;
import com.glxp.api.entity.thrsys.ThrSystemDetailEntity;
import com.glxp.api.req.basic.BasicUnitMaintainFilterRequest;
import com.glxp.api.req.thrsys.FilterThrCorpRequest;
import com.glxp.api.req.thrsys.ThrUnitMaintainFilterRequest;
import com.glxp.api.res.PageSimpleResponse;
import com.glxp.api.res.thrsys.ThrCorpsResponse;
import com.glxp.api.service.thrsys.ThrManufacturerService;
import com.glxp.api.util.CustomUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.glxp.api.entity.basic.BasicManufacturerEntity; import com.glxp.api.entity.basic.BasicManufacturerEntity;
import com.glxp.api.dao.basic.BasicManufacturerMapper; import com.glxp.api.dao.basic.BasicManufacturerMapper;
import javax.annotation.Resource;
import java.util.*;
@Service @Service
public class BasicManufacturerService extends ServiceImpl<BasicManufacturerMapper, BasicManufacturerEntity> { public class BasicManufacturerService extends ServiceImpl<BasicManufacturerMapper, BasicManufacturerEntity> {
@Resource
BasicManufacturerMapper basicManufacturerMapper;
public List<BasicManufacturerEntity> filterList(BasicUnitMaintainFilterRequest basicUnitMaintainFilterRequest) {
if (basicUnitMaintainFilterRequest == null) {
return Collections.emptyList();
}
if (basicUnitMaintainFilterRequest.getPage() != null) {
int offset = (basicUnitMaintainFilterRequest.getPage() - 1) * basicUnitMaintainFilterRequest.getLimit();
PageHelper.offsetPage(offset, basicUnitMaintainFilterRequest.getLimit());
}
List<BasicManufacturerEntity> data = basicManufacturerMapper.filterList(basicUnitMaintainFilterRequest);
return data;
}
public boolean verifyExists(BasicManufacturerEntity basicCorpEntity) {
List<BasicManufacturerEntity> list = basicManufacturerMapper.selectByNameAndCreditNo(basicCorpEntity.getName(), basicCorpEntity.getCreditNo());
if (CollUtil.isNotEmpty(list)) {
if (null != basicCorpEntity.getId()) {
for (BasicManufacturerEntity corpEntity : list) {
if (!corpEntity.getId().equals(basicCorpEntity.getId())) {
return true;
}
}
} else {
return true;
}
}
return false;
}
@Resource
ThrManufacturerService thrManufacturerService;
@Async
public void selectAllUnit(ThrSystemDetailEntity thrSystemDetailEntity, ThrUnitMaintainFilterRequest unitMaintainFilterRequest) {
List<ThrManufacturerEntity> imports = new ArrayList<>();
FilterThrCorpRequest filterThrCorpRequest = new FilterThrCorpRequest();
BeanUtils.copyProperties(unitMaintainFilterRequest, filterThrCorpRequest);
filterThrCorpRequest.setThirdSysFk(unitMaintainFilterRequest.getThirdSys());
filterThrCorpRequest.setPage(null);
List<ThrManufacturerEntity> thrCorpEntities = thrManufacturerService.filterThrManu(filterThrCorpRequest);
imports.addAll(thrCorpEntities);
if (imports != null && imports.size() > 0) {
for (ThrManufacturerEntity erpUnitsResponse : imports) {
BasicManufacturerEntity thrUnitMaintainResponse = new BasicManufacturerEntity();
if (unitMaintainFilterRequest.getThirdSys() != null) {
if ("thirdId".equals(unitMaintainFilterRequest.getThirdSys())) {
thrUnitMaintainResponse.setThirdId(erpUnitsResponse.getUnitId());
thrUnitMaintainResponse.setThirdName(erpUnitsResponse.getName());
} else if ("thirdId1".equals(unitMaintainFilterRequest.getThirdSys())) {
thrUnitMaintainResponse.setThirdId1(erpUnitsResponse.getUnitId());
thrUnitMaintainResponse.setThirdName1(erpUnitsResponse.getName());
} else if ("thirdId2".equals(unitMaintainFilterRequest.getThirdSys())) {
thrUnitMaintainResponse.setThirdId2(erpUnitsResponse.getUnitId());
thrUnitMaintainResponse.setThirdName2(erpUnitsResponse.getName());
} else if ("thirdId3".equals(unitMaintainFilterRequest.getThirdSys())) {
thrUnitMaintainResponse.setThirdId3(erpUnitsResponse.getUnitId());
thrUnitMaintainResponse.setThirdName3(erpUnitsResponse.getName());
} else if ("thirdId4".equals(unitMaintainFilterRequest.getThirdSys())) {
thrUnitMaintainResponse.setThirdId4(erpUnitsResponse.getUnitId());
thrUnitMaintainResponse.setThirdName4(erpUnitsResponse.getName());
}
}
thrUnitMaintainResponse.setErpId(CustomUtil.getId());
thrUnitMaintainResponse.setName(erpUnitsResponse.getName());
if (erpUnitsResponse.getSpell() == null || "".equals(erpUnitsResponse.getSpell())) {
thrUnitMaintainResponse.setSpell(PinyinUtil.getFirstLetter(erpUnitsResponse.getName(), "").toUpperCase(Locale.ROOT));
} else {
thrUnitMaintainResponse.setSpell(erpUnitsResponse.getSpell());
}
thrUnitMaintainResponse.setAddr(erpUnitsResponse.getAddr());
thrUnitMaintainResponse.setCreditNo(erpUnitsResponse.getCreditNo());
thrUnitMaintainResponse.setCorpType(ConstantStatus.CORP_SP);
thrUnitMaintainResponse.setContact(erpUnitsResponse.getContact());
thrUnitMaintainResponse.setMobile(erpUnitsResponse.getMobile());
thrUnitMaintainResponse.setUpdateTime(new Date());
thrUnitMaintainResponse.setId(IdUtil.getSnowflakeNextId());
basicManufacturerMapper.insertIgnore(thrUnitMaintainResponse);
}
}
}
} }

@ -1,34 +1,67 @@
<?xml version="1.0" encoding="UTF-8"?> <?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"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.glxp.api.dao.basic.BasicManufacturerMapper"> <mapper namespace="com.glxp.api.dao.basic.BasicManufacturerMapper">
<resultMap id="BaseResultMap" type="com.glxp.api.entity.basic.BasicManufacturerEntity"> <select id="filterList" parameterType="com.glxp.api.req.basic.BasicUnitMaintainFilterRequest"
<!--@mbg.generated--> resultType="com.glxp.api.entity.basic.BasicManufacturerEntity">
<!--@Table basic_manufacturer--> SELECT *
<id column="id" jdbcType="BIGINT" property="id" /> FROM basic_manufacturer
<result column="code" jdbcType="VARCHAR" property="code" /> <where>
<result column="name" jdbcType="VARCHAR" property="name" /> <if test="key != '' and key != null">
<result column="spell" jdbcType="VARCHAR" property="spell" /> and
<result column="addr" jdbcType="VARCHAR" property="addr" /> (name like concat('%', #{key}, '%')
<result column="status" jdbcType="VARCHAR" property="status" /> or spell like concat('%', #{key}, '%')
<result column="type" jdbcType="VARCHAR" property="type" /> or erpId like concat('%', #{key}, '%')
<result column="contact" jdbcType="VARCHAR" property="contact" /> or creditNo like concat('%', #{key}, '%')
<result column="mobile" jdbcType="VARCHAR" property="mobile" /> or thirdId like concat('%', #{key}, '%')
<result column="creditCode" jdbcType="VARCHAR" property="creditCode" /> or thirdId1 like concat('%', #{key}, '%')
<result column="remark" jdbcType="VARCHAR" property="remark" /> or thirdId2 like concat('%', #{key}, '%')
<result column="thirdId" jdbcType="VARCHAR" property="thirdId" /> or thirdId3 like concat('%', #{key}, '%')
<result column="thirdId1" jdbcType="VARCHAR" property="thirdId1" /> or thirdId4 like concat('%', #{key}, '%')
<result column="thirdId2" jdbcType="VARCHAR" property="thirdId2" /> or addr like concat('%', #{key}, '%')
<result column="thirdId3" jdbcType="VARCHAR" property="thirdId3" /> )
<result column="thirdId4" jdbcType="VARCHAR" property="thirdId4" /> </if>
<result column="createUser" jdbcType="VARCHAR" property="createUser" /> <if test="id != '' and id != null">
<result column="createTime" jdbcType="TIMESTAMP" property="createTime" /> AND id = #{id}
<result column="updateUser" jdbcType="VARCHAR" property="updateUser" /> </if>
<result column="updateTime" jdbcType="TIMESTAMP" property="updateTime" /> <if test="erpId != '' and erpId != null">
</resultMap> AND erpId = #{erpId}
<sql id="Base_Column_List"> </if>
<!--@mbg.generated--> <if test="lastUpdateTime != null and lastUpdateTime != ''">
id, code, `name`, spell, addr, `status`, `type`, contact, mobile, creditCode, remark, <![CDATA[
thirdId, thirdId1, thirdId2, thirdId3, thirdId4, `createUser`, createTime, updateUser, and DATE_FORMAT(updateTime, '%Y-%m-%d %H:%i:%S') >= DATE_FORMAT(#{lastUpdateTime}, '%Y-%m-%d %H:%i:%S')
updateTime ]]>
</sql> </if>
</where>
order by updateTime desc
</select>
<select id="batchSelectByErpIdsAndName" resultType="com.glxp.api.entity.basic.BasicManufacturerEntity">
select *
from basic_manufacturer
<where>
<if test="name != null and name != ''">
AND name like concat('%', #{name}, '%')
</if>
<if test="erpIds != null and erpIds.size() != 0">
AND erpId in
<foreach collection="erpIds" item="item" index="index" separator="," open="(" close=")">
#{item}
</foreach>
</if>
</where>
</select>
<select id="selectByNameAndCreditNo" resultType="com.glxp.api.entity.basic.BasicManufacturerEntity">
select *
from basic_manufacturer
<where>
<if test="name != null and name != ''">
AND name = #{name}
</if>
<if test="creditNo != null and creditNo != ''">
AND creditNo = #{creditNo}
</if>
</where>
</select>
</mapper> </mapper>

Loading…
Cancel
Save