Merge remote-tracking branch 'origin/feature/asyncOrder' into feature/asyncOrder

app.pid

@@ -1 +0,0 @@
-23172

sp-core/sp-api/src/main/java/com/pj/api/client/admin/AdminInterface.java

@@ -73,4 +73,16 @@ public interface AdminInterface {
     @RequestMapping(value = "TbDistrict/rpc/getByIds")
     List<DistrictDTO> getDistrictList(@RequestParam("ids") String ids);
 
+    /**
+     * 同步航通边民信息时,自动给边民注册app账号
+     */
+    @RequestMapping("/AppUser/rpc/generatePeopleAccount")
+    public boolean generatePeopleAccount(@RequestBody PeopleDto peopleDto) throws Exception;
+
+    /**
+     * 同步航通边民信息时,自动给外籍商户注册app账号
+     */
+    @RequestMapping("/AppUser/rpc/generateEnterpriseAccount")
+    public int generateEnterpriseAccount(@RequestBody EnterpriseDto enterpriseDto) throws Exception ;
+
 }

sp-core/sp-api/src/main/java/com/pj/api/client/admin/AdminInterfaceFallback.java

@@ -74,6 +74,18 @@ public class AdminInterfaceFallback implements FallbackFactory<AdminInterface> {
             public List<DistrictDTO> getDistrictList(String ids) {
                 return null;
             }
+
+            @Override
+            public boolean generatePeopleAccount(PeopleDto appUser) throws Exception {
+                log.error("边民注册app账户失败。对象:{}",appUser);
+                return false;
+            }
+
+            @Override
+            public int generateEnterpriseAccount(EnterpriseDto enterpriseDto) throws Exception {
+                log.error("外籍商户注册app账户失败。对象:{}",enterpriseDto);
+                return 0;
+            }
         };
     }
 

sp-core/sp-api/src/main/java/com/pj/api/dto/EnterpriseDto.java

