wms / wms_tianjinggelinmei · Files

package com.huaheng.api.erp.controller;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;

import com.huaheng.common.utils.Wrappers;

import com.huaheng.api.erp.domain.CapturePictureModule;

import com.huaheng.api.erp.service.DisConnect;
import com.huaheng.api.erp.service.HaveReConnect;
import com.huaheng.common.constant.QuantityConstant;

import com.huaheng.common.utils.StringUtils;

import com.huaheng.common.utils.security.ShiroUtils;

import com.huaheng.framework.aspectj.lang.annotation.ApiLogger;

import com.huaheng.framework.shiro.session.OnlineSessionDAO;

import com.huaheng.framework.web.controller.BaseController;
import com.huaheng.framework.web.domain.AjaxResult;

import com.huaheng.pc.config.camera.service.ICameraService;

import com.huaheng.pc.config.company.domain.Company;
import com.huaheng.pc.config.company.service.CompanyService;
import com.huaheng.pc.config.customer.domain.Customer;
import com.huaheng.pc.config.customer.service.CustomerServiceImpl;
import com.huaheng.pc.config.material.domain.Material;
import com.huaheng.pc.config.material.service.MaterialService;
import com.huaheng.pc.config.materialType.domain.MaterialType;
import com.huaheng.pc.config.materialType.service.MaterialTypeService;
import com.huaheng.pc.config.supplier.domain.Supplier;
import com.huaheng.pc.config.supplier.service.SupplierService;
import com.huaheng.pc.config.warehouse.domain.Warehouse;
import com.huaheng.pc.config.warehouse.service.WarehouseService;

import com.huaheng.pc.monitor.job.task.RyTask;

import com.huaheng.pc.monitor.online.domain.OnlineSession;

import com.huaheng.pc.receipt.receiptHeader.domain.ReceiptHeader;
import com.huaheng.pc.receipt.receiptHeader.service.ReceiptHeaderService;
import com.huaheng.pc.system.dept.domain.Dept;
import com.huaheng.pc.system.dept.service.IDeptService;
import com.huaheng.pc.system.role.domain.Role;
import com.huaheng.pc.system.role.service.IRoleService;
import com.huaheng.pc.system.user.domain.User;
import com.huaheng.pc.system.user.service.IUserService;
import com.huaheng.pc.vehicle.vehicleReceipt.service.VehicleReceiptService;
import com.huaheng.pc.vehicle.vehicleShipment.service.VehicleShipmentService;

import com.netsdk.demo.module.LoginModule;
import com.netsdk.lib.NetSDKLib;
import com.sun.jna.Pointer;

import io.swagger.annotations.ApiOperation;

import org.apache.shiro.session.Session;
import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;

import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.IOException;

import java.util.*;

import java.util.List;

@RestController
@RequestMapping("/API/WMS/v2")
public class ErpController extends BaseController {

    @Resource
    private IUserService userService;
    @Resource
    private IDeptService deptService;
    @Resource
    private WarehouseService warehouseService;
    @Resource
    private CompanyService companyService;
    @Resource
    private IRoleService roleService;
    @Resource
    private MaterialTypeService materialTypeService;
    @Resource
    private ReceiptHeaderService receiptHeaderService;
    @Resource
    private MaterialService materialService;
    @Resource
    private VehicleReceiptService vehicleReceiptService;
    @Resource
    private VehicleShipmentService vehicleShipmentService;
    @Resource
    private CustomerServiceImpl customerService;
    @Resource
    private SupplierService supplierService;

    @Autowired
    private OnlineSessionDAO onlineSessionDAO;

    @Autowired
    private ICameraService cameraService;

    /**
     * 1.车辆入库
     * 2.车辆出库
     * 3.物料
     */
    public static String cameraFlag = null;

    @PostMapping("/cameraLogin")

    @ApiOperation("登录拍照")

    @ApiLogger(apiName = "登录拍照", from = "ERP")

    @ResponseBody

    public AjaxResult login(String cameraId) {

        if(cameraId == null || "".equals(cameraId)){

            return AjaxResult.error("没有选择摄像头，缺少 cameraId 信息");

        }

        cameraFlag = cameraId;

        switch(cameraId){

            case "3":
                if(RyTask.camera1 == null){
                    //登录

                    AjaxResult ajaxResult = cameraService.loginCamera("camera1");

                    if(ajaxResult.getCode()!=200){
                        return AjaxResult.error().setData(ajaxResult.getData());
                    }

                }

                CapturePictureModule.remoteCapturePicture(0,new NetSDKLib.LLong(Long.valueOf(RyTask.camera1)));

                break;

            case "1" :
            case "2" :
                if(RyTask.camera2 == null){

                    AjaxResult ajaxResult = cameraService.loginCamera("camera2");

                    if(ajaxResult.getCode()!=200){
                        return AjaxResult.error().setData(ajaxResult.getData());
                    }

                }

                CapturePictureModule.remoteCapturePicture(0,new NetSDKLib.LLong(Long.valueOf(RyTask.camera2)));

                break;

            case "4" :
                if(RyTask.camera3 == null){
                    AjaxResult ajaxResult = cameraService.loginCamera("camera3");
                    if(ajaxResult.getCode()!=200){
                        return AjaxResult.error().setData(ajaxResult.getData());
                    }
                }
                CapturePictureModule.remoteCapturePicture(0,new NetSDKLib.LLong(Long.valueOf(RyTask.camera3)));
                break;

        }

        return AjaxResult.success("成功");

    }

