期初导入程序实现

src/main/java/com/th/demo/controller/ware/InController.java

         }
     }
 
+    @RequestMapping(value = "/inImportAll.do", method = RequestMethod.POST)
+    public String inImportAll(String json,
+                           HttpServletRequest request) {
+
+        try {
+            String userId = (String) request.getAttribute("userId");
+            String belongId = (String) request.getAttribute("belongId");
+            result = inService.inImportAll(json,userId,belongId);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            result = JSONTools.toString(ResponseCodeMsg.CODE_EX, ex.getMessage());
+        } finally {
+            return result;
+        }
+    }
+
 }

src/main/java/com/th/demo/mapping/ware/DistributionMapper.java

     List<Distribution> selectWaitTrucks(String userId, String belongId);
 
     Distribution selectByTruckNo(String truckNo, String belongId);
+
+    Distribution selectByDisNo(String distributionNo, String belongId);
 }

src/main/java/com/th/demo/service/impl/ware/InServiceImpl.java

 import com.auth0.jwt.internal.org.bouncycastle.jce.exception.ExtCertificateEncodingException;
 import com.th.demo.mapping.maint.*;
 import com.th.demo.mapping.system.SysUserMapper;
-import com.th.demo.mapping.ware.InRecordMapper;
-import com.th.demo.mapping.ware.StoreMapper;
+import com.th.demo.mapping.ware.*;
+import com.th.demo.model.finance.AccountDetail;
 import com.th.demo.model.maint.*;
 import com.th.demo.model.system.ResponseCodeMsg;
 import com.th.demo.model.system.SysUser;
 import com.th.demo.model.system.Type;
-import com.th.demo.model.ware.InRecord;
-import com.th.demo.model.ware.OutRecord;
-import com.th.demo.model.ware.Store;
+import com.th.demo.model.ware.*;
 import com.th.demo.service.ware.InService;
+import com.th.demo.service.ware.OutService;
 import com.th.demo.service.ware.StoreService;
 import com.th.demo.tools.JSONTools;
 import com.th.demo.tools.Tools;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.Date;
     public PriceMapper priceMapper;
     @Autowired
     public OrdTractMapper ordTractMapper;
+    @Autowired
+    public OutRecordMapper outRecordMapper;
+    @Autowired
+    public DistributionMapper distributionMapper;
+    @Autowired
+    public DistributionDetailMapper distributionDetailMapper;
     String result = Type.FAIL;
     int num = 0;
 
     public String inImport(String json, String userId, String belongId) throws Exception {
         long startTime = System.currentTimeMillis();
 
-        List<JSONObject> listJO = JSON.parseObject(json, new TypeReference<List<JSONObject>>() {
-        });
+        List<JSONObject> listJO = JSON.parseObject(json, new TypeReference<List<JSONObject>>() { });
 
         List<Store> listStore = objToStore(listJO, userId, belongId);
         List storeArray = new ArrayList();
         return result;
     }
 