@@ -11,128 +11,12 @@ import java.util.Date;
  **/
 public class EnterpriseDto {
 
+    private Long id;
 
     /**
-     * 名称
+     * 铺主姓名
      */
-    private String name;
-    /**
-     * 年龄
-     */
-    private Integer age;
-    /**
-     * 性别[1=男,2=女]
-     */
-    private Integer sex;
-    /**
-     *
-     */
-    private Long tradeAreaId;
-
-    /**
-     *
-     */
-    private String tradeAreaName;
-
-    public Long getTradeAreaId() {
-        return tradeAreaId;
-    }
-
-    public void setTradeAreaId(Long tradeAreaId) {
-        this.tradeAreaId = tradeAreaId;
-    }
-
-    public EnterpriseDto(String name, Integer age, Integer sex, Long tradeAreaId, String tradeAreaName, String nationality, String type, String legalPerson, String idCard, String contact, String businessLicense, Long shopId, String shopName, String bankNo, String bankName, String bankAccount, String dutyParagraph, String addressIds, String address, String agreement, int judgeStatus, String judgeContent, Date judgeTime, Date registerTime, Date createTime, String createBy, String createName, Date updateTime, String updateBy, String updateName, Integer deleteStatus, Integer isLock) {
-        this.name = name;
-        this.age = age;
-        this.sex = sex;
-        this.tradeAreaId = tradeAreaId;
-        this.tradeAreaName = tradeAreaName;
-        this.nationality = nationality;
-        this.type = type;
-        this.legalPerson = legalPerson;
-        this.idCard = idCard;
-        this.contact = contact;
-        this.businessLicense = businessLicense;
-        this.shopId = shopId;
-        this.shopName = shopName;
-        this.bankNo = bankNo;
-        this.bankName = bankName;
-        this.bankAccount = bankAccount;
-        this.dutyParagraph = dutyParagraph;
-        this.addressIds = addressIds;
-        this.address = address;
-        this.agreement = agreement;
-        this.judgeStatus = judgeStatus;
-        this.judgeContent = judgeContent;
-        this.judgeTime = judgeTime;
-        this.registerTime = registerTime;
-        this.createTime = createTime;
-        this.createBy = createBy;
-        this.createName = createName;
-        this.updateTime = updateTime;
-        this.updateBy = updateBy;
-        this.updateName = updateName;
-        this.deleteStatus = deleteStatus;
-        this.isLock = isLock;
-    }
-
-    public String getTradeAreaName() {
-        return tradeAreaName;
-    }
-
-    public void setTradeAreaName(String tradeAreaName) {
-        this.tradeAreaName = tradeAreaName;
-    }
-
-    public EnterpriseDto(String name, Integer age, Integer sex, String nationality, String type, String legalPerson, String idCard, String contact, String businessLicense, Long shopId, String shopName, String bankNo, String bankName, String bankAccount, String dutyParagraph, String addressIds, String address, String agreement, int judgeStatus, String judgeContent, Date judgeTime, Date registerTime, Date createTime, String createBy, String createName, Date updateTime, String updateBy, String updateName, Integer deleteStatus, Integer isLock) {
-        this.name = name;
-        this.age = age;
-        this.sex = sex;
-        this.nationality = nationality;
-        this.type = type;
-        this.legalPerson = legalPerson;
-        this.idCard = idCard;
-        this.contact = contact;
-        this.businessLicense = businessLicense;
-        this.shopId = shopId;
-        this.shopName = shopName;
-        this.bankNo = bankNo;
-        this.bankName = bankName;
-        this.bankAccount = bankAccount;
-        this.dutyParagraph = dutyParagraph;
-        this.addressIds = addressIds;
-        this.address = address;
-        this.agreement = agreement;
-        this.judgeStatus = judgeStatus;
-        this.judgeContent = judgeContent;
-        this.judgeTime = judgeTime;
-        this.registerTime = registerTime;
-        this.createTime = createTime;
-        this.createBy = createBy;
-        this.createName = createName;
-        this.updateTime = updateTime;
-        this.updateBy = updateBy;
-        this.updateName = updateName;
-        this.deleteStatus = deleteStatus;
-        this.isLock = isLock;
-    }
-
-    public Integer getAge() {
-        return age;
-    }
-
-    public void setAge(Integer age) {
-        this.age = age;
-    }
-
-    public Integer getSex() {
-        return sex;
-    }
-
-    public void setSex(Integer sex) {
-        this.sex = sex;
-    }
+    private String ownerName;
 
     /**
      * 国别
@@ -145,6 +29,11 @@ public class EnterpriseDto {
     private String type;
 
     /**
+     * 性别
+     */
+    private Integer sex;
+
+    /**
      * 法人
      */
     private String legalPerson;
@@ -157,7 +46,7 @@ public class EnterpriseDto {
     /**
      * 手机号码
      */
-    private String contact;
+    private String ownerTel;
 
     /**
      * 营业执照
@@ -180,9 +69,9 @@ public class EnterpriseDto {
     private String bankNo;
 
     /**
-     *
+     * 银行名称
      */
-    private String bankName;
+    private String bank;
 
     /**
      * 银行账号
@@ -190,56 +79,63 @@ public class EnterpriseDto {
     private String bankAccount;
 
     /**
+     * 年龄
+     */
+    private Integer age;
+
+    /**
      * 税号
      */
     private String dutyParagraph;
 
     /**
-     *
+     * 地址全路径如1,22,333
      */
     private String addressIds;
 
     /**
-     *
+     * 地址
      */
     private String address;
 
     /**
+     * 详细地址
+     */
+    private String detail;
+
+    /**
      *
      */
     private String agreement;
 
     /**
-     *
+     * 审核状态(0=未审核,1=审核通过,2=审核驳回)
      */
-    private int judgeStatus;
+    private Integer judgeStatus;
 
     /**
-     *
+     * 审核意见
      */
     private String judgeContent;
 
     /**
-     *
+     * 审核时间
      */
-    @JsonFormat(pattern = "yyyy-MM-dd")
     private Date judgeTime;
 
     /**
-     *
+     * 注册时间
      */
-    @JsonFormat(pattern = "yyyy-MM-dd")
     private Date registerTime;
 
-//	/**
-//	 *
-//	 */
-//	private String personId;
+    /**
+     * 审核人
+     */
+    private String judgeBy;
 
     /**
      * 创建时间
      */
-    @JsonFormat(pattern = "yyyy-MM-dd")
     private Date createTime;
 
     /**
@@ -255,7 +151,6 @@ public class EnterpriseDto {
     /**
      * 更新时间
      */
-    @JsonFormat(pattern = "yyyy-MM-dd")
     private Date updateTime;
 
     /**
@@ -271,21 +166,52 @@ public class EnterpriseDto {
     /**
      * 删除状态(0=禁用,1=启用)
      */
-    private Integer deleteStatus;
-
+    private Long deleteStatus;
 
     /**
-     * 是否锁定
+     * 是否锁住
      */
     private Integer isLock;
 
+    /**
+     * 互市区ID
+     */
+    private Long tradeAreaId;
+
+    /**
+     * 互市区名称
+     */
+    private String tradeAreaName;
+
+    /**
+     * 地方平台的内部业务编号
+     */
+    private String platSeqNo;
+
+    /**
+     * 证件类型
+     */
+    private String ownerIdtype;
+
+    /**
+     * 启停用状态： 1- 启用 2-停用 3-注销
+     */
+    private String eDStatus;
 
-    public String getName() {
-        return name;
+    public Long getId() {
+        return id;
     }
 
-    public void setName(String name) {
-        this.name = name;
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getOwnerName() {
+        return ownerName;
+    }
+
+    public void setOwnerName(String ownerName) {
+        this.ownerName = ownerName;
     }
 
     public String getNationality() {
@@ -304,6 +230,14 @@ public class EnterpriseDto {
         this.type = type;
     }
 
+    public Integer getSex() {
+        return sex;
+    }
+
+    public void setSex(Integer sex) {
+        this.sex = sex;
+    }
+
     public String getLegalPerson() {
         return legalPerson;
     }
@@ -320,12 +254,12 @@ public class EnterpriseDto {
         this.idCard = idCard;
     }
 
-    public String getContact() {
-        return contact;
+    public String getOwnerTel() {
+        return ownerTel;
     }
 
-    public void setContact(String contact) {
-        this.contact = contact;
+    public void setOwnerTel(String ownerTel) {
+        this.ownerTel = ownerTel;
     }
 
     public String getBusinessLicense() {
@@ -360,12 +294,12 @@ public class EnterpriseDto {
         this.bankNo = bankNo;
     }
 
-    public String getBankName() {
-        return bankName;
+    public String getBank() {
+        return bank;
     }
 
-    public void setBankName(String bankName) {
-        this.bankName = bankName;
+    public void setBank(String bank) {
+        this.bank = bank;
     }
 
     public String getBankAccount() {
@@ -376,6 +310,14 @@ public class EnterpriseDto {
         this.bankAccount = bankAccount;
     }
 
+    public Integer getAge() {
+        return age;
+    }
+
+    public void setAge(Integer age) {
+        this.age = age;
+    }
+
     public String getDutyParagraph() {
         return dutyParagraph;
     }
@@ -400,6 +342,14 @@ public class EnterpriseDto {
         this.address = address;
     }
 
+    public String getDetail() {
+        return detail;
+    }
+
+    public void setDetail(String detail) {
+        this.detail = detail;
+    }
+
     public String getAgreement() {
         return agreement;
     }
@@ -408,11 +358,11 @@ public class EnterpriseDto {
         this.agreement = agreement;
     }
 
-    public int getJudgeStatus() {
+    public Integer getJudgeStatus() {
         return judgeStatus;
     }
 
-    public void setJudgeStatus(int judgeStatus) {
+    public void setJudgeStatus(Integer judgeStatus) {
         this.judgeStatus = judgeStatus;
     }
 
@@ -440,6 +390,14 @@ public class EnterpriseDto {
         this.registerTime = registerTime;
     }
 
+    public String getJudgeBy() {
+        return judgeBy;
+    }
+
+    public void setJudgeBy(String judgeBy) {
+        this.judgeBy = judgeBy;
+    }
+
     public Date getCreateTime() {
         return createTime;
     }
@@ -488,11 +446,11 @@ public class EnterpriseDto {
         this.updateName = updateName;
     }
 
-    public Integer getDeleteStatus() {
+    public Long getDeleteStatus() {
         return deleteStatus;
     }
 
-    public void setDeleteStatus(Integer deleteStatus) {
+    public void setDeleteStatus(Long deleteStatus) {
         this.deleteStatus = deleteStatus;
     }
 
@@ -504,27 +462,72 @@ public class EnterpriseDto {
         this.isLock = isLock;
     }
 
-    public EnterpriseDto(String name, String nationality, String type, String legalPerson, String idCard, String contact, String businessLicense, Long shopId, String shopName, String bankNo, String bankName, String bankAccount, String dutyParagraph, String addressIds, String address, String agreement, int judgeStatus, String judgeContent, Date judgeTime, Date registerTime, Date createTime, String createBy, String createName, Date updateTime, String updateBy, String updateName, Integer deleteStatus, Integer isLock) {
-        this.name = name;
+    public Long getTradeAreaId() {
+        return tradeAreaId;
+    }
+
+    public void setTradeAreaId(Long tradeAreaId) {
+        this.tradeAreaId = tradeAreaId;
+    }
+
+    public String getTradeAreaName() {
+        return tradeAreaName;
+    }
+
+    public void setTradeAreaName(String tradeAreaName) {
+        this.tradeAreaName = tradeAreaName;
+    }
+
+    public String getPlatSeqNo() {
+        return platSeqNo;
+    }
+
+    public void setPlatSeqNo(String platSeqNo) {
+        this.platSeqNo = platSeqNo;
+    }
+
+    public String getOwnerIdtype() {
+        return ownerIdtype;
+    }
+
+    public void setOwnerIdtype(String ownerIdtype) {
+        this.ownerIdtype = ownerIdtype;
+    }
+
+    public String geteDStatus() {
+        return eDStatus;
+    }
+
+    public void seteDStatus(String eDStatus) {
+        this.eDStatus = eDStatus;
+    }
+
+    public EnterpriseDto(Long id, String ownerName, String nationality, String type, Integer sex, String legalPerson, String idCard, String ownerTel, String businessLicense, Long shopId, String shopName, String bankNo, String bank, String bankAccount, Integer age, String dutyParagraph, String addressIds, String address, String detail, String agreement, Integer judgeStatus, String judgeContent, Date judgeTime, Date registerTime, String judgeBy, Date createTime, String createBy, String createName, Date updateTime, String updateBy, String updateName, Long deleteStatus, Integer isLock, Long tradeAreaId, String tradeAreaName, String platSeqNo, String ownerIdtype, String eDStatus) {
+        this.id = id;
+        this.ownerName = ownerName;
         this.nationality = nationality;
         this.type = type;
+        this.sex = sex;
         this.legalPerson = legalPerson;
         this.idCard = idCard;
-        this.contact = contact;
+        this.ownerTel = ownerTel;
         this.businessLicense = businessLicense;
         this.shopId = shopId;
         this.shopName = shopName;
         this.bankNo = bankNo;
-        this.bankName = bankName;
+        this.bank = bank;
         this.bankAccount = bankAccount;
+        this.age = age;
         this.dutyParagraph = dutyParagraph;
         this.addressIds = addressIds;
         this.address = address;
+        this.detail = detail;
         this.agreement = agreement;
         this.judgeStatus = judgeStatus;
         this.judgeContent = judgeContent;
         this.judgeTime = judgeTime;
         this.registerTime = registerTime;
+        this.judgeBy = judgeBy;
         this.createTime = createTime;
         this.createBy = createBy;
         this.createName = createName;
@@ -533,6 +536,11 @@ public class EnterpriseDto {
         this.updateName = updateName;
         this.deleteStatus = deleteStatus;
         this.isLock = isLock;
+        this.tradeAreaId = tradeAreaId;
+        this.tradeAreaName = tradeAreaName;
+        this.platSeqNo = platSeqNo;
+        this.ownerIdtype = ownerIdtype;
+        this.eDStatus = eDStatus;
     }
 
     public EnterpriseDto() {

sp-core/sp-base/pom.xml

@@ -29,13 +29,6 @@
 		<!-- ================= 模块依赖 end ================= -->
 
 
-        <!-- rabbitmq 依赖 -->
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-amqp</artifactId>
-        </dependency>
-
-
         <!-- 阿里云短信服务 -->
         <dependency>
             <groupId>com.aliyun</groupId>

sp-core/sp-base/src/main/java/com/pj/aliyun/sms/AliyunInformSmsService.java

@@ -85,6 +85,52 @@ public class AliyunInformSmsService {
     }
 
     /**
+     * 发送注册成功通知
+     *
+     * @param mobile 手机号
+     * @return 执行结果
+     */
+    public static boolean sendRegisteSMS(String mobile,String content) {
+        try {
+            IClientProfile profile = DefaultProfile.getProfile(REGION_ID, accessKeyId, accessKeySecret);
+
+            DefaultProfile.addEndpoint(REGION_ID, REGION_ID, PRODUCT, DOMAIN);
+
+            IAcsClient acsClient = new DefaultAcsClient(profile);
+
+            SendSmsRequest request = new SendSmsRequest();
+
+            request.setMethod(MethodType.POST);
+
+            // 手机号可以单个也可以多个（多个用逗号隔开，如：15*******13,13*******27,17*******56）
+            request.setPhoneNumbers(mobile);
+
+            request.setSignName(signName);
+
+            request.setTemplateCode(templateCode);
+
+            /*  例如签名内容为：某某公司
+            例如模板内容为：亲爱的同事,很高兴的通知您，您抽中了由领导${userName}派发的大饼奖励${money}元，请及时找财务领取！
+            变量属性：userName-其他；money-其他；
+            则短信内容为：【某某公司】 亲爱的同事,很高兴的通知您，您抽中了由领导${userName}派发的大饼奖励${money}元，请及时找财务领取！*/
+            request.setTemplateParam(content);
+//            request.setTemplateParam("{\"mobile\":\""+ mobile +"\",\"mobile\":\""+ mobile +"\"}");
+
+            SendSmsResponse sendSmsResponse = acsClient.getAcsResponse(request);
+            if ((sendSmsResponse.getCode() != null) && (sendSmsResponse.getCode().equals("OK"))) {
+                log.info("发送成功,code:" + sendSmsResponse.getCode());
+                return true;
+            } else {
+                log.info("发送失败,code:" + sendSmsResponse.getCode());
+                return false;
+            }
+        } catch (ClientException e) {
+            log.error("发送失败,系统错误！", e);
+            return false;
+        }
+    }
+
+    /**
      * 获取逗号分隔的拼接字符串
      *
      * @param str 用于拼接的字符串集合

sp-core/sp-base/src/main/java/com/pj/retry/SmsRetryService.java

@@ -52,6 +52,22 @@ public class SmsRetryService {
         return true;
     }
 
+    /**
+     * 注册短信
+     * @param phone 手机号
+     * @return
+     * @throws Exception
+     */
+    @Async
+    @Retryable(value = Exception.class,maxAttempts = 3,backoff = @Backoff(delay = 2000,multiplier = 1.5))
+    public boolean sendSmsRegisteMsg(String phone,String content) throws Exception {
+        System.out.println("\n发送注册成功短信!\n");
+        //todo: 发送短信业务逻辑
+        boolean result = AliyunInformSmsService.sendRegisteSMS("18934859524",content);
+        if(!result) throw new Exception("模拟短信发送失败!");
+        return true;
+    }
+
 
     //最终补偿机制
     @Recover

sp-core/sp-base/src/main/java/com/pj/utils/ht/AESUtil.java

@@ -1,6 +1,5 @@
 package com.pj.utils.ht;
 
-import com.pj.rabbitmq.RabbitMQ;
 import org.apache.commons.lang3.RandomStringUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
@@ -275,12 +274,12 @@ public class AESUtil {
                 " \"borderTel\":\"12398524563\", \n" +
                 "\"groupId\":\"14\"\n" +
                 "}\n" +
-                "] }",RabbitMQ.ACC_KEY);
+                "] }",null); // RabbitmQ.ACC_KEY
         System.out.println("aes_cbc加密结果:" + cbcResult);
         System.out.println();
 
         System.out.println("---------解密CBC---------");
-        String cbcDecrypt = decryptCBC(cbcResult, RabbitMQ.ACC_KEY);
+        String cbcDecrypt = decryptCBC(cbcResult, null);// RabbitmQ.ACC_KEY
         System.out.println("aes解密结果:" + cbcDecrypt);
         System.out.println();
     }

sp-core/sp-nacos/src/main/resources/bootstrap.properties

@@ -1,39 +0,0 @@
-# --------------------- nacos注册中心 --------------------- 
-### nacos注册中心 - 地址
-spring.cloud.nacos.discovery.server-addr=127.0.0.1:8001
-### nacos注册中心 - 用户
-spring.cloud.nacos.discovery.username=nacos
-### nacos注册中心 - 密码
-spring.cloud.nacos.discovery.password=nacos
-
-# --------------------- nacos配置中心 --------------------- 
-### nacos配置中心 - 地址 [注册中心地址]
-spring.cloud.nacos.config.server-addr=${spring.cloud.nacos.discovery.server-addr}
-### nacos配置中心 - 用户 [注册中心用户名]
-spring.cloud.nacos.config.username=${spring.cloud.nacos.discovery.username}
-### nacos配置中心 - 密码 [注册中心用密码]
-spring.cloud.nacos.config.password=${spring.cloud.nacos.discovery.password}
-### 配置文件前缀
-spring.cloud.nacos.config.prefix=${spring.application.name}
-### 配置文件后缀
-spring.cloud.nacos.config.file-extension=yml
-### 共享配置 (实时刷新) 
-spring.cloud.nacos.config.refreshable-dataids=application-common.yml, application-common-${spring.profiles.active}.yml
-
-# --------------------- sentinel-dashboard 控制台 --------------------- 
-# sentinel dashboard 控制台地址 
-spring.cloud.sentinel.transport.dashboard=127.0.0.1:8002
-
-# --------------------- sentinel-dashboard 集成nacos (将配置储存到nacos中) --------------------- 
-### 取消控制台懒加载 
-spring.cloud.sentinel.eager=true
-### nacos地址、用户名、密码等信息 
-spring.cloud.sentinel.datasource.ds.nacos.server-addr=${spring.cloud.nacos.discovery.server-addr}
-spring.cloud.sentinel.datasource.ds.nacos.username=${spring.cloud.nacos.discovery.username}
-spring.cloud.sentinel.datasource.ds.nacos.password=${spring.cloud.nacos.discovery.password}
-spring.cloud.sentinel.datasource.ds.nacos.dataId=${spring.application.name}-sentinel
-spring.cloud.sentinel.datasource.ds.nacos.groupId=DEFAULT_GROUP
-spring.cloud.sentinel.datasource.ds.nacos.data-type=json
-spring.cloud.sentinel.datasource.ds.nacos.rule-type=flow
-
-

sp-native/sp-gateway/src/main/resources/application.yml

@@ -0,0 +1,8 @@
+# 端口
+server:
+    port: 8080
+
+spring:
+    # 当前环境
+    profiles.active: dev
+    

sp-native/sp-gateway/src/main/resources/bootstrap.yml

@@ -1,10 +1,5 @@
-# 端口
-server:
-    port: 8080
-
-spring: 
+spring:
     # 服务名称 
     application.name: sp-gateway
-    # 当前环境
-    profiles.active: dev
+
     

sp-service/async-server/.gitignore

@@ -1,33 +0,0 @@
-HELP.md
-target/
-!.mvn/wrapper/maven-wrapper.jar
-!**/src/main/**/target/
-!**/src/test/**/target/
-
-### STS ###
-.apt_generated
-.classpath
-.factorypath
-.project
-.settings
-.springBeans
-.sts4-cache
-
-### IntelliJ IDEA ###
-.idea
-*.iws
-*.iml
-*.ipr
-
-### NetBeans ###
-/nbproject/private/
-/nbbuild/
-/dist/
-/nbdist/
-/.nb-gradle/
-build/
-!**/src/main/**/build/
-!**/src/test/**/build/
-
-### VS Code ###
-.vscode/

sp-service/async-server/mvnw.cmd

@@ -1,188 +0,0 @@
-@REM ----------------------------------------------------------------------------
-@REM Licensed to the Apache Software Foundation (ASF) under one
-@REM or more contributor license agreements.  See the NOTICE file
-@REM distributed with this work for additional information
-@REM regarding copyright ownership.  The ASF licenses this file
-@REM to you under the Apache License, Version 2.0 (the
-@REM "License"); you may not use this file except in compliance
-@REM with the License.  You may obtain a copy of the License at
-@REM
-@REM    https://www.apache.org/licenses/LICENSE-2.0
-@REM
-@REM Unless required by applicable law or agreed to in writing,
-@REM software distributed under the License is distributed on an
-@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-@REM KIND, either express or implied.  See the License for the
-@REM specific language governing permissions and limitations
-@REM under the License.
-@REM ----------------------------------------------------------------------------
-
-@REM ----------------------------------------------------------------------------
-@REM Maven Start Up Batch script
-@REM
-@REM Required ENV vars:
-@REM JAVA_HOME - location of a JDK home dir
-@REM
-@REM Optional ENV vars
-@REM M2_HOME - location of maven2's installed home dir
-@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
-@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
-@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
-@REM     e.g. to debug Maven itself, use
-@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
-@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
-@REM ----------------------------------------------------------------------------
-
-@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
-@echo off
-@REM set title of command window
-title %0
-@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
-@if "%MAVEN_BATCH_ECHO%" == "on"  echo %MAVEN_BATCH_ECHO%
-
-@REM set %HOME% to equivalent of $HOME
-if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
-
-@REM Execute a user defined script before this one
-if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
-@REM check for pre script, once with legacy .bat ending and once with .cmd ending
-if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
-if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
-:skipRcPre
-
-@setlocal
-
-set ERROR_CODE=0
-
-@REM To isolate internal variables from possible post scripts, we use another setlocal
-@setlocal
-
-@REM ==== START VALIDATION ====
-if not "%JAVA_HOME%" == "" goto OkJHome
-
-echo.
-echo Error: JAVA_HOME not found in your environment. >&2
-echo Please set the JAVA_HOME variable in your environment to match the >&2
-echo location of your Java installation. >&2
-echo.
-goto error
-
-:OkJHome
-if exist "%JAVA_HOME%\bin\java.exe" goto init
-
-echo.
-echo Error: JAVA_HOME is set to an invalid directory. >&2
-echo JAVA_HOME = "%JAVA_HOME%" >&2
-echo Please set the JAVA_HOME variable in your environment to match the >&2
-echo location of your Java installation. >&2
-echo.
-goto error
-
-@REM ==== END VALIDATION ====
-
-:init
-
-@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
-@REM Fallback to current working directory if not found.
-
-set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
-IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
-
-set EXEC_DIR=%CD%
-set WDIR=%EXEC_DIR%
-:findBaseDir
-IF EXIST "%WDIR%"\.mvn goto baseDirFound
-cd ..
-IF "%WDIR%"=="%CD%" goto baseDirNotFound
-set WDIR=%CD%
-goto findBaseDir
-
-:baseDirFound
-set MAVEN_PROJECTBASEDIR=%WDIR%
-cd "%EXEC_DIR%"
-goto endDetectBaseDir
-
-:baseDirNotFound
-set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
-cd "%EXEC_DIR%"
-
-:endDetectBaseDir
-
-IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
-
-@setlocal EnableExtensions EnableDelayedExpansion
-for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
-@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
-
-:endReadAdditionalConfig
-
-SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
-set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
-set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
-
-set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
-
-FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
-    IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
-)
-
-@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
-@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
-if exist %WRAPPER_JAR% (
-    if "%MVNW_VERBOSE%" == "true" (
-        echo Found %WRAPPER_JAR%
-    )
-) else (
-    if not "%MVNW_REPOURL%" == "" (
-        SET DOWNLOAD_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
-    )
-    if "%MVNW_VERBOSE%" == "true" (
-        echo Couldn't find %WRAPPER_JAR%, downloading it ...
-        echo Downloading from: %DOWNLOAD_URL%
-    )
-
-    powershell -Command "&{"^
-		"$webclient = new-object System.Net.WebClient;"^
-		"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
-		"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
-		"}"^
-		"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
-		"}"
-    if "%MVNW_VERBOSE%" == "true" (
-        echo Finished downloading %WRAPPER_JAR%
-    )
-)
-@REM End of extension
-
-@REM Provide a "standardized" way to retrieve the CLI args that will
-@REM work with both Windows and non-Windows executions.
-set MAVEN_CMD_LINE_ARGS=%*
-
-%MAVEN_JAVA_EXE% ^
-  %JVM_CONFIG_MAVEN_PROPS% ^
-  %MAVEN_OPTS% ^
-  %MAVEN_DEBUG_OPTS% ^
-  -classpath %WRAPPER_JAR% ^
-  "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
-  %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
-if ERRORLEVEL 1 goto error
-goto end
-
-:error
-set ERROR_CODE=1
-
-:end
-@endlocal & set ERROR_CODE=%ERROR_CODE%
-
-if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
-@REM check for post script, once with legacy .bat ending and once with .cmd ending
-if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
-if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
-:skipRcPost
-
-@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
-if "%MAVEN_BATCH_PAUSE%"=="on" pause
-
-if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
-
-cmd /C exit /B %ERROR_CODE%

sp-service/async-server/pom.xml

@@ -23,6 +23,15 @@
             <version>${project.parent.version}</version>
         </dependency>
 
+
+        <!-- rabbitmq 依赖 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
+
+
+
     </dependencies>
 
 

sp-service/async-server/src/main/java/com/pj/task/HtByteTask.java

@@ -56,9 +56,7 @@ public class HtByteTask {
         //扫描表内是否有待处理任务
         List<HtByte> byteList = htByteMapper.selectList(new LambdaQueryWrapper<HtByte>().eq(HtByte::getFinishStatus, FinishStatus.FINISH_STATUS_ZERO.getCode()));
         //判断是否有任务,没有则返回
-        if(byteList.size() == 0){
-            System.out.println("\n暂无待处理任务。\n");
-        }
+        if(byteList.size() == 0)System.out.println("\n暂无待处理任务。\n");
         //执行任务处理流程
         byteList.forEach(item -> {
             //对象转换

sp-service/async-server/src/main/resources/application.yml

@@ -1 +1,7 @@
 
+# 端口
+server:
+  port: 8068
+spring:
+  # 当前环境
+  profiles.active: dev

sp-service/async-server/src/main/resources/bootstrap.yml

@@ -1,9 +1,4 @@
-# 端口
-server:
-    port: 8068
-
-spring: 
+spring:
     # 服务名称 
-    application.name: async-serverw
-    # 当前环境
-    profiles.active: dev
+    application.name: async-server
+

sp-service/level-one-server/pom.xml

@@ -27,4 +27,5 @@
             <version>${project.parent.version}</version>
         </dependency>
     </dependencies>
+
 </project>

sp-service/level-one-server/src/main/java/com/pj/tb_enterprise/MethodEnterpriseService.java

@@ -144,7 +144,7 @@ public class MethodEnterpriseService {
             TbEnterprise tbEnterprise = new TbEnterprise();
             //解析数据
             if(row.getCell(1) != null && !row.getCell(1).toString().trim().equals(""))
-                tbEnterprise.setName(row.getCell(1).getStringCellValue());
+                tbEnterprise.setOwnerName(row.getCell(1).getStringCellValue());
 
             if(row.getCell(2) != null && !row.getCell(2).toString().trim().equals(""))
                 tbEnterprise.setNationality(row.getCell(2).getStringCellValue());
@@ -159,7 +159,7 @@ public class MethodEnterpriseService {
                 tbEnterprise.setIdCard(row.getCell(5).getStringCellValue());
 
             if(row.getCell(6) != null && !row.getCell(6).toString().trim().equals(""))
-                tbEnterprise.setContact(row.getCell(6).getStringCellValue());
+                tbEnterprise.setOwnerTel(row.getCell(6).getStringCellValue());
 
             if(row.getCell(7) != null && !row.getCell(7).toString().trim().equals(""))
                 tbEnterprise.setBusinessLicense(row.getCell(7).getStringCellValue());
@@ -175,7 +175,7 @@ public class MethodEnterpriseService {
                 tbEnterprise.setBankNo(row.getCell(10).getStringCellValue());
 
             if(row.getCell(11) != null && !row.getCell(11).toString().trim().equals(""))
-                tbEnterprise.setBankName(row.getCell(11).getStringCellValue());
+                tbEnterprise.setBank(row.getCell(11).getStringCellValue());
 
             if(row.getCell(12) != null && !row.getCell(12).toString().trim().equals(""))
                 tbEnterprise.setBankAccount(row.getCell(12).getStringCellValue());
@@ -234,7 +234,7 @@ public class MethodEnterpriseService {
                 tbEnterprise.setUpdateTime(cell3.getDateCellValue());
             }
             //删除状态,默认可用
-            tbEnterprise.setDeleteStatus(1);
+            tbEnterprise.setDeleteStatus(1L);
 //			//添加到集合
 			list.add(tbEnterprise);
 //            int insert = tbEnterpriseMapper.insert(tbEnterprise);

sp-service/level-one-server/src/main/java/com/pj/tb_enterprise/TbEnterprise.java

@@ -1,22 +1,19 @@
 package com.pj.tb_enterprise;
 
-import java.io.Serializable;
-import java.util.Date;
-
-import com.alibaba.excel.annotation.ExcelProperty;
-import com.baomidou.mybatisplus.annotation.*;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.databind.annotation.JsonSerialize;
-import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
-import lombok.EqualsAndHashCode;
-
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
 
+import java.io.Serializable;
+import java.util.Date;
+
 /**
  * Model: tb_enterprise -- 商家
- * @author qzy 
+ * @author yzs 
  */
 @Data
 @Accessors(chain = true)
@@ -39,136 +36,137 @@ public class TbEnterprise extends Model<TbEnterprise> implements Serializable {
 	public static final String PERMISSION_CODE = "tb-enterprise";
 	public static final String PERMISSION_CODE_ADD = "tb-enterprise-add";
 	public static final String PERMISSION_CODE_EDIT = "tb-enterprise-edit";
-	public static final String PERMISSION_CODE_JUDGE = "tb-enterprise-judge";
 	public static final String PERMISSION_CODE_DEL = "tb-enterprise-del";
 
 
 
+
 	// ---------- 表中字段 ----------
 	/**
 	 *  
 	 */
 	@TableId(type = IdType.AUTO)
-	@JsonSerialize(using = ToStringSerializer.class)
 	private Long id;	
 
 	/**
-	 * 名称 
+	 * 铺主姓名 
 	 */
-	private String name;
+	private String ownerName;	
 
 	/**
 	 * 国别 
 	 */
-	private String nationality;
+	private String nationality;	
 
 	/**
 	 * 商户分类(自营商铺=自营商铺,劳务商铺=劳务商铺) 
 	 */
-	private String type;
+	private String type;	
+
+	/**
+	 * 性别 
+	 */
+	private Integer sex;	
 
 	/**
 	 * 法人 
 	 */
-	private String legalPerson;
+	private String legalPerson;	
 
 	/**
 	 * 身份证号 
 	 */
-	private String idCard;
+	private String idCard;	
 
 	/**
 	 * 手机号码 
 	 */
-	private String contact;
+	private String ownerTel;	
 
 	/**
 	 * 营业执照 
 	 */
-	private String businessLicense;
+	private String businessLicense;	
 
 	/**
 	 * 所在铺位ID 
 	 */
-	private Long shopId;
+	private Long shopId;	
 
 	/**
 	 * 所在铺位名称(1=100-2) 
 	 */
-	private String shopName;
+	private String shopName;	
 
 	/**
 	 * 银行编号(CMB= 招商银行) 
 	 */
-	private String bankNo;
+	private String bankNo;	
 
 	/**
-	 *
+	 * 银行名称 
 	 */
-	private String bankName;
+	private String bank;	
 
 	/**
 	 * 银行账号 
 	 */
-	private String bankAccount;
+	private String bankAccount;	
 
 	/**
-	 * 税号 
+	 * 年龄 
 	 */
-	private String dutyParagraph;
+	private Integer age;	
 
 	/**
-	 *
+	 * 税号 
 	 */
-	private String addressIds;
+	private String dutyParagraph;	
 
 	/**
-	 *
+	 * 地址全路径如1,22,333 
 	 */
-	private String address;
-	private String detail;
+	private String addressIds;	
 
 	/**
-	 * 年龄
+	 * 地址 
 	 */
-	private Integer age;
+	private String address;	
 
 	/**
-	 * 性别[1=男,2=女]
+	 * 详细地址 
 	 */
-	private Integer sex;
+	private String detail;	
 
 	/**
 	 *  
 	 */
-	private String agreement;
+	private String agreement;	
 
 	/**
-	 *  审核状态(0=未审核,1=审核通过,2=审核驳回)
+	 * 审核状态(0=未审核,1=审核通过,2=审核驳回) 
 	 */
-	private int judgeStatus;
+	private Integer judgeStatus;
 
 	/**
-	 *  
+	 * 审核意见 
 	 */
-	private String judgeContent;
-
-	private String judgeBy;
+	private String judgeContent;	
 
 	/**
-	 *  
+	 * 审核时间 
 	 */
 	private Date judgeTime;
 
 	/**
-	 *  
+	 * 注册时间 
 	 */
 	private Date registerTime;
 
-//	/**
-//	 *
-//	 */
-//	private String personId;
+	/**
+	 * 审核人 
+	 */
+	private String judgeBy;	
 
 	/**
 	 * 创建时间 
@@ -203,13 +201,43 @@ public class TbEnterprise extends Model<TbEnterprise> implements Serializable {
 	/**
 	 * 删除状态(0=禁用,1=启用) 
 	 */
-	private Integer deleteStatus;
-
+	private Long deleteStatus;	
 
 	/**
-	 * 是否锁定
+	 * 是否锁住 
 	 */
 	private Integer isLock;
 
+	/**
+	 * 互市区ID 
+	 */
+	private Long tradeAreaId;	
+
+	/**
+	 * 互市区名称 
+	 */
+	private String tradeAreaName;	
+
+	/**
+	 * 地方平台的内部业务编号 
+	 */
+	private String platSeqNo;	
+
+	/**
+	 * 证件类型 
+	 */
+	private String ownerIdtype;	
+
+	/**
+	 * 启停用状态： 1- 启用 2-停用 3-注销 
+	 */
+	private String eDStatus;	
+
+
+
+
+
+	
+
 
 }

sp-service/level-one-server/src/main/java/com/pj/tb_enterprise/TbEnterpriseController.java

@@ -144,7 +144,7 @@ public class TbEnterpriseController {
 	* @date
 	*/
 	@RequestMapping("audit")
-	@SaCheckPermission(TbEnterprise.PERMISSION_CODE_JUDGE)
+//	@SaCheckPermission(TbEnterprise.PERMISSION_CODE_JUDGE)
 	public AjaxJson audit(){
 		SoMap soMap=SoMap.getRequestSoMap();
 		Long id=soMap.getLong("id");
@@ -153,7 +153,7 @@ public class TbEnterpriseController {
 		return AjaxJson.toAjax(tbEnterpriseService.audit(id,judgeStatus,judgeContent));
 	}
 	@RequestMapping("auditBatch")
-	@SaCheckPermission(TbEnterprise.PERMISSION_CODE_JUDGE)
+//	@SaCheckPermission(TbEnterprise.PERMISSION_CODE_JUDGE)
 	public AjaxJson auditBatch(){
 		SoMap soMap=SoMap.getRequestSoMap();
 		List<Long> ids=soMap.getListByComma("ids",Long.class);

sp-service/level-one-server/src/main/java/com/pj/tb_enterprise/TbEnterpriseMapper.xml

@@ -6,7 +6,7 @@
 
 
 	<!-- ================================== 查询相关 ================================== -->
-	<!-- select id, name, nationality, type, legal_person, id_card, contact, business_license, shop_id, shop_name, bank_no, bank_name, bank_account, duty_paragraph, address_ids, address, agreement, judge_status, judge_content, judge_time, register_time, person_id, create_time, create_by, create_name, update_time, update_by, update_name, delete_status from tb_enterprise  -->
+	<!-- select id, owner_name, nationality, type, sex, legal_person, id_card, owner_tel, business_license, shop_id, shop_name, bank_no, bank, bank_account, age, duty_paragraph, address_ids, address, detail, agreement, judge_status, judge_content, judge_time, register_time, judge_by, create_time, create_by, create_name, update_time, update_by, update_name, delete_status, is_lock, trade_area_id, trade_area_name, plat_seq_no, owner_idtype, e_d_status from tb_enterprise  -->
 	
 	<!-- 通用映射：自动模式 -->
 	<resultMap id="model" autoMapping="true" type="com.pj.tb_enterprise.TbEnterprise"></resultMap>
@@ -17,33 +17,35 @@
 		from tb_enterprise 
 	</sql>
 
-
+	
 	<!-- 查集合 - 根据条件（参数为空时代表忽略指定条件） [G] -->
 	<select id="getList" resultMap="model">
 		<include refid="select_sql"></include>
 		<where>
 			<if test=' this.has("id") '> and id = #{id} </if>
-			<if test=' this.has("name") '> and name like concat('%',#{name},'%') </if>
+			<if test=' this.has("ownerName") '> and owner_name = #{ownerName} </if>
 			<if test=' this.has("nationality") '> and nationality = #{nationality} </if>
 			<if test=' this.has("type") '> and type = #{type} </if>
+			<if test=' this.has("sex") '> and sex = #{sex} </if>
 			<if test=' this.has("legalPerson") '> and legal_person = #{legalPerson} </if>
 			<if test=' this.has("idCard") '> and id_card = #{idCard} </if>
-			<if test=' this.has("contact") '> and contact = #{contact} </if>
+			<if test=' this.has("ownerTel") '> and owner_tel = #{ownerTel} </if>
 			<if test=' this.has("shopId") '> and shop_id = #{shopId} </if>
 			<if test=' this.has("shopName") '> and shop_name = #{shopName} </if>
 			<if test=' this.has("bankNo") '> and bank_no = #{bankNo} </if>
-			<if test=' this.has("bankName") '> and bank_name = #{bankName} </if>
+			<if test=' this.has("bank") '> and bank = #{bank} </if>
 			<if test=' this.has("bankAccount") '> and bank_account = #{bankAccount} </if>
+			<if test=' this.has("age") '> and age = #{age} </if>
 			<if test=' this.has("dutyParagraph") '> and duty_paragraph = #{dutyParagraph} </if>
 			<if test=' this.has("addressIds") '> and address_ids = #{addressIds} </if>
 			<if test=' this.has("address") '> and address = #{address} </if>
+			<if test=' this.has("detail") '> and detail = #{detail} </if>
 			<if test=' this.has("agreement") '> and agreement = #{agreement} </if>
 			<if test=' this.has("judgeStatus") '> and judge_status = #{judgeStatus} </if>
-			<if test=' this.has("judgeList") '> and (judge_status = 0 or judge_status=2)</if>
 			<if test=' this.has("judgeContent") '> and judge_content = #{judgeContent} </if>
 			<if test=' this.has("judgeTime") '> and judge_time = #{judgeTime} </if>
 			<if test=' this.has("registerTime") '> and register_time = #{registerTime} </if>
-			<if test=' this.has("personId") '> and person_id = #{personId} </if>
+			<if test=' this.has("judgeBy") '> and judge_by = #{judgeBy} </if>
 			<if test=' this.has("createTime") '> and create_time = #{createTime} </if>
 			<if test=' this.has("createBy") '> and create_by = #{createBy} </if>
 			<if test=' this.has("createName") '> and create_name = #{createName} </if>
@@ -51,41 +53,56 @@
 			<if test=' this.has("updateBy") '> and update_by = #{updateBy} </if>
 			<if test=' this.has("updateName") '> and update_name = #{updateName} </if>
 			<if test=' this.has("deleteStatus") '> and delete_status = #{deleteStatus} </if>
+			<if test=' this.has("isLock") '> and is_lock = #{isLock} </if>
+			<if test=' this.has("tradeAreaId") '> and trade_area_id = #{tradeAreaId} </if>
+			<if test=' this.has("tradeAreaName") '> and trade_area_name = #{tradeAreaName} </if>
+			<if test=' this.has("platSeqNo") '> and plat_seq_no = #{platSeqNo} </if>
+			<if test=' this.has("ownerIdtype") '> and owner_idtype = #{ownerIdtype} </if>
+			<if test=' this.has("eDStatus") '> and e_d_status = #{eDStatus} </if>
 		</where>
 		order by
 		<choose>
 			<when test='sortType == 1'> id desc </when>
-			<when test='sortType == 2'> name desc </when>
+			<when test='sortType == 2'> owner_name desc </when>
 			<when test='sortType == 3'> nationality desc </when>
 			<when test='sortType == 4'> type desc </when>
-			<when test='sortType == 5'> legal_person desc </when>
-			<when test='sortType == 6'> id_card desc </when>
-			<when test='sortType == 7'> contact desc </when>
-			<when test='sortType == 8'> shop_id desc </when>
-			<when test='sortType == 9'> shop_name desc </when>
-			<when test='sortType == 10'> bank_no desc </when>
-			<when test='sortType == 11'> bank_name desc </when>
-			<when test='sortType == 12'> bank_account desc </when>
-			<when test='sortType == 13'> duty_paragraph desc </when>
-			<when test='sortType == 14'> address_ids desc </when>
-			<when test='sortType == 15'> address desc </when>
-			<when test='sortType == 16'> agreement desc </when>
-			<when test='sortType == 17'> judge_status desc </when>
-			<when test='sortType == 18'> judge_content desc </when>
-			<when test='sortType == 19'> judge_time desc </when>
-			<when test='sortType == 20'> register_time desc </when>
-			<when test='sortType == 21'> person_id desc </when>
-			<when test='sortType == 22'> create_time desc </when>
-			<when test='sortType == 23'> create_by desc </when>
-			<when test='sortType == 24'> create_name desc </when>
-			<when test='sortType == 25'> update_time desc </when>
-			<when test='sortType == 26'> update_by desc </when>
-			<when test='sortType == 27'> update_name desc </when>
-			<when test='sortType == 28'> delete_status desc </when>
+			<when test='sortType == 5'> sex desc </when>
+			<when test='sortType == 6'> legal_person desc </when>
+			<when test='sortType == 7'> id_card desc </when>
+			<when test='sortType == 8'> owner_tel desc </when>
+			<when test='sortType == 9'> shop_id desc </when>
+			<when test='sortType == 10'> shop_name desc </when>
+			<when test='sortType == 11'> bank_no desc </when>
+			<when test='sortType == 12'> bank desc </when>
+			<when test='sortType == 13'> bank_account desc </when>
+			<when test='sortType == 14'> age desc </when>
+			<when test='sortType == 15'> duty_paragraph desc </when>
+			<when test='sortType == 16'> address_ids desc </when>
+			<when test='sortType == 17'> address desc </when>
+			<when test='sortType == 18'> detail desc </when>
+			<when test='sortType == 19'> agreement desc </when>
+			<when test='sortType == 20'> judge_status desc </when>
+			<when test='sortType == 21'> judge_content desc </when>
+			<when test='sortType == 22'> judge_time desc </when>
+			<when test='sortType == 23'> register_time desc </when>
+			<when test='sortType == 24'> judge_by desc </when>
+			<when test='sortType == 25'> create_time desc </when>
+			<when test='sortType == 26'> create_by desc </when>
+			<when test='sortType == 27'> create_name desc </when>
+			<when test='sortType == 28'> update_time desc </when>
+			<when test='sortType == 29'> update_by desc </when>
+			<when test='sortType == 30'> update_name desc </when>
+			<when test='sortType == 31'> delete_status desc </when>
+			<when test='sortType == 32'> is_lock desc </when>
+			<when test='sortType == 33'> trade_area_id desc </when>
+			<when test='sortType == 34'> trade_area_name desc </when>
+			<when test='sortType == 35'> plat_seq_no desc </when>
+			<when test='sortType == 36'> owner_idtype desc </when>
+			<when test='sortType == 37'> e_d_status desc </when>
 			<otherwise> id desc </otherwise>
 		</choose>
 	</select>
-
+	
 	
 	
 	

sp-service/level-one-server/src/main/java/com/pj/tb_enterprise/TbEnterpriseService.java

@@ -4,7 +4,6 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.pj.api.client.admin.AdminInterface;
-import com.pj.api.client.level_one_server.LevelOneServerInterface;
 import com.pj.api.consts.FeignFactory;
 import com.pj.api.dto.DistrictDTO;
 import com.pj.api.dto.EnterpriseAuditDto;
@@ -147,10 +146,10 @@ public class TbEnterpriseService extends ServiceImpl<TbEnterpriseMapper, TbEnter
     boolean identification(EnterpriseDto dto) {
         TbEnterprise enterprise = tbEnterpriseMapper.selectByCreateBy("" + StpAPPUserUtil.getAPPLoginInfo().getLoginId());
         dto.setJudgeStatus(0);
-        String contact = enterprise != null ? enterprise.getContact() : "";
+        String contact = enterprise != null ? enterprise.getOwnerTel() : "";
         String idCard = enterprise != null ? enterprise.getIdCard() : "";
         //手机号查重
-        if (!contact.equals(dto.getContact()) && tbEnterpriseMapper.selectList(new LambdaQueryWrapper<TbEnterprise>().eq(TbEnterprise::getContact, dto.getContact()).eq(TbEnterprise::getDeleteStatus, DeleteStatus.DELETE_STATUS_ON.getCode())).size() != 0) {
+        if (!contact.equals(dto.getContact()) && tbEnterpriseMapper.selectList(new LambdaQueryWrapper<TbEnterprise>().eq(TbEnterprise::getOwnerTel, dto.getContact()).eq(TbEnterprise::getDeleteStatus, DeleteStatus.DELETE_STATUS_ON.getCode())).size() != 0) {
             throw new RuntimeException("当前手机号已被认证!");
         }
         //身份证号查重
@@ -162,7 +161,7 @@ public class TbEnterpriseService extends ServiceImpl<TbEnterpriseMapper, TbEnter
             BeanUtils.copyProperties(dto, enterprise);
             enterprise.setCreateTime(new Date());
             enterprise.setCreateBy("" + StpAPPUserUtil.getAPPLoginInfo().getLoginId());
-            enterprise.setDeleteStatus(DeleteStatus.DELETE_STATUS_ON.getCode());
+            enterprise.setDeleteStatus(Long.valueOf(DeleteStatus.DELETE_STATUS_ON.getCode()));
             return save(enterprise);
         }
         dto.setId(enterprise.getId());
@@ -239,7 +238,7 @@ public class TbEnterpriseService extends ServiceImpl<TbEnterpriseMapper, TbEnter
         }
         filepath = filepath + "\\商家数据表_" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")) + ".xlsx";
         //根据需求查询数据
-        List<TbEnterprise> selectedList = tbEnterpriseMapper.selectList(new LambdaQueryWrapper<TbEnterprise>().eq(StringUtils.isNoneBlank(keyword), TbEnterprise::getName, keyword));
+        List<TbEnterprise> selectedList = tbEnterpriseMapper.selectList(new LambdaQueryWrapper<TbEnterprise>().eq(StringUtils.isNoneBlank(keyword), TbEnterprise::getOwnerName, keyword));
         if (selectedList.size() == 0) return "没有可导出的数据。";
         //建立excel对象封装数据
         HSSFWorkbook workbook = new HSSFWorkbook();
@@ -283,17 +282,17 @@ public class TbEnterpriseService extends ServiceImpl<TbEnterpriseMapper, TbEnter
         for (int i = 0; i < selectedList.size(); i++) {
             HSSFRow sheetRow = sheet.createRow(sheet.getLastRowNum() + 1);
             sheetRow.createCell(0).setCellValue(i + 1);
-            sheetRow.createCell(1).setCellValue((selectedList.get(i).getName() + "").equals("null") ? "" : selectedList.get(i).getName() + "");
+            sheetRow.createCell(1).setCellValue((selectedList.get(i).getOwnerName() + "").equals("null") ? "" : selectedList.get(i).getOwnerName() + "");
             sheetRow.createCell(2).setCellValue((selectedList.get(i).getNationality() + "").equals("null") ? "" : selectedList.get(i).getNationality() + "");
             sheetRow.createCell(3).setCellValue((selectedList.get(i).getType() + "").equals("null") ? "" : selectedList.get(i).getType() + "");
             sheetRow.createCell(4).setCellValue((selectedList.get(i).getLegalPerson() + "").equals("null") ? "" : selectedList.get(i).getLegalPerson() + "");
             sheetRow.createCell(5).setCellValue((selectedList.get(i).getIdCard() + "").equals("null") ? "" : selectedList.get(i).getIdCard() + "");
-            sheetRow.createCell(6).setCellValue((selectedList.get(i).getContact() + "").equals("null") ? "" : selectedList.get(i).getContact() + "");
+            sheetRow.createCell(6).setCellValue((selectedList.get(i).getOwnerTel() + "").equals("null") ? "" : selectedList.get(i).getOwnerTel() + "");
             sheetRow.createCell(7).setCellValue((selectedList.get(i).getBusinessLicense() + "").equals("null") ? "" : selectedList.get(i).getBusinessLicense() + "");
             sheetRow.createCell(8).setCellValue((selectedList.get(i).getShopId() + "").equals("null") ? "" : selectedList.get(i).getShopId() + "");
             sheetRow.createCell(9).setCellValue((selectedList.get(i).getShopName() + "").equals("null") ? "" : selectedList.get(i).getShopName() + "");
             sheetRow.createCell(10).setCellValue((selectedList.get(i).getBankNo() + "").equals("null") ? "" : selectedList.get(i).getBankNo() + "");
-            sheetRow.createCell(11).setCellValue((selectedList.get(i).getBankName() + "").equals("null") ? "" : selectedList.get(i).getBankName() + "");
+            sheetRow.createCell(11).setCellValue((selectedList.get(i).getBank() + "").equals("null") ? "" : selectedList.get(i).getBank() + "");
             sheetRow.createCell(12).setCellValue((selectedList.get(i).getBankAccount() + "").equals("null") ? "" : selectedList.get(i).getBankAccount() + "");
             sheetRow.createCell(13).setCellValue((selectedList.get(i).getDutyParagraph() + "").equals("null") ? "" : selectedList.get(i).getDutyParagraph() + "");
             sheetRow.createCell(14).setCellValue((selectedList.get(i).getAddressIds() + "").equals("null") ? "" : selectedList.get(i).getAddressIds() + "");

sp-service/level-one-server/src/main/java/com/pj/tb_order/MethodOrderService.java

@@ -108,7 +108,7 @@ public class MethodOrderService {
         //获取商家手机号
         TbEnterprise enterprise = tbEnterpriseMapper.selectById(tbOrder.getEnterpriseId());
         if(enterprise == null)throw new ServiceException("商家信息异常!");
-        orderVo.setConcat(enterprise.getContact());
+        orderVo.setConcat(enterprise.getOwnerTel());
         //获取过审商品名称 计价单位 净重 毛重 商品发布时间
         TbGoodsTransit goodsTransit = tbGoodsTransitMapper.selectById(tbOrder.getGoodsId());
         if(goodsTransit == null)

sp-service/level-one-server/src/main/java/com/pj/tb_order/TbOrderService.java

@@ -151,7 +151,7 @@ public class TbOrderService extends ServiceImpl<TbOrderMapper, TbOrder> implemen
 		if(tbOrder.getCallCarStatus() == 1 || tbOrder.getCallCarStatus() == 2){
 			TbEnterprise enterprise = tbEnterpriseMapper.selectById(appLoginInfo.getFk());
 			String phone = null;
-			if(enterprise != null)phone = enterprise.getContact();
+			if(enterprise != null)phone = enterprise.getOwnerTel();
 			throw new ServiceException("您的订单单号为[ " + tbOrder.getTradeNo() + " ]商户已叫车,无法进行取消,请联系商户电话[ " + phone + " ]进行取消。");
 		}
 		//将状态设置已取消

sp-service/level-one-server/src/main/java/com/pj/tb_people/TbPeopleController.java

@@ -261,7 +261,7 @@ public class TbPeopleController {
      * 注册身份时对应的表添加数据
      */
     @RequestMapping("rpc/peopleDto")
-    public boolean peopleDto(@RequestBody PeopleDto peopleDto) {
+    public boolean peopleDto(@RequestBody PeopleDto peopleDto) throws Exception {
         boolean dto = tbPeopleService.peopleDto(peopleDto);
         return dto;
     }

sp-service/level-one-server/src/main/java/com/pj/tb_people/TbPeopleService.java

@@ -13,7 +13,6 @@ import com.pj.common.core.exception.ServiceException;
 import com.pj.current.dto.PCLoginUserInfo;
 import com.pj.current.satoken.StpUserUtil;
 import com.pj.enummj.*;
-import com.pj.rabbitmq.RabbitMQ;
 import com.pj.tb_group.TbGroup;
 import com.pj.tb_group.TbGroupMapper;
 import com.pj.tb_order.TbOrder;
@@ -29,7 +28,6 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.hssf.usermodel.HSSFRow;
 import org.apache.poi.hssf.usermodel.HSSFSheet;
 import org.apache.poi.hssf.usermodel.HSSFWorkbook;
-import org.springframework.amqp.core.AmqpTemplate;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -70,11 +68,6 @@ public class TbPeopleService extends ServiceImpl<TbPeopleMapper, TbPeople> imple
 	@Autowired
 	TbGroupMapper tbGroupMapper;
 
-	/**
-	 * mq
-	 */
-	@Autowired
-	private AmqpTemplate amqpTemplate;
 
 	/** 增 */
 	void add(TbPeople t){
@@ -528,7 +521,7 @@ public class TbPeopleService extends ServiceImpl<TbPeopleMapper, TbPeople> imple
 	}
 
 	/** 远程调用方法 边民信息事务处理 */
-	public boolean peopleDto(PeopleDto peopleDto){
+	public boolean peopleDto(PeopleDto peopleDto) throws Exception {
 		//创建对象
 		TbPeople tbPeople = new TbPeople();
 		//数据拷贝
@@ -540,7 +533,15 @@ public class TbPeopleService extends ServiceImpl<TbPeopleMapper, TbPeople> imple
 		if(peopleList.size() == 0){
 			//新增
 			boolean save = this.save(tbPeople);
-			return save;
+			if(save){
+				//给边民生成账号
+				List<TbPeople> tbPeopleList = tbPeopleMapper.selectList(new LambdaQueryWrapper<TbPeople>().eq(TbPeople::getBorderTel, tbPeople.getBorderTel()).eq(TbPeople::getDeleteStatus, DeleteStatus.DELETE_STATUS_ON.getCode()));
+				peopleDto.setId(tbPeopleList.get(0).getId());
+				Boolean aBoolean = adminInterface.generatePeopleAccount(peopleDto);
+				if(!aBoolean)
+					throw new RuntimeException("\n边民生成账号时错误。 id = " + tbPeopleList.get(0).getId() + "\n");
+				return aBoolean;
+			}
 		}
 		//修改
 		BeanUtils.copyProperties(peopleList.get(0),tbPeople);

sp-service/level-one-server/src/main/java/com/pj/tb_shop/TbShopController.java

@@ -131,7 +131,7 @@ public class TbShopController {
 	/*------            正常业务👆👆    rpc远程调用👇👇                         -----------*/
 
 	@RequestMapping("rpc/shopDto")
-	public boolean shopDto(@RequestBody ShopDto shopDto){
+	public boolean shopDto(@RequestBody ShopDto shopDto) throws Exception {
 		boolean b = tbShopService.shopDto(shopDto);
 		return b;
 	}

sp-service/level-one-server/src/main/java/com/pj/tb_shop/TbShopService.java

@@ -8,8 +8,15 @@ import java.util.Date;
 import java.util.List;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.pj.api.client.admin.AdminInterface;
+import com.pj.api.dto.EnterpriseDto;
 import com.pj.api.dto.ShopDto;
+import com.pj.common.core.exception.ServiceException;
 import com.pj.enummj.DeleteStatus;
+import com.pj.enummj.JudgeStatus;
+import com.pj.project4sp.SP;
+import com.pj.tb_enterprise.TbEnterprise;
+import com.pj.tb_enterprise.TbEnterpriseMapper;
 import com.pj.utils.so.SoMap;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.hssf.usermodel.HSSFRow;
@@ -20,6 +27,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -40,6 +48,12 @@ public class TbShopService extends ServiceImpl<TbShopMapper, TbShop> implements
 	@Autowired
 	private MethodShopService methodShopService;
 
+	@Autowired
+	private TbEnterpriseMapper tbEnterpriseMapper;
+
+	@Autowired
+	private AdminInterface adminInterface;
+
 	/** 增 */
 	void add(TbShop t){
 		save(t);
@@ -177,17 +191,55 @@ public class TbShopService extends ServiceImpl<TbShopMapper, TbShop> implements
 	}
 
 	/** 远程调用方法 */
-	public boolean shopDto(ShopDto shopDto){
+	@Transactional(propagation = Propagation.REQUIRES_NEW)
+	public boolean shopDto(ShopDto shopDto) throws Exception {
 		TbShop tbShop = new TbShop();
 		BeanUtils.copyProperties(shopDto,tbShop);
 		//根据编号进行事务处理
 		List<TbShop> tbShopList = tbShopMapper.selectList(new LambdaQueryWrapper<TbShop>().eq(TbShop::getPlatSeqNo, shopDto.getPlatSeqNo()));
 		if(tbShopList.size() == 0){
-			//无则新增
+			//去重
+			List<TbShop> tbShops = tbShopMapper.selectList(new LambdaQueryWrapper<TbShop>().eq(TbShop::getPlatSeqNo, shopDto.getPlatSeqNo()));
+			if(tbShops.size() != 0)throw new ServiceException("\n该店铺已存在。platSeqNo = " + shopDto.getPlatSeqNo() + "\n");
+			//无则新增商铺
 			tbShop.setDeleteStatus(DeleteStatus.DELETE_STATUS_ON.getCode());
 			tbShop.setCreateTime(new Date());
 			int insert = tbShopMapper.insert(tbShop);
-			return insert == 1;
+			long primarykey = SP.publicMapper.getPrimarykey();
+			//新增外籍商户
+			if(insert == 1){
+				//去重
+				List<TbEnterprise> tbEnterpriseList = tbEnterpriseMapper.selectList(new LambdaQueryWrapper<TbEnterprise>().eq(TbEnterprise::getPlatSeqNo, shopDto.getPlatSeqNo()));
+				if(tbEnterpriseList.size() != 0)throw new ServiceException("\n该外籍商户信息已存在。 platSeqNo = " + shopDto.getPlatSeqNo() + "\n");
+				TbEnterprise enterprise = new TbEnterprise();
+				BeanUtils.copyProperties(tbShop,enterprise);
+				//设置基本属性
+				enterprise.setOwnerName(shopDto.getOwnerName());
+				enterprise.setDeleteStatus(Long.valueOf(DeleteStatus.DELETE_STATUS_ON.getCode()));
+				enterprise.setJudgeStatus(JudgeStatus.JUDGE_STATUS_ONE.getCode());
+				enterprise.setJudgeTime(new Date());
+				enterprise.setShopId(primarykey);
+				enterprise.setShopName(shopDto.getShopName());
+				enterprise.setBankAccount(shopDto.getBankAccount());
+				enterprise.setBank(shopDto.getBank());
+				enterprise.setAddress(shopDto.getAddress());
+				enterprise.setType(null);
+				//保存
+				int insert1 = tbEnterpriseMapper.insert(enterprise);
+				if(insert1 == 1){
+					//创建商家保存对象
+					EnterpriseDto enterpriseDto = new EnterpriseDto();
+					//查询数据库内的商家
+					List<TbEnterprise> tbEnterprises = tbEnterpriseMapper.selectList(new LambdaQueryWrapper<TbEnterprise>().eq(TbEnterprise::getPlatSeqNo, enterprise.getPlatSeqNo()));
+					//将数据拷贝至enterpriseDto
+					BeanUtils.copyProperties(tbEnterprises.get(0),enterpriseDto);
+					//远程调用生成商家账户方法
+					int i = adminInterface.generateEnterpriseAccount(enterpriseDto);
+					if(i != 1)
+						throw new RuntimeException("\n添加商铺时,保存店铺内的外籍商户信息错误。 id = " + tbEnterprises.get(0).getId() + "\n");
+					return true;
+				}
+			}
 		}
 		//修改
 		BeanUtils.copyProperties(tbShopList.get(0),tbShop);

sp-service/level-two-server/.mvn/wrapper/maven-wrapper.properties

@@ -1,18 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-#   https://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied.  See the License for the
-# specific language governing permissions and limitations
-# under the License.
-distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.7/apache-maven-3.8.7-bin.zip
-wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar

sp-service/level-two-server/src/main/java/com/pj/tb_fee_item_record/TbFeeItemRecord.java

@@ -9,7 +9,7 @@ import lombok.Data;
 import lombok.experimental.Accessors;
 
 /**
- * Model: tb_fee_item_record -- 费项订单
+ * Model: tb_fee_item_record -- 收费记录
  * @author yzs 
  */
 @Data
@@ -30,7 +30,7 @@ public class TbFeeItemRecord extends Model<TbFeeItemRecord> implements Serializa
 	/**
 	 * 此模块对应的权限码 
 	 */
-	public static final String PERMISSION_CODE = "tb-fee-item-record-list";
+	public static final String PERMISSION_CODE = "tb-fee-item-record";
 	public static final String PERMISSION_CODE_ADD = "tb-fee-item-record-add";
 	public static final String PERMISSION_CODE_EDIT = "tb-fee-item-record-edit";
 	public static final String PERMISSION_CODE_DEL = "tb-fee-item-record-del";

sp-service/level-two-server/src/main/java/com/pj/tb_fee_item_record/TbFeeItemRecordController.java

@@ -14,7 +14,7 @@ import cn.dev33.satoken.annotation.SaCheckPermission;
 
 
 /**
- * Controller: tb_fee_item_record -- 费项订单
+ * Controller: tb_fee_item_record -- 收费记录
  * @author yzs 
  */
 @RestController

sp-service/level-two-server/src/main/java/com/pj/tb_fee_item_record/TbFeeItemRecordMapper.java

@@ -9,7 +9,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.springframework.stereotype.Repository;
 
 /**
- * Mapper: tb_fee_item_record -- 费项订单
+ * Mapper: tb_fee_item_record -- 收费记录
  * @author yzs 
  */
 

sp-service/level-two-server/src/main/java/com/pj/tb_fee_item_record/TbFeeItemRecordService.java

@@ -10,7 +10,7 @@ import org.springframework.transaction.annotation.Transactional;
 import com.pj.utils.sg.*;
 
 /**
- * Service: tb_fee_item_record -- 费项订单
+ * Service: tb_fee_item_record -- 收费记录
  * @author yzs 
  */
 @Service

sp-service/level-two-server/src/main/java/com/pj/tb_people_profit_record/TbPeopleProfitRecord.java

@@ -30,7 +30,7 @@ public class TbPeopleProfitRecord extends Model<TbPeopleProfitRecord> implements
 	/**
 	 * 此模块对应的权限码 
 	 */
-	public static final String PERMISSION_CODE = "tb-people-profit-record-list";
+	public static final String PERMISSION_CODE = "tb-people-profit-record";
 	public static final String PERMISSION_CODE_ADD = "tb-people-profit-record-add";
 	public static final String PERMISSION_CODE_EDIT = "tb-people-profit-record-edit";
 	public static final String PERMISSION_CODE_DEL = "tb-people-profit-record-del";

sp-service/level-two-server/src/main/resources/application.yml

@@ -0,0 +1,8 @@
+# 端口
+server:
+    port: 8012
+
+spring:
+    # 当前环境
+    profiles.active: dev
+    

sp-service/level-two-server/src/main/resources/bootstrap.yml

@@ -1,5 +1,3 @@
 spring:
   # ????
   application.name: level-two-server
-  # ????
-  profiles.active: dev

sp-service/pom.xml

@@ -23,23 +23,24 @@
 
 	<!-- 构建配置 -->
     <build>
+        <finalName>${project.name}</finalName>
         <plugins>
             <!-- 打包jar文件时，可配置manifest文件，加入lib包的jar依赖 -->
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-jar-plugin</artifactId>
-<!--                <configuration>-->
-<!--                    <source>${java.version}</source>-->
-<!--                    <target>${java.version}</target>-->
-<!--                    <encoding>${project.build.sourceEncoding}</encoding>-->
-<!--                    <archive>-->
-<!--                        <manifest>-->
-<!--                            <addClasspath>true</addClasspath>-->
-<!--                            <classpathPrefix>lib/</classpathPrefix>-->
-<!--                           	<mainClass>${java.run.main.class}</mainClass>-->
-<!--                        </manifest>-->
-<!--                    </archive>-->
-<!--                </configuration>-->
+                <configuration>
+                    <source>${java.version}</source>
+                    <target>${java.version}</target>
+                    <encoding>${project.build.sourceEncoding}</encoding>
+                    <archive>
+                        <manifest>
+                            <addClasspath>true</addClasspath>
+                            <classpathPrefix>lib/</classpathPrefix>
+                           	<mainClass>${java.run.main.class}</mainClass>
+                        </manifest>
+                    </archive>
+                </configuration>
             </plugin>
             <!-- 拷贝依赖的jar包到lib目录 -->
             <plugin>

sp-service/sp-admin/src/main/java/com/pj/project/app_user/AppUserController.java

@@ -5,6 +5,8 @@ import java.util.List;
 import com.pj.api.dto.AppUserDto;
 
 import com.pj.api.dto.EnterpriseAuditDto;
+import com.pj.api.dto.EnterpriseDto;
+import com.pj.api.dto.PeopleDto;
 import com.pj.utils.so.SoMap;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -127,4 +129,25 @@ public class AppUserController {
 		return info;
 	}
 
+
+	/**
+	 * 同步航通边民信息时,自动给边民注册app账号
+	 */
+	@RequestMapping("rpc/generatePeopleAccount")
+	public boolean generatePeopleAccount(@RequestBody PeopleDto peopleDto) throws Exception {
+		boolean info = appUserService.generatePeopleAccount(peopleDto);
+		return info;
+	}
+
+
+	/**
+	 * 同步航通边民信息时,自动给外籍商户注册app账号
+	 */
+	@RequestMapping("rpc/generateEnterpriseAccount")
+	public int generateEnterpriseAccount(@RequestBody EnterpriseDto enterpriseDto) throws Exception {
+		int account = appUserService.generateEnterpriseAccount(enterpriseDto);
+		return account;
+	}
+
+
 }

sp-service/sp-admin/src/main/java/com/pj/project/app_user/AppUserService.java

@@ -1,5 +1,6 @@
 package com.pj.project.app_user;
 
+import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.List;
 import java.util.Random;
@@ -444,4 +445,76 @@ public class AppUserService extends ServiceImpl<AppUserMapper, AppUser> implemen
 		return update == 1;
 	}
 
+	/** 远程调用: 当从航通导入数据时,自动给边民生成账号 */
+	public boolean generatePeopleAccount(PeopleDto peopleDto) throws Exception {
+		//检查是否重复注册
+		List<AppUser> appUsers = appUserMapper.selectList(new LambdaQueryWrapper<AppUser>().eq(AppUser::getPhone, peopleDto.getBorderTel()));
+		if(appUsers.size() != 0)throw new ServiceException("\n该用户已注册! phone = " + peopleDto.getBorderTel() + "\n");
+		//创建保存对象
+		AppUser appUser = new AppUser();
+		//设置基本属性
+		appUser.setAuth(1 + ""); // 默认已认证
+		appUser.setUserType(1); // 用户类型 1
+		appUser.setCreateTime(new Date()); // 创建时间
+		appUser.setPhone(peopleDto.getBorderTel()); // 电话
+		appUser.setStatus("1"); // 可用状态
+		appUser.setDeleteStatus(DeleteStatus.DELETE_STATUS_ON.getCode()); // 默认可用
+		appUser.setAuthTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); // 认证时间
+		appUser.setName(peopleDto.getBorderName()); // 昵称
+		appUser.setFkId(peopleDto.getId()); // 外键
+		//随机生成6位数密码
+		int password = (int) (Math.random() * (999999 - 100000 + 1) + 100000);
+		//密码加密
+		String encodePassword = passwordEncoder.encode(password + "");
+		//设置密码
+		appUser.setPassword(encodePassword);
+		//保存
+		int insert = appUserMapper.insert(appUser);
+		//发送短信
+		if(insert == 1){
+			//todo: 届时放开注释
+//			boolean msg = smsRetryService.sendSmsRegisteMsg(null, "您好,您已成功注册[边民互市]app账号。账号:" + peopleDto.getBorderTel() + ", 初始密码:" + password + "。可前往app进行修改");
+//			return msg;
+			System.out.println("注册成功! 账户 = " + peopleDto.getBorderTel() + " password = " + password);
+			return true;
+		}
+		throw new RuntimeException("同步航通信息时,边民注册app信息失败,边民手机号为: " + peopleDto.getBorderTel() + "。 时间: " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
+	}
+
+	/** 远程调用: 当从航通导入数据时,自动给外籍商户生成账号 */
+	public int generateEnterpriseAccount(EnterpriseDto enterpriseDto) throws Exception {
+		//判断是否已被注册
+		List<AppUser> appUsers = appUserMapper.selectList(new LambdaQueryWrapper<AppUser>().eq(AppUser::getPhone, enterpriseDto.getOwnerTel()));
+		if(appUsers.size() != 0)throw new ServiceException("\n该用户已注册! phone = " + enterpriseDto.getOwnerTel() + "\n");
+		//创建保存对象
+		AppUser appUser = new AppUser();
+		//设置基本属性
+		appUser.setAuth(1 + ""); // 默认已认证
+		appUser.setUserType(5); // 用户类型 1
+		appUser.setCreateTime(new Date()); // 创建时间
+		appUser.setPhone(enterpriseDto.getOwnerTel()); // 电话
+		appUser.setStatus("1"); // 可用状态
+		appUser.setDeleteStatus(DeleteStatus.DELETE_STATUS_ON.getCode()); // 默认可用
+		appUser.setAuthTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); // 认证时间
+		appUser.setName(enterpriseDto.getOwnerName()); // 昵称
+		appUser.setFkId(enterpriseDto.getId()); // 外键
+		//随机生成6位数密码
+		int password = (int) (Math.random() * (999999 - 100000 + 1) + 100000);
+		//密码加密
+		String encodePassword = passwordEncoder.encode(password + "");
+		//设置密码
+		appUser.setPassword(encodePassword);
+		//保存
+		int insert = appUserMapper.insert(appUser);
+		//发送短信
+		if(insert == 1){
+			//todo: 届时放开注释
+//			boolean msg = smsRetryService.sendSmsRegisteMsg(null, "您好,您已成功注册[边民互市]app账号。账号:" + peopleDto.getBorderTel() + ", 初始密码:" + password + "。可前往app进行修改");
+//			return msg;
+			System.out.println("\n注册成功! 账户 = " + enterpriseDto.getOwnerTel() + " password = " + password + "\n");
+			return 1;
+		}
+		throw new RuntimeException("同步航通信息时,边民注册app信息失败,边民手机号为: " + enterpriseDto.getOwnerTel() + "。 时间: " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
+	}
+
 }

sp-service/sp-admin/src/main/resources/application.yml

@@ -0,0 +1,8 @@
+# 端口
+server:
+    port: 8011
+
+spring: 
+    # 当前环境
+    profiles.active: debug
+

sp-service/sp-admin/src/main/resources/bootstrap.yml

@@ -1,10 +1,4 @@
-# 端口
-server:
-    port: 8011
-
-spring: 
-    # 服务名称 
+spring:
+    # 服务名称
     application.name: sp-admin
-    # 当前环境
-    profiles.active: dev
 

sp-service/transport-server/.mvn/wrapper/maven-wrapper.properties

@@ -1,18 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-#   https://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied.  See the License for the
-# specific language governing permissions and limitations
-# under the License.
-distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.7/apache-maven-3.8.7-bin.zip
-wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar

sp-service/transport-server/src/main/java/com/pj/project/tb_vehicle/MethodVehicleService.java

@@ -68,7 +68,7 @@ public class MethodVehicleService {
         carRecord.setGoodsWeight(goodsTransitById.getGrossWeight()); // 过审商品毛重
         carRecord.setShopName(goodsTransitById.getShopName());  // 一级市场商铺名称
         carRecord.setEnterpriseName(goodsTransitById.getMerchantName()); // 一级市场商户名称
-        carRecord.setEnterprisePhone(enterpriseById.getContact()); // 一级市场商户电话
+        carRecord.setEnterprisePhone(enterpriseById.getOwnerTel()); // 一级市场商户电话
         //司机处理[0=待处理,1=同意,2=拒绝]
         carRecord.setDriverResult(0); // 默认待处理
         //公共字段属性赋值