diff --git a/order-management-common/src/main/java/com/dxhy/order/model/MdmGroupTaxClassCode.java b/order-management-common/src/main/java/com/dxhy/order/model/MdmGroupTaxClassCode.java new file mode 100644 index 00000000..3521c53f --- /dev/null +++ b/order-management-common/src/main/java/com/dxhy/order/model/MdmGroupTaxClassCode.java @@ -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(); + } +} \ No newline at end of file diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/api/InvoiceRestSDEnregy.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/api/InvoiceRestSDEnregy.java index 70f09e4f..5bc8dfe5 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/api/InvoiceRestSDEnregy.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/api/InvoiceRestSDEnregy.java @@ -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 mdmGmfxxtbReqBOS = (List) Optional.of(baseBO) + .map(SDEnergyMdmBaseBO::getESB) + .map(ESBBO::getDATA) + .map(DATABO::getDATAINFOS) + .map(DATAINFOSBO::getDATAINFO) + .map(i -> { + // 转成List + return i.stream().map(j -> { + return JSONObject.parseObject(JSONObject.toJSONString(j), MdmGmfxxtbReqBO.class); + }).collect(Collectors.toList()); + }) + .orElse(new ArrayList()); + + 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 mdmGmfxxtbReqBOS = (List) Optional.of(baseBO) + .map(SDEnergyMdmBaseBO::getESB) + .map(ESBBO::getDATA) + .map(DATABO::getDATAINFOS) + .map(DATAINFOSBO::getDATAINFO) + .map(i -> { + // 转成List + return i.stream().map(j -> { + return JSONObject.parseObject(JSONObject.toJSONString(j), MdmSyncGroupTaxCodeReqBO.class); + }).collect(Collectors.toList()); + }) + .orElse(new ArrayList()); + + 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 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 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; - } } diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/protocol/AjaxResult.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/protocol/AjaxResult.java new file mode 100644 index 00000000..86dbe36a --- /dev/null +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/protocol/AjaxResult.java @@ -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 { + 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); + } +} diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/ISDEnregyService.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/ISDEnregyService.java new file mode 100644 index 00000000..26e8ce06 --- /dev/null +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/ISDEnregyService.java @@ -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 mdmGmfxxtbReqBOS); + + public AjaxResult syncMdmGroupTax(List mdmGmfxxtbReqBOS); + + public SDEnergyMdmBaseBO buildResult(SDEnergyMdmBaseBO baseBO, List respList, Function handleFunction); +} diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceAbstract.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceAbstract.java new file mode 100644 index 00000000..58ec2247 --- /dev/null +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceAbstract.java @@ -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 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; + } +} diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceImpl.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceImpl.java new file mode 100644 index 00000000..549ee97e --- /dev/null +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceImpl.java @@ -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 mdmGmfxxtbReqBOS) { + // TODO 存表 + return null; + } + + /** + * 集团物料同步接口 + * + * @param mdmGmfxxtbReqBOS + * @return + */ + @Override + public AjaxResult syncMdmGroupTax(List mdmGmfxxtbReqBOS) { + // TODO 存表 + List 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; + } + +} diff --git a/order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/dao/MdmGroupTaxClassCodeMapper.java b/order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/dao/MdmGroupTaxClassCodeMapper.java new file mode 100644 index 00000000..aa0f4f6c --- /dev/null +++ b/order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/dao/MdmGroupTaxClassCodeMapper.java @@ -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 record); + + int insertSelective(MdmGroupTaxClassCode record); + + MdmGroupTaxClassCode selectByPrimaryKey(String id); + + int updateByPrimaryKeySelective(MdmGroupTaxClassCode record); + + int updateByPrimaryKey(MdmGroupTaxClassCode record); +} \ No newline at end of file diff --git a/order-management-invoice/src/main/resources/mybatis/mapper/MdmGroupTaxClassCodeDao.xml b/order-management-invoice/src/main/resources/mybatis/mapper/MdmGroupTaxClassCodeDao.xml new file mode 100644 index 00000000..cbf6a384 --- /dev/null +++ b/order-management-invoice/src/main/resources/mybatis/mapper/MdmGroupTaxClassCodeDao.xml @@ -0,0 +1,126 @@ + + + + + + + + + + + + + + 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 + + + + delete from mdm_group_tax_class_code + where id = #{id,jdbcType=VARCHAR} + + + 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 into mdm_group_tax_class_code (id,sort_id, merchandise_name, `encoding`, + metering_unit, create_time, description + ) + values + + #{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} + + 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 into mdm_group_tax_class_code + + + sort_id, + + + merchandise_name, + + + `encoding`, + + + metering_unit, + + + create_time, + + + description, + + + + + #{sortId,jdbcType=BIGINT}, + + + #{merchandiseName,jdbcType=VARCHAR}, + + + #{encoding,jdbcType=VARCHAR}, + + + #{meteringUnit,jdbcType=VARCHAR}, + + + #{createTime,jdbcType=TIMESTAMP}, + + + #{description,jdbcType=VARCHAR}, + + + + + update mdm_group_tax_class_code + + + 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 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} + + \ No newline at end of file diff --git a/pom.xml b/pom.xml index 2b05b5a5..f8b52b4c 100644 --- a/pom.xml +++ b/pom.xml @@ -672,7 +672,6 @@ sdny - dev /data/logs/ debug @@ -682,9 +681,9 @@ http://172.31.32.53:8081/repository/maven-public/ http://172.31.32.53:8081/repository/maven-public/ - http://10.1.20.6:8081/nexus/content/repositories/releases + http://172.31.32.53:8081/nexus/content/repositories/releases - http://10.1.20.6:8081/nexus/content/repositories/snapshots + http://172.31.32.53:8081/nexus/content/repositories/snapshots