销售订单 强制同步接口

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/controller/SySOAndOMController.java

@@ -0,0 +1,66 @@
+package org.jeecg.modules.documents.orderData.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.aspect.annotation.AutoLog;
+import org.jeecg.common.system.base.controller.JeecgController;
+import org.jeecg.modules.documents.orderData.entity.SySOAndOM;
+import org.jeecg.modules.documents.orderData.service.ISySOAndOMService;
+import org.jeecg.modules.documents.orderData.service.impl.SySOAndOMServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+
+@Slf4j
+@Api(tags="订单数据同步接口")
+@RestController
+@RequestMapping("/orderData/sySOAndOM")
+public class SySOAndOMController extends JeecgController<SySOAndOM, ISySOAndOMService> {
+    @Autowired
+    private SySOAndOMServiceImpl sySOAndOMService;
+
+    @AutoLog(value = "订单数据同步接口-分页列表查询销售订单")
+    @ApiOperation(value="订单数据同步接口-分页列表查询销售订单", notes="订单数据同步接口-分页列表查询销售订单")
+    @RequestMapping(value = "/querySOList")
+    public Result<?> querySOList(SySOAndOM sySOAndOM,
+                                 @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
+                                 @RequestParam(name="pageSize", defaultValue="10") Integer pageSize) {
+        if(sySOAndOM==null){
+            return Result.error("请检查查询条件！！！");
+        }
+        if(sySOAndOM.getAccount().equals("901") || sySOAndOM.getAccount().equals("902") ||
+                sySOAndOM.getAccount().equals("903")){
+            return Result.error("请选择账套号！！！");
+        }
+        if(sySOAndOM.getOrderNumber()==null && sySOAndOM.getOrderNumber().equals("")){
+            return Result.error("请输入订单号！！！");
+        }
+        Page<SySOAndOM> page = new Page<SySOAndOM>(pageNo, pageSize);
+        IPage<SySOAndOM> pageList = sySOAndOMService.querySOList(sySOAndOM,page);
+        return Result.OK(pageList);
+    }
+
+    @AutoLog(value = "订单数据同步接口-分页列表查询委外订单")
+    @ApiOperation(value="订单数据同步接口-分页列表查询委外订单", notes="订单数据同步接口-分页列表查询委外订单")
+    @RequestMapping(value = "/queryOMList")
+    public Result<?> queryOMList(SySOAndOM sySOAndOM,
+                                 @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
+                                 @RequestParam(name="pageSize", defaultValue="10") Integer pageSize) {
+        if(sySOAndOM==null){
+            return Result.error("请检查查询条件！！！");
+        }
+        if(sySOAndOM.getCCode()==null && sySOAndOM.getCCode().equals("")){
+            return Result.error("请输入订单号！！！");
+        }
+        Page<SySOAndOM> page = new Page<SySOAndOM>(pageNo, pageSize);
+        IPage<SySOAndOM> pageList = sySOAndOMService.queryOMList(sySOAndOM,page);
+        return Result.OK(pageList);
+    }
+
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/entity/SySOAndOM.java

@@ -0,0 +1,53 @@
+package org.jeecg.modules.documents.orderData.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.jeecgframework.poi.excel.annotation.Excel;
+@Data
+@ApiModel(value="订单数据同步对象", description="订单数据同步对象")
+public class SySOAndOM {
+    /*以下 销售*/
+    //账套号
+    @Excel(name = "账套号", width = 15)
+    @ApiModelProperty(value = "账套号")
+    private java.lang.String account;
+    /**订单号*/
+    @Excel(name = "订单号", width = 15)
+    @ApiModelProperty(value = "订单号")
+    private java.lang.String orderNumber;
+    /**订单号*/
+    @Excel(name = "行号", width = 15)
+    @ApiModelProperty(value = "行号")
+    private java.lang.String iRowNo;
+    /**存货编码*/
+    @Excel(name = "存货编码", width = 15)
+    @ApiModelProperty(value = "存货编码")
+    private java.lang.String inventoryCode;
+    /**存货分类编码*/
+    @Excel(name = "存货分类编码", width = 15)
+    @ApiModelProperty(value = "存货分类编码")
+    private java.lang.String inventoryCcode;
+    /**存货名称*/
+    @Excel(name = "存货名称", width = 15)
+    @ApiModelProperty(value = "存货名称")
+    private java.lang.String inventoryName;
+    /**规格型号*/
+    @Excel(name = "规格型号", width = 15)
+    @ApiModelProperty(value = "规格型号")
+    private java.lang.String specificationAndModel;
+    /**颜色*/
+    @Excel(name = "颜色", width = 15)
+    @ApiModelProperty(value = "颜色")
+    private java.lang.String colour;
+
+    /*以下 委外*/
+    /**委外订单号*/
+    @Excel(name = "委外订单号", width = 15)
+    @ApiModelProperty(value = "委外订单号")
+    private java.lang.String cCode;
+    /**委外行号*/
+    @Excel(name = "委外行号", width = 15)
+    @ApiModelProperty(value = "委外行号")
+    private java.lang.String iVouchRowNo;
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/mapper/SySOAndOMMapper.java

@@ -0,0 +1,22 @@
+package org.jeecg.modules.documents.orderData.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.apache.ibatis.annotations.Param;
+import org.jeecg.modules.documents.orderData.entity.SySOAndOM;
+
+/**
+ * @Description: 订单主表
+ * @Author: jeecg-boot
+ * @Date:   2023-01-03
+ * @Version: V1.0
+ */
+public interface SySOAndOMMapper extends BaseMapper<SySOAndOM> {
+    @DS("multi-three")
+    IPage<SySOAndOM> querySOList(@Param("sy") SySOAndOM sy, Page<SySOAndOM> page);
+
+    @DS("multi-three")
+    IPage<SySOAndOM> queryOMList(@Param("sy") SySOAndOM sy, Page<SySOAndOM> page);
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/mapper/xml/SySOAndOMMapper.xml

@@ -0,0 +1,44 @@
+<?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="org.jeecg.modules.documents.orderData.mapper.SySOAndOMMapper">
+
+    <select id="querySOList" resultType="org.jeecg.modules.documents.orderData.entity.SySOAndOM" >
+        <if test="sy.account !='901'">
+            select
+            sm.cSOCode as orderNumber,sd.iRowNo,sd.cInvCode AS inventoryCode,c.cInvCcode AS inventoryCcode,
+            c.cInvName AS inventoryName,sd.cFree1 AS colour,c.cInvStd as specificationAndModel,901 as account
+            from UFDATA_901_2021.dbo.SO_SOMain sm
+            join UFDATA_901_2021.dbo.SO_SODetails sd on sm.id=sd.id
+            join UFDATA_901_2021.dbo.Inventory c on c.cInvCode=sd.cInvCode
+            where sm.csocode=#{sy.orderNumber}
+        </if>
+        <if test="sy.account !='902'">
+            select
+            sm.cSOCode as orderNumber,sd.iRowNo,sd.cInvCode AS inventoryCode,c.cInvCcode AS inventoryCcode,
+            c.cInvName AS inventoryName,sd.cFree1 AS colour,c.cInvStd as specificationAndModel,902 as account
+            from UFDATA_902_2021.dbo.SO_SOMain sm
+            join UFDATA_902_2021.dbo.SO_SODetails sd on sm.id=sd.id
+            join UFDATA_902_2021.dbo.Inventory c on c.cInvCode=sd.cInvCode
+            where sm.csocode=#{sy.orderNumber}
+        </if>
+        <if test="sy.account !='903'">
+            select
+            sm.cSOCode as orderNumber,sd.iRowNo,sd.cInvCode AS inventoryCode,c.cInvCcode AS inventoryCcode,
+            c.cInvName AS inventoryName,sd.cFree1 AS colour,c.cInvStd as specificationAndModel,903 as account
+            from UFDATA_903_2021.dbo.SO_SOMain sm
+            join UFDATA_903_2021.dbo.SO_SODetails sd on sm.id=sd.id
+            join UFDATA_903_2021.dbo.Inventory c on c.cInvCode=sd.cInvCode
+            where sm.csocode=#{sy.orderNumber}
+        </if>
+    </select>
+
+    <select id="queryOMList" resultType="org.jeecg.modules.documents.orderData.entity.SySOAndOM" >
+        select om.cCode,od.iVouchRowNo,od.cInvCode AS inventoryCode,
+            c.cInvName AS inventoryName,od.cFree1 AS colour,c.cInvStd as specificationAndModel
+        from OM_MOMain om
+        join OM_MODetails od on om.MOID =od.MOID
+        join Inventory c on c.cInvCode=od.cInvCode
+        where om.cCode=#{cCode}
+    </select>
+
+</mapper>

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/service/ISySOAndOMService.java

@@ -0,0 +1,12 @@
+package org.jeecg.modules.documents.orderData.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import org.jeecg.modules.documents.orderData.entity.SySOAndOM;
+
+public interface ISySOAndOMService extends IService<SySOAndOM> {
+    IPage<SySOAndOM> querySOList(SySOAndOM sy, Page<SySOAndOM> page);
+
+    IPage<SySOAndOM> queryOMList(SySOAndOM sy, Page<SySOAndOM> page);
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/service/impl/SySOAndOMServiceImpl.java

@@ -0,0 +1,56 @@
+package org.jeecg.modules.documents.orderData.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.apache.poi.ss.formula.functions.T;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.modules.documents.orderData.entity.SyOrderData;
+import org.jeecg.modules.documents.orderData.entity.SyOrderDataItem;
+import org.jeecg.modules.documents.orderData.entity.SyOrderDataVO;
+import org.jeecg.modules.documents.orderData.entity.SySOAndOM;
+import org.jeecg.modules.documents.orderData.mapper.SyOrderDataMapper;
+import org.jeecg.modules.documents.orderData.mapper.SySOAndOMMapper;
+import org.jeecg.modules.documents.orderData.service.ISyOrderDataItemService;
+import org.jeecg.modules.documents.orderData.service.ISyOrderDataService;
+import org.jeecg.modules.documents.orderData.service.ISySOAndOMService;
+import org.jeecg.modules.openApi.entity.DxpDataPlan;
+import org.jeecg.modules.openApi.service.IDxpDataPlanService;
+import org.jeecg.modules.openApi.service.ISenYuDataSourceOne;
+import org.jeecg.modules.openApi.service.ISenYuDataSourceThree;
+import org.jeecg.modules.openApi.service.ISenYuDataSourceTwo;
+import org.jeecg.modules.system.util.JsonChangeUtils;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Description: 订单主表
+ * @Author: jeecg-boot
+ * @Date:   2022-04-21
+ * @Version: V1.0
+ */
+@Service
+public class SySOAndOMServiceImpl extends ServiceImpl<SySOAndOMMapper, SySOAndOM> implements ISySOAndOMService {
+    @Autowired
+    private SySOAndOMMapper sySOAndOMMapper;
+
+    @Override
+    public IPage<SySOAndOM> querySOList(SySOAndOM sy, Page<SySOAndOM> page) {
+        return sySOAndOMMapper.querySOList(sy, page);
+    }
+
+    @Override
+    public IPage<SySOAndOM> queryOMList(SySOAndOM sy, Page<SySOAndOM> page) {
+        return sySOAndOMMapper.queryOMList(sy, page);
+    }
+}