ANTAI-WLTMS-API/src/main/java/com/steerinfo/dil/controller/BackgroundProcessingController.java

package com.steerinfo.dil.controller;


import com.steerinfo.dil.aspect.LogAspect;
import com.steerinfo.dil.feign.SSOFeign;
import com.steerinfo.dil.mapper.BackgroundProcessingMapper;
import com.steerinfo.dil.mapper.DilAppCidMapper;
import com.steerinfo.dil.mapper.OmstruckOrderMapper;
import com.steerinfo.dil.mapper.UniversalMapper;
import com.steerinfo.dil.model.DilAppCid;
import com.steerinfo.dil.model.OmstruckOrder;
import com.steerinfo.dil.service.impl.BackgroundProcessingServiceImpl;
import com.steerinfo.dil.util.BaseRESTfulController;
import com.steerinfo.dil.util.DataChange;
import com.steerinfo.framework.controller.RESTfulResult;
import io.swagger.annotations.ApiOperation;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import com.steerinfo.dil.util.SSOUtil;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.*;

/*
 * 后台处理程序
 */

@RestController
@RequestMapping("${api.version}/bp")
public class BackgroundProcessingController extends BaseRESTfulController {

    @Autowired
    private BackgroundProcessingMapper backgroundProcessingMapper;


    @Resource
    SSOUtil ssoUtil;

    @Resource
    DilAppCidMapper dilAppCidMapper;

    static final Logger log = Logger.getLogger(BackgroundProcessingController.class);

    @ApiOperation("登录接口")
    @PostMapping("bpLogin")
    public Map<String,Object> bpLogin(@RequestParam String loginName, @RequestParam String password,  @RequestParam String app_code,@RequestParam(required = false) String urlFlag) {
        Map<String,Object> resMap = ssoUtil.individualLogin(loginName,password,app_code);
        if("succeed".equals(resMap.get("status"))) {
            Map<String, Object> dataMap = (Map<String, Object>) resMap.get("data");
            Map<String, Object> userInfo = (Map<String, Object>) dataMap.get("user");
            // 根据用户名去查询该用户绑定的公司及下属公司
            List<Map<String, Object>> companyList = backgroundProcessingMapper.getCompanyList(loginName);
            if(companyList.size() > 0) {
                Map<String, Object> stringMap = new HashMap<>();
                stringMap.put("companyId",-1);
                companyList.add(stringMap);
            }
            Map<String,Object> rootCompanyMap = backgroundProcessingMapper.getCompanyRootMap(loginName);
            userInfo.put("dilCompanyList", companyList);
            if (rootCompanyMap != null && rootCompanyMap.get("isListed") != null) {
                userInfo.put("rootCompanyMap",rootCompanyMap);
            }
            if (urlFlag != null && urlFlag != "" && rootCompanyMap != null && !urlFlag.equals(rootCompanyMap.get("isListed"))) {
                resMap.put("status","failed");
                resMap.put("message","账号未在该平台注册,请检查账号");
                resMap.put("resultMessage","账号未在该平台注册,请检查账号");
                resMap.put("code","500");
                return resMap;
            }
            //查询车牌及司机id
            Map<String,Object> capacityMap = backgroundProcessingMapper.getCapacityMap(loginName);
            if(capacityMap != null){
                dataMap.putAll(capacityMap);
            }
            System.out.println(dataMap);
        }
        return resMap;
    }

    @ApiOperation("更新cid")
    @PostMapping("/insertAppCid")
    public RESTfulResult  insertAppCid(@RequestBody DilAppCid dilAppCid) {
        try {
            Map<String, Object> searchMap = new HashMap<>();
            searchMap.put("cid",dilAppCid.getCid());
            searchMap.put("userCode",dilAppCid.getUserCode());
            List<DilAppCid> mapList = dilAppCidMapper.selectByParameters(searchMap);
            if(mapList.size() > 0 && mapList.get(0) != null) {
                return success();
            }
            dilAppCid.setPrimaryId(dilAppCidMapper.nextId());
            dilAppCidMapper.insertSelective(dilAppCid);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return success("更新成功");
    }



}