+    @Override
+    public String inImportAll(String json, String userId, String belongId) throws ParseException {
+        List<JSONObject> listJO = JSON.parseObject(json, new TypeReference<List<JSONObject>>() { });
+        Store store = new Store();
+        Distribution distribution = new Distribution();
+        String err = Type.SUCCESS;
+        DateFormat df2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        for (int i = 0; i < listJO.size(); i++){
+            String wareName = listJO.get(i).get("仓库名称").toString();
+            String stackName = listJO.get(i).get("垛位号").toString();
+            String materialName = listJO.get(i).get("品名").toString();
+            String standard = listJO.get(i).get("钢种").toString();
+            String customerName = listJO.get(i).get("客户名称").toString();
+            String fk_compony_name = listJO.get(i).get("货权单位").toString();
+            //验证信息增加多条信息验证
+            Ware ware = wareMapper.selectByWareName(wareName, userId, belongId);
+            if (ware == null) {
+                err += "未找到名为\"" + wareName + "\"的库房；";
+            }
+            Stack stack = stackMapper.selectByWareNameStackName(wareName, stackName, userId, belongId);
+            if (stack == null) {
+                err += "未找到名为\"" + stackName + "\"的垛位号；";
+            }
+            // 将传入的材料品名和钢种进行校验
+            Material material = new Material();
+            List<Material> materialList = materialMapper.selectListByNameStandard(materialName, standard, belongId);
+            if (materialList.size() == 0 ){
+                err += "未找到名为\"" + materialName + "，" + standard + "\"的物料类型；";
+            } else if (materialList.size() > 1) {
+                err += "名为\"" + materialName + "，" + standard + "\"的物料类型维护多条；";
+            }else {
+                material= materialList.get(0);
+            }
+
+            // 将传入的客户名称进行校验
+            Customer customer = new Customer();
+            List<Customer> customerList = customerMapper.selectByNameCode(customerName,customerName,belongId);
+            if (customerList.size() == 0){
+                err += "未找到全名或简称为\"" + customerName + "\"的客户名称；";
+            } else if (customerList.size() > 1) {
+                err += "全名或简称为\"" + customerName + "\"的客户名称维护多条；";
+            }else{
+                customer = customerList.get(0);
+            }
+
+            // 将传入的客户名称进行校验
+            Customer fk_compony = new Customer();
+            List<Customer> customerList2 = customerMapper.selectByNameCode(fk_compony_name,fk_compony_name,belongId);
+            if (customerList2.size() == 0){
+                err += "未找到全名或简称为\"" + fk_compony_name + "\"的客户名称；";
+            } else if (customerList2.size() > 1) {
+                err += "全名或简称为\"" + fk_compony_name + "\"的客户名称维护多条；";
+            }else{
+                fk_compony = customerList2.get(0);
+            }
+            store.setWare(ware);
+            store.setStack(stack);
+            store.setMaterial(material);
+            store.setCustomer(customer);
+            store.setFkComponyId(fk_compony.getId());
+            store.setLayer(Integer.parseInt(listJO.get(i).get("层号").toString()));
+            store.setPlateNo(listJO.get(i).get("产品编号").toString());
+            store.setModel(listJO.get(i).get("规格型号").toString());
+            store.setCount(Double.parseDouble(listJO.get(i).get("数量").toString()));
+            store.setWeight(Double.parseDouble(listJO.get(i).get("重量").toString()));
+            if (listJO.get(i).get("收货地址") != null && !listJO.get(i).get("收货地址").toString().equals("")) {
+                store.setReceiveAddress(listJO.get(i).get("收货地址").toString());
+            }
+
+            if(listJO.get(i).get("备注") != null && !listJO.get(i).get("备注").toString().equals("")){
+                store.setRemark(listJO.get(i).get("备注").toString());
+            }
+
+            store.setAddId(userId);
+            store.setAddTime(df2.parse(listJO.get(i).get("入库时间").toString()));
+            store.setCancelFlag("0");
+            store.setBelongId(belongId);
+            if(listJO.get(i).get("计量方式") != null && !listJO.get(i).get("计量方式").toString().equals("")){
+                store.setWgtDcnMtcCd(listJO.get(i).get("计量方式").toString());
+            }
+            if(listJO.get(i).get("产地") != null && !listJO.get(i).get("产地").toString().equals("")){
+                store.setProductionPlace(listJO.get(i).get("产地").toString());
+            }
+            if(listJO.get(i).get("合约号") != null && !listJO.get(i).get("合约号").toString().equals("")){
+                store.setContractNo(listJO.get(i).get("合约号").toString());
+            }
+            if(listJO.get(i).get("订单号") != null && !listJO.get(i).get("订单号").toString().equals("")){
+                store.setOrdNo(listJO.get(i).get("订单号").toString());
+            }
+            if(listJO.get(i).get("入库车号") != null && !listJO.get(i).get("入库车号").toString().equals("")){
+                store.setCarNo(listJO.get(i).get("入库车号").toString());
+            }
+            if(listJO.get(i).get("吊装工") != null && !listJO.get(i).get("吊装工").toString().equals("")){
+                store.setTallyPeople(listJO.get(i).get("吊装工").toString());
+            }
+            if(listJO.get(i).get("捆包号") != null && !listJO.get(i).get("捆包号").toString().equals("")){
+                store.setPackNo(listJO.get(i).get("捆包号").toString());
+            }
+            InRecord inRecord = getInRecord(store, "1", userId);
+            inRecord.setAddTime(df2.parse(listJO.get(i).get("入库时间").toString()));
+            num += inRecordMapper.insert(inRecord);
+
+            store.setOutFlag("0");
+            store.setLockFlag("0");
+            store.setOutId("");
+            store.setInId(inRecord.getId());
+            num += storeMapper.insert(store);
+
+            if(listJO.get(i).get("出库时间")!= null && !listJO.get(i).get("出库时间").equals("")){
+                Distribution isExist = distributionMapper.selectByDisNo(listJO.get(i).get("出库单号").toString(),belongId);
+                if (isExist == null) {
+                    distribution.setTruckNo(listJO.get(i).get("出库车号").toString());
+                    distribution.setAddId(userId);
+                    distribution.setAddTime(new Date());
+                    distribution.setOutFlag("1");
+                    distribution.setBelongId(belongId);
+                    distribution.setSumCount(store.getCount());
+                    distribution.setSumWeight(store.getWeight());
+                    num += distributionMapper.insert(distribution);
+                    DistributionDetail detail = getDistributionDetail(distribution, store, userId, belongId);
+                    num += distributionDetailMapper.insert(detail);
+                } else {
+                    distribution.setModifyId(userId);
+                    distribution.setModifyTime(new Date());
+                    distribution.setSumCount(distribution.getSumCount()+store.getCount());
+                    distribution.setSumWeight(distribution.getSumWeight()+store.getWeight());
+                    num += distributionMapper.updateByPrimaryKey(distribution);
+                    DistributionDetail detail = getDistributionDetail(distribution, store, userId, belongId);
+                    num += distributionDetailMapper.insert(detail);
+                }
+
+                OutRecord outRecord = getOutRecord(store, distribution.getId(), "1", userId);
+                outRecord.setAddTime(df2.parse(listJO.get(i).get("出库时间").toString()));
+                num += outRecordMapper.insert(outRecord);
+
+                store.setOutId(outRecord.getId());
+                store.setOutFlag("1");
+                store.setLockFlag("1");
+                num += storeMapper.updateByPrimaryKey(store);
+            }
+
+
+        }
+        result = Tools.moreThanZeroResultJSON(num);
+        return result;
+    }
+
     private List<Store> resortAndInsert(List<Store> listStore, String userId, String belongId) throws Exception {
         for (int i = 0; i < listStore.size(); i++) {
             Store temp = listStore.get(i);
         String standard = listJO.get(0).get("钢种").toString();
         String customerName = listJO.get(0).get("客户名称").toString();
         String fk_compony_name = listJO.get(0).get("货权单位").toString();
-        String addUserName = listJO.get(0).get("入库操作人员").toString();
         //验证信息增加多条信息验证
         Ware ware = wareMapper.selectByWareName(wareName, userId, belongId);
         if (ware == null) {
         return inRecord;
     }
 
+    private OutRecord getOutRecord(Store store, String distributionId, String recordType, String userId) {
+        OutRecord outRecord = new OutRecord();
+        outRecord.setWareName(store.getWare().getName());
+        outRecord.setStackName(store.getStack().getName());
+        outRecord.setLayer(store.getLayer());
+        outRecord.setMaterialName(store.getMaterial().getName());
+        outRecord.setStandard(store.getMaterial().getStandard());
+        outRecord.setModel(store.getModel());
+        outRecord.setCustomerName(store.getCustomer().getName());
+        if (recordType.equals("0")) {
+            outRecord.setCount(-1 * store.getCount());
+            outRecord.setWeight(-1 * store.getWeight());
+        } else {
+            outRecord.setCount(store.getCount());
+            outRecord.setWeight(store.getWeight());
+        }
+        if (recordType.equals("0")) {
+            outRecord.setCancelFlag("9");
+        } else {
+            outRecord.setCancelFlag("0");
+        }
+
+        outRecord.setPackNo(store.getPackNo());
+        outRecord.setContractNo(store.getContractNo());
+
+        outRecord.setRemark(store.getRemark());
+        outRecord.setBelongId(store.getBelongId());
+        outRecord.setPlateNo(store.getPlateNo());
+        outRecord.setAddUser(new SysUser(userId));
+        outRecord.setAddTime(new Date());
+        outRecord.setInId(store.getInId());
+        outRecord.setRecordType(recordType);
+        outRecord.setReceiveAddress(store.getReceiveAddress());
+        outRecord.setDistributionId(distributionId);
+
+        outRecord.setWgtDcnMtcCd(store.getWgtDcnMtcCd());
+        outRecord.setEdgeTy(store.getEdgeTy());
+        outRecord.setProductionPlace(store.getProductionPlace());
+        outRecord.setInvoicePrice(store.getInvoicePrice());
+        return outRecord;
+    }
 
+    public DistributionDetail getDistributionDetail(Distribution distribution, Store store, String userId, String belongId) {
+        DistributionDetail detail = new DistributionDetail();
+        detail.setDistributionId(distribution.getId());
+        detail.setStore(store);
+        detail.setAddId(userId);
+        detail.setAddTime(new Date());
+        detail.setCancelFlag("0");
+        detail.setBelongId(belongId);
+        return detail;
+    }
 }

src/main/java/com/th/demo/service/ware/InService.java

 package com.th.demo.service.ware;
 
+import java.text.ParseException;
+
 public interface InService {
     String in(String json, String userId, String belongId);
 
     String inImport(String json, String userId, String belongId) throws Exception;
 
     String back(String json, String userId, String belongId);
+
+    String inImportAll(String json, String userId, String belongId) throws ParseException;
 }

src/main/resource/localhost/db.properties

-jdbc.driverClass=com.mysql.jdbc.Driver
-jdbc.jdbcUrl=jdbc:mysql://172.18.200.32:3306/ware_zg?characterEncoding=utf8
-jdbc.user=root
-jdbc.password=root
-
 #jdbc.driverClass=com.mysql.jdbc.Driver
-#jdbc.jdbcUrl=jdbc:mysql://localhost:3306/ware_zg?characterEncoding=utf8
+#jdbc.jdbcUrl=jdbc:mysql://172.18.200.32:3306/ware_zg?characterEncoding=utf8
 #jdbc.user=root
 #jdbc.password=root
 
+jdbc.driverClass=com.mysql.jdbc.Driver
+jdbc.jdbcUrl=jdbc:mysql://localhost:3306/ware_zg?characterEncoding=utf8
+jdbc.user=root
+jdbc.password=root
+
 #jdbc.driverClass=com.mysql.jdbc.Driver
 #jdbc.jdbcUrl=jdbc:mysql://60.205.9.174:3309/ware_zg?useUnicode=true&characterEncoding=utf8
 #jdbc.user=root

src/main/resource/mapper/ware/DistributionMapper.xml

       cancel_flag = #{cancelFlag,jdbcType=VARCHAR},
       belong_id = #{belongId,jdbcType=VARCHAR},
       delivery_company = #{deliveryCompany,jdbcType=VARCHAR},
-      distribution_no =ifnull(distribution_no,(select dis_no from (select concat('BS',DATE_FORMAT(NOW(), '%Y%m%d'),IFNULL(lpad(max(substring(t.distribution_no,11,3)+1),3,'0'),'001')) as dis_no from t_ware_distribution t
+      distribution_no =ifnull(distribution_no,(select dis_no from (select concat('ZG',DATE_FORMAT(NOW(), '%Y%m%d'),IFNULL(lpad(max(substring(t.distribution_no,11,3)+1),3,'0'),'001')) as dis_no from t_ware_distribution t
 where substring(t.distribution_no,3,8) = DATE_FORMAT(NOW(), '%Y%m%d')) temp))
       ,tally_people    = #{tallyPeople,jdbcType=VARCHAR}
     where id = #{id,jdbcType=VARCHAR}
     order by t.add_time desc
   </select>
 
+  <select id="selectByDisNo" resultMap="BaseResultMap" >
+    select    t.*    from t_ware_distribution t
+    where  ifnull(t.out_flag,'0') = '0'
+      and t.distribution_no = #{param1,jdbcType=VARCHAR}
+      and t.belong_id = #{param2,jdbcType=VARCHAR}
+    order by t.add_time desc
+  </select>
+
 </mapper>