123

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/CompanyBaseBiz.java

@@ -4,17 +4,63 @@ package com.xxfc.platform.vehicle.biz;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.xxfc.platform.vehicle.entity.*;
+import com.xxfc.platform.vehicle.mapper.BranchCompanyStockInfoMapper;
 import com.xxfc.platform.vehicle.mapper.CompanyBaseMapper;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
+import java.math.BigDecimal;
+import java.util.List;
+
 @Service
 @Slf4j
 public class CompanyBaseBiz extends BaseBiz<CompanyBaseMapper, CompanyBase>  {
 
 
+     @Autowired
+     BranchCompanyStockRightBiz stockRightBiz;
+
+     @Autowired
+     BranchCompanyStockInfoMapper stockInfoMapper;
+
+    @Value("${branchCompanyPic.url}")
+    private  String companyUrl;
+
     //临时数据同步
-  //  public ObjectRestResponse
+    public ObjectRestResponse synchro(){
+       List<BranchCompanyStockInfo> list= stockInfoMapper.selectAll();
+       if (list.size()>0){
+           for (BranchCompanyStockInfo companyStockInfo:list){
+                int num=0;
+               String companyName=companyStockInfo.getCompanyName();
+               Integer balance=companyStockInfo.getBalance();
+               Integer total=companyStockInfo.getTotal();
+               BigDecimal price=companyStockInfo.getPrice();
+               CompanyBase companyBase=new CompanyBase();
+               companyBase.setAddrCity(companyStockInfo.getAddrCity());
+               companyBase.setAddrProvince(companyStockInfo.getAddrProvince());
+               companyBase.setName(companyName);
+               companyBase.setCover(companyUrl+"/image/admin/upload"+companyStockInfo.getCompanyPic());
+               companyBase.setImages(companyUrl+"/image/admin/upload"+companyStockInfo.getCompanyPic());
+               insertSelective(companyBase);
+               Integer companyBaseId=companyBase.getId();
+               if (companyBaseId!=null){
+                    BranchCompanyStockRight branchCompanyStockRight=new BranchCompanyStockRight();
+                   branchCompanyStockRight.setBalance(balance);
+                   branchCompanyStockRight.setPrice(price);
+                   branchCompanyStockRight.setTotal(total);
+                   branchCompanyStockRight.setState(2);
+                   stockRightBiz.insertSelective(branchCompanyStockRight);
+               }
+               num++;
+               log.info("----成功---num=="+num+"---companyBaseId==="+companyBaseId);
+           }
+       }
+
+        return  ObjectRestResponse.succ();
+    }
 
 
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/admin/CompanyBaseController.java

+package com.xxfc.platform.vehicle.rest.admin;
+
+import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken;
+import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.xxfc.platform.vehicle.biz.BranchCompanyStockApplyInfoBiz;
+import com.xxfc.platform.vehicle.biz.CompanyBaseBiz;
+import com.xxfc.platform.vehicle.common.BaseController;
+import com.xxfc.platform.vehicle.common.RestResponse;
+import com.xxfc.platform.vehicle.constant.ResCode.ResCode;
+import com.xxfc.platform.vehicle.entity.BranchCompanyStockApplyInfo;
+import com.xxfc.platform.vehicle.pojo.BranchCompanyStockApplyVo;
+import com.xxfc.platform.vehicle.pojo.BranchCompanyStockSearchVo;
+import com.xxfc.platform.vehicle.pojo.vo.BranchCompanyStockInfoRightVo;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.servlet.http.HttpServletRequest;
+
+@RestController
+@IgnoreClientToken
+@IgnoreUserToken
+@RequestMapping("company/base")
+public class CompanyBaseController extends BaseController<CompanyBaseBiz> {
+
+
+
+    @PostMapping("synchro")
+    public ObjectRestResponse<String> synchro() {
+        return baseBiz.synchro();
+    }
+
+}