feat:插入MDM表

release
gongquanlin 2 years ago
parent a92bcb38a4
commit 5368710666
  1. 102
      order-management-common/src/main/java/com/dxhy/order/model/MdmGroupTaxClassCode.java
  2. 120
      order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/api/InvoiceRestSDEnregy.java
  3. 187
      order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/protocol/AjaxResult.java
  4. 33
      order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/ISDEnregyService.java
  5. 45
      order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceAbstract.java
  6. 62
      order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceImpl.java
  7. 21
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/dao/MdmGroupTaxClassCodeMapper.java
  8. 126
      order-management-invoice/src/main/resources/mybatis/mapper/MdmGroupTaxClassCodeDao.xml
  9. 5
      pom.xml

@ -0,0 +1,102 @@
package com.dxhy.order.model;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* mdm_group_tax_class_code
* @author
*/
@Data
public class MdmGroupTaxClassCode implements Serializable {
/**
* 主键
*/
private String id;
/**
* 序号
*/
private Long sortId;
/**
* 商品名称 MDM中物料的名称 DESC1
*/
private String merchandiseName;
/**
* 编码 MDM中主编码的值CODE
*/
private String encoding;
/**
* 计量单位 MDM中计量单位的值 DESC5
*/
private String meteringUnit;
/**
* 数据创建时间
*/
private Date createTime;
/**
* 描述 MDM中描述的值 DESCSHORT
*/
private String description;
private static final long serialVersionUID = 1L;
@Override
public boolean equals(Object that) {
if (this == that) {
return true;
}
if (that == null) {
return false;
}
if (getClass() != that.getClass()) {
return false;
}
MdmGroupTaxClassCode other = (MdmGroupTaxClassCode) that;
return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
&& (this.getSortId() == null ? other.getSortId() == null : this.getSortId().equals(other.getSortId()))
&& (this.getMerchandiseName() == null ? other.getMerchandiseName() == null : this.getMerchandiseName().equals(other.getMerchandiseName()))
&& (this.getEncoding() == null ? other.getEncoding() == null : this.getEncoding().equals(other.getEncoding()))
&& (this.getMeteringUnit() == null ? other.getMeteringUnit() == null : this.getMeteringUnit().equals(other.getMeteringUnit()))
&& (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
&& (this.getDescription() == null ? other.getDescription() == null : this.getDescription().equals(other.getDescription()));
}
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
result = prime * result + ((getSortId() == null) ? 0 : getSortId().hashCode());
result = prime * result + ((getMerchandiseName() == null) ? 0 : getMerchandiseName().hashCode());
result = prime * result + ((getEncoding() == null) ? 0 : getEncoding().hashCode());
result = prime * result + ((getMeteringUnit() == null) ? 0 : getMeteringUnit().hashCode());
result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
result = prime * result + ((getDescription() == null) ? 0 : getDescription().hashCode());
return result;
}
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
sb.append(", id=").append(id);
sb.append(", sortId=").append(sortId);
sb.append(", merchandiseName=").append(merchandiseName);
sb.append(", encoding=").append(encoding);
sb.append(", meteringUnit=").append(meteringUnit);
sb.append(", createTime=").append(createTime);
sb.append(", description=").append(description);
sb.append(", serialVersionUID=").append(serialVersionUID);
sb.append("]");
return sb.toString();
}
}

