国联订单创建接口对接

blade-common/src/main/java/org/springblade/common/config/RedisConfig.java

@@ -0,0 +1,117 @@
+package org.springblade.common.config;
+
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+import com.fasterxml.jackson.annotation.PropertyAccessor;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
+import org.springframework.cache.annotation.CachingConfigurerSupport;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.*;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+
+/**
+ * @author rain
+ */
+@Configuration
+@EnableCaching
+public class RedisConfig extends CachingConfigurerSupport {
+
+    /**
+     * redis template相关配置
+     *
+     * @param factory 参数
+     * @return 结果
+     */
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
+
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
+        // 配置连接工厂
+        template.setConnectionFactory(factory);
+
+        //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值（默认使用JDK的序列化方式）
+        Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);
+
+        ObjectMapper om = new ObjectMapper();
+        // 指定要序列化的域，field,get和set,以及修饰符范围，ANY是都有包括private和public
+        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
+        // 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如String,Integer等会跑出异常
+        // om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
+        om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.WRAPPER_ARRAY);
+        jacksonSeial.setObjectMapper(om);
+
+        // 值采用json序列化
+        template.setValueSerializer(jacksonSeial);
+        //使用StringRedisSerializer来序列化和反序列化redis的key值
+        template.setKeySerializer(new StringRedisSerializer());
+
+        // 设置hash key 和value序列化模式
+        template.setHashKeySerializer(new StringRedisSerializer());
+        template.setHashValueSerializer(jacksonSeial);
+        template.afterPropertiesSet();
+
+        return template;
+    }
+
+    /**
+     * 对hash类型的数据操作
+     *
+     * @param redisTemplate 参数
+     * @return 结果
+     */
+    @Bean
+    public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) {
+        return redisTemplate.opsForHash();
+    }
+
+    /**
+     * 对redis字符串类型数据操作
+     *
+     * @param redisTemplate 参数
+     * @return 结果
+     */
+    @Bean
+    public ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) {
+        return redisTemplate.opsForValue();
+    }
+
+    /**
+     * 对链表类型的数据操作
+     *
+     * @param redisTemplate 参数
+     * @return 结果
+     */
+    @Bean
+    public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) {
+        return redisTemplate.opsForList();
+    }
+
+    /**
+     * 对无序集合类型的数据操作
+     *
+     * @param redisTemplate 参数
+     * @return 结果
+     */
+    @Bean
+    public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) {
+        return redisTemplate.opsForSet();
+    }
+
+    /**
+     * 对有序集合类型的数据操作
+     *
+     * @param redisTemplate 参数
+     * @return 结果
+     */
+    @Bean
+    public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
+        return redisTemplate.opsForZSet();
+    }
+
+}

blade-common/src/main/java/org/springblade/common/utils/RedisUtils.java

