DAL-DAZHOU-JOIN-API/src/main/java/com/steerinfo/dil/service/impl/RmsSupplierServiceImpl.java

package com.steerinfo.dil.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.steerinfo.dil.mapper.RmsCarrierMapper;
import com.steerinfo.dil.mapper.RmsSupplierMapper;
import com.steerinfo.dil.model.RmsSupplier;
import com.steerinfo.dil.service.IRmsSupplierService;
import com.steerinfo.dil.util.newFileTool;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * RmsSupplier服务实现：
 * @author generator
 * @version 1.0-SNAPSHORT 2021-10-22 06:18
 * 类描述
 * 修订历史：
 * 日期：2021-10-22
 * 作者：generator
 * 参考：
 * 描述：RmsSupplier服务实现
 * @see null
 * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
 */
@Service(value = "rmsSupplierService")
public class RmsSupplierServiceImpl implements IRmsSupplierService {

    @Autowired
    private RmsSupplierMapper rmsSupplierMapper;

    @Autowired
    RmsCarrierMapper rmsCarrierMapper;

    /**
     * 操作供应商
     * @param mapVal
     * @return
     */
    @Override
    public int operationSupplier(Map<String, Object> mapVal) {
        try{
            new Thread( new Runnable() {
                public void run(){
                    try {
                        JSONObject jsonObject = new JSONObject(mapVal);
                        newFileTool.newFile(jsonObject.toString(),"金蝶同步物流供应商");
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        }catch (Exception e) {
            e.printStackTrace();
        }
        // 得到金蝶主键供应商id
        String EASSupplierId = (String) mapVal.get("EASSupplierId");
        // 得到供应商名称
        String supplierName = (String) mapVal.get("supplierName");
        // 得到供应商供应商简称
        String supplierAbbreviation = (String) mapVal.get("supplierAbbreviation");
        // 得到供应商代码
        String supplierDutyParagraph = (String) mapVal.get("supplierDutyParagraph");
        // 得到供应商地址
        String supplierAddress = (String) mapVal.get("supplierAddress");
        // 得到联系人
        String supplierContactsName = (String) mapVal.get("supplierAgent");
        // 得到联系电话
        String supplierContactNumber = (String) mapVal.get("supplierContactNumber");
        // 得到数据数据状态
        Integer dataStatus = (Integer) mapVal.get("dataStatus");
        // 得到供应商屏蔽信息
        Object supplierScreenInfo =  mapVal.get("supplierScreenInfo");
//        // 判断是供应商还是承运商
//        String dataType = (String) mapVal.get("dataType");
        // 判断是否EASId已存在
        Map<String,Object> map1 = new HashMap<>();
        map1.put("easSupplierId",EASSupplierId);
        Map<String,Object> map2 = new HashMap<>();
        BigDecimal deleted = new BigDecimal(0);
//        map1.put("deleted",deleted);
//        map2.put("deleted",deleted);
        List<RmsSupplier> rmsSuppliers = rmsSupplierMapper.selectByParameters(map1);
        // 供应商
        RmsSupplier rmsSupplier = new RmsSupplier();
        rmsSupplier.setEasSupplierId(EASSupplierId);
        rmsSupplier.setSupplierName(supplierName);
        rmsSupplier.setSupplierAbbreviation(supplierAbbreviation);
        rmsSupplier.setSupplierDutyParagraph(supplierDutyParagraph);
        rmsSupplier.setSupplierAddress(supplierAddress);
        if (supplierScreenInfo != null) {
            rmsSupplier.setSupplierScreenInfo(supplierScreenInfo.toString());
        }
        rmsSupplier.setSupplierContactsName(supplierContactsName);
        rmsSupplier.setSupplierContactNumber(supplierContactNumber);
        rmsSupplier.setInsertTime(new Date());
        rmsSupplier.setInsertUsername("admin");
        rmsSupplier.setUpdateTime(new Date());
        rmsSupplier.setUpdateUsername("admin");
        rmsSupplier.setInsertUpdateRemark("无");
        int result = 0;
        // 新增
        if (rmsSuppliers.size() == 0) {
            BigDecimal supplierId = rmsSupplierMapper.getSupplierId();
            rmsSupplier.setSupplierId(supplierId);
            rmsSupplier.setDeleted(new BigDecimal(0));
            result += rmsSupplierMapper.insertSelective(rmsSupplier);
        }
        // 修改
        if (rmsSuppliers.size() != 0 && dataStatus == 1) {
            RmsSupplier rmsSupplier1 = rmsSuppliers.get(0);
            rmsSupplier.setSupplierId(rmsSupplier1.getSupplierId());
            rmsSupplier.setDeleted(deleted);
            result += rmsSupplierMapper.updateByPrimaryKeySelective(rmsSupplier);
        }
        // 逻辑删除
        if (rmsSuppliers.size() != 0 && dataStatus == 2) {
            RmsSupplier rmsSupplier1 = rmsSuppliers.get(0);
            rmsSupplier.setSupplierId(rmsSupplier1.getSupplierId());
            rmsSupplier.setDeleted(new BigDecimal(1));
            result += rmsSupplierMapper.updateByPrimaryKeySelective(rmsSupplier);
        }
        return result;
    }

    /**
     * 查询供应商列表
     * @param mapVal
     * @return
     */
    @Override
    public List<Map<String, Object>> getSupplierList(Map<String, Object> mapVal) {
        return rmsSupplierMapper.getSupplierList(mapVal);
    }
}