@ -5,16 +5,19 @@ import com.dxhy.order.baseservice.module.buyer.protocol.BuyerResponseV4BO;
import com.dxhy.order.baseservice.module.buyer.protocol.GmfxxtbReqBO;
import com.dxhy.order.baseservice.module.buyer.protocol.GmfxxtbRspBO;
import com.dxhy.order.constant.OrderInfoContentEnum;
import com.dxhy.order.consumer.openapi.protocol.AjaxResult;
import com.dxhy.order.consumer.openapi.protocol.v4.ResponseV4BO;
import com.dxhy.order.consumer.openapi.protocol.v4.grouptax.GroupTaxReqBO;
import com.dxhy.order.consumer.openapi.protocol.v4.grouptax.GroupTaxRespBO;
import com.dxhy.order.consumer.openapi.protocol.v6.sdenergy.*;
import com.dxhy.order.consumer.openapi.service.ISDEnregyService;
import com.dxhy.order.consumer.openapi.service.InterfaceServiceV3;
import com.dxhy.order.exception.OrderReceiveException;
import com.dxhy.order.utils.JsonUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.ss.formula.functions.T;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
@ -42,12 +45,87 @@ public class InvoiceRestSDEnregy {
@Resource
private InterfaceServiceV3 interfaceServiceV3;
@Autowired
private ISDEnregyService isdEnregyService;
/**
* 客商同步接口
*
* @param requestBody
* @return
*/
@PostMapping("/sync_buyer_message")
public String syncBuyerMessage(@RequestBody String requestBody) {
String logUUID = UUID.randomUUID().toString();
log.info("{}[syncBuyerMessage],uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
// 接收请求报文,然后进行入库
SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(requestBody, SDEnergyMdmBaseBO.class);
List<MdmGmfxxtbReqBO> mdmGmfxxtbReqBOS = (List<MdmGmfxxtbReqBO>) Optional.of(baseBO)
.map(SDEnergyMdmBaseBO::getESB)
.map(ESBBO::getDATA)
.map(DATABO::getDATAINFOS)
.map(DATAINFOSBO::getDATAINFO)
.map(i -> {
// 转成List<MdmSyncGroupTaxCodeReqBO>
return i.stream().map(j -> {
return JSONObject.parseObject(JSONObject.toJSONString(j), MdmGmfxxtbReqBO.class);
}).collect(Collectors.toList());
})
.orElse(new ArrayList<MdmGmfxxtbReqBO>());
AjaxResult syncMdmGroupTax = isdEnregyService.syncBuyerMessage(mdmGmfxxtbReqBOS);
if (syncMdmGroupTax.isError()) {
log.info("{}[syncBuyerMessage],uuid:{},请求处理失败,原因:{}", LOGGER_MSG, logUUID, syncMdmGroupTax.getMsg());
return syncMdmGroupTax.getMsg();
}
return (String) syncMdmGroupTax.get("data");
}
/**
* 集团物料同步接口
*
* @param requestBody
* @return
*/
@PostMapping("/sync_group_tax")
public String syncMdmGroupTax(@RequestBody String requestBody) {
String logUUID = UUID.randomUUID().toString();
log.info("{}[syncMdmGroupTax],uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
// 接收请求报文,然后进行入库
SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(requestBody, SDEnergyMdmBaseBO.class);
List<MdmSyncGroupTaxCodeReqBO> mdmGmfxxtbReqBOS = (List<MdmSyncGroupTaxCodeReqBO>) Optional.of(baseBO)
.map(SDEnergyMdmBaseBO::getESB)
.map(ESBBO::getDATA)
.map(DATABO::getDATAINFOS)
.map(DATAINFOSBO::getDATAINFO)
.map(i -> {
// 转成List<MdmSyncGroupTaxCodeReqBO>
return i.stream().map(j -> {
return JSONObject.parseObject(JSONObject.toJSONString(j), MdmSyncGroupTaxCodeReqBO.class);
}).collect(Collectors.toList());
})
.orElse(new ArrayList<MdmSyncGroupTaxCodeReqBO>());
AjaxResult syncMdmGroupTax = isdEnregyService.syncMdmGroupTax(mdmGmfxxtbReqBOS);
if (syncMdmGroupTax.isError()) {
log.info("{}[syncMdmGroupTax],uuid:{},请求处理失败,原因:{}", LOGGER_MSG, logUUID, syncMdmGroupTax.getMsg());
return syncMdmGroupTax.getMsg();
}
return (String) syncMdmGroupTax.get("data");
}
/**
* 将客商信息同步入库
*
* @param requestBody MDM报文TODO 后面页面做引用的时候需要改造成POJO
* @return
*/
private String syncMdmBuyerMessage2BuyerMessage(String requestBody) {
String logUUID = UUID.randomUUID().toString();
log.info("{}[syncBuyerMessage],uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(requestBody, SDEnergyMdmBaseBO.class);
@ -123,7 +201,7 @@ public class InvoiceRestSDEnregy {
}
List<GmfxxtbRspBO> gmfxxtbRspList = interfaceServiceV3.syncBuyerMessage(gmfxxtbReqList, "");
// 构造返回请求
SDEnergyMdmBaseBO result = buildResult(
SDEnergyMdmBaseBO result = isdEnregyService.buildResult(
baseBO,
gmfxxtbRspList,
i -> {
@ -142,8 +220,14 @@ public class InvoiceRestSDEnregy {
return resp;
}
@PostMapping("/sync_group_tax")
public String syncGroupTax(@RequestBody String requestBody) {
/**
* 同步MDM集团税收分类编码到系统税收分类编码
*
* @param requestBody TODO 这里后面要改成POJO
* @return
*/
public String syncMdmGroupTax2GroupTax(String requestBody) {
String logUUID = UUID.randomUUID().toString();
log.info("{}[syncGroupTax],uuid:{},收到请求报文:{}", LOGGER_MSG, logUUID, requestBody);
SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(requestBody, SDEnergyMdmBaseBO.class);
@ -183,7 +267,7 @@ public class InvoiceRestSDEnregy {
}
// 构造返回请求
SDEnergyMdmBaseBO result = buildResult(
SDEnergyMdmBaseBO result = isdEnregyService.buildResult(
baseBO,
respBO,
i -> {
@ -203,32 +287,4 @@ public class InvoiceRestSDEnregy {
}
/**
* 统一构造 山能MDM 返回
*
* @param baseBO
* @param respList
* @param handleFunction
* @return
*/
private SDEnergyMdmBaseBO buildResult(SDEnergyMdmBaseBO baseBO, List respList, Function<Object, SDEnergyMdmBaseRespBO> handleFunction) {
DATAINFOSBO requestDATAINFOSBO = (DATAINFOSBO) Optional.of(baseBO)
.map(SDEnergyMdmBaseBO::getESB)
.map(ESBBO::getDATA)
.map(DATABO::getDATAINFOS)
.orElse(DATAINFOSBO.build());
SDEnergyMdmBaseBO respBaseBO = SDEnergyMdmBaseBO.build();
respBaseBO.getESB().setRESULT("S");
respBaseBO.getESB().setDESC("处理完成");
respBaseBO.getESB().getDATA().getDATAINFOS().setPUUID(requestDATAINFOSBO.getPUUID());
List respDataInfo = respBaseBO.getESB().getDATA().getDATAINFOS().getDATAINFO();
// 开始循环处理结果
for (int i = 0; i < respList.size(); i++) {
Object currentBO = respList.get(i);
SDEnergyMdmBaseRespBO baseRespBO = handleFunction.apply(currentBO);
respDataInfo.add(baseRespBO);
}
return respBaseBO;
}
}

@ -0,0 +1,187 @@
package com.dxhy.order.consumer.openapi.protocol;
import cn.hutool.http.HttpStatus;
import java.util.HashMap;
/**
* 操作消息提醒
*
* @author ruoyi
*/
public class AjaxResult extends HashMap<String, Object> {
private static final long serialVersionUID = 1L;
/**
* 状态码
*/
public static final String CODE_TAG = "code";
/**
* 返回内容
*/
public static final String MSG_TAG = "msg";
/**
* 数据对象
*/
public static final String DATA_TAG = "data";
/**
* 初始化一个新创建的 AjaxResult 对象使其表示一个空消息
*/
public AjaxResult() {
}
/**
* 初始化一个新创建的 AjaxResult 对象
*
* @param code 状态码
* @param msg 返回内容
*/
public AjaxResult(int code, String msg) {
super.put(CODE_TAG, code);
super.put(MSG_TAG, msg);
}
/**
* 初始化一个新创建的 AjaxResult 对象
*
* @param code 状态码
* @param msg 返回内容
* @param data 数据对象
*/
public AjaxResult(int code, String msg, Object data) {
super.put(CODE_TAG, code);
super.put(MSG_TAG, msg);
if (data != null) {
super.put(DATA_TAG, data);
}
}
/**
* 返回成功消息
*
* @return 成功消息
*/
public static AjaxResult success() {
return AjaxResult.success("操作成功");
}
/**
* 返回成功数据
*
* @return 成功消息
*/
public static AjaxResult success(Object data) {
return AjaxResult.success("操作成功", data);
}
/**
* 返回成功消息
*
* @param msg 返回内容
* @return 成功消息
*/
public static AjaxResult success(String msg) {
return AjaxResult.success(msg, null);
}
/**
* 返回成功消息
*
* @param msg 返回内容
* @param data 数据对象
* @return 成功消息
*/
public static AjaxResult success(String msg, Object data) {
return new AjaxResult(HttpStatus.HTTP_OK, msg, data);
}
/**
* 返回警告消息
*
* @param msg 返回内容
* @return 警告消息
*/
public static AjaxResult warn(String msg) {
return AjaxResult.warn(msg, null);
}
/**
* 返回警告消息
*
* @param msg 返回内容
* @param data 数据对象
* @return 警告消息
*/
public static AjaxResult warn(String msg, Object data) {
return new AjaxResult(601, msg, data);
}
/**
* 返回错误消息
*
* @return 错误消息
*/
public static AjaxResult error() {
return AjaxResult.error("操作失败");
}
/**
* 返回错误消息
*
* @param msg 返回内容
* @return 错误消息
*/
public static AjaxResult error(String msg) {
return AjaxResult.error(msg, null);
}
/**
* 返回错误消息
*
* @param msg 返回内容
* @param data 数据对象
* @return 错误消息
*/
public static AjaxResult error(String msg, Object data) {
return new AjaxResult(HttpStatus.HTTP_INTERNAL_ERROR, msg, data);
}
/**
* 返回错误消息
*
* @param code 状态码
* @param msg 返回内容
* @return 错误消息
*/
public static AjaxResult error(int code, String msg) {
return new AjaxResult(code, msg, null);
}
/**
* 方便链式调用
*
* @param key
* @param value
* @return 数据对象
*/
@Override
public AjaxResult put(String key, Object value) {
super.put(key, value);
return this;
}
public boolean isSuccess() {
return this.get(CODE_TAG).equals(HttpStatus.HTTP_OK);
}
public boolean isError() {
return !isSuccess();
}
public String getMsg() {
return (String) this.get(MSG_TAG);
}
}

@ -0,0 +1,33 @@
package com.dxhy.order.consumer.openapi.service;
import com.dxhy.order.consumer.openapi.protocol.AjaxResult;
import com.dxhy.order.consumer.openapi.protocol.v4.grouptax.GroupTaxRespBO;
import com.dxhy.order.consumer.openapi.protocol.v6.sdenergy.MdmGmfxxtbReqBO;
import com.dxhy.order.consumer.openapi.protocol.v6.sdenergy.MdmSyncGroupTaxCodeReqBO;
import com.dxhy.order.consumer.openapi.protocol.v6.sdenergy.SDEnergyMdmBaseBO;
import com.dxhy.order.consumer.openapi.protocol.v6.sdenergy.SDEnergyMdmBaseRespBO;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.function.Function;
/**
* @Description
* @Author 巩权林
* @Date 2023/2/23 09:01
**/
public interface ISDEnregyService {
/**
* 同步客商诶口
*
* @param mdmGmfxxtbReqBOS
* @return
*/
public AjaxResult syncBuyerMessage(List<MdmGmfxxtbReqBO> mdmGmfxxtbReqBOS);
public AjaxResult syncMdmGroupTax(List<MdmSyncGroupTaxCodeReqBO> mdmGmfxxtbReqBOS);
public SDEnergyMdmBaseBO buildResult(SDEnergyMdmBaseBO baseBO, List respList, Function<Object, SDEnergyMdmBaseRespBO> handleFunction);
}

@ -0,0 +1,45 @@
package com.dxhy.order.consumer.openapi.service.impl;
import com.dxhy.order.consumer.openapi.protocol.v6.sdenergy.*;
import com.dxhy.order.consumer.openapi.service.ISDEnregyService;
import java.util.List;
import java.util.Optional;
import java.util.function.Function;
/**
* @Description
* @Author 巩权林
* @Date 2023/2/23 15:11
**/
public abstract class SDEnregyServiceAbstract implements ISDEnregyService {
/**
* 统一构造 山能MDM 返回
*
* @param baseBO
* @param respList
* @param handleFunction
* @return
*/
public SDEnergyMdmBaseBO buildResult(SDEnergyMdmBaseBO baseBO, List respList, Function<Object, SDEnergyMdmBaseRespBO> handleFunction) {
DATAINFOSBO requestDATAINFOSBO = (DATAINFOSBO) Optional.of(baseBO)
.map(SDEnergyMdmBaseBO::getESB)
.map(ESBBO::getDATA)
.map(DATABO::getDATAINFOS)
.orElse(DATAINFOSBO.build());
SDEnergyMdmBaseBO respBaseBO = SDEnergyMdmBaseBO.build();
respBaseBO.getESB().setRESULT("S");
respBaseBO.getESB().setDESC("处理完成");
respBaseBO.getESB().getDATA().getDATAINFOS().setPUUID(requestDATAINFOSBO.getPUUID());
List respDataInfo = respBaseBO.getESB().getDATA().getDATAINFOS().getDATAINFO();
// 开始循环处理结果
for (int i = 0; i < respList.size(); i++) {
Object currentBO = respList.get(i);
SDEnergyMdmBaseRespBO baseRespBO = handleFunction.apply(currentBO);
respDataInfo.add(baseRespBO);
}
return respBaseBO;
}
}

@ -0,0 +1,62 @@
package com.dxhy.order.consumer.openapi.service.impl;
import com.dxhy.order.consumer.openapi.protocol.AjaxResult;
import com.dxhy.order.consumer.openapi.protocol.v6.sdenergy.*;
import com.dxhy.order.consumer.openapi.service.ISDEnregyService;
import com.dxhy.order.invoice.module.invoice.dao.MdmGroupTaxClassCodeMapper;
import com.dxhy.order.model.MdmGroupTaxClassCode;
import com.dxhy.order.utils.DistributedKeyMaker;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Optional;
import java.util.function.Function;
/**
* @Description
* @Author 巩权林
* @Date 2023/2/23 14:24
**/
@Service
public class SDEnregyServiceImpl extends SDEnregyServiceAbstract {
@Autowired
private MdmGroupTaxClassCodeMapper mdmGroupTaxClassCodeMapper;
@Override
public AjaxResult syncBuyerMessage(List<MdmGmfxxtbReqBO> mdmGmfxxtbReqBOS) {
// TODO 存表
return null;
}
/**
* 集团物料同步接口
*
* @param mdmGmfxxtbReqBOS
* @return
*/
@Override
public AjaxResult syncMdmGroupTax(List<MdmSyncGroupTaxCodeReqBO> mdmGmfxxtbReqBOS) {
// TODO 存表
List<MdmGroupTaxClassCode> list = new ArrayList<>();
for (int i = 0; i < mdmGmfxxtbReqBOS.size(); i++) {
MdmSyncGroupTaxCodeReqBO reqBO = mdmGmfxxtbReqBOS.get(i);
MdmGroupTaxClassCode entity = new MdmGroupTaxClassCode();
entity.setId(DistributedKeyMaker.generateShotKey());
entity.setSortId((long) i);
entity.setMerchandiseName(reqBO.getDESC1());
entity.setEncoding(reqBO.getCODE());
entity.setMeteringUnit(reqBO.getDESC5());
entity.setCreateTime(new Date());
entity.setDescription(reqBO.getDESCSHORT());
list.add(entity);
}
mdmGroupTaxClassCodeMapper.insert()
return null;
}
}

@ -0,0 +1,21 @@
package com.dxhy.order.invoice.module.invoice.dao;
import com.dxhy.order.model.MdmGroupTaxClassCode;
import java.util.List;
public interface MdmGroupTaxClassCodeMapper {
int deleteByPrimaryKey(String id);
int insert(MdmGroupTaxClassCode record);
int insertOnDuplicateKey(List<MdmGroupTaxClassCode> record);
int insertSelective(MdmGroupTaxClassCode record);
MdmGroupTaxClassCode selectByPrimaryKey(String id);
int updateByPrimaryKeySelective(MdmGroupTaxClassCode record);
int updateByPrimaryKey(MdmGroupTaxClassCode record);
}

@ -0,0 +1,126 @@
<?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.dxhy.order.invoice.module.invoice.dao.MdmGroupTaxClassCodeMapper">
<resultMap id="BaseResultMap" type="com.dxhy.order.model.InvoiceTaxRateRequestInfo.MdmGroupTaxClassCode">
<id column="mdm_group_tax_class_code_id" jdbcType="VARCHAR" property="id" />
<result column="mdm_group_tax_class_code_sort_id" jdbcType="BIGINT" property="sortId" />
<result column="mdm_group_tax_class_code_merchandise_name" jdbcType="VARCHAR" property="merchandiseName" />
<result column="mdm_group_tax_class_code_encoding" jdbcType="VARCHAR" property="encoding" />
<result column="mdm_group_tax_class_code_metering_unit" jdbcType="VARCHAR" property="meteringUnit" />
<result column="mdm_group_tax_class_code_create_time" jdbcType="TIMESTAMP" property="createTime" />
<result column="mdm_group_tax_class_code_description" jdbcType="VARCHAR" property="description" />
</resultMap>
<sql id="Base_Column_List">
mdm_group_tax_class_code.id as mdm_group_tax_class_code_id, mdm_group_tax_class_code.sort_id as mdm_group_tax_class_code_sort_id,
mdm_group_tax_class_code.merchandise_name as mdm_group_tax_class_code_merchandise_name,
mdm_group_tax_class_code.`encoding` as `mdm_group_tax_class_code_encoding`, mdm_group_tax_class_code.metering_unit as mdm_group_tax_class_code_metering_unit,
mdm_group_tax_class_code.create_time as mdm_group_tax_class_code_create_time, mdm_group_tax_class_code.description as mdm_group_tax_class_code_description
</sql>
<select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from mdm_group_tax_class_code mdm_group_tax_class_code
where mdm_group_tax_class_code.id = #{id,jdbcType=VARCHAR}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.String">
delete from mdm_group_tax_class_code
where id = #{id,jdbcType=VARCHAR}
</delete>
<insert id="insert" keyColumn="id" keyProperty="id" parameterType="generator.MdmGroupTaxClassCode" useGeneratedKeys="false">
insert into mdm_group_tax_class_code (sort_id, merchandise_name, `encoding`,
metering_unit, create_time, description
)
values (#{sortId,jdbcType=BIGINT}, #{merchandiseName,jdbcType=VARCHAR}, #{encoding,jdbcType=VARCHAR},
#{meteringUnit,jdbcType=VARCHAR}, #{createTime,jdbcType=TIMESTAMP}, #{description,jdbcType=VARCHAR}
)
</insert>
<insert id="insertOnDuplicateKey" useGeneratedKeys="false">
insert into mdm_group_tax_class_code (id,sort_id, merchandise_name, `encoding`,
metering_unit, create_time, description
)
values
<foreach collection="array" index="index" item="item" separator="," open="(" close=")">
#{item.id,jdbcType=VARCHAR},#{item.sortId,jdbcType=BIGINT}, #{item.merchandiseName,jdbcType=VARCHAR}, #{item.encoding,jdbcType=VARCHAR},
#{item.meteringUnit,jdbcType=VARCHAR}, #{item.createTime,jdbcType=TIMESTAMP}, #{item.description,jdbcType=VARCHAR}
</foreach>
on duplicate key update id = VALUES(id),sort_id = VALUES(sort_id), merchandise_name = VALUES(merchandise_name), `encoding` = VALUES(`encoding`), metering_unit = VALUES(metering_unit), create_time = VALUES(create_time), description = VALUES(description)
</insert>
<insert id="insertSelective" keyColumn="id" keyProperty="id" parameterType="generator.MdmGroupTaxClassCode" useGeneratedKeys="false">
insert into mdm_group_tax_class_code
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="sortId != null">
sort_id,
</if>
<if test="merchandiseName != null">
merchandise_name,
</if>
<if test="encoding != null">
`encoding`,
</if>
<if test="meteringUnit != null">
metering_unit,
</if>
<if test="createTime != null">
create_time,
</if>
<if test="description != null">
description,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="sortId != null">
#{sortId,jdbcType=BIGINT},
</if>
<if test="merchandiseName != null">
#{merchandiseName,jdbcType=VARCHAR},
</if>
<if test="encoding != null">
#{encoding,jdbcType=VARCHAR},
</if>
<if test="meteringUnit != null">
#{meteringUnit,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
#{createTime,jdbcType=TIMESTAMP},
</if>
<if test="description != null">
#{description,jdbcType=VARCHAR},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="generator.MdmGroupTaxClassCode">
update mdm_group_tax_class_code
<set>
<if test="sortId != null">
sort_id = #{sortId,jdbcType=BIGINT},
</if>
<if test="merchandiseName != null">
merchandise_name = #{merchandiseName,jdbcType=VARCHAR},
</if>
<if test="encoding != null">
`encoding` = #{encoding,jdbcType=VARCHAR},
</if>
<if test="meteringUnit != null">
metering_unit = #{meteringUnit,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
create_time = #{createTime,jdbcType=TIMESTAMP},
</if>
<if test="description != null">
description = #{description,jdbcType=VARCHAR},
</if>
</set>
where id = #{id,jdbcType=VARCHAR}
</update>
<update id="updateByPrimaryKey" parameterType="generator.MdmGroupTaxClassCode">
update mdm_group_tax_class_code
set sort_id = #{sortId,jdbcType=BIGINT},
merchandise_name = #{merchandiseName,jdbcType=VARCHAR},
`encoding` = #{encoding,jdbcType=VARCHAR},
metering_unit = #{meteringUnit,jdbcType=VARCHAR},
create_time = #{createTime,jdbcType=TIMESTAMP},
description = #{description,jdbcType=VARCHAR}
where id = #{id,jdbcType=VARCHAR}
</update>
</mapper>

@ -672,7 +672,6 @@
<profile>
<id>sdny</id>
<properties>
<deployType>dev</deployType>
<logging.file>/data/logs/</logging.file>
<logging.level>debug</logging.level>
<logback.mysql.url>
@ -682,9 +681,9 @@
<repository.url>http://172.31.32.53:8081/repository/maven-public/</repository.url>
<pluginRepositories.url>http://172.31.32.53:8081/repository/maven-public/</pluginRepositories.url>
<distribution.repository.release.url>http://10.1.20.6:8081/nexus/content/repositories/releases
<distribution.repository.release.url>http://172.31.32.53:8081/nexus/content/repositories/releases
</distribution.repository.release.url>
<distribution.repository.snapshot.url>http://10.1.20.6:8081/nexus/content/repositories/snapshots
<distribution.repository.snapshot.url>http://172.31.32.53:8081/nexus/content/repositories/snapshots
</distribution.repository.snapshot.url>
</properties>
</profile>

Loading…
Cancel
Save