@@ -0,0 +1,592 @@
+package org.springblade.common.utils;
+
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+
+import javax.annotation.Resource;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * redisTemplate封装
+ *
+ * @author rain
+ */
+@Component
+public class RedisUtils {
+
+    @Resource
+    private RedisTemplate<String, Object> redisTemplate;
+
+    public RedisUtils(RedisTemplate<String, Object> redisTemplate) {
+        this.redisTemplate = redisTemplate;
+    }
+
+
+    /**
+     * 指定缓存失效时间
+     *
+     * @param key  键
+     * @param time 时间(秒)
+     * @return 结果
+     */
+    public boolean expire(String key, long time) {
+        try {
+            if (time > 0) {
+                redisTemplate.expire(key, time, TimeUnit.SECONDS);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 根据key 获取过期时间
+     *
+     * @param key 键 不能为null
+     * @return 时间(秒) 返回0代表为永久有效
+     */
+    public Long getExpire(String key) {
+        if (!StringUtils.hasText(key)) {
+            throw new NullPointerException("key不能为空");
+        }
+        Long data = redisTemplate.getExpire(key, TimeUnit.SECONDS);
+        return data == null ? 0L : data;
+
+    }
+
+    /**
+     * 判断key是否存在
+     *
+     * @param key 键
+     * @return true 存在 false不存在
+     */
+    public boolean hasKey(String key) {
+        try {
+            return redisTemplate.hasKey(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 删除缓存
+     *
+     * @param key 可以传一个值 或多个
+     */
+    @SuppressWarnings("unchecked")
+    public void del(String... key) {
+        if (key != null && key.length > 0) {
+            if (key.length == 1) {
+                redisTemplate.delete(key[0]);
+            } else {
+                redisTemplate.delete(Arrays.asList(key));
+            }
+        }
+    }
+
+
+    /**
+     * 普通缓存获取
+     *
+     * @param key 键
+     * @return 值
+     */
+    public Object get(String key) {
+        return key == null ? null : redisTemplate.opsForValue().get(key);
+    }
+
+    /**
+     * 普通缓存放入
+     *
+     * @param key   键
+     * @param value 值
+     * @return true成功 false失败
+     */
+    public boolean set(String key, Object value) {
+        try {
+            redisTemplate.opsForValue().set(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 普通缓存放入并设置时间
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期
+     * @return true成功 false 失败
+     */
+    public boolean set(String key, Object value, long time) {
+        try {
+            if (time > 0) {
+                redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
+            } else {
+                set(key, value);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 递增
+     *
+     * @param key   键
+     * @param delta 要增加几(大于0)
+     * @return 结果
+     */
+    public long incr(String key, long delta) {
+        if (delta < 0) {
+            throw new RuntimeException("递增因子必须大于0");
+        }
+        return redisTemplate.opsForValue().increment(key, delta);
+    }
+
+    /**
+     * 递减
+     *
+     * @param key   键
+     * @param delta 要减少几(小于0)
+     * @return 结果
+     */
+    public long decr(String key, long delta) {
+        if (delta < 0) {
+            throw new RuntimeException("递减因子必须大于0");
+        }
+        return redisTemplate.opsForValue().increment(key, -delta);
+    }
+
+    //================================Map=================================
+
+    /**
+     * HashGet
+     *
+     * @param key  键 不能为null
+     * @param item 项 不能为null
+     * @return 值
+     */
+    public Object hget(String key, String item) {
+        return redisTemplate.opsForHash().get(key, item);
+    }
+
+    /**
+     * 获取hashKey对应的所有键值
+     *
+     * @param key 键
+     * @return 对应的多个键值
+     */
+    public Map<Object, Object> hmget(String key) {
+        return redisTemplate.opsForHash().entries(key);
+    }
+
+    /**
+     * HashSet
+     *
+     * @param key 键
+     * @param map 对应多个键值
+     * @return true 成功 false 失败
+     */
+    public boolean hmset(String key, Map<String, Object> map) {
+        try {
+            redisTemplate.opsForHash().putAll(key, map);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * HashSet 并设置时间
+     *
+     * @param key  键
+     * @param map  对应多个键值
+     * @param time 时间(秒)
+     * @return true成功 false失败
+     */
+    public boolean hmset(String key, Map<String, Object> map, long time) {
+        try {
+            redisTemplate.opsForHash().putAll(key, map);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 向一张hash表中放入数据,如果不存在将创建
+     *
+     * @param key   键
+     * @param item  项
+     * @param value 值
+     * @return true 成功 false失败
+     */
+    public boolean hset(String key, String item, Object value) {
+        try {
+            redisTemplate.opsForHash().put(key, item, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 向一张hash表中放入数据,如果不存在将创建
+     *
+     * @param key   键
+     * @param item  项
+     * @param value 值
+     * @param time  时间(秒)  注意:如果已存在的hash表有时间,这里将会替换原有的时间
+     * @return true 成功 false失败
+     */
+    public boolean hset(String key, String item, Object value, long time) {
+        try {
+            redisTemplate.opsForHash().put(key, item, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 删除hash表中的值
+     *
+     * @param key  键 不能为null
+     * @param item 项 可以使多个 不能为null
+     */
+    public void hdel(String key, Object... item) {
+        redisTemplate.opsForHash().delete(key, item);
+    }
+
+    /**
+     * 判断hash表中是否有该项的值
+     *
+     * @param key  键 不能为null
+     * @param item 项 不能为null
+     * @return true 存在 false不存在
+     */
+    public boolean hHasKey(String key, String item) {
+        return redisTemplate.opsForHash().hasKey(key, item);
+    }
+
+    /**
+     * hash递增 如果不存在,就会创建一个 并把新增后的值返回
+     *
+     * @param key  键
+     * @param item 项
+     * @param by   要增加几(大于0)
+     * @return 结果
+     */
+    public double hincr(String key, String item, double by) {
+        return redisTemplate.opsForHash().increment(key, item, by);
+    }
+
+    /**
+     * hash递减
+     *
+     * @param key  键
+     * @param item 项
+     * @param by   要减少记(小于0)
+     * @return 结果
+     */
+    public double hdecr(String key, String item, double by) {
+        return redisTemplate.opsForHash().increment(key, item, -by);
+    }
+
+    //============================set=============================
+
+    /**
+     * 根据key获取Set中的所有值
+     *
+     * @param key 键
+     * @return 结果
+     */
+    public Set<Object> sGet(String key) {
+        try {
+            return redisTemplate.opsForSet().members(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 根据value从一个set中查询,是否存在
+     *
+     * @param key   键
+     * @param value 值
+     * @return true 存在 false不存在
+     */
+    public boolean sHasKey(String key, Object value) {
+        try {
+            return redisTemplate.opsForSet().isMember(key, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将数据放入set缓存
+     *
+     * @param key    键
+     * @param values 值 可以是多个
+     * @return 成功个数
+     */
+    public long sSet(String key, Object... values) {
+        try {
+            return redisTemplate.opsForSet().add(key, values);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 将set数据放入缓存
+     *
+     * @param key    键
+     * @param time   时间(秒)
+     * @param values 值 可以是多个
+     * @return 成功个数
+     */
+    public long sSetAndTime(String key, long time, Object... values) {
+        try {
+            Long count = redisTemplate.opsForSet().add(key, values);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return count;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 获取set缓存的长度
+     *
+     * @param key 键
+     * @return 结果
+     */
+    public long sGetSetSize(String key) {
+        try {
+            return redisTemplate.opsForSet().size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 移除值为value的
+     *
+     * @param key    键
+     * @param values 值 可以是多个
+     * @return 移除的个数
+     */
+    public long setRemove(String key, Object... values) {
+        try {
+            Long count = redisTemplate.opsForSet().remove(key, values);
+            return count;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+    //===============================list=================================
+
+    /**
+     * 获取list缓存的内容
+     *
+     * @param key   键
+     * @param start 开始
+     * @param end   结束  0 到 -1代表所有值
+     * @return
+     */
+    public List<Object> lGet(String key, long start, long end) {
+        try {
+            return redisTemplate.opsForList().range(key, start, end);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 获取list缓存的长度
+     *
+     * @param key 键
+     * @return 结果
+     */
+    public long lGetListSize(String key) {
+        try {
+            return redisTemplate.opsForList().size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 通过索引 获取list中的值
+     *
+     * @param key   键
+     * @param index 索引  index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
+     * @return 结果
+     */
+    public Object lGetIndex(String key, long index) {
+        try {
+            return redisTemplate.opsForList().index(key, index);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @return 结果
+     */
+    public boolean lSet(String key, Object value) {
+        try {
+            redisTemplate.opsForList().rightPush(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒)
+     * @return 结果
+     */
+    public boolean lSet(String key, Object value, long time) {
+        try {
+            redisTemplate.opsForList().rightPush(key, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @return 结果
+     */
+    public boolean lSet(String key, List<Object> value) {
+        try {
+            redisTemplate.opsForList().rightPushAll(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒)
+     * @return 结果
+     */
+    public boolean lSet(String key, List<Object> value, long time) {
+        try {
+            redisTemplate.opsForList().rightPushAll(key, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 根据索引修改list中的某条数据
+     *
+     * @param key   键
+     * @param index 索引
+     * @param value 值
+     * @return 结果
+     */
+    public boolean lUpdateIndex(String key, long index, Object value) {
+        try {
+            redisTemplate.opsForList().set(key, index, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 移除N个值为value
+     *
+     * @param key   键
+     * @param count 移除多少个
+     * @param value 值
+     * @return 移除的个数
+     */
+    public long lRemove(String key, long count, Object value) {
+        try {
+            return redisTemplate.opsForList().remove(key, count, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+	/**
+	 * 增加(自增长), 负数则为自减
+	 *
+	 * @param key
+	 * @param increment
+	 * @return
+	 */
+	public Long incrBy(String key, long increment) {
+		return redisTemplate.opsForValue().increment(key, increment);
+	}
+
+}

blade-service-api/blade-sales-part-api/src/main/java/org/springblade/salesPart/cnauto/ShopResultRecord.java

@@ -0,0 +1,54 @@
+package org.springblade.salesPart.cnauto;
+
+import lombok.Data;
+
+import java.util.Date;
+
+
+/**
+ * @author Rain
+ */
+@Data
+public class ShopResultRecord {
+
+	/**
+	 * 主键ID
+	 */
+	private Long id;
+
+	/**
+	 * 租户ID
+	 */
+	private String tenantId;
+
+	/**
+	 * 应用ID
+	 */
+	private Integer appId;
+
+	/**
+	 * 轮胎数
+	 */
+	private Integer goodsNum;
+
+	/**
+	 * 状态码
+	 */
+	private String resultCode;
+
+	/**
+	 * 消息
+	 */
+	private String resultMsg;
+
+	/**
+	 * 数据
+	 */
+	private String resultData;
+
+	/**
+	 * 创建时间
+	 */
+	private Date createDate;
+
+}

blade-service/blade-sales-part/pom.xml

@@ -109,6 +109,17 @@
             <version>5.8.26</version>
         </dependency>
 
+<!--        <dependency>
+            <groupId>org.springblade</groupId>
+            <artifactId>tire-center-warehouse</artifactId>
+            <version>2.8.2.RELEASE</version>
+        </dependency>-->
+
+        <dependency>
+            <groupId>com.echepei</groupId>
+            <artifactId>shop-sdk</artifactId>
+            <version>1.0.3</version>
+        </dependency>
     </dependencies>
 
     <properties>

blade-service/blade-sales-part/src/main/java/org/springblade/salesPart/SalesPartApplication.java

@@ -1,16 +1,18 @@
 package org.springblade.salesPart;
 
-import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure;
+import org.mybatis.spring.annotation.MapperScan;
 import org.springblade.core.cloud.feign.EnableBladeFeign;
 import org.springblade.core.launch.BladeApplication;
 import org.springblade.core.transaction.annotation.SeataCloudApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.SpringCloudApplication;
+import org.springframework.context.annotation.ComponentScan;
 
 @EnableBladeFeign
 @SpringCloudApplication
 @SeataCloudApplication
 //@SpringBootApplication(exclude = DruidDataSourceAutoConfigure.class)
+@ComponentScan(value = {"com.ecp.tire.center.warehouse.**", "org.springblade.salesPart.**", "org.springblade.common.**"})
+@MapperScan(value = {"com.ecp.tire.center.warehouse.**.mapper", "org.springblade.salesPart.**.mapper"})
 public class SalesPartApplication {
 	public static void main(String[] args) {
 		BladeApplication.run("blade-sales-part", SalesPartApplication.class, args);

blade-service/blade-sales-part/src/main/java/org/springblade/salesPart/check/service/impl/AuditProecessServiceImpl.java

@@ -22,10 +22,10 @@ import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import io.seata.spring.annotation.GlobalTransactional;
 import lombok.AllArgsConstructor;
 import org.springblade.client.entity.Message;
 import org.springblade.client.feign.IMessageClient;
+import org.springblade.common.enums.CommonEnum;
 import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.api.R;
 import org.springblade.salesPart.check.dto.PjAuditProecessDTO;
@@ -36,6 +36,7 @@ import org.springblade.salesPart.check.mapper.AuditPathsActsMapper;
 import org.springblade.salesPart.check.mapper.AuditProecessMapper;
 import org.springblade.salesPart.check.service.IAuditProecessService;
 import org.springblade.salesPart.check.vo.PjAuditProecessVO;
+import org.springblade.salesPart.duoduo.util.ShopMallUtil;
 import org.springblade.salesPart.entity.PjCorpsDesc;
 import org.springblade.salesPart.entity.PjOrder;
 import org.springblade.salesPart.feign.IPJCorpClient;
@@ -82,6 +83,9 @@ public class AuditProecessServiceImpl extends ServiceImpl<AuditProecessMapper, P
 
 	private final IPjpfFundingItemService pjpfFundingItemService;
 
+	private final ShopMallUtil shopMallUtil;
+
+
 	@Override
 	public IPage<PjAuditProecessVO> selectAuditProecessPage(IPage<PjAuditProecessVO> page, PjAuditProecessVO auditProecess) {
 		return page.setRecords(baseMapper.selectAuditProecessPage(page, auditProecess));
@@ -451,6 +455,12 @@ public class AuditProecessServiceImpl extends ServiceImpl<AuditProecessMapper, P
 						item.setBondAmount(bondAmount);
 						item.setFundingAmount(fundingAmount);
 						pjpfFundingItemService.save(item);
+						// 给国联发送订单信息
+						String sendOrder = sysClient.getParamService("send.order");
+						if (CommonEnum.ONE.info.equals(sendOrder)) {
+							// 后台配置的才发送
+							shopMallUtil.sendOrderToMall(AuthUtil.getTenantId(), order.getGoodsTotalNum().intValue());
+						}
 					} else {
 						throw new RuntimeException("未找到融资总账信息");
 					}

blade-service/blade-sales-part/src/main/java/org/springblade/salesPart/duoduo/impl/ShopResultRecordServiceImpl.java

@@ -0,0 +1,16 @@
+package org.springblade.salesPart.duoduo.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springblade.salesPart.cnauto.ShopResultRecord;
+import org.springblade.salesPart.duoduo.mapper.ShopResultRecordMapper;
+import org.springblade.salesPart.duoduo.service.IShopResultRecordService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author Rain
+ */
+@Service
+public class ShopResultRecordServiceImpl extends ServiceImpl<ShopResultRecordMapper, ShopResultRecord> implements IShopResultRecordService {
+
+
+}

blade-service/blade-sales-part/src/main/java/org/springblade/salesPart/duoduo/mapper/ShopResultRecordMapper.java

@@ -0,0 +1,10 @@
+package org.springblade.salesPart.duoduo.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springblade.salesPart.cnauto.ShopResultRecord;
+
+/**
+ * @author Rain
+ */
+public interface ShopResultRecordMapper extends BaseMapper<ShopResultRecord> {
+}

blade-service/blade-sales-part/src/main/java/org/springblade/salesPart/duoduo/mapper/ShopResultRecordMapper.xml

@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.salesPart.duoduo.mapper.ShopResultRecordMapper">
+
+    <resultMap id="shopResultRecordResultMap" type="org.springblade.salesPart.cnauto.ShopResultRecord">
+            <id property="id" column="id"/>
+            <result property="appId" column="app_id"/>
+            <result property="tenantId" column="tenant_id"/>
+            <result property="goodsNum" column="goods_num"/>
+            <result property="resultCode" column="result_code"/>
+            <result property="resultMsg" column="result_msg"/>
+            <result property="resultData" column="result_data"/>
+        <result property="createDate" column="create_date"/>
+    </resultMap>
+
+
+</mapper>

blade-service/blade-sales-part/src/main/java/org/springblade/salesPart/duoduo/service/IShopResultRecordService.java

@@ -0,0 +1,10 @@
+package org.springblade.salesPart.duoduo.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import org.springblade.salesPart.cnauto.ShopResultRecord;
+
+/**
+ * @author Rain
+ */
+public interface IShopResultRecordService extends IService<ShopResultRecord> {
+}

blade-service/blade-sales-part/src/main/java/org/springblade/salesPart/duoduo/util/ShopMallUtil.java

@@ -0,0 +1,50 @@
+package org.springblade.salesPart.duoduo.util;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.ueiibi.shop.model.OrderResult;
+import com.ueiibi.shop.util.TireMallUtil;
+import lombok.AllArgsConstructor;
+import org.springblade.salesPart.cnauto.AppTenant;
+import org.springblade.salesPart.cnauto.ShopResultRecord;
+import org.springblade.salesPart.duoduo.service.IAppTenantService;
+import org.springblade.salesPart.duoduo.service.IShopResultRecordService;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import java.util.Date;
+
+/**
+ * @author Rain
+ */
+@Component
+@AllArgsConstructor
+public class ShopMallUtil {
+
+	private final IAppTenantService appTenantService;
+
+	private final IShopResultRecordService shopResultRecordService;
+
+
+	public void sendOrderToMall(String tenantId, Integer goodsNum){
+		ShopResultRecord shopResultRecord = new ShopResultRecord();
+		shopResultRecord.setTenantId(tenantId);
+		shopResultRecord.setGoodsNum(goodsNum);
+		shopResultRecord.setCreateDate(new Date());
+		AppTenant appTenant = appTenantService.getOne(new LambdaQueryWrapper<AppTenant>()
+			.eq(AppTenant::getTenantId, tenantId).eq(AppTenant::getIsDelete, 0)
+			.orderByDesc(AppTenant::getCreateDate).last(" limit 1"));
+		if (ObjectUtils.isEmpty(appTenant) || ObjectUtils.isEmpty(appTenant.getAppId())) {
+			shopResultRecord.setResultCode("500");
+			shopResultRecord.setResultMsg("appId不存在, 请联系相关人员添加");
+			shopResultRecordService.save(shopResultRecord);
+			return;
+		}
+		OrderResult orderResult = TireMallUtil.sendOrder(Integer.valueOf(appTenant.getAppId()), goodsNum);
+		shopResultRecord.setResultCode(String.valueOf(orderResult.code));
+		shopResultRecord.setResultMsg(orderResult.message);
+		shopResultRecord.setResultData(orderResult.data);
+		shopResultRecordService.save(shopResultRecord);
+	}
+
+
+}

blade-service/blade-sales-part/src/main/java/org/springblade/salesPart/enums/FinalMap.java

@@ -21,4 +21,6 @@ public class FinalMap {
 
 	public static final BigDecimal TWO = new BigDecimal(2);
 
+	public static final Integer FIFTEEN = 15;
+
 }

pom.xml

@@ -130,6 +130,7 @@
                         <fork>true</fork>
                         <finalName>${project.build.finalName}</finalName>
                         <includeSystemScope>true</includeSystemScope>
+                        <skip>true</skip>  <!-- 默认跳过，子模块可覆盖 -->
                     </configuration>
                     <executions>
                         <execution>