    @PostMapping("/selectDept")
    @ApiOperation("查询部门")
    @ApiLogger(apiName = "查询部门", from = "ERP")
    @ResponseBody
    public AjaxResult selectDept() {
        List<Dept> deptList = deptService.selectDeptAll();
        return AjaxResult.success(deptList);
    }

    @PostMapping("/selectUser")
    @ApiOperation("查询用户")
    @ApiLogger(apiName = "查询用户", from = "ERP")
    @ResponseBody
    public AjaxResult selectUser() {
        List<User> selectUserList = userService.selectUserList(null);
        return AjaxResult.success(selectUserList);
    }

    @PostMapping("/selectCompany")
    @ApiOperation("查询货主")
    @ApiLogger(apiName = "查询货主", from = "ERP")
    @ResponseBody
    public AjaxResult selectCompany() {
        List<Company> companyList = companyService.list();
        return AjaxResult.success(companyList);
    }

    @PostMapping("/selectWarehouse")
    @ApiOperation("查询仓库")
    @ApiLogger(apiName = "查询仓库", from = "ERP")
    @ResponseBody
    public AjaxResult selectWarehouse() {
        List<Warehouse> warehouseList = warehouseService.list();
        return AjaxResult.success(warehouseList);
    }

    @PostMapping("/selectRole")
    @ApiOperation("查询角色")
    @ApiLogger(apiName = "查询角色", from = "ERP")
    @ResponseBody
    public AjaxResult selectRole() {
        List<Role> selectRoleAll = roleService.selectRoleAll();
        return AjaxResult.success(selectRoleAll);
    }

    @PostMapping("/selectMaterialType")
    @ApiOperation("查询原材料")
    @ApiLogger(apiName = "查询原材料", from = "ERP")
    @ResponseBody
    public AjaxResult selectMaterialType() {
        List<MaterialType> materialTypeList = materialTypeService.list();
        return AjaxResult.success(materialTypeList);
    }



    @PostMapping("/addUser")
    @ApiOperation("添加用户")
    @ApiLogger(apiName = "添加用户", from = "ERP")
    @ResponseBody
    public AjaxResult addUser(@RequestBody Map<String, String> map) {
        String loginName = map.get("loginName");
        String userName = map.get("userName");
        String passWord = map.get("passWord");
        String deptId = map.get("deptId");
        String warehouseCode = map.get("warehouseCode");
        String companyCode = map.get("companyCode");
        String companyName = map.get("companyName");
        String roleId = map.get("roleId");
        if(userName == null || userName.length()==0){
            return AjaxResult.error("没有 userName");
        }
        if(passWord == null || passWord.length()==0){
            return AjaxResult.error("没有 passWord");
        }
        if(warehouseCode == null || warehouseCode.length()==0){
            return AjaxResult.error("没有 warehouseCode");
        }
        if(companyCode == null || companyCode.length()==0 ){
            return AjaxResult.error("没有 companyCode");
        }
        if(companyName == null || companyName.length()==0){
            return AjaxResult.error("没有 companyName");
        }
        if(StringUtils.isEmpty(loginName)){
            loginName = userName;
        }
        if(roleId == null || roleId.length()==0){
            return AjaxResult.error("没有 roleId");
        }


        User user = new User();
        if(StringUtils.isNotEmpty(deptId)){
            user.setDeptId(Integer.parseInt(deptId));
        }
        user.setDeptId(155);
        user.setPassword(passWord);
        user.setLoginName(loginName);
        user.setUserName(userName);
        user.setCreateBy("ERP");
        List<Integer> roleIdsList = new ArrayList<>();
        roleIdsList.add(Integer.parseInt(roleId));
        user.setRoleIds(roleIdsList);
        List<String> stringList = new ArrayList<>();
        stringList.add(warehouseCode);
        user.setWarehouseCodeList(stringList);
        LambdaQueryWrapper<Company> companyLambdaQueryWrapper = Wrappers.lambdaQuery();
        companyLambdaQueryWrapper.eq(StringUtils.isNotEmpty(companyCode),Company::getCode,companyCode)

                .eq(StringUtils.isNotEmpty(companyName),Company::getName,companyName);

        Company companyServiceOne = companyService.getOne(companyLambdaQueryWrapper);
        Integer companyId = companyServiceOne.getId();
        List<Integer> companyIdList = new ArrayList<>();
        companyIdList.add(companyId);
        user.setCompanyIdList(companyIdList);
        int a = userService.insertUser(user);
        if(a==0){
            return AjaxResult.error("添加角色失败");
        }
        return AjaxResult.success();
    }



