aa

business/jxstore/tempop/tempop.go

@@ -4,7 +4,8 @@ import (
 	"bytes"
 	"context"
 	"fmt"
-	"git.rosy.net.cn/baseapi/platformapi/jdshopapi"
+	"net"
+	"os"
 	"regexp"
 	"strings"
 	"time"
@@ -1944,25 +1945,44 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	//{"address":"成都市金牛区抚琴综合市场博力多超市旁边扶手楼梯上","cityName": "成都市","id": 100002,"name": "抚琴店-下单送盐","payeeName": "李川川","status": 1,"tel1": "13812641804","tel2": ""}
 	//`
 	//weixinmsg.SmartMessageTemplateSend("oYN_usv1RPvrSxCvo1WsbwI8lZa0", weixinmsg.WX_NEWORDER_TEMPLATE_ID, "", weixinmsg.WX_MINI_TO_ORDER_PAGE_URL+fmt.Sprintf("?jxStoreId=%v&data=%v", storeID, data), nil)
-	apiobj := jdshopapi.New("9ad9cf5fc8b140b19a1dbbb700b47676kown", "D5E8352BE0786ED16F77B4548F62F09A", "71e1061ac2f246f6ac27efb900edba12")
-	apiobj.SetCookieWithStr(`
-__jdu=16193999982702078345144; shshshfpa=972f47df-9252-dc1a-1d6d-40594ce0501b-1619400562; webp=1; visitkey=44137284214309276; shshshfp=4d574741223da61a369c18ce2febefe8; shshshfpb=msX4%202n384blCOGusOxGDvQ%3D%3D; unpl=V2_ZzNtbRUHSx19DENcKBtUBWIHEF4RU0MddVwVXCwYDAVkBRVVclRCFnUUR1NnGFQUZwcZXUZcQBFFCEdkeB5fA2AFEFlBZxBFLV0CFi9JH1c%2bbRFdS1NBFH0JRFB6Hmw1ZAMiXUNnQxJ1AERccxFUDGQFE15DUUoXcAxGUX4pbAJXMyJbQFdHE3I4R2R6KR5ROwQXW0RUQVh1D0ZceRFUDW8KEVtDVEITfApDUHscWTVmMxE%3d; __jdv=122270672|baidu-search|t_262767352_baidusearch|cpc|218530903506_0_fa999549b3914532b5191eb9f0a12769|1623222888351; language=zh_CN; csrf_token=ec042bf0-a91b-43c8-a814-826a1c4272c0; wlfstk_smdl=oyivhfpk5e48pbcg0x4ntgoucg83flf4; TrackID=1PpB7nDH0GvHsG8yyfdpnyWOnRYjxio_6Sb9R4DOIfOITwDV6Qzm2AzaWNl12iy4Rcv4OPdaZz6AIBUPOKGSCzZGzc14os7bnKdFv1toeyyo; thor=E6F66DF4AD3A159C1AE9872C7BB0CF4D5E2B8B9C52714A91A28E40CDCDB5FE53E5A70BFEAE6D31233A6A81AE5374CCBC7A6FFCD510DD2A410A450DA70B629E589891DEF251C4E5937763B9560B45AAC01B06702BB6AF0EFCE718417DF1965AF091E9FEED778E89BE7D8B35913844851698F9F28BF3F055B563E6C71A92C9D0C0CA06E44ABDC59ABF07F627B57A4D26AF609D26C23B77DC52E123264DB3D75778; pinId=qA40zQJfoxUJ0BznFrVelbV9-x-f3wj7; pin=jd_5e10f2d70fb4c; unick=jd_181600jgy; ceshi3.com=201; _tp=tPAwCz7dZ2wG9FcrXkvXEPcH%2FgU%2BK8r%2FxTPrJfx1wo8%3D; _pst=jd_5e10f2d70fb4c; _base_=YKH2KDFHMOZBLCUV7NSRBWQUJPBI7JIMU5R3EFJ5UDHJ5LCU7R2NILKK5UJ6GLA2RGYT464UKXAI5KK7PNC5B5UHJ2HVQ4ENFP57OC2NCIWTST4KDNCWZES6EV2TD5XDTCNE6YVKRXISVWNQHZDBO6QEKYXMXGPYGVEOCQCSG4SOQWCP5WPWO6EFS7HEHMRWVKBRVHB33TFD4AUHV3TOJD7MGBX53BNNP2E6MSSOORYGL5H2GYFRURR5ACFJ54GH7PTHFL22YL3C6ODFYFTWGV5UAWCX5C6J372TDCL6LDNEERERTGCUFQRPJPTFLQYXSNPUKPGJPJAJ3VQAQIWW3S2YBGSPJZVO3XPNMOJI6RFTJD5NXZUZMBDK4FVEVR2D; _vender_new_=GI63BGTJFDBQ4KTM333PMOGFGWX4LCRFBIKRUXSZIMQR2CGA7UT6QS3UEGOG3AKYDYGEWBDNK3CSWSNHPSPAMTCGLEQDVNM2LSUTLX2WZTSR5DRPDW7BAWFO3PG4STZEJAOUXLDT2T3C5NVIUAUPD2U4MRQMIY4EBHC2ZCUHI2DYIR7IPWFPH4NRSF55Y2TLDCL5FPL62OR6GGSGHUAIVHXQY756M4VPLLBPMLZYMXAWOY2XWQCXI6RB3XVDWHR6HDOD2SNRC5NX4DRRYOYE7UGG7BABNQEEPCBQTSQOAL4YL62WZATBEQTCPO7SYGSIS655JUGOUILFLXVZE6KCFG7ZTOQUVBLFYXBD66CRKS6VHV72EFJ73OOOFEPN3IJYUFFIKZOFYI7XQUKUXVJ5P6RBKMT2HE65DLUI22O6QKUCCZAY7XTGOTMC53TFUYERGNIH2RBULZ7UTZH5GU3TC6RWFI2QL4QTAIARA6GNVXENEOYIPZEHN222YDAJX5OBBEECAMAPNKZ3XL3SMPZDFFIQY2ZLOCAKLFPCYTJIXW5JXUDR6HR5QTERLDBVKLQE6FXEXLO4Z2MJ7SQW32AXQCKXK6QX5GP7FEOWREOUFJ4PU5XZPDXM62SHEAUIPF33J2F76Z2L4GSPJATDWVYI5C3Y54; AESKEY=248110CB26061826; QRCodeKEY=A8501C3FD5CD679C9C7D63B309D8D2FDED5E44703E70D785D0627044F06D7877EBB6CF72E6BE7DDA170B889D756F81B0; UIDKEY=98771548919883507; _BELONG_CLIENT_=WPSC4XJXWK5USS4JNZY2X7VRLR5MCBKRSVHEXABGTHDGISIQK5YOLZUXYE7IOIM7MOKO74H6CRN6WHAAR4TMDV3XZWMXZRCRT5XRNE3V356BTOB2Y7LPK66VWQK6HPTGWVXIDXDCPVE3W5WMHAIO6AT2LX2XXVNUCXR34ZWFK6HY45CORGIKOSYDYZBF27WOKTUX6BS4FZMIJWNUX6CB4JAA25ZLF7ZEKYOO4QV5HTSBXGNRM3E242MBI6V5D4C5VJDQ3EOYCOW5BMTUJZACIBHXQFAVLRF76VQY5PNJGGJNBEZHSFYYJA3YORRT7FB5AHCOIFQKF3W5RWNUX6CB4JAA26JNMO7AYWNUPZF5HTSBXGNRM3E242MBI6V5D4C5VJDQ3EOYCOW5BWZDKMOJ5BS6II53ERY6ALV3ZWPF42L4CPUHEGPYIII35KDC4FCNVCORCXFD6IVNLBEDPB2GGP4UHWNRUDOQBDIW7RZJXBA2WV5ANZOTEGUCDWYRVQS2YUTIZNZ276PRYG4N56V6YTII7MBKBC7LYHO7C555HTSBXGNRM3E466AYN67DHWVM5HQFJ4NFDO5BTUIU4VMZUEOGM4TXPS4CQVB3CAA; _vender_=TNK3O6PALVQGHZYSSOH7L4PZFUJZD5EGDHEKASUPSRGCBG35OWV7FH6M2DZVEM4VQIKK67XHM3QRQKOLBUAWJMFWJSXXHFGGRIGTHQ6KVOF3DXDVMS5KAV2WMFSCLQKS44AIXTUDOHJ5HAHXVAO5IYCMSVW2AR2ELYDWYXCOEDAM3KGKCC5XRMZNVD5KUU5CBJU6NP7WOAPPTYGXF6PEVUXKO74BCY77252VZBHAW5H7TA7PK4EJVL2N2DWNOIJVHZNX4BZQ7W244ZAYLAW7T2BAXU3PUXOFDWMSSK6EVOSLOGBZC5PIZVNDVDNJXP4G2S23NQFGX3NFYERPAKAKHS3GO6DKGR3KYMAGT5B6LN7AOMH5WXHCJZAENA6SMDSKCIYM3B25NWIYPAC4U3MBP2BDLIX6J6LYQ77R7LC2BHTT2LLD2OP4PFOB4CD3PMLLXPPMWIO2JJAVEEMLPVZZVEIWOFYZJJKXK2CUIHRGHCEFZSYYGZNEN73JJFNNORES; b-sec=2GBADPFJ55VHNAQ2DUPKR7Y2CEX6NF5ABOAAZC76RT6BMTFU655T23CCCVWHAOO3DFOOI3IR4ARJBD6NRWBX675VTE; __jda=48732324.16193999982702078345144.1619399998.1624272684.1624324139.12; __jdc=48732324; JSESSIONID=B4AD8AAA993FA4FBBD38B108E9FF713D.s1; __jdb=48732324.35.16193999982702078345144|12.1624324139; 3AB9D23F7A4B3C9B=CKENC5MAUU744ZQDKVRY2L7UIJ23PJRDYJ6HF3ZMQHC5FFD46FMUQXRINFCOC4SKHL5MU3PPNPP4C4AX5ZYBXJ7LZ4
-`)
-	var CreateShopCategoryParams = []*jdshopapi.CreateShopCategoryParam{
-		&jdshopapi.CreateShopCategoryParam{
-			HomeShow: "0",
-			ID:       "1",
-			Open:     "",
-			OrderNo:  "0",
-			ParentID: "",
-			Title:    "测试1",
-			Type:     "3",
-		},
+
+	server := "print.jxcs.net:8000"
+	tcpAddr, err := net.ResolveTCPAddr("tcp4", server)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
+		os.Exit(1)
 	}
-	apiobj.CreateShopCategory(CreateShopCategoryParams)
+	fmt.Println("tcpaddr", utils.Format4Output(tcpAddr, true))
+	conn, err := net.DialTCP("tcp", nil, tcpAddr)
+	if err != nil {
+		fmt.Println("Dial err:", err)
+		return
+	}
+	textChan = make(chan string, 10)
+	textChan <- "test"
+	connHandler(conn)
 	return err
 }
 
+var (
+	textChan chan string
+)
+
+func connHandler(c net.Conn) {
+	fmt.Println("Please input data...")
+	go func() {
+		for {
+			s := <-textChan
+			//写入数据
+			n, err := c.Write([]byte(s))
+			if err != nil {
+				fmt.Println("Write err:", err, n)
+				return
+			}
+		}
+	}()
+}
+
 func FreeBatchInfo2(name string, handler func(tasksch.ITask, []*jdapi.SkuIdEntity) (interface{}, int, error), ctx *jxcontext.Context, parentTask tasksch.ITask, storeSkuList []*jdapi.SkuIdEntity, batchSize int, isContinueWhenError bool) (resultList []interface{}, err error) {
 	task := tasksch.NewParallelTask2(fmt.Sprintf("FreeBatchInfo:%s", name), tasksch.NewParallelConfig().SetParallelCount(1).SetBatchSize(batchSize).SetIsContinueWhenError(isContinueWhenError), ctx,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {