From 608fa275864c7cb4353e5e030e4a1304e56529ac Mon Sep 17 00:00:00 2001
From: zss <zss@example.com>
Date: 星期三, 20 九月 2023 13:12:05 +0800
Subject: [PATCH] 修改4.0   9.20

---
 inventory-server/src/main/java/com/yuanchu/mom/service/impl/SaleServiceImpl.java |   98 ++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 80 insertions(+), 18 deletions(-)

diff --git a/inventory-server/src/main/java/com/yuanchu/mom/service/impl/SaleServiceImpl.java b/inventory-server/src/main/java/com/yuanchu/mom/service/impl/SaleServiceImpl.java
index c26a616..ea3ff9d 100644
--- a/inventory-server/src/main/java/com/yuanchu/mom/service/impl/SaleServiceImpl.java
+++ b/inventory-server/src/main/java/com/yuanchu/mom/service/impl/SaleServiceImpl.java
@@ -1,8 +1,11 @@
 package com.yuanchu.mom.service.impl;
 
+import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yuanchu.mom.Task.SyncOrder;
 import com.yuanchu.mom.mapper.SaleMaterialMapper;
 import com.yuanchu.mom.pojo.Sale;
 import com.yuanchu.mom.mapper.SaleMapper;
@@ -12,16 +15,19 @@
 import com.yuanchu.mom.pojo.dto.SaleDto;
 import com.yuanchu.mom.pojo.dto.SaleMaterialDto;
 import com.yuanchu.mom.pojo.vo.SaleVo;
+import com.yuanchu.mom.service.SaleMaterialService;
 import com.yuanchu.mom.service.SaleService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yuanchu.mom.vo.Result;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -37,6 +43,9 @@
 
     @Resource
     SaleMapper saleMapper;
+
+    @Resource
+    SaleMaterialService saleMaterialService;
 
     @Resource
     SaleMaterialMapper saleMaterialMapper;
@@ -99,23 +108,29 @@
     //鏍规嵁id鎵归噺鍒犻櫎
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void delAllSale(List<Integer> ids) {
-        List<Sale> sales = saleMapper.selectBatchIds(ids);
-        for (Sale sale : sales) {
-            sale.setState(0);
-            saleMapper.updateById(sale);
-            List<SaleMaterial> saleMaterials = saleMaterialMapper.selectSaleDatil(sale.getId());
-            for (SaleMaterial saleMaterial : saleMaterials) {
-                saleMaterial.setState(0);
-                saleMaterialMapper.updateById(saleMaterial);
-            }
-        }
+    public void delAllSale(String ids) {
+        //鎵归噺鍒犻櫎閿�鍞崟
+        saleMapper.delAllSale(ids);
+        //鎵归噺鍒犻櫎閿�鍞骇鍝佸崟
+        saleMaterialMapper.delAllSale(ids);
     }
 
     //鏍规嵁閿�鍞崟id淇敼淇℃伅
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void updateSaleById(String saleman, Integer id, SaleVo saleVo) {
+    public String updateSaleById(String saleman, Integer id, SaleVo saleVo) {
+        //鏍¢獙,鍚屼竴涓骇鍝佺殑瑙勬牸鍨嬪彿涓嶈兘鐩稿悓
+        List<SaleMaterialDto> saleMaterialList = saleVo.getSaleMaterialList();
+        // 浣跨敤鍝堝笇闆嗗悎鏉ュ垽鏂槸鍚﹀瓨鍦ㄧ浉鍚屽瓧娈靛�肩粍鍚�
+        Set<String> seen = new HashSet<>();
+        for (SaleMaterialDto saleMaterial : saleMaterialList) {
+            String key = saleMaterial.getName() + "," + saleMaterial.getSpecifications();
+            if (seen.contains(key)) {
+                return "鍚屼竴涓骇鍝佺殑瑙勬牸鍨嬪彿涓嶈兘鐩稿悓";
+            } else {
+                seen.add(key);
+            }
+        }
         Sale sale = saleMapper.selectById(id);
         sale.setSaleman(saleman);
         BeanUtils.copyProperties(saleVo, sale);
@@ -127,6 +142,7 @@
             BeanUtils.copyProperties(saleMaterialDto, saleMaterial);
             saleMaterialMapper.updateById(saleMaterial);
         }
+        return "淇敼鎴愬姛!";
     }
 
     //瀹℃牳
@@ -170,11 +186,57 @@
                 .orderCode(orderNumber)
                 .customerCode(sale.getCode())
                 .proname(sale.getProname())
-                .adress(sale.getAdress())
-                .username(sale.getUsername())
-                .phone(sale.getPhone())
+                //.adress(sale.getAdress())
+                //.username(sale.getUsername())
+                //.phone(sale.getPhone())
                 .messages(dto2List)
                 .build();
         return consignmentDto1;
     }
+
+    //鍚屾閿�鍞暟鎹�
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public String synchronization() {
+        //褰撳ぉ鏃堕棿鐨勫噷鏅�4鐐瑰紑濮嬪悓姝�
+        String pattern = "yyyy-MM-dd HH:mm:ss";
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
+        String dateTime = LocalDateTime.now().with(LocalTime.of(4, 0, 0)).format(formatter);
+        //鑾峰彇涓婚攢鍞暟鎹�
+        List<Map<String, Object>> order = SyncOrder.getMainOrder(dateTime);
+        List<Sale> list = order.stream().map(orde -> {
+            Sale sale = new Sale();
+            sale.setOrderNumber(orde.get("orderNo").toString());//璁㈠崟缂栧彿
+            sale.setCode(String.valueOf(orde.get("customerContractNumber")));//瀹㈡埛鍚堝悓缂栧彿
+            sale.setName(orde.get("projectName").toString());//宸ョ▼鍚嶇О
+            sale.setProname(orde.get("customerName").toString());//瀹㈡埛鍚嶇О
+            sale.setOrderName(orde.get("createdName").toString());//涓嬪崟浜�
+            sale.setSaleman(orde.get("salesmanName").toString());//涓氬姟鍛�
+            sale.setDelTime(DateUtil.parseDate(orde.get("wantedDeliveryDate").toString()));//浜よ揣鏃ユ湡
+            sale.setCreateTime(DateUtil.parseDate(orde.get("orderDate").toString()));//涓嬪崟鏃ユ湡
+            sale.setNote(String.valueOf(orde.get("comment")));//澶囨敞
+            return sale;
+        }).collect(Collectors.toList());
+        //鍘婚噸
+        list.removeIf(sale -> ObjectUtils.isNotEmpty(saleMapper.selectOne(Wrappers.<Sale>query().eq("order_number", sale.getOrderNumber()))));
+        this.saveBatch(list);
+        for (Sale sale : list) {
+            List<Map<String, Object>> innerOrder = SyncOrder.getInnerOrder(dateTime, sale.getOrderNumber());
+            List<SaleMaterial> saleMaterials = innerOrder.stream().map(inorder -> {
+                SaleMaterial saleMaterial = new SaleMaterial();
+                saleMaterial.setName(inorder.get("productName").toString()); //浜у搧鍚嶇О
+                saleMaterial.setSpecifications(inorder.get("specificationModel").toString()); //浜у搧瑙勬牸鍨嬪彿
+                saleMaterial.setUnit(inorder.get("unit").toString());   //鍗曚綅
+                saleMaterial.setNumber((int) Double.parseDouble(inorder.get("quantity").toString()));  //鏁伴噺
+                saleMaterial.setPrice(inorder.get("unitPriceInclTax").toString());  //鍗曚环
+                saleMaterial.setSaleId(sale.getId());  //鍏宠仈 閿�鍞崟id
+                saleMaterial.setAdress(String.valueOf(inorder.get("shippingAddress")));  //鏀惰揣鍦板潃
+                saleMaterial.setUsername(String.valueOf(inorder.get("receivingContact")));  //鑱旂郴浜�
+                saleMaterial.setPhone(String.valueOf(inorder.get("receivingContactPhone")));  //鎵嬫満鍙�
+                return saleMaterial;
+            }).collect(Collectors.toList());
+            saleMaterialService.saveBatch(saleMaterials);
+        }
+        return "鍚屾鎴愬姛!";
+    }
 }

--
Gitblit v1.9.3