    //添加部门
    @PostMapping("/addDept")
    @ApiOperation("添加部门")
    @ApiLogger(apiName = "添加部门", from = "ERP")
    @ResponseBody
    public AjaxResult addDept(@RequestBody Map<String, String> map) {
        String parentId = map.get("parentId");
        String deptName = map.get("deptName");
        String ancestors = map.get("ancestors");
        if(deptName == null || deptName.length()==0){
            return AjaxResult.error("没有 deptName");
        }
        Dept dept = new Dept();
        dept.setDeptName(deptName);
        if(StringUtils.isEmpty(parentId)){
            dept.setParentId(0);
        }
        if(StringUtils.isEmpty(ancestors)){
            dept.setAncestors(ancestors);
        }
        dept.setCreateBy("ERP");

        int count = deptService.insertDept(dept);
        if(count<1){
            return AjaxResult.error("添加部门失败");
        }
        return AjaxResult.success();
    }

    //添加仓库
    @PostMapping("/addWarehourse")
    @ApiOperation("添加仓库")
    @ApiLogger(apiName = "添加仓库", from = "ERP")
    @ResponseBody
    public AjaxResult addWarehourse(@RequestBody Map<String, String> map) {
        String city = map.get("city");
        String state = map.get("state");
        String name = map.get("name");
        String code = map.get("code");
        Warehouse warehouse = new Warehouse();
        if(StringUtils.isEmpty(city)){
            warehouse.setCity("格林美");
        }
        if(StringUtils.isEmpty(state)){
            warehouse.setState("武汉");
        }
        if(name == "" || name.length()==0){
            return AjaxResult.error("没有 仓库名name");
        }
        if(code == "" || code.length()==0){
            return AjaxResult.error("没有 仓库code");
        }
        LambdaQueryWrapper<Warehouse> warehouseLambdaQueryWrapper2 = Wrappers.lambdaQuery();
        warehouseLambdaQueryWrapper2.eq(Warehouse::getCode,code);
        List<Warehouse> list2 = warehouseService.list(warehouseLambdaQueryWrapper2);
        if(list2.size()>0){
            return AjaxResult.error("仓库code重复");
        }

        warehouse.setCountry("中国");
        warehouse.setEnable(1);
        warehouse.setCreatedBy("ERP");
        warehouse.setCode(code);
        warehouse.setName(name);
        boolean isSuccess = warehouseService.save(warehouse);
        if(!isSuccess){
            return AjaxResult.error("添加仓库失败");
        }
        return AjaxResult.success();
    }



    //添加货主
    @PostMapping("/addCompany")
    @ApiOperation("添加货主")
    @ApiLogger(apiName = "添加货主", from = "ERP")
    @ResponseBody
    public AjaxResult addCompany(@RequestBody Map<String, String> map) {
        String warehouseCode = map.get("warehouseCode");
        String name = map.get("name");
        String code = map.get("code");
        if(name == null || name.length()==0){
            return AjaxResult.error("没有 货主名name");
        }
        if(code == null || code.length()==0){
            return AjaxResult.error("没有 货主code");
        }
        if(warehouseCode == null || warehouseCode.length()==0){
            return AjaxResult.error("没有 仓库编码warehouseCode");
        }

        LambdaQueryWrapper<Company> companyLambdaQueryWrapper = Wrappers.lambdaQuery();
        companyLambdaQueryWrapper.eq(StringUtils.isNotEmpty(code),Company::getCode,code);
        List<Company> companyList = companyService.list(companyLambdaQueryWrapper);
        if (companyList.size()>0){
            return AjaxResult.error("货主编码code重复");
        }

        LambdaQueryWrapper<Warehouse> warehouseLambdaQueryWrapper = Wrappers.lambdaQuery();
        warehouseLambdaQueryWrapper.eq(StringUtils.isNotEmpty(warehouseCode),Warehouse::getCode,warehouseCode);
        List<Warehouse> warehouseList = warehouseService.list(warehouseLambdaQueryWrapper);
        if (warehouseList.size()==0){
            return AjaxResult.error("没有找到仓库编码warehouseCode");
        }


        Company company = new Company();
        company.setWarehouseCode(warehouseCode);
        company.setCode(code);
        company.setName(name);
        company.setCreatedBy("ERP");
        boolean isSuccess = companyService.save(company);
        if(!isSuccess){
            return AjaxResult.error("添加货主失败");
        }
        return AjaxResult.success();
    }


    //添加原材料
    @PostMapping("/addMaterialType")
    @ApiOperation("添加原材料")
    @ApiLogger(apiName = "添加原材料", from = "ERP")
    @ResponseBody
    public AjaxResult addMaterialType(@RequestBody Map<String, String> map) {
        String name = map.get("name");
        String code = map.get("code");
        String companyCode = map.get("companyCode");
        String warehouseCode = map.get("warehouseCode");
        if(name == null || name.length()==0){
            return AjaxResult.error("没有 原材料name");
        }
        if(code == null || code.length()==0){
            return AjaxResult.error("没有 原材料code");
        }
        if(warehouseCode == null || warehouseCode.length()==0){
            return AjaxResult.error("没有 仓库编码warehouseCode");
        }
        if(companyCode == null || companyCode.length()==0){
            return AjaxResult.error("没有 货主编码companyCode");
        }

        List<String> list = new ArrayList<>();
        list.add(companyCode);
        list.add(warehouseCode);
        list.add(name);
        list.add(code);
        Map<String,String> map1 = new HashMap<>();
        map1.put("companyCode",companyCode);
        map1.put("warehouseCode",warehouseCode);
        map1.put("materialTypeName",name);
        map1.put("materialTypeCode",code);
        String repeat = isRepeat(map1);
        if (repeat.length()>1){
            return AjaxResult.error(repeat);
        };
        MaterialType materialType = new MaterialType();
        materialType.setWarehouseCode(warehouseCode);
        materialType.setName(name);
        materialType.setCode(code);
        materialType.setCompanyCode(companyCode);
        materialType.setEnable(1);
        materialType.setDaysToExpire(0);
        materialType.setTrackSerialNum(0);
        materialType.setAutoGenSerialNum(0);
        materialType.setMinShelfLifeDays(0);
        materialType.setCreatedBy("ERP");
        materialType.setVersion(0);
        boolean isSuccess = materialTypeService.save(materialType);
        if(!isSuccess){
            return AjaxResult.error("添加原材料失败");
        }
        return AjaxResult.success();
    }





    /**
     * 判断是否重复的方法
     */
    public String isRepeat(Map<String,String> map1){
        String companyCode = map1.get("companyCode");
        String warehouseCode = map1.get("warehouseCode");
        String materialTypeName = map1.get("materialTypeName");
        String materialTypeCode = map1.get("materialTypeCode");

        LambdaQueryWrapper<Company> companyLambdaQueryWrapper = Wrappers.lambdaQuery();
        companyLambdaQueryWrapper.eq(StringUtils.isNotEmpty(companyCode),Company::getCode,companyCode);
        List<Company> companyList = companyService.list(companyLambdaQueryWrapper);
        if (companyCode != null || companyList.size()==0){
            return "没有找到货主编码companyCode";
        }
        LambdaQueryWrapper<Warehouse> warehouseLambdaQueryWrapper = Wrappers.lambdaQuery();
        warehouseLambdaQueryWrapper.eq(StringUtils.isNotEmpty(warehouseCode),Warehouse::getCode,warehouseCode);
        List<Warehouse> warehouseList = warehouseService.list(warehouseLambdaQueryWrapper);
        if (warehouseList.size()==0){
            return "没有找到仓库编码warehouseCode";
        }
        LambdaQueryWrapper<MaterialType> materialTypeLambdaQueryWrapper = Wrappers.lambdaQuery();
        materialTypeLambdaQueryWrapper.eq(StringUtils.isNotEmpty(materialTypeName),MaterialType::getName,materialTypeName);
        List<MaterialType> materialTypeList = materialTypeService.list(materialTypeLambdaQueryWrapper);
        if (materialTypeList.size()>0){
            return "原材料名字重复 name";
        }
        LambdaQueryWrapper<MaterialType> materialTypeLambdaQueryWrapper2 = Wrappers.lambdaQuery();
        materialTypeLambdaQueryWrapper2.eq(StringUtils.isNotEmpty(materialTypeCode),MaterialType::getCode,materialTypeCode);
        List<MaterialType> materialTypeList2 = materialTypeService.list(materialTypeLambdaQueryWrapper2);
        if (materialTypeList2.size()>0){
            return "原材料编码重复 code";
        }
        return "1";
    }






    //添加采购单入库单
    @PostMapping("/addReceiptHeader")
    @ApiOperation("添加原材料")
    @ApiLogger(apiName = "添加原材料", from = "ERP")
    @ResponseBody
    public AjaxResult addReceiptHeader(@RequestBody Map<String, String> map) {
        String companyCode = map.get("companyCode");
        String warehouseCode = map.get("warehouseCode");
        String receiptType = map.get("receiptType");
        if(warehouseCode == null || warehouseCode.length()==0){
            return AjaxResult.error("没有 仓库编码warehouseCode");
        }
        if(companyCode == null || companyCode.length()==0){
            return AjaxResult.error("没有 货主编码companyCode");
        }
        LambdaQueryWrapper<Company> companyLambdaQueryWrapper = Wrappers.lambdaQuery();
        companyLambdaQueryWrapper.eq(StringUtils.isNotEmpty(companyCode),Company::getCode,companyCode);
        List<Company> companyList = companyService.list(companyLambdaQueryWrapper);
        if (companyList.size()==0){
            return AjaxResult.error("没有找到货主编码companyCode");
        }
        LambdaQueryWrapper<Warehouse> warehouseLambdaQueryWrapper = Wrappers.lambdaQuery();
        warehouseLambdaQueryWrapper.eq(StringUtils.isNotEmpty(warehouseCode),Warehouse::getCode,warehouseCode);
        List<Warehouse> warehouseList = warehouseService.list(warehouseLambdaQueryWrapper);
        if (warehouseList.size()==0){
            return AjaxResult.error("没有找到仓库编码warehouseCode");
        }
        LambdaQueryWrapper<Company> companyLambdaQueryWrapper2 = Wrappers.lambdaQuery();
        companyLambdaQueryWrapper2.eq(StringUtils.isNotEmpty(companyCode),Company::getCode,companyCode)
                .eq(StringUtils.isNotEmpty(warehouseCode),Company::getWarehouseCode,warehouseCode);
        List<Company> companyList2 = companyService.list(companyLambdaQueryWrapper2);
        if (companyList2.size()==0){
            return AjaxResult.error("货主编码companyCode和仓库编码warehouseCode不一致");
        }
        ReceiptHeader receiptHeader = new ReceiptHeader();
        if(StringUtils.isEmpty(receiptType)){
            receiptHeader.setReceiptType("CGD");
        }
        receiptHeader.setWarehouseCode(warehouseCode);
        receiptHeader.setCompanyCode(companyCode);
        receiptHeaderService.saveReceiptHeaders(receiptHeader);
        return AjaxResult.success();
    }




    //添加成品
    @PostMapping("/addMaterial")
    @ApiOperation("添加成品物料")
    @ApiLogger(apiName = "添加成品物料", from = "ERP")
    @ResponseBody
    public AjaxResult addMaterial(@RequestBody Map<String, String> map) {
        String code = map.get("code");
        String companyCode = map.get("companyCode");
        String warehouseCode = map.get("warehouseCode");
        String name = map.get("name");
        String type = map.get("type");
        if(warehouseCode == null || warehouseCode.length()==0){
            return AjaxResult.error("没有仓库编码 warehouseCode");
        }
        if(companyCode == null || companyCode.length()==0){
            return AjaxResult.error("没有货主编码 companyCode");
        }
        if(code == null || code.length()==0){
            return AjaxResult.error("没有成品物料编码 code");
        }
        if(name == null || name.length()==0){
            return AjaxResult.error("没有成品物料名字 name");
        }
        if(type == null || type.length()==0){
            return AjaxResult.error("没有成品物料原材料类型 type");
        }

        LambdaQueryWrapper<Material> materialLambdaQueryWrapper = Wrappers.lambdaQuery();
        materialLambdaQueryWrapper.eq(Material::getCode,code);
        List<Material> materialList = materialService.list(materialLambdaQueryWrapper);
        if(materialList.size()>0){
            return AjaxResult.error("成品物料编码重复 code");
        }
        LambdaQueryWrapper<Warehouse> warehouseLambdaQueryWrapper = Wrappers.lambdaQuery();
        warehouseLambdaQueryWrapper.eq(Warehouse::getCode,warehouseCode);
        List<Warehouse> warehouseList = warehouseService.list(warehouseLambdaQueryWrapper);
        if(warehouseList.size()==0){
            return AjaxResult.error("没有找到仓库编码 warehouseCode");
        }
        LambdaQueryWrapper<Company> companyLambdaQueryWrapper = Wrappers.lambdaQuery();
        companyLambdaQueryWrapper.eq(StringUtils.isNotEmpty(companyCode),Company::getCode,companyCode);
        List<Company> companyList = companyService.list(companyLambdaQueryWrapper);
        if (companyList.size()==0){
            return AjaxResult.error("没有找到货主编码 companyCode");
        }
        LambdaQueryWrapper<MaterialType> materialTypeLambdaQueryWrapper = Wrappers.lambdaQuery();
        materialTypeLambdaQueryWrapper.eq(MaterialType::getCode,type);
        List<MaterialType> materialTypeList = materialTypeService.list(materialTypeLambdaQueryWrapper);
        if(materialTypeList.size()==0){
            return AjaxResult.error("没有找到成品物料原材料类型 type");
        }

        LambdaQueryWrapper<MaterialType> materialTypeLambdaQueryWrapper2 = Wrappers.lambdaQuery();
        materialTypeLambdaQueryWrapper.eq(MaterialType::getCode,type)

                .eq(MaterialType::getWarehouseCode,warehouseCode)
                .eq(MaterialType::getCompanyCode,companyCode);

        List<MaterialType> materialTypeList2 = materialTypeService.list(materialTypeLambdaQueryWrapper2);
        if(materialTypeList2.size()==0){
            return AjaxResult.error("原材料类型:"+type+"仓库编码:"+warehouseCode+"货主编码:"+companyCode+"对应不一致!");
        }
        Material material = new Material();
        AjaxResult ajaxResult = materialService.addSave(material);
        return ajaxResult;

    }

//    //添加车辆入库信息
//    @PostMapping("/addVehicleReceipt")
//    @ApiOperation("添加车辆入库信息")
//    @ApiLogger(apiName = "添加车辆入库信息", from = "ERP")
//    @ResponseBody
//    public AjaxResult addVehicleReceipt(@RequestBody Map<String, String> map) {
//        String companyCode = map.get("companyCode");
//        String warehouseCode = map.get("warehouseCode");
//        String materialBatch = map.get("materialBatch");
//        String vehicleType = map.get("vehicleType");
//        String meterialName = map.get("meterialName");
//        String grossWeight = map.get("grossWeight");
//        String tareWeight = map.get("tareWeight");
//        String carNumber = map.get("carNumber");
//        String vehicleName = map.get("vehicleName");
//        String driverNumber = map.get("driverNumber");
//        String cardNumber = map.get("cardNumber");
//        String incomingTime = map.get("incomingTime");
//        String remark = map.get("remark");
//        String type = map.get("type");
//
//        if(warehouseCode == null || warehouseCode.length()==0){
//            return AjaxResult.error("没有仓库编码 warehouseCode");
//        }
//        if(companyCode == null || companyCode.length()==0){
//            return AjaxResult.error("没有货主编码 companyCode");
//        }
//        if(materialBatch == null || materialBatch.length()==0){
//            return AjaxResult.error("没有原料批号 materialBatch");
//        }
//        if(vehicleType == null || vehicleType.length()==0){
//            return AjaxResult.error("没有单据类型 vehicleType");
//        }
//
//        if(meterialName == null || meterialName.length()==0){
//            return AjaxResult.error("没有物料名称 meterialName");
//        }
//        if(grossWeight == null || grossWeight.length()==0){
//            return AjaxResult.error("没有毛重 grossWeight");
//        }
//        if(tareWeight == null || tareWeight.length()==0){
//            return AjaxResult.error("没有皮重 tareWeight");
//        }
//        if(carNumber == null || carNumber.length()==0){
//            return AjaxResult.error("没有车牌号 carNumber");
//        }
//        if(vehicleName == null || vehicleName.length()==0){
//            return AjaxResult.error("没有司机名字 vehicleName");
//        }
//        if(driverNumber == null || driverNumber.length()==0){
//            return AjaxResult.error("没有驾驶证号 driverNumber");
//        }
//        if(cardNumber == null || cardNumber.length()==0){
//            return AjaxResult.error("没有身份证 cardNumber");
//        }
//        if(incomingTime == null || incomingTime.length()==0){
//            return AjaxResult.error("没有入厂时间 incomingTime");
//        }
//        if(type == null || type.length()==0){
//            return AjaxResult.error("没有车辆任务类型 type");
//        }
//        VehicleReceipt vehicelReceipt = new VehicleReceipt();
//        vehicelReceipt.setCompanyCode(companyCode);
//        vehicelReceipt.setWarehouseCode(warehouseCode);
//        vehicelReceipt.setMaterialBatch(materialBatch);
//        vehicelReceipt.setVehicleType(vehicleType);
//        vehicelReceipt.setMeterialName(meterialName);
//        vehicelReceipt.setGrossWeight(grossWeight);
//        vehicelReceipt.setTareWeight(tareWeight);
//        vehicelReceipt.setCarNumber(carNumber);
//        vehicelReceipt.setVehicleName(vehicleName);
//        vehicelReceipt.setDriverNumber(driverNumber);
//        vehicelReceipt.setCardNumber(cardNumber);
////        vehicelReceipt.setIncomingTime(new Date());
//        vehicelReceipt.setCreatedBy("ERP");
//        vehicelReceipt.setRemark(remark);
//        boolean save = vehicleReceiptService.save(vehicelReceipt);
//        if(!save){
//            return AjaxResult.error("新增车辆入厂信息失败");
//        }
//        return AjaxResult.success();
//    }
//
//
//
//    //添加车辆出库信息
//    @PostMapping("/addVehicleShipment")
//    @ApiOperation("添加车辆出库信息")
//    @ApiLogger(apiName = "添加车辆出库信息", from = "ERP")
//    @ResponseBody
//    public AjaxResult addVehicleShipment(@RequestBody Map<String, String> map) {
//        String poundNumber = map.get("poundNumber");
//        String vehicleStatus = map.get("vehicleStatus");
//        String seller = map.get("seller");
//        String companyCode = map.get("companyCode");
//        String warehouseCode = map.get("warehouseCode");
//        String meterialName = map.get("meterialName");
//        String grossWeight = map.get("grossWeight");
//        String tareWeight = map.get("tareWeight");
//        String carNumber = map.get("carNumber");
//        String vehicleName = map.get("vehicleName");
//        String driverNumber = map.get("driverNumber");
//        String cardNumber = map.get("cardNumber");
//        String incomingTime = map.get("incomingTime");
//        String remark = map.get("remark");
//        String type = map.get("type");
//
//        if(warehouseCode == null || warehouseCode.length()==0){
//            return AjaxResult.error("没有仓库编码 warehouseCode");
//        }
//        if(companyCode == null || companyCode.length()==0){
//            return AjaxResult.error("没有货主编码 companyCode");
//        }
//        if(poundNumber == null || poundNumber.length()==0){
//            return AjaxResult.error("没有磅单编号 poundNumber");
//        }
//        if(vehicleStatus == null || vehicleStatus.length()==0){
//            return AjaxResult.error("没有状态 vehicleStatus");
//        }
//        if(seller == null || seller.length()==0){
//            return AjaxResult.error("没有销售商 seller");
//        }
//        if(meterialName == null || meterialName.length()==0){
//            return AjaxResult.error("没有物料名称 meterialName");
//        }
//        if(grossWeight == null || grossWeight.length()==0){
//            return AjaxResult.error("没有毛重 grossWeight");
//        }
//        if(tareWeight == null || tareWeight.length()==0){
//            return AjaxResult.error("没有皮重 tareWeight");
//        }
//        if(carNumber == null || carNumber.length()==0){
//            return AjaxResult.error("没有车牌号 carNumber");
//        }
//        if(vehicleName == null || vehicleName.length()==0){
//            return AjaxResult.error("没有司机名字 vehicleName");
//        }
//        if(driverNumber == null || driverNumber.length()==0){
//            return AjaxResult.error("没有驾驶证号 driverNumber");
//        }
//        if(cardNumber == null || cardNumber.length()==0){
//            return AjaxResult.error("没有身份证 cardNumber");
//        }
//        if(incomingTime == null || incomingTime.length()==0){
//            return AjaxResult.error("没有入厂时间 incomingTime");
//        }
//        if(type == null || type.length()==0){
//            return AjaxResult.error("没有车辆任务类型 type");
//        }
//
//        VehicleShipment vehicleShipment = new VehicleShipment();
//        vehicleShipment.setPoundNumber(poundNumber);
//        vehicleShipment.setVehicleStatus(vehicleStatus);
//        vehicleShipment.setSeller(seller);
//        vehicleShipment.setCompanyCode(companyCode);
//        vehicleShipment.setWarehouseCode(warehouseCode);
//        vehicleShipment.setMeterialName(meterialName);
//        vehicleShipment.setGrossWeight(grossWeight);
//        vehicleShipment.setTareWeight(tareWeight);
//        vehicleShipment.setCarNumber(carNumber);
//        vehicleShipment.setVehicleName(vehicleName);
//        vehicleShipment.setDriverNumber(driverNumber);
//        vehicleShipment.setCardNumber(cardNumber);
////        vehicleShipment.setIncomingTime();
//        vehicleShipment.setRemark(remark);
//        vehicleShipment.setType(type);
//        boolean save = vehicleShipmentService.save(vehicleShipment);
//        if(!save){
//            return AjaxResult.error("新增车辆出厂信息失败");
//        }
//        return AjaxResult.success();
//    }

    //添加客户

    @PostMapping("/addCustomer")

    @ApiOperation("添加客户")
    @ApiLogger(apiName = "添加客户", from = "ERP")

    @ResponseBody
    public AjaxResult addCustomer(@RequestBody Map<String, String> map) {
        String code = map.get("code");
        String shipToCode = map.get("shipToCode");
        String warehouseCode = map.get("warehouseCode");
        String companyCode = map.get("companyCode");
        String name = map.get("name");
        String address1 = map.get("address1");
        String address2 = map.get("address2");
        String city = map.get("city");
        String province = map.get("province");
        String country = map.get("country");
        String postalCode = map.get("postalCode");
        String parent = map.get("parent");
        String attentionTo = map.get("attentionTo");
        String phoneNum = map.get("phoneNum");
        String mobile = map.get("mobile");
        String faxNum = map.get("faxNum");
        String email = map.get("email");
        String enable = map.get("enable");
        String createdBy = map.get("createdBy");
        String processStamp = map.get("processStamp");
        String deleted = map.get("deleted");

        String endEnterpriseCode = map.get("endEnterpriseCode");

        String allCreditCode = map.get("allCreditCode");

//        if(StringUtils.isEmpty(country)){
//            return AjaxResult.error("国家地址country 字段不能为空");
//        }
//        if(StringUtils.isEmpty(province)){
//            return AjaxResult.error("省地址province 字段不能为空");
//        }
//        if(StringUtils.isEmpty(city)){
//            return AjaxResult.error("市地址city 字段不能为空");
//        }
//        if(StringUtils.isEmpty(address1)){
//            return AjaxResult.error("县地址address1 字段不能为空");
//        }
//        if(StringUtils.isEmpty(address2)){
//            return AjaxResult.error("镇地址address2 字段不能为空");
//        }

        Customer customer = new Customer();

        if(StringUtils.isEmpty(code)){

            return AjaxResult.error("没有客户ID code");
        }
        if(StringUtils.isEmpty(shipToCode)){
            customer.setShipToCode("");
        }
        if(StringUtils.isEmpty(warehouseCode)){
            customer.setWarehouseCode("CS0001");
        }
        if(StringUtils.isEmpty(companyCode)){
            customer.setCompanyCode("BHF");
        }

        if(StringUtils.isEmpty(name)){
            return AjaxResult.error("没有名称");

        }
        if(StringUtils.isEmpty(address1)){
            customer.setAddress1("");
        }
        if(StringUtils.isEmpty(city)){
            customer.setCity("武汉");
        }
        if(StringUtils.isEmpty(province)){

            customer.setProvince("湖北");

        }
        if(StringUtils.isEmpty(country)){
            customer.setCountry("中国");
        }
        if(StringUtils.isEmpty(postalCode)){
            customer.setPostalCode("");
        }
        if(StringUtils.isEmpty(parent)){
            customer.setParent(0);
        }
        if(StringUtils.isEmpty(attentionTo)){
            customer.setAttentionTo("");
        }
        if(StringUtils.isEmpty(phoneNum)){
            customer.setPhoneNum("");
        }
        if(StringUtils.isEmpty(mobile)){
            customer.setMobile("");
        }
        if(StringUtils.isEmpty(faxNum)){
            customer.setFaxNum("");
        }
        if(StringUtils.isEmpty(email)){
            customer.setEmail("");
        }

//        if(StringUtils.isEmpty(enable)){
//            customer.setEnable(true);

//        }
        if(StringUtils.isEmpty(createdBy)){
            customer.setCreatedBy("ERP");
        }
        if(StringUtils.isEmpty(processStamp)){
            customer.setProcessStamp("");
        }

        if(StringUtils.isEmpty(allCreditCode)){

            return AjaxResult.error("没有企业信用代码");
        }

        if(StringUtils.isEmpty(deleted)){
            customer.setDeleted(false);
        }

        customer.setAllCreditCode(allCreditCode);

        customer.setCode(code);
        customer.setName(name);

        customer.setCountry(country);
        customer.setProvince(province);

        customer.setCity(city);

        customer.setAddress1(address1);
        customer.setAddress2(address2);

        customer.setCreatedBy(createdBy);
        customer.setWarehouseCode("CS0001");
        customer.setCompanyCode("BHF");
        customer.setEnable(true);

        Customer one = customerService.getOne(new LambdaQueryWrapper<Customer>().eq(Customer::getCode, code));
        if (one==null) {
            customerService.save(customer);
        }else {

            customer.setId(one.getId());

            customerService.updateById(customer);
            return AjaxResult.success("客户更新成功");
        }
        return AjaxResult.success("客户同步成功");

    }



    //添加供应商
    @PostMapping("/addSupplier")
    @ApiOperation("添加供应商")
    @ApiLogger(apiName = "添加供应商", from = "ERP")
    @ResponseBody
    public AjaxResult addSupplier(@RequestBody Map<String, String> map) {
        String code = map.get("code");
        String companyCode = map.get("companyCode");
        String name = map.get("name");
        String address1 = map.get("address1");
        String address2 = map.get("address2");
        String city = map.get("city");
        String state = map.get("state");
        String country = map.get("country");
        String postalCode = map.get("postalCode");
        String parent = map.get("parent");
        String attentionTo = map.get("attentionTo");
        String phoneNum = map.get("phoneNum");
        String faxNum = map.get("faxNum");
        String email = map.get("email");
        String enable = map.get("enable");
        String createdBy = map.get("createdBy");
        String carrier = map.get("carrier");
        String version = map.get("version");
        String processStamp = map.get("processStamp");
        String deleted = map.get("deleted");

        String allCreditCode = map.get("allCreditCode");

        Supplier supplier = new Supplier();
        if(StringUtils.isEmpty(carrier)){
            supplier.setCarrier("");
        }
        if(StringUtils.isEmpty(version)){
            supplier.setVersion(0);
        }

        if(StringUtils.isEmpty(code)){
            supplier.setCompanyCode("没有供应商code");

        }
        if(StringUtils.isEmpty(companyCode)){
            supplier.setCompanyCode("BHF");
        }

        if(StringUtils.isEmpty(name)){
            return AjaxResult.error("没有供应商名称");

        }
        if(StringUtils.isEmpty(address1)){
            supplier.setAddress1("");
        }
        if(StringUtils.isEmpty(address2)){
            supplier.setAddress2("");
        }
        if(StringUtils.isEmpty(city)){
            supplier.setCity("武汉");
        }
        if(StringUtils.isEmpty(state)){
            supplier.setState("湖北");
        }
        if(StringUtils.isEmpty(country)){
            supplier.setCountry("中国");
        }
        if(StringUtils.isEmpty(postalCode)){
            supplier.setPostalCode("");
        }
        if(StringUtils.isEmpty(parent)){
            supplier.setParent(0);
        }
        if(StringUtils.isEmpty(attentionTo)){
            supplier.setAttentionTo("");
        }
        if(StringUtils.isEmpty(phoneNum)){
            supplier.setPhoneNum("");
        }
        if(StringUtils.isEmpty(faxNum)){
            supplier.setFaxNum("");
        }
        if(StringUtils.isEmpty(email)){
            supplier.setEmail("");
        }
        if(StringUtils.isEmpty(enable)){
            supplier.setEnable(true);
        }
        if(StringUtils.isEmpty(createdBy)){
            supplier.setCreatedBy("ERP");
        }
        if(StringUtils.isEmpty(processStamp)){
            supplier.setProcessStamp("");
        }
        if(StringUtils.isEmpty(deleted)){
            supplier.setDeleted(false);
        }

        if(StringUtils.isEmpty(allCreditCode)){
            supplier.setAllCreditCode(allCreditCode);
        }

        supplier.setCode(code);
        supplier.setAllCreditCode(allCreditCode);
        supplier.setCreatedBy(carrier);
        supplier.setName(name);
        supplier.setCreatedBy(createdBy);
        supplier.setWarehouseCode("CS0001");
        supplier.setCompanyCode(companyCode);
        supplier.setAddress1(address1);
        supplier.setCity(city);
        supplier.setState(state);
        supplier.setCountry(country);

        Supplier one = supplierService.getOne(new LambdaQueryWrapper<Supplier>().eq(Supplier::getCode, code));
        if (one==null) {
            supplierService.save(supplier);
        }else {

            supplier.setId(one.getId());

            supplierService.updateById(supplier);
            return AjaxResult.success("供应商更新成功");
        }
        return AjaxResult.success("同步供应商成功");

    }

}